final class org.apache.hive.kudu.org.apache.kudu.client.ConnectToCluster extends java.lang.Object
{
private static final org.slf4j.Logger LOG;
private final java.util.List masterAddrs;
private final org.apache.hive.kudu.com.stumbleupon.async.Deferred responseD;
private final java.util.concurrent.atomic.AtomicBoolean responseDCalled;
private final java.util.concurrent.atomic.AtomicInteger countResponsesReceived;
private final java.util.List exceptionsReceived;
private java.util.concurrent.atomic.AtomicReference knownMasters;
private int numMasters;
void <init>(java.util.List)
{
org.apache.hive.kudu.com.stumbleupon.async.Deferred v;
java.util.concurrent.atomic.AtomicBoolean v;
java.util.concurrent.atomic.AtomicReference v;
java.util.ArrayList v;
java.util.List v, v;
org.apache.hive.kudu.org.apache.kudu.client.ConnectToCluster v;
java.util.concurrent.atomic.AtomicInteger v;
int v;
v := @this: org.apache.hive.kudu.org.apache.kudu.client.ConnectToCluster;
v := @parameter: java.util.List;
specialinvoke v.<java.lang.Object: void <init>()>();
v = new java.util.concurrent.atomic.AtomicBoolean;
specialinvoke v.<java.util.concurrent.atomic.AtomicBoolean: void <init>(boolean)>(0);
v.<org.apache.hive.kudu.org.apache.kudu.client.ConnectToCluster: java.util.concurrent.atomic.AtomicBoolean responseDCalled> = v;
v = new java.util.concurrent.atomic.AtomicInteger;
specialinvoke v.<java.util.concurrent.atomic.AtomicInteger: void <init>(int)>(0);
v.<org.apache.hive.kudu.org.apache.kudu.client.ConnectToCluster: java.util.concurrent.atomic.AtomicInteger countResponsesReceived> = v;
v = new java.util.ArrayList;
specialinvoke v.<java.util.ArrayList: void <init>()>();
v = staticinvoke <java.util.Collections: java.util.List synchronizedList(java.util.List)>(v);
v.<org.apache.hive.kudu.org.apache.kudu.client.ConnectToCluster: java.util.List exceptionsReceived> = v;
v = new java.util.concurrent.atomic.AtomicReference;
specialinvoke v.<java.util.concurrent.atomic.AtomicReference: void <init>()>();
v.<org.apache.hive.kudu.org.apache.kudu.client.ConnectToCluster: java.util.concurrent.atomic.AtomicReference knownMasters> = v;
v.<org.apache.hive.kudu.org.apache.kudu.client.ConnectToCluster: java.util.List masterAddrs> = v;
v = new org.apache.hive.kudu.com.stumbleupon.async.Deferred;
specialinvoke v.<org.apache.hive.kudu.com.stumbleupon.async.Deferred: void <init>()>();
v.<org.apache.hive.kudu.org.apache.kudu.client.ConnectToCluster: org.apache.hive.kudu.com.stumbleupon.async.Deferred responseD> = v;
v = interfaceinvoke v.<java.util.List: int size()>();
v.<org.apache.hive.kudu.org.apache.kudu.client.ConnectToCluster: int numMasters> = v;
return;
}
public org.apache.hive.kudu.com.stumbleupon.async.Deferred getDeferred()
{
org.apache.hive.kudu.com.stumbleupon.async.Deferred v;
org.apache.hive.kudu.org.apache.kudu.client.ConnectToCluster v;
v := @this: org.apache.hive.kudu.org.apache.kudu.client.ConnectToCluster;
v = v.<org.apache.hive.kudu.org.apache.kudu.client.ConnectToCluster: org.apache.hive.kudu.com.stumbleupon.async.Deferred responseD>;
return v;
}
java.util.List getExceptionsReceived()
{
java.util.List v;
org.apache.hive.kudu.org.apache.kudu.client.ConnectToCluster v;
v := @this: org.apache.hive.kudu.org.apache.kudu.client.ConnectToCluster;
v = v.<org.apache.hive.kudu.org.apache.kudu.client.ConnectToCluster: java.util.List exceptionsReceived>;
return v;
}
private static org.apache.hive.kudu.com.stumbleupon.async.Deferred connectToMaster(org.apache.hive.kudu.org.apache.kudu.client.KuduTable, org.apache.hive.kudu.org.apache.kudu.client.RpcProxy, org.apache.hive.kudu.org.apache.kudu.client.KuduRpc, org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.Timer, long)
{
org.apache.hive.kudu.com.stumbleupon.async.Deferred v;
org.apache.hive.kudu.org.apache.kudu.client.TimeoutTracker v;
long v, v;
org.apache.hive.kudu.org.apache.kudu.client.KuduRpc v;
org.apache.hive.kudu.org.apache.kudu.client.KuduTable v;
org.apache.hive.kudu.org.apache.kudu.client.ConnectToMasterRequest v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.Timer v;
int v, v;
org.apache.hive.kudu.org.apache.kudu.client.RpcProxy v;
org.apache.hive.kudu.org.apache.kudu.client.ConnectToCluster$1 v;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.client.KuduTable;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.client.RpcProxy;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.client.KuduRpc;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.Timer;
v := @parameter: long;
if v != null goto label;
v = v;
goto label;
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()>();
label:
v = new org.apache.hive.kudu.org.apache.kudu.client.ConnectToMasterRequest;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.client.ConnectToMasterRequest: void <init>(org.apache.hive.kudu.org.apache.kudu.client.KuduTable,org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.Timer,long)>(v, v, v);
virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.client.ConnectToMasterRequest: void setParentRpc(org.apache.hive.kudu.org.apache.kudu.client.KuduRpc)>(v);
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.client.ConnectToMasterRequest: org.apache.hive.kudu.com.stumbleupon.async.Deferred getDeferred()>();
v = v.<org.apache.hive.kudu.org.apache.kudu.client.ConnectToMasterRequest: int attempt>;
v = v + 1;
v.<org.apache.hive.kudu.org.apache.kudu.client.ConnectToMasterRequest: int attempt> = v;
virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.client.RpcProxy: void sendRpc(org.apache.hive.kudu.org.apache.kudu.client.KuduRpc)>(v);
v = new org.apache.hive.kudu.org.apache.kudu.client.ConnectToCluster$1;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.client.ConnectToCluster$1: void <init>(org.apache.hive.kudu.org.apache.kudu.client.ConnectToMasterRequest,org.apache.hive.kudu.org.apache.kudu.client.RpcProxy)>(v, v);
virtualinvoke v.<org.apache.hive.kudu.com.stumbleupon.async.Deferred: org.apache.hive.kudu.com.stumbleupon.async.Deferred addErrback(org.apache.hive.kudu.com.stumbleupon.async.Callback)>(v);
return v;
}
public static org.apache.hive.kudu.com.stumbleupon.async.Deferred run(org.apache.hive.kudu.org.apache.kudu.client.KuduTable, java.util.List, org.apache.hive.kudu.org.apache.kudu.client.KuduRpc, long, org.apache.hive.kudu.org.apache.kudu.client.Connection$CredentialsPolicy)
{
org.apache.hive.kudu.com.stumbleupon.async.Deferred v;
java.util.List v;
org.apache.hive.kudu.org.apache.kudu.client.ConnectToCluster v;
org.apache.hive.kudu.org.apache.kudu.client.Connection$CredentialsPolicy v;
long v;
org.apache.hive.kudu.org.apache.kudu.client.KuduRpc v;
org.apache.hive.kudu.org.apache.kudu.client.KuduTable v;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.client.KuduTable;
v := @parameter: java.util.List;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.client.KuduRpc;
v := @parameter: long;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.client.Connection$CredentialsPolicy;
v = new org.apache.hive.kudu.org.apache.kudu.client.ConnectToCluster;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.client.ConnectToCluster: void <init>(java.util.List)>(v);
virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.client.ConnectToCluster: java.util.List connectToMasters(org.apache.hive.kudu.org.apache.kudu.client.KuduTable,org.apache.hive.kudu.org.apache.kudu.client.KuduRpc,long,org.apache.hive.kudu.org.apache.kudu.client.Connection$CredentialsPolicy)>(v, v, v, v);
v = v.<org.apache.hive.kudu.org.apache.kudu.client.ConnectToCluster: org.apache.hive.kudu.com.stumbleupon.async.Deferred responseD>;
return v;
}
java.util.List connectToMasters(org.apache.hive.kudu.org.apache.kudu.client.KuduTable, org.apache.hive.kudu.org.apache.kudu.client.KuduRpc, long, org.apache.hive.kudu.org.apache.kudu.client.Connection$CredentialsPolicy)
{
java.net.InetAddress[] v;
org.apache.hive.kudu.org.apache.kudu.client.KuduTable v;
java.net.InetAddress v;
org.apache.hive.kudu.org.apache.kudu.client.HostAndPort v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.Timer v;
org.apache.hive.kudu.com.stumbleupon.async.Callback v, v;
boolean v, v;
java.util.List v;
org.apache.hive.kudu.org.apache.kudu.client.ConnectToCluster v;
org.apache.hive.kudu.org.apache.kudu.client.RpcProxy v;
org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient v;
long v;
org.apache.hive.kudu.org.apache.kudu.client.KuduRpc v;
java.util.ArrayList v, v;
int v, v, v, v, v;
org.apache.hive.kudu.org.apache.kudu.util.Pair v, v;
java.lang.String v, v, v, v, v;
org.apache.hive.kudu.org.apache.kudu.client.NonRecoverableException v;
org.apache.hive.kudu.com.stumbleupon.async.Deferred v;
org.slf4j.Logger v, v;
java.util.Iterator v, v;
org.apache.hive.kudu.org.apache.kudu.client.Connection$CredentialsPolicy v;
org.apache.hive.kudu.org.apache.kudu.client.Status v;
java.lang.Object v, v, v, v;
v := @this: org.apache.hive.kudu.org.apache.kudu.client.ConnectToCluster;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.client.KuduTable;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.client.KuduRpc;
v := @parameter: long;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.client.Connection$CredentialsPolicy;
v = new java.util.ArrayList;
specialinvoke v.<java.util.ArrayList: void <init>()>();
v = new java.util.ArrayList;
specialinvoke v.<java.util.ArrayList: void <init>()>();
v = v.<org.apache.hive.kudu.org.apache.kudu.client.ConnectToCluster: java.util.List masterAddrs>;
v = interfaceinvoke v.<java.util.List: java.util.Iterator iterator()>();
label:
v = interfaceinvoke v.<java.util.Iterator: boolean hasNext()>();
if v == 0 goto label;
v = interfaceinvoke v.<java.util.Iterator: java.lang.Object next()>();
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.client.HostAndPort: java.lang.String getHost()>();
v = staticinvoke <org.apache.hive.kudu.org.apache.kudu.util.NetUtil: java.net.InetAddress[] getAllInetAddresses(java.lang.String)>(v);
if v == null goto label;
v = lengthof v;
if v <= 1 goto label;
v = <org.apache.hive.kudu.org.apache.kudu.client.ConnectToCluster: org.slf4j.Logger LOG>;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.client.HostAndPort: java.lang.String getHost()>();
interfaceinvoke v.<org.slf4j.Logger: void info(java.lang.String,java.lang.Object,java.lang.Object)>("Specified master server address {} resolved to multiple IPs {}. Connecting to each one of them.", v, v);
label:
v = lengthof v;
v = 0;
label:
if v >= v goto label;
v = v[v];
v = new org.apache.hive.kudu.org.apache.kudu.util.Pair;
v = new org.apache.hive.kudu.org.apache.kudu.client.HostAndPort;
v = virtualinvoke v.<java.net.InetAddress: java.lang.String getHostAddress()>();
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.client.HostAndPort: int getPort()>();
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.client.HostAndPort: void <init>(java.lang.String,int)>(v, v);
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.util.Pair: void <init>(java.lang.Object,java.lang.Object)>(v, v);
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
v = v + 1;
goto label;
label:
v = new org.apache.hive.kudu.org.apache.kudu.util.Pair;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.util.Pair: void <init>(java.lang.Object,java.lang.Object)>(null, v);
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
goto label;
label:
v = interfaceinvoke v.<java.util.List: int size()>();
v.<org.apache.hive.kudu.org.apache.kudu.client.ConnectToCluster: int numMasters> = v;
v = interfaceinvoke v.<java.util.List: java.util.Iterator iterator()>();
label:
v = interfaceinvoke v.<java.util.Iterator: boolean hasNext()>();
if v == 0 goto label;
v = interfaceinvoke v.<java.util.Iterator: java.lang.Object next()>();
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.util.Pair: java.lang.Object getFirst()>();
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.util.Pair: java.lang.Object getSecond()>();
if v == null goto label;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.client.KuduTable: org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient getAsyncClient()>();
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient: org.apache.hive.kudu.org.apache.kudu.client.RpcProxy newMasterRpcProxy(org.apache.hive.kudu.org.apache.kudu.client.HostAndPort,java.net.InetAddress,org.apache.hive.kudu.org.apache.kudu.client.Connection$CredentialsPolicy)>(v, v, v);
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.Timer getTimer()>();
v = staticinvoke <org.apache.hive.kudu.org.apache.kudu.client.ConnectToCluster: org.apache.hive.kudu.com.stumbleupon.async.Deferred connectToMaster(org.apache.hive.kudu.org.apache.kudu.client.KuduTable,org.apache.hive.kudu.org.apache.kudu.client.RpcProxy,org.apache.hive.kudu.org.apache.kudu.client.KuduRpc,org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.Timer,long)>(v, v, v, v, v);
goto label;
label:
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.client.HostAndPort: java.lang.String toString()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String)>(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[])>("Couldn\'t resolve this master\'s address \u0001");
v = <org.apache.hive.kudu.org.apache.kudu.client.ConnectToCluster: org.slf4j.Logger LOG>;
interfaceinvoke v.<org.slf4j.Logger: void warn(java.lang.String)>(v);
v = staticinvoke <org.apache.hive.kudu.org.apache.kudu.client.Status: org.apache.hive.kudu.org.apache.kudu.client.Status IOError(java.lang.String)>(v);
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);
v = staticinvoke <org.apache.hive.kudu.com.stumbleupon.async.Deferred: org.apache.hive.kudu.com.stumbleupon.async.Deferred fromError(java.lang.Exception)>(v);
label:
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.client.ConnectToCluster: org.apache.hive.kudu.com.stumbleupon.async.Callback callbackForNode(org.apache.hive.kudu.org.apache.kudu.client.HostAndPort)>(v);
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.client.ConnectToCluster: org.apache.hive.kudu.com.stumbleupon.async.Callback errbackForNode(org.apache.hive.kudu.org.apache.kudu.client.HostAndPort)>(v);
virtualinvoke v.<org.apache.hive.kudu.com.stumbleupon.async.Deferred: org.apache.hive.kudu.com.stumbleupon.async.Deferred addCallbacks(org.apache.hive.kudu.com.stumbleupon.async.Callback,org.apache.hive.kudu.com.stumbleupon.async.Callback)>(v, v);
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
goto label;
label:
return v;
}
org.apache.hive.kudu.com.stumbleupon.async.Callback callbackForNode(org.apache.hive.kudu.org.apache.kudu.client.HostAndPort)
{
org.apache.hive.kudu.org.apache.kudu.client.ConnectToCluster$ConnectToMasterCB v;
org.apache.hive.kudu.org.apache.kudu.client.ConnectToCluster v;
org.apache.hive.kudu.org.apache.kudu.client.HostAndPort v;
v := @this: org.apache.hive.kudu.org.apache.kudu.client.ConnectToCluster;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.client.HostAndPort;
v = new org.apache.hive.kudu.org.apache.kudu.client.ConnectToCluster$ConnectToMasterCB;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.client.ConnectToCluster$ConnectToMasterCB: void <init>(org.apache.hive.kudu.org.apache.kudu.client.ConnectToCluster,org.apache.hive.kudu.org.apache.kudu.client.HostAndPort)>(v, v);
return v;
}
org.apache.hive.kudu.com.stumbleupon.async.Callback errbackForNode(org.apache.hive.kudu.org.apache.kudu.client.HostAndPort)
{
org.apache.hive.kudu.org.apache.kudu.client.ConnectToCluster$ConnectToMasterErrCB v;
org.apache.hive.kudu.org.apache.kudu.client.ConnectToCluster v;
org.apache.hive.kudu.org.apache.kudu.client.HostAndPort v;
v := @this: org.apache.hive.kudu.org.apache.kudu.client.ConnectToCluster;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.client.HostAndPort;
v = new org.apache.hive.kudu.org.apache.kudu.client.ConnectToCluster$ConnectToMasterErrCB;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.client.ConnectToCluster$ConnectToMasterErrCB: void <init>(org.apache.hive.kudu.org.apache.kudu.client.ConnectToCluster,org.apache.hive.kudu.org.apache.kudu.client.HostAndPort)>(v, v);
return v;
}
private void incrementCountAndCheckExhausted()
{
java.lang.Integer v, v;
org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.base.Joiner v, v;
java.lang.Object[] v, v, v;
java.lang.String v, v, v, v, v, v, v, v;
org.apache.hive.kudu.org.apache.kudu.client.NonRecoverableException v, v;
org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.base.Function v, v;
java.util.concurrent.atomic.AtomicInteger v, v;
boolean v, v, v, v, v, v;
java.util.List v, v, v, v, v, v, v, v, v, v;
java.lang.StackTraceElement[] v;
org.apache.hive.kudu.org.apache.kudu.client.ConnectToCluster v;
java.util.concurrent.atomic.AtomicBoolean v;
java.util.concurrent.atomic.AtomicReference v;
int v, v, v, v, v, v, v, v, v, v;
org.apache.hive.kudu.org.apache.kudu.client.NoLeaderFoundException v, v, v;
org.apache.hive.kudu.com.stumbleupon.async.Deferred v, v, v;
org.slf4j.Logger v, v, v, v;
java.util.Iterator v;
org.apache.hive.kudu.org.apache.kudu.client.Status v, v, v, v;
java.lang.Object v, v, v;
v := @this: org.apache.hive.kudu.org.apache.kudu.client.ConnectToCluster;
v = v.<org.apache.hive.kudu.org.apache.kudu.client.ConnectToCluster: java.util.concurrent.atomic.AtomicInteger countResponsesReceived>;
v = virtualinvoke v.<java.util.concurrent.atomic.AtomicInteger: int incrementAndGet()>();
v = v.<org.apache.hive.kudu.org.apache.kudu.client.ConnectToCluster: int numMasters>;
if v != v goto label;
v = v.<org.apache.hive.kudu.org.apache.kudu.client.ConnectToCluster: java.util.concurrent.atomic.AtomicBoolean responseDCalled>;
v = virtualinvoke v.<java.util.concurrent.atomic.AtomicBoolean: boolean compareAndSet(boolean,boolean)>(0, 1);
if v == 0 goto label;
v = 1;
v = v.<org.apache.hive.kudu.org.apache.kudu.client.ConnectToCluster: java.util.List exceptionsReceived>;
v = interfaceinvoke v.<java.util.List: int size()>();
v = v.<org.apache.hive.kudu.org.apache.kudu.client.ConnectToCluster: java.util.concurrent.atomic.AtomicInteger countResponsesReceived>;
v = virtualinvoke v.<java.util.concurrent.atomic.AtomicInteger: int get()>();
if v != v goto label;
v = v.<org.apache.hive.kudu.org.apache.kudu.client.ConnectToCluster: java.util.List exceptionsReceived>;
v = interfaceinvoke v.<java.util.List: java.util.Iterator iterator()>();
label:
v = interfaceinvoke v.<java.util.Iterator: boolean hasNext()>();
if v == 0 goto label;
v = interfaceinvoke v.<java.util.Iterator: java.lang.Object next()>();
v = v instanceof org.apache.hive.kudu.org.apache.kudu.client.NonRecoverableException;
if v != 0 goto label;
v = 0;
goto label;
label:
v = 0;
label:
v = v.<org.apache.hive.kudu.org.apache.kudu.client.ConnectToCluster: java.util.List masterAddrs>;
v = staticinvoke <org.apache.hive.kudu.org.apache.kudu.util.NetUtil: java.lang.String hostsAndPortsToString(java.util.List)>(v);
if v == 0 goto label;
v = newarray (java.lang.Object)[2];
v[0] = v;
v = staticinvoke <org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.base.Joiner: org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.base.Joiner on(java.lang.String)>(", ");
v = v.<org.apache.hive.kudu.org.apache.kudu.client.ConnectToCluster: java.util.List exceptionsReceived>;
v = staticinvoke <org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.base.Functions: org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.base.Function toStringFunction()>();
v = staticinvoke <org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.collect.Lists: java.util.List transform(java.util.List,org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.base.Function)>(v, v);
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.base.Joiner: java.lang.String join(java.lang.Iterable)>(v);
v[1] = v;
v = staticinvoke <java.lang.String: java.lang.String format(java.lang.String,java.lang.Object[])>("Couldn\'t find a valid master in (%s). Exceptions received: [%s]", v);
v = staticinvoke <org.apache.hive.kudu.org.apache.kudu.client.Status: org.apache.hive.kudu.org.apache.kudu.client.Status ServiceUnavailable(java.lang.String)>(v);
v = v.<org.apache.hive.kudu.org.apache.kudu.client.ConnectToCluster: org.apache.hive.kudu.com.stumbleupon.async.Deferred responseD>;
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);
virtualinvoke v.<org.apache.hive.kudu.com.stumbleupon.async.Deferred: void callback(java.lang.Object)>(v);
goto label;
label:
v = v.<org.apache.hive.kudu.org.apache.kudu.client.ConnectToCluster: java.util.concurrent.atomic.AtomicReference knownMasters>;
v = virtualinvoke v.<java.util.concurrent.atomic.AtomicReference: java.lang.Object get()>();
if v == null goto label;
v = interfaceinvoke v.<java.util.List: int size()>();
v = v.<org.apache.hive.kudu.org.apache.kudu.client.ConnectToCluster: int numMasters>;
if v <= v goto label;
v = newarray (java.lang.Object)[4];
v = v.<org.apache.hive.kudu.org.apache.kudu.client.ConnectToCluster: int numMasters>;
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
v[0] = v;
v[1] = v;
v = interfaceinvoke v.<java.util.List: int size()>();
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
v[2] = v;
v = staticinvoke <org.apache.hive.kudu.org.apache.kudu.client.ProtobufHelper: java.lang.String hostPortPbListToString(java.util.List)>(v);
v[3] = v;
v = staticinvoke <java.lang.String: java.lang.String format(java.lang.String,java.lang.Object[])>("Could not connect to a leader master. Client configured with %s master(s) (%s) but cluster indicates it expects %s master(s) (%s)", v);
v = <org.apache.hive.kudu.org.apache.kudu.client.ConnectToCluster: org.slf4j.Logger LOG>;
interfaceinvoke v.<org.slf4j.Logger: void warn(java.lang.String)>(v);
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 ConfigurationError(java.lang.String)>(v);
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.client.NonRecoverableException: void <init>(org.apache.hive.kudu.org.apache.kudu.client.Status)>(v);
v = <org.apache.hive.kudu.org.apache.kudu.client.ConnectToCluster: org.slf4j.Logger LOG>;
v = interfaceinvoke v.<org.slf4j.Logger: boolean isDebugEnabled()>();
if v != 0 goto label;
v = newarray (java.lang.StackTraceElement)[0];
virtualinvoke v.<java.lang.Exception: void setStackTrace(java.lang.StackTraceElement[])>(v);
label:
v = v.<org.apache.hive.kudu.org.apache.kudu.client.ConnectToCluster: org.apache.hive.kudu.com.stumbleupon.async.Deferred responseD>;
virtualinvoke v.<org.apache.hive.kudu.com.stumbleupon.async.Deferred: void callback(java.lang.Object)>(v);
return;
label:
v = newarray (java.lang.Object)[1];
v[0] = v;
v = staticinvoke <java.lang.String: java.lang.String format(java.lang.String,java.lang.Object[])>("Master config (%s) has no leader.", v);
v = v.<org.apache.hive.kudu.org.apache.kudu.client.ConnectToCluster: java.util.List exceptionsReceived>;
v = interfaceinvoke v.<java.util.List: boolean isEmpty()>();
if v == 0 goto label;
v = <org.apache.hive.kudu.org.apache.kudu.client.ConnectToCluster: org.slf4j.Logger LOG>;
interfaceinvoke v.<org.slf4j.Logger: void warn(java.lang.String,java.lang.Object)>("None of the provided masters {} is a leader; will retry", v);
v = new org.apache.hive.kudu.org.apache.kudu.client.NoLeaderFoundException;
v = staticinvoke <org.apache.hive.kudu.org.apache.kudu.client.Status: org.apache.hive.kudu.org.apache.kudu.client.Status ServiceUnavailable(java.lang.String)>(v);
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.client.NoLeaderFoundException: void <init>(org.apache.hive.kudu.org.apache.kudu.client.Status)>(v);
v = v;
goto label;
label:
v = <org.apache.hive.kudu.org.apache.kudu.client.ConnectToCluster: org.slf4j.Logger LOG>;
interfaceinvoke v.<org.slf4j.Logger: void warn(java.lang.String,java.lang.Object)>("Unable to find the leader master {}; will retry", v);
v = staticinvoke <org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.base.Joiner: org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.base.Joiner on(java.lang.String)>(",");
v = v.<org.apache.hive.kudu.org.apache.kudu.client.ConnectToCluster: java.util.List exceptionsReceived>;
v = staticinvoke <org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.base.Functions: org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.base.Function toStringFunction()>();
v = staticinvoke <org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.collect.Lists: java.util.List transform(java.util.List,org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.base.Function)>(v, v);
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.base.Joiner: java.lang.String join(java.lang.Iterable)>(v);
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String,java.lang.String)>(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 Exceptions received: \u0001");
v = staticinvoke <org.apache.hive.kudu.org.apache.kudu.client.Status: org.apache.hive.kudu.org.apache.kudu.client.Status ServiceUnavailable(java.lang.String)>(v);
v = new org.apache.hive.kudu.org.apache.kudu.client.NoLeaderFoundException;
v = v.<org.apache.hive.kudu.org.apache.kudu.client.ConnectToCluster: java.util.List exceptionsReceived>;
v = v.<org.apache.hive.kudu.org.apache.kudu.client.ConnectToCluster: java.util.List exceptionsReceived>;
v = interfaceinvoke v.<java.util.List: int size()>();
v = v - 1;
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(v);
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.client.NoLeaderFoundException: void <init>(org.apache.hive.kudu.org.apache.kudu.client.Status,java.lang.Exception)>(v, v);
v = v;
label:
v = v.<org.apache.hive.kudu.org.apache.kudu.client.ConnectToCluster: org.apache.hive.kudu.com.stumbleupon.async.Deferred responseD>;
virtualinvoke v.<org.apache.hive.kudu.com.stumbleupon.async.Deferred: void callback(java.lang.Object)>(v);
label:
return;
}
private void recordKnownMasters(org.apache.hive.kudu.org.apache.kudu.master.Master$ConnectToMasterResponsePB)
{
java.util.List v;
org.apache.hive.kudu.org.apache.kudu.client.ConnectToCluster v;
org.apache.hive.kudu.org.apache.kudu.master.Master$ConnectToMasterResponsePB v;
int v;
java.util.concurrent.atomic.AtomicReference v;
v := @this: org.apache.hive.kudu.org.apache.kudu.client.ConnectToCluster;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.master.Master$ConnectToMasterResponsePB;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.master.Master$ConnectToMasterResponsePB: int getMasterAddrsCount()>();
if v != 0 goto label;
return;
label:
v = v.<org.apache.hive.kudu.org.apache.kudu.client.ConnectToCluster: java.util.concurrent.atomic.AtomicReference knownMasters>;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.master.Master$ConnectToMasterResponsePB: java.util.List getMasterAddrsList()>();
virtualinvoke v.<java.util.concurrent.atomic.AtomicReference: boolean compareAndSet(java.lang.Object,java.lang.Object)>(null, v);
return;
}
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/ConnectToCluster;");
<org.apache.hive.kudu.org.apache.kudu.client.ConnectToCluster: org.slf4j.Logger LOG> = v;
return;
}
}