org.apache.ignite.internal.processors.cache.persistence

Class GridCacheDatabaseSharedManager.Checkpointer

java.lang.Object

org.apache.ignite.internal.util.worker.GridWorker

org.apache.ignite.internal.processors.cache.persistence.GridCacheDatabaseSharedManager.Checkpointer

All Implemented Interfaces:

Runnable

Enclosing class:

GridCacheDatabaseSharedManager

public class GridCacheDatabaseSharedManager.Checkpointer
extends GridWorker

Checkpointer object is used for notification on checkpoint begin, predicate is scheduledCp.nextCpTs - now > 0 . Method wakeupForCheckpoint(long, java.lang.String) uses notify, waitCheckpointEvent() uses wait

Field Summary

Fields inherited from class org.apache.ignite.internal.util.worker.GridWorker

isCancelled, log

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	Checkpointer(String gridName, String name, IgniteLogger log)

Method Summary

Modifier and Type	Method and Description
protected void	body() The implementation should provide the execution body for this runnable.
void	cancel() Cancels this runnable interrupting actual runner.
void	shutdownNow()
IgniteInternalFuture	wakeupForSnapshotCreation(SnapshotOperation snapshotOperation)

Methods inherited from class org.apache.ignite.internal.util.worker.GridWorker

blockingSectionBegin, blockingSectionEnd, cleanup, heartbeatTs, igniteInstanceName, isCancelled, isDone, join, name, onIdle, run, runner, toString, updateHeartbeat

Methods inherited from class java.lang.Object

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

Constructor Detail

Checkpointer

protected Checkpointer(@Nullable
                       String gridName,
                       String name,
                       IgniteLogger log)

Parameters:

gridName - Grid name.

name - Thread name.

log - Logger.

Method Detail

body

protected void body()

The implementation should provide the execution body for this runnable.

Specified by:

body in class GridWorker

wakeupForSnapshotCreation

public IgniteInternalFuture wakeupForSnapshotCreation(SnapshotOperation snapshotOperation)

Parameters:

snapshotOperation - Snapshot operation.

cancel

public void cancel()

Cancels this runnable interrupting actual runner.

Overrides:

cancel in class GridWorker

shutdownNow

public void shutdownNow()