class org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocketClientProtocolHandshakeHandler extends org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelInboundHandlerAdapter
{
private static final long DEFAULT_HANDSHAKE_TIMEOUT_MS;
private final org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker handshaker;
private final long handshakeTimeoutMillis;
private org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandlerContext ctx;
private org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPromise handshakePromise;
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.handler.codec.http.websocketx.WebSocketClientProtocolHandshakeHandler 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.WebSocketClientProtocolHandshakeHandler;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocketClientProtocolHandshakeHandler: void <init>(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker,long)>(v, 10000L);
return;
}
void <init>(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker, long)
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker v;
long v, v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocketClientProtocolHandshakeHandler v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocketClientProtocolHandshakeHandler;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker;
v := @parameter: long;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelInboundHandlerAdapter: void <init>()>();
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocketClientProtocolHandshakeHandler: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker handshaker> = v;
v = staticinvoke <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.internal.ObjectUtil: long checkPositive(long,java.lang.String)>(v, "handshakeTimeoutMillis");
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocketClientProtocolHandshakeHandler: long handshakeTimeoutMillis> = v;
return;
}
public void handlerAdded(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandlerContext) throws java.lang.Exception
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPromise v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandlerContext v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocketClientProtocolHandshakeHandler v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocketClientProtocolHandshakeHandler;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandlerContext;
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocketClientProtocolHandshakeHandler: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandlerContext ctx> = v;
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.ChannelPromise newPromise()>();
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocketClientProtocolHandshakeHandler: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPromise handshakePromise> = v;
return;
}
public void channelActive(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandlerContext) throws java.lang.Exception
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocketClientProtocolHandshakeHandler$1 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.ChannelHandlerContext v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocketClientProtocolHandshakeHandler 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.WebSocketClientProtocolHandshakeHandler;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandlerContext;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelInboundHandlerAdapter: void channelActive(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandlerContext)>(v);
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocketClientProtocolHandshakeHandler: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker handshaker>;
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.Channel channel()>();
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)>(v);
v = new org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocketClientProtocolHandshakeHandler$1;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocketClientProtocolHandshakeHandler$1: void <init>(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocketClientProtocolHandshakeHandler,org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandlerContext)>(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);
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocketClientProtocolHandshakeHandler: void applyHandshakeTimeout()>();
return;
}
public void channelRead(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandlerContext, java.lang.Object) throws java.lang.Exception
{
java.lang.Throwable 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.websocketx.WebSocketClientProtocolHandler$ClientHandshakeStateEvent 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.websocketx.WebSocketClientHandshaker v, v;
java.lang.Object v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandlerContext v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocketClientProtocolHandshakeHandler v;
boolean v, v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocketClientProtocolHandshakeHandler;
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.shaded.io.netty.handler.codec.http.FullHttpResponse;
if v != 0 goto label;
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);
return;
label:
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocketClientProtocolHandshakeHandler: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker handshaker>;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker: boolean isHandshakeComplete()>();
if v != 0 goto label;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocketClientProtocolHandshakeHandler: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker handshaker>;
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.Channel channel()>();
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);
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocketClientProtocolHandshakeHandler: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPromise handshakePromise>;
interfaceinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPromise: boolean trySuccess()>();
v = <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocketClientProtocolHandler$ClientHandshakeStateEvent: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocketClientProtocolHandler$ClientHandshakeStateEvent HANDSHAKE_COMPLETE>;
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 fireUserEventTriggered(java.lang.Object)>(v);
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.ChannelPipeline pipeline()>();
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:
interfaceinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.FullHttpResponse: boolean release()>();
return;
label:
v = new java.lang.IllegalStateException;
specialinvoke v.<java.lang.IllegalStateException: void <init>(java.lang.String)>("WebSocketClientHandshaker should have been non finished yet");
throw v;
label:
v := @caughtexception;
interfaceinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.FullHttpResponse: boolean release()>();
throw v;
catch java.lang.Throwable from label to label with label;
}
private void applyHandshakeTimeout()
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.EventExecutor v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocketClientProtocolHandshakeHandler$2 v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocketClientProtocolHandshakeHandler$3 v;
long v, v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.ScheduledFuture v;
java.util.concurrent.TimeUnit v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPromise v;
byte v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandlerContext v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocketClientProtocolHandshakeHandler v;
boolean v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocketClientProtocolHandshakeHandler;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocketClientProtocolHandshakeHandler: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPromise handshakePromise>;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocketClientProtocolHandshakeHandler: long handshakeTimeoutMillis>;
v = v cmp 0L;
if v <= 0 goto label;
v = interfaceinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPromise: boolean isDone()>();
if v == 0 goto label;
label:
return;
label:
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocketClientProtocolHandshakeHandler: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandlerContext ctx>;
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.util.concurrent.EventExecutor executor()>();
v = new org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocketClientProtocolHandshakeHandler$2;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocketClientProtocolHandshakeHandler$2: void <init>(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocketClientProtocolHandshakeHandler,org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPromise)>(v, v);
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocketClientProtocolHandshakeHandler: long handshakeTimeoutMillis>;
v = <java.util.concurrent.TimeUnit: java.util.concurrent.TimeUnit MILLISECONDS>;
v = interfaceinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.EventExecutor: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.ScheduledFuture schedule(java.lang.Runnable,long,java.util.concurrent.TimeUnit)>(v, v, v);
v = new org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocketClientProtocolHandshakeHandler$3;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocketClientProtocolHandshakeHandler$3: void <init>(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocketClientProtocolHandshakeHandler,org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.Future)>(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 addListener(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.GenericFutureListener)>(v);
return;
}
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelFuture getHandshakeFuture()
{
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.websocketx.WebSocketClientProtocolHandshakeHandler v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocketClientProtocolHandshakeHandler;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocketClientProtocolHandshakeHandler: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPromise handshakePromise>;
return v;
}
}