com.atlassian.confluence.impl.beehive

Class BeehiveLockDao

java.lang.Object

com.atlassian.confluence.impl.beehive.BeehiveLockDao

All Implemented Interfaces:

cloud.atlassian.beehive.db.spi.ClusterLockDao

public class BeehiveLockDao
extends Object
implements cloud.atlassian.beehive.db.spi.ClusterLockDao

Hibernate implementation of ClusterLockDao.

All methods are executed outside current session's transaction.

Constructor Summary

Constructors

Constructor and Description
BeehiveLockDao(org.hibernate.SessionFactory sessionFactory)

Method Summary

Modifier and Type	Method and Description
void	ensureClusterLockExists(String lockName, long heartbeatTime)
cloud.atlassian.beehive.db.ClusterLockStatus	getClusterLockStatusByName(String lockName)
int	tryUpdateAcquireLock(String lockName, String lockedByThread, long heartbeatTime)
int	unlock(String lockName, String lockedByThread)
int	writeHeartbeat(String lockName, String lockedByThread, long heartbeatTime)

Methods inherited from class java.lang.Object

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

Constructor Detail

BeehiveLockDao

public BeehiveLockDao(org.hibernate.SessionFactory sessionFactory)

Method Detail

getClusterLockStatusByName

@Nullable
public cloud.atlassian.beehive.db.ClusterLockStatus getClusterLockStatusByName(@Nonnull
                                                                                         String lockName)

Specified by:

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

tryUpdateAcquireLock

public int tryUpdateAcquireLock(@Nonnull
                                String lockName,
                                @Nonnull
                                String lockedByThread,
                                long heartbeatTime)

Specified by:

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

writeHeartbeat

public int writeHeartbeat(String lockName,
                          String lockedByThread,
                          long heartbeatTime)

Specified by:

writeHeartbeat in interface cloud.atlassian.beehive.db.spi.ClusterLockDao

ensureClusterLockExists

public void ensureClusterLockExists(@Nonnull
                                    String lockName,
                                    long heartbeatTime)

Specified by:

ensureClusterLockExists in interface cloud.atlassian.beehive.db.spi.ClusterLockDao

unlock

public int unlock(@Nonnull
                  String lockName,
                  @Nonnull
                  String lockedByThread)

Specified by:

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