- Sort Score
- Result 10 results
- Languages All
Results 1 - 2 of 2 for startMRFPersistence (0.31 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 Oct 27 19:28:09 UTC 2024 - Last Modified: Tue Aug 13 22:26:05 UTC 2024 - 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 Oct 27 19:28:09 UTC 2024 - Last Modified: Sat Oct 26 09:58:27 UTC 2024 - 16.6K bytes - Viewed (0)