Function mlx5_txpp_start_service

dpdk/drivers/net/mlx5/mlx5_txpp.c:750–794

Attach interrupt handler and fires first request to Rearm Queue. */

/* Attach interrupt handler and fires first request to Rearm Queue. */
static int
mlx5_txpp_start_service(struct mlx5_dev_ctx_shared *sh)
{
	uint16_t event_nums[1] = {0};
	int ret;
	int fd;

	sh->txpp.err_miss_int = 0;
	sh->txpp.err_rearm_queue = 0;
	sh->txpp.err_clock_queue = 0;
	sh->txpp.err_ts_past = 0;
	sh->txpp.err_ts_future = 0;
	sh->txpp.err_ts_order = 0;
	/* Attach interrupt handler to process Rearm Queue completions. */
	fd = mlx5_os_get_devx_channel_fd(sh->txpp.echan);
	ret = mlx5_os_set_nonblock_channel_fd(fd);
	if (ret) {
		DRV_LOG(ERR, "Failed to change event channel FD.");
		rte_errno = errno;
		return -rte_errno;
	}
	fd = mlx5_os_get_devx_channel_fd(sh->txpp.echan);
	sh->txpp.intr_handle = mlx5_os_interrupt_handler_create
		(RTE_INTR_INSTANCE_F_SHARED, false,
		 fd, mlx5_txpp_interrupt_handler, sh);
	if (!sh->txpp.intr_handle) {
		DRV_LOG(ERR, "Fail to allocate intr_handle");
		return -rte_errno;
	}
	/* Subscribe CQ event to the event channel controlled by the driver. */
	ret = mlx5_os_devx_subscribe_devx_event(sh->txpp.echan,
					    sh->txpp.rearm_queue.cq_obj.cq->obj,
					     sizeof(event_nums), event_nums, 0);
	if (ret) {
		DRV_LOG(ERR, "Failed to subscribe CQE event.");
		rte_errno = errno;
		return -errno;
	}
	/* Enable interrupts in the CQ. */
	mlx5_txpp_cq_arm(sh);
	/* Fire the first request on Rearm Queue. */
	mlx5_txpp_doorbell_rearm_queue(sh, sh->txpp.rearm_queue.sq_size - 1);
	mlx5_txpp_init_timestamp(sh);
	return 0;
}

/*
 * The routine initializes the packet pacing infrastructure: