| /external/bluetooth/bluedroid/osi/test/ |
| reactor_test.cpp | 7 #include "reactor.h"
14 reactor_t *reactor = (reactor_t *)ptr; local
17 reactor_start(reactor);
23 static void spawn_reactor_thread(reactor_t *reactor) {
24 int ret = pthread_create(&thread, NULL, reactor_thread, reactor);
39 reactor_t *reactor = reactor_new(); local
40 EXPECT_TRUE(reactor != NULL);
41 reactor_free(reactor);
49 reactor_t *reactor = reactor_new(); local
50 reactor_stop(reactor);
56 reactor_t *reactor = reactor_new(); local
65 reactor_t *reactor = reactor_new(); local
79 reactor_t *reactor = reactor_new(); local
93 reactor_t *reactor = reactor_new(); local
[all...] |
| /external/bluetooth/bluedroid/osi/src/ |
| reactor.c | 29 #include "reactor.h"
40 static reactor_status_t run_reactor(reactor_t *reactor, int iterations, struct timeval *tv);
66 void reactor_free(reactor_t *reactor) {
67 if (!reactor)
70 list_free(reactor->objects);
71 close(reactor->event_fd);
72 free(reactor);
75 reactor_status_t reactor_start(reactor_t *reactor) {
76 assert(reactor != NULL);
77 return run_reactor(reactor, 0, NULL)
[all...] |
| thread.c | 30 #include "reactor.h"
38 reactor_t *reactor; member in struct:thread_t
66 ret->reactor = reactor_new();
67 if (!ret->reactor)
92 reactor_free(ret->reactor);
105 reactor_free(thread->reactor);
132 reactor_stop(thread->reactor);
164 reactor_register(thread->reactor, &work_queue_object);
165 reactor_start(thread->reactor);
|
| /external/bluetooth/bluedroid/osi/include/ |
| reactor.h | 26 // This module implements the Reactor pattern.
35 // Enumerates the types of events a reactor object is interested
43 // Enumerates the reasons a reactor has stopped.
46 REACTOR_STATUS_TIMEOUT, // a timeout was specified and the reactor timed out.
48 REACTOR_STATUS_DONE, // the reactor completed its work (for the _run_once* variants).
60 // Creates a new reactor object. Returns NULL on failure. The returned object
64 // Frees a reactor object created with |reactor_new|. |reactor| may be NULL.
65 void reactor_free(reactor_t *reactor);
67 // Starts the reactor. This function blocks the caller until |reactor_stop| is calle
[all...] |
| /external/bluetooth/bluedroid/osi/ |
| Android.mk | 13 ./src/reactor.c \
|
| /development/tools/axl/ |
| axl.py | 26 from twisted.internet import protocol, reactor, defer namespace
227 reactor.callLater(15, d.callback, count + 1)
247 reactor.listenTCP(protocol.PORT, factory)
250 reactor.run()
|
