com.atlassian.crowd.dao.cluster

Class ClusterLockDAOHibernate

java.lang.Object

com.atlassian.crowd.util.persistence.hibernate.StatelessDao

com.atlassian.crowd.util.persistence.hibernate.HibernateDao

com.atlassian.crowd.dao.cluster.ClusterLockDAOHibernate

public class ClusterLockDAOHibernate
extends HibernateDao

Hibernate DAO to store cluster locks

Field Summary

Fields inherited from class com.atlassian.crowd.util.persistence.hibernate.HibernateDao

batchFinder, batchProcessor, logger, statelessSessionBatchProcessor, timeSource

Fields inherited from class com.atlassian.crowd.util.persistence.hibernate.StatelessDao

sessionFactory

Constructor Summary

Constructors

Constructor and Description
ClusterLockDAOHibernate()

Method Summary

Modifier and Type	Method and Description
void	deleteLocksHeldByNode(String nodeId)
ClusterLockEntity	getLockByName(String lockName)
Class<ClusterLockEntity>	getPersistentClass() All subclasses of HibernateDao must implement this method for #load(long) to work correctly.
void	insertEmptyClusterLock(String lockName, long updateTime) Attempt to insert an "unlocked" DB row for the named lock.
List<ClusterLockEntity>	list()
boolean	tryUpdateAcquireLock(String lockName, String nodeId, long updateTime) Attempt to acquire an existing named lock for the given nodeId.
void	unlock(String lockName, String nodeId, long updateTime) Unlock the named lock, if this node still holds the lock.

Methods inherited from class com.atlassian.crowd.util.persistence.hibernate.HibernateDao

createHibernateQuery, findByProperties, findByProperties, load, load, loadOptional, loadOptional, loadReference, loadReference, remove, save, saveOrUpdate, session, setBatchFinder, setBatchProcessor, setClock, setStatelessSessionBatchProcessor, toPredicates, update

Methods inherited from class com.atlassian.crowd.util.persistence.hibernate.StatelessDao

setSessionFactory, withStatelessSession

Methods inherited from class java.lang.Object

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

Constructor Detail

ClusterLockDAOHibernate

public ClusterLockDAOHibernate()

Method Detail

getPersistentClass

public Class<ClusterLockEntity> getPersistentClass()

Description copied from class: HibernateDao

All subclasses of HibernateDao must implement this method for #load(long) to work correctly.

Specified by:

getPersistentClass in class HibernateDao

Returns:

the entity class for this DAO

getLockByName

public ClusterLockEntity getLockByName(String lockName)

tryUpdateAcquireLock

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

Attempt to acquire an existing named lock for the given nodeId.

Parameters:

lockName - the globally unique id of the lock

nodeId - This node's ID

updateTime - the time in milliseconds that this update was written

Returns:

true if we acquired the lock, false if the row exists but is already locked.

insertEmptyClusterLock

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

Attempt to insert an "unlocked" DB row for the named lock.

Parameters:

lockName - the lock identifier

updateTime - the time in milliseconds that this insert was written

unlock

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

Unlock the named lock, if this node still holds the lock.

Parameters:

lockName - the lock identifier

nodeId - This node's ID

updateTime - the time in milliseconds that this update was written

list

public List<ClusterLockEntity> list()

deleteLocksHeldByNode

public void deleteLocksHeldByNode(String nodeId)