tree-wide: use set_ensure_consume() in various places

No funtional change.

diff --git a/src/network/networkd-ndisc.c b/src/network/networkd-ndisc.c
index beeb34375669a4b5190d28e1bc6fe112b1771765..7889bfb19198fb5b56d28d51b2989a0a9c465225 100644 (file)
--- a/src/network/networkd-ndisc.c
+++ b/src/network/networkd-ndisc.c
@@ -600,12 +600,11 @@ static int ndisc_router_process_rdnss(Link *link, sd_ndisc_router *rt) {
                         .valid_until = time_now + lifetime * USEC_PER_SEC,
                 };
 
-                r = set_ensure_put(&link->ndisc_rdnss, &ndisc_rdnss_hash_ops, x);
+                r = set_ensure_consume(&link->ndisc_rdnss, &ndisc_rdnss_hash_ops, TAKE_PTR(x));
                 if (r < 0)
                         return log_oom();
-                TAKE_PTR(x);
-
                 assert(r > 0);
+
                 link_dirty(link);
         }
 
@@ -683,12 +682,11 @@ static void ndisc_router_process_dnssl(Link *link, sd_ndisc_router *rt) {
 
                 s->valid_until = time_now + lifetime * USEC_PER_SEC;
 
-                r = set_ensure_put(&link->ndisc_dnssl, &ndisc_dnssl_hash_ops, s);
+                r = set_ensure_consume(&link->ndisc_dnssl, &ndisc_dnssl_hash_ops, TAKE_PTR(s));
                 if (r < 0) {
                         log_oom();
                         return;
                 }
-                TAKE_PTR(s);
                 assert(r > 0);
 
                 link_dirty(link);
@@ -972,13 +970,9 @@ int config_parse_ndisc_black_listed_prefix(
                 if (!a)
                         return log_oom();
 
-                r = set_ensure_put(&network->ndisc_black_listed_prefix, &in6_addr_hash_ops, a);
-                if (r < 0) {
-                        log_syntax(unit, LOG_ERR, filename, line, r,
-                                   "Failed to store NDISC black listed prefix '%s', ignoring assignment: %m", n);
-                        continue;
-                }
-                TAKE_PTR(a);
+                r = set_ensure_consume(&network->ndisc_black_listed_prefix, &in6_addr_hash_ops, TAKE_PTR(a));
+                if (r < 0)
+                        return log_oom();
         }
 
         return 0;

diff --git a/src/network/networkd-network.c b/src/network/networkd-network.c
index 01f08a55529e6986d58ff84ca66f58f591953423..7fa359a5425cf34b9a3626f7a61a8b47c41bd17c 100644 (file)
--- a/src/network/networkd-network.c
+++ b/src/network/networkd-network.c
@@ -1268,11 +1268,9 @@ int config_parse_dnssec_negative_trust_anchors(
                         continue;
                 }
 
-                r = set_ensure_put(&n->dnssec_negative_trust_anchors, &dns_name_hash_ops, w);
+                r = set_ensure_consume(&n->dnssec_negative_trust_anchors, &dns_name_hash_ops, TAKE_PTR(w));
                 if (r < 0)
                         return log_oom();
-                if (r > 0)
-                        TAKE_PTR(w);
         }
 
         return 0;

diff --git a/src/resolve/resolved-dns-trust-anchor.c b/src/resolve/resolved-dns-trust-anchor.c
index 1cb749290575ed0a939a08532c92ebc263f46973..d68d0c3ba16cb47609ae5be7cfe92249ca2ad40e 100644 (file)
--- a/src/resolve/resolved-dns-trust-anchor.c
+++ b/src/resolve/resolved-dns-trust-anchor.c
@@ -393,11 +393,9 @@ static int dns_trust_anchor_load_negative(DnsTrustAnchor *d, const char *path, u
                 return -EINVAL;
         }
 
-        r = set_ensure_put(&d->negative_by_name, &dns_name_hash_ops, domain);
+        r = set_ensure_consume(&d->negative_by_name, &dns_name_hash_ops, TAKE_PTR(domain));
         if (r < 0)
                 return log_oom();
-        if (r > 0)
-                domain = NULL;
 
         return 0;
 }

diff --git a/src/shared/userdb.c b/src/shared/userdb.c
index f3b05a7ad38579e4d45df20d5e61f18163e2e4a0..cd9873c06e8b32f637a4acb3f0de13e130ac3454 100644 (file)
--- a/src/shared/userdb.c
+++ b/src/shared/userdb.c
@@ -359,11 +359,9 @@ static int userdb_connect(
         if (r < 0)
                 return log_debug_errno(r, "Failed to invoke varlink method: %m");
 
-        r = set_ensure_put(&iterator->links, &link_hash_ops, vl);
+        r = set_ensure_consume(&iterator->links, &link_hash_ops, TAKE_PTR(vl));
         if (r < 0)
                 return log_debug_errno(r, "Failed to add varlink connection to set: %m");
-
-        TAKE_PTR(vl);
         return r;
 }