public class io.reactiverse.pgclient.impl.codec.decoder.InitiateSslHandler extends io.netty.channel.ChannelInboundHandlerAdapter
minor version: 0
major version: 59
flags: flags: (0x0021) ACC_PUBLIC, ACC_SUPER
this_class: io.reactiverse.pgclient.impl.codec.decoder.InitiateSslHandler
super_class: io.netty.channel.ChannelInboundHandlerAdapter
{
private static final int code;
descriptor: I
flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL
ConstantValue: 80877103
private final io.reactiverse.pgclient.impl.SocketConnection conn;
descriptor: Lio/reactiverse/pgclient/impl/SocketConnection;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
private final io.vertx.core.Future<java.lang.Void> upgradeFuture;
descriptor: Lio/vertx/core/Future;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
Signature: Lio/vertx/core/Future<Ljava/lang/Void;>;
public void <init>(io.reactiverse.pgclient.impl.SocketConnection, io.vertx.core.Future<java.lang.Void>);
descriptor: (Lio/reactiverse/pgclient/impl/SocketConnection;Lio/vertx/core/Future;)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
invokespecial io.netty.channel.ChannelInboundHandlerAdapter.<init>:()V
1: aload 0
aload 1
putfield io.reactiverse.pgclient.impl.codec.decoder.InitiateSslHandler.conn:Lio/reactiverse/pgclient/impl/SocketConnection;
2: aload 0
aload 2
putfield io.reactiverse.pgclient.impl.codec.decoder.InitiateSslHandler.upgradeFuture:Lio/vertx/core/Future;
3: return
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 this Lio/reactiverse/pgclient/impl/codec/decoder/InitiateSslHandler;
0 4 1 conn Lio/reactiverse/pgclient/impl/SocketConnection;
0 4 2 upgradeFuture Lio/vertx/core/Future<Ljava/lang/Void;>;
Signature: (Lio/reactiverse/pgclient/impl/SocketConnection;Lio/vertx/core/Future<Ljava/lang/Void;>;)V
MethodParameters:
Name Flags
conn
upgradeFuture
public void channelActive(io.netty.channel.ChannelHandlerContext);
descriptor: (Lio/netty/channel/ChannelHandlerContext;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=3, args_size=2
start local 0 start local 1 0: invokestatic io.netty.buffer.Unpooled.buffer:()Lio/netty/buffer/ByteBuf;
astore 2
start local 2 1: aload 2
iconst_0
invokevirtual io.netty.buffer.ByteBuf.writeInt:(I)Lio/netty/buffer/ByteBuf;
pop
2: aload 2
ldc 80877103
invokevirtual io.netty.buffer.ByteBuf.writeInt:(I)Lio/netty/buffer/ByteBuf;
pop
3: aload 2
iconst_0
aload 2
invokevirtual io.netty.buffer.ByteBuf.writerIndex:()I
invokevirtual io.netty.buffer.ByteBuf.setInt:(II)Lio/netty/buffer/ByteBuf;
pop
4: aload 1
aload 2
invokeinterface io.netty.channel.ChannelHandlerContext.writeAndFlush:(Ljava/lang/Object;)Lio/netty/channel/ChannelFuture;
pop
5: aload 0
aload 1
invokespecial io.netty.channel.ChannelInboundHandlerAdapter.channelActive:(Lio/netty/channel/ChannelHandlerContext;)V
6: return
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 7 0 this Lio/reactiverse/pgclient/impl/codec/decoder/InitiateSslHandler;
0 7 1 ctx Lio/netty/channel/ChannelHandlerContext;
1 7 2 byteBuf Lio/netty/buffer/ByteBuf;
Exceptions:
throws java.lang.Exception
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=4, locals=5, args_size=3
start local 0 start local 1 start local 2 0: aload 2
checkcast io.netty.buffer.ByteBuf
astore 3
start local 3 1: aload 3
iconst_0
invokevirtual io.netty.buffer.ByteBuf.getByte:(I)B
istore 4
start local 4 2: aload 3
invokevirtual io.netty.buffer.ByteBuf.release:()Z
pop
3: iload 4
lookupswitch { // 2
78: 6
83: 4
default: 8
}
4: StackMap locals: io.netty.buffer.ByteBuf int
StackMap stack:
aload 0
getfield io.reactiverse.pgclient.impl.codec.decoder.InitiateSslHandler.conn:Lio/reactiverse/pgclient/impl/SocketConnection;
invokevirtual io.reactiverse.pgclient.impl.SocketConnection.socket:()Lio/vertx/core/impl/NetSocketInternal;
aload 0
aload 1
invokedynamic handle(Lio/reactiverse/pgclient/impl/codec/decoder/InitiateSslHandler;Lio/netty/channel/ChannelHandlerContext;)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/reactiverse/pgclient/impl/codec/decoder/InitiateSslHandler.lambda$0(Lio/netty/channel/ChannelHandlerContext;Ljava/lang/Void;)V (7)
(Ljava/lang/Void;)V
invokeinterface io.vertx.core.impl.NetSocketInternal.upgradeToSsl:(Lio/vertx/core/Handler;)Lio/vertx/core/net/NetSocket;
pop
5: goto 9
6: StackMap locals:
StackMap stack:
aload 0
getfield io.reactiverse.pgclient.impl.codec.decoder.InitiateSslHandler.upgradeFuture:Lio/vertx/core/Future;
new java.lang.Exception
dup
ldc "Postgres Server does not handle SSL connection"
invokespecial java.lang.Exception.<init>:(Ljava/lang/String;)V
invokeinterface io.vertx.core.Future.fail:(Ljava/lang/Throwable;)V
7: goto 9
8: StackMap locals:
StackMap stack:
aload 0
getfield io.reactiverse.pgclient.impl.codec.decoder.InitiateSslHandler.upgradeFuture:Lio/vertx/core/Future;
new java.lang.Exception
dup
ldc "Invalid SSL connection message"
invokespecial java.lang.Exception.<init>:(Ljava/lang/String;)V
invokeinterface io.vertx.core.Future.fail:(Ljava/lang/Throwable;)V
9: StackMap locals:
StackMap stack:
return
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/reactiverse/pgclient/impl/codec/decoder/InitiateSslHandler;
0 10 1 ctx Lio/netty/channel/ChannelHandlerContext;
0 10 2 msg Ljava/lang/Object;
1 10 3 byteBuf Lio/netty/buffer/ByteBuf;
2 10 4 b B
Exceptions:
throws java.lang.Exception
MethodParameters:
Name Flags
ctx
msg
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 2
instanceof io.netty.handler.codec.DecoderException
ifeq 3
1: aload 2
checkcast io.netty.handler.codec.DecoderException
astore 3
start local 3 2: aload 3
invokevirtual io.netty.handler.codec.DecoderException.getCause:()Ljava/lang/Throwable;
astore 2
end local 3 3: StackMap locals:
StackMap stack:
aload 0
getfield io.reactiverse.pgclient.impl.codec.decoder.InitiateSslHandler.upgradeFuture:Lio/vertx/core/Future;
aload 2
invokeinterface io.vertx.core.Future.tryFail:(Ljava/lang/Throwable;)Z
pop
4: return
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 5 0 this Lio/reactiverse/pgclient/impl/codec/decoder/InitiateSslHandler;
0 5 1 ctx Lio/netty/channel/ChannelHandlerContext;
0 5 2 cause Ljava/lang/Throwable;
2 3 3 err Lio/netty/handler/codec/DecoderException;
Exceptions:
throws java.lang.Exception
MethodParameters:
Name Flags
ctx
cause
public void channelInactive(io.netty.channel.ChannelHandlerContext);
descriptor: (Lio/netty/channel/ChannelHandlerContext;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=5, locals=2, args_size=2
start local 0 start local 1 0: aload 0
aload 1
invokespecial io.netty.channel.ChannelInboundHandlerAdapter.channelInactive:(Lio/netty/channel/ChannelHandlerContext;)V
1: aload 0
getfield io.reactiverse.pgclient.impl.codec.decoder.InitiateSslHandler.upgradeFuture:Lio/vertx/core/Future;
new io.vertx.core.VertxException
dup
ldc "SSL handshake failed"
iconst_1
invokespecial io.vertx.core.VertxException.<init>:(Ljava/lang/String;Z)V
invokeinterface io.vertx.core.Future.tryFail:(Ljava/lang/Throwable;)Z
pop
2: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 this Lio/reactiverse/pgclient/impl/codec/decoder/InitiateSslHandler;
0 3 1 ctx Lio/netty/channel/ChannelHandlerContext;
Exceptions:
throws java.lang.Exception
MethodParameters:
Name Flags
ctx
private void lambda$0(io.netty.channel.ChannelHandlerContext, java.lang.Void);
descriptor: (Lio/netty/channel/ChannelHandlerContext;Ljava/lang/Void;)V
flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
Code:
stack=2, locals=3, args_size=3
start local 0 start local 2 0: aload 1
invokeinterface io.netty.channel.ChannelHandlerContext.pipeline:()Lio/netty/channel/ChannelPipeline;
aload 0
invokeinterface io.netty.channel.ChannelPipeline.remove:(Lio/netty/channel/ChannelHandler;)Lio/netty/channel/ChannelPipeline;
pop
1: aload 0
getfield io.reactiverse.pgclient.impl.codec.decoder.InitiateSslHandler.upgradeFuture:Lio/vertx/core/Future;
invokeinterface io.vertx.core.Future.complete:()V
2: return
end local 2 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 this Lio/reactiverse/pgclient/impl/codec/decoder/InitiateSslHandler;
0 3 2 v Ljava/lang/Void;
}
SourceFile: "InitiateSslHandler.java"
InnerClasses:
public final Lookup = java.lang.invoke.MethodHandles$Lookup of java.lang.invoke.MethodHandles