Lines Matching refs:sock
76 def _set_reuseport(sock):
81 sock.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEPORT, 1)
87 def _is_stream_socket(sock):
91 return (sock.type & socket.SOCK_STREAM) == socket.SOCK_STREAM
94 def _is_dgram_socket(sock):
98 return (sock.type & socket.SOCK_DGRAM) == socket.SOCK_DGRAM
212 for sock in sockets:
213 self._loop._stop_serving(sock)
309 def _make_socket_transport(self, sock, protocol, waiter=None, *,
320 def _make_datagram_transport(self, sock, protocol,
681 ssl=None, family=0, proto=0, flags=0, sock=None,
714 if sock is not None:
716 'host/port and sock can not be specified at the same time')
743 sock = socket.socket(family=family, type=type, proto=proto)
744 sock.setblocking(False)
748 sock.bind(laddr)
758 sock.close()
759 sock = None
762 logger.debug("connect %r to %r", sock, address)
763 yield from self.sock_connect(sock, address)
765 if sock is not None:
766 sock.close()
769 if sock is not None:
770 sock.close()
788 if sock is None:
790 'host and port was not specified and no sock specified')
791 if not _is_stream_socket(sock):
799 'A Stream Socket was expected, got {!r}'.format(sock))
802 sock, protocol_factory, ssl, server_hostname)
806 sock = transport.get_extra_info('socket')
808 sock, host, port, transport, protocol)
812 def _create_connection_transport(self, sock, protocol_factory, ssl,
815 sock.setblocking(False)
822 sock, protocol, sslcontext, waiter,
825 transport = self._make_socket_transport(sock, protocol, waiter)
840 allow_broadcast=None, sock=None):
842 if sock is not None:
843 if not _is_dgram_socket(sock):
845 'A UDP Socket was expected, got {!r}'.format(sock))
858 'when sock is specified. ({})'.format(problems))
859 sock.setblocking(False)
902 sock = None
905 sock = socket.socket(
908 sock.setsockopt(
911 _set_reuseport(sock)
913 sock.setsockopt(
915 sock.setblocking(False)
918 sock.bind(local_address)
920 yield from self.sock_connect(sock, remote_address)
923 if sock is not None:
924 sock.close()
927 if sock is not None:
928 sock.close()
938 sock, protocol, r_addr, waiter)
971 sock=None,
994 if sock is not None:
996 'host/port and sock can not be specified at the same time')
1021 sock = socket.socket(af, socktype, proto)
1029 sockets.append(sock)
1031 sock.setsockopt(
1034 _set_reuseport(sock)
1039 sock.setsockopt(socket.IPPROTO_IPV6,
1043 sock.bind(sa)
1051 for sock in sockets:
1052 sock.close()
1054 if sock is None:
1055 raise ValueError('Neither host/port nor sock were specified')
1056 if not _is_stream_socket(sock):
1058 'A Stream Socket was expected, got {!r}'.format(sock))
1059 sockets = [sock]
1062 for sock in sockets:
1063 sock.listen(backlog)
1064 sock.setblocking(False)
1065 self._start_serving(protocol_factory, sock, ssl, server, backlog)
1071 def connect_accepted_socket(self, protocol_factory, sock, *, ssl=None):
1080 if not _is_stream_socket(sock):
1082 'A Stream Socket was expected, got {!r}'.format(sock))
1085 sock, protocol_factory, ssl, '', server_side=True)
1089 sock = transport.get_extra_info('socket')
1090 logger.debug("%r handled: (%r, %r)", sock, transport, protocol)
