Lines Matching refs:await

33         await lock.acquire()
42             "object Lock can't be used in 'await' expression"
44             await lock
76             await asyncio.sleep(0.01)
80                 r"object \w+ can't be used in 'await' expression"
82                 with await lock:
90         self.assertTrue(await lock.acquire())
93             if await lock.acquire():
98             if await lock.acquire():
103             if await lock.acquire():
110         await asyncio.sleep(0)
114         await asyncio.sleep(0)
117         await asyncio.sleep(0)
123         await asyncio.sleep(0)
127         await asyncio.sleep(0)
139         self.assertTrue(await lock.acquire())
144             await task
165             await lock.acquire()
168                     await blocker
174         await asyncio.sleep(0)
177         await asyncio.sleep(0)
180         await asyncio.sleep(0)
188         await asyncio.sleep(0)
192         await tc
207             await lock.acquire()
214         await lock.acquire()
221         await asyncio.sleep(0)
226             await t1
236         await asyncio.sleep(0)
242         await lock.acquire()
246         await asyncio.sleep(0)
254         await asyncio.sleep(0)
260         await tc
269         await lock.acquire()
308             if await ev.wait():
312             if await ev.wait():
316             if await ev.wait():
322         await asyncio.sleep(0)
328         await asyncio.sleep(0)
342         res = await ev.wait()
351             await wait
369             if await ev.wait():
374         await asyncio.sleep(0)
385         await asyncio.sleep(0)
400             await cond.acquire()
401             if await cond.wait():
406             await cond.acquire()
407             if await cond.wait():
412             await cond.acquire()
413             if await cond.wait():
421         await asyncio.sleep(0)
425         self.assertTrue(await cond.acquire())
427         await asyncio.sleep(0)
432         await asyncio.sleep(0)
437         await asyncio.sleep(0)
442         await asyncio.sleep(0)
447         await asyncio.sleep(0)
460         await cond.acquire()
465             await wait
472         await cond.acquire()
476         await asyncio.sleep(0)
480         await cond.acquire()
487             await wait_task
504                 await cond.wait()
507         await asyncio.sleep(0)  # Start waiting
509         await cond.acquire()
511         await asyncio.sleep(0)  # Get to acquire()
513         await asyncio.sleep(0)  # Activate cancellation
515         await asyncio.sleep(0)  # Cancellation should occur
523             await cond.wait()
535             await cond.acquire()
536             if await cond.wait_for(predicate):
543         await asyncio.sleep(0)
546         await cond.acquire()
549         await asyncio.sleep(0)
553         await cond.acquire()
556         await asyncio.sleep(0)
566         res = await cond.wait_for(lambda: [1, 2, 3])
570             await cond.wait_for(lambda: False)
577             await cond.acquire()
578             if await cond.wait():
584             await cond.acquire()
585             if await cond.wait():
591             await cond.acquire()
592             if await cond.wait():
601         await asyncio.sleep(0)
604         await cond.acquire()
607         await asyncio.sleep(0)
610         await cond.acquire()
614         await asyncio.sleep(0)
630             await cond.acquire()
631             if await cond.wait():
637             await cond.acquire()
638             if await cond.wait():
646         await asyncio.sleep(0)
649         await cond.acquire()
652         await asyncio.sleep(0)
673         await cond.acquire()
712         await f()
713         await f(asyncio.Lock())
715         await f(lock, asyncio.Condition(lock))
736                     await cond.acquire()
750                     await cond.wait()
752         await wrong_loop_in_lock()
753         await wrong_loop_in_cond()
759                 await asyncio.wait_for(condition.wait(), timeout=0.5)
773         await sem.acquire()
795             "object Semaphore can't be used in 'await' expression",
797             await sem
809         self.assertTrue(await sem.acquire())
810         self.assertTrue(await sem.acquire())
814             await sem.acquire()
819             await sem.acquire()
824             await sem.acquire()
829             await sem.acquire()
837         await asyncio.sleep(0)
849         await asyncio.sleep(0)
864         await asyncio.gather(*race_tasks)
868         await sem.acquire()
873             await acquire
885         await asyncio.sleep(0)
891         await asyncio.sleep(0)
892         await asyncio.sleep(0)
900         await asyncio.sleep(0)
907         await asyncio.sleep(0)
911         await asyncio.sleep(0)
912         await asyncio.sleep(0)
922                 await asyncio.sleep(0)
932         r1, r2 = await asyncio.gather(t1, t2, return_exceptions=True)
936         await asyncio.wait_for(sem.acquire(), timeout=1.0)
945         await sem.acquire()
956             await sem.acquire()
958             await asyncio.sleep(0.01)
961             await sem.acquire()
963             await asyncio.sleep(0.01)
981             await sem.acquire()
986             await sem.acquire()
989             await sem.acquire()
994             await sem.acquire()
1002         await asyncio.sleep(0)
1008         await asyncio.gather(*tasks)
1016             await sem.acquire()
1021             await sem.acquire()
1026             await sem.acquire()
1034         await asyncio.sleep(0)
1038         await asyncio.sleep(0)
1044         await asyncio.gather(*tasks, return_exceptions=True)
1051         await super().asyncSetUp()
1060         res = await asyncio.gather(*tasks)
1068             "object Barrier can't be used in 'await' expression",
1070             await barrier
1082             await barrier.wait()
1087         await asyncio.sleep(0)
1096         await asyncio.sleep(0)
1104         await asyncio.sleep(0)
1106         await barrier.reset()
1114         await asyncio.sleep(0)
1116         await barrier.abort()
1123         await asyncio.gather(*waiters, return_exceptions=True)
1140         await self.gather_tasks(self.N, coro)
1153         ret = await f()
1163         await asyncio.sleep(0)
1167         await asyncio.sleep(0)
1180         await asyncio.sleep(0)
1185         await asyncio.sleep(0)
1190         await asyncio.sleep(0)
1192         await asyncio.wait([t1, t2, t3])
1208         await self.gather_tasks(self.N, coro)
1230         res, _ = await self.gather_tasks(self.N, coro)
1250         await self.gather_tasks(self.N, coro)
1271             await barrier.wait()
1277                 await barrier.wait()
1280                 await barrier_nowaiting.wait()
1282                 await barrier.wait()
1286         await self.gather_tasks(self.N, coro)
1294             await barrier.wait()
1298         await asyncio.sleep(0)
1302         await asyncio.sleep(0)
1306         await asyncio.sleep(0)
1309             await t1
1313         await asyncio.sleep(0)
1317         await asyncio.gather(t2, t3, t4)
1329         await asyncio.sleep(0)
1340                 await barrier.wait()
1345             await barrier.reset()
1349         await asyncio.sleep(0)
1353         await asyncio.gather(*tasks)
1368                 await barrier.wait()
1376                     await barrier.reset()
1378         await self.gather_tasks(self.N, coro)
1395                 await barrier.wait()
1401                 await barrier.wait()
1406                     await barrier.reset()
1409                     await barrier.wait()
1412                         await barrier.wait()
1417         await self.gather_tasks(self.N, coro)
1432                 await barrier.wait()
1436                 await barrier.wait()
1447         await asyncio.sleep(0)
1452         await asyncio.gather(*tasks)
1473             i = await barrier.wait()
1477                 await barrier.reset()
1480                 await barrier.wait()
1484                     await barrier.wait()
1494             k = await barrier.wait()
1497         await self.gather_tasks(self.N, coro)
1512         await asyncio.sleep(0)
1527                 await barrier.wait()
1535                     await barrier.abort()
1538                         await barrier.wait()
1543         await self.gather_tasks(self.N, coro)
1567                 await barrier.abort()
1569         await self.gather_tasks(self.N, coro)
1587                 i = await barrier1.wait()
1590                 await barrier1.wait()
1595                 await barrier1.abort()
1600             i = await barrier2.wait()
1602                 await barrier1.reset()
1603             await barrier2.wait()
1604             await barrier1.wait()
1607         await self.gather_tasks(self.N, coro)