edu.umass.cs.protocoltask.examples

Class PingPongServer

java.lang.Object

edu.umass.cs.protocoltask.examples.PingPongServer

All Implemented Interfaces:

ProtocolTask<java.lang.Integer,PingPongPacket.PacketType,java.lang.String>, Keyable<java.lang.String>

Direct Known Subclasses:

PingPongProtocolTask

public class PingPongServer
extends java.lang.Object
implements ProtocolTask<java.lang.Integer,PingPongPacket.PacketType,java.lang.String>

Author:

V. Arun

Field Summary

Fields

Modifier and Type	Field and Description
protected java.lang.Integer	myID

Constructor Summary

Constructors

Constructor and Description
PingPongServer(int id)

Method Summary

Modifier and Type	Method and Description
java.util.Set<PingPongPacket.PacketType>	getEventTypes()
java.lang.String	getKey() Start of overridden methods
MessagingTask[]	handleEvent(ProtocolEvent<PingPongPacket.PacketType,java.lang.String> event, ProtocolTask<java.lang.Integer,PingPongPacket.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()
MessagingTask[]	start() Actions executed in the beginning.

Methods inherited from class java.lang.Object

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

Field Detail

myID

protected final java.lang.Integer myID

Constructor Detail

PingPongServer

public PingPongServer(int id)

Method Detail

getKey

public java.lang.String getKey()

Start of overridden methods

Specified by:

getKey in interface Keyable<java.lang.String>

Returns:

The key.

refreshKey

public java.lang.String refreshKey()

handleEvent

public MessagingTask[] handleEvent(ProtocolEvent<PingPongPacket.PacketType,java.lang.String> event,
                                   ProtocolTask<java.lang.Integer,PingPongPacket.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<java.lang.Integer,PingPongPacket.PacketType,java.lang.String>

Returns:

Returns messaging tasks to be performed.

start

public MessagingTask[] start()

Description copied from interface: ProtocolTask

Actions executed in the beginning.

Specified by:

start in interface ProtocolTask<java.lang.Integer,PingPongPacket.PacketType,java.lang.String>

Returns:

Initial messaging task.

getEventTypes

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

Specified by:

getEventTypes in interface ProtocolTask<java.lang.Integer,PingPongPacket.PacketType,java.lang.String>

Returns:

The event types processed by this protocol task.