Home
last modified time | relevance | path

Searched refs:reactor_t (Results 1 – 10 of 10) sorted by relevance

/system/bt/osi/include/
Dreactor.h29 typedef struct reactor_t reactor_t; typedef
42 reactor_t* reactor_new(void);
45 void reactor_free(reactor_t* reactor);
49 reactor_status_t reactor_start(reactor_t* reactor);
53 reactor_status_t reactor_run_once(reactor_t* reactor);
58 void reactor_stop(reactor_t* reactor);
70 reactor_object_t* reactor_register(reactor_t* reactor, int fd, void* context,
Dthread.h26 typedef struct reactor_t reactor_t; typedef
81 reactor_t* thread_get_reactor(const thread_t* thread);
Dsocket.h26 typedef struct reactor_t reactor_t; typedef
104 void socket_register(socket_t* socket, reactor_t* reactor, void* context,
Dfixed_queue.h28 typedef struct reactor_t reactor_t; typedef
128 void fixed_queue_register_dequeue(fixed_queue_t* queue, reactor_t* reactor,
/system/bt/osi/test/
Dreactor_test.cc17 reactor_t* reactor = (reactor_t*)ptr; in reactor_thread()
26 static void spawn_reactor_thread(reactor_t* reactor) { in spawn_reactor_thread()
34 reactor_t* reactor = reactor_new(); in TEST_F()
42 reactor_t* reactor = reactor_new(); in TEST_F()
49 reactor_t* reactor = reactor_new(); in TEST_F()
58 reactor_t* reactor = reactor_new(); in TEST_F()
72 reactor_t* reactor;
83 reactor_t* reactor = reactor_new(); in TEST_F()
99 reactor_t* reactor = reactor_new(); in TEST_F()
/system/bt/osi/src/
Dreactor.cc42 struct reactor_t { struct
55 reactor_t* reactor; // the reactor instance this object is registered with. argument
64 static reactor_status_t run_reactor(reactor_t* reactor, int iterations);
69 reactor_t* reactor_new(void) { in reactor_new()
70 reactor_t* ret = (reactor_t*)osi_calloc(sizeof(reactor_t)); in reactor_new()
112 void reactor_free(reactor_t* reactor) { in reactor_free()
121 reactor_status_t reactor_start(reactor_t* reactor) { in reactor_start()
126 reactor_status_t reactor_run_once(reactor_t* reactor) { in reactor_run_once()
131 void reactor_stop(reactor_t* reactor) { in reactor_stop()
137 reactor_object_t* reactor_register(reactor_t* reactor, int fd, void* context, in reactor_register()
[all …]
Dthread.cc47 reactor_t* reactor;
182 reactor_t* thread_get_reactor(const thread_t* thread) { in thread_get_reactor()
Dsocket.cc192 void socket_register(socket_t* socket, reactor_t* reactor, void* context, in socket_register()
Dfixed_queue.cc232 void fixed_queue_register_dequeue(fixed_queue_t* queue, reactor_t* reactor, in fixed_queue_register_dequeue()
/system/bt/test/stub/
Dosi.cc207 reactor_object_t* reactor_register(reactor_t* reactor, int fd, void* context, in reactor_register()
213 reactor_status_t reactor_run_once(reactor_t* reactor) { in reactor_run_once()
217 reactor_status_t reactor_start(reactor_t* reactor) { in reactor_start()
221 reactor_t* reactor_new(void) { in reactor_new()
225 void reactor_free(reactor_t* reactor) { mock_function_count_map[__func__]++; } in reactor_free()
226 void reactor_stop(reactor_t* reactor) { mock_function_count_map[__func__]++; } in reactor_stop()
269 reactor_t* thread_get_reactor(const thread_t* thread) { in thread_get_reactor()
345 void fixed_queue_register_dequeue(fixed_queue_t* queue, reactor_t* reactor, in fixed_queue_register_dequeue()
464 void socket_register(socket_t* socket, reactor_t* reactor, void* context, in socket_register()