src/hotspot/share/runtime/thread.inline.hpp

rev 47794 : Port 09.17.Thread_SMR_logging_update from JDK9 to JDK10
rev 47795 : sspitsyn, dcubed, eosterlund CR - minor changes prior to OpenJDK review.
rev 47796 : eosterlund, stefank CR - refactor code into threadSMR.cpp and threadSMR.hpp
rev 47797 : eosterlund CR - need more inline fixes.
rev 47798 : eosterlund, stefank CR - more inline and style cleanups
rev 47800 : Rebase to 2017.10.25 PIT snapshot.

*** 23,40 ****
   */
  
  #ifndef SHARE_VM_RUNTIME_THREAD_INLINE_HPP
  #define SHARE_VM_RUNTIME_THREAD_INLINE_HPP
  
- #define SHARE_VM_RUNTIME_THREAD_INLINE_HPP_SCOPE
- 
  #include "runtime/atomic.hpp"
  #include "runtime/os.inline.hpp"
  #include "runtime/thread.hpp"
  
- #undef SHARE_VM_RUNTIME_THREAD_INLINE_HPP_SCOPE
- 
  inline void Thread::set_suspend_flag(SuspendFlags f) {
    assert(sizeof(jint) == sizeof(_suspend_flags), "size mismatch");
    uint32_t flags;
    do {
      flags = _suspend_flags;
--- 23,37 ----
   */
  
  #ifndef SHARE_VM_RUNTIME_THREAD_INLINE_HPP
  #define SHARE_VM_RUNTIME_THREAD_INLINE_HPP
  
  #include "runtime/atomic.hpp"
  #include "runtime/os.inline.hpp"
  #include "runtime/thread.hpp"
+ #include "runtime/threadSMR.hpp"
  
  inline void Thread::set_suspend_flag(SuspendFlags f) {
    assert(sizeof(jint) == sizeof(_suspend_flags), "size mismatch");
    uint32_t flags;
    do {
      flags = _suspend_flags;
*** 87,96 ****
--- 84,105 ----
      }
    }
    return allocated_bytes;
  }
  
+ inline ThreadsList* Thread::cmpxchg_threads_hazard_ptr(ThreadsList* exchange_value, ThreadsList* compare_value) {
+   return (ThreadsList*)Atomic::cmpxchg(exchange_value, &_threads_hazard_ptr, compare_value);
+ }
+ 
+ inline ThreadsList* Thread::get_threads_hazard_ptr() {
+   return (ThreadsList*)OrderAccess::load_acquire(&_threads_hazard_ptr);
+ }
+ 
+ inline void Thread::set_threads_hazard_ptr(ThreadsList* new_list) {
+   OrderAccess::release_store_fence(&_threads_hazard_ptr, new_list);
+ }
+ 
  inline void JavaThread::set_ext_suspended() {
    set_suspend_flag (_ext_suspended);
  }
  inline void JavaThread::clear_ext_suspended() {
    clear_suspend_flag(_ext_suspended);
*** 161,166 ****
--- 170,260 ----
    }
  #endif
    return _stack_guard_state == stack_guard_enabled;
  }
  
+ inline bool JavaThread::is_exiting() const {
+   // Use load-acquire so that setting of _terminated by
+   // JavaThread::exit() is seen more quickly.
+   TerminatedTypes l_terminated = (TerminatedTypes)
+       OrderAccess::load_acquire((volatile jint *) &_terminated);
+   return l_terminated == _thread_exiting || check_is_terminated(l_terminated);
+ }
+ 
+ inline bool JavaThread::is_terminated() {
+   // Use load-acquire so that setting of _terminated by
+   // JavaThread::exit() is seen more quickly.
+   TerminatedTypes l_terminated = (TerminatedTypes)
+       OrderAccess::load_acquire((volatile jint *) &_terminated);
+   return check_is_terminated(_terminated);
+ }
+ 
+ inline void JavaThread::set_terminated(TerminatedTypes t) {
+   // use release-store so the setting of _terminated is seen more quickly
+   OrderAccess::release_store((volatile jint *) &_terminated, (jint) t);
+ }
+ 
+ // special for Threads::remove() which is static:
+ inline void JavaThread::set_terminated_value() {
+   // use release-store so the setting of _terminated is seen more quickly
+   OrderAccess::release_store((volatile jint *) &_terminated, (jint) _thread_terminated);
+ }
+ 
+ template <class T>
+ inline void Threads::threads_do_smr(T *tc, Thread *self) {
+   ThreadsListHandle handle(self);
+   handle.threads_do(tc);
+ }
+ 
+ inline ThreadsList* Threads::get_smr_java_thread_list() {
+   return (ThreadsList*)OrderAccess::load_acquire(&_smr_java_thread_list);
+ }
+ 
+ inline ThreadsList* Threads::xchg_smr_java_thread_list(ThreadsList* new_list) {
+   return (ThreadsList*)Atomic::xchg(new_list, &_smr_java_thread_list);
+ }
+ 
+ inline void Threads::inc_smr_deleted_thread_cnt() {
+   Atomic::inc(&_smr_deleted_thread_cnt);
+ }
+ 
+ inline void Threads::update_smr_deleted_thread_time_max(jint new_value) {
+   while (true) {
+     jint cur_value = _smr_deleted_thread_time_max;
+     if (new_value <= cur_value) {
+       // No need to update max value so we're done.
+       break;
+     }
+     if (Atomic::cmpxchg(new_value, &_smr_deleted_thread_time_max, cur_value) == cur_value) {
+       // Updated max value so we're done. Otherwise try it all again.
+       break;
+     }
+   }
+ }
+ 
+ inline void Threads::add_smr_deleted_thread_times(jint add_value) {
+   Atomic::add(add_value, &_smr_deleted_thread_times);
+ }
+ 
+ inline void Threads::inc_smr_tlh_cnt() {
+   Atomic::inc(&_smr_tlh_cnt);
+ }
+ 
+ inline void Threads::update_smr_tlh_time_max(jint new_value) {
+   while (true) {
+     jint cur_value = _smr_tlh_time_max;
+     if (new_value <= cur_value) {
+       // No need to update max value so we're done.
+       break;
+     }
+     if (Atomic::cmpxchg(new_value, &_smr_tlh_time_max, cur_value) == cur_value) {
+       // Updated max value so we're done. Otherwise try it all again.
+       break;
+     }
+   }
+ }
+ 
+ inline void Threads::add_smr_tlh_times(jint add_value) {
+   Atomic::add(add_value, &_smr_tlh_times);
+ }
+ 
  #endif // SHARE_VM_RUNTIME_THREAD_INLINE_HPP