1 /*-*- Mode: C; c-basic-offset: 8 -*-*/
4 This file is part of systemd.
6 Copyright 2010 Lennart Poettering
8 systemd is free software; you can redistribute it and/or modify it
9 under the terms of the GNU General Public License as published by
10 the Free Software Foundation; either version 2 of the License, or
11 (at your option) any later version.
13 systemd is distributed in the hope that it will be useful, but
14 WITHOUT ANY WARRANTY; without even the implied warranty of
15 MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
16 General Public License for more details.
18 You should have received a copy of the GNU General Public License
19 along with systemd; If not, see <http://www.gnu.org/licenses/>.
27 #include <sys/ioctl.h>
31 #include <dbus/dbus.h>
38 static const char *arg_type = NULL;
39 static bool arg_all = false;
40 static bool arg_replace = false;
41 static bool arg_session = false;
42 static bool arg_block = false;
44 static int bus_iter_get_basic_and_next(DBusMessageIter *iter, int type, void *data, bool next) {
46 if (dbus_message_iter_get_arg_type(iter) != type)
49 dbus_message_iter_get_basic(iter, data);
51 if (!dbus_message_iter_next(iter) != !next)
57 static int columns(void) {
58 static int parsed_columns = 0;
61 if (parsed_columns > 0)
62 return parsed_columns;
64 if ((e = getenv("COLUMNS")))
65 parsed_columns = atoi(e);
67 if (parsed_columns <= 0) {
71 if (ioctl(STDIN_FILENO, TIOCGWINSZ, &ws) >= 0)
72 parsed_columns = ws.ws_col;
75 if (parsed_columns <= 0)
78 return parsed_columns;
81 static int list_units(DBusConnection *bus, char **args, unsigned n) {
82 DBusMessage *m = NULL, *reply = NULL;
85 DBusMessageIter iter, sub, sub2;
88 dbus_error_init(&error);
90 if (!(m = dbus_message_new_method_call(
91 "org.freedesktop.systemd1",
92 "/org/freedesktop/systemd1",
93 "org.freedesktop.systemd1.Manager",
95 log_error("Could not allocate message.");
99 if (!(reply = dbus_connection_send_with_reply_and_block(bus, m, -1, &error))) {
100 log_error("Failed to issue method call: %s", error.message);
105 if (!dbus_message_iter_init(reply, &iter) ||
106 dbus_message_iter_get_arg_type(&iter) != DBUS_TYPE_ARRAY ||
107 dbus_message_iter_get_element_type(&iter) != DBUS_TYPE_STRUCT) {
108 log_error("Failed to parse reply.");
113 dbus_message_iter_recurse(&iter, &sub);
115 printf("%-45s %-6s %-12s %-12s %-15s %s\n", "UNIT", "LOAD", "ACTIVE", "SUB", "JOB", "DESCRIPTION");
117 while (dbus_message_iter_get_arg_type(&sub) != DBUS_TYPE_INVALID) {
118 const char *id, *description, *load_state, *active_state, *sub_state, *unit_state, *job_type, *job_path, *dot;
121 if (dbus_message_iter_get_arg_type(&sub) != DBUS_TYPE_STRUCT) {
122 log_error("Failed to parse reply.");
127 dbus_message_iter_recurse(&sub, &sub2);
129 if (bus_iter_get_basic_and_next(&sub2, DBUS_TYPE_STRING, &id, true) < 0 ||
130 bus_iter_get_basic_and_next(&sub2, DBUS_TYPE_STRING, &description, true) < 0 ||
131 bus_iter_get_basic_and_next(&sub2, DBUS_TYPE_STRING, &load_state, true) < 0 ||
132 bus_iter_get_basic_and_next(&sub2, DBUS_TYPE_STRING, &active_state, true) < 0 ||
133 bus_iter_get_basic_and_next(&sub2, DBUS_TYPE_STRING, &sub_state, true) < 0 ||
134 bus_iter_get_basic_and_next(&sub2, DBUS_TYPE_OBJECT_PATH, &unit_state, true) < 0 ||
135 bus_iter_get_basic_and_next(&sub2, DBUS_TYPE_UINT32, &job_id, true) < 0 ||
136 bus_iter_get_basic_and_next(&sub2, DBUS_TYPE_STRING, &job_type, true) < 0 ||
137 bus_iter_get_basic_and_next(&sub2, DBUS_TYPE_OBJECT_PATH, &job_path, false) < 0) {
138 log_error("Failed to parse reply.");
143 if ((!arg_type || ((dot = strrchr(id, '.')) &&
144 streq(dot+1, arg_type))) &&
145 (arg_all || !streq(active_state, "inactive"))) {
149 printf("%-45s %-6s %-12s %-12s%n", id, load_state, active_state, sub_state, &a);
152 printf(" %-15s%n", job_type, &b);
156 if (a + b + 2 < columns()) {
160 printf("%.*s", columns() - a - b - 2, description);
167 dbus_message_iter_next(&sub);
171 printf("\n%u units listed.\n", k);
173 printf("\n%u live units listed. Pass --all to see dead units, too.\n", k);
179 dbus_message_unref(m);
182 dbus_message_unref(reply);
184 dbus_error_free(&error);
189 static int list_jobs(DBusConnection *bus, char **args, unsigned n) {
190 DBusMessage *m = NULL, *reply = NULL;
193 DBusMessageIter iter, sub, sub2;
196 dbus_error_init(&error);
198 if (!(m = dbus_message_new_method_call(
199 "org.freedesktop.systemd1",
200 "/org/freedesktop/systemd1",
201 "org.freedesktop.systemd1.Manager",
203 log_error("Could not allocate message.");
207 if (!(reply = dbus_connection_send_with_reply_and_block(bus, m, -1, &error))) {
208 log_error("Failed to issue method call: %s", error.message);
213 if (!dbus_message_iter_init(reply, &iter) ||
214 dbus_message_iter_get_arg_type(&iter) != DBUS_TYPE_ARRAY ||
215 dbus_message_iter_get_element_type(&iter) != DBUS_TYPE_STRUCT) {
216 log_error("Failed to parse reply.");
221 dbus_message_iter_recurse(&iter, &sub);
223 printf("%4s %-45s %-17s %-7s\n", "JOB", "UNIT", "TYPE", "STATE");
225 while (dbus_message_iter_get_arg_type(&sub) != DBUS_TYPE_INVALID) {
226 const char *name, *type, *state, *job_path, *unit_path;
229 if (dbus_message_iter_get_arg_type(&sub) != DBUS_TYPE_STRUCT) {
230 log_error("Failed to parse reply.");
235 dbus_message_iter_recurse(&sub, &sub2);
237 if (bus_iter_get_basic_and_next(&sub2, DBUS_TYPE_UINT32, &id, true) < 0 ||
238 bus_iter_get_basic_and_next(&sub2, DBUS_TYPE_STRING, &name, true) < 0 ||
239 bus_iter_get_basic_and_next(&sub2, DBUS_TYPE_STRING, &type, true) < 0 ||
240 bus_iter_get_basic_and_next(&sub2, DBUS_TYPE_STRING, &state, true) < 0 ||
241 bus_iter_get_basic_and_next(&sub2, DBUS_TYPE_OBJECT_PATH, &job_path, true) < 0 ||
242 bus_iter_get_basic_and_next(&sub2, DBUS_TYPE_OBJECT_PATH, &unit_path, false) < 0) {
243 log_error("Failed to parse reply.");
248 printf("%4u %-45s %-17s %-7s\n", id, name, type, state);
251 dbus_message_iter_next(&sub);
254 printf("\n%u jobs listed.\n", k);
259 dbus_message_unref(m);
262 dbus_message_unref(reply);
264 dbus_error_free(&error);
269 static int load_unit(DBusConnection *bus, char **args, unsigned n) {
270 DBusMessage *m = NULL, *reply = NULL;
275 dbus_error_init(&error);
277 for (i = 1; i < n; i++) {
279 if (!(m = dbus_message_new_method_call(
280 "org.freedesktop.systemd1",
281 "/org/freedesktop/systemd1",
282 "org.freedesktop.systemd1.Manager",
284 log_error("Could not allocate message.");
289 if (!dbus_message_append_args(m,
290 DBUS_TYPE_STRING, &args[i],
291 DBUS_TYPE_INVALID)) {
292 log_error("Could not append arguments to message.");
297 if (!(reply = dbus_connection_send_with_reply_and_block(bus, m, -1, &error))) {
298 log_error("Failed to issue method call: %s", error.message);
303 dbus_message_unref(m);
304 dbus_message_unref(reply);
313 dbus_message_unref(m);
316 dbus_message_unref(reply);
318 dbus_error_free(&error);
323 static int cancel_job(DBusConnection *bus, char **args, unsigned n) {
324 DBusMessage *m = NULL, *reply = NULL;
329 dbus_error_init(&error);
331 for (i = 1; i < n; i++) {
335 if (!(m = dbus_message_new_method_call(
336 "org.freedesktop.systemd1",
337 "/org/freedesktop/systemd1",
338 "org.freedesktop.systemd1.Manager",
340 log_error("Could not allocate message.");
345 if ((r = safe_atou(args[i], &id)) < 0) {
346 log_error("Failed to parse job id: %s", strerror(-r));
350 assert_cc(sizeof(uint32_t) == sizeof(id));
351 if (!dbus_message_append_args(m,
352 DBUS_TYPE_UINT32, &id,
353 DBUS_TYPE_INVALID)) {
354 log_error("Could not append arguments to message.");
359 if (!(reply = dbus_connection_send_with_reply_and_block(bus, m, -1, &error))) {
360 log_error("Failed to issue method call: %s", error.message);
365 if (!dbus_message_get_args(reply, &error,
366 DBUS_TYPE_OBJECT_PATH, &path,
367 DBUS_TYPE_INVALID)) {
368 log_error("Failed to parse reply: %s", error.message);
373 dbus_message_unref(m);
374 if (!(m = dbus_message_new_method_call(
375 "org.freedesktop.systemd1",
377 "org.freedesktop.systemd1.Job",
379 log_error("Could not allocate message.");
384 dbus_message_unref(reply);
385 if (!(reply = dbus_connection_send_with_reply_and_block(bus, m, -1, &error))) {
386 log_error("Failed to issue method call: %s", error.message);
391 dbus_message_unref(m);
392 dbus_message_unref(reply);
400 dbus_message_unref(m);
403 dbus_message_unref(reply);
405 dbus_error_free(&error);
410 static DBusHandlerResult wait_filter(DBusConnection *connection, DBusMessage *message, void *data) {
418 dbus_error_init(&error);
420 /* log_debug("Got D-Bus request: %s.%s() on %s", */
421 /* dbus_message_get_interface(message), */
422 /* dbus_message_get_member(message), */
423 /* dbus_message_get_path(message)); */
425 if (dbus_message_is_signal(message, DBUS_INTERFACE_LOCAL, "Disconnected")) {
426 log_error("Warning! D-Bus connection terminated.");
427 dbus_connection_close(connection);
429 } else if (dbus_message_is_signal(message, "org.freedesktop.systemd1.Manager", "JobRemoved")) {
433 if (!dbus_message_get_args(message, &error,
434 DBUS_TYPE_UINT32, &id,
435 DBUS_TYPE_OBJECT_PATH, &path,
437 log_error("Failed to parse message: %s", error.message);
441 if ((p = set_remove(s, (char*) path)))
446 dbus_error_free(&error);
447 return DBUS_HANDLER_RESULT_NOT_YET_HANDLED;
450 static int wait_for_jobs(DBusConnection *bus, Set *s) {
452 DBusMessage *m = NULL, *reply = NULL;
458 dbus_error_init(&error);
460 dbus_bus_add_match(bus,
462 "sender='org.freedesktop.systemd1',"
463 "interface='org.freedesktop.systemd1.Manager',"
464 "member='JobRemoved',"
465 "path='/org/freedesktop/systemd1'",
468 if (dbus_error_is_set(&error)) {
469 log_error("Failed to add match: %s", error.message);
474 if (!dbus_connection_add_filter(bus, wait_filter, s, NULL)) {
475 log_error("Failed to add filter.");
480 if (!(m = dbus_message_new_method_call(
481 "org.freedesktop.systemd1",
482 "/org/freedesktop/systemd1",
483 "org.freedesktop.systemd1.Manager",
485 log_error("Could not allocate message.");
490 if (!(reply = dbus_connection_send_with_reply_and_block(bus, m, -1, &error))) {
491 log_error("Failed to issue method call: %s", error.message);
496 while (!set_isempty(s) &&
497 dbus_connection_read_write_dispatch(bus, -1))
503 /* This is slightly dirty, since we don't undo the filter or the matches. */
506 dbus_message_unref(m);
509 dbus_message_unref(reply);
511 dbus_error_free(&error);
516 static int start_unit(DBusConnection *bus, char **args, unsigned n) {
517 DBusMessage *m = NULL, *reply = NULL;
521 const char *method, *mode;
525 dbus_error_init(&error);
528 streq(args[0], "start") ? "StartUnit" :
529 streq(args[0], "stop") ? "StopUnit" :
530 streq(args[0], "reload") ? "ReloadUnit" :
533 mode = arg_replace ? "replace" : "fail";
535 for (i = 1; i < n; i++) {
537 if (!(m = dbus_message_new_method_call(
538 "org.freedesktop.systemd1",
539 "/org/freedesktop/systemd1",
540 "org.freedesktop.systemd1.Manager",
542 log_error("Could not allocate message.");
547 if (!dbus_message_append_args(m,
548 DBUS_TYPE_STRING, &args[i],
549 DBUS_TYPE_STRING, &mode,
550 DBUS_TYPE_INVALID)) {
551 log_error("Could not append arguments to message.");
556 if (!(reply = dbus_connection_send_with_reply_and_block(bus, m, -1, &error))) {
557 log_error("Failed to issue method call: %s", error.message);
565 if (!dbus_message_get_args(reply, &error,
566 DBUS_TYPE_OBJECT_PATH, &path,
567 DBUS_TYPE_INVALID)) {
568 log_error("Failed to parse reply: %s", error.message);
574 if (!(s = set_new(string_hash_func, string_compare_func))) {
575 log_error("Failed to allocate set.");
580 if (!(p = strdup(path))) {
581 log_error("Failed to duplicate path.");
586 if ((r = set_put(s, p)) < 0) {
587 log_error("Failed to add path to set.");
593 dbus_message_unref(m);
594 dbus_message_unref(reply);
600 r = wait_for_jobs(bus, s);
611 dbus_message_unref(m);
614 dbus_message_unref(reply);
616 dbus_error_free(&error);
621 static int isolate_unit(DBusConnection *bus, char **args, unsigned n) {
622 DBusMessage *m = NULL, *reply = NULL;
625 const char *mode = "isolate";
629 dbus_error_init(&error);
631 if (!(m = dbus_message_new_method_call(
632 "org.freedesktop.systemd1",
633 "/org/freedesktop/systemd1",
634 "org.freedesktop.systemd1.Manager",
636 log_error("Could not allocate message.");
641 if (!dbus_message_append_args(m,
642 DBUS_TYPE_STRING, &args[1],
643 DBUS_TYPE_STRING, &mode,
644 DBUS_TYPE_INVALID)) {
645 log_error("Could not append arguments to message.");
650 if (!(reply = dbus_connection_send_with_reply_and_block(bus, m, -1, &error))) {
651 log_error("Failed to issue method call: %s", error.message);
659 if (!dbus_message_get_args(reply, &error,
660 DBUS_TYPE_OBJECT_PATH, &path,
661 DBUS_TYPE_INVALID)) {
662 log_error("Failed to parse reply: %s", error.message);
667 if (!(s = set_new(string_hash_func, string_compare_func))) {
668 log_error("Failed to allocate set.");
673 if (!(p = strdup(path))) {
674 log_error("Failed to duplicate path.");
679 if ((r = set_put(s, p)) < 0) {
680 log_error("Failed to add path to set.");
685 r = wait_for_jobs(bus, s);
697 dbus_message_unref(m);
700 dbus_message_unref(reply);
702 dbus_error_free(&error);
707 static DBusHandlerResult monitor_filter(DBusConnection *connection, DBusMessage *message, void *data) {
709 DBusMessage *m = NULL, *reply = NULL;
714 dbus_error_init(&error);
716 /* log_debug("Got D-Bus request: %s.%s() on %s", */
717 /* dbus_message_get_interface(message), */
718 /* dbus_message_get_member(message), */
719 /* dbus_message_get_path(message)); */
721 if (dbus_message_is_signal(message, DBUS_INTERFACE_LOCAL, "Disconnected")) {
722 log_error("Warning! D-Bus connection terminated.");
723 dbus_connection_close(connection);
725 } else if (dbus_message_is_signal(message, "org.freedesktop.systemd1.Manager", "UnitNew") ||
726 dbus_message_is_signal(message, "org.freedesktop.systemd1.Manager", "UnitRemoved")) {
727 const char *id, *path;
729 if (!dbus_message_get_args(message, &error,
730 DBUS_TYPE_STRING, &id,
731 DBUS_TYPE_OBJECT_PATH, &path,
733 log_error("Failed to parse message: %s", error.message);
734 else if (streq(dbus_message_get_member(message), "UnitNew"))
735 printf("Unit %s added.\n", id);
737 printf("Unit %s removed.\n", id);
739 } else if (dbus_message_is_signal(message, "org.freedesktop.systemd1.Manager", "JobNew") ||
740 dbus_message_is_signal(message, "org.freedesktop.systemd1.Manager", "JobRemoved")) {
744 if (!dbus_message_get_args(message, &error,
745 DBUS_TYPE_UINT32, &id,
746 DBUS_TYPE_OBJECT_PATH, &path,
748 log_error("Failed to parse message: %s", error.message);
749 else if (streq(dbus_message_get_member(message), "JobNew"))
750 printf("Job %u added.\n", id);
752 printf("Job %u removed.\n", id);
755 } else if (dbus_message_is_signal(message, "org.freedesktop.systemd1.Unit", "Changed") ||
756 dbus_message_is_signal(message, "org.freedesktop.systemd1.Job", "Changed")) {
758 const char *path, *interface, *property = "Id";
759 DBusMessageIter iter, sub;
761 path = dbus_message_get_path(message);
762 interface = dbus_message_get_interface(message);
764 if (!(m = dbus_message_new_method_call(
765 "org.freedesktop.systemd1",
767 "org.freedesktop.DBus.Properties",
769 log_error("Could not allocate message.");
773 if (!dbus_message_append_args(m,
774 DBUS_TYPE_STRING, &interface,
775 DBUS_TYPE_STRING, &property,
776 DBUS_TYPE_INVALID)) {
777 log_error("Could not append arguments to message.");
781 if (!(reply = dbus_connection_send_with_reply_and_block(connection, m, -1, &error))) {
782 log_error("Failed to issue method call: %s", error.message);
786 if (!dbus_message_iter_init(reply, &iter) ||
787 dbus_message_iter_get_arg_type(&iter) != DBUS_TYPE_VARIANT) {
788 log_error("Failed to parse reply.");
792 dbus_message_iter_recurse(&iter, &sub);
794 if (streq(interface, "org.freedesktop.systemd1.Unit")) {
797 if (dbus_message_iter_get_arg_type(&sub) != DBUS_TYPE_STRING) {
798 log_error("Failed to parse reply.");
802 dbus_message_iter_get_basic(&sub, &id);
803 printf("Unit %s changed.\n", id);
807 if (dbus_message_iter_get_arg_type(&sub) != DBUS_TYPE_UINT32) {
808 log_error("Failed to parse reply.");
812 dbus_message_iter_get_basic(&sub, &id);
813 printf("Job %u changed.\n", id);
819 dbus_message_unref(m);
822 dbus_message_unref(reply);
824 dbus_error_free(&error);
825 return DBUS_HANDLER_RESULT_NOT_YET_HANDLED;
829 dbus_message_unref(m);
832 dbus_message_unref(reply);
834 dbus_error_free(&error);
835 return DBUS_HANDLER_RESULT_NEED_MEMORY;
838 static int monitor(DBusConnection *bus, char **args, unsigned n) {
839 DBusMessage *m = NULL, *reply = NULL;
843 dbus_error_init(&error);
845 dbus_bus_add_match(bus,
847 "sender='org.freedesktop.systemd1',"
848 "interface='org.freedesktop.systemd1.Manager',"
849 "path='/org/freedesktop/systemd1'",
852 if (dbus_error_is_set(&error)) {
853 log_error("Failed to add match: %s", error.message);
858 dbus_bus_add_match(bus,
860 "sender='org.freedesktop.systemd1',"
861 "interface='org.freedesktop.systemd1.Unit',"
865 if (dbus_error_is_set(&error)) {
866 log_error("Failed to add match: %s", error.message);
871 dbus_bus_add_match(bus,
873 "sender='org.freedesktop.systemd1',"
874 "interface='org.freedesktop.systemd1.Job',"
878 if (dbus_error_is_set(&error)) {
879 log_error("Failed to add match: %s", error.message);
884 if (!dbus_connection_add_filter(bus, monitor_filter, NULL, NULL)) {
885 log_error("Failed to add filter.");
890 if (!(m = dbus_message_new_method_call(
891 "org.freedesktop.systemd1",
892 "/org/freedesktop/systemd1",
893 "org.freedesktop.systemd1.Manager",
895 log_error("Could not allocate message.");
900 if (!(reply = dbus_connection_send_with_reply_and_block(bus, m, -1, &error))) {
901 log_error("Failed to issue method call: %s", error.message);
906 while (dbus_connection_read_write_dispatch(bus, -1))
913 /* This is slightly dirty, since we don't undo the filter or the matches. */
916 dbus_message_unref(m);
919 dbus_message_unref(reply);
921 dbus_error_free(&error);
926 static int dump(DBusConnection *bus, char **args, unsigned n) {
927 DBusMessage *m = NULL, *reply = NULL;
932 dbus_error_init(&error);
934 if (!(m = dbus_message_new_method_call(
935 "org.freedesktop.systemd1",
936 "/org/freedesktop/systemd1",
937 "org.freedesktop.systemd1.Manager",
939 log_error("Could not allocate message.");
943 if (!(reply = dbus_connection_send_with_reply_and_block(bus, m, -1, &error))) {
944 log_error("Failed to issue method call: %s", error.message);
949 if (!dbus_message_get_args(reply, &error,
950 DBUS_TYPE_STRING, &text,
951 DBUS_TYPE_INVALID)) {
952 log_error("Failed to parse reply: %s", error.message);
963 dbus_message_unref(m);
966 dbus_message_unref(reply);
968 dbus_error_free(&error);
973 static int snapshot(DBusConnection *bus, char **args, unsigned n) {
974 DBusMessage *m = NULL, *reply = NULL;
977 const char *name = "", *path, *id;
978 dbus_bool_t cleanup = FALSE;
979 DBusMessageIter iter, sub;
981 *interface = "org.freedesktop.systemd1.Unit",
984 dbus_error_init(&error);
986 if (!(m = dbus_message_new_method_call(
987 "org.freedesktop.systemd1",
988 "/org/freedesktop/systemd1",
989 "org.freedesktop.systemd1.Manager",
990 "CreateSnapshot"))) {
991 log_error("Could not allocate message.");
998 if (!dbus_message_append_args(m,
999 DBUS_TYPE_STRING, &name,
1000 DBUS_TYPE_BOOLEAN, &cleanup,
1001 DBUS_TYPE_INVALID)) {
1002 log_error("Could not append arguments to message.");
1007 if (!(reply = dbus_connection_send_with_reply_and_block(bus, m, -1, &error))) {
1008 log_error("Failed to issue method call: %s", error.message);
1013 if (!dbus_message_get_args(reply, &error,
1014 DBUS_TYPE_OBJECT_PATH, &path,
1015 DBUS_TYPE_INVALID)) {
1016 log_error("Failed to parse reply: %s", error.message);
1021 dbus_message_unref(m);
1022 if (!(m = dbus_message_new_method_call(
1023 "org.freedesktop.systemd1",
1025 "org.freedesktop.DBus.Properties",
1027 log_error("Could not allocate message.");
1031 if (!dbus_message_append_args(m,
1032 DBUS_TYPE_STRING, &interface,
1033 DBUS_TYPE_STRING, &property,
1034 DBUS_TYPE_INVALID)) {
1035 log_error("Could not append arguments to message.");
1040 dbus_message_unref(reply);
1041 if (!(reply = dbus_connection_send_with_reply_and_block(bus, m, -1, &error))) {
1042 log_error("Failed to issue method call: %s", error.message);
1047 if (!dbus_message_iter_init(reply, &iter) ||
1048 dbus_message_iter_get_arg_type(&iter) != DBUS_TYPE_VARIANT) {
1049 log_error("Failed to parse reply.");
1054 dbus_message_iter_recurse(&iter, &sub);
1056 if (dbus_message_iter_get_arg_type(&sub) != DBUS_TYPE_STRING) {
1057 log_error("Failed to parse reply.");
1062 dbus_message_iter_get_basic(&sub, &id);
1068 dbus_message_unref(m);
1071 dbus_message_unref(reply);
1073 dbus_error_free(&error);
1078 static int clear_jobs(DBusConnection *bus, char **args, unsigned n) {
1079 DBusMessage *m = NULL, *reply = NULL;
1084 dbus_error_init(&error);
1087 streq(args[0], "clear-jobs") ? "ClearJobs" :
1088 streq(args[0], "daemon-reload") ? "Reload" :
1089 streq(args[0], "daemon-reexec") ? "Reexecute" :
1092 if (!(m = dbus_message_new_method_call(
1093 "org.freedesktop.systemd1",
1094 "/org/freedesktop/systemd1",
1095 "org.freedesktop.systemd1.Manager",
1097 log_error("Could not allocate message.");
1101 if (!(reply = dbus_connection_send_with_reply_and_block(bus, m, -1, &error))) {
1102 log_error("Failed to issue method call: %s", error.message);
1111 dbus_message_unref(m);
1114 dbus_message_unref(reply);
1116 dbus_error_free(&error);
1121 static int show_enviroment(DBusConnection *bus, char **args, unsigned n) {
1122 DBusMessage *m = NULL, *reply = NULL;
1124 DBusMessageIter iter, sub, sub2;
1127 *interface = "org.freedesktop.systemd1.Manager",
1128 *property = "Environment";
1130 dbus_error_init(&error);
1132 if (!(m = dbus_message_new_method_call(
1133 "org.freedesktop.systemd1",
1134 "/org/freedesktop/systemd1",
1135 "org.freedesktop.DBus.Properties",
1137 log_error("Could not allocate message.");
1141 if (!dbus_message_append_args(m,
1142 DBUS_TYPE_STRING, &interface,
1143 DBUS_TYPE_STRING, &property,
1144 DBUS_TYPE_INVALID)) {
1145 log_error("Could not append arguments to message.");
1150 if (!(reply = dbus_connection_send_with_reply_and_block(bus, m, -1, &error))) {
1151 log_error("Failed to issue method call: %s", error.message);
1156 if (!dbus_message_iter_init(reply, &iter) ||
1157 dbus_message_iter_get_arg_type(&iter) != DBUS_TYPE_VARIANT) {
1158 log_error("Failed to parse reply.");
1163 dbus_message_iter_recurse(&iter, &sub);
1165 if (dbus_message_iter_get_arg_type(&sub) != DBUS_TYPE_ARRAY ||
1166 dbus_message_iter_get_element_type(&sub) != DBUS_TYPE_STRING) {
1167 log_error("Failed to parse reply.");
1172 dbus_message_iter_recurse(&sub, &sub2);
1174 while (dbus_message_iter_get_arg_type(&sub2) != DBUS_TYPE_INVALID) {
1177 if (dbus_message_iter_get_arg_type(&sub2) != DBUS_TYPE_STRING) {
1178 log_error("Failed to parse reply.");
1183 dbus_message_iter_get_basic(&sub2, &text);
1184 printf("%s\n", text);
1186 dbus_message_iter_next(&sub2);
1193 dbus_message_unref(m);
1196 dbus_message_unref(reply);
1198 dbus_error_free(&error);
1203 static int set_environment(DBusConnection *bus, char **args, unsigned n) {
1204 DBusMessage *m = NULL, *reply = NULL;
1208 DBusMessageIter iter, sub;
1211 dbus_error_init(&error);
1213 method = streq(args[0], "set-environment")
1215 : "UnsetEnvironment";
1217 if (!(m = dbus_message_new_method_call(
1218 "org.freedesktop.systemd1",
1219 "/org/freedesktop/systemd1",
1220 "org.freedesktop.systemd1.Manager",
1223 log_error("Could not allocate message.");
1227 dbus_message_iter_init_append(m, &iter);
1229 if (!dbus_message_iter_open_container(&iter, DBUS_TYPE_ARRAY, "s", &sub)) {
1230 log_error("Could not append arguments to message.");
1235 for (i = 1; i < n; i++)
1236 if (!dbus_message_iter_append_basic(&sub, DBUS_TYPE_STRING, &args[i])) {
1237 log_error("Could not append arguments to message.");
1242 if (!dbus_message_iter_close_container(&iter, &sub)) {
1243 log_error("Could not append arguments to message.");
1248 if (!(reply = dbus_connection_send_with_reply_and_block(bus, m, -1, &error))) {
1249 log_error("Failed to issue method call: %s", error.message);
1258 dbus_message_unref(m);
1261 dbus_message_unref(reply);
1263 dbus_error_free(&error);
1268 static int help(void) {
1270 printf("%s [options]\n\n"
1271 " -h --help Show this help\n"
1272 " -t --type=TYPE List only units of a particular type\n"
1273 " -a --all Show all units, including dead ones\n"
1274 " --replace When installing a new job, replace existing conflicting ones\n"
1275 " --system Connect to system bus\n"
1276 " --session Connect to session bus\n"
1277 " --block Wait until operation finished\n\n"
1279 " list-units List units\n"
1280 " list-jobs List jobs\n"
1281 " clear-jobs Cancel all jobs\n"
1282 " load [NAME...] Load one or more units\n"
1283 " cancel [JOB...] Cancel one or more jobs\n"
1284 " start [NAME...] Start one or more units\n"
1285 " stop [NAME...] Stop one or more units\n"
1286 " restart [NAME...] Restart one or more units\n"
1287 " reload [NAME...] Reload one or more units\n"
1288 " isolate [NAME] Start one unit and stop all others\n"
1289 " monitor Monitor unit/job changes\n"
1290 " dump Dump server status\n"
1291 " snapshot [NAME] Create a snapshot\n"
1292 " daemon-reload Reload daemon configuration\n"
1293 " daemon-reexecute Reexecute daemon\n"
1294 " daemon-exit Ask the daemon to quit\n"
1295 " show-environment Dump environment\n"
1296 " set-environment [NAME=VALUE...] Set one or more environment variables\n"
1297 " unset-environment [NAME...] Unset one or more environment variables\n",
1303 static int parse_argv(int argc, char *argv[]) {
1306 ARG_REPLACE = 0x100,
1312 static const struct option options[] = {
1313 { "help", no_argument, NULL, 'h' },
1314 { "type", required_argument, NULL, 't' },
1315 { "all", no_argument, NULL, 'a' },
1316 { "replace", no_argument, NULL, ARG_REPLACE },
1317 { "session", no_argument, NULL, ARG_SESSION },
1318 { "system", no_argument, NULL, ARG_SYSTEM },
1319 { "block", no_argument, NULL, ARG_BLOCK }
1327 while ((c = getopt_long(argc, argv, "hta", options, NULL)) >= 0) {
1352 arg_session = false;
1363 log_error("Unknown option code %c", c);
1371 int main(int argc, char*argv[]) {
1374 static const struct {
1382 int (* const dispatch)(DBusConnection *bus, char **args, unsigned n);
1384 { "list-units", LESS, 1, list_units },
1385 { "list-jobs", EQUAL, 1, list_jobs },
1386 { "clear-jobs", EQUAL, 1, clear_jobs },
1387 { "load", MORE, 2, load_unit },
1388 { "cancel", MORE, 2, cancel_job },
1389 { "start", MORE, 2, start_unit },
1390 { "stop", MORE, 2, start_unit },
1391 { "reload", MORE, 2, start_unit },
1392 { "restart", MORE, 2, start_unit },
1393 { "isolate", EQUAL, 2, isolate_unit },
1394 { "monitor", EQUAL, 1, monitor },
1395 { "dump", EQUAL, 1, dump },
1396 { "snapshot", LESS, 2, snapshot },
1397 { "daemon-reload", EQUAL, 1, clear_jobs },
1398 { "daemon-reexec", EQUAL, 1, clear_jobs },
1399 { "daemon-exit", EQUAL, 1, clear_jobs },
1400 { "show-environment", EQUAL, 1, show_enviroment },
1401 { "set-environment", MORE, 2, set_environment },
1402 { "unset-environment", MORE, 2, set_environment },
1405 int r, retval = 1, left;
1407 DBusConnection *bus = NULL;
1410 dbus_error_init(&error);
1412 log_set_target(LOG_TARGET_CONSOLE);
1413 log_parse_environment();
1415 if ((r = parse_argv(argc, argv)) < 0)
1422 left = argc - optind;
1425 /* Special rule: no arguments means "list-units" */
1428 for (i = 0; i < ELEMENTSOF(verbs); i++)
1429 if (streq(argv[optind], verbs[i].verb))
1432 if (i >= ELEMENTSOF(verbs)) {
1433 log_error("Unknown operation %s", argv[optind]);
1438 switch (verbs[i].argc_cmp) {
1441 if (left != verbs[i].argc) {
1442 log_error("Invalid number of arguments.");
1449 if (left < verbs[i].argc) {
1450 log_error("Too few arguments.");
1457 if (left > verbs[i].argc) {
1458 log_error("Too many arguments.");
1465 assert_not_reached("Unknown comparison operator.");
1468 if (!(bus = dbus_bus_get(arg_session ? DBUS_BUS_SESSION : DBUS_BUS_SYSTEM, &error))) {
1469 log_error("Failed to get D-Bus connection: %s", error.message);
1473 dbus_connection_set_exit_on_disconnect(bus, FALSE);
1475 retval = verbs[i].dispatch(bus, argv + optind, left) < 0;
1480 dbus_connection_unref(bus);