Suppressed exceptions during testing.

Signed-off-by: Simone Bordet <simone.bordet@gmail.com>
jetty · Aug 8, 2023 · 6bd067c · 6bd067c
1 parent 9145590
commit 6bd067c
Showing 1 changed file with 44 additions and 40 deletions.
diff --git a/...t-transports/src/test/java/org/eclipse/jetty/test/client/transport/EventsHandlerTest.java b/...t-transports/src/test/java/org/eclipse/jetty/test/client/transport/EventsHandlerTest.java
@@ -28,6 +28,7 @@
 import org.eclipse.jetty.client.StringRequestContent;
 import org.eclipse.jetty.http.HttpFields;
 import org.eclipse.jetty.io.Content;
+import org.eclipse.jetty.logging.StacklessLogging;
 import org.eclipse.jetty.server.Handler;
 import org.eclipse.jetty.server.Request;
 import org.eclipse.jetty.server.Response;
@@ -54,55 +55,58 @@ public class EventsHandlerTest extends AbstractTest
     @MethodSource("transports")
     public void testEventsBufferAndChunkAreReadOnly(Transport transport) throws Exception
     {
-        List<Throwable> onRequestReadExceptions = new CopyOnWriteArrayList<>();
-        List<Throwable> onResponseWriteExceptions = new CopyOnWriteArrayList<>();
-        EventsHandler eventsHandler = new EventsHandler(new EchoHandler())
+        try (StacklessLogging ignored = new StacklessLogging(EventsHandler.class))
         {
-            @Override
-            protected void onRequestRead(Request request, Content.Chunk chunk)
+            List<Throwable> onRequestReadExceptions = new CopyOnWriteArrayList<>();
+            List<Throwable> onResponseWriteExceptions = new CopyOnWriteArrayList<>();
+            EventsHandler eventsHandler = new EventsHandler(new EchoHandler())
             {
-                try
+                @Override
+                protected void onRequestRead(Request request, Content.Chunk chunk)
                 {
-                    if (chunk != null)
+                    try
                     {
-                        chunk.getByteBuffer().put((byte)0);
+                        if (chunk != null)
+                        {
+                            chunk.getByteBuffer().put((byte)0);
+                        }
                     }
+                    catch (ReadOnlyBufferException e)
+                    {
+                        onRequestReadExceptions.add(e);
+                        throw e;
+                    }
+                    if (chunk != null)
+                        chunk.skip(chunk.remaining());
                 }
-                catch (ReadOnlyBufferException e)
-                {
-                    onRequestReadExceptions.add(e);
-                    throw e;
-                }
-                if (chunk != null)
-                    chunk.skip(chunk.remaining());
-            }
 
-            @Override
-            protected void onResponseWrite(Request request, boolean last, ByteBuffer content)
-            {
-                try
-                {
-                    if (content != null)
-                        content.put((byte)0);
-                }
-                catch (ReadOnlyBufferException e)
+                @Override
+                protected void onResponseWrite(Request request, boolean last, ByteBuffer content)
                 {
-                    onResponseWriteExceptions.add(e);
-                    throw e;
+                    try
+                    {
+                        if (content != null)
+                            content.put((byte)0);
+                    }
+                    catch (ReadOnlyBufferException e)
+                    {
+                        onResponseWriteExceptions.add(e);
+                        throw e;
+                    }
                 }
-            }
-        };
-        startServer(transport, eventsHandler);
-        startClient(transport);
-
-        ContentResponse response = client.POST(newURI(transport))
-            .body(new StringRequestContent("ABCDEF"))
-            .send();
-
-        assertThat(response.getStatus(), is(200));
-        assertThat(response.getContentAsString(), is("ABCDEF"));
-        assertThat(onRequestReadExceptions.size(), greaterThan(0));
-        assertThat(onResponseWriteExceptions.size(), greaterThan(0));
+            };
+            startServer(transport, eventsHandler);
+            startClient(transport);
+
+            ContentResponse response = client.POST(newURI(transport))
+                .body(new StringRequestContent("ABCDEF"))
+                .send();
+
+            assertThat(response.getStatus(), is(200));
+            assertThat(response.getContentAsString(), is("ABCDEF"));
+            assertThat(onRequestReadExceptions.size(), greaterThan(0));
+            assertThat(onResponseWriteExceptions.size(), greaterThan(0));
+        }
     }
 
     @ParameterizedTest