Debug test

Author: vietj

.github/workflows/ci.yml

@@ -29,4 +29,4 @@ jobs:
           java-version: ${{ inputs.jdk }}
           distribution: temurin
       - name: Run tests
-        run: mvn -s .github/maven-ci-settings.xml -q clean verify -B ${{ inputs.profile }}
+        run: mvn -s .github/maven-ci-settings.xml -q clean verify -B ${{ inputs.profile }} -Dtest=Http2MYRServerTest#testMYRMultiplex -pl vertx-core

vertx-core/src/test/java/io/vertx/tests/http/Http2MYRServerTest.java

@@ -13,10 +13,7 @@
 
 import io.netty.bootstrap.Bootstrap;
 import io.netty.buffer.ByteBuf;
-import io.netty.channel.Channel;
-import io.netty.channel.ChannelFuture;
-import io.netty.channel.ChannelHandlerContext;
-import io.netty.channel.ChannelInitializer;
+import io.netty.channel.*;
 import io.netty.channel.nio.NioEventLoopGroup;
 import io.netty.channel.socket.nio.NioSocketChannel;
 import io.netty.handler.codec.http2.AbstractHttp2ConnectionHandlerBuilder;
@@ -62,6 +59,7 @@ public void testMYR() throws Exception {
     testMYR(false);
   }
 
+  @Repeat(times = 1000)
   @Test
   public void testMYRMultiplex() throws Exception {
     testMYR(true);
@@ -164,6 +162,33 @@ public void onGoAwayRead(ChannelHandlerContext ctx, int lastStreamId, long error
             Builder clientHandlerBuilder = new Builder();
             Http2ConnectionHandler clientHandler = clientHandlerBuilder.build();
             ch.pipeline().addLast(clientHandler);
+            ch.pipeline().addLast(new ChannelDuplexHandler() {
+              @Override
+              public void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) throws Exception {
+                System.out.println("GOT IT!!!!!");
+                System.out.println("GOT IT!!!!!");
+                System.out.println("GOT IT!!!!!");
+                System.out.println("GOT IT!!!!!");
+                System.out.println("GOT IT!!!!!");
+                System.out.println("GOT IT!!!!!");
+                System.out.println("GOT IT!!!!!");
+                System.out.println("GOT IT!!!!!");
+                System.out.println("GOT IT!!!!!");
+                System.out.println("GOT IT!!!!!");
+                System.out.println("GOT IT!!!!!");
+                System.out.println("GOT IT!!!!!");
+                System.out.println("GOT IT!!!!!");
+                System.out.println("GOT IT!!!!!");
+                System.out.println("GOT IT!!!!!");
+                System.out.println("GOT IT!!!!!");
+                System.out.println("GOT IT!!!!!");
+                System.out.println("GOT IT!!!!!");
+                System.out.println("GOT IT!!!!!");
+                System.out.println("GOT IT!!!!!");
+                System.out.println("GOT IT!!!!!");
+                System.out.println("GOT IT!!!!!");
+              }
+            });
           }
         };
       }
@@ -192,7 +217,7 @@ public ChannelFuture connect(int port, String host, BiConsumer<ChannelHandlerCon
       chctx.flush();
     }).sync();
 
-    goAway.get(10, TimeUnit.SECONDS);
+    goAway.get(20, TimeUnit.SECONDS);
 
     // Check the number of rst frame received before getting a go away
     assertEquals(receivedRstFrames.get(), maxRstFramePerWindow + 1);