git.oblomov.eu Git - linux-2.6/blob - drivers/xen/xenbus/xenbus_client.c

   1 /******************************************************************************
   2  * Client-facing interface for the Xenbus driver.  In other words, the
   3  * interface between the Xenbus and the device-specific code, be it the
   4  * frontend or the backend of that driver.
   5  *
   6  * Copyright (C) 2005 XenSource Ltd
   7  *
   8  * This program is free software; you can redistribute it and/or
   9  * modify it under the terms of the GNU General Public License version 2
  10  * as published by the Free Software Foundation; or, when distributed
  11  * separately from the Linux kernel or incorporated into other
  12  * software packages, subject to the following license:
  13  *
  14  * Permission is hereby granted, free of charge, to any person obtaining a copy
  15  * of this source file (the "Software"), to deal in the Software without
  16  * restriction, including without limitation the rights to use, copy, modify,
  17  * merge, publish, distribute, sublicense, and/or sell copies of the Software,
  18  * and to permit persons to whom the Software is furnished to do so, subject to
  19  * the following conditions:
  20  *
  21  * The above copyright notice and this permission notice shall be included in
  22  * all copies or substantial portions of the Software.
  23  *
  24  * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
  25  * IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
  26  * FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
  27  * AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
  28  * LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING
  29  * FROM, OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS
  30  * IN THE SOFTWARE.
  31  */
  32
  33 #include <linux/types.h>
  34 #include <linux/vmalloc.h>
  35 #include <asm/xen/hypervisor.h>
  36 #include <xen/interface/xen.h>
  37 #include <xen/interface/event_channel.h>
  38 #include <xen/events.h>
  39 #include <xen/grant_table.h>
  40 #include <xen/xenbus.h>
  41
  42 const char *xenbus_strstate(enum xenbus_state state)
  43 {
  44         static const char *const name[] = {
  45                 [ XenbusStateUnknown      ] = "Unknown",
  46                 [ XenbusStateInitialising ] = "Initialising",
  47                 [ XenbusStateInitWait     ] = "InitWait",
  48                 [ XenbusStateInitialised  ] = "Initialised",
  49                 [ XenbusStateConnected    ] = "Connected",
  50                 [ XenbusStateClosing      ] = "Closing",
  51                 [ XenbusStateClosed       ] = "Closed",
  52         };
  53         return (state < ARRAY_SIZE(name)) ? name[state] : "INVALID";
  54 }
  55 EXPORT_SYMBOL_GPL(xenbus_strstate);
  56
  57 /**
  58  * xenbus_watch_path - register a watch
  59  * @dev: xenbus device
  60  * @path: path to watch
  61  * @watch: watch to register
  62  * @callback: callback to register
  63  *
  64  * Register a @watch on the given path, using the given xenbus_watch structure
  65  * for storage, and the given @callback function as the callback.  Return 0 on
  66  * success, or -errno on error.  On success, the given @path will be saved as
  67  * @watch->node, and remains the caller's to free.  On error, @watch->node will
  68  * be NULL, the device will switch to %XenbusStateClosing, and the error will
  69  * be saved in the store.
  70  */
  71 int xenbus_watch_path(struct xenbus_device *dev, const char *path,
  72                       struct xenbus_watch *watch,
  73                       void (*callback)(struct xenbus_watch *,
  74                                        const char **, unsigned int))
  75 {
  76         int err;
  77
  78         watch->node = path;
  79         watch->callback = callback;
  80
  81         err = register_xenbus_watch(watch);
  82
  83         if (err) {
  84                 watch->node = NULL;
  85                 watch->callback = NULL;
  86                 xenbus_dev_fatal(dev, err, "adding watch on %s", path);
  87         }
  88
  89         return err;
  90 }
  91 EXPORT_SYMBOL_GPL(xenbus_watch_path);
  92
  93
  94 /**
  95  * xenbus_watch_pathfmt - register a watch on a sprintf-formatted path
  96  * @dev: xenbus device
  97  * @watch: watch to register
  98  * @callback: callback to register
  99  * @pathfmt: format of path to watch
 100  *
 101  * Register a watch on the given @path, using the given xenbus_watch
 102  * structure for storage, and the given @callback function as the callback.
 103  * Return 0 on success, or -errno on error.  On success, the watched path
 104  * (@path/@path2) will be saved as @watch->node, and becomes the caller's to
 105  * kfree().  On error, watch->node will be NULL, so the caller has nothing to
 106  * free, the device will switch to %XenbusStateClosing, and the error will be
 107  * saved in the store.
 108  */
 109 int xenbus_watch_pathfmt(struct xenbus_device *dev,
 110                          struct xenbus_watch *watch,
 111                          void (*callback)(struct xenbus_watch *,
 112                                         const char **, unsigned int),
 113                          const char *pathfmt, ...)
 114 {
 115         int err;
 116         va_list ap;
 117         char *path;
 118
 119         va_start(ap, pathfmt);
 120         path = kvasprintf(GFP_KERNEL, pathfmt, ap);
 121         va_end(ap);
 122
 123         if (!path) {
 124                 xenbus_dev_fatal(dev, -ENOMEM, "allocating path for watch");
 125                 return -ENOMEM;
 126         }
 127         err = xenbus_watch_path(dev, path, watch, callback);
 128
 129         if (err)
 130                 kfree(path);
 131         return err;
 132 }
 133 EXPORT_SYMBOL_GPL(xenbus_watch_pathfmt);
 134
 135
 136 /**
 137  * xenbus_switch_state
 138  * @dev: xenbus device
 139  * @xbt: transaction handle
 140  * @state: new state
 141  *
 142  * Advertise in the store a change of the given driver to the given new_state.
 143  * Return 0 on success, or -errno on error.  On error, the device will switch
 144  * to XenbusStateClosing, and the error will be saved in the store.
 145  */
 146 int xenbus_switch_state(struct xenbus_device *dev, enum xenbus_state state)
 147 {
 148         /* We check whether the state is currently set to the given value, and
 149            if not, then the state is set.  We don't want to unconditionally
 150            write the given state, because we don't want to fire watches
 151            unnecessarily.  Furthermore, if the node has gone, we don't write
 152            to it, as the device will be tearing down, and we don't want to
 153            resurrect that directory.
 154
 155            Note that, because of this cached value of our state, this function
 156            will not work inside a Xenstore transaction (something it was
 157            trying to in the past) because dev->state would not get reset if
 158            the transaction was aborted.
 159
 160          */
 161
 162         int current_state;
 163         int err;
 164
 165         if (state == dev->state)
 166                 return 0;
 167
 168         err = xenbus_scanf(XBT_NIL, dev->nodename, "state", "%d",
 169                            &current_state);
 170         if (err != 1)
 171                 return 0;
 172
 173         err = xenbus_printf(XBT_NIL, dev->nodename, "state", "%d", state);
 174         if (err) {
 175                 if (state != XenbusStateClosing) /* Avoid looping */
 176                         xenbus_dev_fatal(dev, err, "writing new state");
 177                 return err;
 178         }
 179
 180         dev->state = state;
 181
 182         return 0;
 183 }
 184 EXPORT_SYMBOL_GPL(xenbus_switch_state);
 185
 186 int xenbus_frontend_closed(struct xenbus_device *dev)
 187 {
 188         xenbus_switch_state(dev, XenbusStateClosed);
 189         complete(&dev->down);
 190         return 0;
 191 }
 192 EXPORT_SYMBOL_GPL(xenbus_frontend_closed);
 193
 194 /**
 195  * Return the path to the error node for the given device, or NULL on failure.
 196  * If the value returned is non-NULL, then it is the caller's to kfree.
 197  */
 198 static char *error_path(struct xenbus_device *dev)
 199 {
 200         return kasprintf(GFP_KERNEL, "error/%s", dev->nodename);
 201 }
 202
 203
 204 static void xenbus_va_dev_error(struct xenbus_device *dev, int err,
 205                                 const char *fmt, va_list ap)
 206 {
 207         int ret;
 208         unsigned int len;
 209         char *printf_buffer = NULL;
 210         char *path_buffer = NULL;
 211
 212 #define PRINTF_BUFFER_SIZE 4096
 213         printf_buffer = kmalloc(PRINTF_BUFFER_SIZE, GFP_KERNEL);
 214         if (printf_buffer == NULL)
 215                 goto fail;
 216
 217         len = sprintf(printf_buffer, "%i ", -err);
 218         ret = vsnprintf(printf_buffer+len, PRINTF_BUFFER_SIZE-len, fmt, ap);
 219
 220         BUG_ON(len + ret > PRINTF_BUFFER_SIZE-1);
 221
 222         dev_err(&dev->dev, "%s\n", printf_buffer);
 223
 224         path_buffer = error_path(dev);
 225
 226         if (path_buffer == NULL) {
 227                 dev_err(&dev->dev, "failed to write error node for %s (%s)\n",
 228                        dev->nodename, printf_buffer);
 229                 goto fail;
 230         }
 231
 232         if (xenbus_write(XBT_NIL, path_buffer, "error", printf_buffer) != 0) {
 233                 dev_err(&dev->dev, "failed to write error node for %s (%s)\n",
 234                        dev->nodename, printf_buffer);
 235                 goto fail;
 236         }
 237
 238 fail:
 239         kfree(printf_buffer);
 240         kfree(path_buffer);
 241 }
 242
 243
 244 /**
 245  * xenbus_dev_error
 246  * @dev: xenbus device
 247  * @err: error to report
 248  * @fmt: error message format
 249  *
 250  * Report the given negative errno into the store, along with the given
 251  * formatted message.
 252  */
 253 void xenbus_dev_error(struct xenbus_device *dev, int err, const char *fmt, ...)
 254 {
 255         va_list ap;
 256
 257         va_start(ap, fmt);
 258         xenbus_va_dev_error(dev, err, fmt, ap);
 259         va_end(ap);
 260 }
 261 EXPORT_SYMBOL_GPL(xenbus_dev_error);
 262
 263 /**
 264  * xenbus_dev_fatal
 265  * @dev: xenbus device
 266  * @err: error to report
 267  * @fmt: error message format
 268  *
 269  * Equivalent to xenbus_dev_error(dev, err, fmt, args), followed by
 270  * xenbus_switch_state(dev, NULL, XenbusStateClosing) to schedule an orderly
 271  * closedown of this driver and its peer.
 272  */
 273
 274 void xenbus_dev_fatal(struct xenbus_device *dev, int err, const char *fmt, ...)
 275 {
 276         va_list ap;
 277
 278         va_start(ap, fmt);
 279         xenbus_va_dev_error(dev, err, fmt, ap);
 280         va_end(ap);
 281
 282         xenbus_switch_state(dev, XenbusStateClosing);
 283 }
 284 EXPORT_SYMBOL_GPL(xenbus_dev_fatal);
 285
 286 /**
 287  * xenbus_grant_ring
 288  * @dev: xenbus device
 289  * @ring_mfn: mfn of ring to grant
 290
 291  * Grant access to the given @ring_mfn to the peer of the given device.  Return
 292  * 0 on success, or -errno on error.  On error, the device will switch to
 293  * XenbusStateClosing, and the error will be saved in the store.
 294  */
 295 int xenbus_grant_ring(struct xenbus_device *dev, unsigned long ring_mfn)
 296 {
 297         int err = gnttab_grant_foreign_access(dev->otherend_id, ring_mfn, 0);
 298         if (err < 0)
 299                 xenbus_dev_fatal(dev, err, "granting access to ring page");
 300         return err;
 301 }
 302 EXPORT_SYMBOL_GPL(xenbus_grant_ring);
 303
 304
 305 /**
 306  * Allocate an event channel for the given xenbus_device, assigning the newly
 307  * created local port to *port.  Return 0 on success, or -errno on error.  On
 308  * error, the device will switch to XenbusStateClosing, and the error will be
 309  * saved in the store.
 310  */
 311 int xenbus_alloc_evtchn(struct xenbus_device *dev, int *port)
 312 {
 313         struct evtchn_alloc_unbound alloc_unbound;
 314         int err;
 315
 316         alloc_unbound.dom = DOMID_SELF;
 317         alloc_unbound.remote_dom = dev->otherend_id;
 318
 319         err = HYPERVISOR_event_channel_op(EVTCHNOP_alloc_unbound,
 320                                           &alloc_unbound);
 321         if (err)
 322                 xenbus_dev_fatal(dev, err, "allocating event channel");
 323         else
 324                 *port = alloc_unbound.port;
 325
 326         return err;
 327 }
 328 EXPORT_SYMBOL_GPL(xenbus_alloc_evtchn);
 329
 330
 331 /**
 332  * Bind to an existing interdomain event channel in another domain. Returns 0
 333  * on success and stores the local port in *port. On error, returns -errno,
 334  * switches the device to XenbusStateClosing, and saves the error in XenStore.
 335  */
 336 int xenbus_bind_evtchn(struct xenbus_device *dev, int remote_port, int *port)
 337 {
 338         struct evtchn_bind_interdomain bind_interdomain;
 339         int err;
 340
 341         bind_interdomain.remote_dom = dev->otherend_id;
 342         bind_interdomain.remote_port = remote_port;
 343
 344         err = HYPERVISOR_event_channel_op(EVTCHNOP_bind_interdomain,
 345                                           &bind_interdomain);
 346         if (err)
 347                 xenbus_dev_fatal(dev, err,
 348                                  "binding to event channel %d from domain %d",
 349                                  remote_port, dev->otherend_id);
 350         else
 351                 *port = bind_interdomain.local_port;
 352
 353         return err;
 354 }
 355 EXPORT_SYMBOL_GPL(xenbus_bind_evtchn);
 356
 357
 358 /**
 359  * Free an existing event channel. Returns 0 on success or -errno on error.
 360  */
 361 int xenbus_free_evtchn(struct xenbus_device *dev, int port)
 362 {
 363         struct evtchn_close close;
 364         int err;
 365
 366         close.port = port;
 367
 368         err = HYPERVISOR_event_channel_op(EVTCHNOP_close, &close);
 369         if (err)
 370                 xenbus_dev_error(dev, err, "freeing event channel %d", port);
 371
 372         return err;
 373 }
 374 EXPORT_SYMBOL_GPL(xenbus_free_evtchn);
 375
 376
 377 /**
 378  * xenbus_map_ring_valloc
 379  * @dev: xenbus device
 380  * @gnt_ref: grant reference
 381  * @vaddr: pointer to address to be filled out by mapping
 382  *
 383  * Based on Rusty Russell's skeleton driver's map_page.
 384  * Map a page of memory into this domain from another domain's grant table.
 385  * xenbus_map_ring_valloc allocates a page of virtual address space, maps the
 386  * page to that address, and sets *vaddr to that address.
 387  * Returns 0 on success, and GNTST_* (see xen/include/interface/grant_table.h)
 388  * or -ENOMEM on error. If an error is returned, device will switch to
 389  * XenbusStateClosing and the error message will be saved in XenStore.
 390  */
 391 int xenbus_map_ring_valloc(struct xenbus_device *dev, int gnt_ref, void **vaddr)
 392 {
 393         struct gnttab_map_grant_ref op = {
 394                 .flags = GNTMAP_host_map,
 395                 .ref   = gnt_ref,
 396                 .dom   = dev->otherend_id,
 397         };
 398         struct vm_struct *area;
 399
 400         *vaddr = NULL;
 401
 402         area = xen_alloc_vm_area(PAGE_SIZE);
 403         if (!area)
 404                 return -ENOMEM;
 405
 406         op.host_addr = (unsigned long)area->addr;
 407
 408         if (HYPERVISOR_grant_table_op(GNTTABOP_map_grant_ref, &op, 1))
 409                 BUG();
 410
 411         if (op.status != GNTST_okay) {
 412                 xen_free_vm_area(area);
 413                 xenbus_dev_fatal(dev, op.status,
 414                                  "mapping in shared page %d from domain %d",
 415                                  gnt_ref, dev->otherend_id);
 416                 return op.status;
 417         }
 418
 419         /* Stuff the handle in an unused field */
 420         area->phys_addr = (unsigned long)op.handle;
 421
 422         *vaddr = area->addr;
 423         return 0;
 424 }
 425 EXPORT_SYMBOL_GPL(xenbus_map_ring_valloc);
 426
 427
 428 /**
 429  * xenbus_map_ring
 430  * @dev: xenbus device
 431  * @gnt_ref: grant reference
 432  * @handle: pointer to grant handle to be filled
 433  * @vaddr: address to be mapped to
 434  *
 435  * Map a page of memory into this domain from another domain's grant table.
 436  * xenbus_map_ring does not allocate the virtual address space (you must do
 437  * this yourself!). It only maps in the page to the specified address.
 438  * Returns 0 on success, and GNTST_* (see xen/include/interface/grant_table.h)
 439  * or -ENOMEM on error. If an error is returned, device will switch to
 440  * XenbusStateClosing and the error message will be saved in XenStore.
 441  */
 442 int xenbus_map_ring(struct xenbus_device *dev, int gnt_ref,
 443                     grant_handle_t *handle, void *vaddr)
 444 {
 445         struct gnttab_map_grant_ref op = {
 446                 .host_addr = (unsigned long)vaddr,
 447                 .flags     = GNTMAP_host_map,
 448                 .ref       = gnt_ref,
 449                 .dom       = dev->otherend_id,
 450         };
 451
 452         if (HYPERVISOR_grant_table_op(GNTTABOP_map_grant_ref, &op, 1))
 453                 BUG();
 454
 455         if (op.status != GNTST_okay) {
 456                 xenbus_dev_fatal(dev, op.status,
 457                                  "mapping in shared page %d from domain %d",
 458                                  gnt_ref, dev->otherend_id);
 459         } else
 460                 *handle = op.handle;
 461
 462         return op.status;
 463 }
 464 EXPORT_SYMBOL_GPL(xenbus_map_ring);
 465
 466
 467 /**
 468  * xenbus_unmap_ring_vfree
 469  * @dev: xenbus device
 470  * @vaddr: addr to unmap
 471  *
 472  * Based on Rusty Russell's skeleton driver's unmap_page.
 473  * Unmap a page of memory in this domain that was imported from another domain.
 474  * Use xenbus_unmap_ring_vfree if you mapped in your memory with
 475  * xenbus_map_ring_valloc (it will free the virtual address space).
 476  * Returns 0 on success and returns GNTST_* on error
 477  * (see xen/include/interface/grant_table.h).
 478  */
 479 int xenbus_unmap_ring_vfree(struct xenbus_device *dev, void *vaddr)
 480 {
 481         struct vm_struct *area;
 482         struct gnttab_unmap_grant_ref op = {
 483                 .host_addr = (unsigned long)vaddr,
 484         };
 485
 486         /* It'd be nice if linux/vmalloc.h provided a find_vm_area(void *addr)
 487          * method so that we don't have to muck with vmalloc internals here.
 488          * We could force the user to hang on to their struct vm_struct from
 489          * xenbus_map_ring_valloc, but these 6 lines considerably simplify
 490          * this API.
 491          */
 492         read_lock(&vmlist_lock);
 493         for (area = vmlist; area != NULL; area = area->next) {
 494                 if (area->addr == vaddr)
 495                         break;
 496         }
 497         read_unlock(&vmlist_lock);
 498
 499         if (!area) {
 500                 xenbus_dev_error(dev, -ENOENT,
 501                                  "can't find mapped virtual address %p", vaddr);
 502                 return GNTST_bad_virt_addr;
 503         }
 504
 505         op.handle = (grant_handle_t)area->phys_addr;
 506
 507         if (HYPERVISOR_grant_table_op(GNTTABOP_unmap_grant_ref, &op, 1))
 508                 BUG();
 509
 510         if (op.status == GNTST_okay)
 511                 xen_free_vm_area(area);
 512         else
 513                 xenbus_dev_error(dev, op.status,
 514                                  "unmapping page at handle %d error %d",
 515                                  (int16_t)area->phys_addr, op.status);
 516
 517         return op.status;
 518 }
 519 EXPORT_SYMBOL_GPL(xenbus_unmap_ring_vfree);
 520
 521
 522 /**
 523  * xenbus_unmap_ring
 524  * @dev: xenbus device
 525  * @handle: grant handle
 526  * @vaddr: addr to unmap
 527  *
 528  * Unmap a page of memory in this domain that was imported from another domain.
 529  * Returns 0 on success and returns GNTST_* on error
 530  * (see xen/include/interface/grant_table.h).
 531  */
 532 int xenbus_unmap_ring(struct xenbus_device *dev,
 533                       grant_handle_t handle, void *vaddr)
 534 {
 535         struct gnttab_unmap_grant_ref op = {
 536                 .host_addr = (unsigned long)vaddr,
 537                 .handle    = handle,
 538         };
 539
 540         if (HYPERVISOR_grant_table_op(GNTTABOP_unmap_grant_ref, &op, 1))
 541                 BUG();
 542
 543         if (op.status != GNTST_okay)
 544                 xenbus_dev_error(dev, op.status,
 545                                  "unmapping page at handle %d error %d",
 546                                  handle, op.status);
 547
 548         return op.status;
 549 }
 550 EXPORT_SYMBOL_GPL(xenbus_unmap_ring);
 551
 552
 553 /**
 554  * xenbus_read_driver_state
 555  * @path: path for driver
 556  *
 557  * Return the state of the driver rooted at the given store path, or
 558  * XenbusStateUnknown if no state can be read.
 559  */
 560 enum xenbus_state xenbus_read_driver_state(const char *path)
 561 {
 562         enum xenbus_state result;
 563         int err = xenbus_gather(XBT_NIL, path, "state", "%d", &result, NULL);
 564         if (err)
 565                 result = XenbusStateUnknown;
 566
 567         return result;
 568 }
 569 EXPORT_SYMBOL_GPL(xenbus_read_driver_state);