src/share/vm/gc_implementation/shared/parGCAllocBuffer.hpp

Thu, 13 Feb 2014 17:44:39 +0100

author
stefank
date
Thu, 13 Feb 2014 17:44:39 +0100
changeset 6971
7426d8d76305
parent 6929
983092f35ff7
child 7031
ee019285a52c
permissions
-rw-r--r--

8034761: Remove the do_code_roots parameter from process_strong_roots
Reviewed-by: tschatzl, mgerdin, jmasa

duke@435 1 /*
mikael@6198 2 * Copyright (c) 2001, 2013, Oracle and/or its affiliates. All rights reserved.
duke@435 3 * DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS FILE HEADER.
duke@435 4 *
duke@435 5 * This code is free software; you can redistribute it and/or modify it
duke@435 6 * under the terms of the GNU General Public License version 2 only, as
duke@435 7 * published by the Free Software Foundation.
duke@435 8 *
duke@435 9 * This code is distributed in the hope that it will be useful, but WITHOUT
duke@435 10 * ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or
duke@435 11 * FITNESS FOR A PARTICULAR PURPOSE. See the GNU General Public License
duke@435 12 * version 2 for more details (a copy is included in the LICENSE file that
duke@435 13 * accompanied this code).
duke@435 14 *
duke@435 15 * You should have received a copy of the GNU General Public License version
duke@435 16 * 2 along with this work; if not, write to the Free Software Foundation,
duke@435 17 * Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA.
duke@435 18 *
trims@1907 19 * Please contact Oracle, 500 Oracle Parkway, Redwood Shores, CA 94065 USA
trims@1907 20 * or visit www.oracle.com if you need additional information or have any
trims@1907 21 * questions.
duke@435 22 *
duke@435 23 */
duke@435 24
stefank@2314 25 #ifndef SHARE_VM_GC_IMPLEMENTATION_PARNEW_PARGCALLOCBUFFER_HPP
stefank@2314 26 #define SHARE_VM_GC_IMPLEMENTATION_PARNEW_PARGCALLOCBUFFER_HPP
stefank@2314 27
stefank@2314 28 #include "memory/allocation.hpp"
stefank@2325 29 #include "memory/blockOffsetTable.hpp"
stefank@2314 30 #include "memory/threadLocalAllocBuffer.hpp"
stefank@2314 31 #include "utilities/globalDefinitions.hpp"
stefank@2314 32
duke@435 33 // Forward decl.
duke@435 34
duke@435 35 class PLABStats;
duke@435 36
duke@435 37 // A per-thread allocation buffer used during GC.
zgu@3900 38 class ParGCAllocBuffer: public CHeapObj<mtGC> {
duke@435 39 protected:
duke@435 40 char head[32];
duke@435 41 size_t _word_sz; // in HeapWord units
duke@435 42 HeapWord* _bottom;
duke@435 43 HeapWord* _top;
duke@435 44 HeapWord* _end; // last allocatable address + 1
duke@435 45 HeapWord* _hard_end; // _end + AlignmentReserve
duke@435 46 bool _retained; // whether we hold a _retained_filler
duke@435 47 MemRegion _retained_filler;
duke@435 48 // In support of ergonomic sizing of PLAB's
duke@435 49 size_t _allocated; // in HeapWord units
duke@435 50 size_t _wasted; // in HeapWord units
duke@435 51 char tail[32];
coleenp@548 52 static size_t FillerHeaderSize;
coleenp@548 53 static size_t AlignmentReserve;
duke@435 54
johnc@4067 55 // Flush the stats supporting ergonomic sizing of PLAB's
johnc@4067 56 // Should not be called directly
johnc@4067 57 void flush_stats(PLABStats* stats);
johnc@4067 58
duke@435 59 public:
duke@435 60 // Initializes the buffer to be empty, but with the given "word_sz".
duke@435 61 // Must get initialized with "set_buf" for an allocation to succeed.
duke@435 62 ParGCAllocBuffer(size_t word_sz);
tschatzl@6929 63 virtual ~ParGCAllocBuffer() {}
duke@435 64
duke@435 65 static const size_t min_size() {
duke@435 66 return ThreadLocalAllocBuffer::min_size();
duke@435 67 }
duke@435 68
duke@435 69 static const size_t max_size() {
duke@435 70 return ThreadLocalAllocBuffer::max_size();
duke@435 71 }
duke@435 72
duke@435 73 // If an allocation of the given "word_sz" can be satisfied within the
duke@435 74 // buffer, do the allocation, returning a pointer to the start of the
duke@435 75 // allocated block. If the allocation request cannot be satisfied,
duke@435 76 // return NULL.
duke@435 77 HeapWord* allocate(size_t word_sz) {
duke@435 78 HeapWord* res = _top;
ysr@1069 79 if (pointer_delta(_end, _top) >= word_sz) {
ysr@1069 80 _top = _top + word_sz;
duke@435 81 return res;
duke@435 82 } else {
duke@435 83 return NULL;
duke@435 84 }
duke@435 85 }
duke@435 86
duke@435 87 // Undo the last allocation in the buffer, which is required to be of the
duke@435 88 // "obj" of the given "word_sz".
duke@435 89 void undo_allocation(HeapWord* obj, size_t word_sz) {
ysr@1069 90 assert(pointer_delta(_top, _bottom) >= word_sz, "Bad undo");
ysr@1069 91 assert(pointer_delta(_top, obj) == word_sz, "Bad undo");
ysr@1069 92 _top = obj;
duke@435 93 }
duke@435 94
duke@435 95 // The total (word) size of the buffer, including both allocated and
duke@435 96 // unallocted space.
duke@435 97 size_t word_sz() { return _word_sz; }
duke@435 98
duke@435 99 // Should only be done if we are about to reset with a new buffer of the
duke@435 100 // given size.
duke@435 101 void set_word_size(size_t new_word_sz) {
duke@435 102 assert(new_word_sz > AlignmentReserve, "Too small");
duke@435 103 _word_sz = new_word_sz;
duke@435 104 }
duke@435 105
duke@435 106 // The number of words of unallocated space remaining in the buffer.
duke@435 107 size_t words_remaining() {
duke@435 108 assert(_end >= _top, "Negative buffer");
duke@435 109 return pointer_delta(_end, _top, HeapWordSize);
duke@435 110 }
duke@435 111
duke@435 112 bool contains(void* addr) {
duke@435 113 return (void*)_bottom <= addr && addr < (void*)_hard_end;
duke@435 114 }
duke@435 115
duke@435 116 // Sets the space of the buffer to be [buf, space+word_sz()).
tschatzl@6929 117 virtual void set_buf(HeapWord* buf) {
duke@435 118 _bottom = buf;
duke@435 119 _top = _bottom;
duke@435 120 _hard_end = _bottom + word_sz();
duke@435 121 _end = _hard_end - AlignmentReserve;
duke@435 122 assert(_end >= _top, "Negative buffer");
duke@435 123 // In support of ergonomic sizing
duke@435 124 _allocated += word_sz();
duke@435 125 }
duke@435 126
duke@435 127 // Flush the stats supporting ergonomic sizing of PLAB's
johnc@4067 128 // and retire the current buffer.
johnc@3982 129 void flush_stats_and_retire(PLABStats* stats, bool end_of_gc, bool retain) {
duke@435 130 // We flush the stats first in order to get a reading of
duke@435 131 // unused space in the last buffer.
duke@435 132 if (ResizePLAB) {
duke@435 133 flush_stats(stats);
johnc@4067 134
johnc@4067 135 // Since we have flushed the stats we need to clear
johnc@4067 136 // the _allocated and _wasted fields. Not doing so
johnc@4067 137 // will artifically inflate the values in the stats
johnc@4067 138 // to which we add them.
johnc@4067 139 // The next time we flush these values, we will add
johnc@4067 140 // what we have just flushed in addition to the size
johnc@4067 141 // of the buffers allocated between now and then.
johnc@4067 142 _allocated = 0;
johnc@4067 143 _wasted = 0;
duke@435 144 }
duke@435 145 // Retire the last allocation buffer.
johnc@3982 146 retire(end_of_gc, retain);
duke@435 147 }
duke@435 148
duke@435 149 // Force future allocations to fail and queries for contains()
duke@435 150 // to return false
duke@435 151 void invalidate() {
duke@435 152 assert(!_retained, "Shouldn't retain an invalidated buffer.");
duke@435 153 _end = _hard_end;
duke@435 154 _wasted += pointer_delta(_end, _top); // unused space
duke@435 155 _top = _end; // force future allocations to fail
duke@435 156 _bottom = _end; // force future contains() queries to return false
duke@435 157 }
duke@435 158
duke@435 159 // Fills in the unallocated portion of the buffer with a garbage object.
duke@435 160 // If "end_of_gc" is TRUE, is after the last use in the GC. IF "retain"
duke@435 161 // is true, attempt to re-use the unused portion in the next GC.
tschatzl@6929 162 virtual void retire(bool end_of_gc, bool retain);
duke@435 163
duke@435 164 void print() PRODUCT_RETURN;
duke@435 165 };
duke@435 166
duke@435 167 // PLAB stats book-keeping
duke@435 168 class PLABStats VALUE_OBJ_CLASS_SPEC {
duke@435 169 size_t _allocated; // total allocated
duke@435 170 size_t _wasted; // of which wasted (internal fragmentation)
duke@435 171 size_t _unused; // Unused in last buffer
duke@435 172 size_t _used; // derived = allocated - wasted - unused
duke@435 173 size_t _desired_plab_sz;// output of filter (below), suitably trimmed and quantized
duke@435 174 AdaptiveWeightedAverage
duke@435 175 _filter; // integrator with decay
duke@435 176
duke@435 177 public:
duke@435 178 PLABStats(size_t desired_plab_sz_, unsigned wt) :
duke@435 179 _allocated(0),
duke@435 180 _wasted(0),
duke@435 181 _unused(0),
duke@435 182 _used(0),
duke@435 183 _desired_plab_sz(desired_plab_sz_),
duke@435 184 _filter(wt)
brutisso@6376 185 { }
duke@435 186
duke@435 187 static const size_t min_size() {
duke@435 188 return ParGCAllocBuffer::min_size();
duke@435 189 }
duke@435 190
duke@435 191 static const size_t max_size() {
duke@435 192 return ParGCAllocBuffer::max_size();
duke@435 193 }
duke@435 194
duke@435 195 size_t desired_plab_sz() {
duke@435 196 return _desired_plab_sz;
duke@435 197 }
duke@435 198
johnc@4130 199 void adjust_desired_plab_sz(uint no_of_gc_workers);
johnc@4130 200 // filter computation, latches output to
duke@435 201 // _desired_plab_sz, clears sensor accumulators
duke@435 202
duke@435 203 void add_allocated(size_t v) {
duke@435 204 Atomic::add_ptr(v, &_allocated);
duke@435 205 }
duke@435 206
duke@435 207 void add_unused(size_t v) {
duke@435 208 Atomic::add_ptr(v, &_unused);
duke@435 209 }
duke@435 210
duke@435 211 void add_wasted(size_t v) {
duke@435 212 Atomic::add_ptr(v, &_wasted);
duke@435 213 }
duke@435 214 };
duke@435 215
duke@435 216 class ParGCAllocBufferWithBOT: public ParGCAllocBuffer {
duke@435 217 BlockOffsetArrayContigSpace _bt;
duke@435 218 BlockOffsetSharedArray* _bsa;
duke@435 219 HeapWord* _true_end; // end of the whole ParGCAllocBuffer
duke@435 220
duke@435 221 static const size_t ChunkSizeInWords;
duke@435 222 static const size_t ChunkSizeInBytes;
duke@435 223 HeapWord* allocate_slow(size_t word_sz);
duke@435 224
duke@435 225 void fill_region_with_block(MemRegion mr, bool contig);
duke@435 226
duke@435 227 public:
duke@435 228 ParGCAllocBufferWithBOT(size_t word_sz, BlockOffsetSharedArray* bsa);
duke@435 229
duke@435 230 HeapWord* allocate(size_t word_sz) {
duke@435 231 HeapWord* res = ParGCAllocBuffer::allocate(word_sz);
duke@435 232 if (res != NULL) {
duke@435 233 _bt.alloc_block(res, word_sz);
duke@435 234 } else {
duke@435 235 res = allocate_slow(word_sz);
duke@435 236 }
duke@435 237 return res;
duke@435 238 }
duke@435 239
duke@435 240 void undo_allocation(HeapWord* obj, size_t word_sz);
duke@435 241
tschatzl@6929 242 virtual void set_buf(HeapWord* buf_start) {
duke@435 243 ParGCAllocBuffer::set_buf(buf_start);
duke@435 244 _true_end = _hard_end;
duke@435 245 _bt.set_region(MemRegion(buf_start, word_sz()));
duke@435 246 _bt.initialize_threshold();
duke@435 247 }
duke@435 248
tschatzl@6929 249 virtual void retire(bool end_of_gc, bool retain);
duke@435 250
duke@435 251 MemRegion range() {
duke@435 252 return MemRegion(_top, _true_end);
duke@435 253 }
duke@435 254 };
stefank@2314 255
stefank@2314 256 #endif // SHARE_VM_GC_IMPLEMENTATION_PARNEW_PARGCALLOCBUFFER_HPP

mercurial