send ACK to master from time to time

2 years ago · b5fcbecd42
parent 825438679b
commit b5fcbecd42
1 changed files with 1 additions and 1 deletions
--- a/internal/reader/psync.go
+++ b/internal/reader/psync.go
@ -47,10 +47,10 @@ func (r *psyncReader) StartRead() chan *entry.Entry {

 	go func() {
 		r.clearDir()
+		go r.sendReplconfAck()
 		r.saveRDB()
 		startOffset := r.receivedOffset
 		go r.saveAOF(r.rd)
-		go r.sendReplconfAck()
 		r.sendRDB()
 		time.Sleep(1 * time.Second) // wait for saveAOF create aof file
 		r.sendAOF(startOffset)