| /external/parameter-framework/asio-1.10.6/include/asio/detail/ |
| reactor_fwd.hpp | 21 typedef class epoll_reactor reactor; typedef in namespace:asio::detail
23 typedef class dev_poll_reactor reactor;
25 typedef class select_reactor reactor;
|
| reactive_socket_service_base.hpp | 28 #include "asio/detail/reactor.hpp"
54 // Per-descriptor data used by the reactor.
55 reactor::per_descriptor_data reactor_data_;
210 start_op(impl, reactor::write_op, p.p, is_continuation, true,
235 start_op(impl, reactor::write_op, p.p, is_continuation, false, false);
283 ? reactor::except_op : reactor::read_op,
312 ? reactor::except_op : reactor::read_op,
369 ? reactor::except_op : reactor::read_op
[all...] |
| reactive_socket_service.hpp | 31 #include "asio/detail/reactor.hpp"
240 start_op(impl, reactor::write_op, p.p, is_continuation, true, false);
262 start_op(impl, reactor::write_op, p.p, is_continuation, false, false);
328 ? reactor::except_op : reactor::read_op,
357 ? reactor::except_op : reactor::read_op,
|
| task_io_service.hpp | 158 reactor* task_;
|
| /system/bt/osi/test/ |
| reactor_test.cc | 9 #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) {
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:__anon113499
83 reactor_t* reactor = reactor_new(); local
99 reactor_t* reactor = reactor_new(); local
[all...] |
| /system/bt/osi/src/ |
| reactor.cc | 21 #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) {
115 if (!reactor) return;
117 list_free(reactor->invalidation_list);
118 close(reactor->event_fd);
119 close(reactor->epoll_fd)
200 reactor_t* reactor = obj->reactor; local
[all...] |
| thread.cc | 39 #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...] |
| fixed_queue.cc | 28 #include "osi/include/reactor.h"
232 void fixed_queue_register_dequeue(fixed_queue_t* queue, reactor_t* reactor,
235 CHECK(reactor != NULL);
244 reactor_register(reactor, fixed_queue_get_dequeue_fd(queue), queue,
|
| socket.cc | 35 #include "osi/include/reactor.h"
195 void socket_register(socket_t* socket, reactor_t* reactor, void* context,
210 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*
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);
[all...] |
| socket.h | 99 // 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.
|
| fixed_queue.h | 124 // 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
|
| /development/tools/axl/ |
| axl.py | 26 from twisted.internet import protocol, reactor, defer
227 reactor.callLater(15, d.callback, count + 1)
247 reactor.listenTCP(protocol.PORT, factory)
250 reactor.run()
|
| /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 | |
| /prebuilts/tools/common/m2/repository/org/apache/maven/maven-core/2.0.9/ |
| maven-core-2.0.9.jar | |
