Lines Matching refs:sock
58 def _make_socket_transport(self, sock, protocol, waiter=None, *, argument
60 return _SelectorSocketTransport(self, sock, protocol, waiter,
76 def _make_datagram_transport(self, sock, protocol, argument
78 return _SelectorDatagramTransport(self, sock, protocol,
139 def _start_serving(self, protocol_factory, sock, argument
142 self._add_reader(sock.fileno(), self._accept_connection,
143 protocol_factory, sock, sslcontext, server, backlog,
147 self, protocol_factory, sock, argument
156 conn, addr = sock.accept()
174 'socket': sock,
176 self._remove_reader(sock.fileno())
179 protocol_factory, sock, sslcontext, server,
341 async def sock_recv(self, sock, n): argument
348 if self._debug and sock.gettimeout() != 0:
351 self._sock_recv(fut, None, sock, n)
354 def _sock_recv(self, fut, registered_fd, sock, n): argument
366 data = sock.recv(n)
368 fd = sock.fileno()
369 self.add_reader(fd, self._sock_recv, fut, fd, sock, n)
375 async def sock_recv_into(self, sock, buf): argument
381 if self._debug and sock.gettimeout() != 0:
384 self._sock_recv_into(fut, None, sock, buf)
387 def _sock_recv_into(self, fut, registered_fd, sock, buf): argument
400 nbytes = sock.recv_into(buf)
402 fd = sock.fileno()
403 self.add_reader(fd, self._sock_recv_into, fut, fd, sock, buf)
409 async def sock_sendall(self, sock, data): argument
418 if self._debug and sock.gettimeout() != 0:
422 self._sock_sendall(fut, None, sock, data)
427 def _sock_sendall(self, fut, registered_fd, sock, data): argument
434 n = sock.send(data)
446 fd = sock.fileno()
447 self.add_writer(fd, self._sock_sendall, fut, fd, sock, data)
449 async def sock_connect(self, sock, address): argument
454 if self._debug and sock.gettimeout() != 0:
457 if not hasattr(socket, 'AF_UNIX') or sock.family != socket.AF_UNIX:
459 address, family=sock.family, proto=sock.proto, loop=self)
463 self._sock_connect(fut, sock, address)
466 def _sock_connect(self, fut, sock, address): argument
467 fd = sock.fileno()
469 sock.connect(address)
477 self.add_writer(fd, self._sock_connect_cb, fut, sock, address)
486 def _sock_connect_cb(self, fut, sock, address): argument
491 err = sock.getsockopt(socket.SOL_SOCKET, socket.SO_ERROR)
503 async def sock_accept(self, sock): argument
511 if self._debug and sock.gettimeout() != 0:
514 self._sock_accept(fut, False, sock)
517 def _sock_accept(self, fut, registered, sock): argument
518 fd = sock.fileno()
524 conn, address = sock.accept()
527 self.add_reader(fd, self._sock_accept, fut, True, sock)
561 def _stop_serving(self, sock): argument
562 self._remove_reader(sock.fileno())
563 sock.close()
578 def __init__(self, loop, sock, protocol, extra=None, server=None): argument
580 self._extra['socket'] = sock
581 self._extra['sockname'] = sock.getsockname()
584 self._extra['peername'] = sock.getpeername()
587 self._sock = sock
588 self._sock_fd = sock.fileno()
713 def __init__(self, loop, sock, protocol, waiter=None, argument
717 super().__init__(loop, sock, protocol, extra, server)
934 def __init__(self, loop, sock, protocol, address=None, argument
936 super().__init__(loop, sock, protocol, extra)