Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 20 of 72 for dquorum (0.11 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 Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Oct 31 22:10:24 UTC 2024
    - 21.3K bytes
    - Viewed (0)
  2. cmd/local-locker_test.go

    	wResources := make([]string, 1000)
    	rResources := make([]string, 1000)
    	quorum := 0
    	l := newLocker()
    	ctx := context.Background()
    	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)
    		}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Jul 24 10:24:01 UTC 2024
    - 11.9K bytes
    - Viewed (0)
  3. 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 Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Oct 31 22:10:24 UTC 2024
    - 12.7K bytes
    - Viewed (0)
  4. 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 Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Jul 06 16:18:38 UTC 2023
    - 2.5K bytes
    - Viewed (0)
  5. 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 Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 11.7K bytes
    - Viewed (0)
  6. 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 Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Jul 24 10:24:01 UTC 2024
    - 10.2K bytes
    - Viewed (0)
  7. 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 Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Jul 24 10:24:01 UTC 2024
    - 13.9K bytes
    - Viewed (0)
  8. 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 Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Jul 24 10:24:01 UTC 2024
    - 1.8K bytes
    - Viewed (0)
  9. cmd/metacache-set.go

    				return entries, io.EOF
    			}
    			partN++
    			retries = 0
    		}
    	}
    }
    
    // getListQuorum interprets list quorum values and returns appropriate
    // acceptable quorum expected for list operations
    func getListQuorum(quorum string, driveCount int) int {
    	switch quorum {
    	case "disk":
    		return 1
    	case "reduced":
    		return 2
    	case "optimal":
    		return (driveCount + 1) / 2
    	case "auto":
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jul 12 16:23:16 UTC 2024
    - 30.7K bytes
    - Viewed (0)
  10. docs/metrics/prometheus/alerts.md

        for: 5m
        labels:
          severity: critical
        annotations:
          summary: "Instance {{ $labels.server }} has lost quorum on pool {{ $labels.pool }} on set {{ $labels.set }}"
          description: "MinIO instance {{ $labels.server }} of job {{ $labels.job }} has lost quorum on pool {{ $labels.pool }} on set {{ $labels.set }} for more than 5 minutes."
    ```
    
    ## Verify the configuration and alerts
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Jan 28 20:53:59 UTC 2024
    - 4.4K bytes
    - Viewed (0)
Back to top