org.gridgain.grid.kernal.processors.cache

Class GridCacheMvccManager<K,V>

java.lang.Object

org.gridgain.grid.kernal.processors.cache.GridCacheManagerAdapter<K,V>

org.gridgain.grid.kernal.processors.cache.GridCacheMvccManager<K,V>

All Implemented Interfaces:

GridCacheManager<K,V>

public class GridCacheMvccManager<K,V>
extends GridCacheManagerAdapter<K,V>

Manages lock order within a thread.

Field Summary

Fields inherited from class org.gridgain.grid.kernal.processors.cache.GridCacheManagerAdapter

cctx, log

Constructor Summary

Constructors

Constructor and Description
GridCacheMvccManager()

Method Summary

Methods

Modifier and Type	Method and Description
void	addAtomicFuture(GridCacheVersion futVer, GridCacheAtomicFuture<K,?> fut)
void	addExplicitLock(long threadId, GridCacheMvccCandidate<K> cand, GridDiscoveryTopologySnapshot snapshot) Adds candidate to the list of near local candidates.
boolean	addFuture(GridCacheFuture<?> fut) Adds future.
boolean	addLocal(GridCacheMvccCandidate<K> cand)
boolean	addNext(GridCacheMvccCandidate<K> cand)
boolean	addRemoved(GridCacheVersion ver)
GridFuture<?>	atomicFuture(GridCacheVersion futVer) Gets future by given future ID.
GridCacheMvccCallback<K,V>	callback()
GridCacheMvccCandidate<K>	explicitLock(K key, GridCacheVersion ver) Gets explicit lock candidate added by any thread by given key and lock version.
GridCacheMvccCandidate<K>	explicitLock(long threadId, K key) Gets last added explicit lock candidate by thread id and key.
GridFuture<?>	finishAtomicUpdates(long topVer, Collection<Integer> parts)
GridFuture<?>	finishExplicitLocks(long topVer) Creates a future that will wait for all explicit locks acquired on given topology version to be released.
GridFuture<?>	finishKeys(Collection<K> keys, long topVer)
GridFuture<?>	finishLocks(Collection<Integer> parts, long topVer)
<T> GridCacheFuture<T>	future(GridCacheVersion ver, GridUuid futId) Gets future for given future ID and lock ID.
<T> Collection<? extends GridFuture<T>>	futures(GridCacheVersion ver) Gets all futures for given lock version, possibly empty collection.
boolean	hasFuture(GridCacheFuture<?> fut)
boolean	isLockedByThread(K key, long threadId) Checks if given key is locked by thread with given id or any thread.
boolean	isRemoved(GridCacheVersion ver)
GridDiscoveryTopologySnapshot	lastExplicitLockTopologySnapshot(long threadId)
Collection<GridCacheMvccCandidate<K>>	localCandidates() This method has poor performance, so use with care.
Collection<GridCacheVersion>	localDhtPendingVersions(Collection<K> keys, GridCacheVersion base)
GridCacheVersion	mappedVersion(GridCacheVersion from)
void	mapVersion(GridCacheVersion from, GridCacheVersion to)
void	markExplicitOwner(K key, long threadId) Marks candidates for given thread and given key as owned.
void	onKernalStart0()
void	onKernalStop0(boolean cancel)
void	printMemoryStats() Prints memory statistics (sizes of internal data structures, etc.).
void	recheckPendingLocks()
Collection<GridCacheMvccCandidate<K>>	remoteCandidates() This method has poor performance, so use with care.
GridFuture<?>	removeAtomicFuture(GridCacheVersion futVer)
void	removeExplicitLock(GridCacheMvccCandidate<K> cand) Removes candidate from the list of near local candidates.
GridCacheMvccCandidate<K>	removeExplicitLock(long threadId, K key, GridCacheVersion ver) Removes explicit lock for given thread id, key and optional version.
boolean	removeFuture(GridCacheFuture<?> fut)
boolean	removeLocal(GridCacheMvccCandidate<K> cand)
protected void	start0()
GridCacheVersion	unmapVersion(GridCacheVersion from)

Methods inherited from class org.gridgain.grid.kernal.processors.cache.GridCacheManagerAdapter

context, kernalStartInfo, kernalStopInfo, log, onKernalStart, onKernalStop, start, startInfo, stop, stop0, stopInfo, toString

Methods inherited from class java.lang.Object

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

Constructor Detail

GridCacheMvccManager

public GridCacheMvccManager()

Method Detail

start0

protected void start0()
               throws GridException

Overrides:

start0 in class GridCacheManagerAdapter<K,V>

Throws:

GridException - If failed.

onKernalStart0

public void onKernalStart0()
                    throws GridException

Overrides:

onKernalStart0 in class GridCacheManagerAdapter<K,V>

Throws:

GridException - If failed.

onKernalStop0

public void onKernalStop0(boolean cancel)

Overrides:

onKernalStop0 in class GridCacheManagerAdapter<K,V>

Parameters:

cancel - Cancel flag.

callback

public GridCacheMvccCallback<K,V> callback()

Returns:

MVCC callback.

mapVersion

public void mapVersion(GridCacheVersion from,
              GridCacheVersion to)

Parameters:

from - From version.

to - To version.

mappedVersion

public GridCacheVersion mappedVersion(GridCacheVersion from)

Parameters:

from - Near version.

Returns:

DHT version.

unmapVersion

public GridCacheVersion unmapVersion(GridCacheVersion from)

Parameters:

from - From version.

Returns:

To version.

hasFuture

public boolean hasFuture(GridCacheFuture<?> fut)

Parameters:

fut - Future to check.

Returns:

True if future is registered.

addAtomicFuture

public void addAtomicFuture(GridCacheVersion futVer,
                   GridCacheAtomicFuture<K,?> fut)

Parameters:

futVer - Future ID.

fut - Future.

atomicFuture

@Nullable
public GridFuture<?> atomicFuture(GridCacheVersion futVer)

Gets future by given future ID.

Parameters:

futVer - Future ID.

Returns:

Future.

removeAtomicFuture

@Nullable
public GridFuture<?> removeAtomicFuture(GridCacheVersion futVer)

Parameters:

futVer - Future ID.

Returns:

Removed future.

addFuture

public boolean addFuture(GridCacheFuture<?> fut)

Adds future.

Parameters:

fut - Future.

Returns:

True if added.

removeFuture

public boolean removeFuture(GridCacheFuture<?> fut)

Parameters:

fut - Future to remove.

Returns:

True if removed.

future

@Nullable
public <T> GridCacheFuture<T> future(GridCacheVersion ver,
                                     GridUuid futId)

Gets future for given future ID and lock ID.

Parameters:

ver - Lock ID.

futId - Future ID.

Returns:

Future.

futures

public <T> Collection<? extends GridFuture<T>> futures(GridCacheVersion ver)

Gets all futures for given lock version, possibly empty collection.

Parameters:

ver - Version.

Returns:

All futures for given lock version.

isRemoved

public boolean isRemoved(GridCacheVersion ver)

Parameters:

ver - Lock version to check.

Returns:

True if lock had been removed.

addRemoved

public boolean addRemoved(GridCacheVersion ver)

Parameters:

ver - Obsolete entry version.

Returns:

True if added.

remoteCandidates

public Collection<GridCacheMvccCandidate<K>> remoteCandidates()

This method has poor performance, so use with care. It is currently only used by DGC.

Returns:

Remote candidates.

localCandidates

public Collection<GridCacheMvccCandidate<K>> localCandidates()

This method has poor performance, so use with care. It is currently only used by DGC.

Returns:

Local candidates.

addLocal

public boolean addLocal(GridCacheMvccCandidate<K> cand)

Parameters:

cand - Local lock.

Returns:

True if added.

removeLocal

public boolean removeLocal(GridCacheMvccCandidate<K> cand)

Parameters:

cand - Local candidate to remove.

Returns:

True if removed.

localDhtPendingVersions

public Collection<GridCacheVersion> localDhtPendingVersions(Collection<K> keys,
                                                   GridCacheVersion base)

Parameters:

keys - Keys.

base - Base version.

Returns:

Versions that are less than base whose keys are in the keys collection.

addNext

public boolean addNext(GridCacheMvccCandidate<K> cand)

Parameters:

cand - Cache lock candidate to add.

Returns:

True if added as a result of this operation, false if was previously added.

addExplicitLock

public void addExplicitLock(long threadId,
                   GridCacheMvccCandidate<K> cand,
                   GridDiscoveryTopologySnapshot snapshot)

Adds candidate to the list of near local candidates.

Parameters:

threadId - Thread ID.

cand - Candidate to add.

snapshot - Topology snapshot.

removeExplicitLock

public void removeExplicitLock(GridCacheMvccCandidate<K> cand)

Removes candidate from the list of near local candidates.

Parameters:

cand - Candidate to remove.

isLockedByThread

public boolean isLockedByThread(K key,
                       long threadId)

Checks if given key is locked by thread with given id or any thread.

Parameters:

key - Key to check.

threadId - Thread id. If -1, all threads will be checked.

Returns:

True if locked by any or given thread (depending on threadId value).

markExplicitOwner

public void markExplicitOwner(K key,
                     long threadId)

Marks candidates for given thread and given key as owned.

Parameters:

key - Key.

threadId - Thread id.

removeExplicitLock

public GridCacheMvccCandidate<K> removeExplicitLock(long threadId,
                                           K key,
                                           @Nullable
                                           GridCacheVersion ver)

Removes explicit lock for given thread id, key and optional version.

Parameters:

threadId - Thread id.

key - Key.

ver - Optional version.

Returns:

Candidate.

explicitLock

@Nullable
public GridCacheMvccCandidate<K> explicitLock(long threadId,
                                              K key)

Gets last added explicit lock candidate by thread id and key.

Parameters:

threadId - Thread id.

key - Key to look up.

Returns:

Last added explicit lock candidate for given thread id and key or null if no such candidate.

explicitLock

@Nullable
public GridCacheMvccCandidate<K> explicitLock(K key,
                                              @Nullable
                                              GridCacheVersion ver)

Gets explicit lock candidate added by any thread by given key and lock version.

Parameters:

key - Key.

ver - Version.

Returns:

Lock candidate that satisfies given criteria or null if no such candidate.

lastExplicitLockTopologySnapshot

@Nullable
public GridDiscoveryTopologySnapshot lastExplicitLockTopologySnapshot(long threadId)

Parameters:

threadId - Thread ID.

Returns:

Topology snapshot for last acquired and not released lock.

printMemoryStats

public void printMemoryStats()

Prints memory statistics (sizes of internal data structures, etc.). NOTE: this method is for testing and profiling purposes only.

Specified by:

printMemoryStats in interface GridCacheManager<K,V>

Overrides:

printMemoryStats in class GridCacheManagerAdapter<K,V>

finishLocks

public GridFuture<?> finishLocks(Collection<Integer> parts,
                        long topVer)

Parameters:

parts - Partition numbers.

topVer - Topology version.

Returns:

Future that signals when all locks for given partitions are released.

finishExplicitLocks

public GridFuture<?> finishExplicitLocks(long topVer)

Creates a future that will wait for all explicit locks acquired on given topology version to be released.

Parameters:

topVer - Topology version to wait for.

Returns:

Explicit locks release future.

finishAtomicUpdates

public GridFuture<?> finishAtomicUpdates(long topVer,
                                Collection<Integer> parts)

Parameters:

topVer - Topology version to finish.

parts - Moving partitions.

Returns:

Finish update future.

finishKeys

public GridFuture<?> finishKeys(Collection<K> keys,
                       long topVer)

Parameters:

keys - Key for which locks should be released.

topVer - Topology version.

Returns:

Future that signals when all locks for given keys are released.

recheckPendingLocks

public void recheckPendingLocks()