Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 9 of 9 for defaultParityCount (0.18 sec)

  1. cmd/erasure.go

    	return nil
    }
    
    // defaultWQuorum write quorum based on setDriveCount and defaultParityCount
    func (er erasureObjects) defaultWQuorum() int {
    	dataCount := er.setDriveCount - er.defaultParityCount
    	if dataCount == er.defaultParityCount {
    		return dataCount + 1
    	}
    	return dataCount
    }
    
    // defaultRQuorum read quorum based on setDriveCount and defaultParityCount
    func (er erasureObjects) defaultRQuorum() int {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Oct 04 22:23:33 UTC 2024
    - 16.1K bytes
    - Viewed (0)
  2. cmd/erasure-metadata.go

    }
    
    func commonParity(parities []int, defaultParityCount int) int {
    	N := len(parities)
    
    	occMap := make(map[int]int)
    	for _, p := range parities {
    		occMap[p]++
    	}
    
    	var maxOcc, cparity int
    	for parity, occ := range occMap {
    		if parity == -1 {
    			// Ignore non defined parity
    			continue
    		}
    
    		readQuorum := N - parity
    		if defaultParityCount > 0 && parity == 0 {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Oct 31 22:10:24 UTC 2024
    - 21.3K bytes
    - Viewed (0)
  3. cmd/erasure-healing-common_test.go

    func getLatestFileInfo(ctx context.Context, partsMetadata []FileInfo, defaultParityCount int, errs []error) (FileInfo, error) {
    	// There should be at least half correct entries, if not return failure
    	expectedRQuorum := len(partsMetadata) / 2
    	if defaultParityCount == 0 {
    		// if parity count is '0', we expected all entries to be present.
    		expectedRQuorum = len(partsMetadata)
    	}
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Oct 01 15:19:10 UTC 2024
    - 23.1K bytes
    - Viewed (0)
  4. cmd/erasure-healing_test.go

    		er := set.sets[0]
    		erasureDisks := er.getDisks()
    
    		fileInfos, errs := readAllFileInfo(ctx, erasureDisks, "", bucket, object, "", false, true)
    		nfi, err := getLatestFileInfo(ctx, fileInfos, er.defaultParityCount, errs)
    		if errors.Is(err, errFileNotFound) {
    			continue
    		}
    		if err != nil {
    			t.Fatalf("Failed to getLatestFileInfo - %v", err)
    		}
    
    		for i := 0; i < nfi.Erasure.ParityBlocks; i++ {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jun 10 15:51:27 UTC 2024
    - 49K bytes
    - Viewed (0)
  5. cmd/erasure-sets.go

    		erasureLockOwner:   globalLocalNodeName,
    		endpoints:          endpoints,
    		endpointStrings:    endpointStrings,
    		setCount:           setCount,
    		setDriveCount:      setDriveCount,
    		defaultParityCount: defaultParityCount,
    		format:             format,
    		distributionAlgo:   format.Erasure.DistributionAlgo,
    		deploymentID:       uuid.MustParse(format.ID),
    		poolIndex:          poolIdx,
    	}
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 27 10:41:37 UTC 2024
    - 37K bytes
    - Viewed (1)
  6. cmd/erasure-object.go

    		tags["d:p"] = fmt.Sprintf("%d:%d", m.Erasure.DataBlocks, m.Erasure.ParityBlocks)
    	} else {
    		tags["invalid"] = "1"
    		tags["d:p"] = fmt.Sprintf("%d:%d", er.setDriveCount-er.defaultParityCount, er.defaultParityCount)
    	}
    
    	// count the number of offline disks
    	offline := 0
    	for i := 0; i < len(errs); i++ {
    		var found bool
    		switch {
    		case errors.Is(errs[i], errDiskNotFound):
    			found = true
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Oct 31 22:10:24 UTC 2024
    - 78.8K bytes
    - Viewed (0)
  7. cmd/erasure-healing.go

    	hr = madmin.HealResultItem{
    		Type:         madmin.HealItemObject,
    		Bucket:       bucket,
    		Object:       object,
    		DiskCount:    len(storageDisks),
    		ParityBlocks: er.defaultParityCount,
    		DataBlocks:   len(storageDisks) - er.defaultParityCount,
    		ObjectSize:   0,
    	}
    
    	hr.Before.Drives = make([]madmin.HealDriveInfo, len(storageDisks))
    	hr.After.Drives = make([]madmin.HealDriveInfo, len(storageDisks))
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Oct 02 17:50:41 UTC 2024
    - 34.4K bytes
    - Viewed (0)
  8. cmd/erasure-multipart.go

    	partsMetadata, errs := readAllFileInfo(ctx, storageDisks, bucket, minioMetaMultipartBucket,
    		uploadIDPath, "", false, false)
    
    	readQuorum, writeQuorum, err := objectQuorumFromMeta(ctx, partsMetadata, errs, er.defaultParityCount)
    	if err != nil {
    		return fi, nil, err
    	}
    
    	if readQuorum < 0 {
    		return fi, nil, errErasureReadQuorum
    	}
    
    	if writeQuorum < 0 {
    		return fi, nil, errErasureWriteQuorum
    	}
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Sep 29 22:40:36 UTC 2024
    - 44.7K bytes
    - Viewed (0)
  9. cmd/erasure-server-pool.go

    func (z *erasureServerPools) BackendInfo() (b madmin.BackendInfo) {
    	b.Type = madmin.Erasure
    
    	scParity := globalStorageClass.GetParityForSC(storageclass.STANDARD)
    	if scParity < 0 {
    		scParity = z.serverPools[0].defaultParityCount
    	}
    	rrSCParity := globalStorageClass.GetParityForSC(storageclass.RRS)
    
    	// Data blocks can vary per pool, but parity is same.
    	for i, setDriveCount := range z.SetDriveCounts() {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Sep 29 22:40:36 UTC 2024
    - 89.8K bytes
    - Viewed (0)
Back to top