Merge pull request #139 from elandau/bugfix/grpc_server_onCancel

Add back releasing limit in gRPC's onCancel
Netflix · Jul 17, 2019 · 8965911 · 8965911
2 parents 9414389 + b3c5f2b
commit 8965911
Showing 1 changed file with 10 additions and 0 deletions.
diff --git a/...in/java/com/netflix/concurrency/limits/grpc/server/ConcurrencyLimitServerInterceptor.java b/...in/java/com/netflix/concurrency/limits/grpc/server/ConcurrencyLimitServerInterceptor.java
@@ -202,6 +202,16 @@ public void onHalfClose() {
                                 throw t;
                             }
                         }
+
+                        @Override
+                        public void onCancel() {
+                            try {
+                                super.onCancel();
+                            } finally {
+                                safeComplete(listener::onDropped);
+                            }
+                        }
+
                     };
                 }
             })