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