fix heap init

1 files changed, 10 insertions, 8 deletions

diff --git a/weed/filer/filer_notify_read.go b/weed/filer/filer_notify_read.go
index 1cdf12d63..115a925e9 100644
--- a/weed/filer/filer_notify_read.go
+++ b/weed/filer/filer_notify_read.go
@@ -226,17 +226,19 @@ func (c *LogFileEntryCollector) collectMore(v *OrderedLogVisitor) (err error) {
 			glog.Errorf("Unexpected! failed to find iterator for filer %s", filerId)
 			continue
 		}
-		next, err := iter.getNext(v)
-		if err != nil {
-			if err == io.EOF {
+		next, nextErr := iter.getNext(v)
+		if nextErr != nil {
+			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: %v", entryName, err)
 			}
-			return fmt.Errorf("failed to get next log entry for %v: %v", entryName, err)
+		} else {
+			heap.Push(v.pq, &LogEntryItem{
+				Entry: next,
+				filer: filerId,
+			})
 		}
-		heap.Push(v.pq, &LogEntryItem{
-			Entry: next,
-			filer: filerId,
-		})
 	}
 
 	return nil