On 2011年12月23日 15:09, Hu Tao wrote: >* src/qemu/qemu_driver.c: implement the qemu driver support >--- > src/qemu/qemu_driver.c | 434 ++++++++++++++++++++++++++++++++++++++++++++++++ > 1 files changed, 434 insertions(+), 0 deletions(-) > >diff --git a/src/qemu/qemu_driver.c b/src/qemu/qemu_driver.c >index c908135..2fab489 100644 >--- a/src/qemu/qemu_driver.c >+++ b/src/qemu/qemu_driver.c >@@ -119,6 +119,8 @@ > > #define QEMU_NB_BLKIO_PARAM 2 > >+#define QEMU_NB_BANDWIDTH_PARAM 6 >+ > static void processWatchdogEvent(void *data, void *opaque); > > static int qemudShutdown(void); >@@ -7846,6 +7848,436 @@ qemudDomainInterfaceStats (virDomainPtr dom, > #endif > > static int >+qemuDomainSetInterfaceParameters(virDomainPtr dom, >+ const char *device, >+ virTypedParameterPtr params, >+ int nparams, >+ unsigned int flags) >+{ >+ struct qemud_driver *driver = dom->conn->privateData; >+ int i; >+ virCgroupPtr group = NULL; >+ virDomainObjPtr vm = NULL; >+ virDomainDefPtr persistentDef = NULL; >+ int ret = -1; >+ virDomainNetDefPtr net = NULL; >+ bool isMac = false; >+ virNetDevBandwidthPtr bandwidth; >+ unsigned char mac[VIR_MAC_BUFLEN]; >+ bool isActive; >+ >+ virCheckFlags(VIR_DOMAIN_AFFECT_LIVE | >+ VIR_DOMAIN_AFFECT_CONFIG, -1); >+ qemuDriverLock(driver); >+ >+ vm = virDomainFindByUUID(&driver->domains, dom->uuid); >+ >+ if (vm == NULL) { >+ qemuReportError(VIR_ERR_INTERNAL_ERROR, >+ _("No such domain %s"), dom->uuid); >+ goto cleanup; >+ } == From >+ >+ isActive = virDomainObjIsActive(vm); >+ >+ if (flags == VIR_DOMAIN_AFFECT_CURRENT) { >+ if (isActive) >+ flags = VIR_DOMAIN_AFFECT_LIVE; >+ else >+ flags = VIR_DOMAIN_AFFECT_CONFIG; >+ } >+ >+ if (flags& VIR_DOMAIN_AFFECT_LIVE) { >+ if (!isActive) { >+ qemuReportError(VIR_ERR_OPERATION_INVALID, >+ "%s", _("domain is not running")); >+ goto cleanup; >+ } >+ } >+ >+ if (flags& VIR_DOMAIN_AFFECT_CONFIG) { >+ if (!vm->persistent) { >+ qemuReportError(VIR_ERR_OPERATION_INVALID, "%s", >+ _("cannot change persistent config of a transient domain")); >+ goto cleanup; >+ } >+ if (!(persistentDef = virDomainObjGetPersistentDef(driver->caps, vm))) >+ goto cleanup; >+ } == To The above block can be shortened with using helper function virDomainLiveConfigHelperMethod. See commit ae52342. >+ >+ if (VIR_ALLOC(bandwidth)< 0) { >+ virReportOOMError(); >+ goto cleanup; >+ } >+ if (VIR_ALLOC(bandwidth->in)< 0) { >+ virReportOOMError(); >+ goto cleanup; >+ } >+ memset(bandwidth->in, 0, sizeof(*bandwidth->in)); >+ if (VIR_ALLOC(bandwidth->out)< 0) { >+ virReportOOMError(); >+ goto cleanup; >+ } >+ memset(bandwidth->out, 0, sizeof(*bandwidth->out)); >+ >+ for (i = 0; i< nparams; i++) { >+ virTypedParameterPtr param =&params[i]; >+ >+ if (STREQ(param->field, VIR_DOMAIN_BANDWIDTH_IN_AVERAGE)) { >+ if (param->type != VIR_TYPED_PARAM_UINT) { >+ qemuReportError(VIR_ERR_INVALID_ARG, "%s", >+ _("invalid type for bandwidth average tunable, expected a 'unsigned int'")); >+ goto cleanup; >+ } >+ >+ bandwidth->in->average = params[i].value.ui; >+ } else if (STREQ(param->field, VIR_DOMAIN_BANDWIDTH_IN_PEAK)) { >+ if (param->type != VIR_TYPED_PARAM_UINT) { >+ qemuReportError(VIR_ERR_INVALID_ARG, "%s", >+ _("invalid type for bandwidth peak tunable, expected a 'unsigned int'")); >+ goto cleanup; >+ } >+ >+ bandwidth->in->peak = params[i].value.ui; >+ } else if (STREQ(param->field, VIR_DOMAIN_BANDWIDTH_IN_BURST)) { >+ if (param->type != VIR_TYPED_PARAM_UINT) { >+ qemuReportError(VIR_ERR_INVALID_ARG, "%s", >+ _("invalid type for bandwidth burst tunable, expected a 'unsigned int'")); >+ goto cleanup; >+ } >+ >+ bandwidth->in->burst = params[i].value.ui; >+ } else if (STREQ(param->field, VIR_DOMAIN_BANDWIDTH_OUT_AVERAGE)) { >+ if (param->type != VIR_TYPED_PARAM_UINT) { >+ qemuReportError(VIR_ERR_INVALID_ARG, "%s", >+ _("invalid type for bandwidth average tunable, expected a 'unsigned int'")); >+ goto cleanup; >+ } >+ >+ bandwidth->out->average = params[i].value.ui; >+ } else if (STREQ(param->field, VIR_DOMAIN_BANDWIDTH_OUT_PEAK)) { >+ if (param->type != VIR_TYPED_PARAM_UINT) { >+ qemuReportError(VIR_ERR_INVALID_ARG, "%s", >+ _("invalid type for bandwidth peak tunable, expected a 'unsigned int'")); >+ goto cleanup; >+ } >+ >+ bandwidth->out->peak = params[i].value.ui; >+ } else if (STREQ(param->field, VIR_DOMAIN_BANDWIDTH_OUT_BURST)) { >+ if (param->type != VIR_TYPED_PARAM_UINT) { >+ qemuReportError(VIR_ERR_INVALID_ARG, "%s", >+ _("invalid type for bandwidth burst tunable, expected a 'unsigned int'")); >+ goto cleanup; >+ } >+ >+ bandwidth->out->burst = params[i].value.ui; >+ } else { >+ qemuReportError(VIR_ERR_INVALID_ARG, >+ _("Parameter `%s' not supported"), >+ param->field); >+ goto cleanup; >+ } >+ } >+ >+ /* average is mandatory, peak and burst is optional. So if no >+ * average is given, we free inbound/outbound here which causes >+ * inbound/outbound won't be set. */ >+ if (!bandwidth->in->average) >+ VIR_FREE(bandwidth->in); >+ if (!bandwidth->out->average) >+ VIR_FREE(bandwidth->out); >+ >+ if (virParseMacAddr(device, mac) == 0) >+ isMac = true; >+ >+ ret = 0; >+ if (flags& VIR_DOMAIN_AFFECT_LIVE) { >+ if (isMac) { >+ for (i = 0; i< vm->def->nnets; i++) { >+ if (memcmp(mac, vm->def->nets[i]->mac, VIR_MAC_BUFLEN) == 0) { >+ net = vm->def->nets[i]; >+ break; >+ } >+ } >+ } else { /* ifname */ >+ for (i = 0; i< vm->def->nnets; i++) { >+ if (STREQ(device, vm->def->nets[i]->ifname)) { >+ net = vm->def->nets[i]; >+ break; >+ } >+ } >+ } Should we have a helper function to find the net device? accepting both MAC and ifname. Per it's used twice in this function, and once in qemuDomainGetInterfaceParameters. And also it's very likely be used in future. >+ if (!net) { >+ qemuReportError(VIR_ERR_INVALID_ARG, >+ _("cannt find device %s"), >+ device); >+ goto cleanup; >+ } And it's better to quit ealier before allocating memory for bandwidth and parsing params if the device can't be found, it's just waste to do those work if the device even doesn't exist. >+ if (virNetDevBandwidthSet(net->ifname, bandwidth)< 0) { >+ qemuReportError(VIR_ERR_INTERNAL_ERROR, >+ _("cannot set bandwidth limits on %s"), >+ device); >+ ret = -1; Is this intended? to me it's wrong to change the net config below, since it bandwidth setting already failed. "goto cleanup;" makes sense. >+ } >+ >+ if (!net->bandwidth) { >+ net->bandwidth = bandwidth; >+ bandwidth = NULL; >+ } else { >+ if (bandwidth->in) { >+ VIR_FREE(net->bandwidth->in); >+ net->bandwidth->in = bandwidth->in; >+ bandwidth->in = NULL; >+ } >+ if (bandwidth->out) { >+ VIR_FREE(net->bandwidth->out); >+ net->bandwidth->out = bandwidth->out; >+ bandwidth->out = NULL; >+ } >+ } >+ } >+ if (ret< 0) >+ goto cleanup; Again, failed on setting the bandwidth, but net config is changed. >+ if (flags& VIR_DOMAIN_AFFECT_CONFIG) { >+ if (isMac) { >+ for (i = 0; i< persistentDef->nnets; i++) { >+ if (memcmp(mac, persistentDef->nets[i]->mac, VIR_MAC_BUFLEN) == 0) { >+ net = persistentDef->nets[i]; >+ break; >+ } >+ } >+ } else { /* ifname */ >+ for (i = 0; i< persistentDef->nnets; i++) { >+ if (STREQ(device, persistentDef->nets[i]->ifname)) { >+ net = persistentDef->nets[i]; >+ break; >+ } >+ } >+ } >+ if (!net) { >+ qemuReportError(VIR_ERR_INVALID_ARG, >+ _("Can't find device %s"), device); >+ ret = -1; >+ goto cleanup; >+ } >+ >+ if (!net->bandwidth) { >+ net->bandwidth = bandwidth; >+ bandwidth = NULL; >+ } else { >+ if (bandwidth->in) { >+ VIR_FREE(net->bandwidth->in); >+ net->bandwidth->in = bandwidth->in; >+ bandwidth->in = NULL; >+ } >+ if (bandwidth->out) { >+ VIR_FREE(net->bandwidth->out); >+ net->bandwidth->out = bandwidth->out; >+ bandwidth->out = NULL; >+ } >+ } >+ >+ if (virDomainSaveConfig(driver->configDir, persistentDef)< 0) >+ ret = -1; >+ } >+ >+cleanup: >+ if (bandwidth) { >+ VIR_FREE(bandwidth->in); >+ VIR_FREE(bandwidth->out); >+ VIR_FREE(bandwidth); >+ } >+ virCgroupFree(&group); >+ if (vm) >+ virDomainObjUnlock(vm); >+ qemuDriverUnlock(driver); >+ return ret; >+} >+ >+static int >+qemuDomainGetInterfaceParameters(virDomainPtr dom, >+ const char *device, >+ virTypedParameterPtr params, >+ int *nparams, >+ unsigned int flags) >+{ >+ struct qemud_driver *driver = dom->conn->privateData; >+ int i; >+ virCgroupPtr group = NULL; >+ virDomainObjPtr vm = NULL; >+ virDomainDefPtr def = NULL; >+ virDomainNetDefPtr net = NULL; >+ bool isMac = false; >+ unsigned char mac[VIR_MAC_BUFLEN]; >+ int ret = -1; >+ bool isActive; >+ >+ virCheckFlags(VIR_DOMAIN_AFFECT_LIVE | >+ VIR_DOMAIN_AFFECT_CONFIG | >+ VIR_TYPED_PARAM_STRING_OKAY, -1); >+ >+ qemuDriverLock(driver); >+ >+ flags&= ~VIR_TYPED_PARAM_STRING_OKAY; >+ >+ vm = virDomainFindByUUID(&driver->domains, dom->uuid); >+ >+ if (vm == NULL) { >+ qemuReportError(VIR_ERR_INTERNAL_ERROR, >+ _("No such domain %s"), dom->uuid); >+ goto cleanup; >+ } >+ >+ isActive = virDomainObjIsActive(vm); >+ >+ if (flags == VIR_DOMAIN_AFFECT_CURRENT) { >+ if (isActive) >+ flags = VIR_DOMAIN_AFFECT_LIVE; >+ else >+ flags = VIR_DOMAIN_AFFECT_CONFIG; >+ } >+ >+ if (flags& VIR_DOMAIN_AFFECT_LIVE) { >+ if (!isActive) { >+ qemuReportError(VIR_ERR_OPERATION_INVALID, >+ "%s", _("domain is not running")); >+ goto cleanup; >+ } >+ def = vm->def; >+ } >+ >+ if (flags& VIR_DOMAIN_AFFECT_CONFIG) { >+ if (!vm->persistent) { >+ qemuReportError(VIR_ERR_OPERATION_INVALID, "%s", >+ _("cannot change persistent config of a transient domain")); >+ goto cleanup; >+ } >+ if (!(def = virDomainObjGetPersistentDef(driver->caps, vm))) >+ goto cleanup; >+ } Likewise, >+ >+ if ((*nparams) == 0) { >+ *nparams = QEMU_NB_BANDWIDTH_PARAM; >+ ret = 0; >+ goto cleanup; >+ } >+ >+ if ((*nparams)< QEMU_NB_BANDWIDTH_PARAM) { >+ qemuReportError(VIR_ERR_INVALID_ARG, >+ "%s", _("Invalid parameter count")); >+ goto cleanup; >+ } Should we force *nparams >= QEMU_NB_BANDWIDTH_PARAM? IMO it's not neccessary. >+ >+ if (virParseMacAddr(device, mac) == 0) >+ isMac = true; >+ >+ if (isMac) { >+ for (i = 0; i< def->nnets; i++) { >+ if (memcmp(mac, def->nets[i]->mac, VIR_MAC_BUFLEN) == 0) { >+ net = def->nets[i]; >+ break; >+ } >+ } >+ } else { /* ifname */ >+ for (i = 0; i< def->nnets; i++) { >+ if (STREQ(device, def->nets[i]->ifname)) { >+ net = def->nets[i]; >+ break; >+ } >+ } >+ } >+ >+ if (!net) { >+ qemuReportError(VIR_ERR_INVALID_ARG, >+ _("Can't find device %s"), device); >+ ret = -1; >+ goto cleanup; >+ } >+ >+ for (i = 0; i< *nparams&& i< QEMU_NB_BANDWIDTH_PARAM; i++) { >+ params[i].value.ui = 0; >+ params[i].type = VIR_TYPED_PARAM_UINT; >+ >+ switch(i) { >+ case 0: /* inbound.average */ >+ if (virStrcpyStatic(params[i].field, VIR_DOMAIN_BANDWIDTH_IN_AVERAGE) == NULL) { >+ qemuReportError(VIR_ERR_INTERNAL_ERROR, >+ _("Field name '%s' too long"), >+ VIR_DOMAIN_BANDWIDTH_IN_AVERAGE); >+ goto cleanup; >+ } >+ if (net->bandwidth&& net->bandwidth->in) >+ params[i].value.ui = net->bandwidth->in->average; >+ break; >+ case 1: /* inbound.peak */ >+ if (virStrcpyStatic(params[i].field, VIR_DOMAIN_BANDWIDTH_IN_PEAK) == NULL) { >+ qemuReportError(VIR_ERR_INTERNAL_ERROR, >+ _("Field name '%s' too long"), >+ VIR_DOMAIN_BANDWIDTH_IN_PEAK); >+ goto cleanup; >+ } >+ if (net->bandwidth&& net->bandwidth->in) >+ params[i].value.ui = net->bandwidth->in->peak; >+ break; >+ case 2: /* inbound.burst */ >+ if (virStrcpyStatic(params[i].field, VIR_DOMAIN_BANDWIDTH_IN_BURST) == NULL) { >+ qemuReportError(VIR_ERR_INTERNAL_ERROR, >+ _("Field name '%s' too long"), >+ VIR_DOMAIN_BANDWIDTH_IN_BURST); >+ goto cleanup; >+ } >+ if (net->bandwidth&& net->bandwidth->in) >+ params[i].value.ui = net->bandwidth->in->burst; >+ break; >+ case 3: /* outbound.average */ >+ if (virStrcpyStatic(params[i].field, VIR_DOMAIN_BANDWIDTH_OUT_AVERAGE) == NULL) { >+ qemuReportError(VIR_ERR_INTERNAL_ERROR, >+ _("Field name '%s' too long"), >+ VIR_DOMAIN_BANDWIDTH_OUT_AVERAGE); >+ goto cleanup; >+ } >+ if (net->bandwidth&& net->bandwidth->out) >+ params[i].value.ui = net->bandwidth->out->average; >+ break; >+ case 4: /* outbound.peak */ >+ if (virStrcpyStatic(params[i].field, VIR_DOMAIN_BANDWIDTH_OUT_PEAK) == NULL) { >+ qemuReportError(VIR_ERR_INTERNAL_ERROR, >+ _("Field name '%s' too long"), >+ VIR_DOMAIN_BANDWIDTH_OUT_PEAK); >+ goto cleanup; >+ } >+ if (net->bandwidth&& net->bandwidth->out) >+ params[i].value.ui = net->bandwidth->out->peak; >+ break; >+ case 5: /* outbound.burst */ >+ if (virStrcpyStatic(params[i].field, VIR_DOMAIN_BANDWIDTH_OUT_BURST) == NULL) { >+ qemuReportError(VIR_ERR_INTERNAL_ERROR, >+ _("Field name '%s' too long"), >+ VIR_DOMAIN_BANDWIDTH_OUT_BURST); >+ goto cleanup; >+ } >+ if (net->bandwidth&& net->bandwidth->out) >+ params[i].value.ui = net->bandwidth->out->burst; >+ break; >+ default: >+ break; >+ /* should not hit here */ >+ } >+ } >+ >+ *nparams = QEMU_NB_BANDWIDTH_PARAM; If we allow *nprams < QEMU_NB_BANDWIDTH_PARAM, this should be updated. >+ ret = 0; >+ >+cleanup: >+ if (group) >+ virCgroupFree(&group); >+ if (vm) >+ virDomainObjUnlock(vm); >+ qemuDriverUnlock(driver); >+ return ret; >+} >+ >+static int > qemudDomainMemoryStats (virDomainPtr dom, > struct _virDomainMemoryStat *stats, > unsigned int nr_stats, >@@ -11636,6 +12068,8 @@ static virDriver qemuDriver = { > .domainGetBlockIoTune = qemuDomainGetBlockIoTune, /* 0.9.8 */ > .domainSetNumaParameters = qemuDomainSetNumaParameters, /* 0.9.9 */ > .domainGetNumaParameters = qemuDomainGetNumaParameters, /* 0.9.9 */ >+ .domainGetInterfaceParameters = qemuDomainGetInterfaceParameters, /* 0.9.9 */ >+ .domainSetInterfaceParameters = qemuDomainSetInterfaceParameters, /* 0.9.9 */ > }; > > Others looks fine.

Add a new command domiftune to get/set interface parameters. * tools/virsh.c: implement the new command * tools/virsh.pod: documentation of the new command --- tools/virsh.c | 198 +++++++++++++++++++++++++++++++++++++++++++++++++++++++ tools/virsh.pod | 21 ++++++ 2 files changed, 219 insertions(+), 0 deletions(-) diff --git a/tools/virsh.c b/tools/virsh.c index 02f2e0d..d88fa95 100644 --- a/tools/virsh.c +++ b/tools/virsh.c @@ -427,6 +427,8 @@ static void *_vshCalloc(vshControl *ctl, size_t nmemb, size_t sz, const char *fi static char *_vshStrdup(vshControl *ctl, const char *s, const char *filename, int line); #define vshStrdup(_ctl, _s) _vshStrdup(_ctl, _s, __FILE__, __LINE__) +static int parseRateStr(const char *rateStr, virNetDevBandwidthRatePtr rate); + static void * _vshMalloc(vshControl *ctl, size_t size, const char *filename, int line) { @@ -1601,6 +1603,201 @@ cleanup: return ret; } +/* "domiftune" command + */ +static const vshCmdInfo info_domiftune[] = { + {"help", N_("get link state of a virtual interface")}, + {"desc", N_("Get link state of a domain's virtual interface.")}, + {NULL,NULL} +};

+ +static const vshCmdOptDef opts_domiftune[] = { + {"domain", VSH_OT_DATA, VSH_OFLAG_REQ, N_("domain name, id or uuid")}, + {"interface", VSH_OT_DATA, VSH_OFLAG_REQ, N_("interface device")}, + {"inbound", VSH_OT_DATA, VSH_OFLAG_NONE, N_("control domain's incoming traffics")}, + {"outbound", VSH_OT_DATA, VSH_OFLAG_NONE, N_("control domain's outgoing traffics")}, + {"config", VSH_OT_BOOL, VSH_OFLAG_NONE, N_("affect next boot")}, + {"live", VSH_OT_BOOL, VSH_OFLAG_NONE, N_("affect running domain")}, + {"current", VSH_OT_BOOL, VSH_OFLAG_NONE, N_("affect current domain")}, + {NULL, 0, 0, NULL} +}; + +static bool +cmdDomIftune(vshControl *ctl, const vshCmd *cmd) +{ + virDomainPtr dom; + const char *name = NULL, *device = NULL, + *inboundStr = NULL, *outboundStr = NULL; + unsigned int flags = 0; + int nparams = 0; + virTypedParameterPtr params = NULL; + bool ret = false; + int current = vshCommandOptBool(cmd, "current"); + int config = vshCommandOptBool(cmd, "config"); + int live = vshCommandOptBool(cmd, "live"); + virNetDevBandwidthRate inbound, outbound; + int i; + + if (current) { + if (live || config) { + vshError(ctl, "%s", _("--current must be specified exclusively")); + return false; + } + flags = VIR_DOMAIN_AFFECT_CURRENT; + } else { + if (config) + flags |= VIR_DOMAIN_AFFECT_CONFIG; + if (live) + flags |= VIR_DOMAIN_AFFECT_LIVE; + } + + if (!vshConnectionUsability(ctl, ctl->conn)) + return false; + + if (!(dom = vshCommandOptDomain(ctl, cmd,&name))) + return false; + + if (vshCommandOptString(cmd, "interface",&device)<= 0) { + virDomainFree(dom); + return false; + } + + if (vshCommandOptString(cmd, "inbound",&inboundStr)< 0 || + vshCommandOptString(cmd, "outbound",&outboundStr)< 0) { + vshError(ctl, "missing argument"); + goto cleanup; + } + + memset(&inbound, 0, sizeof(inbound)); + memset(&outbound, 0, sizeof(outbound)); + + if (inboundStr) { + if (parseRateStr(inboundStr,&inbound)< 0) { + vshError(ctl, _("inbound format is incorrect")); + goto cleanup; + } + if (inbound.average == 0) { + vshError(ctl, _("inbound average is mandatory")); + goto cleanup; + } + nparams++; /* average */ + if (inbound.peak) nparams++; + if (inbound.burst) nparams++; + } + if (outboundStr) { + if (parseRateStr(outboundStr,&outbound)< 0) { + vshError(ctl, _("outbound format is incorrect")); + goto cleanup; + } + if (outbound.average == 0) { + vshError(ctl, _("outbound average is mandatory")); + goto cleanup; + } + nparams++; /* average */ + if (outbound.peak) nparams++; + if (outbound.burst) nparams++; + } + + if (nparams == 0) { + /* get the number of interface parameters */ + if (virDomainGetInterfaceParameters(dom, device, NULL,&nparams, flags) != 0) { + vshError(ctl, "%s", + _("Unable to get number of interface parameters")); + goto cleanup; + } + + if (nparams == 0) { + /* nothing to output */ + ret = true; + goto cleanup; + } + + /* get all interface parameters */ + params = vshCalloc(ctl, nparams, sizeof(*params)); + if (!params) { + virReportOOMError(); + goto cleanup; + } + if (virDomainGetInterfaceParameters(dom, device, params,&nparams, flags) != 0) { + vshError(ctl, "%s", _("Unable to get interface parameters")); + goto cleanup; + } + + for (i = 0; i< nparams; i++) { + char *str = vshGetTypedParamValue(ctl,&params[i]); + vshPrint(ctl, "%-15s: %s\n", params[i].field, str); + VIR_FREE(str); + } + } else { + /* set the interface parameters */ + params = vshCalloc(ctl, nparams, sizeof(*params)); + if (!params) { + virReportOOMError(); + goto cleanup; + } + + for (i = 0; i< nparams; i++) + params[i].type = VIR_TYPED_PARAM_UINT; + + i = 0; + if (inbound.average&& i< nparams) { + if (!virStrcpy(params[i].field, VIR_DOMAIN_BANDWIDTH_IN_AVERAGE, + sizeof(params[i].field))) + goto cleanup; + params[i].value.ui = inbound.average; + i++; + } + if (inbound.peak&& i< nparams) { + if (!virStrcpy(params[i].field, VIR_DOMAIN_BANDWIDTH_IN_PEAK, + sizeof(params[i].field))) + goto cleanup; + params[i].value.ui = inbound.peak; + i++; + } + if (inbound.burst&& i< nparams) { + if (!virStrcpy(params[i].field, VIR_DOMAIN_BANDWIDTH_IN_BURST, + sizeof(params[i].field))) + goto cleanup; + params[i].value.ui = inbound.burst; + i++; + } + if (outbound.average&& i< nparams) { + if (!virStrcpy(params[i].field, VIR_DOMAIN_BANDWIDTH_OUT_AVERAGE, + sizeof(params[i].field))) + goto cleanup; + params[i].value.ui = outbound.average; + i++; + } + if (outbound.peak&& i< nparams) { + if (!virStrcpy(params[i].field, VIR_DOMAIN_BANDWIDTH_OUT_PEAK, + sizeof(params[i].field))) + goto cleanup; + params[i].value.ui = outbound.peak; + i++; + } + if (outbound.burst&& i< nparams) { + if (!virStrcpy(params[i].field, VIR_DOMAIN_BANDWIDTH_OUT_BURST, + sizeof(params[i].field))) + goto cleanup; + params[i].value.ui = outbound.burst; + i++; + } + + if (virDomainSetInterfaceParameters(dom, device, params, nparams, flags) != 0) { + vshError(ctl, "%s", _("Unable to set interface parameters")); + goto cleanup; + } + } + + ret = true; + +cleanup: + virTypedParameterArrayClear(params, nparams); + VIR_FREE(params); + virDomainFree(dom); + return ret; +} + /* * "dommemstats" command */ @@ -15589,6 +15786,7 @@ static const vshCmdDef domManagementCmds[] = { info_detach_interface, 0}, {"domid", cmdDomid, opts_domid, info_domid, 0}, {"domif-setlink", cmdDomIfSetLink, opts_domif_setlink, info_domif_setlink, 0}, + {"domiftune", cmdDomIftune, opts_domiftune, info_domiftune, 0}, {"domjobabort", cmdDomjobabort, opts_domjobabort, info_domjobabort, 0}, {"domjobinfo", cmdDomjobinfo, opts_domjobinfo, info_domjobinfo, 0}, {"domname", cmdDomname, opts_domname, info_domname, 0}, diff --git a/tools/virsh.pod b/tools/virsh.pod index 6c10245..d1c5cbe 100644 --- a/tools/virsh.pod +++ b/tools/virsh.pod @@ -554,6 +554,27 @@ configuration of the domain is modified. Query link state of the domain's virtual interface. If --persistent is specified, query the persistent configuration. +=item B<domiftune> I<domain> I<interface-device> +[[I<--config>] [I<--live>] | [I<--current>]] +[I<--inbound average,peak,burst>] +[I<--outbound average,peak,burst>] + +Set or query the domain's network interface's bandwidth parameters. +I<interface-device> can be the interface name (<target dev='name'/>),

+or the mac address if the name is not specified in xml.

+ +If no I<--inbound> or I<--outbound> is specified, this command will +query and show the bandwidth settings. Otherwise, it will set the +inbound or outbound bandwidth. I<average,peak,burst> is the same as +in command I<attach-interface>. + +If I<--live> is specified, affect a running guest. +If I<--config> is specified, affect the next boot of a persistent guest. +If I<--current> is specified, affect the current guest state. +Both I<--live> and I<--current> flags may be given, but I<--current> is +exclusive. If no flag is specified, behavior is different depending +on hypervisor. + =item B<dommemstat> I<domain> Get memory stats for a running domain.