github/kubernetes
1
0
Fork 0
mirror of https://github.com/k3s-io/kubernetes.git synced 2026-08-08 23:37:11 +00:00
Code Issues Projects Releases Wiki Activity

Merge pull request #136264 from michaelasp/unlockWhileProcess

Browse Source 
Ensure that processing does not block queue writers in RealFIFO
This commit is contained in:
Kubernetes Prow Robot
2026-01-22 00:15:26 +05:30
committed by GitHub
parent 7fb075627f 082f38d97b
commit dff962ddbb
7 changed files with 230 additions and 38 deletions
Download Patch File Download Diff File Expand all files Collapse all files

12
pkg/scheduler/schedule_one_test.go
View File

@@ -4660,7 +4660,7 @@ func setupTestScheduler(ctx context.Context, t *testing.T, client clientset.Inte
nodeInfoSnapshot: snapshot,
percentageOfNodesToScore: schedulerapi.DefaultPercentageOfNodesToScore,
NextPod: func(logger klog.Logger) (*framework.QueuedPodInfo, error) {
return &framework.QueuedPodInfo{PodInfo: mustNewPodInfo(t, clientcache.Pop(queuedPodStore).(*v1.Pod))}, nil
return &framework.QueuedPodInfo{PodInfo: mustNewPodInfo(t, pop(queuedPodStore).(*v1.Pod))}, nil
},
SchedulingQueue: schedulingQueue,
APIDispatcher: apiDispatcher,
@@ -4743,3 +4743,13 @@ func mustNewPodInfo(t *testing.T, pod *v1.Pod) *framework.PodInfo {
}
return podInfo
}
func pop(queue clientcache.Queue) interface{} {
obj, err := queue.Pop(func(obj interface{}, isInInitialList bool) error {
return nil
})
if err != nil {
return nil
}
return obj
}