]> git.ipfire.org Git - thirdparty/systemd.git/blob - src/login/logind-dbus.c
stat-util: fix dir_is_empty_at without path
[thirdparty/systemd.git] / src / login / logind-dbus.c
1 /* SPDX-License-Identifier: LGPL-2.1-or-later */
2
3 #include <errno.h>
4 #include <sys/stat.h>
5 #include <unistd.h>
6
7 #include "sd-device.h"
8 #include "sd-messages.h"
9
10 #include "alloc-util.h"
11 #include "audit-util.h"
12 #include "bootspec.h"
13 #include "bus-common-errors.h"
14 #include "bus-error.h"
15 #include "bus-get-properties.h"
16 #include "bus-locator.h"
17 #include "bus-polkit.h"
18 #include "bus-unit-util.h"
19 #include "bus-util.h"
20 #include "cgroup-util.h"
21 #include "device-util.h"
22 #include "dirent-util.h"
23 #include "efi-loader.h"
24 #include "efivars.h"
25 #include "env-util.h"
26 #include "escape.h"
27 #include "fd-util.h"
28 #include "fileio-label.h"
29 #include "fileio.h"
30 #include "format-util.h"
31 #include "fs-util.h"
32 #include "logind-dbus.h"
33 #include "logind-seat-dbus.h"
34 #include "logind-session-dbus.h"
35 #include "logind-user-dbus.h"
36 #include "logind.h"
37 #include "missing_capability.h"
38 #include "mkdir.h"
39 #include "parse-util.h"
40 #include "path-util.h"
41 #include "process-util.h"
42 #include "reboot-util.h"
43 #include "selinux-util.h"
44 #include "sleep-config.h"
45 #include "special.h"
46 #include "stdio-util.h"
47 #include "strv.h"
48 #include "terminal-util.h"
49 #include "tmpfile-util.h"
50 #include "unit-name.h"
51 #include "user-util.h"
52 #include "utmp-wtmp.h"
53 #include "virt.h"
54
55 static int get_sender_session(
56 Manager *m,
57 sd_bus_message *message,
58 bool consult_display,
59 sd_bus_error *error,
60 Session **ret) {
61
62 _cleanup_(sd_bus_creds_unrefp) sd_bus_creds *creds = NULL;
63 Session *session = NULL;
64 const char *name;
65 int r;
66
67 /* Acquire the sender's session. This first checks if the sending process is inside a session itself,
68 * and returns that. If not and 'consult_display' is true, this returns the display session of the
69 * owning user of the caller. */
70
71 r = sd_bus_query_sender_creds(message,
72 SD_BUS_CREDS_SESSION|SD_BUS_CREDS_AUGMENT|
73 (consult_display ? SD_BUS_CREDS_OWNER_UID : 0), &creds);
74 if (r < 0)
75 return r;
76
77 r = sd_bus_creds_get_session(creds, &name);
78 if (r < 0) {
79 if (r != -ENXIO)
80 return r;
81
82 if (consult_display) {
83 uid_t uid;
84
85 r = sd_bus_creds_get_owner_uid(creds, &uid);
86 if (r < 0) {
87 if (r != -ENXIO)
88 return r;
89 } else {
90 User *user;
91
92 user = hashmap_get(m->users, UID_TO_PTR(uid));
93 if (user)
94 session = user->display;
95 }
96 }
97 } else
98 session = hashmap_get(m->sessions, name);
99
100 if (!session)
101 return sd_bus_error_setf(error, BUS_ERROR_NO_SESSION_FOR_PID,
102 consult_display ?
103 "Caller does not belong to any known session and doesn't own any suitable session." :
104 "Caller does not belong to any known session.");
105
106 *ret = session;
107 return 0;
108 }
109
110 int manager_get_session_from_creds(
111 Manager *m,
112 sd_bus_message *message,
113 const char *name,
114 sd_bus_error *error,
115 Session **ret) {
116
117 Session *session;
118
119 assert(m);
120 assert(ret);
121
122 if (SEAT_IS_SELF(name)) /* the caller's own session */
123 return get_sender_session(m, message, false, error, ret);
124 if (SEAT_IS_AUTO(name)) /* The caller's own session if they have one, otherwise their user's display session */
125 return get_sender_session(m, message, true, error, ret);
126
127 session = hashmap_get(m->sessions, name);
128 if (!session)
129 return sd_bus_error_setf(error, BUS_ERROR_NO_SUCH_SESSION, "No session '%s' known", name);
130
131 *ret = session;
132 return 0;
133 }
134
135 static int get_sender_user(Manager *m, sd_bus_message *message, sd_bus_error *error, User **ret) {
136 _cleanup_(sd_bus_creds_unrefp) sd_bus_creds *creds = NULL;
137 uid_t uid;
138 User *user;
139 int r;
140
141 /* Note that we get the owner UID of the session, not the actual client UID here! */
142 r = sd_bus_query_sender_creds(message, SD_BUS_CREDS_OWNER_UID|SD_BUS_CREDS_AUGMENT, &creds);
143 if (r < 0)
144 return r;
145
146 r = sd_bus_creds_get_owner_uid(creds, &uid);
147 if (r < 0) {
148 if (r != -ENXIO)
149 return r;
150
151 user = NULL;
152 } else
153 user = hashmap_get(m->users, UID_TO_PTR(uid));
154
155 if (!user)
156 return sd_bus_error_setf(error, BUS_ERROR_NO_USER_FOR_PID,
157 "Caller does not belong to any logged in or lingering user");
158
159 *ret = user;
160 return 0;
161 }
162
163 int manager_get_user_from_creds(Manager *m, sd_bus_message *message, uid_t uid, sd_bus_error *error, User **ret) {
164 User *user;
165
166 assert(m);
167 assert(ret);
168
169 if (!uid_is_valid(uid))
170 return get_sender_user(m, message, error, ret);
171
172 user = hashmap_get(m->users, UID_TO_PTR(uid));
173 if (!user)
174 return sd_bus_error_setf(error, BUS_ERROR_NO_SUCH_USER,
175 "User ID "UID_FMT" is not logged in or lingering", uid);
176
177 *ret = user;
178 return 0;
179 }
180
181 int manager_get_seat_from_creds(
182 Manager *m,
183 sd_bus_message *message,
184 const char *name,
185 sd_bus_error *error,
186 Seat **ret) {
187
188 Seat *seat;
189 int r;
190
191 assert(m);
192 assert(ret);
193
194 if (SEAT_IS_SELF(name) || SEAT_IS_AUTO(name)) {
195 Session *session;
196
197 /* Use these special seat names as session names */
198 r = manager_get_session_from_creds(m, message, name, error, &session);
199 if (r < 0)
200 return r;
201
202 seat = session->seat;
203 if (!seat)
204 return sd_bus_error_setf(error, BUS_ERROR_NO_SUCH_SEAT, "Session '%s' has no seat.", session->id);
205 } else {
206 seat = hashmap_get(m->seats, name);
207 if (!seat)
208 return sd_bus_error_setf(error, BUS_ERROR_NO_SUCH_SEAT, "No seat '%s' known", name);
209 }
210
211 *ret = seat;
212 return 0;
213 }
214
215 static int return_test_polkit(
216 sd_bus_message *message,
217 int capability,
218 const char *action,
219 const char **details,
220 uid_t good_user,
221 sd_bus_error *e) {
222
223 const char *result;
224 bool challenge;
225 int r;
226
227 r = bus_test_polkit(message, capability, action, details, good_user, &challenge, e);
228 if (r < 0)
229 return r;
230
231 if (r > 0)
232 result = "yes";
233 else if (challenge)
234 result = "challenge";
235 else
236 result = "no";
237
238 return sd_bus_reply_method_return(message, "s", result);
239 }
240
241 static int property_get_idle_hint(
242 sd_bus *bus,
243 const char *path,
244 const char *interface,
245 const char *property,
246 sd_bus_message *reply,
247 void *userdata,
248 sd_bus_error *error) {
249
250 Manager *m = userdata;
251
252 assert(bus);
253 assert(reply);
254 assert(m);
255
256 return sd_bus_message_append(reply, "b", manager_get_idle_hint(m, NULL) > 0);
257 }
258
259 static int property_get_idle_since_hint(
260 sd_bus *bus,
261 const char *path,
262 const char *interface,
263 const char *property,
264 sd_bus_message *reply,
265 void *userdata,
266 sd_bus_error *error) {
267
268 Manager *m = userdata;
269 dual_timestamp t = DUAL_TIMESTAMP_NULL;
270
271 assert(bus);
272 assert(reply);
273 assert(m);
274
275 manager_get_idle_hint(m, &t);
276
277 return sd_bus_message_append(reply, "t", streq(property, "IdleSinceHint") ? t.realtime : t.monotonic);
278 }
279
280 static int property_get_inhibited(
281 sd_bus *bus,
282 const char *path,
283 const char *interface,
284 const char *property,
285 sd_bus_message *reply,
286 void *userdata,
287 sd_bus_error *error) {
288
289 Manager *m = userdata;
290 InhibitWhat w;
291
292 assert(bus);
293 assert(reply);
294 assert(m);
295
296 w = manager_inhibit_what(m, streq(property, "BlockInhibited") ? INHIBIT_BLOCK : INHIBIT_DELAY);
297
298 return sd_bus_message_append(reply, "s", inhibit_what_to_string(w));
299 }
300
301 static int property_get_preparing(
302 sd_bus *bus,
303 const char *path,
304 const char *interface,
305 const char *property,
306 sd_bus_message *reply,
307 void *userdata,
308 sd_bus_error *error) {
309
310 Manager *m = userdata;
311 bool b;
312
313 assert(bus);
314 assert(reply);
315 assert(m);
316
317 if (streq(property, "PreparingForShutdown"))
318 b = m->action_what & INHIBIT_SHUTDOWN;
319 else
320 b = m->action_what & INHIBIT_SLEEP;
321
322 return sd_bus_message_append(reply, "b", b);
323 }
324
325 static int property_get_scheduled_shutdown(
326 sd_bus *bus,
327 const char *path,
328 const char *interface,
329 const char *property,
330 sd_bus_message *reply,
331 void *userdata,
332 sd_bus_error *error) {
333
334 Manager *m = userdata;
335 int r;
336
337 assert(bus);
338 assert(reply);
339 assert(m);
340
341 r = sd_bus_message_open_container(reply, 'r', "st");
342 if (r < 0)
343 return r;
344
345 r = sd_bus_message_append(reply, "st", m->scheduled_shutdown_type, m->scheduled_shutdown_timeout);
346 if (r < 0)
347 return r;
348
349 return sd_bus_message_close_container(reply);
350 }
351
352 static BUS_DEFINE_PROPERTY_GET_ENUM(property_get_handle_action, handle_action, HandleAction);
353 static BUS_DEFINE_PROPERTY_GET(property_get_docked, "b", Manager, manager_is_docked_or_external_displays);
354 static BUS_DEFINE_PROPERTY_GET(property_get_lid_closed, "b", Manager, manager_is_lid_closed);
355 static BUS_DEFINE_PROPERTY_GET_GLOBAL(property_get_on_external_power, "b", manager_is_on_external_power);
356 static BUS_DEFINE_PROPERTY_GET_GLOBAL(property_get_compat_user_tasks_max, "t", CGROUP_LIMIT_MAX);
357 static BUS_DEFINE_PROPERTY_GET_REF(property_get_hashmap_size, "t", Hashmap *, (uint64_t) hashmap_size);
358
359 static int method_get_session(sd_bus_message *message, void *userdata, sd_bus_error *error) {
360 _cleanup_free_ char *p = NULL;
361 Manager *m = userdata;
362 const char *name;
363 Session *session;
364 int r;
365
366 assert(message);
367 assert(m);
368
369 r = sd_bus_message_read(message, "s", &name);
370 if (r < 0)
371 return r;
372
373 r = manager_get_session_from_creds(m, message, name, error, &session);
374 if (r < 0)
375 return r;
376
377 p = session_bus_path(session);
378 if (!p)
379 return -ENOMEM;
380
381 return sd_bus_reply_method_return(message, "o", p);
382 }
383
384 /* Get login session of a process. This is not what you are looking for these days,
385 * as apps may instead belong to a user service unit. This includes terminal
386 * emulators and hence command-line apps. */
387 static int method_get_session_by_pid(sd_bus_message *message, void *userdata, sd_bus_error *error) {
388 _cleanup_free_ char *p = NULL;
389 Session *session = NULL;
390 Manager *m = userdata;
391 pid_t pid;
392 int r;
393
394 assert(message);
395 assert(m);
396
397 assert_cc(sizeof(pid_t) == sizeof(uint32_t));
398
399 r = sd_bus_message_read(message, "u", &pid);
400 if (r < 0)
401 return r;
402 if (pid < 0)
403 return -EINVAL;
404
405 if (pid == 0) {
406 r = manager_get_session_from_creds(m, message, NULL, error, &session);
407 if (r < 0)
408 return r;
409 } else {
410 r = manager_get_session_by_pid(m, pid, &session);
411 if (r < 0)
412 return r;
413
414 if (!session)
415 return sd_bus_error_setf(error, BUS_ERROR_NO_SESSION_FOR_PID,
416 "PID "PID_FMT" does not belong to any known session", pid);
417 }
418
419 p = session_bus_path(session);
420 if (!p)
421 return -ENOMEM;
422
423 return sd_bus_reply_method_return(message, "o", p);
424 }
425
426 static int method_get_user(sd_bus_message *message, void *userdata, sd_bus_error *error) {
427 _cleanup_free_ char *p = NULL;
428 Manager *m = userdata;
429 uint32_t uid;
430 User *user;
431 int r;
432
433 assert(message);
434 assert(m);
435
436 r = sd_bus_message_read(message, "u", &uid);
437 if (r < 0)
438 return r;
439
440 r = manager_get_user_from_creds(m, message, uid, error, &user);
441 if (r < 0)
442 return r;
443
444 p = user_bus_path(user);
445 if (!p)
446 return -ENOMEM;
447
448 return sd_bus_reply_method_return(message, "o", p);
449 }
450
451 static int method_get_user_by_pid(sd_bus_message *message, void *userdata, sd_bus_error *error) {
452 _cleanup_free_ char *p = NULL;
453 Manager *m = userdata;
454 User *user = NULL;
455 pid_t pid;
456 int r;
457
458 assert(message);
459 assert(m);
460
461 assert_cc(sizeof(pid_t) == sizeof(uint32_t));
462
463 r = sd_bus_message_read(message, "u", &pid);
464 if (r < 0)
465 return r;
466 if (pid < 0)
467 return -EINVAL;
468
469 if (pid == 0) {
470 r = manager_get_user_from_creds(m, message, UID_INVALID, error, &user);
471 if (r < 0)
472 return r;
473 } else {
474 r = manager_get_user_by_pid(m, pid, &user);
475 if (r < 0)
476 return r;
477 if (!user)
478 return sd_bus_error_setf(error, BUS_ERROR_NO_USER_FOR_PID,
479 "PID "PID_FMT" does not belong to any logged in user or lingering user",
480 pid);
481 }
482
483 p = user_bus_path(user);
484 if (!p)
485 return -ENOMEM;
486
487 return sd_bus_reply_method_return(message, "o", p);
488 }
489
490 static int method_get_seat(sd_bus_message *message, void *userdata, sd_bus_error *error) {
491 _cleanup_free_ char *p = NULL;
492 Manager *m = userdata;
493 const char *name;
494 Seat *seat;
495 int r;
496
497 assert(message);
498 assert(m);
499
500 r = sd_bus_message_read(message, "s", &name);
501 if (r < 0)
502 return r;
503
504 r = manager_get_seat_from_creds(m, message, name, error, &seat);
505 if (r < 0)
506 return r;
507
508 p = seat_bus_path(seat);
509 if (!p)
510 return -ENOMEM;
511
512 return sd_bus_reply_method_return(message, "o", p);
513 }
514
515 static int method_list_sessions(sd_bus_message *message, void *userdata, sd_bus_error *error) {
516 _cleanup_(sd_bus_message_unrefp) sd_bus_message *reply = NULL;
517 Manager *m = userdata;
518 Session *session;
519 int r;
520
521 assert(message);
522 assert(m);
523
524 r = sd_bus_message_new_method_return(message, &reply);
525 if (r < 0)
526 return r;
527
528 r = sd_bus_message_open_container(reply, 'a', "(susso)");
529 if (r < 0)
530 return r;
531
532 HASHMAP_FOREACH(session, m->sessions) {
533 _cleanup_free_ char *p = NULL;
534
535 p = session_bus_path(session);
536 if (!p)
537 return -ENOMEM;
538
539 r = sd_bus_message_append(reply, "(susso)",
540 session->id,
541 (uint32_t) session->user->user_record->uid,
542 session->user->user_record->user_name,
543 session->seat ? session->seat->id : "",
544 p);
545 if (r < 0)
546 return r;
547 }
548
549 r = sd_bus_message_close_container(reply);
550 if (r < 0)
551 return r;
552
553 return sd_bus_send(NULL, reply, NULL);
554 }
555
556 static int method_list_users(sd_bus_message *message, void *userdata, sd_bus_error *error) {
557 _cleanup_(sd_bus_message_unrefp) sd_bus_message *reply = NULL;
558 Manager *m = userdata;
559 User *user;
560 int r;
561
562 assert(message);
563 assert(m);
564
565 r = sd_bus_message_new_method_return(message, &reply);
566 if (r < 0)
567 return r;
568
569 r = sd_bus_message_open_container(reply, 'a', "(uso)");
570 if (r < 0)
571 return r;
572
573 HASHMAP_FOREACH(user, m->users) {
574 _cleanup_free_ char *p = NULL;
575
576 p = user_bus_path(user);
577 if (!p)
578 return -ENOMEM;
579
580 r = sd_bus_message_append(reply, "(uso)",
581 (uint32_t) user->user_record->uid,
582 user->user_record->user_name,
583 p);
584 if (r < 0)
585 return r;
586 }
587
588 r = sd_bus_message_close_container(reply);
589 if (r < 0)
590 return r;
591
592 return sd_bus_send(NULL, reply, NULL);
593 }
594
595 static int method_list_seats(sd_bus_message *message, void *userdata, sd_bus_error *error) {
596 _cleanup_(sd_bus_message_unrefp) sd_bus_message *reply = NULL;
597 Manager *m = userdata;
598 Seat *seat;
599 int r;
600
601 assert(message);
602 assert(m);
603
604 r = sd_bus_message_new_method_return(message, &reply);
605 if (r < 0)
606 return r;
607
608 r = sd_bus_message_open_container(reply, 'a', "(so)");
609 if (r < 0)
610 return r;
611
612 HASHMAP_FOREACH(seat, m->seats) {
613 _cleanup_free_ char *p = NULL;
614
615 p = seat_bus_path(seat);
616 if (!p)
617 return -ENOMEM;
618
619 r = sd_bus_message_append(reply, "(so)", seat->id, p);
620 if (r < 0)
621 return r;
622 }
623
624 r = sd_bus_message_close_container(reply);
625 if (r < 0)
626 return r;
627
628 return sd_bus_send(NULL, reply, NULL);
629 }
630
631 static int method_list_inhibitors(sd_bus_message *message, void *userdata, sd_bus_error *error) {
632 _cleanup_(sd_bus_message_unrefp) sd_bus_message *reply = NULL;
633 Manager *m = userdata;
634 Inhibitor *inhibitor;
635 int r;
636
637 assert(message);
638 assert(m);
639
640 r = sd_bus_message_new_method_return(message, &reply);
641 if (r < 0)
642 return r;
643
644 r = sd_bus_message_open_container(reply, 'a', "(ssssuu)");
645 if (r < 0)
646 return r;
647
648 HASHMAP_FOREACH(inhibitor, m->inhibitors) {
649
650 r = sd_bus_message_append(reply, "(ssssuu)",
651 strempty(inhibit_what_to_string(inhibitor->what)),
652 strempty(inhibitor->who),
653 strempty(inhibitor->why),
654 strempty(inhibit_mode_to_string(inhibitor->mode)),
655 (uint32_t) inhibitor->uid,
656 (uint32_t) inhibitor->pid);
657 if (r < 0)
658 return r;
659 }
660
661 r = sd_bus_message_close_container(reply);
662 if (r < 0)
663 return r;
664
665 return sd_bus_send(NULL, reply, NULL);
666 }
667
668 static int method_create_session(sd_bus_message *message, void *userdata, sd_bus_error *error) {
669 const char *service, *type, *class, *cseat, *tty, *display, *remote_user, *remote_host, *desktop;
670 _cleanup_free_ char *id = NULL;
671 Session *session = NULL;
672 uint32_t audit_id = 0;
673 Manager *m = userdata;
674 User *user = NULL;
675 Seat *seat = NULL;
676 pid_t leader;
677 uid_t uid;
678 int remote;
679 uint32_t vtnr = 0;
680 SessionType t;
681 SessionClass c;
682 int r;
683
684 assert(message);
685 assert(m);
686
687 assert_cc(sizeof(pid_t) == sizeof(uint32_t));
688 assert_cc(sizeof(uid_t) == sizeof(uint32_t));
689
690 r = sd_bus_message_read(message, "uusssssussbss",
691 &uid, &leader, &service, &type, &class, &desktop, &cseat,
692 &vtnr, &tty, &display, &remote, &remote_user, &remote_host);
693 if (r < 0)
694 return r;
695
696 if (!uid_is_valid(uid))
697 return sd_bus_error_setf(error, SD_BUS_ERROR_INVALID_ARGS, "Invalid UID");
698 if (leader < 0 || leader == 1 || leader == getpid_cached())
699 return sd_bus_error_setf(error, SD_BUS_ERROR_INVALID_ARGS, "Invalid leader PID");
700
701 if (isempty(type))
702 t = _SESSION_TYPE_INVALID;
703 else {
704 t = session_type_from_string(type);
705 if (t < 0)
706 return sd_bus_error_setf(error, SD_BUS_ERROR_INVALID_ARGS,
707 "Invalid session type %s", type);
708 }
709
710 if (isempty(class))
711 c = _SESSION_CLASS_INVALID;
712 else {
713 c = session_class_from_string(class);
714 if (c < 0)
715 return sd_bus_error_setf(error, SD_BUS_ERROR_INVALID_ARGS,
716 "Invalid session class %s", class);
717 }
718
719 if (isempty(desktop))
720 desktop = NULL;
721 else {
722 if (!string_is_safe(desktop))
723 return sd_bus_error_setf(error, SD_BUS_ERROR_INVALID_ARGS,
724 "Invalid desktop string %s", desktop);
725 }
726
727 if (isempty(cseat))
728 seat = NULL;
729 else {
730 seat = hashmap_get(m->seats, cseat);
731 if (!seat)
732 return sd_bus_error_setf(error, BUS_ERROR_NO_SUCH_SEAT,
733 "No seat '%s' known", cseat);
734 }
735
736 if (tty_is_vc(tty)) {
737 int v;
738
739 if (!seat)
740 seat = m->seat0;
741 else if (seat != m->seat0)
742 return sd_bus_error_setf(error, SD_BUS_ERROR_INVALID_ARGS,
743 "TTY %s is virtual console but seat %s is not seat0", tty, seat->id);
744
745 v = vtnr_from_tty(tty);
746 if (v <= 0)
747 return sd_bus_error_setf(error, SD_BUS_ERROR_INVALID_ARGS,
748 "Cannot determine VT number from virtual console TTY %s", tty);
749
750 if (vtnr == 0)
751 vtnr = (uint32_t) v;
752 else if (vtnr != (uint32_t) v)
753 return sd_bus_error_setf(error, SD_BUS_ERROR_INVALID_ARGS,
754 "Specified TTY and VT number do not match");
755
756 } else if (tty_is_console(tty)) {
757
758 if (!seat)
759 seat = m->seat0;
760 else if (seat != m->seat0)
761 return sd_bus_error_setf(error, SD_BUS_ERROR_INVALID_ARGS,
762 "Console TTY specified but seat is not seat0");
763
764 if (vtnr != 0)
765 return sd_bus_error_setf(error, SD_BUS_ERROR_INVALID_ARGS,
766 "Console TTY specified but VT number is not 0");
767 }
768
769 if (seat) {
770 if (seat_has_vts(seat)) {
771 if (vtnr <= 0 || vtnr > 63)
772 return sd_bus_error_setf(error, SD_BUS_ERROR_INVALID_ARGS,
773 "VT number out of range");
774 } else {
775 if (vtnr != 0)
776 return sd_bus_error_setf(error, SD_BUS_ERROR_INVALID_ARGS,
777 "Seat has no VTs but VT number not 0");
778 }
779 }
780
781 if (t == _SESSION_TYPE_INVALID) {
782 if (!isempty(display))
783 t = SESSION_X11;
784 else if (!isempty(tty))
785 t = SESSION_TTY;
786 else
787 t = SESSION_UNSPECIFIED;
788 }
789
790 if (c == _SESSION_CLASS_INVALID) {
791 if (t == SESSION_UNSPECIFIED)
792 c = SESSION_BACKGROUND;
793 else
794 c = SESSION_USER;
795 }
796
797 if (leader == 0) {
798 _cleanup_(sd_bus_creds_unrefp) sd_bus_creds *creds = NULL;
799
800 r = sd_bus_query_sender_creds(message, SD_BUS_CREDS_PID, &creds);
801 if (r < 0)
802 return r;
803
804 r = sd_bus_creds_get_pid(creds, (pid_t*) &leader);
805 if (r < 0)
806 return r;
807 }
808
809 /* Check if we are already in a logind session. Or if we are in user@.service
810 * which is a special PAM session that avoids creating a logind session. */
811 r = manager_get_user_by_pid(m, leader, NULL);
812 if (r < 0)
813 return r;
814 if (r > 0)
815 return sd_bus_error_setf(error, BUS_ERROR_SESSION_BUSY,
816 "Already running in a session or user slice");
817
818 /*
819 * Old gdm and lightdm start the user-session on the same VT as
820 * the greeter session. But they destroy the greeter session
821 * after the user-session and want the user-session to take
822 * over the VT. We need to support this for
823 * backwards-compatibility, so make sure we allow new sessions
824 * on a VT that a greeter is running on. Furthermore, to allow
825 * re-logins, we have to allow a greeter to take over a used VT for
826 * the exact same reasons.
827 */
828 if (c != SESSION_GREETER &&
829 vtnr > 0 &&
830 vtnr < m->seat0->position_count &&
831 m->seat0->positions[vtnr] &&
832 m->seat0->positions[vtnr]->class != SESSION_GREETER)
833 return sd_bus_error_setf(error, BUS_ERROR_SESSION_BUSY, "Already occupied by a session");
834
835 if (hashmap_size(m->sessions) >= m->sessions_max)
836 return sd_bus_error_setf(error, SD_BUS_ERROR_LIMITS_EXCEEDED,
837 "Maximum number of sessions (%" PRIu64 ") reached, refusing further sessions.",
838 m->sessions_max);
839
840 (void) audit_session_from_pid(leader, &audit_id);
841 if (audit_session_is_valid(audit_id)) {
842 /* Keep our session IDs and the audit session IDs in sync */
843
844 if (asprintf(&id, "%"PRIu32, audit_id) < 0)
845 return -ENOMEM;
846
847 /* Wut? There's already a session by this name and we didn't find it above? Weird, then let's
848 * not trust the audit data and let's better register a new ID */
849 if (hashmap_contains(m->sessions, id)) {
850 log_warning("Existing logind session ID %s used by new audit session, ignoring.", id);
851 audit_id = AUDIT_SESSION_INVALID;
852 id = mfree(id);
853 }
854 }
855
856 if (!id) {
857 do {
858 id = mfree(id);
859
860 if (asprintf(&id, "c%lu", ++m->session_counter) < 0)
861 return -ENOMEM;
862
863 } while (hashmap_contains(m->sessions, id));
864 }
865
866 /* The generated names should not clash with 'auto' or 'self' */
867 assert(!SESSION_IS_SELF(id));
868 assert(!SESSION_IS_AUTO(id));
869
870 /* If we are not watching utmp already, try again */
871 manager_reconnect_utmp(m);
872
873 r = manager_add_user_by_uid(m, uid, &user);
874 if (r < 0)
875 goto fail;
876
877 r = manager_add_session(m, id, &session);
878 if (r < 0)
879 goto fail;
880
881 session_set_user(session, user);
882 r = session_set_leader(session, leader);
883 if (r < 0)
884 goto fail;
885
886 session->original_type = session->type = t;
887 session->class = c;
888 session->remote = remote;
889 session->vtnr = vtnr;
890
891 if (!isempty(tty)) {
892 session->tty = strdup(tty);
893 if (!session->tty) {
894 r = -ENOMEM;
895 goto fail;
896 }
897
898 session->tty_validity = TTY_FROM_PAM;
899 }
900
901 if (!isempty(display)) {
902 session->display = strdup(display);
903 if (!session->display) {
904 r = -ENOMEM;
905 goto fail;
906 }
907 }
908
909 if (!isempty(remote_user)) {
910 session->remote_user = strdup(remote_user);
911 if (!session->remote_user) {
912 r = -ENOMEM;
913 goto fail;
914 }
915 }
916
917 if (!isempty(remote_host)) {
918 session->remote_host = strdup(remote_host);
919 if (!session->remote_host) {
920 r = -ENOMEM;
921 goto fail;
922 }
923 }
924
925 if (!isempty(service)) {
926 session->service = strdup(service);
927 if (!session->service) {
928 r = -ENOMEM;
929 goto fail;
930 }
931 }
932
933 if (!isempty(desktop)) {
934 session->desktop = strdup(desktop);
935 if (!session->desktop) {
936 r = -ENOMEM;
937 goto fail;
938 }
939 }
940
941 if (seat) {
942 r = seat_attach_session(seat, session);
943 if (r < 0)
944 goto fail;
945 }
946
947 r = sd_bus_message_enter_container(message, 'a', "(sv)");
948 if (r < 0)
949 goto fail;
950
951 r = session_start(session, message, error);
952 if (r < 0)
953 goto fail;
954
955 r = sd_bus_message_exit_container(message);
956 if (r < 0)
957 goto fail;
958
959 session->create_message = sd_bus_message_ref(message);
960
961 /* Now, let's wait until the slice unit and stuff got created. We send the reply back from
962 * session_send_create_reply(). */
963
964 return 1;
965
966 fail:
967 if (session)
968 session_add_to_gc_queue(session);
969
970 if (user)
971 user_add_to_gc_queue(user);
972
973 return r;
974 }
975
976 static int method_release_session(sd_bus_message *message, void *userdata, sd_bus_error *error) {
977 Manager *m = userdata;
978 Session *session;
979 const char *name;
980 int r;
981
982 assert(message);
983 assert(m);
984
985 r = sd_bus_message_read(message, "s", &name);
986 if (r < 0)
987 return r;
988
989 r = manager_get_session_from_creds(m, message, name, error, &session);
990 if (r < 0)
991 return r;
992
993 r = session_release(session);
994 if (r < 0)
995 return r;
996
997 return sd_bus_reply_method_return(message, NULL);
998 }
999
1000 static int method_activate_session(sd_bus_message *message, void *userdata, sd_bus_error *error) {
1001 Manager *m = userdata;
1002 Session *session;
1003 const char *name;
1004 int r;
1005
1006 assert(message);
1007 assert(m);
1008
1009 r = sd_bus_message_read(message, "s", &name);
1010 if (r < 0)
1011 return r;
1012
1013 r = manager_get_session_from_creds(m, message, name, error, &session);
1014 if (r < 0)
1015 return r;
1016
1017 /* PolicyKit is done by bus_session_method_activate() */
1018
1019 return bus_session_method_activate(message, session, error);
1020 }
1021
1022 static int method_activate_session_on_seat(sd_bus_message *message, void *userdata, sd_bus_error *error) {
1023 const char *session_name, *seat_name;
1024 Manager *m = userdata;
1025 Session *session;
1026 Seat *seat;
1027 int r;
1028
1029 assert(message);
1030 assert(m);
1031
1032 /* Same as ActivateSession() but refuses to work if the seat doesn't match */
1033
1034 r = sd_bus_message_read(message, "ss", &session_name, &seat_name);
1035 if (r < 0)
1036 return r;
1037
1038 r = manager_get_session_from_creds(m, message, session_name, error, &session);
1039 if (r < 0)
1040 return r;
1041
1042 r = manager_get_seat_from_creds(m, message, seat_name, error, &seat);
1043 if (r < 0)
1044 return r;
1045
1046 if (session->seat != seat)
1047 return sd_bus_error_setf(error, BUS_ERROR_SESSION_NOT_ON_SEAT,
1048 "Session %s not on seat %s", session_name, seat_name);
1049
1050 r = bus_verify_polkit_async(
1051 message,
1052 CAP_SYS_ADMIN,
1053 "org.freedesktop.login1.chvt",
1054 NULL,
1055 false,
1056 UID_INVALID,
1057 &m->polkit_registry,
1058 error);
1059 if (r < 0)
1060 return r;
1061 if (r == 0)
1062 return 1; /* Will call us back */
1063
1064 r = session_activate(session);
1065 if (r < 0)
1066 return r;
1067
1068 return sd_bus_reply_method_return(message, NULL);
1069 }
1070
1071 static int method_lock_session(sd_bus_message *message, void *userdata, sd_bus_error *error) {
1072 Manager *m = userdata;
1073 Session *session;
1074 const char *name;
1075 int r;
1076
1077 assert(message);
1078 assert(m);
1079
1080 r = sd_bus_message_read(message, "s", &name);
1081 if (r < 0)
1082 return r;
1083
1084 r = manager_get_session_from_creds(m, message, name, error, &session);
1085 if (r < 0)
1086 return r;
1087
1088 return bus_session_method_lock(message, session, error);
1089 }
1090
1091 static int method_lock_sessions(sd_bus_message *message, void *userdata, sd_bus_error *error) {
1092 Manager *m = userdata;
1093 int r;
1094
1095 assert(message);
1096 assert(m);
1097
1098 r = bus_verify_polkit_async(
1099 message,
1100 CAP_SYS_ADMIN,
1101 "org.freedesktop.login1.lock-sessions",
1102 NULL,
1103 false,
1104 UID_INVALID,
1105 &m->polkit_registry,
1106 error);
1107 if (r < 0)
1108 return r;
1109 if (r == 0)
1110 return 1; /* Will call us back */
1111
1112 r = session_send_lock_all(m, streq(sd_bus_message_get_member(message), "LockSessions"));
1113 if (r < 0)
1114 return r;
1115
1116 return sd_bus_reply_method_return(message, NULL);
1117 }
1118
1119 static int method_kill_session(sd_bus_message *message, void *userdata, sd_bus_error *error) {
1120 const char *name;
1121 Manager *m = userdata;
1122 Session *session;
1123 int r;
1124
1125 assert(message);
1126 assert(m);
1127
1128 r = sd_bus_message_read(message, "s", &name);
1129 if (r < 0)
1130 return r;
1131
1132 r = manager_get_session_from_creds(m, message, name, error, &session);
1133 if (r < 0)
1134 return r;
1135
1136 return bus_session_method_kill(message, session, error);
1137 }
1138
1139 static int method_kill_user(sd_bus_message *message, void *userdata, sd_bus_error *error) {
1140 Manager *m = userdata;
1141 uint32_t uid;
1142 User *user;
1143 int r;
1144
1145 assert(message);
1146 assert(m);
1147
1148 r = sd_bus_message_read(message, "u", &uid);
1149 if (r < 0)
1150 return r;
1151
1152 r = manager_get_user_from_creds(m, message, uid, error, &user);
1153 if (r < 0)
1154 return r;
1155
1156 return bus_user_method_kill(message, user, error);
1157 }
1158
1159 static int method_terminate_session(sd_bus_message *message, void *userdata, sd_bus_error *error) {
1160 Manager *m = userdata;
1161 const char *name;
1162 Session *session;
1163 int r;
1164
1165 assert(message);
1166 assert(m);
1167
1168 r = sd_bus_message_read(message, "s", &name);
1169 if (r < 0)
1170 return r;
1171
1172 r = manager_get_session_from_creds(m, message, name, error, &session);
1173 if (r < 0)
1174 return r;
1175
1176 return bus_session_method_terminate(message, session, error);
1177 }
1178
1179 static int method_terminate_user(sd_bus_message *message, void *userdata, sd_bus_error *error) {
1180 Manager *m = userdata;
1181 uint32_t uid;
1182 User *user;
1183 int r;
1184
1185 assert(message);
1186 assert(m);
1187
1188 r = sd_bus_message_read(message, "u", &uid);
1189 if (r < 0)
1190 return r;
1191
1192 r = manager_get_user_from_creds(m, message, uid, error, &user);
1193 if (r < 0)
1194 return r;
1195
1196 return bus_user_method_terminate(message, user, error);
1197 }
1198
1199 static int method_terminate_seat(sd_bus_message *message, void *userdata, sd_bus_error *error) {
1200 Manager *m = userdata;
1201 const char *name;
1202 Seat *seat;
1203 int r;
1204
1205 assert(message);
1206 assert(m);
1207
1208 r = sd_bus_message_read(message, "s", &name);
1209 if (r < 0)
1210 return r;
1211
1212 r = manager_get_seat_from_creds(m, message, name, error, &seat);
1213 if (r < 0)
1214 return r;
1215
1216 return bus_seat_method_terminate(message, seat, error);
1217 }
1218
1219 static int method_set_user_linger(sd_bus_message *message, void *userdata, sd_bus_error *error) {
1220 _cleanup_(sd_bus_creds_unrefp) sd_bus_creds *creds = NULL;
1221 _cleanup_free_ char *cc = NULL;
1222 Manager *m = userdata;
1223 int r, b, interactive;
1224 struct passwd *pw;
1225 const char *path;
1226 uint32_t uid, auth_uid;
1227
1228 assert(message);
1229 assert(m);
1230
1231 r = sd_bus_message_read(message, "ubb", &uid, &b, &interactive);
1232 if (r < 0)
1233 return r;
1234
1235 r = sd_bus_query_sender_creds(message, SD_BUS_CREDS_EUID |
1236 SD_BUS_CREDS_OWNER_UID|SD_BUS_CREDS_AUGMENT, &creds);
1237 if (r < 0)
1238 return r;
1239
1240 if (!uid_is_valid(uid)) {
1241 /* Note that we get the owner UID of the session or user unit,
1242 * not the actual client UID here! */
1243 r = sd_bus_creds_get_owner_uid(creds, &uid);
1244 if (r < 0)
1245 return r;
1246 }
1247
1248 /* owner_uid is racy, so for authorization we must use euid */
1249 r = sd_bus_creds_get_euid(creds, &auth_uid);
1250 if (r < 0)
1251 return r;
1252
1253 errno = 0;
1254 pw = getpwuid(uid);
1255 if (!pw)
1256 return errno_or_else(ENOENT);
1257
1258 r = bus_verify_polkit_async(
1259 message,
1260 CAP_SYS_ADMIN,
1261 uid == auth_uid ? "org.freedesktop.login1.set-self-linger" :
1262 "org.freedesktop.login1.set-user-linger",
1263 NULL,
1264 interactive,
1265 UID_INVALID,
1266 &m->polkit_registry,
1267 error);
1268 if (r < 0)
1269 return r;
1270 if (r == 0)
1271 return 1; /* No authorization for now, but the async polkit stuff will call us again when it has it */
1272
1273 (void) mkdir_p_label("/var/lib/systemd", 0755);
1274 r = mkdir_safe_label("/var/lib/systemd/linger", 0755, 0, 0, MKDIR_WARN_MODE);
1275 if (r < 0)
1276 return r;
1277
1278 cc = cescape(pw->pw_name);
1279 if (!cc)
1280 return -ENOMEM;
1281
1282 path = strjoina("/var/lib/systemd/linger/", cc);
1283 if (b) {
1284 User *u;
1285
1286 r = touch(path);
1287 if (r < 0)
1288 return r;
1289
1290 if (manager_add_user_by_uid(m, uid, &u) >= 0)
1291 user_start(u);
1292
1293 } else {
1294 User *u;
1295
1296 r = unlink(path);
1297 if (r < 0 && errno != ENOENT)
1298 return -errno;
1299
1300 u = hashmap_get(m->users, UID_TO_PTR(uid));
1301 if (u)
1302 user_add_to_gc_queue(u);
1303 }
1304
1305 return sd_bus_reply_method_return(message, NULL);
1306 }
1307
1308 static int trigger_device(Manager *m, sd_device *d) {
1309 _cleanup_(sd_device_enumerator_unrefp) sd_device_enumerator *e = NULL;
1310 int r;
1311
1312 assert(m);
1313
1314 r = sd_device_enumerator_new(&e);
1315 if (r < 0)
1316 return r;
1317
1318 r = sd_device_enumerator_allow_uninitialized(e);
1319 if (r < 0)
1320 return r;
1321
1322 if (d) {
1323 r = sd_device_enumerator_add_match_parent(e, d);
1324 if (r < 0)
1325 return r;
1326 }
1327
1328 FOREACH_DEVICE(e, d) {
1329 _cleanup_free_ char *t = NULL;
1330 const char *p;
1331
1332 r = sd_device_get_syspath(d, &p);
1333 if (r < 0)
1334 return r;
1335
1336 t = path_join(p, "uevent");
1337 if (!t)
1338 return -ENOMEM;
1339
1340 (void) write_string_file(t, "change", WRITE_STRING_FILE_DISABLE_BUFFER);
1341 }
1342
1343 return 0;
1344 }
1345
1346 static int attach_device(Manager *m, const char *seat, const char *sysfs) {
1347 _cleanup_(sd_device_unrefp) sd_device *d = NULL;
1348 _cleanup_free_ char *rule = NULL, *file = NULL;
1349 const char *id_for_seat;
1350 int r;
1351
1352 assert(m);
1353 assert(seat);
1354 assert(sysfs);
1355
1356 r = sd_device_new_from_syspath(&d, sysfs);
1357 if (r < 0)
1358 return r;
1359
1360 if (sd_device_has_current_tag(d, "seat") <= 0)
1361 return -ENODEV;
1362
1363 if (sd_device_get_property_value(d, "ID_FOR_SEAT", &id_for_seat) < 0)
1364 return -ENODEV;
1365
1366 if (asprintf(&file, "/etc/udev/rules.d/72-seat-%s.rules", id_for_seat) < 0)
1367 return -ENOMEM;
1368
1369 if (asprintf(&rule, "TAG==\"seat\", ENV{ID_FOR_SEAT}==\"%s\", ENV{ID_SEAT}=\"%s\"", id_for_seat, seat) < 0)
1370 return -ENOMEM;
1371
1372 (void) mkdir_p_label("/etc/udev/rules.d", 0755);
1373 r = write_string_file_atomic_label(file, rule);
1374 if (r < 0)
1375 return r;
1376
1377 return trigger_device(m, d);
1378 }
1379
1380 static int flush_devices(Manager *m) {
1381 _cleanup_closedir_ DIR *d;
1382
1383 assert(m);
1384
1385 d = opendir("/etc/udev/rules.d");
1386 if (!d) {
1387 if (errno != ENOENT)
1388 log_warning_errno(errno, "Failed to open /etc/udev/rules.d: %m");
1389 } else {
1390 struct dirent *de;
1391
1392 FOREACH_DIRENT_ALL(de, d, break) {
1393 dirent_ensure_type(d, de);
1394 if (!dirent_is_file(de))
1395 continue;
1396
1397 if (!startswith(de->d_name, "72-seat-"))
1398 continue;
1399
1400 if (!endswith(de->d_name, ".rules"))
1401 continue;
1402
1403 if (unlinkat(dirfd(d), de->d_name, 0) < 0)
1404 log_warning_errno(errno, "Failed to unlink %s: %m", de->d_name);
1405 }
1406 }
1407
1408 return trigger_device(m, NULL);
1409 }
1410
1411 static int method_attach_device(sd_bus_message *message, void *userdata, sd_bus_error *error) {
1412 const char *sysfs, *seat;
1413 Manager *m = userdata;
1414 int interactive, r;
1415
1416 assert(message);
1417 assert(m);
1418
1419 r = sd_bus_message_read(message, "ssb", &seat, &sysfs, &interactive);
1420 if (r < 0)
1421 return r;
1422
1423 if (!path_is_normalized(sysfs))
1424 return sd_bus_error_setf(error, SD_BUS_ERROR_INVALID_ARGS, "Path %s is not normalized", sysfs);
1425 if (!path_startswith(sysfs, "/sys"))
1426 return sd_bus_error_setf(error, SD_BUS_ERROR_INVALID_ARGS, "Path %s is not in /sys", sysfs);
1427
1428 if (SEAT_IS_SELF(seat) || SEAT_IS_AUTO(seat)) {
1429 Seat *found;
1430
1431 r = manager_get_seat_from_creds(m, message, seat, error, &found);
1432 if (r < 0)
1433 return r;
1434
1435 seat = found->id;
1436
1437 } else if (!seat_name_is_valid(seat)) /* Note that a seat does not have to exist yet for this operation to succeed */
1438 return sd_bus_error_setf(error, SD_BUS_ERROR_INVALID_ARGS, "Seat name %s is not valid", seat);
1439
1440 r = bus_verify_polkit_async(
1441 message,
1442 CAP_SYS_ADMIN,
1443 "org.freedesktop.login1.attach-device",
1444 NULL,
1445 interactive,
1446 UID_INVALID,
1447 &m->polkit_registry,
1448 error);
1449 if (r < 0)
1450 return r;
1451 if (r == 0)
1452 return 1; /* No authorization for now, but the async polkit stuff will call us again when it has it */
1453
1454 r = attach_device(m, seat, sysfs);
1455 if (r < 0)
1456 return r;
1457
1458 return sd_bus_reply_method_return(message, NULL);
1459 }
1460
1461 static int method_flush_devices(sd_bus_message *message, void *userdata, sd_bus_error *error) {
1462 Manager *m = userdata;
1463 int interactive, r;
1464
1465 assert(message);
1466 assert(m);
1467
1468 r = sd_bus_message_read(message, "b", &interactive);
1469 if (r < 0)
1470 return r;
1471
1472 r = bus_verify_polkit_async(
1473 message,
1474 CAP_SYS_ADMIN,
1475 "org.freedesktop.login1.flush-devices",
1476 NULL,
1477 interactive,
1478 UID_INVALID,
1479 &m->polkit_registry,
1480 error);
1481 if (r < 0)
1482 return r;
1483 if (r == 0)
1484 return 1; /* No authorization for now, but the async polkit stuff will call us again when it has it */
1485
1486 r = flush_devices(m);
1487 if (r < 0)
1488 return r;
1489
1490 return sd_bus_reply_method_return(message, NULL);
1491 }
1492
1493 static int have_multiple_sessions(
1494 Manager *m,
1495 uid_t uid) {
1496
1497 Session *session;
1498
1499 assert(m);
1500
1501 /* Check for other users' sessions. Greeter sessions do not
1502 * count, and non-login sessions do not count either. */
1503 HASHMAP_FOREACH(session, m->sessions)
1504 if (session->class == SESSION_USER &&
1505 session->user->user_record->uid != uid)
1506 return true;
1507
1508 return false;
1509 }
1510
1511 static int bus_manager_log_shutdown(
1512 Manager *m,
1513 const char *unit_name) {
1514
1515 const char *p, *q;
1516
1517 assert(m);
1518 assert(unit_name);
1519
1520 if (streq(unit_name, SPECIAL_POWEROFF_TARGET)) {
1521 p = "MESSAGE=System is powering down";
1522 q = "SHUTDOWN=power-off";
1523 } else if (streq(unit_name, SPECIAL_REBOOT_TARGET)) {
1524 p = "MESSAGE=System is rebooting";
1525 q = "SHUTDOWN=reboot";
1526 } else if (streq(unit_name, SPECIAL_HALT_TARGET)) {
1527 p = "MESSAGE=System is halting";
1528 q = "SHUTDOWN=halt";
1529 } else if (streq(unit_name, SPECIAL_KEXEC_TARGET)) {
1530 p = "MESSAGE=System is rebooting with kexec";
1531 q = "SHUTDOWN=kexec";
1532 } else {
1533 p = "MESSAGE=System is shutting down";
1534 q = NULL;
1535 }
1536
1537 if (isempty(m->wall_message))
1538 p = strjoina(p, ".");
1539 else
1540 p = strjoina(p, " (", m->wall_message, ").");
1541
1542 return log_struct(LOG_NOTICE,
1543 "MESSAGE_ID=" SD_MESSAGE_SHUTDOWN_STR,
1544 p,
1545 q);
1546 }
1547
1548 static int lid_switch_ignore_handler(sd_event_source *e, uint64_t usec, void *userdata) {
1549 Manager *m = userdata;
1550
1551 assert(e);
1552 assert(m);
1553
1554 m->lid_switch_ignore_event_source = sd_event_source_unref(m->lid_switch_ignore_event_source);
1555 return 0;
1556 }
1557
1558 int manager_set_lid_switch_ignore(Manager *m, usec_t until) {
1559 int r;
1560
1561 assert(m);
1562
1563 if (until <= now(CLOCK_MONOTONIC))
1564 return 0;
1565
1566 /* We want to ignore the lid switch for a while after each
1567 * suspend, and after boot-up. Hence let's install a timer for
1568 * this. As long as the event source exists we ignore the lid
1569 * switch. */
1570
1571 if (m->lid_switch_ignore_event_source) {
1572 usec_t u;
1573
1574 r = sd_event_source_get_time(m->lid_switch_ignore_event_source, &u);
1575 if (r < 0)
1576 return r;
1577
1578 if (until <= u)
1579 return 0;
1580
1581 r = sd_event_source_set_time(m->lid_switch_ignore_event_source, until);
1582 } else
1583 r = sd_event_add_time(
1584 m->event,
1585 &m->lid_switch_ignore_event_source,
1586 CLOCK_MONOTONIC,
1587 until, 0,
1588 lid_switch_ignore_handler, m);
1589
1590 return r;
1591 }
1592
1593 static int send_prepare_for(Manager *m, InhibitWhat w, bool _active) {
1594 int active = _active;
1595
1596 assert(m);
1597 assert(IN_SET(w, INHIBIT_SHUTDOWN, INHIBIT_SLEEP));
1598
1599 return sd_bus_emit_signal(m->bus,
1600 "/org/freedesktop/login1",
1601 "org.freedesktop.login1.Manager",
1602 w == INHIBIT_SHUTDOWN ? "PrepareForShutdown" : "PrepareForSleep",
1603 "b",
1604 active);
1605 }
1606
1607 static int execute_shutdown_or_sleep(
1608 Manager *m,
1609 InhibitWhat w,
1610 const char *unit_name,
1611 sd_bus_error *error) {
1612
1613 _cleanup_(sd_bus_message_unrefp) sd_bus_message *reply = NULL;
1614 const char *p;
1615 int r;
1616
1617 assert(m);
1618 assert(w > 0);
1619 assert(w < _INHIBIT_WHAT_MAX);
1620 assert(unit_name);
1621
1622 if (w == INHIBIT_SHUTDOWN)
1623 bus_manager_log_shutdown(m, unit_name);
1624
1625 r = bus_call_method(
1626 m->bus,
1627 bus_systemd_mgr,
1628 "StartUnit",
1629 error,
1630 &reply,
1631 "ss", unit_name, "replace-irreversibly");
1632 if (r < 0)
1633 goto error;
1634
1635 r = sd_bus_message_read(reply, "o", &p);
1636 if (r < 0)
1637 goto error;
1638
1639 r = free_and_strdup(&m->action_job, p);
1640 if (r < 0)
1641 goto error;
1642
1643 m->action_unit = unit_name;
1644 m->action_what = w;
1645
1646 /* Make sure the lid switch is ignored for a while */
1647 manager_set_lid_switch_ignore(m, now(CLOCK_MONOTONIC) + m->holdoff_timeout_usec);
1648
1649 return 0;
1650
1651 error:
1652 /* Tell people that they now may take a lock again */
1653 (void) send_prepare_for(m, w, false);
1654
1655 return r;
1656 }
1657
1658 int manager_dispatch_delayed(Manager *manager, bool timeout) {
1659
1660 _cleanup_(sd_bus_error_free) sd_bus_error error = SD_BUS_ERROR_NULL;
1661 Inhibitor *offending = NULL;
1662 int r;
1663
1664 assert(manager);
1665
1666 if (manager->action_what == 0 || manager->action_job)
1667 return 0;
1668
1669 if (manager_is_inhibited(manager, manager->action_what, INHIBIT_DELAY, NULL, false, false, 0, &offending)) {
1670 _cleanup_free_ char *comm = NULL, *u = NULL;
1671
1672 if (!timeout)
1673 return 0;
1674
1675 (void) get_process_comm(offending->pid, &comm);
1676 u = uid_to_name(offending->uid);
1677
1678 log_notice("Delay lock is active (UID "UID_FMT"/%s, PID "PID_FMT"/%s) but inhibitor timeout is reached.",
1679 offending->uid, strna(u),
1680 offending->pid, strna(comm));
1681 }
1682
1683 /* Actually do the operation */
1684 r = execute_shutdown_or_sleep(manager, manager->action_what, manager->action_unit, &error);
1685 if (r < 0) {
1686 log_warning("Error during inhibitor-delayed operation (already returned success to client): %s",
1687 bus_error_message(&error, r));
1688
1689 manager->action_unit = NULL;
1690 manager->action_what = 0;
1691 return r;
1692 }
1693
1694 return 1;
1695 }
1696
1697 static int manager_inhibit_timeout_handler(
1698 sd_event_source *s,
1699 uint64_t usec,
1700 void *userdata) {
1701
1702 Manager *manager = userdata;
1703 int r;
1704
1705 assert(manager);
1706 assert(manager->inhibit_timeout_source == s);
1707
1708 r = manager_dispatch_delayed(manager, true);
1709 return (r < 0) ? r : 0;
1710 }
1711
1712 static int delay_shutdown_or_sleep(
1713 Manager *m,
1714 InhibitWhat w,
1715 const char *unit_name) {
1716
1717 int r;
1718
1719 assert(m);
1720 assert(w >= 0);
1721 assert(w < _INHIBIT_WHAT_MAX);
1722 assert(unit_name);
1723
1724 if (m->inhibit_timeout_source) {
1725 r = sd_event_source_set_time_relative(m->inhibit_timeout_source, m->inhibit_delay_max);
1726 if (r < 0)
1727 return log_error_errno(r, "sd_event_source_set_time_relative() failed: %m");
1728
1729 r = sd_event_source_set_enabled(m->inhibit_timeout_source, SD_EVENT_ONESHOT);
1730 if (r < 0)
1731 return log_error_errno(r, "sd_event_source_set_enabled() failed: %m");
1732 } else {
1733 r = sd_event_add_time_relative(
1734 m->event,
1735 &m->inhibit_timeout_source,
1736 CLOCK_MONOTONIC, m->inhibit_delay_max, 0,
1737 manager_inhibit_timeout_handler, m);
1738 if (r < 0)
1739 return r;
1740 }
1741
1742 m->action_unit = unit_name;
1743 m->action_what = w;
1744
1745 return 0;
1746 }
1747
1748 int bus_manager_shutdown_or_sleep_now_or_later(
1749 Manager *m,
1750 const char *unit_name,
1751 InhibitWhat w,
1752 sd_bus_error *error) {
1753
1754 _cleanup_free_ char *load_state = NULL;
1755 bool delayed;
1756 int r;
1757
1758 assert(m);
1759 assert(unit_name);
1760 assert(w > 0);
1761 assert(w < _INHIBIT_WHAT_MAX);
1762 assert(!m->action_job);
1763
1764 r = unit_load_state(m->bus, unit_name, &load_state);
1765 if (r < 0)
1766 return r;
1767
1768 if (!streq(load_state, "loaded"))
1769 return log_notice_errno(SYNTHETIC_ERRNO(EACCES),
1770 "Unit %s is %s, refusing operation.",
1771 unit_name, load_state);
1772
1773 /* Tell everybody to prepare for shutdown/sleep */
1774 (void) send_prepare_for(m, w, true);
1775
1776 delayed =
1777 m->inhibit_delay_max > 0 &&
1778 manager_is_inhibited(m, w, INHIBIT_DELAY, NULL, false, false, 0, NULL);
1779
1780 if (delayed)
1781 /* Shutdown is delayed, keep in mind what we
1782 * want to do, and start a timeout */
1783 r = delay_shutdown_or_sleep(m, w, unit_name);
1784 else
1785 /* Shutdown is not delayed, execute it
1786 * immediately */
1787 r = execute_shutdown_or_sleep(m, w, unit_name, error);
1788
1789 return r;
1790 }
1791
1792 static int verify_shutdown_creds(
1793 Manager *m,
1794 sd_bus_message *message,
1795 InhibitWhat w,
1796 const char *action,
1797 const char *action_multiple_sessions,
1798 const char *action_ignore_inhibit,
1799 uint64_t flags,
1800 sd_bus_error *error) {
1801
1802 _cleanup_(sd_bus_creds_unrefp) sd_bus_creds *creds = NULL;
1803 bool multiple_sessions, blocked, interactive;
1804 uid_t uid;
1805 int r;
1806
1807 assert(m);
1808 assert(message);
1809 assert(w >= 0);
1810 assert(w <= _INHIBIT_WHAT_MAX);
1811
1812 r = sd_bus_query_sender_creds(message, SD_BUS_CREDS_EUID, &creds);
1813 if (r < 0)
1814 return r;
1815
1816 r = sd_bus_creds_get_euid(creds, &uid);
1817 if (r < 0)
1818 return r;
1819
1820 r = have_multiple_sessions(m, uid);
1821 if (r < 0)
1822 return r;
1823
1824 multiple_sessions = r > 0;
1825 blocked = manager_is_inhibited(m, w, INHIBIT_BLOCK, NULL, false, true, uid, NULL);
1826 interactive = flags & SD_LOGIND_INTERACTIVE;
1827
1828 if (multiple_sessions && action_multiple_sessions) {
1829 r = bus_verify_polkit_async(message, CAP_SYS_BOOT, action_multiple_sessions, NULL, interactive, UID_INVALID, &m->polkit_registry, error);
1830 if (r < 0)
1831 return r;
1832 if (r == 0)
1833 return 1; /* No authorization for now, but the async polkit stuff will call us again when it has it */
1834 }
1835
1836 if (blocked) {
1837 /* We don't check polkit for root here, because you can't be more privileged than root */
1838 if (uid == 0 && (flags & SD_LOGIND_ROOT_CHECK_INHIBITORS))
1839 return sd_bus_error_setf(error, SD_BUS_ERROR_ACCESS_DENIED,
1840 "Access denied to root due to active block inhibitor");
1841
1842 if (action_ignore_inhibit) {
1843 r = bus_verify_polkit_async(message, CAP_SYS_BOOT, action_ignore_inhibit, NULL, interactive, UID_INVALID, &m->polkit_registry, error);
1844 if (r < 0)
1845 return r;
1846 if (r == 0)
1847 return 1; /* No authorization for now, but the async polkit stuff will call us again when it has it */
1848 }
1849 }
1850
1851 if (!multiple_sessions && !blocked && action) {
1852 r = bus_verify_polkit_async(message, CAP_SYS_BOOT, action, NULL, interactive, UID_INVALID, &m->polkit_registry, error);
1853 if (r < 0)
1854 return r;
1855 if (r == 0)
1856 return 1; /* No authorization for now, but the async polkit stuff will call us again when it has it */
1857 }
1858
1859 return 0;
1860 }
1861
1862 static int method_do_shutdown_or_sleep(
1863 Manager *m,
1864 sd_bus_message *message,
1865 const char *unit_name,
1866 InhibitWhat w,
1867 const char *action,
1868 const char *action_multiple_sessions,
1869 const char *action_ignore_inhibit,
1870 const char *sleep_verb,
1871 bool with_flags,
1872 sd_bus_error *error) {
1873
1874 uint64_t flags;
1875 int r;
1876
1877 assert(m);
1878 assert(message);
1879 assert(unit_name);
1880 assert(w >= 0);
1881 assert(w <= _INHIBIT_WHAT_MAX);
1882
1883 if (with_flags) {
1884 /* New style method: with flags parameter (and interactive bool in the bus message header) */
1885 r = sd_bus_message_read(message, "t", &flags);
1886 if (r < 0)
1887 return r;
1888 if ((flags & ~SD_LOGIND_SHUTDOWN_AND_SLEEP_FLAGS_PUBLIC) != 0)
1889 return sd_bus_error_setf(error, SD_BUS_ERROR_INVALID_ARGS, "Invalid flags parameter");
1890 } else {
1891 /* Old style method: no flags parameter, but interactive bool passed as boolean in
1892 * payload. Let's convert this argument to the new-style flags parameter for our internal
1893 * use. */
1894 int interactive;
1895
1896 r = sd_bus_message_read(message, "b", &interactive);
1897 if (r < 0)
1898 return r;
1899
1900 flags = interactive ? SD_LOGIND_INTERACTIVE : 0;
1901 }
1902
1903 /* Don't allow multiple jobs being executed at the same time */
1904 if (m->action_what > 0)
1905 return sd_bus_error_setf(error, BUS_ERROR_OPERATION_IN_PROGRESS,
1906 "There's already a shutdown or sleep operation in progress");
1907
1908 if (sleep_verb) {
1909 r = can_sleep(sleep_verb);
1910 if (r == -ENOSPC)
1911 return sd_bus_error_set(error, BUS_ERROR_SLEEP_VERB_NOT_SUPPORTED,
1912 "Not enough swap space for hibernation");
1913 if (r == 0)
1914 return sd_bus_error_setf(error, BUS_ERROR_SLEEP_VERB_NOT_SUPPORTED,
1915 "Sleep verb \"%s\" not supported", sleep_verb);
1916 if (r < 0)
1917 return r;
1918 }
1919
1920 r = verify_shutdown_creds(m, message, w, action, action_multiple_sessions,
1921 action_ignore_inhibit, flags, error);
1922 if (r != 0)
1923 return r;
1924
1925 r = bus_manager_shutdown_or_sleep_now_or_later(m, unit_name, w, error);
1926 if (r < 0)
1927 return r;
1928
1929 return sd_bus_reply_method_return(message, NULL);
1930 }
1931
1932 static int method_poweroff(sd_bus_message *message, void *userdata, sd_bus_error *error) {
1933 Manager *m = userdata;
1934
1935 return method_do_shutdown_or_sleep(
1936 m, message,
1937 SPECIAL_POWEROFF_TARGET,
1938 INHIBIT_SHUTDOWN,
1939 "org.freedesktop.login1.power-off",
1940 "org.freedesktop.login1.power-off-multiple-sessions",
1941 "org.freedesktop.login1.power-off-ignore-inhibit",
1942 NULL,
1943 sd_bus_message_is_method_call(message, NULL, "PowerOffWithFlags"),
1944 error);
1945 }
1946
1947 static int method_reboot(sd_bus_message *message, void *userdata, sd_bus_error *error) {
1948 Manager *m = userdata;
1949
1950 return method_do_shutdown_or_sleep(
1951 m, message,
1952 SPECIAL_REBOOT_TARGET,
1953 INHIBIT_SHUTDOWN,
1954 "org.freedesktop.login1.reboot",
1955 "org.freedesktop.login1.reboot-multiple-sessions",
1956 "org.freedesktop.login1.reboot-ignore-inhibit",
1957 NULL,
1958 sd_bus_message_is_method_call(message, NULL, "RebootWithFlags"),
1959 error);
1960 }
1961
1962 static int method_halt(sd_bus_message *message, void *userdata, sd_bus_error *error) {
1963 Manager *m = userdata;
1964
1965 return method_do_shutdown_or_sleep(
1966 m, message,
1967 SPECIAL_HALT_TARGET,
1968 INHIBIT_SHUTDOWN,
1969 "org.freedesktop.login1.halt",
1970 "org.freedesktop.login1.halt-multiple-sessions",
1971 "org.freedesktop.login1.halt-ignore-inhibit",
1972 NULL,
1973 sd_bus_message_is_method_call(message, NULL, "HaltWithFlags"),
1974 error);
1975 }
1976
1977 static int method_suspend(sd_bus_message *message, void *userdata, sd_bus_error *error) {
1978 Manager *m = userdata;
1979
1980 return method_do_shutdown_or_sleep(
1981 m, message,
1982 SPECIAL_SUSPEND_TARGET,
1983 INHIBIT_SLEEP,
1984 "org.freedesktop.login1.suspend",
1985 "org.freedesktop.login1.suspend-multiple-sessions",
1986 "org.freedesktop.login1.suspend-ignore-inhibit",
1987 "suspend",
1988 sd_bus_message_is_method_call(message, NULL, "SuspendWithFlags"),
1989 error);
1990 }
1991
1992 static int method_hibernate(sd_bus_message *message, void *userdata, sd_bus_error *error) {
1993 Manager *m = userdata;
1994
1995 return method_do_shutdown_or_sleep(
1996 m, message,
1997 SPECIAL_HIBERNATE_TARGET,
1998 INHIBIT_SLEEP,
1999 "org.freedesktop.login1.hibernate",
2000 "org.freedesktop.login1.hibernate-multiple-sessions",
2001 "org.freedesktop.login1.hibernate-ignore-inhibit",
2002 "hibernate",
2003 sd_bus_message_is_method_call(message, NULL, "HibernateWithFlags"),
2004 error);
2005 }
2006
2007 static int method_hybrid_sleep(sd_bus_message *message, void *userdata, sd_bus_error *error) {
2008 Manager *m = userdata;
2009
2010 return method_do_shutdown_or_sleep(
2011 m, message,
2012 SPECIAL_HYBRID_SLEEP_TARGET,
2013 INHIBIT_SLEEP,
2014 "org.freedesktop.login1.hibernate",
2015 "org.freedesktop.login1.hibernate-multiple-sessions",
2016 "org.freedesktop.login1.hibernate-ignore-inhibit",
2017 "hybrid-sleep",
2018 sd_bus_message_is_method_call(message, NULL, "HybridSleepWithFlags"),
2019 error);
2020 }
2021
2022 static int method_suspend_then_hibernate(sd_bus_message *message, void *userdata, sd_bus_error *error) {
2023 Manager *m = userdata;
2024
2025 return method_do_shutdown_or_sleep(
2026 m, message,
2027 SPECIAL_SUSPEND_THEN_HIBERNATE_TARGET,
2028 INHIBIT_SLEEP,
2029 "org.freedesktop.login1.hibernate",
2030 "org.freedesktop.login1.hibernate-multiple-sessions",
2031 "org.freedesktop.login1.hibernate-ignore-inhibit",
2032 "hybrid-sleep",
2033 sd_bus_message_is_method_call(message, NULL, "SuspendThenHibernateWithFlags"),
2034 error);
2035 }
2036
2037 static int nologin_timeout_handler(
2038 sd_event_source *s,
2039 uint64_t usec,
2040 void *userdata) {
2041
2042 Manager *m = userdata;
2043
2044 log_info("Creating /run/nologin, blocking further logins...");
2045
2046 m->unlink_nologin =
2047 create_shutdown_run_nologin_or_warn() >= 0;
2048
2049 return 0;
2050 }
2051
2052 static int update_schedule_file(Manager *m) {
2053 _cleanup_free_ char *temp_path = NULL;
2054 _cleanup_fclose_ FILE *f = NULL;
2055 int r;
2056
2057 assert(m);
2058
2059 r = mkdir_safe_label("/run/systemd/shutdown", 0755, 0, 0, MKDIR_WARN_MODE);
2060 if (r < 0)
2061 return log_error_errno(r, "Failed to create shutdown subdirectory: %m");
2062
2063 r = fopen_temporary("/run/systemd/shutdown/scheduled", &f, &temp_path);
2064 if (r < 0)
2065 return log_error_errno(r, "Failed to save information about scheduled shutdowns: %m");
2066
2067 (void) fchmod(fileno(f), 0644);
2068
2069 fprintf(f,
2070 "USEC="USEC_FMT"\n"
2071 "WARN_WALL=%i\n"
2072 "MODE=%s\n",
2073 m->scheduled_shutdown_timeout,
2074 m->enable_wall_messages,
2075 m->scheduled_shutdown_type);
2076
2077 if (!isempty(m->wall_message)) {
2078 _cleanup_free_ char *t;
2079
2080 t = cescape(m->wall_message);
2081 if (!t) {
2082 r = -ENOMEM;
2083 goto fail;
2084 }
2085
2086 fprintf(f, "WALL_MESSAGE=%s\n", t);
2087 }
2088
2089 r = fflush_and_check(f);
2090 if (r < 0)
2091 goto fail;
2092
2093 if (rename(temp_path, "/run/systemd/shutdown/scheduled") < 0) {
2094 r = -errno;
2095 goto fail;
2096 }
2097
2098 return 0;
2099
2100 fail:
2101 (void) unlink(temp_path);
2102 (void) unlink("/run/systemd/shutdown/scheduled");
2103
2104 return log_error_errno(r, "Failed to write information about scheduled shutdowns: %m");
2105 }
2106
2107 static void reset_scheduled_shutdown(Manager *m) {
2108 assert(m);
2109
2110 m->scheduled_shutdown_timeout_source = sd_event_source_unref(m->scheduled_shutdown_timeout_source);
2111 m->wall_message_timeout_source = sd_event_source_unref(m->wall_message_timeout_source);
2112 m->nologin_timeout_source = sd_event_source_unref(m->nologin_timeout_source);
2113
2114 m->scheduled_shutdown_type = mfree(m->scheduled_shutdown_type);
2115 m->scheduled_shutdown_timeout = 0;
2116 m->shutdown_dry_run = false;
2117
2118 if (m->unlink_nologin) {
2119 (void) unlink_or_warn("/run/nologin");
2120 m->unlink_nologin = false;
2121 }
2122
2123 (void) unlink("/run/systemd/shutdown/scheduled");
2124 }
2125
2126 static int manager_scheduled_shutdown_handler(
2127 sd_event_source *s,
2128 uint64_t usec,
2129 void *userdata) {
2130
2131 _cleanup_(sd_bus_error_free) sd_bus_error error = SD_BUS_ERROR_NULL;
2132 Manager *m = userdata;
2133 const char *target;
2134 int r;
2135
2136 assert(m);
2137
2138 if (isempty(m->scheduled_shutdown_type))
2139 return 0;
2140
2141 if (streq(m->scheduled_shutdown_type, "poweroff"))
2142 target = SPECIAL_POWEROFF_TARGET;
2143 else if (streq(m->scheduled_shutdown_type, "reboot"))
2144 target = SPECIAL_REBOOT_TARGET;
2145 else if (streq(m->scheduled_shutdown_type, "halt"))
2146 target = SPECIAL_HALT_TARGET;
2147 else
2148 assert_not_reached("unexpected shutdown type");
2149
2150 /* Don't allow multiple jobs being executed at the same time */
2151 if (m->action_what > 0) {
2152 r = -EALREADY;
2153 log_error("Scheduled shutdown to %s failed: shutdown or sleep operation already in progress", target);
2154 goto error;
2155 }
2156
2157 if (m->shutdown_dry_run) {
2158 /* We do not process delay inhibitors here. Otherwise, we
2159 * would have to be considered "in progress" (like the check
2160 * above) for some seconds after our admin has seen the final
2161 * wall message. */
2162
2163 bus_manager_log_shutdown(m, target);
2164 log_info("Running in dry run, suppressing action.");
2165 reset_scheduled_shutdown(m);
2166
2167 return 0;
2168 }
2169
2170 r = bus_manager_shutdown_or_sleep_now_or_later(m, target, INHIBIT_SHUTDOWN, &error);
2171 if (r < 0) {
2172 log_error_errno(r, "Scheduled shutdown to %s failed: %m", target);
2173 goto error;
2174 }
2175
2176 return 0;
2177
2178 error:
2179 reset_scheduled_shutdown(m);
2180 return r;
2181 }
2182
2183 static int method_schedule_shutdown(sd_bus_message *message, void *userdata, sd_bus_error *error) {
2184 Manager *m = userdata;
2185 _cleanup_(sd_bus_creds_unrefp) sd_bus_creds *creds = NULL;
2186 const char *action_multiple_sessions = NULL;
2187 const char *action_ignore_inhibit = NULL;
2188 const char *action = NULL;
2189 uint64_t elapse;
2190 char *type;
2191 int r;
2192 bool dry_run = false;
2193
2194 assert(m);
2195 assert(message);
2196
2197 r = sd_bus_message_read(message, "st", &type, &elapse);
2198 if (r < 0)
2199 return r;
2200
2201 if (startswith(type, "dry-")) {
2202 type += 4;
2203 dry_run = true;
2204 }
2205
2206 if (streq(type, "poweroff")) {
2207 action = "org.freedesktop.login1.power-off";
2208 action_multiple_sessions = "org.freedesktop.login1.power-off-multiple-sessions";
2209 action_ignore_inhibit = "org.freedesktop.login1.power-off-ignore-inhibit";
2210 } else if (streq(type, "reboot")) {
2211 action = "org.freedesktop.login1.reboot";
2212 action_multiple_sessions = "org.freedesktop.login1.reboot-multiple-sessions";
2213 action_ignore_inhibit = "org.freedesktop.login1.reboot-ignore-inhibit";
2214 } else if (streq(type, "halt")) {
2215 action = "org.freedesktop.login1.halt";
2216 action_multiple_sessions = "org.freedesktop.login1.halt-multiple-sessions";
2217 action_ignore_inhibit = "org.freedesktop.login1.halt-ignore-inhibit";
2218 } else
2219 return sd_bus_error_setf(error, SD_BUS_ERROR_INVALID_ARGS, "Unsupported shutdown type");
2220
2221 r = verify_shutdown_creds(m, message, INHIBIT_SHUTDOWN, action, action_multiple_sessions,
2222 action_ignore_inhibit, 0, error);
2223 if (r != 0)
2224 return r;
2225
2226 if (m->scheduled_shutdown_timeout_source) {
2227 r = sd_event_source_set_time(m->scheduled_shutdown_timeout_source, elapse);
2228 if (r < 0)
2229 return log_error_errno(r, "sd_event_source_set_time() failed: %m");
2230
2231 r = sd_event_source_set_enabled(m->scheduled_shutdown_timeout_source, SD_EVENT_ONESHOT);
2232 if (r < 0)
2233 return log_error_errno(r, "sd_event_source_set_enabled() failed: %m");
2234 } else {
2235 r = sd_event_add_time(m->event, &m->scheduled_shutdown_timeout_source,
2236 CLOCK_REALTIME, elapse, 0, manager_scheduled_shutdown_handler, m);
2237 if (r < 0)
2238 return log_error_errno(r, "sd_event_add_time() failed: %m");
2239 }
2240
2241 r = free_and_strdup(&m->scheduled_shutdown_type, type);
2242 if (r < 0) {
2243 m->scheduled_shutdown_timeout_source = sd_event_source_unref(m->scheduled_shutdown_timeout_source);
2244 return log_oom();
2245 }
2246
2247 m->shutdown_dry_run = dry_run;
2248
2249 if (m->nologin_timeout_source) {
2250 r = sd_event_source_set_time(m->nologin_timeout_source, elapse);
2251 if (r < 0)
2252 return log_error_errno(r, "sd_event_source_set_time() failed: %m");
2253
2254 r = sd_event_source_set_enabled(m->nologin_timeout_source, SD_EVENT_ONESHOT);
2255 if (r < 0)
2256 return log_error_errno(r, "sd_event_source_set_enabled() failed: %m");
2257 } else {
2258 r = sd_event_add_time(m->event, &m->nologin_timeout_source,
2259 CLOCK_REALTIME, elapse - 5 * USEC_PER_MINUTE, 0, nologin_timeout_handler, m);
2260 if (r < 0)
2261 return log_error_errno(r, "sd_event_add_time() failed: %m");
2262 }
2263
2264 m->scheduled_shutdown_timeout = elapse;
2265
2266 r = sd_bus_query_sender_creds(message, SD_BUS_CREDS_AUGMENT|SD_BUS_CREDS_TTY|SD_BUS_CREDS_UID, &creds);
2267 if (r >= 0) {
2268 const char *tty = NULL;
2269
2270 (void) sd_bus_creds_get_uid(creds, &m->scheduled_shutdown_uid);
2271 (void) sd_bus_creds_get_tty(creds, &tty);
2272
2273 r = free_and_strdup(&m->scheduled_shutdown_tty, tty);
2274 if (r < 0) {
2275 m->scheduled_shutdown_timeout_source = sd_event_source_unref(m->scheduled_shutdown_timeout_source);
2276 return log_oom();
2277 }
2278 }
2279
2280 r = manager_setup_wall_message_timer(m);
2281 if (r < 0)
2282 return r;
2283
2284 r = update_schedule_file(m);
2285 if (r < 0)
2286 return r;
2287
2288 return sd_bus_reply_method_return(message, NULL);
2289 }
2290
2291 static int method_cancel_scheduled_shutdown(sd_bus_message *message, void *userdata, sd_bus_error *error) {
2292 Manager *m = userdata;
2293 bool cancelled;
2294
2295 assert(m);
2296 assert(message);
2297
2298 cancelled = m->scheduled_shutdown_type != NULL;
2299 reset_scheduled_shutdown(m);
2300
2301 if (cancelled && m->enable_wall_messages) {
2302 _cleanup_(sd_bus_creds_unrefp) sd_bus_creds *creds = NULL;
2303 _cleanup_free_ char *username = NULL;
2304 const char *tty = NULL;
2305 uid_t uid = 0;
2306 int r;
2307
2308 r = sd_bus_query_sender_creds(message, SD_BUS_CREDS_AUGMENT|SD_BUS_CREDS_TTY|SD_BUS_CREDS_UID, &creds);
2309 if (r >= 0) {
2310 (void) sd_bus_creds_get_uid(creds, &uid);
2311 (void) sd_bus_creds_get_tty(creds, &tty);
2312 }
2313
2314 username = uid_to_name(uid);
2315 utmp_wall("The system shutdown has been cancelled",
2316 username, tty, logind_wall_tty_filter, m);
2317 }
2318
2319 return sd_bus_reply_method_return(message, "b", cancelled);
2320 }
2321
2322 static int method_can_shutdown_or_sleep(
2323 Manager *m,
2324 sd_bus_message *message,
2325 InhibitWhat w,
2326 const char *action,
2327 const char *action_multiple_sessions,
2328 const char *action_ignore_inhibit,
2329 const char *sleep_verb,
2330 sd_bus_error *error) {
2331
2332 _cleanup_(sd_bus_creds_unrefp) sd_bus_creds *creds = NULL;
2333 HandleAction handle;
2334 bool multiple_sessions, challenge, blocked;
2335 const char *result = NULL;
2336 uid_t uid;
2337 int r;
2338
2339 assert(m);
2340 assert(message);
2341 assert(w >= 0);
2342 assert(w <= _INHIBIT_WHAT_MAX);
2343 assert(action);
2344 assert(action_multiple_sessions);
2345 assert(action_ignore_inhibit);
2346
2347 if (sleep_verb) {
2348 r = can_sleep(sleep_verb);
2349 if (IN_SET(r, 0, -ENOSPC))
2350 return sd_bus_reply_method_return(message, "s", "na");
2351 if (r < 0)
2352 return r;
2353 }
2354
2355 r = sd_bus_query_sender_creds(message, SD_BUS_CREDS_EUID, &creds);
2356 if (r < 0)
2357 return r;
2358
2359 r = sd_bus_creds_get_euid(creds, &uid);
2360 if (r < 0)
2361 return r;
2362
2363 r = have_multiple_sessions(m, uid);
2364 if (r < 0)
2365 return r;
2366
2367 multiple_sessions = r > 0;
2368 blocked = manager_is_inhibited(m, w, INHIBIT_BLOCK, NULL, false, true, uid, NULL);
2369
2370 handle = handle_action_from_string(sleep_verb);
2371 if (handle >= 0) {
2372 const char *target;
2373
2374 target = manager_target_for_action(handle);
2375 if (target) {
2376 _cleanup_free_ char *load_state = NULL;
2377
2378 r = unit_load_state(m->bus, target, &load_state);
2379 if (r < 0)
2380 return r;
2381
2382 if (!streq(load_state, "loaded")) {
2383 result = "no";
2384 goto finish;
2385 }
2386 }
2387 }
2388
2389 if (multiple_sessions) {
2390 r = bus_test_polkit(message, CAP_SYS_BOOT, action_multiple_sessions, NULL, UID_INVALID, &challenge, error);
2391 if (r < 0)
2392 return r;
2393
2394 if (r > 0)
2395 result = "yes";
2396 else if (challenge)
2397 result = "challenge";
2398 else
2399 result = "no";
2400 }
2401
2402 if (blocked) {
2403 r = bus_test_polkit(message, CAP_SYS_BOOT, action_ignore_inhibit, NULL, UID_INVALID, &challenge, error);
2404 if (r < 0)
2405 return r;
2406
2407 if (r > 0) {
2408 if (!result)
2409 result = "yes";
2410 } else if (challenge) {
2411 if (!result || streq(result, "yes"))
2412 result = "challenge";
2413 } else
2414 result = "no";
2415 }
2416
2417 if (!multiple_sessions && !blocked) {
2418 /* If neither inhibit nor multiple sessions
2419 * apply then just check the normal policy */
2420
2421 r = bus_test_polkit(message, CAP_SYS_BOOT, action, NULL, UID_INVALID, &challenge, error);
2422 if (r < 0)
2423 return r;
2424
2425 if (r > 0)
2426 result = "yes";
2427 else if (challenge)
2428 result = "challenge";
2429 else
2430 result = "no";
2431 }
2432
2433 finish:
2434 return sd_bus_reply_method_return(message, "s", result);
2435 }
2436
2437 static int method_can_poweroff(sd_bus_message *message, void *userdata, sd_bus_error *error) {
2438 Manager *m = userdata;
2439
2440 return method_can_shutdown_or_sleep(
2441 m, message,
2442 INHIBIT_SHUTDOWN,
2443 "org.freedesktop.login1.power-off",
2444 "org.freedesktop.login1.power-off-multiple-sessions",
2445 "org.freedesktop.login1.power-off-ignore-inhibit",
2446 NULL,
2447 error);
2448 }
2449
2450 static int method_can_reboot(sd_bus_message *message, void *userdata, sd_bus_error *error) {
2451 Manager *m = userdata;
2452
2453 return method_can_shutdown_or_sleep(
2454 m, message,
2455 INHIBIT_SHUTDOWN,
2456 "org.freedesktop.login1.reboot",
2457 "org.freedesktop.login1.reboot-multiple-sessions",
2458 "org.freedesktop.login1.reboot-ignore-inhibit",
2459 NULL,
2460 error);
2461 }
2462
2463 static int method_can_halt(sd_bus_message *message, void *userdata, sd_bus_error *error) {
2464 Manager *m = userdata;
2465
2466 return method_can_shutdown_or_sleep(
2467 m, message,
2468 INHIBIT_SHUTDOWN,
2469 "org.freedesktop.login1.halt",
2470 "org.freedesktop.login1.halt-multiple-sessions",
2471 "org.freedesktop.login1.halt-ignore-inhibit",
2472 NULL,
2473 error);
2474 }
2475
2476 static int method_can_suspend(sd_bus_message *message, void *userdata, sd_bus_error *error) {
2477 Manager *m = userdata;
2478
2479 return method_can_shutdown_or_sleep(
2480 m, message,
2481 INHIBIT_SLEEP,
2482 "org.freedesktop.login1.suspend",
2483 "org.freedesktop.login1.suspend-multiple-sessions",
2484 "org.freedesktop.login1.suspend-ignore-inhibit",
2485 "suspend",
2486 error);
2487 }
2488
2489 static int method_can_hibernate(sd_bus_message *message, void *userdata, sd_bus_error *error) {
2490 Manager *m = userdata;
2491
2492 return method_can_shutdown_or_sleep(
2493 m, message,
2494 INHIBIT_SLEEP,
2495 "org.freedesktop.login1.hibernate",
2496 "org.freedesktop.login1.hibernate-multiple-sessions",
2497 "org.freedesktop.login1.hibernate-ignore-inhibit",
2498 "hibernate",
2499 error);
2500 }
2501
2502 static int method_can_hybrid_sleep(sd_bus_message *message, void *userdata, sd_bus_error *error) {
2503 Manager *m = userdata;
2504
2505 return method_can_shutdown_or_sleep(
2506 m, message,
2507 INHIBIT_SLEEP,
2508 "org.freedesktop.login1.hibernate",
2509 "org.freedesktop.login1.hibernate-multiple-sessions",
2510 "org.freedesktop.login1.hibernate-ignore-inhibit",
2511 "hybrid-sleep",
2512 error);
2513 }
2514
2515 static int method_can_suspend_then_hibernate(sd_bus_message *message, void *userdata, sd_bus_error *error) {
2516 Manager *m = userdata;
2517
2518 return method_can_shutdown_or_sleep(
2519 m, message,
2520 INHIBIT_SLEEP,
2521 "org.freedesktop.login1.hibernate",
2522 "org.freedesktop.login1.hibernate-multiple-sessions",
2523 "org.freedesktop.login1.hibernate-ignore-inhibit",
2524 "suspend-then-hibernate",
2525 error);
2526 }
2527
2528 static int property_get_reboot_parameter(
2529 sd_bus *bus,
2530 const char *path,
2531 const char *interface,
2532 const char *property,
2533 sd_bus_message *reply,
2534 void *userdata,
2535 sd_bus_error *error) {
2536 _cleanup_free_ char *parameter = NULL;
2537 int r;
2538
2539 assert(bus);
2540 assert(reply);
2541 assert(userdata);
2542
2543 r = read_reboot_parameter(&parameter);
2544 if (r < 0)
2545 return r;
2546
2547 return sd_bus_message_append(reply, "s", parameter);
2548 }
2549
2550 static int method_set_reboot_parameter(
2551 sd_bus_message *message,
2552 void *userdata,
2553 sd_bus_error *error) {
2554
2555 Manager *m = userdata;
2556 const char *arg;
2557 int r;
2558
2559 assert(message);
2560 assert(m);
2561
2562 r = sd_bus_message_read(message, "s", &arg);
2563 if (r < 0)
2564 return r;
2565
2566 r = detect_container();
2567 if (r < 0)
2568 return r;
2569 if (r > 0)
2570 return sd_bus_error_setf(error, SD_BUS_ERROR_NOT_SUPPORTED,
2571 "Reboot parameter not supported in containers, refusing.");
2572
2573 r = bus_verify_polkit_async(message,
2574 CAP_SYS_ADMIN,
2575 "org.freedesktop.login1.set-reboot-parameter",
2576 NULL,
2577 false,
2578 UID_INVALID,
2579 &m->polkit_registry,
2580 error);
2581 if (r < 0)
2582 return r;
2583 if (r == 0)
2584 return 1; /* No authorization for now, but the async polkit stuff will call us again when it has it */
2585
2586 r = update_reboot_parameter_and_warn(arg, false);
2587 if (r < 0)
2588 return r;
2589
2590 return sd_bus_reply_method_return(message, NULL);
2591 }
2592
2593 static int method_can_reboot_parameter(
2594 sd_bus_message *message,
2595 void *userdata,
2596 sd_bus_error *error) {
2597
2598 _unused_ Manager *m = userdata;
2599 int r;
2600
2601 assert(message);
2602 assert(m);
2603
2604 r = detect_container();
2605 if (r < 0)
2606 return r;
2607 if (r > 0) /* Inside containers, specifying a reboot parameter, doesn't make much sense */
2608 return sd_bus_reply_method_return(message, "s", "na");
2609
2610 return return_test_polkit(
2611 message,
2612 CAP_SYS_ADMIN,
2613 "org.freedesktop.login1.set-reboot-parameter",
2614 NULL,
2615 UID_INVALID,
2616 error);
2617 }
2618
2619 static int property_get_reboot_to_firmware_setup(
2620 sd_bus *bus,
2621 const char *path,
2622 const char *interface,
2623 const char *property,
2624 sd_bus_message *reply,
2625 void *userdata,
2626 sd_bus_error *error) {
2627 int r;
2628
2629 assert(bus);
2630 assert(reply);
2631 assert(userdata);
2632
2633 r = getenv_bool("SYSTEMD_REBOOT_TO_FIRMWARE_SETUP");
2634 if (r == -ENXIO) {
2635 /* EFI case: let's see what is currently configured in the EFI variables */
2636 r = efi_get_reboot_to_firmware();
2637 if (r < 0 && r != -EOPNOTSUPP)
2638 log_warning_errno(r, "Failed to determine reboot-to-firmware-setup state: %m");
2639 } else if (r < 0)
2640 log_warning_errno(r, "Failed to parse $SYSTEMD_REBOOT_TO_FIRMWARE_SETUP: %m");
2641 else if (r > 0) {
2642 /* Non-EFI case: let's see whether /run/systemd/reboot-to-firmware-setup exists. */
2643 if (access("/run/systemd/reboot-to-firmware-setup", F_OK) < 0) {
2644 if (errno != ENOENT)
2645 log_warning_errno(errno, "Failed to check whether /run/systemd/reboot-to-firmware-setup exists: %m");
2646
2647 r = false;
2648 } else
2649 r = true;
2650 }
2651
2652 return sd_bus_message_append(reply, "b", r > 0);
2653 }
2654
2655 static int method_set_reboot_to_firmware_setup(
2656 sd_bus_message *message,
2657 void *userdata,
2658 sd_bus_error *error) {
2659
2660 Manager *m = userdata;
2661 bool use_efi;
2662 int b, r;
2663
2664 assert(message);
2665 assert(m);
2666
2667 r = sd_bus_message_read(message, "b", &b);
2668 if (r < 0)
2669 return r;
2670
2671 r = getenv_bool("SYSTEMD_REBOOT_TO_FIRMWARE_SETUP");
2672 if (r == -ENXIO) {
2673 /* EFI case: let's see what the firmware supports */
2674
2675 r = efi_reboot_to_firmware_supported();
2676 if (r == -EOPNOTSUPP)
2677 return sd_bus_error_setf(error, SD_BUS_ERROR_NOT_SUPPORTED, "Firmware does not support boot into firmware.");
2678 if (r < 0)
2679 return r;
2680
2681 use_efi = true;
2682
2683 } else if (r <= 0) {
2684 /* non-EFI case: $SYSTEMD_REBOOT_TO_FIRMWARE_SETUP is set to off */
2685
2686 if (r < 0)
2687 log_warning_errno(r, "Failed to parse $SYSTEMD_REBOOT_TO_FIRMWARE_SETUP: %m");
2688
2689 return sd_bus_error_setf(error, SD_BUS_ERROR_NOT_SUPPORTED, "Firmware does not support boot into firmware.");
2690 } else
2691 /* non-EFI case: $SYSTEMD_REBOOT_TO_FIRMWARE_SETUP is set to on */
2692 use_efi = false;
2693
2694 r = bus_verify_polkit_async(message,
2695 CAP_SYS_ADMIN,
2696 "org.freedesktop.login1.set-reboot-to-firmware-setup",
2697 NULL,
2698 false,
2699 UID_INVALID,
2700 &m->polkit_registry,
2701 error);
2702 if (r < 0)
2703 return r;
2704 if (r == 0)
2705 return 1; /* No authorization for now, but the async polkit stuff will call us again when it has it */
2706
2707 if (use_efi) {
2708 r = efi_set_reboot_to_firmware(b);
2709 if (r < 0)
2710 return r;
2711 } else {
2712 if (b) {
2713 r = touch("/run/systemd/reboot-to-firmware-setup");
2714 if (r < 0)
2715 return r;
2716 } else {
2717 if (unlink("/run/systemd/reboot-to-firmware-setup") < 0 && errno != ENOENT)
2718 return -errno;
2719 }
2720 }
2721
2722 return sd_bus_reply_method_return(message, NULL);
2723 }
2724
2725 static int method_can_reboot_to_firmware_setup(
2726 sd_bus_message *message,
2727 void *userdata,
2728 sd_bus_error *error) {
2729
2730 _unused_ Manager *m = userdata;
2731 int r;
2732
2733 assert(message);
2734 assert(m);
2735
2736 r = getenv_bool("SYSTEMD_REBOOT_TO_FIRMWARE_SETUP");
2737 if (r == -ENXIO) {
2738 /* EFI case: let's see what the firmware supports */
2739
2740 r = efi_reboot_to_firmware_supported();
2741 if (r < 0) {
2742 if (r != -EOPNOTSUPP)
2743 log_warning_errno(r, "Failed to determine whether reboot to firmware is supported: %m");
2744
2745 return sd_bus_reply_method_return(message, "s", "na");
2746 }
2747
2748 } else if (r <= 0) {
2749 /* Non-EFI case: let's trust $SYSTEMD_REBOOT_TO_FIRMWARE_SETUP */
2750
2751 if (r < 0)
2752 log_warning_errno(r, "Failed to parse $SYSTEMD_REBOOT_TO_FIRMWARE_SETUP: %m");
2753
2754 return sd_bus_reply_method_return(message, "s", "na");
2755 }
2756
2757 return return_test_polkit(
2758 message,
2759 CAP_SYS_ADMIN,
2760 "org.freedesktop.login1.set-reboot-to-firmware-setup",
2761 NULL,
2762 UID_INVALID,
2763 error);
2764 }
2765
2766 static int property_get_reboot_to_boot_loader_menu(
2767 sd_bus *bus,
2768 const char *path,
2769 const char *interface,
2770 const char *property,
2771 sd_bus_message *reply,
2772 void *userdata,
2773 sd_bus_error *error) {
2774
2775 uint64_t x = UINT64_MAX;
2776 int r;
2777
2778 assert(bus);
2779 assert(reply);
2780 assert(userdata);
2781
2782 r = getenv_bool("SYSTEMD_REBOOT_TO_BOOT_LOADER_MENU");
2783 if (r == -ENXIO) {
2784 /* EFI case: returns the current value of LoaderConfigTimeoutOneShot. Three cases are distuingished:
2785 *
2786 * 1. Variable not set, boot into boot loader menu is not enabled (we return UINT64_MAX to the user)
2787 * 2. Variable set to "0", boot into boot loader menu is enabled with no timeout (we return 0 to the user)
2788 * 3. Variable set to numeric value formatted in ASCII, boot into boot loader menu with the specified timeout in seconds
2789 */
2790
2791 r = efi_loader_get_config_timeout_one_shot(&x);
2792 if (r < 0) {
2793 if (r != -ENOENT)
2794 log_warning_errno(r, "Failed to read LoaderConfigTimeoutOneShot variable, ignoring: %m");
2795 }
2796
2797 } else if (r < 0)
2798 log_warning_errno(r, "Failed to parse $SYSTEMD_REBOOT_TO_BOOT_LOADER_MENU: %m");
2799 else if (r > 0) {
2800 _cleanup_free_ char *v = NULL;
2801
2802 /* Non-EFI case, let's process /run/systemd/reboot-to-boot-loader-menu. */
2803
2804 r = read_one_line_file("/run/systemd/reboot-to-boot-loader-menu", &v);
2805 if (r < 0) {
2806 if (r != -ENOENT)
2807 log_warning_errno(r, "Failed to read /run/systemd/reboot-to-boot-loader-menu: %m");
2808 } else {
2809 r = safe_atou64(v, &x);
2810 if (r < 0)
2811 log_warning_errno(r, "Failed to parse /run/systemd/reboot-to-boot-loader-menu: %m");
2812 }
2813 }
2814
2815 return sd_bus_message_append(reply, "t", x);
2816 }
2817
2818 static int method_set_reboot_to_boot_loader_menu(
2819 sd_bus_message *message,
2820 void *userdata,
2821 sd_bus_error *error) {
2822
2823 Manager *m = userdata;
2824 bool use_efi;
2825 uint64_t x;
2826 int r;
2827
2828 assert(message);
2829 assert(m);
2830
2831 r = sd_bus_message_read(message, "t", &x);
2832 if (r < 0)
2833 return r;
2834
2835 r = getenv_bool("SYSTEMD_REBOOT_TO_BOOT_LOADER_MENU");
2836 if (r == -ENXIO) {
2837 uint64_t features;
2838
2839 /* EFI case: let's see if booting into boot loader menu is supported. */
2840
2841 r = efi_loader_get_features(&features);
2842 if (r < 0)
2843 log_warning_errno(r, "Failed to determine whether reboot to boot loader menu is supported: %m");
2844 if (r < 0 || !FLAGS_SET(features, EFI_LOADER_FEATURE_CONFIG_TIMEOUT_ONE_SHOT))
2845 return sd_bus_error_setf(error, SD_BUS_ERROR_NOT_SUPPORTED, "Boot loader does not support boot into boot loader menu.");
2846
2847 use_efi = true;
2848
2849 } else if (r <= 0) {
2850 /* non-EFI case: $SYSTEMD_REBOOT_TO_BOOT_LOADER_MENU is set to off */
2851
2852 if (r < 0)
2853 log_warning_errno(r, "Failed to parse $SYSTEMD_REBOOT_TO_BOOT_LOADER_MENU: %m");
2854
2855 return sd_bus_error_setf(error, SD_BUS_ERROR_NOT_SUPPORTED, "Boot loader does not support boot into boot loader menu.");
2856 } else
2857 /* non-EFI case: $SYSTEMD_REBOOT_TO_BOOT_LOADER_MENU is set to on */
2858 use_efi = false;
2859
2860 r = bus_verify_polkit_async(message,
2861 CAP_SYS_ADMIN,
2862 "org.freedesktop.login1.set-reboot-to-boot-loader-menu",
2863 NULL,
2864 false,
2865 UID_INVALID,
2866 &m->polkit_registry,
2867 error);
2868 if (r < 0)
2869 return r;
2870 if (r == 0)
2871 return 1; /* No authorization for now, but the async polkit stuff will call us again when it has it */
2872
2873 if (use_efi) {
2874 if (x == UINT64_MAX)
2875 r = efi_set_variable(EFI_VENDOR_LOADER, "LoaderConfigTimeoutOneShot", NULL, 0);
2876 else {
2877 char buf[DECIMAL_STR_MAX(uint64_t) + 1];
2878 xsprintf(buf, "%" PRIu64, DIV_ROUND_UP(x, USEC_PER_SEC)); /* second granularity */
2879
2880 r = efi_set_variable_string(EFI_VENDOR_LOADER, "LoaderConfigTimeoutOneShot", buf);
2881 }
2882 if (r < 0)
2883 return r;
2884 } else {
2885 if (x == UINT64_MAX) {
2886 if (unlink("/run/systemd/reboot-to-boot-loader-menu") < 0 && errno != ENOENT)
2887 return -errno;
2888 } else {
2889 char buf[DECIMAL_STR_MAX(uint64_t) + 1];
2890
2891 xsprintf(buf, "%" PRIu64, x); /* µs granularity */
2892
2893 r = write_string_file_atomic_label("/run/systemd/reboot-to-boot-loader-menu", buf);
2894 if (r < 0)
2895 return r;
2896 }
2897 }
2898
2899 return sd_bus_reply_method_return(message, NULL);
2900 }
2901
2902 static int method_can_reboot_to_boot_loader_menu(
2903 sd_bus_message *message,
2904 void *userdata,
2905 sd_bus_error *error) {
2906
2907 _unused_ Manager *m = userdata;
2908 int r;
2909
2910 assert(message);
2911 assert(m);
2912
2913 r = getenv_bool("SYSTEMD_REBOOT_TO_BOOT_LOADER_MENU");
2914 if (r == -ENXIO) {
2915 uint64_t features = 0;
2916
2917 /* EFI case, let's see if booting into boot loader menu is supported. */
2918
2919 r = efi_loader_get_features(&features);
2920 if (r < 0)
2921 log_warning_errno(r, "Failed to determine whether reboot to boot loader menu is supported: %m");
2922 if (r < 0 || !FLAGS_SET(features, EFI_LOADER_FEATURE_CONFIG_TIMEOUT_ONE_SHOT))
2923 return sd_bus_reply_method_return(message, "s", "na");
2924
2925 } else if (r <= 0) {
2926 /* Non-EFI case: let's trust $SYSTEMD_REBOOT_TO_BOOT_LOADER_MENU */
2927
2928 if (r < 0)
2929 log_warning_errno(r, "Failed to parse $SYSTEMD_REBOOT_TO_BOOT_LOADER_MENU: %m");
2930
2931 return sd_bus_reply_method_return(message, "s", "na");
2932 }
2933
2934 return return_test_polkit(
2935 message,
2936 CAP_SYS_ADMIN,
2937 "org.freedesktop.login1.set-reboot-to-boot-loader-menu",
2938 NULL,
2939 UID_INVALID,
2940 error);
2941 }
2942
2943 static int property_get_reboot_to_boot_loader_entry(
2944 sd_bus *bus,
2945 const char *path,
2946 const char *interface,
2947 const char *property,
2948 sd_bus_message *reply,
2949 void *userdata,
2950 sd_bus_error *error) {
2951
2952 _cleanup_free_ char *v = NULL;
2953 Manager *m = userdata;
2954 const char *x = NULL;
2955 int r;
2956
2957 assert(bus);
2958 assert(reply);
2959 assert(m);
2960
2961 r = getenv_bool("SYSTEMD_REBOOT_TO_BOOT_LOADER_ENTRY");
2962 if (r == -ENXIO) {
2963 /* EFI case: let's read the LoaderEntryOneShot variable */
2964
2965 r = efi_loader_update_entry_one_shot_cache(&m->efi_loader_entry_one_shot, &m->efi_loader_entry_one_shot_stat);
2966 if (r < 0) {
2967 if (r != -ENOENT)
2968 log_warning_errno(r, "Failed to read LoaderEntryOneShot variable, ignoring: %m");
2969 } else
2970 x = m->efi_loader_entry_one_shot;
2971
2972 } else if (r < 0)
2973 log_warning_errno(r, "Failed to parse $SYSTEMD_REBOOT_TO_BOOT_LOADER_ENTRY: %m");
2974 else if (r > 0) {
2975
2976 /* Non-EFI case, let's process /run/systemd/reboot-to-boot-loader-entry. */
2977
2978 r = read_one_line_file("/run/systemd/reboot-to-boot-loader-entry", &v);
2979 if (r < 0) {
2980 if (r != -ENOENT)
2981 log_warning_errno(r, "Failed to read /run/systemd/reboot-to-boot-loader-entry, ignoring: %m");
2982 } else if (!efi_loader_entry_name_valid(v))
2983 log_warning("/run/systemd/reboot-to-boot-loader-entry is not valid, ignoring.");
2984 else
2985 x = v;
2986 }
2987
2988 return sd_bus_message_append(reply, "s", x);
2989 }
2990
2991 static int boot_loader_entry_exists(Manager *m, const char *id) {
2992 _cleanup_(boot_config_free) BootConfig config = {};
2993 int r;
2994
2995 assert(m);
2996 assert(id);
2997
2998 r = boot_entries_load_config_auto(NULL, NULL, &config);
2999 if (r < 0 && r != -ENOKEY) /* don't complain if no GPT is found, hence skip ENOKEY */
3000 return r;
3001
3002 r = manager_read_efi_boot_loader_entries(m);
3003 if (r >= 0)
3004 (void) boot_entries_augment_from_loader(&config, m->efi_boot_loader_entries, true);
3005
3006 return boot_config_has_entry(&config, id);
3007 }
3008
3009 static int method_set_reboot_to_boot_loader_entry(
3010 sd_bus_message *message,
3011 void *userdata,
3012 sd_bus_error *error) {
3013
3014 Manager *m = userdata;
3015 bool use_efi;
3016 const char *v;
3017 int r;
3018
3019 assert(message);
3020 assert(m);
3021
3022 r = sd_bus_message_read(message, "s", &v);
3023 if (r < 0)
3024 return r;
3025
3026 if (isempty(v))
3027 v = NULL;
3028 else if (efi_loader_entry_name_valid(v)) {
3029 r = boot_loader_entry_exists(m, v);
3030 if (r < 0)
3031 return r;
3032 if (r == 0)
3033 return sd_bus_error_setf(error, SD_BUS_ERROR_NOT_SUPPORTED, "Boot loader entry '%s' is not known.", v);
3034 } else
3035 return sd_bus_error_setf(error, SD_BUS_ERROR_INVALID_ARGS, "Boot loader entry name '%s' is not valid, refusing.", v);
3036
3037 r = getenv_bool("SYSTEMD_REBOOT_TO_BOOT_LOADER_ENTRY");
3038 if (r == -ENXIO) {
3039 uint64_t features;
3040
3041 /* EFI case: let's see if booting into boot loader entry is supported. */
3042
3043 r = efi_loader_get_features(&features);
3044 if (r < 0)
3045 log_warning_errno(r, "Failed to determine whether reboot into boot loader entry is supported: %m");
3046 if (r < 0 || !FLAGS_SET(features, EFI_LOADER_FEATURE_ENTRY_ONESHOT))
3047 return sd_bus_error_setf(error, SD_BUS_ERROR_NOT_SUPPORTED, "Loader does not support boot into boot loader entry.");
3048
3049 use_efi = true;
3050
3051 } else if (r <= 0) {
3052 /* non-EFI case: $SYSTEMD_REBOOT_TO_BOOT_LOADER_ENTRY is set to off */
3053
3054 if (r < 0)
3055 log_warning_errno(r, "Failed to parse $SYSTEMD_REBOOT_TO_BOOT_LOADER_ENTRY: %m");
3056
3057 return sd_bus_error_setf(error, SD_BUS_ERROR_NOT_SUPPORTED, "Loader does not support boot into boot loader entry.");
3058 } else
3059 /* non-EFI case: $SYSTEMD_REBOOT_TO_BOOT_LOADER_ENTRY is set to on */
3060 use_efi = false;
3061
3062 r = bus_verify_polkit_async(message,
3063 CAP_SYS_ADMIN,
3064 "org.freedesktop.login1.set-reboot-to-boot-loader-entry",
3065 NULL,
3066 false,
3067 UID_INVALID,
3068 &m->polkit_registry,
3069 error);
3070 if (r < 0)
3071 return r;
3072 if (r == 0)
3073 return 1; /* No authorization for now, but the async polkit stuff will call us again when it has it */
3074
3075 if (use_efi) {
3076 if (isempty(v))
3077 /* Delete item */
3078 r = efi_set_variable(EFI_VENDOR_LOADER, "LoaderEntryOneShot", NULL, 0);
3079 else
3080 r = efi_set_variable_string(EFI_VENDOR_LOADER, "LoaderEntryOneShot", v);
3081 if (r < 0)
3082 return r;
3083 } else {
3084 if (isempty(v)) {
3085 if (unlink("/run/systemd/reboot-to-boot-loader-entry") < 0 && errno != ENOENT)
3086 return -errno;
3087 } else {
3088 r = write_string_file_atomic_label("/run/systemd/reboot-boot-to-loader-entry", v);
3089 if (r < 0)
3090 return r;
3091 }
3092 }
3093
3094 return sd_bus_reply_method_return(message, NULL);
3095 }
3096
3097 static int method_can_reboot_to_boot_loader_entry(
3098 sd_bus_message *message,
3099 void *userdata,
3100 sd_bus_error *error) {
3101
3102 _unused_ Manager *m = userdata;
3103 int r;
3104
3105 assert(message);
3106 assert(m);
3107
3108 r = getenv_bool("SYSTEMD_REBOOT_TO_BOOT_LOADER_ENTRY");
3109 if (r == -ENXIO) {
3110 uint64_t features = 0;
3111
3112 /* EFI case, let's see if booting into boot loader entry is supported. */
3113
3114 r = efi_loader_get_features(&features);
3115 if (r < 0)
3116 log_warning_errno(r, "Failed to determine whether reboot to boot loader entry is supported: %m");
3117 if (r < 0 || !FLAGS_SET(features, EFI_LOADER_FEATURE_ENTRY_ONESHOT))
3118 return sd_bus_reply_method_return(message, "s", "na");
3119
3120 } else if (r <= 0) {
3121 /* Non-EFI case: let's trust $SYSTEMD_REBOOT_TO_BOOT_LOADER_ENTRY */
3122
3123 if (r < 0)
3124 log_warning_errno(r, "Failed to parse $SYSTEMD_REBOOT_TO_BOOT_LOADER_ENTRY: %m");
3125
3126 return sd_bus_reply_method_return(message, "s", "na");
3127 }
3128
3129 return return_test_polkit(
3130 message,
3131 CAP_SYS_ADMIN,
3132 "org.freedesktop.login1.set-reboot-to-boot-loader-entry",
3133 NULL,
3134 UID_INVALID,
3135 error);
3136 }
3137
3138 static int property_get_boot_loader_entries(
3139 sd_bus *bus,
3140 const char *path,
3141 const char *interface,
3142 const char *property,
3143 sd_bus_message *reply,
3144 void *userdata,
3145 sd_bus_error *error) {
3146
3147 _cleanup_(boot_config_free) BootConfig config = {};
3148 Manager *m = userdata;
3149 size_t i;
3150 int r;
3151
3152 assert(bus);
3153 assert(reply);
3154 assert(m);
3155
3156 r = boot_entries_load_config_auto(NULL, NULL, &config);
3157 if (r < 0 && r != -ENOKEY) /* don't complain if there's no GPT found */
3158 return r;
3159
3160 r = manager_read_efi_boot_loader_entries(m);
3161 if (r >= 0)
3162 (void) boot_entries_augment_from_loader(&config, m->efi_boot_loader_entries, true);
3163
3164 r = sd_bus_message_open_container(reply, 'a', "s");
3165 if (r < 0)
3166 return r;
3167
3168 for (i = 0; i < config.n_entries; i++) {
3169 BootEntry *e = config.entries + i;
3170
3171 r = sd_bus_message_append(reply, "s", e->id);
3172 if (r < 0)
3173 return r;
3174 }
3175
3176 return sd_bus_message_close_container(reply);
3177 }
3178
3179 static int method_set_wall_message(
3180 sd_bus_message *message,
3181 void *userdata,
3182 sd_bus_error *error) {
3183
3184 int r;
3185 Manager *m = userdata;
3186 char *wall_message;
3187 unsigned enable_wall_messages;
3188
3189 assert(message);
3190 assert(m);
3191
3192 r = sd_bus_message_read(message, "sb", &wall_message, &enable_wall_messages);
3193 if (r < 0)
3194 return r;
3195
3196 /* Short-circuit the operation if the desired state is already in place, to
3197 * avoid an unnecessary polkit permission check. */
3198 if (streq_ptr(m->wall_message, empty_to_null(wall_message)) &&
3199 m->enable_wall_messages == enable_wall_messages)
3200 goto done;
3201
3202 r = bus_verify_polkit_async(message,
3203 CAP_SYS_ADMIN,
3204 "org.freedesktop.login1.set-wall-message",
3205 NULL,
3206 false,
3207 UID_INVALID,
3208 &m->polkit_registry,
3209 error);
3210 if (r < 0)
3211 return r;
3212 if (r == 0)
3213 return 1; /* Will call us back */
3214
3215 r = free_and_strdup(&m->wall_message, empty_to_null(wall_message));
3216 if (r < 0)
3217 return log_oom();
3218
3219 m->enable_wall_messages = enable_wall_messages;
3220
3221 done:
3222 return sd_bus_reply_method_return(message, NULL);
3223 }
3224
3225 static int method_inhibit(sd_bus_message *message, void *userdata, sd_bus_error *error) {
3226 _cleanup_(sd_bus_creds_unrefp) sd_bus_creds *creds = NULL;
3227 const char *who, *why, *what, *mode;
3228 _cleanup_free_ char *id = NULL;
3229 _cleanup_close_ int fifo_fd = -1;
3230 Manager *m = userdata;
3231 InhibitMode mm;
3232 InhibitWhat w;
3233 pid_t pid;
3234 uid_t uid;
3235 int r;
3236
3237 assert(message);
3238 assert(m);
3239
3240 r = sd_bus_message_read(message, "ssss", &what, &who, &why, &mode);
3241 if (r < 0)
3242 return r;
3243
3244 w = inhibit_what_from_string(what);
3245 if (w <= 0)
3246 return sd_bus_error_setf(error, SD_BUS_ERROR_INVALID_ARGS,
3247 "Invalid what specification %s", what);
3248
3249 mm = inhibit_mode_from_string(mode);
3250 if (mm < 0)
3251 return sd_bus_error_setf(error, SD_BUS_ERROR_INVALID_ARGS,
3252 "Invalid mode specification %s", mode);
3253
3254 /* Delay is only supported for shutdown/sleep */
3255 if (mm == INHIBIT_DELAY && (w & ~(INHIBIT_SHUTDOWN|INHIBIT_SLEEP)))
3256 return sd_bus_error_setf(error, SD_BUS_ERROR_INVALID_ARGS,
3257 "Delay inhibitors only supported for shutdown and sleep");
3258
3259 /* Don't allow taking delay locks while we are already
3260 * executing the operation. We shouldn't create the impression
3261 * that the lock was successful if the machine is about to go
3262 * down/suspend any moment. */
3263 if (m->action_what & w)
3264 return sd_bus_error_setf(error, BUS_ERROR_OPERATION_IN_PROGRESS,
3265 "The operation inhibition has been requested for is already running");
3266
3267 r = bus_verify_polkit_async(
3268 message,
3269 CAP_SYS_BOOT,
3270 w == INHIBIT_SHUTDOWN ? (mm == INHIBIT_BLOCK ? "org.freedesktop.login1.inhibit-block-shutdown" : "org.freedesktop.login1.inhibit-delay-shutdown") :
3271 w == INHIBIT_SLEEP ? (mm == INHIBIT_BLOCK ? "org.freedesktop.login1.inhibit-block-sleep" : "org.freedesktop.login1.inhibit-delay-sleep") :
3272 w == INHIBIT_IDLE ? "org.freedesktop.login1.inhibit-block-idle" :
3273 w == INHIBIT_HANDLE_POWER_KEY ? "org.freedesktop.login1.inhibit-handle-power-key" :
3274 w == INHIBIT_HANDLE_SUSPEND_KEY ? "org.freedesktop.login1.inhibit-handle-suspend-key" :
3275 w == INHIBIT_HANDLE_REBOOT_KEY ? "org.freedesktop.login1.inhibit-handle-reboot-key" :
3276 w == INHIBIT_HANDLE_HIBERNATE_KEY ? "org.freedesktop.login1.inhibit-handle-hibernate-key" :
3277 "org.freedesktop.login1.inhibit-handle-lid-switch",
3278 NULL,
3279 false,
3280 UID_INVALID,
3281 &m->polkit_registry,
3282 error);
3283 if (r < 0)
3284 return r;
3285 if (r == 0)
3286 return 1; /* No authorization for now, but the async polkit stuff will call us again when it has it */
3287
3288 r = sd_bus_query_sender_creds(message, SD_BUS_CREDS_EUID|SD_BUS_CREDS_PID, &creds);
3289 if (r < 0)
3290 return r;
3291
3292 r = sd_bus_creds_get_euid(creds, &uid);
3293 if (r < 0)
3294 return r;
3295
3296 r = sd_bus_creds_get_pid(creds, &pid);
3297 if (r < 0)
3298 return r;
3299
3300 if (hashmap_size(m->inhibitors) >= m->inhibitors_max)
3301 return sd_bus_error_setf(error, SD_BUS_ERROR_LIMITS_EXCEEDED,
3302 "Maximum number of inhibitors (%" PRIu64 ") reached, refusing further inhibitors.",
3303 m->inhibitors_max);
3304
3305 do {
3306 id = mfree(id);
3307
3308 if (asprintf(&id, "%lu", ++m->inhibit_counter) < 0)
3309 return -ENOMEM;
3310
3311 } while (hashmap_get(m->inhibitors, id));
3312
3313 _cleanup_(inhibitor_freep) Inhibitor *i = NULL;
3314 r = manager_add_inhibitor(m, id, &i);
3315 if (r < 0)
3316 return r;
3317
3318 i->what = w;
3319 i->mode = mm;
3320 i->pid = pid;
3321 i->uid = uid;
3322 i->why = strdup(why);
3323 i->who = strdup(who);
3324
3325 if (!i->why || !i->who)
3326 return -ENOMEM;
3327
3328 fifo_fd = inhibitor_create_fifo(i);
3329 if (fifo_fd < 0)
3330 return fifo_fd;
3331
3332 r = inhibitor_start(i);
3333 if (r < 0)
3334 return r;
3335 TAKE_PTR(i);
3336
3337 return sd_bus_reply_method_return(message, "h", fifo_fd);
3338 }
3339
3340 static const sd_bus_vtable manager_vtable[] = {
3341 SD_BUS_VTABLE_START(0),
3342
3343 SD_BUS_WRITABLE_PROPERTY("EnableWallMessages", "b", NULL, NULL, offsetof(Manager, enable_wall_messages), 0),
3344 SD_BUS_WRITABLE_PROPERTY("WallMessage", "s", NULL, NULL, offsetof(Manager, wall_message), 0),
3345
3346 SD_BUS_PROPERTY("NAutoVTs", "u", NULL, offsetof(Manager, n_autovts), SD_BUS_VTABLE_PROPERTY_CONST),
3347 SD_BUS_PROPERTY("KillOnlyUsers", "as", NULL, offsetof(Manager, kill_only_users), SD_BUS_VTABLE_PROPERTY_CONST),
3348 SD_BUS_PROPERTY("KillExcludeUsers", "as", NULL, offsetof(Manager, kill_exclude_users), SD_BUS_VTABLE_PROPERTY_CONST),
3349 SD_BUS_PROPERTY("KillUserProcesses", "b", NULL, offsetof(Manager, kill_user_processes), SD_BUS_VTABLE_PROPERTY_CONST),
3350 SD_BUS_PROPERTY("RebootParameter", "s", property_get_reboot_parameter, 0, 0),
3351 SD_BUS_PROPERTY("RebootToFirmwareSetup", "b", property_get_reboot_to_firmware_setup, 0, 0),
3352 SD_BUS_PROPERTY("RebootToBootLoaderMenu", "t", property_get_reboot_to_boot_loader_menu, 0, 0),
3353 SD_BUS_PROPERTY("RebootToBootLoaderEntry", "s", property_get_reboot_to_boot_loader_entry, 0, 0),
3354 SD_BUS_PROPERTY("BootLoaderEntries", "as", property_get_boot_loader_entries, 0, SD_BUS_VTABLE_PROPERTY_CONST),
3355 SD_BUS_PROPERTY("IdleHint", "b", property_get_idle_hint, 0, SD_BUS_VTABLE_PROPERTY_EMITS_CHANGE),
3356 SD_BUS_PROPERTY("IdleSinceHint", "t", property_get_idle_since_hint, 0, SD_BUS_VTABLE_PROPERTY_EMITS_CHANGE),
3357 SD_BUS_PROPERTY("IdleSinceHintMonotonic", "t", property_get_idle_since_hint, 0, SD_BUS_VTABLE_PROPERTY_EMITS_CHANGE),
3358 SD_BUS_PROPERTY("BlockInhibited", "s", property_get_inhibited, 0, SD_BUS_VTABLE_PROPERTY_EMITS_CHANGE),
3359 SD_BUS_PROPERTY("DelayInhibited", "s", property_get_inhibited, 0, SD_BUS_VTABLE_PROPERTY_EMITS_CHANGE),
3360 SD_BUS_PROPERTY("InhibitDelayMaxUSec", "t", NULL, offsetof(Manager, inhibit_delay_max), SD_BUS_VTABLE_PROPERTY_CONST),
3361 SD_BUS_PROPERTY("UserStopDelayUSec", "t", NULL, offsetof(Manager, user_stop_delay), SD_BUS_VTABLE_PROPERTY_CONST),
3362 SD_BUS_PROPERTY("HandlePowerKey", "s", property_get_handle_action, offsetof(Manager, handle_power_key), SD_BUS_VTABLE_PROPERTY_CONST),
3363 SD_BUS_PROPERTY("HandleSuspendKey", "s", property_get_handle_action, offsetof(Manager, handle_suspend_key), SD_BUS_VTABLE_PROPERTY_CONST),
3364 SD_BUS_PROPERTY("HandleHibernateKey", "s", property_get_handle_action, offsetof(Manager, handle_hibernate_key), SD_BUS_VTABLE_PROPERTY_CONST),
3365 SD_BUS_PROPERTY("HandleLidSwitch", "s", property_get_handle_action, offsetof(Manager, handle_lid_switch), SD_BUS_VTABLE_PROPERTY_CONST),
3366 SD_BUS_PROPERTY("HandleLidSwitchExternalPower", "s", property_get_handle_action, offsetof(Manager, handle_lid_switch_ep), SD_BUS_VTABLE_PROPERTY_CONST),
3367 SD_BUS_PROPERTY("HandleLidSwitchDocked", "s", property_get_handle_action, offsetof(Manager, handle_lid_switch_docked), SD_BUS_VTABLE_PROPERTY_CONST),
3368 SD_BUS_PROPERTY("HoldoffTimeoutUSec", "t", NULL, offsetof(Manager, holdoff_timeout_usec), SD_BUS_VTABLE_PROPERTY_CONST),
3369 SD_BUS_PROPERTY("IdleAction", "s", property_get_handle_action, offsetof(Manager, idle_action), SD_BUS_VTABLE_PROPERTY_CONST),
3370 SD_BUS_PROPERTY("IdleActionUSec", "t", NULL, offsetof(Manager, idle_action_usec), SD_BUS_VTABLE_PROPERTY_CONST),
3371 SD_BUS_PROPERTY("PreparingForShutdown", "b", property_get_preparing, 0, 0),
3372 SD_BUS_PROPERTY("PreparingForSleep", "b", property_get_preparing, 0, 0),
3373 SD_BUS_PROPERTY("ScheduledShutdown", "(st)", property_get_scheduled_shutdown, 0, 0),
3374 SD_BUS_PROPERTY("Docked", "b", property_get_docked, 0, 0),
3375 SD_BUS_PROPERTY("LidClosed", "b", property_get_lid_closed, 0, 0),
3376 SD_BUS_PROPERTY("OnExternalPower", "b", property_get_on_external_power, 0, 0),
3377 SD_BUS_PROPERTY("RemoveIPC", "b", bus_property_get_bool, offsetof(Manager, remove_ipc), SD_BUS_VTABLE_PROPERTY_CONST),
3378 SD_BUS_PROPERTY("RuntimeDirectorySize", "t", NULL, offsetof(Manager, runtime_dir_size), SD_BUS_VTABLE_PROPERTY_CONST),
3379 SD_BUS_PROPERTY("RuntimeDirectoryInodesMax", "t", NULL, offsetof(Manager, runtime_dir_inodes), SD_BUS_VTABLE_PROPERTY_CONST),
3380 SD_BUS_PROPERTY("InhibitorsMax", "t", NULL, offsetof(Manager, inhibitors_max), SD_BUS_VTABLE_PROPERTY_CONST),
3381 SD_BUS_PROPERTY("NCurrentInhibitors", "t", property_get_hashmap_size, offsetof(Manager, inhibitors), 0),
3382 SD_BUS_PROPERTY("SessionsMax", "t", NULL, offsetof(Manager, sessions_max), SD_BUS_VTABLE_PROPERTY_CONST),
3383 SD_BUS_PROPERTY("NCurrentSessions", "t", property_get_hashmap_size, offsetof(Manager, sessions), 0),
3384 SD_BUS_PROPERTY("UserTasksMax", "t", property_get_compat_user_tasks_max, 0, SD_BUS_VTABLE_PROPERTY_CONST|SD_BUS_VTABLE_HIDDEN),
3385
3386 SD_BUS_METHOD_WITH_NAMES("GetSession",
3387 "s",
3388 SD_BUS_PARAM(session_id),
3389 "o",
3390 SD_BUS_PARAM(object_path),
3391 method_get_session,
3392 SD_BUS_VTABLE_UNPRIVILEGED),
3393 SD_BUS_METHOD_WITH_NAMES("GetSessionByPID",
3394 "u",
3395 SD_BUS_PARAM(pid),
3396 "o",
3397 SD_BUS_PARAM(object_path),
3398 method_get_session_by_pid,
3399 SD_BUS_VTABLE_UNPRIVILEGED),
3400 SD_BUS_METHOD_WITH_NAMES("GetUser",
3401 "u",
3402 SD_BUS_PARAM(uid),
3403 "o",
3404 SD_BUS_PARAM(object_path),
3405 method_get_user,
3406 SD_BUS_VTABLE_UNPRIVILEGED),
3407 SD_BUS_METHOD_WITH_NAMES("GetUserByPID",
3408 "u",
3409 SD_BUS_PARAM(pid),
3410 "o",
3411 SD_BUS_PARAM(object_path),
3412 method_get_user_by_pid,
3413 SD_BUS_VTABLE_UNPRIVILEGED),
3414 SD_BUS_METHOD_WITH_NAMES("GetSeat",
3415 "s",
3416 SD_BUS_PARAM(seat_id),
3417 "o",
3418 SD_BUS_PARAM(object_path),
3419 method_get_seat,
3420 SD_BUS_VTABLE_UNPRIVILEGED),
3421 SD_BUS_METHOD_WITH_NAMES("ListSessions",
3422 NULL,,
3423 "a(susso)",
3424 SD_BUS_PARAM(sessions),
3425 method_list_sessions,
3426 SD_BUS_VTABLE_UNPRIVILEGED),
3427 SD_BUS_METHOD_WITH_NAMES("ListUsers",
3428 NULL,,
3429 "a(uso)",
3430 SD_BUS_PARAM(users),
3431 method_list_users,
3432 SD_BUS_VTABLE_UNPRIVILEGED),
3433 SD_BUS_METHOD_WITH_NAMES("ListSeats",
3434 NULL,,
3435 "a(so)",
3436 SD_BUS_PARAM(seats),
3437 method_list_seats,
3438 SD_BUS_VTABLE_UNPRIVILEGED),
3439 SD_BUS_METHOD_WITH_NAMES("ListInhibitors",
3440 NULL,,
3441 "a(ssssuu)",
3442 SD_BUS_PARAM(inhibitors),
3443 method_list_inhibitors,
3444 SD_BUS_VTABLE_UNPRIVILEGED),
3445 SD_BUS_METHOD_WITH_NAMES("CreateSession",
3446 "uusssssussbssa(sv)",
3447 SD_BUS_PARAM(uid)
3448 SD_BUS_PARAM(pid)
3449 SD_BUS_PARAM(service)
3450 SD_BUS_PARAM(type)
3451 SD_BUS_PARAM(class)
3452 SD_BUS_PARAM(desktop)
3453 SD_BUS_PARAM(seat_id)
3454 SD_BUS_PARAM(vtnr)
3455 SD_BUS_PARAM(tty)
3456 SD_BUS_PARAM(display)
3457 SD_BUS_PARAM(remote)
3458 SD_BUS_PARAM(remote_user)
3459 SD_BUS_PARAM(remote_host)
3460 SD_BUS_PARAM(properties),
3461 "soshusub",
3462 SD_BUS_PARAM(session_id)
3463 SD_BUS_PARAM(object_path)
3464 SD_BUS_PARAM(runtime_path)
3465 SD_BUS_PARAM(fifo_fd)
3466 SD_BUS_PARAM(uid)
3467 SD_BUS_PARAM(seat_id)
3468 SD_BUS_PARAM(vtnr)
3469 SD_BUS_PARAM(existing),
3470 method_create_session,
3471 0),
3472 SD_BUS_METHOD_WITH_NAMES("ReleaseSession",
3473 "s",
3474 SD_BUS_PARAM(session_id),
3475 NULL,,
3476 method_release_session,
3477 0),
3478 SD_BUS_METHOD_WITH_NAMES("ActivateSession",
3479 "s",
3480 SD_BUS_PARAM(session_id),
3481 NULL,,
3482 method_activate_session,
3483 SD_BUS_VTABLE_UNPRIVILEGED),
3484 SD_BUS_METHOD_WITH_NAMES("ActivateSessionOnSeat",
3485 "ss",
3486 SD_BUS_PARAM(session_id)
3487 SD_BUS_PARAM(seat_id),
3488 NULL,,
3489 method_activate_session_on_seat,
3490 SD_BUS_VTABLE_UNPRIVILEGED),
3491 SD_BUS_METHOD_WITH_NAMES("LockSession",
3492 "s",
3493 SD_BUS_PARAM(session_id),
3494 NULL,,
3495 method_lock_session,
3496 SD_BUS_VTABLE_UNPRIVILEGED),
3497 SD_BUS_METHOD_WITH_NAMES("UnlockSession",
3498 "s",
3499 SD_BUS_PARAM(session_id),
3500 NULL,,
3501 method_lock_session,
3502 SD_BUS_VTABLE_UNPRIVILEGED),
3503 SD_BUS_METHOD("LockSessions",
3504 NULL,
3505 NULL,
3506 method_lock_sessions,
3507 SD_BUS_VTABLE_UNPRIVILEGED),
3508 SD_BUS_METHOD("UnlockSessions",
3509 NULL,
3510 NULL,
3511 method_lock_sessions,
3512 SD_BUS_VTABLE_UNPRIVILEGED),
3513 SD_BUS_METHOD_WITH_NAMES("KillSession",
3514 "ssi",
3515 SD_BUS_PARAM(session_id)
3516 SD_BUS_PARAM(who)
3517 SD_BUS_PARAM(signal_number),
3518 NULL,,
3519 method_kill_session,
3520 SD_BUS_VTABLE_UNPRIVILEGED),
3521 SD_BUS_METHOD_WITH_NAMES("KillUser",
3522 "ui",
3523 SD_BUS_PARAM(uid)
3524 SD_BUS_PARAM(signal_number),
3525 NULL,,
3526 method_kill_user,
3527 SD_BUS_VTABLE_UNPRIVILEGED),
3528 SD_BUS_METHOD_WITH_NAMES("TerminateSession",
3529 "s",
3530 SD_BUS_PARAM(session_id),
3531 NULL,,
3532 method_terminate_session,
3533 SD_BUS_VTABLE_UNPRIVILEGED),
3534 SD_BUS_METHOD_WITH_NAMES("TerminateUser",
3535 "u",
3536 SD_BUS_PARAM(uid),
3537 NULL,,
3538 method_terminate_user,
3539 SD_BUS_VTABLE_UNPRIVILEGED),
3540 SD_BUS_METHOD_WITH_NAMES("TerminateSeat",
3541 "s",
3542 SD_BUS_PARAM(seat_id),
3543 NULL,,
3544 method_terminate_seat,
3545 SD_BUS_VTABLE_UNPRIVILEGED),
3546 SD_BUS_METHOD_WITH_NAMES("SetUserLinger",
3547 "ubb",
3548 SD_BUS_PARAM(uid)
3549 SD_BUS_PARAM(enable)
3550 SD_BUS_PARAM(interactive),
3551 NULL,,
3552 method_set_user_linger,
3553 SD_BUS_VTABLE_UNPRIVILEGED),
3554 SD_BUS_METHOD_WITH_NAMES("AttachDevice",
3555 "ssb",
3556 SD_BUS_PARAM(seat_id)
3557 SD_BUS_PARAM(sysfs_path)
3558 SD_BUS_PARAM(interactive),
3559 NULL,,
3560 method_attach_device,
3561 SD_BUS_VTABLE_UNPRIVILEGED),
3562 SD_BUS_METHOD_WITH_NAMES("FlushDevices",
3563 "b",
3564 SD_BUS_PARAM(interactive),
3565 NULL,,
3566 method_flush_devices,
3567 SD_BUS_VTABLE_UNPRIVILEGED),
3568 SD_BUS_METHOD_WITH_NAMES("PowerOff",
3569 "b",
3570 SD_BUS_PARAM(interactive),
3571 NULL,,
3572 method_poweroff,
3573 SD_BUS_VTABLE_UNPRIVILEGED),
3574 SD_BUS_METHOD_WITH_NAMES("PowerOffWithFlags",
3575 "t",
3576 SD_BUS_PARAM(flags),
3577 NULL,,
3578 method_poweroff,
3579 SD_BUS_VTABLE_UNPRIVILEGED),
3580 SD_BUS_METHOD_WITH_NAMES("Reboot",
3581 "b",
3582 SD_BUS_PARAM(interactive),
3583 NULL,,
3584 method_reboot,
3585 SD_BUS_VTABLE_UNPRIVILEGED),
3586 SD_BUS_METHOD_WITH_NAMES("RebootWithFlags",
3587 "t",
3588 SD_BUS_PARAM(flags),
3589 NULL,,
3590 method_reboot,
3591 SD_BUS_VTABLE_UNPRIVILEGED),
3592 SD_BUS_METHOD_WITH_NAMES("Halt",
3593 "b",
3594 SD_BUS_PARAM(interactive),
3595 NULL,,
3596 method_halt,
3597 SD_BUS_VTABLE_UNPRIVILEGED),
3598 SD_BUS_METHOD_WITH_NAMES("HaltWithFlags",
3599 "t",
3600 SD_BUS_PARAM(flags),
3601 NULL,,
3602 method_halt,
3603 SD_BUS_VTABLE_UNPRIVILEGED),
3604 SD_BUS_METHOD_WITH_NAMES("Suspend",
3605 "b",
3606 SD_BUS_PARAM(interactive),
3607 NULL,,
3608 method_suspend,
3609 SD_BUS_VTABLE_UNPRIVILEGED),
3610 SD_BUS_METHOD_WITH_NAMES("SuspendWithFlags",
3611 "t",
3612 SD_BUS_PARAM(flags),
3613 NULL,,
3614 method_suspend,
3615 SD_BUS_VTABLE_UNPRIVILEGED),
3616 SD_BUS_METHOD_WITH_NAMES("Hibernate",
3617 "b",
3618 SD_BUS_PARAM(interactive),
3619 NULL,,
3620 method_hibernate,
3621 SD_BUS_VTABLE_UNPRIVILEGED),
3622 SD_BUS_METHOD_WITH_NAMES("HibernateWithFlags",
3623 "t",
3624 SD_BUS_PARAM(flags),
3625 NULL,,
3626 method_hibernate,
3627 SD_BUS_VTABLE_UNPRIVILEGED),
3628 SD_BUS_METHOD_WITH_NAMES("HybridSleep",
3629 "b",
3630 SD_BUS_PARAM(interactive),
3631 NULL,,
3632 method_hybrid_sleep,
3633 SD_BUS_VTABLE_UNPRIVILEGED),
3634 SD_BUS_METHOD_WITH_NAMES("HybridSleepWithFlags",
3635 "t",
3636 SD_BUS_PARAM(flags),
3637 NULL,,
3638 method_hybrid_sleep,
3639 SD_BUS_VTABLE_UNPRIVILEGED),
3640 SD_BUS_METHOD_WITH_NAMES("SuspendThenHibernate",
3641 "b",
3642 SD_BUS_PARAM(interactive),
3643 NULL,,
3644 method_suspend_then_hibernate,
3645 SD_BUS_VTABLE_UNPRIVILEGED),
3646 SD_BUS_METHOD_WITH_NAMES("SuspendThenHibernateWithFlags",
3647 "t",
3648 SD_BUS_PARAM(flags),
3649 NULL,,
3650 method_suspend_then_hibernate,
3651 SD_BUS_VTABLE_UNPRIVILEGED),
3652 SD_BUS_METHOD_WITH_NAMES("CanPowerOff",
3653 NULL,,
3654 "s",
3655 SD_BUS_PARAM(result),
3656 method_can_poweroff,
3657 SD_BUS_VTABLE_UNPRIVILEGED),
3658 SD_BUS_METHOD_WITH_NAMES("CanReboot",
3659 NULL,,
3660 "s",
3661 SD_BUS_PARAM(result),
3662 method_can_reboot,
3663 SD_BUS_VTABLE_UNPRIVILEGED),
3664 SD_BUS_METHOD_WITH_NAMES("CanHalt",
3665 NULL,,
3666 "s",
3667 SD_BUS_PARAM(result),
3668 method_can_halt,
3669 SD_BUS_VTABLE_UNPRIVILEGED),
3670 SD_BUS_METHOD_WITH_NAMES("CanSuspend",
3671 NULL,,
3672 "s",
3673 SD_BUS_PARAM(result),
3674 method_can_suspend,
3675 SD_BUS_VTABLE_UNPRIVILEGED),
3676 SD_BUS_METHOD_WITH_NAMES("CanHibernate",
3677 NULL,,
3678 "s",
3679 SD_BUS_PARAM(result),
3680 method_can_hibernate,
3681 SD_BUS_VTABLE_UNPRIVILEGED),
3682 SD_BUS_METHOD_WITH_NAMES("CanHybridSleep",
3683 NULL,,
3684 "s",
3685 SD_BUS_PARAM(result),
3686 method_can_hybrid_sleep,
3687 SD_BUS_VTABLE_UNPRIVILEGED),
3688 SD_BUS_METHOD_WITH_NAMES("CanSuspendThenHibernate",
3689 NULL,,
3690 "s",
3691 SD_BUS_PARAM(result),
3692 method_can_suspend_then_hibernate,
3693 SD_BUS_VTABLE_UNPRIVILEGED),
3694 SD_BUS_METHOD_WITH_NAMES("ScheduleShutdown",
3695 "st",
3696 SD_BUS_PARAM(type)
3697 SD_BUS_PARAM(usec),
3698 NULL,,
3699 method_schedule_shutdown,
3700 SD_BUS_VTABLE_UNPRIVILEGED),
3701 SD_BUS_METHOD_WITH_NAMES("CancelScheduledShutdown",
3702 NULL,,
3703 "b",
3704 SD_BUS_PARAM(cancelled),
3705 method_cancel_scheduled_shutdown,
3706 SD_BUS_VTABLE_UNPRIVILEGED),
3707 SD_BUS_METHOD_WITH_NAMES("Inhibit",
3708 "ssss",
3709 SD_BUS_PARAM(what)
3710 SD_BUS_PARAM(who)
3711 SD_BUS_PARAM(why)
3712 SD_BUS_PARAM(mode),
3713 "h",
3714 SD_BUS_PARAM(pipe_fd),
3715 method_inhibit,
3716 SD_BUS_VTABLE_UNPRIVILEGED),
3717 SD_BUS_METHOD_WITH_NAMES("CanRebootParameter",
3718 NULL,,
3719 "s",
3720 SD_BUS_PARAM(result),
3721 method_can_reboot_parameter,
3722 SD_BUS_VTABLE_UNPRIVILEGED),
3723 SD_BUS_METHOD_WITH_NAMES("SetRebootParameter",
3724 "s",
3725 SD_BUS_PARAM(parameter),
3726 NULL,,
3727 method_set_reboot_parameter,
3728 SD_BUS_VTABLE_UNPRIVILEGED),
3729 SD_BUS_METHOD_WITH_NAMES("CanRebootToFirmwareSetup",
3730 NULL,,
3731 "s",
3732 SD_BUS_PARAM(result),
3733 method_can_reboot_to_firmware_setup,
3734 SD_BUS_VTABLE_UNPRIVILEGED),
3735 SD_BUS_METHOD_WITH_NAMES("SetRebootToFirmwareSetup",
3736 "b",
3737 SD_BUS_PARAM(enable),
3738 NULL,,
3739 method_set_reboot_to_firmware_setup,
3740 SD_BUS_VTABLE_UNPRIVILEGED),
3741 SD_BUS_METHOD_WITH_NAMES("CanRebootToBootLoaderMenu",
3742 NULL,,
3743 "s",
3744 SD_BUS_PARAM(result),
3745 method_can_reboot_to_boot_loader_menu,
3746 SD_BUS_VTABLE_UNPRIVILEGED),
3747 SD_BUS_METHOD_WITH_NAMES("SetRebootToBootLoaderMenu",
3748 "t",
3749 SD_BUS_PARAM(timeout),
3750 NULL,,
3751 method_set_reboot_to_boot_loader_menu,
3752 SD_BUS_VTABLE_UNPRIVILEGED),
3753 SD_BUS_METHOD_WITH_NAMES("CanRebootToBootLoaderEntry",
3754 NULL,,
3755 "s",
3756 SD_BUS_PARAM(result),
3757 method_can_reboot_to_boot_loader_entry,
3758 SD_BUS_VTABLE_UNPRIVILEGED),
3759 SD_BUS_METHOD_WITH_NAMES("SetRebootToBootLoaderEntry",
3760 "s",
3761 SD_BUS_PARAM(boot_loader_entry),
3762 NULL,,
3763 method_set_reboot_to_boot_loader_entry,
3764 SD_BUS_VTABLE_UNPRIVILEGED),
3765 SD_BUS_METHOD_WITH_NAMES("SetWallMessage",
3766 "sb",
3767 SD_BUS_PARAM(wall_message)
3768 SD_BUS_PARAM(enable),
3769 NULL,,
3770 method_set_wall_message,
3771 SD_BUS_VTABLE_UNPRIVILEGED),
3772
3773 SD_BUS_SIGNAL_WITH_NAMES("SessionNew",
3774 "so",
3775 SD_BUS_PARAM(session_id)
3776 SD_BUS_PARAM(object_path),
3777 0),
3778 SD_BUS_SIGNAL_WITH_NAMES("SessionRemoved",
3779 "so",
3780 SD_BUS_PARAM(session_id)
3781 SD_BUS_PARAM(object_path),
3782 0),
3783 SD_BUS_SIGNAL_WITH_NAMES("UserNew",
3784 "uo",
3785 SD_BUS_PARAM(uid)
3786 SD_BUS_PARAM(object_path),
3787 0),
3788 SD_BUS_SIGNAL_WITH_NAMES("UserRemoved",
3789 "uo",
3790 SD_BUS_PARAM(uid)
3791 SD_BUS_PARAM(object_path),
3792 0),
3793 SD_BUS_SIGNAL_WITH_NAMES("SeatNew",
3794 "so",
3795 SD_BUS_PARAM(seat_id)
3796 SD_BUS_PARAM(object_path),
3797 0),
3798 SD_BUS_SIGNAL_WITH_NAMES("SeatRemoved",
3799 "so",
3800 SD_BUS_PARAM(seat_id)
3801 SD_BUS_PARAM(object_path),
3802 0),
3803 SD_BUS_SIGNAL_WITH_NAMES("PrepareForShutdown",
3804 "b",
3805 SD_BUS_PARAM(start),
3806 0),
3807 SD_BUS_SIGNAL_WITH_NAMES("PrepareForSleep",
3808 "b",
3809 SD_BUS_PARAM(start),
3810 0),
3811
3812 SD_BUS_VTABLE_END
3813 };
3814
3815 const BusObjectImplementation manager_object = {
3816 "/org/freedesktop/login1",
3817 "org.freedesktop.login1.Manager",
3818 .vtables = BUS_VTABLES(manager_vtable),
3819 .children = BUS_IMPLEMENTATIONS(&seat_object,
3820 &session_object,
3821 &user_object),
3822 };
3823
3824 static int session_jobs_reply(Session *s, uint32_t jid, const char *unit, const char *result) {
3825 assert(s);
3826 assert(unit);
3827
3828 if (!s->started)
3829 return 0;
3830
3831 if (result && !streq(result, "done")) {
3832 _cleanup_(sd_bus_error_free) sd_bus_error e = SD_BUS_ERROR_NULL;
3833
3834 sd_bus_error_setf(&e, BUS_ERROR_JOB_FAILED,
3835 "Job %u for unit '%s' failed with '%s'", jid, unit, result);
3836 return session_send_create_reply(s, &e);
3837 }
3838
3839 return session_send_create_reply(s, NULL);
3840 }
3841
3842 int match_job_removed(sd_bus_message *message, void *userdata, sd_bus_error *error) {
3843 const char *path, *result, *unit;
3844 Manager *m = userdata;
3845 Session *session;
3846 uint32_t id;
3847 User *user;
3848 int r;
3849
3850 assert(message);
3851 assert(m);
3852
3853 r = sd_bus_message_read(message, "uoss", &id, &path, &unit, &result);
3854 if (r < 0) {
3855 bus_log_parse_error(r);
3856 return 0;
3857 }
3858
3859 if (m->action_job && streq(m->action_job, path)) {
3860 log_info("Operation '%s' finished.", inhibit_what_to_string(m->action_what));
3861
3862 /* Tell people that they now may take a lock again */
3863 (void) send_prepare_for(m, m->action_what, false);
3864
3865 m->action_job = mfree(m->action_job);
3866 m->action_unit = NULL;
3867 m->action_what = 0;
3868 return 0;
3869 }
3870
3871 session = hashmap_get(m->session_units, unit);
3872 if (session) {
3873 if (streq_ptr(path, session->scope_job)) {
3874 session->scope_job = mfree(session->scope_job);
3875 (void) session_jobs_reply(session, id, unit, result);
3876
3877 session_save(session);
3878 user_save(session->user);
3879 }
3880
3881 session_add_to_gc_queue(session);
3882 }
3883
3884 user = hashmap_get(m->user_units, unit);
3885 if (user) {
3886 if (streq_ptr(path, user->service_job)) {
3887 user->service_job = mfree(user->service_job);
3888
3889 LIST_FOREACH(sessions_by_user, session, user->sessions)
3890 (void) session_jobs_reply(session, id, unit, NULL /* don't propagate user service failures to the client */);
3891
3892 user_save(user);
3893 }
3894
3895 user_add_to_gc_queue(user);
3896 }
3897
3898 return 0;
3899 }
3900
3901 int match_unit_removed(sd_bus_message *message, void *userdata, sd_bus_error *error) {
3902 const char *path, *unit;
3903 Manager *m = userdata;
3904 Session *session;
3905 User *user;
3906 int r;
3907
3908 assert(message);
3909 assert(m);
3910
3911 r = sd_bus_message_read(message, "so", &unit, &path);
3912 if (r < 0) {
3913 bus_log_parse_error(r);
3914 return 0;
3915 }
3916
3917 session = hashmap_get(m->session_units, unit);
3918 if (session)
3919 session_add_to_gc_queue(session);
3920
3921 user = hashmap_get(m->user_units, unit);
3922 if (user)
3923 user_add_to_gc_queue(user);
3924
3925 return 0;
3926 }
3927
3928 int match_properties_changed(sd_bus_message *message, void *userdata, sd_bus_error *error) {
3929 _cleanup_free_ char *unit = NULL;
3930 Manager *m = userdata;
3931 const char *path;
3932 Session *session;
3933 User *user;
3934 int r;
3935
3936 assert(message);
3937 assert(m);
3938
3939 path = sd_bus_message_get_path(message);
3940 if (!path)
3941 return 0;
3942
3943 r = unit_name_from_dbus_path(path, &unit);
3944 if (r == -EINVAL) /* not a unit */
3945 return 0;
3946 if (r < 0) {
3947 log_oom();
3948 return 0;
3949 }
3950
3951 session = hashmap_get(m->session_units, unit);
3952 if (session)
3953 session_add_to_gc_queue(session);
3954
3955 user = hashmap_get(m->user_units, unit);
3956 if (user)
3957 user_add_to_gc_queue(user);
3958
3959 return 0;
3960 }
3961
3962 int match_reloading(sd_bus_message *message, void *userdata, sd_bus_error *error) {
3963 Manager *m = userdata;
3964 Session *session;
3965 int b, r;
3966
3967 assert(message);
3968 assert(m);
3969
3970 r = sd_bus_message_read(message, "b", &b);
3971 if (r < 0) {
3972 bus_log_parse_error(r);
3973 return 0;
3974 }
3975
3976 if (b)
3977 return 0;
3978
3979 /* systemd finished reloading, let's recheck all our sessions */
3980 log_debug("System manager has been reloaded, rechecking sessions...");
3981
3982 HASHMAP_FOREACH(session, m->sessions)
3983 session_add_to_gc_queue(session);
3984
3985 return 0;
3986 }
3987
3988 int manager_send_changed(Manager *manager, const char *property, ...) {
3989 char **l;
3990
3991 assert(manager);
3992
3993 l = strv_from_stdarg_alloca(property);
3994
3995 return sd_bus_emit_properties_changed_strv(
3996 manager->bus,
3997 "/org/freedesktop/login1",
3998 "org.freedesktop.login1.Manager",
3999 l);
4000 }
4001
4002 static int strdup_job(sd_bus_message *reply, char **job) {
4003 const char *j;
4004 char *copy;
4005 int r;
4006
4007 r = sd_bus_message_read(reply, "o", &j);
4008 if (r < 0)
4009 return r;
4010
4011 copy = strdup(j);
4012 if (!copy)
4013 return -ENOMEM;
4014
4015 *job = copy;
4016 return 1;
4017 }
4018
4019 int manager_start_scope(
4020 Manager *manager,
4021 const char *scope,
4022 pid_t pid,
4023 const char *slice,
4024 const char *description,
4025 char **wants,
4026 char **after,
4027 const char *requires_mounts_for,
4028 sd_bus_message *more_properties,
4029 sd_bus_error *error,
4030 char **job) {
4031
4032 _cleanup_(sd_bus_message_unrefp) sd_bus_message *m = NULL, *reply = NULL;
4033 char **i;
4034 int r;
4035
4036 assert(manager);
4037 assert(scope);
4038 assert(pid > 1);
4039 assert(job);
4040
4041 r = bus_message_new_method_call(manager->bus, &m, bus_systemd_mgr, "StartTransientUnit");
4042 if (r < 0)
4043 return r;
4044
4045 r = sd_bus_message_append(m, "ss", strempty(scope), "fail");
4046 if (r < 0)
4047 return r;
4048
4049 r = sd_bus_message_open_container(m, 'a', "(sv)");
4050 if (r < 0)
4051 return r;
4052
4053 if (!isempty(slice)) {
4054 r = sd_bus_message_append(m, "(sv)", "Slice", "s", slice);
4055 if (r < 0)
4056 return r;
4057 }
4058
4059 if (!isempty(description)) {
4060 r = sd_bus_message_append(m, "(sv)", "Description", "s", description);
4061 if (r < 0)
4062 return r;
4063 }
4064
4065 STRV_FOREACH(i, wants) {
4066 r = sd_bus_message_append(m, "(sv)", "Wants", "as", 1, *i);
4067 if (r < 0)
4068 return r;
4069 }
4070
4071 STRV_FOREACH(i, after) {
4072 r = sd_bus_message_append(m, "(sv)", "After", "as", 1, *i);
4073 if (r < 0)
4074 return r;
4075 }
4076
4077 if (!empty_or_root(requires_mounts_for)) {
4078 r = sd_bus_message_append(m, "(sv)", "RequiresMountsFor", "as", 1, requires_mounts_for);
4079 if (r < 0)
4080 return r;
4081 }
4082
4083 /* Make sure that the session shells are terminated with SIGHUP since bash and friends tend to ignore
4084 * SIGTERM */
4085 r = sd_bus_message_append(m, "(sv)", "SendSIGHUP", "b", true);
4086 if (r < 0)
4087 return r;
4088
4089 r = sd_bus_message_append(m, "(sv)", "PIDs", "au", 1, pid);
4090 if (r < 0)
4091 return r;
4092
4093 /* disable TasksMax= for the session scope, rely on the slice setting for it */
4094 r = sd_bus_message_append(m, "(sv)", "TasksMax", "t", (uint64_t)-1);
4095 if (r < 0)
4096 return bus_log_create_error(r);
4097
4098 if (more_properties) {
4099 /* If TasksMax also appears here, it will overwrite the default value set above */
4100 r = sd_bus_message_copy(m, more_properties, true);
4101 if (r < 0)
4102 return r;
4103 }
4104
4105 r = sd_bus_message_close_container(m);
4106 if (r < 0)
4107 return r;
4108
4109 r = sd_bus_message_append(m, "a(sa(sv))", 0);
4110 if (r < 0)
4111 return r;
4112
4113 r = sd_bus_call(manager->bus, m, 0, error, &reply);
4114 if (r < 0)
4115 return r;
4116
4117 return strdup_job(reply, job);
4118 }
4119
4120 int manager_start_unit(Manager *manager, const char *unit, sd_bus_error *error, char **job) {
4121 _cleanup_(sd_bus_message_unrefp) sd_bus_message *reply = NULL;
4122 int r;
4123
4124 assert(manager);
4125 assert(unit);
4126 assert(job);
4127
4128 r = bus_call_method(
4129 manager->bus,
4130 bus_systemd_mgr,
4131 "StartUnit",
4132 error,
4133 &reply,
4134 "ss", unit, "replace");
4135 if (r < 0)
4136 return r;
4137
4138 return strdup_job(reply, job);
4139 }
4140
4141 int manager_stop_unit(Manager *manager, const char *unit, const char *job_mode, sd_bus_error *error, char **ret_job) {
4142 _cleanup_(sd_bus_message_unrefp) sd_bus_message *reply = NULL;
4143 int r;
4144
4145 assert(manager);
4146 assert(unit);
4147 assert(ret_job);
4148
4149 r = bus_call_method(
4150 manager->bus,
4151 bus_systemd_mgr,
4152 "StopUnit",
4153 error,
4154 &reply,
4155 "ss", unit, job_mode ?: "fail");
4156 if (r < 0) {
4157 if (sd_bus_error_has_names(error, BUS_ERROR_NO_SUCH_UNIT,
4158 BUS_ERROR_LOAD_FAILED)) {
4159
4160 *ret_job = NULL;
4161 sd_bus_error_free(error);
4162 return 0;
4163 }
4164
4165 return r;
4166 }
4167
4168 return strdup_job(reply, ret_job);
4169 }
4170
4171 int manager_abandon_scope(Manager *manager, const char *scope, sd_bus_error *ret_error) {
4172 _cleanup_(sd_bus_error_free) sd_bus_error error = SD_BUS_ERROR_NULL;
4173 _cleanup_free_ char *path = NULL;
4174 int r;
4175
4176 assert(manager);
4177 assert(scope);
4178
4179 path = unit_dbus_path_from_name(scope);
4180 if (!path)
4181 return -ENOMEM;
4182
4183 r = sd_bus_call_method(
4184 manager->bus,
4185 "org.freedesktop.systemd1",
4186 path,
4187 "org.freedesktop.systemd1.Scope",
4188 "Abandon",
4189 &error,
4190 NULL,
4191 NULL);
4192 if (r < 0) {
4193 if (sd_bus_error_has_names(&error, BUS_ERROR_NO_SUCH_UNIT,
4194 BUS_ERROR_LOAD_FAILED,
4195 BUS_ERROR_SCOPE_NOT_RUNNING))
4196 return 0;
4197
4198 sd_bus_error_move(ret_error, &error);
4199 return r;
4200 }
4201
4202 return 1;
4203 }
4204
4205 int manager_kill_unit(Manager *manager, const char *unit, KillWho who, int signo, sd_bus_error *error) {
4206 assert(manager);
4207 assert(unit);
4208
4209 return bus_call_method(
4210 manager->bus,
4211 bus_systemd_mgr,
4212 "KillUnit",
4213 error,
4214 NULL,
4215 "ssi", unit, who == KILL_LEADER ? "main" : "all", signo);
4216 }
4217
4218 int manager_unit_is_active(Manager *manager, const char *unit, sd_bus_error *ret_error) {
4219 _cleanup_(sd_bus_error_free) sd_bus_error error = SD_BUS_ERROR_NULL;
4220 _cleanup_(sd_bus_message_unrefp) sd_bus_message *reply = NULL;
4221 _cleanup_free_ char *path = NULL;
4222 const char *state;
4223 int r;
4224
4225 assert(manager);
4226 assert(unit);
4227
4228 path = unit_dbus_path_from_name(unit);
4229 if (!path)
4230 return -ENOMEM;
4231
4232 r = sd_bus_get_property(
4233 manager->bus,
4234 "org.freedesktop.systemd1",
4235 path,
4236 "org.freedesktop.systemd1.Unit",
4237 "ActiveState",
4238 &error,
4239 &reply,
4240 "s");
4241 if (r < 0) {
4242 /* systemd might have dropped off momentarily, let's
4243 * not make this an error */
4244 if (sd_bus_error_has_names(&error, SD_BUS_ERROR_NO_REPLY,
4245 SD_BUS_ERROR_DISCONNECTED))
4246 return true;
4247
4248 /* If the unit is already unloaded then it's not
4249 * active */
4250 if (sd_bus_error_has_names(&error, BUS_ERROR_NO_SUCH_UNIT,
4251 BUS_ERROR_LOAD_FAILED))
4252 return false;
4253
4254 sd_bus_error_move(ret_error, &error);
4255 return r;
4256 }
4257
4258 r = sd_bus_message_read(reply, "s", &state);
4259 if (r < 0)
4260 return r;
4261
4262 return !STR_IN_SET(state, "inactive", "failed");
4263 }
4264
4265 int manager_job_is_active(Manager *manager, const char *path, sd_bus_error *ret_error) {
4266 _cleanup_(sd_bus_error_free) sd_bus_error error = SD_BUS_ERROR_NULL;
4267 _cleanup_(sd_bus_message_unrefp) sd_bus_message *reply = NULL;
4268 int r;
4269
4270 assert(manager);
4271 assert(path);
4272
4273 r = sd_bus_get_property(
4274 manager->bus,
4275 "org.freedesktop.systemd1",
4276 path,
4277 "org.freedesktop.systemd1.Job",
4278 "State",
4279 &error,
4280 &reply,
4281 "s");
4282 if (r < 0) {
4283 if (sd_bus_error_has_names(&error, SD_BUS_ERROR_NO_REPLY,
4284 SD_BUS_ERROR_DISCONNECTED))
4285 return true;
4286
4287 if (sd_bus_error_has_name(&error, SD_BUS_ERROR_UNKNOWN_OBJECT))
4288 return false;
4289
4290 sd_bus_error_move(ret_error, &error);
4291 return r;
4292 }
4293
4294 /* We don't actually care about the state really. The fact
4295 * that we could read the job state is enough for us */
4296
4297 return true;
4298 }