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() Creates lock table if required.
@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) Try to acquire an existing lock for the given node.
void	unlock(@NotNull String lockName)
void	unlock(@NotNull String lockName, @NotNull String nodeId) Force unlock a lock held by a specified node.

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)

Description copied from interface: ClusterLockBootstrapDao

Try to acquire an existing lock for the given node. This method will succeed and will update the lock timestamp both when the lock has been just acquired by the node and when the lock is already owned by the current node. See also ClusterLockDao.tryAcquireLock(String)

Specified by:

tryUpdateAcquireNodeScopedLock in interface ClusterLockBootstrapDao

Parameters:

lockName - name of the lock to acquire

nodeId - this node id

lockTimeoutSeconds - time (in seconds) after which the lock can be taken over

Returns:

true if the lock has been acquired/updated successfully, false otherwise

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)

Description copied from interface: ClusterLockBootstrapDao

Force unlock a lock held by a specified node.

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()

Description copied from interface: ClusterLockBootstrapDao

Creates lock table if required.

Specified by:

ensureClusterLockTableExists in interface ClusterLockBootstrapDao