com.atlassian.confluence.cluster.hazelcast

Class HazelcastClusterSafetyManager

java.lang.Object

com.atlassian.confluence.cluster.safety.AbstractClusterSafetyManager

com.atlassian.confluence.cluster.hazelcast.HazelcastClusterSafetyManager

All Implemented Interfaces:

ClusterSafetyManager

public class HazelcastClusterSafetyManager
extends AbstractClusterSafetyManager

Field Summary

Fields

Modifier and Type	Field and Description
static String	SAFETY_MAP_PREFIX

Fields inherited from class com.atlassian.confluence.cluster.safety.AbstractClusterSafetyManager

NON_CLUSTERED_NODE_NAME, NOT_FOUND_STATEMENT, random, SAFETY_NUMBER, SAFETY_NUMBER_MODIFIER

Constructor Summary

Constructors

Constructor and Description
HazelcastClusterSafetyManager(ClusterSafetyDao clusterSafetyDao, com.atlassian.event.api.EventPublisher eventPublisher, ClusterManager clusterManager, com.atlassian.util.concurrent.Supplier<com.hazelcast.core.HazelcastInstance> instanceSupplier, ActivityMonitor activityMonitor, ScheduledExecutorService executor, LicenseService licenseService)

Method Summary

Modifier and Type	Method and Description
protected int	decodeClusterSize(int dbSafetyNumber)
protected int	encodeClusterSize(int nextValue)
protected org.slf4j.Logger	getLogger()
protected int	getNextValue()
protected com.hazelcast.core.IMap<String,Integer>	getSafetyNumberMap()
protected com.hazelcast.core.IMap<String,String>	getSafetyNumberModifierMap()
protected void	handlePanic()
protected 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.
void	verify() Ensures cluster is safe.

Methods inherited from class com.atlassian.confluence.cluster.safety.AbstractClusterSafetyManager

getClusterManager, getEventPublisher, getLicenseService, getNodeName, isLogEnabled, updateSafetyNumber

Methods inherited from class java.lang.Object

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

Field Detail

SAFETY_MAP_PREFIX

public static final String SAFETY_MAP_PREFIX

Constructor Detail

HazelcastClusterSafetyManager

public HazelcastClusterSafetyManager(ClusterSafetyDao clusterSafetyDao,
                                     com.atlassian.event.api.EventPublisher eventPublisher,
                                     ClusterManager clusterManager,
                                     com.atlassian.util.concurrent.Supplier<com.hazelcast.core.HazelcastInstance> instanceSupplier,
                                     ActivityMonitor activityMonitor,
                                     ScheduledExecutorService executor,
                                     LicenseService licenseService)

Method Detail

verify

public void verify()

Description copied from interface: ClusterSafetyManager

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

Specified by:

verify in interface ClusterSafetyManager

Overrides:

verify in class AbstractClusterSafetyManager

onDatabaseNumberIsMissed

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

Description copied from class: AbstractClusterSafetyManager

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

Overrides:

onDatabaseNumberIsMissed in class AbstractClusterSafetyManager

Parameters:

lastCacheModifier - last cache modifier

cacheSafetyNumber - safety number in cache

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

onCacheNumberIsMissed

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

Description copied from class: AbstractClusterSafetyManager

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

Overrides:

onCacheNumberIsMissed in class AbstractClusterSafetyManager

Parameters:

dbSafetyNumber - safety number in database

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

onNumbersAreDifferent

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

Description copied from class: AbstractClusterSafetyManager

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

Overrides:

onNumbersAreDifferent in class AbstractClusterSafetyManager

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

onNumbersAreEqual

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

Description copied from class: AbstractClusterSafetyManager

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

Overrides:

onNumbersAreEqual in class AbstractClusterSafetyManager

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

onNumbersMissed

protected void onNumbersMissed(int nextValue)

Description copied from class: AbstractClusterSafetyManager

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

Overrides:

onNumbersMissed in class AbstractClusterSafetyManager

Parameters:

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

handlePanic

protected void handlePanic()

Specified by:

handlePanic in class AbstractClusterSafetyManager

logRuntimeInfo

protected void logRuntimeInfo()

Specified by:

logRuntimeInfo in class AbstractClusterSafetyManager

getLogger

protected org.slf4j.Logger getLogger()

Specified by:

getLogger in class AbstractClusterSafetyManager

getSafetyNumberMap

protected com.hazelcast.core.IMap<String,Integer> getSafetyNumberMap()

Specified by:

getSafetyNumberMap in class AbstractClusterSafetyManager

getSafetyNumberModifierMap

protected com.hazelcast.core.IMap<String,String> getSafetyNumberModifierMap()

Specified by:

getSafetyNumberModifierMap in class AbstractClusterSafetyManager

getNextValue

protected int getNextValue()

Overrides:

getNextValue in class AbstractClusterSafetyManager

encodeClusterSize

protected int encodeClusterSize(int nextValue)

decodeClusterSize

protected int decodeClusterSize(int dbSafetyNumber)