| /dpdk/lib/distributor/ |
| H A D | rte_distributor.c | 256 for (i = 0; i < d->num_workers; i++) { in find_match_scalar()
564 wkr = (wkr + 1) % d->num_workers; in rte_distributor_process()
594 wkr = (wkr + 1) % d->num_workers; in rte_distributor_process()
646 for (wkr = 0; wkr < d->num_workers; wkr++) in total_outstanding()
681 for (wkr = 0; wkr < d->num_workers; wkr++) in rte_distributor_flush()
700 for (wkr = 0; wkr < d->num_workers; wkr++) in rte_distributor_clear_returns()
712 unsigned int num_workers, in rte_distributor_create() argument
727 if (name == NULL || num_workers >= in rte_distributor_create()
740 socket_id, num_workers); in rte_distributor_create()
759 d->num_workers = num_workers; in rte_distributor_create()
[all …]
|
| H A D | rte_distributor_single.c | 165 for (wkr = 0; wkr < d->num_workers; wkr++) { in process_returns()
247 for (i = 0; i < d->num_workers; i++) in rte_distributor_process_single()
289 if (++wkr == d->num_workers) in rte_distributor_process_single()
294 for (wkr = 0; wkr < d->num_workers; wkr++) in rte_distributor_process_single()
346 for (wkr = 0; wkr < d->num_workers; wkr++) in total_outstanding()
379 unsigned num_workers) in rte_distributor_create_single() argument
392 if (name == NULL || num_workers >= RTE_DISTRIB_MAX_WORKERS) { in rte_distributor_create_single()
406 d->num_workers = num_workers; in rte_distributor_create_single()
|
| H A D | distributor_private.h | 83 unsigned int num_workers; /**< Number of workers polling */ member
133 unsigned int num_workers; /**< Number of workers polling */ member
|
| H A D | rte_distributor_single.h | 43 unsigned int num_workers);
|
| H A D | rte_distributor.h | 52 unsigned int num_workers,
|
| H A D | rte_distributor_match_sse.c | 40 for (i = 0; i < d->num_workers; i++) { in find_match_vec()
|
| /dpdk/examples/l3fwd/ |
| H A D | l3fwd_event_internal_port.c | 24 uint16_t num_workers = 0; in l3fwd_event_device_setup_internal_port() local
65 num_workers = rte_lcore_count(); in l3fwd_event_device_setup_internal_port()
66 if (dev_info.max_event_ports < num_workers) in l3fwd_event_device_setup_internal_port()
67 num_workers = dev_info.max_event_ports; in l3fwd_event_device_setup_internal_port()
69 event_d_conf.nb_event_ports = num_workers; in l3fwd_event_device_setup_internal_port()
70 evt_rsrc->evp.nb_ports = num_workers; in l3fwd_event_device_setup_internal_port()
|
| H A D | l3fwd_event_generic.c | 24 uint16_t num_workers = 0; in l3fwd_event_device_setup_generic() local
65 num_workers = rte_lcore_count() - rte_service_lcore_count(); in l3fwd_event_device_setup_generic()
66 if (dev_info.max_event_ports < num_workers) in l3fwd_event_device_setup_generic()
67 num_workers = dev_info.max_event_ports; in l3fwd_event_device_setup_generic()
69 event_d_conf.nb_event_ports = num_workers; in l3fwd_event_device_setup_generic()
70 evt_rsrc->evp.nb_ports = num_workers; in l3fwd_event_device_setup_generic()
|
| /dpdk/examples/l2fwd-event/ |
| H A D | l2fwd_event_internal_port.c | 33 uint16_t num_workers = 0; in l2fwd_event_device_setup_internal_port() local
75 num_workers = rte_lcore_count() - 1; in l2fwd_event_device_setup_internal_port()
76 if (dev_info.max_event_ports < num_workers) in l2fwd_event_device_setup_internal_port()
77 num_workers = dev_info.max_event_ports; in l2fwd_event_device_setup_internal_port()
79 event_d_conf.nb_event_ports = num_workers; in l2fwd_event_device_setup_internal_port()
80 evt_rsrc->evp.nb_ports = num_workers; in l2fwd_event_device_setup_internal_port()
|
| H A D | l2fwd_event_generic.c | 35 uint16_t num_workers = 0; in l2fwd_event_device_setup_generic() local
78 num_workers = rte_lcore_count() - 1 - rte_service_lcore_count(); in l2fwd_event_device_setup_generic()
79 if (dev_info.max_event_ports < num_workers) in l2fwd_event_device_setup_generic()
80 num_workers = dev_info.max_event_ports; in l2fwd_event_device_setup_generic()
82 event_d_conf.nb_event_ports = num_workers; in l2fwd_event_device_setup_generic()
83 evt_rsrc->evp.nb_ports = num_workers; in l2fwd_event_device_setup_generic()
|
| /dpdk/app/test/ |
| H A D | test_distributor_perf.c | 192 const unsigned int num_workers = rte_lcore_count() - 1; in quit_workers() local
196 rte_mempool_get_bulk(p, (void *)bufs, num_workers); in quit_workers()
199 for (i = 0; i < num_workers; i++) { in quit_workers()
204 rte_mempool_put_bulk(p, (void *)bufs, num_workers); in quit_workers()
|
| H A D | test_distributor.c | 789 const unsigned num_workers = rte_lcore_count() - 1; in quit_workers() local
793 if (rte_mempool_get_bulk(p, (void *)bufs, num_workers) != 0) { in quit_workers()
800 for (i = 0; i < num_workers; i++) { in quit_workers()
813 rte_mempool_put_bulk(p, (void *)bufs, num_workers); in quit_workers()
|
| /dpdk/drivers/crypto/scheduler/ |
| H A D | scheduler_multicore.c | 21 uint32_t num_workers; /**< Number of workers polling */ member
50 for (i = 0; i < mc_ctx->num_workers && nb_ops != 0; i++) { in schedule_enqueue()
58 if (++worker_idx == mc_ctx->num_workers) in schedule_enqueue()
92 for (i = 0; i < mc_ctx->num_workers && nb_ops != 0; i++) { in schedule_dequeue()
99 if (++worker_idx == mc_ctx->num_workers) in schedule_dequeue()
343 mc_ctx->num_workers = sched_ctx->nb_wc; in scheduler_create_private_ctx()
|
| /dpdk/examples/eventdev_pipeline/ |
| H A D | main.c | 267 cdata.num_workers++; in parse_app_args()
375 printf("\tworkers: %u\n", cdata.num_workers); in main()
400 worker_data = rte_calloc(0, cdata.num_workers, in main()
461 for (i = 0; i < cdata.num_workers; i++) { in main()
466 for (i = 0; i < cdata.num_workers; i++) { in main()
|
| H A D | pipeline_common.h | 63 unsigned int num_workers; member
|
| H A D | pipeline_worker_generic.c | 131 const uint8_t nb_ports = cdata.num_workers; in setup_eventdev_generic()
246 for (i = 0; i < cdata.num_workers; i++) { in setup_eventdev_generic()
|
| H A D | pipeline_worker_tx.c | 447 const uint8_t nb_ports = cdata.num_workers; in setup_eventdev_worker_tx_enq()
568 for (i = 0; i < cdata.num_workers; i++) { in setup_eventdev_worker_tx_enq()
|
| /dpdk/examples/distributor/ |
| H A D | main.c | 478 const unsigned int num_workers = rte_lcore_count() - 4; in print_stats() local
552 for (i = 0; i < num_workers; i++) { in print_stats()
|