public interface TaskNodeStatus
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)
To be called before sending a ctrl msg to the task
represented by this node.
|
boolean |
hasChanges() |
boolean |
isActive(String neighborId) |
void |
onTopologySetupMessageSent() |
void |
processAcknowledgement(GroupCommunicationMessage msg)
Process the msg that was received and update.
|
void |
updateFailureOf(String taskId)
This should remove state concerning neighboring tasks.
|
void |
updatingTopology()
Called to denote that a UpdateTopology msg will.
|
void |
waitForTopologySetup() |
boolean hasChanges()
void onTopologySetupMessageSent()
void processAcknowledgement(GroupCommunicationMessage msg)
void expectAckFor(ReefNetworkGroupCommProtos.GroupCommMessage.Type msgType, String srcId)
void clearStateAndReleaseLocks()
void updateFailureOf(String taskId)
void waitForTopologySetup()
void updatingTopology()
Copyright © 2017 The Apache Software Foundation. All rights reserved.