diff --git a/weed/filer/cassandra/cassandra_store.go b/weed/filer/cassandra/cassandra_store.go index fe34ec6db..ef5868fe2 100644 --- a/weed/filer/cassandra/cassandra_store.go +++ b/weed/filer/cassandra/cassandra_store.go @@ -220,6 +220,7 @@ func (store *CassandraStore) ListDirectoryEntries(ctx context.Context, dirPath u } if errClose := iter.Close(); errClose != nil { glog.V(0).Infof("list iterator close: %v", errClose) + return lastFileName, errClose } return lastFileName, err diff --git a/weed/filer/cassandra2/cassandra_store.go b/weed/filer/cassandra2/cassandra_store.go index 7dc37121e..d7fc7e5ba 100644 --- a/weed/filer/cassandra2/cassandra_store.go +++ b/weed/filer/cassandra2/cassandra_store.go @@ -221,6 +221,7 @@ func (store *Cassandra2Store) ListDirectoryEntries(ctx context.Context, dirPath if errClose := iter.Close(); errClose != nil { glog.V(0).Infof("list iterator close: %v", errClose) + return lastFileName, errClose } return lastFileName, err diff --git a/weed/filer/mongodb/mongodb_store.go b/weed/filer/mongodb/mongodb_store.go index 9464a4425..bd633dac5 100644 --- a/weed/filer/mongodb/mongodb_store.go +++ b/weed/filer/mongodb/mongodb_store.go @@ -330,8 +330,9 @@ func (store *MongodbStore) ListDirectoryPrefixedEntries(ctx context.Context, dir } } - if err := cur.Close(ctx); err != nil { + if errClose := cur.Close(ctx); errClose != nil { glog.V(0).InfofCtx(ctx, "list iterator close: %v", err) + return lastFileName, errClose } return lastFileName, err