public class oadd.org.apache.hadoop.util.ReadWriteDiskValidatorMetrics extends java.lang.Object
{
oadd.org.apache.hadoop.metrics.lib.MutableCounterInt failureCount;
oadd.org.apache.hadoop.metrics.lib.MutableGaugeLong lastFailureTime;
private final oadd.org.apache.hadoop.metrics.lib.MetricsRegistry registry;
private static final oadd.org.apache.hadoop.metrics.MetricsInfo RECORD_INFO;
private final int[] quantileIntervals;
private final oadd.org.apache.hadoop.metrics.lib.MutableQuantiles[] fileReadQuantiles;
private final oadd.org.apache.hadoop.metrics.lib.MutableQuantiles[] fileWriteQuantiles;
protected static final java.util.Map DIR_METRICS;
public void <init>()
{
oadd.org.apache.hadoop.util.ReadWriteDiskValidatorMetrics v;
int[] v, v, v, v, v;
int v, v, v, v, v, v, v, v;
java.lang.String v, v;
oadd.org.apache.hadoop.metrics.lib.MutableQuantiles[] v, v, v, v, v, v;
oadd.org.apache.hadoop.metrics.lib.MetricsRegistry v, v, v;
oadd.org.apache.hadoop.metrics.MetricsInfo v;
oadd.org.apache.hadoop.metrics.lib.MutableQuantiles v, v;
v := @this: oadd.org.apache.hadoop.util.ReadWriteDiskValidatorMetrics;
specialinvoke v.<java.lang.Object: void <init>()>();
v = newarray (int)[3];
v[0] = 3600;
v[1] = 86400;
v[2] = 864000;
v.<oadd.org.apache.hadoop.util.ReadWriteDiskValidatorMetrics: int[] quantileIntervals> = v;
v = new oadd.org.apache.hadoop.metrics.lib.MetricsRegistry;
v = <oadd.org.apache.hadoop.util.ReadWriteDiskValidatorMetrics: oadd.org.apache.hadoop.metrics.MetricsInfo RECORD_INFO>;
specialinvoke v.<oadd.org.apache.hadoop.metrics.lib.MetricsRegistry: void <init>(oadd.org.apache.hadoop.metrics.MetricsInfo)>(v);
v.<oadd.org.apache.hadoop.util.ReadWriteDiskValidatorMetrics: oadd.org.apache.hadoop.metrics.lib.MetricsRegistry registry> = v;
v = v.<oadd.org.apache.hadoop.util.ReadWriteDiskValidatorMetrics: int[] quantileIntervals>;
v = lengthof v;
v = newarray (oadd.org.apache.hadoop.metrics.lib.MutableQuantiles)[v];
v.<oadd.org.apache.hadoop.util.ReadWriteDiskValidatorMetrics: oadd.org.apache.hadoop.metrics.lib.MutableQuantiles[] fileReadQuantiles> = v;
v = 0;
label:
v = v.<oadd.org.apache.hadoop.util.ReadWriteDiskValidatorMetrics: oadd.org.apache.hadoop.metrics.lib.MutableQuantiles[] fileReadQuantiles>;
v = lengthof v;
if v >= v goto label;
v = v.<oadd.org.apache.hadoop.util.ReadWriteDiskValidatorMetrics: int[] quantileIntervals>;
v = v[v];
v = v.<oadd.org.apache.hadoop.util.ReadWriteDiskValidatorMetrics: oadd.org.apache.hadoop.metrics.lib.MutableQuantiles[] fileReadQuantiles>;
v = v.<oadd.org.apache.hadoop.util.ReadWriteDiskValidatorMetrics: oadd.org.apache.hadoop.metrics.lib.MetricsRegistry registry>;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (int)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("readLatency\u0001s");
v = virtualinvoke v.<oadd.org.apache.hadoop.metrics.lib.MetricsRegistry: oadd.org.apache.hadoop.metrics.lib.MutableQuantiles newQuantiles(java.lang.String,java.lang.String,java.lang.String,java.lang.String,int)>(v, "File read latency", "Ops", "latencyMicros", v);
v[v] = v;
v = v + 1;
goto label;
label:
v = v.<oadd.org.apache.hadoop.util.ReadWriteDiskValidatorMetrics: int[] quantileIntervals>;
v = lengthof v;
v = newarray (oadd.org.apache.hadoop.metrics.lib.MutableQuantiles)[v];
v.<oadd.org.apache.hadoop.util.ReadWriteDiskValidatorMetrics: oadd.org.apache.hadoop.metrics.lib.MutableQuantiles[] fileWriteQuantiles> = v;
v = 0;
label:
v = v.<oadd.org.apache.hadoop.util.ReadWriteDiskValidatorMetrics: oadd.org.apache.hadoop.metrics.lib.MutableQuantiles[] fileWriteQuantiles>;
v = lengthof v;
if v >= v goto label;
v = v.<oadd.org.apache.hadoop.util.ReadWriteDiskValidatorMetrics: int[] quantileIntervals>;
v = v[v];
v = v.<oadd.org.apache.hadoop.util.ReadWriteDiskValidatorMetrics: oadd.org.apache.hadoop.metrics.lib.MutableQuantiles[] fileWriteQuantiles>;
v = v.<oadd.org.apache.hadoop.util.ReadWriteDiskValidatorMetrics: oadd.org.apache.hadoop.metrics.lib.MetricsRegistry registry>;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (int)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("writeLatency\u0001s");
v = virtualinvoke v.<oadd.org.apache.hadoop.metrics.lib.MetricsRegistry: oadd.org.apache.hadoop.metrics.lib.MutableQuantiles newQuantiles(java.lang.String,java.lang.String,java.lang.String,java.lang.String,int)>(v, "File write latency", "Ops", "latencyMicros", v);
v[v] = v;
v = v + 1;
goto label;
label:
return;
}
public static synchronized oadd.org.apache.hadoop.util.ReadWriteDiskValidatorMetrics getMetric(java.lang.String)
{
oadd.org.apache.hadoop.util.ReadWriteDiskValidatorMetrics v;
oadd.org.apache.hadoop.metrics.MetricsSystem v;
java.util.Map v, v;
java.lang.Object v;
java.lang.String v, v, v;
v := @parameter: java.lang.String;
v = staticinvoke <oadd.org.apache.hadoop.metrics.lib.DefaultMetricsSystem: oadd.org.apache.hadoop.metrics.MetricsSystem instance()>();
v = <oadd.org.apache.hadoop.util.ReadWriteDiskValidatorMetrics: java.util.Map DIR_METRICS>;
v = interfaceinvoke v.<java.util.Map: java.lang.Object get(java.lang.Object)>(v);
if v != null goto label;
v = new oadd.org.apache.hadoop.util.ReadWriteDiskValidatorMetrics;
specialinvoke v.<oadd.org.apache.hadoop.util.ReadWriteDiskValidatorMetrics: void <init>()>();
v = v;
if v == null goto label;
v = staticinvoke <oadd.org.apache.hadoop.util.ReadWriteDiskValidatorMetrics: java.lang.String sourceName(java.lang.String)>(v);
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("Metrics for directory: \u0001");
virtualinvoke v.<oadd.org.apache.hadoop.metrics.MetricsSystem: java.lang.Object register(java.lang.String,java.lang.String,java.lang.Object)>(v, v, v);
label:
v = <oadd.org.apache.hadoop.util.ReadWriteDiskValidatorMetrics: java.util.Map DIR_METRICS>;
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, v);
label:
return v;
}
public void addWriteFileLatency(long)
{
oadd.org.apache.hadoop.metrics.lib.MutableQuantiles[] v, v;
oadd.org.apache.hadoop.util.ReadWriteDiskValidatorMetrics v;
int v, v;
oadd.org.apache.hadoop.metrics.lib.MutableQuantiles v;
long v;
v := @this: oadd.org.apache.hadoop.util.ReadWriteDiskValidatorMetrics;
v := @parameter: long;
v = v.<oadd.org.apache.hadoop.util.ReadWriteDiskValidatorMetrics: oadd.org.apache.hadoop.metrics.lib.MutableQuantiles[] fileWriteQuantiles>;
if v == null goto label;
v = v.<oadd.org.apache.hadoop.util.ReadWriteDiskValidatorMetrics: oadd.org.apache.hadoop.metrics.lib.MutableQuantiles[] fileWriteQuantiles>;
v = lengthof v;
v = 0;
label:
if v >= v goto label;
v = v[v];
virtualinvoke v.<oadd.org.apache.hadoop.metrics.lib.MutableQuantiles: void add(long)>(v);
v = v + 1;
goto label;
label:
return;
}
public void addReadFileLatency(long)
{
oadd.org.apache.hadoop.metrics.lib.MutableQuantiles[] v, v;
oadd.org.apache.hadoop.util.ReadWriteDiskValidatorMetrics v;
int v, v;
oadd.org.apache.hadoop.metrics.lib.MutableQuantiles v;
long v;
v := @this: oadd.org.apache.hadoop.util.ReadWriteDiskValidatorMetrics;
v := @parameter: long;
v = v.<oadd.org.apache.hadoop.util.ReadWriteDiskValidatorMetrics: oadd.org.apache.hadoop.metrics.lib.MutableQuantiles[] fileReadQuantiles>;
if v == null goto label;
v = v.<oadd.org.apache.hadoop.util.ReadWriteDiskValidatorMetrics: oadd.org.apache.hadoop.metrics.lib.MutableQuantiles[] fileReadQuantiles>;
v = lengthof v;
v = 0;
label:
if v >= v goto label;
v = v[v];
virtualinvoke v.<oadd.org.apache.hadoop.metrics.lib.MutableQuantiles: void add(long)>(v);
v = v + 1;
goto label;
label:
return;
}
protected static java.lang.String sourceName(java.lang.String)
{
oadd.org.apache.hadoop.metrics.MetricsInfo v;
java.lang.StringBuilder v, v;
java.lang.String v, v, v;
v := @parameter: java.lang.String;
v = new java.lang.StringBuilder;
v = <oadd.org.apache.hadoop.util.ReadWriteDiskValidatorMetrics: oadd.org.apache.hadoop.metrics.MetricsInfo RECORD_INFO>;
v = interfaceinvoke v.<oadd.org.apache.hadoop.metrics.MetricsInfo: java.lang.String name()>();
specialinvoke v.<java.lang.StringBuilder: void <init>(java.lang.String)>(v);
v = virtualinvoke v.<java.lang.StringBuilder: java.lang.StringBuilder append(java.lang.String)>(",dir=");
virtualinvoke v.<java.lang.StringBuilder: java.lang.StringBuilder append(java.lang.String)>(v);
v = virtualinvoke v.<java.lang.StringBuilder: java.lang.String toString()>();
return v;
}
public void diskCheckFailed()
{
oadd.org.apache.hadoop.metrics.lib.MutableCounterInt v;
oadd.org.apache.hadoop.util.ReadWriteDiskValidatorMetrics v;
long v;
oadd.org.apache.hadoop.metrics.lib.MutableGaugeLong v;
v := @this: oadd.org.apache.hadoop.util.ReadWriteDiskValidatorMetrics;
v = v.<oadd.org.apache.hadoop.util.ReadWriteDiskValidatorMetrics: oadd.org.apache.hadoop.metrics.lib.MutableCounterInt failureCount>;
virtualinvoke v.<oadd.org.apache.hadoop.metrics.lib.MutableCounterInt: void incr()>();
v = v.<oadd.org.apache.hadoop.util.ReadWriteDiskValidatorMetrics: oadd.org.apache.hadoop.metrics.lib.MutableGaugeLong lastFailureTime>;
v = staticinvoke <java.lang.System: long nanoTime()>();
virtualinvoke v.<oadd.org.apache.hadoop.metrics.lib.MutableGaugeLong: void set(long)>(v);
return;
}
protected oadd.org.apache.hadoop.metrics.lib.MutableQuantiles[] getFileReadQuantiles()
{
oadd.org.apache.hadoop.metrics.lib.MutableQuantiles[] v;
oadd.org.apache.hadoop.util.ReadWriteDiskValidatorMetrics v;
v := @this: oadd.org.apache.hadoop.util.ReadWriteDiskValidatorMetrics;
v = v.<oadd.org.apache.hadoop.util.ReadWriteDiskValidatorMetrics: oadd.org.apache.hadoop.metrics.lib.MutableQuantiles[] fileReadQuantiles>;
return v;
}
protected oadd.org.apache.hadoop.metrics.lib.MutableQuantiles[] getFileWriteQuantiles()
{
oadd.org.apache.hadoop.metrics.lib.MutableQuantiles[] v;
oadd.org.apache.hadoop.util.ReadWriteDiskValidatorMetrics v;
v := @this: oadd.org.apache.hadoop.util.ReadWriteDiskValidatorMetrics;
v = v.<oadd.org.apache.hadoop.util.ReadWriteDiskValidatorMetrics: oadd.org.apache.hadoop.metrics.lib.MutableQuantiles[] fileWriteQuantiles>;
return v;
}
static void <clinit>()
{
oadd.org.apache.hadoop.metrics.MetricsInfo v;
java.util.HashMap v;
v = staticinvoke <oadd.org.apache.hadoop.metrics.lib.Interns: oadd.org.apache.hadoop.metrics.MetricsInfo info(java.lang.String,java.lang.String)>("ReadWriteDiskValidatorMetrics", "Metrics for the DiskValidator");
<oadd.org.apache.hadoop.util.ReadWriteDiskValidatorMetrics: oadd.org.apache.hadoop.metrics.MetricsInfo RECORD_INFO> = v;
v = new java.util.HashMap;
specialinvoke v.<java.util.HashMap: void <init>()>();
<oadd.org.apache.hadoop.util.ReadWriteDiskValidatorMetrics: java.util.Map DIR_METRICS> = v;
return;
}
}