Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 9 of 9 for reduceReadQuorumErrs (0.19 sec)

  1. cmd/peer-s3-server.go

    					return nil
    				}
    				return err
    			}
    
    			bucketsInfo[index] = BucketInfo{Name: bucket, Created: volInfo.Created}
    			return nil
    		}, index)
    	}
    
    	errs := g.Wait()
    	if err := reduceReadQuorumErrs(ctx, errs, bucketOpIgnoredErrs, (len(localDrives) / 2)); err != nil {
    		return BucketInfo{}, err
    	}
    
    	var bucketInfo BucketInfo
    	for i, err := range errs {
    		if err == nil {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 22 21:57:20 UTC 2024
    - 8.1K bytes
    - Viewed (0)
  2. 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 Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 11.7K bytes
    - Viewed (0)
  3. 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 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-metadata-utils_test.go

    		{canceledErrs, nil, context.Canceled},
    	}
    	// Validates list of all the testcases for returning valid errors.
    	for i, testCase := range testCases {
    		gotErr := reduceReadQuorumErrs(context.Background(), testCase.errs, testCase.ignoredErrs, 5)
    		if gotErr != testCase.err {
    			t.Errorf("Test %d : expected %s, got %s", i+1, testCase.err, gotErr)
    		}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Jan 18 07:03:17 UTC 2024
    - 7.4K bytes
    - Viewed (0)
  5. 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 Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Sep 29 22:40:36 UTC 2024
    - 44.7K bytes
    - Viewed (0)
  6. 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 Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Oct 31 22:10:24 UTC 2024
    - 21.3K bytes
    - Viewed (0)
  7. cmd/erasure-healing.go

    				}
    				mu.Lock()
    				if _, ok := healBuckets[volInfo.Name]; !ok {
    					healBuckets[volInfo.Name] = volInfo
    				}
    				mu.Unlock()
    			}
    			return nil
    		}, index)
    	}
    	return reduceReadQuorumErrs(ctx, g.Wait(), bucketMetadataOpIgnoredErrs, readQuorum)
    }
    
    var errLegacyXLMeta = errors.New("legacy XL meta")
    
    var errOutdatedXLMeta = errors.New("outdated XL meta")
    
    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-sets.go

    					mu.Lock()
    					if _, ok := delBuckets[volName]; !ok {
    						delBuckets[volName] = vi
    					}
    					mu.Unlock()
    				}
    			}
    			return nil
    		}, index)
    	}
    	return reduceReadQuorumErrs(ctx, g.Wait(), bucketMetadataOpIgnoredErrs, readQuorum)
    }
    
    // --- Object Operations ---
    
    // GetObjectNInfo - returns object info and locked object ReadCloser
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 27 10:41:37 UTC 2024
    - 37K bytes
    - Viewed (1)
  9. cmd/erasure-object.go

    		readQuorum, _, err := objectQuorumFromMeta(ctx, metaArr, errs, er.defaultParityCount)
    		if err != nil {
    			return FileInfo{}, nil, nil, time.Time{}, "", err
    		}
    		if err := reduceReadQuorumErrs(ctx, errs, objectOpIgnoredErrs, readQuorum); err != nil {
    			return FileInfo{}, nil, nil, time.Time{}, "", err
    		}
    		onlineDisks, modTime, etag := listOnlineDisks(disks, metaArr, errs, readQuorum)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Oct 31 22:10:24 UTC 2024
    - 78.8K bytes
    - Viewed (0)
Back to top