tree-wide: use ASSERT_PTR more

[thirdparty/systemd.git] / src / shared / bus-wait-for-units.c

diff --git a/src/shared/bus-wait-for-units.c b/src/shared/bus-wait-for-units.c
index 4f1c505bd3f1bae01b165d45c03f01b7f080fcd6..0dd2a295dd9b122d17af8757d3d89a2cd9a17c72 100644 (file)
--- a/src/shared/bus-wait-for-units.c
+++ b/src/shared/bus-wait-for-units.c
@@ -1,5 +1,6 @@
 /* SPDX-License-Identifier: LGPL-2.1-or-later */
 
+#include "bus-error.h"
 #include "bus-map-properties.h"
 #include "bus-wait-for-units.h"
 #include "hashmap.h"
@@ -104,10 +105,9 @@ static void bus_wait_for_units_clear(BusWaitForUnits *d) {
 }
 
 static int match_disconnected(sd_bus_message *m, void *userdata, sd_bus_error *error) {
-        BusWaitForUnits *d = userdata;
+        BusWaitForUnits *d = ASSERT_PTR(userdata);
 
         assert(m);
-        assert(d);
 
         log_error("Warning! D-Bus connection terminated.");
 
@@ -228,13 +228,11 @@ static int property_map_job(
                 sd_bus_error *error,
                 void *userdata) {
 
-        WaitForItem *item = userdata;
+        WaitForItem *item = ASSERT_PTR(userdata);
         const char *path;
         uint32_t id;
         int r;
 
-        assert(item);
-
         r = sd_bus_message_read(m, "(uo)", &id, &path);
         if (r < 0)
                 return r;
@@ -266,12 +264,10 @@ static int wait_for_item_parse_properties(WaitForItem *item, sd_bus_message *m)
 }
 
 static int on_properties_changed(sd_bus_message *m, void *userdata, sd_bus_error *error) {
-        WaitForItem *item = userdata;
+        WaitForItem *item = ASSERT_PTR(userdata);
         const char *interface;
         int r;
 
-        assert(item);
-
         r = sd_bus_message_read(m, "s", &interface);
         if (r < 0) {
                 log_debug_errno(r, "Failed to parse PropertiesChanged signal: %m");
@@ -288,19 +284,20 @@ static int on_properties_changed(sd_bus_message *m, void *userdata, sd_bus_error
         return 0;
 }
 
-static int on_get_all_properties(sd_bus_message *m, void *userdata, sd_bus_error *error) {
-        WaitForItem *item = userdata;
+static int on_get_all_properties(sd_bus_message *m, void *userdata, sd_bus_error *ret_error) {
+        WaitForItem *item = ASSERT_PTR(userdata);
+        const sd_bus_error *e;
         int r;
 
-        assert(item);
-
-        if (sd_bus_error_is_set(error)) {
+        e = sd_bus_message_get_error(m);
+        if (e) {
                 BusWaitForUnits *d = item->parent;
 
                 d->has_failed = true;
 
-                log_debug_errno(sd_bus_error_get_errno(error), "GetAll() failed for %s: %s",
-                                item->bus_path, error->message);
+                r = sd_bus_error_get_errno(e);
+                log_debug_errno(r, "GetAll() failed for %s: %s",
+                                item->bus_path, bus_error_message(e, r));
 
                 call_unit_callback_and_wait(d, item, false);
                 bus_wait_for_units_check_ready(d);
@@ -414,7 +411,7 @@ int bus_wait_for_units_run(BusWaitForUnits *d) {
                 if (r > 0)
                         continue;
 
-                r = sd_bus_wait(d->bus, (uint64_t) -1);
+                r = sd_bus_wait(d->bus, UINT64_MAX);
                 if (r < 0)
                         return r;
         }