Package org.infinispan.protostream.impl

Class TagWriterImpl.HeapByteBufferEncoder

java.lang.Object

org.infinispan.protostream.impl.TagWriterImpl.Encoder

org.infinispan.protostream.impl.TagWriterImpl.ByteArrayEncoder

org.infinispan.protostream.impl.TagWriterImpl.HeapByteBufferEncoder

Enclosing class:

TagWriterImpl

private static final class TagWriterImpl.HeapByteBufferEncoder
extends TagWriterImpl.ByteArrayEncoder

Writes directly to the underlying array of a heap ByteBuffer because is faster than the put() operation. Buffer position is not updated after every write, just on flush.

Field Summary

Fields

Modifier and Type	Field	Description
private final ByteBuffer	buffer
private final int	startPos

Fields inherited from class org.infinispan.protostream.impl.TagWriterImpl.ByteArrayEncoder

limit, offset, pos

Constructor Summary

Constructors

Modifier	Constructor	Description
private	HeapByteBufferEncoder(ByteBuffer buffer)

Method Summary

Modifier and Type	Method	Description
(package private) void	flush()	Commits the witten bytes after several write operations were performed.

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

fillFromBuffer, flushToStream, flushToStream, remainingSpace, writeByte, writeBytes, writeBytes, writeFixed32, writeFixed64, writeVarint32, writeVarint64

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

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

buffer

private final ByteBuffer buffer

startPos

private final int startPos

Constructor Details

HeapByteBufferEncoder

private HeapByteBufferEncoder(ByteBuffer buffer)

Method Details

flush

void flush()

Description copied from class: TagWriterImpl.Encoder

Commits the witten bytes after several write operations were performed. Updates counters, positions, whatever.

Overrides:

flush in class TagWriterImpl.Encoder