Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 13 for getCount (0.24 sec)

  1. cmd/erasure-server-pool.go

    		// Count errNoHealRequired across all serverPools,
    		// to return appropriate error to the caller
    		if errors.Is(err, errNoHealRequired) {
    			countNoHeal++
    		}
    		r.DiskCount += result.DiskCount
    		r.SetCount += result.SetCount
    		r.Before.Drives = append(r.Before.Drives, result.Before.Drives...)
    		r.After.Drives = append(r.After.Drives, result.After.Drives...)
    	}
    
    	// No heal returned by all serverPools, return errNoHealRequired
    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)
  2. docs/debugging/hash-set/main.go

    	flag.IntVar(&setCount, "set-count", 0, "Total set count")
    	flag.IntVar(&shards, "shards", 0, "Total shards count")
    	flag.BoolVar(&verbose, "v", false, "Display all objects")
    
    	flag.Parse()
    
    	if deploymentID == "" {
    		log.Fatalln("deployment ID is mandatory")
    	}
    
    	if setCount == 0 {
    		log.Fatalln("set count cannot be zero")
    	}
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Mon Sep 19 18:05:16 GMT 2022
    - 3.7K bytes
    - Viewed (0)
  3. cmd/format-erasure.go

    func initFormatErasure(ctx context.Context, storageDisks []StorageAPI, setCount, setDriveCount int, deploymentID string, sErrs []error) (*formatErasureV3, error) {
    	format := newFormatErasureV3(setCount, setDriveCount)
    	formats := make([]*formatErasureV3, len(storageDisks))
    	wantAtMost, err := ecDrivesNoConfig(setDriveCount)
    	if err != nil {
    		return nil, err
    	}
    
    	for i := 0; i < setCount; i++ {
    		hostCount := make(map[string]int, setDriveCount)
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri May 03 15:54:03 GMT 2024
    - 23.2K bytes
    - Viewed (0)
  4. cmd/format-erasure_test.go

    }
    
    // Tests getFormatErasureInQuorum()
    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()
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Mon Apr 15 08:25:46 GMT 2024
    - 12.9K bytes
    - Viewed (0)
  5. cmd/peer-s3-client.go

    	})
    
    	_, err := healBucketRPC.Call(ctx, conn, mss)
    
    	// Initialize heal result info
    	return madmin.HealResultItem{
    		Type:     madmin.HealItemBucket,
    		Bucket:   bucket,
    		SetCount: -1, // explicitly set an invalid value -1, for bucket heal scenario
    	}, toStorageErr(err)
    }
    
    // GetBucketInfo returns bucket stat info from a peer
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 14.8K bytes
    - Viewed (0)
  6. cmd/endpoint-ellipses.go

    			newSetCounts[ss] = struct{}{}
    		}
    	}
    
    	setCounts = []uint64{}
    	for setCount := range newSetCounts {
    		setCounts = append(setCounts, setCount)
    	}
    
    	// Not necessarily needed but it ensures to the readers
    	// eyes that we prefer a sorted setCount slice for the
    	// subsequent function to figure out the right common
    	// divisor, it avoids loops.
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri May 03 15:54:03 GMT 2024
    - 14.7K bytes
    - Viewed (0)
  7. cmd/storage-rest-server.go

    	}
    
    	globalLocalSetDrives = make([][][]StorageAPI, len(endpointServerPools))
    	for pool := range globalLocalSetDrives {
    		globalLocalSetDrives[pool] = make([][]StorageAPI, endpointServerPools[pool].SetCount)
    		for set := range globalLocalSetDrives[pool] {
    			globalLocalSetDrives[pool][set] = make([]StorageAPI, endpointServerPools[pool].DrivesPerSet)
    		}
    	}
    	for _, serverPool := range endpointServerPools {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun Apr 28 17:53:50 GMT 2024
    - 44.8K bytes
    - Viewed (0)
  8. cmd/test-utils_test.go

    func mustGetPoolEndpoints(poolIdx int, args ...string) EndpointServerPools {
    	drivesPerSet := len(args)
    	setCount := 1
    	if len(args) >= 16 {
    		drivesPerSet = 16
    		setCount = len(args) / 16
    	}
    	endpoints := mustGetNewEndpoints(poolIdx, drivesPerSet, args...)
    	return []PoolEndpoints{{
    		SetCount:     setCount,
    		DrivesPerSet: drivesPerSet,
    		Endpoints:    endpoints,
    		CmdLine:      strings.Join(args, " "),
    	}}
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri May 03 17:26:51 GMT 2024
    - 76.2K bytes
    - Viewed (0)
  9. cmd/peer-s3-server.go

    			return nil
    		}, index)
    	}
    
    	errs := g.Wait()
    
    	// Initialize heal result info
    	res = madmin.HealResultItem{
    		Type:      madmin.HealItemBucket,
    		Bucket:    bucket,
    		DiskCount: len(localDrives),
    		SetCount:  -1, // explicitly set an invalid value -1, for bucket heal scenario
    	}
    
    	// mutate only if not a dry-run
    	if opts.DryRun {
    		return res, nil
    	}
    
    	for i := range beforeState {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri Mar 08 19:08:18 GMT 2024
    - 8.4K bytes
    - Viewed (0)
  10. cmd/endpoint.go

    		PoolIdx: -1,
    		SetIdx:  -1,
    		DiskIdx: -1,
    	}, nil
    }
    
    // PoolEndpoints represent endpoints in a given pool
    // along with its setCount and setDriveCount.
    type PoolEndpoints struct {
    	// indicates if endpoints are provided in non-ellipses style
    	Legacy       bool
    	SetCount     int
    	DrivesPerSet int
    	Endpoints    Endpoints
    	CmdLine      string
    	Platform     string
    }
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun Apr 21 11:43:18 GMT 2024
    - 34.1K bytes
    - Viewed (0)
Back to top