Class Bzip2Decoder
- java.lang.Object
-
- io.netty.channel.ChannelHandlerAdapter
-
- io.netty.channel.ChannelInboundHandlerAdapter
-
- io.netty.handler.codec.ByteToMessageDecoder
-
- io.netty.handler.codec.compression.Bzip2Decoder
-
- All Implemented Interfaces:
ChannelHandler
,ChannelInboundHandler
public class Bzip2Decoder extends ByteToMessageDecoder
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description private static class
Bzip2Decoder.State
Current state of stream.-
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
Fields Modifier and Type Field Description private int
blockCRC
The CRC of the current block as read from the block header.private Bzip2BlockDecompressor
blockDecompressor
The decompressor for the current block.private int
blockSize
Always: in the range 0 ..private Bzip2Decoder.State
currentState
private Bzip2HuffmanStageDecoder
huffmanStageDecoder
Bzip2 Huffman coding stage.private Bzip2BitReader
reader
A reader that provides bit-level reads.private int
streamCRC
The merged CRC of all blocks decompressed so far.-
Fields inherited from class io.netty.handler.codec.ByteToMessageDecoder
COMPOSITE_CUMULATOR, MERGE_CUMULATOR
-
-
Constructor Summary
Constructors Constructor Description Bzip2Decoder()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description protected void
decode(ChannelHandlerContext ctx, ByteBuf in, java.util.List<java.lang.Object> out)
Decode the from oneByteBuf
to an other.boolean
isClosed()
Returnstrue
if and only if the end of the compressed stream has been reached.-
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 Detail
-
currentState
private Bzip2Decoder.State currentState
-
reader
private final Bzip2BitReader reader
A reader that provides bit-level reads.
-
blockDecompressor
private Bzip2BlockDecompressor blockDecompressor
The decompressor for the current block.
-
huffmanStageDecoder
private Bzip2HuffmanStageDecoder huffmanStageDecoder
Bzip2 Huffman coding stage.
-
blockSize
private int blockSize
Always: in the range 0 .. 9. The current block size is 100000 * this number.
-
blockCRC
private int blockCRC
The CRC of the current block as read from the block header.
-
streamCRC
private int streamCRC
The merged CRC of all blocks decompressed so far.
-
-
Method Detail
-
decode
protected void decode(ChannelHandlerContext ctx, ByteBuf in, java.util.List<java.lang.Object> out) throws java.lang.Exception
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:
java.lang.Exception
- is thrown if an error occurs
-
isClosed
public boolean isClosed()
Returnstrue
if and only if the end of the compressed stream has been reached.
-
-