Package org.infinispan.protostream.impl

Class TagWriterImpl.ByteArrayEncoder

java.lang.Object

org.infinispan.protostream.impl.TagWriterImpl.Encoder

org.infinispan.protostream.impl.TagWriterImpl.ByteArrayEncoder

Direct Known Subclasses:

TagWriterImpl.HeapByteBufferEncoder

Enclosing class:

TagWriterImpl

private static class TagWriterImpl.ByteArrayEncoder
extends TagWriterImpl.Encoder

Writes to a user provided byte array.

Field Summary

Fields

Modifier and Type	Field	Description
private final byte[]	array
protected final int	limit
protected final int	offset
protected int	pos

Constructor Summary

Constructors

Modifier	Constructor	Description
private	ByteArrayEncoder(byte[] array, int offset, int length)

Method Summary

Modifier and Type	Method	Description
protected final void	fillFromBuffer(ByteBuffer byteBuffer)	Copies from byteBuffer buffer to our internal buffer the maximum bytes allowed by the available space and the remaining bytes.
protected final void	flushToStream(OutputStream out)	Flush the entire buffer to an output stream.
protected final void	flushToStream(OutputStream out, int requiredSpace)	Make room for the required space by flushing the entire buffer to stream if the available space is not enough.
protected final int	remainingSpace()
(package private) final void	writeByte(byte value)
(package private) final void	writeBytes(byte[] value, int offset, int length)
(package private) final void	writeBytes(ByteBuffer value)
(package private) final void	writeFixed32(int value)
(package private) final void	writeFixed64(long value)
(package private) final void	writeVarint32(int value)
(package private) final void	writeVarint64(long value)

Methods inherited from class org.infinispan.protostream.impl.TagWriterImpl.Encoder

flush, writeBoolField, writeFixed32Field, writeFixed64Field, writeLengthDelimitedField, writeUInt32Field, writeUInt64Field

Methods inherited from class java.lang.Object

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

Field Details

array

private final byte[] array

offset

protected final int offset

limit

protected final int limit

pos

protected int pos

Constructor Details

ByteArrayEncoder

private ByteArrayEncoder(byte[] array,
 int offset,
 int length)

Method Details

remainingSpace

protected final int remainingSpace()

flushToStream

protected final void flushToStream(OutputStream out,
 int requiredSpace)
                            throws IOException

Make room for the required space by flushing the entire buffer to stream if the available space is not enough.

Throws:

IOException

flushToStream

protected final void flushToStream(OutputStream out)
                            throws IOException

Flush the entire buffer to an output stream.

Throws:

IOException

fillFromBuffer

protected final void fillFromBuffer(ByteBuffer byteBuffer)

Copies from byteBuffer buffer to our internal buffer the maximum bytes allowed by the available space and the remaining bytes. Multiple invocations preceded by a flushToStream(OutputStream) invocation are needed if the byteBuffer buffer still has remaining bytes after this call.

writeByte

final void writeByte(byte value)
              throws IOException

Specified by:

writeByte in class TagWriterImpl.Encoder

Throws:

IOException

writeBytes

final void writeBytes(byte[] value,
 int offset,
 int length)
               throws IOException

Specified by:

writeBytes in class TagWriterImpl.Encoder

Throws:

IOException

writeBytes

final void writeBytes(ByteBuffer value)
               throws IOException

Specified by:

writeBytes in class TagWriterImpl.Encoder

Throws:

IOException

writeVarint32

final void writeVarint32(int value)
                  throws IOException

Specified by:

writeVarint32 in class TagWriterImpl.Encoder

Throws:

IOException

writeVarint64

final void writeVarint64(long value)
                  throws IOException

Specified by:

writeVarint64 in class TagWriterImpl.Encoder

Throws:

IOException

writeFixed32

final void writeFixed32(int value)
                 throws IOException

Specified by:

writeFixed32 in class TagWriterImpl.Encoder

Throws:

IOException

writeFixed64

final void writeFixed64(long value)
                 throws IOException

Specified by:

writeFixed64 in class TagWriterImpl.Encoder

Throws:

IOException