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

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
protected static final class	ClusterNodesCommandsExecutorImpl.StatusReporter

Constructor Summary

Constructors

Modifier	Constructor	Description
	ClusterNodesCommandsExecutorImpl(PeerToPeerClient peerToPeerClient, BambooClusterNodeHeartbeatService bambooClusterNodeHeartbeatService)
protected	ClusterNodesCommandsExecutorImpl(PeerToPeerClient peerToPeerClient, BambooClusterNodeHeartbeatService bambooClusterNodeHeartbeatService, ClusterNodesCommandsExecutorImpl.StatusReporter statusReporter)

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 Details

ClusterNodesCommandsExecutorImpl

@Inject
public ClusterNodesCommandsExecutorImpl(PeerToPeerClient peerToPeerClient,
 BambooClusterNodeHeartbeatService bambooClusterNodeHeartbeatService)

ClusterNodesCommandsExecutorImpl

@VisibleForTesting
protected ClusterNodesCommandsExecutorImpl(PeerToPeerClient peerToPeerClient,
 BambooClusterNodeHeartbeatService bambooClusterNodeHeartbeatService,
 ClusterNodesCommandsExecutorImpl.StatusReporter statusReporter)

Method Details

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)