diff --git a/cmd/data-scanner.go b/cmd/data-scanner.go index 844ae8e36..e3b95b3bf 100644 --- a/cmd/data-scanner.go +++ b/cmd/data-scanner.go @@ -734,11 +734,7 @@ func (f *folderScanner) scanFolder(ctx context.Context, folder cachedFolder, int } }, // Some disks have data for this. - partial: func(entries metaCacheEntries, nAgreed int, errs []error) { - if f.dataUsageScannerDebug { - console.Debugf(healObjectsPrefix+" got partial, %d agreed, errs: %v\n", nAgreed, errs) - } - + partial: func(entries metaCacheEntries, errs []error) { entry, ok := entries.resolve(&resolver) if !ok { // check if we can get one entry atleast diff --git a/cmd/erasure-server-pool-decom.go b/cmd/erasure-server-pool-decom.go index a57fc77fa..cfae29377 100644 --- a/cmd/erasure-server-pool-decom.go +++ b/cmd/erasure-server-pool-decom.go @@ -804,7 +804,7 @@ func (z *erasureServerPools) decommissionPool(ctx context.Context, idx int, pool wg.Add(1) go decommissionEntry(entry) }, - partial: func(entries metaCacheEntries, nAgreed int, errs []error) { + partial: func(entries metaCacheEntries, _ []error) { entry, ok := entries.resolve(&resolver) if ok { parallelWorkers <- struct{}{} diff --git a/cmd/erasure-server-pool.go b/cmd/erasure-server-pool.go index e9972260c..f3cb002d6 100644 --- a/cmd/erasure-server-pool.go +++ b/cmd/erasure-server-pool.go @@ -1822,7 +1822,7 @@ func (z *erasureServerPools) Walk(ctx context.Context, bucket, prefix string, re minDisks: 1, reportNotFound: false, agreed: loadEntry, - partial: func(entries metaCacheEntries, nAgreed int, errs []error) { + partial: func(entries metaCacheEntries, _ []error) { entry, ok := entries.resolve(&resolver) if !ok { // check if we can get one entry atleast @@ -1889,7 +1889,7 @@ func listAndHeal(ctx context.Context, bucket, prefix string, set *erasureObjects cancel() } }, - partial: func(entries metaCacheEntries, nAgreed int, errs []error) { + partial: func(entries metaCacheEntries, _ []error) { entry, ok := entries.resolve(&resolver) if !ok { // check if we can get one entry atleast diff --git a/cmd/erasure-single-drive.go b/cmd/erasure-single-drive.go index f030f0aad..3ba476fbc 100644 --- a/cmd/erasure-single-drive.go +++ b/cmd/erasure-single-drive.go @@ -2984,7 +2984,7 @@ func (es *erasureSingle) Walk(ctx context.Context, bucket, prefix string, result minDisks: 1, reportNotFound: false, agreed: loadEntry, - partial: func(entries metaCacheEntries, nAgreed int, errs []error) { + partial: func(entries metaCacheEntries, _ []error) { entry, ok := entries.resolve(&resolver) if !ok { // check if we can get one entry atleast diff --git a/cmd/global-heal.go b/cmd/global-heal.go index 0d3e0baca..ad3b7e4f4 100644 --- a/cmd/global-heal.go +++ b/cmd/global-heal.go @@ -316,7 +316,7 @@ func (er *erasureObjects) healErasureSet(ctx context.Context, buckets []string, minDisks: 1, reportNotFound: false, agreed: healEntry, - partial: func(entries metaCacheEntries, nAgreed int, errs []error) { + partial: func(entries metaCacheEntries, _ []error) { entry, ok := entries.resolve(&resolver) if !ok { // check if we can get one entry atleast diff --git a/cmd/metacache-set.go b/cmd/metacache-set.go index 37f72a582..02538fa3a 100644 --- a/cmd/metacache-set.go +++ b/cmd/metacache-set.go @@ -760,7 +760,7 @@ func (es *erasureSingle) listPathInner(ctx context.Context, o listPathOptions, r case results <- entry: } }, - partial: func(entries metaCacheEntries, nAgreed int, errs []error) { + partial: func(entries metaCacheEntries, errs []error) { // Results Disagree :-( entry, ok := entries.resolve(&resolver) if ok { @@ -829,7 +829,7 @@ func (er *erasureObjects) listPath(ctx context.Context, o listPathOptions, resul case results <- entry: } }, - partial: func(entries metaCacheEntries, nAgreed int, errs []error) { + partial: func(entries metaCacheEntries, errs []error) { // Results Disagree :-( entry, ok := entries.resolve(&resolver) if ok { @@ -1145,7 +1145,7 @@ type listPathRawOptions struct { // partial will be called when there is disagreement between disks. // if disk did not return any result, but also haven't errored // the entry will be empty and errs will - partial func(entries metaCacheEntries, nAgreed int, errs []error) + partial func(entries metaCacheEntries, errs []error) // finished will be called when all streams have finished and // more than one disk returned an error. @@ -1362,7 +1362,7 @@ func listPathRaw(ctx context.Context, opts listPathRawOptions) (err error) { continue } if opts.partial != nil { - opts.partial(topEntries, agree, errs) + opts.partial(topEntries, errs) } // Skip the inputs we used. for i, r := range readers {