From 6823802bc0c35536f4631bb52d0dc4738f0dfe0e Mon Sep 17 00:00:00 2001 From: Roman Tamarov Date: Fri, 21 Nov 2025 11:15:01 +0300 Subject: [PATCH] fix --- weed/filer/elastic/v7/elastic_store.go | 2 +- weed/filer/filer.go | 2 +- weed/filer/foundationdb/foundationdb_store.go | 2 +- weed/filer/hbase/hbase_store.go | 2 +- weed/filer/ydb/ydb_store.go | 2 +- 5 files changed, 5 insertions(+), 5 deletions(-) diff --git a/weed/filer/elastic/v7/elastic_store.go b/weed/filer/elastic/v7/elastic_store.go index c212b239b..159330dec 100644 --- a/weed/filer/elastic/v7/elastic_store.go +++ b/weed/filer/elastic/v7/elastic_store.go @@ -262,7 +262,7 @@ func (store *ElasticStore) listDirectoryEntries( resEachEntryFunc, resEachEntryFuncErr := eachEntryFunc(esEntry.Entry) if resEachEntryFuncErr != nil { glog.ErrorfCtx(ctx, "failed to process eachEntryFunc for entry %q: %v", fileName, resEachEntryFuncErr) -return lastFileName, fmt.Errorf("failed to process eachEntryFunc for entry %q: %w", fileName, resEachEntryFuncErr) + return lastFileName, fmt.Errorf("failed to process eachEntryFunc for entry %q: %w", fileName, resEachEntryFuncErr) } if !resEachEntryFunc { diff --git a/weed/filer/filer.go b/weed/filer/filer.go index 3584abb1e..f9f3d4fb2 100644 --- a/weed/filer/filer.go +++ b/weed/filer/filer.go @@ -373,7 +373,7 @@ func (f *Filer) doListDirectoryEntries(ctx context.Context, p util.FullPath, sta select { case <-ctx.Done(): glog.Errorf("Context is done.") -return false, fmt.Errorf("context canceled: %w", ctx.Err()) + return false, fmt.Errorf("context canceled: %w", ctx.Err()) default: if entry.TtlSec > 0 { if entry.IsExpireS3Enabled() { diff --git a/weed/filer/foundationdb/foundationdb_store.go b/weed/filer/foundationdb/foundationdb_store.go index dea725464..720afd7bc 100644 --- a/weed/filer/foundationdb/foundationdb_store.go +++ b/weed/filer/foundationdb/foundationdb_store.go @@ -477,7 +477,7 @@ func (store *FoundationDBStore) ListDirectoryPrefixedEntries(ctx context.Context resEachEntryFunc, resEachEntryFuncErr := eachEntryFunc(entry) if resEachEntryFuncErr != nil { glog.ErrorfCtx(ctx, "failed to process eachEntryFunc for entry %q: %v", fileName, resEachEntryFuncErr) -return lastFileName, fmt.Errorf("failed to process eachEntryFunc for entry %q: %w", fileName, resEachEntryFuncErr) + return lastFileName, fmt.Errorf("failed to process eachEntryFunc for entry %q: %w", fileName, resEachEntryFuncErr) } if !resEachEntryFunc { break diff --git a/weed/filer/hbase/hbase_store.go b/weed/filer/hbase/hbase_store.go index 24789812b..d9fd435f5 100644 --- a/weed/filer/hbase/hbase_store.go +++ b/weed/filer/hbase/hbase_store.go @@ -211,7 +211,7 @@ func (store *HbaseStore) ListDirectoryPrefixedEntries(ctx context.Context, dirPa resEachEntryFunc, resEachEntryFuncErr := eachEntryFunc(entry) if resEachEntryFuncErr != nil { -return lastFileName, fmt.Errorf("failed to process eachEntryFunc for entry %q: %w", entry.FullPath, resEachEntryFuncErr) + return lastFileName, fmt.Errorf("failed to process eachEntryFunc for entry %q: %w", entry.FullPath, resEachEntryFuncErr) } if !resEachEntryFunc { diff --git a/weed/filer/ydb/ydb_store.go b/weed/filer/ydb/ydb_store.go index d180bb8be..ee94d13e1 100644 --- a/weed/filer/ydb/ydb_store.go +++ b/weed/filer/ydb/ydb_store.go @@ -315,7 +315,7 @@ func (store *YdbStore) ListDirectoryPrefixedEntries(ctx context.Context, dirPath resEachEntryFunc, resEachEntryFuncErr := eachEntryFunc(entry) if resEachEntryFuncErr != nil { -return fmt.Errorf("failed to process eachEntryFunc for entry %q: %w", entry.FullPath, resEachEntryFuncErr) + return fmt.Errorf("failed to process eachEntryFunc for entry %q: %w", entry.FullPath, resEachEntryFuncErr) } if !resEachEntryFunc {