Class TagReaderImpl.InputStreamDecoder

java.lang.Object

org.infinispan.protostream.impl.TagReaderImpl.Decoder

org.infinispan.protostream.impl.TagReaderImpl.InputStreamDecoder

Enclosing class:

TagReaderImpl

private static final class TagReaderImpl.InputStreamDecoder
extends TagReaderImpl.Decoder

Since:

3.0

Field Summary

Fields

Modifier and Type	Field	Description
private final InputStream	in
private int	limit	Absolute position (from start of input data) of the last byte we are allowed to read by last pushLimit.
private int	pos	Current position.

Fields inherited from class TagReaderImpl.Decoder

globalLimit, lastTag

Constructor Summary

Constructors

Modifier	Constructor	Description
private	InputStreamDecoder(InputStream in)

Method Summary

Modifier and Type	Method	Description
(package private) byte[]	getBufferArray()
(package private) int	getEnd()
(package private) InputStream	getInputStream()
(package private) int	getPos()
(package private) boolean	isAtEnd()
private boolean	isMarkDone()
private boolean	isPushbackDone()
(package private) void	popLimit(int oldLimit)
(package private) int	pushLimit(int limit)
(package private) int	readFixed32()
(package private) long	readFixed64()
(package private) byte	readRawByte()
(package private) byte[]	readRawByteArray(int length)
(package private) ByteBuffer	readRawByteBuffer(int length)
(package private) String	readString()
(package private) long	readVarint64()
(package private) int	setGlobalLimit(int globalLimit)	Sets a hard limit on how many bytes we can continue to read while parsing a message from current position.
private void	skipNBytes(long n)
protected void	skipRawBytes(int length)
protected void	skipVarint()

Methods inherited from class TagReaderImpl.Decoder

checkLastTagWas, readTag, readVarint32, skipField

Methods inherited from class Object

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

Field Details

in

private final InputStream in

pos

private int pos

Current position.

limit

private int limit

Absolute position (from start of input data) of the last byte we are allowed to read by last pushLimit.

Constructor Details

InputStreamDecoder

private InputStreamDecoder(InputStream in)

Method Details

readString

String readString()
           throws IOException

Specified by:

readString in class TagReaderImpl.Decoder

Throws:

IOException

readRawByteBuffer

ByteBuffer readRawByteBuffer(int length)
                      throws IOException

Specified by:

readRawByteBuffer in class TagReaderImpl.Decoder

Throws:

IOException

skipVarint

protected void skipVarint()
                   throws IOException

Specified by:

skipVarint in class TagReaderImpl.Decoder

Throws:

IOException

readVarint64

long readVarint64()
           throws IOException

Specified by:

readVarint64 in class TagReaderImpl.Decoder

Throws:

IOException

readFixed32

int readFixed32()
         throws IOException

Specified by:

readFixed32 in class TagReaderImpl.Decoder

Throws:

IOException

readFixed64

long readFixed64()
          throws IOException

Specified by:

readFixed64 in class TagReaderImpl.Decoder

Throws:

IOException

setGlobalLimit

int setGlobalLimit(int globalLimit)

Description copied from class: TagReaderImpl.Decoder

Sets a hard limit on how many bytes we can continue to read while parsing a message from current position. This is useful to prevent corrupted or malicious messages with wrong length values to abuse memory allocation. Initially this limit is set to Integer.MAX_INT, which means the protection mechanism is disabled by default. The limit is only useful when processing streams. Setting a limit for a decoder backed by a byte array is useless because the memory allocation already happened.

Specified by:

setGlobalLimit in class TagReaderImpl.Decoder

pushLimit

int pushLimit(int limit)
       throws IOException

Specified by:

pushLimit in class TagReaderImpl.Decoder

Throws:

IOException

popLimit

void popLimit(int oldLimit)

Specified by:

popLimit in class TagReaderImpl.Decoder

getEnd

int getEnd()

Specified by:

getEnd in class TagReaderImpl.Decoder

getPos

int getPos()

Specified by:

getPos in class TagReaderImpl.Decoder

getBufferArray

byte[] getBufferArray()
               throws IOException

Specified by:

getBufferArray in class TagReaderImpl.Decoder

Throws:

IOException

getInputStream

InputStream getInputStream()

isAtEnd

boolean isAtEnd()
         throws IOException

Specified by:

isAtEnd in class TagReaderImpl.Decoder

Throws:

IOException

isPushbackDone

private boolean isPushbackDone()
                        throws IOException

Throws:

IOException

isMarkDone

private boolean isMarkDone()
                    throws IOException

Throws:

IOException

readRawByte

byte readRawByte()
          throws IOException

Specified by:

readRawByte in class TagReaderImpl.Decoder

Throws:

IOException

readRawByteArray

byte[] readRawByteArray(int length)
                 throws IOException

Specified by:

readRawByteArray in class TagReaderImpl.Decoder

Throws:

IOException

skipRawBytes

protected void skipRawBytes(int length)
                     throws IOException

Specified by:

skipRawBytes in class TagReaderImpl.Decoder

Throws:

IOException

skipNBytes

private void skipNBytes(long n)
                 throws IOException

Throws:

IOException