You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ratis.apache.org by sz...@apache.org on 2021/09/10 15:35:03 UTC
[ratis] branch master updated: RATIS-1399. should notify all the
log senders Asynchronously (#496)
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 7a85273 RATIS-1399. should notify all the log senders Asynchronously (#496)
7a85273 is described below
commit 7a852736de1588bc645f86a92a1d6b4d37b21e2b
Author: Jackson Yao <ja...@tencent.com>
AuthorDate: Fri Sep 10 23:34:58 2021 +0800
RATIS-1399. should notify all the log senders Asynchronously (#496)
---
.../src/main/java/org/apache/ratis/server/impl/LeaderStateImpl.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/ratis-server/src/main/java/org/apache/ratis/server/impl/LeaderStateImpl.java b/ratis-server/src/main/java/org/apache/ratis/server/impl/LeaderStateImpl.java
index 8bbae24..e62a48f 100644
--- a/ratis-server/src/main/java/org/apache/ratis/server/impl/LeaderStateImpl.java
+++ b/ratis-server/src/main/java/org/apache/ratis/server/impl/LeaderStateImpl.java
@@ -200,7 +200,7 @@ class LeaderStateImpl implements LeaderState {
}
void forEach(Consumer<LogAppender> action) {
- senders.forEach(action);
+ senders.parallelStream().forEach(action);
}
void addAll(Collection<LogAppender> newSenders) {