Package org.infinispan.xsite.statetransfer

Class BaseXSiteStateProviderState<T extends org.infinispan.xsite.statetransfer.BaseXSiteStateProviderState.OutboundTask>

java.lang.Object

org.infinispan.xsite.statetransfer.BaseXSiteStateProviderState<T>

All Implemented Interfaces:

XSiteStateProviderState

Direct Known Subclasses:

AsyncProviderState, SyncProviderState

public abstract class BaseXSiteStateProviderState<T extends org.infinispan.xsite.statetransfer.BaseXSiteStateProviderState.OutboundTask>
extends Object
implements XSiteStateProviderState

Common code for AsyncProviderState and SyncProviderState implementation.

The only difference between the two implementation is the way the state is send to the remote site. The synchronous implementation sends the state directly while the asynchronous makes use of IRAC (and its conflict resolution).

Since:

12.0

Author:

Pedro Ruivo

Constructor Summary

Constructors

Constructor	Description
BaseXSiteStateProviderState(org.infinispan.xsite.XSiteBackup backup, XSiteStateTransferConfiguration configuration)

Method Summary

Modifier and Type	Method	Description
void	cancelTransfer()	Cancels any running state transfer.
XSiteStatePushTask	createPushTask(Address originator, XSiteStateProvider provider)	Creates a new XSiteStatePushTask to do state transfer to remove site.
boolean	isOriginatorMissing(Collection<Address> members)	Returns
boolean	isSending()

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.infinispan.xsite.statetransfer.XSiteStateProviderState

isSync

Constructor Details

BaseXSiteStateProviderState

public BaseXSiteStateProviderState(org.infinispan.xsite.XSiteBackup backup,
 XSiteStateTransferConfiguration configuration)

Method Details

createPushTask

public XSiteStatePushTask createPushTask(Address originator,
 XSiteStateProvider provider)

Description copied from interface: XSiteStateProviderState

Creates a new XSiteStatePushTask to do state transfer to remove site.

Specified by:

createPushTask in interface XSiteStateProviderState

Parameters:

originator - The originator Address (node who initiated the state transfer).

provider - The XSiteStateProvider instance to notify when the XSiteStatePushTask finishes.

Returns:

The XSiteStatePushTask instance. or null if a state transfer is already in progress.

cancelTransfer

public void cancelTransfer()

Description copied from interface: XSiteStateProviderState

Cancels any running state transfer.

If no state transfer is in progress, this method is a no-op.

Specified by:

cancelTransfer in interface XSiteStateProviderState

isSending

public boolean isSending()

Specified by:

isSending in interface XSiteStateProviderState

Returns:

true if a state transfer is in progress for this site.

isOriginatorMissing

public boolean isOriginatorMissing(Collection<Address> members)

Description copied from interface: XSiteStateProviderState

Returns

Specified by:

isOriginatorMissing in interface XSiteStateProviderState

Parameters:

members - The current cluster members list.

Returns:

true if a state transfer is in progress and the originator is not in that Collection.