Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 5 of 5 for shuffledDisks (1.69 sec)

  1. cmd/erasure-metadata-utils_test.go

    	if shuffledDisks[0] != disks[8] ||
    		shuffledDisks[1] != disks[7] ||
    		shuffledDisks[2] != disks[9] ||
    		shuffledDisks[3] != disks[6] ||
    		shuffledDisks[4] != disks[10] ||
    		shuffledDisks[5] != disks[5] ||
    		shuffledDisks[6] != disks[11] ||
    		shuffledDisks[7] != disks[4] ||
    		shuffledDisks[8] != disks[12] ||
    		shuffledDisks[9] != disks[3] ||
    		shuffledDisks[10] != disks[13] ||
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 7.3K bytes
    - Viewed (0)
  2. cmd/erasure-metadata-utils.go

    // NewMultipartUpload metadata shuffling.
    func shuffleDisksAndPartsMetadataByIndex(disks []StorageAPI, metaArr []FileInfo, fi FileInfo) (shuffledDisks []StorageAPI, shuffledPartsMetadata []FileInfo) {
    	shuffledDisks = make([]StorageAPI, len(disks))
    	shuffledPartsMetadata = make([]FileInfo, len(disks))
    	distribution := fi.Erasure.Distribution
    
    	var inconsistent int
    	for i, meta := range metaArr {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 11.7K bytes
    - Viewed (0)
  3. cmd/erasure-healing_test.go

    			er := z.serverPools[0].getHashedSet(object)
    
    			disks := er.getDisks()
    			distribution := hashOrder(pathJoin(bucket, object), nDisks)
    			shuffledDisks := shuffleDisks(disks, distribution)
    
    			// remove last data shard
    			err = removeAll(pathJoin(shuffledDisks[11].String(), bucket, object))
    			if err != nil {
    				t.Fatalf("Failed to delete a file - %v", err)
    			}
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 48.5K bytes
    - Viewed (0)
  4. 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) {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 34.6K bytes
    - Viewed (0)
  5. 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)
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Sun Sep 07 16:13:09 UTC 2025
    - 47.3K bytes
    - Viewed (0)
Back to top