Function process_packets

dpdk/examples/server_node_efd/efd_server/main.c:257–297

Processing packets. 8< */

/* Processing packets. 8< */
static void
process_packets(uint32_t port_num __rte_unused, struct rte_mbuf *pkts[],
		uint16_t rx_count, unsigned int socket_id)
{
	uint16_t i;
	uint8_t node;
	efd_value_t data[RTE_EFD_BURST_MAX];
	const void *key_ptrs[RTE_EFD_BURST_MAX];

	struct rte_ipv4_hdr *ipv4_hdr;
	uint32_t ipv4_dst_ip[RTE_EFD_BURST_MAX];

	for (i = 0; i < rx_count; i++) {
		/* Handle IPv4 header.*/
		ipv4_hdr = rte_pktmbuf_mtod_offset(pkts[i],
			struct rte_ipv4_hdr *, sizeof(struct rte_ether_hdr));
		ipv4_dst_ip[i] = ipv4_hdr->dst_addr;
		key_ptrs[i] = (void *)&ipv4_dst_ip[i];
	}

	rte_efd_lookup_bulk(efd_table, socket_id, rx_count,
				(const void **) key_ptrs, data);
	for (i = 0; i < rx_count; i++) {
		node = (uint8_t) ((uintptr_t)data[i]);

		if (node >= num_nodes) {
			/*
			 * Node is out of range, which means that
			 * flow has not been inserted
			 */
			flow_dist_stats.drop++;
			rte_pktmbuf_free(pkts[i]);
		} else {
			flow_dist_stats.distributed++;
			enqueue_rx_packet(node, pkts[i]);
		}
	}

	for (i = 0; i < num_nodes; i++)
		flush_rx_queue(i);
}
/* >8 End of process_packets. */

/*