class io.vertx.core.net.impl.NetServerImpl$NetServerWorker extends java.lang.Object implements java.util.function.BiConsumer
{
private final io.vertx.core.impl.ContextInternal context;
private final io.vertx.core.Handler connectionHandler;
private final io.vertx.core.Handler exceptionHandler;
final io.vertx.core.net.impl.NetServerImpl this$0;
void <init>(io.vertx.core.net.impl.NetServerImpl, io.vertx.core.impl.ContextInternal, io.vertx.core.Handler, io.vertx.core.Handler)
{
io.vertx.core.net.impl.NetServerImpl v;
io.vertx.core.impl.ContextInternal v;
io.vertx.core.Handler v, v;
io.vertx.core.net.impl.NetServerImpl$NetServerWorker v;
v := @this: io.vertx.core.net.impl.NetServerImpl$NetServerWorker;
v := @parameter: io.vertx.core.net.impl.NetServerImpl;
v := @parameter: io.vertx.core.impl.ContextInternal;
v := @parameter: io.vertx.core.Handler;
v := @parameter: io.vertx.core.Handler;
v.<io.vertx.core.net.impl.NetServerImpl$NetServerWorker: io.vertx.core.net.impl.NetServerImpl this$0> = v;
specialinvoke v.<java.lang.Object: void <init>()>();
v.<io.vertx.core.net.impl.NetServerImpl$NetServerWorker: io.vertx.core.impl.ContextInternal context> = v;
v.<io.vertx.core.net.impl.NetServerImpl$NetServerWorker: io.vertx.core.Handler connectionHandler> = v;
v.<io.vertx.core.net.impl.NetServerImpl$NetServerWorker: io.vertx.core.Handler exceptionHandler> = v;
return;
}
public void accept(io.netty.channel.Channel, io.vertx.core.net.impl.SslChannelProvider)
{
io.vertx.core.net.impl.HAProxyMessageCompletionHandler v;
io.vertx.core.net.impl.NetServerImpl v, v, v, v, v;
long v, v;
byte v;
boolean v, v, v;
io.netty.util.concurrent.Promise v;
io.netty.util.concurrent.GenericFutureListener v;
io.netty.channel.ChannelPipeline v, v, v;
io.netty.channel.EventLoop v;
io.netty.channel.ChannelHandler[] v, v;
io.vertx.core.net.impl.NetServerImpl$NetServerWorker v;
io.netty.channel.Channel v;
java.util.concurrent.TimeUnit v;
io.netty.handler.codec.haproxy.HAProxyMessageDecoder v;
io.netty.handler.timeout.IdleStateHandler v, v;
io.vertx.core.net.NetServerOptions v, v, v, v;
io.vertx.core.net.impl.SslChannelProvider v;
v := @this: io.vertx.core.net.impl.NetServerImpl$NetServerWorker;
v := @parameter: io.netty.channel.Channel;
v := @parameter: io.vertx.core.net.impl.SslChannelProvider;
v = v.<io.vertx.core.net.impl.NetServerImpl$NetServerWorker: io.vertx.core.net.impl.NetServerImpl this$0>;
v = virtualinvoke v.<io.vertx.core.net.impl.NetServerImpl: boolean accept()>();
if v != 0 goto label;
interfaceinvoke v.<io.netty.channel.Channel: io.netty.channel.ChannelFuture close()>();
return;
label:
v = v.<io.vertx.core.net.impl.NetServerImpl$NetServerWorker: io.vertx.core.net.impl.NetServerImpl this$0>;
v = v.<io.vertx.core.net.impl.NetServerImpl: io.vertx.core.net.NetServerOptions options>;
v = virtualinvoke v.<io.vertx.core.net.NetServerOptions: boolean isUseProxyProtocol()>();
v = staticinvoke <io.vertx.core.net.impl.HAProxyMessageCompletionHandler: boolean canUseProxyProtocol(boolean)>(v);
if v == 0 goto label;
v = interfaceinvoke v.<io.netty.channel.Channel: io.netty.channel.EventLoop eventLoop()>();
v = interfaceinvoke v.<io.netty.channel.EventLoop: io.netty.util.concurrent.Promise newPromise()>();
v = interfaceinvoke v.<io.netty.channel.Channel: io.netty.channel.ChannelPipeline pipeline()>();
v = newarray (io.netty.channel.ChannelHandler)[1];
v = new io.netty.handler.codec.haproxy.HAProxyMessageDecoder;
specialinvoke v.<io.netty.handler.codec.haproxy.HAProxyMessageDecoder: void <init>()>();
v[0] = v;
interfaceinvoke v.<io.netty.channel.ChannelPipeline: io.netty.channel.ChannelPipeline addLast(io.netty.channel.ChannelHandler[])>(v);
v = v.<io.vertx.core.net.impl.NetServerImpl$NetServerWorker: io.vertx.core.net.impl.NetServerImpl this$0>;
v = v.<io.vertx.core.net.impl.NetServerImpl: io.vertx.core.net.NetServerOptions options>;
v = virtualinvoke v.<io.vertx.core.net.NetServerOptions: long getProxyProtocolTimeout()>();
v = v cmp 0L;
if v <= 0 goto label;
v = interfaceinvoke v.<io.netty.channel.Channel: io.netty.channel.ChannelPipeline pipeline()>();
v = new io.netty.handler.timeout.IdleStateHandler;
v = v.<io.vertx.core.net.impl.NetServerImpl$NetServerWorker: io.vertx.core.net.impl.NetServerImpl this$0>;
v = v.<io.vertx.core.net.impl.NetServerImpl: io.vertx.core.net.NetServerOptions options>;
v = virtualinvoke v.<io.vertx.core.net.NetServerOptions: long getProxyProtocolTimeout()>();
v = v.<io.vertx.core.net.impl.NetServerImpl$NetServerWorker: io.vertx.core.net.impl.NetServerImpl this$0>;
v = v.<io.vertx.core.net.impl.NetServerImpl: io.vertx.core.net.NetServerOptions options>;
v = virtualinvoke v.<io.vertx.core.net.NetServerOptions: java.util.concurrent.TimeUnit getProxyProtocolTimeoutUnit()>();
specialinvoke v.<io.netty.handler.timeout.IdleStateHandler: void <init>(long,long,long,java.util.concurrent.TimeUnit)>(0L, 0L, v, v);
v = v;
interfaceinvoke v.<io.netty.channel.ChannelPipeline: io.netty.channel.ChannelPipeline addLast(java.lang.String,io.netty.channel.ChannelHandler)>("idle", v);
goto label;
label:
v = null;
label:
v = interfaceinvoke v.<io.netty.channel.Channel: io.netty.channel.ChannelPipeline pipeline()>();
v = newarray (io.netty.channel.ChannelHandler)[1];
v = new io.vertx.core.net.impl.HAProxyMessageCompletionHandler;
specialinvoke v.<io.vertx.core.net.impl.HAProxyMessageCompletionHandler: void <init>(io.netty.util.concurrent.Promise)>(v);
v[0] = v;
interfaceinvoke v.<io.netty.channel.ChannelPipeline: io.netty.channel.ChannelPipeline addLast(io.netty.channel.ChannelHandler[])>(v);
v = staticinvoke <io.vertx.core.net.impl.NetServerImpl$NetServerWorker$lambda_accept_0__1356: io.netty.util.concurrent.GenericFutureListener bootstrap$(io.vertx.core.net.impl.NetServerImpl$NetServerWorker,io.netty.handler.timeout.IdleStateHandler,io.netty.channel.Channel,io.vertx.core.net.impl.SslChannelProvider)>(v, v, v, v);
interfaceinvoke v.<io.netty.util.concurrent.Promise: io.netty.util.concurrent.Promise addListener(io.netty.util.concurrent.GenericFutureListener)>(v);
goto label;
label:
specialinvoke v.<io.vertx.core.net.impl.NetServerImpl$NetServerWorker: void configurePipeline(io.netty.channel.Channel,io.vertx.core.net.impl.SslChannelProvider)>(v, v);
label:
return;
}
private void configurePipeline(io.netty.channel.Channel, io.vertx.core.net.impl.SslChannelProvider)
{
io.vertx.core.net.impl.NetServerImpl v;
io.netty.util.concurrent.GenericFutureListener v;
io.vertx.core.net.impl.SslHandshakeCompletionHandler v;
io.netty.channel.ChannelPipeline v, v;
io.vertx.core.net.impl.NetServerImpl$NetServerWorker v;
io.netty.channel.Channel v;
io.vertx.core.net.NetServerOptions v;
io.netty.channel.ChannelPromise v;
io.vertx.core.net.impl.SslChannelProvider v;
io.netty.channel.ChannelHandler v;
boolean v;
v := @this: io.vertx.core.net.impl.NetServerImpl$NetServerWorker;
v := @parameter: io.netty.channel.Channel;
v := @parameter: io.vertx.core.net.impl.SslChannelProvider;
v = v.<io.vertx.core.net.impl.NetServerImpl$NetServerWorker: io.vertx.core.net.impl.NetServerImpl this$0>;
v = v.<io.vertx.core.net.impl.NetServerImpl: io.vertx.core.net.NetServerOptions options>;
v = virtualinvoke v.<io.vertx.core.net.NetServerOptions: boolean isSsl()>();
if v == 0 goto label;
v = interfaceinvoke v.<io.netty.channel.Channel: io.netty.channel.ChannelPipeline pipeline()>();
v = virtualinvoke v.<io.vertx.core.net.impl.SslChannelProvider: io.netty.channel.ChannelHandler createServerHandler()>();
interfaceinvoke v.<io.netty.channel.ChannelPipeline: io.netty.channel.ChannelPipeline addLast(java.lang.String,io.netty.channel.ChannelHandler)>("ssl", v);
v = interfaceinvoke v.<io.netty.channel.Channel: io.netty.channel.ChannelPromise newPromise()>();
v = interfaceinvoke v.<io.netty.channel.Channel: io.netty.channel.ChannelPipeline pipeline()>();
v = new io.vertx.core.net.impl.SslHandshakeCompletionHandler;
specialinvoke v.<io.vertx.core.net.impl.SslHandshakeCompletionHandler: void <init>(io.netty.util.concurrent.Promise)>(v);
interfaceinvoke v.<io.netty.channel.ChannelPipeline: io.netty.channel.ChannelPipeline addLast(java.lang.String,io.netty.channel.ChannelHandler)>("handshaker", v);
v = staticinvoke <io.vertx.core.net.impl.NetServerImpl$NetServerWorker$lambda_configurePipeline_1__1357: io.netty.util.concurrent.GenericFutureListener bootstrap$(io.vertx.core.net.impl.NetServerImpl$NetServerWorker,io.netty.channel.Channel,io.vertx.core.net.impl.SslChannelProvider)>(v, v, v);
interfaceinvoke v.<io.netty.channel.ChannelPromise: io.netty.channel.ChannelPromise addListener(io.netty.util.concurrent.GenericFutureListener)>(v);
goto label;
label:
specialinvoke v.<io.vertx.core.net.impl.NetServerImpl$NetServerWorker: void connected(io.netty.channel.Channel,io.vertx.core.net.impl.SslChannelProvider)>(v, v);
label:
return;
}
private void handleException(java.lang.Throwable)
{
java.lang.Throwable v;
io.vertx.core.impl.ContextInternal v;
io.vertx.core.Handler v, v;
io.vertx.core.net.impl.NetServerImpl$NetServerWorker v;
v := @this: io.vertx.core.net.impl.NetServerImpl$NetServerWorker;
v := @parameter: java.lang.Throwable;
v = v.<io.vertx.core.net.impl.NetServerImpl$NetServerWorker: io.vertx.core.Handler exceptionHandler>;
if v == null goto label;
v = v.<io.vertx.core.net.impl.NetServerImpl$NetServerWorker: io.vertx.core.impl.ContextInternal context>;
v = staticinvoke <io.vertx.core.net.impl.NetServerImpl$NetServerWorker$lambda_handleException_2__1358: io.vertx.core.Handler bootstrap$(io.vertx.core.net.impl.NetServerImpl$NetServerWorker,java.lang.Throwable)>(v, v);
interfaceinvoke v.<io.vertx.core.impl.ContextInternal: void emit(io.vertx.core.Handler)>(v);
label:
return;
}
private void connected(io.netty.channel.Channel, io.vertx.core.net.impl.SslChannelProvider)
{
io.vertx.core.net.impl.VertxHandler v;
io.vertx.core.net.impl.NetServerImpl v, v, v;
io.vertx.core.spi.metrics.TCPMetrics v;
io.netty.channel.ChannelPipeline v, v;
java.util.function.Function v;
io.vertx.core.net.impl.NetServerImpl$NetServerWorker v;
io.netty.channel.Channel v;
io.vertx.core.net.NetServerOptions v;
io.vertx.core.net.impl.SslChannelProvider v;
io.vertx.core.Handler v, v;
boolean v;
v := @this: io.vertx.core.net.impl.NetServerImpl$NetServerWorker;
v := @parameter: io.netty.channel.Channel;
v := @parameter: io.vertx.core.net.impl.SslChannelProvider;
v = v.<io.vertx.core.net.impl.NetServerImpl$NetServerWorker: io.vertx.core.net.impl.NetServerImpl this$0>;
v = interfaceinvoke v.<io.netty.channel.Channel: io.netty.channel.ChannelPipeline pipeline()>();
v = v.<io.vertx.core.net.impl.NetServerImpl$NetServerWorker: io.vertx.core.net.impl.NetServerImpl this$0>;
v = v.<io.vertx.core.net.impl.NetServerImpl: io.vertx.core.net.NetServerOptions options>;
v = virtualinvoke v.<io.vertx.core.net.NetServerOptions: boolean isSsl()>();
virtualinvoke v.<io.vertx.core.net.impl.NetServerImpl: void initChannel(io.netty.channel.ChannelPipeline,boolean)>(v, v);
v = v.<io.vertx.core.net.impl.NetServerImpl$NetServerWorker: io.vertx.core.net.impl.NetServerImpl this$0>;
v = virtualinvoke v.<io.vertx.core.net.impl.NetServerImpl: io.vertx.core.spi.metrics.TCPMetrics getMetrics()>();
v = staticinvoke <io.vertx.core.net.impl.NetServerImpl$NetServerWorker$lambda_connected_3__1359: java.util.function.Function bootstrap$(io.vertx.core.net.impl.NetServerImpl$NetServerWorker,io.vertx.core.net.impl.SslChannelProvider,io.vertx.core.spi.metrics.TCPMetrics)>(v, v, v);
v = staticinvoke <io.vertx.core.net.impl.VertxHandler: io.vertx.core.net.impl.VertxHandler create(java.util.function.Function)>(v);
v = staticinvoke <io.vertx.core.net.impl.NetServerImpl$NetServerWorker$unregisterEventBusHandler__1360: io.vertx.core.Handler bootstrap$()>();
virtualinvoke v.<io.vertx.core.net.impl.VertxHandler: io.vertx.core.net.impl.VertxHandler removeHandler(io.vertx.core.Handler)>(v);
v = staticinvoke <io.vertx.core.net.impl.NetServerImpl$NetServerWorker$lambda_connected_4__1361: io.vertx.core.Handler bootstrap$(io.vertx.core.net.impl.NetServerImpl$NetServerWorker,io.vertx.core.spi.metrics.TCPMetrics)>(v, v);
virtualinvoke v.<io.vertx.core.net.impl.VertxHandler: io.vertx.core.net.impl.VertxHandler addHandler(io.vertx.core.Handler)>(v);
v = interfaceinvoke v.<io.netty.channel.Channel: io.netty.channel.ChannelPipeline pipeline()>();
interfaceinvoke v.<io.netty.channel.ChannelPipeline: io.netty.channel.ChannelPipeline addLast(java.lang.String,io.netty.channel.ChannelHandler)>("handler", v);
return;
}
}