From mboxrd@z Thu Jan 1 00:00:00 1970 From: Ian Jackson Subject: [PATCH 02/14] libxl: suspend: common suspend callbacks take rc Date: Fri, 20 Dec 2013 18:45:40 +0000 Message-ID: <1387565152-5642-3-git-send-email-ian.jackson@eu.citrix.com> References: <21172.35652.484647.666791@mariner.uk.xensource.com> <1387565152-5642-1-git-send-email-ian.jackson@eu.citrix.com> Mime-Version: 1.0 Content-Type: text/plain; charset="us-ascii" Content-Transfer-Encoding: 7bit Return-path: In-Reply-To: <1387565152-5642-1-git-send-email-ian.jackson@eu.citrix.com> List-Unsubscribe: , List-Post: List-Help: List-Subscribe: , Sender: xen-devel-bounces@lists.xen.org Errors-To: xen-devel-bounces@lists.xen.org To: xen-devel@lists.xensource.com Cc: Ian Jackson , Ian Campbell List-Id: xen-devel@lists.xenproject.org Change the following functions to take a libxl error code rather than a boolean "ok" value, and translate that value to the boolean expected by libxc at the last moment: domain_suspend_callback_common_done } dss->callback_common_done remus_domain_suspend_callback_common_done } domain_suspend_common_done Also, abolish domain_suspend_common_failed as domain_suspend_common_done can easily do its job and the call sites now have to supply the right rc value anyway. In domain_suspend_common_guest_suspended, change "ret" to "rc" as it contains a libxl error code. Signed-off-by: Ian Jackson --- tools/libxl/libxl_dom.c | 51 ++++++++++++++++++++--------------------------- 1 file changed, 22 insertions(+), 29 deletions(-) diff --git a/tools/libxl/libxl_dom.c b/tools/libxl/libxl_dom.c index f5c76f2..65a88c2 100644 --- a/tools/libxl/libxl_dom.c +++ b/tools/libxl/libxl_dom.c @@ -756,9 +756,9 @@ int libxl__toolstack_restore(uint32_t domid, const uint8_t *buf, static void domain_suspend_done(libxl__egc *egc, libxl__domain_suspend_state *dss, int rc); static void domain_suspend_callback_common_done(libxl__egc *egc, - libxl__domain_suspend_state *dss, int ok); + libxl__domain_suspend_state *dss, int rc); static void remus_domain_suspend_callback_common_done(libxl__egc *egc, - libxl__domain_suspend_state *dss, int ok); + libxl__domain_suspend_state *dss, int rc); /*----- complicated callback, called by xc_domain_save -----*/ @@ -1045,11 +1045,9 @@ static void suspend_common_wait_guest_check(libxl__egc *egc, static void suspend_common_wait_guest_timeout(libxl__egc *egc, libxl__ev_time *ev, const struct timeval *requested_abs); -static void domain_suspend_common_failed(libxl__egc *egc, - libxl__domain_suspend_state *dss); static void domain_suspend_common_done(libxl__egc *egc, libxl__domain_suspend_state *dss, - bool ok); + int rc); static bool domain_suspend_pvcontrol_acked(const char *state) { /* any value other than "suspend", including ENOENT, is OK */ @@ -1079,6 +1077,7 @@ static void domain_suspend_callback_common(libxl__egc *egc, ret = xc_evtchn_notify(CTX->xce, dss->guest_evtchn.port); if (ret < 0) { LOG(ERROR, "xc_evtchn_notify failed ret=%d", ret); + rc = ERROR_FAIL; goto err; } @@ -1099,6 +1098,7 @@ static void domain_suspend_callback_common(libxl__egc *egc, ret = xc_domain_shutdown(CTX->xch, domid, SHUTDOWN_suspend); if (ret < 0) { LOGE(ERROR, "xc_domain_shutdown failed"); + rc = ERROR_FAIL; goto err; } /* The guest does not (need to) respond to this sort of request. */ @@ -1113,7 +1113,7 @@ static void domain_suspend_callback_common(libxl__egc *egc, libxl__domain_pvcontrol_write(gc, XBT_NULL, domid, "suspend"); dss->pvcontrol.path = libxl__domain_pvcontrol_xspath(gc, domid); - if (!dss->pvcontrol.path) goto err; + if (!dss->pvcontrol.path) { rc = ERROR_FAIL; goto err; } dss->pvcontrol.ao = ao; dss->pvcontrol.what = "guest acknowledgement of suspend request"; @@ -1123,7 +1123,7 @@ static void domain_suspend_callback_common(libxl__egc *egc, return; err: - domain_suspend_common_failed(egc, dss); + domain_suspend_common_done(egc, dss, rc); } static void domain_suspend_common_wait_guest_evtchn(libxl__egc *egc, @@ -1198,7 +1198,7 @@ static void domain_suspend_common_pvcontrol_suspending(libxl__egc *egc, err: libxl__xs_transaction_abort(gc, &t); - domain_suspend_common_failed(egc, dss); + domain_suspend_common_done(egc, dss, rc); return; } @@ -1222,7 +1222,7 @@ static void domain_suspend_common_wait_guest(libxl__egc *egc, return; err: - domain_suspend_common_failed(egc, dss); + domain_suspend_common_done(egc, dss, rc); } static void suspend_common_wait_guest_watch(libxl__egc *egc, @@ -1247,7 +1247,6 @@ static void suspend_common_wait_guest_check(libxl__egc *egc, if (ret < 0) { LOGE(ERROR, "unable to check for status of guest %"PRId32"", domid); goto err; - domain_suspend_common_failed(egc, dss); } if (!(ret == 1 && info.domain == domid)) { @@ -1273,7 +1272,7 @@ static void suspend_common_wait_guest_check(libxl__egc *egc, return; err: - domain_suspend_common_failed(egc, dss); + domain_suspend_common_done(egc, dss, ERROR_FAIL); } static void suspend_common_wait_guest_timeout(libxl__egc *egc, @@ -1282,46 +1281,40 @@ static void suspend_common_wait_guest_timeout(libxl__egc *egc, libxl__domain_suspend_state *dss = CONTAINER_OF(ev, *dss, guest_timeout); STATE_AO_GC(dss->ao); LOG(ERROR, "guest did not suspend, timed out"); - domain_suspend_common_failed(egc, dss); + domain_suspend_common_done(egc, dss, ERROR_GUEST_TIMEDOUT); } static void domain_suspend_common_guest_suspended(libxl__egc *egc, libxl__domain_suspend_state *dss) { STATE_AO_GC(dss->ao); - int ret; + int rc; libxl__ev_evtchn_cancel(gc, &dss->guest_evtchn); libxl__ev_xswatch_deregister(gc, &dss->guest_watch); libxl__ev_time_deregister(gc, &dss->guest_timeout); if (dss->hvm) { - ret = libxl__domain_suspend_device_model(gc, dss); - if (ret) { - LOG(ERROR, "libxl__domain_suspend_device_model failed ret=%d", ret); - domain_suspend_common_failed(egc, dss); + rc = libxl__domain_suspend_device_model(gc, dss); + if (rc) { + LOG(ERROR, "libxl__domain_suspend_device_model failed ret=%d", rc); + domain_suspend_common_done(egc, dss, rc); return; } } - domain_suspend_common_done(egc, dss, 1); -} - -static void domain_suspend_common_failed(libxl__egc *egc, - libxl__domain_suspend_state *dss) -{ domain_suspend_common_done(egc, dss, 0); } static void domain_suspend_common_done(libxl__egc *egc, libxl__domain_suspend_state *dss, - bool ok) + int rc) { EGC_GC; assert(!libxl__xswait_inuse(&dss->pvcontrol)); libxl__ev_evtchn_cancel(gc, &dss->guest_evtchn); libxl__ev_xswatch_deregister(gc, &dss->guest_watch); libxl__ev_time_deregister(gc, &dss->guest_timeout); - dss->callback_common_done(egc, dss, ok); + dss->callback_common_done(egc, dss, rc); } static inline char *physmap_path(libxl__gc *gc, uint32_t domid, @@ -1419,9 +1412,9 @@ static void libxl__domain_suspend_callback(void *data) } static void domain_suspend_callback_common_done(libxl__egc *egc, - libxl__domain_suspend_state *dss, int ok) + libxl__domain_suspend_state *dss, int rc) { - libxl__xc_domain_saverestore_async_callback_done(egc, &dss->shs, ok); + libxl__xc_domain_saverestore_async_callback_done(egc, &dss->shs, !rc); } /*----- remus callbacks -----*/ @@ -1437,10 +1430,10 @@ static void libxl__remus_domain_suspend_callback(void *data) } static void remus_domain_suspend_callback_common_done(libxl__egc *egc, - libxl__domain_suspend_state *dss, int ok) + libxl__domain_suspend_state *dss, int rc) { /* REMUS TODO: Issue disk and network checkpoint reqs. */ - libxl__xc_domain_saverestore_async_callback_done(egc, &dss->shs, ok); + libxl__xc_domain_saverestore_async_callback_done(egc, &dss->shs, !rc); } static int libxl__remus_domain_resume_callback(void *data) -- 1.7.10.4