Package one.microstream.storage.types

Class StorageEntityCache.Default

java.lang.Object

one.microstream.storage.types.StorageEntityCache.Default

All Implemented Interfaces:

Unpersistable, StorageChannelResetablePart, StorageEntityCache<StorageEntity.Default>, StorageHashChannelPart

Enclosing interface:

StorageEntityCache<E extends StorageEntity>

public static final class StorageEntityCache.Default
extends Object
implements StorageEntityCache<StorageEntity.Default>, Unpersistable

Nested Class Summary

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

StorageEntityCache.Default

Constructor Summary

Constructors

Constructor	Description
Default()

Method Summary

Modifier and Type	Method	Description
long	cacheSize()
int	channelIndex()
long	clearCache()
void	copyRoots(ChunksBuffer dataCollector)
static void	DEBUG_setGarbageCollectionEnabled(boolean enabled)	Deprecated.
long	entityCount()
StorageEntity.Default	getEntry(long objectId)
boolean	incrementalEntityCacheCheck(long nanoTimeBudgetBound)
boolean	incrementalGarbageCollection(long nanoTimeBudgetBound, StorageChannel channel)	Returns true if there are no more oids to mark and false if time ran out.
boolean	issuedEntityCacheCheck(long nanoTimeBudgetBound, StorageEntityCacheEvaluator entityEvaluator)
boolean	issuedGarbageCollection(long nanoTimeBudgetBound, StorageChannel channel)	Returns true if there are no more oids to mark and false if time ran out.
StorageEntityType.Default	lookupType(long typeId)
void	postStorePutEntities(ByteBuffer[] chunks, long[] chunksStoragePositions, StorageLiveDataFile.Default dataFile)
void	reset()	Closes all resources (files, locks, etc.).
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()

Method Details

DEBUG_setGarbageCollectionEnabled

@Deprecated public static void DEBUG_setGarbageCollectionEnabled(boolean enabled)

Deprecated.

/!\ Storage-level garbage collection is an unfinished feature with a still tiny race condition problem that can cause the database to be ruined occasionally.

Enable at your own risk!

Also note that this method is a temporary experimental function for debugging purposes and can disappear at any release.
Do not use this is production mode.

Parameters:

enabled -

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 StorageEntityCache<StorageEntity.Default>

getEntry

public final StorageEntity.Default getEntry(long objectId)

entityCount

public final long entityCount()

channelIndex

public int channelIndex()

Specified by:

channelIndex in interface StorageHashChannelPart

cacheSize

public final long cacheSize()

Specified by:

cacheSize in interface StorageEntityCache<StorageEntity.Default>

clearCache

public final long clearCache()

Specified by:

clearCache in interface StorageEntityCache<StorageEntity.Default>

typeDictionary

public final StorageTypeDictionary typeDictionary()

Specified by:

typeDictionary in interface StorageEntityCache<StorageEntity.Default>

postStorePutEntities

public void postStorePutEntities(ByteBuffer[] chunks, long[] chunksStoragePositions, StorageLiveDataFile.Default dataFile) throws InterruptedException

Throws:

InterruptedException

lookupType

public final StorageEntityType.Default lookupType(long typeId)

Specified by:

lookupType in interface StorageEntityCache<StorageEntity.Default>

copyRoots

public void copyRoots(ChunksBuffer dataCollector)

Specified by:

copyRoots in interface StorageEntityCache<StorageEntity.Default>

incrementalEntityCacheCheck

public final boolean incrementalEntityCacheCheck(long nanoTimeBudgetBound)

Specified by:

incrementalEntityCacheCheck in interface StorageEntityCache<StorageEntity.Default>

issuedEntityCacheCheck

public boolean issuedEntityCacheCheck(long nanoTimeBudgetBound, StorageEntityCacheEvaluator entityEvaluator)

Specified by:

issuedEntityCacheCheck in interface StorageEntityCache<StorageEntity.Default>

issuedGarbageCollection

public final boolean issuedGarbageCollection(long nanoTimeBudgetBound, StorageChannel channel)

Returns true if there are no more oids to mark and false if time ran out. (Meaning the returned boolean effectively means "Was there enough time?")

Specified by:

issuedGarbageCollection in interface StorageEntityCache<StorageEntity.Default>

incrementalGarbageCollection

public final boolean incrementalGarbageCollection(long nanoTimeBudgetBound, StorageChannel channel)

Returns true if there are no more oids to mark and false if time ran out. (Meaning the returned boolean effectively means "Was there enough time?")

Specified by:

incrementalGarbageCollection in interface StorageEntityCache<StorageEntity.Default>