Lines Matching refs:_waiters
84 explicit Notifier(size_t N) : _waiters{N} { in Notifier()
85 assert(_waiters.size() < (1 << kWaiterBits) - 1);
87 _state = kStackMask | (kEpochMask - kEpochInc * _waiters.size() * 2);
124 newstate = (newstate & ~kStackMask) | (w - &_waiters[0]); in commit_wait()
128 w->next.store(&_waiters[state & kStackMask], std::memory_order_relaxed); in commit_wait()
179 Waiter* w = &_waiters[state & kStackMask]; in notify()
182 if (wnext != nullptr) next = wnext - &_waiters[0]; in notify()
193 Waiter* w = &_waiters[state & kStackMask]; in notify()
203 if(n >= _waiters.size()) { in notify_n()
214 return _waiters.size(); in size()
235 std::vector<Waiter> _waiters; member in tf::Notifier
265 _waiters {std::move(rhs._waiters)} {