com.j_spaces.core.cluster.startup

Class ReplicationStartupManager

java.lang.Object

com.j_spaces.core.cluster.startup.ReplicationStartupManager

All Implemented Interfaces:

SpaceConnectionListener

public class ReplicationStartupManager
extends Object
implements SpaceConnectionListener

ReplicationStartupManager handles the space startup state in persistent replicated cluster. Space startup state is needed to keep track of the last space in cluster that was up, since it holds the most updated cluster state. The ReplicationStartupManager monitors all the target spaces in cluster. Initial spaces state is updated at space startup in SpaceImpl. Connection events are received from the AbstractReplicationChannel and disconnect events from GigaSpacesFaultDetectionHandler. Default ReplicationStartupManager implementation stores space state to file. This behavior can be changed by overriding the saveState and loadState methods.

Since:

5.1

Version:

1.0

Author:

anna

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	ReplicationStartupManager.StartupState

Field Summary

Fields

Modifier and Type	Field and Description
protected ReplicationStartupManager.StartupState	_currentSpaceState
protected String	_spaceName
protected File	_stateFile
static String	DIR_NAME
static String	FILENAME_SUFFIX

Constructor Summary

Constructors

Constructor and Description
ReplicationStartupManager(String spaceName)

Method Summary

Modifier and Type	Method and Description
void	changeState(ReplicationStartupManager.StartupState newState) Change space state and store it
ReplicationStartupManager.StartupState	getSpaceState()
protected ReplicationStartupManager.StartupState	loadState()
void	onSpaceConnect(SpaceConnectionEvent event) Called when one of the spaces in cluster connects to this space
void	onSpaceDisconnect(SpaceConnectionEvent event) Called when given space disconnects
protected void	saveState(ReplicationStartupManager.StartupState state) Save space state
boolean	shouldWait(List<String> targetNames) Check if this space should wait for other space in cluster to start
void	waitForLastSpace() Wait for the last space to start

Methods inherited from class java.lang.Object

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

Field Detail

DIR_NAME

public static final String DIR_NAME

See Also:

Constant Field Values

FILENAME_SUFFIX

public static final String FILENAME_SUFFIX

See Also:

Constant Field Values

_spaceName

protected final String _spaceName

_currentSpaceState

protected ReplicationStartupManager.StartupState _currentSpaceState

_stateFile

protected File _stateFile

Constructor Detail

ReplicationStartupManager

public ReplicationStartupManager(String spaceName)

Parameters:

spaceName -

Method Detail

getSpaceState

public ReplicationStartupManager.StartupState getSpaceState()

Returns:

space startup state

changeState

public void changeState(ReplicationStartupManager.StartupState newState)

Change space state and store it

loadState

protected ReplicationStartupManager.StartupState loadState()
                                                    throws IOException

Returns:

Loaded space state

Throws:

IOException

saveState

protected void saveState(ReplicationStartupManager.StartupState state)
                  throws IOException

Save space state

Throws:

IOException

waitForLastSpace

public void waitForLastSpace()
                      throws InterruptedException

Wait for the last space to start

Throws:

InterruptedException

shouldWait

public boolean shouldWait(List<String> targetNames)
                   throws InterruptedException

Check if this space should wait for other space in cluster to start

Throws:

InterruptedException

onSpaceConnect

public void onSpaceConnect(SpaceConnectionEvent event)

Called when one of the spaces in cluster connects to this space

Specified by:

onSpaceConnect in interface SpaceConnectionListener

Parameters:

event - connection event

onSpaceDisconnect

public void onSpaceDisconnect(SpaceConnectionEvent event)

Description copied from interface: SpaceConnectionListener

Called when given space disconnects

Specified by:

onSpaceDisconnect in interface SpaceConnectionListener

Parameters:

event - contains the disconnected space