commit afa4480a3d8b1da9049728b558e406c08bb3fe28
author Tian Jiang <jt2594838@163.com> Thu Jul 27 10:35:38 2023 +0800
committer Tian Jiang <jt2594838@163.com> Thu Jul 27 10:35:38 2023 +0800
tree 4ab633369bc6f0a6df5d198b8a2616f4d23cf82f
parent 4f79fd45a775db016036e248a90123b3181fbc2c

fix wakeup deadlock in dispatcher

consensus/src/main/java/org/apache/iotdb/consensus/natraft/protocol/RaftMember.java

diff --git a/consensus/src/main/java/org/apache/iotdb/consensus/natraft/protocol/RaftMember.java b/consensus/src/main/java/org/apache/iotdb/consensus/natraft/protocol/RaftMember.java
index 1b99873..fac1593 100644
--- a/consensus/src/main/java/org/apache/iotdb/consensus/natraft/protocol/RaftMember.java
+++ b/consensus/src/main/java/org/apache/iotdb/consensus/natraft/protocol/RaftMember.java
@@ -1275,6 +1275,7 @@
     } finally {
       logManager.writeUnlock();
     }
+    logDispatcher.wakeUp();
 
     List<Peer> addedNodes = NodeUtils.computeAddedNodes(oldNodes, this.newNodes);
     for (Peer addedNode : addedNodes) {

consensus/src/main/java/org/apache/iotdb/consensus/natraft/protocol/log/dispatch/CursorBasedDispatcherGroup.java

diff --git a/consensus/src/main/java/org/apache/iotdb/consensus/natraft/protocol/log/dispatch/CursorBasedDispatcherGroup.java b/consensus/src/main/java/org/apache/iotdb/consensus/natraft/protocol/log/dispatch/CursorBasedDispatcherGroup.java
index 1f21cb5..b4e0c5a 100644
--- a/consensus/src/main/java/org/apache/iotdb/consensus/natraft/protocol/log/dispatch/CursorBasedDispatcherGroup.java
+++ b/consensus/src/main/java/org/apache/iotdb/consensus/natraft/protocol/log/dispatch/CursorBasedDispatcherGroup.java
@@ -66,7 +66,6 @@
   }
 
   public boolean add(VotingEntry request) {
-    wakeUp();
     return true;
   }
 }