Lines Matching refs:acquire

29         await lock.acquire()
97         self.assertTrue(await lock.acquire())
100             if await lock.acquire():
105             if await lock.acquire():
110             if await lock.acquire():
146         self.assertTrue(await lock.acquire())
148         task = asyncio.create_task(lock.acquire())
172             await lock.acquire()
214             await lock.acquire()
221         await lock.acquire()
249         await lock.acquire()
252         tb = asyncio.create_task(lock.acquire())
258         tc = asyncio.create_task(lock.acquire())
276         await lock.acquire()
407             await cond.acquire()
413             await cond.acquire()
419             await cond.acquire()
432         self.assertTrue(await cond.acquire())
467         await cond.acquire()
479         await cond.acquire()
487         await cond.acquire()
516         await cond.acquire()
542             await cond.acquire()
553         await cond.acquire()
560         await cond.acquire()
584             await cond.acquire()
591             await cond.acquire()
598             await cond.acquire()
611         await cond.acquire()
617         await cond.acquire()
637             await cond.acquire()
644             await cond.acquire()
656         await cond.acquire()
680         await cond.acquire()
743                     await cond.acquire()
780         await sem.acquire()
818         self.assertTrue(await sem.acquire())
819         self.assertTrue(await sem.acquire())
823             await sem.acquire()
828             await sem.acquire()
833             await sem.acquire()
838             await sem.acquire()
877         await sem.acquire()
879         acquire = asyncio.create_task(sem.acquire())
880         asyncio.get_running_loop().call_soon(acquire.cancel)
882             await acquire
889         t1 = asyncio.create_task(sem.acquire())
890         t2 = asyncio.create_task(sem.acquire())
891         t3 = asyncio.create_task(sem.acquire())
892         t4 = asyncio.create_task(sem.acquire())
913         t1 = asyncio.create_task(sem.acquire())
914         t2 = asyncio.create_task(sem.acquire())
930         await sem.acquire()