Package org.infinispan.protostream.impl

Class TagReaderImpl.ByteBufferDecoder

java.lang.Object

org.infinispan.protostream.impl.TagReaderImpl.Decoder

org.infinispan.protostream.impl.TagReaderImpl.ByteBufferDecoder

Enclosing class:

TagReaderImpl

private static final class TagReaderImpl.ByteBufferDecoder
extends TagReaderImpl.Decoder

Field Summary

Fields

Modifier and Type	Field	Description
private final ByteBuffer	buf
private int	end
private int	limit
private final int	start
private final int	stop

Fields inherited from class org.infinispan.protostream.impl.TagReaderImpl.Decoder

globalLimit, lastTag

Constructor Summary

Constructors

Modifier	Constructor	Description
private	ByteBufferDecoder(ByteBuffer buf)

Method Summary

Modifier and Type	Method	Description
private void	adjustEnd()
(package private) byte[]	getBufferArray()
(package private) int	getEnd()
(package private) int	getPos()
(package private) boolean	isAtEnd()
(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.
protected void	skipRawBytes(int length)
protected void	skipVarint()

Methods inherited from class org.infinispan.protostream.impl.TagReaderImpl.Decoder

checkLastTagWas, readTag, readVarint32, skipField

Methods inherited from class java.lang.Object

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

Field Details

buf

private final ByteBuffer buf

start

private final int start

stop

private final int stop

end

private int end

limit

private int limit

Constructor Details

ByteBufferDecoder

private ByteBufferDecoder(ByteBuffer buf)

Method Details

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

adjustEnd

private void adjustEnd()

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

isAtEnd

boolean isAtEnd()

Specified by:

isAtEnd in class TagReaderImpl.Decoder

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

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

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