public abstract class org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker extends java.lang.Object
{
private static final java.lang.String HTTP_SCHEME_PREFIX;
private static final java.lang.String HTTPS_SCHEME_PREFIX;
protected static final int DEFAULT_FORCE_CLOSE_TIMEOUT_MILLIS;
private final java.net.URI uri;
private final org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocketVersion version;
private volatile boolean handshakeComplete;
private volatile long forceCloseTimeoutMillis;
private volatile int forceCloseInit;
private static final java.util.concurrent.atomic.AtomicIntegerFieldUpdater FORCE_CLOSE_INIT_UPDATER;
private volatile boolean forceCloseComplete;
private final java.lang.String expectedSubprotocol;
private volatile java.lang.String actualSubprotocol;
protected final org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.HttpHeaders customHeaders;
private final int maxFramePayloadLength;
private final boolean absoluteUpgradeUrl;
protected void <init>(java.net.URI, org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocketVersion, java.lang.String, org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.HttpHeaders, int)
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocketVersion v;
int v;
java.lang.String v;
java.net.URI v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.HttpHeaders v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker;
v := @parameter: java.net.URI;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocketVersion;
v := @parameter: java.lang.String;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.HttpHeaders;
v := @parameter: int;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker: void <init>(java.net.URI,org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocketVersion,java.lang.String,org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.HttpHeaders,int,long)>(v, v, v, v, v, 10000L);
return;
}
protected void <init>(java.net.URI, org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocketVersion, java.lang.String, org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.HttpHeaders, int, long)
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocketVersion v;
int v;
long v;
java.lang.String v;
java.net.URI v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.HttpHeaders v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker;
v := @parameter: java.net.URI;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocketVersion;
v := @parameter: java.lang.String;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.HttpHeaders;
v := @parameter: int;
v := @parameter: long;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker: void <init>(java.net.URI,org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocketVersion,java.lang.String,org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.HttpHeaders,int,long,boolean)>(v, v, v, v, v, v, 0);
return;
}
protected void <init>(java.net.URI, org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocketVersion, java.lang.String, org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.HttpHeaders, int, long, boolean)
{
long v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocketVersion v;
int v;
java.lang.String v;
java.net.URI v;
boolean v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.HttpHeaders v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker;
v := @parameter: java.net.URI;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocketVersion;
v := @parameter: java.lang.String;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.HttpHeaders;
v := @parameter: int;
v := @parameter: long;
v := @parameter: boolean;
specialinvoke v.<java.lang.Object: void <init>()>();
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker: long forceCloseTimeoutMillis> = 10000L;
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker: java.net.URI uri> = v;
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocketVersion version> = v;
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker: java.lang.String expectedSubprotocol> = v;
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.HttpHeaders customHeaders> = v;
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker: int maxFramePayloadLength> = v;
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker: long forceCloseTimeoutMillis> = v;
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker: boolean absoluteUpgradeUrl> = v;
return;
}
public java.net.URI uri()
{
java.net.URI v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker: java.net.URI uri>;
return v;
}
public org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocketVersion version()
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocketVersion v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocketVersion version>;
return v;
}
public int maxFramePayloadLength()
{
int v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker: int maxFramePayloadLength>;
return v;
}
public boolean isHandshakeComplete()
{
boolean v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker: boolean handshakeComplete>;
return v;
}
private void setHandshakeComplete()
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker;
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker: boolean handshakeComplete> = 1;
return;
}
public java.lang.String expectedSubprotocol()
{
java.lang.String v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker: java.lang.String expectedSubprotocol>;
return v;
}
public java.lang.String actualSubprotocol()
{
java.lang.String v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker: java.lang.String actualSubprotocol>;
return v;
}
private void setActualSubprotocol(java.lang.String)
{
java.lang.String v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker;
v := @parameter: java.lang.String;
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker: java.lang.String actualSubprotocol> = v;
return;
}
public long forceCloseTimeoutMillis()
{
long v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker: long forceCloseTimeoutMillis>;
return v;
}
protected boolean isForceCloseComplete()
{
boolean v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker: boolean forceCloseComplete>;
return v;
}
public org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker setForceCloseTimeoutMillis(long)
{
long v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker;
v := @parameter: long;
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker: long forceCloseTimeoutMillis> = v;
return v;
}
public org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelFuture handshake(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.Channel)
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPromise v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.Channel v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelFuture v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.Channel;
staticinvoke <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.internal.ObjectUtil: java.lang.Object checkNotNull(java.lang.Object,java.lang.String)>(v, "channel");
v = interfaceinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.Channel: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPromise newPromise()>();
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelFuture handshake(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.Channel,org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPromise)>(v, v);
return v;
}
public final org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelFuture handshake(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.Channel, org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPromise)
{
java.lang.IllegalStateException v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandler 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;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPromise v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPipeline v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.FullHttpRequest v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker$1 v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.Channel;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPromise;
v = interfaceinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.Channel: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPipeline pipeline()>();
v = interfaceinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPipeline: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandler get(java.lang.Class)>(class "Lorg/apache/hive/kudu/org/apache/kudu/shaded/io/netty/handler/codec/http/HttpResponseDecoder;");
if v != null goto label;
v = interfaceinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPipeline: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandler get(java.lang.Class)>(class "Lorg/apache/hive/kudu/org/apache/kudu/shaded/io/netty/handler/codec/http/HttpClientCodec;");
if v != null goto label;
v = new java.lang.IllegalStateException;
specialinvoke v.<java.lang.IllegalStateException: void <init>(java.lang.String)>("ChannelPipeline does not contain an HttpResponseDecoder or HttpClientCodec");
interfaceinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPromise: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPromise setFailure(java.lang.Throwable)>(v);
return v;
label:
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.FullHttpRequest newHandshakeRequest()>();
v = interfaceinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.Channel: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelFuture writeAndFlush(java.lang.Object)>(v);
v = new org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker$1;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker$1: void <init>(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker,org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPromise)>(v, v);
interfaceinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelFuture: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelFuture addListener(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.GenericFutureListener)>(v);
return v;
}
protected abstract org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.FullHttpRequest newHandshakeRequest();
public final void finishHandshake(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.Channel, org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.FullHttpResponse)
{
java.lang.IllegalStateException v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandler v, v, v, v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocketFrameDecoder v, v;
boolean v, 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.handler.codec.http.websocketx.WebSocketClientHandshaker$3 v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPipeline v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker$2 v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.EventLoop v, v;
java.lang.Object[] v;
java.lang.String[] v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.FullHttpResponse v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.AsciiString v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker v;
int v, v;
java.lang.String v, v, v, v, v, v, v, v, v, v, v, v, v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandlerContext v, v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocketHandshakeException v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.HttpHeaders v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.Channel;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.FullHttpResponse;
virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker: void verify(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.FullHttpResponse)>(v);
v = interfaceinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.FullHttpResponse: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.HttpHeaders headers()>();
v = <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.HttpHeaderNames: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.AsciiString SEC_WEBSOCKET_PROTOCOL>;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.HttpHeaders: java.lang.String get(java.lang.CharSequence)>(v);
if v == null goto label;
v = virtualinvoke v.<java.lang.String: java.lang.String trim()>();
goto label;
label:
v = null;
label:
v = v;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker: java.lang.String expectedSubprotocol>;
if v == null goto label;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker: java.lang.String expectedSubprotocol>;
goto label;
label:
v = "";
label:
v = v;
v = 0;
v = virtualinvoke v.<java.lang.String: boolean isEmpty()>();
if v == 0 goto label;
if v != null goto label;
v = 1;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker: java.lang.String expectedSubprotocol>;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker: void setActualSubprotocol(java.lang.String)>(v);
goto label;
label:
v = virtualinvoke v.<java.lang.String: boolean isEmpty()>();
if v != 0 goto label;
if v == null goto label;
v = virtualinvoke v.<java.lang.String: boolean isEmpty()>();
if v != 0 goto label;
v = virtualinvoke v.<java.lang.String: java.lang.String[] split(java.lang.String)>(",");
v = lengthof v;
v = 0;
label:
if v >= v goto label;
v = v[v];
v = virtualinvoke v.<java.lang.String: java.lang.String trim()>();
v = virtualinvoke v.<java.lang.String: boolean equals(java.lang.Object)>(v);
if v == 0 goto label;
v = 1;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker: void setActualSubprotocol(java.lang.String)>(v);
goto label;
label:
v = v + 1;
goto label;
label:
if v != 0 goto label;
v = new org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocketHandshakeException;
v = newarray (java.lang.Object)[2];
v[0] = v;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker: java.lang.String expectedSubprotocol>;
v[1] = v;
v = staticinvoke <java.lang.String: java.lang.String format(java.lang.String,java.lang.Object[])>("Invalid subprotocol. Actual: %s. Expected one of: %s", v);
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocketHandshakeException: void <init>(java.lang.String)>(v);
throw v;
label:
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker: void setHandshakeComplete()>();
v = interfaceinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.Channel: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPipeline pipeline()>();
v = interfaceinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPipeline: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandler get(java.lang.Class)>(class "Lorg/apache/hive/kudu/org/apache/kudu/shaded/io/netty/handler/codec/http/HttpContentDecompressor;");
if v == null goto label;
interfaceinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPipeline: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPipeline remove(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandler)>(v);
label:
v = interfaceinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPipeline: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandler get(java.lang.Class)>(class "Lorg/apache/hive/kudu/org/apache/kudu/shaded/io/netty/handler/codec/http/HttpObjectAggregator;");
if v == null goto label;
interfaceinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPipeline: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPipeline remove(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandler)>(v);
label:
v = interfaceinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPipeline: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandlerContext context(java.lang.Class)>(class "Lorg/apache/hive/kudu/org/apache/kudu/shaded/io/netty/handler/codec/http/HttpResponseDecoder;");
if v != null goto label;
v = interfaceinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPipeline: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandlerContext context(java.lang.Class)>(class "Lorg/apache/hive/kudu/org/apache/kudu/shaded/io/netty/handler/codec/http/HttpClientCodec;");
if v != null goto label;
v = new java.lang.IllegalStateException;
specialinvoke v.<java.lang.IllegalStateException: void <init>(java.lang.String)>("ChannelPipeline does not contain an HttpRequestEncoder or HttpClientCodec");
throw v;
label:
v = interfaceinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandlerContext: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandler handler()>();
virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.HttpClientCodec: void removeOutboundHandler()>();
v = interfaceinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandlerContext: java.lang.String name()>();
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocketFrameDecoder newWebsocketDecoder()>();
interfaceinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPipeline: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPipeline addAfter(java.lang.String,java.lang.String,org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandler)>(v, "ws-decoder", v);
v = interfaceinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.Channel: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.EventLoop eventLoop()>();
v = new org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker$2;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker$2: void <init>(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker,org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPipeline,org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.HttpClientCodec)>(v, v, v);
interfaceinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.EventLoop: void execute(java.lang.Runnable)>(v);
goto label;
label:
v = interfaceinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPipeline: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandler get(java.lang.Class)>(class "Lorg/apache/hive/kudu/org/apache/kudu/shaded/io/netty/handler/codec/http/HttpRequestEncoder;");
if v == null goto label;
interfaceinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPipeline: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandler remove(java.lang.Class)>(class "Lorg/apache/hive/kudu/org/apache/kudu/shaded/io/netty/handler/codec/http/HttpRequestEncoder;");
label:
v = interfaceinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandlerContext: java.lang.String name()>();
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocketFrameDecoder newWebsocketDecoder()>();
interfaceinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPipeline: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPipeline addAfter(java.lang.String,java.lang.String,org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandler)>(v, "ws-decoder", v);
v = interfaceinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.Channel: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.EventLoop eventLoop()>();
v = new org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker$3;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker$3: void <init>(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker,org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPipeline,org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandlerContext)>(v, v, v);
interfaceinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.EventLoop: void execute(java.lang.Runnable)>(v);
label:
return;
}
public final org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelFuture processHandshake(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.Channel, org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.HttpResponse)
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPromise v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.HttpResponse v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.Channel v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelFuture v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.Channel;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.HttpResponse;
v = interfaceinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.Channel: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPromise newPromise()>();
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelFuture processHandshake(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.Channel,org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.HttpResponse,org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPromise)>(v, v, v);
return v;
}
public final org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelFuture processHandshake(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.Channel, org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.HttpResponse, org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPromise)
{
java.lang.Throwable v, v;
java.lang.IllegalStateException v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.Channel v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.HttpObjectAggregator v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker$4 v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPromise v, v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPipeline v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.HttpResponse v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker v;
java.lang.Object v;
java.lang.String v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandlerContext v;
boolean v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.Channel;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.HttpResponse;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPromise;
v = v instanceof org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.FullHttpResponse;
if v == 0 goto label;
label:
virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker: void finishHandshake(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.Channel,org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.FullHttpResponse)>(v, v);
interfaceinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPromise: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPromise setSuccess()>();
label:
goto label;
label:
v := @caughtexception;
interfaceinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPromise: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPromise setFailure(java.lang.Throwable)>(v);
goto label;
label:
v = interfaceinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.Channel: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPipeline pipeline()>();
v = interfaceinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPipeline: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandlerContext context(java.lang.Class)>(class "Lorg/apache/hive/kudu/org/apache/kudu/shaded/io/netty/handler/codec/http/HttpResponseDecoder;");
if v != null goto label;
v = interfaceinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPipeline: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandlerContext context(java.lang.Class)>(class "Lorg/apache/hive/kudu/org/apache/kudu/shaded/io/netty/handler/codec/http/HttpClientCodec;");
if v != null goto label;
v = new java.lang.IllegalStateException;
specialinvoke v.<java.lang.IllegalStateException: void <init>(java.lang.String)>("ChannelPipeline does not contain an HttpResponseDecoder or HttpClientCodec");
v = interfaceinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPromise: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPromise setFailure(java.lang.Throwable)>(v);
return v;
label:
v = interfaceinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandlerContext: java.lang.String name()>();
v = new org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.HttpObjectAggregator;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.HttpObjectAggregator: void <init>(int)>(8192);
interfaceinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPipeline: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPipeline addAfter(java.lang.String,java.lang.String,org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandler)>(v, "httpAggregator", v);
v = new org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker$4;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker$4: void <init>(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker,org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.Channel,org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPromise)>(v, v, v);
interfaceinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPipeline: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPipeline addAfter(java.lang.String,java.lang.String,org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandler)>("httpAggregator", "handshaker", v);
label:
v = staticinvoke <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.ReferenceCountUtil: java.lang.Object retain(java.lang.Object)>(v);
interfaceinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandlerContext: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandlerContext fireChannelRead(java.lang.Object)>(v);
label:
goto label;
label:
v := @caughtexception;
interfaceinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPromise: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPromise setFailure(java.lang.Throwable)>(v);
label:
return v;
catch java.lang.Throwable from label to label with label;
catch java.lang.Throwable from label to label with label;
}
protected abstract void verify(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.FullHttpResponse);
protected abstract org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocketFrameDecoder newWebsocketDecoder();
protected abstract org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocketFrameEncoder newWebSocketEncoder();
public org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelFuture close(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.Channel, org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.CloseWebSocketFrame)
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPromise v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.Channel v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelFuture v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.CloseWebSocketFrame v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.Channel;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.CloseWebSocketFrame;
staticinvoke <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.internal.ObjectUtil: java.lang.Object checkNotNull(java.lang.Object,java.lang.String)>(v, "channel");
v = interfaceinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.Channel: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPromise newPromise()>();
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelFuture close(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.Channel,org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.CloseWebSocketFrame,org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPromise)>(v, v, v);
return v;
}
public org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelFuture close(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.Channel, org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.CloseWebSocketFrame, org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPromise)
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPromise v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.Channel v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.CloseWebSocketFrame v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.Channel;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.CloseWebSocketFrame;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPromise;
staticinvoke <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.internal.ObjectUtil: java.lang.Object checkNotNull(java.lang.Object,java.lang.String)>(v, "channel");
interfaceinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.Channel: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelFuture writeAndFlush(java.lang.Object,org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPromise)>(v, v);
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker: void applyForceCloseTimeout(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.Channel,org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelFuture)>(v, v);
return v;
}
private void applyForceCloseTimeout(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.Channel, org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelFuture)
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.Channel v;
long v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelFuture v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker$5 v;
byte v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker v;
int v;
boolean v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.Channel;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelFuture;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker: long forceCloseTimeoutMillis>;
v = v cmp 0L;
if v <= 0 goto label;
v = interfaceinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.Channel: boolean isActive()>();
if v == 0 goto label;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker: int forceCloseInit>;
if v == 0 goto label;
label:
return;
label:
v = new org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker$5;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker$5: void <init>(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker,org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.Channel,org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker,long)>(v, v, v, v);
interfaceinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelFuture: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelFuture addListener(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.GenericFutureListener)>(v);
return;
}
protected java.lang.String upgradeUrl(java.net.URI)
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker v;
java.lang.String v, v, v, v;
java.net.URI v;
boolean v, v, v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker;
v := @parameter: java.net.URI;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker: boolean absoluteUpgradeUrl>;
if v == 0 goto label;
v = virtualinvoke v.<java.net.URI: java.lang.String toString()>();
return v;
label:
v = virtualinvoke v.<java.net.URI: java.lang.String getRawPath()>();
v = virtualinvoke v.<java.net.URI: java.lang.String getRawQuery()>();
if v == null goto label;
v = virtualinvoke v.<java.lang.String: boolean isEmpty()>();
if v != 0 goto label;
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[])>("\u0001?\u0001");
label:
if v == null goto label;
v = virtualinvoke v.<java.lang.String: boolean isEmpty()>();
if v == 0 goto label;
label:
v = "/";
goto label;
label:
v = v;
label:
return v;
}
static java.lang.CharSequence websocketHostValue(java.net.URI)
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocketScheme v, v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.AsciiString v, v, v, v;
int v, v, v, v;
java.lang.String v, v, v, v, v, v;
java.net.URI v;
boolean v, v, v, v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.HttpScheme v, v, v, v;
v := @parameter: java.net.URI;
v = virtualinvoke v.<java.net.URI: int getPort()>();
v = (int) -1;
if v != v goto label;
v = virtualinvoke v.<java.net.URI: java.lang.String getHost()>();
return v;
label:
v = virtualinvoke v.<java.net.URI: java.lang.String getHost()>();
v = virtualinvoke v.<java.net.URI: java.lang.String getScheme()>();
v = <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.HttpScheme: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.HttpScheme HTTP>;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.HttpScheme: int port()>();
if v != v goto label;
v = <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.HttpScheme: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.HttpScheme HTTP>;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.HttpScheme: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.AsciiString name()>();
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.AsciiString: boolean contentEquals(java.lang.CharSequence)>(v);
if v != 0 goto label;
v = <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocketScheme: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocketScheme WS>;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocketScheme: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.AsciiString name()>();
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.AsciiString: boolean contentEquals(java.lang.CharSequence)>(v);
if v == 0 goto label;
label:
v = v;
goto label;
label:
v = staticinvoke <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.NetUtil: java.lang.String toSocketAddressString(java.lang.String,int)>(v, v);
label:
return v;
label:
v = <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.HttpScheme: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.HttpScheme HTTPS>;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.HttpScheme: int port()>();
if v != v goto label;
v = <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.HttpScheme: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.HttpScheme HTTPS>;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.HttpScheme: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.AsciiString name()>();
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.AsciiString: boolean contentEquals(java.lang.CharSequence)>(v);
if v != 0 goto label;
v = <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocketScheme: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocketScheme WSS>;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocketScheme: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.AsciiString name()>();
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.AsciiString: boolean contentEquals(java.lang.CharSequence)>(v);
if v == 0 goto label;
label:
v = v;
goto label;
label:
v = staticinvoke <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.NetUtil: java.lang.String toSocketAddressString(java.lang.String,int)>(v, v);
label:
return v;
label:
v = staticinvoke <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.NetUtil: java.lang.String toSocketAddressString(java.lang.String,int)>(v, v);
return v;
}
static java.lang.CharSequence websocketOriginValue(java.net.URI)
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocketScheme v, v, v, v;
java.util.Locale v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.AsciiString v, v;
int v, v, v, v;
java.lang.String v, v, v, v, v, v, v;
java.net.URI v;
boolean v, v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.HttpScheme v;
v := @parameter: java.net.URI;
v = virtualinvoke v.<java.net.URI: java.lang.String getScheme()>();
v = virtualinvoke v.<java.net.URI: int getPort()>();
v = <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocketScheme: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocketScheme WSS>;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocketScheme: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.AsciiString name()>();
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.AsciiString: boolean contentEquals(java.lang.CharSequence)>(v);
if v != 0 goto label;
v = <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.HttpScheme: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.HttpScheme HTTPS>;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.HttpScheme: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.AsciiString name()>();
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.AsciiString: boolean contentEquals(java.lang.CharSequence)>(v);
if v != 0 goto label;
if v != null goto label;
v = <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocketScheme: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocketScheme WSS>;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocketScheme: int port()>();
if v != v goto label;
label:
v = <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker: java.lang.String HTTPS_SCHEME_PREFIX>;
v = <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocketScheme: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocketScheme WSS>;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocketScheme: int port()>();
goto label;
label:
v = <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker: java.lang.String HTTP_SCHEME_PREFIX>;
v = <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocketScheme: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocketScheme WS>;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocketScheme: int port()>();
label:
v = virtualinvoke v.<java.net.URI: java.lang.String getHost()>();
v = <java.util.Locale: java.util.Locale US>;
v = virtualinvoke v.<java.lang.String: java.lang.String toLowerCase(java.util.Locale)>(v);
if v == v goto label;
v = (int) -1;
if v == v goto label;
v = staticinvoke <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.NetUtil: java.lang.String toSocketAddressString(java.lang.String,int)>(v, 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[])>("\u0001\u0001");
return v;
label:
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[])>("\u0001\u0001");
return v;
}
static void <clinit>()
{
java.util.concurrent.atomic.AtomicIntegerFieldUpdater v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.HttpScheme v, v;
java.lang.String v, v;
v = <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.HttpScheme: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.HttpScheme HTTP>;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.HttpScheme)>(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[])>("\u0001://");
<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker: java.lang.String HTTP_SCHEME_PREFIX> = v;
v = <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.HttpScheme: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.HttpScheme HTTPS>;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.HttpScheme)>(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[])>("\u0001://");
<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker: java.lang.String HTTPS_SCHEME_PREFIX> = v;
v = staticinvoke <java.util.concurrent.atomic.AtomicIntegerFieldUpdater: java.util.concurrent.atomic.AtomicIntegerFieldUpdater newUpdater(java.lang.Class,java.lang.String)>(class "Lorg/apache/hive/kudu/org/apache/kudu/shaded/io/netty/handler/codec/http/websocketx/WebSocketClientHandshaker;", "forceCloseInit");
<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker: java.util.concurrent.atomic.AtomicIntegerFieldUpdater FORCE_CLOSE_INIT_UPDATER> = v;
return;
}
}