- Sort Score
- Result 10 results
- Languages All
Results 1 - 3 of 3 for pushHealLocalDisks (0.29 sec)
-
cmd/background-newdisks-heal-ops.go
if !ok { return } initBackgroundHealing(ctx, objAPI) // start quick background healing if env.Get("_MINIO_AUTO_DRIVE_HEALING", config.EnableOn) == config.EnableOn { globalBackgroundHealState.pushHealLocalDisks(getLocalDisksToHeal()...) go monitorLocalDisksAndHeal(ctx, z) } go globalMRFState.startMRFPersistence() go globalMRFState.healRoutine(z) } func getLocalDisksToHeal() (disksToHeal Endpoints) {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Sat Oct 26 09:58:27 UTC 2024 - 16.6K bytes - Viewed (0) -
cmd/erasure-sets.go
globalBackgroundHealState.pushHealLocalDisks(endpoint) } else if !errors.Is(err, errDriveIsRoot) { if log { printEndpointError(endpoint, err, true) } } return } if disk.IsLocal() { h := disk.Healing() if h != nil && !h.Finished { globalBackgroundHealState.pushHealLocalDisks(disk.Endpoint()) } } s.erasureDisksMu.Lock()
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri Sep 27 10:41:37 UTC 2024 - 37K bytes - Viewed (1) -
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 } }
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Sat Oct 26 09:58:27 UTC 2024 - 25.6K bytes - Viewed (0)