File tree Expand file tree Collapse file tree 1 file changed +6
-1
lines changed
src/java/org/apache/cassandra/service Expand file tree Collapse file tree 1 file changed +6
-1
lines changed Original file line number Diff line number Diff line change @@ -296,7 +296,8 @@ else if (duration > getGcConcurrentPhaseLogThresholdInMs())
296296 logger .info (sb .toString ());
297297 else if (logger .isTraceEnabled ())
298298 logger .trace (sb .toString ());
299- // TODO: trigger StatusLogger if concurrent phases take too long?
299+ if (duration > this .getConcurrentStatusThresholdInMs ())
300+ StatusLogger .log ();
300301 }
301302 else
302303 {
@@ -479,4 +480,8 @@ public long getStatusThresholdInMs()
479480 return getGcWarnThresholdInMs () != 0 ? getGcWarnThresholdInMs () : getGcLogThresholdInMs ();
480481 }
481482
483+ public long getConcurrentStatusThresholdInMs ()
484+ {
485+ return getGcConcurrentPhaseWarnThresholdInMs () != 0 ? getGcConcurrentPhaseWarnThresholdInMs () : getGcConcurrentPhaseLogThresholdInMs ();
486+ }
482487}
You can’t perform that action at this time.
0 commit comments