| /f-stack/dpdk/lib/librte_ring/ |
| H A D | rte_ring.h | 182 void rte_ring_free(struct rte_ring *r);
285 rte_ring_mp_enqueue(struct rte_ring *r, void *obj) in rte_ring_mp_enqueue()
323 rte_ring_enqueue(struct rte_ring *r, void *obj) in rte_ring_enqueue()
478 rte_ring_reset(struct rte_ring *r);
489 rte_ring_count(const struct rte_ring *r) in rte_ring_count()
506 rte_ring_free_count(const struct rte_ring *r) in rte_ring_free_count()
521 rte_ring_full(const struct rte_ring *r) in rte_ring_full()
536 rte_ring_empty(const struct rte_ring *r) in rte_ring_empty()
554 rte_ring_get_size(const struct rte_ring *r) in rte_ring_get_size()
568 rte_ring_get_capacity(const struct rte_ring *r) in rte_ring_get_capacity()
[all …]
|
| H A D | rte_ring_rts.h | 84 __rte_ring_do_rts_enqueue_elem(struct rte_ring *r, const void *obj_table, in __rte_ring_do_rts_enqueue_elem()
125 __rte_ring_do_rts_dequeue_elem(struct rte_ring *r, void *obj_table, in __rte_ring_do_rts_dequeue_elem()
192 rte_ring_mc_rts_dequeue_bulk_elem(struct rte_ring *r, void *obj_table, in rte_ring_mc_rts_dequeue_bulk_elem()
250 rte_ring_mc_rts_dequeue_burst_elem(struct rte_ring *r, void *obj_table, in rte_ring_mc_rts_dequeue_burst_elem()
274 rte_ring_mp_rts_enqueue_bulk(struct rte_ring *r, void * const *obj_table, in rte_ring_mp_rts_enqueue_bulk()
298 rte_ring_mc_rts_dequeue_bulk(struct rte_ring *r, void **obj_table, in rte_ring_mc_rts_dequeue_bulk()
348 rte_ring_mc_rts_dequeue_burst(struct rte_ring *r, void **obj_table, in rte_ring_mc_rts_dequeue_burst()
366 rte_ring_get_prod_htd_max(const struct rte_ring *r) in rte_ring_get_prod_htd_max()
386 rte_ring_set_prod_htd_max(struct rte_ring *r, uint32_t v) in rte_ring_set_prod_htd_max()
406 rte_ring_get_cons_htd_max(const struct rte_ring *r) in rte_ring_get_cons_htd_max()
[all …]
|
| H A D | rte_ring_peek.h | 57 __rte_ring_do_enqueue_start(struct rte_ring *r, uint32_t n, in __rte_ring_do_enqueue_start()
104 rte_ring_enqueue_bulk_elem_start(struct rte_ring *r, unsigned int n, in rte_ring_enqueue_bulk_elem_start()
130 rte_ring_enqueue_bulk_start(struct rte_ring *r, unsigned int n, in rte_ring_enqueue_bulk_start()
155 rte_ring_enqueue_burst_elem_start(struct rte_ring *r, unsigned int n, in rte_ring_enqueue_burst_elem_start()
181 rte_ring_enqueue_burst_start(struct rte_ring *r, unsigned int n, in rte_ring_enqueue_burst_start()
245 rte_ring_enqueue_finish(struct rte_ring *r, void * const *obj_table, in rte_ring_enqueue_finish()
256 __rte_ring_do_dequeue_start(struct rte_ring *r, void *obj_table, in __rte_ring_do_dequeue_start()
337 rte_ring_dequeue_bulk_start(struct rte_ring *r, void **obj_table, in rte_ring_dequeue_bulk_start()
393 rte_ring_dequeue_burst_start(struct rte_ring *r, void **obj_table, in rte_ring_dequeue_burst_start()
412 rte_ring_dequeue_elem_finish(struct rte_ring *r, unsigned int n) in rte_ring_dequeue_elem_finish()
[all …]
|
| H A D | rte_ring_peek_zc.h | 99 __rte_ring_get_elem_addr(struct rte_ring *r, uint32_t head, in __rte_ring_get_elem_addr()
125 __rte_ring_do_enqueue_zc_elem_start(struct rte_ring *r, unsigned int esize, in __rte_ring_do_enqueue_zc_elem_start()
213 rte_ring_enqueue_zc_bulk_start(struct rte_ring *r, unsigned int n, in rte_ring_enqueue_zc_bulk_start()
276 rte_ring_enqueue_zc_burst_start(struct rte_ring *r, unsigned int n, in rte_ring_enqueue_zc_burst_start()
295 rte_ring_enqueue_zc_elem_finish(struct rte_ring *r, unsigned int n) in rte_ring_enqueue_zc_elem_finish()
328 rte_ring_enqueue_zc_finish(struct rte_ring *r, unsigned int n) in rte_ring_enqueue_zc_finish()
338 __rte_ring_do_dequeue_zc_elem_start(struct rte_ring *r, in __rte_ring_do_dequeue_zc_elem_start()
425 rte_ring_dequeue_zc_bulk_start(struct rte_ring *r, unsigned int n, in rte_ring_dequeue_zc_bulk_start()
488 rte_ring_dequeue_zc_burst_start(struct rte_ring *r, unsigned int n, in rte_ring_dequeue_zc_burst_start()
507 rte_ring_dequeue_zc_elem_finish(struct rte_ring *r, unsigned int n) in rte_ring_dequeue_zc_elem_finish()
[all …]
|
| H A D | rte_ring_hts.h | 57 __rte_ring_do_hts_enqueue_elem(struct rte_ring *r, const void *obj_table, in __rte_ring_do_hts_enqueue_elem()
98 __rte_ring_do_hts_dequeue_elem(struct rte_ring *r, void *obj_table, in __rte_ring_do_hts_dequeue_elem()
137 rte_ring_mp_hts_enqueue_bulk_elem(struct rte_ring *r, const void *obj_table, in rte_ring_mp_hts_enqueue_bulk_elem()
165 rte_ring_mc_hts_dequeue_bulk_elem(struct rte_ring *r, void *obj_table, in rte_ring_mc_hts_dequeue_bulk_elem()
193 rte_ring_mp_hts_enqueue_burst_elem(struct rte_ring *r, const void *obj_table, in rte_ring_mp_hts_enqueue_burst_elem()
223 rte_ring_mc_hts_dequeue_burst_elem(struct rte_ring *r, void *obj_table, in rte_ring_mc_hts_dequeue_burst_elem()
247 rte_ring_mp_hts_enqueue_bulk(struct rte_ring *r, void * const *obj_table, in rte_ring_mp_hts_enqueue_bulk()
271 rte_ring_mc_hts_dequeue_bulk(struct rte_ring *r, void **obj_table, in rte_ring_mc_hts_dequeue_bulk()
295 rte_ring_mp_hts_enqueue_burst(struct rte_ring *r, void * const *obj_table, in rte_ring_mp_hts_enqueue_burst()
321 rte_ring_mc_hts_dequeue_burst(struct rte_ring *r, void **obj_table, in rte_ring_mc_hts_dequeue_burst()
|
| H A D | rte_ring_elem.h | 109 __rte_ring_enqueue_elems_32(struct rte_ring *r, const uint32_t size, in __rte_ring_enqueue_elems_32()
152 __rte_ring_enqueue_elems_64(struct rte_ring *r, uint32_t prod_head, in __rte_ring_enqueue_elems_64()
185 __rte_ring_enqueue_elems_128(struct rte_ring *r, uint32_t prod_head, in __rte_ring_enqueue_elems_128()
218 __rte_ring_enqueue_elems(struct rte_ring *r, uint32_t prod_head, in __rte_ring_enqueue_elems()
286 __rte_ring_dequeue_elems_64(struct rte_ring *r, uint32_t prod_head, in __rte_ring_dequeue_elems_64()
348 __rte_ring_dequeue_elems(struct rte_ring *r, uint32_t cons_head, in __rte_ring_dequeue_elems()
458 __rte_ring_do_dequeue_elem(struct rte_ring *r, void *obj_table, in __rte_ring_do_dequeue_elem()
753 rte_ring_dequeue_bulk_elem(struct rte_ring *r, void *obj_table, in rte_ring_dequeue_bulk_elem()
800 rte_ring_mc_dequeue_elem(struct rte_ring *r, void *obj_p, in rte_ring_mc_dequeue_elem()
824 rte_ring_sc_dequeue_elem(struct rte_ring *r, void *obj_p, in rte_ring_sc_dequeue_elem()
[all …]
|
| H A D | rte_ring.c | 78 sz = sizeof(struct rte_ring) + count * esize; in EAL_REGISTER_TAILQ()
124 rte_ring_reset(struct rte_ring *r) in rte_ring_reset()
188 RTE_BUILD_BUG_ON((sizeof(struct rte_ring) & in rte_ring_init()
248 struct rte_ring *
253 struct rte_ring *r; in rte_ring_create_elem()
316 struct rte_ring *
326 rte_ring_free(struct rte_ring *r) in rte_ring_free()
372 rte_ring_dump(FILE *f, const struct rte_ring *r) in rte_ring_dump()
405 struct rte_ring *
409 struct rte_ring *r = NULL; in rte_ring_lookup()
[all …]
|
| /f-stack/dpdk/doc/guides/mempool/ |
| H A D | ring.rst | 8 ``rte_ring`` DPDK library. This is a default mempool driver.
14 The underlying **rte_ring** operates in multi-thread producer,
20 The underlying **rte_ring** operates in single-thread producer,
26 The underlying **rte_ring** operates in single-thread producer,
31 The underlying **rte_ring** operates in multi-thread producer,
36 For underlying **rte_ring** both producer and consumer operate in
42 For underlying **rte_ring** both producer and consumer operate in
51 For more information about ``rte_ring`` structure, behaviour and available
|
| /f-stack/dpdk/drivers/net/ring/ |
| H A D | rte_eth_ring.h | 33 struct rte_ring * const rx_queues[],
35 struct rte_ring *const tx_queues[],
51 int rte_eth_from_ring(struct rte_ring *r);
|
| /f-stack/dpdk/lib/librte_port/ |
| H A D | rte_port_ring.h | 36 struct rte_ring *ring;
45 struct rte_ring *ring;
58 struct rte_ring *ring;
|
| /f-stack/dpdk/app/test/ |
| H A D | sample_packet_forward.h | 19 struct rte_ring;
22 int test_ring_setup(struct rte_ring **ring, uint16_t *portid);
25 void test_ring_free(struct rte_ring *rxtx);
|
| H A D | test_ring_mpmc_stress.c | 8 _st_ring_dequeue_bulk(struct rte_ring *r, void **obj, uint32_t n, in _st_ring_dequeue_bulk()
15 _st_ring_enqueue_bulk(struct rte_ring *r, void * const *obj, uint32_t n, in _st_ring_enqueue_bulk()
22 _st_ring_init(struct rte_ring *r, const char *name, uint32_t num) in _st_ring_init()
|
| H A D | test_ring_hts_stress.c | 8 _st_ring_dequeue_bulk(struct rte_ring *r, void **obj, uint32_t n, in _st_ring_dequeue_bulk()
15 _st_ring_enqueue_bulk(struct rte_ring *r, void * const *obj, uint32_t n, in _st_ring_enqueue_bulk()
22 _st_ring_init(struct rte_ring *r, const char *name, uint32_t num) in _st_ring_init()
|
| H A D | test_ring_rts_stress.c | 8 _st_ring_dequeue_bulk(struct rte_ring *r, void **obj, uint32_t n, in _st_ring_dequeue_bulk()
15 _st_ring_enqueue_bulk(struct rte_ring *r, void * const *obj, uint32_t n, in _st_ring_enqueue_bulk()
22 _st_ring_init(struct rte_ring *r, const char *name, uint32_t num) in _st_ring_init()
|
| H A D | test_ring_mt_peek_stress.c | 9 _st_ring_dequeue_bulk(struct rte_ring *r, void **obj, uint32_t n, in _st_ring_dequeue_bulk()
21 _st_ring_enqueue_bulk(struct rte_ring *r, void * const *obj, uint32_t n, in _st_ring_enqueue_bulk()
33 _st_ring_init(struct rte_ring *r, const char *name, uint32_t num) in _st_ring_init()
|
| H A D | test_ring_mt_peek_stress_zc.c | 10 _st_ring_dequeue_bulk(struct rte_ring *r, void **obj, uint32_t n, in _st_ring_dequeue_bulk()
27 _st_ring_enqueue_bulk(struct rte_ring *r, void * const *obj, uint32_t n, in _st_ring_enqueue_bulk()
44 _st_ring_init(struct rte_ring *r, const char *name, uint32_t num) in _st_ring_init()
|
| H A D | test_ring_st_peek_stress.c | 9 _st_ring_dequeue_bulk(struct rte_ring *r, void **obj, uint32_t n, in _st_ring_dequeue_bulk()
27 _st_ring_enqueue_bulk(struct rte_ring *r, void * const *obj, uint32_t n, in _st_ring_enqueue_bulk()
45 _st_ring_init(struct rte_ring *r, const char *name, uint32_t num) in _st_ring_init()
|
| H A D | test_ring_st_peek_stress_zc.c | 10 _st_ring_dequeue_bulk(struct rte_ring *r, void **obj, uint32_t n, in _st_ring_dequeue_bulk()
32 _st_ring_enqueue_bulk(struct rte_ring *r, void * const *obj, uint32_t n, in _st_ring_enqueue_bulk()
54 _st_ring_init(struct rte_ring *r, const char *name, uint32_t num) in _st_ring_init()
|
| H A D | test_ring.c | 220 unsigned int (*flegacy)(struct rte_ring *r,
228 unsigned int (*flegacy)(struct rte_ring *r,
231 unsigned int (*felem)(struct rte_ring *r, void *obj_table,
505 struct rte_ring *rp = NULL; in test_ring_negative_tests()
506 struct rte_ring *rt = NULL; in test_ring_negative_tests()
590 struct rte_ring *r; in test_ring_burst_bulk_tests1()
687 struct rte_ring *r; in test_ring_burst_bulk_tests2()
774 struct rte_ring *r; in test_ring_burst_bulk_tests3()
845 struct rte_ring *r; in test_ring_burst_bulk_tests4()
967 struct rte_ring *rp = NULL; in test_ring_basic_ex()
[all …]
|
| /f-stack/dpdk/examples/performance-thread/common/ |
| H A D | lthread_tls.c | 28 static struct rte_ring *key_pool;
49 static struct rte_ring *pool; in _lthread_key_pool_init()
71 rte_ring_mp_enqueue((struct rte_ring *)pool, in _lthread_key_pool_init()
94 if (rte_ring_mc_dequeue((struct rte_ring *)key_pool, (void **)&new_key) in lthread_key_create()
118 rte_ring_mp_enqueue((struct rte_ring *)key_pool, in lthread_key_delete()
|
| /f-stack/dpdk/drivers/crypto/scheduler/ |
| H A D | scheduler_pmd_private.h | 61 struct rte_ring *order_ring;
68 get_max_enqueue_order_count(struct rte_ring *order_ring, uint16_t nb_ops) in get_max_enqueue_order_count()
76 scheduler_order_insert(struct rte_ring *order_ring, in scheduler_order_insert()
83 scheduler_order_drain(struct rte_ring *order_ring, in scheduler_order_drain()
|
| H A D | scheduler_multicore.c | 24 struct rte_ring *sched_enq_ring[RTE_MAX_LCORE];
25 struct rte_ring *sched_deq_ring[RTE_MAX_LCORE];
51 struct rte_ring *enq_ring = mc_ctx->sched_enq_ring[worker_idx]; in schedule_enqueue()
70 struct rte_ring *order_ring = in schedule_enqueue_ordering()
93 struct rte_ring *deq_ring = mc_ctx->sched_deq_ring[worker_idx]; in schedule_dequeue()
113 struct rte_ring *order_ring = in schedule_dequeue_ordering()
153 struct rte_ring *enq_ring; in mc_scheduler_worker()
154 struct rte_ring *deq_ring; in mc_scheduler_worker()
|
| /f-stack/dpdk/examples/pipeline/ |
| H A D | thread.c | 37 struct rte_ring *msgq_req;
38 struct rte_ring *msgq_rsp;
59 struct rte_ring *msgq_req;
60 struct rte_ring *msgq_rsp;
98 struct rte_ring *msgq_req, *msgq_rsp; in thread_init()
206 struct rte_ring *msgq_req = t->msgq_req; in thread_msg_send_recv()
207 struct rte_ring *msgq_rsp = t->msgq_rsp; in thread_msg_send_recv()
386 thread_msg_recv(struct rte_ring *msgq_req) in thread_msg_recv()
399 thread_msg_send(struct rte_ring *msgq_rsp, in thread_msg_send()
|
| /f-stack/dpdk/lib/librte_pdump/ |
| H A D | rte_pdump.c | 44 struct rte_ring *ring;
51 struct rte_ring *ring;
65 struct rte_ring *ring;
81 struct rte_ring *ring; in pdump_copy()
124 struct rte_ring *ring, struct rte_mempool *mp, in pdump_register_rx_callbacks()
178 struct rte_ring *ring, struct rte_mempool *mp, in pdump_register_tx_callbacks()
239 struct rte_ring *ring; in set_pdump_rxtx_cbs()
371 pdump_validate_ring_mp(struct rte_ring *ring, struct rte_mempool *mp) in pdump_validate_ring_mp()
434 struct rte_ring *ring, in pdump_prepare_client_request()
484 struct rte_ring *ring, in rte_pdump_enable()
[all …]
|
| /f-stack/dpdk/examples/qos_sched/ |
| H A D | main.h | 86 struct rte_ring *rx_ring;
87 struct rte_ring *tx_ring;
105 struct rte_ring *rx_ring;
106 struct rte_ring *tx_ring;
|