mirror of https://github.com/k3s-io/k3s
Fix scheduler race
parent
a1efb50a29
commit
0728c08a1e
|
@ -191,5 +191,7 @@ type simpleModelerPods struct {
|
||||||
|
|
||||||
// List returns pods known and assumed to exist.
|
// List returns pods known and assumed to exist.
|
||||||
func (s simpleModelerPods) List(selector labels.Selector) (pods []*api.Pod, err error) {
|
func (s simpleModelerPods) List(selector labels.Selector) (pods []*api.Pod, err error) {
|
||||||
return s.simpleModeler.listPods(selector)
|
s.simpleModeler.LockedAction(
|
||||||
|
func() { pods, err = s.simpleModeler.listPods(selector) })
|
||||||
|
return
|
||||||
}
|
}
|
||||||
|
|
Loading…
Reference in New Issue