[Date Prev][Date Next][Thread Prev][Thread Next][Date Index][Thread Index]
[Qemu-devel] [PATCH 14/21] xen/9pfs: receive requests from the frontend
From: |
Stefano Stabellini |
Subject: |
[Qemu-devel] [PATCH 14/21] xen/9pfs: receive requests from the frontend |
Date: |
Tue, 25 Apr 2017 11:35:06 -0700 |
Upon receiving an event channel notification from the frontend, schedule
the bottom half. From the bottom half, read one request from the ring,
create a pdu and call pdu_submit to handle it.
For now, only handle one request per ring at a time.
Signed-off-by: Stefano Stabellini <address@hidden>
CC: address@hidden
CC: address@hidden
CC: Aneesh Kumar K.V <address@hidden>
CC: Greg Kurz <address@hidden>
---
hw/9pfs/xen-9p-backend.c | 50 ++++++++++++++++++++++++++++++++++++++++++++++++
1 file changed, 50 insertions(+)
diff --git a/hw/9pfs/xen-9p-backend.c b/hw/9pfs/xen-9p-backend.c
index 03dd881..8820e8f 100644
--- a/hw/9pfs/xen-9p-backend.c
+++ b/hw/9pfs/xen-9p-backend.c
@@ -100,12 +100,62 @@ static int xen_9pfs_init(struct XenDevice *xendev)
return 0;
}
+static int xen_9pfs_receive(Xen9pfsRing *ring)
+{
+ P9MsgHeader h;
+ RING_IDX cons, prod, masked_prod, masked_cons;
+ V9fsPDU *pdu;
+
+ if (ring->inprogress) {
+ return 0;
+ }
+
+ cons = ring->intf->out_cons;
+ prod = ring->intf->out_prod;
+ xen_rmb();
+
+ if (xen_9pfs_queued(prod, cons, XEN_FLEX_RING_SIZE(ring->ring_order)) <
+ sizeof(h)) {
+ return 0;
+ }
+ ring->inprogress = true;
+
+ masked_prod = xen_9pfs_mask(prod, XEN_FLEX_RING_SIZE(ring->ring_order));
+ masked_cons = xen_9pfs_mask(cons, XEN_FLEX_RING_SIZE(ring->ring_order));
+
+ xen_9pfs_read_packet((uint8_t *) &h, ring->ring.out, sizeof(h),
+ masked_prod, &masked_cons,
+ XEN_FLEX_RING_SIZE(ring->ring_order));
+
+ /* cannot fail, because we only handle one request per ring at a time */
+ pdu = pdu_alloc(&ring->priv->state);
+ pdu->size = le32_to_cpu(h.size_le);
+ pdu->id = h.id;
+ pdu->tag = le32_to_cpu(h.tag_le);
+ ring->out_size = le32_to_cpu(h.size_le);
+ ring->out_cons = cons + le32_to_cpu(h.size_le);
+
+ qemu_co_queue_init(&pdu->complete);
+ pdu_submit(pdu);
+
+ return 0;
+}
+
static void xen_9pfs_bh(void *opaque)
{
+ Xen9pfsRing *ring = opaque;
+ xen_9pfs_receive(ring);
}
static void xen_9pfs_evtchn_event(void *opaque)
{
+ Xen9pfsRing *ring = opaque;
+ evtchn_port_t port;
+
+ port = xenevtchn_pending(ring->evtchndev);
+ xenevtchn_unmask(ring->evtchndev, port);
+
+ qemu_bh_schedule(ring->bh);
}
static int xen_9pfs_free(struct XenDevice *xendev)
--
1.9.1
- [Qemu-devel] [PATCH 03/21] xen: create wrappers for all other uses of xc_hvm_XXX() functions, (continued)
- [Qemu-devel] [PATCH 03/21] xen: create wrappers for all other uses of xc_hvm_XXX() functions, Stefano Stabellini, 2017/04/25
- [Qemu-devel] [PATCH 04/21] configure: detect presence of libxendevicemodel, Stefano Stabellini, 2017/04/25
- [Qemu-devel] [PATCH 05/21] xen: use libxendevicemodel when available, Stefano Stabellini, 2017/04/25
- [Qemu-devel] [PATCH 08/21] xen: additionally restrict xenforeignmemory operations, Stefano Stabellini, 2017/04/25
- [Qemu-devel] [PATCH 06/21] xen: use 5 digit xen versions, Stefano Stabellini, 2017/04/25
- [Qemu-devel] [PATCH 07/21] xen: use libxendevice model to restrict operations, Stefano Stabellini, 2017/04/25
- [Qemu-devel] [PATCH 09/21] configure: use pkg-config for obtaining xen version, Stefano Stabellini, 2017/04/25
- [Qemu-devel] [PATCH 11/21] 9p: introduce a type for the 9p header, Stefano Stabellini, 2017/04/25
- [Qemu-devel] [PATCH 13/21] xen/9pfs: connect to the frontend, Stefano Stabellini, 2017/04/25
- [Qemu-devel] [PATCH 15/21] xen/9pfs: implement in/out_iov_from_pdu and vmarshal/vunmarshal, Stefano Stabellini, 2017/04/25
- [Qemu-devel] [PATCH 14/21] xen/9pfs: receive requests from the frontend,
Stefano Stabellini <=
- [Qemu-devel] [PATCH 10/21] xen: import ring.h from xen, Stefano Stabellini, 2017/04/25
- [Qemu-devel] [PATCH 12/21] xen/9pfs: introduce Xen 9pfs backend, Stefano Stabellini, 2017/04/25
- [Qemu-devel] [PATCH 16/21] xen/9pfs: send responses back to the frontend, Stefano Stabellini, 2017/04/25
- [Qemu-devel] [PATCH 17/21] xen/9pfs: build and register Xen 9pfs backend, Stefano Stabellini, 2017/04/25
- [Qemu-devel] [PATCH 18/21] add xen-9p-backend to MAINTAINERS under Xen, Stefano Stabellini, 2017/04/25
- [Qemu-devel] [PATCH 19/21] move xen-common.c to hw/xen/, Stefano Stabellini, 2017/04/25
- [Qemu-devel] [PATCH 21/21] move xen-mapcache.c to hw/i386/xen/, Stefano Stabellini, 2017/04/25
- [Qemu-devel] [PATCH 20/21] move xen-hvm.c to hw/i386/xen/, Stefano Stabellini, 2017/04/25
- Re: [Qemu-devel] [PULL 0/21] Please pull xen-20170421-v2-tag for 2.10, Peter Maydell, 2017/04/26