class org.apache.kafkaesque.common.network.Selector$SelectorMetrics extends java.lang.Object implements java.lang.AutoCloseable
{
private final org.apache.kafkaesque.common.metrics.Metrics metrics;
private final java.lang.String metricGrpPrefix;
private final java.util.Map metricTags;
private final boolean metricsPerConnection;
public final org.apache.kafkaesque.common.metrics.Sensor connectionClosed;
public final org.apache.kafkaesque.common.metrics.Sensor connectionCreated;
public final org.apache.kafkaesque.common.metrics.Sensor successfulAuthentication;
public final org.apache.kafkaesque.common.metrics.Sensor successfulReauthentication;
public final org.apache.kafkaesque.common.metrics.Sensor successfulAuthenticationNoReauth;
public final org.apache.kafkaesque.common.metrics.Sensor reauthenticationLatency;
public final org.apache.kafkaesque.common.metrics.Sensor failedAuthentication;
public final org.apache.kafkaesque.common.metrics.Sensor failedReauthentication;
public final org.apache.kafkaesque.common.metrics.Sensor bytesTransferred;
public final org.apache.kafkaesque.common.metrics.Sensor bytesSent;
public final org.apache.kafkaesque.common.metrics.Sensor requestsSent;
public final org.apache.kafkaesque.common.metrics.Sensor bytesReceived;
public final org.apache.kafkaesque.common.metrics.Sensor responsesReceived;
public final org.apache.kafkaesque.common.metrics.Sensor selectTime;
public final org.apache.kafkaesque.common.metrics.Sensor ioTime;
public final org.apache.kafkaesque.common.metrics.internals.IntGaugeSuite connectionsByCipher;
public final org.apache.kafkaesque.common.metrics.internals.IntGaugeSuite connectionsByClient;
private final java.util.List topLevelMetricNames;
private final java.util.List sensors;
final org.apache.kafkaesque.common.network.Selector this$0;
public void <init>(org.apache.kafkaesque.common.network.Selector, org.apache.kafkaesque.common.metrics.Metrics, java.lang.String, java.util.Map, boolean)
{
java.util.Map v;
org.apache.kafkaesque.common.metrics.stats.Avg v, v, v, v;
org.apache.kafkaesque.common.network.Selector$SelectorMetrics v;
java.util.Set v;
org.apache.kafkaesque.common.MetricName v, v, v, v, v, v, v, v;
java.lang.StringBuilder v;
org.apache.kafkaesque.common.metrics.stats.CumulativeSum v;
java.util.ArrayList v, v;
org.apache.kafkaesque.common.metrics.Sensor[] v, v, v, v, v, v, v, v, v, v, v, v, v, v, v;
java.lang.String v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v;
org.apache.kafkaesque.common.network.Selector v;
org.apache.kafkaesque.common.metrics.stats.Max v, v;
org.apache.kafkaesque.common.metrics.stats.Meter v, v, v, v, v, v, v, v, v, v, v, v, v, v;
boolean v, v;
org.apache.kafkaesque.common.metrics.Measurable v;
java.util.List v;
org.apache.kafkaesque.common.metrics.Sensor v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v;
org.apache.kafkaesque.common.metrics.Metrics v, v;
java.util.function.Function v, v;
org.apache.kafkaesque.common.metrics.internals.IntGaugeSuite v, v;
org.slf4j.Logger v, v;
java.util.Iterator v;
org.apache.kafkaesque.common.metrics.stats.WindowedCount v, v, v, v;
java.lang.Object v, v, v;
v := @this: org.apache.kafkaesque.common.network.Selector$SelectorMetrics;
v := @parameter: org.apache.kafkaesque.common.network.Selector;
v := @parameter: org.apache.kafkaesque.common.metrics.Metrics;
v := @parameter: java.lang.String;
v := @parameter: java.util.Map;
v := @parameter: boolean;
v.<org.apache.kafkaesque.common.network.Selector$SelectorMetrics: org.apache.kafkaesque.common.network.Selector this$0> = v;
specialinvoke v.<java.lang.Object: void <init>()>();
v = new java.util.ArrayList;
specialinvoke v.<java.util.ArrayList: void <init>()>();
v.<org.apache.kafkaesque.common.network.Selector$SelectorMetrics: java.util.List topLevelMetricNames> = v;
v = new java.util.ArrayList;
specialinvoke v.<java.util.ArrayList: void <init>()>();
v.<org.apache.kafkaesque.common.network.Selector$SelectorMetrics: java.util.List sensors> = v;
v.<org.apache.kafkaesque.common.network.Selector$SelectorMetrics: org.apache.kafkaesque.common.metrics.Metrics metrics> = v;
v.<org.apache.kafkaesque.common.network.Selector$SelectorMetrics: java.lang.String metricGrpPrefix> = v;
v.<org.apache.kafkaesque.common.network.Selector$SelectorMetrics: java.util.Map metricTags> = v;
v.<org.apache.kafkaesque.common.network.Selector$SelectorMetrics: boolean metricsPerConnection> = 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[])>("\u0001-metrics");
v = new java.lang.StringBuilder;
specialinvoke v.<java.lang.StringBuilder: void <init>()>();
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()>();
virtualinvoke v.<java.lang.StringBuilder: java.lang.StringBuilder append(java.lang.String)>(v);
virtualinvoke v.<java.lang.StringBuilder: java.lang.StringBuilder append(java.lang.String)>("-");
v = interfaceinvoke v.<java.util.Map$Entry: java.lang.Object getValue()>();
virtualinvoke v.<java.lang.StringBuilder: java.lang.StringBuilder append(java.lang.String)>(v);
goto label;
label:
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.StringBuilder)>(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[])>("connections-closed:\u0001");
v = newarray (org.apache.kafkaesque.common.metrics.Sensor)[0];
v = specialinvoke v.<org.apache.kafkaesque.common.network.Selector$SelectorMetrics: org.apache.kafkaesque.common.metrics.Sensor sensor(java.lang.String,org.apache.kafkaesque.common.metrics.Sensor[])>(v, v);
v.<org.apache.kafkaesque.common.network.Selector$SelectorMetrics: org.apache.kafkaesque.common.metrics.Sensor connectionClosed> = v;
v = v.<org.apache.kafkaesque.common.network.Selector$SelectorMetrics: org.apache.kafkaesque.common.metrics.Sensor connectionClosed>;
v = specialinvoke v.<org.apache.kafkaesque.common.network.Selector$SelectorMetrics: org.apache.kafkaesque.common.metrics.stats.Meter createMeter(org.apache.kafkaesque.common.metrics.Metrics,java.lang.String,java.util.Map,java.lang.String,java.lang.String)>(v, v, v, "connection-close", "connections closed");
virtualinvoke v.<org.apache.kafkaesque.common.metrics.Sensor: boolean add(org.apache.kafkaesque.common.metrics.CompoundStat)>(v);
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.StringBuilder)>(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[])>("connections-created:\u0001");
v = newarray (org.apache.kafkaesque.common.metrics.Sensor)[0];
v = specialinvoke v.<org.apache.kafkaesque.common.network.Selector$SelectorMetrics: org.apache.kafkaesque.common.metrics.Sensor sensor(java.lang.String,org.apache.kafkaesque.common.metrics.Sensor[])>(v, v);
v.<org.apache.kafkaesque.common.network.Selector$SelectorMetrics: org.apache.kafkaesque.common.metrics.Sensor connectionCreated> = v;
v = v.<org.apache.kafkaesque.common.network.Selector$SelectorMetrics: org.apache.kafkaesque.common.metrics.Sensor connectionCreated>;
v = specialinvoke v.<org.apache.kafkaesque.common.network.Selector$SelectorMetrics: org.apache.kafkaesque.common.metrics.stats.Meter createMeter(org.apache.kafkaesque.common.metrics.Metrics,java.lang.String,java.util.Map,java.lang.String,java.lang.String)>(v, v, v, "connection-creation", "new connections established");
virtualinvoke v.<org.apache.kafkaesque.common.metrics.Sensor: boolean add(org.apache.kafkaesque.common.metrics.CompoundStat)>(v);
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.StringBuilder)>(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[])>("successful-authentication:\u0001");
v = newarray (org.apache.kafkaesque.common.metrics.Sensor)[0];
v = specialinvoke v.<org.apache.kafkaesque.common.network.Selector$SelectorMetrics: org.apache.kafkaesque.common.metrics.Sensor sensor(java.lang.String,org.apache.kafkaesque.common.metrics.Sensor[])>(v, v);
v.<org.apache.kafkaesque.common.network.Selector$SelectorMetrics: org.apache.kafkaesque.common.metrics.Sensor successfulAuthentication> = v;
v = v.<org.apache.kafkaesque.common.network.Selector$SelectorMetrics: org.apache.kafkaesque.common.metrics.Sensor successfulAuthentication>;
v = specialinvoke v.<org.apache.kafkaesque.common.network.Selector$SelectorMetrics: org.apache.kafkaesque.common.metrics.stats.Meter createMeter(org.apache.kafkaesque.common.metrics.Metrics,java.lang.String,java.util.Map,java.lang.String,java.lang.String)>(v, v, v, "successful-authentication", "connections with successful authentication");
virtualinvoke v.<org.apache.kafkaesque.common.metrics.Sensor: boolean add(org.apache.kafkaesque.common.metrics.CompoundStat)>(v);
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.StringBuilder)>(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[])>("successful-reauthentication:\u0001");
v = newarray (org.apache.kafkaesque.common.metrics.Sensor)[0];
v = specialinvoke v.<org.apache.kafkaesque.common.network.Selector$SelectorMetrics: org.apache.kafkaesque.common.metrics.Sensor sensor(java.lang.String,org.apache.kafkaesque.common.metrics.Sensor[])>(v, v);
v.<org.apache.kafkaesque.common.network.Selector$SelectorMetrics: org.apache.kafkaesque.common.metrics.Sensor successfulReauthentication> = v;
v = v.<org.apache.kafkaesque.common.network.Selector$SelectorMetrics: org.apache.kafkaesque.common.metrics.Sensor successfulReauthentication>;
v = specialinvoke v.<org.apache.kafkaesque.common.network.Selector$SelectorMetrics: org.apache.kafkaesque.common.metrics.stats.Meter createMeter(org.apache.kafkaesque.common.metrics.Metrics,java.lang.String,java.util.Map,java.lang.String,java.lang.String)>(v, v, v, "successful-reauthentication", "successful re-authentication of connections");
virtualinvoke v.<org.apache.kafkaesque.common.metrics.Sensor: boolean add(org.apache.kafkaesque.common.metrics.CompoundStat)>(v);
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.StringBuilder)>(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[])>("successful-authentication-no-reauth:\u0001");
v = newarray (org.apache.kafkaesque.common.metrics.Sensor)[0];
v = specialinvoke v.<org.apache.kafkaesque.common.network.Selector$SelectorMetrics: org.apache.kafkaesque.common.metrics.Sensor sensor(java.lang.String,org.apache.kafkaesque.common.metrics.Sensor[])>(v, v);
v.<org.apache.kafkaesque.common.network.Selector$SelectorMetrics: org.apache.kafkaesque.common.metrics.Sensor successfulAuthenticationNoReauth> = v;
v = virtualinvoke v.<org.apache.kafkaesque.common.metrics.Metrics: org.apache.kafkaesque.common.MetricName metricName(java.lang.String,java.lang.String,java.lang.String,java.util.Map)>("successful-authentication-no-reauth-total", v, "The total number of connections with successful authentication where the client does not support re-authentication", v);
v = v.<org.apache.kafkaesque.common.network.Selector$SelectorMetrics: org.apache.kafkaesque.common.metrics.Sensor successfulAuthenticationNoReauth>;
v = new org.apache.kafkaesque.common.metrics.stats.CumulativeSum;
specialinvoke v.<org.apache.kafkaesque.common.metrics.stats.CumulativeSum: void <init>()>();
virtualinvoke v.<org.apache.kafkaesque.common.metrics.Sensor: boolean add(org.apache.kafkaesque.common.MetricName,org.apache.kafkaesque.common.metrics.MeasurableStat)>(v, v);
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.StringBuilder)>(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[])>("failed-authentication:\u0001");
v = newarray (org.apache.kafkaesque.common.metrics.Sensor)[0];
v = specialinvoke v.<org.apache.kafkaesque.common.network.Selector$SelectorMetrics: org.apache.kafkaesque.common.metrics.Sensor sensor(java.lang.String,org.apache.kafkaesque.common.metrics.Sensor[])>(v, v);
v.<org.apache.kafkaesque.common.network.Selector$SelectorMetrics: org.apache.kafkaesque.common.metrics.Sensor failedAuthentication> = v;
v = v.<org.apache.kafkaesque.common.network.Selector$SelectorMetrics: org.apache.kafkaesque.common.metrics.Sensor failedAuthentication>;
v = specialinvoke v.<org.apache.kafkaesque.common.network.Selector$SelectorMetrics: org.apache.kafkaesque.common.metrics.stats.Meter createMeter(org.apache.kafkaesque.common.metrics.Metrics,java.lang.String,java.util.Map,java.lang.String,java.lang.String)>(v, v, v, "failed-authentication", "connections with failed authentication");
virtualinvoke v.<org.apache.kafkaesque.common.metrics.Sensor: boolean add(org.apache.kafkaesque.common.metrics.CompoundStat)>(v);
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.StringBuilder)>(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[])>("failed-reauthentication:\u0001");
v = newarray (org.apache.kafkaesque.common.metrics.Sensor)[0];
v = specialinvoke v.<org.apache.kafkaesque.common.network.Selector$SelectorMetrics: org.apache.kafkaesque.common.metrics.Sensor sensor(java.lang.String,org.apache.kafkaesque.common.metrics.Sensor[])>(v, v);
v.<org.apache.kafkaesque.common.network.Selector$SelectorMetrics: org.apache.kafkaesque.common.metrics.Sensor failedReauthentication> = v;
v = v.<org.apache.kafkaesque.common.network.Selector$SelectorMetrics: org.apache.kafkaesque.common.metrics.Sensor failedReauthentication>;
v = specialinvoke v.<org.apache.kafkaesque.common.network.Selector$SelectorMetrics: org.apache.kafkaesque.common.metrics.stats.Meter createMeter(org.apache.kafkaesque.common.metrics.Metrics,java.lang.String,java.util.Map,java.lang.String,java.lang.String)>(v, v, v, "failed-reauthentication", "failed re-authentication of connections");
virtualinvoke v.<org.apache.kafkaesque.common.metrics.Sensor: boolean add(org.apache.kafkaesque.common.metrics.CompoundStat)>(v);
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.StringBuilder)>(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[])>("reauthentication-latency:\u0001");
v = newarray (org.apache.kafkaesque.common.metrics.Sensor)[0];
v = specialinvoke v.<org.apache.kafkaesque.common.network.Selector$SelectorMetrics: org.apache.kafkaesque.common.metrics.Sensor sensor(java.lang.String,org.apache.kafkaesque.common.metrics.Sensor[])>(v, v);
v.<org.apache.kafkaesque.common.network.Selector$SelectorMetrics: org.apache.kafkaesque.common.metrics.Sensor reauthenticationLatency> = v;
v = virtualinvoke v.<org.apache.kafkaesque.common.metrics.Metrics: org.apache.kafkaesque.common.MetricName metricName(java.lang.String,java.lang.String,java.lang.String,java.util.Map)>("reauthentication-latency-max", v, "The max latency observed due to re-authentication", v);
v = v.<org.apache.kafkaesque.common.network.Selector$SelectorMetrics: org.apache.kafkaesque.common.metrics.Sensor reauthenticationLatency>;
v = new org.apache.kafkaesque.common.metrics.stats.Max;
specialinvoke v.<org.apache.kafkaesque.common.metrics.stats.Max: void <init>()>();
virtualinvoke v.<org.apache.kafkaesque.common.metrics.Sensor: boolean add(org.apache.kafkaesque.common.MetricName,org.apache.kafkaesque.common.metrics.MeasurableStat)>(v, v);
v = virtualinvoke v.<org.apache.kafkaesque.common.metrics.Metrics: org.apache.kafkaesque.common.MetricName metricName(java.lang.String,java.lang.String,java.lang.String,java.util.Map)>("reauthentication-latency-avg", v, "The average latency observed due to re-authentication", v);
v = v.<org.apache.kafkaesque.common.network.Selector$SelectorMetrics: org.apache.kafkaesque.common.metrics.Sensor reauthenticationLatency>;
v = new org.apache.kafkaesque.common.metrics.stats.Avg;
specialinvoke v.<org.apache.kafkaesque.common.metrics.stats.Avg: void <init>()>();
virtualinvoke v.<org.apache.kafkaesque.common.metrics.Sensor: boolean add(org.apache.kafkaesque.common.MetricName,org.apache.kafkaesque.common.metrics.MeasurableStat)>(v, v);
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.StringBuilder)>(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[])>("bytes-sent-received:\u0001");
v = newarray (org.apache.kafkaesque.common.metrics.Sensor)[0];
v = specialinvoke v.<org.apache.kafkaesque.common.network.Selector$SelectorMetrics: org.apache.kafkaesque.common.metrics.Sensor sensor(java.lang.String,org.apache.kafkaesque.common.metrics.Sensor[])>(v, v);
v.<org.apache.kafkaesque.common.network.Selector$SelectorMetrics: org.apache.kafkaesque.common.metrics.Sensor bytesTransferred> = v;
v = v.<org.apache.kafkaesque.common.network.Selector$SelectorMetrics: org.apache.kafkaesque.common.metrics.Sensor bytesTransferred>;
v = new org.apache.kafkaesque.common.metrics.stats.WindowedCount;
specialinvoke v.<org.apache.kafkaesque.common.metrics.stats.WindowedCount: void <init>()>();
v = specialinvoke v.<org.apache.kafkaesque.common.network.Selector$SelectorMetrics: org.apache.kafkaesque.common.metrics.stats.Meter createMeter(org.apache.kafkaesque.common.metrics.Metrics,java.lang.String,java.util.Map,org.apache.kafkaesque.common.metrics.stats.SampledStat,java.lang.String,java.lang.String)>(v, v, v, v, "network-io", "network operations (reads or writes) on all connections");
virtualinvoke v.<org.apache.kafkaesque.common.metrics.Sensor: boolean add(org.apache.kafkaesque.common.metrics.CompoundStat)>(v);
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.StringBuilder)>(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[])>("bytes-sent:\u0001");
v = newarray (org.apache.kafkaesque.common.metrics.Sensor)[1];
v = v.<org.apache.kafkaesque.common.network.Selector$SelectorMetrics: org.apache.kafkaesque.common.metrics.Sensor bytesTransferred>;
v[0] = v;
v = specialinvoke v.<org.apache.kafkaesque.common.network.Selector$SelectorMetrics: org.apache.kafkaesque.common.metrics.Sensor sensor(java.lang.String,org.apache.kafkaesque.common.metrics.Sensor[])>(v, v);
v.<org.apache.kafkaesque.common.network.Selector$SelectorMetrics: org.apache.kafkaesque.common.metrics.Sensor bytesSent> = v;
v = v.<org.apache.kafkaesque.common.network.Selector$SelectorMetrics: org.apache.kafkaesque.common.metrics.Sensor bytesSent>;
v = specialinvoke v.<org.apache.kafkaesque.common.network.Selector$SelectorMetrics: org.apache.kafkaesque.common.metrics.stats.Meter createMeter(org.apache.kafkaesque.common.metrics.Metrics,java.lang.String,java.util.Map,java.lang.String,java.lang.String)>(v, v, v, "outgoing-byte", "outgoing bytes sent to all servers");
virtualinvoke v.<org.apache.kafkaesque.common.metrics.Sensor: boolean add(org.apache.kafkaesque.common.metrics.CompoundStat)>(v);
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.StringBuilder)>(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[])>("requests-sent:\u0001");
v = newarray (org.apache.kafkaesque.common.metrics.Sensor)[0];
v = specialinvoke v.<org.apache.kafkaesque.common.network.Selector$SelectorMetrics: org.apache.kafkaesque.common.metrics.Sensor sensor(java.lang.String,org.apache.kafkaesque.common.metrics.Sensor[])>(v, v);
v.<org.apache.kafkaesque.common.network.Selector$SelectorMetrics: org.apache.kafkaesque.common.metrics.Sensor requestsSent> = v;
v = v.<org.apache.kafkaesque.common.network.Selector$SelectorMetrics: org.apache.kafkaesque.common.metrics.Sensor requestsSent>;
v = new org.apache.kafkaesque.common.metrics.stats.WindowedCount;
specialinvoke v.<org.apache.kafkaesque.common.metrics.stats.WindowedCount: void <init>()>();
v = specialinvoke v.<org.apache.kafkaesque.common.network.Selector$SelectorMetrics: org.apache.kafkaesque.common.metrics.stats.Meter createMeter(org.apache.kafkaesque.common.metrics.Metrics,java.lang.String,java.util.Map,org.apache.kafkaesque.common.metrics.stats.SampledStat,java.lang.String,java.lang.String)>(v, v, v, v, "request", "requests sent");
virtualinvoke v.<org.apache.kafkaesque.common.metrics.Sensor: boolean add(org.apache.kafkaesque.common.metrics.CompoundStat)>(v);
v = virtualinvoke v.<org.apache.kafkaesque.common.metrics.Metrics: org.apache.kafkaesque.common.MetricName metricName(java.lang.String,java.lang.String,java.lang.String,java.util.Map)>("request-size-avg", v, "The average size of requests sent.", v);
v = v.<org.apache.kafkaesque.common.network.Selector$SelectorMetrics: org.apache.kafkaesque.common.metrics.Sensor requestsSent>;
v = new org.apache.kafkaesque.common.metrics.stats.Avg;
specialinvoke v.<org.apache.kafkaesque.common.metrics.stats.Avg: void <init>()>();
virtualinvoke v.<org.apache.kafkaesque.common.metrics.Sensor: boolean add(org.apache.kafkaesque.common.MetricName,org.apache.kafkaesque.common.metrics.MeasurableStat)>(v, v);
v = virtualinvoke v.<org.apache.kafkaesque.common.metrics.Metrics: org.apache.kafkaesque.common.MetricName metricName(java.lang.String,java.lang.String,java.lang.String,java.util.Map)>("request-size-max", v, "The maximum size of any request sent.", v);
v = v.<org.apache.kafkaesque.common.network.Selector$SelectorMetrics: org.apache.kafkaesque.common.metrics.Sensor requestsSent>;
v = new org.apache.kafkaesque.common.metrics.stats.Max;
specialinvoke v.<org.apache.kafkaesque.common.metrics.stats.Max: void <init>()>();
virtualinvoke v.<org.apache.kafkaesque.common.metrics.Sensor: boolean add(org.apache.kafkaesque.common.MetricName,org.apache.kafkaesque.common.metrics.MeasurableStat)>(v, v);
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.StringBuilder)>(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[])>("bytes-received:\u0001");
v = newarray (org.apache.kafkaesque.common.metrics.Sensor)[1];
v = v.<org.apache.kafkaesque.common.network.Selector$SelectorMetrics: org.apache.kafkaesque.common.metrics.Sensor bytesTransferred>;
v[0] = v;
v = specialinvoke v.<org.apache.kafkaesque.common.network.Selector$SelectorMetrics: org.apache.kafkaesque.common.metrics.Sensor sensor(java.lang.String,org.apache.kafkaesque.common.metrics.Sensor[])>(v, v);
v.<org.apache.kafkaesque.common.network.Selector$SelectorMetrics: org.apache.kafkaesque.common.metrics.Sensor bytesReceived> = v;
v = v.<org.apache.kafkaesque.common.network.Selector$SelectorMetrics: org.apache.kafkaesque.common.metrics.Sensor bytesReceived>;
v = specialinvoke v.<org.apache.kafkaesque.common.network.Selector$SelectorMetrics: org.apache.kafkaesque.common.metrics.stats.Meter createMeter(org.apache.kafkaesque.common.metrics.Metrics,java.lang.String,java.util.Map,java.lang.String,java.lang.String)>(v, v, v, "incoming-byte", "bytes read off all sockets");
virtualinvoke v.<org.apache.kafkaesque.common.metrics.Sensor: boolean add(org.apache.kafkaesque.common.metrics.CompoundStat)>(v);
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.StringBuilder)>(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[])>("responses-received:\u0001");
v = newarray (org.apache.kafkaesque.common.metrics.Sensor)[0];
v = specialinvoke v.<org.apache.kafkaesque.common.network.Selector$SelectorMetrics: org.apache.kafkaesque.common.metrics.Sensor sensor(java.lang.String,org.apache.kafkaesque.common.metrics.Sensor[])>(v, v);
v.<org.apache.kafkaesque.common.network.Selector$SelectorMetrics: org.apache.kafkaesque.common.metrics.Sensor responsesReceived> = v;
v = v.<org.apache.kafkaesque.common.network.Selector$SelectorMetrics: org.apache.kafkaesque.common.metrics.Sensor responsesReceived>;
v = new org.apache.kafkaesque.common.metrics.stats.WindowedCount;
specialinvoke v.<org.apache.kafkaesque.common.metrics.stats.WindowedCount: void <init>()>();
v = specialinvoke v.<org.apache.kafkaesque.common.network.Selector$SelectorMetrics: org.apache.kafkaesque.common.metrics.stats.Meter createMeter(org.apache.kafkaesque.common.metrics.Metrics,java.lang.String,java.util.Map,org.apache.kafkaesque.common.metrics.stats.SampledStat,java.lang.String,java.lang.String)>(v, v, v, v, "response", "responses received");
virtualinvoke v.<org.apache.kafkaesque.common.metrics.Sensor: boolean add(org.apache.kafkaesque.common.metrics.CompoundStat)>(v);
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.StringBuilder)>(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[])>("select-time:\u0001");
v = newarray (org.apache.kafkaesque.common.metrics.Sensor)[0];
v = specialinvoke v.<org.apache.kafkaesque.common.network.Selector$SelectorMetrics: org.apache.kafkaesque.common.metrics.Sensor sensor(java.lang.String,org.apache.kafkaesque.common.metrics.Sensor[])>(v, v);
v.<org.apache.kafkaesque.common.network.Selector$SelectorMetrics: org.apache.kafkaesque.common.metrics.Sensor selectTime> = v;
v = v.<org.apache.kafkaesque.common.network.Selector$SelectorMetrics: org.apache.kafkaesque.common.metrics.Sensor selectTime>;
v = new org.apache.kafkaesque.common.metrics.stats.WindowedCount;
specialinvoke v.<org.apache.kafkaesque.common.metrics.stats.WindowedCount: void <init>()>();
v = specialinvoke v.<org.apache.kafkaesque.common.network.Selector$SelectorMetrics: org.apache.kafkaesque.common.metrics.stats.Meter createMeter(org.apache.kafkaesque.common.metrics.Metrics,java.lang.String,java.util.Map,org.apache.kafkaesque.common.metrics.stats.SampledStat,java.lang.String,java.lang.String)>(v, v, v, v, "select", "times the I/O layer checked for new I/O to perform");
virtualinvoke v.<org.apache.kafkaesque.common.metrics.Sensor: boolean add(org.apache.kafkaesque.common.metrics.CompoundStat)>(v);
v = virtualinvoke v.<org.apache.kafkaesque.common.metrics.Metrics: org.apache.kafkaesque.common.MetricName metricName(java.lang.String,java.lang.String,java.lang.String,java.util.Map)>("io-wait-time-ns-avg", v, "The average length of time the I/O thread spent waiting for a socket ready for reads or writes in nanoseconds.", v);
v = v.<org.apache.kafkaesque.common.network.Selector$SelectorMetrics: org.apache.kafkaesque.common.metrics.Sensor selectTime>;
v = new org.apache.kafkaesque.common.metrics.stats.Avg;
specialinvoke v.<org.apache.kafkaesque.common.metrics.stats.Avg: void <init>()>();
virtualinvoke v.<org.apache.kafkaesque.common.metrics.Sensor: boolean add(org.apache.kafkaesque.common.MetricName,org.apache.kafkaesque.common.metrics.MeasurableStat)>(v, v);
v = v.<org.apache.kafkaesque.common.network.Selector$SelectorMetrics: org.apache.kafkaesque.common.metrics.Sensor selectTime>;
v = specialinvoke v.<org.apache.kafkaesque.common.network.Selector$SelectorMetrics: org.apache.kafkaesque.common.metrics.stats.Meter createIOThreadRatioMeter(org.apache.kafkaesque.common.metrics.Metrics,java.lang.String,java.util.Map,java.lang.String,java.lang.String)>(v, v, v, "io-wait", "waiting");
virtualinvoke v.<org.apache.kafkaesque.common.metrics.Sensor: boolean add(org.apache.kafkaesque.common.metrics.CompoundStat)>(v);
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.StringBuilder)>(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[])>("io-time:\u0001");
v = newarray (org.apache.kafkaesque.common.metrics.Sensor)[0];
v = specialinvoke v.<org.apache.kafkaesque.common.network.Selector$SelectorMetrics: org.apache.kafkaesque.common.metrics.Sensor sensor(java.lang.String,org.apache.kafkaesque.common.metrics.Sensor[])>(v, v);
v.<org.apache.kafkaesque.common.network.Selector$SelectorMetrics: org.apache.kafkaesque.common.metrics.Sensor ioTime> = v;
v = virtualinvoke v.<org.apache.kafkaesque.common.metrics.Metrics: org.apache.kafkaesque.common.MetricName metricName(java.lang.String,java.lang.String,java.lang.String,java.util.Map)>("io-time-ns-avg", v, "The average length of time for I/O per select call in nanoseconds.", v);
v = v.<org.apache.kafkaesque.common.network.Selector$SelectorMetrics: org.apache.kafkaesque.common.metrics.Sensor ioTime>;
v = new org.apache.kafkaesque.common.metrics.stats.Avg;
specialinvoke v.<org.apache.kafkaesque.common.metrics.stats.Avg: void <init>()>();
virtualinvoke v.<org.apache.kafkaesque.common.metrics.Sensor: boolean add(org.apache.kafkaesque.common.MetricName,org.apache.kafkaesque.common.metrics.MeasurableStat)>(v, v);
v = v.<org.apache.kafkaesque.common.network.Selector$SelectorMetrics: org.apache.kafkaesque.common.metrics.Sensor ioTime>;
v = specialinvoke v.<org.apache.kafkaesque.common.network.Selector$SelectorMetrics: org.apache.kafkaesque.common.metrics.stats.Meter createIOThreadRatioMeter(org.apache.kafkaesque.common.metrics.Metrics,java.lang.String,java.util.Map,java.lang.String,java.lang.String)>(v, v, v, "io", "doing I/O");
virtualinvoke v.<org.apache.kafkaesque.common.metrics.Sensor: boolean add(org.apache.kafkaesque.common.metrics.CompoundStat)>(v);
v = new org.apache.kafkaesque.common.metrics.internals.IntGaugeSuite;
v = v.<org.apache.kafkaesque.common.network.Selector: org.slf4j.Logger log>;
v = staticinvoke <org.apache.kafkaesque.common.network.Selector$SelectorMetrics$lambda_new_0__1011: java.util.function.Function bootstrap$(java.util.Map,org.apache.kafkaesque.common.metrics.Metrics,java.lang.String)>(v, v, v);
specialinvoke v.<org.apache.kafkaesque.common.metrics.internals.IntGaugeSuite: void <init>(org.slf4j.Logger,java.lang.String,org.apache.kafkaesque.common.metrics.Metrics,java.util.function.Function,int)>(v, "sslCiphers", v, v, 100);
v.<org.apache.kafkaesque.common.network.Selector$SelectorMetrics: org.apache.kafkaesque.common.metrics.internals.IntGaugeSuite connectionsByCipher> = v;
v = new org.apache.kafkaesque.common.metrics.internals.IntGaugeSuite;
v = v.<org.apache.kafkaesque.common.network.Selector: org.slf4j.Logger log>;
v = staticinvoke <org.apache.kafkaesque.common.network.Selector$SelectorMetrics$lambda_new_1__1012: java.util.function.Function bootstrap$(java.util.Map,org.apache.kafkaesque.common.metrics.Metrics,java.lang.String)>(v, v, v);
specialinvoke v.<org.apache.kafkaesque.common.metrics.internals.IntGaugeSuite: void <init>(org.slf4j.Logger,java.lang.String,org.apache.kafkaesque.common.metrics.Metrics,java.util.function.Function,int)>(v, "clients", v, v, 100);
v.<org.apache.kafkaesque.common.network.Selector$SelectorMetrics: org.apache.kafkaesque.common.metrics.internals.IntGaugeSuite connectionsByClient> = v;
v = virtualinvoke v.<org.apache.kafkaesque.common.metrics.Metrics: org.apache.kafkaesque.common.MetricName metricName(java.lang.String,java.lang.String,java.lang.String,java.util.Map)>("connection-count", v, "The current number of active connections.", v);
v = v.<org.apache.kafkaesque.common.network.Selector$SelectorMetrics: java.util.List topLevelMetricNames>;
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
v = v.<org.apache.kafkaesque.common.network.Selector$SelectorMetrics: org.apache.kafkaesque.common.metrics.Metrics metrics>;
v = staticinvoke <org.apache.kafkaesque.common.network.Selector$SelectorMetrics$lambda_new_2__1013: org.apache.kafkaesque.common.metrics.Measurable bootstrap$(org.apache.kafkaesque.common.network.Selector$SelectorMetrics)>(v);
virtualinvoke v.<org.apache.kafkaesque.common.metrics.Metrics: void addMetric(org.apache.kafkaesque.common.MetricName,org.apache.kafkaesque.common.metrics.Measurable)>(v, v);
return;
}
private org.apache.kafkaesque.common.metrics.stats.Meter createMeter(org.apache.kafkaesque.common.metrics.Metrics, java.lang.String, java.util.Map, org.apache.kafkaesque.common.metrics.stats.SampledStat, java.lang.String, java.lang.String)
{
java.lang.Object[] v, v;
org.apache.kafkaesque.common.metrics.Metrics v;
org.apache.kafkaesque.common.metrics.stats.SampledStat v;
java.util.Map v;
org.apache.kafkaesque.common.metrics.stats.Meter v, v;
java.lang.String v, v, v, v, v, v, v;
org.apache.kafkaesque.common.network.Selector$SelectorMetrics v;
org.apache.kafkaesque.common.MetricName v, v;
v := @this: org.apache.kafkaesque.common.network.Selector$SelectorMetrics;
v := @parameter: org.apache.kafkaesque.common.metrics.Metrics;
v := @parameter: java.lang.String;
v := @parameter: java.util.Map;
v := @parameter: org.apache.kafkaesque.common.metrics.stats.SampledStat;
v := @parameter: java.lang.String;
v := @parameter: java.lang.String;
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[])>("\u0001-rate");
v = newarray (java.lang.Object)[1];
v[0] = v;
v = staticinvoke <java.lang.String: java.lang.String format(java.lang.String,java.lang.Object[])>("The number of %s per second", v);
v = virtualinvoke v.<org.apache.kafkaesque.common.metrics.Metrics: org.apache.kafkaesque.common.MetricName metricName(java.lang.String,java.lang.String,java.lang.String,java.util.Map)>(v, v, v, 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[])>("\u0001-total");
v = newarray (java.lang.Object)[1];
v[0] = v;
v = staticinvoke <java.lang.String: java.lang.String format(java.lang.String,java.lang.Object[])>("The total number of %s", v);
v = virtualinvoke v.<org.apache.kafkaesque.common.metrics.Metrics: org.apache.kafkaesque.common.MetricName metricName(java.lang.String,java.lang.String,java.lang.String,java.util.Map)>(v, v, v, v);
if v != null goto label;
v = new org.apache.kafkaesque.common.metrics.stats.Meter;
specialinvoke v.<org.apache.kafkaesque.common.metrics.stats.Meter: void <init>(org.apache.kafkaesque.common.MetricName,org.apache.kafkaesque.common.MetricName)>(v, v);
return v;
label:
v = new org.apache.kafkaesque.common.metrics.stats.Meter;
specialinvoke v.<org.apache.kafkaesque.common.metrics.stats.Meter: void <init>(org.apache.kafkaesque.common.metrics.stats.SampledStat,org.apache.kafkaesque.common.MetricName,org.apache.kafkaesque.common.MetricName)>(v, v, v);
return v;
}
private org.apache.kafkaesque.common.metrics.stats.Meter createMeter(org.apache.kafkaesque.common.metrics.Metrics, java.lang.String, java.util.Map, java.lang.String, java.lang.String)
{
org.apache.kafkaesque.common.network.Selector$SelectorMetrics v;
java.util.Map v;
org.apache.kafkaesque.common.metrics.Metrics v;
org.apache.kafkaesque.common.metrics.stats.Meter v;
java.lang.String v, v, v;
v := @this: org.apache.kafkaesque.common.network.Selector$SelectorMetrics;
v := @parameter: org.apache.kafkaesque.common.metrics.Metrics;
v := @parameter: java.lang.String;
v := @parameter: java.util.Map;
v := @parameter: java.lang.String;
v := @parameter: java.lang.String;
v = specialinvoke v.<org.apache.kafkaesque.common.network.Selector$SelectorMetrics: org.apache.kafkaesque.common.metrics.stats.Meter createMeter(org.apache.kafkaesque.common.metrics.Metrics,java.lang.String,java.util.Map,org.apache.kafkaesque.common.metrics.stats.SampledStat,java.lang.String,java.lang.String)>(v, v, v, null, v, v);
return v;
}
private org.apache.kafkaesque.common.metrics.stats.Meter createIOThreadRatioMeter(org.apache.kafkaesque.common.metrics.Metrics, java.lang.String, java.util.Map, java.lang.String, java.lang.String)
{
java.lang.Object[] v, v;
org.apache.kafkaesque.common.metrics.Metrics v;
java.util.Map v;
org.apache.kafkaesque.common.metrics.stats.Meter v;
java.lang.String v, v, v, v, v, v, v;
org.apache.kafkaesque.common.network.Selector$SelectorMetrics v;
java.util.concurrent.TimeUnit v;
org.apache.kafkaesque.common.MetricName v, v;
v := @this: org.apache.kafkaesque.common.network.Selector$SelectorMetrics;
v := @parameter: org.apache.kafkaesque.common.metrics.Metrics;
v := @parameter: java.lang.String;
v := @parameter: java.util.Map;
v := @parameter: java.lang.String;
v := @parameter: java.lang.String;
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[])>("\u0001-ratio");
v = newarray (java.lang.Object)[1];
v[0] = v;
v = staticinvoke <java.lang.String: java.lang.String format(java.lang.String,java.lang.Object[])>("The fraction of time the I/O thread spent %s", v);
v = virtualinvoke v.<org.apache.kafkaesque.common.metrics.Metrics: org.apache.kafkaesque.common.MetricName metricName(java.lang.String,java.lang.String,java.lang.String,java.util.Map)>(v, v, v, 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[])>("\u0001time-total");
v = newarray (java.lang.Object)[1];
v[0] = v;
v = staticinvoke <java.lang.String: java.lang.String format(java.lang.String,java.lang.Object[])>("The total time the I/O thread spent %s", v);
v = virtualinvoke v.<org.apache.kafkaesque.common.metrics.Metrics: org.apache.kafkaesque.common.MetricName metricName(java.lang.String,java.lang.String,java.lang.String,java.util.Map)>(v, v, v, v);
v = new org.apache.kafkaesque.common.metrics.stats.Meter;
v = <java.util.concurrent.TimeUnit: java.util.concurrent.TimeUnit NANOSECONDS>;
specialinvoke v.<org.apache.kafkaesque.common.metrics.stats.Meter: void <init>(java.util.concurrent.TimeUnit,org.apache.kafkaesque.common.MetricName,org.apache.kafkaesque.common.MetricName)>(v, v, v);
return v;
}
private transient org.apache.kafkaesque.common.metrics.Sensor sensor(java.lang.String, org.apache.kafkaesque.common.metrics.Sensor[])
{
org.apache.kafkaesque.common.network.Selector$SelectorMetrics v;
java.util.List v;
org.apache.kafkaesque.common.metrics.Sensor v;
org.apache.kafkaesque.common.metrics.Sensor[] v;
org.apache.kafkaesque.common.metrics.Metrics v;
java.lang.String v;
v := @this: org.apache.kafkaesque.common.network.Selector$SelectorMetrics;
v := @parameter: java.lang.String;
v := @parameter: org.apache.kafkaesque.common.metrics.Sensor[];
v = v.<org.apache.kafkaesque.common.network.Selector$SelectorMetrics: org.apache.kafkaesque.common.metrics.Metrics metrics>;
v = virtualinvoke v.<org.apache.kafkaesque.common.metrics.Metrics: org.apache.kafkaesque.common.metrics.Sensor sensor(java.lang.String,org.apache.kafkaesque.common.metrics.Sensor[])>(v, v);
v = v.<org.apache.kafkaesque.common.network.Selector$SelectorMetrics: java.util.List sensors>;
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
return v;
}
public void maybeRegisterConnectionMetrics(java.lang.String)
{
org.apache.kafkaesque.common.metrics.stats.Max v, v;
java.util.Map v;
org.apache.kafkaesque.common.metrics.stats.Meter v, v, v, v;
org.apache.kafkaesque.common.metrics.stats.Avg v, v;
boolean v, v;
org.apache.kafkaesque.common.network.Selector$SelectorMetrics v;
org.apache.kafkaesque.common.MetricName v, v, v, v;
org.apache.kafkaesque.common.metrics.Sensor v, v, v, v, v, v;
org.apache.kafkaesque.common.metrics.Metrics v, v, v, v, v, v, v, v, v;
java.util.LinkedHashMap v;
org.apache.kafkaesque.common.metrics.Sensor[] v, v, v, v, v;
java.lang.String v, v, v, v, v, v, v, v, v;
org.apache.kafkaesque.common.metrics.stats.WindowedCount v, v;
v := @this: org.apache.kafkaesque.common.network.Selector$SelectorMetrics;
v := @parameter: java.lang.String;
v = virtualinvoke v.<java.lang.String: boolean isEmpty()>();
if v != 0 goto label;
v = v.<org.apache.kafkaesque.common.network.Selector$SelectorMetrics: boolean metricsPerConnection>;
if v == 0 goto label;
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[])>("node-\u.requests-sent");
v = v.<org.apache.kafkaesque.common.network.Selector$SelectorMetrics: org.apache.kafkaesque.common.metrics.Metrics metrics>;
v = virtualinvoke v.<org.apache.kafkaesque.common.metrics.Metrics: org.apache.kafkaesque.common.metrics.Sensor getSensor(java.lang.String)>(v);
if v != null goto label;
v = v.<org.apache.kafkaesque.common.network.Selector$SelectorMetrics: java.lang.String metricGrpPrefix>;
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[])>("\u0001-node-metrics");
v = new java.util.LinkedHashMap;
v = v.<org.apache.kafkaesque.common.network.Selector$SelectorMetrics: java.util.Map metricTags>;
specialinvoke v.<java.util.LinkedHashMap: void <init>(java.util.Map)>(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[])>("node-\u0001");
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>("node-id", v);
v = newarray (org.apache.kafkaesque.common.metrics.Sensor)[0];
v = specialinvoke v.<org.apache.kafkaesque.common.network.Selector$SelectorMetrics: org.apache.kafkaesque.common.metrics.Sensor sensor(java.lang.String,org.apache.kafkaesque.common.metrics.Sensor[])>(v, v);
v = v.<org.apache.kafkaesque.common.network.Selector$SelectorMetrics: org.apache.kafkaesque.common.metrics.Metrics metrics>;
v = new org.apache.kafkaesque.common.metrics.stats.WindowedCount;
specialinvoke v.<org.apache.kafkaesque.common.metrics.stats.WindowedCount: void <init>()>();
v = specialinvoke v.<org.apache.kafkaesque.common.network.Selector$SelectorMetrics: org.apache.kafkaesque.common.metrics.stats.Meter createMeter(org.apache.kafkaesque.common.metrics.Metrics,java.lang.String,java.util.Map,org.apache.kafkaesque.common.metrics.stats.SampledStat,java.lang.String,java.lang.String)>(v, v, v, v, "request", "requests sent");
virtualinvoke v.<org.apache.kafkaesque.common.metrics.Sensor: boolean add(org.apache.kafkaesque.common.metrics.CompoundStat)>(v);
v = v.<org.apache.kafkaesque.common.network.Selector$SelectorMetrics: org.apache.kafkaesque.common.metrics.Metrics metrics>;
v = virtualinvoke v.<org.apache.kafkaesque.common.metrics.Metrics: org.apache.kafkaesque.common.MetricName metricName(java.lang.String,java.lang.String,java.lang.String,java.util.Map)>("request-size-avg", v, "The average size of requests sent.", v);
v = new org.apache.kafkaesque.common.metrics.stats.Avg;
specialinvoke v.<org.apache.kafkaesque.common.metrics.stats.Avg: void <init>()>();
virtualinvoke v.<org.apache.kafkaesque.common.metrics.Sensor: boolean add(org.apache.kafkaesque.common.MetricName,org.apache.kafkaesque.common.metrics.MeasurableStat)>(v, v);
v = v.<org.apache.kafkaesque.common.network.Selector$SelectorMetrics: org.apache.kafkaesque.common.metrics.Metrics metrics>;
v = virtualinvoke v.<org.apache.kafkaesque.common.metrics.Metrics: org.apache.kafkaesque.common.MetricName metricName(java.lang.String,java.lang.String,java.lang.String,java.util.Map)>("request-size-max", v, "The maximum size of any request sent.", v);
v = new org.apache.kafkaesque.common.metrics.stats.Max;
specialinvoke v.<org.apache.kafkaesque.common.metrics.stats.Max: void <init>()>();
virtualinvoke v.<org.apache.kafkaesque.common.metrics.Sensor: boolean add(org.apache.kafkaesque.common.MetricName,org.apache.kafkaesque.common.metrics.MeasurableStat)>(v, 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[])>("node-\u.bytes-sent");
v = newarray (org.apache.kafkaesque.common.metrics.Sensor)[0];
v = specialinvoke v.<org.apache.kafkaesque.common.network.Selector$SelectorMetrics: org.apache.kafkaesque.common.metrics.Sensor sensor(java.lang.String,org.apache.kafkaesque.common.metrics.Sensor[])>(v, v);
v = v.<org.apache.kafkaesque.common.network.Selector$SelectorMetrics: org.apache.kafkaesque.common.metrics.Metrics metrics>;
v = specialinvoke v.<org.apache.kafkaesque.common.network.Selector$SelectorMetrics: org.apache.kafkaesque.common.metrics.stats.Meter createMeter(org.apache.kafkaesque.common.metrics.Metrics,java.lang.String,java.util.Map,java.lang.String,java.lang.String)>(v, v, v, "outgoing-byte", "outgoing bytes");
virtualinvoke v.<org.apache.kafkaesque.common.metrics.Sensor: boolean add(org.apache.kafkaesque.common.metrics.CompoundStat)>(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[])>("node-\u.responses-received");
v = newarray (org.apache.kafkaesque.common.metrics.Sensor)[0];
v = specialinvoke v.<org.apache.kafkaesque.common.network.Selector$SelectorMetrics: org.apache.kafkaesque.common.metrics.Sensor sensor(java.lang.String,org.apache.kafkaesque.common.metrics.Sensor[])>(v, v);
v = v.<org.apache.kafkaesque.common.network.Selector$SelectorMetrics: org.apache.kafkaesque.common.metrics.Metrics metrics>;
v = new org.apache.kafkaesque.common.metrics.stats.WindowedCount;
specialinvoke v.<org.apache.kafkaesque.common.metrics.stats.WindowedCount: void <init>()>();
v = specialinvoke v.<org.apache.kafkaesque.common.network.Selector$SelectorMetrics: org.apache.kafkaesque.common.metrics.stats.Meter createMeter(org.apache.kafkaesque.common.metrics.Metrics,java.lang.String,java.util.Map,org.apache.kafkaesque.common.metrics.stats.SampledStat,java.lang.String,java.lang.String)>(v, v, v, v, "response", "responses received");
virtualinvoke v.<org.apache.kafkaesque.common.metrics.Sensor: boolean add(org.apache.kafkaesque.common.metrics.CompoundStat)>(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[])>("node-\u.bytes-received");
v = newarray (org.apache.kafkaesque.common.metrics.Sensor)[0];
v = specialinvoke v.<org.apache.kafkaesque.common.network.Selector$SelectorMetrics: org.apache.kafkaesque.common.metrics.Sensor sensor(java.lang.String,org.apache.kafkaesque.common.metrics.Sensor[])>(v, v);
v = v.<org.apache.kafkaesque.common.network.Selector$SelectorMetrics: org.apache.kafkaesque.common.metrics.Metrics metrics>;
v = specialinvoke v.<org.apache.kafkaesque.common.network.Selector$SelectorMetrics: org.apache.kafkaesque.common.metrics.stats.Meter createMeter(org.apache.kafkaesque.common.metrics.Metrics,java.lang.String,java.util.Map,java.lang.String,java.lang.String)>(v, v, v, "incoming-byte", "incoming bytes");
virtualinvoke v.<org.apache.kafkaesque.common.metrics.Sensor: boolean add(org.apache.kafkaesque.common.metrics.CompoundStat)>(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[])>("node-\u.latency");
v = newarray (org.apache.kafkaesque.common.metrics.Sensor)[0];
v = specialinvoke v.<org.apache.kafkaesque.common.network.Selector$SelectorMetrics: org.apache.kafkaesque.common.metrics.Sensor sensor(java.lang.String,org.apache.kafkaesque.common.metrics.Sensor[])>(v, v);
v = v.<org.apache.kafkaesque.common.network.Selector$SelectorMetrics: org.apache.kafkaesque.common.metrics.Metrics metrics>;
v = virtualinvoke v.<org.apache.kafkaesque.common.metrics.Metrics: org.apache.kafkaesque.common.MetricName metricName(java.lang.String,java.lang.String,java.util.Map)>("request-latency-avg", v, v);
v = new org.apache.kafkaesque.common.metrics.stats.Avg;
specialinvoke v.<org.apache.kafkaesque.common.metrics.stats.Avg: void <init>()>();
virtualinvoke v.<org.apache.kafkaesque.common.metrics.Sensor: boolean add(org.apache.kafkaesque.common.MetricName,org.apache.kafkaesque.common.metrics.MeasurableStat)>(v, v);
v = v.<org.apache.kafkaesque.common.network.Selector$SelectorMetrics: org.apache.kafkaesque.common.metrics.Metrics metrics>;
v = virtualinvoke v.<org.apache.kafkaesque.common.metrics.Metrics: org.apache.kafkaesque.common.MetricName metricName(java.lang.String,java.lang.String,java.util.Map)>("request-latency-max", v, v);
v = new org.apache.kafkaesque.common.metrics.stats.Max;
specialinvoke v.<org.apache.kafkaesque.common.metrics.stats.Max: void <init>()>();
virtualinvoke v.<org.apache.kafkaesque.common.metrics.Sensor: boolean add(org.apache.kafkaesque.common.MetricName,org.apache.kafkaesque.common.metrics.MeasurableStat)>(v, v);
label:
return;
}
public void recordBytesSent(java.lang.String, long, long)
{
org.apache.kafkaesque.common.network.Selector$SelectorMetrics v;
org.apache.kafkaesque.common.metrics.Sensor v, v;
org.apache.kafkaesque.common.metrics.Metrics v;
long v, v;
java.lang.String v, v;
boolean v;
v := @this: org.apache.kafkaesque.common.network.Selector$SelectorMetrics;
v := @parameter: java.lang.String;
v := @parameter: long;
v := @parameter: long;
v = v.<org.apache.kafkaesque.common.network.Selector$SelectorMetrics: org.apache.kafkaesque.common.metrics.Sensor bytesSent>;
virtualinvoke v.<org.apache.kafkaesque.common.metrics.Sensor: void record(double,long)>(v, v);
v = virtualinvoke v.<java.lang.String: boolean isEmpty()>();
if v != 0 goto label;
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[])>("node-\u.bytes-sent");
v = v.<org.apache.kafkaesque.common.network.Selector$SelectorMetrics: org.apache.kafkaesque.common.metrics.Metrics metrics>;
v = virtualinvoke v.<org.apache.kafkaesque.common.metrics.Metrics: org.apache.kafkaesque.common.metrics.Sensor getSensor(java.lang.String)>(v);
if v == null goto label;
virtualinvoke v.<org.apache.kafkaesque.common.metrics.Sensor: void record(double,long)>(v, v);
label:
return;
}
public void recordCompletedSend(java.lang.String, long, long)
{
org.apache.kafkaesque.common.network.Selector$SelectorMetrics v;
org.apache.kafkaesque.common.metrics.Sensor v, v;
org.apache.kafkaesque.common.metrics.Metrics v;
long v, v;
java.lang.String v, v;
boolean v;
v := @this: org.apache.kafkaesque.common.network.Selector$SelectorMetrics;
v := @parameter: java.lang.String;
v := @parameter: long;
v := @parameter: long;
v = v.<org.apache.kafkaesque.common.network.Selector$SelectorMetrics: org.apache.kafkaesque.common.metrics.Sensor requestsSent>;
virtualinvoke v.<org.apache.kafkaesque.common.metrics.Sensor: void record(double,long)>(v, v);
v = virtualinvoke v.<java.lang.String: boolean isEmpty()>();
if v != 0 goto label;
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[])>("node-\u.requests-sent");
v = v.<org.apache.kafkaesque.common.network.Selector$SelectorMetrics: org.apache.kafkaesque.common.metrics.Metrics metrics>;
v = virtualinvoke v.<org.apache.kafkaesque.common.metrics.Metrics: org.apache.kafkaesque.common.metrics.Sensor getSensor(java.lang.String)>(v);
if v == null goto label;
virtualinvoke v.<org.apache.kafkaesque.common.metrics.Sensor: void record(double,long)>(v, v);
label:
return;
}
public void recordBytesReceived(java.lang.String, long, long)
{
org.apache.kafkaesque.common.network.Selector$SelectorMetrics v;
org.apache.kafkaesque.common.metrics.Sensor v, v;
org.apache.kafkaesque.common.metrics.Metrics v;
long v, v;
java.lang.String v, v;
boolean v;
v := @this: org.apache.kafkaesque.common.network.Selector$SelectorMetrics;
v := @parameter: java.lang.String;
v := @parameter: long;
v := @parameter: long;
v = v.<org.apache.kafkaesque.common.network.Selector$SelectorMetrics: org.apache.kafkaesque.common.metrics.Sensor bytesReceived>;
virtualinvoke v.<org.apache.kafkaesque.common.metrics.Sensor: void record(double,long)>(v, v);
v = virtualinvoke v.<java.lang.String: boolean isEmpty()>();
if v != 0 goto label;
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[])>("node-\u.bytes-received");
v = v.<org.apache.kafkaesque.common.network.Selector$SelectorMetrics: org.apache.kafkaesque.common.metrics.Metrics metrics>;
v = virtualinvoke v.<org.apache.kafkaesque.common.metrics.Metrics: org.apache.kafkaesque.common.metrics.Sensor getSensor(java.lang.String)>(v);
if v == null goto label;
virtualinvoke v.<org.apache.kafkaesque.common.metrics.Sensor: void record(double,long)>(v, v);
label:
return;
}
public void recordCompletedReceive(java.lang.String, long, long)
{
org.apache.kafkaesque.common.network.Selector$SelectorMetrics v;
org.apache.kafkaesque.common.metrics.Sensor v, v;
org.apache.kafkaesque.common.metrics.Metrics v;
long v, v;
java.lang.String v, v;
boolean v;
v := @this: org.apache.kafkaesque.common.network.Selector$SelectorMetrics;
v := @parameter: java.lang.String;
v := @parameter: long;
v := @parameter: long;
v = v.<org.apache.kafkaesque.common.network.Selector$SelectorMetrics: org.apache.kafkaesque.common.metrics.Sensor responsesReceived>;
virtualinvoke v.<org.apache.kafkaesque.common.metrics.Sensor: void record(double,long)>(v, v);
v = virtualinvoke v.<java.lang.String: boolean isEmpty()>();
if v != 0 goto label;
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[])>("node-\u.responses-received");
v = v.<org.apache.kafkaesque.common.network.Selector$SelectorMetrics: org.apache.kafkaesque.common.metrics.Metrics metrics>;
v = virtualinvoke v.<org.apache.kafkaesque.common.metrics.Metrics: org.apache.kafkaesque.common.metrics.Sensor getSensor(java.lang.String)>(v);
if v == null goto label;
virtualinvoke v.<org.apache.kafkaesque.common.metrics.Sensor: void record(double,long)>(v, v);
label:
return;
}
public void close()
{
org.apache.kafkaesque.common.network.Selector$SelectorMetrics v;
java.util.Iterator v, v;
org.apache.kafkaesque.common.metrics.Metrics v, v;
java.util.List v, v;
org.apache.kafkaesque.common.metrics.internals.IntGaugeSuite v, v;
java.lang.Object v, v;
java.lang.String v;
boolean v, v;
v := @this: org.apache.kafkaesque.common.network.Selector$SelectorMetrics;
v = v.<org.apache.kafkaesque.common.network.Selector$SelectorMetrics: java.util.List topLevelMetricNames>;
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.network.Selector$SelectorMetrics: org.apache.kafkaesque.common.metrics.Metrics metrics>;
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.network.Selector$SelectorMetrics: java.util.List sensors>;
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.network.Selector$SelectorMetrics: org.apache.kafkaesque.common.metrics.Metrics metrics>;
v = virtualinvoke v.<org.apache.kafkaesque.common.metrics.Sensor: java.lang.String name()>();
virtualinvoke v.<org.apache.kafkaesque.common.metrics.Metrics: void removeSensor(java.lang.String)>(v);
goto label;
label:
v = v.<org.apache.kafkaesque.common.network.Selector$SelectorMetrics: org.apache.kafkaesque.common.metrics.internals.IntGaugeSuite connectionsByCipher>;
virtualinvoke v.<org.apache.kafkaesque.common.metrics.internals.IntGaugeSuite: void close()>();
v = v.<org.apache.kafkaesque.common.network.Selector$SelectorMetrics: org.apache.kafkaesque.common.metrics.internals.IntGaugeSuite connectionsByClient>;
virtualinvoke v.<org.apache.kafkaesque.common.metrics.internals.IntGaugeSuite: void close()>();
return;
}
}