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 show(sd_bus *bus, char **args) {
3679         int r, ret = 0;
3680         bool show_properties, show_status, new_line = false;
3681         char **name;
3682         bool ellipsized = false;
3683
3684         assert(bus);
3685         assert(args);
3686
3687         show_properties = streq(args[0], "show");
3688         show_status = streq(args[0], "status");
3689
3690         if (show_properties)
3691                 pager_open_if_enabled();
3692
3693         /* If no argument is specified inspect the manager itself */
3694
3695         if (show_properties && strv_length(args) <= 1)
3696                 return show_one(args[0], bus, "/org/freedesktop/systemd1", show_properties, &new_line, &ellipsized);
3697
3698         if (show_status && strv_length(args) <= 1)
3699                 ret = show_all(args[0], bus, false, &new_line, &ellipsized);
3700         else
3701                 STRV_FOREACH(name, args+1) {
3702                         _cleanup_free_ char *unit = NULL;
3703                         uint32_t id;
3704
3705                         if (safe_atou32(*name, &id) < 0) {
3706                                 _cleanup_free_ char *n = NULL;
3707                                 /* Interpret as unit name */
3708
3709                                 n = unit_name_mangle(*name);
3710                                 if (!n)
3711                                         return log_oom();
3712
3713                                 unit = unit_dbus_path_from_name(n);
3714                                 if (!unit)
3715                                         return log_oom();
3716
3717                         } else if (show_properties) {
3718                                 /* Interpret as job id */
3719                                 if (asprintf(&unit, "/org/freedesktop/systemd1/job/%u", id) < 0)
3720                                         return log_oom();
3721
3722                         } else {
3723                                 /* Interpret as PID */
3724                                 r = get_unit_dbus_path_by_pid(bus, id, &unit);
3725                                 if (r < 0)
3726                                         ret = r;
3727                         }
3728
3729                         show_one(args[0], bus, unit, show_properties, &new_line, &ellipsized);
3730                 }
3731
3732         if (ellipsized && !arg_quiet)
3733                 printf("Hint: Some lines were ellipsized, use -l to show in full.\n");
3734
3735         return ret;
3736 }
3737
3738 static int append_assignment(sd_bus_message *m, const char *assignment) {
3739         const char *eq;
3740         char *field;
3741         int r;
3742
3743         assert(m);
3744         assert(assignment);
3745
3746         eq = strchr(assignment, '=');
3747         if (!eq) {
3748                 log_error("Not an assignment: %s", assignment);
3749                 return -EINVAL;
3750         }
3751
3752         field = strndupa(assignment, eq - assignment);
3753         eq ++;
3754
3755         r = sd_bus_message_append_basic(m, SD_BUS_TYPE_STRING, field);
3756         if (r < 0)
3757                 return bus_log_create_error(r);
3758
3759         if (streq(field, "CPUAccounting") ||
3760             streq(field, "MemoryAccounting") ||
3761             streq(field, "BlockIOAccounting")) {
3762
3763                 r = parse_boolean(eq);
3764                 if (r < 0) {
3765                         log_error("Failed to parse boolean assignment %s.", assignment);
3766                         return -EINVAL;
3767                 }
3768
3769                 r = sd_bus_message_append(m, "v", "b", r);
3770
3771         } else if (streq(field, "MemoryLimit")) {
3772                 off_t bytes;
3773
3774                 r = parse_bytes(eq, &bytes);
3775                 if (r < 0) {
3776                         log_error("Failed to parse bytes specification %s", assignment);
3777                         return -EINVAL;
3778                 }
3779
3780                 r = sd_bus_message_append(m, "v", "t", (uint64_t) bytes);
3781
3782         } else if (streq(field, "CPUShares") || streq(field, "BlockIOWeight")) {
3783                 uint64_t u;
3784
3785                 r = safe_atou64(eq, &u);
3786                 if (r < 0) {
3787                         log_error("Failed to parse %s value %s.", field, eq);
3788                         return -EINVAL;
3789                 }
3790
3791                 r = sd_bus_message_append(m, "v", "t", u);
3792
3793         } else if (streq(field, "DevicePolicy"))
3794                 r = sd_bus_message_append(m, "v", "s", eq);
3795
3796         else if (streq(field, "DeviceAllow")) {
3797
3798                 if (isempty(eq))
3799                         r = sd_bus_message_append(m, "v", "a(ss)", 0);
3800                 else {
3801                         const char *path, *rwm;
3802                         char *e;
3803
3804                         e = strchr(eq, ' ');
3805                         if (e) {
3806                                 path = strndupa(eq, e - eq);
3807                                 rwm = e+1;
3808                         } else {
3809                                 path = eq;
3810                                 rwm = "";
3811                         }
3812
3813                         if (!path_startswith(path, "/dev")) {
3814                                 log_error("%s is not a device file in /dev.", path);
3815                                 return -EINVAL;
3816                         }
3817
3818                         r = sd_bus_message_append(m, "v", "a(ss)", 1, path, rwm);
3819                 }
3820
3821         } else if (streq(field, "BlockIOReadBandwidth") || streq(field, "BlockIOWriteBandwidth")) {
3822
3823                 if (isempty(eq))
3824                         r = sd_bus_message_append(m, "v", "a(st)", 0);
3825                 else {
3826                         const char *path, *bandwidth;
3827                         off_t bytes;
3828                         char *e;
3829
3830                         e = strchr(eq, ' ');
3831                         if (e) {
3832                                 path = strndupa(eq, e - eq);
3833                                 bandwidth = e+1;
3834                         } else {
3835                                 log_error("Failed to parse %s value %s.", field, eq);
3836                                 return -EINVAL;
3837                         }
3838
3839                         if (!path_startswith(path, "/dev")) {
3840                                 log_error("%s is not a device file in /dev.", path);
3841                                 return -EINVAL;
3842                         }
3843
3844                         r = parse_bytes(bandwidth, &bytes);
3845                         if (r < 0) {
3846                                 log_error("Failed to parse byte value %s.", bandwidth);
3847                                 return -EINVAL;
3848                         }
3849
3850                         r = sd_bus_message_append(m, "v", "a(st)", 1, path, (uint64_t) bytes);
3851                 }
3852
3853         } else if (streq(field, "BlockIODeviceWeight")) {
3854
3855                 if (isempty(eq))
3856                         r = sd_bus_message_append(m, "v", "a(st)", 0);
3857                 else {
3858                         const char *path, *weight;
3859                         uint64_t u;
3860                         char *e;
3861
3862                         e = strchr(eq, ' ');
3863                         if (e) {
3864                                 path = strndupa(eq, e - eq);
3865                                 weight = e+1;
3866                         } else {
3867                                 log_error("Failed to parse %s value %s.", field, eq);
3868                                 return -EINVAL;
3869                         }
3870
3871                         if (!path_startswith(path, "/dev")) {
3872                                 log_error("%s is not a device file in /dev.", path);
3873                                 return -EINVAL;
3874                         }
3875
3876                         r = safe_atou64(weight, &u);
3877                         if (r < 0) {
3878                                 log_error("Failed to parse %s value %s.", field, weight);
3879                                 return -EINVAL;
3880                         }
3881                         r = sd_bus_message_append(m, "v", "a(st)", path, u);
3882                 }
3883
3884         } else {
3885                 log_error("Unknown assignment %s.", assignment);
3886                 return -EINVAL;
3887         }
3888
3889         if (r < 0)
3890                 return bus_log_create_error(r);
3891
3892         return 0;
3893 }
3894
3895 static int set_property(sd_bus *bus, char **args) {
3896         _cleanup_bus_message_unref_ sd_bus_message *m = NULL;
3897         _cleanup_bus_error_free_ sd_bus_error error = SD_BUS_ERROR_NULL;
3898         _cleanup_free_ char *n = NULL;
3899         char **i;
3900         int r;
3901
3902         r = sd_bus_message_new_method_call(
3903                         bus,
3904                         "org.freedesktop.systemd1",
3905                         "/org/freedesktop/systemd1",
3906                         "org.freedesktop.systemd1.Manager",
3907                         "SetUnitProperties",
3908                         &m);
3909         if (r < 0)
3910                 return bus_log_create_error(r);
3911
3912         n = unit_name_mangle(args[1]);
3913         if (!n)
3914                 return log_oom();
3915
3916         r = sd_bus_message_append(m, "sb", n, arg_runtime);
3917         if (r < 0)
3918                 return bus_log_create_error(r);
3919
3920         r = sd_bus_message_open_container(m, SD_BUS_TYPE_ARRAY, "(sv)");
3921         if (r < 0)
3922                 return bus_log_create_error(r);
3923
3924         STRV_FOREACH(i, args + 2) {
3925                 r = sd_bus_message_open_container(m, SD_BUS_TYPE_STRUCT, "sv");
3926                 if (r < 0)
3927                         return bus_log_create_error(r);
3928
3929                 r = append_assignment(m, *i);
3930                 if (r < 0)
3931                         return r;
3932
3933                 r = sd_bus_message_close_container(m);
3934                 if (r < 0)
3935                         return bus_log_create_error(r);
3936         }
3937
3938         r = sd_bus_message_close_container(m);
3939         if (r < 0)
3940                 return bus_log_create_error(r);
3941
3942         r = sd_bus_call(bus, m, 0, &error, NULL);
3943         if (r < 0) {
3944                 log_error("Failed to set unit properties on %s: %s", n, bus_error_message(&error, r));
3945                 return r;
3946         }
3947
3948         return 0;
3949 }
3950
3951 static int snapshot(sd_bus *bus, char **args) {
3952         _cleanup_bus_error_free_ sd_bus_error error = SD_BUS_ERROR_NULL;
3953         _cleanup_bus_message_unref_ sd_bus_message *reply = NULL;
3954         _cleanup_free_ char *n = NULL, *id = NULL;
3955         const char *path;
3956         int r;
3957
3958         if (strv_length(args) > 1)
3959                 n = unit_name_mangle_with_suffix(args[1], ".snapshot");
3960         else
3961                 n = strdup("");
3962         if (!n)
3963                 return log_oom();
3964
3965         r = sd_bus_call_method(
3966                         bus,
3967                         "org.freedesktop.systemd1",
3968                         "/org/freedesktop/systemd1",
3969                         "org.freedesktop.systemd1.Manager",
3970                         "CreateSnapshot",
3971                         &error,
3972                         &reply,
3973                         "sb", n, false);
3974         if (r < 0) {
3975                 log_error("Failed to create snapshot: %s", bus_error_message(&error, r));
3976                 return r;
3977         }
3978
3979         r = sd_bus_message_read(reply, "o", &path);
3980         if (r < 0)
3981                 return bus_log_parse_error(r);
3982
3983         r = sd_bus_get_property_string(
3984                         bus,
3985                         "org.freedesktop.systemd1",
3986                         path,
3987                         "org.freedesktop.systemd1.Unit",
3988                         "Id",
3989                         &error,
3990                         &id);
3991         if (r < 0) {
3992                 log_error("Failed to get ID of snapshot: %s", bus_error_message(&error, r));
3993                 return r;
3994         }
3995
3996         if (!arg_quiet)
3997                 puts(id);
3998
3999         return 0;
4000 }
4001
4002 static int delete_snapshot(sd_bus *bus, char **args) {
4003         _cleanup_bus_error_free_ sd_bus_error error = SD_BUS_ERROR_NULL;
4004         char **name;
4005         int r;
4006
4007         assert(args);
4008
4009         STRV_FOREACH(name, args+1) {
4010                 _cleanup_free_ char *n = NULL;
4011
4012                 n = unit_name_mangle_with_suffix(*name, ".snapshot");
4013                 if (!n)
4014                         return log_oom();
4015
4016                 r = sd_bus_call_method(
4017                                 bus,
4018                                 "org.freedesktop.systemd1",
4019                                 "/org/freedesktop/systemd1",
4020                                 "org.freedesktop.systemd1.Manager",
4021                                 "RemoveSnapshot",
4022                                 &error,
4023                                 NULL,
4024                                 "s", n);
4025                 if (r < 0) {
4026                         log_error("Failed to remove snapshot %s: %s", n, bus_error_message(&error, r));
4027                         return r;
4028                 }
4029         }
4030
4031         return 0;
4032 }
4033
4034 static int daemon_reload(sd_bus *bus, char **args) {
4035         _cleanup_bus_error_free_ sd_bus_error error = SD_BUS_ERROR_NULL;
4036         const char *method;
4037         int r;
4038
4039         if (arg_action == ACTION_RELOAD)
4040                 method = "Reload";
4041         else if (arg_action == ACTION_REEXEC)
4042                 method = "Reexecute";
4043         else {
4044                 assert(arg_action == ACTION_SYSTEMCTL);
4045
4046                 method =
4047                         streq(args[0], "clear-jobs")    ||
4048                         streq(args[0], "cancel")        ? "ClearJobs" :
4049                         streq(args[0], "daemon-reexec") ? "Reexecute" :
4050                         streq(args[0], "reset-failed")  ? "ResetFailed" :
4051                         streq(args[0], "halt")          ? "Halt" :
4052                         streq(args[0], "poweroff")      ? "PowerOff" :
4053                         streq(args[0], "reboot")        ? "Reboot" :
4054                         streq(args[0], "kexec")         ? "KExec" :
4055                         streq(args[0], "exit")          ? "Exit" :
4056                                     /* "daemon-reload" */ "Reload";
4057         }
4058
4059         r = sd_bus_call_method(
4060                         bus,
4061                         "org.freedesktop.systemd1",
4062                         "/org/freedesktop/systemd1",
4063                         "org.freedesktop.systemd1.Manager",
4064                         method,
4065                         &error,
4066                         NULL,
4067                         NULL);
4068
4069         if (r == -ENOENT && arg_action != ACTION_SYSTEMCTL)
4070                 /* There's always a fallback possible for
4071                  * legacy actions. */
4072                 r = -EADDRNOTAVAIL;
4073         else if ((r == -ETIMEDOUT || r == -ECONNRESET) && streq(method, "Reexecute"))
4074                 /* On reexecution, we expect a disconnect, not a
4075                  * reply */
4076                 r = 0;
4077         else if (r < 0)
4078                 log_error("Failed to execute operation: %s", bus_error_message(&error, r));
4079
4080         return r < 0 ? r : 0;
4081 }
4082
4083 static int reset_failed(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         if (strv_length(args) <= 1)
4089                 return daemon_reload(bus, args);
4090
4091         STRV_FOREACH(name, args+1) {
4092                 _cleanup_free_ char *n;
4093
4094                 n = unit_name_mangle(*name);
4095                 if (!n)
4096                         return log_oom();
4097
4098                 r = sd_bus_call_method(
4099                                 bus,
4100                                 "org.freedesktop.systemd1",
4101                                 "/org/freedesktop/systemd1",
4102                                 "org.freedesktop.systemd1.Manager",
4103                                 "ResetFailedUnit",
4104                                 &error,
4105                                 NULL,
4106                                 "s", n);
4107                 if (r < 0) {
4108                         log_error("Failed to reset failed state of unit %s: %s", n, bus_error_message(&error, r));
4109                         return r;
4110                 }
4111         }
4112
4113         return 0;
4114 }
4115
4116 static int show_environment(sd_bus *bus, char **args) {
4117         _cleanup_bus_error_free_ sd_bus_error error = SD_BUS_ERROR_NULL;
4118         _cleanup_bus_message_unref_ sd_bus_message *reply = NULL;
4119         const char *text;
4120         int r;
4121
4122         pager_open_if_enabled();
4123
4124         r = sd_bus_get_property(
4125                         bus,
4126                         "org.freedesktop.systemd1",
4127                         "/org/freedesktop/systemd1",
4128                         "org.freedesktop.systemd1.Manager",
4129                         "Environment",
4130                         &error,
4131                         &reply,
4132                         "as");
4133         if (r < 0) {
4134                 log_error("Failed to get environment: %s", bus_error_message(&error, r));
4135                 return r;
4136         }
4137
4138         r = sd_bus_message_enter_container(reply, SD_BUS_TYPE_ARRAY, "s");
4139         if (r < 0)
4140                 return bus_log_parse_error(r);
4141
4142         while ((r = sd_bus_message_read_basic(reply, SD_BUS_TYPE_STRING, &text)) > 0)
4143                 puts(text);
4144         if (r < 0)
4145                 return bus_log_parse_error(r);
4146
4147         r = sd_bus_message_exit_container(reply);
4148         if (r < 0)
4149                 return bus_log_parse_error(r);
4150
4151         return 0;
4152 }
4153
4154 static int switch_root(sd_bus *bus, char **args) {
4155         _cleanup_bus_error_free_ sd_bus_error error = SD_BUS_ERROR_NULL;
4156         _cleanup_free_ char *init = NULL;
4157         const char *root;
4158         unsigned l;
4159         int r;
4160
4161         l = strv_length(args);
4162         if (l < 2 || l > 3) {
4163                 log_error("Wrong number of arguments.");
4164                 return -EINVAL;
4165         }
4166
4167         root = args[1];
4168
4169         if (l >= 3)
4170                 init = strdup(args[2]);
4171         else {
4172                 parse_env_file("/proc/cmdline", WHITESPACE,
4173                                "init", &init,
4174                                NULL);
4175
4176                 if (!init)
4177                         init = strdup("");
4178         }
4179
4180         if (!init)
4181                 return log_oom();
4182
4183         log_debug("switching root - root: %s; init: %s", root, init);
4184
4185         r = sd_bus_call_method(
4186                         bus,
4187                         "org.freedesktop.systemd1",
4188                         "/org/freedesktop/systemd1",
4189                         "org.freedesktop.systemd1.Manager",
4190                         "SwitchRoot",
4191                         &error,
4192                         NULL,
4193                         "ss", root, init);
4194         if (r < 0) {
4195                 log_error("Failed to switch root: %s", bus_error_message(&error, r));
4196                 return r;
4197         }
4198
4199         return 0;
4200 }
4201
4202 static int set_environment(sd_bus *bus, char **args) {
4203         _cleanup_bus_error_free_ sd_bus_error error = SD_BUS_ERROR_NULL;
4204         _cleanup_bus_message_unref_ sd_bus_message *m = NULL;
4205         const char *method;
4206         int r;
4207
4208         assert(bus);
4209         assert(args);
4210
4211         method = streq(args[0], "set-environment")
4212                 ? "SetEnvironment"
4213                 : "UnsetEnvironment";
4214
4215         r = sd_bus_message_new_method_call(
4216                         bus,
4217                         "org.freedesktop.systemd1",
4218                         "/org/freedesktop/systemd1",
4219                         "org.freedesktop.systemd1.Manager",
4220                         method,
4221                         &m);
4222         if (r < 0)
4223                 return bus_log_create_error(r);
4224
4225         r = sd_bus_message_append_strv(m, args + 1);
4226         if (r < 0)
4227                 return bus_log_create_error(r);
4228
4229         r = sd_bus_call(bus, m, 0, &error, NULL);
4230         if (r < 0) {
4231                 log_error("Failed to set environment: %s", bus_error_message(&error, r));
4232                 return r;
4233         }
4234
4235         return 0;
4236 }
4237
4238 static int enable_sysv_units(const char *verb, char **args) {
4239         int r = 0;
4240
4241 #if defined(HAVE_SYSV_COMPAT) && defined(HAVE_CHKCONFIG)
4242         unsigned f = 1, t = 1;
4243         _cleanup_lookup_paths_free_ LookupPaths paths = {};
4244
4245         if (arg_scope != UNIT_FILE_SYSTEM)
4246                 return 0;
4247
4248         if (!streq(verb, "enable") &&
4249             !streq(verb, "disable") &&
4250             !streq(verb, "is-enabled"))
4251                 return 0;
4252
4253         /* Processes all SysV units, and reshuffles the array so that
4254          * afterwards only the native units remain */
4255
4256         r = lookup_paths_init(&paths, SYSTEMD_SYSTEM, false, NULL, NULL, NULL);
4257         if (r < 0)
4258                 return r;
4259
4260         r = 0;
4261         for (f = 0; args[f]; f++) {
4262                 const char *name;
4263                 _cleanup_free_ char *p = NULL, *q = NULL;
4264                 bool found_native = false, found_sysv;
4265                 unsigned c = 1;
4266                 const char *argv[6] = { "/sbin/chkconfig", NULL, NULL, NULL, NULL };
4267                 char **k, *l;
4268                 int j;
4269                 pid_t pid;
4270                 siginfo_t status;
4271
4272                 name = args[f];
4273
4274                 if (!endswith(name, ".service"))
4275                         continue;
4276
4277                 if (path_is_absolute(name))
4278                         continue;
4279
4280                 STRV_FOREACH(k, paths.unit_path) {
4281                         if (!isempty(arg_root))
4282                                 asprintf(&p, "%s/%s/%s", arg_root, *k, name);
4283                         else
4284                                 asprintf(&p, "%s/%s", *k, name);
4285
4286                         if (!p) {
4287                                 r = log_oom();
4288                                 goto finish;
4289                         }
4290
4291                         found_native = access(p, F_OK) >= 0;
4292                         free(p);
4293                         p = NULL;
4294
4295                         if (found_native)
4296                                 break;
4297                 }
4298
4299                 if (found_native)
4300                         continue;
4301
4302                 if (!isempty(arg_root))
4303                         asprintf(&p, "%s/" SYSTEM_SYSVINIT_PATH "/%s", arg_root, name);
4304                 else
4305                         asprintf(&p, SYSTEM_SYSVINIT_PATH "/%s", name);
4306                 if (!p) {
4307                         r = log_oom();
4308                         goto finish;
4309                 }
4310
4311                 p[strlen(p) - sizeof(".service") + 1] = 0;
4312                 found_sysv = access(p, F_OK) >= 0;
4313
4314                 if (!found_sysv)
4315                         continue;
4316
4317                 /* Mark this entry, so that we don't try enabling it as native unit */
4318                 args[f] = (char*) "";
4319
4320                 log_info("%s is not a native service, redirecting to /sbin/chkconfig.", name);
4321
4322                 if (!isempty(arg_root))
4323                         argv[c++] = q = strappend("--root=", arg_root);
4324
4325                 argv[c++] = path_get_file_name(p);
4326                 argv[c++] =
4327                         streq(verb, "enable") ? "on" :
4328                         streq(verb, "disable") ? "off" : "--level=5";
4329                 argv[c] = NULL;
4330
4331                 l = strv_join((char**)argv, " ");
4332                 if (!l) {
4333                         r = log_oom();
4334                         goto finish;
4335                 }
4336
4337                 log_info("Executing %s", l);
4338                 free(l);
4339
4340                 pid = fork();
4341                 if (pid < 0) {
4342                         log_error("Failed to fork: %m");
4343                         r = -errno;
4344                         goto finish;
4345                 } else if (pid == 0) {
4346                         /* Child */
4347
4348                         execv(argv[0], (char**) argv);
4349                         _exit(EXIT_FAILURE);
4350                 }
4351
4352                 j = wait_for_terminate(pid, &status);
4353                 if (j < 0) {
4354                         log_error("Failed to wait for child: %s", strerror(-r));
4355                         r = j;
4356                         goto finish;
4357                 }
4358
4359                 if (status.si_code == CLD_EXITED) {
4360                         if (streq(verb, "is-enabled")) {
4361                                 if (status.si_status == 0) {
4362                                         if (!arg_quiet)
4363                                                 puts("enabled");
4364                                         r = 1;
4365                                 } else {
4366                                         if (!arg_quiet)
4367                                                 puts("disabled");
4368                                 }
4369
4370                         } else if (status.si_status != 0) {
4371                                 r = -EINVAL;
4372                                 goto finish;
4373                         }
4374                 } else {
4375                         r = -EPROTO;
4376                         goto finish;
4377                 }
4378         }
4379
4380 finish:
4381         /* Drop all SysV units */
4382         for (f = 0, t = 0; args[f]; f++) {
4383
4384                 if (isempty(args[f]))
4385                         continue;
4386
4387                 args[t++] = args[f];
4388         }
4389
4390         args[t] = NULL;
4391
4392 #endif
4393         return r;
4394 }
4395
4396 static int mangle_names(char **original_names, char ***mangled_names) {
4397         char **i, **l, **name;
4398
4399         l = new(char*, strv_length(original_names) + 1);
4400         if (!l)
4401                 return log_oom();
4402
4403         i = l;
4404         STRV_FOREACH(name, original_names) {
4405
4406                 /* When enabling units qualified path names are OK,
4407                  * too, hence allow them explicitly. */
4408
4409                 if (is_path(*name))
4410                         *i = strdup(*name);
4411                 else
4412                         *i = unit_name_mangle(*name);
4413
4414                 if (!*i) {
4415                         strv_free(l);
4416                         return log_oom();
4417                 }
4418
4419                 i++;
4420         }
4421
4422         *i = NULL;
4423         *mangled_names = l;
4424
4425         return 0;
4426 }
4427
4428 static int enable_unit(sd_bus *bus, char **args) {
4429         _cleanup_strv_free_ char **mangled_names = NULL;
4430         const char *verb = args[0];
4431         UnitFileChange *changes = NULL;
4432         unsigned n_changes = 0;
4433         int carries_install_info = -1;
4434         int r;
4435
4436         if (!args[1])
4437                 return 0;
4438
4439         r = mangle_names(args+1, &mangled_names);
4440         if (r < 0)
4441                 return r;
4442
4443         r = enable_sysv_units(verb, mangled_names);
4444         if (r < 0)
4445                 return r;
4446
4447         if (!bus || avoid_bus()) {
4448                 if (streq(verb, "enable")) {
4449                         r = unit_file_enable(arg_scope, arg_runtime, arg_root, mangled_names, arg_force, &changes, &n_changes);
4450                         carries_install_info = r;
4451                 } else if (streq(verb, "disable"))
4452                         r = unit_file_disable(arg_scope, arg_runtime, arg_root, mangled_names, &changes, &n_changes);
4453                 else if (streq(verb, "reenable")) {
4454                         r = unit_file_reenable(arg_scope, arg_runtime, arg_root, mangled_names, arg_force, &changes, &n_changes);
4455                         carries_install_info = r;
4456                 } else if (streq(verb, "link"))
4457                         r = unit_file_link(arg_scope, arg_runtime, arg_root, mangled_names, arg_force, &changes, &n_changes);
4458                 else if (streq(verb, "preset")) {
4459                         r = unit_file_preset(arg_scope, arg_runtime, arg_root, mangled_names, arg_force, &changes, &n_changes);
4460                         carries_install_info = r;
4461                 } else if (streq(verb, "mask"))
4462                         r = unit_file_mask(arg_scope, arg_runtime, arg_root, mangled_names, arg_force, &changes, &n_changes);
4463                 else if (streq(verb, "unmask"))
4464                         r = unit_file_unmask(arg_scope, arg_runtime, arg_root, mangled_names, &changes, &n_changes);
4465                 else
4466                         assert_not_reached("Unknown verb");
4467
4468                 if (r < 0) {
4469                         log_error("Operation failed: %s", strerror(-r));
4470                         goto finish;
4471                 }
4472
4473                 if (!arg_quiet)
4474                         dump_unit_file_changes(changes, n_changes);
4475
4476                 r = 0;
4477         } else {
4478                 _cleanup_bus_message_unref_ sd_bus_message *reply = NULL, *m = NULL;
4479                 _cleanup_bus_error_free_ sd_bus_error error = SD_BUS_ERROR_NULL;
4480                 int expect_carries_install_info = false;
4481                 bool send_force = true;
4482                 const char *method;
4483
4484                 if (streq(verb, "enable")) {
4485                         method = "EnableUnitFiles";
4486                         expect_carries_install_info = true;
4487                 } else if (streq(verb, "disable")) {
4488                         method = "DisableUnitFiles";
4489                         send_force = false;
4490                 } else if (streq(verb, "reenable")) {
4491                         method = "ReenableUnitFiles";
4492                         expect_carries_install_info = true;
4493                 } else if (streq(verb, "link"))
4494                         method = "LinkUnitFiles";
4495                 else if (streq(verb, "preset")) {
4496                         method = "PresetUnitFiles";
4497                         expect_carries_install_info = true;
4498                 } else if (streq(verb, "mask"))
4499                         method = "MaskUnitFiles";
4500                 else if (streq(verb, "unmask")) {
4501                         method = "UnmaskUnitFiles";
4502                         send_force = false;
4503                 } else
4504                         assert_not_reached("Unknown verb");
4505
4506                 r = sd_bus_message_new_method_call(
4507                                 bus,
4508                                 "org.freedesktop.systemd1",
4509                                 "/org/freedesktop/systemd1",
4510                                 "org.freedesktop.systemd1.Manager",
4511                                 method,
4512                                 &m);
4513                 if (r < 0)
4514                         return bus_log_create_error(r);
4515
4516                 r = sd_bus_message_append_strv(m, mangled_names);
4517                 if (r < 0)
4518                         return bus_log_create_error(r);
4519
4520                 r = sd_bus_message_append(m, "b", arg_runtime);
4521                 if (r < 0)
4522                         return bus_log_create_error(r);
4523
4524                 if (send_force) {
4525                         r = sd_bus_message_append(m, "b", arg_force);
4526                         if (r < 0)
4527                                 return bus_log_create_error(r);
4528                 }
4529
4530                 r = sd_bus_call(bus, m, 0, &error, &reply);
4531                 if (r < 0) {
4532                         log_error("Failed to execute operation: %s", bus_error_message(&error, r));
4533                         return r;
4534                 }
4535
4536                 if (expect_carries_install_info) {
4537                         r = sd_bus_message_read(reply, "b", &carries_install_info);
4538                         if (r < 0)
4539                                 return bus_log_parse_error(r);
4540                 }
4541
4542                 r = deserialize_and_dump_unit_file_changes(reply);
4543                 if (r < 0)
4544                         return r;
4545
4546                 /* Try to reload if enabeld */
4547                 if (!arg_no_reload)
4548                         r = daemon_reload(bus, args);
4549                 else
4550                         r = 0;
4551         }
4552
4553         if (carries_install_info == 0)
4554                 log_warning("The unit files have no [Install] section. They are not meant to be enabled\n"
4555                             "using systemctl.\n"
4556                             "Possible reasons for having this kind of units are:\n"
4557                             "1) A unit may be statically enabled by being symlinked from another unit's\n"
4558                             "   .wants/ or .requires/ directory.\n"
4559                             "2) A unit's purpose may be to act as a helper for some other unit which has\n"
4560                             "   a requirement dependency on it.\n"
4561                             "3) A unit may be started when needed via activation (socket, path, timer,\n"
4562                             "   D-Bus, udev, scripted systemctl call, ...).\n");
4563
4564 finish:
4565         unit_file_changes_free(changes, n_changes);
4566
4567         return r;
4568 }
4569
4570 static int unit_is_enabled(sd_bus *bus, char **args) {
4571
4572         _cleanup_bus_error_free_ sd_bus_error error = SD_BUS_ERROR_NULL;
4573         _cleanup_strv_free_ char **mangled_names = NULL;
4574         bool enabled;
4575         char **name;
4576         int r;
4577
4578         r = mangle_names(args+1, &mangled_names);
4579         if (r < 0)
4580                 return r;
4581
4582         r = enable_sysv_units(args[0], mangled_names);
4583         if (r < 0)
4584                 return r;
4585
4586         enabled = r > 0;
4587
4588         if (!bus || avoid_bus()) {
4589
4590                 STRV_FOREACH(name, mangled_names) {
4591                         UnitFileState state;
4592
4593                         state = unit_file_get_state(arg_scope, arg_root, *name);
4594                         if (state < 0) {
4595                                 log_error("Failed to get unit file state for %s: %s", *name, strerror(-state));
4596                                 return state;
4597                         }
4598
4599                         if (state == UNIT_FILE_ENABLED ||
4600                             state == UNIT_FILE_ENABLED_RUNTIME ||
4601                             state == UNIT_FILE_STATIC)
4602                                 enabled = true;
4603
4604                         if (!arg_quiet)
4605                                 puts(unit_file_state_to_string(state));
4606                 }
4607
4608         } else {
4609                 STRV_FOREACH(name, mangled_names) {
4610                         _cleanup_bus_message_unref_ sd_bus_message *reply = NULL;
4611                         const char *s;
4612
4613                         r = sd_bus_call_method(
4614                                         bus,
4615                                         "org.freedesktop.systemd1",
4616                                         "/org/freedesktop/systemd1",
4617                                         "org.freedesktop.systemd1.Manager",
4618                                         "GetUnitFileState",
4619                                         &error,
4620                                         &reply,
4621                                         "s", name);
4622                         if (r < 0) {
4623                                 log_error("Failed to get unit file state for %s: %s", *name, bus_error_message(&error, r));
4624                                 return r;
4625                         }
4626
4627                         r = sd_bus_message_read(reply, "s", &s);
4628                         if (r < 0)
4629                                 return bus_log_parse_error(r);
4630
4631                         if (streq(s, "enabled") ||
4632                             streq(s, "enabled-runtime") ||
4633                             streq(s, "static"))
4634                                 enabled = true;
4635
4636                         if (!arg_quiet)
4637                                 puts(s);
4638                 }
4639         }
4640
4641         return !enabled;
4642 }
4643
4644 static int systemctl_help(void) {
4645
4646         pager_open_if_enabled();
4647
4648         printf("%s [OPTIONS...] {COMMAND} ...\n\n"
4649                "Query or send control commands to the systemd manager.\n\n"
4650                "  -h --help           Show this help\n"
4651                "     --version        Show package version\n"
4652                "     --system         Connect to system manager\n"
4653                "     --user           Connect to user service manager\n"
4654                "  -H --host=[USER@]HOST\n"
4655                "                      Operate on remote host\n"
4656                "  -M --machine=CONTAINER\n"
4657                "                      Operate on local container\n"
4658                "  -t --type=TYPE      List only units of a particular type\n"
4659                "     --state=STATE    List only units with particular LOAD or SUB or ACTIVE state\n"
4660                "  -p --property=NAME  Show only properties by this name\n"
4661                "  -a --all            Show all loaded units/properties, including dead/empty\n"
4662                "                      ones. To list all units installed on the system, use\n"
4663                "                      the 'list-unit-files' command instead.\n"
4664                "  -l --full           Don't ellipsize unit names on output\n"
4665                "     --reverse        Show reverse dependencies with 'list-dependencies'\n"
4666                "     --job-mode=MODE  Specify how to deal with already queued jobs, when\n"
4667                "                      queueing a new job\n"
4668                "     --show-types     When showing sockets, explicitly show their type\n"
4669                "  -i --ignore-inhibitors\n"
4670                "                      When shutting down or sleeping, ignore inhibitors\n"
4671                "     --kill-who=WHO   Who to send signal to\n"
4672                "  -s --signal=SIGNAL  Which signal to send\n"
4673                "  -q --quiet          Suppress output\n"
4674                "     --no-block       Do not wait until operation finished\n"
4675                "     --no-wall        Don't send wall message before halt/power-off/reboot\n"
4676                "     --no-reload      When enabling/disabling unit files, don't reload daemon\n"
4677                "                      configuration\n"
4678                "     --no-legend      Do not print a legend (column headers and hints)\n"
4679                "     --no-pager       Do not pipe output into a pager\n"
4680                "     --no-ask-password\n"
4681                "                      Do not ask for system passwords\n"
4682                "     --global         Enable/disable unit files globally\n"
4683                "     --runtime        Enable unit files only temporarily until next reboot\n"
4684                "  -f --force          When enabling unit files, override existing symlinks\n"
4685                "                      When shutting down, execute action immediately\n"
4686                "     --root=PATH      Enable unit files in the specified root directory\n"
4687                "  -n --lines=INTEGER  Number of journal entries to show\n"
4688                "  -o --output=STRING  Change journal output mode (short, short-monotonic,\n"
4689                "                      verbose, export, json, json-pretty, json-sse, cat)\n\n"
4690                "Unit Commands:\n"
4691                "  list-units                      List loaded units\n"
4692                "  list-sockets                    List loaded sockets ordered by address\n"
4693                "  list-timers                     List loaded timers ordered by next elapse\n"
4694                "  start [NAME...]                 Start (activate) one or more units\n"
4695                "  stop [NAME...]                  Stop (deactivate) one or more units\n"
4696                "  reload [NAME...]                Reload one or more units\n"
4697                "  restart [NAME...]               Start or restart one or more units\n"
4698                "  try-restart [NAME...]           Restart one or more units if active\n"
4699                "  reload-or-restart [NAME...]     Reload one or more units if possible,\n"
4700                "                                  otherwise start or restart\n"
4701                "  reload-or-try-restart [NAME...] Reload one or more units if possible,\n"
4702                "                                  otherwise restart if active\n"
4703                "  isolate [NAME]                  Start one unit and stop all others\n"
4704                "  kill [NAME...]                  Send signal to processes of a unit\n"
4705                "  is-active [NAME...]             Check whether units are active\n"
4706                "  is-failed [NAME...]             Check whether units are failed\n"
4707                "  status [NAME...|PID...]         Show runtime status of one or more units\n"
4708                "  show [NAME...|JOB...]           Show properties of one or more\n"
4709                "                                  units/jobs or the manager\n"
4710                "  set-property [NAME] [ASSIGNMENT...]\n"
4711                "                                  Sets one or more properties of a unit\n"
4712                "  help [NAME...|PID...]           Show manual for one or more units\n"
4713                "  reset-failed [NAME...]          Reset failed state for all, one, or more\n"
4714                "                                  units\n"
4715                "  list-dependencies [NAME]        Recursively show units which are required\n"
4716                "                                  or wanted by this unit or by which this\n"
4717                "                                  unit is required or wanted\n\n"
4718                "Unit File Commands:\n"
4719                "  list-unit-files                 List installed unit files\n"
4720                "  enable [NAME...]                Enable one or more unit files\n"
4721                "  disable [NAME...]               Disable one or more unit files\n"
4722                "  reenable [NAME...]              Reenable one or more unit files\n"
4723                "  preset [NAME...]                Enable/disable one or more unit files\n"
4724                "                                  based on preset configuration\n"
4725                "  is-enabled [NAME...]            Check whether unit files are enabled\n\n"
4726                "  mask [NAME...]                  Mask one or more units\n"
4727                "  unmask [NAME...]                Unmask one or more units\n"
4728                "  link [PATH...]                  Link one or more units files into\n"
4729                "                                  the search path\n"
4730                "  get-default                     Get the name of the default target\n"
4731                "  set-default NAME                Set the default target\n\n"
4732                "Job Commands:\n"
4733                "  list-jobs                       List jobs\n"
4734                "  cancel [JOB...]                 Cancel all, one, or more jobs\n\n"
4735                "Snapshot Commands:\n"
4736                "  snapshot [NAME]                 Create a snapshot\n"
4737                "  delete [NAME...]                Remove one or more snapshots\n\n"
4738                "Environment Commands:\n"
4739                "  show-environment                Dump environment\n"
4740                "  set-environment [NAME=VALUE...] Set one or more environment variables\n"
4741                "  unset-environment [NAME...]     Unset one or more environment variables\n\n"
4742                "Manager Lifecycle Commands:\n"
4743                "  daemon-reload                   Reload systemd manager configuration\n"
4744                "  daemon-reexec                   Reexecute systemd manager\n\n"
4745                "System Commands:\n"
4746                "  default                         Enter system default mode\n"
4747                "  rescue                          Enter system rescue mode\n"
4748                "  emergency                       Enter system emergency mode\n"
4749                "  halt                            Shut down and halt the system\n"
4750                "  poweroff                        Shut down and power-off the system\n"
4751                "  reboot [ARG]                    Shut down and reboot the system\n"
4752                "  kexec                           Shut down and reboot the system with kexec\n"
4753                "  exit                            Request user instance exit\n"
4754                "  switch-root [ROOT] [INIT]       Change to a different root file system\n"
4755                "  suspend                         Suspend the system\n"
4756                "  hibernate                       Hibernate the system\n"
4757                "  hybrid-sleep                    Hibernate and suspend the system\n",
4758                program_invocation_short_name);
4759
4760         return 0;
4761 }
4762
4763 static int halt_help(void) {
4764
4765         printf("%s [OPTIONS...]%s\n\n"
4766                "%s the system.\n\n"
4767                "     --help      Show this help\n"
4768                "     --halt      Halt the machine\n"
4769                "  -p --poweroff  Switch off the machine\n"
4770                "     --reboot    Reboot the machine\n"
4771                "  -f --force     Force immediate halt/power-off/reboot\n"
4772                "  -w --wtmp-only Don't halt/power-off/reboot, just write wtmp record\n"
4773                "  -d --no-wtmp   Don't write wtmp record\n"
4774                "     --no-wall   Don't send wall message before halt/power-off/reboot\n",
4775                program_invocation_short_name,
4776                arg_action == ACTION_REBOOT   ? " [ARG]" : "",
4777                arg_action == ACTION_REBOOT   ? "Reboot" :
4778                arg_action == ACTION_POWEROFF ? "Power off" :
4779                                                "Halt");
4780
4781         return 0;
4782 }
4783
4784 static int shutdown_help(void) {
4785
4786         printf("%s [OPTIONS...] [TIME] [WALL...]\n\n"
4787                "Shut down the system.\n\n"
4788                "     --help      Show this help\n"
4789                "  -H --halt      Halt the machine\n"
4790                "  -P --poweroff  Power-off the machine\n"
4791                "  -r --reboot    Reboot the machine\n"
4792                "  -h             Equivalent to --poweroff, overridden by --halt\n"
4793                "  -k             Don't halt/power-off/reboot, just send warnings\n"
4794                "     --no-wall   Don't send wall message before halt/power-off/reboot\n"
4795                "  -c             Cancel a pending shutdown\n",
4796                program_invocation_short_name);
4797
4798         return 0;
4799 }
4800
4801 static int telinit_help(void) {
4802
4803         printf("%s [OPTIONS...] {COMMAND}\n\n"
4804                "Send control commands to the init daemon.\n\n"
4805                "     --help      Show this help\n"
4806                "     --no-wall   Don't send wall message before halt/power-off/reboot\n\n"
4807                "Commands:\n"
4808                "  0              Power-off the machine\n"
4809                "  6              Reboot the machine\n"
4810                "  2, 3, 4, 5     Start runlevelX.target unit\n"
4811                "  1, s, S        Enter rescue mode\n"
4812                "  q, Q           Reload init daemon configuration\n"
4813                "  u, U           Reexecute init daemon\n",
4814                program_invocation_short_name);
4815
4816         return 0;
4817 }
4818
4819 static int runlevel_help(void) {
4820
4821         printf("%s [OPTIONS...]\n\n"
4822                "Prints the previous and current runlevel of the init system.\n\n"
4823                "     --help      Show this help\n",
4824                program_invocation_short_name);
4825
4826         return 0;
4827 }
4828
4829 static int help_types(void) {
4830         int i;
4831         const char *t;
4832
4833         puts("Available unit types:");
4834         for(i = 0; i < _UNIT_TYPE_MAX; i++) {
4835                 t = unit_type_to_string(i);
4836                 if (t)
4837                         puts(t);
4838         }
4839
4840         return 0;
4841 }
4842
4843 static int systemctl_parse_argv(int argc, char *argv[]) {
4844
4845         enum {
4846                 ARG_FAIL = 0x100,
4847                 ARG_REVERSE,
4848                 ARG_AFTER,
4849                 ARG_BEFORE,
4850                 ARG_SHOW_TYPES,
4851                 ARG_IRREVERSIBLE,
4852                 ARG_IGNORE_DEPENDENCIES,
4853                 ARG_VERSION,
4854                 ARG_USER,
4855                 ARG_SYSTEM,
4856                 ARG_GLOBAL,
4857                 ARG_NO_BLOCK,
4858                 ARG_NO_LEGEND,
4859                 ARG_NO_PAGER,
4860                 ARG_NO_WALL,
4861                 ARG_ROOT,
4862                 ARG_NO_RELOAD,
4863                 ARG_KILL_WHO,
4864                 ARG_NO_ASK_PASSWORD,
4865                 ARG_FAILED,
4866                 ARG_RUNTIME,
4867                 ARG_FORCE,
4868                 ARG_PLAIN,
4869                 ARG_STATE,
4870                 ARG_JOB_MODE
4871         };
4872
4873         static const struct option options[] = {
4874                 { "help",                no_argument,       NULL, 'h'                     },
4875                 { "version",             no_argument,       NULL, ARG_VERSION             },
4876                 { "type",                required_argument, NULL, 't'                     },
4877                 { "property",            required_argument, NULL, 'p'                     },
4878                 { "all",                 no_argument,       NULL, 'a'                     },
4879                 { "reverse",             no_argument,       NULL, ARG_REVERSE             },
4880                 { "after",               no_argument,       NULL, ARG_AFTER               },
4881                 { "before",              no_argument,       NULL, ARG_BEFORE              },
4882                 { "show-types",          no_argument,       NULL, ARG_SHOW_TYPES          },
4883                 { "failed",              no_argument,       NULL, ARG_FAILED              }, /* compatibility only */
4884                 { "full",                no_argument,       NULL, 'l'                     },
4885                 { "job-mode",            required_argument, NULL, ARG_JOB_MODE            },
4886                 { "fail",                no_argument,       NULL, ARG_FAIL                }, /* compatibility only */
4887                 { "irreversible",        no_argument,       NULL, ARG_IRREVERSIBLE        }, /* compatibility only */
4888                 { "ignore-dependencies", no_argument,       NULL, ARG_IGNORE_DEPENDENCIES }, /* compatibility only */
4889                 { "ignore-inhibitors",   no_argument,       NULL, 'i'                     },
4890                 { "user",                no_argument,       NULL, ARG_USER                },
4891                 { "system",              no_argument,       NULL, ARG_SYSTEM              },
4892                 { "global",              no_argument,       NULL, ARG_GLOBAL              },
4893                 { "no-block",            no_argument,       NULL, ARG_NO_BLOCK            },
4894                 { "no-legend",           no_argument,       NULL, ARG_NO_LEGEND           },
4895                 { "no-pager",            no_argument,       NULL, ARG_NO_PAGER            },
4896                 { "no-wall",             no_argument,       NULL, ARG_NO_WALL             },
4897                 { "quiet",               no_argument,       NULL, 'q'                     },
4898                 { "root",                required_argument, NULL, ARG_ROOT                },
4899                 { "force",               no_argument,       NULL, ARG_FORCE               },
4900                 { "no-reload",           no_argument,       NULL, ARG_NO_RELOAD           },
4901                 { "kill-who",            required_argument, NULL, ARG_KILL_WHO            },
4902                 { "signal",              required_argument, NULL, 's'                     },
4903                 { "no-ask-password",     no_argument,       NULL, ARG_NO_ASK_PASSWORD     },
4904                 { "host",                required_argument, NULL, 'H'                     },
4905                 { "machine",             required_argument, NULL, 'M'                     },
4906                 { "runtime",             no_argument,       NULL, ARG_RUNTIME             },
4907                 { "lines",               required_argument, NULL, 'n'                     },
4908                 { "output",              required_argument, NULL, 'o'                     },
4909                 { "plain",               no_argument,       NULL, ARG_PLAIN               },
4910                 { "state",               required_argument, NULL, ARG_STATE               },
4911                 {}
4912         };
4913
4914         int c;
4915
4916         assert(argc >= 0);
4917         assert(argv);
4918
4919         while ((c = getopt_long(argc, argv, "ht:p:alqfs:H:M:n:o:i", options, NULL)) >= 0) {
4920
4921                 switch (c) {
4922
4923                 case 'h':
4924                         return systemctl_help();
4925
4926                 case ARG_VERSION:
4927                         puts(PACKAGE_STRING);
4928                         puts(SYSTEMD_FEATURES);
4929                         return 0;
4930
4931                 case 't': {
4932                         char *word, *state;
4933                         size_t size;
4934
4935                         FOREACH_WORD_SEPARATOR(word, size, optarg, ",", state) {
4936                                 _cleanup_free_ char *type;
4937
4938                                 type = strndup(word, size);
4939                                 if (!type)
4940                                         return -ENOMEM;
4941
4942                                 if (streq(type, "help")) {
4943                                         help_types();
4944                                         return 0;
4945                                 }
4946
4947                                 if (unit_type_from_string(type) >= 0) {
4948                                         if (strv_push(&arg_types, type))
4949                                                 return log_oom();
4950                                         type = NULL;
4951                                         continue;
4952                                 }
4953
4954                                 /* It's much nicer to use --state= for
4955                                  * load states, but let's support this
4956                                  * in --types= too for compatibility
4957                                  * with old versions */
4958                                 if (unit_load_state_from_string(optarg) >= 0) {
4959                                         if (strv_push(&arg_states, type) < 0)
4960                                                 return log_oom();
4961                                         type = NULL;
4962                                         continue;
4963                                 }
4964
4965                                 log_error("Unknown unit type or load state '%s'.", type);
4966                                 log_info("Use -t help to see a list of allowed values.");
4967                                 return -EINVAL;
4968                         }
4969
4970                         break;
4971                 }
4972
4973                 case 'p': {
4974                         /* Make sure that if the empty property list
4975                            was specified, we won't show any properties. */
4976                         if (isempty(optarg) && !arg_properties) {
4977                                 arg_properties = new0(char*, 1);
4978                                 if (!arg_properties)
4979                                         return log_oom();
4980                         } else {
4981                                 char *word, *state;
4982                                 size_t size;
4983
4984                                 FOREACH_WORD_SEPARATOR(word, size, optarg, ",", state) {
4985                                         char *prop;
4986
4987                                         prop = strndup(word, size);
4988                                         if (!prop)
4989                                                 return log_oom();
4990
4991                                         if (strv_push(&arg_properties, prop) < 0) {
4992                                                 free(prop);
4993                                                 return log_oom();
4994                                         }
4995                                 }
4996                         }
4997
4998                         /* If the user asked for a particular
4999                          * property, show it to him, even if it is
5000                          * empty. */
5001                         arg_all = true;
5002
5003                         break;
5004                 }
5005
5006                 case 'a':
5007                         arg_all = true;
5008                         break;
5009
5010                 case ARG_REVERSE:
5011                         arg_dependency = DEPENDENCY_REVERSE;
5012                         break;
5013
5014                 case ARG_AFTER:
5015                         arg_dependency = DEPENDENCY_AFTER;
5016                         break;
5017
5018                 case ARG_BEFORE:
5019                         arg_dependency = DEPENDENCY_BEFORE;
5020                         break;
5021
5022                 case ARG_SHOW_TYPES:
5023                         arg_show_types = true;
5024                         break;
5025
5026                 case ARG_JOB_MODE:
5027                         arg_job_mode = optarg;
5028                         break;
5029
5030                 case ARG_FAIL:
5031                         arg_job_mode = "fail";
5032                         break;
5033
5034                 case ARG_IRREVERSIBLE:
5035                         arg_job_mode = "replace-irreversibly";
5036                         break;
5037
5038                 case ARG_IGNORE_DEPENDENCIES:
5039                         arg_job_mode = "ignore-dependencies";
5040                         break;
5041
5042                 case ARG_USER:
5043                         arg_scope = UNIT_FILE_USER;
5044                         break;
5045
5046                 case ARG_SYSTEM:
5047                         arg_scope = UNIT_FILE_SYSTEM;
5048                         break;
5049
5050                 case ARG_GLOBAL:
5051                         arg_scope = UNIT_FILE_GLOBAL;
5052                         break;
5053
5054                 case ARG_NO_BLOCK:
5055                         arg_no_block = true;
5056                         break;
5057
5058                 case ARG_NO_LEGEND:
5059                         arg_no_legend = true;
5060                         break;
5061
5062                 case ARG_NO_PAGER:
5063                         arg_no_pager = true;
5064                         break;
5065
5066                 case ARG_NO_WALL:
5067                         arg_no_wall = true;
5068                         break;
5069
5070                 case ARG_ROOT:
5071                         arg_root = optarg;
5072                         break;
5073
5074                 case 'l':
5075                         arg_full = true;
5076                         break;
5077
5078                 case ARG_FAILED:
5079                         if (strv_extend(&arg_states, "failed") < 0)
5080                                 return log_oom();
5081
5082                         break;
5083
5084                 case 'q':
5085                         arg_quiet = true;
5086                         break;
5087
5088                 case ARG_FORCE:
5089                         arg_force ++;
5090                         break;
5091
5092                 case 'f':
5093                         arg_force ++;
5094                         break;
5095
5096                 case ARG_NO_RELOAD:
5097                         arg_no_reload = true;
5098                         break;
5099
5100                 case ARG_KILL_WHO:
5101                         arg_kill_who = optarg;
5102                         break;
5103
5104                 case 's':
5105                         if ((arg_signal = signal_from_string_try_harder(optarg)) < 0) {
5106                                 log_error("Failed to parse signal string %s.", optarg);
5107                                 return -EINVAL;
5108                         }
5109                         break;
5110
5111                 case ARG_NO_ASK_PASSWORD:
5112                         arg_ask_password = false;
5113                         break;
5114
5115                 case 'H':
5116                         arg_transport = BUS_TRANSPORT_REMOTE;
5117                         arg_host = optarg;
5118                         break;
5119
5120                 case 'M':
5121                         arg_transport = BUS_TRANSPORT_CONTAINER;
5122                         arg_host = optarg;
5123                         break;
5124
5125                 case ARG_RUNTIME:
5126                         arg_runtime = true;
5127                         break;
5128
5129                 case 'n':
5130                         if (safe_atou(optarg, &arg_lines) < 0) {
5131                                 log_error("Failed to parse lines '%s'", optarg);
5132                                 return -EINVAL;
5133                         }
5134                         break;
5135
5136                 case 'o':
5137                         arg_output = output_mode_from_string(optarg);
5138                         if (arg_output < 0) {
5139                                 log_error("Unknown output '%s'.", optarg);
5140                                 return -EINVAL;
5141                         }
5142                         break;
5143
5144                 case 'i':
5145                         arg_ignore_inhibitors = true;
5146                         break;
5147
5148                 case ARG_PLAIN:
5149                         arg_plain = true;
5150                         break;
5151
5152                 case ARG_STATE: {
5153                         char *word, *state;
5154                         size_t size;
5155
5156                         FOREACH_WORD_SEPARATOR(word, size, optarg, ",", state) {
5157                                 char *s;
5158
5159                                 s = strndup(word, size);
5160                                 if (!s)
5161                                         return log_oom();
5162
5163                                 if (strv_push(&arg_states, s) < 0) {
5164                                         free(s);
5165                                         return log_oom();
5166                                 }
5167                         }
5168                         break;
5169                 }
5170
5171                 case '?':
5172                         return -EINVAL;
5173
5174                 default:
5175                         assert_not_reached("Unhandled option");
5176                 }
5177         }
5178
5179         if (arg_transport != BUS_TRANSPORT_LOCAL && arg_scope != UNIT_FILE_SYSTEM) {
5180                 log_error("Cannot access user instance remotely.");
5181                 return -EINVAL;
5182         }
5183
5184         return 1;
5185 }
5186
5187 static int halt_parse_argv(int argc, char *argv[]) {
5188
5189         enum {
5190                 ARG_HELP = 0x100,
5191                 ARG_HALT,
5192                 ARG_REBOOT,
5193                 ARG_NO_WALL
5194         };
5195
5196         static const struct option options[] = {
5197                 { "help",      no_argument,       NULL, ARG_HELP    },
5198                 { "halt",      no_argument,       NULL, ARG_HALT    },
5199                 { "poweroff",  no_argument,       NULL, 'p'         },
5200                 { "reboot",    no_argument,       NULL, ARG_REBOOT  },
5201                 { "force",     no_argument,       NULL, 'f'         },
5202                 { "wtmp-only", no_argument,       NULL, 'w'         },
5203                 { "no-wtmp",   no_argument,       NULL, 'd'         },
5204                 { "no-wall",   no_argument,       NULL, ARG_NO_WALL },
5205                 {}
5206         };
5207
5208         int c, r, runlevel;
5209
5210         assert(argc >= 0);
5211         assert(argv);
5212
5213         if (utmp_get_runlevel(&runlevel, NULL) >= 0)
5214                 if (runlevel == '0' || runlevel == '6')
5215                         arg_force = 2;
5216
5217         while ((c = getopt_long(argc, argv, "pfwdnih", options, NULL)) >= 0) {
5218                 switch (c) {
5219
5220                 case ARG_HELP:
5221                         return halt_help();
5222
5223                 case ARG_HALT:
5224                         arg_action = ACTION_HALT;
5225                         break;
5226
5227                 case 'p':
5228                         if (arg_action != ACTION_REBOOT)
5229                                 arg_action = ACTION_POWEROFF;
5230                         break;
5231
5232                 case ARG_REBOOT:
5233                         arg_action = ACTION_REBOOT;
5234                         break;
5235
5236                 case 'f':
5237                         arg_force = 2;
5238                         break;
5239
5240                 case 'w':
5241                         arg_dry = true;
5242                         break;
5243
5244                 case 'd':
5245                         arg_no_wtmp = true;
5246                         break;
5247
5248                 case ARG_NO_WALL:
5249                         arg_no_wall = true;
5250                         break;
5251
5252                 case 'i':
5253                 case 'h':
5254                 case 'n':
5255                         /* Compatibility nops */
5256                         break;
5257
5258                 case '?':
5259                         return -EINVAL;
5260
5261                 default:
5262                         assert_not_reached("Unhandled option");
5263                 }
5264         }
5265
5266         if (arg_action == ACTION_REBOOT && argc == optind + 1) {
5267                 r = write_string_file(REBOOT_PARAM_FILE, argv[optind]);
5268                 if (r < 0) {
5269                         log_error("Failed to write reboot param to "
5270                                   REBOOT_PARAM_FILE": %s", strerror(-r));
5271                         return r;
5272                 }
5273         } else if (optind < argc) {
5274                 log_error("Too many arguments.");
5275                 return -EINVAL;
5276         }
5277
5278         return 1;
5279 }
5280
5281 static int parse_time_spec(const char *t, usec_t *_u) {
5282         assert(t);
5283         assert(_u);
5284
5285         if (streq(t, "now"))
5286                 *_u = 0;
5287         else if (!strchr(t, ':')) {
5288                 uint64_t u;
5289
5290                 if (safe_atou64(t, &u) < 0)
5291                         return -EINVAL;
5292
5293                 *_u = now(CLOCK_REALTIME) + USEC_PER_MINUTE * u;
5294         } else {
5295                 char *e = NULL;
5296                 long hour, minute;
5297                 struct tm tm = {};
5298                 time_t s;
5299                 usec_t n;
5300
5301                 errno = 0;
5302                 hour = strtol(t, &e, 10);
5303                 if (errno > 0 || *e != ':' || hour < 0 || hour > 23)
5304                         return -EINVAL;
5305
5306                 minute = strtol(e+1, &e, 10);
5307                 if (errno > 0 || *e != 0 || minute < 0 || minute > 59)
5308                         return -EINVAL;
5309
5310                 n = now(CLOCK_REALTIME);
5311                 s = (time_t) (n / USEC_PER_SEC);
5312
5313                 assert_se(localtime_r(&s, &tm));
5314
5315                 tm.tm_hour = (int) hour;
5316                 tm.tm_min = (int) minute;
5317                 tm.tm_sec = 0;
5318
5319                 assert_se(s = mktime(&tm));
5320
5321                 *_u = (usec_t) s * USEC_PER_SEC;
5322
5323                 while (*_u <= n)
5324                         *_u += USEC_PER_DAY;
5325         }
5326
5327         return 0;
5328 }
5329
5330 static int shutdown_parse_argv(int argc, char *argv[]) {
5331
5332         enum {
5333                 ARG_HELP = 0x100,
5334                 ARG_NO_WALL
5335         };
5336
5337         static const struct option options[] = {
5338                 { "help",      no_argument,       NULL, ARG_HELP    },
5339                 { "halt",      no_argument,       NULL, 'H'         },
5340                 { "poweroff",  no_argument,       NULL, 'P'         },
5341                 { "reboot",    no_argument,       NULL, 'r'         },
5342                 { "kexec",     no_argument,       NULL, 'K'         }, /* not documented extension */
5343                 { "no-wall",   no_argument,       NULL, ARG_NO_WALL },
5344                 {}
5345         };
5346
5347         int c, r;
5348
5349         assert(argc >= 0);
5350         assert(argv);
5351
5352         while ((c = getopt_long(argc, argv, "HPrhkt:afFc", options, NULL)) >= 0) {
5353                 switch (c) {
5354
5355                 case ARG_HELP:
5356                         return shutdown_help();
5357
5358                 case 'H':
5359                         arg_action = ACTION_HALT;
5360                         break;
5361
5362                 case 'P':
5363                         arg_action = ACTION_POWEROFF;
5364                         break;
5365
5366                 case 'r':
5367                         if (kexec_loaded())
5368                                 arg_action = ACTION_KEXEC;
5369                         else
5370                                 arg_action = ACTION_REBOOT;
5371                         break;
5372
5373                 case 'K':
5374                         arg_action = ACTION_KEXEC;
5375                         break;
5376
5377                 case 'h':
5378                         if (arg_action != ACTION_HALT)
5379                                 arg_action = ACTION_POWEROFF;
5380                         break;
5381
5382                 case 'k':
5383                         arg_dry = true;
5384                         break;
5385
5386                 case ARG_NO_WALL:
5387                         arg_no_wall = true;
5388                         break;
5389
5390                 case 't':
5391                 case 'a':
5392                         /* Compatibility nops */
5393                         break;
5394
5395                 case 'c':
5396                         arg_action = ACTION_CANCEL_SHUTDOWN;
5397                         break;
5398
5399                 case '?':
5400                         return -EINVAL;
5401
5402                 default:
5403                         assert_not_reached("Unhandled option");
5404                 }
5405         }
5406
5407         if (argc > optind && arg_action != ACTION_CANCEL_SHUTDOWN) {
5408                 r = parse_time_spec(argv[optind], &arg_when);
5409                 if (r < 0) {
5410                         log_error("Failed to parse time specification: %s", argv[optind]);
5411                         return r;
5412                 }
5413         } else
5414                 arg_when = now(CLOCK_REALTIME) + USEC_PER_MINUTE;
5415
5416         if (argc > optind && arg_action == ACTION_CANCEL_SHUTDOWN)
5417                 /* No time argument for shutdown cancel */
5418                 arg_wall = argv + optind;
5419         else if (argc > optind + 1)
5420                 /* We skip the time argument */
5421                 arg_wall = argv + optind + 1;
5422
5423         optind = argc;
5424
5425         return 1;
5426 }
5427
5428 static int telinit_parse_argv(int argc, char *argv[]) {
5429
5430         enum {
5431                 ARG_HELP = 0x100,
5432                 ARG_NO_WALL
5433         };
5434
5435         static const struct option options[] = {
5436                 { "help",      no_argument,       NULL, ARG_HELP    },
5437                 { "no-wall",   no_argument,       NULL, ARG_NO_WALL },
5438                 {}
5439         };
5440
5441         static const struct {
5442                 char from;
5443                 enum action to;
5444         } table[] = {
5445                 { '0', ACTION_POWEROFF },
5446                 { '6', ACTION_REBOOT },
5447                 { '1', ACTION_RESCUE },
5448                 { '2', ACTION_RUNLEVEL2 },
5449                 { '3', ACTION_RUNLEVEL3 },
5450                 { '4', ACTION_RUNLEVEL4 },
5451                 { '5', ACTION_RUNLEVEL5 },
5452                 { 's', ACTION_RESCUE },
5453                 { 'S', ACTION_RESCUE },
5454                 { 'q', ACTION_RELOAD },
5455                 { 'Q', ACTION_RELOAD },
5456                 { 'u', ACTION_REEXEC },
5457                 { 'U', ACTION_REEXEC }
5458         };
5459
5460         unsigned i;
5461         int c;
5462
5463         assert(argc >= 0);
5464         assert(argv);
5465
5466         while ((c = getopt_long(argc, argv, "", options, NULL)) >= 0) {
5467                 switch (c) {
5468
5469                 case ARG_HELP:
5470                         return telinit_help();
5471
5472                 case ARG_NO_WALL:
5473                         arg_no_wall = true;
5474                         break;
5475
5476                 case '?':
5477                         return -EINVAL;
5478
5479                 default:
5480                         assert_not_reached("Unhandled option");
5481                 }
5482         }
5483
5484         if (optind >= argc) {
5485                 telinit_help();
5486                 return -EINVAL;
5487         }
5488
5489         if (optind + 1 < argc) {
5490                 log_error("Too many arguments.");
5491                 return -EINVAL;
5492         }
5493
5494         if (strlen(argv[optind]) != 1) {
5495                 log_error("Expected single character argument.");
5496                 return -EINVAL;
5497         }
5498
5499         for (i = 0; i < ELEMENTSOF(table); i++)
5500                 if (table[i].from == argv[optind][0])
5501                         break;
5502
5503         if (i >= ELEMENTSOF(table)) {
5504                 log_error("Unknown command '%s'.", argv[optind]);
5505                 return -EINVAL;
5506         }
5507
5508         arg_action = table[i].to;
5509
5510         optind ++;
5511
5512         return 1;
5513 }
5514
5515 static int runlevel_parse_argv(int argc, char *argv[]) {
5516
5517         enum {
5518                 ARG_HELP = 0x100,
5519         };
5520
5521         static const struct option options[] = {
5522                 { "help",      no_argument,       NULL, ARG_HELP    },
5523                 {}
5524         };
5525
5526         int c;
5527
5528         assert(argc >= 0);
5529         assert(argv);
5530
5531         while ((c = getopt_long(argc, argv, "", options, NULL)) >= 0) {
5532                 switch (c) {
5533
5534                 case ARG_HELP:
5535                         return runlevel_help();
5536                         return 0;
5537
5538                 case '?':
5539                         return -EINVAL;
5540
5541                 default:
5542                         assert_not_reached("Unhandled option");
5543                 }
5544         }
5545
5546         if (optind < argc) {
5547                 log_error("Too many arguments.");
5548                 return -EINVAL;
5549         }
5550
5551         return 1;
5552 }
5553
5554 static int parse_argv(int argc, char *argv[]) {
5555         assert(argc >= 0);
5556         assert(argv);
5557
5558         if (program_invocation_short_name) {
5559
5560                 if (strstr(program_invocation_short_name, "halt")) {
5561                         arg_action = ACTION_HALT;
5562                         return halt_parse_argv(argc, argv);
5563                 } else if (strstr(program_invocation_short_name, "poweroff")) {
5564                         arg_action = ACTION_POWEROFF;
5565                         return halt_parse_argv(argc, argv);
5566                 } else if (strstr(program_invocation_short_name, "reboot")) {
5567                         if (kexec_loaded())
5568                                 arg_action = ACTION_KEXEC;
5569                         else
5570                                 arg_action = ACTION_REBOOT;
5571                         return halt_parse_argv(argc, argv);
5572                 } else if (strstr(program_invocation_short_name, "shutdown")) {
5573                         arg_action = ACTION_POWEROFF;
5574                         return shutdown_parse_argv(argc, argv);
5575                 } else if (strstr(program_invocation_short_name, "init")) {
5576
5577                         if (sd_booted() > 0) {
5578                                 arg_action = _ACTION_INVALID;
5579                                 return telinit_parse_argv(argc, argv);
5580                         } else {
5581                                 /* Hmm, so some other init system is
5582                                  * running, we need to forward this
5583                                  * request to it. For now we simply
5584                                  * guess that it is Upstart. */
5585
5586                                 execv(TELINIT, argv);
5587
5588                                 log_error("Couldn't find an alternative telinit implementation to spawn.");
5589                                 return -EIO;
5590                         }
5591
5592                 } else if (strstr(program_invocation_short_name, "runlevel")) {
5593                         arg_action = ACTION_RUNLEVEL;
5594                         return runlevel_parse_argv(argc, argv);
5595                 }
5596         }
5597
5598         arg_action = ACTION_SYSTEMCTL;
5599         return systemctl_parse_argv(argc, argv);
5600 }
5601
5602 _pure_ static int action_to_runlevel(void) {
5603
5604         static const char table[_ACTION_MAX] = {
5605                 [ACTION_HALT] =      '0',
5606                 [ACTION_POWEROFF] =  '0',
5607                 [ACTION_REBOOT] =    '6',
5608                 [ACTION_RUNLEVEL2] = '2',
5609                 [ACTION_RUNLEVEL3] = '3',
5610                 [ACTION_RUNLEVEL4] = '4',
5611                 [ACTION_RUNLEVEL5] = '5',
5612                 [ACTION_RESCUE] =    '1'
5613         };
5614
5615         assert(arg_action < _ACTION_MAX);
5616
5617         return table[arg_action];
5618 }
5619
5620 static int talk_initctl(void) {
5621
5622         struct init_request request = {
5623                 .magic = INIT_MAGIC,
5624                 .sleeptime  = 0,
5625                 .cmd = INIT_CMD_RUNLVL
5626         };
5627
5628         _cleanup_close_ int fd = -1;
5629         char rl;
5630         int r;
5631
5632         rl = action_to_runlevel();
5633         if (!rl)
5634                 return 0;
5635
5636         request.runlevel = rl;
5637
5638         fd = open(INIT_FIFO, O_WRONLY|O_NDELAY|O_CLOEXEC|O_NOCTTY);
5639         if (fd < 0) {
5640                 if (errno == ENOENT)
5641                         return 0;
5642
5643                 log_error("Failed to open "INIT_FIFO": %m");
5644                 return -errno;
5645         }
5646
5647         errno = 0;
5648         r = loop_write(fd, &request, sizeof(request), false) != sizeof(request);
5649         if (r) {
5650                 log_error("Failed to write to "INIT_FIFO": %m");
5651                 return errno > 0 ? -errno : -EIO;
5652         }
5653
5654         return 1;
5655 }
5656
5657 static int systemctl_main(sd_bus *bus, int argc, char *argv[], int bus_error) {
5658
5659         static const struct {
5660                 const char* verb;
5661                 const enum {
5662                         MORE,
5663                         LESS,
5664                         EQUAL
5665                 } argc_cmp;
5666                 const int argc;
5667                 int (* const dispatch)(sd_bus *bus, char **args);
5668         } verbs[] = {
5669                 { "list-units",            LESS,  1, list_units        },
5670                 { "list-unit-files",       EQUAL, 1, list_unit_files   },
5671                 { "list-sockets",          LESS,  1, list_sockets      },
5672                 { "list-timers",           LESS,  1, list_timers       },
5673                 { "list-jobs",             EQUAL, 1, list_jobs         },
5674                 { "clear-jobs",            EQUAL, 1, daemon_reload     },
5675                 { "cancel",                MORE,  2, cancel_job        },
5676                 { "start",                 MORE,  2, start_unit        },
5677                 { "stop",                  MORE,  2, start_unit        },
5678                 { "condstop",              MORE,  2, start_unit        }, /* For compatibility with ALTLinux */
5679                 { "reload",                MORE,  2, start_unit        },
5680                 { "restart",               MORE,  2, start_unit        },
5681                 { "try-restart",           MORE,  2, start_unit        },
5682                 { "reload-or-restart",     MORE,  2, start_unit        },
5683                 { "reload-or-try-restart", MORE,  2, start_unit        },
5684                 { "force-reload",          MORE,  2, start_unit        }, /* For compatibility with SysV */
5685                 { "condreload",            MORE,  2, start_unit        }, /* For compatibility with ALTLinux */
5686                 { "condrestart",           MORE,  2, start_unit        }, /* For compatibility with RH */
5687                 { "isolate",               EQUAL, 2, start_unit        },
5688                 { "kill",                  MORE,  2, kill_unit         },
5689                 { "is-active",             MORE,  2, check_unit_active },
5690                 { "check",                 MORE,  2, check_unit_active },
5691                 { "is-failed",             MORE,  2, check_unit_failed },
5692                 { "show",                  MORE,  1, show              },
5693                 { "status",                MORE,  1, show              },
5694                 { "help",                  MORE,  2, show              },
5695                 { "snapshot",              LESS,  2, snapshot          },
5696                 { "delete",                MORE,  2, delete_snapshot   },
5697                 { "daemon-reload",         EQUAL, 1, daemon_reload     },
5698                 { "daemon-reexec",         EQUAL, 1, daemon_reload     },
5699                 { "show-environment",      EQUAL, 1, show_environment  },
5700                 { "set-environment",       MORE,  2, set_environment   },
5701                 { "unset-environment",     MORE,  2, set_environment   },
5702                 { "halt",                  EQUAL, 1, start_special     },
5703                 { "poweroff",              EQUAL, 1, start_special     },
5704                 { "reboot",                EQUAL, 1, start_special     },
5705                 { "kexec",                 EQUAL, 1, start_special     },
5706                 { "suspend",               EQUAL, 1, start_special     },
5707                 { "hibernate",             EQUAL, 1, start_special     },
5708                 { "hybrid-sleep",          EQUAL, 1, start_special     },
5709                 { "default",               EQUAL, 1, start_special     },
5710                 { "rescue",                EQUAL, 1, start_special     },
5711                 { "emergency",             EQUAL, 1, start_special     },
5712                 { "exit",                  EQUAL, 1, start_special     },
5713                 { "reset-failed",          MORE,  1, reset_failed      },
5714                 { "enable",                MORE,  2, enable_unit       },
5715                 { "disable",               MORE,  2, enable_unit       },
5716                 { "is-enabled",            MORE,  2, unit_is_enabled   },
5717                 { "reenable",              MORE,  2, enable_unit       },
5718                 { "preset",                MORE,  2, enable_unit       },
5719                 { "mask",                  MORE,  2, enable_unit       },
5720                 { "unmask",                MORE,  2, enable_unit       },
5721                 { "link",                  MORE,  2, enable_unit       },
5722                 { "switch-root",           MORE,  2, switch_root       },
5723                 { "list-dependencies",     LESS,  2, list_dependencies },
5724                 { "set-default",           EQUAL, 2, set_default       },
5725                 { "get-default",           EQUAL, 1, get_default       },
5726                 { "set-property",          MORE,  3, set_property      },
5727         };
5728
5729         int left;
5730         unsigned i;
5731
5732         assert(argc >= 0);
5733         assert(argv);
5734
5735         left = argc - optind;
5736
5737         if (left <= 0)
5738                 /* Special rule: no arguments means "list-units" */
5739                 i = 0;
5740         else {
5741                 if (streq(argv[optind], "help") && !argv[optind+1]) {
5742                         log_error("This command expects one or more "
5743                                   "unit names. Did you mean --help?");
5744                         return -EINVAL;
5745                 }
5746
5747                 for (i = 0; i < ELEMENTSOF(verbs); i++)
5748                         if (streq(argv[optind], verbs[i].verb))
5749                                 break;
5750
5751                 if (i >= ELEMENTSOF(verbs)) {
5752                         log_error("Unknown operation '%s'.", argv[optind]);
5753                         return -EINVAL;
5754                 }
5755         }
5756
5757         switch (verbs[i].argc_cmp) {
5758
5759         case EQUAL:
5760                 if (left != verbs[i].argc) {
5761                         log_error("Invalid number of arguments.");
5762                         return -EINVAL;
5763                 }
5764
5765                 break;
5766
5767         case MORE:
5768                 if (left < verbs[i].argc) {
5769                         log_error("Too few arguments.");
5770                         return -EINVAL;
5771                 }
5772
5773                 break;
5774
5775         case LESS:
5776                 if (left > verbs[i].argc) {
5777                         log_error("Too many arguments.");
5778                         return -EINVAL;
5779                 }
5780
5781                 break;
5782
5783         default:
5784                 assert_not_reached("Unknown comparison operator.");
5785         }
5786
5787         /* Require a bus connection for all operations but
5788          * enable/disable */
5789         if (!streq(verbs[i].verb, "enable") &&
5790             !streq(verbs[i].verb, "disable") &&
5791             !streq(verbs[i].verb, "is-enabled") &&
5792             !streq(verbs[i].verb, "list-unit-files") &&
5793             !streq(verbs[i].verb, "reenable") &&
5794             !streq(verbs[i].verb, "preset") &&
5795             !streq(verbs[i].verb, "mask") &&
5796             !streq(verbs[i].verb, "unmask") &&
5797             !streq(verbs[i].verb, "link") &&
5798             !streq(verbs[i].verb, "set-default") &&
5799             !streq(verbs[i].verb, "get-default")) {
5800
5801                 if (running_in_chroot() > 0) {
5802                         log_info("Running in chroot, ignoring request.");
5803                         return 0;
5804                 }
5805
5806                 if (((!streq(verbs[i].verb, "reboot") &&
5807                       !streq(verbs[i].verb, "halt") &&
5808                       !streq(verbs[i].verb, "poweroff")) || arg_force <= 0) && !bus) {
5809                         log_error("Failed to get D-Bus connection: %s", strerror (-bus_error));
5810                         return -EIO;
5811                 }
5812
5813         } else {
5814
5815                 if (!bus && !avoid_bus()) {
5816                         log_error("Failed to get D-Bus connection: %s", strerror (-bus_error));
5817                         return -EIO;
5818                 }
5819         }
5820
5821         return verbs[i].dispatch(bus, argv + optind);
5822 }
5823
5824 static int send_shutdownd(usec_t t, char mode, bool dry_run, bool warn, const char *message) {
5825
5826         struct sd_shutdown_command c = {
5827                 .usec = t,
5828                 .mode = mode,
5829                 .dry_run = dry_run,
5830                 .warn_wall = warn,
5831         };
5832
5833         union sockaddr_union sockaddr = {
5834                 .un.sun_family = AF_UNIX,
5835                 .un.sun_path = "/run/systemd/shutdownd",
5836         };
5837
5838         struct iovec iovec[2] = {{
5839                  .iov_base = (char*) &c,
5840                  .iov_len = offsetof(struct sd_shutdown_command, wall_message),
5841         }};
5842
5843         struct msghdr msghdr = {
5844                 .msg_name = &sockaddr,
5845                 .msg_namelen = offsetof(struct sockaddr_un, sun_path)
5846                                + sizeof("/run/systemd/shutdownd") - 1,
5847                 .msg_iov = iovec,
5848                 .msg_iovlen = 1,
5849         };
5850
5851         _cleanup_close_ int fd;
5852
5853         fd = socket(AF_UNIX, SOCK_DGRAM|SOCK_CLOEXEC, 0);
5854         if (fd < 0)
5855                 return -errno;
5856
5857         if (!isempty(message)) {
5858                 iovec[1].iov_base = (char*) message;
5859                 iovec[1].iov_len = strlen(message);
5860                 msghdr.msg_iovlen++;
5861         }
5862
5863         if (sendmsg(fd, &msghdr, MSG_NOSIGNAL) < 0)
5864                 return -errno;
5865
5866         return 0;
5867 }
5868
5869 static int reload_with_fallback(sd_bus *bus) {
5870
5871         if (bus) {
5872                 /* First, try systemd via D-Bus. */
5873                 if (daemon_reload(bus, NULL) >= 0)
5874                         return 0;
5875         }
5876
5877         /* Nothing else worked, so let's try signals */
5878         assert(arg_action == ACTION_RELOAD || arg_action == ACTION_REEXEC);
5879
5880         if (kill(1, arg_action == ACTION_RELOAD ? SIGHUP : SIGTERM) < 0) {
5881                 log_error("kill() failed: %m");
5882                 return -errno;
5883         }
5884
5885         return 0;
5886 }
5887
5888 static int start_with_fallback(sd_bus *bus) {
5889
5890         if (bus) {
5891                 /* First, try systemd via D-Bus. */
5892                 if (start_unit(bus, NULL) >= 0)
5893                         goto done;
5894         }
5895
5896         /* Nothing else worked, so let's try
5897          * /dev/initctl */
5898         if (talk_initctl() > 0)
5899                 goto done;
5900
5901         log_error("Failed to talk to init daemon.");
5902         return -EIO;
5903
5904 done:
5905         warn_wall(arg_action);
5906         return 0;
5907 }
5908
5909 static int halt_now(enum action a) {
5910
5911 /* Make sure C-A-D is handled by the kernel from this
5912          * point on... */
5913         reboot(RB_ENABLE_CAD);
5914
5915         switch (a) {
5916
5917         case ACTION_HALT:
5918                 log_info("Halting.");
5919                 reboot(RB_HALT_SYSTEM);
5920                 return -errno;
5921
5922         case ACTION_POWEROFF:
5923                 log_info("Powering off.");
5924                 reboot(RB_POWER_OFF);
5925                 return -errno;
5926
5927         case ACTION_REBOOT: {
5928                 _cleanup_free_ char *param = NULL;
5929
5930                 if (read_one_line_file(REBOOT_PARAM_FILE, &param) >= 0) {
5931                         log_info("Rebooting with argument '%s'.", param);
5932                         syscall(SYS_reboot, LINUX_REBOOT_MAGIC1, LINUX_REBOOT_MAGIC2,
5933                                 LINUX_REBOOT_CMD_RESTART2, param);
5934                 }
5935
5936                 log_info("Rebooting.");
5937                 reboot(RB_AUTOBOOT);
5938                 return -errno;
5939         }
5940
5941         default:
5942                 assert_not_reached("Unknown action.");
5943         }
5944 }
5945
5946 static int halt_main(sd_bus *bus) {
5947         int r;
5948
5949         r = check_inhibitors(bus, arg_action);
5950         if (r < 0)
5951                 return r;
5952
5953         if (geteuid() != 0) {
5954                 /* Try logind if we are a normal user and no special
5955                  * mode applies. Maybe PolicyKit allows us to shutdown
5956                  * the machine. */
5957
5958                 if (arg_when <= 0 &&
5959                     !arg_dry &&
5960                     arg_force <= 0 &&
5961                     (arg_action == ACTION_POWEROFF ||
5962                      arg_action == ACTION_REBOOT)) {
5963                         r = reboot_with_logind(bus, arg_action);
5964                         if (r >= 0)
5965                                 return r;
5966                 }
5967
5968                 log_error("Must be root.");
5969                 return -EPERM;
5970         }
5971
5972         if (arg_when > 0) {
5973                 _cleanup_free_ char *m;
5974
5975                 m = strv_join(arg_wall, " ");
5976                 if (!m)
5977                         return log_oom();
5978
5979                 r = send_shutdownd(arg_when,
5980                                    arg_action == ACTION_HALT     ? 'H' :
5981                                    arg_action == ACTION_POWEROFF ? 'P' :
5982                                    arg_action == ACTION_KEXEC    ? 'K' :
5983                                                                    'r',
5984                                    arg_dry,
5985                                    !arg_no_wall,
5986                                    m);
5987
5988                 if (r < 0)
5989                         log_warning("Failed to talk to shutdownd, proceeding with immediate shutdown: %s", strerror(-r));
5990                 else {
5991                         char date[FORMAT_TIMESTAMP_MAX];
5992
5993                         log_info("Shutdown scheduled for %s, use 'shutdown -c' to cancel.",
5994                                  format_timestamp(date, sizeof(date), arg_when));
5995                         return 0;
5996                 }
5997         }
5998
5999         if (!arg_dry && !arg_force)
6000                 return start_with_fallback(bus);
6001
6002         if (!arg_no_wtmp) {
6003                 if (sd_booted() > 0)
6004                         log_debug("Not writing utmp record, assuming that systemd-update-utmp is used.");
6005                 else {
6006                         r = utmp_put_shutdown();
6007                         if (r < 0)
6008                                 log_warning("Failed to write utmp record: %s", strerror(-r));
6009                 }
6010         }
6011
6012         if (arg_dry)
6013                 return 0;
6014
6015         r = halt_now(arg_action);
6016         log_error("Failed to reboot: %s", strerror(-r));
6017
6018         return r;
6019 }
6020
6021 static int runlevel_main(void) {
6022         int r, runlevel, previous;
6023
6024         r = utmp_get_runlevel(&runlevel, &previous);
6025         if (r < 0) {
6026                 puts("unknown");
6027                 return r;
6028         }
6029
6030         printf("%c %c\n",
6031                previous <= 0 ? 'N' : previous,
6032                runlevel <= 0 ? 'N' : runlevel);
6033
6034         return 0;
6035 }
6036
6037 int main(int argc, char*argv[]) {
6038         _cleanup_bus_unref_ sd_bus *bus = NULL;
6039         int r;
6040
6041         setlocale(LC_ALL, "");
6042         log_parse_environment();
6043         log_open();
6044
6045         /* Explicitly not on_tty() to avoid setting cached value.
6046          * This becomes relevant for piping output which might be
6047          * ellipsized. */
6048         original_stdout_is_tty = isatty(STDOUT_FILENO);
6049
6050         r = parse_argv(argc, argv);
6051         if (r <= 0)
6052                 goto finish;
6053
6054         /* /sbin/runlevel doesn't need to communicate via D-Bus, so
6055          * let's shortcut this */
6056         if (arg_action == ACTION_RUNLEVEL) {
6057                 r = runlevel_main();
6058                 goto finish;
6059         }
6060
6061         if (running_in_chroot() > 0 && arg_action != ACTION_SYSTEMCTL) {
6062                 log_info("Running in chroot, ignoring request.");
6063                 r = 0;
6064                 goto finish;
6065         }
6066
6067         if (!avoid_bus())
6068                 r = bus_open_transport_systemd(arg_transport, arg_host, arg_scope != UNIT_FILE_SYSTEM, &bus);
6069
6070         /* systemctl_main() will print an error message for the bus
6071          * connection, but only if it needs to */
6072
6073         switch (arg_action) {
6074
6075         case ACTION_SYSTEMCTL:
6076                 r = systemctl_main(bus, argc, argv, r);
6077                 break;
6078
6079         case ACTION_HALT:
6080         case ACTION_POWEROFF:
6081         case ACTION_REBOOT:
6082         case ACTION_KEXEC:
6083                 r = halt_main(bus);
6084                 break;
6085
6086         case ACTION_RUNLEVEL2:
6087         case ACTION_RUNLEVEL3:
6088         case ACTION_RUNLEVEL4:
6089         case ACTION_RUNLEVEL5:
6090         case ACTION_RESCUE:
6091         case ACTION_EMERGENCY:
6092         case ACTION_DEFAULT:
6093                 r = start_with_fallback(bus);
6094                 break;
6095
6096         case ACTION_RELOAD:
6097         case ACTION_REEXEC:
6098                 r = reload_with_fallback(bus);
6099                 break;
6100
6101         case ACTION_CANCEL_SHUTDOWN: {
6102                 _cleanup_free_ char *m = NULL;
6103
6104                 if (arg_wall) {
6105                         m = strv_join(arg_wall, " ");
6106                         if (!m) {
6107                                 r = log_oom();
6108                                 goto finish;
6109                         }
6110                 }
6111
6112                 r = send_shutdownd(arg_when, SD_SHUTDOWN_NONE, false, !arg_no_wall, m);
6113                 if (r < 0)
6114                         log_warning("Failed to talk to shutdownd, shutdown hasn't been cancelled: %s", strerror(-r));
6115                 break;
6116         }
6117
6118         case ACTION_RUNLEVEL:
6119         case _ACTION_INVALID:
6120         default:
6121                 assert_not_reached("Unknown action");
6122         }
6123
6124 finish:
6125         pager_close();
6126         ask_password_agent_close();
6127         polkit_agent_close();
6128
6129         strv_free(arg_types);
6130         strv_free(arg_states);
6131         strv_free(arg_properties);
6132
6133         return r < 0 ? EXIT_FAILURE : r;
6134 }