Commit 28555bb6 authored by Eric Tune's avatar Eric Tune

Merge pull request #3455 from saad-ali/followup3423

Address nits from PR #3423
parents ff908a0d 826b61c7
...@@ -76,7 +76,9 @@ func (c *PodConfig) Channel(source string) chan<- interface{} { ...@@ -76,7 +76,9 @@ func (c *PodConfig) Channel(source string) chan<- interface{} {
return c.mux.Channel(source) return c.mux.Channel(source)
} }
func (c *PodConfig) SourceSeen(source string) bool { // IsSourceSeen returns true if the specified source string has previously
// been marked as seen.
func (c *PodConfig) IsSourceSeen(source string) bool {
if c.pods == nil { if c.pods == nil {
return false return false
} }
......
...@@ -81,7 +81,7 @@ func ParsePodFullName(podFullName string) (podName, podNamespace string, podAnno ...@@ -81,7 +81,7 @@ func ParsePodFullName(podFullName string) (podName, podNamespace string, podAnno
expectedNumFields := 3 expectedNumFields := 3
actualNumFields := len(parts) actualNumFields := len(parts)
if actualNumFields != expectedNumFields { if actualNumFields != expectedNumFields {
glog.Warningf("found a podFullName (%q) with too few fields: expected %d, actual %d.", podFullName, expectedNumFields, actualNumFields) glog.Errorf("found a podFullName (%q) with too few fields: expected %d, actual %d.", podFullName, expectedNumFields, actualNumFields)
return return
} }
podName = parts[0] podName = parts[0]
......
...@@ -274,7 +274,7 @@ func createAndInitKubelet(kc *KubeletConfig, pc *config.PodConfig) (*kubelet.Kub ...@@ -274,7 +274,7 @@ func createAndInitKubelet(kc *KubeletConfig, pc *config.PodConfig) (*kubelet.Kub
kc.RegistryBurst, kc.RegistryBurst,
kc.MinimumGCAge, kc.MinimumGCAge,
kc.MaxContainerCount, kc.MaxContainerCount,
pc.SourceSeen, pc.IsSourceSeen,
kc.ClusterDomain, kc.ClusterDomain,
net.IP(kc.ClusterDNS)) net.IP(kc.ClusterDNS))
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment