Home
last modified time | relevance | path

Searched refs:my_state (Results 1 – 12 of 12) sorted by relevance

/oneTBB/src/tbb/
H A Dqueuing_rw_mutex.cpp210 (void)predecessor->my_state.load(std::memory_order_acquire); in acquire()
244 s.my_state.store(STATE_ACTIVEREADER, std::memory_order_relaxed); in acquire()
420 s.my_state.store(STATE_READER, std::memory_order_seq_cst); in downgrade_to_reader()
451 next->my_state.store(STATE_UPGRADE_LOSER, std::memory_order_release); in downgrade_to_reader()
452 s.my_state.store(STATE_ACTIVEREADER, std::memory_order_release); in downgrade_to_reader()
457 if (s.my_state.load(std::memory_order_relaxed) == STATE_WRITER) { in upgrade_to_writer()
469 s.my_state.store(STATE_UPGRADE_REQUESTED, std::memory_order_release); in upgrade_to_writer()
481 unsigned short n_state = next->my_state.load(std::memory_order_acquire); in upgrade_to_writer()
569 bool result = ( s.my_state != STATE_UPGRADE_LOSER ); in upgrade_to_writer()
570 s.my_state.store(STATE_WRITER, std::memory_order_relaxed); in upgrade_to_writer()
[all …]
H A Dco_context.h110 co_state my_state; variable
114 : my_state(stack_size ? co_suspended : co_executing) in co_context()
125 __TBB_ASSERT(1 << my_state & (1 << co_suspended | 1 << co_executing), nullptr); in ~co_context()
126 if (my_state == co_suspended) { in ~co_context()
128 my_state = co_executing; in ~co_context()
132 my_state = co_destroyed; in ~co_context()
137 __TBB_ASSERT(my_state == co_executing, nullptr); in resume()
138 __TBB_ASSERT(target.my_state == co_suspended, nullptr); in resume()
140 my_state = co_suspended; in resume()
141 target.my_state = co_executing; in resume()
[all …]
H A Dtask_group_context.cpp58 …__TBB_ASSERT(ctx.my_state.load(std::memory_order_relaxed) == d1::task_group_context::state::bound,… in destroy()
81 ctx.my_state.store(d1::task_group_context::state::dead, std::memory_order_release); in destroy()
93 ctx.my_state.store(d1::task_group_context::state::created, std::memory_order_relaxed); in initialize()
115 …__TBB_ASSERT(ctx.my_state.load(std::memory_order_relaxed) == d1::task_group_context::state::locked… in bind_to_impl()
166 d1::task_group_context::state state = ctx.my_state.load(std::memory_order_acquire); in bind_to()
170 …ypename std::underlying_type<d1::task_group_context::state>::type>&)ctx.my_state).compare_exchange… in bind_to()
174 ctx.my_state.compare_exchange_strong(state, d1::task_group_context::state::locked) in bind_to()
192 ctx.my_state.store(release_state, std::memory_order_release); in bind_to()
194 spin_wait_while_eq(ctx.my_state, d1::task_group_context::state::locked); in bind_to()
196 …__TBB_ASSERT(ctx.my_state.load(std::memory_order_relaxed) != d1::task_group_context::state::create… in bind_to()
[all …]
H A Dprivate_server.cpp59 std::atomic<state_t> my_state; member in tbb::detail::r1::rml::private_worker
98 my_state(st_init), my_server(server), my_client(client), my_index(i), in private_worker()
237 …__TBB_ASSERT(my_state.load(std::memory_order_relaxed) != st_quit, "The quit state is expected to b… in start_shutdown()
241 state_t prev_state = my_state.exchange(st_quit, std::memory_order_acq_rel); in start_shutdown()
269 while( my_state.load(std::memory_order_seq_cst)!=st_quit ) { in run()
274 …__TBB_ASSERT(my_state.load(std::memory_order_relaxed) == st_quit || !my_next, "Thread monitor miss… in run()
285 state_t state = my_state.load(std::memory_order_relaxed); in wake_or_launch()
295 if (my_state.compare_exchange_strong(state, st_starting)) { in wake_or_launch()
310 if (!my_state.compare_exchange_strong(state, st_normal)) { in wake_or_launch()
H A Darena.h142 std::atomic<std::uintptr_t> my_state{UNSET};
145 std::uintptr_t state = my_state.load(std::memory_order_acquire); in test_and_set()
150 if (my_state.compare_exchange_strong(state, SET)) { in test_and_set()
161 return my_state.compare_exchange_strong(state, SET); in test_and_set()
167 std::uintptr_t state = my_state.load(std::memory_order_acquire); in try_clear_if()
168 if (state == SET && my_state.compare_exchange_strong(state, busy)) { in try_clear_if()
170 return my_state.compare_exchange_strong(busy, UNSET); in try_clear_if()
173 my_state.compare_exchange_strong(busy, SET); in try_clear_if()
178 return my_state.load(order) != UNSET;
H A Dtask_dispatcher.h304 __TBB_ASSERT(ed.context->my_state == d1::task_group_context::state::bound || in local_wait_for_all()
305 ed.context->my_state == d1::task_group_context::state::isolated, nullptr); in local_wait_for_all()
/oneTBB/python/rml/
H A Dipc_server.cpp262 std::atomic<state_t> my_state; member in tbb::detail::rml::ipc_worker
308 my_state = st_init; in ipc_worker()
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()
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()
689 …if( ( my_state.load(std::memory_order_acquire)==st_init && my_state.compare_exchange_strong( excep… in wake_or_launch()
717 my_state.compare_exchange_strong(s, st_normal); in wake_or_launch()
776 …if( ( my_state.load(std::memory_order_acquire)==st_init && my_state.compare_exchange_strong( excep… in wake_or_launch()
[all …]
/oneTBB/test/common/
H A Dchecktype.h31 StateType my_state; variable
33 DestroyedTracker() : my_state(LIVE) {} in DestroyedTracker()
34 DestroyedTracker( const DestroyedTracker& src ) : my_state(LIVE) { in DestroyedTracker()
40 my_state = DEAD; in ~DestroyedTracker()
50 return my_state == LIVE; in is_alive()
/oneTBB/test/tbb/
H A Dtest_parallel_scan.cpp155 mutable state_type my_state; member in Accumulator
174 if (!(a.my_state == partial)) in Accumulator()
175 CHECK(a.my_state == full); in Accumulator()
176 if (!(a.my_state == full)) in Accumulator()
185 CHECK(my_state == full); in operator ()()
194 CHECK(my_state == partial); in reverse_join()
195 CHECK( ((left_body.my_state == full) || (left_body.my_state==partial)) ); in reverse_join()
200 my_state = left_body.my_state; in reverse_join()
204 CHECK(my_state == full); in assign()
209 my_state = summary; in assign()
[all …]
/oneTBB/test/conformance/
H A Dconformance_concurrent_hash_map.cpp72 } my_state; member in MyData
76 my_state = LIVE; in MyData()
86 my_state = LIVE; in MyData()
96 my_state = DEAD; in ~MyData()
106 CHECK_FAST(my_state==LIVE); in value_of()
111 CHECK_FAST(my_state==LIVE); in set_value()
117 CHECK_FAST(my_state==LIVE); in operator ==()
128 CHECK_FAST(my_state==LIVE); in MyData2()
134 CHECK_FAST(my_state==LIVE); in MyData2()
140 CHECK_FAST(my_state==LIVE); in operator =()
[all …]
/oneTBB/include/oneapi/tbb/
H A Dqueuing_rw_mutex.h69 my_state = 0xFF; // Set to invalid state in initialize()
124 std::atomic<state_t> my_state; variable
H A Dtask_group.h218 std::atomic<state> my_state; variable
273 , my_state{state::proxy}
293 return my_state.load(std::memory_order_relaxed) == state::proxy; in is_proxy()