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

fix e2e

Browse Source 
Signed-off-by: carlory <baofa.fan@daocloud.io>
This commit is contained in:
carlory 2025-02-21 16:00:20 +08:00
parent ab4389f174
commit 77de0b99c2
1 changed files with 20 additions and 14 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

34
test/e2e/storage/csimock/csi_kubelet_restart.go
View File

@ -25,6 +25,7 @@ import (
"github.com/onsi/ginkgo/v2"
"github.com/onsi/gomega"
apierrors "k8s.io/apimachinery/pkg/api/errors"
metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
"k8s.io/kubernetes/test/e2e/feature"
"k8s.io/kubernetes/test/e2e/framework"
@ -66,22 +67,27 @@ var _ = utils.SIGDescribe("CSI Mock when kubelet restart", feature.Kind, framewo
framework.ExpectNoError(err, "failed to get PVC %s", pvc.Name)
gomega.Expect(pvc.DeletionTimestamp).NotTo(gomega.BeNil(), "PVC %s should have deletion timestamp", pvc.Name)
// FIXME: the expected behavior is no NodeUnpublishVolume call is made during kubelet restart
ginkgo.By(fmt.Sprintf("Verifying that the driver received NodeUnpublishVolume call for PVC %s", pvc.Name))
gomega.Eventually(ctx, m.driver.GetCalls).
ginkgo.By(fmt.Sprintf("Verifying that the driver didn't receive NodeUnpublishVolume call for PVC %s", pvc.Name))
gomega.Consistently(ctx,
func(ctx context.Context) interface{} {
calls, err := m.driver.GetCalls(ctx)
if err != nil {
if apierrors.IsUnexpectedServerError(err) {
// kubelet might not be ready yet when getting the calls
gomega.TryAgainAfter(framework.Poll).Wrap(err).Now()
return nil
}
return nil
}
return calls
}).
WithPolling(framework.Poll).
WithTimeout(framework.RestartNodeReadyAgainTimeout).
Should(gomega.ContainElement(gomega.HaveField("Method", gomega.Equal("NodeUnpublishVolume"))))
WithTimeout(framework.ClaimProvisionShortTimeout).
ShouldNot(gomega.ContainElement(gomega.HaveField("Method", gomega.Equal("NodeUnpublishVolume"))))
// ginkgo.By(fmt.Sprintf("Verifying that the driver didn't receive NodeUnpublishVolume call for PVC %s", pvc.Name))
// gomega.Consistently(ctx, m.driver.GetCalls).
// WithPolling(framework.Poll).
// WithTimeout(framework.ClaimProvisionShortTimeout).
// ShouldNot(gomega.ContainElement(gomega.HaveField("Method", gomega.Equal("NodeUnpublishVolume"))))
// ginkgo.By("Verifying the Pod is still running")
// err = e2epod.WaitForPodRunningInNamespace(ctx, f.ClientSet, pod)
// framework.ExpectNoError(err, "failed to wait for pod %s to be running", pod.Name)
ginkgo.By("Verifying the Pod is still running")
err = e2epod.WaitForPodRunningInNamespace(ctx, f.ClientSet, pod)
framework.ExpectNoError(err, "failed to wait for pod %s to be running", pod.Name)
})
})