com.atlassian.jira.cluster

Class DefaultClusterManager

java.lang.Object

com.atlassian.jira.cluster.DefaultClusterManager

All Implemented Interfaces:

ClusterInfo, ClusterManager, Startable

public class DefaultClusterManager
extends Object
implements ClusterManager, Startable

Manages the cluster - addition of nodes, removal, etc

Since:

v6.1

Field Summary

Fields inherited from interface com.atlassian.jira.cluster.ClusterManager

ALL_NODES, ANY_NODE

Constructor Summary

Constructors

Constructor and Description
DefaultClusterManager(ClusterNodes clusterNodes, com.atlassian.event.api.EventPublisher eventPublisher, ClusterLicenseCheck licenseCheck, MessageHandlerService messageHandlerService, NodeCutOffManager nodeCutOffManager)

Method Summary

Modifier and Type	Method and Description
void	checkIndex() Forces an index check to see if it is current (or can be rebuilt from current) - if the index is too out of date request an index replica, only do this on passive nodes for now
Collection<Node>	findLiveNodes() Returns a snapshot of the live nodes.
Set<Node>	getAllNodes() Returns all the nodes in the cluster.
String	getNodeId() Provides the node ID for this particular cluster node.
boolean	isActive() Returns true if this node is active.
boolean	isClustered() If there is a cluster.properties that appears to be valid
boolean	isClusterLicensed() Returns whether or not JIRA is licensed for clustered configurations.
boolean	isNodeAlive(String nodeId)
boolean	isNodeOffline(String nodeId)
boolean	isNodePresent(String nodeId)
void	moveToOffline(String nodeId) Update nodes's state to OFFLINE if current state is ACTIVE and nonalive
void	refreshLiveNodes() Merges the information from the heartbeat table and the clusternode table to give accurate information of which nodes are alive.
void	releaseNodeReindexService(IndexesRestoredEvent ev)
void	removeIfOffline(String nodeId) Remove node from cluster if node is OFFLINE
void	requestCurrentIndexFromNode(String destinationNode) We send a message to the node we wish a copy from.
void	start() This method will be called after the plugin system is fully initialised and all components added to the dependency injection framework.

Methods inherited from class java.lang.Object

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

Constructor Detail

DefaultClusterManager

public DefaultClusterManager(ClusterNodes clusterNodes,
                             com.atlassian.event.api.EventPublisher eventPublisher,
                             ClusterLicenseCheck licenseCheck,
                             MessageHandlerService messageHandlerService,
                             NodeCutOffManager nodeCutOffManager)

Method Detail

start

public void start()

Description copied from interface: Startable

This method will be called after the plugin system is fully initialised and all components added to the dependency injection framework.

Specified by:

start in interface Startable

getNodeId

@Nullable
public String getNodeId()

Description copied from interface: ClusterInfo

Provides the node ID for this particular cluster node.

Specified by:

getNodeId in interface ClusterInfo

Returns:

node id - null if the server is not in a cluster

isClustered

public boolean isClustered()

If there is a cluster.properties that appears to be valid

Specified by:

isClustered in interface ClusterInfo

Returns:

true if clustered

getAllNodes

public Set<Node> getAllNodes()

Description copied from interface: ClusterManager

Returns all the nodes in the cluster. If not clustered this will return an empty set.

Specified by:

getAllNodes in interface ClusterManager

Returns:

a collection of Nodes in a cluster

isActive

public boolean isActive()

Returns true if this node is active.

Specified by:

isActive in interface ClusterManager

Returns:

true if this node is active.

checkIndex

public void checkIndex()

Forces an index check to see if it is current (or can be rebuilt from current) - if the index is too out of date request an index replica, only do this on passive nodes for now

Specified by:

checkIndex in interface ClusterManager

requestCurrentIndexFromNode

public void requestCurrentIndexFromNode(String destinationNode)

Description copied from interface: ClusterManager

We send a message to the node we wish a copy from.

Specified by:

requestCurrentIndexFromNode in interface ClusterManager

Parameters:

destinationNode - Node to send the message to get an Index Copy from.

findLiveNodes

public Collection<Node> findLiveNodes()

Description copied from interface: ClusterManager

Returns a snapshot of the live nodes. This collection is refreshed in every heartbeat of the server. Or you can force it calling refreshLiveNodes()

Specified by:

findLiveNodes in interface ClusterManager

Returns:

the list of nodes that are alive.

refreshLiveNodes

public void refreshLiveNodes()

Description copied from interface: ClusterManager

Merges the information from the heartbeat table and the clusternode table to give accurate information of which nodes are alive.

Specified by:

refreshLiveNodes in interface ClusterManager

releaseNodeReindexService

@EventListener
public void releaseNodeReindexService(IndexesRestoredEvent ev)

isClusterLicensed

public boolean isClusterLicensed()

Description copied from interface: ClusterManager

Returns whether or not JIRA is licensed for clustered configurations.

Specified by:

isClusterLicensed in interface ClusterManager

Returns:

whether or not JIRA is licensed for clustered configurations.

removeIfOffline

public void removeIfOffline(@NotNull
                            String nodeId)
                     throws ClusterStateException

Description copied from interface: ClusterManager

Remove node from cluster if node is OFFLINE

Specified by:

removeIfOffline in interface ClusterManager

Throws:

ClusterStateException - if node is not offline

moveToOffline

public void moveToOffline(@NotNull
                          String nodeId)
                   throws ClusterStateException

Description copied from interface: ClusterManager

Update nodes's state to OFFLINE if current state is ACTIVE and nonalive

Specified by:

moveToOffline in interface ClusterManager

Throws:

ClusterStateException - if node is alive

isNodeAlive

public boolean isNodeAlive(@NotNull
                           String nodeId)

Specified by:

isNodeAlive in interface ClusterManager

Returns:

true if node is alive otherwise return false

isNodePresent

public boolean isNodePresent(@NotNull
                             String nodeId)

Specified by:

isNodePresent in interface ClusterManager

Returns:

true if node is present in cluster otherwise return false

isNodeOffline

public boolean isNodeOffline(@NotNull
                             String nodeId)

Specified by:

isNodeOffline in interface ClusterManager

Returns:

true if node is OFFLINE otherwise return false