Searched refs:my_server (Results 1 – 5 of 5) sorted by relevance
265 ipc_server& my_server; member in tbb::detail::rml::ipc_worker304 my_server(server), in ipc_worker()558 my_server.propagate_chain_reaction(); in run()567 if( my_server.my_slack>=0 ) { in run()573 if( my_server.my_n_thread > 1 ) my_server.release_active_thread(); in run()583 my_server.remove_server_ref(); in run()612 my_server.my_ref_count++; in wake_or_launch()684 my_server.remove_server_ref(); in run()711 my_server.my_ref_count++; in wake_or_launch()771 my_server.remove_server_ref(); in run()[all …]
62 private_server& my_server; member in tbb::detail::r1::rml::private_worker98 my_state(st_init), my_server(server), my_client(client), my_index(i), in private_worker()245 my_server.remove_server_ref(); in start_shutdown()261 my_server.propagate_chain_reaction(); in run()270 if( my_server.my_slack.load(std::memory_order_acquire)>=0 ) { in run()272 } else if( my_server.try_insert_in_asleep_list(*this) ) { in run()275 my_server.propagate_chain_reaction(); in run()280 ++my_server.my_slack; in run()281 my_server.remove_server_ref(); in run()299 const std::size_t worker_idx = my_server.my_n_thread - this->my_index; in wake_or_launch()[all …]
29 my_server = governor::create_rml_server( *this ); in thread_dispatcher()30 __TBB_ASSERT( my_server, "Failed to create RML server" ); in thread_dispatcher()34 poison_pointer(my_server); in ~thread_dispatcher()65 __TBB_ASSERT(!is_poisoned(my_server), nullptr); in try_unregister_client()168 my_server->adjust_job_count_estimate(delta); in adjust_job_count_estimate()173 my_server->request_close_connection(); in release()
99 rml::tbb_server* my_server{nullptr};
83 if (!governor::UsePrivateRML && td->my_server->default_concurrency() < workers_soft_limit) { in make_thread_dispatcher()85 td->my_server->default_concurrency(), workers_soft_limit); in make_thread_dispatcher()