ensure correct next pointer

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 {