class io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker$4 extends io.netty.channel.ChannelInboundHandlerAdapter
{
private io.netty.handler.codec.http.FullHttpResponse fullHttpResponse;
static final boolean $assertionsDisabled;
final io.netty.channel.ChannelPromise val$promise;
final io.netty.channel.Channel val$channel;
final io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker this$0;
void <init>(io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker, io.netty.channel.ChannelPromise, io.netty.channel.Channel)
{
io.netty.channel.Channel v;
io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker$4 v;
io.netty.channel.ChannelPromise v;
io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker v;
v := @this: io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker$4;
v := @parameter: io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker;
v := @parameter: io.netty.channel.ChannelPromise;
v := @parameter: io.netty.channel.Channel;
v.<io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker$4: io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker this$0> = v;
v.<io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker$4: io.netty.channel.ChannelPromise val$promise> = v;
v.<io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker$4: io.netty.channel.Channel val$channel> = v;
specialinvoke v.<io.netty.channel.ChannelInboundHandlerAdapter: void <init>()>();
return;
}
public void channelRead(io.netty.channel.ChannelHandlerContext, java.lang.Object) throws java.lang.Exception
{
java.lang.Throwable v;
io.netty.channel.ChannelHandlerContext v;
io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker$4 v;
java.lang.Object v;
boolean v;
v := @this: io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker$4;
v := @parameter: io.netty.channel.ChannelHandlerContext;
v := @parameter: java.lang.Object;
v = v instanceof io.netty.handler.codec.http.HttpObject;
if v == 0 goto label;
label:
specialinvoke v.<io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker$4: void handleHandshakeResponse(io.netty.channel.ChannelHandlerContext,io.netty.handler.codec.http.HttpObject)>(v, v);
label:
staticinvoke <io.netty.util.ReferenceCountUtil: boolean release(java.lang.Object)>(v);
goto label;
label:
v := @caughtexception;
staticinvoke <io.netty.util.ReferenceCountUtil: boolean release(java.lang.Object)>(v);
throw v;
label:
specialinvoke v.<io.netty.channel.ChannelInboundHandlerAdapter: void channelRead(io.netty.channel.ChannelHandlerContext,java.lang.Object)>(v, v);
label:
return;
catch java.lang.Throwable from label to label with label;
}
public void exceptionCaught(io.netty.channel.ChannelHandlerContext, java.lang.Throwable) throws java.lang.Exception
{
java.lang.Throwable v;
io.netty.channel.ChannelHandlerContext v;
io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker$4 v;
io.netty.channel.ChannelPromise v;
io.netty.channel.ChannelPipeline v;
v := @this: io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker$4;
v := @parameter: io.netty.channel.ChannelHandlerContext;
v := @parameter: java.lang.Throwable;
v = interfaceinvoke v.<io.netty.channel.ChannelHandlerContext: io.netty.channel.ChannelPipeline pipeline()>();
interfaceinvoke v.<io.netty.channel.ChannelPipeline: io.netty.channel.ChannelPipeline remove(io.netty.channel.ChannelHandler)>(v);
v = v.<io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker$4: io.netty.channel.ChannelPromise val$promise>;
interfaceinvoke v.<io.netty.channel.ChannelPromise: io.netty.channel.ChannelPromise setFailure(java.lang.Throwable)>(v);
return;
}
public void channelInactive(io.netty.channel.ChannelHandlerContext) throws java.lang.Exception
{
java.lang.Throwable v;
io.netty.channel.ChannelHandlerContext v;
io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker$4 v;
io.netty.channel.ChannelPromise v, v;
java.nio.channels.ClosedChannelException v;
boolean v;
v := @this: io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker$4;
v := @parameter: io.netty.channel.ChannelHandlerContext;
label:
v = v.<io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker$4: io.netty.channel.ChannelPromise val$promise>;
v = interfaceinvoke v.<io.netty.channel.ChannelPromise: boolean isDone()>();
if v != 0 goto label;
v = v.<io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker$4: io.netty.channel.ChannelPromise val$promise>;
v = new java.nio.channels.ClosedChannelException;
specialinvoke v.<java.nio.channels.ClosedChannelException: void <init>()>();
interfaceinvoke v.<io.netty.channel.ChannelPromise: boolean tryFailure(java.lang.Throwable)>(v);
label:
interfaceinvoke v.<io.netty.channel.ChannelHandlerContext: io.netty.channel.ChannelHandlerContext fireChannelInactive()>();
label:
specialinvoke v.<io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker$4: void releaseFullHttpResponse()>();
goto label;
label:
v := @caughtexception;
specialinvoke v.<io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker$4: void releaseFullHttpResponse()>();
throw v;
label:
return;
catch java.lang.Throwable from label to label with label;
}
public void handlerRemoved(io.netty.channel.ChannelHandlerContext) throws java.lang.Exception
{
io.netty.channel.ChannelHandlerContext v;
io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker$4 v;
v := @this: io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker$4;
v := @parameter: io.netty.channel.ChannelHandlerContext;
specialinvoke v.<io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker$4: void releaseFullHttpResponse()>();
return;
}
private void handleHandshakeResponse(io.netty.channel.ChannelHandlerContext, io.netty.handler.codec.http.HttpObject)
{
java.lang.Throwable v;
io.netty.handler.codec.http.HttpVersion v;
io.netty.handler.codec.http.HttpHeaders v;
java.lang.AssertionError v;
io.netty.handler.codec.http.HttpObject v;
io.netty.channel.ChannelHandlerContext v;
io.netty.buffer.ByteBuf v;
boolean v, v, v, v, v;
io.netty.handler.codec.http.HttpResponseStatus v;
io.netty.channel.ChannelPipeline v, v;
io.netty.handler.codec.http.EmptyHttpHeaders v;
io.netty.handler.codec.http.FullHttpResponse v, v, v;
io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker$4 v;
io.netty.handler.codec.DecoderResult v, v;
io.netty.handler.codec.http.DefaultFullHttpResponse v;
v := @this: io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker$4;
v := @parameter: io.netty.channel.ChannelHandlerContext;
v := @parameter: io.netty.handler.codec.http.HttpObject;
v = v instanceof io.netty.handler.codec.http.FullHttpResponse;
if v == 0 goto label;
v = interfaceinvoke v.<io.netty.channel.ChannelHandlerContext: io.netty.channel.ChannelPipeline pipeline()>();
interfaceinvoke v.<io.netty.channel.ChannelPipeline: io.netty.channel.ChannelPipeline remove(io.netty.channel.ChannelHandler)>(v);
specialinvoke v.<io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker$4: void tryFinishHandshake(io.netty.handler.codec.http.FullHttpResponse)>(v);
return;
label:
v = v instanceof io.netty.handler.codec.http.LastHttpContent;
if v == 0 goto label;
v = <io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker$4: boolean $assertionsDisabled>;
if v != 0 goto label;
v = v.<io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker$4: io.netty.handler.codec.http.FullHttpResponse fullHttpResponse>;
if v != null goto label;
v = new java.lang.AssertionError;
specialinvoke v.<java.lang.AssertionError: void <init>()>();
throw v;
label:
v = v.<io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker$4: io.netty.handler.codec.http.FullHttpResponse fullHttpResponse>;
v.<io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker$4: io.netty.handler.codec.http.FullHttpResponse fullHttpResponse> = null;
label:
v = interfaceinvoke v.<io.netty.channel.ChannelHandlerContext: io.netty.channel.ChannelPipeline pipeline()>();
interfaceinvoke v.<io.netty.channel.ChannelPipeline: io.netty.channel.ChannelPipeline remove(io.netty.channel.ChannelHandler)>(v);
specialinvoke v.<io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker$4: void tryFinishHandshake(io.netty.handler.codec.http.FullHttpResponse)>(v);
label:
interfaceinvoke v.<io.netty.handler.codec.http.FullHttpResponse: boolean release()>();
goto label;
label:
v := @caughtexception;
interfaceinvoke v.<io.netty.handler.codec.http.FullHttpResponse: boolean release()>();
throw v;
label:
return;
label:
v = v instanceof io.netty.handler.codec.http.HttpResponse;
if v == 0 goto label;
v = new io.netty.handler.codec.http.DefaultFullHttpResponse;
v = interfaceinvoke v.<io.netty.handler.codec.http.HttpResponse: io.netty.handler.codec.http.HttpVersion protocolVersion()>();
v = interfaceinvoke v.<io.netty.handler.codec.http.HttpResponse: io.netty.handler.codec.http.HttpResponseStatus status()>();
v = <io.netty.buffer.Unpooled: io.netty.buffer.ByteBuf EMPTY_BUFFER>;
v = interfaceinvoke v.<io.netty.handler.codec.http.HttpResponse: io.netty.handler.codec.http.HttpHeaders headers()>();
v = <io.netty.handler.codec.http.EmptyHttpHeaders: io.netty.handler.codec.http.EmptyHttpHeaders INSTANCE>;
specialinvoke v.<io.netty.handler.codec.http.DefaultFullHttpResponse: void <init>(io.netty.handler.codec.http.HttpVersion,io.netty.handler.codec.http.HttpResponseStatus,io.netty.buffer.ByteBuf,io.netty.handler.codec.http.HttpHeaders,io.netty.handler.codec.http.HttpHeaders)>(v, v, v, v, v);
v.<io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker$4: io.netty.handler.codec.http.FullHttpResponse fullHttpResponse> = v;
v = interfaceinvoke v.<io.netty.handler.codec.http.HttpResponse: io.netty.handler.codec.DecoderResult decoderResult()>();
v = virtualinvoke v.<io.netty.handler.codec.DecoderResult: boolean isFailure()>();
if v == 0 goto label;
v = v.<io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker$4: io.netty.handler.codec.http.FullHttpResponse fullHttpResponse>;
v = interfaceinvoke v.<io.netty.handler.codec.http.HttpResponse: io.netty.handler.codec.DecoderResult decoderResult()>();
interfaceinvoke v.<io.netty.handler.codec.http.FullHttpResponse: void setDecoderResult(io.netty.handler.codec.DecoderResult)>(v);
label:
return;
catch java.lang.Throwable from label to label with label;
}
private void tryFinishHandshake(io.netty.handler.codec.http.FullHttpResponse)
{
io.netty.channel.Channel v;
java.lang.Throwable v;
io.netty.handler.codec.http.FullHttpResponse v;
io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker$4 v;
io.netty.channel.ChannelPromise v, v;
io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker v;
v := @this: io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker$4;
v := @parameter: io.netty.handler.codec.http.FullHttpResponse;
label:
v = v.<io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker$4: io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker this$0>;
v = v.<io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker$4: io.netty.channel.Channel val$channel>;
virtualinvoke v.<io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker: void finishHandshake(io.netty.channel.Channel,io.netty.handler.codec.http.FullHttpResponse)>(v, v);
v = v.<io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker$4: io.netty.channel.ChannelPromise val$promise>;
interfaceinvoke v.<io.netty.channel.ChannelPromise: io.netty.channel.ChannelPromise setSuccess()>();
label:
goto label;
label:
v := @caughtexception;
v = v.<io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker$4: io.netty.channel.ChannelPromise val$promise>;
interfaceinvoke v.<io.netty.channel.ChannelPromise: io.netty.channel.ChannelPromise setFailure(java.lang.Throwable)>(v);
label:
return;
catch java.lang.Throwable from label to label with label;
}
private void releaseFullHttpResponse()
{
io.netty.handler.codec.http.FullHttpResponse v, v;
io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker$4 v;
v := @this: io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker$4;
v = v.<io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker$4: io.netty.handler.codec.http.FullHttpResponse fullHttpResponse>;
if v == null goto label;
v = v.<io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker$4: io.netty.handler.codec.http.FullHttpResponse fullHttpResponse>;
interfaceinvoke v.<io.netty.handler.codec.http.FullHttpResponse: boolean release()>();
v.<io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker$4: io.netty.handler.codec.http.FullHttpResponse fullHttpResponse> = null;
label:
return;
}
static void <clinit>()
{
java.lang.Class v;
boolean v, v;
v = class "Lio/netty/handler/codec/http/websocketx/WebSocketClientHandshaker;";
v = virtualinvoke v.<java.lang.Class: boolean desiredAssertionStatus()>();
if v != 0 goto label;
v = 1;
goto label;
label:
v = 0;
label:
<io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker$4: boolean $assertionsDisabled> = v;
return;
}
}