edu.umass.cs.reconfiguration

Class SQLReconfiguratorDB<NodeIDType>

java.lang.Object

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

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

Type Parameters:

NodeIDType -

All Implemented Interfaces:

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

public class SQLReconfiguratorDB<NodeIDType>
extends AbstractReconfiguratorDB<NodeIDType>
implements ReconfiguratorDB<NodeIDType>

Author:

V. Arun

Nested Class Summary

Nested classes/interfaces inherited from class edu.umass.cs.reconfiguration.AbstractReconfiguratorDB

AbstractReconfiguratorDB.RecordNames

Field Summary

Fields

Modifier and Type	Field and Description
protected java.lang.String	logDirectory

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

consistentNodeConfig, myID, recovering, TWO_PAXOS_RC

Constructor Summary

Constructors

Constructor and Description
SQLReconfiguratorDB(NodeIDType myID, ConsistentReconfigurableNodeConfig<NodeIDType> nc)

Method Summary

Modifier and Type	Method and Description
boolean	addActiveReplica(NodeIDType node, java.net.InetSocketAddress sockAddr, int version)
boolean	addReconfigurator(NodeIDType node, java.net.InetSocketAddress sockAddr, int version)
java.lang.String	checkpoint(java.lang.String rcGroup) Incomplete paxos methods below
void	clearMerged(java.lang.String rcGroupName, int epoch) Clear all merged state in RC record.
void	close() Close gracefully.
boolean	closeReadActiveRecords()
ReconfigurationRecord<NodeIDType>	createReconfigurationRecord(ReconfigurationRecord<NodeIDType> record)
boolean	createReconfigurationRecords(java.util.Map<java.lang.String,java.lang.String> nameStates, java.util.Set<NodeIDType> newActives, ReconfigurationConfig.ReconfigureUponActivesChange policy)
void	delayedDeleteComplete()
boolean	deleteReconfigurationRecord(java.lang.String name, int epoch)
static void	dropState(java.lang.String myID, ConsistentReconfigurableNodeConfig<java.lang.String> nc)
java.lang.String	fetchAndAggregateMergeeStates(java.util.Map<java.lang.String,java.lang.String> finalStates, java.lang.String mergerGroup, int mergerGroupEpoch)
void	garbageCollectedDeletedNode(NodeIDType node)
boolean	garbageCollectOldReconfigurators(int version)
java.lang.String	getDemandStats(java.lang.String name)
protected java.lang.String	getNodeConfigRecords(ConsistentReconfigurableNodeConfig<NodeIDType> nc)
java.lang.String[]	getPendingReconfigurations() Names for which reconfiguration is incomplete, needed for recovery
java.util.Set<java.lang.String>	getRCGroupNames()
java.util.Map<java.lang.String,java.util.Set<NodeIDType>>	getRCGroups() Get current RC group names from the DB
protected java.lang.String	getRCTableString()
ReconfigurationRecord<NodeIDType>	getReconfigurationRecord(java.lang.String name) Start of overridden methods
boolean	initiateReadActiveRecords(NodeIDType active)
static void	main(java.lang.String[] args)
boolean	markDeleteReconfigurationRecord(java.lang.String name, int epoch)
boolean	mergeIntent(java.lang.String name, int epoch, java.lang.String mergee)
boolean	mergeState(java.lang.String rcGroupName, int epoch, java.lang.String mergee, int mergeeEpoch, java.lang.String state) Merge state, i.e., append instead of replacing state, exactly once.
protected void	printRCTable()
ReconfigurationRecord<NodeIDType>	readNextActiveRecord(boolean add)
void	removePending(java.lang.String name)
boolean	restore(java.lang.String rcGroup, java.lang.String state) Resets the current application state for name to state.
void	setRCEpochs(ReconfigurationRecord<NodeIDType> ncRecord) Sets RC epochs so that we know the epoch numbers for each reconfigurator group.
boolean	setState(java.lang.String name, int epoch, ReconfigurationRecord.RCStates state) Set epoch and state as specified.
boolean	setStateInitReconfiguration(java.util.Map<java.lang.String,java.lang.String> nameStates, int epoch, ReconfigurationRecord.RCStates state, java.util.Set<NodeIDType> newActives)
boolean	setStateInitReconfiguration(java.lang.String name, int epoch, ReconfigurationRecord.RCStates state, java.util.Set<NodeIDType> newActives) Set epoch, state, newActives, primary only if current state is READY
boolean	setStateMerge(java.util.Map<java.lang.String,java.lang.String> nameStates, int epoch, ReconfigurationRecord.RCStates state, java.util.Set<NodeIDType> newActives)
boolean	setStateMerge(java.lang.String name, int epoch, ReconfigurationRecord.RCStates state, java.util.Set<NodeIDType> newActives, java.util.Set<java.lang.String> mergees)
java.lang.String	toString()
boolean	updateDemandStats(DemandReport<NodeIDType> report) Update demand statistics.

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

areRCChangesCompleteDebug, autoInvokeMethod, deleteFinalState, execute, execute, getEpoch, getFinalState, getMergeList, getMergeLists, getNewConsistentHashRing, getNewRCGroups, getNoopRequest, getOldConsistentHashRing, getOldRCGroups, getRCGroupName, getRCGroupName, getRCGroups, getRCGroups, getReconfigurationRecord, getRequest, getRequestTypes, getStopRequest, handleDemandReport, handleRCRecordRequest, handleRequestActiveReplicas, handleStopEpoch, isAffected, isRCGroupName, putInitialState, setCallback, setRCEpochs, updateActiveDBNodeConfig, updateDBNodeConfig

Methods inherited from class java.lang.Object

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

Methods inherited from interface edu.umass.cs.reconfiguration.interfaces.ReconfiguratorDB

setCallback

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

getMutualAuthRequestTypes, getRequest, getServerAuthRequestTypes

Field Detail

logDirectory

protected java.lang.String logDirectory

Constructor Detail

SQLReconfiguratorDB

public SQLReconfiguratorDB(NodeIDType myID,
                           ConsistentReconfigurableNodeConfig<NodeIDType> nc)

Parameters:

myID -

nc -

Method Detail

dropState

public static final void dropState(java.lang.String myID,
                                   ConsistentReconfigurableNodeConfig<java.lang.String> nc)

Parameters:

myID -

nc -

getReconfigurationRecord

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

Start of overridden methods

Specified by:

getReconfigurationRecord in interface ReconfiguratorDB<NodeIDType>

Returns:

ReconfigurationRecord for name.

updateDemandStats

public boolean updateDemandStats(DemandReport<NodeIDType> report)

Description copied from interface: ReconfiguratorDB

Update demand statistics.

Specified by:

updateDemandStats in interface ReconfiguratorDB<NodeIDType>

Returns:

True if updated successfully.

setState

public boolean setState(java.lang.String name,
                        int epoch,
                        ReconfigurationRecord.RCStates state)

Description copied from interface: ReconfiguratorDB

Set epoch and state as specified.

Specified by:

setState in interface ReconfiguratorDB<NodeIDType>

Returns:

True if successfully set; false if the state transition is not legitimate.

setStateMerge

public boolean setStateMerge(java.lang.String name,
                             int epoch,
                             ReconfigurationRecord.RCStates state,
                             java.util.Set<NodeIDType> newActives,
                             java.util.Set<java.lang.String> mergees)

Specified by:

setStateMerge in interface ReconfiguratorDB<NodeIDType>

Returns:

True if state and mergees set successfully.

setStateInitReconfiguration

public boolean setStateInitReconfiguration(java.lang.String name,
                                           int epoch,
                                           ReconfigurationRecord.RCStates state,
                                           java.util.Set<NodeIDType> newActives)

Description copied from interface: ReconfiguratorDB

Set epoch, state, newActives, primary only if current state is READY

Specified by:

setStateInitReconfiguration in interface ReconfiguratorDB<NodeIDType>

Returns:

True if successfully set; false if the state transition is not legitimate.

printRCTable

protected void printRCTable()

getRCTableString

protected java.lang.String getRCTableString()

deleteReconfigurationRecord

public boolean deleteReconfigurationRecord(java.lang.String name,
                                           int epoch)

Specified by:

deleteReconfigurationRecord in interface ReconfiguratorDB<NodeIDType>

Returns:

True if record existed and was successfully deleted.

markDeleteReconfigurationRecord

public boolean markDeleteReconfigurationRecord(java.lang.String name,
                                               int epoch)

Specified by:

markDeleteReconfigurationRecord in interface ReconfiguratorDB<NodeIDType>

Returns:

True if record existed and was successfully marked as pending a deletion.

createReconfigurationRecord

public ReconfigurationRecord<NodeIDType> createReconfigurationRecord(ReconfigurationRecord<NodeIDType> record)

Specified by:

createReconfigurationRecord in interface ReconfiguratorDB<NodeIDType>

Returns:

ReconfigurationRecord created.

checkpoint

public java.lang.String checkpoint(java.lang.String rcGroup)

Incomplete paxos methods below

Specified by:

checkpoint in interface Replicable

Returns:

Returns the checkpoint state. If the application encounters an error while creating the checkpoint, it must retry until successful or throw a RuntimeException. Returning a null value will be interpreted to mean that the application state is indeed null.

Note that state may simply be an app-specific handle, e.g., a file name, representing the state as opposed to the actual state. The application is responsible for interpreting the state returned by Replicable.checkpoint(String) and that supplied in Replicable.restore(String, String) in a consistent manner.

restore

public boolean restore(java.lang.String rcGroup,
                       java.lang.String state)

Description copied from interface: Replicable

Resets the current application state for name to state.

Note that state may simply be an app-specific handle, e.g., a file name, representing the state as opposed to the actual state. The application is responsible for interpreting the state returned by Replicable.checkpoint(String) and that supplied in Replicable.restore(String, String) in a consistent manner.

Specified by:

restore in interface Replicable

Returns:

True if the app atomically updated the state successfully. Else, it must throw an exception. If it returns false, the replica coordination protocol may try to repeat the operation until successful causing the application to get stuck.

getDemandStats

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

Specified by:

getDemandStats in interface ReconfiguratorDB<NodeIDType>

Returns:

Demand statistics as JSON string.

getPendingReconfigurations

public java.lang.String[] getPendingReconfigurations()

Description copied from interface: ReconfiguratorDB

Names for which reconfiguration is incomplete, needed for recovery

Specified by:

getPendingReconfigurations in interface ReconfiguratorDB<NodeIDType>

Returns:

Array of names.

removePending

public void removePending(java.lang.String name)

Specified by:

removePending in interface ReconfiguratorDB<NodeIDType>

getNodeConfigRecords

protected java.lang.String getNodeConfigRecords(ConsistentReconfigurableNodeConfig<NodeIDType> nc)

fetchAndAggregateMergeeStates

public java.lang.String fetchAndAggregateMergeeStates(java.util.Map<java.lang.String,java.lang.String> finalStates,
                                                      java.lang.String mergerGroup,
                                                      int mergerGroupEpoch)

Specified by:

fetchAndAggregateMergeeStates in interface ReconfiguratorDB<NodeIDType>

Parameters:

finalStates -

mergerGroup -

mergerGroupEpoch -

Returns:

Merged checkpoint filename.

getRCGroups

public java.util.Map<java.lang.String,java.util.Set<NodeIDType>> getRCGroups()

Description copied from interface: ReconfiguratorDB

Get current RC group names from the DB

Specified by:

getRCGroups in interface ReconfiguratorDB<NodeIDType>

Returns:

Map of RC group names and their group members.

getRCGroupNames

public java.util.Set<java.lang.String> getRCGroupNames()

Specified by:

getRCGroupNames in interface ReconfiguratorDB<NodeIDType>

Returns:

Set of all RC group names maintained locally.

close

public void close()

Description copied from interface: ReconfiguratorDB

Close gracefully.

Specified by:

close in interface ReconfiguratorDB<NodeIDType>

toString

public java.lang.String toString()

Overrides:

toString in class AbstractReconfiguratorDB<NodeIDType>

addActiveReplica

public boolean addActiveReplica(NodeIDType node,
                                java.net.InetSocketAddress sockAddr,
                                int version)

Specified by:

addActiveReplica in interface ReconfiguratorDB<NodeIDType>

Returns:

True if successfully added.

addReconfigurator

public boolean addReconfigurator(NodeIDType node,
                                 java.net.InetSocketAddress sockAddr,
                                 int version)

Specified by:

addReconfigurator in interface ReconfiguratorDB<NodeIDType>

Returns:

True if successfully added.

garbageCollectOldReconfigurators

public boolean garbageCollectOldReconfigurators(int version)

Specified by:

garbageCollectOldReconfigurators in interface ReconfiguratorDB<NodeIDType>

Returns:

Delete deleted reconfigurators.

mergeState

public boolean mergeState(java.lang.String rcGroupName,
                          int epoch,
                          java.lang.String mergee,
                          int mergeeEpoch,
                          java.lang.String state)

Description copied from interface: ReconfiguratorDB

Merge state, i.e., append instead of replacing state, exactly once. The tricky part is to ensure exactly-once semantics, which we ensure by maintaining a "merged" set in ReconfigurationRecord.

Specified by:

mergeState in interface ReconfiguratorDB<NodeIDType>

Returns:

True if merged successfully.

clearMerged

public void clearMerged(java.lang.String rcGroupName,
                        int epoch)

Description copied from interface: ReconfiguratorDB

Clear all merged state in RC record. Invoked when a stop request is executed just before transitioning to the next epoch.

Specified by:

clearMerged in interface ReconfiguratorDB<NodeIDType>

setRCEpochs

public void setRCEpochs(ReconfigurationRecord<NodeIDType> ncRecord)

Description copied from interface: ReconfiguratorDB

Sets RC epochs so that we know the epoch numbers for each reconfigurator group.

Specified by:

setRCEpochs in interface ReconfiguratorDB<NodeIDType>

mergeIntent

public boolean mergeIntent(java.lang.String name,
                           int epoch,
                           java.lang.String mergee)

Specified by:

mergeIntent in interface ReconfiguratorDB<NodeIDType>

Returns:

True if intent committed successfully.

delayedDeleteComplete

public void delayedDeleteComplete()

Specified by:

delayedDeleteComplete in interface ReconfiguratorDB<NodeIDType>

garbageCollectedDeletedNode

public void garbageCollectedDeletedNode(NodeIDType node)

Specified by:

garbageCollectedDeletedNode in interface ReconfiguratorDB<NodeIDType>

createReconfigurationRecords

public boolean createReconfigurationRecords(java.util.Map<java.lang.String,java.lang.String> nameStates,
                                            java.util.Set<NodeIDType> newActives,
                                            ReconfigurationConfig.ReconfigureUponActivesChange policy)

Specified by:

createReconfigurationRecords in interface ReconfiguratorDB<NodeIDType>

Returns:

True if created successfully.

setStateInitReconfiguration

public boolean setStateInitReconfiguration(java.util.Map<java.lang.String,java.lang.String> nameStates,
                                           int epoch,
                                           ReconfigurationRecord.RCStates state,
                                           java.util.Set<NodeIDType> newActives)

Specified by:

setStateInitReconfiguration in interface ReconfiguratorDB<NodeIDType>

Returns:

True if successfully set; false if any of the constituent state transitions are not legitimate.

setStateMerge

public boolean setStateMerge(java.util.Map<java.lang.String,java.lang.String> nameStates,
                             int epoch,
                             ReconfigurationRecord.RCStates state,
                             java.util.Set<NodeIDType> newActives)

Specified by:

setStateMerge in interface ReconfiguratorDB<NodeIDType>

Returns:

True is state set successfully.

initiateReadActiveRecords

public boolean initiateReadActiveRecords(NodeIDType active)

Specified by:

initiateReadActiveRecords in interface ReconfiguratorDB<NodeIDType>

Returns:

Whether successfully opened.

readNextActiveRecord

public ReconfigurationRecord<NodeIDType> readNextActiveRecord(boolean add)

Specified by:

readNextActiveRecord in interface ReconfiguratorDB<NodeIDType>

Returns:

Next name

closeReadActiveRecords

public boolean closeReadActiveRecords()

Specified by:

closeReadActiveRecords in interface ReconfiguratorDB<NodeIDType>

Returns:

Whether successfully closed.

main

public static void main(java.lang.String[] args)

Parameters:

args -