com.atlassian.confluence.cluster.safety

Class AbstractClusterSafetyManager

java.lang.Object

com.atlassian.confluence.cluster.safety.AbstractClusterSafetyManager

All Implemented Interfaces:

ClusterSafetyManager

Direct Known Subclasses:

DefaultClusterSafetyManager, HazelcastClusterSafetyManager

public abstract class AbstractClusterSafetyManager
extends Object
implements ClusterSafetyManager

Contains common functionality for clustered and standalone safety managers

See Also:

DefaultClusterSafetyManager, HazelcastClusterSafetyManager

Field Summary

Fields

Modifier and Type	Field and Description
protected static String	NON_CLUSTERED_NODE_NAME
protected static String	NOT_FOUND_STATEMENT
protected Random	random
static String	SAFETY_NUMBER
static String	SAFETY_NUMBER_MODIFIER

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	AbstractClusterSafetyManager(ClusterSafetyDao clusterSafetyDao, com.atlassian.event.api.EventPublisher eventPublisher, ClusterManager clusterManager, LicenseService licenseService)

Method Summary

Modifier and Type	Method and Description
ClusterManager	getClusterManager()
com.atlassian.event.api.EventPublisher	getEventPublisher()
LicenseService	getLicenseService()
protected abstract org.slf4j.Logger	getLogger()
protected int	getNextValue()
protected String	getNodeName()
protected abstract Map<String,Integer>	getSafetyNumberMap()
protected abstract Map<String,String>	getSafetyNumberModifierMap()
protected abstract void	handlePanic()
boolean	isLogEnabled()
protected abstract void	logRuntimeInfo()
protected void	onCacheNumberIsMissed(Integer dbSafetyNumber, int nextValue) Method is called when safety number is missed in cache.
protected void	onDatabaseNumberIsMissed(String lastCacheModifier, Integer cacheSafetyNumber, int nextValue) Method is called when safety number is missed in database.
protected void	onNumbersAreDifferent(String lastCacheModifier, Integer dbSafetyNumber, Integer cacheSafetyNumber, int nextValue) Method is called when safety numbers in cache and database are not equal.
protected void	onNumbersAreEqual(String lastCacheModifier, Integer dbSafetyNumber, Integer cacheSafetyNumber, int nextValue) Method is called when safety numbers in cache and database are equal.
protected void	onNumbersMissed(int nextValue) Method is called when safety numbers in cache and database are missed.
protected void	updateSafetyNumber(int nextValue) Updates safety number in cache and database
void	verify(long runInterval) Ensures cluster is safe.

Methods inherited from class java.lang.Object

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

Field Detail

NOT_FOUND_STATEMENT

protected static final String NOT_FOUND_STATEMENT

See Also:

Constant Field Values

NON_CLUSTERED_NODE_NAME

protected static final String NON_CLUSTERED_NODE_NAME

See Also:

Constant Field Values

SAFETY_NUMBER_MODIFIER

public static final String SAFETY_NUMBER_MODIFIER

See Also:

Constant Field Values

SAFETY_NUMBER

public static final String SAFETY_NUMBER

See Also:

Constant Field Values

random

protected final Random random

Constructor Detail

AbstractClusterSafetyManager

protected AbstractClusterSafetyManager(ClusterSafetyDao clusterSafetyDao,
                                       com.atlassian.event.api.EventPublisher eventPublisher,
                                       ClusterManager clusterManager,
                                       LicenseService licenseService)

Method Detail

verify

public void verify(long runInterval)

Description copied from interface: ClusterSafetyManager

Ensures cluster is safe. If not, panic procedure is initiated.

Specified by:

verify in interface ClusterSafetyManager

onDatabaseNumberIsMissed

protected void onDatabaseNumberIsMissed(@Nonnull
                                        String lastCacheModifier,
                                        @Nonnull
                                        Integer cacheSafetyNumber,
                                        int nextValue)
                                 throws ClusterPanicException

Method is called when safety number is missed in database. By default it updates safety number in the cache and database.

Parameters:

lastCacheModifier - last cache modifier

cacheSafetyNumber - safety number in cache

nextValue - next safety number to put into the cache and database

Throws:

ClusterPanicException - in a case if panic should be triggered

onCacheNumberIsMissed

protected void onCacheNumberIsMissed(@Nonnull
                                     Integer dbSafetyNumber,
                                     int nextValue)
                              throws ClusterPanicException

Method is called when safety number is missed in cache. By default it updates safety number in the cache and database.

Parameters:

dbSafetyNumber - safety number in database

nextValue - next safety number to put into the cache and database

Throws:

ClusterPanicException - in a case if panic should be triggered

onNumbersAreEqual

protected void onNumbersAreEqual(@Nonnull
                                 String lastCacheModifier,
                                 @Nonnull
                                 Integer dbSafetyNumber,
                                 @Nonnull
                                 Integer cacheSafetyNumber,
                                 int nextValue)
                          throws ClusterPanicException

Method is called when safety numbers in cache and database are equal. By default it updates safety number in the cache and database.

Parameters:

lastCacheModifier - last cache modifier

dbSafetyNumber - safety number in database

cacheSafetyNumber - safety number in cache

nextValue - next safety number to put into the cache and database

Throws:

ClusterPanicException - in a case if panic should be triggered

onNumbersAreDifferent

protected void onNumbersAreDifferent(@Nonnull
                                     String lastCacheModifier,
                                     @Nonnull
                                     Integer dbSafetyNumber,
                                     @Nonnull
                                     Integer cacheSafetyNumber,
                                     int nextValue)
                              throws ClusterPanicException

Method is called when safety numbers in cache and database are not equal. By default this method throws ClusterPanicException to trigger cluster panic.

Parameters:

lastCacheModifier - last cache modifier

dbSafetyNumber - safety number in database

cacheSafetyNumber - safety number in cache

nextValue - next safety number to put into the cache and database

Throws:

ClusterPanicException - in a case if panic should be triggered

onNumbersMissed

protected void onNumbersMissed(int nextValue)

Method is called when safety numbers in cache and database are missed. By default it updates safety number in the cache and database.

Parameters:

nextValue - next safety number to put into the cache and database

Throws:

ClusterPanicException - in a case if panic should be triggered

updateSafetyNumber

protected void updateSafetyNumber(int nextValue)

Updates safety number in cache and database

Parameters:

nextValue - safety number to be updated in cache and db

getNodeName

@Nonnull
protected String getNodeName()

isLogEnabled

public boolean isLogEnabled()

getNextValue

protected int getNextValue()

getLogger

protected abstract org.slf4j.Logger getLogger()

logRuntimeInfo

protected abstract void logRuntimeInfo()

getSafetyNumberModifierMap

protected abstract Map<String,String> getSafetyNumberModifierMap()

getSafetyNumberMap

protected abstract Map<String,Integer> getSafetyNumberMap()

handlePanic

protected abstract void handlePanic()

getClusterManager

public ClusterManager getClusterManager()

getEventPublisher

public com.atlassian.event.api.EventPublisher getEventPublisher()

getLicenseService

public LicenseService getLicenseService()