- Sort Score
- Result 10 results
- Languages All
Results 1 - 8 of 8 for read_quorum (0.1 sec)
-
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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)