Searched refs:Reactor (Results 1 – 13 of 13) sorted by relevance
| /packages/modules/Bluetooth/system/gd/os/linux_generic/ |
| D | reactor.cc | 45 struct Reactor::Event::impl {
58 Reactor::Event::Event() : pimpl_(new impl()) {} in Event()
59 Reactor::Event::~Event() { in ~Event()
63 bool Reactor::Event::Read() { in Read()
67 int Reactor::Event::Id() const { in Id()
70 void Reactor::Event::Clear() { in Clear()
75 void Reactor::Event::Close() { in Close()
80 void Reactor::Event::Notify() { in Notify()
86 class Reactor::Reactable {
103 Reactor::Reactor() : epoll_fd_(0), control_fd_(0), is_running_(false) { in Reactor() function in bluetooth::os::Reactor
[all …]
|
| D | reactor_unittest.cc | 45 reactor_ = new Reactor; in SetUp()
55 Reactor* reactor_;
87 FakeReactable(Reactor* reactor) : fd_(eventfd(0, 0)), reactor_(reactor) { in FakeReactable()
134 Reactor::Reactable* reactable_ = nullptr;
138 Reactor* reactor_;
161 Reactor::Reactable* reactable_ = nullptr;
170 auto reactor_thread = std::thread(&Reactor::Run, reactor_); in TEST_F()
176 auto reactor_thread = std::thread(&Reactor::Stop, reactor_); in TEST_F()
177 auto another_thread = std::thread(&Reactor::Run, reactor_); in TEST_F()
183 auto reactor_thread = std::thread(&Reactor::Run, reactor_); in TEST_F()
[all …]
|
| D | thread.cc | 74 Reactor* Thread::GetReactor() const { in GetReactor()
|
| D | thread_unittest.cc | 86 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();
97 std::unique_ptr<Reactor::Event> NewEvent() const;
|
| D | queue.h | 95 Reactor::Reactable* reactable_;
184 Reactor* reactor = nullptr; in UnregisterEnqueue()
185 Reactor::Reactable* to_unregister = nullptr; in UnregisterEnqueue()
215 Reactor* reactor = nullptr; in UnregisterDequeue()
216 Reactor::Reactable* to_unregister = nullptr; in UnregisterDequeue()
|
| D | thread.h | 65 Reactor* GetReactor() const;
71 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 | 55 Reactor::Reactable* token_;
|
| /packages/modules/Bluetooth/system/gd/hal/ |
| D | hci_hal_host_rootcanal.cc | 176 …hci_incoming_thread_.GetReactor()->ModifyRegistration(reactable_, os::Reactor::REACT_ON_READ_ONLY); in Start()
214 bluetooth::os::Reactor::Reactable* reactable_ = nullptr;
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 | 313 …hci_incoming_thread_.GetReactor()->ModifyRegistration(reactable_, os::Reactor::REACT_ON_READ_ONLY); in Start()
352 bluetooth::os::Reactor::Reactable* reactable_ = nullptr;
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/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:
|