Package com.atlassian.bamboo.cluster.peertopeer

Class ClusterNodesCommandsExecutorImpl

java.lang.Object

com.atlassian.bamboo.cluster.peertopeer.ClusterNodesCommandsExecutorImpl

All Implemented Interfaces:

ClusterNodesCommandsExecutor

public class ClusterNodesCommandsExecutorImpl
extends Object
implements ClusterNodesCommandsExecutor

Constructor Summary

Constructors

Constructor	Description
ClusterNodesCommandsExecutorImpl(PeerToPeerClient peerToPeerClient, BambooClusterNodeHeartbeatService bambooClusterNodeHeartbeatService)

Method Summary

Modifier and Type	Method	Description
boolean	ensureNodeVisibilityOrWait()	Notifying all cluster nodes that the node the method is called on is reachable and visible to the cluster.
protected long	getRemainingTime(long startTime)

Methods inherited from class java.lang.Object

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

Constructor Details

ClusterNodesCommandsExecutorImpl

@Inject
public ClusterNodesCommandsExecutorImpl(PeerToPeerClient peerToPeerClient,
 BambooClusterNodeHeartbeatService bambooClusterNodeHeartbeatService)

Method Details

ensureNodeVisibilityOrWait

public boolean ensureNodeVisibilityOrWait()

Description copied from interface: ClusterNodesCommandsExecutor

Notifying all cluster nodes that the node the method is called on is reachable and visible to the cluster. The method will block until either all nodes in the cluster have acknowledged the visibility of the node or com.atlassian.bamboo.cluster.BambooClusterSettings.CLUSTER_HEARTBEAT_JOB_INTERVAL_IN_SECONDS seconds passed.

Specified by:

ensureNodeVisibilityOrWait in interface ClusterNodesCommandsExecutor

Returns:

true if all nodes in the cluster have explicitly acknowledged the visibility of the node, false if the function had to wait

getRemainingTime

protected long getRemainingTime(long startTime)