Searched refs:Reactor (Results 1 – 13 of 13) sorted by relevance
| /packages/modules/Bluetooth/system/gd/os/linux_generic/ |
| D | reactor.cc | 43 struct Reactor::Event::impl {
57 Reactor::Event::Event() : pimpl_(new impl()) {} in Event()
58 Reactor::Event::~Event() { delete pimpl_; } in ~Event()
60 bool Reactor::Event::Read() { in Read()
64 int Reactor::Event::Id() const { return pimpl_->fd_; } in Id()
65 void Reactor::Event::Clear() { in Clear()
70 void Reactor::Event::Close() { in Close()
76 void Reactor::Event::Notify() { in Notify()
82 class Reactor::Reactable {
99 Reactor::Reactor() : epoll_fd_(0), control_fd_(0), is_running_(false) { in Reactor() function in bluetooth::os::Reactor
[all …]
|
| D | reactor_unittest.cc | 44 reactor_ = new Reactor; in SetUp()
54 Reactor* reactor_;
80 FakeReactable(Reactor* reactor) : fd_(eventfd(0, 0)), reactor_(reactor) { EXPECT_NE(fd_, -1); } in FakeReactable()
122 Reactor::Reactable* reactable_ = nullptr;
126 Reactor* reactor_;
145 Reactor::Reactable* reactable_ = nullptr;
154 auto reactor_thread = std::thread(&Reactor::Run, reactor_); in TEST_F()
160 auto reactor_thread = std::thread(&Reactor::Stop, reactor_); in TEST_F()
161 auto another_thread = std::thread(&Reactor::Run, reactor_); in TEST_F()
167 auto reactor_thread = std::thread(&Reactor::Run, reactor_); in TEST_F()
[all …]
|
| D | thread.cc | 67 Reactor* Thread::GetReactor() const { return &reactor_; } in GetReactor()
|
| D | thread_unittest.cc | 73 Reactor* reactor = thread->GetReactor(); in TEST_F()
|
| /packages/modules/Bluetooth/system/gd/os/ |
| D | reactor.h | 39 class Reactor {
45 Reactor();
47 Reactor(const Reactor&) = delete;
48 Reactor& operator=(const Reactor&) = delete;
51 ~Reactor();
99 std::unique_ptr<Reactor::Event> NewEvent() const;
|
| D | queue.h | 113 Reactor::Reactable* reactable_;
202 Reactor* reactor = nullptr; in UnregisterEnqueue()
203 Reactor::Reactable* to_unregister = nullptr; in UnregisterEnqueue()
233 Reactor* reactor = nullptr; in UnregisterDequeue()
234 Reactor::Reactable* to_unregister = nullptr; in UnregisterDequeue()
|
| D | thread.h | 66 Reactor* GetReactor() const;
72 mutable Reactor reactor_;
|
| D | handler.h | 77 std::unique_ptr<Reactor::Event> event_;
78 Reactor::Reactable* reactable_;
|
| D | repeating_alarm.h | 55 Reactor::Reactable* token_;
|
| D | alarm.h | 59 Reactor::Reactable* token_;
|
| /packages/modules/Bluetooth/system/gd/hal/ |
| D | hci_hal_host_rootcanal.cc | 178 os::Reactor::REACT_ON_READ_ONLY); in Start()
215 bluetooth::os::Reactor::Reactable* reactable_ = nullptr;
224 os::Reactor::REACT_ON_READ_WRITE); in write_to_fd()
241 os::Reactor::REACT_ON_READ_ONLY); in send_packet_ready()
|
| D | hci_hal_host.cc | 326 os::Reactor::REACT_ON_READ_ONLY); in Start()
368 bluetooth::os::Reactor::Reactable* reactable_ = nullptr;
378 os::Reactor::REACT_ON_READ_WRITE); in write_to_fd()
398 os::Reactor::REACT_ON_READ_ONLY); in send_packet_ready()
|
| /packages/modules/Bluetooth/system/gd/docs/architecture/ |
| D | architecture.md | 102 are data packets sent through queues, signaled using [`Reactor`](#reactor). They
175 ### Reactor {#reactor}
177 [`bluetooth::os:Reactor`](https://android.googlesource.com/platform/packages/modules/Bluetooth/syst…
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:
|