src/share/vm/gc/g1/g1ParScanThreadState.cpp

rev 8813 : imported patch 8003237-no-wait-for-free-list
rev 8814 : imported patch jon-fast-evac-failure
rev 8815 : [mq]: bengt-jon-more-naming
rev 8816 : [mq]: 8133470-fix-plab-inline
rev 8817 : imported patch 8073013-add-detailed-information-about-plab-memory-usage
rev 8823 : imported patch 8040162-avoid-reallocating-plab-allocators

*** 30,50 ****
  #include "gc/g1/g1StringDedup.hpp"
  #include "gc/shared/taskqueue.inline.hpp"
  #include "oops/oop.inline.hpp"
  #include "runtime/prefetch.inline.hpp"
  
! G1ParScanThreadState::G1ParScanThreadState(G1CollectedHeap* g1h, uint worker_id, ReferenceProcessor* rp)
    : _g1h(g1h),
      _refs(g1h->task_queue(worker_id)),
      _dcq(&g1h->dirty_card_queue_set()),
      _ct_bs(g1h->g1_barrier_set()),
      _g1_rem(g1h->g1_rem_set()),
!     _hash_seed(17), _worker_id(worker_id),
!     _term_attempts(0),
      _tenuring_threshold(g1h->g1_policy()->tenuring_threshold()),
!     _age_table(false), _scanner(g1h, rp),
!     _strong_roots_time(0), _term_time(0),
      _old_gen_is_full(false)
  {
    _scanner.set_par_scan_thread_state(this);
    // we allocate G1YoungSurvRateNumRegions plus one entries, since
    // we "sacrifice" entry 0 to keep track of surviving bytes for
--- 30,50 ----
  #include "gc/g1/g1StringDedup.hpp"
  #include "gc/shared/taskqueue.inline.hpp"
  #include "oops/oop.inline.hpp"
  #include "runtime/prefetch.inline.hpp"
  
! G1ParScanThreadState::G1ParScanThreadState(G1CollectedHeap* g1h, uint worker_id)
    : _g1h(g1h),
      _refs(g1h->task_queue(worker_id)),
      _dcq(&g1h->dirty_card_queue_set()),
      _ct_bs(g1h->g1_barrier_set()),
      _g1_rem(g1h->g1_rem_set()),
!     _hash_seed(17),
!     _worker_id(worker_id),
      _tenuring_threshold(g1h->g1_policy()->tenuring_threshold()),
!     _age_table(false),
!     _scanner(g1h),
      _old_gen_is_full(false)
  {
    _scanner.set_par_scan_thread_state(this);
    // we allocate G1YoungSurvRateNumRegions plus one entries, since
    // we "sacrifice" entry 0 to keep track of surviving bytes for
*** 67,108 ****
    _dest[InCSetState::NotInCSet]    = InCSetState::NotInCSet;
    // The dest for Young is used when the objects are aged enough to
    // need to be moved to the next space.
    _dest[InCSetState::Young]        = InCSetState::Old;
    _dest[InCSetState::Old]          = InCSetState::Old;
- 
-   _start = os::elapsedTime();
  }
  
  G1ParScanThreadState::~G1ParScanThreadState() {
    _plab_allocator->flush_and_retire_stats();
    delete _plab_allocator;
    FREE_C_HEAP_ARRAY(size_t, _surviving_young_words_base);
  }
  
! void G1ParScanThreadState::print_termination_stats_hdr(outputStream* const st) {
!   st->print_raw_cr("GC Termination Stats");
!   st->print_raw_cr("     elapsed  --strong roots-- -------termination------- ------waste (KiB)------");
!   st->print_raw_cr("thr     ms        ms      %        ms      %    attempts  total   alloc    undo");
!   st->print_raw_cr("--- --------- --------- ------ --------- ------ -------- ------- ------- -------");
! }
! 
! void G1ParScanThreadState::print_termination_stats(outputStream* const st) const {
!   const double elapsed_ms = elapsed_time() * 1000.0;
!   const double s_roots_ms = strong_roots_time() * 1000.0;
!   const double term_ms    = term_time() * 1000.0;
!   size_t alloc_buffer_waste = 0;
!   size_t undo_waste = 0;
!   _plab_allocator->waste(alloc_buffer_waste, undo_waste);
!   st->print_cr("%3u %9.2f %9.2f %6.2f "
!                "%9.2f %6.2f " SIZE_FORMAT_W(8) " "
!                SIZE_FORMAT_W(7) " " SIZE_FORMAT_W(7) " " SIZE_FORMAT_W(7),
!                _worker_id, elapsed_ms, s_roots_ms, s_roots_ms * 100 / elapsed_ms,
!                term_ms, term_ms * 100 / elapsed_ms, term_attempts(),
!                (alloc_buffer_waste + undo_waste) * HeapWordSize / K,
!                alloc_buffer_waste * HeapWordSize / K,
!                undo_waste * HeapWordSize / K);
  }
  
  #ifdef ASSERT
  bool G1ParScanThreadState::verify_ref(narrowOop* ref) const {
    assert(ref != NULL, "invariant");
--- 67,86 ----
    _dest[InCSetState::NotInCSet]    = InCSetState::NotInCSet;
    // The dest for Young is used when the objects are aged enough to
    // need to be moved to the next space.
    _dest[InCSetState::Young]        = InCSetState::Old;
    _dest[InCSetState::Old]          = InCSetState::Old;
  }
  
  G1ParScanThreadState::~G1ParScanThreadState() {
    _plab_allocator->flush_and_retire_stats();
    delete _plab_allocator;
    FREE_C_HEAP_ARRAY(size_t, _surviving_young_words_base);
  }
  
! void G1ParScanThreadState::waste(size_t& wasted, size_t& undo_wasted) {
!   _plab_allocator->waste(wasted, undo_wasted);
  }
  
  #ifdef ASSERT
  bool G1ParScanThreadState::verify_ref(narrowOop* ref) const {
    assert(ref != NULL, "invariant");
*** 290,301 ****
                                               is_to_young,
                                               _worker_id,
                                               obj);
      }
  
!     size_t* const surv_young_words = surviving_young_words();
!     surv_young_words[young_index] += word_sz;
  
      if (obj->is_objArray() && arrayOop(obj)->length() >= ParGCArrayScanChunk) {
        // We keep track of the next start index in the length field of
        // the to-space object. The actual length can be found in the
        // length field of the from-space object.
--- 268,278 ----
                                               is_to_young,
                                               _worker_id,
                                               obj);
      }
  
!     _surviving_young_words[young_index] += word_sz;
  
      if (obj->is_objArray() && arrayOop(obj)->length() >= ParGCArrayScanChunk) {
        // We keep track of the next start index in the length field of
        // the to-space object. The actual length can be found in the
        // length field of the from-space object.