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
All Methods Instance Methods Concrete Methods 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)
-
-
-
Constructor Detail
-
ClusterNodesCommandsExecutorImpl
@Inject public ClusterNodesCommandsExecutorImpl(PeerToPeerClient peerToPeerClient, BambooClusterNodeHeartbeatService bambooClusterNodeHeartbeatService)
-
-
Method Detail
-
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 orcom.atlassian.bamboo.cluster.BambooClusterSettings.CLUSTER_HEARTBEAT_JOB_INTERVAL_IN_SECONDS
seconds passed.- Specified by:
ensureNodeVisibilityOrWait
in interfaceClusterNodesCommandsExecutor
- 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)
-
-