mirror
/
tile38
mirror of https://github.com/tidwall/tile38.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Hotfix replica sync needs flushing

This commit is contained in:
tidwall 2018-11-13 12:04:16 -07:00
parent dfcdeb7a51
commit 4c3ac62191
1 changed files with 4 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
internal/server/follow.go
View File

@ -129,6 +129,9 @@ func (c *Server) followHandleCommand(args []string, followc int, w io.Writer) (i
if err := c.writeAOF(args, &d); err != nil { if err := c.writeAOF(args, &d); err != nil {
return c.aofsz, err return c.aofsz, err
} }
if len(c.aofbuf) > 10240 {
c.flushAOF()
}
return c.aofsz, nil return c.aofsz, nil
} }
@ -238,6 +241,7 @@ func (c *Server) followStep(host string, port int, followc int) error {
if aofsz >= int(aofSize) { if aofsz >= int(aofSize) {
caughtUp = true caughtUp = true
c.mu.Lock() c.mu.Lock()
c.flushAOF()
c.fcup = true c.fcup = true
c.fcuponce = true c.fcuponce = true
c.mu.Unlock() c.mu.Unlock()