- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 70 for dquorum (0.18 sec)
-
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 Oct 27 19:28:09 UTC 2024 - Last Modified: Wed Jul 24 10:24:01 UTC 2024 - 13.9K bytes - Viewed (0) -
cmd/erasure-errors.go
package cmd import "errors" // errErasureReadQuorum - did not meet read quorum. var errErasureReadQuorum = errors.New("Read failed. Insufficient number of drives online") // errErasureWriteQuorum - did not meet write quorum. var errErasureWriteQuorum = errors.New("Write failed. Insufficient number of drives online")
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Thu Aug 04 23:10:08 UTC 2022 - 1.2K bytes - Viewed (0) -
cmd/metrics-v3-cluster-erasure-set.go
"Overall write quorum across pools and sets") erasureSetOverallHealthMD = NewGaugeMD(erasureSetOverallHealth, "Overall health across pools and sets (1=healthy, 0=unhealthy)") erasureSetReadQuorumMD = NewGaugeMD(erasureSetReadQuorum, "Read quorum for the erasure set in a pool", poolIDL, setIDL) erasureSetWriteQuorumMD = NewGaugeMD(erasureSetWriteQuorum, "Write quorum for the erasure set in a pool", poolIDL, setIDL)
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Tue May 14 07:25:56 UTC 2024 - 4.4K bytes - Viewed (0) -
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 Oct 27 19:28:09 UTC 2024 - Last Modified: Wed Jul 24 10:24:01 UTC 2024 - 10.7K 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 Oct 27 19:28:09 UTC 2024 - Last Modified: Thu Jul 25 21:02:50 UTC 2024 - 13.5K 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 Oct 27 19:28:09 UTC 2024 - 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 Oct 27 19:28:09 UTC 2024 - Last Modified: Fri Jul 12 20:51:54 UTC 2024 - 11.1K bytes - Viewed (0) -
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"
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Wed Aug 28 15:31:56 UTC 2024 - 10.4K 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 Oct 27 19:28:09 UTC 2024 - Last Modified: Sat Oct 26 09:58:27 UTC 2024 - 16.3K bytes - Viewed (0) -
cmd/admin-handlers_test.go
return "READ" } exp = append(exp, madmin.LockEntry{ Resource: lri.Name, Type: lockType(lri), ServerList: owners, Owner: lri.Owner, ID: lri.UID, Quorum: lri.Quorum, Timestamp: time.Unix(0, lri.Timestamp), }) } testCases := []struct { peerLocks []*PeerLocks expected madmin.LockEntries }{ { peerLocks: peerLocks,
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Wed Jul 24 10:24:01 UTC 2024 - 13.9K bytes - Viewed (0)