Searched refs:reactor_t (Results 1 - 11 of 11) sorted by relevance
/system/bt/osi/include/ |
H A D | reactor.h | 29 typedef struct reactor_t reactor_t; typedef in typeref:struct:reactor_t 41 reactor_t *reactor_new(void); 44 void reactor_free(reactor_t *reactor); 48 reactor_status_t reactor_start(reactor_t *reactor); 52 reactor_status_t reactor_run_once(reactor_t *reactor); 56 void reactor_stop(reactor_t *reactor); 66 reactor_object_t *reactor_register(reactor_t *reactor,
|
H A D | eager_reader.h | 28 typedef struct reactor_t reactor_t; typedef in typeref:struct:reactor_t 52 void eager_reader_register(eager_reader_t *reader, reactor_t *reactor, eager_reader_cb read_cb, void *context);
|
H A D | thread.h | 26 typedef struct reactor_t reactor_t; typedef in typeref:struct:reactor_t 65 reactor_t *thread_get_reactor(const thread_t *thread);
|
H A D | fixed_queue.h | 25 typedef struct reactor_t reactor_t; typedef in typeref:struct:reactor_t 93 void fixed_queue_register_dequeue(fixed_queue_t *queue, reactor_t *reactor, fixed_queue_cb ready_cb, void *context);
|
H A D | socket.h | 26 typedef struct reactor_t reactor_t; typedef in typeref:struct:reactor_t 96 void socket_register(socket_t *socket, reactor_t *reactor, void *context, socket_cb read_cb, socket_cb write_cb);
|
/system/bt/osi/test/ |
H A D | reactor_test.cpp | 19 reactor_t *reactor = (reactor_t *)ptr; 28 static void spawn_reactor_thread(reactor_t *reactor) { 38 reactor_t *reactor = reactor_new(); 48 reactor_t *reactor = reactor_new(); 55 reactor_t *reactor = reactor_new(); 64 reactor_t *reactor = reactor_new(); 78 reactor_t *reactor; 89 reactor_t *reactor = reactor_new(); 105 reactor_t *reacto [all...] |
/system/bt/osi/src/ |
H A D | reactor.c | 38 struct reactor_t { struct 51 reactor_t *reactor; // the reactor instance this object is registered with. 58 static reactor_status_t run_reactor(reactor_t *reactor, int iterations); 63 reactor_t *reactor_new(void) { 64 reactor_t *ret = (reactor_t *)osi_calloc(sizeof(reactor_t)); 106 void reactor_free(reactor_t *reactor) { 116 reactor_status_t reactor_start(reactor_t *reactor) { 121 reactor_status_t reactor_run_once(reactor_t *reacto [all...] |
H A D | thread.c | 42 reactor_t *reactor; 162 reactor_t *thread_get_reactor(const thread_t *thread) {
|
H A D | eager_reader.c | 146 void eager_reader_register(eager_reader_t *reader, reactor_t *reactor, eager_reader_cb read_cb, void *context) {
|
H A D | fixed_queue.c | 184 void fixed_queue_register_dequeue(fixed_queue_t *queue, reactor_t *reactor, fixed_queue_cb ready_cb, void *context) {
|
H A D | socket.c | 196 void socket_register(socket_t *socket, reactor_t *reactor, void *context, socket_cb read_cb, socket_cb write_cb) {
|
Completed in 124 milliseconds