From 6b5118e2b952c5d060ec746140c251764ff661dc Mon Sep 17 00:00:00 2001 From: Avesh Agarwal Date: Wed, 16 Aug 2017 14:55:16 -0400 Subject: [PATCH] Remove duplicate unused function. --- test/e2e/scheduling/predicates.go | 29 ----------------------------- 1 file changed, 29 deletions(-) diff --git a/test/e2e/scheduling/predicates.go b/test/e2e/scheduling/predicates.go index 98a38967a5b..0fd0b89b15a 100644 --- a/test/e2e/scheduling/predicates.go +++ b/test/e2e/scheduling/predicates.go @@ -28,7 +28,6 @@ import ( "k8s.io/apimachinery/pkg/util/sets" "k8s.io/apimachinery/pkg/util/uuid" clientset "k8s.io/client-go/kubernetes" - podutil "k8s.io/kubernetes/pkg/api/v1/pod" "k8s.io/kubernetes/test/e2e/common" "k8s.io/kubernetes/test/e2e/framework" testutils "k8s.io/kubernetes/test/utils" @@ -585,34 +584,6 @@ func createPodWithPodAffinity(f *framework.Framework, topologyKey string) *v1.Po }) } -// Returns a number of currently scheduled and not scheduled Pods. -func getPodsScheduled(pods *v1.PodList) (scheduledPods, notScheduledPods []v1.Pod) { - for _, pod := range pods.Items { - if !masterNodes.Has(pod.Spec.NodeName) { - if pod.Spec.NodeName != "" { - _, scheduledCondition := podutil.GetPodCondition(&pod.Status, v1.PodScheduled) - // We can't assume that the scheduledCondition is always set if Pod is assigned to Node, - // as e.g. DaemonController doesn't set it when assigning Pod to a Node. Currently - // Kubelet sets this condition when it gets a Pod without it, but if we were expecting - // that it would always be not nil, this would cause a rare race condition. - if scheduledCondition != nil { - Expect(scheduledCondition.Status).To(Equal(v1.ConditionTrue)) - } - scheduledPods = append(scheduledPods, pod) - } else { - _, scheduledCondition := podutil.GetPodCondition(&pod.Status, v1.PodScheduled) - if scheduledCondition != nil { - Expect(scheduledCondition.Status).To(Equal(v1.ConditionFalse)) - } - if scheduledCondition.Reason == "Unschedulable" { - notScheduledPods = append(notScheduledPods, pod) - } - } - } - } - return -} - func getRequestedCPU(pod v1.Pod) int64 { var result int64 for _, container := range pod.Spec.Containers {