org.waarp.compress.zlib

Class ZlibCodec

java.lang.Object

org.waarp.compress.zlib.ZlibCodec

All Implemented Interfaces:

CompressorCodec

public class ZlibCodec
extends Object
implements CompressorCodec

ZSTD JNI Codec implementation

Constructor Summary

Constructors

Constructor and Description
ZlibCodec()

Method Summary

Modifier and Type	Method and Description
byte[]	compress(byte[] input, int inputLength)
int	compress(byte[] input, int inputLength, byte[] output, int maxOutputLength)
long	compress(File input, File output) Compress the file input to the file output
byte[]	decompress(byte[] compressed, int length)
int	decompress(byte[] input, int inputLength, byte[] output, int maxOutputLength)
long	decompress(File input, File output) Decompress the file input to the file output
byte[]	finishCodec() Finish the CoDec operation.
int	getDecompressedSize(byte[] compressed, int length)
void	initializeCodecForStream(int defaultBlockSize) Allow to specify a block size for CoDec
int	maxCompressedLength(int uncompressedSize)
byte[]	readCodec()
void	writeForCompression(byte[] uncompressed) Write an uncompressed data for compression
void	writeForCompression(io.netty.buffer.ByteBuf uncompressed) Write an uncompressed data for compression
void	writeForDecompression(byte[] compressed) Write a compressed data for decompression
void	writeForDecompression(io.netty.buffer.ByteBuf compressed) Write a compressed data for decompression

Methods inherited from class java.lang.Object

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

Constructor Detail

ZlibCodec

public ZlibCodec()

Method Detail

maxCompressedLength

public final int maxCompressedLength(int uncompressedSize)

Specified by:

maxCompressedLength in interface CompressorCodec

Returns:

the maximum size for Compressed length

compress

public final byte[] compress(byte[] input,
                             int inputLength)

Specified by:

compress in interface CompressorCodec

Returns:

the compressed byte array

compress

public final int compress(byte[] input,
                          int inputLength,
                          byte[] output,
                          int maxOutputLength)
                   throws MalformedInputException

Specified by:

compress in interface CompressorCodec

Returns:

the size of ouput

Throws:

MalformedInputException

compress

public final long compress(File input,
                           File output)
                    throws MalformedInputException

Description copied from interface: CompressorCodec

Compress the file input to the file output

Specified by:

compress in interface CompressorCodec

Returns:

the new length

Throws:

MalformedInputException

decompress

public final byte[] decompress(byte[] compressed,
                               int length)
                        throws MalformedInputException

Specified by:

decompress in interface CompressorCodec

Returns:

the decompressed byte array

Throws:

MalformedInputException

decompress

public final int decompress(byte[] input,
                            int inputLength,
                            byte[] output,
                            int maxOutputLength)
                     throws MalformedInputException

Specified by:

decompress in interface CompressorCodec

Returns:

the size of output

Throws:

MalformedInputException

decompress

public final long decompress(File input,
                             File output)
                      throws MalformedInputException

Description copied from interface: CompressorCodec

Decompress the file input to the file output

Specified by:

decompress in interface CompressorCodec

Returns:

the new length

Throws:

MalformedInputException

getDecompressedSize

public final int getDecompressedSize(byte[] compressed,
                                     int length)

Specified by:

getDecompressedSize in interface CompressorCodec

Returns:

the size of the decompressed array, 0 if unknown

initializeCodecForStream

public void initializeCodecForStream(int defaultBlockSize)

Allow to specify a block size for CoDec

Parameters:

defaultBlockSize -

writeForCompression

public void writeForCompression(byte[] uncompressed)
                         throws IOException

Write an uncompressed data for compression

Parameters:

uncompressed -

Throws:

IOException

writeForCompression

public void writeForCompression(io.netty.buffer.ByteBuf uncompressed)
                         throws IOException

Write an uncompressed data for compression

Parameters:

uncompressed -

Throws:

IOException

writeForDecompression

public void writeForDecompression(byte[] compressed)
                           throws IOException

Write a compressed data for decompression

Parameters:

compressed -

Throws:

IOException

writeForDecompression

public void writeForDecompression(io.netty.buffer.ByteBuf compressed)
                           throws IOException

Write a compressed data for decompression

Parameters:

compressed -

Throws:

IOException

readCodec

public byte[] readCodec()

Returns:

the current available block byte array (releasing it immediately)

finishCodec

public byte[] finishCodec()
                   throws IOException

Finish the CoDec operation. The Codec is ready to be reused.

Important: calling this method is mandatory to prevent OOME

Returns:

the final block byte array

Throws:

IOException