< prev index next >

src/hotspot/share/gc/g1/g1FullGCMarker.cpp

Print this page

44     _stack_closure(this),
45     _cld_closure(mark_closure(), ClassLoaderData::_claim_stw_fullgc_mark),
46     _mark_stats_cache(mark_stats, G1RegionMarkStatsCache::RegionMarkStatsCacheSize) {
47   ClassLoaderDataGraph::verify_claimed_marks_cleared(ClassLoaderData::_claim_stw_fullgc_mark);
48   _mark_stats_cache.reset();
49 }
50 
51 G1FullGCMarker::~G1FullGCMarker() {
52   assert(is_task_queue_empty(), "Must be empty at this point");
53 }
54 
55 void G1FullGCMarker::process_partial_array(PartialArrayState* state, bool stolen) {
56   // Access state before release by claim().
57   objArrayOop obj_array = objArrayOop(state->source());
58   PartialArraySplitter::Claim claim =
59     _partial_array_splitter.claim(state, task_queue(), stolen);
60   process_array_chunk(obj_array, claim._start, claim._end);
61 }
62 
63 void G1FullGCMarker::start_partial_array_processing(objArrayOop obj) {

64   mark_closure()->do_klass(obj->klass());

65   // Don't push empty arrays to avoid unnecessary work.
66   size_t array_length = obj->length();
67   if (array_length > 0) {
68     size_t initial_chunk_size = _partial_array_splitter.start(task_queue(), obj, nullptr, array_length);
69     process_array_chunk(obj, 0, initial_chunk_size);
70   }
71 }
72 
73 void G1FullGCMarker::complete_marking(G1ScannerTasksQueueSet* task_queues,
74                                       TaskTerminator* terminator) {
75   do {
76     process_marking_stacks();
77     ScannerTask stolen_task;
78     if (task_queues->steal(_worker_id, stolen_task)) {
79       dispatch_task(stolen_task, true);
80     }
81   } while (!is_task_queue_empty() || !terminator->offer_termination());
82 }
83 
84 void G1FullGCMarker::flush_mark_stats_cache() {

44     _stack_closure(this),
45     _cld_closure(mark_closure(), ClassLoaderData::_claim_stw_fullgc_mark),
46     _mark_stats_cache(mark_stats, G1RegionMarkStatsCache::RegionMarkStatsCacheSize) {
47   ClassLoaderDataGraph::verify_claimed_marks_cleared(ClassLoaderData::_claim_stw_fullgc_mark);
48   _mark_stats_cache.reset();
49 }
50 
51 G1FullGCMarker::~G1FullGCMarker() {
52   assert(is_task_queue_empty(), "Must be empty at this point");
53 }
54 
55 void G1FullGCMarker::process_partial_array(PartialArrayState* state, bool stolen) {
56   // Access state before release by claim().
57   objArrayOop obj_array = objArrayOop(state->source());
58   PartialArraySplitter::Claim claim =
59     _partial_array_splitter.claim(state, task_queue(), stolen);
60   process_array_chunk(obj_array, claim._start, claim._end);
61 }
62 
63 void G1FullGCMarker::start_partial_array_processing(objArrayOop obj) {
64   precond(obj->is_array_with_oops());
65   mark_closure()->do_klass(obj->klass());
66 
67   // Don't push empty arrays to avoid unnecessary work.
68   size_t array_length = obj->length();
69   if (array_length > 0) {
70     size_t initial_chunk_size = _partial_array_splitter.start(task_queue(), obj, nullptr, array_length);
71     process_array_chunk(obj, 0, initial_chunk_size);
72   }
73 }
74 
75 void G1FullGCMarker::complete_marking(G1ScannerTasksQueueSet* task_queues,
76                                       TaskTerminator* terminator) {
77   do {
78     process_marking_stacks();
79     ScannerTask stolen_task;
80     if (task_queues->steal(_worker_id, stolen_task)) {
81       dispatch_task(stolen_task, true);
82     }
83   } while (!is_task_queue_empty() || !terminator->offer_termination());
84 }
85 
86 void G1FullGCMarker::flush_mark_stats_cache() {
< prev index next >