Added option in graph create to call feature-specific process node
functions. This removes extra overhead for checking feature arc status
in nodes where application is not using feature arc processing

Signed-off-by: Pavan Nikhilesh <pbhagavat...@marvell.com>
Signed-off-by: Nitin Saxena <nsax...@marvell.com>
---
 doc/guides/rel_notes/release_24_11.rst | 3 +++
 lib/graph/graph.c                      | 1 +
 lib/graph/graph_populate.c             | 7 ++++++-
 lib/graph/graph_private.h              | 3 +++
 lib/graph/node.c                       | 2 ++
 lib/graph/rte_graph.h                  | 3 +++
 6 files changed, 18 insertions(+), 1 deletion(-)

diff --git a/doc/guides/rel_notes/release_24_11.rst 
b/doc/guides/rel_notes/release_24_11.rst
index d6d64518e0..5195badf54 100644
--- a/doc/guides/rel_notes/release_24_11.rst
+++ b/doc/guides/rel_notes/release_24_11.rst
@@ -122,6 +122,9 @@ ABI Changes
    Also, make sure to start the actual text at the margin.
    =======================================================
 
+* graph: Added new `feature_arc_enable` parameter in `struct rte_graph_param` 
to
+  allow `rte_graph_walk()` call `feat_arc_proc` node callback function, if it
+  is provided in node registration
 
 Known Issues
 ------------
diff --git a/lib/graph/graph.c b/lib/graph/graph.c
index d5b8c9f918..b0ad3a83ae 100644
--- a/lib/graph/graph.c
+++ b/lib/graph/graph.c
@@ -455,6 +455,7 @@ rte_graph_create(const char *name, struct rte_graph_param 
*prm)
        graph->parent_id = RTE_GRAPH_ID_INVALID;
        graph->lcore_id = RTE_MAX_LCORE;
        graph->num_pkt_to_capture = prm->num_pkt_to_capture;
+       graph->feature_arc_enabled = prm->feature_arc_enable;
        if (prm->pcap_filename)
                rte_strscpy(graph->pcap_filename, prm->pcap_filename, 
RTE_GRAPH_PCAP_FILE_SZ);
 
diff --git a/lib/graph/graph_populate.c b/lib/graph/graph_populate.c
index ed596a7711..5d8aa7b903 100644
--- a/lib/graph/graph_populate.c
+++ b/lib/graph/graph_populate.c
@@ -79,8 +79,13 @@ graph_nodes_populate(struct graph *_graph)
                if (graph_pcap_is_enable()) {
                        node->process = graph_pcap_dispatch;
                        node->original_process = graph_node->node->process;
-               } else
+                       if (_graph->feature_arc_enabled && 
graph_node->node->feat_arc_proc)
+                               node->original_process = 
graph_node->node->feat_arc_proc;
+               } else {
                        node->process = graph_node->node->process;
+                       if (_graph->feature_arc_enabled && 
graph_node->node->feat_arc_proc)
+                               node->process = graph_node->node->feat_arc_proc;
+               }
                memcpy(node->name, graph_node->node->name, RTE_GRAPH_NAMESIZE);
                pid = graph_node->node->parent_id;
                if (pid != RTE_NODE_ID_INVALID) { /* Cloned node */
diff --git a/lib/graph/graph_private.h b/lib/graph/graph_private.h
index d557d55f2d..58ba0abeff 100644
--- a/lib/graph/graph_private.h
+++ b/lib/graph/graph_private.h
@@ -56,6 +56,7 @@ struct node {
        unsigned int lcore_id;
        /**< Node runs on the Lcore ID used for mcore dispatch model. */
        rte_node_process_t process;   /**< Node process function. */
+       rte_node_process_t feat_arc_proc; /**< Node feature-arch process 
function. */
        rte_node_init_t init;         /**< Node init function. */
        rte_node_fini_t fini;         /**< Node fini function. */
        rte_node_t id;                /**< Allocated identifier for the node. */
@@ -126,6 +127,8 @@ struct graph {
        /**< Number of packets to be captured per core. */
        char pcap_filename[RTE_GRAPH_PCAP_FILE_SZ];
        /**< pcap file name/path. */
+       uint8_t feature_arc_enabled;
+       /**< Graph feature arc. */
        STAILQ_HEAD(gnode_list, graph_node) node_list;
        /**< Nodes in a graph. */
 };
diff --git a/lib/graph/node.c b/lib/graph/node.c
index 99a9622779..d8fd273543 100644
--- a/lib/graph/node.c
+++ b/lib/graph/node.c
@@ -90,6 +90,7 @@ __rte_node_register(const struct rte_node_register *reg)
                goto free;
        node->flags = reg->flags;
        node->process = reg->process;
+       node->feat_arc_proc = reg->feat_arc_proc;
        node->init = reg->init;
        node->fini = reg->fini;
        node->nb_edges = reg->nb_edges;
@@ -137,6 +138,7 @@ node_clone(struct node *node, const char *name)
        /* Clone the source node */
        reg->flags = node->flags;
        reg->process = node->process;
+       reg->feat_arc_proc = node->feat_arc_proc;
        reg->init = node->init;
        reg->fini = node->fini;
        reg->nb_edges = node->nb_edges;
diff --git a/lib/graph/rte_graph.h b/lib/graph/rte_graph.h
index ecfec2068a..1a3bd7e1ba 100644
--- a/lib/graph/rte_graph.h
+++ b/lib/graph/rte_graph.h
@@ -172,6 +172,8 @@ struct rte_graph_param {
                        uint32_t mp_capacity; /**< Capacity of memory pool for 
dispatch model. */
                } dispatch;
        };
+
+       bool feature_arc_enable; /**< Enable Graph feature arc. */
 };
 
 /**
@@ -470,6 +472,7 @@ struct rte_node_register {
        uint64_t flags;               /**< Node configuration flag. */
 #define RTE_NODE_SOURCE_F (1ULL << 0) /**< Node type is source. */
        rte_node_process_t process; /**< Node process function. */
+       rte_node_process_t feat_arc_proc; /**< Node feature-arch process 
function. */
        rte_node_init_t init;       /**< Node init function. */
        rte_node_fini_t fini;       /**< Node fini function. */
        rte_node_t id;              /**< Node Identifier. */
-- 
2.43.0

Reply via email to