move history pruning

nicholsl · nicholsl · commit 32a7ac03c1d1 · 2025-09-09T17:38:48.000-04:00
Change-Id: Ibeae2ce0b790ef2731be541a70fa829e220fa4a8
diff --git a/google-cloud-bigtable/src/main/java/com/google/cloud/bigtable/gaxx/grpc/ChannelPoolHealthChecker.java b/google-cloud-bigtable/src/main/java/com/google/cloud/bigtable/gaxx/grpc/ChannelPoolHealthChecker.java
@@ -174,6 +174,7 @@ void addProbeResult(Entry entry, ProbeResult result) {
     } else {
       entry.failedProbesInWindow.incrementAndGet();
     }
+    pruneHistory(entry);
   }
 
   @VisibleForTesting
@@ -214,7 +215,6 @@ boolean isEntryHealthy(Entry entry) {
   Entry findOutlierEntry() {
     List<Entry> unhealthyEntries =
         this.entrySupplier.get().stream()
-            .peek(this::pruneHistory)
             .filter(entry -> !isEntryHealthy(entry))
             .collect(Collectors.toList());
 

Original file line number	Diff line number	Diff line change
`@@ -174,6 +174,7 @@ void addProbeResult(Entry entry, ProbeResult result) {`
`174`	`174`	`} else {`
`175`	`175`	`entry.failedProbesInWindow.incrementAndGet();`
`176`	`176`	`}`
	`177`	`+ pruneHistory(entry);`
`177`	`178`	`}`
`178`	`179`
`179`	`180`	`@VisibleForTesting`
`@@ -214,7 +215,6 @@ boolean isEntryHealthy(Entry entry) {`
`214`	`215`	`Entry findOutlierEntry() {`
`215`	`216`	`List<Entry> unhealthyEntries =`
`216`	`217`	`this.entrySupplier.get().stream()`
`217`		`- .peek(this::pruneHistory)`
`218`	`218`	`.filter(entry -> !isEntryHealthy(entry))`
`219`	`219`	`.collect(Collectors.toList());`
`220`	`220`