Class BaseZstdBufferDecompressingStreamNoFinalizer

java.lang.Object

com.github.luben.zstd.BaseZstdBufferDecompressingStreamNoFinalizer

All Implemented Interfaces:

Closeable, AutoCloseable

Direct Known Subclasses:

ZstdBufferDecompressingStreamNoFinalizer, ZstdDirectBufferDecompressingStreamNoFinalizer

public abstract class BaseZstdBufferDecompressingStreamNoFinalizer
extends Object
implements Closeable

Field Summary

Fields

Modifier and Type	Field	Description
protected boolean	closed
private int	consumed
private boolean	finishedFrame
private int	produced
protected ByteBuffer	source
protected long	stream
private boolean	streamEnd

Constructor Summary

Constructors

Constructor	Description
BaseZstdBufferDecompressingStreamNoFinalizer(ByteBuffer source)

Method Summary

Modifier and Type	Method	Description
void	close()
(package private) abstract long	createDStream()
(package private) abstract long	decompressStream(long stream, ByteBuffer dst, int dstOffset, int dstSize, ByteBuffer src, int srcOffset, int srcSize)
(package private) abstract long	freeDStream(long stream)
boolean	hasRemaining()
(package private) abstract long	initDStream(long stream)
abstract int	read(ByteBuffer target)
(package private) int	readInternal(ByteBuffer target, boolean isDirectBufferRequired)
protected ByteBuffer	refill(ByteBuffer toRefill)	Override this method in case the byte buffer passed to the constructor might not contain the full compressed stream
BaseZstdBufferDecompressingStreamNoFinalizer	setDict(byte[] dict)
BaseZstdBufferDecompressingStreamNoFinalizer	setDict(ZstdDictDecompress dict)
BaseZstdBufferDecompressingStreamNoFinalizer	setLongMax(int windowLogMax)

Methods inherited from class Object

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

Field Details

stream

protected long stream

source

protected ByteBuffer source

closed

protected boolean closed

finishedFrame

private boolean finishedFrame

streamEnd

private boolean streamEnd

consumed

private int consumed

produced

private int produced

Constructor Details

BaseZstdBufferDecompressingStreamNoFinalizer

BaseZstdBufferDecompressingStreamNoFinalizer(ByteBuffer source)

Method Details

refill

protected ByteBuffer refill(ByteBuffer toRefill)

Override this method in case the byte buffer passed to the constructor might not contain the full compressed stream

Parameters:

toRefill - current buffer

Returns:

either the current buffer (but refilled and flipped if there was new content) or a new buffer.

hasRemaining

public boolean hasRemaining()

setDict

public BaseZstdBufferDecompressingStreamNoFinalizer setDict(byte[] dict)
                                                     throws IOException

Throws:

IOException

setDict

public BaseZstdBufferDecompressingStreamNoFinalizer setDict(ZstdDictDecompress dict)
                                                     throws IOException

Throws:

IOException

setLongMax

public BaseZstdBufferDecompressingStreamNoFinalizer setLongMax(int windowLogMax)
                                                        throws IOException

Throws:

IOException

readInternal

int readInternal(ByteBuffer target,
 boolean isDirectBufferRequired)
          throws IOException

Throws:

IOException

close

public void close()

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable

read

public abstract int read(ByteBuffer target)
                  throws IOException

Throws:

IOException

createDStream

abstract long createDStream()

freeDStream

abstract long freeDStream(long stream)

initDStream

abstract long initDStream(long stream)

decompressStream

abstract long decompressStream(long stream,
 ByteBuffer dst,
 int dstOffset,
 int dstSize,
 ByteBuffer src,
 int srcOffset,
 int srcSize)