org.infinispan.conflict.impl

Class StateReceiverImpl<K,V>

java.lang.Object

org.infinispan.conflict.impl.StateReceiverImpl<K,V>

All Implemented Interfaces:

StateReceiver<K,V>

public class StateReceiverImpl<K,V>
extends Object
implements StateReceiver<K,V>

Since:

9.1

Author:

Ryan Emerson

Constructor Summary

Constructors

Constructor and Description
StateReceiverImpl()

Method Summary

Modifier and Type	Method and Description
void	cancelRequests() Cancels all ongoing replica requests.
CompletableFuture<List<Map<Address,CacheEntry<K,V>>>>	getAllReplicasForSegment(int segmentId, LocalizedCacheTopology topology, long timeout) Return all replicas of a cache entry for a given segment.
void	onDataRehash(DataRehashedEvent<K,V> dataRehashedEvent)
void	receiveState(Address sender, int topologyId, Collection<StateChunk> stateChunks)
void	start()
void	stop()

Methods inherited from class java.lang.Object

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

Constructor Detail

StateReceiverImpl

public StateReceiverImpl()

Method Detail

start

public void start()

stop

public void stop()

cancelRequests

public void cancelRequests()

Description copied from interface: StateReceiver

Cancels all ongoing replica requests.

Specified by:

cancelRequests in interface StateReceiver<K,V>

onDataRehash

public void onDataRehash(DataRehashedEvent<K,V> dataRehashedEvent)

getAllReplicasForSegment

public CompletableFuture<List<Map<Address,CacheEntry<K,V>>>> getAllReplicasForSegment(int segmentId,
                                                                                      LocalizedCacheTopology topology,
                                                                                      long timeout)

Description copied from interface: StateReceiver

Return all replicas of a cache entry for a given segment. We require the ConsitentHash to be passed here, as it is necessary for the hash of the last stable topology to be utilised during an automatic merge, before a new merged topology is installed.

Specified by:

getAllReplicasForSegment in interface StateReceiver<K,V>

receiveState

public void receiveState(Address sender,
                         int topologyId,
                         Collection<StateChunk> stateChunks)

Specified by:

receiveState in interface StateReceiver<K,V>