The Design and Implementation of the FreeBSD Operating System, Second Edition
Now available: The Design and Implementation of the FreeBSD Operating System (Second Edition)


[ source navigation ] [ diff markup ] [ identifier search ] [ freetext search ] [ file search ] [ list types ] [ track identifier ]

FreeBSD/Linux Kernel Cross Reference
sys/xen/xenbus/xenbus.c

Version: -  FREEBSD  -  FREEBSD-12-STABLE  -  FREEBSD-12-0  -  FREEBSD-11-STABLE  -  FREEBSD-11-2  -  FREEBSD-11-1  -  FREEBSD-11-0  -  FREEBSD-10-STABLE  -  FREEBSD-10-4  -  FREEBSD-10-3  -  FREEBSD-10-2  -  FREEBSD-10-1  -  FREEBSD-10-0  -  FREEBSD-9-STABLE  -  FREEBSD-9-3  -  FREEBSD-9-2  -  FREEBSD-9-1  -  FREEBSD-9-0  -  FREEBSD-8-STABLE  -  FREEBSD-8-4  -  FREEBSD-8-3  -  FREEBSD-8-2  -  FREEBSD-8-1  -  FREEBSD-8-0  -  FREEBSD-7-STABLE  -  FREEBSD-7-4  -  FREEBSD-7-3  -  FREEBSD-7-2  -  FREEBSD-7-1  -  FREEBSD-7-0  -  FREEBSD-6-STABLE  -  FREEBSD-6-4  -  FREEBSD-6-3  -  FREEBSD-6-2  -  FREEBSD-6-1  -  FREEBSD-6-0  -  FREEBSD-5-STABLE  -  FREEBSD-5-5  -  FREEBSD-5-4  -  FREEBSD-5-3  -  FREEBSD-5-2  -  FREEBSD-5-1  -  FREEBSD-5-0  -  FREEBSD-4-STABLE  -  FREEBSD-3-STABLE  -  FREEBSD22  -  linux-2.6  -  linux-2.4.22  -  MK83  -  MK84  -  PLAN9  -  DFBSD  -  NETBSD  -  NETBSD5  -  NETBSD4  -  NETBSD3  -  NETBSD20  -  OPENBSD  -  xnu-517  -  xnu-792  -  xnu-792.6.70  -  xnu-1228  -  xnu-1456.1.26  -  xnu-1699.24.8  -  xnu-2050.18.24  -  OPENSOLARIS  -  minix-3-1-1 
SearchContext: -  none  -  3  -  10 

    1 /******************************************************************************
    2  * Copyright (C) 2005 XenSource Ltd
    3  * 
    4  * This file may be distributed separately from the Linux kernel, or
    5  * incorporated into other software packages, subject to the following license:
    6  * 
    7  * Permission is hereby granted, free of charge, to any person obtaining a copy
    8  * of this source file (the "Software"), to deal in the Software without
    9  * restriction, including without limitation the rights to use, copy, modify,
   10  * merge, publish, distribute, sublicense, and/or sell copies of the Software,
   11  * and to permit persons to whom the Software is furnished to do so, subject to
   12  * the following conditions:
   13  * 
   14  * The above copyright notice and this permission notice shall be included in
   15  * all copies or substantial portions of the Software.
   16  * 
   17  * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
   18  * IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
   19  * FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
   20  * AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
   21  * LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING
   22  * FROM, OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS
   23  * IN THE SOFTWARE.
   24  */
   25 
   26 /**
   27  * \file xenbus.c
   28  *
   29  * \brief Client-facing interface for the Xenbus driver.
   30  *
   31  * In other words, the interface between the Xenbus and the device-specific
   32  * code, be it the frontend or the backend of that driver.
   33  */
   34 
   35 #if 0
   36 #define DPRINTK(fmt, args...) \
   37     printk("xenbus_client (%s:%d) " fmt ".\n", __FUNCTION__, __LINE__, ##args)
   38 #else
   39 #define DPRINTK(fmt, args...) ((void)0)
   40 #endif
   41 
   42 #include <sys/cdefs.h>
   43 __FBSDID("$FreeBSD: releng/8.2/sys/xen/xenbus/xenbus.c 215788 2010-11-24 01:03:03Z gibbs $");
   44 
   45 #include <sys/cdefs.h>
   46 #include <sys/param.h>
   47 #include <sys/kernel.h>
   48 #include <sys/types.h>
   49 #include <sys/malloc.h>
   50 #include <sys/libkern.h>
   51 #include <sys/sbuf.h>
   52 
   53 #include <machine/xen/xen-os.h>
   54 #include <xen/hypervisor.h>
   55 #include <xen/evtchn.h>
   56 #include <xen/gnttab.h>
   57 #include <xen/xenbus/xenbusvar.h>
   58 #include <machine/stdarg.h>
   59 
   60 MALLOC_DEFINE(M_XENBUS, "xenbus", "XenBus Support");
   61 
   62 /*------------------------- Private Functions --------------------------------*/
   63 /**
   64  * \brief Construct the error path corresponding to the given XenBus
   65  *        device.
   66  *
   67  * \param dev  The XenBus device for which we are constructing an error path.
   68  *
   69  * \return  On success, the contructed error path.  Otherwise NULL.
   70  *
   71  * It is the caller's responsibility to free any returned error path
   72  * node using the M_XENBUS malloc type.
   73  */
   74 static char *
   75 error_path(device_t dev)
   76 {
   77         char *path_buffer = malloc(strlen("error/")
   78             + strlen(xenbus_get_node(dev)) + 1,M_XENBUS, M_WAITOK);
   79 
   80         strcpy(path_buffer, "error/");
   81         strcpy(path_buffer + strlen("error/"), xenbus_get_node(dev));
   82 
   83         return (path_buffer);
   84 }
   85 
   86 /*--------------------------- Public Functions -------------------------------*/
   87 /*-------- API comments for these methods can be found in xenbusvar.h --------*/
   88 const char *
   89 xenbus_strstate(XenbusState state)
   90 {
   91         static const char *const name[] = {
   92                 [ XenbusStateUnknown      ] = "Unknown",
   93                 [ XenbusStateInitialising ] = "Initialising",
   94                 [ XenbusStateInitWait     ] = "InitWait",
   95                 [ XenbusStateInitialised  ] = "Initialised",
   96                 [ XenbusStateConnected    ] = "Connected",
   97                 [ XenbusStateClosing      ] = "Closing",
   98                 [ XenbusStateClosed       ] = "Closed",
   99         };
  100 
  101         return ((state < (XenbusStateClosed + 1)) ? name[state] : "INVALID");
  102 }
  103 
  104 int 
  105 xenbus_watch_path(device_t dev, char *path, struct xs_watch *watch, 
  106     xs_watch_cb_t *callback)
  107 {
  108         int error;
  109 
  110         watch->node = path;
  111         watch->callback = callback;
  112 
  113         error = xs_register_watch(watch);
  114 
  115         if (error) {
  116                 watch->node = NULL;
  117                 watch->callback = NULL;
  118                 xenbus_dev_fatal(dev, error, "adding watch on %s", path);
  119         }
  120 
  121         return (error);
  122 }
  123 
  124 int
  125 xenbus_watch_path2(device_t dev, const char *path,
  126     const char *path2, struct xs_watch *watch, 
  127     xs_watch_cb_t *callback)
  128 {
  129         int error;
  130         char *state = malloc(strlen(path) + 1 + strlen(path2) + 1,
  131            M_XENBUS, M_WAITOK);
  132 
  133         strcpy(state, path);
  134         strcat(state, "/");
  135         strcat(state, path2);
  136 
  137         error = xenbus_watch_path(dev, state, watch, callback);
  138         if (error) {
  139                 free(state,M_XENBUS);
  140         }
  141 
  142         return (error);
  143 }
  144 
  145 void
  146 xenbus_dev_verror(device_t dev, int err, const char *fmt, va_list ap)
  147 {
  148         int ret;
  149         unsigned int len;
  150         char *printf_buffer = NULL, *path_buffer = NULL;
  151 
  152 #define PRINTF_BUFFER_SIZE 4096
  153         printf_buffer = malloc(PRINTF_BUFFER_SIZE,M_XENBUS, M_WAITOK);
  154 
  155         len = sprintf(printf_buffer, "%i ", err);
  156         ret = vsnprintf(printf_buffer+len, PRINTF_BUFFER_SIZE-len, fmt, ap);
  157 
  158         KASSERT(len + ret <= PRINTF_BUFFER_SIZE-1, ("xenbus error message too big"));
  159         device_printf(dev, "Error %s\n", printf_buffer);
  160         path_buffer = error_path(dev);
  161 
  162         if (path_buffer == NULL) {
  163                 printf("xenbus: failed to write error node for %s (%s)\n",
  164                        xenbus_get_node(dev), printf_buffer);
  165                 goto fail;
  166         }
  167 
  168         if (xs_write(XST_NIL, path_buffer, "error", printf_buffer) != 0) {
  169                 printf("xenbus: failed to write error node for %s (%s)\n",
  170                        xenbus_get_node(dev), printf_buffer);
  171                 goto fail;
  172         }
  173 
  174  fail:
  175         if (printf_buffer)
  176                 free(printf_buffer,M_XENBUS);
  177         if (path_buffer)
  178                 free(path_buffer,M_XENBUS);
  179 }
  180 
  181 void
  182 xenbus_dev_error(device_t dev, int err, const char *fmt, ...)
  183 {
  184         va_list ap;
  185 
  186         va_start(ap, fmt);
  187         xenbus_dev_verror(dev, err, fmt, ap);
  188         va_end(ap);
  189 }
  190 
  191 void
  192 xenbus_dev_vfatal(device_t dev, int err, const char *fmt, va_list ap)
  193 {
  194         xenbus_dev_verror(dev, err, fmt, ap);
  195         device_printf(dev, "Fatal error. Transitioning to Closing State\n");
  196         xenbus_set_state(dev, XenbusStateClosing);
  197 }
  198 
  199 void
  200 xenbus_dev_fatal(device_t dev, int err, const char *fmt, ...)
  201 {
  202         va_list ap;
  203 
  204         va_start(ap, fmt);
  205         xenbus_dev_vfatal(dev, err, fmt, ap);
  206         va_end(ap);
  207 }
  208 
  209 int
  210 xenbus_grant_ring(device_t dev, unsigned long ring_mfn, grant_ref_t *refp)
  211 {
  212         int error;
  213 
  214         error = gnttab_grant_foreign_access(
  215                 xenbus_get_otherend_id(dev), ring_mfn, 0, refp);
  216         if (error) {
  217                 xenbus_dev_fatal(dev, error, "granting access to ring page");
  218                 return (error);
  219         }
  220 
  221         return (0);
  222 }
  223 
  224 int
  225 xenbus_alloc_evtchn(device_t dev, evtchn_port_t *port)
  226 {
  227         struct evtchn_alloc_unbound alloc_unbound;
  228         int err;
  229 
  230         alloc_unbound.dom        = DOMID_SELF;
  231         alloc_unbound.remote_dom = xenbus_get_otherend_id(dev);
  232 
  233         err = HYPERVISOR_event_channel_op(EVTCHNOP_alloc_unbound,
  234                                           &alloc_unbound);
  235 
  236         if (err) {
  237                 xenbus_dev_fatal(dev, -err, "allocating event channel");
  238                 return (-err);
  239         }
  240         *port = alloc_unbound.port;
  241         return (0);
  242 }
  243 
  244 int
  245 xenbus_free_evtchn(device_t dev, evtchn_port_t port)
  246 {
  247         struct evtchn_close close;
  248         int err;
  249 
  250         close.port = port;
  251 
  252         err = HYPERVISOR_event_channel_op(EVTCHNOP_close, &close);
  253         if (err) {
  254                 xenbus_dev_error(dev, -err, "freeing event channel %d", port);
  255                 return (-err);
  256         }
  257         return (0);
  258 }
  259 
  260 XenbusState
  261 xenbus_read_driver_state(const char *path)
  262 {
  263         XenbusState result;
  264         int error;
  265 
  266         error = xs_gather(XST_NIL, path, "state", "%d", &result, NULL);
  267         if (error)
  268                 result = XenbusStateClosed;
  269 
  270         return (result);
  271 }
  272 
  273 int
  274 xenbus_dev_is_online(device_t dev)
  275 {
  276         const char *path;
  277         int error;
  278         int value;
  279 
  280         path = xenbus_get_node(dev);
  281         error = xs_gather(XST_NIL, path, "online", "%d", &value, NULL);
  282         if (error != 0) {
  283                 /* Default to not online. */
  284                 value = 0;
  285         }
  286 
  287         return (value);
  288 }

Cache object: 1002c2d8d0b51312f5ca5674713a3cfd


[ source navigation ] [ diff markup ] [ identifier search ] [ freetext search ] [ file search ] [ list types ] [ track identifier ]


This page is part of the FreeBSD/Linux Linux Kernel Cross-Reference, and was automatically generated using a modified version of the LXR engine.