Lines Matching refs:sock
587 and bindSock(sock) to bind it to an unused address.
694 def bindSock(self, sock):
696 socket_helper.bind_unix_socket(sock, path)
715 def bindSock(self, sock):
716 socket_helper.bind_port(sock, host=self.host)
1208 with socket.socket() as sock:
1209 self.assertEqual(sock.gettimeout(), 10)
1214 with socket.socket() as sock:
1215 self.assertEqual(sock.gettimeout(), None)
1392 sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
1393 self.addCleanup(sock.close)
1400 sock.bind(("0.0.0.0", port))
1407 name = sock.getsockname()
1422 sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
1423 self.addCleanup(sock.close)
1424 reuse = sock.getsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR)
1429 sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
1430 self.addCleanup(sock.close)
1431 sock.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1)
1432 reuse = sock.getsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR)
1437 with socket.socket(socket.AF_INET, socket.SOCK_STREAM) as sock:
1438 sock.settimeout(1)
1439 self.assertRaises(OSError, sock.send, b"spam")
1442 sock = socket.socket()
1443 sock.bind((socket._LOCALHOST, 0))
1444 socket.socket(fileno=sock.fileno()).close()
1446 sock.close()
1456 with socket.socket(socket.AF_INET, socket.SOCK_STREAM) as sock:
1457 self.assertEqual(sock.family, socket.AF_INET)
1459 self.assertIn(sock.type,
1463 self.assertEqual(sock.type, socket.SOCK_STREAM)
1464 self.assertEqual(sock.proto, 0)
1467 sock = socket.socket()
1468 self.addCleanup(sock.close)
1472 self.assertRaises(OverflowError, sock.bind, (HOST, big_port))
1473 self.assertRaises(OverflowError, sock.bind, (HOST, neg_port))
1479 sock.bind((HOST, port))
1653 sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
1654 r = repr(sock)
1656 sock = None
1660 sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
1661 f = sock.makefile('rb')
1662 r = repr(sock)
1663 sock = None
1670 with socket.socket(socket.AF_INET, socket.SOCK_STREAM) as sock:
1671 fp = sock.makefile("rb")
1676 with socket.socket() as sock:
1677 fp = sock.makefile("rb", buffering=0)
1687 sock = socket.socket()
1689 sock.bind((HOST, 0))
1690 socket.close(sock.fileno())
1692 sock.listen(1)
1695 # sock.close() fails with EBADF
1696 sock.close()
1705 with socket.socket() as sock:
1707 with sock.makefile(mode, encoding=encoding) as fp:
1713 with socket.socket() as sock:
1715 sock.makefile(mode)
1718 sock = socket.socket()
1719 with sock:
1721 self.assertRaises(TypeError, pickle.dumps, sock, protocol)
1854 sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
1855 fd = sock.detach()
1880 with socket.socket() as sock:
1884 sock._sendfile_use_sendfile(File(fd))
1886 sock._sendfile_use_sendfile(File(2**1000))
1888 sock._sendfile_use_sendfile(File(None))
2548 sock = socket.fromfd(fd, socket.AF_INET, socket.SOCK_STREAM)
2549 self.addCleanup(sock.close)
2550 self.assertIsInstance(sock, socket.socket)
2551 msg = sock.recv(1024)
2559 sock = self.cli_conn.dup()
2560 self.addCleanup(sock.close)
2561 msg = sock.recv(1024)
2604 sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM, fileno=f)
2605 self.addCleanup(sock.close)
2606 msg = sock.recv(1024)
2726 def doRecvmsg(self, sock, bufsize, *args):
2727 # Call recvmsg() on sock with given arguments and return its
2732 result = sock.recvmsg(bufsize, *args)
2821 def doRecvmsg(self, sock, bufsize, *args):
2823 result = sock.recvmsg_into([buf], *args)
4644 def _check_defaults(self, sock):
4645 self.assertIsInstance(sock, socket.socket)
4647 self.assertEqual(sock.family, socket.AF_UNIX)
4649 self.assertEqual(sock.family, socket.AF_INET)
4650 self.assertEqual(sock.type, socket.SOCK_STREAM)
4651 self.assertEqual(sock.proto, 0)
4680 def assert_sock_timeout(self, sock, timeout):
4684 self.assertEqual(sock.getblocking(), blocking)
4688 # internally to a non-blocking mode. Later, sock.sendall(),
4689 # sock.recv(), and other socket operations use a select() call and
4694 flag = fcntl.fcntl(sock, fcntl.F_GETFL, os.O_NONBLOCK)
5288 # None timeout means the same as sock.settimeout(None)
5332 self.cli = sock = socket.create_connection((HOST, self.port))
5333 data = sock.recv(5)
5337 self.cli = sock = socket.create_connection((HOST, self.port), timeout=1)
5338 self.assertRaises(TimeoutError, lambda: sock.recv(5))
5460 sock = socket.socket(
5463 self.addCleanup(sock.detach)
5466 sock.setblocking(False)
5529 self.sock = socket.socket(socket.AF_UNIX, socket.SOCK_STREAM)
5532 self.sock.close()
5545 def bind(self, sock, path):
5548 socket_helper.bind_unix_socket(sock, path)
5559 self.assertIn(self.sock.getsockname(), ('', None))
5564 self.bind(self.sock, path)
5566 self.assertEqual(self.sock.getsockname(), path)
5571 self.bind(self.sock, self.encoded(path))
5573 self.assertEqual(self.sock.getsockname(), path)
5580 self.bind(self.sock, b.decode("ascii", "surrogateescape"))
5582 self.assertEqual(self.sock.getsockname(), path)
5590 self.bind(self.sock, path)
5592 self.assertEqual(self.sock.getsockname(), path)
5597 self.assertRaises(OSError, self.sock.bind, "")
5776 with socket.socket() as sock:
5777 self.assertFalse(sock._closed)
5778 self.assertTrue(sock._closed)
5780 with socket.socket() as sock:
5781 sock.close()
5782 self.assertTrue(sock._closed)
5784 with socket.socket() as sock:
5785 self.assertRaises(OSError, sock.sendall, b'foo')
5786 self.assertTrue(sock._closed)
5796 with socket.create_connection(address) as sock:
5797 self.assertFalse(sock._closed)
5798 sock.sendall(b'foo')
5799 self.assertEqual(sock.recv(1024), b'foo')
5800 self.assertTrue(sock._closed)
5810 with socket.create_connection(address) as sock:
5811 sock.close()
5812 self.assertTrue(sock._closed)
5813 self.assertRaises(OSError, sock.sendall, b'foo')
5827 sock = socket.socket()
5828 with sock:
5829 self.assertEqual(sock.get_inheritable(), False)
5832 sock = socket.socket()
5833 with sock:
5834 newsock = sock.dup()
5835 sock.close()
5840 sock = socket.socket()
5841 with sock:
5842 sock.set_inheritable(True)
5843 self.assertEqual(sock.get_inheritable(), True)
5845 sock.set_inheritable(False)
5846 self.assertEqual(sock.get_inheritable(), False)
5850 sock = socket.socket()
5851 with sock:
5852 fd = sock.fileno()
5853 self.assertEqual(sock.get_inheritable(), False)
5860 self.assertEqual(sock.get_inheritable(), True)
5864 sock = socket.socket()
5865 with sock:
5866 fd = sock.fileno()
5870 sock.set_inheritable(True)
5898 # object, "blocking" means that operations like 'sock.recv()'
5901 # *non-blocking* mode, and 'sock.recv()' uses 'select()'
6097 def meth_from_sock(self, sock):
6100 return getattr(sock, "_sendfile_use_send")
6107 with socket.create_connection(address) as sock, file as file:
6108 meth = self.meth_from_sock(sock)
6124 with socket.create_connection(address) as sock, file as file:
6125 sent = sock.sendfile(file)
6129 sock._sendfile_use_sendfile, file)
6145 with socket.create_connection(address) as sock, file as file:
6146 meth = self.meth_from_sock(sock)
6161 with socket.create_connection(address) as sock, file as file:
6162 meth = self.meth_from_sock(sock)
6178 sock = socket.create_connection(address,
6180 with sock, file:
6182 meth = self.meth_from_sock(sock)
6199 sock = socket.create_connection(address,
6201 with sock, file:
6203 meth = self.meth_from_sock(sock)
6220 with socket.create_connection(address, timeout=2) as sock, file as file:
6222 meth = self.meth_from_sock(sock)
6239 with socket.create_connection(address) as sock, file as file:
6240 sock.setblocking(False)
6241 meth = self.meth_from_sock(sock)
6243 self.assertRaises(ValueError, sock.sendfile, file)
6255 sock = socket.create_connection(address,
6257 with sock, file:
6258 meth = self.meth_from_sock(sock)
6273 with socket.create_connection(address) as sock:
6274 sock.settimeout(0.01)
6275 meth = self.meth_from_sock(sock)
6319 def meth_from_sock(self, sock):
6320 return getattr(sock, "_sendfile_use_sendfile")
6327 sock = socket.socket(socket.AF_ALG, socket.SOCK_SEQPACKET, 0)
6329 sock.bind((typ, name))
6332 sock.close()
6335 return sock
6484 sock = socket.socket(socket.AF_ALG, socket.SOCK_SEQPACKET, 0)
6485 with sock:
6487 sock.sendmsg_afalg()
6490 sock.sendmsg_afalg(op=None)
6493 sock.sendmsg_afalg(1)
6496 sock.sendmsg_afalg(op=socket.ALG_OP_ENCRYPT, assoclen=None)
6499 sock.sendmsg_afalg(op=socket.ALG_OP_ENCRYPT, assoclen=-1)
6503 sock = socket.socket(socket.AF_ALG, socket.SOCK_SEQPACKET, 0)
6504 self.addCleanup(sock.close)
6508 sock.bind(("t" * 13, "name"))
6510 sock.bind(("t" * 14, "name"))
6514 sock.bind(("type", "n" * 63))
6516 sock.bind(("type", "n" * 64))
6552 with socket.create_server(("127.0.0.1", port)) as sock:
6553 self.assertEqual(sock.getsockname()[0], "127.0.0.1")
6554 self.assertEqual(sock.getsockname()[1], port)
6557 family=socket.AF_INET6) as sock:
6558 self.assertEqual(sock.getsockname()[0], "::1")
6559 self.assertEqual(sock.getsockname()[1], port)
6562 with socket.create_server(("127.0.0.1", 0)) as sock:
6563 self.assertEqual(sock.family, socket.AF_INET)
6564 self.assertEqual(sock.type, socket.SOCK_STREAM)
6568 self.assertEqual(sock.type, socket.SOCK_STREAM)
6575 with socket.create_server(("localhost", 0)) as sock:
6576 opt = sock.getsockopt(socket.SOL_SOCKET, socket.SO_REUSEPORT)
6578 with socket.create_server(("localhost", 0), reuse_port=True) as sock:
6579 opt = sock.getsockopt(socket.SOL_SOCKET, socket.SO_REUSEPORT)
6587 with socket.create_server(("::1", 0), family=socket.AF_INET6) as sock:
6588 assert sock.getsockopt(socket.IPPROTO_IPV6, socket.IPV6_V6ONLY)
6595 dualstack_ipv6=True) as sock:
6596 self.assertEqual(sock.family, socket.AF_INET6)
6602 def echo_server(self, sock):
6603 def run(sock):
6604 with sock:
6605 conn, _ = sock.accept()
6614 sock.settimeout(self.timeout)
6615 thread = threading.Thread(target=run, args=(sock, ))
6621 with socket.socket(family=family) as sock:
6622 sock.settimeout(self.timeout)
6623 sock.connect(addr)
6624 sock.sendall(b'foo')
6625 self.assertEqual(sock.recv(1024), b'foo')
6629 with socket.create_server(("", port)) as sock:
6630 self.echo_server(sock)
6637 family=socket.AF_INET6) as sock:
6638 self.echo_server(sock)
6649 dualstack_ipv6=True) as sock:
6650 self.echo_server(sock)
6659 dualstack_ipv6=True) as sock:
6660 self.echo_server(sock)