Description
https://github.com/apache/qpid-dispatch/runs/4703076932?check_suite_focus=true#step:27:5543
71: ::Http1OverTcpEdge2EdgeTest::test_05_large_streaming_msg Exception in thread Thread-26 (_run): 71: Traceback (most recent call last): 71: File "/usr/lib64/python3.10/threading.py", line 1009, in _bootstrap_inner 71: self.run() 71: File "/usr/lib64/python3.10/threading.py", line 946, in run 71: self._target(*self._args, **self._kwargs) 71: File "/home/runner/work/qpid-dispatch/qpid-dispatch/qpid-dispatch/tests/http1_tests.py", line 184, in _run 71: rsp = client.getresponse() 71: File "/usr/lib64/python3.10/http/client.py", line 1374, in getresponse 71: response.begin() 71: File "/usr/lib64/python3.10/http/client.py", line 318, in begin 71: version, status, reason = self._read_status() 71: File "/usr/lib64/python3.10/http/client.py", line 279, in _read_status 71: line = str(self.fp.readline(_MAXLINE + 1), "iso-8859-1") 71: File "/usr/lib64/python3.10/socket.py", line 705, in readinto 71: return self._sock.recv_into(b) 71: TimeoutError: timed out 71: FAILED---------------------------------------- 71: Exception occurred during processing of request from ('127.0.0.1', 34566) 71: Traceback (most recent call last): 71: File "/usr/lib64/python3.10/socketserver.py", line 316, in _handle_request_noblock 71: self.process_request(request, client_address) 71: File "/usr/lib64/python3.10/socketserver.py", line 347, in process_request 71: self.finish_request(request, client_address) 71: File "/usr/lib64/python3.10/socketserver.py", line 360, in finish_request 71: self.RequestHandlerClass(request, client_address, self) 71: File "/usr/lib64/python3.10/socketserver.py", line 747, in __init__ 71: self.handle() 71: File "/usr/lib64/python3.10/http/server.py", line 429, in handle 71: self.handle_one_request() 71: File "/usr/lib64/python3.10/http/server.py", line 415, in handle_one_request 71: method() 71: File "/home/runner/work/qpid-dispatch/qpid-dispatch/qpid-dispatch/tests/http1_tests.py", line 86, in do_PUT 71: self._execute_request(self.server.system_tests["PUT"]) 71: File "/home/runner/work/qpid-dispatch/qpid-dispatch/qpid-dispatch/tests/http1_tests.py", line 58, in _execute_request 71: self._consume_body() 71: File "/home/runner/work/qpid-dispatch/qpid-dispatch/qpid-dispatch/tests/http1_tests.py", line 113, in _consume_body 71: hlen = int(header, base=16) 71: ValueError: invalid literal for int() with base 16: b'' 71: ----------------------------------------
71: =================================== FAILURES =================================== 71: ____________ Http1OverTcpEdge2EdgeTest.test_05_large_streaming_msg _____________ 71: 71: self = <system_tests_http1_over_tcp.Http1OverTcpEdge2EdgeTest testMethod=test_05_large_streaming_msg> 71: 71: def test_05_large_streaming_msg(self): 71: """ 71: Verify large streaming message transfer 71: """ 71: TESTS_11 = { 71: "PUT": [ 71: (RequestMsg("PUT", "/PUT/streaming_test_11", 71: headers={ 71: "Transfer-encoding": "chunked", 71: "Content-Type": "text/plain;charset=utf-8" 71: }, 71: # 4 chunks each ~= 600K 71: body=b'927C1\r\n' + b'0' * 0x927C0 + b'X\r\n' 71: + b'927C0\r\n' + b'1' * 0x927C0 + b'\r\n' 71: + b'927C1\r\n' + b'2' * 0x927C0 + b'X\r\n' 71: + b'927C0\r\n' + b'3' * 0x927C0 + b'\r\n' 71: + b'0\r\n\r\n'), 71: 71: ResponseMsg(201, reason="Created", 71: headers={"Response-Header": "data", 71: "Content-Length": "0"}), 71: ResponseValidator(status=201)) 71: ], 71: 71: "GET": [ 71: (RequestMsg("GET", "/GET/streaming_test_11", 71: headers={"Content-Length": "000"}), 71: ResponseMsg(200, reason="OK", 71: headers={ 71: "transfer-Encoding": "chunked", 71: "Content-Type": "text/plain;charset=utf-8" 71: }, 71: # two 1.2MB chunk 71: body=b'124f80\r\n' + b'4' * 0x124F80 + b'\r\n' 71: + b'124f80\r\n' + b'5' * 0x124F80 + b'\r\n' 71: + b'0\r\n\r\n'), 71: ResponseValidator(status=200)) 71: ], 71: } 71: 71: TESTS_10 = { 71: "POST": [ 71: (RequestMsg("POST", "/POST/streaming_test_10", 71: headers={"Header-1": "H" * 2048, 71: "Content-Length": "2097155", 71: "Content-Type": "text/plain;charset=utf-8"}, 71: body=b'P' * 2097155), 71: ResponseMsg(201, reason="Created", 71: headers={"Response-Header": "data", 71: "Content-Length": "0"}), 71: ResponseValidator(status=201)) 71: ], 71: 71: "GET": [ 71: (RequestMsg("GET", "/GET/streaming_test_10", 71: headers={"Content-Length": "000"}), 71: ResponseMsg(200, reason="OK", 71: headers={"Content-Length": "1999999", 71: "Content-Type": "text/plain;charset=utf-8"}, 71: body=b'G' * 1999999), 71: ResponseValidator(status=200)) 71: ], 71: } 71: server11 = TestServer.new_server(self.http_server11_port, self.http_listener11_port, TESTS_11) 71: self.assertIsNotNone(server11, TEST_SERVER_ERROR % self.http_server11_port) 71: server10 = TestServer.new_server(self.http_server10_port, self.http_listener10_port, TESTS_10, 71: handler_cls=RequestHandler10) 71: self.assertIsNotNone(server10, TEST_SERVER_ERROR % self.http_server10_port) 71: 71: self.EA2.wait_connectors() 71: 71: client11 = ThreadedTestClient(TESTS_11, 71: self.http_listener11_port, 71: repeat=2) 71: client11.wait() 71: self.assertIsNone(client11.error) 71: > self.assertEqual(4, client11.count) 71: E AssertionError: 4 != 2