| Message ID | 1450948220-15758-1-git-send-email-bala.manoharan@linaro.org |
|---|---|
| State | Accepted |
| Commit | 41877180b16b16b09feffaa6fe58098408d87e4d |
| Headers | show |
On Thu, Dec 24, 2015 at 3:10 AM, Balasubramanian Manoharan < bala.manoharan@linaro.org> wrote: > Adds additional ASSERTS for stability in validation suites during failure > > Signed-off-by: Balasubramanian Manoharan <bala.manoharan@linaro.org> > Reviewed-by: Bill Fischofer <bill.fischofer@linaro.org> > --- > .../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]); > -- > 1.9.1 > > _______________________________________________ > lng-odp mailing list > lng-odp@lists.linaro.org > https://lists.linaro.org/mailman/listinfo/lng-odp >
Merged, Maxim. On 12/24/2015 16:14, Bill Fischofer wrote: > > > On Thu, Dec 24, 2015 at 3:10 AM, Balasubramanian Manoharan > <bala.manoharan@linaro.org <mailto:bala.manoharan@linaro.org>> wrote: > > Adds additional ASSERTS for stability in validation suites during > failure > > Signed-off-by: Balasubramanian Manoharan > <bala.manoharan@linaro.org <mailto:bala.manoharan@linaro.org>> > > > Reviewed-by: Bill Fischofer <bill.fischofer@linaro.org > <mailto:bill.fischofer@linaro.org>> > > --- > .../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]); > -- > 1.9.1 > > _______________________________________________ > lng-odp mailing list > lng-odp@lists.linaro.org <mailto:lng-odp@lists.linaro.org> > https://lists.linaro.org/mailman/listinfo/lng-odp > > > > > _______________________________________________ > lng-odp mailing list > lng-odp@lists.linaro.org > https://lists.linaro.org/mailman/listinfo/lng-odp
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]);
Adds additional ASSERTS for stability in validation suites during failure Signed-off-by: Balasubramanian Manoharan <bala.manoharan@linaro.org> --- .../classification/odp_classification_test_pmr.c | 44 +++++++++++++++------- .../classification/odp_classification_tests.c | 23 +++++++---- 2 files changed, 46 insertions(+), 21 deletions(-)