commit | c192c9ea1876c046c9bf7cdb2b6e75a68e92846e | [log] [tgz] |
---|---|---|
author | buyingyi <buyingyi@gmail.com> | Tue Nov 05 15:22:37 2013 -0800 |
committer | buyingyi <buyingyi@gmail.com> | Tue Nov 05 15:22:37 2013 -0800 |
tree | 4d25f13d6ffcf174310497ffbaa46936ad951bdc | |
parent | 288bb96de8c3e3c3ffd734f928969ba7182316b0 [diff] |
minor fix for heartbeat state population
diff --git a/hyracks/hyracks-control/hyracks-control-cc/src/main/java/edu/uci/ics/hyracks/control/cc/NodeControllerState.java b/hyracks/hyracks-control/hyracks-control-cc/src/main/java/edu/uci/ics/hyracks/control/cc/NodeControllerState.java index 6785d6f..85ce104 100644 --- a/hyracks/hyracks-control/hyracks-control-cc/src/main/java/edu/uci/ics/hyracks/control/cc/NodeControllerState.java +++ b/hyracks/hyracks-control/hyracks-control-cc/src/main/java/edu/uci/ics/hyracks/control/cc/NodeControllerState.java
@@ -219,8 +219,8 @@ ipcMessageBytesSent[rrdPtr] = hbData.ipcMessageBytesSent; ipcMessagesReceived[rrdPtr] = hbData.ipcMessagesReceived; ipcMessageBytesReceived[rrdPtr] = hbData.ipcMessageBytesReceived; + rrdPtr = (rrdPtr + 1) % RRD_SIZE; } - rrdPtr = (rrdPtr + 1) % RRD_SIZE; } public int incrementLastHeartbeatDuration() {