org.apache.reef.io.network.group.impl.driver

Class TaskNodeStatusImpl

java.lang.Object

org.apache.reef.io.network.group.impl.driver.TaskNodeStatusImpl

All Implemented Interfaces:

TaskNodeStatus

public class TaskNodeStatusImpl
extends Object
implements TaskNodeStatus

Constructor Summary

Constructors

Constructor and Description
TaskNodeStatusImpl(Class<? extends Name<String>> groupName, Class<? extends Name<String>> operName, String taskId, TaskNode node)

Method Summary

Methods

Modifier and Type	Method and Description
void	clearStateAndReleaseLocks() Used when the task has failed to clear all the state that is associated with this task Also should release the locks held for implementing the convenience wait* methods
void	expectAckFor(ReefNetworkGroupCommProtos.GroupCommMessage.Type msgType, String srcId) This needs to happen in line rather than in a stage because we need to note the messages we send to the tasks before we start processing msgs from the nodes.(Acks & Topology msgs)
boolean	hasChanges()
boolean	isActive(String neighborId)
void	onTopologySetupMessageSent()
void	processAcknowledgement(GroupCommunicationMessage gcm) Process the msg that was received and update state accordingly
void	updateFailureOf(String taskId) This should remove state concerning neighboring tasks that have failed
void	updatingTopology() Called to denote that a UpdateTopology msg will be sent
void	waitForTopologySetup()

Methods inherited from class java.lang.Object

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

Constructor Detail

TaskNodeStatusImpl

public TaskNodeStatusImpl(Class<? extends Name<String>> groupName,
                  Class<? extends Name<String>> operName,
                  String taskId,
                  TaskNode node)

Method Detail

onTopologySetupMessageSent

public void onTopologySetupMessageSent()

Specified by:

onTopologySetupMessageSent in interface TaskNodeStatus

isActive

public boolean isActive(String neighborId)

Specified by:

isActive in interface TaskNodeStatus

expectAckFor

public void expectAckFor(ReefNetworkGroupCommProtos.GroupCommMessage.Type msgType,
                String srcId)

This needs to happen in line rather than in a stage because we need to note the messages we send to the tasks before we start processing msgs from the nodes.(Acks & Topology msgs)

Specified by:

expectAckFor in interface TaskNodeStatus

clearStateAndReleaseLocks

public void clearStateAndReleaseLocks()

Description copied from interface: TaskNodeStatus

Used when the task has failed to clear all the state that is associated with this task Also should release the locks held for implementing the convenience wait* methods

Specified by:

clearStateAndReleaseLocks in interface TaskNodeStatus

updateFailureOf

public void updateFailureOf(String taskId)

Description copied from interface: TaskNodeStatus

This should remove state concerning neighboring tasks that have failed

Specified by:

updateFailureOf in interface TaskNodeStatus

processAcknowledgement

public void processAcknowledgement(GroupCommunicationMessage gcm)

Description copied from interface: TaskNodeStatus

Process the msg that was received and update state accordingly

Specified by:

processAcknowledgement in interface TaskNodeStatus

updatingTopology

public void updatingTopology()

Description copied from interface: TaskNodeStatus

Called to denote that a UpdateTopology msg will be sent

Specified by:

updatingTopology in interface TaskNodeStatus

hasChanges

public boolean hasChanges()

Specified by:

hasChanges in interface TaskNodeStatus

waitForTopologySetup

public void waitForTopologySetup()

Specified by:

waitForTopologySetup in interface TaskNodeStatus