com.hazelcast.spi.hotrestart.impl.gc

Class Rebuilder

java.lang.Object

com.hazelcast.spi.hotrestart.impl.gc.Rebuilder

public class Rebuilder
extends Object

Rebuilds the GC-related metadata during the Hot Restart procedure.

Method Summary

Modifier and Type	Method and Description
boolean	accept(RestartItem item) Called when encountering a record which is not interred by a prefix tombstone.
void	acceptCleared(RestartItem item) Called when encountering a record which is interred by a prefix tombstone.
void	done() Called when done reading.
long	maxChunkSeq()
void	preAccept(long seq, int size) To be called for each encountered record and followed with a call to either accept(RestartItem) or acceptCleared(RestartItem).
void	setMaxSeq(long maxSeq)
void	startValuePhase(Map<Long,SetOfKeyHandle> tombKeys) The Hot Restart procedure starts with the tombstone chunk reading phase and this method is called when transitioning into the value chunk reading phase.

Methods inherited from class java.lang.Object

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

Method Detail

setMaxSeq

public void setMaxSeq(long maxSeq)

maxChunkSeq

public long maxChunkSeq()

Returns:

the highest observed chunk seq number. Used to initialize the chunk seq counter.

startValuePhase

public void startValuePhase(Map<Long,SetOfKeyHandle> tombKeys)

The Hot Restart procedure starts with the tombstone chunk reading phase and this method is called when transitioning into the value chunk reading phase.

Parameters:

tombKeys - map containing the key handles of all reloaded tombstone keys

preAccept

public void preAccept(long seq,
                      int size)

To be called for each encountered record and followed with a call to either accept(RestartItem) or acceptCleared(RestartItem).

Parameters:

seq - record seq

size - record size

acceptCleared

public void acceptCleared(RestartItem item)

Called when encountering a record which is interred by a prefix tombstone.

accept

public boolean accept(RestartItem item)

Called when encountering a record which is not interred by a prefix tombstone.

Returns:

false if the accepted record is known to be garbage; true otherwise.

done

public void done()

Called when done reading. Retires any tombstones which are no longer needed.