41 # Initial delay in seconds for connect_pipe() before retrying to connect
44 # Maximum delay in seconds for connect_pipe() before retrying to connect
51     Cancelling it will immediately cancel the overlapped operation.
57             del self._source_traceback[-1]
71             self._ov.cancel()
83     def cancel(self, msg=None):  member in _OverlappedFuture
85         return super().cancel(msg=msg)
102             del self._source_traceback[-1]
114         # non-blocking wait: use a timeout of 0 millisecond
157     def cancel(self, msg=None):  member in _BaseWaitHandleFuture
159         return super().cancel(msg=msg)
180     def cancel(self):  member in _WaitCancelFuture
292             self._accept_pipe_future.cancel()
296             for pipe in self._free_instances:
325                 self._self_reading_future.cancel()
328                 # already finished and its callback is waiting in the queue,
370                 if pipe and pipe.fileno() != -1:
374                 if pipe and pipe.fileno() != -1:
473                 if exc.winerror in (_overlapped.ERROR_NETNAME_DELETED,
496                 if exc.winerror in (_overlapped.ERROR_NETNAME_DELETED,
516                 if exc.winerror in (_overlapped.ERROR_NETNAME_DELETED,
536                 if exc.winerror in (_overlapped.ERROR_NETNAME_DELETED,
554                 if exc.winerror in (_overlapped.ERROR_NETNAME_DELETED,
574                 if exc.winerror in (_overlapped.ERROR_NETNAME_DELETED,
655                 if exc.winerror in (_overlapped.ERROR_NETNAME_DELETED,
683             # a pipe.  Call CreateFile() in a loop until it doesn't fail with
709         # in IocpProactor.close(), while the event loop is not running.
733             del f._source_traceback[-1]
750         if obj not in self._registered:
765             del f._source_traceback[-1]
778             # notification of the completion in GetQueuedCompletionStatus().
793         already be signalled (pending in the proactor event queue). It is also
836                 if key not in (0, _overlapped.INVALID_HANDLE_VALUE):
840             if obj in self._stopped_serving:
841                 f.cancel()
857         for ov in self._unregistered:
862         # obj is a socket or pipe handle.  It will be closed in
872         # Cancel remaining registered operations.
873         for fut, ov, obj, callback in list(self._cache.values()):
882                     fut.cancel()
895         # overlapped to prevent a crash. Display progress every second if the
903                              self, time.monotonic() - start_time)