]>
Commit | Line | Data |
---|---|---|
db9ecf05 | 1 | /* SPDX-License-Identifier: LGPL-2.1-or-later */ |
daf71ef6 LP |
2 | |
3 | #include "bus-error.h" | |
4 | #include "bus-locator.h" | |
6be4dab0 | 5 | #include "bus-wait-for-units.h" |
daf71ef6 LP |
6 | #include "systemctl-kill.h" |
7 | #include "systemctl-util.h" | |
8 | #include "systemctl.h" | |
9 | ||
32baf64d | 10 | int verb_kill(int argc, char *argv[], void *userdata) { |
6be4dab0 | 11 | _cleanup_(bus_wait_for_units_freep) BusWaitForUnits *w = NULL; |
daf71ef6 | 12 | _cleanup_strv_free_ char **names = NULL; |
d06e6199 | 13 | const char *kill_whom; |
daf71ef6 LP |
14 | sd_bus *bus; |
15 | int r, q; | |
16 | ||
17 | r = acquire_bus(BUS_MANAGER, &bus); | |
18 | if (r < 0) | |
19 | return r; | |
20 | ||
6be4dab0 DDM |
21 | if (arg_wait) { |
22 | r = bus_wait_for_units_new(bus, &w); | |
23 | if (r < 0) | |
24 | return log_error_errno(r, "Failed to allocate unit watch context: %m"); | |
25 | } | |
26 | ||
daf71ef6 LP |
27 | polkit_agent_open_maybe(); |
28 | ||
d06e6199 | 29 | kill_whom = arg_kill_whom ?: "all"; |
daf71ef6 LP |
30 | |
31 | /* --fail was specified */ | |
a88f9dba | 32 | if (streq(arg_job_mode(), "fail")) |
d06e6199 | 33 | kill_whom = strjoina(kill_whom, "-fail"); |
daf71ef6 LP |
34 | |
35 | r = expand_unit_names(bus, strv_skip(argv, 1), NULL, &names, NULL); | |
36 | if (r < 0) | |
37 | return log_error_errno(r, "Failed to expand names: %m"); | |
38 | ||
39 | STRV_FOREACH(name, names) { | |
40 | _cleanup_(sd_bus_error_free) sd_bus_error error = SD_BUS_ERROR_NULL; | |
41 | ||
d06e6199 LP |
42 | if (arg_kill_value_set) |
43 | q = bus_call_method( | |
44 | bus, | |
45 | bus_systemd_mgr, | |
46 | "QueueSignalUnit", | |
47 | &error, | |
48 | NULL, | |
49 | "ssii", *name, kill_whom, arg_signal, arg_kill_value); | |
50 | else | |
51 | q = bus_call_method( | |
52 | bus, | |
53 | bus_systemd_mgr, | |
54 | "KillUnit", | |
55 | &error, | |
56 | NULL, | |
57 | "ssi", *name, kill_whom, arg_signal); | |
daf71ef6 | 58 | if (q < 0) { |
6be4dab0 DDM |
59 | RET_GATHER(r, log_error_errno(q, "Failed to kill unit %s: %s", *name, bus_error_message(&error, q))); |
60 | continue; | |
61 | } | |
62 | ||
63 | if (w) { | |
64 | q = bus_wait_for_units_add_unit(w, *name, BUS_WAIT_FOR_INACTIVE|BUS_WAIT_NO_JOB, NULL, NULL); | |
65 | if (q < 0) | |
66 | RET_GATHER(r, log_error_errno(q, "Failed to watch unit %s: %m", *name)); | |
daf71ef6 LP |
67 | } |
68 | } | |
69 | ||
6be4dab0 DDM |
70 | if (w) { |
71 | q = bus_wait_for_units_run(w); | |
72 | if (q < 0) | |
73 | return log_error_errno(q, "Failed to wait for units: %m"); | |
74 | if (q == BUS_WAIT_FAILURE) | |
75 | RET_GATHER(r, -EIO); | |
76 | } | |
77 | ||
daf71ef6 LP |
78 | return r; |
79 | } |