lib: reduce memory allocation when processing large config transactions

Remove the xpath field from the nb_config_cb structure in order
to reduce its size. This allows the northbound to spend less time
allocating memory during the processing of large configuration
transactions.

To make this work, use yang_dnode_get_path() to obtain the xpath
from the dnode field whenever necessary.

Signed-off-by: Renato Westphal <renato@opensourcerouting.org>

diff --git a/lib/northbound.c b/lib/northbound.c
index a3b75d5c89ab51f47f606c3ce0a48540357e0767..debd46362483364e5595c5fec8a9aba9725f0039 100644 (file)
--- a/lib/northbound.c
+++ b/lib/northbound.c
@@ -381,7 +381,6 @@ static void nb_config_diff_add_change(struct nb_config_cbs *changes,
        change->cb.seq = *seq;
        *seq = *seq + 1;
        change->cb.nb_node = dnode->schema->priv;
-       yang_dnode_get_path(dnode, change->cb.xpath, sizeof(change->cb.xpath));
        change->cb.dnode = dnode;
 
        RB_INSERT(nb_config_cbs, changes, &change->cb);
@@ -810,7 +809,7 @@ static int nb_callback_configuration(const enum nb_event event,
                                     struct nb_config_change *change)
 {
        enum nb_operation operation = change->cb.operation;
-       const char *xpath = change->cb.xpath;
+       char xpath[XPATH_MAXLEN];
        const struct nb_node *nb_node = change->cb.nb_node;
        const struct lyd_node *dnode = change->cb.dnode;
        union nb_resource *resource;
@@ -822,6 +821,7 @@ static int nb_callback_configuration(const enum nb_event event,
                if (dnode && !yang_snode_is_typeless_data(dnode->schema))
                        value = yang_dnode_get_string(dnode, NULL);
 
+               yang_dnode_get_path(dnode, xpath, sizeof(xpath));
                nb_log_callback(event, operation, xpath, value);
        }
 
@@ -844,6 +844,7 @@ static int nb_callback_configuration(const enum nb_event event,
                ret = (*nb_node->cbs.move)(event, dnode);
                break;
        default:
+               yang_dnode_get_path(dnode, xpath, sizeof(xpath));
                flog_err(EC_LIB_DEVELOPMENT,
                         "%s: unknown operation (%u) [xpath %s]", __func__,
                         operation, xpath);
@@ -854,6 +855,8 @@ static int nb_callback_configuration(const enum nb_event event,
                int priority;
                enum lib_log_refs ref;
 
+               yang_dnode_get_path(dnode, xpath, sizeof(xpath));
+
                switch (event) {
                case NB_EV_VALIDATE:
                        priority = LOG_WARNING;
@@ -1024,14 +1027,12 @@ static int nb_transaction_process(enum nb_event event,
 }
 
 static struct nb_config_cb *
-nb_apply_finish_cb_new(struct nb_config_cbs *cbs, const char *xpath,
-                      const struct nb_node *nb_node,
+nb_apply_finish_cb_new(struct nb_config_cbs *cbs, const struct nb_node *nb_node,
                       const struct lyd_node *dnode)
 {
        struct nb_config_cb *cb;
 
        cb = XCALLOC(MTYPE_TMP, sizeof(*cb));
-       strlcpy(cb->xpath, xpath, sizeof(cb->xpath));
        cb->nb_node = nb_node;
        cb->dnode = dnode;
        RB_INSERT(nb_config_cbs, cbs, cb);
@@ -1057,6 +1058,7 @@ static void nb_transaction_apply_finish(struct nb_transaction *transaction)
 {
        struct nb_config_cbs cbs;
        struct nb_config_cb *cb;
+       char xpath[XPATH_MAXLEN];
 
        /* Initialize tree of 'apply_finish' callbacks. */
        RB_INIT(nb_config_cbs, &cbs);
@@ -1073,8 +1075,6 @@ static void nb_transaction_apply_finish(struct nb_transaction *transaction)
                 * be called though).
                 */
                if (change->cb.operation == NB_OP_DESTROY) {
-                       char xpath[XPATH_MAXLEN];
-
                        dnode = dnode->parent;
                        if (!dnode)
                                break;
@@ -1090,7 +1090,6 @@ static void nb_transaction_apply_finish(struct nb_transaction *transaction)
                                               xpath);
                }
                while (dnode) {
-                       char xpath[XPATH_MAXLEN];
                        struct nb_node *nb_node;
 
                        nb_node = dnode->schema->priv;
@@ -1101,11 +1100,10 @@ static void nb_transaction_apply_finish(struct nb_transaction *transaction)
                         * Don't call the callback more than once for the same
                         * data node.
                         */
-                       yang_dnode_get_path(dnode, xpath, sizeof(xpath));
                        if (nb_apply_finish_cb_find(&cbs, nb_node, dnode))
                                goto next;
 
-                       nb_apply_finish_cb_new(&cbs, xpath, nb_node, dnode);
+                       nb_apply_finish_cb_new(&cbs, nb_node, dnode);
 
                next:
                        dnode = dnode->parent;
@@ -1114,9 +1112,11 @@ static void nb_transaction_apply_finish(struct nb_transaction *transaction)
 
        /* Call the 'apply_finish' callbacks, sorted by their priorities. */
        RB_FOREACH (cb, nb_config_cbs, &cbs) {
-               if (DEBUG_MODE_CHECK(&nb_dbg_cbs_config, DEBUG_MODE_ALL))
-                       nb_log_callback(NB_EV_APPLY, NB_OP_APPLY_FINISH,
-                                       cb->xpath, NULL);
+               if (DEBUG_MODE_CHECK(&nb_dbg_cbs_config, DEBUG_MODE_ALL)) {
+                       yang_dnode_get_path(cb->dnode, xpath, sizeof(xpath));
+                       nb_log_callback(NB_EV_APPLY, NB_OP_APPLY_FINISH, xpath,
+                                       NULL);
+               }
 
                (*cb->nb_node->cbs.apply_finish)(cb->dnode);
        }

diff --git a/lib/northbound.h b/lib/northbound.h
index fbd7771db74813a768ce8a403c4be39037f96897..f52fcc90cf08b23d2f6b10267726e5263c7f7209 100644 (file)
--- a/lib/northbound.h
+++ b/lib/northbound.h
@@ -458,7 +458,6 @@ struct nb_config_cb {
        RB_ENTRY(nb_config_cb) entry;
        enum nb_operation operation;
        uint32_t seq;
-       char xpath[XPATH_MAXLEN];
        const struct nb_node *nb_node;
        const struct lyd_node *dnode;
 };