@@ -2050,6 +2050,7 @@ func setupCacheOf1kNodes30kPods(b *testing.B) Cache {
2050
2050
cache := newCache (ctx , time .Second , time .Second )
2051
2051
for i := 0 ; i < 1000 ; i ++ {
2052
2052
nodeName := fmt .Sprintf ("node-%d" , i )
2053
+ cache .AddNode (logger , st .MakeNode ().Name (nodeName ).Obj ())
2053
2054
for j := 0 ; j < 30 ; j ++ {
2054
2055
objName := fmt .Sprintf ("%s-pod-%d" , nodeName , j )
2055
2056
pod := makeBasePod (b , nodeName , objName , "0" , "0" , "" , nil )
@@ -2065,10 +2066,15 @@ func setupCacheOf1kNodes30kPods(b *testing.B) Cache {
2065
2066
func setupCacheWithAssumedPods (b * testing.B , podNum int , assumedTime time.Time ) * cacheImpl {
2066
2067
logger , ctx := ktesting .NewTestContext (b )
2067
2068
ctx , cancel := context .WithCancel (ctx )
2069
+ addedNodes := make (map [string ]struct {})
2068
2070
defer cancel ()
2069
2071
cache := newCache (ctx , time .Second , time .Second )
2070
2072
for i := 0 ; i < podNum ; i ++ {
2071
2073
nodeName := fmt .Sprintf ("node-%d" , i / 10 )
2074
+ if _ , ok := addedNodes [nodeName ]; ! ok {
2075
+ cache .AddNode (logger , st .MakeNode ().Name (nodeName ).Obj ())
2076
+ addedNodes [nodeName ] = struct {}{}
2077
+ }
2072
2078
objName := fmt .Sprintf ("%s-pod-%d" , nodeName , i % 10 )
2073
2079
pod := makeBasePod (b , nodeName , objName , "0" , "0" , "" , nil )
2074
2080
0 commit comments