This is an automated email from the ASF dual-hosted git repository.
tanxinyu pushed a commit to branch master_performance
in repository https://gitbox.apache.org/repos/asf/iotdb.git
The following commit(s) were added to refs/heads/master_performance by this
push:
new 476fe5c open more timer
476fe5c is described below
commit 476fe5c4ffffdb483fd22cd740f05fc103e3ec4c
Author: LebronAl <[email protected]>
AuthorDate: Sat Nov 27 15:28:35 2021 +0800
open more timer
---
.../org/apache/iotdb/cluster/server/monitor/Timer.java | 18 +++++++-----------
1 file changed, 7 insertions(+), 11 deletions(-)
diff --git
a/cluster/src/main/java/org/apache/iotdb/cluster/server/monitor/Timer.java
b/cluster/src/main/java/org/apache/iotdb/cluster/server/monitor/Timer.java
index 562e8cb..723cf05 100644
--- a/cluster/src/main/java/org/apache/iotdb/cluster/server/monitor/Timer.java
+++ b/cluster/src/main/java/org/apache/iotdb/cluster/server/monitor/Timer.java
@@ -161,46 +161,42 @@ public class Timer {
true,
RAFT_SENDER_COMMIT_LOG),
RAFT_SENDER_COMMIT_LOG_IN_MANAGER(
- RAFT_MEMBER_SENDER,
- "commit log in log manager",
- TIME_SCALE,
- RaftMember.USE_LOG_DISPATCHER,
- RAFT_SENDER_COMMIT_LOG),
+ RAFT_MEMBER_SENDER, "commit log in log manager", TIME_SCALE, true,
RAFT_SENDER_COMMIT_LOG),
RAFT_SENDER_COMMIT_GET_LOGS(
RAFT_MEMBER_SENDER,
"get logs to be committed",
TIME_SCALE,
- RaftMember.USE_LOG_DISPATCHER,
+ true,
RAFT_SENDER_COMMIT_LOG_IN_MANAGER),
RAFT_SENDER_COMMIT_DELETE_EXCEEDING_LOGS(
RAFT_MEMBER_SENDER,
"delete logs exceeding capacity",
TIME_SCALE,
- RaftMember.USE_LOG_DISPATCHER,
+ true,
RAFT_SENDER_COMMIT_LOG_IN_MANAGER),
RAFT_SENDER_COMMIT_APPEND_AND_STABLE_LOGS(
RAFT_MEMBER_SENDER,
"append and stable committed logs",
TIME_SCALE,
- RaftMember.USE_LOG_DISPATCHER,
+ true,
RAFT_SENDER_COMMIT_LOG_IN_MANAGER),
RAFT_SENDER_COMMIT_APPLY_LOGS(
RAFT_MEMBER_SENDER,
"apply after committing logs",
TIME_SCALE,
- RaftMember.USE_LOG_DISPATCHER,
+ true,
RAFT_SENDER_COMMIT_LOG_IN_MANAGER),
RAFT_SENDER_COMMIT_TO_CONSUMER_LOGS(
RAFT_MEMBER_SENDER,
"provide log to consumer",
TIME_SCALE,
- RaftMember.USE_LOG_DISPATCHER,
+ true,
RAFT_SENDER_COMMIT_APPLY_LOGS),
RAFT_SENDER_COMMIT_EXCLUSIVE_LOGS(
RAFT_MEMBER_SENDER,
"apply logs that cannot run in parallel",
TIME_SCALE,
- RaftMember.USE_LOG_DISPATCHER,
+ true,
RAFT_SENDER_COMMIT_APPLY_LOGS),
RAFT_SENDER_COMMIT_WAIT_LOG_APPLY(
RAFT_MEMBER_SENDER, "wait until log is applied", TIME_SCALE, true,
RAFT_SENDER_COMMIT_LOG),