com.atlassian.jira.cluster.lock

Class JiraClusterLockQueryDSLDao

java.lang.Object

com.atlassian.jira.cluster.lock.JiraClusterLockQueryDSLDao

All Implemented Interfaces:

com.atlassian.beehive.db.spi.ClusterLockDao, ClusterLockCleanupDao

Direct Known Subclasses:

ZDUAwareJiraClusterLockQueryDSLDao

public abstract class JiraClusterLockQueryDSLDao
extends Object
implements com.atlassian.beehive.db.spi.ClusterLockDao, ClusterLockCleanupDao

JIRA implementation of the ClusterLockDao from the beehive clustering library.

Since:

v8.2

Field Summary

Fields

Modifier and Type	Field and Description
static long	LEASE_EXPIRY_TIME_MS

Constructor Summary

Constructors

Constructor and Description
JiraClusterLockQueryDSLDao(QueryDslAccessor queryDslAccessor, ClusterNodeHeartBeatDao clusterNodeHeartBeatDao, DatabaseSystemTimeReaderFactory databaseSystemTimeReaderFactory)

Method Summary

Modifier and Type	Method and Description
protected abstract com.querydsl.sql.dml.SQLUpdateClause	getAcquireLockQuery(DbConnection dbConnection, String lockName, Long dbTime)
List<com.atlassian.beehive.core.ClusterLockStatus>	getAllHeldClusterLocks()
com.atlassian.beehive.core.ClusterLockStatus	getClusterLockStatusByName(String lockName)
protected long	getDatabaseTime()
protected abstract com.querydsl.sql.SQLQuery	getHeldClusterLocksQuery(DbConnection dbConnection, Long dbTime)
void	insertEmptyClusterLock(String lockName)
void	releaseAllClusterLocks() Release all cluster locks.
void	releaseLocksHeldByNode()
void	renewLease(String lockName)
boolean	tryAcquireLock(String lockName)
void	unlock(String lockName)

Methods inherited from class java.lang.Object

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

Field Detail

LEASE_EXPIRY_TIME_MS

public static final long LEASE_EXPIRY_TIME_MS

Constructor Detail

JiraClusterLockQueryDSLDao

public JiraClusterLockQueryDSLDao(QueryDslAccessor queryDslAccessor,
                                  ClusterNodeHeartBeatDao clusterNodeHeartBeatDao,
                                  DatabaseSystemTimeReaderFactory databaseSystemTimeReaderFactory)

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

tryAcquireLock

public boolean tryAcquireLock(@Nonnull
                              String lockName)

Specified by:

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

insertEmptyClusterLock

public void insertEmptyClusterLock(@Nonnull
                                   String lockName)

Specified by:

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

unlock

public void unlock(@Nonnull
                   String lockName)

Specified by:

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

releaseAllClusterLocks

public void releaseAllClusterLocks()

Description copied from interface: ClusterLockCleanupDao

Release all cluster locks.

Specified by:

releaseAllClusterLocks in interface ClusterLockCleanupDao

renewLease

public void renewLease(@Nonnull
                       String lockName)

Specified by:

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

releaseLocksHeldByNode

public void releaseLocksHeldByNode()

Specified by:

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

getDatabaseTime

protected long getDatabaseTime()

getHeldClusterLocksQuery

protected abstract com.querydsl.sql.SQLQuery getHeldClusterLocksQuery(DbConnection dbConnection,
                                                                      Long dbTime)

getAcquireLockQuery

protected abstract com.querydsl.sql.dml.SQLUpdateClause getAcquireLockQuery(DbConnection dbConnection,
                                                                            String lockName,
                                                                            Long dbTime)