Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for pushHealLocalDisks (0.29 sec)

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