qemu/rbd: improve rbd device specification

This improves the support for qemu rbd devices by adding support for a few
key features (e.g., authentication) and cleaning up the way in which
rbd configuration options are passed to qemu.

An <auth> member of the disk source xml specifies how librbd should
authenticate. The username attribute is the Ceph/RBD user to authenticate as.
The usage or uuid attributes specify which secret to use. Usage is an
arbitrary identifier local to libvirt.

The old RBD support relied on setting an environment variable to
communicate information to qemu/librbd.  Instead, pass those options
explicitly to qemu.  Update the qemu argument parsing and tests
accordingly.

Signed-off-by: Sage Weil <sage@newdream.net>
Signed-off-by: Josh Durgin <josh.durgin@dreamhost.com>
This commit is contained in:
Sage Weil 2011-10-31 18:29:07 -07:00 committed by Eric Blake
parent 0f590c62b2
commit 5745dc123a
8 changed files with 409 additions and 107 deletions

View File

@ -39,6 +39,7 @@
#include "domain_conf.h" #include "domain_conf.h"
#include "network/bridge_driver.h" #include "network/bridge_driver.h"
#include "virnetdevtap.h" #include "virnetdevtap.h"
#include "base64.h"
#include <sys/utsname.h> #include <sys/utsname.h>
#include <sys/stat.h> #include <sys/stat.h>
@ -1444,6 +1445,189 @@ qemuSafeSerialParamValue(const char *value)
return 0; return 0;
} }
static int
qemuBuildRBDString(virConnectPtr conn,
virDomainDiskDefPtr disk,
virBufferPtr opt)
{
int i, ret = 0;
virSecretPtr sec = NULL;
char *secret = NULL;
size_t secret_size;
virBufferAsprintf(opt, "rbd:%s", disk->src);
if (disk->auth.username) {
virBufferEscape(opt, ":", ":id=%s", disk->auth.username);
/* look up secret */
switch (disk->auth.secretType) {
case VIR_DOMAIN_DISK_SECRET_TYPE_UUID:
sec = virSecretLookupByUUID(conn,
disk->auth.secret.uuid);
break;
case VIR_DOMAIN_DISK_SECRET_TYPE_USAGE:
sec = virSecretLookupByUsage(conn,
VIR_SECRET_USAGE_TYPE_CEPH,
disk->auth.secret.usage);
break;
}
if (sec) {
char *base64 = NULL;
secret = (char *)conn->secretDriver->getValue(sec, &secret_size, 0,
VIR_SECRET_GET_VALUE_INTERNAL_CALL);
if (secret == NULL) {
qemuReportError(VIR_ERR_INTERNAL_ERROR,
_("could not get the value of the secret for username %s"),
disk->auth.username);
goto error;
}
/* qemu/librbd wants it base64 encoded */
base64_encode_alloc(secret, secret_size, &base64);
if (!base64) {
virReportOOMError();
goto error;
}
virBufferEscape(opt, ":", ":key=%s:auth_supported=cephx none",
base64);
VIR_FREE(base64);
} else {
qemuReportError(VIR_ERR_INTERNAL_ERROR,
_("rbd username '%s' specified but secret not found"),
disk->auth.username);
goto error;
}
}
if (disk->nhosts > 0) {
virBufferAddLit(opt, ":mon_host=");
for (i = 0; i < disk->nhosts; ++i) {
if (i) {
virBufferAddLit(opt, "\\;");
}
if (disk->hosts[i].port) {
virBufferAsprintf(opt, "%s\\:%s",
disk->hosts[i].name,
disk->hosts[i].port);
} else {
virBufferAsprintf(opt, "%s", disk->hosts[i].name);
}
}
}
cleanup:
VIR_FREE(secret);
if (sec)
virUnrefSecret(sec);
return ret;
error:
ret = -1;
goto cleanup;
}
static int qemuAddRBDHost(virDomainDiskDefPtr disk, char *hostport)
{
char *port;
disk->nhosts++;
if (VIR_REALLOC_N(disk->hosts, disk->nhosts) < 0)
goto no_memory;
port = strstr(hostport, "\\:");
if (port) {
*port = '\0';
port += 2;
disk->hosts[disk->nhosts-1].port = strdup(port);
if (!disk->hosts[disk->nhosts-1].port)
goto no_memory;
} else {
disk->hosts[disk->nhosts-1].port = strdup("6789");
if (!disk->hosts[disk->nhosts-1].port)
goto no_memory;
}
disk->hosts[disk->nhosts-1].name = strdup(hostport);
if (!disk->hosts[disk->nhosts-1].name)
goto no_memory;
return 0;
no_memory:
virReportOOMError();
VIR_FREE(disk->hosts[disk->nhosts-1].port);
VIR_FREE(disk->hosts[disk->nhosts-1].name);
return -1;
}
/* disk->src initially has everything after the rbd: prefix */
static int qemuParseRBDString(virDomainDiskDefPtr disk)
{
char *options = NULL;
char *p, *e, *next;
p = strchr(disk->src, ':');
if (p) {
options = strdup(p + 1);
if (!options)
goto no_memory;
*p = '\0';
}
/* options */
if (!options)
return 0; /* all done */
p = options;
while (*p) {
/* find : delimiter or end of string */
for (e = p; *e && *e != ':'; ++e) {
if (*e == '\\') {
e++;
if (*e == '\0')
break;
}
}
if (*e == '\0') {
next = e; /* last kv pair */
} else {
next = e + 1;
*e = '\0';
}
if (STRPREFIX(p, "id=")) {
disk->auth.username = strdup(p + strlen("id="));
if (!disk->auth.username)
goto no_memory;
}
if (STRPREFIX(p, "mon_host=")) {
char *h, *sep;
h = p + strlen("mon_host=");
while (h < e) {
for (sep = h; sep < e; ++sep) {
if (*sep == '\\' && (sep[1] == ',' ||
sep[1] == ';' ||
sep[1] == ' ')) {
*sep = '\0';
sep += 2;
break;
}
}
if (qemuAddRBDHost(disk, h) < 0) {
return -1;
}
h = sep;
}
}
p = next;
}
return 0;
no_memory:
virReportOOMError();
return -1;
}
char * char *
qemuBuildDriveStr(virConnectPtr conn ATTRIBUTE_UNUSED, qemuBuildDriveStr(virConnectPtr conn ATTRIBUTE_UNUSED,
@ -1563,8 +1747,10 @@ qemuBuildDriveStr(virConnectPtr conn ATTRIBUTE_UNUSED,
disk->hosts->name, disk->hosts->port); disk->hosts->name, disk->hosts->port);
break; break;
case VIR_DOMAIN_DISK_PROTOCOL_RBD: case VIR_DOMAIN_DISK_PROTOCOL_RBD:
/* TODO: set monitor hostnames */ virBufferAddLit(&opt, "file=");
virBufferAsprintf(&opt, "file=rbd:%s,", disk->src); if (qemuBuildRBDString(conn, disk, &opt) < 0)
goto error;
virBufferAddChar(&opt, ',');
break; break;
case VIR_DOMAIN_DISK_PROTOCOL_SHEEPDOG: case VIR_DOMAIN_DISK_PROTOCOL_SHEEPDOG:
if (disk->nhosts == 0) if (disk->nhosts == 0)
@ -3248,8 +3434,6 @@ qemuBuildCommandLine(virConnectPtr conn,
int last_good_net = -1; int last_good_net = -1;
bool hasHwVirt = false; bool hasHwVirt = false;
virCommandPtr cmd; virCommandPtr cmd;
bool has_rbd_hosts = false;
virBuffer rbd_hosts = VIR_BUFFER_INITIALIZER;
bool emitBootindex = false; bool emitBootindex = false;
int usbcontroller = 0; int usbcontroller = 0;
bool usblegacy = false; bool usblegacy = false;
@ -3829,7 +4013,6 @@ qemuBuildCommandLine(virConnectPtr conn,
virDomainDiskDefPtr disk = def->disks[i]; virDomainDiskDefPtr disk = def->disks[i];
int withDeviceArg = 0; int withDeviceArg = 0;
bool deviceFlagMasked = false; bool deviceFlagMasked = false;
int j;
/* Unless we have -device, then USB disks need special /* Unless we have -device, then USB disks need special
handling */ handling */
@ -3887,26 +4070,6 @@ qemuBuildCommandLine(virConnectPtr conn,
virCommandAddArg(cmd, optstr); virCommandAddArg(cmd, optstr);
VIR_FREE(optstr); VIR_FREE(optstr);
if (disk->type == VIR_DOMAIN_DISK_TYPE_NETWORK &&
disk->protocol == VIR_DOMAIN_DISK_PROTOCOL_RBD) {
for (j = 0 ; j < disk->nhosts ; j++) {
if (!has_rbd_hosts) {
virBufferAddLit(&rbd_hosts, "CEPH_ARGS=-m ");
has_rbd_hosts = true;
} else {
virBufferAddLit(&rbd_hosts, ",");
}
virDomainDiskHostDefPtr host = &disk->hosts[j];
if (host->port) {
virBufferAsprintf(&rbd_hosts, "%s:%s",
host->name,
host->port);
} else {
virBufferAdd(&rbd_hosts, host->name, -1);
}
}
}
if (!emitBootindex) if (!emitBootindex)
bootindex = 0; bootindex = 0;
else if (disk->bootIndex) else if (disk->bootIndex)
@ -3944,7 +4107,6 @@ qemuBuildCommandLine(virConnectPtr conn,
char *file; char *file;
const char *fmt; const char *fmt;
virDomainDiskDefPtr disk = def->disks[i]; virDomainDiskDefPtr disk = def->disks[i];
int j;
if (disk->bus == VIR_DOMAIN_DISK_BUS_USB) { if (disk->bus == VIR_DOMAIN_DISK_BUS_USB) {
if (disk->device == VIR_DOMAIN_DISK_DEVICE_DISK) { if (disk->device == VIR_DOMAIN_DISK_DEVICE_DISK) {
@ -4013,24 +4175,15 @@ qemuBuildCommandLine(virConnectPtr conn,
} }
break; break;
case VIR_DOMAIN_DISK_PROTOCOL_RBD: case VIR_DOMAIN_DISK_PROTOCOL_RBD:
if (virAsprintf(&file, "rbd:%s,", disk->src) < 0) { {
goto no_memory; virBuffer opt = VIR_BUFFER_INITIALIZER;
} if (qemuBuildRBDString(conn, disk, &opt) < 0)
for (j = 0 ; j < disk->nhosts ; j++) { goto error;
if (!has_rbd_hosts) { if (virBufferError(&opt)) {
virBufferAddLit(&rbd_hosts, "CEPH_ARGS=-m "); virReportOOMError();
has_rbd_hosts = true; goto error;
} else {
virBufferAddLit(&rbd_hosts, ",");
}
virDomainDiskHostDefPtr host = &disk->hosts[j];
if (host->port) {
virBufferAsprintf(&rbd_hosts, "%s:%s",
host->name,
host->port);
} else {
virBufferAdd(&rbd_hosts, host->name, -1);
} }
file = virBufferContentAndReset(&opt);
} }
break; break;
case VIR_DOMAIN_DISK_PROTOCOL_SHEEPDOG: case VIR_DOMAIN_DISK_PROTOCOL_SHEEPDOG:
@ -4059,9 +4212,6 @@ qemuBuildCommandLine(virConnectPtr conn,
} }
} }
if (has_rbd_hosts)
virCommandAddEnvBuffer(cmd, &rbd_hosts);
if (qemuCapsGet(qemuCaps, QEMU_CAPS_FSDEV)) { if (qemuCapsGet(qemuCaps, QEMU_CAPS_FSDEV)) {
for (i = 0 ; i < def->nfss ; i++) { for (i = 0 ; i < def->nfss ; i++) {
char *optstr; char *optstr;
@ -5232,7 +5382,6 @@ qemuBuildCommandLine(virConnectPtr conn,
networkReleaseActualDevice(def->nets[i]); networkReleaseActualDevice(def->nets[i]);
for (i = 0; i <= last_good_net; i++) for (i = 0; i <= last_good_net; i++)
virDomainConfNWFilterTeardown(def->nets[i]); virDomainConfNWFilterTeardown(def->nets[i]);
virBufferFreeAndReset(&rbd_hosts);
virCommandFree(cmd); virCommandFree(cmd);
return NULL; return NULL;
} }
@ -5471,7 +5620,8 @@ error:
static virDomainDiskDefPtr static virDomainDiskDefPtr
qemuParseCommandLineDisk(virCapsPtr caps, qemuParseCommandLineDisk(virCapsPtr caps,
const char *val, const char *val,
int nvirtiodisk) int nvirtiodisk,
bool old_style_ceph_args)
{ {
virDomainDiskDefPtr def = NULL; virDomainDiskDefPtr def = NULL;
char **keywords; char **keywords;
@ -5546,6 +5696,9 @@ qemuParseCommandLineDisk(virCapsPtr caps,
virReportOOMError(); virReportOOMError();
goto cleanup; goto cleanup;
} }
/* old-style CEPH_ARGS env variable is parsed later */
if (!old_style_ceph_args && qemuParseRBDString(def) < 0)
goto cleanup;
VIR_FREE(p); VIR_FREE(p);
} else if (STRPREFIX(def->src, "sheepdog:")) { } else if (STRPREFIX(def->src, "sheepdog:")) {
@ -6411,6 +6564,7 @@ virDomainDefPtr qemuParseCommandLine(virCapsPtr caps,
int nvirtiodisk = 0; int nvirtiodisk = 0;
qemuDomainCmdlineDefPtr cmd = NULL; qemuDomainCmdlineDefPtr cmd = NULL;
virDomainDiskDefPtr disk = NULL; virDomainDiskDefPtr disk = NULL;
const char *ceph_args = qemuFindEnv(progenv, "CEPH_ARGS");
if (pidfile) if (pidfile)
*pidfile = NULL; *pidfile = NULL;
@ -6665,7 +6819,9 @@ virDomainDefPtr qemuParseCommandLine(virCapsPtr caps,
disk->src = NULL; disk->src = NULL;
break; break;
case VIR_DOMAIN_DISK_PROTOCOL_RBD: case VIR_DOMAIN_DISK_PROTOCOL_RBD:
/* handled later since the hosts for all disks are in CEPH_ARGS */ /* old-style CEPH_ARGS env variable is parsed later */
if (!ceph_args && qemuParseRBDString(disk) < 0)
goto error;
break; break;
case VIR_DOMAIN_DISK_PROTOCOL_SHEEPDOG: case VIR_DOMAIN_DISK_PROTOCOL_SHEEPDOG:
/* disk->src must be [vdiname] or [host]:[port]:[vdiname] */ /* disk->src must be [vdiname] or [host]:[port]:[vdiname] */
@ -6865,7 +7021,8 @@ virDomainDefPtr qemuParseCommandLine(virCapsPtr caps,
} }
} else if (STREQ(arg, "-drive")) { } else if (STREQ(arg, "-drive")) {
WANT_VALUE(); WANT_VALUE();
if (!(disk = qemuParseCommandLineDisk(caps, val, nvirtiodisk))) if (!(disk = qemuParseCommandLineDisk(caps, val, nvirtiodisk,
ceph_args != NULL)))
goto error; goto error;
if (VIR_REALLOC_N(def->disks, def->ndisks+1) < 0) if (VIR_REALLOC_N(def->disks, def->ndisks+1) < 0)
goto no_memory; goto no_memory;
@ -7004,66 +7161,63 @@ virDomainDefPtr qemuParseCommandLine(virCapsPtr caps,
} }
#undef WANT_VALUE #undef WANT_VALUE
if (def->ndisks > 0) { if (def->ndisks > 0 && ceph_args) {
const char *ceph_args = qemuFindEnv(progenv, "CEPH_ARGS"); char *hosts, *port, *saveptr = NULL, *token;
if (ceph_args) { virDomainDiskDefPtr first_rbd_disk = NULL;
char *hosts, *port, *saveptr = NULL, *token; for (i = 0 ; i < def->ndisks ; i++) {
virDomainDiskDefPtr first_rbd_disk = NULL; if (def->disks[i]->type == VIR_DOMAIN_DISK_TYPE_NETWORK &&
for (i = 0 ; i < def->ndisks ; i++) { def->disks[i]->protocol == VIR_DOMAIN_DISK_PROTOCOL_RBD) {
if (def->disks[i]->type == VIR_DOMAIN_DISK_TYPE_NETWORK && first_rbd_disk = def->disks[i];
def->disks[i]->protocol == VIR_DOMAIN_DISK_PROTOCOL_RBD) { break;
first_rbd_disk = def->disks[i];
break;
}
} }
}
if (!first_rbd_disk) { if (!first_rbd_disk) {
qemuReportError(VIR_ERR_INTERNAL_ERROR, qemuReportError(VIR_ERR_INTERNAL_ERROR,
_("CEPH_ARGS was set without an rbd disk")); _("CEPH_ARGS was set without an rbd disk"));
goto error; goto error;
} }
/* CEPH_ARGS should be: -m host1[:port1][,host2[:port2]]... */ /* CEPH_ARGS should be: -m host1[:port1][,host2[:port2]]... */
if (!STRPREFIX(ceph_args, "-m ")) { if (!STRPREFIX(ceph_args, "-m ")) {
qemuReportError(VIR_ERR_INTERNAL_ERROR, qemuReportError(VIR_ERR_INTERNAL_ERROR,
_("could not parse CEPH_ARGS '%s'"), ceph_args); _("could not parse CEPH_ARGS '%s'"), ceph_args);
goto error; goto error;
} }
hosts = strdup(strchr(ceph_args, ' ') + 1); hosts = strdup(strchr(ceph_args, ' ') + 1);
if (!hosts) if (!hosts)
goto no_memory;
first_rbd_disk->nhosts = 0;
token = strtok_r(hosts, ",", &saveptr);
while (token != NULL) {
if (VIR_REALLOC_N(first_rbd_disk->hosts, first_rbd_disk->nhosts + 1) < 0) {
VIR_FREE(hosts);
goto no_memory; goto no_memory;
first_rbd_disk->nhosts = 0;
token = strtok_r(hosts, ",", &saveptr);
while (token != NULL) {
if (VIR_REALLOC_N(first_rbd_disk->hosts, first_rbd_disk->nhosts + 1) < 0) {
VIR_FREE(hosts);
goto no_memory;
}
port = strchr(token, ':');
if (port) {
*port++ = '\0';
port = strdup(port);
if (!port) {
VIR_FREE(hosts);
goto no_memory;
}
}
first_rbd_disk->hosts[first_rbd_disk->nhosts].port = port;
first_rbd_disk->hosts[first_rbd_disk->nhosts].name = strdup(token);
if (!first_rbd_disk->hosts[first_rbd_disk->nhosts].name) {
VIR_FREE(hosts);
goto no_memory;
}
first_rbd_disk->nhosts++;
token = strtok_r(NULL, ",", &saveptr);
} }
VIR_FREE(hosts); port = strchr(token, ':');
if (port) {
*port++ = '\0';
port = strdup(port);
if (!port) {
VIR_FREE(hosts);
goto no_memory;
}
}
first_rbd_disk->hosts[first_rbd_disk->nhosts].port = port;
first_rbd_disk->hosts[first_rbd_disk->nhosts].name = strdup(token);
if (!first_rbd_disk->hosts[first_rbd_disk->nhosts].name) {
VIR_FREE(hosts);
goto no_memory;
}
first_rbd_disk->nhosts++;
token = strtok_r(NULL, ",", &saveptr);
}
VIR_FREE(hosts);
if (first_rbd_disk->nhosts == 0) { if (first_rbd_disk->nhosts == 0) {
qemuReportError(VIR_ERR_INTERNAL_ERROR, qemuReportError(VIR_ERR_INTERNAL_ERROR,
_("found no rbd hosts in CEPH_ARGS '%s'"), ceph_args); _("found no rbd hosts in CEPH_ARGS '%s'"), ceph_args);
goto error; goto error;
}
} }
} }

View File

@ -173,6 +173,8 @@ mymain(void)
DO_TEST("disk-drive-cache-unsafe"); DO_TEST("disk-drive-cache-unsafe");
DO_TEST("disk-drive-network-nbd"); DO_TEST("disk-drive-network-nbd");
DO_TEST("disk-drive-network-rbd"); DO_TEST("disk-drive-network-rbd");
/* older format using CEPH_ARGS env var */
DO_TEST("disk-drive-network-rbd-ceph-env");
DO_TEST("disk-drive-network-sheepdog"); DO_TEST("disk-drive-network-sheepdog");
DO_TEST("disk-usb"); DO_TEST("disk-usb");
DO_TEST("graphics-vnc"); DO_TEST("graphics-vnc");

View File

@ -0,0 +1,10 @@
LC_ALL=C PATH=/bin HOME=/home/test USER=test LOGNAME=test \
/usr/bin/qemu -S -M pc -m 214 -smp 1 -nographic -monitor \
unix:/tmp/test-monitor,server,nowait -no-acpi -boot c -drive \
file=/dev/HostVG/QEMUGuest1,if=ide,bus=0,unit=0 -drive \
file=rbd:pool/image:\
id=myname:\
key=QVFDVm41aE82SHpGQWhBQXEwTkN2OGp0SmNJY0UrSE9CbE1RMUE=:\
auth_supported=cephx none:\
mon_host=mon1.example.org\:6321\;mon2.example.org\:6322\;mon3.example.org\:6322,\
if=virtio,format=raw -net none -serial none -parallel none -usb

View File

@ -0,0 +1,37 @@
<domain type='qemu'>
<name>QEMUGuest1</name>
<uuid>c7a5fdbd-edaf-9455-926a-d65c16db1809</uuid>
<memory>219136</memory>
<currentMemory>219136</currentMemory>
<vcpu>1</vcpu>
<os>
<type arch='i686' machine='pc'>hvm</type>
<boot dev='hd'/>
</os>
<clock offset='utc'/>
<on_poweroff>destroy</on_poweroff>
<on_reboot>restart</on_reboot>
<on_crash>destroy</on_crash>
<devices>
<emulator>/usr/bin/qemu</emulator>
<disk type='block' device='disk'>
<source dev='/dev/HostVG/QEMUGuest1'/>
<target dev='hda' bus='ide'/>
<address type='drive' controller='0' bus='0' unit='0'/>
</disk>
<disk type='network' device='disk'>
<driver name='qemu' type='raw'/>
<auth username='myname'>
<secret type='ceph' usage='mycluster_myname'/>
</auth>
<source protocol='rbd' name='pool/image'>
<host name='mon1.example.org' port='6321'/>
<host name='mon2.example.org' port='6322'/>
<host name='mon3.example.org' port='6322'/>
</source>
<target dev='vda' bus='virtio'/>
</disk>
<controller type='ide' index='0'/>
<memballoon model='virtio'/>
</devices>
</domain>

View File

@ -0,0 +1,6 @@
LC_ALL=C PATH=/bin HOME=/home/test USER=test LOGNAME=test CEPH_ARGS=-m \
mon1.example.org:6321,mon2.example.org:6322,mon3.example.org:6322 \
/usr/bin/qemu -S -M pc -m 214 -smp 1 -nographic -monitor \
unix:/tmp/test-monitor,server,nowait -no-acpi -boot c -drive \
file=/dev/HostVG/QEMUGuest1,if=ide,bus=0,unit=0 -drive file=rbd:pool/image,\
if=virtio,format=raw -net none -serial none -parallel none -usb

View File

@ -0,0 +1,34 @@
<domain type='qemu'>
<name>QEMUGuest1</name>
<uuid>c7a5fdbd-edaf-9455-926a-d65c16db1809</uuid>
<memory>219136</memory>
<currentMemory>219136</currentMemory>
<vcpu>1</vcpu>
<os>
<type arch='i686' machine='pc'>hvm</type>
<boot dev='hd'/>
</os>
<clock offset='utc'/>
<on_poweroff>destroy</on_poweroff>
<on_reboot>restart</on_reboot>
<on_crash>destroy</on_crash>
<devices>
<emulator>/usr/bin/qemu</emulator>
<disk type='block' device='disk'>
<source dev='/dev/HostVG/QEMUGuest1'/>
<target dev='hda' bus='ide'/>
<address type='drive' controller='0' bus='0' unit='0'/>
</disk>
<disk type='network' device='disk'>
<driver name='qemu' type='raw'/>
<source protocol='rbd' name='pool/image'>
<host name='mon1.example.org' port='6321'/>
<host name='mon2.example.org' port='6322'/>
<host name='mon3.example.org' port='6322'/>
</source>
<target dev='vda' bus='virtio'/>
</disk>
<controller type='ide' index='0'/>
<memballoon model='virtio'/>
</devices>
</domain>

View File

@ -1,6 +1,7 @@
LC_ALL=C PATH=/bin HOME=/home/test USER=test LOGNAME=test CEPH_ARGS=-m \ LC_ALL=C PATH=/bin HOME=/home/test USER=test LOGNAME=test \
mon1.example.org:6321,mon2.example.org:6322,mon3.example.org:6322 \
/usr/bin/qemu -S -M pc -m 214 -smp 1 -nographic -monitor \ /usr/bin/qemu -S -M pc -m 214 -smp 1 -nographic -monitor \
unix:/tmp/test-monitor,server,nowait -no-acpi -boot c -drive \ unix:/tmp/test-monitor,server,nowait -no-acpi -boot c -drive \
file=/dev/HostVG/QEMUGuest1,if=ide,bus=0,unit=0 -drive file=rbd:pool/image,\ file=/dev/HostVG/QEMUGuest1,if=ide,bus=0,unit=0 -drive \
file=rbd:pool/image:\
mon_host=mon1.example.org\:6321\;mon2.example.org\:6322\;mon3.example.org\:6322,\
if=virtio,format=raw -net none -serial none -parallel none -usb if=virtio,format=raw -net none -serial none -parallel none -usb

View File

@ -12,6 +12,7 @@
# include "internal.h" # include "internal.h"
# include "testutils.h" # include "testutils.h"
# include "util/memory.h"
# include "qemu/qemu_capabilities.h" # include "qemu/qemu_capabilities.h"
# include "qemu/qemu_command.h" # include "qemu/qemu_command.h"
# include "qemu/qemu_domain.h" # include "qemu/qemu_domain.h"
@ -23,6 +24,60 @@
static const char *abs_top_srcdir; static const char *abs_top_srcdir;
static struct qemud_driver driver; static struct qemud_driver driver;
static unsigned char *
fakeSecretGetValue(virSecretPtr obj ATTRIBUTE_UNUSED,
size_t *value_size,
unsigned int fakeflags ATTRIBUTE_UNUSED,
unsigned int internalFlags ATTRIBUTE_UNUSED)
{
char *secret = strdup("AQCVn5hO6HzFAhAAq0NCv8jtJcIcE+HOBlMQ1A");
*value_size = strlen(secret);
return (unsigned char *) secret;
}
static virSecretPtr
fakeSecretLookupByUsage(virConnectPtr conn,
int usageType ATTRIBUTE_UNUSED,
const char *usageID)
{
virSecretPtr ret = NULL;
int err;
if (STRNEQ(usageID, "mycluster_myname"))
return NULL;
err = VIR_ALLOC(ret);
if (err < 0)
return NULL;
ret->magic = VIR_SECRET_MAGIC;
ret->refs = 1;
ret->usageID = strdup(usageID);
if (!ret->usageID)
return NULL;
ret->conn = conn;
conn->refs++;
return ret;
}
static int
fakeSecretClose(virConnectPtr conn ATTRIBUTE_UNUSED)
{
return 0;
}
static virSecretDriver fakeSecretDriver = {
.name = "fake_secret",
.open = NULL,
.close = fakeSecretClose,
.numOfSecrets = NULL,
.listSecrets = NULL,
.lookupByUUID = NULL,
.lookupByUsage = fakeSecretLookupByUsage,
.defineXML = NULL,
.getXMLDesc = NULL,
.setValue = NULL,
.getValue = fakeSecretGetValue,
.undefine = NULL,
};
static int testCompareXMLToArgvFiles(const char *xml, static int testCompareXMLToArgvFiles(const char *xml,
const char *cmdline, const char *cmdline,
virBitmapPtr extraFlags, virBitmapPtr extraFlags,
@ -44,6 +99,7 @@ static int testCompareXMLToArgvFiles(const char *xml,
if (!(conn = virGetConnect())) if (!(conn = virGetConnect()))
goto fail; goto fail;
conn->secretDriver = &fakeSecretDriver;
len = virtTestLoadFile(cmdline, &expectargv); len = virtTestLoadFile(cmdline, &expectargv);
if (len < 0) if (len < 0)
@ -357,6 +413,8 @@ mymain(void)
QEMU_CAPS_DRIVE, QEMU_CAPS_DRIVE_FORMAT); QEMU_CAPS_DRIVE, QEMU_CAPS_DRIVE_FORMAT);
DO_TEST("disk-drive-network-sheepdog", false, DO_TEST("disk-drive-network-sheepdog", false,
QEMU_CAPS_DRIVE, QEMU_CAPS_DRIVE_FORMAT); QEMU_CAPS_DRIVE, QEMU_CAPS_DRIVE_FORMAT);
DO_TEST("disk-drive-network-rbd-auth", false,
QEMU_CAPS_DRIVE, QEMU_CAPS_DRIVE_FORMAT);
DO_TEST("disk-drive-no-boot", false, DO_TEST("disk-drive-no-boot", false,
QEMU_CAPS_DRIVE, QEMU_CAPS_DEVICE, QEMU_CAPS_BOOTINDEX); QEMU_CAPS_DRIVE, QEMU_CAPS_DEVICE, QEMU_CAPS_BOOTINDEX);
DO_TEST("disk-usb", false, NONE); DO_TEST("disk-usb", false, NONE);