Home
last modified time | relevance | path

Searched refs:GetReactor (Results 1 – 23 of 23) sorted by relevance

/packages/modules/Bluetooth/system/gd/os/
Dhandler.cc31 event_ = thread_->GetReactor()->NewEvent(); in Handler()
32 reactable_ = thread_->GetReactor()->Register( in Handler()
67 thread_->GetReactor()->Unregister(reactable_); in Clear()
74 thread_->GetReactor()->WaitForUnregisteredReactable(timeout), in WaitUntilStopped()
Dqueue.h176 enqueue_.reactable_ = enqueue_.handler_->thread_->GetReactor()->Register( in RegisterEnqueue()
191 reactor = enqueue_.handler_->thread_->GetReactor(); in UnregisterEnqueue()
209 dequeue_.reactable_ = dequeue_.handler_->thread_->GetReactor()->Register( in RegisterDequeue()
222 reactor = dequeue_.handler_->thread_->GetReactor(); in UnregisterDequeue()
Dthread.h65 Reactor* GetReactor() const;
/packages/modules/Bluetooth/system/gd/hal/
Dhci_hal_host_rootcanal.cc172 reactable_ = hci_incoming_thread_.GetReactor()->Register( in Start()
176 …hci_incoming_thread_.GetReactor()->ModifyRegistration(reactable_, os::Reactor::REACT_ON_READ_ONLY); in Start()
185 hci_incoming_thread_.GetReactor()->Unregister(reactable_); in Stop()
188 … hci_incoming_thread_.GetReactor()->WaitForUnregisteredReactable(std::chrono::milliseconds(1000)); in Stop()
222 …hci_incoming_thread_.GetReactor()->ModifyRegistration(reactable_, os::Reactor::REACT_ON_READ_WRITE… in write_to_fd()
236 …hci_incoming_thread_.GetReactor()->ModifyRegistration(reactable_, os::Reactor::REACT_ON_READ_ONLY); in send_packet_ready()
Dhci_hal_host.cc309 reactable_ = hci_incoming_thread_.GetReactor()->Register( in Start()
313 …hci_incoming_thread_.GetReactor()->ModifyRegistration(reactable_, os::Reactor::REACT_ON_READ_ONLY); in Start()
323 hci_incoming_thread_.GetReactor()->Unregister(reactable_); in Stop()
326 … hci_incoming_thread_.GetReactor()->WaitForUnregisteredReactable(std::chrono::milliseconds(1000)); in Stop()
361 …hci_incoming_thread_.GetReactor()->ModifyRegistration(reactable_, os::Reactor::REACT_ON_READ_WRITE… in write_to_fd()
375 …hci_incoming_thread_.GetReactor()->ModifyRegistration(reactable_, os::Reactor::REACT_ON_READ_ONLY); in send_packet_ready()
/packages/modules/Bluetooth/system/gd/os/linux_generic/
Drepeating_alarm.cc43 token_ = handler_->thread_->GetReactor()->Register( in RepeatingAlarm()
48 handler_->thread_->GetReactor()->Unregister(token_); in ~RepeatingAlarm()
Dalarm.cc44 token_ = handler_->thread_->GetReactor()->Register( in Alarm()
49 handler_->thread_->GetReactor()->Unregister(token_); in ~Alarm()
Dthread.cc74 Reactor* Thread::GetReactor() const { in GetReactor() function in bluetooth::os::Thread
Dthread_unittest.cc86 Reactor* reactor = thread->GetReactor(); in TEST_F()
Dqueue_unittest.cc70 enqueue_thread_->GetReactor()->WaitForIdle(2s), in sync_enqueue_handler()
/packages/modules/Bluetooth/system/gd/storage/
Dstorage_module_test.cc133 test_registry_.GetTestThread().GetReactor()->WaitForIdle(std::chrono::seconds(2)); in WaitForReactorIdle()
138 return test_registry_.GetTestThread().GetReactor()->WaitForIdle(std::chrono::seconds(2)); in WaitForReactorIdle()
/packages/modules/Bluetooth/system/gd/
Dmodule.h230 if (!GetTestThread().GetReactor()->WaitForIdle(std::chrono::milliseconds(100))) { in WaitForIdleAndStopAll()
/packages/modules/Bluetooth/system/gd/hci/
Dcontroller_test.cc533 thread_.GetReactor()->WaitForIdle(std::chrono::seconds(1)); in TEST_F()
558 thread_.GetReactor()->WaitForIdle(std::chrono::seconds(1)); in TEST_F()
Dhci_layer_unittest.cc115 fake_registry_.GetTestThread().GetReactor()->WaitForIdle(2s), in sync_handler()
Dle_periodic_sync_manager_test.cc163 thread_->GetReactor()->WaitForIdle(2s), in sync_handler()
Dle_scanning_manager_test.cc319 thread_.GetReactor()->WaitForIdle(std::chrono::seconds(2)), in sync_client_handler()
Dacl_manager_test.cc171 thread_.GetReactor()->WaitForIdle(std::chrono::seconds(2)), in sync_client_handler()
Dle_advertising_manager_test.cc235 thread_.GetReactor()->WaitForIdle(2s), in sync_client_handler()
/packages/modules/Bluetooth/system/gd/hci/acl_manager/
Dle_acl_connection_test.cc200 thread_->GetReactor()->WaitForIdle(2s), in sync_handler()
Dclassic_impl_test.cc208 thread_->GetReactor()->WaitForIdle(2s); in sync_handler()
Dclassic_acl_connection_test.cc265 thread_->GetReactor()->WaitForIdle(2s), in sync_handler()
Dround_robin_scheduler_test.cc102 thread_->GetReactor()->WaitForIdle(2s), in sync_handler()
Dle_impl_test.cc348 thread_->GetReactor()->WaitForIdle(2s), in sync_handler()