Fix #10229 EE10 Idle Timeout

Added test that idle works between requests
jetty · Aug 4, 2023 · 3cb3b7a · 3cb3b7a
1 parent fe1aabc
commit 3cb3b7a
Showing 1 changed file with 39 additions and 1 deletion.
diff --git a/jetty-ee10/jetty-ee10-servlet/src/test/java/org/eclipse/jetty/ee10/servlet/ServletTest.java b/jetty-ee10/jetty-ee10-servlet/src/test/java/org/eclipse/jetty/ee10/servlet/ServletTest.java
@@ -28,6 +28,7 @@
 
 import static org.hamcrest.MatcherAssert.assertThat;
 import static org.hamcrest.Matchers.containsString;
+import static org.junit.jupiter.api.Assertions.assertFalse;
 
 public class ServletTest
 {
@@ -79,7 +80,7 @@ protected void doGet(HttpServletRequest req, HttpServletResponse resp) throws Se
     }
 
     @Test
-    public void testSimpleIdle() throws Exception
+    public void testSimpleIdleIgnored() throws Exception
     {
         _context.addServlet(new HttpServlet()
         {
@@ -108,4 +109,41 @@ protected void doGet(HttpServletRequest req, HttpServletResponse resp) throws Se
         assertThat(response, containsString(" 200 OK"));
         assertThat(response, containsString("Hello!"));
     }
+
+    @Test
+    public void testIdle() throws Exception
+    {
+        _context.addServlet(new HttpServlet()
+        {
+            @Override
+            protected void doGet(HttpServletRequest req, HttpServletResponse resp) throws ServletException, IOException
+            {
+                resp.getWriter().println("Hello!");
+            }
+        }, "/get");
+
+        _connector.setIdleTimeout(250);
+        _server.start();
+
+        try (LocalConnector.LocalEndPoint endPoint = _connector.connect())
+        {
+            String request = """
+                GET /ctx/get HTTP/1.1
+                Host: local
+                            
+                """;
+            endPoint.addInput(request);
+            String response = endPoint.getResponse();
+            assertThat(response, containsString(" 200 OK"));
+            assertThat(response, containsString("Hello!"));
+            endPoint.addInput(request);
+            response = endPoint.getResponse();
+            assertThat(response, containsString(" 200 OK"));
+            assertThat(response, containsString("Hello!"));
+
+            Thread.sleep(500);
+
+            assertFalse(endPoint.isOpen());
+        }
+    }
 }