Save changes.

Author: kannanjgithub

rls/src/main/java/io/grpc/rls/CachingRlsLbClient.java

@@ -133,6 +133,7 @@ final class CachingRlsLbClient {
   private final RefCountedChildPolicyWrapperFactory refCountedChildPolicyWrapperFactory;
   private final ChannelLogger logger;
   private final ChildPolicyWrapper fallbackChildPolicyWrapper;
+  private ConnectivityState lastRlsServerConnectivityState;
 
   static {
     MetricInstrumentRegistry metricInstrumentRegistry
@@ -216,6 +217,8 @@ private CachingRlsLbClient(Builder builder) {
       rlsChannelBuilder.disableServiceConfigLookUp();
     }
     rlsChannel = rlsChannelBuilder.build();
+    lastRlsServerConnectivityState = rlsChannel.getState(false);
+    rlsChannel.notifyWhenStateChanged(lastRlsServerConnectivityState, () -> rlsServerConnectionStateChanged());
     rlsStub = RouteLookupServiceGrpc.newStub(rlsChannel);
     childLbResolvedAddressFactory =
         checkNotNull(builder.resolvedAddressFactory, "resolvedAddressFactory");
@@ -257,6 +260,15 @@ public void accept(BatchRecorder recorder) {
     logger.log(ChannelLogLevel.DEBUG, "CachingRlsLbClient created");
   }
 
+  private void rlsServerConnectionStateChanged() {
+    ConnectivityState currentState = rlsChannel.getState(false);
+    if (lastRlsServerConnectivityState == ConnectivityState.TRANSIENT_FAILURE
+      && currentState == ConnectivityState.READY) {
+
+    }
+    lastRlsServerConnectivityState = currentState;
+  }
+
   void init() {
     synchronized (lock) {
       refCountedChildPolicyWrapperFactory.init();