org.infinispan.statetransfer

Class StateProviderImpl

java.lang.Object

org.infinispan.statetransfer.StateProviderImpl

All Implemented Interfaces:

StateProvider

Direct Known Subclasses:

ScatteredStateProviderImpl

public class StateProviderImpl
extends Object
implements StateProvider

StateProvider implementation.

Since:

5.2

Author:

anistor@redhat.com

Field Summary

Fields

Modifier and Type	Field and Description
protected String	cacheName
protected int	chunkSize
protected CommandsFactory	commandsFactory
protected InternalDataContainer<Object,Object>	dataContainer
protected DistributionManager	distributionManager
protected InternalEntryFactory	entryFactory
protected KeyPartitioner	keyPartitioner
protected PersistenceManager	persistenceManager
protected RpcManager	rpcManager
protected StateTransferLock	stateTransferLock
protected long	timeout
protected TransactionOriginatorChecker	transactionOriginatorChecker

Constructor Summary

Constructors

Constructor and Description
StateProviderImpl()

Method Summary

Modifier and Type	Method and Description
protected void	addTransfer(OutboundTransferTask transferTask)
void	cancelOutboundTransfer(Address destination, int topologyId, IntSet segments) Cancel sending of cache entries that belong to the given set of segments.
Collection<ClusterListenerReplicateCallable<Object,Object>>	getClusterListenersToInstall()
CompletionStage<List<TransactionInfo>>	getTransactionsForSegments(Address destination, int requestTopologyId, IntSet segments) Gets the list of transactions that affect keys from the given segments.
boolean	isStateTransferInProgress()
protected void	logError(OutboundTransferTask task, Throwable t)
protected void	onTaskCompletion(OutboundTransferTask transferTask)
CompletableFuture<Void>	onTopologyUpdate(CacheTopology cacheTopology, boolean isRebalance) Receive notification of topology changes.
protected io.reactivex.rxjava3.core.Flowable<InternalCacheEntry<Object,Object>>	publishDataContainerEntries(IntSet segments)
protected io.reactivex.rxjava3.core.Flowable<InternalCacheEntry<Object,Object>>	publishStoreEntries(IntSet segments)
void	start()
void	startOutboundTransfer(Address destination, int requestTopologyId, IntSet segments, boolean applyState) Start to send cache entries that belong to the given set of segments.
void	stop() Cancels all outbound state transfers.

Methods inherited from class java.lang.Object

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

Field Detail

cacheName

protected String cacheName

rpcManager

protected RpcManager rpcManager

commandsFactory

protected CommandsFactory commandsFactory

dataContainer

protected InternalDataContainer<Object,Object> dataContainer

persistenceManager

protected PersistenceManager persistenceManager

stateTransferLock

protected StateTransferLock stateTransferLock

entryFactory

protected InternalEntryFactory entryFactory

keyPartitioner

protected KeyPartitioner keyPartitioner

distributionManager

protected DistributionManager distributionManager

transactionOriginatorChecker

protected TransactionOriginatorChecker transactionOriginatorChecker

timeout

protected long timeout

chunkSize

protected int chunkSize

Constructor Detail

StateProviderImpl

public StateProviderImpl()

Method Detail

isStateTransferInProgress

public boolean isStateTransferInProgress()

Specified by:

isStateTransferInProgress in interface StateProvider

onTopologyUpdate

public CompletableFuture<Void> onTopologyUpdate(CacheTopology cacheTopology,
                                                boolean isRebalance)

Description copied from interface: StateProvider

Receive notification of topology changes. Cancels all outbound transfers to destinations that are no longer members. The other outbound transfers remain unaffected.

Specified by:

onTopologyUpdate in interface StateProvider

start

public void start()

Specified by:

start in interface StateProvider

stop

public void stop()

Description copied from interface: StateProvider

Cancels all outbound state transfers. This is executed when the cache is shutting down.

Specified by:

stop in interface StateProvider

getTransactionsForSegments

public CompletionStage<List<TransactionInfo>> getTransactionsForSegments(Address destination,
                                                                         int requestTopologyId,
                                                                         IntSet segments)

Description copied from interface: StateProvider

Gets the list of transactions that affect keys from the given segments. This is invoked in response to a StateTransferGetTransactionsCommand.

Specified by:

getTransactionsForSegments in interface StateProvider

Parameters:

destination - the address of the requester

requestTopologyId - required topology before we can start collecting transactions

segments - only return transactions affecting these segments

Returns:

a CompletionStage that completes with the list transactions and locks for the given segments

getClusterListenersToInstall

public Collection<ClusterListenerReplicateCallable<Object,Object>> getClusterListenersToInstall()

Specified by:

getClusterListenersToInstall in interface StateProvider

startOutboundTransfer

public void startOutboundTransfer(Address destination,
                                  int requestTopologyId,
                                  IntSet segments,
                                  boolean applyState)

Description copied from interface: StateProvider

Start to send cache entries that belong to the given set of segments. This is invoked in response to a StateTransferStartCommand. If the applyState field is set to false, then upon delivery at the destination the cache entries are processed by a StateReceiver and are not applied to the local cache.

Specified by:

startOutboundTransfer in interface StateProvider

Parameters:

destination - the address of the requester

publishDataContainerEntries

protected io.reactivex.rxjava3.core.Flowable<InternalCacheEntry<Object,Object>> publishDataContainerEntries(IntSet segments)

publishStoreEntries

protected io.reactivex.rxjava3.core.Flowable<InternalCacheEntry<Object,Object>> publishStoreEntries(IntSet segments)

addTransfer

protected void addTransfer(OutboundTransferTask transferTask)

cancelOutboundTransfer

public void cancelOutboundTransfer(Address destination,
                                   int topologyId,
                                   IntSet segments)

Description copied from interface: StateProvider

Cancel sending of cache entries that belong to the given set of segments. This is invoked in response to a StateTransferCancelCommand.

Specified by:

cancelOutboundTransfer in interface StateProvider

Parameters:

destination - the address of the requester

segments - the segments that we have to cancel transfer for

onTaskCompletion

protected void onTaskCompletion(OutboundTransferTask transferTask)

logError

protected void logError(OutboundTransferTask task,
                        Throwable t)