Function test_deflate_comp_decomp

dpdk/app/test/test_compressdev.c:1985–2165

 */

static int
test_deflate_comp_decomp(const struct interim_data_params *int_data,
		const struct test_data_params *test_data)
{
	unsigned int num_bufs = int_data->num_bufs;
	unsigned int out_of_space = test_data->out_of_space;

	void *stream = NULL;
	char *all_decomp_data = NULL;
	unsigned int decomp_produced_data_size = 0;

	int ret_status = -1;
	int ret;
	struct rte_mbuf *uncomp_bufs[num_bufs];
	struct rte_mbuf *comp_bufs[num_bufs];
	struct rte_comp_op *ops[num_bufs];
	struct rte_comp_op *ops_processed[num_bufs];
	void *priv_xforms[num_bufs];
	unsigned int i;

	uint64_t compress_checksum[num_bufs];
	uint32_t compressed_data_size[num_bufs];
	char *contig_buf = NULL;

	struct rte_mbuf_ext_shared_info compbuf_info;
	struct rte_mbuf_ext_shared_info decompbuf_info;

	const struct rte_compressdev_capabilities *capa;

	/* Compressing with CompressDev */
	unsigned int zlib_compress =
			(test_data->zlib_dir == ZLIB_ALL ||
			test_data->zlib_dir == ZLIB_COMPRESS);
	unsigned int zlib_decompress =
			(test_data->zlib_dir == ZLIB_ALL ||
			test_data->zlib_dir == ZLIB_DECOMPRESS);

	struct test_private_arrays test_priv_data;

	test_priv_data.uncomp_bufs = uncomp_bufs;
	test_priv_data.comp_bufs = comp_bufs;
	test_priv_data.ops = ops;
	test_priv_data.ops_processed = ops_processed;
	test_priv_data.priv_xforms = priv_xforms;
	test_priv_data.compress_checksum = compress_checksum;
	test_priv_data.compressed_data_size = compressed_data_size;

	test_priv_data.stream = &stream;
	test_priv_data.all_decomp_data = &all_decomp_data;
	test_priv_data.decomp_produced_data_size = &decomp_produced_data_size;

	test_priv_data.num_priv_xforms = 0; /* it's used for decompression only */

	capa = rte_compressdev_capability_get(0, RTE_COMP_ALGO_DEFLATE);
	if (capa == NULL) {
		RTE_LOG(ERR, USER1,
			"Compress device does not support DEFLATE\n");
		return -1;