Lines Matching refs:sock
59 def _make_socket_transport(self, sock, protocol, waiter=None, *,
61 return _SelectorSocketTransport(self, sock, protocol, waiter,
81 def _make_datagram_transport(self, sock, protocol,
83 return _SelectorDatagramTransport(self, sock, protocol,
146 def _start_serving(self, protocol_factory, sock,
150 self._add_reader(sock.fileno(), self._accept_connection,
151 protocol_factory, sock, sslcontext, server, backlog,
155 self, protocol_factory, sock,
165 conn, addr = sock.accept()
183 'socket': trsock.TransportSocket(sock),
185 self._remove_reader(sock.fileno())
188 protocol_factory, sock, sslcontext, server,
357 async def sock_recv(self, sock, n):
364 base_events._check_ssl_socket(sock)
365 if self._debug and sock.gettimeout() != 0:
368 return sock.recv(n)
372 fd = sock.fileno()
374 handle = self._add_reader(fd, self._sock_recv, fut, sock, n)
383 def _sock_recv(self, fut, sock, n):
389 data = sock.recv(n)
399 async def sock_recv_into(self, sock, buf):
405 base_events._check_ssl_socket(sock)
406 if self._debug and sock.gettimeout() != 0:
409 return sock.recv_into(buf)
413 fd = sock.fileno()
415 handle = self._add_reader(fd, self._sock_recv_into, fut, sock, buf)
420 def _sock_recv_into(self, fut, sock, buf):
427 nbytes = sock.recv_into(buf)
437 async def sock_recvfrom(self, sock, bufsize):
445 base_events._check_ssl_socket(sock)
446 if self._debug and sock.gettimeout() != 0:
449 return sock.recvfrom(bufsize)
453 fd = sock.fileno()
455 handle = self._add_reader(fd, self._sock_recvfrom, fut, sock, bufsize)
460 def _sock_recvfrom(self, fut, sock, bufsize):
467 result = sock.recvfrom(bufsize)
477 async def sock_recvfrom_into(self, sock, buf, nbytes=0):
483 base_events._check_ssl_socket(sock)
484 if self._debug and sock.gettimeout() != 0:
490 return sock.recvfrom_into(buf, nbytes)
494 fd = sock.fileno()
496 handle = self._add_reader(fd, self._sock_recvfrom_into, fut, sock, buf,
502 def _sock_recvfrom_into(self, fut, sock, buf, bufsize):
509 result = sock.recvfrom_into(buf, bufsize)
519 async def sock_sendall(self, sock, data):
528 base_events._check_ssl_socket(sock)
529 if self._debug and sock.gettimeout() != 0:
532 n = sock.send(data)
541 fd = sock.fileno()
544 handle = self._add_writer(fd, self._sock_sendall, fut, sock,
550 def _sock_sendall(self, fut, sock, view, pos):
556 n = sock.send(view[start:])
572 async def sock_sendto(self, sock, data, address):
581 base_events._check_ssl_socket(sock)
582 if self._debug and sock.gettimeout() != 0:
585 return sock.sendto(data, address)
590 fd = sock.fileno()
593 handle = self._add_writer(fd, self._sock_sendto, fut, sock, data,
599 def _sock_sendto(self, fut, sock, data, address):
604 n = sock.sendto(data, 0, address)
614 async def sock_connect(self, sock, address):
619 base_events._check_ssl_socket(sock)
620 if self._debug and sock.gettimeout() != 0:
623 if sock.family == socket.AF_INET or (
624 base_events._HAS_IPv6 and sock.family == socket.AF_INET6):
626 address, family=sock.family, type=sock.type, proto=sock.proto,
632 self._sock_connect(fut, sock, address)
639 def _sock_connect(self, fut, sock, address):
640 fd = sock.fileno()
642 sock.connect(address)
650 fd, self._sock_connect_cb, fut, sock, address)
666 def _sock_connect_cb(self, fut, sock, address):
671 err = sock.getsockopt(socket.SOL_SOCKET, socket.SO_ERROR)
687 async def sock_accept(self, sock):
695 base_events._check_ssl_socket(sock)
696 if self._debug and sock.gettimeout() != 0:
699 self._sock_accept(fut, sock)
702 def _sock_accept(self, fut, sock):
703 fd = sock.fileno()
705 conn, address = sock.accept()
709 handle = self._add_reader(fd, self._sock_accept, fut, sock)
747 def _stop_serving(self, sock):
748 self._remove_reader(sock.fileno())
749 sock.close()
764 def __init__(self, loop, sock, protocol, extra=None, server=None):
766 self._extra['socket'] = trsock.TransportSocket(sock)
768 self._extra['sockname'] = sock.getsockname()
773 self._extra['peername'] = sock.getpeername()
776 self._sock = sock
777 self._sock_fd = sock.fileno()
921 def __init__(self, loop, sock, protocol, waiter=None,
925 super().__init__(loop, sock, protocol, extra, server)
1138 def __init__(self, loop, sock, protocol, address=None,
1140 super().__init__(loop, sock, protocol, extra)