com.hazelcast.spi.hotrestart.impl.gc

Class MutatorCatchup

java.lang.Object

com.hazelcast.spi.hotrestart.impl.gc.MutatorCatchup

public class MutatorCatchup
extends Object

Instance of this class is passed around to allow catching up with the mutator thread at any point along the GC cycle codepath.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static interface	MutatorCatchup.CatchupRunnable Allows a task to be run with access to the MutatorCatchup.

Field Summary

Fields

Modifier and Type	Field and Description
static int	DEFAULT_CATCHUP_INTERVAL_LOG2 Base-2 log of the number of calls to catchupAsNeeded() before deciding to catch up.

Method Summary

Modifier and Type	Method and Description
int	catchupAsNeeded() Calls catchupAsNeeded(int) with the value of DEFAULT_CATCHUP_INTERVAL_LOG2.
int	catchupNow() Caches up with the mutator thread.
static long	diagnoseLateCatchup(String name, long lastCaughtUp, GcLogger logger)
boolean	shutdownRequested()

Methods inherited from class java.lang.Object

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

Field Detail

DEFAULT_CATCHUP_INTERVAL_LOG2

public static final int DEFAULT_CATCHUP_INTERVAL_LOG2

Base-2 log of the number of calls to catchupAsNeeded() before deciding to catch up.

See Also:

Constant Field Values

Method Detail

catchupAsNeeded

public int catchupAsNeeded()

Calls catchupAsNeeded(int) with the value of DEFAULT_CATCHUP_INTERVAL_LOG2.

catchupNow

public int catchupNow()

Caches up with the mutator thread.

Returns:

the number of work items drained from the work queue and processed

shutdownRequested

public boolean shutdownRequested()

Returns:

whether the GC thread was asked to stop.

diagnoseLateCatchup

public static long diagnoseLateCatchup(String name,
                                       long lastCaughtUp,
                                       GcLogger logger)