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

Class TaskNodeImpl

java.lang.Object

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

All Implemented Interfaces:

TaskNode

public class TaskNodeImpl
extends Object
implements TaskNode

Constructor Summary

Constructors

Constructor and Description
TaskNodeImpl(EStage<GroupCommunicationMessage> senderStage, Class<? extends Name<String>> groupName, Class<? extends Name<String>> operatorName, String taskId, String driverId, boolean isRoot)

Method Summary

Methods

Modifier and Type	Method and Description
void	addChild(TaskNode child)
void	checkAndSendTopologySetupMessage() Check if this node is ready for sending.
void	checkAndSendTopologySetupMessageFor(String source) Check if the neighbor node with id source.
boolean	equals(Object obj)
Iterable<TaskNode>	getChildren()
int	getNumberOfChildren()
TaskNode	getParent()
String	getTaskId()
int	getVersion()
boolean	hasChanges()
int	hashCode()
boolean	isNeighborActive(String neighborId)
boolean	isRunning()
void	onChildDead(String childId)
void	onChildRunning(String childId)
void	onFailedTask() * Methods pertaining to my status change ***.
void	onParentDead()
void	onParentRunning() * Methods pertaining to my status change ends ***.
void	onReceiptOfAcknowledgement(GroupCommunicationMessage msg) * Methods pertaining to my neighbors status change ends ***.
void	onRunningTask()
void	removeChild(TaskNode child)
boolean	resetTopologySetupSent() reset topology setup ensures that update topology is not sent to someone.
void	setParent(TaskNode parent)
void	setSibling(TaskNode leaf)
TaskNode	successor()
String	toString()
void	updatingTopology()
void	waitForTopologySetupOrFailure()

Methods inherited from class java.lang.Object

getClass, notify, notifyAll, wait, wait, wait

Constructor Detail

TaskNodeImpl

public TaskNodeImpl(EStage<GroupCommunicationMessage> senderStage,
            Class<? extends Name<String>> groupName,
            Class<? extends Name<String>> operatorName,
            String taskId,
            String driverId,
            boolean isRoot)

Method Detail

setSibling

public void setSibling(TaskNode leaf)

Specified by:

setSibling in interface TaskNode

getNumberOfChildren

public int getNumberOfChildren()

Specified by:

getNumberOfChildren in interface TaskNode

successor

public TaskNode successor()

Specified by:

successor in interface TaskNode

toString

public String toString()

Overrides:

toString in class Object

onFailedTask

public void onFailedTask()

* Methods pertaining to my status change ***.

Specified by:

onFailedTask in interface TaskNode

onRunningTask

public void onRunningTask()

Specified by:

onRunningTask in interface TaskNode

onParentRunning

public void onParentRunning()

* Methods pertaining to my status change ends ***.

Specified by:

onParentRunning in interface TaskNode

onParentDead

public void onParentDead()

Specified by:

onParentDead in interface TaskNode

onChildRunning

public void onChildRunning(String childId)

Specified by:

onChildRunning in interface TaskNode

onChildDead

public void onChildDead(String childId)

Specified by:

onChildDead in interface TaskNode

onReceiptOfAcknowledgement

public void onReceiptOfAcknowledgement(GroupCommunicationMessage msg)

* Methods pertaining to my neighbors status change ends ***.

Specified by:

onReceiptOfAcknowledgement in interface TaskNode

updatingTopology

public void updatingTopology()

Specified by:

updatingTopology in interface TaskNode

getTaskId

public String getTaskId()

Specified by:

getTaskId in interface TaskNode

addChild

public void addChild(TaskNode child)

Specified by:

addChild in interface TaskNode

removeChild

public void removeChild(TaskNode child)

Specified by:

removeChild in interface TaskNode

setParent

public void setParent(TaskNode parent)

Specified by:

setParent in interface TaskNode

isRunning

public boolean isRunning()

Specified by:

isRunning in interface TaskNode

getParent

public TaskNode getParent()

Specified by:

getParent in interface TaskNode

getChildren

public Iterable<TaskNode> getChildren()

Specified by:

getChildren in interface TaskNode

isNeighborActive

public boolean isNeighborActive(String neighborId)

Specified by:

isNeighborActive in interface TaskNode

resetTopologySetupSent

public boolean resetTopologySetupSent()

Description copied from interface: TaskNode

reset topology setup ensures that update topology is not sent to someone. who is already updating topology which is usually when they are just (re)starting

Specified by:

resetTopologySetupSent in interface TaskNode

Returns:

checkAndSendTopologySetupMessage

public void checkAndSendTopologySetupMessage()

Description copied from interface: TaskNode

Check if this node is ready for sending. TopologySetup

Specified by:

checkAndSendTopologySetupMessage in interface TaskNode

checkAndSendTopologySetupMessageFor

public void checkAndSendTopologySetupMessageFor(String source)

Description copied from interface: TaskNode

Check if the neighbor node with id source. is ready for sending TopologySetup

Specified by:

checkAndSendTopologySetupMessageFor in interface TaskNode

waitForTopologySetupOrFailure

public void waitForTopologySetupOrFailure()

Specified by:

waitForTopologySetupOrFailure in interface TaskNode

hasChanges

public boolean hasChanges()

Specified by:

hasChanges in interface TaskNode

getVersion

public int getVersion()

Specified by:

getVersion in interface TaskNode

hashCode

public int hashCode()

Overrides:

hashCode in class Object

equals

public boolean equals(Object obj)

Overrides:

equals in class Object