# HG changeset patch
# User bpb
# Date 1527190190 25200
# Node ID 25f93c5406bf3d8005f7b1105ec5da4ad81a042e
# Parent  81d3a2c11535600a9d201033801e52e545deb722
8203766: Add some instrumentation to jdk/java/nio/channels/Selector/RacyDeregister.java
Reviewed-by: alanb

diff -r 81d3a2c11535 -r 25f93c5406bf test/jdk/java/nio/channels/Selector/RacyDeregister.java
--- a/test/jdk/java/nio/channels/Selector/RacyDeregister.java	Thu May 24 14:02:37 2018 -0400
+++ b/test/jdk/java/nio/channels/Selector/RacyDeregister.java	Thu May 24 12:29:50 2018 -0700
@@ -1,5 +1,5 @@
 /*
- * Copyright (c) 2013, 2016, Oracle and/or its affiliates. All rights reserved.
+ * Copyright (c) 2013, 2018, Oracle and/or its affiliates. All rights reserved.
  * DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS FILE HEADER.
  *
  * This code is free software; you can redistribute it and/or modify it
@@ -34,17 +34,24 @@
 
 /*
  * @test
- * @bug 6429204
+ * @bug 6429204 8203766
  * @summary SelectionKey.interestOps does not update interest set on Windows.
  * @author Frank Ding
+ * @run main/timeout=1200 RacyDeregister
  */
 public class RacyDeregister {
 
-    // FIXME: numOuterLoopIterations should be reverted to the hard-coded value
-    // 15 when JDK-8161083 is resolved as either a bug or a non-issue.
-    static final int numOuterLoopIterations =
+    // FIXME: NUM_OUTER_LOOP_ITERATIONS should be reverted to the hard-coded
+    // value 15 when JDK-8161083 is resolved as either a bug or a non-issue.
+    static final int NUM_OUTER_LOOP_ITERATIONS =
         System.getProperty("os.name").startsWith("Windows") ? 150 : 15;
 
+    // 90% of 1200 second timeout as milliseconds
+    static final int TIMEOUT_THRESHOLD_MILLIS = 1200*900;
+
+    // Time at start of main().
+    static long t0;
+
     static boolean notified;
     static final Object selectorLock = new Object();
     static final Object notifyLock = new Object();
@@ -56,6 +63,8 @@
     static volatile Boolean succTermination = null;
 
     public static void main(String[] args) throws Exception {
+        t0 = System.currentTimeMillis();
+
         InetAddress addr = InetAddress.getByName(null);
         ServerSocketChannel sc = ServerSocketChannel.open();
         sc.socket().bind(new InetSocketAddress(addr, 0));
@@ -76,13 +85,12 @@
         final SelectionKey[] key = new SelectionKey[]{
             accepted.register(sel, SelectionKey.OP_READ)};
 
-
         // thread that will be changing key[0].interestOps to OP_READ | OP_WRITE
         new Thread() {
 
             public void run() {
                 try {
-                    for (int k = 0; k < numOuterLoopIterations; k++) {
+                    for (int k = 0; k < NUM_OUTER_LOOP_ITERATIONS; k++) {
                         for (int i = 0; i < 10000; i++) {
                             synchronized (notifyLock) {
                                 synchronized (selectorLock) {
@@ -104,7 +112,7 @@
                                             if (notified) {
                                                 long t =
                                                     System.currentTimeMillis();
-                                                System.out.printf
+                                                System.err.printf
                                                     ("Notified after %d ms%n",
                                                      t - beginTime);
                                                 break;
@@ -118,6 +126,15 @@
                                 }
                             }
                         }
+                        long t = System.currentTimeMillis();
+                        if (t - t0 > TIMEOUT_THRESHOLD_MILLIS) {
+                            System.err.format
+                                ("Timeout after %d outer loop iterations%n", k);
+                            succTermination = false;
+                            // wake up main thread doing select()
+                            sel.wakeup();
+                            return;
+                        }
                     }
                     succTermination = true;
                     // wake up main thread doing select()
@@ -140,7 +157,7 @@
                 sc.close();
                 break;
             } else if (Boolean.FALSE.equals(succTermination)) {
-                System.out.println("Failed to pass the test");
+                System.err.println("Failed to pass the test");
                 sel.close();
                 sc.close();
                 throw new RuntimeException("Failed to pass the test");