edu.umass.cs.reconfiguration

Class ReconfigurableNode<NodeIDType>

java.lang.Object

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

Type Parameters:

NodeIDType - A generic type for representing node identifiers. It must support an explicitly overridden toString() method that converts NodeIDType to String, and the NodeConfig object supplied to this class' constructor must support a valueOf(String) method that returns back the original NodeIDType. Thus, even though NodeIDType is generic, a one-to-one mapping between NodeIDType and String is necessary.

Direct Known Subclasses:

NoopReconfigurableNode, ReconfigurableNode.DefaultReconfigurableNode

public abstract class ReconfigurableNode<NodeIDType>
extends java.lang.Object

Author:

V. Arun

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	ReconfigurableNode.DefaultReconfigurableNode

Field Summary

Fields

Modifier and Type	Field and Description
protected JSONMessenger<NodeIDType>	messenger
protected NodeIDType	myID
protected ReconfigurableNodeConfig<NodeIDType>	nodeConfig

Constructor Summary

Constructors

Constructor and Description
ReconfigurableNode(NodeIDType id, ReconfigurableNodeConfig<NodeIDType> nodeConfig)
ReconfigurableNode(NodeIDType id, ReconfigurableNodeConfig<NodeIDType> nodeConfig, java.lang.String[] args, boolean startCleanSlate)

Method Summary

Modifier and Type	Method and Description
void	close() Close gracefully.
protected abstract AbstractReplicaCoordinator<NodeIDType>	createAppCoordinator()
static void	forceClear(java.lang.String server) For testing.
java.lang.String	getMyID()
static void	main(java.lang.String[] args) args contains a list of app arguments followed by a list of active or reconfigurator node IDs at the end.
static void	stopServer(java.lang.String server)
java.lang.String	toString()

Methods inherited from class java.lang.Object

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

Field Detail

myID

protected final NodeIDType myID

nodeConfig

protected final ReconfigurableNodeConfig<NodeIDType> nodeConfig

messenger

protected final JSONMessenger<NodeIDType> messenger

Constructor Detail

ReconfigurableNode

public ReconfigurableNode(NodeIDType id,
                          ReconfigurableNodeConfig<NodeIDType> nodeConfig)
                   throws java.io.IOException

Parameters:

id -

nodeConfig -

Throws:

java.io.IOException

ReconfigurableNode

public ReconfigurableNode(NodeIDType id,
                          ReconfigurableNodeConfig<NodeIDType> nodeConfig,
                          java.lang.String[] args,
                          boolean startCleanSlate)
                   throws java.io.IOException

Parameters:

id - Node ID of this ReconfigurableNode being created.

nodeConfig - Maps node IDs of active replicas and reconfigurators to their socket addresses.

args -

startCleanSlate - Used to join newly added nodes.

Throws:

java.io.IOException - Thrown if networking functions can not be successfully initialized. A common reason for this exception is that the socket addresses corresponding to the supplied 'id' argument are not local, i.e., the node with this id should not be created on this machine in the first place, or if the id is not present at all in the supplied 'nodeConfig' argument.

Method Detail

createAppCoordinator

protected abstract AbstractReplicaCoordinator<NodeIDType> createAppCoordinator()

close

public void close()

Close gracefully.

forceClear

public static void forceClear(java.lang.String server)

For testing. Only a server that has been started from within this JVM can be closed and force-cleared using this method.

Parameters:

server -

stopServer

public static void stopServer(java.lang.String server)

Parameters:

server -

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object

getMyID

public java.lang.String getMyID()

Returns:

String ID

main

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

args contains a list of app arguments followed by a list of active or reconfigurator node IDs at the end. The string "start all" is accepted as a proxy for the list of all nodes if the socket addresses of all nodes are on the local machine.

Parameters:

args -

Throws:

java.io.IOException