Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 3 of 3 for shuffleDisks (0.05 seconds)

The search processing time has exceeded the limit. The displayed results may be partial.

  1. cmd/erasure-metadata-utils.go

    func shuffleCheckParts(parts []int, distribution []int) []int {
    	return shuffleWithDist[int](parts, distribution)
    }
    
    // shuffleDisks - shuffle input disks slice depending on the
    // erasure distribution. Return shuffled slice of disks with
    // their expected distribution.
    func shuffleDisks(disks []StorageAPI, distribution []int) []StorageAPI {
    	return shuffleWithDist[StorageAPI](disks, distribution)
    }
    
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 11.7K bytes
    - Click Count (0)
  2. cmd/erasure-healing.go

    		healingLogOnceIf(ctx, err, "heal-object-online-disks")
    		return er.defaultHealResult(latestMeta, storageDisks, storageEndpoints, errs,
    			bucket, object, versionID), err
    	}
    
    	latestDisks := shuffleDisks(onlineDisks, latestMeta.Erasure.Distribution)
    
    	if !latestMeta.Deleted && len(latestMeta.Erasure.Distribution) != len(outDatedDisks) {
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 34.7K bytes
    - Click Count (0)
  3. cmd/erasure-multipart.go

    			return pi, InvalidArgument{
    				Bucket: bucket,
    				Object: fi.Name,
    				Err:    fmt.Errorf("checksum missing, want %q, got %q", cs, r.ContentCRCType().String()),
    			}
    		}
    	}
    	onlineDisks = shuffleDisks(onlineDisks, fi.Erasure.Distribution)
    
    	// Need a unique name for the part being written in minioMetaBucket to
    	// accommodate concurrent PutObjectPart requests
    
    	partSuffix := fmt.Sprintf("part.%d", partID)
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Oct 24 04:05:31 GMT 2025
    - 47.1K bytes
    - Click Count (0)
Back to Top