You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ratis.apache.org by ms...@apache.org on 2018/07/31 07:40:59 UTC
incubator-ratis git commit: RATIS-284. FollowerInfo#toString should
print the elapsed time from last rpc. Contributed by Mukul Kumar Singh.
Repository: incubator-ratis
Updated Branches:
refs/heads/master c213a1969 -> a4fd89473
RATIS-284. FollowerInfo#toString should print the elapsed time from last rpc. Contributed by Mukul Kumar Singh.
Project: http://git-wip-us.apache.org/repos/asf/incubator-ratis/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-ratis/commit/a4fd8947
Tree: http://git-wip-us.apache.org/repos/asf/incubator-ratis/tree/a4fd8947
Diff: http://git-wip-us.apache.org/repos/asf/incubator-ratis/diff/a4fd8947
Branch: refs/heads/master
Commit: a4fd89473d1849ac2b81a0d1bd7f60537630621a
Parents: c213a19
Author: Mukul Kumar Singh <ms...@apache.org>
Authored: Tue Jul 31 13:10:37 2018 +0530
Committer: Mukul Kumar Singh <ms...@apache.org>
Committed: Tue Jul 31 13:10:37 2018 +0530
----------------------------------------------------------------------
.../src/main/java/org/apache/ratis/server/impl/FollowerInfo.java | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-ratis/blob/a4fd8947/ratis-server/src/main/java/org/apache/ratis/server/impl/FollowerInfo.java
----------------------------------------------------------------------
diff --git a/ratis-server/src/main/java/org/apache/ratis/server/impl/FollowerInfo.java b/ratis-server/src/main/java/org/apache/ratis/server/impl/FollowerInfo.java
index 2a40a55..6bb8e5b 100644
--- a/ratis-server/src/main/java/org/apache/ratis/server/impl/FollowerInfo.java
+++ b/ratis-server/src/main/java/org/apache/ratis/server/impl/FollowerInfo.java
@@ -81,8 +81,8 @@ public class FollowerInfo {
public String toString() {
return peer.getId() + "(next=" + nextIndex + ", match=" + matchIndex + "," +
" attendVote=" + attendVote +
- ", lastRpcSendTime=" + lastRpcSendTime +
- ", lastRpcResponseTime=" + lastRpcResponseTime + ")";
+ ", lastRpcSendTime=" + lastRpcSendTime.get().elapsedTimeMs() +
+ ", lastRpcResponseTime=" + lastRpcResponseTime.get().elapsedTimeMs() + ")";
}
void startAttendVote() {