Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 2 of 2 for reduceWriteQuorumErrs (0.19 sec)

  1. cmd/erasure-object.go

    			}
    			diskVersions[index] = resp.Sign
    			dataDirs[index] = resp.OldDataDir
    			return nil
    		}, index)
    	}
    
    	// Wait for all renames to finish.
    	errs := g.Wait()
    
    	err := reduceWriteQuorumErrs(ctx, errs, objectOpIgnoredErrs, writeQuorum)
    	if err != nil {
    		dg := errgroup.WithNErrs(len(disks))
    		for index, nerr := range errs {
    			if nerr != nil {
    				continue
    			}
    			index := index
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Oct 31 22:10:24 UTC 2024
    - 78.8K bytes
    - Viewed (0)
  2. cmd/erasure-metadata.go

    				return disks[index].WriteMetadata(ctx, origbucket, bucket, prefix, fi)
    			}
    			return errFileCorrupt
    		}, index)
    	}
    
    	// Wait for all the routines.
    	mErrs := g.Wait()
    
    	err := reduceWriteQuorumErrs(ctx, mErrs, objectOpIgnoredErrs, quorum)
    	if err != nil && revert {
    		ng := errgroup.WithNErrs(len(disks))
    		for index := range disks {
    			if mErrs[index] != nil {
    				continue
    			}
    			index := index
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Oct 31 22:10:24 UTC 2024
    - 21.3K bytes
    - Viewed (0)
Back to top