Search Options

Results per page
Sort
Preferred Languages
Advance

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

  1. cmd/background-newdisks-heal-ops.go

    	if env.Get("_MINIO_AUTO_DRIVE_HEALING", config.EnableOn) == config.EnableOn || env.Get("_MINIO_AUTO_DISK_HEALING", config.EnableOn) == config.EnableOn {
    		globalBackgroundHealState.pushHealLocalDisks(getLocalDisksToHeal()...)
    		go monitorLocalDisksAndHeal(ctx, z)
    	}
    }
    
    func getLocalDisksToHeal() (disksToHeal Endpoints) {
    	globalLocalDrivesMu.RLock()
    	localDrives := cloneDrives(globalLocalDrives)
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 14.7K bytes
    - Viewed (0)
  2. cmd/erasure-sets.go

    			if err != nil {
    				if endpoint.IsLocal && errors.Is(err, errUnformattedDisk) {
    					globalBackgroundHealState.pushHealLocalDisks(endpoint)
    				} else {
    					printEndpointError(endpoint, err, true)
    				}
    				return
    			}
    			if disk.IsLocal() && disk.Healing() != nil {
    				globalBackgroundHealState.pushHealLocalDisks(disk.Endpoint())
    			}
    			s.erasureDisksMu.Lock()
    			setIndex, diskIndex, err := findDiskIndex(s.format, format)
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Mon Apr 15 08:25:46 GMT 2024
    - 37.5K bytes
    - Viewed (5)
  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
    	}
    }
    
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 25.1K bytes
    - Viewed (1)
Back to top