Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 11 for writeQuorums (0.19 sec)

  1. 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)
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun May 05 16:56:21 GMT 2024
    - 77.2K bytes
    - Viewed (2)
  2. 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
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Apr 23 17:15:52 GMT 2024
    - 11.3K bytes
    - Viewed (0)
  3. cmd/erasure-encode.go

    			}
    		}(i)
    	}
    	wg.Wait()
    
    	// If nilCount >= p.writeQuorum, we return nil. This is because HealFile() uses
    	// CreateFile with p.writeQuorum=1 to accommodate healing of single disk.
    	// i.e if we do no return here in such a case, reduceWriteQuorumErrs() would
    	// return a quorum error to HealFile().
    	nilCount := countErrs(p.errs, nil)
    	if nilCount >= p.writeQuorum {
    		return nil
    	}
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed Jan 31 02:11:45 GMT 2024
    - 3K bytes
    - Viewed (0)
  4. cmd/erasure-multipart.go

    		}
    	}
    
    	dataDrives := len(onlineDisks) - parityDrives
    
    	// we now know the number of blocks this object needs for data and parity.
    	// establish the writeQuorum using this data
    	writeQuorum := dataDrives
    	if dataDrives == parityDrives {
    		writeQuorum++
    	}
    
    	// Initialize parts metadata
    	partsMetadata := make([]FileInfo, len(onlineDisks))
    
    	fi := newFileInfo(pathJoin(bucket, object), dataDrives, parityDrives)
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun Apr 28 17:53:50 GMT 2024
    - 43K bytes
    - Viewed (0)
  5. 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"
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun Apr 28 17:53:50 GMT 2024
    - 19.2K bytes
    - Viewed (1)
  6. cmd/metrics-v3-cluster-erasure-set.go

    	m.Set(erasureSetOverallWriteQuorum, float64(result.WriteQuorum))
    	m.Set(erasureSetOverallHealth, b2f(result.Healthy))
    
    	for _, h := range result.ESHealth {
    		poolLV := strconv.Itoa(h.PoolID)
    		setLV := strconv.Itoa(h.SetID)
    		m.Set(erasureSetReadQuorum, float64(h.ReadQuorum),
    			poolIDL, poolLV, setIDL, setLV)
    		m.Set(erasureSetWriteQuorum, float64(h.WriteQuorum),
    			poolIDL, poolLV, setIDL, setLV)
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun Mar 10 09:15:15 GMT 2024
    - 3.1K bytes
    - Viewed (0)
  7. 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++
    	}
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Apr 23 17:15:52 GMT 2024
    - 15.3K bytes
    - Viewed (0)
  8. 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 {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri May 03 20:08:20 GMT 2024
    - 80.5K bytes
    - Viewed (0)
  9. 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 {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed Apr 03 21:13:20 GMT 2024
    - 6.5K bytes
    - Viewed (0)
  10. cmd/erasure-decode.go

    			}
    		} else if err != nil {
    			return err
    		}
    
    		if err = e.DecodeDataAndParityBlocks(ctx, bufs); err != nil {
    			return err
    		}
    
    		w := parallelWriter{
    			writers:     writers,
    			writeQuorum: 1,
    			errs:        make([]error, len(writers)),
    		}
    
    		if err = w.Write(ctx, bufs); err != nil {
    			return err
    		}
    	}
    
    	return derr
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri Apr 19 16:44:59 GMT 2024
    - 9.4K bytes
    - Viewed (0)
Back to top