Function virtio_tx_local

dpdk/examples/vhost/main.c:1121–1164

* Check if the packet destination MAC address is for a local device. If so then put * the packet on that devices RX queue. If not then return. */

 * the packet on that devices RX queue. If not then return.
 */
static __rte_always_inline int
virtio_tx_local(struct vhost_dev *vdev, struct rte_mbuf *m)
{
	struct rte_ether_hdr *pkt_hdr;
	struct vhost_dev *dst_vdev;
	struct vhost_bufftable *vhost_txq;
	uint16_t lcore_id = rte_lcore_id();
	pkt_hdr = rte_pktmbuf_mtod(m, struct rte_ether_hdr *);

	dst_vdev = find_vhost_dev(&pkt_hdr->dst_addr);
	if (!dst_vdev)
		return -1;

	if (vdev->vid == dst_vdev->vid) {
		RTE_LOG_DP(DEBUG, VHOST_DATA,
			"(%d) TX: src and dst MAC is same. Dropping packet.\n",
			vdev->vid);
		return 0;
	}

	RTE_LOG_DP(DEBUG, VHOST_DATA,
		"(%d) TX: MAC address is local\n", dst_vdev->vid);

	if (unlikely(dst_vdev->remove)) {
		RTE_LOG_DP(DEBUG, VHOST_DATA,
			"(%d) device is marked for removal\n", dst_vdev->vid);
		return 0;
	}

	vhost_txq = vhost_txbuff[lcore_id * RTE_MAX_VHOST_DEVICE + dst_vdev->vid];
	vhost_txq->m_table[vhost_txq->len++] = m;

	if (enable_stats) {
		vdev->stats.tx_total++;
		vdev->stats.tx++;
	}

	if (unlikely(vhost_txq->len == MAX_PKT_BURST)) {
		drain_vhost(dst_vdev);
		vhost_txq->len = 0;
		vhost_txq->pre_tsc = rte_rdtsc();
	}
	return 0;
}

/*
 * Check if the destination MAC of a packet is one local VM,