Lines Matching refs:ipc_worker

238 class ipc_worker: no_copy {  class
282 ipc_worker* my_next;
303 ipc_worker(ipc_server& server, tbb_client& client, const size_t i) : in ipc_worker() function in tbb::detail::rml::ipc_worker
320 class padded_ipc_worker: public ipc_worker {
321 char pad[cache_line_sz - sizeof(ipc_worker)%cache_line_sz];
324 : ipc_worker( server,client,i ) { suppress_unused_warning(pad); } in padded_ipc_worker()
379 std::atomic<ipc_worker*> my_asleep_list_root;
422 bool try_insert_in_asleep_list(ipc_worker& t);
425 bool try_insert_in_asleep_list_forced(ipc_worker& t);
459 friend class ipc_worker;
504 __RML_DECL_THREAD_ROUTINE ipc_worker::thread_routine(void* arg) { in thread_routine()
505 ipc_worker* self = static_cast<ipc_worker*>(arg); in thread_routine()
514 void ipc_worker::release_handle(thread_handle handle, bool join) { in release_handle()
521 void ipc_worker::start_shutdown(bool join) { in start_shutdown()
540 void ipc_worker::start_stopping(bool join) { in start_stopping()
557 void ipc_worker::run() { in run()
586 inline bool ipc_worker::wake_or_launch() { in wake_or_launch()
845 ipc_worker* t = new( &my_thread_array[i] ) padded_ipc_worker( *this, client, i ); in ipc_server()
887 inline bool ipc_server::try_insert_in_asleep_list(ipc_worker& t) { in try_insert_in_asleep_list()
904 inline bool ipc_server::try_insert_in_asleep_list_forced(ipc_worker& t) { in try_insert_in_asleep_list_forced()
953 ipc_worker* wakee[2]; in wake_some()
954 ipc_worker **w = wakee; in wake_some()
999 ipc_worker* wakee[1]; in wake_one_forced()
1000 ipc_worker **w = wakee; in wake_one_forced()
1037 ipc_worker* current = nullptr; in stop_one()
1038 ipc_worker* next = nullptr; in stop_one()
1043 if( current->my_state.load(std::memory_order_relaxed)==ipc_worker::st_normal ) { in stop_one()
1045 … while( next!= nullptr && next->my_state.load(std::memory_order_relaxed)==ipc_worker::st_normal ) { in stop_one()