Package org.infinispan.affinity.impl

Class KeyAffinityServiceImpl<K>

java.lang.Object

org.infinispan.affinity.impl.KeyAffinityServiceImpl<K>

All Implemented Interfaces:

KeyAffinityService<K>, Lifecycle

@ThreadSafe
public class KeyAffinityServiceImpl<K>
extends Object
implements KeyAffinityService<K>

Implementation of KeyAffinityService.

Since:

4.1

Author:

Mircea.Markus@jboss.com

Field Summary

Fields

Modifier and Type	Field	Description
static final float	THRESHOLD

Constructor Summary

Constructors

Constructor	Description
KeyAffinityServiceImpl(Executor executor, Cache<? extends K,?> cache, KeyGenerator<? extends K> keyGenerator, int bufferSize, Collection<Address> filter, boolean start)

Method Summary

Modifier and Type	Method	Description
Map<Address,BlockingQueue<K>>	getAddress2KeysMapping()
K	getCollocatedKey(K otherKey)	Returns a key that will be distributed on the same node as the supplied key.
K	getKeyForAddress(Address address)	Returns a key that will be distributed on the cluster node identified by address.
int	getMaxNumberOfKeys()
void	handleCacheStopped(CacheStoppedEvent cse)
void	handleViewChange(TopologyChangedEvent<?,?> vce)
boolean	isKeyGeneratorThreadActive()
boolean	isKeyGeneratorThreadAlive()
boolean	isStarted()	Checks weather or not the service is started.
void	start()	Invoked on component start
void	stop()	Invoked on component stop

Methods inherited from class java.lang.Object

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

Field Details

THRESHOLD

public static final float THRESHOLD

See Also:

• Constant Field Values

Constructor Details

KeyAffinityServiceImpl

public KeyAffinityServiceImpl(Executor executor,
 Cache<? extends K,?> cache,
 KeyGenerator<? extends K> keyGenerator,
 int bufferSize,
 Collection<Address> filter,
 boolean start)

Method Details

getCollocatedKey

public K getCollocatedKey(K otherKey)

Description copied from interface: KeyAffinityService

Returns a key that will be distributed on the same node as the supplied key.

Specified by:

getCollocatedKey in interface KeyAffinityService<K>

Parameters:

otherKey - the key for which we need a collocation

Returns:

a key object

getKeyForAddress

public K getKeyForAddress(Address address)

Description copied from interface: KeyAffinityService

Returns a key that will be distributed on the cluster node identified by address.

Specified by:

getKeyForAddress in interface KeyAffinityService<K>

Parameters:

address - identifying the cluster node.

Returns:

a key object

start

public void start()

Description copied from interface: Lifecycle

Invoked on component start

Specified by:

start in interface Lifecycle

stop

public void stop()

Description copied from interface: Lifecycle

Invoked on component stop

Specified by:

stop in interface Lifecycle

handleViewChange

public void handleViewChange(TopologyChangedEvent<?,?> vce)

isKeyGeneratorThreadAlive

public boolean isKeyGeneratorThreadAlive()

handleCacheStopped

public void handleCacheStopped(CacheStoppedEvent cse)

getAddress2KeysMapping

public Map<Address,BlockingQueue<K>> getAddress2KeysMapping()

getMaxNumberOfKeys

public int getMaxNumberOfKeys()

isKeyGeneratorThreadActive

public boolean isKeyGeneratorThreadActive()

isStarted

public boolean isStarted()

Description copied from interface: KeyAffinityService

Checks weather or not the service is started.

Specified by:

isStarted in interface KeyAffinityService<K>