[PATCH v5 1/3] node: support to add next node to ethdev Rx node
Rakesh Kudurumalla
rkudurumalla at marvell.com
Fri Dec 15 10:15:49 CET 2023
By default all packets received on ethdev_rx node
is forwarded to pkt_cls node.This patch provides
library support to add a new node as next node to
ethdev_rx node and forward packet to new node from
rx node.
Signed-off-by: Rakesh Kudurumalla <rkudurumalla at marvell.com>
---
V5: Addressed comments
Handled negative test case
lib/node/ethdev_ctrl.c | 48 +++++++++++++++++++++++++++++++++++++
lib/node/rte_node_eth_api.h | 18 ++++++++++++++
lib/node/version.map | 3 +++
3 files changed, 69 insertions(+)
diff --git a/lib/node/ethdev_ctrl.c b/lib/node/ethdev_ctrl.c
index d564b80e37..b886d2fe32 100644
--- a/lib/node/ethdev_ctrl.c
+++ b/lib/node/ethdev_ctrl.c
@@ -3,6 +3,7 @@
*/
#include <stdlib.h>
+#include <errno.h>
#include <rte_ethdev.h>
#include <rte_graph.h>
@@ -129,3 +130,50 @@ rte_node_eth_config(struct rte_node_ethdev_config *conf, uint16_t nb_confs,
ctrl.nb_graphs = nb_graphs;
return 0;
}
+
+int
+rte_node_ethdev_rx_next_update(rte_node_t id, const char *edge_name)
+{
+ struct ethdev_rx_node_main *data;
+ ethdev_rx_node_elem_t *elem;
+ char **next_nodes;
+ int rc = -EINVAL;
+ uint32_t count;
+ uint16_t i = 0;
+
+ if (edge_name == NULL)
+ goto exit;
+
+ count = rte_node_edge_get(id, NULL);
+
+ if (count == RTE_NODE_ID_INVALID)
+ goto exit;
+
+ next_nodes = malloc(count);
+ if (next_nodes == NULL) {
+ rc = -ENOMEM;
+ goto exit;
+ }
+
+ count = rte_node_edge_get(id, next_nodes);
+
+ while (next_nodes[i] != NULL && i < count) {
+ if (strcmp(edge_name, next_nodes[i]) == 0) {
+ data = ethdev_rx_get_node_data_get();
+ elem = data->head;
+ while (elem->next != data->head) {
+ if (elem->nid == id) {
+ elem->ctx.cls_next = i;
+ rc = 0;
+ goto found;
+ }
+ elem = elem->next;
+ }
+ }
+ i++;
+ }
+found:
+ free(next_nodes);
+exit:
+ return rc;
+}
diff --git a/lib/node/rte_node_eth_api.h b/lib/node/rte_node_eth_api.h
index eaae50772d..5b5ca491dc 100644
--- a/lib/node/rte_node_eth_api.h
+++ b/lib/node/rte_node_eth_api.h
@@ -23,6 +23,7 @@ extern "C" {
#include <rte_compat.h>
#include <rte_common.h>
#include <rte_mempool.h>
+#include <rte_graph.h>
/**
* Port config for ethdev_rx and ethdev_tx node.
@@ -57,6 +58,23 @@ struct rte_node_ethdev_config {
*/
int rte_node_eth_config(struct rte_node_ethdev_config *cfg,
uint16_t cnt, uint16_t nb_graphs);
+
+/**
+ * Update ethdev rx next node.
+ *
+ * @param id
+ * Node id whose edge is to be updated.
+ * @param edge_name
+ * Name of the next node.
+ *
+ * @return
+ * ENINVAL: Either of input parameters are invalid
+ * ENOMEM: If memory allocation failed
+ * 0 on successful initialization.
+ */
+__rte_experimental
+int rte_node_ethdev_rx_next_update(rte_node_t id, const char *edge_name);
+
#ifdef __cplusplus
}
#endif
diff --git a/lib/node/version.map b/lib/node/version.map
index 99ffcdd414..6bdb944c4c 100644
--- a/lib/node/version.map
+++ b/lib/node/version.map
@@ -19,4 +19,7 @@ EXPERIMENTAL {
rte_node_ip4_reassembly_configure;
rte_node_udp4_dst_port_add;
rte_node_udp4_usr_node_add;
+
+ # added in 24.03
+ rte_node_ethdev_rx_next_update;
};
--
2.25.1
More information about the dev
mailing list