Lines Matching refs:thread_id
147 thread_is_running(uint32_t thread_id) in thread_is_running() argument
151 thread_state = rte_eal_get_lcore_state(thread_id); in thread_is_running()
202 thread_msg_send_recv(uint32_t thread_id, in thread_msg_send_recv() argument
205 struct thread *t = &thread[thread_id]; in thread_msg_send_recv()
225 thread_pipeline_enable(uint32_t thread_id, in thread_pipeline_enable() argument
236 if ((thread_id >= RTE_MAX_LCORE) || in thread_pipeline_enable()
240 t = &thread[thread_id]; in thread_pipeline_enable()
244 if (!thread_is_running(thread_id)) { in thread_pipeline_enable()
245 struct thread_data *td = &thread_data[thread_id]; in thread_pipeline_enable()
262 p->thread_id = thread_id; in thread_pipeline_enable()
279 rsp = thread_msg_send_recv(thread_id, req); in thread_pipeline_enable()
291 p->thread_id = thread_id; in thread_pipeline_enable()
298 thread_pipeline_disable(uint32_t thread_id, in thread_pipeline_disable() argument
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()
323 if (!thread_is_running(thread_id)) { in thread_pipeline_disable()
324 struct thread_data *td = &thread_data[thread_id]; in thread_pipeline_disable()
365 rsp = thread_msg_send_recv(thread_id, req); in thread_pipeline_disable()
509 uint32_t thread_id, i; in thread_main() local
511 thread_id = rte_lcore_id(); in thread_main()
512 t = &thread_data[thread_id]; in thread_main()