- Sort Score
- Result 10 results
- Languages All
Results 31 - 35 of 35 for mu (0.13 sec)
-
cmd/bucket-policy-handlers_test.go
var ok, errs int var wg sync.WaitGroup var mu sync.Mutex wg.Add(n) for i := 0; i < n; i++ { go func() { defer wg.Done() // Sync start. <-start if err := obj.MakeBucket(GlobalContext, bucketName1, MakeBucketOptions{}); err != nil { if _, ok := err.(BucketExists); !ok { t.Logf("unexpected error: %T: %v", err, err) return } mu.Lock() errs++ mu.Unlock()
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Jan 18 07:03:17 GMT 2024 - 32.7K bytes - Viewed (0) -
cmd/erasure-sets.go
// the result of the delete operation var wg sync.WaitGroup var mu sync.Mutex wg.Add(len(objSetMap)) for setIdx, objsGroup := range objSetMap { go func(set *erasureObjects, group []delObj) { defer wg.Done() dobjects, errs := set.DeleteObjects(ctx, bucket, toNames(group), opts) mu.Lock() defer mu.Unlock() for i, obj := range group { delErrs[obj.origIndex] = errs[i]
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri May 03 20:08:20 GMT 2024 - 37.7K bytes - Viewed (5) -
cmd/data-scanner.go
func (d *dynamicSleeper) Sleep(ctx context.Context, base time.Duration) { for { // Grab current values d.mu.RLock() minWait, maxWait := d.minSleep, d.maxSleep factor := d.factor cycle := d.cycle d.mu.RUnlock() // Don't sleep for really small amount of time wantSleep := time.Duration(float64(base) * factor) if wantSleep <= minWait { return }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri May 03 11:18:58 GMT 2024 - 47.6K bytes - Viewed (0) -
cmd/erasure-healing.go
// skipped, like the meta-bucket. if isReservedOrInvalidBucket(volInfo.Name, false) { continue } mu.Lock() if _, ok := healBuckets[volInfo.Name]; !ok { healBuckets[volInfo.Name] = volInfo } mu.Unlock() } return nil }, index) } return reduceReadQuorumErrs(ctx, g.Wait(), bucketMetadataOpIgnoredErrs, readQuorum) }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Apr 26 06:32:14 GMT 2024 - 33.1K bytes - Viewed (0) -
istioctl/pkg/waypoint/waypoint.go
if errors.IsNotFound(err) { fmt.Fprintf(cmd.OutOrStdout(), "waypoint %v/%v not found\n", namespace, name) } else { mu.Lock() multiErr = multierror.Append(multiErr, err) mu.Unlock() } } else { fmt.Fprintf(cmd.OutOrStdout(), "waypoint %v/%v deleted\n", namespace, name) } }(name) } wg.Wait() return multiErr.ErrorOrNil() }
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Wed May 08 19:45:58 GMT 2024 - 15.5K bytes - Viewed (0)