From patchwork Thu Dec 24 09:10:20 2015 Content-Type: text/plain; charset="utf-8" MIME-Version: 1.0 Content-Transfer-Encoding: 7bit X-Patchwork-Submitter: Balasubramanian Manoharan X-Patchwork-Id: 58984 Delivered-To: patch@linaro.org Received: by 10.112.89.199 with SMTP id bq7csp4367456lbb; Thu, 24 Dec 2015 01:10:54 -0800 (PST) X-Received: by 10.140.28.66 with SMTP id 60mr46002727qgy.74.1450948254694; Thu, 24 Dec 2015 01:10:54 -0800 (PST) Return-Path: Received: from lists.linaro.org (lists.linaro.org. [54.225.227.206]) by mx.google.com with ESMTP id y20si37469582qka.117.2015.12.24.01.10.53; Thu, 24 Dec 2015 01:10:54 -0800 (PST) Received-SPF: pass (google.com: domain of lng-odp-bounces@lists.linaro.org designates 54.225.227.206 as permitted sender) client-ip=54.225.227.206; Authentication-Results: mx.google.com; spf=pass (google.com: domain of lng-odp-bounces@lists.linaro.org designates 54.225.227.206 as permitted sender) smtp.mailfrom=lng-odp-bounces@lists.linaro.org; dkim=neutral (body hash did not verify) header.i=@linaro.org Received: by lists.linaro.org (Postfix, from userid 109) id 9CB1D6183D; Thu, 24 Dec 2015 09:10:53 +0000 (UTC) Authentication-Results: lists.linaro.org; dkim=fail reason="verification failed; unprotected key" header.d=linaro.org header.i=@linaro.org header.b=dswY2nug; dkim-adsp=none (unprotected policy); dkim-atps=neutral X-Spam-Checker-Version: SpamAssassin 3.4.0 (2014-02-07) on ip-10-142-244-252 X-Spam-Level: X-Spam-Status: No, score=-2.5 required=5.0 tests=BAYES_00,DKIM_SIGNED, RCVD_IN_DNSWL_LOW,RCVD_IN_MSPIKE_H2,T_DKIM_INVALID,URIBL_BLOCKED autolearn=disabled version=3.4.0 Received: from [127.0.0.1] (localhost [127.0.0.1]) by lists.linaro.org (Postfix) with ESMTP id D7128618E5; Thu, 24 Dec 2015 09:10:43 +0000 (UTC) X-Original-To: lng-odp@lists.linaro.org Delivered-To: lng-odp@lists.linaro.org Received: by lists.linaro.org (Postfix, from userid 109) id 0CFED6193C; Thu, 24 Dec 2015 09:10:40 +0000 (UTC) Received: from mail-io0-f176.google.com (mail-io0-f176.google.com [209.85.223.176]) by lists.linaro.org (Postfix) with ESMTPS id 8C16A6183D for ; Thu, 24 Dec 2015 09:10:38 +0000 (UTC) Received: by mail-io0-f176.google.com with SMTP id o67so237995772iof.3 for ; Thu, 24 Dec 2015 01:10:38 -0800 (PST) DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=linaro.org; s=google; h=from:to:cc:subject:date:message-id; bh=QPTWlA4u5S+Da1lCYJFCslsbwLBbn5iiai1K2osUTgw=; b=dswY2nugAhWTmdZUS/IHKELp3zhiMo2OLqeShhTdkpBVSqJgviDPoGithet9AB6w/y 8I3IlOmM+wZ6DJ2SHVRLw1KA08ZJLpHAOZSmlt3oK5R6+bwKmHbMHUpWtYjexgAaJ66A M5c5y0b7nnzEFM/HHvM/ObotN7YN7d+lDZbKA= X-Google-DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=1e100.net; s=20130820; h=x-gm-message-state:from:to:cc:subject:date:message-id; bh=QPTWlA4u5S+Da1lCYJFCslsbwLBbn5iiai1K2osUTgw=; b=jVrYpKmmvUUJrfikCGE9CuBH0f+e2lgS6aRqeeaGkBRajfCgshVmB8U4PFCJpZ9qZL 8ZsEMlMiC1cWQVi1lu3a2naslfgqDkyMKd5ApXU6TbsR0hqbXiybyNAl3C3Fpq9EIN05 XkmPVVL/AxlT3uikRLWaFFXAp80dJ8WaAd6yJpbt3SKHK+2ycK0wMrtbSv0K8PQq6+Pd M7nBsuiY2dyg0dfwZiiZTlKbTtmODVTWaCrJDgMft5Rg7DD8Jda7UpXHjOCBYUItNq36 LwW0jTgqg12N8n6W5NkzYaQA4y8a8+jEi0/T+iaMic+KZWj1MgBTVm2YzUI9tkzZxdlh V7DA== X-Gm-Message-State: ALoCoQmYk+plYbugey36+GGC1n0bm6V6K8o5XkLdepJlHrQxWy3bREY9PCnlAnJkaSZaMpLAKbTHt1b7ZrZ+Vq4OPa86P+tsFA== X-Received: by 10.107.40.76 with SMTP id o73mr29961488ioo.157.1450948238110; Thu, 24 Dec 2015 01:10:38 -0800 (PST) Received: from bala-Vostro-2520.caveonetworks.com ([111.93.218.67]) by smtp.gmail.com with ESMTPSA id 129sm16116658ioo.23.2015.12.24.01.10.36 (version=TLS1_2 cipher=ECDHE-RSA-AES128-SHA bits=128/128); Thu, 24 Dec 2015 01:10:37 -0800 (PST) From: Balasubramanian Manoharan To: lng-odp@lists.linaro.org Date: Thu, 24 Dec 2015 14:40:20 +0530 Message-Id: <1450948220-15758-1-git-send-email-bala.manoharan@linaro.org> X-Mailer: git-send-email 1.9.1 X-Topics: Classification patch Subject: [lng-odp] [API-NEXT PATCH] validation: classification: adds additional ASSERTS for stability X-BeenThere: lng-odp@lists.linaro.org X-Mailman-Version: 2.1.16 Precedence: list List-Id: "The OpenDataPlane \(ODP\) List" List-Unsubscribe: , List-Archive: List-Post: List-Help: List-Subscribe: , MIME-Version: 1.0 Errors-To: lng-odp-bounces@lists.linaro.org Sender: "lng-odp" Adds additional ASSERTS for stability in validation suites during failure Signed-off-by: Balasubramanian Manoharan Reviewed-by: Bill Fischofer --- .../classification/odp_classification_test_pmr.c | 44 +++++++++++++++------- .../classification/odp_classification_tests.c | 23 +++++++---- 2 files changed, 46 insertions(+), 21 deletions(-) diff --git a/test/validation/classification/odp_classification_test_pmr.c b/test/validation/classification/odp_classification_test_pmr.c index 5a13e13..6644b53 100644 --- a/test/validation/classification/odp_classification_test_pmr.c +++ b/test/validation/classification/odp_classification_test_pmr.c @@ -162,7 +162,7 @@ void classification_test_pmr_term_tcp_dport(void) seqno = 0; pktio = create_pktio(ODP_QUEUE_TYPE_SCHED); - CU_ASSERT(pktio != ODP_PKTIO_INVALID); + CU_ASSERT_FATAL(pktio != ODP_PKTIO_INVALID); retval = create_default_inq(pktio, ODP_QUEUE_TYPE_SCHED); CU_ASSERT(retval == 0); @@ -196,6 +196,7 @@ void classification_test_pmr_term_tcp_dport(void) configure_default_cos(pktio, &default_cos, &default_queue, &default_pool); pkt = create_packet(pkt_pool, false, &seq, false); + CU_ASSERT_FATAL(pkt != ODP_PACKET_INVALID); seqno = cls_pkt_get_seq(pkt); CU_ASSERT(seqno != TEST_SEQ_INVALID); @@ -205,7 +206,7 @@ void classification_test_pmr_term_tcp_dport(void) enqueue_pktio_interface(pkt, pktio); pkt = receive_packet(&retqueue, ODP_TIME_SEC_IN_NS); - CU_ASSERT(pkt != ODP_PACKET_INVALID); + CU_ASSERT_FATAL(pkt != ODP_PACKET_INVALID); pool_recv = odp_packet_pool(pkt); CU_ASSERT(pool == pool_recv); CU_ASSERT(retqueue == queue); @@ -215,6 +216,7 @@ void classification_test_pmr_term_tcp_dport(void) /* Other packets are delivered to default queue */ pkt = create_packet(pkt_pool, false, &seq, false); + CU_ASSERT_FATAL(pkt != ODP_PACKET_INVALID); seqno = cls_pkt_get_seq(pkt); CU_ASSERT(seqno != TEST_SEQ_INVALID); @@ -224,7 +226,7 @@ void classification_test_pmr_term_tcp_dport(void) enqueue_pktio_interface(pkt, pktio); pkt = receive_packet(&retqueue, ODP_TIME_SEC_IN_NS); - CU_ASSERT(pkt != ODP_PACKET_INVALID); + CU_ASSERT_FATAL(pkt != ODP_PACKET_INVALID); CU_ASSERT(seqno == cls_pkt_get_seq(pkt)); CU_ASSERT(retqueue == default_queue); recvpool = odp_packet_pool(pkt); @@ -269,6 +271,7 @@ void classification_test_pmr_term_tcp_sport(void) seqno = 0; pktio = create_pktio(ODP_QUEUE_TYPE_SCHED); + CU_ASSERT_FATAL(pktio != ODP_PKTIO_INVALID); retval = create_default_inq(pktio, ODP_QUEUE_TYPE_SCHED); CU_ASSERT(retval == 0); @@ -301,6 +304,7 @@ void classification_test_pmr_term_tcp_sport(void) configure_default_cos(pktio, &default_cos, &default_queue, &default_pool); pkt = create_packet(pkt_pool, false, &seq, false); + CU_ASSERT_FATAL(pkt != ODP_PACKET_INVALID); seqno = cls_pkt_get_seq(pkt); CU_ASSERT(seqno != TEST_SEQ_INVALID); @@ -310,7 +314,7 @@ void classification_test_pmr_term_tcp_sport(void) enqueue_pktio_interface(pkt, pktio); pkt = receive_packet(&retqueue, ODP_TIME_SEC_IN_NS); - CU_ASSERT(pkt != ODP_PACKET_INVALID); + CU_ASSERT_FATAL(pkt != ODP_PACKET_INVALID); CU_ASSERT(seqno == cls_pkt_get_seq(pkt)); CU_ASSERT(retqueue == queue); recvpool = odp_packet_pool(pkt); @@ -318,6 +322,7 @@ void classification_test_pmr_term_tcp_sport(void) odp_packet_free(pkt); pkt = create_packet(pkt_pool, false, &seq, false); + CU_ASSERT_FATAL(pkt != ODP_PACKET_INVALID); seqno = cls_pkt_get_seq(pkt); CU_ASSERT(seqno != TEST_SEQ_INVALID); @@ -327,7 +332,7 @@ void classification_test_pmr_term_tcp_sport(void) enqueue_pktio_interface(pkt, pktio); pkt = receive_packet(&retqueue, ODP_TIME_SEC_IN_NS); - CU_ASSERT(pkt != ODP_PACKET_INVALID); + CU_ASSERT_FATAL(pkt != ODP_PACKET_INVALID); CU_ASSERT(seqno == cls_pkt_get_seq(pkt)); CU_ASSERT(retqueue == default_queue); recvpool = odp_packet_pool(pkt); @@ -372,6 +377,7 @@ void classification_test_pmr_term_udp_dport(void) seqno = 0; pktio = create_pktio(ODP_QUEUE_TYPE_SCHED); + CU_ASSERT_FATAL(pktio != ODP_PKTIO_INVALID); retval = create_default_inq(pktio, ODP_QUEUE_TYPE_SCHED); CU_ASSERT(retval == 0); @@ -404,6 +410,7 @@ void classification_test_pmr_term_udp_dport(void) configure_default_cos(pktio, &default_cos, &default_queue, &default_pool); pkt = create_packet(pkt_pool, false, &seq, true); + CU_ASSERT_FATAL(pkt != ODP_PACKET_INVALID); seqno = cls_pkt_get_seq(pkt); CU_ASSERT(seqno != TEST_SEQ_INVALID); @@ -413,7 +420,7 @@ void classification_test_pmr_term_udp_dport(void) enqueue_pktio_interface(pkt, pktio); pkt = receive_packet(&retqueue, ODP_TIME_SEC_IN_NS); - CU_ASSERT(pkt != ODP_PACKET_INVALID); + CU_ASSERT_FATAL(pkt != ODP_PACKET_INVALID); CU_ASSERT(seqno == cls_pkt_get_seq(pkt)); CU_ASSERT(retqueue == queue); recvpool = odp_packet_pool(pkt); @@ -422,6 +429,7 @@ void classification_test_pmr_term_udp_dport(void) /* Other packets received in default queue */ pkt = create_packet(pkt_pool, false, &seq, true); + CU_ASSERT_FATAL(pkt != ODP_PACKET_INVALID); seqno = cls_pkt_get_seq(pkt); CU_ASSERT(seqno != TEST_SEQ_INVALID); @@ -431,7 +439,7 @@ void classification_test_pmr_term_udp_dport(void) enqueue_pktio_interface(pkt, pktio); pkt = receive_packet(&retqueue, ODP_TIME_SEC_IN_NS); - CU_ASSERT(pkt != ODP_PACKET_INVALID); + CU_ASSERT_FATAL(pkt != ODP_PACKET_INVALID); CU_ASSERT(seqno == cls_pkt_get_seq(pkt)); CU_ASSERT(retqueue == default_queue); recvpool = odp_packet_pool(pkt); @@ -476,6 +484,7 @@ void classification_test_pmr_term_udp_sport(void) seqno = 0; pktio = create_pktio(ODP_QUEUE_TYPE_SCHED); + CU_ASSERT_FATAL(pktio != ODP_PKTIO_INVALID); retval = create_default_inq(pktio, ODP_QUEUE_TYPE_SCHED); CU_ASSERT(retval == 0); @@ -508,6 +517,7 @@ void classification_test_pmr_term_udp_sport(void) configure_default_cos(pktio, &default_cos, &default_queue, &default_pool); pkt = create_packet(pkt_pool, false, &seq, true); + CU_ASSERT_FATAL(pkt != ODP_PACKET_INVALID); seqno = cls_pkt_get_seq(pkt); CU_ASSERT(seqno != TEST_SEQ_INVALID); @@ -517,7 +527,7 @@ void classification_test_pmr_term_udp_sport(void) enqueue_pktio_interface(pkt, pktio); pkt = receive_packet(&retqueue, ODP_TIME_SEC_IN_NS); - CU_ASSERT(pkt != ODP_PACKET_INVALID); + CU_ASSERT_FATAL(pkt != ODP_PACKET_INVALID); CU_ASSERT(seqno == cls_pkt_get_seq(pkt)); CU_ASSERT(retqueue == queue); recvpool = odp_packet_pool(pkt); @@ -525,6 +535,7 @@ void classification_test_pmr_term_udp_sport(void) odp_packet_free(pkt); pkt = create_packet(pkt_pool, false, &seq, true); + CU_ASSERT_FATAL(pkt != ODP_PACKET_INVALID); seqno = cls_pkt_get_seq(pkt); CU_ASSERT(seqno != TEST_SEQ_INVALID); @@ -534,7 +545,7 @@ void classification_test_pmr_term_udp_sport(void) enqueue_pktio_interface(pkt, pktio); pkt = receive_packet(&retqueue, ODP_TIME_SEC_IN_NS); - CU_ASSERT(pkt != ODP_PACKET_INVALID); + CU_ASSERT_FATAL(pkt != ODP_PACKET_INVALID); CU_ASSERT(seqno == cls_pkt_get_seq(pkt)); CU_ASSERT(retqueue == default_queue); recvpool = odp_packet_pool(pkt); @@ -578,6 +589,7 @@ void classification_test_pmr_term_ipproto(void) seqno = 0; pktio = create_pktio(ODP_QUEUE_TYPE_SCHED); + CU_ASSERT_FATAL(pktio != ODP_PKTIO_INVALID); retval = create_default_inq(pktio, ODP_QUEUE_TYPE_SCHED); CU_ASSERT(retval == 0); @@ -610,13 +622,14 @@ void classification_test_pmr_term_ipproto(void) configure_default_cos(pktio, &default_cos, &default_queue, &default_pool); pkt = create_packet(pkt_pool, false, &seq, true); + CU_ASSERT_FATAL(pkt != ODP_PACKET_INVALID); seqno = cls_pkt_get_seq(pkt); CU_ASSERT(seqno != TEST_SEQ_INVALID); enqueue_pktio_interface(pkt, pktio); pkt = receive_packet(&retqueue, ODP_TIME_SEC_IN_NS); - CU_ASSERT(pkt != ODP_PACKET_INVALID); + CU_ASSERT_FATAL(pkt != ODP_PACKET_INVALID); CU_ASSERT(seqno == cls_pkt_get_seq(pkt)); recvpool = odp_packet_pool(pkt); CU_ASSERT(recvpool == pool); @@ -625,13 +638,14 @@ void classification_test_pmr_term_ipproto(void) /* Other packets delivered to default queue */ pkt = create_packet(pkt_pool, false, &seq, false); + CU_ASSERT_FATAL(pkt != ODP_PACKET_INVALID); seqno = cls_pkt_get_seq(pkt); CU_ASSERT(seqno != TEST_SEQ_INVALID); enqueue_pktio_interface(pkt, pktio); pkt = receive_packet(&retqueue, ODP_TIME_SEC_IN_NS); - CU_ASSERT(pkt != ODP_PACKET_INVALID); + CU_ASSERT_FATAL(pkt != ODP_PACKET_INVALID); CU_ASSERT(seqno == cls_pkt_get_seq(pkt)); recvpool = odp_packet_pool(pkt); CU_ASSERT(recvpool == default_pool); @@ -676,6 +690,7 @@ static void classification_test_pmr_pool_set(void) seqno = 0; pktio = create_pktio(ODP_QUEUE_TYPE_SCHED); + CU_ASSERT_FATAL(pktio != ODP_PKTIO_INVALID); retval = create_default_inq(pktio, ODP_QUEUE_TYPE_SCHED); CU_ASSERT(retval == 0); @@ -715,13 +730,14 @@ static void classification_test_pmr_pool_set(void) configure_default_cos(pktio, &default_cos, &default_queue, &default_pool); pkt = create_packet(pkt_pool, false, &seq, true); + CU_ASSERT_FATAL(pkt != ODP_PACKET_INVALID); seqno = cls_pkt_get_seq(pkt); CU_ASSERT(seqno != TEST_SEQ_INVALID); enqueue_pktio_interface(pkt, pktio); pkt = receive_packet(&retqueue, ODP_TIME_SEC_IN_NS); - CU_ASSERT(pkt != ODP_PACKET_INVALID); + CU_ASSERT_FATAL(pkt != ODP_PACKET_INVALID); CU_ASSERT(seqno == cls_pkt_get_seq(pkt)); recvpool = odp_packet_pool(pkt); CU_ASSERT(recvpool == pool_new); @@ -768,6 +784,7 @@ static void classification_test_pmr_queue_set(void) seqno = 0; pktio = create_pktio(ODP_QUEUE_TYPE_SCHED); + CU_ASSERT_FATAL(pktio != ODP_PKTIO_INVALID); retval = create_default_inq(pktio, ODP_QUEUE_TYPE_SCHED); CU_ASSERT(retval == 0); @@ -807,13 +824,14 @@ static void classification_test_pmr_queue_set(void) configure_default_cos(pktio, &default_cos, &default_queue, &default_pool); pkt = create_packet(pkt_pool, false, &seq, true); + CU_ASSERT_FATAL(pkt != ODP_PACKET_INVALID); seqno = cls_pkt_get_seq(pkt); CU_ASSERT(seqno != TEST_SEQ_INVALID); enqueue_pktio_interface(pkt, pktio); pkt = receive_packet(&retqueue, ODP_TIME_SEC_IN_NS); - CU_ASSERT(pkt != ODP_PACKET_INVALID); + CU_ASSERT_FATAL(pkt != ODP_PACKET_INVALID); CU_ASSERT(seqno == cls_pkt_get_seq(pkt)); recvpool = odp_packet_pool(pkt); CU_ASSERT(recvpool == pool); diff --git a/test/validation/classification/odp_classification_tests.c b/test/validation/classification/odp_classification_tests.c index 99242d0..e11c3d8 100644 --- a/test/validation/classification/odp_classification_tests.c +++ b/test/validation/classification/odp_classification_tests.c @@ -226,6 +226,7 @@ void test_cls_pmr_chain(void) uint32_t seqno = 0; pkt = create_packet(pool_default, false, &seq, true); + CU_ASSERT_FATAL(pkt != ODP_PACKET_INVALID); seqno = cls_pkt_get_seq(pkt); CU_ASSERT(seqno != TEST_SEQ_INVALID); @@ -241,7 +242,7 @@ void test_cls_pmr_chain(void) enqueue_pktio_interface(pkt, pktio_loop); pkt = receive_packet(&queue, ODP_TIME_SEC_IN_NS); - CU_ASSERT(pkt != ODP_PACKET_INVALID); + CU_ASSERT_FATAL(pkt != ODP_PACKET_INVALID); CU_ASSERT(queue == queue_list[CLS_PMR_CHAIN_DST]); CU_ASSERT(seqno == cls_pkt_get_seq(pkt)); pool = odp_packet_pool(pkt); @@ -249,6 +250,7 @@ void test_cls_pmr_chain(void) odp_packet_free(pkt); pkt = create_packet(pool_default, false, &seq, true); + CU_ASSERT_FATAL(pkt != ODP_PACKET_INVALID); seqno = cls_pkt_get_seq(pkt); CU_ASSERT(seqno != TEST_SEQ_INVALID); @@ -260,7 +262,7 @@ void test_cls_pmr_chain(void) enqueue_pktio_interface(pkt, pktio_loop); pkt = receive_packet(&queue, ODP_TIME_SEC_IN_NS); - CU_ASSERT(pkt != ODP_PACKET_INVALID); + CU_ASSERT_FATAL(pkt != ODP_PACKET_INVALID); CU_ASSERT(queue == queue_list[CLS_PMR_CHAIN_SRC]); CU_ASSERT(seqno == cls_pkt_get_seq(pkt)); pool = odp_packet_pool(pkt); @@ -310,13 +312,14 @@ void test_pktio_default_cos(void) odp_pool_t pool; /* create a default packet */ pkt = create_packet(pool_default, false, &seq, true); + CU_ASSERT_FATAL(pkt != ODP_PACKET_INVALID); seqno = cls_pkt_get_seq(pkt); CU_ASSERT(seqno != TEST_SEQ_INVALID); enqueue_pktio_interface(pkt, pktio_loop); pkt = receive_packet(&queue, ODP_TIME_SEC_IN_NS); - CU_ASSERT(pkt != ODP_PACKET_INVALID); + CU_ASSERT_FATAL(pkt != ODP_PACKET_INVALID); /* Default packet should be received in default queue */ CU_ASSERT(queue == queue_list[CLS_DEFAULT]); CU_ASSERT(seqno == cls_pkt_get_seq(pkt)); @@ -370,6 +373,7 @@ void test_pktio_error_cos(void) /*Create an error packet */ pkt = create_packet(pool_default, false, &seq, true); + CU_ASSERT_FATAL(pkt != ODP_PACKET_INVALID); odph_ipv4hdr_t *ip = (odph_ipv4hdr_t *)odp_packet_l3_ptr(pkt, NULL); /* Incorrect IpV4 version */ @@ -378,7 +382,7 @@ void test_pktio_error_cos(void) enqueue_pktio_interface(pkt, pktio_loop); pkt = receive_packet(&queue, ODP_TIME_SEC_IN_NS); - CU_ASSERT(pkt != ODP_PACKET_INVALID); + CU_ASSERT_FATAL(pkt != ODP_PACKET_INVALID); /* Error packet should be received in error queue */ CU_ASSERT(queue == queue_list[CLS_ERROR]); pool = odp_packet_pool(pkt); @@ -480,6 +484,7 @@ void test_cos_with_l2_priority(void) uint8_t i; for (i = 0; i < CLS_L2_QOS_MAX; i++) { pkt = create_packet(pool_default, true, &seq, true); + CU_ASSERT_FATAL(pkt != ODP_PACKET_INVALID); seqno = cls_pkt_get_seq(pkt); CU_ASSERT(seqno != TEST_SEQ_INVALID); ethhdr = (odph_ethhdr_t *)odp_packet_l2_ptr(pkt, NULL); @@ -487,7 +492,7 @@ void test_cos_with_l2_priority(void) vlan->tci = odp_cpu_to_be_16(i << 13); enqueue_pktio_interface(pkt, pktio_loop); pkt = receive_packet(&queue, ODP_TIME_SEC_IN_NS); - CU_ASSERT(pkt != ODP_PACKET_INVALID); + CU_ASSERT_FATAL(pkt != ODP_PACKET_INVALID); CU_ASSERT(queue == queue_list[CLS_L2_QOS_0 + i]); pool = odp_packet_pool(pkt); CU_ASSERT(pool == pool_list[CLS_L2_QOS_0 + i]); @@ -516,7 +521,7 @@ void configure_pmr_cos(void) match.val_sz = sizeof(val); pmr_list[CLS_PMR] = odp_pmr_create(&match); - CU_ASSERT(pmr_list[CLS_PMR] != ODP_PMR_INVAL); + CU_ASSERT_FATAL(pmr_list[CLS_PMR] != ODP_PMR_INVAL); odp_queue_param_init(&qparam); qparam.sched.prio = ODP_SCHED_PRIO_HIGHEST; @@ -555,13 +560,14 @@ void test_pmr_cos(void) uint32_t seqno = 0; pkt = create_packet(pool_default, false, &seq, true); + CU_ASSERT_FATAL(pkt != ODP_PACKET_INVALID); seqno = cls_pkt_get_seq(pkt); CU_ASSERT(seqno != TEST_SEQ_INVALID); udp = (odph_udphdr_t *)odp_packet_l4_ptr(pkt, NULL); udp->src_port = odp_cpu_to_be_16(CLS_PMR_SPORT); enqueue_pktio_interface(pkt, pktio_loop); pkt = receive_packet(&queue, ODP_TIME_SEC_IN_NS); - CU_ASSERT(pkt != ODP_PACKET_INVALID); + CU_ASSERT_FATAL(pkt != ODP_PACKET_INVALID); CU_ASSERT(queue == queue_list[CLS_PMR]); pool = odp_packet_pool(pkt); CU_ASSERT(pool == pool_list[CLS_PMR]); @@ -641,6 +647,7 @@ void test_pktio_pmr_match_set_cos(void) uint32_t seqno = 0; pkt = create_packet(pool_default, false, &seq, true); + CU_ASSERT_FATAL(pkt != ODP_PACKET_INVALID); seqno = cls_pkt_get_seq(pkt); CU_ASSERT(seqno != TEST_SEQ_INVALID); @@ -654,7 +661,7 @@ void test_pktio_pmr_match_set_cos(void) udp->src_port = odp_cpu_to_be_16(CLS_PMR_SET_SPORT); enqueue_pktio_interface(pkt, pktio_loop); pkt = receive_packet(&queue, ODP_TIME_SEC_IN_NS); - CU_ASSERT(pkt != ODP_PACKET_INVALID); + CU_ASSERT_FATAL(pkt != ODP_PACKET_INVALID); CU_ASSERT(queue == queue_list[CLS_PMR_SET]); pool = odp_packet_pool(pkt); CU_ASSERT(pool == pool_list[CLS_PMR_SET]);