public interface TaskNode
Modifier and Type | Method and Description |
---|---|
void |
addChild(TaskNode child) |
void |
checkAndSendTopologySetupMessage()
Check if this node is ready for sending
TopologySetup
|
void |
checkAndSendTopologySetupMessageFor(String source)
Check if the neighbor node with id source
is ready for sending TopologySetup
|
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
who is already updating topology which is usually when they are just
(re)starting
|
void |
setParent(TaskNode parent) |
void |
setSibling(TaskNode leaf) |
TaskNode |
successor() |
void |
updatingTopology() |
void |
waitForTopologySetupOrFailure() |
int getVersion()
int getNumberOfChildren()
void removeChild(TaskNode taskNode)
boolean isRunning()
void onRunningTask()
void onFailedTask()
boolean hasChanges()
boolean isNeighborActive(String neighborId)
void onReceiptOfAcknowledgement(GroupCommunicationMessage msg)
void onParentRunning()
void onParentDead()
void onChildRunning(String childId)
void onChildDead(String childId)
void checkAndSendTopologySetupMessage()
void checkAndSendTopologySetupMessageFor(String source)
source
- boolean resetTopologySetupSent()
void waitForTopologySetupOrFailure()
void setSibling(TaskNode leaf)
void updatingTopology()
Copyright © 2015 The Apache Software Foundation. All rights reserved.