Mercurial > jdk8-mips64-public > hotspot / annotate

src/share/vm/gc_implementation/parallelScavenge/pcTasks.cpp@8b46c4d82093 (annotated)

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

Wed, 02 Sep 2009 00:04:29 -0700

author
ysr
date
Wed, 02 Sep 2009 00:04:29 -0700
changeset 1376
8b46c4d82093
parent 810
81cd571500b0
child 1383
89e0543e1737
child 1428
54b3b351d6f9
permissions
-rw-r--r--

4957990: Perm heap bloat in JVM
Summary: Treat ProfileData in MDO's as a source of weak, not strong, roots. Fixes the bug for stop-world collection -- the case of concurrent collection will be fixed separately.
Reviewed-by: jcoomes, jmasa, kvn, never

duke@435 1 /*
xdono@631 2 * Copyright 2005-2008 Sun Microsystems, Inc. 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 *
duke@435 19 * Please contact Sun Microsystems, Inc., 4150 Network Circle, Santa Clara,
duke@435 20 * CA 95054 USA or visit www.sun.com if you need additional information or
duke@435 21 * have any questions.
duke@435 22 *
duke@435 23 */
duke@435 24
duke@435 25 # include "incls/_precompiled.incl"
duke@435 26 # include "incls/_pcTasks.cpp.incl"
duke@435 27
duke@435 28 //
duke@435 29 // ThreadRootsMarkingTask
duke@435 30 //
duke@435 31
duke@435 32 void ThreadRootsMarkingTask::do_it(GCTaskManager* manager, uint which) {
duke@435 33 assert(Universe::heap()->is_gc_active(), "called outside gc");
duke@435 34
duke@435 35 ResourceMark rm;
duke@435 36
duke@435 37 NOT_PRODUCT(TraceTime tm("ThreadRootsMarkingTask",
duke@435 38 PrintGCDetails && TraceParallelOldGCTasks, true, gclog_or_tty));
duke@435 39 ParCompactionManager* cm =
duke@435 40 ParCompactionManager::gc_thread_compaction_manager(which);
duke@435 41 PSParallelCompact::MarkAndPushClosure mark_and_push_closure(cm);
duke@435 42
duke@435 43 if (_java_thread != NULL)
duke@435 44 _java_thread->oops_do(&mark_and_push_closure);
duke@435 45
duke@435 46 if (_vm_thread != NULL)
duke@435 47 _vm_thread->oops_do(&mark_and_push_closure);
duke@435 48
duke@435 49 // Do the real work
duke@435 50 cm->drain_marking_stacks(&mark_and_push_closure);
duke@435 51 }
duke@435 52
duke@435 53
duke@435 54 void MarkFromRootsTask::do_it(GCTaskManager* manager, uint which) {
duke@435 55 assert(Universe::heap()->is_gc_active(), "called outside gc");
duke@435 56
duke@435 57 NOT_PRODUCT(TraceTime tm("MarkFromRootsTask",
duke@435 58 PrintGCDetails && TraceParallelOldGCTasks, true, gclog_or_tty));
duke@435 59 ParCompactionManager* cm =
duke@435 60 ParCompactionManager::gc_thread_compaction_manager(which);
duke@435 61 assert(cm->stacks_have_been_allocated(),
ysr@1376 62 "Stack space has not been allocated");
duke@435 63 PSParallelCompact::MarkAndPushClosure mark_and_push_closure(cm);
duke@435 64
duke@435 65 switch (_root_type) {
duke@435 66 case universe:
duke@435 67 Universe::oops_do(&mark_and_push_closure);
duke@435 68 break;
duke@435 69
duke@435 70 case reference_processing:
duke@435 71 ReferenceProcessor::oops_do(&mark_and_push_closure);
duke@435 72 break;
duke@435 73
duke@435 74 case jni_handles:
duke@435 75 JNIHandles::oops_do(&mark_and_push_closure);
duke@435 76 break;
duke@435 77
duke@435 78 case threads:
duke@435 79 {
duke@435 80 ResourceMark rm;
duke@435 81 Threads::oops_do(&mark_and_push_closure);
duke@435 82 }
duke@435 83 break;
duke@435 84
duke@435 85 case object_synchronizer:
duke@435 86 ObjectSynchronizer::oops_do(&mark_and_push_closure);
duke@435 87 break;
duke@435 88
duke@435 89 case flat_profiler:
duke@435 90 FlatProfiler::oops_do(&mark_and_push_closure);
duke@435 91 break;
duke@435 92
duke@435 93 case management:
duke@435 94 Management::oops_do(&mark_and_push_closure);
duke@435 95 break;
duke@435 96
duke@435 97 case jvmti:
duke@435 98 JvmtiExport::oops_do(&mark_and_push_closure);
duke@435 99 break;
duke@435 100
duke@435 101 case system_dictionary:
duke@435 102 SystemDictionary::always_strong_oops_do(&mark_and_push_closure);
duke@435 103 break;
duke@435 104
duke@435 105 case vm_symbols:
duke@435 106 vmSymbols::oops_do(&mark_and_push_closure);
duke@435 107 break;
duke@435 108
duke@435 109 default:
duke@435 110 fatal("Unknown root type");
duke@435 111 }
duke@435 112
duke@435 113 // Do the real work
duke@435 114 cm->drain_marking_stacks(&mark_and_push_closure);
duke@435 115 // cm->deallocate_stacks();
duke@435 116 }
duke@435 117
duke@435 118
duke@435 119 //
duke@435 120 // RefProcTaskProxy
duke@435 121 //
duke@435 122
duke@435 123 void RefProcTaskProxy::do_it(GCTaskManager* manager, uint which)
duke@435 124 {
duke@435 125 assert(Universe::heap()->is_gc_active(), "called outside gc");
duke@435 126
duke@435 127 NOT_PRODUCT(TraceTime tm("RefProcTask",
duke@435 128 PrintGCDetails && TraceParallelOldGCTasks, true, gclog_or_tty));
duke@435 129 ParCompactionManager* cm =
duke@435 130 ParCompactionManager::gc_thread_compaction_manager(which);
duke@435 131 assert(cm->stacks_have_been_allocated(),
ysr@1376 132 "Stack space has not been allocated");
duke@435 133 PSParallelCompact::MarkAndPushClosure mark_and_push_closure(cm);
duke@435 134 PSParallelCompact::FollowStackClosure follow_stack_closure(cm);
duke@435 135 _rp_task.work(_work_id, *PSParallelCompact::is_alive_closure(),
duke@435 136 mark_and_push_closure, follow_stack_closure);
duke@435 137 }
duke@435 138
duke@435 139 //
duke@435 140 // RefProcTaskExecutor
duke@435 141 //
duke@435 142
duke@435 143 void RefProcTaskExecutor::execute(ProcessTask& task)
duke@435 144 {
duke@435 145 ParallelScavengeHeap* heap = PSParallelCompact::gc_heap();
duke@435 146 uint parallel_gc_threads = heap->gc_task_manager()->workers();
jcoomes@810 147 RegionTaskQueueSet* qset = ParCompactionManager::region_array();
duke@435 148 ParallelTaskTerminator terminator(parallel_gc_threads, qset);
duke@435 149 GCTaskQueue* q = GCTaskQueue::create();
duke@435 150 for(uint i=0; i<parallel_gc_threads; i++) {
duke@435 151 q->enqueue(new RefProcTaskProxy(task, i));
duke@435 152 }
duke@435 153 if (task.marks_oops_alive()) {
duke@435 154 if (parallel_gc_threads>1) {
duke@435 155 for (uint j=0; j<parallel_gc_threads; j++) {
duke@435 156 q->enqueue(new StealMarkingTask(&terminator));
duke@435 157 }
duke@435 158 }
duke@435 159 }
duke@435 160 PSParallelCompact::gc_task_manager()->execute_and_wait(q);
duke@435 161 }
duke@435 162
duke@435 163 void RefProcTaskExecutor::execute(EnqueueTask& task)
duke@435 164 {
duke@435 165 ParallelScavengeHeap* heap = PSParallelCompact::gc_heap();
duke@435 166 uint parallel_gc_threads = heap->gc_task_manager()->workers();
duke@435 167 GCTaskQueue* q = GCTaskQueue::create();
duke@435 168 for(uint i=0; i<parallel_gc_threads; i++) {
duke@435 169 q->enqueue(new RefEnqueueTaskProxy(task, i));
duke@435 170 }
duke@435 171 PSParallelCompact::gc_task_manager()->execute_and_wait(q);
duke@435 172 }
duke@435 173
duke@435 174 //
duke@435 175 // StealMarkingTask
duke@435 176 //
duke@435 177
duke@435 178 StealMarkingTask::StealMarkingTask(ParallelTaskTerminator* t) :
duke@435 179 _terminator(t) {}
duke@435 180
duke@435 181 void StealMarkingTask::do_it(GCTaskManager* manager, uint which) {
duke@435 182 assert(Universe::heap()->is_gc_active(), "called outside gc");
duke@435 183
duke@435 184 NOT_PRODUCT(TraceTime tm("StealMarkingTask",
duke@435 185 PrintGCDetails && TraceParallelOldGCTasks, true, gclog_or_tty));
duke@435 186
duke@435 187 ParCompactionManager* cm =
duke@435 188 ParCompactionManager::gc_thread_compaction_manager(which);
duke@435 189 PSParallelCompact::MarkAndPushClosure mark_and_push_closure(cm);
duke@435 190
duke@435 191 oop obj = NULL;
duke@435 192 int random_seed = 17;
duke@435 193 while(true) {
duke@435 194 if (ParCompactionManager::steal(which, &random_seed, obj)) {
duke@435 195 obj->follow_contents(cm);
duke@435 196 cm->drain_marking_stacks(&mark_and_push_closure);
duke@435 197 } else {
duke@435 198 if (terminator()->offer_termination()) {
duke@435 199 break;
duke@435 200 }
duke@435 201 }
duke@435 202 }
duke@435 203 }
duke@435 204
duke@435 205 //
jcoomes@810 206 // StealRegionCompactionTask
duke@435 207 //
duke@435 208
duke@435 209
jcoomes@810 210 StealRegionCompactionTask::StealRegionCompactionTask(ParallelTaskTerminator* t):
jcoomes@810 211 _terminator(t) {}
duke@435 212
jcoomes@810 213 void StealRegionCompactionTask::do_it(GCTaskManager* manager, uint which) {
duke@435 214 assert(Universe::heap()->is_gc_active(), "called outside gc");
duke@435 215
jcoomes@810 216 NOT_PRODUCT(TraceTime tm("StealRegionCompactionTask",
duke@435 217 PrintGCDetails && TraceParallelOldGCTasks, true, gclog_or_tty));
duke@435 218
duke@435 219 ParCompactionManager* cm =
duke@435 220 ParCompactionManager::gc_thread_compaction_manager(which);
duke@435 221
jcoomes@810 222 // Has to drain stacks first because there may be regions on
duke@435 223 // preloaded onto the stack and this thread may never have
duke@435 224 // done a draining task. Are the draining tasks needed?
duke@435 225
jcoomes@810 226 cm->drain_region_stacks();
duke@435 227
jcoomes@810 228 size_t region_index = 0;
duke@435 229 int random_seed = 17;
duke@435 230
duke@435 231 // If we're the termination task, try 10 rounds of stealing before
duke@435 232 // setting the termination flag
duke@435 233
duke@435 234 while(true) {
jcoomes@810 235 if (ParCompactionManager::steal(which, &random_seed, region_index)) {
jcoomes@810 236 PSParallelCompact::fill_and_update_region(cm, region_index);
jcoomes@810 237 cm->drain_region_stacks();
duke@435 238 } else {
duke@435 239 if (terminator()->offer_termination()) {
duke@435 240 break;
duke@435 241 }
duke@435 242 // Go around again.
duke@435 243 }
duke@435 244 }
duke@435 245 return;
duke@435 246 }
duke@435 247
duke@435 248 UpdateDensePrefixTask::UpdateDensePrefixTask(
duke@435 249 PSParallelCompact::SpaceId space_id,
jcoomes@810 250 size_t region_index_start,
jcoomes@810 251 size_t region_index_end) :
jcoomes@810 252 _space_id(space_id), _region_index_start(region_index_start),
jcoomes@810 253 _region_index_end(region_index_end) {}
duke@435 254
duke@435 255 void UpdateDensePrefixTask::do_it(GCTaskManager* manager, uint which) {
duke@435 256
duke@435 257 NOT_PRODUCT(TraceTime tm("UpdateDensePrefixTask",
duke@435 258 PrintGCDetails && TraceParallelOldGCTasks, true, gclog_or_tty));
duke@435 259
duke@435 260 ParCompactionManager* cm =
duke@435 261 ParCompactionManager::gc_thread_compaction_manager(which);
duke@435 262
duke@435 263 PSParallelCompact::update_and_deadwood_in_dense_prefix(cm,
duke@435 264 _space_id,
jcoomes@810 265 _region_index_start,
jcoomes@810 266 _region_index_end);
duke@435 267 }
duke@435 268
duke@435 269 void DrainStacksCompactionTask::do_it(GCTaskManager* manager, uint which) {
duke@435 270 assert(Universe::heap()->is_gc_active(), "called outside gc");
duke@435 271
duke@435 272 NOT_PRODUCT(TraceTime tm("DrainStacksCompactionTask",
duke@435 273 PrintGCDetails && TraceParallelOldGCTasks, true, gclog_or_tty));
duke@435 274
duke@435 275 ParCompactionManager* cm =
duke@435 276 ParCompactionManager::gc_thread_compaction_manager(which);
duke@435 277
jcoomes@810 278 // Process any regions already in the compaction managers stacks.
jcoomes@810 279 cm->drain_region_stacks();
duke@435 280 }

Mercurial Repository: jdk8-mips64-public/hotspot

mercurial