edu.umass.cs.reconfiguration.reconfigurationprotocoltasks

Class WaitEpochFinalState<NodeIDType>

java.lang.Object

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

edu.umass.cs.reconfiguration.reconfigurationprotocoltasks.WaitEpochFinalState<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 WaitEpochFinalState<NodeIDType>
extends ThresholdProtocolTask<NodeIDType,ReconfigurationPacket.PacketType,java.lang.String>

Author:

V. Arun

Field Summary

Fields

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

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

waitfor

Constructor Summary

Constructors

Constructor and Description
WaitEpochFinalState(NodeIDType myID, StartEpoch<NodeIDType> startEpoch, AbstractReplicaCoordinator<NodeIDType> appCoordinator)

Method Summary

Modifier and Type	Method and Description
java.lang.String	addNotifiee(NodeIDType node, java.lang.String key)
GenericMessagingTask<NodeIDType,?>[]	getAckStarts()
java.util.Set<ReconfigurationPacket.PacketType>	getEventTypes()
java.lang.String	getKey()
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.
boolean	isDone()
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, getPeriod, handleEvent, setPeriod

Methods inherited from class java.lang.Object

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

Field Detail

types

protected static final ReconfigurationPacket.PacketType[] types

Constructor Detail

WaitEpochFinalState

public WaitEpochFinalState(NodeIDType myID,
                           StartEpoch<NodeIDType> startEpoch,
                           AbstractReplicaCoordinator<NodeIDType> appCoordinator)

Parameters:

myID -

startEpoch -

appCoordinator -

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.

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.

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object

addNotifiee

public java.lang.String addNotifiee(NodeIDType node,
                                    java.lang.String key)

Parameters:

node -

key -

Returns:

Node to be notified with AckStartEpoch when epoch final state becomes ready.

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

getAckStarts

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

Returns:

Messaging tasks to be performed to send acks to notifiees.

isDone

public boolean isDone()

Returns:

True if done.