Home
last modified time | relevance | path

Searched refs:thread_id (Results 1 – 25 of 33) sorted by relevance

12

/dpdk/app/test/
H A Dtest_threads.c34 rte_thread_t thread_id; in test_thread_create_join() local
38 RTE_TEST_ASSERT(rte_thread_create(&thread_id, NULL, thread_main, &thread_main_id) == 0, in test_thread_create_join()
44 RTE_TEST_ASSERT(rte_thread_equal(thread_id, thread_main_id) != 0, in test_thread_create_join()
49 RTE_TEST_ASSERT(rte_thread_join(thread_id, NULL) == 0, in test_thread_create_join()
58 rte_thread_t thread_id; in test_thread_create_detach() local
62 RTE_TEST_ASSERT(rte_thread_create(&thread_id, NULL, thread_main, in test_thread_create_detach()
68 RTE_TEST_ASSERT(rte_thread_equal(thread_id, thread_main_id) != 0, in test_thread_create_detach()
73 RTE_TEST_ASSERT(rte_thread_detach(thread_id) == 0, in test_thread_create_detach()
82 rte_thread_t thread_id; in test_thread_priority() local
86 RTE_TEST_ASSERT(rte_thread_create(&thread_id, NULL, thread_main, NULL) == 0, in test_thread_priority()
[all …]
H A Dtest_rcu_qsbr_perf.c60 uint32_t thread_id = alloc_thread_id(); in test_rcu_qsbr_reader_perf() local
65 rte_rcu_qsbr_thread_register(t[0], thread_id); in test_rcu_qsbr_reader_perf()
67 rte_rcu_qsbr_thread_online(t[0], thread_id); in test_rcu_qsbr_reader_perf()
74 rte_rcu_qsbr_quiescent(t[0], thread_id); in test_rcu_qsbr_reader_perf()
80 rte_rcu_qsbr_quiescent(t[0], thread_id); in test_rcu_qsbr_reader_perf()
90 rte_rcu_qsbr_thread_offline(t[0], thread_id); in test_rcu_qsbr_reader_perf()
92 rte_rcu_qsbr_thread_unregister(t[0], thread_id); in test_rcu_qsbr_reader_perf()
294 uint32_t thread_id = alloc_thread_id(); in test_rcu_qsbr_hash_reader() local
301 rte_rcu_qsbr_thread_register(temp, thread_id); in test_rcu_qsbr_hash_reader()
306 rte_rcu_qsbr_thread_online(temp, thread_id); in test_rcu_qsbr_hash_reader()
[all …]
H A Dtest_lpm_perf.c402 uint32_t thread_id = alloc_thread_id(); in test_lpm_rcu_qsbr_reader() local
408 rte_rcu_qsbr_thread_register(rv, thread_id); in test_lpm_rcu_qsbr_reader()
409 rte_rcu_qsbr_thread_online(rv, thread_id); in test_lpm_rcu_qsbr_reader()
419 rte_rcu_qsbr_quiescent(rv, thread_id); in test_lpm_rcu_qsbr_reader()
422 rte_rcu_qsbr_thread_offline(rv, thread_id); in test_lpm_rcu_qsbr_reader()
423 rte_rcu_qsbr_thread_unregister(rv, thread_id); in test_lpm_rcu_qsbr_reader()
/dpdk/examples/pipeline/
H A Dthread.c66 uint32_t thread_id; in thread_init() local
69 RTE_LCORE_FOREACH_WORKER(thread_id) { in thread_init()
70 struct thread *t = &threads[thread_id]; in thread_init()
91 RTE_LCORE_FOREACH_WORKER(thread_id) { in thread_init()
92 struct thread *t = &threads[thread_id]; in thread_init()
109 uint32_t thread_id; in pipeline_find() local
111 for (thread_id = 0; thread_id < RTE_MAX_LCORE; thread_id++) { in pipeline_find()
112 struct thread *t = &threads[thread_id]; in pipeline_find()
123 return thread_id; in pipeline_find()
129 uint32_t thread_id; in block_find() local
[all …]
H A Dthread.h19 pipeline_enable(struct rte_swx_pipeline *p, uint32_t thread_id);
28 block_enable(block_run_f block_func, void *block, uint32_t thread_id);
/dpdk/drivers/net/softnic/
H A Drte_eth_softnic_thread.c92 thread_is_valid(struct pmd_internals *softnic, uint32_t thread_id) in thread_is_valid() argument
94 if (thread_id >= RTE_MAX_LCORE) in thread_is_valid()
97 if (thread_id == rte_get_main_lcore()) in thread_is_valid()
100 if (softnic->params.sc && rte_lcore_has_role(thread_id, ROLE_SERVICE)) in thread_is_valid()
102 if (!softnic->params.sc && rte_lcore_has_role(thread_id, ROLE_RTE)) in thread_is_valid()
109 thread_is_running(uint32_t thread_id) in thread_is_running() argument
113 thread_state = rte_eal_get_lcore_state(thread_id); in thread_is_running()
121 thread_sc_service_up(struct pmd_internals *softnic, uint32_t thread_id) in thread_sc_service_up() argument
124 struct softnic_thread *t = &softnic->thread[thread_id]; in thread_sc_service_up()
135 thread_id); in thread_sc_service_up()
[all …]
H A Drte_eth_softnic_internals.h84 uint32_t thread_id; member
220 softnic_pipeline_thread_count(struct pmd_internals *p, uint32_t thread_id);
243 uint32_t thread_id,
248 uint32_t thread_id,
H A Drte_eth_softnic_pipeline.c46 pipeline->thread_id, in softnic_pipeline_disable_all()
51 softnic_pipeline_thread_count(struct pmd_internals *p, uint32_t thread_id) in softnic_pipeline_thread_count() argument
57 if ((pipeline->enabled) && (pipeline->thread_id == thread_id)) in softnic_pipeline_thread_count()
/dpdk/lib/rcu/
H A Drte_rcu_qsbr.h50 #define __RTE_RCU_IS_LOCK_CNT_ZERO(v, thread_id, level, ...) do { \ argument
51 if (v->qsbr_cnt[thread_id].lock_cnt) \
55 #define __RTE_RCU_IS_LOCK_CNT_ZERO(v, thread_id, level, ...) argument
244 * @param thread_id
246 * the QS variable. thread_id is a value between 0 and (max_threads - 1).
250 rte_rcu_qsbr_thread_register(struct rte_rcu_qsbr *v, unsigned int thread_id);
263 * @param thread_id
268 rte_rcu_qsbr_thread_unregister(struct rte_rcu_qsbr *v, unsigned int thread_id);
291 * @param thread_id
296 rte_rcu_qsbr_thread_online(struct rte_rcu_qsbr *v, unsigned int thread_id) in rte_rcu_qsbr_thread_online() argument
349 rte_rcu_qsbr_thread_offline(struct rte_rcu_qsbr * v,unsigned int thread_id) rte_rcu_qsbr_thread_offline() argument
387 rte_rcu_qsbr_lock(__rte_unused struct rte_rcu_qsbr * v,__rte_unused unsigned int thread_id) rte_rcu_qsbr_lock() argument
420 rte_rcu_qsbr_unlock(__rte_unused struct rte_rcu_qsbr * v,__rte_unused unsigned int thread_id) rte_rcu_qsbr_unlock() argument
478 rte_rcu_qsbr_quiescent(struct rte_rcu_qsbr * v,unsigned int thread_id) rte_rcu_qsbr_quiescent() argument
[all...]
H A Drte_rcu_qsbr.c82 rte_rcu_qsbr_thread_register(struct rte_rcu_qsbr *v, unsigned int thread_id) in rte_rcu_qsbr_thread_register() argument
87 if (v == NULL || thread_id >= v->max_threads) { in rte_rcu_qsbr_thread_register()
94 __RTE_RCU_IS_LOCK_CNT_ZERO(v, thread_id, ERR, "Lock counter %u", in rte_rcu_qsbr_thread_register()
95 v->qsbr_cnt[thread_id].lock_cnt); in rte_rcu_qsbr_thread_register()
97 id = thread_id & __RTE_QSBR_THRID_MASK; in rte_rcu_qsbr_thread_register()
98 i = thread_id >> __RTE_QSBR_THRID_INDEX_SHIFT; in rte_rcu_qsbr_thread_register()
117 rte_rcu_qsbr_thread_unregister(struct rte_rcu_qsbr *v, unsigned int thread_id) in rte_rcu_qsbr_thread_register()
122 if (v == NULL || thread_id >= v->max_threads) { in rte_rcu_qsbr_thread_register()
129 __RTE_RCU_IS_LOCK_CNT_ZERO(v, thread_id, ERR, "Lock counter %u",
130 v->qsbr_cnt[thread_id]
133 rte_rcu_qsbr_thread_unregister(struct rte_rcu_qsbr * v,unsigned int thread_id) rte_rcu_qsbr_thread_unregister() argument
186 rte_rcu_qsbr_synchronize(struct rte_rcu_qsbr * v,unsigned int thread_id) rte_rcu_qsbr_synchronize() argument
[all...]
/dpdk/lib/eal/unix/
H A Drte_thread.c122 rte_thread_create(rte_thread_t *thread_id, in rte_thread_create()
198 ret = pthread_create((pthread_t *)&thread_id->opaque_id, attrp, in rte_thread_create()
205 ret = pthread_create((pthread_t *)&thread_id->opaque_id, attrp, in rte_thread_join() argument
219 rte_thread_join(*thread_id, NULL); in rte_thread_join()
230 rte_thread_join(rte_thread_t thread_id, uint32_t *value_ptr) in rte_thread_detach()
239 ret = pthread_join((pthread_t)thread_id.opaque_id, pres); in rte_thread_self()
252 rte_thread_detach(rte_thread_t thread_id) in rte_thread_get_priority()
254 return pthread_detach((pthread_t)thread_id.opaque_id); in rte_thread_get_priority()
268 rte_thread_t thread_id; in rte_thread_get_priority()
270 thread_id in rte_thread_get_priority()
118 rte_thread_create(rte_thread_t * thread_id,const rte_thread_attr_t * thread_attr,rte_thread_func thread_func,void * args) rte_thread_create() argument
227 rte_thread_detach(rte_thread_t thread_id) rte_thread_detach() argument
243 rte_thread_t thread_id; rte_thread_self() local
251 rte_thread_get_priority(rte_thread_t thread_id,enum rte_thread_priority * priority) rte_thread_get_priority() argument
273 rte_thread_set_priority(rte_thread_t thread_id,enum rte_thread_priority priority) rte_thread_set_priority() argument
369 rte_thread_set_affinity_by_id(rte_thread_t thread_id,const rte_cpuset_t * cpuset) rte_thread_set_affinity_by_id() argument
377 rte_thread_get_affinity_by_id(rte_thread_t thread_id,rte_cpuset_t * cpuset) rte_thread_get_affinity_by_id() argument
[all...]
/dpdk/lib/eal/include/
H A Drte_thread.h99 int rte_thread_create(rte_thread_t *thread_id,
171 int rte_thread_join(rte_thread_t thread_id, uint32_t *value_ptr);
184 int rte_thread_detach(rte_thread_t thread_id);
209 rte_thread_set_name(rte_thread_t thread_id, const char *thread_name);
327 int rte_thread_set_affinity_by_id(rte_thread_t thread_id,
344 int rte_thread_get_affinity_by_id(rte_thread_t thread_id,
382 int rte_thread_get_priority(rte_thread_t thread_id,
398 int rte_thread_set_priority(rte_thread_t thread_id,
/dpdk/lib/eal/windows/
H A Drte_thread.c185 rte_thread_create(rte_thread_t *thread_id, in rte_thread_create() argument
212 thread_id->opaque_id = tid; in rte_thread_create()
233 ret = rte_thread_set_priority(*thread_id, in rte_thread_create()
262 rte_thread_join(rte_thread_t thread_id, uint32_t *value_ptr) in rte_thread_join() argument
271 FALSE, thread_id.opaque_id); in rte_thread_join()
302 rte_thread_detach(rte_thread_t thread_id) in rte_thread_detach() argument
305 RTE_SET_USED(thread_id); in rte_thread_detach()
319 rte_thread_t thread_id; in rte_thread_self() local
321 thread_id.opaque_id = GetCurrentThreadId(); in rte_thread_self()
323 return thread_id; in rte_thread_self()
[all …]
H A Deal_interrupts.c26 DWORD thread_id = GetCurrentThreadId(); in eal_intr_thread_handle_init() local
28 intr_thread_handle = OpenThread(THREAD_ALL_ACCESS, FALSE, thread_id); in eal_intr_thread_handle_init()
30 RTE_LOG_WIN32_ERR("OpenThread(%lu)", thread_id); in eal_intr_thread_handle_init()
H A Deal.c443 if (rte_thread_create(&lcore_config[i].thread_id, NULL, in rte_eal_init()
450 rte_thread_set_name(lcore_config[i].thread_id, thread_name); in rte_eal_init()
452 ret = rte_thread_set_affinity_by_id(lcore_config[i].thread_id, in rte_eal_init()
/dpdk/lib/pipeline/
H A Drte_swx_pipeline_internal.h1602 uint32_t thread_id; member
1651 struct thread *t = &p->threads[p->thread_id]; in thread_ip_inc()
1665 p->thread_id = (p->thread_id + 1) & (RTE_SWX_PIPELINE_THREADS_MAX - 1); in thread_yield()
1671 p->thread_id = (p->thread_id + cond) & (RTE_SWX_PIPELINE_THREADS_MAX - 1); in thread_yield_cond()
1687 p->thread_id, in __instr_rx_exec()
1712 p->thread_id, in __instr_rx_exec()
1738 struct thread *t = &p->threads[p->thread_id]; in instr_rx_exec()
1841 p->thread_id); in __instr_tx_exec()
1862 p->thread_id, in __instr_tx_exec()
1883 p->thread_id); in __instr_tx_i_exec()
[all …]
H A Drte_swx_pipeline.c1912 struct thread *t = &p->threads[p->thread_id]; in instr_tx_exec()
1925 struct thread *t = &p->threads[p->thread_id]; in instr_tx_i_exec()
1938 struct thread *t = &p->threads[p->thread_id]; in instr_drop_exec()
1989 struct thread *t = &p->threads[p->thread_id]; in instr_mirror_exec()
2040 struct thread *t = &p->threads[p->thread_id]; in instr_recirculate_exec()
2052 struct thread *t = &p->threads[p->thread_id]; in instr_recircid_exec()
2135 struct thread *t = &p->threads[p->thread_id]; in instr_hdr_extract_exec()
2147 struct thread *t = &p->threads[p->thread_id]; in instr_hdr_extract2_exec()
2159 struct thread *t = &p->threads[p->thread_id]; in instr_hdr_extract3_exec()
2171 struct thread *t = &p->threads[p->thread_id]; in instr_hdr_extract4_exec()
[all …]
/dpdk/lib/eal/linux/
H A Deal_thread.c24 void rte_thread_set_name(rte_thread_t thread_id, const char *thread_name) in rte_thread_set_name() argument
35 ret = pthread_setname_np((pthread_t)thread_id.opaque_id, truncated); in rte_thread_set_name()
38 RTE_SET_USED(thread_id); in rte_thread_set_name()
H A Deal.c904 if (pthread_create((pthread_t *)&lcore_config[lcore_id].thread_id.opaque_id, in is_iommu_enabled()
1213 rte_thread_set_name(lcore_config[i].thread_id, thread_name); in rte_eal_init()
1215 ret = rte_thread_set_affinity_by_id(lcore_config[i].thread_id, in rte_eal_init()
/dpdk/examples/ip_pipeline/
H A Dthread.h11 thread_pipeline_enable(uint32_t thread_id,
15 thread_pipeline_disable(uint32_t thread_id,
H A Dthread.c157 thread_is_running(uint32_t thread_id) in thread_is_running() argument
161 thread_state = rte_eal_get_lcore_state(thread_id); in thread_is_running()
176 return thread_is_running(p->thread_id); in pipeline_is_running()
232 thread_msg_send_recv(uint32_t thread_id, in thread_msg_send_recv() argument
235 struct thread *t = &thread[thread_id]; in thread_msg_send_recv()
255 thread_pipeline_enable(uint32_t thread_id, in thread_pipeline_enable() argument
266 if ((thread_id >= RTE_MAX_LCORE) || in thread_pipeline_enable()
273 t = &thread[thread_id]; in thread_pipeline_enable()
278 if (!thread_is_running(thread_id)) { in thread_pipeline_enable()
279 struct thread_data *td = &thread_data[thread_id]; in thread_pipeline_enable()
344 thread_pipeline_disable(uint32_t thread_id,const char * pipeline_name) thread_pipeline_disable() argument
3085 uint32_t thread_id, i; thread_main() local
[all...]
H A Dparser.h49 uint32_t thread_id; member
/dpdk/lib/eal/freebsd/
H A Deal_thread.c35 void rte_thread_set_name(rte_thread_t thread_id, const char *thread_name) in rte_thread_set_name() argument
43 pthread_set_name_np((pthread_t)thread_id.opaque_id, truncated); in rte_thread_set_name()
H A Deal.c811 ret = rte_thread_create(&lcore_config[i].thread_id, NULL, in rte_eal_init()
819 rte_thread_set_name(lcore_config[i].thread_id, thread_name); in rte_eal_init()
821 ret = rte_thread_set_affinity_by_id(lcore_config[i].thread_id, in rte_eal_init()
/dpdk/lib/eal/common/
H A Deal_private.h24 rte_thread_t thread_id; /**< thread identifier */ member

12