Mirror of #395 (#397)

according to Naveen tests pass locally, issue in downloading the emulator. * mirror of #395 * need to rerun the ci again after agent upgrade from ububtu 16 to 20 * need to rerun the ci again after agent upgrade from ububtu 16 to 20 * adding space to trigger ci which is in struct state Co-authored-by: Mohammad Derakhshani <moderakh@users.noreply.github.com>
Azure · Dec 22, 2021 · 33f09ac · 33f09ac
1 parent 983dc9e
commit 33f09ac
Show file tree

Hide file tree

Showing 2 changed files with 8 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,11 +605,14 @@ 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);
         }
     }