#include <sys/reboot.h>

#include <linux/reboot.h>

#include <sys/syscall.h>

#include <stdio.h>

#include <getopt.h>

#include <locale.h>

#include <stdbool.h>

#include <string.h>

#include <errno.h>

#include <sys/ioctl.h>

#include <termios.h>

#include <unistd.h>

#include <fcntl.h>

#include <sys/socket.h>

#include <sys/stat.h>

#include <stddef.h>

#include <sys/prctl.h>

#include <fnmatch.h>

#include "sd-daemon.h"

#include "sd-shutdown.h"

#include "sd-login.h"

#include "sd-bus.h"

#include "log.h"

#include "util.h"

#include "macro.h"

#include "set.h"

#include "utmp-wtmp.h"

#include "special.h"

#include "initreq.h"

#include "path-util.h"

#include "strv.h"

#include "cgroup-show.h"

#include "cgroup-util.h"

#include "list.h"

#include "path-lookup.h"

#include "conf-parser.h"

#include "exit-status.h"

#include "bus-errors.h"

#include "build.h"

#include "unit-name.h"

#include "pager.h"

#include "spawn-ask-password-agent.h"

#include "spawn-polkit-agent.h"

#include "install.h"

#include "logs-show.h"

#include "socket-util.h"

#include "fileio.h"

#include "bus-util.h"

#include "bus-message.h"

#include "bus-error.h"

#include "bus-errors.h"

static char **arg_types = NULL;

static char **arg_states = NULL;

static char **arg_properties = NULL;

static bool arg_all = false;

static bool original_stdout_is_tty;

static enum dependency {

DEPENDENCY_FORWARD,

DEPENDENCY_REVERSE,

DEPENDENCY_AFTER,

DEPENDENCY_BEFORE,

_DEPENDENCY_MAX

} arg_dependency = DEPENDENCY_FORWARD;

static const char *arg_job_mode = "replace";

static UnitFileScope arg_scope = UNIT_FILE_SYSTEM;

static bool arg_no_block = false;

static bool arg_no_legend = false;

static bool arg_no_pager = false;

static bool arg_no_wtmp = false;

static bool arg_no_wall = false;

static bool arg_no_reload = false;

static bool arg_show_types = false;

static bool arg_ignore_inhibitors = false;

static bool arg_dry = false;

static bool arg_quiet = false;

static bool arg_full = false;

static int arg_force = 0;

static bool arg_ask_password = true;

static bool arg_runtime = false;

static char **arg_wall = NULL;

static const char *arg_kill_who = NULL;

static int arg_signal = SIGTERM;

static const char *arg_root = NULL;

static usec_t arg_when = 0;

static enum action {

_ACTION_INVALID,

ACTION_SYSTEMCTL,

ACTION_HALT,

ACTION_POWEROFF,

ACTION_REBOOT,

ACTION_KEXEC,

ACTION_EXIT,

ACTION_SUSPEND,

ACTION_HIBERNATE,

ACTION_HYBRID_SLEEP,

ACTION_RUNLEVEL2,

ACTION_RUNLEVEL3,

ACTION_RUNLEVEL4,

ACTION_RUNLEVEL5,

ACTION_RESCUE,

ACTION_EMERGENCY,

ACTION_DEFAULT,

ACTION_RELOAD,

ACTION_REEXEC,

ACTION_RUNLEVEL,

ACTION_CANCEL_SHUTDOWN,

_ACTION_MAX

} arg_action = ACTION_SYSTEMCTL;

static BusTransport arg_transport = BUS_TRANSPORT_LOCAL;

static char *arg_host = NULL;

static unsigned arg_lines = 10;

static OutputMode arg_output = OUTPUT_SHORT;

static bool arg_plain = false;

static int daemon_reload(sd_bus *bus, char **args);

static int halt_now(enum action a);

static int check_one_unit(sd_bus *bus, const char *name, const char *good_states, bool quiet);

static char** strv_skip_first(char **strv) {

if (strv_length(strv) > 0)

return strv + 1;

return NULL;

}

static void pager_open_if_enabled(void) {

if (arg_no_pager)

return;

pager_open(false);

}

static void ask_password_agent_open_if_enabled(void) {

/* Open the password agent as a child process if necessary */

if (!arg_ask_password)

return;

if (arg_scope != UNIT_FILE_SYSTEM)

return;

if (arg_transport != BUS_TRANSPORT_LOCAL)

return;

ask_password_agent_open();

}

#ifdef HAVE_LOGIND

static void polkit_agent_open_if_enabled(void) {

/* Open the polkit agent as a child process if necessary */

if (!arg_ask_password)

return;

if (arg_scope != UNIT_FILE_SYSTEM)

return;

if (arg_transport != BUS_TRANSPORT_LOCAL)

return;

polkit_agent_open();

}

#endif

static int translate_bus_error_to_exit_status(int r, const sd_bus_error *error) {

assert(error);

if (!sd_bus_error_is_set(error))

return r;

if (sd_bus_error_has_name(error, SD_BUS_ERROR_ACCESS_DENIED) ||

sd_bus_error_has_name(error, BUS_ERROR_ONLY_BY_DEPENDENCY) ||

sd_bus_error_has_name(error, BUS_ERROR_NO_ISOLATION) ||

sd_bus_error_has_name(error, BUS_ERROR_TRANSACTION_IS_DESTRUCTIVE))

return EXIT_NOPERMISSION;

if (sd_bus_error_has_name(error, BUS_ERROR_NO_SUCH_UNIT))

return EXIT_NOTINSTALLED;

if (sd_bus_error_has_name(error, BUS_ERROR_JOB_TYPE_NOT_APPLICABLE) ||

sd_bus_error_has_name(error, SD_BUS_ERROR_NOT_SUPPORTED))

return EXIT_NOTIMPLEMENTED;

if (sd_bus_error_has_name(error, BUS_ERROR_LOAD_FAILED))

return EXIT_NOTCONFIGURED;

if (r != 0)

return r;

return EXIT_FAILURE;

}

static void warn_wall(enum action a) {

static const char *table[_ACTION_MAX] = {

[ACTION_HALT] = "The system is going down for system halt NOW!",

[ACTION_REBOOT] = "The system is going down for reboot NOW!",

[ACTION_POWEROFF] = "The system is going down for power-off NOW!",

[ACTION_KEXEC] = "The system is going down for kexec reboot NOW!",

[ACTION_RESCUE] = "The system is going down to rescue mode NOW!",

[ACTION_EMERGENCY] = "The system is going down to emergency mode NOW!",

[ACTION_CANCEL_SHUTDOWN] = "The system shutdown has been cancelled NOW!"

};

if (arg_no_wall)

return;

if (arg_wall) {

_cleanup_free_ char *p;

p = strv_join(arg_wall, " ");

if (!p) {

log_oom();

return;

}

if (*p) {

utmp_wall(p, NULL);

return;

}

}

if (!table[a])

return;

utmp_wall(table[a], NULL);

}

static bool avoid_bus(void) {

if (running_in_chroot() > 0)

return true;

if (sd_booted() <= 0)

return true;

if (!isempty(arg_root))

return true;

if (arg_scope == UNIT_FILE_GLOBAL)

return true;

return false;

}

static int compare_unit_info(const void *a, const void *b) {

const UnitInfo *u = a, *v = b;

const char *d1, *d2;

d1 = strrchr(u->id, '.');

d2 = strrchr(v->id, '.');

if (d1 && d2) {

int r;

r = strcasecmp(d1, d2);

if (r != 0)

return r;

}

return strcasecmp(u->id, v->id);

}

static bool output_show_unit(const UnitInfo *u, char **patterns) {

const char *dot;

if (!strv_isempty(arg_states))

return

strv_contains(arg_states, u->load_state) ||

strv_contains(arg_states, u->sub_state) ||

strv_contains(arg_states, u->active_state);

if (!strv_isempty(patterns)) {

char **pattern;

STRV_FOREACH(pattern, patterns)

if (fnmatch(*pattern, u->id, FNM_NOESCAPE) == 0)

return true;

return false;

}

return (!arg_types || ((dot = strrchr(u->id, '.')) &&

strv_find(arg_types, dot+1))) &&

(arg_all || !(streq(u->active_state, "inactive")

|| u->following[0]) || u->job_id > 0);

}

static void output_units_list(const UnitInfo *unit_infos, unsigned c) {

unsigned id_len, max_id_len, load_len, active_len, sub_len, job_len, desc_len;

const UnitInfo *u;

unsigned n_shown = 0;

int job_count = 0;

max_id_len = sizeof("UNIT")-1;

load_len = sizeof("LOAD")-1;

active_len = sizeof("ACTIVE")-1;

sub_len = sizeof("SUB")-1;

job_len = sizeof("JOB")-1;

desc_len = 0;

for (u = unit_infos; u < unit_infos + c; u++) {

max_id_len = MAX(max_id_len, strlen(u->id));

load_len = MAX(load_len, strlen(u->load_state));

active_len = MAX(active_len, strlen(u->active_state));

sub_len = MAX(sub_len, strlen(u->sub_state));

if (u->job_id != 0) {

job_len = MAX(job_len, strlen(u->job_type));

job_count++;

}

}

if (!arg_full && original_stdout_is_tty) {

unsigned basic_len;

id_len = MIN(max_id_len, 25u);

basic_len = 5 + id_len + 5 + active_len + sub_len;

if (job_count)

basic_len += job_len + 1;

if (basic_len < (unsigned) columns()) {

unsigned extra_len, incr;

extra_len = columns() - basic_len;

/* Either UNIT already got 25, or is fully satisfied.

incr = MIN(extra_len, 25u);

desc_len += incr;

extra_len -= incr;

/* split the remaining space between UNIT and DESC,

if (extra_len > 0) {

incr = MIN(extra_len / 2, max_id_len - id_len);

id_len += incr;

desc_len += extra_len - incr;

}

}

} else

id_len = max_id_len;

for (u = unit_infos; u < unit_infos + c; u++) {

_cleanup_free_ char *e = NULL;

const char *on_loaded, *off_loaded, *on = "";

const char *on_active, *off_active, *off = "";

if (!n_shown && !arg_no_legend) {

printf("%-*s %-*s %-*s %-*s ",

id_len, "UNIT",

load_len, "LOAD",

active_len, "ACTIVE",

sub_len, "SUB");

if (job_count)

printf("%-*s ", job_len, "JOB");

if (!arg_full && arg_no_pager)

printf("%.*s\n", desc_len, "DESCRIPTION");

else

printf("%s\n", "DESCRIPTION");

}

n_shown++;

if (streq(u->load_state, "error") ||

streq(u->load_state, "not-found")) {

on_loaded = on = ansi_highlight_red();

off_loaded = off = ansi_highlight_off();

} else

on_loaded = off_loaded = "";

if (streq(u->active_state, "failed")) {

on_active = on = ansi_highlight_red();

off_active = off = ansi_highlight_off();

} else

on_active = off_active = "";

e = arg_full ? NULL : ellipsize(u->id, id_len, 33);

printf("%s%-*s%s %s%-*s%s %s%-*s %-*s%s %-*s",

on, id_len, e ? e : u->id, off,

on_loaded, load_len, u->load_state, off_loaded,

on_active, active_len, u->active_state,

sub_len, u->sub_state, off_active,

job_count ? job_len + 1 : 0, u->job_id ? u->job_type : "");

if (desc_len > 0)

printf("%.*s\n", desc_len, u->description);

else

printf("%s\n", u->description);

}

if (!arg_no_legend) {

const char *on, *off;

if (n_shown) {

printf("\nLOAD = Reflects whether the unit definition was properly loaded.\n"

"ACTIVE = The high-level unit activation state, i.e. generalization of SUB.\n"

"SUB = The low-level unit activation state, values depend on unit type.\n");

if (job_count)

printf("JOB = Pending job for the unit.\n");

puts("");

on = ansi_highlight();

off = ansi_highlight_off();

} else {

on = ansi_highlight_red();

off = ansi_highlight_off();

}

if (arg_all)

printf("%s%u loaded units listed.%s\n"

"To show all installed unit files use 'systemctl list-unit-files'.\n",

on, n_shown, off);

else

printf("%s%u loaded units listed.%s Pass --all to see loaded but inactive units, too.\n"

"To show all installed unit files use 'systemctl list-unit-files'.\n",

on, n_shown, off);

}

}

static int get_unit_list(

sd_bus *bus,

sd_bus_message **_reply,

UnitInfo **_unit_infos,

char **patterns) {

_cleanup_bus_error_free_ sd_bus_error error = SD_BUS_ERROR_NULL;

_cleanup_bus_message_unref_ sd_bus_message *reply = NULL;

_cleanup_free_ UnitInfo *unit_infos = NULL;

size_t size = 0;

int r, c = 0;

UnitInfo u;

assert(bus);

assert(_reply);

assert(_unit_infos);

r = sd_bus_call_method(

bus,

"org.freedesktop.systemd1",

"/org/freedesktop/systemd1",

"org.freedesktop.systemd1.Manager",

"ListUnits",

&error,

&reply,

NULL);

if (r < 0) {

log_error("Failed to list units: %s", bus_error_message(&error, r));

return r;

}

r = sd_bus_message_enter_container(reply, SD_BUS_TYPE_ARRAY, "(ssssssouso)");

if (r < 0)

return bus_log_parse_error(r);

while ((r = bus_parse_unit_info(reply, &u)) > 0) {

if (!output_show_unit(&u, patterns))

continue;

if (!GREEDY_REALLOC(unit_infos, size, c+1))

return log_oom();

unit_infos[c++] = u;

}

if (r < 0)

return bus_log_parse_error(r);

r = sd_bus_message_exit_container(reply);

if (r < 0)

return bus_log_parse_error(r);

*_reply = reply;

reply = NULL;

*_unit_infos = unit_infos;

unit_infos = NULL;

return c;

}

static int list_units(sd_bus *bus, char **args) {

_cleanup_bus_message_unref_ sd_bus_message *reply = NULL;

_cleanup_free_ UnitInfo *unit_infos = NULL;

int r;

pager_open_if_enabled();

r = get_unit_list(bus, &reply, &unit_infos, strv_skip_first(args));

if (r < 0)

return r;

qsort_safe(unit_infos, r, sizeof(UnitInfo), compare_unit_info);

output_units_list(unit_infos, r);

return 0;

}

static int get_triggered_units(

sd_bus *bus,

const char* path,

char*** ret) {

_cleanup_bus_error_free_ sd_bus_error error = SD_BUS_ERROR_NULL;

int r;

r = sd_bus_get_property_strv(

bus,

"org.freedesktop.systemd1",

path,

"org.freedesktop.systemd1.Unit",

"Triggers",

&error,

ret);

if (r < 0)

log_error("Failed to determine triggers: %s", bus_error_message(&error, r));

return 0;

}

static int get_listening(

sd_bus *bus,

const char* unit_path,

char*** listening) {

_cleanup_bus_error_free_ sd_bus_error error = SD_BUS_ERROR_NULL;

_cleanup_bus_message_unref_ sd_bus_message *reply = NULL;

const char *type, *path;

int r, n = 0;

r = sd_bus_get_property(

bus,

"org.freedesktop.systemd1",

unit_path,

"org.freedesktop.systemd1.Socket",

"Listen",

&error,

&reply,

"a(ss)");

if (r < 0) {

log_error("Failed to get list of listening sockets: %s", bus_error_message(&error, r));

return r;

}

r = sd_bus_message_enter_container(reply, SD_BUS_TYPE_ARRAY, "(ss)");

if (r < 0)

return bus_log_parse_error(r);

while ((r = sd_bus_message_read(reply, "(ss)", &type, &path)) > 0) {

r = strv_extend(listening, type);

if (r < 0)

return log_oom();

r = strv_extend(listening, path);

if (r < 0)

return log_oom();

n++;

}

if (r < 0)

return bus_log_parse_error(r);

r = sd_bus_message_exit_container(reply);

if (r < 0)

return bus_log_parse_error(r);

return n;

}

struct socket_info {

const char* id;

char* type;

char* path;

/* Note: triggered is a list here, although it almost certainly

char** triggered;

/* The strv above is shared. free is set only in the first one. */

bool own_triggered;

};

static int socket_info_compare(const struct socket_info *a, const struct socket_info *b) {

int o;

assert(a);

assert(b);

o = strcmp(a->path, b->path);

if (o == 0)

o = strcmp(a->type, b->type);

return o;

}

static int output_sockets_list(struct socket_info *socket_infos, unsigned cs) {

struct socket_info *s;

unsigned pathlen = sizeof("LISTEN") - 1,

typelen = (sizeof("TYPE") - 1) * arg_show_types,

socklen = sizeof("UNIT") - 1,

servlen = sizeof("ACTIVATES") - 1;

const char *on, *off;

for (s = socket_infos; s < socket_infos + cs; s++) {

unsigned tmp = 0;

char **a;

socklen = MAX(socklen, strlen(s->id));

if (arg_show_types)

typelen = MAX(typelen, strlen(s->type));

pathlen = MAX(pathlen, strlen(s->path));

STRV_FOREACH(a, s->triggered)

tmp += strlen(*a) + 2*(a != s->triggered);

servlen = MAX(servlen, tmp);

}

if (cs) {

if (!arg_no_legend)

printf("%-*s %-*.*s%-*s %s\n",

pathlen, "LISTEN",

typelen + arg_show_types, typelen + arg_show_types, "TYPE ",

socklen, "UNIT",

"ACTIVATES");

for (s = socket_infos; s < socket_infos + cs; s++) {

char **a;

if (arg_show_types)

printf("%-*s %-*s %-*s",

pathlen, s->path, typelen, s->type, socklen, s->id);

else

printf("%-*s %-*s",

pathlen, s->path, socklen, s->id);

STRV_FOREACH(a, s->triggered)

printf("%s %s",

a == s->triggered ? "" : ",", *a);

printf("\n");

}

on = ansi_highlight();

off = ansi_highlight_off();

if (!arg_no_legend)

printf("\n");

} else {

on = ansi_highlight_red();

off = ansi_highlight_off();

}

if (!arg_no_legend) {

printf("%s%u sockets listed.%s\n", on, cs, off);

if (!arg_all)

printf("Pass --all to see loaded but inactive sockets, too.\n");

}

return 0;

}

static int list_sockets(sd_bus *bus, char **args) {

_cleanup_bus_message_unref_ sd_bus_message *reply = NULL;

_cleanup_free_ UnitInfo *unit_infos = NULL;

_cleanup_free_ struct socket_info *socket_infos = NULL;

const UnitInfo *u;

struct socket_info *s;

unsigned cs = 0;

size_t size = 0;

int r = 0, n;

pager_open_if_enabled();

n = get_unit_list(bus, &reply, &unit_infos, strv_skip_first(args));

if (n < 0)

return n;

for (u = unit_infos; u < unit_infos + n; u++) {

_cleanup_strv_free_ char **listening = NULL, **triggered = NULL;

int i, c;

if (!endswith(u->id, ".socket"))

continue;

r = get_triggered_units(bus, u->unit_path, &triggered);

if (r < 0)

goto cleanup;

c = get_listening(bus, u->unit_path, &listening);

if (c < 0) {

r = c;

goto cleanup;

}

if (!GREEDY_REALLOC(socket_infos, size, cs + c)) {

r = log_oom();

goto cleanup;

}

for (i = 0; i < c; i++)

socket_infos[cs + i] = (struct socket_info) {

.id = u->id,

.type = listening[i*2],

.path = listening[i*2 + 1],

.triggered = triggered,

.own_triggered = i==0,

};

/* from this point on we will cleanup those socket_infos */

cs += c;

free(listening);

listening = triggered = NULL; /* avoid cleanup */

}

qsort_safe(socket_infos, cs, sizeof(struct socket_info),

(__compar_fn_t) socket_info_compare);

output_sockets_list(socket_infos, cs);

cleanup:

assert(cs == 0 || socket_infos);

for (s = socket_infos; s < socket_infos + cs; s++) {

free(s->type);

free(s->path);

if (s->own_triggered)

strv_free(s->triggered);

}

return r;

}

static int get_next_elapse(

sd_bus *bus,

const char *path,

dual_timestamp *next) {

_cleanup_bus_error_free_ sd_bus_error error = SD_BUS_ERROR_NULL;

dual_timestamp t;

int r;

assert(bus);

assert(path);

assert(next);

r = sd_bus_get_property_trivial(

bus,

"org.freedesktop.systemd1",

path,

"org.freedesktop.systemd1.Timer",

"NextElapseUSecMonotonic",

&error,

't',

&t.monotonic);

if (r < 0) {

log_error("Failed to get next elapsation time: %s", bus_error_message(&error, r));

return r;

}

r = sd_bus_get_property_trivial(

bus,

"org.freedesktop.systemd1",

path,

"org.freedesktop.systemd1.Timer",

"NextElapseUSecRealtime",

&error,

't',

&t.realtime);

if (r < 0) {

log_error("Failed to get next elapsation time: %s", bus_error_message(&error, r));

return r;

}

*next = t;

return 0;

}

struct timer_info {

const char* id;

usec_t next_elapse;

char** triggered;

};

static int timer_info_compare(const struct timer_info *a, const struct timer_info *b) {

assert(a);

assert(b);

if (a->next_elapse < b->next_elapse)

return -1;

if (a->next_elapse > b->next_elapse)

return 1;

return strcmp(a->id, b->id);

}

static int output_timers_list(struct timer_info *timer_infos, unsigned n) {

struct timer_info *t;

unsigned

nextlen = sizeof("NEXT") - 1,

leftlen = sizeof("LEFT") - 1,

unitlen = sizeof("UNIT") - 1,

activatelen = sizeof("ACTIVATES") - 1;

const char *on, *off;

assert(timer_infos || n == 0);

for (t = timer_infos; t < timer_infos + n; t++) {

unsigned ul = 0;

char **a;

if (t->next_elapse > 0) {

char tstamp[FORMAT_TIMESTAMP_MAX] = "", trel[FORMAT_TIMESTAMP_RELATIVE_MAX] = "";

format_timestamp(tstamp, sizeof(tstamp), t->next_elapse);

nextlen = MAX(nextlen, strlen(tstamp) + 1);

format_timestamp_relative(trel, sizeof(trel), t->next_elapse);

leftlen = MAX(leftlen, strlen(trel));

}

unitlen = MAX(unitlen, strlen(t->id));

STRV_FOREACH(a, t->triggered)

ul += strlen(*a) + 2*(a != t->triggered);

activatelen = MAX(activatelen, ul);

}

if (n > 0) {

if (!arg_no_legend)

printf("%-*s %-*s %-*s %s\n",

nextlen, "NEXT",

leftlen, "LEFT",

unitlen, "UNIT",

"ACTIVATES");

for (t = timer_infos; t < timer_infos + n; t++) {

char tstamp[FORMAT_TIMESTAMP_MAX] = "n/a", trel[FORMAT_TIMESTAMP_RELATIVE_MAX] = "n/a";

char **a;

format_timestamp(tstamp, sizeof(tstamp), t->next_elapse);

format_timestamp_relative(trel, sizeof(trel), t->next_elapse);

printf("%-*s %-*s %-*s",

nextlen, tstamp, leftlen, trel, unitlen, t->id);

STRV_FOREACH(a, t->triggered)

printf("%s %s",

a == t->triggered ? "" : ",", *a);

printf("\n");

}

on = ansi_highlight();

off = ansi_highlight_off();

if (!arg_no_legend)

printf("\n");

} else {

on = ansi_highlight_red();

off = ansi_highlight_off();

}

if (!arg_no_legend) {

printf("%s%u timers listed.%s\n", on, n, off);

if (!arg_all)

printf("Pass --all to see loaded but inactive timers, too.\n");

}

return 0;

}

static int list_timers(sd_bus *bus, char **args) {

_cleanup_bus_message_unref_ sd_bus_message *reply = NULL;

_cleanup_free_ struct timer_info *timer_infos = NULL;

_cleanup_free_ UnitInfo *unit_infos = NULL;

struct timer_info *t;

const UnitInfo *u;

size_t size = 0;

int n, c = 0;

dual_timestamp nw;

int r = 0;

pager_open_if_enabled();

n = get_unit_list(bus, &reply, &unit_infos, strv_skip_first(args));

if (n < 0)

return n;

dual_timestamp_get(&nw);

for (u = unit_infos; u < unit_infos + n; u++) {

_cleanup_strv_free_ char **triggered = NULL;

dual_timestamp next;

usec_t m;

if (!endswith(u->id, ".timer"))

continue;

r = get_triggered_units(bus, u->unit_path, &triggered);

if (r < 0)

goto cleanup;

r = get_next_elapse(bus, u->unit_path, &next);

if (r < 0)

goto cleanup;

if (next.monotonic != (usec_t) -1 && next.monotonic > 0) {

usec_t converted;

if (next.monotonic > nw.monotonic)

converted = nw.realtime + (next.monotonic - nw.monotonic);

else

converted = nw.realtime - (nw.monotonic - next.monotonic);

if (next.realtime != (usec_t) -1 && next.realtime > 0)

m = MIN(converted, next.realtime);

else

m = converted;

} else

m = next.realtime;

if (!GREEDY_REALLOC(timer_infos, size, c+1)) {

r = log_oom();

goto cleanup;

}

timer_infos[c++] = (struct timer_info) {

.id = u->id,

.next_elapse = m,

.triggered = triggered,

};

triggered = NULL; /* avoid cleanup */

}

qsort_safe(timer_infos, c, sizeof(struct timer_info),

(__compar_fn_t) timer_info_compare);

output_timers_list(timer_infos, c);

cleanup:

for (t = timer_infos; t < timer_infos + c; t++)

strv_free(t->triggered);

return r;

}

static int compare_unit_file_list(const void *a, const void *b) {

const char *d1, *d2;

const UnitFileList *u = a, *v = b;

d1 = strrchr(u->path, '.');

d2 = strrchr(v->path, '.');

if (d1 && d2) {

int r;

r = strcasecmp(d1, d2);

if (r != 0)

return r;

}

return strcasecmp(basename(u->path), basename(v->path));

}

static bool output_show_unit_file(const UnitFileList *u, char **patterns) {

const char *dot;

if (!strv_isempty(patterns)) {

char **pattern;

STRV_FOREACH(pattern, patterns)

if (fnmatch(*pattern, basename(u->path), FNM_NOESCAPE) == 0)

return true;

return false;

}

return !arg_types || ((dot = strrchr(u->path, '.')) && strv_find(arg_types, dot+1));

}

static void output_unit_file_list(const UnitFileList *units, unsigned c) {

unsigned max_id_len, id_cols, state_cols, n_shown = 0;

const UnitFileList *u;

max_id_len = sizeof("UNIT FILE")-1;

state_cols = sizeof("STATE")-1;

for (u = units; u < units + c; u++) {

max_id_len = MAX(max_id_len, strlen(basename(u->path)));

state_cols = MAX(state_cols, strlen(unit_file_state_to_string(u->state)));

}

if (!arg_full) {

unsigned basic_cols;

id_cols = MIN(max_id_len, 25u);

basic_cols = 1 + id_cols + state_cols;

if (basic_cols < (unsigned) columns())

id_cols += MIN(columns() - basic_cols, max_id_len - id_cols);

} else

id_cols = max_id_len;

if (!arg_no_legend)

printf("%-*s %-*s\n",

id_cols, "UNIT FILE",

state_cols, "STATE");

for (u = units; u < units + c; u++) {

_cleanup_free_ char *e = NULL;

const char *on, *off;

const char *id;

n_shown++;

if (u->state == UNIT_FILE_MASKED ||

u->state == UNIT_FILE_MASKED_RUNTIME ||

u->state == UNIT_FILE_DISABLED ||

u->state == UNIT_FILE_INVALID) {

on = ansi_highlight_red();

off = ansi_highlight_off();

} else if (u->state == UNIT_FILE_ENABLED) {

on = ansi_highlight_green();

off = ansi_highlight_off();

} else

on = off = "";

id = basename(u->path);

e = arg_full ? NULL : ellipsize(id, id_cols, 33);

printf("%-*s %s%-*s%s\n",

id_cols, e ? e : id,

on, state_cols, unit_file_state_to_string(u->state), off);

}

if (!arg_no_legend)

printf("\n%u unit files listed.\n", n_shown);

}

static int list_unit_files(sd_bus *bus, char **args) {

_cleanup_bus_message_unref_ sd_bus_message *reply = NULL;

_cleanup_bus_error_free_ sd_bus_error error = SD_BUS_ERROR_NULL;

_cleanup_free_ UnitFileList *units = NULL;

UnitFileList *unit;

size_t size = 0;

unsigned c = 0;

const char *state;

char *path;

int r;

pager_open_if_enabled();

if (avoid_bus()) {

Hashmap *h;

UnitFileList *u;

Iterator i;

unsigned n_units;

h = hashmap_new(string_hash_func, string_compare_func);

if (!h)

return log_oom();

r = unit_file_get_list(arg_scope, arg_root, h);

if (r < 0) {

unit_file_list_free(h);

log_error("Failed to get unit file list: %s", strerror(-r));

return r;

}

n_units = hashmap_size(h);

units = new(UnitFileList, n_units);

if (!units) {

unit_file_list_free(h);

return log_oom();

}

HASHMAP_FOREACH(u, h, i) {

if (!output_show_unit_file(u, strv_skip_first(args)))

continue;

units[c++] = *u;

free(u);

}

assert(c <= n_units);

hashmap_free(h);

} else {

r = sd_bus_call_method(

bus,

"org.freedesktop.systemd1",

"/org/freedesktop/systemd1",

"org.freedesktop.systemd1.Manager",

"ListUnitFiles",

&error,

&reply,

NULL);

if (r < 0) {

log_error("Failed to list unit files: %s", bus_error_message(&error, r));

return r;

}

r = sd_bus_message_enter_container(reply, SD_BUS_TYPE_ARRAY, "(ss)");

if (r < 0)

return bus_log_parse_error(r);

while ((r = sd_bus_message_read(reply, "(ss)", &path, &state)) > 0) {

if (!GREEDY_REALLOC(units, size, c + 1))

return log_oom();

units[c] = (struct UnitFileList) {

path,

unit_file_state_from_string(state)

};

if (output_show_unit_file(&units[c], strv_skip_first(args)))

c ++;

}

if (r < 0)

return bus_log_parse_error(r);

r = sd_bus_message_exit_container(reply);

if (r < 0)

return bus_log_parse_error(r);

}

if (c > 0) {

qsort(units, c, sizeof(UnitFileList), compare_unit_file_list);

output_unit_file_list(units, c);

}

if (avoid_bus())

for (unit = units; unit < units + c; unit++)

free(unit->path);

return 0;

}

static int list_dependencies_print(const char *name, int level, unsigned int branches, bool last) {

_cleanup_free_ char *n = NULL;

size_t max_len = MAX(columns(),20u);

size_t len = 0;

int i;

if (!arg_plain) {

for (i = level - 1; i >= 0; i--) {

len += 2;

if (len > max_len - 3 && !arg_full) {

printf("%s...\n",max_len % 2 ? "" : " ");

return 0;

}

printf("%s", draw_special_char(branches & (1 << i) ? DRAW_TREE_VERT : DRAW_TREE_SPACE));

}

len += 2;

if (len > max_len - 3 && !arg_full) {

printf("%s...\n",max_len % 2 ? "" : " ");

return 0;

}

printf("%s", draw_special_char(last ? DRAW_TREE_RIGHT : DRAW_TREE_BRANCH));

}

if (arg_full){

printf("%s\n", name);

return 0;

}

n = ellipsize(name, max_len-len, 100);

if (!n)

return log_oom();

printf("%s\n", n);

return 0;

}

static int list_dependencies_get_dependencies(sd_bus *bus, const char *name, char ***deps) {

static const char *dependencies[_DEPENDENCY_MAX] = {

[DEPENDENCY_FORWARD] = "Requires\0"

"RequiresOverridable\0"

"Requisite\0"

"RequisiteOverridable\0"

"Wants\0",

[DEPENDENCY_REVERSE] = "RequiredBy\0"

"RequiredByOverridable\0"

"WantedBy\0"

"PartOf\0",

[DEPENDENCY_AFTER] = "After\0",

[DEPENDENCY_BEFORE] = "Before\0",

};

_cleanup_bus_error_free_ sd_bus_error error = SD_BUS_ERROR_NULL;

_cleanup_bus_message_unref_ sd_bus_message *reply = NULL;

_cleanup_strv_free_ char **ret = NULL;

_cleanup_free_ char *path = NULL;

int r;

assert(bus);

assert(name);

assert(deps);

assert_cc(ELEMENTSOF(dependencies) == _DEPENDENCY_MAX);

path = unit_dbus_path_from_name(name);

if (!path)

return log_oom();

r = sd_bus_call_method(

bus,

"org.freedesktop.systemd1",

path,

"org.freedesktop.DBus.Properties",

"GetAll",

&error,

&reply,

"s", "org.freedesktop.systemd1.Unit");

if (r < 0) {

log_error("Failed to get properties of %s: %s", name, bus_error_message(&error, r));

return r;

}

r = sd_bus_message_enter_container(reply, SD_BUS_TYPE_ARRAY, "{sv}");

if (r < 0)

return bus_log_parse_error(r);

while ((r = sd_bus_message_enter_container(reply, SD_BUS_TYPE_DICT_ENTRY, "sv")) > 0) {

const char *prop;

r = sd_bus_message_read(reply, "s", &prop);

if (r < 0)

return bus_log_parse_error(r);

if (!nulstr_contains(dependencies[arg_dependency], prop)) {

r = sd_bus_message_skip(reply, "v");

if (r < 0)

return bus_log_parse_error(r);

} else {

r = sd_bus_message_enter_container(reply, SD_BUS_TYPE_VARIANT, "as");

if (r < 0)

return bus_log_parse_error(r);

r = bus_message_read_strv_extend(reply, &ret);

if (r < 0)

return bus_log_parse_error(r);

r = sd_bus_message_exit_container(reply);

if (r < 0)

return bus_log_parse_error(r);

}

r = sd_bus_message_exit_container(reply);

if (r < 0)

return bus_log_parse_error(r);

}

if (r < 0)

return bus_log_parse_error(r);

r = sd_bus_message_exit_container(reply);

if (r < 0)

return bus_log_parse_error(r);

*deps = ret;

ret = NULL;

return 0;

}

static int list_dependencies_compare(const void *_a, const void *_b) {

const char **a = (const char**) _a, **b = (const char**) _b;

if (unit_name_to_type(*a) == UNIT_TARGET && unit_name_to_type(*b) != UNIT_TARGET)

return 1;

if (unit_name_to_type(*a) != UNIT_TARGET && unit_name_to_type(*b) == UNIT_TARGET)

return -1;

return strcasecmp(*a, *b);

}

static int list_dependencies_one(

sd_bus *bus,

const char *name,

int level,

char ***units,

unsigned int branches) {

_cleanup_strv_free_ char **deps = NULL, **u;

char **c;

int r = 0;

assert(bus);

assert(name);

assert(units);

u = strv_append(*units, name);

if (!u)

return log_oom();

r = list_dependencies_get_dependencies(bus, name, &deps);

if (r < 0)

return r;

qsort_safe(deps, strv_length(deps), sizeof (char*), list_dependencies_compare);

STRV_FOREACH(c, deps) {

int state;

if (strv_contains(u, *c)) {

if (!arg_plain) {

r = list_dependencies_print("...", level + 1, (branches << 1) | (c[1] == NULL ? 0 : 1), 1);

if (r < 0)

return r;

}

continue;

}

state = check_one_unit(bus, *c, "activating\0active\0reloading\0", true);

if (state > 0)

printf("%s%s%s", ansi_highlight_green(), draw_special_char(DRAW_BLACK_CIRCLE), ansi_highlight_off());

else

printf("%s%s%s", ansi_highlight_red(), draw_special_char(DRAW_BLACK_CIRCLE), ansi_highlight_off());

r = list_dependencies_print(*c, level, branches, c[1] == NULL);

if (r < 0)

return r;

if (arg_all || unit_name_to_type(*c) == UNIT_TARGET) {

r = list_dependencies_one(bus, *c, level + 1, &u, (branches << 1) | (c[1] == NULL ? 0 : 1));

if (r < 0)

return r;

}

}

if (arg_plain) {

strv_free(*units);

*units = u;

u = NULL;

}

return 0;

}

static int list_dependencies(sd_bus *bus, char **args) {

_cleanup_strv_free_ char **units = NULL;

_cleanup_free_ char *unit = NULL;

const char *u;

assert(bus);

if (args[1]) {

unit = unit_name_mangle(args[1]);

if (!unit)

return log_oom();

u = unit;

} else

u = SPECIAL_DEFAULT_TARGET;

pager_open_if_enabled();

puts(u);

return list_dependencies_one(bus, u, 0, &units, 0);

}

static int get_default(sd_bus *bus, char **args) {

_cleanup_bus_message_unref_ sd_bus_message *reply = NULL;

_cleanup_bus_error_free_ sd_bus_error error = SD_BUS_ERROR_NULL;

_cleanup_free_ char *_path = NULL;

const char *path;

int r;

if (!bus || avoid_bus()) {

r = unit_file_get_default(arg_scope, arg_root, &_path);

if (r < 0) {

log_error("Failed to get default target: %s", strerror(-r));

return r;

}

path = _path;

} else {

r = sd_bus_call_method(

bus,

"org.freedesktop.systemd1",

"/org/freedesktop/systemd1",

"org.freedesktop.systemd1.Manager",

"GetDefaultTarget",

&error,

&reply,

NULL);

if (r < 0) {

log_error("Failed to get default target: %s", bus_error_message(&error, -r));

return r;

}

r = sd_bus_message_read(reply, "s", &path);

if (r < 0)

return bus_log_parse_error(r);

}

if (path)

printf("%s\n", path);

return 0;

}

static void dump_unit_file_changes(const UnitFileChange *changes, unsigned n_changes) {

unsigned i;

assert(changes || n_changes == 0);

for (i = 0; i < n_changes; i++) {

if (changes[i].type == UNIT_FILE_SYMLINK)

log_info("ln -s '%s' '%s'", changes[i].source, changes[i].path);

else

log_info("rm '%s'", changes[i].path);

}

}

static int deserialize_and_dump_unit_file_changes(sd_bus_message *m) {

const char *type, *path, *source;

int r;

r = sd_bus_message_enter_container(m, SD_BUS_TYPE_ARRAY, "(sss)");

if (r < 0)

return bus_log_parse_error(r);

while ((r = sd_bus_message_read(m, "(sss)", &type, &path, &source)) > 0) {

if (!arg_quiet) {

if (streq(type, "symlink"))

log_info("ln -s '%s' '%s'", source, path);

else

log_info("rm '%s'", path);

}

}

if (r < 0)

return bus_log_parse_error(r);

r = sd_bus_message_exit_container(m);

if (r < 0)

return bus_log_parse_error(r);

return 0;

}

static int set_default(sd_bus *bus, char **args) {

_cleanup_free_ char *unit = NULL;

UnitFileChange *changes = NULL;

unsigned n_changes = 0;

int r;

unit = unit_name_mangle_with_suffix(args[1], ".target");

if (!unit)

return log_oom();

if (!bus || avoid_bus()) {

r = unit_file_set_default(arg_scope, arg_root, unit, arg_force, &changes, &n_changes);

if (r < 0) {

log_error("Failed to set default target: %s", strerror(-r));

return r;

}

if (!arg_quiet)

dump_unit_file_changes(changes, n_changes);

r = 0;

} else {

_cleanup_bus_message_unref_ sd_bus_message *reply = NULL;

_cleanup_bus_error_free_ sd_bus_error error = SD_BUS_ERROR_NULL;

r = sd_bus_call_method(

bus,

"org.freedesktop.systemd1",

"/org/freedesktop/systemd1",

"org.freedesktop.systemd1.Manager",

"SetDefaultTarget",

&error,

&reply,

"sb", unit, arg_force);

if (r < 0) {

log_error("Failed to set default target: %s", bus_error_message(&error, -r));

return r;

}

r = deserialize_and_dump_unit_file_changes(reply);

if (r < 0)

return r;

/* Try to reload if enabeld */

if (!arg_no_reload)

r = daemon_reload(bus, args);

else

r = 0;

}

unit_file_changes_free(changes, n_changes);

return r;

}

struct job_info {

uint32_t id;

const char *name, *type, *state;

};

static void output_jobs_list(const struct job_info* jobs, unsigned n, bool skipped) {

unsigned id_len, unit_len, type_len, state_len;

const struct job_info *j;

const char *on, *off;

bool shorten = false;

assert(n == 0 || jobs);

if (n == 0) {

on = ansi_highlight_green();

off = ansi_highlight_off();

printf("%sNo jobs %s.%s\n", on, skipped ? "listed" : "running", off);

return;

}

pager_open_if_enabled();

id_len = sizeof("JOB")-1;

unit_len = sizeof("UNIT")-1;

type_len = sizeof("TYPE")-1;

state_len = sizeof("STATE")-1;

for (j = jobs; j < jobs + n; j++) {

uint32_t id = j->id;

assert(j->name && j->type && j->state);

id_len = MAX(id_len, DECIMAL_STR_WIDTH(id));

unit_len = MAX(unit_len, strlen(j->name));

type_len = MAX(type_len, strlen(j->type));

state_len = MAX(state_len, strlen(j->state));

}

if (!arg_full && id_len + 1 + unit_len + type_len + 1 + state_len > columns()) {

unit_len = MAX(33u, columns() - id_len - type_len - state_len - 3);

shorten = true;

}

if (!arg_no_legend)

printf("%*s %-*s %-*s %-*s\n",

id_len, "JOB",

unit_len, "UNIT",

type_len, "TYPE",

state_len, "STATE");

for (j = jobs; j < jobs + n; j++) {

_cleanup_free_ char *e = NULL;

if (streq(j->state, "running")) {

on = ansi_highlight();

off = ansi_highlight_off();

} else

on = off = "";

e = shorten ? ellipsize(j->name, unit_len, 33) : NULL;

printf("%*u %s%-*s%s %-*s %s%-*s%s\n",

id_len, j->id,

on, unit_len, e ? e : j->name, off,

type_len, j->type,

on, state_len, j->state, off);

}

if (!arg_no_legend) {

on = ansi_highlight();

off = ansi_highlight_off();

printf("\n%s%u jobs listed%s.\n", on, n, off);

}

}

static bool output_show_job(struct job_info *job, char **patterns) {

if (!strv_isempty(patterns)) {

char **pattern;

STRV_FOREACH(pattern, patterns)

if (fnmatch(*pattern, job->name, FNM_NOESCAPE) == 0)

return true;

return false;

}

return true;

}

static int list_jobs(sd_bus *bus, char **args) {

_cleanup_bus_error_free_ sd_bus_error error = SD_BUS_ERROR_NULL;

_cleanup_bus_message_unref_ sd_bus_message *reply = NULL;

const char *name, *type, *state, *job_path, *unit_path;

_cleanup_free_ struct job_info *jobs = NULL;

size_t size = 0;

unsigned c = 0;

uint32_t id;

int r;

bool skipped = false;

r = sd_bus_call_method(

bus,

"org.freedesktop.systemd1",

"/org/freedesktop/systemd1",

"org.freedesktop.systemd1.Manager",

"ListJobs",

&error,

&reply,

NULL);

if (r < 0) {

log_error("Failed to list jobs: %s", bus_error_message(&error, r));

return r;

}

r = sd_bus_message_enter_container(reply, 'a', "(usssoo)");

if (r < 0)

return bus_log_parse_error(r);

while ((r = sd_bus_message_read(reply, "(usssoo)", &id, &name, &type, &state, &job_path, &unit_path)) > 0) {

struct job_info job = { id, name, type, state };

if (!output_show_job(&job, strv_skip_first(args))) {

skipped = true;

continue;

}

if (!GREEDY_REALLOC(jobs, size, c + 1))

return log_oom();

jobs[c++] = job;

}

if (r < 0)

return bus_log_parse_error(r);

r = sd_bus_message_exit_container(reply);

if (r < 0)

return bus_log_parse_error(r);

output_jobs_list(jobs, c, skipped);

return r;

}

static int cancel_job(sd_bus *bus, char **args) {

_cleanup_bus_error_free_ sd_bus_error error = SD_BUS_ERROR_NULL;

char **name;

assert(args);

if (strv_length(args) <= 1)

return daemon_reload(bus, args);

STRV_FOREACH(name, args+1) {

uint32_t id;

int r;

r = safe_atou32(*name, &id);

if (r < 0) {

log_error("Failed to parse job id \"%s\": %s", *name, strerror(-r));

return r;

}

r = sd_bus_call_method(

bus,

"org.freedesktop.systemd1",

"/org/freedesktop/systemd1",

"org.freedesktop.systemd1.Manager",

"CancelJob",

&error,

NULL,

"u", id);

if (r < 0) {

log_error("Failed to cancel job %u: %s", (unsigned) id, bus_error_message(&error, r));

return r;

}

}

return 0;

}

static int need_daemon_reload(sd_bus *bus, const char *unit) {

_cleanup_bus_message_unref_ sd_bus_message *reply = NULL;

_cleanup_free_ char *n = NULL;

const char *path;

int b, r;

/* We ignore all errors here, since this is used to show a

n = unit_name_mangle(unit);

if (!n)

return -ENOMEM;

/* We don't use unit_dbus_path_from_name() directly since we

r = sd_bus_call_method(

bus,

"org.freedesktop.systemd1",

"/org/freedesktop/systemd1",

"org.freedesktop.systemd1.Manager",

"GetUnit",

NULL,

&reply,

"s", n);

if (r < 0)

return r;

r = sd_bus_message_read(reply, "o", &path);

if (r < 0)

return r;

r = sd_bus_get_property_trivial(

bus,

"org.freedesktop.systemd1",

path,

"org.freedesktop.systemd1.Unit",

"NeedDaemonReload",

NULL,

'b', &b);

if (r < 0)

return r;

return b;

}

typedef struct WaitData {

Set *set;

char *name;

char *result;

} WaitData;

static int wait_filter(sd_bus *bus, sd_bus_message *m, void *data, sd_bus_error *error) {

WaitData *d = data;

assert(bus);

assert(m);

assert(d);

log_debug("Got D-Bus request: %s.%s() on %s",

sd_bus_message_get_interface(m),

sd_bus_message_get_member(m),

sd_bus_message_get_path(m));

if (sd_bus_message_is_signal(m, "org.freedesktop.DBus.Local", "Disconnected")) {

log_error("Warning! D-Bus connection terminated.");

sd_bus_close(bus);

} else if (sd_bus_message_is_signal(m, "org.freedesktop.systemd1.Manager", "JobRemoved")) {

uint32_t id;

const char *path, *result, *unit;

char *ret;

int r;

r = sd_bus_message_read(m, "uoss", &id, &path, &unit, &result);

if (r >= 0) {

ret = set_remove(d->set, (char*) path);

if (!ret)

return 0;

free(ret);

if (!isempty(result))

d->result = strdup(result);

if (!isempty(unit))

d->name = strdup(unit);

return 0;

}

#ifndef NOLEGACY

r = sd_bus_message_read(m, "uos", &id, &path, &result);

if (r >= 0) {

ret = set_remove(d->set, (char*) path);

if (!ret)

return 0;

free(ret);

if (*result)

d->result = strdup(result);

return 0;

}

#endif

bus_log_parse_error(r);

}

return 0;

}

static int enable_wait_for_jobs(sd_bus *bus) {

int r;

assert(bus);

r = sd_bus_add_match(

bus,

"type='signal',"

"sender='org.freedesktop.systemd1',"

"interface='org.freedesktop.systemd1.Manager',"

"member='JobRemoved',"

"path='/org/freedesktop/systemd1'",

NULL, NULL);

if (r < 0) {

log_error("Failed to add match");

return -EIO;

}

/* This is slightly dirty, since we don't undo the match registrations. */

return 0;

}

static int bus_process_wait(sd_bus *bus) {

int r;

for (;;) {

r = sd_bus_process(bus, NULL);

if (r < 0)

return r;

if (r > 0)

return 0;

r = sd_bus_wait(bus, (uint64_t) -1);

if (r < 0)

return r;

}

}

static int check_wait_response(WaitData *d) {

int r = 0;

assert(d->result);

if (!arg_quiet) {

if (streq(d->result, "timeout"))

log_error("Job for %s timed out.", strna(d->name));

else if (streq(d->result, "canceled"))

log_error("Job for %s canceled.", strna(d->name));

else if (streq(d->result, "dependency"))

log_error("A dependency job for %s failed. See 'journalctl -xn' for details.", strna(d->name));

else if (!streq(d->result, "done") && !streq(d->result, "skipped"))

log_error("Job for %s failed. See 'systemctl status %s' and 'journalctl -xn' for details.", strna(d->name), strna(d->name));

}

if (streq(d->result, "timeout"))

r = -ETIME;

else if (streq(d->result, "canceled"))

r = -ECANCELED;

else if (streq(d->result, "dependency"))

r = -EIO;

else if (!streq(d->result, "done") && !streq(d->result, "skipped"))

r = -EIO;

return r;

}

static int wait_for_jobs(sd_bus *bus, Set *s) {

WaitData d = { .set = s };

int r = 0, q;

assert(bus);

assert(s);

q = sd_bus_add_filter(bus, wait_filter, &d);

if (q < 0)

return log_oom();

while (!set_isempty(s)) {

q = bus_process_wait(bus);

if (q < 0)

return q;

if (d.result) {

q = check_wait_response(&d);

/* Return the first error as it is most likely to be

if (q < 0 && r == 0)

r = q;

}

free(d.name);

d.name = NULL;

free(d.result);

d.result = NULL;

}

q = sd_bus_remove_filter(bus, wait_filter, &d);

if (q < 0 && r == 0)

r = q;

return r;

}

static int check_one_unit(sd_bus *bus, const char *name, const char *good_states, bool quiet) {

_cleanup_bus_message_unref_ sd_bus_message *reply = NULL;

_cleanup_free_ char *n = NULL, *state = NULL;

const char *path;

int r;

assert(name);

n = unit_name_mangle(name);

if (!n)

return log_oom();

/* We don't use unit_dbus_path_from_name() directly since we

r = sd_bus_call_method(

bus,

"org.freedesktop.systemd1",

"/org/freedesktop/systemd1",

"org.freedesktop.systemd1.Manager",

"GetUnit",

NULL,

&reply,

"s", n);

if (r < 0) {

if (!quiet)

puts("unknown");

return 0;

}

r = sd_bus_message_read(reply, "o", &path);

if (r < 0)

return bus_log_parse_error(r);

r = sd_bus_get_property_string(

bus,

"org.freedesktop.systemd1",

path,

"org.freedesktop.systemd1.Unit",

"ActiveState",

NULL,

&state);

if (r < 0) {

if (!quiet)

puts("unknown");

return 0;

}

if (!quiet)

puts(state);

return nulstr_contains(good_states, state);

}

static int check_triggering_units(

sd_bus *bus,

const char *name) {

_cleanup_bus_error_free_ sd_bus_error error = SD_BUS_ERROR_NULL;

_cleanup_free_ char *path = NULL, *n = NULL, *state = NULL;

_cleanup_strv_free_ char **triggered_by = NULL;

bool print_warning_label = true;

char **i;

int r;

n = unit_name_mangle(name);

if (!n)

return log_oom();

path = unit_dbus_path_from_name(n);

if (!path)

return log_oom();

r = sd_bus_get_property_string(

bus,

"org.freedesktop.systemd1",

path,

"org.freedesktop.systemd1.Unit",

"LoadState",

&error,

&state);

if (r < 0) {

log_error("Failed to get load state of %s: %s", n, bus_error_message(&error, r));

return r;

}

if (streq(state, "masked"))

return 0;

r = sd_bus_get_property_strv(

bus,

"org.freedesktop.systemd1",

path,

"org.freedesktop.systemd1.Unit",

"TriggeredBy",

&error,

&triggered_by);

if (r < 0) {

log_error("Failed to get triggered by array of %s: %s", n, bus_error_message(&error, r));

return r;

}

STRV_FOREACH(i, triggered_by) {

r = check_one_unit(bus, *i, "active\0reloading\0", true);

if (r < 0) {

log_error("Failed to check unit: %s", strerror(-r));

return r;

}

if (r == 0)

continue;

if (print_warning_label) {

log_warning("Warning: Stopping %s, but it can still be activated by:", n);

print_warning_label = false;

}

log_warning(" %s", *i);

}

return 0;

}

static int start_unit_one(

sd_bus *bus,

const char *method,

const char *name,

const char *mode,

sd_bus_error *error,

Set *s) {

_cleanup_bus_message_unref_ sd_bus_message *reply = NULL;

_cleanup_free_ char *n;

const char *path;

int r;

assert(method);

assert(name);

assert(mode);

assert(error);

n = unit_name_mangle(name);

if (!n)

return log_oom();

r = sd_bus_call_method(

bus,

"org.freedesktop.systemd1",

"/org/freedesktop/systemd1",

"org.freedesktop.systemd1.Manager",

method,

error,

&reply,

"ss", n, mode);

if (r < 0) {

if (r == -ENOENT && arg_action != ACTION_SYSTEMCTL)

/* There's always a fallback possible for

return -EADDRNOTAVAIL;

log_error("Failed to start %s: %s", name, bus_error_message(error, r));

return r;

}

r = sd_bus_message_read(reply, "o", &path);

if (r < 0)

return bus_log_parse_error(r);

if (need_daemon_reload(bus, n) > 0)

log_warning("Warning: Unit file of %s changed on disk, 'systemctl%s daemon-reload' recommended.",

n, arg_scope == UNIT_FILE_SYSTEM ? "" : " --user");

if (s) {

char *p;

p = strdup(path);

if (!p)

return log_oom();

r = set_consume(s, p);

if (r < 0)

return log_oom();

}

return 0;

}

static const struct {

const char *target;

const char *verb;

const char *mode;

} action_table[_ACTION_MAX] = {

[ACTION_HALT] = { SPECIAL_HALT_TARGET, "halt", "replace-irreversibly" },

[ACTION_POWEROFF] = { SPECIAL_POWEROFF_TARGET, "poweroff", "replace-irreversibly" },

[ACTION_REBOOT] = { SPECIAL_REBOOT_TARGET, "reboot", "replace-irreversibly" },

[ACTION_KEXEC] = { SPECIAL_KEXEC_TARGET, "kexec", "replace-irreversibly" },

[ACTION_RUNLEVEL2] = { SPECIAL_RUNLEVEL2_TARGET, NULL, "isolate" },

[ACTION_RUNLEVEL3] = { SPECIAL_RUNLEVEL3_TARGET, NULL, "isolate" },

[ACTION_RUNLEVEL4] = { SPECIAL_RUNLEVEL4_TARGET, NULL, "isolate" },

[ACTION_RUNLEVEL5] = { SPECIAL_RUNLEVEL5_TARGET, NULL, "isolate" },

[ACTION_RESCUE] = { SPECIAL_RESCUE_TARGET, "rescue", "isolate" },

[ACTION_EMERGENCY] = { SPECIAL_EMERGENCY_TARGET, "emergency", "isolate" },

[ACTION_DEFAULT] = { SPECIAL_DEFAULT_TARGET, "default", "isolate" },

[ACTION_EXIT] = { SPECIAL_EXIT_TARGET, "exit", "replace-irreversibly" },

[ACTION_SUSPEND] = { SPECIAL_SUSPEND_TARGET, "suspend", "replace-irreversibly" },

[ACTION_HIBERNATE] = { SPECIAL_HIBERNATE_TARGET, "hibernate", "replace-irreversibly" },

[ACTION_HYBRID_SLEEP] = { SPECIAL_HYBRID_SLEEP_TARGET, "hybrid-sleep", "replace-irreversibly" },

};

static enum action verb_to_action(const char *verb) {

enum action i;

for (i = _ACTION_INVALID; i < _ACTION_MAX; i++)

if (streq_ptr(action_table[i].verb, verb))

return i;

return _ACTION_INVALID;

}

static int start_unit(sd_bus *bus, char **args) {

_cleanup_bus_error_free_ sd_bus_error error = SD_BUS_ERROR_NULL;

_cleanup_set_free_free_ Set *s = NULL;

const char *method, *mode;

char **name;

int r = 0;

char **names, *strv[] = {NULL, NULL}; /* at most one name */

assert(bus);

ask_password_agent_open_if_enabled();

if (arg_action == ACTION_SYSTEMCTL) {

enum action action;

method =

streq(args[0], "stop") ||

streq(args[0], "condstop") ? "StopUnit" :

streq(args[0], "reload") ? "ReloadUnit" :

streq(args[0], "restart") ? "RestartUnit" :

streq(args[0], "try-restart") ||

streq(args[0], "condrestart") ? "TryRestartUnit" :

streq(args[0], "reload-or-restart") ? "ReloadOrRestartUnit" :

streq(args[0], "reload-or-try-restart") ||

streq(args[0], "condreload") ||

streq(args[0], "force-reload") ? "ReloadOrTryRestartUnit" :

"StartUnit";

action = verb_to_action(args[0]);

mode = streq(args[0], "isolate") ? "isolate" :

action_table[action].mode ?: arg_job_mode;

strv[0] = (char*) action_table[action].target;

} else {

assert(arg_action < ELEMENTSOF(action_table));

assert(action_table[arg_action].target);

method = "StartUnit";

mode = action_table[arg_action].mode;

strv[0] = (char*) action_table[arg_action].target;

}

if (strv[0])

names = strv;

else

names = args + 1;

if (!arg_no_block) {

r = enable_wait_for_jobs(bus);

if (r < 0) {

log_error("Could not watch jobs: %s", strerror(-r));

return r;

}

s = set_new(string_hash_func, string_compare_func);

if (!s)

return log_oom();

}

STRV_FOREACH(name, names) {

int q;

q = start_unit_one(bus, method, *name, mode, &error, s);

if (r == 0 && q < 0) {

r = translate_bus_error_to_exit_status(q, &error);

sd_bus_error_free(&error);

}

}

if (!arg_no_block) {

int q;

q = wait_for_jobs(bus, s);

if (q < 0)

return q;

/* When stopping units, warn if they can still be triggered by

if (!arg_quiet && streq(method, "StopUnit"))

STRV_FOREACH(name, names)

check_triggering_units(bus, *name);

}

return r;

}

static int reboot_with_logind(sd_bus *bus, enum action a) {

#ifdef HAVE_LOGIND

_cleanup_bus_error_free_ sd_bus_error error = SD_BUS_ERROR_NULL;

const char *method;

int r;

if (!bus)

return -EIO;

polkit_agent_open_if_enabled();

switch (a) {

case ACTION_REBOOT:

method = "Reboot";

break;

case ACTION_POWEROFF:

method = "PowerOff";

break;

case ACTION_SUSPEND:

method = "Suspend";

break;

case ACTION_HIBERNATE:

method = "Hibernate";

break;

case ACTION_HYBRID_SLEEP:

method = "HybridSleep";

break;

default:

return -EINVAL;

}

r = sd_bus_call_method(

bus,

"org.freedesktop.login1",

"/org/freedesktop/login1",

"org.freedesktop.login1.Manager",

method,

&error,

NULL,

"b", true);

if (r < 0)

log_error("Failed to execute operation: %s", bus_error_message(&error, r));

return r;

#else

return -ENOSYS;

#endif

}

static int check_inhibitors(sd_bus *bus, enum action a) {

#ifdef HAVE_LOGIND

_cleanup_bus_message_unref_ sd_bus_message *reply = NULL;

_cleanup_strv_free_ char **sessions = NULL;

const char *what, *who, *why, *mode;

uint32_t uid, pid;

unsigned c = 0;

char **s;

int r;

if (!bus)

return 0;

if (arg_ignore_inhibitors || arg_force > 0)

return 0;

if (arg_when > 0)

return 0;

if (geteuid() == 0)

return 0;

if (!on_tty())

return 0;

r = sd_bus_call_method(

bus,

"org.freedesktop.login1",

"/org/freedesktop/login1",

"org.freedesktop.login1.Manager",

"ListInhibitors",

NULL,

&reply,

NULL);

if (r < 0)

/* If logind is not around, then there are no inhibitors... */

return 0;

r = sd_bus_message_enter_container(reply, SD_BUS_TYPE_ARRAY, "(ssssuu)");

if (r < 0)

return bus_log_parse_error(r);

while ((r = sd_bus_message_read(reply, "(ssssuu)", &what, &who, &why, &mode, &uid, &pid)) > 0) {

_cleanup_free_ char *comm = NULL, *user = NULL;

_cleanup_strv_free_ char **sv = NULL;

if (!streq(mode, "block"))

continue;

sv = strv_split(what, ":");

if (!sv)

return log_oom();

if (!strv_contains(sv,

a == ACTION_HALT ||

a == ACTION_POWEROFF ||

a == ACTION_REBOOT ||

a == ACTION_KEXEC ? "shutdown" : "sleep"))

continue;

get_process_comm(pid, &comm);

user = uid_to_name(uid);

log_warning("Operation inhibited by \"%s\" (PID %lu \"%s\", user %s), reason is \"%s\".",

who, (unsigned long) pid, strna(comm), strna(user), why);

c++;

}

if (r < 0)

return bus_log_parse_error(r);

r = sd_bus_message_exit_container(reply);

if (r < 0)

return bus_log_parse_error(r);

/* Check for current sessions */

sd_get_sessions(&sessions);

STRV_FOREACH(s, sessions) {

_cleanup_free_ char *type = NULL, *tty = NULL, *seat = NULL, *user = NULL, *service = NULL, *class = NULL;

if (sd_session_get_uid(*s, &uid) < 0 || uid == getuid())

continue;

if (sd_session_get_class(*s, &class) < 0 || !streq(class, "user"))

continue;

if (sd_session_get_type(*s, &type) < 0 || (!streq(type, "x11") && !streq(type, "tty")))

continue;

sd_session_get_tty(*s, &tty);

sd_session_get_seat(*s, &seat);

sd_session_get_service(*s, &service);

user = uid_to_name(uid);

log_warning("User %s is logged in on %s.", strna(user), isempty(tty) ? (isempty(seat) ? strna(service) : seat) : tty);

c++;

}

if (c <= 0)

return 0;

log_error("Please retry operation after closing inhibitors and logging out other users.\nAlternatively, ignore inhibitors and users with 'systemctl %s -i'.",

action_table[a].verb);

return -EPERM;

#else

return 0;

#endif

}

static int start_special(sd_bus *bus, char **args) {

enum action a;

int r;

assert(args);

a = verb_to_action(args[0]);

r = check_inhibitors(bus, a);

if (r < 0)

return r;

if (arg_force >= 2 && geteuid() != 0) {

log_error("Must be root.");

return -EPERM;

}

if (arg_force >= 2 &&

(a == ACTION_HALT ||

a == ACTION_POWEROFF ||

a == ACTION_REBOOT))

return halt_now(a);

if (arg_force >= 1 &&

(a == ACTION_HALT ||

a == ACTION_POWEROFF ||

a == ACTION_REBOOT ||

a == ACTION_KEXEC ||

a == ACTION_EXIT))

return daemon_reload(bus, args);

/* first try logind, to allow authentication with polkit */

if (geteuid() != 0 &&

(a == ACTION_POWEROFF ||

a == ACTION_REBOOT ||

a == ACTION_SUSPEND ||

a == ACTION_HIBERNATE ||

a == ACTION_HYBRID_SLEEP)) {

r = reboot_with_logind(bus, a);

if (r >= 0)

return r;

}

r = start_unit(bus, args);

if (r == EXIT_SUCCESS)

warn_wall(a);

return r;

}

static int check_unit_active(sd_bus *bus, char **args) {

char **name;

int r = 3; /* According to LSB: "program is not running" */

assert(bus);

assert(args);

STRV_FOREACH(name, args+1) {

int state;

state = check_one_unit(bus, *name, "active\0reloading\0", arg_quiet);

if (state < 0)

return state;

if (state > 0)

r = 0;

}

return r;

}

static int check_unit_failed(sd_bus *bus, char **args) {

char **name;

int r = 1;

assert(bus);

assert(args);

STRV_FOREACH(name, args+1) {

int state;

state = check_one_unit(bus, *name, "failed\0", arg_quiet);

if (state < 0)

return state;

if (state > 0)

r = 0;

}

return r;

}

static int kill_unit(sd_bus *bus, char **args) {

_cleanup_bus_error_free_ sd_bus_error error = SD_BUS_ERROR_NULL;

char **name;

int r = 0;

assert(bus);

assert(args);

if (!arg_kill_who)

arg_kill_who = "all";

STRV_FOREACH(name, args+1) {

_cleanup_free_ char *n = NULL;

n = unit_name_mangle(*name);

if (!n)

return log_oom();

r = sd_bus_call_method(

bus,

"org.freedesktop.systemd1",

"/org/freedesktop/systemd1",

"org.freedesktop.systemd1.Manager",

"KillUnit",

&error,

NULL,

"ssi", n, arg_kill_who, arg_signal);

if (r < 0) {

log_error("Failed to kill unit %s: %s", n, bus_error_message(&error, r));

return r;

}

}

return 0;

}

typedef struct ExecStatusInfo {

char *name;

char *path;

char **argv;

bool ignore;

usec_t start_timestamp;

usec_t exit_timestamp;

pid_t pid;

int code;

int status;

LIST_FIELDS(struct ExecStatusInfo, exec);

} ExecStatusInfo;

static void exec_status_info_free(ExecStatusInfo *i) {

assert(i);

free(i->name);

free(i->path);

strv_free(i->argv);

free(i);

}

static int exec_status_info_deserialize(sd_bus_message *m, ExecStatusInfo *i) {

uint64_t start_timestamp, exit_timestamp, start_timestamp_monotonic, exit_timestamp_monotonic;

const char *path;

uint32_t pid;

int32_t code, status;

int ignore, r;

assert(m);

assert(i);

r = sd_bus_message_enter_container(m, SD_BUS_TYPE_STRUCT, "sasbttttuii");

if (r < 0)

return bus_log_parse_error(r);

else if (r == 0)

return 0;

r = sd_bus_message_read(m, "s", &path);

if (r < 0)

return bus_log_parse_error(r);

i->path = strdup(path);

if (!i->path)

return log_oom();

r = sd_bus_message_read_strv(m, &i->argv);

if (r < 0)

return bus_log_parse_error(r);

r = sd_bus_message_read(m,

"bttttuii",

&ignore,

&start_timestamp, &start_timestamp_monotonic,

&exit_timestamp, &exit_timestamp_monotonic,

&pid,

&code, &status);

if (r < 0)

return bus_log_parse_error(r);

i->ignore = ignore;

i->start_timestamp = (usec_t) start_timestamp;

i->exit_timestamp = (usec_t) exit_timestamp;

i->pid = (pid_t) pid;

i->code = code;

i->status = status;

r = sd_bus_message_exit_container(m);

if (r < 0)

return bus_log_parse_error(r);

return 1;

}

typedef struct UnitStatusInfo {

const char *id;

const char *load_state;

const char *active_state;

const char *sub_state;

const char *unit_file_state;

const char *description;

const char *following;

char **documentation;

const char *fragment_path;

const char *source_path;

const char *control_group;

char **dropin_paths;

const char *load_error;

const char *result;

usec_t inactive_exit_timestamp;

usec_t inactive_exit_timestamp_monotonic;

usec_t active_enter_timestamp;

usec_t active_exit_timestamp;

usec_t inactive_enter_timestamp;

bool need_daemon_reload;

/* Service */

pid_t main_pid;

pid_t control_pid;

const char *status_text;

const char *pid_file;

bool running:1;

usec_t start_timestamp;

usec_t exit_timestamp;

int exit_code, exit_status;

usec_t condition_timestamp;

bool condition_result;

bool failed_condition_trigger;

bool failed_condition_negate;

const char *failed_condition;

const char *failed_condition_param;

/* Socket */

unsigned n_accepted;

unsigned n_connections;

bool accept;

/* Pairs of type, path */

char **listen;

/* Device */

const char *sysfs_path;

/* Mount, Automount */

const char *where;

/* Swap */

const char *what;

LIST_HEAD(ExecStatusInfo, exec);

} UnitStatusInfo;

static void print_status_info(

UnitStatusInfo *i,

bool *ellipsized) {

ExecStatusInfo *p;

const char *on, *off, *ss;

usec_t timestamp;

char since1[FORMAT_TIMESTAMP_RELATIVE_MAX], *s1;

char since2[FORMAT_TIMESTAMP_MAX], *s2;

const char *path;

int flags =

arg_all * OUTPUT_SHOW_ALL |

(!on_tty() || pager_have()) * OUTPUT_FULL_WIDTH |

on_tty() * OUTPUT_COLOR |

!arg_quiet * OUTPUT_WARN_CUTOFF |

arg_full * OUTPUT_FULL_WIDTH;

char **t, **t2;

assert(i);

/* This shows pretty information about a unit. See

printf("%s", strna(i->id));

if (i->description && !streq_ptr(i->id, i->description))

printf(" - %s", i->description);

printf("\n");

if (i->following)

printf(" Follow: unit currently follows state of %s\n", i->following);

if (streq_ptr(i->load_state, "error")) {

on = ansi_highlight_red();

off = ansi_highlight_off();

} else

on = off = "";

path = i->source_path ? i->source_path : i->fragment_path;

if (i->load_error)

printf(" Loaded: %s%s%s (Reason: %s)\n",

on, strna(i->load_state), off, i->load_error);

else if (path && i->unit_file_state)

printf(" Loaded: %s%s%s (%s; %s)\n",

on, strna(i->load_state), off, path, i->unit_file_state);

else if (path)

printf(" Loaded: %s%s%s (%s)\n",

on, strna(i->load_state), off, path);

else

printf(" Loaded: %s%s%s\n",

on, strna(i->load_state), off);

if (!strv_isempty(i->dropin_paths)) {

_cleanup_free_ char *dir = NULL;

bool last = false;

char ** dropin;

STRV_FOREACH(dropin, i->dropin_paths) {

if (! dir || last) {

printf(dir ? " " : " Drop-In: ");

free(dir);

dir = NULL;

if (path_get_parent(*dropin, &dir) < 0) {

log_oom();

return;

}

printf("%s\n %s", dir,

draw_special_char(DRAW_TREE_RIGHT));

}

last = ! (*(dropin + 1) && startswith(*(dropin + 1), dir));

printf("%s%s", basename(*dropin), last ? "\n" : ", ");

}

}

ss = streq_ptr(i->active_state, i->sub_state) ? NULL : i->sub_state;

if (streq_ptr(i->active_state, "failed")) {

on = ansi_highlight_red();

off = ansi_highlight_off();

} else if (streq_ptr(i->active_state, "active") || streq_ptr(i->active_state, "reloading")) {

on = ansi_highlight_green();

off = ansi_highlight_off();

} else

on = off = "";

if (ss)

printf(" Active: %s%s (%s)%s",

on, strna(i->active_state), ss, off);

else

printf(" Active: %s%s%s",

on, strna(i->active_state), off);

if (!isempty(i->result) && !streq(i->result, "success"))

printf(" (Result: %s)", i->result);

timestamp = (streq_ptr(i->active_state, "active") ||

streq_ptr(i->active_state, "reloading")) ? i->active_enter_timestamp :

(streq_ptr(i->active_state, "inactive") ||

streq_ptr(i->active_state, "failed")) ? i->inactive_enter_timestamp :

streq_ptr(i->active_state, "activating") ? i->inactive_exit_timestamp :

i->active_exit_timestamp;

s1 = format_timestamp_relative(since1, sizeof(since1), timestamp);

s2 = format_timestamp(since2, sizeof(since2), timestamp);

if (s1)

printf(" since %s; %s\n", s2, s1);

else if (s2)

printf(" since %s\n", s2);

else

printf("\n");

if (!i->condition_result && i->condition_timestamp > 0) {

s1 = format_timestamp_relative(since1, sizeof(since1), i->condition_timestamp);

s2 = format_timestamp(since2, sizeof(since2), i->condition_timestamp);

printf(" start condition failed at %s%s%s\n",

s2, s1 ? "; " : "", s1 ? s1 : "");

if (i->failed_condition_trigger)

printf(" none of the trigger conditions were met\n");

else if (i->failed_condition)

printf(" %s=%s%s was not met\n",

i->failed_condition,

i->failed_condition_negate ? "!" : "",