Lines Matching refs:my_n_thread
361 tbb_client::size_type my_n_thread; member in tbb::detail::rml::ipc_server
473 for( size_t i=0; i<my_n_thread; ++i ) in request_close_connection()
482 unsigned default_concurrency() const override { return my_n_thread - 1; } in default_concurrency()
573 if( my_server.my_n_thread > 1 ) my_server.release_active_thread(); in run()
836 my_n_thread = tbb::internal::rml::get_num_threads(IPC_MAX_THREADS_VAR_NAME); in ipc_server()
837 if( my_n_thread==0 ) { in ipc_server()
838 my_n_thread = tbb::detail::r1::AvailableHwConcurrency(); in ipc_server()
839 __TBB_ASSERT( my_n_thread>0, nullptr ); in ipc_server()
843 my_thread_array = tbb::cache_aligned_allocator<padded_ipc_worker>().allocate( my_n_thread ); in ipc_server()
844 for( size_t i=0; i<my_n_thread; ++i ) { in ipc_server()
851 new( my_waker ) ipc_waker( *this, client, my_n_thread ); in ipc_server()
854 new( my_stopper ) ipc_stopper( *this, client, my_n_thread + 1 ); in ipc_server()
857 my_active_sem = sem_open( active_sem_name, O_CREAT, IPC_SEM_MODE, my_n_thread - 1 ); in ipc_server()
870 for( size_t i=my_n_thread; i--; ) in ~ipc_server()
872 tbb::cache_aligned_allocator<padded_ipc_worker>().deallocate( my_thread_array, my_n_thread ); in ~ipc_server()
1061 if( my_n_thread > 1 ) { in adjust_job_count_estimate()