Home
last modified time | relevance | path

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

12

/f-stack/dpdk/lib/librte_rcu/
H A Drte_rcu_qsbr.h56 if (v->qsbr_cnt[thread_id].lock_cnt) \
310 v->qsbr_cnt[thread_id].lock_cnt); in rte_rcu_qsbr_thread_online()
322 __atomic_store_n(&v->qsbr_cnt[thread_id].cnt, in rte_rcu_qsbr_thread_online()
366 v->qsbr_cnt[thread_id].lock_cnt); in rte_rcu_qsbr_thread_offline()
373 __atomic_store_n(&v->qsbr_cnt[thread_id].cnt, in rte_rcu_qsbr_thread_offline()
399 __rte_unused unsigned int thread_id) in rte_rcu_qsbr_lock() argument
432 __rte_unused unsigned int thread_id) in rte_rcu_qsbr_unlock() argument
443 v->qsbr_cnt[thread_id].lock_cnt); in rte_rcu_qsbr_unlock()
497 v->qsbr_cnt[thread_id].lock_cnt); in rte_rcu_qsbr_quiescent()
512 __atomic_store_n(&v->qsbr_cnt[thread_id].cnt, in rte_rcu_qsbr_quiescent()
[all …]
H A Drte_rcu_qsbr.c91 if (v == NULL || thread_id >= v->max_threads) { in rte_rcu_qsbr_thread_register()
99 __RTE_RCU_IS_LOCK_CNT_ZERO(v, thread_id, ERR, "Lock counter %u\n", in rte_rcu_qsbr_thread_register()
100 v->qsbr_cnt[thread_id].lock_cnt); in rte_rcu_qsbr_thread_register()
102 id = thread_id & __RTE_QSBR_THRID_MASK; in rte_rcu_qsbr_thread_register()
103 i = thread_id >> __RTE_QSBR_THRID_INDEX_SHIFT; in rte_rcu_qsbr_thread_register()
143 if (v == NULL || thread_id >= v->max_threads) { in rte_rcu_qsbr_thread_unregister()
152 v->qsbr_cnt[thread_id].lock_cnt); in rte_rcu_qsbr_thread_unregister()
154 id = thread_id & __RTE_QSBR_THRID_MASK; in rte_rcu_qsbr_thread_unregister()
155 i = thread_id >> __RTE_QSBR_THRID_INDEX_SHIFT; in rte_rcu_qsbr_thread_unregister()
203 if (thread_id != RTE_QSBR_THRID_INVALID) in rte_rcu_qsbr_synchronize()
[all …]
/f-stack/dpdk/examples/pipeline/
H A Dthread.c147 thread_is_running(uint32_t thread_id) in thread_is_running() argument
236 if ((thread_id >= RTE_MAX_LCORE) || in thread_pipeline_enable()
240 t = &thread[thread_id]; in thread_pipeline_enable()
262 p->thread_id = thread_id; in thread_pipeline_enable()
291 p->thread_id = thread_id; in thread_pipeline_enable()
309 if ((thread_id >= RTE_MAX_LCORE) || in thread_pipeline_disable()
313 t = &thread[thread_id]; in thread_pipeline_disable()
320 if (p->thread_id != thread_id) in thread_pipeline_disable()
509 uint32_t thread_id, i; in thread_main() local
511 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.h119 uint32_t thread_id; member
H A Dcli.c1082 uint32_t thread_id; in cmd_thread_pipeline_enable() local
1090 if (parser_read_uint32(&thread_id, tokens[1]) != 0) { in cmd_thread_pipeline_enable()
1112 status = thread_pipeline_enable(thread_id, obj, pipeline_name); in cmd_thread_pipeline_enable()
1131 uint32_t thread_id; in cmd_thread_pipeline_disable() local
1139 if (parser_read_uint32(&thread_id, tokens[1]) != 0) { in cmd_thread_pipeline_disable()
1161 status = thread_pipeline_disable(thread_id, obj, pipeline_name); in cmd_thread_pipeline_disable()
/f-stack/dpdk/app/test/
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.c400 uint32_t thread_id = alloc_thread_id(); in test_lpm_rcu_qsbr_reader() local
406 rte_rcu_qsbr_thread_register(rv, thread_id); in test_lpm_rcu_qsbr_reader()
407 rte_rcu_qsbr_thread_online(rv, thread_id); in test_lpm_rcu_qsbr_reader()
417 rte_rcu_qsbr_quiescent(rv, thread_id); in test_lpm_rcu_qsbr_reader()
420 rte_rcu_qsbr_thread_offline(rv, thread_id); in test_lpm_rcu_qsbr_reader()
421 rte_rcu_qsbr_thread_unregister(rv, thread_id); in test_lpm_rcu_qsbr_reader()
/f-stack/dpdk/lib/librte_pipeline/
H A Drte_swx_pipeline.c1002 uint32_t thread_id; member
2430 p->thread_id = (p->thread_id + 1) & (RTE_SWX_PIPELINE_THREADS_MAX - 1); in thread_yield()
2482 p->thread_id, in instr_rx_exec()
2596 p->thread_id, in instr_tx_exec()
2656 p->thread_id, in __instr_hdr_extract_exec()
2692 p->thread_id); in instr_hdr_extract2_exec()
2704 p->thread_id); in instr_hdr_extract3_exec()
3089 p->thread_id, in instr_table_exec()
3157 p->thread_id, in instr_extern_obj_exec()
3179 p->thread_id, in instr_extern_func_exec()
[all …]
/f-stack/dpdk/lib/librte_eal/windows/
H A Deal_thread.c63 pthread_t thread_id; in eal_thread_loop() local
67 thread_id = pthread_self(); in eal_thread_loop()
71 if (thread_id == lcore_config[lcore_id].thread_id) in eal_thread_loop()
83 lcore_id, (uintptr_t)thread_id, cpuset); in eal_thread_loop()
/f-stack/dpdk/lib/librte_eal/freebsd/
H A Deal_thread.c76 pthread_t thread_id; in eal_thread_loop() local
80 thread_id = pthread_self(); in eal_thread_loop()
84 if (thread_id == lcore_config[lcore_id].thread_id) in eal_thread_loop()
97 lcore_id, thread_id, cpuset, ret == 0 ? "" : "..."); in eal_thread_loop()
H A Deal.c666 pthread_t thread_id; in rte_eal_init() local
689 thread_id = pthread_self(); in rte_eal_init()
865 config->main_lcore, thread_id, cpuset, in rte_eal_init()
882 ret = pthread_create(&lcore_config[i].thread_id, NULL, in rte_eal_init()
890 rte_thread_setname(lcore_config[i].thread_id, thread_name); in rte_eal_init()
892 ret = pthread_setaffinity_np(lcore_config[i].thread_id, in rte_eal_init()
/f-stack/dpdk/lib/librte_eal/linux/
H A Deal_thread.c76 pthread_t thread_id; in eal_thread_loop() local
80 thread_id = pthread_self(); in eal_thread_loop()
84 if (thread_id == lcore_config[lcore_id].thread_id) in eal_thread_loop()
97 lcore_id, (uintptr_t)thread_id, cpuset, ret == 0 ? "" : "..."); in eal_thread_loop()
H A Deal.c961 pthread_t thread_id; in rte_eal_init() local
989 thread_id = pthread_self(); in rte_eal_init()
1228 config->main_lcore, (uintptr_t)thread_id, cpuset, in rte_eal_init()
1245 ret = pthread_create(&lcore_config[i].thread_id, NULL, in rte_eal_init()
1253 ret = rte_thread_setname(lcore_config[i].thread_id, in rte_eal_init()
1259 ret = pthread_setaffinity_np(lcore_config[i].thread_id, in rte_eal_init()
/f-stack/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.c159 thread_is_running(uint32_t thread_id) in thread_is_running() argument
268 if ((thread_id >= RTE_MAX_LCORE) || in thread_pipeline_enable()
275 t = &thread[thread_id]; in thread_pipeline_enable()
304 p->thread_id = thread_id; in thread_pipeline_enable()
339 p->thread_id = thread_id; in thread_pipeline_enable()
356 if ((thread_id >= RTE_MAX_LCORE) || in thread_pipeline_disable()
360 t = &thread[thread_id]; in thread_pipeline_disable()
367 if (p->thread_id != thread_id) in thread_pipeline_disable()
3089 uint32_t thread_id, i; in thread_main() local
3091 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()
/f-stack/dpdk/drivers/net/softnic/
H A Drte_eth_softnic_thread.c102 if (thread_id == rte_get_main_lcore()) in thread_is_valid()
114 thread_is_running(uint32_t thread_id) in thread_is_running() argument
142 thread_id); in thread_sc_service_up()
265 uint32_t thread_id, in thread_msg_send_recv() argument
289 uint32_t thread_id, in softnic_thread_pipeline_enable() argument
338 p->thread_id = thread_id; in softnic_thread_pipeline_enable()
373 p->thread_id = thread_id; in softnic_thread_pipeline_enable()
381 uint32_t thread_id, in softnic_thread_pipeline_disable() argument
393 (p->enabled && (p->thread_id != thread_id))) in softnic_thread_pipeline_disable()
2997 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.h535 uint32_t thread_id; member
860 softnic_pipeline_thread_count(struct pmd_internals *p, uint32_t thread_id);
1111 uint32_t thread_id,
1116 uint32_t thread_id,
/f-stack/freebsd/contrib/octeon-sdk/cvmx-malloc/
H A Dthread-m.h37 typedef int thread_id; typedef
/f-stack/dpdk/lib/librte_eal/common/
H A Deal_private.h22 pthread_t thread_id; /**< pthread identifier */ member
/f-stack/dpdk/examples/performance-thread/l3fwd-thread/
H A Dmain.c266 uint8_t thread_id; member
288 uint8_t thread_id; member
579 uint16_t thread_id; /**< Thread ID */ member
2235 rx_thread[i].conf.thread_id = i; in lthread_spawner()
2253 tx_thread[i].conf.thread_id = i; in lthread_spawner()
2559 tx_conf->conf.thread_id); in init_rx_rings()
2561 rx_thread_id = tx_conf->conf.thread_id; in init_rx_rings()
2601 thread = rx_thread_params[i].thread_id; in init_rx_queues()
2610 rx_thread[thread].conf.thread_id = thread; in init_rx_queues()
2632 tx_thread[n_tx_thread].conf.thread_id = tx_thread_params[i].thread_id; in init_tx_threads()
[all …]

12