org.jboss.as.clustering.lock

Class NonGloballyExclusiveClusterLockSupport

java.lang.Object

org.jboss.as.clustering.lock.AbstractClusterLockSupport

org.jboss.as.clustering.lock.NonGloballyExclusiveClusterLockSupport

All Implemented Interfaces:

GroupMembershipListener

public class NonGloballyExclusiveClusterLockSupport
extends AbstractClusterLockSupport

Support class for cluster locking scenarios where threads can hold a local lock on a category but not a cluster-wide lock. Multiple nodes can simultaneously hold a local lock on a category, but none can hold a local lock on a category if the cluster-wide lock is held. Cluster-wide lock cannot be acquired while any node holds a local lock.

NOTE: This class does not support "upgrades", i.e. scenarios where a thread acquires the local lock and then while holding the local lock attempts to acquire the cluster-wide lock.

Author:

Brian Stansberry

Nested Class Summary

Nested classes/interfaces inherited from class org.jboss.as.clustering.lock.AbstractClusterLockSupport

AbstractClusterLockSupport.RpcTarget

Field Summary

Fields inherited from class org.jboss.as.clustering.lock.AbstractClusterLockSupport

RELEASE_REMOTE_LOCK_TYPES, REMOTE_LOCK_TYPES

Constructor Summary

Constructors

Constructor and Description
NonGloballyExclusiveClusterLockSupport(String serviceHAName, GroupRpcDispatcher rpcDispatcher, GroupMembershipNotifier membershipNotifier, LocalLockHandler handler)

Method Summary

Methods

Modifier and Type	Method and Description
protected ClusterLockState	getClusterLockState(Serializable categoryName)
protected RemoteLockResponse	getRemoteLockResponseForUnknownLock(Serializable lockName, ClusterNode caller, long timeout)
protected RemoteLockResponse	handleLockSuccess(ClusterLockState lockState, ClusterNode caller)
void	unlock(Serializable lockId)
protected RemoteLockResponse	yieldLock(ClusterLockState lockState, ClusterNode caller, long timeout)

Methods inherited from class org.jboss.as.clustering.lock.AbstractClusterLockSupport

getClusterLockState, getCurrentView, getGroupMembershipNotifier, getGroupName, getGroupRpcDispatcher, getLocalClusterNode, getLocalHandler, getLock, getServiceHAName, lock, membershipChanged, membershipChangedDuringMerge, recordLockHolder, removeLockState, start, stop

Methods inherited from class java.lang.Object

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

Constructor Detail

NonGloballyExclusiveClusterLockSupport

public NonGloballyExclusiveClusterLockSupport(String serviceHAName,
                                      GroupRpcDispatcher rpcDispatcher,
                                      GroupMembershipNotifier membershipNotifier,
                                      LocalLockHandler handler)

Method Detail

unlock

public void unlock(Serializable lockId)

Specified by:

unlock in class AbstractClusterLockSupport

getClusterLockState

protected ClusterLockState getClusterLockState(Serializable categoryName)

Specified by:

getClusterLockState in class AbstractClusterLockSupport

yieldLock

protected RemoteLockResponse yieldLock(ClusterLockState lockState,
                           ClusterNode caller,
                           long timeout)

Specified by:

yieldLock in class AbstractClusterLockSupport

handleLockSuccess

protected RemoteLockResponse handleLockSuccess(ClusterLockState lockState,
                                   ClusterNode caller)

Specified by:

handleLockSuccess in class AbstractClusterLockSupport

getRemoteLockResponseForUnknownLock

protected RemoteLockResponse getRemoteLockResponseForUnknownLock(Serializable lockName,
                                                     ClusterNode caller,
                                                     long timeout)

Specified by:

getRemoteLockResponseForUnknownLock in class AbstractClusterLockSupport