/usr/lib/python3/dist-packages/aiohttp/locks.py is in python3-aiohttp 3.0.1-1.
This file is owned by root:root, with mode 0o644.
The actual contents of the file can be viewed below.
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 | import asyncio
import collections
class EventResultOrError:
"""
This class wrappers the Event asyncio lock allowing either awake the
locked Tasks without any error or raising an exception.
thanks to @vorpalsmith for the simple design.
"""
def __init__(self, loop):
self._loop = loop
self._exc = None
self._event = asyncio.Event(loop=loop)
self._waiters = collections.deque()
def set(self, exc=None):
self._exc = exc
self._event.set()
async def wait(self):
waiter = self._loop.create_task(self._event.wait())
self._waiters.append(waiter)
try:
val = await waiter
finally:
self._waiters.remove(waiter)
if self._exc is not None:
raise self._exc
return val
def cancel(self):
""" Cancel all waiters """
for waiter in self._waiters:
waiter.cancel()
|