Home
last modified time | relevance | path

Searched refs:nb_workers (Results 1 – 22 of 22) sorted by relevance

/f-stack/dpdk/drivers/crypto/scheduler/
H A Drte_cryptodev_scheduler.c145 if (!sched_ctx->nb_workers) in update_max_nb_qp()
187 if (sched_ctx->nb_workers >= in rte_cryptodev_scheduler_worker_attach()
205 sched_ctx->nb_workers++; in rte_cryptodev_scheduler_worker_attach()
210 sched_ctx->nb_workers--; in rte_cryptodev_scheduler_worker_attach()
250 if (worker_pos == sched_ctx->nb_workers) { in rte_cryptodev_scheduler_worker_detach()
266 sched_ctx->nb_workers--; in rte_cryptodev_scheduler_worker_detach()
492 uint32_t nb_workers = 0; in rte_cryptodev_scheduler_workers_get() local
506 nb_workers = sched_ctx->nb_workers; in rte_cryptodev_scheduler_workers_get()
508 if (workers && nb_workers) { in rte_cryptodev_scheduler_workers_get()
511 for (i = 0; i < nb_workers; i++) in rte_cryptodev_scheduler_workers_get()
[all …]
H A Dscheduler_pmd_ops.c72 for (i = 0; i < sched_ctx->nb_workers; i++) { in scheduler_pmd_config()
92 sched_ctx->nb_workers * PER_WORKER_BUFF_SIZE); in update_order_ring()
158 if (!sched_ctx->nb_workers) { in scheduler_pmd_start()
165 for (i = 0; i < sched_ctx->nb_workers; i++) { in scheduler_pmd_start()
182 for (i = 0; i < sched_ctx->nb_workers; i++) { in scheduler_pmd_start()
209 for (i = 0; i < sched_ctx->nb_workers; i++) { in scheduler_pmd_stop()
220 for (i = 0; i < sched_ctx->nb_workers; i++) { in scheduler_pmd_stop()
241 for (i = 0; i < sched_ctx->nb_workers; i++) { in scheduler_pmd_close()
286 for (i = 0; i < sched_ctx->nb_workers; i++) { in scheduler_pmd_stats_get()
309 for (i = 0; i < sched_ctx->nb_workers; i++) { in scheduler_pmd_stats_reset()
[all …]
H A Dscheduler_roundrobin.c13 uint32_t nb_workers; member
40 rr_qp_ctx->last_enq_worker_idx %= rr_qp_ctx->nb_workers; in schedule_enqueue()
76 if (unlikely(last_worker_idx >= rr_qp_ctx->nb_workers)) in schedule_dequeue()
91 last_worker_idx %= rr_qp_ctx->nb_workers; in schedule_dequeue()
149 for (j = 0; j < sched_ctx->nb_workers; j++) { in scheduler_start()
155 rr_qp_ctx->nb_workers = sched_ctx->nb_workers; in scheduler_start()
H A Dscheduler_pmd.c21 uint32_t nb_workers; member
196 for (i = 0; i < init_params->nb_workers; i++) { in cryptodev_scheduler_create()
252 if (sched_ctx->nb_workers) { in cryptodev_scheduler_remove()
255 for (i = 0; i < sched_ctx->nb_workers; i++) in cryptodev_scheduler_remove()
384 if (param->nb_workers >= RTE_CRYPTODEV_SCHEDULER_MAX_NB_WORKERS) { in parse_worker_arg()
389 strncpy(param->worker_names[param->nb_workers++], value, in parse_worker_arg()
537 .nb_workers = 0, in cryptodev_scheduler_probe()
H A Dscheduler_multicore.c30 uint32_t nb_workers; member
272 for (j = 0; j < sched_ctx->nb_workers; j++) { in scheduler_start()
278 mc_qp_ctx->nb_workers = sched_ctx->nb_workers; in scheduler_start()
H A Dscheduler_pmd_private.h39 uint32_t nb_workers; member
H A Dscheduler_failover.c142 if (sched_ctx->nb_workers < 2) { in scheduler_start()
H A Dscheduler_pkt_size_distr.c260 if (sched_ctx->nb_workers < NB_PKT_SIZE_WORKERS) { in scheduler_start()
/f-stack/dpdk/app/test/
H A Dtest_trace_perf.c25 unsigned int nb_workers; member
52 for (workers = 0; workers < data->nb_workers; workers++) { in measure_perf()
70 for (workers = 0; workers < data->nb_workers; workers++) in wait_till_workers_are_ready()
80 for (workers = 0; workers < data->nb_workers; workers++) { in signal_workers_to_finish()
134 data->nb_workers = rte_lcore_count() - 1; in WORKER_DEFINE()
150 unsigned int nb_cores, nb_workers; in test_trace_perf() local
155 nb_workers = nb_cores - 1; in test_trace_perf()
163 sz += nb_workers * sizeof(struct lcore_data); in test_trace_perf()
/f-stack/dpdk/app/test-eventdev/
H A Dtest_order_atq.c131 const uint8_t nb_workers = evt_nr_active_lcores(opt->wlcores); in order_atq_eventdev_setup() local
133 const uint8_t nb_ports = nb_workers + 1; in order_atq_eventdev_setup()
155 ret = order_event_dev_port_setup(test, opt, nb_workers, NB_QUEUES); in order_atq_eventdev_setup()
H A Dtest_order_queue.c132 const uint8_t nb_workers = evt_nr_active_lcores(opt->wlcores); in order_queue_eventdev_setup() local
134 const uint8_t nb_ports = nb_workers + 1; in order_queue_eventdev_setup()
169 ret = order_event_dev_port_setup(test, opt, nb_workers, NB_QUEUES); in order_queue_eventdev_setup()
H A Dtest_pipeline_common.c17 for (i = 0; i < t->nb_workers; i++) in pipeline_test_result()
19 for (i = 0; i < t->nb_workers; i++) in pipeline_test_result()
48 for (i = 0; i < t->nb_workers; i++) in processed_pkts()
518 t->nb_workers = evt_nr_active_lcores(opt->wlcores); in pipeline_test_setup()
H A Dtest_perf_common.c16 for (i = 0; i < t->nb_workers; i++) in perf_test_result()
18 for (i = 0; i < t->nb_workers; i++) in perf_test_result()
228 for (i = 0; i < t->nb_workers; i++) in processed_pkts()
241 for (i = 0; i < t->nb_workers; i++) in total_latency()
821 t->nb_workers = evt_nr_active_lcores(opt->wlcores); in perf_test_setup()
H A Dtest_order_common.c325 uint8_t nb_workers, uint8_t nb_queues) in order_event_dev_port_setup() argument
350 for (port = 0; port < nb_workers; port++) { in order_event_dev_port_setup()
H A Dtest_order_common.h149 uint8_t nb_workers, uint8_t nb_queues);
H A Dtest_perf_common.h50 uint8_t nb_workers; member
H A Dtest_pipeline_common.h44 uint8_t nb_workers; member
/f-stack/dpdk/doc/guides/tools/
H A Dtesteventdev.rst187 | 3 | nb_workers | >= 1 | |
190 | 4 | nb_ports | nb_workers + | Workers use port 0 to |
266 | 3 | nb_workers | >= 1 | |
269 | 4 | nb_ports | nb_workers + | Workers use port 0 to |
330 | 3 | nb_workers | >= 1 | Selected through --wlcores command line |
333 | 4 | nb_ports | nb_workers + | Workers use port 0 to port n-1. |
445 | 3 | nb_workers | >= 1 | Selected through --wlcores command line |
448 | 4 | nb_ports | nb_workers + | Workers use port 0 to port n-1. |
543 | 3 | nb_workers | >= 1 | Selected through --wlcores command line |
546 | 4 | nb_ports | nb_workers + | Workers use port 0 to port n. |
[all …]
/f-stack/dpdk/drivers/event/dpaa2/
H A Ddpaa2_eventdev_selftest.c497 uint8_t nb_workers, uint8_t sched_type) in launch_workers_and_wait() argument
506 if (!nb_workers) in launch_workers_and_wait()
512 param = malloc(sizeof(struct test_core_param) * nb_workers); in launch_workers_and_wait()
535 for (port = 1; port < nb_workers; port++) { in launch_workers_and_wait()
/f-stack/dpdk/drivers/event/octeontx2/
H A Dotx2_evdev_selftest.c593 uint8_t nb_workers, uint8_t sched_type) in launch_workers_and_wait() argument
602 if (!nb_workers) in launch_workers_and_wait()
608 param = malloc(sizeof(struct test_core_param) * nb_workers); in launch_workers_and_wait()
632 for (port = 1; port < nb_workers; port++) { in launch_workers_and_wait()
/f-stack/dpdk/drivers/event/octeontx/
H A Dssovf_evdev_selftest.c608 uint8_t nb_workers, uint8_t sched_type) in launch_workers_and_wait() argument
617 if (!nb_workers) in launch_workers_and_wait()
623 param = malloc(sizeof(struct test_core_param) * nb_workers); in launch_workers_and_wait()
646 for (port = 1; port < nb_workers; port++) { in launch_workers_and_wait()
/f-stack/dpdk/examples/l2fwd-crypto/
H A Dmain.c2277 uint32_t nb_workers = in initialize_cryptodevs() local
2281 sessions_needed = enabled_cdev_count * nb_workers; in initialize_cryptodevs()