fix

Author: sushanb

google-cloud-bigtable/src/main/java/com/google/cloud/bigtable/gaxx/grpc/BigtableChannelPool.java

@@ -526,12 +526,12 @@ static class Entry {
      * start.
      */
     @VisibleForTesting final AtomicInteger outstandingUnaryRpcs = new AtomicInteger(0);
+
     @VisibleForTesting final AtomicInteger outstandingStreamingRpcs = new AtomicInteger(0);
 
     private final AtomicInteger maxOutstandingUnaryRpcs = new AtomicInteger();
     private final AtomicInteger maxOutstandingStreamingRpcs = new AtomicInteger();
 
-
     /** Queue storing the last 5 minutes of probe results */
     @VisibleForTesting
     final ConcurrentLinkedQueue<ProbeResult> probeHistory = new ConcurrentLinkedQueue<>();
@@ -557,6 +557,7 @@ static class Entry {
     ManagedChannel getManagedChannel() {
       return this.channel;
     }
+
     @VisibleForTesting
     int totalOutstandingRpcs() {
       return outstandingUnaryRpcs.get() + outstandingStreamingRpcs.get();
@@ -579,7 +580,8 @@ int getAndResetMaxOutstanding() {
     @VisibleForTesting
     boolean retain(boolean isStreaming) {
       AtomicInteger counter = isStreaming ? outstandingStreamingRpcs : outstandingUnaryRpcs;
-      AtomicInteger maxCounter = isStreaming ? maxOutstandingStreamingRpcs : maxOutstandingUnaryRpcs;
+      AtomicInteger maxCounter =
+          isStreaming ? maxOutstandingStreamingRpcs : maxOutstandingUnaryRpcs;
       int currentOutstanding = counter.incrementAndGet();
       maxCounter.accumulateAndGet(currentOutstanding, Math::max);
       // abort if the channel is closing
@@ -601,13 +603,12 @@ void release(boolean isStreaming) {
         LOG.log(Level.WARNING, "Bug! Reference count is negative (" + newCount + ")!");
       }
 
-      // Must check toalOutstandingRpcs after shutdownRequested (in reverse order of retain()) to ensure
+      // Must check toalOutstandingRpcs after shutdownRequested (in reverse order of retain()) to
+      // ensure
       // mutual exclusion.
       if (shutdownRequested.get() && totalOutstandingRpcs() == 0) {
         shutdown();
       }
-
-
     }
 
     /**
@@ -647,7 +648,8 @@ public <RequestT, ResponseT> ClientCall<RequestT, ResponseT> newCall(
         MethodDescriptor<RequestT, ResponseT> methodDescriptor, CallOptions callOptions) {
       boolean isStreaming = methodDescriptor.getType() != MethodDescriptor.MethodType.UNARY;
       Entry entry = getRetainedEntry(index, isStreaming);
-      return new ReleasingClientCall<>(entry.channel.newCall(methodDescriptor, callOptions), entry, isStreaming);
+      return new ReleasingClientCall<>(
+          entry.channel.newCall(methodDescriptor, callOptions), entry, isStreaming);
     }
   }
 

google-cloud-bigtable/src/test/java/com/google/cloud/bigtable/gaxx/grpc/BigtableChannelPoolSettingsTest.java

@@ -19,13 +19,12 @@
 
 import com.google.api.gax.grpc.ChannelPoolSettings;
 import com.google.common.collect.ImmutableSet;
+import io.grpc.ManagedChannel;
 import java.lang.reflect.Method;
 import java.lang.reflect.Modifier;
 import java.util.Arrays;
 import java.util.Set;
 import java.util.stream.Collectors;
-
-import io.grpc.ManagedChannel;
 import org.junit.Test;
 import org.junit.runner.RunWith;
 import org.junit.runners.JUnit4;
@@ -89,7 +88,6 @@ public void testEntryRetainReleaseByType() {
     assertThat(entry.totalOutstandingRpcs()).isEqualTo(0);
   }
 
-
   @Test
   public void testToBigtableChannelPoolSettingsDefaultValuesCopiesCorrectly() throws Exception {
     ChannelPoolSettings originalSettings = ChannelPoolSettings.builder().build();