Lines Matching refs:ov
54 def __init__(self, ov, *, loop=None):
58 self._ov = ov
99 def __init__(self, ov, handle, wait_handle, *, loop=None):
105 self._ov = ov
175 def __init__(self, ov, event, wait_handle, *, loop=None):
176 super().__init__(ov, event, wait_handle, loop=loop)
195 def __init__(self, ov, handle, wait_handle, proactor, *, loop=None):
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)
460 ov = _overlapped.Overlapped(NULL)
463 ov.WSARecv(conn.fileno(), nbytes, flags)
465 ov.ReadFile(conn.fileno(), nbytes)
469 def finish_recv(trans, key, ov):
471 return ov.getresult()
479 return self._register(ov, conn, finish_recv)
483 ov = _overlapped.Overlapped(NULL)
486 ov.WSARecvInto(conn.fileno(), buf, flags)
488 ov.ReadFileInto(conn.fileno(), buf)
492 def finish_recv(trans, key, ov):
494 return ov.getresult()
502 return self._register(ov, conn, finish_recv)
506 ov = _overlapped.Overlapped(NULL)
508 ov.WSARecvFrom(conn.fileno(), nbytes, flags)
512 def finish_recv(trans, key, ov):
514 return ov.getresult()
522 return self._register(ov, conn, finish_recv)
526 ov = _overlapped.Overlapped(NULL)
528 ov.WSARecvFromInto(conn.fileno(), buf, flags)
532 def finish_recv(trans, key, ov):
534 return ov.getresult()
542 return self._register(ov, conn, finish_recv)
546 ov = _overlapped.Overlapped(NULL)
548 ov.WSASendTo(conn.fileno(), buf, flags, addr)
550 def finish_send(trans, key, ov):
552 return ov.getresult()
560 return self._register(ov, conn, finish_send)
564 ov = _overlapped.Overlapped(NULL)
566 ov.WSASend(conn.fileno(), buf, flags)
568 ov.WriteFile(conn.fileno(), buf)
570 def finish_send(trans, key, ov):
572 return ov.getresult()
580 return self._register(ov, conn, finish_send)
585 ov = _overlapped.Overlapped(NULL)
586 ov.AcceptEx(listener.fileno(), conn.fileno())
588 def finish_accept(trans, key, ov):
589 ov.getresult()
605 future = self._register(ov, listener, finish_accept)
629 ov = _overlapped.Overlapped(NULL)
630 ov.ConnectEx(conn.fileno(), address)
632 def finish_connect(trans, key, ov):
633 ov.getresult()
639 return self._register(ov, conn, finish_connect)
643 ov = _overlapped.Overlapped(NULL)
646 ov.TransmitFile(sock.fileno(),
651 def finish_sendfile(trans, key, ov):
653 return ov.getresult()
660 return self._register(ov, sock, finish_sendfile)
664 ov = _overlapped.Overlapped(NULL)
665 connected = ov.ConnectNamedPipe(pipe.fileno())
673 def finish_accept_pipe(trans, key, ov):
674 ov.getresult()
677 return self._register(ov, pipe, finish_accept_pipe)
723 # We only create ov so we can use ov.address as a key for the cache.
724 ov = _overlapped.Overlapped(NULL)
726 handle, self._iocp, ov.address, ms)
728 f = _WaitCancelFuture(ov, handle, wait_handle, loop=self._loop)
730 f = _WaitHandleFuture(ov, handle, wait_handle, self,
735 def finish_wait_for_handle(trans, key, ov):
744 self._cache[ov.address] = (f, ov, 0, finish_wait_for_handle)
757 def _register(self, ov, obj, callback):
763 f = _OverlappedFuture(ov, loop=self._loop)
766 if not ov.pending:
772 value = callback(None, None, ov)
786 self._cache[ov.address] = (f, ov, obj, callback)
789 def _unregister(self, ov):
797 self._unregistered.append(ov)
824 f, ov, obj, callback = self._cache.pop(address)
846 value = callback(transferred, key, ov)
857 for ov in self._unregistered:
858 self._cache.pop(ov.address, None)
873 for fut, ov, obj, callback in list(self._cache.values()):