Lines Matching refs:thread_id
66 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
131 for (thread_id = 0; thread_id < RTE_MAX_LCORE; thread_id++) { in block_find()
132 struct thread *t = &threads[thread_id]; in block_find()
143 return thread_id; in block_find()
163 pipeline_enable(struct rte_swx_pipeline *p, uint32_t thread_id) in pipeline_enable() argument
169 if (!p || thread_id >= RTE_MAX_LCORE) in pipeline_enable()
175 t = &threads[thread_id]; in pipeline_enable()
229 uint32_t thread_id, i; in pipeline_disable() local
236 thread_id = pipeline_find(p); in pipeline_disable()
237 if (thread_id == RTE_MAX_LCORE) in pipeline_disable()
240 t = &threads[thread_id]; in pipeline_disable()
265 block_enable(block_run_f block_func, void *block, uint32_t thread_id) in block_enable() argument
271 if (!block_func || !block || thread_id >= RTE_MAX_LCORE) in block_enable()
277 t = &threads[thread_id]; in block_enable()
302 uint32_t thread_id, i; in block_disable() local
309 thread_id = block_find(block); in block_disable()
310 if (thread_id == RTE_MAX_LCORE) in block_disable()
313 t = &threads[thread_id]; in block_disable()
356 uint32_t thread_id; in thread_main() local
358 thread_id = rte_lcore_id(); in thread_main()
359 t = &threads[thread_id]; in thread_main()