From 224103e13b57339db94e426f02bc9e9272f0ee4d Mon Sep 17 00:00:00 2001
From: Chris Lu <chris.lu@gmail.com>
Date: Sat, 11 Jul 2020 09:12:03 -0700
Subject: [PATCH] aggregated logs has empty flushFn

---
 weed/util/log_buffer/log_buffer.go | 13 ++++++++-----
 1 file changed, 8 insertions(+), 5 deletions(-)

diff --git a/weed/util/log_buffer/log_buffer.go b/weed/util/log_buffer/log_buffer.go
index b02c45b52..cb9565fb2 100644
--- a/weed/util/log_buffer/log_buffer.go
+++ b/weed/util/log_buffer/log_buffer.go
@@ -145,12 +145,15 @@ func (m *LogBuffer) loopInterval() {
 
 func (m *LogBuffer) copyToFlush() *dataToFlush {
 
-	if m.flushFn != nil && m.pos > 0 {
+	if m.pos > 0 {
 		// fmt.Printf("flush buffer %d pos %d empty space %d\n", len(m.buf), m.pos, len(m.buf)-m.pos)
-		d := &dataToFlush{
-			startTime: m.startTime,
-			stopTime:  m.stopTime,
-			data:      copiedBytes(m.buf[:m.pos]),
+		var d *dataToFlush
+		if m.flushFn != nil {
+			d = &dataToFlush{
+				startTime: m.startTime,
+				stopTime:  m.stopTime,
+				data:      copiedBytes(m.buf[:m.pos]),
+			}
 		}
 		// fmt.Printf("flusing [0,%d) with %d entries\n", m.pos, len(m.idx))
 		m.buf = m.prevBuffers.SealBuffer(m.startTime, m.stopTime, m.buf, m.pos)