org.eclipse.jetty/jetty-server/10.0.0-alpha0 : org/eclipse/jetty/server/AcceptRateLimit.class

AcceptRateLimit
http://www.eclipse.org/jetty: The core jetty server artifact. (Webtide)
Greg Wilkins (Webtide, LLC)
Jan Bartel (Webtide, LLC)
Jesse McConnell (Webtide, LLC)
Joakim Erdfelt (Webtide, LLC)
Simone Bordet (Webtide, LLC)
David Jencks (IBM)
Olivier Lamy (Webtide, LLC)
public class org.eclipse.jetty.server.AcceptRateLimit extends org.eclipse.jetty.util.component.AbstractLifeCycle implements org.eclipse.jetty.io.SelectorManager$AcceptListener, java.lang.Runnable
  minor version: 0
  major version: 59
  flags: flags: (0x0021) ACC_PUBLIC, ACC_SUPER
  this_class: org.eclipse.jetty.server.AcceptRateLimit
  super_class: org.eclipse.jetty.util.component.AbstractLifeCycle
{
  private static final org.eclipse.jetty.util.log.Logger LOG;
    descriptor: Lorg/eclipse/jetty/util/log/Logger;
    flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL

  private final org.eclipse.jetty.server.Server _server;
    descriptor: Lorg/eclipse/jetty/server/Server;
    flags: (0x0012) ACC_PRIVATE, ACC_FINAL

  private final java.util.List<org.eclipse.jetty.server.AbstractConnector> _connectors;
    descriptor: Ljava/util/List;
    flags: (0x0012) ACC_PRIVATE, ACC_FINAL
    Signature: Ljava/util/List<Lorg/eclipse/jetty/server/AbstractConnector;>;

  private final org.eclipse.jetty.server.AcceptRateLimit$Rate _rate;
    descriptor: Lorg/eclipse/jetty/server/AcceptRateLimit$Rate;
    flags: (0x0012) ACC_PRIVATE, ACC_FINAL

  private final int _acceptRateLimit;
    descriptor: I
    flags: (0x0012) ACC_PRIVATE, ACC_FINAL

  private boolean _limiting;
    descriptor: Z
    flags: (0x0002) ACC_PRIVATE

  private org.eclipse.jetty.util.thread.Scheduler$Task _task;
    descriptor: Lorg/eclipse/jetty/util/thread/Scheduler$Task;
    flags: (0x0002) ACC_PRIVATE

  static void <clinit>();
    descriptor: ()V
    flags: (0x0008) ACC_STATIC
    Code:
      stack=1, locals=0, args_size=0
         0: .line 65
            ldc Lorg/eclipse/jetty/server/AcceptRateLimit;
            invokestatic org.eclipse.jetty.util.log.Log.getLogger:(Ljava/lang/Class;)Lorg/eclipse/jetty/util/log/Logger;
            putstatic org.eclipse.jetty.server.AcceptRateLimit.LOG:Lorg/eclipse/jetty/util/log/Logger;
            return
      LocalVariableTable:
        Start  End  Slot  Name  Signature

  public void <init>(int, long, java.util.concurrent.TimeUnit, org.eclipse.jetty.server.Server);
    descriptor: (IJLjava/util/concurrent/TimeUnit;Lorg/eclipse/jetty/server/Server;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=7, locals=6, args_size=5
        start local 0 // org.eclipse.jetty.server.AcceptRateLimit this
        start local 1 // int acceptRateLimit
        start local 2 // long period
        start local 4 // java.util.concurrent.TimeUnit units
        start local 5 // org.eclipse.jetty.server.Server server
         0: .line 74
            aload 0 /* this */
            invokespecial org.eclipse.jetty.util.component.AbstractLifeCycle.<init>:()V
         1: .line 68
            aload 0 /* this */
            new java.util.ArrayList
            dup
            invokespecial java.util.ArrayList.<init>:()V
            putfield org.eclipse.jetty.server.AcceptRateLimit._connectors:Ljava/util/List;
         2: .line 76
            aload 0 /* this */
            aload 5 /* server */
            putfield org.eclipse.jetty.server.AcceptRateLimit._server:Lorg/eclipse/jetty/server/Server;
         3: .line 77
            aload 0 /* this */
            iload 1 /* acceptRateLimit */
            putfield org.eclipse.jetty.server.AcceptRateLimit._acceptRateLimit:I
         4: .line 78
            aload 0 /* this */
            new org.eclipse.jetty.server.AcceptRateLimit$Rate
            dup
            aload 0 /* this */
            lload 2 /* period */
            aload 4 /* units */
            invokespecial org.eclipse.jetty.server.AcceptRateLimit$Rate.<init>:(Lorg/eclipse/jetty/server/AcceptRateLimit;JLjava/util/concurrent/TimeUnit;)V
            putfield org.eclipse.jetty.server.AcceptRateLimit._rate:Lorg/eclipse/jetty/server/AcceptRateLimit$Rate;
         5: .line 79
            return
        end local 5 // org.eclipse.jetty.server.Server server
        end local 4 // java.util.concurrent.TimeUnit units
        end local 2 // long period
        end local 1 // int acceptRateLimit
        end local 0 // org.eclipse.jetty.server.AcceptRateLimit this
      LocalVariableTable:
        Start  End  Slot             Name  Signature
            0    6     0             this  Lorg/eclipse/jetty/server/AcceptRateLimit;
            0    6     1  acceptRateLimit  I
            0    6     2           period  J
            0    6     4            units  Ljava/util/concurrent/TimeUnit;
            0    6     5           server  Lorg/eclipse/jetty/server/Server;
    RuntimeVisibleParameterAnnotations: 
      0:
        org.eclipse.jetty.util.annotation.Name(value = "acceptRateLimit")
      1:
        org.eclipse.jetty.util.annotation.Name(value = "period")
      2:
        org.eclipse.jetty.util.annotation.Name(value = "units")
      3:
        org.eclipse.jetty.util.annotation.Name(value = "server")
    MethodParameters:
                 Name  Flags
      acceptRateLimit  
      period           
      units            
      server           

  public void <init>(int, long, java.util.concurrent.TimeUnit, org.eclipse.jetty.server.Connector[]);
    descriptor: (IJLjava/util/concurrent/TimeUnit;[Lorg/eclipse/jetty/server/Connector;)V
    flags: (0x0081) ACC_PUBLIC, ACC_VARARGS
    Code:
      stack=6, locals=10, args_size=5
        start local 0 // org.eclipse.jetty.server.AcceptRateLimit this
        start local 1 // int limit
        start local 2 // long period
        start local 4 // java.util.concurrent.TimeUnit units
        start local 5 // org.eclipse.jetty.server.Connector[] connectors
         0: .line 83
            aload 0 /* this */
            iload 1 /* limit */
            lload 2 /* period */
            aload 4 /* units */
            aconst_null
            invokespecial org.eclipse.jetty.server.AcceptRateLimit.<init>:(IJLjava/util/concurrent/TimeUnit;Lorg/eclipse/jetty/server/Server;)V
         1: .line 84
            aload 5 /* connectors */
            dup
            astore 9
            arraylength
            istore 8
            iconst_0
            istore 7
            goto 7
      StackMap locals: org.eclipse.jetty.server.AcceptRateLimit int long java.util.concurrent.TimeUnit org.eclipse.jetty.server.Connector[] top int int org.eclipse.jetty.server.Connector[]
      StackMap stack:
         2: aload 9
            iload 7
            aaload
            astore 6 /* c */
        start local 6 // org.eclipse.jetty.server.Connector c
         3: .line 86
            aload 6 /* c */
            instanceof org.eclipse.jetty.server.AbstractConnector
            ifeq 5
         4: .line 87
            aload 0 /* this */
            getfield org.eclipse.jetty.server.AcceptRateLimit._connectors:Ljava/util/List;
            aload 6 /* c */
            checkcast org.eclipse.jetty.server.AbstractConnector
            invokeinterface java.util.List.add:(Ljava/lang/Object;)Z
            pop
            goto 6
         5: .line 89
      StackMap locals: org.eclipse.jetty.server.AcceptRateLimit int long java.util.concurrent.TimeUnit org.eclipse.jetty.server.Connector[] org.eclipse.jetty.server.Connector int int org.eclipse.jetty.server.Connector[]
      StackMap stack:
            getstatic org.eclipse.jetty.server.AcceptRateLimit.LOG:Lorg/eclipse/jetty/util/log/Logger;
            ldc "Connector {} is not an AbstractConnector. Connections not limited"
            iconst_1
            anewarray java.lang.Object
            dup
            iconst_0
            aload 6 /* c */
            aastore
            invokeinterface org.eclipse.jetty.util.log.Logger.warn:(Ljava/lang/String;[Ljava/lang/Object;)V
        end local 6 // org.eclipse.jetty.server.Connector c
         6: .line 84
      StackMap locals: org.eclipse.jetty.server.AcceptRateLimit int long java.util.concurrent.TimeUnit org.eclipse.jetty.server.Connector[] top int int org.eclipse.jetty.server.Connector[]
      StackMap stack:
            iinc 7 1
      StackMap locals:
      StackMap stack:
         7: iload 7
            iload 8
            if_icmplt 2
         8: .line 91
            return
        end local 5 // org.eclipse.jetty.server.Connector[] connectors
        end local 4 // java.util.concurrent.TimeUnit units
        end local 2 // long period
        end local 1 // int limit
        end local 0 // org.eclipse.jetty.server.AcceptRateLimit this
      LocalVariableTable:
        Start  End  Slot        Name  Signature
            0    9     0        this  Lorg/eclipse/jetty/server/AcceptRateLimit;
            0    9     1       limit  I
            0    9     2      period  J
            0    9     4       units  Ljava/util/concurrent/TimeUnit;
            0    9     5  connectors  [Lorg/eclipse/jetty/server/Connector;
            3    6     6           c  Lorg/eclipse/jetty/server/Connector;
    RuntimeVisibleParameterAnnotations: 
      0:
        org.eclipse.jetty.util.annotation.Name(value = "limit")
      1:
        org.eclipse.jetty.util.annotation.Name(value = "period")
      2:
        org.eclipse.jetty.util.annotation.Name(value = "units")
      3:
        org.eclipse.jetty.util.annotation.Name(value = "connectors")
    MethodParameters:
            Name  Flags
      limit       
      period      
      units       
      connectors  

  public int getAcceptRateLimit();
    descriptor: ()I
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=1, locals=1, args_size=1
        start local 0 // org.eclipse.jetty.server.AcceptRateLimit this
         0: .line 96
            aload 0 /* this */
            getfield org.eclipse.jetty.server.AcceptRateLimit._acceptRateLimit:I
            ireturn
        end local 0 // org.eclipse.jetty.server.AcceptRateLimit this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Lorg/eclipse/jetty/server/AcceptRateLimit;
    RuntimeVisibleAnnotations: 
      org.eclipse.jetty.util.annotation.ManagedAttribute(value = "The accept rate limit")

  public long getPeriod();
    descriptor: ()J
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=2, locals=1, args_size=1
        start local 0 // org.eclipse.jetty.server.AcceptRateLimit this
         0: .line 102
            aload 0 /* this */
            getfield org.eclipse.jetty.server.AcceptRateLimit._rate:Lorg/eclipse/jetty/server/AcceptRateLimit$Rate;
            invokevirtual org.eclipse.jetty.server.AcceptRateLimit$Rate.getPeriod:()J
            lreturn
        end local 0 // org.eclipse.jetty.server.AcceptRateLimit this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Lorg/eclipse/jetty/server/AcceptRateLimit;
    RuntimeVisibleAnnotations: 
      org.eclipse.jetty.util.annotation.ManagedAttribute(value = "The accept rate period")

  public java.util.concurrent.TimeUnit getUnits();
    descriptor: ()Ljava/util/concurrent/TimeUnit;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=1, locals=1, args_size=1
        start local 0 // org.eclipse.jetty.server.AcceptRateLimit this
         0: .line 108
            aload 0 /* this */
            getfield org.eclipse.jetty.server.AcceptRateLimit._rate:Lorg/eclipse/jetty/server/AcceptRateLimit$Rate;
            invokevirtual org.eclipse.jetty.server.AcceptRateLimit$Rate.getUnits:()Ljava/util/concurrent/TimeUnit;
            areturn
        end local 0 // org.eclipse.jetty.server.AcceptRateLimit this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Lorg/eclipse/jetty/server/AcceptRateLimit;
    RuntimeVisibleAnnotations: 
      org.eclipse.jetty.util.annotation.ManagedAttribute(value = "The accept rate period units")

  public int getRate();
    descriptor: ()I
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=1, locals=1, args_size=1
        start local 0 // org.eclipse.jetty.server.AcceptRateLimit this
         0: .line 114
            aload 0 /* this */
            getfield org.eclipse.jetty.server.AcceptRateLimit._rate:Lorg/eclipse/jetty/server/AcceptRateLimit$Rate;
            invokevirtual org.eclipse.jetty.server.AcceptRateLimit$Rate.getRate:()I
            ireturn
        end local 0 // org.eclipse.jetty.server.AcceptRateLimit this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Lorg/eclipse/jetty/server/AcceptRateLimit;
    RuntimeVisibleAnnotations: 
      org.eclipse.jetty.util.annotation.ManagedAttribute(value = "The current accept rate")

  public long getMaxRate();
    descriptor: ()J
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=2, locals=1, args_size=1
        start local 0 // org.eclipse.jetty.server.AcceptRateLimit this
         0: .line 120
            aload 0 /* this */
            getfield org.eclipse.jetty.server.AcceptRateLimit._rate:Lorg/eclipse/jetty/server/AcceptRateLimit$Rate;
            invokevirtual org.eclipse.jetty.server.AcceptRateLimit$Rate.getMax:()J
            lreturn
        end local 0 // org.eclipse.jetty.server.AcceptRateLimit this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Lorg/eclipse/jetty/server/AcceptRateLimit;
    RuntimeVisibleAnnotations: 
      org.eclipse.jetty.util.annotation.ManagedAttribute(value = "The maximum accept rate achieved")

  public void reset();
    descriptor: ()V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=2, locals=2, args_size=1
        start local 0 // org.eclipse.jetty.server.AcceptRateLimit this
         0: .line 126
            aload 0 /* this */
            getfield org.eclipse.jetty.server.AcceptRateLimit._rate:Lorg/eclipse/jetty/server/AcceptRateLimit$Rate;
            dup
            astore 1
            monitorenter
         1: .line 128
            aload 0 /* this */
            getfield org.eclipse.jetty.server.AcceptRateLimit._rate:Lorg/eclipse/jetty/server/AcceptRateLimit$Rate;
            invokevirtual org.eclipse.jetty.server.AcceptRateLimit$Rate.reset:()V
         2: .line 129
            aload 0 /* this */
            getfield org.eclipse.jetty.server.AcceptRateLimit._limiting:Z
            ifeq 5
         3: .line 131
            aload 0 /* this */
            iconst_0
            putfield org.eclipse.jetty.server.AcceptRateLimit._limiting:Z
         4: .line 132
            aload 0 /* this */
            invokevirtual org.eclipse.jetty.server.AcceptRateLimit.unlimit:()V
         5: .line 126
      StackMap locals: org.eclipse.jetty.server.AcceptRateLimit$Rate
      StackMap stack:
            aload 1
            monitorexit
         6: goto 9
      StackMap locals:
      StackMap stack: java.lang.Throwable
         7: aload 1
            monitorexit
         8: athrow
         9: .line 135
      StackMap locals:
      StackMap stack:
            return
        end local 0 // org.eclipse.jetty.server.AcceptRateLimit this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0   10     0  this  Lorg/eclipse/jetty/server/AcceptRateLimit;
      Exception table:
        from    to  target  type
           1     6       7  any
           7     8       7  any
    RuntimeVisibleAnnotations: 
      org.eclipse.jetty.util.annotation.ManagedOperation(value = "Resets the accept rate", impact = "ACTION")

  protected void age(long, java.util.concurrent.TimeUnit);
    descriptor: (JLjava/util/concurrent/TimeUnit;)V
    flags: (0x0004) ACC_PROTECTED
    Code:
      stack=4, locals=4, args_size=3
        start local 0 // org.eclipse.jetty.server.AcceptRateLimit this
        start local 1 // long period
        start local 3 // java.util.concurrent.TimeUnit units
         0: .line 139
            aload 0 /* this */
            getfield org.eclipse.jetty.server.AcceptRateLimit._rate:Lorg/eclipse/jetty/server/AcceptRateLimit$Rate;
            lload 1 /* period */
            aload 3 /* units */
            invokevirtual org.eclipse.jetty.server.AcceptRateLimit$Rate.age:(JLjava/util/concurrent/TimeUnit;)V
         1: .line 140
            return
        end local 3 // java.util.concurrent.TimeUnit units
        end local 1 // long period
        end local 0 // org.eclipse.jetty.server.AcceptRateLimit this
      LocalVariableTable:
        Start  End  Slot    Name  Signature
            0    2     0    this  Lorg/eclipse/jetty/server/AcceptRateLimit;
            0    2     1  period  J
            0    2     3   units  Ljava/util/concurrent/TimeUnit;
    MethodParameters:
        Name  Flags
      period  
      units   

  protected void doStart();
    descriptor: ()V
    flags: (0x0004) ACC_PROTECTED
    Code:
      stack=6, locals=6, args_size=1
        start local 0 // org.eclipse.jetty.server.AcceptRateLimit this
         0: .line 145
            aload 0 /* this */
            getfield org.eclipse.jetty.server.AcceptRateLimit._rate:Lorg/eclipse/jetty/server/AcceptRateLimit$Rate;
            dup
            astore 1
            monitorenter
         1: .line 147
            aload 0 /* this */
            getfield org.eclipse.jetty.server.AcceptRateLimit._server:Lorg/eclipse/jetty/server/Server;
            ifnull 9
         2: .line 149
            aload 0 /* this */
            getfield org.eclipse.jetty.server.AcceptRateLimit._server:Lorg/eclipse/jetty/server/Server;
            invokevirtual org.eclipse.jetty.server.Server.getConnectors:()[Lorg/eclipse/jetty/server/Connector;
            dup
            astore 5
            arraylength
            istore 4
            iconst_0
            istore 3
            goto 8
      StackMap locals: org.eclipse.jetty.server.AcceptRateLimit org.eclipse.jetty.server.AcceptRateLimit$Rate top int int org.eclipse.jetty.server.Connector[]
      StackMap stack:
         3: aload 5
            iload 3
            aaload
            astore 2 /* c */
        start local 2 // org.eclipse.jetty.server.Connector c
         4: .line 151
            aload 2 /* c */
            instanceof org.eclipse.jetty.server.AbstractConnector
            ifeq 6
         5: .line 152
            aload 0 /* this */
            getfield org.eclipse.jetty.server.AcceptRateLimit._connectors:Ljava/util/List;
            aload 2 /* c */
            checkcast org.eclipse.jetty.server.AbstractConnector
            invokeinterface java.util.List.add:(Ljava/lang/Object;)Z
            pop
            goto 7
         6: .line 154
      StackMap locals: org.eclipse.jetty.server.AcceptRateLimit org.eclipse.jetty.server.AcceptRateLimit$Rate org.eclipse.jetty.server.Connector int int org.eclipse.jetty.server.Connector[]
      StackMap stack:
            getstatic org.eclipse.jetty.server.AcceptRateLimit.LOG:Lorg/eclipse/jetty/util/log/Logger;
            ldc "Connector {} is not an AbstractConnector. Connections not limited"
            iconst_1
            anewarray java.lang.Object
            dup
            iconst_0
            aload 2 /* c */
            aastore
            invokeinterface org.eclipse.jetty.util.log.Logger.warn:(Ljava/lang/String;[Ljava/lang/Object;)V
        end local 2 // org.eclipse.jetty.server.Connector c
         7: .line 149
      StackMap locals: org.eclipse.jetty.server.AcceptRateLimit org.eclipse.jetty.server.AcceptRateLimit$Rate top int int org.eclipse.jetty.server.Connector[]
      StackMap stack:
            iinc 3 1
      StackMap locals:
      StackMap stack:
         8: iload 3
            iload 4
            if_icmplt 3
         9: .line 158
      StackMap locals: org.eclipse.jetty.server.AcceptRateLimit org.eclipse.jetty.server.AcceptRateLimit$Rate
      StackMap stack:
            getstatic org.eclipse.jetty.server.AcceptRateLimit.LOG:Lorg/eclipse/jetty/util/log/Logger;
            invokeinterface org.eclipse.jetty.util.log.Logger.isDebugEnabled:()Z
            ifeq 11
        10: .line 159
            getstatic org.eclipse.jetty.server.AcceptRateLimit.LOG:Lorg/eclipse/jetty/util/log/Logger;
            ldc "AcceptLimit accept<{} rate<{} in {} for {}"
            iconst_3
            anewarray java.lang.Object
            dup
            iconst_0
            aload 0 /* this */
            getfield org.eclipse.jetty.server.AcceptRateLimit._acceptRateLimit:I
            invokestatic java.lang.Integer.valueOf:(I)Ljava/lang/Integer;
            aastore
            dup
            iconst_1
            aload 0 /* this */
            getfield org.eclipse.jetty.server.AcceptRateLimit._rate:Lorg/eclipse/jetty/server/AcceptRateLimit$Rate;
            aastore
            dup
            iconst_2
            aload 0 /* this */
            getfield org.eclipse.jetty.server.AcceptRateLimit._connectors:Ljava/util/List;
            aastore
            invokeinterface org.eclipse.jetty.util.log.Logger.debug:(Ljava/lang/String;[Ljava/lang/Object;)V
        11: .line 161
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            getfield org.eclipse.jetty.server.AcceptRateLimit._connectors:Ljava/util/List;
            invokeinterface java.util.List.iterator:()Ljava/util/Iterator;
            astore 3
            goto 14
      StackMap locals: org.eclipse.jetty.server.AcceptRateLimit org.eclipse.jetty.server.AcceptRateLimit$Rate top java.util.Iterator
      StackMap stack:
        12: aload 3
            invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
            checkcast org.eclipse.jetty.server.AbstractConnector
            astore 2 /* c */
        start local 2 // org.eclipse.jetty.server.AbstractConnector c
        13: .line 163
            aload 2 /* c */
            aload 0 /* this */
            invokevirtual org.eclipse.jetty.server.AbstractConnector.addBean:(Ljava/lang/Object;)Z
            pop
        end local 2 // org.eclipse.jetty.server.AbstractConnector c
        14: .line 161
      StackMap locals:
      StackMap stack:
            aload 3
            invokeinterface java.util.Iterator.hasNext:()Z
            ifne 12
        15: .line 145
            aload 1
            monitorexit
        16: goto 19
      StackMap locals: org.eclipse.jetty.server.AcceptRateLimit org.eclipse.jetty.server.AcceptRateLimit$Rate
      StackMap stack: java.lang.Throwable
        17: aload 1
            monitorexit
        18: athrow
        19: .line 166
      StackMap locals:
      StackMap stack:
            return
        end local 0 // org.eclipse.jetty.server.AcceptRateLimit this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0   20     0  this  Lorg/eclipse/jetty/server/AcceptRateLimit;
            4    7     2     c  Lorg/eclipse/jetty/server/Connector;
           13   14     2     c  Lorg/eclipse/jetty/server/AbstractConnector;
      Exception table:
        from    to  target  type
           1    16      17  any
          17    18      17  any
    Exceptions:
      throws java.lang.Exception

  protected void doStop();
    descriptor: ()V
    flags: (0x0004) ACC_PROTECTED
    Code:
      stack=2, locals=4, args_size=1
        start local 0 // org.eclipse.jetty.server.AcceptRateLimit this
         0: .line 171
            aload 0 /* this */
            getfield org.eclipse.jetty.server.AcceptRateLimit._rate:Lorg/eclipse/jetty/server/AcceptRateLimit$Rate;
            dup
            astore 1
            monitorenter
         1: .line 173
            aload 0 /* this */
            getfield org.eclipse.jetty.server.AcceptRateLimit._task:Lorg/eclipse/jetty/util/thread/Scheduler$Task;
            ifnull 3
         2: .line 174
            aload 0 /* this */
            getfield org.eclipse.jetty.server.AcceptRateLimit._task:Lorg/eclipse/jetty/util/thread/Scheduler$Task;
            invokeinterface org.eclipse.jetty.util.thread.Scheduler$Task.cancel:()Z
            pop
         3: .line 175
      StackMap locals: org.eclipse.jetty.server.AcceptRateLimit$Rate
      StackMap stack:
            aload 0 /* this */
            aconst_null
            putfield org.eclipse.jetty.server.AcceptRateLimit._task:Lorg/eclipse/jetty/util/thread/Scheduler$Task;
         4: .line 176
            aload 0 /* this */
            getfield org.eclipse.jetty.server.AcceptRateLimit._connectors:Ljava/util/List;
            invokeinterface java.util.List.iterator:()Ljava/util/Iterator;
            astore 3
            goto 7
      StackMap locals: org.eclipse.jetty.server.AcceptRateLimit org.eclipse.jetty.server.AcceptRateLimit$Rate top java.util.Iterator
      StackMap stack:
         5: aload 3
            invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
            checkcast org.eclipse.jetty.server.AbstractConnector
            astore 2 /* c */
        start local 2 // org.eclipse.jetty.server.AbstractConnector c
         6: .line 178
            aload 2 /* c */
            aload 0 /* this */
            invokevirtual org.eclipse.jetty.server.AbstractConnector.removeBean:(Ljava/lang/Object;)Z
            pop
        end local 2 // org.eclipse.jetty.server.AbstractConnector c
         7: .line 176
      StackMap locals:
      StackMap stack:
            aload 3
            invokeinterface java.util.Iterator.hasNext:()Z
            ifne 5
         8: .line 180
            aload 0 /* this */
            getfield org.eclipse.jetty.server.AcceptRateLimit._server:Lorg/eclipse/jetty/server/Server;
            ifnull 10
         9: .line 181
            aload 0 /* this */
            getfield org.eclipse.jetty.server.AcceptRateLimit._connectors:Ljava/util/List;
            invokeinterface java.util.List.clear:()V
        10: .line 182
      StackMap locals: org.eclipse.jetty.server.AcceptRateLimit org.eclipse.jetty.server.AcceptRateLimit$Rate
      StackMap stack:
            aload 0 /* this */
            iconst_0
            putfield org.eclipse.jetty.server.AcceptRateLimit._limiting:Z
        11: .line 171
            aload 1
            monitorexit
        12: goto 15
      StackMap locals:
      StackMap stack: java.lang.Throwable
        13: aload 1
            monitorexit
        14: athrow
        15: .line 184
      StackMap locals:
      StackMap stack:
            return
        end local 0 // org.eclipse.jetty.server.AcceptRateLimit this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0   16     0  this  Lorg/eclipse/jetty/server/AcceptRateLimit;
            6    7     2     c  Lorg/eclipse/jetty/server/AbstractConnector;
      Exception table:
        from    to  target  type
           1    12      13  any
          13    14      13  any
    Exceptions:
      throws java.lang.Exception

  protected void limit();
    descriptor: ()V
    flags: (0x0004) ACC_PROTECTED
    Code:
      stack=2, locals=3, args_size=1
        start local 0 // org.eclipse.jetty.server.AcceptRateLimit this
         0: .line 188
            aload 0 /* this */
            getfield org.eclipse.jetty.server.AcceptRateLimit._connectors:Ljava/util/List;
            invokeinterface java.util.List.iterator:()Ljava/util/Iterator;
            astore 2
            goto 3
      StackMap locals: org.eclipse.jetty.server.AcceptRateLimit top java.util.Iterator
      StackMap stack:
         1: aload 2
            invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
            checkcast org.eclipse.jetty.server.AbstractConnector
            astore 1 /* c */
        start local 1 // org.eclipse.jetty.server.AbstractConnector c
         2: .line 190
            aload 1 /* c */
            iconst_0
            invokevirtual org.eclipse.jetty.server.AbstractConnector.setAccepting:(Z)V
        end local 1 // org.eclipse.jetty.server.AbstractConnector c
         3: .line 188
      StackMap locals:
      StackMap stack:
            aload 2
            invokeinterface java.util.Iterator.hasNext:()Z
            ifne 1
         4: .line 192
            aload 0 /* this */
            invokevirtual org.eclipse.jetty.server.AcceptRateLimit.schedule:()V
         5: .line 193
            return
        end local 0 // org.eclipse.jetty.server.AcceptRateLimit this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    6     0  this  Lorg/eclipse/jetty/server/AcceptRateLimit;
            2    3     1     c  Lorg/eclipse/jetty/server/AbstractConnector;

  protected void unlimit();
    descriptor: ()V
    flags: (0x0004) ACC_PROTECTED
    Code:
      stack=2, locals=3, args_size=1
        start local 0 // org.eclipse.jetty.server.AcceptRateLimit this
         0: .line 197
            aload 0 /* this */
            getfield org.eclipse.jetty.server.AcceptRateLimit._connectors:Ljava/util/List;
            invokeinterface java.util.List.iterator:()Ljava/util/Iterator;
            astore 2
            goto 3
      StackMap locals: org.eclipse.jetty.server.AcceptRateLimit top java.util.Iterator
      StackMap stack:
         1: aload 2
            invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
            checkcast org.eclipse.jetty.server.AbstractConnector
            astore 1 /* c */
        start local 1 // org.eclipse.jetty.server.AbstractConnector c
         2: .line 199
            aload 1 /* c */
            iconst_1
            invokevirtual org.eclipse.jetty.server.AbstractConnector.setAccepting:(Z)V
        end local 1 // org.eclipse.jetty.server.AbstractConnector c
         3: .line 197
      StackMap locals:
      StackMap stack:
            aload 2
            invokeinterface java.util.Iterator.hasNext:()Z
            ifne 1
         4: .line 201
            return
        end local 0 // org.eclipse.jetty.server.AcceptRateLimit this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    5     0  this  Lorg/eclipse/jetty/server/AcceptRateLimit;
            2    3     1     c  Lorg/eclipse/jetty/server/AbstractConnector;

  public void onAccepting(java.nio.channels.SelectableChannel);
    descriptor: (Ljava/nio/channels/SelectableChannel;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=6, locals=4, args_size=2
        start local 0 // org.eclipse.jetty.server.AcceptRateLimit this
        start local 1 // java.nio.channels.SelectableChannel channel
         0: .line 206
            aload 0 /* this */
            getfield org.eclipse.jetty.server.AcceptRateLimit._rate:Lorg/eclipse/jetty/server/AcceptRateLimit$Rate;
            dup
            astore 2
            monitorenter
         1: .line 208
            aload 0 /* this */
            getfield org.eclipse.jetty.server.AcceptRateLimit._rate:Lorg/eclipse/jetty/server/AcceptRateLimit$Rate;
            invokevirtual org.eclipse.jetty.server.AcceptRateLimit$Rate.record:()I
            istore 3 /* rate */
        start local 3 // int rate
         2: .line 209
            getstatic org.eclipse.jetty.server.AcceptRateLimit.LOG:Lorg/eclipse/jetty/util/log/Logger;
            invokeinterface org.eclipse.jetty.util.log.Logger.isDebugEnabled:()Z
            ifeq 4
         3: .line 211
            getstatic org.eclipse.jetty.server.AcceptRateLimit.LOG:Lorg/eclipse/jetty/util/log/Logger;
            ldc "onAccepting rate {}/{} for {} {}"
            iconst_4
            anewarray java.lang.Object
            dup
            iconst_0
            iload 3 /* rate */
            invokestatic java.lang.Integer.valueOf:(I)Ljava/lang/Integer;
            aastore
            dup
            iconst_1
            aload 0 /* this */
            getfield org.eclipse.jetty.server.AcceptRateLimit._acceptRateLimit:I
            invokestatic java.lang.Integer.valueOf:(I)Ljava/lang/Integer;
            aastore
            dup
            iconst_2
            aload 0 /* this */
            getfield org.eclipse.jetty.server.AcceptRateLimit._rate:Lorg/eclipse/jetty/server/AcceptRateLimit$Rate;
            aastore
            dup
            iconst_3
            aload 1 /* channel */
            aastore
            invokeinterface org.eclipse.jetty.util.log.Logger.debug:(Ljava/lang/String;[Ljava/lang/Object;)V
         4: .line 213
      StackMap locals: org.eclipse.jetty.server.AcceptRateLimit$Rate int
      StackMap stack:
            iload 3 /* rate */
            aload 0 /* this */
            getfield org.eclipse.jetty.server.AcceptRateLimit._acceptRateLimit:I
            if_icmple 9
         5: .line 215
            aload 0 /* this */
            getfield org.eclipse.jetty.server.AcceptRateLimit._limiting:Z
            ifne 9
         6: .line 217
            aload 0 /* this */
            iconst_1
            putfield org.eclipse.jetty.server.AcceptRateLimit._limiting:Z
         7: .line 219
            getstatic org.eclipse.jetty.server.AcceptRateLimit.LOG:Lorg/eclipse/jetty/util/log/Logger;
            ldc "AcceptLimit rate exceeded {}>{} on {}"
            iconst_3
            anewarray java.lang.Object
            dup
            iconst_0
            iload 3 /* rate */
            invokestatic java.lang.Integer.valueOf:(I)Ljava/lang/Integer;
            aastore
            dup
            iconst_1
            aload 0 /* this */
            getfield org.eclipse.jetty.server.AcceptRateLimit._acceptRateLimit:I
            invokestatic java.lang.Integer.valueOf:(I)Ljava/lang/Integer;
            aastore
            dup
            iconst_2
            aload 0 /* this */
            getfield org.eclipse.jetty.server.AcceptRateLimit._connectors:Ljava/util/List;
            aastore
            invokeinterface org.eclipse.jetty.util.log.Logger.warn:(Ljava/lang/String;[Ljava/lang/Object;)V
         8: .line 220
            aload 0 /* this */
            invokevirtual org.eclipse.jetty.server.AcceptRateLimit.limit:()V
        end local 3 // int rate
         9: .line 206
      StackMap locals:
      StackMap stack:
            aload 2
            monitorexit
        10: goto 13
      StackMap locals:
      StackMap stack: java.lang.Throwable
        11: aload 2
            monitorexit
        12: athrow
        13: .line 224
      StackMap locals:
      StackMap stack:
            return
        end local 1 // java.nio.channels.SelectableChannel channel
        end local 0 // org.eclipse.jetty.server.AcceptRateLimit this
      LocalVariableTable:
        Start  End  Slot     Name  Signature
            0   14     0     this  Lorg/eclipse/jetty/server/AcceptRateLimit;
            0   14     1  channel  Ljava/nio/channels/SelectableChannel;
            2    9     3     rate  I
      Exception table:
        from    to  target  type
           1    10      11  any
          11    12      11  any
    MethodParameters:
         Name  Flags
      channel  

  private void schedule();
    descriptor: ()V
    flags: (0x0002) ACC_PRIVATE
    Code:
      stack=7, locals=7, args_size=1
        start local 0 // org.eclipse.jetty.server.AcceptRateLimit this
         0: .line 228
            aload 0 /* this */
            getfield org.eclipse.jetty.server.AcceptRateLimit._rate:Lorg/eclipse/jetty/server/AcceptRateLimit$Rate;
            getstatic java.util.concurrent.TimeUnit.MILLISECONDS:Ljava/util/concurrent/TimeUnit;
            invokevirtual org.eclipse.jetty.server.AcceptRateLimit$Rate.getOldest:(Ljava/util/concurrent/TimeUnit;)J
            lstore 1 /* oldest */
        start local 1 // long oldest
         1: .line 229
            getstatic java.util.concurrent.TimeUnit.MILLISECONDS:Ljava/util/concurrent/TimeUnit;
            aload 0 /* this */
            getfield org.eclipse.jetty.server.AcceptRateLimit._rate:Lorg/eclipse/jetty/server/AcceptRateLimit$Rate;
            invokevirtual org.eclipse.jetty.server.AcceptRateLimit$Rate.getPeriod:()J
            aload 0 /* this */
            getfield org.eclipse.jetty.server.AcceptRateLimit._rate:Lorg/eclipse/jetty/server/AcceptRateLimit$Rate;
            invokevirtual org.eclipse.jetty.server.AcceptRateLimit$Rate.getUnits:()Ljava/util/concurrent/TimeUnit;
            invokevirtual java.util.concurrent.TimeUnit.convert:(JLjava/util/concurrent/TimeUnit;)J
            lstore 3 /* period */
        start local 3 // long period
         2: .line 230
            lload 3 /* period */
            lload 1 /* oldest */
            lconst_0
            lcmp
            ifle 3
            lload 1 /* oldest */
            goto 4
      StackMap locals: org.eclipse.jetty.server.AcceptRateLimit long long
      StackMap stack: long
         3: lconst_0
      StackMap locals: org.eclipse.jetty.server.AcceptRateLimit long long
      StackMap stack: long long
         4: lsub
            lstore 5 /* delay */
        start local 5 // long delay
         5: .line 231
            lload 5 /* delay */
            lconst_0
            lcmp
            ifge 7
         6: .line 232
            lconst_0
            lstore 5 /* delay */
         7: .line 233
      StackMap locals: long
      StackMap stack:
            getstatic org.eclipse.jetty.server.AcceptRateLimit.LOG:Lorg/eclipse/jetty/util/log/Logger;
            invokeinterface org.eclipse.jetty.util.log.Logger.isDebugEnabled:()Z
            ifeq 9
         8: .line 234
            getstatic org.eclipse.jetty.server.AcceptRateLimit.LOG:Lorg/eclipse/jetty/util/log/Logger;
            ldc "schedule {} {}"
            iconst_2
            anewarray java.lang.Object
            dup
            iconst_0
            lload 5 /* delay */
            invokestatic java.lang.Long.valueOf:(J)Ljava/lang/Long;
            aastore
            dup
            iconst_1
            getstatic java.util.concurrent.TimeUnit.MILLISECONDS:Ljava/util/concurrent/TimeUnit;
            aastore
            invokeinterface org.eclipse.jetty.util.log.Logger.debug:(Ljava/lang/String;[Ljava/lang/Object;)V
         9: .line 235
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            aload 0 /* this */
            getfield org.eclipse.jetty.server.AcceptRateLimit._connectors:Ljava/util/List;
            iconst_0
            invokeinterface java.util.List.get:(I)Ljava/lang/Object;
            checkcast org.eclipse.jetty.server.AbstractConnector
            invokevirtual org.eclipse.jetty.server.AbstractConnector.getScheduler:()Lorg/eclipse/jetty/util/thread/Scheduler;
            aload 0 /* this */
            lload 5 /* delay */
            getstatic java.util.concurrent.TimeUnit.MILLISECONDS:Ljava/util/concurrent/TimeUnit;
            invokeinterface org.eclipse.jetty.util.thread.Scheduler.schedule:(Ljava/lang/Runnable;JLjava/util/concurrent/TimeUnit;)Lorg/eclipse/jetty/util/thread/Scheduler$Task;
            putfield org.eclipse.jetty.server.AcceptRateLimit._task:Lorg/eclipse/jetty/util/thread/Scheduler$Task;
        10: .line 236
            return
        end local 5 // long delay
        end local 3 // long period
        end local 1 // long oldest
        end local 0 // org.eclipse.jetty.server.AcceptRateLimit this
      LocalVariableTable:
        Start  End  Slot    Name  Signature
            0   11     0    this  Lorg/eclipse/jetty/server/AcceptRateLimit;
            1   11     1  oldest  J
            2   11     3  period  J
            5   11     5   delay  J

  public void run();
    descriptor: ()V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=6, locals=3, args_size=1
        start local 0 // org.eclipse.jetty.server.AcceptRateLimit this
         0: .line 241
            aload 0 /* this */
            getfield org.eclipse.jetty.server.AcceptRateLimit._rate:Lorg/eclipse/jetty/server/AcceptRateLimit$Rate;
            dup
            astore 1
            monitorenter
         1: .line 243
            aload 0 /* this */
            aconst_null
            putfield org.eclipse.jetty.server.AcceptRateLimit._task:Lorg/eclipse/jetty/util/thread/Scheduler$Task;
         2: .line 244
            aload 0 /* this */
            invokevirtual org.eclipse.jetty.server.AcceptRateLimit.isRunning:()Z
            ifne 5
         3: .line 245
            aload 1
            monitorexit
         4: return
         5: .line 246
      StackMap locals: org.eclipse.jetty.server.AcceptRateLimit$Rate
      StackMap stack:
            aload 0 /* this */
            getfield org.eclipse.jetty.server.AcceptRateLimit._rate:Lorg/eclipse/jetty/server/AcceptRateLimit$Rate;
            invokevirtual org.eclipse.jetty.server.AcceptRateLimit$Rate.getRate:()I
            istore 2 /* rate */
        start local 2 // int rate
         6: .line 247
            iload 2 /* rate */
            aload 0 /* this */
            getfield org.eclipse.jetty.server.AcceptRateLimit._acceptRateLimit:I
            if_icmple 10
         7: .line 249
            aload 0 /* this */
            invokevirtual org.eclipse.jetty.server.AcceptRateLimit.schedule:()V
         8: .line 250
            aload 1
            monitorexit
         9: return
        10: .line 252
      StackMap locals: int
      StackMap stack:
            aload 0 /* this */
            getfield org.eclipse.jetty.server.AcceptRateLimit._limiting:Z
            ifeq 14
        11: .line 254
            aload 0 /* this */
            iconst_0
            putfield org.eclipse.jetty.server.AcceptRateLimit._limiting:Z
        12: .line 255
            getstatic org.eclipse.jetty.server.AcceptRateLimit.LOG:Lorg/eclipse/jetty/util/log/Logger;
            ldc "AcceptLimit rate OK {}<={} on {}"
            iconst_3
            anewarray java.lang.Object
            dup
            iconst_0
            iload 2 /* rate */
            invokestatic java.lang.Integer.valueOf:(I)Ljava/lang/Integer;
            aastore
            dup
            iconst_1
            aload 0 /* this */
            getfield org.eclipse.jetty.server.AcceptRateLimit._acceptRateLimit:I
            invokestatic java.lang.Integer.valueOf:(I)Ljava/lang/Integer;
            aastore
            dup
            iconst_2
            aload 0 /* this */
            getfield org.eclipse.jetty.server.AcceptRateLimit._connectors:Ljava/util/List;
            aastore
            invokeinterface org.eclipse.jetty.util.log.Logger.warn:(Ljava/lang/String;[Ljava/lang/Object;)V
        13: .line 256
            aload 0 /* this */
            invokevirtual org.eclipse.jetty.server.AcceptRateLimit.unlimit:()V
        end local 2 // int rate
        14: .line 241
      StackMap locals:
      StackMap stack:
            aload 1
            monitorexit
        15: goto 18
      StackMap locals:
      StackMap stack: java.lang.Throwable
        16: aload 1
            monitorexit
        17: athrow
        18: .line 259
      StackMap locals:
      StackMap stack:
            return
        end local 0 // org.eclipse.jetty.server.AcceptRateLimit this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0   19     0  this  Lorg/eclipse/jetty/server/AcceptRateLimit;
            6   14     2  rate  I
      Exception table:
        from    to  target  type
           1     4      16  any
           5     9      16  any
          10    15      16  any
          16    17      16  any
}
SourceFile: "AcceptRateLimit.java"
NestMembers:
  org.eclipse.jetty.server.AcceptRateLimit$Rate
InnerClasses:
  public abstract AcceptListener = org.eclipse.jetty.io.SelectorManager$AcceptListener of org.eclipse.jetty.io.SelectorManager
  private final Rate = org.eclipse.jetty.server.AcceptRateLimit$Rate of org.eclipse.jetty.server.AcceptRateLimit
  public abstract Task = org.eclipse.jetty.util.thread.Scheduler$Task of org.eclipse.jetty.util.thread.Scheduler
    RuntimeVisibleAnnotations: 
      org.eclipse.jetty.util.annotation.ManagedObject()
/

org.eclipse.jetty/ jetty-server/ 10.0.0-alpha0/ org/eclipse/jetty/server/AcceptRateLimit.class
