49     def __init__(self, ov, *, loop=None):  argument
53         self._ov = ov
94     def __init__(self, ov, handle, wait_handle, *, loop=None):  argument
100         self._ov = ov
170     def __init__(self, ov, event, wait_handle, *, loop=None):  argument
171         super().__init__(ov, event, wait_handle, loop=loop)
190     def __init__(self, ov, handle, wait_handle, proactor, *, loop=None):  argument
191         super().__init__(ov, handle, wait_handle, loop=loop)
319                 ov = self._self_reading_future._ov
323                 if ov is not None:
324                     self._proactor._unregister(ov)
442         ov = _overlapped.Overlapped(NULL)
445                 ov.WSARecv(conn.fileno(), nbytes, flags)
447                 ov.ReadFile(conn.fileno(), nbytes)
451         def finish_recv(trans, key, ov):  argument
453                 return ov.getresult()
461         return self._register(ov, conn, finish_recv)
465         ov = _overlapped.Overlapped(NULL)
468                 ov.WSARecvInto(conn.fileno(), buf, flags)
470                 ov.ReadFileInto(conn.fileno(), buf)
474         def finish_recv(trans, key, ov):  argument
476                 return ov.getresult()
484         return self._register(ov, conn, finish_recv)
488         ov = _overlapped.Overlapped(NULL)
490             ov.WSARecvFrom(conn.fileno(), nbytes, flags)
494         def finish_recv(trans, key, ov):  argument
496                 return ov.getresult()
504         return self._register(ov, conn, finish_recv)
508         ov = _overlapped.Overlapped(NULL)
510         ov.WSASendTo(conn.fileno(), buf, flags, addr)
512         def finish_send(trans, key, ov):  argument
514                 return ov.getresult()
522         return self._register(ov, conn, finish_send)
526         ov = _overlapped.Overlapped(NULL)
528             ov.WSASend(conn.fileno(), buf, flags)
530             ov.WriteFile(conn.fileno(), buf)
532         def finish_send(trans, key, ov):  argument
534                 return ov.getresult()
542         return self._register(ov, conn, finish_send)
547         ov = _overlapped.Overlapped(NULL)
548         ov.AcceptEx(listener.fileno(), conn.fileno())
550         def finish_accept(trans, key, ov):  argument
551             ov.getresult()
567         future = self._register(ov, listener, finish_accept)
591         ov = _overlapped.Overlapped(NULL)
592         ov.ConnectEx(conn.fileno(), address)
594         def finish_connect(trans, key, ov):  argument
595             ov.getresult()
601         return self._register(ov, conn, finish_connect)
605         ov = _overlapped.Overlapped(NULL)
608         ov.TransmitFile(sock.fileno(),
613         def finish_sendfile(trans, key, ov):  argument
615                 return ov.getresult()
622         return self._register(ov, sock, finish_sendfile)
626         ov = _overlapped.Overlapped(NULL)
627         connected = ov.ConnectNamedPipe(pipe.fileno())
635         def finish_accept_pipe(trans, key, ov):  argument
636             ov.getresult()
639         return self._register(ov, pipe, finish_accept_pipe)
686         ov = _overlapped.Overlapped(NULL)
688             handle, self._iocp, ov.address, ms)
690             f = _WaitCancelFuture(ov, handle, wait_handle, loop=self._loop)
692             f = _WaitHandleFuture(ov, handle, wait_handle, self,
697         def finish_wait_for_handle(trans, key, ov):  argument
706         self._cache[ov.address] = (f, ov, 0, finish_wait_for_handle)
719     def _register(self, ov, obj, callback):  argument
725         f = _OverlappedFuture(ov, loop=self._loop)
728         if not ov.pending:
734                 value = callback(None, None, ov)
748         self._cache[ov.address] = (f, ov, obj, callback)
751     def _unregister(self, ov):  argument
759         self._unregistered.append(ov)
786                 f, ov, obj, callback = self._cache.pop(address)
808                     value = callback(transferred, key, ov)
817         for ov in self._unregistered:
818             self._cache.pop(ov.address, None)
833         for address, (fut, ov, obj, callback) in list(self._cache.items()):