Fix retries that timeout hanging forever. (#10855)

Fixes #10336
grpc · Jan 31, 2024 · c0a9d31 · c0a9d31
1 parent 8d280c9
commit c0a9d31
Showing 1 changed file with 4 additions and 1 deletion.
diff --git a/core/src/main/java/io/grpc/internal/RetriableStream.java b/core/src/main/java/io/grpc/internal/RetriableStream.java
@@ -195,7 +195,10 @@ public void run() {
             }
           }
           if (retryFuture != null) {
-            retryFuture.cancel(false);
+            boolean cancelled = retryFuture.cancel(false);
+            if (cancelled) {
+              inFlightSubStreams.decrementAndGet();
+            }
           }
           if (hedgingFuture != null) {
             hedgingFuture.cancel(false);