mirror of #395

Azure · Dec 21, 2021 · 5980117 · 5980117
1 parent f6921f6
commit 5980117
Show file tree

Hide file tree

Showing 2 changed files with 7 additions and 5 deletions.
diff --git a/...n/java/com/microsoft/azure/cosmosdb/internal/directconnectivity/RntbdTransportClient.java b/...n/java/com/microsoft/azure/cosmosdb/internal/directconnectivity/RntbdTransportClient.java
@@ -245,7 +245,7 @@ private Options() {
             this.bufferPageSize = 8192;
             this.connectionTimeout = null;
             this.idleChannelTimeout = Duration.ZERO;
-            this.idleEndpointTimeout = Duration.ofSeconds(70L);
+            this.idleEndpointTimeout = Duration.ofHours(1);
             this.maxBufferCapacity = 8192 << 10;
             this.maxChannelsPerEndpoint = 10;
             this.maxRequestsPerChannel = 30;

diff --git a/...om/microsoft/azure/cosmosdb/internal/directconnectivity/rntbd/RntbdClientChannelPool.java b/...om/microsoft/azure/cosmosdb/internal/directconnectivity/rntbd/RntbdClientChannelPool.java
@@ -605,10 +605,12 @@ public void operationComplete(Future<Channel> future) {
         }
 
         private void fail(Throwable cause) {
-            if (this.acquired) {
-                this.pool.decrementAndRunTaskQueue();
-            } else {
-                this.pool.runTaskQueue();
+            if (!this.pool.isClosed()) {
+                if (this.acquired) {
+                    this.pool.decrementAndRunTaskQueue();
+                } else {
+                    this.pool.runTaskQueue();
+                }
             }
             this.originalPromise.setFailure(cause);
         }