Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for reduceReadQuorumErrs (0.08 sec)

  1. cmd/erasure-metadata-utils.go

    	}
    	maxCount, maxErr := reduceErrs(errs, ignoredErrs)
    	if maxCount >= quorum {
    		return maxErr
    	}
    	return quorumErr
    }
    
    // reduceReadQuorumErrs behaves like reduceErrs but only for returning
    // values of maximally occurring errors validated against readQuorum.
    func reduceReadQuorumErrs(ctx context.Context, errs []error, ignoredErrs []error, readQuorum int) (maxErr error) {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 11.7K bytes
    - Viewed (0)
  2. cmd/erasure-healing-common_test.go

    	expectedRQuorum := len(partsMetadata) / 2
    	if defaultParityCount == 0 {
    		// if parity count is '0', we expected all entries to be present.
    		expectedRQuorum = len(partsMetadata)
    	}
    
    	reducedErr := reduceReadQuorumErrs(ctx, errs, objectOpIgnoredErrs, expectedRQuorum)
    	if reducedErr != nil {
    		return FileInfo{}, reducedErr
    	}
    
    	// List all the file commit ids from parts metadata.
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 22.4K bytes
    - Viewed (0)
  3. cmd/erasure-multipart.go

    	_, modTime, etag := listOnlineDisks(storageDisks, partsMetadata, errs, quorum)
    
    	if write {
    		err = reduceWriteQuorumErrs(ctx, errs, objectOpIgnoredErrs, writeQuorum)
    	} else {
    		err = reduceReadQuorumErrs(ctx, errs, objectOpIgnoredErrs, readQuorum)
    	}
    	if err != nil {
    		return fi, nil, err
    	}
    
    	// Pick one from the first valid metadata.
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Sun Sep 07 16:13:09 UTC 2025
    - 47.3K bytes
    - Viewed (0)
  4. cmd/erasure-metadata.go

    	expectedRQuorum := len(partsMetaData) / 2
    	if defaultParityCount == 0 {
    		// if parity count is '0', we expected all entries to be present.
    		expectedRQuorum = len(partsMetaData)
    	}
    
    	reducedErr := reduceReadQuorumErrs(ctx, errs, objectOpIgnoredErrs, expectedRQuorum)
    	if reducedErr != nil {
    		return -1, -1, reducedErr
    	}
    
    	// special case when parity is '0'
    	if defaultParityCount == 0 {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 21.3K bytes
    - Viewed (0)
  5. cmd/erasure-healing.go

    					}
    					return VolInfo{
    						Name:    volInfo.Name,
    						Created: volInfo.Created,
    						count:   1,
    					}, false
    				})
    			}
    
    			return nil
    		}, index)
    	}
    
    	if err := reduceReadQuorumErrs(ctx, g.Wait(), bucketMetadataOpIgnoredErrs, readQuorum); err != nil {
    		return err
    	}
    
    	healBuckets.Range(func(volName string, volInfo VolInfo) bool {
    		if volInfo.count < readQuorum {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 34.6K bytes
    - Viewed (0)
  6. cmd/erasure-sets.go

    				if err == nil {
    					vi.Name = strings.TrimSuffix(volName, SlashSeparator)
    					delBuckets.Store(volName, vi)
    				}
    			}
    			return nil
    		}, index)
    	}
    	return reduceReadQuorumErrs(ctx, g.Wait(), bucketMetadataOpIgnoredErrs, readQuorum)
    }
    
    // --- Object Operations ---
    
    // GetObjectNInfo - returns object info and locked object ReadCloser
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 37K bytes
    - Viewed (1)
Back to top