Merge branch 'fix/http_async_handler_ci_test_failure_v5.5' into 'release/v5.5'

fix(http_server): Fix CI test failure async_handler (v5.5)

See merge request espressif/esp-idf!42542

Author: mahavirj

examples/protocols/http_server/async_handlers/pytest_http_server_async.py

@@ -22,8 +22,12 @@ def test_http_server_async_handler_multiple_long_requests(dut: Dut) -> None:
     # Parse IP address of Ethernet
     got_ip = dut.expect(r'IPv4 address: (\d+\.\d+\.\d+\.\d+)[^\d]', timeout=30)[1].decode()
     got_port = 80  # Assuming the server is running on port 80
-    logging.info('Got IP   : {}'.format(got_ip))
-    logging.info('Connecting to server at {}:{}'.format(got_ip, got_port))
+    logging.info(f'Got IP   : {got_ip}')
+    dut.expect('starting async req task worker', timeout=30)
+    dut.expect('starting async req task worker', timeout=30)
+    dut.expect(f"Starting server on port: '{got_port}'", timeout=30)
+    dut.expect('Registering URI handlers', timeout=30)
+    logging.info(f'Connecting to server at {got_ip}:{got_port}')
 
     # Create two HTTP connections for long requests
     conn_long1 = http.client.HTTPConnection(got_ip, got_port, timeout=30)
@@ -73,8 +77,12 @@ def test_http_server_async_handler(dut: Dut) -> None:
     # Parse IP address of Ethernet
     got_ip = dut.expect(r'IPv4 address: (\d+\.\d+\.\d+\.\d+)[^\d]', timeout=30)[1].decode()
     got_port = 80  # Assuming the server is running on port 80
-    logging.info('Got IP   : {}'.format(got_ip))
-    logging.info('Connecting to server at {}:{}'.format(got_ip, got_port))
+    logging.info(f'Got IP   : {got_ip}')
+    dut.expect('starting async req task worker', timeout=30)
+    dut.expect('starting async req task worker', timeout=30)
+    dut.expect(f"Starting server on port: '{got_port}'", timeout=30)
+    dut.expect('Registering URI handlers', timeout=30)
+    logging.info(f'Connecting to server at {got_ip}:{got_port}')
 
     # Create HTTP connection
     conn_long = http.client.HTTPConnection(got_ip, got_port, timeout=15)
@@ -102,3 +110,78 @@ def test_http_server_async_handler(dut: Dut) -> None:
         conn_quick.close()
 
     conn_long.close()
+
+
+@pytest.mark.ethernet
+@idf_parametrize('target', ['esp32'], indirect=['target'])
+def test_http_server_async_handler_same_session_sequential(dut: Dut) -> None:
+    """
+    Test that verifies async completion fix:
+    1. Send /long request (async, 60 seconds)
+    2. Wait for completion
+    3. Send another request on same session
+    4. Verify second request works (doesn't get stuck)
+    """
+    # Get binary file
+    binary_file = os.path.join(dut.app.binary_path, 'simple.bin')
+    bin_size = os.path.getsize(binary_file)
+    logging.info(f'http_server_bin_size : {bin_size // 1024}KB')
+    logging.info('Waiting to connect with Ethernet')
+
+    # Parse IP address of Ethernet
+    got_ip = dut.expect(r'IPv4 address: (\d+\.\d+\.\d+\.\d+)[^\d]', timeout=30)[1].decode()
+    got_port = 80  # Assuming the server is running on port 80
+    logging.info(f'Got IP   : {got_ip}')
+    dut.expect('starting async req task worker', timeout=30)
+    dut.expect('starting async req task worker', timeout=30)
+    dut.expect(f"Starting server on port: '{got_port}'", timeout=30)
+    dut.expect('Registering URI handlers', timeout=30)
+    logging.info(f'Connecting to server at {got_ip}:{got_port}')
+
+    # Create HTTP connection for same session testing
+    conn = http.client.HTTPConnection(got_ip, got_port, timeout=70)  # Longer timeout for async
+
+    # Test 1: Send /long request (async, 60 seconds)
+    logging.info('=== Test 1: Sending /long request (async) ===')
+    conn.request('GET', '/long?test=sequential1')
+
+    # Verify request is received and processed
+    dut.expect('uri: /long', timeout=30)
+    dut.expect('Found query string => test=sequential1', timeout=30)
+
+    # Wait for async completion (60 seconds + buffer)
+    logging.info('Waiting for async /long request to complete (60 seconds)...')
+    start_time = time.time()
+
+    # Get response (this will block until async handler completes)
+    response_long = conn.getresponse()
+    completion_time = time.time() - start_time
+
+    logging.info(f'Response status for /long: {response_long.status}')
+    logging.info(f'Async request completed in {completion_time:.2f} seconds')
+    assert response_long.status == 200, 'Failed to access /long URI'
+
+    # Verify we got the full response (should contain 60 ticks)
+    response_data = response_long.read().decode()
+    assert 'req: 1' in response_data, 'Expected request count in response'
+    assert '59' in response_data, 'Expected final tick (59) in response'
+
+    # Test 3: Send another /long request on same session
+    logging.info('=== Test 2: Sending another /long request on same session ===')
+    conn.request('GET', '/long?test=sequential3')
+
+    # Verify third request is processed
+    dut.expect('uri: /long', timeout=30)
+    dut.expect('Found query string => test=sequential3', timeout=30)
+
+    # Get response for third request
+    response_long2 = conn.getresponse()
+    logging.info(f'Response status for second /long: {response_long2.status}')
+    assert response_long2.status == 200, 'Failed to access second /long URI on same session'
+
+    # Verify we got the full response
+    response_data2 = response_long2.read().decode()
+    assert 'req: 2' in response_data2, 'Expected request count 2 in response'
+
+    conn.close()
+    logging.info('=== Test completed successfully: Same session sequential requests work ===')