This repository was archived by the owner on May 8, 2026. It is now read-only.
File tree Expand file tree Collapse file tree
google-cloud-bigtable/src/main/java/com/google/cloud/bigtable/gaxx/grpc Expand file tree Collapse file tree Original file line number Diff line number Diff line change @@ -451,16 +451,16 @@ static class Entry {
451451
452452 private final AtomicInteger maxOutstanding = new AtomicInteger ();
453453
454- /**
455- * Queue storing the last 5 minutes of probe results
456- */
454+ /** Queue storing the last 5 minutes of probe results */
457455 @ VisibleForTesting
458456 final ConcurrentLinkedQueue <ProbeResult > probeHistory = new ConcurrentLinkedQueue <>();
459457
460458 /**
461- * Keep both # of failed and # of successful probes so that we don't have to check size() on the ConcurrentLinkedQueue all the time
459+ * Keep both # of failed and # of successful probes so that we don't have to check size() on the
460+ * ConcurrentLinkedQueue all the time
462461 */
463462 final AtomicInteger failedProbesInWindow = new AtomicInteger ();
463+
464464 final AtomicInteger successfulProbesInWindow = new AtomicInteger ();
465465
466466 // Flag that the channel should be closed once all the outstanding RPCs complete.
Original file line number Diff line number Diff line change 1919import com .google .auto .value .AutoValue ;
2020import com .google .bigtable .v2 .PingAndWarmResponse ;
2121import com .google .cloud .bigtable .data .v2 .stub .BigtableChannelPrimer ;
22- import com .google .cloud .bigtable .data .v2 .stub .NoOpChannelPrimer ;
2322import com .google .cloud .bigtable .gaxx .grpc .BigtableChannelPool .Entry ;
2423import com .google .common .annotations .VisibleForTesting ;
2524import com .google .common .collect .ImmutableList ;
You can’t perform that action at this time.
0 commit comments