xref: /qemu/hw/xen/xen-legacy-backend.c (revision 6f0dd6c5)
1 /*
2  *  xen backend driver infrastructure
3  *  (c) 2008 Gerd Hoffmann <kraxel@redhat.com>
4  *
5  *  This program is free software; you can redistribute it and/or modify
6  *  it under the terms of the GNU General Public License as published by
7  *  the Free Software Foundation; under version 2 of the License.
8  *
9  *  This program is distributed in the hope that it will be useful,
10  *  but WITHOUT ANY WARRANTY; without even the implied warranty of
11  *  MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
12  *  GNU General Public License for more details.
13  *
14  *  You should have received a copy of the GNU General Public License along
15  *  with this program; if not, see <http://www.gnu.org/licenses/>.
16  *
17  *  Contributions after 2012-01-13 are licensed under the terms of the
18  *  GNU GPL, version 2 or (at your option) any later version.
19  */
20 
21 /*
22  * TODO: add some xenbus / xenstore concepts overview here.
23  */
24 
25 #include "qemu/osdep.h"
26 #include <sys/signal.h>
27 
28 #include "hw/sysbus.h"
29 #include "hw/boards.h"
30 #include "hw/qdev-properties.h"
31 #include "qemu/log.h"
32 #include "qemu/main-loop.h"
33 #include "qapi/error.h"
34 #include "hw/xen/xen-legacy-backend.h"
35 #include "hw/xen/xen_pvdev.h"
36 #include "monitor/qdev.h"
37 
38 DeviceState *xen_sysdev;
39 BusState *xen_sysbus;
40 
41 /* ------------------------------------------------------------- */
42 
43 /* public */
44 struct xs_handle *xenstore;
45 const char *xen_protocol;
46 
47 /* private */
48 static bool xen_feature_grant_copy;
49 static int debug;
50 
51 int xenstore_write_be_str(struct XenLegacyDevice *xendev, const char *node,
52                           const char *val)
53 {
54     return xenstore_write_str(xendev->be, node, val);
55 }
56 
57 int xenstore_write_be_int(struct XenLegacyDevice *xendev, const char *node,
58                           int ival)
59 {
60     return xenstore_write_int(xendev->be, node, ival);
61 }
62 
63 int xenstore_write_be_int64(struct XenLegacyDevice *xendev, const char *node,
64                             int64_t ival)
65 {
66     return xenstore_write_int64(xendev->be, node, ival);
67 }
68 
69 char *xenstore_read_be_str(struct XenLegacyDevice *xendev, const char *node)
70 {
71     return xenstore_read_str(xendev->be, node);
72 }
73 
74 int xenstore_read_be_int(struct XenLegacyDevice *xendev, const char *node,
75                          int *ival)
76 {
77     return xenstore_read_int(xendev->be, node, ival);
78 }
79 
80 char *xenstore_read_fe_str(struct XenLegacyDevice *xendev, const char *node)
81 {
82     return xenstore_read_str(xendev->fe, node);
83 }
84 
85 int xenstore_read_fe_int(struct XenLegacyDevice *xendev, const char *node,
86                          int *ival)
87 {
88     return xenstore_read_int(xendev->fe, node, ival);
89 }
90 
91 int xenstore_read_fe_uint64(struct XenLegacyDevice *xendev, const char *node,
92                             uint64_t *uval)
93 {
94     return xenstore_read_uint64(xendev->fe, node, uval);
95 }
96 
97 /* ------------------------------------------------------------- */
98 
99 int xen_be_set_state(struct XenLegacyDevice *xendev, enum xenbus_state state)
100 {
101     int rc;
102 
103     rc = xenstore_write_be_int(xendev, "state", state);
104     if (rc < 0) {
105         return rc;
106     }
107     xen_pv_printf(xendev, 1, "backend state: %s -> %s\n",
108                   xenbus_strstate(xendev->be_state), xenbus_strstate(state));
109     xendev->be_state = state;
110     return 0;
111 }
112 
113 void xen_be_set_max_grant_refs(struct XenLegacyDevice *xendev,
114                                unsigned int nr_refs)
115 {
116     assert(xendev->ops->flags & DEVOPS_FLAG_NEED_GNTDEV);
117 
118     if (xengnttab_set_max_grants(xendev->gnttabdev, nr_refs)) {
119         xen_pv_printf(xendev, 0, "xengnttab_set_max_grants failed: %s\n",
120                       strerror(errno));
121     }
122 }
123 
124 void *xen_be_map_grant_refs(struct XenLegacyDevice *xendev, uint32_t *refs,
125                             unsigned int nr_refs, int prot)
126 {
127     void *ptr;
128 
129     assert(xendev->ops->flags & DEVOPS_FLAG_NEED_GNTDEV);
130 
131     ptr = xengnttab_map_domain_grant_refs(xendev->gnttabdev, nr_refs,
132                                           xen_domid, refs, prot);
133     if (!ptr) {
134         xen_pv_printf(xendev, 0,
135                       "xengnttab_map_domain_grant_refs failed: %s\n",
136                       strerror(errno));
137     }
138 
139     return ptr;
140 }
141 
142 void xen_be_unmap_grant_refs(struct XenLegacyDevice *xendev, void *ptr,
143                              unsigned int nr_refs)
144 {
145     assert(xendev->ops->flags & DEVOPS_FLAG_NEED_GNTDEV);
146 
147     if (xengnttab_unmap(xendev->gnttabdev, ptr, nr_refs)) {
148         xen_pv_printf(xendev, 0, "xengnttab_unmap failed: %s\n",
149                       strerror(errno));
150     }
151 }
152 
153 static int compat_copy_grant_refs(struct XenLegacyDevice *xendev,
154                                   bool to_domain,
155                                   XenGrantCopySegment segs[],
156                                   unsigned int nr_segs)
157 {
158     uint32_t *refs = g_new(uint32_t, nr_segs);
159     int prot = to_domain ? PROT_WRITE : PROT_READ;
160     void *pages;
161     unsigned int i;
162 
163     for (i = 0; i < nr_segs; i++) {
164         XenGrantCopySegment *seg = &segs[i];
165 
166         refs[i] = to_domain ?
167             seg->dest.foreign.ref : seg->source.foreign.ref;
168     }
169 
170     pages = xengnttab_map_domain_grant_refs(xendev->gnttabdev, nr_segs,
171                                             xen_domid, refs, prot);
172     if (!pages) {
173         xen_pv_printf(xendev, 0,
174                       "xengnttab_map_domain_grant_refs failed: %s\n",
175                       strerror(errno));
176         g_free(refs);
177         return -1;
178     }
179 
180     for (i = 0; i < nr_segs; i++) {
181         XenGrantCopySegment *seg = &segs[i];
182         void *page = pages + (i * XC_PAGE_SIZE);
183 
184         if (to_domain) {
185             memcpy(page + seg->dest.foreign.offset, seg->source.virt,
186                    seg->len);
187         } else {
188             memcpy(seg->dest.virt, page + seg->source.foreign.offset,
189                    seg->len);
190         }
191     }
192 
193     if (xengnttab_unmap(xendev->gnttabdev, pages, nr_segs)) {
194         xen_pv_printf(xendev, 0, "xengnttab_unmap failed: %s\n",
195                       strerror(errno));
196     }
197 
198     g_free(refs);
199     return 0;
200 }
201 
202 int xen_be_copy_grant_refs(struct XenLegacyDevice *xendev,
203                            bool to_domain,
204                            XenGrantCopySegment segs[],
205                            unsigned int nr_segs)
206 {
207     xengnttab_grant_copy_segment_t *xengnttab_segs;
208     unsigned int i;
209     int rc;
210 
211     assert(xendev->ops->flags & DEVOPS_FLAG_NEED_GNTDEV);
212 
213     if (!xen_feature_grant_copy) {
214         return compat_copy_grant_refs(xendev, to_domain, segs, nr_segs);
215     }
216 
217     xengnttab_segs = g_new0(xengnttab_grant_copy_segment_t, nr_segs);
218 
219     for (i = 0; i < nr_segs; i++) {
220         XenGrantCopySegment *seg = &segs[i];
221         xengnttab_grant_copy_segment_t *xengnttab_seg = &xengnttab_segs[i];
222 
223         if (to_domain) {
224             xengnttab_seg->flags = GNTCOPY_dest_gref;
225             xengnttab_seg->dest.foreign.domid = xen_domid;
226             xengnttab_seg->dest.foreign.ref = seg->dest.foreign.ref;
227             xengnttab_seg->dest.foreign.offset = seg->dest.foreign.offset;
228             xengnttab_seg->source.virt = seg->source.virt;
229         } else {
230             xengnttab_seg->flags = GNTCOPY_source_gref;
231             xengnttab_seg->source.foreign.domid = xen_domid;
232             xengnttab_seg->source.foreign.ref = seg->source.foreign.ref;
233             xengnttab_seg->source.foreign.offset =
234                 seg->source.foreign.offset;
235             xengnttab_seg->dest.virt = seg->dest.virt;
236         }
237 
238         xengnttab_seg->len = seg->len;
239     }
240 
241     rc = xengnttab_grant_copy(xendev->gnttabdev, nr_segs, xengnttab_segs);
242 
243     if (rc) {
244         xen_pv_printf(xendev, 0, "xengnttab_copy failed: %s\n",
245                       strerror(errno));
246     }
247 
248     for (i = 0; i < nr_segs; i++) {
249         xengnttab_grant_copy_segment_t *xengnttab_seg =
250             &xengnttab_segs[i];
251 
252         if (xengnttab_seg->status != GNTST_okay) {
253             xen_pv_printf(xendev, 0, "segment[%u] status: %d\n", i,
254                           xengnttab_seg->status);
255             rc = -1;
256         }
257     }
258 
259     g_free(xengnttab_segs);
260     return rc;
261 }
262 
263 /*
264  * get xen backend device, allocate a new one if it doesn't exist.
265  */
266 static struct XenLegacyDevice *xen_be_get_xendev(const char *type, int dom,
267                                                  int dev,
268                                                  struct XenDevOps *ops)
269 {
270     struct XenLegacyDevice *xendev;
271 
272     xendev = xen_pv_find_xendev(type, dom, dev);
273     if (xendev) {
274         return xendev;
275     }
276 
277     /* init new xendev */
278     xendev = g_malloc0(ops->size);
279     object_initialize(&xendev->qdev, ops->size, TYPE_XENBACKEND);
280     OBJECT(xendev)->free = g_free;
281     qdev_set_parent_bus(DEVICE(xendev), xen_sysbus);
282     qdev_set_id(DEVICE(xendev), g_strdup_printf("xen-%s-%d", type, dev));
283     qdev_init_nofail(DEVICE(xendev));
284     object_unref(OBJECT(xendev));
285 
286     xendev->type  = type;
287     xendev->dom   = dom;
288     xendev->dev   = dev;
289     xendev->ops   = ops;
290 
291     snprintf(xendev->be, sizeof(xendev->be), "backend/%s/%d/%d",
292              xendev->type, xendev->dom, xendev->dev);
293     snprintf(xendev->name, sizeof(xendev->name), "%s-%d",
294              xendev->type, xendev->dev);
295 
296     xendev->debug      = debug;
297     xendev->local_port = -1;
298 
299     xendev->evtchndev = xenevtchn_open(NULL, 0);
300     if (xendev->evtchndev == NULL) {
301         xen_pv_printf(NULL, 0, "can't open evtchn device\n");
302         qdev_unplug(DEVICE(xendev), NULL);
303         return NULL;
304     }
305     qemu_set_cloexec(xenevtchn_fd(xendev->evtchndev));
306 
307     xen_pv_insert_xendev(xendev);
308 
309     if (xendev->ops->alloc) {
310         xendev->ops->alloc(xendev);
311     }
312 
313     return xendev;
314 }
315 
316 
317 /*
318  * Sync internal data structures on xenstore updates.
319  * Node specifies the changed field.  node = NULL means
320  * update all fields (used for initialization).
321  */
322 static void xen_be_backend_changed(struct XenLegacyDevice *xendev,
323                                    const char *node)
324 {
325     if (node == NULL  ||  strcmp(node, "online") == 0) {
326         if (xenstore_read_be_int(xendev, "online", &xendev->online) == -1) {
327             xendev->online = 0;
328         }
329     }
330 
331     if (node) {
332         xen_pv_printf(xendev, 2, "backend update: %s\n", node);
333         if (xendev->ops->backend_changed) {
334             xendev->ops->backend_changed(xendev, node);
335         }
336     }
337 }
338 
339 static void xen_be_frontend_changed(struct XenLegacyDevice *xendev,
340                                     const char *node)
341 {
342     int fe_state;
343 
344     if (node == NULL  ||  strcmp(node, "state") == 0) {
345         if (xenstore_read_fe_int(xendev, "state", &fe_state) == -1) {
346             fe_state = XenbusStateUnknown;
347         }
348         if (xendev->fe_state != fe_state) {
349             xen_pv_printf(xendev, 1, "frontend state: %s -> %s\n",
350                           xenbus_strstate(xendev->fe_state),
351                           xenbus_strstate(fe_state));
352         }
353         xendev->fe_state = fe_state;
354     }
355     if (node == NULL  ||  strcmp(node, "protocol") == 0) {
356         g_free(xendev->protocol);
357         xendev->protocol = xenstore_read_fe_str(xendev, "protocol");
358         if (xendev->protocol) {
359             xen_pv_printf(xendev, 1, "frontend protocol: %s\n",
360                           xendev->protocol);
361         }
362     }
363 
364     if (node) {
365         xen_pv_printf(xendev, 2, "frontend update: %s\n", node);
366         if (xendev->ops->frontend_changed) {
367             xendev->ops->frontend_changed(xendev, node);
368         }
369     }
370 }
371 
372 /* ------------------------------------------------------------- */
373 /* Check for possible state transitions and perform them.        */
374 
375 /*
376  * Initial xendev setup.  Read frontend path, register watch for it.
377  * Should succeed once xend finished setting up the backend device.
378  *
379  * Also sets initial state (-> Initializing) when done.  Which
380  * only affects the xendev->be_state variable as xenbus should
381  * already be put into that state by xend.
382  */
383 static int xen_be_try_setup(struct XenLegacyDevice *xendev)
384 {
385     char token[XEN_BUFSIZE];
386     int be_state;
387 
388     if (xenstore_read_be_int(xendev, "state", &be_state) == -1) {
389         xen_pv_printf(xendev, 0, "reading backend state failed\n");
390         return -1;
391     }
392 
393     if (be_state != XenbusStateInitialising) {
394         xen_pv_printf(xendev, 0, "initial backend state is wrong (%s)\n",
395                       xenbus_strstate(be_state));
396         return -1;
397     }
398 
399     xendev->fe = xenstore_read_be_str(xendev, "frontend");
400     if (xendev->fe == NULL) {
401         xen_pv_printf(xendev, 0, "reading frontend path failed\n");
402         return -1;
403     }
404 
405     /* setup frontend watch */
406     snprintf(token, sizeof(token), "fe:%p", xendev);
407     if (!xs_watch(xenstore, xendev->fe, token)) {
408         xen_pv_printf(xendev, 0, "watching frontend path (%s) failed\n",
409                       xendev->fe);
410         return -1;
411     }
412     xen_be_set_state(xendev, XenbusStateInitialising);
413 
414     xen_be_backend_changed(xendev, NULL);
415     xen_be_frontend_changed(xendev, NULL);
416     return 0;
417 }
418 
419 /*
420  * Try initialize xendev.  Prepare everything the backend can do
421  * without synchronizing with the frontend.  Fakes hotplug-status.  No
422  * hotplug involved here because this is about userspace drivers, thus
423  * there are kernel backend devices which could invoke hotplug.
424  *
425  * Goes to InitWait on success.
426  */
427 static int xen_be_try_init(struct XenLegacyDevice *xendev)
428 {
429     int rc = 0;
430 
431     if (!xendev->online) {
432         xen_pv_printf(xendev, 1, "not online\n");
433         return -1;
434     }
435 
436     if (xendev->ops->init) {
437         rc = xendev->ops->init(xendev);
438     }
439     if (rc != 0) {
440         xen_pv_printf(xendev, 1, "init() failed\n");
441         return rc;
442     }
443 
444     xenstore_write_be_str(xendev, "hotplug-status", "connected");
445     xen_be_set_state(xendev, XenbusStateInitWait);
446     return 0;
447 }
448 
449 /*
450  * Try to initialise xendev.  Depends on the frontend being ready
451  * for it (shared ring and evtchn info in xenstore, state being
452  * Initialised or Connected).
453  *
454  * Goes to Connected on success.
455  */
456 static int xen_be_try_initialise(struct XenLegacyDevice *xendev)
457 {
458     int rc = 0;
459 
460     if (xendev->fe_state != XenbusStateInitialised  &&
461         xendev->fe_state != XenbusStateConnected) {
462         if (xendev->ops->flags & DEVOPS_FLAG_IGNORE_STATE) {
463             xen_pv_printf(xendev, 2, "frontend not ready, ignoring\n");
464         } else {
465             xen_pv_printf(xendev, 2, "frontend not ready (yet)\n");
466             return -1;
467         }
468     }
469 
470     if (xendev->ops->flags & DEVOPS_FLAG_NEED_GNTDEV) {
471         xendev->gnttabdev = xengnttab_open(NULL, 0);
472         if (xendev->gnttabdev == NULL) {
473             xen_pv_printf(NULL, 0, "can't open gnttab device\n");
474             return -1;
475         }
476     } else {
477         xendev->gnttabdev = NULL;
478     }
479 
480     if (xendev->ops->initialise) {
481         rc = xendev->ops->initialise(xendev);
482     }
483     if (rc != 0) {
484         xen_pv_printf(xendev, 0, "initialise() failed\n");
485         return rc;
486     }
487 
488     xen_be_set_state(xendev, XenbusStateConnected);
489     return 0;
490 }
491 
492 /*
493  * Try to let xendev know that it is connected.  Depends on the
494  * frontend being Connected.  Note that this may be called more
495  * than once since the backend state is not modified.
496  */
497 static void xen_be_try_connected(struct XenLegacyDevice *xendev)
498 {
499     if (!xendev->ops->connected) {
500         return;
501     }
502 
503     if (xendev->fe_state != XenbusStateConnected) {
504         if (xendev->ops->flags & DEVOPS_FLAG_IGNORE_STATE) {
505             xen_pv_printf(xendev, 2, "frontend not ready, ignoring\n");
506         } else {
507             xen_pv_printf(xendev, 2, "frontend not ready (yet)\n");
508             return;
509         }
510     }
511 
512     xendev->ops->connected(xendev);
513 }
514 
515 /*
516  * Teardown connection.
517  *
518  * Goes to Closed when done.
519  */
520 static void xen_be_disconnect(struct XenLegacyDevice *xendev,
521                               enum xenbus_state state)
522 {
523     if (xendev->be_state != XenbusStateClosing &&
524         xendev->be_state != XenbusStateClosed  &&
525         xendev->ops->disconnect) {
526         xendev->ops->disconnect(xendev);
527     }
528     if (xendev->gnttabdev) {
529         xengnttab_close(xendev->gnttabdev);
530         xendev->gnttabdev = NULL;
531     }
532     if (xendev->be_state != state) {
533         xen_be_set_state(xendev, state);
534     }
535 }
536 
537 /*
538  * Try to reset xendev, for reconnection by another frontend instance.
539  */
540 static int xen_be_try_reset(struct XenLegacyDevice *xendev)
541 {
542     if (xendev->fe_state != XenbusStateInitialising) {
543         return -1;
544     }
545 
546     xen_pv_printf(xendev, 1, "device reset (for re-connect)\n");
547     xen_be_set_state(xendev, XenbusStateInitialising);
548     return 0;
549 }
550 
551 /*
552  * state change dispatcher function
553  */
554 void xen_be_check_state(struct XenLegacyDevice *xendev)
555 {
556     int rc = 0;
557 
558     /* frontend may request shutdown from almost anywhere */
559     if (xendev->fe_state == XenbusStateClosing ||
560         xendev->fe_state == XenbusStateClosed) {
561         xen_be_disconnect(xendev, xendev->fe_state);
562         return;
563     }
564 
565     /* check for possible backend state transitions */
566     for (;;) {
567         switch (xendev->be_state) {
568         case XenbusStateUnknown:
569             rc = xen_be_try_setup(xendev);
570             break;
571         case XenbusStateInitialising:
572             rc = xen_be_try_init(xendev);
573             break;
574         case XenbusStateInitWait:
575             rc = xen_be_try_initialise(xendev);
576             break;
577         case XenbusStateConnected:
578             /* xendev->be_state doesn't change */
579             xen_be_try_connected(xendev);
580             rc = -1;
581             break;
582         case XenbusStateClosed:
583             rc = xen_be_try_reset(xendev);
584             break;
585         default:
586             rc = -1;
587         }
588         if (rc != 0) {
589             break;
590         }
591     }
592 }
593 
594 /* ------------------------------------------------------------- */
595 
596 static int xenstore_scan(const char *type, int dom, struct XenDevOps *ops)
597 {
598     struct XenLegacyDevice *xendev;
599     char path[XEN_BUFSIZE], token[XEN_BUFSIZE];
600     char **dev = NULL;
601     unsigned int cdev, j;
602 
603     /* setup watch */
604     snprintf(token, sizeof(token), "be:%p:%d:%p", type, dom, ops);
605     snprintf(path, sizeof(path), "backend/%s/%d", type, dom);
606     if (!xs_watch(xenstore, path, token)) {
607         xen_pv_printf(NULL, 0, "xen be: watching backend path (%s) failed\n",
608                       path);
609         return -1;
610     }
611 
612     /* look for backends */
613     dev = xs_directory(xenstore, 0, path, &cdev);
614     if (!dev) {
615         return 0;
616     }
617     for (j = 0; j < cdev; j++) {
618         xendev = xen_be_get_xendev(type, dom, atoi(dev[j]), ops);
619         if (xendev == NULL) {
620             continue;
621         }
622         xen_be_check_state(xendev);
623     }
624     free(dev);
625     return 0;
626 }
627 
628 void xenstore_update_be(char *watch, char *type, int dom,
629                         struct XenDevOps *ops)
630 {
631     struct XenLegacyDevice *xendev;
632     char path[XEN_BUFSIZE], *bepath;
633     unsigned int len, dev;
634 
635     len = snprintf(path, sizeof(path), "backend/%s/%d", type, dom);
636     if (strncmp(path, watch, len) != 0) {
637         return;
638     }
639     if (sscanf(watch + len, "/%u/%255s", &dev, path) != 2) {
640         strcpy(path, "");
641         if (sscanf(watch + len, "/%u", &dev) != 1) {
642             dev = -1;
643         }
644     }
645     if (dev == -1) {
646         return;
647     }
648 
649     xendev = xen_be_get_xendev(type, dom, dev, ops);
650     if (xendev != NULL) {
651         bepath = xs_read(xenstore, 0, xendev->be, &len);
652         if (bepath == NULL) {
653             xen_pv_del_xendev(xendev);
654         } else {
655             free(bepath);
656             xen_be_backend_changed(xendev, path);
657             xen_be_check_state(xendev);
658         }
659     }
660 }
661 
662 void xenstore_update_fe(char *watch, struct XenLegacyDevice *xendev)
663 {
664     char *node;
665     unsigned int len;
666 
667     len = strlen(xendev->fe);
668     if (strncmp(xendev->fe, watch, len) != 0) {
669         return;
670     }
671     if (watch[len] != '/') {
672         return;
673     }
674     node = watch + len + 1;
675 
676     xen_be_frontend_changed(xendev, node);
677     xen_be_check_state(xendev);
678 }
679 /* -------------------------------------------------------------------- */
680 
681 int xen_be_init(void)
682 {
683     xengnttab_handle *gnttabdev;
684 
685     xenstore = xs_daemon_open();
686     if (!xenstore) {
687         xen_pv_printf(NULL, 0, "can't connect to xenstored\n");
688         return -1;
689     }
690 
691     qemu_set_fd_handler(xs_fileno(xenstore), xenstore_update, NULL, NULL);
692 
693     if (xen_xc == NULL || xen_fmem == NULL) {
694         /* Check if xen_init() have been called */
695         goto err;
696     }
697 
698     gnttabdev = xengnttab_open(NULL, 0);
699     if (gnttabdev != NULL) {
700         if (xengnttab_grant_copy(gnttabdev, 0, NULL) == 0) {
701             xen_feature_grant_copy = true;
702         }
703         xengnttab_close(gnttabdev);
704     }
705 
706     xen_sysdev = qdev_create(NULL, TYPE_XENSYSDEV);
707     qdev_init_nofail(xen_sysdev);
708     xen_sysbus = qbus_create(TYPE_XENSYSBUS, DEVICE(xen_sysdev), "xen-sysbus");
709     qbus_set_bus_hotplug_handler(xen_sysbus, &error_abort);
710 
711     return 0;
712 
713 err:
714     qemu_set_fd_handler(xs_fileno(xenstore), NULL, NULL, NULL);
715     xs_daemon_close(xenstore);
716     xenstore = NULL;
717 
718     return -1;
719 }
720 
721 static void xen_set_dynamic_sysbus(void)
722 {
723     Object *machine = qdev_get_machine();
724     ObjectClass *oc = object_get_class(machine);
725     MachineClass *mc = MACHINE_CLASS(oc);
726 
727     machine_class_allow_dynamic_sysbus_dev(mc, TYPE_XENSYSDEV);
728 }
729 
730 int xen_be_register(const char *type, struct XenDevOps *ops)
731 {
732     char path[50];
733     int rc;
734 
735     if (ops->backend_register) {
736         rc = ops->backend_register();
737         if (rc) {
738             return rc;
739         }
740     }
741 
742     snprintf(path, sizeof(path), "device-model/%u/backends/%s", xen_domid,
743              type);
744     xenstore_mkdir(path, XS_PERM_NONE);
745 
746     return xenstore_scan(type, xen_domid, ops);
747 }
748 
749 void xen_be_register_common(void)
750 {
751     xen_set_dynamic_sysbus();
752 
753     xen_be_register("console", &xen_console_ops);
754     xen_be_register("vkbd", &xen_kbdmouse_ops);
755 #ifdef CONFIG_VIRTFS
756     xen_be_register("9pfs", &xen_9pfs_ops);
757 #endif
758 #ifdef CONFIG_USB_LIBUSB
759     xen_be_register("qusb", &xen_usb_ops);
760 #endif
761 }
762 
763 int xen_be_bind_evtchn(struct XenLegacyDevice *xendev)
764 {
765     if (xendev->local_port != -1) {
766         return 0;
767     }
768     xendev->local_port = xenevtchn_bind_interdomain
769         (xendev->evtchndev, xendev->dom, xendev->remote_port);
770     if (xendev->local_port == -1) {
771         xen_pv_printf(xendev, 0, "xenevtchn_bind_interdomain failed\n");
772         return -1;
773     }
774     xen_pv_printf(xendev, 2, "bind evtchn port %d\n", xendev->local_port);
775     qemu_set_fd_handler(xenevtchn_fd(xendev->evtchndev),
776                         xen_pv_evtchn_event, NULL, xendev);
777     return 0;
778 }
779 
780 
781 static Property xendev_properties[] = {
782     DEFINE_PROP_END_OF_LIST(),
783 };
784 
785 static void xendev_class_init(ObjectClass *klass, void *data)
786 {
787     DeviceClass *dc = DEVICE_CLASS(klass);
788 
789     dc->props = xendev_properties;
790     set_bit(DEVICE_CATEGORY_MISC, dc->categories);
791     /* xen-backend devices can be plugged/unplugged dynamically */
792     dc->user_creatable = true;
793 }
794 
795 static const TypeInfo xendev_type_info = {
796     .name          = TYPE_XENBACKEND,
797     .parent        = TYPE_XENSYSDEV,
798     .class_init    = xendev_class_init,
799     .instance_size = sizeof(struct XenLegacyDevice),
800 };
801 
802 static void xen_sysbus_class_init(ObjectClass *klass, void *data)
803 {
804     HotplugHandlerClass *hc = HOTPLUG_HANDLER_CLASS(klass);
805 
806     hc->unplug = qdev_simple_device_unplug_cb;
807 }
808 
809 static const TypeInfo xensysbus_info = {
810     .name       = TYPE_XENSYSBUS,
811     .parent     = TYPE_BUS,
812     .class_init = xen_sysbus_class_init,
813     .interfaces = (InterfaceInfo[]) {
814         { TYPE_HOTPLUG_HANDLER },
815         { }
816     }
817 };
818 
819 static Property xen_sysdev_properties[] = {
820     {/* end of property list */},
821 };
822 
823 static void xen_sysdev_class_init(ObjectClass *klass, void *data)
824 {
825     DeviceClass *dc = DEVICE_CLASS(klass);
826 
827     dc->props = xen_sysdev_properties;
828     dc->bus_type = TYPE_XENSYSBUS;
829 }
830 
831 static const TypeInfo xensysdev_info = {
832     .name          = TYPE_XENSYSDEV,
833     .parent        = TYPE_SYS_BUS_DEVICE,
834     .instance_size = sizeof(SysBusDevice),
835     .class_init    = xen_sysdev_class_init,
836 };
837 
838 static void xenbe_register_types(void)
839 {
840     type_register_static(&xensysbus_info);
841     type_register_static(&xensysdev_info);
842     type_register_static(&xendev_type_info);
843 }
844 
845 type_init(xenbe_register_types)
846