/openjdk7/hotspot/src/share/vm/utilities/ |
H A D | yieldingWorkgroup.cpp | 128 _active_workers = active_workers(); 151 assert(started_workers() <= active_workers(), "invariant"); 152 assert(finished_workers() <= active_workers(), "invariant"); 153 assert(yielded_workers() <= active_workers(), "invariant"); 159 assert(finished_workers() == active_workers(), "Inconsistent status"); 166 assert(yielded_workers() + finished_workers() == active_workers(), 204 assert(yielded_workers() < active_workers(), "Consistency check"); 215 if (++_yielded_workers + finished_workers() == active_workers()) { 251 assert(yielded_workers() < active_workers(), "Consistency check"); 315 if (gang()->started_workers() == yf_gang()->active_workers()) { [all...] |
H A D | workgroup.hpp | 78 virtual void set_for_termination(int active_workers) {}; argument 116 virtual void set_for_termination(int active_workers) { argument 117 terminator()->reset_for_reuse(active_workers); 174 virtual uint active_workers() const { function in class:AbstractWorkGang 329 // Initialize active_workers to a minimum value. Setting it to 338 virtual uint active_workers() const { return _active_workers; } function in class:FlexibleWorkGang
|
H A D | workgroup.cpp | 170 // If active_workers() is passed, _finished_workers 174 WorkGang::run_task(task, (uint) active_workers()); 186 while (finished_workers() < active_workers()) { 189 name(), finished_workers(), active_workers());
|
/openjdk7/hotspot/src/share/vm/gc_implementation/parallelScavenge/ |
H A D | psScavenge.cpp | 191 for(uint i=0; i < manager->active_workers(); i++) { 194 ParallelTaskTerminator terminator(manager->active_workers(), 196 if (task.marks_oops_alive() && manager->active_workers() > 1) { 197 for (uint j = 0; j < manager->active_workers(); j++) { 209 for(uint i=0; i < manager->active_workers(); i++) { 397 uint active_workers = gc_task_manager()->active_workers(); local 398 heap->set_par_threads(active_workers); 410 uint stripe_total = active_workers; 429 active_workers, [all...] |
H A D | pcTasks.cpp | 157 uint active_gc_threads = heap->gc_task_manager()->active_workers(); 241 assert(manager->active_workers() == ParallelGCThreads, 243 " active %d ParallelGCThreads %d", manager->active_workers(), 320 assert(manager->active_workers() == ParallelGCThreads, 322 " active %d ParallelGCThreads %d", manager->active_workers(),
|
H A D | gcTaskManager.cpp | 480 active_workers(), 483 assert(!all_workers_active() || active_workers() == ParallelGCThreads, 485 "active %d ParallelGCThreads %d", active_workers(), 491 all_workers_active(), workers(), active_workers(), 509 // active_workers are a number being requested. idle_workers 512 // the number of active_workers to be consistent with the 516 // to allow the desired number of active_workers. 518 workers() - active_workers() - idle_workers(); 520 int reduced_active_workers = active_workers() + more_inactive_workers; 529 active_workers(), [all...] |
H A D | gcTaskManager.hpp | 565 bool all_workers_active() { return workers() == active_workers(); } 566 uint active_workers() const { function in class:GCTaskManager
|
H A D | psParallelCompact.cpp | 2090 heap->set_par_threads(gc_task_manager()->active_workers()); 2396 uint active_gc_threads = heap->gc_task_manager()->active_workers(); 2735 uint active_gc_threads = heap->gc_task_manager()->active_workers();
|
/openjdk7/hotspot/src/share/vm/gc_implementation/shared/ |
H A D | adaptiveSizePolicy.cpp | 102 uintx active_workers, 112 uintx prev_active_workers = active_workers; 171 "active_workers(): %d new_acitve_workers: %d " 174 active_workers, new_active_workers, prev_active_workers, 182 uintx active_workers, 198 active_workers, 206 uintx active_workers, 215 active_workers, 100 calc_default_active_workers(uintx total_workers, const uintx min_workers, uintx active_workers, uintx application_workers) argument 181 calc_active_workers(uintx total_workers, uintx active_workers, uintx application_workers) argument 205 calc_active_conc_workers(uintx total_workers, uintx active_workers, uintx application_workers) argument
|
H A D | adaptiveSizePolicy.hpp | 348 uintx active_workers, 362 uintx active_workers, 367 uintx active_workers,
|
/openjdk7/hotspot/src/share/vm/gc_implementation/g1/ |
H A D | collectionSetChooser.cpp | 165 assert(G1CollectedHeap::heap()->workers()->active_workers() > 0, 171 n_threads = MAX2(G1CollectedHeap::heap()->workers()->active_workers(),
|
H A D | concurrentMark.cpp | 1089 uint active_workers = MAX2(1U, parallel_marking_threads()); local 1093 _parallel_workers->set_active_workers((int) active_workers); 1122 uint active_workers = MAX2(1U, parallel_marking_threads()); local 1125 set_concurrency_and_phase(active_workers, true /* concurrent */); 1129 _parallel_workers->set_active_workers((int)active_workers); 1132 assert(_parallel_workers->active_workers() > 0, "Should have been set"); 1532 assert( _g1h->workers()->active_workers() > 0, 1534 _n_workers = _g1h->workers()->active_workers(); 1657 assert( _g1h->workers()->active_workers() > 0, 1659 _n_workers = _g1h->workers()->active_workers(); 2365 uint active_workers = (processing_is_mt ? g1h->workers()->active_workers() : 1U); local 2449 CMRemarkTask(ConcurrentMark* cm, int active_workers, bool is_serial) argument 2465 uint active_workers = g1h->workers()->active_workers(); local 2486 uint active_workers = 1; local [all...] |
H A D | g1CollectedHeap.cpp | 1215 _g1->workers()->active_workers(), 1452 workers()->active_workers(), 1469 workers()->active_workers() == workers()->total_workers(), 1472 assert(workers()->active_workers() > 0, 1474 set_par_threads(workers()->active_workers()); 2963 uint active_workers = workers()->active_workers(); local 2965 active_workers == workers()->total_workers(), 2968 uint end_ind = (cs_size * worker_i) / active_workers; 2975 start_ind = (cs_size * (worker_i - 1)) / active_workers; 3864 int active_workers = (G1CollectedHeap::use_parallel_gc_threads() ? local 4922 set_for_termination(int active_workers) argument [all...] |
H A D | g1CollectorPolicy.cpp | 1568 _g1->workers()->active_workers(),
|
/openjdk7/hotspot/src/share/vm/gc_implementation/parNew/ |
H A D | parNewGeneration.cpp | 310 void reset(int active_workers, bool promotion_failed); 588 void ParNewGenTask::set_for_termination(int active_workers) { argument 589 _state_set->reset(active_workers, _gen->promotion_failed()); 593 gch->set_n_termination(active_workers); 775 virtual void set_for_termination(int active_workers) { argument 776 _state_set.terminator()->reset_for_reuse(active_workers); 835 _state_set.reset(workers->active_workers(), _generation.promotion_failed()); 933 int active_workers = local 935 workers->active_workers(), 937 workers->set_active_workers(active_workers); [all...] |
H A D | parNewGeneration.hpp | 250 // "active_workers" threads. 251 virtual void set_for_termination(int active_workers);
|
/openjdk7/hotspot/src/share/vm/memory/ |
H A D | cardTableModRefBS.cpp | 470 // of workers()->active_workers(). n_par_threads can be set to 0 to 473 // used, then n_par_threads() may have been set to 0. active_workers 478 // equal to active_workers. When a different mechanism for shutting 479 // off parallelism is used, then active_workers can be used in 499 SharedHeap::heap()->workers()->active_workers(), "Mismatch"); 529 SharedHeap::heap()->workers()->active_workers()), "Mismatch");
|
H A D | cardTableRS.cpp | 167 // Cannot yet substitute active_workers for n_par_threads 173 SharedHeap::heap()->workers()->active_workers()), "Mismatch");
|
/openjdk7/hotspot/src/share/vm/gc_implementation/concurrentMarkSweep/ |
H A D | concurrentMarkSweepGeneration.cpp | 3837 virtual void set_for_termination(int active_workers) { 3838 terminator()->reset_for_reuse(active_workers); 4301 conc_workers()->active_workers(), 5607 // into "active_workers". If active_workers is not set, set it 5609 int n_workers = workers->active_workers(); 5795 set_for_termination(workers->active_workers()); 5960 int active_workers = ParallelGCThreads; 5963 active_workers = workers->active_workers(); [all...] |
H A D | compactibleFreeListSpace.cpp | 686 SharedHeap::heap()->workers()->active_workers(), "Mismatch"); \ 1940 SharedHeap::heap()->workers()->active_workers()), "Mismatch");
|
/openjdk7/hotspot/src/share/vm/runtime/ |
H A D | thread.cpp | 813 assert(SharedHeap::heap()->workers()->active_workers() > 0, 818 assert(SharedHeap::heap()->workers()->active_workers() > 0, 4137 // Cannot yet substitute active_workers for n_par_threads 4140 // turn off parallelism in process_strong_roots while active_workers 4145 SharedHeap::heap()->workers()->active_workers()), "Mismatch");
|