github/kubernetes
1
0
Fork 0
mirror of https://github.com/k3s-io/kubernetes.git synced 2025-08-03 01:06:27 +00:00
Code Issues Projects Releases Wiki Activity

Merge pull request #6836 from lavalamp/fix4

Browse Source 
add missing syncronization
This commit is contained in:
Wojciech Tyczynski 2015-04-15 15:25:43 +02:00
commit 20f39cd788
1 changed files with 11 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

18
plugin/pkg/scheduler/factory/factory.go
View File

@ -84,16 +84,20 @@ func NewConfigFactory(client *client.Client) *ConfigFactory {
framework.ResourceEventHandlerFuncs{ framework.ResourceEventHandlerFuncs{
AddFunc: func(obj interface{}) { AddFunc: func(obj interface{}) {
if pod, ok := obj.(*api.Pod); ok { if pod, ok := obj.(*api.Pod); ok {
c.modeler.ForgetPod(pod) c.modeler.LockedAction(func() {
c.modeler.ForgetPod(pod)
})
} }
}, },
DeleteFunc: func(obj interface{}) { DeleteFunc: func(obj interface{}) {
switch t := obj.(type) { c.modeler.LockedAction(func() {
case *api.Pod: switch t := obj.(type) {
c.modeler.ForgetPod(t) case *api.Pod:
case cache.DeletedFinalStateUnknown: c.modeler.ForgetPod(t)
c.modeler.ForgetPodByKey(t.Key) case cache.DeletedFinalStateUnknown:
} c.modeler.ForgetPodByKey(t.Key)
}
})
}, },
}, },
) )