- Sort Score
- Result 10 results
- Languages All
Results 1 - 4 of 4 for WithNErrs (0.07 sec)
-
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) -
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) -
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) -
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)