Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 8 of 8 for read_quorum (0.1 sec)

  1. cmd/erasure-metadata.go

    		if parity == -1 {
    			// Ignore non defined parity
    			continue
    		}
    
    		readQuorum := N - parity
    		if defaultParityCount > 0 && parity == 0 {
    			// In this case, parity == 0 implies that this object version is a
    			// delete marker
    			readQuorum = N/2 + 1
    		}
    		if occ < readQuorum {
    			// Ignore this parity since we don't have enough shards for read quorum
    			continue
    		}
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Oct 31 22:10:24 UTC 2024
    - 21.3K bytes
    - Viewed (0)
  2. cmd/erasure-multipart.go

    		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
    	}
    
    	quorum := readQuorum
    	if write {
    		quorum = writeQuorum
    	}
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Sep 29 22:40:36 UTC 2024
    - 44.7K bytes
    - Viewed (0)
  3. cmd/erasure-object.go

    	}
    
    	// List all online disks.
    	onlineDisks, modTime, etag := listOnlineDisks(storageDisks, metaArr, errs, readQuorum)
    
    	// Pick latest valid metadata.
    	fi, err := pickValidFileInfo(ctx, metaArr, modTime, etag, readQuorum)
    	if err != nil {
    		return oi, toObjectErr(err, srcBucket, srcObject)
    	}
    	if fi.Deleted {
    		if srcOpts.VersionID == "" {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Oct 31 22:10:24 UTC 2024
    - 78.8K bytes
    - Viewed (0)
  4. cmd/erasure-healing.go

    			errs, bucket, object, versionID), err
    	}
    
    	result.ParityBlocks = result.DiskCount - readQuorum
    	result.DataBlocks = readQuorum
    
    	// List of disks having latest version of the object xl.meta
    	// (by modtime).
    	onlineDisks, quorumModTime, quorumETag := listOnlineDisks(storageDisks, partsMetadata, errs, readQuorum)
    
    	// Latest FileInfo for reference. If a valid metadata is not
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Oct 02 17:50:41 UTC 2024
    - 34.4K bytes
    - Viewed (0)
  5. cmd/erasure-healing-common_test.go

    	if err != nil {
    		t.Fatalf("Failed to putObject %v", err)
    	}
    
    	_, errs := readAllFileInfo(ctx, erasureDisks, "", bucket, object, "", false, true)
    	readQuorum := len(erasureDisks) / 2
    	if reducedErr := reduceReadQuorumErrs(ctx, errs, objectOpIgnoredErrs, readQuorum); reducedErr != nil {
    		t.Fatalf("Failed to read xl meta data %v", reducedErr)
    	}
    
    	// Test 1: Test that all disks are returned without any failures with
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Oct 01 15:19:10 UTC 2024
    - 23.1K bytes
    - Viewed (0)
  6. cmd/erasure-server-pool.go

    	}
    
    	var maximumReadQuorum int
    	for _, readQuorum := range poolReadQuorums {
    		if maximumReadQuorum == 0 {
    			maximumReadQuorum = readQuorum
    		}
    		if readQuorum > maximumReadQuorum {
    			maximumReadQuorum = readQuorum
    		}
    	}
    
    	result := HealthResult{
    		Healthy:       true,
    		HealthyRead:   true,
    		WriteQuorum:   maximumWriteQuorum,
    		ReadQuorum:    maximumReadQuorum,
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Sep 29 22:40:36 UTC 2024
    - 89.8K bytes
    - Viewed (0)
  7. cmd/storage-datatypes.go

    		return dquorum
    	}
    	quorum := fi.Erasure.DataBlocks
    	if fi.Erasure.DataBlocks == fi.Erasure.ParityBlocks {
    		quorum++
    	}
    	return quorum
    }
    
    // ReadQuorum returns expected read quorum for this FileInfo
    func (fi FileInfo) ReadQuorum(dquorum int) int {
    	if fi.Deleted {
    		return dquorum
    	}
    	return fi.Erasure.DataBlocks
    }
    
    // Equals checks if fi(FileInfo) matches ofi(FileInfo)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Oct 22 15:30:50 UTC 2024
    - 17.3K bytes
    - Viewed (0)
  8. cmd/erasure-sets.go

    	return s.sets[s.getHashedSetIndex(input)]
    }
    
    // listDeletedBuckets lists deleted buckets from all disks.
    func listDeletedBuckets(ctx context.Context, storageDisks []StorageAPI, delBuckets map[string]VolInfo, readQuorum int) error {
    	g := errgroup.WithNErrs(len(storageDisks))
    	var mu sync.Mutex
    	for index := range storageDisks {
    		index := index
    		g.Go(func() error {
    			if storageDisks[index] == nil {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 27 10:41:37 UTC 2024
    - 37K bytes
    - Viewed (1)
Back to top