final class org.apache.cassandra.transport.ConnectionLimitHandler extends io.netty.channel.ChannelInboundHandlerAdapter
  minor version: 0
  major version: 59
  flags: flags: (0x0030) ACC_FINAL, ACC_SUPER
  this_class: org.apache.cassandra.transport.ConnectionLimitHandler
  super_class: io.netty.channel.ChannelInboundHandlerAdapter
{
  private static final org.slf4j.Logger logger;
    descriptor: Lorg/slf4j/Logger;
    flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL

  private final java.util.concurrent.ConcurrentMap<java.net.InetAddress, java.util.concurrent.atomic.AtomicLong> connectionsPerClient;
    descriptor: Ljava/util/concurrent/ConcurrentMap;
    flags: (0x0012) ACC_PRIVATE, ACC_FINAL
    Signature: Ljava/util/concurrent/ConcurrentMap<Ljava/net/InetAddress;Ljava/util/concurrent/atomic/AtomicLong;>;

  private final java.util.concurrent.atomic.AtomicLong counter;
    descriptor: Ljava/util/concurrent/atomic/AtomicLong;
    flags: (0x0012) ACC_PRIVATE, ACC_FINAL

  static void <clinit>();
    descriptor: ()V
    flags: (0x0008) ACC_STATIC
    Code:
      stack=1, locals=0, args_size=0
         0: .line 42
            ldc Lorg/apache/cassandra/transport/ConnectionLimitHandler;
            invokestatic org.slf4j.LoggerFactory.getLogger:(Ljava/lang/Class;)Lorg/slf4j/Logger;
            putstatic org.apache.cassandra.transport.ConnectionLimitHandler.logger:Lorg/slf4j/Logger;
            return
      LocalVariableTable:
        Start  End  Slot  Name  Signature

  void <init>();
    descriptor: ()V
    flags: (0x0000) 
    Code:
      stack=5, locals=1, args_size=1
        start local 0 // org.apache.cassandra.transport.ConnectionLimitHandler this
         0: .line 40
            aload 0 /* this */
            invokespecial io.netty.channel.ChannelInboundHandlerAdapter.<init>:()V
         1: .line 43
            aload 0 /* this */
            new java.util.concurrent.ConcurrentHashMap
            dup
            invokespecial java.util.concurrent.ConcurrentHashMap.<init>:()V
            putfield org.apache.cassandra.transport.ConnectionLimitHandler.connectionsPerClient:Ljava/util/concurrent/ConcurrentMap;
         2: .line 44
            aload 0 /* this */
            new java.util.concurrent.atomic.AtomicLong
            dup
            lconst_0
            invokespecial java.util.concurrent.atomic.AtomicLong.<init>:(J)V
            putfield org.apache.cassandra.transport.ConnectionLimitHandler.counter:Ljava/util/concurrent/atomic/AtomicLong;
         3: .line 40
            return
        end local 0 // org.apache.cassandra.transport.ConnectionLimitHandler this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    4     0  this  Lorg/apache/cassandra/transport/ConnectionLimitHandler;

  public void channelActive(io.netty.channel.ChannelHandlerContext);
    descriptor: (Lio/netty/channel/ChannelHandlerContext;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=5, locals=11, args_size=2
        start local 0 // org.apache.cassandra.transport.ConnectionLimitHandler this
        start local 1 // io.netty.channel.ChannelHandlerContext ctx
         0: .line 49
            aload 0 /* this */
            getfield org.apache.cassandra.transport.ConnectionLimitHandler.counter:Ljava/util/concurrent/atomic/AtomicLong;
            invokevirtual java.util.concurrent.atomic.AtomicLong.incrementAndGet:()J
            lstore 2 /* count */
        start local 2 // long count
         1: .line 50
            invokestatic org.apache.cassandra.config.DatabaseDescriptor.getNativeTransportMaxConcurrentConnections:()J
            lstore 4 /* limit */
        start local 4 // long limit
         2: .line 52
            lload 4 /* limit */
            lconst_0
            lcmp
            ifge 4
         3: .line 54
            ldc 9223372036854775807
            lstore 4 /* limit */
         4: .line 56
      StackMap locals: long long
      StackMap stack:
            lload 2 /* count */
            lload 4 /* limit */
            lcmp
            ifle 8
         5: .line 59
            getstatic org.apache.cassandra.transport.ConnectionLimitHandler.logger:Lorg/slf4j/Logger;
            ldc "Exceeded maximum native connection limit of {} by using {} connections"
            lload 4 /* limit */
            invokestatic java.lang.Long.valueOf:(J)Ljava/lang/Long;
            lload 2 /* count */
            invokestatic java.lang.Long.valueOf:(J)Ljava/lang/Long;
            invokeinterface org.slf4j.Logger.warn:(Ljava/lang/String;Ljava/lang/Object;Ljava/lang/Object;)V
         6: .line 60
            aload 1 /* ctx */
            invokeinterface io.netty.channel.ChannelHandlerContext.close:()Lio/netty/channel/ChannelFuture;
            pop
         7: .line 61
            goto 22
         8: .line 64
      StackMap locals:
      StackMap stack:
            invokestatic org.apache.cassandra.config.DatabaseDescriptor.getNativeTransportMaxConcurrentConnectionsPerIp:()J
            lstore 6 /* perIpLimit */
        start local 6 // long perIpLimit
         9: .line 65
            lload 6 /* perIpLimit */
            lconst_0
            lcmp
            ifle 21
        10: .line 67
            aload 1 /* ctx */
            invokeinterface io.netty.channel.ChannelHandlerContext.channel:()Lio/netty/channel/Channel;
            invokeinterface io.netty.channel.Channel.remoteAddress:()Ljava/net/SocketAddress;
            checkcast java.net.InetSocketAddress
            invokevirtual java.net.InetSocketAddress.getAddress:()Ljava/net/InetAddress;
            astore 8 /* address */
        start local 8 // java.net.InetAddress address
        11: .line 69
            aload 0 /* this */
            getfield org.apache.cassandra.transport.ConnectionLimitHandler.connectionsPerClient:Ljava/util/concurrent/ConcurrentMap;
            aload 8 /* address */
            invokeinterface java.util.concurrent.ConcurrentMap.get:(Ljava/lang/Object;)Ljava/lang/Object;
            checkcast java.util.concurrent.atomic.AtomicLong
            astore 9 /* perIpCount */
        start local 9 // java.util.concurrent.atomic.AtomicLong perIpCount
        12: .line 70
            aload 9 /* perIpCount */
            ifnonnull 17
        13: .line 72
            new java.util.concurrent.atomic.AtomicLong
            dup
            lconst_0
            invokespecial java.util.concurrent.atomic.AtomicLong.<init>:(J)V
            astore 9 /* perIpCount */
        14: .line 74
            aload 0 /* this */
            getfield org.apache.cassandra.transport.ConnectionLimitHandler.connectionsPerClient:Ljava/util/concurrent/ConcurrentMap;
            aload 8 /* address */
            aload 9 /* perIpCount */
            invokeinterface java.util.concurrent.ConcurrentMap.putIfAbsent:(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
            checkcast java.util.concurrent.atomic.AtomicLong
            astore 10 /* old */
        start local 10 // java.util.concurrent.atomic.AtomicLong old
        15: .line 75
            aload 10 /* old */
            ifnull 17
        16: .line 77
            aload 10 /* old */
            astore 9 /* perIpCount */
        end local 10 // java.util.concurrent.atomic.AtomicLong old
        17: .line 80
      StackMap locals: long java.net.InetAddress java.util.concurrent.atomic.AtomicLong
      StackMap stack:
            aload 9 /* perIpCount */
            invokevirtual java.util.concurrent.atomic.AtomicLong.incrementAndGet:()J
            lload 6 /* perIpLimit */
            lcmp
            ifle 21
        18: .line 83
            getstatic org.apache.cassandra.transport.ConnectionLimitHandler.logger:Lorg/slf4j/Logger;
            ldc "Exceeded maximum native connection limit per ip of {} by using {} connections"
            lload 6 /* perIpLimit */
            invokestatic java.lang.Long.valueOf:(J)Ljava/lang/Long;
            aload 9 /* perIpCount */
            invokeinterface org.slf4j.Logger.warn:(Ljava/lang/String;Ljava/lang/Object;Ljava/lang/Object;)V
        19: .line 84
            aload 1 /* ctx */
            invokeinterface io.netty.channel.ChannelHandlerContext.close:()Lio/netty/channel/ChannelFuture;
            pop
        20: .line 85
            return
        end local 9 // java.util.concurrent.atomic.AtomicLong perIpCount
        end local 8 // java.net.InetAddress address
        21: .line 88
      StackMap locals:
      StackMap stack:
            aload 1 /* ctx */
            invokeinterface io.netty.channel.ChannelHandlerContext.fireChannelActive:()Lio/netty/channel/ChannelHandlerContext;
            pop
        end local 6 // long perIpLimit
        22: .line 90
      StackMap locals:
      StackMap stack:
            return
        end local 4 // long limit
        end local 2 // long count
        end local 1 // io.netty.channel.ChannelHandlerContext ctx
        end local 0 // org.apache.cassandra.transport.ConnectionLimitHandler this
      LocalVariableTable:
        Start  End  Slot        Name  Signature
            0   23     0        this  Lorg/apache/cassandra/transport/ConnectionLimitHandler;
            0   23     1         ctx  Lio/netty/channel/ChannelHandlerContext;
            1   23     2       count  J
            2   23     4       limit  J
            9   22     6  perIpLimit  J
           11   21     8     address  Ljava/net/InetAddress;
           12   21     9  perIpCount  Ljava/util/concurrent/atomic/AtomicLong;
           15   17    10         old  Ljava/util/concurrent/atomic/AtomicLong;
    Exceptions:
      throws java.lang.Exception
    MethodParameters:
      Name  Flags
      ctx   

  public void channelInactive(io.netty.channel.ChannelHandlerContext);
    descriptor: (Lio/netty/channel/ChannelHandlerContext;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=4, locals=4, args_size=2
        start local 0 // org.apache.cassandra.transport.ConnectionLimitHandler this
        start local 1 // io.netty.channel.ChannelHandlerContext ctx
         0: .line 95
            aload 0 /* this */
            getfield org.apache.cassandra.transport.ConnectionLimitHandler.counter:Ljava/util/concurrent/atomic/AtomicLong;
            invokevirtual java.util.concurrent.atomic.AtomicLong.decrementAndGet:()J
            pop2
         1: .line 96
            aload 1 /* ctx */
            invokeinterface io.netty.channel.ChannelHandlerContext.channel:()Lio/netty/channel/Channel;
            invokeinterface io.netty.channel.Channel.remoteAddress:()Ljava/net/SocketAddress;
            checkcast java.net.InetSocketAddress
            invokevirtual java.net.InetSocketAddress.getAddress:()Ljava/net/InetAddress;
            astore 2 /* address */
        start local 2 // java.net.InetAddress address
         2: .line 98
            aload 0 /* this */
            getfield org.apache.cassandra.transport.ConnectionLimitHandler.connectionsPerClient:Ljava/util/concurrent/ConcurrentMap;
            aload 2 /* address */
            invokeinterface java.util.concurrent.ConcurrentMap.get:(Ljava/lang/Object;)Ljava/lang/Object;
            checkcast java.util.concurrent.atomic.AtomicLong
            astore 3 /* count */
        start local 3 // java.util.concurrent.atomic.AtomicLong count
         3: .line 99
            aload 3 /* count */
            ifnull 6
         4: .line 101
            aload 3 /* count */
            invokevirtual java.util.concurrent.atomic.AtomicLong.decrementAndGet:()J
            lconst_0
            lcmp
            ifgt 6
         5: .line 103
            aload 0 /* this */
            getfield org.apache.cassandra.transport.ConnectionLimitHandler.connectionsPerClient:Ljava/util/concurrent/ConcurrentMap;
            aload 2 /* address */
            invokeinterface java.util.concurrent.ConcurrentMap.remove:(Ljava/lang/Object;)Ljava/lang/Object;
            pop
         6: .line 106
      StackMap locals: java.net.InetAddress java.util.concurrent.atomic.AtomicLong
      StackMap stack:
            aload 1 /* ctx */
            invokeinterface io.netty.channel.ChannelHandlerContext.fireChannelInactive:()Lio/netty/channel/ChannelHandlerContext;
            pop
         7: .line 107
            return
        end local 3 // java.util.concurrent.atomic.AtomicLong count
        end local 2 // java.net.InetAddress address
        end local 1 // io.netty.channel.ChannelHandlerContext ctx
        end local 0 // org.apache.cassandra.transport.ConnectionLimitHandler this
      LocalVariableTable:
        Start  End  Slot     Name  Signature
            0    8     0     this  Lorg/apache/cassandra/transport/ConnectionLimitHandler;
            0    8     1      ctx  Lio/netty/channel/ChannelHandlerContext;
            2    8     2  address  Ljava/net/InetAddress;
            3    8     3    count  Ljava/util/concurrent/atomic/AtomicLong;
    Exceptions:
      throws java.lang.Exception
    MethodParameters:
      Name  Flags
      ctx   
}
SourceFile: "ConnectionLimitHandler.java"
InnerClasses:
  public abstract Sharable = io.netty.channel.ChannelHandler$Sharable of io.netty.channel.ChannelHandler
    RuntimeVisibleAnnotations: 
      io.netty.channel.ChannelHandler$Sharable()