Lines Matching refs:my_server
265 ipc_server& my_server; member in tbb::detail::rml::ipc_worker
304 my_server(server), in ipc_worker()
558 my_server.propagate_chain_reaction(); in run()
567 if( my_server.my_slack>=0 ) { in run()
572 if( state!=st_quit && state!=st_stop && my_server.try_insert_in_asleep_list(*this) ) { in run()
573 if( my_server.my_n_thread > 1 ) my_server.release_active_thread(); in run()
575 my_server.propagate_chain_reaction(); in run()
583 my_server.remove_server_ref(); in run()
592 …my_handle = ipc_thread_monitor::launch( thread_routine, this, my_server.my_stack_size, &this->my_i… in wake_or_launch()
597 my_handle = ipc_thread_monitor::launch( thread_routine, this, my_server.my_stack_size ); in wake_or_launch()
608 release_handle( my_handle, my_server.my_join_workers ); in wake_or_launch()
612 my_server.my_ref_count++; in wake_or_launch()
624 release_handle( my_handle, my_server.my_join_workers ); in wake_or_launch()
664 if( my_server.my_slack.load(std::memory_order_acquire)>0 ) { in run()
665 if( my_server.wait_active_thread() ) { in run()
666 if( my_server.my_slack.load(std::memory_order_acquire)>0 ) { in run()
667 my_server.wake_some( 0, 1 ); in run()
669 my_server.release_active_thread(); in run()
678 if( my_server.my_slack.load(std::memory_order_acquire)<0 ) { in run()
684 my_server.remove_server_ref(); in run()
692 …my_handle = ipc_thread_monitor::launch( thread_routine, this, my_server.my_stack_size, &this->my_i… in wake_or_launch()
697 my_handle = ipc_thread_monitor::launch( thread_routine, this, my_server.my_stack_size ); in wake_or_launch()
707 release_handle( my_handle, my_server.my_join_workers ); in wake_or_launch()
711 my_server.my_ref_count++; in wake_or_launch()
723 release_handle( my_handle, my_server.my_join_workers ); in wake_or_launch()
761 if( my_server.wait_stop_thread() ) { in run()
763 if( !my_server.stop_one() ) { in run()
764 my_server.add_stop_thread(); in run()
771 my_server.remove_server_ref(); in run()
779 …my_handle = ipc_thread_monitor::launch( thread_routine, this, my_server.my_stack_size, &this->my_i… in wake_or_launch()
784 my_handle = ipc_thread_monitor::launch( thread_routine, this, my_server.my_stack_size ); in wake_or_launch()
794 release_handle( my_handle, my_server.my_join_workers ); in wake_or_launch()
798 my_server.my_ref_count++; in wake_or_launch()
810 release_handle( my_handle, my_server.my_join_workers ); in wake_or_launch()