DPDK  20.11.10
Functions
rte_ring.h File Reference
#include <rte_ring_core.h>
#include <rte_ring_elem.h>

Go to the source code of this file.

Functions

ssize_t rte_ring_get_memsize (unsigned int count)
 
int rte_ring_init (struct rte_ring *r, const char *name, unsigned int count, unsigned int flags)
 
struct rte_ringrte_ring_create (const char *name, unsigned int count, int socket_id, unsigned int flags)
 
void rte_ring_free (struct rte_ring *r)
 
void rte_ring_dump (FILE *f, const struct rte_ring *r)
 
static __rte_always_inline unsigned int rte_ring_mp_enqueue_bulk (struct rte_ring *r, void *const *obj_table, unsigned int n, unsigned int *free_space)
 
static __rte_always_inline unsigned int rte_ring_sp_enqueue_bulk (struct rte_ring *r, void *const *obj_table, unsigned int n, unsigned int *free_space)
 
static __rte_always_inline unsigned int rte_ring_enqueue_bulk (struct rte_ring *r, void *const *obj_table, unsigned int n, unsigned int *free_space)
 
static __rte_always_inline int rte_ring_mp_enqueue (struct rte_ring *r, void *obj)
 
static __rte_always_inline int rte_ring_sp_enqueue (struct rte_ring *r, void *obj)
 
static __rte_always_inline int rte_ring_enqueue (struct rte_ring *r, void *obj)
 
static __rte_always_inline unsigned int rte_ring_mc_dequeue_bulk (struct rte_ring *r, void **obj_table, unsigned int n, unsigned int *available)
 
static __rte_always_inline unsigned int rte_ring_sc_dequeue_bulk (struct rte_ring *r, void **obj_table, unsigned int n, unsigned int *available)
 
static __rte_always_inline unsigned int rte_ring_dequeue_bulk (struct rte_ring *r, void **obj_table, unsigned int n, unsigned int *available)
 
static __rte_always_inline int rte_ring_mc_dequeue (struct rte_ring *r, void **obj_p)
 
static __rte_always_inline int rte_ring_sc_dequeue (struct rte_ring *r, void **obj_p)
 
static __rte_always_inline int rte_ring_dequeue (struct rte_ring *r, void **obj_p)
 
void rte_ring_reset (struct rte_ring *r)
 
static unsigned int rte_ring_count (const struct rte_ring *r)
 
static unsigned int rte_ring_free_count (const struct rte_ring *r)
 
static int rte_ring_full (const struct rte_ring *r)
 
static int rte_ring_empty (const struct rte_ring *r)
 
static unsigned int rte_ring_get_size (const struct rte_ring *r)
 
static unsigned int rte_ring_get_capacity (const struct rte_ring *r)
 
static enum rte_ring_sync_type rte_ring_get_prod_sync_type (const struct rte_ring *r)
 
static int rte_ring_is_prod_single (const struct rte_ring *r)
 
static enum rte_ring_sync_type rte_ring_get_cons_sync_type (const struct rte_ring *r)
 
static int rte_ring_is_cons_single (const struct rte_ring *r)
 
void rte_ring_list_dump (FILE *f)
 
struct rte_ringrte_ring_lookup (const char *name)
 
static __rte_always_inline unsigned int rte_ring_mp_enqueue_burst (struct rte_ring *r, void *const *obj_table, unsigned int n, unsigned int *free_space)
 
static __rte_always_inline unsigned int rte_ring_sp_enqueue_burst (struct rte_ring *r, void *const *obj_table, unsigned int n, unsigned int *free_space)
 
static __rte_always_inline unsigned int rte_ring_enqueue_burst (struct rte_ring *r, void *const *obj_table, unsigned int n, unsigned int *free_space)
 
static __rte_always_inline unsigned int rte_ring_mc_dequeue_burst (struct rte_ring *r, void **obj_table, unsigned int n, unsigned int *available)
 
static __rte_always_inline unsigned int rte_ring_sc_dequeue_burst (struct rte_ring *r, void **obj_table, unsigned int n, unsigned int *available)
 
static __rte_always_inline unsigned int rte_ring_dequeue_burst (struct rte_ring *r, void **obj_table, unsigned int n, unsigned int *available)
 

Detailed Description

RTE Ring

The Ring Manager is a fixed-size queue, implemented as a table of pointers. Head and tail pointers are modified atomically, allowing concurrent access to it. It has the following features:

Note: the ring implementation is not preemptible. Refer to Programmer's guide/Environment Abstraction Layer/Multiple pthread/Known Issues/rte_ring for more information.

Definition in file rte_ring.h.

Function Documentation

◆ rte_ring_get_memsize()

ssize_t rte_ring_get_memsize ( unsigned int  count)

Calculate the memory size needed for a ring

This function returns the number of bytes needed for a ring, given the number of elements in it. This value is the sum of the size of the structure rte_ring and the size of the memory needed by the objects pointers. The value is aligned to a cache line size.

Parameters
countThe number of elements in the ring (must be a power of 2).
Returns
  • The memory size needed for the ring on success.
  • -EINVAL if count is not a power of 2.

◆ rte_ring_init()

int rte_ring_init ( struct rte_ring r,
const char *  name,
unsigned int  count,
unsigned int  flags 
)

Initialize a ring structure.

Initialize a ring structure in memory pointed by "r". The size of the memory area must be large enough to store the ring structure and the object table. It is advised to use rte_ring_get_memsize() to get the appropriate size.

The ring size is set to count, which must be a power of two. The real usable ring size is count-1 instead of count to differentiate a full ring from an empty ring.

The ring is not added in RTE_TAILQ_RING global list. Indeed, the memory given by the caller may not be shareable among dpdk processes.

Parameters
rThe pointer to the ring structure followed by the objects table.
nameThe name of the ring.
countThe number of elements in the ring (must be a power of 2).
flagsAn OR of the following:
Returns
0 on success, or a negative value on error.

◆ rte_ring_create()

struct rte_ring* rte_ring_create ( const char *  name,
unsigned int  count,
int  socket_id,
unsigned int  flags 
)

Create a new ring named name in memory.

This function uses memzone_reserve() to allocate memory. Then it calls rte_ring_init() to initialize an empty ring.

The new ring size is set to count, which must be a power of two. The real usable ring size is count-1 instead of count to differentiate a full ring from an empty ring.

The ring is added in RTE_TAILQ_RING list.

Parameters
nameThe name of the ring.
countThe size of the ring (must be a power of 2).
socket_idThe socket_id argument is the socket identifier in case of NUMA. The value can be SOCKET_ID_ANY if there is no NUMA constraint for the reserved zone.
flagsAn OR of the following:
Returns
On success, the pointer to the new allocated ring. NULL on error with rte_errno set appropriately. Possible errno values include:
  • E_RTE_NO_CONFIG - function could not get pointer to rte_config structure
  • EINVAL - count provided is not a power of 2
  • ENOSPC - the maximum number of memzones has already been allocated
  • EEXIST - a memzone with the same name already exists
  • ENOMEM - no appropriate memory area found in which to create memzone
Examples:
examples/bbdev_app/main.c, examples/distributor/main.c, examples/ioat/ioatfwd.c, examples/ip_pipeline/pipeline.c, examples/ip_pipeline/swq.c, examples/ip_pipeline/thread.c, examples/multi_process/client_server_mp/mp_server/init.c, examples/multi_process/simple_mp/main.c, examples/packet_ordering/main.c, examples/performance-thread/common/lthread_tls.c, examples/performance-thread/l3fwd-thread/main.c, examples/pipeline/thread.c, examples/qos_sched/init.c, and examples/server_node_efd/server/init.c.

◆ rte_ring_free()

void rte_ring_free ( struct rte_ring r)

De-allocate all memory used by the ring.

Parameters
rRing to free
Examples:
examples/ioat/ioatfwd.c, examples/ip_pipeline/pipeline.c, examples/ip_pipeline/swq.c, examples/ip_pipeline/thread.c, and examples/pipeline/thread.c.

◆ rte_ring_dump()

void rte_ring_dump ( FILE *  f,
const struct rte_ring r 
)

Dump the status of the ring to a file.

Parameters
fA pointer to a file for output
rA pointer to the ring structure.

◆ rte_ring_mp_enqueue_bulk()

static __rte_always_inline unsigned int rte_ring_mp_enqueue_bulk ( struct rte_ring r,
void *const *  obj_table,
unsigned int  n,
unsigned int *  free_space 
)
static

Enqueue several objects on the ring (multi-producers safe).

This function uses a "compare and set" instruction to move the producer index atomically.

Parameters
rA pointer to the ring structure.
obj_tableA pointer to a table of void * pointers (objects).
nThe number of objects to add in the ring from the obj_table.
free_spaceif non-NULL, returns the amount of space in the ring after the enqueue operation has finished.
Returns
The number of objects enqueued, either 0 or n

Definition at line 210 of file rte_ring.h.

◆ rte_ring_sp_enqueue_bulk()

static __rte_always_inline unsigned int rte_ring_sp_enqueue_bulk ( struct rte_ring r,
void *const *  obj_table,
unsigned int  n,
unsigned int *  free_space 
)
static

Enqueue several objects on a ring (NOT multi-producers safe).

Parameters
rA pointer to the ring structure.
obj_tableA pointer to a table of void * pointers (objects).
nThe number of objects to add in the ring from the obj_table.
free_spaceif non-NULL, returns the amount of space in the ring after the enqueue operation has finished.
Returns
The number of objects enqueued, either 0 or n
Examples:
examples/qos_sched/app_thread.c.

Definition at line 233 of file rte_ring.h.

◆ rte_ring_enqueue_bulk()

static __rte_always_inline unsigned int rte_ring_enqueue_bulk ( struct rte_ring r,
void *const *  obj_table,
unsigned int  n,
unsigned int *  free_space 
)
static

Enqueue several objects on a ring.

This function calls the multi-producer or the single-producer version depending on the default behavior that was specified at ring creation time (see flags).

Parameters
rA pointer to the ring structure.
obj_tableA pointer to a table of void * pointers (objects).
nThe number of objects to add in the ring from the obj_table.
free_spaceif non-NULL, returns the amount of space in the ring after the enqueue operation has finished.
Returns
The number of objects enqueued, either 0 or n
Examples:
examples/multi_process/client_server_mp/mp_server/main.c, and examples/server_node_efd/server/main.c.

Definition at line 260 of file rte_ring.h.

◆ rte_ring_mp_enqueue()

static __rte_always_inline int rte_ring_mp_enqueue ( struct rte_ring r,
void *  obj 
)
static

Enqueue one object on a ring (multi-producers safe).

This function uses a "compare and set" instruction to move the producer index atomically.

Parameters
rA pointer to the ring structure.
objA pointer to the object to be added.
Returns
  • 0: Success; objects enqueued.
  • -ENOBUFS: Not enough room in the ring to enqueue; no object is enqueued.
Examples:
examples/performance-thread/common/lthread_tls.c.

Definition at line 282 of file rte_ring.h.

◆ rte_ring_sp_enqueue()

static __rte_always_inline int rte_ring_sp_enqueue ( struct rte_ring r,
void *  obj 
)
static

Enqueue one object on a ring (NOT multi-producers safe).

Parameters
rA pointer to the ring structure.
objA pointer to the object to be added.
Returns
  • 0: Success; objects enqueued.
  • -ENOBUFS: Not enough room in the ring to enqueue; no object is enqueued.
Examples:
examples/ip_pipeline/thread.c, and examples/pipeline/thread.c.

Definition at line 299 of file rte_ring.h.

◆ rte_ring_enqueue()

static __rte_always_inline int rte_ring_enqueue ( struct rte_ring r,
void *  obj 
)
static

Enqueue one object on a ring.

This function calls the multi-producer or the single-producer version, depending on the default behaviour that was specified at ring creation time (see flags).

Parameters
rA pointer to the ring structure.
objA pointer to the object to be added.
Returns
  • 0: Success; objects enqueued.
  • -ENOBUFS: Not enough room in the ring to enqueue; no object is enqueued.
Examples:
examples/multi_process/simple_mp/mp_commands.c.

Definition at line 320 of file rte_ring.h.

◆ rte_ring_mc_dequeue_bulk()

static __rte_always_inline unsigned int rte_ring_mc_dequeue_bulk ( struct rte_ring r,
void **  obj_table,
unsigned int  n,
unsigned int *  available 
)
static

Dequeue several objects from a ring (multi-consumers safe).

This function uses a "compare and set" instruction to move the consumer index atomically.

Parameters
rA pointer to the ring structure.
obj_tableA pointer to a table of void * pointers (objects) that will be filled.
nThe number of objects to dequeue from the ring to the obj_table.
availableIf non-NULL, returns the number of remaining ring entries after the dequeue has finished.
Returns
The number of objects dequeued, either 0 or n

Definition at line 344 of file rte_ring.h.

◆ rte_ring_sc_dequeue_bulk()

static __rte_always_inline unsigned int rte_ring_sc_dequeue_bulk ( struct rte_ring r,
void **  obj_table,
unsigned int  n,
unsigned int *  available 
)
static

Dequeue several objects from a ring (NOT multi-consumers safe).

Parameters
rA pointer to the ring structure.
obj_tableA pointer to a table of void * pointers (objects) that will be filled.
nThe number of objects to dequeue from the ring to the obj_table, must be strictly positive.
availableIf non-NULL, returns the number of remaining ring entries after the dequeue has finished.
Returns
The number of objects dequeued, either 0 or n
Examples:
examples/qos_sched/app_thread.c.

Definition at line 368 of file rte_ring.h.

◆ rte_ring_dequeue_bulk()

static __rte_always_inline unsigned int rte_ring_dequeue_bulk ( struct rte_ring r,
void **  obj_table,
unsigned int  n,
unsigned int *  available 
)
static

Dequeue several objects from a ring.

This function calls the multi-consumers or the single-consumer version, depending on the default behaviour that was specified at ring creation time (see flags).

Parameters
rA pointer to the ring structure.
obj_tableA pointer to a table of void * pointers (objects) that will be filled.
nThe number of objects to dequeue from the ring to the obj_table.
availableIf non-NULL, returns the number of remaining ring entries after the dequeue has finished.
Returns
The number of objects dequeued, either 0 or n
Examples:
examples/server_node_efd/node/node.c.

Definition at line 395 of file rte_ring.h.

◆ rte_ring_mc_dequeue()

static __rte_always_inline int rte_ring_mc_dequeue ( struct rte_ring r,
void **  obj_p 
)
static

Dequeue one object from a ring (multi-consumers safe).

This function uses a "compare and set" instruction to move the consumer index atomically.

Parameters
rA pointer to the ring structure.
obj_pA pointer to a void * pointer (object) that will be filled.
Returns
  • 0: Success; objects dequeued.
  • -ENOENT: Not enough entries in the ring to dequeue; no object is dequeued.
Examples:
examples/performance-thread/common/lthread_tls.c.

Definition at line 418 of file rte_ring.h.

◆ rte_ring_sc_dequeue()

static __rte_always_inline int rte_ring_sc_dequeue ( struct rte_ring r,
void **  obj_p 
)
static

Dequeue one object from a ring (NOT multi-consumers safe).

Parameters
rA pointer to the ring structure.
obj_pA pointer to a void * pointer (object) that will be filled.
Returns
  • 0: Success; objects dequeued.
  • -ENOENT: Not enough entries in the ring to dequeue, no object is dequeued.
Examples:
examples/ip_pipeline/thread.c, and examples/pipeline/thread.c.

Definition at line 436 of file rte_ring.h.

◆ rte_ring_dequeue()

static __rte_always_inline int rte_ring_dequeue ( struct rte_ring r,
void **  obj_p 
)
static

Dequeue one object from a ring.

This function calls the multi-consumers or the single-consumer version depending on the default behaviour that was specified at ring creation time (see flags).

Parameters
rA pointer to the ring structure.
obj_pA pointer to a void * pointer (object) that will be filled.
Returns
  • 0: Success, objects dequeued.
  • -ENOENT: Not enough entries in the ring to dequeue, no object is dequeued.
Examples:
examples/multi_process/simple_mp/main.c.

Definition at line 458 of file rte_ring.h.

◆ rte_ring_reset()

void rte_ring_reset ( struct rte_ring r)

Flush a ring.

This function flush all the elements in a ring

Warning
Make sure the ring is not in use while calling this function.
Parameters
rA pointer to the ring structure.

◆ rte_ring_count()

static unsigned int rte_ring_count ( const struct rte_ring r)
inlinestatic

Return the number of entries in a ring.

Parameters
rA pointer to the ring structure.
Returns
The number of entries in the ring.
Examples:
examples/server_node_efd/node/node.c.

Definition at line 486 of file rte_ring.h.

◆ rte_ring_free_count()

static unsigned int rte_ring_free_count ( const struct rte_ring r)
inlinestatic

Return the number of free entries in a ring.

Parameters
rA pointer to the ring structure.
Returns
The number of free entries in the ring.

Definition at line 503 of file rte_ring.h.

◆ rte_ring_full()

static int rte_ring_full ( const struct rte_ring r)
inlinestatic

Test if a ring is full.

Parameters
rA pointer to the ring structure.
Returns
  • 1: The ring is full.
  • 0: The ring is not full.

Definition at line 518 of file rte_ring.h.

◆ rte_ring_empty()

static int rte_ring_empty ( const struct rte_ring r)
inlinestatic

Test if a ring is empty.

Parameters
rA pointer to the ring structure.
Returns
  • 1: The ring is empty.
  • 0: The ring is not empty.

Definition at line 533 of file rte_ring.h.

◆ rte_ring_get_size()

static unsigned int rte_ring_get_size ( const struct rte_ring r)
inlinestatic

Return the size of the ring.

Parameters
rA pointer to the ring structure.
Returns
The size of the data store used by the ring. NOTE: this is not the same as the usable space in the ring. To query that use rte_ring_get_capacity().

Definition at line 551 of file rte_ring.h.

◆ rte_ring_get_capacity()

static unsigned int rte_ring_get_capacity ( const struct rte_ring r)
inlinestatic

Return the number of elements which can be stored in the ring.

Parameters
rA pointer to the ring structure.
Returns
The usable size of the ring.

Definition at line 565 of file rte_ring.h.

◆ rte_ring_get_prod_sync_type()

static enum rte_ring_sync_type rte_ring_get_prod_sync_type ( const struct rte_ring r)
inlinestatic

Return sync type used by producer in the ring.

Parameters
rA pointer to the ring structure.
Returns
Producer sync type value.

Definition at line 579 of file rte_ring.h.

◆ rte_ring_is_prod_single()

static int rte_ring_is_prod_single ( const struct rte_ring r)
inlinestatic

Check is the ring for single producer.

Parameters
rA pointer to the ring structure.
Returns
true if ring is SP, zero otherwise.

Definition at line 593 of file rte_ring.h.

◆ rte_ring_get_cons_sync_type()

static enum rte_ring_sync_type rte_ring_get_cons_sync_type ( const struct rte_ring r)
inlinestatic

Return sync type used by consumer in the ring.

Parameters
rA pointer to the ring structure.
Returns
Consumer sync type value.

Definition at line 607 of file rte_ring.h.

◆ rte_ring_is_cons_single()

static int rte_ring_is_cons_single ( const struct rte_ring r)
inlinestatic

Check is the ring for single consumer.

Parameters
rA pointer to the ring structure.
Returns
true if ring is SC, zero otherwise.

Definition at line 621 of file rte_ring.h.

◆ rte_ring_list_dump()

void rte_ring_list_dump ( FILE *  f)

Dump the status of all rings on the console

Parameters
fA pointer to a file for output

◆ rte_ring_lookup()

struct rte_ring* rte_ring_lookup ( const char *  name)

Search a ring from its name

Parameters
nameThe name of the ring.
Returns
The pointer to the ring matching the name, or NULL if not found, with rte_errno set appropriately. Possible rte_errno values include:
  • ENOENT - required entry not available to return.
Examples:
examples/multi_process/client_server_mp/mp_client/client.c, examples/multi_process/simple_mp/main.c, examples/qos_sched/init.c, and examples/server_node_efd/node/node.c.

◆ rte_ring_mp_enqueue_burst()

static __rte_always_inline unsigned int rte_ring_mp_enqueue_burst ( struct rte_ring r,
void *const *  obj_table,
unsigned int  n,
unsigned int *  free_space 
)
static

Enqueue several objects on the ring (multi-producers safe).

This function uses a "compare and set" instruction to move the producer index atomically.

Parameters
rA pointer to the ring structure.
obj_tableA pointer to a table of void * pointers (objects).
nThe number of objects to add in the ring from the obj_table.
free_spaceif non-NULL, returns the amount of space in the ring after the enqueue operation has finished.
Returns
  • n: Actual number of objects enqueued.

Definition at line 665 of file rte_ring.h.

◆ rte_ring_sp_enqueue_burst()

static __rte_always_inline unsigned int rte_ring_sp_enqueue_burst ( struct rte_ring r,
void *const *  obj_table,
unsigned int  n,
unsigned int *  free_space 
)
static

Enqueue several objects on a ring (NOT multi-producers safe).

Parameters
rA pointer to the ring structure.
obj_tableA pointer to a table of void * pointers (objects).
nThe number of objects to add in the ring from the obj_table.
free_spaceif non-NULL, returns the amount of space in the ring after the enqueue operation has finished.
Returns
  • n: Actual number of objects enqueued.
Examples:
examples/performance-thread/l3fwd-thread/main.c.

Definition at line 688 of file rte_ring.h.

◆ rte_ring_enqueue_burst()

static __rte_always_inline unsigned int rte_ring_enqueue_burst ( struct rte_ring r,
void *const *  obj_table,
unsigned int  n,
unsigned int *  free_space 
)
static

Enqueue several objects on a ring.

This function calls the multi-producer or the single-producer version depending on the default behavior that was specified at ring creation time (see flags).

Parameters
rA pointer to the ring structure.
obj_tableA pointer to a table of void * pointers (objects).
nThe number of objects to add in the ring from the obj_table.
free_spaceif non-NULL, returns the amount of space in the ring after the enqueue operation has finished.
Returns
  • n: Actual number of objects enqueued.
Examples:
examples/bbdev_app/main.c, examples/distributor/main.c, examples/ioat/ioatfwd.c, and examples/packet_ordering/main.c.

Definition at line 715 of file rte_ring.h.

◆ rte_ring_mc_dequeue_burst()

static __rte_always_inline unsigned int rte_ring_mc_dequeue_burst ( struct rte_ring r,
void **  obj_table,
unsigned int  n,
unsigned int *  available 
)
static

Dequeue several objects from a ring (multi-consumers safe). When the request objects are more than the available objects, only dequeue the actual number of objects

This function uses a "compare and set" instruction to move the consumer index atomically.

Parameters
rA pointer to the ring structure.
obj_tableA pointer to a table of void * pointers (objects) that will be filled.
nThe number of objects to dequeue from the ring to the obj_table.
availableIf non-NULL, returns the number of remaining ring entries after the dequeue has finished.
Returns
  • n: Actual number of objects dequeued, 0 if ring is empty

Definition at line 743 of file rte_ring.h.

◆ rte_ring_sc_dequeue_burst()

static __rte_always_inline unsigned int rte_ring_sc_dequeue_burst ( struct rte_ring r,
void **  obj_table,
unsigned int  n,
unsigned int *  available 
)
static

Dequeue several objects from a ring (NOT multi-consumers safe).When the request objects are more than the available objects, only dequeue the actual number of objects

Parameters
rA pointer to the ring structure.
obj_tableA pointer to a table of void * pointers (objects) that will be filled.
nThe number of objects to dequeue from the ring to the obj_table.
availableIf non-NULL, returns the number of remaining ring entries after the dequeue has finished.
Returns
  • n: Actual number of objects dequeued, 0 if ring is empty
Examples:
examples/performance-thread/l3fwd-thread/main.c, and examples/qos_sched/app_thread.c.

Definition at line 768 of file rte_ring.h.

◆ rte_ring_dequeue_burst()

static __rte_always_inline unsigned int rte_ring_dequeue_burst ( struct rte_ring r,
void **  obj_table,
unsigned int  n,
unsigned int *  available 
)
static

Dequeue multiple objects from a ring up to a maximum number.

This function calls the multi-consumers or the single-consumer version, depending on the default behaviour that was specified at ring creation time (see flags).

Parameters
rA pointer to the ring structure.
obj_tableA pointer to a table of void * pointers (objects) that will be filled.
nThe number of objects to dequeue from the ring to the obj_table.
availableIf non-NULL, returns the number of remaining ring entries after the dequeue has finished.
Returns
  • Number of objects dequeued
Examples:
examples/bbdev_app/main.c, examples/distributor/main.c, examples/ioat/ioatfwd.c, examples/multi_process/client_server_mp/mp_client/client.c, and examples/packet_ordering/main.c.

Definition at line 795 of file rte_ring.h.