mirror of
https://github.com/k3s-io/kubernetes.git
synced 2025-08-08 19:47:56 +00:00
Increase timeout for waiting for RC in load test
This commit is contained in:
parent
91fc1af928
commit
c151f6bc1f
@ -157,6 +157,7 @@ func generateRCConfigsForGroup(c *client.Client, ns, groupName string, size, cou
|
||||
Client: c,
|
||||
Name: groupName + "-" + strconv.Itoa(i),
|
||||
Namespace: ns,
|
||||
Timeout: 10 * time.Minute,
|
||||
Image: image,
|
||||
Replicas: size,
|
||||
}
|
||||
|
@ -157,6 +157,7 @@ type RCConfig struct {
|
||||
Name string
|
||||
Namespace string
|
||||
PollInterval time.Duration
|
||||
Timeout time.Duration
|
||||
PodStatusFile *os.File
|
||||
Replicas int
|
||||
|
||||
@ -969,10 +970,14 @@ func RunRC(config RCConfig) error {
|
||||
if interval <= 0 {
|
||||
interval = 10 * time.Second
|
||||
}
|
||||
timeout := config.Timeout
|
||||
if timeout <= 0 {
|
||||
timeout = 5 * time.Minute
|
||||
}
|
||||
oldPods := make([]*api.Pod, 0)
|
||||
oldRunning := 0
|
||||
lastChange := time.Now()
|
||||
for oldRunning != config.Replicas && time.Since(lastChange) < 5*time.Minute {
|
||||
for oldRunning != config.Replicas && time.Since(lastChange) < timeout {
|
||||
time.Sleep(interval)
|
||||
|
||||
running := 0
|
||||
|
Loading…
Reference in New Issue
Block a user