[Accel-config] [PATCH RESEND v1 05/14] accel-config/test: Add test code of operation Zdecompress32

--===============6984770943916414013==
Content-Type: text/plain; charset="utf-8"
MIME-Version: 1.0
Content-Transfer-Encoding: quoted-printable

Add test code of operation Zdecompress32

Signed-off-by: Li Zhang <li4.zhang(a)intel.com>
---
 test/iaa.c      | 126 ++++++++++++++++++++++++++++++++++++++++++++++++
 test/iaa.h      |   3 ++
 test/iaa_prep.c |  11 +++++
 test/iaa_test.c |  11 +++++
 4 files changed, 151 insertions(+)

diff --git a/test/iaa.c b/test/iaa.c
index f3d45f5..524446a 100644
--- a/test/iaa.c
+++ b/test/iaa.c
@@ -121,6 +121,38 @@ static int init_zcompress32(struct task *tsk, int tfla=
gs, int opcode, unsigned l
 	return ACCTEST_STATUS_OK;
 }
 =

+static int init_zdecompress32(struct task *tsk, int tflags, int opcode, un=
signed long input_size)
+{
+	tsk->pattern =3D 0x98765432abcdef01;
+	tsk->opcode =3D opcode;
+	tsk->test_flags =3D tflags;
+
+	tsk->input =3D aligned_alloc(ADDR_ALIGNMENT, input_size);
+	if (!tsk->input)
+		return -ENOMEM;
+	iaa_zcompress16_randomize_input(tsk->input, tsk->pattern, input_size);
+
+	tsk->src1 =3D aligned_alloc(ADDR_ALIGNMENT, input_size * 2);
+	if (!tsk->src1)
+		return -ENOMEM;
+	memset_pattern(tsk->src1, 0, input_size * 2);
+	tsk->xfer_size =3D iaa_do_zcompress32(tsk->src1, tsk->input, input_size);
+
+	tsk->dst1 =3D aligned_alloc(ADDR_ALIGNMENT, input_size);
+	if (!tsk->dst1)
+		return -ENOMEM;
+	memset_pattern(tsk->dst1, 0, input_size);
+
+	tsk->output =3D aligned_alloc(ADDR_ALIGNMENT, input_size);
+	if (!tsk->output)
+		return -ENOMEM;
+	memset_pattern(tsk->output, 0, input_size);
+
+	tsk->iaa_max_dst_size =3D input_size;
+
+	return ACCTEST_STATUS_OK;
+}
+
 int init_task(struct task *tsk, int tflags, int opcode, unsigned long src1=
_xfer_size)
 {
 	int rc =3D 0;
@@ -141,6 +173,9 @@ int init_task(struct task *tsk, int tflags, int opcode,=
 unsigned long src1_xfer_
 	case IAX_OPCODE_ZCOMPRESS32:
 		rc =3D init_zcompress32(tsk, tflags, opcode, src1_xfer_size);
 		break;
+	case IAX_OPCODE_ZDECOMPRESS32:
+		rc =3D init_zdecompress32(tsk, tflags, opcode, src1_xfer_size);
+		break;
 	}
 =

 	if (rc !=3D ACCTEST_STATUS_OK) {
@@ -386,6 +421,53 @@ int iaa_zcompress32_multi_task_nodes(struct acctest_co=
ntext *ctx)
 	return ret;
 }
 =

+static int iaa_wait_zdecompress32(struct acctest_context *ctx, struct task=
 *tsk)
+{
+	struct completion_record *comp =3D tsk->comp;
+	int rc;
+
+	rc =3D acctest_wait_on_desc_timeout(comp, ctx, ms_timeout);
+	if (rc < 0) {
+		err("zdecompress32 desc timeout\n");
+		return ACCTEST_STATUS_TIMEOUT;
+	}
+
+	return ACCTEST_STATUS_OK;
+}
+
+int iaa_zdecompress32_multi_task_nodes(struct acctest_context *ctx)
+{
+	struct task_node *tsk_node =3D ctx->multi_task_node;
+	int ret =3D ACCTEST_STATUS_OK;
+
+	while (tsk_node) {
+		tsk_node->tsk->dflags |=3D (IDXD_OP_FLAG_CRAV | IDXD_OP_FLAG_RCR);
+		if ((tsk_node->tsk->test_flags & TEST_FLAGS_BOF) && ctx->bof)
+			tsk_node->tsk->dflags |=3D IDXD_OP_FLAG_BOF;
+
+		iaa_prep_zdecompress32(tsk_node->tsk);
+		tsk_node =3D tsk_node->next;
+	}
+
+	info("Submitted all zdecompress32 jobs\n");
+	tsk_node =3D ctx->multi_task_node;
+	while (tsk_node) {
+		acctest_desc_submit(ctx, tsk_node->tsk->desc);
+		tsk_node =3D tsk_node->next;
+	}
+
+	tsk_node =3D ctx->multi_task_node;
+	while (tsk_node) {
+		ret =3D iaa_wait_zdecompress32(ctx, tsk_node->tsk);
+		if (ret !=3D ACCTEST_STATUS_OK)
+			info("Desc: %p failed with ret: %d\n",
+			     tsk_node->tsk->desc, tsk_node->tsk->comp->status);
+		tsk_node =3D tsk_node->next;
+	}
+
+	return ret;
+}
+
 /* mismatch_expected: expect mismatched buffer with success status 0x1 */
 int iaa_task_result_verify(struct task *tsk, int mismatch_expected)
 {
@@ -409,6 +491,9 @@ int iaa_task_result_verify(struct task *tsk, int mismat=
ch_expected)
 	case IAX_OPCODE_ZCOMPRESS32:
 		ret =3D task_result_verify_zcompress32(tsk, mismatch_expected);
 		break;
+	case IAX_OPCODE_ZDECOMPRESS32:
+		ret =3D task_result_verify_zdecompress32(tsk, mismatch_expected);
+		break;
 	}
 =

 	if (ret =3D=3D ACCTEST_STATUS_OK)
@@ -596,3 +681,44 @@ int task_result_verify_zcompress32(struct task *tsk, i=
nt mismatch_expected)
 =

 	return -ENXIO;
 }
+
+int task_result_verify_zdecompress32(struct task *tsk, int mismatch_expect=
ed)
+{
+	int i;
+	int rc;
+	int expected_len;
+
+	if (mismatch_expected)
+		warn("invalid arg mismatch_expected for %d\n", tsk->opcode);
+
+	expected_len =3D iaa_do_zdecompress32(tsk->output, tsk->src1, tsk->xfer_s=
ize);
+	rc =3D memcmp(tsk->dst1, tsk->output, expected_len);
+
+	if (!mismatch_expected) {
+		if (expected_len - tsk->comp->iax_output_size) {
+			err("zdecompress32 mismatch, exp len %d, act len %d\n",
+			    expected_len, tsk->comp->iax_output_size);
+
+			return -ENXIO;
+		}
+		if (rc) {
+			err("zdecompress32 mismatch, memcmp rc %d\n", rc);
+			for (i =3D 0; i < (expected_len / 4); i++) {
+				printf("Exp[%d]=3D0x%08X, Act[%d]=3D0x%08X\n",
+				       i, ((uint32_t *)tsk->output)[i],
+				       i, ((uint32_t *)tsk->dst1)[i]);
+			}
+
+			return -ENXIO;
+		}
+		return ACCTEST_STATUS_OK;
+	}
+
+	/* mismatch_expected */
+	if (rc) {
+		info("expected mismatch\n");
+		return ACCTEST_STATUS_OK;
+	}
+
+	return -ENXIO;
+}
diff --git a/test/iaa.h b/test/iaa.h
index 9746466..2a14781 100644
--- a/test/iaa.h
+++ b/test/iaa.h
@@ -14,11 +14,13 @@ int iaa_crc64_multi_task_nodes(struct acctest_context *=
ctx);
 int iaa_zcompress16_multi_task_nodes(struct acctest_context *ctx);
 int iaa_zdecompress16_multi_task_nodes(struct acctest_context *ctx);
 int iaa_zcompress32_multi_task_nodes(struct acctest_context *ctx);
+int iaa_zdecompress32_multi_task_nodes(struct acctest_context *ctx);
 void iaa_prep_noop(struct task *tsk);
 void iaa_prep_crc64(struct task *tsk);
 void iaa_prep_zcompress16(struct task *tsk);
 void iaa_prep_zdecompress16(struct task *tsk);
 void iaa_prep_zcompress32(struct task *tsk);
+void iaa_prep_zdecompress32(struct task *tsk);
 =

 int iaa_task_result_verify(struct task *tsk, int mismatch_expected);
 int iaa_task_result_verify_task_nodes(struct acctest_context *ctx, int mis=
match_expected);
@@ -26,5 +28,6 @@ int task_result_verify_crc64(struct task *tsk, int mismat=
ch_expected);
 int task_result_verify_zcompress16(struct task *tsk, int mismatch_expected=
);
 int task_result_verify_zdecompress16(struct task *tsk, int mismatch_expect=
ed);
 int task_result_verify_zcompress32(struct task *tsk, int mismatch_expected=
);
+int task_result_verify_zdecompress32(struct task *tsk, int mismatch_expect=
ed);
 =

 #endif
diff --git a/test/iaa_prep.c b/test/iaa_prep.c
index 7aff1e2..78668ac 100644
--- a/test/iaa_prep.c
+++ b/test/iaa_prep.c
@@ -64,3 +64,14 @@ void iaa_prep_zcompress32(struct task *tsk)
 	tsk->desc->iax_max_dst_size =3D tsk->iaa_max_dst_size;
 	tsk->comp->status =3D 0;
 }
+
+void iaa_prep_zdecompress32(struct task *tsk)
+{
+	info("preparing descriptor for zdecompress32\n");
+
+	acctest_prep_desc_common(tsk->desc, tsk->opcode, (uint64_t)(tsk->dst1),
+				 (uint64_t)(tsk->src1), tsk->xfer_size, tsk->dflags);
+	tsk->desc->completion_addr =3D (uint64_t)(tsk->comp);
+	tsk->desc->iax_max_dst_size =3D tsk->iaa_max_dst_size;
+	tsk->comp->status =3D 0;
+}
diff --git a/test/iaa_test.c b/test/iaa_test.c
index 7141979..ba3d412 100644
--- a/test/iaa_test.c
+++ b/test/iaa_test.c
@@ -194,6 +194,16 @@ static int test_zcompress(struct acctest_context *ctx,=
 size_t buf_size,
 			if (rc !=3D ACCTEST_STATUS_OK)
 				return rc;
 =

+			/* Verification of all the nodes*/
+			rc =3D iaa_task_result_verify_task_nodes(ctx, 0);
+			if (rc !=3D ACCTEST_STATUS_OK)
+				return rc;
+			break;
+		case IAX_OPCODE_ZDECOMPRESS32:
+			rc =3D iaa_zdecompress32_multi_task_nodes(ctx);
+			if (rc !=3D ACCTEST_STATUS_OK)
+				return rc;
+
 			/* Verification of all the nodes*/
 			rc =3D iaa_task_result_verify_task_nodes(ctx, 0);
 			if (rc !=3D ACCTEST_STATUS_OK)
@@ -299,6 +309,7 @@ int main(int argc, char *argv[])
 	case IAX_OPCODE_ZCOMPRESS16:
 	case IAX_OPCODE_ZDECOMPRESS16:
 	case IAX_OPCODE_ZCOMPRESS32:
+	case IAX_OPCODE_ZDECOMPRESS32:
 		rc =3D test_zcompress(iaa, buf_size, tflags, opcode, num_desc);
 		if (rc !=3D ACCTEST_STATUS_OK)
 			goto error;
-- =

2.25.1

--===============6984770943916414013==--