Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 5 of 5 for shuffleDisks (0.18 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] ||
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Thu Jan 18 07:03:17 GMT 2024
    - 7.4K bytes
    - Viewed (0)
  2. cmd/erasure-metadata-utils.go

    	}
    	return shuffledPartsMetadata
    }
    
    // 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) (shuffledDisks []StorageAPI) {
    	if distribution == nil {
    		return disks
    	}
    	shuffledDisks = make([]StorageAPI, len(disks))
    	// Shuffle disks for expected distribution.
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Tue Apr 23 17:15:52 GMT 2024
    - 11.3K bytes
    - Viewed (0)
  3. cmd/erasure-healing.go

    		healingLogOnceIf(ctx, err, "heal-object-available-disks")
    		return er.defaultHealResult(latestMeta, storageDisks, storageEndpoints, errs,
    			bucket, object, versionID), err
    	}
    
    	latestDisks := shuffleDisks(availableDisks, latestMeta.Erasure.Distribution)
    
    	if !latestMeta.Deleted && len(latestMeta.Erasure.Distribution) != len(outDatedDisks) {
    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)
  4. 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)
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Sun Apr 28 17:53:50 GMT 2024
    - 43K bytes
    - Viewed (0)
  5. 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)
    			}
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Wed Mar 27 15:10:40 GMT 2024
    - 47.6K bytes
    - Viewed (0)
Back to top