From 054d0b348785fe087809e1fdd99cb93489602db5 Mon Sep 17 00:00:00 2001
From: chrislu <chris.lu@gmail.com>
Date: Sat, 16 Mar 2024 11:14:14 -0700
Subject: [PATCH] wait for data

---
 weed/util/log_buffer/log_read.go | 14 +++++++++-----
 1 file changed, 9 insertions(+), 5 deletions(-)

diff --git a/weed/util/log_buffer/log_read.go b/weed/util/log_buffer/log_read.go
index d7ca47155..0354f0e7f 100644
--- a/weed/util/log_buffer/log_read.go
+++ b/weed/util/log_buffer/log_read.go
@@ -66,16 +66,20 @@ func (logBuffer *LogBuffer) LoopProcessLogData(readerName string, startPosition
 				isDone = true
 				return
 			}
-			if waitForDataFn() {
-				continue
-			} else {
-				isDone = true
-				return
+			lastTsNs := logBuffer.LastTsNs
+			for lastTsNs == logBuffer.LastTsNs {
+				if waitForDataFn() {
+					continue
+				} else {
+					isDone = true
+					return
+				}
 			}
 			if logBuffer.IsStopping() {
 				isDone = true
 				return
 			}
+			continue
 		}
 
 		buf := bytesBuf.Bytes()