Home
last modified time | relevance | path

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

123

/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-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 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 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...]
/device/soc/rockchip/common/vendor/drivers/gpu/arm/mali400/mali/common/
H A Dmali_timeline.c40 struct mali_timeline_waiter *waiter);
229 /* The tracker and waiter lists will initially be empty. */ in mali_timeline_create()
336 /* Inserting the waiter object into the given timeline */
347 /* Finding out where to put this waiter, in the linked waiter list of the given timeline **/ in mali_timeline_insert_waiter()
352 * find the correct spot to insert the new waiter */ in mali_timeline_insert_waiter()
438 * Releasing a waiter can trigger this function to be called again, so in mali_timeline_update_oldest_point()
443 struct mali_timeline_waiter *waiter = timeline->waiter_tail; in mali_timeline_update_oldest_point() local
446 waiter_time_relative = waiter->point - timeline->point_oldest; in mali_timeline_update_oldest_point()
453 /* Remove waiter fro in mali_timeline_update_oldest_point()
473 struct mali_timeline_waiter *waiter; mali_timeline_release_with_depended_point() local
1017 struct mali_timeline_waiter *waiter, *next; global() local
1103 struct mali_timeline_waiter *waiter; global() local
1125 struct mali_timeline_waiter *waiter; global() local
1204 struct mali_timeline_waiter *waiter; global() local
1268 struct mali_timeline_waiter *waiter; global() local
1336 struct mali_timeline_waiter *waiter; global() local
1469 mali_timeline_system_release_waiter(struct mali_timeline_system *system, struct mali_timeline_waiter *waiter) global() argument
1561 struct mali_timeline_waiter *waiter = NULL; global() local
1959 struct mali_timeline_waiter *waiter; global() local
[all...]
/device/soc/rockchip/common/kernel/drivers/gpu/arm/mali400/mali/common/
H A Dmali_timeline.c39 struct mali_timeline_waiter *waiter);
225 /* The tracker and waiter lists will initially be empty. */ in mali_timeline_create()
332 /* Inserting the waiter object into the given timeline */
343 /* Finding out where to put this waiter, in the linked waiter list of the given timeline **/ in mali_timeline_insert_waiter()
348 * find the correct spot to insert the new waiter */ in mali_timeline_insert_waiter()
431 * Releasing a waiter can trigger this function to be called again, so in mali_timeline_update_oldest_point()
436 struct mali_timeline_waiter *waiter = timeline->waiter_tail; in mali_timeline_update_oldest_point() local
439 waiter_time_relative = waiter->point - timeline->point_oldest; in mali_timeline_update_oldest_point()
446 /* Remove waiter fro in mali_timeline_update_oldest_point()
466 struct mali_timeline_waiter *waiter; mali_timeline_release_with_depended_point() local
1001 struct mali_timeline_waiter *waiter, *next; global() local
1086 struct mali_timeline_waiter *waiter; global() local
1109 struct mali_timeline_waiter *waiter; global() local
1186 struct mali_timeline_waiter *waiter; global() local
1250 struct mali_timeline_waiter *waiter; global() local
1320 struct mali_timeline_waiter *waiter; global() local
1452 mali_timeline_system_release_waiter(struct mali_timeline_system *system, struct mali_timeline_waiter *waiter) global() argument
1542 struct mali_timeline_waiter *waiter = NULL; global() local
1928 struct mali_timeline_waiter *waiter; global() local
[all...]
/device/soc/rockchip/common/kernel/drivers/gpu/arm/mali400/mali/linux/
H A Dmali_internal_sync.c77 struct mali_internal_sync_fence_waiter *waiter; in mali_internal_fence_check_cb_func()
87 waiter = container_of(cb, struct mali_internal_sync_fence_waiter, cb); in mali_internal_fence_check_cb_func()
88 sync_fence = (struct mali_internal_sync_fence *)waiter->work.private; in mali_internal_fence_check_cb_func()
514 void mali_internal_sync_fence_waiter_init(struct mali_internal_sync_fence_waiter *waiter, in mali_internal_sync_fence_waiter_init() argument
517 MALI_DEBUG_ASSERT_POINTER(waiter); in mali_internal_sync_fence_waiter_init()
521 INIT_LIST_HEAD(&waiter->work.entry); in mali_internal_sync_fence_waiter_init()
523 INIT_LIST_HEAD(&waiter->work.task_list); in mali_internal_sync_fence_waiter_init()
525 waiter->callback = callback; in mali_internal_sync_fence_waiter_init()
529 struct mali_internal_sync_fence_waiter *waiter) in mali_internal_sync_fence_wait_async()
535 MALI_DEBUG_ASSERT_POINTER(waiter); in mali_internal_sync_fence_wait_async()
528 mali_internal_sync_fence_wait_async(struct mali_internal_sync_fence *sync_fence, struct mali_internal_sync_fence_waiter *waiter) mali_internal_sync_fence_wait_async() argument
601 mali_internal_sync_fence_cancel_async(struct mali_internal_sync_fence *sync_fence, struct mali_internal_sync_fence_waiter *waiter) mali_internal_sync_fence_cancel_async() argument
[all...]
H A Dmali_internal_sync.h117 struct mali_internal_sync_fence_waiter *waiter);
181 void mali_internal_sync_fence_waiter_init(struct mali_internal_sync_fence_waiter *waiter,
185 struct mali_internal_sync_fence_waiter *waiter);
188 struct mali_internal_sync_fence_waiter *waiter);
/device/soc/rockchip/common/vendor/drivers/gpu/arm/mali400/mali/linux/
H A Dmali_internal_sync.c88 struct mali_internal_sync_fence_waiter *waiter; in mali_internal_fence_check_cb_func()
98 waiter = container_of(cb, struct mali_internal_sync_fence_waiter, cb); in mali_internal_fence_check_cb_func()
99 sync_fence = (struct mali_internal_sync_fence *)waiter->work.private; in mali_internal_fence_check_cb_func()
574 struct mali_internal_sync_fence_waiter *waiter, in mali_internal_sync_fence_waiter_init()
577 MALI_DEBUG_ASSERT_POINTER(waiter); in mali_internal_sync_fence_waiter_init()
581 INIT_LIST_HEAD(&waiter->work.entry); in mali_internal_sync_fence_waiter_init()
583 INIT_LIST_HEAD(&waiter->work.task_list); in mali_internal_sync_fence_waiter_init()
585 waiter->callback = callback; in mali_internal_sync_fence_waiter_init()
590 struct mali_internal_sync_fence_waiter *waiter) in mali_internal_sync_fence_wait_async()
596 MALI_DEBUG_ASSERT_POINTER(waiter); in mali_internal_sync_fence_wait_async()
573 mali_internal_sync_fence_waiter_init( struct mali_internal_sync_fence_waiter *waiter, mali_internal_sync_callback_t callback) mali_internal_sync_fence_waiter_init() argument
588 mali_internal_sync_fence_wait_async( struct mali_internal_sync_fence *sync_fence, struct mali_internal_sync_fence_waiter *waiter) mali_internal_sync_fence_wait_async() argument
671 mali_internal_sync_fence_cancel_async( struct mali_internal_sync_fence *sync_fence, struct mali_internal_sync_fence_waiter *waiter) mali_internal_sync_fence_cancel_async() argument
[all...]
H A Dmali_internal_sync.h118 struct mali_internal_sync_fence_waiter *waiter);
182 void mali_internal_sync_fence_waiter_init(struct mali_internal_sync_fence_waiter *waiter,
186 struct mali_internal_sync_fence_waiter *waiter);
189 struct mali_internal_sync_fence_waiter *waiter);
/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...]
/device/soc/rockchip/rk3588/kernel/drivers/video/rockchip/rga3/
H A Drga_fence.c109 struct rga_fence_waiter *waiter; in rga_add_dma_fence_callback() local
112 waiter = kmalloc(sizeof(*waiter), GFP_KERNEL); in rga_add_dma_fence_callback()
113 if (!waiter) { in rga_add_dma_fence_callback()
114 pr_err("%s: Failed to allocate waiter\n", __func__); in rga_add_dma_fence_callback()
118 waiter->job = job; in rga_add_dma_fence_callback()
120 ret = dma_fence_add_callback(in_fence, &waiter->waiter, func); in rga_add_dma_fence_callback()
134 kfree(waiter); in rga_add_dma_fence_callback()
/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...]

Completed in 15 milliseconds

123