98   QueueEndpoint enqueue_;  variable
162 Queue<T>::Queue(size_t capacity) : enqueue_(capacity), dequeue_(0){};  in Queue()
166   log::assert_that(enqueue_.handler_ == nullptr, "Enqueue is not unregistered");  in ~Queue()
173   log::assert_that(enqueue_.handler_ == nullptr, "assert failed: enqueue_.handler_ == nullptr");  in RegisterEnqueue()
174   log::assert_that(enqueue_.reactable_ == nullptr, "assert failed: enqueue_.reactable_ == nullptr");  in RegisterEnqueue()
175   enqueue_.handler_ = handler;  in RegisterEnqueue()
176   enqueue_.reactable_ = enqueue_.handler_->thread_->GetReactor()->Register(  in RegisterEnqueue()
177       enqueue_.reactive_semaphore_.GetFd(),  in RegisterEnqueue()
190         enqueue_.reactable_ != nullptr, "assert failed: enqueue_.reactable_ != nullptr");  in UnregisterEnqueue()
191     reactor = enqueue_.handler_->thread_->GetReactor();  in UnregisterEnqueue()
192     wait_for_unregister = (!enqueue_.handler_->thread_->IsSameThread());  in UnregisterEnqueue()
193     to_unregister = enqueue_.reactable_;  in UnregisterEnqueue()
194     enqueue_.reactable_ = nullptr;  in UnregisterEnqueue()
195     enqueue_.handler_ = nullptr;  in UnregisterEnqueue()
247   enqueue_.reactive_semaphore_.Increase();  in TryDequeue()
257   enqueue_.reactive_semaphore_.Decrease();  in EnqueueCallbackInternal()