mirror of
https://github.com/k3s-io/kubernetes.git
synced 2025-07-23 19:56:01 +00:00
Merge pull request #10345 from wojtek-t/increase_rc_timeout
Increase timeout for waiting for pods running in load test
This commit is contained in:
commit
8b0efe8b85
@ -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
|
||||
|
||||
@ -966,10 +967,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