From mboxrd@z Thu Jan 1 00:00:00 1970 Received: from eggs.gnu.org ([2001:4830:134:3::10]:46015) by lists.gnu.org with esmtp (Exim 4.71) (envelope-from ) id 1XPw9l-0004JA-Ax for qemu-devel@nongnu.org; Fri, 05 Sep 2014 12:14:43 -0400 Received: from Debian-exim by eggs.gnu.org with spam-scanned (Exim 4.71) (envelope-from ) id 1XPw9e-0005xC-Qn for qemu-devel@nongnu.org; Fri, 05 Sep 2014 12:14:37 -0400 Received: from mx1.redhat.com ([209.132.183.28]:19051) by eggs.gnu.org with esmtp (Exim 4.71) (envelope-from ) id 1XPw9e-0005wu-KC for qemu-devel@nongnu.org; Fri, 05 Sep 2014 12:14:30 -0400 From: Stefan Hajnoczi Date: Fri, 5 Sep 2014 17:13:40 +0100 Message-Id: <1409933634-11331-13-git-send-email-stefanha@redhat.com> In-Reply-To: <1409933634-11331-1-git-send-email-stefanha@redhat.com> References: <1409933634-11331-1-git-send-email-stefanha@redhat.com> MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: quoted-printable Subject: [Qemu-devel] [PULL 12/26] libqos: Added EVENT_IDX support List-Id: List-Unsubscribe: , List-Archive: List-Post: List-Help: List-Subscribe: , To: qemu-devel@nongnu.org Cc: =?UTF-8?q?Marc=20Mar=C3=AD?= , Peter Maydell , Stefan Hajnoczi From: Marc Mar=C3=AD Added avail_event and NO_NOTIFY check before notifying. Added used_event setting. Signed-off-by: Marc Mar=C3=AD Signed-off-by: Stefan Hajnoczi --- tests/libqos/virtio-pci.c | 1 + tests/libqos/virtio.c | 27 +++++++++- tests/libqos/virtio.h | 5 ++ tests/virtio-blk-test.c | 124 ++++++++++++++++++++++++++++++++++++++++= ++++++ 4 files changed, 156 insertions(+), 1 deletion(-) diff --git a/tests/libqos/virtio-pci.c b/tests/libqos/virtio-pci.c index ab28717..788ebaf 100644 --- a/tests/libqos/virtio-pci.c +++ b/tests/libqos/virtio-pci.c @@ -203,6 +203,7 @@ static QVirtQueue *qvirtio_pci_virtqueue_setup(QVirti= oDevice *d, vqpci->vq.num_free =3D vqpci->vq.size; vqpci->vq.align =3D QVIRTIO_PCI_ALIGN; vqpci->vq.indirect =3D (feat & QVIRTIO_F_RING_INDIRECT_DESC) !=3D 0; + vqpci->vq.event =3D (feat & QVIRTIO_F_RING_EVENT_IDX) !=3D 0; =20 vqpci->msix_entry =3D -1; vqpci->msix_addr =3D 0; diff --git a/tests/libqos/virtio.c b/tests/libqos/virtio.c index 16eaf79..128dbd0 100644 --- a/tests/libqos/virtio.c +++ b/tests/libqos/virtio.c @@ -124,9 +124,13 @@ void qvring_init(const QGuestAllocator *alloc, QVirt= Queue *vq, uint64_t addr) writew(vq->avail, 0); /* vq->avail->idx */ writew(vq->avail + 2, 0); + /* vq->avail->used_event */ + writew(vq->avail + 4 + (2 * vq->size), 0); =20 /* vq->used->flags */ writew(vq->used, 0); + /* vq->used->avail_event */ + writew(vq->used+2+(sizeof(struct QVRingUsedElem)*vq->size), 0); } =20 QVRingIndirectDesc *qvring_indirect_desc_setup(QVirtioDevice *d, @@ -222,11 +226,32 @@ void qvirtqueue_kick(const QVirtioBus *bus, QVirtio= Device *d, QVirtQueue *vq, { /* vq->avail->idx */ uint16_t idx =3D readl(vq->avail + 2); + /* vq->used->flags */ + uint16_t flags; + /* vq->used->avail_event */ + uint16_t avail_event; =20 /* vq->avail->ring[idx % vq->size] */ writel(vq->avail + 4 + (2 * (idx % vq->size)), free_head); /* vq->avail->idx */ writel(vq->avail + 2, idx + 1); =20 - bus->virtqueue_kick(d, vq); + /* Must read after idx is updated */ + flags =3D readw(vq->avail); + avail_event =3D readw(vq->used + 4 + + (sizeof(struct QVRingUsedElem) * vq->siz= e)); + + /* < 1 because we add elements to avail queue one by one */ + if ((flags & QVRING_USED_F_NO_NOTIFY) =3D=3D 0 && + (!vq->event || (uint16_t)(idx-avail_event) <= 1)) { + bus->virtqueue_kick(d, vq); + } +} + +void qvirtqueue_set_used_event(QVirtQueue *vq, uint16_t idx) +{ + g_assert(vq->event); + + /* vq->avail->used_event */ + writew(vq->avail + 4 + (2 * vq->size), idx); } diff --git a/tests/libqos/virtio.h b/tests/libqos/virtio.h index cebccd2..70b3376 100644 --- a/tests/libqos/virtio.h +++ b/tests/libqos/virtio.h @@ -26,6 +26,7 @@ #define QVIRTIO_F_ANY_LAYOUT 0x08000000 #define QVIRTIO_F_RING_INDIRECT_DESC 0x10000000 #define QVIRTIO_F_RING_EVENT_IDX 0x20000000 +#define QVIRTIO_F_BAD_FEATURE 0x40000000 =20 #define QVRING_DESC_F_NEXT 0x1 #define QVRING_DESC_F_WRITE 0x2 @@ -57,6 +58,7 @@ typedef struct QVRingAvail { uint16_t flags; uint16_t idx; uint16_t ring[0]; /* This is an array of uint16_t */ + uint16_t used_event; } QVRingAvail; =20 typedef struct QVRingUsedElem { @@ -68,6 +70,7 @@ typedef struct QVRingUsed { uint16_t flags; uint16_t idx; QVRingUsedElem ring[0]; /* This is an array of QVRingUsedElem struct= s */ + uint16_t avail_event; } QVRingUsed; =20 typedef struct QVirtQueue { @@ -80,6 +83,7 @@ typedef struct QVirtQueue { uint32_t num_free; uint32_t align; bool indirect; + bool event; } QVirtQueue; =20 typedef struct QVRingIndirectDesc { @@ -174,4 +178,5 @@ uint32_t qvirtqueue_add_indirect(QVirtQueue *vq, QVRi= ngIndirectDesc *indirect); void qvirtqueue_kick(const QVirtioBus *bus, QVirtioDevice *d, QVirtQueue= *vq, uint32_t fre= e_head); =20 +void qvirtqueue_set_used_event(QVirtQueue *vq, uint16_t idx); #endif diff --git a/tests/virtio-blk-test.c b/tests/virtio-blk-test.c index 0100aaa..588666c 100644 --- a/tests/virtio-blk-test.c +++ b/tests/virtio-blk-test.c @@ -496,6 +496,129 @@ static void pci_msix(void) =20 qvirtqueue_kick(&qvirtio_pci, &dev->vdev, &vqpci->vq, free_head); =20 + + g_assert(qvirtio_wait_queue_isr(&qvirtio_pci, &dev->vdev, &vqpci->vq= , + QVIRTIO_BLK_TIME= OUT)); + + status =3D readb(req_addr + 528); + g_assert_cmpint(status, =3D=3D, 0); + + data =3D g_malloc0(512); + memread(req_addr + 16, data, 512); + g_assert_cmpstr(data, =3D=3D, "TEST"); + g_free(data); + + guest_free(alloc, req_addr); + + /* End test */ + guest_free(alloc, (uint64_t)vqpci->vq.desc); + qpci_msix_disable(dev->pdev); + qvirtio_pci_device_disable(dev); + g_free(dev); + test_end(); +} + +static void pci_idx(void) +{ + QVirtioPCIDevice *dev; + QPCIBus *bus; + QVirtQueuePCI *vqpci; + QGuestAllocator *alloc; + QVirtioBlkReq req; + void *addr; + uint64_t req_addr; + uint64_t capacity; + uint32_t features; + uint32_t free_head; + uint8_t status; + char *data; + + bus =3D test_start(); + alloc =3D pc_alloc_init(); + + dev =3D virtio_blk_init(bus); + qpci_msix_enable(dev->pdev); + + qvirtio_pci_set_msix_configuration_vector(dev, alloc, 0); + + /* MSI-X is enabled */ + addr =3D dev->addr + QVIRTIO_DEVICE_SPECIFIC_MSIX; + + capacity =3D qvirtio_config_readq(&qvirtio_pci, &dev->vdev, addr); + g_assert_cmpint(capacity, =3D=3D, TEST_IMAGE_SIZE / 512); + + features =3D qvirtio_get_features(&qvirtio_pci, &dev->vdev); + features =3D features & ~(QVIRTIO_F_BAD_FEATURE | + QVIRTIO_F_RING_INDIRECT_DESC | + QVIRTIO_F_NOTIFY_ON_EMPTY | QVIRTIO_BLK_F_SC= SI); + qvirtio_set_features(&qvirtio_pci, &dev->vdev, features); + + vqpci =3D (QVirtQueuePCI *)qvirtqueue_setup(&qvirtio_pci, &dev->vdev= , + allo= c, 0); + qvirtqueue_pci_msix_setup(dev, vqpci, alloc, 1); + + qvirtio_set_driver_ok(&qvirtio_pci, &dev->vdev); + + /* Write request */ + req.type =3D QVIRTIO_BLK_T_OUT; + req.ioprio =3D 1; + req.sector =3D 0; + req.data =3D g_malloc0(512); + strcpy(req.data, "TEST"); + + req_addr =3D virtio_blk_request(alloc, &req, 512); + + g_free(req.data); + + free_head =3D qvirtqueue_add(&vqpci->vq, req_addr, 528, false, true)= ; + qvirtqueue_add(&vqpci->vq, req_addr + 528, 1, true, false); + qvirtqueue_kick(&qvirtio_pci, &dev->vdev, &vqpci->vq, free_head); + + g_assert(qvirtio_wait_queue_isr(&qvirtio_pci, &dev->vdev, &vqpci->vq= , + QVIRTIO_BLK_TIME= OUT)); + + /* Write request */ + req.type =3D QVIRTIO_BLK_T_OUT; + req.ioprio =3D 1; + req.sector =3D 1; + req.data =3D g_malloc0(512); + strcpy(req.data, "TEST"); + + req_addr =3D virtio_blk_request(alloc, &req, 512); + + g_free(req.data); + + /* Notify after processing the third request */ + qvirtqueue_set_used_event(&vqpci->vq, 2); + free_head =3D qvirtqueue_add(&vqpci->vq, req_addr, 528, false, true)= ; + qvirtqueue_add(&vqpci->vq, req_addr + 528, 1, true, false); + qvirtqueue_kick(&qvirtio_pci, &dev->vdev, &vqpci->vq, free_head); + + /* No notification expected */ + g_assert(!qvirtio_wait_queue_isr(&qvirtio_pci, &dev->vdev, &vqpci->v= q, + QVIRTIO_BLK_TIME= OUT)); + + status =3D readb(req_addr + 528); + g_assert_cmpint(status, =3D=3D, 0); + + guest_free(alloc, req_addr); + + /* Read request */ + req.type =3D QVIRTIO_BLK_T_IN; + req.ioprio =3D 1; + req.sector =3D 1; + req.data =3D g_malloc0(512); + + req_addr =3D virtio_blk_request(alloc, &req, 512); + + g_free(req.data); + + free_head =3D qvirtqueue_add(&vqpci->vq, req_addr, 16, false, true); + qvirtqueue_add(&vqpci->vq, req_addr + 16, 513, true, false); + + qvirtqueue_kick(&qvirtio_pci, &dev->vdev, &vqpci->vq, free_head); + + g_assert(qvirtio_wait_queue_isr(&qvirtio_pci, &dev->vdev, &vqpci->vq= , QVIRTIO_BLK_TIME= OUT)); =20 @@ -527,6 +650,7 @@ int main(int argc, char **argv) g_test_add_func("/virtio/blk/pci/indirect", pci_indirect); g_test_add_func("/virtio/blk/pci/config", pci_config); g_test_add_func("/virtio/blk/pci/msix", pci_msix); + g_test_add_func("/virtio/blk/pci/idx", pci_idx); =20 ret =3D g_test_run(); =20 --=20 1.9.3