/*

 * Copyright (c) 2002, 2012, 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/symbolTable.hpp"

#include "code/codeCache.hpp"

#include "gc_implementation/parallelScavenge/cardTableExtension.hpp"

#include "gc_implementation/parallelScavenge/gcTaskManager.hpp"

#include "gc_implementation/parallelScavenge/generationSizer.hpp"

#include "gc_implementation/parallelScavenge/parallelScavengeHeap.hpp"

#include "gc_implementation/parallelScavenge/psAdaptiveSizePolicy.hpp"

#include "gc_implementation/parallelScavenge/psMarkSweep.hpp"

#include "gc_implementation/parallelScavenge/psParallelCompact.hpp"

#include "gc_implementation/parallelScavenge/psScavenge.inline.hpp"

#include "gc_implementation/parallelScavenge/psTasks.hpp"

#include "gc_implementation/shared/isGCActiveMark.hpp"

#include "gc_implementation/shared/spaceDecorator.hpp"

#include "gc_interface/gcCause.hpp"

#include "memory/collectorPolicy.hpp"

#include "memory/gcLocker.inline.hpp"

#include "memory/referencePolicy.hpp"

#include "memory/referenceProcessor.hpp"

#include "memory/resourceArea.hpp"

#include "oops/oop.inline.hpp"

#include "oops/oop.psgc.inline.hpp"

#include "runtime/biasedLocking.hpp"

#include "runtime/fprofiler.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;

ReferenceProcessor*        PSScavenge::_ref_processor = NULL;

CardTableExtension*        PSScavenge::_card_table = NULL;

bool                       PSScavenge::_survivor_overflow = false;

int                        PSScavenge::_tenuring_threshold = 0;

HeapWord*                  PSScavenge::_young_generation_boundary = NULL;

elapsedTimer               PSScavenge::_accumulated_time;

CollectorCounters*         PSScavenge::_counters = NULL;

bool                       PSScavenge::_promotion_failed = false;

// Define before use

class PSIsAliveClosure: public BoolObjectClosure {

public:

  void do_object(oop p) {

    assert(false, "Do not call.");

  }

  bool do_object_b(oop p) {

    return (!PSScavenge::is_obj_in_young((HeapWord*) 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*)Universe::heap();

    assert(heap->kind() == CollectedHeap::ParallelScavengeHeap, "Sanity");

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

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

  }

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

    assert (!oopDesc::is_null(*p), "expected non-null ref");

    assert ((oopDesc::load_decode_heap_oop_not_null(p))->is_oop(),

            "expected an oop while scanning weak refs");

    // Weak refs may be visited more than once.

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

      PSScavenge::copy_and_push_safe_barrier<T, /*promote_immediately=*/false>(_promotion_manager, 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 PSPromotionFailedClosure : public ObjectClosure {

  virtual void do_object(oop obj) {

    if (obj->is_forwarded()) {

      obj->init_mark();

    }

  }

};

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(!Universe::heap()->is_gc_active(), "not reentrant");

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

  assert(heap->kind() == CollectedHeap::ParallelScavengeHeap, "Sanity");

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

    CollectorPolicy* cp = heap->collector_policy();

    const bool clear_all_softrefs = cp->should_clear_all_soft_refs();

    if (UseParallelOldGC) {

      full_gc_done = PSParallelCompact::invoke_no_policy(clear_all_softrefs);

    } else {

      full_gc_done = PSMarkSweep::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");

  assert(_preserved_mark_stack.is_empty(), "should be empty");

  assert(_preserved_oop_stack.is_empty(), "should be empty");

  TimeStamp scavenge_entry;

  TimeStamp scavenge_midpoint;

  TimeStamp scavenge_exit;

  scavenge_entry.update();

  if (GC_locker::check_active_before_gc()) {

    return false;

  }

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

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

  assert(heap->kind() == CollectedHeap::ParallelScavengeHeap, "Sanity");

  // Check for potential problems.

  if (!should_attempt_scavenge()) {

    return false;

  }

  bool promotion_failure_occurred = false;

  PSYoungGen* young_gen = heap->young_gen();

  PSOldGen* old_gen = heap->old_gen();

  PSPermGen* perm_gen = heap->perm_gen();

  PSAdaptiveSizePolicy* size_policy = heap->size_policy();

  heap->increment_total_collections();

  AdaptiveSizePolicyOutput(size_policy, heap->total_collections());

  if ((gc_cause != GCCause::_java_lang_system_gc) ||

       UseAdaptiveSizePolicyWithSystemGC) {

    // Gather the feedback data for eden occupancy.

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

  }

  if (ZapUnusedHeapArea) {

    // Save information needed to minimize mangling

    heap->record_gen_tops_before_GC();

  }

  heap->print_heap_before_gc();

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

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

  size_t prev_used = heap->used();

  assert(promotion_failed() == false, "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

    gclog_or_tty->print(" VerifyBeforeGC:");

    Universe::verify(true);

  }

  {

    ResourceMark rm;

    HandleMark hm;

    gclog_or_tty->date_stamp(PrintGC && PrintGCDateStamps);

    TraceCPUTime tcpu(PrintGCDetails, true, gclog_or_tty);

    TraceTime t1(GCCauseString("GC", gc_cause), PrintGC, !PrintGCDetails, gclog_or_tty);

    TraceCollectorStats tcs(counters());

    TraceMemoryManagerStats tms(false /* not full GC */,gc_cause);

    if (TraceGen0Time) 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();

      perm_gen->verify_object_start_array();

    }

    // Verify no unmarked old->young roots

    if (VerifyRememberedSets) {

      CardTableExtension::verify_all_young_refs_imprecise();

    }

    if (!ScavengeWithObjectsInToSpace) {

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

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

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

    } else if (ZapUnusedHeapArea) {

      young_gen->to_space()->mangle_unused_area();

    }

    save_to_space_top_before_gc();

    COMPILER2_PRESENT(DerivedPointerTable::clear());

    reference_processor()->enable_discovery(true /*verify_disabled*/, true /*verify_no_refs*/);

    reference_processor()->setup_policy(false);

    // We track how much was promoted to the next generation for

    // the AdaptiveSizePolicy.

    size_t old_gen_used_before = old_gen->used_in_bytes();

    // For PrintGCDetails

    size_t young_gen_used_before = young_gen->used_in_bytes();

    // Reset our survivor overflow.

    set_survivor_overflow(false);

    // We need to save the old/perm 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();

    HeapWord* perm_top = perm_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();

    heap->set_par_threads(active_workers);

    PSPromotionManager::pre_scavenge();

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

    PSPromotionManager* promotion_manager = PSPromotionManager::vm_thread_promotion_manager();

    {

      // TraceTime("Roots");

      ParallelScavengeHeap::ParStrongRootsScope psrs;

      GCTaskQueue* q = GCTaskQueue::create();

      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 SerialOldToYoungRootsTask(perm_gen, perm_top));

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

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

      // We scan the thread roots in parallel

      Threads::create_thread_roots_tasks(q);

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

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

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

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

      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 > 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

    {

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

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

        PSRefProcTaskExecutor task_executor;

        reference_processor()->process_discovered_references(

          &_is_alive_closure, &keep_alive, &evac_followers, &task_executor);

      } else {

        reference_processor()->process_discovered_references(

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

      }

    }

    // Enqueue reference objects discovered during scavenge.

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

      PSRefProcTaskExecutor task_executor;

      reference_processor()->enqueue_discovered_references(&task_executor);

    } else {

      reference_processor()->enqueue_discovered_references(NULL);

    }

    if (!JavaObjectsInPerm) {

      // Unlink any dead interned Strings

      StringTable::unlink(&_is_alive_closure);

      // Process the remaining live ones

      PSScavengeRootsClosure root_closure(promotion_manager);

      StringTable::oops_do(&root_closure);

    }

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

    PSPromotionManager::post_scavenge();

    promotion_failure_occurred = promotion_failed();

    if (promotion_failure_occurred) {

      clean_up_failed_promotion();

      if (PrintGC) {

        gclog_or_tty->print("--");

      }

    }

    // 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() - old_gen_used_before;

      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

        if (PrintAdaptiveSizePolicy) {

          gclog_or_tty->print("AdaptiveSizeStart: ");

          gclog_or_tty->stamp();

          gclog_or_tty->print_cr(" collection: %d ",

                         heap->total_collections());

          if (Verbose) {

            gclog_or_tty->print("old_gen_capacity: %d young_gen_capacity: %d"

              " perm_gen_capacity: %d ",

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

              perm_gen->capacity_in_bytes());

          }

        }

        if (UsePerfData) {