Searched refs:GetReactor (Results 1 – 9 of 9) sorted by relevance
41 reactable_ = thread_->GetReactor()->Register( in Handler()83 thread_->GetReactor()->Unregister(reactable_); in Clear()89 ASSERT(thread_->GetReactor()->WaitForUnregisteredReactable(timeout)); in WaitUntilStopped()
42 token_ = handler_->thread_->GetReactor()->Register( in RepeatingAlarm()47 handler_->thread_->GetReactor()->Unregister(token_); in ~RepeatingAlarm()
43 token_ = handler_->thread_->GetReactor()->Register( in Alarm()48 handler_->thread_->GetReactor()->Unregister(token_); in ~Alarm()
32 enqueue_.reactable_ = enqueue_.handler_->thread_->GetReactor()->Register(46 reactor = enqueue_.handler_->thread_->GetReactor();64 dequeue_.reactable_ = dequeue_.handler_->thread_->GetReactor()->Register(76 reactor = dequeue_.handler_->thread_->GetReactor();
71 Reactor* Thread::GetReactor() const { in GetReactor() function in bluetooth::os::Thread
86 Reactor* reactor = thread->GetReactor(); in TEST_F()
154 reactable_ = hci_incoming_thread_.GetReactor()->Register( in Start()166 hci_incoming_thread_.GetReactor()->Unregister(reactable_); in Stop()169 … hci_incoming_thread_.GetReactor()->WaitForUnregisteredReactable(std::chrono::milliseconds(1000)); in Stop()200 hci_incoming_thread_.GetReactor()->ModifyRegistration( in write_to_rootcanal_fd()216 this->hci_incoming_thread_.GetReactor()->ModifyRegistration( in send_packet_ready()
64 Reactor* GetReactor() const;
228 if (!GetTestThread().GetReactor()->WaitForIdle(std::chrono::milliseconds(100))) { in WaitForIdleAndStopAll()