Skip to content

K
k3s
Commit 3191b26b authored by Robert Rati's avatar Robert Rati
Browse files
Options

Only sleep 1.1*interval. #7572

parent 7361f751
Hide whitespace changes
Inline Side-by-side
Showing with 2 additions and 2 deletions
test/e2e/util.go
View file @ 3191b26b
...@@ -555,7 +555,7 @@ func RunRC(config RCConfig) error { ...@@ -555,7 +555,7 @@ func RunRC(config RCConfig) error {
By(fmt.Sprintf("Making sure all %d replicas of rc %s in namespace %s exist", replicas, name, ns)) By(fmt.Sprintf("Making sure all %d replicas of rc %s in namespace %s exist", replicas, name, ns))
failCount := int(25 / interval) failCount := int(25 / interval)
for same < failCount && current < replicas { for same < failCount && current < replicas {
time.Sleep(time.Duration(interval*2) * time.Second) time.Sleep(time.Duration(float32(interval)*1.1) * time.Second)
// Greedily read all existing entries in the queue until // Greedily read all existing entries in the queue until
// all pods are found submitted or the queue is empty // all pods are found submitted or the queue is empty
...@@ -593,7 +593,7 @@ func RunRC(config RCConfig) error { ...@@ -593,7 +593,7 @@ func RunRC(config RCConfig) error {
podLists.Reset() podLists.Reset()
foundAllPods := false foundAllPods := false
for same < failCount && current < replicas { for same < failCount && current < replicas {
time.Sleep(time.Duration(interval*2) * time.Second) time.Sleep(time.Duration(float32(interval)*1.1) * time.Second)
// Greedily read all existing entries in the queue until // Greedily read all existing entries in the queue until
// either all pods are running or the queue is empty // either all pods are running or the queue is empty
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment