77edede86f
Add rte_node ethdev_tx process function and register it to graph infra. This node has a specific (port, tx-queue) as context and it enqueue's all the packets received to that specific queue pair. When rte_eth_tx_burst() i.e enqueue to queue pair fails, packets are forwarded to pkt_drop node to be free'd. Signed-off-by: Nithin Dabilpuram <ndabilpuram@marvell.com> Signed-off-by: Pavan Nikhilesh <pbhagavatula@marvell.com> Signed-off-by: Kiran Kumar K <kirankumark@marvell.com>
87 lines
1.8 KiB
C
87 lines
1.8 KiB
C
/* SPDX-License-Identifier: BSD-3-Clause
|
|
* Copyright(C) 2020 Marvell International Ltd.
|
|
*/
|
|
|
|
#include <rte_debug.h>
|
|
#include <rte_ethdev.h>
|
|
#include <rte_graph.h>
|
|
#include <rte_graph_worker.h>
|
|
#include <rte_mbuf.h>
|
|
|
|
#include "ethdev_tx_priv.h"
|
|
|
|
static struct ethdev_tx_node_main ethdev_tx_main;
|
|
|
|
static uint16_t
|
|
ethdev_tx_node_process(struct rte_graph *graph, struct rte_node *node,
|
|
void **objs, uint16_t nb_objs)
|
|
{
|
|
ethdev_tx_node_ctx_t *ctx = (ethdev_tx_node_ctx_t *)node->ctx;
|
|
uint16_t port, queue;
|
|
uint16_t count;
|
|
|
|
/* Get Tx port id */
|
|
port = ctx->port;
|
|
queue = ctx->queue;
|
|
|
|
count = rte_eth_tx_burst(port, queue, (struct rte_mbuf **)objs,
|
|
nb_objs);
|
|
|
|
/* Redirect unsent pkts to drop node */
|
|
if (count != nb_objs) {
|
|
rte_node_enqueue(graph, node, ETHDEV_TX_NEXT_PKT_DROP,
|
|
&objs[count], nb_objs - count);
|
|
}
|
|
|
|
return count;
|
|
}
|
|
|
|
static int
|
|
ethdev_tx_node_init(const struct rte_graph *graph, struct rte_node *node)
|
|
{
|
|
ethdev_tx_node_ctx_t *ctx = (ethdev_tx_node_ctx_t *)node->ctx;
|
|
uint64_t port_id = RTE_MAX_ETHPORTS;
|
|
int i;
|
|
|
|
/* Find our port id */
|
|
for (i = 0; i < RTE_MAX_ETHPORTS; i++) {
|
|
if (ethdev_tx_main.nodes[i] == node->id) {
|
|
port_id = i;
|
|
break;
|
|
}
|
|
}
|
|
RTE_VERIFY(port_id < RTE_MAX_ETHPORTS);
|
|
|
|
/* Update port and queue */
|
|
ctx->port = port_id;
|
|
ctx->queue = graph->id;
|
|
|
|
return 0;
|
|
}
|
|
|
|
struct ethdev_tx_node_main *
|
|
ethdev_tx_node_data_get(void)
|
|
{
|
|
return ðdev_tx_main;
|
|
}
|
|
|
|
static struct rte_node_register ethdev_tx_node_base = {
|
|
.process = ethdev_tx_node_process,
|
|
.name = "ethdev_tx",
|
|
|
|
.init = ethdev_tx_node_init,
|
|
|
|
.nb_edges = ETHDEV_TX_NEXT_MAX,
|
|
.next_nodes = {
|
|
[ETHDEV_TX_NEXT_PKT_DROP] = "pkt_drop",
|
|
},
|
|
};
|
|
|
|
struct rte_node_register *
|
|
ethdev_tx_node_get(void)
|
|
{
|
|
return ðdev_tx_node_base;
|
|
}
|
|
|
|
RTE_NODE_REGISTER(ethdev_tx_node_base);
|