github/kubernetes
1
0
Fork 0
mirror of https://github.com/k3s-io/kubernetes.git synced 2025-07-29 06:27:05 +00:00
Code Issues Projects Releases Wiki Activity

make a copy when sort array using cpu usage

Browse Source
This commit is contained in:
Zhou Fang 2016-08-08 16:44:25 -07:00
parent 475f6c5ef6
commit e9c1cb9b78
2 changed files with 7 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
test/e2e_node/density_test.go
View File

@ -185,7 +185,7 @@ var _ = framework.KubeDescribe("Density [Serial] [Slow]", func() {
// verify resource // verify resource
By("Verifying resource") By("Verifying resource")
verifyResource(f, testArg, rc) verifyResource(f, itArg, rc)
}) })
} }
}) })
@ -242,7 +242,7 @@ var _ = framework.KubeDescribe("Density [Serial] [Slow]", func() {
// verify resource // verify resource
By("Verifying resource") By("Verifying resource")
verifyResource(f, testArg, rc) verifyResource(f, itArg, rc)
}) })
} }
}) })

6
test/e2e_node/resource_controller.go → test/e2e_node/resource_collector.go
View File

@ -203,7 +203,11 @@ func (r *ResourceCollector) GetBasicCPUStats(containerName string) map[float64]f
r.lock.RLock() r.lock.RLock()
defer r.lock.RUnlock() defer r.lock.RUnlock()
result := make(map[float64]float64, len(percentiles)) result := make(map[float64]float64, len(percentiles))
usages := r.buffers[containerName] usages := make([]*framework.ContainerResourceUsage, len(r.buffers[containerName]))
// must make a copy of array, otherwise the timeseries order is changed
for i, usage := range r.buffers[containerName] {
usages[i] = usage
}
sort.Sort(resourceUsageByCPU(usages)) sort.Sort(resourceUsageByCPU(usages))
for _, q := range percentiles { for _, q := range percentiles {
index := int(float64(len(usages))*q) - 1 index := int(float64(len(usages))*q) - 1