org.codehaus.wadi.replication.manager.basic
Class SyncSecondaryManager
java.lang.Object
org.codehaus.wadi.replication.manager.basic.SyncSecondaryManager
- All Implemented Interfaces:
- SecondaryManager
public class SyncSecondaryManager
- extends java.lang.Object
- implements SecondaryManager
- Version:
- $Revision: 2340 $
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 |
SyncSecondaryManager
public SyncSecondaryManager(java.util.Map<java.lang.Object,ReplicaInfo> keyToReplicaInfo,
BackingStrategy backingStrategy,
LocalPeer localPeer,
ObjectStateHandler stateHandler,
ServiceProxyFactory replicaStorageServiceProxy)
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.