org.infinispan.distribution
Class MergeTask

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

public class MergeTask
extends JoinTask

This task is kicked off whenever a MERGE is detected

Since:
4.2.1
Author:
Manik Surtani

Nested Class Summary
 
Nested classes/interfaces inherited from class org.infinispan.distribution.JoinTask
JoinTask.JoinStateGrabber
 
Nested classes/interfaces inherited from class org.infinispan.distribution.RehashTask
RehashTask.StateGrabber
 
Field Summary
 
Fields inherited from class org.infinispan.distribution.JoinTask
chNew, chOld
 
Fields inherited from class org.infinispan.distribution.RehashTask
cf, configuration, dataContainer, distributionManager, log, rpcManager, self, statePullExecutor, trace
 
Constructor Summary
MergeTask(RpcManager rpcManager, CommandsFactory commandsFactory, Configuration conf, DataContainer dataContainer, DistributionManagerImpl dmi, InboundInvocationHandler inboundInvocationHandler, List<Address> newView, List<List<Address>> mergedGroups)
           
 
Method Summary
protected  void broadcastNewConsistentHash()
           
protected  void getPermissionToJoin()
           
protected  void signalJoinRehashEnd()
           
 
Methods inherited from class org.infinispan.distribution.JoinTask
getMyAddress, performRehash
 
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
 

Constructor Detail

MergeTask

public MergeTask(RpcManager rpcManager,
                 CommandsFactory commandsFactory,
                 Configuration conf,
                 DataContainer dataContainer,
                 DistributionManagerImpl dmi,
                 InboundInvocationHandler inboundInvocationHandler,
                 List<Address> newView,
                 List<List<Address>> mergedGroups)
Method Detail

getPermissionToJoin

protected void getPermissionToJoin()
Overrides:
getPermissionToJoin in class JoinTask

broadcastNewConsistentHash

protected void broadcastNewConsistentHash()
Overrides:
broadcastNewConsistentHash in class JoinTask

signalJoinRehashEnd

protected void signalJoinRehashEnd()
Overrides:
signalJoinRehashEnd in class JoinTask

-->

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