Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 14 for setDriveCount (0.12 sec)

  1. cmd/format-erasure_test.go

    func TestGetFormatErasureInQuorumCheck(t *testing.T) {
    	setCount := 2
    	setDriveCount := 16
    
    	format := newFormatErasureV3(setCount, setDriveCount)
    	format.Erasure.DistributionAlgo = formatErasureVersionV2DistributionAlgoV1
    	formats := make([]*formatErasureV3, 32)
    
    	for i := 0; i < setCount; i++ {
    		for j := 0; j < setDriveCount; j++ {
    			newFormat := format.Clone()
    			newFormat.Erasure.This = format.Erasure.Sets[i][j]
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Apr 15 08:25:46 UTC 2024
    - 12.9K bytes
    - Viewed (0)
  2. internal/config/storageclass/storage-class.go

    	}
    
    	if setDriveCount > 2 {
    		if ssParity > setDriveCount/2 {
    			return fmt.Errorf("Standard storage class parity %d should be less than or equal to %d", ssParity, setDriveCount/2)
    		}
    
    		if rrsParity > setDriveCount/2 {
    			return fmt.Errorf("Reduced redundancy storage class parity %d should be less than or equal to %d", rrsParity, setDriveCount/2)
    		}
    	}
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Sep 12 12:24:04 UTC 2024
    - 12.3K bytes
    - Viewed (0)
  3. cmd/format-erasure.go

    		for j := 0; j < setDriveCount; j++ {
    			disk := storageDisks[i*setDriveCount+j]
    			newFormat := format.Clone()
    			newFormat.Erasure.This = format.Erasure.Sets[i][j]
    			if deploymentID != "" {
    				newFormat.ID = deploymentID
    			}
    			hostCount[disk.Hostname()]++
    			formats[i*setDriveCount+j] = newFormat
    		}
    		var once sync.Once
    		for host, count := range hostCount {
    			if count > wantAtMost {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 23.2K bytes
    - Viewed (0)
  4. cmd/endpoint-ellipses.go

    	// only meant if you want to further optimize drive distribution.
    	if setDriveCount > 0 {
    		msg := fmt.Sprintf("Invalid set drive count. Acceptable values for %d number drives are %d", commonSize, setCounts)
    		var found bool
    		for _, ss := range setCounts {
    			if ss == setDriveCount {
    				found = true
    			}
    		}
    		if !found {
    			return nil, config.ErrInvalidErasureSetSize(nil).Msg(msg)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Aug 14 17:11:51 UTC 2024
    - 14.7K bytes
    - Viewed (0)
  5. cmd/erasure-sets.go

    		eps := make([]string, s.setDriveCount)
    		copy(eps, s.endpointStrings[setIndex*s.setDriveCount:setIndex*s.setDriveCount+s.setDriveCount])
    		return eps
    	}
    }
    
    func (s *erasureSets) GetEndpoints(setIndex int) func() []Endpoint {
    	return func() []Endpoint {
    		eps := make([]Endpoint, s.setDriveCount)
    		copy(eps, s.endpoints.Endpoints[setIndex*s.setDriveCount:setIndex*s.setDriveCount+s.setDriveCount])
    		return eps
    	}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 27 10:41:37 UTC 2024
    - 37K bytes
    - Viewed (1)
  6. cmd/prepare-storage.go

    	if err = checkFormatErasureValues(formatConfigs, storageDisks, setDriveCount); err != nil {
    		return nil, err
    	}
    
    	// All disks report unformatted we should initialized everyone.
    	if shouldInitErasureDisks(sErrs) && firstDisk {
    		logger.Info("Formatting %s pool, %v set(s), %v drives per set.",
    			humanize.Ordinal(poolCount), setCount, setDriveCount)
    
    		// Initialize erasure code format on disks
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jul 12 20:51:54 UTC 2024
    - 11.1K bytes
    - Viewed (1)
  7. cmd/erasure.go

    	return nil
    }
    
    // defaultWQuorum write quorum based on setDriveCount and defaultParityCount
    func (er erasureObjects) defaultWQuorum() int {
    	dataCount := er.setDriveCount - er.defaultParityCount
    	if dataCount == er.defaultParityCount {
    		return dataCount + 1
    	}
    	return dataCount
    }
    
    // defaultRQuorum read quorum based on setDriveCount and defaultParityCount
    func (er erasureObjects) defaultRQuorum() int {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Oct 04 22:23:33 UTC 2024
    - 16.1K bytes
    - Viewed (0)
  8. cmd/server-main.go

    				args:          list,
    				setDriveCount: setDriveCount,
    			})
    		}
    	case "v2":
    		cf := config.ServerConfig{}
    		cfReader.Seek(0, io.SeekStart)
    		if err = yaml.Unmarshal(rd, &cf); err != nil {
    			return err
    		}
    
    		pools = make([]poolArgs, 0, len(cf.Pools))
    		for _, list := range cf.Pools {
    			driveCount := list.SetDriveCount
    			if setDriveCount > 0 {
    				driveCount = setDriveCount
    			}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Sep 24 21:50:11 UTC 2024
    - 35.2K bytes
    - Viewed (1)
  9. cmd/config-current.go

    			return err
    		}
    	case config.StorageClassSubSys:
    		if objAPI == nil {
    			return errServerNotInitialized
    		}
    		for _, setDriveCount := range objAPI.SetDriveCounts() {
    			if _, err := storageclass.LookupConfig(s[config.StorageClassSubSys][config.Default], setDriveCount); err != nil {
    				return err
    			}
    		}
    	case config.CompressionSubSys:
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Sep 03 18:23:41 UTC 2024
    - 30.1K bytes
    - Viewed (0)
  10. cmd/global-heal.go

    			return nil
    		}
    
    		disks = disks[:len(disks)-healing] // healing drives are always at the end of the list
    
    		if len(disks) < er.setDriveCount/2 {
    			return fmt.Errorf("not enough drives (found=%d, healing=%d, total=%d) are available to heal `%s`", len(disks), healing, er.setDriveCount, tracker.disk.String())
    		}
    
    		rand.Shuffle(len(disks), func(i, j int) {
    			disks[i], disks[j] = disks[j], disks[i]
    		})
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Oct 26 09:58:27 UTC 2024
    - 16.3K bytes
    - Viewed (0)
Back to top