|
@@ -53,6 +53,9 @@ public class FSOpDurations implements MetricsSource {
|
|
@Metric("Duration for an update call")
|
|
@Metric("Duration for an update call")
|
|
MutableRate updateCall;
|
|
MutableRate updateCall;
|
|
|
|
|
|
|
|
+ @Metric("Duration for a preempt call")
|
|
|
|
+ MutableRate preemptCall;
|
|
|
|
+
|
|
private static final MetricsInfo RECORD_INFO =
|
|
private static final MetricsInfo RECORD_INFO =
|
|
info("FSOpDurations", "Durations of FairScheduler calls or thread-runs");
|
|
info("FSOpDurations", "Durations of FairScheduler calls or thread-runs");
|
|
|
|
|
|
@@ -85,6 +88,7 @@ public class FSOpDurations implements MetricsSource {
|
|
nodeUpdateCall.setExtended(isExtended);
|
|
nodeUpdateCall.setExtended(isExtended);
|
|
updateThreadRun.setExtended(isExtended);
|
|
updateThreadRun.setExtended(isExtended);
|
|
updateCall.setExtended(isExtended);
|
|
updateCall.setExtended(isExtended);
|
|
|
|
+ preemptCall.setExtended(isExtended);
|
|
|
|
|
|
INSTANCE.isExtended = isExtended;
|
|
INSTANCE.isExtended = isExtended;
|
|
}
|
|
}
|
|
@@ -110,6 +114,10 @@ public class FSOpDurations implements MetricsSource {
|
|
updateCall.add(value);
|
|
updateCall.add(value);
|
|
}
|
|
}
|
|
|
|
|
|
|
|
+ public void addPreemptCallDuration(long value) {
|
|
|
|
+ preemptCall.add(value);
|
|
|
|
+ }
|
|
|
|
+
|
|
@VisibleForTesting
|
|
@VisibleForTesting
|
|
public boolean hasUpdateThreadRunChanged() {
|
|
public boolean hasUpdateThreadRunChanged() {
|
|
return updateThreadRun.changed();
|
|
return updateThreadRun.changed();
|