8362836: JFR: Broken pipe in jdk/jfr/event/io/TestIOTopFrame.java

Backport-of: 1b94a3466e7bb3815c0caeeeebff6018b6440455

Author: egahlin

test/jdk/jdk/jfr/event/io/TestIOTopFrame.java

@@ -52,6 +52,7 @@
 import java.util.Map;
 import java.util.TreeMap;
 import java.util.concurrent.Callable;
+import java.util.concurrent.CountDownLatch;
 import java.util.concurrent.ExecutorService;
 import java.util.concurrent.Executors;
 
@@ -246,22 +247,25 @@ private static void testSocketChannels() throws Exception {
                 r.enable(EVENT_SOCKET_READ).withStackTrace();
                 r.enable(EVENT_SOCKET_WRITE).withStackTrace();
                 r.start();
-                Thread readerThread = Thread.ofPlatform().start(() -> readSocketChannel(ssc));
+                CountDownLatch latch = new CountDownLatch(1);
+                Thread readerThread = Thread.ofPlatform().start(() -> readSocketChannel(ssc, latch));
                 writeSocketChannel(ssc);
+                latch.countDown();
                 readerThread.join();
                 r.stop();
                 assertTopFrames(r, "readSocket", 6, "readSocketChannel", 2, "writeSocket", 3, "writeSocketChannel", 2);
             }
         }
     }
 
-    private static void readSocketChannel(ServerSocketChannel ssc) {
+    private static void readSocketChannel(ServerSocketChannel ssc, CountDownLatch latch) {
         ByteBuffer[] buffers = createBuffers();
         try (SocketChannel sc = ssc.accept()) {
             sc.read(buffers[0]); // 1
             sc.read(buffers); // 2
             try (InputStream is = sc.socket().getInputStream()) {
                 readSocket(is);
+                latch.await();
             }
         } catch (Exception ioe) {
             throw new RuntimeException(ioe);