54     def __init__(self, ov, *, loop=None):  argument
58         self._ov = ov
99     def __init__(self, ov, handle, wait_handle, *, loop=None):  argument
105         self._ov = ov
175     def __init__(self, ov, event, wait_handle, *, loop=None):  argument
176         super().__init__(ov, event, wait_handle, loop=loop)
195     def __init__(self, ov, handle, wait_handle, proactor, *, loop=None):  argument
196         super().__init__(ov, handle, wait_handle, loop=loop)
324                 ov = self._self_reading_future._ov
332                 if ov is not None:
333                     self._proactor._unregister(ov)
451         ov = _overlapped.Overlapped(NULL)
454                 ov.WSARecv(conn.fileno(), nbytes, flags)
456                 ov.ReadFile(conn.fileno(), nbytes)
460         def finish_recv(trans, key, ov):  argument
462                 return ov.getresult()
470         return self._register(ov, conn, finish_recv)
474         ov = _overlapped.Overlapped(NULL)
477                 ov.WSARecvInto(conn.fileno(), buf, flags)
479                 ov.ReadFileInto(conn.fileno(), buf)
483         def finish_recv(trans, key, ov):  argument
485                 return ov.getresult()
493         return self._register(ov, conn, finish_recv)
497         ov = _overlapped.Overlapped(NULL)
499             ov.WSARecvFrom(conn.fileno(), nbytes, flags)
503         def finish_recv(trans, key, ov):  argument
505                 return ov.getresult()
513         return self._register(ov, conn, finish_recv)
517         ov = _overlapped.Overlapped(NULL)
519         ov.WSASendTo(conn.fileno(), buf, flags, addr)
521         def finish_send(trans, key, ov):  argument
523                 return ov.getresult()
531         return self._register(ov, conn, finish_send)
535         ov = _overlapped.Overlapped(NULL)
537             ov.WSASend(conn.fileno(), buf, flags)
539             ov.WriteFile(conn.fileno(), buf)
541         def finish_send(trans, key, ov):  argument
543                 return ov.getresult()
551         return self._register(ov, conn, finish_send)
556         ov = _overlapped.Overlapped(NULL)
557         ov.AcceptEx(listener.fileno(), conn.fileno())
559         def finish_accept(trans, key, ov):  argument
560             ov.getresult()
576         future = self._register(ov, listener, finish_accept)
600         ov = _overlapped.Overlapped(NULL)
601         ov.ConnectEx(conn.fileno(), address)
603         def finish_connect(trans, key, ov):  argument
604             ov.getresult()
610         return self._register(ov, conn, finish_connect)
614         ov = _overlapped.Overlapped(NULL)
617         ov.TransmitFile(sock.fileno(),
622         def finish_sendfile(trans, key, ov):  argument
624                 return ov.getresult()
631         return self._register(ov, sock, finish_sendfile)
635         ov = _overlapped.Overlapped(NULL)
636         connected = ov.ConnectNamedPipe(pipe.fileno())
644         def finish_accept_pipe(trans, key, ov):  argument
645             ov.getresult()
648         return self._register(ov, pipe, finish_accept_pipe)
695         ov = _overlapped.Overlapped(NULL)
697             handle, self._iocp, ov.address, ms)
699             f = _WaitCancelFuture(ov, handle, wait_handle, loop=self._loop)
701             f = _WaitHandleFuture(ov, handle, wait_handle, self,
706         def finish_wait_for_handle(trans, key, ov):  argument
715         self._cache[ov.address] = (f, ov, 0, finish_wait_for_handle)
728     def _register(self, ov, obj, callback):  argument
734         f = _OverlappedFuture(ov, loop=self._loop)
737         if not ov.pending:
743                 value = callback(None, None, ov)
757         self._cache[ov.address] = (f, ov, obj, callback)
760     def _unregister(self, ov):  argument
768         self._unregistered.append(ov)
795                 f, ov, obj, callback = self._cache.pop(address)
817                     value = callback(transferred, key, ov)
826         for ov in self._unregistered:
827             self._cache.pop(ov.address, None)
842         for address, (fut, ov, obj, callback) in list(self._cache.items()):