Lines Matching +full:getsockopt +full:- +full:timeouts
44 MSG = 'Michael Gilfix was here\u1234\r\n'.encode('utf-8')
205 """Subclass of unittest.TestCase with thread-safe cleanup methods.
523 """Socket tests for client-server connection.
587 # gives a drop-in replacement for SocketConnectedTest, but different
690 """Base class for Unix-domain socket tests."""
708 """Base class for Unix-domain SOCK_STREAM tests."""
727 """Base class for TCP-over-IPv4 tests."""
733 """Base class for UDP-over-IPv4 tests."""
739 """Base class for UDPLITE-over-IPv4 tests."""
745 """Base class for SCTP tests in one-to-one (SOCK_STREAM) mode."""
758 """Base class for UDP-over-IPv6 tests."""
764 """Base class for UDPLITE-over-IPv6 tests."""
770 # Test-skipping decorators for use with ThreadableTest.
868 expected = ('<socket object, fd=-1, family=%s, type=%s, proto=%s>'
905 "a bytes-like object is required, not 'str'")
909 "a bytes-like object is required, not 'complex'")
917 "a bytes-like object is required, not 'str'")
921 "a bytes-like object is required, not 'complex'")
1035 # a matching name entry (e.g. 'ip6-localhost')
1083 # interface indices are non-zero integers
1130 mask = (1<<size) - 1
1143 l_bad_values = [-1, -2, 1<<32, 1<<1000]
1146 [_testcapi.INT_MIN-1, _testcapi.INT_MAX+1] +
1170 # assumption breaking non-standard port/protocol entry
1203 self.assertRaises(OverflowError, socket.getservbyport, -1)
1226 self.assertRaises(ValueError, socket.setdefaulttimeout, -1)
1254 # bpo-29972: inet_pton() doesn't fail on AIX
1314 # bpo-29972: inet_pton() doesn't fail on AIX
1396 # XXX The following don't test module-level functionality...
1428 # Testing getsockopt()
1432 reuse = sock.getsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR)
1440 reuse = sock.getsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR)
1479 neg_port = port - 65536
1503 self.assertRaises(ValueError, s.ioctl, -1, None)
1681 self.assertEqual(repr(fp), "<_io.BufferedReader name=-1>")
1708 socket.close(-1)
1714 encoding = None if "b" in mode else "utf-8"
1737 for backlog in 0, -1:
1759 self.assertRaises(OverflowError, s.bind, (socket_helper.HOSTv6, 0, -10))
1831 # Make sure that the AF_* and SOCK_* constants have enum-like string
1952 socket.socket(socket.AF_INET, socket.SOCK_STREAM, fileno=-1)
1954 @unittest.skipIf(os.name == "nt", "Windows disallows -1 only")
1957 socket.socket(socket.AF_INET, socket.SOCK_STREAM, fileno=-42)
2090 s.getsockopt(socket.SOL_CAN_RAW, socket.CAN_RAW_LOOPBACK))
2100 s.getsockopt(socket.SOL_CAN_RAW, socket.CAN_RAW_FILTER, 8))
2403 self.assertRaises(OSError, socket_helper.bind_port, s, host=-2)
2434 orig_max = s.getsockopt(socket.AF_VSOCK,
2436 orig = s.getsockopt(socket.AF_VSOCK,
2438 orig_min = s.getsockopt(socket.AF_VSOCK,
2449 s.getsockopt(socket.AF_VSOCK,
2452 s.getsockopt(socket.AF_VSOCK,
2455 s.getsockopt(socket.AF_VSOCK,
2513 seg1 = self.cli_conn.recv(len(MSG) - 3)
2531 seg1, addr = self.cli_conn.recvfrom(len(MSG)-3)
2644 self.assertRaises(ValueError, self.serv.recvfrom, -1)
2675 self.assertRaises(ValueError, self.serv.recvfrom, -1)
2737 # recvmsg() or recvmsg_into() - RecvmsgIntoMixin overrides
2855 # Base class for tests on connectionless-mode sockets. Users must
3049 # bpo-33937 the test randomly fails on Travis CI with
3065 # Check that MSG_DONTWAIT in flags causes non-blocking behaviour.
3075 # bpo-33937: catch also ENOMEM, the test randomly fails on Travis CI
3084 # Tests for sendmsg() which require a connectionless-mode
3142 len(MSG) - 3)
3143 self.assertEqual(msg, MSG[:-3])
3202 len(MSG) - 3, 0,
3204 self.assertEqual(msg, MSG[:-3])
3255 # Receive end-of-stream indicator (b"", peer socket closed).
3260 self.checkFlags(flags, eor=None) # Might not have end-of-record marker
3268 len(MSG) - 3)
3292 -1, 0, 0)
3294 len(MSG), -1, 0)
3332 [buf], -1, 0)
3377 b1 = bytearray(b"----")
3379 b3 = bytearray(b"--------------")
3385 self.assertEqual(b3, bytearray(b"little lamb---"))
3411 toobig = self.socklen_t_limit - socket.CMSG_LEN(0) + 1
3412 values = list(range(257)) + list(range(toobig - 257, toobig))
3419 self.assertEqual(ret - socket.CMSG_LEN(0), n)
3422 self.assertRaises(OverflowError, socket.CMSG_LEN, -1)
3432 toobig = self.socklen_t_limit - socket.CMSG_SPACE(1) + 1
3433 values = list(range(257)) + list(range(toobig - 257, toobig))
3446 self.assertRaises(OverflowError, socket.CMSG_SPACE, -1)
3454 # Tests for file descriptor passing on Unix-domain sockets.
3459 badfd = -0x5555
3462 # Return a list of n file descriptors for newly-created files
3491 len(cmsg_data) - (len(cmsg_data) % fds.itemsize)])
3497 # server, with the constant MSG as the non-ancillary data.
3671 array.array("i", [self.badfd]).tobytes()[:-1])])
3688 len(cmsg_data) - (len(cmsg_data) % fds.itemsize)])
3699 array.array("i", [fd0, self.badfd]).tobytes()[:-1]),
3734 # Check that no ancillary data is returned for various non-zero
3755 socket.CMSG_LEN(0) - 1))
3784 len(cmsg_data) - (len(cmsg_data) % fds.itemsize)])
3807 self.checkTruncatedArray(ancbuf=socket.CMSG_LEN(2 * SIZEOF_INT) - 1,
3808 maxdata=(2 * SIZEOF_INT) - 1)
3828 # -1 means "use kernel default".
3829 traffic_class = -1
4073 # Check that no ancillary data is returned for various non-zero
4096 self.checkHopLimitTruncatedHeader(ancbufsize=socket.CMSG_LEN(0) - 1)
4112 self.serv_sock, len(MSG), socket.CMSG_LEN(SIZEOF_INT) - 1)
4198 socket.CMSG_LEN(0) - 1)
4217 socket.CMSG_SPACE(SIZEOF_INT) + socket.CMSG_LEN(SIZEOF_INT) - 1)
4275 self.assertEqual(addr1[:-1], addr2[:-1])
4348 self.assertEqual(addr1[:-1], addr2[:-1])
4438 self.skipTest("sporadic ENOTCONN (kernel issue?) - see issue #13876")
4452 self.skipTest("sporadic ENOTCONN (kernel issue?) - see issue #13876")
4615 # sendto() doesn't allow passing a zero-length one; POSIX
4617 # connection-mode, however.
4699 # This forces the version using the non-OS provided socketpair
4703 # This platform already uses the non-OS provided version.
4704 # This platform already uses the non-OS provided version.
4772 # No-op. Exists for base class threading infrastructure to call.
4792 # When a Python socket has a non-zero timeout, it's switched
4793 # internally to a non-blocking mode. Later, sock.sendall(),
4796 # timeouts are enforced.
4854 # bpo-7995: accept() on a listening socket with a timeout and the
4866 # bpo-7995: accept() on a listening socket with a timeout and the
4880 # Testing non-blocking accept
4883 # connect() didn't start: non-blocking accept() fails
4887 dt = time.monotonic() - start_time
4896 # connect() completed: non-blocking accept() doesn't block
4903 # that non-blocking accept() raises BlockingIOError
4909 # Testing non-blocking recv
4914 # the server didn't send data yet: non-blocking recv() fails
4922 self.fail("Error during select call to non-blocking socket.")
4924 # the server sent data yet: non-blocking recv() doesn't block
4932 # that non-blocking recv() raises BlockingIOError
4951 bufsize = -1 # Use default buffer size
4952 encoding = 'utf-8'
5015 first_seg = self.read_file.read(len(self.read_msg)-3)
5144 self.assertEqual(refcount_before - 1, refcount_after)
5149 # Non-blocking ops
5150 # NOTE: to set `read_file` as non-blocking, we must call
5151 # `cli_conn.setblocking` and vice-versa (see setUp / clientSetUp).
5156 self.assertEqual(self.read_file.read(len(self.read_msg) - 3), None)
5159 first_seg = self.read_file.read(len(self.read_msg) - 3)
5163 first_seg = self.read_file.read(len(self.read_msg) - 3)
5183 # The client thread can't skip directly - the SkipTest exception
5212 bufsize = 1 # Default-buffered for reading; line-buffered for writing
5224 read_msg = MSG.decode('utf-8')
5236 write_msg = MSG.decode('utf-8')
5244 read_msg = MSG.decode('utf-8')
5246 write_msg = MSG.decode('utf-8')
5580 address = b"\x00python-test-hello\x00\xff"
5591 address = b"\x00" + b"h" * (self.UNIX_PATH_MAX - 1)
5619 abstract_address = b"^\0[0-9a-f]{5}"
5681 # Test binding to a valid non-ASCII pathname, with the
5682 # non-ASCII bytes supplied using surrogateescape encoding.
5801 f = open("/proc/modules", encoding="utf-8")
5827 TIPC_LOWER + int((TIPC_UPPER - TIPC_LOWER) / 2), 0)
5863 TIPC_LOWER + int((TIPC_UPPER - TIPC_LOWER) / 2), 0)
6005 # "blocking" Python sockets *with timeouts* are in a
6006 # *non-blocking* mode, and 'sock.recv()' uses 'select()'
6106 self.assertRaises(ValueError, socket.fromshare, data[:-1])
6169 total -= step
6269 self.assertEqual(sent, self.FILESIZE - 5000)
6275 self.assertEqual(len(data), self.FILESIZE - 5000)
6355 # timeout (non-triggered)
6386 # bpo-45212: the wait here needs to be longer than the client-side timeout (0.01s)
6400 with open(os_helper.TESTFN, encoding="utf-8") as file:
6415 meth, file, count=-1)
6442 # bpo-31705: On kernel older than 4.5, sendto() failed with ENOKEY,
6472 # Ubuntu 15.10 with Kernel 4.2.0-19.
6539 self.assertEqual(expected_ct, res[assoclen:-taglen])
6540 self.assertEqual(expected_tag, res[-taglen:])
6549 self.assertEqual(expected_ct, res[assoclen:-taglen])
6550 self.assertEqual(expected_tag, res[-taglen:])
6565 self.assertEqual(expected_ct, res[assoclen:-taglen])
6566 self.assertEqual(expected_tag, res[-taglen:])
6574 res = op.recv(len(msg) - taglen)
6604 sock.sendmsg_afalg(op=socket.ALG_OP_ENCRYPT, assoclen=-1)
6607 # bpo-35050, off-by-one error in length check
6650 "New TCP flags were discovered. See bpo-32394 for more information")
6681 opt = sock.getsockopt(socket.SOL_SOCKET, socket.SO_REUSEPORT)
6684 opt = sock.getsockopt(socket.SOL_SOCKET, socket.SO_REUSEPORT)
6693 assert sock.getsockopt(socket.IPPROTO_IPV6, socket.IPV6_V6ONLY)
6746 # --- dual stack tests