org.infinispan.xsite.statetransfer

Class NoOpXSiteStateTransferManager

java.lang.Object

org.infinispan.xsite.statetransfer.NoOpXSiteStateTransferManager

All Implemented Interfaces:

XSiteStateTransferManager

public class NoOpXSiteStateTransferManager
extends Object
implements XSiteStateTransferManager

A no-op implementation of XSiteStateTransferManager. This instance is used when cross-site replication is disabled.

Since:

8.0

Author:

Pedro Ruivo

Field Summary

Fields inherited from interface org.infinispan.xsite.statetransfer.XSiteStateTransferManager

STATUS_CANCELED, STATUS_ERROR, STATUS_OK, STATUS_SENDING

Constructor Summary

Constructors

Constructor and Description
NoOpXSiteStateTransferManager()

Method Summary

Modifier and Type	Method and Description
void	becomeCoordinator(String siteName) Makes this node the coordinator for the state transfer to the site name.
void	cancelPushState(String siteName) It cancels a running state transfer.
void	cancelReceive(String siteName) Sets the cluster to normal state.
void	clearClusterStatus() Clears the completed state transfer status in all the cluster.
void	clearStatus() Clears the completed state transfer status.
Map<String,String>	getClusterStatus()
List<String>	getRunningStateTransfers()
String	getSendingSiteName()
XSiteStateConsumer	getStateConsumer()
XSiteStateProvider	getStateProvider()
Map<String,String>	getStatus()
void	notifyStatePushFinished(String siteName, Address node, boolean statusOk) It receives the notifications from local site when some node finishes pushing the state to the remote site.
void	startPushState(String siteName) It notifies all nodes from local site to start transfer the state to the remote site.
String	toString()

Methods inherited from class java.lang.Object

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

Constructor Detail

NoOpXSiteStateTransferManager

public NoOpXSiteStateTransferManager()

Method Detail

notifyStatePushFinished

public void notifyStatePushFinished(String siteName,
                                    Address node,
                                    boolean statusOk)

Description copied from interface: XSiteStateTransferManager

It receives the notifications from local site when some node finishes pushing the state to the remote site.

Specified by:

notifyStatePushFinished in interface XSiteStateTransferManager

Parameters:

siteName - the remote site name

node - the Address from the node that finishes.

statusOk - true if no error or exception occurred during the state transfer.

startPushState

public void startPushState(String siteName)

Description copied from interface: XSiteStateTransferManager

It notifies all nodes from local site to start transfer the state to the remote site.

Specified by:

startPushState in interface XSiteStateTransferManager

Parameters:

siteName - the remote site name

cancelPushState

public void cancelPushState(String siteName)

Description copied from interface: XSiteStateTransferManager

It cancels a running state transfer.

Specified by:

cancelPushState in interface XSiteStateTransferManager

Parameters:

siteName - the site name to where the state is being sent.

getRunningStateTransfers

public List<String> getRunningStateTransfers()

Specified by:

getRunningStateTransfers in interface XSiteStateTransferManager

Returns:

a list of site names in which this cache is pushing state.

getStatus

public Map<String,String> getStatus()

Specified by:

getStatus in interface XSiteStateTransferManager

Returns:

the completed state transfer status for which this node is the coordinator.

clearStatus

public void clearStatus()

Description copied from interface: XSiteStateTransferManager

Clears the completed state transfer status.

Specified by:

clearStatus in interface XSiteStateTransferManager

getClusterStatus

public Map<String,String> getClusterStatus()

Specified by:

getClusterStatus in interface XSiteStateTransferManager

Returns:

the completed state transfer status from all the coordinators in the cluster.

clearClusterStatus

public void clearClusterStatus()

Description copied from interface: XSiteStateTransferManager

Clears the completed state transfer status in all the cluster.

Specified by:

clearClusterStatus in interface XSiteStateTransferManager

getSendingSiteName

public String getSendingSiteName()

Specified by:

getSendingSiteName in interface XSiteStateTransferManager

Returns:

null if this node is not receiving state or the site name which is sending the state.

cancelReceive

public void cancelReceive(String siteName)

Description copied from interface: XSiteStateTransferManager

Sets the cluster to normal state.

The main use for this method is when the link between the sites is broken and the receiver site keeps it state transfer state forever.

Specified by:

cancelReceive in interface XSiteStateTransferManager

Parameters:

siteName - the site name which is sending the state.

becomeCoordinator

public void becomeCoordinator(String siteName)

Description copied from interface: XSiteStateTransferManager

Makes this node the coordinator for the state transfer to the site name.

This method is invoked when the coordinator dies and this node receives a late start state transfer request.

Specified by:

becomeCoordinator in interface XSiteStateTransferManager

Parameters:

siteName - the site name.

getStateProvider

public XSiteStateProvider getStateProvider()

Specified by:

getStateProvider in interface XSiteStateTransferManager

getStateConsumer

public XSiteStateConsumer getStateConsumer()

Specified by:

getStateConsumer in interface XSiteStateTransferManager

toString

public String toString()

Overrides:

toString in class Object