Package one.microstream.storage.types

Class StorageFileManager.Default

java.lang.Object

one.microstream.storage.types.StorageFileManager.Default

All Implemented Interfaces:

StorageChannelResetablePart, StorageFileManager, StorageFileUser, StorageHashChannelPart

Enclosing interface:

StorageFileManager

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

Nested Class Summary

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

StorageFileManager.Default

Constructor Summary

Constructors

Constructor

Description

Default(int channelIndex, StorageInitialDataFileNumberProvider initialDataFileNumberProvider, StorageTimestampProvider timestampProvider, StorageLiveFileProvider fileProvider, StorageDataFileEvaluator dataFileEvaluator, StorageEntityCache.Default entityCache, StorageWriteController writeController, StorageFileWriter writer, BufferSizeProvider standardBufferSizeProvider, StorageBackupHandler backupHandler)

Method Summary

Modifier and Type	Method	Description
int	channelIndex()
void	commitImport(long taskTimestamp)
void	commitWrite()
void	copyData(StorageImportSourceFile importFile)
StorageRawFileStatistics.ChannelStatistics	createRawFileStatistics()
StorageLiveDataFile.Default	currentStorageFile()
void	exportData(StorageLiveFileProvider fileProvider)
boolean	incrementalFileCleanupCheck(long nanoTimeBudgetBound)
StorageIdAnalysis	initializeStorage(long taskTimestamp, long consistentStoreTimestamp, StorageInventory storageInventory, StorageChannel parent)
boolean	issuedFileCleanupCheck(long nanoTimeBudgetBound)
void	iterateStorageFiles(Consumer<? super StorageLiveDataFile> procedure)
StorageInventory	readStorage()
void	reset()	Closes all resources (files, locks, etc.).
void	restartFileCleanupCursor()
void	rollbackWrite()
long[]	storeChunks(long timestamp, ByteBuffer[] dataBuffers)

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, StorageLiveFileProvider fileProvider, StorageDataFileEvaluator dataFileEvaluator, StorageEntityCache.Default entityCache, StorageWriteController writeController, 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 StorageLiveDataFile.Default currentStorageFile()

Specified by:

currentStorageFile in interface StorageFileManager

iterateStorageFiles

public void iterateStorageFiles(Consumer<? super StorageLiveDataFile> 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

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(StorageLiveFileProvider fileProvider)

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 nanoTimeBudgetBound)

Specified by:

issuedFileCleanupCheck in interface StorageFileManager

copyData

public void copyData(StorageImportSourceFile importFile)

commitImport

public void commitImport(long taskTimestamp)