- Sort Score
- Num 10 results
- Language All
Results 1 - 10 of 43 for Quorum (0.06 seconds)
The search processing time has exceeded the limit. The displayed results may be partial.
-
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) -
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) -
internal/dsync/lock-args_gen.go
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) -
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 }
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 16.6K bytes - Click Count (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)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) -
cmd/metacache-entries_test.go
wantOk: true, }, { name: "one zero, below quorum", m: metaCacheEntries{inputSerialized[0], inputSerialized[0], inputSerialized[0], metaCacheEntry{}}, r: metadataResolutionParams{dirQuorum: 4, objQuorum: 4, strict: false}, wantSelected: nil, wantOk: false, }, { name: "one zero, below quorum, strict",Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 31.6K bytes - Click Count (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.
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Fri Jul 12 20:51:54 GMT 2024 - 11.1K bytes - Click Count (1) -
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)
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 13.9K bytes - Click Count (1) -
internal/http/headers.go
// Header indicates if the etag should be preserved by client MinIOSourceETag = "x-minio-source-etag" // Writes expected write quorum MinIOWriteQuorum = "x-minio-write-quorum" // Reads expected read quorum MinIOReadQuorum = "x-minio-read-quorum" // Indicates if we are using default storage class and there was problem loading config // if this header is set to "true"
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Wed May 07 15:37:12 GMT 2025 - 10.8K bytes - Click Count (0) -
cmd/erasure-healing-common_test.go
// This test uses two FileInfo values that represent the same object but // have different parities. They occur in equal number of drives, but only // one has read quorum. commonParity should pick the parity corresponding to // the FileInfo which has read quorum. fi1 := FileInfo{ Volume: "mybucket", Name: "myobject", VersionID: "", IsLatest: true, Deleted: false,Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 22.4K bytes - Click Count (0)