@@ -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, ð->src, sizeof(eth->src));
+ ret = odp_pktio_mac_addr(src, ð->src, sizeof(eth->src));
if (ret <= 0)
memcpy(ð->src, pktio_test_mac_src, sizeof(eth->src));
- ret = odp_pktio_mac_addr(dst->id, ð->dst, sizeof(eth->dst));
+ ret = odp_pktio_mac_addr(dst, ð->dst, sizeof(eth->dst));
if (ret <= 0)
memcpy(ð->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);
}
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(-)