org.infinispan.distribution.impl

Class DistributionManagerImpl

java.lang.Object

org.infinispan.distribution.impl.DistributionManagerImpl

All Implemented Interfaces:

DistributionManager

@MBean(objectName="DistributionManager",
       description="Component that handles distribution of content across a cluster")
public class DistributionManagerImpl
extends Object
implements DistributionManager

The default distribution manager implementation

Since:

4.0

Author:

Manik Surtani, Vladimir Blagojevic, Mircea.Markus@jboss.com, Bela Ban, Dan Berindei <dan@infinispan.org>, anistor@redhat.com

Constructor Summary

Constructors

Constructor and Description
DistributionManagerImpl()

Method Summary

Modifier and Type	Method and Description
LocalizedCacheTopology	createLocalizedCacheTopology(CacheTopology cacheTopology)
LocalizedCacheTopology	getCacheTopology()
ConsistentHash	getReadConsistentHash()
ConsistentHash	getWriteConsistentHash()
boolean	isAffectedByRehash(Object key) Tests whether a given key is affected by a rehash that may be in progress.
boolean	isJoinComplete() Tests whether the current instance has completed joining the cluster
boolean	isLocatedLocally(String key)
boolean	isRehashInProgress() Tests whether a rehash is in progress
List<String>	locateKey(String key)
static LocalizedCacheTopology	makeSingletonTopology(CacheMode cacheMode, KeyPartitioner keyPartitioner, int numSegments, Address localAddress)
void	setCacheTopology(CacheTopology cacheTopology)

Methods inherited from class java.lang.Object

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

Constructor Detail

DistributionManagerImpl

public DistributionManagerImpl()

Method Detail

getReadConsistentHash

public ConsistentHash getReadConsistentHash()

Specified by:

getReadConsistentHash in interface DistributionManager

Returns:

the consistent hash used for reading.

getWriteConsistentHash

public ConsistentHash getWriteConsistentHash()

Specified by:

getWriteConsistentHash in interface DistributionManager

Returns:

the consistent hash used for writing.

isAffectedByRehash

@ManagedOperation(description="Determines whether a given key is affected by an ongoing rehash, if any.",
                  displayName="Could key be affected by rehash?")
public boolean isAffectedByRehash(@Parameter(name="key",description="Key to check")
                                                                                                                                                                                                              Object key)

Description copied from interface: DistributionManager

Tests whether a given key is affected by a rehash that may be in progress. If no rehash is in progress, this method returns false. Helps determine whether additional steps are necessary in handling an operation with a given key.

Specified by:

isAffectedByRehash in interface DistributionManager

Parameters:

key - key to test

Returns:

whether a key is affected by a rehash

isRehashInProgress

public boolean isRehashInProgress()

Tests whether a rehash is in progress

Specified by:

isRehashInProgress in interface DistributionManager

Returns:

true if a rehash is in progress, false otherwise

isJoinComplete

public boolean isJoinComplete()

Description copied from interface: DistributionManager

Tests whether the current instance has completed joining the cluster

Specified by:

isJoinComplete in interface DistributionManager

Returns:

true if join is in progress, false otherwise

isLocatedLocally

@ManagedOperation(description="Tells you whether a given key would be written to this instance of the cache according to the consistent hashing algorithm. Only works with String keys.",
                  displayName="Is key local?")
public boolean isLocatedLocally(@Parameter(name="key",description="Key to query")
                                                                                                                                                                                                                                                                         String key)

locateKey

@ManagedOperation(description="Shows the addresses of the nodes where a write operation would store the entry associated with the specified key. Only works with String keys.",
                  displayName="Locate key")
public List<String> locateKey(@Parameter(name="key",description="Key to locate")
                                                                                                                                                                                                                                                          String key)

getCacheTopology

public LocalizedCacheTopology getCacheTopology()

Specified by:

getCacheTopology in interface DistributionManager

Returns:

the current cache topology, which includes the read and write consistent hashes.

setCacheTopology

public void setCacheTopology(CacheTopology cacheTopology)

Specified by:

setCacheTopology in interface DistributionManager

createLocalizedCacheTopology

public LocalizedCacheTopology createLocalizedCacheTopology(CacheTopology cacheTopology)

Specified by:

createLocalizedCacheTopology in interface DistributionManager

makeSingletonTopology

public static LocalizedCacheTopology makeSingletonTopology(CacheMode cacheMode,
                                                           KeyPartitioner keyPartitioner,
                                                           int numSegments,
                                                           Address localAddress)