From dc62007478a2616f8b37f420cc72e49c4ef9cc5d Mon Sep 17 00:00:00 2001 From: Xiang Li Date: Mon, 3 Oct 2016 18:45:45 -0700 Subject: [PATCH] scheduler: cache.delete deletes the pod from node specified in the cached state --- plugin/pkg/scheduler/schedulercache/cache.go | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/plugin/pkg/scheduler/schedulercache/cache.go b/plugin/pkg/scheduler/schedulercache/cache.go index 556aea3082..985f9ed0f7 100644 --- a/plugin/pkg/scheduler/schedulercache/cache.go +++ b/plugin/pkg/scheduler/schedulercache/cache.go @@ -244,12 +244,12 @@ func (cache *schedulerCache) RemovePod(pod *api.Pod) error { cache.mu.Lock() defer cache.mu.Unlock() - _, ok := cache.podStates[key] + cachedstate, ok := cache.podStates[key] switch { // An assumed pod won't have Delete/Remove event. It needs to have Add event // before Remove event, in which case the state would change from Assumed to Added. case ok && !cache.assumedPods[key]: - err := cache.removePod(pod) + err := cache.removePod(cachedstate.pod) if err != nil { return err }