This is an automated email from the ASF dual-hosted git repository. szetszwo pushed a commit to branch branch-3.1.1_review in repository https://gitbox.apache.org/repos/asf/ratis.git
commit 2e7cb458ca6a10b4c38cafca7e8eee8a8e7fcef1 Author: z-bb <[email protected]> AuthorDate: Thu Aug 22 23:37:09 2024 +0800 RATIS-2140. Thread wait when installing snapshot. (#1137) --- .../src/main/java/org/apache/ratis/grpc/server/GrpcLogAppender.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/ratis-grpc/src/main/java/org/apache/ratis/grpc/server/GrpcLogAppender.java b/ratis-grpc/src/main/java/org/apache/ratis/grpc/server/GrpcLogAppender.java index 88e28dc48..8580c4239 100644 --- a/ratis-grpc/src/main/java/org/apache/ratis/grpc/server/GrpcLogAppender.java +++ b/ratis-grpc/src/main/java/org/apache/ratis/grpc/server/GrpcLogAppender.java @@ -770,7 +770,7 @@ public class GrpcLogAppender extends LogAppenderBase { while (isRunning() && !responseHandler.isDone()) { try { - getEventAwaitForSignal().await(); + getEventAwaitForSignal().await(getWaitTimeMs(), TimeUnit.MILLISECONDS); } catch (InterruptedException ignored) { Thread.currentThread().interrupt(); } @@ -815,7 +815,7 @@ public class GrpcLogAppender extends LogAppenderBase { while (isRunning() && !responseHandler.isDone()) { try { - getEventAwaitForSignal().await(); + getEventAwaitForSignal().await(getWaitTimeMs(), TimeUnit.MILLISECONDS); } catch (InterruptedException ignored) { Thread.currentThread().interrupt(); }
