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.
void	expectAckFor(ReefNetworkGroupCommProtos.GroupCommMessage.Type msgType, String srcId) This needs to happen in line rather than in a stage because we need to note.
boolean	hasChanges()
boolean	isActive(String neighborId)
void	onTopologySetupMessageSent()
void	processAcknowledgement(GroupCommunicationMessage gcm) Process the msg that was received and update.
void	updateFailureOf(String failTaskId) This should remove state concerning neighboring tasks.
void	updatingTopology() Called to denote that a UpdateTopology msg will.
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 and 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 failTaskId)

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