diff options
| -rw-r--r-- | weed/filer/filer_notify_read.go | 1 |
1 files changed, 1 insertions, 0 deletions
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 { |