public class io.vertx.core.net.impl.NetSocketImpl extends io.vertx.core.net.impl.ConnectionBase implements io.vertx.core.net.impl.NetSocketInternal
{
private static final io.vertx.core.impl.logging.Logger log;
private final java.lang.String writeHandlerID;
private final io.vertx.core.net.impl.SslChannelProvider sslChannelProvider;
private final io.vertx.core.net.SocketAddress remoteAddress;
private final io.vertx.core.spi.metrics.TCPMetrics metrics;
private final io.vertx.core.streams.impl.InboundBuffer pending;
private final java.lang.String negotiatedApplicationLayerProtocol;
private io.vertx.core.Handler endHandler;
private io.vertx.core.Handler drainHandler;
private io.vertx.core.eventbus.MessageConsumer registration;
private io.vertx.core.Handler handler;
private io.vertx.core.Handler messageHandler;
private io.vertx.core.Handler eventHandler;
public void <init>(io.vertx.core.impl.ContextInternal, io.netty.channel.ChannelHandlerContext, io.vertx.core.net.impl.SslChannelProvider, io.vertx.core.spi.metrics.TCPMetrics, boolean)
{
io.vertx.core.net.impl.NetSocketImpl v;
io.netty.channel.ChannelHandlerContext v;
io.vertx.core.net.impl.SslChannelProvider v;
io.vertx.core.impl.ContextInternal v;
io.vertx.core.spi.metrics.TCPMetrics v;
boolean v;
v := @this: io.vertx.core.net.impl.NetSocketImpl;
v := @parameter: io.vertx.core.impl.ContextInternal;
v := @parameter: io.netty.channel.ChannelHandlerContext;
v := @parameter: io.vertx.core.net.impl.SslChannelProvider;
v := @parameter: io.vertx.core.spi.metrics.TCPMetrics;
v := @parameter: boolean;
specialinvoke v.<io.vertx.core.net.impl.NetSocketImpl: void <init>(io.vertx.core.impl.ContextInternal,io.netty.channel.ChannelHandlerContext,io.vertx.core.net.SocketAddress,io.vertx.core.net.impl.SslChannelProvider,io.vertx.core.spi.metrics.TCPMetrics,java.lang.String,boolean)>(v, v, null, v, v, null, v);
return;
}
public void <init>(io.vertx.core.impl.ContextInternal, io.netty.channel.ChannelHandlerContext, io.vertx.core.net.SocketAddress, io.vertx.core.net.impl.SslChannelProvider, io.vertx.core.spi.metrics.TCPMetrics, java.lang.String, boolean)
{
io.vertx.core.net.impl.NetSocketImpl v;
io.vertx.core.streams.impl.InboundBuffer v, v, v, v;
io.vertx.core.impl.ContextInternal v;
io.vertx.core.spi.metrics.TCPMetrics v;
io.netty.channel.ChannelHandlerContext v;
java.lang.String v, v;
boolean v;
io.vertx.core.net.SocketAddress v;
io.vertx.core.net.impl.NetSocketImpl$DataMessageHandler v;
java.util.UUID v;
io.vertx.core.net.impl.SslChannelProvider v;
io.vertx.core.Handler v, v, v;
v := @this: io.vertx.core.net.impl.NetSocketImpl;
v := @parameter: io.vertx.core.impl.ContextInternal;
v := @parameter: io.netty.channel.ChannelHandlerContext;
v := @parameter: io.vertx.core.net.SocketAddress;
v := @parameter: io.vertx.core.net.impl.SslChannelProvider;
v := @parameter: io.vertx.core.spi.metrics.TCPMetrics;
v := @parameter: java.lang.String;
v := @parameter: boolean;
specialinvoke v.<io.vertx.core.net.impl.ConnectionBase: void <init>(io.vertx.core.impl.ContextInternal,io.netty.channel.ChannelHandlerContext)>(v, v);
v.<io.vertx.core.net.impl.NetSocketImpl: io.vertx.core.net.impl.SslChannelProvider sslChannelProvider> = v;
if v == 0 goto label;
v = staticinvoke <java.util.UUID: java.util.UUID randomUUID()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.util.UUID)>(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[])>("__vertx.net.\u0001");
goto label;
label:
v = null;
label:
v.<io.vertx.core.net.impl.NetSocketImpl: java.lang.String writeHandlerID> = v;
v.<io.vertx.core.net.impl.NetSocketImpl: io.vertx.core.net.SocketAddress remoteAddress> = v;
v.<io.vertx.core.net.impl.NetSocketImpl: io.vertx.core.spi.metrics.TCPMetrics metrics> = v;
v = new io.vertx.core.net.impl.NetSocketImpl$DataMessageHandler;
specialinvoke v.<io.vertx.core.net.impl.NetSocketImpl$DataMessageHandler: void <init>(io.vertx.core.net.impl.NetSocketImpl)>(v);
v.<io.vertx.core.net.impl.NetSocketImpl: io.vertx.core.Handler messageHandler> = v;
v.<io.vertx.core.net.impl.NetSocketImpl: java.lang.String negotiatedApplicationLayerProtocol> = v;
v = new io.vertx.core.streams.impl.InboundBuffer;
specialinvoke v.<io.vertx.core.streams.impl.InboundBuffer: void <init>(io.vertx.core.Context)>(v);
v.<io.vertx.core.net.impl.NetSocketImpl: io.vertx.core.streams.impl.InboundBuffer pending> = v;
v = v.<io.vertx.core.net.impl.NetSocketImpl: io.vertx.core.streams.impl.InboundBuffer pending>;
v = staticinvoke <io.vertx.core.net.impl.NetSocketImpl$lambda_new_0__1363: io.vertx.core.Handler bootstrap$(io.vertx.core.net.impl.NetSocketImpl)>(v);
virtualinvoke v.<io.vertx.core.streams.impl.InboundBuffer: io.vertx.core.streams.impl.InboundBuffer drainHandler(io.vertx.core.Handler)>(v);
v = v.<io.vertx.core.net.impl.NetSocketImpl: io.vertx.core.streams.impl.InboundBuffer pending>;
virtualinvoke v.<java.lang.Object: java.lang.Class getClass()>();
v = staticinvoke <io.vertx.core.net.impl.NetSocketImpl$reportException__1364: io.vertx.core.Handler bootstrap$(io.vertx.core.impl.ContextInternal)>(v);
virtualinvoke v.<io.vertx.core.streams.impl.InboundBuffer: io.vertx.core.streams.impl.InboundBuffer exceptionHandler(io.vertx.core.Handler)>(v);
v = v.<io.vertx.core.net.impl.NetSocketImpl: io.vertx.core.streams.impl.InboundBuffer pending>;
v = staticinvoke <io.vertx.core.net.impl.NetSocketImpl$lambda_new_1__1365: io.vertx.core.Handler bootstrap$(io.vertx.core.net.impl.NetSocketImpl)>(v);
virtualinvoke v.<io.vertx.core.streams.impl.InboundBuffer: io.vertx.core.streams.impl.InboundBuffer handler(io.vertx.core.Handler)>(v);
return;
}
void registerEventBusHandler()
{
io.vertx.core.net.impl.NetSocketImpl v;
io.vertx.core.impl.VertxInternal v;
io.vertx.core.eventbus.EventBus v;
java.lang.String v, v;
io.vertx.core.Handler v;
io.vertx.core.eventbus.MessageConsumer v, v;
v := @this: io.vertx.core.net.impl.NetSocketImpl;
v = v.<io.vertx.core.net.impl.NetSocketImpl: java.lang.String writeHandlerID>;
if v == null goto label;
v = staticinvoke <io.vertx.core.net.impl.NetSocketImpl$lambda_registerEventBusHandler_2__1366: io.vertx.core.Handler bootstrap$(io.vertx.core.net.impl.NetSocketImpl)>(v);
v = v.<io.vertx.core.net.impl.NetSocketImpl: io.vertx.core.impl.VertxInternal vertx>;
v = interfaceinvoke v.<io.vertx.core.impl.VertxInternal: io.vertx.core.eventbus.EventBus eventBus()>();
v = v.<io.vertx.core.net.impl.NetSocketImpl: java.lang.String writeHandlerID>;
v = interfaceinvoke v.<io.vertx.core.eventbus.EventBus: io.vertx.core.eventbus.MessageConsumer localConsumer(java.lang.String)>(v);
v = interfaceinvoke v.<io.vertx.core.eventbus.MessageConsumer: io.vertx.core.eventbus.MessageConsumer handler(io.vertx.core.Handler)>(v);
v.<io.vertx.core.net.impl.NetSocketImpl: io.vertx.core.eventbus.MessageConsumer registration> = v;
label:
return;
}
void unregisterEventBusHandler()
{
io.vertx.core.net.impl.NetSocketImpl v;
io.vertx.core.eventbus.MessageConsumer v, v;
v := @this: io.vertx.core.net.impl.NetSocketImpl;
v = v.<io.vertx.core.net.impl.NetSocketImpl: io.vertx.core.eventbus.MessageConsumer registration>;
if v == null goto label;
v = v.<io.vertx.core.net.impl.NetSocketImpl: io.vertx.core.eventbus.MessageConsumer registration>;
v.<io.vertx.core.net.impl.NetSocketImpl: io.vertx.core.eventbus.MessageConsumer registration> = null;
interfaceinvoke v.<io.vertx.core.eventbus.MessageConsumer: io.vertx.core.Future unregister()>();
label:
return;
}
public io.vertx.core.spi.metrics.TCPMetrics metrics()
{
io.vertx.core.net.impl.NetSocketImpl v;
io.vertx.core.spi.metrics.TCPMetrics v;
v := @this: io.vertx.core.net.impl.NetSocketImpl;
v = v.<io.vertx.core.net.impl.NetSocketImpl: io.vertx.core.spi.metrics.TCPMetrics metrics>;
return v;
}
public java.lang.String writeHandlerID()
{
io.vertx.core.net.impl.NetSocketImpl v;
java.lang.String v;
v := @this: io.vertx.core.net.impl.NetSocketImpl;
v = v.<io.vertx.core.net.impl.NetSocketImpl: java.lang.String writeHandlerID>;
return v;
}
public synchronized io.vertx.core.Future writeMessage(java.lang.Object)
{
io.vertx.core.net.impl.NetSocketImpl v;
io.vertx.core.impl.future.PromiseInternal v;
io.vertx.core.impl.ContextInternal v;
java.lang.Object v;
io.vertx.core.Future v;
v := @this: io.vertx.core.net.impl.NetSocketImpl;
v := @parameter: java.lang.Object;
v = v.<io.vertx.core.net.impl.NetSocketImpl: io.vertx.core.impl.ContextInternal context>;
v = interfaceinvoke v.<io.vertx.core.impl.ContextInternal: io.vertx.core.impl.future.PromiseInternal promise()>();
virtualinvoke v.<io.vertx.core.net.impl.NetSocketImpl: io.vertx.core.net.impl.NetSocketInternal writeMessage(java.lang.Object,io.vertx.core.Handler)>(v, v);
v = interfaceinvoke v.<io.vertx.core.Promise: io.vertx.core.Future future()>();
return v;
}
public io.vertx.core.net.impl.NetSocketInternal writeMessage(java.lang.Object, io.vertx.core.Handler)
{
io.vertx.core.net.impl.NetSocketImpl v;
io.vertx.core.impl.future.PromiseInternal v;
io.vertx.core.impl.ContextInternal v;
java.lang.Object v;
io.vertx.core.Handler v;
v := @this: io.vertx.core.net.impl.NetSocketImpl;
v := @parameter: java.lang.Object;
v := @parameter: io.vertx.core.Handler;
if v != null goto label;
v = null;
goto label;
label:
v = v.<io.vertx.core.net.impl.NetSocketImpl: io.vertx.core.impl.ContextInternal context>;
v = interfaceinvoke v.<io.vertx.core.impl.ContextInternal: io.vertx.core.impl.future.PromiseInternal promise(io.vertx.core.Handler)>(v);
label:
virtualinvoke v.<io.vertx.core.net.impl.NetSocketImpl: void writeToChannel(java.lang.Object,io.netty.util.concurrent.FutureListener)>(v, v);
return v;
}
public java.lang.String applicationLayerProtocol()
{
io.vertx.core.net.impl.NetSocketImpl v;
java.lang.String v;
v := @this: io.vertx.core.net.impl.NetSocketImpl;
v = v.<io.vertx.core.net.impl.NetSocketImpl: java.lang.String negotiatedApplicationLayerProtocol>;
return v;
}
public io.vertx.core.Future write(io.vertx.core.buffer.Buffer)
{
io.vertx.core.net.impl.NetSocketImpl v;
io.netty.buffer.ByteBuf v;
io.vertx.core.buffer.Buffer v;
io.vertx.core.Future v;
v := @this: io.vertx.core.net.impl.NetSocketImpl;
v := @parameter: io.vertx.core.buffer.Buffer;
v = interfaceinvoke v.<io.vertx.core.buffer.Buffer: io.netty.buffer.ByteBuf getByteBuf()>();
v = virtualinvoke v.<io.vertx.core.net.impl.NetSocketImpl: io.vertx.core.Future writeMessage(java.lang.Object)>(v);
return v;
}
public void write(java.lang.String, io.vertx.core.Handler)
{
io.vertx.core.net.impl.NetSocketImpl v;
io.netty.buffer.ByteBuf v;
java.nio.charset.Charset v;
java.lang.String v;
io.vertx.core.Handler v;
v := @this: io.vertx.core.net.impl.NetSocketImpl;
v := @parameter: java.lang.String;
v := @parameter: io.vertx.core.Handler;
v = <io.netty.util.CharsetUtil: java.nio.charset.Charset UTF_8>;
v = staticinvoke <io.netty.buffer.Unpooled: io.netty.buffer.ByteBuf copiedBuffer(java.lang.CharSequence,java.nio.charset.Charset)>(v, v);
specialinvoke v.<io.vertx.core.net.impl.NetSocketImpl: void write(io.netty.buffer.ByteBuf,io.vertx.core.Handler)>(v, v);
return;
}
public io.vertx.core.Future write(java.lang.String)
{
io.vertx.core.net.impl.NetSocketImpl v;
io.netty.buffer.ByteBuf v;
java.nio.charset.Charset v;
java.lang.String v;
io.vertx.core.Future v;
v := @this: io.vertx.core.net.impl.NetSocketImpl;
v := @parameter: java.lang.String;
v = <io.netty.util.CharsetUtil: java.nio.charset.Charset UTF_8>;
v = staticinvoke <io.netty.buffer.Unpooled: io.netty.buffer.ByteBuf copiedBuffer(java.lang.CharSequence,java.nio.charset.Charset)>(v, v);
v = virtualinvoke v.<io.vertx.core.net.impl.NetSocketImpl: io.vertx.core.Future writeMessage(java.lang.Object)>(v);
return v;
}
public io.vertx.core.Future write(java.lang.String, java.lang.String)
{
io.vertx.core.net.impl.NetSocketImpl v;
io.netty.buffer.ByteBuf v;
java.nio.charset.Charset v;
java.lang.String v, v;
io.vertx.core.Future v;
v := @this: io.vertx.core.net.impl.NetSocketImpl;
v := @parameter: java.lang.String;
v := @parameter: java.lang.String;
v = staticinvoke <java.nio.charset.Charset: java.nio.charset.Charset forName(java.lang.String)>(v);
v = staticinvoke <io.netty.buffer.Unpooled: io.netty.buffer.ByteBuf copiedBuffer(java.lang.CharSequence,java.nio.charset.Charset)>(v, v);
v = virtualinvoke v.<io.vertx.core.net.impl.NetSocketImpl: io.vertx.core.Future writeMessage(java.lang.Object)>(v);
return v;
}
public void write(java.lang.String, java.lang.String, io.vertx.core.Handler)
{
io.vertx.core.net.impl.NetSocketImpl v;
io.netty.buffer.ByteBuf v;
java.nio.charset.Charset v;
java.lang.String v, v;
io.vertx.core.Handler v;
v := @this: io.vertx.core.net.impl.NetSocketImpl;
v := @parameter: java.lang.String;
v := @parameter: java.lang.String;
v := @parameter: io.vertx.core.Handler;
if v == null goto label;
v = staticinvoke <java.nio.charset.Charset: java.nio.charset.Charset forName(java.lang.String)>(v);
goto label;
label:
v = <io.netty.util.CharsetUtil: java.nio.charset.Charset UTF_8>;
label:
v = staticinvoke <io.netty.buffer.Unpooled: io.netty.buffer.ByteBuf copiedBuffer(java.lang.CharSequence,java.nio.charset.Charset)>(v, v);
specialinvoke v.<io.vertx.core.net.impl.NetSocketImpl: void write(io.netty.buffer.ByteBuf,io.vertx.core.Handler)>(v, v);
return;
}
public void write(io.vertx.core.buffer.Buffer, io.vertx.core.Handler)
{
io.vertx.core.net.impl.NetSocketImpl v;
io.netty.buffer.ByteBuf v;
io.vertx.core.buffer.Buffer v;
io.vertx.core.Handler v;
v := @this: io.vertx.core.net.impl.NetSocketImpl;
v := @parameter: io.vertx.core.buffer.Buffer;
v := @parameter: io.vertx.core.Handler;
v = interfaceinvoke v.<io.vertx.core.buffer.Buffer: io.netty.buffer.ByteBuf getByteBuf()>();
specialinvoke v.<io.vertx.core.net.impl.NetSocketImpl: void write(io.netty.buffer.ByteBuf,io.vertx.core.Handler)>(v, v);
return;
}
private void write(io.netty.buffer.ByteBuf, io.vertx.core.Handler)
{
io.vertx.core.net.impl.NetSocketImpl v;
io.netty.buffer.ByteBuf v;
int v;
io.vertx.core.Handler v;
v := @this: io.vertx.core.net.impl.NetSocketImpl;
v := @parameter: io.netty.buffer.ByteBuf;
v := @parameter: io.vertx.core.Handler;
v = virtualinvoke v.<io.netty.buffer.ByteBuf: int readableBytes()>();
virtualinvoke v.<io.vertx.core.net.impl.NetSocketImpl: void reportBytesWritten(long)>(v);
virtualinvoke v.<io.vertx.core.net.impl.NetSocketImpl: io.vertx.core.net.impl.NetSocketInternal writeMessage(java.lang.Object,io.vertx.core.Handler)>(v, v);
return;
}
private synchronized io.vertx.core.Handler handler()
{
io.vertx.core.net.impl.NetSocketImpl v;
io.vertx.core.Handler v;
v := @this: io.vertx.core.net.impl.NetSocketImpl;
v = v.<io.vertx.core.net.impl.NetSocketImpl: io.vertx.core.Handler handler>;
return v;
}
public synchronized io.vertx.core.net.NetSocket handler(io.vertx.core.Handler)
{
io.vertx.core.net.impl.NetSocketImpl v;
io.vertx.core.Handler v;
v := @this: io.vertx.core.net.impl.NetSocketImpl;
v := @parameter: io.vertx.core.Handler;
v.<io.vertx.core.net.impl.NetSocketImpl: io.vertx.core.Handler handler> = v;
return v;
}
private synchronized io.vertx.core.Handler messageHandler()
{
io.vertx.core.net.impl.NetSocketImpl v;
io.vertx.core.Handler v;
v := @this: io.vertx.core.net.impl.NetSocketImpl;
v = v.<io.vertx.core.net.impl.NetSocketImpl: io.vertx.core.Handler messageHandler>;
return v;
}
public synchronized io.vertx.core.net.impl.NetSocketInternal messageHandler(io.vertx.core.Handler)
{
io.vertx.core.net.impl.NetSocketImpl v;
io.vertx.core.net.impl.NetSocketImpl$DataMessageHandler v;
io.vertx.core.Handler v, v;
v := @this: io.vertx.core.net.impl.NetSocketImpl;
v := @parameter: io.vertx.core.Handler;
if v != null goto label;
v = new io.vertx.core.net.impl.NetSocketImpl$DataMessageHandler;
v = v;
specialinvoke v.<io.vertx.core.net.impl.NetSocketImpl$DataMessageHandler: void <init>(io.vertx.core.net.impl.NetSocketImpl)>(v);
goto label;
label:
v = v;
label:
v.<io.vertx.core.net.impl.NetSocketImpl: io.vertx.core.Handler messageHandler> = v;
return v;
}
public synchronized io.vertx.core.net.impl.NetSocketInternal eventHandler(io.vertx.core.Handler)
{
io.vertx.core.net.impl.NetSocketImpl v;
io.vertx.core.Handler v;
v := @this: io.vertx.core.net.impl.NetSocketImpl;
v := @parameter: io.vertx.core.Handler;
v.<io.vertx.core.net.impl.NetSocketImpl: io.vertx.core.Handler eventHandler> = v;
return v;
}
public synchronized io.vertx.core.net.NetSocket pause()
{
io.vertx.core.net.impl.NetSocketImpl v;
io.vertx.core.streams.impl.InboundBuffer v;
v := @this: io.vertx.core.net.impl.NetSocketImpl;
v = v.<io.vertx.core.net.impl.NetSocketImpl: io.vertx.core.streams.impl.InboundBuffer pending>;
virtualinvoke v.<io.vertx.core.streams.impl.InboundBuffer: io.vertx.core.streams.impl.InboundBuffer pause()>();
return v;
}
public io.vertx.core.net.NetSocket fetch(long)
{
io.vertx.core.net.impl.NetSocketImpl v;
long v;
io.vertx.core.streams.impl.InboundBuffer v;
v := @this: io.vertx.core.net.impl.NetSocketImpl;
v := @parameter: long;
v = v.<io.vertx.core.net.impl.NetSocketImpl: io.vertx.core.streams.impl.InboundBuffer pending>;
virtualinvoke v.<io.vertx.core.streams.impl.InboundBuffer: boolean fetch(long)>(v);
return v;
}
public synchronized io.vertx.core.net.NetSocket resume()
{
io.vertx.core.net.impl.NetSocketImpl v;
io.vertx.core.net.NetSocket v;
v := @this: io.vertx.core.net.impl.NetSocketImpl;
v = virtualinvoke v.<io.vertx.core.net.impl.NetSocketImpl: io.vertx.core.net.NetSocket fetch(long)>(9223372036854775807L);
return v;
}
public io.vertx.core.net.NetSocket setWriteQueueMaxSize(int)
{
int v;
io.vertx.core.net.impl.NetSocketImpl v;
v := @this: io.vertx.core.net.impl.NetSocketImpl;
v := @parameter: int;
virtualinvoke v.<io.vertx.core.net.impl.NetSocketImpl: void doSetWriteQueueMaxSize(int)>(v);
return v;
}
public boolean writeQueueFull()
{
io.vertx.core.net.impl.NetSocketImpl v;
boolean v;
v := @this: io.vertx.core.net.impl.NetSocketImpl;
v = virtualinvoke v.<io.vertx.core.net.impl.NetSocketImpl: boolean isNotWritable()>();
return v;
}
private synchronized io.vertx.core.Handler endHandler()
{
io.vertx.core.net.impl.NetSocketImpl v;
io.vertx.core.Handler v;
v := @this: io.vertx.core.net.impl.NetSocketImpl;
v = v.<io.vertx.core.net.impl.NetSocketImpl: io.vertx.core.Handler endHandler>;
return v;
}
public synchronized io.vertx.core.net.NetSocket endHandler(io.vertx.core.Handler)
{
io.vertx.core.net.impl.NetSocketImpl v;
io.vertx.core.Handler v;
v := @this: io.vertx.core.net.impl.NetSocketImpl;
v := @parameter: io.vertx.core.Handler;
v.<io.vertx.core.net.impl.NetSocketImpl: io.vertx.core.Handler endHandler> = v;
return v;
}
public synchronized io.vertx.core.net.NetSocket drainHandler(io.vertx.core.Handler)
{
io.vertx.core.net.impl.NetSocketImpl v;
io.vertx.core.impl.VertxInternal v;
io.vertx.core.Handler v, v;
v := @this: io.vertx.core.net.impl.NetSocketImpl;
v := @parameter: io.vertx.core.Handler;
v.<io.vertx.core.net.impl.NetSocketImpl: io.vertx.core.Handler drainHandler> = v;
v = v.<io.vertx.core.net.impl.NetSocketImpl: io.vertx.core.impl.VertxInternal vertx>;
v = staticinvoke <io.vertx.core.net.impl.NetSocketImpl$lambda_drainHandler_3__1367: io.vertx.core.Handler bootstrap$(io.vertx.core.net.impl.NetSocketImpl)>(v);
interfaceinvoke v.<io.vertx.core.impl.VertxInternal: void runOnContext(io.vertx.core.Handler)>(v);
return v;
}
public io.vertx.core.Future sendFile(java.lang.String, long, long)
{
io.vertx.core.net.impl.NetSocketImpl v;
io.vertx.core.impl.future.PromiseInternal v;
io.vertx.core.impl.ContextInternal v;
long v, v;
java.lang.String v;
io.vertx.core.Future v;
v := @this: io.vertx.core.net.impl.NetSocketImpl;
v := @parameter: java.lang.String;
v := @parameter: long;
v := @parameter: long;
v = v.<io.vertx.core.net.impl.NetSocketImpl: io.vertx.core.impl.ContextInternal context>;
v = interfaceinvoke v.<io.vertx.core.impl.ContextInternal: io.vertx.core.impl.future.PromiseInternal promise()>();
virtualinvoke v.<io.vertx.core.net.impl.NetSocketImpl: io.vertx.core.net.NetSocket sendFile(java.lang.String,long,long,io.vertx.core.Handler)>(v, v, v, v);
v = interfaceinvoke v.<io.vertx.core.Promise: io.vertx.core.Future future()>();
return v;
}
public io.vertx.core.net.NetSocket sendFile(java.lang.String, long, long, io.vertx.core.Handler)
{
io.vertx.core.net.impl.NetSocketImpl v;
java.io.RandomAccessFile v, v;
long v, v, v, v, v, v, v;
java.lang.String v;
boolean v;
io.vertx.core.impl.logging.Logger v;
io.vertx.core.impl.VertxInternal v, v;
io.netty.util.concurrent.GenericFutureListener v;
java.io.IOException v, v;
java.lang.IllegalArgumentException v;
java.io.File v;
io.netty.channel.ChannelFuture v;
io.vertx.core.Handler v, v;
v := @this: io.vertx.core.net.impl.NetSocketImpl;
v := @parameter: java.lang.String;
v := @parameter: long;
v := @parameter: long;
v := @parameter: io.vertx.core.Handler;
v = v.<io.vertx.core.net.impl.NetSocketImpl: io.vertx.core.impl.VertxInternal vertx>;
v = interfaceinvoke v.<io.vertx.core.impl.VertxInternal: java.io.File resolveFile(java.lang.String)>(v);
v = virtualinvoke v.<java.io.File: boolean isDirectory()>();
if v == 0 goto label;
v = new java.lang.IllegalArgumentException;
specialinvoke v.<java.lang.IllegalArgumentException: void <init>(java.lang.String)>("filename must point to a file and not to a directory");
throw v;
label:
v = null;
label:
v = new java.io.RandomAccessFile;
specialinvoke v.<java.io.RandomAccessFile: void <init>(java.io.File,java.lang.String)>(v, "r");
v = v;
v = virtualinvoke v.<java.io.File: long length()>();
v = staticinvoke <java.lang.Math: long min(long,long)>(v, v);
v = virtualinvoke v.<java.io.File: long length()>();
v = v - v;
v = staticinvoke <java.lang.Math: long min(long,long)>(v, v);
v = specialinvoke v.<io.vertx.core.net.impl.ConnectionBase: io.netty.channel.ChannelFuture sendFile(java.io.RandomAccessFile,long,long)>(v, v, v);
if v == null goto label;
v = staticinvoke <io.vertx.core.net.impl.NetSocketImpl$lambda_sendFile_5__1368: io.netty.util.concurrent.GenericFutureListener bootstrap$(io.vertx.core.net.impl.NetSocketImpl,io.netty.channel.ChannelFuture,io.vertx.core.Handler)>(v, v, v);
interfaceinvoke v.<io.netty.channel.ChannelFuture: io.netty.channel.ChannelFuture addListener(io.netty.util.concurrent.GenericFutureListener)>(v);
label:
goto label;
label:
v := @caughtexception;
label:
if v == null goto label;
virtualinvoke v.<java.io.RandomAccessFile: void close()>();
label:
goto label;
label:
v := @caughtexception;
label:
if v == null goto label;
v = v.<io.vertx.core.net.impl.NetSocketImpl: io.vertx.core.impl.VertxInternal vertx>;
v = staticinvoke <io.vertx.core.net.impl.NetSocketImpl$lambda_sendFile_6__1369: io.vertx.core.Handler bootstrap$(io.vertx.core.Handler,java.io.IOException)>(v, v);
interfaceinvoke v.<io.vertx.core.impl.VertxInternal: void runOnContext(io.vertx.core.Handler)>(v);
goto label;
label:
v = <io.vertx.core.net.impl.NetSocketImpl: io.vertx.core.impl.logging.Logger log>;
interfaceinvoke v.<io.vertx.core.impl.logging.Logger: void error(java.lang.Object,java.lang.Throwable)>("Failed to send file", v);
label:
return v;
catch java.io.IOException from label to label with label;
catch java.io.IOException from label to label with label;
}
public io.vertx.core.net.impl.NetSocketImpl exceptionHandler(io.vertx.core.Handler)
{
io.vertx.core.net.impl.NetSocketImpl v;
io.vertx.core.Handler v;
io.vertx.core.net.impl.ConnectionBase v;
v := @this: io.vertx.core.net.impl.NetSocketImpl;
v := @parameter: io.vertx.core.Handler;
v = specialinvoke v.<io.vertx.core.net.impl.ConnectionBase: io.vertx.core.net.impl.ConnectionBase exceptionHandler(io.vertx.core.Handler)>(v);
return v;
}
public io.vertx.core.net.impl.NetSocketImpl closeHandler(io.vertx.core.Handler)
{
io.vertx.core.net.impl.NetSocketImpl v;
io.vertx.core.Handler v;
io.vertx.core.net.impl.ConnectionBase v;
v := @this: io.vertx.core.net.impl.NetSocketImpl;
v := @parameter: io.vertx.core.Handler;
v = specialinvoke v.<io.vertx.core.net.impl.ConnectionBase: io.vertx.core.net.impl.ConnectionBase closeHandler(io.vertx.core.Handler)>(v);
return v;
}
public io.vertx.core.Future upgradeToSsl()
{
io.vertx.core.net.impl.NetSocketImpl v;
java.lang.String v;
io.vertx.core.Future v;
v := @this: io.vertx.core.net.impl.NetSocketImpl;
v = null;
v = virtualinvoke v.<io.vertx.core.net.impl.NetSocketImpl: io.vertx.core.Future upgradeToSsl(java.lang.String)>(v);
return v;
}
public io.vertx.core.Future upgradeToSsl(java.lang.String)
{
io.vertx.core.net.impl.NetSocketImpl v;
io.vertx.core.impl.future.PromiseInternal v;
io.netty.util.concurrent.GenericFutureListener v;
io.vertx.core.impl.ContextInternal v;
io.netty.channel.ChannelPipeline v;
io.vertx.core.Future v;
io.netty.channel.ChannelHandlerContext v, v;
io.netty.channel.ChannelPromise v;
io.netty.channel.ChannelHandler v;
java.lang.String v;
v := @this: io.vertx.core.net.impl.NetSocketImpl;
v := @parameter: java.lang.String;
v = v.<io.vertx.core.net.impl.NetSocketImpl: io.vertx.core.impl.ContextInternal context>;
v = interfaceinvoke v.<io.vertx.core.impl.ContextInternal: io.vertx.core.impl.future.PromiseInternal promise()>();
v = v.<io.vertx.core.net.impl.NetSocketImpl: io.netty.channel.ChannelHandlerContext chctx>;
v = interfaceinvoke v.<io.netty.channel.ChannelHandlerContext: io.netty.channel.ChannelPipeline pipeline()>();
v = interfaceinvoke v.<io.netty.channel.ChannelPipeline: io.netty.channel.ChannelHandler get(java.lang.String)>("ssl");
if v != null goto label;
v = v.<io.vertx.core.net.impl.NetSocketImpl: io.netty.channel.ChannelHandlerContext chctx>;
v = interfaceinvoke v.<io.netty.channel.ChannelHandlerContext: io.netty.channel.ChannelPromise newPromise()>();
virtualinvoke v.<io.vertx.core.net.impl.NetSocketImpl: void flush(io.netty.channel.ChannelPromise)>(v);
v = staticinvoke <io.vertx.core.net.impl.NetSocketImpl$lambda_upgradeToSsl_7__1370: io.netty.util.concurrent.GenericFutureListener bootstrap$(io.vertx.core.net.impl.NetSocketImpl,io.vertx.core.impl.future.PromiseInternal,java.lang.String)>(v, v, v);
interfaceinvoke v.<io.netty.channel.ChannelPromise: io.netty.channel.ChannelPromise addListener(io.netty.util.concurrent.GenericFutureListener)>(v);
label:
v = interfaceinvoke v.<io.vertx.core.impl.future.PromiseInternal: io.vertx.core.Future future()>();
return v;
}
public io.vertx.core.net.NetSocket upgradeToSsl(io.vertx.core.Handler)
{
io.vertx.core.net.impl.NetSocketImpl v;
io.vertx.core.Handler v;
io.vertx.core.net.NetSocket v;
v := @this: io.vertx.core.net.impl.NetSocketImpl;
v := @parameter: io.vertx.core.Handler;
v = virtualinvoke v.<io.vertx.core.net.impl.NetSocketImpl: io.vertx.core.net.NetSocket upgradeToSsl(java.lang.String,io.vertx.core.Handler)>(null, v);
return v;
}
public io.vertx.core.net.NetSocket upgradeToSsl(java.lang.String, io.vertx.core.Handler)
{
io.vertx.core.net.impl.NetSocketImpl v;
java.lang.String v;
io.vertx.core.Handler v;
io.vertx.core.Future v;
v := @this: io.vertx.core.net.impl.NetSocketImpl;
v := @parameter: java.lang.String;
v := @parameter: io.vertx.core.Handler;
v = virtualinvoke v.<io.vertx.core.net.impl.NetSocketImpl: io.vertx.core.Future upgradeToSsl(java.lang.String)>(v);
if v == null goto label;
interfaceinvoke v.<io.vertx.core.Future: io.vertx.core.Future onComplete(io.vertx.core.Handler)>(v);
label:
return v;
}
protected void handleInterestedOpsChanged()
{
io.vertx.core.net.impl.NetSocketImpl v;
io.vertx.core.impl.ContextInternal v;
io.vertx.core.Handler v;
v := @this: io.vertx.core.net.impl.NetSocketImpl;
v = v.<io.vertx.core.net.impl.NetSocketImpl: io.vertx.core.impl.ContextInternal context>;
v = staticinvoke <io.vertx.core.net.impl.NetSocketImpl$lambda_handleInterestedOpsChanged_8__1371: io.vertx.core.Handler bootstrap$(io.vertx.core.net.impl.NetSocketImpl)>(v);
interfaceinvoke v.<io.vertx.core.impl.ContextInternal: void emit(java.lang.Object,io.vertx.core.Handler)>(null, v);
return;
}
public void end(io.vertx.core.Handler)
{
io.vertx.core.net.impl.NetSocketImpl v;
io.vertx.core.Handler v;
v := @this: io.vertx.core.net.impl.NetSocketImpl;
v := @parameter: io.vertx.core.Handler;
virtualinvoke v.<io.vertx.core.net.impl.NetSocketImpl: void close(io.vertx.core.Handler)>(v);
return;
}
public io.vertx.core.Future end()
{
io.vertx.core.net.impl.NetSocketImpl v;
io.vertx.core.Future v;
v := @this: io.vertx.core.net.impl.NetSocketImpl;
v = virtualinvoke v.<io.vertx.core.net.impl.NetSocketImpl: io.vertx.core.Future close()>();
return v;
}
protected void handleClosed()
{
io.vertx.core.net.impl.NetSocketImpl v;
io.vertx.core.streams.impl.InboundBuffer v;
io.vertx.core.impl.ContextInternal v;
java.lang.Object v;
io.vertx.core.Handler v;
v := @this: io.vertx.core.net.impl.NetSocketImpl;
v = v.<io.vertx.core.net.impl.NetSocketImpl: io.vertx.core.impl.ContextInternal context>;
v = <io.vertx.core.streams.impl.InboundBuffer: java.lang.Object END_SENTINEL>;
v = v.<io.vertx.core.net.impl.NetSocketImpl: io.vertx.core.streams.impl.InboundBuffer pending>;
virtualinvoke v.<java.lang.Object: java.lang.Class getClass()>();
v = staticinvoke <io.vertx.core.net.impl.NetSocketImpl$write__1372: io.vertx.core.Handler bootstrap$(io.vertx.core.streams.impl.InboundBuffer)>(v);
interfaceinvoke v.<io.vertx.core.impl.ContextInternal: void emit(java.lang.Object,io.vertx.core.Handler)>(v, v);
specialinvoke v.<io.vertx.core.net.impl.ConnectionBase: void handleClosed()>();
return;
}
public void handleMessage(java.lang.Object)
{
io.vertx.core.net.impl.NetSocketImpl v;
io.vertx.core.impl.ContextInternal v;
java.lang.Object v;
io.vertx.core.Handler v;
v := @this: io.vertx.core.net.impl.NetSocketImpl;
v := @parameter: java.lang.Object;
v = v.<io.vertx.core.net.impl.NetSocketImpl: io.vertx.core.impl.ContextInternal context>;
v = specialinvoke v.<io.vertx.core.net.impl.NetSocketImpl: io.vertx.core.Handler messageHandler()>();
interfaceinvoke v.<io.vertx.core.impl.ContextInternal: void emit(java.lang.Object,io.vertx.core.Handler)>(v, v);
return;
}
protected void handleEvent(java.lang.Object)
{
io.vertx.core.net.impl.NetSocketImpl v;
java.lang.Throwable v;
io.vertx.core.impl.ContextInternal v;
java.lang.Object v;
io.vertx.core.Handler v;
v := @this: io.vertx.core.net.impl.NetSocketImpl;
v := @parameter: java.lang.Object;
entermonitor v;
label:
v = v.<io.vertx.core.net.impl.NetSocketImpl: io.vertx.core.Handler eventHandler>;
exitmonitor v;
label:
goto label;
label:
v := @caughtexception;
exitmonitor v;
throw v;
label:
if v == null goto label;
v = v.<io.vertx.core.net.impl.NetSocketImpl: io.vertx.core.impl.ContextInternal context>;
interfaceinvoke v.<io.vertx.core.impl.ContextInternal: void emit(java.lang.Object,io.vertx.core.Handler)>(v, v);
goto label;
label:
specialinvoke v.<io.vertx.core.net.impl.ConnectionBase: void handleEvent(java.lang.Object)>(v);
label:
return;
catch java.lang.Throwable from label to label with label;
}
private synchronized void callDrainHandler()
{
io.vertx.core.net.impl.NetSocketImpl v;
io.vertx.core.Handler v, v;
boolean v;
v := @this: io.vertx.core.net.impl.NetSocketImpl;
v = v.<io.vertx.core.net.impl.NetSocketImpl: io.vertx.core.Handler drainHandler>;
if v == null goto label;
v = virtualinvoke v.<io.vertx.core.net.impl.NetSocketImpl: boolean writeQueueFull()>();
if v != 0 goto label;
v = v.<io.vertx.core.net.impl.NetSocketImpl: io.vertx.core.Handler drainHandler>;
interfaceinvoke v.<io.vertx.core.Handler: void handle(java.lang.Object)>(null);
label:
return;
}
static void <clinit>()
{
io.vertx.core.impl.logging.Logger v;
v = staticinvoke <io.vertx.core.impl.logging.LoggerFactory: io.vertx.core.impl.logging.Logger getLogger(java.lang.Class)>(class "Lio/vertx/core/net/impl/NetSocketImpl;");
<io.vertx.core.net.impl.NetSocketImpl: io.vertx.core.impl.logging.Logger log> = v;
return;
}
}