Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 4 of 4 for write_quorum (0.24 sec)

  1. cmd/metrics-v3-cluster-erasure-set.go

    package cmd
    
    import (
    	"context"
    	"strconv"
    )
    
    const (
    	erasureSetOverallWriteQuorum = "overall_write_quorum"
    	erasureSetOverallHealth      = "overall_health"
    	erasureSetReadQuorum         = "read_quorum"
    	erasureSetWriteQuorum        = "write_quorum"
    	erasureSetOnlineDrivesCount  = "online_drives_count"
    	erasureSetHealingDrivesCount = "healing_drives_count"
    	erasureSetHealth             = "health"
    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)
  2. 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)
  3. 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)
  4. 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