[libvirt] [PATCH 5/5] qemu: Implement virDomainOpenChannel API
---
src/qemu/qemu_driver.c | 73 ++++++++++++++++++++++++++++++++++++++++++++++++++
1 file changed, 73 insertions(+)
diff --git a/src/qemu/qemu_driver.c b/src/qemu/qemu_driver.c
index 441272d..bcd9c57 100644
--- a/src/qemu/qemu_driver.c
+++ b/src/qemu/qemu_driver.c
@@ -12907,6 +12907,78 @@ cleanup:
return ret;
}
+static int
+qemuDomainOpenChannel(virDomainPtr dom,
+ const char *name,
+ virStreamPtr st,
+ unsigned int flags)
+{
+ virDomainObjPtr vm = NULL;
+ int ret = -1;
+ int i;
+ virDomainChrDefPtr chr = NULL;
+ qemuDomainObjPrivatePtr priv;
+
+ virCheckFlags(VIR_DOMAIN_CHANNEL_FORCE, -1);
+
+ if (!(vm = qemuDomObjFromDomain(dom)))
+ goto cleanup;
+
+ if (!virDomainObjIsActive(vm)) {
+ virReportError(VIR_ERR_OPERATION_INVALID,
+ "%s", _("domain is not running"));
+ goto cleanup;
+ }
+
+ priv = vm->privateData;
+
+ if (name) {
+ for (i = 0 ; !chr && i < vm->def->nchannels ; i++) {
+ if (STREQ(name, vm->def->channels[i]->info.alias))
+ chr = vm->def->channels[i];
+
+ if (vm->def->channels[i]->targetType == \
+ VIR_DOMAIN_CHR_CHANNEL_TARGET_TYPE_VIRTIO &&
+ STREQ(name, vm->def->channels[i]->target.name))
+ chr = vm->def->channels[i];
+ }
+ } else {
+ if (vm->def->nchannels)
+ chr = vm->def->channels[0];
+ }
+
+ if (!chr) {
+ virReportError(VIR_ERR_INTERNAL_ERROR,
+ _("cannot find channel %s"),
+ NULLSTR(name));
+ goto cleanup;
+ }
+
+ if (chr->source.type != VIR_DOMAIN_CHR_TYPE_UNIX) {
+ virReportError(VIR_ERR_INTERNAL_ERROR,
+ _("channel %s is not using a UNIX socket"),
+ NULLSTR(name));
+ goto cleanup;
+ }
+
+ /* handle mutually exclusive access to channel devices */
+ ret = virChrdevOpen(priv->devs,
+ &chr->source,
+ st,
+ (flags & VIR_DOMAIN_CHANNEL_FORCE) != 0);
+
+ if (ret == 1) {
+ virReportError(VIR_ERR_OPERATION_FAILED, "%s",
+ _("Active channel stream exists for this domain"));
+ ret = -1;
+ }
+
+cleanup:
+ if (vm)
+ virDomainObjUnlock(vm);
+ return ret;
+}
+
static char *
qemuDiskPathToAlias(virDomainObjPtr vm, const char *path, int *idx)
{
@@ -15062,6 +15134,7 @@ static virDriver qemuDriver = {
.nodeSetMemoryParameters = nodeSetMemoryParameters, /* 0.10.2 */
.nodeGetCPUMap = nodeGetCPUMap, /* 1.0.0 */
.domainFSTrim = qemuDomainFSTrim, /* 1.0.1 */
+ .domainOpenChannel = qemuDomainOpenChannel, /* 1.0.1 */
};
--
1.7.11.7