Function pipeline_tx_first

dpdk/app/test-eventdev/test_pipeline_common.c:131–210

}

static void
pipeline_tx_first(struct test_pipeline *t, struct evt_options *opt)
{
#define TX_DEF_PACKET_LEN 64
	uint16_t eth_port_id = 0;
	uint16_t pkt_sz, rc;
	uint32_t i;

	pkt_sz = opt->tx_pkt_sz;
	if (pkt_sz > opt->max_pkt_sz)
		pkt_sz = opt->max_pkt_sz;
	if (!pkt_sz)
		pkt_sz = TX_DEF_PACKET_LEN;

	RTE_ETH_FOREACH_DEV(eth_port_id) {
		struct rte_ether_addr src_mac;
		struct rte_ether_addr dst_mac;
		struct rte_ether_hdr eth_hdr;

		/* Send to the same dest.mac as port mac */
		rte_eth_macaddr_get(eth_port_id, &dst_mac);
		rte_eth_random_addr((uint8_t *)&src_mac);

		rte_ether_addr_copy(&dst_mac, &eth_hdr.dst_addr);
		rte_ether_addr_copy(&src_mac, &eth_hdr.src_addr);
		eth_hdr.ether_type = rte_cpu_to_be_16(RTE_ETHER_TYPE_IPV4);

		for (i = 0; i < opt->tx_first; i++) {
			struct rte_udp_hdr *pkt_udp_hdr;
			struct rte_ipv4_hdr ip_hdr;
			struct rte_udp_hdr udp_hdr;
			struct rte_mbuf *mbuf;

			mbuf = rte_pktmbuf_alloc(
				opt->per_port_pool ? t->pool[i] : t->pool[0]);
			if (mbuf == NULL)
				continue;

			setup_pkt_udp_ip_headers(
				&ip_hdr, &udp_hdr,
				pkt_sz - sizeof(struct rte_ether_hdr) -
					sizeof(struct rte_ipv4_hdr) -
					sizeof(struct rte_udp_hdr),
				eth_port_id, i);
			mbuf->port = eth_port_id;
			mbuf->data_len = pkt_sz;
			mbuf->pkt_len = pkt_sz;

			/* Copy Ethernet header */
			rte_memcpy(rte_pktmbuf_mtod_offset(mbuf, char *, 0),
				   &eth_hdr, sizeof(struct rte_ether_hdr));

			/* Copy Ipv4 header */
			rte_memcpy(rte_pktmbuf_mtod_offset(
					   mbuf, char *,
					   sizeof(struct rte_ether_hdr)),
				   &ip_hdr, sizeof(struct rte_ipv4_hdr));