github/kubernetes
4
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

kubelet: remove redundant hostNetwork helper

Browse Source 
It did the same thing as the helper in kubecontainer
This commit is contained in:
Euan Kemp 2016-12-07 17:23:04 -08:00
parent ca049360e2
commit 15fc470343
2 changed files with 3 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
pkg/kubelet/kubelet.go
View File

@ -1443,7 +1443,7 @@ func (kl *Kubelet) syncPod(o syncPodOptions) error {
} }
// If the network plugin is not ready, only start the pod if it uses the host network // If the network plugin is not ready, only start the pod if it uses the host network
if rs := kl.runtimeState.networkErrors(); len(rs) != 0 && !podUsesHostNetwork(pod) { if rs := kl.runtimeState.networkErrors(); len(rs) != 0 && !kubecontainer.IsHostNetworkPod(pod) {
return fmt.Errorf("network is not ready: %v", rs) return fmt.Errorf("network is not ready: %v", rs)
} }
@ -1548,7 +1548,7 @@ func (kl *Kubelet) syncPod(o syncPodOptions) error {
return err return err
} }
if egress != nil || ingress != nil { if egress != nil || ingress != nil {
if podUsesHostNetwork(pod) { if kubecontainer.IsHostNetworkPod(pod) {
kl.recorder.Event(pod, v1.EventTypeWarning, events.HostNetworkNotSupported, "Bandwidth shaping is not currently supported on the host network") kl.recorder.Event(pod, v1.EventTypeWarning, events.HostNetworkNotSupported, "Bandwidth shaping is not currently supported on the host network")
} else if kl.shaper != nil { } else if kl.shaper != nil {
if len(apiPodStatus.PodIP) > 0 { if len(apiPodStatus.PodIP) > 0 {

7
pkg/kubelet/kubelet_pods.go
View File

@ -592,11 +592,6 @@ func (kl *Kubelet) makePodDataDirs(pod *v1.Pod) error {
return nil return nil
} }
// returns whether the pod uses the host network namespace.
func podUsesHostNetwork(pod *v1.Pod) bool {
return pod.Spec.HostNetwork
}
// getPullSecretsForPod inspects the Pod and retrieves the referenced pull // getPullSecretsForPod inspects the Pod and retrieves the referenced pull
// secrets. // secrets.
// TODO: duplicate secrets are being retrieved multiple times and there // TODO: duplicate secrets are being retrieved multiple times and there
@ -1066,7 +1061,7 @@ func (kl *Kubelet) generateAPIPodStatus(pod *v1.Pod, podStatus *kubecontainer.Po
glog.V(4).Infof("Cannot get host IP: %v", err) glog.V(4).Infof("Cannot get host IP: %v", err)
} else { } else {
s.HostIP = hostIP.String() s.HostIP = hostIP.String()
if podUsesHostNetwork(pod) && s.PodIP == "" { if kubecontainer.IsHostNetworkPod(pod) && s.PodIP == "" {
s.PodIP = hostIP.String() s.PodIP = hostIP.String()
} }
} }