From eb1c453a9aa81bd689183ad0928c422266323134 Mon Sep 17 00:00:00 2001 From: Vishnu Kannan Date: Fri, 3 Apr 2015 20:19:52 +0000 Subject: [PATCH] Updating kube-proxy logging levels to assist debugging. --- pkg/proxy/proxier.go | 2 +- pkg/proxy/roundrobin.go | 6 +++--- 2 files changed, 4 insertions(+), 4 deletions(-) diff --git a/pkg/proxy/proxier.go b/pkg/proxy/proxier.go index e6acd9712dfe5..d297e3392ee71 100644 --- a/pkg/proxy/proxier.go +++ b/pkg/proxy/proxier.go @@ -360,7 +360,7 @@ func (proxier *Proxier) SyncLoop() { for { select { case <-time.After(syncInterval): - glog.V(2).Infof("Periodic sync") + glog.V(3).Infof("Periodic sync") if err := iptablesInit(proxier.iptables); err != nil { glog.Errorf("Failed to ensure iptables: %v", err) } diff --git a/pkg/proxy/roundrobin.go b/pkg/proxy/roundrobin.go index c1bd4ab835438..26031691ab0df 100644 --- a/pkg/proxy/roundrobin.go +++ b/pkg/proxy/roundrobin.go @@ -214,7 +214,7 @@ func (lb *LoadBalancerRR) updateAffinityMap(svcPort ServicePortName, newEndpoint } for mKey, mVal := range allEndpoints { if mVal == 1 { - glog.V(3).Infof("Delete endpoint %s for service %q", mKey, svcPort) + glog.V(2).Infof("Delete endpoint %s for service %q", mKey, svcPort) removeSessionAffinityByEndpoint(state, svcPort, mKey) } } @@ -257,7 +257,7 @@ func (lb *LoadBalancerRR) OnUpdate(allEndpoints []api.Endpoints) { newEndpoints := flattenValidEndpoints(portsToEndpoints[portname]) if !exists || state == nil || len(curEndpoints) != len(newEndpoints) || !slicesEquiv(slice.CopyStrings(curEndpoints), newEndpoints) { - glog.V(3).Infof("LoadBalancerRR: Setting endpoints for %s to %+v", svcPort, newEndpoints) + glog.V(1).Infof("LoadBalancerRR: Setting endpoints for %s to %+v", svcPort, newEndpoints) lb.updateAffinityMap(svcPort, newEndpoints) // OnUpdate can be called without NewService being called externally. // To be safe we will call it here. A new service will only be created @@ -274,7 +274,7 @@ func (lb *LoadBalancerRR) OnUpdate(allEndpoints []api.Endpoints) { // Remove endpoints missing from the update. for k := range lb.services { if _, exists := registeredEndpoints[k]; !exists { - glog.V(3).Infof("LoadBalancerRR: Removing endpoints for %s", k) + glog.V(2).Infof("LoadBalancerRR: Removing endpoints for %s", k) delete(lb.services, k) } }