< prev index next >
src/share/vm/gc_implementation/g1/g1GCPhaseTimes.cpp
Print this page
*** 71,87 ****
va_start(ap, format);
vappend(format, ap);
va_end(ap);
}
void append_and_print_cr(const char* format, ...) ATTRIBUTE_PRINTF(2, 3) {
va_list ap;
va_start(ap, format);
vappend(format, ap);
va_end(ap);
! gclog_or_tty->print_cr("%s", _buffer);
! _cur = _indent_level * INDENT_CHARS;
}
};
template <class T>
WorkerDataArray<T>::WorkerDataArray(uint length, const char* title, bool print_sum, int log_level, uint indent_level) :
--- 71,91 ----
va_start(ap, format);
vappend(format, ap);
va_end(ap);
}
+ void print_cr() {
+ gclog_or_tty->print_cr("%s", _buffer);
+ _cur = _indent_level * INDENT_CHARS;
+ }
+
void append_and_print_cr(const char* format, ...) ATTRIBUTE_PRINTF(2, 3) {
va_list ap;
va_start(ap, format);
vappend(format, ap);
va_end(ap);
! print_cr();
}
};
template <class T>
WorkerDataArray<T>::WorkerDataArray(uint length, const char* title, bool print_sum, int log_level, uint indent_level) :
*** 95,113 ****
template <class T>
WorkerDataArray<T>::~WorkerDataArray() {
FREE_C_HEAP_ARRAY(T, _data);
}
! template <>
! void WorkerDataArray<double>::log_value(LineBuffer& buf, double value) {
! buf.append("%.1lf", value * 1000);
! }
!
! template <>
! void WorkerDataArray<size_t>::log_value(LineBuffer& buf, size_t value) {
! buf.append(SIZE_FORMAT, value);
! }
template <>
size_t WorkerDataArray<size_t>::uninitialized() {
return (size_t)-1;
}
--- 99,109 ----
template <class T>
WorkerDataArray<T>::~WorkerDataArray() {
FREE_C_HEAP_ARRAY(T, _data);
}
! #ifndef PRODUCT
template <>
size_t WorkerDataArray<size_t>::uninitialized() {
return (size_t)-1;
}
*** 116,185 ****
double WorkerDataArray<double>::uninitialized() {
return -1.0;
}
template <class T>
- void WorkerDataArray<T>::print() {
- if (_log_level > G1Log::level() || !_enabled) {
- return;
- }
-
- if (_length == 1) {
- // No need for min, max, average and sum for only one worker
- LineBuffer buf(_indent_level);
- buf.append("[%s: ", _title);
- log_value(buf, _data[0]);
- buf.append_and_print_cr("]");
- return;
- }
-
- T min = _data[0];
- T max = _data[0];
- T sum = 0;
-
- LineBuffer buf(_indent_level);
- buf.append("[%s:", _title);
- for (uint i = 0; i < _length; ++i) {
- T val = _data[i];
- min = MIN2(val, min);
- max = MAX2(val, max);
- sum += val;
- if (G1Log::finest()) {
- buf.append(" ");
- log_value(buf, val);
- }
- }
-
- if (G1Log::finest()) {
- buf.append_and_print_cr("%s", "");
- }
-
- double avg = (double)sum / (double)_length;
- buf.append(" Min: ");
- log_value(buf, min);
- buf.append(", Avg: ");
- buf.append("%.1lf", avg); // Always print average as a double
- buf.append(", Max: ");
- log_value(buf, max);
- buf.append(", Diff: ");
- log_value(buf, max - min);
- if (_print_sum) {
- // for things like the start and end times the sum is not
- // that relevant
- buf.append(", Sum: ");
- log_value(buf, sum);
- }
- buf.append_and_print_cr("]");
-
- if (_sub_count != NULL) {
- _sub_count->print();
- }
- }
-
- #ifndef PRODUCT
-
- template <class T>
void WorkerDataArray<T>::reset() {
for (uint i = 0; i < _length; i++) {
_data[i] = WorkerDataArray<T>::uninitialized();
}
if (_sub_count != NULL) {
--- 112,121 ----
*** 243,271 ****
_gc_phases[i]->reset();
}
_gc_phases[SATBFiltering]->set_enabled(mark_in_progress);
! _gc_phases[StringDedupQueueFixup]->set_enabled(G1StringDedup::is_enabled);
! _gc_phases[StringDedupTableFixup]->set_enabled(G1StringDedup::is_enabled);
}
void G1GCPhaseTimes::note_gc_end() {
for (uint i = 0; i < _active_gc_threads; i++) {
double worker_time = _gc_phases[GCWorkerEnd]->get(i) - _gc_phases[GCWorkerStart]->get(i);
! record_time(GCWorkerTotal, i , worker_time);
double worker_known_time =
_gc_phases[ExtRootScan]->get(i) +
_gc_phases[SATBFiltering]->get(i) +
_gc_phases[UpdateRS]->get(i) +
_gc_phases[ScanRS]->get(i) +
_gc_phases[CodeRoots]->get(i) +
_gc_phases[ObjCopy]->get(i) +
_gc_phases[Termination]->get(i);
! record_time(Other, i, worker_time - worker_known_time);
}
for (int i = 0; i < Sentinel; i++) {
_gc_phases[i]->verify();
}
--- 179,207 ----
_gc_phases[i]->reset();
}
_gc_phases[SATBFiltering]->set_enabled(mark_in_progress);
! _gc_phases[StringDedupQueueFixup]->set_enabled(G1StringDedup::is_enabled());
! _gc_phases[StringDedupTableFixup]->set_enabled(G1StringDedup::is_enabled());
}
void G1GCPhaseTimes::note_gc_end() {
for (uint i = 0; i < _active_gc_threads; i++) {
double worker_time = _gc_phases[GCWorkerEnd]->get(i) - _gc_phases[GCWorkerStart]->get(i);
! record_time_secs(GCWorkerTotal, i , worker_time);
double worker_known_time =
_gc_phases[ExtRootScan]->get(i) +
_gc_phases[SATBFiltering]->get(i) +
_gc_phases[UpdateRS]->get(i) +
_gc_phases[ScanRS]->get(i) +
_gc_phases[CodeRoots]->get(i) +
_gc_phases[ObjCopy]->get(i) +
_gc_phases[Termination]->get(i);
! record_time_secs(Other, i, worker_time - worker_known_time);
}
for (int i = 0; i < Sentinel; i++) {
_gc_phases[i]->verify();
}
*** 307,331 ****
return misc_time_ms;
}
void G1GCPhaseTimes::print(double pause_time_sec) {
if (_root_region_scan_wait_time_ms > 0.0) {
print_stats(1, "Root Region Scan Waiting", _root_region_scan_wait_time_ms);
}
print_stats(1, "Parallel Time", _cur_collection_par_time_ms, _active_gc_threads);
for (int i = 0; i <= GCMainPhasesLast; i++) {
! _gc_phases[i]->print();
}
print_stats(1, "Code Root Fixup", _cur_collection_code_root_fixup_time_ms);
print_stats(1, "Code Root Purge", _cur_strong_code_root_purge_time_ms);
if (G1StringDedup::is_enabled()) {
print_stats(1, "String Dedup Fixup", _cur_string_dedup_fixup_time_ms, _active_gc_threads);
for (int i = StringDedupPhasesFirst; i <= StringDedupPhasesLast; i++) {
! _gc_phases[i]->print();
}
}
print_stats(1, "Clear CT", _cur_clear_ct_time_ms);
double misc_time_ms = pause_time_sec * MILLIUNITS - accounted_time_ms();
print_stats(1, "Other", misc_time_ms);
--- 243,269 ----
return misc_time_ms;
}
void G1GCPhaseTimes::print(double pause_time_sec) {
+ G1GCPhasePrinter phase_printer(this);
+
if (_root_region_scan_wait_time_ms > 0.0) {
print_stats(1, "Root Region Scan Waiting", _root_region_scan_wait_time_ms);
}
print_stats(1, "Parallel Time", _cur_collection_par_time_ms, _active_gc_threads);
for (int i = 0; i <= GCMainPhasesLast; i++) {
! phase_printer.print((GCPhases) i);
}
print_stats(1, "Code Root Fixup", _cur_collection_code_root_fixup_time_ms);
print_stats(1, "Code Root Purge", _cur_strong_code_root_purge_time_ms);
if (G1StringDedup::is_enabled()) {
print_stats(1, "String Dedup Fixup", _cur_string_dedup_fixup_time_ms, _active_gc_threads);
for (int i = StringDedupPhasesFirst; i <= StringDedupPhasesLast; i++) {
! phase_printer.print((GCPhases) i);
}
}
print_stats(1, "Clear CT", _cur_clear_ct_time_ms);
double misc_time_ms = pause_time_sec * MILLIUNITS - accounted_time_ms();
print_stats(1, "Other", misc_time_ms);
*** 346,356 ****
(_recorded_young_cset_choice_time_ms +
_recorded_non_young_cset_choice_time_ms));
print_stats(2, "Ref Proc", _cur_ref_proc_time_ms);
print_stats(2, "Ref Enq", _cur_ref_enq_time_ms);
print_stats(2, "Redirty Cards", _recorded_redirty_logged_cards_time_ms);
! _gc_phases[RedirtyCards]->print();
if (G1EagerReclaimHumongousObjects) {
print_stats(2, "Humongous Register", _cur_fast_reclaim_humongous_register_time_ms);
if (G1Log::finest()) {
print_stats(3, "Humongous Total", _cur_fast_reclaim_humongous_total);
print_stats(3, "Humongous Candidate", _cur_fast_reclaim_humongous_candidates);
--- 284,294 ----
(_recorded_young_cset_choice_time_ms +
_recorded_non_young_cset_choice_time_ms));
print_stats(2, "Ref Proc", _cur_ref_proc_time_ms);
print_stats(2, "Ref Enq", _cur_ref_enq_time_ms);
print_stats(2, "Redirty Cards", _recorded_redirty_logged_cards_time_ms);
! phase_printer.print(RedirtyCards);
if (G1EagerReclaimHumongousObjects) {
print_stats(2, "Humongous Register", _cur_fast_reclaim_humongous_register_time_ms);
if (G1Log::finest()) {
print_stats(3, "Humongous Total", _cur_fast_reclaim_humongous_total);
print_stats(3, "Humongous Candidate", _cur_fast_reclaim_humongous_candidates);
*** 376,382 ****
_phase_times(phase_times), _phase(phase), _worker_id(worker_id) {
_start_time = os::elapsedTime();
}
G1GCPhaseTimesTracker::~G1GCPhaseTimesTracker() {
! _phase_times->record_time(_phase, _worker_id, os::elapsedTime() - _start_time);
}
--- 314,399 ----
_phase_times(phase_times), _phase(phase), _worker_id(worker_id) {
_start_time = os::elapsedTime();
}
G1GCPhaseTimesTracker::~G1GCPhaseTimesTracker() {
! _phase_times->record_time_secs(_phase, _worker_id, os::elapsedTime() - _start_time);
! }
!
! void G1GCPhasePrinter::print_single_length(G1GCPhaseTimes::GCPhases phase_id, WorkerDataArray<double>* phase) {
! // No need for min, max, average and sum for only one worker
! LineBuffer buf(phase->_indent_level);
! buf.append_and_print_cr("[%s: %.1lf]", phase->_title, _phase_times->get_time_ms(phase_id, 0));
!
! if (phase->_sub_count != NULL) {
! LineBuffer buf2(phase->_sub_count->_indent_level);
! buf2.append_and_print_cr("[%s: "SIZE_FORMAT"]", phase->_sub_count->_title, _phase_times->sub_count_sum(phase_id));
! }
! }
!
! void G1GCPhasePrinter::print_time_values(LineBuffer& buf, G1GCPhaseTimes::GCPhases phase_id, WorkerDataArray<double>* phase) {
! for (uint i = 0; i < phase->_length; ++i) {
! buf.append(" %.1lf", _phase_times->get_time_ms(phase_id, i));
! }
! buf.print_cr();
! }
!
! void G1GCPhasePrinter::print_count_values(LineBuffer& buf, G1GCPhaseTimes::GCPhases phase_id, WorkerDataArray<size_t>* sub_count) {
! for (uint i = 0; i < sub_count->_length; ++i) {
! buf.append(" " SIZE_FORMAT, _phase_times->get_sub_count(phase_id, i));
! }
! buf.print_cr();
! }
!
! void G1GCPhasePrinter::print_sub_count(G1GCPhaseTimes::GCPhases phase_id, WorkerDataArray<size_t>* sub_count) {
! LineBuffer buf(sub_count->_indent_level);
! buf.append("[%s:", sub_count->_title);
!
! if (G1Log::finest()) {
! print_count_values(buf, phase_id, sub_count);
! }
!
! assert(sub_count->_print_sum, err_msg("%s does not have print sum true even though it is a count", sub_count->_title));
!
! buf.append_and_print_cr(" Min: " SIZE_FORMAT ", Avg: %.1lf, Max: " SIZE_FORMAT ", Diff: " SIZE_FORMAT ", Sum: " SIZE_FORMAT "]",
! _phase_times->min_sub_count(phase_id), _phase_times->average_sub_count(phase_id), _phase_times->max_sub_count(phase_id),
! _phase_times->max_sub_count(phase_id) - _phase_times->min_sub_count(phase_id), _phase_times->sum_sub_count(phase_id));
! }
!
! void G1GCPhasePrinter::print_multi_length(G1GCPhaseTimes::GCPhases phase_id, WorkerDataArray<double>* phase) {
! LineBuffer buf(phase->_indent_level);
! buf.append("[%s:", phase->_title);
!
! if (G1Log::finest()) {
! print_time_values(buf, phase_id, phase);
! }
!
! buf.append(" Min: %.1lf, Avg: %.1lf, Max: %.1lf, Diff: %.1lf",
! _phase_times->min_time_ms(phase_id), _phase_times->average_time_ms(phase_id), _phase_times->max_time_ms(phase_id),
! _phase_times->max_time_ms(phase_id) - _phase_times->min_time_ms(phase_id));
!
! if (phase->_print_sum) {
! // for things like the start and end times the sum is not
! // that relevant
! buf.append(", Sum: %.1lf", _phase_times->sum_time_ms(phase_id));
! }
!
! buf.append_and_print_cr("]");
!
! if (phase->_sub_count != NULL) {
! print_sub_count(phase_id, phase->_sub_count);
! }
! }
!
! void G1GCPhasePrinter::print(G1GCPhaseTimes::GCPhases phase_id) {
! WorkerDataArray<double>* phase = _phase_times->_gc_phases[phase_id];
!
! if (phase->_log_level > G1Log::level() || !phase->_enabled) {
! return;
! }
!
! if (phase->_length == 1) {
! print_single_length(phase_id, phase);
! } else {
! print_multi_length(phase_id, phase);
! }
}
< prev index next >