Restoring authorship annotation for <shadchin@yandex-team.ru>. Commit 2 of 2.

1 files changed, 83 insertions, 83 deletions

diff --git a/contrib/tools/python3/src/Lib/asyncio/windows_events.py b/contrib/tools/python3/src/Lib/asyncio/windows_events.py
index bf9e43b7a0..da81ab435b 100644
--- a/contrib/tools/python3/src/Lib/asyncio/windows_events.py
+++ b/contrib/tools/python3/src/Lib/asyncio/windows_events.py
@@ -1,10 +1,10 @@
 """Selector and proactor event loops for Windows."""
 
-import sys 
- 
-if sys.platform != 'win32':  # pragma: no cover 
-    raise ImportError('win32 only') 
- 
+import sys
+
+if sys.platform != 'win32':  # pragma: no cover
+    raise ImportError('win32 only')
+
 import _overlapped
 import _winapi
 import errno
@@ -18,7 +18,7 @@ import weakref
 from . import events
 from . import base_subprocess
 from . import futures
-from . import exceptions 
+from . import exceptions
 from . import proactor_events
 from . import selector_events
 from . import tasks
@@ -80,9 +80,9 @@ class _OverlappedFuture(futures.Future):
             self._loop.call_exception_handler(context)
         self._ov = None
 
-    def cancel(self, msg=None): 
+    def cancel(self, msg=None):
         self._cancel_overlapped()
-        return super().cancel(msg=msg) 
+        return super().cancel(msg=msg)
 
     def set_exception(self, exception):
         super().set_exception(exception)
@@ -154,9 +154,9 @@ class _BaseWaitHandleFuture(futures.Future):
 
         self._unregister_wait_cb(None)
 
-    def cancel(self, msg=None): 
+    def cancel(self, msg=None):
         self._unregister_wait()
-        return super().cancel(msg=msg) 
+        return super().cancel(msg=msg)
 
     def set_exception(self, exception):
         self._unregister_wait()
@@ -314,25 +314,25 @@ class ProactorEventLoop(proactor_events.BaseProactorEventLoop):
             proactor = IocpProactor()
         super().__init__(proactor)
 
-    def run_forever(self): 
-        try: 
-            assert self._self_reading_future is None 
-            self.call_soon(self._loop_self_reading) 
-            super().run_forever() 
-        finally: 
-            if self._self_reading_future is not None: 
-                ov = self._self_reading_future._ov 
-                self._self_reading_future.cancel() 
-                # self_reading_future was just cancelled so if it hasn't been 
-                # finished yet, it never will be (it's possible that it has 
-                # already finished and its callback is waiting in the queue, 
-                # where it could still happen if the event loop is restarted). 
-                # Unregister it otherwise IocpProactor.close will wait for it 
-                # forever 
-                if ov is not None: 
-                    self._proactor._unregister(ov) 
-                self._self_reading_future = None 
- 
+    def run_forever(self):
+        try:
+            assert self._self_reading_future is None
+            self.call_soon(self._loop_self_reading)
+            super().run_forever()
+        finally:
+            if self._self_reading_future is not None:
+                ov = self._self_reading_future._ov
+                self._self_reading_future.cancel()
+                # self_reading_future was just cancelled so if it hasn't been
+                # finished yet, it never will be (it's possible that it has
+                # already finished and its callback is waiting in the queue,
+                # where it could still happen if the event loop is restarted).
+                # Unregister it otherwise IocpProactor.close will wait for it
+                # forever
+                if ov is not None:
+                    self._proactor._unregister(ov)
+                self._self_reading_future = None
+
     async def create_pipe_connection(self, protocol_factory, address):
         f = self._proactor.connect_pipe(address)
         pipe = await f
@@ -377,7 +377,7 @@ class ProactorEventLoop(proactor_events.BaseProactorEventLoop):
                 elif self._debug:
                     logger.warning("Accept pipe failed on pipe %r",
                                    pipe, exc_info=True)
-            except exceptions.CancelledError: 
+            except exceptions.CancelledError:
                 if pipe:
                     pipe.close()
             else:
@@ -397,9 +397,9 @@ class ProactorEventLoop(proactor_events.BaseProactorEventLoop):
                                              **kwargs)
         try:
             await waiter
-        except (SystemExit, KeyboardInterrupt): 
-            raise 
-        except BaseException: 
+        except (SystemExit, KeyboardInterrupt):
+            raise
+        except BaseException:
             transp.close()
             await transp._wait()
             raise
@@ -478,7 +478,7 @@ class IocpProactor:
             else:
                 ov.ReadFileInto(conn.fileno(), buf)
         except BrokenPipeError:
-            return self._result(0) 
+            return self._result(0)
 
         def finish_recv(trans, key, ov):
             try:
@@ -492,44 +492,44 @@ class IocpProactor:
 
         return self._register(ov, conn, finish_recv)
 
-    def recvfrom(self, conn, nbytes, flags=0): 
-        self._register_with_iocp(conn) 
-        ov = _overlapped.Overlapped(NULL) 
-        try: 
-            ov.WSARecvFrom(conn.fileno(), nbytes, flags) 
-        except BrokenPipeError: 
-            return self._result((b'', None)) 
- 
-        def finish_recv(trans, key, ov): 
-            try: 
-                return ov.getresult() 
-            except OSError as exc: 
-                if exc.winerror in (_overlapped.ERROR_NETNAME_DELETED, 
-                                    _overlapped.ERROR_OPERATION_ABORTED): 
-                    raise ConnectionResetError(*exc.args) 
-                else: 
-                    raise 
- 
-        return self._register(ov, conn, finish_recv) 
- 
-    def sendto(self, conn, buf, flags=0, addr=None): 
-        self._register_with_iocp(conn) 
-        ov = _overlapped.Overlapped(NULL) 
- 
-        ov.WSASendTo(conn.fileno(), buf, flags, addr) 
- 
-        def finish_send(trans, key, ov): 
-            try: 
-                return ov.getresult() 
-            except OSError as exc: 
-                if exc.winerror in (_overlapped.ERROR_NETNAME_DELETED, 
-                                    _overlapped.ERROR_OPERATION_ABORTED): 
-                    raise ConnectionResetError(*exc.args) 
-                else: 
-                    raise 
- 
-        return self._register(ov, conn, finish_send) 
- 
+    def recvfrom(self, conn, nbytes, flags=0):
+        self._register_with_iocp(conn)
+        ov = _overlapped.Overlapped(NULL)
+        try:
+            ov.WSARecvFrom(conn.fileno(), nbytes, flags)
+        except BrokenPipeError:
+            return self._result((b'', None))
+
+        def finish_recv(trans, key, ov):
+            try:
+                return ov.getresult()
+            except OSError as exc:
+                if exc.winerror in (_overlapped.ERROR_NETNAME_DELETED,
+                                    _overlapped.ERROR_OPERATION_ABORTED):
+                    raise ConnectionResetError(*exc.args)
+                else:
+                    raise
+
+        return self._register(ov, conn, finish_recv)
+
+    def sendto(self, conn, buf, flags=0, addr=None):
+        self._register_with_iocp(conn)
+        ov = _overlapped.Overlapped(NULL)
+
+        ov.WSASendTo(conn.fileno(), buf, flags, addr)
+
+        def finish_send(trans, key, ov):
+            try:
+                return ov.getresult()
+            except OSError as exc:
+                if exc.winerror in (_overlapped.ERROR_NETNAME_DELETED,
+                                    _overlapped.ERROR_OPERATION_ABORTED):
+                    raise ConnectionResetError(*exc.args)
+                else:
+                    raise
+
+        return self._register(ov, conn, finish_send)
+
     def send(self, conn, buf, flags=0):
         self._register_with_iocp(conn)
         ov = _overlapped.Overlapped(NULL)
@@ -569,7 +569,7 @@ class IocpProactor:
             # Coroutine closing the accept socket if the future is cancelled
             try:
                 await future
-            except exceptions.CancelledError: 
+            except exceptions.CancelledError:
                 conn.close()
                 raise
 
@@ -579,14 +579,14 @@ class IocpProactor:
         return future
 
     def connect(self, conn, address):
-        if conn.type == socket.SOCK_DGRAM: 
-            # WSAConnect will complete immediately for UDP sockets so we don't 
-            # need to register any IOCP operation 
-            _overlapped.WSAConnect(conn.fileno(), address) 
-            fut = self._loop.create_future() 
-            fut.set_result(None) 
-            return fut 
- 
+        if conn.type == socket.SOCK_DGRAM:
+            # WSAConnect will complete immediately for UDP sockets so we don't
+            # need to register any IOCP operation
+            _overlapped.WSAConnect(conn.fileno(), address)
+            fut = self._loop.create_future()
+            fut.set_result(None)
+            return fut
+
         self._register_with_iocp(conn)
         # The socket needs to be locally bound before we call ConnectEx().
         try:
@@ -662,7 +662,7 @@ class IocpProactor:
 
             # ConnectPipe() failed with ERROR_PIPE_BUSY: retry later
             delay = min(delay * 2, CONNECT_PIPE_MAX_DELAY)
-            await tasks.sleep(delay) 
+            await tasks.sleep(delay)
 
         return windows_utils.PipeHandle(handle)
 
@@ -910,4 +910,4 @@ class WindowsProactorEventLoopPolicy(events.BaseDefaultEventLoopPolicy):
     _loop_factory = ProactorEventLoop
 
 
-DefaultEventLoopPolicy = WindowsProactorEventLoopPolicy 
+DefaultEventLoopPolicy = WindowsProactorEventLoopPolicy