Home
last modified time | relevance | path

Searched refs:waiter (Results 1 - 25 of 43) sorted by relevance

12

/third_party/alsa-utils/axfer/
H A Dwaiter.c3 // waiter.c - I/O event waiter.
9 #include "waiter.h"
41 int waiter_context_init(struct waiter_context *waiter, in waiter_context_init() argument
46 const struct waiter_data *waiter; in waiter_context_init() member
64 waiter->private_data = malloc(entries[i].waiter->private_size); in waiter_context_init()
65 if (waiter->private_data == NULL) in waiter_context_init()
67 memset(waiter->private_data, 0, entries[i].waiter in waiter_context_init()
80 waiter_context_prepare(struct waiter_context *waiter) waiter_context_prepare() argument
85 waiter_context_wait_event(struct waiter_context *waiter, int timeout_msec) waiter_context_wait_event() argument
91 waiter_context_release(struct waiter_context *waiter) waiter_context_release() argument
96 waiter_context_destroy(struct waiter_context *waiter) waiter_context_destroy() argument
[all...]
H A Dwaiter-epoll.c3 // waiter-epoll.c - Waiter for event notification by epoll(7).
9 #include "waiter.h"
25 static int epoll_prepare(struct waiter_context *waiter) in epoll_prepare() argument
27 struct epoll_state *state = waiter->private_data; in epoll_prepare()
30 state->ev_count = waiter->pfd_count; in epoll_prepare()
39 for (i = 0; i < (int)waiter->pfd_count; ++i) { in epoll_prepare()
41 .data.fd = waiter->pfds[i].fd, in epoll_prepare()
42 .events = waiter->pfds[i].events, in epoll_prepare()
51 static int epoll_wait_event(struct waiter_context *waiter, int timeout_msec) in epoll_wait_event() argument
53 struct epoll_state *state = waiter in epoll_wait_event()
81 epoll_release(struct waiter_context *waiter) epoll_release() argument
[all...]
H A Dwaiter.h3 // waiter.h - a header for I/O event waiter.
37 int waiter_context_init(struct waiter_context *waiter,
39 int waiter_context_prepare(struct waiter_context *waiter);
40 int waiter_context_wait_event(struct waiter_context *waiter,
42 void waiter_context_release(struct waiter_context *waiter);
43 void waiter_context_destroy(struct waiter_context *waiter);
45 // For internal use in 'waiter' module.
48 int (*prepare)(struct waiter_context *waiter);
49 int (*wait_event)(struct waiter_context *waiter, in
[all...]
H A Dwaiter-poll.c3 // waiter-poll.c - Waiter for event notification by poll(2).
9 #include "waiter.h"
16 static int poll_prepare(struct waiter_context *waiter ATTRIBUTE_UNUSED) in poll_prepare()
18 // Nothing to do because an instance of waiter has required data. in poll_prepare()
22 static int poll_wait_event(struct waiter_context *waiter, int timeout_msec) in poll_wait_event() argument
26 err = poll(waiter->pfds, waiter->pfd_count, timeout_msec); in poll_wait_event()
33 static void poll_release(struct waiter_context *waiter ATTRIBUTE_UNUSED) in poll_release()
35 // Nothing to do because an instance of waiter has required data. in poll_release()
H A Dwaiter-select.c3 // waiter-select.c - Waiter for event notification by select(2).
9 #include "waiter.h"
37 static int select_prepare(struct waiter_context *waiter ATTRIBUTE_UNUSED) in select_prepare()
42 static int select_wait_event(struct waiter_context *waiter, int timeout_msec) in select_wait_event() argument
44 struct select_state *state = waiter->private_data; in select_wait_event()
56 for (i = 0; i < (int)waiter->pfd_count; ++i) { in select_wait_event()
57 pfd = &waiter->pfds[i]; in select_wait_event()
82 for (i = 0; i < (int)waiter->pfd_count; ++i) { in select_wait_event()
83 pfd = &waiter->pfds[i]; in select_wait_event()
97 static void select_release(struct waiter_context *waiter ATTRIBUTE_UNUSE
[all...]
H A Dxfer-libasound.c46 {"waiter-type", 1, 0, OPT_WAITER_TYPE},
186 "An option for waiter type should not be " in xfer_libasound_validate_opts()
192 "An option for waiter type should be used " in xfer_libasound_validate_opts()
316 // Nothing to do for dafault waiter (=snd_pcm_wait()). in prepare_waiter()
327 state->waiter = malloc(sizeof(*state->waiter)); in prepare_waiter()
328 if (state->waiter == NULL) in prepare_waiter()
331 err = waiter_context_init(state->waiter, state->waiter_type, pfd_count); in prepare_waiter()
335 err = snd_pcm_poll_descriptors(state->handle, state->waiter->pfds, in prepare_waiter()
340 return waiter_context_prepare(state->waiter); in prepare_waiter()
349 struct waiter_context *waiter = state->waiter; xfer_libasound_wait_event() local
[all...]
/third_party/python/Lib/concurrent/futures/
H A D_base.py157 waiter = _AsCompletedWaiter()
159 waiter = _FirstCompletedWaiter()
165 waiter = _AllCompletedWaiter(pending_count, stop_on_exception=True)
167 waiter = _AllCompletedWaiter(pending_count, stop_on_exception=False)
172 f._waiters.append(waiter)
174 return waiter
177 def _yield_finished_futures(fs, waiter, ref_collect):
181 Before yielding a future, *waiter* is removed from its waiters
193 f._waiters.remove(waiter)
227 waiter
[all...]
/third_party/python/Lib/asyncio/
H A Dbase_subprocess.py14 waiter=None, extra=None, **kwargs):
53 self._loop.create_task(self._connect_pipes(waiter))
156 async def _connect_pipes(self, waiter):
188 if waiter is not None and not waiter.cancelled():
189 waiter.set_exception(exc)
191 if waiter is not None and not waiter.cancelled():
192 waiter.set_result(None)
228 waiter
[all...]
H A Dstreams.py148 for waiter in self._drain_waiters:
149 if not waiter.done():
150 waiter.set_result(None)
158 for waiter in self._drain_waiters:
159 if not waiter.done():
161 waiter.set_result(None)
163 waiter.set_exception(exc)
170 waiter = self._loop.create_future()
171 self._drain_waiters.append(waiter)
173 await waiter
[all...]
H A Dproactor_events.py50 def __init__(self, loop, sock, protocol, waiter=None,
68 if waiter is not None:
69 # only wake up the waiter when connection_made() has been called
71 waiter, None)
185 def __init__(self, loop, sock, protocol, waiter=None,
189 super().__init__(loop, sock, protocol, waiter, extra, server)
427 raise RuntimeError("Empty waiter is already set")
463 waiter=None, extra=None):
469 super().__init__(loop, sock, protocol, waiter=waiter, extr
[all...]
H A Dtasks.py421 def _release_waiter(waiter, *args):
422 if not waiter.done():
423 waiter.set_result(None)
456 waiter = loop.create_future()
457 timeout_handle = loop.call_later(timeout, _release_waiter, waiter)
458 cb = functools.partial(_release_waiter, waiter)
466 await waiter
503 waiter = loop.create_future()
506 timeout_handle = loop.call_later(timeout, _release_waiter, waiter)
518 if not waiter
[all...]
H A Dbase_events.py306 for waiter in waiters:
307 if not waiter.done():
308 waiter.set_result(waiter)
382 waiter = self._loop.create_future()
383 self._waiters.append(waiter)
384 await waiter
468 def _make_socket_transport(self, sock, protocol, waiter=None, *,
474 self, rawsock, protocol, sslcontext, waiter=None,
484 address=None, waiter
[all...]
H A Dselector_events.py59 def _make_socket_transport(self, sock, protocol, waiter=None, *,
61 return _SelectorSocketTransport(self, sock, protocol, waiter,
65 self, rawsock, protocol, sslcontext, waiter=None,
72 self, protocol, sslcontext, waiter,
82 address=None, waiter=None, extra=None):
84 address, waiter, extra)
209 waiter = self.create_future()
212 conn, protocol, sslcontext, waiter=waiter,
218 conn, protocol, waiter
[all...]
H A Dunix_events.py187 def _make_read_pipe_transport(self, pipe, protocol, waiter=None,
189 return _UnixReadPipeTransport(self, pipe, protocol, waiter, extra)
191 def _make_write_pipe_transport(self, pipe, protocol, waiter=None,
193 return _UnixWritePipeTransport(self, pipe, protocol, waiter, extra)
206 waiter = self.create_future()
209 waiter=waiter, extra=extra,
215 await waiter
462 def __init__(self, loop, pipe, protocol, waiter=None, extra=None):
487 if waiter i
[all...]
H A Dqueues.py59 # Wake up the next waiter (if any) that isn't cancelled.
61 waiter = waiters.popleft()
62 if not waiter.done():
63 waiter.set_result(None)
/third_party/python/Lib/test/test_asyncio/
H A Dtest_sslproto.py34 def ssl_protocol(self, *, waiter=None, proto=None):
38 ssl_proto = sslproto.SSLProtocol(self.loop, proto, sslcontext, waiter,
58 waiter = mock.Mock()
60 sslproto.SSLProtocol(self.loop, app_proto, sslcontext, waiter,
66 waiter = mock.Mock()
68 sslproto.SSLProtocol(self.loop, app_proto, sslcontext, waiter,
72 waiter = self.loop.create_future()
73 ssl_proto = self.ssl_protocol(waiter=waiter)
80 self.assertIsInstance(waiter
[all...]
/third_party/alsa-lib/aserver/
H A Daserver.c115 typedef struct waiter waiter_t;
116 typedef int (*waiter_handler_t)(waiter_t *waiter, unsigned short events);
117 struct waiter { struct
221 static int pcm_handler(waiter_t *waiter, unsigned short events)
223 client_t *client = waiter->private_data;
239 del_waiter(waiter->fd);
531 static int ctl_handler(waiter_t *waiter, unsigned short events) in ctl_handler() argument
533 client_t *client = waiter->private_data; in ctl_handler()
543 del_waiter(waiter->fd); in ctl_handler()
803 static int client_poll_handler(waiter_t *waiter, unsigne argument
817 client_ctrl_handler(waiter_t *waiter, unsigned short events) client_ctrl_handler() argument
835 inet_pending_handler(waiter_t *waiter, unsigned short events) inet_pending_handler() argument
887 local_handler(waiter_t *waiter, unsigned short events ATTRIBUTE_UNUSED) local_handler() argument
906 inet_handler(waiter_t *waiter, unsigned short events ATTRIBUTE_UNUSED) inet_handler() argument
[all...]
/third_party/ltp/testcases/kernel/ipc/semaphore/
H A Dsem02.c60 void *waiter(void *);
101 rc = pthread_create(&pt[i], &attr, waiter, retval[i]); in main()
123 void *waiter(void *foo) in waiter() function
140 waiter thread which will start waiting on it in 10 seconds, should
/third_party/ltp/testcases/kernel/syscalls/ipc/semop/
H A Dsemop05.c60 void *waiter(void *);
101 rc = pthread_create(&pt[i], &attr, waiter, retval[i]); in main()
123 void *waiter(void *foo) in waiter() function
140 waiter thread which will start waiting on it in 10 seconds, should
/third_party/libfuse/lib/
H A Dhelper.c257 int waiter[2]; in fuse_daemonize() local
260 if (pipe(waiter)) { in fuse_daemonize()
276 (void) read(waiter[0], &completed, sizeof(completed)); in fuse_daemonize()
298 (void) write(waiter[1], &completed, sizeof(completed)); in fuse_daemonize()
299 close(waiter[0]); in fuse_daemonize()
300 close(waiter[1]); in fuse_daemonize()
/third_party/musl/src/thread/
H A Dpthread_cond_timedwait.c4 * struct waiter
13 * protected by the lock on the cv. Detached waiter lists are never
20 * different processes), the waiter list is not used for the
25 struct waiter { struct
26 struct waiter *prev, *next;
64 struct waiter node = { 0 }; in __pthread_cond_timedwait()
118 /* Access to cv object is valid because this waiter was not in __pthread_cond_timedwait()
120 * after seeing a LEAVING waiter without getting notified in __pthread_cond_timedwait()
152 /* Unlock the barrier that's holding back the next waiter, and in __pthread_cond_timedwait()
178 struct waiter * in __private_cond_signal()
[all...]
/third_party/skia/third_party/externals/dng_sdk/source/
H A Ddng_pthread.cpp59 struct waiter { struct
60 struct waiter *prev;
61 struct waiter *next;
87 waiter *head_waiter; // List of threads waiting on this condition
88 waiter *tail_waiter; // Used to get FIFO, rather than LIFO, behavior for pthread_cond_signal
576 waiter this_wait; in cond_wait_internal()
578 int my_generation; // The broadcast generation this waiter is in in cond_wait_internal()
587 // Add this waiter to the end of the list. in cond_wait_internal()
593 // If the list was empty, set the head of the list to this waiter. in cond_wait_internal()
597 // Note which broadcast generation this waiter belong in cond_wait_internal()
[all...]
/third_party/musl/porting/linux/user/src/thread/
H A Dpthread_cond_timedwait.c19 * struct waiter
28 * protected by the lock on the cv. Detached waiter lists are never
35 * different processes), the waiter list is not used for the
40 struct waiter { struct
41 struct waiter *prev, *next;
84 struct waiter node = { 0 }; in __pthread_cond_timedwait()
148 /* Access to cv object is valid because this waiter was not in __pthread_cond_timedwait()
150 * after seeing a LEAVING waiter without getting notified in __pthread_cond_timedwait()
194 /* Unlock the barrier that's holding back the next waiter, and in __pthread_cond_timedwait()
224 struct waiter * in __private_cond_signal()
[all...]
/third_party/musl/libc-test/src/regression/
H A Dpthread_cond_wait-cancel_ignored.c21 static void *waiter(void *p) in waiter() function
38 pthread_create(&td, 0, waiter, 0); in main()
/third_party/python/Lib/
H A Dthreading.py313 waiter = _allocate_lock()
314 waiter.acquire()
315 self._waiters.append(waiter)
320 waiter.acquire()
324 gotit = waiter.acquire(True, timeout)
326 gotit = waiter.acquire(False)
332 self._waiters.remove(waiter)
373 waiter = waiters[0]
375 waiter.release()
385 waiters.remove(waiter)
[all...]

Completed in 14 milliseconds

12