Send a message on startup, increase the timeout, and stop sending later calls

This is a followup to the original bug report to emphasize that Jetty 12
is failing to notify the servlet and its listeners that the client is
definitely gone. Further, it calls out that 12+ee10 does not notify on
timeouts.

Author: niloc132

jetty-11/src/main/java/com/example/jetty11/Server.java

@@ -33,15 +33,15 @@ public static void main(String[] args) throws Exception {
         context.addServlet(new ServletHolder(servlet), "/connect");
         s.setHandler(context);
 
-        ScheduledExecutorService executorService = Executors.newSingleThreadScheduledExecutor();
-        executorService.scheduleAtFixedRate(() -> {
-            try {
-                servlet.sayHi();
-            } catch (Exception e) {
-                // log and continue
-                LOG.warn("Error writing in exec service", e);
-            }
-        }, 1, 1, TimeUnit.SECONDS);
+//        ScheduledExecutorService executorService = Executors.newSingleThreadScheduledExecutor();
+//        executorService.scheduleAtFixedRate(() -> {
+//            try {
+//                servlet.sayHi();
+//            } catch (Exception e) {
+//                // log and continue
+//                LOG.warn("Error writing in exec service", e);
+//            }
+//        }, 1, 1, TimeUnit.SECONDS);
 
         s.start();
         s.join();

jetty-12/ee10/src/main/java/com/example/jetty12/ee10/Server.java

@@ -33,15 +33,15 @@ public static void main(String[] args) throws Exception {
         context.addServlet(new ServletHolder(servlet), "/connect");
         s.setHandler(context);
 
-        ScheduledExecutorService executorService = Executors.newSingleThreadScheduledExecutor();
-        executorService.scheduleAtFixedRate(() -> {
-            try {
-                servlet.sayHi();
-            } catch (Exception e) {
-                // log and continue
-                LOG.warn("Error writing in exec service", e);
-            }
-        }, 1, 1, TimeUnit.SECONDS);
+//        ScheduledExecutorService executorService = Executors.newSingleThreadScheduledExecutor();
+//        executorService.scheduleAtFixedRate(() -> {
+//            try {
+//                servlet.sayHi();
+//            } catch (Exception e) {
+//                // log and continue
+//                LOG.warn("Error writing in exec service", e);
+//            }
+//        }, 1, 1, TimeUnit.SECONDS);
 
         s.start();
         s.join();

jetty-12/ee9/src/main/java/com/example/jetty12/ee9/Server.java

@@ -33,15 +33,15 @@ public static void main(String[] args) throws Exception {
         context.addServlet(new ServletHolder(servlet), "/connect");
         s.setHandler(context);
 
-        ScheduledExecutorService executorService = Executors.newSingleThreadScheduledExecutor();
-        executorService.scheduleAtFixedRate(() -> {
-            try {
-                servlet.sayHi();
-            } catch (Exception e) {
-                // log and continue
-                LOG.warn("Error writing in exec service", e);
-            }
-        }, 1, 1, TimeUnit.SECONDS);
+//        ScheduledExecutorService executorService = Executors.newSingleThreadScheduledExecutor();
+//        executorService.scheduleAtFixedRate(() -> {
+//            try {
+//                servlet.sayHi();
+//            } catch (Exception e) {
+//                // log and continue
+//                LOG.warn("Error writing in exec service", e);
+//            }
+//        }, 1, 1, TimeUnit.SECONDS);
 
         s.start();
         s.join();

servlet/src/main/java/com/example/servlet/AsyncStreamingServlet.java

@@ -127,13 +127,14 @@ protected void doPost(HttpServletRequest req, HttpServletResponse resp) throws S
     @Override
     protected void doGet(HttpServletRequest req, HttpServletResponse resp) throws ServletException, IOException {
         AsyncContext asyncCtx = req.startAsync(req, resp);
-        asyncCtx.setTimeout(10_000);
+        asyncCtx.setTimeout(100_000);
 
         final int id = nextId.getAndIncrement();
 
         LOG.info("New request #" + id);
 
         ClientConnection c = new ClientConnection(id, asyncCtx);
+        c.println("startup");
         connections.add(c);
     }