fix redisSlave hang after dumping fail too quick

ctripcorp · Sep 9, 2024 · 7d8d789 · 7d8d789
1 parent a7051fa
commit 7d8d789
Showing 1 changed file with 5 additions and 1 deletion.
diff --git a/...edis-keeper/src/main/java/com/ctrip/xpipe/redis/keeper/impl/DefaultRedisKeeperServer.java b/...edis-keeper/src/main/java/com/ctrip/xpipe/redis/keeper/impl/DefaultRedisKeeperServer.java
@@ -796,8 +796,12 @@ public void fullSyncToSlave(final RedisSlave redisSlave) throws IOException {
 				}
 
 				try{
-					dumpNewRdb(tryRordb);
+					RdbDumper newDumper = dumpNewRdb(tryRordb);
 					redisSlave.waitForRdbDumping();
+					if (newDumper.future().isDone() && !newDumper.future().isSuccess()) {
+						logger.info("[fullSyncToSlave][new dumper fail immediatelly]");
+						redisSlave.close();
+					}
 				}catch(AbstractRdbDumperException e){
 					logger.error("[fullSyncToSlave]", e);
 					if(e.isCancelSlave()){