Lines Matching refs:ipc_server

108 class ipc_server;
265 ipc_server& my_server;
284 friend class ipc_server;
303 ipc_worker(ipc_server& server, tbb_client& client, const size_t i) : in ipc_worker()
323 padded_ipc_worker(ipc_server& server, tbb_client& client, const size_t i) in padded_ipc_worker()
336 friend class ipc_server;
339 ipc_waker(ipc_server& server, tbb_client& client, const size_t i) in ipc_waker()
349 friend class ipc_server;
352 ipc_stopper(ipc_server& server, tbb_client& client, const size_t i) in ipc_stopper()
356 class ipc_server: public tbb_server, no_copy { class
454 this->~ipc_server(); in remove_server_ref()
455 tbb::cache_aligned_allocator<ipc_server>().deallocate( this, 1 ); in remove_server_ref()
463 ipc_server(tbb_client& client);
464 virtual ~ipc_server();
823 ipc_server::ipc_server(tbb_client& client) : in ipc_server() function in tbb::detail::rml::ipc_server
867 ipc_server::~ipc_server() { 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()
916 inline bool ipc_server::wait_active_thread() { in wait_active_thread()
924 inline bool ipc_server::try_get_active_thread() { in try_get_active_thread()
932 inline void ipc_server::release_active_thread() { in release_active_thread()
936 inline bool ipc_server::wait_stop_thread() { in wait_stop_thread()
947 inline void ipc_server::add_stop_thread() { in add_stop_thread()
951 void ipc_server::wake_some( int additional_slack, int active_threads ) { in wake_some()
997 void ipc_server::wake_one_forced( int additional_slack ) { in wake_one_forced()
1036 bool ipc_server::stop_one() { in stop_one()
1057 void ipc_server::adjust_job_count_estimate( int delta ) { in adjust_job_count_estimate()
1105 ipc_server* server = static_cast<ipc_server*>( my_global_server ); in rml_atfork_child()
1106 server->~ipc_server(); in rml_atfork_child()
1108 new( server ) ipc_server( *my_global_client ); in rml_atfork_child()
1117 server = new( tbb::cache_aligned_allocator<ipc_server>().allocate(1) ) ipc_server(client); in __TBB_make_rml_server()