/*

 * Copyright (c) 2002, 2018, 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 "classfile/stringTable.hpp"

#include "code/codeCache.hpp"

#include "gc/parallel/gcTaskManager.hpp"

#include "gc/parallel/parallelScavengeHeap.hpp"

#include "gc/parallel/psAdaptiveSizePolicy.hpp"

#include "gc/parallel/psMarkSweepProxy.hpp"

#include "gc/parallel/psParallelCompact.inline.hpp"

#include "gc/parallel/psScavenge.inline.hpp"

#include "gc/parallel/psTasks.hpp"

#include "gc/shared/collectorPolicy.hpp"

#include "gc/shared/gcCause.hpp"

#include "gc/shared/gcHeapSummary.hpp"

#include "gc/shared/gcId.hpp"

#include "gc/shared/gcLocker.hpp"

#include "gc/shared/gcTimer.hpp"

#include "gc/shared/gcTrace.hpp"

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

#include "gc/shared/isGCActiveMark.hpp"

#include "gc/shared/referencePolicy.hpp"

#include "gc/shared/referenceProcessor.hpp"

#include "gc/shared/spaceDecorator.hpp"

#include "gc/shared/weakProcessor.hpp"

#include "memory/resourceArea.hpp"

#include "logging/log.hpp"

#include "oops/access.inline.hpp"

#include "oops/compressedOops.inline.hpp"

#include "oops/oop.inline.hpp"

#include "runtime/biasedLocking.hpp"

#include "runtime/handles.inline.hpp"

#include "runtime/threadCritical.hpp"

#include "runtime/vmThread.hpp"

#include "runtime/vm_operations.hpp"

#include "services/memoryService.hpp"

#include "utilities/stack.inline.hpp"

HeapWord*                     PSScavenge::_to_space_top_before_gc = NULL;

int                           PSScavenge::_consecutive_skipped_scavenges = 0;

SpanSubjectToDiscoveryClosure PSScavenge::_span_based_discoverer;

ReferenceProcessor*           PSScavenge::_ref_processor = NULL;

PSCardTable*                  PSScavenge::_card_table = NULL;

bool                          PSScavenge::_survivor_overflow = false;

uint                          PSScavenge::_tenuring_threshold = 0;

HeapWord*                     PSScavenge::_young_generation_boundary = NULL;

uintptr_t                     PSScavenge::_young_generation_boundary_compressed = 0;

elapsedTimer                  PSScavenge::_accumulated_time;

STWGCTimer                    PSScavenge::_gc_timer;

ParallelScavengeTracer        PSScavenge::_gc_tracer;

CollectorCounters*            PSScavenge::_counters = NULL;

// Define before use

class PSIsAliveClosure: public BoolObjectClosure {

public:

  bool do_object_b(oop p) {

    return (!PSScavenge::is_obj_in_young(p)) || p->is_forwarded();

  }

};

PSIsAliveClosure PSScavenge::_is_alive_closure;

class PSKeepAliveClosure: public OopClosure {

protected:

  MutableSpace* _to_space;

  PSPromotionManager* _promotion_manager;

public:

  PSKeepAliveClosure(PSPromotionManager* pm) : _promotion_manager(pm) {

    ParallelScavengeHeap* heap = ParallelScavengeHeap::heap();

    _to_space = heap->young_gen()->to_space();

    assert(_promotion_manager != NULL, "Sanity");

  }

  template <class T> void do_oop_work(T* p) {

    assert (oopDesc::is_oop(RawAccess<OOP_NOT_NULL>::oop_load(p)),

            "expected an oop while scanning weak refs");

    // Weak refs may be visited more than once.

    if (PSScavenge::should_scavenge(p, _to_space)) {

      _promotion_manager->copy_and_push_safe_barrier<T, /*promote_immediately=*/false>(p);

    }

  }

  virtual void do_oop(oop* p)       { PSKeepAliveClosure::do_oop_work(p); }

  virtual void do_oop(narrowOop* p) { PSKeepAliveClosure::do_oop_work(p); }

};

class PSEvacuateFollowersClosure: public VoidClosure {

 private:

  PSPromotionManager* _promotion_manager;

 public:

  PSEvacuateFollowersClosure(PSPromotionManager* pm) : _promotion_manager(pm) {}

  virtual void do_void() {

    assert(_promotion_manager != NULL, "Sanity");

    _promotion_manager->drain_stacks(true);

    guarantee(_promotion_manager->stacks_empty(),

              "stacks should be empty at this point");

  }

};

class PSRefProcTaskProxy: public GCTask {

  typedef AbstractRefProcTaskExecutor::ProcessTask ProcessTask;

  ProcessTask & _rp_task;

  uint          _work_id;

public:

  PSRefProcTaskProxy(ProcessTask & rp_task, uint work_id)

    : _rp_task(rp_task),

      _work_id(work_id)

  { }

private:

  virtual char* name() { return (char *)"Process referents by policy in parallel"; }

  virtual void do_it(GCTaskManager* manager, uint which);

};

void PSRefProcTaskProxy::do_it(GCTaskManager* manager, uint which)

{

  PSPromotionManager* promotion_manager =

    PSPromotionManager::gc_thread_promotion_manager(which);

  assert(promotion_manager != NULL, "sanity check");

  PSKeepAliveClosure keep_alive(promotion_manager);

  PSEvacuateFollowersClosure evac_followers(promotion_manager);

  PSIsAliveClosure is_alive;

  _rp_task.work(_work_id, is_alive, keep_alive, evac_followers);

}

class PSRefEnqueueTaskProxy: public GCTask {

  typedef AbstractRefProcTaskExecutor::EnqueueTask EnqueueTask;

  EnqueueTask& _enq_task;

  uint         _work_id;

public:

  PSRefEnqueueTaskProxy(EnqueueTask& enq_task, uint work_id)

    : _enq_task(enq_task),

      _work_id(work_id)

  { }

  virtual char* name() { return (char *)"Enqueue reference objects in parallel"; }

  virtual void do_it(GCTaskManager* manager, uint which)

  {

    _enq_task.work(_work_id);

  }

};

class PSRefProcTaskExecutor: public AbstractRefProcTaskExecutor {

  virtual void execute(ProcessTask& task);

  virtual void execute(EnqueueTask& task);

};

void PSRefProcTaskExecutor::execute(ProcessTask& task)

{

  GCTaskQueue* q = GCTaskQueue::create();

  GCTaskManager* manager = ParallelScavengeHeap::gc_task_manager();

  for(uint i=0; i < manager->active_workers(); i++) {

    q->enqueue(new PSRefProcTaskProxy(task, i));

  }

  ParallelTaskTerminator terminator(manager->active_workers(),

                 (TaskQueueSetSuper*) PSPromotionManager::stack_array_depth());

  if (task.marks_oops_alive() && manager->active_workers() > 1) {

    for (uint j = 0; j < manager->active_workers(); j++) {

      q->enqueue(new StealTask(&terminator));

    }

  }

  manager->execute_and_wait(q);

}

void PSRefProcTaskExecutor::execute(EnqueueTask& task)

{

  GCTaskQueue* q = GCTaskQueue::create();

  GCTaskManager* manager = ParallelScavengeHeap::gc_task_manager();

  for(uint i=0; i < manager->active_workers(); i++) {

    q->enqueue(new PSRefEnqueueTaskProxy(task, i));

  }

  manager->execute_and_wait(q);

}

// This method contains all heap specific policy for invoking scavenge.

// PSScavenge::invoke_no_policy() will do nothing but attempt to

// scavenge. It will not clean up after failed promotions, bail out if

// we've exceeded policy time limits, or any other special behavior.

// All such policy should be placed here.

//

// Note that this method should only be called from the vm_thread while

// at a safepoint!

bool PSScavenge::invoke() {

  assert(SafepointSynchronize::is_at_safepoint(), "should be at safepoint");

  assert(Thread::current() == (Thread*)VMThread::vm_thread(), "should be in vm thread");

  assert(!ParallelScavengeHeap::heap()->is_gc_active(), "not reentrant");

  ParallelScavengeHeap* const heap = ParallelScavengeHeap::heap();

  PSAdaptiveSizePolicy* policy = heap->size_policy();

  IsGCActiveMark mark;

  const bool scavenge_done = PSScavenge::invoke_no_policy();

  const bool need_full_gc = !scavenge_done ||

    policy->should_full_GC(heap->old_gen()->free_in_bytes());

  bool full_gc_done = false;

  if (UsePerfData) {

    PSGCAdaptivePolicyCounters* const counters = heap->gc_policy_counters();

    const int ffs_val = need_full_gc ? full_follows_scavenge : not_skipped;

    counters->update_full_follows_scavenge(ffs_val);

  }

  if (need_full_gc) {

    GCCauseSetter gccs(heap, GCCause::_adaptive_size_policy);

    SoftRefPolicy* srp = heap->soft_ref_policy();

    const bool clear_all_softrefs = srp->should_clear_all_soft_refs();

    if (UseParallelOldGC) {

      full_gc_done = PSParallelCompact::invoke_no_policy(clear_all_softrefs);

    } else {

      full_gc_done = PSMarkSweepProxy::invoke_no_policy(clear_all_softrefs);

    }

  }

  return full_gc_done;

}

// This method contains no policy. You should probably

// be calling invoke() instead.

bool PSScavenge::invoke_no_policy() {

  assert(SafepointSynchronize::is_at_safepoint(), "should be at safepoint");

  assert(Thread::current() == (Thread*)VMThread::vm_thread(), "should be in vm thread");

  _gc_timer.register_gc_start();

  TimeStamp scavenge_entry;

  TimeStamp scavenge_midpoint;

  TimeStamp scavenge_exit;

  scavenge_entry.update();

  if (GCLocker::check_active_before_gc()) {

    return false;

  }

  ParallelScavengeHeap* heap = ParallelScavengeHeap::heap();

  GCCause::Cause gc_cause = heap->gc_cause();

  // Check for potential problems.

  if (!should_attempt_scavenge()) {

    return false;

  }

  GCIdMark gc_id_mark;

  _gc_tracer.report_gc_start(heap->gc_cause(), _gc_timer.gc_start());

  bool promotion_failure_occurred = false;

  PSYoungGen* young_gen = heap->young_gen();

  PSOldGen* old_gen = heap->old_gen();

  PSAdaptiveSizePolicy* size_policy = heap->size_policy();

  heap->increment_total_collections();

  if (AdaptiveSizePolicy::should_update_eden_stats(gc_cause)) {

    // Gather the feedback data for eden occupancy.

    young_gen->eden_space()->accumulate_statistics();

  }

  heap->print_heap_before_gc();

  heap->trace_heap_before_gc(&_gc_tracer);

  assert(!NeverTenure || _tenuring_threshold == markOopDesc::max_age + 1, "Sanity");

  assert(!AlwaysTenure || _tenuring_threshold == 0, "Sanity");

  // Fill in TLABs

  heap->accumulate_statistics_all_tlabs();

  heap->ensure_parsability(true);  // retire TLABs

  if (VerifyBeforeGC && heap->total_collections() >= VerifyGCStartAt) {

    HandleMark hm;  // Discard invalid handles created during verification

    Universe::verify("Before GC");

  }

  {

    ResourceMark rm;

    HandleMark hm;

    GCTraceCPUTime tcpu;

    GCTraceTime(Info, gc) tm("Pause Young", NULL, gc_cause, true);

    TraceCollectorStats tcs(counters());

    TraceMemoryManagerStats tms(heap->young_gc_manager(), gc_cause);

    if (log_is_enabled(Debug, gc, heap, exit)) {

      accumulated_time()->start();

    }

    // Let the size policy know we're starting

    size_policy->minor_collection_begin();

    // Verify the object start arrays.

    if (VerifyObjectStartArray &&

        VerifyBeforeGC) {

      old_gen->verify_object_start_array();

    }

    // Verify no unmarked old->young roots

    if (VerifyRememberedSets) {

      heap->card_table()->verify_all_young_refs_imprecise();

    }

    assert(young_gen->to_space()->is_empty(),

           "Attempt to scavenge with live objects in to_space");

    young_gen->to_space()->clear(SpaceDecorator::Mangle);

    save_to_space_top_before_gc();

#if COMPILER2_OR_JVMCI

    DerivedPointerTable::clear();

#endif

    reference_processor()->enable_discovery();

    reference_processor()->setup_policy(false);

    PreGCValues pre_gc_values(heap);

    // Reset our survivor overflow.

    set_survivor_overflow(false);

    // We need to save the old top values before

    // creating the promotion_manager. We pass the top

    // values to the card_table, to prevent it from

    // straying into the promotion labs.

    HeapWord* old_top = old_gen->object_space()->top();

    // Release all previously held resources

    gc_task_manager()->release_all_resources();

    // Set the number of GC threads to be used in this collection

    gc_task_manager()->set_active_gang();

    gc_task_manager()->task_idle_workers();

    // Get the active number of workers here and use that value

    // throughout the methods.

    uint active_workers = gc_task_manager()->active_workers();

    PSPromotionManager::pre_scavenge();

    // We'll use the promotion manager again later.

    PSPromotionManager* promotion_manager = PSPromotionManager::vm_thread_promotion_manager();

    {

      GCTraceTime(Debug, gc, phases) tm("Scavenge", &_gc_timer);

      ParallelScavengeHeap::ParStrongRootsScope psrs;

      GCTaskQueue* q = GCTaskQueue::create();

      if (!old_gen->object_space()->is_empty()) {

        // There are only old-to-young pointers if there are objects

        // in the old gen.

        uint stripe_total = active_workers;

        for(uint i=0; i < stripe_total; i++) {

          q->enqueue(new OldToYoungRootsTask(old_gen, old_top, i, stripe_total));

        }

      }

      q->enqueue(new ScavengeRootsTask(ScavengeRootsTask::universe));

      q->enqueue(new ScavengeRootsTask(ScavengeRootsTask::jni_handles));

      // We scan the thread roots in parallel

      q->enqueue(new ScavengeRootsTask(ScavengeRootsTask::object_synchronizer));

      q->enqueue(new ScavengeRootsTask(ScavengeRootsTask::management));

      q->enqueue(new ScavengeRootsTask(ScavengeRootsTask::system_dictionary));

      q->enqueue(new ScavengeRootsTask(ScavengeRootsTask::class_loader_data));

      q->enqueue(new ScavengeRootsTask(ScavengeRootsTask::jvmti));

      q->enqueue(new ScavengeRootsTask(ScavengeRootsTask::code_cache));

      ParallelTaskTerminator terminator(

        active_workers,

                  (TaskQueueSetSuper*) promotion_manager->stack_array_depth());

        // If active_workers can exceed 1, add a StrealTask.

        // PSPromotionManager::drain_stacks_depth() does not fully drain its

        // stacks and expects a StealTask to complete the draining if

        // ParallelGCThreads is > 1.

        if (gc_task_manager()->workers() > 1) {

          for (uint j = 0; j < active_workers; j++) {

            q->enqueue(new StealTask(&terminator));

          }

        }

      gc_task_manager()->execute_and_wait(q);

    }

    scavenge_midpoint.update();

    // Process reference objects discovered during scavenge

    {

      GCTraceTime(Debug, gc, phases) tm("Reference Processing", &_gc_timer);

      reference_processor()->setup_policy(false); // not always_clear

      reference_processor()->set_active_mt_degree(active_workers);

      PSKeepAliveClosure keep_alive(promotion_manager);

      PSEvacuateFollowersClosure evac_followers(promotion_manager);

      ReferenceProcessorStats stats;

      ReferenceProcessorPhaseTimes pt(&_gc_timer, reference_processor()->num_queues());

      if (reference_processor()->processing_is_mt()) {

        PSRefProcTaskExecutor task_executor;

        stats = reference_processor()->process_discovered_references(

          &_is_alive_closure, &keep_alive, &evac_followers, &task_executor,

          &pt);

      } else {

        stats = reference_processor()->process_discovered_references(

          &_is_alive_closure, &keep_alive, &evac_followers, NULL, &pt);

      }

      _gc_tracer.report_gc_reference_stats(stats);

      pt.print_all_references();

    }

    assert(promotion_manager->stacks_empty(),"stacks should be empty at this point");

    PSScavengeRootsClosure root_closure(promotion_manager);

    {

      GCTraceTime(Debug, gc, phases) tm("Weak Processing", &_gc_timer);

      WeakProcessor::weak_oops_do(&_is_alive_closure, &root_closure);

    }

    {

      GCTraceTime(Debug, gc, phases) tm("Scrub String Table", &_gc_timer);

      // Unlink any dead interned Strings and process the remaining live ones.

      StringTable::unlink_or_oops_do(&_is_alive_closure, &root_closure);

    }

    // Verify that usage of root_closure didn't copy any objects.

    assert(promotion_manager->stacks_empty(),"stacks should be empty at this point");

    // Finally, flush the promotion_manager's labs, and deallocate its stacks.

    promotion_failure_occurred = PSPromotionManager::post_scavenge(_gc_tracer);

    if (promotion_failure_occurred) {

      clean_up_failed_promotion();

      log_info(gc, promotion)("Promotion failed");

    }

    _gc_tracer.report_tenuring_threshold(tenuring_threshold());

    // Let the size policy know we're done.  Note that we count promotion

    // failure cleanup time as part of the collection (otherwise, we're

    // implicitly saying it's mutator time).

    size_policy->minor_collection_end(gc_cause);

    if (!promotion_failure_occurred) {

      // Swap the survivor spaces.

      young_gen->eden_space()->clear(SpaceDecorator::Mangle);

      young_gen->from_space()->clear(SpaceDecorator::Mangle);

      young_gen->swap_spaces();

      size_t survived = young_gen->from_space()->used_in_bytes();

      size_t promoted = old_gen->used_in_bytes() - pre_gc_values.old_gen_used();

      size_policy->update_averages(_survivor_overflow, survived, promoted);

      // A successful scavenge should restart the GC time limit count which is

      // for full GC's.

      size_policy->reset_gc_overhead_limit_count();

      if (UseAdaptiveSizePolicy) {

        // Calculate the new survivor size and tenuring threshold

        log_debug(gc, ergo)("AdaptiveSizeStart:  collection: %d ", heap->total_collections());

        log_trace(gc, ergo)("old_gen_capacity: " SIZE_FORMAT " young_gen_capacity: " SIZE_FORMAT,

                            old_gen->capacity_in_bytes(), young_gen->capacity_in_bytes());

        if (UsePerfData) {

          PSGCAdaptivePolicyCounters* counters = heap->gc_policy_counters();

          counters->update_old_eden_size(

            size_policy->calculated_eden_size_in_bytes());

          counters->update_old_promo_size(