Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 10 of 40 for quorum (0.03 seconds)

  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()
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 21.3K bytes
    - Click Count (0)
  2. 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++
    		}
    	}
    
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 20.3K bytes
    - Click Count (0)
  3. 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 {
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 11.8K bytes
    - Click Count (0)
  4. cmd/erasure-metadata_test.go

    			if succModTimes != nil {
    				fis[i].SuccessorModTime = succModTimes[i]
    				fis[i].IsLatest = succModTimes[i].IsZero()
    			}
    			if numVersions != nil {
    				fis[i].NumVersions = numVersions[i]
    			}
    			quorum--
    			if quorum == 0 {
    				break
    			}
    		}
    		return fis
    	}
    
    	commonSuccModTime := time.Date(2023, time.August, 25, 0, 0, 0, 0, time.UTC)
    	succModTimesInQuorum := make([]time.Time, 16)
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 13.4K bytes
    - Click Count (0)
  5. 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.
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 15.6K bytes
    - Click Count (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:
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 10.2K bytes
    - Click Count (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
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 11.7K bytes
    - Click Count (0)
  8. 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 ""
    }
    
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 12K bytes
    - Click Count (0)
  9. cmd/erasure-object_test.go

    				t.Errorf("Expected %s, got %s", tt.expectedError, err)
    			}
    			if tt.expectedReadQuorum != actualReadQuorum {
    				t.Errorf("Expected Read Quorum %d, got %d", tt.expectedReadQuorum, actualReadQuorum)
    			}
    			if tt.expectedWriteQuorum != actualWriteQuorum {
    				t.Errorf("Expected Write Quorum %d, got %d", tt.expectedWriteQuorum, actualWriteQuorum)
    			}
    		})
    	}
    }
    
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 38.3K bytes
    - Click Count (0)
  10. cmd/xl-storage-format-v2_test.go

    		name        string
    		input       [][]xlMetaV2ShallowVersion
    		quorum      int
    		reqVersions int
    		want        []xlMetaV2ShallowVersion
    	}{
    		{
    			name: "obj-on-one",
    			input: [][]xlMetaV2ShallowVersion{
    				0: {vDelMarker, vObj}, // disk 0
    				1: {vDelMarker},       // disk 1
    				2: {vDelMarker},       // disk 2
    			},
    			quorum:      2,
    			reqVersions: 0,
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 37.8K bytes
    - Click Count (0)
Back to Top