org.apache.ignite.internal.processors.cache.version

Class GridCacheVersionManager

java.lang.Object

org.apache.ignite.internal.processors.cache.GridCacheSharedManagerAdapter

org.apache.ignite.internal.processors.cache.version.GridCacheVersionManager

All Implemented Interfaces:

GridCacheSharedManager

public class GridCacheVersionManager
extends GridCacheSharedManagerAdapter

Makes sure that cache lock order values come in proper sequence.

NOTE: this class should not make use of any cache specific structures, like, for example GridCacheContext, as it may be reused between different caches.

Field Summary

Fields

Modifier and Type	Field and Description
static GridCacheVersion	EVICT_VER
static String	LAST_DATA_VER Last data version metric name.
protected AtomicLongMetric	lastDataVer Last version metric.
static long	TOP_VER_BASE_TIME Timestamp used as base time for cache topology version (January 1, 2014).

Fields inherited from class org.apache.ignite.internal.processors.cache.GridCacheSharedManagerAdapter

cctx, diagnosticLog, log

Constructor Summary

Constructors

Constructor and Description
GridCacheVersionManager()

Method Summary

Modifier and Type	Method and Description
void	dataCenterId(byte dataCenterId) Sets data center ID.
GridCacheVersion	isolatedStreamerVersion() Version for entries loaded with isolated streamer, should be less than any version generated for entries update.
boolean	isStartVersion(GridCacheVersion ver) Check if given version is start version.
GridCacheVersion	last() Gets last generated version without generating a new one.
GridCacheVersion	next()
GridCacheVersion	next(AffinityTopologyVersion topVer) Gets next version based on given topology version.
GridCacheVersion	next(byte dataCenterId)
GridCacheVersion	next(GridCacheVersion ver) Gets next version based on given cache version.
GridCacheVersion	nextForLoad() Gets next version for cache store load and reload operations.
GridCacheVersion	nextForLoad(AffinityTopologyVersion topVer) Gets next version for cache store load and reload operations.
GridCacheVersion	nextForLoad(GridCacheVersion ver) Gets next version for cache store load and reload operations.
void	onExchange(long rcvOrder)
void	onReceived(UUID nodeId, GridCacheVersion ver)
void	onReceived(UUID nodeId, long ver)
GridCacheVersion	onReceivedAndNext(UUID nodeId, GridCacheVersion ver)
void	start0()
GridCacheVersion	startVersion() Gets start version.
protected void	stop0(boolean cancel)

Methods inherited from class org.apache.ignite.internal.processors.cache.GridCacheSharedManagerAdapter

context, isStopping, kernalStartInfo, kernalStopInfo, log, onDisconnected, onKernalStart, onKernalStart0, onKernalStop, onKernalStop0, onReconnected, printMemoryStats, start, startInfo, stop, stopInfo, toString

Methods inherited from class java.lang.Object

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

Field Detail

EVICT_VER

public static final GridCacheVersion EVICT_VER

TOP_VER_BASE_TIME

public static final long TOP_VER_BASE_TIME

Timestamp used as base time for cache topology version (January 1, 2014).

See Also:

Constant Field Values

LAST_DATA_VER

public static final String LAST_DATA_VER

Last data version metric name.

See Also:

Constant Field Values

lastDataVer

protected AtomicLongMetric lastDataVer

Last version metric.

Constructor Detail

GridCacheVersionManager

public GridCacheVersionManager()

Method Detail

start0

public void start0()
            throws IgniteCheckedException

Overrides:

start0 in class GridCacheSharedManagerAdapter

Throws:

IgniteCheckedException - If failed.

stop0

protected void stop0(boolean cancel)

Overrides:

stop0 in class GridCacheSharedManagerAdapter

Parameters:

cancel - Cancel flag.

dataCenterId

public void dataCenterId(byte dataCenterId)

Sets data center ID.

Parameters:

dataCenterId - Data center ID.

onReceived

public void onReceived(UUID nodeId,
                       GridCacheVersion ver)

Parameters:

nodeId - Node ID.

ver - Remote version.

onReceived

public void onReceived(UUID nodeId,
                       long ver)

Parameters:

nodeId - Node ID.

ver - Remote version.

onExchange

public void onExchange(long rcvOrder)

Parameters:

rcvOrder - Received order.

onReceivedAndNext

public GridCacheVersion onReceivedAndNext(UUID nodeId,
                                          GridCacheVersion ver)

Parameters:

nodeId - Node ID.

ver - Received version.

Returns:

Next version.

isolatedStreamerVersion

public GridCacheVersion isolatedStreamerVersion()

Version for entries loaded with isolated streamer, should be less than any version generated for entries update.

Returns:

Version for entries loaded with isolated streamer.

next

public GridCacheVersion next()

Returns:

Next version based on current topology.

next

public GridCacheVersion next(byte dataCenterId)

Parameters:

dataCenterId - Data center id.

Returns:

Next version based on current topology with given data center id.

next

public GridCacheVersion next(AffinityTopologyVersion topVer)

Gets next version based on given topology version. Given value should be real topology version calculated as number of grid topology changes and obtained from discovery manager.

Parameters:

topVer - Topology version for which new version should be obtained.

Returns:

Next version based on given topology version.

nextForLoad

public GridCacheVersion nextForLoad()

Gets next version for cache store load and reload operations.

Returns:

Next version for cache store operations.

nextForLoad

public GridCacheVersion nextForLoad(AffinityTopologyVersion topVer)

Gets next version for cache store load and reload operations.

Returns:

Next version for cache store operations.

nextForLoad

public GridCacheVersion nextForLoad(GridCacheVersion ver)

Gets next version for cache store load and reload operations.

Returns:

Next version for cache store operations.

next

public GridCacheVersion next(GridCacheVersion ver)

Gets next version based on given cache version.

Parameters:

ver - Cache version for which new version should be obtained.

Returns:

Next version based on given cache version.

last

public GridCacheVersion last()

Gets last generated version without generating a new one.

Returns:

Last generated version.

startVersion

public GridCacheVersion startVersion()

Gets start version.

Returns:

Start version.

isStartVersion

public boolean isStartVersion(GridCacheVersion ver)

Check if given version is start version.

Parameters:

ver - Version.

Returns:

True if given version is start version.