public class org.apache.commons.compress.utils.FixedLengthBlockOutputStream extends java.io.OutputStream implements java.nio.channels.WritableByteChannel
minor version: 0
major version: 59
flags: flags: (0x0021) ACC_PUBLIC, ACC_SUPER
this_class: org.apache.commons.compress.utils.FixedLengthBlockOutputStream
super_class: java.io.OutputStream
{
private final java.nio.channels.WritableByteChannel out;
descriptor: Ljava/nio/channels/WritableByteChannel;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
private final int blockSize;
descriptor: I
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
private final java.nio.ByteBuffer buffer;
descriptor: Ljava/nio/ByteBuffer;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
private final java.util.concurrent.atomic.AtomicBoolean closed;
descriptor: Ljava/util/concurrent/atomic/AtomicBoolean;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
public void <init>(java.io.OutputStream, int);
descriptor: (Ljava/io/OutputStream;I)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=4, locals=4, args_size=3
start local 0 start local 1 start local 2 0: aload 0
invokespecial java.io.OutputStream.<init>:()V
1: aload 0
new java.util.concurrent.atomic.AtomicBoolean
dup
iconst_0
invokespecial java.util.concurrent.atomic.AtomicBoolean.<init>:(Z)V
putfield org.apache.commons.compress.utils.FixedLengthBlockOutputStream.closed:Ljava/util/concurrent/atomic/AtomicBoolean;
2: aload 1
instanceof java.io.FileOutputStream
ifeq 7
3: aload 1
checkcast java.io.FileOutputStream
astore 3
start local 3 4: aload 0
aload 3
invokevirtual java.io.FileOutputStream.getChannel:()Ljava/nio/channels/FileChannel;
putfield org.apache.commons.compress.utils.FixedLengthBlockOutputStream.out:Ljava/nio/channels/WritableByteChannel;
5: aload 0
iload 2
invokestatic java.nio.ByteBuffer.allocateDirect:(I)Ljava/nio/ByteBuffer;
putfield org.apache.commons.compress.utils.FixedLengthBlockOutputStream.buffer:Ljava/nio/ByteBuffer;
end local 3 6: goto 9
7: StackMap locals: org.apache.commons.compress.utils.FixedLengthBlockOutputStream java.io.OutputStream int
StackMap stack:
aload 0
new org.apache.commons.compress.utils.FixedLengthBlockOutputStream$BufferAtATimeOutputChannel
dup
aload 1
invokespecial org.apache.commons.compress.utils.FixedLengthBlockOutputStream$BufferAtATimeOutputChannel.<init>:(Ljava/io/OutputStream;)V
putfield org.apache.commons.compress.utils.FixedLengthBlockOutputStream.out:Ljava/nio/channels/WritableByteChannel;
8: aload 0
iload 2
invokestatic java.nio.ByteBuffer.allocate:(I)Ljava/nio/ByteBuffer;
putfield org.apache.commons.compress.utils.FixedLengthBlockOutputStream.buffer:Ljava/nio/ByteBuffer;
9: StackMap locals:
StackMap stack:
aload 0
iload 2
putfield org.apache.commons.compress.utils.FixedLengthBlockOutputStream.blockSize:I
10: return
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 11 0 this Lorg/apache/commons/compress/utils/FixedLengthBlockOutputStream;
0 11 1 os Ljava/io/OutputStream;
0 11 2 blockSize I
4 6 3 fileOutputStream Ljava/io/FileOutputStream;
MethodParameters:
Name Flags
os
blockSize
public void <init>(java.nio.channels.WritableByteChannel, int);
descriptor: (Ljava/nio/channels/WritableByteChannel;I)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=4, locals=3, args_size=3
start local 0 start local 1 start local 2 0: aload 0
invokespecial java.io.OutputStream.<init>:()V
1: aload 0
new java.util.concurrent.atomic.AtomicBoolean
dup
iconst_0
invokespecial java.util.concurrent.atomic.AtomicBoolean.<init>:(Z)V
putfield org.apache.commons.compress.utils.FixedLengthBlockOutputStream.closed:Ljava/util/concurrent/atomic/AtomicBoolean;
2: aload 0
aload 1
putfield org.apache.commons.compress.utils.FixedLengthBlockOutputStream.out:Ljava/nio/channels/WritableByteChannel;
3: aload 0
iload 2
putfield org.apache.commons.compress.utils.FixedLengthBlockOutputStream.blockSize:I
4: aload 0
iload 2
invokestatic java.nio.ByteBuffer.allocateDirect:(I)Ljava/nio/ByteBuffer;
putfield org.apache.commons.compress.utils.FixedLengthBlockOutputStream.buffer:Ljava/nio/ByteBuffer;
5: return
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 6 0 this Lorg/apache/commons/compress/utils/FixedLengthBlockOutputStream;
0 6 1 out Ljava/nio/channels/WritableByteChannel;
0 6 2 blockSize I
MethodParameters:
Name Flags
out
blockSize
private void maybeFlush();
descriptor: ()V
flags: (0x0002) ACC_PRIVATE
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield org.apache.commons.compress.utils.FixedLengthBlockOutputStream.buffer:Ljava/nio/ByteBuffer;
invokevirtual java.nio.ByteBuffer.hasRemaining:()Z
ifne 2
1: aload 0
invokevirtual org.apache.commons.compress.utils.FixedLengthBlockOutputStream.writeBlock:()V
2: StackMap locals:
StackMap stack:
return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 this Lorg/apache/commons/compress/utils/FixedLengthBlockOutputStream;
Exceptions:
throws java.io.IOException
private void writeBlock();
descriptor: ()V
flags: (0x0002) ACC_PRIVATE
Code:
stack=5, locals=4, args_size=1
start local 0 0: aload 0
getfield org.apache.commons.compress.utils.FixedLengthBlockOutputStream.buffer:Ljava/nio/ByteBuffer;
invokevirtual java.nio.ByteBuffer.flip:()Ljava/nio/Buffer;
pop
1: aload 0
getfield org.apache.commons.compress.utils.FixedLengthBlockOutputStream.out:Ljava/nio/channels/WritableByteChannel;
aload 0
getfield org.apache.commons.compress.utils.FixedLengthBlockOutputStream.buffer:Ljava/nio/ByteBuffer;
invokeinterface java.nio.channels.WritableByteChannel.write:(Ljava/nio/ByteBuffer;)I
istore 1
start local 1 2: aload 0
getfield org.apache.commons.compress.utils.FixedLengthBlockOutputStream.buffer:Ljava/nio/ByteBuffer;
invokevirtual java.nio.ByteBuffer.hasRemaining:()Z
istore 2
start local 2 3: iload 1
aload 0
getfield org.apache.commons.compress.utils.FixedLengthBlockOutputStream.blockSize:I
if_icmpne 4
iload 2
ifeq 9
4: StackMap locals: int int
StackMap stack:
ldc "Failed to write %,d bytes atomically. Only wrote %,d"
iconst_2
anewarray java.lang.Object
dup
iconst_0
5: aload 0
getfield org.apache.commons.compress.utils.FixedLengthBlockOutputStream.blockSize:I
invokestatic java.lang.Integer.valueOf:(I)Ljava/lang/Integer;
aastore
dup
iconst_1
iload 1
invokestatic java.lang.Integer.valueOf:(I)Ljava/lang/Integer;
aastore
6: invokestatic java.lang.String.format:(Ljava/lang/String;[Ljava/lang/Object;)Ljava/lang/String;
7: astore 3
start local 3 8: new java.io.IOException
dup
aload 3
invokespecial java.io.IOException.<init>:(Ljava/lang/String;)V
athrow
end local 3 9: StackMap locals:
StackMap stack:
aload 0
getfield org.apache.commons.compress.utils.FixedLengthBlockOutputStream.buffer:Ljava/nio/ByteBuffer;
invokevirtual java.nio.ByteBuffer.clear:()Ljava/nio/Buffer;
pop
10: return
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 11 0 this Lorg/apache/commons/compress/utils/FixedLengthBlockOutputStream;
2 11 1 i I
3 11 2 hasRemaining Z
8 9 3 msg Ljava/lang/String;
Exceptions:
throws java.io.IOException
public void write(int);
descriptor: (I)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 0
invokevirtual org.apache.commons.compress.utils.FixedLengthBlockOutputStream.isOpen:()Z
ifne 2
1: new java.nio.channels.ClosedChannelException
dup
invokespecial java.nio.channels.ClosedChannelException.<init>:()V
athrow
2: StackMap locals:
StackMap stack:
aload 0
getfield org.apache.commons.compress.utils.FixedLengthBlockOutputStream.buffer:Ljava/nio/ByteBuffer;
iload 1
i2b
invokevirtual java.nio.ByteBuffer.put:(B)Ljava/nio/ByteBuffer;
pop
3: aload 0
invokevirtual org.apache.commons.compress.utils.FixedLengthBlockOutputStream.maybeFlush:()V
4: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 5 0 this Lorg/apache/commons/compress/utils/FixedLengthBlockOutputStream;
0 5 1 b I
Exceptions:
throws java.io.IOException
MethodParameters:
Name Flags
b
public void write(byte[], int, int);
descriptor: ([BII)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=4, locals=7, args_size=4
start local 0 start local 1 start local 2 start local 3 0: aload 0
invokevirtual org.apache.commons.compress.utils.FixedLengthBlockOutputStream.isOpen:()Z
ifne 2
1: new java.nio.channels.ClosedChannelException
dup
invokespecial java.nio.channels.ClosedChannelException.<init>:()V
athrow
2: StackMap locals:
StackMap stack:
iload 2
istore 4
start local 4 3: iload 3
istore 5
start local 5 4: goto 10
5: StackMap locals: int int
StackMap stack:
iload 5
aload 0
getfield org.apache.commons.compress.utils.FixedLengthBlockOutputStream.buffer:Ljava/nio/ByteBuffer;
invokevirtual java.nio.ByteBuffer.remaining:()I
invokestatic java.lang.Math.min:(II)I
istore 6
start local 6 6: aload 0
getfield org.apache.commons.compress.utils.FixedLengthBlockOutputStream.buffer:Ljava/nio/ByteBuffer;
aload 1
iload 4
iload 6
invokevirtual java.nio.ByteBuffer.put:([BII)Ljava/nio/ByteBuffer;
pop
7: aload 0
invokevirtual org.apache.commons.compress.utils.FixedLengthBlockOutputStream.maybeFlush:()V
8: iload 5
iload 6
isub
istore 5
9: iload 4
iload 6
iadd
istore 4
end local 6 10: StackMap locals:
StackMap stack:
iload 5
ifgt 5
11: return
end local 5 end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 12 0 this Lorg/apache/commons/compress/utils/FixedLengthBlockOutputStream;
0 12 1 b [B
0 12 2 offset I
0 12 3 length I
3 12 4 off I
4 12 5 len I
6 10 6 n I
Exceptions:
throws java.io.IOException
MethodParameters:
Name Flags
b
offset final
length final
public int write(java.nio.ByteBuffer);
descriptor: (Ljava/nio/ByteBuffer;)I
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=6, args_size=2
start local 0 start local 1 0: aload 0
invokevirtual org.apache.commons.compress.utils.FixedLengthBlockOutputStream.isOpen:()Z
ifne 2
1: new java.nio.channels.ClosedChannelException
dup
invokespecial java.nio.channels.ClosedChannelException.<init>:()V
athrow
2: StackMap locals:
StackMap stack:
aload 1
invokevirtual java.nio.ByteBuffer.remaining:()I
istore 2
start local 2 3: iload 2
aload 0
getfield org.apache.commons.compress.utils.FixedLengthBlockOutputStream.buffer:Ljava/nio/ByteBuffer;
invokevirtual java.nio.ByteBuffer.remaining:()I
if_icmpge 6
4: aload 0
getfield org.apache.commons.compress.utils.FixedLengthBlockOutputStream.buffer:Ljava/nio/ByteBuffer;
aload 1
invokevirtual java.nio.ByteBuffer.put:(Ljava/nio/ByteBuffer;)Ljava/nio/ByteBuffer;
pop
5: goto 21
6: StackMap locals: int
StackMap stack:
iload 2
istore 3
start local 3 7: aload 1
invokevirtual java.nio.ByteBuffer.limit:()I
istore 4
start local 4 8: aload 0
getfield org.apache.commons.compress.utils.FixedLengthBlockOutputStream.buffer:Ljava/nio/ByteBuffer;
invokevirtual java.nio.ByteBuffer.position:()I
ifeq 18
9: aload 0
getfield org.apache.commons.compress.utils.FixedLengthBlockOutputStream.buffer:Ljava/nio/ByteBuffer;
invokevirtual java.nio.ByteBuffer.remaining:()I
istore 5
start local 5 10: aload 1
aload 1
invokevirtual java.nio.ByteBuffer.position:()I
iload 5
iadd
invokevirtual java.nio.ByteBuffer.limit:(I)Ljava/nio/Buffer;
pop
11: aload 0
getfield org.apache.commons.compress.utils.FixedLengthBlockOutputStream.buffer:Ljava/nio/ByteBuffer;
aload 1
invokevirtual java.nio.ByteBuffer.put:(Ljava/nio/ByteBuffer;)Ljava/nio/ByteBuffer;
pop
12: aload 0
invokevirtual org.apache.commons.compress.utils.FixedLengthBlockOutputStream.writeBlock:()V
13: iload 3
iload 5
isub
istore 3
end local 5 14: goto 18
15: StackMap locals: int int
StackMap stack:
aload 1
aload 1
invokevirtual java.nio.ByteBuffer.position:()I
aload 0
getfield org.apache.commons.compress.utils.FixedLengthBlockOutputStream.blockSize:I
iadd
invokevirtual java.nio.ByteBuffer.limit:(I)Ljava/nio/Buffer;
pop
16: aload 0
getfield org.apache.commons.compress.utils.FixedLengthBlockOutputStream.out:Ljava/nio/channels/WritableByteChannel;
aload 1
invokeinterface java.nio.channels.WritableByteChannel.write:(Ljava/nio/ByteBuffer;)I
pop
17: iload 3
aload 0
getfield org.apache.commons.compress.utils.FixedLengthBlockOutputStream.blockSize:I
isub
istore 3
18: StackMap locals:
StackMap stack:
iload 3
aload 0
getfield org.apache.commons.compress.utils.FixedLengthBlockOutputStream.blockSize:I
if_icmpge 15
19: aload 1
iload 4
invokevirtual java.nio.ByteBuffer.limit:(I)Ljava/nio/Buffer;
pop
20: aload 0
getfield org.apache.commons.compress.utils.FixedLengthBlockOutputStream.buffer:Ljava/nio/ByteBuffer;
aload 1
invokevirtual java.nio.ByteBuffer.put:(Ljava/nio/ByteBuffer;)Ljava/nio/ByteBuffer;
pop
end local 4 end local 3 21: StackMap locals:
StackMap stack:
iload 2
ireturn
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 22 0 this Lorg/apache/commons/compress/utils/FixedLengthBlockOutputStream;
0 22 1 src Ljava/nio/ByteBuffer;
3 22 2 srcRemaining I
7 21 3 srcLeft I
8 21 4 savedLimit I
10 14 5 n I
Exceptions:
throws java.io.IOException
MethodParameters:
Name Flags
src
public boolean isOpen();
descriptor: ()Z
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=1, args_size=1
start local 0 0: aload 0
getfield org.apache.commons.compress.utils.FixedLengthBlockOutputStream.out:Ljava/nio/channels/WritableByteChannel;
invokeinterface java.nio.channels.WritableByteChannel.isOpen:()Z
ifne 2
1: aload 0
getfield org.apache.commons.compress.utils.FixedLengthBlockOutputStream.closed:Ljava/util/concurrent/atomic/AtomicBoolean;
iconst_1
invokevirtual java.util.concurrent.atomic.AtomicBoolean.set:(Z)V
2: StackMap locals:
StackMap stack:
aload 0
getfield org.apache.commons.compress.utils.FixedLengthBlockOutputStream.closed:Ljava/util/concurrent/atomic/AtomicBoolean;
invokevirtual java.util.concurrent.atomic.AtomicBoolean.get:()Z
ifeq 3
iconst_0
goto 4
StackMap locals:
StackMap stack:
3: iconst_1
StackMap locals:
StackMap stack: int
4: ireturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 5 0 this Lorg/apache/commons/compress/utils/FixedLengthBlockOutputStream;
public void flushBlock();
descriptor: ()V
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield org.apache.commons.compress.utils.FixedLengthBlockOutputStream.buffer:Ljava/nio/ByteBuffer;
invokevirtual java.nio.ByteBuffer.position:()I
ifeq 3
1: aload 0
invokevirtual org.apache.commons.compress.utils.FixedLengthBlockOutputStream.padBlock:()V
2: aload 0
invokevirtual org.apache.commons.compress.utils.FixedLengthBlockOutputStream.writeBlock:()V
3: StackMap locals:
StackMap stack:
return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 this Lorg/apache/commons/compress/utils/FixedLengthBlockOutputStream;
Exceptions:
throws java.io.IOException
public void close();
descriptor: ()V
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=2, args_size=1
start local 0 0: aload 0
getfield org.apache.commons.compress.utils.FixedLengthBlockOutputStream.closed:Ljava/util/concurrent/atomic/AtomicBoolean;
iconst_0
iconst_1
invokevirtual java.util.concurrent.atomic.AtomicBoolean.compareAndSet:(ZZ)Z
ifeq 7
1: aload 0
invokevirtual org.apache.commons.compress.utils.FixedLengthBlockOutputStream.flushBlock:()V
2: goto 6
StackMap locals:
StackMap stack: java.lang.Throwable
3: astore 1
4: aload 0
getfield org.apache.commons.compress.utils.FixedLengthBlockOutputStream.out:Ljava/nio/channels/WritableByteChannel;
invokeinterface java.nio.channels.WritableByteChannel.close:()V
5: aload 1
athrow
6: StackMap locals:
StackMap stack:
aload 0
getfield org.apache.commons.compress.utils.FixedLengthBlockOutputStream.out:Ljava/nio/channels/WritableByteChannel;
invokeinterface java.nio.channels.WritableByteChannel.close:()V
7: StackMap locals:
StackMap stack:
return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 8 0 this Lorg/apache/commons/compress/utils/FixedLengthBlockOutputStream;
Exception table:
from to target type
1 3 3 any
Exceptions:
throws java.io.IOException
private void padBlock();
descriptor: ()V
flags: (0x0002) ACC_PRIVATE
Code:
stack=3, locals=5, args_size=1
start local 0 0: aload 0
getfield org.apache.commons.compress.utils.FixedLengthBlockOutputStream.buffer:Ljava/nio/ByteBuffer;
invokestatic java.nio.ByteOrder.nativeOrder:()Ljava/nio/ByteOrder;
invokevirtual java.nio.ByteBuffer.order:(Ljava/nio/ByteOrder;)Ljava/nio/ByteBuffer;
pop
1: aload 0
getfield org.apache.commons.compress.utils.FixedLengthBlockOutputStream.buffer:Ljava/nio/ByteBuffer;
invokevirtual java.nio.ByteBuffer.remaining:()I
istore 1
start local 1 2: iload 1
bipush 8
if_icmple 18
3: aload 0
getfield org.apache.commons.compress.utils.FixedLengthBlockOutputStream.buffer:Ljava/nio/ByteBuffer;
invokevirtual java.nio.ByteBuffer.position:()I
bipush 7
iand
istore 2
start local 2 4: iload 2
ifeq 15
5: bipush 8
iload 2
isub
istore 3
start local 3 6: iconst_0
istore 4
start local 4 7: goto 10
8: StackMap locals: org.apache.commons.compress.utils.FixedLengthBlockOutputStream int int int int
StackMap stack:
aload 0
getfield org.apache.commons.compress.utils.FixedLengthBlockOutputStream.buffer:Ljava/nio/ByteBuffer;
iconst_0
invokevirtual java.nio.ByteBuffer.put:(B)Ljava/nio/ByteBuffer;
pop
9: iinc 4 1
StackMap locals:
StackMap stack:
10: iload 4
iload 3
if_icmplt 8
end local 4 11: iload 1
iload 3
isub
istore 1
end local 3 12: goto 15
13: StackMap locals:
StackMap stack:
aload 0
getfield org.apache.commons.compress.utils.FixedLengthBlockOutputStream.buffer:Ljava/nio/ByteBuffer;
lconst_0
invokevirtual java.nio.ByteBuffer.putLong:(J)Ljava/nio/ByteBuffer;
pop
14: iinc 1 -8
15: StackMap locals:
StackMap stack:
iload 1
bipush 8
if_icmpge 13
end local 2 16: goto 18
17: StackMap locals:
StackMap stack:
aload 0
getfield org.apache.commons.compress.utils.FixedLengthBlockOutputStream.buffer:Ljava/nio/ByteBuffer;
iconst_0
invokevirtual java.nio.ByteBuffer.put:(B)Ljava/nio/ByteBuffer;
pop
18: StackMap locals:
StackMap stack:
aload 0
getfield org.apache.commons.compress.utils.FixedLengthBlockOutputStream.buffer:Ljava/nio/ByteBuffer;
invokevirtual java.nio.ByteBuffer.hasRemaining:()Z
ifne 17
19: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 20 0 this Lorg/apache/commons/compress/utils/FixedLengthBlockOutputStream;
2 20 1 bytesToWrite I
4 16 2 align I
6 12 3 limit I
7 11 4 i I
}
SourceFile: "FixedLengthBlockOutputStream.java"
NestMembers:
org.apache.commons.compress.utils.FixedLengthBlockOutputStream$BufferAtATimeOutputChannel
InnerClasses:
private BufferAtATimeOutputChannel = org.apache.commons.compress.utils.FixedLengthBlockOutputStream$BufferAtATimeOutputChannel of org.apache.commons.compress.utils.FixedLengthBlockOutputStream