Merge pull request #810 from ctripcorp/revert-807-feature/async-reset-sentinels

LanternLee · web-flow · commit 6768995c39a0 · 2024-05-29T19:54:00.000+08:00
Revert "reset sentinels async"
diff --git a/redis/redis-checker/src/main/java/com/ctrip/xpipe/redis/checker/healthcheck/actions/sentinel/collector/command/ResetSentinels.java b/redis/redis-checker/src/main/java/com/ctrip/xpipe/redis/checker/healthcheck/actions/sentinel/collector/command/ResetSentinels.java
@@ -51,7 +51,7 @@ public ResetSentinels(SentinelHelloCollectContext context, MetaCache metaCache,
 
     @Override
     protected void doExecute() throws Throwable {
-        resetExecutor.execute(() -> checkSentinels(context.getInfo().getClusterId(), context.getInfo().getShardId(), context.getSentinelMonitorName(), context.getToCheckReset()));
+        checkSentinels(context.getInfo().getClusterId(), context.getInfo().getShardId(), context.getSentinelMonitorName(), context.getToCheckReset());
         future().setSuccess();
     }
 

Original file line number	Diff line number	Diff line change
`@@ -51,7 +51,7 @@ public ResetSentinels(SentinelHelloCollectContext context, MetaCache metaCache,`
`51`	`51`
`52`	`52`	`@Override`
`53`	`53`	`protected void doExecute() throws Throwable {`
`54`		`- resetExecutor.execute(() -> checkSentinels(context.getInfo().getClusterId(), context.getInfo().getShardId(), context.getSentinelMonitorName(), context.getToCheckReset()));`
	`54`	`+ checkSentinels(context.getInfo().getClusterId(), context.getInfo().getShardId(), context.getSentinelMonitorName(), context.getToCheckReset());`
`55`	`55`	`future().setSuccess();`
`56`	`56`	`}`
`57`	`57`