From mboxrd@z Thu Jan 1 00:00:00 1970 From: Yang Hongyang Subject: Re: [PATCH v3 2/5] remus: resume immediately if libxl__xc_domain_save_done() completes Date: Tue, 26 Jan 2016 14:41:01 +0800 Message-ID: <56A714FD.9040301@easystack.cn> References: <1452235131-1861-1-git-send-email-wency@cn.fujitsu.com> <1452235131-1861-3-git-send-email-wency@cn.fujitsu.com> Mime-Version: 1.0 Content-Type: text/plain; charset="us-ascii"; Format="flowed" Content-Transfer-Encoding: 7bit Return-path: In-Reply-To: <1452235131-1861-3-git-send-email-wency@cn.fujitsu.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: Wen Congyang , xen devel , Andrew Cooper Cc: Shriram Rajagopalan , Ian Jackson , Changlong Xie , Wei Liu , Ian Campbell List-Id: xen-devel@lists.xenproject.org On 01/08/2016 02:38 PM, Wen Congyang wrote: > For example: if the secondary host is down, and we fail to send the data to > the secondary host. xc_domain_save() returns 0. So in the function > libxl__xc_domain_save_done(), rc is 0(the helper program exits normally), > and retval is 0(it is xc_domain_save()'s return value). In such case, we > just need to complete the stream. > > Signed-off-by: Wen Congyang > --- > tools/libxl/libxl_stream_write.c | 13 +++++++++++-- > 1 file changed, 11 insertions(+), 2 deletions(-) > > diff --git a/tools/libxl/libxl_stream_write.c b/tools/libxl/libxl_stream_write.c > index 80d9208..82e7719 100644 > --- a/tools/libxl/libxl_stream_write.c > +++ b/tools/libxl/libxl_stream_write.c > @@ -354,8 +354,17 @@ void libxl__xc_domain_save_done(libxl__egc *egc, void *dss_void, > * alive, and check_all_finished() may have torn it down around us. > * If the stream is not still alive, we must not continue any work. > */ > - if (libxl__stream_write_inuse(stream)) > - write_emulator_xenstore_record(egc, stream); > + if (libxl__stream_write_inuse(stream)) { > + if (dss->remus) > + /* > + * For remus, if libxl__xc_domain_save_done() completes, xc_domain_save() completes. > + * there was an error sending data to the secondary. > + * Resume the primary ASAP. > + */ > + stream_complete(egc, stream, 0); > + else > + write_emulator_xenstore_record(egc, stream); > + } > } > > static void write_emulator_xenstore_record(libxl__egc *egc, > -- Thanks, Yang