services: log an error to java logger when health-check disabled. (#5261)
This is required by the spec:
https://github.com/grpc/proposal/blob/master/A17-client-side-health-checking.md
diff --git a/services/src/main/java/io/grpc/services/HealthCheckingLoadBalancerFactory.java b/services/src/main/java/io/grpc/services/HealthCheckingLoadBalancerFactory.java
index 214eeab..754d1a7 100644
--- a/services/src/main/java/io/grpc/services/HealthCheckingLoadBalancerFactory.java
+++ b/services/src/main/java/io/grpc/services/HealthCheckingLoadBalancerFactory.java
@@ -56,6 +56,8 @@
import java.util.Map;
import java.util.concurrent.ScheduledExecutorService;
import java.util.concurrent.TimeUnit;
+import java.util.logging.Level;
+import java.util.logging.Logger;
import javax.annotation.Nullable;
/**
@@ -69,6 +71,8 @@
final class HealthCheckingLoadBalancerFactory extends Factory {
private static final Attributes.Key<HealthCheckState> KEY_HEALTH_CHECK_STATE =
Attributes.Key.create("io.grpc.services.HealthCheckingLoadBalancerFactory.healthCheckState");
+ private static final Logger logger =
+ Logger.getLogger(HealthCheckingLoadBalancerFactory.class.getName());
private final Factory delegateFactory;
private final BackoffPolicy.Provider backoffPolicyProvider;
@@ -421,6 +425,9 @@
void handleStreamClosed(Status status) {
if (Objects.equal(status.getCode(), Code.UNIMPLEMENTED)) {
disabled = true;
+ logger.log(
+ Level.SEVERE, "Health-check with {0} is disabled. Server returned: {1}",
+ new Object[] {subchannel.getAllAddresses(), status});
subchannelLogger.log(ChannelLogLevel.ERROR, "Health-check disabled: {0}", status);
subchannelLogger.log(ChannelLogLevel.INFO, "{0} (no health-check)", rawState);
gotoState(rawState);
