chore: generate libraries at Wed Dec 24 09:24:38 UTC 2025

Author: cloud-java-bot

google-cloud-spanner/src/main/java/com/google/cloud/spanner/MultiplexedSessionDatabaseClient.java

@@ -317,8 +317,8 @@ public void close() {
   private final AtomicBoolean unimplemented = new AtomicBoolean(false);
 
   /**
-   *  This flag is set to true if create session RPC is in progress. This flag prevents application
-   *  from firing two requests concurrently
+   * This flag is set to true if create session RPC is in progress. This flag prevents application
+   * from firing two requests concurrently
    */
   private final AtomicBoolean retryingSessionCreation = new AtomicBoolean(true);
 

google-cloud-spanner/src/test/java/com/google/cloud/spanner/MultiplexedSessionDatabaseClientMockServerTest.java

@@ -308,7 +308,8 @@ public void testDeadlineExceededErrorWithOneRetryWithParallelRequests()
       throws InterruptedException {
     mockSpanner.setCreateSessionExecutionTime(
         SimulatedExecutionTime.ofMinimumAndRandomTimeAndExceptions(
-            2000, 0,
+            2000,
+            0,
             Arrays.asList(
                 Status.DEADLINE_EXCEEDED
                     .withDescription(
@@ -326,24 +327,24 @@ public void testDeadlineExceededErrorWithOneRetryWithParallelRequests()
         (DatabaseClientImpl) spanner.getDatabaseClient(DatabaseId.of("p", "i", "d"));
     assertNotNull(client.multiplexedSessionDatabaseClient);
 
-
     ExecutorService executor = Executors.newCachedThreadPool();
 
     // First set of request should fail with an error
     CountDownLatch failureCountDownLatch = new CountDownLatch(3);
     for (int i = 0; i < 3; i++) {
-      executor.submit(() -> {
-        try {
-          try (ResultSet resultSet = client.singleUse().executeQuery(STATEMENT)) {
-            //noinspection StatementWithEmptyBody
-            while (resultSet.next()) {
-              // ignore
+      executor.submit(
+          () -> {
+            try {
+              try (ResultSet resultSet = client.singleUse().executeQuery(STATEMENT)) {
+                //noinspection StatementWithEmptyBody
+                while (resultSet.next()) {
+                  // ignore
+                }
+              }
+            } catch (SpannerException e) {
+              failureCountDownLatch.countDown();
             }
-          }
-        } catch (SpannerException e) {
-          failureCountDownLatch.countDown();
-        }
-      });
+          });
     }
 
     assertTrue(failureCountDownLatch.await(2, TimeUnit.SECONDS));
@@ -352,18 +353,19 @@ public void testDeadlineExceededErrorWithOneRetryWithParallelRequests()
     // Second set of requests should pass
     CountDownLatch countDownLatch = new CountDownLatch(3);
     for (int i = 0; i < 3; i++) {
-      executor.submit(() -> {
-        try {
-          try (ResultSet resultSet = client.singleUse().executeQuery(STATEMENT)) {
-            //noinspection StatementWithEmptyBody
-            while (resultSet.next()) {
-              // ignore
+      executor.submit(
+          () -> {
+            try {
+              try (ResultSet resultSet = client.singleUse().executeQuery(STATEMENT)) {
+                //noinspection StatementWithEmptyBody
+                while (resultSet.next()) {
+                  // ignore
+                }
+              }
+            } catch (SpannerException e) {
+              countDownLatch.countDown();
             }
-          }
-        } catch (SpannerException e) {
-          countDownLatch.countDown();
-        }
-      });
+          });
     }
 
     assertFalse(countDownLatch.await(3, TimeUnit.SECONDS));