Lines Matching refs:sock
28 def __init__(self, loop, sock, protocol, waiter=None, argument
31 self._set_extra(sock)
32 self._sock = sock
68 def _set_extra(self, sock): argument
69 self._extra['pipe'] = sock
160 def __init__(self, loop, sock, protocol, waiter=None, argument
164 super().__init__(loop, sock, protocol, waiter, extra, server)
447 def __init__(self, loop, sock, protocol, waiter=None, argument
449 super().__init__(loop, sock, protocol, waiter, extra, server)
450 base_events._set_nodelay(sock)
452 def _set_extra(self, sock): argument
453 self._extra['socket'] = sock
456 self._extra['sockname'] = sock.getsockname()
460 "getsockname() failed on %r", sock, exc_info=True)
464 self._extra['peername'] = sock.getpeername()
468 sock, exc_info=True)
493 def _make_socket_transport(self, sock, protocol, waiter=None, argument
495 return _ProactorSocketTransport(self, sock, protocol, waiter,
511 def _make_duplex_pipe_transport(self, sock, protocol, waiter=None, argument
514 sock, protocol, waiter, extra)
516 def _make_read_pipe_transport(self, sock, protocol, waiter=None, argument
518 return _ProactorReadPipeTransport(self, sock, protocol, waiter, extra)
520 def _make_write_pipe_transport(self, sock, protocol, waiter=None, argument
524 sock, protocol, waiter, extra)
544 async def sock_recv(self, sock, n): argument
545 return await self._proactor.recv(sock, n)
547 async def sock_recv_into(self, sock, buf): argument
548 return await self._proactor.recv_into(sock, buf)
550 async def sock_sendall(self, sock, data): argument
551 return await self._proactor.send(sock, data)
553 async def sock_connect(self, sock, address): argument
554 return await self._proactor.connect(sock, address)
556 async def sock_accept(self, sock): argument
557 return await self._proactor.accept(sock)
559 async def _sock_sendfile_native(self, sock, file, offset, count): argument
581 await self._proactor.sendfile(sock, file, offset, blocksize)
645 def _start_serving(self, protocol_factory, sock, argument
668 f = self._proactor.accept(sock)
670 if sock.fileno() != -1:
674 'socket': sock,
676 sock.close()
679 sock, exc_info=True)
681 sock.close()
683 self._accept_futures[sock.fileno()] = f
697 def _stop_serving(self, sock): argument
698 future = self._accept_futures.pop(sock.fileno(), None)
701 self._proactor._stop_serving(sock)
702 sock.close()