com.gigaspaces.internal.server.space.recovery.direct_persistency

Class DirectPersistencyRecoveryHelper

java.lang.Object

com.gigaspaces.internal.server.space.recovery.direct_persistency.DirectPersistencyRecoveryHelper

All Implemented Interfaces:

ISpaceModeListener, IStorageConsistency, Remote, EventListener

public class DirectPersistencyRecoveryHelper
extends Object
implements IStorageConsistency, ISpaceModeListener

helper functions in order to maintain direct-persistency recovery consistency

Since:

10.1

Author:

yechiel

Field Summary

Fields

Modifier and Type	Field and Description
static String	LAST_PRIMARY_ZOOKEEPER_PATH_DEFAULT

Constructor Summary

Constructors

Constructor and Description
DirectPersistencyRecoveryHelper(SpaceImpl spaceImpl, Logger logger)

Method Summary

Modifier and Type	Method and Description
void	afterSpaceModeChange(SpaceMode newMode) Called right after the space mode changes.
void	beforePrimaryElectionProcess()
void	beforeSpaceModeChange(SpaceMode newMode) Called right before the space mode changes. Implementors usually use it to allow specific service initializations.
StorageConsistencyModes	getStorageState()
void	handleDirectPersistencyRecoverFailure(int retryCount)
boolean	isInconsistentStorage()
boolean	isMeLastPrimary()
boolean	isPendingBackupRecovery()
boolean	isPerInstancePersistency()
void	setMeAsLastPrimary()
void	setPendingBackupRecovery(boolean pendingRecovery)
void	setStorageState(StorageConsistencyModes s)

Methods inherited from class java.lang.Object

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

Field Detail

LAST_PRIMARY_ZOOKEEPER_PATH_DEFAULT

public static final String LAST_PRIMARY_ZOOKEEPER_PATH_DEFAULT

See Also:

Constant Field Values

Constructor Detail

DirectPersistencyRecoveryHelper

public DirectPersistencyRecoveryHelper(SpaceImpl spaceImpl,
                                       Logger logger)

Method Detail

getStorageState

public StorageConsistencyModes getStorageState()

Specified by:

getStorageState in interface IStorageConsistency

setStorageState

public void setStorageState(StorageConsistencyModes s)

Specified by:

setStorageState in interface IStorageConsistency

isPerInstancePersistency

public boolean isPerInstancePersistency()

Specified by:

isPerInstancePersistency in interface IStorageConsistency

beforePrimaryElectionProcess

public void beforePrimaryElectionProcess()

isInconsistentStorage

public boolean isInconsistentStorage()

setMeAsLastPrimary

public void setMeAsLastPrimary()

isMeLastPrimary

public boolean isMeLastPrimary()

beforeSpaceModeChange

public void beforeSpaceModeChange(SpaceMode newMode)
                           throws RemoteException

Description copied from interface: ISpaceModeListener

Called right before the space mode changes.
Implementors usually use it to allow specific service initializations.

Specified by:

beforeSpaceModeChange in interface ISpaceModeListener

Parameters:

newMode - the new mode change before it's published.

Throws:

RemoteException - if an exception occurred during execution of a remote call.

afterSpaceModeChange

public void afterSpaceModeChange(SpaceMode newMode)
                          throws RemoteException

Description copied from interface: ISpaceModeListener

Called right after the space mode changes.
Implementors usually use it to invoke any needed services.

Specified by:

afterSpaceModeChange in interface ISpaceModeListener

Parameters:

newMode - the new mode change after it was published.

Throws:

RemoteException - if an exception occurred during execution of a remote call.

setPendingBackupRecovery

public void setPendingBackupRecovery(boolean pendingRecovery)

isPendingBackupRecovery

public boolean isPendingBackupRecovery()

handleDirectPersistencyRecoverFailure

public void handleDirectPersistencyRecoverFailure(int retryCount)