com.hazelcast.spi.hotrestart.impl.gc

Class GcExecutor

java.lang.Object

com.hazelcast.spi.hotrestart.impl.gc.GcExecutor

public class GcExecutor
extends Object

Contains top-level control code for the GC thread.

Field Summary

Fields

Modifier and Type	Field and Description
static int	COLLECTOR_QUEUE_CAPACITY Capacity of the work queue which is used by the mutator thread to submit tasks to the GC thread.

Method Summary

Modifier and Type	Method and Description
void	runWhileGcPaused(MutatorCatchup.CatchupRunnable task) Runs the task while holding a mutex lock which is also held during GC activity.
void	shutdown() Asks the GC thread to stop and awaits its completion.
void	start() Starts the GC thread.
void	submitBackup(File targetDir)
void	submitRecord(HotRestartKey key, long freshSeq, int freshSize, boolean freshIsTombstone) Submits a "record added" event to the GC thread's work queue.
void	submitReplaceActiveChunk(ActiveChunk closed, ActiveChunk fresh) Submits a "active chunk replaced" event to the GC thread's work queue.

Methods inherited from class java.lang.Object

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

Field Detail

COLLECTOR_QUEUE_CAPACITY

public static final int COLLECTOR_QUEUE_CAPACITY

Capacity of the work queue which is used by the mutator thread to submit tasks to the GC thread.

See Also:

Constant Field Values

Method Detail

start

public void start()

Starts the GC thread.

shutdown

public void shutdown()

Asks the GC thread to stop and awaits its completion.

submitRecord

public void submitRecord(HotRestartKey key,
                         long freshSeq,
                         int freshSize,
                         boolean freshIsTombstone)

Submits a "record added" event to the GC thread's work queue.

submitReplaceActiveChunk

public void submitReplaceActiveChunk(ActiveChunk closed,
                                     ActiveChunk fresh)

Submits a "active chunk replaced" event to the GC thread's work queue.

runWhileGcPaused

public void runWhileGcPaused(MutatorCatchup.CatchupRunnable task)

Runs the task while holding a mutex lock which is also held during GC activity. Provided only to facilitate testing.

submitBackup

public void submitBackup(File targetDir)