[lng-odp] [PATCH 6/9] validation: pktio: initialise packet headers in pktio_test_start_stop()

[Stuart Haslam]

The pktio_test_start_stop() test wasn't initialising packet headers
correctly (source and dest mac, UDP checksum), which can cause test
failures depending on the interfaces being tested and how they're
connected.

Signed-off-by: Stuart Haslam <stuart.has...@linaro.org>
---
 test/validation/pktio/pktio.c | 57 ++++++++++++++++++++++++++++---------------
 1 file changed, 38 insertions(+), 19 deletions(-)

diff --git a/test/validation/pktio/pktio.c b/test/validation/pktio/pktio.c
index 7e0f399..da1442f 100644
--- a/test/validation/pktio/pktio.c
+++ b/test/validation/pktio/pktio.c
@@ -89,17 +89,17 @@ static void set_pool_len(odp_pool_param_t *params)
 }
 
 static void pktio_pkt_set_macs(odp_packet_t pkt,
-                              pktio_info_t *src, pktio_info_t *dst)
+                              odp_pktio_t src, odp_pktio_t dst)
 {
        uint32_t len;
        odph_ethhdr_t *eth = (odph_ethhdr_t *)odp_packet_l2_ptr(pkt, &len);
        int ret;
 
-       ret = odp_pktio_mac_addr(src->id, &eth->src, sizeof(eth->src));
+       ret = odp_pktio_mac_addr(src, &eth->src, sizeof(eth->src));
        if (ret <= 0)
                memcpy(&eth->src, pktio_test_mac_src, sizeof(eth->src));
 
-       ret = odp_pktio_mac_addr(dst->id, &eth->dst, sizeof(eth->dst));
+       ret = odp_pktio_mac_addr(dst, &eth->dst, sizeof(eth->dst));
        if (ret <= 0)
                memcpy(&eth->dst, pktio_test_mac_dst, sizeof(eth->dst));
 }
@@ -235,6 +235,30 @@ static int pktio_fixup_checksums(odp_packet_t pkt)
        return 0;
 }
 
+static odp_packet_t pktio_create_packet(odp_pool_t pool, uint32_t packet_len,
+                                       odp_pktio_t src, odp_pktio_t dst)
+{
+       odp_packet_t pkt;
+
+       pkt = odp_packet_alloc(pool, packet_len);
+       if (pkt == ODP_PACKET_INVALID)
+               return ODP_PACKET_INVALID;
+
+       if (pktio_init_packet(pkt) == TEST_SEQ_INVALID) {
+               odp_packet_free(pkt);
+               return ODP_PACKET_INVALID;
+       }
+
+       pktio_pkt_set_macs(pkt, src, dst);
+
+       if (pktio_fixup_checksums(pkt) != 0) {
+               odp_packet_free(pkt);
+               return ODP_PACKET_INVALID;
+       }
+
+       return pkt;
+}
+
 static int default_pool_create(void)
 {
        odp_pool_param_t params;
@@ -404,18 +428,10 @@ static void pktio_txrx_multi(pktio_info_t *pktio_a, 
pktio_info_t *pktio_b,
 
        /* generate test packets to send */
        for (i = 0; i < num_pkts; ++i) {
-               tx_pkt[i] = odp_packet_alloc(default_pkt_pool, packet_len);
-               if (tx_pkt[i] == ODP_PACKET_INVALID)
-                       break;
-
-               tx_seq[i] = pktio_init_packet(tx_pkt[i]);
-               if (tx_seq[i] == TEST_SEQ_INVALID)
-                       break;
-
-               pktio_pkt_set_macs(tx_pkt[i], pktio_a, pktio_b);
-               if (pktio_fixup_checksums(tx_pkt[i]) != 0)
-                       break;
-
+               tx_pkt[i] = pktio_create_packet(default_pkt_pool, packet_len,
+                                               pktio_a->id, pktio_b->id);
+               CU_ASSERT_FATAL(tx_pkt[i] != ODP_PACKET_INVALID);
+               tx_seq[i] = pktio_pkt_seq(tx_pkt[i]);
                tx_ev[i] = odp_packet_to_event(tx_pkt[i]);
        }
 
@@ -713,6 +729,7 @@ void pktio_test_start_stop(void)
        int i, pkts, ret, alloc = 0;
        odp_queue_t outq;
        uint64_t wait = odp_schedule_wait_time(ODP_TIME_MSEC);
+       odp_pktio_t pktio_dst;
 
        for (i = 0; i < num_ifaces; i++) {
                pktio[i] = create_pktio(iface_name[i], ODP_QUEUE_TYPE_SCHED, 0);
@@ -720,11 +737,13 @@ void pktio_test_start_stop(void)
                create_inq(pktio[i],  ODP_QUEUE_TYPE_SCHED);
        }
 
+       pktio_dst = num_ifaces > 1 ? pktio[1] : pktio[0];
+
        for (alloc = 0; alloc < 1000; alloc++) {
-               pkt = odp_packet_alloc(default_pkt_pool, packet_len);
+               pkt = pktio_create_packet(default_pkt_pool, packet_len,
+                                         pktio[0], pktio_dst);
                if (pkt == ODP_PACKET_INVALID)
                        break;
-               pktio_init_packet(pkt);
                tx_ev[alloc] = odp_packet_to_event(pkt);
        }
 
@@ -779,10 +798,10 @@ void pktio_test_start_stop(void)
 
        /* alloc */
        for (alloc = 0; alloc < 1000; alloc++) {
-               pkt = odp_packet_alloc(default_pkt_pool, packet_len);
+               pkt = pktio_create_packet(default_pkt_pool, packet_len,
+                                         pktio[0], pktio_dst);
                if (pkt == ODP_PACKET_INVALID)
                        break;
-               pktio_init_packet(pkt);
                tx_ev[alloc] = odp_packet_to_event(pkt);
        }
 
-- 
2.1.1

_______________________________________________
lng-odp mailing list
lng-odp@lists.linaro.org
https://lists.linaro.org/mailman/listinfo/lng-odp