drivers/vhost/test.c

45 	struct vhost_virtqueue *vq = &n->vqs[VHOST_TEST_VQ];
51 	mutex_lock(&vq->mutex);
52 	private = vhost_vq_get_backend(vq);
54 		mutex_unlock(&vq->mutex);
58 	vhost_disable_notify(&n->dev, vq);
61 		head = vhost_get_vq_desc(vq, vq->iov,
62 					 ARRAY_SIZE(vq->iov),
69 		if (head == vq->num) {
70 			if (unlikely(vhost_enable_notify(&n->dev, vq))) {
71 				vhost_disable_notify(&n->dev, vq);
77 			vq_err(vq, "Unexpected descriptor format for TX: "
81 		len = iov_length(vq->iov, out);
84 			vq_err(vq, "Unexpected 0 len for TX\n");
87 		vhost_add_used_and_signal(&n->dev, vq, head, 0);
89 		if (unlikely(vhost_exceeds_weight(vq, 0, total_len)))
93 	mutex_unlock(&vq->mutex);
98 	struct vhost_virtqueue *vq = container_of(work, struct vhost_virtqueue,
100 	struct vhost_test *n = container_of(vq->dev, struct vhost_test, dev);
131 				struct vhost_virtqueue *vq)
135 	mutex_lock(&vq->mutex);
136 	private = vhost_vq_get_backend(vq);
137 	vhost_vq_set_backend(vq, NULL);
138 	mutex_unlock(&vq->mutex);
169 	struct vhost_virtqueue *vq;
189 		vq = n->vqs + index;
190 		mutex_lock(&vq->mutex);
194 		oldpriv = vhost_vq_get_backend(vq);
195 		vhost_vq_set_backend(vq, priv);
199 		mutex_unlock(&vq->mutex);
243 	struct vhost_virtqueue *vq;
251 	vq = &n->vqs[VHOST_TEST_VQ];
252 	mutex_lock(&vq->mutex);
253 	vq->acked_features = features;
254 	mutex_unlock(&vq->mutex);
264 	struct vhost_virtqueue *vq;
276 	vq = &n->vqs[index];
277 	mutex_lock(&vq->mutex);
280 	if (!vhost_vq_access_ok(vq)) {
285 		vhost_poll_stop(&vq->poll);
286 		backend = vhost_vq_get_backend(vq);
287 		vhost_vq_set_backend(vq, NULL);
289 		vhost_vq_set_backend(vq, backend);
290 		r = vhost_vq_init_access(vq);
292 			r = vhost_poll_start(&vq->poll, vq->kick);
295 	mutex_unlock(&vq->mutex);
305 	mutex_unlock(&vq->mutex);