/*

 * Copyright (c) 2001, 2019, Oracle and/or its affiliates. All rights reserved.

 * DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS FILE HEADER.

 *

 * 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 "gc/g1/g1CollectedHeap.inline.hpp"

#include "gc/g1/g1ConcurrentMarkThread.inline.hpp"

#include "gc/g1/g1Policy.hpp"

#include "gc/g1/g1VMOperations.hpp"

#include "gc/shared/gcId.hpp"

#include "gc/shared/gcTimer.hpp"

#include "gc/shared/gcTraceTime.inline.hpp"

#include "gc/shared/isGCActiveMark.hpp"

#include "memory/universe.hpp"

#include "runtime/interfaceSupport.inline.hpp"

void VM_G1CollectFull::doit() {

  G1CollectedHeap* g1h = G1CollectedHeap::heap();

  GCCauseSetter x(g1h, _gc_cause);

  _gc_succeeded = g1h->do_full_collection(true /* explicit_gc */, false /* clear_all_soft_refs */);

}

VM_G1CollectForAllocation::VM_G1CollectForAllocation(size_t         word_size,

                                                     uint           gc_count_before,

                                                     GCCause::Cause gc_cause,

                                                     double         target_pause_time_ms) :

  VM_CollectForAllocation(word_size, gc_count_before, gc_cause),

  _gc_succeeded(false),

  guarantee(target_pause_time_ms > 0.0,

            "target_pause_time_ms = %1.6lf should be positive",

            target_pause_time_ms);

  _gc_cause = gc_cause;

}

void VM_G1CollectForAllocation::doit() {

  G1CollectedHeap* g1h = G1CollectedHeap::heap();

  if (_word_size > 0) {

    // An allocation has been requested. So, try to do that first.

    _result = g1h->attempt_allocation_at_safepoint(_word_size,

                                                   false /* expect_null_cur_alloc_region */);

    if (_result != NULL) {

      // If we can successfully allocate before we actually do the

      // pause then we will consider this pause successful.

      _gc_succeeded = true;

      return;

    }

  }

  GCCauseSetter x(g1h, _gc_cause);

  // Try a partial collection of some kind.

  _gc_succeeded = g1h->do_collection_pause_at_safepoint(_target_pause_time_ms);

  if (_gc_succeeded) {

    if (_word_size > 0) {

      // An allocation had been requested. Do it, eventually trying a stronger

      // kind of GC.

      _result = g1h->satisfy_failed_allocation(_word_size, &_gc_succeeded);

    }

    guarantee(_gc_succeeded, "Elevated collections during the safepoint must always succeed.");

  }

}

void VM_G1Concurrent::doit() {

  GCIdMark gc_id_mark(_gc_id);

  GCTraceCPUTime tcpu;

  G1CollectedHeap* g1h = G1CollectedHeap::heap();

  GCTraceTime(Info, gc) t(_message, g1h->concurrent_mark()->gc_timer_cm(), GCCause::_no_gc, true);

  TraceCollectorStats tcs(g1h->g1mm()->conc_collection_counters());

  SvcGCMarker sgcm(SvcGCMarker::CONCURRENT);

  IsGCActiveMark x;

  _cl->do_void();

}

bool VM_G1Concurrent::doit_prologue() {

  Heap_lock->lock();

  return true;

}

void VM_G1Concurrent::doit_epilogue() {

  if (Universe::has_reference_pending_list()) {

    Heap_lock->notify_all();

  }

  Heap_lock->unlock();

}