public abstract class io.undertow.conduits.AbstractFixedLengthStreamSinkConduit extends org.xnio.conduits.AbstractStreamSinkConduit<org.xnio.conduits.StreamSinkConduit>
minor version: 0
major version: 59
flags: flags: (0x0421) ACC_PUBLIC, ACC_SUPER, ACC_ABSTRACT
this_class: io.undertow.conduits.AbstractFixedLengthStreamSinkConduit
super_class: org.xnio.conduits.AbstractStreamSinkConduit
{
private int config;
descriptor: I
flags: (0x0002) ACC_PRIVATE
private long state;
descriptor: J
flags: (0x0002) ACC_PRIVATE
private boolean broken;
descriptor: Z
flags: (0x0002) ACC_PRIVATE
private static final int CONF_FLAG_CONFIGURABLE;
descriptor: I
flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL
ConstantValue: 1
private static final int CONF_FLAG_PASS_CLOSE;
descriptor: I
flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL
ConstantValue: 2
private static final long FLAG_CLOSE_REQUESTED;
descriptor: J
flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL
ConstantValue: -9223372036854775808
private static final long FLAG_CLOSE_COMPLETE;
descriptor: J
flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL
ConstantValue: 4611686018427387904
private static final long FLAG_FINISHED_CALLED;
descriptor: J
flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL
ConstantValue: 2305843009213693952
private static final long MASK_COUNT;
descriptor: J
flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL
static void <clinit>();
descriptor: ()V
flags: (0x0008) ACC_STATIC
Code:
stack=2, locals=0, args_size=0
0: iconst_0
bipush 60
invokestatic org.xnio.Bits.longBitMask:(II)J
putstatic io.undertow.conduits.AbstractFixedLengthStreamSinkConduit.MASK_COUNT:J
return
LocalVariableTable:
Start End Slot Name Signature
public void <init>(org.xnio.conduits.StreamSinkConduit, long, boolean, boolean);
descriptor: (Lorg/xnio/conduits/StreamSinkConduit;JZZ)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=4, locals=6, args_size=5
start local 0 start local 1 start local 2 start local 4 start local 5 0: aload 0
aload 1
invokespecial org.xnio.conduits.AbstractStreamSinkConduit.<init>:(Lorg/xnio/conduits/StreamSinkConduit;)V
1: aload 0
iconst_0
putfield io.undertow.conduits.AbstractFixedLengthStreamSinkConduit.broken:Z
2: lload 2
lconst_0
lcmp
ifge 4
3: new java.lang.IllegalArgumentException
dup
ldc "Content length must be greater than or equal to zero"
invokespecial java.lang.IllegalArgumentException.<init>:(Ljava/lang/String;)V
athrow
4: StackMap locals: io.undertow.conduits.AbstractFixedLengthStreamSinkConduit org.xnio.conduits.StreamSinkConduit long int int
StackMap stack:
lload 2
getstatic io.undertow.conduits.AbstractFixedLengthStreamSinkConduit.MASK_COUNT:J
lcmp
ifle 6
5: new java.lang.IllegalArgumentException
dup
ldc "Content length is too long"
invokespecial java.lang.IllegalArgumentException.<init>:(Ljava/lang/String;)V
athrow
6: StackMap locals:
StackMap stack:
aload 0
iload 4
ifeq 7
iconst_1
goto 8
StackMap locals:
StackMap stack: io.undertow.conduits.AbstractFixedLengthStreamSinkConduit
7: iconst_0
StackMap locals: io.undertow.conduits.AbstractFixedLengthStreamSinkConduit org.xnio.conduits.StreamSinkConduit long int int
StackMap stack: io.undertow.conduits.AbstractFixedLengthStreamSinkConduit int
8: iload 5
ifeq 9
iconst_2
goto 10
StackMap locals: io.undertow.conduits.AbstractFixedLengthStreamSinkConduit org.xnio.conduits.StreamSinkConduit long int int
StackMap stack: io.undertow.conduits.AbstractFixedLengthStreamSinkConduit int
9: iconst_0
StackMap locals: io.undertow.conduits.AbstractFixedLengthStreamSinkConduit org.xnio.conduits.StreamSinkConduit long int int
StackMap stack: io.undertow.conduits.AbstractFixedLengthStreamSinkConduit int int
10: ior
putfield io.undertow.conduits.AbstractFixedLengthStreamSinkConduit.config:I
11: aload 0
lload 2
putfield io.undertow.conduits.AbstractFixedLengthStreamSinkConduit.state:J
12: return
end local 5 end local 4 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 13 0 this Lio/undertow/conduits/AbstractFixedLengthStreamSinkConduit;
0 13 1 next Lorg/xnio/conduits/StreamSinkConduit;
0 13 2 contentLength J
0 13 4 configurable Z
0 13 5 propagateClose Z
MethodParameters:
Name Flags
next final
contentLength final
configurable final
propagateClose final
protected void reset(long, boolean);
descriptor: (JZ)V
flags: (0x0004) ACC_PROTECTED
Code:
stack=3, locals=4, args_size=3
start local 0 start local 1 start local 3 0: aload 0
lload 1
putfield io.undertow.conduits.AbstractFixedLengthStreamSinkConduit.state:J
1: iload 3
ifeq 4
2: aload 0
dup
getfield io.undertow.conduits.AbstractFixedLengthStreamSinkConduit.config:I
iconst_2
ior
putfield io.undertow.conduits.AbstractFixedLengthStreamSinkConduit.config:I
3: goto 5
4: StackMap locals:
StackMap stack:
aload 0
dup
getfield io.undertow.conduits.AbstractFixedLengthStreamSinkConduit.config:I
bipush -3
iand
putfield io.undertow.conduits.AbstractFixedLengthStreamSinkConduit.config:I
5: StackMap locals:
StackMap stack:
return
end local 3 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 6 0 this Lio/undertow/conduits/AbstractFixedLengthStreamSinkConduit;
0 6 1 contentLength J
0 6 3 propagateClose Z
MethodParameters:
Name Flags
contentLength
propagateClose
public int write(java.nio.ByteBuffer);
descriptor: (Ljava/nio/ByteBuffer;)I
flags: (0x0001) ACC_PUBLIC
Code:
stack=5, locals=11, args_size=2
start local 0 start local 1 0: aload 0
getfield io.undertow.conduits.AbstractFixedLengthStreamSinkConduit.state:J
lstore 2
start local 2 1: lload 2
getstatic io.undertow.conduits.AbstractFixedLengthStreamSinkConduit.MASK_COUNT:J
land
lstore 4
start local 4 2: aload 1
invokevirtual java.nio.ByteBuffer.hasRemaining:()Z
ifne 4
3: iconst_0
ireturn
4: StackMap locals: long long
StackMap stack:
lload 2
ldc -9223372036854775808
invokestatic org.xnio.Bits.allAreSet:(JJ)Z
ifeq 6
5: new java.nio.channels.ClosedChannelException
dup
invokespecial java.nio.channels.ClosedChannelException.<init>:()V
athrow
6: StackMap locals:
StackMap stack:
aload 1
invokevirtual java.nio.ByteBuffer.limit:()I
istore 6
start local 6 7: lload 4
lconst_0
lcmp
ifne 9
8: new org.xnio.channels.FixedLengthOverflowException
dup
invokespecial org.xnio.channels.FixedLengthOverflowException.<init>:()V
athrow
9: StackMap locals: int
StackMap stack:
aload 1
invokevirtual java.nio.ByteBuffer.remaining:()I
i2l
lload 4
lcmp
ifle 11
10: aload 1
aload 1
invokevirtual java.nio.ByteBuffer.position:()I
i2l
lload 4
ladd
l2i
invokevirtual java.nio.ByteBuffer.limit:(I)Ljava/nio/Buffer;
pop
11: StackMap locals:
StackMap stack:
iconst_0
istore 7
start local 7 12: aload 0
getfield io.undertow.conduits.AbstractFixedLengthStreamSinkConduit.next:Lorg/xnio/conduits/Conduit;
checkcast org.xnio.conduits.StreamSinkConduit
aload 1
invokeinterface org.xnio.conduits.StreamSinkConduit.write:(Ljava/nio/ByteBuffer;)I
dup
istore 7
istore 10
13: aload 1
iload 6
invokevirtual java.nio.ByteBuffer.limit:(I)Ljava/nio/Buffer;
pop
14: aload 0
lload 2
iload 7
i2l
invokevirtual io.undertow.conduits.AbstractFixedLengthStreamSinkConduit.exitWrite:(JJ)V
15: iload 10
ireturn
16: StackMap locals: io.undertow.conduits.AbstractFixedLengthStreamSinkConduit java.nio.ByteBuffer long long int int
StackMap stack: java.lang.Throwable
astore 8
start local 8 17: aload 0
iconst_1
putfield io.undertow.conduits.AbstractFixedLengthStreamSinkConduit.broken:Z
18: aload 8
athrow
end local 8 19: StackMap locals:
StackMap stack: java.lang.Throwable
astore 9
20: aload 1
iload 6
invokevirtual java.nio.ByteBuffer.limit:(I)Ljava/nio/Buffer;
pop
21: aload 0
lload 2
iload 7
i2l
invokevirtual io.undertow.conduits.AbstractFixedLengthStreamSinkConduit.exitWrite:(JJ)V
22: aload 9
athrow
end local 7 end local 6 end local 4 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 23 0 this Lio/undertow/conduits/AbstractFixedLengthStreamSinkConduit;
0 23 1 src Ljava/nio/ByteBuffer;
1 23 2 val J
2 23 4 remaining J
7 23 6 oldLimit I
12 23 7 res I
17 19 8 e Ljava/lang/Throwable;
Exception table:
from to target type
12 13 16 Class java.io.IOException
12 13 16 Class java.lang.RuntimeException
12 13 16 Class java.lang.Error
12 13 19 any
16 19 19 any
Exceptions:
throws java.io.IOException
MethodParameters:
Name Flags
src final
public long write(java.nio.ByteBuffer[], int, int);
descriptor: ([Ljava/nio/ByteBuffer;II)J
flags: (0x0001) ACC_PUBLIC
Code:
stack=5, locals=18, args_size=4
start local 0 start local 1 start local 2 start local 3 0: iload 3
ifne 2
1: lconst_0
lreturn
2: StackMap locals:
StackMap stack:
iload 3
iconst_1
if_icmpne 4
3: aload 0
aload 1
iload 2
aaload
invokevirtual io.undertow.conduits.AbstractFixedLengthStreamSinkConduit.write:(Ljava/nio/ByteBuffer;)I
i2l
lreturn
4: StackMap locals:
StackMap stack:
aload 0
getfield io.undertow.conduits.AbstractFixedLengthStreamSinkConduit.state:J
lstore 4
start local 4 5: lload 4
getstatic io.undertow.conduits.AbstractFixedLengthStreamSinkConduit.MASK_COUNT:J
land
lstore 6
start local 6 6: lload 4
ldc -9223372036854775808
invokestatic org.xnio.Bits.allAreSet:(JJ)Z
ifeq 8
7: new java.nio.channels.ClosedChannelException
dup
invokespecial java.nio.channels.ClosedChannelException.<init>:()V
athrow
8: StackMap locals: long long
StackMap stack:
aload 1
iload 2
iload 3
invokestatic org.xnio.Buffers.remaining:([Ljava/nio/Buffer;II)J
lstore 8
start local 8 9: lload 6
lconst_0
lcmp
ifne 11
10: new org.xnio.channels.FixedLengthOverflowException
dup
invokespecial org.xnio.channels.FixedLengthOverflowException.<init>:()V
athrow
11: StackMap locals: long
StackMap stack:
aconst_null
astore 10
start local 10 12: lload 8
lload 6
lcmp
ifle 26
13: iload 3
newarray 10
astore 10
14: lload 6
lstore 11
start local 11 15: iload 2
istore 13
start local 13 16: goto 25
17: StackMap locals: int[] long int
StackMap stack:
aload 10
iload 13
iload 2
isub
aload 1
iload 13
aaload
invokevirtual java.nio.ByteBuffer.limit:()I
iastore
18: aload 1
iload 13
aaload
invokevirtual java.nio.ByteBuffer.remaining:()I
istore 14
start local 14 19: iload 14
i2l
lload 11
lcmp
ifge 22
20: lload 11
iload 14
i2l
lsub
lstore 11
21: goto 24
22: StackMap locals: int
StackMap stack:
aload 1
iload 13
aaload
aload 1
iload 13
aaload
invokevirtual java.nio.ByteBuffer.position:()I
i2l
lload 11
ladd
l2i
invokevirtual java.nio.ByteBuffer.limit:(I)Ljava/nio/Buffer;
pop
23: lconst_0
lstore 11
end local 14 24: StackMap locals:
StackMap stack:
iinc 13 1
StackMap locals:
StackMap stack:
25: iload 13
iload 2
iload 3
iadd
if_icmplt 17
end local 13 end local 11 26: StackMap locals:
StackMap stack:
lconst_0
lstore 11
start local 11 27: aload 0
getfield io.undertow.conduits.AbstractFixedLengthStreamSinkConduit.next:Lorg/xnio/conduits/Conduit;
checkcast org.xnio.conduits.StreamSinkConduit
aload 1
iload 2
iload 3
invokeinterface org.xnio.conduits.StreamSinkConduit.write:([Ljava/nio/ByteBuffer;II)J
dup2
lstore 11
lstore 15
28: aload 10
ifnull 34
29: iload 2
istore 17
start local 17 30: goto 33
31: StackMap locals: io.undertow.conduits.AbstractFixedLengthStreamSinkConduit java.nio.ByteBuffer[] int int long long long int[] long top top long int
StackMap stack:
aload 1
iload 17
aaload
aload 10
iload 17
iload 2
isub
iaload
invokevirtual java.nio.ByteBuffer.limit:(I)Ljava/nio/Buffer;
pop
32: iinc 17 1
StackMap locals:
StackMap stack:
33: iload 17
iload 2
iload 3
iadd
if_icmplt 31
end local 17 34: StackMap locals:
StackMap stack:
aload 0
lload 4
lload 11
invokevirtual io.undertow.conduits.AbstractFixedLengthStreamSinkConduit.exitWrite:(JJ)V
35: lload 15
lreturn
36: StackMap locals: io.undertow.conduits.AbstractFixedLengthStreamSinkConduit java.nio.ByteBuffer[] int int long long long int[] long
StackMap stack: java.lang.Throwable
astore 13
start local 13 37: aload 0
iconst_1
putfield io.undertow.conduits.AbstractFixedLengthStreamSinkConduit.broken:Z
38: aload 13
athrow
end local 13 39: StackMap locals:
StackMap stack: java.lang.Throwable
astore 14
40: aload 10
ifnull 46
41: iload 2
istore 17
start local 17 42: goto 45
43: StackMap locals: io.undertow.conduits.AbstractFixedLengthStreamSinkConduit java.nio.ByteBuffer[] int int long long long int[] long top java.lang.Throwable top top int
StackMap stack:
aload 1
iload 17
aaload
aload 10
iload 17
iload 2
isub
iaload
invokevirtual java.nio.ByteBuffer.limit:(I)Ljava/nio/Buffer;
pop
44: iinc 17 1
StackMap locals:
StackMap stack:
45: iload 17
iload 2
iload 3
iadd
if_icmplt 43
end local 17 46: StackMap locals: io.undertow.conduits.AbstractFixedLengthStreamSinkConduit java.nio.ByteBuffer[] int int long long long int[] long top java.lang.Throwable
StackMap stack:
aload 0
lload 4
lload 11
invokevirtual io.undertow.conduits.AbstractFixedLengthStreamSinkConduit.exitWrite:(JJ)V
47: aload 14
athrow
end local 11 end local 10 end local 8 end local 6 end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 48 0 this Lio/undertow/conduits/AbstractFixedLengthStreamSinkConduit;
0 48 1 srcs [Ljava/nio/ByteBuffer;
0 48 2 offset I
0 48 3 length I
5 48 4 val J
6 48 6 remaining J
9 48 8 toWrite J
12 48 10 limits [I
15 26 11 r J
16 26 13 i I
19 24 14 br I
27 48 11 res J
37 39 13 e Ljava/lang/Throwable;
30 34 17 i I
42 46 17 i I
Exception table:
from to target type
27 28 36 Class java.io.IOException
27 28 36 Class java.lang.RuntimeException
27 28 36 Class java.lang.Error
27 28 39 any
36 39 39 any
Exceptions:
throws java.io.IOException
MethodParameters:
Name Flags
srcs final
offset final
length final
public long writeFinal(java.nio.ByteBuffer[], int, int);
descriptor: ([Ljava/nio/ByteBuffer;II)J
flags: (0x0001) ACC_PUBLIC
Code:
stack=4, locals=5, args_size=4
start local 0 start local 1 start local 2 start local 3 0: aload 0
aload 1
iload 2
iload 3
invokestatic org.xnio.conduits.Conduits.writeFinalBasic:(Lorg/xnio/conduits/StreamSinkConduit;[Ljava/nio/ByteBuffer;II)J
1: lreturn
2: StackMap locals:
StackMap stack: java.lang.Throwable
astore 4
start local 4 3: aload 0
iconst_1
putfield io.undertow.conduits.AbstractFixedLengthStreamSinkConduit.broken:Z
4: aload 4
athrow
end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 5 0 this Lio/undertow/conduits/AbstractFixedLengthStreamSinkConduit;
0 5 1 srcs [Ljava/nio/ByteBuffer;
0 5 2 offset I
0 5 3 length I
3 5 4 e Ljava/lang/Throwable;
Exception table:
from to target type
0 1 2 Class java.io.IOException
0 1 2 Class java.lang.RuntimeException
0 1 2 Class java.lang.Error
Exceptions:
throws java.io.IOException
MethodParameters:
Name Flags
srcs
offset
length
public int writeFinal(java.nio.ByteBuffer);
descriptor: (Ljava/nio/ByteBuffer;)I
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=3, args_size=2
start local 0 start local 1 0: aload 0
aload 1
invokestatic org.xnio.conduits.Conduits.writeFinalBasic:(Lorg/xnio/conduits/StreamSinkConduit;Ljava/nio/ByteBuffer;)I
1: ireturn
2: StackMap locals:
StackMap stack: java.lang.Throwable
astore 2
start local 2 3: aload 0
iconst_1
putfield io.undertow.conduits.AbstractFixedLengthStreamSinkConduit.broken:Z
4: aload 2
athrow
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 5 0 this Lio/undertow/conduits/AbstractFixedLengthStreamSinkConduit;
0 5 1 src Ljava/nio/ByteBuffer;
3 5 2 e Ljava/lang/Throwable;
Exception table:
from to target type
0 1 2 Class java.io.IOException
0 1 2 Class java.lang.RuntimeException
0 1 2 Class java.lang.Error
Exceptions:
throws java.io.IOException
MethodParameters:
Name Flags
src
public long transferFrom(java.nio.channels.FileChannel, long, long);
descriptor: (Ljava/nio/channels/FileChannel;JJ)J
flags: (0x0001) ACC_PUBLIC
Code:
stack=10, locals=14, args_size=4
start local 0 start local 1 start local 2 start local 4 0: lload 4
lconst_0
lcmp
ifne 1
lconst_0
lreturn
1: StackMap locals:
StackMap stack:
aload 0
getfield io.undertow.conduits.AbstractFixedLengthStreamSinkConduit.state:J
lstore 6
start local 6 2: lload 6
ldc -9223372036854775808
invokestatic org.xnio.Bits.allAreSet:(JJ)Z
ifeq 4
3: new java.nio.channels.ClosedChannelException
dup
invokespecial java.nio.channels.ClosedChannelException.<init>:()V
athrow
4: StackMap locals: long
StackMap stack:
lload 6
getstatic io.undertow.conduits.AbstractFixedLengthStreamSinkConduit.MASK_COUNT:J
invokestatic org.xnio.Bits.allAreClear:(JJ)Z
ifeq 6
5: new org.xnio.channels.FixedLengthOverflowException
dup
invokespecial org.xnio.channels.FixedLengthOverflowException.<init>:()V
athrow
6: StackMap locals:
StackMap stack:
lconst_0
lstore 8
start local 8 7: aload 0
getfield io.undertow.conduits.AbstractFixedLengthStreamSinkConduit.next:Lorg/xnio/conduits/Conduit;
checkcast org.xnio.conduits.StreamSinkConduit
aload 1
lload 2
lload 4
lload 6
getstatic io.undertow.conduits.AbstractFixedLengthStreamSinkConduit.MASK_COUNT:J
land
invokestatic java.lang.Math.min:(JJ)J
invokeinterface org.xnio.conduits.StreamSinkConduit.transferFrom:(Ljava/nio/channels/FileChannel;JJ)J
dup2
lstore 8
lstore 12
8: aload 0
lload 6
lload 8
invokevirtual io.undertow.conduits.AbstractFixedLengthStreamSinkConduit.exitWrite:(JJ)V
9: lload 12
lreturn
10: StackMap locals: io.undertow.conduits.AbstractFixedLengthStreamSinkConduit java.nio.channels.FileChannel long long long long
StackMap stack: java.lang.Throwable
astore 10
start local 10 11: aload 0
iconst_1
putfield io.undertow.conduits.AbstractFixedLengthStreamSinkConduit.broken:Z
12: aload 10
athrow
end local 10 13: StackMap locals:
StackMap stack: java.lang.Throwable
astore 11
14: aload 0
lload 6
lload 8
invokevirtual io.undertow.conduits.AbstractFixedLengthStreamSinkConduit.exitWrite:(JJ)V
15: aload 11
athrow
end local 8 end local 6 end local 4 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 16 0 this Lio/undertow/conduits/AbstractFixedLengthStreamSinkConduit;
0 16 1 src Ljava/nio/channels/FileChannel;
0 16 2 position J
0 16 4 count J
2 16 6 val J
7 16 8 res J
11 13 10 e Ljava/lang/Throwable;
Exception table:
from to target type
7 8 10 Class java.io.IOException
7 8 10 Class java.lang.RuntimeException
7 8 10 Class java.lang.Error
7 8 13 any
10 13 13 any
Exceptions:
throws java.io.IOException
MethodParameters:
Name Flags
src final
position final
count final
public long transferFrom(org.xnio.channels.StreamSourceChannel, long, java.nio.ByteBuffer);
descriptor: (Lorg/xnio/channels/StreamSourceChannel;JLjava/nio/ByteBuffer;)J
flags: (0x0001) ACC_PUBLIC
Code:
stack=8, locals=13, args_size=4
start local 0 start local 1 start local 2 start local 4 0: lload 2
lconst_0
lcmp
ifne 1
lconst_0
lreturn
1: StackMap locals:
StackMap stack:
aload 0
getfield io.undertow.conduits.AbstractFixedLengthStreamSinkConduit.state:J
lstore 5
start local 5 2: lload 5
ldc -9223372036854775808
invokestatic org.xnio.Bits.allAreSet:(JJ)Z
ifeq 4
3: new java.nio.channels.ClosedChannelException
dup
invokespecial java.nio.channels.ClosedChannelException.<init>:()V
athrow
4: StackMap locals: long
StackMap stack:
lload 5
getstatic io.undertow.conduits.AbstractFixedLengthStreamSinkConduit.MASK_COUNT:J
invokestatic org.xnio.Bits.allAreClear:(JJ)Z
ifeq 6
5: new org.xnio.channels.FixedLengthOverflowException
dup
invokespecial org.xnio.channels.FixedLengthOverflowException.<init>:()V
athrow
6: StackMap locals:
StackMap stack:
lconst_0
lstore 7
start local 7 7: aload 0
getfield io.undertow.conduits.AbstractFixedLengthStreamSinkConduit.next:Lorg/xnio/conduits/Conduit;
checkcast org.xnio.conduits.StreamSinkConduit
aload 1
lload 2
lload 5
getstatic io.undertow.conduits.AbstractFixedLengthStreamSinkConduit.MASK_COUNT:J
land
invokestatic java.lang.Math.min:(JJ)J
aload 4
invokeinterface org.xnio.conduits.StreamSinkConduit.transferFrom:(Lorg/xnio/channels/StreamSourceChannel;JLjava/nio/ByteBuffer;)J
dup2
lstore 7
lstore 11
8: aload 0
lload 5
lload 7
invokevirtual io.undertow.conduits.AbstractFixedLengthStreamSinkConduit.exitWrite:(JJ)V
9: lload 11
lreturn
10: StackMap locals: io.undertow.conduits.AbstractFixedLengthStreamSinkConduit org.xnio.channels.StreamSourceChannel long java.nio.ByteBuffer long long
StackMap stack: java.lang.Throwable
astore 9
start local 9 11: aload 0
iconst_1
putfield io.undertow.conduits.AbstractFixedLengthStreamSinkConduit.broken:Z
12: aload 9
athrow
end local 9 13: StackMap locals:
StackMap stack: java.lang.Throwable
astore 10
14: aload 0
lload 5
lload 7
invokevirtual io.undertow.conduits.AbstractFixedLengthStreamSinkConduit.exitWrite:(JJ)V
15: aload 10
athrow
end local 7 end local 5 end local 4 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 16 0 this Lio/undertow/conduits/AbstractFixedLengthStreamSinkConduit;
0 16 1 source Lorg/xnio/channels/StreamSourceChannel;
0 16 2 count J
0 16 4 throughBuffer Ljava/nio/ByteBuffer;
2 16 5 val J
7 16 7 res J
11 13 9 e Ljava/lang/Throwable;
Exception table:
from to target type
7 8 10 Class java.io.IOException
7 8 10 Class java.lang.RuntimeException
7 8 10 Class java.lang.Error
7 8 13 any
10 13 13 any
Exceptions:
throws java.io.IOException
MethodParameters:
Name Flags
source final
count final
throughBuffer final
public boolean flush();
descriptor: ()Z
flags: (0x0001) ACC_PUBLIC
Code:
stack=4, locals=7, args_size=1
start local 0 0: aload 0
getfield io.undertow.conduits.AbstractFixedLengthStreamSinkConduit.state:J
lstore 1
start local 1 1: lload 1
ldc 4611686018427387904
invokestatic org.xnio.Bits.anyAreSet:(JJ)Z
ifeq 3
2: iconst_1
ireturn
3: StackMap locals: long
StackMap stack:
iconst_0
istore 3
start local 3 4: aload 0
getfield io.undertow.conduits.AbstractFixedLengthStreamSinkConduit.next:Lorg/xnio/conduits/Conduit;
checkcast org.xnio.conduits.StreamSinkConduit
invokeinterface org.xnio.conduits.StreamSinkConduit.flush:()Z
dup
istore 3
istore 6
5: aload 0
lload 1
iload 3
invokevirtual io.undertow.conduits.AbstractFixedLengthStreamSinkConduit.exitFlush:(JZ)V
6: iload 6
ireturn
7: StackMap locals: io.undertow.conduits.AbstractFixedLengthStreamSinkConduit long int
StackMap stack: java.lang.Throwable
astore 4
start local 4 8: aload 0
iconst_1
putfield io.undertow.conduits.AbstractFixedLengthStreamSinkConduit.broken:Z
9: aload 4
athrow
end local 4 10: StackMap locals:
StackMap stack: java.lang.Throwable
astore 5
11: aload 0
lload 1
iload 3
invokevirtual io.undertow.conduits.AbstractFixedLengthStreamSinkConduit.exitFlush:(JZ)V
12: aload 5
athrow
end local 3 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 13 0 this Lio/undertow/conduits/AbstractFixedLengthStreamSinkConduit;
1 13 1 val J
4 13 3 flushed Z
8 10 4 e Ljava/lang/Throwable;
Exception table:
from to target type
4 5 7 Class java.io.IOException
4 5 7 Class java.lang.RuntimeException
4 5 7 Class java.lang.Error
4 5 10 any
7 10 10 any
Exceptions:
throws java.io.IOException
public boolean isWriteResumed();
descriptor: ()Z
flags: (0x0001) ACC_PUBLIC
Code:
stack=4, locals=1, args_size=1
start local 0 0: aload 0
getfield io.undertow.conduits.AbstractFixedLengthStreamSinkConduit.state:J
ldc 4611686018427387904
invokestatic org.xnio.Bits.allAreClear:(JJ)Z
ifeq 1
aload 0
getfield io.undertow.conduits.AbstractFixedLengthStreamSinkConduit.next:Lorg/xnio/conduits/Conduit;
checkcast org.xnio.conduits.StreamSinkConduit
invokeinterface org.xnio.conduits.StreamSinkConduit.isWriteResumed:()Z
ifeq 1
iconst_1
ireturn
StackMap locals:
StackMap stack:
1: iconst_0
ireturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lio/undertow/conduits/AbstractFixedLengthStreamSinkConduit;
public void wakeupWrites();
descriptor: ()V
flags: (0x0001) ACC_PUBLIC
Code:
stack=4, locals=3, args_size=1
start local 0 0: aload 0
getfield io.undertow.conduits.AbstractFixedLengthStreamSinkConduit.state:J
lstore 1
start local 1 1: lload 1
ldc 4611686018427387904
invokestatic org.xnio.Bits.anyAreSet:(JJ)Z
ifeq 3
2: return
3: StackMap locals: long
StackMap stack:
aload 0
getfield io.undertow.conduits.AbstractFixedLengthStreamSinkConduit.next:Lorg/xnio/conduits/Conduit;
checkcast org.xnio.conduits.StreamSinkConduit
invokeinterface org.xnio.conduits.StreamSinkConduit.wakeupWrites:()V
4: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 5 0 this Lio/undertow/conduits/AbstractFixedLengthStreamSinkConduit;
1 5 1 val J
public void terminateWrites();
descriptor: ()V
flags: (0x0001) ACC_PUBLIC
Code:
stack=6, locals=4, args_size=1
start local 0 0: aload 0
invokevirtual io.undertow.conduits.AbstractFixedLengthStreamSinkConduit.enterShutdown:()J
lstore 1
start local 1 1: lload 1
getstatic io.undertow.conduits.AbstractFixedLengthStreamSinkConduit.MASK_COUNT:J
invokestatic org.xnio.Bits.anyAreSet:(JJ)Z
ifeq 14
aload 0
getfield io.undertow.conduits.AbstractFixedLengthStreamSinkConduit.broken:Z
ifne 14
2: getstatic io.undertow.UndertowLogger.REQUEST_IO_LOGGER:Lio/undertow/UndertowLogger;
ldc "Fixed length stream closed with with %s bytes remaining"
lload 1
getstatic io.undertow.conduits.AbstractFixedLengthStreamSinkConduit.MASK_COUNT:J
land
invokeinterface io.undertow.UndertowLogger.debugf:(Ljava/lang/String;J)V
3: aload 0
getfield io.undertow.conduits.AbstractFixedLengthStreamSinkConduit.next:Lorg/xnio/conduits/Conduit;
checkcast org.xnio.conduits.StreamSinkConduit
invokeinterface org.xnio.conduits.StreamSinkConduit.truncateWrites:()V
4: goto 10
StackMap locals: io.undertow.conduits.AbstractFixedLengthStreamSinkConduit long
StackMap stack: java.lang.Throwable
5: astore 3
6: aload 0
getfield io.undertow.conduits.AbstractFixedLengthStreamSinkConduit.state:J
ldc 2305843009213693952
invokestatic org.xnio.Bits.anyAreSet:(JJ)Z
ifne 9
7: aload 0
dup
getfield io.undertow.conduits.AbstractFixedLengthStreamSinkConduit.state:J
ldc 2305843009213693952
lor
putfield io.undertow.conduits.AbstractFixedLengthStreamSinkConduit.state:J
8: aload 0
invokevirtual io.undertow.conduits.AbstractFixedLengthStreamSinkConduit.channelFinished:()V
9: StackMap locals: java.lang.Throwable
StackMap stack:
aload 3
athrow
10: StackMap locals:
StackMap stack:
aload 0
getfield io.undertow.conduits.AbstractFixedLengthStreamSinkConduit.state:J
ldc 2305843009213693952
invokestatic org.xnio.Bits.anyAreSet:(JJ)Z
ifne 16
11: aload 0
dup
getfield io.undertow.conduits.AbstractFixedLengthStreamSinkConduit.state:J
ldc 2305843009213693952
lor
putfield io.undertow.conduits.AbstractFixedLengthStreamSinkConduit.state:J
12: aload 0
invokevirtual io.undertow.conduits.AbstractFixedLengthStreamSinkConduit.channelFinished:()V
13: goto 16
StackMap locals:
StackMap stack:
14: aload 0
getfield io.undertow.conduits.AbstractFixedLengthStreamSinkConduit.config:I
iconst_2
invokestatic org.xnio.Bits.allAreSet:(II)Z
ifeq 16
15: aload 0
getfield io.undertow.conduits.AbstractFixedLengthStreamSinkConduit.next:Lorg/xnio/conduits/Conduit;
checkcast org.xnio.conduits.StreamSinkConduit
invokeinterface org.xnio.conduits.StreamSinkConduit.terminateWrites:()V
16: StackMap locals:
StackMap stack:
return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 17 0 this Lio/undertow/conduits/AbstractFixedLengthStreamSinkConduit;
1 17 1 val J
Exception table:
from to target type
3 5 5 any
Exceptions:
throws java.io.IOException
public void truncateWrites();
descriptor: ()V
flags: (0x0001) ACC_PUBLIC
Code:
stack=5, locals=2, args_size=1
start local 0 0: aload 0
getfield io.undertow.conduits.AbstractFixedLengthStreamSinkConduit.state:J
ldc 2305843009213693952
invokestatic org.xnio.Bits.anyAreSet:(JJ)Z
ifne 7
1: aload 0
dup
getfield io.undertow.conduits.AbstractFixedLengthStreamSinkConduit.state:J
ldc 2305843009213693952
lor
putfield io.undertow.conduits.AbstractFixedLengthStreamSinkConduit.state:J
2: aload 0
invokevirtual io.undertow.conduits.AbstractFixedLengthStreamSinkConduit.channelFinished:()V
3: goto 7
StackMap locals:
StackMap stack: java.lang.Throwable
4: astore 1
5: aload 0
invokespecial org.xnio.conduits.AbstractStreamSinkConduit.truncateWrites:()V
6: aload 1
athrow
7: StackMap locals:
StackMap stack:
aload 0
invokespecial org.xnio.conduits.AbstractStreamSinkConduit.truncateWrites:()V
8: return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 9 0 this Lio/undertow/conduits/AbstractFixedLengthStreamSinkConduit;
Exception table:
from to target type
0 4 4 any
Exceptions:
throws java.io.IOException
public void awaitWritable();
descriptor: ()V
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield io.undertow.conduits.AbstractFixedLengthStreamSinkConduit.next:Lorg/xnio/conduits/Conduit;
checkcast org.xnio.conduits.StreamSinkConduit
invokeinterface org.xnio.conduits.StreamSinkConduit.awaitWritable:()V
1: return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lio/undertow/conduits/AbstractFixedLengthStreamSinkConduit;
Exceptions:
throws java.io.IOException
public void awaitWritable(long, java.util.concurrent.TimeUnit);
descriptor: (JLjava/util/concurrent/TimeUnit;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=4, locals=4, args_size=3
start local 0 start local 1 start local 3 0: aload 0
getfield io.undertow.conduits.AbstractFixedLengthStreamSinkConduit.next:Lorg/xnio/conduits/Conduit;
checkcast org.xnio.conduits.StreamSinkConduit
lload 1
aload 3
invokeinterface org.xnio.conduits.StreamSinkConduit.awaitWritable:(JLjava/util/concurrent/TimeUnit;)V
1: return
end local 3 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lio/undertow/conduits/AbstractFixedLengthStreamSinkConduit;
0 2 1 time J
0 2 3 timeUnit Ljava/util/concurrent/TimeUnit;
Exceptions:
throws java.io.IOException
MethodParameters:
Name Flags
time final
timeUnit final
public long getRemaining();
descriptor: ()J
flags: (0x0001) ACC_PUBLIC
Code:
stack=4, locals=1, args_size=1
start local 0 0: aload 0
getfield io.undertow.conduits.AbstractFixedLengthStreamSinkConduit.state:J
getstatic io.undertow.conduits.AbstractFixedLengthStreamSinkConduit.MASK_COUNT:J
land
lreturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/undertow/conduits/AbstractFixedLengthStreamSinkConduit;
private void exitWrite(long, long);
descriptor: (JJ)V
flags: (0x0002) ACC_PRIVATE
Code:
stack=4, locals=7, args_size=3
start local 0 start local 1 start local 3 0: lload 1
lload 3
lsub
lstore 5
start local 5 1: aload 0
lload 5
putfield io.undertow.conduits.AbstractFixedLengthStreamSinkConduit.state:J
2: return
end local 5 end local 3 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 this Lio/undertow/conduits/AbstractFixedLengthStreamSinkConduit;
0 3 1 oldVal J
0 3 3 consumed J
1 3 5 newVal J
MethodParameters:
Name Flags
oldVal
consumed
private void exitFlush(long, boolean);
descriptor: (JZ)V
flags: (0x0002) ACC_PRIVATE
Code:
stack=4, locals=7, args_size=3
start local 0 start local 1 start local 3 0: lload 1
lstore 4
start local 4 1: iconst_0
istore 6
start local 6 2: lload 1
ldc -9223372036854775808
invokestatic org.xnio.Bits.anyAreSet:(JJ)Z
ifne 3
lload 4
getstatic io.undertow.conduits.AbstractFixedLengthStreamSinkConduit.MASK_COUNT:J
land
lconst_0
lcmp
ifne 11
StackMap locals: long int
StackMap stack:
3: iload 3
ifeq 11
4: lload 4
ldc 4611686018427387904
lor
lstore 4
5: lload 1
ldc 2305843009213693952
invokestatic org.xnio.Bits.anyAreSet:(JJ)Z
ifne 8
lload 4
getstatic io.undertow.conduits.AbstractFixedLengthStreamSinkConduit.MASK_COUNT:J
land
lconst_0
lcmp
ifne 8
6: lload 4
ldc 2305843009213693952
lor
lstore 4
7: iconst_1
istore 6
8: StackMap locals:
StackMap stack:
aload 0
lload 4
putfield io.undertow.conduits.AbstractFixedLengthStreamSinkConduit.state:J
9: iload 6
ifeq 11
10: aload 0
invokevirtual io.undertow.conduits.AbstractFixedLengthStreamSinkConduit.channelFinished:()V
11: StackMap locals:
StackMap stack:
return
end local 6 end local 4 end local 3 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 12 0 this Lio/undertow/conduits/AbstractFixedLengthStreamSinkConduit;
0 12 1 oldVal J
0 12 3 flushed Z
1 12 4 newVal J
2 12 6 callFinish Z
MethodParameters:
Name Flags
oldVal
flushed
protected void channelFinished();
descriptor: ()V
flags: (0x0004) ACC_PROTECTED
Code:
stack=0, locals=1, args_size=1
start local 0 0: return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/undertow/conduits/AbstractFixedLengthStreamSinkConduit;
private long enterShutdown();
descriptor: ()J
flags: (0x0002) ACC_PRIVATE
Code:
stack=4, locals=5, args_size=1
start local 0 0: aload 0
getfield io.undertow.conduits.AbstractFixedLengthStreamSinkConduit.state:J
lstore 1
start local 1 1: lload 1
ldc -4611686018427387904
invokestatic org.xnio.Bits.anyAreSet:(JJ)Z
ifeq 3
2: lload 1
lreturn
3: StackMap locals: long
StackMap stack:
lload 1
ldc -9223372036854775808
lor
lstore 3
start local 3 4: lload 1
getstatic io.undertow.conduits.AbstractFixedLengthStreamSinkConduit.MASK_COUNT:J
invokestatic org.xnio.Bits.anyAreSet:(JJ)Z
ifeq 6
5: lload 3
ldc 4611686018427387904
lor
lstore 3
6: StackMap locals: long
StackMap stack:
aload 0
lload 3
putfield io.undertow.conduits.AbstractFixedLengthStreamSinkConduit.state:J
7: lload 1
lreturn
end local 3 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 8 0 this Lio/undertow/conduits/AbstractFixedLengthStreamSinkConduit;
1 8 1 oldVal J
4 8 3 newVal J
}
Signature: Lorg/xnio/conduits/AbstractStreamSinkConduit<Lorg/xnio/conduits/StreamSinkConduit;>;
SourceFile: "AbstractFixedLengthStreamSinkConduit.java"