Infinispan Distribution 5.2.6.Final-redhat-2

org.infinispan.statetransfer
Interface StateTransferManager

All Known Implementing Classes:
StateTransferManagerImpl

public interface StateTransferManager

A component that manages the state transfer when the topology of the cluster changes.

Since:
5.1
Author:
Dan Berindei , Mircea Markus, anistor@redhat.com

Method Summary
 void forwardCommandIfNeeded(TopologyAffectedCommand command, Set<Object> affectedKeys, Address origin, boolean sync)
          If there is an state transfer happening at the moment, this method forwards the supplied command to the nodes that are new owners of the data, in order to assure consistency.
 CacheTopology getCacheTopology()
           
 boolean isJoinComplete()
           
 boolean isLocalNodeFirst()
           
 boolean isStateTransferInProgress()
          Checks if an inbound state transfer is in progress.
 boolean isStateTransferInProgressForKey(Object key)
          Checks if an inbound state transfer is in progress for a given key.
 void notifyEndOfTopologyUpdate(int topologyId)
           
 void start()
           
 void stop()
           
 

Method Detail

isJoinComplete

boolean isJoinComplete()

isStateTransferInProgress

boolean isStateTransferInProgress()
Checks if an inbound state transfer is in progress.


isStateTransferInProgressForKey

boolean isStateTransferInProgressForKey(Object key)
Checks if an inbound state transfer is in progress for a given key.

Parameters:
key -
Returns:

getCacheTopology

CacheTopology getCacheTopology()

start

void start()
           throws Exception
Throws:
Exception

stop

void stop()

isLocalNodeFirst

boolean isLocalNodeFirst()
Returns:
true if the local node was the first to start this cache in the cluster.

forwardCommandIfNeeded

void forwardCommandIfNeeded(TopologyAffectedCommand command,
                            Set<Object> affectedKeys,
                            Address origin,
                            boolean sync)
If there is an state transfer happening at the moment, this method forwards the supplied command to the nodes that are new owners of the data, in order to assure consistency.


notifyEndOfTopologyUpdate

void notifyEndOfTopologyUpdate(int topologyId)

Infinispan Distribution 5.2.6.Final-redhat-2

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