Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for jitterBy (0.62 sec)

  1. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/connection/RealConnectionPool.kt

        } catch (e: IOException) {
          // No need to log, user.connectFailed() will already have been called. Just try again later.
          return state.policy.backoffDelayMillis.jitterBy(state.policy.backoffJitterMillis) * 1_000_000
        }
      }
    
      private fun Long.jitterBy(amount: Int): Long = this + ThreadLocalRandom.current().nextInt(amount * -1, amount)
    
      class AddressState(
        val address: Address,
        val queue: TaskQueue,
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Tue Jun 03 17:10:08 UTC 2025
    - 16.1K bytes
    - Viewed (0)
  2. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/connection/AddressPolicy.kt

       */
      @JvmField val minimumConcurrentCalls: Int = 0,
      /** How long to wait to retry pre-emptive connection attempts that fail. */
      @JvmField val backoffDelayMillis: Long = 60 * 1000,
      /** How much jitter to introduce in connection retry backoff delays */
      @JvmField val backoffJitterMillis: Int = 100,
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Tue Jun 03 17:10:08 UTC 2025
    - 1.3K bytes
    - Viewed (0)
  3. cmd/erasure.go

    	bucketResults := make(chan dataUsageEntryInfo, len(disks))
    
    	// Start async collector/saver.
    	// This goroutine owns the cache.
    	var saverWg sync.WaitGroup
    	saverWg.Add(1)
    	go func() {
    		// Add jitter to the update time so multiple sets don't sync up.
    		updateTime := 30*time.Second + time.Duration(float64(10*time.Second)*rand.Float64())
    		t := time.NewTicker(updateTime)
    		defer t.Stop()
    		defer saverWg.Done()
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 16.1K bytes
    - Viewed (0)
Back to top