MyFavMirrors/minio
1
0
Fork 0
mirror of https://github.com/minio/minio.git synced 2025-04-12 23:42:22 -04:00
Code Issues Packages Projects Releases Wiki Activity

drive heal if we have enough success, do not error setList() (#516)

Browse Source
This commit is contained in:
Harshavardhana 2025-03-10 19:52:42 -07:00
parent 11507d46da
commit 2a3acc4f24
2 changed files with 4 additions and 14 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
cmd/global-heal.go
View File

@ -539,7 +539,8 @@ func (er *erasureObjects) healErasureSet(ctx context.Context, buckets []string,
go healEntry(bucket, *entry)
},
finished: func(errs []error) {
if countErrs(errs, nil) != len(errs) {
success := countErrs(errs, nil)
if success < expectedDisks {
retErr = fmt.Errorf("one or more errors reported during listing: %v", errors.Join(errs...))
}
},

15
cmd/metacache-set.go
View File

@ -1110,7 +1110,7 @@ func listPathRaw(ctx context.Context, opts listPathRawOptions) (err error) {
continue
}
hasErr++
errs[i] = err
errs[i] = fmt.Errorf("drive: %s returned err: %v", disks[i], err)
continue
}
// If no current, add it.
@ -1159,18 +1159,7 @@ func listPathRaw(ctx context.Context, opts listPathRawOptions) (err error) {
if opts.finished != nil {
opts.finished(errs)
}
var combinedErr []string
for i, err := range errs {
if err != nil {
if disks[i] != nil {
combinedErr = append(combinedErr,
fmt.Sprintf("drive %s returned: %s", disks[i], err))
} else {
combinedErr = append(combinedErr, err.Error())
}
}
}
return errors.New(strings.Join(combinedErr, ", "))
return errors.Join(errs...)
}
// Break if all at EOF or error.