Mercurial > jdk8-mips64-public > hotspot / file revision

 /*

  * Copyright (c) 1997, 2010, 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

  * 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 Oracle, 500 Oracle Parkway, Redwood Shores, CA 94065 USA

  * or visit www.oracle.com if you need additional information or have any

  * questions.

  *

  */

 #include "precompiled.hpp"

 #include "classfile/symbolTable.hpp"

 #include "classfile/vmSymbols.hpp"

 #include "compiler/compileBroker.hpp"

 #include "compiler/compilerOracle.hpp"

 #include "gc_implementation/shared/isGCActiveMark.hpp"

 #include "memory/resourceArea.hpp"

 #include "oops/symbol.hpp"

 #include "runtime/arguments.hpp"

 #include "runtime/deoptimization.hpp"

 #include "runtime/interfaceSupport.hpp"

 #include "runtime/sweeper.hpp"

 #include "runtime/vm_operations.hpp"

 #include "services/threadService.hpp"

 #ifdef TARGET_OS_FAMILY_linux

 # include "thread_linux.inline.hpp"

 #endif

 #ifdef TARGET_OS_FAMILY_solaris

 # include "thread_solaris.inline.hpp"

 #endif

 #ifdef TARGET_OS_FAMILY_windows

 # include "thread_windows.inline.hpp"

 #endif

 #define VM_OP_NAME_INITIALIZE(name) #name,

 const char* VM_Operation::_names[VM_Operation::VMOp_Terminating] = \

   { VM_OPS_DO(VM_OP_NAME_INITIALIZE) };

 void VM_Operation::set_calling_thread(Thread* thread, ThreadPriority priority) {

   _calling_thread = thread;

   assert(MinPriority <= priority && priority <= MaxPriority, "sanity check");

   _priority = priority;

 }

 void VM_Operation::evaluate() {

   ResourceMark rm;

   if (TraceVMOperation) {

     tty->print("[");

     NOT_PRODUCT(print();)

   }

   doit();

   if (TraceVMOperation) {

     tty->print_cr("]");

   }

 }

 // Called by fatal error handler.

 void VM_Operation::print_on_error(outputStream* st) const {

   st->print("VM_Operation (" PTR_FORMAT "): ", this);

   st->print("%s", name());

   const char* mode;

   switch(evaluation_mode()) {

     case _safepoint      : mode = "safepoint";       break;

     case _no_safepoint   : mode = "no safepoint";    break;

     case _concurrent     : mode = "concurrent";      break;

     case _async_safepoint: mode = "async safepoint"; break;

     default              : mode = "unknown";         break;

   }

   st->print(", mode: %s", mode);

   if (calling_thread()) {

     st->print(", requested by thread " PTR_FORMAT, calling_thread());

   }

 }

 void VM_ThreadStop::doit() {

   assert(SafepointSynchronize::is_at_safepoint(), "must be at a safepoint");

   JavaThread* target = java_lang_Thread::thread(target_thread());

   // Note that this now allows multiple ThreadDeath exceptions to be

   // thrown at a thread.

   if (target != NULL) {

     // the thread has run and is not already in the process of exiting

     target->send_thread_stop(throwable());

   }

 }

 void VM_Deoptimize::doit() {

   // We do not want any GCs to happen while we are in the middle of this VM operation

   ResourceMark rm;

   DeoptimizationMarker dm;

   // Deoptimize all activations depending on marked nmethods

   Deoptimization::deoptimize_dependents();

   // Make the dependent methods zombies

   CodeCache::make_marked_nmethods_zombies();

 }

 VM_DeoptimizeFrame::VM_DeoptimizeFrame(JavaThread* thread, intptr_t* id) {

   _thread = thread;

   _id     = id;

 }

 void VM_DeoptimizeFrame::doit() {

   Deoptimization::deoptimize_frame_internal(_thread, _id);

 }

 #ifndef PRODUCT

 void VM_DeoptimizeAll::doit() {

   DeoptimizationMarker dm;

   // deoptimize all java threads in the system

   if (DeoptimizeALot) {

     for (JavaThread* thread = Threads::first(); thread != NULL; thread = thread->next()) {

       if (thread->has_last_Java_frame()) {

         thread->deoptimize();

       }

     }

   } else if (DeoptimizeRandom) {

     // Deoptimize some selected threads and frames

     int tnum = os::random() & 0x3;

     int fnum =  os::random() & 0x3;

     int tcount = 0;

     for (JavaThread* thread = Threads::first(); thread != NULL; thread = thread->next()) {

       if (thread->has_last_Java_frame()) {

         if (tcount++ == tnum)  {

         tcount = 0;

           int fcount = 0;

           // Deoptimize some selected frames.

           // Biased llocking wants a updated register map

           for(StackFrameStream fst(thread, UseBiasedLocking); !fst.is_done(); fst.next()) {

             if (fst.current()->can_be_deoptimized()) {

               if (fcount++ == fnum) {

                 fcount = 0;

                 Deoptimization::deoptimize(thread, *fst.current(), fst.register_map());

               }

             }

           }

         }

       }

     }

   }

 }

 void VM_ZombieAll::doit() {

   JavaThread *thread = (JavaThread *)calling_thread();

   assert(thread->is_Java_thread(), "must be a Java thread");

   thread->make_zombies();

 }

 #endif // !PRODUCT

 void VM_UnlinkSymbols::doit() {

   JavaThread *thread = (JavaThread *)calling_thread();

   assert(thread->is_Java_thread(), "must be a Java thread");

   SymbolTable::unlink();

 }

 void VM_HandleFullCodeCache::doit() {

   NMethodSweeper::speculative_disconnect_nmethods(_is_full);

 }

 void VM_Verify::doit() {

   Universe::verify();

 }

 bool VM_PrintThreads::doit_prologue() {

   assert(Thread::current()->is_Java_thread(), "just checking");

   // Make sure AbstractOwnableSynchronizer is loaded

   if (JDK_Version::is_gte_jdk16x_version()) {

     java_util_concurrent_locks_AbstractOwnableSynchronizer::initialize(JavaThread::current());

   }

   // Get Heap_lock if concurrent locks will be dumped

   if (_print_concurrent_locks) {

     Heap_lock->lock();

   }

   return true;

 }

 void VM_PrintThreads::doit() {

   Threads::print_on(_out, true, false, _print_concurrent_locks);

 }

 void VM_PrintThreads::doit_epilogue() {

   if (_print_concurrent_locks) {

     // Release Heap_lock

     Heap_lock->unlock();

   }

 }

 void VM_PrintJNI::doit() {

   JNIHandles::print_on(_out);

 }

 VM_FindDeadlocks::~VM_FindDeadlocks() {

   if (_deadlocks != NULL) {

     DeadlockCycle* cycle = _deadlocks;

     while (cycle != NULL) {

       DeadlockCycle* d = cycle;

       cycle = cycle->next();

       delete d;

     }

   }

 }

 bool VM_FindDeadlocks::doit_prologue() {

   assert(Thread::current()->is_Java_thread(), "just checking");

   // Load AbstractOwnableSynchronizer class

   if (_concurrent_locks && JDK_Version::is_gte_jdk16x_version()) {

     java_util_concurrent_locks_AbstractOwnableSynchronizer::initialize(JavaThread::current());

   }

   return true;

 }

 void VM_FindDeadlocks::doit() {

   _deadlocks = ThreadService::find_deadlocks_at_safepoint(_concurrent_locks);

   if (_out != NULL) {

     int num_deadlocks = 0;

     for (DeadlockCycle* cycle = _deadlocks; cycle != NULL; cycle = cycle->next()) {

       num_deadlocks++;

       cycle->print_on(_out);

     }

     if (num_deadlocks == 1) {

       _out->print_cr("\nFound 1 deadlock.\n");

       _out->flush();

     } else if (num_deadlocks > 1) {

       _out->print_cr("\nFound %d deadlocks.\n", num_deadlocks);

       _out->flush();

     }

   }

 }

 VM_ThreadDump::VM_ThreadDump(ThreadDumpResult* result,

                              int max_depth,

                              bool with_locked_monitors,

                              bool with_locked_synchronizers) {

   _result = result;

   _num_threads = 0; // 0 indicates all threads

   _threads = NULL;

   _result = result;

   _max_depth = max_depth;

   _with_locked_monitors = with_locked_monitors;

   _with_locked_synchronizers = with_locked_synchronizers;

 }

 VM_ThreadDump::VM_ThreadDump(ThreadDumpResult* result,

                              GrowableArray<instanceHandle>* threads,

                              int num_threads,

                              int max_depth,

                              bool with_locked_monitors,

                              bool with_locked_synchronizers) {

   _result = result;

   _num_threads = num_threads;

   _threads = threads;

   _result = result;

   _max_depth = max_depth;

   _with_locked_monitors = with_locked_monitors;

   _with_locked_synchronizers = with_locked_synchronizers;

 }

 bool VM_ThreadDump::doit_prologue() {

   assert(Thread::current()->is_Java_thread(), "just checking");

   // Load AbstractOwnableSynchronizer class before taking thread snapshots

   if (JDK_Version::is_gte_jdk16x_version()) {

     java_util_concurrent_locks_AbstractOwnableSynchronizer::initialize(JavaThread::current());

   }

   if (_with_locked_synchronizers) {

     // Acquire Heap_lock to dump concurrent locks

     Heap_lock->lock();

   }

   return true;

 }

 void VM_ThreadDump::doit_epilogue() {

   if (_with_locked_synchronizers) {

     // Release Heap_lock

     Heap_lock->unlock();

   }

 }

 void VM_ThreadDump::doit() {

   ResourceMark rm;

   ConcurrentLocksDump concurrent_locks(true);

   if (_with_locked_synchronizers) {

     concurrent_locks.dump_at_safepoint();

   }

   if (_num_threads == 0) {

     // Snapshot all live threads

     for (JavaThread* jt = Threads::first(); jt != NULL; jt = jt->next()) {

       if (jt->is_exiting() ||

           jt->is_hidden_from_external_view())  {

         // skip terminating threads and hidden threads

         continue;

       }

       ThreadConcurrentLocks* tcl = NULL;

       if (_with_locked_synchronizers) {

         tcl = concurrent_locks.thread_concurrent_locks(jt);

       }

       ThreadSnapshot* ts = snapshot_thread(jt, tcl);

       _result->add_thread_snapshot(ts);

     }

   } else {

     // Snapshot threads in the given _threads array

     // A dummy snapshot is created if a thread doesn't exist

     for (int i = 0; i < _num_threads; i++) {

       instanceHandle th = _threads->at(i);

       if (th() == NULL) {

         // skip if the thread doesn't exist

         // Add a dummy snapshot

         _result->add_thread_snapshot(new ThreadSnapshot());

         continue;

       }

       // Dump thread stack only if the thread is alive and not exiting

       // and not VM internal thread.

       JavaThread* jt = java_lang_Thread::thread(th());

       if (jt == NULL || /* thread not alive */

           jt->is_exiting() ||

           jt->is_hidden_from_external_view())  {

         // add a NULL snapshot if skipped

         _result->add_thread_snapshot(new ThreadSnapshot());

         continue;

       }

       ThreadConcurrentLocks* tcl = NULL;

       if (_with_locked_synchronizers) {

         tcl = concurrent_locks.thread_concurrent_locks(jt);

       }

       ThreadSnapshot* ts = snapshot_thread(jt, tcl);

       _result->add_thread_snapshot(ts);

     }

   }

 }

 ThreadSnapshot* VM_ThreadDump::snapshot_thread(JavaThread* java_thread, ThreadConcurrentLocks* tcl) {

   ThreadSnapshot* snapshot = new ThreadSnapshot(java_thread);

   snapshot->dump_stack_at_safepoint(_max_depth, _with_locked_monitors);

   snapshot->set_concurrent_locks(tcl);

   return snapshot;

 }

 volatile bool VM_Exit::_vm_exited = false;

 Thread * VM_Exit::_shutdown_thread = NULL;

 int VM_Exit::set_vm_exited() {

   Thread * thr_cur = ThreadLocalStorage::get_thread_slow();

   assert(SafepointSynchronize::is_at_safepoint(), "must be at safepoint already");

   int num_active = 0;

   _shutdown_thread = thr_cur;

   _vm_exited = true;                                // global flag

   for(JavaThread *thr = Threads::first(); thr != NULL; thr = thr->next())

     if (thr!=thr_cur && thr->thread_state() == _thread_in_native) {

       ++num_active;

       thr->set_terminated(JavaThread::_vm_exited);  // per-thread flag

     }

   return num_active;

 }

 int VM_Exit::wait_for_threads_in_native_to_block() {

   // VM exits at safepoint. This function must be called at the final safepoint

   // to wait for threads in _thread_in_native state to be quiescent.

   assert(SafepointSynchronize::is_at_safepoint(), "must be at safepoint already");

   Thread * thr_cur = ThreadLocalStorage::get_thread_slow();

   Monitor timer(Mutex::leaf, "VM_Exit timer", true);

   // Compiler threads need longer wait because they can access VM data directly

   // while in native. If they are active and some structures being used are

   // deleted by the shutdown sequence, they will crash. On the other hand, user

   // threads must go through native=>Java/VM transitions first to access VM

   // data, and they will be stopped during state transition. In theory, we

   // don't have to wait for user threads to be quiescent, but it's always

   // better to terminate VM when current thread is the only active thread, so

   // wait for user threads too. Numbers are in 10 milliseconds.

   int max_wait_user_thread = 30;                  // at least 300 milliseconds

   int max_wait_compiler_thread = 1000;            // at least 10 seconds

   int max_wait = max_wait_compiler_thread;

   int attempts = 0;

   while (true) {

     int num_active = 0;

     int num_active_compiler_thread = 0;

     for(JavaThread *thr = Threads::first(); thr != NULL; thr = thr->next()) {

       if (thr!=thr_cur && thr->thread_state() == _thread_in_native) {

         num_active++;

         if (thr->is_Compiler_thread()) {

           num_active_compiler_thread++;

         }

       }

     }

     if (num_active == 0) {

        return 0;

     } else if (attempts > max_wait) {

        return num_active;

     } else if (num_active_compiler_thread == 0 && attempts > max_wait_user_thread) {

        return num_active;

     }

     attempts++;

     MutexLockerEx ml(&timer, Mutex::_no_safepoint_check_flag);

     timer.wait(Mutex::_no_safepoint_check_flag, 10);

   }

 }

 void VM_Exit::doit() {

   CompileBroker::set_should_block();

   // Wait for a short period for threads in native to block. Any thread

   // still executing native code after the wait will be stopped at

   // native==>Java/VM barriers.

   // Among 16276 JCK tests, 94% of them come here without any threads still

   // running in native; the other 6% are quiescent within 250ms (Ultra 80).

   wait_for_threads_in_native_to_block();

   set_vm_exited();

   // cleanup globals resources before exiting. exit_globals() currently

   // cleans up outputStream resources and PerfMemory resources.

   exit_globals();

   // Check for exit hook

   exit_hook_t exit_hook = Arguments::exit_hook();

   if (exit_hook != NULL) {

     // exit hook should exit.

     exit_hook(_exit_code);

     // ... but if it didn't, we must do it here

     vm_direct_exit(_exit_code);

   } else {

     vm_direct_exit(_exit_code);

   }

 }

 void VM_Exit::wait_if_vm_exited() {

   if (_vm_exited &&

       ThreadLocalStorage::get_thread_slow() != _shutdown_thread) {

     // _vm_exited is set at safepoint, and the Threads_lock is never released

     // we will block here until the process dies

     Threads_lock->lock_without_safepoint_check();

     ShouldNotReachHere();

   }

 }