| /third_party/python/Lib/test/test_asyncio/ |
| H A D | test_selector_events.py | 492 def socket_transport(self, waiter=None):
494 self.protocol, waiter=waiter)
499 waiter = self.loop.create_future()
500 tr = self.socket_transport(waiter=waiter)
501 self.loop.run_until_complete(waiter)
508 waiter = self.loop.create_future()
509 self.socket_transport(waiter=waiter)
[all...] |
| H A D | test_subprocess.py | 52 def create_transport(self, waiter=None):
56 None, None, None, 0, waiter=waiter)
60 waiter = self.loop.create_future()
61 transport, protocol = self.create_transport(waiter)
63 self.loop.run_until_complete(waiter)
86 waiter = self.loop.create_future()
87 transport, protocol = self.create_transport(waiter)
89 self.loop.run_until_complete(waiter)
|
| H A D | test_unix_events.py | 674 def read_pipe_transport(self, waiter=None):
677 waiter=waiter)
682 waiter = self.loop.create_future()
683 tr = self.read_pipe_transport(waiter=waiter)
684 self.loop.run_until_complete(waiter)
688 self.assertIsNone(waiter.result())
851 def write_pipe_transport(self, waiter=None):
854 waiter
[all...] |
| H A D | test_queues.py | 134 waiter = loop.create_future()
135 q._putters.append(waiter)
138 self.assertTrue(waiter.done())
139 self.assertIsNone(waiter.result())
|
| H A D | test_locks.py | 157 # If B's waiter is marked cancelled but not yet removed from
159 # B's waiter; instead, it should move on to C's waiter.
249 # Create a second waiter, wake up the first, and cancel it.
506 waiter = asyncio.create_task(wait_on_cond())
512 waiter.cancel()
517 self.assertTrue(waiter.cancelled())
875 all(waiter.done() for waiter in sem._waiters))
|
| H A D | test_tasks.py | 1810 # Cancelling outer() cancels inner() cancels waiter.
1812 waiter = self.new_future(self.loop)
1817 await waiter
1838 self.assertTrue(waiter.cancelled())
1844 waiter = self.new_future(self.loop)
1848 await waiter
1862 waiter.set_result(None)
1908 waiter = self.new_future(self.loop)
1912 await waiter
1925 waiter
[all...] |
| H A D | test_proactor_events.py | 45 def socket_transport(self, waiter=None):
47 self.protocol, waiter=waiter)
53 tr = self.socket_transport(waiter=fut)
|
| H A D | test_base_events.py | 1437 def mock_make_ssl_transport(sock, protocol, sslcontext, waiter,
1439 waiter.set_result(None)
|
| /third_party/ltp/testcases/open_posix_testsuite/conformance/interfaces/pthread_cond_broadcast/ |
| H A D | 4-2.c | 124 static void *waiter(void *arg PTS_ATTRIBUTE_UNUSED) in waiter() function
136 UNRESOLVED(ret, "Unable to lock mutex in waiter thread"); in waiter()
149 UNRESOLVED(ret, "Unable to unlock mutex in waiter thread"); in waiter()
219 ret = pthread_create(&th_waiter[i], NULL, waiter, NULL); in main()
|
| /third_party/ltp/testcases/open_posix_testsuite/conformance/interfaces/pthread_cond_signal/ |
| H A D | 4-2.c | 158 static void *waiter(void *arg PTS_ATTRIBUTE_UNUSED) in waiter() function
171 UNRESOLVED(ret, "Unable to lock mutex in waiter thread"); in waiter()
187 UNRESOLVED(ret, "Unable to unlock mutex in waiter thread"); in waiter()
264 if ((ret = pthread_create(&th_waiter, NULL, waiter, NULL))) { in main()
|
| /third_party/ltp/testcases/open_posix_testsuite/conformance/interfaces/pthread_cond_wait/ |
| H A D | 4-1.c | 160 static void *waiter(void *arg PTS_ATTRIBUTE_UNUSED) in waiter() function
173 UNRESOLVED(ret, "Unable to lock mutex in waiter thread"); in waiter()
194 UNRESOLVED(ret, "Unable to unlock mutex in waiter thread"); in waiter()
287 if ((ret = pthread_create(&th_waiter, NULL, waiter, NULL))) { in main()
|
| /third_party/ltp/testcases/open_posix_testsuite/conformance/interfaces/pthread_cond_timedwait/ |
| H A D | 4-3.c | 133 static void *waiter(void *arg) in waiter() function
149 UNRESOLVED(ret, "Unable to lock mutex in waiter thread"); in waiter()
183 UNRESOLVED(ret, "Unable to unlock mutex in waiter thread"); in waiter()
275 if ((ret = pthread_create(&th_waiter, NULL, waiter, NULL))) { in main()
|
| /third_party/alsa-utils/axfer/ |
| H A D | xfer-libasound.h | 13 #include "waiter.h"
63 struct waiter_context *waiter; member
|
| /third_party/python/Lib/asyncio/ |
| H A D | windows_events.py | 398 waiter = self.create_future()
401 waiter=waiter, extra=extra,
404 await waiter
|
| H A D | sslproto.py | 267 def __init__(self, loop, app_protocol, sslcontext, waiter,
309 self._waiter = waiter
|
| /third_party/ltp/testcases/open_posix_testsuite/stress/threads/pthread_cond_timedwait/ |
| H A D | s-c.c | 247 static void *waiter(void *arg) in waiter() function
255 UNRESOLVED(ret, "Mutex lock failed in waiter"); in waiter()
269 UNRESOLVED(ret, "pthread_cond_wait failed in waiter"); in waiter()
277 UNRESOLVED(ret, "Mutex unlock failed in waiter"); in waiter()
395 /* Create the waiter threads */ in do_threads_test()
398 pthread_create(&th[i], &ta, waiter, in do_threads_test()
433 /* All waiter threads are created now */ in do_threads_test()
435 output("%i waiter threads created successfully\n", i); in do_threads_test()
465 output("%i waiter threads are waiting; start measure\n", in do_threads_test()
|
| /third_party/python/Lib/test/ |
| H A D | test_asyncgen.py | 1435 async def waiter(timeout): function
1445 async for _ in waiter(1):
|
| H A D | test_coroutines.py | 1157 async def waiter(coro): function
1165 waiter(coro).send(None)
|