Package one.microstream.storage.types

Class StorageFileManager.Default

java.lang.Object

one.microstream.storage.types.StorageFileManager.Default

All Implemented Interfaces:

StorageChannelResetablePart, StorageFileManager, StorageFileUser, StorageHashChannelPart, StorageReaderCallback

Enclosing interface:

StorageFileManager

public static final class StorageFileManager.Default
extends Object
implements StorageFileManager, StorageReaderCallback, StorageFileUser

Nested Class Summary

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

StorageFileManager.Default

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

StorageReaderCallback.Default

Constructor Summary

Constructors

Constructor	Description
Default(int channelIndex, StorageInitialDataFileNumberProvider initialDataFileNumberProvider, StorageTimestampProvider timestampProvider, StorageFileProvider storageFileProvider, StorageDataFileEvaluator dataFileEvaluator, StorageEntityCache.Default entityCache, StorageFileReader reader, StorageFileWriter writer, BufferSizeProvider standardBufferSizeProvider, StorageBackupHandler backupHandler)

Method Summary

Modifier and Type	Method	Description
int	channelIndex()
void	commitImport(long taskTimestamp)
void	commitWrite()
void	copyData(StorageChannelImportSourceFile importFile)
StorageRawFileStatistics.ChannelStatistics	createRawFileStatistics()
StorageDataFile.Default	currentStorageFile()
void	exportData(StorageIoHandler fileHandler)
boolean	incrementalFileCleanupCheck(long nanoTimeBudgetBound)
StorageIdAnalysis	initializeStorage(long taskTimestamp, long consistentStoreTimestamp, StorageInventory storageInventory, StorageChannel parent)
boolean	issuedFileCleanupCheck(long nanoTimeBudget)
void	iterateStorageFiles(Consumer<? super StorageDataFile<?>> procedure)
StorageInventory	readStorage()
void	reset()	Closes all resources (files, locks, etc.).
void	restartFileCleanupCursor()
void	rollbackWrite()
long[]	storeChunks(long timestamp, ByteBuffer[] dataBuffers)
void	validateIncrementalRead(StorageLockedFile fileChannel, long filePosition, ByteBuffer buffer, long lastReadCount)

Methods inherited from class java.lang.Object

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

Constructor Details

Default

public Default(int channelIndex, StorageInitialDataFileNumberProvider initialDataFileNumberProvider, StorageTimestampProvider timestampProvider, StorageFileProvider storageFileProvider, StorageDataFileEvaluator dataFileEvaluator, StorageEntityCache.Default entityCache, StorageFileReader reader, StorageFileWriter writer, BufferSizeProvider standardBufferSizeProvider, StorageBackupHandler backupHandler)

Method Details

channelIndex

public final int channelIndex()

Specified by:

channelIndex in interface StorageFileManager

Specified by:

channelIndex in interface StorageHashChannelPart

currentStorageFile

public final StorageDataFile.Default currentStorageFile()

Specified by:

currentStorageFile in interface StorageFileManager

iterateStorageFiles

public void iterateStorageFiles(Consumer<? super StorageDataFile<?>> procedure)

Specified by:

iterateStorageFiles in interface StorageFileManager

storeChunks

public final long[] storeChunks(long timestamp, ByteBuffer[] dataBuffers) throws StorageExceptionIoWritingChunk

Specified by:

storeChunks in interface StorageFileManager

Throws:

StorageExceptionIoWritingChunk

rollbackWrite

public final void rollbackWrite()

Specified by:

rollbackWrite in interface StorageFileManager

commitWrite

public final void commitWrite()

Specified by:

commitWrite in interface StorageFileManager

validateIncrementalRead

public void validateIncrementalRead(StorageLockedFile fileChannel, long filePosition, ByteBuffer buffer, long lastReadCount) throws IOException

Specified by:

validateIncrementalRead in interface StorageReaderCallback

Throws:

IOException

readStorage

public final StorageInventory readStorage()

Specified by:

readStorage in interface StorageFileManager

initializeStorage

public StorageIdAnalysis initializeStorage(long taskTimestamp, long consistentStoreTimestamp, StorageInventory storageInventory, StorageChannel parent)

Specified by:

initializeStorage in interface StorageFileManager

reset

public final void reset()

Description copied from interface: StorageChannelResetablePart

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

Specified by:

reset in interface StorageFileManager

exportData

public void exportData(StorageIoHandler fileHandler)

Specified by:

exportData in interface StorageFileManager

createRawFileStatistics

public final StorageRawFileStatistics.ChannelStatistics createRawFileStatistics()

Specified by:

createRawFileStatistics in interface StorageFileManager

incrementalFileCleanupCheck

public final boolean incrementalFileCleanupCheck(long nanoTimeBudgetBound)

Specified by:

incrementalFileCleanupCheck in interface StorageFileManager

restartFileCleanupCursor

public final void restartFileCleanupCursor()

Specified by:

restartFileCleanupCursor in interface StorageFileManager

issuedFileCleanupCheck

public final boolean issuedFileCleanupCheck(long nanoTimeBudget)

Specified by:

issuedFileCleanupCheck in interface StorageFileManager

copyData

public void copyData(StorageChannelImportSourceFile importFile)

commitImport

public void commitImport(long taskTimestamp)