You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by yu...@apache.org on 2020/09/01 13:56:08 UTC
[incubator-iotdb] branch cluster_performance updated: print ms
This is an automated email from the ASF dual-hosted git repository.
yuyuankang pushed a commit to branch cluster_performance
in repository https://gitbox.apache.org/repos/asf/incubator-iotdb.git
The following commit(s) were added to refs/heads/cluster_performance by this push:
new 76e10cc print ms
76e10cc is described below
commit 76e10cc76ea897497ec8c5c428f844f24ab1bfd7
Author: Ring-k <yu...@hotmail.com>
AuthorDate: Tue Sep 1 19:02:48 2020 +0800
print ms
---
.../org/apache/iotdb/cluster/server/Timer.java | 36 +++++++++++-----------
.../iotdb/cluster/server/member/RaftMember.java | 2 +-
2 files changed, 19 insertions(+), 19 deletions(-)
diff --git a/cluster/src/main/java/org/apache/iotdb/cluster/server/Timer.java b/cluster/src/main/java/org/apache/iotdb/cluster/server/Timer.java
index 7ae3620..6908aa3 100644
--- a/cluster/src/main/java/org/apache/iotdb/cluster/server/Timer.java
+++ b/cluster/src/main/java/org/apache/iotdb/cluster/server/Timer.java
@@ -36,48 +36,48 @@ public class Timer {
public static String getReport() {
String result = "";
result += dataGroupMemberProcessPlanLocallyMSString
- + dataGroupMemberProcessPlanLocallyMS + ", "
+ + dataGroupMemberProcessPlanLocallyMS.get()/1000000L + ", "
+ dataGroupMemberProcessPlanLocallyCounter + ", "
- + (double) dataGroupMemberProcessPlanLocallyMS.get()
+ + (double) dataGroupMemberProcessPlanLocallyMS.get()/1000000L
/ dataGroupMemberProcessPlanLocallyCounter.get()
+ "\n";
result += dataGroupMemberWaitLeaderMSString
- + dataGroupMemberWaitLeaderMS + ", "
+ + dataGroupMemberWaitLeaderMS.get()/1000000L + ", "
+ dataGroupMemberWaitLeaderCounter + ", "
- + (double) dataGroupMemberWaitLeaderMS.get() / dataGroupMemberWaitLeaderCounter.get()
+ + (double) dataGroupMemberWaitLeaderMS.get()/1000000L / dataGroupMemberWaitLeaderCounter.get()
+ "\n";
result += metaGroupMemberExecuteNonQueryMSString
- + metaGroupMemberExecuteNonQueryMS + ", "
+ + metaGroupMemberExecuteNonQueryMS.get()/1000000L + ", "
+ metaGroupMemberExecuteNonQueryCounter + ", "
- + (double) metaGroupMemberExecuteNonQueryMS.get() / metaGroupMemberExecuteNonQueryCounter
+ + (double) metaGroupMemberExecuteNonQueryMS.get()/1000000L / metaGroupMemberExecuteNonQueryCounter
.get() + "\n";
result += metaGroupMemberExecuteNonQueryInLocalGroupMSString
- + metaGroupMemberExecuteNonQueryInLocalGroupMS + ", "
+ + metaGroupMemberExecuteNonQueryInLocalGroupMS.get()/1000000L + ", "
+ metaGroupMemberExecuteNonQueryInLocalGroupCounter + ", "
- + (double) metaGroupMemberExecuteNonQueryInLocalGroupMS.get()
+ + (double) metaGroupMemberExecuteNonQueryInLocalGroupMS.get()/1000000L
/ metaGroupMemberExecuteNonQueryInLocalGroupCounter.get() + "\n";
result += metaGroupMemberExecuteNonQueryInRemoteGroupMSString
- + metaGroupMemberExecuteNonQueryInRemoteGroupMS + ", "
+ + metaGroupMemberExecuteNonQueryInRemoteGroupMS.get()/1000000L + ", "
+ metaGroupMemberExecuteNonQueryInRemoteGroupCounter + ", "
- + (double) metaGroupMemberExecuteNonQueryInRemoteGroupMS.get()
+ + (double) metaGroupMemberExecuteNonQueryInRemoteGroupMS.get()/1000000L
/ metaGroupMemberExecuteNonQueryInRemoteGroupCounter.get() + "\n";
result += raftMemberAppendLogMSString
- + raftMemberAppendLogMS + ", "
+ + raftMemberAppendLogMS.get()/1000000L + ", "
+ raftMemberAppendLogCounter + ", "
- + (double) raftMemberAppendLogMS.get() / raftMemberAppendLogCounter.get() + "\n";
+ + (double) raftMemberAppendLogMS.get()/1000000L / raftMemberAppendLogCounter.get() + "\n";
result += raftMemberSendLogToFollowerMSString
- + raftMemberSendLogToFollowerMS + ", "
+ + raftMemberSendLogToFollowerMS.get()/1000000L + ", "
+ raftMemberSendLogToFollowerCounter + ", "
- + (double) raftMemberSendLogToFollowerMS.get() / raftMemberSendLogToFollowerCounter.get()
+ + (double) raftMemberSendLogToFollowerMS.get()/1000000L / raftMemberSendLogToFollowerCounter.get()
+ "\n";
result += raftMemberCommitLogMSString
- + raftMemberCommitLogMS + ", "
+ + raftMemberCommitLogMS.get()/1000000L + ", "
+ raftMemberCommitLogCounter + ", "
- + (double) raftMemberCommitLogMS.get() / raftMemberCommitLogCounter.get() + "\n";
+ + (double) raftMemberCommitLogMS.get()/1000000L / raftMemberCommitLogCounter.get() + "\n";
result += raftFollowerAppendEntryString
- + raftFollowerAppendEntryMS + ", "
+ + raftFollowerAppendEntryMS.get()/1000000L + ", "
+ raftFollowerAppendEntryCounter + ", "
- + (double) raftFollowerAppendEntryMS.get() / raftFollowerAppendEntryCounter.get() + "\n";
+ + (double) raftFollowerAppendEntryMS.get()/1000000L / raftFollowerAppendEntryCounter.get() + "\n";
return result;
}
diff --git a/cluster/src/main/java/org/apache/iotdb/cluster/server/member/RaftMember.java b/cluster/src/main/java/org/apache/iotdb/cluster/server/member/RaftMember.java
index 6620f72..76d3aa4 100644
--- a/cluster/src/main/java/org/apache/iotdb/cluster/server/member/RaftMember.java
+++ b/cluster/src/main/java/org/apache/iotdb/cluster/server/member/RaftMember.java
@@ -1247,7 +1247,7 @@ public abstract class RaftMember {
log.setPlan(plan);
logManager.append(log);
}
- Timer.raftMemberAppendLogMS.addAndGet(System.currentTimeMillis() - start);
+ Timer.raftMemberAppendLogMS.addAndGet(System.nanoTime() - start);
Timer.raftMemberAppendLogCounter.incrementAndGet();
try {