add proxy delete log

ctripcorp · Sep 24, 2024 · be6cf44 · be6cf44
1 parent 99abb22
commit be6cf44
Show file tree

Hide file tree

Showing 3 changed files with 13 additions and 2 deletions.
diff --git a/.../xpipe/redis/checker/healthcheck/actions/interaction/DefaultDelayPingActionCollector.java b/.../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);
                     }
                 });

diff --git a/...er/healthcheck/actions/interaction/processor/route/AbstractRouteHealthEventProcessor.java b/...er/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);

diff --git a/...s/redis-checker/src/main/java/com/ctrip/xpipe/redis/checker/impl/CheckerProxyManager.java b/...s/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