From 98cce6a150227b155bd40cc2bfc5cc9957a5e891 Mon Sep 17 00:00:00 2001 From: chrislu Date: Tue, 15 Feb 2022 16:15:44 -0800 Subject: [PATCH] mongodb: ensure closing cursor --- weed/filer/mongodb/mongodb_store.go | 10 +++++++--- 1 file changed, 7 insertions(+), 3 deletions(-) diff --git a/weed/filer/mongodb/mongodb_store.go b/weed/filer/mongodb/mongodb_store.go index 6935be1ab..7f2da7047 100644 --- a/weed/filer/mongodb/mongodb_store.go +++ b/weed/filer/mongodb/mongodb_store.go @@ -199,9 +199,13 @@ func (store *MongodbStore) ListDirectoryEntries(ctx context.Context, dirPath uti for cur.Next(ctx) { var data Model - err := cur.Decode(&data) - if err != nil && err != mongo.ErrNoDocuments { - return lastFileName, err + err = cur.Decode(&data) + if err == mongo.ErrNoDocuments { + err = nil + break + } + if err != nil { + break } entry := &filer.Entry{