Searched refs:reactor_t (Results 1 - 11 of 11) sorted by relevance

/system/bt/osi/include/
H A Dreactor.h29 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 Deager_reader.h28 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 Dthread.h26 typedef struct reactor_t reactor_t; typedef in typeref:struct:reactor_t
65 reactor_t *thread_get_reactor(const thread_t *thread);
H A Dfixed_queue.h25 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 Dsocket.h26 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 Dreactor_test.cpp19 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 Dreactor.c38 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 Dthread.c42 reactor_t *reactor;
162 reactor_t *thread_get_reactor(const thread_t *thread) {
H A Deager_reader.c146 void eager_reader_register(eager_reader_t *reader, reactor_t *reactor, eager_reader_cb read_cb, void *context) {
H A Dfixed_queue.c184 void fixed_queue_register_dequeue(fixed_queue_t *queue, reactor_t *reactor, fixed_queue_cb ready_cb, void *context) {
H A Dsocket.c196 void socket_register(socket_t *socket, reactor_t *reactor, void *context, socket_cb read_cb, socket_cb write_cb) {

Completed in 64 milliseconds