Michal Privoznik wrote: > On 13.03.2014 23:11, Jim Fehlig wrote: >> This patch adds initial migration support to the libxl driver, >> using the VIR_DRV_FEATURE_MIGRATION_PARAMS family of migration >> functions. >> >> Signed-off-by: Jim Fehlig <jfehlig@xxxxxxxx> >> --- >> >> V2: >> - Now that the libxl driver supports hostdev passthrough, ensure >> domain has no hostdevs before migration >> - Fail early in libxlDomainMigrateBegin3Params if domain is inactive >> - Change name of local variable in libxlDoMigrateSend from 'live' >> to 'xl_flags'. >> >> po/POTFILES.in | 1 + >> src/Makefile.am | 3 +- >> src/libxl/libxl_conf.h | 6 + >> src/libxl/libxl_domain.h | 1 + >> src/libxl/libxl_driver.c | 225 +++++++++++++++++ >> src/libxl/libxl_migration.c | 598 >> ++++++++++++++++++++++++++++++++++++++++++++ >> src/libxl/libxl_migration.h | 78 ++++++ >> 7 files changed, 911 insertions(+), 1 deletion(-) >> > >> diff --git a/src/libxl/libxl_driver.c b/src/libxl/libxl_driver.c >> index 3306dc1..6fc5266 100644 >> --- a/src/libxl/libxl_driver.c >> +++ b/src/libxl/libxl_driver.c > >> @@ -4313,6 +4323,216 @@ cleanup: >> return ret; >> } >> >> +static char * >> +libxlDomainMigrateBegin3Params(virDomainPtr domain, >> + virTypedParameterPtr params, >> + int nparams, >> + char **cookieout ATTRIBUTE_UNUSED, >> + int *cookieoutlen ATTRIBUTE_UNUSED, >> + unsigned int flags) >> +{ >> + const char *xmlin = NULL; >> + const char *dname = NULL; >> + virDomainObjPtr vm = NULL; >> + >> + virCheckFlags(LIBXL_MIGRATION_FLAGS, NULL); >> + if (virTypedParamsValidate(params, nparams, >> LIBXL_MIGRATION_PARAMETERS) < 0) >> + return NULL; >> + >> + if (virTypedParamsGetString(params, nparams, >> + VIR_MIGRATE_PARAM_DEST_XML, >> + &xmlin) < 0 || >> + virTypedParamsGetString(params, nparams, >> + VIR_MIGRATE_PARAM_DEST_NAME, >> + &dname) < 0) > > I'd expect @dname to be used somewhere... > >> + return NULL; >> + >> + if (!(vm = libxlDomObjFromDomain(domain))) >> + return NULL; >> + >> + if (virDomainMigrateBegin3ParamsEnsureACL(domain->conn, vm->def) >> < 0) { >> + virObjectUnlock(vm); >> + return NULL; >> + } >> + >> + if (!virDomainObjIsActive(vm)) { >> + virReportError(VIR_ERR_OPERATION_INVALID, >> + "%s", _("domain is not running")); >> + virObjectUnlock(vm); >> + return NULL; >> + } >> + >> + return libxlDomainMigrationBegin(domain->conn, vm, xmlin); >> +} >> + > >> diff --git a/src/libxl/libxl_migration.c b/src/libxl/libxl_migration.c >> new file mode 100644 >> index 0000000..01023db >> --- /dev/null >> +++ b/src/libxl/libxl_migration.c >> @@ -0,0 +1,598 @@ >> +/* >> + * libxl_migration.c: methods for handling migration with libxenlight >> + * >> + * Copyright (C) 2014 SUSE LINUX Products GmbH, Nuernberg, Germany. >> + * >> + * This library is free software; you can redistribute it and/or >> + * modify it under the terms of the GNU Lesser General Public >> + * License as published by the Free Software Foundation; either >> + * version 2.1 of the License, or (at your option) any later version. >> + * >> + * This library is distributed in the hope that it will be useful, >> + * but WITHOUT ANY WARRANTY; without even the implied warranty of >> + * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU >> + * Lesser General Public License for more details. >> + * >> + * You should have received a copy of the GNU Lesser General Public >> + * License along with this library. If not, see >> + * <http://www.gnu.org/licenses/>. >> + * >> + * Authors: >> + * Jim Fehlig <jfehlig@xxxxxxxx> >> + * Chunyan Liu <cyliu@xxxxxxxx> >> + */ >> + >> +#include <config.h> >> + >> +#include "internal.h" >> +#include "virlog.h" >> +#include "virerror.h" >> +#include "virconf.h" >> +#include "datatypes.h" >> +#include "virfile.h" >> +#include "viralloc.h" >> +#include "viruuid.h" >> +#include "vircommand.h" >> +#include "virstring.h" >> +#include "rpc/virnetsocket.h" >> +#include "libxl_domain.h" >> +#include "libxl_driver.h" >> +#include "libxl_conf.h" >> +#include "libxl_migration.h" >> + >> +#define VIR_FROM_THIS VIR_FROM_LIBXL >> + >> +typedef struct _libxlMigrateReceiveArgs { >> + virConnectPtr conn; >> + virDomainObjPtr vm; >> + >> + /* for freeing listen sockets */ >> + virNetSocketPtr *socks; >> + size_t nsocks; >> +} libxlMigrateReceiveArgs; >> + >> +static const char libxlMigrateReceiverReady[] = >> + "libvirt libxl migration receiver ready, send binary domain data"; >> +static const char libxlMigrateReceiverFinish[] = >> + "domain received, ready to unpause"; > > So you're using these to sync source and destination on migration. > Kudos for using text protocol not a binary blob. I haven't followed v1 > closely, so what was resolution on this? I mean, my concern is if this > is extensible. I was hoping to keep the libxl side of the protocol simple with only a "ready to receive" and "received" ping-pong, and do most of the heavy lifting within the libvirt V3 protocol. For example subsequent patches can make use of the cookie to do more checks in the begin and prepare phases. But this has made me a bit nervous wrt migrating between a libvirtd containing such enhancements and a libvirtd running this initial migration patch that doesn't support cookies. Perhaps this initial series should ensure any cookiein is NULL? Sadly, I forgot to cc xen-devel on this series (done now) in case the Xen community has some input as well. I'll be sure to include xen-devel on a V3 addressing your comments. Thanks for reviewing the series! Regards, Jim > >> + >> + >> +static int >> +libxlCheckMessageBanner(int fd, const char *banner, int banner_sz) >> +{ >> + char buf[banner_sz]; >> + int ret = 0; >> + >> + do { >> + ret = saferead(fd, buf, banner_sz); >> + } while (ret == -1 && errno == EAGAIN); > > The @fd is in blocking state, so we should never get EAGAIN here. But > it doesn't hurt to check. > >> + >> + if (ret != banner_sz || memcmp(buf, banner, banner_sz)) { >> + return -1; >> + } >> + >> + return 0; >> +} >> + >> +static void >> +libxlDoMigrateReceive(virNetSocketPtr sock, >> + int events ATTRIBUTE_UNUSED, >> + void *opaque) >> +{ >> + libxlMigrateReceiveArgs *data = opaque; >> + virConnectPtr conn = data->conn; >> + virDomainObjPtr vm = data->vm; >> + virNetSocketPtr *socks = data->socks; >> + size_t nsocks = data->nsocks; >> + libxlDriverPrivatePtr driver = conn->privateData; >> + virNetSocketPtr client_sock; >> + int recv_fd; >> + int len; >> + size_t i; >> + int ret; >> + >> + virNetSocketAccept(sock, &client_sock); >> + if (client_sock == NULL) { >> + virReportError(VIR_ERR_OPERATION_INVALID, "%s", >> + _("Fail to accept migration connection")); >> + goto cleanup; >> + } >> + VIR_DEBUG("Accepted migration\n"); >> + recv_fd = virNetSocketDupFD(client_sock, true); >> + virObjectUnref(client_sock); >> + >> + len = sizeof(libxlMigrateReceiverReady); >> + if (safewrite(recv_fd, libxlMigrateReceiverReady, len) != len) { >> + virReportError(VIR_ERR_OPERATION_FAILED, "%s", >> + _("Failed to write libxlMigrateReceiverReady")); >> + goto cleanup; >> + } >> + >> + virObjectLock(vm); >> + ret = libxlDomainStart(driver, vm, false, recv_fd); >> + virObjectUnlock(vm); >> + >> + if (ret < 0) { >> + virReportError(VIR_ERR_INTERNAL_ERROR, "%s", >> + _("Failed to restore domain with libxenlight")); >> + if (!vm->persistent) { >> + virDomainObjListRemove(driver->domains, vm); >> + vm = NULL; >> + } >> + goto cleanup; >> + } >> + >> + len = sizeof(libxlMigrateReceiverFinish); >> + if (safewrite(recv_fd, libxlMigrateReceiverFinish, len) != len) { >> + virReportError(VIR_ERR_OPERATION_FAILED, "%s", >> + _("Failed to write >> libxlMigrateReceiverFinish")); >> + } >> + >> + /* Remove all listen socks from event handler, and close them. */ >> + if (nsocks) { > > Useless 'if' > >> + for (i = 0; i < nsocks; i++) { >> + virNetSocketUpdateIOCallback(socks[i], 0); >> + virNetSocketRemoveIOCallback(socks[i]); >> + virNetSocketClose(socks[i]); >> + virObjectUnref(socks[i]); >> + } >> + VIR_FREE(socks); >> + } >> + >> +cleanup: >> + VIR_FORCE_CLOSE(recv_fd); >> + VIR_FREE(opaque); >> + return; >> +} >> + > >> +int >> +libxlDomainMigrationPrepare(virConnectPtr dconn, >> + virDomainDefPtr def, >> + const char *uri_in, >> + char **uri_out) >> +{ >> + libxlDriverPrivatePtr driver = dconn->privateData; >> + virDomainObjPtr vm = NULL; >> + char *hostname = NULL; >> + unsigned short port; >> + char portstr[100]; >> + virURIPtr uri = NULL; >> + virNetSocketPtr *socks = NULL; >> + size_t nsocks = 0; >> + int nsocks_listen = 0; >> + libxlMigrateReceiveArgs *args; >> + size_t i; >> + int ret = -1; >> + >> + if (!(vm = virDomainObjListAdd(driver->domains, def, >> + driver->xmlopt, >> + VIR_DOMAIN_OBJ_LIST_ADD_LIVE | >> + VIR_DOMAIN_OBJ_LIST_ADD_CHECK_LIVE, >> + NULL))) >> + goto cleanup; >> + >> + /* Create socket connection to receive migration data */ >> + if (!uri_in) { >> + if ((hostname = virGetHostname()) == NULL) >> + goto cleanup; >> + >> + if (STRPREFIX(hostname, "localhost")) { >> + virReportError(VIR_ERR_INTERNAL_ERROR, "%s", >> + _("hostname on destination resolved to >> localhost," >> + " but migration requires an FQDN")); >> + goto cleanup; >> + } >> + >> + if (virPortAllocatorAcquire(driver->migrationPorts, &port) < 0) >> + goto cleanup; >> + >> + if (virAsprintf(uri_out, "tcp://%s:%d", hostname, port) < 0) >> + goto cleanup; >> + } else { >> + if (!(STRPREFIX(uri_in, "tcp://"))) { >> + /* not full URI, add prefix tcp:// */ >> + char *tmp; >> + if (virAsprintf(&tmp, "tcp://%s", uri_in) < 0) >> + goto cleanup; >> + uri = virURIParse(tmp); >> + VIR_FREE(tmp); >> + } else { >> + uri = virURIParse(uri_in); >> + } >> + >> + if (uri == NULL) { >> + virReportError(VIR_ERR_INVALID_ARG, >> + _("unable to parse URI: %s"), >> + uri_in); >> + goto cleanup; >> + } >> + >> + if (uri->server == NULL) { >> + virReportError(VIR_ERR_INVALID_ARG, >> + _("missing host in migration URI: %s"), >> + uri_in); >> + goto cleanup; >> + } else { >> + hostname = uri->server; >> + } >> + >> + if (uri->port == 0) { >> + if (virPortAllocatorAcquire(driver->migrationPorts, >> &port) < 0) >> + goto cleanup; >> + >> + } else { >> + port = uri->port; >> + } >> + >> + if (virAsprintf(uri_out, "tcp://%s:%d", hostname, port) < 0) >> + goto cleanup; >> + } >> + >> + snprintf(portstr, sizeof(portstr), "%d", port); >> + >> + if (virNetSocketNewListenTCP(hostname, portstr, &socks, &nsocks) >> < 0) { >> + virReportError(VIR_ERR_OPERATION_FAILED, "%s", >> + _("Fail to create socket for incoming >> migration")); >> + goto cleanup; >> + } >> + >> + if (VIR_ALLOC(args) < 0) >> + goto cleanup; >> + >> + args->conn = dconn; >> + args->vm = vm; >> + args->socks = socks; >> + args->nsocks = nsocks; >> + >> + for (i = 0; i < nsocks; i++) { >> + if (virNetSocketSetBlocking(socks[i], true) < 0) >> + continue; >> + if (virNetSocketListen(socks[i], 1) < 0) >> + continue; >> + >> + if (virNetSocketAddIOCallback(socks[i], >> + 0, >> + libxlDoMigrateReceive, >> + args, >> + NULL) < 0) { >> + continue; >> + } >> + >> + virNetSocketUpdateIOCallback(socks[i], >> VIR_EVENT_HANDLE_READABLE); >> + nsocks_listen++; >> + } >> + >> + if (!nsocks_listen) >> + goto cleanup; >> + >> + ret = 0; >> + goto done; >> + >> +cleanup: >> + if (nsocks) { > > There's no need for this 'if'. > >> + for (i = 0; i < nsocks; i++) { >> + virNetSocketClose(socks[i]); >> + virObjectUnref(socks[i]); >> + } >> + VIR_FREE(socks); >> + } >> + >> +done: >> + virURIFree(uri); >> + if (vm) >> + virObjectUnlock(vm); >> + return ret; >> +} >> + >> +int >> +libxlDomainMigrationPerform(libxlDriverPrivatePtr driver, >> + virDomainObjPtr vm, >> + const char *dom_xml ATTRIBUTE_UNUSED, >> + const char *dconnuri ATTRIBUTE_UNUSED, >> + const char *uri_str, >> + const char *dname ATTRIBUTE_UNUSED, >> + unsigned int flags) >> +{ >> + char *hostname = NULL; >> + unsigned short port = 0; >> + char portstr[100]; >> + virURIPtr uri = NULL; >> + virNetSocketPtr sock; >> + int sockfd = -1; >> + int saved_errno = EINVAL; >> + int ret = -1; >> + > > Missing virCheckFlags(VIR_MIGRATE_LIVE, -1); > >> + /* parse dst host:port from uri */ >> + uri = virURIParse(uri_str); >> + if (uri == NULL || uri->server == NULL || uri->port == 0) >> + goto cleanup; >> + >> + hostname = uri->server; >> + port = uri->port; >> + snprintf(portstr, sizeof(portstr), "%d", port); >> + >> + /* socket connect to dst host:port */ >> + if (virNetSocketNewConnectTCP(hostname, portstr, &sock) < 0) { >> + virReportSystemError(saved_errno, >> + _("unable to connect to '%s:%s'"), >> + hostname, portstr); >> + goto cleanup; >> + } >> + >> + if (virNetSocketSetBlocking(sock, true) < 0) { >> + virObjectUnref(sock); >> + goto cleanup; >> + } >> + >> + sockfd = virNetSocketDupFD(sock, true); >> + virObjectUnref(sock); >> + >> + /* suspend vm and send saved data to dst through socket fd */ >> + virObjectUnlock(vm); >> + ret = libxlDoMigrateSend(driver, vm, flags, sockfd); >> + virObjectLock(vm); >> + >> +cleanup: >> + VIR_FORCE_CLOSE(sockfd); >> + virURIFree(uri); >> + return ret; >> +} >> + >> +virDomainPtr >> +libxlDomainMigrationFinish(virConnectPtr dconn, >> + virDomainObjPtr vm, >> + unsigned int flags, >> + int cancelled) >> +{ >> + libxlDriverPrivatePtr driver = dconn->privateData; >> + libxlDriverConfigPtr cfg = libxlDriverConfigGet(driver); >> + libxlDomainObjPrivatePtr priv = vm->privateData; >> + virObjectEventPtr event = NULL; >> + virDomainPtr dom = NULL; >> + >> + virPortAllocatorRelease(driver->migrationPorts, >> priv->migrationPort); >> + priv->migrationPort = 0; >> + >> + if (cancelled) >> + goto cleanup; >> + >> + if (!(flags & VIR_MIGRATE_PAUSED)) { >> + if (libxl_domain_unpause(priv->ctx, vm->def->id) != 0) { >> + virReportError(VIR_ERR_OPERATION_FAILED, "%s", >> + _("Failed to unpause domain")); >> + goto cleanup; >> + } >> + >> + virDomainObjSetState(vm, VIR_DOMAIN_RUNNING, >> + VIR_DOMAIN_RUNNING_MIGRATED); >> + event = virDomainEventLifecycleNewFromObj(vm, >> + VIR_DOMAIN_EVENT_RESUMED, >> + >> VIR_DOMAIN_EVENT_RESUMED_MIGRATED); >> + } else { >> + virDomainObjSetState(vm, VIR_DOMAIN_PAUSED, >> VIR_DOMAIN_PAUSED_USER); >> + event = virDomainEventLifecycleNewFromObj(vm, >> + VIR_DOMAIN_EVENT_SUSPENDED, >> + >> VIR_DOMAIN_EVENT_SUSPENDED_PAUSED); >> + } >> + >> + if (virDomainSaveStatus(driver->xmlopt, cfg->stateDir, vm) < 0) >> + goto cleanup; >> + >> + dom = virGetDomain(dconn, vm->def->name, vm->def->uuid); >> + >> + if (dom == NULL) { >> + libxl_domain_destroy(priv->ctx, vm->def->id, NULL); >> + libxlDomainCleanup(driver, vm, VIR_DOMAIN_SHUTOFF_FAILED); >> + event = virDomainEventLifecycleNewFromObj(vm, >> VIR_DOMAIN_EVENT_STOPPED, >> + >> VIR_DOMAIN_EVENT_STOPPED_FAILED); >> + libxlDomainEventQueue(driver, event); >> + } >> + >> +cleanup: >> + if (event) >> + libxlDomainEventQueue(driver, event); >> + if (vm) >> + virObjectUnlock(vm); >> + virObjectUnref(cfg); >> + return dom; >> +} >> + >> +int >> +libxlDomainMigrationConfirm(libxlDriverPrivatePtr driver, >> + virDomainObjPtr vm, >> + unsigned int flags, >> + int cancelled) >> +{ >> + libxlDriverConfigPtr cfg = libxlDriverConfigGet(driver); >> + libxlDomainObjPrivatePtr priv = vm->privateData; >> + virObjectEventPtr event = NULL; >> + int ret = -1; >> + >> + if (cancelled) { >> + virReportError(VIR_ERR_INTERNAL_ERROR, "%s", >> + _("migration failed, attempting to resume on >> source host")); >> + if (libxl_domain_resume(priv->ctx, vm->def->id, 1, 0) == 0) { >> + ret = 0; >> + } else { >> + VIR_DEBUG("Unable to resume domain '%s' after failed >> migration", >> + vm->def->name); >> + virDomainObjSetState(vm, VIR_DOMAIN_PAUSED, >> + VIR_DOMAIN_PAUSED_MIGRATION); >> + event = virDomainEventLifecycleNewFromObj(vm, >> VIR_DOMAIN_EVENT_SUSPENDED, >> + >> VIR_DOMAIN_EVENT_SUSPENDED_MIGRATED); >> + ignore_value(virDomainSaveStatus(driver->xmlopt, >> cfg->stateDir, vm)); >> + } >> + goto cleanup; >> + } >> + >> + libxl_domain_destroy(priv->ctx, vm->def->id, NULL); >> + libxlDomainCleanup(driver, vm, VIR_DOMAIN_SHUTOFF_MIGRATED); >> + event = virDomainEventLifecycleNewFromObj(vm, >> VIR_DOMAIN_EVENT_STOPPED, >> + >> VIR_DOMAIN_EVENT_STOPPED_MIGRATED); >> + >> + VIR_DEBUG("Domain '%s' successfully migrated", vm->def->name); >> + >> + if (flags & VIR_MIGRATE_UNDEFINE_SOURCE) >> + virDomainDeleteConfig(cfg->configDir, cfg->autostartDir, vm); >> + >> + if (!vm->persistent || (flags & VIR_MIGRATE_UNDEFINE_SOURCE)) >> + virDomainObjListRemove(driver->domains, vm); >> + >> + ret = 0; >> + >> +cleanup: >> + if (!libxlDomainObjEndJob(driver, vm)) >> + vm = NULL; >> + if (event) >> + libxlDomainEventQueue(driver, event); >> + if (vm) >> + virObjectUnlock(vm); >> + virObjectUnref(cfg); >> + return ret; >> +} >> diff --git a/src/libxl/libxl_migration.h b/src/libxl/libxl_migration.h >> new file mode 100644 >> index 0000000..63d8bdc >> --- /dev/null >> +++ b/src/libxl/libxl_migration.h >> @@ -0,0 +1,78 @@ >> +/* >> + * libxl_migration.h: methods for handling migration with libxenlight >> + * >> + * Copyright (c) 2014 SUSE LINUX Products GmbH, Nuernberg, Germany. >> + * >> + * This library is free software; you can redistribute it and/or >> + * modify it under the terms of the GNU Lesser General Public >> + * License as published by the Free Software Foundation; either >> + * version 2.1 of the License, or (at your option) any later version. >> + * >> + * This library is distributed in the hope that it will be useful, >> + * but WITHOUT ANY WARRANTY; without even the implied warranty of >> + * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU >> + * Lesser General Public License for more details. >> + * >> + * You should have received a copy of the GNU Lesser General Public >> + * License along with this library. If not, see >> + * <http://www.gnu.org/licenses/>. >> + * >> + * Authors: >> + * Jim Fehlig <jfehlig@xxxxxxxx> >> + */ >> + >> +#ifndef LIBXL_MIGRATION_H >> +# define LIBXL_MIGRATION_H >> + >> +# include "libxl_conf.h" >> + >> +# define LIBXL_MIGRATION_FLAGS \ >> + (VIR_MIGRATE_LIVE | \ >> + VIR_MIGRATE_UNDEFINE_SOURCE | \ >> + VIR_MIGRATE_PAUSED) >> + >> +/* All supported migration parameters and their types. */ >> +# define LIBXL_MIGRATION_PARAMETERS \ >> + VIR_MIGRATE_PARAM_URI, VIR_TYPED_PARAM_STRING, \ >> + VIR_MIGRATE_PARAM_DEST_NAME, VIR_TYPED_PARAM_STRING, \ >> + VIR_MIGRATE_PARAM_DEST_XML, VIR_TYPED_PARAM_STRING, \ >> + NULL >> + >> +char * >> +libxlDomainMigrationBegin(virConnectPtr conn, >> + virDomainObjPtr vm, >> + const char *xmlin); >> + >> +virDomainDefPtr >> +libxlDomainMigrationPrepareDef(libxlDriverPrivatePtr driver, >> + const char *dom_xml, >> + const char *dname); >> + >> +int >> +libxlDomainMigrationPrepare(virConnectPtr dconn, >> + virDomainDefPtr def, >> + const char *uri_in, >> + char **uri_out); >> + >> +int >> +libxlDomainMigrationPerform(libxlDriverPrivatePtr driver, >> + virDomainObjPtr vm, >> + const char *dom_xml, >> + const char *dconnuri, >> + const char *uri_str, >> + const char *dname, >> + unsigned int flags); >> + >> +virDomainPtr >> +libxlDomainMigrationFinish(virConnectPtr dconn, >> + virDomainObjPtr vm, >> + unsigned int flags, >> + int cancelled); >> + >> +int >> +libxlDomainMigrationConfirm(libxlDriverPrivatePtr driver, >> + virDomainObjPtr vm, >> + unsigned int flags, >> + int cancelled); >> + >> +#endif /* LIBXL_DRIVER_H */ >> > > Michal > -- libvir-list mailing list libvir-list@xxxxxxxxxx https://www.redhat.com/mailman/listinfo/libvir-list