Perform rewrite operation after repairing Replication append aof file

snower · Apr 28, 2024 · 9bbed7f · 9bbed7f
1 parent 1038fc3
commit 9bbed7f
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/server/replication.go b/server/replication.go
@@ -810,7 +810,7 @@ func (self *ReplicationClient) ProcessAofAppend() {
 		}
 		if aof.AppendLock(aofLock) {
 			self.glock.Lock()
-			if self.replayAofIndex == aof.aofFileIndex {
+			if self.replayAofIndex <= aof.aofFileIndex {
 				aof.ExecuteConsistencyBarrierCommand(0)
 				aof.isWaitRewite = false
 				self.manager.slock.Log().Infof("Replication ready wait aof execute rewrite")