[6/9] validation: pktio: initialise packet headers in pktio_test_start_stop()

Message ID 1446060551-21029-7-git-send-email-stuart.haslam@linaro.org
State New
Headers show

Commit Message

Stuart Haslam Oct. 28, 2015, 7:29 p.m.
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.haslam@linaro.org>
---
 test/validation/pktio/pktio.c | 57 ++++++++++++++++++++++++++++---------------
 1 file changed, 38 insertions(+), 19 deletions(-)

Patch

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);
 	}