Flush to file periodically

2017-12-11 16:12:15 -08:00 · 2017-12-11 16:12:15 -08:00 · 28aebe856f
commit 28aebe856f
parent 5945ae2a68
1 changed files with 5 additions and 5 deletions
--- a/controller/aofshrink.go
+++ b/controller/aofshrink.go
@ -169,7 +169,6 @@ func (c *Controller) aofshrink() {
 					)

 				}()
-			}
 				if len(aofbuf) > maxchunk {
 					if _, err := f.Write(aofbuf); err != nil {
 						return err
@ -177,6 +176,7 @@ func (c *Controller) aofshrink() {
 					aofbuf = aofbuf[:0]
 				}
 			}
+		}

 		// load hooks
 		// first load the names of the hooks