public abstract class 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 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 io.netty.handler.codec.http.HttpHeaders customHeaders;
private final int maxFramePayloadLength;
private final boolean absoluteUpgradeUrl;
protected final boolean generateOriginHeader;
protected void <init>(java.net.URI, io.netty.handler.codec.http.websocketx.WebSocketVersion, java.lang.String, io.netty.handler.codec.http.HttpHeaders, int)
{
io.netty.handler.codec.http.websocketx.WebSocketVersion v;
io.netty.handler.codec.http.HttpHeaders v;
io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker v;
int v;
java.lang.String v;
java.net.URI v;
v := @this: io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker;
v := @parameter: java.net.URI;
v := @parameter: io.netty.handler.codec.http.websocketx.WebSocketVersion;
v := @parameter: java.lang.String;
v := @parameter: io.netty.handler.codec.http.HttpHeaders;
v := @parameter: int;
specialinvoke v.<io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker: void <init>(java.net.URI,io.netty.handler.codec.http.websocketx.WebSocketVersion,java.lang.String,io.netty.handler.codec.http.HttpHeaders,int,long)>(v, v, v, v, v, 10000L);
return;
}
protected void <init>(java.net.URI, io.netty.handler.codec.http.websocketx.WebSocketVersion, java.lang.String, io.netty.handler.codec.http.HttpHeaders, int, long)
{
io.netty.handler.codec.http.websocketx.WebSocketVersion v;
io.netty.handler.codec.http.HttpHeaders v;
io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker v;
int v;
long v;
java.lang.String v;
java.net.URI v;
v := @this: io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker;
v := @parameter: java.net.URI;
v := @parameter: io.netty.handler.codec.http.websocketx.WebSocketVersion;
v := @parameter: java.lang.String;
v := @parameter: io.netty.handler.codec.http.HttpHeaders;
v := @parameter: int;
v := @parameter: long;
specialinvoke v.<io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker: void <init>(java.net.URI,io.netty.handler.codec.http.websocketx.WebSocketVersion,java.lang.String,io.netty.handler.codec.http.HttpHeaders,int,long,boolean)>(v, v, v, v, v, v, 0);
return;
}
protected void <init>(java.net.URI, io.netty.handler.codec.http.websocketx.WebSocketVersion, java.lang.String, io.netty.handler.codec.http.HttpHeaders, int, long, boolean)
{
io.netty.handler.codec.http.HttpHeaders v;
long v;
io.netty.handler.codec.http.websocketx.WebSocketVersion v;
io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker v;
int v;
java.lang.String v;
java.net.URI v;
boolean v;
v := @this: io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker;
v := @parameter: java.net.URI;
v := @parameter: io.netty.handler.codec.http.websocketx.WebSocketVersion;
v := @parameter: java.lang.String;
v := @parameter: io.netty.handler.codec.http.HttpHeaders;
v := @parameter: int;
v := @parameter: long;
v := @parameter: boolean;
specialinvoke v.<io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker: void <init>(java.net.URI,io.netty.handler.codec.http.websocketx.WebSocketVersion,java.lang.String,io.netty.handler.codec.http.HttpHeaders,int,long,boolean,boolean)>(v, v, v, v, v, v, v, 1);
return;
}
protected void <init>(java.net.URI, io.netty.handler.codec.http.websocketx.WebSocketVersion, java.lang.String, io.netty.handler.codec.http.HttpHeaders, int, long, boolean, boolean)
{
io.netty.handler.codec.http.HttpHeaders v;
long v;
io.netty.handler.codec.http.websocketx.WebSocketVersion v;
io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker v;
int v;
java.lang.String v;
java.net.URI v;
boolean v, v;
v := @this: io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker;
v := @parameter: java.net.URI;
v := @parameter: io.netty.handler.codec.http.websocketx.WebSocketVersion;
v := @parameter: java.lang.String;
v := @parameter: io.netty.handler.codec.http.HttpHeaders;
v := @parameter: int;
v := @parameter: long;
v := @parameter: boolean;
v := @parameter: boolean;
specialinvoke v.<java.lang.Object: void <init>()>();
v.<io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker: long forceCloseTimeoutMillis> = 10000L;
v.<io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker: java.net.URI uri> = v;
v.<io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker: io.netty.handler.codec.http.websocketx.WebSocketVersion version> = v;
v.<io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker: java.lang.String expectedSubprotocol> = v;
v.<io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker: io.netty.handler.codec.http.HttpHeaders customHeaders> = v;
v.<io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker: int maxFramePayloadLength> = v;
v.<io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker: long forceCloseTimeoutMillis> = v;
v.<io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker: boolean absoluteUpgradeUrl> = v;
v.<io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker: boolean generateOriginHeader> = v;
return;
}
public java.net.URI uri()
{
java.net.URI v;
io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker v;
v := @this: io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker;
v = v.<io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker: java.net.URI uri>;
return v;
}
public io.netty.handler.codec.http.websocketx.WebSocketVersion version()
{
io.netty.handler.codec.http.websocketx.WebSocketVersion v;
io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker v;
v := @this: io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker;
v = v.<io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker: io.netty.handler.codec.http.websocketx.WebSocketVersion version>;
return v;
}
public int maxFramePayloadLength()
{
int v;
io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker v;
v := @this: io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker;
v = v.<io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker: int maxFramePayloadLength>;
return v;
}
public boolean isHandshakeComplete()
{
boolean v;
io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker v;
v := @this: io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker;
v = v.<io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker: boolean handshakeComplete>;
return v;
}
private void setHandshakeComplete()
{
io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker v;
v := @this: io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker;
v.<io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker: boolean handshakeComplete> = 1;
return;
}
public java.lang.String expectedSubprotocol()
{
java.lang.String v;
io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker v;
v := @this: io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker;
v = v.<io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker: java.lang.String expectedSubprotocol>;
return v;
}
public java.lang.String actualSubprotocol()
{
java.lang.String v;
io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker v;
v := @this: io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker;
v = v.<io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker: java.lang.String actualSubprotocol>;
return v;
}
private void setActualSubprotocol(java.lang.String)
{
java.lang.String v;
io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker v;
v := @this: io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker;
v := @parameter: java.lang.String;
v.<io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker: java.lang.String actualSubprotocol> = v;
return;
}
public long forceCloseTimeoutMillis()
{
long v;
io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker v;
v := @this: io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker;
v = v.<io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker: long forceCloseTimeoutMillis>;
return v;
}
protected boolean isForceCloseComplete()
{
boolean v;
io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker v;
v := @this: io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker;
v = v.<io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker: boolean forceCloseComplete>;
return v;
}
public io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker setForceCloseTimeoutMillis(long)
{
long v;
io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker v;
v := @this: io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker;
v := @parameter: long;
v.<io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker: long forceCloseTimeoutMillis> = v;
return v;
}
public io.netty.channel.ChannelFuture handshake(io.netty.channel.Channel)
{
io.netty.channel.Channel v;
io.netty.channel.ChannelPromise v;
io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker v;
io.netty.channel.ChannelFuture v;
v := @this: io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker;
v := @parameter: io.netty.channel.Channel;
staticinvoke <io.netty.util.internal.ObjectUtil: java.lang.Object checkNotNull(java.lang.Object,java.lang.String)>(v, "channel");
v = interfaceinvoke v.<io.netty.channel.Channel: io.netty.channel.ChannelPromise newPromise()>();
v = virtualinvoke v.<io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker: io.netty.channel.ChannelFuture handshake(io.netty.channel.Channel,io.netty.channel.ChannelPromise)>(v, v);
return v;
}
public final io.netty.channel.ChannelFuture handshake(io.netty.channel.Channel, io.netty.channel.ChannelPromise)
{
java.lang.IllegalStateException v;
io.netty.handler.codec.http.HttpHeaders v, v, v;
io.netty.util.AsciiString v, v, v, v;
io.netty.handler.codec.http.websocketx.WebSocketVersion v, v, v, v;
io.netty.channel.ChannelPromise v;
java.lang.String v, v, v;
java.net.URI v;
boolean v, v, v;
io.netty.channel.ChannelPipeline v;
java.lang.IllegalArgumentException v, v;
io.netty.handler.codec.http.FullHttpRequest v;
io.netty.channel.ChannelFuture v;
io.netty.channel.Channel v;
io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker$1 v;
io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker v;
io.netty.channel.ChannelHandler v, v;
v := @this: io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker;
v := @parameter: io.netty.channel.Channel;
v := @parameter: io.netty.channel.ChannelPromise;
v = interfaceinvoke v.<io.netty.channel.Channel: io.netty.channel.ChannelPipeline pipeline()>();
v = interfaceinvoke v.<io.netty.channel.ChannelPipeline: io.netty.channel.ChannelHandler get(java.lang.Class)>(class "Lio/netty/handler/codec/http/HttpResponseDecoder;");
if v != null goto label;
v = interfaceinvoke v.<io.netty.channel.ChannelPipeline: io.netty.channel.ChannelHandler get(java.lang.Class)>(class "Lio/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.<io.netty.channel.ChannelPromise: io.netty.channel.ChannelPromise setFailure(java.lang.Throwable)>(v);
return v;
label:
v = v.<io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker: java.net.URI uri>;
v = virtualinvoke v.<java.net.URI: java.lang.String getHost()>();
if v != null goto label;
v = v.<io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker: io.netty.handler.codec.http.HttpHeaders customHeaders>;
if v == null goto label;
v = v.<io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker: io.netty.handler.codec.http.HttpHeaders customHeaders>;
v = <io.netty.handler.codec.http.HttpHeaderNames: io.netty.util.AsciiString HOST>;
v = virtualinvoke v.<io.netty.handler.codec.http.HttpHeaders: boolean contains(java.lang.CharSequence)>(v);
if v != 0 goto label;
label:
v = new java.lang.IllegalArgumentException;
specialinvoke v.<java.lang.IllegalArgumentException: void <init>(java.lang.String)>("Cannot generate the \'host\' header value, webSocketURI should contain host or passed through customHeaders");
interfaceinvoke v.<io.netty.channel.ChannelPromise: io.netty.channel.ChannelPromise setFailure(java.lang.Throwable)>(v);
return v;
label:
v = v.<io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker: boolean generateOriginHeader>;
if v == 0 goto label;
v = v.<io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker: io.netty.handler.codec.http.HttpHeaders customHeaders>;
v = <io.netty.handler.codec.http.HttpHeaderNames: io.netty.util.AsciiString ORIGIN>;
v = virtualinvoke v.<io.netty.handler.codec.http.HttpHeaders: boolean contains(java.lang.CharSequence)>(v);
if v != 0 goto label;
v = v.<io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker: io.netty.handler.codec.http.websocketx.WebSocketVersion version>;
v = <io.netty.handler.codec.http.websocketx.WebSocketVersion: io.netty.handler.codec.http.websocketx.WebSocketVersion V07>;
if v == v goto label;
v = v.<io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker: io.netty.handler.codec.http.websocketx.WebSocketVersion version>;
v = <io.netty.handler.codec.http.websocketx.WebSocketVersion: io.netty.handler.codec.http.websocketx.WebSocketVersion V08>;
if v != v goto label;
label:
v = <io.netty.handler.codec.http.HttpHeaderNames: io.netty.util.AsciiString SEC_WEBSOCKET_ORIGIN>;
v = virtualinvoke v.<io.netty.util.AsciiString: java.lang.String toString()>();
goto label;
label:
v = <io.netty.handler.codec.http.HttpHeaderNames: io.netty.util.AsciiString ORIGIN>;
v = virtualinvoke v.<io.netty.util.AsciiString: java.lang.String toString()>();
label:
v = new java.lang.IllegalArgumentException;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("Cannot generate the \'\u0001\' header value, webSocketURI should contain host or disable generateOriginHeader or pass value through customHeaders");
specialinvoke v.<java.lang.IllegalArgumentException: void <init>(java.lang.String)>(v);
interfaceinvoke v.<io.netty.channel.ChannelPromise: io.netty.channel.ChannelPromise setFailure(java.lang.Throwable)>(v);
return v;
label:
v = virtualinvoke v.<io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker: io.netty.handler.codec.http.FullHttpRequest newHandshakeRequest()>();
v = interfaceinvoke v.<io.netty.channel.Channel: io.netty.channel.ChannelFuture writeAndFlush(java.lang.Object)>(v);
v = new io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker$1;
specialinvoke v.<io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker$1: void <init>(io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker,io.netty.channel.ChannelPromise)>(v, v);
interfaceinvoke v.<io.netty.channel.ChannelFuture: io.netty.channel.ChannelFuture addListener(io.netty.util.concurrent.GenericFutureListener)>(v);
return v;
}
protected abstract io.netty.handler.codec.http.FullHttpRequest newHandshakeRequest();
public final void finishHandshake(io.netty.channel.Channel, io.netty.handler.codec.http.FullHttpResponse)
{
java.lang.IllegalStateException v;
io.netty.handler.codec.http.HttpHeaders v;
io.netty.util.AsciiString v;
io.netty.handler.codec.http.websocketx.WebSocketFrameDecoder v, v;
boolean v, v, v, v, v;
io.netty.handler.codec.http.websocketx.WebSocketClientHandshakeException v;
io.netty.channel.ChannelPipeline v;
io.netty.channel.EventLoop v, v;
java.lang.Object[] v;
java.lang.String[] v;
io.netty.channel.ChannelHandlerContext v, v;
int v, v;
java.lang.String v, v, v, v, v, v, v, v, v, v, v, v, v;
io.netty.channel.Channel v;
io.netty.handler.codec.http.FullHttpResponse v;
io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker$3 v;
io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker$2 v;
io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker v;
io.netty.channel.ChannelHandler v, v, v, v;
v := @this: io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker;
v := @parameter: io.netty.channel.Channel;
v := @parameter: io.netty.handler.codec.http.FullHttpResponse;
virtualinvoke v.<io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker: void verify(io.netty.handler.codec.http.FullHttpResponse)>(v);
v = interfaceinvoke v.<io.netty.handler.codec.http.FullHttpResponse: io.netty.handler.codec.http.HttpHeaders headers()>();
v = <io.netty.handler.codec.http.HttpHeaderNames: io.netty.util.AsciiString SEC_WEBSOCKET_PROTOCOL>;
v = virtualinvoke v.<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.<io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker: java.lang.String expectedSubprotocol>;
if v == null goto label;
v = v.<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.<io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker: java.lang.String expectedSubprotocol>;
specialinvoke v.<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.<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 io.netty.handler.codec.http.websocketx.WebSocketClientHandshakeException;
v = newarray (java.lang.Object)[2];
v[0] = v;
v = v.<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.<io.netty.handler.codec.http.websocketx.WebSocketClientHandshakeException: void <init>(java.lang.String,io.netty.handler.codec.http.HttpResponse)>(v, v);
throw v;
label:
specialinvoke v.<io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker: void setHandshakeComplete()>();
v = interfaceinvoke v.<io.netty.channel.Channel: io.netty.channel.ChannelPipeline pipeline()>();
v = interfaceinvoke v.<io.netty.channel.ChannelPipeline: io.netty.channel.ChannelHandler get(java.lang.Class)>(class "Lio/netty/handler/codec/http/HttpContentDecompressor;");
if v == null goto label;
interfaceinvoke v.<io.netty.channel.ChannelPipeline: io.netty.channel.ChannelPipeline remove(io.netty.channel.ChannelHandler)>(v);
label:
v = interfaceinvoke v.<io.netty.channel.ChannelPipeline: io.netty.channel.ChannelHandler get(java.lang.Class)>(class "Lio/netty/handler/codec/http/HttpObjectAggregator;");
if v == null goto label;
interfaceinvoke v.<io.netty.channel.ChannelPipeline: io.netty.channel.ChannelPipeline remove(io.netty.channel.ChannelHandler)>(v);
label:
v = interfaceinvoke v.<io.netty.channel.ChannelPipeline: io.netty.channel.ChannelHandlerContext context(java.lang.Class)>(class "Lio/netty/handler/codec/http/HttpResponseDecoder;");
if v != null goto label;
v = interfaceinvoke v.<io.netty.channel.ChannelPipeline: io.netty.channel.ChannelHandlerContext context(java.lang.Class)>(class "Lio/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.<io.netty.channel.ChannelHandlerContext: io.netty.channel.ChannelHandler handler()>();
virtualinvoke v.<io.netty.handler.codec.http.HttpClientCodec: void removeOutboundHandler()>();
v = interfaceinvoke v.<io.netty.channel.ChannelHandlerContext: java.lang.String name()>();
v = virtualinvoke v.<io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker: io.netty.handler.codec.http.websocketx.WebSocketFrameDecoder newWebsocketDecoder()>();
interfaceinvoke v.<io.netty.channel.ChannelPipeline: io.netty.channel.ChannelPipeline addAfter(java.lang.String,java.lang.String,io.netty.channel.ChannelHandler)>(v, "ws-decoder", v);
v = interfaceinvoke v.<io.netty.channel.Channel: io.netty.channel.EventLoop eventLoop()>();
v = new io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker$2;
specialinvoke v.<io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker$2: void <init>(io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker,io.netty.channel.ChannelPipeline,io.netty.handler.codec.http.HttpClientCodec)>(v, v, v);
interfaceinvoke v.<io.netty.channel.EventLoop: void execute(java.lang.Runnable)>(v);
goto label;
label:
v = interfaceinvoke v.<io.netty.channel.ChannelPipeline: io.netty.channel.ChannelHandler get(java.lang.Class)>(class "Lio/netty/handler/codec/http/HttpRequestEncoder;");
if v == null goto label;
interfaceinvoke v.<io.netty.channel.ChannelPipeline: io.netty.channel.ChannelHandler remove(java.lang.Class)>(class "Lio/netty/handler/codec/http/HttpRequestEncoder;");
label:
v = interfaceinvoke v.<io.netty.channel.ChannelHandlerContext: java.lang.String name()>();
v = virtualinvoke v.<io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker: io.netty.handler.codec.http.websocketx.WebSocketFrameDecoder newWebsocketDecoder()>();
interfaceinvoke v.<io.netty.channel.ChannelPipeline: io.netty.channel.ChannelPipeline addAfter(java.lang.String,java.lang.String,io.netty.channel.ChannelHandler)>(v, "ws-decoder", v);
v = interfaceinvoke v.<io.netty.channel.Channel: io.netty.channel.EventLoop eventLoop()>();
v = new io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker$3;
specialinvoke v.<io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker$3: void <init>(io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker,io.netty.channel.ChannelPipeline,io.netty.channel.ChannelHandlerContext)>(v, v, v);
interfaceinvoke v.<io.netty.channel.EventLoop: void execute(java.lang.Runnable)>(v);
label:
return;
}
public final io.netty.channel.ChannelFuture processHandshake(io.netty.channel.Channel, io.netty.handler.codec.http.HttpResponse)
{
io.netty.channel.Channel v;
io.netty.channel.ChannelPromise v;
io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker v;
io.netty.handler.codec.http.HttpResponse v;
io.netty.channel.ChannelFuture v;
v := @this: io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker;
v := @parameter: io.netty.channel.Channel;
v := @parameter: io.netty.handler.codec.http.HttpResponse;
v = interfaceinvoke v.<io.netty.channel.Channel: io.netty.channel.ChannelPromise newPromise()>();
v = virtualinvoke v.<io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker: io.netty.channel.ChannelFuture processHandshake(io.netty.channel.Channel,io.netty.handler.codec.http.HttpResponse,io.netty.channel.ChannelPromise)>(v, v, v);
return v;
}
public final io.netty.channel.ChannelFuture processHandshake(io.netty.channel.Channel, io.netty.handler.codec.http.HttpResponse, io.netty.channel.ChannelPromise)
{
java.lang.Throwable v, v;
java.lang.IllegalStateException v;
io.netty.channel.ChannelHandlerContext v;
io.netty.handler.codec.http.websocketx.WebSocketVersion v, v;
io.netty.channel.ChannelPromise v, v;
java.lang.String v, v;
boolean v;
io.netty.channel.ChannelPipeline v;
io.netty.channel.Channel v;
io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker$4 v;
io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker v;
io.netty.handler.codec.http.HttpResponse v;
java.lang.Object v;
io.netty.handler.codec.http.HttpObjectAggregator v;
v := @this: io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker;
v := @parameter: io.netty.channel.Channel;
v := @parameter: io.netty.handler.codec.http.HttpResponse;
v := @parameter: io.netty.channel.ChannelPromise;
v = v instanceof io.netty.handler.codec.http.FullHttpResponse;
if v == 0 goto label;
label:
virtualinvoke v.<io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker: void finishHandshake(io.netty.channel.Channel,io.netty.handler.codec.http.FullHttpResponse)>(v, v);
interfaceinvoke v.<io.netty.channel.ChannelPromise: io.netty.channel.ChannelPromise setSuccess()>();
label:
goto label;
label:
v := @caughtexception;
interfaceinvoke v.<io.netty.channel.ChannelPromise: io.netty.channel.ChannelPromise setFailure(java.lang.Throwable)>(v);
goto label;
label:
v = interfaceinvoke v.<io.netty.channel.Channel: io.netty.channel.ChannelPipeline pipeline()>();
v = interfaceinvoke v.<io.netty.channel.ChannelPipeline: io.netty.channel.ChannelHandlerContext context(java.lang.Class)>(class "Lio/netty/handler/codec/http/HttpResponseDecoder;");
if v != null goto label;
v = interfaceinvoke v.<io.netty.channel.ChannelPipeline: io.netty.channel.ChannelHandlerContext context(java.lang.Class)>(class "Lio/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.<io.netty.channel.ChannelPromise: io.netty.channel.ChannelPromise setFailure(java.lang.Throwable)>(v);
return v;
label:
v = interfaceinvoke v.<io.netty.channel.ChannelHandlerContext: java.lang.String name()>();
v = v.<io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker: io.netty.handler.codec.http.websocketx.WebSocketVersion version>;
v = <io.netty.handler.codec.http.websocketx.WebSocketVersion: io.netty.handler.codec.http.websocketx.WebSocketVersion V00>;
if v != v goto label;
v = "httpAggregator";
v = interfaceinvoke v.<io.netty.channel.ChannelHandlerContext: java.lang.String name()>();
v = new io.netty.handler.codec.http.HttpObjectAggregator;
specialinvoke v.<io.netty.handler.codec.http.HttpObjectAggregator: void <init>(int)>(8192);
interfaceinvoke v.<io.netty.channel.ChannelPipeline: io.netty.channel.ChannelPipeline addAfter(java.lang.String,java.lang.String,io.netty.channel.ChannelHandler)>(v, "httpAggregator", v);
label:
v = new io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker$4;
specialinvoke v.<io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker$4: void <init>(io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker,io.netty.channel.ChannelPromise,io.netty.channel.Channel)>(v, v, v);
interfaceinvoke v.<io.netty.channel.ChannelPipeline: io.netty.channel.ChannelPipeline addAfter(java.lang.String,java.lang.String,io.netty.channel.ChannelHandler)>(v, "handshaker", v);
label:
v = staticinvoke <io.netty.util.ReferenceCountUtil: java.lang.Object retain(java.lang.Object)>(v);
interfaceinvoke v.<io.netty.channel.ChannelHandlerContext: io.netty.channel.ChannelHandlerContext fireChannelRead(java.lang.Object)>(v);
label:
goto label;
label:
v := @caughtexception;
interfaceinvoke v.<io.netty.channel.ChannelPromise: 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(io.netty.handler.codec.http.FullHttpResponse);
protected abstract io.netty.handler.codec.http.websocketx.WebSocketFrameDecoder newWebsocketDecoder();
protected abstract io.netty.handler.codec.http.websocketx.WebSocketFrameEncoder newWebSocketEncoder();
public io.netty.channel.ChannelFuture close(io.netty.channel.Channel, io.netty.handler.codec.http.websocketx.CloseWebSocketFrame)
{
io.netty.channel.Channel v;
io.netty.channel.ChannelPromise v;
io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker v;
io.netty.handler.codec.http.websocketx.CloseWebSocketFrame v;
io.netty.channel.ChannelFuture v;
v := @this: io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker;
v := @parameter: io.netty.channel.Channel;
v := @parameter: io.netty.handler.codec.http.websocketx.CloseWebSocketFrame;
staticinvoke <io.netty.util.internal.ObjectUtil: java.lang.Object checkNotNull(java.lang.Object,java.lang.String)>(v, "channel");
v = interfaceinvoke v.<io.netty.channel.Channel: io.netty.channel.ChannelPromise newPromise()>();
v = virtualinvoke v.<io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker: io.netty.channel.ChannelFuture close(io.netty.channel.Channel,io.netty.handler.codec.http.websocketx.CloseWebSocketFrame,io.netty.channel.ChannelPromise)>(v, v, v);
return v;
}
public io.netty.channel.ChannelFuture close(io.netty.channel.Channel, io.netty.handler.codec.http.websocketx.CloseWebSocketFrame, io.netty.channel.ChannelPromise)
{
io.netty.channel.Channel v;
io.netty.channel.ChannelPromise v;
io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker v;
io.netty.handler.codec.http.websocketx.CloseWebSocketFrame v;
io.netty.channel.ChannelFuture v;
v := @this: io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker;
v := @parameter: io.netty.channel.Channel;
v := @parameter: io.netty.handler.codec.http.websocketx.CloseWebSocketFrame;
v := @parameter: io.netty.channel.ChannelPromise;
staticinvoke <io.netty.util.internal.ObjectUtil: java.lang.Object checkNotNull(java.lang.Object,java.lang.String)>(v, "channel");
v = specialinvoke v.<io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker: io.netty.channel.ChannelFuture close0(io.netty.channel.ChannelOutboundInvoker,io.netty.channel.Channel,io.netty.handler.codec.http.websocketx.CloseWebSocketFrame,io.netty.channel.ChannelPromise)>(v, v, v, v);
return v;
}
public io.netty.channel.ChannelFuture close(io.netty.channel.ChannelHandlerContext, io.netty.handler.codec.http.websocketx.CloseWebSocketFrame)
{
io.netty.channel.ChannelHandlerContext v;
io.netty.channel.ChannelPromise v;
io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker v;
io.netty.handler.codec.http.websocketx.CloseWebSocketFrame v;
io.netty.channel.ChannelFuture v;
v := @this: io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker;
v := @parameter: io.netty.channel.ChannelHandlerContext;
v := @parameter: io.netty.handler.codec.http.websocketx.CloseWebSocketFrame;
staticinvoke <io.netty.util.internal.ObjectUtil: java.lang.Object checkNotNull(java.lang.Object,java.lang.String)>(v, "ctx");
v = interfaceinvoke v.<io.netty.channel.ChannelHandlerContext: io.netty.channel.ChannelPromise newPromise()>();
v = virtualinvoke v.<io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker: io.netty.channel.ChannelFuture close(io.netty.channel.ChannelHandlerContext,io.netty.handler.codec.http.websocketx.CloseWebSocketFrame,io.netty.channel.ChannelPromise)>(v, v, v);
return v;
}
public io.netty.channel.ChannelFuture close(io.netty.channel.ChannelHandlerContext, io.netty.handler.codec.http.websocketx.CloseWebSocketFrame, io.netty.channel.ChannelPromise)
{
io.netty.channel.Channel v;
io.netty.channel.ChannelHandlerContext v;
io.netty.channel.ChannelPromise v;
io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker v;
io.netty.handler.codec.http.websocketx.CloseWebSocketFrame v;
io.netty.channel.ChannelFuture v;
v := @this: io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker;
v := @parameter: io.netty.channel.ChannelHandlerContext;
v := @parameter: io.netty.handler.codec.http.websocketx.CloseWebSocketFrame;
v := @parameter: io.netty.channel.ChannelPromise;
staticinvoke <io.netty.util.internal.ObjectUtil: java.lang.Object checkNotNull(java.lang.Object,java.lang.String)>(v, "ctx");
v = interfaceinvoke v.<io.netty.channel.ChannelHandlerContext: io.netty.channel.Channel channel()>();
v = specialinvoke v.<io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker: io.netty.channel.ChannelFuture close0(io.netty.channel.ChannelOutboundInvoker,io.netty.channel.Channel,io.netty.handler.codec.http.websocketx.CloseWebSocketFrame,io.netty.channel.ChannelPromise)>(v, v, v, v);
return v;
}
private io.netty.channel.ChannelFuture close0(io.netty.channel.ChannelOutboundInvoker, io.netty.channel.Channel, io.netty.handler.codec.http.websocketx.CloseWebSocketFrame, io.netty.channel.ChannelPromise)
{
long v;
io.netty.channel.Channel v;
io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker$5 v;
byte v;
io.netty.channel.ChannelPromise v;
io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker v;
int v;
io.netty.channel.ChannelOutboundInvoker v;
io.netty.handler.codec.http.websocketx.CloseWebSocketFrame v;
boolean v;
v := @this: io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker;
v := @parameter: io.netty.channel.ChannelOutboundInvoker;
v := @parameter: io.netty.channel.Channel;
v := @parameter: io.netty.handler.codec.http.websocketx.CloseWebSocketFrame;
v := @parameter: io.netty.channel.ChannelPromise;
interfaceinvoke v.<io.netty.channel.ChannelOutboundInvoker: io.netty.channel.ChannelFuture writeAndFlush(java.lang.Object,io.netty.channel.ChannelPromise)>(v, v);
v = v.<io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker: long forceCloseTimeoutMillis>;
v = v cmp 0L;
if v <= 0 goto label;
v = interfaceinvoke v.<io.netty.channel.Channel: boolean isActive()>();
if v == 0 goto label;
v = v.<io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker: int forceCloseInit>;
if v == 0 goto label;
label:
return v;
label:
v = new io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker$5;
specialinvoke v.<io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker$5: void <init>(io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker,io.netty.channel.Channel,io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker,io.netty.channel.ChannelOutboundInvoker,long)>(v, v, v, v, v);
interfaceinvoke v.<io.netty.channel.ChannelPromise: io.netty.channel.ChannelPromise addListener(io.netty.util.concurrent.GenericFutureListener)>(v);
return v;
}
protected java.lang.String upgradeUrl(java.net.URI)
{
io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker v;
java.lang.String v, v, v, v, v, v;
java.net.URI v;
boolean v, v, v;
v := @this: io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker;
v := @parameter: java.net.URI;
v = v.<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()>();
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:
v = v;
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");
goto label;
label:
v = v;
label:
return v;
}
static java.lang.CharSequence websocketHostValue(java.net.URI)
{
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;
io.netty.handler.codec.http.websocketx.WebSocketScheme v, v;
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 = <io.netty.handler.codec.http.HttpScheme: io.netty.handler.codec.http.HttpScheme HTTP>;
v = virtualinvoke v.<io.netty.handler.codec.http.HttpScheme: int port()>();
if v != v goto label;
v = <io.netty.handler.codec.http.HttpScheme: io.netty.handler.codec.http.HttpScheme HTTP>;
v = virtualinvoke v.<io.netty.handler.codec.http.HttpScheme: io.netty.util.AsciiString name()>();
v = virtualinvoke v.<io.netty.util.AsciiString: boolean contentEquals(java.lang.CharSequence)>(v);
if v != 0 goto label;
v = <io.netty.handler.codec.http.websocketx.WebSocketScheme: io.netty.handler.codec.http.websocketx.WebSocketScheme WS>;
v = virtualinvoke v.<io.netty.handler.codec.http.websocketx.WebSocketScheme: io.netty.util.AsciiString name()>();
v = virtualinvoke v.<io.netty.util.AsciiString: boolean contentEquals(java.lang.CharSequence)>(v);
if v == 0 goto label;
label:
v = v;
goto label;
label:
v = staticinvoke <io.netty.util.NetUtil: java.lang.String toSocketAddressString(java.lang.String,int)>(v, v);
label:
return v;
label:
v = <io.netty.handler.codec.http.HttpScheme: io.netty.handler.codec.http.HttpScheme HTTPS>;
v = virtualinvoke v.<io.netty.handler.codec.http.HttpScheme: int port()>();
if v != v goto label;
v = <io.netty.handler.codec.http.HttpScheme: io.netty.handler.codec.http.HttpScheme HTTPS>;
v = virtualinvoke v.<io.netty.handler.codec.http.HttpScheme: io.netty.util.AsciiString name()>();
v = virtualinvoke v.<io.netty.util.AsciiString: boolean contentEquals(java.lang.CharSequence)>(v);
if v != 0 goto label;
v = <io.netty.handler.codec.http.websocketx.WebSocketScheme: io.netty.handler.codec.http.websocketx.WebSocketScheme WSS>;
v = virtualinvoke v.<io.netty.handler.codec.http.websocketx.WebSocketScheme: io.netty.util.AsciiString name()>();
v = virtualinvoke v.<io.netty.util.AsciiString: boolean contentEquals(java.lang.CharSequence)>(v);
if v == 0 goto label;
label:
v = v;
goto label;
label:
v = staticinvoke <io.netty.util.NetUtil: java.lang.String toSocketAddressString(java.lang.String,int)>(v, v);
label:
return v;
label:
v = staticinvoke <io.netty.util.NetUtil: java.lang.String toSocketAddressString(java.lang.String,int)>(v, v);
return v;
}
static java.lang.CharSequence websocketOriginValue(java.net.URI)
{
io.netty.util.AsciiString v, v;
java.util.Locale v;
int v, v, v, v;
java.lang.String v, v, v, v, v, v, v;
java.net.URI v;
boolean v, v;
io.netty.handler.codec.http.websocketx.WebSocketScheme v, v, v, v;
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 = <io.netty.handler.codec.http.websocketx.WebSocketScheme: io.netty.handler.codec.http.websocketx.WebSocketScheme WSS>;
v = virtualinvoke v.<io.netty.handler.codec.http.websocketx.WebSocketScheme: io.netty.util.AsciiString name()>();
v = virtualinvoke v.<io.netty.util.AsciiString: boolean contentEquals(java.lang.CharSequence)>(v);
if v != 0 goto label;
v = <io.netty.handler.codec.http.HttpScheme: io.netty.handler.codec.http.HttpScheme HTTPS>;
v = virtualinvoke v.<io.netty.handler.codec.http.HttpScheme: io.netty.util.AsciiString name()>();
v = virtualinvoke v.<io.netty.util.AsciiString: boolean contentEquals(java.lang.CharSequence)>(v);
if v != 0 goto label;
if v != null goto label;
v = <io.netty.handler.codec.http.websocketx.WebSocketScheme: io.netty.handler.codec.http.websocketx.WebSocketScheme WSS>;
v = virtualinvoke v.<io.netty.handler.codec.http.websocketx.WebSocketScheme: int port()>();
if v != v goto label;
label:
v = <io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker: java.lang.String HTTPS_SCHEME_PREFIX>;
v = <io.netty.handler.codec.http.websocketx.WebSocketScheme: io.netty.handler.codec.http.websocketx.WebSocketScheme WSS>;
v = virtualinvoke v.<io.netty.handler.codec.http.websocketx.WebSocketScheme: int port()>();
goto label;
label:
v = <io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker: java.lang.String HTTP_SCHEME_PREFIX>;
v = <io.netty.handler.codec.http.websocketx.WebSocketScheme: io.netty.handler.codec.http.websocketx.WebSocketScheme WS>;
v = virtualinvoke v.<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 <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>()
{
io.netty.handler.codec.http.HttpScheme v, v;
java.util.concurrent.atomic.AtomicIntegerFieldUpdater v;
java.lang.String v, v;
v = <io.netty.handler.codec.http.HttpScheme: io.netty.handler.codec.http.HttpScheme HTTP>;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (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://");
<io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker: java.lang.String HTTP_SCHEME_PREFIX> = v;
v = <io.netty.handler.codec.http.HttpScheme: io.netty.handler.codec.http.HttpScheme HTTPS>;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (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://");
<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 "Lio/netty/handler/codec/http/websocketx/WebSocketClientHandshaker;", "forceCloseInit");
<io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker: java.util.concurrent.atomic.AtomicIntegerFieldUpdater FORCE_CLOSE_INIT_UPDATER> = v;
return;
}
}