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 {