Home
last modified time | relevance | path

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

/packages/modules/Bluetooth/system/gd/os/linux_generic/
Dreactor.cc45 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 …]
Dreactor_unittest.cc45 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 …]
Dthread.cc74 Reactor* Thread::GetReactor() const { in GetReactor()
Dthread_unittest.cc86 Reactor* reactor = thread->GetReactor(); in TEST_F()
/packages/modules/Bluetooth/system/gd/os/
Dreactor.h39 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;
Dqueue.h95 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()
Dthread.h65 Reactor* GetReactor() const;
71 mutable Reactor reactor_;
Dhandler.h77 std::unique_ptr<Reactor::Event> event_;
78 Reactor::Reactable* reactable_;
Drepeating_alarm.h55 Reactor::Reactable* token_;
Dalarm.h55 Reactor::Reactable* token_;
/packages/modules/Bluetooth/system/gd/hal/
Dhci_hal_host_rootcanal.cc176 …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()
Dhci_hal_host.cc313 …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/
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/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: