path: root/test/validation/api/ipsec/ipsec.c

/* Copyright (c) 2017-2018, Linaro Limited
 * Copyright (c) 2018-2022, Nokia
 * Copyright (c) 2020-2021, Marvell
 * All rights reserved.
 *
 * SPDX-License-Identifier:	 BSD-3-Clause
 */

#include <odp_api.h>
#include <odp_cunit_common.h>
#include <unistd.h>
#include <odp/helper/odph_api.h>

#include "ipsec.h"

#include "test_vectors.h"
#include "reass_test_vectors.h"

struct suite_context_s suite_context;
static odp_ipsec_capability_t capa;

#define PKT_POOL_NUM  64
#define EVENT_WAIT_TIME ODP_TIME_SEC_IN_NS

#define PACKET_USER_PTR	((void *)0x1212fefe)
#define IPSEC_SA_CTX	((void *)0xfefefafa)

static odp_pktio_t pktio_create(odp_pool_t pool)
{
	odp_pktio_t pktio;
	odp_pktio_param_t pktio_param;
	odp_pktin_queue_param_t pktin_param;
	odp_pktio_capability_t capa;

	int ret;

	if (pool == ODP_POOL_INVALID)
		return ODP_PKTIO_INVALID;

	odp_pktio_param_init(&pktio_param);
	pktio_param.in_mode = ODP_PKTIN_MODE_QUEUE;

	pktio = odp_pktio_open("loop", pool, &pktio_param);
	if (pktio == ODP_PKTIO_INVALID) {
		ret = odp_pool_destroy(pool);
		if (ret)
			fprintf(stderr, "unable to destroy pool.\n");
		return ODP_PKTIO_INVALID;
	}

	if (odp_pktio_capability(pktio, &capa)) {
		fprintf(stderr, "pktio capabilities failed.\n");
		return ODP_PKTIO_INVALID;
	}

	odp_pktin_queue_param_init(&pktin_param);
	pktin_param.queue_param.sched.sync = ODP_SCHED_SYNC_ATOMIC;

	if (odp_pktin_queue_config(pktio, &pktin_param)) {
		fprintf(stderr, "pktin queue config failed.\n");
		return ODP_PKTIO_INVALID;
	}

	if (odp_pktout_queue_config(pktio, NULL)) {
		fprintf(stderr, "pktout queue config failed.\n");
		return ODP_PKTIO_INVALID;
	}

	return pktio;
}

static int pktio_start(odp_pktio_t pktio, odp_bool_t in, odp_bool_t out)
{
	odp_pktio_capability_t capa;
	odp_pktio_config_t config;

	if (ODP_PKTIO_INVALID == pktio)
		return -1;

	if (odp_pktio_capability(pktio, &capa))
		return -1;
	/* If inline is not supported, return here. Tests will be marked as
	 * inactive when testing for IPsec capabilities. */
	if (in && !capa.config.inbound_ipsec)
		return 0;
	if (out && !capa.config.outbound_ipsec)
		return 0;

	odp_pktio_config_init(&config);
	config.parser.layer = ODP_PROTO_LAYER_ALL;
	config.inbound_ipsec = in;
	config.outbound_ipsec = out;

	if (odp_pktio_config(pktio, &config))
		return -1;
	if (odp_pktio_start(pktio))
		return -1;

	suite_context.pktio = pktio;

	return 1;
}

static odp_event_t sched_queue_deq(uint64_t wait_ns)
{
	uint64_t wait = odp_schedule_wait_time(wait_ns);

	return odp_schedule(NULL, wait);
}

static odp_event_t plain_queue_deq(odp_queue_t queue, uint64_t wait_ns)
{
	odp_time_t cur, wait, next;
	odp_event_t event;

	wait = odp_time_local_from_ns(wait_ns);
	next = odp_time_sum(odp_time_local(), wait);

	do {
		event = odp_queue_deq(queue);
		cur = odp_time_local();
	} while (event == ODP_EVENT_INVALID && odp_time_cmp(next, cur) >= 0);

	return event;
}

static odp_event_t recv_event(odp_queue_t queue, uint64_t wait_ns)
{
	odp_event_t event;

	if (odp_queue_type(queue) == ODP_QUEUE_TYPE_PLAIN)
		event = plain_queue_deq(queue, wait_ns);
	else
		event = sched_queue_deq(wait_ns);

	return event;
}

static void pktio_stop(odp_pktio_t pktio)
{
	odp_queue_t queue = ODP_QUEUE_INVALID;

	odp_pktin_event_queue(pktio, &queue, 1);

	if (odp_pktio_stop(pktio))
		fprintf(stderr, "IPsec pktio stop failed.\n");

	while (1) {
		odp_event_t ev = recv_event(queue, 0);

		if (ev != ODP_EVENT_INVALID)
			odp_event_free(ev);
		else
			break;
	}
}

int ipsec_check(odp_bool_t ah,
		odp_cipher_alg_t cipher,
		uint32_t cipher_bits,
		odp_auth_alg_t auth,
		uint32_t auth_bits)
{
	if ((ODP_IPSEC_OP_MODE_SYNC == suite_context.inbound_op_mode &&
	     ODP_SUPPORT_NO == capa.op_mode_sync) ||
	    (ODP_IPSEC_OP_MODE_SYNC == suite_context.outbound_op_mode &&
	     ODP_SUPPORT_NO == capa.op_mode_sync) ||
	    (ODP_IPSEC_OP_MODE_ASYNC == suite_context.inbound_op_mode &&
	     ODP_SUPPORT_NO == capa.op_mode_async) ||
	    (ODP_IPSEC_OP_MODE_ASYNC == suite_context.outbound_op_mode &&
	     ODP_SUPPORT_NO == capa.op_mode_async) ||
	    (ODP_IPSEC_OP_MODE_INLINE == suite_context.inbound_op_mode &&
	     ODP_SUPPORT_NO == capa.op_mode_inline_in) ||
	    (ODP_IPSEC_OP_MODE_INLINE == suite_context.outbound_op_mode &&
	     ODP_SUPPORT_NO == capa.op_mode_inline_out))
		return ODP_TEST_INACTIVE;

	if (!(ODP_IPSEC_OP_MODE_SYNC == suite_context.inbound_op_mode &&
	      ODP_IPSEC_OP_MODE_SYNC == suite_context.outbound_op_mode) &&
	    ODP_QUEUE_INVALID != suite_context.queue) {
		if (suite_context.q_type == ODP_QUEUE_TYPE_PLAIN &&
		    !capa.queue_type_plain)
			return ODP_TEST_INACTIVE;
		if (suite_context.q_type == ODP_QUEUE_TYPE_SCHED &&
		    !capa.queue_type_sched)
			return ODP_TEST_INACTIVE;
	}

	/* suite_context.pktio is set to ODP_PKTIO_INVALID in ipsec_suite_init()
	 * if the pktio device doesn't support inline IPsec processing. */
	if (suite_context.pktio == ODP_PKTIO_INVALID &&
	    (ODP_IPSEC_OP_MODE_INLINE == suite_context.inbound_op_mode ||
	     ODP_IPSEC_OP_MODE_INLINE == suite_context.outbound_op_mode))
		return ODP_TEST_INACTIVE;

	if (ah && (ODP_SUPPORT_NO == capa.proto_ah))
		return ODP_TEST_INACTIVE;

	if (odph_ipsec_alg_check(capa, cipher, cipher_bits / 8, auth,
				 auth_bits / 8) < 0)
		return ODP_TEST_INACTIVE;

	return ODP_TEST_ACTIVE;
}

int ipsec_check_ah_sha256(void)
{
	return ipsec_check_ah(ODP_AUTH_ALG_SHA256_HMAC, 256);
}

int ipsec_check_esp_null_sha256(void)
{
	return  ipsec_check_esp(ODP_CIPHER_ALG_NULL, 0,
				ODP_AUTH_ALG_SHA256_HMAC, 256);
}

int ipsec_check_esp_aes_cbc_128_null(void)
{
	return  ipsec_check_esp(ODP_CIPHER_ALG_AES_CBC, 128,
				ODP_AUTH_ALG_NULL, 0);
}

int ipsec_check_esp_aes_cbc_128_sha1(void)
{
	return  ipsec_check_esp(ODP_CIPHER_ALG_AES_CBC, 128,
				ODP_AUTH_ALG_SHA1_HMAC, 160);
}

int ipsec_check_esp_aes_cbc_128_sha256(void)
{
	return  ipsec_check_esp(ODP_CIPHER_ALG_AES_CBC, 128,
				ODP_AUTH_ALG_SHA256_HMAC, 256);
}

int ipsec_check_esp_aes_cbc_128_sha384(void)
{
	return  ipsec_check_esp(ODP_CIPHER_ALG_AES_CBC, 128,
				ODP_AUTH_ALG_SHA384_HMAC, 384);
}

int ipsec_check_esp_aes_cbc_128_sha512(void)
{
	return  ipsec_check_esp(ODP_CIPHER_ALG_AES_CBC, 128,
				ODP_AUTH_ALG_SHA512_HMAC, 512);
}

int ipsec_check_esp_aes_ctr_128_null(void)
{
	return  ipsec_check_esp(ODP_CIPHER_ALG_AES_CTR, 128,
				ODP_AUTH_ALG_NULL, 0);
}

int ipsec_check_esp_aes_gcm_128(void)
{
	return  ipsec_check_esp(ODP_CIPHER_ALG_AES_GCM, 128,
				ODP_AUTH_ALG_AES_GCM, 0);
}

int ipsec_check_esp_aes_gcm_256(void)
{
	return  ipsec_check_esp(ODP_CIPHER_ALG_AES_GCM, 256,
				ODP_AUTH_ALG_AES_GCM, 0);
}

int ipsec_check_ah_aes_gmac_128(void)
{
	return  ipsec_check_ah(ODP_AUTH_ALG_AES_GMAC, 128);
}

int ipsec_check_esp_null_aes_gmac_128(void)
{
	return  ipsec_check_esp(ODP_CIPHER_ALG_NULL, 0,
				ODP_AUTH_ALG_AES_GMAC, 128);
}

int ipsec_check_esp_chacha20_poly1305(void)
{
	return  ipsec_check_esp(ODP_CIPHER_ALG_CHACHA20_POLY1305, 256,
				ODP_AUTH_ALG_CHACHA20_POLY1305, 0);
}

int ipsec_check_test_sa_update_seq_num(void)
{
	odp_ipsec_capability_t capa;

	odp_ipsec_capability(&capa);

	if (!capa.test.sa_operations.seq_num)
		return ODP_TEST_INACTIVE;

	return ODP_TEST_ACTIVE;
}

int ipsec_check_esp_aes_gcm_128_reass_ipv4(void)
{
	if (suite_context.reass_ipv4)
		return  ipsec_check_esp(ODP_CIPHER_ALG_AES_GCM, 128,
					ODP_AUTH_ALG_AES_GCM, 0);
	return ODP_TEST_INACTIVE;
}

int ipsec_check_esp_aes_gcm_128_reass_ipv6(void)
{
	if (suite_context.reass_ipv6)
		return  ipsec_check_esp(ODP_CIPHER_ALG_AES_GCM, 128,
					ODP_AUTH_ALG_AES_GCM, 0);
	return ODP_TEST_INACTIVE;
}

int ipsec_check_esp_null_aes_xcbc(void)
{
	return  ipsec_check_esp(ODP_CIPHER_ALG_NULL, 0,
				ODP_AUTH_ALG_AES_XCBC_MAC, 128);
}

void ipsec_sa_param_fill(odp_ipsec_sa_param_t *param,
			 odp_ipsec_dir_t dir,
			 odp_ipsec_protocol_t proto,
			 uint32_t spi,
			 odp_ipsec_tunnel_param_t *tun,
			 odp_cipher_alg_t cipher_alg,
			 const odp_crypto_key_t *cipher_key,
			 odp_auth_alg_t auth_alg,
			 const odp_crypto_key_t *auth_key,
			 const odp_crypto_key_t *cipher_key_extra,
			 const odp_crypto_key_t *auth_key_extra)
{
	odp_ipsec_sa_param_init(param);
	param->dir = dir;
	if (dir == ODP_IPSEC_DIR_INBOUND) {
		param->inbound.lookup_mode = ODP_IPSEC_LOOKUP_SPI;
		param->inbound.antireplay_ws = capa.max_antireplay_ws;
	}
	param->proto = proto;

	if (tun) {
		param->mode = ODP_IPSEC_MODE_TUNNEL;
		if (dir == ODP_IPSEC_DIR_OUTBOUND)
			param->outbound.tunnel = *tun;
	} else {
		param->mode = ODP_IPSEC_MODE_TRANSPORT;
	}

	param->spi = spi;

	param->dest_queue = suite_context.queue;

	param->context = IPSEC_SA_CTX;

	param->crypto.cipher_alg = cipher_alg;
	if (cipher_key)
		param->crypto.cipher_key = *cipher_key;

	param->crypto.auth_alg = auth_alg;
	if (auth_key)
		param->crypto.auth_key = *auth_key;

	if (cipher_key_extra)
		param->crypto.cipher_key_extra = *cipher_key_extra;

	if (auth_key_extra)
		param->crypto.auth_key_extra = *auth_key_extra;

	/*
	 * Let's use arbitrary non-zero life time values to get life time
	 * checking code paths exercised. Let's not use very small values
	 * to avoid unexpected expiration with implementations that do
	 * not have packet-accurate life time checking but may report
	 * expiration a bit early.
	 */
	param->lifetime.soft_limit.bytes = 900 * 1000;
	param->lifetime.hard_limit.bytes = 1000 * 1000;
	param->lifetime.soft_limit.packets = 9000 * 1000;
	param->lifetime.hard_limit.packets = 10000 * 1000;
}

void ipsec_sa_destroy(odp_ipsec_sa_t sa)
{
	odp_event_t event;
	odp_ipsec_status_t status;
	int ret;

	CU_ASSERT_EQUAL(IPSEC_SA_CTX, odp_ipsec_sa_context(sa));

	CU_ASSERT_EQUAL(ODP_IPSEC_OK, odp_ipsec_sa_disable(sa));

	if (ODP_QUEUE_INVALID != suite_context.queue) {
		event = recv_event(suite_context.queue, EVENT_WAIT_TIME);

		CU_ASSERT(odp_event_is_valid(event) == 1);
		CU_ASSERT_EQUAL(ODP_EVENT_IPSEC_STATUS, odp_event_type(event));

		ret = odp_ipsec_status(&status, event);
		CU_ASSERT(ret == 0);

		if (ret == 0) {
			CU_ASSERT_EQUAL(ODP_IPSEC_STATUS_SA_DISABLE, status.id);
			CU_ASSERT_EQUAL(sa, status.sa);
			CU_ASSERT_EQUAL(0, status.result);
			CU_ASSERT_EQUAL(0, status.warn.all);
		}

		odp_event_free(event);
	}

	CU_ASSERT_EQUAL(ODP_IPSEC_OK, odp_ipsec_sa_destroy(sa));
}

odp_packet_t ipsec_packet(const ipsec_test_packet *itp)
{
	odp_packet_t pkt = odp_packet_alloc(suite_context.pool, itp->len);

	CU_ASSERT_NOT_EQUAL_FATAL(ODP_PACKET_INVALID, pkt);
	if (ODP_PACKET_INVALID == pkt)
		return pkt;

	CU_ASSERT_EQUAL(0, odp_packet_copy_from_mem(pkt, 0, itp->len,
						    itp->data));
	if (itp->l2_offset != ODP_PACKET_OFFSET_INVALID)
		CU_ASSERT_EQUAL(0, odp_packet_l2_offset_set(pkt,
							    itp->l2_offset));
	if (itp->l3_offset != ODP_PACKET_OFFSET_INVALID)
		CU_ASSERT_EQUAL(0, odp_packet_l3_offset_set(pkt,
							    itp->l3_offset));
	if (itp->l4_offset != ODP_PACKET_OFFSET_INVALID)
		CU_ASSERT_EQUAL(0, odp_packet_l4_offset_set(pkt,
							    itp->l4_offset));

	odp_packet_user_ptr_set(pkt, PACKET_USER_PTR);

	return pkt;
}

static void check_l2_header(const ipsec_test_packet *itp, odp_packet_t pkt)
{
	uint32_t len = odp_packet_len(pkt);
	uint8_t data[len];
	uint32_t l2 = odp_packet_l2_offset(pkt);
	uint32_t l3 = odp_packet_l3_offset(pkt);
	uint32_t hdr_len;

	if (!itp)
		return;

	hdr_len = itp->l3_offset - itp->l2_offset;

	CU_ASSERT_FATAL(l2 != ODP_PACKET_OFFSET_INVALID);
	CU_ASSERT_FATAL(l3 != ODP_PACKET_OFFSET_INVALID);
	CU_ASSERT_EQUAL(l3 - l2, hdr_len);
	odp_packet_copy_to_mem(pkt, 0, len, data);
	CU_ASSERT_EQUAL(0, memcmp(data + l2,
				  itp->data + itp->l2_offset,
				  hdr_len));
}

/*
 * Compare packages ignoring everything before L3 header
 */
static void ipsec_check_packet(const ipsec_test_packet *itp, odp_packet_t pkt,
			       odp_bool_t is_outbound)
{
	uint32_t len = (ODP_PACKET_INVALID == pkt) ? 1 : odp_packet_len(pkt);
	uint32_t l3, l4;
	uint8_t data[len];
	const odph_ipv4hdr_t *itp_ip;
	odph_ipv4hdr_t *ip;

	if (NULL == itp)
		return;

	l3 = odp_packet_l3_offset(pkt);
	l4 = odp_packet_l4_offset(pkt);
	odp_packet_copy_to_mem(pkt, 0, len, data);

	if (l3 == ODP_PACKET_OFFSET_INVALID) {
		CU_ASSERT_EQUAL(itp->l3_offset, ODP_PACKET_OFFSET_INVALID);
		CU_ASSERT_EQUAL(l4, ODP_PACKET_OFFSET_INVALID);

		return;
	}

	CU_ASSERT_EQUAL(len - l3, itp->len - itp->l3_offset);
	if (len - l3 != itp->len - itp->l3_offset)
		return;

	CU_ASSERT_EQUAL(l4 - l3, itp->l4_offset - itp->l3_offset);
	if (l4 - l3 != itp->l4_offset - itp->l3_offset)
		return;

	ip = (odph_ipv4hdr_t *) &data[l3];
	itp_ip = (const odph_ipv4hdr_t *) &itp->data[itp->l3_offset];
	if (ODPH_IPV4HDR_VER(ip->ver_ihl) == ODPH_IPV4 &&
	    is_outbound &&
	    ip->id != itp_ip->id) {
		/*
		 * IP ID value chosen by the implementation differs
		 * from the IP value in our test vector. This requires
		 * special handling in outbound checks.
		 */
		/*
		 * Let's change IP ID and header checksum to same values
		 * as in the test vector to facilitate packet comparison.
		 */
		CU_ASSERT(odph_ipv4_csum_valid(pkt));
		ip->id = itp_ip->id;
		ip->chksum = itp_ip->chksum;

		if (ip->proto == ODPH_IPPROTO_AH) {
			/*
			 * ID field is included in the authentication so
			 * we cannot check ICV against our test vector.
			 * Check packet data before the first possible
			 * location of the AH ICV field.
			 */
			CU_ASSERT_EQUAL(0, memcmp(data + l3,
						  itp->data + itp->l3_offset,
						  ODPH_IPV4HDR_LEN + 12));
			return;
		}
	}

	CU_ASSERT_EQUAL(0, memcmp(data + l3,
				  itp->data + itp->l3_offset,
				  len - l3));
}

static int send_pkts(const ipsec_test_part part[], int num_part)
{
	odp_packet_t pkt[num_part];
	odp_pktout_queue_t pktout;
	int i;

	if (odp_pktout_queue(suite_context.pktio, &pktout, 1) != 1) {
		CU_FAIL_FATAL("No pktout queue");
		return 0;
	}

	for (i = 0; i < num_part; i++)
		pkt[i] = ipsec_packet(part[i].pkt_in);

	CU_ASSERT_EQUAL(num_part, odp_pktout_send(pktout, pkt, num_part));

	return num_part;
}

/* Receive async inbound packet */
static odp_event_t recv_pkt_async_inbound(odp_ipsec_op_status_t status)
{
	odp_queue_t queue;

	/*
	 * In case of SA lookup failure, the event is enqueued to the default
	 * queue specified during odp_ipsec_config()
	 */
	if (status.error.sa_lookup == 0)
		queue = suite_context.queue;
	else
		queue = suite_context.default_queue;

	return recv_event(queue, EVENT_WAIT_TIME);
}

/* Receive inline processed packets */
static int recv_pkts_inline(const ipsec_test_part *part,
			    odp_packet_t *pkto)
{
	odp_queue_t queue = ODP_QUEUE_INVALID;
	int i;

	CU_ASSERT_EQUAL_FATAL(1, odp_pktin_event_queue(suite_context.pktio,
						       &queue, 1));

	for (i = 0; i < part->num_pkt;) {
		odp_event_t ev;
		odp_event_subtype_t subtype;

		ev = recv_event(queue, 0);
		if (ODP_EVENT_INVALID != ev) {
			CU_ASSERT(odp_event_is_valid(ev) == 1);
			CU_ASSERT_EQUAL(ODP_EVENT_PACKET,
					odp_event_types(ev, &subtype));
			CU_ASSERT_EQUAL(ODP_EVENT_PACKET_BASIC,
					subtype);
			CU_ASSERT(part->out[i].status.error.sa_lookup);

			pkto[i] = odp_packet_from_event(ev);
			CU_ASSERT_FATAL(pkto[i] != ODP_PACKET_INVALID);
			i++;
			continue;
		}

		ev = recv_event(suite_context.queue, 0);
		if (ODP_EVENT_INVALID != ev) {
			odp_packet_t pkt;
			int num_pkts = 0;
			odp_packet_reass_status_t reass_status;
			odp_packet_reass_info_t reass = {0};
			odp_packet_reass_partial_state_t reass_state;
			odp_packet_t frags[MAX_FRAGS];
			int j;

			CU_ASSERT(odp_event_is_valid(ev) == 1);
			CU_ASSERT_EQUAL(ODP_EVENT_PACKET, odp_event_type(ev));
			pkt = odp_packet_from_event(ev);

			CU_ASSERT(!part->out[i].status.error.sa_lookup);

			reass_status = odp_packet_reass_status(pkt);
			CU_ASSERT(reass_status == part->out[i].reass_status);

			switch (reass_status) {
			case ODP_PACKET_REASS_COMPLETE:
				CU_ASSERT(odp_packet_reass_info(pkt, &reass) == 0);
				CU_ASSERT(part->out[i].num_frags == reass.num_frags);
				/* FALLTHROUGH */
			case ODP_PACKET_REASS_NONE:
				pkto[i] = pkt;
				num_pkts = 1;
				break;
			case ODP_PACKET_REASS_INCOMPLETE:
				CU_ASSERT(0 ==
					  odp_packet_reass_partial_state(pkt, frags, &reass_state));
				num_pkts = reass_state.num_frags;

				CU_ASSERT_FATAL(i + num_pkts <= part->num_pkt);
				for (j = 0; j < num_pkts; j++)
					pkto[i + j] = frags[j];
				break;
			default:
				CU_FAIL("Unknown reassembly status");
				break;
			}

			for (; num_pkts > 0; num_pkts--)
				CU_ASSERT(odp_packet_subtype(pkto[i++]) ==
					  ODP_EVENT_PACKET_IPSEC);

			continue;
		}
	}

	return i;
}

static int ipsec_process_in(const ipsec_test_part *part,
			    odp_ipsec_sa_t sa,
			    odp_packet_t *pkto)
{
	odp_ipsec_in_param_t param;
	int num_out = part->num_pkt;
	odp_packet_t pkt;
	int i;

	memset(&param, 0, sizeof(param));
	if (!part->flags.lookup) {
		param.num_sa = 1;
		param.sa = &sa;
	} else {
		param.num_sa = 0;
		param.sa = NULL;
	}

	if (ODP_IPSEC_OP_MODE_SYNC == suite_context.inbound_op_mode) {
		pkt = ipsec_packet(part->pkt_in);
		CU_ASSERT_EQUAL(part->num_pkt, odp_ipsec_in(&pkt, 1,
							    pkto, &num_out,
							    &param));
		CU_ASSERT_EQUAL(num_out, part->num_pkt);
		CU_ASSERT_FATAL(*pkto != ODP_PACKET_INVALID);
		CU_ASSERT(odp_packet_subtype(*pkto) == ODP_EVENT_PACKET_IPSEC);
	} else if (ODP_IPSEC_OP_MODE_ASYNC == suite_context.inbound_op_mode) {
		int consumed;

		pkt = ipsec_packet(part->pkt_in);
		consumed = odp_ipsec_in_enq(&pkt, 1, &param);
		CU_ASSERT_EQUAL(1, consumed);
		if (consumed <= 0)
			num_out = 0;

		for (i = 0; i < num_out; i++) {
			odp_event_t event;
			odp_event_subtype_t subtype;

			event = recv_pkt_async_inbound(part->out[i].status);

			CU_ASSERT(odp_event_is_valid(event) == 1);
			CU_ASSERT_EQUAL(ODP_EVENT_PACKET,
					odp_event_types(event, &subtype));
			CU_ASSERT_EQUAL(ODP_EVENT_PACKET_IPSEC, subtype);
			pkto[i] = odp_ipsec_packet_from_event(event);
			CU_ASSERT_FATAL(pkto[i] != ODP_PACKET_INVALID);
			CU_ASSERT(odp_packet_subtype(pkto[i]) ==
				  ODP_EVENT_PACKET_IPSEC);
		}
	} else {
		CU_ASSERT_EQUAL(1, send_pkts(part, 1));
		if (part->num_pkt)
			CU_ASSERT_EQUAL(part->num_pkt, recv_pkts_inline(part, pkto));
	}

	return num_out;
}

static int ipsec_send_out_one(const ipsec_test_part *part,
			      odp_ipsec_sa_t sa,
			      odp_packet_t *pkto)
{
	odp_ipsec_out_param_t param;
	int num_out = part->num_pkt;
	odp_packet_t pkt;
	int i;

	pkt = ipsec_packet(part->pkt_in);

	memset(&param, 0, sizeof(param));
	param.num_sa = 1;
	param.sa = &sa;
	param.num_opt = part->num_opt;
	param.opt = &part->opt;

	if (ODP_IPSEC_OP_MODE_SYNC == suite_context.outbound_op_mode) {
		CU_ASSERT_EQUAL(1, odp_ipsec_out(&pkt, 1, pkto, &num_out,
						 &param));
		CU_ASSERT_FATAL(num_out == 1);
		CU_ASSERT_FATAL(*pkto != ODP_PACKET_INVALID);
		CU_ASSERT(odp_packet_subtype(*pkto) == ODP_EVENT_PACKET_IPSEC);
	} else if (ODP_IPSEC_OP_MODE_ASYNC == suite_context.outbound_op_mode) {
		num_out = odp_ipsec_out_enq(&pkt, 1, &param);
		CU_ASSERT_EQUAL(1, num_out);

		num_out = (num_out == 1) ?  1 : 0;

		for (i = 0; i < num_out; i++) {
			odp_event_t event;
			odp_event_subtype_t subtype;

			event = recv_event(suite_context.queue, EVENT_WAIT_TIME);

			CU_ASSERT(odp_event_is_valid(event) == 1);
			CU_ASSERT_EQUAL(ODP_EVENT_PACKET,
					odp_event_types(event, &subtype));
			CU_ASSERT_EQUAL(ODP_EVENT_PACKET_IPSEC, subtype);
			pkto[i] = odp_ipsec_packet_from_event(event);
			CU_ASSERT_FATAL(pkto[i] != ODP_PACKET_INVALID);
			CU_ASSERT(odp_packet_subtype(pkto[i]) ==
				  ODP_EVENT_PACKET_IPSEC);
		}
	} else {
		struct odp_ipsec_out_inline_param_t inline_param;
		uint32_t hdr_len;
		odph_ethhdr_t hdr;
		odp_queue_t queue = ODP_QUEUE_INVALID;

		if (NULL != part->out[0].pkt_res) {
			/*
			 * Take L2 header from the expected result.
			 * This way ethertype will be correct for input
			 * processing even with IPv4-in-IPv6-tunnels etc.
			 */
			hdr_len = part->out[0].pkt_res->l3_offset;
			CU_ASSERT_FATAL(hdr_len <= sizeof(hdr));
			memcpy(&hdr, part->out[0].pkt_res->data, hdr_len);
		} else {
			hdr_len = 14;
			memset(&hdr, 0xff, hdr_len);

			if (part->out[0].l3_type == ODP_PROTO_L3_TYPE_IPV6) {
				hdr.type = odp_cpu_to_be_16(ODPH_ETHTYPE_IPV6);
			} else {
				hdr.type = odp_cpu_to_be_16(ODPH_ETHTYPE_IPV4);
			}
		}

		if (part->flags.inline_hdr_in_packet) {
			/*
			 * Provide the to-be-prepended header to ODP in the
			 * the packet data. Use nonzero L2 offset for better
			 * test coverage.
			 */
			uint32_t new_l2_offset = 100;
			uint32_t l3_offset = odp_packet_l3_offset(pkt);
			uint32_t new_l3_offset = new_l2_offset + hdr_len;
			uint32_t l4_offset = odp_packet_l4_offset(pkt);
			int ret;

			ret = odp_packet_trunc_head(&pkt, l3_offset,
						    NULL, NULL);
			CU_ASSERT_FATAL(ret >= 0);
			ret = odp_packet_extend_head(&pkt, new_l3_offset,
						     NULL, NULL);
			CU_ASSERT_FATAL(ret >= 0);
			odp_packet_l2_offset_set(pkt, new_l2_offset);
			odp_packet_l3_offset_set(pkt, new_l3_offset);
			odp_packet_copy_from_mem(pkt, new_l2_offset, hdr_len, &hdr);
			if (l4_offset != ODP_PACKET_OFFSET_INVALID)
				odp_packet_l4_offset_set(pkt, new_l3_offset +
							 l4_offset - l3_offset);

			inline_param.outer_hdr.ptr = NULL;
		} else {
			inline_param.outer_hdr.ptr = (void *)&hdr;
		}

		inline_param.pktio = suite_context.pktio;
		inline_param.tm_queue = ODP_TM_INVALID;
		inline_param.outer_hdr.len = hdr_len;

		CU_ASSERT_EQUAL(1, odp_ipsec_out_inline(&pkt, 1, &param,
							&inline_param));
		CU_ASSERT_EQUAL_FATAL(1,
				      odp_pktin_event_queue(suite_context.
							    pktio,
							    &queue, 1));

		for (i = 0; i < num_out;) {
			odp_event_t ev;
			odp_event_subtype_t subtype;

			ev = recv_event(queue, 0);
			if (ODP_EVENT_INVALID != ev) {
				CU_ASSERT(odp_event_is_valid(ev) == 1);
				CU_ASSERT_EQUAL(ODP_EVENT_PACKET,
						odp_event_types(ev, &subtype));
				CU_ASSERT_EQUAL(ODP_EVENT_PACKET_BASIC,
						subtype);
				CU_ASSERT(!part->out[i].status.error.all);

				pkto[i] = odp_packet_from_event(ev);
				CU_ASSERT_FATAL(pkto[i] != ODP_PACKET_INVALID);
				i++;
				continue;
			}

			ev = recv_event(suite_context.queue, 0);
			if (ODP_EVENT_INVALID != ev) {
				CU_ASSERT(odp_event_is_valid(ev) == 1);
				CU_ASSERT_EQUAL(ODP_EVENT_PACKET,
						odp_event_types(ev, &subtype));
				CU_ASSERT_EQUAL(ODP_EVENT_PACKET_IPSEC,
						subtype);
				CU_ASSERT(part->out[i].status.error.all);

				pkto[i] = odp_ipsec_packet_from_event(ev);
				CU_ASSERT_FATAL(pkto[i] != ODP_PACKET_INVALID);
				CU_ASSERT(odp_packet_subtype(pkto[i]) ==
					  ODP_EVENT_PACKET_IPSEC);
				i++;
				continue;
			}
		}
	}

	return num_out;
}

int ipsec_test_sa_update_seq_num(odp_ipsec_sa_t sa, uint32_t seq_num)
{
	odp_ipsec_test_sa_operation_t sa_op;
	odp_ipsec_test_sa_param_t sa_param;

	sa_op = ODP_IPSEC_TEST_SA_UPDATE_SEQ_NUM;
	sa_param.seq_num = seq_num;

	return odp_ipsec_test_sa_update(sa, sa_op, &sa_param);
}

static void ipsec_pkt_seq_num_check(odp_packet_t pkt, uint32_t seq_num)
{
	uint32_t l3_off = odp_packet_l3_offset(pkt);
	uint32_t l4_off;
	odph_ipv4hdr_t ip;

	CU_ASSERT_NOT_EQUAL_FATAL(ODP_PACKET_OFFSET_INVALID, l3_off);
	CU_ASSERT_EQUAL_FATAL(0, odp_packet_copy_to_mem(pkt, l3_off, sizeof(ip),
							&ip));

	if (ODPH_IPV4HDR_VER(ip.ver_ihl) == ODPH_IPV4) {
		l4_off = l3_off + (ODPH_IPV4HDR_IHL(ip.ver_ihl) * 4);

		if (ip.proto == ODPH_IPPROTO_ESP) {
			odph_esphdr_t esp;

			odp_packet_copy_to_mem(pkt, l4_off, sizeof(esp), &esp);
			CU_ASSERT_EQUAL(odp_be_to_cpu_32(esp.seq_no), seq_num);
		} else if (ip.proto == ODPH_IPPROTO_AH) {
			odph_ahhdr_t ah;

			odp_packet_copy_to_mem(pkt, l4_off, sizeof(ah), &ah);
			CU_ASSERT_EQUAL(odp_be_to_cpu_32(ah.seq_no), seq_num);
		} else {
			CU_FAIL("Unexpected IP Proto");
		}
	} else {
		CU_FAIL("Unexpected IP Version");
	}
}

/* Verify inbound processed one part */
static void verify_in(const ipsec_test_part *part,
		      odp_ipsec_sa_t sa,
		      odp_packet_t *pkto)
{
	int i;

	for (i = 0; i < part->num_pkt; i++) {
		odp_ipsec_packet_result_t result;
		void *expected_user_ptr = PACKET_USER_PTR;

		if (ODP_EVENT_PACKET_IPSEC !=
		    odp_event_subtype(odp_packet_to_event(pkto[i]))) {
			/* Inline packet failed SA lookup */
			CU_ASSERT_EQUAL(1, part->out[i].status.error.sa_lookup);
		} else {
			CU_ASSERT_EQUAL(0, odp_ipsec_result(&result, pkto[i]));
			CU_ASSERT_EQUAL(part->out[i].status.error.all,
					result.status.error.all);

			if (part->out[i].status.error.all != 0) {
				odp_packet_free(pkto[i]);
				return;
			}

			if (0 == result.status.error.all)
				CU_ASSERT_EQUAL(0,
						odp_packet_has_error(pkto[i]));
			CU_ASSERT_EQUAL(suite_context.inbound_op_mode ==
					ODP_IPSEC_OP_MODE_INLINE,
					result.flag.inline_mode);
			CU_ASSERT_EQUAL(sa, result.sa);
			if (ODP_IPSEC_SA_INVALID != sa)
				CU_ASSERT_EQUAL(IPSEC_SA_CTX,
						odp_ipsec_sa_context(sa));
			if (suite_context.inbound_op_mode != ODP_IPSEC_OP_MODE_SYNC) {
				uint32_t len;

				if (part->out[i].orig_ip_len)
					len = part->out[i].orig_ip_len;
				else
					len = part->pkt_in->len - part->pkt_in->l3_offset;

				CU_ASSERT(result.orig_ip_len == 0 ||
					  result.orig_ip_len == len);
			}
		}
		ipsec_check_packet(part->out[i].pkt_res,
				   pkto[i],
				   false);
		if (suite_context.inbound_op_mode == ODP_IPSEC_OP_MODE_INLINE)
			expected_user_ptr = NULL;
		CU_ASSERT(odp_packet_user_ptr(pkto[i]) == expected_user_ptr);

		if (part->out[i].pkt_res != NULL &&
		    part->out[i].l3_type != _ODP_PROTO_L3_TYPE_UNDEF)
			CU_ASSERT_EQUAL(part->out[i].l3_type,
					odp_packet_l3_type(pkto[i]));
		if (part->out[i].pkt_res != NULL &&
		    part->out[i].l4_type != _ODP_PROTO_L4_TYPE_UNDEF)
			CU_ASSERT_EQUAL(part->out[i].l4_type,
					odp_packet_l4_type(pkto[i]));
		odp_packet_free(pkto[i]);
	}
}

static void parse_ip(odp_packet_t pkt)
{
	uint8_t *ver_ihl;
	odp_proto_t proto = ODP_PROTO_NONE;
	uint32_t l3 = odp_packet_l3_offset(pkt);

	ver_ihl = odp_packet_l3_ptr(pkt, NULL);
	if ((*ver_ihl >> 4) == 4)
		proto = ODP_PROTO_IPV4;
	else if ((*ver_ihl >> 4) == 6)
		proto = ODP_PROTO_IPV6;
	else
		CU_FAIL("Invalid IP version");

	odp_packet_parse_param_t param = {
		.proto = proto,
		.last_layer = ODP_PROTO_LAYER_L4,
	};
	CU_ASSERT(odp_packet_parse(pkt, l3, &param) == 0);
}

int ipsec_check_out(const ipsec_test_part *part, odp_ipsec_sa_t sa,
		    odp_packet_t *pkto)
{
	int i;
	int num_out;

	num_out = ipsec_send_out_one(part, sa, pkto);

	for (i = 0; i < num_out; i++) {
		odp_ipsec_packet_result_t result;

		if (ODP_EVENT_PACKET_IPSEC !=
		    odp_event_subtype(odp_packet_to_event(pkto[i]))) {
			/* Inline packet went through loop */
			CU_ASSERT_EQUAL(0, part->out[i].status.error.all);
			CU_ASSERT(odp_packet_user_ptr(pkto[i]) == NULL);
			/* L2 header must match the requested one */
			check_l2_header(part->out[i].pkt_res, pkto[i]);
		} else {
			/* IPsec packet */
			CU_ASSERT_EQUAL(0, odp_ipsec_result(&result, pkto[i]));
			CU_ASSERT_EQUAL(part->out[i].status.error.all,
					result.status.error.all);
			if (0 == result.status.error.all)
				CU_ASSERT_EQUAL(0,
						odp_packet_has_error(pkto[i]));
			CU_ASSERT_EQUAL(sa, result.sa);
			CU_ASSERT_EQUAL(IPSEC_SA_CTX,
					odp_ipsec_sa_context(sa));
			CU_ASSERT(odp_packet_user_ptr(pkto[i]) == PACKET_USER_PTR);

			/* Parse the packet to set L4 offset and type */
			parse_ip(pkto[i]);
		}

		if (part->flags.test_sa_seq_num)
			ipsec_pkt_seq_num_check(pkto[i], part->out[i].seq_num);

		ipsec_check_packet(part->out[i].pkt_res,
				   pkto[i],
				   true);

		/*
		 * If we did not have an expected packet to compare the
		 * result packet with, we will check the l3 and l4 types
		 * against the expected ones.
		 */
		if (part->out[i].pkt_res == NULL) {
			if (part->out[i].l3_type != _ODP_PROTO_L3_TYPE_UNDEF)
				CU_ASSERT(part->out[i].l3_type ==
					  odp_packet_l3_type(pkto[i]));
			if (part->out[i].l4_type != _ODP_PROTO_L4_TYPE_UNDEF)
				CU_ASSERT(part->out[i].l4_type ==
					  odp_packet_l4_type(pkto[i]));
		}
	}
	return num_out;
}

void ipsec_check_in_one(const ipsec_test_part *part, odp_ipsec_sa_t sa)
{
	odp_packet_t pkto[MAX_FRAGS] = {0};
	int num_out;

	num_out = ipsec_process_in(part, sa, pkto);
	CU_ASSERT_EQUAL(num_out, part->num_pkt);

	verify_in(part, sa, pkto);
}

void ipsec_check_out_one(const ipsec_test_part *part, odp_ipsec_sa_t sa)
{
	int num_out = part->num_pkt;
	odp_packet_t pkto[num_out];
	int i;

	num_out = ipsec_check_out(part, sa, pkto);

	for (i = 0; i < num_out; i++)
		odp_packet_free(pkto[i]);
}

static int ipsec_suite_init(void)
{
	int rc = 0;

	if (suite_context.pktio != ODP_PKTIO_INVALID)
		rc = pktio_start(suite_context.pktio,
				 suite_context.inbound_op_mode ==
				 ODP_IPSEC_OP_MODE_INLINE,
				 suite_context.outbound_op_mode ==
				 ODP_IPSEC_OP_MODE_INLINE);
	if (rc == 0)
		suite_context.pktio = ODP_PKTIO_INVALID;

	return rc < 0 ? -1 : 0;
}

void ipsec_test_packet_from_pkt(ipsec_test_packet *test_pkt, odp_packet_t *pkt)
{
	CU_ASSERT_FATAL(odp_packet_len(*pkt) <= sizeof(test_pkt->data));

	test_pkt->len = odp_packet_len(*pkt);
	test_pkt->l2_offset = odp_packet_l2_offset(*pkt);
	test_pkt->l3_offset = odp_packet_l3_offset(*pkt);
	test_pkt->l4_offset = odp_packet_l4_offset(*pkt);
	odp_packet_copy_to_mem(*pkt, 0, test_pkt->len, test_pkt->data);
	odp_packet_free(*pkt);
}

int ipsec_suite_term(void)
{
	if (suite_context.pktio != ODP_PKTIO_INVALID)
		pktio_stop(suite_context.pktio);

	if (ODP_QUEUE_INVALID != suite_context.queue) {
		if (odp_queue_destroy(suite_context.queue))
			fprintf(stderr, "IPsec destq destroy failed.\n");
	}

	if (odp_cunit_print_inactive())
		return -1;

	return 0;
}

int ipsec_in_term(void)
{
	return ipsec_suite_term();
}

int ipsec_out_term(void)
{
	return ipsec_suite_term();
}

static odp_queue_t sched_queue_create(const char *name)
{
	odp_queue_param_t qparam;

	odp_queue_param_init(&qparam);
	qparam.type = ODP_QUEUE_TYPE_SCHED;
	qparam.sched.prio  = odp_schedule_default_prio();
	qparam.sched.sync  = ODP_SCHED_SYNC_PARALLEL;
	qparam.sched.group = ODP_SCHED_GROUP_ALL;

	return odp_queue_create(name, &qparam);
}

static odp_queue_t plain_queue_create(const char *name)
{
	return odp_queue_create(name, NULL);
}

int ipsec_suite_sync_init(void)
{
	suite_context.queue = ODP_QUEUE_INVALID;

	 /* q_type doesn't matter when queue handle is invalid. */
	suite_context.q_type = ODP_QUEUE_TYPE_PLAIN;

	return ipsec_suite_init();
}

int ipsec_suite_plain_init(void)
{
	odp_queue_t dest_queue;

	dest_queue = plain_queue_create("ipsec-out");
	if (ODP_QUEUE_INVALID == dest_queue) {
		fprintf(stderr, "IPsec destq creation failed.\n");
		return -1;
	}

	suite_context.queue = dest_queue;
	suite_context.q_type = ODP_QUEUE_TYPE_PLAIN;

	return ipsec_suite_init();
}

int ipsec_suite_sched_init(void)
{
	odp_queue_t dest_queue;

	dest_queue = sched_queue_create("ipsec-out");
	if (ODP_QUEUE_INVALID == dest_queue) {
		fprintf(stderr, "IPsec destq creation failed.\n");
		return -1;
	}

	suite_context.queue = dest_queue;
	suite_context.q_type = ODP_QUEUE_TYPE_SCHED;

	return ipsec_suite_init();
}

int ipsec_init(odp_instance_t *inst, odp_ipsec_op_mode_t mode)
{
	odp_pool_param_t params;
	odp_pool_t pool;
	odp_pool_capability_t pool_capa;
	odp_pktio_t pktio;
	odp_init_t init_param;
	odph_helper_options_t helper_options;

	suite_context.reass_ipv4 = false;
	suite_context.reass_ipv6 = false;
	suite_context.pool = ODP_POOL_INVALID;
	suite_context.pktio = ODP_PKTIO_INVALID;
	suite_context.default_queue = ODP_QUEUE_INVALID;

	if (odph_options(&helper_options)) {
		fprintf(stderr, "error: odph_options() failed.\n");
		return -1;
	}

	odp_init_param_init(&init_param);
	init_param.mem_model = helper_options.mem_model;

	if (0 != odp_init_global(inst, &init_param, NULL)) {
		fprintf(stderr, "error: odp_init_global() failed.\n");
		return -1;
	}

	if (0 != odp_init_local(*inst, ODP_THREAD_CONTROL)) {
		fprintf(stderr, "error: odp_init_local() failed.\n");
		return -1;
	}

	if (odp_schedule_config(NULL)) {
		fprintf(stderr, "odp_schedule_config() failed.\n");
		return -1;
	}

	if (odp_pool_capability(&pool_capa) < 0) {
		fprintf(stderr, "error: odp_pool_capability() failed.\n");
		return -1;
	}

	odp_pool_param_init(&params);
	params.pkt.seg_len = MAX_PKT_LEN;
	params.pkt.len     = MAX_PKT_LEN;
	params.pkt.num     = PKT_POOL_NUM;
	params.type        = ODP_POOL_PACKET;

	if (pool_capa.pkt.max_seg_len &&
	    MAX_PKT_LEN > pool_capa.pkt.max_seg_len) {
		fprintf(stderr, "Warning: small packet segment length\n");
		params.pkt.seg_len = pool_capa.pkt.max_seg_len;
	}

	if (pool_capa.pkt.max_len &&
	    MAX_PKT_LEN > pool_capa.pkt.max_len) {
		fprintf(stderr, "Pool max packet length too small\n");
		return -1;
	}

	pool = odp_pool_create("packet_pool", &params);

	if (ODP_POOL_INVALID == pool) {
		fprintf(stderr, "Packet pool creation failed.\n");
		return -1;
	}

	if (mode == ODP_IPSEC_OP_MODE_INLINE) {
		pktio = pktio_create(pool);
		if (ODP_PKTIO_INVALID == pktio) {
			fprintf(stderr, "IPsec pktio creation failed.\n");
			return -1;
		}
	}

	return 0;
}

int ipsec_config(odp_instance_t ODP_UNUSED inst)
{
	odp_ipsec_config_t ipsec_config;

	if (odp_ipsec_capability(&capa) < 0)
		return -1;

	/* If we can not setup IPsec due to mode being unsupported, don't
	 * return an error here. It is easier (and more correct) to filter that
	 * in test checking function and just say that the test is inactive. */
	if ((ODP_IPSEC_OP_MODE_SYNC == suite_context.inbound_op_mode &&
	     ODP_SUPPORT_NO == capa.op_mode_sync) ||
	    (ODP_IPSEC_OP_MODE_SYNC == suite_context.outbound_op_mode &&
	     ODP_SUPPORT_NO == capa.op_mode_sync) ||
	    (ODP_IPSEC_OP_MODE_ASYNC == suite_context.inbound_op_mode &&
	     ODP_SUPPORT_NO == capa.op_mode_async) ||
	    (ODP_IPSEC_OP_MODE_ASYNC == suite_context.outbound_op_mode &&
	     ODP_SUPPORT_NO == capa.op_mode_async) ||
	    (ODP_IPSEC_OP_MODE_INLINE == suite_context.inbound_op_mode &&
	     ODP_SUPPORT_NO == capa.op_mode_inline_in) ||
	    (ODP_IPSEC_OP_MODE_INLINE == suite_context.outbound_op_mode &&
	     ODP_SUPPORT_NO == capa.op_mode_inline_out))
		return 0;

	if (suite_context.inbound_op_mode == ODP_IPSEC_OP_MODE_ASYNC ||
	    suite_context.inbound_op_mode == ODP_IPSEC_OP_MODE_INLINE) {
		if (capa.queue_type_plain)
			suite_context.default_queue = plain_queue_create("ipsec-default");
		else if (capa.queue_type_sched)
			suite_context.default_queue = sched_queue_create("ipsec-default");

		if (ODP_QUEUE_INVALID == suite_context.default_queue) {
			fprintf(stderr, "IPsec defaultq creation failed.\n");
			return -1;
		}
	}

	reass_test_vectors_init();

	odp_ipsec_config_init(&ipsec_config);
	ipsec_config.max_num_sa = capa.max_num_sa;
	ipsec_config.inbound_mode = suite_context.inbound_op_mode;
	ipsec_config.outbound_mode = suite_context.outbound_op_mode;
	ipsec_config.outbound.all_chksum = ~0;
	ipsec_config.inbound.default_queue = suite_context.default_queue;
	ipsec_config.inbound.parse_level = ODP_PROTO_LAYER_ALL;
	ipsec_config.inbound.chksums.all_chksum = ~0;
	ipsec_config.stats_en = true;

	ipsec_config.inbound.reassembly.max_wait_time = 100 * ODP_TIME_MSEC_IN_NS;
	if (ipsec_config.inbound.reassembly.max_wait_time > capa.reassembly.max_wait_time)
		ipsec_config.inbound.reassembly.max_wait_time = capa.reassembly.max_wait_time;

	ipsec_config.inbound.reassembly.max_num_frags = MAX_FRAGS;

	if (capa.reassembly.ip) {
		ipsec_config.inbound.reassembly.en_ipv4 = true;
		ipsec_config.inbound.reassembly.en_ipv6 = true;
	}

	if (capa.reassembly.ipv4)
		ipsec_config.inbound.reassembly.en_ipv4 = true;

	if (capa.reassembly.ipv6)
		ipsec_config.inbound.reassembly.en_ipv6 = true;

	if (ODP_IPSEC_OP_MODE_INLINE == suite_context.inbound_op_mode &&
	    !capa.reass_inline) {
		ipsec_config.inbound.reassembly.en_ipv4 = false;
		ipsec_config.inbound.reassembly.en_ipv6 = false;
	}

	if (ODP_IPSEC_OP_MODE_ASYNC == suite_context.inbound_op_mode &&
	    !capa.reass_async) {
		ipsec_config.inbound.reassembly.en_ipv4 = false;
		ipsec_config.inbound.reassembly.en_ipv6 = false;
	}

	if (ODP_IPSEC_OP_MODE_SYNC == suite_context.inbound_op_mode) {
		ipsec_config.inbound.reassembly.en_ipv4 = false;
		ipsec_config.inbound.reassembly.en_ipv6 = false;
	}

	if (capa.reassembly.max_num_frags < MAX_FRAGS) {
		ipsec_config.inbound.reassembly.en_ipv4 = false;
		ipsec_config.inbound.reassembly.en_ipv6 = false;
	}

	if (ipsec_config.inbound.reassembly.en_ipv4)
		suite_context.reass_ipv4 = true;
	else
		suite_context.reass_ipv4 = false;

	if (ipsec_config.inbound.reassembly.en_ipv6)
		suite_context.reass_ipv6 = true;
	else
		suite_context.reass_ipv6 = false;

	if (suite_context.reass_ipv4 || suite_context.reass_ipv6) {
		if (ODP_IPSEC_OP_MODE_INLINE == suite_context.inbound_op_mode)
			ipsec_config.inbound.reass_inline = true;

		if (ODP_IPSEC_OP_MODE_ASYNC == suite_context.inbound_op_mode) {
			ipsec_config.inbound.reass_async = true;

			/* Reassembly with ASYNC not supported */
			suite_context.reass_ipv4 = false;
			suite_context.reass_ipv6 = false;
		}
	}

	if (ODP_IPSEC_OK != odp_ipsec_config(&ipsec_config))
		return -1;

	return 0;
}

int ipsec_term(odp_instance_t inst)
{
	odp_pool_t pool = suite_context.pool;
	odp_queue_t default_queue = suite_context.default_queue;
	/* suite_context.pktio is set to ODP_PKTIO_INVALID by ipsec_suite_init()
	   if inline processing is not supported. */
	odp_pktio_t pktio = odp_pktio_lookup("loop");

	if (ODP_PKTIO_INVALID != pktio) {
		if (odp_pktio_close(pktio))
			fprintf(stderr, "IPsec pktio close failed.\n");
	}

	if (ODP_QUEUE_INVALID != default_queue) {
		if (odp_queue_destroy(default_queue))
			fprintf(stderr, "IPsec defaultq destroy failed.\n");
	}

	if (ODP_POOL_INVALID != pool) {
		if (odp_pool_destroy(pool))
			fprintf(stderr, "Packet pool destroy failed.\n");
	}

	if (0 != odp_term_local()) {
		fprintf(stderr, "error: odp_term_local() failed.\n");
		return -1;
	}

	if (0 != odp_term_global(inst)) {
		fprintf(stderr, "error: odp_term_global() failed.\n");
		return -1;
	}

	return 0;
}