Home
last modified time | relevance | path

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

12

/dpdk/lib/rcu/
H A Drte_rcu_qsbr.h52 if (v->qsbr_cnt[thread_id].lock_cnt) \
306 v->qsbr_cnt[thread_id].lock_cnt); in rte_rcu_qsbr_thread_online()
318 __atomic_store_n(&v->qsbr_cnt[thread_id].cnt, in rte_rcu_qsbr_thread_online()
357 v->qsbr_cnt[thread_id].lock_cnt); in rte_rcu_qsbr_thread_offline()
364 __atomic_store_n(&v->qsbr_cnt[thread_id].cnt, in rte_rcu_qsbr_thread_offline()
390 __rte_unused unsigned int thread_id) in rte_rcu_qsbr_lock() argument
423 __rte_unused unsigned int thread_id) in rte_rcu_qsbr_unlock() argument
434 v->qsbr_cnt[thread_id].lock_cnt); in rte_rcu_qsbr_unlock()
488 v->qsbr_cnt[thread_id].lock_cnt); in rte_rcu_qsbr_quiescent()
503 __atomic_store_n(&v->qsbr_cnt[thread_id].cnt, in rte_rcu_qsbr_quiescent()
[all …]
H A Drte_rcu_qsbr.c87 if (v == NULL || thread_id >= v->max_threads) { in rte_rcu_qsbr_thread_register()
95 __RTE_RCU_IS_LOCK_CNT_ZERO(v, thread_id, ERR, "Lock counter %u\n", in rte_rcu_qsbr_thread_register()
96 v->qsbr_cnt[thread_id].lock_cnt); in rte_rcu_qsbr_thread_register()
98 id = thread_id & __RTE_QSBR_THRID_MASK; in rte_rcu_qsbr_thread_register()
99 i = thread_id >> __RTE_QSBR_THRID_INDEX_SHIFT; in rte_rcu_qsbr_thread_register()
139 if (v == NULL || thread_id >= v->max_threads) { in rte_rcu_qsbr_thread_unregister()
148 v->qsbr_cnt[thread_id].lock_cnt); in rte_rcu_qsbr_thread_unregister()
150 id = thread_id & __RTE_QSBR_THRID_MASK; in rte_rcu_qsbr_thread_unregister()
151 i = thread_id >> __RTE_QSBR_THRID_INDEX_SHIFT; in rte_rcu_qsbr_thread_unregister()
199 if (thread_id != RTE_QSBR_THRID_INVALID) in rte_rcu_qsbr_synchronize()
[all …]
/dpdk/examples/pipeline/
H A Dthread.c154 thread_is_running(uint32_t thread_id) in thread_is_running() argument
243 if ((thread_id >= RTE_MAX_LCORE) || in thread_pipeline_enable()
247 t = &thread[thread_id]; in thread_pipeline_enable()
269 p->thread_id = thread_id; in thread_pipeline_enable()
298 p->thread_id = thread_id; in thread_pipeline_enable()
316 if ((thread_id >= RTE_MAX_LCORE) || in thread_pipeline_disable()
320 t = &thread[thread_id]; in thread_pipeline_disable()
327 if (p->thread_id != thread_id) in thread_pipeline_disable()
516 uint32_t thread_id, i; in thread_main() local
518 thread_id = rte_lcore_id(); in thread_main()
[all …]
H A Dthread.h13 thread_pipeline_enable(uint32_t thread_id,
18 thread_pipeline_disable(uint32_t thread_id,
H A Dobj.h158 uint32_t thread_id; member
/dpdk/lib/pipeline/
H A Drte_swx_pipeline_internal.h1428 uint32_t thread_id; member
1485 p->thread_id = (p->thread_id + 1) & (RTE_SWX_PIPELINE_THREADS_MAX - 1); in thread_yield()
1510 p->thread_id, in __instr_rx_exec()
1607 p->thread_id, in __instr_tx_exec()
1625 p->thread_id, in __instr_tx_i_exec()
1794 p->thread_id, in __instr_hdr_extract_m_exec()
1824 p->thread_id, in __instr_hdr_lookahead_exec()
2059 p->thread_id, in __instr_learn_exec()
2084 p->thread_id, in __instr_forget_exec()
2105 p->thread_id, in __instr_extern_obj_exec()
[all …]
H A Drte_swx_pipeline.c2132 p->thread_id, in instr_table_exec()
2145 p->thread_id, in instr_table_exec()
2184 p->thread_id, in instr_table_af_exec()
2198 p->thread_id, in instr_table_af_exec()
2237 p->thread_id, in instr_selector_exec()
2246 p->thread_id, in instr_selector_exec()
2282 p->thread_id, in instr_learner_exec()
2295 p->thread_id, in instr_learner_exec()
2340 p->thread_id, in instr_learner_af_exec()
2354 p->thread_id, in instr_learner_af_exec()
[all …]
/dpdk/lib/eal/unix/
H A Drte_thread.c24 rte_thread_t thread_id; in rte_thread_self() local
26 thread_id.opaque_id = (uintptr_t)pthread_self(); in rte_thread_self()
28 return thread_id; in rte_thread_self()
107 rte_thread_set_affinity_by_id(rte_thread_t thread_id, in rte_thread_set_affinity_by_id() argument
110 return pthread_setaffinity_np((pthread_t)thread_id.opaque_id, in rte_thread_set_affinity_by_id()
115 rte_thread_get_affinity_by_id(rte_thread_t thread_id, in rte_thread_get_affinity_by_id() argument
118 return pthread_getaffinity_np((pthread_t)thread_id.opaque_id, in rte_thread_get_affinity_by_id()
/dpdk/app/test/
H A Dtest_threads.c30 rte_thread_t thread_id; in test_thread_affinity() local
34 RTE_TEST_ASSERT(pthread_create(&id, NULL, thread_main, &thread_id) == 0, in test_thread_affinity()
40 RTE_TEST_ASSERT(rte_thread_get_affinity_by_id(thread_id, &cpuset0) == 0, in test_thread_affinity()
42 RTE_TEST_ASSERT(rte_thread_get_affinity_by_id(thread_id, &cpuset1) == 0, in test_thread_affinity()
55 RTE_TEST_ASSERT(rte_thread_set_affinity_by_id(thread_id, &cpuset0) == 0, in test_thread_affinity()
57 RTE_TEST_ASSERT(rte_thread_get_affinity_by_id(thread_id, &cpuset1) == 0, in test_thread_affinity()
H A Dtest_rcu_qsbr_perf.c58 uint32_t thread_id = alloc_thread_id(); in test_rcu_qsbr_reader_perf() local
65 rte_rcu_qsbr_thread_online(t[0], thread_id); in test_rcu_qsbr_reader_perf()
72 rte_rcu_qsbr_quiescent(t[0], thread_id); in test_rcu_qsbr_reader_perf()
78 rte_rcu_qsbr_quiescent(t[0], thread_id); in test_rcu_qsbr_reader_perf()
88 rte_rcu_qsbr_thread_offline(t[0], thread_id); in test_rcu_qsbr_reader_perf()
290 uint32_t thread_id = alloc_thread_id(); in test_rcu_qsbr_hash_reader() local
304 rte_rcu_qsbr_lock(temp, thread_id); in test_rcu_qsbr_hash_reader()
307 pdata[thread_id] = 0; in test_rcu_qsbr_hash_reader()
309 pdata[thread_id]++; in test_rcu_qsbr_hash_reader()
311 rte_rcu_qsbr_unlock(temp, thread_id); in test_rcu_qsbr_hash_reader()
[all …]
H A Dtest_lpm_perf.c410 uint32_t thread_id = alloc_thread_id(); in test_lpm_rcu_qsbr_reader() local
416 rte_rcu_qsbr_thread_register(rv, thread_id); in test_lpm_rcu_qsbr_reader()
417 rte_rcu_qsbr_thread_online(rv, thread_id); in test_lpm_rcu_qsbr_reader()
427 rte_rcu_qsbr_quiescent(rv, thread_id); in test_lpm_rcu_qsbr_reader()
430 rte_rcu_qsbr_thread_offline(rv, thread_id); in test_lpm_rcu_qsbr_reader()
431 rte_rcu_qsbr_thread_unregister(rv, thread_id); in test_lpm_rcu_qsbr_reader()
/dpdk/lib/eal/windows/
H A Drte_thread.c67 rte_thread_t thread_id; in rte_thread_self() local
69 thread_id.opaque_id = GetCurrentThreadId(); in rte_thread_self()
71 return thread_id; in rte_thread_self()
192 rte_thread_set_affinity_by_id(rte_thread_t thread_id, in rte_thread_set_affinity_by_id() argument
211 thread_id.opaque_id); in rte_thread_set_affinity_by_id()
232 rte_thread_get_affinity_by_id(rte_thread_t thread_id, in rte_thread_get_affinity_by_id() argument
247 thread_id.opaque_id); in rte_thread_get_affinity_by_id()
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.c435 if (eal_thread_create(&lcore_config[i].thread_id, i) != 0) in rte_eal_init()
437 ret = pthread_setaffinity_np(lcore_config[i].thread_id, in rte_eal_init()
/dpdk/drivers/net/softnic/
H A Drte_eth_softnic_thread.c100 if (thread_id == rte_get_main_lcore()) in thread_is_valid()
112 thread_is_running(uint32_t thread_id) in thread_is_running() argument
138 thread_id); in thread_sc_service_up()
261 uint32_t thread_id, in thread_msg_send_recv() argument
285 uint32_t thread_id, in softnic_thread_pipeline_enable() argument
334 p->thread_id = thread_id; in softnic_thread_pipeline_enable()
369 p->thread_id = thread_id; in softnic_thread_pipeline_enable()
377 uint32_t thread_id, in softnic_thread_pipeline_disable() argument
389 (p->enabled && (p->thread_id != thread_id))) in softnic_thread_pipeline_disable()
2993 uint32_t thread_id, j; in rte_pmd_softnic_run_internal() local
[all …]
H A Dparser.h59 uint32_t thread_id; member
H A Drte_eth_softnic_internals.h547 uint32_t thread_id; member
873 softnic_pipeline_thread_count(struct pmd_internals *p, uint32_t thread_id);
1124 uint32_t thread_id,
1129 uint32_t thread_id,
/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
266 if ((thread_id >= RTE_MAX_LCORE) || in thread_pipeline_enable()
273 t = &thread[thread_id]; in thread_pipeline_enable()
302 p->thread_id = thread_id; in thread_pipeline_enable()
337 p->thread_id = thread_id; in thread_pipeline_enable()
354 if ((thread_id >= RTE_MAX_LCORE) || in thread_pipeline_disable()
358 t = &thread[thread_id]; in thread_pipeline_disable()
365 if (p->thread_id != thread_id) in thread_pipeline_disable()
3087 uint32_t thread_id, i; in thread_main() local
3089 thread_id = rte_lcore_id(); in thread_main()
[all …]
H A Dkni.h37 uint32_t thread_id; member
H A Dparser.h56 uint32_t thread_id; member
H A Dkni.c134 kni_conf.core_id = params->thread_id; in kni_create()
/dpdk/lib/eal/include/
H A Drte_thread.h70 int rte_thread_set_affinity_by_id(rte_thread_t thread_id,
91 int rte_thread_get_affinity_by_id(rte_thread_t thread_id,
/dpdk/lib/eal/freebsd/
H A Deal.c812 ret = pthread_create(&lcore_config[i].thread_id, NULL, in rte_eal_init()
820 rte_thread_setname(lcore_config[i].thread_id, thread_name); in rte_eal_init()
822 ret = pthread_setaffinity_np(lcore_config[i].thread_id, in rte_eal_init()
/dpdk/lib/eal/common/
H A Deal_private.h23 pthread_t thread_id; /**< pthread identifier */ member

12