class org.apache.hive.kudu.org.apache.kudu.client.Connection extends org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.SimpleChannelInboundHandler { private final org.apache.hive.kudu.org.apache.kudu.client.ServerInfo serverInfo; private final org.apache.hive.kudu.org.apache.kudu.client.SecurityContext securityContext; private final org.apache.hive.kudu.org.apache.kudu.client.Connection$CredentialsPolicy credentialsPolicy; private final org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.bootstrap.Bootstrap bootstrap; private org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.socket.SocketChannel channel; private volatile boolean explicitlyDisconnected; private static final org.slf4j.Logger LOG; private static final byte RPC_CURRENT_VERSION; private static final byte[] CONNECTION_HEADER; private static final java.lang.String NEGOTIATION_TIMEOUT_HANDLER; private static final long NEGOTIATION_TIMEOUT_MS; private final java.util.concurrent.locks.ReentrantLock lock; private org.apache.hive.kudu.org.apache.kudu.client.Connection$State state; private java.util.HashMap inflightMessages; private java.util.ArrayList queuedMessages; private org.apache.hive.kudu.org.apache.kudu.client.Negotiator$Success negotiationResult; private org.apache.hive.kudu.org.apache.kudu.client.Negotiator$Failure negotiationFailure; private int nextCallId; private org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelFuture connectFuture; static final boolean $assertionsDisabled; void (org.apache.hive.kudu.org.apache.kudu.client.ServerInfo, org.apache.hive.kudu.org.apache.kudu.client.SecurityContext, org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.bootstrap.Bootstrap, org.apache.hive.kudu.org.apache.kudu.client.Connection$CredentialsPolicy) { org.apache.hive.kudu.org.apache.kudu.client.ServerInfo v; java.util.concurrent.locks.ReentrantLock v; org.apache.hive.kudu.org.apache.kudu.client.Connection$CredentialsPolicy v; org.apache.hive.kudu.org.apache.kudu.client.Connection$ConnectionChannelInitializer v; org.apache.hive.kudu.org.apache.kudu.client.SecurityContext v; org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.bootstrap.Bootstrap v, v, v; java.util.HashMap v; java.util.ArrayList v; org.apache.hive.kudu.org.apache.kudu.client.Connection v; org.apache.hive.kudu.org.apache.kudu.client.Connection$State v; v := @this: org.apache.hive.kudu.org.apache.kudu.client.Connection; v := @parameter: org.apache.hive.kudu.org.apache.kudu.client.ServerInfo; v := @parameter: org.apache.hive.kudu.org.apache.kudu.client.SecurityContext; v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.bootstrap.Bootstrap; v := @parameter: org.apache.hive.kudu.org.apache.kudu.client.Connection$CredentialsPolicy; specialinvoke v.()>(); v. = 0; v = new java.util.concurrent.locks.ReentrantLock; specialinvoke v.()>(); v. = v; v = new java.util.HashMap; specialinvoke v.()>(); v. = v; v = staticinvoke (); v. = v; v. = null; v. = null; v. = 0; v. = v; v. = v; v = ; v. = v; v. = v; v = virtualinvoke v.(); v. = v; v = v.; v = new org.apache.hive.kudu.org.apache.kudu.client.Connection$ConnectionChannelInitializer; specialinvoke v.(org.apache.hive.kudu.org.apache.kudu.client.Connection)>(v); virtualinvoke v.(v); return; } public void channelActive(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandlerContext) { java.lang.Throwable v; byte[] v; org.apache.hive.kudu.org.apache.kudu.client.ServerInfo v; org.apache.hive.kudu.org.apache.kudu.client.SecurityContext v; java.lang.String v, v; org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandlerContext v; boolean v, v; java.util.concurrent.locks.ReentrantLock v, v, v, v; org.apache.hive.kudu.org.apache.kudu.client.Connection$CredentialsPolicy v, v; org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf v; org.apache.hive.kudu.org.apache.kudu.client.Negotiator v; org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPromise v; org.apache.hive.kudu.org.apache.kudu.client.Connection v; org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPipeline v; org.apache.hive.kudu.org.apache.kudu.client.Connection$State v, v, v, v, v; v := @this: org.apache.hive.kudu.org.apache.kudu.client.Connection; v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandlerContext; v = v.; virtualinvoke v.(); label: v = v.; v = ; if v != v goto label; label: v = v.; virtualinvoke v.(); return; label: v = v.; v = ; if v != v goto label; v = 1; goto label; label: v = 0; label: staticinvoke (v); v = ; v. = v; label: v = v.; virtualinvoke v.(); goto label; label: v := @caughtexception; v = v.; virtualinvoke v.(); throw v; label: v = ; v = staticinvoke (v); v = interfaceinvoke v.(); interfaceinvoke v.(v, v); v = new org.apache.hive.kudu.org.apache.kudu.client.Negotiator; v = v.; v = virtualinvoke v.(); v = v.; v = v.; v = ; if v != v goto label; v = 1; goto label; label: v = 0; label: specialinvoke v.(java.lang.String,org.apache.hive.kudu.org.apache.kudu.client.SecurityContext,boolean)>(v, v, v); v = interfaceinvoke v.(); v = interfaceinvoke v.(); interfaceinvoke v.(v, "negotiation", v); virtualinvoke v.(v); return; catch java.lang.Throwable from label to label with label; catch java.lang.Throwable from label to label with label; } public void channelInactive(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandlerContext) { java.lang.Throwable v, v, v; java.lang.String v, v; org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandlerContext v; org.slf4j.Logger v; java.util.concurrent.locks.ReentrantLock v, v, v; org.apache.hive.kudu.org.apache.kudu.client.Status v; org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelFuture v, v, v; org.apache.hive.kudu.org.apache.kudu.client.RecoverableException v; org.apache.hive.kudu.org.apache.kudu.client.Connection v; v := @this: org.apache.hive.kudu.org.apache.kudu.client.Connection; v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandlerContext; v = ; v = virtualinvoke v.(); interfaceinvoke v.("{} handling channelInactive", v); v = "connection closed"; v = v.; virtualinvoke v.(); label: v = v.; if v == null goto label; v = v.; v = interfaceinvoke v.(); if v == null goto label; v = v.; v = interfaceinvoke v.(); v = virtualinvoke v.(); label: v = v.; virtualinvoke v.(); goto label; label: v := @caughtexception; v = v.; virtualinvoke v.(); throw v; label: v = new org.apache.hive.kudu.org.apache.kudu.client.RecoverableException; v = staticinvoke (v); specialinvoke v.(org.apache.hive.kudu.org.apache.kudu.client.Status)>(v); specialinvoke v.(v); return; catch java.lang.Throwable from label to label with label; } public void channelRead0(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandlerContext, java.lang.Object) throws java.lang.Exception { org.apache.hive.kudu.org.apache.kudu.rpc.RpcHeader$ResponseHeader v; java.lang.Integer v, v; org.apache.hive.kudu.org.apache.kudu.util.Slice v; org.apache.hive.kudu.org.apache.kudu.client.Connection$CallResponseInfo v, v, v, v; org.apache.hive.kudu.org.apache.kudu.client.Connection$State v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v; java.lang.Throwable v, v, v, v; org.apache.hive.kudu.org.apache.kudu.client.InvalidAuthzTokenException v; java.util.ArrayList v, v, v; org.apache.hive.kudu.org.apache.kudu.rpc.RpcHeader$ErrorStatusPB$RpcErrorCodePB v, v, v, v; java.lang.String v, 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.io.netty.channel.ChannelHandlerContext v; org.apache.hive.kudu.org.apache.kudu.rpc.RpcHeader$ErrorStatusPB v; org.apache.hive.kudu.org.apache.kudu.rpc.RpcHeader$ErrorStatusPB$Builder v; org.apache.hive.kudu.com.stumbleupon.async.Callback v; org.apache.hive.kudu.org.apache.kudu.client.RpcRemoteException v; boolean v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v; org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPipeline v; org.apache.hive.kudu.org.apache.kudu.rpc.RpcHeader$RequestHeader$Builder v; java.util.HashMap v, v, v, v; org.apache.hive.kudu.org.apache.kudu.client.RpcOutboundMessage v, v; int v, v, v; org.slf4j.Logger v, v, v; java.util.Iterator v, v; java.util.concurrent.locks.ReentrantLock v, v, v, v, v, v, v, v, v, v, v, v, v, v, v; org.apache.hive.kudu.org.apache.kudu.client.Status v, v, v, v, v; org.apache.hive.kudu.org.apache.kudu.client.RecoverableException v; org.apache.hive.kudu.org.apache.kudu.client.Connection v; java.lang.Object v, v, v, v, v; v := @this: org.apache.hive.kudu.org.apache.kudu.client.Connection; v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandlerContext; v := @parameter: java.lang.Object; v = v instanceof org.apache.hive.kudu.org.apache.kudu.client.Negotiator$Success; if v == 0 goto label; v = v.; virtualinvoke v.(); label: v. = v; v = v.; v = ; if v == v goto label; v = v.; v = virtualinvoke v.(); if v == 0 goto label; label: v = 1; goto label; label: v = 0; label: staticinvoke (v); label: v = v.; v = ; if v == v goto label; v = v.; v = virtualinvoke v.(); if v != 0 goto label; v = v.; v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = v.; v = v.; v = virtualinvoke v.(); v = virtualinvoke v.(); v = staticinvoke (v); v = v.; v = virtualinvoke v.(v, v); if v != null goto label; v = 1; goto label; label: v = 0; label: staticinvoke (v); goto label; label: v = staticinvoke (); v. = v; v = v.; virtualinvoke v.(); label: v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = v.; specialinvoke v.(v); goto label; label: v = v.; virtualinvoke v.(); goto label; label: v := @caughtexception; v = v.; virtualinvoke v.(); throw v; label: v = v.; v = ; if v != v goto label; label: v = v.; virtualinvoke v.(); return; label: v = v.; v = ; if v != v goto label; v = 1; goto label; label: v = 0; label: staticinvoke (v); v. = null; v = interfaceinvoke v.(); interfaceinvoke v.("negotiation-timeout-handler"); v = ; v. = v; label: v = v.; virtualinvoke v.(); goto label; label: v := @caughtexception; v = v.; virtualinvoke v.(); throw v; label: return; label: v = v instanceof org.apache.hive.kudu.org.apache.kudu.client.Negotiator$Failure; if v == 0 goto label; v = v.; virtualinvoke v.(); label: v = v.; v = ; if v != v goto label; label: v = v.; virtualinvoke v.(); return; label: v = v.; v = ; if v != v goto label; v = 1; goto label; label: v = 0; label: staticinvoke (v); v = v.; v = virtualinvoke v.(); staticinvoke (v); v = ; v. = v; v. = v; label: v = v.; virtualinvoke v.(); goto label; label: v := @caughtexception; v = v.; virtualinvoke v.(); throw v; label: interfaceinvoke v.(); return; label: v = v instanceof org.apache.hive.kudu.org.apache.kudu.client.CallResponse; if v != 0 goto label; interfaceinvoke v.(v); return; label: v = virtualinvoke v.(); v = virtualinvoke v.(); if v != 0 goto label; v = virtualinvoke v.(); v = virtualinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v, v, v) ("\u RPC response (size: \u) doesn\'t have callID: \u0001"); v = ; interfaceinvoke v.(v); v = new org.apache.hive.kudu.org.apache.kudu.client.NonRecoverableException; v = staticinvoke (v); specialinvoke v.(org.apache.hive.kudu.org.apache.kudu.client.Status)>(v); throw v; label: v = virtualinvoke v.(); v = v.; virtualinvoke v.(); label: v = v.; v = ; if v != v goto label; label: v = v.; virtualinvoke v.(); return; label: v = v.; v = ; if v != v goto label; v = 1; goto label; label: v = 0; label: staticinvoke (v); v = v.; v = staticinvoke (v); v = virtualinvoke v.(v); label: v = v.; virtualinvoke v.(); goto label; label: v := @caughtexception; v = v.; virtualinvoke v.(); throw v; label: if v != null goto label; v = virtualinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v, v) ("\u invalid callID: \u0001"); v = ; interfaceinvoke v.(v); v = new org.apache.hive.kudu.org.apache.kudu.client.NonRecoverableException; v = staticinvoke (v); specialinvoke v.(org.apache.hive.kudu.org.apache.kudu.client.Status)>(v); throw v; label: v = virtualinvoke v.(); if v == 0 goto label; v = virtualinvoke v.(); if v != 0 goto label; label: v = new org.apache.hive.kudu.org.apache.kudu.client.Connection$CallResponseInfo; specialinvoke v.(org.apache.hive.kudu.org.apache.kudu.client.CallResponse,org.apache.hive.kudu.org.apache.kudu.client.KuduException)>(v, null); interfaceinvoke v.(v); return; label: v = staticinvoke (); v = virtualinvoke v.(); staticinvoke (v, v); v = virtualinvoke v.(); v = virtualinvoke v.(); v = ; v = virtualinvoke v.(v); if v != 0 goto label; v = ; v = virtualinvoke v.(v); if v == 0 goto label; label: v = new org.apache.hive.kudu.org.apache.kudu.client.Connection$CallResponseInfo; v = new org.apache.hive.kudu.org.apache.kudu.client.RecoverableException; v = virtualinvoke v.(); v = staticinvoke (v); specialinvoke v.(org.apache.hive.kudu.org.apache.kudu.client.Status)>(v); specialinvoke v.(org.apache.hive.kudu.org.apache.kudu.client.CallResponse,org.apache.hive.kudu.org.apache.kudu.client.KuduException)>(v, v); interfaceinvoke v.(v); return; label: v = ; v = virtualinvoke v.(v); if v == 0 goto label; v = new org.apache.hive.kudu.org.apache.kudu.client.Connection$CallResponseInfo; v = new org.apache.hive.kudu.org.apache.kudu.client.InvalidAuthzTokenException; v = virtualinvoke v.(); v = staticinvoke (v); specialinvoke v.(org.apache.hive.kudu.org.apache.kudu.client.Status)>(v); specialinvoke v.(org.apache.hive.kudu.org.apache.kudu.client.CallResponse,org.apache.hive.kudu.org.apache.kudu.client.KuduException)>(v, v); interfaceinvoke v.(v); return; label: v = virtualinvoke v.(); v = virtualinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v, v) ("\u server sent error \u0001"); v = ; interfaceinvoke v.(v); v = new org.apache.hive.kudu.org.apache.kudu.client.Connection$CallResponseInfo; v = new org.apache.hive.kudu.org.apache.kudu.client.RpcRemoteException; v = staticinvoke (v); specialinvoke v.(org.apache.hive.kudu.org.apache.kudu.client.Status,org.apache.hive.kudu.org.apache.kudu.rpc.RpcHeader$ErrorStatusPB)>(v, v); specialinvoke v.(org.apache.hive.kudu.org.apache.kudu.client.CallResponse,org.apache.hive.kudu.org.apache.kudu.client.KuduException)>(v, v); interfaceinvoke v.(v); return; catch java.lang.Throwable from label to label with label; catch java.lang.Throwable from label to label with label; catch java.lang.Throwable from label to label with label; catch java.lang.Throwable from label to label with label; catch java.lang.Throwable from label to label with label; catch java.lang.Throwable from label to label with label; catch java.lang.Throwable from label to label with label; } public void exceptionCaught(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandlerContext, java.lang.Throwable) throws java.lang.Exception { 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.shaded.io.netty.channel.Channel v; java.lang.Throwable v; java.lang.Object[] v, v, v, v, v, v; java.lang.AssertionError v; java.lang.String v, v, v, v, v, v, v, v, v, v, v, v, v, v, v; org.apache.hive.kudu.org.apache.kudu.client.NonRecoverableException v; org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandlerContext v; org.slf4j.Logger v, v, v, v, v, v; org.apache.hive.kudu.org.apache.kudu.client.Status v, v, v, v, v, v, v; org.apache.hive.kudu.org.apache.kudu.client.RecoverableException v, v, v, v, v, v; org.apache.hive.kudu.org.apache.kudu.client.Connection v; v := @this: org.apache.hive.kudu.org.apache.kudu.client.Connection; v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandlerContext; v := @parameter: java.lang.Throwable; v = v instanceof org.apache.hive.kudu.org.apache.kudu.client.KuduException; if v != 0 goto label; v = v instanceof java.util.concurrent.RejectedExecutionException; if v == 0 goto label; v = newarray (java.lang.Object)[1]; v = virtualinvoke v.(); v[0] = v; v = staticinvoke ("%s RPC rejected by the executor (ignore if shutting down)", v); v = new org.apache.hive.kudu.org.apache.kudu.client.RecoverableException; v = staticinvoke (v); specialinvoke v.(org.apache.hive.kudu.org.apache.kudu.client.Status,java.lang.Throwable)>(v, v); v = v; v = ; interfaceinvoke v.(v, v); goto label; label: v = v instanceof org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.timeout.ReadTimeoutException; if v == 0 goto label; v = newarray (java.lang.Object)[1]; v = virtualinvoke v.(); v[0] = v; v = staticinvoke ("%s encountered a read timeout; closing the channel", v); v = new org.apache.hive.kudu.org.apache.kudu.client.RecoverableException; v = staticinvoke (v); specialinvoke v.(org.apache.hive.kudu.org.apache.kudu.client.Status,java.lang.Throwable)>(v, v); v = v; v = ; interfaceinvoke v.(v); goto label; label: v = v instanceof java.nio.channels.ClosedChannelException; if v == 0 goto label; v = v.; if v == 0 goto label; v = "%s disconnected from peer"; goto label; label: v = "%s lost connection to peer"; label: v = newarray (java.lang.Object)[1]; v = virtualinvoke v.(); v[0] = v; v = staticinvoke (v, v); v = new org.apache.hive.kudu.org.apache.kudu.client.RecoverableException; v = staticinvoke (v); specialinvoke v.(org.apache.hive.kudu.org.apache.kudu.client.Status,java.lang.Throwable)>(v, v); v = v; v = ; interfaceinvoke v.(v); goto label; label: v = v instanceof java.net.ConnectException; if v == 0 goto label; v = v.; v = virtualinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v, v) ("Failed to connect to peer \u0001: \u0001"); v = new org.apache.hive.kudu.org.apache.kudu.client.RecoverableException; v = staticinvoke (v); specialinvoke v.(org.apache.hive.kudu.org.apache.kudu.client.Status,java.lang.Throwable)>(v, v); v = v; v = ; interfaceinvoke v.(v); goto label; label: v = v instanceof javax.net.ssl.SSLException; if v == 0 goto label; v = v.; if v == 0 goto label; v = new org.apache.hive.kudu.org.apache.kudu.client.RecoverableException; v = newarray (java.lang.Object)[1]; v = virtualinvoke v.(); v[0] = v; v = staticinvoke ("%s disconnected from peer", v); v = staticinvoke (v); specialinvoke v.(org.apache.hive.kudu.org.apache.kudu.client.Status)>(v); v = v; goto label; label: v = v instanceof javax.net.ssl.SSLPeerUnverifiedException; if v == 0 goto label; v = newarray (java.lang.Object)[2]; v = v.; v[0] = v; v = virtualinvoke v.(); v[1] = v; v = staticinvoke ("unable to verify identity of peer %s: %s", v); v = new org.apache.hive.kudu.org.apache.kudu.client.NonRecoverableException; v = staticinvoke (v); specialinvoke v.(org.apache.hive.kudu.org.apache.kudu.client.Status,java.lang.Throwable)>(v, v); v = v; v = ; interfaceinvoke v.(v, v); goto label; label: v = ; if v != 0 goto label; v = v.; if v == 0 goto label; v = new java.lang.AssertionError; specialinvoke v.()>(); throw v; label: v = newarray (java.lang.Object)[2]; v = virtualinvoke v.(); v[0] = v; v = interfaceinvoke v.(); v[1] = v; v = staticinvoke ("%s unexpected exception from downstream on %s", v); v = new org.apache.hive.kudu.org.apache.kudu.client.RecoverableException; v = staticinvoke (v); specialinvoke v.(org.apache.hive.kudu.org.apache.kudu.client.Status,java.lang.Throwable)>(v, v); v = v; v = ; interfaceinvoke v.(v, v); label: specialinvoke v.(v); if v == null goto label; interfaceinvoke v.(); label: return; } public org.apache.hive.kudu.org.apache.kudu.client.ServerInfo getServerInfo() { org.apache.hive.kudu.org.apache.kudu.client.ServerInfo v; org.apache.hive.kudu.org.apache.kudu.client.Connection v; v := @this: org.apache.hive.kudu.org.apache.kudu.client.Connection; v = v.; return v; } org.apache.hive.kudu.org.apache.kudu.client.Connection$CredentialsPolicy getCredentialsPolicy() { org.apache.hive.kudu.org.apache.kudu.client.Connection v; org.apache.hive.kudu.org.apache.kudu.client.Connection$CredentialsPolicy v; v := @this: org.apache.hive.kudu.org.apache.kudu.client.Connection; v = v.; return v; } boolean isTerminated() { java.lang.Throwable v; java.util.concurrent.locks.ReentrantLock v, v, v; org.apache.hive.kudu.org.apache.kudu.client.Connection v; org.apache.hive.kudu.org.apache.kudu.client.Connection$State v, v; boolean v; v := @this: org.apache.hive.kudu.org.apache.kudu.client.Connection; v = v.; virtualinvoke v.(); label: v = v.; v = ; if v != v goto label; v = 1; goto label; label: v = 0; label: v = v.; virtualinvoke v.(); return v; label: v := @caughtexception; v = v.; virtualinvoke v.(); throw v; catch java.lang.Throwable from label to label with label; } java.util.Set getPeerFeatures() { java.lang.Throwable v; java.util.concurrent.locks.ReentrantLock v, v, v; java.util.Set v; org.apache.hive.kudu.org.apache.kudu.client.Connection v; org.apache.hive.kudu.org.apache.kudu.client.Negotiator$Success v, v; v := @this: org.apache.hive.kudu.org.apache.kudu.client.Connection; v = null; v = v.; virtualinvoke v.(); label: v = v.; if v == null goto label; v = v.; v = v.; label: v = v.; virtualinvoke v.(); goto label; label: v := @caughtexception; v = v.; virtualinvoke v.(); throw v; label: return v; catch java.lang.Throwable from label to label with label; } java.lang.String getLogPrefix() { org.apache.hive.kudu.org.apache.kudu.client.ServerInfo v; java.lang.String v; org.apache.hive.kudu.org.apache.kudu.client.Connection v; v := @this: org.apache.hive.kudu.org.apache.kudu.client.Connection; v = v.; v = dynamicinvoke "makeConcatWithConstants" (v) ("[peer \u]"); return v; } void enqueueMessage(org.apache.hive.kudu.org.apache.kudu.client.RpcOutboundMessage, org.apache.hive.kudu.com.stumbleupon.async.Callback) throws org.apache.hive.kudu.org.apache.kudu.client.RecoverableException { java.lang.Throwable v; org.apache.hive.kudu.org.apache.kudu.rpc.RpcHeader$RequestHeader$Builder v; java.util.HashMap v; java.lang.AssertionError v; java.lang.Integer v; java.util.ArrayList v; org.apache.hive.kudu.org.apache.kudu.client.RpcOutboundMessage v; int v, v, v; org.apache.hive.kudu.com.stumbleupon.async.Callback v; boolean v, v; java.util.concurrent.locks.ReentrantLock v, v, v, v; org.apache.hive.kudu.org.apache.kudu.client.Status v; org.apache.hive.kudu.org.apache.kudu.client.Connection$QueuedMessage 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.Connection$State v, v, v, v, v, v, v, v; java.lang.Object v; v := @this: org.apache.hive.kudu.org.apache.kudu.client.Connection; v := @parameter: org.apache.hive.kudu.org.apache.kudu.client.RpcOutboundMessage; v := @parameter: org.apache.hive.kudu.com.stumbleupon.async.Callback; v = v.; virtualinvoke v.(); label: v = v.; v = ; if v != v goto label; v = new org.apache.hive.kudu.org.apache.kudu.client.RecoverableException; v = staticinvoke ("connection is terminated"); specialinvoke v.(org.apache.hive.kudu.org.apache.kudu.client.Status)>(v); throw v; label: v = v.; v = ; if v != v goto label; specialinvoke v.(); label: v = v.; v = v + 1; v. = v; v = virtualinvoke v.(); virtualinvoke v.(v); v = virtualinvoke v.(); if v <= 0 goto label; virtualinvoke v.(v); label: v = v.; v = ; if v == v goto label; v = v.; v = new org.apache.hive.kudu.org.apache.kudu.client.Connection$QueuedMessage; specialinvoke v.(org.apache.hive.kudu.org.apache.kudu.client.RpcOutboundMessage,org.apache.hive.kudu.com.stumbleupon.async.Callback)>(v, v); virtualinvoke v.(v); label: v = v.; virtualinvoke v.(); return; label: v = ; if v != 0 goto label; v = v.; v = ; if v == v goto label; v = new java.lang.AssertionError; specialinvoke v.()>(); throw v; label: v = v.; v = staticinvoke (v); v = virtualinvoke v.(v, v); if v != null goto label; v = 1; goto label; label: v = 0; label: staticinvoke (v); label: v = v.; virtualinvoke v.(); goto label; label: v := @caughtexception; v = v.; virtualinvoke v.(); throw v; label: specialinvoke v.(v); return; catch java.lang.Throwable from label to label with label; catch java.lang.Throwable from label to label with label; } org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelFuture disconnect() { java.lang.Throwable v; java.lang.String v; org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.embedded.EmbeddedChannel v; org.slf4j.Logger v; java.util.concurrent.locks.ReentrantLock v, v, v, v; org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.Channel v; org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelFuture v, v, v; org.apache.hive.kudu.org.apache.kudu.client.Connection v; org.apache.hive.kudu.org.apache.kudu.client.Connection$State v, v, v; v := @this: org.apache.hive.kudu.org.apache.kudu.client.Connection; v = v.; virtualinvoke v.(); label: v = ; v = virtualinvoke v.(); v = v.; interfaceinvoke v.("{} disconnecting while in state {}", v, v); v. = 1; v = v.; v = ; if v != v goto label; v = new org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.embedded.EmbeddedChannel; specialinvoke v.()>(); v = virtualinvoke v.(); label: v = v.; virtualinvoke v.(); return v; label: v = v.; v = interfaceinvoke v.(); v = interfaceinvoke v.(); label: v = v.; virtualinvoke v.(); return v; label: v := @caughtexception; v = v.; virtualinvoke v.(); throw v; catch java.lang.Throwable from label to label with label; catch java.lang.Throwable from label to label with label; } org.apache.hive.kudu.com.stumbleupon.async.Deferred shutdown() { org.apache.hive.kudu.com.stumbleupon.async.Deferred v; org.apache.hive.kudu.org.apache.kudu.client.Connection$ShutdownListener v; org.apache.hive.kudu.org.apache.kudu.client.Connection v; org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelFuture v; v := @this: org.apache.hive.kudu.org.apache.kudu.client.Connection; v = virtualinvoke v.(); v = new org.apache.hive.kudu.com.stumbleupon.async.Deferred; specialinvoke v.()>(); v = new org.apache.hive.kudu.org.apache.kudu.client.Connection$ShutdownListener; specialinvoke v.(org.apache.hive.kudu.com.stumbleupon.async.Deferred)>(v); interfaceinvoke v.(v); return v; } public java.lang.String toString() { java.lang.Throwable v; org.apache.hive.kudu.org.apache.kudu.client.ServerInfo v; java.util.HashMap v, v; java.util.ArrayList v, v; int v, v, v, v; java.lang.String v, v; java.util.concurrent.locks.ReentrantLock v, v, v; org.apache.hive.kudu.org.apache.kudu.client.Connection v; java.lang.StringBuilder v, v, v, v, v, v, v, v, v, v; org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.socket.SocketChannel v; v := @this: org.apache.hive.kudu.org.apache.kudu.client.Connection; v = new java.lang.StringBuilder; specialinvoke v.()>(); v = virtualinvoke v.("Connection@"); v = virtualinvoke v.(); v = virtualinvoke v.(v); v = virtualinvoke v.("(channel="); v = v.; v = virtualinvoke v.(v); v = virtualinvoke v.(", uuid="); v = v.; v = virtualinvoke v.(); virtualinvoke v.(v); v = v.; virtualinvoke v.(); label: v = v.; if v != null goto label; v = 0; goto label; label: v = v.; v = virtualinvoke v.(); label: v = v; v = v.; if v != null goto label; v = 0; goto label; label: v = v.; v = virtualinvoke v.(); label: v = v.; virtualinvoke v.(); goto label; label: v := @caughtexception; v = v.; virtualinvoke v.(); throw v; label: v = virtualinvoke v.(", #queued="); v = virtualinvoke v.(v); v = virtualinvoke v.(", #inflight="); v = virtualinvoke v.(v); virtualinvoke v.(")"); v = virtualinvoke v.(); return v; catch java.lang.Throwable from label to label with label; } boolean isReady() { java.lang.Throwable v; java.util.concurrent.locks.ReentrantLock v, v, v; org.apache.hive.kudu.org.apache.kudu.client.Connection v; org.apache.hive.kudu.org.apache.kudu.client.Connection$State v, v; boolean v; v := @this: org.apache.hive.kudu.org.apache.kudu.client.Connection; v = v.; virtualinvoke v.(); label: v = v.; v = ; if v != v goto label; v = 1; goto label; label: v = 0; label: v = v.; virtualinvoke v.(); return v; label: v := @caughtexception; v = v.; virtualinvoke v.(); throw v; catch java.lang.Throwable from label to label with label; } private void sendCallToWire(org.apache.hive.kudu.org.apache.kudu.client.RpcOutboundMessage) { org.slf4j.Logger v, v; java.util.concurrent.locks.ReentrantLock v; java.lang.AssertionError v; org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPromise v; org.apache.hive.kudu.org.apache.kudu.client.Connection v; org.apache.hive.kudu.org.apache.kudu.client.RpcOutboundMessage v; org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.socket.SocketChannel v, v; java.lang.String v; boolean v, v, v; v := @this: org.apache.hive.kudu.org.apache.kudu.client.Connection; v := @parameter: org.apache.hive.kudu.org.apache.kudu.client.RpcOutboundMessage; v = ; if v != 0 goto label; v = v.; v = virtualinvoke v.(); if v == 0 goto label; v = new java.lang.AssertionError; specialinvoke v.()>(); throw v; label: v = ; v = interfaceinvoke v.(); if v == 0 goto label; v = ; v = virtualinvoke v.(); interfaceinvoke v.("{} sending {}", v, v); label: v = v.; v = v.; v = interfaceinvoke v.(); interfaceinvoke v.(v, v); return; } private void cleanup(org.apache.hive.kudu.org.apache.kudu.client.KuduException) { org.apache.hive.kudu.org.apache.kudu.client.InvalidAuthnTokenException v; org.apache.hive.kudu.com.stumbleupon.async.Callback v; boolean v, v, v, v, v, v, v; java.util.Collection v; org.apache.hive.kudu.org.apache.kudu.client.Connection$CallResponseInfo v, v; java.lang.Exception v, v; org.apache.hive.kudu.org.apache.kudu.client.Connection$State v, v, v, v, v, v; java.lang.Throwable v; java.lang.Object[] v; java.util.HashMap v, v, v; org.apache.hive.kudu.org.apache.kudu.client.Negotiator$Failure v, v; java.util.ArrayList v, v; org.apache.hive.kudu.org.apache.kudu.rpc.RpcHeader$ErrorStatusPB$RpcErrorCodePB v, v; java.lang.String v, v, v, v; org.slf4j.Logger v, v, v; java.util.Iterator v, v; java.util.concurrent.locks.ReentrantLock v, v, v, v; org.apache.hive.kudu.org.apache.kudu.client.Status v; org.apache.hive.kudu.org.apache.kudu.client.Connection v; org.apache.hive.kudu.org.apache.kudu.rpc.RpcHeader$ErrorStatusPB v; java.lang.Object v, v; org.apache.hive.kudu.org.apache.kudu.client.KuduException v; v := @this: org.apache.hive.kudu.org.apache.kudu.client.Connection; v := @parameter: org.apache.hive.kudu.org.apache.kudu.client.KuduException; v = 0; v = v.; virtualinvoke v.(); label: v = v.; v = ; if v != v goto label; v = v.; if v != null goto label; v = 1; goto label; label: v = 0; label: staticinvoke (v); v = v.