Proxmox-Port/qemu
1
0
Fork 0
mirror of https://github.com/qemu/qemu.git synced 2025-08-08 08:05:17 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

virtio-blk: associate request with a virtqueue

Browse Source 
Multiqueue requires that each request knows to which virtqueue it
belongs.

Signed-off-by: Stefan Hajnoczi <stefanha@redhat.com>
Reviewed-by: Fam Zheng <famz@redhat.com>
Message-id: 1466511196-12612-5-git-send-email-stefanha@redhat.com
Signed-off-by: Stefan Hajnoczi <stefanha@redhat.com>
This commit is contained in:
Stefan Hajnoczi 2016-06-21 13:13:13 +01:00
parent b234cdda95
commit edaffd9f0b
2 changed files with 14 additions and 10 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

20
hw/block/virtio-blk.c
View File

@ -29,9 +29,11 @@
#include "hw/virtio/virtio-bus.h" #include "hw/virtio/virtio-bus.h"
#include "hw/virtio/virtio-access.h" #include "hw/virtio/virtio-access.h"
void virtio_blk_init_request(VirtIOBlock *s, VirtIOBlockReq *req) void virtio_blk_init_request(VirtIOBlock *s, VirtQueue *vq,
VirtIOBlockReq *req)
{ {
req->dev = s; req->dev = s;
req->vq = vq;
req->qiov.size = 0; req->qiov.size = 0;
req->in_len = 0; req->in_len = 0;
req->next = NULL; req->next = NULL;
@ -53,11 +55,11 @@ static void virtio_blk_req_complete(VirtIOBlockReq *req, unsigned char status)
trace_virtio_blk_req_complete(req, status); trace_virtio_blk_req_complete(req, status);
stb_p(&req->in->status, status); stb_p(&req->in->status, status);
virtqueue_push(s->vq, &req->elem, req->in_len); virtqueue_push(req->vq, &req->elem, req->in_len);
if (s->dataplane_started && !s->dataplane_disabled) { if (s->dataplane_started && !s->dataplane_disabled) {
virtio_blk_data_plane_notify(s->dataplane, s->vq); virtio_blk_data_plane_notify(s->dataplane, req->vq);
} else { } else {
virtio_notify(vdev, s->vq); virtio_notify(vdev, req->vq);
} }
} }
@ -187,12 +189,12 @@ out:
#endif #endif
static VirtIOBlockReq *virtio_blk_get_request(VirtIOBlock *s) static VirtIOBlockReq *virtio_blk_get_request(VirtIOBlock *s, VirtQueue *vq)
{ {
VirtIOBlockReq *req = virtqueue_pop(s->vq, sizeof(VirtIOBlockReq)); VirtIOBlockReq *req = virtqueue_pop(vq, sizeof(VirtIOBlockReq));
if (req) { if (req) {
virtio_blk_init_request(s, req); virtio_blk_init_request(s, vq, req);
} }
return req; return req;
} }
@ -583,7 +585,7 @@ void virtio_blk_handle_vq(VirtIOBlock *s, VirtQueue *vq)
blk_io_plug(s->blk); blk_io_plug(s->blk);
while ((req = virtio_blk_get_request(s))) { while ((req = virtio_blk_get_request(s, vq))) {
virtio_blk_handle_request(req, &mrb); virtio_blk_handle_request(req, &mrb);
} }
@ -831,7 +833,7 @@ static int virtio_blk_load_device(VirtIODevice *vdev, QEMUFile *f,
while (qemu_get_sbyte(f)) { while (qemu_get_sbyte(f)) {
VirtIOBlockReq *req; VirtIOBlockReq *req;
req = qemu_get_virtqueue_element(f, sizeof(VirtIOBlockReq)); req = qemu_get_virtqueue_element(f, sizeof(VirtIOBlockReq));
virtio_blk_init_request(s, req); virtio_blk_init_request(s, s->vq, req);
req->next = s->rq; req->next = s->rq;
s->rq = req; s->rq = req;
} }

4
include/hw/virtio/virtio-blk.h
View File

@ -63,6 +63,7 @@ typedef struct VirtIOBlockReq {
VirtQueueElement elem; VirtQueueElement elem;
int64_t sector_num; int64_t sector_num;
VirtIOBlock *dev; VirtIOBlock *dev;
VirtQueue *vq;
struct virtio_blk_inhdr *in; struct virtio_blk_inhdr *in;
struct virtio_blk_outhdr out; struct virtio_blk_outhdr out;
QEMUIOVector qiov; QEMUIOVector qiov;
@ -80,7 +81,8 @@ typedef struct MultiReqBuffer {
bool is_write; bool is_write;
} MultiReqBuffer; } MultiReqBuffer;
void virtio_blk_init_request(VirtIOBlock *s, VirtIOBlockReq *req); void virtio_blk_init_request(VirtIOBlock *s, VirtQueue *vq,
VirtIOBlockReq *req);
void virtio_blk_free_request(VirtIOBlockReq *req); void virtio_blk_free_request(VirtIOBlockReq *req);
void virtio_blk_handle_request(VirtIOBlockReq *req, MultiReqBuffer *mrb); void virtio_blk_handle_request(VirtIOBlockReq *req, MultiReqBuffer *mrb);