Lines Matching refs:vq

112 	struct spdk_vhost_virtqueue *vq;
277 	struct spdk_vhost_virtqueue *vq;
285 	vq = &vsession->virtqueue[VIRTIO_SCSI_EVENTQ];
287 	if (vq->vring.desc == NULL || vhost_vq_avail_ring_get(vq, &req, 1) != 1) {
293 	rc = vhost_vq_get_desc(vsession, vq, req, &desc, &desc_table, &desc_table_size);
324 	vhost_vq_used_ring_enqueue(vsession, vq, req, req_size);
332 	vhost_vq_used_ring_enqueue(vsession, task->vq, task->req_idx,
389 	vhost_vq_used_ring_enqueue(vsession, task->vq, task->req_idx,
436 	rc = vhost_vq_get_desc(vsession, task->vq, task->req_idx, &desc, &desc_table,
453 		      task->req_idx, desc, (void *)desc->addr, desc->len, desc->flags, task->vq->last_used_idx,
454 		      task->vq->vring.kickfd, task->vq->vring.size);
517 	vhost_vq_used_ring_enqueue(vsession, task->vq, task->req_idx, used_len);
540 	rc = vhost_vq_get_desc(vsession, task->vq, task->req_idx, &desc, &desc_table, &desc_table_len);
694 		  struct spdk_vhost_virtqueue *vq,
700 	task = &((struct spdk_vhost_scsi_task *)vq->tasks)[req_idx];
704 		vhost_vq_used_ring_enqueue(vsession, vq, req_idx, 0);
711 	if (spdk_unlikely(vq->vring_idx == VIRTIO_SCSI_CONTROLQ)) {
733 		     struct spdk_vhost_virtqueue *vq)
741 	resubmit = vq->vring_inflight.resubmit_inflight;
755 		if (spdk_unlikely(req_idx >= vq->vring.size)) {
757 				    vsession->name, req_idx, vq->vring.size);
758 			vhost_vq_used_ring_enqueue(vsession, vq, req_idx, 0);
762 		process_scsi_task(vsession, vq, req_idx);
770 process_vq(struct spdk_vhost_scsi_session *svsession, struct spdk_vhost_virtqueue *vq)
777 	resubmit_cnt = submit_inflight_desc(svsession, vq);
779 	reqs_cnt = vhost_vq_avail_ring_get(vq, reqs, SPDK_COUNTOF(reqs));
786 		if (spdk_unlikely(reqs[i] >= vq->vring.size)) {
788 				    vsession->name, reqs[i], vq->vring.size);
789 			vhost_vq_used_ring_enqueue(vsession, vq, reqs[i], 0);
793 		rte_vhost_set_inflight_desc_split(vsession->vid, vq->vring_idx, reqs[i]);
795 		process_scsi_task(vsession, vq, reqs[i]);
1356 	struct spdk_vhost_virtqueue *vq;
1360 		vq = &vsession->virtqueue[i];
1361 		if (vq->tasks == NULL) {
1365 		spdk_free(vq->tasks);
1366 		vq->tasks = NULL;
1374 	struct spdk_vhost_virtqueue *vq;
1383 	vq = &vsession->virtqueue[qid];
1384 	if (vq->vring.desc == NULL) {
1388 	task_cnt = vq->vring.size;
1395 	vq->tasks = spdk_zmalloc(sizeof(struct spdk_vhost_scsi_task) * task_cnt,
1398 	if (vq->tasks == NULL) {
1405 		task = &((struct spdk_vhost_scsi_task *)vq->tasks)[j];
1407 		task->vq = vq;