Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 2 of 2 for startMRFPersistence (0.13 sec)

  1. 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)
  2. 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)
Back to top