lint

Change-Id: I2fc110b6f3a05a61e99c28aa83e948e0f23c5e8e

Author: nicholsl

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

@@ -42,7 +42,6 @@
 import java.util.logging.Level;
 import java.util.logging.Logger;
 import javax.annotation.Nullable;
-import org.checkerframework.checker.units.qual.A;
 
 /**
  * A {@link ManagedChannel} that will send requests round-robin via a set of channels.
@@ -62,7 +61,8 @@ public class BigtableChannelPool extends ManagedChannel {
   private final BigtableChannelPoolSettings settings;
   private final ChannelFactory channelFactory;
   private final ScheduledExecutorService executor;
-  private final ScheduledExecutorService channelHealthProbingExecutor = Executors.newSingleThreadScheduledExecutor();
+  private final ScheduledExecutorService channelHealthProbingExecutor =
+      Executors.newSingleThreadScheduledExecutor();
 
   private final Object entryWriteLock = new Object();
   @VisibleForTesting final AtomicReference<ImmutableList<Entry>> entries = new AtomicReference<>();
@@ -96,7 +96,8 @@ public static BigtableChannelPool create(
     ImmutableList.Builder<Entry> initialListBuilder = ImmutableList.builder();
 
     for (int i = 0; i < settings.getInitialChannelCount(); i++) {
-      initialListBuilder.add(new Entry(channelFactory.createSingleChannel(), channelHealthProbingExecutor));
+      initialListBuilder.add(
+          new Entry(channelFactory.createSingleChannel(), channelHealthProbingExecutor));
     }
 
     entries.set(initialListBuilder.build());
@@ -154,7 +155,7 @@ public ManagedChannel shutdown() {
       // shutdownNow will cancel scheduled tasks
       executor.shutdownNow();
     }
-    if (channelHealthProbingExecutor != null){
+    if (channelHealthProbingExecutor != null) {
       channelHealthProbingExecutor.shutdownNow();
     }
     return this;
@@ -326,7 +327,8 @@ private void expand(int desiredSize) {
 
     for (int i = 0; i < desiredSize - localEntries.size(); i++) {
       try {
-        newEntries.add(new Entry(channelFactory.createSingleChannel(), channelHealthProbingExecutor));
+        newEntries.add(
+            new Entry(channelFactory.createSingleChannel(), channelHealthProbingExecutor));
       } catch (IOException e) {
         LOG.log(Level.WARNING, "Failed to add channel", e);
       }
@@ -364,7 +366,8 @@ void refresh() {
 
       for (int i = 0; i < newEntries.size(); i++) {
         try {
-          newEntries.set(i, new Entry(channelFactory.createSingleChannel(), channelHealthProbingExecutor));
+          newEntries.set(
+              i, new Entry(channelFactory.createSingleChannel(), channelHealthProbingExecutor));
         } catch (IOException e) {
           LOG.log(Level.WARNING, "Failed to refresh channel, leaving old channel", e);
         }
@@ -442,7 +445,6 @@ static class Entry {
     private final AtomicInteger maxOutstanding = new AtomicInteger();
     private final AtomicInteger probesInFlight = new AtomicInteger(0);
 
-
     // Flag that the channel should be closed once all of the outstanding RPC complete.
     private final AtomicBoolean shutdownRequested = new AtomicBoolean();
     // Flag that the channel has been closed.
@@ -463,7 +465,6 @@ public ChannelHealthChecker getHealthChecker() {
       return healthChecker;
     }
 
-
     int getAndResetMaxOutstanding() {
       return maxOutstanding.getAndSet(outstandingRpcs.get());
     }

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

@@ -43,6 +43,7 @@ public class ChannelHealthChecker {
   private volatile ScheduledFuture<?> scheduledProbeFuture;
   private final ReadWriteLock probeResultsLock = new ReentrantReadWriteLock();
   private final EvictingQueue<ProbeResult> probeResults;
+
   // private final AtomicInteger probesInFlight = new AtomicInteger(0);
 
   /** Inner class to represent the result of a single probe. */

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

@@ -18,9 +18,6 @@
 import com.google.cloud.bigtable.gaxx.grpc.BigtableChannelPool.Entry;
 import com.google.common.collect.ImmutableList;
 import java.time.Instant;
-import java.util.Collections;
-import java.util.Map;
-import java.util.WeakHashMap;
 import java.util.concurrent.Executors;
 import java.util.concurrent.ScheduledExecutorService;
 import java.util.function.Supplier;