< prev index next >

src/hotspot/share/gc/g1/g1RemSetSummary.cpp

Print this page
rev 60637 : 8252141: Rename G1YoungRemSetSamplingThread to better reflect its purpose
Reviewed-by:

*** 28,38 **** #include "gc/g1/g1ConcurrentRefine.hpp" #include "gc/g1/g1ConcurrentRefineThread.hpp" #include "gc/g1/g1DirtyCardQueue.hpp" #include "gc/g1/g1RemSet.hpp" #include "gc/g1/g1RemSetSummary.hpp" ! #include "gc/g1/g1YoungRemSetSamplingThread.hpp" #include "gc/g1/heapRegion.hpp" #include "gc/g1/heapRegionRemSet.hpp" #include "memory/allocation.inline.hpp" #include "memory/iterator.hpp" #include "runtime/thread.inline.hpp" --- 28,38 ---- #include "gc/g1/g1ConcurrentRefine.hpp" #include "gc/g1/g1ConcurrentRefineThread.hpp" #include "gc/g1/g1DirtyCardQueue.hpp" #include "gc/g1/g1RemSet.hpp" #include "gc/g1/g1RemSetSummary.hpp" ! #include "gc/g1/g1ServiceThread.hpp" #include "gc/g1/heapRegion.hpp" #include "gc/g1/heapRegionRemSet.hpp" #include "memory/allocation.inline.hpp" #include "memory/iterator.hpp" #include "runtime/thread.inline.hpp"
*** 51,61 **** } collector(this); G1CollectedHeap* g1h = G1CollectedHeap::heap(); g1h->concurrent_refine()->threads_do(&collector); _num_coarsenings = HeapRegionRemSet::n_coarsenings(); ! set_sampling_thread_vtime(g1h->sampling_thread()->vtime_accum()); } void G1RemSetSummary::set_rs_thread_vtime(uint thread, double value) { assert(_rs_threads_vtimes != NULL, "just checking"); assert(thread < _num_vtimes, "just checking"); --- 51,61 ---- } collector(this); G1CollectedHeap* g1h = G1CollectedHeap::heap(); g1h->concurrent_refine()->threads_do(&collector); _num_coarsenings = HeapRegionRemSet::n_coarsenings(); ! set_service_thread_vtime(g1h->service_thread()->vtime_accum()); } void G1RemSetSummary::set_rs_thread_vtime(uint thread, double value) { assert(_rs_threads_vtimes != NULL, "just checking"); assert(thread < _num_vtimes, "just checking");
*** 70,80 **** G1RemSetSummary::G1RemSetSummary(bool should_update) : _num_coarsenings(0), _num_vtimes(G1ConcurrentRefine::max_num_threads()), _rs_threads_vtimes(NEW_C_HEAP_ARRAY(double, _num_vtimes, mtGC)), ! _sampling_thread_vtime(0.0f) { memset(_rs_threads_vtimes, 0, sizeof(double) * _num_vtimes); if (should_update) { update(); --- 70,80 ---- G1RemSetSummary::G1RemSetSummary(bool should_update) : _num_coarsenings(0), _num_vtimes(G1ConcurrentRefine::max_num_threads()), _rs_threads_vtimes(NEW_C_HEAP_ARRAY(double, _num_vtimes, mtGC)), ! _service_thread_vtime(0.0f) { memset(_rs_threads_vtimes, 0, sizeof(double) * _num_vtimes); if (should_update) { update();
*** 91,101 **** _num_coarsenings = other->num_coarsenings(); memcpy(_rs_threads_vtimes, other->_rs_threads_vtimes, sizeof(double) * _num_vtimes); ! set_sampling_thread_vtime(other->sampling_thread_vtime()); } void G1RemSetSummary::subtract_from(G1RemSetSummary* other) { assert(other != NULL, "just checking"); assert(_num_vtimes == other->_num_vtimes, "just checking"); --- 91,101 ---- _num_coarsenings = other->num_coarsenings(); memcpy(_rs_threads_vtimes, other->_rs_threads_vtimes, sizeof(double) * _num_vtimes); ! set_service_thread_vtime(other->service_thread_vtime()); } void G1RemSetSummary::subtract_from(G1RemSetSummary* other) { assert(other != NULL, "just checking"); assert(_num_vtimes == other->_num_vtimes, "just checking");
*** 104,114 **** for (uint i = 0; i < _num_vtimes; i++) { set_rs_thread_vtime(i, other->rs_thread_vtime(i) - rs_thread_vtime(i)); } ! _sampling_thread_vtime = other->sampling_thread_vtime() - _sampling_thread_vtime; } class RegionTypeCounter { private: const char* _name; --- 104,114 ---- for (uint i = 0; i < _num_vtimes; i++) { set_rs_thread_vtime(i, other->rs_thread_vtime(i) - rs_thread_vtime(i)); } ! _service_thread_vtime = other->service_thread_vtime() - _service_thread_vtime; } class RegionTypeCounter { private: const char* _name;
*** 326,336 **** for (uint i = 0; i < _num_vtimes; i++) { out->print(" %5.2f", rs_thread_vtime(i)); } out->cr(); out->print_cr(" Concurrent sampling threads times (s)"); ! out->print_cr(" %5.2f", sampling_thread_vtime()); HRRSStatsIter blk; G1CollectedHeap::heap()->heap_region_iterate(&blk); blk.print_summary_on(out); } --- 326,336 ---- for (uint i = 0; i < _num_vtimes; i++) { out->print(" %5.2f", rs_thread_vtime(i)); } out->cr(); out->print_cr(" Concurrent sampling threads times (s)"); ! out->print_cr(" %5.2f", service_thread_vtime()); HRRSStatsIter blk; G1CollectedHeap::heap()->heap_region_iterate(&blk); blk.print_summary_on(out); }
< prev index next >