Module kala.compress.archivers.zip

Package kala.compress.archivers.zip

Class ZipArchiveReader.BoundedFileChannelInputStream

java.lang.Object

java.io.InputStream

kala.compress.utils.BoundedArchiveInputStream

kala.compress.archivers.zip.ZipArchiveReader.BoundedFileChannelInputStream

All Implemented Interfaces:

Closeable, AutoCloseable

Enclosing class:

ZipArchiveReader

private static class ZipArchiveReader.BoundedFileChannelInputStream
extends BoundedArchiveInputStream

Lock-free implementation of BoundedInputStream. The implementation uses positioned reads on the underlying archive file channel and therefore performs significantly faster in concurrent environment.

Field Summary

Fields

Modifier and Type	Field	Description
private final FileChannel	archive

Constructor Summary

Constructors

Constructor	Description
BoundedFileChannelInputStream(long start, long remaining, FileChannel archive)

Method Summary

Modifier and Type	Method	Description
protected int	read(long pos, ByteBuffer buf)	Reads content of the stream into a ByteBuffer.

Methods inherited from class kala.compress.utils.BoundedArchiveInputStream

read, read

Methods inherited from class java.io.InputStream

available, close, mark, markSupported, nullInputStream, read, readAllBytes, readNBytes, readNBytes, reset, skip, skipNBytes, transferTo

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

archive

private final FileChannel archive

Constructor Details

BoundedFileChannelInputStream

BoundedFileChannelInputStream(long start,
 long remaining,
 FileChannel archive)

Method Details

read

protected int read(long pos,
 ByteBuffer buf)
            throws IOException

Description copied from class: BoundedArchiveInputStream

Reads content of the stream into a ByteBuffer.

Specified by:

read in class BoundedArchiveInputStream

Parameters:

pos - position to start the read.

buf - buffer to add the read content.

Returns:

number of read bytes.

Throws:

IOException - if I/O fails.