(ratis) branch master updated: RATIS-2505. Improve RATIS-2387 with direct synchronous append when compose disabled (#1436)

[szetszwo]

This is an automated email from the ASF dual-hosted git repository.

szetszwo pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/ratis.git


The following commit(s) were added to refs/heads/master by this push:
     new 01b6e4f56 RATIS-2505. Improve RATIS-2387 with direct synchronous 
append when compose disabled (#1436)
01b6e4f56 is described below

commit 01b6e4f56e5a7121763f802165e977e9d52a7a2e
Author: Sergey Soldatov <s...@apache.org>
AuthorDate: Thu Apr 23 10:20:36 2026 -0700

    RATIS-2505. Improve RATIS-2387 with direct synchronous append when compose 
disabled (#1436)
---
 .../src/main/java/org/apache/ratis/server/impl/RaftServerImpl.java     | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

diff --git 
a/ratis-server/src/main/java/org/apache/ratis/server/impl/RaftServerImpl.java 
b/ratis-server/src/main/java/org/apache/ratis/server/impl/RaftServerImpl.java
index af7fd27a1..c0e93338a 100644
--- 
a/ratis-server/src/main/java/org/apache/ratis/server/impl/RaftServerImpl.java
+++ 
b/ratis-server/src/main/java/org/apache/ratis/server/impl/RaftServerImpl.java
@@ -1687,7 +1687,7 @@ class RaftServerImpl implements RaftServer.Division,
     future.join();
     final CompletableFuture<Void> appendFuture = entries.isEmpty()? 
CompletableFuture.completedFuture(null)
         : appendLogTermIndices != null ? appendLogTermIndices.append(entries, 
this::appendLog)
-        : appendLog(entries);
+        : JavaUtils.allOf(state.getLog().append(entries));
 
     proto.getCommitInfosList().forEach(commitInfoCache::update);
 
@@ -1719,6 +1719,7 @@ class RaftServerImpl implements RaftServer.Division,
       return reply;
     });
   }
+
   private CompletableFuture<Void> appendLog(List<LogEntryProto> entries) {
     return CompletableFuture.completedFuture(null)
         .thenComposeAsync(dummy -> 
JavaUtils.allOf(state.getLog().append(entries)), serverExecutor);