Class FastLzFrameDecoder
java.lang.Object
io.netty.channel.ChannelHandlerAdapter
io.netty.channel.ChannelInboundHandlerAdapter
io.netty.handler.codec.ByteToMessageDecoder
io.netty.handler.codec.compression.FastLzFrameDecoder
- All Implemented Interfaces:
ChannelHandler
,ChannelInboundHandler
-
Nested Class Summary
Nested ClassesModifier and TypeClassDescriptionprivate static enum
Current state of decompression.Nested classes/interfaces inherited from class io.netty.handler.codec.ByteToMessageDecoder
ByteToMessageDecoder.Cumulator
Nested classes/interfaces inherited from interface io.netty.channel.ChannelHandler
ChannelHandler.Sharable
-
Field Summary
FieldsModifier and TypeFieldDescriptionprivate final ByteBufChecksum
Underlying checksum calculator in use.private int
Length of current received chunk of data.private int
Checksum value of current received chunk of data which has checksum.private FastLzFrameDecoder.State
private boolean
Indicates is this chunk has checksum or not.private boolean
Indicates is this chunk compressed or not.private int
Original of current received chunk of data.Fields inherited from class io.netty.handler.codec.ByteToMessageDecoder
COMPOSITE_CUMULATOR, MERGE_CUMULATOR
-
Constructor Summary
ConstructorsConstructorDescriptionCreates the fastest FastLZ decoder without checksum calculation.FastLzFrameDecoder
(boolean validateChecksums) Creates a FastLZ decoder with calculation of checksums as specified.FastLzFrameDecoder
(Checksum checksum) Creates a FastLZ decoder with specified checksum calculator. -
Method Summary
Methods inherited from class io.netty.handler.codec.ByteToMessageDecoder
actualReadableBytes, callDecode, channelInactive, channelRead, channelReadComplete, decodeLast, discardSomeReadBytes, handlerRemoved, handlerRemoved0, internalBuffer, isSingleDecode, setCumulator, setDiscardAfterReads, setSingleDecode, userEventTriggered
Methods inherited from class io.netty.channel.ChannelInboundHandlerAdapter
channelActive, channelRegistered, channelUnregistered, channelWritabilityChanged, exceptionCaught
Methods inherited from class io.netty.channel.ChannelHandlerAdapter
ensureNotSharable, handlerAdded, isSharable
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
Methods inherited from interface io.netty.channel.ChannelHandler
handlerAdded
-
Field Details
-
currentState
-
checksum
Underlying checksum calculator in use. -
chunkLength
private int chunkLengthLength of current received chunk of data. -
originalLength
private int originalLengthOriginal of current received chunk of data. It is equal tochunkLength
for non compressed chunks. -
isCompressed
private boolean isCompressedIndicates is this chunk compressed or not. -
hasChecksum
private boolean hasChecksumIndicates is this chunk has checksum or not. -
currentChecksum
private int currentChecksumChecksum value of current received chunk of data which has checksum.
-
-
Constructor Details
-
FastLzFrameDecoder
public FastLzFrameDecoder()Creates the fastest FastLZ decoder without checksum calculation. -
FastLzFrameDecoder
public FastLzFrameDecoder(boolean validateChecksums) Creates a FastLZ decoder with calculation of checksums as specified.- Parameters:
validateChecksums
- If true, the checksum field will be validated against the actual uncompressed data, and if the checksums do not match, a suitableDecompressionException
will be thrown. Note, that in this case decoder will useAdler32
as a default checksum calculator.
-
FastLzFrameDecoder
Creates a FastLZ decoder with specified checksum calculator.- Parameters:
checksum
- theChecksum
instance to use to check data for integrity. You may setnull
if you do not want to validate checksum of each block.
-
-
Method Details
-
decode
Description copied from class:ByteToMessageDecoder
Decode the from oneByteBuf
to an other. This method will be called till either the inputByteBuf
has nothing to read when return from this method or till nothing was read from the inputByteBuf
.- Specified by:
decode
in classByteToMessageDecoder
- Parameters:
ctx
- theChannelHandlerContext
which thisByteToMessageDecoder
belongs toin
- theByteBuf
from which to read dataout
- theList
to which decoded messages should be added- Throws:
Exception
- is thrown if an error occurs
-