public final class org.apache.kafkaesque.common.metrics.internals.IntGaugeSuite extends java.lang.Object implements java.lang.AutoCloseable
{
private final org.slf4j.Logger log;
private final java.lang.String suiteName;
private final org.apache.kafkaesque.common.metrics.Metrics metrics;
private final java.util.function.Function metricNameCalculator;
private final int maxEntries;
private final java.util.Map gauges;
private final java.util.Set removable;
private final java.util.concurrent.ConcurrentLinkedDeque pending;
private final java.util.concurrent.locks.Lock modifyMetricsLock;
private boolean closed;
public void <init>(org.slf4j.Logger, java.lang.String, org.apache.kafkaesque.common.metrics.Metrics, java.util.function.Function, int)
{
org.slf4j.Logger v;
java.util.concurrent.locks.ReentrantLock v;
org.apache.kafkaesque.common.metrics.Metrics v;
java.util.HashMap v;
java.lang.Integer v;
java.util.function.Function v;
java.util.concurrent.ConcurrentLinkedDeque v;
java.util.HashSet v;
int v;
org.apache.kafkaesque.common.metrics.internals.IntGaugeSuite v;
java.lang.String v;
v := @this: org.apache.kafkaesque.common.metrics.internals.IntGaugeSuite;
v := @parameter: org.slf4j.Logger;
v := @parameter: java.lang.String;
v := @parameter: org.apache.kafkaesque.common.metrics.Metrics;
v := @parameter: java.util.function.Function;
v := @parameter: int;
specialinvoke v.<java.lang.Object: void <init>()>();
v.<org.apache.kafkaesque.common.metrics.internals.IntGaugeSuite: org.slf4j.Logger log> = v;
v.<org.apache.kafkaesque.common.metrics.internals.IntGaugeSuite: java.lang.String suiteName> = v;
v.<org.apache.kafkaesque.common.metrics.internals.IntGaugeSuite: org.apache.kafkaesque.common.metrics.Metrics metrics> = v;
v.<org.apache.kafkaesque.common.metrics.internals.IntGaugeSuite: java.util.function.Function metricNameCalculator> = v;
v.<org.apache.kafkaesque.common.metrics.internals.IntGaugeSuite: int maxEntries> = v;
v = new java.util.HashMap;
specialinvoke v.<java.util.HashMap: void <init>(int)>(1);
v.<org.apache.kafkaesque.common.metrics.internals.IntGaugeSuite: java.util.Map gauges> = v;
v = new java.util.HashSet;
specialinvoke v.<java.util.HashSet: void <init>()>();
v.<org.apache.kafkaesque.common.metrics.internals.IntGaugeSuite: java.util.Set removable> = v;
v = new java.util.concurrent.ConcurrentLinkedDeque;
specialinvoke v.<java.util.concurrent.ConcurrentLinkedDeque: void <init>()>();
v.<org.apache.kafkaesque.common.metrics.internals.IntGaugeSuite: java.util.concurrent.ConcurrentLinkedDeque pending> = v;
v = new java.util.concurrent.locks.ReentrantLock;
specialinvoke v.<java.util.concurrent.locks.ReentrantLock: void <init>()>();
v.<org.apache.kafkaesque.common.metrics.internals.IntGaugeSuite: java.util.concurrent.locks.Lock modifyMetricsLock> = v;
v.<org.apache.kafkaesque.common.metrics.internals.IntGaugeSuite: boolean closed> = 0;
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
interfaceinvoke v.<org.slf4j.Logger: void trace(java.lang.String,java.lang.Object,java.lang.Object)>("{}: created new gauge suite with maxEntries = {}.", v, v);
return;
}
public void increment(java.lang.Object)
{
java.lang.Integer v;
java.util.Map v, v, v, v, v;
boolean v, v;
org.apache.kafkaesque.common.metrics.internals.IntGaugeSuite$StoredIntGauge v;
java.util.Set v, v, v;
org.apache.kafkaesque.common.MetricName v;
java.lang.Throwable v;
java.lang.Object[] v;
java.util.function.Function v;
int v, v, v, v;
org.apache.kafkaesque.common.metrics.internals.IntGaugeSuite v;
java.lang.String v, v, v, v, v, v, v, v;
org.apache.kafkaesque.common.metrics.internals.IntGaugeSuite$PendingMetricsChange v, v;
org.slf4j.Logger v, v, v, v;
java.util.Iterator v;
java.util.concurrent.ConcurrentLinkedDeque v, v;
java.lang.Object v, v, v, v, v;
v := @this: org.apache.kafkaesque.common.metrics.internals.IntGaugeSuite;
v := @parameter: java.lang.Object;
entermonitor v;
label:
v = v.<org.apache.kafkaesque.common.metrics.internals.IntGaugeSuite: boolean closed>;
if v == 0 goto label;
v = v.<org.apache.kafkaesque.common.metrics.internals.IntGaugeSuite: org.slf4j.Logger log>;
v = v.<org.apache.kafkaesque.common.metrics.internals.IntGaugeSuite: java.lang.String suiteName>;
v = virtualinvoke v.<java.lang.Object: java.lang.String toString()>();
interfaceinvoke v.<org.slf4j.Logger: void warn(java.lang.String,java.lang.Object,java.lang.Object)>("{}: Attempted to increment {}, but the GaugeSuite was closed.", v, v);
exitmonitor v;
label:
return;
label:
v = v.<org.apache.kafkaesque.common.metrics.internals.IntGaugeSuite: java.util.Map gauges>;
v = interfaceinvoke v.<java.util.Map: java.lang.Object get(java.lang.Object)>(v);
if v == null goto label;
v = virtualinvoke v.<org.apache.kafkaesque.common.metrics.internals.IntGaugeSuite$StoredIntGauge: int increment()>();
if v <= 0 goto label;
v = v.<org.apache.kafkaesque.common.metrics.internals.IntGaugeSuite: java.util.Set removable>;
interfaceinvoke v.<java.util.Set: boolean remove(java.lang.Object)>(v);
label:
exitmonitor v;
label:
return;
label:
v = v.<org.apache.kafkaesque.common.metrics.internals.IntGaugeSuite: java.util.Map gauges>;
v = interfaceinvoke v.<java.util.Map: int size()>();
v = v.<org.apache.kafkaesque.common.metrics.internals.IntGaugeSuite: int maxEntries>;
if v != v goto label;
v = v.<org.apache.kafkaesque.common.metrics.internals.IntGaugeSuite: java.util.Set removable>;
v = interfaceinvoke v.<java.util.Set: boolean isEmpty()>();
if v == 0 goto label;
v = v.<org.apache.kafkaesque.common.metrics.internals.IntGaugeSuite: org.slf4j.Logger log>;
v = newarray (java.lang.Object)[3];
v = v.<org.apache.kafkaesque.common.metrics.internals.IntGaugeSuite: java.lang.String suiteName>;
v[0] = v;
v = virtualinvoke v.<java.lang.Object: java.lang.String toString()>();
v[1] = v;
v = v.<org.apache.kafkaesque.common.metrics.internals.IntGaugeSuite: int maxEntries>;
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
v[2] = v;
interfaceinvoke v.<org.slf4j.Logger: void debug(java.lang.String,java.lang.Object[])>("{}: Attempted to increment {}, but there are already {} entries.", v);
exitmonitor v;
label:
return;
label:
v = v.<org.apache.kafkaesque.common.metrics.internals.IntGaugeSuite: java.util.Set removable>;
v = interfaceinvoke v.<java.util.Set: java.util.Iterator iterator()>();
v = interfaceinvoke v.<java.util.Iterator: java.lang.Object next()>();
interfaceinvoke v.<java.util.Iterator: void remove()>();
v = v.<org.apache.kafkaesque.common.metrics.internals.IntGaugeSuite: java.util.Map gauges>;
v = interfaceinvoke v.<java.util.Map: java.lang.Object get(java.lang.Object)>(v);
v = v.<org.apache.kafkaesque.common.metrics.internals.IntGaugeSuite$StoredIntGauge: org.apache.kafkaesque.common.MetricName metricName>;
v = v.<org.apache.kafkaesque.common.metrics.internals.IntGaugeSuite: java.util.Map gauges>;
interfaceinvoke v.<java.util.Map: java.lang.Object remove(java.lang.Object)>(v);
v = v.<org.apache.kafkaesque.common.metrics.internals.IntGaugeSuite: java.util.concurrent.ConcurrentLinkedDeque pending>;
v = new org.apache.kafkaesque.common.metrics.internals.IntGaugeSuite$PendingMetricsChange;
specialinvoke v.<org.apache.kafkaesque.common.metrics.internals.IntGaugeSuite$PendingMetricsChange: void <init>(org.apache.kafkaesque.common.MetricName,org.apache.kafkaesque.common.metrics.MetricValueProvider)>(v, null);
virtualinvoke v.<java.util.concurrent.ConcurrentLinkedDeque: void push(java.lang.Object)>(v);
v = v.<org.apache.kafkaesque.common.metrics.internals.IntGaugeSuite: org.slf4j.Logger log>;
v = v.<org.apache.kafkaesque.common.metrics.internals.IntGaugeSuite: java.lang.String suiteName>;
v = virtualinvoke v.<java.lang.Object: java.lang.String toString()>();
interfaceinvoke v.<org.slf4j.Logger: void trace(java.lang.String,java.lang.Object,java.lang.Object)>("{}: Removing the metric {}, which has a value of 0.", v, v);
label:
v = v.<org.apache.kafkaesque.common.metrics.internals.IntGaugeSuite: java.util.function.Function metricNameCalculator>;
v = interfaceinvoke v.<java.util.function.Function: java.lang.Object apply(java.lang.Object)>(v);
v = new org.apache.kafkaesque.common.metrics.internals.IntGaugeSuite$StoredIntGauge;
specialinvoke v.<org.apache.kafkaesque.common.metrics.internals.IntGaugeSuite$StoredIntGauge: void <init>(org.apache.kafkaesque.common.MetricName)>(v);
v = v.<org.apache.kafkaesque.common.metrics.internals.IntGaugeSuite: java.util.Map gauges>;
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, v);
v = v.<org.apache.kafkaesque.common.metrics.internals.IntGaugeSuite: java.util.concurrent.ConcurrentLinkedDeque pending>;
v = new org.apache.kafkaesque.common.metrics.internals.IntGaugeSuite$PendingMetricsChange;
specialinvoke v.<org.apache.kafkaesque.common.metrics.internals.IntGaugeSuite$PendingMetricsChange: void <init>(org.apache.kafkaesque.common.MetricName,org.apache.kafkaesque.common.metrics.MetricValueProvider)>(v, v);
virtualinvoke v.<java.util.concurrent.ConcurrentLinkedDeque: void push(java.lang.Object)>(v);
v = v.<org.apache.kafkaesque.common.metrics.internals.IntGaugeSuite: org.slf4j.Logger log>;
v = v.<org.apache.kafkaesque.common.metrics.internals.IntGaugeSuite: java.lang.String suiteName>;
v = virtualinvoke v.<java.lang.Object: java.lang.String toString()>();
interfaceinvoke v.<org.slf4j.Logger: void trace(java.lang.String,java.lang.Object,java.lang.Object)>("{}: Adding a new metric {}.", v, v);
exitmonitor v;
label:
goto label;
label:
v := @caughtexception;
exitmonitor v;
throw v;
label:
specialinvoke v.<org.apache.kafkaesque.common.metrics.internals.IntGaugeSuite: void performPendingMetricsOperations()>();
return;
catch java.lang.Throwable from label to label with label;
catch java.lang.Throwable from label to label with label;
catch java.lang.Throwable from label to label with label;
catch java.lang.Throwable from label to label with label;
}
private void performPendingMetricsOperations()
{
java.lang.Throwable v;
org.apache.kafkaesque.common.metrics.Metrics v, v;
org.apache.kafkaesque.common.metrics.internals.IntGaugeSuite v;
java.lang.String v, v, v, v;
boolean v, v;
org.slf4j.Logger v, v, v, v, v, v;
java.util.concurrent.ConcurrentLinkedDeque v, v;
java.util.concurrent.locks.Lock v, v, v;
org.apache.kafkaesque.common.MetricName v, v, v, v;
java.lang.Object v;
org.apache.kafkaesque.common.metrics.MetricValueProvider v, v;
v := @this: org.apache.kafkaesque.common.metrics.internals.IntGaugeSuite;
v = v.<org.apache.kafkaesque.common.metrics.internals.IntGaugeSuite: java.util.concurrent.locks.Lock modifyMetricsLock>;
interfaceinvoke v.<java.util.concurrent.locks.Lock: void lock()>();
label:
v = v.<org.apache.kafkaesque.common.metrics.internals.IntGaugeSuite: org.slf4j.Logger log>;
v = v.<org.apache.kafkaesque.common.metrics.internals.IntGaugeSuite: java.lang.String suiteName>;
interfaceinvoke v.<org.slf4j.Logger: void trace(java.lang.String,java.lang.Object)>("{}: entering performPendingMetricsOperations", v);
v = v.<org.apache.kafkaesque.common.metrics.internals.IntGaugeSuite: java.util.concurrent.ConcurrentLinkedDeque pending>;
v = virtualinvoke v.<java.util.concurrent.ConcurrentLinkedDeque: java.lang.Object pollLast()>();
label:
if v == null goto label;
v = v.<org.apache.kafkaesque.common.metrics.internals.IntGaugeSuite$PendingMetricsChange: org.apache.kafkaesque.common.metrics.MetricValueProvider provider>;
if v != null goto label;
v = v.<org.apache.kafkaesque.common.metrics.internals.IntGaugeSuite: org.slf4j.Logger log>;
v = interfaceinvoke v.<org.slf4j.Logger: boolean isTraceEnabled()>();
if v == 0 goto label;
v = v.<org.apache.kafkaesque.common.metrics.internals.IntGaugeSuite: org.slf4j.Logger log>;
v = v.<org.apache.kafkaesque.common.metrics.internals.IntGaugeSuite: java.lang.String suiteName>;
v = v.<org.apache.kafkaesque.common.metrics.internals.IntGaugeSuite$PendingMetricsChange: org.apache.kafkaesque.common.MetricName metricName>;
interfaceinvoke v.<org.slf4j.Logger: void trace(java.lang.String,java.lang.Object,java.lang.Object)>("{}: removing metric {}", v, v);
label:
v = v.<org.apache.kafkaesque.common.metrics.internals.IntGaugeSuite: org.apache.kafkaesque.common.metrics.Metrics metrics>;
v = v.<org.apache.kafkaesque.common.metrics.internals.IntGaugeSuite$PendingMetricsChange: org.apache.kafkaesque.common.MetricName metricName>;
virtualinvoke v.<org.apache.kafkaesque.common.metrics.Metrics: org.apache.kafkaesque.common.metrics.KafkaMetric removeMetric(org.apache.kafkaesque.common.MetricName)>(v);
goto label;
label:
v = v.<org.apache.kafkaesque.common.metrics.internals.IntGaugeSuite: org.slf4j.Logger log>;
v = interfaceinvoke v.<org.slf4j.Logger: boolean isTraceEnabled()>();
if v == 0 goto label;
v = v.<org.apache.kafkaesque.common.metrics.internals.IntGaugeSuite: org.slf4j.Logger log>;
v = v.<org.apache.kafkaesque.common.metrics.internals.IntGaugeSuite: java.lang.String suiteName>;
v = v.<org.apache.kafkaesque.common.metrics.internals.IntGaugeSuite$PendingMetricsChange: org.apache.kafkaesque.common.MetricName metricName>;
interfaceinvoke v.<org.slf4j.Logger: void trace(java.lang.String,java.lang.Object,java.lang.Object)>("{}: adding metric {}", v, v);
label:
v = v.<org.apache.kafkaesque.common.metrics.internals.IntGaugeSuite: org.apache.kafkaesque.common.metrics.Metrics metrics>;
v = v.<org.apache.kafkaesque.common.metrics.internals.IntGaugeSuite$PendingMetricsChange: org.apache.kafkaesque.common.MetricName metricName>;
v = v.<org.apache.kafkaesque.common.metrics.internals.IntGaugeSuite$PendingMetricsChange: org.apache.kafkaesque.common.metrics.MetricValueProvider provider>;
virtualinvoke v.<org.apache.kafkaesque.common.metrics.Metrics: void addMetric(org.apache.kafkaesque.common.MetricName,org.apache.kafkaesque.common.metrics.MetricValueProvider)>(v, v);
label:
v = v.<org.apache.kafkaesque.common.metrics.internals.IntGaugeSuite: java.util.concurrent.ConcurrentLinkedDeque pending>;
virtualinvoke v.<java.util.concurrent.ConcurrentLinkedDeque: java.lang.Object pollLast()>();
goto label;
label:
v = v.<org.apache.kafkaesque.common.metrics.internals.IntGaugeSuite: org.slf4j.Logger log>;
v = v.<org.apache.kafkaesque.common.metrics.internals.IntGaugeSuite: java.lang.String suiteName>;
interfaceinvoke v.<org.slf4j.Logger: void trace(java.lang.String,java.lang.Object)>("{}: leaving performPendingMetricsOperations", v);
label:
v = v.<org.apache.kafkaesque.common.metrics.internals.IntGaugeSuite: java.util.concurrent.locks.Lock modifyMetricsLock>;
interfaceinvoke v.<java.util.concurrent.locks.Lock: void unlock()>();
goto label;
label:
v := @caughtexception;
v = v.<org.apache.kafkaesque.common.metrics.internals.IntGaugeSuite: java.util.concurrent.locks.Lock modifyMetricsLock>;
interfaceinvoke v.<java.util.concurrent.locks.Lock: void unlock()>();
throw v;
label:
return;
catch java.lang.Throwable from label to label with label;
}
public synchronized void decrement(java.lang.Object)
{
java.lang.Object[] v;
java.lang.Integer v;
java.util.Map v;
int v;
org.apache.kafkaesque.common.metrics.internals.IntGaugeSuite v;
java.lang.String v, v, v, v, v, v;
boolean v;
org.slf4j.Logger v, v, v;
java.util.Set v;
java.lang.Object v, v;
v := @this: org.apache.kafkaesque.common.metrics.internals.IntGaugeSuite;
v := @parameter: java.lang.Object;
v = v.<org.apache.kafkaesque.common.metrics.internals.IntGaugeSuite: boolean closed>;
if v == 0 goto label;
v = v.<org.apache.kafkaesque.common.metrics.internals.IntGaugeSuite: org.slf4j.Logger log>;
v = v.<org.apache.kafkaesque.common.metrics.internals.IntGaugeSuite: java.lang.String suiteName>;
v = virtualinvoke v.<java.lang.Object: java.lang.String toString()>();
interfaceinvoke v.<org.slf4j.Logger: void warn(java.lang.String,java.lang.Object,java.lang.Object)>("{}: Attempted to decrement {}, but the gauge suite was closed.", v, v);
return;
label:
v = v.<org.apache.kafkaesque.common.metrics.internals.IntGaugeSuite: java.util.Map gauges>;
v = interfaceinvoke v.<java.util.Map: java.lang.Object get(java.lang.Object)>(v);
if v != null goto label;
v = v.<org.apache.kafkaesque.common.metrics.internals.IntGaugeSuite: org.slf4j.Logger log>;
v = v.<org.apache.kafkaesque.common.metrics.internals.IntGaugeSuite: java.lang.String suiteName>;
v = virtualinvoke v.<java.lang.Object: java.lang.String toString()>();
interfaceinvoke v.<org.slf4j.Logger: void debug(java.lang.String,java.lang.Object,java.lang.Object)>("{}: Attempted to decrement {}, but no such metric was registered.", v, v);
goto label;
label:
v = virtualinvoke v.<org.apache.kafkaesque.common.metrics.internals.IntGaugeSuite$StoredIntGauge: int decrement()>();
v = v.<org.apache.kafkaesque.common.metrics.internals.IntGaugeSuite: org.slf4j.Logger log>;
v = newarray (java.lang.Object)[3];
v = v.<org.apache.kafkaesque.common.metrics.internals.IntGaugeSuite: java.lang.String suiteName>;
v[0] = v;
v = virtualinvoke v.<java.lang.Object: java.lang.String toString()>();
v[1] = v;
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
v[2] = v;
interfaceinvoke v.<org.slf4j.Logger: void trace(java.lang.String,java.lang.Object[])>("{}: Removed a reference to {}.  {} reference(s) remaining.", v);
if v > 0 goto label;
v = v.<org.apache.kafkaesque.common.metrics.internals.IntGaugeSuite: java.util.Set removable>;
interfaceinvoke v.<java.util.Set: boolean add(java.lang.Object)>(v);
label:
return;
}
public synchronized void close()
{
java.lang.Integer v;
java.util.Map v;
int v;
org.apache.kafkaesque.common.metrics.internals.IntGaugeSuite v;
java.lang.String v, v;
boolean v, v;
org.apache.kafkaesque.common.metrics.internals.IntGaugeSuite$PendingMetricsChange v;
org.slf4j.Logger v, v;
java.util.Iterator v;
java.util.Collection v;
java.util.concurrent.ConcurrentLinkedDeque v;
org.apache.kafkaesque.common.MetricName v;
java.lang.Object v;
v := @this: org.apache.kafkaesque.common.metrics.internals.IntGaugeSuite;
v = v.<org.apache.kafkaesque.common.metrics.internals.IntGaugeSuite: boolean closed>;
if v == 0 goto label;
v = v.<org.apache.kafkaesque.common.metrics.internals.IntGaugeSuite: org.slf4j.Logger log>;
v = v.<org.apache.kafkaesque.common.metrics.internals.IntGaugeSuite: java.lang.String suiteName>;
interfaceinvoke v.<org.slf4j.Logger: void trace(java.lang.String,java.lang.Object)>("{}: gauge suite is already closed.", v);
return;
label:
v.<org.apache.kafkaesque.common.metrics.internals.IntGaugeSuite: boolean closed> = 1;
v = 0;
v = v.<org.apache.kafkaesque.common.metrics.internals.IntGaugeSuite: java.util.Map gauges>;
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 = v.<org.apache.kafkaesque.common.metrics.internals.IntGaugeSuite: java.util.concurrent.ConcurrentLinkedDeque pending>;
v = new org.apache.kafkaesque.common.metrics.internals.IntGaugeSuite$PendingMetricsChange;
v = interfaceinvoke v.<java.util.Iterator: java.lang.Object next()>();
v = v.<org.apache.kafkaesque.common.metrics.internals.IntGaugeSuite$StoredIntGauge: org.apache.kafkaesque.common.MetricName metricName>;
specialinvoke v.<org.apache.kafkaesque.common.metrics.internals.IntGaugeSuite$PendingMetricsChange: void <init>(org.apache.kafkaesque.common.MetricName,org.apache.kafkaesque.common.metrics.MetricValueProvider)>(v, null);
virtualinvoke v.<java.util.concurrent.ConcurrentLinkedDeque: void push(java.lang.Object)>(v);
v = v + 1;
interfaceinvoke v.<java.util.Iterator: void remove()>();
goto label;
label:
specialinvoke v.<org.apache.kafkaesque.common.metrics.internals.IntGaugeSuite: void performPendingMetricsOperations()>();
v = v.<org.apache.kafkaesque.common.metrics.internals.IntGaugeSuite: org.slf4j.Logger log>;
v = v.<org.apache.kafkaesque.common.metrics.internals.IntGaugeSuite: java.lang.String suiteName>;
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
interfaceinvoke v.<org.slf4j.Logger: void trace(java.lang.String,java.lang.Object,java.lang.Object)>("{}: closed {} metric(s).", v, v);
return;
}
public int maxEntries()
{
int v;
org.apache.kafkaesque.common.metrics.internals.IntGaugeSuite v;
v := @this: org.apache.kafkaesque.common.metrics.internals.IntGaugeSuite;
v = v.<org.apache.kafkaesque.common.metrics.internals.IntGaugeSuite: int maxEntries>;
return v;
}
org.apache.kafkaesque.common.metrics.Metrics metrics()
{
org.apache.kafkaesque.common.metrics.internals.IntGaugeSuite v;
org.apache.kafkaesque.common.metrics.Metrics v;
v := @this: org.apache.kafkaesque.common.metrics.internals.IntGaugeSuite;
v = v.<org.apache.kafkaesque.common.metrics.internals.IntGaugeSuite: org.apache.kafkaesque.common.metrics.Metrics metrics>;
return v;
}
synchronized java.util.Map values()
{
java.util.Iterator v;
java.util.Set v;
java.util.HashMap v;
java.lang.Integer v;
java.util.Map v;
int v;
org.apache.kafkaesque.common.metrics.internals.IntGaugeSuite v;
java.lang.Object v, v, v;
boolean v;
v := @this: org.apache.kafkaesque.common.metrics.internals.IntGaugeSuite;
v = new java.util.HashMap;
specialinvoke v.<java.util.HashMap: void <init>()>();
v = v.<org.apache.kafkaesque.common.metrics.internals.IntGaugeSuite: java.util.Map gauges>;
v = interfaceinvoke v.<java.util.Map: java.util.Set entrySet()>();
v = interfaceinvoke v.<java.util.Set: 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 = interfaceinvoke v.<java.util.Map$Entry: java.lang.Object getKey()>();
v = interfaceinvoke v.<java.util.Map$Entry: java.lang.Object getValue()>();
v = virtualinvoke v.<org.apache.kafkaesque.common.metrics.internals.IntGaugeSuite$StoredIntGauge: int value()>();
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
virtualinvoke v.<java.util.HashMap: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, v);
goto label;
label:
return v;
}
}