- Sort Score
- Result 10 results
- Languages All
Results 1 - 2 of 2 for robinIndex (0.1 sec)
-
staging/src/k8s.io/apiserver/pkg/util/flowcontrol/fairqueuing/queueset/queueset.go
sMax := fqrequest.MinSeatSeconds dsMax := fqrequest.MinSeatSeconds var minQueue *queue var minIndex int nq := len(qs.queues) for range qs.queues { qs.robinIndex = (qs.robinIndex + 1) % nq queue := qs.queues[qs.robinIndex] oldestWaiting, _ := queue.requestsWaiting.Peek() if oldestWaiting != nil { sMin = min(sMin, queue.nextDispatchR) sMax = max(sMax, queue.nextDispatchR)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Jan 04 16:59:21 UTC 2024 - 42.4K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/util/flowcontrol/fairqueuing/queueset/queueset_test.go
t.Run(test.name, func(t *testing.T) { qs := &queueSet{ estimatedServiceDuration: G, seatDemandIntegrator: fq.NewNamedIntegrator(clock.RealClock{}, "seatDemandSubject"), robinIndex: test.robinIndex, totSeatsInUse: test.totSeatsInUse, qCfg: fq.QueuingConfig{Name: "TestSelectQueueLocked/" + test.name}, dCfg: fq.DispatchingConfig{
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Sep 26 12:55:23 UTC 2023 - 58.4K bytes - Viewed (0)