diff --git a/cmd/xl-storage-disk-id-check.go b/cmd/xl-storage-disk-id-check.go index 9f40fb7f0..dd745eebc 100644 --- a/cmd/xl-storage-disk-id-check.go +++ b/cmd/xl-storage-disk-id-check.go @@ -175,10 +175,12 @@ func (p *xlStorageDiskIDCheck) Healing() *healingTracker { func (p *xlStorageDiskIDCheck) NSScanner(ctx context.Context, cache dataUsageCache, updates chan<- dataUsageEntry, scanMode madmin.HealScanMode) (dataUsageCache, error) { if contextCanceled(ctx) { + close(updates) return dataUsageCache{}, ctx.Err() } if err := p.checkDiskStale(); err != nil { + close(updates) return dataUsageCache{}, err } return p.storage.NSScanner(ctx, cache, updates, scanMode)