--- /dev/null 2020-01-17 11:46:19.065201212 +0100 +++ new/src/hotspot/share/gc/shenandoah/shenandoahUtils.cpp 2020-01-17 17:10:48.542128361 +0100 @@ -0,0 +1,186 @@ +/* + * Copyright (c) 2017, 2019, Red Hat, Inc. All rights reserved. + * + * 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 "jfr/jfrEvents.hpp" +#include "gc/shared/gcCause.hpp" +#include "gc/shared/gcTimer.hpp" +#include "gc/shared/gcTrace.hpp" +#include "gc/shared/gcWhen.hpp" +#include "gc/shenandoah/shenandoahAllocTracker.hpp" +#include "gc/shenandoah/shenandoahCollectorPolicy.hpp" +#include "gc/shenandoah/shenandoahMarkCompact.hpp" +#include "gc/shenandoah/shenandoahHeap.hpp" +#include "gc/shenandoah/shenandoahHeuristics.hpp" +#include "gc/shenandoah/shenandoahUtils.hpp" +#include "utilities/debug.hpp" + +ShenandoahPhaseTimings::Phase ShenandoahGCPhase::_current_phase = ShenandoahGCPhase::_invalid_phase; + +ShenandoahGCSession::ShenandoahGCSession(GCCause::Cause cause) : + _heap(ShenandoahHeap::heap()), + _timer(_heap->gc_timer()), + _tracer(_heap->tracer()) { + assert(!ShenandoahGCPhase::is_valid_phase(ShenandoahGCPhase::current_phase()), + "No current GC phase"); + + _heap->set_gc_cause(cause); + _timer->register_gc_start(); + _tracer->report_gc_start(cause, _timer->gc_start()); + _heap->trace_heap(GCWhen::BeforeGC, _tracer); + + _heap->shenandoah_policy()->record_cycle_start(); + _heap->heuristics()->record_cycle_start(); + _trace_cycle.initialize(_heap->cycle_memory_manager(), cause, + /* allMemoryPoolsAffected */ true, + /* recordGCBeginTime = */ true, + /* recordPreGCUsage = */ true, + /* recordPeakUsage = */ true, + /* recordPostGCUsage = */ true, + /* recordAccumulatedGCTime = */ true, + /* recordGCEndTime = */ true, + /* countCollection = */ true + ); +} + +ShenandoahGCSession::~ShenandoahGCSession() { + _heap->heuristics()->record_cycle_end(); + _timer->register_gc_end(); + _heap->trace_heap(GCWhen::AfterGC, _tracer); + _tracer->report_gc_end(_timer->gc_end(), _timer->time_partitions()); + assert(!ShenandoahGCPhase::is_valid_phase(ShenandoahGCPhase::current_phase()), + "No current GC phase"); + _heap->set_gc_cause(GCCause::_no_gc); +} + +ShenandoahGCPauseMark::ShenandoahGCPauseMark(uint gc_id, SvcGCMarker::reason_type type) : + _heap(ShenandoahHeap::heap()), _gc_id_mark(gc_id), _svc_gc_mark(type), _is_gc_active_mark() { + + // FIXME: It seems that JMC throws away level 0 events, which are the Shenandoah + // pause events. Create this pseudo level 0 event to push real events to level 1. + _heap->gc_timer()->register_gc_phase_start("Shenandoah", Ticks::now()); + _trace_pause.initialize(_heap->stw_memory_manager(), _heap->gc_cause(), + /* allMemoryPoolsAffected */ true, + /* recordGCBeginTime = */ true, + /* recordPreGCUsage = */ false, + /* recordPeakUsage = */ false, + /* recordPostGCUsage = */ false, + /* recordAccumulatedGCTime = */ true, + /* recordGCEndTime = */ true, + /* countCollection = */ true + ); + + _heap->heuristics()->record_gc_start(); +} + +ShenandoahGCPauseMark::~ShenandoahGCPauseMark() { + _heap->gc_timer()->register_gc_phase_end(Ticks::now()); + _heap->heuristics()->record_gc_end(); +} + +ShenandoahGCPhase::ShenandoahGCPhase(const ShenandoahPhaseTimings::Phase phase) : + _heap(ShenandoahHeap::heap()), _phase(phase) { + assert(!Thread::current()->is_Worker_thread() && + (Thread::current()->is_VM_thread() || + Thread::current()->is_ConcurrentGC_thread()), + "Must be set by these threads"); + _parent_phase = _current_phase; + _current_phase = phase; + + _heap->phase_timings()->record_phase_start(_phase); +} + +ShenandoahGCPhase::~ShenandoahGCPhase() { + _heap->phase_timings()->record_phase_end(_phase); + _current_phase = _parent_phase; +} + +bool ShenandoahGCPhase::is_valid_phase(ShenandoahPhaseTimings::Phase phase) { + return phase >= 0 && phase < ShenandoahPhaseTimings::_num_phases; +} + +bool ShenandoahGCPhase::is_root_work_phase() { + switch(current_phase()) { + case ShenandoahPhaseTimings::scan_roots: + case ShenandoahPhaseTimings::update_roots: + case ShenandoahPhaseTimings::init_evac: + case ShenandoahPhaseTimings::final_update_refs_roots: + case ShenandoahPhaseTimings::degen_gc_update_roots: + case ShenandoahPhaseTimings::init_traversal_gc_work: + case ShenandoahPhaseTimings::final_traversal_gc_work: + case ShenandoahPhaseTimings::final_traversal_update_roots: + case ShenandoahPhaseTimings::full_gc_roots: + return true; + default: + return false; + } +} + +ShenandoahAllocTrace::ShenandoahAllocTrace(size_t words_size, ShenandoahAllocRequest::Type alloc_type) { + if (ShenandoahAllocationTrace) { + _start = os::elapsedTime(); + _size = words_size; + _alloc_type = alloc_type; + } else { + _start = 0; + _size = 0; + _alloc_type = ShenandoahAllocRequest::Type(0); + } +} + +ShenandoahAllocTrace::~ShenandoahAllocTrace() { + if (ShenandoahAllocationTrace) { + double stop = os::elapsedTime(); + double duration_sec = stop - _start; + double duration_us = duration_sec * 1000000; + ShenandoahAllocTracker* tracker = ShenandoahHeap::heap()->alloc_tracker(); + assert(tracker != NULL, "Must be"); + tracker->record_alloc_latency(_size, _alloc_type, duration_us); + if (duration_us > ShenandoahAllocationStallThreshold) { + log_warning(gc)("Allocation stall: %.0f us (threshold: " INTX_FORMAT " us)", + duration_us, ShenandoahAllocationStallThreshold); + } + } +} + +ShenandoahWorkerSession::ShenandoahWorkerSession(uint worker_id) : _worker_id(worker_id) { + Thread* thr = Thread::current(); + assert(ShenandoahThreadLocalData::worker_id(thr) == ShenandoahThreadLocalData::INVALID_WORKER_ID, "Already set"); + ShenandoahThreadLocalData::set_worker_id(thr, worker_id); +} + +ShenandoahConcurrentWorkerSession::~ShenandoahConcurrentWorkerSession() { + // Do nothing. Per-worker events are not supported in this JDK. +} + +ShenandoahParallelWorkerSession::~ShenandoahParallelWorkerSession() { + // Do nothing. Per-worker events are not supported in this JDK. +} +ShenandoahWorkerSession::~ShenandoahWorkerSession() { +#ifdef ASSERT + Thread* thr = Thread::current(); + assert(ShenandoahThreadLocalData::worker_id(thr) != ShenandoahThreadLocalData::INVALID_WORKER_ID, "Must be set"); + ShenandoahThreadLocalData::set_worker_id(thr, ShenandoahThreadLocalData::INVALID_WORKER_ID); +#endif +}