org.infinispan.distribution
Class RehashTask

java.lang.Object
  org.infinispan.distribution.RehashTask

All Implemented Interfaces:

Callable<Void>

Direct Known Subclasses:

JoinTask, LeaveTask

public abstract class RehashTask
extends Object
implements Callable<Void>

A task that handles the rehashing of data in the cache system wheh nodes join or leave the cluster. This abstract class contains common functionality. Subclasses will specify different behavior for nodes joining and leaving.

Since:

4.0

Author:

Manik Surtani

Constructor Summary

protected

RehashTask(DistributionManagerImpl dmi, RpcManager rpcManager, Configuration configuration, TransactionLogger transactionLogger, CommandsFactory cf, DataContainer dataContainer)

Method Summary

Void	call()
protected Collection<Address>	coordinator()
protected Collection<Address>	getInvalidHolders(Object key, ConsistentHash chOld, ConsistentHash chNew)
protected abstract Log	getLog()
protected void	invalidateInvalidHolders(ConsistentHash chOld, ConsistentHash chNew)
protected abstract void	performRehash()

Methods inherited from class java.lang.Object

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

Constructor Detail

RehashTask

protected RehashTask(DistributionManagerImpl dmi,
                     RpcManager rpcManager,
                     Configuration configuration,
                     TransactionLogger transactionLogger,
                     CommandsFactory cf,
                     DataContainer dataContainer)

Method Detail

call

public Void call()
          throws Exception

Specified by:

call in interface Callable<Void>

Throws:

Exception

performRehash

protected abstract void performRehash()
                               throws Exception

Throws:

Exception

getLog

protected abstract Log getLog()

coordinator

protected Collection<Address> coordinator()

invalidateInvalidHolders

protected void invalidateInvalidHolders(ConsistentHash chOld,
                                        ConsistentHash chNew)
                                 throws ExecutionException,
                                        InterruptedException

Throws:

ExecutionException

InterruptedException

getInvalidHolders

protected Collection<Address> getInvalidHolders(Object key,
                                                ConsistentHash chOld,
                                                ConsistentHash chNew)