mirror of https://github.com/minio/minio.git
heal: Do not mark buckets as done when there is no online disks (#16621)
This commit is contained in:
parent
15a75bd79b
commit
857674c3a0
|
@ -383,6 +383,10 @@ func healFreshDisk(ctx context.Context, z *erasureServerPools, endpoint Endpoint
|
||||||
logger.Info("Healing drive '%s' complete (healed: %d, failed: %d).", disk, tracker.ItemsHealed, tracker.ItemsFailed)
|
logger.Info("Healing drive '%s' complete (healed: %d, failed: %d).", disk, tracker.ItemsHealed, tracker.ItemsFailed)
|
||||||
}
|
}
|
||||||
|
|
||||||
|
if len(tracker.QueuedBuckets) > 0 {
|
||||||
|
return fmt.Errorf("not all buckets were healed: %v", tracker.QueuedBuckets)
|
||||||
|
}
|
||||||
|
|
||||||
if serverDebugLog {
|
if serverDebugLog {
|
||||||
tracker.printTo(os.Stdout)
|
tracker.printTo(os.Stdout)
|
||||||
logger.Info("\n")
|
logger.Info("\n")
|
||||||
|
|
|
@ -214,11 +214,7 @@ func (er *erasureObjects) healErasureSet(ctx context.Context, buckets []string,
|
||||||
|
|
||||||
disks, _ := er.getOnlineDisksWithHealing()
|
disks, _ := er.getOnlineDisksWithHealing()
|
||||||
if len(disks) == 0 {
|
if len(disks) == 0 {
|
||||||
// all disks are healing in this set, this is allowed
|
logger.LogIf(ctx, fmt.Errorf("no online disks found to heal the bucket `%s`", bucket))
|
||||||
// so we simply proceed to next bucket, marking the bucket
|
|
||||||
// as done as there are no objects to heal.
|
|
||||||
tracker.bucketDone(bucket)
|
|
||||||
logger.LogIf(ctx, tracker.update(ctx))
|
|
||||||
continue
|
continue
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
Loading…
Reference in New Issue