edu.umass.cs.reconfiguration.reconfigurationprotocoltasks

Class ReconfiguratorProtocolTask<NodeIDType>

java.lang.Object

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

Type Parameters:

NodeIDType -

All Implemented Interfaces:

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

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

Author:

V. Arun

Constructor Summary

Constructors

Constructor and Description
ReconfiguratorProtocolTask(NodeIDType id, Reconfigurator<NodeIDType> reconfigurator)

Method Summary

Modifier and Type	Method and Description
static java.lang.Object	autoInvokeMethod(java.lang.Object target, ProtocolEvent<ReconfigurationPacket.PacketType,java.lang.String> event, ProtocolTask<?,ReconfigurationPacket.PacketType,java.lang.String>[] ptasks)
java.util.Set<ReconfigurationPacket.PacketType>	getDefaultTypes()
java.util.Set<ReconfigurationPacket.PacketType>	getEventTypes()
java.lang.String	getKey()
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.
GenericMessagingTask<NodeIDType,?>[]	handleEvent(ProtocolEvent<ReconfigurationPacket.PacketType,java.lang.String> event, ProtocolTask<NodeIDType,ReconfigurationPacket.PacketType,java.lang.String>[] ptasks, Callback<Request,ReconfiguratorRequest> callback)
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

ReconfiguratorProtocolTask

public ReconfiguratorProtocolTask(NodeIDType id,
                                  Reconfigurator<NodeIDType> reconfigurator)

Parameters:

id -

reconfigurator -

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 reconfiguration 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.

handleEvent

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

Parameters:

event -

ptasks -

callback -

Returns:

Messaging task.

autoInvokeMethod

public static java.lang.Object autoInvokeMethod(java.lang.Object target,
                                                ProtocolEvent<ReconfigurationPacket.PacketType,java.lang.String> event,
                                                ProtocolTask<?,ReconfigurationPacket.PacketType,java.lang.String>[] ptasks)

Parameters:

target -

event -

ptasks -

Returns:

Object returned by the packet handler.