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
void	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)
@NotNull List<String>	getUnnotifiedNodes(@NotNull List<String> allAskedNodeIds, @NotNull List<String> successfullyNotifiedNodes)

Methods inherited from class java.lang.Object

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

Constructor Detail

ClusterNodesCommandsExecutorImpl

@Inject
public ClusterNodesCommandsExecutorImpl(PeerToPeerClient peerToPeerClient,
                                        BambooClusterNodeHeartbeatService bambooClusterNodeHeartbeatService)

Method Detail

ensureNodeVisibilityOrWait

public void ensureNodeVisibilityOrWait()
                                throws StartupException

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

Throws:

StartupException - if the notification to other nodes fails, indicating potential connection issues between nodes.

getRemainingTime

@VisibleForTesting
protected long getRemainingTime(long startTime)

getUnnotifiedNodes

@NotNull
public @NotNull List<String> getUnnotifiedNodes(@NotNull
                                                @NotNull List<String> allAskedNodeIds,
                                                @NotNull
                                                @NotNull List<String> successfullyNotifiedNodes)