diff --git a/cmd/erasure-zones.go b/cmd/erasure-zones.go index 586e557a0..f44d98e76 100644 --- a/cmd/erasure-zones.go +++ b/cmd/erasure-zones.go @@ -22,6 +22,7 @@ import ( "io" "math/rand" "net/http" + "strconv" "strings" "sync" "time" @@ -2063,6 +2064,8 @@ func (z *erasureZones) Health(ctx context.Context, opts HealthOptions) HealthRes } } + reqInfo := (&logger.ReqInfo{}).AppendTags("maintenance", strconv.FormatBool(opts.Maintenance)) + for zoneIdx := range erasureSetUpCount { parityDrives := globalStorageClass.GetParityForSC(storageclass.STANDARD) diskCount := z.zones[zoneIdx].drivesPerSet @@ -2076,8 +2079,9 @@ func (z *erasureZones) Health(ctx context.Context, opts HealthOptions) HealthRes } for setIdx := range erasureSetUpCount[zoneIdx] { if erasureSetUpCount[zoneIdx][setIdx] < writeQuorum { - logger.LogIf(ctx, fmt.Errorf("Write quorum lost on zone: %d, set: %d, expected write quorum: %d", - zoneIdx, setIdx, writeQuorum)) + logger.LogIf(logger.SetReqInfo(ctx, reqInfo), + fmt.Errorf("Write quorum may be lost on zone: %d, set: %d, expected write quorum: %d", + zoneIdx, setIdx, writeQuorum)) return HealthResult{ Healthy: false, ZoneID: zoneIdx, @@ -2101,14 +2105,14 @@ func (z *erasureZones) Health(ctx context.Context, opts HealthOptions) HealthRes // is not taken down for maintenance aggHealStateResult, err := getAggregatedBackgroundHealState(ctx, true) if err != nil { - logger.LogIf(ctx, fmt.Errorf("Unable to verify global heal status: %w", err)) + logger.LogIf(logger.SetReqInfo(ctx, reqInfo), fmt.Errorf("Unable to verify global heal status: %w", err)) return HealthResult{ Healthy: false, } } if len(aggHealStateResult.HealDisks) > 0 { - logger.LogIf(ctx, fmt.Errorf("Total drives to be healed %d", len(aggHealStateResult.HealDisks))) + logger.LogIf(logger.SetReqInfo(ctx, reqInfo), fmt.Errorf("Total drives to be healed %d", len(aggHealStateResult.HealDisks))) } healthy := len(aggHealStateResult.HealDisks) == 0 diff --git a/pkg/disk/root_disk_unix.go b/pkg/disk/root_disk_unix.go index 4a1025fe6..83d68660e 100644 --- a/pkg/disk/root_disk_unix.go +++ b/pkg/disk/root_disk_unix.go @@ -31,7 +31,7 @@ func IsRootDisk(diskPath string) (bool, error) { if err != nil { return false, err } - rootInfo, err := os.Stat("/") + rootInfo, err := os.Stat("/etc/hosts") if err != nil { return false, err }