Lines Matching refs:vqs
55 struct virtio_blk_vq *vqs; member
238 spin_lock_irqsave(&vblk->vqs[qid].lock, flags); in virtblk_done()
241 while ((vbr = virtqueue_get_buf(vblk->vqs[qid].vq, &len)) != NULL) { in virtblk_done()
254 spin_unlock_irqrestore(&vblk->vqs[qid].lock, flags); in virtblk_done()
260 struct virtio_blk_vq *vq = &vblk->vqs[hctx->queue_num]; in virtio_commit_rqs()
335 spin_lock_irqsave(&vblk->vqs[qid].lock, flags); in virtio_queue_rq()
337 err = virtblk_add_req_scsi(vblk->vqs[qid].vq, vbr, vbr->sg, num); in virtio_queue_rq()
339 err = virtblk_add_req(vblk->vqs[qid].vq, vbr, vbr->sg, num); in virtio_queue_rq()
341 virtqueue_kick(vblk->vqs[qid].vq); in virtio_queue_rq()
343 spin_unlock_irqrestore(&vblk->vqs[qid].lock, flags); in virtio_queue_rq()
351 if (bd->last && virtqueue_kick_prepare(vblk->vqs[qid].vq)) in virtio_queue_rq()
353 spin_unlock_irqrestore(&vblk->vqs[qid].lock, flags); in virtio_queue_rq()
356 virtqueue_notify(vblk->vqs[qid].vq); in virtio_queue_rq()
506 struct virtqueue **vqs; in init_vq() local
519 vblk->vqs = kmalloc_array(num_vqs, sizeof(*vblk->vqs), GFP_KERNEL); in init_vq()
520 if (!vblk->vqs) in init_vq()
525 vqs = kmalloc_array(num_vqs, sizeof(*vqs), GFP_KERNEL); in init_vq()
526 if (!names || !callbacks || !vqs) { in init_vq()
533 snprintf(vblk->vqs[i].name, VQ_NAME_LEN, "req.%d", i); in init_vq()
534 names[i] = vblk->vqs[i].name; in init_vq()
538 err = virtio_find_vqs(vdev, num_vqs, vqs, callbacks, names, &desc); in init_vq()
543 spin_lock_init(&vblk->vqs[i].lock); in init_vq()
544 vblk->vqs[i].vq = vqs[i]; in init_vq()
549 kfree(vqs); in init_vq()
553 kfree(vblk->vqs); in init_vq()
781 virtblk_queue_depth = vblk->vqs[0].vq->num_free; in virtblk_probe()
945 kfree(vblk->vqs); in virtblk_remove()