From mboxrd@z Thu Jan 1 00:00:00 1970 From: Ian Jackson Subject: [PATCH 28/29] libxl: ao: datacopier callback gets an rc Date: Tue, 10 Feb 2015 20:10:15 +0000 Message-ID: <1423599016-32639-29-git-send-email-ian.jackson@eu.citrix.com> References: <1423599016-32639-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: <1423599016-32639-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 , Euan Harris List-Id: xen-devel@lists.xenproject.org libxl__datacopier_* now provides its caller's callback function with an rc value. This relieves the caller of the need to figure out an appropriate rc value. Arrange that the `other internal failure' cases now get a valid positive errno value (EIO). In a few places, assert that errno is nonzero before passing it to our caller. Extend the datacopier callback API to permit the dc to signal CANCELLED. (It doesn't actually do this yet, though.) Signed-off-by: Ian Jackson --- v2: New in this version of the series. --- tools/libxl/libxl_aoutils.c | 22 ++++++++++++---------- tools/libxl/libxl_bootloader.c | 20 +++++++++++--------- tools/libxl/libxl_dom.c | 10 +++------- tools/libxl/libxl_internal.h | 18 +++++++++++------- 4 files changed, 37 insertions(+), 33 deletions(-) diff --git a/tools/libxl/libxl_aoutils.c b/tools/libxl/libxl_aoutils.c index 0b6d750..ece7981 100644 --- a/tools/libxl/libxl_aoutils.c +++ b/tools/libxl/libxl_aoutils.c @@ -121,10 +121,10 @@ void libxl__datacopier_kill(libxl__datacopier_state *dc) } static void datacopier_callback(libxl__egc *egc, libxl__datacopier_state *dc, - int onwrite, int errnoval) + int rc, int onwrite, int errnoval) { libxl__datacopier_kill(dc); - dc->callback(egc, dc, onwrite, errnoval); + dc->callback(egc, dc, rc, onwrite, errnoval); } static void datacopier_writable(libxl__egc *egc, libxl__ev_fd *ev, @@ -142,13 +142,13 @@ static void datacopier_check_state(libxl__egc *egc, libxl__datacopier_state *dc) if (rc) { LOG(ERROR, "unable to establish write event on %s" " during copy of %s", dc->writewhat, dc->copywhat); - datacopier_callback(egc, dc, -1, 0); + datacopier_callback(egc, dc, ERROR_FAIL, -1, EIO); return; } } } else if (!libxl__ev_fd_isregistered(&dc->toread)) { /* we have had eof */ - datacopier_callback(egc, dc, 0, 0); + datacopier_callback(egc, dc, 0, 0, 0); return; } else { /* nothing buffered, but still reading */ @@ -190,7 +190,7 @@ static int datacopier_pollhup_handled(libxl__egc *egc, onwrite ? dc->writewhat : dc->readwhat, dc->copywhat); libxl__datacopier_kill(dc); - dc->callback_pollhup(egc, dc, onwrite, -1); + dc->callback_pollhup(egc, dc, ERROR_FAIL, onwrite, -1); return 1; } return 0; @@ -207,7 +207,7 @@ static void datacopier_readable(libxl__egc *egc, libxl__ev_fd *ev, if (revents & ~POLLIN) { LOG(ERROR, "unexpected poll event 0x%x (should be POLLIN)" " on %s during copy of %s", revents, dc->readwhat, dc->copywhat); - datacopier_callback(egc, dc, -1, 0); + datacopier_callback(egc, dc, ERROR_FAIL, -1, EIO); return; } assert(revents & POLLIN); @@ -234,9 +234,10 @@ static void datacopier_readable(libxl__egc *egc, libxl__ev_fd *ev, if (r < 0) { if (errno == EINTR) continue; if (errno == EWOULDBLOCK) break; + assert(errno); LOGE(ERROR, "error reading %s during copy of %s", dc->readwhat, dc->copywhat); - datacopier_callback(egc, dc, 0, errno); + datacopier_callback(egc, dc, ERROR_FAIL, 0, errno); return; } if (r == 0) { @@ -249,7 +250,7 @@ static void datacopier_readable(libxl__egc *egc, libxl__ev_fd *ev, assert(ferror(dc->log)); assert(errno); LOGE(ERROR, "error logging %s", dc->copywhat); - datacopier_callback(egc, dc, 0, errno); + datacopier_callback(egc, dc, ERROR_FAIL, 0, errno); return; } } @@ -271,7 +272,7 @@ static void datacopier_writable(libxl__egc *egc, libxl__ev_fd *ev, if (revents & ~POLLOUT) { LOG(ERROR, "unexpected poll event 0x%x (should be POLLOUT)" " on %s during copy of %s", revents, dc->writewhat, dc->copywhat); - datacopier_callback(egc, dc, -1, 0); + datacopier_callback(egc, dc, ERROR_FAIL, -1, EIO); return; } assert(revents & POLLOUT); @@ -288,9 +289,10 @@ static void datacopier_writable(libxl__egc *egc, libxl__ev_fd *ev, if (r < 0) { if (errno == EINTR) continue; if (errno == EWOULDBLOCK) break; + assert(errno); LOGE(ERROR, "error writing to %s during copy of %s", dc->writewhat, dc->copywhat); - datacopier_callback(egc, dc, 1, errno); + datacopier_callback(egc, dc, ERROR_FAIL, 1, errno); return; } assert(r > 0); diff --git a/tools/libxl/libxl_bootloader.c b/tools/libxl/libxl_bootloader.c index 21f92dc..c26f1d6 100644 --- a/tools/libxl/libxl_bootloader.c +++ b/tools/libxl/libxl_bootloader.c @@ -30,9 +30,9 @@ static void bootloader_gotptys(libxl__egc *egc, libxl__openpty_state *op); static void bootloader_keystrokes_copyfail(libxl__egc *egc, - libxl__datacopier_state *dc, int onwrite, int errnoval); + libxl__datacopier_state *dc, int rc, int onwrite, int errnoval); static void bootloader_display_copyfail(libxl__egc *egc, - libxl__datacopier_state *dc, int onwrite, int errnoval); + libxl__datacopier_state *dc, int rc, int onwrite, int errnoval); static void bootloader_domaindeath(libxl__egc*, libxl__domaindeathcheck *dc, int rc); static void bootloader_finished(libxl__egc *egc, libxl__ev_child *child, @@ -577,10 +577,10 @@ static void bootloader_gotptys(libxl__egc *egc, libxl__openpty_state *op) /* perhaps one of these will be called, but perhaps not */ static void bootloader_copyfail(libxl__egc *egc, const char *which, - libxl__bootloader_state *bl, int ondisplay, int onwrite, int errnoval) + libxl__bootloader_state *bl, int ondisplay, + int rc, int onwrite, int errnoval) { STATE_AO_GC(bl->ao); - int rc = ERROR_FAIL; if (errnoval==-1) { /* POLLHUP */ @@ -591,22 +591,24 @@ static void bootloader_copyfail(libxl__egc *egc, const char *which, LOG(ERROR, "unexpected POLLHUP on %s", which); } } - if (!onwrite && !errnoval) + if (!rc) { LOG(ERROR, "unexpected eof copying %s", which); + rc = ERROR_FAIL; + } bootloader_stop(egc, bl, rc); } static void bootloader_keystrokes_copyfail(libxl__egc *egc, - libxl__datacopier_state *dc, int onwrite, int errnoval) + libxl__datacopier_state *dc, int rc, int onwrite, int errnoval) { libxl__bootloader_state *bl = CONTAINER_OF(dc, *bl, keystrokes); - bootloader_copyfail(egc, "bootloader input", bl, 0, onwrite, errnoval); + bootloader_copyfail(egc, "bootloader input", bl, 0, rc,onwrite,errnoval); } static void bootloader_display_copyfail(libxl__egc *egc, - libxl__datacopier_state *dc, int onwrite, int errnoval) + libxl__datacopier_state *dc, int rc, int onwrite, int errnoval) { libxl__bootloader_state *bl = CONTAINER_OF(dc, *bl, display); - bootloader_copyfail(egc, "bootloader output", bl, 1, onwrite, errnoval); + bootloader_copyfail(egc, "bootloader output", bl, 1, rc,onwrite,errnoval); } static void bootloader_domaindeath(libxl__egc *egc, diff --git a/tools/libxl/libxl_dom.c b/tools/libxl/libxl_dom.c index 87b5fdd..ff0f55d 100644 --- a/tools/libxl/libxl_dom.c +++ b/tools/libxl/libxl_dom.c @@ -1918,7 +1918,7 @@ out: } static void save_device_model_datacopier_done(libxl__egc *egc, - libxl__datacopier_state *dc, int onwrite, int errnoval); + libxl__datacopier_state *dc, int rc, int onwrite, int errnoval); void libxl__domain_save_device_model(libxl__egc *egc, libxl__domain_suspend_state *dss, @@ -1977,11 +1977,11 @@ void libxl__domain_save_device_model(libxl__egc *egc, return; out: - save_device_model_datacopier_done(egc, dc, -1, 0); + save_device_model_datacopier_done(egc, dc, rc, -1, EIO); } static void save_device_model_datacopier_done(libxl__egc *egc, - libxl__datacopier_state *dc, int onwrite, int errnoval) + libxl__datacopier_state *dc, int our_rc, int onwrite, int errnoval) { libxl__domain_suspend_state *dss = CONTAINER_OF(dc, *dss, save_dm_datacopier); @@ -1989,14 +1989,10 @@ static void save_device_model_datacopier_done(libxl__egc *egc, /* Convenience aliases */ const char *const filename = dss->dm_savefile; - int our_rc = 0; int rc; libxl__datacopier_kill(dc); - if (onwrite || errnoval) - our_rc = ERROR_FAIL; - if (dc->readfd >= 0) { close(dc->readfd); dc->readfd = -1; diff --git a/tools/libxl/libxl_internal.h b/tools/libxl/libxl_internal.h index eb8e5f2..29a612c 100644 --- a/tools/libxl/libxl_internal.h +++ b/tools/libxl/libxl_internal.h @@ -2562,16 +2562,20 @@ _hidden void libxl__device_disk_local_initiate_detach(libxl__egc *egc, typedef struct libxl__datacopier_state libxl__datacopier_state; typedef struct libxl__datacopier_buf libxl__datacopier_buf; -/* onwrite==1 means failure happened when writing, logged, errnoval is valid - * onwrite==0 means failure happened when reading - * errnoval==0 means we got eof and all data was written - * errnoval!=0 means we had a read error, logged - * onwrite==-1 means some other internal failure, errnoval not valid, logged - * If we get POLLHUP, we call callback_pollhup(..., onwrite, -1); +/* onwrite==1 means problem happened when writing + * rc==FAIL errnoval >0 we had a write error, logged + * onwrite==0 means problem happened when reading + * rc==0 errnoval==0 we got eof and all data was written + * rc==FAIL errnoval >0 we had a read error, logged + * onwrite==-1 means some other internal problem + * rc==FAIL errnoval==EIO some other internal failure, logged + * rc==CANCEL errnoval==0 cancellation requested, not logged + * If we get POLLHUP, we call callback_pollhup with + * rc==FAIL errnoval==-1 POLLHUP signalled * or if callback_pollhup==0 this is an internal failure, as above. * In all cases copier is killed before calling this callback */ typedef void libxl__datacopier_callback(libxl__egc *egc, - libxl__datacopier_state *dc, int onwrite, int errnoval); + libxl__datacopier_state *dc, int rc, int onwrite, int errnoval); struct libxl__datacopier_buf { /* private to datacopier */ -- 1.7.10.4