public final class io.vertx.core.net.impl.VertxHandler<C extends io.vertx.core.net.impl.ConnectionBase> extends io.netty.channel.ChannelDuplexHandler
minor version: 0
major version: 59
flags: flags: (0x0031) ACC_PUBLIC, ACC_FINAL, ACC_SUPER
this_class: io.vertx.core.net.impl.VertxHandler
super_class: io.netty.channel.ChannelDuplexHandler
{
private final java.util.function.Function<io.netty.channel.ChannelHandlerContext, C> connectionFactory;
descriptor: Ljava/util/function/Function;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
Signature: Ljava/util/function/Function<Lio/netty/channel/ChannelHandlerContext;TC;>;
private C conn;
descriptor: Lio/vertx/core/net/impl/ConnectionBase;
flags: (0x0002) ACC_PRIVATE
Signature: TC;
private io.vertx.core.Handler<C> addHandler;
descriptor: Lio/vertx/core/Handler;
flags: (0x0002) ACC_PRIVATE
Signature: Lio/vertx/core/Handler<TC;>;
private io.vertx.core.Handler<C> removeHandler;
descriptor: Lio/vertx/core/Handler;
flags: (0x0002) ACC_PRIVATE
Signature: Lio/vertx/core/Handler<TC;>;
public static <C extends io.vertx.core.net.impl.ConnectionBase> io.vertx.core.net.impl.VertxHandler<C> create(java.util.function.Function<io.netty.channel.ChannelHandlerContext, C>);
descriptor: (Ljava/util/function/Function;)Lio/vertx/core/net/impl/VertxHandler;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=3, locals=1, args_size=1
start local 0 0: new io.vertx.core.net.impl.VertxHandler
dup
aload 0
invokespecial io.vertx.core.net.impl.VertxHandler.<init>:(Ljava/util/function/Function;)V
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 connectionFactory Ljava/util/function/Function<Lio/netty/channel/ChannelHandlerContext;TC;>;
Signature: <C:Lio/vertx/core/net/impl/ConnectionBase;>(Ljava/util/function/Function<Lio/netty/channel/ChannelHandlerContext;TC;>;)Lio/vertx/core/net/impl/VertxHandler<TC;>;
MethodParameters:
Name Flags
connectionFactory
private void <init>(java.util.function.Function<io.netty.channel.ChannelHandlerContext, C>);
descriptor: (Ljava/util/function/Function;)V
flags: (0x0002) ACC_PRIVATE
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 0
invokespecial io.netty.channel.ChannelDuplexHandler.<init>:()V
1: aload 0
aload 1
putfield io.vertx.core.net.impl.VertxHandler.connectionFactory:Ljava/util/function/Function;
2: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 this Lio/vertx/core/net/impl/VertxHandler<TC;>;
0 3 1 connectionFactory Ljava/util/function/Function<Lio/netty/channel/ChannelHandlerContext;TC;>;
Signature: (Ljava/util/function/Function<Lio/netty/channel/ChannelHandlerContext;TC;>;)V
MethodParameters:
Name Flags
connectionFactory
public static io.netty.buffer.ByteBuf safeBuffer(io.netty.buffer.ByteBufHolder, io.netty.buffer.ByteBufAllocator);
descriptor: (Lio/netty/buffer/ByteBufHolder;Lio/netty/buffer/ByteBufAllocator;)Lio/netty/buffer/ByteBuf;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 0
invokeinterface io.netty.buffer.ByteBufHolder.content:()Lio/netty/buffer/ByteBuf;
aload 1
invokestatic io.vertx.core.net.impl.VertxHandler.safeBuffer:(Lio/netty/buffer/ByteBuf;Lio/netty/buffer/ByteBufAllocator;)Lio/netty/buffer/ByteBuf;
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 holder Lio/netty/buffer/ByteBufHolder;
0 1 1 allocator Lio/netty/buffer/ByteBufAllocator;
MethodParameters:
Name Flags
holder
allocator
public static io.netty.buffer.ByteBuf safeBuffer(io.netty.buffer.ByteBuf, io.netty.buffer.ByteBufAllocator);
descriptor: (Lio/netty/buffer/ByteBuf;Lio/netty/buffer/ByteBufAllocator;)Lio/netty/buffer/ByteBuf;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=2, locals=5, args_size=2
start local 0 start local 1 0: aload 0
getstatic io.netty.buffer.Unpooled.EMPTY_BUFFER:Lio/netty/buffer/ByteBuf;
if_acmpne 2
1: aload 0
areturn
2: StackMap locals:
StackMap stack:
aload 0
invokevirtual io.netty.buffer.ByteBuf.isDirect:()Z
ifne 3
aload 0
instanceof io.netty.buffer.CompositeByteBuf
ifeq 15
3: StackMap locals:
StackMap stack:
aload 0
invokevirtual io.netty.buffer.ByteBuf.isReadable:()Z
ifeq 9
4: aload 1
aload 0
invokevirtual io.netty.buffer.ByteBuf.readableBytes:()I
invokeinterface io.netty.buffer.ByteBufAllocator.heapBuffer:(I)Lio/netty/buffer/ByteBuf;
astore 2
start local 2 5: aload 2
aload 0
invokevirtual io.netty.buffer.ByteBuf.writeBytes:(Lio/netty/buffer/ByteBuf;)Lio/netty/buffer/ByteBuf;
pop
6: aload 2
astore 4
7: aload 0
invokevirtual io.netty.buffer.ByteBuf.release:()Z
pop
8: aload 4
areturn
end local 2 9: StackMap locals:
StackMap stack:
getstatic io.netty.buffer.Unpooled.EMPTY_BUFFER:Lio/netty/buffer/ByteBuf;
astore 4
10: aload 0
invokevirtual io.netty.buffer.ByteBuf.release:()Z
pop
11: aload 4
areturn
12: StackMap locals:
StackMap stack: java.lang.Throwable
astore 3
13: aload 0
invokevirtual io.netty.buffer.ByteBuf.release:()Z
pop
14: aload 3
athrow
15: StackMap locals:
StackMap stack:
aload 0
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 16 0 buf Lio/netty/buffer/ByteBuf;
0 16 1 allocator Lio/netty/buffer/ByteBufAllocator;
5 9 2 buffer Lio/netty/buffer/ByteBuf;
Exception table:
from to target type
3 7 12 any
9 10 12 any
MethodParameters:
Name Flags
buf
allocator
private void setConnection();
descriptor: (Lio/vertx/core/net/impl/ConnectionBase;)V
flags: (0x0002) ACC_PRIVATE
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.VertxHandler.conn:Lio/vertx/core/net/impl/ConnectionBase;
1: aload 0
getfield io.vertx.core.net.impl.VertxHandler.addHandler:Lio/vertx/core/Handler;
ifnull 3
2: aload 0
getfield io.vertx.core.net.impl.VertxHandler.addHandler:Lio/vertx/core/Handler;
aload 1
invokeinterface io.vertx.core.Handler.handle:(Ljava/lang/Object;)V
3: StackMap locals:
StackMap stack:
return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 this Lio/vertx/core/net/impl/VertxHandler<TC;>;
0 4 1 connection TC;
Signature: (TC;)V
MethodParameters:
Name Flags
connection
public void handlerAdded(io.netty.channel.ChannelHandlerContext);
descriptor: (Lio/netty/channel/ChannelHandlerContext;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=2, args_size=2
start local 0 start local 1 0: aload 0
aload 0
getfield io.vertx.core.net.impl.VertxHandler.connectionFactory:Ljava/util/function/Function;
aload 1
invokeinterface java.util.function.Function.apply:(Ljava/lang/Object;)Ljava/lang/Object;
checkcast io.vertx.core.net.impl.ConnectionBase
invokevirtual io.vertx.core.net.impl.VertxHandler.setConnection:(Lio/vertx/core/net/impl/ConnectionBase;)V
1: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lio/vertx/core/net/impl/VertxHandler<TC;>;
0 2 1 ctx Lio/netty/channel/ChannelHandlerContext;
MethodParameters:
Name Flags
ctx
public io.vertx.core.net.impl.VertxHandler<C> addHandler(io.vertx.core.Handler<C>);
descriptor: (Lio/vertx/core/Handler;)Lio/vertx/core/net/impl/VertxHandler;
flags: (0x0001) ACC_PUBLIC
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.VertxHandler.addHandler: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/VertxHandler<TC;>;
0 2 1 handler Lio/vertx/core/Handler<TC;>;
Signature: (Lio/vertx/core/Handler<TC;>;)Lio/vertx/core/net/impl/VertxHandler<TC;>;
MethodParameters:
Name Flags
handler
public io.vertx.core.net.impl.VertxHandler<C> removeHandler(io.vertx.core.Handler<C>);
descriptor: (Lio/vertx/core/Handler;)Lio/vertx/core/net/impl/VertxHandler;
flags: (0x0001) ACC_PUBLIC
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.VertxHandler.removeHandler: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/VertxHandler<TC;>;
0 2 1 handler Lio/vertx/core/Handler<TC;>;
Signature: (Lio/vertx/core/Handler<TC;>;)Lio/vertx/core/net/impl/VertxHandler<TC;>;
MethodParameters:
Name Flags
handler
public C getConnection();
descriptor: ()Lio/vertx/core/net/impl/ConnectionBase;
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield io.vertx.core.net.impl.VertxHandler.conn:Lio/vertx/core/net/impl/ConnectionBase;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/core/net/impl/VertxHandler<TC;>;
Signature: ()TC;
public void channelWritabilityChanged(io.netty.channel.ChannelHandlerContext);
descriptor: (Lio/netty/channel/ChannelHandlerContext;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=3, args_size=2
start local 0 start local 1 0: aload 0
invokevirtual io.vertx.core.net.impl.VertxHandler.getConnection:()Lio/vertx/core/net/impl/ConnectionBase;
astore 2
start local 2 1: aload 2
invokevirtual io.vertx.core.net.impl.ConnectionBase.handleInterestedOpsChanged:()V
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/VertxHandler<TC;>;
0 3 1 ctx Lio/netty/channel/ChannelHandlerContext;
1 3 2 conn TC;
MethodParameters:
Name Flags
ctx
public void exceptionCaught(io.netty.channel.ChannelHandlerContext, java.lang.Throwable);
descriptor: (Lio/netty/channel/ChannelHandlerContext;Ljava/lang/Throwable;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=4, args_size=3
start local 0 start local 1 start local 2 0: aload 0
invokevirtual io.vertx.core.net.impl.VertxHandler.getConnection:()Lio/vertx/core/net/impl/ConnectionBase;
astore 3
start local 3 1: aload 3
ifnull 3
2: aload 3
aload 2
invokevirtual io.vertx.core.net.impl.ConnectionBase.handleException:(Ljava/lang/Throwable;)V
3: StackMap locals: io.vertx.core.net.impl.ConnectionBase
StackMap stack:
aload 1
invokeinterface io.netty.channel.ChannelHandlerContext.close:()Lio/netty/channel/ChannelFuture;
pop
4: return
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/VertxHandler<TC;>;
0 5 1 chctx Lio/netty/channel/ChannelHandlerContext;
0 5 2 t Ljava/lang/Throwable;
1 5 3 connection TC;
MethodParameters:
Name Flags
chctx
t final
public void channelInactive(io.netty.channel.ChannelHandlerContext);
descriptor: (Lio/netty/channel/ChannelHandlerContext;)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.VertxHandler.removeHandler:Lio/vertx/core/Handler;
ifnull 2
1: aload 0
getfield io.vertx.core.net.impl.VertxHandler.removeHandler:Lio/vertx/core/Handler;
aload 0
getfield io.vertx.core.net.impl.VertxHandler.conn:Lio/vertx/core/net/impl/ConnectionBase;
invokeinterface io.vertx.core.Handler.handle:(Ljava/lang/Object;)V
2: StackMap locals:
StackMap stack:
aload 0
getfield io.vertx.core.net.impl.VertxHandler.conn:Lio/vertx/core/net/impl/ConnectionBase;
invokevirtual io.vertx.core.net.impl.ConnectionBase.handleClosed:()V
3: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 this Lio/vertx/core/net/impl/VertxHandler<TC;>;
0 4 1 chctx Lio/netty/channel/ChannelHandlerContext;
MethodParameters:
Name Flags
chctx
public void channelReadComplete(io.netty.channel.ChannelHandlerContext);
descriptor: (Lio/netty/channel/ChannelHandlerContext;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=2, args_size=2
start local 0 start local 1 0: aload 0
getfield io.vertx.core.net.impl.VertxHandler.conn:Lio/vertx/core/net/impl/ConnectionBase;
invokevirtual io.vertx.core.net.impl.ConnectionBase.endReadAndFlush:()V
1: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lio/vertx/core/net/impl/VertxHandler<TC;>;
0 2 1 ctx Lio/netty/channel/ChannelHandlerContext;
MethodParameters:
Name Flags
ctx
public void channelRead(io.netty.channel.ChannelHandlerContext, java.lang.Object);
descriptor: (Lio/netty/channel/ChannelHandlerContext;Ljava/lang/Object;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=3, args_size=3
start local 0 start local 1 start local 2 0: aload 0
getfield io.vertx.core.net.impl.VertxHandler.conn:Lio/vertx/core/net/impl/ConnectionBase;
aload 2
invokevirtual io.vertx.core.net.impl.ConnectionBase.read:(Ljava/lang/Object;)V
1: return
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lio/vertx/core/net/impl/VertxHandler<TC;>;
0 2 1 chctx Lio/netty/channel/ChannelHandlerContext;
0 2 2 msg Ljava/lang/Object;
MethodParameters:
Name Flags
chctx
msg
public void close(io.netty.channel.ChannelHandlerContext, io.netty.channel.ChannelPromise);
descriptor: (Lio/netty/channel/ChannelHandlerContext;Lio/netty/channel/ChannelPromise;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=3, args_size=3
start local 0 start local 1 start local 2 0: aload 0
getfield io.vertx.core.net.impl.VertxHandler.conn:Lio/vertx/core/net/impl/ConnectionBase;
aload 2
invokevirtual io.vertx.core.net.impl.ConnectionBase.close:(Lio/netty/channel/ChannelPromise;)V
1: return
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lio/vertx/core/net/impl/VertxHandler<TC;>;
0 2 1 ctx Lio/netty/channel/ChannelHandlerContext;
0 2 2 promise Lio/netty/channel/ChannelPromise;
Exceptions:
throws java.lang.Exception
MethodParameters:
Name Flags
ctx
promise
public void userEventTriggered(io.netty.channel.ChannelHandlerContext, java.lang.Object);
descriptor: (Lio/netty/channel/ChannelHandlerContext;Ljava/lang/Object;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=3, args_size=3
start local 0 start local 1 start local 2 0: aload 2
instanceof io.netty.handler.timeout.IdleStateEvent
ifeq 3
aload 2
checkcast io.netty.handler.timeout.IdleStateEvent
invokevirtual io.netty.handler.timeout.IdleStateEvent.state:()Lio/netty/handler/timeout/IdleState;
getstatic io.netty.handler.timeout.IdleState.ALL_IDLE:Lio/netty/handler/timeout/IdleState;
if_acmpne 3
1: aload 0
getfield io.vertx.core.net.impl.VertxHandler.conn:Lio/vertx/core/net/impl/ConnectionBase;
invokevirtual io.vertx.core.net.impl.ConnectionBase.handleIdle:()V
2: goto 4
3: StackMap locals:
StackMap stack:
aload 1
aload 2
invokeinterface io.netty.channel.ChannelHandlerContext.fireUserEventTriggered:(Ljava/lang/Object;)Lio/netty/channel/ChannelHandlerContext;
pop
4: StackMap locals:
StackMap stack:
return
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 5 0 this Lio/vertx/core/net/impl/VertxHandler<TC;>;
0 5 1 ctx Lio/netty/channel/ChannelHandlerContext;
0 5 2 evt Ljava/lang/Object;
Exceptions:
throws java.lang.Exception
MethodParameters:
Name Flags
ctx
evt
}
Signature: <C:Lio/vertx/core/net/impl/ConnectionBase;>Lio/netty/channel/ChannelDuplexHandler;
SourceFile: "VertxHandler.java"