diff options
| author | chrislu <chris.lu@gmail.com> | 2025-08-15 10:19:17 -0700 |
|---|---|---|
| committer | chrislu <chris.lu@gmail.com> | 2025-08-15 10:35:33 -0700 |
| commit | 8eb85415fb24adaa467534d8cdf907a7bf57e921 (patch) | |
| tree | de85bbf1889cdae12f22e63c07dc7600018bb7e8 | |
| parent | 9843a10f2b493d2739d6a2621a13db3490b9a29a (diff) | |
| download | seaweedfs-8eb85415fb24adaa467534d8cdf907a7bf57e921.tar.xz seaweedfs-8eb85415fb24adaa467534d8cdf907a7bf57e921.zip | |
correct error
| -rw-r--r-- | weed/filer/filer_notify_read.go | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/weed/filer/filer_notify_read.go b/weed/filer/filer_notify_read.go index 3e929452e..cc24bf9dc 100644 --- a/weed/filer/filer_notify_read.go +++ b/weed/filer/filer_notify_read.go @@ -245,7 +245,7 @@ func (c *LogFileEntryCollector) collectMore(v *OrderedLogVisitor) (err error) { if nextErr == io.EOF { // do nothing since the filer has no more log entries } else { - return fmt.Errorf("failed to get next log entry for %v: %w", entryName, err) + return fmt.Errorf("failed to get next log entry for %v: %w", entryName, nextErr) } } else { heap.Push(v.pq, &LogEntryItem{ |