Home
last modified time | relevance | path

Searched refs:num_workers (Results 1 – 20 of 20) sorted by relevance

/f-stack/dpdk/lib/librte_distributor/
H A Drte_distributor.c258 for (i = 0; i < d->num_workers; i++) { in find_match_scalar()
566 wkr = (wkr + 1) % d->num_workers; in rte_distributor_process()
596 wkr = (wkr + 1) % d->num_workers; in rte_distributor_process()
648 for (wkr = 0; wkr < d->num_workers; wkr++) in total_outstanding()
683 for (wkr = 0; wkr < d->num_workers; wkr++) in rte_distributor_flush()
702 for (wkr = 0; wkr < d->num_workers; wkr++) in rte_distributor_clear_returns()
714 unsigned int num_workers, in rte_distributor_create() argument
729 if (name == NULL || num_workers >= in rte_distributor_create()
742 socket_id, num_workers); in rte_distributor_create()
761 d->num_workers = num_workers; in rte_distributor_create()
[all …]
H A Drte_distributor_single.c169 for (wkr = 0; wkr < d->num_workers; wkr++) { in process_returns()
251 for (i = 0; i < d->num_workers; i++) in rte_distributor_process_single()
294 if (++wkr == d->num_workers) in rte_distributor_process_single()
299 for (wkr = 0; wkr < d->num_workers; wkr++) in rte_distributor_process_single()
351 for (wkr = 0; wkr < d->num_workers; wkr++) in total_outstanding()
384 unsigned num_workers) in rte_distributor_create_single() argument
397 if (name == NULL || num_workers >= RTE_DISTRIB_MAX_WORKERS) { in rte_distributor_create_single()
411 d->num_workers = num_workers; in rte_distributor_create_single()
H A Ddistributor_private.h87 unsigned int num_workers; /**< Number of workers polling */ member
137 unsigned int num_workers; /**< Number of workers polling */ member
H A Drte_distributor_single.h43 unsigned int num_workers);
H A Drte_distributor.h52 unsigned int num_workers,
H A Drte_distributor_match_sse.c42 for (i = 0; i < d->num_workers; i++) { in find_match_vec()
/f-stack/dpdk/app/test/
H A Dtest_distributor_perf.c184 const unsigned int num_workers = rte_lcore_count() - 1; in quit_workers() local
188 rte_mempool_get_bulk(p, (void *)bufs, num_workers); in quit_workers()
191 for (i = 0; i < num_workers; i++) in quit_workers()
193 rte_distributor_process(d, bufs, num_workers); in quit_workers()
195 rte_mempool_put_bulk(p, (void *)bufs, num_workers); in quit_workers()
H A Dtest_distributor.c776 const unsigned num_workers = rte_lcore_count() - 1; in quit_workers() local
780 if (rte_mempool_get_bulk(p, (void *)bufs, num_workers) != 0) { in quit_workers()
787 for (i = 0; i < num_workers; i++) { in quit_workers()
800 rte_mempool_put_bulk(p, (void *)bufs, num_workers); in quit_workers()
/f-stack/dpdk/examples/l3fwd/
H A Dl3fwd_event_internal_port.c24 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 Dl3fwd_event_generic.c24 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()
/f-stack/dpdk/examples/l2fwd-event/
H A Dl2fwd_event_internal_port.c33 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 Dl2fwd_event_generic.c33 uint16_t num_workers = 0; in l2fwd_event_device_setup_generic() local
76 num_workers = rte_lcore_count() - 1 - rte_service_lcore_count(); in l2fwd_event_device_setup_generic()
77 if (dev_info.max_event_ports < num_workers) in l2fwd_event_device_setup_generic()
78 num_workers = dev_info.max_event_ports; in l2fwd_event_device_setup_generic()
80 event_d_conf.nb_event_ports = num_workers; in l2fwd_event_device_setup_generic()
81 evt_rsrc->evp.nb_ports = num_workers; in l2fwd_event_device_setup_generic()
/f-stack/dpdk/drivers/crypto/scheduler/
H A Dscheduler_multicore.c21 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()
/f-stack/dpdk/examples/eventdev_pipeline/
H A Dmain.c241 cdata.num_workers++; in parse_app_args()
354 printf("\tworkers: %u\n", cdata.num_workers); in main()
379 worker_data = rte_calloc(0, cdata.num_workers, in main()
453 for (i = 0; i < cdata.num_workers; i++) { in main()
458 for (i = 0; i < cdata.num_workers; i++) { in main()
H A Dpipeline_common.h63 unsigned int num_workers; member
H A Dpipeline_worker_generic.c128 const uint8_t nb_ports = cdata.num_workers; in setup_eventdev_generic()
242 for (i = 0; i < cdata.num_workers; i++) { in setup_eventdev_generic()
H A Dpipeline_worker_tx.c422 const uint8_t nb_ports = cdata.num_workers; in setup_eventdev_worker_tx_enq()
542 for (i = 0; i < cdata.num_workers; i++) { in setup_eventdev_worker_tx_enq()
/f-stack/dpdk/examples/distributor/
H A Dmain.c482 const unsigned int num_workers = rte_lcore_count() - 4; in print_stats() local
556 for (i = 0; i < num_workers; i++) { in print_stats()
/f-stack/dpdk/doc/guides/sample_app_ug/
H A Dl2_forward_event.rst326 .nb_event_ports = num_workers, /* Dedicated to each lcore */
398 for (event_p_id = 0; event_p_id < num_workers; event_p_id++) {
/f-stack/freebsd/opencrypto/
H A Dcrypto.c195 SYSCTL_INT(_kern_crypto, OID_AUTO, num_workers, CTLFLAG_RDTUN,