Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for Int63n (0.04 sec)

  1. cmd/bootstrap-peer-server.go

    		select {
    		case <-ctx.Done():
    			return ctx.Err()
    		default:
    			// Sleep and stagger to avoid blocked CPU and thundering
    			// herd upon start up sequence.
    			time.Sleep(25*time.Millisecond + time.Duration(rand.Int63n(int64(100*time.Millisecond))))
    			retries++
    			// after 20 retries start logging that servers are not reachable yet
    			if retries >= 20 {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Oct 01 22:13:18 UTC 2024
    - 8.4K bytes
    - Viewed (0)
  2. cmd/bucket-metadata-sys.go

    	for index := range buckets {
    		index := index
    		g.Go(func() error {
    			// Sleep and stagger to avoid blocked CPU and thundering
    			// herd upon start up sequence.
    			time.Sleep(25*time.Millisecond + time.Duration(rand.Int63n(int64(100*time.Millisecond))))
    
    			_, _ = sys.objAPI.HealBucket(ctx, buckets[index], madmin.HealOpts{Recreate: true})
    			meta, err := loadBucketMetadata(ctx, sys.objAPI, buckets[index])
    			if err != nil {
    				return err
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Aug 28 15:32:18 UTC 2024
    - 20.4K bytes
    - Viewed (0)
  3. cmd/data-usage-cache.go

    			break
    		}
    		retry, err = load(name+".bkp", 30*time.Second)
    		if err == nil && !retry {
    			// Only return when we have valid data from the backup
    			break
    		}
    		retries++
    		time.Sleep(time.Duration(rand.Int63n(int64(time.Second))))
    	}
    
    	if retries == 5 {
    		scannerLogOnceIf(ctx, fmt.Errorf("maximum retry reached to load the data usage cache `%s`", name), "retry-loading-data-usage-cache")
    	}
    
    	return nil
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Oct 22 15:30:50 UTC 2024
    - 34.7K bytes
    - Viewed (0)
  4. cmd/xl-storage-disk-id-check.go

    				p.health.waiting.Add(1)
    				go p.monitorDiskStatus(spent, fn)
    			}
    		}
    
    		// Offset checks a bit.
    		time.Sleep(time.Duration(rng.Int63n(int64(1 * time.Second))))
    
    		dctx, dcancel := context.WithCancel(ctx)
    		started := time.Now()
    		go func() {
    			timeout := time.NewTimer(globalDriveConfig.GetMaxTimeout())
    			select {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Oct 26 09:56:26 UTC 2024
    - 34.5K bytes
    - Viewed (0)
  5. cmd/bucket-replication.go

    		cancel()
    		if err == nil {
    			break
    		}
    		if minio.ToErrorResponse(err).Code == "PreconditionFailed" {
    			return nil
    		}
    		attempts++
    		time.Sleep(time.Duration(rand.Int63n(int64(time.Second))))
    	}
    	if err != nil {
    		return err
    	}
    
    	defer func() {
    		if err != nil {
    			// block and abort remote upload upon failure.
    			attempts := 1
    			for attempts <= 3 {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Oct 10 06:49:55 UTC 2024
    - 116.1K bytes
    - Viewed (0)
  6. cmd/test-utils_test.go

    var src = rand.NewSource(time.Now().UnixNano())
    
    func randString(n int) string {
    	b := make([]byte, n)
    	// A src.Int63() generates 63 random bits, enough for letterIdxMax characters!
    	for i, cache, remain := n-1, src.Int63(), letterIdxMax; i >= 0; {
    		if remain == 0 {
    			cache, remain = src.Int63(), letterIdxMax
    		}
    		if idx := int(cache & letterIdxMask); idx < len(letterBytes) {
    			b[i] = letterBytes[idx]
    			i--
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Oct 01 22:13:18 UTC 2024
    - 77K bytes
    - Viewed (0)
Back to top