Lines Matching refs:worker_i

111   ScanRSClosure(OopsInHeapRegionClosure* oc, int worker_i) :
115 _worker_i(worker_i),
214 void G1RemSet::scanRS(OopsInHeapRegionClosure* oc, int worker_i) {
216 HeapRegion *startRegion = _g1->start_cset_region_for_worker(worker_i);
218 ScanRSClosure scanRScl(oc, worker_i);
227 _cards_scanned[worker_i] = scanRScl.cards_done();
229 _g1p->phase_times()->record_scan_rs_time(worker_i, scan_rs_time_sec * 1000.0);
244 bool do_card_ptr(jbyte* card_ptr, int worker_i) {
248 // In this case worker_i should be the id of a GC worker thread.
250 assert(worker_i < (int) (ParallelGCThreads == 0 ? 1 : ParallelGCThreads), "should be a GC worker");
252 if (_g1rs->refine_card(card_ptr, worker_i, true)) {
265 void G1RemSet::updateRS(DirtyCardQueue* into_cset_dcq, int worker_i) {
270 _g1->iterate_dirty_card_closure(&into_cset_update_rs_cl, into_cset_dcq, false, worker_i);
281 _g1p->phase_times()->record_update_rs_time(worker_i, (os::elapsedTime() - start) * 1000.0);
289 int worker_i) {
296 assert(worker_i < (int)n_workers(), "sanity");
297 _cset_rs_update_cl[worker_i] = oc;
314 assert((ParallelGCThreads > 0) || worker_i == 0, "invariant");
322 if (G1UseParallelRSetUpdating || (worker_i == 0)) {
323 updateRS(&into_cset_dcq, worker_i);
325 _g1p->phase_times()->record_update_rs_processed_buffers(worker_i, 0);
326 _g1p->phase_times()->record_update_rs_time(worker_i, 0.0);
328 if (G1UseParallelRSetScanning || (worker_i == 0)) {
329 scanRS(oc, worker_i);
331 _g1p->phase_times()->record_scan_rs_time(worker_i, 0.0);
335 _cset_rs_update_cl[worker_i] = NULL;
373 bool do_card_ptr(jbyte* card_ptr, int worker_i) {
519 int worker_i) :
522 _push_ref_cl(push_ref_cl), _worker_i(worker_i) { }
528 bool G1RemSet::refine_card(jbyte* card_ptr, int worker_i,
629 assert((size_t)worker_i < n_workers(), "index of worker larger than _cset_rs_update_cl[].length");
630 oops_in_heap_closure = _cset_rs_update_cl[worker_i];
636 worker_i);