This is however supported only on domain interfaces with type='network'. Moreover, target network needs to have at least inbound QoS set. This is required by hierarchical traffic shaping. --- docs/formatdomain.html.in | 21 ++++++++-- docs/schemas/networkcommon.rng | 5 ++ src/conf/domain_conf.c | 6 ++- src/conf/netdev_bandwidth_conf.c | 81 ++++++++++++++++++++++++++++++-------- src/conf/netdev_bandwidth_conf.h | 3 +- src/conf/network_conf.c | 4 +- src/util/virnetdevbandwidth.c | 2 +- src/util/virnetdevbandwidth.h | 1 + 8 files changed, 96 insertions(+), 27 deletions(-) diff --git a/docs/formatdomain.html.in b/docs/formatdomain.html.in index f9dbcda..2e9a8e2 100644 --- a/docs/formatdomain.html.in +++ b/docs/formatdomain.html.in @@ -2311,7 +2311,7 @@ qemu-kvm -net nic,model=? /dev/null &lt;source network='default'/&gt; &lt;target dev='vnet0'/&gt; <b>&lt;bandwidth&gt; - &lt;inbound average='1000' peak='5000' burst='1024'/&gt; + &lt;inbound average='1000' peak='5000' floor='200' burst='1024'/&gt; &lt;outbound average='128' peak='256' burst='256'/&gt; &lt;/bandwidth&gt;</b> &lt;/interface&gt; @@ -2325,15 +2325,28 @@ qemu-kvm -net nic,model=? /dev/null and at most one <code>outbound</code> child elements. Leaving any of these children element out result in no QoS applied on that traffic direction. So, when you want to shape only domain's incoming traffic, use - <code>inbound</code> only, and vice versa. Each of these elements have one - mandatory attribute <code>average</code>. It specifies average bit rate on - interface being shaped. Then there are two optional attributes: + <code>inbound</code> only, and vice versa. For <code>outbound</code> + element <code>average</code> is mandatory. However, <code>inbound</code> + can satisfied with <code>floor</code> (iff interface's type='network' and + source network has inbound shaping set) or <code>average</code> (if you + want to set at least one of <code>peak</code>, <code>burst</code>). + <code>average</code> specifies average bit rate on interface being shaped. + Then there are two optional attributes: <code>peak</code>, which specifies maximum rate at which interface can send data, and <code>burst</code>, amount of bytes that can be burst at <code>peak</code> speed. Accepted values for attributes are integer numbers. The units for <code>average</code> and <code>peak</code> attributes are kilobytes per second, and for the <code>burst</code> just kilobytes. <span class="since">Since 0.9.4</span> + <code>floor</code> attribute tells libvirt to set hierarchical classes, + so interfaces can share unused bandwidth and have guaranteed rate at + the same time. But to be able to do this, we need traffic to go through + one point which can then borrow unused bandwidth to all currently + transmitting interfaces. Therefore, it required that interface is 'network' + type and source network have inbound QoS set. Be aware, libvirt does + not check if sum of <code>floor</code> on interfaces connected to a network + does not exceed network <code>peak</code>. + <span class="since">Since 0.9.9</span> </p> <h5><a name="elementLink">Modyfing virtual link state</a></h5> diff --git a/docs/schemas/networkcommon.rng b/docs/schemas/networkcommon.rng index 3a168c3..cc1732c 100644 --- a/docs/schemas/networkcommon.rng +++ b/docs/schemas/networkcommon.rng @@ -77,6 +77,11 @@ </attribute> </optional> <optional> + <attribute name="floor"> + <ref name="speed"/> + </attribute> + </optional> + <optional> <attribute name='burst'> <ref name="BurstSize"/> </attribute> diff --git a/src/conf/domain_conf.c b/src/conf/domain_conf.c index 75e51a0..ebd0473 100644 --- a/src/conf/domain_conf.c +++ b/src/conf/domain_conf.c @@ -3370,7 +3370,8 @@ virDomainActualNetDefParseXML(xmlNodePtr node, bandwidth_node = virXPathNode("./bandwidth", ctxt); if (bandwidth_node && - !(actual->bandwidth = virNetDevBandwidthParse(bandwidth_node))) + !(actual->bandwidth = virNetDevBandwidthParse(bandwidth_node, + actual->type))) goto error; *def = actual; @@ -3528,7 +3529,8 @@ virDomainNetDefParseXML(virCapsPtr caps, if (virDomainActualNetDefParseXML(cur, ctxt, &actual) < 0) goto error; } else if (xmlStrEqual(cur->name, BAD_CAST "bandwidth")) { - if (!(def->bandwidth = virNetDevBandwidthParse(cur))) + if (!(def->bandwidth = virNetDevBandwidthParse(cur, + def->type))) goto error; } } diff --git a/src/conf/netdev_bandwidth_conf.c b/src/conf/netdev_bandwidth_conf.c index 24cd13d..21e5ac6 100644 --- a/src/conf/netdev_bandwidth_conf.c +++ b/src/conf/netdev_bandwidth_conf.c @@ -26,19 +26,28 @@ #include "virterror_internal.h" #include "util.h" #include "memory.h" +#include "domain_conf.h" #define VIR_FROM_THIS VIR_FROM_NONE #define virNetDevError(code, ...) \ virReportErrorHelper(VIR_FROM_THIS, code, __FILE__, \ __FUNCTION__, __LINE__, __VA_ARGS__) +enum virNetDevBandwidthElem { + VIR_NET_DEV_BANDWIDTH_ELEM_INBOUND, + VIR_NET_DEV_BANDWIDTH_ELEM_OUTBOUND +}; static int -virNetDevBandwidthParseRate(xmlNodePtr node, virNetDevBandwidthRatePtr rate) +virNetDevBandwidthParseRate(xmlNodePtr node, + virNetDevBandwidthRatePtr rate, + int elem_type, + int net_type) { int ret = -1; char *average = NULL; char *peak = NULL; + char *floor = NULL; char *burst = NULL; if (!node || !rate) { @@ -49,18 +58,32 @@ virNetDevBandwidthParseRate(xmlNodePtr node, virNetDevBandwidthRatePtr rate) average = virXMLPropString(node, "average"); peak = virXMLPropString(node, "peak"); + floor = virXMLPropString(node, "floor"); burst = virXMLPropString(node, "burst"); - if (average) { - if (virStrToLong_ull(average, NULL, 10, &rate->average) < 0) { - virNetDevError(VIR_ERR_CONFIG_UNSUPPORTED, - _("could not convert %s"), - average); - goto cleanup; - } - } else { + if (!average && !floor) { + virNetDevError(VIR_ERR_XML_DETAIL, "%s", + _("Missing 'average' or 'floor' attribute")); + goto cleanup; + } + + if (!average && (peak || burst)) { virNetDevError(VIR_ERR_XML_DETAIL, "%s", - _("Missing mandatory average attribute")); + _("'peak' and 'burst' require 'average' attribute")); + goto cleanup; + } + + if (floor && elem_type != VIR_NET_DEV_BANDWIDTH_ELEM_INBOUND && + net_type != VIR_DOMAIN_NET_TYPE_NETWORK) { + virNetDevError(VIR_ERR_CONFIG_UNSUPPORTED, "%s", + _("'floor' is not supported in this context")); + goto cleanup; + } + + if (average && virStrToLong_ull(average, NULL, 10, &rate->average) < 0) { + virNetDevError(VIR_ERR_CONFIG_UNSUPPORTED, + _("could not convert %s"), + average); goto cleanup; } @@ -71,6 +94,13 @@ virNetDevBandwidthParseRate(xmlNodePtr node, virNetDevBandwidthRatePtr rate) goto cleanup; } + if (floor && virStrToLong_ull(floor, NULL, 10, &rate->floor) < 0) { + virNetDevError(VIR_ERR_CONFIG_UNSUPPORTED, + _("could not convert %s"), + floor); + goto cleanup; + } + if (burst && virStrToLong_ull(burst, NULL, 10, &rate->burst) < 0) { virNetDevError(VIR_ERR_CONFIG_UNSUPPORTED, _("could not convert %s"), @@ -83,6 +113,7 @@ virNetDevBandwidthParseRate(xmlNodePtr node, virNetDevBandwidthRatePtr rate) cleanup: VIR_FREE(average); VIR_FREE(peak); + VIR_FREE(floor); VIR_FREE(burst); return ret; @@ -91,13 +122,21 @@ cleanup: /** * virNetDevBandwidthParse: * @node: XML node + * @net_type: type of network interface is connected to * - * Parse bandwidth XML and return pointer to structure + * Parse bandwidth XML and return pointer to structure. + * If interface is not connected to any network (e.g. + * it is a bridge), -1 must be passed. This is needed as + * some attributes are available only in some contexts, + * e.g. 'floor' only in + * "/domain/devices/interface[@type='network']/ + * bandwidth/inbound" * * Returns !NULL on success, NULL on error. */ virNetDevBandwidthPtr -virNetDevBandwidthParse(xmlNodePtr node) +virNetDevBandwidthParse(xmlNodePtr node, + int net_type) { virNetDevBandwidthPtr def = NULL; xmlNodePtr cur = node->children; @@ -144,7 +183,9 @@ virNetDevBandwidthParse(xmlNodePtr node) goto error; } - if (virNetDevBandwidthParseRate(in, def->in) < 0) { + if (virNetDevBandwidthParseRate(in, def->in, + VIR_NET_DEV_BANDWIDTH_ELEM_INBOUND, + net_type) < 0) { /* helper reported error for us */ goto error; } @@ -156,7 +197,9 @@ virNetDevBandwidthParse(xmlNodePtr node) goto error; } - if (virNetDevBandwidthParseRate(out, def->out) < 0) { + if (virNetDevBandwidthParseRate(out, def->out, + VIR_NET_DEV_BANDWIDTH_ELEM_OUTBOUND, + net_type) < 0) { /* helper reported error for us */ goto error; } @@ -179,13 +222,17 @@ virNetDevBandwidthRateFormat(virNetDevBandwidthRatePtr def, if (!def) return 0; - if (def->average) { - virBufferAsprintf(buf, " <%s average='%llu'", elem_name, - def->average); + if (def->average || def->floor) { + virBufferAsprintf(buf, " <%s", elem_name); + if (def->average) + virBufferAsprintf(buf, " average='%llu'", def->average); if (def->peak) virBufferAsprintf(buf, " peak='%llu'", def->peak); + if (def->floor) + virBufferAsprintf(buf, " floor='%llu'", def->floor); + if (def->burst) virBufferAsprintf(buf, " burst='%llu'", def->burst); virBufferAddLit(buf, "/>\n"); diff --git a/src/conf/netdev_bandwidth_conf.h b/src/conf/netdev_bandwidth_conf.h index 4bb7def..8ad6176 100644 --- a/src/conf/netdev_bandwidth_conf.h +++ b/src/conf/netdev_bandwidth_conf.h @@ -28,7 +28,8 @@ # include "buf.h" # include "xml.h" -virNetDevBandwidthPtr virNetDevBandwidthParse(xmlNodePtr node) +virNetDevBandwidthPtr virNetDevBandwidthParse(xmlNodePtr node, + int net_type) ATTRIBUTE_NONNULL(1) ATTRIBUTE_RETURN_CHECK; int virNetDevBandwidthFormat(virNetDevBandwidthPtr def, virBufferPtr buf) diff --git a/src/conf/network_conf.c b/src/conf/network_conf.c index 1058b07..949cea8 100644 --- a/src/conf/network_conf.c +++ b/src/conf/network_conf.c @@ -796,7 +796,7 @@ virNetworkPortGroupParseXML(virPortGroupDefPtr def, bandwidth_node = virXPathNode("./bandwidth", ctxt); if (bandwidth_node && - !(def->bandwidth = virNetDevBandwidthParse(bandwidth_node))) { + !(def->bandwidth = virNetDevBandwidthParse(bandwidth_node, -1))) { goto error; } @@ -862,7 +862,7 @@ virNetworkDefParseXML(xmlXPathContextPtr ctxt) def->domain = virXPathString("string(./domain[1]/@name)", ctxt); if ((bandwidthNode = virXPathNode("./bandwidth", ctxt)) != NULL && - (def->bandwidth = virNetDevBandwidthParse(bandwidthNode)) == NULL) + (def->bandwidth = virNetDevBandwidthParse(bandwidthNode, -1)) == NULL) goto error; /* Parse bridge information */ diff --git a/src/util/virnetdevbandwidth.c b/src/util/virnetdevbandwidth.c index b9bd2e3..d23d600 100644 --- a/src/util/virnetdevbandwidth.c +++ b/src/util/virnetdevbandwidth.c @@ -72,7 +72,7 @@ virNetDevBandwidthSet(const char *ifname, ignore_value(virNetDevBandwidthClear(ifname)); - if (bandwidth->in) { + if (bandwidth->in && bandwidth->in->average) { if (virAsprintf(&average, "%llukbps", bandwidth->in->average) < 0) goto cleanup; if (bandwidth->in->peak && diff --git a/src/util/virnetdevbandwidth.h b/src/util/virnetdevbandwidth.h index 58decff..8551caa 100644 --- a/src/util/virnetdevbandwidth.h +++ b/src/util/virnetdevbandwidth.h @@ -30,6 +30,7 @@ typedef virNetDevBandwidthRate *virNetDevBandwidthRatePtr; struct _virNetDevBandwidthRate { unsigned long long average; /* kbytes/s */ unsigned long long peak; /* kbytes/s */ + unsigned long long floor; /* kbytes/s */ unsigned long long burst; /* kbytes */ }; -- 1.7.3.4

These set bridge part of QoS when bringing domain's interface up. --- po/POTFILES.in | 1 + src/util/virnetdevbandwidth.c | 177 +++++++++++++++++++++++++++++++++++++++++ src/util/virnetdevbandwidth.h | 14 +++ 3 files changed, 192 insertions(+), 0 deletions(-) diff --git a/po/POTFILES.in b/po/POTFILES.in index 3e8359a..edac362 100644 --- a/po/POTFILES.in +++ b/po/POTFILES.in @@ -126,6 +126,7 @@ src/util/util.c src/util/viraudit.c src/util/virfile.c src/util/virnetdev.c +src/util/virnetdevbandwidth.c src/util/virnetdevbridge.c src/util/virnetdevmacvlan.c src/util/virnetdevtap.c diff --git a/src/util/virnetdevbandwidth.c b/src/util/virnetdevbandwidth.c index ac3a93d..2d7e156 100644 --- a/src/util/virnetdevbandwidth.c +++ b/src/util/virnetdevbandwidth.c @@ -27,6 +27,7 @@ #include "memory.h" #include "virterror_internal.h" #include "ignore-value.h" +#include "logging.h" #define VIR_FROM_THIS VIR_FROM_NONE @@ -167,6 +168,182 @@ cleanup: return ret; } +/* + * virNetDevBandwidthPlug: + * @brname: name of the bridge + * @net_bandwidth: QoS settings on @brname + * @ifname: interface being plugged into @brname + * @ifmac: MAC of @ifname + * @bandwidth: QoS settings for @ifname + * @id: unique ID (MUST be greater than 2) + * + * Set bridge part of interface QoS settings, + * e.g. guaranteed bandwidth. + * @id is an unique ID (among @brname) from which + * other identifiers for class, qdisc and filter + * are derived. However, two classes were already + * set up (by virNetDevBandwidthSet). That's why + * this @id MUST be greater than 2. + * You may want to keep passed @id, as it is used + * later by virNetDevBandwidthUnplug. + * + * Returns: + * 1 if there is nothing to set + * 0 if QoS set successfully + * -1 otherwise. + */ +int +virNetDevBandwidthPlug(const char *brname, + virNetDevBandwidthPtr net_bandwidth, + const char *ifname, + unsigned const char *ifmac, + virNetDevBandwidthPtr bandwidth, + unsigned int id) +{ + int ret = -1; + virCommandPtr cmd = NULL; + char *class_id = NULL; + char *qdisc_id = NULL; + char *filter_id = NULL; + char *floor = NULL; + char *ceil = NULL; + char *mac[2]; + + if (!bandwidth || !bandwidth->in || !bandwidth->in->floor) { + /* nothing to set */ + return 1; + } + + if (!net_bandwidth || !net_bandwidth->in) { + VIR_ERROR(_("Bridge '%s' has no QoS set, " + "therefore unable to set 'floor' on '%s'"), + brname, ifname); + return -1; + } + + if (virAsprintf(&class_id, "1:%x", id) < 0 || + virAsprintf(&qdisc_id, "%x:", id) < 0 || + virAsprintf(&filter_id, "%u", id) < 0 || + virAsprintf(&mac[0], "0x%02x%02x%02x%02x", ifmac[2], + ifmac[3], ifmac[4], ifmac[5]) < 0 || + virAsprintf(&mac[1], "0x%02x%02x", ifmac[0], ifmac[1]) < 0 || + virAsprintf(&floor, "%llukbps", bandwidth->in->floor) < 0 || + virAsprintf(&ceil, "%llukbps", net_bandwidth->in->peak ? : + net_bandwidth->in->average) < 0) { + virReportOOMError(); + goto cleanup; + } + + cmd = virCommandNew(TC); + virCommandAddArgList(cmd, "class", "add", "dev", brname, "parent", "1:1", + "classid", class_id, "htb", "rate", floor, + "ceil", ceil, NULL); + + if (virCommandRun(cmd, NULL) < 0) + goto cleanup; + + virCommandFree(cmd); + cmd = virCommandNew(TC); + virCommandAddArgList(cmd, "qdisc", "add", "dev", brname, "parent", + class_id, "handle", qdisc_id, "sfq", "perturb", + "10", NULL); + + if (virCommandRun(cmd, NULL) < 0) + goto cleanup; + + virCommandFree(cmd); + cmd = virCommandNew(TC); + /* Okay, this not nice. But since libvirt does not know anything + * about interface IP address(es), and tc fw filter simply + * refuse to use ebtables marks, we need to use u32 selector + * to match MAC address. + * If libvirt will ever know something, remove this FIXME + */ + virCommandAddArgList(cmd, "filter", "add", "dev", brname, "protocol", "ip", + "prio", filter_id, "u32", + "match", "u16", "0x0800", "0xffff", "at", "-2", + "match", "u32", mac[0], "0xffffffff", "at", "-12", + "match", "u16", mac[1], "0xffff", "at", "-14", + "flowid", class_id, NULL); + + if (virCommandRun(cmd, NULL) < 0) + goto cleanup; + + ret = 0; + +cleanup: + VIR_FREE(ceil); + VIR_FREE(floor); + VIR_FREE(mac[1]); + VIR_FREE(mac[0]); + VIR_FREE(filter_id); + VIR_FREE(qdisc_id); + VIR_FREE(class_id); + virCommandFree(cmd); + return ret; +} + +/* + * virNetDevBandwidthUnplug: + * @brname: from which bridge are we unplugging + * @id: unique identifier (MUST be greater than 2) + * + * Remove QoS settings from bridge. + * + * Returns 0 on success, -1 otherwise. + */ +int +virNetDevBandwidthUnplug(const char *brname, + unsigned int id) +{ + int ret = -1; + int cmd_ret = 0; + virCommandPtr cmd = NULL; + char *class_id = NULL; + char *qdisc_id = NULL; + char *filter_id = NULL; + + if (virAsprintf(&class_id, "1:%x", id) < 0 || + virAsprintf(&qdisc_id, "%x:", id) < 0 || + virAsprintf(&filter_id, "%u", id) < 0) { + virReportOOMError(); + goto cleanup; + } + + cmd = virCommandNew(TC); + virCommandAddArgList(cmd, "qdisc", "del", "dev", brname, + "handle", qdisc_id, NULL); + + /* Don't threat tc errors as fatal, but + * try to remove as much as possible */ + if (virCommandRun(cmd, &cmd_ret) < 0) + goto cleanup; + + virCommandFree(cmd); + cmd = virCommandNew(TC); + virCommandAddArgList(cmd, "filter", "del", "dev", brname, + "prio", filter_id, NULL); + + if (virCommandRun(cmd, &cmd_ret) < 0) + goto cleanup; + + cmd = virCommandNew(TC); + virCommandAddArgList(cmd, "class", "del", "dev", brname, + "classid", class_id, NULL); + + if (virCommandRun(cmd, &cmd_ret) < 0) + goto cleanup; + + ret = 0; + +cleanup: + VIR_FREE(filter_id); + VIR_FREE(qdisc_id); + VIR_FREE(class_id); + virCommandFree(cmd); + return ret; +} + /** * virNetDevBandwidthClear: * @ifname: on which interface diff --git a/src/util/virnetdevbandwidth.h b/src/util/virnetdevbandwidth.h index 1e7d46d..c1bec45 100644 --- a/src/util/virnetdevbandwidth.h +++ b/src/util/virnetdevbandwidth.h @@ -53,4 +53,18 @@ int virNetDevBandwidthCopy(virNetDevBandwidthPtr *dest, const virNetDevBandwidth bool virNetDevBandwidthEqual(virNetDevBandwidthPtr a, virNetDevBandwidthPtr b); + +int virNetDevBandwidthPlug(const char *brname, + virNetDevBandwidthPtr net_bandwidth, + const char *ifname, + unsigned const char *ifmac, + virNetDevBandwidthPtr bandwidth, + unsigned int id) + ATTRIBUTE_NONNULL(1) ATTRIBUTE_NONNULL(2) + ATTRIBUTE_RETURN_CHECK; + +int virNetDevBandwidthUnplug(const char *brname, + unsigned int id) + ATTRIBUTE_NONNULL(1) ATTRIBUTE_RETURN_CHECK; + #endif /* __VIR_NETDEV_BANDWIDTH_H__ */ -- 1.7.3.4

Like we keep domain status file to keep some internal data during daemon restart, now it is needed for network as well. Because network has now class_id attribute which is hidden from users and thus not part of network XML. --- daemon/libvirtd.c | 3 + src/conf/network_conf.c | 215 ++++++++++++++++++++++++++++++++++++------- src/conf/network_conf.h | 7 ++ src/libvirt_private.syms | 2 + src/network/bridge_driver.c | 33 +++++-- 5 files changed, 219 insertions(+), 41 deletions(-) diff --git a/daemon/libvirtd.c b/daemon/libvirtd.c index d7a03d7..d7a6288 100644 --- a/daemon/libvirtd.c +++ b/daemon/libvirtd.c @@ -1586,6 +1586,9 @@ int main(int argc, char **argv) { 0, "shutdown", NULL); cleanup: + /* Notify drivers we are about to quit, + * so they can save their stuff */ + virStateCleanup(); virNetServerProgramFree(remoteProgram); virNetServerProgramFree(qemuProgram); virNetServerClose(srv); diff --git a/src/conf/network_conf.c b/src/conf/network_conf.c index df6da3c..4219f7c 100644 --- a/src/conf/network_conf.c +++ b/src/conf/network_conf.c @@ -1130,6 +1130,99 @@ cleanup: } static int +virNetworkObjParseXML(virNetworkObjPtr obj, + xmlDocPtr xml ATTRIBUTE_UNUSED, + xmlXPathContextPtr ctxt) +{ + int ret = -1; + xmlNodePtr config; + char *class_id = NULL; + + if ((config = virXPathNode("./network", ctxt))) { + xmlNodePtr oldnode; + virNetworkDefPtr tmp_def; + + oldnode = ctxt->node; + ctxt->node = config; + tmp_def = virNetworkDefParseXML(ctxt); + ctxt->node = oldnode; + + if (tmp_def) { + obj->newDef = obj->def; + obj->def = tmp_def; + } else { + goto cleanup; + } + } + + if ((class_id=virXPathString("string(./class_id[1]/@next)", ctxt))) { + if (virStrToLong_ui(class_id, NULL, 10, &obj->class_id) < 0) { + virNetworkReportError(VIR_ERR_XML_ERROR, + _("Malformed class_id attribute: %s"), + class_id); + goto cleanup; + } + } + + ret = 0; + +cleanup: + VIR_FREE(class_id); + return ret; +} + +static int +virNetworkObjParseNode(virNetworkObjPtr obj, + xmlDocPtr xml, + xmlNodePtr root) +{ + int ret = -1; + xmlXPathContextPtr ctxt = NULL; + + if (!xmlStrEqual(root->name, BAD_CAST "networkstatus")) { + virNetworkReportError(VIR_ERR_XML_ERROR, + _("unexpected root element <%s>, " + "expecting <networkstatus>"), + root->name); + return -1; + } + + if (!(ctxt = xmlXPathNewContext(xml))) { + virReportOOMError(); + goto cleanup; + } + + ctxt->node = root; + ret = virNetworkObjParseXML(obj, xml, ctxt); + +cleanup: + xmlXPathFreeContext(ctxt); + return ret; +} + +static int +virNetworkObjParseFile(virNetworkObjPtr obj, + const char *filename) +{ + int ret = -1; + xmlDocPtr xml; + + if ((xml = virXMLParseFile(filename))) { + ret = virNetworkObjParseNode(obj, xml, xmlDocGetRootElement(xml)); + xmlFreeDoc(xml); + } + + return ret; +} + +int +virNetworkObjUpdateStatus(virNetworkObjPtr net, + const char *filename) +{ + return virNetworkObjParseFile(net, filename); +} + +static int virNetworkDNSDefFormat(virBufferPtr buf, virNetworkDNSDefPtr def) { @@ -1276,19 +1369,19 @@ virPortGroupDefFormat(virBufferPtr buf, return 0; } -char *virNetworkDefFormat(const virNetworkDefPtr def) +static int +virNetworkDefFormatInternal(virBufferPtr buf, const virNetworkDefPtr def) { - virBuffer buf = VIR_BUFFER_INITIALIZER; unsigned char *uuid; char uuidstr[VIR_UUID_STRING_BUFLEN]; int ii; - virBufferAddLit(&buf, "<network>\n"); - virBufferEscapeString(&buf, " <name>%s</name>\n", def->name); + virBufferAddLit(buf, "<network>\n"); + virBufferEscapeString(buf, " <name>%s</name>\n", def->name); uuid = def->uuid; virUUIDFormat(uuid, uuidstr); - virBufferAsprintf(&buf, " <uuid>%s</uuid>\n", uuidstr); + virBufferAsprintf(buf, " <uuid>%s</uuid>\n", uuidstr); if (def->forwardType != VIR_NETWORK_FORWARD_NONE) { const char *dev = virNetworkDefForwardIf(def, 0); @@ -1300,20 +1393,20 @@ char *virNetworkDefFormat(const virNetworkDefPtr def) def->forwardType, def->name); goto error; } - virBufferAddLit(&buf, " <forward"); + virBufferAddLit(buf, " <forward"); if (dev) - virBufferEscapeString(&buf, " dev='%s'", dev); - virBufferAsprintf(&buf, " mode='%s'%s>\n", mode, + virBufferEscapeString(buf, " dev='%s'", dev); + virBufferAsprintf(buf, " mode='%s'%s>\n", mode, def->nForwardIfs ? "" : "/"); if (def->nForwardIfs) { for (ii = 0; ii < def->nForwardIfs; ii++) { if (def->forwardIfs[ii].dev) { - virBufferEscapeString(&buf, " <interface dev='%s'/>\n", + virBufferEscapeString(buf, " <interface dev='%s'/>\n", def->forwardIfs[ii].dev); } } - virBufferAddLit(&buf, " </forward>\n"); + virBufferAddLit(buf, " </forward>\n"); } } @@ -1321,61 +1414,72 @@ char *virNetworkDefFormat(const virNetworkDefPtr def) def->forwardType == VIR_NETWORK_FORWARD_NAT || def->forwardType == VIR_NETWORK_FORWARD_ROUTE) { - virBufferAddLit(&buf, " <bridge"); + virBufferAddLit(buf, " <bridge"); if (def->bridge) - virBufferEscapeString(&buf, " name='%s'", def->bridge); - virBufferAsprintf(&buf, " stp='%s' delay='%ld' />\n", + virBufferEscapeString(buf, " name='%s'", def->bridge); + virBufferAsprintf(buf, " stp='%s' delay='%ld' />\n", def->stp ? "on" : "off", def->delay); } else if (def->forwardType == VIR_NETWORK_FORWARD_BRIDGE && def->bridge) { - virBufferEscapeString(&buf, " <bridge name='%s' />\n", def->bridge); + virBufferEscapeString(buf, " <bridge name='%s' />\n", def->bridge); } if (def->mac_specified) { char macaddr[VIR_MAC_STRING_BUFLEN]; virFormatMacAddr(def->mac, macaddr); - virBufferAsprintf(&buf, " <mac address='%s'/>\n", macaddr); + virBufferAsprintf(buf, " <mac address='%s'/>\n", macaddr); } if (def->domain) - virBufferAsprintf(&buf, " <domain name='%s'/>\n", def->domain); + virBufferAsprintf(buf, " <domain name='%s'/>\n", def->domain); - if (virNetworkDNSDefFormat(&buf, def->dns) < 0) + if (virNetworkDNSDefFormat(buf, def->dns) < 0) goto error; - virBufferAdjustIndent(&buf, 2); - if (virNetDevBandwidthFormat(def->bandwidth, &buf) < 0) + virBufferAdjustIndent(buf, 2); + if (virNetDevBandwidthFormat(def->bandwidth, buf) < 0) goto error; - virBufferAdjustIndent(&buf, -2); + virBufferAdjustIndent(buf, -2); for (ii = 0; ii < def->nips; ii++) { - if (virNetworkIpDefFormat(&buf, &def->ips[ii]) < 0) + if (virNetworkIpDefFormat(buf, &def->ips[ii]) < 0) goto error; } - virBufferAdjustIndent(&buf, 2); - if (virNetDevVPortProfileFormat(def->virtPortProfile, &buf) < 0) + virBufferAdjustIndent(buf, 2); + if (virNetDevVPortProfileFormat(def->virtPortProfile, buf) < 0) goto error; - virBufferAdjustIndent(&buf, -2); + virBufferAdjustIndent(buf, -2); for (ii = 0; ii < def->nPortGroups; ii++) - if (virPortGroupDefFormat(&buf, &def->portGroups[ii]) < 0) + if (virPortGroupDefFormat(buf, &def->portGroups[ii]) < 0) goto error; - virBufferAddLit(&buf, "</network>\n"); + virBufferAddLit(buf, "</network>\n"); - if (virBufferError(&buf)) + if (virBufferError(buf)) goto no_memory; - return virBufferContentAndReset(&buf); + return 0; - no_memory: +no_memory: virReportOOMError(); - error: - virBufferFreeAndReset(&buf); - return NULL; +error: + return -1; +} + +char *virNetworkDefFormat(const virNetworkDefPtr def) +{ + virBuffer buf = VIR_BUFFER_INITIALIZER; + + if (virNetworkDefFormatInternal(&buf, def) < 0) { + virBufferFreeAndReset(&buf); + return NULL; + } + + return virBufferContentAndReset(&buf); } virPortGroupDefPtr virPortGroupFindByName(virNetworkDefPtr net, @@ -1394,6 +1498,34 @@ virPortGroupDefPtr virPortGroupFindByName(virNetworkDefPtr net, return NULL; } +static char * +virNetworkObjFormat(virNetworkObjPtr obj) +{ + virBuffer buf = VIR_BUFFER_INITIALIZER; + + virBufferAddLit(&buf, "<networkstatus>\n"); + if (obj->class_id) + virBufferAsprintf(&buf, " <class_id next='%u'/>\n", obj->class_id); + + virBufferAdjustIndent(&buf, 2); + if (virNetworkDefFormatInternal(&buf, obj->def) < 0) + goto error; + virBufferAdjustIndent(&buf, -2); + + virBufferAddLit(&buf, "</networkstatus>\n"); + + if (virBufferError(&buf)) + goto no_memory; + + return virBufferContentAndReset(&buf); + +no_memory: + virReportOOMError(); +error: + virBufferFreeAndReset(&buf); + return NULL; +} + int virNetworkSaveXML(const char *configDir, virNetworkDefPtr def, const char *xml) @@ -1418,6 +1550,24 @@ int virNetworkSaveXML(const char *configDir, return ret; } +int virNetworkSaveObj(const char *configDir, + virNetworkObjPtr net) +{ + int ret = -1; + char *xml; + + if (!(xml = virNetworkObjFormat(net))) + goto cleanup; + + if (virNetworkSaveXML(configDir, net->def, xml)) + goto cleanup; + + ret = 0; +cleanup: + VIR_FREE(xml); + return ret; +} + int virNetworkSaveConfig(const char *configDir, virNetworkDefPtr def) { @@ -1436,7 +1586,6 @@ cleanup: return ret; } - virNetworkObjPtr virNetworkLoadConfig(virNetworkObjListPtr nets, const char *configDir, const char *autostartDir, diff --git a/src/conf/network_conf.h b/src/conf/network_conf.h index 2e49dc6..3c58da5 100644 --- a/src/conf/network_conf.h +++ b/src/conf/network_conf.h @@ -236,11 +236,18 @@ int virNetworkSaveXML(const char *configDir, int virNetworkSaveConfig(const char *configDir, virNetworkDefPtr def); +int virNetworkSaveObj(const char *configDir, + virNetworkObjPtr net); + virNetworkObjPtr virNetworkLoadConfig(virNetworkObjListPtr nets, const char *configDir, const char *autostartDir, const char *file); +int virNetworkObjUpdateStatus(virNetworkObjPtr net, + const char *filename) + ATTRIBUTE_NONNULL(1); + int virNetworkLoadAllConfigs(virNetworkObjListPtr nets, const char *configDir, const char *autostartDir); diff --git a/src/libvirt_private.syms b/src/libvirt_private.syms index a81c230..bcb7b27 100644 --- a/src/libvirt_private.syms +++ b/src/libvirt_private.syms @@ -771,8 +771,10 @@ virNetworkObjIsDuplicate; virNetworkObjListFree; virNetworkObjLock; virNetworkObjUnlock; +virNetworkObjUpdateStatus; virNetworkRemoveInactive; virNetworkSaveConfig; +virNetworkSaveObj; virNetworkSetBridgeMacAddr; virNetworkSetBridgeName; virPortGroupFindByName; diff --git a/src/network/bridge_driver.c b/src/network/bridge_driver.c index 527b52e..d7e7220 100644 --- a/src/network/bridge_driver.c +++ b/src/network/bridge_driver.c @@ -184,7 +184,6 @@ networkFindActiveConfigs(struct network_driver *driver) { for (i = 0 ; i < driver->networks.count ; i++) { virNetworkObjPtr obj = driver->networks.objs[i]; - virNetworkDefPtr tmp; char *config; virNetworkObjLock(obj); @@ -201,13 +200,12 @@ networkFindActiveConfigs(struct network_driver *driver) { continue; } - /* Try and load the live config */ - tmp = virNetworkDefParseFile(config); - VIR_FREE(config); - if (tmp) { - obj->newDef = obj->def; - obj->def = tmp; + /* Try to update the live config */ + if (virNetworkObjUpdateStatus(obj, config) < 0) { + VIR_WARN("Unable to update config on '%s' network", + obj->def->name); } + VIR_FREE(config); /* If bridge exists, then mark it active */ if (obj->def->bridge && @@ -396,11 +394,25 @@ networkActive(void) { */ static int networkShutdown(void) { + unsigned int i; + if (!driverState) return -1; networkDriverLock(driverState); + for (i = 0; i < driverState->networks.count; i++) { + virNetworkObjPtr obj = driverState->networks.objs[i]; + + if (!virNetworkObjIsActive(obj)) + continue; + + if (virNetworkSaveObj(NETWORK_STATE_DIR, obj) < 0) { + VIR_WARN("Unable to save network '%s'", + obj->def->name); + } + } + /* free inactive networks */ virNetworkObjListFree(&driverState->networks); @@ -1939,7 +1951,7 @@ networkStartNetwork(struct network_driver *driver, /* Persist the live configuration now that anything autogenerated * is setup. */ - if ((ret = virNetworkSaveConfig(NETWORK_STATE_DIR, network->def)) < 0) { + if ((ret = virNetworkSaveObj(NETWORK_STATE_DIR, network)) < 0) { goto error; } @@ -3202,6 +3214,11 @@ networkNotifyPlug(virNetworkPtr net, network->class_id++; } + if (virNetworkSaveObj(NETWORK_STATE_DIR, network) < 0) { + VIR_WARN("Unable to save network '%s'", + network->def->name); + } + ret = 0; cleanup: -- 1.7.3.4