| /packages/modules/Bluetooth/system/osi/include/ |
| D | reactor.h | 29 typedef struct reactor_t reactor_t; typedef
42 reactor_t* reactor_new(void);
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 | thread.h | 26 typedef struct reactor_t reactor_t; typedef
81 reactor_t* thread_get_reactor(const thread_t* thread);
|
| D | socket.h | 26 typedef struct reactor_t reactor_t; typedef
104 void socket_register(socket_t* socket, reactor_t* reactor, void* context,
|
| D | fixed_queue.h | 28 typedef struct reactor_t reactor_t; typedef
128 void fixed_queue_register_dequeue(fixed_queue_t* queue, reactor_t* reactor,
|
| /packages/modules/Bluetooth/system/osi/test/ |
| D | reactor_test.cc | 15 reactor_t* reactor = (reactor_t*)ptr; in reactor_thread()
24 static void spawn_reactor_thread(reactor_t* reactor) { in spawn_reactor_thread()
32 reactor_t* reactor = reactor_new(); in TEST_F()
40 reactor_t* reactor = reactor_new(); in TEST_F()
47 reactor_t* reactor = reactor_new(); in TEST_F()
56 reactor_t* reactor = reactor_new(); in TEST_F()
70 reactor_t* reactor;
81 reactor_t* reactor = reactor_new(); in TEST_F()
97 reactor_t* reactor = reactor_new(); in TEST_F()
|
| /packages/modules/Bluetooth/system/osi/src/ |
| D | reactor.cc | 43 struct reactor_t { struct
56 reactor_t* reactor; // the reactor instance this object is registered with. argument
65 static reactor_status_t run_reactor(reactor_t* reactor, int iterations);
70 reactor_t* reactor_new(void) { in reactor_new()
71 reactor_t* ret = (reactor_t*)osi_calloc(sizeof(reactor_t)); in reactor_new()
112 void reactor_free(reactor_t* reactor) { in reactor_free()
122 reactor_status_t reactor_start(reactor_t* reactor) { in reactor_start()
127 reactor_status_t reactor_run_once(reactor_t* reactor) { in reactor_run_once()
132 void reactor_stop(reactor_t* reactor) { in reactor_stop()
138 reactor_object_t* reactor_register(reactor_t* reactor, int fd, void* context, in reactor_register()
[all …]
|
| D | thread.cc | 49 reactor_t* reactor;
185 reactor_t* thread_get_reactor(const thread_t* thread) { in thread_get_reactor()
|
| D | socket.cc | 191 void socket_register(socket_t* socket, reactor_t* reactor, void* context, in socket_register()
|
| D | fixed_queue.cc | 235 void fixed_queue_register_dequeue(fixed_queue_t* queue, reactor_t* reactor, in fixed_queue_register_dequeue()
|
| /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()
186 reactor_status_t reactor_run_once(reactor_t* reactor) { in reactor_run_once()
190 reactor_status_t reactor_start(reactor_t* reactor) { in reactor_start()
194 reactor_t* reactor_new(void) { in reactor_new()
198 void reactor_free(reactor_t* reactor) { inc_func_call_count(__func__); } in reactor_free()
199 void reactor_stop(reactor_t* reactor) { inc_func_call_count(__func__); } in reactor_stop()
242 reactor_t* thread_get_reactor(const thread_t* thread) { in thread_get_reactor()
318 void fixed_queue_register_dequeue(fixed_queue_t* queue, reactor_t* reactor, in fixed_queue_register_dequeue()
423 void socket_register(socket_t* socket, reactor_t* reactor, void* context, in socket_register()
|
| /packages/modules/Bluetooth/system/test/mock/ |
| D | mock_osi_thread.h | 51 reactor_t* return_value{0};
52 std::function<reactor_t*(const thread_t* thread)> body{
54 reactor_t* operator()(const thread_t* thread) { return body(thread); }; in operator()
|
| D | mock_osi_socket.h | 122 std::function<void(socket_t* socket, reactor_t* reactor, void* context,
124 body{[](socket_t* /* socket */, reactor_t* /* reactor */,
127 void operator()(socket_t* socket, reactor_t* reactor, void* context, in operator()
|
| D | mock_osi_fixed_queue.h | 167 std::function<void(fixed_queue_t* queue, reactor_t* reactor,
169 body{[](fixed_queue_t* /* queue */, reactor_t* /* reactor */,
171 void operator()(fixed_queue_t* queue, reactor_t* reactor, in operator()
|
| D | mock_osi_thread.cc | 56 reactor_t* thread_get_reactor(const thread_t* thread) { in thread_get_reactor()
|
| D | mock_osi_socket.cc | 80 void socket_register(socket_t* socket, reactor_t* reactor, void* context, 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()
|
| /packages/modules/Bluetooth/system/test/fake/ |
| D | fake_osi.cc | 361 [](fixed_queue_t* /* q */, reactor_t* /* reactor */, in FakeOsi()
|