- Sort Score
- Result 10 results
- Languages All
Results 1 - 9 of 9 for write_quorum (0.09 sec)
-
cmd/erasure-object.go
} dataDrives := len(storageDisks) - parityDrives // we now know the number of blocks this object needs for data and parity. // writeQuorum is dataBlocks + 1 writeQuorum := dataDrives if dataDrives == parityDrives { writeQuorum++ } // Validate input data size and it can never be less than zero. if data.Size() < -1 { bugLogIf(ctx, errInvalidArgument, logger.ErrorKind)
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Oct 31 22:10:24 UTC 2024 - 78.8K bytes - Viewed (0) -
cmd/erasure-metadata-utils.go
} // reduceWriteQuorumErrs behaves like reduceErrs but only for returning // values of maximally occurring errors validated against writeQuorum. func reduceWriteQuorumErrs(ctx context.Context, errs []error, ignoredErrs []error, writeQuorum int) (maxErr error) { return reduceQuorumErrs(ctx, errs, ignoredErrs, writeQuorum, errErasureWriteQuorum) } // Similar to 'len(slice)' but returns the actual elements count
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 11.7K bytes - Viewed (0) -
cmd/erasure-multipart.go
uploadIDPath, "", false, false) readQuorum, writeQuorum, err := objectQuorumFromMeta(ctx, partsMetadata, errs, er.defaultParityCount) if err != nil { return fi, nil, err } if readQuorum < 0 { return fi, nil, errErasureReadQuorum } if writeQuorum < 0 { return fi, nil, errErasureWriteQuorum } quorum := readQuorum if write { quorum = writeQuorum } // List all online disks.
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Sun Sep 29 22:40:36 UTC 2024 - 44.7K bytes - Viewed (0) -
cmd/erasure-metadata.go
} dataBlocks := len(partsMetaData) - parityBlocks writeQuorum := dataBlocks if dataBlocks == parityBlocks { writeQuorum++ } // Since all the valid erasure code meta updated at the same time are equivalent, pass dataBlocks // from latestFileInfo to get the quorum return dataBlocks, writeQuorum, nil } const ( tierFVID = "tier-free-versionID"
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Oct 31 22:10:24 UTC 2024 - 21.3K bytes - Viewed (0) -
cmd/erasure-server-pool.go
usingDefaults = true } var maximumWriteQuorum int for _, writeQuorum := range poolWriteQuorums { if maximumWriteQuorum == 0 { maximumWriteQuorum = writeQuorum } if writeQuorum > maximumWriteQuorum { maximumWriteQuorum = writeQuorum } } var maximumReadQuorum int for _, readQuorum := range poolReadQuorums {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Sun Sep 29 22:40:36 UTC 2024 - 89.8K bytes - Viewed (0) -
cmd/storage-datatypes.go
n.Volume = fi.Volume n.Name = fi.Name n.VersionID = fi.VersionID n.Deleted = fi.Deleted n.Erasure = fi.Erasure return } // WriteQuorum returns expected write quorum for this FileInfo func (fi FileInfo) WriteQuorum(dquorum int) int { if fi.Deleted { return dquorum } quorum := fi.Erasure.DataBlocks if fi.Erasure.DataBlocks == fi.Erasure.ParityBlocks { quorum++ }
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Tue Oct 22 15:30:50 UTC 2024 - 17.3K bytes - Viewed (0) -
cmd/healthcheck-handler.go
Maintenance: r.Form.Get("maintenance") == "true", DeploymentType: r.Form.Get("deployment-type"), } result := objLayer.Health(ctx, opts) w.Header().Set(xhttp.MinIOWriteQuorum, strconv.Itoa(result.WriteQuorum)) w.Header().Set(xhttp.MinIOStorageClassDefaults, strconv.FormatBool(result.UsingDefaults)) // return how many drives are being healed if any if result.HealingDrives > 0 {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Wed Jun 26 07:44:34 UTC 2024 - 6.9K bytes - Viewed (0) -
cmd/erasure-decode.go
} } else if err != nil { return err } if err = e.DecodeDataAndParityBlocks(ctx, bufs); err != nil { return err } w := multiWriter{ writers: writers, writeQuorum: 1, errs: make([]error, len(writers)), } if err = w.Write(ctx, bufs); err != nil { return err } } return derr
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Aug 29 01:40:52 UTC 2024 - 9.5K bytes - Viewed (0) -
cmd/metrics-v2.go
metrics = make([]MetricV2, 0, 2+4*len(result.ESHealth)) metrics = append(metrics, MetricV2{ Description: getClusterWriteQuorumMD(), Value: float64(result.WriteQuorum), }) health := 1 if !result.Healthy { health = 0 } metrics = append(metrics, MetricV2{ Description: getClusterHealthStatusMD(), Value: float64(health),
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Aug 15 12:04:40 UTC 2024 - 131.9K bytes - Viewed (0)