6772683: Thread.isInterrupted() fails to return true on multiprocessor PC

Summary: Set the control edge for the field _interrupted load in inline_native_isInterrupted().
Reviewed-by: never

src/share/vm/opto/library_call.cpp

@@ -2593,7 +2593,8 @@ bool LibraryCallKit::inline_native_isInterrupted() {
   Node* p = basic_plus_adr(top()/*!oop*/, tls_ptr, in_bytes(JavaThread::osthread_offset()));
   Node* osthread = make_load(NULL, p, TypeRawPtr::NOTNULL, T_ADDRESS);
   p = basic_plus_adr(top()/*!oop*/, osthread, in_bytes(OSThread::interrupted_offset()));
-  Node* int_bit = make_load(NULL, p, TypeInt::BOOL, T_INT);
+  // Set the control input on the field _interrupted read to prevent it floating up.
+  Node* int_bit = make_load(control(), p, TypeInt::BOOL, T_INT);
   Node* cmp_bit = _gvn.transform( new (C, 3) CmpINode(int_bit, intcon(0)) );
   Node* bol_bit = _gvn.transform( new (C, 2) BoolNode(cmp_bit, BoolTest::ne) );
 

test/compiler/6772683/InterruptedTest.java

+/*
+ * Copyright 2008 Sun Microsystems, Inc.  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
+ * under the terms of the GNU General Public License version 2 only, as
+ * published by the Free Software Foundation.
+ *
+ * This code is distributed in the hope that it will be useful, but WITHOUT
+ * ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or
+ * FITNESS FOR A PARTICULAR PURPOSE.  See the GNU General Public License
+ * version 2 for more details (a copy is included in the LICENSE file that
+ * accompanied this code).
+ *
+ * You should have received a copy of the GNU General Public License version
+ * 2 along with this work; if not, write to the Free Software Foundation,
+ * Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA.
+ *
+ * Please contact Sun Microsystems, Inc., 4150 Network Circle, Santa Clara,
+ * CA 95054 USA or visit www.sun.com if you need additional information or
+ * have any questions.
+ *
+ */
+
+/*
+ * @test
+ * @bug 6772683
+ * @summary Thread.isInterrupted() fails to return true on multiprocessor PC
+ * @run main/othervm InterruptedTest
+ */
+
+public class InterruptedTest {
+
+    public static void main(String[] args) throws Exception {
+        Thread workerThread = new Thread("worker") {
+            public void run() {
+                System.out.println("Worker thread: running...");
+                while (!Thread.currentThread().isInterrupted()) {
+                }
+                System.out.println("Worker thread: bye");
+            }
+        };
+        System.out.println("Main thread: starts a worker thread...");
+        workerThread.start();
+        System.out.println("Main thread: waits at most 5s for the worker thread to die...");
+        workerThread.join(5000); // Wait 5 sec to let run() method to be compiled
+        int ntries = 0;
+        while (workerThread.isAlive() && ntries < 5) {
+            System.out.println("Main thread: interrupts the worker thread...");
+            workerThread.interrupt();
+            if (workerThread.isInterrupted()) {
+                System.out.println("Main thread: worker thread is interrupted");
+            }
+            ntries++;
+            System.out.println("Main thread: waits for the worker thread to die...");
+            workerThread.join(1000); // Wait 1 sec and try again
+        }
+        if (ntries == 5) {
+          System.out.println("Main thread: the worker thread dod not die");
+          System.exit(97);
+        }
+        System.out.println("Main thread: bye");
+    }
+
+}