| /packages/modules/Bluetooth/system/osi/test/ |
| D | reactor_test.cc | 15 reactor_t* reactor = (reactor_t*)ptr; in reactor_thread() local
18 reactor_start(reactor); in reactor_thread()
24 static void spawn_reactor_thread(reactor_t* reactor) { in spawn_reactor_thread() argument
25 int ret = pthread_create(&thread, NULL, reactor_thread, reactor); in spawn_reactor_thread()
32 reactor_t* reactor = reactor_new(); in TEST_F() local
33 EXPECT_TRUE(reactor != NULL); in TEST_F()
34 reactor_free(reactor); in TEST_F()
40 reactor_t* reactor = reactor_new(); in TEST_F() local
41 reactor_stop(reactor); in TEST_F()
42 reactor_start(reactor); in TEST_F()
[all …]
|
| /packages/modules/Bluetooth/system/osi/src/ |
| D | reactor.cc | 56 reactor_t* reactor; // the reactor instance this object is registered with. member
65 static reactor_status_t run_reactor(reactor_t* reactor, int iterations);
112 void reactor_free(reactor_t* reactor) { in reactor_free() argument
113 if (!reactor) return; in reactor_free()
115 list_free(reactor->invalidation_list); in reactor_free()
116 close(reactor->event_fd); in reactor_free()
117 close(reactor->epoll_fd); in reactor_free()
118 delete reactor->list_mutex; in reactor_free()
119 osi_free(reactor); in reactor_free()
122 reactor_status_t reactor_start(reactor_t* reactor) { in reactor_start() argument
[all …]
|
| D | thread.cc | 49 reactor_t* reactor; member
76 ret->reactor = reactor_new(); in thread_new_sized()
77 if (!ret->reactor) goto error; in thread_new_sized()
101 reactor_free(ret->reactor); in thread_new_sized()
118 reactor_free(thread->reactor); in thread_free()
148 reactor_stop(thread->reactor); in thread_stop()
187 return thread->reactor; in thread_get_reactor()
219 reactor_register(thread->reactor, fd, context, work_queue_read_cb, NULL); in run_thread()
220 reactor_start(thread->reactor); in run_thread()
|
| D | fixed_queue.cc | 235 void fixed_queue_register_dequeue(fixed_queue_t* queue, reactor_t* reactor, in fixed_queue_register_dequeue() argument
238 log::assert_that(reactor != NULL, "assert failed: reactor != NULL"); in fixed_queue_register_dequeue()
247 reactor_register(reactor, fixed_queue_get_dequeue_fd(queue), queue, in fixed_queue_register_dequeue()
|
| D | socket.cc | 191 void socket_register(socket_t* socket, reactor_t* reactor, void* context, in socket_register() argument
206 reactor_register(reactor, socket->fd, socket, read_fn, write_fn); in socket_register()
|
| /packages/modules/Bluetooth/system/osi/include/ |
| D | reactor.h | 45 void reactor_free(reactor_t* reactor);
49 reactor_status_t reactor_start(reactor_t* reactor);
53 reactor_status_t reactor_run_once(reactor_t* reactor);
58 void reactor_stop(reactor_t* reactor);
70 reactor_object_t* reactor_register(reactor_t* reactor, int fd, void* context,
|
| D | socket.h | 104 void socket_register(socket_t* socket, reactor_t* reactor, void* context,
|
| D | fixed_queue.h | 128 void fixed_queue_register_dequeue(fixed_queue_t* queue, reactor_t* reactor,
|
| /packages/modules/Bluetooth/system/gd/os/ |
| D | queue.h | 184 Reactor* reactor = nullptr; in UnregisterEnqueue() local
191 reactor = enqueue_.handler_->thread_->GetReactor(); in UnregisterEnqueue()
197 reactor->Unregister(to_unregister); in UnregisterEnqueue()
199 reactor->WaitForUnregisteredReactable(std::chrono::milliseconds(1000)); in UnregisterEnqueue()
215 Reactor* reactor = nullptr; in UnregisterDequeue() local
222 reactor = dequeue_.handler_->thread_->GetReactor(); in UnregisterDequeue()
228 reactor->Unregister(to_unregister); in UnregisterDequeue()
230 reactor->WaitForUnregisteredReactable(std::chrono::milliseconds(1000)); in UnregisterDequeue()
|
| D | Android.bp | 65 "linux_generic/reactor.cc",
130 "linux_generic/reactor.cc",
|
| D | BUILD.gn | 60 "linux_generic/reactor.cc",
|
| /packages/modules/Bluetooth/system/gd/os/linux_generic/ |
| D | thread_unittest.cc | 86 Reactor* reactor = thread->GetReactor(); in TEST_F() local
88 auto* reactable = reactor->Register( in TEST_F()
96 reactor->Unregister(reactable); in TEST_F()
|
| D | reactor_unittest.cc | 87 FakeReactable(Reactor* reactor) : fd_(eventfd(0, 0)), reactor_(reactor) { in FakeReactable() argument
|
| /packages/modules/Bluetooth/system/test/stub/ |
| D | osi.cc | 180 reactor_object_t* reactor_register(reactor_t* reactor, int fd, void* context, in reactor_register() argument
186 reactor_status_t reactor_run_once(reactor_t* reactor) { in reactor_run_once() argument
190 reactor_status_t reactor_start(reactor_t* reactor) { in reactor_start() argument
198 void reactor_free(reactor_t* reactor) { inc_func_call_count(__func__); } in reactor_free() argument
199 void reactor_stop(reactor_t* reactor) { inc_func_call_count(__func__); } in reactor_stop() argument
318 void fixed_queue_register_dequeue(fixed_queue_t* queue, reactor_t* reactor, in fixed_queue_register_dequeue() argument
423 void socket_register(socket_t* socket, reactor_t* reactor, void* context, in socket_register() argument
|
| /packages/modules/Bluetooth/system/test/mock/ |
| D | mock_osi_socket.h | 122 std::function<void(socket_t* socket, reactor_t* reactor, void* context,
127 void operator()(socket_t* socket, reactor_t* reactor, void* context, in operator()
129 body(socket, reactor, context, read_cb, write_cb); in operator()
|
| D | mock_osi_fixed_queue.h | 167 std::function<void(fixed_queue_t* queue, reactor_t* reactor,
171 void operator()(fixed_queue_t* queue, reactor_t* reactor, in operator()
173 body(queue, reactor, ready_cb, context); in operator()
|
| D | mock_osi_socket.cc | 80 void socket_register(socket_t* socket, reactor_t* reactor, void* context, in socket_register() argument
83 test::mock::osi_socket::socket_register(socket, reactor, context, read_cb, in socket_register()
|
| D | mock_osi_fixed_queue.cc | 103 void fixed_queue_register_dequeue(fixed_queue_t* queue, reactor_t* reactor, in fixed_queue_register_dequeue() argument
106 test::mock::osi_fixed_queue::fixed_queue_register_dequeue(queue, reactor, in fixed_queue_register_dequeue()
|
| /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 …tps://android.googlesource.com/platform/packages/modules/Bluetooth/system/+/master/gd/os/reactor.h)
205 https://android.googlesource.com/platform/packages/modules/Bluetooth/system/+/master/gd/os/reactor.h
|
| /packages/modules/Bluetooth/system/osi/ |
| D | BUILD.gn | 29 "src/reactor.cc",
|
| D | Android.bp | 61 "src/reactor.cc",
|
| /packages/modules/AdServices/adservices/tests/unittest/service-core/assets/classifier/ |
| D | precomputed_test_app_list.csv | 1366 coolcherrytrees.games.reactor 10230
|
| /packages/modules/AdServices/adservices/apk/assets/classifier/ |
| D | precomputed_app_list.csv | 1366 coolcherrytrees.games.reactor 10230
|
| /packages/inputmethods/LatinIME/dictionaries/ |
| D | en_GB_wordlist.combined.gz | |
| D | en_US_wordlist.combined.gz | |