Home
last modified time | relevance | path

Searched refs:Reactor (Results 1 – 13 of 13) sorted by relevance

/system/bt/gd/os/linux_generic/
Dreactor.cc44 class Reactor::Reactable {
61 Reactor::Reactor() : epoll_fd_(0), control_fd_(0), is_running_(false) { in Reactor() function in bluetooth::os::Reactor
74 Reactor::~Reactor() { in ~Reactor()
86 void Reactor::Run() { in Run()
128 auto* reactable = static_cast<Reactor::Reactable*>(event.data.ptr); in Run()
159 void Reactor::Stop() { in Stop()
167 Reactor::Reactable* Reactor::Register(int fd, Closure on_read_ready, Closure on_write_ready) { in Register()
186 void Reactor::Unregister(Reactor::Reactable* reactable) { in Unregister()
218 bool Reactor::WaitForUnregisteredReactable(std::chrono::milliseconds timeout) { in WaitForUnregisteredReactable()
230 bool Reactor::WaitForIdle(std::chrono::milliseconds timeout) { in WaitForIdle()
[all …]
Dreactor_unittest.cc44 reactor_ = new Reactor; in SetUp()
54 Reactor* reactor_;
86 FakeReactable(Reactor* reactor) : fd_(eventfd(0, 0)), reactor_(reactor) { in FakeReactable()
133 Reactor::Reactable* reactable_ = nullptr;
137 Reactor* reactor_;
160 Reactor::Reactable* reactable_ = nullptr;
169 auto reactor_thread = std::thread(&Reactor::Run, reactor_); in TEST_F()
175 auto reactor_thread = std::thread(&Reactor::Stop, reactor_); in TEST_F()
176 auto another_thread = std::thread(&Reactor::Run, reactor_); in TEST_F()
182 auto reactor_thread = std::thread(&Reactor::Run, reactor_); in TEST_F()
[all …]
Dqueue.tpp40 Reactor* reactor = nullptr;
41 Reactor::Reactable* to_unregister = nullptr;
70 Reactor* reactor = nullptr;
71 Reactor::Reactable* to_unregister = nullptr;
Dthread.cc71 Reactor* Thread::GetReactor() const { in GetReactor()
Dthread_unittest.cc86 Reactor* reactor = thread->GetReactor(); in TEST_F()
/system/bt/gd/os/
Dreactor.h38 class Reactor {
44 Reactor();
47 ~Reactor();
49 DISALLOW_COPY_AND_ASSIGN(Reactor);
Dthread.h64 Reactor* GetReactor() const;
70 mutable Reactor reactor_;
Drepeating_alarm.h54 Reactor::Reactable* token_;
Dalarm.h54 Reactor::Reactable* token_;
Dhandler.h106 Reactor::Reactable* reactable_;
Dqueue.h98 Reactor::Reactable* reactable_;
/system/bt/gd/docs/architecture/
Darchitecture.md102 are data packets sent through queues, signaled using [`Reactor`](#reactor). They
175 ### Reactor {#reactor}
177 [`bluetooth::os:Reactor`](https://android.googlesource.com/platform/system/bt/+/master/gd/os/reacto…
179 [Reactor Design Pattern](https://en.wikipedia.org/wiki/Reactor_pattern), in
207 A pure data use case of `Reactor` is a `Reactive Queue`, see its definition at:
/system/bt/gd/hal/
Dhci_hal_host_rootcanal.cc192 bluetooth::os::Reactor::Reactable* reactable_ = nullptr;