org.infinispan.statetransfer
Interface StateTransferManager

All Known Implementing Classes:

BaseStateTransferManagerImpl, DistributedStateTransferManagerImpl, DummyInvalidationStateTransferManagerImpl, ReplicatedStateTransferManagerImpl

public interface StateTransferManager

A component that manages the state transfer when the topology of the cluster changes.

Since:

5.1

Author:

Dan Berindei , Mircea Markus

Method Summary

void	applyLocks(Collection<LockInfo> locks, Address sender, int viewId)
void	applyState(Collection<InternalCacheEntry> state, Address sender, int viewId)
boolean	hasJoinStarted()
boolean	isJoinComplete()
boolean	isLocationInDoubt(Object key)
boolean	isStateTransferInProgress()
void	waitForJoinToComplete()
void	waitForJoinToStart()
void	waitForStateTransferToComplete()

Method Detail

isJoinComplete

boolean isJoinComplete()

waitForJoinToComplete

void waitForJoinToComplete()
                           throws InterruptedException

Throws:

InterruptedException

hasJoinStarted

boolean hasJoinStarted()

waitForJoinToStart

void waitForJoinToStart()
                        throws InterruptedException

Throws:

InterruptedException

isStateTransferInProgress

boolean isStateTransferInProgress()

waitForStateTransferToComplete

void waitForStateTransferToComplete()
                                    throws InterruptedException

Throws:

InterruptedException

applyState

void applyState(Collection<InternalCacheEntry> state,
                Address sender,
                int viewId)
                throws InterruptedException

Throws:

InterruptedException

applyLocks

void applyLocks(Collection<LockInfo> locks,
                Address sender,
                int viewId)
                throws InterruptedException

Throws:

InterruptedException

isLocationInDoubt

boolean isLocationInDoubt(Object key)

Returns:

true if the key should be local but has not yet been copied to the local node