You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by ja...@apache.org on 2025/01/25 07:01:49 UTC
(iotdb) 14/31: IoTConsensusV2: Accelerate follower receive dispatch based on TPCx case
This is an automated email from the ASF dual-hosted git repository.
jackietien pushed a commit to branch rc/2.0.1
in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit 51f148e77d59f3f5d258e3c308bb2fa2a58020b0
Author: Peng Junzhi <78...@users.noreply.github.com>
AuthorDate: Tue Jan 14 16:21:29 2025 +0800
IoTConsensusV2: Accelerate follower receive dispatch based on TPCx case
(cherry picked from commit b4edfdf1d6897b4db3802a60f69e4669e2c41aa9)
---
.../db/pipe/receiver/protocol/pipeconsensus/PipeConsensusReceiver.java | 2 ++
1 file changed, 2 insertions(+)
diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/receiver/protocol/pipeconsensus/PipeConsensusReceiver.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/receiver/protocol/pipeconsensus/PipeConsensusReceiver.java
index eb7491e460e..047a37c732a 100644
--- a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/receiver/protocol/pipeconsensus/PipeConsensusReceiver.java
+++ b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/receiver/protocol/pipeconsensus/PipeConsensusReceiver.java
@@ -1458,6 +1458,8 @@ public class PipeConsensusReceiver {
if (resp != null
&& resp.getStatus().getCode() == TSStatusCode.SUCCESS_STATUS.getStatusCode()) {
onSuccess(tCommitId, isTransferTsFileSeal);
+ // signal all other reqs to accelerate dispatch process.
+ condition.signalAll();
}
return resp;
}