Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for reduceWriteQuorumErrs (0.12 sec)

  1. cmd/peer-s3-server.go

    		index := index
    		g.Go(func() error {
    			if localDrives[index] == nil {
    				return errDiskNotFound
    			}
    			return localDrives[index].DeleteVol(ctx, bucket, opts.Force)
    		}, index)
    	}
    
    	return reduceWriteQuorumErrs(ctx, g.Wait(), bucketOpIgnoredErrs, (len(localDrives)/2)+1)
    }
    
    func makeBucketLocal(ctx context.Context, bucket string, opts MakeBucketOptions) error {
    	globalLocalDrivesMu.RLock()
    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-encode.go

    	// CreateFile with p.writeQuorum=1 to accommodate healing of single disk.
    	// i.e if we do no return here in such a case, reduceWriteQuorumErrs() would
    	// return a quorum error to HealFile().
    	nilCount := countErrs(p.errs, nil)
    	if nilCount >= p.writeQuorum {
    		return nil
    	}
    
    	writeErr := reduceWriteQuorumErrs(ctx, p.errs, objectOpIgnoredErrs, p.writeQuorum)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed May 15 00:11:04 UTC 2024
    - 2.9K bytes
    - Viewed (0)
  3. cmd/erasure-metadata-utils_test.go

    		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)
    		}
    		gotNewErr := reduceWriteQuorumErrs(context.Background(), testCase.errs, testCase.ignoredErrs, 6)
    		if gotNewErr != errErasureWriteQuorum {
    			t.Errorf("Test %d : expected %s, got %s", i+1, errErasureWriteQuorum, 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)
Back to top