github/kubernetes
1
0
Fork 0
mirror of https://github.com/k3s-io/kubernetes.git synced 2025-09-02 01:39:02 +00:00
Code Issues Projects Releases Wiki Activity

Create fewer pods in Scheduler Predicates e2e test to speed things up.

Browse Source
This commit is contained in:
Quinton Hoole
2015-08-28 10:48:13 -07:00
parent 8d0d54ffed
commit 97ddc9781c
1 changed files with 5 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

9
test/e2e/scheduler_predicates.go
View File

@@ -241,7 +241,7 @@ var _ = Describe("SchedulerPredicates", func() {
cleanupPods(c, ns) cleanupPods(c, ns)
}) })
// This test verifies we don't allow scheduling of pods in a way that sum of limits of pods is greater than machines capacit. // This test verifies we don't allow scheduling of pods in a way that sum of limits of pods is greater than machines capacity.
// It assumes that cluster add-on pods stay stable and cannot be run in parallel with any other test that touches Nodes or Pods. // It assumes that cluster add-on pods stay stable and cannot be run in parallel with any other test that touches Nodes or Pods.
// It is so because we need to have precise control on what's running in the cluster. // It is so because we need to have precise control on what's running in the cluster.
It("validates resource limits of pods that are allowed to run.", func() { It("validates resource limits of pods that are allowed to run.", func() {
@@ -267,9 +267,10 @@ var _ = Describe("SchedulerPredicates", func() {
} }
var podsNeededForSaturation int var podsNeededForSaturation int
milliCpuPerPod := int64(500)
for name, leftCapacity := range nodeToCapacityMap { for name, leftCapacity := range nodeToCapacityMap {
Logf("Node: %v has capacity: %v", name, leftCapacity) Logf("Node: %v has capacity: %v", name, leftCapacity)
podsNeededForSaturation += (int)(leftCapacity / 100) podsNeededForSaturation += (int)(leftCapacity / milliCpuPerPod)
} }
By(fmt.Sprintf("Starting additional %v Pods to fully saturate the cluster CPU and trying to start another one", podsNeededForSaturation)) By(fmt.Sprintf("Starting additional %v Pods to fully saturate the cluster CPU and trying to start another one", podsNeededForSaturation))
@@ -289,7 +290,7 @@ var _ = Describe("SchedulerPredicates", func() {
Image: "gcr.io/google_containers/pause:go", Image: "gcr.io/google_containers/pause:go",
Resources: api.ResourceRequirements{ Resources: api.ResourceRequirements{
Limits: api.ResourceList{ Limits: api.ResourceList{
"cpu": *resource.NewMilliQuantity(100, "DecimalSI"), "cpu": *resource.NewMilliQuantity(milliCpuPerPod, "DecimalSI"),
}, },
}, },
}, },
@@ -313,7 +314,7 @@ var _ = Describe("SchedulerPredicates", func() {
Image: "gcr.io/google_containers/pause:go", Image: "gcr.io/google_containers/pause:go",
Resources: api.ResourceRequirements{ Resources: api.ResourceRequirements{
Limits: api.ResourceList{ Limits: api.ResourceList{
"cpu": *resource.NewMilliQuantity(100, "DecimalSI"), "cpu": *resource.NewMilliQuantity(milliCpuPerPod, "DecimalSI"),
}, },
}, },
}, },