edu.umass.cs.reconfiguration.reconfigurationprotocoltasks

Class WaitAckStopEpoch<NodeIDType>

java.lang.Object

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

edu.umass.cs.reconfiguration.reconfigurationprotocoltasks.WaitAckStopEpoch<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>

Direct Known Subclasses:

WaitPrimaryExecution

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

Author:

V. Arun

Field Summary

Fields

Modifier and Type	Field and Description
protected RepliconfigurableReconfiguratorDB<NodeIDType>	DB
protected static java.util.logging.Logger	log
static long	RESTART_PERIOD Retransmission timeout.
protected int	restartCount
StartEpoch<NodeIDType>	startEpoch
static ReconfigurationPacket.PacketType[]	types Packet types handled.

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

waitfor

Constructor Summary

Constructors

Constructor and Description
WaitAckStopEpoch(StartEpoch<NodeIDType> startEpoch, RepliconfigurableReconfiguratorDB<NodeIDType> DB)
WaitAckStopEpoch(StartEpoch<NodeIDType> startEpoch, RepliconfigurableReconfiguratorDB<NodeIDType> DB, java.lang.Object monitor)

Method Summary

Modifier and Type	Method and Description
protected boolean	amObviated()
java.util.Set<ReconfigurationPacket.PacketType>	getEventTypes()
java.lang.String	getFinalState()
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.
java.lang.String	refreshKey() Note: Trying to start this task when one is already running will cause the executor to get stuck.
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

RESTART_PERIOD

public static final long RESTART_PERIOD

Retransmission timeout. The restart periods for most other reconfiguration protocol tasks are multiples of this, so it should be changed with care.

startEpoch

public final StartEpoch<NodeIDType> startEpoch

DB

protected final RepliconfigurableReconfiguratorDB<NodeIDType> DB

restartCount

protected int restartCount

log

protected static final java.util.logging.Logger log

types

public static final ReconfigurationPacket.PacketType[] types

Packet types handled.

Constructor Detail

WaitAckStopEpoch

public WaitAckStopEpoch(StartEpoch<NodeIDType> startEpoch,
                        RepliconfigurableReconfiguratorDB<NodeIDType> DB,
                        java.lang.Object monitor)

Parameters:

startEpoch -

DB -

monitor -

WaitAckStopEpoch

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

Parameters:

startEpoch -

DB -

Method Detail

restart

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

Returns:

The messaging task upon each restart.

amObviated

protected boolean amObviated()

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()

Note: Trying to start this task when one is already running will cause the executor to get stuck.

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

getFinalState

public java.lang.String getFinalState()

Returns:

Retrieved final state if any of stopped epoch.

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object