Home
last modified time | relevance | path

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

/f-stack/dpdk/lib/librte_eal/common/
H A Deal_common_launch.c24 rte_eal_wait_lcore(unsigned worker_id) in rte_eal_wait_lcore() argument
26 if (lcore_config[worker_id].state == WAIT) in rte_eal_wait_lcore()
29 while (lcore_config[worker_id].state != WAIT && in rte_eal_wait_lcore()
30 lcore_config[worker_id].state != FINISHED) in rte_eal_wait_lcore()
36 lcore_config[worker_id].state = WAIT; in rte_eal_wait_lcore()
37 return lcore_config[worker_id].ret; in rte_eal_wait_lcore()
/f-stack/dpdk/lib/librte_eal/freebsd/
H A Deal_thread.c34 rte_eal_remote_launch(int (*f)(void *), void *arg, unsigned worker_id) in rte_eal_remote_launch() argument
38 int m2w = lcore_config[worker_id].pipe_main2worker[1]; in rte_eal_remote_launch()
39 int w2m = lcore_config[worker_id].pipe_worker2main[0]; in rte_eal_remote_launch()
42 if (lcore_config[worker_id].state != WAIT) in rte_eal_remote_launch()
45 lcore_config[worker_id].f = f; in rte_eal_remote_launch()
46 lcore_config[worker_id].arg = arg; in rte_eal_remote_launch()
65 rte_eal_trace_thread_remote_launch(f, arg, worker_id, rc); in rte_eal_remote_launch()
/f-stack/dpdk/lib/librte_eal/linux/
H A Deal_thread.c34 rte_eal_remote_launch(int (*f)(void *), void *arg, unsigned int worker_id) in rte_eal_remote_launch() argument
38 int m2w = lcore_config[worker_id].pipe_main2worker[1]; in rte_eal_remote_launch()
39 int w2m = lcore_config[worker_id].pipe_worker2main[0]; in rte_eal_remote_launch()
42 if (lcore_config[worker_id].state != WAIT) in rte_eal_remote_launch()
45 lcore_config[worker_id].f = f; in rte_eal_remote_launch()
46 lcore_config[worker_id].arg = arg; in rte_eal_remote_launch()
65 rte_eal_trace_thread_remote_launch(f, arg, worker_id, rc); in rte_eal_remote_launch()
/f-stack/dpdk/lib/librte_eal/windows/
H A Deal_thread.c25 rte_eal_remote_launch(lcore_function_t *f, void *arg, unsigned int worker_id) in rte_eal_remote_launch() argument
29 int m2w = lcore_config[worker_id].pipe_main2worker[1]; in rte_eal_remote_launch()
30 int w2m = lcore_config[worker_id].pipe_worker2main[0]; in rte_eal_remote_launch()
32 if (lcore_config[worker_id].state != WAIT) in rte_eal_remote_launch()
35 lcore_config[worker_id].f = f; in rte_eal_remote_launch()
36 lcore_config[worker_id].arg = arg; in rte_eal_remote_launch()
/f-stack/dpdk/lib/librte_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.c36 unsigned int worker_id, struct rte_mbuf **oldpkt, in EAL_REGISTER_TAILQ()
39 struct rte_distributor_buffer *buf = &(d->bufs[worker_id]); in EAL_REGISTER_TAILQ()
46 worker_id, count ? oldpkt[0] : NULL); in EAL_REGISTER_TAILQ()
88 unsigned int worker_id, struct rte_mbuf **pkts) in rte_distributor_poll_pkt() argument
97 worker_id); in rte_distributor_poll_pkt()
132 unsigned int worker_id, struct rte_mbuf **pkts, in rte_distributor_get_pkt() argument
140 worker_id, return_count ? oldpkt[0] : NULL); in rte_distributor_get_pkt()
148 count = rte_distributor_poll_pkt(d, worker_id, pkts); in rte_distributor_get_pkt()
155 count = rte_distributor_poll_pkt(d, worker_id, pkts); in rte_distributor_get_pkt()
170 worker_id, oldpkt[0]); in rte_distributor_return_pkt()
[all …]
H A Drte_distributor_single.c31 unsigned worker_id, struct rte_mbuf *oldpkt) in EAL_REGISTER_TAILQ()
33 union rte_distributor_buffer_single *buf = &d->bufs[worker_id]; in EAL_REGISTER_TAILQ()
46 unsigned worker_id) in rte_distributor_poll_pkt_single() argument
48 union rte_distributor_buffer_single *buf = &d->bufs[worker_id]; in rte_distributor_poll_pkt_single()
61 unsigned worker_id, struct rte_mbuf *oldpkt) in rte_distributor_get_pkt_single() argument
64 rte_distributor_request_pkt_single(d, worker_id, oldpkt); in rte_distributor_get_pkt_single()
65 while ((ret = rte_distributor_poll_pkt_single(d, worker_id)) == NULL) in rte_distributor_get_pkt_single()
72 unsigned worker_id, struct rte_mbuf *oldpkt) in rte_distributor_return_pkt_single() argument
74 union rte_distributor_buffer_single *buf = &d->bufs[worker_id]; in rte_distributor_return_pkt_single()
/f-stack/dpdk/lib/librte_eal/include/
H A Drte_launch.h65 int rte_eal_remote_launch(lcore_function_t *f, void *arg, unsigned worker_id);
114 enum rte_lcore_state_t rte_eal_get_lcore_state(unsigned int worker_id);
134 int rte_eal_wait_lcore(unsigned worker_id);
H A Drte_eal_trace.h267 unsigned int worker_id, int rc),
270 rte_trace_point_emit_u32(worker_id);
/f-stack/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_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_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_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.c413 uint8_t worker_id = sched_ctx->workers[i].dev_id; in scheduler_pmd_qp_setup() local
420 ret = rte_cryptodev_queue_pair_setup(worker_id, qp_id, in scheduler_pmd_qp_setup()
/f-stack/dpdk/examples/distributor/
H A Dmain.c217 unsigned worker_id; member
573 const unsigned id = p->worker_id; in lcore_worker()
587 app_stats.worker_pkts[p->worker_id] = 1; in lcore_worker()
601 app_stats.worker_pkts[p->worker_id] += num; in lcore_worker()
603 app_stats.worker_bursts[p->worker_id][num-1]++; in lcore_worker()
709 unsigned int lcore_id, worker_id = 0; in main() local
878 worker_id, lcore_id); in main()
883 *p = (struct lcore_params){worker_id++, d, rx_dist_ring, in main()
899 *pd = (struct lcore_params){worker_id++, d, in main()
910 *pr = (struct lcore_params){worker_id++, d, rx_dist_ring, in main()
/f-stack/dpdk/app/test/
H A Dtest_pmd_perf.c664 uint16_t nb_ports, num, nb_lcores, worker_id = (uint16_t)-1; in test_pmd_perf() local
702 worker_id = alloc_lcore(socketid); in test_pmd_perf()
703 if (worker_id == (uint16_t)-1) { in test_pmd_perf()
708 worker_id, socketid); in test_pmd_perf()
765 lcore_conf[worker_id].portlist[num++] = portid; in test_pmd_perf()
766 lcore_conf[worker_id].nb_ports++; in test_pmd_perf()
791 rte_eal_remote_launch(main_loop, NULL, worker_id); in test_pmd_perf()
793 if (rte_eal_wait_lcore(worker_id) < 0) in test_pmd_perf()
797 if (exec_burst(sc_flag, worker_id) < 0) in test_pmd_perf()
/f-stack/dpdk/examples/performance-thread/l3fwd-thread/
H A Dmain.c2125 int worker_id; in lthread_rx() local
2161 worker_id = 0; in lthread_rx()
2180 worker_id = (worker_id + 1) % rx_conf->n_ring; in lthread_rx()
2181 old_len = len[worker_id]; in lthread_rx()
2185 rx_conf->ring[worker_id], in lthread_rx()
2192 lthread_cond_signal(rx_conf->ready[worker_id]); in lthread_rx()
2196 len[worker_id] = new_len; in lthread_rx()
2378 int worker_id; in pthread_rx() local
2407 worker_id = 0; in pthread_rx()
2430 worker_id = (worker_id + 1) % rx_conf->n_ring; in pthread_rx()
[all …]
/f-stack/dpdk/doc/guides/contributing/
H A Dcoding_style.rst365 int rte_eal_remote_launch(lcore_function_t *f, void *arg, unsigned worker_id);