src/share/vm/gc_implementation/parallelScavenge/psMarkSweepDecorator.cpp

Thu, 16 Jun 2011 15:51:57 -0400

author
tonyp
date
Thu, 16 Jun 2011 15:51:57 -0400
changeset 2971
c9ca3f51cf41
parent 2314
f95d63e2154a
child 3290
d06a2d7fcd5b
permissions
-rw-r--r--

6994322: Remove the is_tlab and is_noref / is_large_noref parameters from the CollectedHeap
Summary: Remove two unused parameters from the mem_allocate() method and update its uses accordingly.
Reviewed-by: stefank, johnc

duke@435 1 /*
stefank@2314 2 * Copyright (c) 2001, 2010, 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 #include "precompiled.hpp"
stefank@2314 26 #include "classfile/systemDictionary.hpp"
stefank@2314 27 #include "gc_implementation/parallelScavenge/objectStartArray.hpp"
stefank@2314 28 #include "gc_implementation/parallelScavenge/parallelScavengeHeap.hpp"
stefank@2314 29 #include "gc_implementation/parallelScavenge/psMarkSweep.hpp"
stefank@2314 30 #include "gc_implementation/parallelScavenge/psMarkSweepDecorator.hpp"
stefank@2314 31 #include "gc_implementation/shared/liveRange.hpp"
stefank@2314 32 #include "gc_implementation/shared/markSweep.inline.hpp"
stefank@2314 33 #include "gc_implementation/shared/spaceDecorator.hpp"
stefank@2314 34 #include "oops/oop.inline.hpp"
duke@435 35
duke@435 36 PSMarkSweepDecorator* PSMarkSweepDecorator::_destination_decorator = NULL;
duke@435 37
duke@435 38
duke@435 39 void PSMarkSweepDecorator::set_destination_decorator_tenured() {
duke@435 40 ParallelScavengeHeap* heap = (ParallelScavengeHeap*)Universe::heap();
duke@435 41 assert(heap->kind() == CollectedHeap::ParallelScavengeHeap, "Sanity");
duke@435 42
duke@435 43 _destination_decorator = heap->old_gen()->object_mark_sweep();
duke@435 44 }
duke@435 45
duke@435 46 void PSMarkSweepDecorator::set_destination_decorator_perm_gen() {
duke@435 47 ParallelScavengeHeap* heap = (ParallelScavengeHeap*)Universe::heap();
duke@435 48 assert(heap->kind() == CollectedHeap::ParallelScavengeHeap, "Sanity");
duke@435 49
duke@435 50 _destination_decorator = heap->perm_gen()->object_mark_sweep();
duke@435 51 }
duke@435 52
duke@435 53 void PSMarkSweepDecorator::advance_destination_decorator() {
duke@435 54 ParallelScavengeHeap* heap = (ParallelScavengeHeap*)Universe::heap();
duke@435 55 assert(heap->kind() == CollectedHeap::ParallelScavengeHeap, "Sanity");
duke@435 56
duke@435 57 assert(_destination_decorator != NULL, "Sanity");
duke@435 58 guarantee(_destination_decorator != heap->perm_gen()->object_mark_sweep(), "Cannot advance perm gen decorator");
duke@435 59
duke@435 60 PSMarkSweepDecorator* first = heap->old_gen()->object_mark_sweep();
duke@435 61 PSMarkSweepDecorator* second = heap->young_gen()->eden_mark_sweep();
duke@435 62 PSMarkSweepDecorator* third = heap->young_gen()->from_mark_sweep();
duke@435 63 PSMarkSweepDecorator* fourth = heap->young_gen()->to_mark_sweep();
duke@435 64
duke@435 65 if ( _destination_decorator == first ) {
duke@435 66 _destination_decorator = second;
duke@435 67 } else if ( _destination_decorator == second ) {
duke@435 68 _destination_decorator = third;
duke@435 69 } else if ( _destination_decorator == third ) {
duke@435 70 _destination_decorator = fourth;
duke@435 71 } else {
duke@435 72 fatal("PSMarkSweep attempting to advance past last compaction area");
duke@435 73 }
duke@435 74 }
duke@435 75
duke@435 76 PSMarkSweepDecorator* PSMarkSweepDecorator::destination_decorator() {
duke@435 77 assert(_destination_decorator != NULL, "Sanity");
duke@435 78
duke@435 79 return _destination_decorator;
duke@435 80 }
duke@435 81
duke@435 82 // FIX ME FIX ME FIX ME FIX ME!!!!!!!!!
duke@435 83 // The object forwarding code is duplicated. Factor this out!!!!!
duke@435 84 //
duke@435 85 // This method "precompacts" objects inside its space to dest. It places forwarding
duke@435 86 // pointers into markOops for use by adjust_pointers. If "dest" should overflow, we
duke@435 87 // finish by compacting into our own space.
duke@435 88
duke@435 89 void PSMarkSweepDecorator::precompact() {
duke@435 90 // Reset our own compact top.
duke@435 91 set_compaction_top(space()->bottom());
duke@435 92
duke@435 93 /* We allow some amount of garbage towards the bottom of the space, so
duke@435 94 * we don't start compacting before there is a significant gain to be made.
duke@435 95 * Occasionally, we want to ensure a full compaction, which is determined
duke@435 96 * by the MarkSweepAlwaysCompactCount parameter. This is a significant
duke@435 97 * performance improvement!
duke@435 98 */
duke@435 99 bool skip_dead = ((PSMarkSweep::total_invocations() % MarkSweepAlwaysCompactCount) != 0);
duke@435 100
jcoomes@873 101 size_t allowed_deadspace = 0;
duke@435 102 if (skip_dead) {
jcoomes@873 103 const size_t ratio = allowed_dead_ratio();
jcoomes@873 104 allowed_deadspace = space()->capacity_in_words() * ratio / 100;
duke@435 105 }
duke@435 106
duke@435 107 // Fetch the current destination decorator
duke@435 108 PSMarkSweepDecorator* dest = destination_decorator();
duke@435 109 ObjectStartArray* start_array = dest->start_array();
duke@435 110
duke@435 111 HeapWord* compact_top = dest->compaction_top();
duke@435 112 HeapWord* compact_end = dest->space()->end();
duke@435 113
duke@435 114 HeapWord* q = space()->bottom();
duke@435 115 HeapWord* t = space()->top();
duke@435 116
duke@435 117 HeapWord* end_of_live= q; /* One byte beyond the last byte of the last
duke@435 118 live object. */
duke@435 119 HeapWord* first_dead = space()->end(); /* The first dead object. */
duke@435 120 LiveRange* liveRange = NULL; /* The current live range, recorded in the
duke@435 121 first header of preceding free area. */
duke@435 122 _first_dead = first_dead;
duke@435 123
duke@435 124 const intx interval = PrefetchScanIntervalInBytes;
duke@435 125
duke@435 126 while (q < t) {
duke@435 127 assert(oop(q)->mark()->is_marked() || oop(q)->mark()->is_unlocked() ||
duke@435 128 oop(q)->mark()->has_bias_pattern(),
duke@435 129 "these are the only valid states during a mark sweep");
duke@435 130 if (oop(q)->is_gc_marked()) {
duke@435 131 /* prefetch beyond q */
duke@435 132 Prefetch::write(q, interval);
duke@435 133 size_t size = oop(q)->size();
duke@435 134
duke@435 135 size_t compaction_max_size = pointer_delta(compact_end, compact_top);
duke@435 136
duke@435 137 // This should only happen if a space in the young gen overflows the
duke@435 138 // old gen. If that should happen, we null out the start_array, because
duke@435 139 // the young spaces are not covered by one.
duke@435 140 while(size > compaction_max_size) {
duke@435 141 // First record the last compact_top
duke@435 142 dest->set_compaction_top(compact_top);
duke@435 143
duke@435 144 // Advance to the next compaction decorator
duke@435 145 advance_destination_decorator();
duke@435 146 dest = destination_decorator();
duke@435 147
duke@435 148 // Update compaction info
duke@435 149 start_array = dest->start_array();
duke@435 150 compact_top = dest->compaction_top();
duke@435 151 compact_end = dest->space()->end();
duke@435 152 assert(compact_top == dest->space()->bottom(), "Advanced to space already in use");
duke@435 153 assert(compact_end > compact_top, "Must always be space remaining");
duke@435 154 compaction_max_size =
duke@435 155 pointer_delta(compact_end, compact_top);
duke@435 156 }
duke@435 157
duke@435 158 // store the forwarding pointer into the mark word
duke@435 159 if (q != compact_top) {
duke@435 160 oop(q)->forward_to(oop(compact_top));
duke@435 161 assert(oop(q)->is_gc_marked(), "encoding the pointer should preserve the mark");
duke@435 162 } else {
jcoomes@809 163 // if the object isn't moving we can just set the mark to the default
jcoomes@809 164 // mark and handle it specially later on.
jcoomes@809 165 oop(q)->init_mark();
duke@435 166 assert(oop(q)->forwardee() == NULL, "should be forwarded to NULL");
duke@435 167 }
duke@435 168
duke@435 169 // Update object start array
jcoomes@809 170 if (start_array) {
jcoomes@809 171 start_array->allocate_block(compact_top);
duke@435 172 }
duke@435 173
coleenp@548 174 VALIDATE_MARK_SWEEP_ONLY(MarkSweep::register_live_oop(oop(q), size));
duke@435 175 compact_top += size;
duke@435 176 assert(compact_top <= dest->space()->end(),
duke@435 177 "Exceeding space in destination");
duke@435 178
duke@435 179 q += size;
duke@435 180 end_of_live = q;
duke@435 181 } else {
duke@435 182 /* run over all the contiguous dead objects */
duke@435 183 HeapWord* end = q;
duke@435 184 do {
duke@435 185 /* prefetch beyond end */
duke@435 186 Prefetch::write(end, interval);
duke@435 187 end += oop(end)->size();
duke@435 188 } while (end < t && (!oop(end)->is_gc_marked()));
duke@435 189
duke@435 190 /* see if we might want to pretend this object is alive so that
duke@435 191 * we don't have to compact quite as often.
duke@435 192 */
duke@435 193 if (allowed_deadspace > 0 && q == compact_top) {
duke@435 194 size_t sz = pointer_delta(end, q);
duke@435 195 if (insert_deadspace(allowed_deadspace, q, sz)) {
duke@435 196 size_t compaction_max_size = pointer_delta(compact_end, compact_top);
duke@435 197
duke@435 198 // This should only happen if a space in the young gen overflows the
duke@435 199 // old gen. If that should happen, we null out the start_array, because
duke@435 200 // the young spaces are not covered by one.
duke@435 201 while (sz > compaction_max_size) {
duke@435 202 // First record the last compact_top
duke@435 203 dest->set_compaction_top(compact_top);
duke@435 204
duke@435 205 // Advance to the next compaction decorator
duke@435 206 advance_destination_decorator();
duke@435 207 dest = destination_decorator();
duke@435 208
duke@435 209 // Update compaction info
duke@435 210 start_array = dest->start_array();
duke@435 211 compact_top = dest->compaction_top();
duke@435 212 compact_end = dest->space()->end();
duke@435 213 assert(compact_top == dest->space()->bottom(), "Advanced to space already in use");
duke@435 214 assert(compact_end > compact_top, "Must always be space remaining");
duke@435 215 compaction_max_size =
duke@435 216 pointer_delta(compact_end, compact_top);
duke@435 217 }
duke@435 218
duke@435 219 // store the forwarding pointer into the mark word
duke@435 220 if (q != compact_top) {
duke@435 221 oop(q)->forward_to(oop(compact_top));
duke@435 222 assert(oop(q)->is_gc_marked(), "encoding the pointer should preserve the mark");
duke@435 223 } else {
duke@435 224 // if the object isn't moving we can just set the mark to the default
jcoomes@809 225 // mark and handle it specially later on.
jcoomes@809 226 oop(q)->init_mark();
duke@435 227 assert(oop(q)->forwardee() == NULL, "should be forwarded to NULL");
duke@435 228 }
duke@435 229
jcoomes@809 230 // Update object start array
jcoomes@809 231 if (start_array) {
jcoomes@809 232 start_array->allocate_block(compact_top);
duke@435 233 }
duke@435 234
coleenp@548 235 VALIDATE_MARK_SWEEP_ONLY(MarkSweep::register_live_oop(oop(q), sz));
duke@435 236 compact_top += sz;
duke@435 237 assert(compact_top <= dest->space()->end(),
duke@435 238 "Exceeding space in destination");
duke@435 239
duke@435 240 q = end;
duke@435 241 end_of_live = end;
duke@435 242 continue;
duke@435 243 }
duke@435 244 }
duke@435 245
duke@435 246 /* for the previous LiveRange, record the end of the live objects. */
duke@435 247 if (liveRange) {
duke@435 248 liveRange->set_end(q);
duke@435 249 }
duke@435 250
duke@435 251 /* record the current LiveRange object.
duke@435 252 * liveRange->start() is overlaid on the mark word.
duke@435 253 */
duke@435 254 liveRange = (LiveRange*)q;
duke@435 255 liveRange->set_start(end);
duke@435 256 liveRange->set_end(end);
duke@435 257
duke@435 258 /* see if this is the first dead region. */
duke@435 259 if (q < first_dead) {
duke@435 260 first_dead = q;
duke@435 261 }
duke@435 262
duke@435 263 /* move on to the next object */
duke@435 264 q = end;
duke@435 265 }
duke@435 266 }
duke@435 267
duke@435 268 assert(q == t, "just checking");
duke@435 269 if (liveRange != NULL) {
duke@435 270 liveRange->set_end(q);
duke@435 271 }
duke@435 272 _end_of_live = end_of_live;
duke@435 273 if (end_of_live < first_dead) {
duke@435 274 first_dead = end_of_live;
duke@435 275 }
duke@435 276 _first_dead = first_dead;
duke@435 277
duke@435 278 // Update compaction top
duke@435 279 dest->set_compaction_top(compact_top);
duke@435 280 }
duke@435 281
jcoomes@873 282 bool PSMarkSweepDecorator::insert_deadspace(size_t& allowed_deadspace_words,
jcoomes@873 283 HeapWord* q, size_t deadlength) {
jcoomes@873 284 if (allowed_deadspace_words >= deadlength) {
jcoomes@873 285 allowed_deadspace_words -= deadlength;
jcoomes@916 286 CollectedHeap::fill_with_object(q, deadlength);
jcoomes@916 287 oop(q)->set_mark(oop(q)->mark()->set_marked());
jcoomes@916 288 assert((int) deadlength == oop(q)->size(), "bad filler object size");
duke@435 289 // Recall that we required "q == compaction_top".
duke@435 290 return true;
duke@435 291 } else {
duke@435 292 allowed_deadspace_words = 0;
duke@435 293 return false;
duke@435 294 }
duke@435 295 }
duke@435 296
duke@435 297 void PSMarkSweepDecorator::adjust_pointers() {
duke@435 298 // adjust all the interior pointers to point at the new locations of objects
duke@435 299 // Used by MarkSweep::mark_sweep_phase3()
duke@435 300
duke@435 301 HeapWord* q = space()->bottom();
duke@435 302 HeapWord* t = _end_of_live; // Established by "prepare_for_compaction".
duke@435 303
duke@435 304 assert(_first_dead <= _end_of_live, "Stands to reason, no?");
duke@435 305
duke@435 306 if (q < t && _first_dead > q &&
duke@435 307 !oop(q)->is_gc_marked()) {
duke@435 308 // we have a chunk of the space which hasn't moved and we've
duke@435 309 // reinitialized the mark word during the previous pass, so we can't
duke@435 310 // use is_gc_marked for the traversal.
duke@435 311 HeapWord* end = _first_dead;
duke@435 312
duke@435 313 while (q < end) {
coleenp@548 314 VALIDATE_MARK_SWEEP_ONLY(MarkSweep::track_interior_pointers(oop(q)));
duke@435 315 // point all the oops to the new location
duke@435 316 size_t size = oop(q)->adjust_pointers();
coleenp@548 317 VALIDATE_MARK_SWEEP_ONLY(MarkSweep::check_interior_pointers());
coleenp@548 318 VALIDATE_MARK_SWEEP_ONLY(MarkSweep::validate_live_oop(oop(q), size));
duke@435 319 q += size;
duke@435 320 }
duke@435 321
duke@435 322 if (_first_dead == t) {
duke@435 323 q = t;
duke@435 324 } else {
duke@435 325 // $$$ This is funky. Using this to read the previously written
duke@435 326 // LiveRange. See also use below.
duke@435 327 q = (HeapWord*)oop(_first_dead)->mark()->decode_pointer();
duke@435 328 }
duke@435 329 }
duke@435 330 const intx interval = PrefetchScanIntervalInBytes;
duke@435 331
duke@435 332 debug_only(HeapWord* prev_q = NULL);
duke@435 333 while (q < t) {
duke@435 334 // prefetch beyond q
duke@435 335 Prefetch::write(q, interval);
duke@435 336 if (oop(q)->is_gc_marked()) {
duke@435 337 // q is alive
coleenp@548 338 VALIDATE_MARK_SWEEP_ONLY(MarkSweep::track_interior_pointers(oop(q)));
duke@435 339 // point all the oops to the new location
duke@435 340 size_t size = oop(q)->adjust_pointers();
coleenp@548 341 VALIDATE_MARK_SWEEP_ONLY(MarkSweep::check_interior_pointers());
coleenp@548 342 VALIDATE_MARK_SWEEP_ONLY(MarkSweep::validate_live_oop(oop(q), size));
duke@435 343 debug_only(prev_q = q);
duke@435 344 q += size;
duke@435 345 } else {
duke@435 346 // q is not a live object, so its mark should point at the next
duke@435 347 // live object
duke@435 348 debug_only(prev_q = q);
duke@435 349 q = (HeapWord*) oop(q)->mark()->decode_pointer();
duke@435 350 assert(q > prev_q, "we should be moving forward through memory");
duke@435 351 }
duke@435 352 }
duke@435 353
duke@435 354 assert(q == t, "just checking");
duke@435 355 }
duke@435 356
duke@435 357 void PSMarkSweepDecorator::compact(bool mangle_free_space ) {
duke@435 358 // Copy all live objects to their new location
duke@435 359 // Used by MarkSweep::mark_sweep_phase4()
duke@435 360
duke@435 361 HeapWord* q = space()->bottom();
duke@435 362 HeapWord* const t = _end_of_live;
duke@435 363 debug_only(HeapWord* prev_q = NULL);
duke@435 364
duke@435 365 if (q < t && _first_dead > q &&
duke@435 366 !oop(q)->is_gc_marked()) {
duke@435 367 #ifdef ASSERT
duke@435 368 // we have a chunk of the space which hasn't moved and we've reinitialized the
duke@435 369 // mark word during the previous pass, so we can't use is_gc_marked for the
duke@435 370 // traversal.
duke@435 371 HeapWord* const end = _first_dead;
duke@435 372
duke@435 373 while (q < end) {
duke@435 374 size_t size = oop(q)->size();
duke@435 375 assert(!oop(q)->is_gc_marked(), "should be unmarked (special dense prefix handling)");
coleenp@548 376 VALIDATE_MARK_SWEEP_ONLY(MarkSweep::live_oop_moved_to(q, size, q));
duke@435 377 debug_only(prev_q = q);
duke@435 378 q += size;
duke@435 379 }
duke@435 380 #endif
duke@435 381
duke@435 382 if (_first_dead == t) {
duke@435 383 q = t;
duke@435 384 } else {
duke@435 385 // $$$ Funky
duke@435 386 q = (HeapWord*) oop(_first_dead)->mark()->decode_pointer();
duke@435 387 }
duke@435 388 }
duke@435 389
duke@435 390 const intx scan_interval = PrefetchScanIntervalInBytes;
duke@435 391 const intx copy_interval = PrefetchCopyIntervalInBytes;
duke@435 392
duke@435 393 while (q < t) {
duke@435 394 if (!oop(q)->is_gc_marked()) {
duke@435 395 // mark is pointer to next marked oop
duke@435 396 debug_only(prev_q = q);
duke@435 397 q = (HeapWord*) oop(q)->mark()->decode_pointer();
duke@435 398 assert(q > prev_q, "we should be moving forward through memory");
duke@435 399 } else {
duke@435 400 // prefetch beyond q
duke@435 401 Prefetch::read(q, scan_interval);
duke@435 402
duke@435 403 // size and destination
duke@435 404 size_t size = oop(q)->size();
duke@435 405 HeapWord* compaction_top = (HeapWord*)oop(q)->forwardee();
duke@435 406
duke@435 407 // prefetch beyond compaction_top
duke@435 408 Prefetch::write(compaction_top, copy_interval);
duke@435 409
duke@435 410 // copy object and reinit its mark
coleenp@548 411 VALIDATE_MARK_SWEEP_ONLY(MarkSweep::live_oop_moved_to(q, size, compaction_top));
duke@435 412 assert(q != compaction_top, "everything in this pass should be moving");
duke@435 413 Copy::aligned_conjoint_words(q, compaction_top, size);
duke@435 414 oop(compaction_top)->init_mark();
duke@435 415 assert(oop(compaction_top)->klass() != NULL, "should have a class");
duke@435 416
duke@435 417 debug_only(prev_q = q);
duke@435 418 q += size;
duke@435 419 }
duke@435 420 }
duke@435 421
duke@435 422 assert(compaction_top() >= space()->bottom() && compaction_top() <= space()->end(),
duke@435 423 "should point inside space");
duke@435 424 space()->set_top(compaction_top());
duke@435 425
jmasa@698 426 if (mangle_free_space) {
jmasa@698 427 space()->mangle_unused_area();
jmasa@698 428 }
duke@435 429 }

mercurial