public class SnappyFramedDecoder extends ByteToMessageDecoder
ByteBuf
encoded with the Snappy framing format.
See http://code.google.com/p/snappy/source/browse/trunk/framing_format.txt
Note that by default, validation of the checksum header in each chunk is
DISABLED for performance improvements. If performance is less of an issue,
or if you would prefer the safety that checksum validation brings, please
use the SnappyFramedDecoder(boolean)
constructor with the argument
set to true
.ChannelHandler.Sharable
Constructor and Description |
---|
SnappyFramedDecoder()
Creates a new snappy-framed decoder with validation of checksums
turned OFF.
|
SnappyFramedDecoder(boolean validateChecksums)
Creates a new snappy-framed decoder with validation of checksums
as specified.
|
Modifier and Type | Method and Description |
---|---|
protected void |
decode(ChannelHandlerContext ctx,
ByteBuf in,
List<Object> out)
Decode the from one
ByteBuf to an other. |
actualReadableBytes, callDecode, channelInactive, channelRead, channelReadComplete, decodeLast, handlerRemoved, handlerRemoved0, internalBuffer, isSingleDecode, setSingleDecode
channelActive, channelRegistered, channelUnregistered, channelWritabilityChanged, exceptionCaught, userEventTriggered
handlerAdded, isSharable
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
handlerAdded
public SnappyFramedDecoder()
SnappyFramedDecoder(boolean)
constructor.public SnappyFramedDecoder(boolean validateChecksums)
validateChecksums
- If true, the checksum field will be validated against the actual
uncompressed data, and if the checksums do not match, a suitable
DecompressionException
will be thrownprotected void decode(ChannelHandlerContext ctx, ByteBuf in, List<Object> out) throws Exception
ByteToMessageDecoder
ByteBuf
to an other. This method will be called till either the input
ByteBuf
has nothing to read anymore, till nothing was read from the input ByteBuf
or till
this method returns null
.decode
in class ByteToMessageDecoder
ctx
- the ChannelHandlerContext
which this ByteToMessageDecoder
belongs toin
- the ByteBuf
from which to read dataout
- the List
to which decoded messages should be addedException
- is thrown if an error accourCopyright © 2008–2013 The Netty Project. All rights reserved.