Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 2 of 2 for updateLocked (0.47 sec)

  1. staging/src/k8s.io/apiserver/pkg/util/flowcontrol/fairqueuing/integrator.go

    func (igr *integrator) SetToCurrentTime() {
    	igr.Set(float64(time.Now().UnixNano()))
    }
    
    func (igr *integrator) setLocked(x float64) {
    	igr.updateLocked()
    	igr.x = x
    	if x < igr.min {
    		igr.min = x
    	}
    	if x > igr.max {
    		igr.max = x
    	}
    }
    
    func (igr *integrator) updateLocked() {
    	now := igr.clock.Now()
    	dt := now.Sub(igr.lastTime).Seconds()
    	igr.lastTime = now
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Nov 03 17:37:20 UTC 2022
    - 5K bytes
    - Viewed (0)
  2. src/runtime/mgclimit.go

    		// our total assist time.
    		return
    	}
    	if l.transitioning {
    		throw("update during transition")
    	}
    	l.updateLocked(now)
    	l.unlock()
    }
    
    // updateLocked is the implementation of update. l.lock must be held.
    func (l *gcCPULimiterState) updateLocked(now int64) {
    	lastUpdate := l.lastUpdate.Load()
    	if now < lastUpdate {
    		// Defensively avoid overflow. This isn't even the latest update anyway.
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Mon Apr 22 22:07:41 UTC 2024
    - 17.3K bytes
    - Viewed (0)
Back to top