Package one.microstream.storage.types

Class StorageEntityMarkMonitor.Default

java.lang.Object

one.microstream.storage.types.StorageEntityMarkMonitor.Default

All Implemented Interfaces:

PersistenceObjectIdAcceptor, StorageEntityMarkMonitor, StorageReferenceMarker

Enclosing interface:

StorageEntityMarkMonitor

public static final class StorageEntityMarkMonitor.Default
extends Object
implements StorageEntityMarkMonitor, StorageReferenceMarker

Nested Class Summary

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

StorageEntityMarkMonitor.Creator, StorageEntityMarkMonitor.Default, StorageEntityMarkMonitor.ObjectIds

Constructor Summary

Constructors

Constructor	Description
Default()

Method Summary

Modifier and Type	Method	Description
void	acceptObjectId(long objectId)
void	advanceMarking(StorageObjectIdMarkQueue oidMarkQueue, int amount)
void	clearPendingStoreUpdate(StorageEntityCache<?> channel)
void	completeSweep(StorageEntityCache<?> channel, StorageRootOidSelector rootOidSelector, long channelRootOid)
String	DEBUG_state()
void	enqueue(StorageObjectIdMarkQueue objectIdMarkQueue, long objectId)
boolean	isComplete(StorageEntityCache<?> channel)
boolean	isMarkingComplete()
boolean	isPendingSweep(StorageEntityCache<?> channel)
boolean	needsSweep(StorageEntityCache<?> channel)
StorageReferenceMarker	provideReferenceMarker(StorageEntityCache<?> channel)
void	reset()	Reset to a clean initial state, ready to be used.
void	resetCompletion()
void	signalPendingStoreUpdate(StorageEntityCache<?> channel)
boolean	tryFlush()

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

reset

public final void reset()

Description copied from interface: StorageEntityMarkMonitor

Reset to a clean initial state, ready to be used.

Specified by:

reset in interface StorageEntityMarkMonitor

Specified by:

reset in interface StorageReferenceMarker

isMarkingComplete

public final boolean isMarkingComplete()

Specified by:

isMarkingComplete in interface StorageEntityMarkMonitor

advanceMarking

public final void advanceMarking(StorageObjectIdMarkQueue oidMarkQueue, int amount)

Specified by:

advanceMarking in interface StorageEntityMarkMonitor

signalPendingStoreUpdate

public final void signalPendingStoreUpdate(StorageEntityCache<?> channel)

Specified by:

signalPendingStoreUpdate in interface StorageEntityMarkMonitor

clearPendingStoreUpdate

public final void clearPendingStoreUpdate(StorageEntityCache<?> channel)

Specified by:

clearPendingStoreUpdate in interface StorageEntityMarkMonitor

needsSweep

public final boolean needsSweep(StorageEntityCache<?> channel)

Specified by:

needsSweep in interface StorageEntityMarkMonitor

isPendingSweep

public final boolean isPendingSweep(StorageEntityCache<?> channel)

Specified by:

isPendingSweep in interface StorageEntityMarkMonitor

completeSweep

public final void completeSweep(StorageEntityCache<?> channel, StorageRootOidSelector rootOidSelector, long channelRootOid)

Specified by:

completeSweep in interface StorageEntityMarkMonitor

acceptObjectId

public final void acceptObjectId(long objectId)

Specified by:

acceptObjectId in interface PersistenceObjectIdAcceptor

enqueue

public final void enqueue(StorageObjectIdMarkQueue objectIdMarkQueue, long objectId)

Specified by:

enqueue in interface StorageEntityMarkMonitor

tryFlush

public final boolean tryFlush()

Specified by:

tryFlush in interface StorageReferenceMarker

provideReferenceMarker

public final StorageReferenceMarker provideReferenceMarker(StorageEntityCache<?> channel)

Specified by:

provideReferenceMarker in interface StorageEntityMarkMonitor

resetCompletion

public final void resetCompletion()

Specified by:

resetCompletion in interface StorageEntityMarkMonitor

isComplete

public final boolean isComplete(StorageEntityCache<?> channel)

Specified by:

isComplete in interface StorageEntityMarkMonitor

DEBUG_state

public String DEBUG_state()