TaskNode (REEF 0.15.0 API)

All Known Implementing Classes:

TaskNodeImpl
```
public interface TaskNode
```
A node in the Topology representing a Task on the driver. Impl should maintain state relating to whether task is running/dead and status of neighboring nodes and send ctrl msgs to the tasks indicating topology changing events

Method Summary

All Methods Instance Methods Abstract 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.
`Iterable<TaskNode>`	`getChildren()`
`int`	`getNumberOfChildren()`
`TaskNode`	`getParent()`
`String`	`getTaskId()`
`int`	`getVersion()`
`boolean`	`hasChanges()`
`boolean`	`isNeighborActive(String neighborId)`
`boolean`	`isRunning()`
`void`	`onChildDead(String childId)`
`void`	`onChildRunning(String childId)`
`void`	`onFailedTask()`
`void`	`onParentDead()`
`void`	`onParentRunning()`
`void`	`onReceiptOfAcknowledgement(GroupCommunicationMessage msg)`
`void`	`onRunningTask()`
`void`	`removeChild(TaskNode taskNode)`
`boolean`	`resetTopologySetupSent()` reset topology setup ensures that update topology is not sent to someone.
`void`	`setParent(TaskNode parent)`
`void`	`setSibling(TaskNode leaf)`
`TaskNode`	`successor()`
`void`	`updatingTopology()`
`void`	`waitForTopologySetupOrFailure()`

Method Detail

getTaskId
```
String getTaskId()
```

getVersion
```
int getVersion()
```

getNumberOfChildren
```
int getNumberOfChildren()
```

getParent
```
TaskNode getParent()
```

setParent
```
void setParent(TaskNode parent)
```

getChildren
```
Iterable<TaskNode> getChildren()
```

addChild
```
void addChild(TaskNode child)
```

removeChild
```
void removeChild(TaskNode taskNode)
```

isRunning
```
boolean isRunning()
```

onRunningTask
```
void onRunningTask()
```

onFailedTask
```
void onFailedTask()
```

hasChanges
```
boolean hasChanges()
```

isNeighborActive

boolean isNeighborActive(String neighborId)

onReceiptOfAcknowledgement

void onReceiptOfAcknowledgement(GroupCommunicationMessage msg)

onParentRunning
```
void onParentRunning()
```

onParentDead
```
void onParentDead()
```

onChildRunning
```
void onChildRunning(String childId)
```

onChildDead
```
void onChildDead(String childId)
```

checkAndSendTopologySetupMessage
```
void checkAndSendTopologySetupMessage()
```
Check if this node is ready for sending. TopologySetup

checkAndSendTopologySetupMessageFor
```
void checkAndSendTopologySetupMessageFor(String source)
```
Check if the neighbor node with id source. is ready for sending TopologySetup

Parameters:

source -

resetTopologySetupSent
```
boolean resetTopologySetupSent()
```
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

Returns:

waitForTopologySetupOrFailure
```
void waitForTopologySetupOrFailure()
```

setSibling
```
void setSibling(TaskNode leaf)
```

successor
```
TaskNode successor()
```

updatingTopology
```
void updatingTopology()
```

Interface TaskNode

Method Summary

Method Detail

getTaskId

getVersion

getNumberOfChildren

getParent

setParent

getChildren

addChild

removeChild

isRunning

onRunningTask

onFailedTask

hasChanges

isNeighborActive

onReceiptOfAcknowledgement

onParentRunning

onParentDead

onChildRunning

onChildDead

checkAndSendTopologySetupMessage

checkAndSendTopologySetupMessageFor

resetTopologySetupSent

waitForTopologySetupOrFailure

setSibling

successor

updatingTopology