diff --git a/cmd/erasure-multipart.go b/cmd/erasure-multipart.go index 8916d207f..cc56e7e95 100644 --- a/cmd/erasure-multipart.go +++ b/cmd/erasure-multipart.go @@ -846,21 +846,21 @@ func (er erasureObjects) CompleteMultipartUpload(ctx context.Context, bucket str } // Check if there is any offline disk and add it to the MRF list - for i, disk := range onlineDisks { - if disk == nil || storageDisks[i] == nil { - er.addPartial(bucket, object, fi.VersionID) - break + for _, disk := range onlineDisks { + if disk != nil && disk.IsOnline() { + continue } + er.addPartial(bucket, object, fi.VersionID) + break } for i := 0; i < len(onlineDisks); i++ { - if onlineDisks[i] == nil { - continue + if onlineDisks[i] != nil && onlineDisks[i].IsOnline() { + // Object info is the same in all disks, so we can pick + // the first meta from online disk + fi = partsMetadata[i] + break } - // Object info is the same in all disks, so we can pick - // the first meta from online disk - fi = partsMetadata[i] - break } // Success, return object info. diff --git a/cmd/erasure-object.go b/cmd/erasure-object.go index fb13702f0..fb7b1ae2e 100644 --- a/cmd/erasure-object.go +++ b/cmd/erasure-object.go @@ -727,20 +727,20 @@ func (er erasureObjects) putObject(ctx context.Context, bucket string, object st // Whether a disk was initially or becomes offline // during this upload, send it to the MRF list. for i := 0; i < len(onlineDisks); i++ { - if onlineDisks[i] == nil || storageDisks[i] == nil { - er.addPartial(bucket, object, fi.VersionID) - break + if onlineDisks[i] != nil && onlineDisks[i].IsOnline() { + continue } + er.addPartial(bucket, object, fi.VersionID) + break } for i := 0; i < len(onlineDisks); i++ { - if onlineDisks[i] == nil { - continue + if onlineDisks[i] != nil && onlineDisks[i].IsOnline() { + // Object info is the same in all disks, so we can pick + // the first meta from online disk + fi = partsMetadata[i] + break } - // Object info is the same in all disks, so we can pick - // the first meta from online disk - fi = partsMetadata[i] - break } return fi.ToObjectInfo(bucket, object), nil @@ -922,16 +922,15 @@ func (er erasureObjects) DeleteObjects(ctx context.Context, bucket string, objec for _, version := range versions { // Check if there is any offline disk and add it to the MRF list for _, disk := range storageDisks { - if disk == nil { - // ignore delete markers for quorum - if version.Deleted { - continue - } - // all other direct versionId references we should - // ensure no dangling file is left over. - er.addPartial(bucket, version.Name, version.VersionID) - break + if disk != nil && disk.IsOnline() { + // Skip attempted heal on online disks. + continue } + + // all other direct versionId references we should + // ensure no dangling file is left over. + er.addPartial(bucket, version.Name, version.VersionID) + break } } @@ -1042,10 +1041,11 @@ func (er erasureObjects) DeleteObject(ctx context.Context, bucket, object string } for _, disk := range storageDisks { - if disk == nil { - er.addPartial(bucket, object, opts.VersionID) - break + if disk != nil && disk.IsOnline() { + continue } + er.addPartial(bucket, object, opts.VersionID) + break } return ObjectInfo{ diff --git a/cmd/metacache-entries.go b/cmd/metacache-entries.go index 7ba4dd367..a8dccea4b 100644 --- a/cmd/metacache-entries.go +++ b/cmd/metacache-entries.go @@ -73,11 +73,13 @@ func (e *metaCacheEntry) matches(other *metaCacheEntry, bucket string) bool { if len(e.metadata) != len(other.metadata) || e.name != other.name { return false } + eFi, eErr := e.fileInfo(bucket) - oFi, oErr := e.fileInfo(bucket) + oFi, oErr := other.fileInfo(bucket) if eErr != nil || oErr != nil { return eErr == oErr } + return eFi.ModTime.Equal(oFi.ModTime) && eFi.Size == oFi.Size && eFi.VersionID == oFi.VersionID } @@ -213,11 +215,12 @@ func (m metaCacheEntries) resolve(r *metadataResolutionParams) (selected *metaCa } // Get new entry metadata - objExists++ fiv, err := entry.fileInfo(r.bucket) if err != nil { continue } + + objExists++ if selFIV == nil { selected = entry selFIV = fiv @@ -227,14 +230,8 @@ func (m metaCacheEntries) resolve(r *metadataResolutionParams) (selected *metaCa if selected.matches(entry, r.bucket) { continue } - - // Select latest modtime. - if fiv.ModTime.After(selFIV.ModTime) { - selected = entry - selFIV = fiv - continue - } } + // If directory, we need quorum. if dirExists > 0 && dirExists < r.dirQuorum { return nil, false diff --git a/cmd/metacache-server-pool.go b/cmd/metacache-server-pool.go index 5932d82ec..d1815be94 100644 --- a/cmd/metacache-server-pool.go +++ b/cmd/metacache-server-pool.go @@ -147,13 +147,11 @@ func (z *erasureServerPools) listPath(ctx context.Context, o listPathOptions) (e var wg sync.WaitGroup var errs []error allAtEOF := true - asked := 0 mu.Lock() // Ask all sets and merge entries. for _, zone := range z.serverPools { for _, set := range zone.sets { wg.Add(1) - asked++ go func(i int, set *erasureObjects) { defer wg.Done() e, err := set.listPath(ctx, o) diff --git a/cmd/metacache-set.go b/cmd/metacache-set.go index f5e7a74b9..37f1d8c59 100644 --- a/cmd/metacache-set.go +++ b/cmd/metacache-set.go @@ -168,11 +168,9 @@ func (o *listPathOptions) gatherResults(in <-chan metaCacheEntry) func() (metaCa o.debugln("not in dir", o.Prefix, o.Separator) continue } - if !o.InclDeleted && entry.isObject() { - if entry.isLatestDeletemarker() { - o.debugln("latest delete") - continue - } + if !o.InclDeleted && entry.isObject() && entry.isLatestDeletemarker() { + o.debugln("latest is delete marker") + continue } if o.Limit > 0 && results.len() >= o.Limit { // We have enough and we have more. diff --git a/cmd/metacache-stream.go b/cmd/metacache-stream.go index fac52214a..cc2db5a43 100644 --- a/cmd/metacache-stream.go +++ b/cmd/metacache-stream.go @@ -519,7 +519,7 @@ func (r *metacacheReader) readN(n int, inclDeleted, inclDirs bool, prefix string if !inclDirs && meta.isDir() { continue } - if meta.isDir() && !inclDeleted && meta.isLatestDeletemarker() { + if !inclDeleted && meta.isLatestDeletemarker() { continue } res = append(res, meta)