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 <[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),
