Re: [dpdk-dev] [v3,4/5] test: add event crypto adapter auto-test

[Jerin Jacob <jerin.jacob@caviumnetworks.com>]

-----Original Message-----
> Date: Sun, 6 May 2018 00:17:09 +0530
> From: Abhinandan Gujjar <abhinandan.gujjar@intel.com>
> To: jerin.jacob@caviumnetworks.com, hemant.agrawal@nxp.com,
>  akhil.goyal@nxp.com, dev@dpdk.org
> CC: narender.vangati@intel.com, abhinandan.gujjar@intel.com,
>  nikhil.rao@intel.com, gage.eads@intel.com
> Subject: [v3,4/5] test: add event crypto adapter auto-test
> X-Mailer: git-send-email 1.9.1
> 
> Signed-off-by: Abhinandan Gujjar <abhinandan.gujjar@intel.com>
> ---
>  MAINTAINERS                           |   1 +
>  test/test/Makefile                    |   1 +
>  test/test/test_event_crypto_adapter.c | 913 ++++++++++++++++++++++++++++++++++
>  3 files changed, 915 insertions(+)
>  create mode 100644 test/test/test_event_crypto_adapter.c
> 
> diff --git a/MAINTAINERS b/MAINTAINERS
> index 991b465..60ebef7 100644
> --- a/MAINTAINERS
> +++ b/MAINTAINERS
> @@ -366,6 +366,7 @@ Eventdev Crypto Adapter API - EXPERIMENTAL
>  M: Abhinandan Gujjar <abhinandan.gujjar@intel.com>
>  T: git://dpdk.org/next/dpdk-next-eventdev
>  F: lib/librte_eventdev/*crypto_adapter*
> +F: test/test/test_event_crypto_adapter.c

Shared(x86_64-native-linuxapp-gcc+shared) build fails due to

test_event_crypto_adapter.o: In function
`test_crypto_adapter_qp_add_del':
test_event_crypto_adapter.c:(.text+0x43): undefined reference to
`rte_event_crypto_adapter_caps_get'
test_event_crypto_adapter.o: In function
`test_crypto_adapter_conf_op_new_mode':
test_event_crypto_adapter.c:(.text+0x16c): undefined reference to
`rte_event_crypto_adapter_caps_get'
test_event_crypto_adapter.o: In function
`test_crypto_adapter_conf_op_forward_mode':
test_event_crypto_adapter.c:(.text+0x138f): undefined reference to
`rte_event_crypto_adapter_caps_get'
test_event_crypto_adapter.o: In function `test_op_new_mode':
test_event_crypto_adapter.c:(.text+0x181c): undefined reference to
`rte_event_crypto_adapter_caps_get'
test_event_crypto_adapter.o: In function
`test_sessionless_with_op_new_mode':
test_event_crypto_adapter.c:(.text+0x2111): undefined reference to
`rte_event_crypto_adapter_caps_get'
test_event_crypto_adapter.o:test_event_crypto_adapter.c:(.text+0x2261):
more undefined references to `rte_event_crypto_adapter_caps_get' follow




>  
>  Raw device API - EXPERIMENTAL
>  M: Shreyansh Jain <shreyansh.jain@nxp.com>
> diff --git a/test/test/Makefile b/test/test/Makefile
> index 2630ab4..3a45ab2 100644
> --- a/test/test/Makefile
> +++ b/test/test/Makefile
> @@ -185,6 +185,7 @@ SRCS-y += test_eventdev.c
>  SRCS-y += test_event_ring.c
>  SRCS-y += test_event_eth_rx_adapter.c
>  SRCS-y += test_event_timer_adapter.c
> +SRCS-y += test_event_crypto_adapter.c
>  endif
>  
>  ifeq ($(CONFIG_RTE_LIBRTE_RAWDEV),y)
> diff --git a/test/test/test_event_crypto_adapter.c b/test/test/test_event_crypto_adapter.c
> new file mode 100644
> index 0000000..099adcb
> --- /dev/null
> +++ b/test/test/test_event_crypto_adapter.c
> @@ -0,0 +1,913 @@
> +static void
> +test_crypto_adapter_stop(void)
> +{
> +	uint32_t evdev_service_id, adapter_service_id;
> +
> +	/* retrieve service ids */
> +	rte_event_dev_service_id_get(evdev, &evdev_service_id);
> +	rte_event_crypto_adapter_service_id_get(
> +			TEST_ADAPTER_ID, &adapter_service_id);
> +
> +	/* stop services */
> +	rte_service_runstate_set(evdev_service_id, 0);
> +	rte_service_runstate_set(adapter_service_id, 0);
> +	rte_service_lcore_stop(slcore_id);
> +	rte_service_lcore_del(slcore_id);

In HW case, These service core wont be there. Right? So I think, you can
check the return value of rte_event_dev_service_id_get() and decide to
invoke rte_service_ runtime operations.


> +	rte_event_crypto_adapter_stop(TEST_ADAPTER_ID);
> +	rte_event_dev_stop(evdev);
> +}
> +/* SPDX-License-Identifier: BSD-3-Clause
> + * Copyright(c) 2018 Intel Corporation
> + */
> +
> +#include <string.h>
> +#include <rte_common.h>
> +#include <rte_mempool.h>
> +#include <rte_mbuf.h>
> +#include <rte_cryptodev.h>
> +#include <rte_eventdev.h>
> +#include <rte_bus_vdev.h>
> +#include <rte_service.h>
> +#include <rte_event_crypto_adapter.h>
> +#include "test.h"
> +
> +#define PKT_TRACE                  0
> +#define NUM                        1
> +#define DEFAULT_NUM_XFORMS        (2)
> +#define NUM_MBUFS                 (8191)
> +#define MBUF_CACHE_SIZE           (256)
> +#define MAXIMUM_IV_LENGTH         (16)
> +#define DEFAULT_NUM_OPS_INFLIGHT  (128)
> +#define TEST_APP_PORT_ID           0
> +#define TEST_APP_EV_QUEUE_ID       0
> +#define TEST_CRYPTO_EV_QUEUE_ID    1
> +#define TEST_ADAPTER_ID            0
> +#define TEST_CDEV_ID               0
> +#define TEST_CDEV_QP_ID            0
> +#define PACKET_LENGTH              64
> +#define NB_TEST_PORTS              1
> +#define NB_TEST_QUEUES             2
> +#define CRYPTODEV_NAME_NULL_PMD    crypto_null
> +
> +#define MBUF_SIZE              (sizeof(struct rte_mbuf) + \
> +				RTE_PKTMBUF_HEADROOM + PACKET_LENGTH)
> +#define IV_OFFSET              (sizeof(struct rte_crypto_op) + \
> +				sizeof(struct rte_crypto_sym_op) + \
> +				DEFAULT_NUM_XFORMS * \
> +				sizeof(struct rte_crypto_sym_xform))
> +
> +
> +static const uint8_t text_64B[] = {
> +	0x05, 0x15, 0x77, 0x32, 0xc9, 0x66, 0x91, 0x50,
> +	0x93, 0x9f, 0xbb, 0x4e, 0x2e, 0x5a, 0x02, 0xd0,
> +	0x2d, 0x9d, 0x31, 0x5d, 0xc8, 0x9e, 0x86, 0x36,
> +	0x54, 0x5c, 0x50, 0xe8, 0x75, 0x54, 0x74, 0x5e,
> +	0xd5, 0xa2, 0x84, 0x21, 0x2d, 0xc5, 0xf8, 0x1c,
> +	0x55, 0x1a, 0xba, 0x91, 0xce, 0xb5, 0xa3, 0x1e,
> +	0x31, 0xbf, 0xe9, 0xa1, 0x97, 0x5c, 0x2b, 0xd6,
> +	0x57, 0xa5, 0x9f, 0xab, 0xbd, 0xb0, 0x9b, 0x9c
> +};
> +
> +struct event_crypto_adapter_test_params {
> +	struct rte_mempool *mbuf_pool;
> +	struct rte_mempool *op_mpool;
> +	struct rte_mempool *session_mpool;
> +	struct rte_cryptodev_config *config;
> +	uint8_t crypto_event_port_id;
> +};
> +
> +struct rte_event response_info = {
> +	.queue_id = TEST_APP_EV_QUEUE_ID,
> +	.sched_type = RTE_SCHED_TYPE_ATOMIC,
> +	.flow_id = 0xAABB,
> +	.sub_event_type = 0,
> +	.event_type = 0,
> +	.priority = 0,
> +	.impl_opaque = 0
> +};
> +
> +struct rte_event_crypto_request request_info = {
> +	.cdev_id = TEST_CDEV_ID,
> +	.queue_pair_id = TEST_CDEV_QP_ID
> +};
> +
> +static struct event_crypto_adapter_test_params params;
> +static uint8_t crypto_adapter_setup_done;
> +static uint32_t slcore_id;
> +static int evdev;
> +
> +static struct rte_mbuf *
> +alloc_fill_mbuf(struct rte_mempool *mpool, const uint8_t *data,
> +		size_t len, uint8_t blocksize)
> +{
> +	struct rte_mbuf *m = rte_pktmbuf_alloc(mpool);
> +	size_t t_len = len - (blocksize ? (len % blocksize) : 0);
> +
> +	if (m) {
> +		char *dst = rte_pktmbuf_append(m, t_len);
> +
> +		if (!dst) {
> +			rte_pktmbuf_free(m);
> +			return NULL;
> +		}
> +
> +		rte_memcpy(dst, (const void *)data, t_len);
> +	}
> +	return m;
> +}
> +
> +static int
> +send_recv_ev(struct rte_event *ev)
> +{
> +	struct rte_crypto_op *op;
> +	struct rte_event recv_ev;
> +	int ret;
> +
> +	ret = rte_event_enqueue_burst(evdev, TEST_APP_PORT_ID, ev, NUM);
> +	TEST_ASSERT_EQUAL(ret, NUM,
> +			  "Failed to send event to crypto adapter\n");
> +
> +	while (rte_event_dequeue_burst(evdev,
> +			TEST_APP_PORT_ID, &recv_ev, NUM, 0) == 0)
> +		rte_pause();
> +
> +	op = recv_ev.event_ptr;
> +#if PKT_TRACE
> +	struct rte_mbuf *m = op->sym->m_src;
> +	rte_pktmbuf_dump(stdout, m, rte_pktmbuf_pkt_len(m));
> +#endif
> +	rte_pktmbuf_free(op->sym->m_src);
> +	rte_crypto_op_free(op);
> +
> +	return TEST_SUCCESS;
> +}
> +
> +static int
> +test_crypto_adapter_stats(void)
> +{
> +	struct rte_event_crypto_adapter_stats stats;
> +
> +	rte_event_crypto_adapter_stats_get(TEST_ADAPTER_ID, &stats);
> +	printf(" +------------------------------------------------------+\n");
> +	printf(" + Crypto adapter stats for instance %u:\n", TEST_ADAPTER_ID);
> +	printf(" + Event port poll count          %lu\n",
> +		stats.event_poll_count);
> +	printf(" + Event dequeue count            %lu\n",
> +		stats.event_deq_count);
> +	printf(" + Cryptodev enqueue count        %lu\n",
> +		stats.crypto_enq_count);
> +	printf(" + Cryptodev enqueue failed count %lu\n",
> +		stats.crypto_enq_fail);
> +	printf(" + Cryptodev dequeue count        %lu\n",
> +		stats.crypto_deq_count);
> +	printf(" + Event enqueue count            %lu\n",
> +		stats.event_enq_count);
> +	printf(" + Event enqueue retry count      %lu\n",
> +		stats.event_enq_retry_count);
> +	printf(" + Event enqueue fail count       %lu\n",
> +		stats.event_enq_fail_count);
> +	printf(" +------------------------------------------------------+\n");
> +
> +	rte_event_crypto_adapter_stats_reset(TEST_ADAPTER_ID);
> +	return TEST_SUCCESS;
> +}
> +
> +static int
> +test_op_forward_mode(uint8_t session_less)
> +{
> +	struct rte_crypto_sym_xform cipher_xform;
> +	struct rte_cryptodev_sym_session *sess;
> +	union rte_event_crypto_metadata m_data;
> +	struct rte_crypto_sym_op *sym_op;
> +	struct rte_crypto_op *op;
> +	struct rte_mbuf *m;
> +	struct rte_event ev;
> +	uint32_t cap;
> +	int ret;
> +
> +	memset(&m_data, 0, sizeof(m_data));
> +
> +	m = alloc_fill_mbuf(params.mbuf_pool, text_64B, PACKET_LENGTH, 0);
> +	TEST_ASSERT_NOT_NULL(m, "Failed to allocate mbuf!\n");
> +#if PKT_TRACE
> +	rte_pktmbuf_dump(stdout, m, rte_pktmbuf_pkt_len(m));
> +#endif
> +	/* Setup Cipher Parameters */
> +	cipher_xform.type = RTE_CRYPTO_SYM_XFORM_CIPHER;
> +	cipher_xform.next = NULL;
> +
> +	cipher_xform.cipher.algo = RTE_CRYPTO_CIPHER_NULL;
> +	cipher_xform.cipher.op = RTE_CRYPTO_CIPHER_OP_ENCRYPT;
> +
> +	op = rte_crypto_op_alloc(params.op_mpool,
> +			RTE_CRYPTO_OP_TYPE_SYMMETRIC);
> +	TEST_ASSERT_NOT_NULL(op,
> +		"Failed to allocate symmetric crypto operation struct\n");
> +
> +	sym_op = op->sym;
> +
> +	if (!session_less) {
> +		sess = rte_cryptodev_sym_session_create(params.session_mpool);
> +		TEST_ASSERT_NOT_NULL(sess, "Session creation failed\n");
> +
> +		/* Create Crypto session*/
> +		rte_cryptodev_sym_session_init(TEST_CDEV_ID, sess,
> +				&cipher_xform, params.session_mpool);
> +
> +		ret = rte_event_crypto_adapter_caps_get(TEST_ADAPTER_ID,
> +							evdev, &cap);
> +		TEST_ASSERT_SUCCESS(ret, "Failed to get adapter capabilities\n");
> +
> +		if (cap & RTE_EVENT_CRYPTO_ADAPTER_CAP_SESSION_PRIVATE_DATA) {
> +			/* Fill in private date information */
> +			rte_memcpy(&m_data.response_info, &response_info,
> +				sizeof(response_info));
> +			rte_memcpy(&m_data.request_info, &request_info,
> +				sizeof(request_info));
> +			rte_cryptodev_sym_session_set_private_data(sess,
> +						&m_data, sizeof(m_data));
> +		}
> +
> +		rte_crypto_op_attach_sym_session(op, sess);
> +	} else {
> +		struct rte_crypto_sym_xform *first_xform;
> +
> +		rte_crypto_op_sym_xforms_alloc(op, NUM);
> +		op->sess_type = RTE_CRYPTO_OP_SESSIONLESS;
> +		first_xform = &cipher_xform;
> +		sym_op->xform = first_xform;
> +		uint32_t len = IV_OFFSET + MAXIMUM_IV_LENGTH +
> +				(sizeof(struct rte_crypto_sym_xform) * 2);
> +		op->private_data_offset = len;
> +		/* Fill in private data information */
> +		rte_memcpy(&m_data.response_info, &response_info,
> +			   sizeof(response_info));
> +		rte_memcpy(&m_data.request_info, &request_info,
> +			   sizeof(request_info));
> +		rte_memcpy((uint8_t *)op + len, &m_data, sizeof(m_data));
> +	}
> +
> +	sym_op->m_src = m;
> +	sym_op->cipher.data.offset = 0;
> +	sym_op->cipher.data.length = PACKET_LENGTH;
> +
> +	/* Fill in event info and update event_ptr with rte_crypto_op */
> +	memset(&ev, 0, sizeof(ev));
> +	ev.queue_id = TEST_CRYPTO_EV_QUEUE_ID;
> +	ev.sched_type = RTE_SCHED_TYPE_ATOMIC;
> +	ev.flow_id = 0xAABB;
> +	ev.event_ptr = op;
> +
> +	ret = send_recv_ev(&ev);
> +	TEST_ASSERT_SUCCESS(ret, "Failed to send/receive event to "
> +				"crypto adapter\n");
> +
> +	test_crypto_adapter_stats();
> +
> +	return TEST_SUCCESS;
> +}
> +
> +static int
> +map_adapter_service_core(void)
> +{
> +	uint32_t adapter_service_id;
> +
> +	TEST_ASSERT_SUCCESS(rte_event_crypto_adapter_service_id_get(
> +			    TEST_ADAPTER_ID, &adapter_service_id),
> +			    "Failed to get event crypto adapter service id");
> +
> +	TEST_ASSERT_SUCCESS(rte_service_map_lcore_set(adapter_service_id,
> +			slcore_id, 1), "Failed to map adapter service");
> +
> +	return TEST_SUCCESS;
> +}
> +
> +static int
> +test_sessionless_with_op_forward_mode(void)
> +{
> +	uint32_t cap;
> +	int ret;
> +
> +	ret = rte_event_crypto_adapter_caps_get(TEST_ADAPTER_ID, evdev, &cap);
> +	TEST_ASSERT_SUCCESS(ret, "Failed to get adapter capabilities\n");
> +
> +	if (!(cap & RTE_EVENT_CRYPTO_ADAPTER_CAP_INTERNAL_PORT_OP_FWD))
> +		map_adapter_service_core();
> +
> +	TEST_ASSERT_SUCCESS(rte_event_crypto_adapter_start(TEST_ADAPTER_ID),
> +				"Failed to start event crypto adapter");
> +
> +	ret = test_op_forward_mode(1);
> +	TEST_ASSERT_SUCCESS(ret, "Sessionless - ENQ-DEQ mode test failed\n");
> +	return TEST_SUCCESS;
> +}
> +
> +static int
> +test_session_with_op_forward_mode(void)
> +{
> +	uint32_t cap;
> +	int ret;
> +
> +	ret = rte_event_crypto_adapter_caps_get(TEST_ADAPTER_ID, evdev, &cap);
> +	TEST_ASSERT_SUCCESS(ret, "Failed to get adapter capabilities\n");
> +
> +	if (!(cap & RTE_EVENT_CRYPTO_ADAPTER_CAP_INTERNAL_PORT_OP_FWD))
> +		map_adapter_service_core();
> +
> +	TEST_ASSERT_SUCCESS(rte_event_crypto_adapter_start(TEST_ADAPTER_ID
> +				), "Failed to start event crypto adapter");
> +
> +	ret = test_op_forward_mode(0);
> +	TEST_ASSERT_SUCCESS(ret, "Session based - ENQ-DEQ mode test failed\n");
> +	return TEST_SUCCESS;
> +}
> +
> +static int
> +send_op_recv_ev(struct rte_crypto_op *op)
> +{
> +	struct rte_crypto_op *recv_op;
> +	struct rte_event ev;
> +	int ret;
> +
> +	ret = rte_cryptodev_enqueue_burst(TEST_CDEV_ID, TEST_CDEV_QP_ID,
> +					  &op, NUM);
> +	TEST_ASSERT_EQUAL(ret, NUM, "Failed to enqueue to cryptodev\n");
> +	memset(&ev, 0, sizeof(ev));
> +
> +	while (rte_event_dequeue_burst(evdev,
> +		TEST_APP_PORT_ID, &ev, NUM, 0) == 0)
> +		rte_pause();
> +
> +	recv_op = ev.event_ptr;
> +#if PKT_TRACE
> +	struct rte_mbuf *m = recv_op->sym->m_src;
> +	rte_pktmbuf_dump(stdout, m, rte_pktmbuf_pkt_len(m));
> +#endif
> +	rte_pktmbuf_free(recv_op->sym->m_src);
> +	rte_crypto_op_free(recv_op);
> +
> +	return TEST_SUCCESS;
> +}
> +
> +static int
> +test_op_new_mode(uint8_t session_less)
> +{
> +	struct rte_crypto_sym_xform cipher_xform;
> +	struct rte_cryptodev_sym_session *sess;
> +	union rte_event_crypto_metadata m_data;
> +	struct rte_crypto_sym_op *sym_op;
> +	struct rte_crypto_op *op;
> +	struct rte_mbuf *m;
> +	uint32_t cap;
> +	int ret;
> +
> +	memset(&m_data, 0, sizeof(m_data));
> +
> +	m = alloc_fill_mbuf(params.mbuf_pool, text_64B, PACKET_LENGTH, 0);
> +	TEST_ASSERT_NOT_NULL(m, "Failed to allocate mbuf!\n");
> +#if PKT_TRACE
> +	rte_pktmbuf_dump(stdout, m, rte_pktmbuf_pkt_len(m));
> +#endif
> +	/* Setup Cipher Parameters */
> +	cipher_xform.type = RTE_CRYPTO_SYM_XFORM_CIPHER;
> +	cipher_xform.next = NULL;
> +
> +	cipher_xform.cipher.algo = RTE_CRYPTO_CIPHER_NULL;
> +	cipher_xform.cipher.op = RTE_CRYPTO_CIPHER_OP_ENCRYPT;
> +
> +	op = rte_crypto_op_alloc(params.op_mpool,
> +			RTE_CRYPTO_OP_TYPE_SYMMETRIC);
> +	TEST_ASSERT_NOT_NULL(op, "Failed to allocate crypto_op!\n");
> +
> +	sym_op = op->sym;
> +
> +	if (!session_less) {
> +		sess = rte_cryptodev_sym_session_create(params.session_mpool);
> +		TEST_ASSERT_NOT_NULL(sess, "Session creation failed\n");
> +
> +		ret = rte_event_crypto_adapter_caps_get(TEST_ADAPTER_ID,
> +							evdev, &cap);
> +		TEST_ASSERT_SUCCESS(ret, "Failed to get adapter capabilities\n");
> +
> +		if (cap & RTE_EVENT_CRYPTO_ADAPTER_CAP_SESSION_PRIVATE_DATA) {
> +			/* Fill in private data information */
> +			rte_memcpy(&m_data.response_info, &response_info,
> +				   sizeof(m_data));
> +			rte_cryptodev_sym_session_set_private_data(sess,
> +						&m_data, sizeof(m_data));
> +		}
> +		rte_cryptodev_sym_session_init(TEST_CDEV_ID, sess,
> +				&cipher_xform, params.session_mpool);
> +		rte_crypto_op_attach_sym_session(op, sess);
> +	} else {
> +		struct rte_crypto_sym_xform *first_xform;
> +
> +		rte_crypto_op_sym_xforms_alloc(op, NUM);
> +		op->sess_type = RTE_CRYPTO_OP_SESSIONLESS;
> +		first_xform = &cipher_xform;
> +		sym_op->xform = first_xform;
> +		uint32_t len = IV_OFFSET + MAXIMUM_IV_LENGTH +
> +				(sizeof(struct rte_crypto_sym_xform) * 2);
> +		op->private_data_offset = len;
> +		/* Fill in private data information */
> +		rte_memcpy(&m_data.response_info, &response_info,
> +			   sizeof(m_data));
> +		rte_memcpy((uint8_t *)op + len, &m_data, sizeof(m_data));
> +	}
> +
> +	sym_op->m_src = m;
> +	sym_op->cipher.data.offset = 0;
> +	sym_op->cipher.data.length = PACKET_LENGTH;
> +
> +	ret = send_op_recv_ev(op);
> +	TEST_ASSERT_SUCCESS(ret, "Failed to enqueue op to cryptodev\n");
> +
> +	test_crypto_adapter_stats();
> +
> +	return TEST_SUCCESS;
> +}
> +
> +static int
> +test_sessionless_with_op_new_mode(void)
> +{
> +	uint32_t cap;
> +	int ret;
> +
> +	ret = rte_event_crypto_adapter_caps_get(TEST_ADAPTER_ID, evdev, &cap);
> +	TEST_ASSERT_SUCCESS(ret, "Failed to get adapter capabilities\n");
> +
> +	if (!(cap & RTE_EVENT_CRYPTO_ADAPTER_CAP_INTERNAL_PORT_OP_FWD) ||
> +	    !(cap & RTE_EVENT_CRYPTO_ADAPTER_CAP_INTERNAL_PORT_OP_NEW))
> +		map_adapter_service_core();
> +
> +	/* start the event crypto adapter */
> +	TEST_ASSERT_SUCCESS(rte_event_crypto_adapter_start(TEST_ADAPTER_ID),
> +				"Failed to start event crypto adapter");
> +
> +	ret = test_op_new_mode(1);
> +	TEST_ASSERT_SUCCESS(ret, "Sessionless - DEQ_ONLY test failed\n");
> +	return TEST_SUCCESS;
> +}
> +
> +static int
> +test_session_with_op_new_mode(void)
> +{
> +	uint32_t cap;
> +	int ret;
> +
> +	ret = rte_event_crypto_adapter_caps_get(TEST_ADAPTER_ID, evdev, &cap);
> +	TEST_ASSERT_SUCCESS(ret, "Failed to get adapter capabilities\n");
> +
> +	if (!(cap & RTE_EVENT_CRYPTO_ADAPTER_CAP_INTERNAL_PORT_OP_FWD) ||
> +	    !(cap & RTE_EVENT_CRYPTO_ADAPTER_CAP_INTERNAL_PORT_OP_NEW))
> +		map_adapter_service_core();
> +
> +	TEST_ASSERT_SUCCESS(rte_event_crypto_adapter_start(TEST_ADAPTER_ID),
> +				"Failed to start event crypto adapter");
> +
> +	ret = test_op_new_mode(0);
> +	TEST_ASSERT_SUCCESS(ret, "Session based - DEQ_ONLY test failed\n");
> +	return TEST_SUCCESS;
> +}
> +
> +static int
> +configure_cryptodev(void)
> +{
> +	struct rte_cryptodev_qp_conf qp_conf;
> +	struct rte_cryptodev_config conf;
> +	struct rte_cryptodev_info info;
> +	unsigned int session_size;
> +	uint8_t nb_devs;
> +	int ret;
> +
> +	params.mbuf_pool = rte_pktmbuf_pool_create(
> +			"CRYPTO_ADAPTER_MBUFPOOL",
> +			NUM_MBUFS, MBUF_CACHE_SIZE, 0, MBUF_SIZE,
> +			rte_socket_id());
> +	if (params.mbuf_pool == NULL) {
> +		RTE_LOG(ERR, USER1, "Can't create CRYPTO_MBUFPOOL\n");
> +		return TEST_FAILED;
> +	}
> +
> +	params.op_mpool = rte_crypto_op_pool_create(
> +			"EVENT_CRYPTO_SYM_OP_POOL",
> +			RTE_CRYPTO_OP_TYPE_SYMMETRIC,
> +			NUM_MBUFS, MBUF_CACHE_SIZE,
> +			DEFAULT_NUM_XFORMS *
> +			sizeof(struct rte_crypto_sym_xform) +
> +			MAXIMUM_IV_LENGTH,
> +			rte_socket_id());
> +	if (params.op_mpool == NULL) {
> +		RTE_LOG(ERR, USER1, "Can't create CRYPTO_OP_POOL\n");
> +		return TEST_FAILED;
> +	}
> +
> +	/* Create a NULL crypto device */
> +	nb_devs = rte_cryptodev_device_count_by_driver(
> +			rte_cryptodev_driver_id_get(
> +			RTE_STR(CRYPTODEV_NAME_NULL_PMD)));
> +	if (!nb_devs) {
> +		ret = rte_vdev_init(
> +			RTE_STR(CRYPTODEV_NAME_NULL_PMD), NULL);
> +
> +		TEST_ASSERT(ret == 0, "Failed to create pmd:%s instance\n",
> +			    RTE_STR(CRYPTODEV_NAME_NULL_PMD));
> +	}
> +
> +	nb_devs = rte_cryptodev_count();
> +	if (!nb_devs) {
> +		RTE_LOG(ERR, USER1, "No crypto devices found?\n");
> +		return TEST_FAILED;
> +	}
> +
> +	/*
> +	 * Create mempool with maximum number of sessions * 2,
> +	 * to include the session headers & private data
> +	 */
> +	session_size = rte_cryptodev_get_private_session_size(TEST_CDEV_ID);
> +	session_size += sizeof(union rte_event_crypto_metadata);
> +
> +	params.session_mpool = rte_mempool_create(
> +				"CRYPTO_ADAPTER_SESSION_MP",
> +				info.sym.max_nb_sessions * 2,
> +				session_size,
> +				0, 0, NULL, NULL, NULL,
> +				NULL, SOCKET_ID_ANY,
> +				0);
> +
> +	TEST_ASSERT_NOT_NULL(params.session_mpool,
> +			"session mempool allocation failed\n");
> +
> +	rte_cryptodev_info_get(TEST_CDEV_ID, &info);
> +	conf.nb_queue_pairs = info.max_nb_queue_pairs;
> +	conf.socket_id = SOCKET_ID_ANY;
> +
> +	TEST_ASSERT_SUCCESS(rte_cryptodev_configure(TEST_CDEV_ID,
> +			&conf),
> +			"Failed to configure cryptodev %u with %u qps\n",
> +			TEST_CDEV_ID, conf.nb_queue_pairs);
> +
> +	qp_conf.nb_descriptors = DEFAULT_NUM_OPS_INFLIGHT;
> +
> +	TEST_ASSERT_SUCCESS(rte_cryptodev_queue_pair_setup(
> +			TEST_CDEV_ID, TEST_CDEV_QP_ID, &qp_conf,
> +			rte_cryptodev_socket_id(TEST_CDEV_ID),
> +			params.session_mpool),
> +			"Failed to setup queue pair %u on cryptodev %u\n",
> +			TEST_CDEV_QP_ID, TEST_CDEV_ID);
> +
> +	return TEST_SUCCESS;
> +}
> +
> +static inline void
> +evdev_set_conf_values(struct rte_event_dev_config *dev_conf,
> +			struct rte_event_dev_info *info)
> +{
> +	memset(dev_conf, 0, sizeof(struct rte_event_dev_config));
> +	dev_conf->dequeue_timeout_ns = info->min_dequeue_timeout_ns;
> +	dev_conf->nb_event_ports = NB_TEST_PORTS;
> +	dev_conf->nb_event_queues = NB_TEST_QUEUES;
> +	dev_conf->nb_event_queue_flows = info->max_event_queue_flows;
> +	dev_conf->nb_event_port_dequeue_depth =
> +			info->max_event_port_dequeue_depth;
> +	dev_conf->nb_event_port_enqueue_depth =
> +			info->max_event_port_enqueue_depth;
> +	dev_conf->nb_event_port_enqueue_depth =
> +			info->max_event_port_enqueue_depth;
> +	dev_conf->nb_events_limit =
> +			info->max_num_events;
> +}
> +
> +static int
> +configure_eventdev(void)
> +{
> +	const char *eventdev_name = "event_sw0";
> +	struct rte_event_queue_conf queue_conf;
> +	struct rte_event_dev_config devconf;
> +	struct rte_event_dev_info info;
> +	uint32_t queue_count;
> +	uint32_t port_count;
> +	int ret;
> +	uint8_t qid;
> +
> +	evdev = rte_event_dev_get_dev_id(eventdev_name);
> +	if (evdev < 0) {
> +		if (rte_vdev_init(eventdev_name, NULL) < 0) {
> +			RTE_LOG(DEBUG, USER1, "Error creating eventdev\n");
> +			return TEST_FAILED;
> +		}
> +		evdev = rte_event_dev_get_dev_id(eventdev_name);
> +		if (evdev < 0) {
> +			RTE_LOG(DEBUG, USER1, "Error finding eventdev!\n");
> +			return TEST_FAILED;
> +		}
> +	}
> +
> +	ret = rte_event_dev_info_get(evdev, &info);
> +	TEST_ASSERT_SUCCESS(ret, "Failed to get event dev info\n");
> +
> +	evdev_set_conf_values(&devconf, &info);
> +
> +	ret = rte_event_dev_configure(evdev, &devconf);
> +	TEST_ASSERT_SUCCESS(ret, "Failed to configure eventdev\n");
> +
> +	/* Set up event queue */
> +	ret = rte_event_dev_attr_get(evdev, RTE_EVENT_DEV_ATTR_QUEUE_COUNT,
> +					&queue_count);
> +	TEST_ASSERT_SUCCESS(ret, "Queue count get failed\n");
> +	TEST_ASSERT_EQUAL(queue_count, 2, "Unexpected queue count\n");
> +
> +	qid = TEST_APP_EV_QUEUE_ID;
> +	ret = rte_event_queue_setup(evdev, qid, NULL);
> +	TEST_ASSERT_SUCCESS(ret, "Failed to setup queue=%d\n", qid);
> +
> +	queue_conf.nb_atomic_flows = info.max_event_queue_flows;
> +	queue_conf.nb_atomic_order_sequences = 32;
> +	queue_conf.schedule_type = RTE_SCHED_TYPE_ATOMIC;
> +	queue_conf.priority = RTE_EVENT_DEV_PRIORITY_HIGHEST;
> +	queue_conf.event_queue_cfg = RTE_EVENT_QUEUE_CFG_SINGLE_LINK;
> +
> +	qid = TEST_CRYPTO_EV_QUEUE_ID;
> +	ret = rte_event_queue_setup(evdev, qid, &queue_conf);
> +	TEST_ASSERT_SUCCESS(ret, "Failed to setup queue=%u\n", qid);
> +
> +	/* Set up event port */
> +	ret = rte_event_dev_attr_get(evdev, RTE_EVENT_DEV_ATTR_PORT_COUNT,
> +					&port_count);
> +	TEST_ASSERT_SUCCESS(ret, "Port count get failed\n");
> +	TEST_ASSERT_EQUAL(port_count, 1, "Unexpected port count\n");
> +
> +	ret = rte_event_port_setup(evdev, TEST_APP_PORT_ID, NULL);
> +	TEST_ASSERT_SUCCESS(ret, "Failed to setup port=%d\n",
> +			    TEST_APP_PORT_ID);
> +
> +	qid = TEST_APP_EV_QUEUE_ID;
> +	ret = rte_event_port_link(evdev, TEST_APP_PORT_ID, &qid, NULL, 1);
> +	TEST_ASSERT(ret >= 0, "Failed to link queue port=%d\n",
> +		    TEST_APP_PORT_ID);
> +
> +	return TEST_SUCCESS;
> +}
> +
> +static void
> +test_crypto_adapter_free(void)
> +{
> +	rte_event_crypto_adapter_free(TEST_ADAPTER_ID);
> +}
> +
> +static int
> +test_crypto_adapter_create(void)
> +{
> +	struct rte_event_port_conf conf = {
> +		.dequeue_depth = 8,
> +		.enqueue_depth = 8,
> +		.new_event_threshold = 1200,
> +	};
> +	int ret;
> +
> +	/* Create adapter with default port creation callback */
> +	ret = rte_event_crypto_adapter_create(TEST_ADAPTER_ID,
> +					      TEST_CDEV_ID,
> +					      &conf, 0);
> +	TEST_ASSERT_SUCCESS(ret, "Failed to create event crypto adapter\n");
> +
> +	return TEST_SUCCESS;
> +}
> +
> +static int
> +test_crypto_adapter_qp_add_del(void)
> +{
> +	uint32_t cap;
> +	int ret;
> +
> +	ret = rte_event_crypto_adapter_caps_get(TEST_ADAPTER_ID, evdev, &cap);
> +	TEST_ASSERT_SUCCESS(ret, "Failed to get adapter capabilities\n");
> +
> +	if (cap & RTE_EVENT_CRYPTO_ADAPTER_CAP_INTERNAL_PORT_QP_EV_BIND) {
> +		ret = rte_event_crypto_adapter_queue_pair_add(TEST_ADAPTER_ID,
> +				TEST_CDEV_ID, TEST_CDEV_QP_ID, &response_info);
> +	} else
> +		ret = rte_event_crypto_adapter_queue_pair_add(TEST_ADAPTER_ID,
> +					TEST_CDEV_ID, TEST_CDEV_QP_ID, NULL);
> +
> +	TEST_ASSERT_SUCCESS(ret, "Failed to create add queue pair\n");
> +
> +	ret = rte_event_crypto_adapter_queue_pair_del(TEST_ADAPTER_ID,
> +					TEST_CDEV_ID, TEST_CDEV_QP_ID);
> +	TEST_ASSERT_SUCCESS(ret, "Failed to delete add queue pair\n");
> +
> +	return TEST_SUCCESS;
> +}
> +
> +static int
> +configure_event_crypto_adapter(enum rte_event_crypto_adapter_mode mode)
> +{
> +	struct rte_event_port_conf conf = {
> +		.dequeue_depth = 8,
> +		.enqueue_depth = 8,
> +		.new_event_threshold = 1200,
> +	};
> +
> +	uint32_t cap;
> +	int ret;
> +
> +	/* Create adapter with default port creation callback */
> +	ret = rte_event_crypto_adapter_create(TEST_ADAPTER_ID,
> +					      TEST_CDEV_ID,
> +					      &conf, mode);
> +	TEST_ASSERT_SUCCESS(ret, "Failed to create event crypto adapter\n");
> +
> +	ret = rte_event_crypto_adapter_caps_get(TEST_ADAPTER_ID, evdev, &cap);
> +	TEST_ASSERT_SUCCESS(ret, "Failed to get adapter capabilities\n");
> +
> +	if (cap & RTE_EVENT_CRYPTO_ADAPTER_CAP_INTERNAL_PORT_QP_EV_BIND) {
> +		ret = rte_event_crypto_adapter_queue_pair_add(TEST_ADAPTER_ID,
> +				TEST_CDEV_ID, TEST_CDEV_QP_ID, &response_info);
> +	} else
> +		ret = rte_event_crypto_adapter_queue_pair_add(TEST_ADAPTER_ID,
> +				TEST_CDEV_ID, TEST_CDEV_QP_ID, NULL);
> +
> +	TEST_ASSERT_SUCCESS(ret, "Failed to add queue pair\n");
> +
> +	ret = rte_event_crypto_adapter_event_port_get(TEST_ADAPTER_ID,
> +				&params.crypto_event_port_id);
> +	TEST_ASSERT_SUCCESS(ret, "Failed to get event port\n");
> +
> +	return TEST_SUCCESS;
> +}
> +
> +