mirror of
https://github.com/intel/intel-device-plugins-for-kubernetes.git
synced 2025-06-03 03:59:37 +00:00
QAT, e2e: add qat-engine's testapp case
Add qat-engine testapp e2e tests Disable in CI/CD since the test is known not to work on simics. Signed-off-by: Hyeongju Johannes Lee <hyeongju.lee@intel.com>
This commit is contained in:
Hyeongju Johannes Lee
parent
7af23f1f70
commit
bdc86bc448
2
.github/workflows/lib-e2e.yaml
vendored
2
.github/workflows/lib-e2e.yaml
vendored
@ -28,7 +28,7 @@ jobs:
|
||||
- accel-config-demo
|
||||
- intel-deviceplugin-operator
|
||||
- name: e2e-qat-gnrd
|
||||
targetjob: e2e-qat FOCUS="Mode:dpdk" SKIP="(App:(crypto-perf|compress-perf)|Functionality)"
|
||||
targetjob: e2e-qat FOCUS="Mode:dpdk" SKIP="(App:(crypto-perf|compress-perf|qat-engine)|Functionality)"
|
||||
runner: simics-gnrd
|
||||
images:
|
||||
- intel-qat-plugin
|
||||
|
||||
@ -125,7 +125,16 @@ func describeQatDpdkPlugin() {
|
||||
})
|
||||
|
||||
ginkgo.It("deploys a crypto pod (openssl) requesting QAT resources [App:openssl]", func(ctx context.Context) {
|
||||
runCpaSampleCode(ctx, f, symmetric, resourceName)
|
||||
command := []string{
|
||||
"cpa_sample_code",
|
||||
"runTests=" + strconv.Itoa(symmetric),
|
||||
"signOfLife=1",
|
||||
}
|
||||
pod := createPod(ctx, f, "cpa-sample-code", resourceName, "intel/openssl-qat-engine:devel", command)
|
||||
|
||||
ginkgo.By("waiting the cpa-sample-code pod for the resource " + resourceName.String() + " to finish successfully")
|
||||
err := e2epod.WaitForPodSuccessInNamespaceTimeout(ctx, f.ClientSet, pod.ObjectMeta.Name, f.Namespace.Name, 300*time.Second)
|
||||
gomega.Expect(err).To(gomega.BeNil(), utils.GetPodLogs(ctx, f, pod.ObjectMeta.Name, pod.Spec.Containers[0].Name))
|
||||
})
|
||||
|
||||
ginkgo.It("deploys a crypto pod (dpdk crypto-perf) requesting QAT resources [App:crypto-perf]", func(ctx context.Context) {
|
||||
@ -137,6 +146,24 @@ func describeQatDpdkPlugin() {
|
||||
gomega.Expect(err).To(gomega.BeNil(), utils.GetPodLogs(ctx, f, "qat-dpdk-test-crypto-perf", "crypto-perf"))
|
||||
})
|
||||
|
||||
ginkgo.It("deploys a crypto pod (qat-engine testapp) [App:qat-engine]", func(ctx context.Context) {
|
||||
command := []string{
|
||||
"testapp",
|
||||
"-engine", "qathwtest",
|
||||
"-async_jobs", "1",
|
||||
"-c", "1",
|
||||
"-n", "1",
|
||||
"-nc", "1",
|
||||
"-v",
|
||||
"-hw_algo", "0x0029",
|
||||
}
|
||||
pod := createPod(ctx, f, "qat-engine-testapp", resourceName, "intel/openssl-qat-engine:devel", command)
|
||||
|
||||
ginkgo.By("waiting the qat-engine-testapp pod for the resource " + resourceName.String() + " to finish successfully")
|
||||
err := e2epod.WaitForPodSuccessInNamespaceTimeout(ctx, f.ClientSet, pod.ObjectMeta.Name, f.Namespace.Name, 300*time.Second)
|
||||
gomega.Expect(err).To(gomega.BeNil(), utils.GetPodLogs(ctx, f, pod.ObjectMeta.Name, pod.Spec.Containers[0].Name))
|
||||
})
|
||||
|
||||
ginkgo.When("there is no app to run [App:noapp]", func() {
|
||||
ginkgo.It("does nothing", func() {})
|
||||
})
|
||||
@ -152,7 +179,16 @@ func describeQatDpdkPlugin() {
|
||||
})
|
||||
|
||||
ginkgo.It("deploys a compress pod (openssl) requesting QAT resources [App:openssl]", func(ctx context.Context) {
|
||||
runCpaSampleCode(ctx, f, compression, resourceName)
|
||||
command := []string{
|
||||
"cpa_sample_code",
|
||||
"runTests=" + strconv.Itoa(compression),
|
||||
"signOfLife=1",
|
||||
}
|
||||
pod := createPod(ctx, f, "cpa-sample-code", resourceName, "intel/openssl-qat-engine:devel", command)
|
||||
|
||||
ginkgo.By("waiting the cpa-sample-code pod for the resource " + resourceName.String() + " to finish successfully")
|
||||
err := e2epod.WaitForPodSuccessInNamespaceTimeout(ctx, f.ClientSet, pod.ObjectMeta.Name, f.Namespace.Name, 300*time.Second)
|
||||
gomega.Expect(err).To(gomega.BeNil(), utils.GetPodLogs(ctx, f, pod.ObjectMeta.Name, pod.Spec.Containers[0].Name))
|
||||
})
|
||||
|
||||
ginkgo.It("deploys a compress pod (dpdk compress-perf) requesting QAT resources [App:compress-perf]", func(ctx context.Context) {
|
||||
@ -212,23 +248,31 @@ func describeQatDpdkPlugin() {
|
||||
}
|
||||
|
||||
ginkgo.By("checking if openssl pod runs successfully")
|
||||
runCpaSampleCode(ctx, f, compression, resourceName)
|
||||
command := []string{
|
||||
"cpa_sample_code",
|
||||
"runTests=" + strconv.Itoa(compression),
|
||||
"signOfLife=1",
|
||||
}
|
||||
pod := createPod(ctx, f, "cpa-sample-code", resourceName, "intel/openssl-qat-engine:devel", command)
|
||||
|
||||
ginkgo.By("waiting the cpa-sample-code pod for the resource " + resourceName.String() + " to finish successfully")
|
||||
err := e2epod.WaitForPodSuccessInNamespaceTimeout(ctx, f.ClientSet, pod.ObjectMeta.Name, f.Namespace.Name, 300*time.Second)
|
||||
gomega.Expect(err).To(gomega.BeNil(), utils.GetPodLogs(ctx, f, pod.ObjectMeta.Name, pod.Spec.Containers[0].Name))
|
||||
})
|
||||
})
|
||||
})
|
||||
}
|
||||
|
||||
func runCpaSampleCode(ctx context.Context, f *framework.Framework, runTests int, resourceName v1.ResourceName) {
|
||||
ginkgo.By("submitting a pod requesting QAT" + resourceName.String() + "resources")
|
||||
func createPod(ctx context.Context, f *framework.Framework, name string, resourceName v1.ResourceName, image string, command []string) *v1.Pod {
|
||||
podSpec := &v1.Pod{
|
||||
ObjectMeta: metav1.ObjectMeta{Name: "openssl-qat-engine"},
|
||||
ObjectMeta: metav1.ObjectMeta{Name: name},
|
||||
Spec: v1.PodSpec{
|
||||
Containers: []v1.Container{
|
||||
{
|
||||
Name: "openssl-qat-engine",
|
||||
Image: "intel/openssl-qat-engine:devel",
|
||||
Name: name,
|
||||
Image: image,
|
||||
ImagePullPolicy: "IfNotPresent",
|
||||
Command: []string{"cpa_sample_code", "runTests=" + strconv.Itoa(runTests), "signOfLife=1"},
|
||||
Command: command,
|
||||
SecurityContext: &v1.SecurityContext{
|
||||
Capabilities: &v1.Capabilities{
|
||||
Add: []v1.Capability{"IPC_LOCK"}},
|
||||
@ -242,13 +286,11 @@ func runCpaSampleCode(ctx context.Context, f *framework.Framework, runTests int,
|
||||
RestartPolicy: v1.RestartPolicyNever,
|
||||
},
|
||||
}
|
||||
|
||||
pod, err := f.ClientSet.CoreV1().Pods(f.Namespace.Name).Create(ctx, podSpec, metav1.CreateOptions{})
|
||||
framework.ExpectNoError(err, "pod Create API error")
|
||||
|
||||
ginkgo.By("waiting the cpa_sample_code pod for the resource" + resourceName.String() + "to finish successfully")
|
||||
|
||||
err = e2epod.WaitForPodSuccessInNamespaceTimeout(ctx, f.ClientSet, pod.ObjectMeta.Name, f.Namespace.Name, 300*time.Second)
|
||||
gomega.Expect(err).To(gomega.BeNil(), utils.GetPodLogs(ctx, f, pod.ObjectMeta.Name, pod.Spec.Containers[0].Name))
|
||||
return pod
|
||||
}
|
||||
|
||||
func injectError(ctx context.Context, f *framework.Framework, resourceName v1.ResourceName) {
|
||||
|
||||
Loading…
Reference in New Issue
Block a user