test(showcase): clean up background resources in ITGdch to prevent gRPC channel leak

Author: lqiu96

java-showcase/gapic-showcase/src/test/java/com/google/showcase/v1beta1/it/ITGdch.java

@@ -26,6 +26,7 @@
 import com.google.api.client.json.GenericJson;
 import com.google.api.client.json.JsonFactory;
 import com.google.api.client.json.gson.GsonFactory;
+import com.google.api.gax.core.BackgroundResource;
 import com.google.api.gax.core.FixedCredentialsProvider;
 import com.google.api.gax.rpc.ClientContext;
 import com.google.auth.Credentials;
@@ -85,9 +86,25 @@ void setup(@TempDir Path tempDir) throws IOException {
 
   @AfterEach
   void tearDown() throws InterruptedException {
-    if (client != null) {
-      client.close();
-      client.awaitTermination(TestClientInitializer.AWAIT_TERMINATION_SECONDS, TimeUnit.SECONDS);
+    try {
+      if (client != null) {
+        client.close();
+        client.awaitTermination(TestClientInitializer.AWAIT_TERMINATION_SECONDS, TimeUnit.SECONDS);
+      }
+    } finally {
+      if (context != null) {
+        // EchoStubSettings.newBuilder(context) configures a FixedTransportChannelProvider using the
+        // channel from ClientContext. FixedTransportChannelProvider disables auto-closing
+        // (shouldAutoClose() == false), so closing the client does not close the channel. We must
+        // manually shut down the background resources owned by ClientContext.
+        for (BackgroundResource resource : context.getBackgroundResources()) {
+          resource.shutdown();
+        }
+        for (BackgroundResource resource : context.getBackgroundResources()) {
+          resource.awaitTermination(
+              TestClientInitializer.AWAIT_TERMINATION_SECONDS, TimeUnit.SECONDS);
+        }
+      }
     }
   }
 

sdk-platform-java/java-showcase-3.21.0/gapic-showcase/src/test/java/com/google/showcase/v1beta1/it/ITGdch.java

@@ -26,6 +26,7 @@
 import com.google.api.client.json.GenericJson;
 import com.google.api.client.json.JsonFactory;
 import com.google.api.client.json.gson.GsonFactory;
+import com.google.api.gax.core.BackgroundResource;
 import com.google.api.gax.core.FixedCredentialsProvider;
 import com.google.api.gax.rpc.ClientContext;
 import com.google.auth.Credentials;
@@ -85,9 +86,25 @@ void setup(@TempDir Path tempDir) throws IOException {
 
   @AfterEach
   void tearDown() throws InterruptedException {
-    if (client != null) {
-      client.close();
-      client.awaitTermination(TestClientInitializer.AWAIT_TERMINATION_SECONDS, TimeUnit.SECONDS);
+    try {
+      if (client != null) {
+        client.close();
+        client.awaitTermination(TestClientInitializer.AWAIT_TERMINATION_SECONDS, TimeUnit.SECONDS);
+      }
+    } finally {
+      if (context != null) {
+        // EchoStubSettings.newBuilder(context) configures a FixedTransportChannelProvider using the
+        // channel from ClientContext. FixedTransportChannelProvider disables auto-closing
+        // (shouldAutoClose() == false), so closing the client does not close the channel. We must
+        // manually shut down the background resources owned by ClientContext.
+        for (BackgroundResource resource : context.getBackgroundResources()) {
+          resource.shutdown();
+        }
+        for (BackgroundResource resource : context.getBackgroundResources()) {
+          resource.awaitTermination(
+              TestClientInitializer.AWAIT_TERMINATION_SECONDS, TimeUnit.SECONDS);
+        }
+      }
     }
   }
 

sdk-platform-java/java-showcase-3.25.8/gapic-showcase/src/test/java/com/google/showcase/v1beta1/it/ITGdch.java

@@ -26,6 +26,7 @@
 import com.google.api.client.json.GenericJson;
 import com.google.api.client.json.JsonFactory;
 import com.google.api.client.json.gson.GsonFactory;
+import com.google.api.gax.core.BackgroundResource;
 import com.google.api.gax.core.FixedCredentialsProvider;
 import com.google.api.gax.rpc.ClientContext;
 import com.google.auth.Credentials;
@@ -85,9 +86,25 @@ void setup(@TempDir Path tempDir) throws IOException {
 
   @AfterEach
   void tearDown() throws InterruptedException {
-    if (client != null) {
-      client.close();
-      client.awaitTermination(TestClientInitializer.AWAIT_TERMINATION_SECONDS, TimeUnit.SECONDS);
+    try {
+      if (client != null) {
+        client.close();
+        client.awaitTermination(TestClientInitializer.AWAIT_TERMINATION_SECONDS, TimeUnit.SECONDS);
+      }
+    } finally {
+      if (context != null) {
+        // EchoStubSettings.newBuilder(context) configures a FixedTransportChannelProvider using the
+        // channel from ClientContext. FixedTransportChannelProvider disables auto-closing
+        // (shouldAutoClose() == false), so closing the client does not close the channel. We must
+        // manually shut down the background resources owned by ClientContext.
+        for (BackgroundResource resource : context.getBackgroundResources()) {
+          resource.shutdown();
+        }
+        for (BackgroundResource resource : context.getBackgroundResources()) {
+          resource.awaitTermination(
+              TestClientInitializer.AWAIT_TERMINATION_SECONDS, TimeUnit.SECONDS);
+        }
+      }
     }
   }