Lines Matching refs:vqs

82 	struct virtio_blk_vq *vqs;  member
107 struct virtio_blk_vq *vq = &vblk->vqs[hctx->queue_num]; in get_virtio_blk_vq()
284 spin_lock_irqsave(&vblk->vqs[qid].lock, flags); in virtblk_done()
287 while ((vbr = virtqueue_get_buf(vblk->vqs[qid].vq, &len)) != NULL) { in virtblk_done()
301 spin_unlock_irqrestore(&vblk->vqs[qid].lock, flags); in virtblk_done()
307 struct virtio_blk_vq *vq = &vblk->vqs[hctx->queue_num]; in virtio_commit_rqs()
356 spin_lock_irqsave(&vblk->vqs[qid].lock, flags); in virtio_queue_rq()
357 err = virtblk_add_req(vblk->vqs[qid].vq, vbr); in virtio_queue_rq()
359 virtqueue_kick(vblk->vqs[qid].vq); in virtio_queue_rq()
365 spin_unlock_irqrestore(&vblk->vqs[qid].lock, flags); in virtio_queue_rq()
378 if (bd->last && virtqueue_kick_prepare(vblk->vqs[qid].vq)) in virtio_queue_rq()
380 spin_unlock_irqrestore(&vblk->vqs[qid].lock, flags); in virtio_queue_rq()
383 virtqueue_notify(vblk->vqs[qid].vq); in virtio_queue_rq()
610 struct virtqueue **vqs; in init_vq() local
642 vblk->vqs = kmalloc_array(num_vqs, sizeof(*vblk->vqs), GFP_KERNEL); in init_vq()
643 if (!vblk->vqs) in init_vq()
648 vqs = kmalloc_array(num_vqs, sizeof(*vqs), GFP_KERNEL); in init_vq()
649 if (!names || !callbacks || !vqs) { in init_vq()
656 snprintf(vblk->vqs[i].name, VQ_NAME_LEN, "req.%d", i); in init_vq()
657 names[i] = vblk->vqs[i].name; in init_vq()
662 snprintf(vblk->vqs[i].name, VQ_NAME_LEN, "req_poll.%d", i); in init_vq()
663 names[i] = vblk->vqs[i].name; in init_vq()
667 err = virtio_find_vqs(vdev, num_vqs, vqs, callbacks, names, &desc); in init_vq()
672 spin_lock_init(&vblk->vqs[i].lock); in init_vq()
673 vblk->vqs[i].vq = vqs[i]; in init_vq()
678 kfree(vqs); in init_vq()
682 kfree(vblk->vqs); in init_vq()
941 queue_depth = vblk->vqs[0].vq->num_free; in virtblk_probe()
1162 kfree(vblk->vqs); in virtblk_probe()
1190 kfree(vblk->vqs); in virtblk_remove()
1211 kfree(vblk->vqs); in virtblk_freeze()