org.codehaus.wadi.replication.manager.basic
Class SyncSecondaryManager

java.lang.Object
  extended by org.codehaus.wadi.replication.manager.basic.SyncSecondaryManager
All Implemented Interfaces:
SecondaryManager

public class SyncSecondaryManager
extends java.lang.Object
implements SecondaryManager

Version:
$Revision: 2340 $

Constructor Summary
SyncSecondaryManager(java.util.Map<java.lang.Object,ReplicaInfo> keyToReplicaInfo, BackingStrategy backingStrategy, LocalPeer localPeer, ObjectStateHandler stateHandler, ServiceProxyFactory replicaStorageServiceProxy)
           
 
Method Summary
protected  Peer[] filterLeavingPeer(Peer leavingPeer, Peer[] oldSecondaries)
           
protected  ReplicaInfo updateSecondaries(java.lang.Object key, ReplicaInfo replicaInfo)
           
protected  void updateSecondaries(java.lang.Object key, ReplicaInfo replicaInfo, Peer[] oldSecondaries)
           
protected  ReplicaInfo updateSecondaries(java.lang.Object key, ReplicaInfo replicaInfo, SecondaryFilter secondaryFilter)
           
 void updateSecondariesFollowingJoiningPeer(Peer joiningPeer)
           
protected  ReplicaInfo updateSecondariesFollowingLeavingPeer(java.lang.Object key, ReplicaInfo replicaInfo, Peer leavingPeer)
           
 void updateSecondariesFollowingLeavingPeer(Peer leavingPeer)
           
 ReplicaInfo updateSecondariesFollowingRestoreFromSecondary(java.lang.Object key, ReplicaInfo replicaInfo)
           
 ReplicaInfo updateSecondariesWithBlackListedSecondary(java.lang.Object key, ReplicaInfo replicaInfo, Peer blackListedSecondary)
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

SyncSecondaryManager

public SyncSecondaryManager(java.util.Map<java.lang.Object,ReplicaInfo> keyToReplicaInfo,
                            BackingStrategy backingStrategy,
                            LocalPeer localPeer,
                            ObjectStateHandler stateHandler,
                            ServiceProxyFactory replicaStorageServiceProxy)
Method Detail

updateSecondariesFollowingJoiningPeer

public void updateSecondariesFollowingJoiningPeer(Peer joiningPeer)
Specified by:
updateSecondariesFollowingJoiningPeer in interface SecondaryManager

updateSecondariesFollowingLeavingPeer

public void updateSecondariesFollowingLeavingPeer(Peer leavingPeer)
Specified by:
updateSecondariesFollowingLeavingPeer in interface SecondaryManager

updateSecondariesFollowingRestoreFromSecondary

public ReplicaInfo updateSecondariesFollowingRestoreFromSecondary(java.lang.Object key,
                                                                  ReplicaInfo replicaInfo)
Specified by:
updateSecondariesFollowingRestoreFromSecondary in interface SecondaryManager

updateSecondariesWithBlackListedSecondary

public ReplicaInfo updateSecondariesWithBlackListedSecondary(java.lang.Object key,
                                                             ReplicaInfo replicaInfo,
                                                             Peer blackListedSecondary)
Specified by:
updateSecondariesWithBlackListedSecondary in interface SecondaryManager

updateSecondaries

protected ReplicaInfo updateSecondaries(java.lang.Object key,
                                        ReplicaInfo replicaInfo)

updateSecondaries

protected ReplicaInfo updateSecondaries(java.lang.Object key,
                                        ReplicaInfo replicaInfo,
                                        SecondaryFilter secondaryFilter)

updateSecondariesFollowingLeavingPeer

protected ReplicaInfo updateSecondariesFollowingLeavingPeer(java.lang.Object key,
                                                            ReplicaInfo replicaInfo,
                                                            Peer leavingPeer)

filterLeavingPeer

protected Peer[] filterLeavingPeer(Peer leavingPeer,
                                   Peer[] oldSecondaries)

updateSecondaries

protected void updateSecondaries(java.lang.Object key,
                                 ReplicaInfo replicaInfo,
                                 Peer[] oldSecondaries)


Copyright © 2010. All Rights Reserved.