Uploaded image for project: 'Qpid Dispatch'
  1. Qpid Dispatch
  2. DISPATCH-2303

system_tests_http1_over_tcp Http1OverTcpEdge2EdgeTest::test_05_large_streaming_msg failure: invalid literal for int() with base 16: b''

Attach filesAttach ScreenshotVotersWatch issueWatchersCreate sub-taskLinkCloneUpdate Comment AuthorReplace String in CommentUpdate Comment VisibilityDelete Comments
    XMLWordPrintableJSON

Details

    • Test
    • Status: Closed
    • Minor
    • Resolution: Cannot Reproduce
    • 1.19.0
    • 1.19.0
    • Tests
    • None

    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
      

      Attachments

        Activity

          This comment will be Viewable by All Users Viewable by All Users
          Cancel

          People

            kgiusti Ken Giusti
            jdanek Jiri Daněk
            Votes:
            0 Vote for this issue
            Watchers:
            2 Start watching this issue

            Dates

              Created:
              Updated:
              Resolved:

              Slack

                Issue deployment