Searched refs:reactor (Results 1 – 10 of 10) sorted by relevance
| /system/bt/osi/test/ |
| D | reactor_test.cc | 17 reactor_t* reactor = (reactor_t*)ptr; in reactor_thread() local
20 reactor_start(reactor); in reactor_thread()
26 static void spawn_reactor_thread(reactor_t* reactor) { in spawn_reactor_thread() argument
27 int ret = pthread_create(&thread, NULL, reactor_thread, reactor); in spawn_reactor_thread()
34 reactor_t* reactor = reactor_new(); in TEST_F() local
35 EXPECT_TRUE(reactor != NULL); in TEST_F()
36 reactor_free(reactor); in TEST_F()
42 reactor_t* reactor = reactor_new(); in TEST_F() local
43 reactor_stop(reactor); in TEST_F()
44 reactor_start(reactor); in TEST_F()
[all …]
|
| /system/bt/osi/src/ |
| D | reactor.cc | 55 reactor_t* reactor; // the reactor instance this object is registered with. member
64 static reactor_status_t run_reactor(reactor_t* reactor, int iterations);
114 void reactor_free(reactor_t* reactor) { in reactor_free() argument
115 if (!reactor) return; in reactor_free()
117 list_free(reactor->invalidation_list); in reactor_free()
118 close(reactor->event_fd); in reactor_free()
119 close(reactor->epoll_fd); in reactor_free()
120 osi_free(reactor); in reactor_free()
123 reactor_status_t reactor_start(reactor_t* reactor) { in reactor_start() argument
124 CHECK(reactor != NULL); in reactor_start()
[all …]
|
| D | thread.cc | 47 reactor_t* reactor; member
73 ret->reactor = reactor_new(); in thread_new_sized()
74 if (!ret->reactor) goto error; in thread_new_sized()
98 reactor_free(ret->reactor); in thread_new_sized()
115 reactor_free(thread->reactor); in thread_free()
145 reactor_stop(thread->reactor); in thread_stop()
186 return thread->reactor; in thread_get_reactor()
220 reactor_register(thread->reactor, fd, context, work_queue_read_cb, NULL); in run_thread()
221 reactor_start(thread->reactor); in run_thread()
|
| D | fixed_queue.cc | 232 void fixed_queue_register_dequeue(fixed_queue_t* queue, reactor_t* reactor, in fixed_queue_register_dequeue() argument
235 CHECK(reactor != NULL); in fixed_queue_register_dequeue()
244 reactor_register(reactor, fixed_queue_get_dequeue_fd(queue), queue, in fixed_queue_register_dequeue()
|
| D | socket.cc | 195 void socket_register(socket_t* socket, reactor_t* reactor, void* context, in socket_register() argument
210 reactor_register(reactor, socket->fd, socket, read_fn, write_fn); in socket_register()
|
| /system/bt/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,
|
| /system/bt/osi/ |
| D | BUILD.gn | 34 "src/reactor.cc",
|
| D | Android.bp | 61 "src/reactor.cc",
|