network: Rework networkGetDHCPLeases()

Firstly, bring variables that are used only within loops into
their respective loops. Secondly, drop 'error' label which is
redundant since we have @rv which holds the return value.
Thirdly, fix indendation in one case, the rest is indented
properly.

Signed-off-by: Michal Privoznik <mprivozn@redhat.com>
Reviewed-by: Daniel P. Berrangé <berrange@redhat.com>
This commit is contained in:
Michal Privoznik 2020-12-18 16:09:14 +01:00
parent ee93656c40
commit 5fb6d98c88

View File

@ -4031,22 +4031,16 @@ networkGetDHCPLeases(virNetworkPtr net,
unsigned int flags) unsigned int flags)
{ {
virNetworkDriverStatePtr driver = networkGetDriver(); virNetworkDriverStatePtr driver = networkGetDriver();
size_t i, j; size_t i;
size_t nleases = 0; size_t nleases = 0;
int rv = -1; int rv = -1;
size_t size = 0; size_t size = 0;
bool need_results = !!leases; bool need_results = !!leases;
long long currtime = 0; long long currtime = 0;
long long expirytime_tmp = -1;
bool ipv6 = false;
g_autofree char *lease_entries = NULL; g_autofree char *lease_entries = NULL;
g_autofree char *custom_lease_file = NULL; g_autofree char *custom_lease_file = NULL;
const char *ip_tmp = NULL;
const char *mac_tmp = NULL;
virJSONValuePtr lease_tmp = NULL;
g_autoptr(virJSONValue) leases_array = NULL; g_autoptr(virJSONValue) leases_array = NULL;
virNetworkIPDefPtr ipdef_tmp = NULL; g_autofree virNetworkDHCPLeasePtr *leases_ret = NULL;
virNetworkDHCPLeasePtr *leases_ret = NULL;
virNetworkObjPtr obj; virNetworkObjPtr obj;
virNetworkDefPtr def; virNetworkDefPtr def;
virMacAddr mac_addr; virMacAddr mac_addr;
@ -4084,34 +4078,38 @@ networkGetDHCPLeases(virNetworkPtr net,
_("Unable to read leases file: %s"), _("Unable to read leases file: %s"),
custom_lease_file); custom_lease_file);
} }
goto error; goto cleanup;
} }
if (STREQ(lease_entries, "")) { if (STREQ(lease_entries, "")) {
rv = 0; rv = 0;
goto error; goto cleanup;
} }
if (!(leases_array = virJSONValueFromString(lease_entries))) { if (!(leases_array = virJSONValueFromString(lease_entries))) {
virReportError(VIR_ERR_INTERNAL_ERROR, virReportError(VIR_ERR_INTERNAL_ERROR,
_("invalid json in file: %s"), custom_lease_file); _("invalid json in file: %s"), custom_lease_file);
goto error; goto cleanup;
} }
if (!virJSONValueIsArray(leases_array)) { if (!virJSONValueIsArray(leases_array)) {
virReportError(VIR_ERR_INTERNAL_ERROR, "%s", virReportError(VIR_ERR_INTERNAL_ERROR, "%s",
_("Malformed lease_entries array")); _("Malformed lease_entries array"));
goto error; goto cleanup;
} }
size = virJSONValueArraySize(leases_array); size = virJSONValueArraySize(leases_array);
currtime = (long long)time(NULL); currtime = (long long)time(NULL);
for (i = 0; i < size; i++) { for (i = 0; i < size; i++) {
if (!(lease_tmp = virJSONValueArrayGet(leases_array, i))) { virJSONValuePtr lease_tmp = virJSONValueArrayGet(leases_array, i);
long long expirytime_tmp = -1;
const char *mac_tmp = NULL;
if (!lease_tmp) {
virReportError(VIR_ERR_INTERNAL_ERROR, "%s", virReportError(VIR_ERR_INTERNAL_ERROR, "%s",
_("failed to parse json")); _("failed to parse json"));
goto error; goto cleanup;
} }
if (!(mac_tmp = virJSONValueObjectGetString(lease_tmp, "mac-address"))) { if (!(mac_tmp = virJSONValueObjectGetString(lease_tmp, "mac-address"))) {
@ -4119,7 +4117,7 @@ networkGetDHCPLeases(virNetworkPtr net,
* mac-address is known otherwise not */ * mac-address is known otherwise not */
virReportError(VIR_ERR_INTERNAL_ERROR, "%s", virReportError(VIR_ERR_INTERNAL_ERROR, "%s",
_("found lease without mac-address")); _("found lease without mac-address"));
goto error; goto cleanup;
} }
if (mac && virMacAddrCompare(mac, mac_tmp)) if (mac && virMacAddrCompare(mac, mac_tmp))
@ -4129,7 +4127,7 @@ networkGetDHCPLeases(virNetworkPtr net,
/* A lease cannot be present without expiry-time */ /* A lease cannot be present without expiry-time */
virReportError(VIR_ERR_INTERNAL_ERROR, "%s", virReportError(VIR_ERR_INTERNAL_ERROR, "%s",
_("found lease without expiry-time")); _("found lease without expiry-time"));
goto error; goto cleanup;
} }
/* Do not report expired lease */ /* Do not report expired lease */
@ -4138,6 +4136,9 @@ networkGetDHCPLeases(virNetworkPtr net,
if (need_results) { if (need_results) {
g_autoptr(virNetworkDHCPLease) lease = g_new0(virNetworkDHCPLease, 1); g_autoptr(virNetworkDHCPLease) lease = g_new0(virNetworkDHCPLease, 1);
const char *ip_tmp = NULL;
bool ipv6 = false;
size_t j;
lease->expirytime = expirytime_tmp; lease->expirytime = expirytime_tmp;
@ -4145,7 +4146,7 @@ networkGetDHCPLeases(virNetworkPtr net,
/* A lease without ip-address makes no sense */ /* A lease without ip-address makes no sense */
virReportError(VIR_ERR_INTERNAL_ERROR, "%s", virReportError(VIR_ERR_INTERNAL_ERROR, "%s",
_("found lease without ip-address")); _("found lease without ip-address"));
goto error; goto cleanup;
} }
/* Unlike IPv4, IPv6 uses ':' instead of '.' as separator */ /* Unlike IPv4, IPv6 uses ':' instead of '.' as separator */
@ -4154,7 +4155,7 @@ networkGetDHCPLeases(virNetworkPtr net,
/* Obtain prefix */ /* Obtain prefix */
for (j = 0; j < def->nips; j++) { for (j = 0; j < def->nips; j++) {
ipdef_tmp = &def->ips[j]; virNetworkIPDefPtr ipdef_tmp = ipdef_tmp = &def->ips[j];
if (ipv6 && VIR_SOCKET_ADDR_IS_FAMILY(&ipdef_tmp->address, if (ipv6 && VIR_SOCKET_ADDR_IS_FAMILY(&ipdef_tmp->address,
AF_INET6)) { AF_INET6)) {
@ -4162,7 +4163,7 @@ networkGetDHCPLeases(virNetworkPtr net,
break; break;
} }
if (!ipv6 && VIR_SOCKET_ADDR_IS_FAMILY(&ipdef_tmp->address, if (!ipv6 && VIR_SOCKET_ADDR_IS_FAMILY(&ipdef_tmp->address,
AF_INET)) { AF_INET)) {
lease->prefix = virSocketAddrGetIPPrefix(&ipdef_tmp->address, lease->prefix = virSocketAddrGetIPPrefix(&ipdef_tmp->address,
&ipdef_tmp->netmask, &ipdef_tmp->netmask,
ipdef_tmp->prefix); ipdef_tmp->prefix);
@ -4180,7 +4181,7 @@ networkGetDHCPLeases(virNetworkPtr net,
lease->hostname = g_strdup(virJSONValueObjectGetString(lease_tmp, "hostname")); lease->hostname = g_strdup(virJSONValueObjectGetString(lease_tmp, "hostname"));
if (VIR_APPEND_ELEMENT(leases_ret, nleases, lease) < 0) if (VIR_APPEND_ELEMENT(leases_ret, nleases, lease) < 0)
goto error; goto cleanup;
} else { } else {
nleases++; nleases++;
@ -4197,15 +4198,11 @@ networkGetDHCPLeases(virNetworkPtr net,
cleanup: cleanup:
virNetworkObjEndAPI(&obj); virNetworkObjEndAPI(&obj);
return rv;
error:
if (leases_ret) { if (leases_ret) {
for (i = 0; i < nleases; i++) for (i = 0; i < nleases; i++)
virNetworkDHCPLeaseFree(leases_ret[i]); virNetworkDHCPLeaseFree(leases_ret[i]);
g_free(leases_ret);
} }
goto cleanup; return rv;
} }