DPDK 22.11.5
Functions
rte_graph_worker.h File Reference
#include <rte_compat.h>
#include <rte_common.h>
#include <rte_cycles.h>
#include <rte_prefetch.h>
#include <rte_memcpy.h>
#include <rte_memory.h>
#include "rte_graph.h"

Go to the source code of this file.

Functions

static __rte_experimental void rte_graph_walk (struct rte_graph *graph)
 
static __rte_experimental void rte_node_enqueue (struct rte_graph *graph, struct rte_node *node, rte_edge_t next, void **objs, uint16_t nb_objs)
 
static __rte_experimental void rte_node_enqueue_x1 (struct rte_graph *graph, struct rte_node *node, rte_edge_t next, void *obj)
 
static __rte_experimental void rte_node_enqueue_x2 (struct rte_graph *graph, struct rte_node *node, rte_edge_t next, void *obj0, void *obj1)
 
static __rte_experimental void rte_node_enqueue_x4 (struct rte_graph *graph, struct rte_node *node, rte_edge_t next, void *obj0, void *obj1, void *obj2, void *obj3)
 
static __rte_experimental void rte_node_enqueue_next (struct rte_graph *graph, struct rte_node *node, rte_edge_t *nexts, void **objs, uint16_t nb_objs)
 
static __rte_experimental void ** rte_node_next_stream_get (struct rte_graph *graph, struct rte_node *node, rte_edge_t next, uint16_t nb_objs)
 
static __rte_experimental void rte_node_next_stream_put (struct rte_graph *graph, struct rte_node *node, rte_edge_t next, uint16_t idx)
 
static __rte_experimental void rte_node_next_stream_move (struct rte_graph *graph, struct rte_node *src, rte_edge_t next)
 

Detailed Description

Warning
EXPERIMENTAL: All functions in this file may be changed or removed without prior notice.

This API allows a worker thread to walk over a graph and nodes to create, process, enqueue and move streams of objects to the next nodes.

Definition in file rte_graph_worker.h.

Function Documentation

◆ rte_graph_walk()

static __rte_experimental void rte_graph_walk ( struct rte_graph *  graph)
inlinestatic

Perform graph walk on the circular buffer and invoke the process function of the nodes and collect the stats.

Parameters
graphGraph pointer returned from rte_graph_lookup function.
See also
rte_graph_lookup()
Examples
examples/l3fwd-graph/main.c.

Definition at line 133 of file rte_graph_worker.h.

◆ rte_node_enqueue()

static __rte_experimental void rte_node_enqueue ( struct rte_graph *  graph,
struct rte_node *  node,
rte_edge_t  next,
void **  objs,
uint16_t  nb_objs 
)
inlinestatic

Enqueue the objs to next node for further processing and set the next node to pending state in the circular buffer.

Parameters
graphGraph pointer returned from rte_graph_lookup().
nodeCurrent node pointer.
nextRelative next node index to enqueue objs.
objsObjs to enqueue.
nb_objsNumber of objs to enqueue.

Definition at line 272 of file rte_graph_worker.h.

◆ rte_node_enqueue_x1()

static __rte_experimental void rte_node_enqueue_x1 ( struct rte_graph *  graph,
struct rte_node *  node,
rte_edge_t  next,
void *  obj 
)
inlinestatic

Enqueue only one obj to next node for further processing and set the next node to pending state in the circular buffer.

Parameters
graphGraph pointer returned from rte_graph_lookup().
nodeCurrent node pointer.
nextRelative next node index to enqueue objs.
objObj to enqueue.

Definition at line 299 of file rte_graph_worker.h.

◆ rte_node_enqueue_x2()

static __rte_experimental void rte_node_enqueue_x2 ( struct rte_graph *  graph,
struct rte_node *  node,
rte_edge_t  next,
void *  obj0,
void *  obj1 
)
inlinestatic

Enqueue only two objs to next node for further processing and set the next node to pending state in the circular buffer. Same as rte_node_enqueue_x1 but enqueue two objs.

Parameters
graphGraph pointer returned from rte_graph_lookup().
nodeCurrent node pointer.
nextRelative next node index to enqueue objs.
obj0Obj to enqueue.
obj1Obj to enqueue.

Definition at line 329 of file rte_graph_worker.h.

◆ rte_node_enqueue_x4()

static __rte_experimental void rte_node_enqueue_x4 ( struct rte_graph *  graph,
struct rte_node *  node,
rte_edge_t  next,
void *  obj0,
void *  obj1,
void *  obj2,
void *  obj3 
)
inlinestatic

Enqueue only four objs to next node for further processing and set the next node to pending state in the circular buffer. Same as rte_node_enqueue_x1 but enqueue four objs.

Parameters
graphGraph pointer returned from rte_graph_lookup().
nodeCurrent node pointer.
nextRelative next node index to enqueue objs.
obj01st obj to enqueue.
obj12nd obj to enqueue.
obj23rd obj to enqueue.
obj34th obj to enqueue.

Definition at line 364 of file rte_graph_worker.h.

◆ rte_node_enqueue_next()

static __rte_experimental void rte_node_enqueue_next ( struct rte_graph *  graph,
struct rte_node *  node,
rte_edge_t nexts,
void **  objs,
uint16_t  nb_objs 
)
inlinestatic

Enqueue objs to multiple next nodes for further processing and set the next nodes to pending state in the circular buffer. objs[i] will be enqueued to nexts[i].

Parameters
graphGraph pointer returned from rte_graph_lookup().
nodeCurrent node pointer.
nextsList of relative next node indices to enqueue objs.
objsList of objs to enqueue.
nb_objsNumber of objs to enqueue.

Definition at line 398 of file rte_graph_worker.h.

◆ rte_node_next_stream_get()

static __rte_experimental void ** rte_node_next_stream_get ( struct rte_graph *  graph,
struct rte_node *  node,
rte_edge_t  next,
uint16_t  nb_objs 
)
inlinestatic

Get the stream of next node to enqueue the objs. Once done with the updating the objs, needs to call rte_node_next_stream_put to put the next node to pending state.

Parameters
graphGraph pointer returned from rte_graph_lookup().
nodeCurrent node pointer.
nextRelative next node index to get stream.
nb_objsRequested free size of the next stream.
Returns
Valid next stream on success.
See also
rte_node_next_stream_put().

Definition at line 428 of file rte_graph_worker.h.

◆ rte_node_next_stream_put()

static __rte_experimental void rte_node_next_stream_put ( struct rte_graph *  graph,
struct rte_node *  node,
rte_edge_t  next,
uint16_t  idx 
)
inlinestatic

Put the next stream to pending state in the circular buffer for further processing. Should be invoked after rte_node_next_stream_get().

Parameters
graphGraph pointer returned from rte_graph_lookup().
nodeCurrent node pointer.
nextRelative next node index..
idxNumber of objs updated in the stream after getting the stream using rte_node_next_stream_get.
See also
rte_node_next_stream_get().

Definition at line 459 of file rte_graph_worker.h.

◆ rte_node_next_stream_move()

static __rte_experimental void rte_node_next_stream_move ( struct rte_graph *  graph,
struct rte_node *  src,
rte_edge_t  next 
)
inlinestatic

Home run scenario, Enqueue all the objs of current node to next node in optimized way by swapping the streams of both nodes. Performs good when next node is already not in pending state. If next node is already in pending state then normal enqueue will be used.

Parameters
graphGraph pointer returned from rte_graph_lookup().
srcCurrent node pointer.
nextRelative next node index.

Definition at line 488 of file rte_graph_worker.h.