- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 73 for dquorum (0.03 sec)
-
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) -
cmd/erasure-healing-common.go
// occurs >= quorum, else return timeSentinel func commonTime(modTimes []time.Time, quorum int) time.Time { if modTime, count := commonTimeAndOccurrence(modTimes, 0); count >= quorum { return modTime } return timeSentinel } func commonETag(etags []string, quorum int) string { if etag, count := commonETags(etags); count >= quorum { return etag } return "" }
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Sun Sep 28 20:59:21 UTC 2025 - 12K bytes - Viewed (0) -
docs/metrics/healthcheck/README.md
## Cluster probe ### Cluster-writeable probe The reply is '200 OK' if cluster has write quorum if not it returns '503 Service Unavailable'. ``` curl http://minio1:9001/minio/health/cluster HTTP/1.1 503 Service Unavailable Accept-Ranges: bytes Content-Length: 0 Server: MinIO Vary: Origin X-Amz-Bucket-Region: us-east-1 X-Minio-Write-Quorum: 3 X-Amz-Request-Id: 16239D6AB80EBECF X-Xss-Protection: 1; mode=block
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Thu Jul 06 16:18:38 UTC 2023 - 2.5K bytes - Viewed (0) -
cmd/erasure-metadata-utils.go
// GetValueWithQuorum returns the first key which occurs >= quorum number of times. func (c counterMap[T]) GetValueWithQuorum(quorum int) (T, bool) { var zero T for x, count := range c { if count >= quorum { return x, true } } return zero, false } // figure out the most commonVersions across disk that satisfies // the 'writeQuorum' this function returns "" if quorum cannot
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 11.7K bytes - Viewed (0) -
internal/dsync/lock-args_gen.go
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Sun Sep 28 20:59:21 UTC 2025 - 10.2K bytes - Viewed (0) -
internal/dsync/lock-args.go
Owner string // Source contains the line number, function and file name of the code // on the client node that requested the lock. Source string `msgp:"omitempty"` // Quorum represents the expected quorum for this lock type. Quorum *int `msgp:"omitempty"` } // ResponseCode is the response code for a locking request. type ResponseCode uint8 // Response codes for a locking request. const (
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Wed Jul 24 10:24:01 UTC 2024 - 1.8K bytes - Viewed (0) -
cmd/local-locker_gen.go
return } case "Owner": z.Owner, err = dc.ReadString() if err != nil { err = msgp.WrapError(err, "Owner") return } case "Quorum": z.Quorum, err = dc.ReadInt() if err != nil { err = msgp.WrapError(err, "Quorum") return } default: err = dc.Skip() if err != nil { err = msgp.WrapError(err) return } } } return }
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Sun Sep 28 20:59:21 UTC 2025 - 16.6K bytes - Viewed (0)