mirror of https://github.com/k3s-io/k3s
Adds replication controller name to "Too many|few" logging
parent
3bc8f4e793
commit
38230ef12f
|
@ -198,7 +198,7 @@ func (rm *ReplicationManager) syncReplicationController(controller api.Replicati
|
||||||
diff *= -1
|
diff *= -1
|
||||||
wait := sync.WaitGroup{}
|
wait := sync.WaitGroup{}
|
||||||
wait.Add(diff)
|
wait.Add(diff)
|
||||||
glog.V(2).Infof("Too few replicas, creating %d\n", diff)
|
glog.V(2).Infof("Too few \"%s\" replicas, creating %d\n", controller.Name, diff)
|
||||||
for i := 0; i < diff; i++ {
|
for i := 0; i < diff; i++ {
|
||||||
go func() {
|
go func() {
|
||||||
defer wait.Done()
|
defer wait.Done()
|
||||||
|
@ -207,7 +207,7 @@ func (rm *ReplicationManager) syncReplicationController(controller api.Replicati
|
||||||
}
|
}
|
||||||
wait.Wait()
|
wait.Wait()
|
||||||
} else if diff > 0 {
|
} else if diff > 0 {
|
||||||
glog.V(2).Infof("Too many replicas, deleting %d\n", diff)
|
glog.V(2).Infof("Too many \"%s\" replicas, deleting %d\n", controller.Name, diff)
|
||||||
wait := sync.WaitGroup{}
|
wait := sync.WaitGroup{}
|
||||||
wait.Add(diff)
|
wait.Add(diff)
|
||||||
for i := 0; i < diff; i++ {
|
for i := 0; i < diff; i++ {
|
||||||
|
|
Loading…
Reference in New Issue