class sun.net.www.http.KeepAliveStreamCleaner extends java.util.LinkedList<sun.net.www.http.KeepAliveCleanerEntry> implements java.lang.Runnable
  minor version: 0
  major version: 59
  flags: flags: (0x0020) ACC_SUPER
  this_class: sun.net.www.http.KeepAliveStreamCleaner
  super_class: java.util.LinkedList
{
  protected static int MAX_DATA_REMAINING;
    descriptor: I
    flags: (0x000c) ACC_PROTECTED, ACC_STATIC

  protected static int MAX_CAPACITY;
    descriptor: I
    flags: (0x000c) ACC_PROTECTED, ACC_STATIC

  protected static final int TIMEOUT;
    descriptor: I
    flags: (0x001c) ACC_PROTECTED, ACC_STATIC, ACC_FINAL
    ConstantValue: 5000

  private static final int MAX_RETRIES;
    descriptor: I
    flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL
    ConstantValue: 5

  private final java.util.concurrent.locks.ReentrantLock queueLock;
    descriptor: Ljava/util/concurrent/locks/ReentrantLock;
    flags: (0x0012) ACC_PRIVATE, ACC_FINAL

  private final java.util.concurrent.locks.Condition waiter;
    descriptor: Ljava/util/concurrent/locks/Condition;
    flags: (0x0012) ACC_PRIVATE, ACC_FINAL

  static void <clinit>();
    descriptor: ()V
    flags: (0x0008) ACC_STATIC
    Code:
      stack=2, locals=2, args_size=0
         0: .line 54
            sipush 512
            putstatic sun.net.www.http.KeepAliveStreamCleaner.MAX_DATA_REMAINING:I
         1: .line 57
            bipush 10
            putstatic sun.net.www.http.KeepAliveStreamCleaner.MAX_CAPACITY:I
         2: .line 68
            new sun.net.www.http.KeepAliveStreamCleaner$1
            dup
            invokespecial sun.net.www.http.KeepAliveStreamCleaner$1.<init>:()V
         3: .line 67
            invokestatic java.security.AccessController.doPrivileged:(Ljava/security/PrivilegedAction;)Ljava/lang/Object;
            checkcast java.lang.Integer
         4: .line 71
            invokevirtual java.lang.Integer.intValue:()I
            sipush 1024
         5: .line 67
            imul
            istore 0 /* maxData */
        start local 0 // int maxData
         6: .line 72
            iload 0 /* maxData */
            putstatic sun.net.www.http.KeepAliveStreamCleaner.MAX_DATA_REMAINING:I
         7: .line 76
            new sun.net.www.http.KeepAliveStreamCleaner$2
            dup
            invokespecial sun.net.www.http.KeepAliveStreamCleaner$2.<init>:()V
         8: .line 75
            invokestatic java.security.AccessController.doPrivileged:(Ljava/security/PrivilegedAction;)Ljava/lang/Object;
            checkcast java.lang.Integer
         9: .line 79
            invokevirtual java.lang.Integer.intValue:()I
        10: .line 75
            istore 1 /* maxCapacity */
        start local 1 // int maxCapacity
        11: .line 80
            iload 1 /* maxCapacity */
            putstatic sun.net.www.http.KeepAliveStreamCleaner.MAX_CAPACITY:I
        end local 1 // int maxCapacity
        end local 0 // int maxData
        12: .line 82
            return
      LocalVariableTable:
        Start  End  Slot         Name  Signature
            6   12     0      maxData  I
           11   12     1  maxCapacity  I

  void <init>();
    descriptor: ()V
    flags: (0x0000) 
    Code:
      stack=3, locals=1, args_size=1
        start local 0 // sun.net.www.http.KeepAliveStreamCleaner this
         0: .line 49
            aload 0 /* this */
            invokespecial java.util.LinkedList.<init>:()V
         1: .line 84
            aload 0 /* this */
            new java.util.concurrent.locks.ReentrantLock
            dup
            invokespecial java.util.concurrent.locks.ReentrantLock.<init>:()V
            putfield sun.net.www.http.KeepAliveStreamCleaner.queueLock:Ljava/util/concurrent/locks/ReentrantLock;
         2: .line 85
            aload 0 /* this */
            aload 0 /* this */
            getfield sun.net.www.http.KeepAliveStreamCleaner.queueLock:Ljava/util/concurrent/locks/ReentrantLock;
            invokevirtual java.util.concurrent.locks.ReentrantLock.newCondition:()Ljava/util/concurrent/locks/Condition;
            putfield sun.net.www.http.KeepAliveStreamCleaner.waiter:Ljava/util/concurrent/locks/Condition;
         3: .line 49
            return
        end local 0 // sun.net.www.http.KeepAliveStreamCleaner this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    4     0  this  Lsun/net/www/http/KeepAliveStreamCleaner;

  final void signalAll();
    descriptor: ()V
    flags: (0x0010) ACC_FINAL
    Code:
      stack=1, locals=1, args_size=1
        start local 0 // sun.net.www.http.KeepAliveStreamCleaner this
         0: .line 88
            aload 0 /* this */
            getfield sun.net.www.http.KeepAliveStreamCleaner.waiter:Ljava/util/concurrent/locks/Condition;
            invokeinterface java.util.concurrent.locks.Condition.signalAll:()V
         1: .line 89
            return
        end local 0 // sun.net.www.http.KeepAliveStreamCleaner this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    2     0  this  Lsun/net/www/http/KeepAliveStreamCleaner;

  final void lock();
    descriptor: ()V
    flags: (0x0010) ACC_FINAL
    Code:
      stack=1, locals=1, args_size=1
        start local 0 // sun.net.www.http.KeepAliveStreamCleaner this
         0: .line 92
            aload 0 /* this */
            getfield sun.net.www.http.KeepAliveStreamCleaner.queueLock:Ljava/util/concurrent/locks/ReentrantLock;
            invokevirtual java.util.concurrent.locks.ReentrantLock.lock:()V
         1: .line 93
            return
        end local 0 // sun.net.www.http.KeepAliveStreamCleaner this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    2     0  this  Lsun/net/www/http/KeepAliveStreamCleaner;

  final void unlock();
    descriptor: ()V
    flags: (0x0010) ACC_FINAL
    Code:
      stack=1, locals=1, args_size=1
        start local 0 // sun.net.www.http.KeepAliveStreamCleaner this
         0: .line 96
            aload 0 /* this */
            getfield sun.net.www.http.KeepAliveStreamCleaner.queueLock:Ljava/util/concurrent/locks/ReentrantLock;
            invokevirtual java.util.concurrent.locks.ReentrantLock.unlock:()V
         1: .line 97
            return
        end local 0 // sun.net.www.http.KeepAliveStreamCleaner this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    2     0  this  Lsun/net/www/http/KeepAliveStreamCleaner;

  public boolean offer(sun.net.www.http.KeepAliveCleanerEntry);
    descriptor: (Lsun/net/www/http/KeepAliveCleanerEntry;)Z
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=2, locals=2, args_size=2
        start local 0 // sun.net.www.http.KeepAliveStreamCleaner this
        start local 1 // sun.net.www.http.KeepAliveCleanerEntry e
         0: .line 101
            aload 0 /* this */
            invokevirtual sun.net.www.http.KeepAliveStreamCleaner.size:()I
            getstatic sun.net.www.http.KeepAliveStreamCleaner.MAX_CAPACITY:I
            if_icmplt 2
         1: .line 102
            iconst_0
            ireturn
         2: .line 104
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            aload 1 /* e */
            invokespecial java.util.LinkedList.offer:(Ljava/lang/Object;)Z
            ireturn
        end local 1 // sun.net.www.http.KeepAliveCleanerEntry e
        end local 0 // sun.net.www.http.KeepAliveStreamCleaner this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    3     0  this  Lsun/net/www/http/KeepAliveStreamCleaner;
            0    3     1     e  Lsun/net/www/http/KeepAliveCleanerEntry;
    MethodParameters:
      Name  Flags
      e     

  public void run();
    descriptor: ()V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=4, locals=12, args_size=1
        start local 0 // sun.net.www.http.KeepAliveStreamCleaner this
         0: .line 110
            aconst_null
            astore 1 /* kace */
        start local 1 // sun.net.www.http.KeepAliveCleanerEntry kace
         1: .line 114
      StackMap locals: sun.net.www.http.KeepAliveCleanerEntry
      StackMap stack:
            aload 0 /* this */
            invokevirtual sun.net.www.http.KeepAliveStreamCleaner.lock:()V
         2: .line 116
            invokestatic java.lang.System.currentTimeMillis:()J
            lstore 2 /* before */
        start local 2 // long before
         3: .line 117
            ldc 5000
            lstore 4 /* timeout */
        start local 4 // long timeout
         4: .line 118
            goto 13
         5: .line 119
      StackMap locals: long long
      StackMap stack:
            aload 0 /* this */
            getfield sun.net.www.http.KeepAliveStreamCleaner.waiter:Ljava/util/concurrent/locks/Condition;
            lload 4 /* timeout */
            getstatic java.util.concurrent.TimeUnit.MILLISECONDS:Ljava/util/concurrent/TimeUnit;
            invokeinterface java.util.concurrent.locks.Condition.await:(JLjava/util/concurrent/TimeUnit;)Z
            pop
         6: .line 121
            invokestatic java.lang.System.currentTimeMillis:()J
            lstore 6 /* after */
        start local 6 // long after
         7: .line 122
            lload 6 /* after */
            lload 2 /* before */
            lsub
            lstore 8 /* elapsed */
        start local 8 // long elapsed
         8: .line 123
            lload 8 /* elapsed */
            lload 4 /* timeout */
            lcmp
            ifle 11
         9: .line 125
            aload 0 /* this */
            invokevirtual sun.net.www.http.KeepAliveStreamCleaner.poll:()Ljava/lang/Object;
            checkcast sun.net.www.http.KeepAliveCleanerEntry
            astore 1 /* kace */
        10: .line 126
            goto 18
        11: .line 128
      StackMap locals: long long
      StackMap stack:
            lload 6 /* after */
            lstore 2 /* before */
        12: .line 129
            lload 4 /* timeout */
            lload 8 /* elapsed */
            lsub
            lstore 4 /* timeout */
        end local 8 // long elapsed
        end local 6 // long after
        13: .line 118
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            invokevirtual sun.net.www.http.KeepAliveStreamCleaner.poll:()Ljava/lang/Object;
            checkcast sun.net.www.http.KeepAliveCleanerEntry
            dup
            astore 1 /* kace */
            ifnull 5
        end local 4 // long timeout
        end local 2 // long before
        14: .line 131
            goto 18
      StackMap locals: sun.net.www.http.KeepAliveStreamCleaner sun.net.www.http.KeepAliveCleanerEntry
      StackMap stack: java.lang.Throwable
        15: astore 10
        16: .line 132
            aload 0 /* this */
            invokevirtual sun.net.www.http.KeepAliveStreamCleaner.unlock:()V
        17: .line 133
            aload 10
            athrow
        18: .line 132
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            invokevirtual sun.net.www.http.KeepAliveStreamCleaner.unlock:()V
        19: .line 135
            aload 1 /* kace */
            ifnonnull 21
        20: .line 136
            goto 60
        21: .line 138
      StackMap locals:
      StackMap stack:
            aload 1 /* kace */
            invokevirtual sun.net.www.http.KeepAliveCleanerEntry.getKeepAliveStream:()Lsun/net/www/http/KeepAliveStream;
            astore 2 /* kas */
        start local 2 // sun.net.www.http.KeepAliveStream kas
        22: .line 140
            aload 2 /* kas */
            ifnull 59
        23: .line 141
            aload 2 /* kas */
            invokevirtual sun.net.www.http.KeepAliveStream.lock:()V
        24: .line 143
            aload 1 /* kace */
            invokevirtual sun.net.www.http.KeepAliveCleanerEntry.getHttpClient:()Lsun/net/www/http/HttpClient;
            astore 3 /* hc */
        start local 3 // sun.net.www.http.HttpClient hc
        25: .line 145
            aload 3 /* hc */
            ifnull 51
            aload 3 /* hc */
            invokevirtual sun.net.www.http.HttpClient.isInKeepAliveCache:()Z
            ifne 51
        26: .line 146
            aload 3 /* hc */
            invokevirtual sun.net.www.http.HttpClient.getReadTimeout:()I
            istore 4 /* oldTimeout */
        start local 4 // int oldTimeout
        27: .line 147
            aload 3 /* hc */
            sipush 5000
            invokevirtual sun.net.www.http.HttpClient.setReadTimeout:(I)V
        28: .line 148
            aload 2 /* kas */
            invokevirtual sun.net.www.http.KeepAliveStream.remainingToRead:()J
            lstore 5 /* remainingToRead */
        start local 5 // long remainingToRead
        29: .line 149
            lload 5 /* remainingToRead */
            lconst_0
            lcmp
            ifle 39
        30: .line 150
            lconst_0
            lstore 7 /* n */
        start local 7 // long n
        31: .line 151
            iconst_0
            istore 9 /* retries */
        start local 9 // int retries
        32: .line 152
            goto 37
        33: .line 153
      StackMap locals: sun.net.www.http.KeepAliveStreamCleaner sun.net.www.http.KeepAliveCleanerEntry sun.net.www.http.KeepAliveStream sun.net.www.http.HttpClient int long long int
      StackMap stack:
            lload 5 /* remainingToRead */
            lload 7 /* n */
            lsub
            lstore 5 /* remainingToRead */
        34: .line 154
            aload 2 /* kas */
            lload 5 /* remainingToRead */
            invokevirtual sun.net.www.http.KeepAliveStream.skip:(J)J
            lstore 7 /* n */
        35: .line 155
            lload 7 /* n */
            lconst_0
            lcmp
            ifne 37
        36: .line 156
            iinc 9 /* retries */ 1
        37: .line 152
      StackMap locals:
      StackMap stack:
            lload 7 /* n */
            lload 5 /* remainingToRead */
            lcmp
            ifge 38
            iload 9 /* retries */
            iconst_5
            if_icmplt 33
        38: .line 158
      StackMap locals:
      StackMap stack:
            lload 5 /* remainingToRead */
            lload 7 /* n */
            lsub
            lstore 5 /* remainingToRead */
        end local 9 // int retries
        end local 7 // long n
        39: .line 160
      StackMap locals:
      StackMap stack:
            lload 5 /* remainingToRead */
            lconst_0
            lcmp
            ifne 43
        40: .line 161
            aload 3 /* hc */
            iload 4 /* oldTimeout */
            invokevirtual sun.net.www.http.HttpClient.setReadTimeout:(I)V
        41: .line 162
            aload 3 /* hc */
            invokevirtual sun.net.www.http.HttpClient.finished:()V
        42: .line 163
            goto 51
        43: .line 164
      StackMap locals:
      StackMap stack:
            aload 3 /* hc */
            invokevirtual sun.net.www.http.HttpClient.closeServer:()V
        end local 5 // long remainingToRead
        end local 4 // int oldTimeout
        44: .line 166
            goto 51
      StackMap locals: sun.net.www.http.KeepAliveStreamCleaner sun.net.www.http.KeepAliveCleanerEntry sun.net.www.http.KeepAliveStream sun.net.www.http.HttpClient
      StackMap stack: java.io.IOException
        45: pop
        46: .line 167
            aload 3 /* hc */
            invokevirtual sun.net.www.http.HttpClient.closeServer:()V
        47: .line 169
            aload 2 /* kas */
            invokevirtual sun.net.www.http.KeepAliveStream.setClosed:()V
            goto 56
        48: .line 168
      StackMap locals:
      StackMap stack: java.lang.Throwable
            astore 10
        49: .line 169
            aload 2 /* kas */
            invokevirtual sun.net.www.http.KeepAliveStream.setClosed:()V
        50: .line 170
            aload 10
            athrow
        51: .line 169
      StackMap locals:
      StackMap stack:
            aload 2 /* kas */
            invokevirtual sun.net.www.http.KeepAliveStream.setClosed:()V
        end local 3 // sun.net.www.http.HttpClient hc
        52: .line 171
            goto 56
      StackMap locals: sun.net.www.http.KeepAliveStreamCleaner sun.net.www.http.KeepAliveCleanerEntry sun.net.www.http.KeepAliveStream
      StackMap stack: java.lang.Throwable
        53: astore 11
        54: .line 172
            aload 2 /* kas */
            invokevirtual sun.net.www.http.KeepAliveStream.unlock:()V
        55: .line 173
            aload 11
            athrow
        56: .line 172
      StackMap locals:
      StackMap stack:
            aload 2 /* kas */
            invokevirtual sun.net.www.http.KeepAliveStream.unlock:()V
        end local 2 // sun.net.www.http.KeepAliveStream kas
        57: .line 175
            goto 59
      StackMap locals: sun.net.www.http.KeepAliveStreamCleaner sun.net.www.http.KeepAliveCleanerEntry
      StackMap stack: java.lang.InterruptedException
        58: pop
        59: .line 176
      StackMap locals:
      StackMap stack:
            aload 1 /* kace */
            ifnonnull 1
        60: .line 177
      StackMap locals:
      StackMap stack:
            return
        end local 1 // sun.net.www.http.KeepAliveCleanerEntry kace
        end local 0 // sun.net.www.http.KeepAliveStreamCleaner this
      LocalVariableTable:
        Start  End  Slot             Name  Signature
            0   61     0             this  Lsun/net/www/http/KeepAliveStreamCleaner;
            1   61     1             kace  Lsun/net/www/http/KeepAliveCleanerEntry;
            3   14     2           before  J
            4   14     4          timeout  J
            7   13     6            after  J
            8   13     8          elapsed  J
           22   57     2              kas  Lsun/net/www/http/KeepAliveStream;
           25   52     3               hc  Lsun/net/www/http/HttpClient;
           27   44     4       oldTimeout  I
           29   44     5  remainingToRead  J
           31   39     7                n  J
           32   39     9          retries  I
      Exception table:
        from    to  target  type
           2    15      15  any
          25    44      45  Class java.io.IOException
          25    47      48  any
          24    53      53  any
           1    20      58  Class java.lang.InterruptedException
          21    57      58  Class java.lang.InterruptedException

  public boolean offer(java.lang.Object);
    descriptor: (Ljava/lang/Object;)Z
    flags: (0x1041) ACC_PUBLIC, ACC_BRIDGE, ACC_SYNTHETIC
    Code:
      stack=2, locals=2, args_size=2
         0: .line 1
            aload 0
            aload 1
            checkcast sun.net.www.http.KeepAliveCleanerEntry
            invokevirtual sun.net.www.http.KeepAliveStreamCleaner.offer:(Lsun/net/www/http/KeepAliveCleanerEntry;)Z
            ireturn
      LocalVariableTable:
        Start  End  Slot  Name  Signature
}
Signature: Ljava/util/LinkedList<Lsun/net/www/http/KeepAliveCleanerEntry;>;Ljava/lang/Runnable;
SourceFile: "KeepAliveStreamCleaner.java"
NestMembers:
  sun.net.www.http.KeepAliveStreamCleaner$1  sun.net.www.http.KeepAliveStreamCleaner$2
InnerClasses:
  sun.net.www.http.KeepAliveStreamCleaner$1
  sun.net.www.http.KeepAliveStreamCleaner$2