upstream/kubernetes
1
0
Fork 0
mirror of https://github.com/kubernetes/kubernetes.git synced 2026-06-09 00:34:10 -04:00
Code Issues Projects Releases Packages Wiki Activity Actions

clean: add nodeinfo to cache

Browse source 
Signed-off-by: likakuli <1154584512@qq.com>
This commit is contained in:
likakuli 2024-06-25 14:17:14 +08:00
parent 535e833aef
commit ea6ca270b5
1 changed files with 6 additions and 0 deletions
Show stats 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)