[ https://issues.apache.org/jira/browse/DISPATCH-2303?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Ganesh Murthy resolved DISPATCH-2303. ------------------------------------- Fix Version/s: 1.19.0 Resolution: Cannot Reproduce > system_tests_http1_over_tcp > Http1OverTcpEdge2EdgeTest::test_05_large_streaming_msg failure: invalid > literal for int() with base 16: b'' > --------------------------------------------------------------------------------------------------------------------------------------- > > Key: DISPATCH-2303 > URL: https://issues.apache.org/jira/browse/DISPATCH-2303 > Project: Qpid Dispatch > Issue Type: Test > Components: Tests > Affects Versions: 1.19.0 > Reporter: Jiri Daněk > Assignee: Ken Giusti > Priority: Minor > Fix For: 1.19.0 > > > https://github.com/apache/qpid-dispatch/runs/4703076932?check_suite_focus=true#step:27:5543 > {noformat} > 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: ---------------------------------------- > {noformat} > {noformat} > 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 > {noformat} -- This message was sent by Atlassian Jira (v8.20.1#820001) --------------------------------------------------------------------- To unsubscribe, e-mail: dev-unsubscr...@qpid.apache.org For additional commands, e-mail: dev-h...@qpid.apache.org