99   QueueEndpoint dequeue_;  variable
162 Queue<T>::Queue(size_t capacity) : enqueue_(capacity), dequeue_(0){};  in Queue()
167   log::assert_that(dequeue_.handler_ == nullptr, "Dequeue is not unregistered");  in ~Queue()
206   log::assert_that(dequeue_.handler_ == nullptr, "assert failed: dequeue_.handler_ == nullptr");  in RegisterDequeue()
207   log::assert_that(dequeue_.reactable_ == nullptr, "assert failed: dequeue_.reactable_ == nullptr");  in RegisterDequeue()
208   dequeue_.handler_ = handler;  in RegisterDequeue()
209   dequeue_.reactable_ = dequeue_.handler_->thread_->GetReactor()->Register(  in RegisterDequeue()
210       dequeue_.reactive_semaphore_.GetFd(), callback, base::Closure());  in RegisterDequeue()
221         dequeue_.reactable_ != nullptr, "assert failed: dequeue_.reactable_ != nullptr");  in UnregisterDequeue()
222     reactor = dequeue_.handler_->thread_->GetReactor();  in UnregisterDequeue()
223     wait_for_unregister = (!dequeue_.handler_->thread_->IsSameThread());  in UnregisterDequeue()
224     to_unregister = dequeue_.reactable_;  in UnregisterDequeue()
225     dequeue_.reactable_ = nullptr;  in UnregisterDequeue()
226     dequeue_.handler_ = nullptr;  in UnregisterDequeue()
242   dequeue_.reactive_semaphore_.Decrease();  in TryDequeue()
259   dequeue_.reactive_semaphore_.Increase();  in EnqueueCallbackInternal()