src/systemctl/systemctl.c

   1 /*-*- Mode: C; c-basic-offset: 8; indent-tabs-mode: nil -*-*/
   2
   3 /***
   4   This file is part of systemd.
   5
   6   Copyright 2010 Lennart Poettering
   7   Copyright 2013 Marc-Antoine Perennou
   8
   9   systemd is free software; you can redistribute it and/or modify it
  10   under the terms of the GNU Lesser General Public License as published by
  11   the Free Software Foundation; either version 2.1 of the License, or
  12   (at your option) any later version.
  13
  14   systemd is distributed in the hope that it will be useful, but
  15   WITHOUT ANY WARRANTY; without even the implied warranty of
  16   MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
  17   Lesser General Public License for more details.
  18
  19   You should have received a copy of the GNU Lesser General Public License
  20   along with systemd; If not, see <http://www.gnu.org/licenses/>.
  21 ***/
  22
  23 #include <sys/reboot.h>
  24 #include <linux/reboot.h>
  25 #include <sys/syscall.h>
  26 #include <stdio.h>
  27 #include <getopt.h>
  28 #include <locale.h>
  29 #include <stdbool.h>
  30 #include <string.h>
  31 #include <errno.h>
  32 #include <sys/ioctl.h>
  33 #include <termios.h>
  34 #include <unistd.h>
  35 #include <fcntl.h>
  36 #include <sys/socket.h>
  37 #include <sys/stat.h>
  38 #include <stddef.h>
  39 #include <sys/prctl.h>
  40
  41 #include "sd-daemon.h"
  42 #include "sd-shutdown.h"
  43 #include "sd-login.h"
  44 #include "sd-bus.h"
  45 #include "log.h"
  46 #include "util.h"
  47 #include "macro.h"
  48 #include "set.h"
  49 #include "utmp-wtmp.h"
  50 #include "special.h"
  51 #include "initreq.h"
  52 #include "path-util.h"
  53 #include "strv.h"
  54 #include "cgroup-show.h"
  55 #include "cgroup-util.h"
  56 #include "list.h"
  57 #include "path-lookup.h"
  58 #include "conf-parser.h"
  59 #include "exit-status.h"
  60 #include "bus-errors.h"
  61 #include "build.h"
  62 #include "unit-name.h"
  63 #include "pager.h"
  64 #include "spawn-ask-password-agent.h"
  65 #include "spawn-polkit-agent.h"
  66 #include "install.h"
  67 #include "logs-show.h"
  68 #include "socket-util.h"
  69 #include "fileio.h"
  70 #include "bus-util.h"
  71 #include "bus-message.h"
  72 #include "bus-error.h"
  73 #include "bus-errors.h"
  74
  75 static char **arg_types = NULL;
  76 static char **arg_states = NULL;
  77 static char **arg_properties = NULL;
  78 static bool arg_all = false;
  79 static bool original_stdout_is_tty;
  80 static enum dependency {
  81         DEPENDENCY_FORWARD,
  82         DEPENDENCY_REVERSE,
  83         DEPENDENCY_AFTER,
  84         DEPENDENCY_BEFORE,
  85 } arg_dependency = DEPENDENCY_FORWARD;
  86 static const char *arg_job_mode = "replace";
  87 static UnitFileScope arg_scope = UNIT_FILE_SYSTEM;
  88 static bool arg_no_block = false;
  89 static bool arg_no_legend = false;
  90 static bool arg_no_pager = false;
  91 static bool arg_no_wtmp = false;
  92 static bool arg_no_wall = false;
  93 static bool arg_no_reload = false;
  94 static bool arg_show_types = false;
  95 static bool arg_ignore_inhibitors = false;
  96 static bool arg_dry = false;
  97 static bool arg_quiet = false;
  98 static bool arg_full = false;
  99 static int arg_force = 0;
 100 static bool arg_ask_password = true;
 101 static bool arg_runtime = false;
 102 static char **arg_wall = NULL;
 103 static const char *arg_kill_who = NULL;
 104 static int arg_signal = SIGTERM;
 105 static const char *arg_root = NULL;
 106 static usec_t arg_when = 0;
 107 static enum action {
 108         _ACTION_INVALID,
 109         ACTION_SYSTEMCTL,
 110         ACTION_HALT,
 111         ACTION_POWEROFF,
 112         ACTION_REBOOT,
 113         ACTION_KEXEC,
 114         ACTION_EXIT,
 115         ACTION_SUSPEND,
 116         ACTION_HIBERNATE,
 117         ACTION_HYBRID_SLEEP,
 118         ACTION_RUNLEVEL2,
 119         ACTION_RUNLEVEL3,
 120         ACTION_RUNLEVEL4,
 121         ACTION_RUNLEVEL5,
 122         ACTION_RESCUE,
 123         ACTION_EMERGENCY,
 124         ACTION_DEFAULT,
 125         ACTION_RELOAD,
 126         ACTION_REEXEC,
 127         ACTION_RUNLEVEL,
 128         ACTION_CANCEL_SHUTDOWN,
 129         _ACTION_MAX
 130 } arg_action = ACTION_SYSTEMCTL;
 131 static BusTransport arg_transport = BUS_TRANSPORT_LOCAL;
 132 static char *arg_host = NULL;
 133 static unsigned arg_lines = 10;
 134 static OutputMode arg_output = OUTPUT_SHORT;
 135 static bool arg_plain = false;
 136
 137 static int daemon_reload(sd_bus *bus, char **args);
 138 static int halt_now(enum action a);
 139
 140 static int check_one_unit(sd_bus *bus, const char *name, const char *good_states, bool quiet);
 141
 142 static void pager_open_if_enabled(void) {
 143
 144         if (arg_no_pager)
 145                 return;
 146
 147         pager_open(false);
 148 }
 149
 150 static void ask_password_agent_open_if_enabled(void) {
 151
 152         /* Open the password agent as a child process if necessary */
 153
 154         if (!arg_ask_password)
 155                 return;
 156
 157         if (arg_scope != UNIT_FILE_SYSTEM)
 158                 return;
 159
 160         if (arg_transport != BUS_TRANSPORT_LOCAL)
 161                 return;
 162
 163         ask_password_agent_open();
 164 }
 165
 166 #ifdef HAVE_LOGIND
 167 static void polkit_agent_open_if_enabled(void) {
 168
 169         /* Open the polkit agent as a child process if necessary */
 170
 171         if (!arg_ask_password)
 172                 return;
 173
 174         if (arg_scope != UNIT_FILE_SYSTEM)
 175                 return;
 176
 177         if (arg_transport != BUS_TRANSPORT_LOCAL)
 178                 return;
 179
 180         polkit_agent_open();
 181 }
 182 #endif
 183
 184 static int translate_bus_error_to_exit_status(int r, const sd_bus_error *error) {
 185         assert(error);
 186
 187         if (!sd_bus_error_is_set(error))
 188                 return r;
 189
 190         if (sd_bus_error_has_name(error, SD_BUS_ERROR_ACCESS_DENIED) ||
 191             sd_bus_error_has_name(error, BUS_ERROR_ONLY_BY_DEPENDENCY) ||
 192             sd_bus_error_has_name(error, BUS_ERROR_NO_ISOLATION) ||
 193             sd_bus_error_has_name(error, BUS_ERROR_TRANSACTION_IS_DESTRUCTIVE))
 194                 return EXIT_NOPERMISSION;
 195
 196         if (sd_bus_error_has_name(error, BUS_ERROR_NO_SUCH_UNIT))
 197                 return EXIT_NOTINSTALLED;
 198
 199         if (sd_bus_error_has_name(error, BUS_ERROR_JOB_TYPE_NOT_APPLICABLE) ||
 200             sd_bus_error_has_name(error, SD_BUS_ERROR_NOT_SUPPORTED))
 201                 return EXIT_NOTIMPLEMENTED;
 202
 203         if (sd_bus_error_has_name(error, BUS_ERROR_LOAD_FAILED))
 204                 return EXIT_NOTCONFIGURED;
 205
 206         if (r != 0)
 207                 return r;
 208
 209         return EXIT_FAILURE;
 210 }
 211
 212 static void warn_wall(enum action a) {
 213         static const char *table[_ACTION_MAX] = {
 214                 [ACTION_HALT]            = "The system is going down for system halt NOW!",
 215                 [ACTION_REBOOT]          = "The system is going down for reboot NOW!",
 216                 [ACTION_POWEROFF]        = "The system is going down for power-off NOW!",
 217                 [ACTION_KEXEC]           = "The system is going down for kexec reboot NOW!",
 218                 [ACTION_RESCUE]          = "The system is going down to rescue mode NOW!",
 219                 [ACTION_EMERGENCY]       = "The system is going down to emergency mode NOW!",
 220                 [ACTION_CANCEL_SHUTDOWN] = "The system shutdown has been cancelled NOW!"
 221         };
 222
 223         if (arg_no_wall)
 224                 return;
 225
 226         if (arg_wall) {
 227                 _cleanup_free_ char *p;
 228
 229                 p = strv_join(arg_wall, " ");
 230                 if (!p) {
 231                         log_oom();
 232                         return;
 233                 }
 234
 235                 if (*p) {
 236                         utmp_wall(p, NULL);
 237                         return;
 238                 }
 239         }
 240
 241         if (!table[a])
 242                 return;
 243
 244         utmp_wall(table[a], NULL);
 245 }
 246
 247 static bool avoid_bus(void) {
 248
 249         if (running_in_chroot() > 0)
 250                 return true;
 251
 252         if (sd_booted() <= 0)
 253                 return true;
 254
 255         if (!isempty(arg_root))
 256                 return true;
 257
 258         if (arg_scope == UNIT_FILE_GLOBAL)
 259                 return true;
 260
 261         return false;
 262 }
 263
 264 static int compare_unit_info(const void *a, const void *b) {
 265         const UnitInfo *u = a, *v = b;
 266         const char *d1, *d2;
 267
 268         d1 = strrchr(u->id, '.');
 269         d2 = strrchr(v->id, '.');
 270
 271         if (d1 && d2) {
 272                 int r;
 273
 274                 r = strcasecmp(d1, d2);
 275                 if (r != 0)
 276                         return r;
 277         }
 278
 279         return strcasecmp(u->id, v->id);
 280 }
 281
 282 static bool output_show_unit(const UnitInfo *u) {
 283         const char *dot;
 284
 285         if (!strv_isempty(arg_states))
 286                 return
 287                         strv_contains(arg_states, u->load_state) ||
 288                         strv_contains(arg_states, u->sub_state) ||
 289                         strv_contains(arg_states, u->active_state);
 290
 291         return (!arg_types || ((dot = strrchr(u->id, '.')) &&
 292                                strv_find(arg_types, dot+1))) &&
 293                 (arg_all || !(streq(u->active_state, "inactive")
 294                               || u->following[0]) || u->job_id > 0);
 295 }
 296
 297 static void output_units_list(const UnitInfo *unit_infos, unsigned c) {
 298         unsigned id_len, max_id_len, load_len, active_len, sub_len, job_len, desc_len;
 299         const UnitInfo *u;
 300         unsigned n_shown = 0;
 301         int job_count = 0;
 302
 303         max_id_len = sizeof("UNIT")-1;
 304         load_len = sizeof("LOAD")-1;
 305         active_len = sizeof("ACTIVE")-1;
 306         sub_len = sizeof("SUB")-1;
 307         job_len = sizeof("JOB")-1;
 308         desc_len = 0;
 309
 310         for (u = unit_infos; u < unit_infos + c; u++) {
 311                 if (!output_show_unit(u))
 312                         continue;
 313
 314                 max_id_len = MAX(max_id_len, strlen(u->id));
 315                 load_len = MAX(load_len, strlen(u->load_state));
 316                 active_len = MAX(active_len, strlen(u->active_state));
 317                 sub_len = MAX(sub_len, strlen(u->sub_state));
 318
 319                 if (u->job_id != 0) {
 320                         job_len = MAX(job_len, strlen(u->job_type));
 321                         job_count++;
 322                 }
 323         }
 324
 325         if (!arg_full && original_stdout_is_tty) {
 326                 unsigned basic_len;
 327
 328                 id_len = MIN(max_id_len, 25u);
 329                 basic_len = 5 + id_len + 5 + active_len + sub_len;
 330
 331                 if (job_count)
 332                         basic_len += job_len + 1;
 333
 334                 if (basic_len < (unsigned) columns()) {
 335                         unsigned extra_len, incr;
 336                         extra_len = columns() - basic_len;
 337
 338                         /* Either UNIT already got 25, or is fully satisfied.
 339                          * Grant up to 25 to DESC now. */
 340                         incr = MIN(extra_len, 25u);
 341                         desc_len += incr;
 342                         extra_len -= incr;
 343
 344                         /* split the remaining space between UNIT and DESC,
 345                          * but do not give UNIT more than it needs. */
 346                         if (extra_len > 0) {
 347                                 incr = MIN(extra_len / 2, max_id_len - id_len);
 348                                 id_len += incr;
 349                                 desc_len += extra_len - incr;
 350                         }
 351                 }
 352         } else
 353                 id_len = max_id_len;
 354
 355         for (u = unit_infos; u < unit_infos + c; u++) {
 356                 _cleanup_free_ char *e = NULL;
 357                 const char *on_loaded, *off_loaded, *on = "";
 358                 const char *on_active, *off_active, *off = "";
 359
 360                 if (!output_show_unit(u))
 361                         continue;
 362
 363                 if (!n_shown && !arg_no_legend) {
 364                         printf("%-*s %-*s %-*s %-*s ",
 365                                id_len, "UNIT",
 366                                load_len, "LOAD",
 367                                active_len, "ACTIVE",
 368                                sub_len, "SUB");
 369
 370                         if (job_count)
 371                                 printf("%-*s ", job_len, "JOB");
 372
 373                         if (!arg_full && arg_no_pager)
 374                                 printf("%.*s\n", desc_len, "DESCRIPTION");
 375                         else
 376                                 printf("%s\n", "DESCRIPTION");
 377                 }
 378
 379                 n_shown++;
 380
 381                 if (streq(u->load_state, "error") ||
 382                     streq(u->load_state, "not-found")) {
 383                         on_loaded = on = ansi_highlight_red();
 384                         off_loaded = off = ansi_highlight_off();
 385                 } else
 386                         on_loaded = off_loaded = "";
 387
 388                 if (streq(u->active_state, "failed")) {
 389                         on_active = on = ansi_highlight_red();
 390                         off_active = off = ansi_highlight_off();
 391                 } else
 392                         on_active = off_active = "";
 393
 394                 e = arg_full ? NULL : ellipsize(u->id, id_len, 33);
 395
 396                 printf("%s%-*s%s %s%-*s%s %s%-*s %-*s%s %-*s",
 397                        on, id_len, e ? e : u->id, off,
 398                        on_loaded, load_len, u->load_state, off_loaded,
 399                        on_active, active_len, u->active_state,
 400                        sub_len, u->sub_state, off_active,
 401                        job_count ? job_len + 1 : 0, u->job_id ? u->job_type : "");
 402
 403                 if (desc_len > 0)
 404                         printf("%.*s\n", desc_len, u->description);
 405                 else
 406                         printf("%s\n", u->description);
 407         }
 408
 409         if (!arg_no_legend) {
 410                 const char *on, *off;
 411
 412                 if (n_shown) {
 413                         printf("\nLOAD   = Reflects whether the unit definition was properly loaded.\n"
 414                                "ACTIVE = The high-level unit activation state, i.e. generalization of SUB.\n"
 415                                "SUB    = The low-level unit activation state, values depend on unit type.\n");
 416                         if (job_count)
 417                                 printf("JOB    = Pending job for the unit.\n");
 418                         puts("");
 419                         on = ansi_highlight();
 420                         off = ansi_highlight_off();
 421                 } else {
 422                         on = ansi_highlight_red();
 423                         off = ansi_highlight_off();
 424                 }
 425
 426                 if (arg_all)
 427                         printf("%s%u loaded units listed.%s\n"
 428                                "To show all installed unit files use 'systemctl list-unit-files'.\n",
 429                                on, n_shown, off);
 430                 else
 431                         printf("%s%u loaded units listed.%s Pass --all to see loaded but inactive units, too.\n"
 432                                "To show all installed unit files use 'systemctl list-unit-files'.\n",
 433                                on, n_shown, off);
 434         }
 435 }
 436
 437 static int get_unit_list(
 438                 sd_bus *bus,
 439                 sd_bus_message **_reply,
 440                 UnitInfo **_unit_infos) {
 441
 442         _cleanup_bus_error_free_ sd_bus_error error = SD_BUS_ERROR_NULL;
 443         _cleanup_bus_message_unref_ sd_bus_message *reply = NULL;
 444         _cleanup_free_ UnitInfo *unit_infos = NULL;
 445         size_t size = 0;
 446         int r, c = 0;
 447         UnitInfo u;
 448
 449         assert(bus);
 450         assert(_reply);
 451         assert(_unit_infos);
 452
 453         r = sd_bus_call_method(
 454                         bus,
 455                         "org.freedesktop.systemd1",
 456                         "/org/freedesktop/systemd1",
 457                         "org.freedesktop.systemd1.Manager",
 458                         "ListUnits",
 459                         &error,
 460                         &reply,
 461                         NULL);
 462         if (r < 0) {
 463                 log_error("Failed to list units: %s", bus_error_message(&error, r));
 464                 return r;
 465         }
 466
 467         r = sd_bus_message_enter_container(reply, SD_BUS_TYPE_ARRAY, "(ssssssouso)");
 468         if (r < 0)
 469                 return bus_log_parse_error(r);
 470
 471         while ((r = bus_parse_unit_info(reply, &u)) > 0) {
 472
 473                 if (!GREEDY_REALLOC(unit_infos, size, c+1))
 474                         return log_oom();
 475
 476                 unit_infos[c++] = u;
 477         }
 478         if (r < 0)
 479                 return bus_log_parse_error(r);
 480
 481         r = sd_bus_message_exit_container(reply);
 482         if (r < 0)
 483                 return bus_log_parse_error(r);
 484
 485         *_reply = reply;
 486         reply = NULL;
 487
 488         *_unit_infos = unit_infos;
 489         unit_infos = NULL;
 490
 491         return c;
 492 }
 493
 494 static int list_units(sd_bus *bus, char **args) {
 495         _cleanup_bus_message_unref_ sd_bus_message *reply = NULL;
 496         _cleanup_free_ UnitInfo *unit_infos = NULL;
 497         int r;
 498
 499         pager_open_if_enabled();
 500
 501         r = get_unit_list(bus, &reply, &unit_infos);
 502         if (r < 0)
 503                 return r;
 504
 505         qsort_safe(unit_infos, r, sizeof(UnitInfo), compare_unit_info);
 506         output_units_list(unit_infos, r);
 507
 508         return 0;
 509 }
 510
 511 static int get_triggered_units(
 512                 sd_bus *bus,
 513                 const char* path,
 514                 char*** ret) {
 515
 516         _cleanup_bus_error_free_ sd_bus_error error = SD_BUS_ERROR_NULL;
 517         int r;
 518
 519         r = sd_bus_get_property_strv(
 520                         bus,
 521                         "org.freedesktop.systemd1",
 522                         path,
 523                         "org.freedesktop.systemd1.Unit",
 524                         "Triggers",
 525                         &error,
 526                         ret);
 527
 528         if (r < 0)
 529                 log_error("Failed to determine triggers: %s", bus_error_message(&error, r));
 530
 531         return 0;
 532 }
 533
 534 static int get_listening(
 535                 sd_bus *bus,
 536                 const char* unit_path,
 537                 char*** listening) {
 538
 539         _cleanup_bus_error_free_ sd_bus_error error = SD_BUS_ERROR_NULL;
 540         _cleanup_bus_message_unref_ sd_bus_message *reply = NULL;
 541         const char *type, *path;
 542         int r, n = 0;
 543
 544         r = sd_bus_get_property(
 545                         bus,
 546                         "org.freedesktop.systemd1",
 547                         unit_path,
 548                         "org.freedesktop.systemd1.Socket",
 549                         "Listen",
 550                         &error,
 551                         &reply,
 552                         "a(ss)");
 553         if (r < 0) {
 554                 log_error("Failed to get list of listening sockets: %s", bus_error_message(&error, r));
 555                 return r;
 556         }
 557
 558         r = sd_bus_message_enter_container(reply, SD_BUS_TYPE_ARRAY, "(ss)");
 559         if (r < 0)
 560                 return bus_log_parse_error(r);
 561
 562         while ((r = sd_bus_message_read(reply, "(ss)", &type, &path)) > 0) {
 563
 564                 r = strv_extend(listening, type);
 565                 if (r < 0)
 566                         return log_oom();
 567
 568                 r = strv_extend(listening, path);
 569                 if (r < 0)
 570                         return log_oom();
 571
 572                 n++;
 573         }
 574         if (r < 0)
 575                 return bus_log_parse_error(r);
 576
 577         r = sd_bus_message_exit_container(reply);
 578         if (r < 0)
 579                 return bus_log_parse_error(r);
 580
 581         return n;
 582 }
 583
 584 struct socket_info {
 585         const char* id;
 586
 587         char* type;
 588         char* path;
 589
 590         /* Note: triggered is a list here, although it almost certainly
 591          * will always be one unit. Nevertheless, dbus API allows for multiple
 592          * values, so let's follow that.*/
 593         char** triggered;
 594
 595         /* The strv above is shared. free is set only in the first one. */
 596         bool own_triggered;
 597 };
 598
 599 static int socket_info_compare(const struct socket_info *a, const struct socket_info *b) {
 600         int o;
 601
 602         assert(a);
 603         assert(b);
 604
 605         o = strcmp(a->path, b->path);
 606         if (o == 0)
 607                 o = strcmp(a->type, b->type);
 608
 609         return o;
 610 }
 611
 612 static int output_sockets_list(struct socket_info *socket_infos, unsigned cs) {
 613         struct socket_info *s;
 614         unsigned pathlen = sizeof("LISTEN") - 1,
 615                 typelen = (sizeof("TYPE") - 1) * arg_show_types,
 616                 socklen = sizeof("UNIT") - 1,
 617                 servlen = sizeof("ACTIVATES") - 1;
 618         const char *on, *off;
 619
 620         for (s = socket_infos; s < socket_infos + cs; s++) {
 621                 unsigned tmp = 0;
 622                 char **a;
 623
 624                 socklen = MAX(socklen, strlen(s->id));
 625                 if (arg_show_types)
 626                         typelen = MAX(typelen, strlen(s->type));
 627                 pathlen = MAX(pathlen, strlen(s->path));
 628
 629                 STRV_FOREACH(a, s->triggered)
 630                         tmp += strlen(*a) + 2*(a != s->triggered);
 631                 servlen = MAX(servlen, tmp);
 632         }
 633
 634         if (cs) {
 635                 if (!arg_no_legend)
 636                         printf("%-*s %-*.*s%-*s %s\n",
 637                                pathlen, "LISTEN",
 638                                typelen + arg_show_types, typelen + arg_show_types, "TYPE ",
 639                                socklen, "UNIT",
 640                                "ACTIVATES");
 641
 642                 for (s = socket_infos; s < socket_infos + cs; s++) {
 643                         char **a;
 644
 645                         if (arg_show_types)
 646                                 printf("%-*s %-*s %-*s",
 647                                        pathlen, s->path, typelen, s->type, socklen, s->id);
 648                         else
 649                                 printf("%-*s %-*s",
 650                                        pathlen, s->path, socklen, s->id);
 651                         STRV_FOREACH(a, s->triggered)
 652                                 printf("%s %s",
 653                                        a == s->triggered ? "" : ",", *a);
 654                         printf("\n");
 655                 }
 656
 657                 on = ansi_highlight();
 658                 off = ansi_highlight_off();
 659                 if (!arg_no_legend)
 660                         printf("\n");
 661         } else {
 662                 on = ansi_highlight_red();
 663                 off = ansi_highlight_off();
 664         }
 665
 666         if (!arg_no_legend) {
 667                 printf("%s%u sockets listed.%s\n", on, cs, off);
 668                 if (!arg_all)
 669                         printf("Pass --all to see loaded but inactive sockets, too.\n");
 670         }
 671
 672         return 0;
 673 }
 674
 675 static int list_sockets(sd_bus *bus, char **args) {
 676         _cleanup_bus_message_unref_ sd_bus_message *reply = NULL;
 677         _cleanup_free_ UnitInfo *unit_infos = NULL;
 678         struct socket_info *socket_infos = NULL;
 679         const UnitInfo *u;
 680         struct socket_info *s;
 681         unsigned cs = 0;
 682         size_t size = 0;
 683         int r = 0, n;
 684
 685         pager_open_if_enabled();
 686
 687         n = get_unit_list(bus, &reply, &unit_infos);
 688         if (n < 0)
 689                 return n;
 690
 691         for (u = unit_infos; u < unit_infos + n; u++) {
 692                 _cleanup_strv_free_ char **listening = NULL, **triggered = NULL;
 693                 int i, c;
 694
 695                 if (!output_show_unit(u))
 696                         continue;
 697
 698                 if (!endswith(u->id, ".socket"))
 699                         continue;
 700
 701                 r = get_triggered_units(bus, u->unit_path, &triggered);
 702                 if (r < 0)
 703                         goto cleanup;
 704
 705                 c = get_listening(bus, u->unit_path, &listening);
 706                 if (c < 0) {
 707                         r = c;
 708                         goto cleanup;
 709                 }
 710
 711                 if (!GREEDY_REALLOC(socket_infos, size, cs + c)) {
 712                         r = log_oom();
 713                         goto cleanup;
 714                 }
 715
 716                 for (i = 0; i < c; i++)
 717                         socket_infos[cs + i] = (struct socket_info) {
 718                                 .id = u->id,
 719                                 .type = listening[i*2],
 720                                 .path = listening[i*2 + 1],
 721                                 .triggered = triggered,
 722                                 .own_triggered = i==0,
 723                         };
 724
 725                 /* from this point on we will cleanup those socket_infos */
 726                 cs += c;
 727                 free(listening);
 728                 listening = triggered = NULL; /* avoid cleanup */
 729         }
 730
 731         qsort_safe(socket_infos, cs, sizeof(struct socket_info),
 732                    (__compar_fn_t) socket_info_compare);
 733
 734         output_sockets_list(socket_infos, cs);
 735
 736  cleanup:
 737         assert(cs == 0 || socket_infos);
 738         for (s = socket_infos; s < socket_infos + cs; s++) {
 739                 free(s->type);
 740                 free(s->path);
 741                 if (s->own_triggered)
 742                         strv_free(s->triggered);
 743         }
 744         free(socket_infos);
 745
 746         return r;
 747 }
 748
 749 static int get_next_elapse(
 750                 sd_bus *bus,
 751                 const char *path,
 752                 dual_timestamp *next) {
 753
 754         _cleanup_bus_error_free_ sd_bus_error error = SD_BUS_ERROR_NULL;
 755         dual_timestamp t;
 756         int r;
 757
 758         assert(bus);
 759         assert(path);
 760         assert(next);
 761
 762         r = sd_bus_get_property_trivial(
 763                         bus,
 764                         "org.freedesktop.systemd1",
 765                         path,
 766                         "org.freedesktop.systemd1.Timer",
 767                         "NextElapseUSecMonotonic",
 768                         &error,
 769                         't',
 770                         &t.monotonic);
 771         if (r < 0) {
 772                 log_error("Failed to get next elapsation time: %s", bus_error_message(&error, r));
 773                 return r;
 774         }
 775
 776         r = sd_bus_get_property_trivial(
 777                         bus,
 778                         "org.freedesktop.systemd1",
 779                         path,
 780                         "org.freedesktop.systemd1.Timer",
 781                         "NextElapseUSecRealtime",
 782                         &error,
 783                         't',
 784                         &t.realtime);
 785         if (r < 0) {
 786                 log_error("Failed to get next elapsation time: %s", bus_error_message(&error, r));
 787                 return r;
 788         }
 789
 790         *next = t;
 791         return 0;
 792 }
 793
 794 struct timer_info {
 795         const char* id;
 796         usec_t next_elapse;
 797         char** triggered;
 798 };
 799
 800 static int timer_info_compare(const struct timer_info *a, const struct timer_info *b) {
 801         assert(a);
 802         assert(b);
 803
 804         if (a->next_elapse < b->next_elapse)
 805                 return -1;
 806         if (a->next_elapse > b->next_elapse)
 807                 return 1;
 808
 809         return strcmp(a->id, b->id);
 810 }
 811
 812 static int output_timers_list(struct timer_info *timer_infos, unsigned n) {
 813         struct timer_info *t;
 814         unsigned
 815                 nextlen = sizeof("NEXT") - 1,
 816                 leftlen = sizeof("LEFT") - 1,
 817                 unitlen = sizeof("UNIT") - 1,
 818                 activatelen = sizeof("ACTIVATES") - 1;
 819
 820         const char *on, *off;
 821
 822         assert(timer_infos || n == 0);
 823
 824         for (t = timer_infos; t < timer_infos + n; t++) {
 825                 unsigned ul = 0;
 826                 char **a;
 827
 828                 if (t->next_elapse > 0) {
 829                         char tstamp[FORMAT_TIMESTAMP_MAX] = "", trel[FORMAT_TIMESTAMP_RELATIVE_MAX] = "";
 830
 831                         format_timestamp(tstamp, sizeof(tstamp), t->next_elapse);
 832                         nextlen = MAX(nextlen, strlen(tstamp) + 1);
 833
 834                         format_timestamp_relative(trel, sizeof(trel), t->next_elapse);
 835                         leftlen = MAX(leftlen, strlen(trel));
 836                 }
 837
 838                 unitlen = MAX(unitlen, strlen(t->id));
 839
 840                 STRV_FOREACH(a, t->triggered)
 841                         ul += strlen(*a) + 2*(a != t->triggered);
 842                 activatelen = MAX(activatelen, ul);
 843         }
 844
 845         if (n > 0) {
 846                 if (!arg_no_legend)
 847                         printf("%-*s %-*s %-*s %s\n",
 848                                nextlen, "NEXT",
 849                                leftlen, "LEFT",
 850                                unitlen, "UNIT",
 851                                         "ACTIVATES");
 852
 853                 for (t = timer_infos; t < timer_infos + n; t++) {
 854                         char tstamp[FORMAT_TIMESTAMP_MAX] = "n/a", trel[FORMAT_TIMESTAMP_RELATIVE_MAX] = "n/a";
 855                         char **a;
 856
 857                         format_timestamp(tstamp, sizeof(tstamp), t->next_elapse);
 858                         format_timestamp_relative(trel, sizeof(trel), t->next_elapse);
 859
 860                         printf("%-*s %-*s %-*s",
 861                                nextlen, tstamp, leftlen, trel, unitlen, t->id);
 862
 863                         STRV_FOREACH(a, t->triggered)
 864                                 printf("%s %s",
 865                                        a == t->triggered ? "" : ",", *a);
 866                         printf("\n");
 867                 }
 868
 869                 on = ansi_highlight();
 870                 off = ansi_highlight_off();
 871                 if (!arg_no_legend)
 872                         printf("\n");
 873         } else {
 874                 on = ansi_highlight_red();
 875                 off = ansi_highlight_off();
 876         }
 877
 878         if (!arg_no_legend) {
 879                 printf("%s%u timers listed.%s\n", on, n, off);
 880                 if (!arg_all)
 881                         printf("Pass --all to see loaded but inactive timers, too.\n");
 882         }
 883
 884         return 0;
 885 }
 886
 887 static int list_timers(sd_bus *bus, char **args) {
 888
 889         _cleanup_bus_message_unref_ sd_bus_message *reply = NULL;
 890         _cleanup_free_ struct timer_info *timer_infos = NULL;
 891         _cleanup_free_ UnitInfo *unit_infos = NULL;
 892         struct timer_info *t;
 893         const UnitInfo *u;
 894         size_t size = 0;
 895         int n, c = 0;
 896         dual_timestamp nw;
 897         int r = 0;
 898
 899         pager_open_if_enabled();
 900
 901         n = get_unit_list(bus, &reply, &unit_infos);
 902         if (n < 0)
 903                 return n;
 904
 905         dual_timestamp_get(&nw);
 906
 907         for (u = unit_infos; u < unit_infos + n; u++) {
 908                 _cleanup_strv_free_ char **triggered = NULL;
 909                 dual_timestamp next;
 910                 usec_t m;
 911
 912                 if (!output_show_unit(u))
 913                         continue;
 914
 915                 if (!endswith(u->id, ".timer"))
 916                         continue;
 917
 918                 r = get_triggered_units(bus, u->unit_path, &triggered);
 919                 if (r < 0)
 920                         goto cleanup;
 921
 922                 r = get_next_elapse(bus, u->unit_path, &next);
 923                 if (r < 0)
 924                         goto cleanup;
 925
 926                 if (next.monotonic != (usec_t) -1 && next.monotonic > 0) {
 927                         usec_t converted;
 928
 929                         if (next.monotonic > nw.monotonic)
 930                                 converted = nw.realtime + (next.monotonic - nw.monotonic);
 931                         else
 932                                 converted = nw.realtime - (nw.monotonic - next.monotonic);
 933
 934                         if (next.realtime != (usec_t) -1 && next.realtime > 0)
 935                                 m = MIN(converted, next.realtime);
 936                         else
 937                                 m = converted;
 938                 } else
 939                         m = next.realtime;
 940
 941                 if (!GREEDY_REALLOC(timer_infos, size, c+1)) {
 942                         r = log_oom();
 943                         goto cleanup;
 944                 }
 945
 946                 timer_infos[c++] = (struct timer_info) {
 947                         .id = u->id,
 948                         .next_elapse = m,
 949                         .triggered = triggered,
 950                 };
 951
 952                 triggered = NULL; /* avoid cleanup */
 953         }
 954
 955         qsort_safe(timer_infos, c, sizeof(struct timer_info),
 956                    (__compar_fn_t) timer_info_compare);
 957
 958         output_timers_list(timer_infos, c);
 959
 960  cleanup:
 961         for (t = timer_infos; t < timer_infos + c; t++)
 962                 strv_free(t->triggered);
 963
 964         return r;
 965 }
 966
 967 static int compare_unit_file_list(const void *a, const void *b) {
 968         const char *d1, *d2;
 969         const UnitFileList *u = a, *v = b;
 970
 971         d1 = strrchr(u->path, '.');
 972         d2 = strrchr(v->path, '.');
 973
 974         if (d1 && d2) {
 975                 int r;
 976
 977                 r = strcasecmp(d1, d2);
 978                 if (r != 0)
 979                         return r;
 980         }
 981
 982         return strcasecmp(path_get_file_name(u->path), path_get_file_name(v->path));
 983 }
 984
 985 static bool output_show_unit_file(const UnitFileList *u) {
 986         const char *dot;
 987
 988         return !arg_types || ((dot = strrchr(u->path, '.')) && strv_find(arg_types, dot+1));
 989 }
 990
 991 static void output_unit_file_list(const UnitFileList *units, unsigned c) {
 992         unsigned max_id_len, id_cols, state_cols, n_shown = 0;
 993         const UnitFileList *u;
 994
 995         max_id_len = sizeof("UNIT FILE")-1;
 996         state_cols = sizeof("STATE")-1;
 997
 998         for (u = units; u < units + c; u++) {
 999                 if (!output_show_unit_file(u))
1000                         continue;
1001
1002                 max_id_len = MAX(max_id_len, strlen(path_get_file_name(u->path)));
1003                 state_cols = MAX(state_cols, strlen(unit_file_state_to_string(u->state)));
1004         }
1005
1006         if (!arg_full) {
1007                 unsigned basic_cols;
1008
1009                 id_cols = MIN(max_id_len, 25u);
1010                 basic_cols = 1 + id_cols + state_cols;
1011                 if (basic_cols < (unsigned) columns())
1012                         id_cols += MIN(columns() - basic_cols, max_id_len - id_cols);
1013         } else
1014                 id_cols = max_id_len;
1015
1016         if (!arg_no_legend)
1017                 printf("%-*s %-*s\n",
1018                        id_cols, "UNIT FILE",
1019                        state_cols, "STATE");
1020
1021         for (u = units; u < units + c; u++) {
1022                 _cleanup_free_ char *e = NULL;
1023                 const char *on, *off;
1024                 const char *id;
1025
1026                 if (!output_show_unit_file(u))
1027                         continue;
1028
1029                 n_shown++;
1030
1031                 if (u->state == UNIT_FILE_MASKED ||
1032                     u->state == UNIT_FILE_MASKED_RUNTIME ||
1033                     u->state == UNIT_FILE_DISABLED ||
1034                     u->state == UNIT_FILE_INVALID) {
1035                         on  = ansi_highlight_red();
1036                         off = ansi_highlight_off();
1037                 } else if (u->state == UNIT_FILE_ENABLED) {
1038                         on  = ansi_highlight_green();
1039                         off = ansi_highlight_off();
1040                 } else
1041                         on = off = "";
1042
1043                 id = path_get_file_name(u->path);
1044
1045                 e = arg_full ? NULL : ellipsize(id, id_cols, 33);
1046
1047                 printf("%-*s %s%-*s%s\n",
1048                        id_cols, e ? e : id,
1049                        on, state_cols, unit_file_state_to_string(u->state), off);
1050         }
1051
1052         if (!arg_no_legend)
1053                 printf("\n%u unit files listed.\n", n_shown);
1054 }
1055
1056 static int list_unit_files(sd_bus *bus, char **args) {
1057         _cleanup_bus_message_unref_ sd_bus_message *reply = NULL;
1058         _cleanup_bus_error_free_ sd_bus_error error = SD_BUS_ERROR_NULL;
1059         _cleanup_free_ UnitFileList *units = NULL;
1060         unsigned c = 0;
1061         const char *state;
1062         char *path;
1063         int r;
1064
1065         pager_open_if_enabled();
1066
1067         if (avoid_bus()) {
1068                 Hashmap *h;
1069                 UnitFileList *u;
1070                 Iterator i;
1071                 unsigned n_units;
1072
1073                 h = hashmap_new(string_hash_func, string_compare_func);
1074                 if (!h)
1075                         return log_oom();
1076
1077                 r = unit_file_get_list(arg_scope, arg_root, h);
1078                 if (r < 0) {
1079                         unit_file_list_free(h);
1080                         log_error("Failed to get unit file list: %s", strerror(-r));
1081                         return r;
1082                 }
1083
1084                 n_units = hashmap_size(h);
1085                 units = new(UnitFileList, n_units);
1086                 if (!units) {
1087                         unit_file_list_free(h);
1088                         return log_oom();
1089                 }
1090
1091                 HASHMAP_FOREACH(u, h, i) {
1092                         memcpy(units + c++, u, sizeof(UnitFileList));
1093                         free(u);
1094                 }
1095
1096                 assert(c == n_units);
1097                 hashmap_free(h);
1098         } else {
1099                 size_t size = 0;
1100
1101                 r = sd_bus_call_method(
1102                                 bus,
1103                                 "org.freedesktop.systemd1",
1104                                 "/org/freedesktop/systemd1",
1105                                 "org.freedesktop.systemd1.Manager",
1106                                 "ListUnitFiles",
1107                                 &error,
1108                                 &reply,
1109                                 NULL);
1110                 if (r < 0) {
1111                         log_error("Failed to list unit files: %s", bus_error_message(&error, r));
1112                         return r;
1113                 }
1114
1115                 r = sd_bus_message_enter_container(reply, SD_BUS_TYPE_ARRAY, "(ss)");
1116                 if (r < 0)
1117                         return bus_log_parse_error(r);
1118
1119                 while ((r = sd_bus_message_read(reply, "(ss)", &path, &state)) > 0) {
1120
1121                         if (!GREEDY_REALLOC(units, size, c + 1))
1122                                 return log_oom();
1123
1124                         units[c++] = (struct UnitFileList) {
1125                                 path,
1126                                 unit_file_state_from_string(state)
1127                         };
1128                 }
1129                 if (r < 0)
1130                         return bus_log_parse_error(r);
1131
1132                 r = sd_bus_message_exit_container(reply);
1133                 if (r < 0)
1134                         return bus_log_parse_error(r);
1135         }
1136
1137         if (c > 0) {
1138                 qsort(units, c, sizeof(UnitFileList), compare_unit_file_list);
1139                 output_unit_file_list(units, c);
1140         }
1141
1142         return 0;
1143 }
1144
1145 static int list_dependencies_print(const char *name, int level, unsigned int branches, bool last) {
1146         _cleanup_free_ char *n = NULL;
1147         size_t max_len = MAX(columns(),20u);
1148         size_t len = 0;
1149         int i;
1150
1151         if (!arg_plain) {
1152
1153                 for (i = level - 1; i >= 0; i--) {
1154                         len += 2;
1155                         if (len > max_len - 3 && !arg_full) {
1156                                 printf("%s...\n",max_len % 2 ? "" : " ");
1157                                 return 0;
1158                         }
1159                         printf("%s", draw_special_char(branches & (1 << i) ? DRAW_TREE_VERT : DRAW_TREE_SPACE));
1160                 }
1161                 len += 2;
1162
1163                 if (len > max_len - 3 && !arg_full) {
1164                         printf("%s...\n",max_len % 2 ? "" : " ");
1165                         return 0;
1166                 }
1167
1168                 printf("%s", draw_special_char(last ? DRAW_TREE_RIGHT : DRAW_TREE_BRANCH));
1169         }
1170
1171         if (arg_full){
1172                 printf("%s\n", name);
1173                 return 0;
1174         }
1175
1176         n = ellipsize(name, max_len-len, 100);
1177         if (!n)
1178                 return log_oom();
1179
1180         printf("%s\n", n);
1181         return 0;
1182 }
1183
1184 static int list_dependencies_get_dependencies(sd_bus *bus, const char *name, char ***deps) {
1185
1186         static const char *dependencies[] = {
1187                 [DEPENDENCY_FORWARD] = "Requires\0"
1188                                        "RequiresOverridable\0"
1189                                        "Requisite\0"
1190                                        "RequisiteOverridable\0"
1191                                        "Wants\0",
1192                 [DEPENDENCY_REVERSE] = "RequiredBy\0"
1193                                        "RequiredByOverridable\0"
1194                                        "WantedBy\0"
1195                                        "PartOf\0",
1196                 [DEPENDENCY_AFTER]   = "After\0",
1197                 [DEPENDENCY_BEFORE]  = "Before\0",
1198         };
1199
1200         _cleanup_bus_error_free_ sd_bus_error error = SD_BUS_ERROR_NULL;
1201         _cleanup_bus_message_unref_ sd_bus_message *reply = NULL;
1202         _cleanup_strv_free_ char **ret = NULL;
1203         _cleanup_free_ char *path = NULL;
1204         int r;
1205
1206         assert(bus);
1207         assert(name);
1208         assert(deps);
1209         assert(arg_dependency < ELEMENTSOF(dependencies));
1210
1211         path = unit_dbus_path_from_name(name);
1212         if (!path)
1213                 return log_oom();
1214
1215         r = sd_bus_call_method(
1216                         bus,
1217                         "org.freedesktop.systemd1",
1218                         path,
1219                         "org.freedesktop.DBus.Properties",
1220                         "GetAll",
1221                         &error,
1222                         &reply,
1223                         "s", "org.freedesktop.systemd1.Unit");
1224         if (r < 0) {
1225                 log_error("Failed to get properties of %s: %s", name, bus_error_message(&error, r));
1226                 return r;
1227         }
1228
1229         r = sd_bus_message_enter_container(reply, SD_BUS_TYPE_ARRAY, "{sv}");
1230         if (r < 0)
1231                 return bus_log_parse_error(r);
1232
1233         while ((r = sd_bus_message_enter_container(reply, SD_BUS_TYPE_DICT_ENTRY, "sv")) > 0) {
1234                 const char *prop;
1235
1236                 r = sd_bus_message_read(reply, "s", &prop);
1237                 if (r < 0)
1238                         return bus_log_parse_error(r);
1239
1240                 if (!nulstr_contains(dependencies[arg_dependency], prop)) {
1241                         r = sd_bus_message_skip(reply, "v");
1242                         if (r < 0)
1243                                 return bus_log_parse_error(r);
1244                 } else {
1245
1246                         r = sd_bus_message_enter_container(reply, SD_BUS_TYPE_VARIANT, "as");
1247                         if (r < 0)
1248                                 return bus_log_parse_error(r);
1249
1250                         r = bus_message_read_strv_extend(reply, &ret);
1251                         if (r < 0)
1252                                 return bus_log_parse_error(r);
1253
1254                         r = sd_bus_message_exit_container(reply);
1255                         if (r < 0)
1256                                 return bus_log_parse_error(r);
1257                 }
1258
1259                 r = sd_bus_message_exit_container(reply);
1260                 if (r < 0)
1261                         return bus_log_parse_error(r);
1262
1263         }
1264         if (r < 0)
1265                 return bus_log_parse_error(r);
1266
1267         r = sd_bus_message_exit_container(reply);
1268         if (r < 0)
1269                 return bus_log_parse_error(r);
1270
1271         *deps = ret;
1272         ret = NULL;
1273
1274         return 0;
1275 }
1276
1277 static int list_dependencies_compare(const void *_a, const void *_b) {
1278         const char **a = (const char**) _a, **b = (const char**) _b;
1279
1280         if (unit_name_to_type(*a) == UNIT_TARGET && unit_name_to_type(*b) != UNIT_TARGET)
1281                 return 1;
1282         if (unit_name_to_type(*a) != UNIT_TARGET && unit_name_to_type(*b) == UNIT_TARGET)
1283                 return -1;
1284
1285         return strcasecmp(*a, *b);
1286 }
1287
1288 static int list_dependencies_one(
1289                 sd_bus *bus,
1290                 const char *name,
1291                 int level,
1292                 char ***units,
1293                 unsigned int branches) {
1294
1295         _cleanup_strv_free_ char **deps = NULL, **u;
1296         char **c;
1297         int r = 0;
1298
1299         assert(bus);
1300         assert(name);
1301         assert(units);
1302
1303         u = strv_append(*units, name);
1304         if (!u)
1305                 return log_oom();
1306
1307         r = list_dependencies_get_dependencies(bus, name, &deps);
1308         if (r < 0)
1309                 return r;
1310
1311         qsort_safe(deps, strv_length(deps), sizeof (char*), list_dependencies_compare);
1312
1313         STRV_FOREACH(c, deps) {
1314                 int state;
1315
1316                 if (strv_contains(u, *c)) {
1317                         if (!arg_plain) {
1318                                 r = list_dependencies_print("...", level + 1, (branches << 1) | (c[1] == NULL ? 0 : 1), 1);
1319                                 if (r < 0)
1320                                         return r;
1321                         }
1322                         continue;
1323                 }
1324
1325                 state = check_one_unit(bus, *c, "activating\0active\0reloading\0", true);
1326                 if (state > 0)
1327                         printf("%s%s%s", ansi_highlight_green(), draw_special_char(DRAW_BLACK_CIRCLE), ansi_highlight_off());
1328                 else
1329                         printf("%s%s%s", ansi_highlight_red(), draw_special_char(DRAW_BLACK_CIRCLE), ansi_highlight_off());
1330
1331                 r = list_dependencies_print(*c, level, branches, c[1] == NULL);
1332                 if (r < 0)
1333                         return r;
1334
1335                 if (arg_all || unit_name_to_type(*c) == UNIT_TARGET) {
1336                        r = list_dependencies_one(bus, *c, level + 1, &u, (branches << 1) | (c[1] == NULL ? 0 : 1));
1337                        if (r < 0)
1338                                return r;
1339                 }
1340         }
1341
1342         if (arg_plain) {
1343                 strv_free(*units);
1344                 *units = u;
1345                 u = NULL;
1346         }
1347
1348         return 0;
1349 }
1350
1351 static int list_dependencies(sd_bus *bus, char **args) {
1352         _cleanup_strv_free_ char **units = NULL;
1353         _cleanup_free_ char *unit = NULL;
1354         const char *u;
1355
1356         assert(bus);
1357
1358         if (args[1]) {
1359                 unit = unit_name_mangle(args[1]);
1360                 if (!unit)
1361                         return log_oom();
1362                 u = unit;
1363         } else
1364                 u = SPECIAL_DEFAULT_TARGET;
1365
1366         pager_open_if_enabled();
1367
1368         puts(u);
1369
1370         return list_dependencies_one(bus, u, 0, &units, 0);
1371 }
1372
1373 static int get_default(sd_bus *bus, char **args) {
1374         _cleanup_bus_message_unref_ sd_bus_message *reply = NULL;
1375         _cleanup_bus_error_free_ sd_bus_error error = SD_BUS_ERROR_NULL;
1376         _cleanup_free_ char *_path = NULL;
1377         const char *path;
1378         int r;
1379
1380         if (!bus || avoid_bus()) {
1381                 r = unit_file_get_default(arg_scope, arg_root, &_path);
1382                 if (r < 0) {
1383                         log_error("Failed to get default target: %s", strerror(-r));
1384                         return r;
1385                 }
1386                 path = _path;
1387
1388         } else {
1389                 r = sd_bus_call_method(
1390                                 bus,
1391                                 "org.freedesktop.systemd1",
1392                                 "/org/freedesktop/systemd1",
1393                                 "org.freedesktop.systemd1.Manager",
1394                                 "GetDefaultTarget",
1395                                 &error,
1396                                 &reply,
1397                                 NULL);
1398                 if (r < 0) {
1399                         log_error("Failed to get default target: %s", bus_error_message(&error, -r));
1400                         return r;
1401                 }
1402
1403                 r = sd_bus_message_read(reply, "s", &path);
1404                 if (r < 0)
1405                         return bus_log_parse_error(r);
1406         }
1407
1408         if (path)
1409                 printf("%s\n", path);
1410
1411         return 0;
1412 }
1413
1414 static void dump_unit_file_changes(const UnitFileChange *changes, unsigned n_changes) {
1415         unsigned i;
1416
1417         assert(changes || n_changes == 0);
1418
1419         for (i = 0; i < n_changes; i++) {
1420                 if (changes[i].type == UNIT_FILE_SYMLINK)
1421                         log_info("ln -s '%s' '%s'", changes[i].source, changes[i].path);
1422                 else
1423                         log_info("rm '%s'", changes[i].path);
1424         }
1425 }
1426
1427 static int deserialize_and_dump_unit_file_changes(sd_bus_message *m) {
1428         const char *type, *path, *source;
1429         int r;
1430
1431         r = sd_bus_message_enter_container(m, SD_BUS_TYPE_ARRAY, "(sss)");
1432         if (r < 0)
1433                 return bus_log_parse_error(r);
1434
1435         while ((r = sd_bus_message_read(m, "(sss)", &type, &path, &source)) > 0) {
1436                 if (!arg_quiet) {
1437                         if (streq(type, "symlink"))
1438                                 log_info("ln -s '%s' '%s'", source, path);
1439                         else
1440                                 log_info("rm '%s'", path);
1441                 }
1442         }
1443         if (r < 0)
1444                 return bus_log_parse_error(r);
1445
1446         r = sd_bus_message_exit_container(m);
1447         if (r < 0)
1448                 return bus_log_parse_error(r);
1449
1450         return 0;
1451 }
1452
1453 static int set_default(sd_bus *bus, char **args) {
1454         _cleanup_free_ char *unit = NULL;
1455         UnitFileChange *changes = NULL;
1456         unsigned n_changes = 0;
1457         int r;
1458
1459         unit = unit_name_mangle_with_suffix(args[1], ".target");
1460         if (!unit)
1461                 return log_oom();
1462
1463         if (!bus || avoid_bus()) {
1464                 r = unit_file_set_default(arg_scope, arg_root, unit, arg_force, &changes, &n_changes);
1465                 if (r < 0) {
1466                         log_error("Failed to set default target: %s", strerror(-r));
1467                         return r;
1468                 }
1469
1470                 if (!arg_quiet)
1471                         dump_unit_file_changes(changes, n_changes);
1472
1473                 r = 0;
1474         } else {
1475                 _cleanup_bus_message_unref_ sd_bus_message *reply = NULL;
1476                 _cleanup_bus_error_free_ sd_bus_error error = SD_BUS_ERROR_NULL;
1477
1478                 r = sd_bus_call_method(
1479                                 bus,
1480                                 "org.freedesktop.systemd1",
1481                                 "/org/freedesktop/systemd1",
1482                                 "org.freedesktop.systemd1.Manager",
1483                                 "SetDefaultTarget",
1484                                 &error,
1485                                 &reply,
1486                                 "sb", unit, arg_force);
1487                 if (r < 0) {
1488                         log_error("Failed to set default target: %s", bus_error_message(&error, -r));
1489                         return r;
1490                 }
1491
1492                 r = deserialize_and_dump_unit_file_changes(reply);
1493                 if (r < 0)
1494                         return r;
1495
1496                 /* Try to reload if enabeld */
1497                 if (!arg_no_reload)
1498                         r = daemon_reload(bus, args);
1499                 else
1500                         r = 0;
1501         }
1502
1503         unit_file_changes_free(changes, n_changes);
1504
1505         return r;
1506 }
1507
1508 struct job_info {
1509         uint32_t id;
1510         const char *name, *type, *state;
1511 };
1512
1513 static void output_jobs_list(const struct job_info* jobs, unsigned n) {
1514         unsigned id_len, unit_len, type_len, state_len;
1515         const struct job_info *j;
1516         const char *on, *off;
1517         bool shorten = false;
1518
1519         assert(n == 0 || jobs);
1520
1521         if (n == 0) {
1522                 on = ansi_highlight_green();
1523                 off = ansi_highlight_off();
1524
1525                 printf("%sNo jobs running.%s\n", on, off);
1526                 return;
1527         }
1528
1529         pager_open_if_enabled();
1530
1531         id_len = sizeof("JOB")-1;
1532         unit_len = sizeof("UNIT")-1;
1533         type_len = sizeof("TYPE")-1;
1534         state_len = sizeof("STATE")-1;
1535
1536         for (j = jobs; j < jobs + n; j++) {
1537                 uint32_t id = j->id;
1538                 assert(j->name && j->type && j->state);
1539
1540                 id_len = MAX(id_len, DECIMAL_STR_WIDTH(id));
1541                 unit_len = MAX(unit_len, strlen(j->name));
1542                 type_len = MAX(type_len, strlen(j->type));
1543                 state_len = MAX(state_len, strlen(j->state));
1544         }
1545
1546         if (!arg_full && id_len + 1 + unit_len + type_len + 1 + state_len > columns()) {
1547                 unit_len = MAX(33u, columns() - id_len - type_len - state_len - 3);
1548                 shorten = true;
1549         }
1550
1551         if (!arg_no_legend)
1552                 printf("%*s %-*s %-*s %-*s\n",
1553                        id_len, "JOB",
1554                        unit_len, "UNIT",
1555                        type_len, "TYPE",
1556                        state_len, "STATE");
1557
1558         for (j = jobs; j < jobs + n; j++) {
1559                 _cleanup_free_ char *e = NULL;
1560
1561                 if (streq(j->state, "running")) {
1562                         on = ansi_highlight();
1563                         off = ansi_highlight_off();
1564                 } else
1565                         on = off = "";
1566
1567                 e = shorten ? ellipsize(j->name, unit_len, 33) : NULL;
1568                 printf("%*u %s%-*s%s %-*s %s%-*s%s\n",
1569                        id_len, j->id,
1570                        on, unit_len, e ? e : j->name, off,
1571                        type_len, j->type,
1572                        on, state_len, j->state, off);
1573         }
1574
1575         if (!arg_no_legend) {
1576                 on = ansi_highlight();
1577                 off = ansi_highlight_off();
1578
1579                 printf("\n%s%u jobs listed%s.\n", on, n, off);
1580         }
1581 }
1582
1583 static int list_jobs(sd_bus *bus, char **args) {
1584         _cleanup_bus_error_free_ sd_bus_error error = SD_BUS_ERROR_NULL;
1585         _cleanup_bus_message_unref_ sd_bus_message *reply = NULL;
1586         const char *name, *type, *state, *job_path, *unit_path;
1587         _cleanup_free_ struct job_info *jobs = NULL;
1588         size_t size = 0;
1589         unsigned c = 0;
1590         uint32_t id;
1591         int r;
1592
1593         r = sd_bus_call_method(
1594                         bus,
1595                         "org.freedesktop.systemd1",
1596                         "/org/freedesktop/systemd1",
1597                         "org.freedesktop.systemd1.Manager",
1598                         "ListJobs",
1599                         &error,
1600                         &reply,
1601                         NULL);
1602         if (r < 0) {
1603                 log_error("Failed to list jobs: %s", bus_error_message(&error, r));
1604                 return r;
1605         }
1606
1607         r = sd_bus_message_enter_container(reply, 'a', "(usssoo)");
1608         if (r < 0)
1609                 return bus_log_parse_error(r);
1610
1611         while ((r = sd_bus_message_read(reply, "(usssoo)", &id, &name, &type, &state, &job_path, &unit_path)) > 0) {
1612
1613                 if (!GREEDY_REALLOC(jobs, size, c + 1))
1614                         return log_oom();
1615
1616                 jobs[c++] = (struct job_info) {
1617                         id,
1618                         name,
1619                         type,
1620                         state
1621                 };
1622         }
1623         if (r < 0)
1624                 return bus_log_parse_error(r);
1625
1626         r = sd_bus_message_exit_container(reply);
1627         if (r < 0)
1628                 return bus_log_parse_error(r);
1629
1630         output_jobs_list(jobs, c);
1631         return r;
1632 }
1633
1634 static int cancel_job(sd_bus *bus, char **args) {
1635         _cleanup_bus_error_free_ sd_bus_error error = SD_BUS_ERROR_NULL;
1636         char **name;
1637
1638         assert(args);
1639
1640         if (strv_length(args) <= 1)
1641                 return daemon_reload(bus, args);
1642
1643         STRV_FOREACH(name, args+1) {
1644                 uint32_t id;
1645                 int r;
1646
1647                 r = safe_atou32(*name, &id);
1648                 if (r < 0) {
1649                         log_error("Failed to parse job id \"%s\": %s", *name, strerror(-r));
1650                         return r;
1651                 }
1652
1653                 r = sd_bus_call_method(
1654                                 bus,
1655                                 "org.freedesktop.systemd1",
1656                                 "/org/freedesktop/systemd1",
1657                                 "org.freedesktop.systemd1.Manager",
1658                                 "CancelJob",
1659                                 &error,
1660                                 NULL,
1661                                 "u", id);
1662                 if (r < 0) {
1663                         log_error("Failed to cancel job %u: %s", (unsigned) id, bus_error_message(&error, r));
1664                         return r;
1665                 }
1666         }
1667
1668         return 0;
1669 }
1670
1671 static int need_daemon_reload(sd_bus *bus, const char *unit) {
1672         _cleanup_bus_message_unref_ sd_bus_message *reply = NULL;
1673         _cleanup_free_ char *n = NULL;
1674         const char *path;
1675         int b, r;
1676
1677         /* We ignore all errors here, since this is used to show a
1678          * warning only */
1679
1680         n = unit_name_mangle(unit);
1681         if (!n)
1682                 return -ENOMEM;
1683
1684         /* We don't use unit_dbus_path_from_name() directly since we
1685          * don't want to load the unit if it isn't loaded. */
1686
1687         r = sd_bus_call_method(
1688                         bus,
1689                         "org.freedesktop.systemd1",
1690                         "/org/freedesktop/systemd1",
1691                         "org.freedesktop.systemd1.Manager",
1692                         "GetUnit",
1693                         NULL,
1694                         &reply,
1695                         "s", n);
1696         if (r < 0)
1697                 return r;
1698
1699         r = sd_bus_message_read(reply, "o", &path);
1700         if (r < 0)
1701                 return r;
1702
1703         r = sd_bus_get_property_trivial(
1704                         bus,
1705                         "org.freedesktop.systemd1",
1706                         path,
1707                         "org.freedesktop.systemd1.Unit",
1708                         "NeedDaemonReload",
1709                         NULL,
1710                         'b', &b);
1711         if (r < 0)
1712                 return r;
1713
1714         return b;
1715 }
1716
1717 typedef struct WaitData {
1718         Set *set;
1719
1720         char *name;
1721         char *result;
1722 } WaitData;
1723
1724 static int wait_filter(sd_bus *bus, sd_bus_message *m, void *data, sd_bus_error *error) {
1725         WaitData *d = data;
1726
1727         assert(bus);
1728         assert(m);
1729         assert(d);
1730
1731         log_debug("Got D-Bus request: %s.%s() on %s",
1732                   sd_bus_message_get_interface(m),
1733                   sd_bus_message_get_member(m),
1734                   sd_bus_message_get_path(m));
1735
1736         if (sd_bus_message_is_signal(m, "org.freedesktop.DBus.Local", "Disconnected")) {
1737                 log_error("Warning! D-Bus connection terminated.");
1738                 sd_bus_close(bus);
1739         } else if (sd_bus_message_is_signal(m, "org.freedesktop.systemd1.Manager", "JobRemoved")) {
1740                 uint32_t id;
1741                 const char *path, *result, *unit;
1742                 char *ret;
1743                 int r;
1744
1745                 r = sd_bus_message_read(m, "uoss", &id, &path, &unit, &result);
1746                 if (r >= 0) {
1747                         ret = set_remove(d->set, (char*) path);
1748                         if (!ret)
1749                                 return 0;
1750
1751                         free(ret);
1752
1753                         if (!isempty(result))
1754                                 d->result = strdup(result);
1755
1756                         if (!isempty(unit))
1757                                 d->name = strdup(unit);
1758
1759                         return 0;
1760                 }
1761 #ifndef NOLEGACY
1762                 r = sd_bus_message_read(m, "uos", &id, &path, &result);
1763                 if (r >= 0) {
1764                         ret = set_remove(d->set, (char*) path);
1765                         if (!ret)
1766                                 return 0;
1767
1768                         free(ret);
1769
1770                         if (*result)
1771                                 d->result = strdup(result);
1772
1773                         return 0;
1774                 }
1775 #endif
1776
1777                 bus_log_parse_error(r);
1778         }
1779
1780         return 0;
1781 }
1782
1783 static int enable_wait_for_jobs(sd_bus *bus) {
1784         int r;
1785
1786         assert(bus);
1787
1788         r = sd_bus_add_match(
1789                         bus,
1790                         "type='signal',"
1791                         "sender='org.freedesktop.systemd1',"
1792                         "interface='org.freedesktop.systemd1.Manager',"
1793                         "member='JobRemoved',"
1794                         "path='/org/freedesktop/systemd1'",
1795                         NULL, NULL);
1796         if (r < 0) {
1797                 log_error("Failed to add match");
1798                 return -EIO;
1799         }
1800
1801         /* This is slightly dirty, since we don't undo the match registrations. */
1802         return 0;
1803 }
1804
1805 static int wait_for_jobs(sd_bus *bus, Set *s) {
1806         WaitData d = { .set = s };
1807         int r;
1808
1809         assert(bus);
1810         assert(s);
1811
1812         r = sd_bus_add_filter(bus, wait_filter, &d);
1813         if (r < 0)
1814                 return log_oom();
1815
1816         while (!set_isempty(s)) {
1817                 for (;;) {
1818                         r = sd_bus_process(bus, NULL);
1819                         if (r < 0)
1820                                 return r;
1821                         if (r > 0)
1822                                 break;
1823                         r = sd_bus_wait(bus, (uint64_t) -1);
1824                         if (r < 0)
1825                                 return r;
1826                 }
1827
1828                 if (!d.result)
1829                         goto free_name;
1830
1831                 if (!arg_quiet) {
1832                         if (streq(d.result, "timeout"))
1833                                 log_error("Job for %s timed out.", strna(d.name));
1834                         else if (streq(d.result, "canceled"))
1835                                 log_error("Job for %s canceled.", strna(d.name));
1836                         else if (streq(d.result, "dependency"))
1837                                 log_error("A dependency job for %s failed. See 'journalctl -xn' for details.", strna(d.name));
1838                         else if (!streq(d.result, "done") && !streq(d.result, "skipped"))
1839                                 log_error("Job for %s failed. See 'systemctl status %s' and 'journalctl -xn' for details.", strna(d.name), strna(d.name));
1840                 }
1841
1842                 if (streq_ptr(d.result, "timeout"))
1843                         r = -ETIME;
1844                 else if (streq_ptr(d.result, "canceled"))
1845                         r = -ECANCELED;
1846                 else if (!streq_ptr(d.result, "done") && !streq_ptr(d.result, "skipped"))
1847                         r = -EIO;
1848
1849                 free(d.result);
1850                 d.result = NULL;
1851
1852         free_name:
1853                 free(d.name);
1854                 d.name = NULL;
1855         }
1856
1857         return sd_bus_remove_filter(bus, wait_filter, &d);
1858 }
1859
1860 static int check_one_unit(sd_bus *bus, const char *name, const char *good_states, bool quiet) {
1861         _cleanup_bus_message_unref_ sd_bus_message *reply = NULL;
1862         _cleanup_free_ char *n = NULL, *state = NULL;
1863         const char *path;
1864         int r;
1865
1866         assert(name);
1867
1868         n = unit_name_mangle(name);
1869         if (!n)
1870                 return log_oom();
1871
1872         /* We don't use unit_dbus_path_from_name() directly since we
1873          * don't want to load the unit if it isn't loaded. */
1874
1875         r = sd_bus_call_method(
1876                         bus,
1877                         "org.freedesktop.systemd1",
1878                         "/org/freedesktop/systemd1",
1879                         "org.freedesktop.systemd1.Manager",
1880                         "GetUnit",
1881                         NULL,
1882                         &reply,
1883                         "s", n);
1884         if (r < 0) {
1885                 if (!quiet)
1886                         puts("unknown");
1887                 return 0;
1888         }
1889
1890         r = sd_bus_message_read(reply, "o", &path);
1891         if (r < 0)
1892                 return bus_log_parse_error(r);
1893
1894         r = sd_bus_get_property_string(
1895                         bus,
1896                         "org.freedesktop.systemd1",
1897                         path,
1898                         "org.freedesktop.systemd1.Unit",
1899                         "ActiveState",
1900                         NULL,
1901                         &state);
1902         if (r < 0) {
1903                 if (!quiet)
1904                         puts("unknown");
1905                 return 0;
1906         }
1907
1908         if (!quiet)
1909                 puts(state);
1910
1911         return nulstr_contains(good_states, state);
1912 }
1913
1914 static int check_triggering_units(
1915                 sd_bus *bus,
1916                 const char *name) {
1917
1918         _cleanup_bus_error_free_ sd_bus_error error = SD_BUS_ERROR_NULL;
1919         _cleanup_free_ char *path = NULL, *n = NULL, *state = NULL;
1920         _cleanup_strv_free_ char **triggered_by = NULL;
1921         bool print_warning_label = true;
1922         char **i;
1923         int r;
1924
1925         n = unit_name_mangle(name);
1926         if (!n)
1927                 return log_oom();
1928
1929         path = unit_dbus_path_from_name(n);
1930         if (!path)
1931                 return log_oom();
1932
1933         r = sd_bus_get_property_string(
1934                         bus,
1935                         "org.freedesktop.systemd1",
1936                         path,
1937                         "org.freedesktop.systemd1.Unit",
1938                         "LoadState",
1939                         &error,
1940                         &state);
1941         if (r < 0) {
1942                 log_error("Failed to get load state of %s: %s", n, bus_error_message(&error, r));
1943                 return r;
1944         }
1945
1946         if (streq(state, "masked"))
1947                 return 0;
1948
1949         r = sd_bus_get_property_strv(
1950                         bus,
1951                         "org.freedesktop.systemd1",
1952                         path,
1953                         "org.freedesktop.systemd1.Unit",
1954                         "TriggeredBy",
1955                         &error,
1956                         &triggered_by);
1957         if (r < 0) {
1958                 log_error("Failed to get triggered by array of %s: %s", n, bus_error_message(&error, r));
1959                 return r;
1960         }
1961
1962         STRV_FOREACH(i, triggered_by) {
1963                 r = check_one_unit(bus, *i, "active\0reloading\0", true);
1964                 if (r < 0) {
1965                         log_error("Failed to check unit: %s", strerror(-r));
1966                         return r;
1967                 }
1968
1969                 if (r == 0)
1970                         continue;
1971
1972                 if (print_warning_label) {
1973                         log_warning("Warning: Stopping %s, but it can still be activated by:", n);
1974                         print_warning_label = false;
1975                 }
1976
1977                 log_warning("  %s", *i);
1978         }
1979
1980         return 0;
1981 }
1982
1983 static int start_unit_one(
1984                 sd_bus *bus,
1985                 const char *method,
1986                 const char *name,
1987                 const char *mode,
1988                 sd_bus_error *error,
1989                 Set *s) {
1990
1991         _cleanup_bus_message_unref_ sd_bus_message *reply = NULL;
1992         _cleanup_free_ char *n;
1993         const char *path;
1994         int r;
1995
1996         assert(method);
1997         assert(name);
1998         assert(mode);
1999         assert(error);
2000
2001         n = unit_name_mangle(name);
2002         if (!n)
2003                 return log_oom();
2004
2005         r = sd_bus_call_method(
2006                         bus,
2007                         "org.freedesktop.systemd1",
2008                         "/org/freedesktop/systemd1",
2009                         "org.freedesktop.systemd1.Manager",
2010                         method,
2011                         error,
2012                         &reply,
2013                         "ss", n, mode);
2014         if (r < 0) {
2015                 if (r == -ENOENT && arg_action != ACTION_SYSTEMCTL)
2016                         /* There's always a fallback possible for
2017                          * legacy actions. */
2018                         return -EADDRNOTAVAIL;
2019
2020                 log_error("Failed to start %s: %s", name, bus_error_message(error, r));
2021                 return r;
2022         }
2023
2024         r = sd_bus_message_read(reply, "o", &path);
2025         if (r < 0)
2026                 return bus_log_parse_error(r);
2027
2028         if (need_daemon_reload(bus, n) > 0)
2029                 log_warning("Warning: Unit file of %s changed on disk, 'systemctl%s daemon-reload' recommended.",
2030                             n, arg_scope == UNIT_FILE_SYSTEM ? "" : " --user");
2031
2032         if (s) {
2033                 char *p;
2034
2035                 p = strdup(path);
2036                 if (!p)
2037                         return log_oom();
2038
2039                 r = set_consume(s, p);
2040                 if (r < 0)
2041                         return log_oom();
2042         }
2043
2044         return 0;
2045 }
2046
2047 static const struct {
2048         const char *target;
2049         const char *verb;
2050         const char *mode;
2051 } action_table[_ACTION_MAX] = {
2052         [ACTION_HALT]         = { SPECIAL_HALT_TARGET,         "halt",         "replace-irreversibly" },
2053         [ACTION_POWEROFF]     = { SPECIAL_POWEROFF_TARGET,     "poweroff",     "replace-irreversibly" },
2054         [ACTION_REBOOT]       = { SPECIAL_REBOOT_TARGET,       "reboot",       "replace-irreversibly" },
2055         [ACTION_KEXEC]        = { SPECIAL_KEXEC_TARGET,        "kexec",        "replace-irreversibly" },
2056         [ACTION_RUNLEVEL2]    = { SPECIAL_RUNLEVEL2_TARGET,    NULL,           "isolate" },
2057         [ACTION_RUNLEVEL3]    = { SPECIAL_RUNLEVEL3_TARGET,    NULL,           "isolate" },
2058         [ACTION_RUNLEVEL4]    = { SPECIAL_RUNLEVEL4_TARGET,    NULL,           "isolate" },
2059         [ACTION_RUNLEVEL5]    = { SPECIAL_RUNLEVEL5_TARGET,    NULL,           "isolate" },
2060         [ACTION_RESCUE]       = { SPECIAL_RESCUE_TARGET,       "rescue",       "isolate" },
2061         [ACTION_EMERGENCY]    = { SPECIAL_EMERGENCY_TARGET,    "emergency",    "isolate" },
2062         [ACTION_DEFAULT]      = { SPECIAL_DEFAULT_TARGET,      "default",      "isolate" },
2063         [ACTION_EXIT]         = { SPECIAL_EXIT_TARGET,         "exit",         "replace-irreversibly" },
2064         [ACTION_SUSPEND]      = { SPECIAL_SUSPEND_TARGET,      "suspend",      "replace-irreversibly" },
2065         [ACTION_HIBERNATE]    = { SPECIAL_HIBERNATE_TARGET,    "hibernate",    "replace-irreversibly" },
2066         [ACTION_HYBRID_SLEEP] = { SPECIAL_HYBRID_SLEEP_TARGET, "hybrid-sleep", "replace-irreversibly" },
2067 };
2068
2069 static enum action verb_to_action(const char *verb) {
2070         enum action i;
2071
2072         for (i = _ACTION_INVALID; i < _ACTION_MAX; i++)
2073                 if (streq_ptr(action_table[i].verb, verb))
2074                         return i;
2075
2076         return _ACTION_INVALID;
2077 }
2078
2079 static int start_unit(sd_bus *bus, char **args) {
2080         _cleanup_bus_error_free_ sd_bus_error error = SD_BUS_ERROR_NULL;
2081         _cleanup_set_free_free_ Set *s = NULL;
2082         const char *method, *mode, *one_name;
2083         char **name;
2084         int r;
2085
2086         assert(bus);
2087
2088         ask_password_agent_open_if_enabled();
2089
2090         if (arg_action == ACTION_SYSTEMCTL) {
2091                 enum action action;
2092                 method =
2093                         streq(args[0], "stop") ||
2094                         streq(args[0], "condstop")              ? "StopUnit" :
2095                         streq(args[0], "reload")                ? "ReloadUnit" :
2096                         streq(args[0], "restart")               ? "RestartUnit" :
2097
2098                         streq(args[0], "try-restart")           ||
2099                         streq(args[0], "condrestart")           ? "TryRestartUnit" :
2100
2101                         streq(args[0], "reload-or-restart")     ? "ReloadOrRestartUnit" :
2102
2103                         streq(args[0], "reload-or-try-restart") ||
2104                         streq(args[0], "condreload")            ||
2105                         streq(args[0], "force-reload")          ? "ReloadOrTryRestartUnit" :
2106                                                                   "StartUnit";
2107                 action = verb_to_action(args[0]);
2108
2109                 mode = streq(args[0], "isolate") ? "isolate" :
2110                        action_table[action].mode ?: arg_job_mode;
2111
2112                 one_name = action_table[action].target;
2113         } else {
2114                 assert(arg_action < ELEMENTSOF(action_table));
2115                 assert(action_table[arg_action].target);
2116
2117                 method = "StartUnit";
2118
2119                 mode = action_table[arg_action].mode;
2120                 one_name = action_table[arg_action].target;
2121         }
2122
2123         if (!arg_no_block) {
2124                 r = enable_wait_for_jobs(bus);
2125                 if (r < 0) {
2126                         log_error("Could not watch jobs: %s", strerror(-r));
2127                         return r;
2128                 }
2129
2130                 s = set_new(string_hash_func, string_compare_func);
2131                 if (!s)
2132                         return log_oom();
2133         }
2134
2135         if (one_name) {
2136                 r = start_unit_one(bus, method, one_name, mode, &error, s);
2137                 if (r < 0)
2138                         r = translate_bus_error_to_exit_status(r, &error);
2139         } else {
2140                 r = 0;
2141
2142                 STRV_FOREACH(name, args+1) {
2143                         int q;
2144
2145                         q = start_unit_one(bus, method, *name, mode, &error, s);
2146                         if (q < 0) {
2147                                 r = translate_bus_error_to_exit_status(r, &error);
2148                                 sd_bus_error_free(&error);
2149                         }
2150                 }
2151         }
2152
2153         if (!arg_no_block) {
2154                 int q;
2155
2156                 q = wait_for_jobs(bus, s);
2157                 if (q < 0)
2158                         return q;
2159
2160                 /* When stopping units, warn if they can still be triggered by
2161                  * another active unit (socket, path, timer) */
2162                 if (!arg_quiet && streq(method, "StopUnit")) {
2163                         if (one_name)
2164                                 check_triggering_units(bus, one_name);
2165                         else
2166                                 STRV_FOREACH(name, args+1)
2167                                         check_triggering_units(bus, *name);
2168                 }
2169         }
2170
2171         return r;
2172 }
2173
2174 /* Ask systemd-logind, which might grant access to unprivileged users
2175  * through PolicyKit */
2176 static int reboot_with_logind(sd_bus *bus, enum action a) {
2177 #ifdef HAVE_LOGIND
2178         _cleanup_bus_error_free_ sd_bus_error error = SD_BUS_ERROR_NULL;
2179         const char *method;
2180         int r;
2181
2182         if (!bus)
2183                 return -EIO;
2184
2185         polkit_agent_open_if_enabled();
2186
2187         switch (a) {
2188
2189         case ACTION_REBOOT:
2190                 method = "Reboot";
2191                 break;
2192
2193         case ACTION_POWEROFF:
2194                 method = "PowerOff";
2195                 break;
2196
2197         case ACTION_SUSPEND:
2198                 method = "Suspend";
2199                 break;
2200
2201         case ACTION_HIBERNATE:
2202                 method = "Hibernate";
2203                 break;
2204
2205         case ACTION_HYBRID_SLEEP:
2206                 method = "HybridSleep";
2207                 break;
2208
2209         default:
2210                 return -EINVAL;
2211         }
2212
2213         r = sd_bus_call_method(
2214                         bus,
2215                         "org.freedesktop.login1",
2216                         "/org/freedesktop/login1",
2217                         "org.freedesktop.login1.Manager",
2218                         method,
2219                         &error,
2220                         NULL,
2221                         "b", true);
2222         if (r < 0)
2223                 log_error("Failed to execute operation: %s", bus_error_message(&error, r));
2224
2225         return r;
2226 #else
2227         return -ENOSYS;
2228 #endif
2229 }
2230
2231 static int check_inhibitors(sd_bus *bus, enum action a) {
2232 #ifdef HAVE_LOGIND
2233         _cleanup_bus_message_unref_ sd_bus_message *reply = NULL;
2234         _cleanup_strv_free_ char **sessions = NULL;
2235         const char *what, *who, *why, *mode;
2236         uint32_t uid, pid;
2237         unsigned c = 0;
2238         char **s;
2239         int r;
2240
2241         if (!bus)
2242                 return 0;
2243
2244         if (arg_ignore_inhibitors || arg_force > 0)
2245                 return 0;
2246
2247         if (arg_when > 0)
2248                 return 0;
2249
2250         if (geteuid() == 0)
2251                 return 0;
2252
2253         if (!on_tty())
2254                 return 0;
2255
2256         r = sd_bus_call_method(
2257                         bus,
2258                         "org.freedesktop.login1",
2259                         "/org/freedesktop/login1",
2260                         "org.freedesktop.login1.Manager",
2261                         "ListInhibitors",
2262                         NULL,
2263                         &reply,
2264                         NULL);
2265         if (r < 0)
2266                 /* If logind is not around, then there are no inhibitors... */
2267                 return 0;
2268
2269         r = sd_bus_message_enter_container(reply, SD_BUS_TYPE_ARRAY, "(ssssuu)");
2270         if (r < 0)
2271                 return bus_log_parse_error(r);
2272
2273         while ((r = sd_bus_message_read(reply, "(ssssuu)", &what, &who, &why, &mode, &uid, &pid)) > 0) {
2274                 _cleanup_free_ char *comm = NULL, *user = NULL;
2275                 _cleanup_strv_free_ char **sv = NULL;
2276
2277                 if (!streq(mode, "block"))
2278                         continue;
2279
2280                 sv = strv_split(what, ":");
2281                 if (!sv)
2282                         return log_oom();
2283
2284                 if (!strv_contains(sv,
2285                                   a == ACTION_HALT ||
2286                                   a == ACTION_POWEROFF ||
2287                                   a == ACTION_REBOOT ||
2288                                   a == ACTION_KEXEC ? "shutdown" : "sleep"))
2289                         continue;
2290
2291                 get_process_comm(pid, &comm);
2292                 user = uid_to_name(uid);
2293
2294                 log_warning("Operation inhibited by \"%s\" (PID %lu \"%s\", user %s), reason is \"%s\".",
2295                             who, (unsigned long) pid, strna(comm), strna(user), why);
2296
2297                 c++;
2298         }
2299         if (r < 0)
2300                 return bus_log_parse_error(r);
2301
2302         r = sd_bus_message_exit_container(reply);
2303         if (r < 0)
2304                 return bus_log_parse_error(r);
2305
2306         /* Check for current sessions */
2307         sd_get_sessions(&sessions);
2308         STRV_FOREACH(s, sessions) {
2309                 _cleanup_free_ char *type = NULL, *tty = NULL, *seat = NULL, *user = NULL, *service = NULL, *class = NULL;
2310
2311                 if (sd_session_get_uid(*s, &uid) < 0 || uid == getuid())
2312                         continue;
2313
2314                 if (sd_session_get_class(*s, &class) < 0 || !streq(class, "user"))
2315                         continue;
2316
2317                 if (sd_session_get_type(*s, &type) < 0 || (!streq(type, "x11") && !streq(type, "tty")))
2318                         continue;
2319
2320                 sd_session_get_tty(*s, &tty);
2321                 sd_session_get_seat(*s, &seat);
2322                 sd_session_get_service(*s, &service);
2323                 user = uid_to_name(uid);
2324
2325                 log_warning("User %s is logged in on %s.", strna(user), isempty(tty) ? (isempty(seat) ? strna(service) : seat) : tty);
2326                 c++;
2327         }
2328
2329         if (c <= 0)
2330                 return 0;
2331
2332         log_error("Please retry operation after closing inhibitors and logging out other users.\nAlternatively, ignore inhibitors and users with 'systemctl %s -i'.",
2333                   action_table[a].verb);
2334
2335         return -EPERM;
2336 #else
2337         return 0;
2338 #endif
2339 }
2340
2341 static int start_special(sd_bus *bus, char **args) {
2342         enum action a;
2343         int r;
2344
2345         assert(args);
2346
2347         a = verb_to_action(args[0]);
2348
2349         r = check_inhibitors(bus, a);
2350         if (r < 0)
2351                 return r;
2352
2353         if (arg_force >= 2 && geteuid() != 0) {
2354                 log_error("Must be root.");
2355                 return -EPERM;
2356         }
2357
2358         if (arg_force >= 2 &&
2359             (a == ACTION_HALT ||
2360              a == ACTION_POWEROFF ||
2361              a == ACTION_REBOOT))
2362                 return halt_now(a);
2363
2364         if (arg_force >= 1 &&
2365             (a == ACTION_HALT ||
2366              a == ACTION_POWEROFF ||
2367              a == ACTION_REBOOT ||
2368              a == ACTION_KEXEC ||
2369              a == ACTION_EXIT))
2370                 return daemon_reload(bus, args);
2371
2372         /* first try logind, to allow authentication with polkit */
2373         if (geteuid() != 0 &&
2374             (a == ACTION_POWEROFF ||
2375              a == ACTION_REBOOT ||
2376              a == ACTION_SUSPEND ||
2377              a == ACTION_HIBERNATE ||
2378              a == ACTION_HYBRID_SLEEP)) {
2379                 r = reboot_with_logind(bus, a);
2380                 if (r >= 0)
2381                         return r;
2382         }
2383
2384         r = start_unit(bus, args);
2385         if (r == EXIT_SUCCESS)
2386                 warn_wall(a);
2387
2388         return r;
2389 }
2390
2391 static int check_unit_active(sd_bus *bus, char **args) {
2392         char **name;
2393         int r = 3; /* According to LSB: "program is not running" */
2394
2395         assert(bus);
2396         assert(args);
2397
2398         STRV_FOREACH(name, args+1) {
2399                 int state;
2400
2401                 state = check_one_unit(bus, *name, "active\0reloading\0", arg_quiet);
2402                 if (state < 0)
2403                         return state;
2404                 if (state > 0)
2405                         r = 0;
2406         }
2407
2408         return r;
2409 }
2410
2411 static int check_unit_failed(sd_bus *bus, char **args) {
2412         char **name;
2413         int r = 1;
2414
2415         assert(bus);
2416         assert(args);
2417
2418         STRV_FOREACH(name, args+1) {
2419                 int state;
2420
2421                 state = check_one_unit(bus, *name, "failed\0", arg_quiet);
2422                 if (state < 0)
2423                         return state;
2424                 if (state > 0)
2425                         r = 0;
2426         }
2427
2428         return r;
2429 }
2430
2431 static int kill_unit(sd_bus *bus, char **args) {
2432         _cleanup_bus_error_free_ sd_bus_error error = SD_BUS_ERROR_NULL;
2433         char **name;
2434         int r = 0;
2435
2436         assert(bus);
2437         assert(args);
2438
2439         if (!arg_kill_who)
2440                 arg_kill_who = "all";
2441
2442         STRV_FOREACH(name, args+1) {
2443                 _cleanup_free_ char *n = NULL;
2444
2445                 n = unit_name_mangle(*name);
2446                 if (!n)
2447                         return log_oom();
2448
2449                 r = sd_bus_call_method(
2450                                 bus,
2451                                 "org.freedesktop.systemd1",
2452                                 "/org/freedesktop/systemd1",
2453                                 "org.freedesktop.systemd1.Manager",
2454                                 "KillUnit",
2455                                 &error,
2456                                 NULL,
2457                                 "ssi", n, arg_kill_who, arg_signal);
2458                 if (r < 0) {
2459                         log_error("Failed to kill unit %s: %s", n, bus_error_message(&error, r));
2460                         return r;
2461                 }
2462         }
2463
2464         return 0;
2465 }
2466
2467 typedef struct ExecStatusInfo {
2468         char *name;
2469
2470         char *path;
2471         char **argv;
2472
2473         bool ignore;
2474
2475         usec_t start_timestamp;
2476         usec_t exit_timestamp;
2477         pid_t pid;
2478         int code;
2479         int status;
2480
2481         LIST_FIELDS(struct ExecStatusInfo, exec);
2482 } ExecStatusInfo;
2483
2484 static void exec_status_info_free(ExecStatusInfo *i) {
2485         assert(i);
2486
2487         free(i->name);
2488         free(i->path);
2489         strv_free(i->argv);
2490         free(i);
2491 }
2492
2493 static int exec_status_info_deserialize(sd_bus_message *m, ExecStatusInfo *i) {
2494         uint64_t start_timestamp, exit_timestamp, start_timestamp_monotonic, exit_timestamp_monotonic;
2495         const char *path;
2496         uint32_t pid;
2497         int32_t code, status;
2498         int ignore, r;
2499
2500         assert(m);
2501         assert(i);
2502
2503         r = sd_bus_message_enter_container(m, SD_BUS_TYPE_STRUCT, "sasbttttuii");
2504         if (r < 0)
2505                 return bus_log_parse_error(r);
2506         else if (r == 0)
2507                 return 0;
2508
2509         r = sd_bus_message_read(m, "s", &path);
2510         if (r < 0)
2511                 return bus_log_parse_error(r);
2512
2513         i->path = strdup(path);
2514         if (!i->path)
2515                 return log_oom();
2516
2517         r = sd_bus_message_read_strv(m, &i->argv);
2518         if (r < 0)
2519                 return bus_log_parse_error(r);
2520
2521         r = sd_bus_message_read(m,
2522                                 "bttttuii",
2523                                 &ignore,
2524                                 &start_timestamp, &start_timestamp_monotonic,
2525                                 &exit_timestamp, &exit_timestamp_monotonic,
2526                                 &pid,
2527                                 &code, &status);
2528         if (r < 0)
2529                 return bus_log_parse_error(r);
2530
2531         i->ignore = ignore;
2532         i->start_timestamp = (usec_t) start_timestamp;
2533         i->exit_timestamp = (usec_t) exit_timestamp;
2534         i->pid = (pid_t) pid;
2535         i->code = code;
2536         i->status = status;
2537
2538         r = sd_bus_message_exit_container(m);
2539         if (r < 0)
2540                 return bus_log_parse_error(r);
2541
2542         return 1;
2543 }
2544
2545 typedef struct UnitStatusInfo {
2546         const char *id;
2547         const char *load_state;
2548         const char *active_state;
2549         const char *sub_state;
2550         const char *unit_file_state;
2551
2552         const char *description;
2553         const char *following;
2554
2555         char **documentation;
2556
2557         const char *fragment_path;
2558         const char *source_path;
2559         const char *control_group;
2560
2561         char **dropin_paths;
2562
2563         const char *load_error;
2564         const char *result;
2565
2566         usec_t inactive_exit_timestamp;
2567         usec_t inactive_exit_timestamp_monotonic;
2568         usec_t active_enter_timestamp;
2569         usec_t active_exit_timestamp;
2570         usec_t inactive_enter_timestamp;
2571
2572         bool need_daemon_reload;
2573
2574         /* Service */
2575         pid_t main_pid;
2576         pid_t control_pid;
2577         const char *status_text;
2578         const char *pid_file;
2579         bool running:1;
2580
2581         usec_t start_timestamp;
2582         usec_t exit_timestamp;
2583
2584         int exit_code, exit_status;
2585
2586         usec_t condition_timestamp;
2587         bool condition_result;
2588         bool failed_condition_trigger;
2589         bool failed_condition_negate;
2590         const char *failed_condition;
2591         const char *failed_condition_param;
2592
2593         /* Socket */
2594         unsigned n_accepted;
2595         unsigned n_connections;
2596         bool accept;
2597
2598         /* Pairs of type, path */
2599         char **listen;
2600
2601         /* Device */
2602         const char *sysfs_path;
2603
2604         /* Mount, Automount */
2605         const char *where;
2606
2607         /* Swap */
2608         const char *what;
2609
2610         LIST_HEAD(ExecStatusInfo, exec);
2611 } UnitStatusInfo;
2612
2613 static void print_status_info(
2614                 UnitStatusInfo *i,
2615                 bool *ellipsized) {
2616
2617         ExecStatusInfo *p;
2618         const char *on, *off, *ss;
2619         usec_t timestamp;
2620         char since1[FORMAT_TIMESTAMP_RELATIVE_MAX], *s1;
2621         char since2[FORMAT_TIMESTAMP_MAX], *s2;
2622         const char *path;
2623         int flags =
2624                 arg_all * OUTPUT_SHOW_ALL |
2625                 (!on_tty() || pager_have()) * OUTPUT_FULL_WIDTH |
2626                 on_tty() * OUTPUT_COLOR |
2627                 !arg_quiet * OUTPUT_WARN_CUTOFF |
2628                 arg_full * OUTPUT_FULL_WIDTH;
2629         char **t, **t2;
2630
2631         assert(i);
2632
2633         /* This shows pretty information about a unit. See
2634          * print_property() for a low-level property printer */
2635
2636         printf("%s", strna(i->id));
2637
2638         if (i->description && !streq_ptr(i->id, i->description))
2639                 printf(" - %s", i->description);
2640
2641         printf("\n");
2642
2643         if (i->following)
2644                 printf("   Follow: unit currently follows state of %s\n", i->following);
2645
2646         if (streq_ptr(i->load_state, "error")) {
2647                 on = ansi_highlight_red();
2648                 off = ansi_highlight_off();
2649         } else
2650                 on = off = "";
2651
2652         path = i->source_path ? i->source_path : i->fragment_path;
2653
2654         if (i->load_error)
2655                 printf("   Loaded: %s%s%s (Reason: %s)\n",
2656                        on, strna(i->load_state), off, i->load_error);
2657         else if (path && i->unit_file_state)
2658                 printf("   Loaded: %s%s%s (%s; %s)\n",
2659                        on, strna(i->load_state), off, path, i->unit_file_state);
2660         else if (path)
2661                 printf("   Loaded: %s%s%s (%s)\n",
2662                        on, strna(i->load_state), off, path);
2663         else
2664                 printf("   Loaded: %s%s%s\n",
2665                        on, strna(i->load_state), off);
2666
2667         if (!strv_isempty(i->dropin_paths)) {
2668                 _cleanup_free_ char *dir = NULL;
2669                 bool last = false;
2670                 char ** dropin;
2671
2672                 STRV_FOREACH(dropin, i->dropin_paths) {
2673                         if (! dir || last) {
2674                                 printf(dir ? "        " : "  Drop-In: ");
2675
2676                                 free(dir);
2677                                 dir = NULL;
2678
2679                                 if (path_get_parent(*dropin, &dir) < 0) {
2680                                         log_oom();
2681                                         return;
2682                                 }
2683
2684                                 printf("%s\n           %s", dir,
2685                                        draw_special_char(DRAW_TREE_RIGHT));
2686                         }
2687
2688                         last = ! (*(dropin + 1) && startswith(*(dropin + 1), dir));
2689
2690                         printf("%s%s", path_get_file_name(*dropin), last ? "\n" : ", ");
2691                 }
2692         }
2693
2694         ss = streq_ptr(i->active_state, i->sub_state) ? NULL : i->sub_state;
2695
2696         if (streq_ptr(i->active_state, "failed")) {
2697                 on = ansi_highlight_red();
2698                 off = ansi_highlight_off();
2699         } else if (streq_ptr(i->active_state, "active") || streq_ptr(i->active_state, "reloading")) {
2700                 on = ansi_highlight_green();
2701                 off = ansi_highlight_off();
2702         } else
2703                 on = off = "";
2704
2705         if (ss)
2706                 printf("   Active: %s%s (%s)%s",
2707                        on, strna(i->active_state), ss, off);
2708         else
2709                 printf("   Active: %s%s%s",
2710                        on, strna(i->active_state), off);
2711
2712         if (!isempty(i->result) && !streq(i->result, "success"))
2713                 printf(" (Result: %s)", i->result);
2714
2715         timestamp = (streq_ptr(i->active_state, "active")      ||
2716                      streq_ptr(i->active_state, "reloading"))   ? i->active_enter_timestamp :
2717                     (streq_ptr(i->active_state, "inactive")    ||
2718                      streq_ptr(i->active_state, "failed"))      ? i->inactive_enter_timestamp :
2719                     streq_ptr(i->active_state, "activating")    ? i->inactive_exit_timestamp :
2720                                                                   i->active_exit_timestamp;
2721
2722         s1 = format_timestamp_relative(since1, sizeof(since1), timestamp);
2723         s2 = format_timestamp(since2, sizeof(since2), timestamp);
2724
2725         if (s1)
2726                 printf(" since %s; %s\n", s2, s1);
2727         else if (s2)
2728                 printf(" since %s\n", s2);
2729         else
2730                 printf("\n");
2731
2732         if (!i->condition_result && i->condition_timestamp > 0) {
2733                 s1 = format_timestamp_relative(since1, sizeof(since1), i->condition_timestamp);
2734                 s2 = format_timestamp(since2, sizeof(since2), i->condition_timestamp);
2735
2736                 printf("           start condition failed at %s%s%s\n",
2737                        s2, s1 ? "; " : "", s1 ? s1 : "");
2738                 if (i->failed_condition_trigger)
2739                         printf("           none of the trigger conditions were met\n");
2740                 else if (i->failed_condition)
2741                         printf("           %s=%s%s was not met\n",
2742                                i->failed_condition,
2743                                i->failed_condition_negate ? "!" : "",
2744                                i->failed_condition_param);
2745         }
2746
2747         if (i->sysfs_path)
2748                 printf("   Device: %s\n", i->sysfs_path);
2749         if (i->where)
2750                 printf("    Where: %s\n", i->where);
2751         if (i->what)
2752                 printf("     What: %s\n", i->what);
2753
2754         STRV_FOREACH(t, i->documentation)
2755                 printf(" %*s %s\n", 9, t == i->documentation ? "Docs:" : "", *t);
2756
2757         STRV_FOREACH_PAIR(t, t2, i->listen)
2758                 printf(" %*s %s (%s)\n", 9, t == i->listen ? "Listen:" : "", *t2, *t);
2759
2760         if (i->accept)
2761                 printf(" Accepted: %u; Connected: %u\n", i->n_accepted, i->n_connections);
2762
2763         LIST_FOREACH(exec, p, i->exec) {
2764                 _cleanup_free_ char *argv = NULL;
2765                 bool good;
2766
2767                 /* Only show exited processes here */
2768                 if (p->code == 0)
2769                         continue;
2770
2771                 argv = strv_join(p->argv, " ");
2772                 printf("  Process: %u %s=%s ", p->pid, p->name, strna(argv));
2773
2774                 good = is_clean_exit_lsb(p->code, p->status, NULL);
2775                 if (!good) {
2776                         on = ansi_highlight_red();
2777                         off = ansi_highlight_off();
2778                 } else
2779                         on = off = "";
2780
2781                 printf("%s(code=%s, ", on, sigchld_code_to_string(p->code));
2782
2783                 if (p->code == CLD_EXITED) {
2784                         const char *c;
2785
2786                         printf("status=%i", p->status);
2787
2788                         c = exit_status_to_string(p->status, EXIT_STATUS_SYSTEMD);
2789                         if (c)
2790                                 printf("/%s", c);
2791
2792                 } else
2793                         printf("signal=%s", signal_to_string(p->status));
2794
2795                 printf(")%s\n", off);
2796
2797                 if (i->main_pid == p->pid &&
2798                     i->start_timestamp == p->start_timestamp &&
2799                     i->exit_timestamp == p->start_timestamp)
2800                         /* Let's not show this twice */
2801                         i->main_pid = 0;
2802
2803                 if (p->pid == i->control_pid)
2804                         i->control_pid = 0;
2805         }
2806
2807         if (i->main_pid > 0 || i->control_pid > 0) {
2808                 if (i->main_pid > 0) {
2809                         printf(" Main PID: %u", (unsigned) i->main_pid);
2810
2811                         if (i->running) {
2812                                 _cleanup_free_ char *comm = NULL;
2813                                 get_process_comm(i->main_pid, &comm);
2814                                 if (comm)
2815                                         printf(" (%s)", comm);
2816                         } else if (i->exit_code > 0) {
2817                                 printf(" (code=%s, ", sigchld_code_to_string(i->exit_code));
2818
2819                                 if (i->exit_code == CLD_EXITED) {
2820                                         const char *c;
2821
2822                                         printf("status=%i", i->exit_status);
2823
2824                                         c = exit_status_to_string(i->exit_status, EXIT_STATUS_SYSTEMD);
2825                                         if (c)
2826                                                 printf("/%s", c);
2827
2828                                 } else
2829                                         printf("signal=%s", signal_to_string(i->exit_status));
2830                                 printf(")");
2831                         }
2832
2833                         if (i->control_pid > 0)
2834                                 printf(";");
2835                 }
2836
2837                 if (i->control_pid > 0) {
2838                         _cleanup_free_ char *c = NULL;
2839
2840                         printf(" %8s: %u", i->main_pid ? "" : " Control", (unsigned) i->control_pid);
2841
2842                         get_process_comm(i->control_pid, &c);
2843                         if (c)
2844                                 printf(" (%s)", c);
2845                 }
2846
2847                 printf("\n");
2848         }
2849
2850         if (i->status_text)
2851                 printf("   Status: \"%s\"\n", i->status_text);
2852
2853         if (i->control_group &&
2854             (i->main_pid > 0 || i->control_pid > 0 || cg_is_empty_recursive(SYSTEMD_CGROUP_CONTROLLER, i->control_group, false) == 0)) {
2855                 unsigned c;
2856
2857                 printf("   CGroup: %s\n", i->control_group);
2858
2859                 if (arg_transport == BUS_TRANSPORT_LOCAL || arg_transport == BUS_TRANSPORT_CONTAINER) {
2860                         unsigned k = 0;
2861                         pid_t extra[2];
2862                         char prefix[] = "           ";
2863
2864                         c = columns();
2865                         if (c > sizeof(prefix) - 1)
2866                                 c -= sizeof(prefix) - 1;
2867                         else
2868                                 c = 0;
2869
2870                         if (i->main_pid > 0)
2871                                 extra[k++] = i->main_pid;
2872
2873                         if (i->control_pid > 0)
2874                                 extra[k++] = i->control_pid;
2875
2876                         show_cgroup_and_extra(SYSTEMD_CGROUP_CONTROLLER, i->control_group, prefix,
2877                                                       c, false, extra, k, flags);
2878                 }
2879         }
2880
2881         if (i->id && arg_transport == BUS_TRANSPORT_LOCAL) {
2882                 printf("\n");
2883                 show_journal_by_unit(stdout,
2884                                      i->id,
2885                                      arg_output,
2886                                      0,
2887                                      i->inactive_exit_timestamp_monotonic,
2888                                      arg_lines,
2889                                      getuid(),
2890                                      flags,
2891                                      arg_scope == UNIT_FILE_SYSTEM,
2892                                      ellipsized);
2893         }
2894
2895         if (i->need_daemon_reload)
2896                 printf("\n%sWarning:%s Unit file changed on disk, 'systemctl %sdaemon-reload' recommended.\n",
2897                        ansi_highlight_red(),
2898                        ansi_highlight_off(),
2899                        arg_scope == UNIT_FILE_SYSTEM ? "" : "--user ");
2900 }
2901
2902 static void show_unit_help(UnitStatusInfo *i) {
2903         char **p;
2904
2905         assert(i);
2906
2907         if (!i->documentation) {
2908                 log_info("Documentation for %s not known.", i->id);
2909                 return;
2910         }
2911
2912         STRV_FOREACH(p, i->documentation) {
2913
2914                 if (startswith(*p, "man:")) {
2915                         const char *args[4] = { "man", NULL, NULL, NULL };
2916                         _cleanup_free_ char *page = NULL, *section = NULL;
2917                         char *e = NULL;
2918                         pid_t pid;
2919                         size_t k;
2920
2921                         k = strlen(*p);
2922
2923                         if ((*p)[k-1] == ')')
2924                                 e = strrchr(*p, '(');
2925
2926                         if (e) {
2927                                 page = strndup((*p) + 4, e - *p - 4);
2928                                 section = strndup(e + 1, *p + k - e - 2);
2929                                 if (!page || !section) {
2930                                         log_oom();
2931                                         return;
2932                                 }
2933
2934                                 args[1] = section;
2935                                 args[2] = page;
2936                         } else
2937                                 args[1] = *p + 4;
2938
2939                         pid = fork();
2940                         if (pid < 0) {
2941                                 log_error("Failed to fork: %m");
2942                                 continue;
2943                         }
2944
2945                         if (pid == 0) {
2946                                 /* Child */
2947                                 execvp(args[0], (char**) args);
2948                                 log_error("Failed to execute man: %m");
2949                                 _exit(EXIT_FAILURE);
2950                         }
2951
2952                         wait_for_terminate(pid, NULL);
2953                 } else
2954                         log_info("Can't show: %s", *p);
2955         }
2956 }
2957
2958 static int status_property(const char *name, sd_bus_message *m, UnitStatusInfo *i, const char *contents) {
2959         int r;
2960
2961         assert(name);
2962         assert(m);
2963         assert(i);
2964
2965         switch (contents[0]) {
2966
2967         case SD_BUS_TYPE_STRING: {
2968                 const char *s;
2969
2970                 r = sd_bus_message_read(m, "s", &s);
2971                 if (r < 0)
2972                         return bus_log_parse_error(r);
2973
2974                 if (!isempty(s)) {
2975                         if (streq(name, "Id"))
2976                                 i->id = s;
2977                         else if (streq(name, "LoadState"))
2978                                 i->load_state = s;
2979                         else if (streq(name, "ActiveState"))
2980                                 i->active_state = s;
2981                         else if (streq(name, "SubState"))
2982                                 i->sub_state = s;
2983                         else if (streq(name, "Description"))
2984                                 i->description = s;
2985                         else if (streq(name, "FragmentPath"))
2986                                 i->fragment_path = s;
2987                         else if (streq(name, "SourcePath"))
2988                                 i->source_path = s;
2989 #ifndef NOLEGACY
2990                         else if (streq(name, "DefaultControlGroup")) {
2991                                 const char *e;
2992                                 e = startswith(s, SYSTEMD_CGROUP_CONTROLLER ":");
2993                                 if (e)
2994                                         i->control_group = e;
2995                         }
2996 #endif
2997                         else if (streq(name, "ControlGroup"))
2998                                 i->control_group = s;
2999                         else if (streq(name, "StatusText"))
3000                                 i->status_text = s;
3001                         else if (streq(name, "PIDFile"))
3002                                 i->pid_file = s;
3003                         else if (streq(name, "SysFSPath"))
3004                                 i->sysfs_path = s;
3005                         else if (streq(name, "Where"))
3006                                 i->where = s;
3007                         else if (streq(name, "What"))
3008                                 i->what = s;
3009                         else if (streq(name, "Following"))
3010                                 i->following = s;
3011                         else if (streq(name, "UnitFileState"))
3012                                 i->unit_file_state = s;
3013                         else if (streq(name, "Result"))
3014                                 i->result = s;
3015                 }
3016
3017                 break;
3018         }
3019
3020         case SD_BUS_TYPE_BOOLEAN: {
3021                 int b;
3022
3023                 r = sd_bus_message_read(m, "b", &b);
3024                 if (r < 0)
3025                         return bus_log_parse_error(r);
3026
3027                 if (streq(name, "Accept"))
3028                         i->accept = b;
3029                 else if (streq(name, "NeedDaemonReload"))
3030                         i->need_daemon_reload = b;
3031                 else if (streq(name, "ConditionResult"))
3032                         i->condition_result = b;
3033
3034                 break;
3035         }
3036
3037         case SD_BUS_TYPE_UINT32: {
3038                 uint32_t u;
3039
3040                 r = sd_bus_message_read(m, "u", &u);
3041                 if (r < 0)
3042                         return bus_log_parse_error(r);
3043
3044                 if (streq(name, "MainPID")) {
3045                         if (u > 0) {
3046                                 i->main_pid = (pid_t) u;
3047                                 i->running = true;
3048                         }
3049                 } else if (streq(name, "ControlPID"))
3050                         i->control_pid = (pid_t) u;
3051                 else if (streq(name, "ExecMainPID")) {
3052                         if (u > 0)
3053                                 i->main_pid = (pid_t) u;
3054                 } else if (streq(name, "NAccepted"))
3055                         i->n_accepted = u;
3056                 else if (streq(name, "NConnections"))
3057                         i->n_connections = u;
3058
3059                 break;
3060         }
3061
3062         case SD_BUS_TYPE_INT32: {
3063                 int32_t j;
3064
3065                 r = sd_bus_message_read(m, "i", &j);
3066                 if (r < 0)
3067                         return bus_log_parse_error(r);
3068
3069                 if (streq(name, "ExecMainCode"))
3070                         i->exit_code = (int) j;
3071                 else if (streq(name, "ExecMainStatus"))
3072                         i->exit_status = (int) j;
3073
3074                 break;
3075         }
3076
3077         case SD_BUS_TYPE_UINT64: {
3078                 uint64_t u;
3079
3080                 r = sd_bus_message_read(m, "t", &u);
3081                 if (r < 0)
3082                         return bus_log_parse_error(r);
3083
3084                 if (streq(name, "ExecMainStartTimestamp"))
3085                         i->start_timestamp = (usec_t) u;
3086                 else if (streq(name, "ExecMainExitTimestamp"))
3087                         i->exit_timestamp = (usec_t) u;
3088                 else if (streq(name, "ActiveEnterTimestamp"))
3089                         i->active_enter_timestamp = (usec_t) u;
3090                 else if (streq(name, "InactiveEnterTimestamp"))
3091                         i->inactive_enter_timestamp = (usec_t) u;
3092                 else if (streq(name, "InactiveExitTimestamp"))
3093                         i->inactive_exit_timestamp = (usec_t) u;
3094                 else if (streq(name, "InactiveExitTimestampMonotonic"))
3095                         i->inactive_exit_timestamp_monotonic = (usec_t) u;
3096                 else if (streq(name, "ActiveExitTimestamp"))
3097                         i->active_exit_timestamp = (usec_t) u;
3098                 else if (streq(name, "ConditionTimestamp"))
3099                         i->condition_timestamp = (usec_t) u;
3100
3101                 break;
3102         }
3103
3104         case SD_BUS_TYPE_ARRAY:
3105
3106                 if (contents[1] == SD_BUS_TYPE_STRUCT_BEGIN && startswith(name, "Exec")) {
3107                         _cleanup_free_ ExecStatusInfo *info = NULL;
3108
3109                         r = sd_bus_message_enter_container(m, SD_BUS_TYPE_ARRAY, "(sasbttttuii)");
3110                         if (r < 0)
3111                                 return bus_log_parse_error(r);
3112
3113                         info = new0(ExecStatusInfo, 1);
3114                         if (!info)
3115                                 return log_oom();
3116
3117                         while ((r = exec_status_info_deserialize(m, info)) > 0) {
3118
3119                                 info->name = strdup(name);
3120                                 if (!info->name)
3121                                         log_oom();
3122
3123                                 LIST_PREPEND(exec, i->exec, info);
3124
3125                                 info = new0(ExecStatusInfo, 1);
3126                                 if (!info)
3127                                         log_oom();
3128                         }
3129
3130                         if (r < 0)
3131                                 return bus_log_parse_error(r);
3132
3133                         r = sd_bus_message_exit_container(m);
3134                         if (r < 0)
3135                                 return bus_log_parse_error(r);
3136
3137                         return 0;
3138
3139                 } else if (contents[1] == SD_BUS_TYPE_STRUCT_BEGIN && streq(name, "Listen")) {
3140                         const char *type, *path;
3141
3142                         r = sd_bus_message_enter_container(m, SD_BUS_TYPE_ARRAY, "(ss)");
3143                         if (r < 0)
3144                                 return bus_log_parse_error(r);
3145
3146                         while ((r = sd_bus_message_read(m, "(ss)", &type, &path)) > 0) {
3147
3148                                 r = strv_extend(&i->listen, type);
3149                                 if (r < 0)
3150                                         return r;
3151
3152                                 r = strv_extend(&i->listen, path);
3153                                 if (r < 0)
3154                                         return r;
3155                         }
3156                         if (r < 0)
3157                                 return bus_log_parse_error(r);
3158
3159                         r = sd_bus_message_exit_container(m);
3160                         if (r < 0)
3161                                 return bus_log_parse_error(r);
3162
3163                         return 0;
3164
3165                 } else if (contents[1] == SD_BUS_TYPE_STRING && streq(name, "DropInPaths")) {
3166
3167                         r = sd_bus_message_read_strv(m, &i->dropin_paths);
3168                         if (r < 0)
3169                                 return bus_log_parse_error(r);
3170
3171                 } else if (contents[1] == SD_BUS_TYPE_STRING && streq(name, "Documentation")) {
3172
3173                         r = sd_bus_message_read_strv(m, &i->documentation);
3174                         if (r < 0)
3175                                 return bus_log_parse_error(r);
3176
3177                 } else if (contents[1] == SD_BUS_TYPE_STRUCT_BEGIN && streq(name, "Conditions")) {
3178                         const char *cond, *param;
3179                         int trigger, negate;
3180                         int32_t state;
3181
3182                         r = sd_bus_message_enter_container(m, SD_BUS_TYPE_ARRAY, "(sbbsi)");
3183                         if (r < 0)
3184                                 return bus_log_parse_error(r);
3185
3186                         while ((r = sd_bus_message_read(m, "(sbbsi)", &cond, &trigger, &negate, &param, &state)) > 0) {
3187                                 log_debug("%s %d %d %s %d", cond, trigger, negate, param, state);
3188                                 if (state < 0 && (!trigger || !i->failed_condition)) {
3189                                         i->failed_condition = cond;
3190                                         i->failed_condition_trigger = trigger;
3191                                         i->failed_condition_negate = negate;
3192                                         i->failed_condition_param = param;
3193                                 }
3194                         }
3195                         if (r < 0)
3196                                 return bus_log_parse_error(r);
3197
3198                         r = sd_bus_message_exit_container(m);
3199                         if (r < 0)
3200                                 return bus_log_parse_error(r);
3201
3202                 } else
3203                         goto skip;
3204
3205                 break;
3206
3207         case SD_BUS_TYPE_STRUCT_BEGIN:
3208
3209                 if (streq(name, "LoadError")) {
3210                         const char *n, *message;
3211
3212                         r = sd_bus_message_read(m, "(ss)", &n, &message);
3213                         if (r < 0)
3214                                 return bus_log_parse_error(r);
3215
3216                         if (!isempty(message))
3217                                 i->load_error = message;
3218                 } else
3219                         goto skip;
3220
3221                 break;
3222
3223         default:
3224                 goto skip;
3225         }
3226
3227         return 0;
3228
3229 skip:
3230         r = sd_bus_message_skip(m, contents);
3231         if (r < 0)
3232                 return bus_log_parse_error(r);
3233
3234         return 0;
3235 }
3236
3237 static int print_property(const char *name, sd_bus_message *m, const char *contents) {
3238         int r;
3239
3240         assert(name);
3241         assert(m);
3242
3243         /* This is a low-level property printer, see
3244          * print_status_info() for the nicer output */
3245
3246         if (arg_properties && !strv_find(arg_properties, name)) {
3247                 /* skip what we didn't read */
3248                 r = sd_bus_message_skip(m, contents);
3249                 return r;
3250         }
3251
3252         switch (contents[0]) {
3253
3254         case SD_BUS_TYPE_STRUCT_BEGIN:
3255
3256                 if (contents[1] == SD_BUS_TYPE_UINT32 && streq(name, "Job")) {
3257                         uint32_t u;
3258
3259                         r = sd_bus_message_read(m, "(uo)", &u, NULL);
3260                         if (r < 0)
3261                                 return bus_log_parse_error(r);
3262
3263                         if (u > 0)
3264                                 printf("%s=%u\n", name, (unsigned) u);
3265                         else if (arg_all)
3266                                 printf("%s=\n", name);
3267
3268                         return 0;
3269
3270                 } else if (contents[1] == SD_BUS_TYPE_STRING && streq(name, "Unit")) {
3271                         const char *s;
3272
3273                         r = sd_bus_message_read(m, "(so)", &s, NULL);
3274                         if (r < 0)
3275                                 return bus_log_parse_error(r);
3276
3277                         if (arg_all || !isempty(s))
3278                                 printf("%s=%s\n", name, s);
3279
3280                         return 0;
3281
3282                 } else if (contents[1] == SD_BUS_TYPE_STRING && streq(name, "LoadError")) {
3283                         const char *a = NULL, *b = NULL;
3284
3285                         r = sd_bus_message_read(m, "(ss)", &a, &b);
3286                         if (r < 0)
3287                                 return bus_log_parse_error(r);
3288
3289                         if (arg_all || !isempty(a) || !isempty(b))
3290                                 printf("%s=%s \"%s\"\n", name, strempty(a), strempty(b));
3291
3292                         return 0;
3293                 }
3294
3295                 break;
3296
3297         case SD_BUS_TYPE_ARRAY:
3298
3299                 if (contents[1] == SD_BUS_TYPE_STRUCT_BEGIN && streq(name, "EnvironmentFiles")) {
3300                         const char *path;
3301                         int ignore;
3302
3303                         r = sd_bus_message_enter_container(m, SD_BUS_TYPE_ARRAY, "(sb)");
3304                         if (r < 0)
3305                                 return bus_log_parse_error(r);
3306
3307                         while ((r = sd_bus_message_read(m, "(sb)", &path, &ignore)) > 0)
3308                                 printf("EnvironmentFile=%s (ignore_errors=%s)\n", path, yes_no(ignore));
3309
3310                         if (r < 0)
3311                                 return bus_log_parse_error(r);
3312
3313                         r = sd_bus_message_exit_container(m);
3314                         if (r < 0)
3315                                 return bus_log_parse_error(r);
3316
3317                         return 0;
3318
3319                 } else if (contents[1] == SD_BUS_TYPE_STRUCT_BEGIN && streq(name, "Paths")) {
3320                         const char *type, *path;
3321
3322                         r = sd_bus_message_enter_container(m, SD_BUS_TYPE_ARRAY, "(ss)");
3323                         if (r < 0)
3324                                 return bus_log_parse_error(r);
3325
3326                         while ((r = sd_bus_message_read(m, "(ss)", &type, &path)) > 0)
3327                                 printf("%s=%s\n", type, path);
3328                         if (r < 0)
3329                                 return bus_log_parse_error(r);
3330
3331                         r = sd_bus_message_exit_container(m);
3332                         if (r < 0)
3333                                 return bus_log_parse_error(r);
3334
3335                         return 0;
3336
3337                 } else if (contents[1] == SD_BUS_TYPE_STRUCT_BEGIN && streq(name, "Listen")) {
3338                         const char *type, *path;
3339
3340                         r = sd_bus_message_enter_container(m, SD_BUS_TYPE_ARRAY, "(ss)");
3341                         if (r < 0)
3342                                 return bus_log_parse_error(r);
3343
3344                         while ((r = sd_bus_message_read(m, "(ss)", &type, &path)) > 0)
3345                                 printf("Listen%s=%s\n", type, path);
3346                         if (r < 0)
3347                                 return bus_log_parse_error(r);
3348
3349                         r = sd_bus_message_exit_container(m);
3350                         if (r < 0)
3351                                 return bus_log_parse_error(r);
3352
3353                         return 0;
3354
3355                 } else if (contents[1] == SD_BUS_TYPE_STRUCT_BEGIN && streq(name, "Timers")) {
3356                         const char *base;
3357                         uint64_t value, next_elapse;
3358
3359                         r = sd_bus_message_enter_container(m, SD_BUS_TYPE_ARRAY, "(stt)");
3360                         if (r < 0)
3361                                 return bus_log_parse_error(r);
3362
3363                         while ((r = sd_bus_message_read(m, "(stt)", &base, &value, &next_elapse)) > 0) {
3364                                 char timespan1[FORMAT_TIMESPAN_MAX], timespan2[FORMAT_TIMESPAN_MAX];
3365
3366                                 printf("%s={ value=%s ; next_elapse=%s }\n",
3367                                        base,
3368                                        format_timespan(timespan1, sizeof(timespan1), value, 0),
3369                                        format_timespan(timespan2, sizeof(timespan2), next_elapse, 0));
3370                         }
3371                         if (r < 0)
3372                                 return bus_log_parse_error(r);
3373
3374                         r = sd_bus_message_exit_container(m);
3375                         if (r < 0)
3376                                 return bus_log_parse_error(r);
3377
3378                         return 0;
3379
3380                 } else if (contents[1] == SD_BUS_TYPE_STRUCT_BEGIN && startswith(name, "Exec")) {
3381                         ExecStatusInfo info = {};
3382
3383                         r = sd_bus_message_enter_container(m, SD_BUS_TYPE_ARRAY, "(sasbttttuii)");
3384                         if (r < 0)
3385                                 return bus_log_parse_error(r);
3386
3387                         while ((r = exec_status_info_deserialize(m, &info)) > 0) {
3388                                 char timestamp1[FORMAT_TIMESTAMP_MAX], timestamp2[FORMAT_TIMESTAMP_MAX];
3389                                 _cleanup_free_ char *tt;
3390
3391                                 tt = strv_join(info.argv, " ");
3392
3393                                 printf("%s={ path=%s ; argv[]=%s ; ignore_errors=%s ; start_time=[%s] ; stop_time=[%s] ; pid=%u ; code=%s ; status=%i%s%s }\n",
3394                                        name,
3395                                        strna(info.path),
3396                                        strna(tt),
3397                                        yes_no(info.ignore),
3398                                        strna(format_timestamp(timestamp1, sizeof(timestamp1), info.start_timestamp)),
3399                                        strna(format_timestamp(timestamp2, sizeof(timestamp2), info.exit_timestamp)),
3400                                        (unsigned) info. pid,
3401                                        sigchld_code_to_string(info.code),
3402                                        info.status,
3403                                        info.code == CLD_EXITED ? "" : "/",
3404                                        strempty(info.code == CLD_EXITED ? NULL : signal_to_string(info.status)));
3405
3406                                 free(info.path);
3407                                 strv_free(info.argv);
3408                                 zero(info);
3409                         }
3410
3411                         r = sd_bus_message_exit_container(m);
3412                         if (r < 0)
3413                                 return bus_log_parse_error(r);
3414
3415                         return 0;
3416
3417                 } else if (contents[1] == SD_BUS_TYPE_STRUCT_BEGIN && streq(name, "DeviceAllow")) {
3418                         const char *path, *rwm;
3419
3420                         r = sd_bus_message_enter_container(m, SD_BUS_TYPE_ARRAY, "(ss)");
3421                         if (r < 0)
3422                                 return bus_log_parse_error(r);
3423
3424                         while ((r = sd_bus_message_read(m, "(ss)", &path, &rwm)) > 0)
3425                                 printf("%s=%s %s\n", name, strna(path), strna(rwm));
3426                         if (r < 0)
3427                                 return bus_log_parse_error(r);
3428
3429                         r = sd_bus_message_exit_container(m);
3430                         if (r < 0)
3431                                 return bus_log_parse_error(r);
3432
3433                         return 0;
3434
3435                 } else if (contents[1] == SD_BUS_TYPE_STRUCT_BEGIN && streq(name, "BlockIODeviceWeight")) {
3436                         const char *path;
3437                         uint64_t weight;
3438
3439                         r = sd_bus_message_enter_container(m, SD_BUS_TYPE_ARRAY, "(st)");
3440                         if (r < 0)
3441                                 return bus_log_parse_error(r);
3442
3443                         while ((r = sd_bus_message_read(m, "(st)", &path, &weight)) > 0)
3444                                 printf("%s=%s %" PRIu64 "\n", name, strna(path), weight);
3445                         if (r < 0)
3446                                 return bus_log_parse_error(r);
3447
3448                         r = sd_bus_message_exit_container(m);
3449                         if (r < 0)
3450                                 return bus_log_parse_error(r);
3451
3452                         return 0;
3453
3454                 } else if (contents[1] == SD_BUS_TYPE_STRUCT_BEGIN && (streq(name, "BlockIOReadBandwidth") || streq(name, "BlockIOWriteBandwidth"))) {
3455                         const char *path;
3456                         uint64_t bandwidth;
3457
3458                         r = sd_bus_message_enter_container(m, SD_BUS_TYPE_ARRAY, "(st)");
3459                         if (r < 0)
3460                                 return bus_log_parse_error(r);
3461
3462                         while ((r = sd_bus_message_read(m, "(st)", &path, &bandwidth)) > 0)
3463                                 printf("%s=%s %" PRIu64 "\n", name, strna(path), bandwidth);
3464                         if (r < 0)
3465                                 return bus_log_parse_error(r);
3466
3467                         r = sd_bus_message_exit_container(m);
3468                         if (r < 0)
3469                                 return bus_log_parse_error(r);
3470
3471                         return 0;
3472                 }
3473
3474                 break;
3475         }
3476
3477         r = bus_print_property(name, m, arg_all);
3478         if (r < 0)
3479                 return bus_log_parse_error(r);
3480
3481         if (r == 0) {
3482                 r = sd_bus_message_skip(m, contents);
3483                 if (r < 0)
3484                         return bus_log_parse_error(r);
3485
3486                 if (arg_all)
3487                         printf("%s=[unprintable]\n", name);
3488         }
3489
3490         return 0;
3491 }
3492
3493 static int show_one(
3494                 const char *verb,
3495                 sd_bus *bus,
3496                 const char *path,
3497                 bool show_properties,
3498                 bool *new_line,
3499                 bool *ellipsized) {
3500
3501         _cleanup_bus_message_unref_ sd_bus_message *reply = NULL;
3502         _cleanup_bus_error_free_ sd_bus_error error = SD_BUS_ERROR_NULL;
3503         UnitStatusInfo info = {};
3504         ExecStatusInfo *p;
3505         int r;
3506
3507         assert(path);
3508         assert(new_line);
3509
3510         r = sd_bus_call_method(
3511                         bus,
3512                         "org.freedesktop.systemd1",
3513                         path,
3514                         "org.freedesktop.DBus.Properties",
3515                         "GetAll",
3516                         &error,
3517                         &reply,
3518                         "s", "");
3519         if (r < 0) {
3520                 log_error("Failed to get properties: %s", bus_error_message(&error, r));
3521                 return r;
3522         }
3523
3524         r = sd_bus_message_enter_container(reply, SD_BUS_TYPE_ARRAY, "{sv}");
3525         if (r < 0)
3526                 return bus_log_parse_error(r);
3527
3528         if (*new_line)
3529                 printf("\n");
3530
3531         *new_line = true;
3532
3533         while ((r = sd_bus_message_enter_container(reply, SD_BUS_TYPE_DICT_ENTRY, "sv")) > 0) {
3534                 const char *name, *contents;
3535
3536                 r = sd_bus_message_read(reply, "s", &name);
3537                 if (r < 0)
3538                         return bus_log_parse_error(r);
3539
3540                 r = sd_bus_message_peek_type(reply, NULL, &contents);
3541                 if (r < 0)
3542                         return bus_log_parse_error(r);
3543
3544                 r = sd_bus_message_enter_container(reply, SD_BUS_TYPE_VARIANT, contents);
3545                 if (r < 0)
3546                         return bus_log_parse_error(r);
3547
3548                 if (show_properties)
3549                         r = print_property(name, reply, contents);
3550                 else
3551                         r = status_property(name, reply, &info, contents);
3552                 if (r < 0)
3553                         return r;
3554
3555                 r = sd_bus_message_exit_container(reply);
3556                 if (r < 0)
3557                         return bus_log_parse_error(r);
3558
3559                 r = sd_bus_message_exit_container(reply);
3560                 if (r < 0)
3561                         return bus_log_parse_error(r);
3562         }
3563         if (r < 0)
3564                 return bus_log_parse_error(r);
3565
3566         r = sd_bus_message_exit_container(reply);
3567         if (r < 0)
3568                 return bus_log_parse_error(r);
3569
3570         r = 0;
3571
3572         if (!show_properties) {
3573                 if (streq(verb, "help"))
3574                         show_unit_help(&info);
3575                 else
3576                         print_status_info(&info, ellipsized);
3577         }
3578
3579         strv_free(info.documentation);
3580         strv_free(info.dropin_paths);
3581         strv_free(info.listen);
3582
3583         if (!streq_ptr(info.active_state, "active") &&
3584             !streq_ptr(info.active_state, "reloading") &&
3585             streq(verb, "status")) {
3586                 /* According to LSB: "program not running" */
3587                 /* 0: program is running or service is OK
3588                  * 1: program is dead and /var/run pid file exists
3589                  * 2: program is dead and /var/lock lock file exists
3590                  * 3: program is not running
3591                  * 4: program or service status is unknown
3592                  */
3593                 if (info.pid_file && access(info.pid_file, F_OK) == 0)
3594                         r = 1;
3595                 else
3596                         r = 3;
3597         }
3598
3599         while ((p = info.exec)) {
3600                 LIST_REMOVE(exec, info.exec, p);
3601                 exec_status_info_free(p);
3602         }
3603
3604         return r;
3605 }
3606
3607 static int get_unit_dbus_path_by_pid(
3608                 sd_bus *bus,
3609                 uint32_t pid,
3610                 char **unit) {
3611
3612         _cleanup_bus_error_free_ sd_bus_error error = SD_BUS_ERROR_NULL;
3613         _cleanup_bus_message_unref_ sd_bus_message *reply = NULL;
3614         int r;
3615
3616         r = sd_bus_call_method(
3617                         bus,
3618                         "org.freedesktop.systemd1",
3619                         "/org/freedesktop/systemd1",
3620                         "org.freedesktop.systemd1.Manager",
3621                         "GetUnitByPID",
3622                         &error,
3623                         &reply,
3624                         "u", pid);
3625         if (r < 0) {
3626                 log_error("Failed to get unit for PID %lu: %s", (unsigned long) pid, bus_error_message(&error, r));
3627                 return r;
3628         }
3629
3630         r = sd_bus_message_read(reply, "o", unit);
3631         if (r < 0)
3632                 return bus_log_parse_error(r);
3633
3634         return 0;
3635 }
3636
3637 static int show_all(
3638                 const char* verb,
3639                 sd_bus *bus,
3640                 bool show_properties,
3641                 bool *new_line,
3642                 bool *ellipsized) {
3643
3644         _cleanup_bus_message_unref_ sd_bus_message *reply = NULL;
3645         _cleanup_free_ UnitInfo *unit_infos = NULL;
3646         const UnitInfo *u;
3647         unsigned c;
3648         int r;
3649
3650         r = get_unit_list(bus, &reply, &unit_infos);
3651         if (r < 0)
3652                 return r;
3653
3654         pager_open_if_enabled();
3655
3656         c = (unsigned) r;
3657
3658         qsort_safe(unit_infos, c, sizeof(UnitInfo), compare_unit_info);
3659
3660         for (u = unit_infos; u < unit_infos + c; u++) {
3661                 _cleanup_free_ char *p = NULL;
3662
3663                 if (!output_show_unit(u))
3664                         continue;
3665
3666                 p = unit_dbus_path_from_name(u->id);
3667                 if (!p)
3668                         return log_oom();
3669
3670                 r = show_one(verb, bus, p, show_properties, new_line, ellipsized);
3671                 if (r != 0)
3672                         return r;
3673         }
3674
3675         return 0;
3676 }
3677
3678 static int cat(sd_bus *bus, char **args) {
3679         int r = 0;
3680         char **name;
3681
3682         _cleanup_free_ char *unit = NULL, *n = NULL;
3683
3684         assert(bus);
3685         assert(args);
3686
3687         pager_open_if_enabled();
3688
3689         STRV_FOREACH(name, args+1) {
3690                 _cleanup_free_ char *fragment_path = NULL;
3691                 _cleanup_strv_free_ char **dropin_paths = NULL;
3692                 sd_bus_error error;
3693                 char **path;
3694
3695                 n = unit_name_mangle(*name);
3696                 if (!n)
3697                         return log_oom();
3698
3699                 unit = unit_dbus_path_from_name(n);
3700                 if (!unit)
3701                         return log_oom();
3702
3703                 if (need_daemon_reload(bus, n) > 0)
3704                         log_warning("Unit file of %s changed on disk. Run 'systemctl%s daemon-reload'.",
3705                                     n, arg_scope == UNIT_FILE_SYSTEM ? "" : " --user");
3706
3707                 r = sd_bus_get_property_string(
3708                                 bus,
3709                                 "org.freedesktop.systemd1",
3710                                 unit,
3711                                 "org.freedesktop.systemd1.Unit",
3712                                 "FragmentPath",
3713                                 &error,
3714                                 &fragment_path);
3715                 if (r < 0) {
3716                         log_warning("Failed to get FragmentPath: %s", bus_error_message(&error, r));
3717                         continue;
3718                 }
3719
3720                 r = sd_bus_get_property_strv(
3721                                 bus,
3722                                 "org.freedesktop.systemd1",
3723                                 unit,
3724                                 "org.freedesktop.systemd1.Unit",
3725                                 "DropInPaths",
3726                                 &error,
3727                                 &dropin_paths);
3728                 if (r < 0) {
3729                         log_warning("Failed to get DropInPaths: %s", bus_error_message(&error, r));
3730                         continue;
3731                 }
3732
3733                 if (!isempty(fragment_path)) {
3734                         fprintf(stdout, "# %s\n", fragment_path);
3735                         fflush(stdout);
3736                         r = sendfile_full(STDOUT_FILENO, fragment_path);
3737                         if (r < 0) {
3738                                 log_warning("Failed to cat %s: %s", fragment_path, strerror(-r));
3739                                 continue;
3740                         }
3741                 }
3742
3743                 STRV_FOREACH(path, dropin_paths) {
3744                         fprintf(stdout,   "%s# %s\n",
3745                                 isempty(fragment_path) && path == dropin_paths ? "" : "\n",
3746                                 *path);
3747                         fflush(stdout);
3748                         r = sendfile_full(STDOUT_FILENO, *path);
3749                         if (r < 0) {
3750                                 log_warning("Failed to cat %s: %s", *path, strerror(-r));
3751                                 continue;
3752                         }
3753                 }
3754         }
3755
3756         return r;
3757 }
3758
3759 static int show(sd_bus *bus, char **args) {
3760         int r, ret = 0;
3761         bool show_properties, show_status, new_line = false;
3762         char **name;
3763         bool ellipsized = false;
3764
3765         assert(bus);
3766         assert(args);
3767
3768         show_properties = streq(args[0], "show");
3769         show_status = streq(args[0], "status");
3770
3771         if (show_properties)
3772                 pager_open_if_enabled();
3773
3774         /* If no argument is specified inspect the manager itself */
3775
3776         if (show_properties && strv_length(args) <= 1)
3777                 return show_one(args[0], bus, "/org/freedesktop/systemd1", show_properties, &new_line, &ellipsized);
3778
3779         if (show_status && strv_length(args) <= 1)
3780                 ret = show_all(args[0], bus, false, &new_line, &ellipsized);
3781         else
3782                 STRV_FOREACH(name, args+1) {
3783                         _cleanup_free_ char *unit = NULL;
3784                         uint32_t id;
3785
3786                         if (safe_atou32(*name, &id) < 0) {
3787                                 _cleanup_free_ char *n = NULL;
3788                                 /* Interpret as unit name */
3789
3790                                 n = unit_name_mangle(*name);
3791                                 if (!n)
3792                                         return log_oom();
3793
3794                                 unit = unit_dbus_path_from_name(n);
3795                                 if (!unit)
3796                                         return log_oom();
3797
3798                         } else if (show_properties) {
3799                                 /* Interpret as job id */
3800                                 if (asprintf(&unit, "/org/freedesktop/systemd1/job/%u", id) < 0)
3801                                         return log_oom();
3802
3803                         } else {
3804                                 /* Interpret as PID */
3805                                 r = get_unit_dbus_path_by_pid(bus, id, &unit);
3806                                 if (r < 0)
3807                                         ret = r;
3808                         }
3809
3810                         show_one(args[0], bus, unit, show_properties, &new_line, &ellipsized);
3811                 }
3812
3813         if (ellipsized && !arg_quiet)
3814                 printf("Hint: Some lines were ellipsized, use -l to show in full.\n");
3815
3816         return ret;
3817 }
3818
3819 static int append_assignment(sd_bus_message *m, const char *assignment) {
3820         const char *eq;
3821         char *field;
3822         int r;
3823
3824         assert(m);
3825         assert(assignment);
3826
3827         eq = strchr(assignment, '=');
3828         if (!eq) {
3829                 log_error("Not an assignment: %s", assignment);
3830                 return -EINVAL;
3831         }
3832
3833         field = strndupa(assignment, eq - assignment);
3834         eq ++;
3835
3836         r = sd_bus_message_append_basic(m, SD_BUS_TYPE_STRING, field);
3837         if (r < 0)
3838                 return bus_log_create_error(r);
3839
3840         if (streq(field, "CPUAccounting") ||
3841             streq(field, "MemoryAccounting") ||
3842             streq(field, "BlockIOAccounting")) {
3843
3844                 r = parse_boolean(eq);
3845                 if (r < 0) {
3846                         log_error("Failed to parse boolean assignment %s.", assignment);
3847                         return -EINVAL;
3848                 }
3849
3850                 r = sd_bus_message_append(m, "v", "b", r);
3851
3852         } else if (streq(field, "MemoryLimit")) {
3853                 off_t bytes;
3854
3855                 r = parse_bytes(eq, &bytes);
3856                 if (r < 0) {
3857                         log_error("Failed to parse bytes specification %s", assignment);
3858                         return -EINVAL;
3859                 }
3860
3861                 r = sd_bus_message_append(m, "v", "t", (uint64_t) bytes);
3862
3863         } else if (streq(field, "CPUShares") || streq(field, "BlockIOWeight")) {
3864                 uint64_t u;
3865
3866                 r = safe_atou64(eq, &u);
3867                 if (r < 0) {
3868                         log_error("Failed to parse %s value %s.", field, eq);
3869                         return -EINVAL;
3870                 }
3871
3872                 r = sd_bus_message_append(m, "v", "t", u);
3873
3874         } else if (streq(field, "DevicePolicy"))
3875                 r = sd_bus_message_append(m, "v", "s", eq);
3876
3877         else if (streq(field, "DeviceAllow")) {
3878
3879                 if (isempty(eq))
3880                         r = sd_bus_message_append(m, "v", "a(ss)", 0);
3881                 else {
3882                         const char *path, *rwm;
3883                         char *e;
3884
3885                         e = strchr(eq, ' ');
3886                         if (e) {
3887                                 path = strndupa(eq, e - eq);
3888                                 rwm = e+1;
3889                         } else {
3890                                 path = eq;
3891                                 rwm = "";
3892                         }
3893
3894                         if (!path_startswith(path, "/dev")) {
3895                                 log_error("%s is not a device file in /dev.", path);
3896                                 return -EINVAL;
3897                         }
3898
3899                         r = sd_bus_message_append(m, "v", "a(ss)", 1, path, rwm);
3900                 }
3901
3902         } else if (streq(field, "BlockIOReadBandwidth") || streq(field, "BlockIOWriteBandwidth")) {
3903
3904                 if (isempty(eq))
3905                         r = sd_bus_message_append(m, "v", "a(st)", 0);
3906                 else {
3907                         const char *path, *bandwidth;
3908                         off_t bytes;
3909                         char *e;
3910
3911                         e = strchr(eq, ' ');
3912                         if (e) {
3913                                 path = strndupa(eq, e - eq);
3914                                 bandwidth = e+1;
3915                         } else {
3916                                 log_error("Failed to parse %s value %s.", field, eq);
3917                                 return -EINVAL;
3918                         }
3919
3920                         if (!path_startswith(path, "/dev")) {
3921                                 log_error("%s is not a device file in /dev.", path);
3922                                 return -EINVAL;
3923                         }
3924
3925                         r = parse_bytes(bandwidth, &bytes);
3926                         if (r < 0) {
3927                                 log_error("Failed to parse byte value %s.", bandwidth);
3928                                 return -EINVAL;
3929                         }
3930
3931                         r = sd_bus_message_append(m, "v", "a(st)", 1, path, (uint64_t) bytes);
3932                 }
3933
3934         } else if (streq(field, "BlockIODeviceWeight")) {
3935
3936                 if (isempty(eq))
3937                         r = sd_bus_message_append(m, "v", "a(st)", 0);
3938                 else {
3939                         const char *path, *weight;
3940                         uint64_t u;
3941                         char *e;
3942
3943                         e = strchr(eq, ' ');
3944                         if (e) {
3945                                 path = strndupa(eq, e - eq);
3946                                 weight = e+1;
3947                         } else {
3948                                 log_error("Failed to parse %s value %s.", field, eq);
3949                                 return -EINVAL;
3950                         }
3951
3952                         if (!path_startswith(path, "/dev")) {
3953                                 log_error("%s is not a device file in /dev.", path);
3954                                 return -EINVAL;
3955                         }
3956
3957                         r = safe_atou64(weight, &u);
3958                         if (r < 0) {
3959                                 log_error("Failed to parse %s value %s.", field, weight);
3960                                 return -EINVAL;
3961                         }
3962                         r = sd_bus_message_append(m, "v", "a(st)", path, u);
3963                 }
3964
3965         } else {
3966                 log_error("Unknown assignment %s.", assignment);
3967                 return -EINVAL;
3968         }
3969
3970         if (r < 0)
3971                 return bus_log_create_error(r);
3972
3973         return 0;
3974 }
3975
3976 static int set_property(sd_bus *bus, char **args) {
3977         _cleanup_bus_message_unref_ sd_bus_message *m = NULL;
3978         _cleanup_bus_error_free_ sd_bus_error error = SD_BUS_ERROR_NULL;
3979         _cleanup_free_ char *n = NULL;
3980         char **i;
3981         int r;
3982
3983         r = sd_bus_message_new_method_call(
3984                         bus,
3985                         "org.freedesktop.systemd1",
3986                         "/org/freedesktop/systemd1",
3987                         "org.freedesktop.systemd1.Manager",
3988                         "SetUnitProperties",
3989                         &m);
3990         if (r < 0)
3991                 return bus_log_create_error(r);
3992
3993         n = unit_name_mangle(args[1]);
3994         if (!n)
3995                 return log_oom();
3996
3997         r = sd_bus_message_append(m, "sb", n, arg_runtime);
3998         if (r < 0)
3999                 return bus_log_create_error(r);
4000
4001         r = sd_bus_message_open_container(m, SD_BUS_TYPE_ARRAY, "(sv)");
4002         if (r < 0)
4003                 return bus_log_create_error(r);
4004
4005         STRV_FOREACH(i, args + 2) {
4006                 r = sd_bus_message_open_container(m, SD_BUS_TYPE_STRUCT, "sv");
4007                 if (r < 0)
4008                         return bus_log_create_error(r);
4009
4010                 r = append_assignment(m, *i);
4011                 if (r < 0)
4012                         return r;
4013
4014                 r = sd_bus_message_close_container(m);
4015                 if (r < 0)
4016                         return bus_log_create_error(r);
4017         }
4018
4019         r = sd_bus_message_close_container(m);
4020         if (r < 0)
4021                 return bus_log_create_error(r);
4022
4023         r = sd_bus_call(bus, m, 0, &error, NULL);
4024         if (r < 0) {
4025                 log_error("Failed to set unit properties on %s: %s", n, bus_error_message(&error, r));
4026                 return r;
4027         }
4028
4029         return 0;
4030 }
4031
4032 static int snapshot(sd_bus *bus, char **args) {
4033         _cleanup_bus_error_free_ sd_bus_error error = SD_BUS_ERROR_NULL;
4034         _cleanup_bus_message_unref_ sd_bus_message *reply = NULL;
4035         _cleanup_free_ char *n = NULL, *id = NULL;
4036         const char *path;
4037         int r;
4038
4039         if (strv_length(args) > 1)
4040                 n = unit_name_mangle_with_suffix(args[1], ".snapshot");
4041         else
4042                 n = strdup("");
4043         if (!n)
4044                 return log_oom();
4045
4046         r = sd_bus_call_method(
4047                         bus,
4048                         "org.freedesktop.systemd1",
4049                         "/org/freedesktop/systemd1",
4050                         "org.freedesktop.systemd1.Manager",
4051                         "CreateSnapshot",
4052                         &error,
4053                         &reply,
4054                         "sb", n, false);
4055         if (r < 0) {
4056                 log_error("Failed to create snapshot: %s", bus_error_message(&error, r));
4057                 return r;
4058         }
4059
4060         r = sd_bus_message_read(reply, "o", &path);
4061         if (r < 0)
4062                 return bus_log_parse_error(r);
4063
4064         r = sd_bus_get_property_string(
4065                         bus,
4066                         "org.freedesktop.systemd1",
4067                         path,
4068                         "org.freedesktop.systemd1.Unit",
4069                         "Id",
4070                         &error,
4071                         &id);
4072         if (r < 0) {
4073                 log_error("Failed to get ID of snapshot: %s", bus_error_message(&error, r));
4074                 return r;
4075         }
4076
4077         if (!arg_quiet)
4078                 puts(id);
4079
4080         return 0;
4081 }
4082
4083 static int delete_snapshot(sd_bus *bus, char **args) {
4084         _cleanup_bus_error_free_ sd_bus_error error = SD_BUS_ERROR_NULL;
4085         char **name;
4086         int r;
4087
4088         assert(args);
4089
4090         STRV_FOREACH(name, args+1) {
4091                 _cleanup_free_ char *n = NULL;
4092
4093                 n = unit_name_mangle_with_suffix(*name, ".snapshot");
4094                 if (!n)
4095                         return log_oom();
4096
4097                 r = sd_bus_call_method(
4098                                 bus,
4099                                 "org.freedesktop.systemd1",
4100                                 "/org/freedesktop/systemd1",
4101                                 "org.freedesktop.systemd1.Manager",
4102                                 "RemoveSnapshot",
4103                                 &error,
4104                                 NULL,
4105                                 "s", n);
4106                 if (r < 0) {
4107                         log_error("Failed to remove snapshot %s: %s", n, bus_error_message(&error, r));
4108                         return r;
4109                 }
4110         }
4111
4112         return 0;
4113 }
4114
4115 static int daemon_reload(sd_bus *bus, char **args) {
4116         _cleanup_bus_error_free_ sd_bus_error error = SD_BUS_ERROR_NULL;
4117         const char *method;
4118         int r;
4119
4120         if (arg_action == ACTION_RELOAD)
4121                 method = "Reload";
4122         else if (arg_action == ACTION_REEXEC)
4123                 method = "Reexecute";
4124         else {
4125                 assert(arg_action == ACTION_SYSTEMCTL);
4126
4127                 method =
4128                         streq(args[0], "clear-jobs")    ||
4129                         streq(args[0], "cancel")        ? "ClearJobs" :
4130                         streq(args[0], "daemon-reexec") ? "Reexecute" :
4131                         streq(args[0], "reset-failed")  ? "ResetFailed" :
4132                         streq(args[0], "halt")          ? "Halt" :
4133                         streq(args[0], "poweroff")      ? "PowerOff" :
4134                         streq(args[0], "reboot")        ? "Reboot" :
4135                         streq(args[0], "kexec")         ? "KExec" :
4136                         streq(args[0], "exit")          ? "Exit" :
4137                                     /* "daemon-reload" */ "Reload";
4138         }
4139
4140         r = sd_bus_call_method(
4141                         bus,
4142                         "org.freedesktop.systemd1",
4143                         "/org/freedesktop/systemd1",
4144                         "org.freedesktop.systemd1.Manager",
4145                         method,
4146                         &error,
4147                         NULL,
4148                         NULL);
4149
4150         if (r == -ENOENT && arg_action != ACTION_SYSTEMCTL)
4151                 /* There's always a fallback possible for
4152                  * legacy actions. */
4153                 r = -EADDRNOTAVAIL;
4154         else if ((r == -ETIMEDOUT || r == -ECONNRESET) && streq(method, "Reexecute"))
4155                 /* On reexecution, we expect a disconnect, not a
4156                  * reply */
4157                 r = 0;
4158         else if (r < 0)
4159                 log_error("Failed to execute operation: %s", bus_error_message(&error, r));
4160
4161         return r < 0 ? r : 0;
4162 }
4163
4164 static int reset_failed(sd_bus *bus, char **args) {
4165         _cleanup_bus_error_free_ sd_bus_error error = SD_BUS_ERROR_NULL;
4166         char **name;
4167         int r;
4168
4169         if (strv_length(args) <= 1)
4170                 return daemon_reload(bus, args);
4171
4172         STRV_FOREACH(name, args+1) {
4173                 _cleanup_free_ char *n;
4174
4175                 n = unit_name_mangle(*name);
4176                 if (!n)
4177                         return log_oom();
4178
4179                 r = sd_bus_call_method(
4180                                 bus,
4181                                 "org.freedesktop.systemd1",
4182                                 "/org/freedesktop/systemd1",
4183                                 "org.freedesktop.systemd1.Manager",
4184                                 "ResetFailedUnit",
4185                                 &error,
4186                                 NULL,
4187                                 "s", n);
4188                 if (r < 0) {
4189                         log_error("Failed to reset failed state of unit %s: %s", n, bus_error_message(&error, r));
4190                         return r;
4191                 }
4192         }
4193
4194         return 0;
4195 }
4196
4197 static int show_environment(sd_bus *bus, char **args) {
4198         _cleanup_bus_error_free_ sd_bus_error error = SD_BUS_ERROR_NULL;
4199         _cleanup_bus_message_unref_ sd_bus_message *reply = NULL;
4200         const char *text;
4201         int r;
4202
4203         pager_open_if_enabled();
4204
4205         r = sd_bus_get_property(
4206                         bus,
4207                         "org.freedesktop.systemd1",
4208                         "/org/freedesktop/systemd1",
4209                         "org.freedesktop.systemd1.Manager",
4210                         "Environment",
4211                         &error,
4212                         &reply,
4213                         "as");
4214         if (r < 0) {
4215                 log_error("Failed to get environment: %s", bus_error_message(&error, r));
4216                 return r;
4217         }
4218
4219         r = sd_bus_message_enter_container(reply, SD_BUS_TYPE_ARRAY, "s");
4220         if (r < 0)
4221                 return bus_log_parse_error(r);
4222
4223         while ((r = sd_bus_message_read_basic(reply, SD_BUS_TYPE_STRING, &text)) > 0)
4224                 puts(text);
4225         if (r < 0)
4226                 return bus_log_parse_error(r);
4227
4228         r = sd_bus_message_exit_container(reply);
4229         if (r < 0)
4230                 return bus_log_parse_error(r);
4231
4232         return 0;
4233 }
4234
4235 static int switch_root(sd_bus *bus, char **args) {
4236         _cleanup_bus_error_free_ sd_bus_error error = SD_BUS_ERROR_NULL;
4237         _cleanup_free_ char *init = NULL;
4238         const char *root;
4239         unsigned l;
4240         int r;
4241
4242         l = strv_length(args);
4243         if (l < 2 || l > 3) {
4244                 log_error("Wrong number of arguments.");
4245                 return -EINVAL;
4246         }
4247
4248         root = args[1];
4249
4250         if (l >= 3)
4251                 init = strdup(args[2]);
4252         else {
4253                 parse_env_file("/proc/cmdline", WHITESPACE,
4254                                "init", &init,
4255                                NULL);
4256
4257                 if (!init)
4258                         init = strdup("");
4259         }
4260
4261         if (!init)
4262                 return log_oom();
4263
4264         log_debug("switching root - root: %s; init: %s", root, init);
4265
4266         r = sd_bus_call_method(
4267                         bus,
4268                         "org.freedesktop.systemd1",
4269                         "/org/freedesktop/systemd1",
4270                         "org.freedesktop.systemd1.Manager",
4271                         "SwitchRoot",
4272                         &error,
4273                         NULL,
4274                         "ss", root, init);
4275         if (r < 0) {
4276                 log_error("Failed to switch root: %s", bus_error_message(&error, r));
4277                 return r;
4278         }
4279
4280         return 0;
4281 }
4282
4283 static int set_environment(sd_bus *bus, char **args) {
4284         _cleanup_bus_error_free_ sd_bus_error error = SD_BUS_ERROR_NULL;
4285         _cleanup_bus_message_unref_ sd_bus_message *m = NULL;
4286         const char *method;
4287         int r;
4288
4289         assert(bus);
4290         assert(args);
4291
4292         method = streq(args[0], "set-environment")
4293                 ? "SetEnvironment"
4294                 : "UnsetEnvironment";
4295
4296         r = sd_bus_message_new_method_call(
4297                         bus,
4298                         "org.freedesktop.systemd1",
4299                         "/org/freedesktop/systemd1",
4300                         "org.freedesktop.systemd1.Manager",
4301                         method,
4302                         &m);
4303         if (r < 0)
4304                 return bus_log_create_error(r);
4305
4306         r = sd_bus_message_append_strv(m, args + 1);
4307         if (r < 0)
4308                 return bus_log_create_error(r);
4309
4310         r = sd_bus_call(bus, m, 0, &error, NULL);
4311         if (r < 0) {
4312                 log_error("Failed to set environment: %s", bus_error_message(&error, r));
4313                 return r;
4314         }
4315
4316         return 0;
4317 }
4318
4319 static int enable_sysv_units(const char *verb, char **args) {
4320         int r = 0;
4321
4322 #if defined(HAVE_SYSV_COMPAT) && defined(HAVE_CHKCONFIG)
4323         unsigned f = 1, t = 1;
4324         _cleanup_lookup_paths_free_ LookupPaths paths = {};
4325
4326         if (arg_scope != UNIT_FILE_SYSTEM)
4327                 return 0;
4328
4329         if (!streq(verb, "enable") &&
4330             !streq(verb, "disable") &&
4331             !streq(verb, "is-enabled"))
4332                 return 0;
4333
4334         /* Processes all SysV units, and reshuffles the array so that
4335          * afterwards only the native units remain */
4336
4337         r = lookup_paths_init(&paths, SYSTEMD_SYSTEM, false, NULL, NULL, NULL);
4338         if (r < 0)
4339                 return r;
4340
4341         r = 0;
4342         for (f = 0; args[f]; f++) {
4343                 const char *name;
4344                 _cleanup_free_ char *p = NULL, *q = NULL;
4345                 bool found_native = false, found_sysv;
4346                 unsigned c = 1;
4347                 const char *argv[6] = { "/sbin/chkconfig", NULL, NULL, NULL, NULL };
4348                 char **k, *l;
4349                 int j;
4350                 pid_t pid;
4351                 siginfo_t status;
4352
4353                 name = args[f];
4354
4355                 if (!endswith(name, ".service"))
4356                         continue;
4357
4358                 if (path_is_absolute(name))
4359                         continue;
4360
4361                 STRV_FOREACH(k, paths.unit_path) {
4362                         if (!isempty(arg_root))
4363                                 asprintf(&p, "%s/%s/%s", arg_root, *k, name);
4364                         else
4365                                 asprintf(&p, "%s/%s", *k, name);
4366
4367                         if (!p) {
4368                                 r = log_oom();
4369                                 goto finish;
4370                         }
4371
4372                         found_native = access(p, F_OK) >= 0;
4373                         free(p);
4374                         p = NULL;
4375
4376                         if (found_native)
4377                                 break;
4378                 }
4379
4380                 if (found_native)
4381                         continue;
4382
4383                 if (!isempty(arg_root))
4384                         asprintf(&p, "%s/" SYSTEM_SYSVINIT_PATH "/%s", arg_root, name);
4385                 else
4386                         asprintf(&p, SYSTEM_SYSVINIT_PATH "/%s", name);
4387                 if (!p) {
4388                         r = log_oom();
4389                         goto finish;
4390                 }
4391
4392                 p[strlen(p) - sizeof(".service") + 1] = 0;
4393                 found_sysv = access(p, F_OK) >= 0;
4394
4395                 if (!found_sysv)
4396                         continue;
4397
4398                 /* Mark this entry, so that we don't try enabling it as native unit */
4399                 args[f] = (char*) "";
4400
4401                 log_info("%s is not a native service, redirecting to /sbin/chkconfig.", name);
4402
4403                 if (!isempty(arg_root))
4404                         argv[c++] = q = strappend("--root=", arg_root);
4405
4406                 argv[c++] = path_get_file_name(p);
4407                 argv[c++] =
4408                         streq(verb, "enable") ? "on" :
4409                         streq(verb, "disable") ? "off" : "--level=5";
4410                 argv[c] = NULL;
4411
4412                 l = strv_join((char**)argv, " ");
4413                 if (!l) {
4414                         r = log_oom();
4415                         goto finish;
4416                 }
4417
4418                 log_info("Executing %s", l);
4419                 free(l);
4420
4421                 pid = fork();
4422                 if (pid < 0) {
4423                         log_error("Failed to fork: %m");
4424                         r = -errno;
4425                         goto finish;
4426                 } else if (pid == 0) {
4427                         /* Child */
4428
4429                         execv(argv[0], (char**) argv);
4430                         _exit(EXIT_FAILURE);
4431                 }
4432
4433                 j = wait_for_terminate(pid, &status);
4434                 if (j < 0) {
4435                         log_error("Failed to wait for child: %s", strerror(-r));
4436                         r = j;
4437                         goto finish;
4438                 }
4439
4440                 if (status.si_code == CLD_EXITED) {
4441                         if (streq(verb, "is-enabled")) {
4442                                 if (status.si_status == 0) {
4443                                         if (!arg_quiet)
4444                                                 puts("enabled");
4445                                         r = 1;
4446                                 } else {
4447                                         if (!arg_quiet)
4448                                                 puts("disabled");
4449                                 }
4450
4451                         } else if (status.si_status != 0) {
4452                                 r = -EINVAL;
4453                                 goto finish;
4454                         }
4455                 } else {
4456                         r = -EPROTO;
4457                         goto finish;
4458                 }
4459         }
4460
4461 finish:
4462         /* Drop all SysV units */
4463         for (f = 0, t = 0; args[f]; f++) {
4464
4465                 if (isempty(args[f]))
4466                         continue;
4467
4468                 args[t++] = args[f];
4469         }
4470
4471         args[t] = NULL;
4472
4473 #endif
4474         return r;
4475 }
4476
4477 static int mangle_names(char **original_names, char ***mangled_names) {
4478         char **i, **l, **name;
4479
4480         l = new(char*, strv_length(original_names) + 1);
4481         if (!l)
4482                 return log_oom();
4483
4484         i = l;
4485         STRV_FOREACH(name, original_names) {
4486
4487                 /* When enabling units qualified path names are OK,
4488                  * too, hence allow them explicitly. */
4489
4490                 if (is_path(*name))
4491                         *i = strdup(*name);
4492                 else
4493                         *i = unit_name_mangle(*name);
4494
4495                 if (!*i) {
4496                         strv_free(l);
4497                         return log_oom();
4498                 }
4499
4500                 i++;
4501         }
4502
4503         *i = NULL;
4504         *mangled_names = l;
4505
4506         return 0;
4507 }
4508
4509 static int enable_unit(sd_bus *bus, char **args) {
4510         _cleanup_strv_free_ char **mangled_names = NULL;
4511         const char *verb = args[0];
4512         UnitFileChange *changes = NULL;
4513         unsigned n_changes = 0;
4514         int carries_install_info = -1;
4515         int r;
4516
4517         if (!args[1])
4518                 return 0;
4519
4520         r = mangle_names(args+1, &mangled_names);
4521         if (r < 0)
4522                 return r;
4523
4524         r = enable_sysv_units(verb, mangled_names);
4525         if (r < 0)
4526                 return r;
4527
4528         if (!bus || avoid_bus()) {
4529                 if (streq(verb, "enable")) {
4530                         r = unit_file_enable(arg_scope, arg_runtime, arg_root, mangled_names, arg_force, &changes, &n_changes);
4531                         carries_install_info = r;
4532                 } else if (streq(verb, "disable"))
4533                         r = unit_file_disable(arg_scope, arg_runtime, arg_root, mangled_names, &changes, &n_changes);
4534                 else if (streq(verb, "reenable")) {
4535                         r = unit_file_reenable(arg_scope, arg_runtime, arg_root, mangled_names, arg_force, &changes, &n_changes);
4536                         carries_install_info = r;
4537                 } else if (streq(verb, "link"))
4538                         r = unit_file_link(arg_scope, arg_runtime, arg_root, mangled_names, arg_force, &changes, &n_changes);
4539                 else if (streq(verb, "preset")) {
4540                         r = unit_file_preset(arg_scope, arg_runtime, arg_root, mangled_names, arg_force, &changes, &n_changes);
4541                         carries_install_info = r;
4542                 } else if (streq(verb, "mask"))
4543                         r = unit_file_mask(arg_scope, arg_runtime, arg_root, mangled_names, arg_force, &changes, &n_changes);
4544                 else if (streq(verb, "unmask"))
4545                         r = unit_file_unmask(arg_scope, arg_runtime, arg_root, mangled_names, &changes, &n_changes);
4546                 else
4547                         assert_not_reached("Unknown verb");
4548
4549                 if (r < 0) {
4550                         log_error("Operation failed: %s", strerror(-r));
4551                         goto finish;
4552                 }
4553
4554                 if (!arg_quiet)
4555                         dump_unit_file_changes(changes, n_changes);
4556
4557                 r = 0;
4558         } else {
4559                 _cleanup_bus_message_unref_ sd_bus_message *reply = NULL, *m = NULL;
4560                 _cleanup_bus_error_free_ sd_bus_error error = SD_BUS_ERROR_NULL;
4561                 int expect_carries_install_info = false;
4562                 bool send_force = true;
4563                 const char *method;
4564
4565                 if (streq(verb, "enable")) {
4566                         method = "EnableUnitFiles";
4567                         expect_carries_install_info = true;
4568                 } else if (streq(verb, "disable")) {
4569                         method = "DisableUnitFiles";
4570                         send_force = false;
4571                 } else if (streq(verb, "reenable")) {
4572                         method = "ReenableUnitFiles";
4573                         expect_carries_install_info = true;
4574                 } else if (streq(verb, "link"))
4575                         method = "LinkUnitFiles";
4576                 else if (streq(verb, "preset")) {
4577                         method = "PresetUnitFiles";
4578                         expect_carries_install_info = true;
4579                 } else if (streq(verb, "mask"))
4580                         method = "MaskUnitFiles";
4581                 else if (streq(verb, "unmask")) {
4582                         method = "UnmaskUnitFiles";
4583                         send_force = false;
4584                 } else
4585                         assert_not_reached("Unknown verb");
4586
4587                 r = sd_bus_message_new_method_call(
4588                                 bus,
4589                                 "org.freedesktop.systemd1",
4590                                 "/org/freedesktop/systemd1",
4591                                 "org.freedesktop.systemd1.Manager",
4592                                 method,
4593                                 &m);
4594                 if (r < 0)
4595                         return bus_log_create_error(r);
4596
4597                 r = sd_bus_message_append_strv(m, mangled_names);
4598                 if (r < 0)
4599                         return bus_log_create_error(r);
4600
4601                 r = sd_bus_message_append(m, "b", arg_runtime);
4602                 if (r < 0)
4603                         return bus_log_create_error(r);
4604
4605                 if (send_force) {
4606                         r = sd_bus_message_append(m, "b", arg_force);
4607                         if (r < 0)
4608                                 return bus_log_create_error(r);
4609                 }
4610
4611                 r = sd_bus_call(bus, m, 0, &error, &reply);
4612                 if (r < 0) {
4613                         log_error("Failed to execute operation: %s", bus_error_message(&error, r));
4614                         return r;
4615                 }
4616
4617                 if (expect_carries_install_info) {
4618                         r = sd_bus_message_read(reply, "b", &carries_install_info);
4619                         if (r < 0)
4620                                 return bus_log_parse_error(r);
4621                 }
4622
4623                 r = deserialize_and_dump_unit_file_changes(reply);
4624                 if (r < 0)
4625                         return r;
4626
4627                 /* Try to reload if enabeld */
4628                 if (!arg_no_reload)
4629                         r = daemon_reload(bus, args);
4630                 else
4631                         r = 0;
4632         }
4633
4634         if (carries_install_info == 0)
4635                 log_warning("The unit files have no [Install] section. They are not meant to be enabled\n"
4636                             "using systemctl.\n"
4637                             "Possible reasons for having this kind of units are:\n"
4638                             "1) A unit may be statically enabled by being symlinked from another unit's\n"
4639                             "   .wants/ or .requires/ directory.\n"
4640                             "2) A unit's purpose may be to act as a helper for some other unit which has\n"
4641                             "   a requirement dependency on it.\n"
4642                             "3) A unit may be started when needed via activation (socket, path, timer,\n"
4643                             "   D-Bus, udev, scripted systemctl call, ...).\n");
4644
4645 finish:
4646         unit_file_changes_free(changes, n_changes);
4647
4648         return r;
4649 }
4650
4651 static int unit_is_enabled(sd_bus *bus, char **args) {
4652
4653         _cleanup_bus_error_free_ sd_bus_error error = SD_BUS_ERROR_NULL;
4654         _cleanup_strv_free_ char **mangled_names = NULL;
4655         bool enabled;
4656         char **name;
4657         int r;
4658
4659         r = mangle_names(args+1, &mangled_names);
4660         if (r < 0)
4661                 return r;
4662
4663         r = enable_sysv_units(args[0], mangled_names);
4664         if (r < 0)
4665                 return r;
4666
4667         enabled = r > 0;
4668
4669         if (!bus || avoid_bus()) {
4670
4671                 STRV_FOREACH(name, mangled_names) {
4672                         UnitFileState state;
4673
4674                         state = unit_file_get_state(arg_scope, arg_root, *name);
4675                         if (state < 0) {
4676                                 log_error("Failed to get unit file state for %s: %s", *name, strerror(-state));
4677                                 return state;
4678                         }
4679
4680                         if (state == UNIT_FILE_ENABLED ||
4681                             state == UNIT_FILE_ENABLED_RUNTIME ||
4682                             state == UNIT_FILE_STATIC)
4683                                 enabled = true;
4684
4685                         if (!arg_quiet)
4686                                 puts(unit_file_state_to_string(state));
4687                 }
4688
4689         } else {
4690                 STRV_FOREACH(name, mangled_names) {
4691                         _cleanup_bus_message_unref_ sd_bus_message *reply = NULL;
4692                         const char *s;
4693
4694                         r = sd_bus_call_method(
4695                                         bus,
4696                                         "org.freedesktop.systemd1",
4697                                         "/org/freedesktop/systemd1",
4698                                         "org.freedesktop.systemd1.Manager",
4699                                         "GetUnitFileState",
4700                                         &error,
4701                                         &reply,
4702                                         "s", name);
4703                         if (r < 0) {
4704                                 log_error("Failed to get unit file state for %s: %s", *name, bus_error_message(&error, r));
4705                                 return r;
4706                         }
4707
4708                         r = sd_bus_message_read(reply, "s", &s);
4709                         if (r < 0)
4710                                 return bus_log_parse_error(r);
4711
4712                         if (streq(s, "enabled") ||
4713                             streq(s, "enabled-runtime") ||
4714                             streq(s, "static"))
4715                                 enabled = true;
4716
4717                         if (!arg_quiet)
4718                                 puts(s);
4719                 }
4720         }
4721
4722         return !enabled;
4723 }
4724
4725 static int systemctl_help(void) {
4726
4727         pager_open_if_enabled();
4728
4729         printf("%s [OPTIONS...] {COMMAND} ...\n\n"
4730                "Query or send control commands to the systemd manager.\n\n"
4731                "  -h --help           Show this help\n"
4732                "     --version        Show package version\n"
4733                "     --system         Connect to system manager\n"
4734                "     --user           Connect to user service manager\n"
4735                "  -H --host=[USER@]HOST\n"
4736                "                      Operate on remote host\n"
4737                "  -M --machine=CONTAINER\n"
4738                "                      Operate on local container\n"
4739                "  -t --type=TYPE      List only units of a particular type\n"
4740                "     --state=STATE    List only units with particular LOAD or SUB or ACTIVE state\n"
4741                "  -p --property=NAME  Show only properties by this name\n"
4742                "  -a --all            Show all loaded units/properties, including dead/empty\n"
4743                "                      ones. To list all units installed on the system, use\n"
4744                "                      the 'list-unit-files' command instead.\n"
4745                "  -l --full           Don't ellipsize unit names on output\n"
4746                "     --reverse        Show reverse dependencies with 'list-dependencies'\n"
4747                "     --job-mode=MODE  Specify how to deal with already queued jobs, when\n"
4748                "                      queueing a new job\n"
4749                "     --show-types     When showing sockets, explicitly show their type\n"
4750                "  -i --ignore-inhibitors\n"
4751                "                      When shutting down or sleeping, ignore inhibitors\n"
4752                "     --kill-who=WHO   Who to send signal to\n"
4753                "  -s --signal=SIGNAL  Which signal to send\n"
4754                "  -q --quiet          Suppress output\n"
4755                "     --no-block       Do not wait until operation finished\n"
4756                "     --no-wall        Don't send wall message before halt/power-off/reboot\n"
4757                "     --no-reload      When enabling/disabling unit files, don't reload daemon\n"
4758                "                      configuration\n"
4759                "     --no-legend      Do not print a legend (column headers and hints)\n"
4760                "     --no-pager       Do not pipe output into a pager\n"
4761                "     --no-ask-password\n"
4762                "                      Do not ask for system passwords\n"
4763                "     --global         Enable/disable unit files globally\n"
4764                "     --runtime        Enable unit files only temporarily until next reboot\n"
4765                "  -f --force          When enabling unit files, override existing symlinks\n"
4766                "                      When shutting down, execute action immediately\n"
4767                "     --root=PATH      Enable unit files in the specified root directory\n"
4768                "  -n --lines=INTEGER  Number of journal entries to show\n"
4769                "  -o --output=STRING  Change journal output mode (short, short-monotonic,\n"
4770                "                      verbose, export, json, json-pretty, json-sse, cat)\n\n"
4771                "Unit Commands:\n"
4772                "  list-units                      List loaded units\n"
4773                "  list-sockets                    List loaded sockets ordered by address\n"
4774                "  list-timers                     List loaded timers ordered by next elapse\n"
4775                "  start [NAME...]                 Start (activate) one or more units\n"
4776                "  stop [NAME...]                  Stop (deactivate) one or more units\n"
4777                "  reload [NAME...]                Reload one or more units\n"
4778                "  restart [NAME...]               Start or restart one or more units\n"
4779                "  try-restart [NAME...]           Restart one or more units if active\n"
4780                "  reload-or-restart [NAME...]     Reload one or more units if possible,\n"
4781                "                                  otherwise start or restart\n"
4782                "  reload-or-try-restart [NAME...] Reload one or more units if possible,\n"
4783                "                                  otherwise restart if active\n"
4784                "  isolate [NAME]                  Start one unit and stop all others\n"
4785                "  kill [NAME...]                  Send signal to processes of a unit\n"
4786                "  is-active [NAME...]             Check whether units are active\n"
4787                "  is-failed [NAME...]             Check whether units are failed\n"
4788                "  status [NAME...|PID...]         Show runtime status of one or more units\n"
4789                "  show [NAME...|JOB...]           Show properties of one or more\n"
4790                "                                  units/jobs or the manager\n"
4791                "  cat [NAME...]                   Show files and drop-ins of one or more units\n"
4792                "  set-property [NAME] [ASSIGNMENT...]\n"
4793                "                                  Sets one or more properties of a unit\n"
4794                "  help [NAME...|PID...]           Show manual for one or more units\n"
4795                "  reset-failed [NAME...]          Reset failed state for all, one, or more\n"
4796                "                                  units\n"
4797                "  list-dependencies [NAME]        Recursively show units which are required\n"
4798                "                                  or wanted by this unit or by which this\n"
4799                "                                  unit is required or wanted\n\n"
4800                "Unit File Commands:\n"
4801                "  list-unit-files                 List installed unit files\n"
4802                "  enable [NAME...]                Enable one or more unit files\n"
4803                "  disable [NAME...]               Disable one or more unit files\n"
4804                "  reenable [NAME...]              Reenable one or more unit files\n"
4805                "  preset [NAME...]                Enable/disable one or more unit files\n"
4806                "                                  based on preset configuration\n"
4807                "  is-enabled [NAME...]            Check whether unit files are enabled\n\n"
4808                "  mask [NAME...]                  Mask one or more units\n"
4809                "  unmask [NAME...]                Unmask one or more units\n"
4810                "  link [PATH...]                  Link one or more units files into\n"
4811                "                                  the search path\n"
4812                "  get-default                     Get the name of the default target\n"
4813                "  set-default NAME                Set the default target\n\n"
4814                "Job Commands:\n"
4815                "  list-jobs                       List jobs\n"
4816                "  cancel [JOB...]                 Cancel all, one, or more jobs\n\n"
4817                "Snapshot Commands:\n"
4818                "  snapshot [NAME]                 Create a snapshot\n"
4819                "  delete [NAME...]                Remove one or more snapshots\n\n"
4820                "Environment Commands:\n"
4821                "  show-environment                Dump environment\n"
4822                "  set-environment [NAME=VALUE...] Set one or more environment variables\n"
4823                "  unset-environment [NAME...]     Unset one or more environment variables\n\n"
4824                "Manager Lifecycle Commands:\n"
4825                "  daemon-reload                   Reload systemd manager configuration\n"
4826                "  daemon-reexec                   Reexecute systemd manager\n\n"
4827                "System Commands:\n"
4828                "  default                         Enter system default mode\n"
4829                "  rescue                          Enter system rescue mode\n"
4830                "  emergency                       Enter system emergency mode\n"
4831                "  halt                            Shut down and halt the system\n"
4832                "  poweroff                        Shut down and power-off the system\n"
4833                "  reboot [ARG]                    Shut down and reboot the system\n"
4834                "  kexec                           Shut down and reboot the system with kexec\n"
4835                "  exit                            Request user instance exit\n"
4836                "  switch-root [ROOT] [INIT]       Change to a different root file system\n"
4837                "  suspend                         Suspend the system\n"
4838                "  hibernate                       Hibernate the system\n"
4839                "  hybrid-sleep                    Hibernate and suspend the system\n",
4840                program_invocation_short_name);
4841
4842         return 0;
4843 }
4844
4845 static int halt_help(void) {
4846
4847         printf("%s [OPTIONS...]%s\n\n"
4848                "%s the system.\n\n"
4849                "     --help      Show this help\n"
4850                "     --halt      Halt the machine\n"
4851                "  -p --poweroff  Switch off the machine\n"
4852                "     --reboot    Reboot the machine\n"
4853                "  -f --force     Force immediate halt/power-off/reboot\n"
4854                "  -w --wtmp-only Don't halt/power-off/reboot, just write wtmp record\n"
4855                "  -d --no-wtmp   Don't write wtmp record\n"
4856                "     --no-wall   Don't send wall message before halt/power-off/reboot\n",
4857                program_invocation_short_name,
4858                arg_action == ACTION_REBOOT   ? " [ARG]" : "",
4859                arg_action == ACTION_REBOOT   ? "Reboot" :
4860                arg_action == ACTION_POWEROFF ? "Power off" :
4861                                                "Halt");
4862
4863         return 0;
4864 }
4865
4866 static int shutdown_help(void) {
4867
4868         printf("%s [OPTIONS...] [TIME] [WALL...]\n\n"
4869                "Shut down the system.\n\n"
4870                "     --help      Show this help\n"
4871                "  -H --halt      Halt the machine\n"
4872                "  -P --poweroff  Power-off the machine\n"
4873                "  -r --reboot    Reboot the machine\n"
4874                "  -h             Equivalent to --poweroff, overridden by --halt\n"
4875                "  -k             Don't halt/power-off/reboot, just send warnings\n"
4876                "     --no-wall   Don't send wall message before halt/power-off/reboot\n"
4877                "  -c             Cancel a pending shutdown\n",
4878                program_invocation_short_name);
4879
4880         return 0;
4881 }
4882
4883 static int telinit_help(void) {
4884
4885         printf("%s [OPTIONS...] {COMMAND}\n\n"
4886                "Send control commands to the init daemon.\n\n"
4887                "     --help      Show this help\n"
4888                "     --no-wall   Don't send wall message before halt/power-off/reboot\n\n"
4889                "Commands:\n"
4890                "  0              Power-off the machine\n"
4891                "  6              Reboot the machine\n"
4892                "  2, 3, 4, 5     Start runlevelX.target unit\n"
4893                "  1, s, S        Enter rescue mode\n"
4894                "  q, Q           Reload init daemon configuration\n"
4895                "  u, U           Reexecute init daemon\n",
4896                program_invocation_short_name);
4897
4898         return 0;
4899 }
4900
4901 static int runlevel_help(void) {
4902
4903         printf("%s [OPTIONS...]\n\n"
4904                "Prints the previous and current runlevel of the init system.\n\n"
4905                "     --help      Show this help\n",
4906                program_invocation_short_name);
4907
4908         return 0;
4909 }
4910
4911 static int help_types(void) {
4912         int i;
4913         const char *t;
4914
4915         puts("Available unit types:");
4916         for (i = 0; i < _UNIT_TYPE_MAX; i++) {
4917                 t = unit_type_to_string(i);
4918                 if (t)
4919                         puts(t);
4920         }
4921
4922         return 0;
4923 }
4924
4925 static int systemctl_parse_argv(int argc, char *argv[]) {
4926
4927         enum {
4928                 ARG_FAIL = 0x100,
4929                 ARG_REVERSE,
4930                 ARG_AFTER,
4931                 ARG_BEFORE,
4932                 ARG_SHOW_TYPES,
4933                 ARG_IRREVERSIBLE,
4934                 ARG_IGNORE_DEPENDENCIES,
4935                 ARG_VERSION,
4936                 ARG_USER,
4937                 ARG_SYSTEM,
4938                 ARG_GLOBAL,
4939                 ARG_NO_BLOCK,
4940                 ARG_NO_LEGEND,
4941                 ARG_NO_PAGER,
4942                 ARG_NO_WALL,
4943                 ARG_ROOT,
4944                 ARG_NO_RELOAD,
4945                 ARG_KILL_WHO,
4946                 ARG_NO_ASK_PASSWORD,
4947                 ARG_FAILED,
4948                 ARG_RUNTIME,
4949                 ARG_FORCE,
4950                 ARG_PLAIN,
4951                 ARG_STATE,
4952                 ARG_JOB_MODE
4953         };
4954
4955         static const struct option options[] = {
4956                 { "help",                no_argument,       NULL, 'h'                     },
4957                 { "version",             no_argument,       NULL, ARG_VERSION             },
4958                 { "type",                required_argument, NULL, 't'                     },
4959                 { "property",            required_argument, NULL, 'p'                     },
4960                 { "all",                 no_argument,       NULL, 'a'                     },
4961                 { "reverse",             no_argument,       NULL, ARG_REVERSE             },
4962                 { "after",               no_argument,       NULL, ARG_AFTER               },
4963                 { "before",              no_argument,       NULL, ARG_BEFORE              },
4964                 { "show-types",          no_argument,       NULL, ARG_SHOW_TYPES          },
4965                 { "failed",              no_argument,       NULL, ARG_FAILED              }, /* compatibility only */
4966                 { "full",                no_argument,       NULL, 'l'                     },
4967                 { "job-mode",            required_argument, NULL, ARG_JOB_MODE            },
4968                 { "fail",                no_argument,       NULL, ARG_FAIL                }, /* compatibility only */
4969                 { "irreversible",        no_argument,       NULL, ARG_IRREVERSIBLE        }, /* compatibility only */
4970                 { "ignore-dependencies", no_argument,       NULL, ARG_IGNORE_DEPENDENCIES }, /* compatibility only */
4971                 { "ignore-inhibitors",   no_argument,       NULL, 'i'                     },
4972                 { "user",                no_argument,       NULL, ARG_USER                },
4973                 { "system",              no_argument,       NULL, ARG_SYSTEM              },
4974                 { "global",              no_argument,       NULL, ARG_GLOBAL              },
4975                 { "no-block",            no_argument,       NULL, ARG_NO_BLOCK            },
4976                 { "no-legend",           no_argument,       NULL, ARG_NO_LEGEND           },
4977                 { "no-pager",            no_argument,       NULL, ARG_NO_PAGER            },
4978                 { "no-wall",             no_argument,       NULL, ARG_NO_WALL             },
4979                 { "quiet",               no_argument,       NULL, 'q'                     },
4980                 { "root",                required_argument, NULL, ARG_ROOT                },
4981                 { "force",               no_argument,       NULL, ARG_FORCE               },
4982                 { "no-reload",           no_argument,       NULL, ARG_NO_RELOAD           },
4983                 { "kill-who",            required_argument, NULL, ARG_KILL_WHO            },
4984                 { "signal",              required_argument, NULL, 's'                     },
4985                 { "no-ask-password",     no_argument,       NULL, ARG_NO_ASK_PASSWORD     },
4986                 { "host",                required_argument, NULL, 'H'                     },
4987                 { "machine",             required_argument, NULL, 'M'                     },
4988                 { "runtime",             no_argument,       NULL, ARG_RUNTIME             },
4989                 { "lines",               required_argument, NULL, 'n'                     },
4990                 { "output",              required_argument, NULL, 'o'                     },
4991                 { "plain",               no_argument,       NULL, ARG_PLAIN               },
4992                 { "state",               required_argument, NULL, ARG_STATE               },
4993                 {}
4994         };
4995
4996         int c;
4997
4998         assert(argc >= 0);
4999         assert(argv);
5000
5001         while ((c = getopt_long(argc, argv, "ht:p:alqfs:H:M:n:o:i", options, NULL)) >= 0) {
5002
5003                 switch (c) {
5004
5005                 case 'h':
5006                         return systemctl_help();
5007
5008                 case ARG_VERSION:
5009                         puts(PACKAGE_STRING);
5010                         puts(SYSTEMD_FEATURES);
5011                         return 0;
5012
5013                 case 't': {
5014                         char *word, *state;
5015                         size_t size;
5016
5017                         FOREACH_WORD_SEPARATOR(word, size, optarg, ",", state) {
5018                                 _cleanup_free_ char *type;
5019
5020                                 type = strndup(word, size);
5021                                 if (!type)
5022                                         return -ENOMEM;
5023
5024                                 if (streq(type, "help")) {
5025                                         help_types();
5026                                         return 0;
5027                                 }
5028
5029                                 if (unit_type_from_string(type) >= 0) {
5030                                         if (strv_push(&arg_types, type))
5031                                                 return log_oom();
5032                                         type = NULL;
5033                                         continue;
5034                                 }
5035
5036                                 /* It's much nicer to use --state= for
5037                                  * load states, but let's support this
5038                                  * in --types= too for compatibility
5039                                  * with old versions */
5040                                 if (unit_load_state_from_string(optarg) >= 0) {
5041                                         if (strv_push(&arg_states, type) < 0)
5042                                                 return log_oom();
5043                                         type = NULL;
5044                                         continue;
5045                                 }
5046
5047                                 log_error("Unknown unit type or load state '%s'.", type);
5048                                 log_info("Use -t help to see a list of allowed values.");
5049                                 return -EINVAL;
5050                         }
5051
5052                         break;
5053                 }
5054
5055                 case 'p': {
5056                         /* Make sure that if the empty property list
5057                            was specified, we won't show any properties. */
5058                         if (isempty(optarg) && !arg_properties) {
5059                                 arg_properties = new0(char*, 1);
5060                                 if (!arg_properties)
5061                                         return log_oom();
5062                         } else {
5063                                 char *word, *state;
5064                                 size_t size;
5065
5066                                 FOREACH_WORD_SEPARATOR(word, size, optarg, ",", state) {
5067                                         char *prop;
5068
5069                                         prop = strndup(word, size);
5070                                         if (!prop)
5071                                                 return log_oom();
5072
5073                                         if (strv_push(&arg_properties, prop) < 0) {
5074                                                 free(prop);
5075                                                 return log_oom();
5076                                         }
5077                                 }
5078                         }
5079
5080                         /* If the user asked for a particular
5081                          * property, show it to him, even if it is
5082                          * empty. */
5083                         arg_all = true;
5084
5085                         break;
5086                 }
5087
5088                 case 'a':
5089                         arg_all = true;
5090                         break;
5091
5092                 case ARG_REVERSE:
5093                         arg_dependency = DEPENDENCY_REVERSE;
5094                         break;
5095
5096                 case ARG_AFTER:
5097                         arg_dependency = DEPENDENCY_AFTER;
5098                         break;
5099
5100                 case ARG_BEFORE:
5101                         arg_dependency = DEPENDENCY_BEFORE;
5102                         break;
5103
5104                 case ARG_SHOW_TYPES:
5105                         arg_show_types = true;
5106                         break;
5107
5108                 case ARG_JOB_MODE:
5109                         arg_job_mode = optarg;
5110                         break;
5111
5112                 case ARG_FAIL:
5113                         arg_job_mode = "fail";
5114                         break;
5115
5116                 case ARG_IRREVERSIBLE:
5117                         arg_job_mode = "replace-irreversibly";
5118                         break;
5119
5120                 case ARG_IGNORE_DEPENDENCIES:
5121                         arg_job_mode = "ignore-dependencies";
5122                         break;
5123
5124                 case ARG_USER:
5125                         arg_scope = UNIT_FILE_USER;
5126                         break;
5127
5128                 case ARG_SYSTEM:
5129                         arg_scope = UNIT_FILE_SYSTEM;
5130                         break;
5131
5132                 case ARG_GLOBAL:
5133                         arg_scope = UNIT_FILE_GLOBAL;
5134                         break;
5135
5136                 case ARG_NO_BLOCK:
5137                         arg_no_block = true;
5138                         break;
5139
5140                 case ARG_NO_LEGEND:
5141                         arg_no_legend = true;
5142                         break;
5143
5144                 case ARG_NO_PAGER:
5145                         arg_no_pager = true;
5146                         break;
5147
5148                 case ARG_NO_WALL:
5149                         arg_no_wall = true;
5150                         break;
5151
5152                 case ARG_ROOT:
5153                         arg_root = optarg;
5154                         break;
5155
5156                 case 'l':
5157                         arg_full = true;
5158                         break;
5159
5160                 case ARG_FAILED:
5161                         if (strv_extend(&arg_states, "failed") < 0)
5162                                 return log_oom();
5163
5164                         break;
5165
5166                 case 'q':
5167                         arg_quiet = true;
5168                         break;
5169
5170                 case ARG_FORCE:
5171                         arg_force ++;
5172                         break;
5173
5174                 case 'f':
5175                         arg_force ++;
5176                         break;
5177
5178                 case ARG_NO_RELOAD:
5179                         arg_no_reload = true;
5180                         break;
5181
5182                 case ARG_KILL_WHO:
5183                         arg_kill_who = optarg;
5184                         break;
5185
5186                 case 's':
5187                         if ((arg_signal = signal_from_string_try_harder(optarg)) < 0) {
5188                                 log_error("Failed to parse signal string %s.", optarg);
5189                                 return -EINVAL;
5190                         }
5191                         break;
5192
5193                 case ARG_NO_ASK_PASSWORD:
5194                         arg_ask_password = false;
5195                         break;
5196
5197                 case 'H':
5198                         arg_transport = BUS_TRANSPORT_REMOTE;
5199                         arg_host = optarg;
5200                         break;
5201
5202                 case 'M':
5203                         arg_transport = BUS_TRANSPORT_CONTAINER;
5204                         arg_host = optarg;
5205                         break;
5206
5207                 case ARG_RUNTIME:
5208                         arg_runtime = true;
5209                         break;
5210
5211                 case 'n':
5212                         if (safe_atou(optarg, &arg_lines) < 0) {
5213                                 log_error("Failed to parse lines '%s'", optarg);
5214                                 return -EINVAL;
5215                         }
5216                         break;
5217
5218                 case 'o':
5219                         arg_output = output_mode_from_string(optarg);
5220                         if (arg_output < 0) {
5221                                 log_error("Unknown output '%s'.", optarg);
5222                                 return -EINVAL;
5223                         }
5224                         break;
5225
5226                 case 'i':
5227                         arg_ignore_inhibitors = true;
5228                         break;
5229
5230                 case ARG_PLAIN:
5231                         arg_plain = true;
5232                         break;
5233
5234                 case ARG_STATE: {
5235                         char *word, *state;
5236                         size_t size;
5237
5238                         FOREACH_WORD_SEPARATOR(word, size, optarg, ",", state) {
5239                                 char *s;
5240
5241                                 s = strndup(word, size);
5242                                 if (!s)
5243                                         return log_oom();
5244
5245                                 if (strv_push(&arg_states, s) < 0) {
5246                                         free(s);
5247                                         return log_oom();
5248                                 }
5249                         }
5250                         break;
5251                 }
5252
5253                 case '?':
5254                         return -EINVAL;
5255
5256                 default:
5257                         assert_not_reached("Unhandled option");
5258                 }
5259         }
5260
5261         if (arg_transport != BUS_TRANSPORT_LOCAL && arg_scope != UNIT_FILE_SYSTEM) {
5262                 log_error("Cannot access user instance remotely.");
5263                 return -EINVAL;
5264         }
5265
5266         return 1;
5267 }
5268
5269 static int halt_parse_argv(int argc, char *argv[]) {
5270
5271         enum {
5272                 ARG_HELP = 0x100,
5273                 ARG_HALT,
5274                 ARG_REBOOT,
5275                 ARG_NO_WALL
5276         };
5277
5278         static const struct option options[] = {
5279                 { "help",      no_argument,       NULL, ARG_HELP    },
5280                 { "halt",      no_argument,       NULL, ARG_HALT    },
5281                 { "poweroff",  no_argument,       NULL, 'p'         },
5282                 { "reboot",    no_argument,       NULL, ARG_REBOOT  },
5283                 { "force",     no_argument,       NULL, 'f'         },
5284                 { "wtmp-only", no_argument,       NULL, 'w'         },
5285                 { "no-wtmp",   no_argument,       NULL, 'd'         },
5286                 { "no-wall",   no_argument,       NULL, ARG_NO_WALL },
5287                 {}
5288         };
5289
5290         int c, r, runlevel;
5291
5292         assert(argc >= 0);
5293         assert(argv);
5294
5295         if (utmp_get_runlevel(&runlevel, NULL) >= 0)
5296                 if (runlevel == '0' || runlevel == '6')
5297                         arg_force = 2;
5298
5299         while ((c = getopt_long(argc, argv, "pfwdnih", options, NULL)) >= 0) {
5300                 switch (c) {
5301
5302                 case ARG_HELP:
5303                         return halt_help();
5304
5305                 case ARG_HALT:
5306                         arg_action = ACTION_HALT;
5307                         break;
5308
5309                 case 'p':
5310                         if (arg_action != ACTION_REBOOT)
5311                                 arg_action = ACTION_POWEROFF;
5312                         break;
5313
5314                 case ARG_REBOOT:
5315                         arg_action = ACTION_REBOOT;
5316                         break;
5317
5318                 case 'f':
5319                         arg_force = 2;
5320                         break;
5321
5322                 case 'w':
5323                         arg_dry = true;
5324                         break;
5325
5326                 case 'd':
5327                         arg_no_wtmp = true;
5328                         break;
5329
5330                 case ARG_NO_WALL:
5331                         arg_no_wall = true;
5332                         break;
5333
5334                 case 'i':
5335                 case 'h':
5336                 case 'n':
5337                         /* Compatibility nops */
5338                         break;
5339
5340                 case '?':
5341                         return -EINVAL;
5342
5343                 default:
5344                         assert_not_reached("Unhandled option");
5345                 }
5346         }
5347
5348         if (arg_action == ACTION_REBOOT && argc == optind + 1) {
5349                 r = write_string_file(REBOOT_PARAM_FILE, argv[optind]);
5350                 if (r < 0) {
5351                         log_error("Failed to write reboot param to "
5352                                   REBOOT_PARAM_FILE": %s", strerror(-r));
5353                         return r;
5354                 }
5355         } else if (optind < argc) {
5356                 log_error("Too many arguments.");
5357                 return -EINVAL;
5358         }
5359
5360         return 1;
5361 }
5362
5363 static int parse_time_spec(const char *t, usec_t *_u) {
5364         assert(t);
5365         assert(_u);
5366
5367         if (streq(t, "now"))
5368                 *_u = 0;
5369         else if (!strchr(t, ':')) {
5370                 uint64_t u;
5371
5372                 if (safe_atou64(t, &u) < 0)
5373                         return -EINVAL;
5374
5375                 *_u = now(CLOCK_REALTIME) + USEC_PER_MINUTE * u;
5376         } else {
5377                 char *e = NULL;
5378                 long hour, minute;
5379                 struct tm tm = {};
5380                 time_t s;
5381                 usec_t n;
5382
5383                 errno = 0;
5384                 hour = strtol(t, &e, 10);
5385                 if (errno > 0 || *e != ':' || hour < 0 || hour > 23)
5386                         return -EINVAL;
5387
5388                 minute = strtol(e+1, &e, 10);
5389                 if (errno > 0 || *e != 0 || minute < 0 || minute > 59)
5390                         return -EINVAL;
5391
5392                 n = now(CLOCK_REALTIME);
5393                 s = (time_t) (n / USEC_PER_SEC);
5394
5395                 assert_se(localtime_r(&s, &tm));
5396
5397                 tm.tm_hour = (int) hour;
5398                 tm.tm_min = (int) minute;
5399                 tm.tm_sec = 0;
5400
5401                 assert_se(s = mktime(&tm));
5402
5403                 *_u = (usec_t) s * USEC_PER_SEC;
5404
5405                 while (*_u <= n)
5406                         *_u += USEC_PER_DAY;
5407         }
5408
5409         return 0;
5410 }
5411
5412 static int shutdown_parse_argv(int argc, char *argv[]) {
5413
5414         enum {
5415                 ARG_HELP = 0x100,
5416                 ARG_NO_WALL
5417         };
5418
5419         static const struct option options[] = {
5420                 { "help",      no_argument,       NULL, ARG_HELP    },
5421                 { "halt",      no_argument,       NULL, 'H'         },
5422                 { "poweroff",  no_argument,       NULL, 'P'         },
5423                 { "reboot",    no_argument,       NULL, 'r'         },
5424                 { "kexec",     no_argument,       NULL, 'K'         }, /* not documented extension */
5425                 { "no-wall",   no_argument,       NULL, ARG_NO_WALL },
5426                 {}
5427         };
5428
5429         int c, r;
5430
5431         assert(argc >= 0);
5432         assert(argv);
5433
5434         while ((c = getopt_long(argc, argv, "HPrhkt:afFc", options, NULL)) >= 0) {
5435                 switch (c) {
5436
5437                 case ARG_HELP:
5438                         return shutdown_help();
5439
5440                 case 'H':
5441                         arg_action = ACTION_HALT;
5442                         break;
5443
5444                 case 'P':
5445                         arg_action = ACTION_POWEROFF;
5446                         break;
5447
5448                 case 'r':
5449                         if (kexec_loaded())
5450                                 arg_action = ACTION_KEXEC;
5451                         else
5452                                 arg_action = ACTION_REBOOT;
5453                         break;
5454
5455                 case 'K':
5456                         arg_action = ACTION_KEXEC;
5457                         break;
5458
5459                 case 'h':
5460                         if (arg_action != ACTION_HALT)
5461                                 arg_action = ACTION_POWEROFF;
5462                         break;
5463
5464                 case 'k':
5465                         arg_dry = true;
5466                         break;
5467
5468                 case ARG_NO_WALL:
5469                         arg_no_wall = true;
5470                         break;
5471
5472                 case 't':
5473                 case 'a':
5474                         /* Compatibility nops */
5475                         break;
5476
5477                 case 'c':
5478                         arg_action = ACTION_CANCEL_SHUTDOWN;
5479                         break;
5480
5481                 case '?':
5482                         return -EINVAL;
5483
5484                 default:
5485                         assert_not_reached("Unhandled option");
5486                 }
5487         }
5488
5489         if (argc > optind && arg_action != ACTION_CANCEL_SHUTDOWN) {
5490                 r = parse_time_spec(argv[optind], &arg_when);
5491                 if (r < 0) {
5492                         log_error("Failed to parse time specification: %s", argv[optind]);
5493                         return r;
5494                 }
5495         } else
5496                 arg_when = now(CLOCK_REALTIME) + USEC_PER_MINUTE;
5497
5498         if (argc > optind && arg_action == ACTION_CANCEL_SHUTDOWN)
5499                 /* No time argument for shutdown cancel */
5500                 arg_wall = argv + optind;
5501         else if (argc > optind + 1)
5502                 /* We skip the time argument */
5503                 arg_wall = argv + optind + 1;
5504
5505         optind = argc;
5506
5507         return 1;
5508 }
5509
5510 static int telinit_parse_argv(int argc, char *argv[]) {
5511
5512         enum {
5513                 ARG_HELP = 0x100,
5514                 ARG_NO_WALL
5515         };
5516
5517         static const struct option options[] = {
5518                 { "help",      no_argument,       NULL, ARG_HELP    },
5519                 { "no-wall",   no_argument,       NULL, ARG_NO_WALL },
5520                 {}
5521         };
5522
5523         static const struct {
5524                 char from;
5525                 enum action to;
5526         } table[] = {
5527                 { '0', ACTION_POWEROFF },
5528                 { '6', ACTION_REBOOT },
5529                 { '1', ACTION_RESCUE },
5530                 { '2', ACTION_RUNLEVEL2 },
5531                 { '3', ACTION_RUNLEVEL3 },
5532                 { '4', ACTION_RUNLEVEL4 },
5533                 { '5', ACTION_RUNLEVEL5 },
5534                 { 's', ACTION_RESCUE },
5535                 { 'S', ACTION_RESCUE },
5536                 { 'q', ACTION_RELOAD },
5537                 { 'Q', ACTION_RELOAD },
5538                 { 'u', ACTION_REEXEC },
5539                 { 'U', ACTION_REEXEC }
5540         };
5541
5542         unsigned i;
5543         int c;
5544
5545         assert(argc >= 0);
5546         assert(argv);
5547
5548         while ((c = getopt_long(argc, argv, "", options, NULL)) >= 0) {
5549                 switch (c) {
5550
5551                 case ARG_HELP:
5552                         return telinit_help();
5553
5554                 case ARG_NO_WALL:
5555                         arg_no_wall = true;
5556                         break;
5557
5558                 case '?':
5559                         return -EINVAL;
5560
5561                 default:
5562                         assert_not_reached("Unhandled option");
5563                 }
5564         }
5565
5566         if (optind >= argc) {
5567                 telinit_help();
5568                 return -EINVAL;
5569         }
5570
5571         if (optind + 1 < argc) {
5572                 log_error("Too many arguments.");
5573                 return -EINVAL;
5574         }
5575
5576         if (strlen(argv[optind]) != 1) {
5577                 log_error("Expected single character argument.");
5578                 return -EINVAL;
5579         }
5580
5581         for (i = 0; i < ELEMENTSOF(table); i++)
5582                 if (table[i].from == argv[optind][0])
5583                         break;
5584
5585         if (i >= ELEMENTSOF(table)) {
5586                 log_error("Unknown command '%s'.", argv[optind]);
5587                 return -EINVAL;
5588         }
5589
5590         arg_action = table[i].to;
5591
5592         optind ++;
5593
5594         return 1;
5595 }
5596
5597 static int runlevel_parse_argv(int argc, char *argv[]) {
5598
5599         enum {
5600                 ARG_HELP = 0x100,
5601         };
5602
5603         static const struct option options[] = {
5604                 { "help",      no_argument,       NULL, ARG_HELP    },
5605                 {}
5606         };
5607
5608         int c;
5609
5610         assert(argc >= 0);
5611         assert(argv);
5612
5613         while ((c = getopt_long(argc, argv, "", options, NULL)) >= 0) {
5614                 switch (c) {
5615
5616                 case ARG_HELP:
5617                         return runlevel_help();
5618                         return 0;
5619
5620                 case '?':
5621                         return -EINVAL;
5622
5623                 default:
5624                         assert_not_reached("Unhandled option");
5625                 }
5626         }
5627
5628         if (optind < argc) {
5629                 log_error("Too many arguments.");
5630                 return -EINVAL;
5631         }
5632
5633         return 1;
5634 }
5635
5636 static int parse_argv(int argc, char *argv[]) {
5637         assert(argc >= 0);
5638         assert(argv);
5639
5640         if (program_invocation_short_name) {
5641
5642                 if (strstr(program_invocation_short_name, "halt")) {
5643                         arg_action = ACTION_HALT;
5644                         return halt_parse_argv(argc, argv);
5645                 } else if (strstr(program_invocation_short_name, "poweroff")) {
5646                         arg_action = ACTION_POWEROFF;
5647                         return halt_parse_argv(argc, argv);
5648                 } else if (strstr(program_invocation_short_name, "reboot")) {
5649                         if (kexec_loaded())
5650                                 arg_action = ACTION_KEXEC;
5651                         else
5652                                 arg_action = ACTION_REBOOT;
5653                         return halt_parse_argv(argc, argv);
5654                 } else if (strstr(program_invocation_short_name, "shutdown")) {
5655                         arg_action = ACTION_POWEROFF;
5656                         return shutdown_parse_argv(argc, argv);
5657                 } else if (strstr(program_invocation_short_name, "init")) {
5658
5659                         if (sd_booted() > 0) {
5660                                 arg_action = _ACTION_INVALID;
5661                                 return telinit_parse_argv(argc, argv);
5662                         } else {
5663                                 /* Hmm, so some other init system is
5664                                  * running, we need to forward this
5665                                  * request to it. For now we simply
5666                                  * guess that it is Upstart. */
5667
5668                                 execv(TELINIT, argv);
5669
5670                                 log_error("Couldn't find an alternative telinit implementation to spawn.");
5671                                 return -EIO;
5672                         }
5673
5674                 } else if (strstr(program_invocation_short_name, "runlevel")) {
5675                         arg_action = ACTION_RUNLEVEL;
5676                         return runlevel_parse_argv(argc, argv);
5677                 }
5678         }
5679
5680         arg_action = ACTION_SYSTEMCTL;
5681         return systemctl_parse_argv(argc, argv);
5682 }
5683
5684 _pure_ static int action_to_runlevel(void) {
5685
5686         static const char table[_ACTION_MAX] = {
5687                 [ACTION_HALT] =      '0',
5688                 [ACTION_POWEROFF] =  '0',
5689                 [ACTION_REBOOT] =    '6',
5690                 [ACTION_RUNLEVEL2] = '2',
5691                 [ACTION_RUNLEVEL3] = '3',
5692                 [ACTION_RUNLEVEL4] = '4',
5693                 [ACTION_RUNLEVEL5] = '5',
5694                 [ACTION_RESCUE] =    '1'
5695         };
5696
5697         assert(arg_action < _ACTION_MAX);
5698
5699         return table[arg_action];
5700 }
5701
5702 static int talk_initctl(void) {
5703
5704         struct init_request request = {
5705                 .magic = INIT_MAGIC,
5706                 .sleeptime  = 0,
5707                 .cmd = INIT_CMD_RUNLVL
5708         };
5709
5710         _cleanup_close_ int fd = -1;
5711         char rl;
5712         int r;
5713
5714         rl = action_to_runlevel();
5715         if (!rl)
5716                 return 0;
5717
5718         request.runlevel = rl;
5719
5720         fd = open(INIT_FIFO, O_WRONLY|O_NDELAY|O_CLOEXEC|O_NOCTTY);
5721         if (fd < 0) {
5722                 if (errno == ENOENT)
5723                         return 0;
5724
5725                 log_error("Failed to open "INIT_FIFO": %m");
5726                 return -errno;
5727         }
5728
5729         errno = 0;
5730         r = loop_write(fd, &request, sizeof(request), false) != sizeof(request);
5731         if (r) {
5732                 log_error("Failed to write to "INIT_FIFO": %m");
5733                 return errno > 0 ? -errno : -EIO;
5734         }
5735
5736         return 1;
5737 }
5738
5739 static int systemctl_main(sd_bus *bus, int argc, char *argv[], int bus_error) {
5740
5741         static const struct {
5742                 const char* verb;
5743                 const enum {
5744                         MORE,
5745                         LESS,
5746                         EQUAL
5747                 } argc_cmp;
5748                 const int argc;
5749                 int (* const dispatch)(sd_bus *bus, char **args);
5750         } verbs[] = {
5751                 { "list-units",            LESS,  1, list_units        },
5752                 { "list-unit-files",       EQUAL, 1, list_unit_files   },
5753                 { "list-sockets",          LESS,  1, list_sockets      },
5754                 { "list-timers",           LESS,  1, list_timers       },
5755                 { "list-jobs",             EQUAL, 1, list_jobs         },
5756                 { "clear-jobs",            EQUAL, 1, daemon_reload     },
5757                 { "cancel",                MORE,  2, cancel_job        },
5758                 { "start",                 MORE,  2, start_unit        },
5759                 { "stop",                  MORE,  2, start_unit        },
5760                 { "condstop",              MORE,  2, start_unit        }, /* For compatibility with ALTLinux */
5761                 { "reload",                MORE,  2, start_unit        },
5762                 { "restart",               MORE,  2, start_unit        },
5763                 { "try-restart",           MORE,  2, start_unit        },
5764                 { "reload-or-restart",     MORE,  2, start_unit        },
5765                 { "reload-or-try-restart", MORE,  2, start_unit        },
5766                 { "force-reload",          MORE,  2, start_unit        }, /* For compatibility with SysV */
5767                 { "condreload",            MORE,  2, start_unit        }, /* For compatibility with ALTLinux */
5768                 { "condrestart",           MORE,  2, start_unit        }, /* For compatibility with RH */
5769                 { "isolate",               EQUAL, 2, start_unit        },
5770                 { "kill",                  MORE,  2, kill_unit         },
5771                 { "is-active",             MORE,  2, check_unit_active },
5772                 { "check",                 MORE,  2, check_unit_active },
5773                 { "is-failed",             MORE,  2, check_unit_failed },
5774                 { "show",                  MORE,  1, show              },
5775                 { "cat",                   MORE,  2, cat               },
5776                 { "status",                MORE,  1, show              },
5777                 { "help",                  MORE,  2, show              },
5778                 { "snapshot",              LESS,  2, snapshot          },
5779                 { "delete",                MORE,  2, delete_snapshot   },
5780                 { "daemon-reload",         EQUAL, 1, daemon_reload     },
5781                 { "daemon-reexec",         EQUAL, 1, daemon_reload     },
5782                 { "show-environment",      EQUAL, 1, show_environment  },
5783                 { "set-environment",       MORE,  2, set_environment   },
5784                 { "unset-environment",     MORE,  2, set_environment   },
5785                 { "halt",                  EQUAL, 1, start_special     },
5786                 { "poweroff",              EQUAL, 1, start_special     },
5787                 { "reboot",                EQUAL, 1, start_special     },
5788                 { "kexec",                 EQUAL, 1, start_special     },
5789                 { "suspend",               EQUAL, 1, start_special     },
5790                 { "hibernate",             EQUAL, 1, start_special     },
5791                 { "hybrid-sleep",          EQUAL, 1, start_special     },
5792                 { "default",               EQUAL, 1, start_special     },
5793                 { "rescue",                EQUAL, 1, start_special     },
5794                 { "emergency",             EQUAL, 1, start_special     },
5795                 { "exit",                  EQUAL, 1, start_special     },
5796                 { "reset-failed",          MORE,  1, reset_failed      },
5797                 { "enable",                MORE,  2, enable_unit       },
5798                 { "disable",               MORE,  2, enable_unit       },
5799                 { "is-enabled",            MORE,  2, unit_is_enabled   },
5800                 { "reenable",              MORE,  2, enable_unit       },
5801                 { "preset",                MORE,  2, enable_unit       },
5802                 { "mask",                  MORE,  2, enable_unit       },
5803                 { "unmask",                MORE,  2, enable_unit       },
5804                 { "link",                  MORE,  2, enable_unit       },
5805                 { "switch-root",           MORE,  2, switch_root       },
5806                 { "list-dependencies",     LESS,  2, list_dependencies },
5807                 { "set-default",           EQUAL, 2, set_default       },
5808                 { "get-default",           EQUAL, 1, get_default       },
5809                 { "set-property",          MORE,  3, set_property      },
5810         };
5811
5812         int left;
5813         unsigned i;
5814
5815         assert(argc >= 0);
5816         assert(argv);
5817
5818         left = argc - optind;
5819
5820         if (left <= 0)
5821                 /* Special rule: no arguments means "list-units" */
5822                 i = 0;
5823         else {
5824                 if (streq(argv[optind], "help") && !argv[optind+1]) {
5825                         log_error("This command expects one or more "
5826                                   "unit names. Did you mean --help?");
5827                         return -EINVAL;
5828                 }
5829
5830                 for (i = 0; i < ELEMENTSOF(verbs); i++)
5831                         if (streq(argv[optind], verbs[i].verb))
5832                                 break;
5833
5834                 if (i >= ELEMENTSOF(verbs)) {
5835                         log_error("Unknown operation '%s'.", argv[optind]);
5836                         return -EINVAL;
5837                 }
5838         }
5839
5840         switch (verbs[i].argc_cmp) {
5841
5842         case EQUAL:
5843                 if (left != verbs[i].argc) {
5844                         log_error("Invalid number of arguments.");
5845                         return -EINVAL;
5846                 }
5847
5848                 break;
5849
5850         case MORE:
5851                 if (left < verbs[i].argc) {
5852                         log_error("Too few arguments.");
5853                         return -EINVAL;
5854                 }
5855
5856                 break;
5857
5858         case LESS:
5859                 if (left > verbs[i].argc) {
5860                         log_error("Too many arguments.");
5861                         return -EINVAL;
5862                 }
5863
5864                 break;
5865
5866         default:
5867                 assert_not_reached("Unknown comparison operator.");
5868         }
5869
5870         /* Require a bus connection for all operations but
5871          * enable/disable */
5872         if (!streq(verbs[i].verb, "enable") &&
5873             !streq(verbs[i].verb, "disable") &&
5874             !streq(verbs[i].verb, "is-enabled") &&
5875             !streq(verbs[i].verb, "list-unit-files") &&
5876             !streq(verbs[i].verb, "reenable") &&
5877             !streq(verbs[i].verb, "preset") &&
5878             !streq(verbs[i].verb, "mask") &&
5879             !streq(verbs[i].verb, "unmask") &&
5880             !streq(verbs[i].verb, "link") &&
5881             !streq(verbs[i].verb, "set-default") &&
5882             !streq(verbs[i].verb, "get-default")) {
5883
5884                 if (running_in_chroot() > 0) {
5885                         log_info("Running in chroot, ignoring request.");
5886                         return 0;
5887                 }
5888
5889                 if (((!streq(verbs[i].verb, "reboot") &&
5890                       !streq(verbs[i].verb, "halt") &&
5891                       !streq(verbs[i].verb, "poweroff")) || arg_force <= 0) && !bus) {
5892                         log_error("Failed to get D-Bus connection: %s", strerror (-bus_error));
5893                         return -EIO;
5894                 }
5895
5896         } else {
5897
5898                 if (!bus && !avoid_bus()) {
5899                         log_error("Failed to get D-Bus connection: %s", strerror (-bus_error));
5900                         return -EIO;
5901                 }
5902         }
5903
5904         return verbs[i].dispatch(bus, argv + optind);
5905 }
5906
5907 static int send_shutdownd(usec_t t, char mode, bool dry_run, bool warn, const char *message) {
5908
5909         struct sd_shutdown_command c = {
5910                 .usec = t,
5911                 .mode = mode,
5912                 .dry_run = dry_run,
5913                 .warn_wall = warn,
5914         };
5915
5916         union sockaddr_union sockaddr = {
5917                 .un.sun_family = AF_UNIX,
5918                 .un.sun_path = "/run/systemd/shutdownd",
5919         };
5920
5921         struct iovec iovec[2] = {{
5922                  .iov_base = (char*) &c,
5923                  .iov_len = offsetof(struct sd_shutdown_command, wall_message),
5924         }};
5925
5926         struct msghdr msghdr = {
5927                 .msg_name = &sockaddr,
5928                 .msg_namelen = offsetof(struct sockaddr_un, sun_path)
5929                                + sizeof("/run/systemd/shutdownd") - 1,
5930                 .msg_iov = iovec,
5931                 .msg_iovlen = 1,
5932         };
5933
5934         _cleanup_close_ int fd;
5935
5936         fd = socket(AF_UNIX, SOCK_DGRAM|SOCK_CLOEXEC, 0);
5937         if (fd < 0)
5938                 return -errno;
5939
5940         if (!isempty(message)) {
5941                 iovec[1].iov_base = (char*) message;
5942                 iovec[1].iov_len = strlen(message);
5943                 msghdr.msg_iovlen++;
5944         }
5945
5946         if (sendmsg(fd, &msghdr, MSG_NOSIGNAL) < 0)
5947                 return -errno;
5948
5949         return 0;
5950 }
5951
5952 static int reload_with_fallback(sd_bus *bus) {
5953
5954         if (bus) {
5955                 /* First, try systemd via D-Bus. */
5956                 if (daemon_reload(bus, NULL) >= 0)
5957                         return 0;
5958         }
5959
5960         /* Nothing else worked, so let's try signals */
5961         assert(arg_action == ACTION_RELOAD || arg_action == ACTION_REEXEC);
5962
5963         if (kill(1, arg_action == ACTION_RELOAD ? SIGHUP : SIGTERM) < 0) {
5964                 log_error("kill() failed: %m");
5965                 return -errno;
5966         }
5967
5968         return 0;
5969 }
5970
5971 static int start_with_fallback(sd_bus *bus) {
5972
5973         if (bus) {
5974                 /* First, try systemd via D-Bus. */
5975                 if (start_unit(bus, NULL) >= 0)
5976                         goto done;
5977         }
5978
5979         /* Nothing else worked, so let's try
5980          * /dev/initctl */
5981         if (talk_initctl() > 0)
5982                 goto done;
5983
5984         log_error("Failed to talk to init daemon.");
5985         return -EIO;
5986
5987 done:
5988         warn_wall(arg_action);
5989         return 0;
5990 }
5991
5992 static int halt_now(enum action a) {
5993
5994 /* Make sure C-A-D is handled by the kernel from this
5995          * point on... */
5996         reboot(RB_ENABLE_CAD);
5997
5998         switch (a) {
5999
6000         case ACTION_HALT:
6001                 log_info("Halting.");
6002                 reboot(RB_HALT_SYSTEM);
6003                 return -errno;
6004
6005         case ACTION_POWEROFF:
6006                 log_info("Powering off.");
6007                 reboot(RB_POWER_OFF);
6008                 return -errno;
6009
6010         case ACTION_REBOOT: {
6011                 _cleanup_free_ char *param = NULL;
6012
6013                 if (read_one_line_file(REBOOT_PARAM_FILE, &param) >= 0) {
6014                         log_info("Rebooting with argument '%s'.", param);
6015                         syscall(SYS_reboot, LINUX_REBOOT_MAGIC1, LINUX_REBOOT_MAGIC2,
6016                                 LINUX_REBOOT_CMD_RESTART2, param);
6017                 }
6018
6019                 log_info("Rebooting.");
6020                 reboot(RB_AUTOBOOT);
6021                 return -errno;
6022         }
6023
6024         default:
6025                 assert_not_reached("Unknown action.");
6026         }
6027 }
6028
6029 static int halt_main(sd_bus *bus) {
6030         int r;
6031
6032         r = check_inhibitors(bus, arg_action);
6033         if (r < 0)
6034                 return r;
6035
6036         if (geteuid() != 0) {
6037                 /* Try logind if we are a normal user and no special
6038                  * mode applies. Maybe PolicyKit allows us to shutdown
6039                  * the machine. */
6040
6041                 if (arg_when <= 0 &&
6042                     !arg_dry &&
6043                     arg_force <= 0 &&
6044                     (arg_action == ACTION_POWEROFF ||
6045                      arg_action == ACTION_REBOOT)) {
6046                         r = reboot_with_logind(bus, arg_action);
6047                         if (r >= 0)
6048                                 return r;
6049                 }
6050
6051                 log_error("Must be root.");
6052                 return -EPERM;
6053         }
6054
6055         if (arg_when > 0) {
6056                 _cleanup_free_ char *m;
6057
6058                 m = strv_join(arg_wall, " ");
6059                 if (!m)
6060                         return log_oom();
6061
6062                 r = send_shutdownd(arg_when,
6063                                    arg_action == ACTION_HALT     ? 'H' :
6064                                    arg_action == ACTION_POWEROFF ? 'P' :
6065                                    arg_action == ACTION_KEXEC    ? 'K' :
6066                                                                    'r',
6067                                    arg_dry,
6068                                    !arg_no_wall,
6069                                    m);
6070
6071                 if (r < 0)
6072                         log_warning("Failed to talk to shutdownd, proceeding with immediate shutdown: %s", strerror(-r));
6073                 else {
6074                         char date[FORMAT_TIMESTAMP_MAX];
6075
6076                         log_info("Shutdown scheduled for %s, use 'shutdown -c' to cancel.",
6077                                  format_timestamp(date, sizeof(date), arg_when));
6078                         return 0;
6079                 }
6080         }
6081
6082         if (!arg_dry && !arg_force)
6083                 return start_with_fallback(bus);
6084
6085         if (!arg_no_wtmp) {
6086                 if (sd_booted() > 0)
6087                         log_debug("Not writing utmp record, assuming that systemd-update-utmp is used.");
6088                 else {
6089                         r = utmp_put_shutdown();
6090                         if (r < 0)
6091                                 log_warning("Failed to write utmp record: %s", strerror(-r));
6092                 }
6093         }
6094
6095         if (arg_dry)
6096                 return 0;
6097
6098         r = halt_now(arg_action);
6099         log_error("Failed to reboot: %s", strerror(-r));
6100
6101         return r;
6102 }
6103
6104 static int runlevel_main(void) {
6105         int r, runlevel, previous;
6106
6107         r = utmp_get_runlevel(&runlevel, &previous);
6108         if (r < 0) {
6109                 puts("unknown");
6110                 return r;
6111         }
6112
6113         printf("%c %c\n",
6114                previous <= 0 ? 'N' : previous,
6115                runlevel <= 0 ? 'N' : runlevel);
6116
6117         return 0;
6118 }
6119
6120 int main(int argc, char*argv[]) {
6121         _cleanup_bus_unref_ sd_bus *bus = NULL;
6122         int r;
6123
6124         setlocale(LC_ALL, "");
6125         log_parse_environment();
6126         log_open();
6127
6128         /* Explicitly not on_tty() to avoid setting cached value.
6129          * This becomes relevant for piping output which might be
6130          * ellipsized. */
6131         original_stdout_is_tty = isatty(STDOUT_FILENO);
6132
6133         r = parse_argv(argc, argv);
6134         if (r <= 0)
6135                 goto finish;
6136
6137         /* /sbin/runlevel doesn't need to communicate via D-Bus, so
6138          * let's shortcut this */
6139         if (arg_action == ACTION_RUNLEVEL) {
6140                 r = runlevel_main();
6141                 goto finish;
6142         }
6143
6144         if (running_in_chroot() > 0 && arg_action != ACTION_SYSTEMCTL) {
6145                 log_info("Running in chroot, ignoring request.");
6146                 r = 0;
6147                 goto finish;
6148         }
6149
6150         if (!avoid_bus())
6151                 r = bus_open_transport_systemd(arg_transport, arg_host, arg_scope != UNIT_FILE_SYSTEM, &bus);
6152
6153         /* systemctl_main() will print an error message for the bus
6154          * connection, but only if it needs to */
6155
6156         switch (arg_action) {
6157
6158         case ACTION_SYSTEMCTL:
6159                 r = systemctl_main(bus, argc, argv, r);
6160                 break;
6161
6162         case ACTION_HALT:
6163         case ACTION_POWEROFF:
6164         case ACTION_REBOOT:
6165         case ACTION_KEXEC:
6166                 r = halt_main(bus);
6167                 break;
6168
6169         case ACTION_RUNLEVEL2:
6170         case ACTION_RUNLEVEL3:
6171         case ACTION_RUNLEVEL4:
6172         case ACTION_RUNLEVEL5:
6173         case ACTION_RESCUE:
6174         case ACTION_EMERGENCY:
6175         case ACTION_DEFAULT:
6176                 r = start_with_fallback(bus);
6177                 break;
6178
6179         case ACTION_RELOAD:
6180         case ACTION_REEXEC:
6181                 r = reload_with_fallback(bus);
6182                 break;
6183
6184         case ACTION_CANCEL_SHUTDOWN: {
6185                 _cleanup_free_ char *m = NULL;
6186
6187                 if (arg_wall) {
6188                         m = strv_join(arg_wall, " ");
6189                         if (!m) {
6190                                 r = log_oom();
6191                                 goto finish;
6192                         }
6193                 }
6194
6195                 r = send_shutdownd(arg_when, SD_SHUTDOWN_NONE, false, !arg_no_wall, m);
6196                 if (r < 0)
6197                         log_warning("Failed to talk to shutdownd, shutdown hasn't been cancelled: %s", strerror(-r));
6198                 break;
6199         }
6200
6201         case ACTION_RUNLEVEL:
6202         case _ACTION_INVALID:
6203         default:
6204                 assert_not_reached("Unknown action");
6205         }
6206
6207 finish:
6208         pager_close();
6209         ask_password_agent_close();
6210         polkit_agent_close();
6211
6212         strv_free(arg_types);
6213         strv_free(arg_states);
6214         strv_free(arg_properties);
6215
6216         return r < 0 ? EXIT_FAILURE : r;
6217 }