Lines Matching refs:handler_
22 ASSERT_LOG(enqueue_.handler_ == nullptr, "Enqueue is not unregistered");
23 ASSERT_LOG(dequeue_.handler_ == nullptr, "Dequeue is not unregistered");
29 ASSERT(enqueue_.handler_ == nullptr);
31 enqueue_.handler_ = handler;
32 enqueue_.reactable_ = enqueue_.handler_->thread_->GetReactor()->Register(
46 reactor = enqueue_.handler_->thread_->GetReactor();
47 wait_for_unregister = (!enqueue_.handler_->thread_->IsSameThread());
50 enqueue_.handler_ = nullptr;
61 ASSERT(dequeue_.handler_ == nullptr);
63 dequeue_.handler_ = handler;
64 dequeue_.reactable_ = dequeue_.handler_->thread_->GetReactor()->Register(
76 reactor = dequeue_.handler_->thread_->GetReactor();
77 wait_for_unregister = (!dequeue_.handler_->thread_->IsSameThread());
80 dequeue_.handler_ = nullptr;