com.atlassian.jira.cluster.lock

Class ZDUAwareJiraClusterLockQueryDSLDao

java.lang.Object

com.atlassian.jira.cluster.lock.JiraClusterLockQueryDSLDao

com.atlassian.jira.cluster.lock.ZDUAwareJiraClusterLockQueryDSLDao

All Implemented Interfaces:

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

public class ZDUAwareJiraClusterLockQueryDSLDao
extends JiraClusterLockQueryDSLDao

An implementation of ClusterLockDao that can switch between old hearbeat-based lock eviction and eviction based on leases.

Since:

v8.2

Field Summary

Fields inherited from class com.atlassian.jira.cluster.lock.JiraClusterLockQueryDSLDao

LEASE_EXPIRY_TIME_MS

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and Description
protected com.querydsl.sql.dml.SQLUpdateClause	getAcquireLockQuery(DbConnection dbConnection, String lockName, Long dbTime)
protected com.querydsl.sql.SQLQuery	getHeldClusterLocksQuery(DbConnection dbConnection, Long dbTime)

Methods inherited from class com.atlassian.jira.cluster.lock.JiraClusterLockQueryDSLDao

getAllHeldClusterLocks, getClusterLockStatusByName, getDatabaseTime, insertEmptyClusterLock, releaseAllClusterLocks, releaseLocksHeldByNode, renewLease, tryAcquireLock, unlock

Methods inherited from class java.lang.Object

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

Constructor Detail

ZDUAwareJiraClusterLockQueryDSLDao

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

Method Detail

getHeldClusterLocksQuery

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

Specified by:

getHeldClusterLocksQuery in class JiraClusterLockQueryDSLDao

getAcquireLockQuery

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

Specified by:

getAcquireLockQuery in class JiraClusterLockQueryDSLDao