Package one.microstream.storage.types

Class StorageChannel.Default

java.lang.Object

one.microstream.storage.types.StorageChannel.Default

All Implemented Interfaces:

Runnable, Unpersistable, StorageActivePart, StorageChannel, StorageChannelResetablePart, StorageHashChannelPart

Enclosing interface:

StorageChannel

public static final class StorageChannel.Default
extends Object
implements StorageChannel, Unpersistable

Nested Class Summary

Nested classes/interfaces inherited from interface one.microstream.storage.types.StorageChannel

StorageChannel.Default, StorageChannel.EntityCollectorByOid, StorageChannel.EntityCollectorByTid, StorageChannel.HousekeepingTask

Constructor Summary

Constructors

Constructor	Description
Default(int hashIndex, StorageExceptionHandler exceptionHandler, StorageTaskBroker taskBroker, StorageOperationController operationController, StorageHousekeepingController housekeepingController, StorageEntityCache.Default entityCache, boolean switchByteOrder, BufferSizeProviderIncremental loadingBufferSizeProvider, StorageFileManager.Default fileManager, StorageEventLogger eventLogger)

Method Summary

Modifier and Type	Method	Description
int	channelIndex()
void	cleanupStore()
ChunksBuffer	collectLoadByOids(ChunksBuffer[] resultArray, PersistenceIdSet loadOids)
ChunksBuffer	collectLoadByTids(ChunksBuffer[] resultArray, PersistenceIdSet loadTids)
ChunksBuffer	collectLoadRoots(ChunksBuffer[] resultArray)
void	commitChunkStorage()
void	commitImportData(long taskTimestamp)
StorageRawFileStatistics.ChannelStatistics	createRawFileStatistics()
void	exportData(StorageIoHandler fileHandler)
KeyValue<Long,Long>	exportTypeEntities(StorageEntityTypeHandler type, StorageLockedFile file)
KeyValue<Long,Long>	exportTypeEntities(StorageEntityTypeHandler type, StorageLockedFile file, Predicate<? super StorageEntity> predicateEntity)
void	importData(StorageChannelImportSourceFile importFile)
StorageIdAnalysis	initializeStorage(long taskTimestamp, long consistentStoreTimestamp, StorageInventory storageInventory)
boolean	isActive()	Queries whether the part is actually active right now.
boolean	issuedCacheCheck(long nanoTimeBudget, StorageEntityCacheEvaluator entityEvaluator)
boolean	issuedFileCheck(long nanoTimeBudget)
boolean	issuedGarbageCollection(long nanoTimeBudget)
void	postStoreUpdateEntityCache(ByteBuffer[] chunks, long[] chunksStoragePositions)
StorageEntityCache.Default	prepareImportData()
StorageInventory	readStorage()
void	reset()	Closes all resources (files, locks, etc.).
void	rollbackChunkStorage()
void	rollbackImportData(Throwable cause)
void	run()
void	signalGarbageCollectionSweepCompleted()
KeyValue<ByteBuffer[],long[]>	storeEntities(long timestamp, Chunk chunkData)
StorageTypeDictionary	typeDictionary()

Methods inherited from class java.lang.Object

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

Constructor Details

Default

public Default(int hashIndex, StorageExceptionHandler exceptionHandler, StorageTaskBroker taskBroker, StorageOperationController operationController, StorageHousekeepingController housekeepingController, StorageEntityCache.Default entityCache, boolean switchByteOrder, BufferSizeProviderIncremental loadingBufferSizeProvider, StorageFileManager.Default fileManager, StorageEventLogger eventLogger)

Method Details

isActive

public boolean isActive()

Description copied from interface: StorageActivePart

Queries whether the part is actually active right now. This might return true even despite some "running" flag being set to false because there might be one last loop cycle execution before checking the "running" flag again.

Specified by:

isActive in interface StorageActivePart

Returns:

if the part is actually active right now.

run

public final void run()

Specified by:

run in interface Runnable

commitChunkStorage

public void commitChunkStorage()

Specified by:

commitChunkStorage in interface StorageChannel

storeEntities

public KeyValue<ByteBuffer[],long[]> storeEntities(long timestamp, Chunk chunkData)

Specified by:

storeEntities in interface StorageChannel

postStoreUpdateEntityCache

public void postStoreUpdateEntityCache(ByteBuffer[] chunks, long[] chunksStoragePositions) throws InterruptedException

Specified by:

postStoreUpdateEntityCache in interface StorageChannel

Throws:

InterruptedException

channelIndex

public final int channelIndex()

Specified by:

channelIndex in interface StorageHashChannelPart

typeDictionary

public final StorageTypeDictionary typeDictionary()

Specified by:

typeDictionary in interface StorageChannel

collectLoadByOids

public final ChunksBuffer collectLoadByOids(ChunksBuffer[] resultArray, PersistenceIdSet loadOids)

Specified by:

collectLoadByOids in interface StorageChannel

collectLoadRoots

public final ChunksBuffer collectLoadRoots(ChunksBuffer[] resultArray)

Specified by:

collectLoadRoots in interface StorageChannel

collectLoadByTids

public final ChunksBuffer collectLoadByTids(ChunksBuffer[] resultArray, PersistenceIdSet loadTids)

Specified by:

collectLoadByTids in interface StorageChannel

issuedGarbageCollection

public final boolean issuedGarbageCollection(long nanoTimeBudget)

Specified by:

issuedGarbageCollection in interface StorageChannel

issuedFileCheck

public boolean issuedFileCheck(long nanoTimeBudget)

Specified by:

issuedFileCheck in interface StorageChannel

issuedCacheCheck

public boolean issuedCacheCheck(long nanoTimeBudget, StorageEntityCacheEvaluator entityEvaluator)

Specified by:

issuedCacheCheck in interface StorageChannel

exportData

public final void exportData(StorageIoHandler fileHandler)

Specified by:

exportData in interface StorageChannel

prepareImportData

public StorageEntityCache.Default prepareImportData()

Specified by:

prepareImportData in interface StorageChannel

importData

public void importData(StorageChannelImportSourceFile importFile)

Specified by:

importData in interface StorageChannel

rollbackImportData

public void rollbackImportData(Throwable cause)

Specified by:

rollbackImportData in interface StorageChannel

commitImportData

public void commitImportData(long taskTimestamp)

Specified by:

commitImportData in interface StorageChannel

exportTypeEntities

public final KeyValue<Long,Long> exportTypeEntities(StorageEntityTypeHandler type, StorageLockedFile file, Predicate<? super StorageEntity> predicateEntity) throws IOException

Specified by:

exportTypeEntities in interface StorageChannel

Throws:

IOException

exportTypeEntities

public final KeyValue<Long,Long> exportTypeEntities(StorageEntityTypeHandler type, StorageLockedFile file) throws IOException

Specified by:

exportTypeEntities in interface StorageChannel

Throws:

IOException

createRawFileStatistics

public final StorageRawFileStatistics.ChannelStatistics createRawFileStatistics()

Specified by:

createRawFileStatistics in interface StorageChannel

rollbackChunkStorage

public final void rollbackChunkStorage()

Specified by:

rollbackChunkStorage in interface StorageChannel

readStorage

public final StorageInventory readStorage()

Specified by:

readStorage in interface StorageChannel

initializeStorage

public final StorageIdAnalysis initializeStorage(long taskTimestamp, long consistentStoreTimestamp, StorageInventory storageInventory)

Specified by:

initializeStorage in interface StorageChannel

reset

public final void reset()

Closes all resources (files, locks, etc.). Clears all variable length items (cache, registry, etc.). Resets internal state to initial values. For itself and all its parts (entity cache, file manager, etc.). Basically a "back to just being born" action.

Specified by:

reset in interface StorageChannelResetablePart

signalGarbageCollectionSweepCompleted

public final void signalGarbageCollectionSweepCompleted()

Specified by:

signalGarbageCollectionSweepCompleted in interface StorageChannel

cleanupStore

public void cleanupStore()

Specified by:

cleanupStore in interface StorageChannel