class org.apache.hive.kudu.org.apache.kudu.client.RpcProxy extends java.lang.Object
{
private static final org.slf4j.Logger LOG;
private static int staticNumFail;
private static java.lang.Exception staticException;
private final org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient client;
private final org.apache.hive.kudu.org.apache.kudu.client.Connection connection;
void <init>(org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient, org.apache.hive.kudu.org.apache.kudu.client.Connection)
{
org.apache.hive.kudu.org.apache.kudu.client.Connection v;
org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient v;
java.lang.Object v, v;
org.apache.hive.kudu.org.apache.kudu.client.RpcProxy v;
v := @this: org.apache.hive.kudu.org.apache.kudu.client.RpcProxy;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.client.Connection;
specialinvoke v.<java.lang.Object: void <init>()>();
v = staticinvoke <org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.base.Preconditions: java.lang.Object checkNotNull(java.lang.Object)>(v);
v.<org.apache.hive.kudu.org.apache.kudu.client.RpcProxy: org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient client> = v;
v = staticinvoke <org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.base.Preconditions: java.lang.Object checkNotNull(java.lang.Object)>(v);
v.<org.apache.hive.kudu.org.apache.kudu.client.RpcProxy: org.apache.hive.kudu.org.apache.kudu.client.Connection connection> = v;
return;
}
static void failNextRpcs(int, java.lang.Exception)
{
int v;
java.lang.Exception v;
v := @parameter: int;
v := @parameter: java.lang.Exception;
staticinvoke <org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.base.Preconditions: java.lang.Object checkNotNull(java.lang.Object)>(v);
<org.apache.hive.kudu.org.apache.kudu.client.RpcProxy: int staticNumFail> = v;
<org.apache.hive.kudu.org.apache.kudu.client.RpcProxy: java.lang.Exception staticException> = v;
return;
}
void sendRpc(org.apache.hive.kudu.org.apache.kudu.client.KuduRpc)
{
org.apache.hive.kudu.org.apache.kudu.client.Connection v;
org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient v;
org.apache.hive.kudu.org.apache.kudu.client.RpcProxy v;
org.apache.hive.kudu.org.apache.kudu.client.KuduRpc v;
v := @this: org.apache.hive.kudu.org.apache.kudu.client.RpcProxy;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.client.KuduRpc;
v = v.<org.apache.hive.kudu.org.apache.kudu.client.RpcProxy: org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient client>;
v = v.<org.apache.hive.kudu.org.apache.kudu.client.RpcProxy: org.apache.hive.kudu.org.apache.kudu.client.Connection connection>;
staticinvoke <org.apache.hive.kudu.org.apache.kudu.client.RpcProxy: void sendRpc(org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient,org.apache.hive.kudu.org.apache.kudu.client.Connection,org.apache.hive.kudu.org.apache.kudu.client.KuduRpc)>(v, v, v);
return;
}
static void sendRpc(org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient, org.apache.hive.kudu.org.apache.kudu.client.Connection, org.apache.hive.kudu.org.apache.kudu.client.KuduRpc)
{
org.apache.hive.kudu.org.apache.kudu.client.ServerInfo v;
org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient v;
org.apache.hive.kudu.org.apache.kudu.client.KuduRpc 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.client.RpcOutboundMessage v;
int v, v, v;
java.lang.String v, v;
org.apache.hive.kudu.org.apache.kudu.client.NonRecoverableException v;
boolean v, v, v;
org.apache.hive.kudu.org.apache.kudu.client.RpcProxy$1 v;
org.apache.hive.kudu.org.apache.kudu.rpc.RpcHeader$RpcFeatureFlag v;
org.slf4j.Logger v;
java.util.Collection v;
java.util.Set v;
org.apache.hive.kudu.org.apache.kudu.client.Status v;
java.lang.Exception v, v;
org.apache.hive.kudu.org.apache.kudu.client.RecoverableException v;
org.apache.hive.kudu.org.apache.kudu.client.Connection v;
org.apache.hive.kudu.org.apache.kudu.client.RpcTraceFrame$Action v;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.client.Connection;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.client.KuduRpc;
label:
v = <org.apache.hive.kudu.org.apache.kudu.client.RpcProxy: int staticNumFail>;
if v <= 0 goto label;
v = <org.apache.hive.kudu.org.apache.kudu.client.RpcProxy: int staticNumFail>;
v = v - 1;
<org.apache.hive.kudu.org.apache.kudu.client.RpcProxy: int staticNumFail> = v;
v = <org.apache.hive.kudu.org.apache.kudu.client.RpcProxy: org.slf4j.Logger LOG>;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (org.apache.hive.kudu.org.apache.kudu.client.KuduRpc)>(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[])>("Forcing a failure on sendRpc: \u0001");
interfaceinvoke v.<org.slf4j.Logger: void warn(java.lang.String)>(v);
v = <org.apache.hive.kudu.org.apache.kudu.client.RpcProxy: java.lang.Exception staticException>;
throw v;
label:
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.client.KuduRpc: java.util.Collection getRequiredFeatures()>();
v = interfaceinvoke v.<java.util.Collection: boolean isEmpty()>();
if v != 0 goto label;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.client.Connection: java.util.Set getPeerFeatures()>();
if v == null goto label;
v = <org.apache.hive.kudu.org.apache.kudu.rpc.RpcHeader$RpcFeatureFlag: org.apache.hive.kudu.org.apache.kudu.rpc.RpcHeader$RpcFeatureFlag APPLICATION_FEATURE_FLAGS>;
v = interfaceinvoke v.<java.util.Set: boolean contains(java.lang.Object)>(v);
if v != 0 goto label;
v = new org.apache.hive.kudu.org.apache.kudu.client.NonRecoverableException;
v = staticinvoke <org.apache.hive.kudu.org.apache.kudu.client.Status: org.apache.hive.kudu.org.apache.kudu.client.Status NotSupported(java.lang.String)>("the server does not support the APPLICATION_FEATURE_FLAGS RPC feature");
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.client.NonRecoverableException: void <init>(org.apache.hive.kudu.org.apache.kudu.client.Status)>(v);
throw v;
label:
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.client.KuduRpc: boolean hasDeferred()>();
staticinvoke <org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.base.Preconditions: void checkArgument(boolean)>(v);
v = new org.apache.hive.kudu.org.apache.kudu.client.RpcTraceFrame$RpcTraceFrameBuilder;
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 SEND_TO_SERVER>;
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.Connection: org.apache.hive.kudu.org.apache.kudu.client.ServerInfo getServerInfo()>();
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.client.RpcTraceFrame$RpcTraceFrameBuilder: org.apache.hive.kudu.org.apache.kudu.client.RpcTraceFrame$RpcTraceFrameBuilder serverInfo(org.apache.hive.kudu.org.apache.kudu.client.ServerInfo)>(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 = staticinvoke <org.apache.hive.kudu.org.apache.kudu.client.RpcProxy: org.apache.hive.kudu.org.apache.kudu.client.RpcOutboundMessage rpcToMessage(org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient,org.apache.hive.kudu.org.apache.kudu.client.KuduRpc)>(v, v);
v = new org.apache.hive.kudu.org.apache.kudu.client.RpcProxy$1;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.client.RpcProxy$1: void <init>(org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient,org.apache.hive.kudu.org.apache.kudu.client.Connection,org.apache.hive.kudu.org.apache.kudu.client.KuduRpc)>(v, v, v);
virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.client.Connection: void enqueueMessage(org.apache.hive.kudu.org.apache.kudu.client.RpcOutboundMessage,org.apache.hive.kudu.com.stumbleupon.async.Callback)>(v, v);
label:
goto label;
label:
v := @caughtexception;
virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient: void handleRetryableError(org.apache.hive.kudu.org.apache.kudu.client.KuduRpc,org.apache.hive.kudu.org.apache.kudu.client.KuduException)>(v, v);
goto label;
label:
v := @caughtexception;
virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.client.KuduRpc: void errback(java.lang.Exception)>(v);
label:
return;
catch org.apache.hive.kudu.org.apache.kudu.client.RecoverableException from label to label with label;
catch java.lang.Exception from label to label with label;
}
private static org.apache.hive.kudu.org.apache.kudu.client.RpcOutboundMessage rpcToMessage(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.client.AsyncKuduClient v;
org.apache.hive.kudu.org.apache.kudu.rpc.RpcHeader$RequestHeader$Builder v, v, v;
long v, v, v, v, v;
org.apache.hive.kudu.org.apache.kudu.client.KuduRpc v;
org.apache.hive.kudu.org.apache.kudu.client.KuduTable v;
byte v;
org.apache.hive.kudu.org.apache.kudu.client.RpcOutboundMessage v;
int v;
org.apache.hive.kudu.org.apache.kudu.shaded.com.google.protobuf.Message v;
java.lang.String v, v, v, v;
org.apache.hive.kudu.org.apache.kudu.rpc.RpcHeader$RequestIdPB$Builder v;
boolean v, v, v;
org.apache.hive.kudu.org.apache.kudu.rpc.RpcHeader$RemoteMethodPB$Builder v, v, v;
java.util.Collection v;
org.apache.hive.kudu.org.apache.kudu.client.TimeoutTracker v, v;
org.apache.hive.kudu.org.apache.kudu.security.Token$SignedTokenPB v;
org.apache.hive.kudu.org.apache.kudu.client.RequestTracker v;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.client.KuduRpc;
v = staticinvoke <org.apache.hive.kudu.org.apache.kudu.rpc.RpcHeader$RequestHeader: org.apache.hive.kudu.org.apache.kudu.rpc.RpcHeader$RequestHeader$Builder newBuilder()>();
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.client.KuduRpc: java.util.Collection getRequiredFeatures()>();
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.rpc.RpcHeader$RequestHeader$Builder: org.apache.hive.kudu.org.apache.kudu.rpc.RpcHeader$RequestHeader$Builder addAllRequiredFeatureFlags(java.lang.Iterable)>(v);
v = staticinvoke <org.apache.hive.kudu.org.apache.kudu.rpc.RpcHeader$RemoteMethodPB: org.apache.hive.kudu.org.apache.kudu.rpc.RpcHeader$RemoteMethodPB$Builder newBuilder()>();
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.client.KuduRpc: java.lang.String serviceName()>();
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.rpc.RpcHeader$RemoteMethodPB$Builder: org.apache.hive.kudu.org.apache.kudu.rpc.RpcHeader$RemoteMethodPB$Builder setServiceName(java.lang.String)>(v);
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.client.KuduRpc: java.lang.String method()>();
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.rpc.RpcHeader$RemoteMethodPB$Builder: org.apache.hive.kudu.org.apache.kudu.rpc.RpcHeader$RemoteMethodPB$Builder setMethodName(java.lang.String)>(v);
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.rpc.RpcHeader$RequestHeader$Builder: org.apache.hive.kudu.org.apache.kudu.rpc.RpcHeader$RequestHeader$Builder setRemoteMethod(org.apache.hive.kudu.org.apache.kudu.rpc.RpcHeader$RemoteMethodPB$Builder)>(v);
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.client.KuduRpc: boolean needsAuthzToken()>();
if v == 0 goto label;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.client.KuduRpc: org.apache.hive.kudu.org.apache.kudu.client.KuduTable getTable()>();
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.client.KuduTable: java.lang.String getTableId()>();
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient: org.apache.hive.kudu.org.apache.kudu.security.Token$SignedTokenPB getAuthzToken(java.lang.String)>(v);
virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.client.KuduRpc: void bindAuthzToken(org.apache.hive.kudu.org.apache.kudu.security.Token$SignedTokenPB)>(v);
label:
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.client.KuduRpc: org.apache.hive.kudu.org.apache.kudu.shaded.com.google.protobuf.Message createRequestPB()>();
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 hasTimeout()>();
if v == 0 goto label;
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: long getMillisBeforeTimeout()>();
virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.rpc.RpcHeader$RequestHeader$Builder: org.apache.hive.kudu.org.apache.kudu.rpc.RpcHeader$RequestHeader$Builder setTimeoutMillis(int)>(v);
label:
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.client.KuduRpc: boolean isRequestTracked()>();
if v == 0 goto label;
v = staticinvoke <org.apache.hive.kudu.org.apache.kudu.rpc.RpcHeader$RequestIdPB: org.apache.hive.kudu.org.apache.kudu.rpc.RpcHeader$RequestIdPB$Builder newBuilder()>();
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient: org.apache.hive.kudu.org.apache.kudu.client.RequestTracker getRequestTracker()>();
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.client.KuduRpc: long getSequenceId()>();
v = v cmp -1L;
if v != 0 goto label;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.client.RequestTracker: long newSeqNo()>();
virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.client.KuduRpc: void setSequenceId(long)>(v);
label:
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.client.RequestTracker: java.lang.String getClientId()>();
virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.rpc.RpcHeader$RequestIdPB$Builder: org.apache.hive.kudu.org.apache.kudu.rpc.RpcHeader$RequestIdPB$Builder setClientId(java.lang.String)>(v);
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.client.KuduRpc: long getSequenceId()>();
virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.rpc.RpcHeader$RequestIdPB$Builder: org.apache.hive.kudu.org.apache.kudu.rpc.RpcHeader$RequestIdPB$Builder setSeqNo(long)>(v);
v = v.<org.apache.hive.kudu.org.apache.kudu.client.KuduRpc: int attempt>;
virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.rpc.RpcHeader$RequestIdPB$Builder: org.apache.hive.kudu.org.apache.kudu.rpc.RpcHeader$RequestIdPB$Builder setAttemptNo(long)>(v);
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.client.RequestTracker: long firstIncomplete()>();
virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.rpc.RpcHeader$RequestIdPB$Builder: org.apache.hive.kudu.org.apache.kudu.rpc.RpcHeader$RequestIdPB$Builder setFirstIncompleteSeqNo(long)>(v);
virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.rpc.RpcHeader$RequestHeader$Builder: org.apache.hive.kudu.org.apache.kudu.rpc.RpcHeader$RequestHeader$Builder setRequestId(org.apache.hive.kudu.org.apache.kudu.rpc.RpcHeader$RequestIdPB$Builder)>(v);
label:
v = new org.apache.hive.kudu.org.apache.kudu.client.RpcOutboundMessage;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.client.RpcOutboundMessage: void <init>(org.apache.hive.kudu.org.apache.kudu.rpc.RpcHeader$RequestHeader$Builder,org.apache.hive.kudu.org.apache.kudu.shaded.com.google.protobuf.Message)>(v, v);
return v;
}
private static void responseReceived(org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient, org.apache.hive.kudu.org.apache.kudu.client.Connection, org.apache.hive.kudu.org.apache.kudu.client.KuduRpc, org.apache.hive.kudu.org.apache.kudu.client.CallResponse, org.apache.hive.kudu.org.apache.kudu.client.KuduException)
{
org.apache.hive.kudu.org.apache.kudu.rpc.RpcHeader$ResponseHeader v, v;
java.lang.Integer v, v, v;
org.apache.hive.kudu.org.apache.kudu.client.RpcTraceFrame v, v, v, v;
java.lang.Long v;
org.apache.hive.kudu.org.apache.kudu.client.RpcTraceFrame$RpcTraceFrameBuilder v, v, v, v, v;
java.lang.Exception v, v;
java.lang.Object[] v, v;
long v, v, v, v;
org.apache.hive.kudu.org.apache.kudu.client.KuduRpc v;
java.lang.String v, v, v, v, v;
org.apache.hive.kudu.org.apache.kudu.client.RpcTraceFrame$Action v;
org.apache.hive.kudu.org.apache.kudu.client.KuduException v, v, v;
org.apache.hive.kudu.org.apache.kudu.client.ServerInfo v, v;
boolean v, v, v, v, v, v, v, v, v, v, v;
org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient v;
org.apache.hive.kudu.org.apache.kudu.client.CallResponse v;
int v, v, v;
org.apache.hive.kudu.org.apache.kudu.util.Pair v;
org.apache.hive.kudu.org.apache.kudu.client.Statistics v, v;
org.slf4j.Logger v, v, v, v, v, v;
org.apache.hive.kudu.org.apache.kudu.client.Status v, v, v;
org.apache.hive.kudu.org.apache.kudu.client.Connection v;
java.lang.Object v, v, v, v, v, v, v;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.client.Connection;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.client.KuduRpc;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.client.CallResponse;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.client.KuduException;
v = staticinvoke <java.lang.System: long nanoTime()>();
v = <org.apache.hive.kudu.org.apache.kudu.client.RpcProxy: org.slf4j.Logger LOG>;
v = interfaceinvoke v.<org.slf4j.Logger: boolean isTraceEnabled()>();
if v == 0 goto label;
if v != null goto label;
v = <org.apache.hive.kudu.org.apache.kudu.client.RpcProxy: org.slf4j.Logger LOG>;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.client.Connection: java.lang.String getLogPrefix()>();
interfaceinvoke v.<org.slf4j.Logger: void trace(java.lang.String,java.lang.Object,java.lang.Object)>("{} received null response for RPC {}", v, v);
goto label;
label:
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.client.CallResponse: org.apache.hive.kudu.org.apache.kudu.rpc.RpcHeader$ResponseHeader getHeader()>();
v = <org.apache.hive.kudu.org.apache.kudu.client.RpcProxy: org.slf4j.Logger LOG>;
v = newarray (java.lang.Object)[4];
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.client.Connection: java.lang.String getLogPrefix()>();
v[0] = v;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.rpc.RpcHeader$ResponseHeader: int getCallId()>();
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
v[1] = v;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.client.CallResponse: int getTotalResponseSize()>();
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
v[2] = v;
v[3] = v;
interfaceinvoke v.<org.slf4j.Logger: void trace(java.lang.String,java.lang.Object[])>("{} received response with rpcId {}, size {} for RPC {}", v);
label:
v = new org.apache.hive.kudu.org.apache.kudu.client.RpcTraceFrame$RpcTraceFrameBuilder;
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 RECEIVE_FROM_SERVER>;
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.Connection: org.apache.hive.kudu.org.apache.kudu.client.ServerInfo getServerInfo()>();
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.client.RpcTraceFrame$RpcTraceFrameBuilder: org.apache.hive.kudu.org.apache.kudu.client.RpcTraceFrame$RpcTraceFrameBuilder serverInfo(org.apache.hive.kudu.org.apache.kudu.client.ServerInfo)>(v);
if v == null goto label;
v = v instanceof org.apache.hive.kudu.org.apache.kudu.client.InvalidAuthnTokenException;
if v == 0 goto label;
virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient: void handleInvalidAuthnToken(org.apache.hive.kudu.org.apache.kudu.client.KuduRpc)>(v);
return;
label:
v = v instanceof org.apache.hive.kudu.org.apache.kudu.client.InvalidAuthzTokenException;
if v == 0 goto label;
virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient: void handleInvalidAuthzToken(org.apache.hive.kudu.org.apache.kudu.client.KuduRpc,org.apache.hive.kudu.org.apache.kudu.client.KuduException)>(v, v);
return;
label:
v = v instanceof org.apache.hive.kudu.org.apache.kudu.client.RecoverableException;
if v == 0 goto label;
staticinvoke <org.apache.hive.kudu.org.apache.kudu.client.RpcProxy: void failOrRetryRpc(org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient,org.apache.hive.kudu.org.apache.kudu.client.Connection,org.apache.hive.kudu.org.apache.kudu.client.KuduRpc,org.apache.hive.kudu.org.apache.kudu.client.RecoverableException)>(v, v, v, v);
return;
label:
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.client.KuduException: 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);
virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.client.KuduRpc: void errback(java.lang.Exception)>(v);
return;
label:
v = null;
v = null;
label:
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.client.Connection: org.apache.hive.kudu.org.apache.kudu.client.ServerInfo getServerInfo()>();
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.client.ServerInfo: java.lang.String getUuid()>();
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.client.KuduRpc: org.apache.hive.kudu.org.apache.kudu.util.Pair deserialize(org.apache.hive.kudu.org.apache.kudu.client.CallResponse,java.lang.String)>(v, v);
label:
goto label;
label:
v := @caughtexception;
v = v;
goto label;
label:
v := @caughtexception;
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);
virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.client.KuduRpc: void errback(java.lang.Exception)>(v);
return;
label:
if v == null goto label;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.util.Pair: java.lang.Object getSecond()>();
v = v instanceof org.apache.hive.kudu.org.apache.kudu.tserver.Tserver$TabletServerErrorPB;
if v == 0 goto label;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.util.Pair: java.lang.Object getSecond()>();
v = staticinvoke <org.apache.hive.kudu.org.apache.kudu.client.RpcProxy: org.apache.hive.kudu.org.apache.kudu.client.KuduException dispatchTSError(org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient,org.apache.hive.kudu.org.apache.kudu.client.Connection,org.apache.hive.kudu.org.apache.kudu.client.KuduRpc,org.apache.hive.kudu.org.apache.kudu.tserver.Tserver$TabletServerErrorPB,org.apache.hive.kudu.org.apache.kudu.client.RpcTraceFrame$RpcTraceFrameBuilder)>(v, v, v, v, v);
if v != null goto label;
return;
label:
v = null;
goto label;
label:
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.util.Pair: java.lang.Object getSecond()>();
v = v instanceof org.apache.hive.kudu.org.apache.kudu.master.Master$MasterErrorPB;
if v == 0 goto label;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.util.Pair: java.lang.Object getSecond()>();
v = staticinvoke <org.apache.hive.kudu.org.apache.kudu.client.RpcProxy: org.apache.hive.kudu.org.apache.kudu.client.KuduException dispatchMasterError(org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient,org.apache.hive.kudu.org.apache.kudu.client.Connection,org.apache.hive.kudu.org.apache.kudu.client.KuduRpc,org.apache.hive.kudu.org.apache.kudu.master.Master$MasterErrorPB,org.apache.hive.kudu.org.apache.kudu.client.RpcTraceFrame$RpcTraceFrameBuilder)>(v, v, v, v, v);
if v != null goto label;
return;
label:
v = null;
label:
if v == null goto label;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.util.Pair: java.lang.Object getFirst()>();
v = v instanceof java.lang.Exception;
if v != 0 goto label;
v = 1;
goto label;
label:
v = 0;
label:
staticinvoke <org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.base.Preconditions: void checkState(boolean)>(v);
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient: boolean isStatisticsEnabled()>();
if v == 0 goto label;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient: org.apache.hive.kudu.org.apache.kudu.client.Statistics getStatistics()>();
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.util.Pair: java.lang.Object getFirst()>();
virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.client.KuduRpc: void updateStatistics(org.apache.hive.kudu.org.apache.kudu.client.Statistics,java.lang.Object)>(v, v);
label:
v = staticinvoke <org.apache.hive.kudu.org.apache.kudu.client.Status: org.apache.hive.kudu.org.apache.kudu.client.Status OK()>();
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 = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.util.Pair: java.lang.Object getFirst()>();
virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.client.KuduRpc: void callback(java.lang.Object)>(v);
goto label;
label:
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient: boolean isStatisticsEnabled()>();
if v == 0 goto label;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient: org.apache.hive.kudu.org.apache.kudu.client.Statistics getStatistics()>();
virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.client.KuduRpc: void updateStatistics(org.apache.hive.kudu.org.apache.kudu.client.Statistics,java.lang.Object)>(v, null);
label:
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.client.KuduException: 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);
virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.client.KuduRpc: void errback(java.lang.Exception)>(v);
label:
goto label;
label:
v := @caughtexception;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.client.CallResponse: org.apache.hive.kudu.org.apache.kudu.rpc.RpcHeader$ResponseHeader getHeader()>();
staticinvoke <org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.base.Preconditions: java.lang.Object checkNotNull(java.lang.Object)>(v);
v = <org.apache.hive.kudu.org.apache.kudu.client.RpcProxy: org.slf4j.Logger LOG>;
v = newarray (java.lang.Object)[4];
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.client.Connection: java.lang.String getLogPrefix()>();
v[0] = v;
v[1] = v;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.rpc.RpcHeader$ResponseHeader: int getCallId()>();
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
v[2] = v;
v[3] = v;
interfaceinvoke v.<org.slf4j.Logger: void debug(java.lang.String,java.lang.Object[])>("{} unexpected exception {} while handling call: callId {}, RPC {}", v);
label:
v = <org.apache.hive.kudu.org.apache.kudu.client.RpcProxy: org.slf4j.Logger LOG>;
v = interfaceinvoke v.<org.slf4j.Logger: boolean isTraceEnabled()>();
if v == 0 goto label;
v = <org.apache.hive.kudu.org.apache.kudu.client.RpcProxy: org.slf4j.Logger LOG>;
v = staticinvoke <java.lang.System: long nanoTime()>();
v = v - v;
v = v / 1000L;
v = staticinvoke <java.lang.Long: java.lang.Long valueOf(long)>(v);
interfaceinvoke v.<org.slf4j.Logger: void trace(java.lang.String,java.lang.Object)>("------------------<< LEAVING  DECODE <<------------------ time elapsed: {} us", v);
label:
return;
catch org.apache.hive.kudu.org.apache.kudu.client.KuduException from label to label with label;
catch java.lang.Exception from label to label with label;
catch java.lang.Exception from label to label with label;
}
private static org.apache.hive.kudu.org.apache.kudu.client.KuduException dispatchTSError(org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient, org.apache.hive.kudu.org.apache.kudu.client.Connection, org.apache.hive.kudu.org.apache.kudu.client.KuduRpc, org.apache.hive.kudu.org.apache.kudu.tserver.Tserver$TabletServerErrorPB, org.apache.hive.kudu.org.apache.kudu.client.RpcTraceFrame$RpcTraceFrameBuilder)
{
org.apache.hive.kudu.org.apache.kudu.client.ServerInfo v, v;
org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient v;
org.apache.hive.kudu.org.apache.kudu.WireProtocol$AppStatusPB v;
org.apache.hive.kudu.org.apache.kudu.client.KuduRpc 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.client.NonRecoverableException v;
org.apache.hive.kudu.org.apache.kudu.client.Status v;
org.apache.hive.kudu.org.apache.kudu.WireProtocol$AppStatusPB$ErrorCode v, v, v, v;
org.apache.hive.kudu.org.apache.kudu.client.RecoverableException v, v, v;
org.apache.hive.kudu.org.apache.kudu.client.Connection v;
org.apache.hive.kudu.org.apache.kudu.tserver.Tserver$TabletServerErrorPB$Code v, v, v;
org.apache.hive.kudu.org.apache.kudu.tserver.Tserver$TabletServerErrorPB v;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.client.Connection;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.client.KuduRpc;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.tserver.Tserver$TabletServerErrorPB;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.client.RpcTraceFrame$RpcTraceFrameBuilder;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.tserver.Tserver$TabletServerErrorPB: org.apache.hive.kudu.org.apache.kudu.tserver.Tserver$TabletServerErrorPB$Code getCode()>();
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.tserver.Tserver$TabletServerErrorPB: org.apache.hive.kudu.org.apache.kudu.WireProtocol$AppStatusPB getStatus()>();
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.WireProtocol$AppStatusPB: org.apache.hive.kudu.org.apache.kudu.WireProtocol$AppStatusPB$ErrorCode getCode()>();
v = staticinvoke <org.apache.hive.kudu.org.apache.kudu.client.Status: org.apache.hive.kudu.org.apache.kudu.client.Status fromTabletServerErrorPB(org.apache.hive.kudu.org.apache.kudu.tserver.Tserver$TabletServerErrorPB)>(v);
v = <org.apache.hive.kudu.org.apache.kudu.tserver.Tserver$TabletServerErrorPB$Code: org.apache.hive.kudu.org.apache.kudu.tserver.Tserver$TabletServerErrorPB$Code TABLET_NOT_FOUND>;
if v != v goto label;
v = new org.apache.hive.kudu.org.apache.kudu.client.RecoverableException;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.client.RecoverableException: void <init>(org.apache.hive.kudu.org.apache.kudu.client.Status)>(v);
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.client.Connection: org.apache.hive.kudu.org.apache.kudu.client.ServerInfo getServerInfo()>();
virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient: void handleTabletNotFound(org.apache.hive.kudu.org.apache.kudu.client.KuduRpc,org.apache.hive.kudu.org.apache.kudu.client.KuduException,org.apache.hive.kudu.org.apache.kudu.client.ServerInfo)>(v, v, v);
goto label;
label:
v = <org.apache.hive.kudu.org.apache.kudu.tserver.Tserver$TabletServerErrorPB$Code: org.apache.hive.kudu.org.apache.kudu.tserver.Tserver$TabletServerErrorPB$Code TABLET_NOT_RUNNING>;
if v == v goto label;
v = <org.apache.hive.kudu.org.apache.kudu.WireProtocol$AppStatusPB$ErrorCode: org.apache.hive.kudu.org.apache.kudu.WireProtocol$AppStatusPB$ErrorCode SERVICE_UNAVAILABLE>;
if v != v goto label;
label:
v = new org.apache.hive.kudu.org.apache.kudu.client.RecoverableException;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.client.RecoverableException: void <init>(org.apache.hive.kudu.org.apache.kudu.client.Status)>(v);
virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient: void handleRetryableError(org.apache.hive.kudu.org.apache.kudu.client.KuduRpc,org.apache.hive.kudu.org.apache.kudu.client.KuduException)>(v, v);
goto label;
label:
v = <org.apache.hive.kudu.org.apache.kudu.WireProtocol$AppStatusPB$ErrorCode: org.apache.hive.kudu.org.apache.kudu.WireProtocol$AppStatusPB$ErrorCode ILLEGAL_STATE>;
if v == v goto label;
v = <org.apache.hive.kudu.org.apache.kudu.WireProtocol$AppStatusPB$ErrorCode: org.apache.hive.kudu.org.apache.kudu.WireProtocol$AppStatusPB$ErrorCode ABORTED>;
if v != v goto label;
label:
v = new org.apache.hive.kudu.org.apache.kudu.client.RecoverableException;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.client.RecoverableException: void <init>(org.apache.hive.kudu.org.apache.kudu.client.Status)>(v);
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.client.Connection: org.apache.hive.kudu.org.apache.kudu.client.ServerInfo getServerInfo()>();
virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient: void handleNotLeader(org.apache.hive.kudu.org.apache.kudu.client.KuduRpc,org.apache.hive.kudu.org.apache.kudu.client.KuduException,org.apache.hive.kudu.org.apache.kudu.client.ServerInfo)>(v, v, v);
goto label;
label:
v = new org.apache.hive.kudu.org.apache.kudu.client.NonRecoverableException;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.client.NonRecoverableException: void <init>(org.apache.hive.kudu.org.apache.kudu.client.Status)>(v);
return v;
label:
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);
return null;
}
private static org.apache.hive.kudu.org.apache.kudu.client.KuduException dispatchMasterError(org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient, org.apache.hive.kudu.org.apache.kudu.client.Connection, org.apache.hive.kudu.org.apache.kudu.client.KuduRpc, org.apache.hive.kudu.org.apache.kudu.master.Master$MasterErrorPB, org.apache.hive.kudu.org.apache.kudu.client.RpcTraceFrame$RpcTraceFrameBuilder)
{
org.apache.hive.kudu.org.apache.kudu.client.ServerInfo v;
org.apache.hive.kudu.org.apache.kudu.master.Master$MasterErrorPB$Code v, v;
org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient v;
org.apache.hive.kudu.org.apache.kudu.WireProtocol$AppStatusPB v;
org.apache.hive.kudu.org.apache.kudu.client.KuduRpc v;
org.apache.hive.kudu.org.apache.kudu.master.Master$MasterErrorPB 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.client.NonRecoverableException v;
boolean v;
org.apache.hive.kudu.org.apache.kudu.client.Status v;
org.apache.hive.kudu.org.apache.kudu.WireProtocol$AppStatusPB$ErrorCode v, v;
org.apache.hive.kudu.org.apache.kudu.client.RecoverableException v, v, v;
org.apache.hive.kudu.org.apache.kudu.client.Connection v;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.client.Connection;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.client.KuduRpc;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.master.Master$MasterErrorPB;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.client.RpcTraceFrame$RpcTraceFrameBuilder;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.master.Master$MasterErrorPB: org.apache.hive.kudu.org.apache.kudu.WireProtocol$AppStatusPB getStatus()>();
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.WireProtocol$AppStatusPB: org.apache.hive.kudu.org.apache.kudu.WireProtocol$AppStatusPB$ErrorCode getCode()>();
v = staticinvoke <org.apache.hive.kudu.org.apache.kudu.client.Status: org.apache.hive.kudu.org.apache.kudu.client.Status fromMasterErrorPB(org.apache.hive.kudu.org.apache.kudu.master.Master$MasterErrorPB)>(v);
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.master.Master$MasterErrorPB: org.apache.hive.kudu.org.apache.kudu.master.Master$MasterErrorPB$Code getCode()>();
v = <org.apache.hive.kudu.org.apache.kudu.master.Master$MasterErrorPB$Code: org.apache.hive.kudu.org.apache.kudu.master.Master$MasterErrorPB$Code NOT_THE_LEADER>;
if v != v goto label;
v = new org.apache.hive.kudu.org.apache.kudu.client.RecoverableException;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.client.RecoverableException: void <init>(org.apache.hive.kudu.org.apache.kudu.client.Status)>(v);
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.client.Connection: org.apache.hive.kudu.org.apache.kudu.client.ServerInfo getServerInfo()>();
virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient: void handleNotLeader(org.apache.hive.kudu.org.apache.kudu.client.KuduRpc,org.apache.hive.kudu.org.apache.kudu.client.KuduException,org.apache.hive.kudu.org.apache.kudu.client.ServerInfo)>(v, v, v);
goto label;
label:
v = <org.apache.hive.kudu.org.apache.kudu.WireProtocol$AppStatusPB$ErrorCode: org.apache.hive.kudu.org.apache.kudu.WireProtocol$AppStatusPB$ErrorCode SERVICE_UNAVAILABLE>;
if v != v goto label;
v = v instanceof org.apache.hive.kudu.org.apache.kudu.client.ConnectToMasterRequest;
if v == 0 goto label;
v = new org.apache.hive.kudu.org.apache.kudu.client.RecoverableException;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.client.RecoverableException: void <init>(org.apache.hive.kudu.org.apache.kudu.client.Status)>(v);
return v;
label:
v = new org.apache.hive.kudu.org.apache.kudu.client.RecoverableException;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.client.RecoverableException: void <init>(org.apache.hive.kudu.org.apache.kudu.client.Status)>(v);
virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient: void handleRetryableError(org.apache.hive.kudu.org.apache.kudu.client.KuduRpc,org.apache.hive.kudu.org.apache.kudu.client.KuduException)>(v, v);
goto label;
label:
v = new org.apache.hive.kudu.org.apache.kudu.client.NonRecoverableException;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.client.NonRecoverableException: void <init>(org.apache.hive.kudu.org.apache.kudu.client.Status)>(v);
return v;
label:
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);
return null;
}
private static void failOrRetryRpc(org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient, org.apache.hive.kudu.org.apache.kudu.client.Connection, org.apache.hive.kudu.org.apache.kudu.client.KuduRpc, org.apache.hive.kudu.org.apache.kudu.client.RecoverableException)
{
org.apache.hive.kudu.org.apache.kudu.client.ServerInfo v, v;
org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient v;
org.apache.hive.kudu.org.apache.kudu.client.KuduRpc v;
org.apache.hive.kudu.org.apache.kudu.client.RpcTraceFrame v;
org.apache.hive.kudu.org.apache.kudu.client.RpcTraceFrame$RpcTraceFrameBuilder v, v, v;
java.lang.String v;
boolean v, v, v;
org.apache.hive.kudu.org.apache.kudu.client.Status v, v;
org.apache.hive.kudu.org.apache.kudu.client.RecoverableException v;
org.apache.hive.kudu.org.apache.kudu.client.Connection v;
org.apache.hive.kudu.org.apache.kudu.client.RemoteTablet v;
org.apache.hive.kudu.org.apache.kudu.client.RpcTraceFrame$Action v;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.client.Connection;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.client.KuduRpc;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.client.RecoverableException;
v = new org.apache.hive.kudu.org.apache.kudu.client.RpcTraceFrame$RpcTraceFrameBuilder;
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 RECEIVE_FROM_SERVER>;
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.Connection: org.apache.hive.kudu.org.apache.kudu.client.ServerInfo getServerInfo()>();
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.client.RpcTraceFrame$RpcTraceFrameBuilder: org.apache.hive.kudu.org.apache.kudu.client.RpcTraceFrame$RpcTraceFrameBuilder serverInfo(org.apache.hive.kudu.org.apache.kudu.client.ServerInfo)>(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 = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.client.KuduRpc: org.apache.hive.kudu.org.apache.kudu.client.RemoteTablet getTablet()>();
if v != null goto label;
virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.client.KuduRpc: void errback(java.lang.Exception)>(v);
return;
label:
v = v instanceof org.apache.hive.kudu.org.apache.kudu.client.InvalidAuthnTokenException;
if v == 0 goto label;
virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient: void handleInvalidAuthnToken(org.apache.hive.kudu.org.apache.kudu.client.KuduRpc)>(v);
goto label;
label:
v = v instanceof org.apache.hive.kudu.org.apache.kudu.client.InvalidAuthzTokenException;
if v == 0 goto label;
virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient: void handleInvalidAuthzToken(org.apache.hive.kudu.org.apache.kudu.client.KuduRpc,org.apache.hive.kudu.org.apache.kudu.client.KuduException)>(v, v);
goto label;
label:
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.Status: boolean isServiceUnavailable()>();
if v == 0 goto label;
virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient: void handleRetryableError(org.apache.hive.kudu.org.apache.kudu.client.KuduRpc,org.apache.hive.kudu.org.apache.kudu.client.KuduException)>(v, v);
goto label;
label:
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.client.Connection: org.apache.hive.kudu.org.apache.kudu.client.ServerInfo getServerInfo()>();
virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient: void handleTabletNotFound(org.apache.hive.kudu.org.apache.kudu.client.KuduRpc,org.apache.hive.kudu.org.apache.kudu.client.KuduException,org.apache.hive.kudu.org.apache.kudu.client.ServerInfo)>(v, v, v);
label:
return;
}
public java.lang.String toString()
{
org.apache.hive.kudu.org.apache.kudu.client.Connection v;
int v;
org.apache.hive.kudu.org.apache.kudu.client.RpcProxy v;
java.lang.String v;
v := @this: org.apache.hive.kudu.org.apache.kudu.client.RpcProxy;
v = virtualinvoke v.<java.lang.Object: int hashCode()>();
v = v.<org.apache.hive.kudu.org.apache.kudu.client.RpcProxy: org.apache.hive.kudu.org.apache.kudu.client.Connection connection>;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (int,org.apache.hive.kudu.org.apache.kudu.client.Connection)>(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[])>("RpcProxy@\u, connection=\u0001");
return v;
}
org.apache.hive.kudu.org.apache.kudu.client.Connection getConnection()
{
org.apache.hive.kudu.org.apache.kudu.client.RpcProxy v;
org.apache.hive.kudu.org.apache.kudu.client.Connection v;
v := @this: org.apache.hive.kudu.org.apache.kudu.client.RpcProxy;
v = v.<org.apache.hive.kudu.org.apache.kudu.client.RpcProxy: org.apache.hive.kudu.org.apache.kudu.client.Connection connection>;
return v;
}
static void <clinit>()
{
org.slf4j.Logger v;
v = staticinvoke <org.slf4j.LoggerFactory: org.slf4j.Logger getLogger(java.lang.Class)>(class "Lorg/apache/hive/kudu/org/apache/kudu/client/RpcProxy;");
<org.apache.hive.kudu.org.apache.kudu.client.RpcProxy: org.slf4j.Logger LOG> = v;
<org.apache.hive.kudu.org.apache.kudu.client.RpcProxy: int staticNumFail> = 0;
<org.apache.hive.kudu.org.apache.kudu.client.RpcProxy: java.lang.Exception staticException> = null;
return;
}
}