Lines Matching refs:enqueue_

18 Queue<T>::Queue(size_t capacity) : enqueue_(capacity), dequeue_(0){};
22   ASSERT_LOG(enqueue_.handler_ == nullptr, "Enqueue is not unregistered");
29   ASSERT(enqueue_.handler_ == nullptr);
30   ASSERT(enqueue_.reactable_ == nullptr);
31   enqueue_.handler_ = handler;
32   enqueue_.reactable_ = enqueue_.handler_->thread_->GetReactor()->Register(
33       enqueue_.reactive_semaphore_.GetFd(),
45     ASSERT(enqueue_.reactable_ != nullptr);
46     reactor = enqueue_.handler_->thread_->GetReactor();
47     wait_for_unregister = (!enqueue_.handler_->thread_->IsSameThread());
48     to_unregister = enqueue_.reactable_;
49     enqueue_.reactable_ = nullptr;
50     enqueue_.handler_ = nullptr;
101   enqueue_.reactive_semaphore_.Increase();
111   enqueue_.reactive_semaphore_.Decrease();