diff options
| author | chrislu <chris.lu@gmail.com> | 2022-02-15 16:15:44 -0800 |
|---|---|---|
| committer | chrislu <chris.lu@gmail.com> | 2022-02-15 16:15:44 -0800 |
| commit | 98cce6a150227b155bd40cc2bfc5cc9957a5e891 (patch) | |
| tree | 941518ce372611c34fa7732bc07e67050fe97f7c /weed/filer/mongodb/mongodb_store.go | |
| parent | aa7fc299b87a1b3e7e787733f9d46c79f9d69619 (diff) | |
| download | seaweedfs-98cce6a150227b155bd40cc2bfc5cc9957a5e891.tar.xz seaweedfs-98cce6a150227b155bd40cc2bfc5cc9957a5e891.zip | |
mongodb: ensure closing cursor
Diffstat (limited to 'weed/filer/mongodb/mongodb_store.go')
| -rw-r--r-- | weed/filer/mongodb/mongodb_store.go | 10 |
1 files 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{ |