8211325: test/jdk/java/net/Socket/LingerTest.java fails with cleaning up
authorchegar
Tue, 02 Oct 2018 09:05:07 +0100
changeset 51980 191c2b7d7186
parent 51979 3241975b1830
child 51981 48dec0c13bec
8211325: test/jdk/java/net/Socket/LingerTest.java fails with cleaning up Reviewed-by: dfuchs
test/jdk/ProblemList.txt
test/jdk/java/net/Socket/LingerTest.java
--- a/test/jdk/ProblemList.txt	Tue Oct 02 16:02:35 2018 +0800
+++ b/test/jdk/ProblemList.txt	Tue Oct 02 09:05:07 2018 +0100
@@ -556,8 +556,6 @@
 
 java/net/DatagramSocket/SendDatagramToBadAddress.java           7143960 macosx-all
 
-java/net/Socket/LingerTest.java                                 8208690 generic-all
-
 ############################################################################
 
 # jdk_nio
--- a/test/jdk/java/net/Socket/LingerTest.java	Tue Oct 02 16:02:35 2018 +0800
+++ b/test/jdk/java/net/Socket/LingerTest.java	Tue Oct 02 09:05:07 2018 +0100
@@ -109,38 +109,45 @@
         Socket s2 = ss.accept();
 
         // setup conditions for untransmitted data and lengthy
-            // linger interval
-            s1.setSendBufferSize(128*1024);
+        // linger interval
+        s1.setSendBufferSize(128*1024);
         s1.setSoLinger(true, 30);
         s2.setReceiveBufferSize(1*1024);
 
         // start sender
-            Thread thr = new Thread(new Sender(s1));
-        thr.start();
+        Thread senderThread = new Thread(new Sender(s1));
+        senderThread.start();
 
         // other thread that will connect after 5 seconds.
-            Other other = new Other(ss.getLocalPort(), 5000);
-        thr = new Thread(other);
-        thr.start();
+        Other other = new Other(ss.getLocalPort(), 5000);
+        Thread otherThread = new Thread(other);
+        otherThread.start();
 
         // give sender time to queue the data
-            System.out.println ("Main sleep 1000");
-            Thread.sleep(1000);
-            System.out.println ("Main continue");
+        System.out.println ("Main sleep 1000");
+        Thread.sleep(1000);
+        System.out.println ("Main continue");
 
         // close the socket asynchronously
-            (new Thread(new Closer(s1))).start();
+        Thread closerThread = new Thread(new Closer(s1));
+        closerThread.start();
 
-            System.out.println ("Main sleep 15000");
+        System.out.println ("Main sleep 15000");
         // give other time to run
-            Thread.sleep(15000);
-            System.out.println ("Main closing serversocket");
+        Thread.sleep(15000);
+        System.out.println ("Main closing serversocket");
 
         ss.close();
         // check that other is done
-            if (!other.connected()) {
+        if (!other.connected()) {
             throw new RuntimeException("Other thread is blocked");
         }
+
+        // await termination of all test related threads
+        senderThread.join(60_000);
+        otherThread.join(60_000);
+        closerThread.join(60_000);
+
         System.out.println ("Main ends");
     }
 }