class org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient$RetryTaskErrback extends java.lang.Object implements org.apache.hive.kudu.com.stumbleupon.async.Callback
{
private final org.apache.hive.kudu.org.apache.kudu.client.KuduRpc fakeRpc;
private final org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.TimerTask retryTask;
final org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient this$0;
public void <init>(org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient, org.apache.hive.kudu.org.apache.kudu.client.KuduRpc, org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.TimerTask)
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.TimerTask v;
org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient v;
org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient$RetryTaskErrback v;
org.apache.hive.kudu.org.apache.kudu.client.KuduRpc v;
v := @this: org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient$RetryTaskErrback;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.client.KuduRpc;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.TimerTask;
v.<org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient$RetryTaskErrback: org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient this$0> = v;
specialinvoke v.<java.lang.Object: void <init>()>();
v.<org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient$RetryTaskErrback: org.apache.hive.kudu.org.apache.kudu.client.KuduRpc fakeRpc> = v;
v.<org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient$RetryTaskErrback: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.TimerTask retryTask> = v;
return;
}
public java.lang.Void call(java.lang.Exception)
{
org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient v, v;
long v;
org.apache.hive.kudu.org.apache.kudu.client.KuduRpc v, v, v, v, v, v, v;
org.apache.hive.kudu.org.apache.kudu.client.RpcTraceFrame v;
org.apache.hive.kudu.org.apache.kudu.client.RpcTraceFrame$RpcTraceFrameBuilder v, v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.HashedWheelTimer v;
java.lang.String v;
boolean v, v, v;
org.apache.hive.kudu.org.apache.kudu.client.TimeoutTracker v;
org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient$RetryTaskErrback v;
org.apache.hive.kudu.org.apache.kudu.client.Status v;
java.lang.Exception v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.TimerTask v;
org.apache.hive.kudu.org.apache.kudu.client.RpcTraceFrame$Action v;
v := @this: org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient$RetryTaskErrback;
v := @parameter: java.lang.Exception;
v = v instanceof org.apache.hive.kudu.org.apache.kudu.client.RecoverableException;
if v != 0 goto label;
v = v.<org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient$RetryTaskErrback: org.apache.hive.kudu.org.apache.kudu.client.KuduRpc fakeRpc>;
virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.client.KuduRpc: void errback(java.lang.Exception)>(v);
return null;
label:
v = v.<org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient$RetryTaskErrback: org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient this$0>;
v = v.<org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient$RetryTaskErrback: org.apache.hive.kudu.org.apache.kudu.client.KuduRpc fakeRpc>;
v = specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient: long getSleepTimeForRpcMillis(org.apache.hive.kudu.org.apache.kudu.client.KuduRpc)>(v);
v = v.<org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient$RetryTaskErrback: org.apache.hive.kudu.org.apache.kudu.client.KuduRpc fakeRpc>;
v = staticinvoke <org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient: boolean cannotRetryRequest(org.apache.hive.kudu.org.apache.kudu.client.KuduRpc)>(v);
if v != 0 goto label;
v = v.<org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient$RetryTaskErrback: org.apache.hive.kudu.org.apache.kudu.client.KuduRpc fakeRpc>;
v = v.<org.apache.hive.kudu.org.apache.kudu.client.KuduRpc: org.apache.hive.kudu.org.apache.kudu.client.TimeoutTracker timeoutTracker>;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.client.TimeoutTracker: boolean wouldSleepingTimeoutMillis(long)>(v);
if v == 0 goto label;
label:
v = v.<org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient$RetryTaskErrback: org.apache.hive.kudu.org.apache.kudu.client.KuduRpc fakeRpc>;
staticinvoke <org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient: org.apache.hive.kudu.com.stumbleupon.async.Deferred tooManyAttemptsOrTimeout(org.apache.hive.kudu.org.apache.kudu.client.KuduRpc,org.apache.hive.kudu.org.apache.kudu.client.KuduException)>(v, v);
return null;
label:
v = v.<org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient$RetryTaskErrback: org.apache.hive.kudu.org.apache.kudu.client.KuduRpc fakeRpc>;
v = new org.apache.hive.kudu.org.apache.kudu.client.RpcTraceFrame$RpcTraceFrameBuilder;
v = v.<org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient$RetryTaskErrback: org.apache.hive.kudu.org.apache.kudu.client.KuduRpc fakeRpc>;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.client.KuduRpc: java.lang.String method()>();
v = <org.apache.hive.kudu.org.apache.kudu.client.RpcTraceFrame$Action: org.apache.hive.kudu.org.apache.kudu.client.RpcTraceFrame$Action SLEEP_THEN_RETRY>;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.client.RpcTraceFrame$RpcTraceFrameBuilder: void <init>(java.lang.String,org.apache.hive.kudu.org.apache.kudu.client.RpcTraceFrame$Action)>(v, v);
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.client.RecoverableException: org.apache.hive.kudu.org.apache.kudu.client.Status getStatus()>();
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.client.RpcTraceFrame$RpcTraceFrameBuilder: org.apache.hive.kudu.org.apache.kudu.client.RpcTraceFrame$RpcTraceFrameBuilder callStatus(org.apache.hive.kudu.org.apache.kudu.client.Status)>(v);
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.client.RpcTraceFrame$RpcTraceFrameBuilder: org.apache.hive.kudu.org.apache.kudu.client.RpcTraceFrame build()>();
virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.client.KuduRpc: void addTrace(org.apache.hive.kudu.org.apache.kudu.client.RpcTraceFrame)>(v);
v = v.<org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient$RetryTaskErrback: org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient this$0>;
v = v.<org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.HashedWheelTimer timer>;
v = v.<org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient$RetryTaskErrback: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.TimerTask retryTask>;
staticinvoke <org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.Timeout newTimeout(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.Timer,org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.TimerTask,long)>(v, v, v);
return null;
}
public java.lang.String toString()
{
org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient$RetryTaskErrback v;
v := @this: org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient$RetryTaskErrback;
return "retry task after error";
}
}