/*

 * Copyright (c) 2017, 2018, 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"

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");

  _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(), _heap->gc_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");

}

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_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() {

  _event.commit(GCId::current(), ShenandoahPhaseTimings::phase_name(ShenandoahGCPhase::current_phase()));

}

ShenandoahParallelWorkerSession::~ShenandoahParallelWorkerSession() {

  _event.commit(GCId::current(), _worker_id, ShenandoahPhaseTimings::phase_name(ShenandoahGCPhase::current_phase()));

}

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

}