com.atlassian.bamboo.beehive

Class BambooClusterLockRawJdbcDao

java.lang.Object

com.atlassian.bamboo.beehive.AbstractBambooRawJdbcDao

com.atlassian.bamboo.beehive.BambooClusterLockRawJdbcDao

All Implemented Interfaces:

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

public class BambooClusterLockRawJdbcDao
extends AbstractBambooRawJdbcDao
implements ClusterLockBootstrapDao

Field Summary

Fields inherited from class com.atlassian.bamboo.beehive.AbstractBambooRawJdbcDao

dbmsBean, hibernateConfig

Constructor Summary

Constructors

Constructor and Description
BambooClusterLockRawJdbcDao(@NotNull ClusterNodeHeartbeatBootstrapDao clusterNodeHeartbeatBootstrapDao)

Method Summary

Modifier and Type	Method and Description
void	deleteLocksHeldByNode(String nodeId)
void	ensureClusterLockTableExists()
@NotNull List<com.atlassian.beehive.core.ClusterLockStatus>	getAllHeldClusterLocks()
@Nullable com.atlassian.beehive.core.ClusterLockStatus	getClusterLockStatusByName(@NotNull String lockName)
void	insertEmptyClusterLock(@NotNull String lockName)
void	releaseLocksHeldByNode()
void	renewLease(@NotNull String lockName)
void	renewLease(@NotNull String lockName, @NotNull String nodeId)
boolean	tryAcquireLock(@NotNull String lockName)
boolean	tryUpdateAcquireNodeScopedLock(@NotNull String lockName, @NotNull String nodeId, long lockTimeoutSeconds)
void	unlock(@NotNull String lockName)
void	unlock(@NotNull String lockName, @NotNull String nodeId)

Methods inherited from class com.atlassian.bamboo.beehive.AbstractBambooRawJdbcDao

ensureClusterTableExists, supplierWithConnection, withDatabaseConnection

Methods inherited from class java.lang.Object

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

Constructor Detail

BambooClusterLockRawJdbcDao

public BambooClusterLockRawJdbcDao(@NotNull
                                   @NotNull ClusterNodeHeartbeatBootstrapDao clusterNodeHeartbeatBootstrapDao)

Method Detail

getAllHeldClusterLocks

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

Specified by:

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

getClusterLockStatusByName

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

Specified by:

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

tryAcquireLock

public boolean tryAcquireLock(@NotNull
                              @NotNull String lockName)

Specified by:

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

tryUpdateAcquireNodeScopedLock

public boolean tryUpdateAcquireNodeScopedLock(@NotNull
                                              @NotNull String lockName,
                                              @NotNull
                                              @NotNull String nodeId,
                                              long lockTimeoutSeconds)

Specified by:

tryUpdateAcquireNodeScopedLock in interface ClusterLockBootstrapDao

insertEmptyClusterLock

public void insertEmptyClusterLock(@NotNull
                                   @NotNull String lockName)

Specified by:

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

unlock

public void unlock(@NotNull
                   @NotNull String lockName)

Specified by:

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

renewLease

public void renewLease(@NotNull
                       @NotNull String lockName)

Specified by:

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

renewLease

public void renewLease(@NotNull
                       @NotNull String lockName,
                       @NotNull
                       @NotNull String nodeId)

unlock

public void unlock(@NotNull
                   @NotNull String lockName,
                   @NotNull
                   @NotNull String nodeId)

Specified by:

unlock in interface ClusterLockBootstrapDao

releaseLocksHeldByNode

public void releaseLocksHeldByNode()

Specified by:

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

deleteLocksHeldByNode

public void deleteLocksHeldByNode(String nodeId)

ensureClusterLockTableExists

public void ensureClusterLockTableExists()

Specified by:

ensureClusterLockTableExists in interface ClusterLockBootstrapDao