public class io.vertx.core.net.impl.NetSocketImpl extends io.vertx.core.net.impl.ConnectionBase implements io.vertx.core.impl.NetSocketInternal
minor version: 0
major version: 59
flags: flags: (0x0021) ACC_PUBLIC, ACC_SUPER
this_class: io.vertx.core.net.impl.NetSocketImpl
super_class: io.vertx.core.net.impl.ConnectionBase
{
private static final io.vertx.core.Handler<java.lang.Object> NULL_MSG_HANDLER;
descriptor: Lio/vertx/core/Handler;
flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL
Signature: Lio/vertx/core/Handler<Ljava/lang/Object;>;
private static final io.vertx.core.logging.Logger log;
descriptor: Lio/vertx/core/logging/Logger;
flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL
private final java.lang.String writeHandlerID;
descriptor: Ljava/lang/String;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
private final io.vertx.core.net.impl.SSLHelper helper;
descriptor: Lio/vertx/core/net/impl/SSLHelper;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
private final io.vertx.core.net.SocketAddress remoteAddress;
descriptor: Lio/vertx/core/net/SocketAddress;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
private final io.vertx.core.spi.metrics.TCPMetrics metrics;
descriptor: Lio/vertx/core/spi/metrics/TCPMetrics;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
private io.vertx.core.Handler<java.lang.Void> endHandler;
descriptor: Lio/vertx/core/Handler;
flags: (0x0002) ACC_PRIVATE
Signature: Lio/vertx/core/Handler<Ljava/lang/Void;>;
private io.vertx.core.Handler<java.lang.Void> drainHandler;
descriptor: Lio/vertx/core/Handler;
flags: (0x0002) ACC_PRIVATE
Signature: Lio/vertx/core/Handler<Ljava/lang/Void;>;
private io.vertx.core.streams.impl.InboundBuffer<java.lang.Object> pending;
descriptor: Lio/vertx/core/streams/impl/InboundBuffer;
flags: (0x0002) ACC_PRIVATE
Signature: Lio/vertx/core/streams/impl/InboundBuffer<Ljava/lang/Object;>;
private io.vertx.core.eventbus.MessageConsumer registration;
descriptor: Lio/vertx/core/eventbus/MessageConsumer;
flags: (0x0002) ACC_PRIVATE
private io.vertx.core.Handler<java.lang.Object> messageHandler;
descriptor: Lio/vertx/core/Handler;
flags: (0x0002) ACC_PRIVATE
Signature: Lio/vertx/core/Handler<Ljava/lang/Object;>;
private boolean closed;
descriptor: Z
flags: (0x0002) ACC_PRIVATE
static void <clinit>();
descriptor: ()V
flags: (0x0008) ACC_STATIC
Code:
stack=1, locals=0, args_size=0
0: invokedynamic handle()Lio/vertx/core/Handler;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
(Ljava/lang/Object;)V
io/vertx/core/net/impl/NetSocketImpl.lambda$0(Ljava/lang/Object;)V (6)
(Ljava/lang/Object;)V
putstatic io.vertx.core.net.impl.NetSocketImpl.NULL_MSG_HANDLER:Lio/vertx/core/Handler;
1: ldc Lio/vertx/core/net/impl/NetSocketImpl;
invokestatic io.vertx.core.logging.LoggerFactory.getLogger:(Ljava/lang/Class;)Lio/vertx/core/logging/Logger;
putstatic io.vertx.core.net.impl.NetSocketImpl.log:Lio/vertx/core/logging/Logger;
return
LocalVariableTable:
Start End Slot Name Signature
public void <init>(io.vertx.core.impl.VertxInternal, io.netty.channel.ChannelHandlerContext, io.vertx.core.impl.ContextInternal, io.vertx.core.net.impl.SSLHelper, io.vertx.core.spi.metrics.TCPMetrics);
descriptor: (Lio/vertx/core/impl/VertxInternal;Lio/netty/channel/ChannelHandlerContext;Lio/vertx/core/impl/ContextInternal;Lio/vertx/core/net/impl/SSLHelper;Lio/vertx/core/spi/metrics/TCPMetrics;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=7, locals=6, args_size=6
start local 0 start local 1 start local 2 start local 3 start local 4 start local 5 0: aload 0
aload 1
aload 2
aconst_null
aload 3
aload 4
aload 5
invokespecial io.vertx.core.net.impl.NetSocketImpl.<init>:(Lio/vertx/core/impl/VertxInternal;Lio/netty/channel/ChannelHandlerContext;Lio/vertx/core/net/SocketAddress;Lio/vertx/core/impl/ContextInternal;Lio/vertx/core/net/impl/SSLHelper;Lio/vertx/core/spi/metrics/TCPMetrics;)V
1: return
end local 5 end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lio/vertx/core/net/impl/NetSocketImpl;
0 2 1 vertx Lio/vertx/core/impl/VertxInternal;
0 2 2 channel Lio/netty/channel/ChannelHandlerContext;
0 2 3 context Lio/vertx/core/impl/ContextInternal;
0 2 4 helper Lio/vertx/core/net/impl/SSLHelper;
0 2 5 metrics Lio/vertx/core/spi/metrics/TCPMetrics;
MethodParameters:
Name Flags
vertx
channel
context
helper
metrics
public void <init>(io.vertx.core.impl.VertxInternal, io.netty.channel.ChannelHandlerContext, io.vertx.core.net.SocketAddress, io.vertx.core.impl.ContextInternal, io.vertx.core.net.impl.SSLHelper, io.vertx.core.spi.metrics.TCPMetrics);
descriptor: (Lio/vertx/core/impl/VertxInternal;Lio/netty/channel/ChannelHandlerContext;Lio/vertx/core/net/SocketAddress;Lio/vertx/core/impl/ContextInternal;Lio/vertx/core/net/impl/SSLHelper;Lio/vertx/core/spi/metrics/TCPMetrics;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=4, locals=7, args_size=7
start local 0 start local 1 start local 2 start local 3 start local 4 start local 5 start local 6 0: aload 0
aload 1
aload 2
aload 4
invokespecial io.vertx.core.net.impl.ConnectionBase.<init>:(Lio/vertx/core/impl/VertxInternal;Lio/netty/channel/ChannelHandlerContext;Lio/vertx/core/impl/ContextInternal;)V
1: aload 0
aload 5
putfield io.vertx.core.net.impl.NetSocketImpl.helper:Lio/vertx/core/net/impl/SSLHelper;
2: aload 0
new java.lang.StringBuilder
dup
ldc "__vertx.net."
invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
invokestatic java.util.UUID.randomUUID:()Ljava/util/UUID;
invokevirtual java.util.UUID.toString:()Ljava/lang/String;
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
putfield io.vertx.core.net.impl.NetSocketImpl.writeHandlerID:Ljava/lang/String;
3: aload 0
aload 3
putfield io.vertx.core.net.impl.NetSocketImpl.remoteAddress:Lio/vertx/core/net/SocketAddress;
4: aload 0
aload 6
putfield io.vertx.core.net.impl.NetSocketImpl.metrics:Lio/vertx/core/spi/metrics/TCPMetrics;
5: aload 0
getstatic io.vertx.core.net.impl.NetSocketImpl.NULL_MSG_HANDLER:Lio/vertx/core/Handler;
putfield io.vertx.core.net.impl.NetSocketImpl.messageHandler:Lio/vertx/core/Handler;
6: aload 0
new io.vertx.core.streams.impl.InboundBuffer
dup
aload 4
invokespecial io.vertx.core.streams.impl.InboundBuffer.<init>:(Lio/vertx/core/Context;)V
putfield io.vertx.core.net.impl.NetSocketImpl.pending:Lio/vertx/core/streams/impl/InboundBuffer;
7: aload 0
getfield io.vertx.core.net.impl.NetSocketImpl.pending:Lio/vertx/core/streams/impl/InboundBuffer;
aload 0
invokedynamic handle(Lio/vertx/core/net/impl/NetSocketImpl;)Lio/vertx/core/Handler;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
(Ljava/lang/Object;)V
io/vertx/core/net/impl/NetSocketImpl.lambda$1(Ljava/lang/Void;)V (7)
(Ljava/lang/Void;)V
invokevirtual io.vertx.core.streams.impl.InboundBuffer.drainHandler:(Lio/vertx/core/Handler;)Lio/vertx/core/streams/impl/InboundBuffer;
pop
8: aload 0
getfield io.vertx.core.net.impl.NetSocketImpl.pending:Lio/vertx/core/streams/impl/InboundBuffer;
aload 0
invokedynamic handle(Lio/vertx/core/net/impl/NetSocketImpl;)Lio/vertx/core/Handler;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
(Ljava/lang/Object;)V
io/vertx/core/net/impl/NetSocketImpl.lambda$2(Ljava/lang/Object;)V (7)
(Ljava/lang/Object;)V
invokevirtual io.vertx.core.streams.impl.InboundBuffer.handler:(Lio/vertx/core/Handler;)Lio/vertx/core/streams/impl/InboundBuffer;
pop
9: return
end local 6 end local 5 end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 10 0 this Lio/vertx/core/net/impl/NetSocketImpl;
0 10 1 vertx Lio/vertx/core/impl/VertxInternal;
0 10 2 channel Lio/netty/channel/ChannelHandlerContext;
0 10 3 remoteAddress Lio/vertx/core/net/SocketAddress;
0 10 4 context Lio/vertx/core/impl/ContextInternal;
0 10 5 helper Lio/vertx/core/net/impl/SSLHelper;
0 10 6 metrics Lio/vertx/core/spi/metrics/TCPMetrics;
MethodParameters:
Name Flags
vertx
channel
remoteAddress
context
helper
metrics
synchronized void registerEventBusHandler();
descriptor: ()V
flags: (0x0020) ACC_SYNCHRONIZED
Code:
stack=3, locals=2, args_size=1
start local 0 0: aload 0
invokedynamic handle(Lio/vertx/core/net/impl/NetSocketImpl;)Lio/vertx/core/Handler;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
(Ljava/lang/Object;)V
io/vertx/core/net/impl/NetSocketImpl.lambda$3(Lio/vertx/core/eventbus/Message;)V (7)
(Lio/vertx/core/eventbus/Message;)V
astore 1
start local 1 1: aload 0
aload 0
getfield io.vertx.core.net.impl.NetSocketImpl.vertx:Lio/vertx/core/impl/VertxInternal;
invokeinterface io.vertx.core.impl.VertxInternal.eventBus:()Lio/vertx/core/eventbus/EventBus;
aload 0
getfield io.vertx.core.net.impl.NetSocketImpl.writeHandlerID:Ljava/lang/String;
invokeinterface io.vertx.core.eventbus.EventBus.localConsumer:(Ljava/lang/String;)Lio/vertx/core/eventbus/MessageConsumer;
aload 1
invokeinterface io.vertx.core.eventbus.MessageConsumer.handler:(Lio/vertx/core/Handler;)Lio/vertx/core/eventbus/MessageConsumer;
putfield io.vertx.core.net.impl.NetSocketImpl.registration:Lio/vertx/core/eventbus/MessageConsumer;
2: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 this Lio/vertx/core/net/impl/NetSocketImpl;
1 3 1 writeHandler Lio/vertx/core/Handler<Lio/vertx/core/eventbus/Message<Lio/vertx/core/buffer/Buffer;>;>;
public io.vertx.core.spi.metrics.TCPMetrics metrics();
descriptor: ()Lio/vertx/core/spi/metrics/TCPMetrics;
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield io.vertx.core.net.impl.NetSocketImpl.metrics:Lio/vertx/core/spi/metrics/TCPMetrics;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/core/net/impl/NetSocketImpl;
public java.lang.String writeHandlerID();
descriptor: ()Ljava/lang/String;
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield io.vertx.core.net.impl.NetSocketImpl.writeHandlerID:Ljava/lang/String;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/core/net/impl/NetSocketImpl;
public synchronized io.vertx.core.impl.NetSocketInternal writeMessage(java.lang.Object);
descriptor: (Ljava/lang/Object;)Lio/vertx/core/impl/NetSocketInternal;
flags: (0x0021) ACC_PUBLIC, ACC_SYNCHRONIZED
Code:
stack=3, locals=2, args_size=2
start local 0 start local 1 0: aload 0
getfield io.vertx.core.net.impl.NetSocketImpl.closed:Z
ifeq 2
1: new java.lang.IllegalStateException
dup
ldc "Socket is closed"
invokespecial java.lang.IllegalStateException.<init>:(Ljava/lang/String;)V
athrow
2: StackMap locals:
StackMap stack:
aload 0
aload 1
invokevirtual io.vertx.core.net.impl.NetSocketImpl.writeToChannel:(Ljava/lang/Object;)V
3: aload 0
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 this Lio/vertx/core/net/impl/NetSocketImpl;
0 4 1 message Ljava/lang/Object;
MethodParameters:
Name Flags
message
public io.vertx.core.impl.NetSocketInternal writeMessage(, io.vertx.core.Handler<io.vertx.core.AsyncResult<java.lang.Void>>);
descriptor: (Ljava/lang/Object;Lio/vertx/core/Handler;)Lio/vertx/core/impl/NetSocketInternal;
flags: (0x0001) ACC_PUBLIC
Code:
stack=4, locals=3, args_size=3
start local 0 start local 1 start local 2 0: aload 0
aload 1
aload 0
aload 2
invokevirtual io.vertx.core.net.impl.NetSocketImpl.toPromise:(Lio/vertx/core/Handler;)Lio/netty/channel/ChannelPromise;
invokevirtual io.vertx.core.net.impl.NetSocketImpl.writeToChannel:(Ljava/lang/Object;Lio/netty/channel/ChannelPromise;)V
1: aload 0
areturn
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lio/vertx/core/net/impl/NetSocketImpl;
0 2 1 message Ljava/lang/Object;
0 2 2 handler Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/Void;>;>;
Signature: (Ljava/lang/Object;Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/Void;>;>;)Lio/vertx/core/impl/NetSocketInternal;
MethodParameters:
Name Flags
message
handler
public io.vertx.core.net.NetSocket write(io.vertx.core.buffer.Buffer);
descriptor: (Lio/vertx/core/buffer/Buffer;)Lio/vertx/core/net/NetSocket;
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=2, args_size=2
start local 0 start local 1 0: aload 0
aload 1
invokeinterface io.vertx.core.buffer.Buffer.getByteBuf:()Lio/netty/buffer/ByteBuf;
aconst_null
invokevirtual io.vertx.core.net.impl.NetSocketImpl.write:(Lio/netty/buffer/ByteBuf;Lio/vertx/core/Handler;)V
1: aload 0
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lio/vertx/core/net/impl/NetSocketImpl;
0 2 1 data Lio/vertx/core/buffer/Buffer;
MethodParameters:
Name Flags
data
public io.vertx.core.net.NetSocket write(java.lang.String);
descriptor: (Ljava/lang/String;)Lio/vertx/core/net/NetSocket;
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=2, args_size=2
start local 0 start local 1 0: aload 0
aload 1
aconst_null
invokevirtual io.vertx.core.net.impl.NetSocketImpl.write:(Ljava/lang/String;Lio/vertx/core/Handler;)Lio/vertx/core/net/NetSocket;
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/core/net/impl/NetSocketImpl;
0 1 1 str Ljava/lang/String;
MethodParameters:
Name Flags
str
public io.vertx.core.net.NetSocket write(java.lang.String, io.vertx.core.Handler<io.vertx.core.AsyncResult<java.lang.Void>>);
descriptor: (Ljava/lang/String;Lio/vertx/core/Handler;)Lio/vertx/core/net/NetSocket;
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=3, args_size=3
start local 0 start local 1 start local 2 0: aload 0
aload 1
getstatic io.netty.util.CharsetUtil.UTF_8:Ljava/nio/charset/Charset;
invokestatic io.netty.buffer.Unpooled.copiedBuffer:(Ljava/lang/CharSequence;Ljava/nio/charset/Charset;)Lio/netty/buffer/ByteBuf;
aload 2
invokevirtual io.vertx.core.net.impl.NetSocketImpl.write:(Lio/netty/buffer/ByteBuf;Lio/vertx/core/Handler;)V
1: aload 0
areturn
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lio/vertx/core/net/impl/NetSocketImpl;
0 2 1 str Ljava/lang/String;
0 2 2 handler Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/Void;>;>;
Signature: (Ljava/lang/String;Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/Void;>;>;)Lio/vertx/core/net/NetSocket;
MethodParameters:
Name Flags
str
handler
public io.vertx.core.net.NetSocket write(java.lang.String, java.lang.String);
descriptor: (Ljava/lang/String;Ljava/lang/String;)Lio/vertx/core/net/NetSocket;
flags: (0x0001) ACC_PUBLIC
Code:
stack=4, locals=3, args_size=3
start local 0 start local 1 start local 2 0: aload 0
aload 1
aload 2
aconst_null
invokevirtual io.vertx.core.net.impl.NetSocketImpl.write:(Ljava/lang/String;Ljava/lang/String;Lio/vertx/core/Handler;)Lio/vertx/core/net/NetSocket;
areturn
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/core/net/impl/NetSocketImpl;
0 1 1 str Ljava/lang/String;
0 1 2 enc Ljava/lang/String;
MethodParameters:
Name Flags
str
enc
public io.vertx.core.net.NetSocket write(java.lang.String, java.lang.String, io.vertx.core.Handler<io.vertx.core.AsyncResult<java.lang.Void>>);
descriptor: (Ljava/lang/String;Ljava/lang/String;Lio/vertx/core/Handler;)Lio/vertx/core/net/NetSocket;
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=4, args_size=4
start local 0 start local 1 start local 2 start local 3 0: aload 2
ifnonnull 3
1: aload 0
aload 1
invokevirtual io.vertx.core.net.impl.NetSocketImpl.write:(Ljava/lang/String;)Lio/vertx/core/net/NetSocket;
pop
2: goto 4
3: StackMap locals:
StackMap stack:
aload 0
aload 1
aload 2
invokestatic java.nio.charset.Charset.forName:(Ljava/lang/String;)Ljava/nio/charset/Charset;
invokestatic io.netty.buffer.Unpooled.copiedBuffer:(Ljava/lang/CharSequence;Ljava/nio/charset/Charset;)Lio/netty/buffer/ByteBuf;
aload 3
invokevirtual io.vertx.core.net.impl.NetSocketImpl.write:(Lio/netty/buffer/ByteBuf;Lio/vertx/core/Handler;)V
4: StackMap locals:
StackMap stack:
aload 0
areturn
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 5 0 this Lio/vertx/core/net/impl/NetSocketImpl;
0 5 1 str Ljava/lang/String;
0 5 2 enc Ljava/lang/String;
0 5 3 handler Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/Void;>;>;
Signature: (Ljava/lang/String;Ljava/lang/String;Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/Void;>;>;)Lio/vertx/core/net/NetSocket;
MethodParameters:
Name Flags
str
enc
handler
public io.vertx.core.net.NetSocket write(io.vertx.core.buffer.Buffer, io.vertx.core.Handler<io.vertx.core.AsyncResult<java.lang.Void>>);
descriptor: (Lio/vertx/core/buffer/Buffer;Lio/vertx/core/Handler;)Lio/vertx/core/net/NetSocket;
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=3, args_size=3
start local 0 start local 1 start local 2 0: aload 0
aload 1
invokeinterface io.vertx.core.buffer.Buffer.getByteBuf:()Lio/netty/buffer/ByteBuf;
aload 2
invokevirtual io.vertx.core.net.impl.NetSocketImpl.write:(Lio/netty/buffer/ByteBuf;Lio/vertx/core/Handler;)V
1: aload 0
areturn
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lio/vertx/core/net/impl/NetSocketImpl;
0 2 1 message Lio/vertx/core/buffer/Buffer;
0 2 2 handler Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/Void;>;>;
Signature: (Lio/vertx/core/buffer/Buffer;Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/Void;>;>;)Lio/vertx/core/net/NetSocket;
MethodParameters:
Name Flags
message
handler
private void write(io.netty.buffer.ByteBuf, io.vertx.core.Handler<io.vertx.core.AsyncResult<java.lang.Void>>);
descriptor: (Lio/netty/buffer/ByteBuf;Lio/vertx/core/Handler;)V
flags: (0x0002) ACC_PRIVATE
Code:
stack=3, locals=3, args_size=3
start local 0 start local 1 start local 2 0: aload 0
aload 1
invokevirtual io.netty.buffer.ByteBuf.readableBytes:()I
i2l
invokevirtual io.vertx.core.net.impl.NetSocketImpl.reportBytesWritten:(J)V
1: aload 0
aload 1
aload 2
invokevirtual io.vertx.core.net.impl.NetSocketImpl.writeMessage:(Ljava/lang/Object;Lio/vertx/core/Handler;)Lio/vertx/core/impl/NetSocketInternal;
pop
2: return
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 this Lio/vertx/core/net/impl/NetSocketImpl;
0 3 1 buff Lio/netty/buffer/ByteBuf;
0 3 2 handler Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/Void;>;>;
Signature: (Lio/netty/buffer/ByteBuf;Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/Void;>;>;)V
MethodParameters:
Name Flags
buff
handler
public synchronized io.vertx.core.net.NetSocket handler(io.vertx.core.Handler<io.vertx.core.buffer.Buffer>);
descriptor: (Lio/vertx/core/Handler;)Lio/vertx/core/net/NetSocket;
flags: (0x0021) ACC_PUBLIC, ACC_SYNCHRONIZED
Code:
stack=6, locals=2, args_size=2
start local 0 start local 1 0: aload 1
ifnull 3
1: aload 0
new io.vertx.core.net.impl.NetSocketImpl$DataMessageHandler
dup
aload 0
aload 0
invokevirtual io.vertx.core.net.impl.NetSocketImpl.channelHandlerContext:()Lio/netty/channel/ChannelHandlerContext;
invokeinterface io.netty.channel.ChannelHandlerContext.alloc:()Lio/netty/buffer/ByteBufAllocator;
aload 1
invokespecial io.vertx.core.net.impl.NetSocketImpl$DataMessageHandler.<init>:(Lio/vertx/core/net/impl/NetSocketImpl;Lio/netty/buffer/ByteBufAllocator;Lio/vertx/core/Handler;)V
invokevirtual io.vertx.core.net.impl.NetSocketImpl.messageHandler:(Lio/vertx/core/Handler;)Lio/vertx/core/impl/NetSocketInternal;
pop
2: goto 4
3: StackMap locals:
StackMap stack:
aload 0
aconst_null
invokevirtual io.vertx.core.net.impl.NetSocketImpl.messageHandler:(Lio/vertx/core/Handler;)Lio/vertx/core/impl/NetSocketInternal;
pop
4: StackMap locals:
StackMap stack:
aload 0
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 5 0 this Lio/vertx/core/net/impl/NetSocketImpl;
0 5 1 dataHandler Lio/vertx/core/Handler<Lio/vertx/core/buffer/Buffer;>;
Signature: (Lio/vertx/core/Handler<Lio/vertx/core/buffer/Buffer;>;)Lio/vertx/core/net/NetSocket;
MethodParameters:
Name Flags
dataHandler
private synchronized io.vertx.core.Handler<java.lang.Object> messageHandler();
descriptor: ()Lio/vertx/core/Handler;
flags: (0x0022) ACC_PRIVATE, ACC_SYNCHRONIZED
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield io.vertx.core.net.impl.NetSocketImpl.messageHandler:Lio/vertx/core/Handler;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/core/net/impl/NetSocketImpl;
Signature: ()Lio/vertx/core/Handler<Ljava/lang/Object;>;
public synchronized io.vertx.core.impl.NetSocketInternal messageHandler(io.vertx.core.Handler<java.lang.Object>);
descriptor: (Lio/vertx/core/Handler;)Lio/vertx/core/impl/NetSocketInternal;
flags: (0x0021) ACC_PUBLIC, ACC_SYNCHRONIZED
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 0
aload 1
putfield io.vertx.core.net.impl.NetSocketImpl.messageHandler:Lio/vertx/core/Handler;
1: aload 0
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lio/vertx/core/net/impl/NetSocketImpl;
0 2 1 handler Lio/vertx/core/Handler<Ljava/lang/Object;>;
Signature: (Lio/vertx/core/Handler<Ljava/lang/Object;>;)Lio/vertx/core/impl/NetSocketInternal;
MethodParameters:
Name Flags
handler
public synchronized io.vertx.core.net.NetSocket pause();
descriptor: ()Lio/vertx/core/net/NetSocket;
flags: (0x0021) ACC_PUBLIC, ACC_SYNCHRONIZED
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield io.vertx.core.net.impl.NetSocketImpl.pending:Lio/vertx/core/streams/impl/InboundBuffer;
invokevirtual io.vertx.core.streams.impl.InboundBuffer.pause:()Lio/vertx/core/streams/impl/InboundBuffer;
pop
1: aload 0
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lio/vertx/core/net/impl/NetSocketImpl;
public io.vertx.core.net.NetSocket fetch(long);
descriptor: (J)Lio/vertx/core/net/NetSocket;
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=3, args_size=2
start local 0 start local 1 0: aload 0
getfield io.vertx.core.net.impl.NetSocketImpl.pending:Lio/vertx/core/streams/impl/InboundBuffer;
lload 1
invokevirtual io.vertx.core.streams.impl.InboundBuffer.fetch:(J)Z
pop
1: aload 0
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lio/vertx/core/net/impl/NetSocketImpl;
0 2 1 amount J
MethodParameters:
Name Flags
amount
public synchronized io.vertx.core.net.NetSocket resume();
descriptor: ()Lio/vertx/core/net/NetSocket;
flags: (0x0021) ACC_PUBLIC, ACC_SYNCHRONIZED
Code:
stack=3, locals=1, args_size=1
start local 0 0: aload 0
ldc 9223372036854775807
invokevirtual io.vertx.core.net.impl.NetSocketImpl.fetch:(J)Lio/vertx/core/net/NetSocket;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/core/net/impl/NetSocketImpl;
public io.vertx.core.net.NetSocket setWriteQueueMaxSize(int);
descriptor: (I)Lio/vertx/core/net/NetSocket;
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 0
iload 1
invokevirtual io.vertx.core.net.impl.NetSocketImpl.doSetWriteQueueMaxSize:(I)V
1: aload 0
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lio/vertx/core/net/impl/NetSocketImpl;
0 2 1 maxSize I
MethodParameters:
Name Flags
maxSize
public boolean writeQueueFull();
descriptor: ()Z
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
invokevirtual io.vertx.core.net.impl.NetSocketImpl.isNotWritable:()Z
ireturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/core/net/impl/NetSocketImpl;
private synchronized io.vertx.core.Handler<java.lang.Void> endHandler();
descriptor: ()Lio/vertx/core/Handler;
flags: (0x0022) ACC_PRIVATE, ACC_SYNCHRONIZED
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield io.vertx.core.net.impl.NetSocketImpl.endHandler:Lio/vertx/core/Handler;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/core/net/impl/NetSocketImpl;
Signature: ()Lio/vertx/core/Handler<Ljava/lang/Void;>;
public synchronized io.vertx.core.net.NetSocket endHandler(io.vertx.core.Handler<java.lang.Void>);
descriptor: (Lio/vertx/core/Handler;)Lio/vertx/core/net/NetSocket;
flags: (0x0021) ACC_PUBLIC, ACC_SYNCHRONIZED
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 0
aload 1
putfield io.vertx.core.net.impl.NetSocketImpl.endHandler:Lio/vertx/core/Handler;
1: aload 0
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lio/vertx/core/net/impl/NetSocketImpl;
0 2 1 endHandler Lio/vertx/core/Handler<Ljava/lang/Void;>;
Signature: (Lio/vertx/core/Handler<Ljava/lang/Void;>;)Lio/vertx/core/net/NetSocket;
MethodParameters:
Name Flags
endHandler
public synchronized io.vertx.core.net.NetSocket drainHandler(io.vertx.core.Handler<java.lang.Void>);
descriptor: (Lio/vertx/core/Handler;)Lio/vertx/core/net/NetSocket;
flags: (0x0021) ACC_PUBLIC, ACC_SYNCHRONIZED
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 0
aload 1
putfield io.vertx.core.net.impl.NetSocketImpl.drainHandler:Lio/vertx/core/Handler;
1: aload 0
getfield io.vertx.core.net.impl.NetSocketImpl.vertx:Lio/vertx/core/impl/VertxInternal;
aload 0
invokedynamic handle(Lio/vertx/core/net/impl/NetSocketImpl;)Lio/vertx/core/Handler;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
(Ljava/lang/Object;)V
io/vertx/core/net/impl/NetSocketImpl.lambda$4(Ljava/lang/Void;)V (7)
(Ljava/lang/Void;)V
invokeinterface io.vertx.core.impl.VertxInternal.runOnContext:(Lio/vertx/core/Handler;)V
2: aload 0
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 this Lio/vertx/core/net/impl/NetSocketImpl;
0 3 1 drainHandler Lio/vertx/core/Handler<Ljava/lang/Void;>;
Signature: (Lio/vertx/core/Handler<Ljava/lang/Void;>;)Lio/vertx/core/net/NetSocket;
MethodParameters:
Name Flags
drainHandler
public io.vertx.core.net.NetSocket sendFile(java.lang.String, long, long);
descriptor: (Ljava/lang/String;JJ)Lio/vertx/core/net/NetSocket;
flags: (0x0001) ACC_PUBLIC
Code:
stack=7, locals=6, args_size=4
start local 0 start local 1 start local 2 start local 4 0: aload 0
aload 1
lload 2
lload 4
aconst_null
invokevirtual io.vertx.core.net.impl.NetSocketImpl.sendFile:(Ljava/lang/String;JJLio/vertx/core/Handler;)Lio/vertx/core/net/NetSocket;
areturn
end local 4 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/core/net/impl/NetSocketImpl;
0 1 1 filename Ljava/lang/String;
0 1 2 offset J
0 1 4 length J
MethodParameters:
Name Flags
filename
offset
length
public io.vertx.core.net.NetSocket sendFile(java.lang.String, long, long, io.vertx.core.Handler<io.vertx.core.AsyncResult<java.lang.Void>>);
descriptor: (Ljava/lang/String;JJLio/vertx/core/Handler;)Lio/vertx/core/net/NetSocket;
flags: (0x0001) ACC_PUBLIC
Code:
stack=10, locals=10, args_size=5
start local 0 start local 1 start local 2 start local 4 start local 6 0: aload 0
getfield io.vertx.core.net.impl.NetSocketImpl.vertx:Lio/vertx/core/impl/VertxInternal;
aload 1
invokeinterface io.vertx.core.impl.VertxInternal.resolveFile:(Ljava/lang/String;)Ljava/io/File;
astore 7
start local 7 1: aload 7
invokevirtual java.io.File.isDirectory:()Z
ifeq 3
2: new java.lang.IllegalArgumentException
dup
ldc "filename must point to a file and not to a directory"
invokespecial java.lang.IllegalArgumentException.<init>:(Ljava/lang/String;)V
athrow
3: StackMap locals: java.io.File
StackMap stack:
aconst_null
astore 8
start local 8 4: new java.io.RandomAccessFile
dup
aload 7
ldc "r"
invokespecial java.io.RandomAccessFile.<init>:(Ljava/io/File;Ljava/lang/String;)V
astore 8
5: aload 0
aload 8
lload 2
aload 7
invokevirtual java.io.File.length:()J
invokestatic java.lang.Math.min:(JJ)J
lload 4
aload 7
invokevirtual java.io.File.length:()J
lload 2
lsub
invokestatic java.lang.Math.min:(JJ)J
invokespecial io.vertx.core.net.impl.ConnectionBase.sendFile:(Ljava/io/RandomAccessFile;JJ)Lio/netty/channel/ChannelFuture;
astore 9
start local 9 6: aload 6
ifnull 18
7: aload 9
aload 0
aload 9
aload 6
invokedynamic operationComplete(Lio/vertx/core/net/impl/NetSocketImpl;Lio/netty/channel/ChannelFuture;Lio/vertx/core/Handler;)Lio/netty/util/concurrent/GenericFutureListener;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
(Lio/netty/util/concurrent/Future;)V
io/vertx/core/net/impl/NetSocketImpl.lambda$5(Lio/netty/channel/ChannelFuture;Lio/vertx/core/Handler;Lio/netty/util/concurrent/Future;)V (7)
(Lio/netty/util/concurrent/Future;)V
invokeinterface io.netty.channel.ChannelFuture.addListener:(Lio/netty/util/concurrent/GenericFutureListener;)Lio/netty/channel/ChannelFuture;
pop
end local 9 8: goto 18
StackMap locals: io.vertx.core.net.impl.NetSocketImpl java.lang.String long long io.vertx.core.Handler java.io.File java.io.RandomAccessFile
StackMap stack: java.io.IOException
9: astore 9
start local 9 10: aload 8
ifnull 14
11: aload 8
invokevirtual java.io.RandomAccessFile.close:()V
12: goto 14
StackMap locals: io.vertx.core.net.impl.NetSocketImpl java.lang.String long long io.vertx.core.Handler java.io.File java.io.RandomAccessFile java.io.IOException
StackMap stack: java.io.IOException
13: pop
14: StackMap locals:
StackMap stack:
aload 6
ifnull 17
15: aload 0
getfield io.vertx.core.net.impl.NetSocketImpl.vertx:Lio/vertx/core/impl/VertxInternal;
aload 6
aload 9
invokedynamic handle(Lio/vertx/core/Handler;Ljava/io/IOException;)Lio/vertx/core/Handler;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
(Ljava/lang/Object;)V
io/vertx/core/net/impl/NetSocketImpl.lambda$7(Lio/vertx/core/Handler;Ljava/io/IOException;Ljava/lang/Void;)V (6)
(Ljava/lang/Void;)V
invokeinterface io.vertx.core.impl.VertxInternal.runOnContext:(Lio/vertx/core/Handler;)V
16: goto 18
17: StackMap locals:
StackMap stack:
getstatic io.vertx.core.net.impl.NetSocketImpl.log:Lio/vertx/core/logging/Logger;
ldc "Failed to send file"
aload 9
invokevirtual io.vertx.core.logging.Logger.error:(Ljava/lang/Object;Ljava/lang/Throwable;)V
end local 9 18: StackMap locals:
StackMap stack:
aload 0
areturn
end local 8 end local 7 end local 6 end local 4 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 19 0 this Lio/vertx/core/net/impl/NetSocketImpl;
0 19 1 filename Ljava/lang/String;
0 19 2 offset J
0 19 4 length J
0 19 6 resultHandler Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/Void;>;>;
1 19 7 f Ljava/io/File;
4 19 8 raf Ljava/io/RandomAccessFile;
6 8 9 future Lio/netty/channel/ChannelFuture;
10 18 9 e Ljava/io/IOException;
Exception table:
from to target type
4 8 9 Class java.io.IOException
10 12 13 Class java.io.IOException
Signature: (Ljava/lang/String;JJLio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/Void;>;>;)Lio/vertx/core/net/NetSocket;
MethodParameters:
Name Flags
filename
offset
length
resultHandler final
public io.vertx.core.net.impl.NetSocketImpl exceptionHandler(io.vertx.core.Handler<java.lang.Throwable>);
descriptor: (Lio/vertx/core/Handler;)Lio/vertx/core/net/impl/NetSocketImpl;
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 0
aload 1
invokespecial io.vertx.core.net.impl.ConnectionBase.exceptionHandler:(Lio/vertx/core/Handler;)Lio/vertx/core/net/impl/ConnectionBase;
checkcast io.vertx.core.net.impl.NetSocketImpl
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/core/net/impl/NetSocketImpl;
0 1 1 handler Lio/vertx/core/Handler<Ljava/lang/Throwable;>;
Signature: (Lio/vertx/core/Handler<Ljava/lang/Throwable;>;)Lio/vertx/core/net/impl/NetSocketImpl;
MethodParameters:
Name Flags
handler
public io.vertx.core.net.impl.NetSocketImpl closeHandler(io.vertx.core.Handler<java.lang.Void>);
descriptor: (Lio/vertx/core/Handler;)Lio/vertx/core/net/impl/NetSocketImpl;
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 0
aload 1
invokespecial io.vertx.core.net.impl.ConnectionBase.closeHandler:(Lio/vertx/core/Handler;)Lio/vertx/core/net/impl/ConnectionBase;
checkcast io.vertx.core.net.impl.NetSocketImpl
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/core/net/impl/NetSocketImpl;
0 1 1 handler Lio/vertx/core/Handler<Ljava/lang/Void;>;
Signature: (Lio/vertx/core/Handler<Ljava/lang/Void;>;)Lio/vertx/core/net/impl/NetSocketImpl;
MethodParameters:
Name Flags
handler
public io.vertx.core.net.NetSocket upgradeToSsl(io.vertx.core.Handler<java.lang.Void>);
descriptor: (Lio/vertx/core/Handler;)Lio/vertx/core/net/NetSocket;
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=2, args_size=2
start local 0 start local 1 0: aload 0
aconst_null
aload 1
invokevirtual io.vertx.core.net.impl.NetSocketImpl.upgradeToSsl:(Ljava/lang/String;Lio/vertx/core/Handler;)Lio/vertx/core/net/NetSocket;
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/core/net/impl/NetSocketImpl;
0 1 1 handler Lio/vertx/core/Handler<Ljava/lang/Void;>;
Signature: (Lio/vertx/core/Handler<Ljava/lang/Void;>;)Lio/vertx/core/net/NetSocket;
MethodParameters:
Name Flags
handler
public io.vertx.core.net.NetSocket upgradeToSsl(java.lang.String, io.vertx.core.Handler<java.lang.Void>);
descriptor: (Ljava/lang/String;Lio/vertx/core/Handler;)Lio/vertx/core/net/NetSocket;
flags: (0x0001) ACC_PUBLIC
Code:
stack=6, locals=4, args_size=3
start local 0 start local 1 start local 2 0: aload 0
getfield io.vertx.core.net.impl.NetSocketImpl.chctx:Lio/netty/channel/ChannelHandlerContext;
invokeinterface io.netty.channel.ChannelHandlerContext.pipeline:()Lio/netty/channel/ChannelPipeline;
ldc "ssl"
invokeinterface io.netty.channel.ChannelPipeline.get:(Ljava/lang/String;)Lio/netty/channel/ChannelHandler;
checkcast io.netty.channel.ChannelOutboundHandler
astore 3
start local 3 1: aload 3
ifnonnull 13
2: aload 0
getfield io.vertx.core.net.impl.NetSocketImpl.chctx:Lio/netty/channel/ChannelHandlerContext;
invokeinterface io.netty.channel.ChannelHandlerContext.pipeline:()Lio/netty/channel/ChannelPipeline;
ldc "handshaker"
new io.vertx.core.net.impl.SslHandshakeCompletionHandler
dup
aload 0
aload 2
invokedynamic handle(Lio/vertx/core/net/impl/NetSocketImpl;Lio/vertx/core/Handler;)Lio/vertx/core/Handler;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
(Ljava/lang/Object;)V
io/vertx/core/net/impl/NetSocketImpl.lambda$8(Lio/vertx/core/Handler;Lio/vertx/core/AsyncResult;)V (7)
(Lio/vertx/core/AsyncResult;)V
invokespecial io.vertx.core.net.impl.SslHandshakeCompletionHandler.<init>:(Lio/vertx/core/Handler;)V
invokeinterface io.netty.channel.ChannelPipeline.addFirst:(Ljava/lang/String;Lio/netty/channel/ChannelHandler;)Lio/netty/channel/ChannelPipeline;
pop
3: aload 0
getfield io.vertx.core.net.impl.NetSocketImpl.remoteAddress:Lio/vertx/core/net/SocketAddress;
ifnull 7
4: new io.netty.handler.ssl.SslHandler
dup
aload 0
getfield io.vertx.core.net.impl.NetSocketImpl.helper:Lio/vertx/core/net/impl/SSLHelper;
aload 0
getfield io.vertx.core.net.impl.NetSocketImpl.vertx:Lio/vertx/core/impl/VertxInternal;
aload 0
getfield io.vertx.core.net.impl.NetSocketImpl.remoteAddress:Lio/vertx/core/net/SocketAddress;
aload 1
invokevirtual io.vertx.core.net.impl.SSLHelper.createEngine:(Lio/vertx/core/impl/VertxInternal;Lio/vertx/core/net/SocketAddress;Ljava/lang/String;)Ljavax/net/ssl/SSLEngine;
invokespecial io.netty.handler.ssl.SslHandler.<init>:(Ljavax/net/ssl/SSLEngine;)V
astore 3
5: aload 3
checkcast io.netty.handler.ssl.SslHandler
aload 0
getfield io.vertx.core.net.impl.NetSocketImpl.helper:Lio/vertx/core/net/impl/SSLHelper;
invokevirtual io.vertx.core.net.impl.SSLHelper.getSslHandshakeTimeout:()J
aload 0
getfield io.vertx.core.net.impl.NetSocketImpl.helper:Lio/vertx/core/net/impl/SSLHelper;
invokevirtual io.vertx.core.net.impl.SSLHelper.getSslHandshakeTimeoutUnit:()Ljava/util/concurrent/TimeUnit;
invokevirtual io.netty.handler.ssl.SslHandler.setHandshakeTimeout:(JLjava/util/concurrent/TimeUnit;)V
6: goto 12
7: StackMap locals: io.netty.channel.ChannelOutboundHandler
StackMap stack:
aload 0
getfield io.vertx.core.net.impl.NetSocketImpl.helper:Lio/vertx/core/net/impl/SSLHelper;
invokevirtual io.vertx.core.net.impl.SSLHelper.isSNI:()Z
ifeq 10
8: new io.netty.handler.ssl.SniHandler
dup
aload 0
getfield io.vertx.core.net.impl.NetSocketImpl.helper:Lio/vertx/core/net/impl/SSLHelper;
aload 0
getfield io.vertx.core.net.impl.NetSocketImpl.vertx:Lio/vertx/core/impl/VertxInternal;
invokevirtual io.vertx.core.net.impl.SSLHelper.serverNameMapper:(Lio/vertx/core/impl/VertxInternal;)Lio/netty/util/Mapping;
invokespecial io.netty.handler.ssl.SniHandler.<init>:(Lio/netty/util/Mapping;)V
astore 3
9: goto 12
10: StackMap locals:
StackMap stack:
new io.netty.handler.ssl.SslHandler
dup
aload 0
getfield io.vertx.core.net.impl.NetSocketImpl.helper:Lio/vertx/core/net/impl/SSLHelper;
aload 0
getfield io.vertx.core.net.impl.NetSocketImpl.vertx:Lio/vertx/core/impl/VertxInternal;
invokevirtual io.vertx.core.net.impl.SSLHelper.createEngine:(Lio/vertx/core/impl/VertxInternal;)Ljavax/net/ssl/SSLEngine;
invokespecial io.netty.handler.ssl.SslHandler.<init>:(Ljavax/net/ssl/SSLEngine;)V
astore 3
11: aload 3
checkcast io.netty.handler.ssl.SslHandler
aload 0
getfield io.vertx.core.net.impl.NetSocketImpl.helper:Lio/vertx/core/net/impl/SSLHelper;
invokevirtual io.vertx.core.net.impl.SSLHelper.getSslHandshakeTimeout:()J
aload 0
getfield io.vertx.core.net.impl.NetSocketImpl.helper:Lio/vertx/core/net/impl/SSLHelper;
invokevirtual io.vertx.core.net.impl.SSLHelper.getSslHandshakeTimeoutUnit:()Ljava/util/concurrent/TimeUnit;
invokevirtual io.netty.handler.ssl.SslHandler.setHandshakeTimeout:(JLjava/util/concurrent/TimeUnit;)V
12: StackMap locals:
StackMap stack:
aload 0
getfield io.vertx.core.net.impl.NetSocketImpl.chctx:Lio/netty/channel/ChannelHandlerContext;
invokeinterface io.netty.channel.ChannelHandlerContext.pipeline:()Lio/netty/channel/ChannelPipeline;
ldc "ssl"
aload 3
invokeinterface io.netty.channel.ChannelPipeline.addFirst:(Ljava/lang/String;Lio/netty/channel/ChannelHandler;)Lio/netty/channel/ChannelPipeline;
pop
13: StackMap locals:
StackMap stack:
aload 0
areturn
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 14 0 this Lio/vertx/core/net/impl/NetSocketImpl;
0 14 1 serverName Ljava/lang/String;
0 14 2 handler Lio/vertx/core/Handler<Ljava/lang/Void;>;
1 14 3 sslHandler Lio/netty/channel/ChannelOutboundHandler;
Signature: (Ljava/lang/String;Lio/vertx/core/Handler<Ljava/lang/Void;>;)Lio/vertx/core/net/NetSocket;
MethodParameters:
Name Flags
serverName
handler
protected synchronized void handleInterestedOpsChanged();
descriptor: ()V
flags: (0x0024) ACC_PROTECTED, ACC_SYNCHRONIZED
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
invokevirtual io.vertx.core.net.impl.NetSocketImpl.checkContext:()V
1: aload 0
invokevirtual io.vertx.core.net.impl.NetSocketImpl.callDrainHandler:()V
2: return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 this Lio/vertx/core/net/impl/NetSocketImpl;
public void end(io.vertx.core.Handler<io.vertx.core.AsyncResult<java.lang.Void>>);
descriptor: (Lio/vertx/core/Handler;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 0
aload 1
invokevirtual io.vertx.core.net.impl.NetSocketImpl.close:(Lio/vertx/core/Handler;)V
1: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lio/vertx/core/net/impl/NetSocketImpl;
0 2 1 handler Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/Void;>;>;
Signature: (Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/Void;>;>;)V
MethodParameters:
Name Flags
handler
public void end();
descriptor: ()V
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
invokevirtual io.vertx.core.net.impl.NetSocketImpl.close:()V
1: return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lio/vertx/core/net/impl/NetSocketImpl;
protected void handleClosed();
descriptor: ()V
flags: (0x0004) ACC_PROTECTED
Code:
stack=2, locals=3, args_size=1
start local 0 0: aload 0
dup
astore 2
monitorenter
1: aload 0
getfield io.vertx.core.net.impl.NetSocketImpl.closed:Z
ifeq 4
2: aload 2
monitorexit
3: return
4: StackMap locals: io.vertx.core.net.impl.NetSocketImpl top io.vertx.core.net.impl.NetSocketImpl
StackMap stack:
aload 0
iconst_1
putfield io.vertx.core.net.impl.NetSocketImpl.closed:Z
5: aload 0
getfield io.vertx.core.net.impl.NetSocketImpl.registration:Lio/vertx/core/eventbus/MessageConsumer;
astore 1
start local 1 6: aload 0
aconst_null
putfield io.vertx.core.net.impl.NetSocketImpl.registration:Lio/vertx/core/eventbus/MessageConsumer;
7: aload 2
monitorexit
8: goto 11
end local 1 StackMap locals:
StackMap stack: java.lang.Throwable
9: aload 2
monitorexit
10: athrow
start local 1 11: StackMap locals: io.vertx.core.net.impl.NetSocketImpl io.vertx.core.eventbus.MessageConsumer
StackMap stack:
aload 0
getfield io.vertx.core.net.impl.NetSocketImpl.pending:Lio/vertx/core/streams/impl/InboundBuffer;
getstatic io.vertx.core.streams.impl.InboundBuffer.END_SENTINEL:Ljava/lang/Object;
invokevirtual io.vertx.core.streams.impl.InboundBuffer.write:(Ljava/lang/Object;)Z
pop
12: aload 0
invokespecial io.vertx.core.net.impl.ConnectionBase.handleClosed:()V
13: aload 1
ifnull 15
14: aload 1
invokeinterface io.vertx.core.eventbus.MessageConsumer.unregister:()V
15: StackMap locals:
StackMap stack:
return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 16 0 this Lio/vertx/core/net/impl/NetSocketImpl;
6 9 1 consumer Lio/vertx/core/eventbus/MessageConsumer;
11 16 1 consumer Lio/vertx/core/eventbus/MessageConsumer;
Exception table:
from to target type
1 3 9 any
4 8 9 any
9 10 9 any
public void handleMessage(java.lang.Object);
descriptor: (Ljava/lang/Object;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 0
getfield io.vertx.core.net.impl.NetSocketImpl.pending:Lio/vertx/core/streams/impl/InboundBuffer;
aload 1
invokevirtual io.vertx.core.streams.impl.InboundBuffer.write:(Ljava/lang/Object;)Z
ifne 2
1: aload 0
invokevirtual io.vertx.core.net.impl.NetSocketImpl.doPause:()V
2: StackMap locals:
StackMap stack:
return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 this Lio/vertx/core/net/impl/NetSocketImpl;
0 3 1 msg Ljava/lang/Object;
MethodParameters:
Name Flags
msg
private synchronized void callDrainHandler();
descriptor: ()V
flags: (0x0022) ACC_PRIVATE, ACC_SYNCHRONIZED
Code:
stack=2, locals=1, args_size=1
start local 0 0: aload 0
getfield io.vertx.core.net.impl.NetSocketImpl.drainHandler:Lio/vertx/core/Handler;
ifnull 3
1: aload 0
invokevirtual io.vertx.core.net.impl.NetSocketImpl.writeQueueFull:()Z
ifne 3
2: aload 0
getfield io.vertx.core.net.impl.NetSocketImpl.drainHandler:Lio/vertx/core/Handler;
aconst_null
invokeinterface io.vertx.core.Handler.handle:(Ljava/lang/Object;)V
3: StackMap locals:
StackMap stack:
return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 this Lio/vertx/core/net/impl/NetSocketImpl;
public io.vertx.core.streams.WriteStream write(java.lang.Object, io.vertx.core.Handler);
descriptor: (Ljava/lang/Object;Lio/vertx/core/Handler;)Lio/vertx/core/streams/WriteStream;
flags: (0x1041) ACC_PUBLIC, ACC_BRIDGE, ACC_SYNTHETIC
Code:
stack=3, locals=3, args_size=3
0: aload 0
aload 1
checkcast io.vertx.core.buffer.Buffer
aload 2
invokevirtual io.vertx.core.net.impl.NetSocketImpl.write:(Lio/vertx/core/buffer/Buffer;Lio/vertx/core/Handler;)Lio/vertx/core/net/NetSocket;
areturn
LocalVariableTable:
Start End Slot Name Signature
public io.vertx.core.streams.WriteStream write(java.lang.Object);
descriptor: (Ljava/lang/Object;)Lio/vertx/core/streams/WriteStream;
flags: (0x1041) ACC_PUBLIC, ACC_BRIDGE, ACC_SYNTHETIC
Code:
stack=2, locals=2, args_size=2
0: aload 0
aload 1
checkcast io.vertx.core.buffer.Buffer
invokevirtual io.vertx.core.net.impl.NetSocketImpl.write:(Lio/vertx/core/buffer/Buffer;)Lio/vertx/core/net/NetSocket;
areturn
LocalVariableTable:
Start End Slot Name Signature
public io.vertx.core.streams.WriteStream setWriteQueueMaxSize(int);
descriptor: (I)Lio/vertx/core/streams/WriteStream;
flags: (0x1041) ACC_PUBLIC, ACC_BRIDGE, ACC_SYNTHETIC
Code:
stack=2, locals=2, args_size=2
0: aload 0
iload 1
invokevirtual io.vertx.core.net.impl.NetSocketImpl.setWriteQueueMaxSize:(I)Lio/vertx/core/net/NetSocket;
areturn
LocalVariableTable:
Start End Slot Name Signature
public io.vertx.core.streams.StreamBase exceptionHandler(io.vertx.core.Handler);
descriptor: (Lio/vertx/core/Handler;)Lio/vertx/core/streams/StreamBase;
flags: (0x1041) ACC_PUBLIC, ACC_BRIDGE, ACC_SYNTHETIC
Code:
stack=2, locals=2, args_size=2
0: aload 0
aload 1
invokevirtual io.vertx.core.net.impl.NetSocketImpl.exceptionHandler:(Lio/vertx/core/Handler;)Lio/vertx/core/net/impl/NetSocketImpl;
areturn
LocalVariableTable:
Start End Slot Name Signature
public io.vertx.core.streams.ReadStream exceptionHandler(io.vertx.core.Handler);
descriptor: (Lio/vertx/core/Handler;)Lio/vertx/core/streams/ReadStream;
flags: (0x1041) ACC_PUBLIC, ACC_BRIDGE, ACC_SYNTHETIC
Code:
stack=2, locals=2, args_size=2
0: aload 0
aload 1
invokevirtual io.vertx.core.net.impl.NetSocketImpl.exceptionHandler:(Lio/vertx/core/Handler;)Lio/vertx/core/net/impl/NetSocketImpl;
areturn
LocalVariableTable:
Start End Slot Name Signature
public io.vertx.core.streams.WriteStream exceptionHandler(io.vertx.core.Handler);
descriptor: (Lio/vertx/core/Handler;)Lio/vertx/core/streams/WriteStream;
flags: (0x1041) ACC_PUBLIC, ACC_BRIDGE, ACC_SYNTHETIC
Code:
stack=2, locals=2, args_size=2
0: aload 0
aload 1
invokevirtual io.vertx.core.net.impl.NetSocketImpl.exceptionHandler:(Lio/vertx/core/Handler;)Lio/vertx/core/net/impl/NetSocketImpl;
areturn
LocalVariableTable:
Start End Slot Name Signature
public io.vertx.core.net.NetSocket exceptionHandler(io.vertx.core.Handler);
descriptor: (Lio/vertx/core/Handler;)Lio/vertx/core/net/NetSocket;
flags: (0x1041) ACC_PUBLIC, ACC_BRIDGE, ACC_SYNTHETIC
Code:
stack=2, locals=2, args_size=2
0: aload 0
aload 1
invokevirtual io.vertx.core.net.impl.NetSocketImpl.exceptionHandler:(Lio/vertx/core/Handler;)Lio/vertx/core/net/impl/NetSocketImpl;
areturn
LocalVariableTable:
Start End Slot Name Signature
public io.vertx.core.net.impl.ConnectionBase exceptionHandler(io.vertx.core.Handler);
descriptor: (Lio/vertx/core/Handler;)Lio/vertx/core/net/impl/ConnectionBase;
flags: (0x1041) ACC_PUBLIC, ACC_BRIDGE, ACC_SYNTHETIC
Code:
stack=2, locals=2, args_size=2
0: aload 0
aload 1
invokevirtual io.vertx.core.net.impl.NetSocketImpl.exceptionHandler:(Lio/vertx/core/Handler;)Lio/vertx/core/net/impl/NetSocketImpl;
areturn
LocalVariableTable:
Start End Slot Name Signature
public io.vertx.core.net.NetSocket closeHandler(io.vertx.core.Handler);
descriptor: (Lio/vertx/core/Handler;)Lio/vertx/core/net/NetSocket;
flags: (0x1041) ACC_PUBLIC, ACC_BRIDGE, ACC_SYNTHETIC
Code:
stack=2, locals=2, args_size=2
0: aload 0
aload 1
invokevirtual io.vertx.core.net.impl.NetSocketImpl.closeHandler:(Lio/vertx/core/Handler;)Lio/vertx/core/net/impl/NetSocketImpl;
areturn
LocalVariableTable:
Start End Slot Name Signature
public io.vertx.core.net.impl.ConnectionBase closeHandler(io.vertx.core.Handler);
descriptor: (Lio/vertx/core/Handler;)Lio/vertx/core/net/impl/ConnectionBase;
flags: (0x1041) ACC_PUBLIC, ACC_BRIDGE, ACC_SYNTHETIC
Code:
stack=2, locals=2, args_size=2
0: aload 0
aload 1
invokevirtual io.vertx.core.net.impl.NetSocketImpl.closeHandler:(Lio/vertx/core/Handler;)Lio/vertx/core/net/impl/NetSocketImpl;
areturn
LocalVariableTable:
Start End Slot Name Signature
public io.vertx.core.streams.ReadStream resume();
descriptor: ()Lio/vertx/core/streams/ReadStream;
flags: (0x1041) ACC_PUBLIC, ACC_BRIDGE, ACC_SYNTHETIC
Code:
stack=1, locals=1, args_size=1
0: aload 0
invokevirtual io.vertx.core.net.impl.NetSocketImpl.resume:()Lio/vertx/core/net/NetSocket;
areturn
LocalVariableTable:
Start End Slot Name Signature
public io.vertx.core.spi.metrics.NetworkMetrics metrics();
descriptor: ()Lio/vertx/core/spi/metrics/NetworkMetrics;
flags: (0x1041) ACC_PUBLIC, ACC_BRIDGE, ACC_SYNTHETIC
Code:
stack=1, locals=1, args_size=1
0: aload 0
invokevirtual io.vertx.core.net.impl.NetSocketImpl.metrics:()Lio/vertx/core/spi/metrics/TCPMetrics;
areturn
LocalVariableTable:
Start End Slot Name Signature
public io.vertx.core.streams.ReadStream handler(io.vertx.core.Handler);
descriptor: (Lio/vertx/core/Handler;)Lio/vertx/core/streams/ReadStream;
flags: (0x1041) ACC_PUBLIC, ACC_BRIDGE, ACC_SYNTHETIC
Code:
stack=2, locals=2, args_size=2
0: aload 0
aload 1
checkcast io.vertx.core.Handler
invokevirtual io.vertx.core.net.impl.NetSocketImpl.handler:(Lio/vertx/core/Handler;)Lio/vertx/core/net/NetSocket;
areturn
LocalVariableTable:
Start End Slot Name Signature
public io.vertx.core.streams.ReadStream pause();
descriptor: ()Lio/vertx/core/streams/ReadStream;
flags: (0x1041) ACC_PUBLIC, ACC_BRIDGE, ACC_SYNTHETIC
Code:
stack=1, locals=1, args_size=1
0: aload 0
invokevirtual io.vertx.core.net.impl.NetSocketImpl.pause:()Lio/vertx/core/net/NetSocket;
areturn
LocalVariableTable:
Start End Slot Name Signature
public io.vertx.core.streams.ReadStream endHandler(io.vertx.core.Handler);
descriptor: (Lio/vertx/core/Handler;)Lio/vertx/core/streams/ReadStream;
flags: (0x1041) ACC_PUBLIC, ACC_BRIDGE, ACC_SYNTHETIC
Code:
stack=2, locals=2, args_size=2
0: aload 0
aload 1
invokevirtual io.vertx.core.net.impl.NetSocketImpl.endHandler:(Lio/vertx/core/Handler;)Lio/vertx/core/net/NetSocket;
areturn
LocalVariableTable:
Start End Slot Name Signature
public io.vertx.core.streams.WriteStream drainHandler(io.vertx.core.Handler);
descriptor: (Lio/vertx/core/Handler;)Lio/vertx/core/streams/WriteStream;
flags: (0x1041) ACC_PUBLIC, ACC_BRIDGE, ACC_SYNTHETIC
Code:
stack=2, locals=2, args_size=2
0: aload 0
aload 1
invokevirtual io.vertx.core.net.impl.NetSocketImpl.drainHandler:(Lio/vertx/core/Handler;)Lio/vertx/core/net/NetSocket;
areturn
LocalVariableTable:
Start End Slot Name Signature
public io.vertx.core.streams.ReadStream fetch(long);
descriptor: (J)Lio/vertx/core/streams/ReadStream;
flags: (0x1041) ACC_PUBLIC, ACC_BRIDGE, ACC_SYNTHETIC
Code:
stack=3, locals=3, args_size=2
0: aload 0
lload 1
invokevirtual io.vertx.core.net.impl.NetSocketImpl.fetch:(J)Lio/vertx/core/net/NetSocket;
areturn
LocalVariableTable:
Start End Slot Name Signature
private static void lambda$0(java.lang.Object);
descriptor: (Ljava/lang/Object;)V
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=1, locals=2, args_size=1
start local 0 0: aload 0
instanceof io.netty.buffer.ByteBuf
ifeq 3
1: aload 0
checkcast io.netty.buffer.ByteBuf
astore 1
start local 1 2: aload 1
invokevirtual io.netty.buffer.ByteBuf.release:()Z
pop
end local 1 3: StackMap locals:
StackMap stack:
return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 event Ljava/lang/Object;
2 3 1 byteBuf Lio/netty/buffer/ByteBuf;
private void lambda$1(java.lang.Void);
descriptor: (Ljava/lang/Void;)V
flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
Code:
stack=1, locals=2, args_size=2
start local 0 start local 1 0: aload 0
invokevirtual io.vertx.core.net.impl.NetSocketImpl.doResume:()V
return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/core/net/impl/NetSocketImpl;
0 1 1 v Ljava/lang/Void;
private void lambda$2(java.lang.Object);
descriptor: (Ljava/lang/Object;)V
flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
Code:
stack=2, locals=3, args_size=2
start local 0 start local 1 0: aload 1
getstatic io.vertx.core.streams.impl.InboundBuffer.END_SENTINEL:Ljava/lang/Object;
if_acmpne 5
1: aload 0
invokevirtual io.vertx.core.net.impl.NetSocketImpl.endHandler:()Lio/vertx/core/Handler;
astore 2
start local 2 2: aload 2
ifnull 8
3: aload 2
aconst_null
invokeinterface io.vertx.core.Handler.handle:(Ljava/lang/Object;)V
end local 2 4: goto 8
5: StackMap locals:
StackMap stack:
aload 0
invokevirtual io.vertx.core.net.impl.NetSocketImpl.messageHandler:()Lio/vertx/core/Handler;
astore 2
start local 2 6: aload 2
ifnull 8
7: aload 2
aload 1
invokeinterface io.vertx.core.Handler.handle:(Ljava/lang/Object;)V
end local 2 8: StackMap locals:
StackMap stack:
return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 9 0 this Lio/vertx/core/net/impl/NetSocketImpl;
0 9 1 obj Ljava/lang/Object;
2 4 2 handler Lio/vertx/core/Handler<Ljava/lang/Void;>;
6 8 2 handler Lio/vertx/core/Handler<Ljava/lang/Object;>;
private void lambda$3(io.vertx.core.eventbus.Message);
descriptor: (Lio/vertx/core/eventbus/Message;)V
flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 0
aload 1
invokeinterface io.vertx.core.eventbus.Message.body:()Ljava/lang/Object;
checkcast io.vertx.core.buffer.Buffer
invokevirtual io.vertx.core.net.impl.NetSocketImpl.write:(Lio/vertx/core/buffer/Buffer;)Lio/vertx/core/net/NetSocket;
return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/core/net/impl/NetSocketImpl;
0 1 1 msg Lio/vertx/core/eventbus/Message<Lio/vertx/core/buffer/Buffer;>;
private void lambda$4(java.lang.Void);
descriptor: (Ljava/lang/Void;)V
flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
Code:
stack=1, locals=2, args_size=2
start local 0 start local 1 0: aload 0
invokevirtual io.vertx.core.net.impl.NetSocketImpl.callDrainHandler:()V
return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/core/net/impl/NetSocketImpl;
0 1 1 v Ljava/lang/Void;
private void lambda$5(io.netty.channel.ChannelFuture, io.vertx.core.Handler, io.netty.util.concurrent.Future);
descriptor: (Lio/netty/channel/ChannelFuture;Lio/vertx/core/Handler;Lio/netty/util/concurrent/Future;)V
flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
Code:
stack=3, locals=5, args_size=4
start local 0 start local 3 0: aload 1
invokeinterface io.netty.channel.ChannelFuture.isSuccess:()Z
ifeq 3
1: invokestatic io.vertx.core.Future.succeededFuture:()Lio/vertx/core/Future;
astore 4
start local 4 2: goto 4
end local 4 3: StackMap locals:
StackMap stack:
aload 1
invokeinterface io.netty.channel.ChannelFuture.cause:()Ljava/lang/Throwable;
invokestatic io.vertx.core.Future.failedFuture:(Ljava/lang/Throwable;)Lio/vertx/core/Future;
astore 4
start local 4 4: StackMap locals: io.vertx.core.AsyncResult
StackMap stack:
aload 0
getfield io.vertx.core.net.impl.NetSocketImpl.vertx:Lio/vertx/core/impl/VertxInternal;
aload 2
aload 4
invokedynamic handle(Lio/vertx/core/Handler;Lio/vertx/core/AsyncResult;)Lio/vertx/core/Handler;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
(Ljava/lang/Object;)V
io/vertx/core/net/impl/NetSocketImpl.lambda$6(Lio/vertx/core/Handler;Lio/vertx/core/AsyncResult;Ljava/lang/Void;)V (6)
(Ljava/lang/Void;)V
invokeinterface io.vertx.core.impl.VertxInternal.runOnContext:(Lio/vertx/core/Handler;)V
end local 4 5: return
end local 3 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 6 0 this Lio/vertx/core/net/impl/NetSocketImpl;
0 6 3 fut Lio/netty/util/concurrent/Future<-Ljava/lang/Void;>;
2 3 4 res Lio/vertx/core/AsyncResult<Ljava/lang/Void;>;
4 5 4 res Lio/vertx/core/AsyncResult<Ljava/lang/Void;>;
Exceptions:
throws java.lang.Exception
private static void lambda$7(io.vertx.core.Handler, java.io.IOException, java.lang.Void);
descriptor: (Lio/vertx/core/Handler;Ljava/io/IOException;Ljava/lang/Void;)V
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=2, locals=3, args_size=3
start local 2 0: aload 0
aload 1
invokestatic io.vertx.core.Future.failedFuture:(Ljava/lang/Throwable;)Lio/vertx/core/Future;
invokeinterface io.vertx.core.Handler.handle:(Ljava/lang/Object;)V
return
end local 2 LocalVariableTable:
Start End Slot Name Signature
0 1 2 v Ljava/lang/Void;
private void lambda$8(io.vertx.core.Handler, io.vertx.core.AsyncResult);
descriptor: (Lio/vertx/core/Handler;Lio/vertx/core/AsyncResult;)V
flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
Code:
stack=2, locals=3, args_size=3
start local 0 start local 2 0: aload 2
invokeinterface io.vertx.core.AsyncResult.succeeded:()Z
ifeq 3
1: aload 1
aconst_null
invokeinterface io.vertx.core.Handler.handle:(Ljava/lang/Object;)V
2: goto 5
3: StackMap locals:
StackMap stack:
aload 0
getfield io.vertx.core.net.impl.NetSocketImpl.chctx:Lio/netty/channel/ChannelHandlerContext;
invokeinterface io.netty.channel.ChannelHandlerContext.channel:()Lio/netty/channel/Channel;
invokeinterface io.netty.channel.Channel.closeFuture:()Lio/netty/channel/ChannelFuture;
pop
4: aload 0
aload 2
invokeinterface io.vertx.core.AsyncResult.cause:()Ljava/lang/Throwable;
invokevirtual io.vertx.core.net.impl.NetSocketImpl.handleException:(Ljava/lang/Throwable;)V
5: StackMap locals:
StackMap stack:
return
end local 2 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 6 0 this Lio/vertx/core/net/impl/NetSocketImpl;
0 6 2 ar Lio/vertx/core/AsyncResult<Lio/netty/channel/Channel;>;
private static void lambda$6(io.vertx.core.Handler, io.vertx.core.AsyncResult, java.lang.Void);
descriptor: (Lio/vertx/core/Handler;Lio/vertx/core/AsyncResult;Ljava/lang/Void;)V
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=2, locals=3, args_size=3
start local 2 0: aload 0
aload 1
invokeinterface io.vertx.core.Handler.handle:(Ljava/lang/Object;)V
return
end local 2 LocalVariableTable:
Start End Slot Name Signature
0 1 2 v Ljava/lang/Void;
}
SourceFile: "NetSocketImpl.java"
NestMembers:
io.vertx.core.net.impl.NetSocketImpl$DataMessageHandler
InnerClasses:
private DataMessageHandler = io.vertx.core.net.impl.NetSocketImpl$DataMessageHandler of io.vertx.core.net.impl.NetSocketImpl
public final Lookup = java.lang.invoke.MethodHandles$Lookup of java.lang.invoke.MethodHandles