edu.umass.cs.reconfiguration.reconfigurationprotocoltasks

Class ActiveReplicaProtocolTask<NodeIDType>

java.lang.Object

edu.umass.cs.reconfiguration.reconfigurationprotocoltasks.ActiveReplicaProtocolTask<NodeIDType>

Type Parameters:

NodeIDType -

All Implemented Interfaces:

ProtocolTask<NodeIDType,ReconfigurationPacket.PacketType,java.lang.String>, Keyable<java.lang.String>

public class ActiveReplicaProtocolTask<NodeIDType>
extends java.lang.Object
implements ProtocolTask<NodeIDType,ReconfigurationPacket.PacketType,java.lang.String>

Author:

V. Arun

Constructor Summary

Constructors

Constructor and Description
ActiveReplicaProtocolTask(NodeIDType id, Stringifiable<NodeIDType> unstringer, ActiveReplica<NodeIDType> ar)

Method Summary

Modifier and Type	Method and Description
java.util.Set<ReconfigurationPacket.PacketType>	getDefaultTypes()
java.util.Set<ReconfigurationPacket.PacketType>	getEventTypes()
java.lang.String	getKey()
BasicReconfigurationPacket<NodeIDType>	getReconfigurationPacket(org.json.JSONObject json)
GenericMessagingTask<NodeIDType,?>[]	handleEvent(ProtocolEvent<ReconfigurationPacket.PacketType,java.lang.String> event, ProtocolTask<NodeIDType,ReconfigurationPacket.PacketType,java.lang.String>[] ptasks) The action handling the event may return messaging tasks that will be automatically handled by this interface.
java.lang.String	refreshKey()
GenericMessagingTask<NodeIDType,?>[]	start() Actions executed in the beginning.

Methods inherited from class java.lang.Object

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

Constructor Detail

ActiveReplicaProtocolTask

public ActiveReplicaProtocolTask(NodeIDType id,
                                 Stringifiable<NodeIDType> unstringer,
                                 ActiveReplica<NodeIDType> ar)

Parameters:

id -

unstringer -

ar -

Method Detail

getKey

public java.lang.String getKey()

Specified by:

getKey in interface Keyable<java.lang.String>

Returns:

The key.

start

public GenericMessagingTask<NodeIDType,?>[] start()

Description copied from interface: ProtocolTask

Actions executed in the beginning.

Specified by:

start in interface ProtocolTask<NodeIDType,ReconfigurationPacket.PacketType,java.lang.String>

Returns:

Initial messaging task.

refreshKey

public java.lang.String refreshKey()

Returns:

The refreshed key.

getEventTypes

public java.util.Set<ReconfigurationPacket.PacketType> getEventTypes()

Specified by:

getEventTypes in interface ProtocolTask<NodeIDType,ReconfigurationPacket.PacketType,java.lang.String>

Returns:

The event types processed by this protocol task.

getDefaultTypes

public java.util.Set<ReconfigurationPacket.PacketType> getDefaultTypes()

Returns:

Default packet types handled, i.e., not counting temporary protocol tasks.

handleEvent

public GenericMessagingTask<NodeIDType,?>[] handleEvent(ProtocolEvent<ReconfigurationPacket.PacketType,java.lang.String> event,
                                                        ProtocolTask<NodeIDType,ReconfigurationPacket.PacketType,java.lang.String>[] ptasks)

Description copied from interface: ProtocolTask

The action handling the event may return messaging tasks that will be automatically handled by this interface. This interface lets the protocol developer focus on event/action pairs without worrying about networking or scheduling optimizations. The parameter ptasks[0] returns a single protocol task if any spawned by this action. We need a unique key ***that is unique across all nodes*** in order to match incoming messages against the corresponding task. ProtocolExecutor automatically inserts this key in every message exchanged as part of the protocol task. The getKey method is necessitated by the Keyable interface in this class. A simple way to choose a String key that is unique across all nodes at a node is to use the current node's ID concatenated with a random number and/or the current time. A protocol task can also explicitly choose meaningful (i.e., not random or based on timestamps) names for tasks, but they still need to be unique across all nodes. Refer to the examples provided with the protocoltask package. A protocol task can be canceled from within the task, if necessary, by invoking ProtocolExecutor.cancel(this). But you probably have a bad design if you need to rely on this.

Specified by:

handleEvent in interface ProtocolTask<NodeIDType,ReconfigurationPacket.PacketType,java.lang.String>

Returns:

Returns messaging tasks to be performed.

getReconfigurationPacket

public BasicReconfigurationPacket<NodeIDType> getReconfigurationPacket(org.json.JSONObject json)
                                                                throws org.json.JSONException

Parameters:

json -

Returns:

BasicReconfigurationPacket generated via reflection from JSON.

Throws:

org.json.JSONException