edu.umass.cs.protocoltask.examples.thresholdfetch

Class MajorityFetchProtocolTask

java.lang.Object

edu.umass.cs.protocoltask.ThresholdProtocolTask<java.lang.Integer,PingPongPacket.PacketType,java.lang.String>

edu.umass.cs.protocoltask.examples.thresholdfetch.MajorityFetchProtocolTask

All Implemented Interfaces:

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

public class MajorityFetchProtocolTask
extends ThresholdProtocolTask<java.lang.Integer,PingPongPacket.PacketType,java.lang.String>

Field Summary

Fields inherited from class edu.umass.cs.protocoltask.ThresholdProtocolTask

waitfor

Constructor Summary

Constructors

Constructor and Description
MajorityFetchProtocolTask(int id, java.util.Set<java.lang.Integer> nodes)

Method Summary

Modifier and Type	Method and Description
java.util.Set<PingPongPacket.PacketType>	getEventTypes()
java.lang.String	getKey() Start of overridden methods
boolean	handleEvent(ProtocolEvent<PingPongPacket.PacketType,java.lang.String> event)
GenericMessagingTask<java.lang.Integer,?>[]	handleThresholdEvent(ProtocolTask<java.lang.Integer,PingPongPacket.PacketType,java.lang.String>[] ptasks) Default action is to cancel the protocol task when the threshold is reached.
static void	main(java.lang.String[] args)
java.lang.String	refreshKey()
MessagingTask[]	restart()
MessagingTask[]	start() Actions executed in the beginning.

Methods inherited from class edu.umass.cs.protocoltask.ThresholdProtocolTask

fix, getPeriod, handleEvent, setPeriod

Methods inherited from class java.lang.Object

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

Constructor Detail

MajorityFetchProtocolTask

public MajorityFetchProtocolTask(int id,
                                 java.util.Set<java.lang.Integer> nodes)

Method Detail

getKey

public java.lang.String getKey()

Start of overridden methods

Returns:

The key.

refreshKey

public java.lang.String refreshKey()

handleEvent

public boolean handleEvent(ProtocolEvent<PingPongPacket.PacketType,java.lang.String> event)

Specified by:

handleEvent in class ThresholdProtocolTask<java.lang.Integer,PingPongPacket.PacketType,java.lang.String>

Returns:

Return value indicates if the event is a valid response.

start

public MessagingTask[] start()

Description copied from interface: ProtocolTask

Actions executed in the beginning.

Returns:

Initial messaging task.

handleThresholdEvent

public GenericMessagingTask<java.lang.Integer,?>[] handleThresholdEvent(ProtocolTask<java.lang.Integer,PingPongPacket.PacketType,java.lang.String>[] ptasks)

Description copied from class: ThresholdProtocolTask

Default action is to cancel the protocol task when the threshold is reached.

Overrides:

handleThresholdEvent in class ThresholdProtocolTask<java.lang.Integer,PingPongPacket.PacketType,java.lang.String>

Returns:

Returns messaging tasks to be performed when the threshold is reached. Additional protocol task actions may also be spawned via ptasks[0].

restart

public MessagingTask[] restart()

Returns:

The messaging task upon each restart.

main

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

Parameters:

args -

getEventTypes

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

Returns:

The event types processed by this protocol task.