- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 47 for dquorum (0.05 sec)
-
cmd/storage-datatypes.go
} // WriteQuorum returns expected write quorum for this FileInfo func (fi FileInfo) WriteQuorum(dquorum int) int { if fi.Deleted { 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 {
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Sun Sep 28 20:59:21 UTC 2025 - 17.4K bytes - Viewed (0) -
cmd/metacache-entries_test.go
// We get the both versions, since we only request quorum 1 wantSelected: &inputSerialized[2], wantOk: true, }, { name: "additional version, quorum two", m: metaCacheEntries{inputSerialized[0], inputSerialized[0], inputSerialized[0], inputSerialized[2]}, r: metadataResolutionParams{dirQuorum: 2, objQuorum: 2, strict: true},
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 31.6K bytes - Viewed (0) -
internal/dsync/drwmutex.go
tolerance := len(restClnts) / 2 // Quorum is effectively = total clients subtracted with tolerance limit quorum := len(restClnts) - tolerance if !isReadLock { // In situations for write locks, as a special case // to avoid split brains we make sure to acquire // quorum + 1 when tolerance is exactly half of the // total locker clients. if quorum == tolerance { quorum++ } }
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 20.3K bytes - Viewed (0) -
cmd/erasure-healing-common_test.go
} f.WriteString("oops") // Will cause bitrot error f.Close() break } } rQuorum := len(errs) - z.serverPools[0].sets[0].defaultParityCount onlineDisks, modTime, _ := listOnlineDisks(erasureDisks, partsMetadata, test.errs, rQuorum) if !modTime.Equal(test.expectedTime) { t.Fatalf("Expected modTime to be equal to %v but was found to be %v", test.expectedTime, modTime)
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 22.4K bytes - Viewed (0) -
cmd/erasure-object.go
return objInfo, wquorum, toObjectErr(errMethodNotAllowed, bucket, object) } if fi.Deleted { if opts.VersionID == "" || opts.DeleteMarker { return objInfo, wquorum, toObjectErr(errFileNotFound, bucket, object) } // Make sure to return object info to provide extra information. return objInfo, wquorum, toObjectErr(errMethodNotAllowed, bucket, object) }
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Fri Oct 24 04:05:31 UTC 2025 - 80.4K bytes - Viewed (0) -
cmd/peer-s3-client.go
for i, client := range sys.peerClients { if slices.Contains(client.GetPools(), poolIdx) { perPoolErrs = append(perPoolErrs, errs[i]) } } quorum := len(perPoolErrs) / 2 poolErrs = append(poolErrs, reduceWriteQuorumErrs(ctx, perPoolErrs, bucketOpIgnoredErrs, quorum)) } if !opts.Recreate { // when there is no force recreate look for pool // errors to recreate the bucket on all pools.Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 15.6K bytes - Viewed (0) -
cmd/erasure-metadata.go
return 0, 0, InvalidRange{} } func findFileInfoInQuorum(ctx context.Context, metaArr []FileInfo, modTime time.Time, etag string, quorum int) (FileInfo, error) { // with less quorum return error. if quorum < 1 { return FileInfo{}, InsufficientReadQuorum{Err: errErasureReadQuorum, Type: RQInsufficientOnlineDrives} } metaHashes := make([]string, len(metaArr)) h := sha256.New()Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Sun Sep 28 20:59:21 UTC 2025 - 21.3K bytes - Viewed (0) -
cmd/erasure-object-conditional_test.go
if !isErrReadQuorum(err) { t.Errorf("Expected read quorum error when if-none-match is used with quorum failure, got: %v", err) } }) t.Run("if-match with read quorum failure", func(t *testing.T) { // Test Case 2: if-match (update only if ETag matches) // With if-match: <etag>, this should only succeed if object exists with matching ETag. // Since read quorum fails, we can't determine if object exists or ETag matches.Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Fri Oct 24 04:05:31 UTC 2025 - 4.9K bytes - Viewed (0) -
cmd/erasure-multipart-conditional_test.go
if !isErrReadQuorum(err) { t.Errorf("Expected read quorum error when if-none-match is used with quorum failure, got: %v", err) } }) t.Run("if-match with wrong ETag and read quorum failure", func(t *testing.T) { // Test Case 2: if-match with WRONG ETag // This should fail even without quorum issues, but with quorum failure // we can't verify the ETag at all. opts := ObjectOptions{Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Fri Oct 24 04:05:31 UTC 2025 - 6.9K bytes - Viewed (0) -
cmd/local-locker_test.go
wResources := make([]string, 1000) rResources := make([]string, 1000) quorum := 0 l := newLocker() ctx := t.Context() for i := range wResources { arg := dsync.LockArgs{ UID: mustGetUUID(), Resources: []string{mustGetUUID()}, Source: t.Name(), Owner: "owner", Quorum: &quorum, } ok, err := l.Lock(ctx, arg) if err != nil { t.Fatal(err) } if !ok {
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 11.8K bytes - Viewed (0)