Searched refs:dequeue_ (Results 1 – 1 of 1) sorted by relevance
117 QueueEndpoint dequeue_; variable179 Queue<T>::Queue(size_t capacity) : enqueue_(capacity), dequeue_(0){}; in Queue()184 log::assert_that(dequeue_.handler_ == nullptr, "Dequeue is not unregistered"); in ~Queue()224 log::assert_that(dequeue_.handler_ == nullptr, "assert failed: dequeue_.handler_ == nullptr"); in RegisterDequeue()225 log::assert_that(dequeue_.reactable_ == nullptr, "assert failed: dequeue_.reactable_ == nullptr"); in RegisterDequeue()226 dequeue_.handler_ = handler; in RegisterDequeue()227 dequeue_.reactable_ = dequeue_.handler_->thread_->GetReactor()->Register( in RegisterDequeue()228 dequeue_.reactive_semaphore_.GetFd(), callback, base::Closure()); in RegisterDequeue()238 log::assert_that(dequeue_.reactable_ != nullptr, in UnregisterDequeue()240 reactor = dequeue_.handler_->thread_->GetReactor(); in UnregisterDequeue()[all …]