io.netty/netty-all/4.1.25.Final : io/netty/example/socksproxy/SocksServerConnectHandler.class

SocksServerConnectHandler
http://netty.io/netty-all/: Netty is an asynchronous event-driven network application framework for rapid development of maintainable high performance protocol servers and clients. (The Netty Project)
Apache License, Version 2.0
The Netty Project Contributors (The Netty Project)
public final class io.netty.example.socksproxy.SocksServerConnectHandler extends io.netty.channel.SimpleChannelInboundHandler<io.netty.handler.codec.socksx.SocksMessage>
  minor version: 0
  major version: 59
  flags: flags: (0x0031) ACC_PUBLIC, ACC_FINAL, ACC_SUPER
  this_class: io.netty.example.socksproxy.SocksServerConnectHandler
  super_class: io.netty.channel.SimpleChannelInboundHandler
{
  private final io.netty.bootstrap.Bootstrap b;
    descriptor: Lio/netty/bootstrap/Bootstrap;
    flags: (0x0012) ACC_PRIVATE, ACC_FINAL

  public void <init>();
    descriptor: ()V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=3, locals=1, args_size=1
        start local 0 // io.netty.example.socksproxy.SocksServerConnectHandler this
         0: .line 39
            aload 0 /* this */
            invokespecial io.netty.channel.SimpleChannelInboundHandler.<init>:()V
         1: .line 41
            aload 0 /* this */
            new io.netty.bootstrap.Bootstrap
            dup
            invokespecial io.netty.bootstrap.Bootstrap.<init>:()V
            putfield io.netty.example.socksproxy.SocksServerConnectHandler.b:Lio/netty/bootstrap/Bootstrap;
         2: .line 39
            return
        end local 0 // io.netty.example.socksproxy.SocksServerConnectHandler this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    3     0  this  Lio/netty/example/socksproxy/SocksServerConnectHandler;

  public void channelRead0(io.netty.channel.ChannelHandlerContext, io.netty.handler.codec.socksx.SocksMessage);
    descriptor: (Lio/netty/channel/ChannelHandlerContext;Lio/netty/handler/codec/socksx/SocksMessage;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=6, locals=6, args_size=3
        start local 0 // io.netty.example.socksproxy.SocksServerConnectHandler this
        start local 1 // io.netty.channel.ChannelHandlerContext ctx
        start local 2 // io.netty.handler.codec.socksx.SocksMessage message
         0: .line 45
            aload 2 /* message */
            instanceof io.netty.handler.codec.socksx.v4.Socks4CommandRequest
            ifeq 14
         1: .line 46
            aload 2 /* message */
            checkcast io.netty.handler.codec.socksx.v4.Socks4CommandRequest
            astore 3 /* request */
        start local 3 // io.netty.handler.codec.socksx.v4.Socks4CommandRequest request
         2: .line 47
            aload 1 /* ctx */
            invokeinterface io.netty.channel.ChannelHandlerContext.executor:()Lio/netty/util/concurrent/EventExecutor;
            invokeinterface io.netty.util.concurrent.EventExecutor.newPromise:()Lio/netty/util/concurrent/Promise;
            astore 4 /* promise */
        start local 4 // io.netty.util.concurrent.Promise promise
         3: .line 48
            aload 4 /* promise */
         4: .line 49
            new io.netty.example.socksproxy.SocksServerConnectHandler$1
            dup
            aload 0 /* this */
            aload 1 /* ctx */
            invokespecial io.netty.example.socksproxy.SocksServerConnectHandler$1.<init>:(Lio/netty/example/socksproxy/SocksServerConnectHandler;Lio/netty/channel/ChannelHandlerContext;)V
         5: .line 48
            invokeinterface io.netty.util.concurrent.Promise.addListener:(Lio/netty/util/concurrent/GenericFutureListener;)Lio/netty/util/concurrent/Promise;
            pop
         6: .line 73
            aload 1 /* ctx */
            invokeinterface io.netty.channel.ChannelHandlerContext.channel:()Lio/netty/channel/Channel;
            astore 5 /* inboundChannel */
        start local 5 // io.netty.channel.Channel inboundChannel
         7: .line 74
            aload 0 /* this */
            getfield io.netty.example.socksproxy.SocksServerConnectHandler.b:Lio/netty/bootstrap/Bootstrap;
            aload 5 /* inboundChannel */
            invokeinterface io.netty.channel.Channel.eventLoop:()Lio/netty/channel/EventLoop;
            invokevirtual io.netty.bootstrap.Bootstrap.group:(Lio/netty/channel/EventLoopGroup;)Lio/netty/bootstrap/AbstractBootstrap;
            checkcast io.netty.bootstrap.Bootstrap
         8: .line 75
            ldc Lio/netty/channel/socket/nio/NioSocketChannel;
            invokevirtual io.netty.bootstrap.Bootstrap.channel:(Ljava/lang/Class;)Lio/netty/bootstrap/AbstractBootstrap;
            checkcast io.netty.bootstrap.Bootstrap
         9: .line 76
            getstatic io.netty.channel.ChannelOption.CONNECT_TIMEOUT_MILLIS:Lio/netty/channel/ChannelOption;
            sipush 10000
            invokestatic java.lang.Integer.valueOf:(I)Ljava/lang/Integer;
            invokevirtual io.netty.bootstrap.Bootstrap.option:(Lio/netty/channel/ChannelOption;Ljava/lang/Object;)Lio/netty/bootstrap/AbstractBootstrap;
            checkcast io.netty.bootstrap.Bootstrap
        10: .line 77
            getstatic io.netty.channel.ChannelOption.SO_KEEPALIVE:Lio/netty/channel/ChannelOption;
            iconst_1
            invokestatic java.lang.Boolean.valueOf:(Z)Ljava/lang/Boolean;
            invokevirtual io.netty.bootstrap.Bootstrap.option:(Lio/netty/channel/ChannelOption;Ljava/lang/Object;)Lio/netty/bootstrap/AbstractBootstrap;
            checkcast io.netty.bootstrap.Bootstrap
        11: .line 78
            new io.netty.example.socksproxy.DirectClientHandler
            dup
            aload 4 /* promise */
            invokespecial io.netty.example.socksproxy.DirectClientHandler.<init>:(Lio/netty/util/concurrent/Promise;)V
            invokevirtual io.netty.bootstrap.Bootstrap.handler:(Lio/netty/channel/ChannelHandler;)Lio/netty/bootstrap/AbstractBootstrap;
            pop
        12: .line 80
            aload 0 /* this */
            getfield io.netty.example.socksproxy.SocksServerConnectHandler.b:Lio/netty/bootstrap/Bootstrap;
            aload 3 /* request */
            invokeinterface io.netty.handler.codec.socksx.v4.Socks4CommandRequest.dstAddr:()Ljava/lang/String;
            aload 3 /* request */
            invokeinterface io.netty.handler.codec.socksx.v4.Socks4CommandRequest.dstPort:()I
            invokevirtual io.netty.bootstrap.Bootstrap.connect:(Ljava/lang/String;I)Lio/netty/channel/ChannelFuture;
            new io.netty.example.socksproxy.SocksServerConnectHandler$2
            dup
            aload 0 /* this */
            aload 1 /* ctx */
            invokespecial io.netty.example.socksproxy.SocksServerConnectHandler$2.<init>:(Lio/netty/example/socksproxy/SocksServerConnectHandler;Lio/netty/channel/ChannelHandlerContext;)V
            invokeinterface io.netty.channel.ChannelFuture.addListener:(Lio/netty/util/concurrent/GenericFutureListener;)Lio/netty/channel/ChannelFuture;
            pop
        end local 5 // io.netty.channel.Channel inboundChannel
        end local 4 // io.netty.util.concurrent.Promise promise
        end local 3 // io.netty.handler.codec.socksx.v4.Socks4CommandRequest request
        13: .line 94
            goto 29
      StackMap locals:
      StackMap stack:
        14: aload 2 /* message */
            instanceof io.netty.handler.codec.socksx.v5.Socks5CommandRequest
            ifeq 28
        15: .line 95
            aload 2 /* message */
            checkcast io.netty.handler.codec.socksx.v5.Socks5CommandRequest
            astore 3 /* request */
        start local 3 // io.netty.handler.codec.socksx.v5.Socks5CommandRequest request
        16: .line 96
            aload 1 /* ctx */
            invokeinterface io.netty.channel.ChannelHandlerContext.executor:()Lio/netty/util/concurrent/EventExecutor;
            invokeinterface io.netty.util.concurrent.EventExecutor.newPromise:()Lio/netty/util/concurrent/Promise;
            astore 4 /* promise */
        start local 4 // io.netty.util.concurrent.Promise promise
        17: .line 97
            aload 4 /* promise */
        18: .line 98
            new io.netty.example.socksproxy.SocksServerConnectHandler$3
            dup
            aload 0 /* this */
            aload 1 /* ctx */
            aload 3 /* request */
            invokespecial io.netty.example.socksproxy.SocksServerConnectHandler$3.<init>:(Lio/netty/example/socksproxy/SocksServerConnectHandler;Lio/netty/channel/ChannelHandlerContext;Lio/netty/handler/codec/socksx/v5/Socks5CommandRequest;)V
        19: .line 97
            invokeinterface io.netty.util.concurrent.Promise.addListener:(Lio/netty/util/concurrent/GenericFutureListener;)Lio/netty/util/concurrent/Promise;
            pop
        20: .line 126
            aload 1 /* ctx */
            invokeinterface io.netty.channel.ChannelHandlerContext.channel:()Lio/netty/channel/Channel;
            astore 5 /* inboundChannel */
        start local 5 // io.netty.channel.Channel inboundChannel
        21: .line 127
            aload 0 /* this */
            getfield io.netty.example.socksproxy.SocksServerConnectHandler.b:Lio/netty/bootstrap/Bootstrap;
            aload 5 /* inboundChannel */
            invokeinterface io.netty.channel.Channel.eventLoop:()Lio/netty/channel/EventLoop;
            invokevirtual io.netty.bootstrap.Bootstrap.group:(Lio/netty/channel/EventLoopGroup;)Lio/netty/bootstrap/AbstractBootstrap;
            checkcast io.netty.bootstrap.Bootstrap
        22: .line 128
            ldc Lio/netty/channel/socket/nio/NioSocketChannel;
            invokevirtual io.netty.bootstrap.Bootstrap.channel:(Ljava/lang/Class;)Lio/netty/bootstrap/AbstractBootstrap;
            checkcast io.netty.bootstrap.Bootstrap
        23: .line 129
            getstatic io.netty.channel.ChannelOption.CONNECT_TIMEOUT_MILLIS:Lio/netty/channel/ChannelOption;
            sipush 10000
            invokestatic java.lang.Integer.valueOf:(I)Ljava/lang/Integer;
            invokevirtual io.netty.bootstrap.Bootstrap.option:(Lio/netty/channel/ChannelOption;Ljava/lang/Object;)Lio/netty/bootstrap/AbstractBootstrap;
            checkcast io.netty.bootstrap.Bootstrap
        24: .line 130
            getstatic io.netty.channel.ChannelOption.SO_KEEPALIVE:Lio/netty/channel/ChannelOption;
            iconst_1
            invokestatic java.lang.Boolean.valueOf:(Z)Ljava/lang/Boolean;
            invokevirtual io.netty.bootstrap.Bootstrap.option:(Lio/netty/channel/ChannelOption;Ljava/lang/Object;)Lio/netty/bootstrap/AbstractBootstrap;
            checkcast io.netty.bootstrap.Bootstrap
        25: .line 131
            new io.netty.example.socksproxy.DirectClientHandler
            dup
            aload 4 /* promise */
            invokespecial io.netty.example.socksproxy.DirectClientHandler.<init>:(Lio/netty/util/concurrent/Promise;)V
            invokevirtual io.netty.bootstrap.Bootstrap.handler:(Lio/netty/channel/ChannelHandler;)Lio/netty/bootstrap/AbstractBootstrap;
            pop
        26: .line 133
            aload 0 /* this */
            getfield io.netty.example.socksproxy.SocksServerConnectHandler.b:Lio/netty/bootstrap/Bootstrap;
            aload 3 /* request */
            invokeinterface io.netty.handler.codec.socksx.v5.Socks5CommandRequest.dstAddr:()Ljava/lang/String;
            aload 3 /* request */
            invokeinterface io.netty.handler.codec.socksx.v5.Socks5CommandRequest.dstPort:()I
            invokevirtual io.netty.bootstrap.Bootstrap.connect:(Ljava/lang/String;I)Lio/netty/channel/ChannelFuture;
            new io.netty.example.socksproxy.SocksServerConnectHandler$4
            dup
            aload 0 /* this */
            aload 1 /* ctx */
            aload 3 /* request */
            invokespecial io.netty.example.socksproxy.SocksServerConnectHandler$4.<init>:(Lio/netty/example/socksproxy/SocksServerConnectHandler;Lio/netty/channel/ChannelHandlerContext;Lio/netty/handler/codec/socksx/v5/Socks5CommandRequest;)V
            invokeinterface io.netty.channel.ChannelFuture.addListener:(Lio/netty/util/concurrent/GenericFutureListener;)Lio/netty/channel/ChannelFuture;
            pop
        end local 5 // io.netty.channel.Channel inboundChannel
        end local 4 // io.netty.util.concurrent.Promise promise
        end local 3 // io.netty.handler.codec.socksx.v5.Socks5CommandRequest request
        27: .line 146
            goto 29
        28: .line 147
      StackMap locals:
      StackMap stack:
            aload 1 /* ctx */
            invokeinterface io.netty.channel.ChannelHandlerContext.close:()Lio/netty/channel/ChannelFuture;
            pop
        29: .line 149
      StackMap locals:
      StackMap stack:
            return
        end local 2 // io.netty.handler.codec.socksx.SocksMessage message
        end local 1 // io.netty.channel.ChannelHandlerContext ctx
        end local 0 // io.netty.example.socksproxy.SocksServerConnectHandler this
      LocalVariableTable:
        Start  End  Slot            Name  Signature
            0   30     0            this  Lio/netty/example/socksproxy/SocksServerConnectHandler;
            0   30     1             ctx  Lio/netty/channel/ChannelHandlerContext;
            0   30     2         message  Lio/netty/handler/codec/socksx/SocksMessage;
            2   13     3         request  Lio/netty/handler/codec/socksx/v4/Socks4CommandRequest;
            3   13     4         promise  Lio/netty/util/concurrent/Promise<Lio/netty/channel/Channel;>;
            7   13     5  inboundChannel  Lio/netty/channel/Channel;
           16   27     3         request  Lio/netty/handler/codec/socksx/v5/Socks5CommandRequest;
           17   27     4         promise  Lio/netty/util/concurrent/Promise<Lio/netty/channel/Channel;>;
           21   27     5  inboundChannel  Lio/netty/channel/Channel;
    Exceptions:
      throws java.lang.Exception
    MethodParameters:
         Name  Flags
      ctx      final
      message  final

  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=1, locals=3, args_size=3
        start local 0 // io.netty.example.socksproxy.SocksServerConnectHandler this
        start local 1 // io.netty.channel.ChannelHandlerContext ctx
        start local 2 // java.lang.Throwable cause
         0: .line 153
            aload 1 /* ctx */
            invokeinterface io.netty.channel.ChannelHandlerContext.channel:()Lio/netty/channel/Channel;
            invokestatic io.netty.example.socksproxy.SocksServerUtils.closeOnFlush:(Lio/netty/channel/Channel;)V
         1: .line 154
            return
        end local 2 // java.lang.Throwable cause
        end local 1 // io.netty.channel.ChannelHandlerContext ctx
        end local 0 // io.netty.example.socksproxy.SocksServerConnectHandler this
      LocalVariableTable:
        Start  End  Slot   Name  Signature
            0    2     0   this  Lio/netty/example/socksproxy/SocksServerConnectHandler;
            0    2     1    ctx  Lio/netty/channel/ChannelHandlerContext;
            0    2     2  cause  Ljava/lang/Throwable;
    Exceptions:
      throws java.lang.Exception
    MethodParameters:
       Name  Flags
      ctx    
      cause  

  public void channelRead0(io.netty.channel.ChannelHandlerContext, java.lang.Object);
    descriptor: (Lio/netty/channel/ChannelHandlerContext;Ljava/lang/Object;)V
    flags: (0x1041) ACC_PUBLIC, ACC_BRIDGE, ACC_SYNTHETIC
    Code:
      stack=3, locals=3, args_size=3
         0: .line 1
            aload 0
            aload 1
            aload 2
            checkcast io.netty.handler.codec.socksx.SocksMessage
            invokevirtual io.netty.example.socksproxy.SocksServerConnectHandler.channelRead0:(Lio/netty/channel/ChannelHandlerContext;Lio/netty/handler/codec/socksx/SocksMessage;)V
            return
      LocalVariableTable:
        Start  End  Slot  Name  Signature
    Exceptions:
      throws java.lang.Exception
}
Signature: Lio/netty/channel/SimpleChannelInboundHandler<Lio/netty/handler/codec/socksx/SocksMessage;>;
SourceFile: "SocksServerConnectHandler.java"
NestMembers:
  io.netty.example.socksproxy.SocksServerConnectHandler$1  io.netty.example.socksproxy.SocksServerConnectHandler$1$1  io.netty.example.socksproxy.SocksServerConnectHandler$2  io.netty.example.socksproxy.SocksServerConnectHandler$3  io.netty.example.socksproxy.SocksServerConnectHandler$3$1  io.netty.example.socksproxy.SocksServerConnectHandler$4
InnerClasses:
  public abstract Sharable = io.netty.channel.ChannelHandler$Sharable of io.netty.channel.ChannelHandler
  io.netty.example.socksproxy.SocksServerConnectHandler$1
  io.netty.example.socksproxy.SocksServerConnectHandler$2
  io.netty.example.socksproxy.SocksServerConnectHandler$3
  io.netty.example.socksproxy.SocksServerConnectHandler$4
    RuntimeVisibleAnnotations: 
      io.netty.channel.ChannelHandler$Sharable()
/

io.netty/ netty-all/ 4.1.25.Final/ io/netty/example/socksproxy/SocksServerConnectHandler.class
