(ratis) branch master updated: RATIS-2140. Thread wait when installing snapshot. (#1137)

[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 17a408f95 RATIS-2140. Thread wait when installing snapshot. (#1137)
17a408f95 is described below

commit 17a408f951c422294c220e565e46e7220c27377f
Author: z-bb <35120306+z...@users.noreply.github.com>
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 351e7f109..06e0c5428 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
@@ -779,7 +779,7 @@ public class GrpcLogAppender extends LogAppenderBase {
 
     while (isRunning() && !responseHandler.isDone()) {
       try {
-        getEventAwaitForSignal().await();
+        getEventAwaitForSignal().await(getWaitTimeMs(), TimeUnit.MILLISECONDS);
       } catch (InterruptedException ignored) {
         Thread.currentThread().interrupt();
       }
@@ -824,7 +824,7 @@ public class GrpcLogAppender extends LogAppenderBase {
 
     while (isRunning() && !responseHandler.isDone()) {
       try {
-        getEventAwaitForSignal().await();
+        getEventAwaitForSignal().await(getWaitTimeMs(), TimeUnit.MILLISECONDS);
       } catch (InterruptedException ignored) {
         Thread.currentThread().interrupt();
       }