Searched defs:reactor (Results 1 - 5 of 5) 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 | 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 | 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 | 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);
|
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...] |
Completed in 67 milliseconds