edu.umass.cs.reconfiguration

Class RepliconfigurableReconfiguratorDB<NodeIDType>

java.lang.Object

edu.umass.cs.reconfiguration.AbstractReplicaCoordinator<NodeIDType>

edu.umass.cs.reconfiguration.PaxosReplicaCoordinator<NodeIDType>

edu.umass.cs.reconfiguration.RepliconfigurableReconfiguratorDB<NodeIDType>

Type Parameters:

NodeIDType -

All Implemented Interfaces:

Application, AppRequestParser, AppRequestParserBytes, Replicable, Reconfigurable, ReplicaCoordinator<NodeIDType>, Repliconfigurable

public class RepliconfigurableReconfiguratorDB<NodeIDType>
extends PaxosReplicaCoordinator<NodeIDType>

Author:

V. Arun

We need this class to extend both PaxosReplicationCoordinator and AbstractReconfiguratorDB, so we use an interface for the latter.

Field Summary

Fields

Modifier and Type	Field and Description
protected AbstractReconfiguratorDB<NodeIDType>	app
protected ConsistentReconfigurableNodeConfig<NodeIDType>	consistentNodeConfig

Fields inherited from class edu.umass.cs.reconfiguration.PaxosReplicaCoordinator

log

Fields inherited from class edu.umass.cs.reconfiguration.AbstractReplicaCoordinator

messenger

Constructor Summary

Constructors

Constructor and Description
RepliconfigurableReconfiguratorDB(AbstractReconfiguratorDB<NodeIDType> app, NodeIDType myID, ConsistentReconfigurableNodeConfig<NodeIDType> consistentNodeConfig, Messenger<NodeIDType,org.json.JSONObject> niot, boolean startCleanSlate)

Method Summary

Modifier and Type	Method and Description
protected void	addToOutstanding(java.lang.String name)
protected boolean	amAffected(NodeIDType node)
protected boolean	changeActiveDBNodeConfig(int version)
protected boolean	changeDBNodeConfig(int version)
protected void	close()
boolean	coordinateRequest(Request request, ExecutedCallback callback) Start of abstract methods
boolean	coordinateRequestSuppressExceptions(Request request, ExecutedCallback callback)
boolean	createReplicaGroup(java.lang.String groupName, int epoch, java.lang.String state, java.util.Set<NodeIDType> nodes) This method should return true if the replica group is successfully created or one already exists with the same set of nodes.
protected void	delayedDeleteComplete()
boolean	deleteFinalState(java.lang.String rcGroupName, int epoch) Garbage-collects the final state for name, epoch.
java.util.Set<NodeIDType>	filterDeletedActives(java.util.Set<NodeIDType> toFilter)
protected void	garbageCollectDeletedNode(NodeIDType node)
protected void	garbageCollectOldFileSystemBasedCheckpoints()
protected java.util.Set<NodeIDType>	getActiveReplicas(java.lang.String name)
protected int	getCurNCEpoch()
protected java.lang.String	getDemandStats(java.lang.String name)
protected java.util.Set<java.lang.String>	getMergeList(java.lang.String newRCGroupName) Reconfigurator reconfiguration methods
protected java.util.Map<java.lang.String,java.util.Set<java.lang.String>>	getMergeLists()
protected ConsistentHashing<NodeIDType>	getNewConsistentHashRing()
protected java.util.Map<java.lang.String,java.util.Set<NodeIDType>>	getNewGroup(java.lang.String oldRCNode)
protected java.util.Map<java.lang.String,java.util.Set<NodeIDType>>	getNewRCGroups()
protected java.util.Set<java.lang.String>	getNodeSetAsStringSet(java.util.Set<NodeIDType> nodeSet)
protected ConsistentHashing<NodeIDType>	getOldConsistentHashRing()
protected java.util.Map<java.lang.String,java.util.Set<NodeIDType>>	getOldGroup(java.lang.String newRCNode)
protected java.lang.String	getOldGroupName(java.lang.String name)
protected java.util.Map<java.lang.String,java.util.Set<NodeIDType>>	getOldRCGroups()
protected java.lang.String[]	getPendingReconfigurations()
java.lang.String	getRCGroupName(NodeIDType node) RC group name of node is just node.toString().
protected java.lang.String	getRCGroupName(java.lang.String serviceName)
ReconfigurationRecord<NodeIDType>	getReconfigurationRecord(java.lang.String name) Allows uncoordinated access to DB state.
java.util.Set<NodeIDType>	getReplicaGroup(java.lang.String serviceName) This method must return the replica group that was most recently successfully created for the serviceName using createReplicaGroup.
protected boolean	isBeingAdded(java.lang.String curRCGroup)
protected boolean	isBeingDeleted(java.lang.String curRCGroup)
protected boolean	isNCRecord(java.lang.String name)
boolean	isRCGroupName(java.lang.String name) Checks if RC group name is name itself by consulting the soft copy of node config.
protected void	notifyOutstanding(java.lang.String name)
protected boolean	outstandingContains(java.lang.String name)
void	removePending(java.lang.String name)
protected void	setOutstanding(NodeIDType active)
protected java.util.Set<NodeIDType>	setRCEpochs(java.util.Set<NodeIDType> addNodes, java.util.Set<NodeIDType> deleteNodes)
protected void	setRecovering(boolean b)
protected void	waitOutstanding(int max)

Methods inherited from class edu.umass.cs.reconfiguration.PaxosReplicaCoordinator

coordinateRequest, createReplicaGroup, deleteReplicaGroup, existsOrHigher, forceCheckpoint, getEpoch, getFinalState, getFinalStateContainer, getRequestTypes, getStopRequest, putInitialState, removeDead, setOutOfOrderLimit, stop, stopFailureMonitoring, toString

Methods inherited from class edu.umass.cs.reconfiguration.AbstractReplicaCoordinator

callCallback, checkpoint, execute, execute, execute, getAppRequestTypes, getARARNodesAsString, getARRCNodesAsString, getCallback, getCoordinatorRequestTypes, getMessenger, getMutualAuthAppRequestTypes, getMyID, getRequest, getRequest, getRequest, handleIncoming, hasLargeCheckpoints, registerCoordination, restore, sendAllLazy, setCallback, setLargeCheckpoints, setMessenger, setStopCallback

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Methods inherited from interface edu.umass.cs.gigapaxos.interfaces.AppRequestParser

getMutualAuthRequestTypes, getServerAuthRequestTypes

Field Detail

app

protected final AbstractReconfiguratorDB<NodeIDType> app

consistentNodeConfig

protected final ConsistentReconfigurableNodeConfig<NodeIDType> consistentNodeConfig

Constructor Detail

RepliconfigurableReconfiguratorDB

public RepliconfigurableReconfiguratorDB(AbstractReconfiguratorDB<NodeIDType> app,
                                         NodeIDType myID,
                                         ConsistentReconfigurableNodeConfig<NodeIDType> consistentNodeConfig,
                                         Messenger<NodeIDType,org.json.JSONObject> niot,
                                         boolean startCleanSlate)

Parameters:

app -

myID -

consistentNodeConfig -

niot -

startCleanSlate -

Method Detail

getActiveReplicas

protected java.util.Set<NodeIDType> getActiveReplicas(java.lang.String name)

coordinateRequest

public boolean coordinateRequest(Request request,
                                 ExecutedCallback callback)
                          throws java.io.IOException,
                                 RequestParseException

Description copied from class: AbstractReplicaCoordinator

Start of abstract methods

Specified by:

coordinateRequest in interface ReplicaCoordinator<NodeIDType>

Overrides:

coordinateRequest in class PaxosReplicaCoordinator<NodeIDType>

Returns:

Success of coordination.

Throws:

java.io.IOException

RequestParseException

coordinateRequestSuppressExceptions

public boolean coordinateRequestSuppressExceptions(Request request,
                                                   ExecutedCallback callback)

Parameters:

request -

callback -

Returns:

Returns the result of coordinateRequest(Request,ExecutedCallback).

getReconfigurationRecord

public ReconfigurationRecord<NodeIDType> getReconfigurationRecord(java.lang.String name)

Allows uncoordinated access to DB state. In-memory "DB" could also allow outsiders to modify DB state through returned references, which is problematic unless the returned values are deep copied.

Parameters:

name -

Returns:

ReconfigurationRecord for name.

createReplicaGroup

public boolean createReplicaGroup(java.lang.String groupName,
                                  int epoch,
                                  java.lang.String state,
                                  java.util.Set<NodeIDType> nodes)

Description copied from interface: ReplicaCoordinator

This method should return true if the replica group is successfully created or one already exists with the same set of nodes. It should return false otherwise.

Specified by:

createReplicaGroup in interface ReplicaCoordinator<NodeIDType>

Overrides:

createReplicaGroup in class PaxosReplicaCoordinator<NodeIDType>

Returns:

True if created successfully.

getDemandStats

protected java.lang.String getDemandStats(java.lang.String name)

getPendingReconfigurations

protected java.lang.String[] getPendingReconfigurations()

close

protected void close()

getReplicaGroup

public java.util.Set<NodeIDType> getReplicaGroup(java.lang.String serviceName)

Description copied from interface: ReplicaCoordinator

This method must return the replica group that was most recently successfully created for the serviceName using createReplicaGroup.

Specified by:

getReplicaGroup in interface ReplicaCoordinator<NodeIDType>

Overrides:

getReplicaGroup in class PaxosReplicaCoordinator<NodeIDType>

Returns:

Set of nodes in the replica group for serviceName.

getRCGroupName

protected java.lang.String getRCGroupName(java.lang.String serviceName)

setRecovering

protected void setRecovering(boolean b)

getMergeList

protected java.util.Set<java.lang.String> getMergeList(java.lang.String newRCGroupName)

Reconfigurator reconfiguration methods

getMergeLists

protected java.util.Map<java.lang.String,java.util.Set<java.lang.String>> getMergeLists()

amAffected

protected boolean amAffected(NodeIDType node)

setRCEpochs

protected java.util.Set<NodeIDType> setRCEpochs(java.util.Set<NodeIDType> addNodes,
                                                java.util.Set<NodeIDType> deleteNodes)

getOldRCGroups

protected java.util.Map<java.lang.String,java.util.Set<NodeIDType>> getOldRCGroups()

getNewRCGroups

protected java.util.Map<java.lang.String,java.util.Set<NodeIDType>> getNewRCGroups()

isRCGroupName

public boolean isRCGroupName(java.lang.String name)

Checks if RC group name is name itself by consulting the soft copy of node config. We could also have checked if the name is node.toString() for some node in the current set of reconfigurators.

Parameters:

name -

Returns:

True if name represents a reconfigurator group name.

getRCGroupName

public final java.lang.String getRCGroupName(NodeIDType node)

RC group name of node is just node.toString(). Changing it to anything else will break code.

Parameters:

node -

Returns:

String form of node.

getOldGroupName

protected java.lang.String getOldGroupName(java.lang.String name)

getOldConsistentHashRing

protected ConsistentHashing<NodeIDType> getOldConsistentHashRing()

getNewConsistentHashRing

protected ConsistentHashing<NodeIDType> getNewConsistentHashRing()

getOldGroup

protected java.util.Map<java.lang.String,java.util.Set<NodeIDType>> getOldGroup(java.lang.String newRCNode)

getNodeSetAsStringSet

protected java.util.Set<java.lang.String> getNodeSetAsStringSet(java.util.Set<NodeIDType> nodeSet)

getNewGroup

protected java.util.Map<java.lang.String,java.util.Set<NodeIDType>> getNewGroup(java.lang.String oldRCNode)

changeDBNodeConfig

protected boolean changeDBNodeConfig(int version)

changeActiveDBNodeConfig

protected boolean changeActiveDBNodeConfig(int version)

deleteFinalState

public boolean deleteFinalState(java.lang.String rcGroupName,
                                int epoch)

Description copied from interface: Reconfigurable

Garbage-collects the final state for name, epoch.

Specified by:

deleteFinalState in interface Reconfigurable

Overrides:

deleteFinalState in class PaxosReplicaCoordinator<NodeIDType>

Returns:

True if final state for name:epoch was deleted or did not exist to begin with.

isBeingDeleted

protected boolean isBeingDeleted(java.lang.String curRCGroup)

isBeingAdded

protected boolean isBeingAdded(java.lang.String curRCGroup)

delayedDeleteComplete

protected void delayedDeleteComplete()

getCurNCEpoch

protected int getCurNCEpoch()

garbageCollectDeletedNode

protected void garbageCollectDeletedNode(NodeIDType node)

garbageCollectOldFileSystemBasedCheckpoints

protected void garbageCollectOldFileSystemBasedCheckpoints()

isNCRecord

protected boolean isNCRecord(java.lang.String name)

removePending

public void removePending(java.lang.String name)

Parameters:

name -

setOutstanding

protected void setOutstanding(NodeIDType active)

filterDeletedActives

public java.util.Set<NodeIDType> filterDeletedActives(java.util.Set<NodeIDType> toFilter)

Parameters:

toFilter -

Returns:

Will modify argument and return it by removing active nodes either currently being deleted or that have been deleted. Used by WaitAckDropEpoch to avoid unnecessary message send failures.

outstandingContains

protected boolean outstandingContains(java.lang.String name)

addToOutstanding

protected void addToOutstanding(java.lang.String name)

waitOutstanding

protected void waitOutstanding(int max)
                        throws java.lang.InterruptedException

Throws:

java.lang.InterruptedException

notifyOutstanding

protected void notifyOutstanding(java.lang.String name)