pass the ingress in or the 2nd invocation will be used

kubernetes · Mar 13, 2017 · 0fa2a32 · 0fa2a32
1 parent 448a42a
commit 0fa2a32
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/core/pkg/ingress/status/status.go b/core/pkg/ingress/status/status.go
@@ -252,7 +252,7 @@ func (s *statusSync) updateStatus(newIPs []api.LoadBalancerIngress) {
 			continue
 		}
 
-		go func(wg *sync.WaitGroup) {
+		go func(wg *sync.WaitGroup, ing *extensions.Ingress) {
 			defer wg.Done()
 			ingClient := s.Client.Extensions().Ingresses(ing.Namespace)
 			currIng, err := ingClient.Get(ing.Name)
@@ -274,7 +274,7 @@ func (s *statusSync) updateStatus(newIPs []api.LoadBalancerIngress) {
 			if err != nil {
 				glog.Warningf("error updating ingress rule: %v", err)
 			}
-		}(&wg)
+		}(&wg, ing)
 	}
 
 	wg.Wait()