public class sun.net.www.http.KeepAliveStream extends sun.net.www.MeteredStream implements sun.net.www.http.Hurryable
minor version: 0
major version: 59
flags: flags: (0x0021) ACC_PUBLIC, ACC_SUPER
this_class: sun.net.www.http.KeepAliveStream
super_class: sun.net.www.MeteredStream
{
sun.net.www.http.HttpClient hc;
descriptor: Lsun/net/www/http/HttpClient;
flags: (0x0000)
boolean hurried;
descriptor: Z
flags: (0x0000)
protected volatile boolean queuedForCleanup;
descriptor: Z
flags: (0x0044) ACC_PROTECTED, ACC_VOLATILE
private static final sun.net.www.http.KeepAliveStreamCleaner queue;
descriptor: Lsun/net/www/http/KeepAliveStreamCleaner;
flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL
private static java.lang.Thread cleanerThread;
descriptor: Ljava/lang/Thread;
flags: (0x000a) ACC_PRIVATE, ACC_STATIC
static final boolean $assertionsDisabled;
descriptor: Z
flags: (0x1018) ACC_STATIC, ACC_FINAL, ACC_SYNTHETIC
static void <clinit>();
descriptor: ()V
flags: (0x0008) ACC_STATIC
Code:
stack=2, locals=0, args_size=0
0: ldc Lsun/net/www/http/KeepAliveStream;
invokevirtual java.lang.Class.desiredAssertionStatus:()Z
ifne 1
iconst_1
goto 2
StackMap locals:
StackMap stack:
1: iconst_0
StackMap locals:
StackMap stack: int
2: putstatic sun.net.www.http.KeepAliveStream.$assertionsDisabled:Z
3: new sun.net.www.http.KeepAliveStreamCleaner
dup
invokespecial sun.net.www.http.KeepAliveStreamCleaner.<init>:()V
putstatic sun.net.www.http.KeepAliveStream.queue:Lsun/net/www/http/KeepAliveStreamCleaner;
4: return
LocalVariableTable:
Start End Slot Name Signature
public void <init>(java.io.InputStream, sun.net.ProgressSource, long, sun.net.www.http.HttpClient);
descriptor: (Ljava/io/InputStream;Lsun/net/ProgressSource;JLsun/net/www/http/HttpClient;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=5, locals=6, args_size=5
start local 0 start local 1 start local 2 start local 3 start local 5 0: aload 0
aload 1
aload 2
lload 3
invokespecial sun.net.www.MeteredStream.<init>:(Ljava/io/InputStream;Lsun/net/ProgressSource;J)V
1: aload 0
iconst_0
putfield sun.net.www.http.KeepAliveStream.queuedForCleanup:Z
2: aload 0
aload 5
putfield sun.net.www.http.KeepAliveStream.hc:Lsun/net/www/http/HttpClient;
3: return
end local 5 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 this Lsun/net/www/http/KeepAliveStream;
0 4 1 is Ljava/io/InputStream;
0 4 2 pi Lsun/net/ProgressSource;
0 4 3 expected J
0 4 5 hc Lsun/net/www/http/HttpClient;
MethodParameters:
Name Flags
is
pi
expected
hc
public void close();
descriptor: ()V
flags: (0x0001) ACC_PUBLIC
Code:
stack=5, locals=5, args_size=1
start local 0 0: aload 0
getfield sun.net.www.http.KeepAliveStream.queuedForCleanup:Z
ifeq 1
return
1: StackMap locals:
StackMap stack:
aload 0
invokevirtual sun.net.www.http.KeepAliveStream.lock:()V
2: aload 0
getfield sun.net.www.http.KeepAliveStream.closed:Z
ifne 3
aload 0
getfield sun.net.www.http.KeepAliveStream.queuedForCleanup:Z
ifeq 5
3: StackMap locals:
StackMap stack:
aload 0
invokevirtual sun.net.www.http.KeepAliveStream.unlock:()V
4: return
5: StackMap locals:
StackMap stack:
aload 0
getfield sun.net.www.http.KeepAliveStream.expected:J
aload 0
getfield sun.net.www.http.KeepAliveStream.count:J
lcmp
ifle 16
6: aload 0
getfield sun.net.www.http.KeepAliveStream.expected:J
aload 0
getfield sun.net.www.http.KeepAliveStream.count:J
lsub
lstore 1
start local 1 7: lload 1
aload 0
invokevirtual sun.net.www.http.KeepAliveStream.available:()I
i2l
lcmp
ifgt 12
8: StackMap locals: long
StackMap stack:
aload 0
getfield sun.net.www.http.KeepAliveStream.expected:J
aload 0
getfield sun.net.www.http.KeepAliveStream.count:J
lsub
dup2
lstore 1
lconst_0
lcmp
ifle 16
9: aload 0
lload 1
aload 0
invokevirtual sun.net.www.http.KeepAliveStream.available:()I
i2l
invokestatic java.lang.Math.min:(JJ)J
invokevirtual sun.net.www.http.KeepAliveStream.skip:(J)J
lconst_0
10: lcmp
ifgt 8
11: goto 16
StackMap locals:
StackMap stack:
12: aload 0
getfield sun.net.www.http.KeepAliveStream.expected:J
getstatic sun.net.www.http.KeepAliveStreamCleaner.MAX_DATA_REMAINING:I
i2l
lcmp
ifgt 15
aload 0
getfield sun.net.www.http.KeepAliveStream.hurried:Z
ifne 15
13: new sun.net.www.http.KeepAliveCleanerEntry
dup
aload 0
aload 0
getfield sun.net.www.http.KeepAliveStream.hc:Lsun/net/www/http/HttpClient;
invokespecial sun.net.www.http.KeepAliveCleanerEntry.<init>:(Lsun/net/www/http/KeepAliveStream;Lsun/net/www/http/HttpClient;)V
invokestatic sun.net.www.http.KeepAliveStream.queueForCleanup:(Lsun/net/www/http/KeepAliveCleanerEntry;)V
14: goto 16
15: StackMap locals:
StackMap stack:
aload 0
getfield sun.net.www.http.KeepAliveStream.hc:Lsun/net/www/http/HttpClient;
invokevirtual sun.net.www.http.HttpClient.closeServer:()V
end local 1 16: StackMap locals:
StackMap stack:
aload 0
getfield sun.net.www.http.KeepAliveStream.closed:Z
ifne 27
aload 0
getfield sun.net.www.http.KeepAliveStream.hurried:Z
ifne 27
aload 0
getfield sun.net.www.http.KeepAliveStream.queuedForCleanup:Z
ifne 27
17: aload 0
getfield sun.net.www.http.KeepAliveStream.hc:Lsun/net/www/http/HttpClient;
invokevirtual sun.net.www.http.HttpClient.finished:()V
18: goto 27
StackMap locals:
StackMap stack: java.lang.Throwable
19: astore 3
20: aload 0
getfield sun.net.www.http.KeepAliveStream.pi:Lsun/net/ProgressSource;
ifnull 22
21: aload 0
getfield sun.net.www.http.KeepAliveStream.pi:Lsun/net/ProgressSource;
invokevirtual sun.net.ProgressSource.finishTracking:()V
22: StackMap locals: sun.net.www.http.KeepAliveStream top top java.lang.Throwable
StackMap stack:
aload 0
getfield sun.net.www.http.KeepAliveStream.queuedForCleanup:Z
ifne 26
23: aload 0
aconst_null
putfield sun.net.www.http.KeepAliveStream.in:Ljava/io/InputStream;
24: aload 0
aconst_null
putfield sun.net.www.http.KeepAliveStream.hc:Lsun/net/www/http/HttpClient;
25: aload 0
iconst_1
putfield sun.net.www.http.KeepAliveStream.closed:Z
26: StackMap locals:
StackMap stack:
aload 3
athrow
27: StackMap locals: sun.net.www.http.KeepAliveStream
StackMap stack:
aload 0
getfield sun.net.www.http.KeepAliveStream.pi:Lsun/net/ProgressSource;
ifnull 29
28: aload 0
getfield sun.net.www.http.KeepAliveStream.pi:Lsun/net/ProgressSource;
invokevirtual sun.net.ProgressSource.finishTracking:()V
29: StackMap locals:
StackMap stack:
aload 0
getfield sun.net.www.http.KeepAliveStream.queuedForCleanup:Z
ifne 37
30: aload 0
aconst_null
putfield sun.net.www.http.KeepAliveStream.in:Ljava/io/InputStream;
31: aload 0
aconst_null
putfield sun.net.www.http.KeepAliveStream.hc:Lsun/net/www/http/HttpClient;
32: aload 0
iconst_1
putfield sun.net.www.http.KeepAliveStream.closed:Z
33: goto 37
StackMap locals:
StackMap stack: java.lang.Throwable
34: astore 4
35: aload 0
invokevirtual sun.net.www.http.KeepAliveStream.unlock:()V
36: aload 4
athrow
37: StackMap locals:
StackMap stack:
aload 0
invokevirtual sun.net.www.http.KeepAliveStream.unlock:()V
38: return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 39 0 this Lsun/net/www/http/KeepAliveStream;
7 16 1 nskip J
Exception table:
from to target type
5 19 19 any
2 3 34 any
5 34 34 any
Exceptions:
throws java.io.IOException
public boolean markSupported();
descriptor: ()Z
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: iconst_0
ireturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lsun/net/www/http/KeepAliveStream;
public void mark(int);
descriptor: (I)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=0, locals=2, args_size=2
start local 0 start local 1 0: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lsun/net/www/http/KeepAliveStream;
0 1 1 limit I
MethodParameters:
Name Flags
limit
public void reset();
descriptor: ()V
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=1, args_size=1
start local 0 0: new java.io.IOException
dup
ldc "mark/reset not supported"
invokespecial java.io.IOException.<init>:(Ljava/lang/String;)V
athrow
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lsun/net/www/http/KeepAliveStream;
Exceptions:
throws java.io.IOException
public boolean hurry();
descriptor: ()Z
flags: (0x0001) ACC_PUBLIC
Code:
stack=6, locals=5, args_size=1
start local 0 0: aload 0
invokevirtual sun.net.www.http.KeepAliveStream.lock:()V
1: aload 0
getfield sun.net.www.http.KeepAliveStream.closed:Z
ifne 2
aload 0
getfield sun.net.www.http.KeepAliveStream.count:J
aload 0
getfield sun.net.www.http.KeepAliveStream.expected:J
lcmp
iflt 4
2: StackMap locals:
StackMap stack:
aload 0
invokevirtual sun.net.www.http.KeepAliveStream.unlock:()V
3: iconst_0
ireturn
4: StackMap locals:
StackMap stack:
aload 0
getfield sun.net.www.http.KeepAliveStream.in:Ljava/io/InputStream;
invokevirtual java.io.InputStream.available:()I
i2l
aload 0
getfield sun.net.www.http.KeepAliveStream.expected:J
aload 0
getfield sun.net.www.http.KeepAliveStream.count:J
lsub
lcmp
ifge 7
5: aload 0
invokevirtual sun.net.www.http.KeepAliveStream.unlock:()V
6: iconst_0
ireturn
7: StackMap locals:
StackMap stack:
aload 0
getfield sun.net.www.http.KeepAliveStream.expected:J
aload 0
getfield sun.net.www.http.KeepAliveStream.count:J
lsub
l2i
istore 1
start local 1 8: iload 1
newarray 8
astore 2
start local 2 9: new java.io.DataInputStream
dup
aload 0
getfield sun.net.www.http.KeepAliveStream.in:Ljava/io/InputStream;
invokespecial java.io.DataInputStream.<init>:(Ljava/io/InputStream;)V
astore 3
start local 3 10: aload 3
aload 2
invokevirtual java.io.DataInputStream.readFully:([B)V
11: aload 0
new java.io.ByteArrayInputStream
dup
aload 2
invokespecial java.io.ByteArrayInputStream.<init>:([B)V
putfield sun.net.www.http.KeepAliveStream.in:Ljava/io/InputStream;
12: aload 0
iconst_1
putfield sun.net.www.http.KeepAliveStream.hurried:Z
13: aload 0
invokevirtual sun.net.www.http.KeepAliveStream.unlock:()V
14: iconst_1
ireturn
end local 3 end local 2 end local 1 15: StackMap locals:
StackMap stack: java.io.IOException
pop
16: aload 0
invokevirtual sun.net.www.http.KeepAliveStream.unlock:()V
17: iconst_0
ireturn
18: StackMap locals:
StackMap stack: java.lang.Throwable
astore 4
19: aload 0
invokevirtual sun.net.www.http.KeepAliveStream.unlock:()V
20: aload 4
athrow
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 21 0 this Lsun/net/www/http/KeepAliveStream;
8 15 1 size I
9 15 2 buf [B
10 15 3 dis Ljava/io/DataInputStream;
Exception table:
from to target type
1 2 15 Class java.io.IOException
4 5 15 Class java.io.IOException
7 13 15 Class java.io.IOException
1 2 18 any
4 5 18 any
7 13 18 any
15 16 18 any
private static void queueForCleanup(sun.net.www.http.KeepAliveCleanerEntry);
descriptor: (Lsun/net/www/http/KeepAliveCleanerEntry;)V
flags: (0x000a) ACC_PRIVATE, ACC_STATIC
Code:
stack=2, locals=3, args_size=1
start local 0 0: getstatic sun.net.www.http.KeepAliveStream.queue:Lsun/net/www/http/KeepAliveStreamCleaner;
invokevirtual sun.net.www.http.KeepAliveStreamCleaner.lock:()V
1: aload 0
invokevirtual sun.net.www.http.KeepAliveCleanerEntry.getQueuedForCleanup:()Z
ifne 8
2: getstatic sun.net.www.http.KeepAliveStream.queue:Lsun/net/www/http/KeepAliveStreamCleaner;
aload 0
invokevirtual sun.net.www.http.KeepAliveStreamCleaner.offer:(Lsun/net/www/http/KeepAliveCleanerEntry;)Z
ifne 6
3: aload 0
invokevirtual sun.net.www.http.KeepAliveCleanerEntry.getHttpClient:()Lsun/net/www/http/HttpClient;
invokevirtual sun.net.www.http.HttpClient.closeServer:()V
4: getstatic sun.net.www.http.KeepAliveStream.queue:Lsun/net/www/http/KeepAliveStreamCleaner;
invokevirtual sun.net.www.http.KeepAliveStreamCleaner.unlock:()V
5: return
6: StackMap locals:
StackMap stack:
aload 0
invokevirtual sun.net.www.http.KeepAliveCleanerEntry.setQueuedForCleanup:()V
7: getstatic sun.net.www.http.KeepAliveStream.queue:Lsun/net/www/http/KeepAliveStreamCleaner;
invokevirtual sun.net.www.http.KeepAliveStreamCleaner.signalAll:()V
8: StackMap locals:
StackMap stack:
getstatic sun.net.www.http.KeepAliveStream.cleanerThread:Ljava/lang/Thread;
ifnonnull 9
iconst_1
goto 10
StackMap locals:
StackMap stack:
9: iconst_0
StackMap locals:
StackMap stack: int
10: istore 1
start local 1 11: iload 1
ifne 14
12: getstatic sun.net.www.http.KeepAliveStream.cleanerThread:Ljava/lang/Thread;
invokevirtual java.lang.Thread.isAlive:()Z
ifne 14
13: iconst_1
istore 1
14: StackMap locals: int
StackMap stack:
iload 1
ifeq 21
15: new sun.net.www.http.KeepAliveStream$1
dup
invokespecial sun.net.www.http.KeepAliveStream$1.<init>:()V
16: invokestatic java.security.AccessController.doPrivileged:(Ljava/security/PrivilegedAction;)Ljava/lang/Object;
pop
end local 1 17: goto 21
StackMap locals: sun.net.www.http.KeepAliveCleanerEntry
StackMap stack: java.lang.Throwable
18: astore 2
19: getstatic sun.net.www.http.KeepAliveStream.queue:Lsun/net/www/http/KeepAliveStreamCleaner;
invokevirtual sun.net.www.http.KeepAliveStreamCleaner.unlock:()V
20: aload 2
athrow
21: StackMap locals:
StackMap stack:
getstatic sun.net.www.http.KeepAliveStream.queue:Lsun/net/www/http/KeepAliveStreamCleaner;
invokevirtual sun.net.www.http.KeepAliveStreamCleaner.unlock:()V
22: return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 23 0 kace Lsun/net/www/http/KeepAliveCleanerEntry;
11 17 1 startCleanupThread Z
Exception table:
from to target type
1 4 18 any
6 18 18 any
MethodParameters:
Name Flags
kace
protected long remainingToRead();
descriptor: ()J
flags: (0x0004) ACC_PROTECTED
Code:
stack=4, locals=1, args_size=1
start local 0 0: getstatic sun.net.www.http.KeepAliveStream.$assertionsDisabled:Z
ifne 1
aload 0
invokevirtual sun.net.www.http.KeepAliveStream.isLockHeldByCurrentThread:()Z
ifne 1
new java.lang.AssertionError
dup
invokespecial java.lang.AssertionError.<init>:()V
athrow
1: StackMap locals:
StackMap stack:
aload 0
getfield sun.net.www.http.KeepAliveStream.expected:J
aload 0
getfield sun.net.www.http.KeepAliveStream.count:J
lsub
lreturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lsun/net/www/http/KeepAliveStream;
protected void setClosed();
descriptor: ()V
flags: (0x0004) ACC_PROTECTED
Code:
stack=2, locals=1, args_size=1
start local 0 0: getstatic sun.net.www.http.KeepAliveStream.$assertionsDisabled:Z
ifne 1
aload 0
invokevirtual sun.net.www.http.KeepAliveStream.isLockHeldByCurrentThread:()Z
ifne 1
new java.lang.AssertionError
dup
invokespecial java.lang.AssertionError.<init>:()V
athrow
1: StackMap locals:
StackMap stack:
aload 0
aconst_null
putfield sun.net.www.http.KeepAliveStream.in:Ljava/io/InputStream;
2: aload 0
aconst_null
putfield sun.net.www.http.KeepAliveStream.hc:Lsun/net/www/http/HttpClient;
3: aload 0
iconst_1
putfield sun.net.www.http.KeepAliveStream.closed:Z
4: return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 5 0 this Lsun/net/www/http/KeepAliveStream;
}
SourceFile: "KeepAliveStream.java"
NestMembers:
sun.net.www.http.KeepAliveStream$1
InnerClasses:
sun.net.www.http.KeepAliveStream$1