Revert "busctl: use Monitoring interface (#3245)"

This reverts commit 17fd746098bb, which reworks busctl monitor to use D-Bus'
new BecomeMonitor call.  This broke monitor on kdbus system so revert this
change for now.

Change-Id: I70626c03b375f692a184214a3d5055ec0a96b5c8

diff --git a/src/libsystemd/sd-bus/busctl.c b/src/libsystemd/sd-bus/busctl.c
index eb042e9..ccb618a 100644 (file)
--- a/src/libsystemd/sd-bus/busctl.c
+++ b/src/libsystemd/sd-bus/busctl.c
@@ -1079,21 +1079,10 @@ static int message_pcap(sd_bus_message *m, FILE *f) {
 }
 
 static int monitor(sd_bus *bus, char *argv[], int (*dump)(sd_bus_message *m, FILE *f)) {
-        _cleanup_(sd_bus_message_unrefp) sd_bus_message *message = NULL;
-        _cleanup_(sd_bus_error_free) sd_bus_error error = SD_BUS_ERROR_NULL;
+        bool added_something = false;
         char **i;
-        uint32_t flags = 0;
         int r;
 
-        /* upgrade connection; it's not used for anything else after this call */
-        r = sd_bus_message_new_method_call(bus, &message, "org.freedesktop.DBus", "/org/freedesktop/DBus", "org.freedesktop.DBus.Monitoring", "BecomeMonitor");
-        if (r < 0)
-                return bus_log_create_error(r);
-
-        r = sd_bus_message_open_container(message, 'a', "s");
-        if (r < 0)
-                return bus_log_create_error(r);
-
         STRV_FOREACH(i, argv+1) {
                 _cleanup_free_ char *m = NULL;
 
@@ -1106,38 +1095,34 @@ static int monitor(sd_bus *bus, char *argv[], int (*dump)(sd_bus_message *m, FIL
                 if (!m)
                         return log_oom();
 
-                r = sd_bus_message_append_basic(message, 's', m);
+                r = sd_bus_add_match(bus, NULL, m, NULL, NULL);
                 if (r < 0)
-                        return bus_log_create_error(r);
+                        return log_error_errno(r, "Failed to add match: %m");
 
                 free(m);
                 m = strjoin("destination='", *i, "'", NULL);
                 if (!m)
                         return log_oom();
 
-                r = sd_bus_message_append_basic(message, 's', m);
+                r = sd_bus_add_match(bus, NULL, m, NULL, NULL);
                 if (r < 0)
-                        return bus_log_create_error(r);
+                        return log_error_errno(r, "Failed to add match: %m");
+
+                added_something = true;
         }
 
         STRV_FOREACH(i, arg_matches) {
-                r = sd_bus_message_append_basic(message, 's', *i);
+                r = sd_bus_add_match(bus, NULL, *i, NULL, NULL);
                 if (r < 0)
-                        return bus_log_create_error(r);
-        }
-
-        r = sd_bus_message_close_container(message);
-        if (r < 0)
-                return bus_log_create_error(r);
+                        return log_error_errno(r, "Failed to add match: %m");
 
-        r = sd_bus_message_append_basic(message, 'u', &flags);
-        if (r < 0)
-                return bus_log_create_error(r);
+                added_something = true;
+        }
 
-        r = sd_bus_call(bus, message, arg_timeout, &error, NULL);
-        if (r < 0) {
-                log_error("%s", bus_error_message(&error, r));
-                return r;
+        if (!added_something) {
+                r = sd_bus_add_match(bus, NULL, "", NULL, NULL);
+                if (r < 0)
+                        return log_error_errno(r, "Failed to add match: %m");
         }
 
         log_info("Monitoring bus message stream.");