Searched refs:Reactor (Results 1 – 9 of 9) sorted by relevance
| /system/bt/gd/os/linux_generic/ |
| D | reactor.cc | 39 class Reactor::Reactable {
53 Reactor::Reactor() in Reactor() function in bluetooth::os::Reactor
70 Reactor::~Reactor() { in ~Reactor()
82 void Reactor::Run() { in Run()
104 auto* reactable = static_cast<Reactor::Reactable*>(event.data.ptr); in Run()
131 void Reactor::Stop() { in Stop()
139 Reactor::Reactable* Reactor::Register(int fd, Closure on_read_ready, Closure on_write_ready) { in Register()
158 void Reactor::Unregister(Reactor::Reactable* reactable) { in Unregister()
185 void Reactor::ModifyRegistration(Reactor::Reactable* reactable, Closure on_read_ready, Closure on_w… in ModifyRegistration()
|
| D | reactor_unittest.cc | 38 reactor_ = new Reactor; in SetUp()
48 Reactor* reactor_;
80 FakeReactable(Reactor* reactor) : fd_(eventfd(0, 0)), reactor_(reactor) { in FakeReactable()
113 Reactor::Reactable* reactable_ = nullptr;
117 Reactor* reactor_;
122 auto reactor_thread = std::thread(&Reactor::Run, reactor_); in TEST_F()
128 auto reactor_thread = std::thread(&Reactor::Stop, reactor_); in TEST_F()
129 auto another_thread = std::thread(&Reactor::Run, reactor_); in TEST_F()
135 auto reactor_thread = std::thread(&Reactor::Run, reactor_); in TEST_F()
154 auto reactor_thread = std::thread(&Reactor::Run, reactor_); in TEST_F()
[all …]
|
| D | thread.cc | 72 Reactor* Thread::GetReactor() const { in GetReactor()
|
| D | thread_unittest.cc | 85 Reactor* reactor = thread->GetReactor(); in TEST_F()
|
| /system/bt/gd/os/ |
| D | reactor.h | 38 class Reactor {
44 Reactor();
47 ~Reactor();
49 DISALLOW_COPY_AND_ASSIGN(Reactor);
|
| D | thread.h | 64 Reactor* GetReactor() const;
70 mutable Reactor reactor_;
|
| D | handler.h | 53 Reactor::Reactable* reactable_;
|
| D | repeating_alarm.h | 52 Reactor::Reactable* token_;
|
| D | alarm.h | 52 Reactor::Reactable* token_;
|