Mercurial > jdk8-mips64-public > hotspot / annotate

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

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

Sat, 01 Dec 2007 00:00:00 +0000

author
duke
date
Sat, 01 Dec 2007 00:00:00 +0000
changeset 435
a61af66fc99e
child 548
ba764ed4b6f2
permissions
-rw-r--r--

Initial load

duke@435 1 /*
duke@435 2 * Copyright 2005-2007 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 // cm->allocate_stacks();
duke@435 62 assert(cm->stacks_have_been_allocated(),
duke@435 63 "Stack space has not been allocated");
duke@435 64 PSParallelCompact::MarkAndPushClosure mark_and_push_closure(cm);
duke@435 65
duke@435 66 switch (_root_type) {
duke@435 67 case universe:
duke@435 68 Universe::oops_do(&mark_and_push_closure);
duke@435 69 break;
duke@435 70
duke@435 71 case reference_processing:
duke@435 72 ReferenceProcessor::oops_do(&mark_and_push_closure);
duke@435 73 break;
duke@435 74
duke@435 75 case jni_handles:
duke@435 76 JNIHandles::oops_do(&mark_and_push_closure);
duke@435 77 break;
duke@435 78
duke@435 79 case threads:
duke@435 80 {
duke@435 81 ResourceMark rm;
duke@435 82 Threads::oops_do(&mark_and_push_closure);
duke@435 83 }
duke@435 84 break;
duke@435 85
duke@435 86 case object_synchronizer:
duke@435 87 ObjectSynchronizer::oops_do(&mark_and_push_closure);
duke@435 88 break;
duke@435 89
duke@435 90 case flat_profiler:
duke@435 91 FlatProfiler::oops_do(&mark_and_push_closure);
duke@435 92 break;
duke@435 93
duke@435 94 case management:
duke@435 95 Management::oops_do(&mark_and_push_closure);
duke@435 96 break;
duke@435 97
duke@435 98 case jvmti:
duke@435 99 JvmtiExport::oops_do(&mark_and_push_closure);
duke@435 100 break;
duke@435 101
duke@435 102 case system_dictionary:
duke@435 103 SystemDictionary::always_strong_oops_do(&mark_and_push_closure);
duke@435 104 break;
duke@435 105
duke@435 106 case vm_symbols:
duke@435 107 vmSymbols::oops_do(&mark_and_push_closure);
duke@435 108 break;
duke@435 109
duke@435 110 default:
duke@435 111 fatal("Unknown root type");
duke@435 112 }
duke@435 113
duke@435 114 // Do the real work
duke@435 115 cm->drain_marking_stacks(&mark_and_push_closure);
duke@435 116 // cm->deallocate_stacks();
duke@435 117 }
duke@435 118
duke@435 119
duke@435 120 //
duke@435 121 // RefProcTaskProxy
duke@435 122 //
duke@435 123
duke@435 124 void RefProcTaskProxy::do_it(GCTaskManager* manager, uint which)
duke@435 125 {
duke@435 126 assert(Universe::heap()->is_gc_active(), "called outside gc");
duke@435 127
duke@435 128 NOT_PRODUCT(TraceTime tm("RefProcTask",
duke@435 129 PrintGCDetails && TraceParallelOldGCTasks, true, gclog_or_tty));
duke@435 130 ParCompactionManager* cm =
duke@435 131 ParCompactionManager::gc_thread_compaction_manager(which);
duke@435 132 // cm->allocate_stacks();
duke@435 133 assert(cm->stacks_have_been_allocated(),
duke@435 134 "Stack space has not been allocated");
duke@435 135 PSParallelCompact::MarkAndPushClosure mark_and_push_closure(cm);
duke@435 136 PSParallelCompact::FollowStackClosure follow_stack_closure(cm);
duke@435 137 _rp_task.work(_work_id, *PSParallelCompact::is_alive_closure(),
duke@435 138 mark_and_push_closure, follow_stack_closure);
duke@435 139 }
duke@435 140
duke@435 141 //
duke@435 142 // RefProcTaskExecutor
duke@435 143 //
duke@435 144
duke@435 145 void RefProcTaskExecutor::execute(ProcessTask& task)
duke@435 146 {
duke@435 147 ParallelScavengeHeap* heap = PSParallelCompact::gc_heap();
duke@435 148 uint parallel_gc_threads = heap->gc_task_manager()->workers();
duke@435 149 TaskQueueSetSuper* qset = ParCompactionManager::chunk_array();
duke@435 150 ParallelTaskTerminator terminator(parallel_gc_threads, qset);
duke@435 151 GCTaskQueue* q = GCTaskQueue::create();
duke@435 152 for(uint i=0; i<parallel_gc_threads; i++) {
duke@435 153 q->enqueue(new RefProcTaskProxy(task, i));
duke@435 154 }
duke@435 155 if (task.marks_oops_alive()) {
duke@435 156 if (parallel_gc_threads>1) {
duke@435 157 for (uint j=0; j<parallel_gc_threads; j++) {
duke@435 158 q->enqueue(new StealMarkingTask(&terminator));
duke@435 159 }
duke@435 160 }
duke@435 161 }
duke@435 162 PSParallelCompact::gc_task_manager()->execute_and_wait(q);
duke@435 163 }
duke@435 164
duke@435 165 void RefProcTaskExecutor::execute(EnqueueTask& task)
duke@435 166 {
duke@435 167 ParallelScavengeHeap* heap = PSParallelCompact::gc_heap();
duke@435 168 uint parallel_gc_threads = heap->gc_task_manager()->workers();
duke@435 169 GCTaskQueue* q = GCTaskQueue::create();
duke@435 170 for(uint i=0; i<parallel_gc_threads; i++) {
duke@435 171 q->enqueue(new RefEnqueueTaskProxy(task, i));
duke@435 172 }
duke@435 173 PSParallelCompact::gc_task_manager()->execute_and_wait(q);
duke@435 174 }
duke@435 175
duke@435 176 //
duke@435 177 // StealMarkingTask
duke@435 178 //
duke@435 179
duke@435 180 StealMarkingTask::StealMarkingTask(ParallelTaskTerminator* t) :
duke@435 181 _terminator(t) {}
duke@435 182
duke@435 183 void StealMarkingTask::do_it(GCTaskManager* manager, uint which) {
duke@435 184 assert(Universe::heap()->is_gc_active(), "called outside gc");
duke@435 185
duke@435 186 NOT_PRODUCT(TraceTime tm("StealMarkingTask",
duke@435 187 PrintGCDetails && TraceParallelOldGCTasks, true, gclog_or_tty));
duke@435 188
duke@435 189 ParCompactionManager* cm =
duke@435 190 ParCompactionManager::gc_thread_compaction_manager(which);
duke@435 191 PSParallelCompact::MarkAndPushClosure mark_and_push_closure(cm);
duke@435 192
duke@435 193 oop obj = NULL;
duke@435 194 int random_seed = 17;
duke@435 195 while(true) {
duke@435 196 if (ParCompactionManager::steal(which, &random_seed, obj)) {
duke@435 197 obj->follow_contents(cm);
duke@435 198 cm->drain_marking_stacks(&mark_and_push_closure);
duke@435 199 } else {
duke@435 200 if (terminator()->offer_termination()) {
duke@435 201 break;
duke@435 202 }
duke@435 203 }
duke@435 204 }
duke@435 205 }
duke@435 206
duke@435 207 //
duke@435 208 // StealChunkCompactionTask
duke@435 209 //
duke@435 210
duke@435 211
duke@435 212 StealChunkCompactionTask::StealChunkCompactionTask(ParallelTaskTerminator* t) :
duke@435 213 _terminator(t) {};
duke@435 214
duke@435 215 void StealChunkCompactionTask::do_it(GCTaskManager* manager, uint which) {
duke@435 216 assert(Universe::heap()->is_gc_active(), "called outside gc");
duke@435 217
duke@435 218 NOT_PRODUCT(TraceTime tm("StealChunkCompactionTask",
duke@435 219 PrintGCDetails && TraceParallelOldGCTasks, true, gclog_or_tty));
duke@435 220
duke@435 221 ParCompactionManager* cm =
duke@435 222 ParCompactionManager::gc_thread_compaction_manager(which);
duke@435 223
duke@435 224 // Has to drain stacks first because there may be chunks on
duke@435 225 // preloaded onto the stack and this thread may never have
duke@435 226 // done a draining task. Are the draining tasks needed?
duke@435 227
duke@435 228 cm->drain_chunk_stacks();
duke@435 229
duke@435 230 size_t chunk_index = 0;
duke@435 231 int random_seed = 17;
duke@435 232
duke@435 233 // If we're the termination task, try 10 rounds of stealing before
duke@435 234 // setting the termination flag
duke@435 235
duke@435 236 while(true) {
duke@435 237 if (ParCompactionManager::steal(which, &random_seed, chunk_index)) {
duke@435 238 PSParallelCompact::fill_and_update_chunk(cm, chunk_index);
duke@435 239 cm->drain_chunk_stacks();
duke@435 240 } else {
duke@435 241 if (terminator()->offer_termination()) {
duke@435 242 break;
duke@435 243 }
duke@435 244 // Go around again.
duke@435 245 }
duke@435 246 }
duke@435 247 return;
duke@435 248 }
duke@435 249
duke@435 250 UpdateDensePrefixTask::UpdateDensePrefixTask(
duke@435 251 PSParallelCompact::SpaceId space_id,
duke@435 252 size_t chunk_index_start,
duke@435 253 size_t chunk_index_end) :
duke@435 254 _space_id(space_id), _chunk_index_start(chunk_index_start),
duke@435 255 _chunk_index_end(chunk_index_end)
duke@435 256 {}
duke@435 257
duke@435 258 void UpdateDensePrefixTask::do_it(GCTaskManager* manager, uint which) {
duke@435 259
duke@435 260 NOT_PRODUCT(TraceTime tm("UpdateDensePrefixTask",
duke@435 261 PrintGCDetails && TraceParallelOldGCTasks, true, gclog_or_tty));
duke@435 262
duke@435 263 ParCompactionManager* cm =
duke@435 264 ParCompactionManager::gc_thread_compaction_manager(which);
duke@435 265
duke@435 266 PSParallelCompact::update_and_deadwood_in_dense_prefix(cm,
duke@435 267 _space_id,
duke@435 268 _chunk_index_start,
duke@435 269 _chunk_index_end);
duke@435 270 }
duke@435 271
duke@435 272 void DrainStacksCompactionTask::do_it(GCTaskManager* manager, uint which) {
duke@435 273 assert(Universe::heap()->is_gc_active(), "called outside gc");
duke@435 274
duke@435 275 NOT_PRODUCT(TraceTime tm("DrainStacksCompactionTask",
duke@435 276 PrintGCDetails && TraceParallelOldGCTasks, true, gclog_or_tty));
duke@435 277
duke@435 278 ParCompactionManager* cm =
duke@435 279 ParCompactionManager::gc_thread_compaction_manager(which);
duke@435 280
duke@435 281 // Process any chunks already in the compaction managers stacks.
duke@435 282 cm->drain_chunk_stacks();
duke@435 283 }

Mercurial Repository: jdk8-mips64-public/hotspot

mercurial