Searched refs:reactable_ (Results 1 – 6 of 6) sorted by relevance
/packages/modules/Bluetooth/system/gd/os/ |
D | queue.h | 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() [all …]
|
D | handler.cc | 32 reactable_ = thread_->GetReactor()->Register( in Handler() 67 thread_->GetReactor()->Unregister(reactable_); in Clear() 68 reactable_ = nullptr; in Clear() 72 log::assert_that(reactable_ == nullptr, "assert failed: reactable_ == nullptr"); in WaitUntilStopped()
|
D | handler.h | 78 Reactor::Reactable* reactable_; variable
|
/packages/modules/Bluetooth/system/gd/hal/ |
D | hci_hal_host_rootcanal.cc | 172 reactable_ = hci_incoming_thread_.GetReactor()->Register( in Start() 176 …hci_incoming_thread_.GetReactor()->ModifyRegistration(reactable_, os::Reactor::REACT_ON_READ_ONLY); in Start() 184 if (reactable_ != nullptr) { in Stop() 185 hci_incoming_thread_.GetReactor()->Unregister(reactable_); in Stop() 192 reactable_ = nullptr; in Stop() 214 bluetooth::os::Reactor::Reactable* reactable_ = nullptr; member in bluetooth::hal::HciHalHost 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()
|
D | hci_hal_host.cc | 309 reactable_ = hci_incoming_thread_.GetReactor()->Register( in Start() 313 …hci_incoming_thread_.GetReactor()->ModifyRegistration(reactable_, os::Reactor::REACT_ON_READ_ONLY); in Start() 322 if (reactable_ != nullptr) { in Stop() 323 hci_incoming_thread_.GetReactor()->Unregister(reactable_); in Stop() 330 reactable_ = nullptr; in Stop() 352 bluetooth::os::Reactor::Reactable* reactable_ = nullptr; member in bluetooth::hal::HciHalHost 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/ |
D | reactor_unittest.cc | 105 reactable_ = reactor_->Register( in OnReadReady() 112 reactor_->Unregister(reactable_); in OnReadReady() 130 reactor_->Unregister(reactable_); in UnregisterInCallback() 134 Reactor::Reactable* reactable_ = nullptr; member in bluetooth::os::__anon1aab34370111::FakeReactable 161 Reactor::Reactable* reactable_ = nullptr; member in bluetooth::os::__anon1aab34370111::FakeRunningReactable 359 fake_reactable2.reactable_ = reactable2; in TEST_F() 381 fake_reactable2.reactable_ = reactable2; in TEST_F()
|