From 5896ac9e073c48b60dfbb864abd49dbd0e2b3ad7 Mon Sep 17 00:00:00 2001 From: Mike Danese Date: Fri, 12 Jun 2015 10:20:26 -0700 Subject: [PATCH] skip GetHostIP call on standalone mode kubelet to fix spammy log statement --- cmd/kubelet/app/server.go | 4 ++++ contrib/mesos/pkg/executor/service/service.go | 18 ++++++++++-------- pkg/kubelet/kubelet.go | 17 ++++++++++++----- 3 files changed, 26 insertions(+), 13 deletions(-) diff --git a/cmd/kubelet/app/server.go b/cmd/kubelet/app/server.go index 2fb8bc9dce9..241b835e0e6 100644 --- a/cmd/kubelet/app/server.go +++ b/cmd/kubelet/app/server.go @@ -94,6 +94,7 @@ type KubeletServer struct { OOMScoreAdj int APIServerList util.StringList RegisterNode bool + StandaloneMode bool ClusterDomain string MasterServiceNamespace string ClusterDNS util.IP @@ -332,6 +333,7 @@ func (s *KubeletServer) Run(_ []string) error { MaxPerPodContainerCount: s.MaxPerPodContainerCount, MaxContainerCount: s.MaxContainerCount, RegisterNode: s.RegisterNode, + StandaloneMode: (len(s.APIServerList) == 0), ClusterDomain: s.ClusterDomain, ClusterDNS: s.ClusterDNS, Runonce: s.RunOnce, @@ -662,6 +664,7 @@ type KubeletConfig struct { MaxPerPodContainerCount int MaxContainerCount int RegisterNode bool + StandaloneMode bool ClusterDomain string ClusterDNS util.IP EnableServer bool @@ -722,6 +725,7 @@ func createAndInitKubelet(kc *KubeletConfig) (k KubeletBootstrap, pc *config.Pod gcPolicy, pc.SeenAllSources, kc.RegisterNode, + kc.StandaloneMode, kc.ClusterDomain, net.IP(kc.ClusterDNS), kc.MasterServiceNamespace, diff --git a/contrib/mesos/pkg/executor/service/service.go b/contrib/mesos/pkg/executor/service/service.go index 5de0da0db65..be3335c0dc9 100644 --- a/contrib/mesos/pkg/executor/service/service.go +++ b/contrib/mesos/pkg/executor/service/service.go @@ -218,14 +218,15 @@ func (s *KubeletExecutorServer) Run(hks hyperkube.Interface, _ []string) error { // ManifestURL: "" // FileCheckFrequency // HTTPCheckFrequency - PodInfraContainerImage: s.PodInfraContainerImage, - SyncFrequency: s.SyncFrequency, - RegistryPullQPS: s.RegistryPullQPS, - RegistryBurst: s.RegistryBurst, - MinimumGCAge: s.MinimumGCAge, - MaxPerPodContainerCount: s.MaxPerPodContainerCount, - MaxContainerCount: s.MaxContainerCount, - RegisterNode: s.RegisterNode, + PodInfraContainerImage: s.PodInfraContainerImage, + SyncFrequency: s.SyncFrequency, + RegistryPullQPS: s.RegistryPullQPS, + RegistryBurst: s.RegistryBurst, + MinimumGCAge: s.MinimumGCAge, + MaxPerPodContainerCount: s.MaxPerPodContainerCount, + MaxContainerCount: s.MaxContainerCount, + RegisterNode: s.RegisterNode, + // StandaloneMode: false ClusterDomain: s.ClusterDomain, ClusterDNS: s.ClusterDNS, Runonce: s.RunOnce, @@ -327,6 +328,7 @@ func (ks *KubeletExecutorServer) createAndInitKubelet( gcPolicy, pc.SeenAllSources, kc.RegisterNode, + kc.StandaloneMode, kc.ClusterDomain, net.IP(kc.ClusterDNS), kc.MasterServiceNamespace, diff --git a/pkg/kubelet/kubelet.go b/pkg/kubelet/kubelet.go index c0981db355f..74d0b93d988 100644 --- a/pkg/kubelet/kubelet.go +++ b/pkg/kubelet/kubelet.go @@ -124,6 +124,7 @@ func NewMainKubelet( containerGCPolicy ContainerGCPolicy, sourcesReady SourcesReadyFn, registerNode bool, + standaloneMode bool, clusterDomain string, clusterDNS net.IP, masterServiceNamespace string, @@ -232,6 +233,7 @@ func NewMainKubelet( httpClient: &http.Client{}, sourcesReady: sourcesReady, registerNode: registerNode, + standaloneMode: standaloneMode, clusterDomain: clusterDomain, clusterDNS: clusterDNS, serviceLister: serviceLister, @@ -387,6 +389,9 @@ type Kubelet struct { // Set to true to have the node register itself with the apiserver. registerNode bool + // Set to true if the kubelet is in standalone mode (i.e. setup without an apiserver) + standaloneMode bool + // If non-empty, use this for container DNS search. clusterDomain string @@ -2124,11 +2129,13 @@ func (kl *Kubelet) generatePodStatus(pod *api.Pod) (api.PodStatus, error) { podStatus.Conditions = append(podStatus.Conditions, getPodReadyCondition(spec, podStatus.ContainerStatuses)...) - hostIP, err := kl.GetHostIP() - if err != nil { - glog.Errorf("Cannot get host IP: %v", err) - } else { - podStatus.HostIP = hostIP.String() + if !kl.standaloneMode { + hostIP, err := kl.GetHostIP() + if err != nil { + glog.V(4).Infof("Cannot get host IP: %v", err) + } else { + podStatus.HostIP = hostIP.String() + } } return *podStatus, nil