- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 65 for dquorum (0.05 sec)
-
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 Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 30.7K bytes - Viewed (0) -
cmd/global-heal.go
reqInfo := &logger.ReqInfo{API: "BackgroundHeal"} ctx, cancelCtx := context.WithCancel(logger.SetReqInfo(GlobalContext, reqInfo)) hs := madmin.HealOpts{ // Remove objects that do not have read-quorum Remove: healDeleteDangling, } return &healSequence{ startTime: UTCNow(), clientToken: bgHealingUUID, // run-background heal with reserved bucket bucket: minioReservedBucket, settings: hs,
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Apr 04 13:49:12 UTC 2025 - 16.2K bytes - Viewed (0) -
cmd/erasure-encode.go
// Encode reads from the reader, erasure-encodes the data and writes to the writers. func (e *Erasure) Encode(ctx context.Context, src io.Reader, writers []io.Writer, buf []byte, quorum int) (total int64, err error) { writer := &multiWriter{ writers: writers, writeQuorum: quorum, errs: make([]error, len(writers)), } for { var blocks [][]byte n, err := io.ReadFull(src, buf) if err != nil {
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Wed May 15 00:11:04 UTC 2024 - 2.9K bytes - Viewed (0) -
cmd/prepare-storage.go
return nil, err } return format, nil } // Return error when quorum unformatted disks - indicating we are // waiting for first server to be online. unformattedDisks := quorumUnformattedDisks(sErrs) if unformattedDisks && !firstDisk { return nil, errNotFirstDisk } // Return error when quorum unformatted disks but waiting for rest // of the servers to be online.
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Jul 12 20:51:54 UTC 2024 - 11.1K bytes - Viewed (1) -
cmd/local-locker.go
Group bool // indicates if it was a group lock. Owner string // Owner represents the UUID of the owner who originally requested the lock. Quorum int // Quorum represents the quorum required for this lock to be active. idx int `msg:"-"` // index of the lock in the lockMap. } // isWriteLock returns whether the lock is a write or read lock.
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 12K bytes - Viewed (0) -
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)
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 13.4K bytes - Viewed (0) -
cmd/admin-handlers_test.go
Group: true, Quorum: 3, } lris = append(lris, lri) locksHeld[resource] = []lockRequesterInfo{lri} } // Add a few concurrent read locks to the mix for i := range 50 { resource := fmt.Sprintf("bucket/get-object-%d", i) lri := lockRequesterInfo{ Name: resource, UID: mustGetUUID(), Owner: owners[i%len(owners)], Quorum: 2, } lris = append(lris, lri)
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 13.9K bytes - Viewed (0) -
docs/minio-limits.md
| Minimum number of drives per server when server count is 4 | 01 | | Maximum number of drives per server | no-limit | | Read quorum | N/2 | | Write quorum | N/2+1 | ## Limits of S3 API
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Tue Aug 12 18:20:36 UTC 2025 - 6K bytes - Viewed (0) -
cmd/erasure-multipart.go
return fi, nil, errErasureReadQuorum } if writeQuorum < 0 { return fi, nil, errErasureWriteQuorum } quorum := readQuorum if write { quorum = writeQuorum } // List all online disks. _, modTime, etag := listOnlineDisks(storageDisks, partsMetadata, errs, quorum) if write { err = reduceWriteQuorumErrs(ctx, errs, objectOpIgnoredErrs, writeQuorum) } else {
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Sun Sep 07 16:13:09 UTC 2025 - 47.3K bytes - Viewed (0) -
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) } }) } }
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 38.3K bytes - Viewed (0)