com.hazelcast.spi.hotrestart.impl.gc

Class PrefixTombstoneManager

java.lang.Object

com.hazelcast.spi.hotrestart.impl.gc.PrefixTombstoneManager

public class PrefixTombstoneManager
extends Object

Manages "prefix tombstones" which inter all entries under a given key prefix. These tombstones are used to implement the Hot Restart store's HotRestartStore.clear(boolean, long...) operation.

Field Summary

Fields

Modifier and Type	Field and Description
static String	NEW_FILE_SUFFIX
static int	SWEEPING_TIMESLICE_MS

Method Summary

Modifier and Type	Method and Description
void	addPrefixTombstones(long[] prefixes) Adds prefix tombstones for the given key prefixes.
void	backup(File targetDir) Copies the prefix tombstone file to the target directory.
boolean	dismissGarbage(Chunk chunk) Propagates the effects of all prefix tombstones to the given chunk.
long	maxRecordSeq() Returns the maximum observed record seq in the collector prefix tombstone list, regardless of prefix
void	setPrefixTombstones(com.hazelcast.util.collection.Long2LongHashMap prefixTombstones) Initializes this object with the existing prefix tombstones reloaded from a file.

Methods inherited from class java.lang.Object

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

Field Detail

NEW_FILE_SUFFIX

public static final String NEW_FILE_SUFFIX

See Also:

Constant Field Values

SWEEPING_TIMESLICE_MS

public static final int SWEEPING_TIMESLICE_MS

See Also:

Constant Field Values

Method Detail

maxRecordSeq

public long maxRecordSeq()

Returns the maximum observed record seq in the collector prefix tombstone list, regardless of prefix

setPrefixTombstones

public void setPrefixTombstones(com.hazelcast.util.collection.Long2LongHashMap prefixTombstones)

Initializes this object with the existing prefix tombstones reloaded from a file.

addPrefixTombstones

public void addPrefixTombstones(long[] prefixes)

Adds prefix tombstones for the given key prefixes. Called on the mutator thread.

dismissGarbage

public boolean dismissGarbage(Chunk chunk)

Propagates the effects of all prefix tombstones to the given chunk. Avoids applying a prefix tombstone to the chunk which was active at the time the tombstone was added (that work was already done by dismissGarbage(ActiveValChunk, long[])).

Returns:

true if the chunk needed dismissing.

backup

public void backup(File targetDir)

Copies the prefix tombstone file to the target directory.