(ratis) branch master updated: RATIS-2407. Missing return statement after stream closed check in OrderedRequestStreamObserver. (#1348)

[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 53eba3bcd RATIS-2407. Missing return statement after stream closed 
check in OrderedRequestStreamObserver. (#1348)
53eba3bcd is described below

commit 53eba3bcd80c04bc72c0c68b0e507e41faacaf70
Author: slfan1989 <55643692+slfan1...@users.noreply.github.com>
AuthorDate: Sat Feb 14 11:39:37 2026 +0800

    RATIS-2407. Missing return statement after stream closed check in 
OrderedRequestStreamObserver. (#1348)
---
 .../java/org/apache/ratis/grpc/server/GrpcClientProtocolService.java     | 1 +
 1 file changed, 1 insertion(+)

diff --git 
a/ratis-grpc/src/main/java/org/apache/ratis/grpc/server/GrpcClientProtocolService.java
 
b/ratis-grpc/src/main/java/org/apache/ratis/grpc/server/GrpcClientProtocolService.java
index 9c1968467..1da3587e9 100644
--- 
a/ratis-grpc/src/main/java/org/apache/ratis/grpc/server/GrpcClientProtocolService.java
+++ 
b/ratis-grpc/src/main/java/org/apache/ratis/grpc/server/GrpcClientProtocolService.java
@@ -338,6 +338,7 @@ class GrpcClientProtocolService extends 
RaftClientProtocolServiceImplBase {
       if (isClosed()) {
         final AlreadyClosedException exception = new 
AlreadyClosedException(getName() + ": the stream is closed");
         responseError(exception, () -> "processClientRequest (stream already 
closed) for " + r);
+        return;
       }
 
       final RaftGroupId requestGroupId = r.getRaftGroupId();