scheduler: cache.delete deletes the pod from node specified in the cached state

pull/6/head
Xiang Li 2016-10-03 18:45:45 -07:00
parent 186a4a06c6
commit dc62007478
1 changed files with 2 additions and 2 deletions

View File

@ -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
}