org.infinispan.distribution
Class JoinTask

java.lang.Object
  extended by org.infinispan.distribution.RehashTask
      extended by org.infinispan.distribution.JoinTask
All Implemented Interfaces:
Callable<Void>
Direct Known Subclasses:
MergeTask

public class JoinTask
extends RehashTask

JoinTask: This is a PULL based rehash. JoinTask is kicked off on the JOINER. Please see detailed designs on http://community.jboss.org/wiki/DesignOfDynamicRehashing

Since:
4.0
Author:
Manik Surtani, Mircea.Markus@jboss.com

Nested Class Summary
protected  class JoinTask.JoinStateGrabber
           
 
Nested classes/interfaces inherited from class org.infinispan.distribution.RehashTask
RehashTask.StateGrabber
 
Field Summary
protected  ConsistentHash chNew
           
protected  ConsistentHash chOld
           
 
Fields inherited from class org.infinispan.distribution.RehashTask
cf, configuration, dataContainer, distributionManager, log, rpcManager, self, statePullExecutor, trace
 
Constructor Summary
JoinTask(RpcManager rpcManager, CommandsFactory commandsFactory, Configuration conf, DataContainer dataContainer, DistributionManagerImpl dmi, InboundInvocationHandler inboundInvocationHandler)
           
 
Method Summary
protected  void broadcastNewConsistentHash()
           
 Address getMyAddress()
           
protected  void getPermissionToJoin()
           
protected  void performRehash()
           
protected  void signalJoinRehashEnd()
           
 
Methods inherited from class org.infinispan.distribution.RehashTask
call, coordinator, getInvalidHolders, invalidateInvalidHolders, invalidateInvalidHolders
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Field Detail

chOld

protected ConsistentHash chOld

chNew

protected ConsistentHash chNew
Constructor Detail

JoinTask

public JoinTask(RpcManager rpcManager,
                CommandsFactory commandsFactory,
                Configuration conf,
                DataContainer dataContainer,
                DistributionManagerImpl dmi,
                InboundInvocationHandler inboundInvocationHandler)
Method Detail

getPermissionToJoin

protected void getPermissionToJoin()
                            throws Exception
Throws:
Exception

signalJoinRehashEnd

protected void signalJoinRehashEnd()

performRehash

protected void performRehash()
                      throws Exception
Specified by:
performRehash in class RehashTask
Throws:
Exception

broadcastNewConsistentHash

protected void broadcastNewConsistentHash()

getMyAddress

public Address getMyAddress()


Copyright © 2011 JBoss, a division of Red Hat. All Rights Reserved.