Searched refs:reactor (Results 1 - 8 of 8) sorted by relevance
/system/bt/osi/test/ |
H A D | reactor_test.cc | 9 #include "osi/include/reactor.h" 17 reactor_t* reactor = (reactor_t*)ptr; local 20 reactor_start(reactor); 26 static void spawn_reactor_thread(reactor_t* reactor) { argument 27 int ret = pthread_create(&thread, NULL, reactor_thread, reactor); 34 reactor_t* reactor = reactor_new(); local 35 EXPECT_TRUE(reactor != NULL); 36 reactor_free(reactor); 42 reactor_t* reactor = reactor_new(); local 43 reactor_stop(reactor); 49 reactor_t* reactor = reactor_new(); local 58 reactor_t* reactor = reactor_new(); local 72 reactor_t* reactor; member in struct:__anon755 83 reactor_t* reactor = reactor_new(); local 99 reactor_t* reactor = reactor_new(); local [all...] |
/system/bt/osi/src/ |
H A D | reactor.cc | 21 #include "osi/include/reactor.h" 46 list_t* invalidation_list; // reactor objects that have been unregistered. 55 reactor_t* reactor; // the reactor instance this object is registered with. member in struct:reactor_object_t 64 static reactor_status_t run_reactor(reactor_t* reactor, int iterations); 114 void reactor_free(reactor_t* reactor) { argument 115 if (!reactor) return; 117 list_free(reactor->invalidation_list); 118 close(reactor->event_fd); 119 close(reactor 123 reactor_start(reactor_t* reactor) argument 128 reactor_run_once(reactor_t* reactor) argument 133 reactor_stop(reactor_t* reactor) argument 139 reactor_register(reactor_t* reactor, int fd, void* context, void (*read_ready)(void* context), void (*write_ready)(void* context)) argument 200 reactor_t* reactor = obj->reactor; local 234 run_reactor(reactor_t* reactor, int iterations) argument [all...] |
H A D | thread.cc | 39 #include "osi/include/reactor.h" 47 reactor_t* reactor; member in struct:thread_t 73 ret->reactor = reactor_new(); 74 if (!ret->reactor) goto error; 98 reactor_free(ret->reactor); 115 reactor_free(thread->reactor); 145 reactor_stop(thread->reactor); 186 return thread->reactor; 220 reactor_register(thread->reactor, fd, context, work_queue_read_cb, NULL); 221 reactor_start(thread->reactor); [all...] |
H A D | fixed_queue.cc | 28 #include "osi/include/reactor.h" 232 void fixed_queue_register_dequeue(fixed_queue_t* queue, reactor_t* reactor, argument 235 CHECK(reactor != NULL); 244 reactor_register(reactor, fixed_queue_get_dequeue_fd(queue), queue,
|
H A D | socket.cc | 35 #include "osi/include/reactor.h" 195 void socket_register(socket_t* socket, reactor_t* reactor, void* context, argument 210 reactor_register(reactor, socket->fd, socket, read_fn, write_fn);
|
/system/bt/osi/include/ |
H A D | reactor.h | 32 // Enumerates the reasons a reactor has stopped. 36 REACTOR_STATUS_DONE, // the reactor completed its work (for the _run_once* 40 // Creates a new reactor object. Returns NULL on failure. The returned object 44 // Frees a reactor object created with |reactor_new|. |reactor| may be NULL. 45 void reactor_free(reactor_t* reactor); 47 // Starts the reactor. This function blocks the caller until |reactor_stop| is 48 // called from another thread or in a callback. |reactor| may not be NULL. 49 reactor_status_t reactor_start(reactor_t* reactor); 51 // Runs one iteration of the reactor [all...] |
H A D | socket.h | 99 // Registers |socket| with the |reactor|. When the socket becomes readable, 102 // callback routines. Neither |socket| nor |reactor| may be NULL. |read_cb|, 104 void socket_register(socket_t* socket, reactor_t* reactor, void* context, 107 // Unregisters |socket| from whichever reactor it is registered with, if any.
|
H A D | fixed_queue.h | 124 // Registers |queue| with |reactor| for dequeue operations. When there is an 126 // passed, untouched, to the callback routine. Neither |queue|, nor |reactor|, 128 void fixed_queue_register_dequeue(fixed_queue_t* queue, reactor_t* reactor, 131 // Unregisters the dequeue ready callback for |queue| from whichever reactor
|
Completed in 96 milliseconds