Lines Matching refs:socket
8 import socket
53 if not hasattr(socket, 'IOCTL_VM_SOCKETS_GET_LOCAL_CID'):
57 r = fcntl.ioctl(f, socket.IOCTL_VM_SOCKETS_GET_LOCAL_CID, " ")
66 s = socket.socket(socket.PF_CAN, socket.SOCK_RAW, socket.CAN_RAW)
76 s = socket.socket(socket.PF_CAN, socket.SOCK_DGRAM, socket.CAN_ISOTP)
86 s = socket.socket(socket.PF_CAN, socket.SOCK_DGRAM, socket.CAN_J1939)
96 s = socket.socket(socket.PF_RDS, socket.SOCK_SEQPACKET, 0)
106 s = socket.socket(socket.AF_ALG, socket.SOCK_SEQPACKET, 0)
116 s = socket.socket(socket.AF_QIPCRTR, socket.SOCK_DGRAM, 0)
134 s = socket.socket(socket.AF_BLUETOOTH, socket.SOCK_STREAM, socket.BTPROTO_RFCOMM)
144 old_timeout = socket.getdefaulttimeout()
146 socket.setdefaulttimeout(timeout)
149 socket.setdefaulttimeout(old_timeout)
166 HAVE_SOCKET_UDPLITE = hasattr(socket, "IPPROTO_UDPLITE")
176 self.serv = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
187 self.serv = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)
197 self.serv = socket.socket(socket.AF_INET, socket.SOCK_DGRAM, socket.IPPROTO_UDPLITE)
261 self.s = socket.socket(socket.PF_CAN, socket.SOCK_RAW, socket.CAN_RAW)
278 self.serv = socket.socket(socket.PF_RDS, socket.SOCK_SEQPACKET, 0)
410 self.cli = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
424 self.cli = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)
440 self.cli = socket.socket(socket.AF_INET, socket.SOCK_DGRAM, socket.IPPROTO_UDPLITE)
454 self.cli = socket.socket(socket.PF_CAN, socket.SOCK_RAW, socket.CAN_RAW)
474 self.cli = socket.socket(socket.PF_RDS, socket.SOCK_SEQPACKET, 0)
501 self.serv = socket.socket(socket.AF_VSOCK, socket.SOCK_STREAM)
503 self.serv.bind((socket.VMADDR_CID_ANY, VSOCKPORT))
511 self.cli = socket.socket(socket.AF_VSOCK, socket.SOCK_STREAM)
564 self.serv, self.cli = socket.socketpair()
705 return socket.socket(socket.AF_UNIX, socket.SOCK_STREAM)
724 return socket.socket(socket.AF_INET, socket.SOCK_STREAM)
730 return socket.socket(socket.AF_INET, socket.SOCK_DGRAM)
736 return socket.socket(socket.AF_INET, socket.SOCK_DGRAM, socket.IPPROTO_UDPLITE)
742 return socket.socket(socket.AF_INET, socket.SOCK_STREAM,
743 socket.IPPROTO_SCTP)
755 return socket.socket(socket.AF_INET6, socket.SOCK_DGRAM)
761 return socket.socket(socket.AF_INET6, socket.SOCK_DGRAM, socket.IPPROTO_UDPLITE)
808 isinstance(obj, str) and not hasattr(socket, obj)]
812 callargs = [getattr(socket, obj) if isinstance(obj, str) else obj
815 s = socket.socket(*callargs)
834 self.assertTrue(socket.SocketType is _socket.socket)
835 s = socket.socket()
836 self.assertIsInstance(s, socket.SocketType)
840 s = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
843 self.assertIn('family=%s' % socket.AF_INET, repr(s))
844 self.assertIn('type=%s' % socket.SOCK_STREAM, repr(s))
855 s = _socket.socket(_socket.AF_INET, _socket.SOCK_STREAM)
867 with socket.socket(socket.AF_INET, socket.SOCK_STREAM) as s:
884 raise socket.herror
886 raise socket.gaierror
890 s = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)
934 socket.AF_INET
935 if socket.has_ipv6:
936 socket.AF_INET6
937 socket.SOCK_STREAM
938 socket.SOCK_DGRAM
939 socket.SOCK_RAW
940 socket.SOCK_RDM
941 socket.SOCK_SEQPACKET
942 socket.SOL_SOCKET
943 socket.SO_REUSEADDR
946 socket.IPPROTO_TCP
947 socket.IPPROTO_UDP
948 if socket.has_ipv6:
949 socket.IPPROTO_IPV6
953 socket.IPPROTO_ICLFXBM
954 socket.IPPROTO_ST
955 socket.IPPROTO_CBT
956 socket.IPPROTO_IGP
957 socket.IPPROTO_RDP
958 socket.IPPROTO_PGM
959 socket.IPPROTO_L2TP
960 socket.IPPROTO_SCTP
990 hasattr(socket, opt), f"Missing RFC3542 socket option '{opt}'"
995 hostname = socket.gethostname()
997 ip = socket.gethostbyname(hostname)
1003 hname, aliases, ipaddrs = socket.gethostbyaddr(ip)
1008 fqhn = socket.getfqdn(ip)
1014 self.assertEqual(socket.gethostbyname(addr), addr)
1019 self.assertIn(host, socket.gethostbyaddr(host)[2])
1032 socket.gethostbyname(addr)
1034 socket.gethostbyaddr(addr)
1036 @unittest.skipUnless(hasattr(socket, 'sethostname'), "test needs socket.sethostname()")
1037 @unittest.skipUnless(hasattr(socket, 'gethostname'), "test needs socket.gethostname()")
1039 oldhn = socket.gethostname()
1041 socket.sethostname('new')
1049 self.assertEqual(socket.gethostname(), 'new')
1051 socket.sethostname(b'bar')
1052 self.assertEqual(socket.gethostname(), 'bar')
1054 socket.sethostname(oldhn)
1056 @unittest.skipUnless(hasattr(socket, 'if_nameindex'),
1059 interfaces = socket.if_nameindex()
1065 _index = socket.if_nametoindex(name)
1068 _name = socket.if_indextoname(index)
1072 @unittest.skipUnless(hasattr(socket, 'if_indextoname'),
1075 self.assertRaises(OSError, socket.if_indextoname, 0)
1076 self.assertRaises(TypeError, socket.if_indextoname, '_DEADBEEF')
1078 @unittest.skipUnless(hasattr(socket, 'if_nametoindex'),
1081 self.assertRaises(TypeError, socket.if_nametoindex, 0)
1082 self.assertRaises(OSError, socket.if_nametoindex, '_DEADBEEF')
1091 socket.getnameinfo(__name__,0)
1100 socket.getnameinfo(('x', 0, 0, 0), 0)
1107 sizes = {socket.htonl: 32, socket.ntohl: 32,
1108 socket.htons: 16, socket.ntohs: 16}
1128 socket.ntohs(k)
1129 socket.htons(k)
1131 socket.ntohl(k)
1132 socket.htonl(k)
1134 self.assertRaises(OverflowError, socket.ntohs, k)
1135 self.assertRaises(OverflowError, socket.htons, k)
1137 self.assertRaises(OverflowError, socket.ntohl, k)
1138 self.assertRaises(OverflowError, socket.htonl, k)
1140 self.assertWarns(DeprecationWarning, socket.ntohs, k)
1141 self.assertWarns(DeprecationWarning, socket.htons, k)
1157 port = socket.getservbyname(service, 'tcp')
1167 port2 = socket.getservbyname(service)
1171 udpport = socket.getservbyname(service, 'udp')
1179 eq(socket.getservbyport(port2), service)
1180 eq(socket.getservbyport(port, 'tcp'), service)
1182 eq(socket.getservbyport(udpport, 'udp'), service)
1184 self.assertRaises(OverflowError, socket.getservbyport, -1)
1185 self.assertRaises(OverflowError, socket.getservbyport, 65536)
1190 self.assertEqual(socket.getdefaulttimeout(), None)
1191 with socket.socket() as s:
1196 self.assertEqual(socket.getdefaulttimeout(), 10)
1197 with socket.socket() as sock:
1201 socket.setdefaulttimeout(None)
1202 self.assertEqual(socket.getdefaulttimeout(), None)
1203 with socket.socket() as sock:
1207 self.assertRaises(ValueError, socket.setdefaulttimeout, -1)
1210 self.assertRaises(TypeError, socket.setdefaulttimeout, "spam")
1212 @unittest.skipUnless(hasattr(socket, 'inet_aton'),
1217 self.assertEqual(b'\x00'*4, socket.inet_aton('0.0.0.0'))
1218 self.assertEqual(b'\xff'*4, socket.inet_aton('255.255.255.255'))
1220 @unittest.skipUnless(hasattr(socket, 'inet_pton'),
1223 from socket import inet_aton as f, inet_pton, AF_INET
1253 @unittest.skipUnless(hasattr(socket, 'inet_pton'),
1257 from socket import inet_pton, AF_INET6, has_ipv6
1317 @unittest.skipUnless(hasattr(socket, 'inet_ntop'),
1320 from socket import inet_ntoa as f, inet_ntop, AF_INET
1343 @unittest.skipUnless(hasattr(socket, 'inet_ntop'),
1347 from socket import inet_ntop, AF_INET6, has_ipv6
1382 sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
1390 my_ip_addr = socket.gethostbyname(socket.gethostname())
1400 sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
1402 reuse = sock.getsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR)
1407 sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
1409 sock.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1)
1410 reuse = sock.getsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR)
1415 with socket.socket(socket.AF_INET, socket.SOCK_STREAM) as sock:
1420 sock = socket.socket()
1421 sock.bind((socket._LOCALHOST, 0))
1422 socket.socket(fileno=sock.fileno()).close()
1434 with socket.socket(socket.AF_INET, socket.SOCK_STREAM) as sock:
1435 self.assertEqual(sock.family, socket.AF_INET)
1436 if hasattr(socket, 'SOCK_CLOEXEC'):
1438 (socket.SOCK_STREAM | socket.SOCK_CLOEXEC,
1439 socket.SOCK_STREAM))
1441 self.assertEqual(sock.type, socket.SOCK_STREAM)
1445 sock = socket.socket()
1466 self.assertTrue(hasattr(socket.socket, 'ioctl'))
1467 self.assertTrue(hasattr(socket, 'SIO_RCVALL'))
1468 self.assertTrue(hasattr(socket, 'RCVALL_ON'))
1469 self.assertTrue(hasattr(socket, 'RCVALL_OFF'))
1470 self.assertTrue(hasattr(socket, 'SIO_KEEPALIVE_VALS'))
1471 s = socket.socket()
1474 s.ioctl(socket.SIO_KEEPALIVE_VALS, (1, 100, 100))
1477 @unittest.skipUnless(hasattr(socket, 'SIO_LOOPBACK_FAST_PATH'),
1480 s = socket.socket()
1483 s.ioctl(socket.SIO_LOOPBACK_FAST_PATH, True)
1490 self.assertRaises(TypeError, s.ioctl, socket.SIO_LOOPBACK_FAST_PATH, None)
1494 socket.getaddrinfo('localhost', 80)
1495 except socket.gaierror as err:
1496 if err.errno == socket.EAI_SERVICE:
1501 for info in socket.getaddrinfo(HOST, None):
1505 socket.getaddrinfo('localhost', 80)
1506 socket.getaddrinfo('127.0.0.1', 80)
1507 socket.getaddrinfo(None, 80)
1509 socket.getaddrinfo('::1', 80)
1515 socket.getaddrinfo(HOST, "http")
1516 socket.getaddrinfo(HOST, 80)
1517 socket.getaddrinfo(HOST, None)
1519 infos = socket.getaddrinfo(HOST, 80, socket.AF_INET, socket.SOCK_STREAM)
1521 self.assertEqual(family, socket.AF_INET)
1523 self.assertEqual(type, socket.SOCK_STREAM)
1525 infos = socket.getaddrinfo(HOST, None, 0, socket.SOCK_STREAM)
1527 self.assertEqual(socktype, socket.SOCK_STREAM)
1529 socket.getaddrinfo(HOST, None, 0, 0, socket.SOL_TCP)
1530 socket.getaddrinfo(HOST, None, 0, 0, 0, socket.AI_PASSIVE)
1533 socket.getaddrinfo(None, 0, socket.AF_UNSPEC, socket.SOCK_STREAM, 0,
1534 socket.AI_PASSIVE)
1536 a = socket.getaddrinfo(HOST, None)
1537 b = socket.getaddrinfo(host=HOST, port=None)
1539 a = socket.getaddrinfo(HOST, None, socket.AF_INET)
1540 b = socket.getaddrinfo(HOST, None, family=socket.AF_INET)
1542 a = socket.getaddrinfo(HOST, None, 0, socket.SOCK_STREAM)
1543 b = socket.getaddrinfo(HOST, None, type=socket.SOCK_STREAM)
1545 a = socket.getaddrinfo(HOST, None, 0, 0, socket.SOL_TCP)
1546 b = socket.getaddrinfo(HOST, None, proto=socket.SOL_TCP)
1548 a = socket.getaddrinfo(HOST, None, 0, 0, 0, socket.AI_PASSIVE)
1549 b = socket.getaddrinfo(HOST, None, flags=socket.AI_PASSIVE)
1551 a = socket.getaddrinfo(None, 0, socket.AF_UNSPEC, socket.SOCK_STREAM, 0,
1552 socket.AI_PASSIVE)
1553 b = socket.getaddrinfo(host=None, port=0, family=socket.AF_UNSPEC,
1554 type=socket.SOCK_STREAM, proto=0,
1555 flags=socket.AI_PASSIVE)
1558 self.assertRaises(UnicodeEncodeError, socket.getaddrinfo, 'localhost', '\uD800')
1561 if hasattr(socket, 'AI_NUMERICSERV'):
1565 socket.getaddrinfo("localhost", None, 0, 0, 0,
1566 socket.AI_NUMERICSERV)
1567 except socket.gaierror:
1572 self.assertRaises(OSError, socket.getnameinfo, ('mail.python.org',0), 0)
1580 socket.gethostbyname('python.org')
1584 socket.gethostbyname(domain)
1585 socket.gethostbyname_ex(domain)
1586 socket.getaddrinfo(domain,0,socket.AF_UNSPEC,socket.SOCK_STREAM)
1593 if not hasattr(signal, 'alarm') or not hasattr(socket, 'socketpair'):
1602 c, s = socket.socketpair()
1614 self.assertRaises(socket.timeout, c.sendall,
1629 sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
1636 sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
1646 with socket.socket(socket.AF_INET, socket.SOCK_STREAM) as sock:
1652 with socket.socket() as sock:
1663 sock = socket.socket()
1666 socket.close(sock.fileno())
1674 socket.close(None)
1676 socket.close(-1)
1681 with socket.socket() as sock:
1688 with socket.socket() as sock:
1693 sock = socket.socket()
1698 family = pickle.loads(pickle.dumps(socket.AF_INET, protocol))
1699 self.assertEqual(family, socket.AF_INET)
1700 type = pickle.loads(pickle.dumps(socket.SOCK_STREAM, protocol))
1701 self.assertEqual(type, socket.SOCK_STREAM)
1705 with socket.socket(socket.AF_INET, socket.SOCK_STREAM) as srv:
1709 with socket.socket(socket.AF_INET, socket.SOCK_STREAM) as srv:
1717 with socket.socket(socket.AF_INET, socket.SOCK_STREAM) as srv:
1723 self.assertRaises(OverflowError, socket.getnameinfo,
1725 with socket.socket(socket.AF_INET6, socket.SOCK_STREAM) as s:
1730 ((*_, sockaddr),) = socket.getaddrinfo(
1732 1234, socket.AF_INET6,
1733 socket.SOCK_DGRAM,
1734 socket.IPPROTO_UDP
1743 (ifindex, test_interface) = socket.if_nameindex()[0]
1744 ((*_, sockaddr),) = socket.getaddrinfo(
1746 1234, socket.AF_INET6,
1747 socket.SOCK_DGRAM,
1748 socket.IPPROTO_UDP
1761 ((*_, sockaddr),) = socket.getaddrinfo(
1763 1234, socket.AF_INET6,
1764 socket.SOCK_DGRAM,
1765 socket.IPPROTO_UDP
1775 (ifindex, test_interface) = socket.if_nameindex()[0]
1777 nameinfo = socket.getnameinfo(sockaddr, socket.NI_NUMERICHOST | socket.NI_NUMERICSERV)
1788 nameinfo = socket.getnameinfo(sockaddr, socket.NI_NUMERICHOST | socket.NI_NUMERICSERV)
1794 with socket.socket(socket.AF_INET, socket.SOCK_STREAM) as s:
1799 SOCK_NONBLOCK = getattr(socket, 'SOCK_NONBLOCK', 0)
1800 SOCK_CLOEXEC = getattr(socket, 'SOCK_CLOEXEC', 0)
1801 sock_type = socket.SOCK_STREAM | SOCK_NONBLOCK | SOCK_CLOEXEC
1803 with socket.socket(socket.AF_INET, sock_type) as s:
1804 self.assertEqual(s.type, socket.SOCK_STREAM)
1806 self.assertEqual(s.type, socket.SOCK_STREAM)
1808 self.assertEqual(s.type, socket.SOCK_STREAM)
1810 self.assertEqual(s.type, socket.SOCK_STREAM)
1812 self.assertEqual(s.type, socket.SOCK_STREAM)
1821 sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
1823 unknown_family = max(socket.AddressFamily.__members__.values()) + 1
1827 for name, kind in socket.SocketKind.__members__.items()
1831 with socket.socket(
1847 with socket.socket() as sock:
1850 with self.assertRaises(socket._GiveupOnSendfile):
1862 s2 = socket.socket(fileno=fd)
1871 s = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
1874 self._test_socket_fileno(s, socket.AF_INET, socket.SOCK_STREAM)
1876 if hasattr(socket, "SOCK_DGRAM"):
1877 s = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)
1880 self._test_socket_fileno(s, socket.AF_INET, socket.SOCK_DGRAM)
1883 s = socket.socket(socket.AF_INET6, socket.SOCK_STREAM)
1886 self._test_socket_fileno(s, socket.AF_INET6, socket.SOCK_STREAM)
1888 if hasattr(socket, "AF_UNIX"):
1891 s = socket.socket(socket.AF_UNIX, socket.SOCK_STREAM)
1898 self._test_socket_fileno(s, socket.AF_UNIX,
1899 socket.SOCK_STREAM)
1903 socket.socket(socket.AF_INET, socket.SOCK_STREAM, fileno=42.5)
1907 socket.socket(socket.AF_INET, socket.SOCK_STREAM, fileno="foo")
1911 socket.socket(socket.AF_INET, socket.SOCK_STREAM, fileno=-1)
1916 socket.socket(socket.AF_INET, socket.SOCK_STREAM, fileno=-42)
1921 socket.socket(fileno=support.make_bad_fd())
1925 socket.socket(
1926 socket.AF_INET,
1927 socket.SOCK_STREAM,
1934 socket.socket(fileno=afile.fileno())
1937 socket.socket(
1938 socket.AF_INET,
1939 socket.SOCK_STREAM,
1948 socket.AF_CAN
1949 socket.PF_CAN
1950 socket.CAN_RAW
1952 @unittest.skipUnless(hasattr(socket, "CAN_BCM"),
1955 socket.CAN_BCM
1958 socket.CAN_BCM_TX_SETUP # create (cyclic) transmission task
1959 socket.CAN_BCM_TX_DELETE # remove (cyclic) transmission task
1960 socket.CAN_BCM_TX_READ # read properties of (cyclic) transmission task
1961 socket.CAN_BCM_TX_SEND # send one CAN frame
1962 socket.CAN_BCM_RX_SETUP # create RX content filter subscription
1963 socket.CAN_BCM_RX_DELETE # remove RX content filter subscription
1964 socket.CAN_BCM_RX_READ # read properties of RX content filter subscription
1965 socket.CAN_BCM_TX_STATUS # reply to TX_READ request
1966 socket.CAN_BCM_TX_EXPIRED # notification on performed transmissions (count=0)
1967 socket.CAN_BCM_RX_STATUS # reply to RX_READ request
1968 socket.CAN_BCM_RX_TIMEOUT # cyclic message is absent
1969 socket.CAN_BCM_RX_CHANGED # updated CAN frame (detected content change)
1972 socket.CAN_BCM_SETTIMER
1973 socket.CAN_BCM_STARTTIMER
1974 socket.CAN_BCM_TX_COUNTEVT
1975 socket.CAN_BCM_TX_ANNOUNCE
1976 socket.CAN_BCM_TX_CP_CAN_ID
1977 socket.CAN_BCM_RX_FILTER_ID
1978 socket.CAN_BCM_RX_CHECK_DLC
1979 socket.CAN_BCM_RX_NO_AUTOTIMER
1980 socket.CAN_BCM_RX_ANNOUNCE_RESUME
1981 socket.CAN_BCM_TX_RESET_MULTI_IDX
1982 socket.CAN_BCM_RX_RTR_FRAME
1985 with socket.socket(socket.PF_CAN, socket.SOCK_RAW, socket.CAN_RAW) as s:
1988 @unittest.skipUnless(hasattr(socket, "CAN_BCM"),
1991 with socket.socket(socket.PF_CAN, socket.SOCK_DGRAM, socket.CAN_BCM) as s:
1995 with socket.socket(socket.PF_CAN, socket.SOCK_RAW, socket.CAN_RAW) as s:
2002 with socket.socket(socket.PF_CAN, socket.SOCK_RAW, socket.CAN_RAW) as s:
2006 @unittest.skipUnless(hasattr(socket, "CAN_RAW_LOOPBACK"),
2009 with socket.socket(socket.PF_CAN, socket.SOCK_RAW, socket.CAN_RAW) as s:
2011 s.setsockopt(socket.SOL_CAN_RAW, socket.CAN_RAW_LOOPBACK,
2014 s.getsockopt(socket.SOL_CAN_RAW, socket.CAN_RAW_LOOPBACK))
2016 @unittest.skipUnless(hasattr(socket, "CAN_RAW_FILTER"),
2021 with socket.socket(socket.PF_CAN, socket.SOCK_RAW, socket.CAN_RAW) as s:
2022 s.setsockopt(socket.SOL_CAN_RAW, socket.CAN_RAW_FILTER, can_filter)
2024 s.getsockopt(socket.SOL_CAN_RAW, socket.CAN_RAW_FILTER, 8))
2025 s.setsockopt(socket.SOL_CAN_RAW, socket.CAN_RAW_FILTER, bytearray(can_filter))
2051 self.assertEqual(addr[1], socket.AF_CAN)
2079 @unittest.skipUnless(hasattr(socket, "CAN_BCM"),
2088 @unittest.skipUnless(hasattr(socket, "CAN_BCM"),
2091 bcm = socket.socket(socket.PF_CAN, socket.SOCK_DGRAM, socket.CAN_BCM)
2097 opcode = socket.CAN_BCM_TX_SEND
2128 socket.AF_CAN
2129 socket.PF_CAN
2130 socket.CAN_ISOTP
2131 socket.SOCK_DGRAM
2134 with socket.socket(socket.PF_CAN, socket.SOCK_RAW, socket.CAN_RAW) as s:
2137 @unittest.skipUnless(hasattr(socket, "CAN_ISOTP"),
2140 with socket.socket(socket.PF_CAN, socket.SOCK_DGRAM, socket.CAN_ISOTP) as s:
2145 with socket.socket(socket.PF_CAN, socket.SOCK_DGRAM, socket.CAN_ISOTP) as s:
2151 with socket.socket(socket.PF_CAN, socket.SOCK_DGRAM, socket.CAN_ISOTP) as s:
2170 @unittest.skipUnless(hasattr(socket, "CAN_J1939"),
2173 socket.CAN_J1939
2175 socket.J1939_MAX_UNICAST_ADDR
2176 socket.J1939_IDLE_ADDR
2177 socket.J1939_NO_ADDR
2178 socket.J1939_NO_NAME
2179 socket.J1939_PGN_REQUEST
2180 socket.J1939_PGN_ADDRESS_CLAIMED
2181 socket.J1939_PGN_ADDRESS_COMMANDED
2182 socket.J1939_PGN_PDU1_MAX
2183 socket.J1939_PGN_MAX
2184 socket.J1939_NO_PGN
2187 socket.SO_J1939_FILTER
2188 socket.SO_J1939_PROMISC
2189 socket.SO_J1939_SEND_PRIO
2190 socket.SO_J1939_ERRQUEUE
2192 socket.SCM_J1939_DEST_ADDR
2193 socket.SCM_J1939_DEST_NAME
2194 socket.SCM_J1939_PRIO
2195 socket.SCM_J1939_ERRQUEUE
2197 socket.J1939_NLA_PAD
2198 socket.J1939_NLA_BYTES_ACKED
2200 socket.J1939_EE_INFO_NONE
2201 socket.J1939_EE_INFO_TX_ABORT
2203 socket.J1939_FILTER_MAX
2205 @unittest.skipUnless(hasattr(socket, "CAN_J1939"),
2208 with socket.socket(socket.PF_CAN, socket.SOCK_DGRAM, socket.CAN_J1939) as s:
2213 with socket.socket(socket.PF_CAN, socket.SOCK_DGRAM, socket.CAN_J1939) as s:
2214 … addr = self.interface, socket.J1939_NO_NAME, socket.J1939_NO_PGN, socket.J1939_NO_ADDR
2229 socket.AF_RDS
2230 socket.PF_RDS
2233 with socket.socket(socket.PF_RDS, socket.SOCK_SEQPACKET, 0) as s:
2238 with socket.socket(socket.PF_RDS, socket.SOCK_SEQPACKET, 0) as s:
2239 s.setsockopt(socket.SOL_SOCKET, socket.SO_RCVBUF, bufsize)
2240 s.setsockopt(socket.SOL_SOCKET, socket.SO_SNDBUF, bufsize)
2263 data, addr = self.serv.recvfrom(self.bufsize, socket.MSG_PEEK)
2272 @requireAttrs(socket.socket, 'recvmsg')
2277 @requireAttrs(socket.socket, 'sendmsg')
2311 socket.AF_QIPCRTR
2314 with socket.socket(socket.AF_QIPCRTR, socket.SOCK_DGRAM) as s:
2318 with socket.socket(socket.AF_QIPCRTR, socket.SOCK_DGRAM) as s:
2322 with socket.socket(socket.AF_QIPCRTR, socket.SOCK_DGRAM) as s:
2327 with socket.socket(socket.AF_QIPCRTR, socket.SOCK_DGRAM) as s:
2331 with socket.socket(socket.AF_QIPCRTR, socket.SOCK_DGRAM) as s:
2341 socket.AF_VSOCK
2344 socket.SO_VM_SOCKETS_BUFFER_SIZE
2345 socket.SO_VM_SOCKETS_BUFFER_MIN_SIZE
2346 socket.SO_VM_SOCKETS_BUFFER_MAX_SIZE
2347 socket.VMADDR_CID_ANY
2348 socket.VMADDR_PORT_ANY
2349 socket.VMADDR_CID_HOST
2350 socket.VM_SOCKETS_INVALID_VERSION
2351 socket.IOCTL_VM_SOCKETS_GET_LOCAL_CID
2354 with socket.socket(socket.AF_VSOCK, socket.SOCK_STREAM) as s:
2358 with socket.socket(socket.AF_VSOCK, socket.SOCK_STREAM) as s:
2359 orig_max = s.getsockopt(socket.AF_VSOCK,
2360 socket.SO_VM_SOCKETS_BUFFER_MAX_SIZE)
2361 orig = s.getsockopt(socket.AF_VSOCK,
2362 socket.SO_VM_SOCKETS_BUFFER_SIZE)
2363 orig_min = s.getsockopt(socket.AF_VSOCK,
2364 socket.SO_VM_SOCKETS_BUFFER_MIN_SIZE)
2366 s.setsockopt(socket.AF_VSOCK,
2367 socket.SO_VM_SOCKETS_BUFFER_MAX_SIZE, orig_max * 2)
2368 s.setsockopt(socket.AF_VSOCK,
2369 socket.SO_VM_SOCKETS_BUFFER_SIZE, orig * 2)
2370 s.setsockopt(socket.AF_VSOCK,
2371 socket.SO_VM_SOCKETS_BUFFER_MIN_SIZE, orig_min * 2)
2374 s.getsockopt(socket.AF_VSOCK,
2375 socket.SO_VM_SOCKETS_BUFFER_MAX_SIZE))
2377 s.getsockopt(socket.AF_VSOCK,
2378 socket.SO_VM_SOCKETS_BUFFER_SIZE))
2380 s.getsockopt(socket.AF_VSOCK,
2381 socket.SO_VM_SOCKETS_BUFFER_MIN_SIZE))
2389 socket.BDADDR_ANY
2390 socket.BDADDR_LOCAL
2391 socket.AF_BLUETOOTH
2392 socket.BTPROTO_RFCOMM
2395 socket.BTPROTO_HCI
2396 socket.SOL_HCI
2397 socket.BTPROTO_L2CAP
2400 socket.BTPROTO_SCO
2403 with socket.socket(socket.AF_BLUETOOTH, socket.SOCK_STREAM, socket.BTPROTO_RFCOMM) as s:
2408 with socket.socket(socket.AF_BLUETOOTH, socket.SOCK_SEQPACKET, socket.BTPROTO_L2CAP) as s:
2413 with socket.socket(socket.AF_BLUETOOTH, socket.SOCK_RAW, socket.BTPROTO_HCI) as s:
2419 with socket.socket(socket.AF_BLUETOOTH, socket.SOCK_SEQPACKET, socket.BTPROTO_SCO) as s:
2481 sock = socket.fromfd(fd, socket.AF_INET, socket.SOCK_STREAM)
2483 self.assertIsInstance(sock, socket.socket)
2537 sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM, fileno=f)
2683 msg_flags_common_unset |= getattr(socket, name, 0)
2768 return super().msg_flags_non_eor_indicator | socket.MSG_TRUNC
2776 return super().msg_flags_eor_indicator | socket.MSG_EOR
2911 @requireAttrs(socket, "CMSG_SPACE")
2931 if not hasattr(socket, "CMSG_SPACE"):
2969 except socket.timeout:
2999 self.sendmsgToServer([b"a"*512], [], socket.MSG_DONTWAIT)
3112 self.assertRaises(socket.timeout,
3120 @requireAttrs(socket, "MSG_PEEK")
3128 socket.MSG_PEEK)
3137 ignore=getattr(socket, "MSG_TRUNC", 0))
3142 socket.MSG_PEEK)
3159 @requireAttrs(socket.socket, "sendmsg")
3332 @requireAttrs(socket, "CMSG_LEN")
3336 toobig = self.socklen_t_limit - socket.CMSG_LEN(0) + 1
3340 self.assertGreater(socket.CMSG_LEN(0), array.array("i").itemsize * 2)
3342 ret = socket.CMSG_LEN(n)
3344 self.assertEqual(ret - socket.CMSG_LEN(0), n)
3347 self.assertRaises(OverflowError, socket.CMSG_LEN, -1)
3350 self.assertRaises(OverflowError, socket.CMSG_LEN, toobig)
3351 self.assertRaises(OverflowError, socket.CMSG_LEN, sys.maxsize)
3353 @requireAttrs(socket, "CMSG_SPACE")
3357 toobig = self.socklen_t_limit - socket.CMSG_SPACE(1) + 1
3360 last = socket.CMSG_SPACE(0)
3364 ret = socket.CMSG_SPACE(n)
3366 self.assertGreaterEqual(ret, socket.CMSG_LEN(n))
3367 self.assertGreaterEqual(ret, n + socket.CMSG_LEN(0))
3371 self.assertRaises(OverflowError, socket.CMSG_SPACE, -1)
3374 self.assertRaises(OverflowError, socket.CMSG_SPACE, toobig)
3375 self.assertRaises(OverflowError, socket.CMSG_SPACE, sys.maxsize)
3412 if (cmsg_level == socket.SOL_SOCKET and
3413 cmsg_type == socket.SCM_RIGHTS):
3425 [(socket.SOL_SOCKET,
3426 socket.SCM_RIGHTS,
3439 self.checkFlags(flags, eor=True, checkunset=socket.MSG_CTRUNC,
3448 self.assertEqual(cmsg_level, socket.SOL_SOCKET)
3449 self.assertEqual(cmsg_type, socket.SCM_RIGHTS)
3466 [(socket.SOL_SOCKET,
3467 socket.SCM_RIGHTS,
3479 @requireAttrs(socket, "CMSG_SPACE")
3484 socket.CMSG_SPACE(4 * SIZEOF_INT)))
3494 socket.CMSG_LEN(4 * SIZEOF_INT)),
3498 ignoreflags=socket.MSG_CTRUNC)
3505 @requireAttrs(socket, "CMSG_SPACE")
3519 self.sendmsgToServer([MSG], [(socket.SOL_SOCKET,
3520 socket.SCM_RIGHTS,
3522 (socket.SOL_SOCKET,
3523 socket.SCM_RIGHTS,
3529 @requireAttrs(socket, "CMSG_SPACE")
3536 socket.CMSG_SPACE(SIZEOF_INT) +
3537 socket.CMSG_LEN(SIZEOF_INT * num_fds)),
3538 maxcmsgs=2, ignoreflags=socket.MSG_CTRUNC)
3546 self.sendmsgToServer([MSG], [(socket.SOL_SOCKET,
3547 socket.SCM_RIGHTS,
3549 (socket.SOL_SOCKET,
3550 socket.SCM_RIGHTS,
3571 ignoreflags=socket.MSG_CTRUNC)
3574 self.sendAncillaryIfPossible(MSG, [(socket.SOL_SOCKET,
3575 socket.SCM_RIGHTS,
3584 self.checkFlags(flags, eor=True, ignore=socket.MSG_CTRUNC)
3587 self.assertEqual(cmsg_level, socket.SOL_SOCKET)
3588 self.assertEqual(cmsg_type, socket.SCM_RIGHTS)
3594 [(socket.SOL_SOCKET,
3595 socket.SCM_RIGHTS,
3598 @requireAttrs(socket, "CMSG_SPACE")
3605 self.checkFlags(flags, eor=True, ignore=socket.MSG_CTRUNC)
3610 self.assertEqual(cmsg_level, socket.SOL_SOCKET)
3611 self.assertEqual(cmsg_type, socket.SCM_RIGHTS)
3622 [(socket.SOL_SOCKET,
3623 socket.SCM_RIGHTS,
3625 (socket.SOL_SOCKET,
3626 socket.SCM_RIGHTS,
3636 self.checkFlags(flags, eor=True, checkset=socket.MSG_CTRUNC,
3646 ignoreflags=socket.MSG_CTRUNC)
3654 ignoreflags=socket.MSG_CTRUNC)
3680 socket.CMSG_LEN(0) - 1))
3697 self.checkFlags(flags, eor=True, checkset=socket.MSG_CTRUNC)
3703 self.assertEqual(cmsg_level, socket.SOL_SOCKET)
3704 self.assertEqual(cmsg_type, socket.SCM_RIGHTS)
3713 self.checkTruncatedArray(ancbuf=socket.CMSG_LEN(0), maxdata=0)
3719 self.checkTruncatedArray(ancbuf=socket.CMSG_LEN(0) + 1, maxdata=1)
3725 self.checkTruncatedArray(ancbuf=socket.CMSG_LEN(SIZEOF_INT),
3732 self.checkTruncatedArray(ancbuf=socket.CMSG_LEN(2 * SIZEOF_INT) - 1,
3771 self.serv_sock.setsockopt(socket.IPPROTO_IPV6,
3772 socket.IPV6_RECVHOPLIMIT, 1)
3779 self.checkFlags(flags, eor=True, checkunset=socket.MSG_CTRUNC,
3785 self.assertEqual(cmsg_level, socket.IPPROTO_IPV6)
3786 self.assertEqual(cmsg_type, socket.IPV6_HOPLIMIT)
3794 @requireAttrs(socket, "IPV6_RECVHOPLIMIT", "IPV6_HOPLIMIT")
3807 @requireAttrs(socket, "CMSG_SPACE", "IPV6_RECVHOPLIMIT", "IPV6_HOPLIMIT")
3810 self.checkHopLimit(ancbufsize=socket.CMSG_SPACE(SIZEOF_INT))
3822 @requireAttrs(socket.socket, "sendmsg")
3823 @requireAttrs(socket, "IPV6_RECVHOPLIMIT", "IPV6_HOPLIMIT")
3834 [(socket.IPPROTO_IPV6, socket.IPV6_HOPLIMIT,
3845 self.serv_sock.setsockopt(socket.IPPROTO_IPV6,
3846 socket.IPV6_RECVHOPLIMIT, 1)
3847 self.serv_sock.setsockopt(socket.IPPROTO_IPV6,
3848 socket.IPV6_RECVTCLASS, 1)
3855 self.checkFlags(flags, eor=True, checkunset=socket.MSG_CTRUNC,
3860 tcdata = ancmap[(socket.IPPROTO_IPV6, socket.IPV6_TCLASS)]
3867 hldata = ancmap[(socket.IPPROTO_IPV6, socket.IPV6_HOPLIMIT)]
3874 @requireAttrs(socket, "IPV6_RECVHOPLIMIT", "IPV6_HOPLIMIT",
3885 @requireAttrs(socket, "CMSG_SPACE", "IPV6_RECVHOPLIMIT", "IPV6_HOPLIMIT",
3891 ancbufsize=socket.CMSG_SPACE(SIZEOF_INT) * 2)
3898 @requireAttrs(socket.socket, "sendmsg")
3899 @requireAttrs(socket, "CMSG_SPACE", "IPV6_RECVHOPLIMIT", "IPV6_HOPLIMIT",
3912 [(socket.IPPROTO_IPV6, socket.IPV6_TCLASS,
3914 (socket.IPPROTO_IPV6, socket.IPV6_HOPLIMIT,
3918 @requireAttrs(socket.socket, "sendmsg")
3919 @requireAttrs(socket, "CMSG_SPACE", "IPV6_RECVHOPLIMIT", "IPV6_HOPLIMIT",
3934 [(socket.IPPROTO_IPV6, socket.IPV6_TCLASS,
3936 (socket.IPPROTO_IPV6, socket.IPV6_HOPLIMIT,
3942 [(socket.IPPROTO_IPV6, socket.IPV6_TCLASS,
3944 (socket.IPPROTO_IPV6, socket.IPV6_HOPLIMIT,
3957 self.serv_sock.setsockopt(socket.IPPROTO_IPV6,
3958 socket.IPV6_RECVHOPLIMIT, 1)
3967 self.checkFlags(flags, eor=True, checkset=socket.MSG_CTRUNC,
3970 @requireAttrs(socket, "IPV6_RECVHOPLIMIT", "IPV6_HOPLIMIT")
3979 ignoreflags=socket.MSG_CTRUNC)
3986 @requireAttrs(socket, "IPV6_RECVHOPLIMIT", "IPV6_HOPLIMIT")
3991 ignoreflags=socket.MSG_CTRUNC)
4001 @requireAttrs(socket, "IPV6_RECVHOPLIMIT", "IPV6_HOPLIMIT")
4010 @requireAttrs(socket, "IPV6_RECVHOPLIMIT", "IPV6_HOPLIMIT")
4019 @requireAttrs(socket, "IPV6_RECVHOPLIMIT", "IPV6_HOPLIMIT")
4021 self.checkHopLimitTruncatedHeader(ancbufsize=socket.CMSG_LEN(0) - 1)
4028 @requireAttrs(socket, "IPV6_RECVHOPLIMIT", "IPV6_HOPLIMIT")
4033 self.serv_sock.setsockopt(socket.IPPROTO_IPV6,
4034 socket.IPV6_RECVHOPLIMIT, 1)
4037 self.serv_sock, len(MSG), socket.CMSG_LEN(SIZEOF_INT) - 1)
4041 self.checkFlags(flags, eor=True, checkset=socket.MSG_CTRUNC)
4046 self.assertEqual(cmsg_level, socket.IPPROTO_IPV6)
4047 self.assertEqual(cmsg_type, socket.IPV6_HOPLIMIT)
4062 self.serv_sock.setsockopt(socket.IPPROTO_IPV6,
4063 socket.IPV6_RECVHOPLIMIT, 1)
4064 self.serv_sock.setsockopt(socket.IPPROTO_IPV6,
4065 socket.IPV6_RECVTCLASS, 1)
4072 self.checkFlags(flags, eor=True, checkset=socket.MSG_CTRUNC,
4077 self.assertEqual(cmsg_level, socket.IPPROTO_IPV6)
4078 self.assertIn(cmsg_type, {socket.IPV6_TCLASS, socket.IPV6_HOPLIMIT})
4087 @requireAttrs(socket, "CMSG_SPACE", "IPV6_RECVHOPLIMIT", "IPV6_HOPLIMIT",
4090 self.checkTruncatedSecondHeader(socket.CMSG_SPACE(SIZEOF_INT),
4091 ignoreflags=socket.MSG_CTRUNC)
4098 @requireAttrs(socket, "CMSG_SPACE", "IPV6_RECVHOPLIMIT", "IPV6_HOPLIMIT",
4101 self.checkTruncatedSecondHeader(socket.CMSG_SPACE(SIZEOF_INT) + 1)
4108 @requireAttrs(socket, "CMSG_SPACE", "IPV6_RECVHOPLIMIT", "IPV6_HOPLIMIT",
4111 self.checkTruncatedSecondHeader(socket.CMSG_SPACE(SIZEOF_INT) +
4119 @requireAttrs(socket, "CMSG_SPACE", "IPV6_RECVHOPLIMIT", "IPV6_HOPLIMIT",
4122 self.checkTruncatedSecondHeader(socket.CMSG_SPACE(SIZEOF_INT) +
4123 socket.CMSG_LEN(0) - 1)
4130 @requireAttrs(socket, "CMSG_SPACE", "IPV6_RECVHOPLIMIT", "IPV6_HOPLIMIT",
4135 self.serv_sock.setsockopt(socket.IPPROTO_IPV6,
4136 socket.IPV6_RECVHOPLIMIT, 1)
4137 self.serv_sock.setsockopt(socket.IPPROTO_IPV6,
4138 socket.IPV6_RECVTCLASS, 1)
4142 socket.CMSG_SPACE(SIZEOF_INT) + socket.CMSG_LEN(SIZEOF_INT) - 1)
4146 self.checkFlags(flags, eor=True, checkset=socket.MSG_CTRUNC)
4148 cmsg_types = {socket.IPV6_TCLASS, socket.IPV6_HOPLIMIT}
4151 self.assertEqual(cmsg_level, socket.IPPROTO_IPV6)
4161 self.assertEqual(cmsg_level, socket.IPPROTO_IPV6)
4180 @requireAttrs(socket.socket, "sendmsg")
4184 @requireAttrs(socket.socket, "recvmsg")
4188 @requireAttrs(socket.socket, "recvmsg_into")
4202 @requireAttrs(socket.socket, "sendmsg")
4208 @requireAttrs(socket.socket, "recvmsg")
4214 @requireAttrs(socket.socket, "recvmsg_into")
4220 @requireAttrs(socket.socket, "recvmsg")
4222 @requireAttrs(socket, "IPPROTO_IPV6")
4228 @requireAttrs(socket.socket, "recvmsg_into")
4230 @requireAttrs(socket, "IPPROTO_IPV6")
4247 @requireAttrs(socket.socket, "sendmsg")
4253 @requireAttrs(socket.socket, "recvmsg")
4259 @requireAttrs(socket.socket, "recvmsg_into")
4275 @requireAttrs(socket.socket, "sendmsg")
4283 @requireAttrs(socket.socket, "recvmsg")
4291 @requireAttrs(socket.socket, "recvmsg_into")
4299 @requireAttrs(socket.socket, "recvmsg")
4303 @requireAttrs(socket, "IPPROTO_IPV6")
4309 @requireAttrs(socket.socket, "recvmsg_into")
4313 @requireAttrs(socket, "IPPROTO_IPV6")
4325 @requireAttrs(socket.socket, "sendmsg")
4329 @requireAttrs(socket.socket, "recvmsg")
4334 @requireAttrs(socket.socket, "recvmsg_into")
4345 @requireAttrs(socket.socket, "sendmsg")
4351 @requireAttrs(socket.socket, "recvmsg")
4365 @requireAttrs(socket.socket, "recvmsg_into")
4384 @requireAttrs(socket.socket, "sendmsg")
4385 @requireAttrs(socket, "AF_UNIX")
4389 @requireAttrs(socket.socket, "recvmsg")
4390 @requireAttrs(socket, "AF_UNIX")
4395 @requireAttrs(socket.socket, "recvmsg_into")
4396 @requireAttrs(socket, "AF_UNIX")
4401 @requireAttrs(socket.socket, "sendmsg", "recvmsg")
4402 @requireAttrs(socket, "AF_UNIX", "SOL_SOCKET", "SCM_RIGHTS")
4406 @requireAttrs(socket.socket, "sendmsg", "recvmsg_into")
4407 @requireAttrs(socket, "AF_UNIX", "SOL_SOCKET", "SCM_RIGHTS")
4483 @requireAttrs(socket.socket, "recvmsg")
4487 @requireAttrs(socket.socket, "recvmsg_into")
4547 @requireAttrs(socket.socket, "sendmsg")
4578 self.assertIsInstance(sock, socket.socket)
4579 if hasattr(socket, 'AF_UNIX'):
4580 self.assertEqual(sock.family, socket.AF_UNIX)
4582 self.assertEqual(sock.family, socket.AF_INET)
4583 self.assertEqual(sock.type, socket.SOCK_STREAM)
4668 @unittest.skipUnless(hasattr(socket, 'SOCK_NONBLOCK'),
4674 self.serv = socket.socket(socket.AF_INET,
4675 socket.SOCK_STREAM | socket.SOCK_NONBLOCK)
4830 self.assertRaises(socket.timeout, self.read_file.read, 1)
5084 self.cli = socket.create_connection((HOST, self.port))
5093 class MockSocket(socket.socket):
5095 raise socket.timeout('timed out')
5100 old_socket = socket.socket
5101 socket.socket = self.MockSocket
5105 socket.socket = old_socket
5109 cli = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
5120 socket.create_connection((HOST, port))
5144 socket.create_connection((HOST, 1234))
5145 except socket.timeout:
5174 self.cli = socket.create_connection((HOST, self.port),
5181 self.cli = socket.create_connection((HOST, self.port),
5192 self.assertTrue(socket.getdefaulttimeout() is None)
5193 socket.setdefaulttimeout(42)
5195 self.cli = socket.create_connection((HOST, self.port))
5198 socket.setdefaulttimeout(None)
5204 self.assertTrue(socket.getdefaulttimeout() is None)
5205 socket.setdefaulttimeout(30)
5207 self.cli = socket.create_connection((HOST, self.port), timeout=None)
5210 socket.setdefaulttimeout(None)
5215 self.cli = socket.create_connection((HOST, self.port), timeout=30)
5220 self.cli = socket.create_connection((HOST, self.port), 30)
5247 self.cli = sock = socket.create_connection((HOST, self.port))
5252 self.cli = sock = socket.create_connection((HOST, self.port), timeout=1)
5253 self.assertRaises(socket.timeout, lambda: sock.recv(5))
5262 self.assertRaises(socket.timeout, raise_timeout,
5270 except socket.timeout:
5295 except socket.timeout:
5319 self.assertRaises(socket.timeout, raise_timeout,
5327 except socket.timeout:
5344 self.assertRaises(socket.timeout, raise_timeout,
5352 except socket.timeout:
5365 self.assertTrue(issubclass(socket.herror, OSError))
5366 self.assertTrue(issubclass(socket.gaierror, OSError))
5367 self.assertTrue(issubclass(socket.timeout, OSError))
5372 sock0 = socket.socket(socket.AF_INET, socket.SOCK_STREAM, 0)
5373 sock = socket.socket(
5374 socket.AF_INET, socket.SOCK_STREAM, 0, sock0.fileno())
5389 with socket.socket(socket.AF_UNIX, socket.SOCK_STREAM) as s1:
5392 with socket.socket(socket.AF_UNIX, socket.SOCK_STREAM) as s2:
5400 with socket.socket(socket.AF_UNIX, socket.SOCK_STREAM) as s:
5406 with socket.socket(socket.AF_UNIX, socket.SOCK_STREAM) as s:
5411 s = socket.socket(socket.AF_UNIX, socket.SOCK_STREAM)
5420 with socket.socket(socket.AF_UNIX, socket.SOCK_STREAM) as s:
5424 @unittest.skipUnless(hasattr(socket, 'AF_UNIX'), 'test needs socket.AF_UNIX')
5428 self.sock = socket.socket(socket.AF_UNIX, socket.SOCK_STREAM)
5587 if not hasattr(socket, "AF_TIPC"):
5605 srv = socket.socket(socket.AF_TIPC, socket.SOCK_RDM)
5606 cli = socket.socket(socket.AF_TIPC, socket.SOCK_RDM)
5610 srv.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1)
5611 srvaddr = (socket.TIPC_ADDR_NAMESEQ, TIPC_STYPE,
5615 sendaddr = (socket.TIPC_ADDR_NAME, TIPC_STYPE,
5633 self.srv = socket.socket(socket.AF_TIPC, socket.SOCK_STREAM)
5635 self.srv.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1)
5636 srvaddr = (socket.TIPC_ADDR_NAMESEQ, TIPC_STYPE,
5649 self.cli = socket.socket(socket.AF_TIPC, socket.SOCK_STREAM)
5651 addr = (socket.TIPC_ADDR_NAME, TIPC_STYPE,
5670 with socket.socket() as sock:
5674 with socket.socket() as sock:
5678 with socket.socket() as sock:
5690 with socket.create_connection(address) as sock:
5704 with socket.create_connection(address) as sock:
5711 @unittest.skipUnless(hasattr(socket, "SOCK_CLOEXEC"),
5715 with socket.socket(socket.AF_INET,
5716 socket.SOCK_STREAM | socket.SOCK_CLOEXEC) as s:
5717 self.assertEqual(s.type, socket.SOCK_STREAM)
5721 sock = socket.socket()
5726 sock = socket.socket()
5734 sock = socket.socket()
5744 sock = socket.socket()
5758 sock = socket.socket()
5770 s1, s2 = socket.socketpair()
5777 @unittest.skipUnless(hasattr(socket, "SOCK_NONBLOCK"),
5782 self.assertEqual(s.type, socket.SOCK_STREAM)
5799 self.assertEqual(s.type, socket.SOCK_STREAM)
5809 with socket.socket(socket.AF_INET,
5810 socket.SOCK_STREAM | socket.SOCK_NONBLOCK) as s:
5823 t = socket.getdefaulttimeout()
5824 socket.setdefaulttimeout(0.0)
5825 with socket.socket() as s:
5827 socket.setdefaulttimeout(None)
5828 with socket.socket() as s:
5830 socket.setdefaulttimeout(2.0)
5831 with socket.socket() as s:
5833 socket.setdefaulttimeout(None)
5834 with socket.socket() as s:
5836 socket.setdefaulttimeout(t)
5850 s = socket.fromshare(sdata)
5880 s = socket.create_connection(addr)
5895 self.assertRaises(ValueError, socket.fromshare, data[:-1])
5896 self.assertRaises(ValueError, socket.fromshare, data+b"foo")
5916 s = socket.fromshare(data)
5923 families = [socket.AF_INET, socket.AF_INET6]
5924 types = [socket.SOCK_STREAM, socket.SOCK_DGRAM]
5928 source = socket.socket(f, t)
5933 shared = socket.fromshare(data)
6001 with socket.create_connection(address) as sock, file as file:
6018 with socket.create_connection(address) as sock, file as file:
6022 self.assertRaises(socket._GiveupOnSendfile,
6039 with socket.create_connection(address) as sock, file as file:
6055 with socket.create_connection(address) as sock, file as file:
6072 sock = socket.create_connection(address,
6093 sock = socket.create_connection(address,
6114 with socket.create_connection(address, timeout=2) as sock, file as file:
6133 with socket.create_connection(address) as sock, file as file:
6149 sock = socket.create_connection(address,
6167 with socket.create_connection(address) as sock:
6170 self.assertRaises(socket.timeout, meth, file)
6183 with socket.socket(type=socket.SOCK_DGRAM) as s:
6188 with socket.socket() as s:
6193 with socket.socket() as s:
6219 sock = socket.socket(socket.AF_ALG, socket.SOCK_SEQPACKET, 0)
6243 op.send(b'a', socket.MSG_MORE)
6244 op.send(b'b', socket.MSG_MORE)
6245 op.send(b'c', socket.MSG_MORE)
6252 algo.setsockopt(socket.SOL_ALG, socket.ALG_SET_KEY, b"Jefe")
6268 algo.setsockopt(socket.SOL_ALG, socket.ALG_SET_KEY, key)
6271 op.sendmsg_afalg(op=socket.ALG_OP_ENCRYPT, iv=iv,
6272 flags=socket.MSG_MORE)
6279 op=socket.ALG_OP_DECRYPT, iv=iv)
6288 op=socket.ALG_OP_ENCRYPT, iv=iv)
6296 op=socket.ALG_OP_DECRYPT, iv=iv)
6314 algo.setsockopt(socket.SOL_ALG, socket.ALG_SET_KEY, key)
6315 algo.setsockopt(socket.SOL_ALG, socket.ALG_SET_AEAD_AUTHSIZE,
6321 op.sendmsg_afalg(op=socket.ALG_OP_ENCRYPT, iv=iv,
6322 assoclen=assoclen, flags=socket.MSG_MORE)
6323 op.sendall(assoc, socket.MSG_MORE)
6333 op.sendmsg_afalg([msg], op=socket.ALG_OP_ENCRYPT, iv=iv,
6346 ([socket.SOL_ALG, socket.ALG_SET_OP, pack_uint32(socket.ALG_OP_ENCRYPT)],
6347 [socket.SOL_ALG, socket.ALG_SET_IV, pack_uint32(len(iv)) + iv],
6348 [socket.SOL_ALG, socket.ALG_SET_AEAD_ASSOCLEN, pack_uint32(assoclen)],
6359 op.sendmsg_afalg([msg], op=socket.ALG_OP_DECRYPT, iv=iv,
6369 algo.setsockopt(socket.SOL_ALG, socket.ALG_SET_KEY, extra_seed)
6376 sock = socket.socket(socket.AF_ALG, socket.SOCK_SEQPACKET, 0)
6388 sock.sendmsg_afalg(op=socket.ALG_OP_ENCRYPT, assoclen=None)
6391 sock.sendmsg_afalg(op=socket.ALG_OP_ENCRYPT, assoclen=-1)
6395 sock = socket.socket(socket.AF_ALG, socket.SOCK_SEQPACKET, 0)
6427 provided = [s for s in dir(socket) if s.startswith('TCP')]
6438 with socket.create_server(("127.0.0.1", port)) as sock:
6442 with socket.create_server(("::1", port),
6443 family=socket.AF_INET6) as sock:
6448 with socket.create_server(("127.0.0.1", 0)) as sock:
6449 self.assertEqual(sock.family, socket.AF_INET)
6450 self.assertEqual(sock.type, socket.SOCK_STREAM)
6452 with socket.create_server(("::1", 0), family=socket.AF_INET6) as s:
6453 self.assertEqual(s.family, socket.AF_INET6)
6454 self.assertEqual(sock.type, socket.SOCK_STREAM)
6457 if not hasattr(socket, "SO_REUSEPORT"):
6459 socket.create_server(("localhost", 0), reuse_port=True)
6461 with socket.create_server(("localhost", 0)) as sock:
6462 opt = sock.getsockopt(socket.SOL_SOCKET, socket.SO_REUSEPORT)
6464 with socket.create_server(("localhost", 0), reuse_port=True) as sock:
6465 opt = sock.getsockopt(socket.SOL_SOCKET, socket.SO_REUSEPORT)
6473 with socket.create_server(("::1", 0), family=socket.AF_INET6) as sock:
6474 assert sock.getsockopt(socket.IPPROTO_IPV6, socket.IPV6_V6ONLY)
6476 @unittest.skipIf(not socket.has_dualstack_ipv6(),
6480 with socket.create_server(("::1", 0), family=socket.AF_INET6,
6482 self.assertEqual(sock.family, socket.AF_INET6)
6513 with socket.socket(family=family) as sock:
6521 with socket.create_server(("", port)) as sock:
6523 self.echo_client(("127.0.0.1", port), socket.AF_INET)
6528 with socket.create_server(("", port),
6529 family=socket.AF_INET6) as sock:
6531 self.echo_client(("::1", port), socket.AF_INET6)
6535 @unittest.skipIf(not socket.has_dualstack_ipv6(),
6540 with socket.create_server(("", port), family=socket.AF_INET6,
6543 self.echo_client(("127.0.0.1", port), socket.AF_INET)
6545 @unittest.skipIf(not socket.has_dualstack_ipv6(),
6550 with socket.create_server(("", port), family=socket.AF_INET6,
6553 self.echo_client(("::1", port), socket.AF_INET6)
6555 @requireAttrs(socket, "send_fds")
6556 @requireAttrs(socket, "recv_fds")
6557 @requireAttrs(socket, "AF_UNIX")
6575 sock1, sock2 = socket.socketpair(socket.AF_UNIX, socket.SOCK_STREAM)
6577 socket.send_fds(sock1, [MSG], fds)
6579 msg, fds2, flags, addr = socket.recv_fds(sock2, len(MSG) * 2, len(fds) * 2)