Lines Matching refs:thread_id

159 thread_is_running(uint32_t thread_id)  in thread_is_running()  argument
163 thread_state = rte_eal_get_lcore_state(thread_id); in thread_is_running()
178 return thread_is_running(p->thread_id); in pipeline_is_running()
234 thread_msg_send_recv(uint32_t thread_id, in thread_msg_send_recv() argument
237 struct thread *t = &thread[thread_id]; in thread_msg_send_recv()
257 thread_pipeline_enable(uint32_t thread_id, in thread_pipeline_enable() argument
268 if ((thread_id >= RTE_MAX_LCORE) || in thread_pipeline_enable()
275 t = &thread[thread_id]; in thread_pipeline_enable()
280 if (!thread_is_running(thread_id)) { in thread_pipeline_enable()
281 struct thread_data *td = &thread_data[thread_id]; in thread_pipeline_enable()
304 p->thread_id = thread_id; in thread_pipeline_enable()
327 rsp = thread_msg_send_recv(thread_id, req); in thread_pipeline_enable()
339 p->thread_id = thread_id; in thread_pipeline_enable()
346 thread_pipeline_disable(uint32_t thread_id, in thread_pipeline_disable() argument
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()
370 if (!thread_is_running(thread_id)) { in thread_pipeline_disable()
371 struct thread_data *td = &thread_data[thread_id]; in thread_pipeline_disable()
412 rsp = thread_msg_send_recv(thread_id, req); in thread_pipeline_disable()
3089 uint32_t thread_id, i; in thread_main() local
3091 thread_id = rte_lcore_id(); in thread_main()
3092 t = &thread_data[thread_id]; in thread_main()