< prev index next >
src/hotspot/share/runtime/threadSMR.hpp
Print this page
rev 48162 : 8191789: migrate more Thread-SMR stuff from thread.[ch]pp -> threadSMR.[ch]pp
Reviewed-by: stefank
rev 48163 : CR round 0: dcubed - move more code into sort order, add update_smr_tlh_stats(); stefank - refactor Threads::add() and Threads::remove() to allow more ThreadsSMRSupport functions to be private, move is_a_protected_JavaThread_with_lock() to threadSMR.inline.hpp
*** 108,144 ****
static uint _smr_to_delete_list_max;
static ThreadsList *acquire_stable_list_fast_path(Thread *self);
static ThreadsList *acquire_stable_list_nested_path(Thread *self);
static void add_smr_deleted_thread_times(uint add_value);
static void clear_smr_delete_notify();
static void inc_smr_deleted_thread_cnt();
static bool is_a_protected_JavaThread(JavaThread *thread);
static void release_stable_list_fast_path(Thread *self);
static void release_stable_list_nested_path(Thread *self);
static void release_stable_list_wake_up(char *log_str);
static void set_smr_delete_notify();
static Monitor* smr_delete_lock() { return _smr_delete_lock; }
static bool smr_delete_notify();
static void update_smr_deleted_thread_time_max(uint new_value);
public:
static ThreadsList *acquire_stable_list(Thread *self, bool is_ThreadsListSetter);
! static void add_smr_tlh_times(uint add_value);
static ThreadsList* get_smr_java_thread_list();
! static void inc_smr_java_thread_list_alloc_cnt();
! static void inc_smr_tlh_cnt();
! static bool is_a_protected_JavaThread_with_lock(JavaThread *thread) {
! MutexLockerEx ml(Threads_lock->owned_by_self() ? NULL : Threads_lock);
! return is_a_protected_JavaThread(thread);
! }
static void release_stable_list(Thread *self);
static void smr_delete(JavaThread *thread);
! static void smr_free_list(ThreadsList* threads);
! static void update_smr_java_thread_list_max(uint new_value);
! static void update_smr_tlh_time_max(uint new_value);
! static ThreadsList* xchg_smr_java_thread_list(ThreadsList* new_list);
// Logging and printing support:
static void log_smr_statistics();
static void print_smr_info_elements_on(outputStream* st, ThreadsList* t_list);
static void print_smr_info_on(outputStream* st);
--- 108,144 ----
static uint _smr_to_delete_list_max;
static ThreadsList *acquire_stable_list_fast_path(Thread *self);
static ThreadsList *acquire_stable_list_nested_path(Thread *self);
static void add_smr_deleted_thread_times(uint add_value);
+ static void add_smr_tlh_times(uint add_value);
static void clear_smr_delete_notify();
static void inc_smr_deleted_thread_cnt();
+ static void inc_smr_java_thread_list_alloc_cnt();
+ static void inc_smr_tlh_cnt();
static bool is_a_protected_JavaThread(JavaThread *thread);
static void release_stable_list_fast_path(Thread *self);
static void release_stable_list_nested_path(Thread *self);
static void release_stable_list_wake_up(char *log_str);
static void set_smr_delete_notify();
static Monitor* smr_delete_lock() { return _smr_delete_lock; }
static bool smr_delete_notify();
+ static void smr_free_list(ThreadsList* threads);
static void update_smr_deleted_thread_time_max(uint new_value);
+ static void update_smr_java_thread_list_max(uint new_value);
+ static void update_smr_tlh_time_max(uint new_value);
+ static ThreadsList* xchg_smr_java_thread_list(ThreadsList* new_list);
public:
static ThreadsList *acquire_stable_list(Thread *self, bool is_ThreadsListSetter);
! static void add_thread(JavaThread *thread);
static ThreadsList* get_smr_java_thread_list();
! static bool is_a_protected_JavaThread_with_lock(JavaThread *thread);
static void release_stable_list(Thread *self);
+ static void remove_thread(JavaThread *thread);
static void smr_delete(JavaThread *thread);
! static void update_smr_tlh_stats(uint millis);
// Logging and printing support:
static void log_smr_statistics();
static void print_smr_info_elements_on(outputStream* st, ThreadsList* t_list);
static void print_smr_info_on(outputStream* st);
*** 157,166 ****
--- 157,169 ----
void threads_do_dispatch(T *cl, JavaThread *const thread) const;
ThreadsList *next_list() const { return _next_list; }
void set_next_list(ThreadsList *list) { _next_list = list; }
+ static ThreadsList* add_thread(ThreadsList* list, JavaThread* java_thread);
+ static ThreadsList* remove_thread(ThreadsList* list, JavaThread* java_thread);
+
public:
ThreadsList(int entries);
~ThreadsList();
template <class T>
*** 174,186 ****
// Returns -1 if target is not found.
int find_index_of_JavaThread(JavaThread* target);
JavaThread* find_JavaThread_from_java_tid(jlong java_tid) const;
bool includes(const JavaThread * const p) const;
-
- static ThreadsList* add_thread(ThreadsList* list, JavaThread* java_thread);
- static ThreadsList* remove_thread(ThreadsList* list, JavaThread* java_thread);
};
// Linked list of ThreadsLists to support nested ThreadsListHandles.
class NestedThreadsList : public CHeapObj<mtThread> {
ThreadsList*const _t_list;
--- 177,186 ----
< prev index next >