Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for WithNErrs (0.05 sec)

  1. cmd/erasure-object.go

    	fi := FileInfo{
    		VersionID: m.VersionID,
    	}
    	if opts.VersionID != "" {
    		fi.VersionID = opts.VersionID
    	}
    	fi.SetTierFreeVersionID(mustGetUUID())
    	disks := er.getDisks()
    	g := errgroup.WithNErrs(len(disks))
    	for index := range disks {
    		index := index
    		g.Go(func() error {
    			if disks[index] == nil {
    				return errDiskNotFound
    			}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Oct 31 22:10:24 UTC 2024
    - 78.8K bytes
    - Viewed (0)
  2. cmd/erasure-server-pool.go

    	serverPools := make(serverPoolsAvailableSpace, len(z.serverPools))
    
    	storageInfos := make([][]*DiskInfo, len(z.serverPools))
    	nSets := make([]int, len(z.serverPools))
    	g := errgroup.WithNErrs(len(z.serverPools))
    	for index := range z.serverPools {
    		index := index
    		// Skip suspended pools or pools participating in rebalance for any new
    		// I/O.
    		if z.IsSuspended(index) || z.IsPoolRebalancing(index) {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Sep 29 22:40:36 UTC 2024
    - 89.8K bytes
    - Viewed (0)
  3. cmd/bucket-handlers.go

    			// an error and continue.
    			bucketsInConflict.Add(bucket)
    		}
    	}
    
    	// Add/update buckets that are not registered with the DNS
    	bucketsToBeUpdatedSlice := bucketsToBeUpdated.ToSlice()
    	g := errgroup.WithNErrs(len(bucketsToBeUpdatedSlice)).WithConcurrency(50)
    
    	for index := range bucketsToBeUpdatedSlice {
    		index := index
    		g.Go(func() error {
    			return globalDNSConfig.Put(bucketsToBeUpdatedSlice[index])
    		}, index)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Sep 12 12:24:04 UTC 2024
    - 63.4K bytes
    - Viewed (0)
Back to top