com.atlassian.jira.cluster.lock

Class JiraClusterNodeHeartBeatDao

java.lang.Object

com.atlassian.jira.cluster.lock.JiraClusterNodeHeartBeatDao

All Implemented Interfaces:

com.atlassian.beehive.db.spi.ClusterNodeHeartBeatDao, TimedClusterNodeHeartBeatDao

public class JiraClusterNodeHeartBeatDao
extends Object
implements TimedClusterNodeHeartBeatDao

JIRA implementation of ClusterNodeHeartBeatDao - used for cluster locks.

Since:

6.3

Constructor Summary

Constructors

Constructor and Description
JiraClusterNodeHeartBeatDao(ClusterManager clusterManager, EntityEngine entityEngine, DatabaseSystemTimeReaderFactory dbTimeReaderFactory)

Method Summary

Methods

Modifier and Type	Method and Description
Collection<String>	findNodesWithHeartbeatsAfter(long time)
Map<String,Long>	getActiveNodesDatabaseTimeOffsets(long databaseActiveTime) Returns each active cluster node's clock offset from the database clock.
Long	getLastHeartbeatTime(String nodeId)
String	getNodeId()
void	writeHeartBeat(long time)

Methods inherited from class java.lang.Object

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

Constructor Detail

JiraClusterNodeHeartBeatDao

public JiraClusterNodeHeartBeatDao(ClusterManager clusterManager,
                           EntityEngine entityEngine,
                           DatabaseSystemTimeReaderFactory dbTimeReaderFactory)

Method Detail

getNodeId

@Nonnull
public String getNodeId()

Specified by:

getNodeId in interface com.atlassian.beehive.db.spi.ClusterNodeHeartBeatDao

writeHeartBeat

public void writeHeartBeat(long time)

Specified by:

writeHeartBeat in interface com.atlassian.beehive.db.spi.ClusterNodeHeartBeatDao

getLastHeartbeatTime

@Nullable
public Long getLastHeartbeatTime(@Nonnull
                                 String nodeId)

Specified by:

getLastHeartbeatTime in interface com.atlassian.beehive.db.spi.ClusterNodeHeartBeatDao

getActiveNodesDatabaseTimeOffsets

@Nonnull
public Map<String,Long> getActiveNodesDatabaseTimeOffsets(long databaseActiveTime)

Description copied from interface: TimedClusterNodeHeartBeatDao

Returns each active cluster node's clock offset from the database clock.

The returned map maps node IDs to their clock offset times in milliseconds. A clock offset time is the number of milliseconds difference between that node's system clock and the clock of the database. These values can be used to determine how synchronized the node's clocks are.

It is possible that a node's time offset value is returned as null if they have not registered a heartbeat yet after they have started up or if they are upgrading their version and have not written a database time value in the database yet.

Specified by:

getActiveNodesDatabaseTimeOffsets in interface TimedClusterNodeHeartBeatDao

Parameters:

databaseActiveTime - the minimum database time a node should have in the system to regard it as active. Nodes that registered their heartbeat with an associated database time less than this value will not be returned.

Returns:

a map mapping node IDs to offset times in milliseconds.

findNodesWithHeartbeatsAfter

@Nonnull
public Collection<String> findNodesWithHeartbeatsAfter(long time)

Specified by:

findNodesWithHeartbeatsAfter in interface com.atlassian.beehive.db.spi.ClusterNodeHeartBeatDao