org.infinispan.distribution
Class LeaveTask

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

All Implemented Interfaces:

Callable<Void>

public class LeaveTask
extends RehashTask

A task to handle rehashing for when a node leaves the cluster

Since:

4.0

Author:

Manik Surtani

Constructor Summary

protected

LeaveTask(DistributionManagerImpl dmi, RpcManager rpcManager, Configuration configuration, List<Address> leavers, TransactionLogger transactionLogger, CommandsFactory cf, DataContainer dataContainer)

Method Summary

protected Collection<Address>	getInvalidHolders(Object key, ConsistentHash chOld, ConsistentHash chNew)
protected Log	getLog()
protected void	performRehash()

Methods inherited from class org.infinispan.distribution.RehashTask

call, coordinator, invalidateInvalidHolders

Methods inherited from class java.lang.Object

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

Constructor Detail

LeaveTask

protected LeaveTask(DistributionManagerImpl dmi,
                    RpcManager rpcManager,
                    Configuration configuration,
                    List<Address> leavers,
                    TransactionLogger transactionLogger,
                    CommandsFactory cf,
                    DataContainer dataContainer)

Method Detail

performRehash

protected void performRehash()
                      throws Exception

Specified by:

performRehash in class RehashTask

Throws:

Exception

getLog

protected Log getLog()

Specified by:

getLog in class RehashTask

getInvalidHolders

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

Overrides:

getInvalidHolders in class RehashTask