34 uint size = GenericTaskQueueSet<ShenandoahObjToScanQueue, mtGC>::size();
35 for (uint index = 0; index < size; index ++) {
36 ShenandoahObjToScanQueue* q = queue(index);
37 assert(q != nullptr, "Sanity");
38 q->clear();
39 }
40 }
41
42 bool ShenandoahObjToScanQueueSet::is_empty() {
43 uint size = GenericTaskQueueSet<ShenandoahObjToScanQueue, mtGC>::size();
44 for (uint index = 0; index < size; index ++) {
45 ShenandoahObjToScanQueue* q = queue(index);
46 assert(q != nullptr, "Sanity");
47 if (!q->is_empty()) {
48 return false;
49 }
50 }
51 return true;
52 }
53
54 #if TASKQUEUE_STATS
55 void ShenandoahObjToScanQueueSet::print_taskqueue_stats_hdr(outputStream* const st) {
56 st->print_raw_cr("GC Task Stats");
57 st->print_raw("thr "); TaskQueueStats::print_header(1, st); st->cr();
58 st->print_raw("--- "); TaskQueueStats::print_header(2, st); st->cr();
59 }
60
61 void ShenandoahObjToScanQueueSet::print_taskqueue_stats() const {
62 if (!log_develop_is_enabled(Trace, gc, task, stats)) {
63 return;
64 }
65 Log(gc, task, stats) log;
66 ResourceMark rm;
67 LogStream ls(log.trace());
68 outputStream* st = &ls;
69 print_taskqueue_stats_hdr(st);
70
71 ShenandoahObjToScanQueueSet* queues = const_cast<ShenandoahObjToScanQueueSet*>(this);
72 TaskQueueStats totals;
73 const uint n = size();
74 for (uint i = 0; i < n; ++i) {
75 st->print(UINT32_FORMAT_W(3), i);
76 queues->queue(i)->stats.print(st);
77 st->cr();
78 totals += queues->queue(i)->stats;
79 }
80 st->print("tot "); totals.print(st); st->cr();
81 DEBUG_ONLY(totals.verify());
82
83 }
84
85 void ShenandoahObjToScanQueueSet::reset_taskqueue_stats() {
86 const uint n = size();
87 for (uint i = 0; i < n; ++i) {
88 queue(i)->stats.reset();
89 }
90 }
91 #endif // TASKQUEUE_STATS
92
93 bool ShenandoahTerminatorTerminator::should_exit_termination() {
94 return _heap->cancelled_gc();
95 }
|
34 uint size = GenericTaskQueueSet<ShenandoahObjToScanQueue, mtGC>::size();
35 for (uint index = 0; index < size; index ++) {
36 ShenandoahObjToScanQueue* q = queue(index);
37 assert(q != nullptr, "Sanity");
38 q->clear();
39 }
40 }
41
42 bool ShenandoahObjToScanQueueSet::is_empty() {
43 uint size = GenericTaskQueueSet<ShenandoahObjToScanQueue, mtGC>::size();
44 for (uint index = 0; index < size; index ++) {
45 ShenandoahObjToScanQueue* q = queue(index);
46 assert(q != nullptr, "Sanity");
47 if (!q->is_empty()) {
48 return false;
49 }
50 }
51 return true;
52 }
53
54 bool ShenandoahTerminatorTerminator::should_exit_termination() {
55 return _heap->cancelled_gc();
56 }
|