- Sort Score
- Result 10 results
- Languages All
Results 1 - 2 of 2 for updateLocked (0.47 sec)
-
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) -
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)