< prev index next >

src/share/vm/gc/parallel/gcTaskManager.cpp

Print this page

        

*** 28,37 **** --- 28,38 ---- #include "gc/shared/adaptiveSizePolicy.hpp" #include "gc/shared/gcId.hpp" #include "logging/log.hpp" #include "memory/allocation.hpp" #include "memory/allocation.inline.hpp" + #include "memory/resourceArea.hpp" #include "runtime/mutex.hpp" #include "runtime/mutexLocker.hpp" #include "runtime/orderAccess.inline.hpp" //
*** 402,417 **** } _thread = NEW_C_HEAP_ARRAY(GCTaskThread*, workers(), mtGC); for (uint t = 0; t < workers(); t += 1) { set_thread(t, GCTaskThread::create(this, t, processor_assignment[t])); } ! if (TraceGCTaskThread) { ! tty->print("GCTaskManager::initialize: distribution:"); for (uint t = 0; t < workers(); t += 1) { ! tty->print(" %u", processor_assignment[t]); } ! tty->cr(); } FREE_C_HEAP_ARRAY(uint, processor_assignment); } reset_busy_workers(); set_unblocked(); --- 403,421 ---- } _thread = NEW_C_HEAP_ARRAY(GCTaskThread*, workers(), mtGC); for (uint t = 0; t < workers(); t += 1) { set_thread(t, GCTaskThread::create(this, t, processor_assignment[t])); } ! LogHandle(gc, task, thread) log; ! if (log.is_trace()) { ! ResourceMark rm; ! outputStream* out = log.trace_stream(); ! out->print("GCTaskManager::initialize: distribution:"); for (uint t = 0; t < workers(); t += 1) { ! out->print(" %u", processor_assignment[t]); } ! out->cr(); } FREE_C_HEAP_ARRAY(uint, processor_assignment); } reset_busy_workers(); set_unblocked();
< prev index next >