com.atlassian.jira.cluster

Class DefaultNodeStateManager

java.lang.Object

com.atlassian.jira.cluster.DefaultNodeStateManager

All Implemented Interfaces:

NodeStateManager

public class DefaultNodeStateManager
extends Object
implements NodeStateManager

Manage the state of the current node. The activate() and deactivate() methods are synchronised as we should only ever be running one of those methods at a time to avoid weird race conditions that would be possible if we tried to go from active to passive and vice-versa at the same time.

Since:

v6.1

Constructor Summary

Constructors

Constructor and Description

DefaultNodeStateManager(OfBizClusterNodeStore ofBizClusterNodeStore, ClusterNodes clusterNodes, ClusterNodeProperties clusterNodeProperties, com.atlassian.scheduler.core.LifecycleAwareSchedulerService schedulerService, ComponentFactory componentFactory, com.atlassian.mail.queue.MailQueue mailQueue, com.atlassian.event.api.EventPublisher eventPublisher, JiraSystemRestarter jiraSystemRestarter, com.atlassian.cache.CacheManager cacheManager, BuildUtilsInfo buildUtilsInfo, ClusterNodeAuditHandler clusterNodeAuditHandler)

Method Summary

Modifier and Type	Method and Description
void	activate() Activate the node.
void	clearCache(ClearCacheEvent event)
void	deactivate() Deactivate the node.
protected Long	getCacheListenerPort()
void	quiesce() There are times when you want the server to go into a deep sleep mode, such as when an import is taking place on the cluster.
void	restart()
void	shutdownNode() We are going to change the state when the component manager stops so the other nodes do not get alerts about this node
protected boolean	stateHasChanged(Node node) We validate if the state of the node has changed.

Methods inherited from class java.lang.Object

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

Constructor Detail

DefaultNodeStateManager

public DefaultNodeStateManager(OfBizClusterNodeStore ofBizClusterNodeStore,
                               ClusterNodes clusterNodes,
                               ClusterNodeProperties clusterNodeProperties,
                               com.atlassian.scheduler.core.LifecycleAwareSchedulerService schedulerService,
                               ComponentFactory componentFactory,
                               com.atlassian.mail.queue.MailQueue mailQueue,
                               com.atlassian.event.api.EventPublisher eventPublisher,
                               JiraSystemRestarter jiraSystemRestarter,
                               com.atlassian.cache.CacheManager cacheManager,
                               BuildUtilsInfo buildUtilsInfo,
                               ClusterNodeAuditHandler clusterNodeAuditHandler)

Method Detail

clearCache

@EventListener
public void clearCache(ClearCacheEvent event)

shutdownNode

public void shutdownNode()

We are going to change the state when the component manager stops so the other nodes do not get alerts about this node

Specified by:

shutdownNode in interface NodeStateManager

activate

public void activate()
              throws ClusterStateException

Description copied from interface: NodeStateManager

Activate the node. This method will block until the node becomes active.

Specified by:

activate in interface NodeStateManager

Throws:

ClusterStateException - when we can't become active as requested

quiesce

public void quiesce()
             throws NotClusteredException

There are times when you want the server to go into a deep sleep mode, such as when an import is taking place on the cluster.

Specified by:

quiesce in interface NodeStateManager

Throws:

NotClusteredException

restart

public void restart()

Specified by:

restart in interface NodeStateManager

deactivate

public void deactivate()
                throws NotClusteredException

Description copied from interface: NodeStateManager

Deactivate the node. This method will block until the node becomes inactive (passive).

Specified by:

deactivate in interface NodeStateManager

Throws:

NotClusteredException - if the instance is not clustered

stateHasChanged

protected boolean stateHasChanged(Node node)

We validate if the state of the node has changed.

1) if the node is in offline state in the db, and we are initializing it. 2) if the node has a different IP address. 3) if the port of multicasting has changed

Parameters:

node - the node

Returns:

true if the state has changed, false if not

getCacheListenerPort

protected Long getCacheListenerPort()