Function eth_vhost_install_intr

dpdk/drivers/net/vhost/rte_eth_vhost.c:635–703

}

static int
eth_vhost_install_intr(struct rte_eth_dev *dev)
{
	int nb_rxq = dev->data->nb_rx_queues;
	struct vhost_queue *vq;

	int ret;
	int i;

	dev->intr_handle = rte_intr_instance_alloc(RTE_INTR_INSTANCE_F_PRIVATE);
	if (dev->intr_handle == NULL) {
		VHOST_LOG(ERR, "Fail to allocate intr_handle\n");
		ret = -ENOMEM;
		goto error;
	}
	if (rte_intr_efd_counter_size_set(dev->intr_handle, 0)) {
		ret = -rte_errno;
		goto error;
	}

	if (rte_intr_vec_list_alloc(dev->intr_handle, NULL, nb_rxq)) {
		VHOST_LOG(ERR, "Failed to allocate memory for interrupt vector\n");
		ret = -ENOMEM;
		goto error;
	}

	VHOST_LOG(DEBUG, "Prepare intr vec\n");
	for (i = 0; i < nb_rxq; i++) {
		int epoll_fd = epoll_create1(0);

		if (epoll_fd < 0) {
			VHOST_LOG(ERR, "Failed to create proxy epoll fd for rxq-%d\n", i);
			ret = -errno;
			goto error;
		}

		if (rte_intr_vec_list_index_set(dev->intr_handle, i,
				RTE_INTR_VEC_RXTX_OFFSET + i) ||
				rte_intr_efds_index_set(dev->intr_handle, i, epoll_fd)) {
			ret = -rte_errno;
			close(epoll_fd);
			goto error;
		}

		vq = dev->data->rx_queues[i];
		memset(&vq->ev, 0, sizeof(vq->ev));
		vq->ev.events = EPOLLIN;
		vq->ev.data.fd = epoll_fd;
	}

	if (rte_intr_nb_efd_set(dev->intr_handle, nb_rxq)) {
		ret = -rte_errno;
		goto error;
	}
	if (rte_intr_max_intr_set(dev->intr_handle, nb_rxq + 1)) {
		ret = -rte_errno;
		goto error;
	}