in grpc-gcp/src/main/java/com/google/cloud/grpc/GcpManagedChannel.java [1667:1686]
protected void activeStreamsCountDecr(long startNanos, Status status, boolean fromClientSide) {
int actStreams = activeStreamsCount.decrementAndGet();
if (minActiveStreams > actStreams) {
minActiveStreams = actStreams;
}
int totalActStreams = totalActiveStreams.decrementAndGet();
if (minTotalActiveStreams > totalActStreams) {
minTotalActiveStreams = totalActStreams;
}
if (status.isOk()) {
okCalls.incrementAndGet();
totalOkCalls.incrementAndGet();
} else {
errCalls.incrementAndGet();
totalErrCalls.incrementAndGet();
}
if (unresponsiveDetectionEnabled) {
detectUnresponsiveConnection(startNanos, status, fromClientSide);
}
}