Skip to content

Commit 94895d5

Browse files
committed
have all operations related to proberesults be handled by the ChannelHealthChecker
Change-Id: I8068fed8c5eb49fef55ce481ef927aa33448ecae
1 parent c70f7ff commit 94895d5

2 files changed

Lines changed: 10 additions & 11 deletions

File tree

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

Lines changed: 0 additions & 11 deletions
Original file line numberDiff line numberDiff line change
@@ -440,17 +440,6 @@ static class Entry {
440440
@VisibleForTesting final AtomicInteger outstandingRpcs = new AtomicInteger(0);
441441

442442
private final AtomicInteger maxOutstanding = new AtomicInteger();
443-
444-
/** Number of probes in flight plus number of probe results. (No-op stub) */
445-
AtomicInteger recentProbesSent() {
446-
return new AtomicInteger(0);
447-
}
448-
449-
/** Number of recently failed probes. (No-op stub) */
450-
AtomicInteger recentlyFailedProbes() {
451-
return new AtomicInteger(0);
452-
}
453-
454443
private final AtomicInteger probesInFlight = new AtomicInteger(0);
455444

456445

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

Lines changed: 10 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -84,6 +84,16 @@ void probeFinished(Instant startTime, boolean success) {
8484
// Method stub, no operation.
8585
}
8686

87+
/** Number of probes in flight plus number of probe results. (No-op stub) */
88+
AtomicInteger recentProbesSent() {
89+
return new AtomicInteger(0);
90+
}
91+
92+
/** Number of recently failed probes. (No-op stub) */
93+
AtomicInteger recentlyFailedProbes() {
94+
return new AtomicInteger(0);
95+
}
96+
8797
/**
8898
* Determines if the channel is healthy. (No-op stub)
8999
*

0 commit comments

Comments
 (0)