- Sort Score
- Result 10 results
- Languages All
Results 1 - 3 of 3 for pushHealLocalDisks (0.18 sec)
-
cmd/background-newdisks-heal-ops.go
if env.Get("_MINIO_AUTO_DRIVE_HEALING", config.EnableOn) == config.EnableOn || env.Get("_MINIO_AUTO_DISK_HEALING", config.EnableOn) == config.EnableOn { globalBackgroundHealState.pushHealLocalDisks(getLocalDisksToHeal()...) go monitorLocalDisksAndHeal(ctx, z) } } func getLocalDisksToHeal() (disksToHeal Endpoints) { globalLocalDrivesMu.RLock() localDrives := cloneDrives(globalLocalDrives)
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 14.7K bytes - Viewed (0) -
cmd/erasure-sets.go
if err != nil { if endpoint.IsLocal && errors.Is(err, errUnformattedDisk) { globalBackgroundHealState.pushHealLocalDisks(endpoint) } else { printEndpointError(endpoint, err, true) } return } if disk.IsLocal() && disk.Healing() != nil { globalBackgroundHealState.pushHealLocalDisks(disk.Endpoint()) } s.erasureDisksMu.Lock() setIndex, diskIndex, err := findDiskIndex(s.format, format)
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Mon Apr 15 08:25:46 GMT 2024 - 37.5K bytes - Viewed (5) -
cmd/admin-heal-ops.go
func (ahs *allHealState) setDiskHealingStatus(ep Endpoint, healing bool) { ahs.Lock() defer ahs.Unlock() ahs.healLocalDisks[ep] = healing } func (ahs *allHealState) pushHealLocalDisks(healLocalDisks ...Endpoint) { ahs.Lock() defer ahs.Unlock() for _, ep := range healLocalDisks { ahs.healLocalDisks[ep] = false } }
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 25.1K bytes - Viewed (1)