Home
last modified time | relevance | path

Searched refs:worker_id (Results 1 – 21 of 21) sorted by relevance

/dpdk/lib/eal/common/
H A Deal_common_launch.c20 rte_eal_wait_lcore(unsigned worker_id) in rte_eal_wait_lcore() argument
22 while (__atomic_load_n(&lcore_config[worker_id].state, in rte_eal_wait_lcore()
26 return lcore_config[worker_id].ret; in rte_eal_wait_lcore()
35 rte_eal_remote_launch(lcore_function_t *f, void *arg, unsigned int worker_id) in rte_eal_remote_launch() argument
42 if (__atomic_load_n(&lcore_config[worker_id].state, in rte_eal_remote_launch()
46 lcore_config[worker_id].arg = arg; in rte_eal_remote_launch()
51 __atomic_store_n(&lcore_config[worker_id].f, f, __ATOMIC_RELEASE); in rte_eal_remote_launch()
53 eal_thread_wake_worker(worker_id); in rte_eal_remote_launch()
57 rte_eal_trace_thread_remote_launch(f, arg, worker_id, rc); in rte_eal_remote_launch()
H A Deal_thread.h71 eal_thread_wake_worker(unsigned int worker_id);
/dpdk/lib/distributor/
H A Drte_distributor_single.h152 unsigned int worker_id, struct rte_mbuf *oldpkt);
168 unsigned int worker_id, struct rte_mbuf *mbuf);
192 unsigned int worker_id, struct rte_mbuf *oldpkt);
212 unsigned int worker_id);
H A Drte_distributor.h167 unsigned int worker_id, struct rte_mbuf **pkts,
186 unsigned int worker_id, struct rte_mbuf **oldpkt, int num);
212 unsigned int worker_id, struct rte_mbuf **oldpkt,
236 unsigned int worker_id, struct rte_mbuf **mbufs);
H A Drte_distributor.c34 unsigned int worker_id, struct rte_mbuf **oldpkt, in EAL_REGISTER_TAILQ()
37 struct rte_distributor_buffer *buf = &(d->bufs[worker_id]); in EAL_REGISTER_TAILQ()
44 worker_id, count ? oldpkt[0] : NULL); in EAL_REGISTER_TAILQ()
86 unsigned int worker_id, struct rte_mbuf **pkts) in rte_distributor_poll_pkt() argument
95 worker_id); in rte_distributor_poll_pkt()
130 unsigned int worker_id, struct rte_mbuf **pkts, in rte_distributor_get_pkt() argument
138 worker_id, return_count ? oldpkt[0] : NULL); in rte_distributor_get_pkt()
146 count = rte_distributor_poll_pkt(d, worker_id, pkts); in rte_distributor_get_pkt()
153 count = rte_distributor_poll_pkt(d, worker_id, pkts); in rte_distributor_get_pkt()
168 worker_id, oldpkt[0]); in rte_distributor_return_pkt()
[all …]
H A Drte_distributor_single.c29 unsigned worker_id, struct rte_mbuf *oldpkt) in EAL_REGISTER_TAILQ()
31 union rte_distributor_buffer_single *buf = &d->bufs[worker_id]; in EAL_REGISTER_TAILQ()
43 unsigned worker_id) in rte_distributor_poll_pkt_single() argument
45 union rte_distributor_buffer_single *buf = &d->bufs[worker_id]; in rte_distributor_poll_pkt_single()
58 unsigned worker_id, struct rte_mbuf *oldpkt) in rte_distributor_get_pkt_single() argument
61 rte_distributor_request_pkt_single(d, worker_id, oldpkt); in rte_distributor_get_pkt_single()
62 while ((ret = rte_distributor_poll_pkt_single(d, worker_id)) == NULL) in rte_distributor_get_pkt_single()
69 unsigned worker_id, struct rte_mbuf *oldpkt) in rte_distributor_return_pkt_single() argument
71 union rte_distributor_buffer_single *buf = &d->bufs[worker_id]; in rte_distributor_return_pkt_single()
/dpdk/lib/eal/include/
H A Drte_launch.h66 int rte_eal_remote_launch(lcore_function_t *f, void *arg, unsigned worker_id);
111 enum rte_lcore_state_t rte_eal_get_lcore_state(unsigned int worker_id);
129 int rte_eal_wait_lcore(unsigned worker_id);
H A Drte_eal_trace.h269 unsigned int worker_id, int rc),
272 rte_trace_point_emit_u32(worker_id);
/dpdk/lib/eal/unix/
H A Deal_unix_thread.c13 eal_thread_wake_worker(unsigned int worker_id) in eal_thread_wake_worker() argument
15 int m2w = lcore_config[worker_id].pipe_main2worker[1]; in eal_thread_wake_worker()
16 int w2m = lcore_config[worker_id].pipe_worker2main[0]; in eal_thread_wake_worker()
/dpdk/lib/eal/windows/
H A Deal_thread.c20 eal_thread_wake_worker(unsigned int worker_id) in eal_thread_wake_worker() argument
22 int m2w = lcore_config[worker_id].pipe_main2worker[1]; in eal_thread_wake_worker()
23 int w2m = lcore_config[worker_id].pipe_worker2main[0]; in eal_thread_wake_worker()
/dpdk/examples/distributor/
H A Dmain.c213 unsigned worker_id; member
569 const unsigned id = p->worker_id; in lcore_worker()
583 app_stats.worker_pkts[p->worker_id] = 1; in lcore_worker()
597 app_stats.worker_pkts[p->worker_id] += num; in lcore_worker()
599 app_stats.worker_bursts[p->worker_id][num-1]++; in lcore_worker()
705 unsigned int lcore_id, worker_id = 0; in main() local
874 worker_id, lcore_id); in main()
879 *p = (struct lcore_params){worker_id++, d, rx_dist_ring, in main()
895 *pd = (struct lcore_params){worker_id++, d, in main()
906 *pr = (struct lcore_params){worker_id++, d, rx_dist_ring, in main()
/dpdk/drivers/crypto/scheduler/
H A Drte_cryptodev_scheduler_operations.h15 struct rte_cryptodev *dev, uint8_t worker_id);
17 struct rte_cryptodev *dev, uint8_t worker_id);
H A Drte_cryptodev_scheduler.c163 rte_cryptodev_scheduler_worker_attach(uint8_t scheduler_id, uint8_t worker_id) in rte_cryptodev_scheduler_worker_attach() argument
194 if (sched_ctx->workers[i].dev_id == worker_id) { in rte_cryptodev_scheduler_worker_attach()
201 rte_cryptodev_info_get(worker_id, &dev_info); in rte_cryptodev_scheduler_worker_attach()
203 worker->dev_id = worker_id; in rte_cryptodev_scheduler_worker_attach()
224 rte_cryptodev_scheduler_worker_detach(uint8_t scheduler_id, uint8_t worker_id) in rte_cryptodev_scheduler_worker_detach() argument
248 if (sched_ctx->workers[worker_pos].dev_id == worker_id) in rte_cryptodev_scheduler_worker_detach()
255 if (sched_ctx->ops.worker_detach(dev, worker_id) < 0) { in rte_cryptodev_scheduler_worker_detach()
H A Drte_cryptodev_scheduler.h119 rte_cryptodev_scheduler_worker_attach(uint8_t scheduler_id, uint8_t worker_id);
135 rte_cryptodev_scheduler_worker_detach(uint8_t scheduler_id, uint8_t worker_id);
H A Dscheduler_roundrobin.c114 __rte_unused uint8_t worker_id) in worker_attach() argument
121 __rte_unused uint8_t worker_id) in worker_detach() argument
H A Dscheduler_failover.c124 __rte_unused uint8_t worker_id) in worker_attach() argument
131 __rte_unused uint8_t worker_id) in worker_detach() argument
H A Dscheduler_multicore.c136 __rte_unused uint8_t worker_id) in worker_attach() argument
143 __rte_unused uint8_t worker_id) in worker_detach() argument
H A Dscheduler_pkt_size_distr.c240 __rte_unused uint8_t worker_id) in worker_attach() argument
247 __rte_unused uint8_t worker_id) in worker_detach() argument
H A Dscheduler_pmd_ops.c406 uint8_t worker_id = sched_ctx->workers[i].dev_id; in scheduler_pmd_qp_setup() local
413 ret = rte_cryptodev_queue_pair_setup(worker_id, qp_id, in scheduler_pmd_qp_setup()
/dpdk/app/test/
H A Dtest_pmd_perf.c676 uint16_t nb_ports, num, nb_lcores, worker_id = (uint16_t)-1; in test_pmd_perf() local
716 worker_id = alloc_lcore(socketid); in test_pmd_perf()
717 if (worker_id == (uint16_t)-1) { in test_pmd_perf()
722 worker_id, socketid); in test_pmd_perf()
779 lcore_conf[worker_id].portlist[num++] = portid; in test_pmd_perf()
780 lcore_conf[worker_id].nb_ports++; in test_pmd_perf()
805 rte_eal_remote_launch(main_loop, NULL, worker_id); in test_pmd_perf()
807 if (rte_eal_wait_lcore(worker_id) < 0) in test_pmd_perf()
811 if (exec_burst(sc_flag, worker_id) < 0) in test_pmd_perf()
/dpdk/doc/guides/contributing/
H A Dcoding_style.rst425 int rte_eal_remote_launch(lcore_function_t *f, void *arg, unsigned worker_id);