Searched refs:worker_id (Results 1 - 16 of 16) sorted by relevance

/openjdk7/hotspot/src/share/vm/gc_implementation/g1/
H A Dg1EvacFailure.hpp81 uint worker_id) :
86 _worker_id(worker_id) { }
167 uint worker_id) :
169 _worker_id(worker_id), _cm(_g1h->concurrent_mark()) { }
226 void work(uint worker_id) { argument
236 RemoveSelfForwardPtrHRClosure rsfp_cl(_g1h, update_rset_cl, worker_id);
238 HeapRegion* hr = _g1h->start_cset_region_for_worker(worker_id);
76 RemoveSelfForwardPtrObjClosure(G1CollectedHeap* g1, ConcurrentMark* cm, HeapRegion* hr, OopsInHeapRegionClosure* update_rset_cl, bool during_initial_mark, bool during_conc_mark, uint worker_id) argument
165 RemoveSelfForwardPtrHRClosure(G1CollectedHeap* g1h, OopsInHeapRegionClosure* update_rset_cl, uint worker_id) argument
H A DconcurrentMark.inline.hpp122 uint worker_id) {
123 size_t* marked_bytes_array = count_marked_bytes_array_for(worker_id);
124 BitMap* task_card_bm = count_card_bitmap_for(worker_id);
130 inline void ConcurrentMark::count_region(MemRegion mr, uint worker_id) { argument
133 count_region(mr, hr, worker_id);
149 uint worker_id) {
150 size_t* marked_bytes_array = count_marked_bytes_array_for(worker_id);
151 BitMap* task_card_bm = count_card_bitmap_for(worker_id);
177 uint worker_id) {
181 count_region(mr, hr, worker_id);
120 count_region(MemRegion mr, HeapRegion* hr, uint worker_id) argument
147 count_object(oop obj, HeapRegion* hr, uint worker_id) argument
174 par_mark_and_count(oop obj, size_t word_size, HeapRegion* hr, uint worker_id) argument
190 par_mark_and_count(oop obj, HeapRegion* hr, uint worker_id) argument
204 par_mark_and_count(oop obj, uint worker_id) argument
212 par_mark_and_count(oop obj, size_t word_size, uint worker_id) argument
405 grayRoot(oop obj, size_t word_size, uint worker_id, HeapRegion* hr) argument
[all...]
H A DconcurrentG1RefineThread.hpp74 int worker_id_offset, int worker_id);
H A DconcurrentMark.hpp682 uint worker_id, HeapRegion* hr = NULL);
722 void scanRootRegion(HeapRegion* hr, uint worker_id);
840 BitMap* count_card_bitmap_for(uint worker_id) { argument
841 assert(0 <= worker_id && worker_id < _max_task_num, "oob");
843 BitMap* task_card_bm = &_count_card_bitmaps[worker_id];
850 size_t* count_marked_bytes_array_for(uint worker_id) { argument
851 assert(0 <= worker_id && worker_id < _max_task_num, "oob");
853 size_t* marked_bytes_array = _count_marked_bytes[worker_id];
[all...]
H A DconcurrentG1RefineThread.cpp36 int worker_id_offset, int worker_id) :
39 _worker_id(worker_id),
52 if (worker_id > 0) {
35 ConcurrentG1RefineThread(ConcurrentG1Refine* cg1r, ConcurrentG1RefineThread *next, int worker_id_offset, int worker_id) argument
H A DconcurrentMark.cpp948 void work(uint worker_id) { argument
957 assert(worker_id < _cm->active_tasks(), "invariant");
958 CMTask* the_task = _cm->task(worker_id);
976 bool ret = _cm->do_yield_check(worker_id);
1005 _cm->update_accum_task_vtime(worker_id, end_vtime - start_vtime);
1043 void ConcurrentMark::scanRootRegion(HeapRegion* hr, uint worker_id) { argument
1046 G1RootRegionScanClosure cl(_g1h, this, worker_id);
1068 void work(uint worker_id) { argument
1075 _cm->scanRootRegion(hr, worker_id);
1545 void work(uint worker_id) { argument
1665 work(uint worker_id) argument
1763 work(uint worker_id) argument
1831 work(uint worker_id) argument
2249 work(uint worker_id) argument
2284 work(uint worker_id) argument
2432 work(uint worker_id) argument
3043 work(uint worker_id) argument
3189 do_yield_check(uint worker_id) argument
[all...]
H A Dg1OopClosures.hpp230 uint worker_id) :
231 _g1h(g1h), _cm(cm), _worker_id(worker_id) { }
229 G1RootRegionScanClosure(G1CollectedHeap* g1h, ConcurrentMark* cm, uint worker_id) argument
H A Dg1CollectedHeap.cpp1212 void work(uint worker_id) { argument
1213 RebuildRSOutOfRegionClosure rebuild_rs(_g1, worker_id);
1214 _g1->heap_region_par_iterate_chunked(&rebuild_rs, worker_id,
2740 uint worker_id,
2752 start_region_for_worker(worker_id, no_of_par_workers);
3355 void work(uint worker_id) { argument
3358 _g1h->heap_region_par_iterate_chunked(&blk, worker_id,
4934 void work(uint worker_id) { argument
4935 if (worker_id >= _n_workers) return; // no work needed this round
4938 _g1h->g1_policy()->phase_times()->record_gc_worker_start_time(worker_id, start_time_m
2739 heap_region_par_iterate_chunked(HeapRegionClosure* cl, uint worker_id, uint no_of_par_workers, jint claim_value) argument
5330 work(uint worker_id) argument
5404 work(uint worker_id) argument
5445 work(uint worker_id) argument
5924 work(uint worker_id) argument
[all...]
H A Dg1CollectorPolicy.cpp1563 void work(uint worker_id) { argument
1567 _g1->heap_region_par_iterate_chunked(&parKnownGarbageCl, worker_id,
/openjdk7/hotspot/src/share/vm/utilities/
H A DyieldingWorkgroup.hpp74 virtual void work(uint worker_id) = 0;
131 virtual void work(uint worker_id) = 0;
H A Dworkgroup.hpp71 virtual void work(uint worker_id) = 0;
/openjdk7/hotspot/src/share/vm/gc_implementation/concurrentMarkSweep/
H A DpromotionInfo.hpp168 void stopTrackingPromotions(uint worker_id = 0);
210 void print_statistics(uint worker_id) const;
H A DpromotionInfo.cpp237 void PromotionInfo::stopTrackingPromotions(uint worker_id) { argument
243 print_statistics(worker_id);
247 void PromotionInfo::print_statistics(uint worker_id) const {
269 worker_id, blocks, slots);
H A DconcurrentMarkSweepGeneration.cpp3841 void work(uint worker_id);
3914 void CMSConcMarkingTask::work(uint worker_id) {
3922 assert(work_queue(worker_id)->size() == 0, "Expected to be empty");
3925 do_scan_and_mark(worker_id, _cms_space);
3929 worker_id, _timer.seconds());
3936 do_scan_and_mark(worker_id, _perm_space);
3940 worker_id, _timer.seconds());
3947 do_work_steal(worker_id);
3951 worker_id, _timer.seconds());
3955 assert(work_queue(worker_id)
[all...]
/openjdk7/hotspot/src/share/vm/gc_implementation/parNew/
H A DparNewGeneration.cpp604 void ParNewGenTask::work(uint worker_id) { argument
615 ParScanThreadState& par_scan_state = _state_set->thread_state(worker_id);
616 assert(_state_set->is_valid(worker_id), "Should not have been called");
774 virtual void work(uint worker_id);
800 void ParNewRefProcTaskProxy::work(uint worker_id) argument
804 ParScanThreadState& par_scan_state = _state_set.thread_state(worker_id);
806 _task.work(worker_id, par_scan_state.is_alive_closure(),
821 virtual void work(uint worker_id) argument
823 _task.work(worker_id);
H A DparNewGeneration.hpp247 void work(uint worker_id);

Completed in 113 milliseconds