class org.apache.kafkaesqueesque.clients.ClusterConnectionStates$NodeConnectionState extends java.lang.Object
{
org.apache.kafkaesqueesque.clients.ConnectionState state;
org.apache.kafkaesqueesque.common.errors.AuthenticationException authenticationException;
long lastConnectAttemptMs;
long failedAttempts;
long reconnectBackoffMs;
long throttleUntilTimeMs;
private java.util.List addresses;
private int addressIndex;
private final java.lang.String host;
private final org.apache.kafkaesqueesque.clients.ClientDnsLookup clientDnsLookup;
private void <init>(org.apache.kafkaesqueesque.clients.ConnectionState, long, long, java.lang.String, org.apache.kafkaesqueesque.clients.ClientDnsLookup)
{
org.apache.kafkaesqueesque.clients.ClusterConnectionStates$NodeConnectionState v;
org.apache.kafkaesqueesque.clients.ConnectionState v;
long v, v;
org.apache.kafkaesqueesque.clients.ClientDnsLookup v;
java.util.List v;
int v;
java.lang.String v;
v := @this: org.apache.kafkaesqueesque.clients.ClusterConnectionStates$NodeConnectionState;
v := @parameter: org.apache.kafkaesqueesque.clients.ConnectionState;
v := @parameter: long;
v := @parameter: long;
v := @parameter: java.lang.String;
v := @parameter: org.apache.kafkaesqueesque.clients.ClientDnsLookup;
specialinvoke v.<java.lang.Object: void <init>()>();
v.<org.apache.kafkaesqueesque.clients.ClusterConnectionStates$NodeConnectionState: org.apache.kafkaesqueesque.clients.ConnectionState state> = v;
v = staticinvoke <java.util.Collections: java.util.List emptyList()>();
v.<org.apache.kafkaesqueesque.clients.ClusterConnectionStates$NodeConnectionState: java.util.List addresses> = v;
v = (int) -1;
v.<org.apache.kafkaesqueesque.clients.ClusterConnectionStates$NodeConnectionState: int addressIndex> = v;
v.<org.apache.kafkaesqueesque.clients.ClusterConnectionStates$NodeConnectionState: org.apache.kafkaesqueesque.common.errors.AuthenticationException authenticationException> = null;
v.<org.apache.kafkaesqueesque.clients.ClusterConnectionStates$NodeConnectionState: long lastConnectAttemptMs> = v;
v.<org.apache.kafkaesqueesque.clients.ClusterConnectionStates$NodeConnectionState: long failedAttempts> = 0L;
v.<org.apache.kafkaesqueesque.clients.ClusterConnectionStates$NodeConnectionState: long reconnectBackoffMs> = v;
v.<org.apache.kafkaesqueesque.clients.ClusterConnectionStates$NodeConnectionState: long throttleUntilTimeMs> = 0L;
v.<org.apache.kafkaesqueesque.clients.ClusterConnectionStates$NodeConnectionState: java.lang.String host> = v;
v.<org.apache.kafkaesqueesque.clients.ClusterConnectionStates$NodeConnectionState: org.apache.kafkaesqueesque.clients.ClientDnsLookup clientDnsLookup> = v;
return;
}
public java.lang.String host()
{
org.apache.kafkaesqueesque.clients.ClusterConnectionStates$NodeConnectionState v;
java.lang.String v;
v := @this: org.apache.kafkaesqueesque.clients.ClusterConnectionStates$NodeConnectionState;
v = v.<org.apache.kafkaesqueesque.clients.ClusterConnectionStates$NodeConnectionState: java.lang.String host>;
return v;
}
private java.net.InetAddress currentAddress() throws java.net.UnknownHostException
{
org.apache.kafkaesqueesque.clients.ClusterConnectionStates$NodeConnectionState v;
org.apache.kafkaesqueesque.clients.ClientDnsLookup v;
java.util.List v, v, v;
int v;
java.lang.Object v;
java.lang.String v;
boolean v;
v := @this: org.apache.kafkaesqueesque.clients.ClusterConnectionStates$NodeConnectionState;
v = v.<org.apache.kafkaesqueesque.clients.ClusterConnectionStates$NodeConnectionState: java.util.List addresses>;
v = interfaceinvoke v.<java.util.List: boolean isEmpty()>();
if v == 0 goto label;
v = v.<org.apache.kafkaesqueesque.clients.ClusterConnectionStates$NodeConnectionState: java.lang.String host>;
v = v.<org.apache.kafkaesqueesque.clients.ClusterConnectionStates$NodeConnectionState: org.apache.kafkaesqueesque.clients.ClientDnsLookup clientDnsLookup>;
v = staticinvoke <org.apache.kafkaesqueesque.clients.ClientUtils: java.util.List resolve(java.lang.String,org.apache.kafkaesqueesque.clients.ClientDnsLookup)>(v, v);
v.<org.apache.kafkaesqueesque.clients.ClusterConnectionStates$NodeConnectionState: java.util.List addresses> = v;
v.<org.apache.kafkaesqueesque.clients.ClusterConnectionStates$NodeConnectionState: int addressIndex> = 0;
label:
v = v.<org.apache.kafkaesqueesque.clients.ClusterConnectionStates$NodeConnectionState: java.util.List addresses>;
v = v.<org.apache.kafkaesqueesque.clients.ClusterConnectionStates$NodeConnectionState: int addressIndex>;
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(v);
return v;
}
private void moveToNextAddress()
{
org.apache.kafkaesqueesque.clients.ClusterConnectionStates$NodeConnectionState v;
java.util.List v, v, v;
int v, v, v, v, v;
boolean v;
v := @this: org.apache.kafkaesqueesque.clients.ClusterConnectionStates$NodeConnectionState;
v = v.<org.apache.kafkaesqueesque.clients.ClusterConnectionStates$NodeConnectionState: java.util.List addresses>;
v = interfaceinvoke v.<java.util.List: boolean isEmpty()>();
if v == 0 goto label;
return;
label:
v = v.<org.apache.kafkaesqueesque.clients.ClusterConnectionStates$NodeConnectionState: int addressIndex>;
v = v + 1;
v = v.<org.apache.kafkaesqueesque.clients.ClusterConnectionStates$NodeConnectionState: java.util.List addresses>;
v = interfaceinvoke v.<java.util.List: int size()>();
v = v % v;
v.<org.apache.kafkaesqueesque.clients.ClusterConnectionStates$NodeConnectionState: int addressIndex> = v;
v = v.<org.apache.kafkaesqueesque.clients.ClusterConnectionStates$NodeConnectionState: int addressIndex>;
if v != 0 goto label;
v = staticinvoke <java.util.Collections: java.util.List emptyList()>();
v.<org.apache.kafkaesqueesque.clients.ClusterConnectionStates$NodeConnectionState: java.util.List addresses> = v;
label:
return;
}
public java.lang.String toString()
{
org.apache.kafkaesqueesque.clients.ClusterConnectionStates$NodeConnectionState v;
org.apache.kafkaesqueesque.clients.ConnectionState v;
long v, v, v;
java.lang.String v;
v := @this: org.apache.kafkaesqueesque.clients.ClusterConnectionStates$NodeConnectionState;
v = v.<org.apache.kafkaesqueesque.clients.ClusterConnectionStates$NodeConnectionState: org.apache.kafkaesqueesque.clients.ConnectionState state>;
v = v.<org.apache.kafkaesqueesque.clients.ClusterConnectionStates$NodeConnectionState: long lastConnectAttemptMs>;
v = v.<org.apache.kafkaesqueesque.clients.ClusterConnectionStates$NodeConnectionState: long failedAttempts>;
v = v.<org.apache.kafkaesqueesque.clients.ClusterConnectionStates$NodeConnectionState: long throttleUntilTimeMs>;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (org.apache.kafkaesqueesque.clients.ConnectionState,long,long,long)>(v, v, v, 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[])>("NodeState(\u, \u, \u, \u)");
return v;
}
}