Package one.microstream.persistence.binary.types

Class ChunksBuffer

java.lang.Object

one.microstream.persistence.binary.types.Binary

one.microstream.persistence.binary.types.ChunksBuffer

All Implemented Interfaces:

Chunk, MemoryRangeReader

Direct Known Subclasses:

ChunksBufferByteReversing

public class ChunksBuffer
extends Binary
implements MemoryRangeReader

Constructor Summary

Constructors

Constructor	Description
ChunksBuffer()

Method Summary

Modifier and Type	Method	Description
ByteBuffer[]	buffers()
Binary	channelChunk(int channelIndex)
int	channelCount()
void	clear()
ChunksBuffer	complete()
boolean	isEmpty()
void	iterateChannelChunks(Consumer<? super Binary> logic)
void	iterateEntityData(BinaryEntityDataReader reader)
long	iterateReferences(BinaryReferenceTraverser[] traversers, PersistenceObjectIdAcceptor acceptor)
long	loadItemEntityContentAddress()
void	modifyLoadItem(ByteBuffer directByteBuffer, long offset, long entityTotalLength, long entityTypeId, long entityObjectId)
static ChunksBuffer	New(ChunksBuffer[] channelBuffers, BufferSizeProviderIncremental bufferSizeProvider)
void	readMemory(long address, long length)	It is completely the caller's responsibility that the passed array contains a valid [LEN][TID][OID][data] byte sequence.
void	storeEntityHeader(long entityContentLength, long entityTypeId, long entityObjectId)
long	totalLength()

Methods inherited from class one.microstream.persistence.binary.types.Binary

binaryListMaximumLength, binaryListMinimumLength, build_booleans, build_booleans, build_bytes, build_bytes, build_chars, build_chars, build_doubles, build_doubles, build_floats, build_floats, build_ints, build_ints, build_longs, build_longs, build_shorts, build_shorts, buildBoolean, buildBoolean, buildByte, buildByte, buildCharacter, buildCharacter, buildDouble, buildDouble, buildFloat, buildFloat, buildInteger, buildInteger, buildLong, buildLong, buildPrimitiveWrapper, buildPrimitiveWrapper, buildRootMapping, buildShort, buildShort, buildString, buildStrings, calculateBinaryLengthChars, calculateReferenceListTotalBinaryLength, calculateStringListContentBinaryLength, collectElementsIntoArray, collectKeyValueReferences, collectListObjectReferences, collectObjectReferences, copyMemory, create_booleans, create_booleans, create_bytes, create_bytes, create_chars, create_chars, create_doubles, create_doubles, create_floats, create_floats, create_ints, create_ints, create_longs, create_longs, create_shorts, create_shorts, entityContentLength, entityHeaderLength, entityTotalLength, getBinaryListElementCountUnvalidating, getBinaryListElementCountValidating, getBinaryListTotalByteLength, getBuildItemContentLength, getBuildItemObjectId, getBuildItemTotalLength, getBuildItemTypeId, getEntityLengthRawValue, getEntityObjectIdRawValue, getEntityTypeIdRawValue, getHelper, getListElementCount, getListElementCountKeyValue, getListElementCountReferences, getLoadItemAvailableContentLength, getSizedArrayElementCount, getSizedArrayElementsAddress, getSizedArrayLength, isSwitchedByteOrder, isValidEntityLength, isValidGapLength, iterateKeyValueEntriesReferences, iterateListElementReferences, iterateListStructureElements, iterateListStructureReferenceRange, iterateReferenceRange, iterateReferenceRangeUnvalidated, iterateSizedArrayElementReferences, keyValueBinaryLength, keyValueReferenceCount, lengthLength, objectIdByteLength, read_boolean, read_byte, read_char, read_double, read_float, read_int, read_long, read_short, referenceBinaryLength, registerHelper, store_boolean, store_boolean, store_booleans, store_byte, store_byte, store_bytes, store_char, store_char, store_chars, store_double, store_double, store_doubles, store_float, store_float, store_floats, store_int, store_int, store_ints, store_long, store_long, store_longs, store_short, store_short, store_shorts, storeBoolean, storeByte, storeCharacter, storeCharsAsList, storeDouble, storeFixedSize, storeFloat, storeInteger, storeIterableAsList, storeIterableContentAsList, storeKeyValuesAsEntries, storeKeyValuesAsEntries, storeListHeader, storeLong, storeMapEntrySet, storeReferences, storeReferences, storeReferencesAsList, storeRoots, storeShort, storeSizedArray, storeSizedArray, storeStateless, storeStringsAsList, storeStringsAsList, storeStringValue, storeStringValue, storeStringValue, toBinaryListByteLengthOffset, toBinaryListContentByteLength, toBinaryListElementCountOffset, toBinaryListElementsOffset, toBinaryListTotalByteLength, toEntityContentOffset, update_booleans, update_booleans, update_bytes, update_bytes, update_chars, update_chars, update_doubles, update_doubles, update_floats, update_floats, update_ints, update_ints, update_longs, update_longs, update_shorts, update_shorts, updateArrayObjectReferences, updateArrayObjectReferences1, updateFixedSize, updateSizedArrayObjectReferences, validateArrayLength

Methods inherited from class java.lang.Object

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

Constructor Detail

ChunksBuffer

public ChunksBuffer()

Method Detail

New

public static ChunksBuffer New(ChunksBuffer[] channelBuffers,
                               BufferSizeProviderIncremental bufferSizeProvider)

channelChunk

public final Binary channelChunk(int channelIndex)

Specified by:

channelChunk in class Binary

channelCount

public final int channelCount()

Specified by:

channelCount in class Binary

clear

public final void clear()

Specified by:

clear in interface Chunk

readMemory

public void readMemory(long address,
                       long length)

It is completely the caller's responsibility that the passed array contains a valid [LEN][TID][OID][data] byte sequence.

Specified by:

readMemory in interface MemoryRangeReader

storeEntityHeader

public final void storeEntityHeader(long entityContentLength,
                                    long entityTypeId,
                                    long entityObjectId)

Specified by:

storeEntityHeader in class Binary

buffers

public final ByteBuffer[] buffers()

Specified by:

buffers in interface Chunk

Specified by:

buffers in class Binary

complete

public final ChunksBuffer complete()

iterateEntityData

public void iterateEntityData(BinaryEntityDataReader reader)

Specified by:

iterateEntityData in class Binary

iterateChannelChunks

public void iterateChannelChunks(Consumer<? super Binary> logic)

Specified by:

iterateChannelChunks in class Binary

isEmpty

public final boolean isEmpty()

Specified by:

isEmpty in interface Chunk

totalLength

public final long totalLength()

Specified by:

totalLength in interface Chunk

loadItemEntityContentAddress

public final long loadItemEntityContentAddress()

modifyLoadItem

public final void modifyLoadItem(ByteBuffer directByteBuffer,
                                 long offset,
                                 long entityTotalLength,
                                 long entityTypeId,
                                 long entityObjectId)

Specified by:

modifyLoadItem in class Binary

iterateReferences

public long iterateReferences(BinaryReferenceTraverser[] traversers,
                              PersistenceObjectIdAcceptor acceptor)

Specified by:

iterateReferences in class Binary