From 4ac6129578af00f3d3d845a2c67850ef1e0f0260 Mon Sep 17 00:00:00 2001 From: Yifan Gu Date: Fri, 4 Dec 2015 14:46:36 -0800 Subject: [PATCH] kubelet: Small refactor on GetPhase(). --- pkg/kubelet/kubelet.go | 40 ++++++++++++++++++++++------------------ 1 file changed, 22 insertions(+), 18 deletions(-) diff --git a/pkg/kubelet/kubelet.go b/pkg/kubelet/kubelet.go index c2242ea534..1da673174a 100644 --- a/pkg/kubelet/kubelet.go +++ b/pkg/kubelet/kubelet.go @@ -2955,29 +2955,33 @@ func GetPhase(spec *api.PodSpec, info []api.ContainerStatus) api.PodPhase { succeeded := 0 unknown := 0 for _, container := range spec.Containers { - if containerStatus, ok := api.GetContainerStatus(info, container.Name); ok { - if containerStatus.State.Running != nil { - running++ - } else if containerStatus.State.Terminated != nil { - stopped++ - if containerStatus.State.Terminated.ExitCode == 0 { - succeeded++ - } else { - failed++ - } - } else if containerStatus.State.Waiting != nil { - if containerStatus.LastTerminationState.Terminated != nil { - stopped++ - } else { - waiting++ - } + containerStatus, ok := api.GetContainerStatus(info, container.Name) + if !ok { + unknown++ + continue + } + + switch { + case containerStatus.State.Running != nil: + running++ + case containerStatus.State.Terminated != nil: + stopped++ + if containerStatus.State.Terminated.ExitCode == 0 { + succeeded++ } else { - unknown++ + failed++ } - } else { + case containerStatus.State.Waiting != nil: + if containerStatus.LastTerminationState.Terminated != nil { + stopped++ + } else { + waiting++ + } + default: unknown++ } } + switch { case waiting > 0: glog.V(5).Infof("pod waiting > 0, pending")