| /system/bt/osi/test/ |
| reactor_test.cpp | 10 #include "reactor.h"
19 reactor_t *reactor = (reactor_t *)ptr; local
22 reactor_start(reactor);
28 static void spawn_reactor_thread(reactor_t *reactor) {
29 int ret = pthread_create(&thread, NULL, reactor_thread, reactor);
38 reactor_t *reactor = reactor_new(); local
39 EXPECT_TRUE(reactor != NULL);
40 reactor_free(reactor);
48 reactor_t *reactor = reactor_new(); local
49 reactor_stop(reactor);
55 reactor_t *reactor = reactor_new(); local
64 reactor_t *reactor = reactor_new(); local
78 reactor_t *reactor; member in struct:__anon69285
89 reactor_t *reactor = reactor_new(); local
105 reactor_t *reactor = reactor_new(); local
[all...] |
| /system/bt/osi/src/ |
| reactor.c | 32 #include "osi/include/reactor.h"
42 list_t *invalidation_list; // reactor objects that have been unregistered.
51 reactor_t *reactor; // the reactor instance this object is registered with. member in struct:reactor_object_t
58 static reactor_status_t run_reactor(reactor_t *reactor, int iterations);
106 void reactor_free(reactor_t *reactor) {
107 if (!reactor)
110 list_free(reactor->invalidation_list);
111 close(reactor->event_fd);
112 close(reactor->epoll_fd)
199 reactor_t *reactor = obj->reactor; local
[all...] |
| thread.c | 33 #include "osi/include/reactor.h"
42 reactor_t *reactor; member in struct:thread_t
70 ret->reactor = reactor_new();
71 if (!ret->reactor)
99 reactor_free(ret->reactor);
117 reactor_free(thread->reactor);
154 reactor_stop(thread->reactor);
164 return thread->reactor;
193 reactor_object_t *work_queue_object = reactor_register(thread->reactor, fd, context, work_queue_read_cb, NULL);
194 reactor_start(thread->reactor);
[all...] |
| eager_reader.c | 32 #include "osi/include/reactor.h"
146 void eager_reader_register(eager_reader_t *reader, reactor_t *reactor, eager_reader_cb read_cb, void *context) {
148 assert(reactor != NULL);
156 reader->outbound_registration = reactor_register(reactor, reader->bytes_available_fd, reader, internal_outbound_read_ready, NULL);
|
| fixed_queue.c | 28 #include "osi/include/reactor.h"
184 void fixed_queue_register_dequeue(fixed_queue_t *queue, reactor_t *reactor, fixed_queue_cb ready_cb, void *context) {
186 assert(reactor != NULL);
195 reactor,
|
| socket.c | 34 #include "osi/include/reactor.h"
196 void socket_register(socket_t *socket, reactor_t *reactor, void *context, socket_cb read_cb, socket_cb write_cb) {
209 socket->reactor_object = reactor_register(reactor, socket->fd, socket, read_fn, write_fn);
|
| /system/bt/osi/include/ |
| reactor.h | 26 // This module implements the Reactor pattern.
32 // Enumerates the reasons a reactor has stopped.
36 REACTOR_STATUS_DONE, // the reactor completed its work (for the _run_once* variants).
39 // Creates a new reactor object. Returns NULL on failure. The returned object
43 // Frees a reactor object created with |reactor_new|. |reactor| may be NULL.
44 void reactor_free(reactor_t *reactor);
46 // Starts the reactor. This function blocks the caller until |reactor_stop| is called
47 // from another thread or in a callback. |reactor| may not be NULL.
48 reactor_status_t reactor_start(reactor_t *reactor);
[all...] |
| eager_reader.h | 49 // Registers |reader| with the |reactor|. When the reader has data
51 // Neither |reader|, nor |reactor|, nor |read_cb| may be NULL. |context| may be NULL.
52 void eager_reader_register(eager_reader_t *reader, reactor_t *reactor, eager_reader_cb read_cb, void *context);
54 // Unregisters |reader| from whichever reactor it is registered with, if any. This
|
| fixed_queue.h | 89 // Registers |queue| with |reactor| for dequeue operations. When there is an element
91 // to the callback routine. Neither |queue|, nor |reactor|, nor |read_cb| may be NULL.
93 void fixed_queue_register_dequeue(fixed_queue_t *queue, reactor_t *reactor, fixed_queue_cb ready_cb, void *context);
95 // Unregisters the dequeue ready callback for |queue| from whichever reactor
|
| socket.h | 92 // Registers |socket| with the |reactor|. When the socket becomes readable, |read_cb|
95 // |socket| nor |reactor| may be NULL. |read_cb|, |write_cb|, and |context| may be NULL.
96 void socket_register(socket_t *socket, reactor_t *reactor, void *context, socket_cb read_cb, socket_cb write_cb);
98 // Unregisters |socket| from whichever reactor it is registered with, if any. This
|
| /prebuilts/eclipse/mavenplugins/tycho/tycho-dependencies-m2repo/org/eclipse/tycho/tycho-artifactcomparator/0.20.0/ |
| tycho-artifactcomparator-0.20.0.jar | |
| /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()
|
| /system/bt/osi/ |
| Android.mk | 45 ./src/reactor.c \
|
| /prebuilts/eclipse/mavenplugins/tycho/tycho-dependencies-m2repo/org/eclipse/tycho/org.eclipse.tycho.p2.tools.impl/0.20.0/ |
| org.eclipse.tycho.p2.tools.impl-0.20.0.jar | |
| /prebuilts/tools/common/m2/repository/org/eclipse/tycho/org.eclipse.tycho.p2.tools.impl/0.18.1/ |
| org.eclipse.tycho.p2.tools.impl-0.18.1.jar | |
