github/kubernetes
1
0
Fork 0
mirror of https://github.com/k3s-io/kubernetes.git synced 2025-07-29 14:37:00 +00:00
Code Issues Projects Releases Wiki Activity

RC: rename wait -> wg

Browse Source 
We already have a package called "wait". We should make the name different.
This commit is contained in:
Hongchao Deng 2016-06-17 12:16:15 -07:00
parent 3cc43eb0d2
commit b9c8c0fc23
1 changed files with 8 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

16
pkg/controller/replication/replication_controller.go
View File

@ -471,12 +471,12 @@ func (rm *ReplicationManager) manageReplicas(filteredPods []*api.Pod, rc *api.Re
// into a performance bottleneck. We should generate a UID for the pod // into a performance bottleneck. We should generate a UID for the pod
// beforehand and store it via ExpectCreations. // beforehand and store it via ExpectCreations.
rm.expectations.ExpectCreations(rcKey, diff) rm.expectations.ExpectCreations(rcKey, diff)
wait := sync.WaitGroup{} var wg sync.WaitGroup
wait.Add(diff) wg.Add(diff)
glog.V(2).Infof("Too few %q/%q replicas, need %d, creating %d", rc.Namespace, rc.Name, rc.Spec.Replicas, diff) glog.V(2).Infof("Too few %q/%q replicas, need %d, creating %d", rc.Namespace, rc.Name, rc.Spec.Replicas, diff)
for i := 0; i < diff; i++ { for i := 0; i < diff; i++ {
go func() { go func() {
defer wait.Done() defer wg.Done()
if err := rm.podControl.CreatePods(rc.Namespace, rc.Spec.Template, rc); err != nil { if err := rm.podControl.CreatePods(rc.Namespace, rc.Spec.Template, rc); err != nil {
// Decrement the expected number of creates because the informer won't observe this pod // Decrement the expected number of creates because the informer won't observe this pod
glog.V(2).Infof("Failed creation, decrementing expectations for controller %q/%q", rc.Namespace, rc.Name) glog.V(2).Infof("Failed creation, decrementing expectations for controller %q/%q", rc.Namespace, rc.Name)
@ -486,7 +486,7 @@ func (rm *ReplicationManager) manageReplicas(filteredPods []*api.Pod, rc *api.Re
} }
}() }()
} }
wait.Wait() wg.Wait()
} else if diff > 0 { } else if diff > 0 {
if diff > rm.burstReplicas { if diff > rm.burstReplicas {
diff = rm.burstReplicas diff = rm.burstReplicas
@ -513,11 +513,11 @@ func (rm *ReplicationManager) manageReplicas(filteredPods []*api.Pod, rc *api.Re
// labels on a pod/rc change in a way that the pod gets orphaned, the // labels on a pod/rc change in a way that the pod gets orphaned, the
// rc will only wake up after the expectation has expired. // rc will only wake up after the expectation has expired.
rm.expectations.ExpectDeletions(rcKey, deletedPodKeys) rm.expectations.ExpectDeletions(rcKey, deletedPodKeys)
wait := sync.WaitGroup{} var wg sync.WaitGroup
wait.Add(diff) wg.Add(diff)
for i := 0; i < diff; i++ { for i := 0; i < diff; i++ {
go func(ix int) { go func(ix int) {
defer wait.Done() defer wg.Done()
if err := rm.podControl.DeletePod(rc.Namespace, filteredPods[ix].Name, rc); err != nil { if err := rm.podControl.DeletePod(rc.Namespace, filteredPods[ix].Name, rc); err != nil {
// Decrement the expected number of deletes because the informer won't observe this deletion // Decrement the expected number of deletes because the informer won't observe this deletion
podKey := controller.PodKey(filteredPods[ix]) podKey := controller.PodKey(filteredPods[ix])
@ -528,7 +528,7 @@ func (rm *ReplicationManager) manageReplicas(filteredPods []*api.Pod, rc *api.Re
} }
}(i) }(i)
} }
wait.Wait() wg.Wait()
} }
} }