From 6d265cc74b06ba15200d8a7132f02a76c6fd4d9c Mon Sep 17 00:00:00 2001
From: chrislu <chris.lu@gmail.com>
Date: Fri, 15 Aug 2025 10:19:43 -0700
Subject: [PATCH] ensure correct next pointer

---
 weed/filer/filer_notify_read.go | 1 +
 1 file changed, 1 insertion(+)

diff --git a/weed/filer/filer_notify_read.go b/weed/filer/filer_notify_read.go
index d8b1d38ae..af3ce702e 100644
--- a/weed/filer/filer_notify_read.go
+++ b/weed/filer/filer_notify_read.go
@@ -307,6 +307,7 @@ func (iter *LogFileQueueIterator) getNext(v *OrderedLogVisitor) (logEntry *filer
 			if collectErr := v.logFileEntryCollector.collectMore(v); collectErr != nil && collectErr != io.EOF {
 				return nil, collectErr
 			}
+			next = iter.q.Peek() // Re-peek after collectMore
 		}
 		// skip the file if the next entry is before the startTsNs
 		if next != nil && next.TsNs <= iter.startTsNs {