From b5fcbecd4276523d3528b181c4530b68ffa1d194 Mon Sep 17 00:00:00 2001 From: suxb201 Date: Sat, 2 Jul 2022 22:28:45 +0800 Subject: [PATCH] send ACK to master from time to time --- internal/reader/psync.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/internal/reader/psync.go b/internal/reader/psync.go index e121d43..1f512bf 100644 --- 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)