Package org.infinispan.xsite.statetransfer

Class XSiteStateProviderImpl

java.lang.Object

org.infinispan.xsite.statetransfer.XSiteStateProviderImpl

All Implemented Interfaces:

XSiteStateProvider

public class XSiteStateProviderImpl
extends Object
implements XSiteStateProvider

It contains the logic to send state to another site.

Since:

7.0

Author:

Pedro Ruivo

Constructor Summary

Constructors

Constructor	Description
XSiteStateProviderImpl(Configuration configuration)

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.
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	start()
void	startStateTransfer(String siteName, Address origin, int minTopologyId)	It notifies this node to start sending state to the remote site.

Methods inherited from class java.lang.Object

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

Constructor Detail

XSiteStateProviderImpl

public XSiteStateProviderImpl(Configuration configuration)

Method Detail

start

public void start()

startStateTransfer

public void startStateTransfer(String siteName,
                               Address origin,
                               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.

origin - 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