- Sort Score
- Result 10 results
- Languages All
Results 1 - 2 of 2 for startMRFPersistence (0.2 sec)
-
cmd/mrf.go
err := localDrive.CreateFile(context.Background(), "", minioMetaBucket, pathJoin(healMRFDir, "list.bin"), -1, r) r.Close() if err == nil { break } } } func (m *mrfState) startMRFPersistence() { loadMRF := func(rc io.ReadCloser, opCh chan PartialOperation) error { defer rc.Close() var data [4]byte n, err := rc.Read(data[:]) if err != nil { return err } if n != len(data) {
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Tue May 27 15:19:03 UTC 2025 - 6.5K bytes - Viewed (0) -
cmd/background-newdisks-heal-ops.go
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) { globalLocalDrivesMu.RLock() localDrives := cloneDrives(globalLocalDrivesMap) globalLocalDrivesMu.RUnlock()
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 16.5K bytes - Viewed (0)