mirror of
				https://github.com/optim-enterprises-bv/kubernetes.git
				synced 2025-11-04 04:08:16 +00:00 
			
		
		
		
	
		
			
				
	
	
		
			2123 lines
		
	
	
		
			70 KiB
		
	
	
	
		
			Go
		
	
	
	
	
	
			
		
		
	
	
			2123 lines
		
	
	
		
			70 KiB
		
	
	
	
		
			Go
		
	
	
	
	
	
/*
 | 
						|
Copyright 2015 The Kubernetes Authors.
 | 
						|
 | 
						|
Licensed under the Apache License, Version 2.0 (the "License");
 | 
						|
you may not use this file except in compliance with the License.
 | 
						|
You may obtain a copy of the License at
 | 
						|
 | 
						|
    http://www.apache.org/licenses/LICENSE-2.0
 | 
						|
 | 
						|
Unless required by applicable law or agreed to in writing, software
 | 
						|
distributed under the License is distributed on an "AS IS" BASIS,
 | 
						|
WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 | 
						|
See the License for the specific language governing permissions and
 | 
						|
limitations under the License.
 | 
						|
*/
 | 
						|
 | 
						|
package daemon
 | 
						|
 | 
						|
import (
 | 
						|
	"fmt"
 | 
						|
	"reflect"
 | 
						|
	"sort"
 | 
						|
	"strconv"
 | 
						|
	"sync"
 | 
						|
	"testing"
 | 
						|
 | 
						|
	"k8s.io/api/core/v1"
 | 
						|
	extensions "k8s.io/api/extensions/v1beta1"
 | 
						|
	"k8s.io/apimachinery/pkg/api/resource"
 | 
						|
	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
 | 
						|
	"k8s.io/apimachinery/pkg/runtime"
 | 
						|
	"k8s.io/apimachinery/pkg/util/intstr"
 | 
						|
	"k8s.io/apimachinery/pkg/util/uuid"
 | 
						|
	"k8s.io/apiserver/pkg/storage/names"
 | 
						|
	utilfeature "k8s.io/apiserver/pkg/util/feature"
 | 
						|
	"k8s.io/client-go/informers"
 | 
						|
	"k8s.io/client-go/kubernetes/fake"
 | 
						|
	core "k8s.io/client-go/testing"
 | 
						|
	"k8s.io/client-go/tools/cache"
 | 
						|
	"k8s.io/client-go/tools/record"
 | 
						|
	"k8s.io/client-go/util/workqueue"
 | 
						|
	"k8s.io/kubernetes/pkg/api"
 | 
						|
	"k8s.io/kubernetes/pkg/api/testapi"
 | 
						|
	podutil "k8s.io/kubernetes/pkg/api/v1/pod"
 | 
						|
	"k8s.io/kubernetes/pkg/controller"
 | 
						|
	kubelettypes "k8s.io/kubernetes/pkg/kubelet/types"
 | 
						|
	"k8s.io/kubernetes/pkg/securitycontext"
 | 
						|
	labelsutil "k8s.io/kubernetes/pkg/util/labels"
 | 
						|
	"k8s.io/kubernetes/plugin/pkg/scheduler/algorithm"
 | 
						|
)
 | 
						|
 | 
						|
var (
 | 
						|
	simpleDaemonSetLabel  = map[string]string{"name": "simple-daemon", "type": "production"}
 | 
						|
	simpleDaemonSetLabel2 = map[string]string{"name": "simple-daemon", "type": "test"}
 | 
						|
	simpleNodeLabel       = map[string]string{"color": "blue", "speed": "fast"}
 | 
						|
	simpleNodeLabel2      = map[string]string{"color": "red", "speed": "fast"}
 | 
						|
	alwaysReady           = func() bool { return true }
 | 
						|
)
 | 
						|
 | 
						|
var (
 | 
						|
	noScheduleTolerations = []v1.Toleration{{Key: "dedicated", Value: "user1", Effect: "NoSchedule"}}
 | 
						|
	noScheduleTaints      = []v1.Taint{{Key: "dedicated", Value: "user1", Effect: "NoSchedule"}}
 | 
						|
	noExecuteTaints       = []v1.Taint{{Key: "dedicated", Value: "user1", Effect: "NoExecute"}}
 | 
						|
)
 | 
						|
 | 
						|
func nowPointer() *metav1.Time {
 | 
						|
	now := metav1.Now()
 | 
						|
	return &now
 | 
						|
}
 | 
						|
 | 
						|
var (
 | 
						|
	nodeNotReady = []v1.Taint{{
 | 
						|
		Key:       algorithm.TaintNodeNotReady,
 | 
						|
		Effect:    v1.TaintEffectNoExecute,
 | 
						|
		TimeAdded: nowPointer(),
 | 
						|
	}}
 | 
						|
 | 
						|
	nodeUnreachable = []v1.Taint{{
 | 
						|
		Key:       algorithm.TaintNodeUnreachable,
 | 
						|
		Effect:    v1.TaintEffectNoExecute,
 | 
						|
		TimeAdded: nowPointer(),
 | 
						|
	}}
 | 
						|
)
 | 
						|
 | 
						|
func getKey(ds *extensions.DaemonSet, t *testing.T) string {
 | 
						|
	if key, err := controller.KeyFunc(ds); err != nil {
 | 
						|
		t.Errorf("Unexpected error getting key for ds %v: %v", ds.Name, err)
 | 
						|
		return ""
 | 
						|
	} else {
 | 
						|
		return key
 | 
						|
	}
 | 
						|
}
 | 
						|
 | 
						|
func newDaemonSet(name string) *extensions.DaemonSet {
 | 
						|
	two := int32(2)
 | 
						|
	return &extensions.DaemonSet{
 | 
						|
		TypeMeta: metav1.TypeMeta{APIVersion: testapi.Extensions.GroupVersion().String()},
 | 
						|
		ObjectMeta: metav1.ObjectMeta{
 | 
						|
			UID:       uuid.NewUUID(),
 | 
						|
			Name:      name,
 | 
						|
			Namespace: metav1.NamespaceDefault,
 | 
						|
		},
 | 
						|
		Spec: extensions.DaemonSetSpec{
 | 
						|
			RevisionHistoryLimit: &two,
 | 
						|
			UpdateStrategy: extensions.DaemonSetUpdateStrategy{
 | 
						|
				Type: extensions.OnDeleteDaemonSetStrategyType,
 | 
						|
			},
 | 
						|
			Selector: &metav1.LabelSelector{MatchLabels: simpleDaemonSetLabel},
 | 
						|
			Template: v1.PodTemplateSpec{
 | 
						|
				ObjectMeta: metav1.ObjectMeta{
 | 
						|
					Labels: simpleDaemonSetLabel,
 | 
						|
				},
 | 
						|
				Spec: v1.PodSpec{
 | 
						|
					Containers: []v1.Container{
 | 
						|
						{
 | 
						|
							Image: "foo/bar",
 | 
						|
							TerminationMessagePath: v1.TerminationMessagePathDefault,
 | 
						|
							ImagePullPolicy:        v1.PullIfNotPresent,
 | 
						|
							SecurityContext:        securitycontext.ValidSecurityContextWithContainerDefaults(),
 | 
						|
						},
 | 
						|
					},
 | 
						|
					DNSPolicy: v1.DNSDefault,
 | 
						|
				},
 | 
						|
			},
 | 
						|
		},
 | 
						|
	}
 | 
						|
}
 | 
						|
 | 
						|
func newRollbackStrategy() *extensions.DaemonSetUpdateStrategy {
 | 
						|
	one := intstr.FromInt(1)
 | 
						|
	return &extensions.DaemonSetUpdateStrategy{
 | 
						|
		Type:          extensions.RollingUpdateDaemonSetStrategyType,
 | 
						|
		RollingUpdate: &extensions.RollingUpdateDaemonSet{MaxUnavailable: &one},
 | 
						|
	}
 | 
						|
}
 | 
						|
 | 
						|
func newOnDeleteStrategy() *extensions.DaemonSetUpdateStrategy {
 | 
						|
	return &extensions.DaemonSetUpdateStrategy{
 | 
						|
		Type: extensions.OnDeleteDaemonSetStrategyType,
 | 
						|
	}
 | 
						|
}
 | 
						|
 | 
						|
func updateStrategies() []*extensions.DaemonSetUpdateStrategy {
 | 
						|
	return []*extensions.DaemonSetUpdateStrategy{newOnDeleteStrategy(), newRollbackStrategy()}
 | 
						|
}
 | 
						|
 | 
						|
func newNode(name string, label map[string]string) *v1.Node {
 | 
						|
	return &v1.Node{
 | 
						|
		TypeMeta: metav1.TypeMeta{APIVersion: api.Registry.GroupOrDie(v1.GroupName).GroupVersion.String()},
 | 
						|
		ObjectMeta: metav1.ObjectMeta{
 | 
						|
			Name:      name,
 | 
						|
			Labels:    label,
 | 
						|
			Namespace: metav1.NamespaceDefault,
 | 
						|
		},
 | 
						|
		Status: v1.NodeStatus{
 | 
						|
			Conditions: []v1.NodeCondition{
 | 
						|
				{Type: v1.NodeReady, Status: v1.ConditionTrue},
 | 
						|
			},
 | 
						|
			Allocatable: v1.ResourceList{
 | 
						|
				v1.ResourcePods: resource.MustParse("100"),
 | 
						|
			},
 | 
						|
		},
 | 
						|
	}
 | 
						|
}
 | 
						|
 | 
						|
func addNodes(nodeStore cache.Store, startIndex, numNodes int, label map[string]string) {
 | 
						|
	for i := startIndex; i < startIndex+numNodes; i++ {
 | 
						|
		nodeStore.Add(newNode(fmt.Sprintf("node-%d", i), label))
 | 
						|
	}
 | 
						|
}
 | 
						|
 | 
						|
func newPod(podName string, nodeName string, label map[string]string, ds *extensions.DaemonSet) *v1.Pod {
 | 
						|
	// Add hash unique label to the pod
 | 
						|
	newLabels := label
 | 
						|
	var podSpec v1.PodSpec
 | 
						|
	// Copy pod spec from DaemonSet template, or use a default one if DaemonSet is nil
 | 
						|
	if ds != nil {
 | 
						|
		hash := fmt.Sprint(controller.ComputeHash(&ds.Spec.Template, ds.Status.CollisionCount))
 | 
						|
		newLabels = labelsutil.CloneAndAddLabel(label, extensions.DefaultDaemonSetUniqueLabelKey, hash)
 | 
						|
		podSpec = ds.Spec.Template.Spec
 | 
						|
	} else {
 | 
						|
		podSpec = v1.PodSpec{
 | 
						|
			Containers: []v1.Container{
 | 
						|
				{
 | 
						|
					Image: "foo/bar",
 | 
						|
					TerminationMessagePath: v1.TerminationMessagePathDefault,
 | 
						|
					ImagePullPolicy:        v1.PullIfNotPresent,
 | 
						|
					SecurityContext:        securitycontext.ValidSecurityContextWithContainerDefaults(),
 | 
						|
				},
 | 
						|
			},
 | 
						|
		}
 | 
						|
	}
 | 
						|
	// Add node name to the pod
 | 
						|
	if len(nodeName) > 0 {
 | 
						|
		podSpec.NodeName = nodeName
 | 
						|
	}
 | 
						|
 | 
						|
	pod := &v1.Pod{
 | 
						|
		TypeMeta: metav1.TypeMeta{APIVersion: api.Registry.GroupOrDie(v1.GroupName).GroupVersion.String()},
 | 
						|
		ObjectMeta: metav1.ObjectMeta{
 | 
						|
			GenerateName: podName,
 | 
						|
			Labels:       newLabels,
 | 
						|
			Namespace:    metav1.NamespaceDefault,
 | 
						|
		},
 | 
						|
		Spec: podSpec,
 | 
						|
	}
 | 
						|
	pod.Name = names.SimpleNameGenerator.GenerateName(podName)
 | 
						|
	if ds != nil {
 | 
						|
		pod.OwnerReferences = []metav1.OwnerReference{*metav1.NewControllerRef(ds, controllerKind)}
 | 
						|
	}
 | 
						|
	return pod
 | 
						|
}
 | 
						|
 | 
						|
func addPods(podStore cache.Store, nodeName string, label map[string]string, ds *extensions.DaemonSet, number int) {
 | 
						|
	for i := 0; i < number; i++ {
 | 
						|
		pod := newPod(fmt.Sprintf("%s-", nodeName), nodeName, label, ds)
 | 
						|
		podStore.Add(pod)
 | 
						|
	}
 | 
						|
}
 | 
						|
 | 
						|
func addFailedPods(podStore cache.Store, nodeName string, label map[string]string, ds *extensions.DaemonSet, number int) {
 | 
						|
	for i := 0; i < number; i++ {
 | 
						|
		pod := newPod(fmt.Sprintf("%s-", nodeName), nodeName, label, ds)
 | 
						|
		pod.Status = v1.PodStatus{Phase: v1.PodFailed}
 | 
						|
		podStore.Add(pod)
 | 
						|
	}
 | 
						|
}
 | 
						|
 | 
						|
type fakePodControl struct {
 | 
						|
	sync.Mutex
 | 
						|
	*controller.FakePodControl
 | 
						|
	podStore cache.Store
 | 
						|
	podIDMap map[string]*v1.Pod
 | 
						|
}
 | 
						|
 | 
						|
func newFakePodControl() *fakePodControl {
 | 
						|
	podIDMap := make(map[string]*v1.Pod)
 | 
						|
	return &fakePodControl{
 | 
						|
		FakePodControl: &controller.FakePodControl{},
 | 
						|
		podIDMap:       podIDMap}
 | 
						|
}
 | 
						|
 | 
						|
func (f *fakePodControl) CreatePodsOnNode(nodeName, namespace string, template *v1.PodTemplateSpec, object runtime.Object, controllerRef *metav1.OwnerReference) error {
 | 
						|
	f.Lock()
 | 
						|
	defer f.Unlock()
 | 
						|
	if err := f.FakePodControl.CreatePodsOnNode(nodeName, namespace, template, object, controllerRef); err != nil {
 | 
						|
		return fmt.Errorf("failed to create pod on node %q", nodeName)
 | 
						|
	}
 | 
						|
 | 
						|
	pod := &v1.Pod{
 | 
						|
		ObjectMeta: metav1.ObjectMeta{
 | 
						|
			Labels:       template.Labels,
 | 
						|
			Namespace:    namespace,
 | 
						|
			GenerateName: fmt.Sprintf("%s-", nodeName),
 | 
						|
		},
 | 
						|
	}
 | 
						|
 | 
						|
	if err := api.Scheme.Convert(&template.Spec, &pod.Spec, nil); err != nil {
 | 
						|
		return fmt.Errorf("unable to convert pod template: %v", err)
 | 
						|
	}
 | 
						|
	if len(nodeName) != 0 {
 | 
						|
		pod.Spec.NodeName = nodeName
 | 
						|
	}
 | 
						|
	pod.Name = names.SimpleNameGenerator.GenerateName(fmt.Sprintf("%s-", nodeName))
 | 
						|
 | 
						|
	f.podStore.Update(pod)
 | 
						|
	f.podIDMap[pod.Name] = pod
 | 
						|
	return nil
 | 
						|
}
 | 
						|
 | 
						|
func (f *fakePodControl) DeletePod(namespace string, podID string, object runtime.Object) error {
 | 
						|
	f.Lock()
 | 
						|
	defer f.Unlock()
 | 
						|
	if err := f.FakePodControl.DeletePod(namespace, podID, object); err != nil {
 | 
						|
		return fmt.Errorf("failed to delete pod %q", podID)
 | 
						|
	}
 | 
						|
	pod, ok := f.podIDMap[podID]
 | 
						|
	if !ok {
 | 
						|
		return fmt.Errorf("pod %q does not exist", podID)
 | 
						|
	}
 | 
						|
	f.podStore.Delete(pod)
 | 
						|
	delete(f.podIDMap, podID)
 | 
						|
	return nil
 | 
						|
}
 | 
						|
 | 
						|
type daemonSetsController struct {
 | 
						|
	*DaemonSetsController
 | 
						|
 | 
						|
	dsStore      cache.Store
 | 
						|
	historyStore cache.Store
 | 
						|
	podStore     cache.Store
 | 
						|
	nodeStore    cache.Store
 | 
						|
	fakeRecorder *record.FakeRecorder
 | 
						|
}
 | 
						|
 | 
						|
func newTestController(initialObjects ...runtime.Object) (*daemonSetsController, *fakePodControl, *fake.Clientset) {
 | 
						|
	clientset := fake.NewSimpleClientset(initialObjects...)
 | 
						|
	informerFactory := informers.NewSharedInformerFactory(clientset, controller.NoResyncPeriodFunc())
 | 
						|
 | 
						|
	dsc := NewDaemonSetsController(
 | 
						|
		informerFactory.Extensions().V1beta1().DaemonSets(),
 | 
						|
		informerFactory.Apps().V1beta1().ControllerRevisions(),
 | 
						|
		informerFactory.Core().V1().Pods(),
 | 
						|
		informerFactory.Core().V1().Nodes(),
 | 
						|
		clientset,
 | 
						|
	)
 | 
						|
 | 
						|
	fakeRecorder := record.NewFakeRecorder(100)
 | 
						|
	dsc.eventRecorder = fakeRecorder
 | 
						|
 | 
						|
	dsc.podStoreSynced = alwaysReady
 | 
						|
	dsc.nodeStoreSynced = alwaysReady
 | 
						|
	dsc.dsStoreSynced = alwaysReady
 | 
						|
	dsc.historyStoreSynced = alwaysReady
 | 
						|
	podControl := newFakePodControl()
 | 
						|
	dsc.podControl = podControl
 | 
						|
	podControl.podStore = informerFactory.Core().V1().Pods().Informer().GetStore()
 | 
						|
 | 
						|
	return &daemonSetsController{
 | 
						|
		dsc,
 | 
						|
		informerFactory.Extensions().V1beta1().DaemonSets().Informer().GetStore(),
 | 
						|
		informerFactory.Apps().V1beta1().ControllerRevisions().Informer().GetStore(),
 | 
						|
		informerFactory.Core().V1().Pods().Informer().GetStore(),
 | 
						|
		informerFactory.Core().V1().Nodes().Informer().GetStore(),
 | 
						|
		fakeRecorder,
 | 
						|
	}, podControl, clientset
 | 
						|
}
 | 
						|
 | 
						|
func validateSyncDaemonSets(t *testing.T, manager *daemonSetsController, fakePodControl *fakePodControl, expectedCreates, expectedDeletes int, expectedEvents int) {
 | 
						|
	if len(fakePodControl.Templates) != expectedCreates {
 | 
						|
		t.Errorf("Unexpected number of creates.  Expected %d, saw %d\n", expectedCreates, len(fakePodControl.Templates))
 | 
						|
	}
 | 
						|
	if len(fakePodControl.DeletePodName) != expectedDeletes {
 | 
						|
		t.Errorf("Unexpected number of deletes.  Expected %d, saw %d\n", expectedDeletes, len(fakePodControl.DeletePodName))
 | 
						|
	}
 | 
						|
	if len(manager.fakeRecorder.Events) != expectedEvents {
 | 
						|
		t.Errorf("Unexpected number of events.  Expected %d, saw %d\n", expectedEvents, len(manager.fakeRecorder.Events))
 | 
						|
	}
 | 
						|
	// Every Pod created should have a ControllerRef.
 | 
						|
	if got, want := len(fakePodControl.ControllerRefs), expectedCreates; got != want {
 | 
						|
		t.Errorf("len(ControllerRefs) = %v, want %v", got, want)
 | 
						|
	}
 | 
						|
	// Make sure the ControllerRefs are correct.
 | 
						|
	for _, controllerRef := range fakePodControl.ControllerRefs {
 | 
						|
		if got, want := controllerRef.APIVersion, "extensions/v1beta1"; got != want {
 | 
						|
			t.Errorf("controllerRef.APIVersion = %q, want %q", got, want)
 | 
						|
		}
 | 
						|
		if got, want := controllerRef.Kind, "DaemonSet"; got != want {
 | 
						|
			t.Errorf("controllerRef.Kind = %q, want %q", got, want)
 | 
						|
		}
 | 
						|
		if controllerRef.Controller == nil || *controllerRef.Controller != true {
 | 
						|
			t.Errorf("controllerRef.Controller is not set to true")
 | 
						|
		}
 | 
						|
	}
 | 
						|
}
 | 
						|
 | 
						|
func syncAndValidateDaemonSets(t *testing.T, manager *daemonSetsController, ds *extensions.DaemonSet, podControl *fakePodControl, expectedCreates, expectedDeletes int, expectedEvents int) {
 | 
						|
	key, err := controller.KeyFunc(ds)
 | 
						|
	if err != nil {
 | 
						|
		t.Errorf("Could not get key for daemon.")
 | 
						|
	}
 | 
						|
	manager.syncHandler(key)
 | 
						|
	validateSyncDaemonSets(t, manager, podControl, expectedCreates, expectedDeletes, expectedEvents)
 | 
						|
}
 | 
						|
 | 
						|
// clearExpectations copies the FakePodControl to PodStore and clears the create and delete expectations.
 | 
						|
func clearExpectations(t *testing.T, manager *daemonSetsController, ds *extensions.DaemonSet, fakePodControl *fakePodControl) {
 | 
						|
	fakePodControl.Clear()
 | 
						|
 | 
						|
	key, err := controller.KeyFunc(ds)
 | 
						|
	if err != nil {
 | 
						|
		t.Errorf("Could not get key for daemon.")
 | 
						|
		return
 | 
						|
	}
 | 
						|
	manager.expectations.DeleteExpectations(key)
 | 
						|
}
 | 
						|
 | 
						|
func TestDeleteFinalStateUnknown(t *testing.T) {
 | 
						|
	for _, strategy := range updateStrategies() {
 | 
						|
		manager, _, _ := newTestController()
 | 
						|
		addNodes(manager.nodeStore, 0, 1, nil)
 | 
						|
		ds := newDaemonSet("foo")
 | 
						|
		ds.Spec.UpdateStrategy = *strategy
 | 
						|
		// DeletedFinalStateUnknown should queue the embedded DS if found.
 | 
						|
		manager.deleteDaemonset(cache.DeletedFinalStateUnknown{Key: "foo", Obj: ds})
 | 
						|
		enqueuedKey, _ := manager.queue.Get()
 | 
						|
		if enqueuedKey.(string) != "default/foo" {
 | 
						|
			t.Errorf("expected delete of DeletedFinalStateUnknown to enqueue the daemonset but found: %#v", enqueuedKey)
 | 
						|
		}
 | 
						|
	}
 | 
						|
}
 | 
						|
 | 
						|
func markPodsReady(store cache.Store) {
 | 
						|
	// mark pods as ready
 | 
						|
	for _, obj := range store.List() {
 | 
						|
		pod := obj.(*v1.Pod)
 | 
						|
		markPodReady(pod)
 | 
						|
	}
 | 
						|
}
 | 
						|
 | 
						|
func markPodReady(pod *v1.Pod) {
 | 
						|
	condition := v1.PodCondition{Type: v1.PodReady, Status: v1.ConditionTrue}
 | 
						|
	podutil.UpdatePodCondition(&pod.Status, &condition)
 | 
						|
}
 | 
						|
 | 
						|
// DaemonSets without node selectors should launch pods on every node.
 | 
						|
func TestSimpleDaemonSetLaunchesPods(t *testing.T) {
 | 
						|
	for _, strategy := range updateStrategies() {
 | 
						|
		ds := newDaemonSet("foo")
 | 
						|
		ds.Spec.UpdateStrategy = *strategy
 | 
						|
		manager, podControl, _ := newTestController(ds)
 | 
						|
		addNodes(manager.nodeStore, 0, 5, nil)
 | 
						|
		manager.dsStore.Add(ds)
 | 
						|
		syncAndValidateDaemonSets(t, manager, ds, podControl, 5, 0, 0)
 | 
						|
	}
 | 
						|
}
 | 
						|
 | 
						|
// Simulate a cluster with 100 nodes, but simulate a limit (like a quota limit)
 | 
						|
// of 10 pods, and verify that the ds doesn't make 100 create calls per sync pass
 | 
						|
func TestSimpleDaemonSetPodCreateErrors(t *testing.T) {
 | 
						|
	for _, strategy := range updateStrategies() {
 | 
						|
		ds := newDaemonSet("foo")
 | 
						|
		ds.Spec.UpdateStrategy = *strategy
 | 
						|
		manager, podControl, _ := newTestController(ds)
 | 
						|
		podControl.FakePodControl.CreateLimit = 10
 | 
						|
		addNodes(manager.nodeStore, 0, podControl.FakePodControl.CreateLimit*10, nil)
 | 
						|
		manager.dsStore.Add(ds)
 | 
						|
		syncAndValidateDaemonSets(t, manager, ds, podControl, podControl.FakePodControl.CreateLimit, 0, 0)
 | 
						|
		expectedLimit := 0
 | 
						|
		for pass := uint8(0); expectedLimit <= podControl.FakePodControl.CreateLimit; pass++ {
 | 
						|
			expectedLimit += controller.SlowStartInitialBatchSize << pass
 | 
						|
		}
 | 
						|
		if podControl.FakePodControl.CreateCallCount > expectedLimit {
 | 
						|
			t.Errorf("Unexpected number of create calls.  Expected <= %d, saw %d\n", podControl.FakePodControl.CreateLimit*2, podControl.FakePodControl.CreateCallCount)
 | 
						|
		}
 | 
						|
 | 
						|
	}
 | 
						|
}
 | 
						|
 | 
						|
func TestSimpleDaemonSetUpdatesStatusAfterLaunchingPods(t *testing.T) {
 | 
						|
	for _, strategy := range updateStrategies() {
 | 
						|
		ds := newDaemonSet("foo")
 | 
						|
		ds.Spec.UpdateStrategy = *strategy
 | 
						|
		manager, podControl, clientset := newTestController(ds)
 | 
						|
 | 
						|
		var updated *extensions.DaemonSet
 | 
						|
		clientset.PrependReactor("update", "daemonsets", func(action core.Action) (handled bool, ret runtime.Object, err error) {
 | 
						|
			if action.GetSubresource() != "status" {
 | 
						|
				return false, nil, nil
 | 
						|
			}
 | 
						|
			if u, ok := action.(core.UpdateAction); ok {
 | 
						|
				updated = u.GetObject().(*extensions.DaemonSet)
 | 
						|
			}
 | 
						|
			return false, nil, nil
 | 
						|
		})
 | 
						|
 | 
						|
		manager.dsStore.Add(ds)
 | 
						|
		addNodes(manager.nodeStore, 0, 5, nil)
 | 
						|
		syncAndValidateDaemonSets(t, manager, ds, podControl, 5, 0, 0)
 | 
						|
 | 
						|
		// Make sure the single sync() updated Status already for the change made
 | 
						|
		// during the manage() phase.
 | 
						|
		if got, want := updated.Status.CurrentNumberScheduled, int32(5); got != want {
 | 
						|
			t.Errorf("Status.CurrentNumberScheduled = %v, want %v", got, want)
 | 
						|
		}
 | 
						|
	}
 | 
						|
}
 | 
						|
 | 
						|
// DaemonSets should do nothing if there aren't any nodes
 | 
						|
func TestNoNodesDoesNothing(t *testing.T) {
 | 
						|
	for _, strategy := range updateStrategies() {
 | 
						|
		manager, podControl, _ := newTestController()
 | 
						|
		ds := newDaemonSet("foo")
 | 
						|
		ds.Spec.UpdateStrategy = *strategy
 | 
						|
		manager.dsStore.Add(ds)
 | 
						|
		syncAndValidateDaemonSets(t, manager, ds, podControl, 0, 0, 0)
 | 
						|
	}
 | 
						|
}
 | 
						|
 | 
						|
// DaemonSets without node selectors should launch on a single node in a
 | 
						|
// single node cluster.
 | 
						|
func TestOneNodeDaemonLaunchesPod(t *testing.T) {
 | 
						|
	for _, strategy := range updateStrategies() {
 | 
						|
		ds := newDaemonSet("foo")
 | 
						|
		ds.Spec.UpdateStrategy = *strategy
 | 
						|
		manager, podControl, _ := newTestController(ds)
 | 
						|
		manager.nodeStore.Add(newNode("only-node", nil))
 | 
						|
		manager.dsStore.Add(ds)
 | 
						|
		syncAndValidateDaemonSets(t, manager, ds, podControl, 1, 0, 0)
 | 
						|
	}
 | 
						|
}
 | 
						|
 | 
						|
// DaemonSets should place onto NotReady nodes
 | 
						|
func TestNotReadNodeDaemonDoesNotLaunchPod(t *testing.T) {
 | 
						|
	for _, strategy := range updateStrategies() {
 | 
						|
		ds := newDaemonSet("foo")
 | 
						|
		ds.Spec.UpdateStrategy = *strategy
 | 
						|
		manager, podControl, _ := newTestController(ds)
 | 
						|
		node := newNode("not-ready", nil)
 | 
						|
		node.Status.Conditions = []v1.NodeCondition{
 | 
						|
			{Type: v1.NodeReady, Status: v1.ConditionFalse},
 | 
						|
		}
 | 
						|
		manager.nodeStore.Add(node)
 | 
						|
		manager.dsStore.Add(ds)
 | 
						|
		syncAndValidateDaemonSets(t, manager, ds, podControl, 1, 0, 0)
 | 
						|
	}
 | 
						|
}
 | 
						|
 | 
						|
func resourcePodSpec(nodeName, memory, cpu string) v1.PodSpec {
 | 
						|
	return v1.PodSpec{
 | 
						|
		NodeName: nodeName,
 | 
						|
		Containers: []v1.Container{{
 | 
						|
			Resources: v1.ResourceRequirements{
 | 
						|
				Requests: allocatableResources(memory, cpu),
 | 
						|
			},
 | 
						|
		}},
 | 
						|
	}
 | 
						|
}
 | 
						|
 | 
						|
func resourcePodSpecWithoutNodeName(memory, cpu string) v1.PodSpec {
 | 
						|
	return v1.PodSpec{
 | 
						|
		Containers: []v1.Container{{
 | 
						|
			Resources: v1.ResourceRequirements{
 | 
						|
				Requests: allocatableResources(memory, cpu),
 | 
						|
			},
 | 
						|
		}},
 | 
						|
	}
 | 
						|
}
 | 
						|
 | 
						|
func allocatableResources(memory, cpu string) v1.ResourceList {
 | 
						|
	return v1.ResourceList{
 | 
						|
		v1.ResourceMemory: resource.MustParse(memory),
 | 
						|
		v1.ResourceCPU:    resource.MustParse(cpu),
 | 
						|
		v1.ResourcePods:   resource.MustParse("100"),
 | 
						|
	}
 | 
						|
}
 | 
						|
 | 
						|
// DaemonSets should not place onto nodes with insufficient free resource
 | 
						|
func TestInsufficientCapacityNodeDaemonDoesNotLaunchPod(t *testing.T) {
 | 
						|
	for _, strategy := range updateStrategies() {
 | 
						|
		podSpec := resourcePodSpec("too-much-mem", "75M", "75m")
 | 
						|
		ds := newDaemonSet("foo")
 | 
						|
		ds.Spec.UpdateStrategy = *strategy
 | 
						|
		ds.Spec.Template.Spec = podSpec
 | 
						|
		manager, podControl, _ := newTestController(ds)
 | 
						|
		node := newNode("too-much-mem", nil)
 | 
						|
		node.Status.Allocatable = allocatableResources("100M", "200m")
 | 
						|
		manager.nodeStore.Add(node)
 | 
						|
		manager.podStore.Add(&v1.Pod{
 | 
						|
			Spec: podSpec,
 | 
						|
		})
 | 
						|
		manager.dsStore.Add(ds)
 | 
						|
		switch strategy.Type {
 | 
						|
		case extensions.OnDeleteDaemonSetStrategyType:
 | 
						|
			syncAndValidateDaemonSets(t, manager, ds, podControl, 0, 0, 2)
 | 
						|
		case extensions.RollingUpdateDaemonSetStrategyType:
 | 
						|
			syncAndValidateDaemonSets(t, manager, ds, podControl, 0, 0, 3)
 | 
						|
		default:
 | 
						|
			t.Fatalf("unexpected UpdateStrategy %+v", strategy)
 | 
						|
		}
 | 
						|
	}
 | 
						|
}
 | 
						|
 | 
						|
// DaemonSets should not unschedule a daemonset pod from a node with insufficient free resource
 | 
						|
func TestInsufficientCapacityNodeDaemonDoesNotUnscheduleRunningPod(t *testing.T) {
 | 
						|
	for _, strategy := range updateStrategies() {
 | 
						|
		podSpec := resourcePodSpec("too-much-mem", "75M", "75m")
 | 
						|
		podSpec.NodeName = "too-much-mem"
 | 
						|
		ds := newDaemonSet("foo")
 | 
						|
		ds.Spec.UpdateStrategy = *strategy
 | 
						|
		ds.Spec.Template.Spec = podSpec
 | 
						|
		manager, podControl, _ := newTestController(ds)
 | 
						|
		node := newNode("too-much-mem", nil)
 | 
						|
		node.Status.Allocatable = allocatableResources("100M", "200m")
 | 
						|
		manager.nodeStore.Add(node)
 | 
						|
		manager.podStore.Add(&v1.Pod{
 | 
						|
			Spec: podSpec,
 | 
						|
		})
 | 
						|
		manager.dsStore.Add(ds)
 | 
						|
		switch strategy.Type {
 | 
						|
		case extensions.OnDeleteDaemonSetStrategyType:
 | 
						|
			syncAndValidateDaemonSets(t, manager, ds, podControl, 0, 0, 2)
 | 
						|
		case extensions.RollingUpdateDaemonSetStrategyType:
 | 
						|
			syncAndValidateDaemonSets(t, manager, ds, podControl, 0, 0, 3)
 | 
						|
		default:
 | 
						|
			t.Fatalf("unexpected UpdateStrategy %+v", strategy)
 | 
						|
		}
 | 
						|
	}
 | 
						|
}
 | 
						|
 | 
						|
// DaemonSets should only place onto nodes with sufficient free resource and matched node selector
 | 
						|
func TestInsufficientCapacityNodeSufficientCapacityWithNodeLabelDaemonLaunchPod(t *testing.T) {
 | 
						|
	podSpec := resourcePodSpecWithoutNodeName("50M", "75m")
 | 
						|
	ds := newDaemonSet("foo")
 | 
						|
	ds.Spec.Template.Spec = podSpec
 | 
						|
	ds.Spec.Template.Spec.NodeSelector = simpleNodeLabel
 | 
						|
	manager, podControl, _ := newTestController(ds)
 | 
						|
	node1 := newNode("not-enough-resource", nil)
 | 
						|
	node1.Status.Allocatable = allocatableResources("10M", "20m")
 | 
						|
	node2 := newNode("enough-resource", simpleNodeLabel)
 | 
						|
	node2.Status.Allocatable = allocatableResources("100M", "200m")
 | 
						|
	manager.nodeStore.Add(node1)
 | 
						|
	manager.nodeStore.Add(node2)
 | 
						|
	manager.dsStore.Add(ds)
 | 
						|
	syncAndValidateDaemonSets(t, manager, ds, podControl, 1, 0, 0)
 | 
						|
	// we do not expect any event for insufficient free resource
 | 
						|
	if len(manager.fakeRecorder.Events) != 0 {
 | 
						|
		t.Fatalf("unexpected events, got %v, expected %v: %+v", len(manager.fakeRecorder.Events), 0, manager.fakeRecorder.Events)
 | 
						|
	}
 | 
						|
}
 | 
						|
 | 
						|
func TestSufficientCapacityWithTerminatedPodsDaemonLaunchesPod(t *testing.T) {
 | 
						|
	for _, strategy := range updateStrategies() {
 | 
						|
		podSpec := resourcePodSpec("too-much-mem", "75M", "75m")
 | 
						|
		ds := newDaemonSet("foo")
 | 
						|
		ds.Spec.UpdateStrategy = *strategy
 | 
						|
		ds.Spec.Template.Spec = podSpec
 | 
						|
		manager, podControl, _ := newTestController(ds)
 | 
						|
		node := newNode("too-much-mem", nil)
 | 
						|
		node.Status.Allocatable = allocatableResources("100M", "200m")
 | 
						|
		manager.nodeStore.Add(node)
 | 
						|
		manager.podStore.Add(&v1.Pod{
 | 
						|
			Spec:   podSpec,
 | 
						|
			Status: v1.PodStatus{Phase: v1.PodSucceeded},
 | 
						|
		})
 | 
						|
		manager.dsStore.Add(ds)
 | 
						|
		syncAndValidateDaemonSets(t, manager, ds, podControl, 1, 0, 1)
 | 
						|
	}
 | 
						|
}
 | 
						|
 | 
						|
// DaemonSets should place onto nodes with sufficient free resource
 | 
						|
func TestSufficientCapacityNodeDaemonLaunchesPod(t *testing.T) {
 | 
						|
	for _, strategy := range updateStrategies() {
 | 
						|
		podSpec := resourcePodSpec("not-too-much-mem", "75M", "75m")
 | 
						|
		ds := newDaemonSet("foo")
 | 
						|
		ds.Spec.UpdateStrategy = *strategy
 | 
						|
		ds.Spec.Template.Spec = podSpec
 | 
						|
		manager, podControl, _ := newTestController(ds)
 | 
						|
		node := newNode("not-too-much-mem", nil)
 | 
						|
		node.Status.Allocatable = allocatableResources("200M", "200m")
 | 
						|
		manager.nodeStore.Add(node)
 | 
						|
		manager.podStore.Add(&v1.Pod{
 | 
						|
			Spec: podSpec,
 | 
						|
		})
 | 
						|
		manager.dsStore.Add(ds)
 | 
						|
		syncAndValidateDaemonSets(t, manager, ds, podControl, 1, 0, 1)
 | 
						|
	}
 | 
						|
}
 | 
						|
 | 
						|
// DaemonSet should launch a pod on a node with taint NetworkUnavailable condition.
 | 
						|
func TestNetworkUnavailableNodeDaemonLaunchesPod(t *testing.T) {
 | 
						|
	for _, strategy := range updateStrategies() {
 | 
						|
		ds := newDaemonSet("simple")
 | 
						|
		ds.Spec.UpdateStrategy = *strategy
 | 
						|
		manager, podControl, _ := newTestController(ds)
 | 
						|
 | 
						|
		node := newNode("network-unavailable", nil)
 | 
						|
		node.Status.Conditions = []v1.NodeCondition{
 | 
						|
			{Type: v1.NodeNetworkUnavailable, Status: v1.ConditionTrue},
 | 
						|
		}
 | 
						|
		manager.nodeStore.Add(node)
 | 
						|
		manager.dsStore.Add(ds)
 | 
						|
 | 
						|
		syncAndValidateDaemonSets(t, manager, ds, podControl, 1, 0, 0)
 | 
						|
	}
 | 
						|
}
 | 
						|
 | 
						|
// DaemonSets not take any actions when being deleted
 | 
						|
func TestDontDoAnythingIfBeingDeleted(t *testing.T) {
 | 
						|
	for _, strategy := range updateStrategies() {
 | 
						|
		podSpec := resourcePodSpec("not-too-much-mem", "75M", "75m")
 | 
						|
		ds := newDaemonSet("foo")
 | 
						|
		ds.Spec.UpdateStrategy = *strategy
 | 
						|
		ds.Spec.Template.Spec = podSpec
 | 
						|
		now := metav1.Now()
 | 
						|
		ds.DeletionTimestamp = &now
 | 
						|
		manager, podControl, _ := newTestController(ds)
 | 
						|
		node := newNode("not-too-much-mem", nil)
 | 
						|
		node.Status.Allocatable = allocatableResources("200M", "200m")
 | 
						|
		manager.nodeStore.Add(node)
 | 
						|
		manager.podStore.Add(&v1.Pod{
 | 
						|
			Spec: podSpec,
 | 
						|
		})
 | 
						|
		manager.dsStore.Add(ds)
 | 
						|
		syncAndValidateDaemonSets(t, manager, ds, podControl, 0, 0, 0)
 | 
						|
	}
 | 
						|
}
 | 
						|
 | 
						|
func TestDontDoAnythingIfBeingDeletedRace(t *testing.T) {
 | 
						|
	for _, strategy := range updateStrategies() {
 | 
						|
		// Bare client says it IS deleted.
 | 
						|
		ds := newDaemonSet("foo")
 | 
						|
		ds.Spec.UpdateStrategy = *strategy
 | 
						|
		now := metav1.Now()
 | 
						|
		ds.DeletionTimestamp = &now
 | 
						|
		manager, podControl, _ := newTestController(ds)
 | 
						|
		addNodes(manager.nodeStore, 0, 5, nil)
 | 
						|
 | 
						|
		// Lister (cache) says it's NOT deleted.
 | 
						|
		ds2 := *ds
 | 
						|
		ds2.DeletionTimestamp = nil
 | 
						|
		manager.dsStore.Add(&ds2)
 | 
						|
 | 
						|
		// The existence of a matching orphan should block all actions in this state.
 | 
						|
		pod := newPod("pod1-", "node-0", simpleDaemonSetLabel, nil)
 | 
						|
		manager.podStore.Add(pod)
 | 
						|
 | 
						|
		syncAndValidateDaemonSets(t, manager, ds, podControl, 0, 0, 0)
 | 
						|
	}
 | 
						|
}
 | 
						|
 | 
						|
// DaemonSets should not place onto nodes that would cause port conflicts
 | 
						|
func TestPortConflictNodeDaemonDoesNotLaunchPod(t *testing.T) {
 | 
						|
	for _, strategy := range updateStrategies() {
 | 
						|
		podSpec := v1.PodSpec{
 | 
						|
			NodeName: "port-conflict",
 | 
						|
			Containers: []v1.Container{{
 | 
						|
				Ports: []v1.ContainerPort{{
 | 
						|
					HostPort: 666,
 | 
						|
				}},
 | 
						|
			}},
 | 
						|
		}
 | 
						|
		manager, podControl, _ := newTestController()
 | 
						|
		node := newNode("port-conflict", nil)
 | 
						|
		manager.nodeStore.Add(node)
 | 
						|
		manager.podStore.Add(&v1.Pod{
 | 
						|
			Spec: podSpec,
 | 
						|
		})
 | 
						|
 | 
						|
		ds := newDaemonSet("foo")
 | 
						|
		ds.Spec.UpdateStrategy = *strategy
 | 
						|
		ds.Spec.Template.Spec = podSpec
 | 
						|
		manager.dsStore.Add(ds)
 | 
						|
		syncAndValidateDaemonSets(t, manager, ds, podControl, 0, 0, 0)
 | 
						|
	}
 | 
						|
}
 | 
						|
 | 
						|
// Test that if the node is already scheduled with a pod using a host port
 | 
						|
// but belonging to the same daemonset, we don't delete that pod
 | 
						|
//
 | 
						|
// Issue: https://github.com/kubernetes/kubernetes/issues/22309
 | 
						|
func TestPortConflictWithSameDaemonPodDoesNotDeletePod(t *testing.T) {
 | 
						|
	for _, strategy := range updateStrategies() {
 | 
						|
		podSpec := v1.PodSpec{
 | 
						|
			NodeName: "port-conflict",
 | 
						|
			Containers: []v1.Container{{
 | 
						|
				Ports: []v1.ContainerPort{{
 | 
						|
					HostPort: 666,
 | 
						|
				}},
 | 
						|
			}},
 | 
						|
		}
 | 
						|
		manager, podControl, _ := newTestController()
 | 
						|
		node := newNode("port-conflict", nil)
 | 
						|
		manager.nodeStore.Add(node)
 | 
						|
		ds := newDaemonSet("foo")
 | 
						|
		ds.Spec.UpdateStrategy = *strategy
 | 
						|
		ds.Spec.Template.Spec = podSpec
 | 
						|
		manager.dsStore.Add(ds)
 | 
						|
		pod := newPod(ds.Name+"-", node.Name, simpleDaemonSetLabel, ds)
 | 
						|
		manager.podStore.Add(pod)
 | 
						|
		syncAndValidateDaemonSets(t, manager, ds, podControl, 0, 0, 0)
 | 
						|
	}
 | 
						|
}
 | 
						|
 | 
						|
// DaemonSets should place onto nodes that would not cause port conflicts
 | 
						|
func TestNoPortConflictNodeDaemonLaunchesPod(t *testing.T) {
 | 
						|
	for _, strategy := range updateStrategies() {
 | 
						|
		podSpec1 := v1.PodSpec{
 | 
						|
			NodeName: "no-port-conflict",
 | 
						|
			Containers: []v1.Container{{
 | 
						|
				Ports: []v1.ContainerPort{{
 | 
						|
					HostPort: 6661,
 | 
						|
				}},
 | 
						|
			}},
 | 
						|
		}
 | 
						|
		podSpec2 := v1.PodSpec{
 | 
						|
			NodeName: "no-port-conflict",
 | 
						|
			Containers: []v1.Container{{
 | 
						|
				Ports: []v1.ContainerPort{{
 | 
						|
					HostPort: 6662,
 | 
						|
				}},
 | 
						|
			}},
 | 
						|
		}
 | 
						|
		ds := newDaemonSet("foo")
 | 
						|
		ds.Spec.UpdateStrategy = *strategy
 | 
						|
		ds.Spec.Template.Spec = podSpec2
 | 
						|
		manager, podControl, _ := newTestController(ds)
 | 
						|
		node := newNode("no-port-conflict", nil)
 | 
						|
		manager.nodeStore.Add(node)
 | 
						|
		manager.podStore.Add(&v1.Pod{
 | 
						|
			Spec: podSpec1,
 | 
						|
		})
 | 
						|
		manager.dsStore.Add(ds)
 | 
						|
		syncAndValidateDaemonSets(t, manager, ds, podControl, 1, 0, 0)
 | 
						|
	}
 | 
						|
}
 | 
						|
 | 
						|
// DaemonSetController should not sync DaemonSets with empty pod selectors.
 | 
						|
//
 | 
						|
// issue https://github.com/kubernetes/kubernetes/pull/23223
 | 
						|
func TestPodIsNotDeletedByDaemonsetWithEmptyLabelSelector(t *testing.T) {
 | 
						|
	// Create a misconfigured DaemonSet. An empty pod selector is invalid but could happen
 | 
						|
	// if we upgrade and make a backwards incompatible change.
 | 
						|
	//
 | 
						|
	// The node selector matches no nodes which mimics the behavior of kubectl delete.
 | 
						|
	//
 | 
						|
	// The DaemonSet should not schedule pods and should not delete scheduled pods in
 | 
						|
	// this case even though it's empty pod selector matches all pods. The DaemonSetController
 | 
						|
	// should detect this misconfiguration and choose not to sync the DaemonSet. We should
 | 
						|
	// not observe a deletion of the pod on node1.
 | 
						|
	for _, strategy := range updateStrategies() {
 | 
						|
		ds := newDaemonSet("foo")
 | 
						|
		ds.Spec.UpdateStrategy = *strategy
 | 
						|
		ls := metav1.LabelSelector{}
 | 
						|
		ds.Spec.Selector = &ls
 | 
						|
		ds.Spec.Template.Spec.NodeSelector = map[string]string{"foo": "bar"}
 | 
						|
 | 
						|
		manager, podControl, _ := newTestController(ds)
 | 
						|
		manager.nodeStore.Add(newNode("node1", nil))
 | 
						|
		// Create pod not controlled by a daemonset.
 | 
						|
		manager.podStore.Add(&v1.Pod{
 | 
						|
			ObjectMeta: metav1.ObjectMeta{
 | 
						|
				Labels:    map[string]string{"bang": "boom"},
 | 
						|
				Namespace: metav1.NamespaceDefault,
 | 
						|
			},
 | 
						|
			Spec: v1.PodSpec{
 | 
						|
				NodeName: "node1",
 | 
						|
			},
 | 
						|
		})
 | 
						|
		manager.dsStore.Add(ds)
 | 
						|
 | 
						|
		syncAndValidateDaemonSets(t, manager, ds, podControl, 0, 0, 1)
 | 
						|
	}
 | 
						|
}
 | 
						|
 | 
						|
// Controller should not create pods on nodes which have daemon pods, and should remove excess pods from nodes that have extra pods.
 | 
						|
func TestDealsWithExistingPods(t *testing.T) {
 | 
						|
	for _, strategy := range updateStrategies() {
 | 
						|
		ds := newDaemonSet("foo")
 | 
						|
		ds.Spec.UpdateStrategy = *strategy
 | 
						|
		manager, podControl, _ := newTestController(ds)
 | 
						|
		manager.dsStore.Add(ds)
 | 
						|
		addNodes(manager.nodeStore, 0, 5, nil)
 | 
						|
		addPods(manager.podStore, "node-1", simpleDaemonSetLabel, ds, 1)
 | 
						|
		addPods(manager.podStore, "node-2", simpleDaemonSetLabel, ds, 2)
 | 
						|
		addPods(manager.podStore, "node-3", simpleDaemonSetLabel, ds, 5)
 | 
						|
		addPods(manager.podStore, "node-4", simpleDaemonSetLabel2, ds, 2)
 | 
						|
		syncAndValidateDaemonSets(t, manager, ds, podControl, 2, 5, 0)
 | 
						|
	}
 | 
						|
}
 | 
						|
 | 
						|
// Daemon with node selector should launch pods on nodes matching selector.
 | 
						|
func TestSelectorDaemonLaunchesPods(t *testing.T) {
 | 
						|
	for _, strategy := range updateStrategies() {
 | 
						|
		daemon := newDaemonSet("foo")
 | 
						|
		daemon.Spec.UpdateStrategy = *strategy
 | 
						|
		daemon.Spec.Template.Spec.NodeSelector = simpleNodeLabel
 | 
						|
		manager, podControl, _ := newTestController(daemon)
 | 
						|
		addNodes(manager.nodeStore, 0, 4, nil)
 | 
						|
		addNodes(manager.nodeStore, 4, 3, simpleNodeLabel)
 | 
						|
		manager.dsStore.Add(daemon)
 | 
						|
		syncAndValidateDaemonSets(t, manager, daemon, podControl, 3, 0, 0)
 | 
						|
	}
 | 
						|
}
 | 
						|
 | 
						|
// Daemon with node selector should delete pods from nodes that do not satisfy selector.
 | 
						|
func TestSelectorDaemonDeletesUnselectedPods(t *testing.T) {
 | 
						|
	for _, strategy := range updateStrategies() {
 | 
						|
		ds := newDaemonSet("foo")
 | 
						|
		ds.Spec.UpdateStrategy = *strategy
 | 
						|
		ds.Spec.Template.Spec.NodeSelector = simpleNodeLabel
 | 
						|
		manager, podControl, _ := newTestController(ds)
 | 
						|
		manager.dsStore.Add(ds)
 | 
						|
		addNodes(manager.nodeStore, 0, 5, nil)
 | 
						|
		addNodes(manager.nodeStore, 5, 5, simpleNodeLabel)
 | 
						|
		addPods(manager.podStore, "node-0", simpleDaemonSetLabel2, ds, 2)
 | 
						|
		addPods(manager.podStore, "node-1", simpleDaemonSetLabel, ds, 3)
 | 
						|
		addPods(manager.podStore, "node-1", simpleDaemonSetLabel2, ds, 1)
 | 
						|
		addPods(manager.podStore, "node-4", simpleDaemonSetLabel, ds, 1)
 | 
						|
		syncAndValidateDaemonSets(t, manager, ds, podControl, 5, 4, 0)
 | 
						|
	}
 | 
						|
}
 | 
						|
 | 
						|
// DaemonSet with node selector should launch pods on nodes matching selector, but also deal with existing pods on nodes.
 | 
						|
func TestSelectorDaemonDealsWithExistingPods(t *testing.T) {
 | 
						|
	for _, strategy := range updateStrategies() {
 | 
						|
		ds := newDaemonSet("foo")
 | 
						|
		ds.Spec.UpdateStrategy = *strategy
 | 
						|
		ds.Spec.Template.Spec.NodeSelector = simpleNodeLabel
 | 
						|
		manager, podControl, _ := newTestController(ds)
 | 
						|
		manager.dsStore.Add(ds)
 | 
						|
		addNodes(manager.nodeStore, 0, 5, nil)
 | 
						|
		addNodes(manager.nodeStore, 5, 5, simpleNodeLabel)
 | 
						|
		addPods(manager.podStore, "node-0", simpleDaemonSetLabel, ds, 1)
 | 
						|
		addPods(manager.podStore, "node-1", simpleDaemonSetLabel, ds, 3)
 | 
						|
		addPods(manager.podStore, "node-1", simpleDaemonSetLabel2, ds, 2)
 | 
						|
		addPods(manager.podStore, "node-2", simpleDaemonSetLabel, ds, 4)
 | 
						|
		addPods(manager.podStore, "node-6", simpleDaemonSetLabel, ds, 13)
 | 
						|
		addPods(manager.podStore, "node-7", simpleDaemonSetLabel2, ds, 4)
 | 
						|
		addPods(manager.podStore, "node-9", simpleDaemonSetLabel, ds, 1)
 | 
						|
		addPods(manager.podStore, "node-9", simpleDaemonSetLabel2, ds, 1)
 | 
						|
		syncAndValidateDaemonSets(t, manager, ds, podControl, 3, 20, 0)
 | 
						|
	}
 | 
						|
}
 | 
						|
 | 
						|
// DaemonSet with node selector which does not match any node labels should not launch pods.
 | 
						|
func TestBadSelectorDaemonDoesNothing(t *testing.T) {
 | 
						|
	for _, strategy := range updateStrategies() {
 | 
						|
		manager, podControl, _ := newTestController()
 | 
						|
		addNodes(manager.nodeStore, 0, 4, nil)
 | 
						|
		addNodes(manager.nodeStore, 4, 3, simpleNodeLabel)
 | 
						|
		ds := newDaemonSet("foo")
 | 
						|
		ds.Spec.UpdateStrategy = *strategy
 | 
						|
		ds.Spec.Template.Spec.NodeSelector = simpleNodeLabel2
 | 
						|
		manager.dsStore.Add(ds)
 | 
						|
		syncAndValidateDaemonSets(t, manager, ds, podControl, 0, 0, 0)
 | 
						|
	}
 | 
						|
}
 | 
						|
 | 
						|
// DaemonSet with node name should launch pod on node with corresponding name.
 | 
						|
func TestNameDaemonSetLaunchesPods(t *testing.T) {
 | 
						|
	for _, strategy := range updateStrategies() {
 | 
						|
		ds := newDaemonSet("foo")
 | 
						|
		ds.Spec.UpdateStrategy = *strategy
 | 
						|
		ds.Spec.Template.Spec.NodeName = "node-0"
 | 
						|
		manager, podControl, _ := newTestController(ds)
 | 
						|
		addNodes(manager.nodeStore, 0, 5, nil)
 | 
						|
		manager.dsStore.Add(ds)
 | 
						|
		syncAndValidateDaemonSets(t, manager, ds, podControl, 1, 0, 0)
 | 
						|
	}
 | 
						|
}
 | 
						|
 | 
						|
// DaemonSet with node name that does not exist should not launch pods.
 | 
						|
func TestBadNameDaemonSetDoesNothing(t *testing.T) {
 | 
						|
	for _, strategy := range updateStrategies() {
 | 
						|
		ds := newDaemonSet("foo")
 | 
						|
		ds.Spec.UpdateStrategy = *strategy
 | 
						|
		ds.Spec.Template.Spec.NodeName = "node-10"
 | 
						|
		manager, podControl, _ := newTestController(ds)
 | 
						|
		addNodes(manager.nodeStore, 0, 5, nil)
 | 
						|
		manager.dsStore.Add(ds)
 | 
						|
		syncAndValidateDaemonSets(t, manager, ds, podControl, 0, 0, 0)
 | 
						|
	}
 | 
						|
}
 | 
						|
 | 
						|
// DaemonSet with node selector, and node name, matching a node, should launch a pod on the node.
 | 
						|
func TestNameAndSelectorDaemonSetLaunchesPods(t *testing.T) {
 | 
						|
	for _, strategy := range updateStrategies() {
 | 
						|
		ds := newDaemonSet("foo")
 | 
						|
		ds.Spec.UpdateStrategy = *strategy
 | 
						|
		ds.Spec.Template.Spec.NodeSelector = simpleNodeLabel
 | 
						|
		ds.Spec.Template.Spec.NodeName = "node-6"
 | 
						|
		manager, podControl, _ := newTestController(ds)
 | 
						|
		addNodes(manager.nodeStore, 0, 4, nil)
 | 
						|
		addNodes(manager.nodeStore, 4, 3, simpleNodeLabel)
 | 
						|
		manager.dsStore.Add(ds)
 | 
						|
		syncAndValidateDaemonSets(t, manager, ds, podControl, 1, 0, 0)
 | 
						|
	}
 | 
						|
}
 | 
						|
 | 
						|
// DaemonSet with node selector that matches some nodes, and node name that matches a different node, should do nothing.
 | 
						|
func TestInconsistentNameSelectorDaemonSetDoesNothing(t *testing.T) {
 | 
						|
	for _, strategy := range updateStrategies() {
 | 
						|
		ds := newDaemonSet("foo")
 | 
						|
		ds.Spec.UpdateStrategy = *strategy
 | 
						|
		ds.Spec.Template.Spec.NodeSelector = simpleNodeLabel
 | 
						|
		ds.Spec.Template.Spec.NodeName = "node-0"
 | 
						|
		manager, podControl, _ := newTestController(ds)
 | 
						|
		addNodes(manager.nodeStore, 0, 4, nil)
 | 
						|
		addNodes(manager.nodeStore, 4, 3, simpleNodeLabel)
 | 
						|
		manager.dsStore.Add(ds)
 | 
						|
		syncAndValidateDaemonSets(t, manager, ds, podControl, 0, 0, 0)
 | 
						|
	}
 | 
						|
}
 | 
						|
 | 
						|
// DaemonSet with node selector, matching some nodes, should launch pods on all the nodes.
 | 
						|
func TestSelectorDaemonSetLaunchesPods(t *testing.T) {
 | 
						|
	ds := newDaemonSet("foo")
 | 
						|
	ds.Spec.Template.Spec.NodeSelector = simpleNodeLabel
 | 
						|
	manager, podControl, _ := newTestController(ds)
 | 
						|
	addNodes(manager.nodeStore, 0, 4, nil)
 | 
						|
	addNodes(manager.nodeStore, 4, 3, simpleNodeLabel)
 | 
						|
	manager.dsStore.Add(ds)
 | 
						|
	syncAndValidateDaemonSets(t, manager, ds, podControl, 3, 0, 0)
 | 
						|
}
 | 
						|
 | 
						|
// Daemon with node affinity should launch pods on nodes matching affinity.
 | 
						|
func TestNodeAffinityDaemonLaunchesPods(t *testing.T) {
 | 
						|
	for _, strategy := range updateStrategies() {
 | 
						|
		daemon := newDaemonSet("foo")
 | 
						|
		daemon.Spec.UpdateStrategy = *strategy
 | 
						|
		daemon.Spec.Template.Spec.Affinity = &v1.Affinity{
 | 
						|
			NodeAffinity: &v1.NodeAffinity{
 | 
						|
				RequiredDuringSchedulingIgnoredDuringExecution: &v1.NodeSelector{
 | 
						|
					NodeSelectorTerms: []v1.NodeSelectorTerm{
 | 
						|
						{
 | 
						|
							MatchExpressions: []v1.NodeSelectorRequirement{
 | 
						|
								{
 | 
						|
									Key:      "color",
 | 
						|
									Operator: v1.NodeSelectorOpIn,
 | 
						|
									Values:   []string{simpleNodeLabel["color"]},
 | 
						|
								},
 | 
						|
							},
 | 
						|
						},
 | 
						|
					},
 | 
						|
				},
 | 
						|
			},
 | 
						|
		}
 | 
						|
 | 
						|
		manager, podControl, _ := newTestController(daemon)
 | 
						|
		addNodes(manager.nodeStore, 0, 4, nil)
 | 
						|
		addNodes(manager.nodeStore, 4, 3, simpleNodeLabel)
 | 
						|
		manager.dsStore.Add(daemon)
 | 
						|
		syncAndValidateDaemonSets(t, manager, daemon, podControl, 3, 0, 0)
 | 
						|
	}
 | 
						|
}
 | 
						|
 | 
						|
func TestNumberReadyStatus(t *testing.T) {
 | 
						|
	for _, strategy := range updateStrategies() {
 | 
						|
		ds := newDaemonSet("foo")
 | 
						|
		ds.Spec.UpdateStrategy = *strategy
 | 
						|
		manager, podControl, clientset := newTestController(ds)
 | 
						|
		var updated *extensions.DaemonSet
 | 
						|
		clientset.PrependReactor("update", "daemonsets", func(action core.Action) (handled bool, ret runtime.Object, err error) {
 | 
						|
			if action.GetSubresource() != "status" {
 | 
						|
				return false, nil, nil
 | 
						|
			}
 | 
						|
			if u, ok := action.(core.UpdateAction); ok {
 | 
						|
				updated = u.GetObject().(*extensions.DaemonSet)
 | 
						|
			}
 | 
						|
			return false, nil, nil
 | 
						|
		})
 | 
						|
		addNodes(manager.nodeStore, 0, 2, simpleNodeLabel)
 | 
						|
		addPods(manager.podStore, "node-0", simpleDaemonSetLabel, ds, 1)
 | 
						|
		addPods(manager.podStore, "node-1", simpleDaemonSetLabel, ds, 1)
 | 
						|
		manager.dsStore.Add(ds)
 | 
						|
 | 
						|
		syncAndValidateDaemonSets(t, manager, ds, podControl, 0, 0, 0)
 | 
						|
		if updated.Status.NumberReady != 0 {
 | 
						|
			t.Errorf("Wrong daemon %s status: %v", updated.Name, updated.Status)
 | 
						|
		}
 | 
						|
 | 
						|
		selector, _ := metav1.LabelSelectorAsSelector(ds.Spec.Selector)
 | 
						|
		daemonPods, _ := manager.podLister.Pods(ds.Namespace).List(selector)
 | 
						|
		for _, pod := range daemonPods {
 | 
						|
			condition := v1.PodCondition{Type: v1.PodReady, Status: v1.ConditionTrue}
 | 
						|
			pod.Status.Conditions = append(pod.Status.Conditions, condition)
 | 
						|
		}
 | 
						|
 | 
						|
		syncAndValidateDaemonSets(t, manager, ds, podControl, 0, 0, 0)
 | 
						|
		if updated.Status.NumberReady != 2 {
 | 
						|
			t.Errorf("Wrong daemon %s status: %v", updated.Name, updated.Status)
 | 
						|
		}
 | 
						|
	}
 | 
						|
}
 | 
						|
 | 
						|
func TestObservedGeneration(t *testing.T) {
 | 
						|
	for _, strategy := range updateStrategies() {
 | 
						|
		ds := newDaemonSet("foo")
 | 
						|
		ds.Spec.UpdateStrategy = *strategy
 | 
						|
		ds.Generation = 1
 | 
						|
		manager, podControl, clientset := newTestController(ds)
 | 
						|
		var updated *extensions.DaemonSet
 | 
						|
		clientset.PrependReactor("update", "daemonsets", func(action core.Action) (handled bool, ret runtime.Object, err error) {
 | 
						|
			if action.GetSubresource() != "status" {
 | 
						|
				return false, nil, nil
 | 
						|
			}
 | 
						|
			if u, ok := action.(core.UpdateAction); ok {
 | 
						|
				updated = u.GetObject().(*extensions.DaemonSet)
 | 
						|
			}
 | 
						|
			return false, nil, nil
 | 
						|
		})
 | 
						|
 | 
						|
		addNodes(manager.nodeStore, 0, 1, simpleNodeLabel)
 | 
						|
		addPods(manager.podStore, "node-0", simpleDaemonSetLabel, ds, 1)
 | 
						|
		manager.dsStore.Add(ds)
 | 
						|
 | 
						|
		syncAndValidateDaemonSets(t, manager, ds, podControl, 0, 0, 0)
 | 
						|
		if updated.Status.ObservedGeneration != ds.Generation {
 | 
						|
			t.Errorf("Wrong ObservedGeneration for daemon %s in status. Expected %d, got %d", updated.Name, ds.Generation, updated.Status.ObservedGeneration)
 | 
						|
		}
 | 
						|
	}
 | 
						|
}
 | 
						|
 | 
						|
// DaemonSet controller should kill all failed pods and create at most 1 pod on every node.
 | 
						|
func TestDaemonKillFailedPods(t *testing.T) {
 | 
						|
	tests := []struct {
 | 
						|
		numFailedPods, numNormalPods, expectedCreates, expectedDeletes, expectedEvents int
 | 
						|
		test                                                                           string
 | 
						|
	}{
 | 
						|
		{numFailedPods: 0, numNormalPods: 1, expectedCreates: 0, expectedDeletes: 0, expectedEvents: 0, test: "normal (do nothing)"},
 | 
						|
		{numFailedPods: 0, numNormalPods: 0, expectedCreates: 1, expectedDeletes: 0, expectedEvents: 0, test: "no pods (create 1)"},
 | 
						|
		{numFailedPods: 1, numNormalPods: 0, expectedCreates: 0, expectedDeletes: 1, expectedEvents: 1, test: "1 failed pod (kill 1), 0 normal pod (create 0; will create in the next sync)"},
 | 
						|
		{numFailedPods: 1, numNormalPods: 3, expectedCreates: 0, expectedDeletes: 3, expectedEvents: 1, test: "1 failed pod (kill 1), 3 normal pods (kill 2)"},
 | 
						|
		{numFailedPods: 2, numNormalPods: 1, expectedCreates: 0, expectedDeletes: 2, expectedEvents: 2, test: "2 failed pods (kill 2), 1 normal pod"},
 | 
						|
	}
 | 
						|
 | 
						|
	for _, test := range tests {
 | 
						|
		t.Logf("test case: %s\n", test.test)
 | 
						|
		for _, strategy := range updateStrategies() {
 | 
						|
			ds := newDaemonSet("foo")
 | 
						|
			ds.Spec.UpdateStrategy = *strategy
 | 
						|
			manager, podControl, _ := newTestController(ds)
 | 
						|
			manager.dsStore.Add(ds)
 | 
						|
			addNodes(manager.nodeStore, 0, 1, nil)
 | 
						|
			addFailedPods(manager.podStore, "node-0", simpleDaemonSetLabel, ds, test.numFailedPods)
 | 
						|
			addPods(manager.podStore, "node-0", simpleDaemonSetLabel, ds, test.numNormalPods)
 | 
						|
			syncAndValidateDaemonSets(t, manager, ds, podControl, test.expectedCreates, test.expectedDeletes, test.expectedEvents)
 | 
						|
		}
 | 
						|
	}
 | 
						|
}
 | 
						|
 | 
						|
// Daemonset should not remove a running pod from a node if the pod doesn't
 | 
						|
// tolerate the nodes NoSchedule taint
 | 
						|
func TestNoScheduleTaintedDoesntEvicitRunningIntolerantPod(t *testing.T) {
 | 
						|
	for _, strategy := range updateStrategies() {
 | 
						|
		ds := newDaemonSet("intolerant")
 | 
						|
		ds.Spec.UpdateStrategy = *strategy
 | 
						|
		manager, podControl, _ := newTestController(ds)
 | 
						|
 | 
						|
		node := newNode("tainted", nil)
 | 
						|
		manager.nodeStore.Add(node)
 | 
						|
		setNodeTaint(node, noScheduleTaints)
 | 
						|
		manager.podStore.Add(newPod("keep-running-me", "tainted", simpleDaemonSetLabel, ds))
 | 
						|
		manager.dsStore.Add(ds)
 | 
						|
 | 
						|
		syncAndValidateDaemonSets(t, manager, ds, podControl, 0, 0, 0)
 | 
						|
	}
 | 
						|
}
 | 
						|
 | 
						|
// Daemonset should remove a running pod from a node if the pod doesn't
 | 
						|
// tolerate the nodes NoExecute taint
 | 
						|
func TestNoExecuteTaintedDoesEvicitRunningIntolerantPod(t *testing.T) {
 | 
						|
	for _, strategy := range updateStrategies() {
 | 
						|
		ds := newDaemonSet("intolerant")
 | 
						|
		ds.Spec.UpdateStrategy = *strategy
 | 
						|
		manager, podControl, _ := newTestController(ds)
 | 
						|
 | 
						|
		node := newNode("tainted", nil)
 | 
						|
		manager.nodeStore.Add(node)
 | 
						|
		setNodeTaint(node, noExecuteTaints)
 | 
						|
		manager.podStore.Add(newPod("stop-running-me", "tainted", simpleDaemonSetLabel, ds))
 | 
						|
		manager.dsStore.Add(ds)
 | 
						|
 | 
						|
		syncAndValidateDaemonSets(t, manager, ds, podControl, 0, 1, 0)
 | 
						|
	}
 | 
						|
}
 | 
						|
 | 
						|
// DaemonSet should not launch a pod on a tainted node when the pod doesn't tolerate that taint.
 | 
						|
func TestTaintedNodeDaemonDoesNotLaunchIntolerantPod(t *testing.T) {
 | 
						|
	for _, strategy := range updateStrategies() {
 | 
						|
		ds := newDaemonSet("intolerant")
 | 
						|
		ds.Spec.UpdateStrategy = *strategy
 | 
						|
		manager, podControl, _ := newTestController(ds)
 | 
						|
 | 
						|
		node := newNode("tainted", nil)
 | 
						|
		setNodeTaint(node, noScheduleTaints)
 | 
						|
		manager.nodeStore.Add(node)
 | 
						|
		manager.dsStore.Add(ds)
 | 
						|
 | 
						|
		syncAndValidateDaemonSets(t, manager, ds, podControl, 0, 0, 0)
 | 
						|
	}
 | 
						|
}
 | 
						|
 | 
						|
// DaemonSet should launch a pod on a tainted node when the pod can tolerate that taint.
 | 
						|
func TestTaintedNodeDaemonLaunchesToleratePod(t *testing.T) {
 | 
						|
	for _, strategy := range updateStrategies() {
 | 
						|
		ds := newDaemonSet("tolerate")
 | 
						|
		ds.Spec.UpdateStrategy = *strategy
 | 
						|
		setDaemonSetToleration(ds, noScheduleTolerations)
 | 
						|
		manager, podControl, _ := newTestController(ds)
 | 
						|
 | 
						|
		node := newNode("tainted", nil)
 | 
						|
		setNodeTaint(node, noScheduleTaints)
 | 
						|
		manager.nodeStore.Add(node)
 | 
						|
		manager.dsStore.Add(ds)
 | 
						|
 | 
						|
		syncAndValidateDaemonSets(t, manager, ds, podControl, 1, 0, 0)
 | 
						|
	}
 | 
						|
}
 | 
						|
 | 
						|
// DaemonSet should launch a pod on a not ready node with taint notReady:NoExecute.
 | 
						|
func TestNotReadyNodeDaemonLaunchesPod(t *testing.T) {
 | 
						|
	for _, strategy := range updateStrategies() {
 | 
						|
		ds := newDaemonSet("simple")
 | 
						|
		ds.Spec.UpdateStrategy = *strategy
 | 
						|
		manager, podControl, _ := newTestController(ds)
 | 
						|
 | 
						|
		node := newNode("tainted", nil)
 | 
						|
		setNodeTaint(node, nodeNotReady)
 | 
						|
		node.Status.Conditions = []v1.NodeCondition{
 | 
						|
			{Type: v1.NodeReady, Status: v1.ConditionFalse},
 | 
						|
		}
 | 
						|
		manager.nodeStore.Add(node)
 | 
						|
		manager.dsStore.Add(ds)
 | 
						|
 | 
						|
		syncAndValidateDaemonSets(t, manager, ds, podControl, 1, 0, 0)
 | 
						|
	}
 | 
						|
}
 | 
						|
 | 
						|
// DaemonSet should launch a pod on an unreachable node with taint unreachable:NoExecute.
 | 
						|
func TestUnreachableNodeDaemonLaunchesPod(t *testing.T) {
 | 
						|
	for _, strategy := range updateStrategies() {
 | 
						|
		ds := newDaemonSet("simple")
 | 
						|
		ds.Spec.UpdateStrategy = *strategy
 | 
						|
		manager, podControl, _ := newTestController(ds)
 | 
						|
 | 
						|
		node := newNode("tainted", nil)
 | 
						|
		setNodeTaint(node, nodeUnreachable)
 | 
						|
		node.Status.Conditions = []v1.NodeCondition{
 | 
						|
			{Type: v1.NodeReady, Status: v1.ConditionUnknown},
 | 
						|
		}
 | 
						|
		manager.nodeStore.Add(node)
 | 
						|
		manager.dsStore.Add(ds)
 | 
						|
 | 
						|
		syncAndValidateDaemonSets(t, manager, ds, podControl, 1, 0, 0)
 | 
						|
	}
 | 
						|
}
 | 
						|
 | 
						|
// DaemonSet should launch a pod on an untainted node when the pod has tolerations.
 | 
						|
func TestNodeDaemonLaunchesToleratePod(t *testing.T) {
 | 
						|
	for _, strategy := range updateStrategies() {
 | 
						|
		ds := newDaemonSet("tolerate")
 | 
						|
		ds.Spec.UpdateStrategy = *strategy
 | 
						|
		setDaemonSetToleration(ds, noScheduleTolerations)
 | 
						|
		manager, podControl, _ := newTestController(ds)
 | 
						|
		addNodes(manager.nodeStore, 0, 1, nil)
 | 
						|
		manager.dsStore.Add(ds)
 | 
						|
 | 
						|
		syncAndValidateDaemonSets(t, manager, ds, podControl, 1, 0, 0)
 | 
						|
	}
 | 
						|
}
 | 
						|
 | 
						|
// DaemonSet should launch a pod on a not ready node with taint notReady:NoExecute.
 | 
						|
func TestDaemonSetRespectsTermination(t *testing.T) {
 | 
						|
	for _, strategy := range updateStrategies() {
 | 
						|
		ds := newDaemonSet("foo")
 | 
						|
		ds.Spec.UpdateStrategy = *strategy
 | 
						|
		manager, podControl, _ := newTestController(ds)
 | 
						|
 | 
						|
		addNodes(manager.nodeStore, 0, 1, simpleNodeLabel)
 | 
						|
		pod := newPod(fmt.Sprintf("%s-", "node-0"), "node-0", simpleDaemonSetLabel, ds)
 | 
						|
		dt := metav1.Now()
 | 
						|
		pod.DeletionTimestamp = &dt
 | 
						|
		manager.podStore.Add(pod)
 | 
						|
		manager.dsStore.Add(ds)
 | 
						|
		syncAndValidateDaemonSets(t, manager, ds, podControl, 0, 0, 0)
 | 
						|
	}
 | 
						|
}
 | 
						|
 | 
						|
func setNodeTaint(node *v1.Node, taints []v1.Taint) {
 | 
						|
	node.Spec.Taints = taints
 | 
						|
}
 | 
						|
 | 
						|
func setDaemonSetToleration(ds *extensions.DaemonSet, tolerations []v1.Toleration) {
 | 
						|
	ds.Spec.Template.Spec.Tolerations = tolerations
 | 
						|
}
 | 
						|
 | 
						|
// DaemonSet should launch a critical pod even when the node with OutOfDisk taints.
 | 
						|
// TODO(#48843) OutOfDisk taints will be removed in 1.10
 | 
						|
func TestTaintOutOfDiskNodeDaemonLaunchesCriticalPod(t *testing.T) {
 | 
						|
	for _, strategy := range updateStrategies() {
 | 
						|
		ds := newDaemonSet("critical")
 | 
						|
		ds.Spec.UpdateStrategy = *strategy
 | 
						|
		setDaemonSetCritical(ds)
 | 
						|
		manager, podControl, _ := newTestController(ds)
 | 
						|
 | 
						|
		node := newNode("not-enough-disk", nil)
 | 
						|
		node.Status.Conditions = []v1.NodeCondition{{Type: v1.NodeOutOfDisk, Status: v1.ConditionTrue}}
 | 
						|
		node.Spec.Taints = []v1.Taint{{Key: algorithm.TaintNodeOutOfDisk, Effect: v1.TaintEffectNoSchedule}}
 | 
						|
		manager.nodeStore.Add(node)
 | 
						|
 | 
						|
		// NOTE: Whether or not TaintNodesByCondition is enabled, it'll add toleration to DaemonSet pods.
 | 
						|
 | 
						|
		// Without enabling critical pod annotation feature gate, we shouldn't create critical pod
 | 
						|
		utilfeature.DefaultFeatureGate.Set("ExperimentalCriticalPodAnnotation=False")
 | 
						|
		utilfeature.DefaultFeatureGate.Set("TaintNodesByCondition=True")
 | 
						|
		manager.dsStore.Add(ds)
 | 
						|
		syncAndValidateDaemonSets(t, manager, ds, podControl, 0, 0, 0)
 | 
						|
 | 
						|
		// With enabling critical pod annotation feature gate, we will create critical pod
 | 
						|
		utilfeature.DefaultFeatureGate.Set("ExperimentalCriticalPodAnnotation=True")
 | 
						|
		utilfeature.DefaultFeatureGate.Set("TaintNodesByCondition=False")
 | 
						|
		manager.dsStore.Add(ds)
 | 
						|
		syncAndValidateDaemonSets(t, manager, ds, podControl, 1, 0, 0)
 | 
						|
 | 
						|
		// Rollback feature gate to false.
 | 
						|
		utilfeature.DefaultFeatureGate.Set("TaintNodesByCondition=False")
 | 
						|
		utilfeature.DefaultFeatureGate.Set("ExperimentalCriticalPodAnnotation=False")
 | 
						|
	}
 | 
						|
}
 | 
						|
 | 
						|
// DaemonSet should launch a pod even when the node with MemoryPressure/DiskPressure taints.
 | 
						|
func TestTaintPressureNodeDaemonLaunchesPod(t *testing.T) {
 | 
						|
	for _, strategy := range updateStrategies() {
 | 
						|
		ds := newDaemonSet("critical")
 | 
						|
		ds.Spec.UpdateStrategy = *strategy
 | 
						|
		setDaemonSetCritical(ds)
 | 
						|
		manager, podControl, _ := newTestController(ds)
 | 
						|
 | 
						|
		node := newNode("resources-pressure", nil)
 | 
						|
		node.Status.Conditions = []v1.NodeCondition{
 | 
						|
			{Type: v1.NodeDiskPressure, Status: v1.ConditionTrue},
 | 
						|
			{Type: v1.NodeMemoryPressure, Status: v1.ConditionTrue},
 | 
						|
		}
 | 
						|
		node.Spec.Taints = []v1.Taint{
 | 
						|
			{Key: algorithm.TaintNodeDiskPressure, Effect: v1.TaintEffectNoSchedule},
 | 
						|
			{Key: algorithm.TaintNodeMemoryPressure, Effect: v1.TaintEffectNoSchedule},
 | 
						|
		}
 | 
						|
		manager.nodeStore.Add(node)
 | 
						|
 | 
						|
		// Enabling critical pod and taint nodes by condition feature gate should create critical pod
 | 
						|
		utilfeature.DefaultFeatureGate.Set("TaintNodesByCondition=True")
 | 
						|
		manager.dsStore.Add(ds)
 | 
						|
		syncAndValidateDaemonSets(t, manager, ds, podControl, 1, 0, 0)
 | 
						|
 | 
						|
		// Rollback feature gate to false.
 | 
						|
		utilfeature.DefaultFeatureGate.Set("TaintNodesByCondition=False")
 | 
						|
	}
 | 
						|
}
 | 
						|
 | 
						|
// DaemonSet should launch a critical pod even when the node has insufficient free resource.
 | 
						|
func TestInsufficientCapacityNodeDaemonLaunchesCriticalPod(t *testing.T) {
 | 
						|
	for _, strategy := range updateStrategies() {
 | 
						|
		podSpec := resourcePodSpec("too-much-mem", "75M", "75m")
 | 
						|
		ds := newDaemonSet("critical")
 | 
						|
		ds.Spec.UpdateStrategy = *strategy
 | 
						|
		ds.Spec.Template.Spec = podSpec
 | 
						|
		setDaemonSetCritical(ds)
 | 
						|
 | 
						|
		manager, podControl, _ := newTestController(ds)
 | 
						|
		node := newNode("too-much-mem", nil)
 | 
						|
		node.Status.Allocatable = allocatableResources("100M", "200m")
 | 
						|
		manager.nodeStore.Add(node)
 | 
						|
		manager.podStore.Add(&v1.Pod{
 | 
						|
			Spec: podSpec,
 | 
						|
		})
 | 
						|
 | 
						|
		// Without enabling critical pod annotation feature gate, we shouldn't create critical pod
 | 
						|
		utilfeature.DefaultFeatureGate.Set("ExperimentalCriticalPodAnnotation=False")
 | 
						|
		manager.dsStore.Add(ds)
 | 
						|
		switch strategy.Type {
 | 
						|
		case extensions.OnDeleteDaemonSetStrategyType:
 | 
						|
			syncAndValidateDaemonSets(t, manager, ds, podControl, 0, 0, 2)
 | 
						|
		case extensions.RollingUpdateDaemonSetStrategyType:
 | 
						|
			syncAndValidateDaemonSets(t, manager, ds, podControl, 0, 0, 3)
 | 
						|
		default:
 | 
						|
			t.Fatalf("unexpected UpdateStrategy %+v", strategy)
 | 
						|
		}
 | 
						|
 | 
						|
		// Enabling critical pod annotation feature gate should create critical pod
 | 
						|
		utilfeature.DefaultFeatureGate.Set("ExperimentalCriticalPodAnnotation=True")
 | 
						|
		switch strategy.Type {
 | 
						|
		case extensions.OnDeleteDaemonSetStrategyType:
 | 
						|
			syncAndValidateDaemonSets(t, manager, ds, podControl, 1, 0, 2)
 | 
						|
		case extensions.RollingUpdateDaemonSetStrategyType:
 | 
						|
			syncAndValidateDaemonSets(t, manager, ds, podControl, 1, 0, 3)
 | 
						|
		default:
 | 
						|
			t.Fatalf("unexpected UpdateStrategy %+v", strategy)
 | 
						|
		}
 | 
						|
	}
 | 
						|
}
 | 
						|
 | 
						|
// DaemonSets should NOT launch a critical pod when there are port conflicts.
 | 
						|
func TestPortConflictNodeDaemonDoesNotLaunchCriticalPod(t *testing.T) {
 | 
						|
	for _, strategy := range updateStrategies() {
 | 
						|
		podSpec := v1.PodSpec{
 | 
						|
			NodeName: "port-conflict",
 | 
						|
			Containers: []v1.Container{{
 | 
						|
				Ports: []v1.ContainerPort{{
 | 
						|
					HostPort: 666,
 | 
						|
				}},
 | 
						|
			}},
 | 
						|
		}
 | 
						|
		manager, podControl, _ := newTestController()
 | 
						|
		node := newNode("port-conflict", nil)
 | 
						|
		manager.nodeStore.Add(node)
 | 
						|
		manager.podStore.Add(&v1.Pod{
 | 
						|
			Spec: podSpec,
 | 
						|
		})
 | 
						|
 | 
						|
		utilfeature.DefaultFeatureGate.Set("ExperimentalCriticalPodAnnotation=True")
 | 
						|
		ds := newDaemonSet("critical")
 | 
						|
		ds.Spec.UpdateStrategy = *strategy
 | 
						|
		ds.Spec.Template.Spec = podSpec
 | 
						|
		setDaemonSetCritical(ds)
 | 
						|
		manager.dsStore.Add(ds)
 | 
						|
		syncAndValidateDaemonSets(t, manager, ds, podControl, 0, 0, 0)
 | 
						|
	}
 | 
						|
}
 | 
						|
 | 
						|
func setDaemonSetCritical(ds *extensions.DaemonSet) {
 | 
						|
	ds.Namespace = api.NamespaceSystem
 | 
						|
	if ds.Spec.Template.ObjectMeta.Annotations == nil {
 | 
						|
		ds.Spec.Template.ObjectMeta.Annotations = make(map[string]string)
 | 
						|
	}
 | 
						|
	ds.Spec.Template.ObjectMeta.Annotations[kubelettypes.CriticalPodAnnotationKey] = ""
 | 
						|
}
 | 
						|
 | 
						|
func TestNodeShouldRunDaemonPod(t *testing.T) {
 | 
						|
	cases := []struct {
 | 
						|
		podsOnNode                                       []*v1.Pod
 | 
						|
		nodeCondition                                    []v1.NodeCondition
 | 
						|
		ds                                               *extensions.DaemonSet
 | 
						|
		wantToRun, shouldSchedule, shouldContinueRunning bool
 | 
						|
		err                                              error
 | 
						|
	}{
 | 
						|
		{
 | 
						|
			ds: &extensions.DaemonSet{
 | 
						|
				Spec: extensions.DaemonSetSpec{
 | 
						|
					Selector: &metav1.LabelSelector{MatchLabels: simpleDaemonSetLabel},
 | 
						|
					Template: v1.PodTemplateSpec{
 | 
						|
						ObjectMeta: metav1.ObjectMeta{
 | 
						|
							Labels: simpleDaemonSetLabel,
 | 
						|
						},
 | 
						|
						Spec: resourcePodSpec("", "50M", "0.5"),
 | 
						|
					},
 | 
						|
				},
 | 
						|
			},
 | 
						|
			wantToRun:             true,
 | 
						|
			shouldSchedule:        true,
 | 
						|
			shouldContinueRunning: true,
 | 
						|
		},
 | 
						|
		{
 | 
						|
			ds: &extensions.DaemonSet{
 | 
						|
				Spec: extensions.DaemonSetSpec{
 | 
						|
					Selector: &metav1.LabelSelector{MatchLabels: simpleDaemonSetLabel},
 | 
						|
					Template: v1.PodTemplateSpec{
 | 
						|
						ObjectMeta: metav1.ObjectMeta{
 | 
						|
							Labels: simpleDaemonSetLabel,
 | 
						|
						},
 | 
						|
						Spec: resourcePodSpec("", "200M", "0.5"),
 | 
						|
					},
 | 
						|
				},
 | 
						|
			},
 | 
						|
			wantToRun:             true,
 | 
						|
			shouldSchedule:        false,
 | 
						|
			shouldContinueRunning: true,
 | 
						|
		},
 | 
						|
		{
 | 
						|
			ds: &extensions.DaemonSet{
 | 
						|
				Spec: extensions.DaemonSetSpec{
 | 
						|
					Selector: &metav1.LabelSelector{MatchLabels: simpleDaemonSetLabel},
 | 
						|
					Template: v1.PodTemplateSpec{
 | 
						|
						ObjectMeta: metav1.ObjectMeta{
 | 
						|
							Labels: simpleDaemonSetLabel,
 | 
						|
						},
 | 
						|
						Spec: resourcePodSpec("other-node", "50M", "0.5"),
 | 
						|
					},
 | 
						|
				},
 | 
						|
			},
 | 
						|
			wantToRun:             false,
 | 
						|
			shouldSchedule:        false,
 | 
						|
			shouldContinueRunning: false,
 | 
						|
		},
 | 
						|
		{
 | 
						|
			podsOnNode: []*v1.Pod{
 | 
						|
				{
 | 
						|
					Spec: v1.PodSpec{
 | 
						|
						Containers: []v1.Container{{
 | 
						|
							Ports: []v1.ContainerPort{{
 | 
						|
								HostPort: 666,
 | 
						|
							}},
 | 
						|
						}},
 | 
						|
					},
 | 
						|
				},
 | 
						|
			},
 | 
						|
			ds: &extensions.DaemonSet{
 | 
						|
				Spec: extensions.DaemonSetSpec{
 | 
						|
					Selector: &metav1.LabelSelector{MatchLabels: simpleDaemonSetLabel},
 | 
						|
					Template: v1.PodTemplateSpec{
 | 
						|
						ObjectMeta: metav1.ObjectMeta{
 | 
						|
							Labels: simpleDaemonSetLabel,
 | 
						|
						},
 | 
						|
						Spec: v1.PodSpec{
 | 
						|
							Containers: []v1.Container{{
 | 
						|
								Ports: []v1.ContainerPort{{
 | 
						|
									HostPort: 666,
 | 
						|
								}},
 | 
						|
							}},
 | 
						|
						},
 | 
						|
					},
 | 
						|
				},
 | 
						|
			},
 | 
						|
			wantToRun:             false,
 | 
						|
			shouldSchedule:        false,
 | 
						|
			shouldContinueRunning: false,
 | 
						|
		},
 | 
						|
	}
 | 
						|
 | 
						|
	for i, c := range cases {
 | 
						|
		for _, strategy := range updateStrategies() {
 | 
						|
			node := newNode("test-node", nil)
 | 
						|
			node.Status.Conditions = append(node.Status.Conditions, c.nodeCondition...)
 | 
						|
			node.Status.Allocatable = allocatableResources("100M", "1")
 | 
						|
			manager, _, _ := newTestController()
 | 
						|
			manager.nodeStore.Add(node)
 | 
						|
			for _, p := range c.podsOnNode {
 | 
						|
				manager.podStore.Add(p)
 | 
						|
				p.Spec.NodeName = "test-node"
 | 
						|
			}
 | 
						|
			c.ds.Spec.UpdateStrategy = *strategy
 | 
						|
			wantToRun, shouldSchedule, shouldContinueRunning, err := manager.nodeShouldRunDaemonPod(node, c.ds)
 | 
						|
 | 
						|
			if wantToRun != c.wantToRun {
 | 
						|
				t.Errorf("[%v] expected wantToRun: %v, got: %v", i, c.wantToRun, wantToRun)
 | 
						|
			}
 | 
						|
			if shouldSchedule != c.shouldSchedule {
 | 
						|
				t.Errorf("[%v] expected shouldSchedule: %v, got: %v", i, c.shouldSchedule, shouldSchedule)
 | 
						|
			}
 | 
						|
			if shouldContinueRunning != c.shouldContinueRunning {
 | 
						|
				t.Errorf("[%v] expected shouldContinueRunning: %v, got: %v", i, c.shouldContinueRunning, shouldContinueRunning)
 | 
						|
			}
 | 
						|
			if err != c.err {
 | 
						|
				t.Errorf("[%v] expected err: %v, got: %v", i, c.err, err)
 | 
						|
			}
 | 
						|
		}
 | 
						|
	}
 | 
						|
}
 | 
						|
 | 
						|
// DaemonSets should be resynced when node labels or taints changed
 | 
						|
func TestUpdateNode(t *testing.T) {
 | 
						|
	var enqueued bool
 | 
						|
 | 
						|
	cases := []struct {
 | 
						|
		test          string
 | 
						|
		newNode       *v1.Node
 | 
						|
		oldNode       *v1.Node
 | 
						|
		ds            *extensions.DaemonSet
 | 
						|
		shouldEnqueue bool
 | 
						|
	}{
 | 
						|
		{
 | 
						|
			test:    "Nothing changed, should not enqueue",
 | 
						|
			oldNode: newNode("node1", nil),
 | 
						|
			newNode: newNode("node1", nil),
 | 
						|
			ds: func() *extensions.DaemonSet {
 | 
						|
				ds := newDaemonSet("ds")
 | 
						|
				ds.Spec.Template.Spec.NodeSelector = simpleNodeLabel
 | 
						|
				return ds
 | 
						|
			}(),
 | 
						|
			shouldEnqueue: false,
 | 
						|
		},
 | 
						|
		{
 | 
						|
			test:    "Node labels changed",
 | 
						|
			oldNode: newNode("node1", nil),
 | 
						|
			newNode: newNode("node1", simpleNodeLabel),
 | 
						|
			ds: func() *extensions.DaemonSet {
 | 
						|
				ds := newDaemonSet("ds")
 | 
						|
				ds.Spec.Template.Spec.NodeSelector = simpleNodeLabel
 | 
						|
				return ds
 | 
						|
			}(),
 | 
						|
			shouldEnqueue: true,
 | 
						|
		},
 | 
						|
		{
 | 
						|
			test: "Node taints changed",
 | 
						|
			oldNode: func() *v1.Node {
 | 
						|
				node := newNode("node1", nil)
 | 
						|
				setNodeTaint(node, noScheduleTaints)
 | 
						|
				return node
 | 
						|
			}(),
 | 
						|
			newNode:       newNode("node1", nil),
 | 
						|
			ds:            newDaemonSet("ds"),
 | 
						|
			shouldEnqueue: true,
 | 
						|
		},
 | 
						|
	}
 | 
						|
	for _, c := range cases {
 | 
						|
		for _, strategy := range updateStrategies() {
 | 
						|
			manager, podControl, _ := newTestController()
 | 
						|
			manager.nodeStore.Add(c.oldNode)
 | 
						|
			c.ds.Spec.UpdateStrategy = *strategy
 | 
						|
			manager.dsStore.Add(c.ds)
 | 
						|
			syncAndValidateDaemonSets(t, manager, c.ds, podControl, 0, 0, 0)
 | 
						|
 | 
						|
			manager.enqueueDaemonSet = func(ds *extensions.DaemonSet) {
 | 
						|
				if ds.Name == "ds" {
 | 
						|
					enqueued = true
 | 
						|
				}
 | 
						|
			}
 | 
						|
 | 
						|
			enqueued = false
 | 
						|
			manager.updateNode(c.oldNode, c.newNode)
 | 
						|
			if enqueued != c.shouldEnqueue {
 | 
						|
				t.Errorf("Test case: '%s', expected: %t, got: %t", c.test, c.shouldEnqueue, enqueued)
 | 
						|
			}
 | 
						|
		}
 | 
						|
	}
 | 
						|
}
 | 
						|
 | 
						|
// DaemonSets should be resynced when non-daemon pods was deleted.
 | 
						|
func TestDeleteNoDaemonPod(t *testing.T) {
 | 
						|
	var enqueued bool
 | 
						|
 | 
						|
	cases := []struct {
 | 
						|
		test          string
 | 
						|
		node          *v1.Node
 | 
						|
		existPods     []*v1.Pod
 | 
						|
		deletedPod    *v1.Pod
 | 
						|
		ds            *extensions.DaemonSet
 | 
						|
		shouldEnqueue bool
 | 
						|
	}{
 | 
						|
		{
 | 
						|
			test: "Deleted non-daemon pods to release resources",
 | 
						|
			node: func() *v1.Node {
 | 
						|
				node := newNode("node1", nil)
 | 
						|
				node.Status.Conditions = []v1.NodeCondition{
 | 
						|
					{Type: v1.NodeReady, Status: v1.ConditionTrue},
 | 
						|
				}
 | 
						|
				node.Status.Allocatable = allocatableResources("200M", "200m")
 | 
						|
				return node
 | 
						|
			}(),
 | 
						|
			existPods: func() []*v1.Pod {
 | 
						|
				pods := []*v1.Pod{}
 | 
						|
				for i := 0; i < 4; i++ {
 | 
						|
					podSpec := resourcePodSpec("node1", "50M", "50m")
 | 
						|
					pods = append(pods, &v1.Pod{
 | 
						|
						ObjectMeta: metav1.ObjectMeta{
 | 
						|
							Name: fmt.Sprintf("pod_%d", i),
 | 
						|
						},
 | 
						|
						Spec: podSpec,
 | 
						|
					})
 | 
						|
				}
 | 
						|
				return pods
 | 
						|
			}(),
 | 
						|
			deletedPod: func() *v1.Pod {
 | 
						|
				podSpec := resourcePodSpec("node1", "50M", "50m")
 | 
						|
				return &v1.Pod{
 | 
						|
					ObjectMeta: metav1.ObjectMeta{
 | 
						|
						Name: "pod_0",
 | 
						|
					},
 | 
						|
					Spec: podSpec,
 | 
						|
				}
 | 
						|
			}(),
 | 
						|
			ds: func() *extensions.DaemonSet {
 | 
						|
				ds := newDaemonSet("ds")
 | 
						|
				ds.Spec.Template.Spec = resourcePodSpec("", "50M", "50m")
 | 
						|
				return ds
 | 
						|
			}(),
 | 
						|
			shouldEnqueue: true,
 | 
						|
		},
 | 
						|
		{
 | 
						|
			test: "Deleted non-daemon pods (with controller) to release resources",
 | 
						|
			node: func() *v1.Node {
 | 
						|
				node := newNode("node1", nil)
 | 
						|
				node.Status.Conditions = []v1.NodeCondition{
 | 
						|
					{Type: v1.NodeReady, Status: v1.ConditionTrue},
 | 
						|
				}
 | 
						|
				node.Status.Allocatable = allocatableResources("200M", "200m")
 | 
						|
				return node
 | 
						|
			}(),
 | 
						|
			existPods: func() []*v1.Pod {
 | 
						|
				pods := []*v1.Pod{}
 | 
						|
				for i := 0; i < 4; i++ {
 | 
						|
					podSpec := resourcePodSpec("node1", "50M", "50m")
 | 
						|
					pods = append(pods, &v1.Pod{
 | 
						|
						ObjectMeta: metav1.ObjectMeta{
 | 
						|
							Name: fmt.Sprintf("pod_%d", i),
 | 
						|
							OwnerReferences: []metav1.OwnerReference{
 | 
						|
								{Controller: func() *bool { res := true; return &res }()},
 | 
						|
							},
 | 
						|
						},
 | 
						|
						Spec: podSpec,
 | 
						|
					})
 | 
						|
				}
 | 
						|
				return pods
 | 
						|
			}(),
 | 
						|
			deletedPod: func() *v1.Pod {
 | 
						|
				podSpec := resourcePodSpec("node1", "50M", "50m")
 | 
						|
				return &v1.Pod{
 | 
						|
					ObjectMeta: metav1.ObjectMeta{
 | 
						|
						Name: "pod_0",
 | 
						|
						OwnerReferences: []metav1.OwnerReference{
 | 
						|
							{Controller: func() *bool { res := true; return &res }()},
 | 
						|
						},
 | 
						|
					},
 | 
						|
					Spec: podSpec,
 | 
						|
				}
 | 
						|
			}(),
 | 
						|
			ds: func() *extensions.DaemonSet {
 | 
						|
				ds := newDaemonSet("ds")
 | 
						|
				ds.Spec.Template.Spec = resourcePodSpec("", "50M", "50m")
 | 
						|
				return ds
 | 
						|
			}(),
 | 
						|
			shouldEnqueue: true,
 | 
						|
		},
 | 
						|
		{
 | 
						|
			test: "Deleted no scheduled pods",
 | 
						|
			node: func() *v1.Node {
 | 
						|
				node := newNode("node1", nil)
 | 
						|
				node.Status.Conditions = []v1.NodeCondition{
 | 
						|
					{Type: v1.NodeReady, Status: v1.ConditionTrue},
 | 
						|
				}
 | 
						|
				node.Status.Allocatable = allocatableResources("200M", "200m")
 | 
						|
				return node
 | 
						|
			}(),
 | 
						|
			existPods: func() []*v1.Pod {
 | 
						|
				pods := []*v1.Pod{}
 | 
						|
				for i := 0; i < 4; i++ {
 | 
						|
					podSpec := resourcePodSpec("node1", "50M", "50m")
 | 
						|
					pods = append(pods, &v1.Pod{
 | 
						|
						ObjectMeta: metav1.ObjectMeta{
 | 
						|
							Name: fmt.Sprintf("pod_%d", i),
 | 
						|
							OwnerReferences: []metav1.OwnerReference{
 | 
						|
								{Controller: func() *bool { res := true; return &res }()},
 | 
						|
							},
 | 
						|
						},
 | 
						|
						Spec: podSpec,
 | 
						|
					})
 | 
						|
				}
 | 
						|
				return pods
 | 
						|
			}(),
 | 
						|
			deletedPod: func() *v1.Pod {
 | 
						|
				podSpec := resourcePodSpec("", "50M", "50m")
 | 
						|
				return &v1.Pod{
 | 
						|
					ObjectMeta: metav1.ObjectMeta{
 | 
						|
						Name: "pod_5",
 | 
						|
					},
 | 
						|
					Spec: podSpec,
 | 
						|
				}
 | 
						|
			}(),
 | 
						|
			ds: func() *extensions.DaemonSet {
 | 
						|
				ds := newDaemonSet("ds")
 | 
						|
				ds.Spec.Template.Spec = resourcePodSpec("", "50M", "50m")
 | 
						|
				return ds
 | 
						|
			}(),
 | 
						|
			shouldEnqueue: false,
 | 
						|
		},
 | 
						|
	}
 | 
						|
 | 
						|
	for _, c := range cases {
 | 
						|
		for _, strategy := range updateStrategies() {
 | 
						|
			manager, podControl, _ := newTestController()
 | 
						|
			manager.nodeStore.Add(c.node)
 | 
						|
			c.ds.Spec.UpdateStrategy = *strategy
 | 
						|
			manager.dsStore.Add(c.ds)
 | 
						|
			for _, pod := range c.existPods {
 | 
						|
				manager.podStore.Add(pod)
 | 
						|
			}
 | 
						|
			switch strategy.Type {
 | 
						|
			case extensions.OnDeleteDaemonSetStrategyType:
 | 
						|
				syncAndValidateDaemonSets(t, manager, c.ds, podControl, 0, 0, 2)
 | 
						|
			case extensions.RollingUpdateDaemonSetStrategyType:
 | 
						|
				syncAndValidateDaemonSets(t, manager, c.ds, podControl, 0, 0, 3)
 | 
						|
			default:
 | 
						|
				t.Fatalf("unexpected UpdateStrategy %+v", strategy)
 | 
						|
			}
 | 
						|
 | 
						|
			manager.enqueueDaemonSetRateLimited = func(ds *extensions.DaemonSet) {
 | 
						|
				if ds.Name == "ds" {
 | 
						|
					enqueued = true
 | 
						|
				}
 | 
						|
			}
 | 
						|
 | 
						|
			enqueued = false
 | 
						|
			manager.deletePod(c.deletedPod)
 | 
						|
			if enqueued != c.shouldEnqueue {
 | 
						|
				t.Errorf("Test case: '%s', expected: %t, got: %t", c.test, c.shouldEnqueue, enqueued)
 | 
						|
			}
 | 
						|
		}
 | 
						|
	}
 | 
						|
}
 | 
						|
 | 
						|
func TestGetNodesToDaemonPods(t *testing.T) {
 | 
						|
	for _, strategy := range updateStrategies() {
 | 
						|
		ds := newDaemonSet("foo")
 | 
						|
		ds.Spec.UpdateStrategy = *strategy
 | 
						|
		ds2 := newDaemonSet("foo2")
 | 
						|
		ds2.Spec.UpdateStrategy = *strategy
 | 
						|
		manager, _, _ := newTestController(ds, ds2)
 | 
						|
		manager.dsStore.Add(ds)
 | 
						|
		manager.dsStore.Add(ds2)
 | 
						|
		addNodes(manager.nodeStore, 0, 2, nil)
 | 
						|
 | 
						|
		// These pods should be returned.
 | 
						|
		wantedPods := []*v1.Pod{
 | 
						|
			newPod("matching-owned-0-", "node-0", simpleDaemonSetLabel, ds),
 | 
						|
			newPod("matching-orphan-0-", "node-0", simpleDaemonSetLabel, nil),
 | 
						|
			newPod("matching-owned-1-", "node-1", simpleDaemonSetLabel, ds),
 | 
						|
			newPod("matching-orphan-1-", "node-1", simpleDaemonSetLabel, nil),
 | 
						|
		}
 | 
						|
		failedPod := newPod("matching-owned-failed-pod-1-", "node-1", simpleDaemonSetLabel, ds)
 | 
						|
		failedPod.Status = v1.PodStatus{Phase: v1.PodFailed}
 | 
						|
		wantedPods = append(wantedPods, failedPod)
 | 
						|
		for _, pod := range wantedPods {
 | 
						|
			manager.podStore.Add(pod)
 | 
						|
		}
 | 
						|
 | 
						|
		// These pods should be ignored.
 | 
						|
		ignoredPods := []*v1.Pod{
 | 
						|
			newPod("non-matching-owned-0-", "node-0", simpleDaemonSetLabel2, ds),
 | 
						|
			newPod("non-matching-orphan-1-", "node-1", simpleDaemonSetLabel2, nil),
 | 
						|
			newPod("matching-owned-by-other-0-", "node-0", simpleDaemonSetLabel, ds2),
 | 
						|
		}
 | 
						|
		for _, pod := range ignoredPods {
 | 
						|
			manager.podStore.Add(pod)
 | 
						|
		}
 | 
						|
 | 
						|
		nodesToDaemonPods, err := manager.getNodesToDaemonPods(ds)
 | 
						|
		if err != nil {
 | 
						|
			t.Fatalf("getNodesToDaemonPods() error: %v", err)
 | 
						|
		}
 | 
						|
		gotPods := map[string]bool{}
 | 
						|
		for node, pods := range nodesToDaemonPods {
 | 
						|
			for _, pod := range pods {
 | 
						|
				if pod.Spec.NodeName != node {
 | 
						|
					t.Errorf("pod %v grouped into %v but belongs in %v", pod.Name, node, pod.Spec.NodeName)
 | 
						|
				}
 | 
						|
				gotPods[pod.Name] = true
 | 
						|
			}
 | 
						|
		}
 | 
						|
		for _, pod := range wantedPods {
 | 
						|
			if !gotPods[pod.Name] {
 | 
						|
				t.Errorf("expected pod %v but didn't get it", pod.Name)
 | 
						|
			}
 | 
						|
			delete(gotPods, pod.Name)
 | 
						|
		}
 | 
						|
		for podName := range gotPods {
 | 
						|
			t.Errorf("unexpected pod %v was returned", podName)
 | 
						|
		}
 | 
						|
	}
 | 
						|
}
 | 
						|
 | 
						|
func TestAddNode(t *testing.T) {
 | 
						|
	manager, _, _ := newTestController()
 | 
						|
	node1 := newNode("node1", nil)
 | 
						|
	ds := newDaemonSet("ds")
 | 
						|
	ds.Spec.Template.Spec.NodeSelector = simpleNodeLabel
 | 
						|
	manager.dsStore.Add(ds)
 | 
						|
 | 
						|
	manager.addNode(node1)
 | 
						|
	if got, want := manager.queue.Len(), 0; got != want {
 | 
						|
		t.Fatalf("queue.Len() = %v, want %v", got, want)
 | 
						|
	}
 | 
						|
 | 
						|
	node2 := newNode("node2", simpleNodeLabel)
 | 
						|
	manager.addNode(node2)
 | 
						|
	if got, want := manager.queue.Len(), 1; got != want {
 | 
						|
		t.Fatalf("queue.Len() = %v, want %v", got, want)
 | 
						|
	}
 | 
						|
	key, done := manager.queue.Get()
 | 
						|
	if key == nil || done {
 | 
						|
		t.Fatalf("failed to enqueue controller for node %v", node2.Name)
 | 
						|
	}
 | 
						|
}
 | 
						|
 | 
						|
func TestAddPod(t *testing.T) {
 | 
						|
	for _, strategy := range updateStrategies() {
 | 
						|
		manager, _, _ := newTestController()
 | 
						|
		ds1 := newDaemonSet("foo1")
 | 
						|
		ds1.Spec.UpdateStrategy = *strategy
 | 
						|
		ds2 := newDaemonSet("foo2")
 | 
						|
		ds2.Spec.UpdateStrategy = *strategy
 | 
						|
		manager.dsStore.Add(ds1)
 | 
						|
		manager.dsStore.Add(ds2)
 | 
						|
 | 
						|
		pod1 := newPod("pod1-", "node-0", simpleDaemonSetLabel, ds1)
 | 
						|
		manager.addPod(pod1)
 | 
						|
		if got, want := manager.queue.Len(), 1; got != want {
 | 
						|
			t.Fatalf("queue.Len() = %v, want %v", got, want)
 | 
						|
		}
 | 
						|
		key, done := manager.queue.Get()
 | 
						|
		if key == nil || done {
 | 
						|
			t.Fatalf("failed to enqueue controller for pod %v", pod1.Name)
 | 
						|
		}
 | 
						|
		expectedKey, _ := controller.KeyFunc(ds1)
 | 
						|
		if got, want := key.(string), expectedKey; got != want {
 | 
						|
			t.Errorf("queue.Get() = %v, want %v", got, want)
 | 
						|
		}
 | 
						|
 | 
						|
		pod2 := newPod("pod2-", "node-0", simpleDaemonSetLabel, ds2)
 | 
						|
		manager.addPod(pod2)
 | 
						|
		if got, want := manager.queue.Len(), 1; got != want {
 | 
						|
			t.Fatalf("queue.Len() = %v, want %v", got, want)
 | 
						|
		}
 | 
						|
		key, done = manager.queue.Get()
 | 
						|
		if key == nil || done {
 | 
						|
			t.Fatalf("failed to enqueue controller for pod %v", pod2.Name)
 | 
						|
		}
 | 
						|
		expectedKey, _ = controller.KeyFunc(ds2)
 | 
						|
		if got, want := key.(string), expectedKey; got != want {
 | 
						|
			t.Errorf("queue.Get() = %v, want %v", got, want)
 | 
						|
		}
 | 
						|
	}
 | 
						|
}
 | 
						|
 | 
						|
func TestAddPodOrphan(t *testing.T) {
 | 
						|
	for _, strategy := range updateStrategies() {
 | 
						|
		manager, _, _ := newTestController()
 | 
						|
		ds1 := newDaemonSet("foo1")
 | 
						|
		ds1.Spec.UpdateStrategy = *strategy
 | 
						|
		ds2 := newDaemonSet("foo2")
 | 
						|
		ds2.Spec.UpdateStrategy = *strategy
 | 
						|
		ds3 := newDaemonSet("foo3")
 | 
						|
		ds3.Spec.UpdateStrategy = *strategy
 | 
						|
		ds3.Spec.Selector.MatchLabels = simpleDaemonSetLabel2
 | 
						|
		manager.dsStore.Add(ds1)
 | 
						|
		manager.dsStore.Add(ds2)
 | 
						|
		manager.dsStore.Add(ds3)
 | 
						|
 | 
						|
		// Make pod an orphan. Expect matching sets to be queued.
 | 
						|
		pod := newPod("pod1-", "node-0", simpleDaemonSetLabel, nil)
 | 
						|
		manager.addPod(pod)
 | 
						|
		if got, want := manager.queue.Len(), 2; got != want {
 | 
						|
			t.Fatalf("queue.Len() = %v, want %v", got, want)
 | 
						|
		}
 | 
						|
		if got, want := getQueuedKeys(manager.queue), []string{"default/foo1", "default/foo2"}; !reflect.DeepEqual(got, want) {
 | 
						|
			t.Errorf("getQueuedKeys() = %v, want %v", got, want)
 | 
						|
		}
 | 
						|
	}
 | 
						|
}
 | 
						|
 | 
						|
func TestUpdatePod(t *testing.T) {
 | 
						|
	for _, strategy := range updateStrategies() {
 | 
						|
		manager, _, _ := newTestController()
 | 
						|
		ds1 := newDaemonSet("foo1")
 | 
						|
		ds1.Spec.UpdateStrategy = *strategy
 | 
						|
		ds2 := newDaemonSet("foo2")
 | 
						|
		ds2.Spec.UpdateStrategy = *strategy
 | 
						|
		manager.dsStore.Add(ds1)
 | 
						|
		manager.dsStore.Add(ds2)
 | 
						|
 | 
						|
		pod1 := newPod("pod1-", "node-0", simpleDaemonSetLabel, ds1)
 | 
						|
		prev := *pod1
 | 
						|
		bumpResourceVersion(pod1)
 | 
						|
		manager.updatePod(&prev, pod1)
 | 
						|
		if got, want := manager.queue.Len(), 1; got != want {
 | 
						|
			t.Fatalf("queue.Len() = %v, want %v", got, want)
 | 
						|
		}
 | 
						|
		key, done := manager.queue.Get()
 | 
						|
		if key == nil || done {
 | 
						|
			t.Fatalf("failed to enqueue controller for pod %v", pod1.Name)
 | 
						|
		}
 | 
						|
		expectedKey, _ := controller.KeyFunc(ds1)
 | 
						|
		if got, want := key.(string), expectedKey; got != want {
 | 
						|
			t.Errorf("queue.Get() = %v, want %v", got, want)
 | 
						|
		}
 | 
						|
 | 
						|
		pod2 := newPod("pod2-", "node-0", simpleDaemonSetLabel, ds2)
 | 
						|
		prev = *pod2
 | 
						|
		bumpResourceVersion(pod2)
 | 
						|
		manager.updatePod(&prev, pod2)
 | 
						|
		if got, want := manager.queue.Len(), 1; got != want {
 | 
						|
			t.Fatalf("queue.Len() = %v, want %v", got, want)
 | 
						|
		}
 | 
						|
		key, done = manager.queue.Get()
 | 
						|
		if key == nil || done {
 | 
						|
			t.Fatalf("failed to enqueue controller for pod %v", pod2.Name)
 | 
						|
		}
 | 
						|
		expectedKey, _ = controller.KeyFunc(ds2)
 | 
						|
		if got, want := key.(string), expectedKey; got != want {
 | 
						|
			t.Errorf("queue.Get() = %v, want %v", got, want)
 | 
						|
		}
 | 
						|
	}
 | 
						|
}
 | 
						|
 | 
						|
func TestUpdatePodOrphanSameLabels(t *testing.T) {
 | 
						|
	for _, strategy := range updateStrategies() {
 | 
						|
		manager, _, _ := newTestController()
 | 
						|
		ds1 := newDaemonSet("foo1")
 | 
						|
		ds1.Spec.UpdateStrategy = *strategy
 | 
						|
		ds2 := newDaemonSet("foo2")
 | 
						|
		ds2.Spec.UpdateStrategy = *strategy
 | 
						|
		manager.dsStore.Add(ds1)
 | 
						|
		manager.dsStore.Add(ds2)
 | 
						|
 | 
						|
		pod := newPod("pod1-", "node-0", simpleDaemonSetLabel, nil)
 | 
						|
		prev := *pod
 | 
						|
		bumpResourceVersion(pod)
 | 
						|
		manager.updatePod(&prev, pod)
 | 
						|
		if got, want := manager.queue.Len(), 0; got != want {
 | 
						|
			t.Fatalf("queue.Len() = %v, want %v", got, want)
 | 
						|
		}
 | 
						|
	}
 | 
						|
}
 | 
						|
 | 
						|
func TestUpdatePodOrphanWithNewLabels(t *testing.T) {
 | 
						|
	for _, strategy := range updateStrategies() {
 | 
						|
		manager, _, _ := newTestController()
 | 
						|
		ds1 := newDaemonSet("foo1")
 | 
						|
		ds1.Spec.UpdateStrategy = *strategy
 | 
						|
		ds2 := newDaemonSet("foo2")
 | 
						|
		ds2.Spec.UpdateStrategy = *strategy
 | 
						|
		manager.dsStore.Add(ds1)
 | 
						|
		manager.dsStore.Add(ds2)
 | 
						|
 | 
						|
		pod := newPod("pod1-", "node-0", simpleDaemonSetLabel, nil)
 | 
						|
		prev := *pod
 | 
						|
		prev.Labels = map[string]string{"foo2": "bar2"}
 | 
						|
		bumpResourceVersion(pod)
 | 
						|
		manager.updatePod(&prev, pod)
 | 
						|
		if got, want := manager.queue.Len(), 2; got != want {
 | 
						|
			t.Fatalf("queue.Len() = %v, want %v", got, want)
 | 
						|
		}
 | 
						|
		if got, want := getQueuedKeys(manager.queue), []string{"default/foo1", "default/foo2"}; !reflect.DeepEqual(got, want) {
 | 
						|
			t.Errorf("getQueuedKeys() = %v, want %v", got, want)
 | 
						|
		}
 | 
						|
	}
 | 
						|
}
 | 
						|
 | 
						|
func TestUpdatePodChangeControllerRef(t *testing.T) {
 | 
						|
	for _, strategy := range updateStrategies() {
 | 
						|
		ds := newDaemonSet("foo")
 | 
						|
		ds.Spec.UpdateStrategy = *strategy
 | 
						|
		manager, _, _ := newTestController()
 | 
						|
		ds1 := newDaemonSet("foo1")
 | 
						|
		ds2 := newDaemonSet("foo2")
 | 
						|
		manager.dsStore.Add(ds1)
 | 
						|
		manager.dsStore.Add(ds2)
 | 
						|
 | 
						|
		pod := newPod("pod1-", "node-0", simpleDaemonSetLabel, ds1)
 | 
						|
		prev := *pod
 | 
						|
		prev.OwnerReferences = []metav1.OwnerReference{*metav1.NewControllerRef(ds2, controllerKind)}
 | 
						|
		bumpResourceVersion(pod)
 | 
						|
		manager.updatePod(&prev, pod)
 | 
						|
		if got, want := manager.queue.Len(), 2; got != want {
 | 
						|
			t.Fatalf("queue.Len() = %v, want %v", got, want)
 | 
						|
		}
 | 
						|
	}
 | 
						|
}
 | 
						|
 | 
						|
func TestUpdatePodControllerRefRemoved(t *testing.T) {
 | 
						|
	for _, strategy := range updateStrategies() {
 | 
						|
		manager, _, _ := newTestController()
 | 
						|
		ds1 := newDaemonSet("foo1")
 | 
						|
		ds1.Spec.UpdateStrategy = *strategy
 | 
						|
		ds2 := newDaemonSet("foo2")
 | 
						|
		ds2.Spec.UpdateStrategy = *strategy
 | 
						|
		manager.dsStore.Add(ds1)
 | 
						|
		manager.dsStore.Add(ds2)
 | 
						|
 | 
						|
		pod := newPod("pod1-", "node-0", simpleDaemonSetLabel, ds1)
 | 
						|
		prev := *pod
 | 
						|
		pod.OwnerReferences = nil
 | 
						|
		bumpResourceVersion(pod)
 | 
						|
		manager.updatePod(&prev, pod)
 | 
						|
		if got, want := manager.queue.Len(), 2; got != want {
 | 
						|
			t.Fatalf("queue.Len() = %v, want %v", got, want)
 | 
						|
		}
 | 
						|
	}
 | 
						|
}
 | 
						|
 | 
						|
func TestDeletePod(t *testing.T) {
 | 
						|
	for _, strategy := range updateStrategies() {
 | 
						|
		manager, _, _ := newTestController()
 | 
						|
		ds1 := newDaemonSet("foo1")
 | 
						|
		ds1.Spec.UpdateStrategy = *strategy
 | 
						|
		ds2 := newDaemonSet("foo2")
 | 
						|
		ds2.Spec.UpdateStrategy = *strategy
 | 
						|
		manager.dsStore.Add(ds1)
 | 
						|
		manager.dsStore.Add(ds2)
 | 
						|
 | 
						|
		pod1 := newPod("pod1-", "node-0", simpleDaemonSetLabel, ds1)
 | 
						|
		manager.deletePod(pod1)
 | 
						|
		if got, want := manager.queue.Len(), 1; got != want {
 | 
						|
			t.Fatalf("queue.Len() = %v, want %v", got, want)
 | 
						|
		}
 | 
						|
		key, done := manager.queue.Get()
 | 
						|
		if key == nil || done {
 | 
						|
			t.Fatalf("failed to enqueue controller for pod %v", pod1.Name)
 | 
						|
		}
 | 
						|
		expectedKey, _ := controller.KeyFunc(ds1)
 | 
						|
		if got, want := key.(string), expectedKey; got != want {
 | 
						|
			t.Errorf("queue.Get() = %v, want %v", got, want)
 | 
						|
		}
 | 
						|
 | 
						|
		pod2 := newPod("pod2-", "node-0", simpleDaemonSetLabel, ds2)
 | 
						|
		manager.deletePod(pod2)
 | 
						|
		if got, want := manager.queue.Len(), 1; got != want {
 | 
						|
			t.Fatalf("queue.Len() = %v, want %v", got, want)
 | 
						|
		}
 | 
						|
		key, done = manager.queue.Get()
 | 
						|
		if key == nil || done {
 | 
						|
			t.Fatalf("failed to enqueue controller for pod %v", pod2.Name)
 | 
						|
		}
 | 
						|
		expectedKey, _ = controller.KeyFunc(ds2)
 | 
						|
		if got, want := key.(string), expectedKey; got != want {
 | 
						|
			t.Errorf("queue.Get() = %v, want %v", got, want)
 | 
						|
		}
 | 
						|
	}
 | 
						|
}
 | 
						|
 | 
						|
func TestDeletePodOrphan(t *testing.T) {
 | 
						|
	for _, strategy := range updateStrategies() {
 | 
						|
		manager, _, _ := newTestController()
 | 
						|
		ds1 := newDaemonSet("foo1")
 | 
						|
		ds1.Spec.UpdateStrategy = *strategy
 | 
						|
		ds2 := newDaemonSet("foo2")
 | 
						|
		ds2.Spec.UpdateStrategy = *strategy
 | 
						|
		ds3 := newDaemonSet("foo3")
 | 
						|
		ds3.Spec.UpdateStrategy = *strategy
 | 
						|
		ds3.Spec.Selector.MatchLabels = simpleDaemonSetLabel2
 | 
						|
		manager.dsStore.Add(ds1)
 | 
						|
		manager.dsStore.Add(ds2)
 | 
						|
		manager.dsStore.Add(ds3)
 | 
						|
 | 
						|
		pod := newPod("pod1-", "node-0", simpleDaemonSetLabel, nil)
 | 
						|
		manager.deletePod(pod)
 | 
						|
		if got, want := manager.queue.Len(), 0; got != want {
 | 
						|
			t.Fatalf("queue.Len() = %v, want %v", got, want)
 | 
						|
		}
 | 
						|
	}
 | 
						|
}
 | 
						|
 | 
						|
func bumpResourceVersion(obj metav1.Object) {
 | 
						|
	ver, _ := strconv.ParseInt(obj.GetResourceVersion(), 10, 32)
 | 
						|
	obj.SetResourceVersion(strconv.FormatInt(ver+1, 10))
 | 
						|
}
 | 
						|
 | 
						|
// getQueuedKeys returns a sorted list of keys in the queue.
 | 
						|
// It can be used to quickly check that multiple keys are in there.
 | 
						|
func getQueuedKeys(queue workqueue.RateLimitingInterface) []string {
 | 
						|
	var keys []string
 | 
						|
	count := queue.Len()
 | 
						|
	for i := 0; i < count; i++ {
 | 
						|
		key, done := queue.Get()
 | 
						|
		if done {
 | 
						|
			return keys
 | 
						|
		}
 | 
						|
		keys = append(keys, key.(string))
 | 
						|
	}
 | 
						|
	sort.Strings(keys)
 | 
						|
	return keys
 | 
						|
}
 |