scottk/kubernetes
1
0
Fork 0
mirror of https://github.com/optim-enterprises-bv/kubernetes.git synced 2025-11-03 19:58:17 +00:00
Code Issues Packages Projects Releases Wiki Activity

Merge pull request #125683 from likakuli/fix-benchmarkupdatesnapshot

Browse Source 
clean: add nodeinfo to cache
This commit is contained in:
Kubernetes Prow Robot
2024-06-25 14:18:39 -07:00
committed by GitHub
parent beb48b7f5d ea6ca270b5
commit d0579b6f9c
1 changed files with 6 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
pkg/scheduler/internal/cache/cache_test.go vendored
View File

@@ -2050,6 +2050,7 @@ func setupCacheOf1kNodes30kPods(b *testing.B) Cache {
cache := newCache(ctx, time.Second, time.Second)
for i := 0; i < 1000; i++ {
nodeName := fmt.Sprintf("node-%d", i)
cache.AddNode(logger, st.MakeNode().Name(nodeName).Obj())
for j := 0; j < 30; j++ {
objName := fmt.Sprintf("%s-pod-%d", nodeName, j)
pod := makeBasePod(b, nodeName, objName, "0", "0", "", nil)
@@ -2065,10 +2066,15 @@ func setupCacheOf1kNodes30kPods(b *testing.B) Cache {
func setupCacheWithAssumedPods(b *testing.B, podNum int, assumedTime time.Time) *cacheImpl {
logger, ctx := ktesting.NewTestContext(b)
ctx, cancel := context.WithCancel(ctx)
addedNodes := make(map[string]struct{})
defer cancel()
cache := newCache(ctx, time.Second, time.Second)
for i := 0; i < podNum; i++ {
nodeName := fmt.Sprintf("node-%d", i/10)
if _, ok := addedNodes[nodeName]; !ok {
cache.AddNode(logger, st.MakeNode().Name(nodeName).Obj())
addedNodes[nodeName] = struct{}{}
}
objName := fmt.Sprintf("%s-pod-%d", nodeName, i%10)
pod := makeBasePod(b, nodeName, objName, "0", "0", "", nil)