From: Stefano Stabellini <sstabellini@kernel.org> To: xen-devel@lists.xen.org Cc: linux-kernel@vger.kernel.org, sstabellini@kernel.org, jgross@suse.com, boris.ostrovsky@oracle.com, Stefano Stabellini <stefano@aporeto.com> Subject: [PATCH v4 03/13] xen/pvcalls: connect to the backend Date: Fri, 15 Sep 2017 16:00:30 -0700 [thread overview] Message-ID: <1505516440-11111-3-git-send-email-sstabellini@kernel.org> (raw) In-Reply-To: <1505516440-11111-1-git-send-email-sstabellini@kernel.org> Implement the probe function for the pvcalls frontend. Read the supported versions, max-page-order and function-calls nodes from xenstore. Only one frontend<->backend connection is supported at any given time for a guest. Store the active frontend device to a static pointer. Introduce a stub functions for the event handler. Signed-off-by: Stefano Stabellini <stefano@aporeto.com> CC: boris.ostrovsky@oracle.com CC: jgross@suse.com --- drivers/xen/pvcalls-front.c | 133 ++++++++++++++++++++++++++++++++++++++++++++ 1 file changed, 133 insertions(+) diff --git a/drivers/xen/pvcalls-front.c b/drivers/xen/pvcalls-front.c index 67c8337..ffbbcd1 100644 --- a/drivers/xen/pvcalls-front.c +++ b/drivers/xen/pvcalls-front.c @@ -96,12 +96,145 @@ static int pvcalls_front_remove(struct xenbus_device *dev) static int pvcalls_front_probe(struct xenbus_device *dev, const struct xenbus_device_id *id) { + int ret = -ENOMEM, evtchn, i; + unsigned int max_page_order, function_calls, len; + char *versions; + grant_ref_t gref_head = 0; + struct xenbus_transaction xbt; + struct pvcalls_bedata *bedata = NULL; + struct xen_pvcalls_sring *sring; + + if (pvcalls_front_dev != NULL) { + dev_err(&dev->dev, "only one PV Calls connection supported\n"); + return -EINVAL; + } + + versions = xenbus_read(XBT_NIL, dev->otherend, "versions", &len); + if (!len) + return -EINVAL; + if (strcmp(versions, "1")) { + kfree(versions); + return -EINVAL; + } + kfree(versions); + max_page_order = xenbus_read_unsigned(dev->otherend, + "max-page-order", 0); + if (max_page_order < PVCALLS_RING_ORDER) + return -ENODEV; + function_calls = xenbus_read_unsigned(dev->otherend, + "function-calls", 0); + /* See XENBUS_FUNCTIONS_CALLS in pvcalls.h */ + if (function_calls != 1) + return -ENODEV; + pr_info("%s max-page-order is %u\n", __func__, max_page_order); + + bedata = kzalloc(sizeof(struct pvcalls_bedata), GFP_KERNEL); + if (!bedata) + return -ENOMEM; + + dev_set_drvdata(&dev->dev, bedata); + pvcalls_front_dev = dev; + init_waitqueue_head(&bedata->inflight_req); + INIT_LIST_HEAD(&bedata->socket_mappings); + INIT_LIST_HEAD(&bedata->socketpass_mappings); + spin_lock_init(&bedata->socket_lock); + bedata->irq = -1; + bedata->ref = -1; + + for (i = 0; i < PVCALLS_NR_REQ_PER_RING; i++) + bedata->rsp[i].req_id = PVCALLS_INVALID_ID; + + sring = (struct xen_pvcalls_sring *) __get_free_page(GFP_KERNEL | + __GFP_ZERO); + if (!sring) + goto error; + SHARED_RING_INIT(sring); + FRONT_RING_INIT(&bedata->ring, sring, XEN_PAGE_SIZE); + + ret = xenbus_alloc_evtchn(dev, &evtchn); + if (ret) + goto error; + + bedata->irq = bind_evtchn_to_irqhandler(evtchn, + pvcalls_front_event_handler, + 0, "pvcalls-frontend", dev); + if (bedata->irq < 0) { + ret = bedata->irq; + goto error; + } + + ret = gnttab_alloc_grant_references(1, &gref_head); + if (ret < 0) + goto error; + bedata->ref = gnttab_claim_grant_reference(&gref_head); + if (bedata->ref < 0) { + ret = bedata->ref; + goto error; + } + gnttab_grant_foreign_access_ref(bedata->ref, dev->otherend_id, + virt_to_gfn((void *)sring), 0); + + again: + ret = xenbus_transaction_start(&xbt); + if (ret) { + xenbus_dev_fatal(dev, ret, "starting transaction"); + goto error; + } + ret = xenbus_printf(xbt, dev->nodename, "version", "%u", 1); + if (ret) + goto error_xenbus; + ret = xenbus_printf(xbt, dev->nodename, "ring-ref", "%d", bedata->ref); + if (ret) + goto error_xenbus; + ret = xenbus_printf(xbt, dev->nodename, "port", "%u", + evtchn); + if (ret) + goto error_xenbus; + ret = xenbus_transaction_end(xbt, 0); + if (ret) { + if (ret == -EAGAIN) + goto again; + xenbus_dev_fatal(dev, ret, "completing transaction"); + goto error; + } + xenbus_switch_state(dev, XenbusStateInitialised); + return 0; + + error_xenbus: + xenbus_transaction_end(xbt, 1); + xenbus_dev_fatal(dev, ret, "writing xenstore"); + error: + pvcalls_front_remove(dev); + return ret; } static void pvcalls_front_changed(struct xenbus_device *dev, enum xenbus_state backend_state) { + switch (backend_state) { + case XenbusStateReconfiguring: + case XenbusStateReconfigured: + case XenbusStateInitialising: + case XenbusStateInitialised: + case XenbusStateUnknown: + break; + + case XenbusStateInitWait: + break; + + case XenbusStateConnected: + xenbus_switch_state(dev, XenbusStateConnected); + break; + + case XenbusStateClosed: + if (dev->state == XenbusStateClosed) + break; + /* Missed the backend's CLOSING state -- fallthrough */ + case XenbusStateClosing: + xenbus_frontend_closed(dev); + break; + } } static struct xenbus_driver pvcalls_front_driver = { -- 1.9.1
WARNING: multiple messages have this Message-ID (diff)
From: Stefano Stabellini <sstabellini@kernel.org> To: xen-devel@lists.xen.org Cc: jgross@suse.com, Stefano Stabellini <stefano@aporeto.com>, boris.ostrovsky@oracle.com, sstabellini@kernel.org, linux-kernel@vger.kernel.org Subject: [PATCH v4 03/13] xen/pvcalls: connect to the backend Date: Fri, 15 Sep 2017 16:00:30 -0700 [thread overview] Message-ID: <1505516440-11111-3-git-send-email-sstabellini@kernel.org> (raw) In-Reply-To: <1505516440-11111-1-git-send-email-sstabellini@kernel.org> Implement the probe function for the pvcalls frontend. Read the supported versions, max-page-order and function-calls nodes from xenstore. Only one frontend<->backend connection is supported at any given time for a guest. Store the active frontend device to a static pointer. Introduce a stub functions for the event handler. Signed-off-by: Stefano Stabellini <stefano@aporeto.com> CC: boris.ostrovsky@oracle.com CC: jgross@suse.com --- drivers/xen/pvcalls-front.c | 133 ++++++++++++++++++++++++++++++++++++++++++++ 1 file changed, 133 insertions(+) diff --git a/drivers/xen/pvcalls-front.c b/drivers/xen/pvcalls-front.c index 67c8337..ffbbcd1 100644 --- a/drivers/xen/pvcalls-front.c +++ b/drivers/xen/pvcalls-front.c @@ -96,12 +96,145 @@ static int pvcalls_front_remove(struct xenbus_device *dev) static int pvcalls_front_probe(struct xenbus_device *dev, const struct xenbus_device_id *id) { + int ret = -ENOMEM, evtchn, i; + unsigned int max_page_order, function_calls, len; + char *versions; + grant_ref_t gref_head = 0; + struct xenbus_transaction xbt; + struct pvcalls_bedata *bedata = NULL; + struct xen_pvcalls_sring *sring; + + if (pvcalls_front_dev != NULL) { + dev_err(&dev->dev, "only one PV Calls connection supported\n"); + return -EINVAL; + } + + versions = xenbus_read(XBT_NIL, dev->otherend, "versions", &len); + if (!len) + return -EINVAL; + if (strcmp(versions, "1")) { + kfree(versions); + return -EINVAL; + } + kfree(versions); + max_page_order = xenbus_read_unsigned(dev->otherend, + "max-page-order", 0); + if (max_page_order < PVCALLS_RING_ORDER) + return -ENODEV; + function_calls = xenbus_read_unsigned(dev->otherend, + "function-calls", 0); + /* See XENBUS_FUNCTIONS_CALLS in pvcalls.h */ + if (function_calls != 1) + return -ENODEV; + pr_info("%s max-page-order is %u\n", __func__, max_page_order); + + bedata = kzalloc(sizeof(struct pvcalls_bedata), GFP_KERNEL); + if (!bedata) + return -ENOMEM; + + dev_set_drvdata(&dev->dev, bedata); + pvcalls_front_dev = dev; + init_waitqueue_head(&bedata->inflight_req); + INIT_LIST_HEAD(&bedata->socket_mappings); + INIT_LIST_HEAD(&bedata->socketpass_mappings); + spin_lock_init(&bedata->socket_lock); + bedata->irq = -1; + bedata->ref = -1; + + for (i = 0; i < PVCALLS_NR_REQ_PER_RING; i++) + bedata->rsp[i].req_id = PVCALLS_INVALID_ID; + + sring = (struct xen_pvcalls_sring *) __get_free_page(GFP_KERNEL | + __GFP_ZERO); + if (!sring) + goto error; + SHARED_RING_INIT(sring); + FRONT_RING_INIT(&bedata->ring, sring, XEN_PAGE_SIZE); + + ret = xenbus_alloc_evtchn(dev, &evtchn); + if (ret) + goto error; + + bedata->irq = bind_evtchn_to_irqhandler(evtchn, + pvcalls_front_event_handler, + 0, "pvcalls-frontend", dev); + if (bedata->irq < 0) { + ret = bedata->irq; + goto error; + } + + ret = gnttab_alloc_grant_references(1, &gref_head); + if (ret < 0) + goto error; + bedata->ref = gnttab_claim_grant_reference(&gref_head); + if (bedata->ref < 0) { + ret = bedata->ref; + goto error; + } + gnttab_grant_foreign_access_ref(bedata->ref, dev->otherend_id, + virt_to_gfn((void *)sring), 0); + + again: + ret = xenbus_transaction_start(&xbt); + if (ret) { + xenbus_dev_fatal(dev, ret, "starting transaction"); + goto error; + } + ret = xenbus_printf(xbt, dev->nodename, "version", "%u", 1); + if (ret) + goto error_xenbus; + ret = xenbus_printf(xbt, dev->nodename, "ring-ref", "%d", bedata->ref); + if (ret) + goto error_xenbus; + ret = xenbus_printf(xbt, dev->nodename, "port", "%u", + evtchn); + if (ret) + goto error_xenbus; + ret = xenbus_transaction_end(xbt, 0); + if (ret) { + if (ret == -EAGAIN) + goto again; + xenbus_dev_fatal(dev, ret, "completing transaction"); + goto error; + } + xenbus_switch_state(dev, XenbusStateInitialised); + return 0; + + error_xenbus: + xenbus_transaction_end(xbt, 1); + xenbus_dev_fatal(dev, ret, "writing xenstore"); + error: + pvcalls_front_remove(dev); + return ret; } static void pvcalls_front_changed(struct xenbus_device *dev, enum xenbus_state backend_state) { + switch (backend_state) { + case XenbusStateReconfiguring: + case XenbusStateReconfigured: + case XenbusStateInitialising: + case XenbusStateInitialised: + case XenbusStateUnknown: + break; + + case XenbusStateInitWait: + break; + + case XenbusStateConnected: + xenbus_switch_state(dev, XenbusStateConnected); + break; + + case XenbusStateClosed: + if (dev->state == XenbusStateClosed) + break; + /* Missed the backend's CLOSING state -- fallthrough */ + case XenbusStateClosing: + xenbus_frontend_closed(dev); + break; + } } static struct xenbus_driver pvcalls_front_driver = { -- 1.9.1 _______________________________________________ Xen-devel mailing list Xen-devel@lists.xen.org https://lists.xen.org/xen-devel
next prev parent reply other threads:[~2017-09-15 23:03 UTC|newest] Thread overview: 85+ messages / expand[flat|nested] mbox.gz Atom feed top 2017-09-15 23:00 [PATCH v4 00/13] introduce the Xen PV Calls frontend Stefano Stabellini 2017-09-15 23:00 ` [PATCH v4 01/13] xen/pvcalls: introduce the pvcalls xenbus frontend Stefano Stabellini 2017-09-15 23:00 ` Stefano Stabellini 2017-09-15 23:00 ` [PATCH v4 02/13] xen/pvcalls: implement frontend disconnect Stefano Stabellini 2017-09-20 20:32 ` Boris Ostrovsky 2017-09-20 20:32 ` Boris Ostrovsky 2017-10-06 17:51 ` Stefano Stabellini 2017-10-06 20:21 ` Boris Ostrovsky 2017-10-06 20:21 ` Boris Ostrovsky 2017-10-06 20:29 ` Stefano Stabellini 2017-10-06 20:29 ` Stefano Stabellini 2017-10-06 20:31 ` Boris Ostrovsky 2017-10-06 20:31 ` Boris Ostrovsky 2017-10-06 17:51 ` Stefano Stabellini 2017-09-20 20:59 ` Boris Ostrovsky 2017-10-07 0:08 ` Stefano Stabellini 2017-10-07 0:08 ` Stefano Stabellini 2017-09-20 20:59 ` Boris Ostrovsky 2017-09-15 23:00 ` Stefano Stabellini 2017-09-15 23:00 ` Stefano Stabellini [this message] 2017-09-15 23:00 ` [PATCH v4 03/13] xen/pvcalls: connect to the backend Stefano Stabellini 2017-09-20 21:08 ` Boris Ostrovsky 2017-09-20 21:08 ` Boris Ostrovsky 2017-09-15 23:00 ` [PATCH v4 04/13] xen/pvcalls: implement socket command and handle events Stefano Stabellini 2017-09-15 23:00 ` Stefano Stabellini 2017-09-21 17:42 ` Boris Ostrovsky 2017-09-21 17:42 ` Boris Ostrovsky 2017-10-06 18:38 ` Stefano Stabellini 2017-10-06 20:36 ` Boris Ostrovsky 2017-10-06 20:36 ` Boris Ostrovsky 2017-10-06 18:38 ` Stefano Stabellini 2017-09-15 23:00 ` [PATCH v4 05/13] xen/pvcalls: implement connect command Stefano Stabellini 2017-09-15 23:00 ` Stefano Stabellini 2017-09-21 18:28 ` Boris Ostrovsky 2017-09-21 18:28 ` Boris Ostrovsky 2017-10-06 17:44 ` Stefano Stabellini 2017-10-06 17:54 ` Stefano Stabellini 2017-10-06 17:54 ` Stefano Stabellini 2017-10-06 17:44 ` Stefano Stabellini 2017-09-15 23:00 ` [PATCH v4 06/13] xen/pvcalls: implement bind command Stefano Stabellini 2017-09-15 23:00 ` Stefano Stabellini 2017-09-21 19:40 ` Boris Ostrovsky 2017-10-06 20:35 ` Stefano Stabellini 2017-10-06 20:35 ` Stefano Stabellini 2017-09-21 19:40 ` Boris Ostrovsky 2017-09-15 23:00 ` [PATCH v4 07/13] xen/pvcalls: implement listen command Stefano Stabellini 2017-09-15 23:00 ` Stefano Stabellini 2017-09-15 23:00 ` [PATCH v4 08/13] xen/pvcalls: implement accept command Stefano Stabellini 2017-09-15 23:00 ` Stefano Stabellini 2017-09-22 0:00 ` Boris Ostrovsky 2017-09-22 0:00 ` Boris Ostrovsky 2017-10-06 22:06 ` Stefano Stabellini 2017-10-06 22:06 ` Stefano Stabellini 2017-09-15 23:00 ` [PATCH v4 09/13] xen/pvcalls: implement sendmsg Stefano Stabellini 2017-09-22 21:57 ` Boris Ostrovsky 2017-10-06 21:43 ` Stefano Stabellini 2017-10-06 21:43 ` Stefano Stabellini 2017-09-22 21:57 ` Boris Ostrovsky 2017-09-15 23:00 ` Stefano Stabellini 2017-09-15 23:00 ` [PATCH v4 10/13] xen/pvcalls: implement recvmsg Stefano Stabellini 2017-09-22 22:05 ` Boris Ostrovsky 2017-10-06 20:46 ` Stefano Stabellini 2017-10-06 20:46 ` Stefano Stabellini 2017-09-22 22:05 ` Boris Ostrovsky 2017-09-15 23:00 ` Stefano Stabellini 2017-09-15 23:00 ` [PATCH v4 11/13] xen/pvcalls: implement poll command Stefano Stabellini 2017-09-19 15:19 ` Andrea Parri 2017-09-19 15:19 ` Andrea Parri 2017-10-06 23:33 ` Stefano Stabellini 2017-10-06 23:33 ` Stefano Stabellini 2017-09-22 22:27 ` Boris Ostrovsky 2017-09-22 22:27 ` Boris Ostrovsky 2017-10-06 23:39 ` Stefano Stabellini 2017-10-06 23:39 ` Stefano Stabellini 2017-09-15 23:00 ` Stefano Stabellini 2017-09-15 23:00 ` [PATCH v4 12/13] xen/pvcalls: implement release command Stefano Stabellini 2017-09-15 23:00 ` Stefano Stabellini 2017-09-22 22:43 ` Boris Ostrovsky 2017-09-22 22:43 ` Boris Ostrovsky 2017-09-22 22:48 ` Boris Ostrovsky 2017-09-22 22:48 ` Boris Ostrovsky 2017-10-06 23:49 ` Stefano Stabellini 2017-10-06 23:49 ` Stefano Stabellini 2017-09-15 23:00 ` [PATCH v4 13/13] xen: introduce a Kconfig option to enable the pvcalls frontend Stefano Stabellini 2017-09-15 23:00 ` Stefano Stabellini
Reply instructions: You may reply publicly to this message via plain-text email using any one of the following methods: * Save the following mbox file, import it into your mail client, and reply-to-all from there: mbox Avoid top-posting and favor interleaved quoting: https://en.wikipedia.org/wiki/Posting_style#Interleaved_style * Reply using the --to, --cc, and --in-reply-to switches of git-send-email(1): git send-email \ --in-reply-to=1505516440-11111-3-git-send-email-sstabellini@kernel.org \ --to=sstabellini@kernel.org \ --cc=boris.ostrovsky@oracle.com \ --cc=jgross@suse.com \ --cc=linux-kernel@vger.kernel.org \ --cc=stefano@aporeto.com \ --cc=xen-devel@lists.xen.org \ /path/to/YOUR_REPLY https://kernel.org/pub/software/scm/git/docs/git-send-email.html * If your mail client supports setting the In-Reply-To header via mailto: links, try the mailto: linkBe sure your reply has a Subject: header at the top and a blank line before the message body.
This is an external index of several public inboxes, see mirroring instructions on how to clone and mirror all data and code used by this external index.