Package org.infinispan.conflict.impl

Class DefaultConflictManager<K,V>

java.lang.Object

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

All Implemented Interfaces:

ConflictManager<K,V>, InternalConflictManager<K,V>

public class DefaultConflictManager<K,V>
extends Object
implements InternalConflictManager<K,V>

Author:

Ryan Emerson

Constructor Summary

Constructors

Constructor	Description
DefaultConflictManager()

Method Summary

Modifier and Type	Method	Description
void	cancelConflictResolution()
void	cancelVersionRequests()
Map<Address,InternalCacheValue<V>>	getAllVersions(K key)	Get all CacheEntry's that exists for a given key.
Stream<Map<Address,CacheEntry<K,V>>>	getConflicts()	Returns a stream of conflicts detected in the cluster.
boolean	isConflictResolutionInProgress()
boolean	isStateTransferInProgress()
void	resolveConflicts()	Utilises ConflictManager.getConflicts() to discover conflicts between Key replicas and utilises the configured EntryMergePolicy to determine which entry should take precedence.
void	resolveConflicts(EntryMergePolicy<K,V> mergePolicy)	Utilises ConflictManager.getConflicts() to discover conflicts between Key replicas and utilises the provided EntryMergePolicy to determine which entry should take precedence.
CompletableFuture<Void>	resolveConflicts(CacheTopology topology, Set<Address> preferredNodes)
void	restartVersionRequests()
void	start()
void	stop()

Methods inherited from class java.lang.Object

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

Constructor Detail

DefaultConflictManager

public DefaultConflictManager()

Method Detail

start

public void start()

stop

public void stop()

cancelVersionRequests

public void cancelVersionRequests()

Specified by:

cancelVersionRequests in interface InternalConflictManager<K,V>

restartVersionRequests

public void restartVersionRequests()

Specified by:

restartVersionRequests in interface InternalConflictManager<K,V>

getAllVersions

public Map<Address,InternalCacheValue<V>> getAllVersions(K key)

Description copied from interface: ConflictManager

Get all CacheEntry's that exists for a given key. Note, concurrent calls to this method for the same key will utilise the same CompletableFuture inside this method and consequently return the same results as all other invocations. If this method is invoked during state transfer it will block until rehashing has completed. Similarly, if state transfer is initiated during an invocation of this method and rehashing affects the segments of the provided key, the initial requests for the entries versions are cancelled and re-attempted once state transfer has completed. This method utilises the addresses of the local DistributionInfo.writeOwners() to request values for a given key. If a value does not exist for a key at one of the addresses, then a null valued is mapped to said address.

Specified by:

getAllVersions in interface ConflictManager<K,V>

Parameters:

key - the key for which associated entries are to be returned

Returns:

a map of an address and it's associated CacheEntry

getConflicts

public Stream<Map<Address,CacheEntry<K,V>>> getConflicts()

Description copied from interface: ConflictManager

Returns a stream of conflicts detected in the cluster. This is a lazily-loaded stream which searches for conflicts by sequentially fetching cache segments from their respective owner nodes. If a rebalance is initiated whilst the stream is fetching a cache segment, then a CacheException is thrown when executing the stream.

Specified by:

getConflicts in interface ConflictManager<K,V>

Returns:

a stream of Map<Address, CacheEntry> for all conflicts detected throughout this cache.

isConflictResolutionInProgress

public boolean isConflictResolutionInProgress()

Specified by:

isConflictResolutionInProgress in interface ConflictManager<K,V>

Returns:

true if conflict resolution is in progress. This can happen if the user has multiple threads interacting with the ConflictManager or if a Split-brain merge is in progress.

resolveConflicts

public void resolveConflicts()

Description copied from interface: ConflictManager

Utilises ConflictManager.getConflicts() to discover conflicts between Key replicas and utilises the configured EntryMergePolicy to determine which entry should take precedence. The resulting CacheEntry is then applied on all replicas in the cluster.

Specified by:

resolveConflicts in interface ConflictManager<K,V>

resolveConflicts

public void resolveConflicts(EntryMergePolicy<K,V> mergePolicy)

Description copied from interface: ConflictManager

Utilises ConflictManager.getConflicts() to discover conflicts between Key replicas and utilises the provided EntryMergePolicy to determine which entry should take precedence. The resulting CacheEntry is then applied on all replicas in the cluster.

Specified by:

resolveConflicts in interface ConflictManager<K,V>

Parameters:

mergePolicy - the policy to be applied to all detected conflicts

resolveConflicts

public CompletableFuture<Void> resolveConflicts(CacheTopology topology,
                                                Set<Address> preferredNodes)

Specified by:

resolveConflicts in interface InternalConflictManager<K,V>

cancelConflictResolution

public void cancelConflictResolution()

Specified by:

cancelConflictResolution in interface InternalConflictManager<K,V>

isStateTransferInProgress

public boolean isStateTransferInProgress()

Specified by:

isStateTransferInProgress in interface ConflictManager<K,V>

Returns:

true if a state transfer is currently in progress.