1
0
mirror of https://gitlab.com/libvirt/libvirt.git synced 2025-01-06 17:17:56 +03:00

network: eliminate unnecessary labels

All these cleanup/error labels were reduced to having just "return
ret" by a previous patch, so get rid of them and return directly.

This patch coincidentally fixes a bug in
networkFindUnusedBridgeName(), where we would log an error yet still
return success if we failed to find a single unused "virbrNNN" name
after checking all values of "N" from 0 - 256. Said bug was introduced
when that function was originally written, in commit a28d3e485f
(libvirt 1.2.15, 2015)

Signed-off-by: Laine Stump <laine@redhat.com>
Reviewed-by: Ján Tomko <jtomko@redhat.com>
This commit is contained in:
Laine Stump 2020-07-03 23:51:27 -04:00
parent b32b2746ad
commit f931c85fb0
2 changed files with 109 additions and 159 deletions

View File

@ -197,18 +197,14 @@ networkDnsmasqDefNamespaceParse(xmlXPathContextPtr ctxt,
void **data) void **data)
{ {
g_autoptr(networkDnsmasqXmlNsDef) nsdata = g_new0(networkDnsmasqXmlNsDef, 1); g_autoptr(networkDnsmasqXmlNsDef) nsdata = g_new0(networkDnsmasqXmlNsDef, 1);
int ret = -1;
if (networkDnsmasqDefNamespaceParseOptions(nsdata, ctxt)) if (networkDnsmasqDefNamespaceParseOptions(nsdata, ctxt))
goto cleanup; return -1;
if (nsdata->noptions > 0) if (nsdata->noptions > 0)
*data = g_steal_pointer(&nsdata); *data = g_steal_pointer(&nsdata);
ret = 0; return 0;
cleanup:
return ret;
} }
@ -331,22 +327,20 @@ networkRunHook(virNetworkObjPtr obj,
g_auto(virBuffer) buf = VIR_BUFFER_INITIALIZER; g_auto(virBuffer) buf = VIR_BUFFER_INITIALIZER;
g_autofree char *xml = NULL; g_autofree char *xml = NULL;
int hookret; int hookret;
int ret = -1;
if (virHookPresent(VIR_HOOK_DRIVER_NETWORK)) { if (virHookPresent(VIR_HOOK_DRIVER_NETWORK)) {
if (!obj) { if (!obj) {
VIR_DEBUG("Not running hook as @obj is NULL"); VIR_DEBUG("Not running hook as @obj is NULL");
ret = 0; return 0;
goto cleanup;
} }
def = virNetworkObjGetDef(obj); def = virNetworkObjGetDef(obj);
virBufferAddLit(&buf, "<hookData>\n"); virBufferAddLit(&buf, "<hookData>\n");
virBufferAdjustIndent(&buf, 2); virBufferAdjustIndent(&buf, 2);
if (virNetworkDefFormatBuf(&buf, def, network_driver->xmlopt, 0) < 0) if (virNetworkDefFormatBuf(&buf, def, network_driver->xmlopt, 0) < 0)
goto cleanup; return -1;
if (port && virNetworkPortDefFormatBuf(&buf, port) < 0) if (port && virNetworkPortDefFormatBuf(&buf, port) < 0)
goto cleanup; return -1;
virBufferAdjustIndent(&buf, -2); virBufferAdjustIndent(&buf, -2);
virBufferAddLit(&buf, "</hookData>"); virBufferAddLit(&buf, "</hookData>");
@ -359,14 +353,12 @@ networkRunHook(virNetworkObjPtr obj,
* If the script raised an error, pass it to the callee. * If the script raised an error, pass it to the callee.
*/ */
if (hookret < 0) if (hookret < 0)
goto cleanup; return -1;
networkNetworkObjTaint(obj, VIR_NETWORK_TAINT_HOOK); networkNetworkObjTaint(obj, VIR_NETWORK_TAINT_HOOK);
} }
ret = 0; return 0;
cleanup:
return ret;
} }
@ -440,34 +432,32 @@ networkRemoveInactive(virNetworkDriverStatePtr driver,
g_autoptr(dnsmasqContext) dctx = NULL; g_autoptr(dnsmasqContext) dctx = NULL;
virNetworkDefPtr def = virNetworkObjGetPersistentDef(obj); virNetworkDefPtr def = virNetworkObjGetPersistentDef(obj);
int ret = -1;
/* remove the (possibly) existing dnsmasq and radvd files */ /* remove the (possibly) existing dnsmasq and radvd files */
if (!(dctx = dnsmasqContextNew(def->name, if (!(dctx = dnsmasqContextNew(def->name,
driver->dnsmasqStateDir))) { driver->dnsmasqStateDir))) {
goto cleanup; return -1;
} }
if (!(leasefile = networkDnsmasqLeaseFileNameDefault(driver, def->name))) if (!(leasefile = networkDnsmasqLeaseFileNameDefault(driver, def->name)))
goto cleanup; return -1;
if (!(customleasefile = networkDnsmasqLeaseFileNameCustom(driver, def->bridge))) if (!(customleasefile = networkDnsmasqLeaseFileNameCustom(driver, def->bridge)))
goto cleanup; return -1;
if (!(radvdconfigfile = networkRadvdConfigFileName(driver, def->name))) if (!(radvdconfigfile = networkRadvdConfigFileName(driver, def->name)))
goto cleanup; return -1;
if (!(radvdpidbase = networkRadvdPidfileBasename(def->name))) if (!(radvdpidbase = networkRadvdPidfileBasename(def->name)))
goto cleanup; return -1;
if (!(configfile = networkDnsmasqConfigFileName(driver, def->name))) if (!(configfile = networkDnsmasqConfigFileName(driver, def->name)))
goto cleanup; return -1;
if (!(statusfile = virNetworkConfigFile(driver->stateDir, def->name))) if (!(statusfile = virNetworkConfigFile(driver->stateDir, def->name)))
goto cleanup; return -1;
if (!(macMapFile = virMacMapFileName(driver->dnsmasqStateDir, def->bridge))) if (!(macMapFile = virMacMapFileName(driver->dnsmasqStateDir, def->bridge)))
goto cleanup; return -1;
/* dnsmasq */ /* dnsmasq */
dnsmasqDelete(dctx); dnsmasqDelete(dctx);
@ -488,10 +478,7 @@ networkRemoveInactive(virNetworkDriverStatePtr driver,
/* remove the network definition */ /* remove the network definition */
virNetworkObjRemoveInactive(driver->networks, obj); virNetworkObjRemoveInactive(driver->networks, obj);
ret = 0; return 0;
cleanup:
return ret;
} }
@ -703,7 +690,6 @@ networkStateInitialize(bool privileged,
virStateInhibitCallback callback G_GNUC_UNUSED, virStateInhibitCallback callback G_GNUC_UNUSED,
void *opaque G_GNUC_UNUSED) void *opaque G_GNUC_UNUSED)
{ {
int ret = VIR_DRV_STATE_INIT_ERROR;
g_autofree char *configdir = NULL; g_autofree char *configdir = NULL;
g_autofree char *rundir = NULL; g_autofree char *rundir = NULL;
bool autostart = true; bool autostart = true;
@ -831,13 +817,12 @@ networkStateInitialize(bool privileged,
} }
#endif #endif
ret = VIR_DRV_STATE_INIT_COMPLETE; return VIR_DRV_STATE_INIT_COMPLETE;
cleanup:
return ret;
error: error:
networkStateCleanup(); networkStateCleanup();
goto cleanup; return VIR_DRV_STATE_INIT_ERROR;
} }
@ -1074,7 +1059,7 @@ networkDnsmasqConfContents(virNetworkObjPtr obj,
{ {
virNetworkDefPtr def = virNetworkObjGetDef(obj); virNetworkDefPtr def = virNetworkObjGetDef(obj);
g_auto(virBuffer) configbuf = VIR_BUFFER_INITIALIZER; g_auto(virBuffer) configbuf = VIR_BUFFER_INITIALIZER;
int r, ret = -1; int r;
int nbleases = 0; int nbleases = 0;
size_t i; size_t i;
virNetworkDNSDefPtr dns = &def->dns; virNetworkDNSDefPtr dns = &def->dns;
@ -1138,7 +1123,7 @@ networkDnsmasqConfContents(virNetworkObjPtr obj,
g_autofree char *addr = virSocketAddrFormat(&fwd->addr); g_autofree char *addr = virSocketAddrFormat(&fwd->addr);
if (!addr) if (!addr)
goto cleanup; return -1;
virBufferAsprintf(&configbuf, "%s\n", addr); virBufferAsprintf(&configbuf, "%s\n", addr);
if (!fwd->domain) if (!fwd->domain)
addNoResolv = true; addNoResolv = true;
@ -1165,7 +1150,7 @@ networkDnsmasqConfContents(virNetworkObjPtr obj,
if (wantDNS && if (wantDNS &&
networkDnsmasqConfLocalPTRs(&configbuf, def) < 0) networkDnsmasqConfLocalPTRs(&configbuf, def) < 0)
goto cleanup; return -1;
if (wantDNS && def->dns.forwardPlainNames == VIR_TRISTATE_BOOL_NO) { if (wantDNS && def->dns.forwardPlainNames == VIR_TRISTATE_BOOL_NO) {
virBufferAddLit(&configbuf, "domain-needed\n"); virBufferAddLit(&configbuf, "domain-needed\n");
@ -1215,7 +1200,7 @@ networkDnsmasqConfContents(virNetworkObjPtr obj,
g_autofree char *ipaddr = virSocketAddrFormat(&tmpipdef->address); g_autofree char *ipaddr = virSocketAddrFormat(&tmpipdef->address);
if (!ipaddr) if (!ipaddr)
goto cleanup; return -1;
/* also part of CVE 2012-3411 - if the host's version of /* also part of CVE 2012-3411 - if the host's version of
* dnsmasq doesn't have bind-dynamic, only allow listening on * dnsmasq doesn't have bind-dynamic, only allow listening on
@ -1238,7 +1223,7 @@ networkDnsmasqConfContents(virNetworkObjPtr obj,
"(as described in RFC1918/RFC3484/RFC4193)."), "(as described in RFC1918/RFC3484/RFC4193)."),
ipaddr, (int)version / 1000000, ipaddr, (int)version / 1000000,
(int)(version % 1000000) / 1000); (int)(version % 1000000) / 1000);
goto cleanup; return -1;
} }
virBufferAsprintf(&configbuf, "listen-address=%s\n", ipaddr); virBufferAsprintf(&configbuf, "listen-address=%s\n", ipaddr);
} }
@ -1279,14 +1264,14 @@ networkDnsmasqConfContents(virNetworkObjPtr obj,
_("Missing required 'service' " _("Missing required 'service' "
"attribute in SRV record of network '%s'"), "attribute in SRV record of network '%s'"),
def->name); def->name);
goto cleanup; return -1;
} }
if (!dns->srvs[i].protocol) { if (!dns->srvs[i].protocol) {
virReportError(VIR_ERR_INTERNAL_ERROR, virReportError(VIR_ERR_INTERNAL_ERROR,
_("Missing required 'service' " _("Missing required 'service' "
"attribute in SRV record of network '%s'"), "attribute in SRV record of network '%s'"),
def->name); def->name);
goto cleanup; return -1;
} }
/* RFC2782 requires that service and protocol be preceded by /* RFC2782 requires that service and protocol be preceded by
* an underscore. * an underscore.
@ -1335,7 +1320,7 @@ networkDnsmasqConfContents(virNetworkObjPtr obj,
virReportError(VIR_ERR_CONFIG_UNSUPPORTED, "%s", virReportError(VIR_ERR_CONFIG_UNSUPPORTED, "%s",
_("For IPv4, multiple DHCP definitions " _("For IPv4, multiple DHCP definitions "
"cannot be specified.")); "cannot be specified."));
goto cleanup; return -1;
} else { } else {
ipv4def = ipdef; ipv4def = ipdef;
} }
@ -1355,13 +1340,13 @@ networkDnsmasqConfContents(virNetworkObjPtr obj,
(int)(version % 1000000) / 1000, (int)(version % 1000000) / 1000,
DNSMASQ_DHCPv6_MAJOR_REQD, DNSMASQ_DHCPv6_MAJOR_REQD,
DNSMASQ_DHCPv6_MINOR_REQD); DNSMASQ_DHCPv6_MINOR_REQD);
goto cleanup; return -1;
} }
if (ipv6def) { if (ipv6def) {
virReportError(VIR_ERR_CONFIG_UNSUPPORTED, "%s", virReportError(VIR_ERR_CONFIG_UNSUPPORTED, "%s",
_("For IPv6, multiple DHCP definitions " _("For IPv6, multiple DHCP definitions "
"cannot be specified.")); "cannot be specified."));
goto cleanup; return -1;
} else { } else {
ipv6def = ipdef; ipv6def = ipdef;
} }
@ -1390,7 +1375,7 @@ networkDnsmasqConfContents(virNetworkObjPtr obj,
virReportError(VIR_ERR_INTERNAL_ERROR, virReportError(VIR_ERR_INTERNAL_ERROR,
_("bridge '%s' has an invalid prefix"), _("bridge '%s' has an invalid prefix"),
def->bridge); def->bridge);
goto cleanup; return -1;
} }
for (r = 0; r < ipdef->nranges; r++) { for (r = 0; r < ipdef->nranges; r++) {
int thisRange; int thisRange;
@ -1401,7 +1386,7 @@ networkDnsmasqConfContents(virNetworkObjPtr obj,
if (!(saddr = virSocketAddrFormat(&range.addr.start)) || if (!(saddr = virSocketAddrFormat(&range.addr.start)) ||
!(eaddr = virSocketAddrFormat(&range.addr.end))) !(eaddr = virSocketAddrFormat(&range.addr.end)))
goto cleanup; return -1;
if (VIR_SOCKET_ADDR_IS_FAMILY(&ipdef->address, AF_INET6)) { if (VIR_SOCKET_ADDR_IS_FAMILY(&ipdef->address, AF_INET6)) {
virBufferAsprintf(&configbuf, "dhcp-range=%s,%s,%d", virBufferAsprintf(&configbuf, "dhcp-range=%s,%s,%d",
@ -1416,11 +1401,11 @@ networkDnsmasqConfContents(virNetworkObjPtr obj,
_("Failed to translate bridge '%s' " _("Failed to translate bridge '%s' "
"prefix %d to netmask"), "prefix %d to netmask"),
def->bridge, prefix); def->bridge, prefix);
goto cleanup; return -1;
} }
if (!(netmaskStr = virSocketAddrFormat(&netmask))) if (!(netmaskStr = virSocketAddrFormat(&netmask)))
goto cleanup; return -1;
virBufferAsprintf(&configbuf, "dhcp-range=%s,%s,%s", virBufferAsprintf(&configbuf, "dhcp-range=%s,%s,%s",
saddr, eaddr, netmaskStr); saddr, eaddr, netmaskStr);
} }
@ -1435,7 +1420,7 @@ networkDnsmasqConfContents(virNetworkObjPtr obj,
&ipdef->address, &ipdef->address,
virNetworkIPDefPrefix(ipdef)); virNetworkIPDefPrefix(ipdef));
if (thisRange < 0) if (thisRange < 0)
goto cleanup; return -1;
nbleases += thisRange; nbleases += thisRange;
} }
@ -1448,7 +1433,7 @@ networkDnsmasqConfContents(virNetworkObjPtr obj,
if (!ipdef->nranges && ipdef->nhosts) { if (!ipdef->nranges && ipdef->nhosts) {
g_autofree char *bridgeaddr = virSocketAddrFormat(&ipdef->address); g_autofree char *bridgeaddr = virSocketAddrFormat(&ipdef->address);
if (!bridgeaddr) if (!bridgeaddr)
goto cleanup; return -1;
virBufferAsprintf(&configbuf, "dhcp-range=%s,static", virBufferAsprintf(&configbuf, "dhcp-range=%s,static",
bridgeaddr); bridgeaddr);
if (VIR_SOCKET_ADDR_IS_FAMILY(&ipdef->address, AF_INET6)) if (VIR_SOCKET_ADDR_IS_FAMILY(&ipdef->address, AF_INET6))
@ -1457,7 +1442,7 @@ networkDnsmasqConfContents(virNetworkObjPtr obj,
} }
if (networkBuildDnsmasqDhcpHostsList(dctx, ipdef) < 0) if (networkBuildDnsmasqDhcpHostsList(dctx, ipdef) < 0)
goto cleanup; return -1;
/* Note: the following is IPv4 only */ /* Note: the following is IPv4 only */
if (VIR_SOCKET_ADDR_IS_FAMILY(&ipdef->address, AF_INET)) { if (VIR_SOCKET_ADDR_IS_FAMILY(&ipdef->address, AF_INET)) {
@ -1476,7 +1461,7 @@ networkDnsmasqConfContents(virNetworkObjPtr obj,
g_autofree char *bootserver = virSocketAddrFormat(&ipdef->bootserver); g_autofree char *bootserver = virSocketAddrFormat(&ipdef->bootserver);
if (!bootserver) if (!bootserver)
goto cleanup; return -1;
virBufferAsprintf(&configbuf, "dhcp-boot=%s%s%s\n", virBufferAsprintf(&configbuf, "dhcp-boot=%s%s%s\n",
ipdef->bootfile, ",,", bootserver); ipdef->bootfile, ",,", bootserver);
} else { } else {
@ -1492,7 +1477,7 @@ networkDnsmasqConfContents(virNetworkObjPtr obj,
/* this is done once per interface */ /* this is done once per interface */
if (networkBuildDnsmasqHostsList(dctx, dns) < 0) if (networkBuildDnsmasqHostsList(dctx, dns) < 0)
goto cleanup; return -1;
/* Even if there are currently no static hosts, if we're /* Even if there are currently no static hosts, if we're
* listening for DHCP, we should write a 0-length hosts * listening for DHCP, we should write a 0-length hosts
@ -1525,7 +1510,7 @@ networkDnsmasqConfContents(virNetworkObjPtr obj,
if (!(ipdef->nranges || ipdef->nhosts)) { if (!(ipdef->nranges || ipdef->nhosts)) {
g_autofree char *bridgeaddr = virSocketAddrFormat(&ipdef->address); g_autofree char *bridgeaddr = virSocketAddrFormat(&ipdef->address);
if (!bridgeaddr) if (!bridgeaddr)
goto cleanup; return -1;
virBufferAsprintf(&configbuf, virBufferAsprintf(&configbuf,
"dhcp-range=%s,ra-only\n", bridgeaddr); "dhcp-range=%s,ra-only\n", bridgeaddr);
} }
@ -1540,15 +1525,12 @@ networkDnsmasqConfContents(virNetworkObjPtr obj,
} }
if (!(*configstr = virBufferContentAndReset(&configbuf))) if (!(*configstr = virBufferContentAndReset(&configbuf)))
goto cleanup; return -1;
*hostsfilestr = dnsmasqDhcpHostsToString(dctx->hostsfile->hosts, *hostsfilestr = dnsmasqDhcpHostsToString(dctx->hostsfile->hosts,
dctx->hostsfile->nhosts); dctx->hostsfile->nhosts);
ret = 0; return 0;
cleanup:
return ret;
} }
@ -1563,7 +1545,6 @@ networkBuildDhcpDaemonCommandLine(virNetworkDriverStatePtr driver,
virNetworkDefPtr def = virNetworkObjGetDef(obj); virNetworkDefPtr def = virNetworkObjGetDef(obj);
g_autoptr(dnsmasqCaps) dnsmasq_caps = networkGetDnsmasqCaps(driver); g_autoptr(dnsmasqCaps) dnsmasq_caps = networkGetDnsmasqCaps(driver);
g_autoptr(virCommand) cmd = NULL; g_autoptr(virCommand) cmd = NULL;
int ret = -1;
g_autofree char *configfile = NULL; g_autofree char *configfile = NULL;
g_autofree char *configstr = NULL; g_autofree char *configstr = NULL;
g_autofree char *hostsfilestr = NULL; g_autofree char *hostsfilestr = NULL;
@ -1573,27 +1554,27 @@ networkBuildDhcpDaemonCommandLine(virNetworkDriverStatePtr driver,
if (networkDnsmasqConfContents(obj, pidfile, &configstr, &hostsfilestr, if (networkDnsmasqConfContents(obj, pidfile, &configstr, &hostsfilestr,
dctx, dnsmasq_caps) < 0) dctx, dnsmasq_caps) < 0)
goto cleanup; return -1;
if (!configstr) if (!configstr)
goto cleanup; return -1;
/* construct the filename */ /* construct the filename */
if (!(configfile = networkDnsmasqConfigFileName(driver, def->name))) if (!(configfile = networkDnsmasqConfigFileName(driver, def->name)))
goto cleanup; return -1;
/* Write the file */ /* Write the file */
if (virFileWriteStr(configfile, configstr, 0600) < 0) { if (virFileWriteStr(configfile, configstr, 0600) < 0) {
virReportSystemError(errno, virReportSystemError(errno,
_("couldn't write dnsmasq config file '%s'"), _("couldn't write dnsmasq config file '%s'"),
configfile); configfile);
goto cleanup; return -1;
} }
/* This helper is used to create custom leases file for libvirt */ /* This helper is used to create custom leases file for libvirt */
if (!(leaseshelper_path = virFileFindResource("libvirt_leaseshelper", if (!(leaseshelper_path = virFileFindResource("libvirt_leaseshelper",
abs_top_builddir "/src", abs_top_builddir "/src",
LIBEXECDIR))) LIBEXECDIR)))
goto cleanup; return -1;
cmd = virCommandNew(dnsmasqCapsGetBinaryPath(dnsmasq_caps)); cmd = virCommandNew(dnsmasqCapsGetBinaryPath(dnsmasq_caps));
virCommandAddArgFormat(cmd, "--conf-file=%s", configfile); virCommandAddArgFormat(cmd, "--conf-file=%s", configfile);
@ -1603,9 +1584,7 @@ networkBuildDhcpDaemonCommandLine(virNetworkDriverStatePtr driver,
virCommandAddEnvPair(cmd, "VIR_BRIDGE_NAME", def->bridge); virCommandAddEnvPair(cmd, "VIR_BRIDGE_NAME", def->bridge);
*cmdout = g_steal_pointer(&cmd); *cmdout = g_steal_pointer(&cmd);
ret = 0; return 0;
cleanup:
return ret;
} }
@ -1620,7 +1599,6 @@ networkStartDhcpDaemon(virNetworkDriverStatePtr driver,
g_autoptr(virCommand) cmd = NULL; g_autoptr(virCommand) cmd = NULL;
g_autofree char *pidfile = NULL; g_autofree char *pidfile = NULL;
pid_t dnsmasqPid; pid_t dnsmasqPid;
int ret = -1;
g_autoptr(dnsmasqContext) dctx = NULL; g_autoptr(dnsmasqContext) dctx = NULL;
/* see if there are any IP addresses that need a dhcp server */ /* see if there are any IP addresses that need a dhcp server */
@ -1631,53 +1609,46 @@ networkStartDhcpDaemon(virNetworkDriverStatePtr driver,
needDnsmasq = true; needDnsmasq = true;
} }
if (i == 0) { /* no IP addresses at all, so we don't need to run */
/* no IP addresses at all, so we don't need to run */ if (i == 0)
ret = 0; return 0;
goto cleanup;
}
if (!needDnsmasq && def->dns.enable == VIR_TRISTATE_BOOL_NO) { /* no DHCP services needed, and user disabled DNS service */
/* no DHCP services needed, and user disabled DNS service */ if (!needDnsmasq && def->dns.enable == VIR_TRISTATE_BOOL_NO)
ret = 0; return 0;
goto cleanup;
}
if (virFileMakePath(driver->pidDir) < 0) { if (virFileMakePath(driver->pidDir) < 0) {
virReportSystemError(errno, virReportSystemError(errno,
_("cannot create directory %s"), _("cannot create directory %s"),
driver->pidDir); driver->pidDir);
goto cleanup; return -1;
} }
if (!(pidfile = virPidFileBuildPath(driver->pidDir, def->name))) if (!(pidfile = virPidFileBuildPath(driver->pidDir, def->name)))
goto cleanup; return -1;
if (virFileMakePath(driver->dnsmasqStateDir) < 0) { if (virFileMakePath(driver->dnsmasqStateDir) < 0) {
virReportSystemError(errno, virReportSystemError(errno,
_("cannot create directory %s"), _("cannot create directory %s"),
driver->dnsmasqStateDir); driver->dnsmasqStateDir);
goto cleanup; return -1;
} }
dctx = dnsmasqContextNew(def->name, driver->dnsmasqStateDir); dctx = dnsmasqContextNew(def->name, driver->dnsmasqStateDir);
if (dctx == NULL) if (dctx == NULL)
goto cleanup; return -1;
if (networkDnsmasqCapsRefresh(driver) < 0) if (networkDnsmasqCapsRefresh(driver) < 0)
goto cleanup; return -1;
ret = networkBuildDhcpDaemonCommandLine(driver, obj, &cmd, pidfile, dctx); if (networkBuildDhcpDaemonCommandLine(driver, obj, &cmd, pidfile, dctx) < 0)
if (ret < 0) return -1;
goto cleanup;
ret = dnsmasqSave(dctx); if (dnsmasqSave(dctx) < 0)
if (ret < 0) return -1;
goto cleanup;
ret = virCommandRun(cmd, NULL); if (virCommandRun(cmd, NULL) < 0)
if (ret < 0) return -1;
goto cleanup;
/* /*
* There really is no race here - when dnsmasq daemonizes, its * There really is no race here - when dnsmasq daemonizes, its
@ -1687,14 +1658,12 @@ networkStartDhcpDaemon(virNetworkDriverStatePtr driver,
* pid * pid
*/ */
ret = virPidFileRead(driver->pidDir, def->name, &dnsmasqPid); if (virPidFileRead(driver->pidDir, def->name, &dnsmasqPid) < 0)
if (ret < 0) return -1;
goto cleanup;
virNetworkObjSetDnsmasqPid(obj, dnsmasqPid); virNetworkObjSetDnsmasqPid(obj, dnsmasqPid);
ret = 0; return 0;
cleanup:
return ret;
} }
@ -1710,7 +1679,6 @@ networkRefreshDhcpDaemon(virNetworkDriverStatePtr driver,
virNetworkObjPtr obj) virNetworkObjPtr obj)
{ {
virNetworkDefPtr def = virNetworkObjGetDef(obj); virNetworkDefPtr def = virNetworkObjGetDef(obj);
int ret = -1;
size_t i; size_t i;
pid_t dnsmasqPid; pid_t dnsmasqPid;
virNetworkIPDefPtr ipdef, ipv4def, ipv6def; virNetworkIPDefPtr ipdef, ipv4def, ipv6def;
@ -1726,10 +1694,8 @@ networkRefreshDhcpDaemon(virNetworkDriverStatePtr driver,
return networkStartDhcpDaemon(driver, obj); return networkStartDhcpDaemon(driver, obj);
VIR_INFO("Refreshing dnsmasq for network %s", def->bridge); VIR_INFO("Refreshing dnsmasq for network %s", def->bridge);
if (!(dctx = dnsmasqContextNew(def->name, if (!(dctx = dnsmasqContextNew(def->name, driver->dnsmasqStateDir)))
driver->dnsmasqStateDir))) { return -1;
goto cleanup;
}
/* Look for first IPv4 address that has dhcp defined. /* Look for first IPv4 address that has dhcp defined.
* We only support dhcp-host config on one IPv4 subnetwork * We only support dhcp-host config on one IPv4 subnetwork
@ -1752,21 +1718,20 @@ networkRefreshDhcpDaemon(virNetworkDriverStatePtr driver,
} }
if (ipv4def && (networkBuildDnsmasqDhcpHostsList(dctx, ipv4def) < 0)) if (ipv4def && (networkBuildDnsmasqDhcpHostsList(dctx, ipv4def) < 0))
goto cleanup; return -1;
if (ipv6def && (networkBuildDnsmasqDhcpHostsList(dctx, ipv6def) < 0)) if (ipv6def && (networkBuildDnsmasqDhcpHostsList(dctx, ipv6def) < 0))
goto cleanup; return -1;
if (networkBuildDnsmasqHostsList(dctx, &def->dns) < 0) if (networkBuildDnsmasqHostsList(dctx, &def->dns) < 0)
goto cleanup; return -1;
if ((ret = dnsmasqSave(dctx)) < 0) if (dnsmasqSave(dctx) < 0)
goto cleanup; return -1;
dnsmasqPid = virNetworkObjGetDnsmasqPid(obj); dnsmasqPid = virNetworkObjGetDnsmasqPid(obj);
ret = kill(dnsmasqPid, SIGHUP); return kill(dnsmasqPid, SIGHUP);
cleanup:
return ret;
} }
@ -1874,7 +1839,6 @@ networkRadvdConfWrite(virNetworkDriverStatePtr driver,
char **configFile) char **configFile)
{ {
virNetworkDefPtr def = virNetworkObjGetDef(obj); virNetworkDefPtr def = virNetworkObjGetDef(obj);
int ret = -1;
g_autofree char *configStr = NULL; g_autofree char *configStr = NULL;
g_autofree char *myConfigFile = NULL; g_autofree char *myConfigFile = NULL;
@ -1884,27 +1848,24 @@ networkRadvdConfWrite(virNetworkDriverStatePtr driver,
*configFile = NULL; *configFile = NULL;
if (networkRadvdConfContents(obj, &configStr) < 0) if (networkRadvdConfContents(obj, &configStr) < 0)
goto cleanup; return -1;
if (!configStr) { if (!configStr)
ret = 0; return 0;
goto cleanup;
}
/* construct the filename */ /* construct the filename */
if (!(*configFile = networkRadvdConfigFileName(driver, def->name))) if (!(*configFile = networkRadvdConfigFileName(driver, def->name)))
goto cleanup; return -1;
/* write the file */ /* write the file */
if (virFileWriteStr(*configFile, configStr, 0600) < 0) { if (virFileWriteStr(*configFile, configStr, 0600) < 0) {
virReportSystemError(errno, virReportSystemError(errno,
_("couldn't write radvd config file '%s'"), _("couldn't write radvd config file '%s'"),
*configFile); *configFile);
goto cleanup; return -1;
} }
ret = 0; return 0;
cleanup:
return ret;
} }
@ -1919,20 +1880,16 @@ networkStartRadvd(virNetworkDriverStatePtr driver,
g_autofree char *radvdpidbase = NULL; g_autofree char *radvdpidbase = NULL;
g_autofree char *configfile = NULL; g_autofree char *configfile = NULL;
g_autoptr(virCommand) cmd = NULL; g_autoptr(virCommand) cmd = NULL;
int ret = -1;
virNetworkObjSetRadvdPid(obj, -1); virNetworkObjSetRadvdPid(obj, -1);
/* Is dnsmasq handling RA? */ /* Is dnsmasq handling RA? */
if (DNSMASQ_RA_SUPPORT(dnsmasq_caps)) { if (DNSMASQ_RA_SUPPORT(dnsmasq_caps))
ret = 0; return 0;
goto cleanup;
}
if (!virNetworkDefGetIPByIndex(def, AF_INET6, 0)) { if (!virNetworkDefGetIPByIndex(def, AF_INET6, 0)) {
/* no IPv6 addresses, so we don't need to run radvd */ /* no IPv6 addresses, so we don't need to run radvd */
ret = 0; return 0;
goto cleanup;
} }
if (!virFileIsExecutable(RADVD)) { if (!virFileIsExecutable(RADVD)) {
@ -1940,30 +1897,32 @@ networkStartRadvd(virNetworkDriverStatePtr driver,
_("Cannot find %s - " _("Cannot find %s - "
"Possibly the package isn't installed"), "Possibly the package isn't installed"),
RADVD); RADVD);
goto cleanup; return -1;
} }
if (virFileMakePath(driver->pidDir) < 0) { if (virFileMakePath(driver->pidDir) < 0) {
virReportSystemError(errno, virReportSystemError(errno,
_("cannot create directory %s"), _("cannot create directory %s"),
driver->pidDir); driver->pidDir);
goto cleanup; return -1;
} }
if (virFileMakePath(driver->radvdStateDir) < 0) { if (virFileMakePath(driver->radvdStateDir) < 0) {
virReportSystemError(errno, virReportSystemError(errno,
_("cannot create directory %s"), _("cannot create directory %s"),
driver->radvdStateDir); driver->radvdStateDir);
goto cleanup; return -1;
} }
/* construct pidfile name */ /* construct pidfile name */
if (!(radvdpidbase = networkRadvdPidfileBasename(def->name))) if (!(radvdpidbase = networkRadvdPidfileBasename(def->name)))
goto cleanup; return -1;
if (!(pidfile = virPidFileBuildPath(driver->pidDir, radvdpidbase))) if (!(pidfile = virPidFileBuildPath(driver->pidDir, radvdpidbase)))
goto cleanup; return -1;
if (networkRadvdConfWrite(driver, obj, &configfile) < 0) if (networkRadvdConfWrite(driver, obj, &configfile) < 0)
goto cleanup; return -1;
/* prevent radvd from daemonizing itself with "--debug 1", and use /* prevent radvd from daemonizing itself with "--debug 1", and use
* a dummy pidfile name - virCommand will create the pidfile we * a dummy pidfile name - virCommand will create the pidfile we
@ -1983,15 +1942,13 @@ networkStartRadvd(virNetworkDriverStatePtr driver,
virCommandDaemonize(cmd); virCommandDaemonize(cmd);
if (virCommandRun(cmd, NULL) < 0) if (virCommandRun(cmd, NULL) < 0)
goto cleanup; return -1;
if (virPidFileRead(driver->pidDir, radvdpidbase, &radvdPid) < 0) if (virPidFileRead(driver->pidDir, radvdpidbase, &radvdPid) < 0)
goto cleanup; return -1;
virNetworkObjSetRadvdPid(obj, radvdPid);
ret = 0; virNetworkObjSetRadvdPid(obj, radvdPid);
cleanup: return 0;
return ret;
} }
@ -2221,8 +2178,7 @@ networkSetIPv6Sysctls(virNetworkObjPtr obj)
if (!enableIPv6) if (!enableIPv6)
VIR_DEBUG("ipv6 appears to already be disabled on %s", VIR_DEBUG("ipv6 appears to already be disabled on %s",
def->bridge); def->bridge);
ret = 0; return 0;
goto cleanup;
} }
if (virFileWriteStr(field, enableIPv6 ? "0" : "1", 0) < 0) { if (virFileWriteStr(field, enableIPv6 ? "0" : "1", 0) < 0) {
@ -3191,7 +3147,7 @@ static int
networkFindUnusedBridgeName(virNetworkObjListPtr nets, networkFindUnusedBridgeName(virNetworkObjListPtr nets,
virNetworkDefPtr def) virNetworkDefPtr def)
{ {
int ret = -1, id = 0; int id = 0;
const char *templ = "virbr%d"; const char *templ = "virbr%d";
const char *p; const char *p;
@ -3212,17 +3168,14 @@ networkFindUnusedBridgeName(virNetworkObjListPtr nets,
virNetDevExists(newname) == 1)) { virNetDevExists(newname) == 1)) {
VIR_FREE(def->bridge); /*could contain template */ VIR_FREE(def->bridge); /*could contain template */
def->bridge = g_steal_pointer(&newname); def->bridge = g_steal_pointer(&newname);
ret = 0; return 0;
goto cleanup;
} }
} while (++id <= MAX_BRIDGE_ID); } while (++id <= MAX_BRIDGE_ID);
virReportError(VIR_ERR_INTERNAL_ERROR, virReportError(VIR_ERR_INTERNAL_ERROR,
_("Bridge generation exceeded max id %d"), _("Bridge generation exceeded max id %d"),
MAX_BRIDGE_ID); MAX_BRIDGE_ID);
ret = 0; return -1;
cleanup:
return ret;
} }

View File

@ -217,7 +217,7 @@ void networkPostReloadFirewallRules(bool startup G_GNUC_UNUSED)
*/ */
int networkCheckRouteCollision(virNetworkDefPtr def) int networkCheckRouteCollision(virNetworkDefPtr def)
{ {
int ret = 0, len; int len;
char *cur; char *cur;
g_autofree char *buf = NULL; g_autofree char *buf = NULL;
/* allow for up to 100000 routes (each line is 128 bytes) */ /* allow for up to 100000 routes (each line is 128 bytes) */
@ -225,7 +225,7 @@ int networkCheckRouteCollision(virNetworkDefPtr def)
/* Read whole routing table into memory */ /* Read whole routing table into memory */
if ((len = virFileReadAll(PROC_NET_ROUTE, MAX_ROUTE_SIZE, &buf)) < 0) if ((len = virFileReadAll(PROC_NET_ROUTE, MAX_ROUTE_SIZE, &buf)) < 0)
goto out; return 0;
/* Dropping the last character shouldn't hurt */ /* Dropping the last character shouldn't hurt */
if (len > 0) if (len > 0)
@ -234,7 +234,7 @@ int networkCheckRouteCollision(virNetworkDefPtr def)
VIR_DEBUG("%s output:\n%s", PROC_NET_ROUTE, buf); VIR_DEBUG("%s output:\n%s", PROC_NET_ROUTE, buf);
if (!STRPREFIX(buf, "Iface")) if (!STRPREFIX(buf, "Iface"))
goto out; return 0;
/* First line is just headings, skip it */ /* First line is just headings, skip it */
cur = strchr(buf, '\n'); cur = strchr(buf, '\n');
@ -296,8 +296,7 @@ int networkCheckRouteCollision(virNetworkDefPtr def)
virReportError(VIR_ERR_INTERNAL_ERROR, virReportError(VIR_ERR_INTERNAL_ERROR,
_("Network is already in use by interface %s"), _("Network is already in use by interface %s"),
iface); iface);
ret = -1; return -1;
goto out;
} }
} }
@ -323,14 +322,12 @@ int networkCheckRouteCollision(virNetworkDefPtr def)
_("Route address '%s' conflicts " _("Route address '%s' conflicts "
"with IP address for '%s'"), "with IP address for '%s'"),
NULLSTR(addr_str), iface); NULLSTR(addr_str), iface);
ret = -1; return -1;
goto out;
} }
} }
} }
out: return 0;
return ret;
} }
static const char networkLocalMulticastIPv4[] = "224.0.0.0/24"; static const char networkLocalMulticastIPv4[] = "224.0.0.0/24";