public final class org.apache.kafkaesque.common.metrics.Sensor extends java.lang.Object
{
private final org.apache.kafkaesque.common.metrics.Metrics registry;
private final java.lang.String name;
private final org.apache.kafkaesque.common.metrics.Sensor[] parents;
private final java.util.List stats;
private final java.util.Map metrics;
private final org.apache.kafkaesque.common.metrics.MetricConfig config;
private final org.apache.kafkaesque.common.utils.Time time;
private volatile long lastRecordTime;
private final long inactiveSensorExpirationTimeMs;
private final java.lang.Object metricLock;
private final org.apache.kafkaesque.common.metrics.Sensor$RecordingLevel recordingLevel;
void <init>(org.apache.kafkaesque.common.metrics.Metrics, java.lang.String, org.apache.kafkaesque.common.metrics.Sensor[], org.apache.kafkaesque.common.metrics.MetricConfig, org.apache.kafkaesque.common.utils.Time, long, org.apache.kafkaesque.common.metrics.Sensor$RecordingLevel)
{
org.apache.kafkaesque.common.metrics.Sensor v;
org.apache.kafkaesque.common.metrics.Metrics v;
long v, v, v;
java.util.ArrayList v;
java.util.HashSet v;
java.util.LinkedHashMap v;
org.apache.kafkaesque.common.metrics.Sensor[] v, v;
org.apache.kafkaesque.common.utils.Time v;
java.lang.String v;
org.apache.kafkaesque.common.metrics.Sensor$RecordingLevel v;
java.util.concurrent.TimeUnit v, v;
org.apache.kafkaesque.common.metrics.MetricConfig v;
java.lang.Object v, v;
v := @this: org.apache.kafkaesque.common.metrics.Sensor;
v := @parameter: org.apache.kafkaesque.common.metrics.Metrics;
v := @parameter: java.lang.String;
v := @parameter: org.apache.kafkaesque.common.metrics.Sensor[];
v := @parameter: org.apache.kafkaesque.common.metrics.MetricConfig;
v := @parameter: org.apache.kafkaesque.common.utils.Time;
v := @parameter: long;
v := @parameter: org.apache.kafkaesque.common.metrics.Sensor$RecordingLevel;
specialinvoke v.<java.lang.Object: void <init>()>();
v.<org.apache.kafkaesque.common.metrics.Sensor: org.apache.kafkaesque.common.metrics.Metrics registry> = v;
v = staticinvoke <java.util.Objects: java.lang.Object requireNonNull(java.lang.Object)>(v);
v.<org.apache.kafkaesque.common.metrics.Sensor: java.lang.String name> = v;
if v != null goto label;
v = newarray (org.apache.kafkaesque.common.metrics.Sensor)[0];
goto label;
label:
v = v;
label:
v.<org.apache.kafkaesque.common.metrics.Sensor: org.apache.kafkaesque.common.metrics.Sensor[] parents> = v;
v = new java.util.LinkedHashMap;
specialinvoke v.<java.util.LinkedHashMap: void <init>()>();
v.<org.apache.kafkaesque.common.metrics.Sensor: java.util.Map metrics> = v;
v = new java.util.ArrayList;
specialinvoke v.<java.util.ArrayList: void <init>()>();
v.<org.apache.kafkaesque.common.metrics.Sensor: java.util.List stats> = v;
v.<org.apache.kafkaesque.common.metrics.Sensor: org.apache.kafkaesque.common.metrics.MetricConfig config> = v;
v.<org.apache.kafkaesque.common.metrics.Sensor: org.apache.kafkaesque.common.utils.Time time> = v;
v = <java.util.concurrent.TimeUnit: java.util.concurrent.TimeUnit MILLISECONDS>;
v = <java.util.concurrent.TimeUnit: java.util.concurrent.TimeUnit SECONDS>;
v = virtualinvoke v.<java.util.concurrent.TimeUnit: long convert(long,java.util.concurrent.TimeUnit)>(v, v);
v.<org.apache.kafkaesque.common.metrics.Sensor: long inactiveSensorExpirationTimeMs> = v;
v = interfaceinvoke v.<org.apache.kafkaesque.common.utils.Time: long milliseconds()>();
v.<org.apache.kafkaesque.common.metrics.Sensor: long lastRecordTime> = v;
v.<org.apache.kafkaesque.common.metrics.Sensor: org.apache.kafkaesque.common.metrics.Sensor$RecordingLevel recordingLevel> = v;
v = new java.lang.Object;
specialinvoke v.<java.lang.Object: void <init>()>();
v.<org.apache.kafkaesque.common.metrics.Sensor: java.lang.Object metricLock> = v;
v = new java.util.HashSet;
specialinvoke v.<java.util.HashSet: void <init>()>();
specialinvoke v.<org.apache.kafkaesque.common.metrics.Sensor: void checkForest(java.util.Set)>(v);
return;
}
private void checkForest(java.util.Set)
{
org.apache.kafkaesque.common.metrics.Sensor v, v;
java.util.Set v;
java.lang.IllegalArgumentException v;
org.apache.kafkaesque.common.metrics.Sensor[] v;
int v, v;
java.lang.String v, v;
boolean v;
v := @this: org.apache.kafkaesque.common.metrics.Sensor;
v := @parameter: java.util.Set;
v = interfaceinvoke v.<java.util.Set: boolean add(java.lang.Object)>(v);
if v != 0 goto label;
v = new java.lang.IllegalArgumentException;
v = virtualinvoke v.<org.apache.kafkaesque.common.metrics.Sensor: java.lang.String name()>();
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[])>("Circular dependency in sensors: \u is its own parent.");
specialinvoke v.<java.lang.IllegalArgumentException: void <init>(java.lang.String)>(v);
throw v;
label:
v = v.<org.apache.kafkaesque.common.metrics.Sensor: org.apache.kafkaesque.common.metrics.Sensor[] parents>;
v = lengthof v;
v = 0;
label:
if v >= v goto label;
v = v[v];
specialinvoke v.<org.apache.kafkaesque.common.metrics.Sensor: void checkForest(java.util.Set)>(v);
v = v + 1;
goto label;
label:
return;
}
public java.lang.String name()
{
org.apache.kafkaesque.common.metrics.Sensor v;
java.lang.String v;
v := @this: org.apache.kafkaesque.common.metrics.Sensor;
v = v.<org.apache.kafkaesque.common.metrics.Sensor: java.lang.String name>;
return v;
}
java.util.List parents()
{
java.util.List v, v;
org.apache.kafkaesque.common.metrics.Sensor v;
org.apache.kafkaesque.common.metrics.Sensor[] v;
v := @this: org.apache.kafkaesque.common.metrics.Sensor;
v = v.<org.apache.kafkaesque.common.metrics.Sensor: org.apache.kafkaesque.common.metrics.Sensor[] parents>;
v = staticinvoke <java.util.Arrays: java.util.List asList(java.lang.Object[])>(v);
v = staticinvoke <java.util.Collections: java.util.List unmodifiableList(java.util.List)>(v);
return v;
}
public void record()
{
org.apache.kafkaesque.common.metrics.Sensor v;
boolean v;
v := @this: org.apache.kafkaesque.common.metrics.Sensor;
v = virtualinvoke v.<org.apache.kafkaesque.common.metrics.Sensor: boolean shouldRecord()>();
if v == 0 goto label;
virtualinvoke v.<org.apache.kafkaesque.common.metrics.Sensor: void record(double)>(1.0);
label:
return;
}
public boolean shouldRecord()
{
org.apache.kafkaesque.common.metrics.MetricConfig v;
org.apache.kafkaesque.common.metrics.Sensor v;
org.apache.kafkaesque.common.metrics.Sensor$RecordingLevel v, v;
short v;
boolean v;
v := @this: org.apache.kafkaesque.common.metrics.Sensor;
v = v.<org.apache.kafkaesque.common.metrics.Sensor: org.apache.kafkaesque.common.metrics.Sensor$RecordingLevel recordingLevel>;
v = v.<org.apache.kafkaesque.common.metrics.Sensor: org.apache.kafkaesque.common.metrics.MetricConfig config>;
v = virtualinvoke v.<org.apache.kafkaesque.common.metrics.MetricConfig: org.apache.kafkaesque.common.metrics.Sensor$RecordingLevel recordLevel()>();
v = v.<org.apache.kafkaesque.common.metrics.Sensor$RecordingLevel: short id>;
v = virtualinvoke v.<org.apache.kafkaesque.common.metrics.Sensor$RecordingLevel: boolean shouldRecord(int)>(v);
return v;
}
public void record(double)
{
org.apache.kafkaesque.common.metrics.Sensor v;
long v;
org.apache.kafkaesque.common.utils.Time v;
boolean v;
double v;
v := @this: org.apache.kafkaesque.common.metrics.Sensor;
v := @parameter: double;
v = virtualinvoke v.<org.apache.kafkaesque.common.metrics.Sensor: boolean shouldRecord()>();
if v == 0 goto label;
v = v.<org.apache.kafkaesque.common.metrics.Sensor: org.apache.kafkaesque.common.utils.Time time>;
v = interfaceinvoke v.<org.apache.kafkaesque.common.utils.Time: long milliseconds()>();
virtualinvoke v.<org.apache.kafkaesque.common.metrics.Sensor: void record(double,long)>(v, v);
label:
return;
}
public void record(double, long)
{
long v;
org.apache.kafkaesque.common.metrics.Sensor v;
double v;
v := @this: org.apache.kafkaesque.common.metrics.Sensor;
v := @parameter: double;
v := @parameter: long;
virtualinvoke v.<org.apache.kafkaesque.common.metrics.Sensor: void record(double,long,boolean)>(v, v, 1);
return;
}
public void record(double, long, boolean)
{
java.lang.Throwable v, v;
org.apache.kafkaesque.common.metrics.Sensor v, v;
long v;
org.apache.kafkaesque.common.metrics.Sensor[] v;
int v, v;
boolean v, v, v;
double v;
java.util.Iterator v;
org.apache.kafkaesque.common.metrics.MetricConfig v;
java.util.List v;
java.lang.Object v, v;
v := @this: org.apache.kafkaesque.common.metrics.Sensor;
v := @parameter: double;
v := @parameter: long;
v := @parameter: boolean;
v = virtualinvoke v.<org.apache.kafkaesque.common.metrics.Sensor: boolean shouldRecord()>();
if v == 0 goto label;
v.<org.apache.kafkaesque.common.metrics.Sensor: long lastRecordTime> = v;
entermonitor v;
label:
v = specialinvoke v.<org.apache.kafkaesque.common.metrics.Sensor: java.lang.Object metricLock()>();
entermonitor v;
label:
v = v.<org.apache.kafkaesque.common.metrics.Sensor: java.util.List stats>;
v = interfaceinvoke v.<java.util.List: java.util.Iterator iterator()>();
label:
v = interfaceinvoke v.<java.util.Iterator: boolean hasNext()>();
if v == 0 goto label;
v = interfaceinvoke v.<java.util.Iterator: java.lang.Object next()>();
v = v.<org.apache.kafkaesque.common.metrics.Sensor: org.apache.kafkaesque.common.metrics.MetricConfig config>;
interfaceinvoke v.<org.apache.kafkaesque.common.metrics.Stat: void record(org.apache.kafkaesque.common.metrics.MetricConfig,double,long)>(v, v, v);
goto label;
label:
exitmonitor v;
label:
goto label;
label:
v := @caughtexception;
exitmonitor v;
throw v;
label:
if v == 0 goto label;
virtualinvoke v.<org.apache.kafkaesque.common.metrics.Sensor: void checkQuotas(long)>(v);
label:
exitmonitor v;
label:
goto label;
label:
v := @caughtexception;
exitmonitor v;
throw v;
label:
v = v.<org.apache.kafkaesque.common.metrics.Sensor: org.apache.kafkaesque.common.metrics.Sensor[] parents>;
v = lengthof v;
v = 0;
label:
if v >= v goto label;
v = v[v];
virtualinvoke v.<org.apache.kafkaesque.common.metrics.Sensor: void record(double,long,boolean)>(v, v, v);
v = v + 1;
goto label;
label:
return;
catch java.lang.Throwable from label to label with label;
catch java.lang.Throwable from label to label with label;
}
public void checkQuotas()
{
long v;
org.apache.kafkaesque.common.metrics.Sensor v;
org.apache.kafkaesque.common.utils.Time v;
v := @this: org.apache.kafkaesque.common.metrics.Sensor;
v = v.<org.apache.kafkaesque.common.metrics.Sensor: org.apache.kafkaesque.common.utils.Time time>;
v = interfaceinvoke v.<org.apache.kafkaesque.common.utils.Time: long milliseconds()>();
virtualinvoke v.<org.apache.kafkaesque.common.metrics.Sensor: void checkQuotas(long)>(v);
return;
}
public void checkQuotas(long)
{
org.apache.kafkaesque.common.metrics.Sensor v;
java.util.Iterator v;
java.util.Collection v;
long v;
org.apache.kafkaesque.common.metrics.MetricConfig v;
org.apache.kafkaesque.common.metrics.Quota v;
org.apache.kafkaesque.common.metrics.QuotaViolationException v;
org.apache.kafkaesque.common.MetricName v;
java.util.Map v;
java.lang.Object v;
boolean v, v;
double v, v;
v := @this: org.apache.kafkaesque.common.metrics.Sensor;
v := @parameter: long;
v = v.<org.apache.kafkaesque.common.metrics.Sensor: java.util.Map metrics>;
v = interfaceinvoke v.<java.util.Map: java.util.Collection values()>();
v = interfaceinvoke v.<java.util.Collection: java.util.Iterator iterator()>();
label:
v = interfaceinvoke v.<java.util.Iterator: boolean hasNext()>();
if v == 0 goto label;
v = interfaceinvoke v.<java.util.Iterator: java.lang.Object next()>();
v = virtualinvoke v.<org.apache.kafkaesque.common.metrics.KafkaMetric: org.apache.kafkaesque.common.metrics.MetricConfig config()>();
if v == null goto label;
v = virtualinvoke v.<org.apache.kafkaesque.common.metrics.MetricConfig: org.apache.kafkaesque.common.metrics.Quota quota()>();
if v == null goto label;
v = virtualinvoke v.<org.apache.kafkaesque.common.metrics.KafkaMetric: double measurableValue(long)>(v);
v = virtualinvoke v.<org.apache.kafkaesque.common.metrics.Quota: boolean acceptable(double)>(v);
if v != 0 goto label;
v = new org.apache.kafkaesque.common.metrics.QuotaViolationException;
v = virtualinvoke v.<org.apache.kafkaesque.common.metrics.KafkaMetric: org.apache.kafkaesque.common.MetricName metricName()>();
v = virtualinvoke v.<org.apache.kafkaesque.common.metrics.Quota: double bound()>();
specialinvoke v.<org.apache.kafkaesque.common.metrics.QuotaViolationException: void <init>(org.apache.kafkaesque.common.MetricName,double,double)>(v, v, v);
throw v;
label:
return;
}
public boolean add(org.apache.kafkaesque.common.metrics.CompoundStat)
{
org.apache.kafkaesque.common.metrics.Sensor v;
org.apache.kafkaesque.common.metrics.CompoundStat v;
boolean v;
v := @this: org.apache.kafkaesque.common.metrics.Sensor;
v := @parameter: org.apache.kafkaesque.common.metrics.CompoundStat;
v = virtualinvoke v.<org.apache.kafkaesque.common.metrics.Sensor: boolean add(org.apache.kafkaesque.common.metrics.CompoundStat,org.apache.kafkaesque.common.metrics.MetricConfig)>(v, null);
return v;
}
public synchronized boolean add(org.apache.kafkaesque.common.metrics.CompoundStat, org.apache.kafkaesque.common.metrics.MetricConfig)
{
org.apache.kafkaesque.common.metrics.Sensor v;
org.apache.kafkaesque.common.metrics.Metrics v;
org.apache.kafkaesque.common.metrics.KafkaMetric v;
java.util.Map v, v;
org.apache.kafkaesque.common.utils.Time v;
boolean v, v, v;
java.util.Iterator v;
org.apache.kafkaesque.common.metrics.CompoundStat v;
org.apache.kafkaesque.common.metrics.Measurable v;
org.apache.kafkaesque.common.metrics.MetricConfig v, v;
java.util.List v, v;
org.apache.kafkaesque.common.MetricName v, v, v;
java.lang.Object v, v, v;
v := @this: org.apache.kafkaesque.common.metrics.Sensor;
v := @parameter: org.apache.kafkaesque.common.metrics.CompoundStat;
v := @parameter: org.apache.kafkaesque.common.metrics.MetricConfig;
v = virtualinvoke v.<org.apache.kafkaesque.common.metrics.Sensor: boolean hasExpired()>();
if v == 0 goto label;
return 0;
label:
v = v.<org.apache.kafkaesque.common.metrics.Sensor: java.util.List stats>;
v = staticinvoke <java.util.Objects: java.lang.Object requireNonNull(java.lang.Object)>(v);
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
v = specialinvoke v.<org.apache.kafkaesque.common.metrics.Sensor: java.lang.Object metricLock()>();
v = interfaceinvoke v.<org.apache.kafkaesque.common.metrics.CompoundStat: java.util.List stats()>();
v = interfaceinvoke v.<java.util.List: java.util.Iterator iterator()>();
label:
v = interfaceinvoke v.<java.util.Iterator: boolean hasNext()>();
if v == 0 goto label;
v = interfaceinvoke v.<java.util.Iterator: java.lang.Object next()>();
v = new org.apache.kafkaesque.common.metrics.KafkaMetric;
v = virtualinvoke v.<org.apache.kafkaesque.common.metrics.CompoundStat$NamedMeasurable: org.apache.kafkaesque.common.MetricName name()>();
v = virtualinvoke v.<org.apache.kafkaesque.common.metrics.CompoundStat$NamedMeasurable: org.apache.kafkaesque.common.metrics.Measurable stat()>();
if v != null goto label;
v = v.<org.apache.kafkaesque.common.metrics.Sensor: org.apache.kafkaesque.common.metrics.MetricConfig config>;
goto label;
label:
v = v;
label:
v = v.<org.apache.kafkaesque.common.metrics.Sensor: org.apache.kafkaesque.common.utils.Time time>;
specialinvoke v.<org.apache.kafkaesque.common.metrics.KafkaMetric: void <init>(java.lang.Object,org.apache.kafkaesque.common.MetricName,org.apache.kafkaesque.common.metrics.MetricValueProvider,org.apache.kafkaesque.common.metrics.MetricConfig,org.apache.kafkaesque.common.utils.Time)>(v, v, v, v, v);
v = v.<org.apache.kafkaesque.common.metrics.Sensor: java.util.Map metrics>;
v = virtualinvoke v.<org.apache.kafkaesque.common.metrics.KafkaMetric: org.apache.kafkaesque.common.MetricName metricName()>();
v = interfaceinvoke v.<java.util.Map: boolean containsKey(java.lang.Object)>(v);
if v != 0 goto label;
v = v.<org.apache.kafkaesque.common.metrics.Sensor: org.apache.kafkaesque.common.metrics.Metrics registry>;
virtualinvoke v.<org.apache.kafkaesque.common.metrics.Metrics: void registerMetric(org.apache.kafkaesque.common.metrics.KafkaMetric)>(v);
v = v.<org.apache.kafkaesque.common.metrics.Sensor: java.util.Map metrics>;
v = virtualinvoke v.<org.apache.kafkaesque.common.metrics.KafkaMetric: org.apache.kafkaesque.common.MetricName metricName()>();
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, v);
goto label;
label:
return 1;
}
public boolean add(org.apache.kafkaesque.common.MetricName, org.apache.kafkaesque.common.metrics.MeasurableStat)
{
org.apache.kafkaesque.common.metrics.Sensor v;
org.apache.kafkaesque.common.MetricName v;
org.apache.kafkaesque.common.metrics.MeasurableStat v;
boolean v;
v := @this: org.apache.kafkaesque.common.metrics.Sensor;
v := @parameter: org.apache.kafkaesque.common.MetricName;
v := @parameter: org.apache.kafkaesque.common.metrics.MeasurableStat;
v = virtualinvoke v.<org.apache.kafkaesque.common.metrics.Sensor: boolean add(org.apache.kafkaesque.common.MetricName,org.apache.kafkaesque.common.metrics.MeasurableStat,org.apache.kafkaesque.common.metrics.MetricConfig)>(v, v, null);
return v;
}
public synchronized boolean add(org.apache.kafkaesque.common.MetricName, org.apache.kafkaesque.common.metrics.MeasurableStat, org.apache.kafkaesque.common.metrics.MetricConfig)
{
org.apache.kafkaesque.common.metrics.Sensor v;
org.apache.kafkaesque.common.metrics.Metrics v;
org.apache.kafkaesque.common.metrics.KafkaMetric v;
java.util.Map v, v;
org.apache.kafkaesque.common.utils.Time v;
boolean v, v;
org.apache.kafkaesque.common.metrics.MeasurableStat v;
org.apache.kafkaesque.common.metrics.MetricConfig v, v;
java.util.List v;
org.apache.kafkaesque.common.MetricName v, v;
java.lang.Object v, v, v;
v := @this: org.apache.kafkaesque.common.metrics.Sensor;
v := @parameter: org.apache.kafkaesque.common.MetricName;
v := @parameter: org.apache.kafkaesque.common.metrics.MeasurableStat;
v := @parameter: org.apache.kafkaesque.common.metrics.MetricConfig;
v = virtualinvoke v.<org.apache.kafkaesque.common.metrics.Sensor: boolean hasExpired()>();
if v == 0 goto label;
return 0;
label:
v = v.<org.apache.kafkaesque.common.metrics.Sensor: java.util.Map metrics>;
v = interfaceinvoke v.<java.util.Map: boolean containsKey(java.lang.Object)>(v);
if v == 0 goto label;
return 1;
label:
v = new org.apache.kafkaesque.common.metrics.KafkaMetric;
v = specialinvoke v.<org.apache.kafkaesque.common.metrics.Sensor: java.lang.Object metricLock()>();
v = staticinvoke <java.util.Objects: java.lang.Object requireNonNull(java.lang.Object)>(v);
v = staticinvoke <java.util.Objects: java.lang.Object requireNonNull(java.lang.Object)>(v);
if v != null goto label;
v = v.<org.apache.kafkaesque.common.metrics.Sensor: org.apache.kafkaesque.common.metrics.MetricConfig config>;
goto label;
label:
v = v;
label:
v = v.<org.apache.kafkaesque.common.metrics.Sensor: org.apache.kafkaesque.common.utils.Time time>;
specialinvoke v.<org.apache.kafkaesque.common.metrics.KafkaMetric: void <init>(java.lang.Object,org.apache.kafkaesque.common.MetricName,org.apache.kafkaesque.common.metrics.MetricValueProvider,org.apache.kafkaesque.common.metrics.MetricConfig,org.apache.kafkaesque.common.utils.Time)>(v, v, v, v, v);
v = v.<org.apache.kafkaesque.common.metrics.Sensor: org.apache.kafkaesque.common.metrics.Metrics registry>;
virtualinvoke v.<org.apache.kafkaesque.common.metrics.Metrics: void registerMetric(org.apache.kafkaesque.common.metrics.KafkaMetric)>(v);
v = v.<org.apache.kafkaesque.common.metrics.Sensor: java.util.Map metrics>;
v = virtualinvoke v.<org.apache.kafkaesque.common.metrics.KafkaMetric: org.apache.kafkaesque.common.MetricName metricName()>();
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, v);
v = v.<org.apache.kafkaesque.common.metrics.Sensor: java.util.List stats>;
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
return 1;
}
public synchronized boolean hasMetrics()
{
org.apache.kafkaesque.common.metrics.Sensor v;
java.util.Map v;
boolean v, v;
v := @this: org.apache.kafkaesque.common.metrics.Sensor;
v = v.<org.apache.kafkaesque.common.metrics.Sensor: java.util.Map metrics>;
v = interfaceinvoke v.<java.util.Map: boolean isEmpty()>();
if v != 0 goto label;
v = 1;
goto label;
label:
v = 0;
label:
return v;
}
public boolean hasExpired()
{
org.apache.kafkaesque.common.metrics.Sensor v;
long v, v, v, v;
byte v;
org.apache.kafkaesque.common.utils.Time v;
boolean v;
v := @this: org.apache.kafkaesque.common.metrics.Sensor;
v = v.<org.apache.kafkaesque.common.metrics.Sensor: org.apache.kafkaesque.common.utils.Time time>;
v = interfaceinvoke v.<org.apache.kafkaesque.common.utils.Time: long milliseconds()>();
v = v.<org.apache.kafkaesque.common.metrics.Sensor: long lastRecordTime>;
v = v - v;
v = v.<org.apache.kafkaesque.common.metrics.Sensor: long inactiveSensorExpirationTimeMs>;
v = v cmp v;
if v <= 0 goto label;
v = 1;
goto label;
label:
v = 0;
label:
return v;
}
synchronized java.util.List metrics()
{
java.util.List v;
org.apache.kafkaesque.common.metrics.Sensor v;
java.util.Collection v;
java.util.Map v;
java.util.LinkedList v;
v := @this: org.apache.kafkaesque.common.metrics.Sensor;
v = new java.util.LinkedList;
v = v.<org.apache.kafkaesque.common.metrics.Sensor: java.util.Map metrics>;
v = interfaceinvoke v.<java.util.Map: java.util.Collection values()>();
specialinvoke v.<java.util.LinkedList: void <init>(java.util.Collection)>(v);
v = staticinvoke <java.util.Collections: java.util.List unmodifiableList(java.util.List)>(v);
return v;
}
private java.lang.Object metricLock()
{
java.lang.Object v;
org.apache.kafkaesque.common.metrics.Sensor v;
v := @this: org.apache.kafkaesque.common.metrics.Sensor;
v = v.<org.apache.kafkaesque.common.metrics.Sensor: java.lang.Object metricLock>;
return v;
}
}