From e18d5693e515fc928a4fda06660a39aa248d0f43 Mon Sep 17 00:00:00 2001 From: Roman Tamarov Date: Fri, 14 Nov 2025 12:53:41 +0300 Subject: [PATCH] return error if errClose --- weed/filer/cassandra/cassandra_store.go | 1 + weed/filer/cassandra2/cassandra_store.go | 1 + weed/filer/mongodb/mongodb_store.go | 3 ++- 3 files changed, 4 insertions(+), 1 deletion(-) 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