Searched refs:m_state (Results 1 – 5 of 5) sorted by relevance
| /oneTBB/include/oneapi/tbb/ |
| H A D | rw_mutex.h | 34 rw_mutex() noexcept : m_state(0) { in rw_mutex()
59 m_state |= WRITER_PENDING; in lock()
75 state_type s = m_state.load(std::memory_order_relaxed); in try_lock()
77 if (m_state.compare_exchange_strong(s, WRITER)) { in try_lock()
117 if (m_state.fetch_add(ONE_READER) & has_writer) { in try_lock_shared()
118 m_state -= ONE_READER; in try_lock_shared()
151 state_type s = m_state.load(std::memory_order_relaxed); in upgrade()
166 m_state -= (ONE_READER + WRITER_PENDING); in upgrade()
180 m_state += (ONE_READER - WRITER); in downgrade()
182 if (!(m_state & WRITER_PENDING)) { in downgrade()
[all …]
|
| H A D | spin_rw_mutex.h | 44 spin_rw_mutex() noexcept : m_state(0) { in spin_rw_mutex()
70 if (m_state.compare_exchange_strong(s, WRITER)) in lock()
74 m_state |= WRITER_PENDING; in lock()
86 if (m_state.compare_exchange_strong(s, WRITER)) { in try_lock()
97 m_state &= READERS; in unlock()
111 m_state -= ONE_READER; in lock_shared()
129 m_state -= ONE_READER; in try_lock_shared()
138 m_state -= ONE_READER; in unlock_shared()
159 m_state -= (ONE_READER + WRITER_PENDING); in upgrade()
172 m_state += (ONE_READER - WRITER); in downgrade()
[all …]
|
| H A D | collaborative_call_once.h | 139 std::atomic<std::uintptr_t> m_state{ state::uninitialized };
151 spin_wait_until_eq(m_state, expected); in set_completion_state()
152 } while (!m_state.compare_exchange_strong(expected, desired)); in set_completion_state()
157 std::uintptr_t expected = m_state.load(std::memory_order_acquire); in do_collaborative_call_once()
180 expected = spin_wait_while_eq(m_state, max_value); in do_collaborative_call_once()
182 … } while (expected > state::done && !m_state.compare_exchange_strong(expected, expected + 1)); in do_collaborative_call_once()
186 m_state.fetch_sub(1); in do_collaborative_call_once()
193 __TBB_ASSERT(m_state.load(std::memory_order_relaxed) != state::dead, in do_collaborative_call_once()
201 m_state.store(state::dead, std::memory_order_relaxed); in ~collaborative_once_flag()
209 __TBB_ASSERT(flag.m_state.load(std::memory_order_relaxed) != collaborative_once_flag::dead, in collaborative_call_once()
[all …]
|
| /oneTBB/src/tbb/ |
| H A D | rtm_rw_mutex.cpp | 72 if(m.m_state.load(std::memory_order_acquire)) { in acquire_writer()
74 spin_wait_until_eq(m.m_state, d1::rtm_rw_mutex::state_type(0)); in acquire_writer()
80 … if(m.m_state.load(std::memory_order_relaxed)) { // add spin_rw_mutex to read-set. in acquire_writer()
162 if(m.m_state.load(std::memory_order_acquire)) { // add spin_rw_mutex to read-set. in upgrade()
|
| /oneTBB/test/common/ |
| H A D | utils.h | 279 } m_state;
282 NoAfterlife() : m_state(LIVE) {}
283 NoAfterlife(const NoAfterlife& src) : m_state(LIVE) {
288 m_state = DEAD;
299 return m_state == LIVE;
|