add proxy delete log

redis/redis-checker/src/main/java/com/ctrip/xpipe/redis/checker/healthcheck/actions/interaction/DefaultDelayPingActionCollector.java

@@ -187,6 +187,7 @@ private void onInstanceStateChange(Object args) {
  executors.execute(new AbstractExceptionLogTask() {
  @Override
  protected void doRun() throws Exception {
+ logger.debug("[onInstanceStateChange] {}", processor.getClass().getSimpleName());
  processor.onEvent((AbstractInstanceEvent) args);
  }
  });

redis/redis-checker/src/main/java/com/ctrip/xpipe/redis/checker/healthcheck/actions/interaction/processor/route/AbstractRouteHealthEventProcessor.java

@@ -80,6 +80,7 @@ public void onEvent(AbstractInstanceEvent event) {
 
  @VisibleForTesting
  protected void doOnEvent(AbstractInstanceEvent instanceSick) {
+ logger.info("[doOnEvent] {}", instanceSick.getInstance().getEndpoint());
  ProxyTunnelInfo proxyTunnelInfo = findProxyTunnelInfo(instanceSick);
  if (proxyTunnelInfo == null) {
  logger.warn("[doOnEvent]proxy chain not found for {}", instanceSick);

redis/redis-checker/src/main/java/com/ctrip/xpipe/redis/checker/impl/CheckerProxyManager.java

@@ -82,8 +82,17 @@ public List<ProxyTunnelInfo> getAllProxyTunnels() {
 
  @Override
  public ProxyTunnelInfo getProxyTunnelInfo(String backupDcId, String clusterId, String shardId, String peerDcId) {
- if (!clusterServer.amILeader()) return null;
- return proxyTunnelInfos.get(new DcClusterShardPeer(backupDcId, clusterId, shardId, peerDcId));
+ if (!clusterServer.amILeader()) {
+ logger.info("[getProxyTunnelInfo] not leader");
+ return null;
+ }
+ DcClusterShardPeer dcClusterShardPeer = new DcClusterShardPeer(backupDcId, clusterId, shardId, peerDcId);
+ ProxyTunnelInfo proxyTunnelInfo = proxyTunnelInfos.get(dcClusterShardPeer);
+ if (proxyTunnelInfo == null) {
+ logger.info("[getProxyTunnelInfo][unfound]{}", dcClusterShardPeer);
+ logger.debug("[getProxyTunnelInfo]{}", proxyTunnelInfos.keySet());
+ }
+ return proxyTunnelInfo;
  }
 
  @Override