Function new_device

dpdk/examples/vhost_blk/vhost_blk.c:592–690

}

static int
new_device(int vid)
{
	struct vhost_blk_ctrlr *ctrlr;
	struct vhost_blk_queue *vq;
	char path[PATH_MAX];
	uint64_t features, protocol_features;
	rte_thread_t tid;
	int i, ret;
	bool packed_ring, inflight_shmfd;

	ret = rte_vhost_get_ifname(vid, path, PATH_MAX);
	if (ret) {
		fprintf(stderr, "Failed to get the socket path\n");
		return -1;
	}

	ctrlr = vhost_blk_ctrlr_find(path);
	if (!ctrlr) {
		fprintf(stderr, "Failed to find controller\n");
		return -1;
	}

	if (ctrlr->started)
		return 0;

	ctrlr->vid = vid;
	ret = rte_vhost_get_negotiated_features(vid, &features);
	if (ret) {
		fprintf(stderr, "Failed to get the negotiated features\n");
		return -1;
	}
	packed_ring = !!(features & (1ULL << VIRTIO_F_RING_PACKED));

	ret = rte_vhost_get_negotiated_protocol_features(
		vid, &protocol_features);
	if (ret) {
		fprintf(stderr,
			"Failed to get the negotiated protocol features\n");
		return -1;
	}
	inflight_shmfd = !!(features &
			    (1ULL << VHOST_USER_PROTOCOL_F_INFLIGHT_SHMFD));

	/* Disable Notifications and init last idx */
	for (i = 0; i < NUM_OF_BLK_QUEUES; i++) {
		vq = &ctrlr->queues[i];
		vq->id = i;

		assert(rte_vhost_get_vhost_vring(ctrlr->vid, i,
						 &vq->vring) == 0);
		assert(rte_vhost_get_vring_base(ctrlr->vid, i,
					       &vq->last_avail_idx,
					       &vq->last_used_idx) == 0);

		if (inflight_shmfd)
			assert(rte_vhost_get_vhost_ring_inflight(
				       ctrlr->vid, i,