Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 20 of 73 for dquorum (0.03 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. internal/dsync/lock-args_gen.go

    				return
    			}
    		case "Quorum":
    			if dc.IsNil() {
    				err = dc.ReadNil()
    				if err != nil {
    					err = msgp.WrapError(err, "Quorum")
    					return
    				}
    				z.Quorum = nil
    			} else {
    				if z.Quorum == nil {
    					z.Quorum = new(int)
    				}
    				*z.Quorum, err = dc.ReadInt()
    				if err != nil {
    					err = msgp.WrapError(err, "Quorum")
    					return
    				}
    			}
    		default:
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 10.2K bytes
    - Viewed (0)
  9. 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)
  10. 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)
Back to top