Home
last modified time | relevance | path

Searched refs:reactable (Results 1 – 4 of 4) sorted by relevance

/packages/modules/Bluetooth/system/gd/os/linux_generic/
Dreactor.cc170 auto* reactable = static_cast<Reactor::Reactable*>(event.data.ptr); in Run() local
174 …if (std::find(invalidation_list_.begin(), invalidation_list_.end(), reactable) != invalidation_lis… in Run()
179 std::lock_guard<std::mutex> reactable_lock(reactable->mutex_); in Run()
181 reactable->is_executing_ = true; in Run()
183 …if (event.events & (EPOLLIN | EPOLLHUP | EPOLLRDHUP | EPOLLERR) && !reactable->on_read_ready_.is_n… in Run()
184 reactable->on_read_ready_.Run(); in Run()
186 if (event.events & EPOLLOUT && !reactable->on_write_ready_.is_null()) { in Run()
187 reactable->on_write_ready_.Run(); in Run()
190 std::unique_lock<std::mutex> reactable_lock(reactable->mutex_); in Run()
191 reactable->is_executing_ = false; in Run()
[all …]
Dreactor_unittest.cc191 auto* reactable = reactor_->Register( in TEST_F() local
194 reactor_->Unregister(reactable); in TEST_F()
199 auto* reactable = reactor_->Register( in TEST_F() local
209 reactor_->Unregister(reactable); in TEST_F()
217 auto* reactable = reactor_->Register( in TEST_F() local
225 reactor_->Unregister(reactable); in TEST_F()
230 auto* reactable = reactor_->Register( in TEST_F() local
238 reactor_->Unregister(reactable); in TEST_F()
248 auto* reactable = reactor_->Register( in TEST_F() local
256 reactor_->Unregister(reactable); in TEST_F()
[all …]
Dthread_unittest.cc88 auto* reactable = reactor->Register( in TEST_F() local
96 reactor->Unregister(reactable); in TEST_F()
/packages/modules/Bluetooth/system/gd/os/
Dreactor.h65 void Unregister(Reactable* reactable);
80 void ModifyRegistration(Reactable* reactable, ReactOn react_on);