Remove goaway received connections from channelpool

ballerina-platform · Jan 17, 2024 · 9a239bb · 9a239bb
1 parent 5ee83dd
commit 9a239bb
Showing 1 changed file with 4 additions and 0 deletions.
diff --git a/.../stdlib/http/transport/contractimpl/sender/channel/pool/PoolableTargetChannelFactory.java b/.../stdlib/http/transport/contractimpl/sender/channel/pool/PoolableTargetChannelFactory.java
@@ -152,6 +152,10 @@ public void destroyObject(Object o) throws Exception {
     @Override
     public boolean validateObject(Object o) {
         TargetChannel targetChannel = (TargetChannel) o;
+        if (targetChannel.getHttp2ClientChannel() != null &&
+                targetChannel.getHttp2ClientChannel().getConnection().goAwayReceived()) {
+            return false;
+        }
         if (targetChannel.getChannel() != null) {
             boolean answer = targetChannel.getChannel().isActive();
             LOG.debug("Validating channel: {} -> {}", targetChannel.getChannel().id(), answer);