92         : reactive_semaphore_(initial_value), handler_(nullptr), reactable_(nullptr) {}  in QueueEndpoint()
95     Reactor::Reactable* reactable_;  variable
174   log::assert_that(enqueue_.reactable_ == nullptr, "assert failed: enqueue_.reactable_ == nullptr");  in RegisterEnqueue()
176   enqueue_.reactable_ = enqueue_.handler_->thread_->GetReactor()->Register(  in RegisterEnqueue()
190         enqueue_.reactable_ != nullptr, "assert failed: enqueue_.reactable_ != nullptr");  in UnregisterEnqueue()
193     to_unregister = enqueue_.reactable_;  in UnregisterEnqueue()
194     enqueue_.reactable_ = nullptr;  in UnregisterEnqueue()
207   log::assert_that(dequeue_.reactable_ == nullptr, "assert failed: dequeue_.reactable_ == nullptr");  in RegisterDequeue()
209   dequeue_.reactable_ = dequeue_.handler_->thread_->GetReactor()->Register(  in RegisterDequeue()
221         dequeue_.reactable_ != nullptr, "assert failed: dequeue_.reactable_ != nullptr");  in UnregisterDequeue()
224     to_unregister = dequeue_.reactable_;  in UnregisterDequeue()
225     dequeue_.reactable_ = nullptr;  in UnregisterDequeue()