Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 4 of 4 for WithNErrs (0.07 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 {
    		g.Go(func() error {
    			if disks[index] == nil {
    				return errDiskNotFound
    			}
    			return disks[index].DeleteVersion(ctx, bucket, object, fi, false, DeleteOptions{})
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Sun Sep 07 16:13:09 UTC 2025
    - 80.4K 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 {
    		// Skip suspended pools or pools participating in rebalance for any new
    		// I/O.
    		if z.IsSuspended(index) || z.IsPoolRebalancing(index) {
    			continue
    		}
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 89.1K 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 {
    		g.Go(func() error {
    			return globalDNSConfig.Put(bucketsToBeUpdatedSlice[index])
    		}, index)
    	}
    
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 63.9K bytes
    - Viewed (0)
  4. cmd/iam-store.go

    		// rely on user policy for access, instead of fallback.
    		return nil, nil
    	}
    
    	var mu sync.Mutex
    
    	// no mappings found, fallback for all groups.
    	g := errgroup.WithNErrs(len(groups)).WithConcurrency(10) // load like 10 groups at a time.
    
    	for index := range groups {
    		g.Go(func() error {
    			err := store.loadMappedPolicy(context.TODO(), groups[index], regUser, true, c.iamGroupPolicyMap)
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 86.7K bytes
    - Viewed (0)
Back to top