4.x Intermittent pipeline test failure in SseClientTest.testSseJson1 #10471

Signed-off-by: Jorge Bescos Gascon <[email protected]>

Author: jbescos

webserver/tests/sse/src/test/java/io/helidon/webserver/tests/sse/SseBaseTest.java

@@ -1,5 +1,5 @@
 /*
- * Copyright (c) 2023, 2024 Oracle and/or its affiliates.
+ * Copyright (c) 2023, 2025 Oracle and/or its affiliates.
  *
  * Licensed under the Apache License, Version 2.0 (the "License");
  * you may not use this file except in compliance with the License.
@@ -31,6 +31,7 @@
 
 class SseBaseTest {
 
+    private static final System.Logger LOGGER = System.getLogger(SseBaseTest.class.getName());
     private final WebServer webServer;
 
     SseBaseTest() {
@@ -62,11 +63,14 @@ static void sseString2(ServerRequest req, ServerResponse res) throws Interrupted
     }
 
     static void sseJson1(ServerRequest req, ServerResponse res) {
+        LOGGER.log(System.Logger.Level.ERROR, "sseJson1 called");
         JsonObject json = Json.createObjectBuilder()
                 .add("hello", "world")
                 .build();
         try (SseSink sseSink = res.sink(SseSink.TYPE)) {
+            LOGGER.log(System.Logger.Level.ERROR, "sseJson1 sseSink called");
             sseSink.emit(SseEvent.create(json));
+            LOGGER.log(System.Logger.Level.ERROR, "sseJson1 emit called");
         }
     }
 
@@ -84,10 +88,13 @@ public void setHello(String hello) {
     }
 
     static void sseJson2(ServerRequest req, ServerResponse res) {
+        LOGGER.log(System.Logger.Level.ERROR, "sseJson2 called");
         SseServerTest.HelloWorld json = new SseServerTest.HelloWorld();
         json.setHello("world");
         try (SseSink sseSink = res.sink(SseSink.TYPE)) {
+            LOGGER.log(System.Logger.Level.ERROR, "sseJson2 sseSink called");
             sseSink.emit(SseEvent.create(json));
+            LOGGER.log(System.Logger.Level.ERROR, "sseJson2 emit called");
         }
     }
 

webserver/tests/sse/src/test/java/io/helidon/webserver/tests/sse/SseClientTest.java

@@ -45,6 +45,7 @@
 @Disabled
 class SseClientTest extends SseBaseTest {
 
+    private static final System.Logger LOGGER = System.getLogger(SseClientTest.class.getName());
     private final Http1Client client;
 
     SseClientTest(WebServer webServer, Http1Client client) {
@@ -145,9 +146,12 @@ public void onClose() {
 
     @Test
     void testSseJson1() throws InterruptedException {
+        LOGGER.log(System.Logger.Level.ERROR, "testSseJson1 called");
         try (Http1ClientResponse r = client.get("/sseJson1").header(ACCEPT_EVENT_STREAM).request()) {
+            LOGGER.log(System.Logger.Level.ERROR, "testSseJson1 client called");
             CountDownLatch latch = new CountDownLatch(1);
             r.source(SseSource.TYPE, event -> {
+                LOGGER.log(System.Logger.Level.ERROR, "testSseJson1 source called");
                 JsonObject json = event.data(JsonObject.class);
                 assertThat(json, is(notNullValue()));
                 assertThat(json.getString("hello"), is("world"));
@@ -159,9 +163,12 @@ void testSseJson1() throws InterruptedException {
 
     @Test
     void testSseJson2() throws InterruptedException {
+        LOGGER.log(System.Logger.Level.ERROR, "testSseJson2 called");
         try (Http1ClientResponse r = client.get("/sseJson2").header(ACCEPT_EVENT_STREAM).request()) {
+            LOGGER.log(System.Logger.Level.ERROR, "testSseJson2 client called");
             CountDownLatch latch = new CountDownLatch(1);
             r.source(SseSource.TYPE, event -> {
+                LOGGER.log(System.Logger.Level.ERROR, "testSseJson2 source called");
                 HelloWorld json = event.data(HelloWorld.class, MediaTypes.APPLICATION_JSON);
                 assertThat(json, is(notNullValue()));
                 assertThat(json.getHello(), is("world"));