Lines Matching refs:load

150     int old = my_global_thread_count.load(std::memory_order_relaxed);  in release_thread_sem()
189 if( my_global_thread_count.load(std::memory_order_acquire)!=0 ) { in release_resources()
197 } while( my_global_thread_count.load(std::memory_order_acquire)!=0 ); in release_resources()
409 if( my_slack.load(std::memory_order_acquire)>0 ) { in propagate_chain_reaction()
522 state_t s = my_state.load(std::memory_order_relaxed); in start_shutdown()
541 state_t s = my_state.load(std::memory_order_relaxed); in start_stopping()
565 state_t state = my_state.load(std::memory_order_acquire); in run()
571 state = my_state.load(std::memory_order_seq_cst); in run()
579 state = my_state.load(std::memory_order_seq_cst); in run()
588 …if( ( my_state.load(std::memory_order_acquire)==st_init && my_state.compare_exchange_strong( expec… in wake_or_launch()
589 …( my_state.load(std::memory_order_acquire)==st_stop && my_state.compare_exchange_strong( excepted_… in wake_or_launch()
662 while( my_state.load(std::memory_order_seq_cst)!=st_quit ) { in run()
664 if( my_server.my_slack.load(std::memory_order_acquire)>0 ) { in run()
666 if( my_server.my_slack.load(std::memory_order_acquire)>0 ) { in run()
678 if( my_server.my_slack.load(std::memory_order_acquire)<0 ) { in run()
689 …if( ( my_state.load(std::memory_order_acquire)==st_init && my_state.compare_exchange_strong( excep… in wake_or_launch()
760 while( my_state.load(std::memory_order_acquire)!=st_quit ) { in run()
762 if( my_state.load(std::memory_order_acquire)!=st_quit ) { in run()
776 …if( ( my_state.load(std::memory_order_acquire)==st_init && my_state.compare_exchange_strong( excep… in wake_or_launch()
868 __TBB_ASSERT( my_net_slack_requests.load(std::memory_order_relaxed)==0, nullptr ); in ~ipc_server()
895 t.my_next = my_asleep_list_root.load(std::memory_order_relaxed); in try_insert_in_asleep_list()
911 t.my_next = my_asleep_list_root.load(std::memory_order_relaxed); in try_insert_in_asleep_list_forced()
957 … while( active_threads>0 && my_asleep_list_root.load(std::memory_order_relaxed) && w<wakee+2 ) { in wake_some()
959 …if( additional_slack+my_slack.load(std::memory_order_acquire)<=0 ) // additional demand does not e… in wake_some()
966 old = my_slack.load(std::memory_order_relaxed); in wake_some()
972 (*w++ = my_asleep_list_root.load(std::memory_order_relaxed))->my_next, in wake_some()
1003 while( my_asleep_list_root.load(std::memory_order_relaxed) && w<wakee+1 ) { in wake_one_forced()
1005 …if( additional_slack+my_slack.load(std::memory_order_acquire)<=0 ) // additional demand does not e… in wake_one_forced()
1012 old = my_slack.load(std::memory_order_relaxed); in wake_one_forced()
1018 (*w++ = my_asleep_list_root.load(std::memory_order_relaxed))->my_next, in wake_one_forced()
1041 if( my_asleep_list_root.load(std::memory_order_relaxed) ) { in stop_one()
1042 current = my_asleep_list_root.load(std::memory_order_relaxed); in stop_one()
1043 if( current->my_state.load(std::memory_order_relaxed)==ipc_worker::st_normal ) { in stop_one()
1045 … while( next!= nullptr && next->my_state.load(std::memory_order_relaxed)==ipc_worker::st_normal ) { in stop_one()