Searched refs:waiter (Results 51 - 58 of 58) sorted by relevance
123
| /third_party/python/Lib/test/test_asyncio/ |
| 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)
|
| /device/soc/rockchip/rk3588/kernel/drivers/video/rockchip/rga3/include/ |
| H A D | rga_drv.h | 124 /* Base sync driver waiter structure */
125 struct dma_fence_cb waiter; member
|
| /third_party/python/Lib/asyncio/ |
| H A D | sslproto.py | 267 def __init__(self, loop, app_protocol, sslcontext, waiter,
309 self._waiter = waiter
|
| /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)
|
Completed in 15 milliseconds
123