class oadd.org.apache.hadoop.io.retry.RetryPolicies$FailoverOnNetworkExceptionRetry extends java.lang.Object implements oadd.org.apache.hadoop.io.retry.RetryPolicy
{
private oadd.org.apache.hadoop.io.retry.RetryPolicy fallbackPolicy;
private int maxFailovers;
private int maxRetries;
private long delayMillis;
private long maxDelayBase;
public void <init>(oadd.org.apache.hadoop.io.retry.RetryPolicy, int)
{
int v;
oadd.org.apache.hadoop.io.retry.RetryPolicies$FailoverOnNetworkExceptionRetry v;
oadd.org.apache.hadoop.io.retry.RetryPolicy v;
v := @this: oadd.org.apache.hadoop.io.retry.RetryPolicies$FailoverOnNetworkExceptionRetry;
v := @parameter: oadd.org.apache.hadoop.io.retry.RetryPolicy;
v := @parameter: int;
specialinvoke v.<oadd.org.apache.hadoop.io.retry.RetryPolicies$FailoverOnNetworkExceptionRetry: void <init>(oadd.org.apache.hadoop.io.retry.RetryPolicy,int,int,long,long)>(v, v, 0, 0L, 0L);
return;
}
public void <init>(oadd.org.apache.hadoop.io.retry.RetryPolicy, int, long, long)
{
int v;
oadd.org.apache.hadoop.io.retry.RetryPolicies$FailoverOnNetworkExceptionRetry v;
long v, v;
oadd.org.apache.hadoop.io.retry.RetryPolicy v;
v := @this: oadd.org.apache.hadoop.io.retry.RetryPolicies$FailoverOnNetworkExceptionRetry;
v := @parameter: oadd.org.apache.hadoop.io.retry.RetryPolicy;
v := @parameter: int;
v := @parameter: long;
v := @parameter: long;
specialinvoke v.<oadd.org.apache.hadoop.io.retry.RetryPolicies$FailoverOnNetworkExceptionRetry: void <init>(oadd.org.apache.hadoop.io.retry.RetryPolicy,int,int,long,long)>(v, v, 0, v, v);
return;
}
public void <init>(oadd.org.apache.hadoop.io.retry.RetryPolicy, int, int, long, long)
{
int v, v;
oadd.org.apache.hadoop.io.retry.RetryPolicies$FailoverOnNetworkExceptionRetry v;
long v, v;
oadd.org.apache.hadoop.io.retry.RetryPolicy v;
v := @this: oadd.org.apache.hadoop.io.retry.RetryPolicies$FailoverOnNetworkExceptionRetry;
v := @parameter: oadd.org.apache.hadoop.io.retry.RetryPolicy;
v := @parameter: int;
v := @parameter: int;
v := @parameter: long;
v := @parameter: long;
specialinvoke v.<java.lang.Object: void <init>()>();
v.<oadd.org.apache.hadoop.io.retry.RetryPolicies$FailoverOnNetworkExceptionRetry: oadd.org.apache.hadoop.io.retry.RetryPolicy fallbackPolicy> = v;
v.<oadd.org.apache.hadoop.io.retry.RetryPolicies$FailoverOnNetworkExceptionRetry: int maxFailovers> = v;
v.<oadd.org.apache.hadoop.io.retry.RetryPolicies$FailoverOnNetworkExceptionRetry: int maxRetries> = v;
v.<oadd.org.apache.hadoop.io.retry.RetryPolicies$FailoverOnNetworkExceptionRetry: long delayMillis> = v;
v.<oadd.org.apache.hadoop.io.retry.RetryPolicies$FailoverOnNetworkExceptionRetry: long maxDelayBase> = v;
return;
}
private long getFailoverOrRetrySleepTime(int)
{
int v;
oadd.org.apache.hadoop.io.retry.RetryPolicies$FailoverOnNetworkExceptionRetry v;
long v, v, v;
v := @this: oadd.org.apache.hadoop.io.retry.RetryPolicies$FailoverOnNetworkExceptionRetry;
v := @parameter: int;
if v != 0 goto label;
v = 0L;
goto label;
label:
v = v.<oadd.org.apache.hadoop.io.retry.RetryPolicies$FailoverOnNetworkExceptionRetry: long delayMillis>;
v = v.<oadd.org.apache.hadoop.io.retry.RetryPolicies$FailoverOnNetworkExceptionRetry: long maxDelayBase>;
v = staticinvoke <oadd.org.apache.hadoop.io.retry.RetryPolicies: long calculateExponentialTime(long,int,long)>(v, v, v);
label:
return v;
}
public oadd.org.apache.hadoop.io.retry.RetryPolicy$RetryAction shouldRetry(java.lang.Exception, int, int, boolean) throws java.lang.Exception
{
oadd.org.apache.hadoop.io.retry.RetryPolicies$FailoverOnNetworkExceptionRetry v;
oadd.org.apache.hadoop.io.retry.RetryPolicy v;
boolean v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v;
java.lang.Exception v;
long v, v, v;
int v, v, v, v, v, v, v;
oadd.org.apache.hadoop.io.retry.RetryPolicy$RetryAction v, v, v, v, v, v, v, v, v, v;
java.lang.String v, v;
oadd.org.apache.hadoop.io.retry.RetryPolicy$RetryAction$RetryDecision v, v, v, v, v, v, v, v, v;
oadd.org.apache.hadoop.ipc.RetriableException v;
v := @this: oadd.org.apache.hadoop.io.retry.RetryPolicies$FailoverOnNetworkExceptionRetry;
v := @parameter: java.lang.Exception;
v := @parameter: int;
v := @parameter: int;
v := @parameter: boolean;
v = v.<oadd.org.apache.hadoop.io.retry.RetryPolicies$FailoverOnNetworkExceptionRetry: int maxFailovers>;
if v < v goto label;
v = new oadd.org.apache.hadoop.io.retry.RetryPolicy$RetryAction;
v = <oadd.org.apache.hadoop.io.retry.RetryPolicy$RetryAction$RetryDecision: oadd.org.apache.hadoop.io.retry.RetryPolicy$RetryAction$RetryDecision FAIL>;
v = v.<oadd.org.apache.hadoop.io.retry.RetryPolicies$FailoverOnNetworkExceptionRetry: int maxFailovers>;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (int,int)>(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[])>("failovers (\u) exceeded maximum allowed (\u)");
specialinvoke v.<oadd.org.apache.hadoop.io.retry.RetryPolicy$RetryAction: void <init>(oadd.org.apache.hadoop.io.retry.RetryPolicy$RetryAction$RetryDecision,long,java.lang.String)>(v, 0L, v);
return v;
label:
v = v - v;
v = v.<oadd.org.apache.hadoop.io.retry.RetryPolicies$FailoverOnNetworkExceptionRetry: int maxRetries>;
if v <= v goto label;
v = new oadd.org.apache.hadoop.io.retry.RetryPolicy$RetryAction;
v = <oadd.org.apache.hadoop.io.retry.RetryPolicy$RetryAction$RetryDecision: oadd.org.apache.hadoop.io.retry.RetryPolicy$RetryAction$RetryDecision FAIL>;
v = v.<oadd.org.apache.hadoop.io.retry.RetryPolicies$FailoverOnNetworkExceptionRetry: int maxRetries>;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (int,int)>(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[])>("retries (\u) exceeded maximum allowed (\u)");
specialinvoke v.<oadd.org.apache.hadoop.io.retry.RetryPolicy$RetryAction: void <init>(oadd.org.apache.hadoop.io.retry.RetryPolicy$RetryAction$RetryDecision,long,java.lang.String)>(v, 0L, v);
return v;
label:
v = staticinvoke <oadd.org.apache.hadoop.io.retry.RetryPolicies: boolean isSaslFailure(java.lang.Exception)>(v);
if v == 0 goto label;
v = new oadd.org.apache.hadoop.io.retry.RetryPolicy$RetryAction;
v = <oadd.org.apache.hadoop.io.retry.RetryPolicy$RetryAction$RetryDecision: oadd.org.apache.hadoop.io.retry.RetryPolicy$RetryAction$RetryDecision FAIL>;
specialinvoke v.<oadd.org.apache.hadoop.io.retry.RetryPolicy$RetryAction: void <init>(oadd.org.apache.hadoop.io.retry.RetryPolicy$RetryAction$RetryDecision,long,java.lang.String)>(v, 0L, "SASL failure");
return v;
label:
v = v instanceof java.net.ConnectException;
if v != 0 goto label;
v = v instanceof java.io.EOFException;
if v != 0 goto label;
v = v instanceof java.net.NoRouteToHostException;
if v != 0 goto label;
v = v instanceof java.net.UnknownHostException;
if v != 0 goto label;
v = v instanceof oadd.org.apache.hadoop.ipc.StandbyException;
if v != 0 goto label;
v = v instanceof oadd.org.apache.hadoop.net.ConnectTimeoutException;
if v != 0 goto label;
v = staticinvoke <oadd.org.apache.hadoop.io.retry.RetryPolicies: boolean shouldFailoverOnException(java.lang.Exception)>(v);
if v == 0 goto label;
label:
v = new oadd.org.apache.hadoop.io.retry.RetryPolicy$RetryAction;
v = <oadd.org.apache.hadoop.io.retry.RetryPolicy$RetryAction$RetryDecision: oadd.org.apache.hadoop.io.retry.RetryPolicy$RetryAction$RetryDecision FAILOVER_AND_RETRY>;
v = specialinvoke v.<oadd.org.apache.hadoop.io.retry.RetryPolicies$FailoverOnNetworkExceptionRetry: long getFailoverOrRetrySleepTime(int)>(v);
specialinvoke v.<oadd.org.apache.hadoop.io.retry.RetryPolicy$RetryAction: void <init>(oadd.org.apache.hadoop.io.retry.RetryPolicy$RetryAction$RetryDecision,long)>(v, v);
return v;
label:
v = v instanceof oadd.org.apache.hadoop.ipc.RetriableException;
if v != 0 goto label;
v = staticinvoke <oadd.org.apache.hadoop.io.retry.RetryPolicies: oadd.org.apache.hadoop.ipc.RetriableException getWrappedRetriableException(java.lang.Exception)>(v);
if v == null goto label;
label:
v = new oadd.org.apache.hadoop.io.retry.RetryPolicy$RetryAction;
v = <oadd.org.apache.hadoop.io.retry.RetryPolicy$RetryAction$RetryDecision: oadd.org.apache.hadoop.io.retry.RetryPolicy$RetryAction$RetryDecision RETRY>;
v = specialinvoke v.<oadd.org.apache.hadoop.io.retry.RetryPolicies$FailoverOnNetworkExceptionRetry: long getFailoverOrRetrySleepTime(int)>(v);
specialinvoke v.<oadd.org.apache.hadoop.io.retry.RetryPolicy$RetryAction: void <init>(oadd.org.apache.hadoop.io.retry.RetryPolicy$RetryAction$RetryDecision,long)>(v, v);
return v;
label:
v = v instanceof oadd.org.apache.hadoop.security.token.SecretManager$InvalidToken;
if v == 0 goto label;
v = new oadd.org.apache.hadoop.io.retry.RetryPolicy$RetryAction;
v = <oadd.org.apache.hadoop.io.retry.RetryPolicy$RetryAction$RetryDecision: oadd.org.apache.hadoop.io.retry.RetryPolicy$RetryAction$RetryDecision FAIL>;
specialinvoke v.<oadd.org.apache.hadoop.io.retry.RetryPolicy$RetryAction: void <init>(oadd.org.apache.hadoop.io.retry.RetryPolicy$RetryAction$RetryDecision,long,java.lang.String)>(v, 0L, "Invalid or Cancelled Token");
return v;
label:
v = v instanceof oadd.org.apache.hadoop.security.AccessControlException;
if v != 0 goto label;
v = staticinvoke <oadd.org.apache.hadoop.io.retry.RetryPolicies: boolean hasWrappedAccessControlException(java.lang.Exception)>(v);
if v == 0 goto label;
label:
v = new oadd.org.apache.hadoop.io.retry.RetryPolicy$RetryAction;
v = <oadd.org.apache.hadoop.io.retry.RetryPolicy$RetryAction$RetryDecision: oadd.org.apache.hadoop.io.retry.RetryPolicy$RetryAction$RetryDecision FAIL>;
specialinvoke v.<oadd.org.apache.hadoop.io.retry.RetryPolicy$RetryAction: void <init>(oadd.org.apache.hadoop.io.retry.RetryPolicy$RetryAction$RetryDecision,long,java.lang.String)>(v, 0L, "Access denied");
return v;
label:
v = v instanceof java.net.SocketException;
if v != 0 goto label;
v = v instanceof java.io.IOException;
if v == 0 goto label;
v = v instanceof oadd.org.apache.hadoop.ipc.RemoteException;
if v != 0 goto label;
label:
if v == 0 goto label;
v = new oadd.org.apache.hadoop.io.retry.RetryPolicy$RetryAction;
v = <oadd.org.apache.hadoop.io.retry.RetryPolicy$RetryAction$RetryDecision: oadd.org.apache.hadoop.io.retry.RetryPolicy$RetryAction$RetryDecision FAILOVER_AND_RETRY>;
v = specialinvoke v.<oadd.org.apache.hadoop.io.retry.RetryPolicies$FailoverOnNetworkExceptionRetry: long getFailoverOrRetrySleepTime(int)>(v);
specialinvoke v.<oadd.org.apache.hadoop.io.retry.RetryPolicy$RetryAction: void <init>(oadd.org.apache.hadoop.io.retry.RetryPolicy$RetryAction$RetryDecision,long)>(v, v);
return v;
label:
v = new oadd.org.apache.hadoop.io.retry.RetryPolicy$RetryAction;
v = <oadd.org.apache.hadoop.io.retry.RetryPolicy$RetryAction$RetryDecision: oadd.org.apache.hadoop.io.retry.RetryPolicy$RetryAction$RetryDecision FAIL>;
specialinvoke v.<oadd.org.apache.hadoop.io.retry.RetryPolicy$RetryAction: void <init>(oadd.org.apache.hadoop.io.retry.RetryPolicy$RetryAction$RetryDecision,long,java.lang.String)>(v, 0L, "the invoked method is not idempotent, and unable to determine whether it was invoked");
return v;
label:
v = v.<oadd.org.apache.hadoop.io.retry.RetryPolicies$FailoverOnNetworkExceptionRetry: oadd.org.apache.hadoop.io.retry.RetryPolicy fallbackPolicy>;
v = interfaceinvoke v.<oadd.org.apache.hadoop.io.retry.RetryPolicy: oadd.org.apache.hadoop.io.retry.RetryPolicy$RetryAction shouldRetry(java.lang.Exception,int,int,boolean)>(v, v, v, v);
return v;
}
}