edu.umass.cs.reconfiguration.reconfigurationprotocoltasks

Class WaitAckStartEpoch<NodeIDType>

java.lang.Object

edu.umass.cs.protocoltask.ThresholdProtocolTask<NodeIDType,ReconfigurationPacket.PacketType,java.lang.String>

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

Type Parameters:

NodeIDType -

All Implemented Interfaces:

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

public class WaitAckStartEpoch<NodeIDType>
extends ThresholdProtocolTask<NodeIDType,ReconfigurationPacket.PacketType,java.lang.String>

Author:

V. Arun

Field Summary

Fields

Modifier and Type	Field and Description
static ReconfigurationPacket.PacketType[]	types Packet types handled.

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

waitfor

Constructor Summary

Constructors

Constructor and Description
WaitAckStartEpoch(StartEpoch<NodeIDType> startEpoch, RepliconfigurableReconfiguratorDB<NodeIDType> DB)

Method Summary

Modifier and Type	Method and Description
protected boolean	amObviated()
java.util.Set<ReconfigurationPacket.PacketType>	getEventTypes()
java.lang.String	getKey()
long	getPeriod() The current restart period.
boolean	handleEvent(ProtocolEvent<ReconfigurationPacket.PacketType,java.lang.String> event)
GenericMessagingTask<NodeIDType,?>[]	handleThresholdEvent(ProtocolTask<NodeIDType,ReconfigurationPacket.PacketType,java.lang.String>[] ptasks) Default action is to cancel the protocol task when the threshold is reached.
java.lang.String	refreshKey()
GenericMessagingTask<NodeIDType,?>[]	restart()
GenericMessagingTask<NodeIDType,?>[]	start() Actions executed in the beginning.
java.lang.String	toString()

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

fix, handleEvent, setPeriod

Methods inherited from class java.lang.Object

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

Field Detail

types

public static final ReconfigurationPacket.PacketType[] types

Packet types handled.

Constructor Detail

WaitAckStartEpoch

public WaitAckStartEpoch(StartEpoch<NodeIDType> startEpoch,
                         RepliconfigurableReconfiguratorDB<NodeIDType> DB)

Parameters:

startEpoch -

DB -

Method Detail

restart

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

Returns:

The messaging task upon each restart.

start

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

Description copied from interface: ProtocolTask

Actions executed in the beginning.

Returns:

Initial messaging task.

amObviated

protected boolean amObviated()

refreshKey

public java.lang.String refreshKey()

Returns:

The refreshed key.

getEventTypes

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

Returns:

The event types processed by this protocol task.

getKey

public java.lang.String getKey()

Returns:

The key.

handleEvent

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

Specified by:

handleEvent in class ThresholdProtocolTask<NodeIDType,ReconfigurationPacket.PacketType,java.lang.String>

Returns:

Return value indicates if the event is a valid response.

handleThresholdEvent

public GenericMessagingTask<NodeIDType,?>[] handleThresholdEvent(ProtocolTask<NodeIDType,ReconfigurationPacket.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<NodeIDType,ReconfigurationPacket.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].

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object

getPeriod

public long getPeriod()

Description copied from class: ThresholdProtocolTask

The current restart period.

Specified by:

getPeriod in interface SchedulableProtocolTask<NodeIDType,ReconfigurationPacket.PacketType,java.lang.String>

Overrides:

getPeriod in class ThresholdProtocolTask<NodeIDType,ReconfigurationPacket.PacketType,java.lang.String>

Returns:

The restart period.