fix timeout to wait daemonset

Author: bzsuni

test/e2e/common/ds.go

@@ -13,6 +13,8 @@ import (
 	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
 	"k8s.io/apimachinery/pkg/types"
 	"sigs.k8s.io/controller-runtime/pkg/client"
+
+	. "github.com/onsi/ginkgo/v2"
 )
 
 func CreateDaemonSet(ctx context.Context, cli client.Client, name string, image string, timeout time.Duration) (*appsv1.DaemonSet, error) {
@@ -64,6 +66,10 @@ func CreateDaemonSet(ctx context.Context, cli client.Client, name string, image
 			b := res.Status.DesiredNumberScheduled
 			c := res.Status.NumberAvailable
 
+			GinkgoWriter.Printf("=======sundebug========res.Status.CurrentNumberScheduled: %v\n", res.Status.CurrentNumberScheduled)
+			GinkgoWriter.Printf("=======sundebug========res.Status.DesiredNumberScheduled: %v\n", res.Status.DesiredNumberScheduled)
+			GinkgoWriter.Printf("=======sundebug========res.Status.NumberAvailable: %v\n", res.Status.NumberAvailable)
+
 			if a == b && b == c && a > 0 {
 				return res, nil
 			}

test/e2e/reliability/reliability_test.go

@@ -290,13 +290,13 @@ var _ = Describe("Reliability", Serial, Label("Reliability"), func() {
 			Expect(err).NotTo(HaveOccurred())
 			Expect(nowEgep.Endpoints).Should(Equal(beforeEgep.Endpoints), fmt.Sprintf("expect:\n%v\ngot:\n %v\n", beforeEgep.Endpoints, nowEgep.Endpoints))
 		},
-			Entry("restart kube-controller-manager", constant.KubeControllerManagerLabel, time.Minute*2),
-			Entry("restart kube-apiserver", constant.KubeApiServerLabel, time.Minute*2),
-			Entry("restart etcd", constant.KubeEtcdLabel, time.Minute*2),
-			Entry("restart kube-scheduler", constant.KubeSchedulerLabel, time.Minute*2),
-			Entry("restart kube-proxy", constant.KubeProxyLabel, time.Minute*2),
-			Entry("restart calico-node", constant.CalicoNodeLabel, time.Minute*2),
-			Entry("restart calico-kube-controllers", constant.CalicoControllerLabel, time.Minute*2),
+			Entry("restart kube-controller-manager", Serial, constant.KubeControllerManagerLabel, time.Minute*2),
+			Entry("restart kube-apiserver", Serial, constant.KubeApiServerLabel, time.Minute*2),
+			Entry("restart etcd", Serial, constant.KubeEtcdLabel, time.Minute*2),
+			Entry("restart kube-scheduler", Serial, constant.KubeSchedulerLabel, time.Minute*2),
+			Entry("restart kube-proxy", Label("xxx"), Serial, constant.KubeProxyLabel, time.Minute*2),
+			Entry("restart calico-node", Serial, constant.CalicoNodeLabel, time.Minute*2),
+			Entry("restart calico-kube-controllers", Serial, constant.CalicoControllerLabel, time.Minute*2),
 		)
 	})