mirror of
https://github.com/k3s-io/kubernetes.git
synced 2025-07-31 23:37:01 +00:00
Merge pull request #45530 from zhangxiaoyu-zidif/e2e-delete-redundant-para
Automatic merge from submit-queue util.go: format for **What this PR does / why we need it**: format for. delete redundant para. make code clean. **Release note**: ```release-note NONE ```
This commit is contained in:
commit
6328ca6fc1
@ -4051,12 +4051,12 @@ func CheckPodsCondition(c clientset.Interface, ns string, podNames []string, tim
|
|||||||
np := len(podNames)
|
np := len(podNames)
|
||||||
Logf("Waiting up to %v for %d pods to be %s: %s", timeout, np, desc, podNames)
|
Logf("Waiting up to %v for %d pods to be %s: %s", timeout, np, desc, podNames)
|
||||||
result := make(chan bool, len(podNames))
|
result := make(chan bool, len(podNames))
|
||||||
for ix := range podNames {
|
for _, podName := range podNames {
|
||||||
// Launch off pod readiness checkers.
|
// Launch off pod readiness checkers.
|
||||||
go func(name string) {
|
go func(name string) {
|
||||||
err := WaitForPodCondition(c, ns, name, desc, timeout, condition)
|
err := WaitForPodCondition(c, ns, name, desc, timeout, condition)
|
||||||
result <- err == nil
|
result <- err == nil
|
||||||
}(podNames[ix])
|
}(podName)
|
||||||
}
|
}
|
||||||
// Wait for them all to finish.
|
// Wait for them all to finish.
|
||||||
success := true
|
success := true
|
||||||
@ -4801,8 +4801,7 @@ func ensureGCELoadBalancerResourcesDeleted(ip, portRange string) error {
|
|||||||
if err != nil {
|
if err != nil {
|
||||||
return false, err
|
return false, err
|
||||||
}
|
}
|
||||||
for ix := range list.Items {
|
for _, item := range list.Items {
|
||||||
item := list.Items[ix]
|
|
||||||
if item.PortRange == portRange && item.IPAddress == ip {
|
if item.PortRange == portRange && item.IPAddress == ip {
|
||||||
Logf("found a load balancer: %v", item)
|
Logf("found a load balancer: %v", item)
|
||||||
return false, nil
|
return false, nil
|
||||||
|
Loading…
Reference in New Issue
Block a user