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 and Description
XSiteStateProviderImpl()

Method Summary

Modifier and Type	Method and Description
void	cancelStateTransfer(String siteName) It cancels the state transfer for the remote site.
Collection<String>	getCurrentStateSending()
Collection<String>	getSitesMissingCoordinator(Collection<Address> currentMembers)
void	inject(DataContainer dataContainer, PersistenceManager persistenceManager, RpcManager rpcManager, ClusteringDependentLogic clusteringDependentLogic, CommandsFactory commandsFactory, ExecutorService executorService, Configuration configuration, XSiteStateTransferManager xSiteStateTransferManager, StateTransferLock stateTransferLock)
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()

Method Detail

inject

public void inject(DataContainer dataContainer,
                   PersistenceManager persistenceManager,
                   RpcManager rpcManager,
                   ClusteringDependentLogic clusteringDependentLogic,
                   CommandsFactory commandsFactory,
                   ExecutorService executorService,
                   Configuration configuration,
                   XSiteStateTransferManager xSiteStateTransferManager,
                   StateTransferLock stateTransferLock)

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.

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.