| /xen/tools/libxl/ |
| A D | libxl_stream_write.c | 66 static void stream_done(libxl__egc *egc,
109 static void write_done(libxl__egc *egc,
188 static void write_done(libxl__egc *egc, in write_done() argument
201 cb(egc, stream); in write_done()
285 stream_complete(egc, stream, rc); in libxl__stream_write_start()
419 stream_complete(egc, stream, rc); in write_emulator_xenstore_record()
499 stream_complete(egc, stream, rc); in write_emulator_context_record()
533 write_end_record(egc, stream); in emulator_context_record_done()
563 checkpoint_done(egc, stream, 0); in checkpoint_end_record_done()
570 stream_complete(egc, stream, 0); in stream_success()
[all …]
|
| A D | libxl_remus.c | 63 static void remus_setup_done(libxl__egc *egc,
120 dss->callback(egc, dss, ERROR_FAIL); in libxl__remus_setup()
130 libxl__domain_save(egc, dss); in remus_setup_done()
151 dss->callback(egc, dss, rc); in remus_setup_failed()
157 void libxl__remus_teardown(libxl__egc *egc, in libxl__remus_teardown() argument
187 dss->callback(egc, dss, rc); in remus_teardown_done()
204 libxl__egc *egc = shs->egc; in libxl__remus_domain_suspend_callback() local
209 libxl__domain_suspend(egc, dsps); in libxl__remus_domain_suspend_callback()
250 libxl__egc *egc = shs->egc; in libxl__remus_domain_resume_callback() local
295 libxl__egc *egc = shs->egc; in libxl__remus_domain_save_checkpoint_callback() local
[all …]
|
| A D | libxl_stream_read.c | 293 stream_complete(egc, stream, rc); in libxl__stream_read_start()
309 stream_continue(egc, stream); in libxl__stream_read_start_checkpoint()
360 stream_continue(egc, stream); in stream_header_done()
365 stream_complete(egc, stream, rc); in stream_header_done()
494 stream_complete(egc, stream, rc); in setup_read_record()
526 stream_complete(egc, stream, rc); in record_header_done()
543 stream_continue(egc, stream); in record_body_done()
548 stream_complete(egc, stream, rc); in record_body_done()
729 stream_continue(egc, stream); in write_emulator_done()
771 stream_done(egc, stream, rc); in stream_complete()
[all …]
|
| A D | libxl_colo_restore.c | 76 lds->callback(egc, lds, 0); in colo_enable_logdirty()
101 lds->callback(egc, lds, 0); in colo_disable_logdirty()
131 crcs->callback(egc, crcs, rc); in colo_resume_vm()
279 crs->callback(egc, crs, rc); in libxl__colo_restore_setup()
289 crcs->callback(egc, crcs, rc); in libxl__colo_domain_create_cb()
366 do_failover(egc, crs); in colo_restore_teardown_devices_done()
444 crcs->callback(egc, crcs, 0); in colo_disable_logdirty_done()
632 colo_resume_vm(egc, crcs, 1); in colo_restore_resume_vm()
729 colo_enable_logdirty(crs, egc); in colo_reenable_logdirty()
1055 crcs->callback(egc, crcs, 0); in colo_common_write_stream_done()
[all …]
|
| A D | libxl_colo_save.c | 138 libxl__stream_read_start(egc, &css->srs); in libxl__colo_save_setup()
158 dss->callback(egc, dss, ERROR_FAIL); in libxl__colo_save_setup()
170 libxl__domain_save(egc, dss); in colo_save_setup_done()
193 dss->callback(egc, dss, rc); in colo_save_setup_failed()
235 dss->callback(egc, dss, rc); in colo_teardown_done()
267 libxl__egc *egc = shs->egc; in libxl__colo_save_domain_suspend_callback() local
275 libxl__domain_suspend(egc, dsps); in libxl__colo_save_domain_suspend_callback()
402 libxl__egc *egc = shs->egc; in libxl__colo_save_domain_resume_callback() local
597 libxl__egc *egc = dss->sws.shs.egc; in libxl__colo_save_domain_wait_checkpoint_callback() local
676 css->callback(egc, css, 0); in colo_common_write_stream_done()
[all …]
|
| A D | libxl_dom_suspend.c | 22 int libxl__domain_suspend_init(libxl__egc *egc, in libxl__domain_suspend_init() argument
129 void libxl__domain_suspend(libxl__egc *egc, in libxl__domain_suspend() argument
401 libxl__egc *egc = shs->egc; in libxl__domain_suspend_callback() local
503 void libxl__dm_resume(libxl__egc *egc, in libxl__dm_resume() argument
559 dm_resume_done(egc, dmrs, rc); in libxl__dm_resume()
580 dm_resume_done(egc, dmrs, rc); in dm_resume_xswatch_cb()
589 dm_resume_done(egc, dmrs, rc); in dm_resume_qmp_done()
598 dm_resume_done(egc, dmrs, rc); in dm_resume_timeout()
620 void libxl__domain_resume(libxl__egc *egc, in libxl__domain_resume() argument
644 domain_resume_done(egc, dmrs, rc); in libxl__domain_resume()
[all …]
|
| A D | libxl_checkpoint_device.c | 24 static void all_devices_setup_cb(libxl__egc *egc,
27 static void device_setup_iterate(libxl__egc *egc,
29 static void devices_teardown_cb(libxl__egc *egc,
90 checkpoint_devices_setup(egc, cds); in libxl__checkpoint_devices_setup()
95 cds->callback(egc, cds, 0); in libxl__checkpoint_devices_setup()
164 dev->ops->setup(egc,dev); in device_setup_iterate()
168 libxl__multidev_one_callback(egc,aodev); in device_setup_iterate()
181 cds->callback(egc, cds, rc); in all_devices_setup_cb()
200 dev->ops->teardown(egc,dev); in libxl__checkpoint_devices_teardown()
226 cds->callback(egc, cds, rc); in devices_teardown_cb()
[all …]
|
| A D | libxl_save_callout.c | 111 shs->egc = egc; in libxl__xc_domain_saverestore_async_callback_done()
113 shs->egc = 0; in libxl__xc_domain_saverestore_async_callback_done()
244 helper_failed(egc, shs, rc);; in run_helper()
258 helper_done(egc, shs); in helper_failed()
271 helper_failed(egc, shs, rc); in helper_stop()
314 shs->egc = egc; in helper_stdout_readable()
316 shs->egc = 0; in helper_stdout_readable()
352 helper_done(egc, shs); in helper_exited()
366 shs->egc = egc; in helper_done()
369 shs->egc = 0; in helper_done()
[all …]
|
| A D | libxl_dom_save.c | 24 static void stream_done(libxl__egc *egc,
26 static void domain_save_done(libxl__egc *egc,
152 switch_logdirty_done(egc,lds,rc); in domain_suspend_switch_qemu_xen_traditional_logdirty()
205 switch_logdirty_done(egc,lds,rc); in switch_logdirty_xswatch()
248 switch_logdirty_done(egc, lds, rc); in switch_qemu_xen_logdirty_done()
271 lds->callback(egc, lds, rc); in switch_logdirty_done()
281 libxl__egc *egc = shs->egc; in libxl__domain_suspend_common_switch_qemu_logdirty() local
444 domain_save_done(egc, dss, rc); in libxl__domain_save()
447 static void stream_done(libxl__egc *egc, in stream_done() argument
450 domain_save_done(egc, sws->dss, rc); in stream_done()
[all …]
|
| A D | libxl_remus_disk_drbd.c | 48 static void match_async_exec_cb(libxl__egc *egc,
60 match_async_exec(egc, dev); in drbd_setup()
101 dev->aodev.callback(egc, &dev->aodev); in match_async_exec()
104 static void match_async_exec_cb(libxl__egc *egc, in match_async_exec_cb() argument
141 aodev->callback(egc, aodev); in match_async_exec_cb()
151 dev->aodev.callback(egc, &dev->aodev); in drbd_teardown()
157 static void checkpoint_async_call_done(libxl__egc *egc,
176 dev->aodev.callback(egc, &dev->aodev); in drbd_postsuspend()
184 ASYNC_CALL(egc, dev->cds->ao, &dev->aodev.child, dev, in drbd_preresume()
202 static void checkpoint_async_call_done(libxl__egc *egc, in checkpoint_async_call_done() argument
[all …]
|
| A D | libxl_colo_qdisk.c | 104 dev->aodev.callback(egc, &dev->aodev); in colo_qdisk_setup()
144 dev->aodev.callback(egc, &dev->aodev); in colo_qdisk_teardown()
149 static void colo_qdisk_save_preresume(libxl__egc *egc, in colo_qdisk_save_preresume() argument
188 dev->aodev.callback(egc, &dev->aodev); in colo_qdisk_save_preresume()
193 static void colo_qdisk_save_setup(libxl__egc *egc, in colo_qdisk_save_setup() argument
196 colo_qdisk_setup(egc, dev, true); in colo_qdisk_save_setup()
199 static void colo_qdisk_save_teardown(libxl__egc *egc, in colo_qdisk_save_teardown() argument
202 colo_qdisk_teardown(egc, dev, true); in colo_qdisk_save_teardown()
214 static void colo_qdisk_restore_setup(libxl__egc *egc, in colo_qdisk_restore_setup() argument
217 colo_qdisk_setup(egc, dev, false); in colo_qdisk_restore_setup()
[all …]
|
| A D | libxl_convert_callout.c | 27 static void helper_exited(libxl__egc *egc, libxl__ev_child *ch,
29 static void helper_stop(libxl__egc *egc, libxl__ao_abortable *abrt, int rc);
30 static void helper_done(libxl__egc *egc,
45 int libxl__convert_legacy_stream(libxl__egc *egc, in libxl__convert_legacy_stream() argument
119 void libxl__conversion_helper_abort(libxl__egc *egc, in libxl__conversion_helper_abort() argument
137 static void helper_stop(libxl__egc *egc, libxl__ao_abortable *abrt, int rc) in helper_stop() argument
142 libxl__conversion_helper_abort(egc, chs, rc); in helper_stop()
145 static void helper_exited(libxl__egc *egc, libxl__ev_child *ch, in helper_exited() argument
160 helper_done(egc, chs); in helper_exited()
163 static void helper_done(libxl__egc *egc, in helper_done() argument
[all …]
|
| A D | libxl_no_colo.c | 20 void libxl__colo_restore_setup(libxl__egc *egc, in libxl__colo_restore_setup() argument
27 crs->callback(egc, crs, ERROR_FAIL); in libxl__colo_restore_setup()
30 void libxl__colo_restore_teardown(libxl__egc *egc, void *dcs_void, in libxl__colo_restore_teardown() argument
37 void libxl__colo_save_setup(libxl__egc *egc, libxl__colo_save_state *css) in libxl__colo_save_setup() argument
44 dss->callback(egc, dss, ERROR_FAIL); in libxl__colo_save_setup()
47 void libxl__colo_save_teardown(libxl__egc *egc, in libxl__colo_save_teardown() argument
|
| A D | libxl_aoutils.c | 79 xswa->callback(egc, xswa, 0, data); in xswait_xswatch_callback()
89 xswait_report_error(egc, xswa, rc); in xswait_timeout_callback()
97 xswa->callback(egc, xswa, rc, 0); in xswait_report_error()
129 dc->callback(egc, dc, rc, onwrite, errnoval); in datacopier_callback()
154 datacopier_callback(egc, dc, 0, 0, 0); in datacopier_check_state()
211 datacopier_callback(egc, dc, rc, -1, 0); in datacopier_abort()
314 datacopier_check_state(egc, dc); in datacopier_readable()
359 datacopier_check_state(egc, dc); in datacopier_writable()
425 op->callback(egc, op); in openpty_exited()
549 static void async_exec_done(libxl__egc *egc, in async_exec_done() argument
[all …]
|
| A D | libxl_colo_nic.c | 38 static void colo_save_setup_script_cb(libxl__egc *egc,
41 static void colo_save_teardown_script_cb(libxl__egc *egc,
182 dev->aodev.callback(egc, &dev->aodev); in colo_nic_setup()
185 static void colo_save_setup_script_cb(libxl__egc *egc, in colo_save_setup_script_cb() argument
227 aodev->callback(egc, aodev); in colo_save_setup_script_cb()
253 dev->aodev.callback(egc, &dev->aodev); in colo_nic_teardown()
256 static void colo_save_teardown_script_cb(libxl__egc *egc, in colo_save_teardown_script_cb() argument
268 aodev->callback(egc, aodev); in colo_save_teardown_script_cb()
280 static void colo_nic_save_teardown(libxl__egc *egc, in colo_nic_save_teardown() argument
296 static void colo_nic_restore_setup(libxl__egc *egc, in colo_nic_restore_setup() argument
[all …]
|
| A D | libxl_domain.c | 200 libxl__ao_complete(egc, ao, rc); in domain_resume_done()
504 libxl__ao_complete(egc,ao,rc); in domain_suspend_cb()
538 libxl__domain_save(egc, dss); in libxl_domain_suspend()
549 libxl__ao_complete(egc,ao,rc); in domain_suspend_empty_cb()
589 libxl__ao_complete(egc, ao, 0); in libxl_domain_pause()
693 dmrs->callback(egc, dmrs, rc); in domain_unpause_done()
874 libxl__event_occurred(egc, ev); in domain_death_occurred()
1195 dis->callback(egc, dis, rc); in libxl__destroy_domid()
1254 dis->callback(egc, dis, rc); in destroy_domid_pci_done()
1601 dis->callback(egc, dis, rc); in devices_destroy_cb()
[all …]
|
| A D | libxl_bootloader.c | 268 bootloader_cleanup(egc, bl); in bootloader_callback()
288 bl->callback(egc, bl, bl->rc); in bootloader_local_detached_cb()
403 bootloader_callback(egc, bl, rc); in libxl__bootloader_run()
463 bootloader_callback(egc, bl, rc); in bootloader_disk_attached_cb()
491 rc = setup_xenconsoled_pty(egc, bl, in bootloader_gotptys()
517 bl->console_available(egc, bl); in bootloader_gotptys()
589 bootloader_callback(egc, bl, rc); in bootloader_gotptys()
612 bootloader_stop(egc, bl, rc); in bootloader_copyfail()
632 bootloader_stop(egc, bl, rc); in bootloader_domaindeath()
664 rc = parse_bootloader_result(egc, bl); in bootloader_finished()
[all …]
|
| A D | libxl_colo.h | 24 #define ASYNC_CALL(egc, ao, child, param, func, callback) do { \ argument
43 callback(egc, child, -1, 1); \
97 typedef void libxl__colo_callback(struct libxl__egc *egc,
132 extern void libxl__colo_restore_setup(struct libxl__egc *egc,
134 extern void libxl__colo_restore_teardown(struct libxl__egc *egc, void *dcs_void,
136 extern void libxl__colo_save_setup(struct libxl__egc *egc,
138 extern void libxl__colo_save_teardown(struct libxl__egc *egc,
|
| A D | libxl_test_fdevent.c | 15 static void fdevent_complete(libxl__egc *egc, libxl__test_fdevent *tfe,
31 static void tfe_fd_cb(libxl__egc *egc, libxl__ev_fd *ev, in tfe_fd_cb() argument
36 fdevent_complete(egc, tfe, 0); in tfe_fd_cb()
39 static void tfe_abrt_cb(libxl__egc *egc, libxl__ao_abortable *abrt, in tfe_abrt_cb() argument
44 fdevent_complete(egc, tfe, rc); in tfe_abrt_cb()
47 static void fdevent_complete(libxl__egc *egc, libxl__test_fdevent *tfe, in fdevent_complete() argument
52 libxl__ao_complete(egc, ao, rc); in fdevent_complete()
|
| A D | libxl_internal.h | 1476 _hidden void libxl__dm_resume(libxl__egc *egc,
1478 _hidden void libxl__domain_resume(libxl__egc *egc,
2398 libxl__egc egc[1]; LIBXL_INIT_EGC(egc[0],ctx); \
2505 libxl__egc egc[1]; LIBXL_INIT_EGC(egc[0],ctx); \
3449 void (*completion_callback)(libxl__egc *egc,
3452 void (*checkpoint_callback)(libxl__egc *egc,
3527 void (*completion_callback)(libxl__egc *egc,
3530 void (*checkpoint_callback)(libxl__egc *egc,
3615 int libxl__domain_suspend_init(libxl__egc *egc,
4214 _hidden void libxl__domain_save(libxl__egc *egc,
[all …]
|
| A D | libxl_event.c | 529 ev->func(egc, ev, &ev->abs, rc); in time_aborted()
941 evev->callback(egc, evev); in evtchn_fd_callback()
1062 ds->callback(egc, ds, rc); in devstate_callback()
1162 dc->callback(egc, dc, rc); in domaindeathcheck_abort()
1517 fd_occurs(egc, ev, revents_ign); in libxl_osevent_occurred_fd()
1586 ei->callback(egc, ei); in egc_run_callbacks()
1625 egc_run_callbacks(egc); in libxl__egc_cleanup_2_ul_cb_gc()
2188 libxl__egc egc; in libxl__ao_inprogress() local
2189 LIBXL_INIT_EGC(egc,CTX); in libxl__ao_inprogress()
2245 libxl__egc egc; in ao__abort() local
[all …]
|
| A D | libxl_disk.c | 75 libxl__event_occurred(egc, ev); in disk_eject_xswatch_callback()
433 libxl__wait_device_connection(egc, aodev); in device_disk_add()
443 if (rc) aodev->callback(egc, aodev); in device_disk_add()
668 static void cdrom_insert_done(libxl__egc *egc,
1043 cdrom_insert_done(egc, cis, rc); in cdrom_insert_timout()
1057 libxl__ao_complete(egc, cis->ao, rc); in cdrom_insert_done()
1189 dls->callback(egc, dls, 0); in libxl__device_disk_local_initiate_attach()
1215 dls->callback(egc, dls, rc); in libxl__device_disk_local_initiate_attach()
1245 dls->callback(egc, dls, 0); in local_device_attach_cb()
1287 local_device_detach_cb(egc, aodev); in libxl__device_disk_local_initiate_detach()
[all …]
|
| A D | libxl_pci.c | 1073 static void do_pci_add(libxl__egc *egc, in do_pci_add() argument
1313 pci_add_dm_done(egc, pas, rc); in pci_add_timeout()
1446 pas->callback(egc, pas, rc); in pci_add_dm_done()
1708 device_pci_add_done(egc, pas, rc); in device_pci_add_stubdom_done()
1728 aodev->callback(egc, aodev); in device_pci_add_done()
1791 aodev->callback(egc, aodev); in add_pcidevs_done()
2002 pci_remove_detatched(egc, prs, rc); in pci_remove_qemu_trad_watch_state_cb()
2028 pci_remove_detatched(egc, prs, rc); in pci_remove_qmp_device_del()
2203 pci_remove_done(egc, prs, rc); in pci_remove_detatched()
2211 pci_remove_done(egc, prs, 0); in pci_remove_stubdom_done()
[all …]
|
| A D | libxl_usb.c | 442 static void device_usbctrl_add_done(libxl__egc *egc,
503 libxl__wait_device_connection(egc, aodev); in libxl__device_usbctrl_add()
509 device_usbctrl_add_done(egc, aodev, rc); in libxl__device_usbctrl_add()
536 device_usbctrl_add_done(egc, aodev, rc); in device_usbctrl_add_qmp_cb()
539 static void device_usbctrl_add_done(libxl__egc *egc, in device_usbctrl_add_done() argument
547 aodev->callback(egc, aodev); in device_usbctrl_add_done()
692 device_usbctrl_remove_done(egc, aodev, rc); in device_usbctrl_remove_qmp_cb()
707 aodev->callback(egc, aodev); in device_usbctrl_remove_done()
1675 static void device_usbdev_add_done(libxl__egc *egc,
1865 aodev->callback(egc, aodev); in device_usbdev_add_done()
[all …]
|
| A D | libxl_qmp.c | 954 libxl__ao_complete(egc, ao, rc); in qemu_monitor_command_done()
970 void libxl__qmp_suspend_save(libxl__egc *egc, in libxl__qmp_suspend_save() argument
982 rc = libxl__ev_qmp_send(egc, ev, "stop", NULL); in libxl__qmp_suspend_save()
1005 dm_state_save_to_fdset(egc, ev, 1); in dm_stopped()
1053 dm_state_save_to_fdset(egc, ev, fdset); in dm_state_fd_ready()
1169 static int qmp_ev_handle_message(libxl__egc *egc,
1300 libxl__ev_slowlock_lock(egc, &ev->lock); in qmp_ev_connect()
1357 libxl__ev_immediate_register(egc, &ev->ei); in qmp_ev_lock_aquired()
1541 rc = qmp_ev_get_next_msg(egc, ev, &o); in qmp_ev_callback_readable()
1645 static int qmp_ev_handle_message(libxl__egc *egc, in qmp_ev_handle_message() argument
[all …]
|