Package org.infinispan.xsite.statetransfer

Class NoOpXSiteStateProvider

java.lang.Object

org.infinispan.xsite.statetransfer.NoOpXSiteStateProvider

All Implemented Interfaces:

XSiteStateProvider

public class NoOpXSiteStateProvider
extends Object
implements XSiteStateProvider

A no-op implementation of XSiteStateProvider.

This class is used when cross-site replication is disabled.

Since:

10.0

Author:

Pedro Ruivo

Method Summary

Modifier and Type	Method	Description
void	cancelStateTransfer(String siteName)	It cancels the state transfer for the remote site.
CommandsFactory	getCommandsFactory()	Exposes CommandsFactory to XSiteStatePushTask.
Collection<String>	getCurrentStateSending()
Executor	getExecutor()	Exposes non-blocking Executor to XSiteStatePushTask.
static NoOpXSiteStateProvider	getInstance()
IracManager	getIracManager()	Exposes IracManager to XSiteStatePushTask.
RpcManager	getRpcManager()	Exposes RpcManager to XSiteStatePushTask.
ScheduledExecutorService	getScheduledExecutorService()	Exposes timeout ScheduledExecutorService to XSiteStatePushTask.
Collection<String>	getSitesMissingCoordinator(Collection<Address> currentMembers)
void	notifyStateTransferEnd(String siteName, Address origin, boolean statusOk)	Notifies XSiteStatePushTask has completed the send.
void	startStateTransfer(String siteName, Address requestor, int minTopologyId)	It notifies this node to start sending state to the remote site.
String	toString()

Methods inherited from class java.lang.Object

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

Method Details

getInstance

public static NoOpXSiteStateProvider getInstance()

startStateTransfer

public void startStateTransfer(String siteName,
 Address requestor,
 int minTopologyId)

Description copied from interface: XSiteStateProvider

It notifies this node to start sending state to the remote site. Also, it should keep information about which node requested the state transfer in order to send back the notification when finishes.

Specified by:

startStateTransfer in interface XSiteStateProvider

Parameters:

siteName - the remote site name.

requestor - the requestor.

minTopologyId - the topology id to wait before start sending the state.

cancelStateTransfer

public void cancelStateTransfer(String siteName)

Description copied from interface: XSiteStateProvider

It cancels the state transfer for the remote site. If no state transfer is available, it should do nothing.

Specified by:

cancelStateTransfer in interface XSiteStateProvider

Parameters:

siteName - the remote site name.

getCurrentStateSending

public Collection<String> getCurrentStateSending()

Specified by:

getCurrentStateSending in interface XSiteStateProvider

Returns:

a site name collection with the sites in which this cache is sending state.

getSitesMissingCoordinator

public Collection<String> getSitesMissingCoordinator(Collection<Address> currentMembers)

Specified by:

getSitesMissingCoordinator in interface XSiteStateProvider

Returns:

a site name collection with sites in which the coordinator is not in the currentMembers.

notifyStateTransferEnd

public void notifyStateTransferEnd(String siteName,
 Address origin,
 boolean statusOk)

Description copied from interface: XSiteStateProvider

Notifies XSiteStatePushTask has completed the send.

Specified by:

notifyStateTransferEnd in interface XSiteStateProvider

Parameters:

siteName - The remote site name.

origin - The originator Address.

statusOk - true if completed successfully, false if it failed.

getCommandsFactory

public CommandsFactory getCommandsFactory()

Description copied from interface: XSiteStateProvider

Exposes CommandsFactory to XSiteStatePushTask.

Specified by:

getCommandsFactory in interface XSiteStateProvider

getRpcManager

public RpcManager getRpcManager()

Description copied from interface: XSiteStateProvider

Exposes RpcManager to XSiteStatePushTask.

Specified by:

getRpcManager in interface XSiteStateProvider

getIracManager

public IracManager getIracManager()

Description copied from interface: XSiteStateProvider

Exposes IracManager to XSiteStatePushTask.

Specified by:

getIracManager in interface XSiteStateProvider

getScheduledExecutorService

public ScheduledExecutorService getScheduledExecutorService()

Description copied from interface: XSiteStateProvider

Exposes timeout ScheduledExecutorService to XSiteStatePushTask.

Specified by:

getScheduledExecutorService in interface XSiteStateProvider

getExecutor

public Executor getExecutor()

Description copied from interface: XSiteStateProvider

Exposes non-blocking Executor to XSiteStatePushTask.

Specified by:

getExecutor in interface XSiteStateProvider

toString

public String toString()

Overrides:

toString in class Object