Browse Source

mongodb: ensure closing cursor

pull/2680/head
chrislu 3 years ago
parent
commit
98cce6a150
  1. 10
      weed/filer/mongodb/mongodb_store.go

10
weed/filer/mongodb/mongodb_store.go

@ -199,9 +199,13 @@ func (store *MongodbStore) ListDirectoryEntries(ctx context.Context, dirPath uti
for cur.Next(ctx) { for cur.Next(ctx) {
var data Model 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{ entry := &filer.Entry{

Loading…
Cancel
Save