Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 4 of 4 for getOnlineDisksWithHealing (0.29 sec)

  1. cmd/erasure.go

    	/// Then add healing disks.
    	newDisks = append(newDisks, healingDisks...)
    	newInfos = append(newInfos, healingInfos...)
    
    	return newDisks, newInfos, healing
    }
    
    func (er erasureObjects) getOnlineDisksWithHealing(inclHealing bool) ([]StorageAPI, bool) {
    	newDisks, _, healing := er.getOnlineDisksWithHealingAndInfo(inclHealing)
    	return newDisks, healing > 0
    }
    
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Fri Apr 26 06:32:14 GMT 2024
    - 16K bytes
    - Viewed (1)
  2. cmd/erasure-server-pool-rebalance.go

    		return true
    	}
    
    	return false
    }
    
    func (set *erasureObjects) listObjectsToRebalance(ctx context.Context, bucketName string, fn func(entry metaCacheEntry)) error {
    	disks, _ := set.getOnlineDisksWithHealing(false)
    	if len(disks) == 0 {
    		return fmt.Errorf("no online drives found for set with endpoints %s", set.getEndpoints())
    	}
    
    	// However many we ask, versions must exist on ~50%
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Fri Apr 26 19:29:28 GMT 2024
    - 27.2K bytes
    - Viewed (0)
  3. cmd/erasure-server-pool-decom.go

    		return v[i].ModTime.Before(v[j].ModTime)
    	})
    }
    
    func (set *erasureObjects) listObjectsToDecommission(ctx context.Context, bi decomBucketInfo, fn func(entry metaCacheEntry)) error {
    	disks, _ := set.getOnlineDisksWithHealing(false)
    	if len(disks) == 0 {
    		return fmt.Errorf("no online drives found for set with endpoints %s", set.getEndpoints())
    	}
    
    	// However many we ask, versions must exist on ~50%
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Mon Apr 22 17:49:30 GMT 2024
    - 41.3K bytes
    - Viewed (1)
  4. cmd/erasure-healing.go

    	ctx, cancel := context.WithCancel(ctx)
    	defer cancel()
    
    	disks, _ := er.getOnlineDisksWithHealing(false)
    	if len(disks) == 0 {
    		return errors.New("listAndHeal: No non-healing drives found")
    	}
    
    	expectedDisks := len(disks)/2 + 1
    	fallbackDisks := disks[expectedDisks:]
    	disks = disks[:expectedDisks]
    
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Fri Apr 26 06:32:14 GMT 2024
    - 33.1K bytes
    - Viewed (0)
Back to top