edu.umass.cs.reconfiguration.reconfigurationutils

Class ReconfigurationRecord<NodeIDType>

java.lang.Object

org.json.JSONObject

edu.umass.cs.reconfiguration.reconfigurationutils.ReconfigurationRecord<NodeIDType>

Type Parameters:

NodeIDType -

public class ReconfigurationRecord<NodeIDType>
extends org.json.JSONObject

Author:

V. Arun

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
protected static class	ReconfigurationRecord.Keys
static class	ReconfigurationRecord.RCStates RC record states.

Field Summary

Fields inherited from class org.json.JSONObject

NULL, reasonableFieldSize

Constructor Summary

Constructors

Constructor and Description
ReconfigurationRecord(org.json.JSONObject json, Stringifiable<NodeIDType> unstringer)
ReconfigurationRecord(java.lang.String name, int epoch, java.util.Set<NodeIDType> newActives)
ReconfigurationRecord(java.lang.String name, int epoch, java.util.Set<NodeIDType> newActives, ReconfigurationConfig.ReconfigureUponActivesChange policy)
ReconfigurationRecord(java.lang.String name, int epoch, java.util.Set<NodeIDType> actives, java.util.Set<NodeIDType> newActives, ReconfigurationConfig.ReconfigureUponActivesChange policy)

Method Summary

Modifier and Type	Method and Description
boolean	addToMerge(java.lang.String s)
boolean	areMergesAllDone()
void	clearMerged()
boolean	clearMerged(java.lang.String mergee)
java.util.Set<NodeIDType>	getActiveReplicas()
java.util.Set<NodeIDType>	getActiveReplicas(java.lang.String name, int epoch)
long	getDeleteTime()
int	getEpoch()
java.lang.String	getName()
java.util.Set<NodeIDType>	getNewActives()
java.lang.Integer	getRCEpoch(NodeIDType rcGroupName)
java.lang.Integer	getRCEpoch(java.lang.String rcGroupName) To get the RC epoch upon a node config change completion.
java.lang.String	getRCGroupName()
ReconfigurationConfig.ReconfigureUponActivesChange	getReconfigureUponActivesChangePolicy()
ReconfigurationRecord.RCStates	getState()
java.lang.String	getSummary()
int	getUnclean()
boolean	hasBeenMerged(java.util.Set<java.lang.String> mergees)
boolean	hasBeenMerged(java.lang.String s)
boolean	incrEpoch(int epoch)
boolean	insertMerged(java.lang.String s)
boolean	isDeletable()
boolean	isDeletePending()
boolean	isReady()
boolean	isReconfigurationReady()
ReconfigurationRecord<NodeIDType>	putActiveReplicas(java.lang.String name, int epoch, java.util.Set<NodeIDType> arSet)
void	setActivesToNewActives()
void	setActivesToNewActives(java.util.Set<NodeIDType> newActives)
boolean	setDropPreviousEpochCompleted()
boolean	setEpoch(int epoch)
void	setRCEpochs(java.util.Set<NodeIDType> affectedRCs, java.util.Set<NodeIDType> addNodes, java.util.Set<NodeIDType> deleteNodes)
ReconfigurationRecord<NodeIDType>	setRCGroupName(java.lang.String groupName)
ReconfigurationRecord<NodeIDType>	setState(java.lang.String name, int epoch, ReconfigurationRecord.RCStates state)
void	setState(java.lang.String name, int epoch, ReconfigurationRecord.RCStates state, java.util.Set<NodeIDType> newActives)
void	setStateMerge(java.lang.String name, int epoch, ReconfigurationRecord.RCStates state, java.util.Set<java.lang.String> mergees)
org.json.JSONObject	toJSONObject()
boolean	toMergeContains(java.lang.String s)
java.lang.String	toString() Make a JSON text of this JSONObject.
void	trimRCEpochs() Needed to trim the rcEpochs map when reconfigurator nodes get deleted.
boolean	updateStats(DemandReport<NodeIDType> report)

Methods inherited from class org.json.JSONObject

accumulate, append, doubleToString, ellipsize, get, getBoolean, getDouble, getInt, getJSONArray, getJSONObject, getLong, getNames, getNames, getString, has, increment, isNull, keys, length, names, numberToString, opt, optBoolean, optBoolean, optDouble, optDouble, optInt, optInt, optJSONArray, optJSONObject, optLong, optLong, optString, optString, put, put, put, put, put, put, put, putOnce, putOpt, quote, remove, stringToValue, testValidity, toJSONArray, toReasonableString, toString, valueToReasonableString, valueToString, wrap, write

Methods inherited from class java.lang.Object

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

Constructor Detail

ReconfigurationRecord

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

Parameters:

name -

epoch -

newActives -

ReconfigurationRecord

public ReconfigurationRecord(java.lang.String name,
                             int epoch,
                             java.util.Set<NodeIDType> newActives,
                             ReconfigurationConfig.ReconfigureUponActivesChange policy)

Parameters:

name -

epoch -

newActives -

policy -

ReconfigurationRecord

public ReconfigurationRecord(java.lang.String name,
                             int epoch,
                             java.util.Set<NodeIDType> actives,
                             java.util.Set<NodeIDType> newActives,
                             ReconfigurationConfig.ReconfigureUponActivesChange policy)

Parameters:

name -

epoch -

actives -

newActives -

policy -

ReconfigurationRecord

public ReconfigurationRecord(org.json.JSONObject json,
                             Stringifiable<NodeIDType> unstringer)
                      throws org.json.JSONException

Parameters:

json -

unstringer -

Throws:

org.json.JSONException

Method Detail

toJSONObject

public org.json.JSONObject toJSONObject()
                                 throws org.json.JSONException

Returns:

JSON serialization of this object.

Throws:

org.json.JSONException

toString

public java.lang.String toString()

Description copied from class: org.json.JSONObject

Make a JSON text of this JSONObject. For compactness, no whitespace is added. If this would not result in a syntactically correct JSON text, then null will be returned instead.

Warning: This method assumes that the data structure is acyclical.

Overrides:

toString in class org.json.JSONObject

Returns:

a printable, displayable, portable, transmittable representation of the object, beginning with { (left brace) and ending with } (right brace).

getEpoch

public int getEpoch()

Returns:

Current epoch number.

setEpoch

public boolean setEpoch(int epoch)

Parameters:

epoch -

Returns:

Whether epoch number changed.

incrEpoch

public boolean incrEpoch(int epoch)

Parameters:

epoch -

Returns:

Whether epoch number was incremented.

getActiveReplicas

public java.util.Set<NodeIDType> getActiveReplicas(java.lang.String name,
                                                   int epoch)

Parameters:

name -

epoch -

Returns:

Set of active replicas for name:epoch

getActiveReplicas

public java.util.Set<NodeIDType> getActiveReplicas()

Returns:

Set of current active replicas. Will return null if this record is pending a delete, will return newActives if it is awaiting the start of the next epoch, and the current actives otherwise.

putActiveReplicas

public ReconfigurationRecord<NodeIDType> putActiveReplicas(java.lang.String name,
                                                           int epoch,
                                                           java.util.Set<NodeIDType> arSet)

Parameters:

name -

epoch -

arSet -

Returns:

Returns this ReconfigurationRecord after modification.

getState

public ReconfigurationRecord.RCStates getState()

Returns:

RCStates.

isReady

public boolean isReady()

Returns:

True if ready for the next epoch (but may not have dropped previous epoch final state yet).

isReconfigurationReady

public boolean isReconfigurationReady()

Returns:

True if the new active replica group is ready and aggressive reconfigurations are allowed or the previous epoch final state has been completely dropped (a stronger condition), and in either case, merges are all done.

setActivesToNewActives

public void setActivesToNewActives(java.util.Set<NodeIDType> newActives)

Parameters:

newActives -

setActivesToNewActives

public void setActivesToNewActives()

getNewActives

public java.util.Set<NodeIDType> getNewActives()

Returns:

Set of new active replicas.

insertMerged

public boolean insertMerged(java.lang.String s)

Parameters:

s -

Returns:

Whether the string being added was already present,.

addToMerge

public boolean addToMerge(java.lang.String s)

Parameters:

s -

Returns:

Whether the string being added was already present.

clearMerged

public void clearMerged()

clearMerged

public boolean clearMerged(java.lang.String mergee)

Parameters:

mergee -

Returns:

If mergee was removed.

hasBeenMerged

public boolean hasBeenMerged(java.lang.String s)

Parameters:

s -

Returns:

True if contains s.

hasBeenMerged

public boolean hasBeenMerged(java.util.Set<java.lang.String> mergees)

Parameters:

mergees -

Returns:

True if contains all mergees.

areMergesAllDone

public boolean areMergesAllDone()

Returns:

True if all merges are done.

toMergeContains

public boolean toMergeContains(java.lang.String s)

Parameters:

s -

Returns:

True is toMerge contains s.

isDeletePending

public boolean isDeletePending()

Returns:

True if this record is pending a delete.

updateStats

public boolean updateStats(DemandReport<NodeIDType> report)

Parameters:

report -

Returns:

Whether stats were updated successfully,

setDropPreviousEpochCompleted

public boolean setDropPreviousEpochCompleted()

Returns:

True if reset to 0.

setState

public ReconfigurationRecord<NodeIDType> setState(java.lang.String name,
                                                  int epoch,
                                                  ReconfigurationRecord.RCStates state)

Parameters:

name -

epoch -

state -

Returns:

this

setStateMerge

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

Parameters:

name -

epoch -

state -

mergees -

isDeletable

public boolean isDeletable()

Returns:

True if it can be safely deleted.

getUnclean

public int getUnclean()

Returns:

Number of unclean reconfigurations.

setState

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

Parameters:

name -

epoch -

state -

newActives -

getName

public java.lang.String getName()

Returns:

Nale of replica group.

getRCEpoch

public java.lang.Integer getRCEpoch(java.lang.String rcGroupName)

To get the RC epoch upon a node config change completion. Used only when reconfiguring reconfigurators.

Parameters:

rcGroupName -

Returns:

The epoch number for the reconfigurator group name.

getRCEpoch

public java.lang.Integer getRCEpoch(NodeIDType rcGroupName)

Parameters:

rcGroupName -

Returns:

The epoch number for the reconfigurator group name. Inserts default of 0 if no entry found, which can only happen if the inserted value before a crash was not checkpointed.

setRCEpochs

public void setRCEpochs(java.util.Set<NodeIDType> affectedRCs,
                        java.util.Set<NodeIDType> addNodes,
                        java.util.Set<NodeIDType> deleteNodes)

Parameters:

affectedRCs -

addNodes -

deleteNodes -

trimRCEpochs

public void trimRCEpochs()

Needed to trim the rcEpochs map when reconfigurator nodes get deleted.

getDeleteTime

public long getDeleteTime()

Returns:

The time when the state was changed to WAIT_DELETE.

setRCGroupName

public ReconfigurationRecord<NodeIDType> setRCGroupName(java.lang.String groupName)

Parameters:

groupName -

Returns:

this

getRCGroupName

public java.lang.String getRCGroupName()

Returns:

RC group name to which this record currently belongs.

getSummary

public java.lang.String getSummary()

Returns:

For instrumentation purposes.

getReconfigureUponActivesChangePolicy

public ReconfigurationConfig.ReconfigureUponActivesChange getReconfigureUponActivesChangePolicy()

Returns:

ReconfigureUponActivesChange policy.