Searched refs:reactor (Results 1 - 8 of 8) sorted by relevance

/system/bt/osi/test/
H A Dreactor_test.cc9 #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 Dreactor.cc21 #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 Dthread.cc39 #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 Dfixed_queue.cc28 #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 Dsocket.cc35 #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 Dreactor.h32 // 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 Dsocket.h99 // 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 Dfixed_queue.h124 // 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