From ede4fb4a37a854968a74349ae5b93f7909679693 Mon Sep 17 00:00:00 2001 From: Xiang Li Date: Tue, 14 Apr 2015 17:53:13 -0700 Subject: [PATCH 1/3] pkg/kubelet: remove unnecessary wrapper code in pod_manager.go --- pkg/kubelet/pod_manager.go | 12 +----------- 1 file changed, 1 insertion(+), 11 deletions(-) diff --git a/pkg/kubelet/pod_manager.go b/pkg/kubelet/pod_manager.go index 1f261e87641..1c4984cc067 100644 --- a/pkg/kubelet/pod_manager.go +++ b/pkg/kubelet/pod_manager.go @@ -72,7 +72,7 @@ type basicPodManager struct { mirrorPodByFullName map[string]*api.Pod // A mirror pod client to create/delete mirror pods. - mirrorClient mirrorClient + mirrorClient } func newBasicPodManager(apiserverClient client.Interface) *basicPodManager { @@ -271,16 +271,6 @@ func (self *basicPodManager) DeleteOrphanedMirrorPods() { } } -// Creates a mirror pod for the given pod. -func (self *basicPodManager) CreateMirrorPod(pod api.Pod) error { - return self.mirrorClient.CreateMirrorPod(pod) -} - -// Delete a mirror pod by name. -func (self *basicPodManager) DeleteMirrorPod(podFullName string) error { - return self.mirrorClient.DeleteMirrorPod(podFullName) -} - // Returns true if mirrorPod is a correct representation of pod; false otherwise. func (self *basicPodManager) IsMirrorPodOf(mirrorPod, pod *api.Pod) bool { // Check name and namespace first. From 864f9b4a8afb5833be37746439cb7c7ca7457118 Mon Sep 17 00:00:00 2001 From: Xiang Li Date: Tue, 14 Apr 2015 18:07:45 -0700 Subject: [PATCH 2/3] pkg/kubelet: drop unnecessary receiver in pod_manager.go --- pkg/kubelet/pod_manager.go | 22 +++++++++++----------- 1 file changed, 11 insertions(+), 11 deletions(-) diff --git a/pkg/kubelet/pod_manager.go b/pkg/kubelet/pod_manager.go index 1c4984cc067..6df8d5ee628 100644 --- a/pkg/kubelet/pod_manager.go +++ b/pkg/kubelet/pod_manager.go @@ -179,24 +179,16 @@ func applyUpdates(changed []api.Pod, current []api.Pod) []api.Pod { return updated } -func (self *basicPodManager) convertMapToPods(UIDMap map[types.UID]*api.Pod) []api.Pod { - pods := make([]api.Pod, 0, len(UIDMap)) - for _, pod := range UIDMap { - pods = append(pods, *pod) - } - return pods -} - // GetPods returns the regular pods bound to the kubelet and their spec. func (self *basicPodManager) GetPods() []api.Pod { self.lock.RLock() defer self.lock.RUnlock() - return self.convertMapToPods(self.podByUID) + return podsMapToPods(self.podByUID) } // Returns all pods (including mirror pods). func (self *basicPodManager) getAllPods() []api.Pod { - return append(self.convertMapToPods(self.podByUID), self.convertMapToPods(self.mirrorPodByUID)...) + return append(podsMapToPods(self.podByUID), podsMapToPods(self.mirrorPodByUID)...) } // GetPodsAndMirrorMap returns the a copy of the regular pods and the mirror @@ -208,7 +200,7 @@ func (self *basicPodManager) GetPodsAndMirrorMap() ([]api.Pod, map[string]api.Po for key, pod := range self.mirrorPodByFullName { mirrorPods[key] = *pod } - return self.convertMapToPods(self.podByUID), mirrorPods + return podsMapToPods(self.podByUID), mirrorPods } // GetPodByName provides the (non-mirror) pod that matches namespace and name, @@ -279,3 +271,11 @@ func (self *basicPodManager) IsMirrorPodOf(mirrorPod, pod *api.Pod) bool { } return api.Semantic.DeepEqual(&pod.Spec, &mirrorPod.Spec) } + +func podsMapToPods(UIDMap map[types.UID]*api.Pod) []api.Pod { + pods := make([]api.Pod, 0, len(UIDMap)) + for _, pod := range UIDMap { + pods = append(pods, *pod) + } + return pods +} From 28c17262327ece3f4b1e1db4b7099a9ecf4cfcf9 Mon Sep 17 00:00:00 2001 From: Xiang Li Date: Tue, 14 Apr 2015 18:30:47 -0700 Subject: [PATCH 3/3] pkg/kubelet: minor cleanup in pod_manager.go --- pkg/kubelet/pod_manager.go | 6 ++---- 1 file changed, 2 insertions(+), 4 deletions(-) diff --git a/pkg/kubelet/pod_manager.go b/pkg/kubelet/pod_manager.go index 6df8d5ee628..11658998150 100644 --- a/pkg/kubelet/pod_manager.go +++ b/pkg/kubelet/pod_manager.go @@ -215,10 +215,8 @@ func (self *basicPodManager) GetPodByName(namespace, name string) (*api.Pod, boo func (self *basicPodManager) GetPodByFullName(podFullName string) (*api.Pod, bool) { self.lock.RLock() defer self.lock.RUnlock() - if pod, ok := self.podByFullName[podFullName]; ok { - return pod, true - } - return nil, false + pod, ok := self.podByFullName[podFullName] + return pod, ok } // If the UID belongs to a mirror pod, maps it to the UID of its static pod.