You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by ta...@apache.org on 2022/01/14 06:19:30 UTC
[iotdb] 05/13: open more timer
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
commit f38b5760f9f2c21c0c8532ede4c8b99191293c9e
Author: LebronAl <TX...@gmail.com>
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),