test_locks.py - OpenGrok cross reference for /third_party/python/Lib/test/test_asyncio/test

Lines Matching refs:acquire
33         await lock.acquire()
90         self.assertTrue(await lock.acquire())
93             if await lock.acquire():
98             if await lock.acquire():
103             if await lock.acquire():
139         self.assertTrue(await lock.acquire())
141         task = asyncio.create_task(lock.acquire())
150         # - B is blocked in acquire()
151         # - C is blocked in acquire()
165             await lock.acquire()
207             await lock.acquire()
214         await lock.acquire()
234         # Cleanup the task that is stuck on acquire.
242         await lock.acquire()
245         tb = asyncio.create_task(lock.acquire())
251         tc = asyncio.create_task(lock.acquire())
269         await lock.acquire()
400             await cond.acquire()
406             await cond.acquire()
412             await cond.acquire()
425         self.assertTrue(await cond.acquire())
460         await cond.acquire()
472         await cond.acquire()
480         await cond.acquire()
509         await cond.acquire()
511         await asyncio.sleep(0)  # Get to acquire()
535             await cond.acquire()
546         await cond.acquire()
553         await cond.acquire()
577             await cond.acquire()
584             await cond.acquire()
591             await cond.acquire()
604         await cond.acquire()
610         await cond.acquire()
630             await cond.acquire()
637             await cond.acquire()
649         await cond.acquire()
673         await cond.acquire()
730                 # cond.acquire() will trigger waiting on the lock
736                     await cond.acquire()
773         await sem.acquire()
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()
868         await sem.acquire()
870         acquire = asyncio.create_task(sem.acquire())
871         asyncio.get_running_loop().call_soon(acquire.cancel)
873             await acquire
880         t1 = asyncio.create_task(sem.acquire())
881         t2 = asyncio.create_task(sem.acquire())
882         t3 = asyncio.create_task(sem.acquire())
883         t4 = asyncio.create_task(sem.acquire())
905         t1 = asyncio.create_task(sem.acquire())
906         t2 = asyncio.create_task(sem.acquire())
936         await asyncio.wait_for(sem.acquire(), timeout=1.0)
945         await sem.acquire()
956             await sem.acquire()
961             await sem.acquire()
981             await sem.acquire()
986             await sem.acquire()
989             await sem.acquire()
994             await sem.acquire()
1016             await sem.acquire()
1021             await sem.acquire()
1026             await sem.acquire()