github/kubernetes
1
0
Fork 0
mirror of https://github.com/k3s-io/kubernetes.git synced 2025-08-04 01:40:07 +00:00
Code Issues Projects Releases Wiki Activity

kubelet: delete unused code

Browse Source
This commit is contained in:
Euan Kemp 2016-07-08 02:03:51 -07:00 committed by Euan Kemp
parent 2296108886
commit 26e0f50504
3 changed files with 2 additions and 26 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
pkg/kubelet/kubelet.go
View File

@ -2357,19 +2357,6 @@ func (kl *Kubelet) isOutOfDisk() bool {
return false return false
} }
// matchesNodeSelector returns true if pod matches node's labels.
func (kl *Kubelet) matchesNodeSelector(pod *api.Pod) bool {
if kl.standaloneMode {
return true
}
node, err := kl.GetNode()
if err != nil {
glog.Errorf("error getting node: %v", err)
return false
}
return predicates.PodMatchesNodeLabels(pod, node)
}
// rejectPod records an event about the pod with the given reason and message, // rejectPod records an event about the pod with the given reason and message,
// and updates the pod to the failed phase in the status manage. // and updates the pod to the failed phase in the status manage.
func (kl *Kubelet) rejectPod(pod *api.Pod, reason, message string) { func (kl *Kubelet) rejectPod(pod *api.Pod, reason, message string) {

11
pkg/kubelet/kubelet_test.go
View File

@ -22,7 +22,6 @@ import (
"io" "io"
"io/ioutil" "io/ioutil"
"net" "net"
"net/http"
"os" "os"
"reflect" "reflect"
goruntime "runtime" goruntime "runtime"
@ -100,16 +99,6 @@ const (
maxImgSize int64 = 1000 * 1024 * 1024 maxImgSize int64 = 1000 * 1024 * 1024
) )
type fakeHTTP struct {
url string
err error
}
func (f *fakeHTTP) Get(url string) (*http.Response, error) {
f.url = url
return nil, f.err
}
type TestKubelet struct { type TestKubelet struct {
kubelet *Kubelet kubelet *Kubelet
fakeRuntime *containertest.FakeRuntime fakeRuntime *containertest.FakeRuntime

4
plugin/pkg/scheduler/algorithm/predicates/predicates.go
View File

@ -492,7 +492,7 @@ func nodeMatchesNodeSelectorTerms(node *api.Node, nodeSelectorTerms []api.NodeSe
} }
// The pod can only schedule onto nodes that satisfy requirements in both NodeAffinity and nodeSelector. // The pod can only schedule onto nodes that satisfy requirements in both NodeAffinity and nodeSelector.
func PodMatchesNodeLabels(pod *api.Pod, node *api.Node) bool { func podMatchesNodeLabels(pod *api.Pod, node *api.Node) bool {
// Check if node.Labels match pod.Spec.NodeSelector. // Check if node.Labels match pod.Spec.NodeSelector.
if len(pod.Spec.NodeSelector) > 0 { if len(pod.Spec.NodeSelector) > 0 {
selector := labels.SelectorFromSet(pod.Spec.NodeSelector) selector := labels.SelectorFromSet(pod.Spec.NodeSelector)
@ -549,7 +549,7 @@ func PodSelectorMatches(pod *api.Pod, nodeInfo *schedulercache.NodeInfo) (bool,
if node == nil { if node == nil {
return false, fmt.Errorf("node not found") return false, fmt.Errorf("node not found")
} }
if PodMatchesNodeLabels(pod, node) { if podMatchesNodeLabels(pod, node) {
return true, nil return true, nil
} }
return false, ErrNodeSelectorNotMatch return false, ErrNodeSelectorNotMatch