Rework the way test packets are generated in order to allow generating and verifying arbitrary length packets.
Signed-off-by: Stuart Haslam <[email protected]> --- test/validation/odp_pktio.c | 140 ++++++++++++++++++-------------------------- 1 file changed, 58 insertions(+), 82 deletions(-) diff --git a/test/validation/odp_pktio.c b/test/validation/odp_pktio.c index 5ea45e4..a078efe 100644 --- a/test/validation/odp_pktio.c +++ b/test/validation/odp_pktio.c @@ -14,11 +14,10 @@ #include <stdlib.h> #define PKT_BUF_NUM 32 -#define PKT_BUF_SIZE 1856 -#define PKT_BUF_JUMBO_SIZE (9*1024) -#define PKT_BUF_JUMBO_MAX_PAYLOAD (PKT_BUF_JUMBO_SIZE -\ - (ODPH_UDPHDR_LEN +\ - ODPH_IPV4HDR_LEN + ODPH_ETHHDR_LEN)) +#define PKT_BUF_SIZE (9*1024) +#define PKT_LEN_NORMAL 64 +#define PKT_LEN_JUMBO (PKT_BUF_SIZE - ODPH_ETHHDR_LEN - \ + ODPH_IPV4HDR_LEN - ODPH_UDPHDR_LEN) #define MAX_NUM_IFACES 2 #define TEST_SEQ_INVALID ((uint32_t)~0) #define TEST_SEQ_MAGIC 0x92749451 @@ -37,20 +36,19 @@ typedef struct { odp_queue_t inq; } pktio_info_t; +/** magic number and sequence at start of UDP payload */ typedef struct ODP_PACKED { uint32be_t magic; uint32be_t seq; } pkt_head_t; -/** structure of test packet UDP payload */ +/** magic number at end of UDP payload */ typedef struct ODP_PACKED { - pkt_head_t head; - char data[PKT_BUF_JUMBO_MAX_PAYLOAD - sizeof(pkt_head_t) - - sizeof(uint32be_t)]; - uint32be_t magic2; -} pkt_test_data_t; + uint32be_t magic; +} pkt_tail_t; -static int test_jumbo; +/** size of transmitted packets */ +static uint32_t packet_len = PKT_LEN_NORMAL; /** default packet pool */ odp_pool_t default_pkt_pool = ODP_POOL_INVALID; @@ -72,87 +70,76 @@ static void pktio_pkt_set_macs(odp_packet_t pkt, CU_ASSERT(ret == ODPH_ETHADDR_LEN); } -static uint32_t pkt_payload_len(void) -{ - return test_jumbo ? sizeof(pkt_test_data_t) : sizeof(pkt_head_t); -} - -static int pktio_pkt_set_seq(odp_packet_t pkt) +static uint32_t pktio_pkt_set_seq(odp_packet_t pkt) { static uint32_t tstseq; - size_t l4_off; - pkt_test_data_t *data; - uint32_t len = pkt_payload_len(); - + size_t off; + pkt_head_t head; + pkt_tail_t tail; - l4_off = odp_packet_l4_offset(pkt); - if (!l4_off) { + off = odp_packet_l4_offset(pkt); + if (off == ODP_PACKET_OFFSET_INVALID) { CU_FAIL("packet L4 offset not set"); - return -1; + return TEST_SEQ_INVALID; } - data = calloc(1, len); - CU_ASSERT_FATAL(data != NULL); + head.magic = TEST_SEQ_MAGIC; + head.seq = tstseq; - data->head.magic = TEST_SEQ_MAGIC; - if (test_jumbo) - data->magic2 = TEST_SEQ_MAGIC; - data->head.seq = tstseq; + off += ODPH_UDPHDR_LEN; + if (odp_packet_copydata_in(pkt, off, sizeof(head), &head) != 0) + return TEST_SEQ_INVALID; + + tail.magic = TEST_SEQ_MAGIC; + off = odp_packet_len(pkt) - sizeof(pkt_tail_t); + if (odp_packet_copydata_in(pkt, off, sizeof(tail), &tail) != 0) + return TEST_SEQ_INVALID; - odp_packet_copydata_in(pkt, l4_off+ODPH_UDPHDR_LEN, - len, data); - free(data); tstseq++; - return 0; + return head.seq; } static uint32_t pktio_pkt_seq(odp_packet_t pkt) { - size_t l4_off; + size_t off; uint32_t seq = TEST_SEQ_INVALID; - pkt_test_data_t *data; - uint32_t len = pkt_payload_len(); + pkt_head_t head; + pkt_tail_t tail; - l4_off = odp_packet_l4_offset(pkt); - if (l4_off == ODP_PACKET_OFFSET_INVALID) + off = odp_packet_l4_offset(pkt); + if (off == ODP_PACKET_OFFSET_INVALID) return TEST_SEQ_INVALID; - data = calloc(1, len); - CU_ASSERT_FATAL(data != NULL); + off += ODPH_UDPHDR_LEN; + if (odp_packet_copydata_out(pkt, off, sizeof(head), &head) != 0) + return TEST_SEQ_INVALID; - odp_packet_copydata_out(pkt, l4_off+ODPH_UDPHDR_LEN, - len, data); + if (head.magic != TEST_SEQ_MAGIC) + return TEST_SEQ_INVALID; - if (data->head.magic == TEST_SEQ_MAGIC) { - if (test_jumbo && data->magic2 != TEST_SEQ_MAGIC) { - free(data); + if (odp_packet_len(pkt) == packet_len) { + off = packet_len - sizeof(tail); + if (odp_packet_copydata_out(pkt, off, sizeof(tail), &tail) != 0) return TEST_SEQ_INVALID; - } - seq = data->head.seq; + + if (tail.magic == TEST_SEQ_MAGIC) + seq = head.seq; } - free(data); return seq; } -static odp_packet_t pktio_create_packet(void) +static uint32_t pktio_init_packet(odp_packet_t pkt) { - odp_packet_t pkt; odph_ethhdr_t *eth; odph_ipv4hdr_t *ip; odph_udphdr_t *udp; char *buf; uint16_t seq; - size_t payload_len = pkt_payload_len(); uint8_t mac[ODPH_ETHADDR_LEN] = {0}; + int pkt_len = odp_packet_len(pkt); - pkt = odp_packet_alloc(default_pkt_pool, payload_len + ODPH_UDPHDR_LEN + - ODPH_IPV4HDR_LEN + ODPH_ETHHDR_LEN); - if (pkt == ODP_PACKET_INVALID) { - CU_FAIL("failed to allocate packet buffer"); - return ODP_PACKET_INVALID; - } buf = odp_packet_data(pkt); /* Ethernet */ @@ -168,8 +155,7 @@ static odp_packet_t pktio_create_packet(void) ip->dst_addr = odp_cpu_to_be_32(0); ip->src_addr = odp_cpu_to_be_32(0); ip->ver_ihl = ODPH_IPV4 << 4 | ODPH_IPV4HDR_IHL_MIN; - ip->tot_len = odp_cpu_to_be_16(payload_len + ODPH_UDPHDR_LEN + - ODPH_IPV4HDR_LEN); + ip->tot_len = odp_cpu_to_be_16(pkt_len - ODPH_ETHHDR_LEN); ip->ttl = 128; ip->proto = ODPH_IPPROTO_UDP; seq = odp_atomic_fetch_inc_u32(&ip_seq); @@ -182,15 +168,11 @@ static odp_packet_t pktio_create_packet(void) udp = (odph_udphdr_t *)(buf + ODPH_ETHHDR_LEN + ODPH_IPV4HDR_LEN); udp->src_port = odp_cpu_to_be_16(0); udp->dst_port = odp_cpu_to_be_16(0); - udp->length = odp_cpu_to_be_16(payload_len + ODPH_UDPHDR_LEN); + udp->length = odp_cpu_to_be_16(pkt_len - + ODPH_ETHHDR_LEN - ODPH_IPV4HDR_LEN); udp->chksum = 0; - if (pktio_pkt_set_seq(pkt) != 0) { - odp_packet_free(pkt); - return ODP_PACKET_INVALID; - } - - return pkt; + return pktio_pkt_set_seq(pkt); } static int pktio_fixup_checksums(odp_packet_t pkt) @@ -224,8 +206,8 @@ static int default_pool_create(void) return -1; memset(¶ms, 0, sizeof(params)); - params.pkt.seg_len = PKT_BUF_JUMBO_SIZE; - params.pkt.len = PKT_BUF_JUMBO_SIZE; + params.pkt.seg_len = PKT_BUF_SIZE; + params.pkt.len = PKT_BUF_SIZE; params.pkt.num = PKT_BUF_NUM; params.type = ODP_POOL_PACKET; @@ -245,14 +227,8 @@ static odp_pktio_t create_pktio(const char *iface) odp_pool_param_t params; memset(¶ms, 0, sizeof(params)); - if (test_jumbo) { - params.pkt.seg_len = PKT_BUF_JUMBO_SIZE; - params.pkt.len = PKT_BUF_JUMBO_SIZE; - - } else { - params.pkt.seg_len = PKT_BUF_SIZE; - params.pkt.len = PKT_BUF_SIZE; - } + params.pkt.seg_len = PKT_BUF_SIZE; + params.pkt.len = PKT_BUF_SIZE; params.pkt.num = PKT_BUF_NUM; params.type = ODP_POOL_PACKET; @@ -393,11 +369,11 @@ 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] = pktio_create_packet(); + tx_pkt[i] = odp_packet_alloc(default_pkt_pool, packet_len); if (tx_pkt[i] == ODP_PACKET_INVALID) break; - tx_seq[i] = pktio_pkt_seq(tx_pkt[i]); + tx_seq[i] = pktio_init_packet(tx_pkt[i]); if (tx_seq[i] == TEST_SEQ_INVALID) break; @@ -500,9 +476,9 @@ static void test_odp_pktio_sched_multi(void) static void test_odp_pktio_jumbo(void) { - test_jumbo = 1; + packet_len = PKT_LEN_JUMBO; test_odp_pktio_sched_multi(); - test_jumbo = 0; + packet_len = PKT_LEN_NORMAL; } static void test_odp_pktio_mtu(void) -- 2.1.1 _______________________________________________ lng-odp mailing list [email protected] https://lists.linaro.org/mailman/listinfo/lng-odp
