abstract class org.apache.kafkaesqueesqueesque.clients.admin.KafkaAdminClient$Call extends java.lang.Object
{
private final boolean internal;
private final java.lang.String callName;
private final long deadlineMs;
private final org.apache.kafkaesqueesqueesque.clients.admin.KafkaAdminClient$NodeProvider nodeProvider;
private int tries;
private boolean aborted;
private org.apache.kafkaesqueesqueesque.common.Node curNode;
private long nextAllowedTryMs;
final org.apache.kafkaesqueesqueesque.clients.admin.KafkaAdminClient this$0;
void <init>(org.apache.kafkaesqueesqueesque.clients.admin.KafkaAdminClient, boolean, java.lang.String, long, org.apache.kafkaesqueesqueesque.clients.admin.KafkaAdminClient$NodeProvider)
{
org.apache.kafkaesqueesqueesque.clients.admin.KafkaAdminClient v;
org.apache.kafkaesqueesqueesque.clients.admin.KafkaAdminClient$Call v;
long v;
java.lang.String v;
org.apache.kafkaesqueesqueesque.clients.admin.KafkaAdminClient$NodeProvider v;
boolean v;
v := @this: org.apache.kafkaesqueesqueesque.clients.admin.KafkaAdminClient$Call;
v := @parameter: org.apache.kafkaesqueesqueesque.clients.admin.KafkaAdminClient;
v := @parameter: boolean;
v := @parameter: java.lang.String;
v := @parameter: long;
v := @parameter: org.apache.kafkaesqueesqueesque.clients.admin.KafkaAdminClient$NodeProvider;
v.<org.apache.kafkaesqueesqueesque.clients.admin.KafkaAdminClient$Call: org.apache.kafkaesqueesqueesque.clients.admin.KafkaAdminClient this$0> = v;
specialinvoke v.<java.lang.Object: void <init>()>();
v.<org.apache.kafkaesqueesqueesque.clients.admin.KafkaAdminClient$Call: int tries> = 0;
v.<org.apache.kafkaesqueesqueesque.clients.admin.KafkaAdminClient$Call: boolean aborted> = 0;
v.<org.apache.kafkaesqueesqueesque.clients.admin.KafkaAdminClient$Call: org.apache.kafkaesqueesqueesque.common.Node curNode> = null;
v.<org.apache.kafkaesqueesqueesque.clients.admin.KafkaAdminClient$Call: long nextAllowedTryMs> = 0L;
v.<org.apache.kafkaesqueesqueesque.clients.admin.KafkaAdminClient$Call: boolean internal> = v;
v.<org.apache.kafkaesqueesqueesque.clients.admin.KafkaAdminClient$Call: java.lang.String callName> = v;
v.<org.apache.kafkaesqueesqueesque.clients.admin.KafkaAdminClient$Call: long deadlineMs> = v;
v.<org.apache.kafkaesqueesqueesque.clients.admin.KafkaAdminClient$Call: org.apache.kafkaesqueesqueesque.clients.admin.KafkaAdminClient$NodeProvider nodeProvider> = v;
return;
}
void <init>(org.apache.kafkaesqueesqueesque.clients.admin.KafkaAdminClient, java.lang.String, long, org.apache.kafkaesqueesqueesque.clients.admin.KafkaAdminClient$NodeProvider)
{
org.apache.kafkaesqueesqueesque.clients.admin.KafkaAdminClient v;
org.apache.kafkaesqueesqueesque.clients.admin.KafkaAdminClient$Call v;
long v;
java.lang.String v;
org.apache.kafkaesqueesqueesque.clients.admin.KafkaAdminClient$NodeProvider v;
v := @this: org.apache.kafkaesqueesqueesque.clients.admin.KafkaAdminClient$Call;
v := @parameter: org.apache.kafkaesqueesqueesque.clients.admin.KafkaAdminClient;
v := @parameter: java.lang.String;
v := @parameter: long;
v := @parameter: org.apache.kafkaesqueesqueesque.clients.admin.KafkaAdminClient$NodeProvider;
specialinvoke v.<org.apache.kafkaesqueesqueesque.clients.admin.KafkaAdminClient$Call: void <init>(org.apache.kafkaesqueesqueesque.clients.admin.KafkaAdminClient,boolean,java.lang.String,long,org.apache.kafkaesqueesqueesque.clients.admin.KafkaAdminClient$NodeProvider)>(v, 0, v, v, v);
return;
}
protected org.apache.kafkaesqueesqueesque.common.Node curNode()
{
org.apache.kafkaesqueesqueesque.clients.admin.KafkaAdminClient$Call v;
org.apache.kafkaesqueesqueesque.common.Node v;
v := @this: org.apache.kafkaesqueesqueesque.clients.admin.KafkaAdminClient$Call;
v = v.<org.apache.kafkaesqueesqueesque.clients.admin.KafkaAdminClient$Call: org.apache.kafkaesqueesqueesque.common.Node curNode>;
return v;
}
final void fail(long, java.lang.Throwable)
{
java.lang.Integer v, v;
boolean v, v, v, v, v, v;
java.lang.Exception v;
org.apache.kafkaesqueesqueesque.clients.admin.KafkaAdminClient$AdminClientRunnable v, v;
java.lang.Throwable v;
java.lang.Object[] v, v;
long v, v, v, v;
int v, v, v, v, v, v, v, v, v;
java.lang.String v, v;
org.apache.kafkaesqueesqueesque.clients.admin.KafkaAdminClient v, v, v, v, v, v, v, v, v;
org.slf4j.Logger v, v, v, v, v;
org.apache.kafkaesqueesqueesque.clients.admin.KafkaAdminClient$Call v;
v := @this: org.apache.kafkaesqueesqueesque.clients.admin.KafkaAdminClient$Call;
v := @parameter: long;
v := @parameter: java.lang.Throwable;
v = v.<org.apache.kafkaesqueesqueesque.clients.admin.KafkaAdminClient$Call: boolean aborted>;
if v == 0 goto label;
v = v.<org.apache.kafkaesqueesqueesque.clients.admin.KafkaAdminClient$Call: int tries>;
v = v + 1;
v.<org.apache.kafkaesqueesqueesque.clients.admin.KafkaAdminClient$Call: int tries> = v;
specialinvoke v.<org.apache.kafkaesqueesqueesque.clients.admin.KafkaAdminClient$Call: void failWithTimeout(long,java.lang.Throwable)>(v, v);
return;
label:
v = v instanceof org.apache.kafkaesqueesqueesque.common.errors.UnsupportedVersionException;
if v == 0 goto label;
v = virtualinvoke v.<org.apache.kafkaesqueesqueesque.clients.admin.KafkaAdminClient$Call: boolean handleUnsupportedVersionException(org.apache.kafkaesqueesqueesque.common.errors.UnsupportedVersionException)>(v);
if v == 0 goto label;
v = v.<org.apache.kafkaesqueesqueesque.clients.admin.KafkaAdminClient$Call: org.apache.kafkaesqueesqueesque.clients.admin.KafkaAdminClient this$0>;
v = v.<org.apache.kafkaesqueesqueesque.clients.admin.KafkaAdminClient: org.slf4j.Logger log>;
interfaceinvoke v.<org.slf4j.Logger: void debug(java.lang.String,java.lang.Object)>("{} attempting protocol downgrade and then retry.", v);
v = v.<org.apache.kafkaesqueesqueesque.clients.admin.KafkaAdminClient$Call: org.apache.kafkaesqueesqueesque.clients.admin.KafkaAdminClient this$0>;
v = v.<org.apache.kafkaesqueesqueesque.clients.admin.KafkaAdminClient: org.apache.kafkaesqueesqueesque.clients.admin.KafkaAdminClient$AdminClientRunnable runnable>;
virtualinvoke v.<org.apache.kafkaesqueesqueesque.clients.admin.KafkaAdminClient$AdminClientRunnable: void enqueue(org.apache.kafkaesqueesqueesque.clients.admin.KafkaAdminClient$Call,long)>(v, v);
return;
label:
v = v.<org.apache.kafkaesqueesqueesque.clients.admin.KafkaAdminClient$Call: int tries>;
v = v + 1;
v.<org.apache.kafkaesqueesqueesque.clients.admin.KafkaAdminClient$Call: int tries> = v;
v = v.<org.apache.kafkaesqueesqueesque.clients.admin.KafkaAdminClient$Call: org.apache.kafkaesqueesqueesque.clients.admin.KafkaAdminClient this$0>;
v = v.<org.apache.kafkaesqueesqueesque.clients.admin.KafkaAdminClient: long retryBackoffMs>;
v = v + v;
v.<org.apache.kafkaesqueesqueesque.clients.admin.KafkaAdminClient$Call: long nextAllowedTryMs> = v;
v = v.<org.apache.kafkaesqueesqueesque.clients.admin.KafkaAdminClient$Call: long deadlineMs>;
v = staticinvoke <org.apache.kafkaesqueesqueesque.clients.admin.KafkaAdminClient: int calcTimeoutMsRemainingAsInt(long,long)>(v, v);
if v >= 0 goto label;
specialinvoke v.<org.apache.kafkaesqueesqueesque.clients.admin.KafkaAdminClient$Call: void failWithTimeout(long,java.lang.Throwable)>(v, v);
return;
label:
v = v instanceof org.apache.kafkaesqueesqueesque.common.errors.RetriableException;
if v != 0 goto label;
v = v.<org.apache.kafkaesqueesqueesque.clients.admin.KafkaAdminClient$Call: org.apache.kafkaesqueesqueesque.clients.admin.KafkaAdminClient this$0>;
v = v.<org.apache.kafkaesqueesqueesque.clients.admin.KafkaAdminClient: org.slf4j.Logger log>;
v = interfaceinvoke v.<org.slf4j.Logger: boolean isDebugEnabled()>();
if v == 0 goto label;
v = v.<org.apache.kafkaesqueesqueesque.clients.admin.KafkaAdminClient$Call: org.apache.kafkaesqueesqueesque.clients.admin.KafkaAdminClient this$0>;
v = v.<org.apache.kafkaesqueesqueesque.clients.admin.KafkaAdminClient: org.slf4j.Logger log>;
v = newarray (java.lang.Object)[3];
v[0] = v;
v = v.<org.apache.kafkaesqueesqueesque.clients.admin.KafkaAdminClient$Call: int tries>;
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
v[1] = v;
v = new java.lang.Exception;
v = staticinvoke <org.apache.kafkaesqueesqueesque.clients.admin.KafkaAdminClient: java.lang.String prettyPrintException(java.lang.Throwable)>(v);
specialinvoke v.<java.lang.Exception: void <init>(java.lang.String)>(v);
v[2] = v;
interfaceinvoke v.<org.slf4j.Logger: void debug(java.lang.String,java.lang.Object[])>("{} failed with non-retriable exception after {} attempt(s)", v);
label:
virtualinvoke v.<org.apache.kafkaesqueesqueesque.clients.admin.KafkaAdminClient$Call: void handleFailure(java.lang.Throwable)>(v);
return;
label:
v = v.<org.apache.kafkaesqueesqueesque.clients.admin.KafkaAdminClient$Call: int tries>;
v = v.<org.apache.kafkaesqueesqueesque.clients.admin.KafkaAdminClient$Call: org.apache.kafkaesqueesqueesque.clients.admin.KafkaAdminClient this$0>;
v = v.<org.apache.kafkaesqueesqueesque.clients.admin.KafkaAdminClient: int maxRetries>;
if v <= v goto label;
specialinvoke v.<org.apache.kafkaesqueesqueesque.clients.admin.KafkaAdminClient$Call: void failWithTimeout(long,java.lang.Throwable)>(v, v);
return;
label:
v = v.<org.apache.kafkaesqueesqueesque.clients.admin.KafkaAdminClient$Call: org.apache.kafkaesqueesqueesque.clients.admin.KafkaAdminClient this$0>;
v = v.<org.apache.kafkaesqueesqueesque.clients.admin.KafkaAdminClient: org.slf4j.Logger log>;
v = interfaceinvoke v.<org.slf4j.Logger: boolean isDebugEnabled()>();
if v == 0 goto label;
v = v.<org.apache.kafkaesqueesqueesque.clients.admin.KafkaAdminClient$Call: org.apache.kafkaesqueesqueesque.clients.admin.KafkaAdminClient this$0>;
v = v.<org.apache.kafkaesqueesqueesque.clients.admin.KafkaAdminClient: org.slf4j.Logger log>;
v = newarray (java.lang.Object)[3];
v[0] = v;
v = staticinvoke <org.apache.kafkaesqueesqueesque.clients.admin.KafkaAdminClient: java.lang.String prettyPrintException(java.lang.Throwable)>(v);
v[1] = v;
v = v.<org.apache.kafkaesqueesqueesque.clients.admin.KafkaAdminClient$Call: int tries>;
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[])>("{} failed: {}. Beginning retry #{}", v);
label:
v = v.<org.apache.kafkaesqueesqueesque.clients.admin.KafkaAdminClient$Call: org.apache.kafkaesqueesqueesque.clients.admin.KafkaAdminClient this$0>;
v = v.<org.apache.kafkaesqueesqueesque.clients.admin.KafkaAdminClient: org.apache.kafkaesqueesqueesque.clients.admin.KafkaAdminClient$AdminClientRunnable runnable>;
virtualinvoke v.<org.apache.kafkaesqueesqueesque.clients.admin.KafkaAdminClient$AdminClientRunnable: void enqueue(org.apache.kafkaesqueesqueesque.clients.admin.KafkaAdminClient$Call,long)>(v, v);
return;
}
private void failWithTimeout(long, java.lang.Throwable)
{
java.lang.Throwable v;
java.lang.Object[] v;
long v;
java.lang.Integer v;
java.lang.Long v;
int v, v;
java.lang.String v, v;
boolean v;
org.apache.kafkaesqueesqueesque.clients.admin.KafkaAdminClient v, v;
org.slf4j.Logger v, v;
java.lang.Exception v;
org.apache.kafkaesqueesqueesque.common.errors.TimeoutException v;
org.apache.kafkaesqueesqueesque.clients.admin.KafkaAdminClient$Call v;
v := @this: org.apache.kafkaesqueesqueesque.clients.admin.KafkaAdminClient$Call;
v := @parameter: long;
v := @parameter: java.lang.Throwable;
v = v.<org.apache.kafkaesqueesqueesque.clients.admin.KafkaAdminClient$Call: org.apache.kafkaesqueesqueesque.clients.admin.KafkaAdminClient this$0>;
v = v.<org.apache.kafkaesqueesqueesque.clients.admin.KafkaAdminClient: org.slf4j.Logger log>;
v = interfaceinvoke v.<org.slf4j.Logger: boolean isDebugEnabled()>();
if v == 0 goto label;
v = v.<org.apache.kafkaesqueesqueesque.clients.admin.KafkaAdminClient$Call: org.apache.kafkaesqueesqueesque.clients.admin.KafkaAdminClient this$0>;
v = v.<org.apache.kafkaesqueesqueesque.clients.admin.KafkaAdminClient: org.slf4j.Logger log>;
v = newarray (java.lang.Object)[4];
v[0] = v;
v = staticinvoke <java.lang.Long: java.lang.Long valueOf(long)>(v);
v[1] = v;
v = v.<org.apache.kafkaesqueesqueesque.clients.admin.KafkaAdminClient$Call: int tries>;
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
v[2] = v;
v = new java.lang.Exception;
v = staticinvoke <org.apache.kafkaesqueesqueesque.clients.admin.KafkaAdminClient: java.lang.String prettyPrintException(java.lang.Throwable)>(v);
specialinvoke v.<java.lang.Exception: void <init>(java.lang.String)>(v);
v[3] = v;
interfaceinvoke v.<org.slf4j.Logger: void debug(java.lang.String,java.lang.Object[])>("{} timed out at {} after {} attempt(s)", v);
label:
v = new org.apache.kafkaesqueesqueesque.common.errors.TimeoutException;
v = v.<org.apache.kafkaesqueesqueesque.clients.admin.KafkaAdminClient$Call: int tries>;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (org.apache.kafkaesqueesqueesque.clients.admin.KafkaAdminClient$Call,long,int)>(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[])>("\u timed out at \u after \u attempt(s)");
specialinvoke v.<org.apache.kafkaesqueesqueesque.common.errors.TimeoutException: void <init>(java.lang.String,java.lang.Throwable)>(v, v);
virtualinvoke v.<org.apache.kafkaesqueesqueesque.clients.admin.KafkaAdminClient$Call: void handleFailure(java.lang.Throwable)>(v);
return;
}
abstract org.apache.kafkaesqueesqueesque.common.requests.AbstractRequest$Builder createRequest(int);
abstract void handleResponse(org.apache.kafkaesqueesqueesque.common.requests.AbstractResponse);
abstract void handleFailure(java.lang.Throwable);
boolean handleUnsupportedVersionException(org.apache.kafkaesqueesqueesque.common.errors.UnsupportedVersionException)
{
org.apache.kafkaesqueesqueesque.clients.admin.KafkaAdminClient$Call v;
org.apache.kafkaesqueesqueesque.common.errors.UnsupportedVersionException v;
v := @this: org.apache.kafkaesqueesqueesque.clients.admin.KafkaAdminClient$Call;
v := @parameter: org.apache.kafkaesqueesqueesque.common.errors.UnsupportedVersionException;
return 0;
}
public java.lang.String toString()
{
org.apache.kafkaesqueesqueesque.clients.admin.KafkaAdminClient$Call v;
long v;
java.lang.String v, v;
v := @this: org.apache.kafkaesqueesqueesque.clients.admin.KafkaAdminClient$Call;
v = v.<org.apache.kafkaesqueesqueesque.clients.admin.KafkaAdminClient$Call: java.lang.String callName>;
v = v.<org.apache.kafkaesqueesqueesque.clients.admin.KafkaAdminClient$Call: long deadlineMs>;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String,long)>(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[])>("Call(callName=\u, deadlineMs=\u)");
return v;
}
public boolean isInternal()
{
org.apache.kafkaesqueesqueesque.clients.admin.KafkaAdminClient$Call v;
boolean v;
v := @this: org.apache.kafkaesqueesqueesque.clients.admin.KafkaAdminClient$Call;
v = v.<org.apache.kafkaesqueesqueesque.clients.admin.KafkaAdminClient$Call: boolean internal>;
return v;
}
}