Lines Matching refs:dequeue_

18 Queue<T>::Queue(size_t capacity) : enqueue_(capacity), dequeue_(0){};
23   ASSERT_LOG(dequeue_.handler_ == nullptr, "Dequeue is not unregistered");
61   ASSERT(dequeue_.handler_ == nullptr);
62   ASSERT(dequeue_.reactable_ == nullptr);
63   dequeue_.handler_ = handler;
64   dequeue_.reactable_ = dequeue_.handler_->thread_->GetReactor()->Register(
65       dequeue_.reactive_semaphore_.GetFd(), callback, base::Closure());
75     ASSERT(dequeue_.reactable_ != nullptr);
76     reactor = dequeue_.handler_->thread_->GetReactor();
77     wait_for_unregister = (!dequeue_.handler_->thread_->IsSameThread());
78     to_unregister = dequeue_.reactable_;
79     dequeue_.reactable_ = nullptr;
80     dequeue_.handler_ = nullptr;
96   dequeue_.reactive_semaphore_.Decrease();
113   dequeue_.reactive_semaphore_.Increase();