Searched refs:dequeue_ (Results 1 – 2 of 2) sorted by relevance
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());[all …]
102 QueueEndpoint dequeue_; variable