Lines Matching refs:handler_
92 : reactive_semaphore_(initial_value), handler_(nullptr), reactable_(nullptr) {} in QueueEndpoint()
94 Handler* handler_; variable
166 log::assert_that(enqueue_.handler_ == nullptr, "Enqueue is not unregistered"); in ~Queue()
167 log::assert_that(dequeue_.handler_ == nullptr, "Dequeue is not unregistered"); in ~Queue()
173 log::assert_that(enqueue_.handler_ == nullptr, "assert failed: enqueue_.handler_ == nullptr"); in RegisterEnqueue()
175 enqueue_.handler_ = handler; in RegisterEnqueue()
176 enqueue_.reactable_ = enqueue_.handler_->thread_->GetReactor()->Register( in RegisterEnqueue()
191 reactor = enqueue_.handler_->thread_->GetReactor(); in UnregisterEnqueue()
192 wait_for_unregister = (!enqueue_.handler_->thread_->IsSameThread()); in UnregisterEnqueue()
195 enqueue_.handler_ = nullptr; in UnregisterEnqueue()
206 log::assert_that(dequeue_.handler_ == nullptr, "assert failed: dequeue_.handler_ == nullptr"); in RegisterDequeue()
208 dequeue_.handler_ = handler; in RegisterDequeue()
209 dequeue_.reactable_ = dequeue_.handler_->thread_->GetReactor()->Register( in RegisterDequeue()
222 reactor = dequeue_.handler_->thread_->GetReactor(); in UnregisterDequeue()
223 wait_for_unregister = (!dequeue_.handler_->thread_->IsSameThread()); in UnregisterDequeue()
226 dequeue_.handler_ = nullptr; in UnregisterDequeue()