Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for backoffDuration (0.35 sec)

  1. pkg/controller/job/backoff_utils.go

    	if failuresCount == 0 {
    		return 0
    	}
    
    	backoffDuration := defaultBackoff
    	for i := 1; i < int(failuresCount); i++ {
    		backoffDuration = backoffDuration * 2
    		if backoffDuration >= maxBackoff {
    			backoffDuration = maxBackoff
    			break
    		}
    	}
    
    	timeElapsedSinceLastFailure := clock.Since(*lastFailureTime)
    
    	if backoffDuration < timeElapsedSinceLastFailure {
    		return 0
    	}
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Jun 06 07:46:41 UTC 2024
    - 8.3K bytes
    - Viewed (0)
  2. src/net/lookup_test.go

    		tt := lookupGoogleSRVTests[i]
    		cname, srvs, err := LookupSRV(tt.service, tt.proto, tt.name)
    		if err != nil {
    			testenv.SkipFlakyNet(t)
    			if attempts < len(backoffDuration) {
    				dur := backoffDuration[attempts]
    				t.Logf("backoff %v after failure %v\n", dur, err)
    				time.Sleep(dur)
    				attempts++
    				i--
    				continue
    			}
    			t.Fatal(err)
    		}
    		if len(srvs) == 0 {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu May 23 01:00:11 UTC 2024
    - 41.4K bytes
    - Viewed (0)
  3. pkg/scheduler/internal/queue/scheduling_queue.go

    	duration := p.calculateBackoffDuration(podInfo)
    	backoffTime := podInfo.Timestamp.Add(duration)
    	return backoffTime
    }
    
    // calculateBackoffDuration is a helper function for calculating the backoffDuration
    // based on the number of attempts the pod has made.
    func (p *PriorityQueue) calculateBackoffDuration(podInfo *framework.QueuedPodInfo) time.Duration {
    	duration := p.podInitialBackoffDuration
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jun 12 13:26:09 UTC 2024
    - 61.4K bytes
    - Viewed (0)
Back to top