Home
last modified time | relevance | path

Searched refs:my_n_thread (Results 1 – 2 of 2) sorted by relevance

/oneTBB/src/tbb/
H A Dprivate_server.cpp125 const tbb_client::size_type my_n_thread; member in tbb::detail::r1::rml::private_server
187 for( std::size_t i=0; i<my_n_thread; ++i ) in request_close_connection()
299 const std::size_t worker_idx = my_server.my_n_thread - this->my_index; in wake_or_launch()
329 my_n_thread(client.max_job_count()), in private_server()
332 my_ref_count(my_n_thread+1), in private_server()
339 my_thread_array = tbb::cache_aligned_allocator<padded_private_worker>().allocate( my_n_thread ); in private_server()
340 for( std::size_t i=0; i<my_n_thread; ++i ) { in private_server()
349 for( std::size_t i=my_n_thread; i--; ) in ~private_server()
351 … tbb::cache_aligned_allocator<padded_private_worker>().deallocate( my_thread_array, my_n_thread ); in ~private_server()
/oneTBB/python/rml/
H A Dipc_server.cpp361 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()
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()
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()
870 for( size_t i=my_n_thread; i--; ) in ~ipc_server()
[all …]