Branch data Line data Source code
1 : : /* SPDX-License-Identifier: LGPL-2.1+ */
2 : :
3 : : #include "sd-bus.h"
4 : :
5 : : #include "alloc-util.h"
6 : : #include "dbus-job.h"
7 : : #include "dbus-unit.h"
8 : : #include "dbus.h"
9 : : #include "job.h"
10 : : #include "log.h"
11 : : #include "selinux-access.h"
12 : : #include "string-util.h"
13 : : #include "strv.h"
14 : :
15 [ # # # # : 0 : static BUS_DEFINE_PROPERTY_GET_ENUM(property_get_type, job_type, JobType);
# # ]
16 [ # # # # : 0 : static BUS_DEFINE_PROPERTY_GET_ENUM(property_get_state, job_state, JobState);
# # ]
17 : :
18 : 0 : static int property_get_unit(
19 : : sd_bus *bus,
20 : : const char *path,
21 : : const char *interface,
22 : : const char *property,
23 : : sd_bus_message *reply,
24 : : void *userdata,
25 : : sd_bus_error *error) {
26 : :
27 : 0 : _cleanup_free_ char *p = NULL;
28 : 0 : Job *j = userdata;
29 : :
30 [ # # ]: 0 : assert(bus);
31 [ # # ]: 0 : assert(reply);
32 [ # # ]: 0 : assert(j);
33 : :
34 : 0 : p = unit_dbus_path(j->unit);
35 [ # # ]: 0 : if (!p)
36 : 0 : return -ENOMEM;
37 : :
38 : 0 : return sd_bus_message_append(reply, "(so)", j->unit->id, p);
39 : : }
40 : :
41 : 0 : int bus_job_method_cancel(sd_bus_message *message, void *userdata, sd_bus_error *error) {
42 : 0 : Job *j = userdata;
43 : : int r;
44 : :
45 [ # # ]: 0 : assert(message);
46 [ # # ]: 0 : assert(j);
47 : :
48 : 0 : r = mac_selinux_unit_access_check(j->unit, message, "stop", error);
49 [ # # ]: 0 : if (r < 0)
50 : 0 : return r;
51 : :
52 : : /* Access is granted to the job owner */
53 [ # # ]: 0 : if (!sd_bus_track_contains(j->bus_track, sd_bus_message_get_sender(message))) {
54 : :
55 : : /* And for everybody else consult polkit */
56 : 0 : r = bus_verify_manage_units_async(j->unit->manager, message, error);
57 [ # # ]: 0 : if (r < 0)
58 : 0 : return r;
59 [ # # ]: 0 : if (r == 0)
60 : 0 : return 1; /* No authorization for now, but the async polkit stuff will call us again when it has it */
61 : : }
62 : :
63 : 0 : job_finish_and_invalidate(j, JOB_CANCELED, true, false);
64 : :
65 : 0 : return sd_bus_reply_method_return(message, NULL);
66 : : }
67 : :
68 : 0 : int bus_job_method_get_waiting_jobs(sd_bus_message *message, void *userdata, sd_bus_error *error) {
69 : 0 : _cleanup_(sd_bus_message_unrefp) sd_bus_message *reply = NULL;
70 : 0 : _cleanup_free_ Job **list = NULL;
71 : 0 : Job *j = userdata;
72 : : int r, i, n;
73 : :
74 [ # # ]: 0 : if (strstr(sd_bus_message_get_member(message), "After"))
75 : 0 : n = job_get_after(j, &list);
76 : : else
77 : 0 : n = job_get_before(j, &list);
78 [ # # ]: 0 : if (n < 0)
79 : 0 : return n;
80 : :
81 : 0 : r = sd_bus_message_new_method_return(message, &reply);
82 [ # # ]: 0 : if (r < 0)
83 : 0 : return r;
84 : :
85 : 0 : r = sd_bus_message_open_container(reply, 'a', "(usssoo)");
86 [ # # ]: 0 : if (r < 0)
87 : 0 : return r;
88 : :
89 [ # # ]: 0 : for (i = 0; i < n; i ++) {
90 [ # # # # ]: 0 : _cleanup_free_ char *unit_path = NULL, *job_path = NULL;
91 : :
92 : 0 : job_path = job_dbus_path(list[i]);
93 [ # # ]: 0 : if (!job_path)
94 : 0 : return -ENOMEM;
95 : :
96 : 0 : unit_path = unit_dbus_path(list[i]->unit);
97 [ # # ]: 0 : if (!unit_path)
98 : 0 : return -ENOMEM;
99 : :
100 : 0 : r = sd_bus_message_append(reply, "(usssoo)",
101 : 0 : list[i]->id,
102 : 0 : list[i]->unit->id,
103 : 0 : job_type_to_string(list[i]->type),
104 : 0 : job_state_to_string(list[i]->state),
105 : : job_path,
106 : : unit_path);
107 [ # # ]: 0 : if (r < 0)
108 : 0 : return r;
109 : : }
110 : :
111 : 0 : r = sd_bus_message_close_container(reply);
112 [ # # ]: 0 : if (r < 0)
113 : 0 : return r;
114 : :
115 : 0 : return sd_bus_send(NULL, reply, NULL);
116 : : }
117 : :
118 : : const sd_bus_vtable bus_job_vtable[] = {
119 : : SD_BUS_VTABLE_START(0),
120 : : SD_BUS_METHOD("Cancel", NULL, NULL, bus_job_method_cancel, SD_BUS_VTABLE_UNPRIVILEGED),
121 : : SD_BUS_METHOD("GetAfter", NULL, "a(usssoo)", bus_job_method_get_waiting_jobs, SD_BUS_VTABLE_UNPRIVILEGED),
122 : : SD_BUS_METHOD("GetBefore", NULL, "a(usssoo)", bus_job_method_get_waiting_jobs, SD_BUS_VTABLE_UNPRIVILEGED),
123 : : SD_BUS_PROPERTY("Id", "u", NULL, offsetof(Job, id), SD_BUS_VTABLE_PROPERTY_CONST),
124 : : SD_BUS_PROPERTY("Unit", "(so)", property_get_unit, 0, SD_BUS_VTABLE_PROPERTY_CONST),
125 : : SD_BUS_PROPERTY("JobType", "s", property_get_type, offsetof(Job, type), SD_BUS_VTABLE_PROPERTY_CONST),
126 : : SD_BUS_PROPERTY("State", "s", property_get_state, offsetof(Job, state), SD_BUS_VTABLE_PROPERTY_EMITS_CHANGE),
127 : : SD_BUS_VTABLE_END
128 : : };
129 : :
130 : 0 : static int send_new_signal(sd_bus *bus, void *userdata) {
131 : 0 : _cleanup_(sd_bus_message_unrefp) sd_bus_message *m = NULL;
132 : 0 : _cleanup_free_ char *p = NULL;
133 : 0 : Job *j = userdata;
134 : : int r;
135 : :
136 [ # # ]: 0 : assert(bus);
137 [ # # ]: 0 : assert(j);
138 : :
139 : 0 : p = job_dbus_path(j);
140 [ # # ]: 0 : if (!p)
141 : 0 : return -ENOMEM;
142 : :
143 : 0 : r = sd_bus_message_new_signal(
144 : : bus,
145 : : &m,
146 : : "/org/freedesktop/systemd1",
147 : : "org.freedesktop.systemd1.Manager",
148 : : "JobNew");
149 [ # # ]: 0 : if (r < 0)
150 : 0 : return r;
151 : :
152 : 0 : r = sd_bus_message_append(m, "uos", j->id, p, j->unit->id);
153 [ # # ]: 0 : if (r < 0)
154 : 0 : return r;
155 : :
156 : 0 : return sd_bus_send(bus, m, NULL);
157 : : }
158 : :
159 : 0 : static int send_changed_signal(sd_bus *bus, void *userdata) {
160 : 0 : _cleanup_free_ char *p = NULL;
161 : 0 : Job *j = userdata;
162 : :
163 [ # # ]: 0 : assert(bus);
164 [ # # ]: 0 : assert(j);
165 : :
166 : 0 : p = job_dbus_path(j);
167 [ # # ]: 0 : if (!p)
168 : 0 : return -ENOMEM;
169 : :
170 : 0 : return sd_bus_emit_properties_changed(bus, p, "org.freedesktop.systemd1.Job", "State", NULL);
171 : : }
172 : :
173 : 200 : void bus_job_send_change_signal(Job *j) {
174 : : int r;
175 : :
176 [ - + ]: 200 : assert(j);
177 : :
178 : : /* Make sure that any change signal on the unit is reflected before we send out the change signal on the job */
179 : 200 : bus_unit_send_pending_change_signal(j->unit, true);
180 : :
181 [ + - ]: 200 : if (j->in_dbus_queue) {
182 [ - + + + : 200 : LIST_REMOVE(dbus_queue, j->manager->dbus_job_queue, j);
+ + - + ]
183 : 200 : j->in_dbus_queue = false;
184 : : }
185 : :
186 [ - + ]: 200 : r = bus_foreach_bus(j->manager, j->bus_track, j->sent_dbus_new_signal ? send_changed_signal : send_new_signal, j);
187 [ - + ]: 200 : if (r < 0)
188 [ # # ]: 0 : log_debug_errno(r, "Failed to send job change signal for %u: %m", j->id);
189 : :
190 : 200 : j->sent_dbus_new_signal = true;
191 : 200 : }
192 : :
193 : 0 : void bus_job_send_pending_change_signal(Job *j, bool including_new) {
194 [ # # ]: 0 : assert(j);
195 : :
196 [ # # ]: 0 : if (!j->in_dbus_queue)
197 : 0 : return;
198 : :
199 [ # # # # ]: 0 : if (!j->sent_dbus_new_signal && !including_new)
200 : 0 : return;
201 : :
202 [ # # ]: 0 : if (MANAGER_IS_RELOADING(j->unit->manager))
203 : 0 : return;
204 : :
205 : 0 : bus_job_send_change_signal(j);
206 : : }
207 : :
208 : 0 : static int send_removed_signal(sd_bus *bus, void *userdata) {
209 : 0 : _cleanup_(sd_bus_message_unrefp) sd_bus_message *m = NULL;
210 : 0 : _cleanup_free_ char *p = NULL;
211 : 0 : Job *j = userdata;
212 : : int r;
213 : :
214 [ # # ]: 0 : assert(bus);
215 [ # # ]: 0 : assert(j);
216 : :
217 : 0 : p = job_dbus_path(j);
218 [ # # ]: 0 : if (!p)
219 : 0 : return -ENOMEM;
220 : :
221 : 0 : r = sd_bus_message_new_signal(
222 : : bus,
223 : : &m,
224 : : "/org/freedesktop/systemd1",
225 : : "org.freedesktop.systemd1.Manager",
226 : : "JobRemoved");
227 [ # # ]: 0 : if (r < 0)
228 : 0 : return r;
229 : :
230 : 0 : r = sd_bus_message_append(m, "uoss", j->id, p, j->unit->id, job_result_to_string(j->result));
231 [ # # ]: 0 : if (r < 0)
232 : 0 : return r;
233 : :
234 : 0 : return sd_bus_send(bus, m, NULL);
235 : : }
236 : :
237 : 200 : void bus_job_send_removed_signal(Job *j) {
238 : : int r;
239 : :
240 [ - + ]: 200 : assert(j);
241 : :
242 [ + - ]: 200 : if (!j->sent_dbus_new_signal)
243 : 200 : bus_job_send_change_signal(j);
244 : :
245 : : /* Make sure that any change signal on the unit is reflected before we send out the change signal on the job */
246 : 200 : bus_unit_send_pending_change_signal(j->unit, true);
247 : :
248 : 200 : r = bus_foreach_bus(j->manager, j->bus_track, send_removed_signal, j);
249 [ - + ]: 200 : if (r < 0)
250 [ # # ]: 0 : log_debug_errno(r, "Failed to send job remove signal for %u: %m", j->id);
251 : 200 : }
252 : :
253 : 0 : static int bus_job_track_handler(sd_bus_track *t, void *userdata) {
254 : 0 : Job *j = userdata;
255 : :
256 [ # # ]: 0 : assert(t);
257 [ # # ]: 0 : assert(j);
258 : :
259 : 0 : j->bus_track = sd_bus_track_unref(j->bus_track); /* make sure we aren't called again */
260 : :
261 : : /* Last client dropped off the bus, maybe we should GC this now? */
262 : 0 : job_add_to_gc_queue(j);
263 : 0 : return 0;
264 : : }
265 : :
266 : 0 : static int bus_job_allocate_bus_track(Job *j) {
267 : :
268 [ # # ]: 0 : assert(j);
269 : :
270 [ # # ]: 0 : if (j->bus_track)
271 : 0 : return 0;
272 : :
273 : 0 : return sd_bus_track_new(j->unit->manager->api_bus, &j->bus_track, bus_job_track_handler, j);
274 : : }
275 : :
276 : 0 : int bus_job_coldplug_bus_track(Job *j) {
277 : 0 : int r = 0;
278 : 0 : _cleanup_strv_free_ char **deserialized_clients = NULL;
279 : :
280 [ # # ]: 0 : assert(j);
281 : :
282 : 0 : deserialized_clients = TAKE_PTR(j->deserialized_clients);
283 : :
284 [ # # ]: 0 : if (strv_isempty(deserialized_clients))
285 : 0 : return 0;
286 : :
287 [ # # ]: 0 : if (!j->manager->api_bus)
288 : 0 : return 0;
289 : :
290 : 0 : r = bus_job_allocate_bus_track(j);
291 [ # # ]: 0 : if (r < 0)
292 : 0 : return r;
293 : :
294 : 0 : return bus_track_add_name_many(j->bus_track, deserialized_clients);
295 : : }
296 : :
297 : 0 : int bus_job_track_sender(Job *j, sd_bus_message *m) {
298 : : int r;
299 : :
300 [ # # ]: 0 : assert(j);
301 [ # # ]: 0 : assert(m);
302 : :
303 [ # # ]: 0 : if (sd_bus_message_get_bus(m) != j->unit->manager->api_bus) {
304 : 0 : j->ref_by_private_bus = true;
305 : 0 : return 0;
306 : : }
307 : :
308 : 0 : r = bus_job_allocate_bus_track(j);
309 [ # # ]: 0 : if (r < 0)
310 : 0 : return r;
311 : :
312 : 0 : return sd_bus_track_add_sender(j->bus_track, m);
313 : : }
|
