add proxy delete log

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

Hide file tree

Showing 3 changed files with 12 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:{}", processor.getClass().getName());
  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.debug("[AbstractRouteHealthEventProcessor] start");
  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,16 @@ 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));
+ logger.info("[getProxyTunnelInfo]{}-{}-{}-{}", backupDcId, clusterId, shardId, peerDcId);
+ if (!clusterServer.amILeader()) {
+ logger.debug("[getProxyTunnelInfo] no leader");
+ return null;
+ }
+ ProxyTunnelInfo proxyTunnelInfo = proxyTunnelInfos.get(new DcClusterShardPeer(backupDcId, clusterId, shardId, peerDcId));
+ if (proxyTunnelInfo == null) {
+ logger.info("[getProxyTunnelInfo] proxyTunnelInfo is null, proxyTunnelInfo size:{}", proxyTunnelInfos.size());
+ }
+ return proxyTunnelInfo;
  }
 
  @Override