Lines Matching refs:state

42   auto state = w->state.load(std::memory_order_acquire);  in BlockingAwaitState()  local
43 assert(state != STATE_LOCKED_WAITING); in BlockingAwaitState()
44 if ((state & goal_mask) == 0 && in BlockingAwaitState()
45 w->state.compare_exchange_strong(state, STATE_LOCKED_WAITING)) { in BlockingAwaitState()
49 return w->state.load(std::memory_order_relaxed) != STATE_LOCKED_WAITING; in BlockingAwaitState()
51 state = w->state.load(std::memory_order_relaxed); in BlockingAwaitState()
58 assert((state & goal_mask) != 0); in BlockingAwaitState()
59 return state; in BlockingAwaitState()
64 uint8_t state = 0; in AwaitState() local
75 state = w->state.load(std::memory_order_acquire); in AwaitState()
76 if ((state & goal_mask) != 0) { in AwaitState()
77 return state; in AwaitState()
160 state = w->state.load(std::memory_order_acquire); in AwaitState()
161 if ((state & goal_mask) != 0) { in AwaitState()
185 if ((state & goal_mask) == 0) { in AwaitState()
187 state = BlockingAwaitState(w, goal_mask); in AwaitState()
206 assert((state & goal_mask) != 0); in AwaitState()
207 return state; in AwaitState()
211 auto state = w->state.load(std::memory_order_acquire); in SetState() local
212 if (state == STATE_LOCKED_WAITING || in SetState()
213 !w->state.compare_exchange_strong(state, new_state)) { in SetState()
214 assert(state == STATE_LOCKED_WAITING); in SetState()
217 assert(w->state.load(std::memory_order_relaxed) != new_state); in SetState()
218 w->state.store(new_state, std::memory_order_relaxed); in SetState()
225 assert(w->state == STATE_INIT); in LinkOne()
608 assert(w->state == STATE_PARALLEL_MEMTABLE_WRITER); in ExitAsBatchGroupFollower()
612 assert(w->state == STATE_COMPLETED); in ExitAsBatchGroupFollower()