com.atlassian.crowd.manager.cluster.locks

Class CrowdClusterLockDaoDecorator

java.lang.Object

com.atlassian.crowd.manager.cluster.locks.CrowdClusterLockDaoDecorator

All Implemented Interfaces:

com.atlassian.beehive.db.spi.ClusterLockDao

public class CrowdClusterLockDaoDecorator
extends Object
implements com.atlassian.beehive.db.spi.ClusterLockDao

Constructor Summary

Constructors

Constructor and Description
CrowdClusterLockDaoDecorator(ClusterLockDAOHibernate dao)

Method Summary

Modifier and Type	Method and Description
void	deleteLocksHeldByNode(String nodeId)
List<com.atlassian.beehive.core.ClusterLockStatus>	getAllHeldClusterLocks()
com.atlassian.beehive.core.ClusterLockStatus	getClusterLockStatusByName(String lockName)
void	insertEmptyClusterLock(String lockName, long updateTime)
boolean	tryUpdateAcquireLock(String lockName, String nodeId, long updateTime)
void	unlock(String lockName, String nodeId, long updateTime)

Methods inherited from class java.lang.Object

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

Constructor Detail

CrowdClusterLockDaoDecorator

public CrowdClusterLockDaoDecorator(ClusterLockDAOHibernate dao)

Method Detail

getAllHeldClusterLocks

@Nonnull
public List<com.atlassian.beehive.core.ClusterLockStatus> getAllHeldClusterLocks()

Specified by:

getAllHeldClusterLocks in interface com.atlassian.beehive.db.spi.ClusterLockDao

getClusterLockStatusByName

@Nullable
public com.atlassian.beehive.core.ClusterLockStatus getClusterLockStatusByName(@Nonnull
                                                                                         String lockName)

Specified by:

getClusterLockStatusByName in interface com.atlassian.beehive.db.spi.ClusterLockDao

tryUpdateAcquireLock

public boolean tryUpdateAcquireLock(@Nonnull
                                    String lockName,
                                    @Nonnull
                                    String nodeId,
                                    long updateTime)

Specified by:

tryUpdateAcquireLock in interface com.atlassian.beehive.db.spi.ClusterLockDao

insertEmptyClusterLock

public void insertEmptyClusterLock(@Nonnull
                                   String lockName,
                                   long updateTime)

Specified by:

insertEmptyClusterLock in interface com.atlassian.beehive.db.spi.ClusterLockDao

unlock

public void unlock(@Nonnull
                   String lockName,
                   @Nonnull
                   String nodeId,
                   long updateTime)

Specified by:

unlock in interface com.atlassian.beehive.db.spi.ClusterLockDao

deleteLocksHeldByNode

public void deleteLocksHeldByNode(String nodeId)

Specified by:

deleteLocksHeldByNode in interface com.atlassian.beehive.db.spi.ClusterLockDao