org.apache.ignite.internal.processors.cache

Class GridCacheExplicitLockSpan

java.lang.Object

java.util.concurrent.locks.ReentrantLock

org.apache.ignite.internal.processors.cache.GridCacheExplicitLockSpan

All Implemented Interfaces:

Serializable, Lock

public class GridCacheExplicitLockSpan
extends ReentrantLock

Collection of near local locks acquired by a thread on one topology version.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
GridCacheExplicitLockSpan(GridDiscoveryTopologySnapshot topSnapshot, GridCacheMvccCandidate cand)

Method Summary

Methods

Modifier and Type	Method and Description
boolean	addCandidate(GridDiscoveryTopologySnapshot topSnapshot, GridCacheMvccCandidate cand) Adds candidate to a lock span.
GridCacheMvccCandidate	candidate(KeyCacheObject key, GridCacheVersion ver) Gets explicit lock candidate for given key.
boolean	isEmpty()
void	markOwned(KeyCacheObject key) Marks all candidates added for given key as owned.
IgniteInternalFuture<Object>	releaseFuture() Gets span release future.
boolean	removeCandidate(GridCacheMvccCandidate cand) Removes candidate from this lock span.
GridCacheMvccCandidate	removeCandidate(KeyCacheObject key, GridCacheVersion ver) Removes lock by key and optional version.
GridDiscoveryTopologySnapshot	topologySnapshot() Gets actual topology snapshot for thread lock span.
String	toString()

Methods inherited from class java.util.concurrent.locks.ReentrantLock

getHoldCount, getOwner, getQueuedThreads, getQueueLength, getWaitingThreads, getWaitQueueLength, hasQueuedThread, hasQueuedThreads, hasWaiters, isFair, isHeldByCurrentThread, isLocked, lock, lockInterruptibly, newCondition, tryLock, tryLock, unlock

Methods inherited from class java.lang.Object

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

Constructor Detail

GridCacheExplicitLockSpan

public GridCacheExplicitLockSpan(GridDiscoveryTopologySnapshot topSnapshot,
                         GridCacheMvccCandidate cand)

Parameters:

topSnapshot - Topology snapshot.

cand - Candidate.

Method Detail

addCandidate

public boolean addCandidate(GridDiscoveryTopologySnapshot topSnapshot,
                   GridCacheMvccCandidate cand)

Adds candidate to a lock span.

Parameters:

topSnapshot - Topology snapshot for which candidate is added.

cand - Candidate to add.

Returns:

True if candidate was added, false if this span is empty and new span should be created.

removeCandidate

public boolean removeCandidate(GridCacheMvccCandidate cand)

Removes candidate from this lock span.

Parameters:

cand - Candidate to remove.

Returns:

True if span is empty and should be removed, false otherwise.

removeCandidate

public GridCacheMvccCandidate removeCandidate(KeyCacheObject key,
                                     @Nullable
                                     GridCacheVersion ver)

Removes lock by key and optional version.

Parameters:

key - Key.

ver - Version (or null if any candidate should be removed.)

Returns:

Removed candidate if matches given parameters.

isEmpty

public boolean isEmpty()

Returns:

True if span is empty and candidates cannot be added anymore.

markOwned

public void markOwned(KeyCacheObject key)

Marks all candidates added for given key as owned.

Parameters:

key - Key.

candidate

@Nullable
public GridCacheMvccCandidate candidate(KeyCacheObject key,
                                        @Nullable
                                        GridCacheVersion ver)

Gets explicit lock candidate for given key.

Parameters:

key - Key to lookup.

ver - Version to lookup (if null - return any).

Returns:

Last added explicit lock candidate, if any, or null.

topologySnapshot

@Nullable
public GridDiscoveryTopologySnapshot topologySnapshot()

Gets actual topology snapshot for thread lock span.

Returns:

Topology snapshot or null if candidate list is empty.

releaseFuture

public IgniteInternalFuture<Object> releaseFuture()

Gets span release future. Future is completed when last lock is released.

Returns:

Release future.

toString

public String toString()

Overrides:

toString in class ReentrantLock