diff --git a/internal/client/redis.go b/internal/client/redis.go index 15546e3..d830ece 100644 --- a/internal/client/redis.go +++ b/internal/client/redis.go @@ -204,9 +204,6 @@ func (r *Redis) SendBytesBuff(buf []byte) { } func (r *Redis) flushBuff() { - if atomic.AddUint64(&r.sendCount, 1)%100 != 0 { - return - } if !r.timer.Stop() { select { case <-r.timer.C: @@ -214,6 +211,9 @@ func (r *Redis) flushBuff() { } } r.timer.Reset(time.Second) + if atomic.AddUint64(&r.sendCount, 1)%100 != 0 { + return + } r.flush() } diff --git a/internal/utils/file_rotate/aof_writer.go b/internal/utils/file_rotate/aof_writer.go index 17647ef..fadb93f 100644 --- a/internal/utils/file_rotate/aof_writer.go +++ b/internal/utils/file_rotate/aof_writer.go @@ -50,10 +50,6 @@ func (w *AOFWriter) Write(buf []byte) { w.Close() w.openFile(w.offset) } - err = w.file.Sync() - if err != nil { - log.Panicf(err.Error()) - } } func (w *AOFWriter) Close() {