Searched refs:active_workers (Results 1 - 21 of 21) sorted by relevance

/openjdk7/hotspot/src/share/vm/utilities/
H A DyieldingWorkgroup.cpp128 _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 Dworkgroup.hpp78 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 Dworkgroup.cpp170 // 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 DpsScavenge.cpp191 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 DpcTasks.cpp157 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 DgcTaskManager.cpp480 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 DgcTaskManager.hpp565 bool all_workers_active() { return workers() == active_workers(); }
566 uint active_workers() const { function in class:GCTaskManager
H A DpsParallelCompact.cpp2090 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 DadaptiveSizePolicy.cpp102 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 DadaptiveSizePolicy.hpp348 uintx active_workers,
362 uintx active_workers,
367 uintx active_workers,
/openjdk7/hotspot/src/share/vm/gc_implementation/g1/
H A DcollectionSetChooser.cpp165 assert(G1CollectedHeap::heap()->workers()->active_workers() > 0,
171 n_threads = MAX2(G1CollectedHeap::heap()->workers()->active_workers(),
H A DconcurrentMark.cpp1089 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 Dg1CollectedHeap.cpp1215 _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 Dg1CollectorPolicy.cpp1568 _g1->workers()->active_workers(),
/openjdk7/hotspot/src/share/vm/gc_implementation/parNew/
H A DparNewGeneration.cpp310 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 DparNewGeneration.hpp250 // "active_workers" threads.
251 virtual void set_for_termination(int active_workers);
/openjdk7/hotspot/src/share/vm/memory/
H A DcardTableModRefBS.cpp470 // 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 DcardTableRS.cpp167 // 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 DconcurrentMarkSweepGeneration.cpp3837 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 DcompactibleFreeListSpace.cpp686 SharedHeap::heap()->workers()->active_workers(), "Mismatch"); \
1940 SharedHeap::heap()->workers()->active_workers()), "Mismatch");
/openjdk7/hotspot/src/share/vm/runtime/
H A Dthread.cpp813 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");

Completed in 135 milliseconds