| /third_party/alsa-utils/axfer/ |
| D | waiter.c | 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->private_size); in waiter_context_init()
69 waiter->type = type; in waiter_context_init()
70 waiter->ops = &entries[i].waiter->ops; in waiter_context_init()
72 waiter->pfds = calloc(pfd_count, sizeof(*waiter->pfds)); in waiter_context_init()
73 if (waiter->pfds == NULL) in waiter_context_init()
75 waiter->pfd_count = pfd_count; in waiter_context_init()
[all …]
|
| D | waiter-epoll.c | 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 < 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->private_data; in epoll_wait_event()
69 for (j = 0; j < waiter->pfd_count; ++j) { in epoll_wait_event()
70 if (waiter->pfds[i].fd == ev->data.fd) { in epoll_wait_event()
[all …]
|
| D | waiter.h | 36 int waiter_context_init(struct waiter_context *waiter,
38 int waiter_context_prepare(struct waiter_context *waiter);
39 int waiter_context_wait_event(struct waiter_context *waiter,
41 void waiter_context_release(struct waiter_context *waiter);
42 void waiter_context_destroy(struct waiter_context *waiter);
47 int (*prepare)(struct waiter_context *waiter);
48 int (*wait_event)(struct waiter_context *waiter, int timeout_msec);
49 void (*release)(struct waiter_context *waiter);
|
| D | waiter-select.c | 37 static int select_prepare(struct waiter_context *waiter) in select_prepare() argument
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 < waiter->pfd_count; ++i) { in select_wait_event()
57 pfd = &waiter->pfds[i]; in select_wait_event()
82 for (i = 0; i < 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) in select_release() argument
|
| D | waiter-poll.c | 16 static int poll_prepare(struct waiter_context *waiter) in poll_prepare() argument
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) in poll_release() argument
|
| D | Makefile.am | 30 waiter.h
57 waiter.h \
58 waiter.c \
59 waiter-poll.c \
60 waiter-select.c \
61 waiter-epoll.c \
|
| D | xfer-libasound.c | 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; in xfer_libasound_wait_event() local
352 count = waiter_context_wait_event(waiter, timeout_msec); in xfer_libasound_wait_event()
359 waiter->pfds, waiter->pfd_count, revents); in xfer_libasound_wait_event()
|
| /third_party/python/Lib/concurrent/futures/ |
| D | _base.py | 159 waiter = _AsCompletedWaiter()
161 waiter = _FirstCompletedWaiter()
167 waiter = _AllCompletedWaiter(pending_count, stop_on_exception=True)
169 waiter = _AllCompletedWaiter(pending_count, stop_on_exception=False)
174 f._waiters.append(waiter)
176 return waiter
179 def _yield_finished_futures(fs, waiter, ref_collect): argument
195 f._waiters.remove(waiter)
229 waiter = _create_and_install_waiters(fs, _AS_COMPLETED)
232 yield from _yield_finished_futures(finished, waiter,
[all …]
|
| /third_party/python/Lib/asyncio/ |
| D | streams.py | 147 waiter = self._drain_waiter
148 if waiter is not None:
150 if not waiter.done():
151 waiter.set_result(None)
158 waiter = self._drain_waiter
159 if waiter is None:
162 if waiter.done():
165 waiter.set_result(None)
167 waiter.set_exception(exc)
174 waiter = self._drain_waiter
[all …]
|
| D | base_subprocess.py | 14 waiter=None, extra=None, **kwargs): argument
53 self._loop.create_task(self._connect_pipes(waiter))
156 async def _connect_pipes(self, waiter): argument
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)
221 for waiter in self._exit_waiters:
222 if not waiter.cancelled():
223 waiter.set_result(returncode)
[all …]
|
| D | proactor_events.py | 50 def __init__(self, loop, sock, protocol, waiter=None, argument
67 if waiter is not None:
70 waiter, None)
181 def __init__(self, loop, sock, protocol, waiter=None, argument
185 super().__init__(loop, sock, protocol, waiter, extra, server)
458 waiter=None, extra=None): argument
463 super().__init__(loop, sock, protocol, waiter=waiter, extra=extra)
602 def __init__(self, loop, sock, protocol, waiter=None, argument
604 super().__init__(loop, sock, protocol, waiter, extra, server)
636 def _make_socket_transport(self, sock, protocol, waiter=None, argument
[all …]
|
| D | tasks.py | 387 def _release_waiter(waiter, *args): argument
388 if not waiter.done():
389 waiter.set_result(None)
422 waiter = loop.create_future()
423 timeout_handle = loop.call_later(timeout, _release_waiter, waiter)
424 cb = functools.partial(_release_waiter, waiter)
432 await waiter
469 waiter = loop.create_future()
472 timeout_handle = loop.call_later(timeout, _release_waiter, waiter)
484 if not waiter.done():
[all …]
|
| D | base_events.py | 304 for waiter in waiters:
305 if not waiter.done():
306 waiter.set_result(waiter)
379 waiter = self._loop.create_future()
380 self._waiters.append(waiter)
381 await waiter
460 def _make_socket_transport(self, sock, protocol, waiter=None, *, argument
466 self, rawsock, protocol, sslcontext, waiter=None, argument
475 address=None, waiter=None, extra=None): argument
479 def _make_read_pipe_transport(self, pipe, protocol, waiter=None, argument
[all …]
|
| D | selector_events.py | 64 def _make_socket_transport(self, sock, protocol, waiter=None, *, argument
66 return _SelectorSocketTransport(self, sock, protocol, waiter,
70 self, rawsock, protocol, sslcontext, waiter=None, argument
75 self, protocol, sslcontext, waiter,
83 address=None, waiter=None, extra=None): argument
85 address, waiter, extra)
206 waiter = self.create_future()
209 conn, protocol, sslcontext, waiter=waiter,
214 conn, protocol, waiter=waiter, extra=extra,
218 await waiter
[all …]
|
| /third_party/python/Lib/test/test_asyncio/ |
| D | test_sslproto.py | 35 def ssl_protocol(self, *, waiter=None, proto=None): argument
39 ssl_proto = sslproto.SSLProtocol(self.loop, proto, sslcontext, waiter,
62 waiter = mock.Mock()
64 sslproto.SSLProtocol(self.loop, app_proto, sslcontext, waiter,
70 waiter = mock.Mock()
72 sslproto.SSLProtocol(self.loop, app_proto, sslcontext, waiter,
76 waiter = self.loop.create_future()
77 ssl_proto = self.ssl_protocol(waiter=waiter)
81 self.assertIsInstance(waiter.exception(), ConnectionResetError)
87 waiter = self.loop.create_future()
[all …]
|
| D | test_selector_events.py | 81 waiter = self.loop.create_future()
84 m, asyncio.Protocol(), m, waiter)
512 def socket_transport(self, waiter=None): argument
514 self.protocol, waiter=waiter)
519 waiter = self.loop.create_future()
520 tr = self.socket_transport(waiter=waiter)
521 self.loop.run_until_complete(waiter)
528 waiter = self.loop.create_future()
529 self.socket_transport(waiter=waiter)
530 self.loop.run_until_complete(waiter)
[all …]
|
| /third_party/alsa-lib/aserver/ |
| D | aserver.c | 114 typedef struct waiter waiter_t;
115 typedef int (*waiter_handler_t)(waiter_t *waiter, unsigned short events);
116 struct waiter { struct
220 static int pcm_handler(waiter_t *waiter, unsigned short events)
222 client_t *client = waiter->private_data;
238 del_waiter(waiter->fd);
530 static int ctl_handler(waiter_t *waiter, unsigned short events) in ctl_handler() argument
532 client_t *client = waiter->private_data; in ctl_handler()
542 del_waiter(waiter->fd); in ctl_handler()
798 static int client_poll_handler(waiter_t *waiter, unsigned short events ATTRIBUTE_UNUSED) in client_poll_handler() argument
[all …]
|
| /third_party/ltp/testcases/kernel/ipc/semaphore/ |
| D | sem02.c | 60 void *waiter(void *);
101 rc = pthread_create(&pt[i], &attr, waiter, retval[i]); in main()
123 void *waiter(void *foo) in waiter() function
|
| /third_party/ltp/testcases/kernel/syscalls/ipc/semop/ |
| D | semop05.c | 60 void *waiter(void *);
101 rc = pthread_create(&pt[i], &attr, waiter, retval[i]); in main()
123 void *waiter(void *foo) in waiter() function
|
| /third_party/libfuse/lib/ |
| D | helper.c | 257 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/rust/crates/once_cell/src/ |
| D | imp_std.rs | 168 let mut waiter = strict::map_addr(queue, |q| q & !STATE_MASK); in drop() localVariable
169 while !waiter.is_null() { in drop()
170 let next = (*waiter).next; in drop()
171 let thread = (*waiter).thread.take().unwrap(); in drop()
172 (*waiter).signaled.store(true, Ordering::Release); in drop()
173 waiter = next; in drop()
|
| /third_party/musl/src/thread/ |
| D | pthread_cond_timedwait.c | 25 struct waiter { struct
26 struct waiter *prev, *next; argument
64 struct waiter node = { 0 }; in __pthread_cond_timedwait()
178 struct waiter *p, *first=0; in __private_cond_signal()
|
| /third_party/musl/porting/linux/user/src/thread/ |
| D | pthread_cond_timedwait.c | 25 struct waiter { struct
26 struct waiter *prev, *next; argument
64 struct waiter node = { 0 }; in __pthread_cond_timedwait()
178 struct waiter *p, *first=0; in __private_cond_signal()
|
| /third_party/skia/third_party/externals/dng_sdk/source/ |
| D | dng_pthread.cpp | 59 struct waiter { struct
60 struct waiter *prev; argument
61 struct waiter *next; argument
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()
687 waiter *first; in dng_pthread_cond_signal()
719 waiter *first; in dng_pthread_cond_broadcast()
734 waiter *next = first->next; in dng_pthread_cond_broadcast()
|
| /third_party/python/Lib/ |
| D | threading.py | 313 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)
375 for waiter in waiters_to_notify:
376 waiter.release()
378 all_waiters.remove(waiter)
|