src/login/logind-session-dbus.c

   1 /* SPDX-License-Identifier: LGPL-2.1+ */
   2 /***
   3   This file is part of systemd.
   4
   5   Copyright 2011 Lennart Poettering
   6 ***/
   7
   8 #include <errno.h>
   9 #include <string.h>
  10
  11 #include "alloc-util.h"
  12 #include "bus-common-errors.h"
  13 #include "bus-label.h"
  14 #include "bus-util.h"
  15 #include "fd-util.h"
  16 #include "logind-session-device.h"
  17 #include "logind-session.h"
  18 #include "logind.h"
  19 #include "signal-util.h"
  20 #include "strv.h"
  21 #include "util.h"
  22
  23 static int property_get_user(
  24                 sd_bus *bus,
  25                 const char *path,
  26                 const char *interface,
  27                 const char *property,
  28                 sd_bus_message *reply,
  29                 void *userdata,
  30                 sd_bus_error *error) {
  31
  32         _cleanup_free_ char *p = NULL;
  33         Session *s = userdata;
  34
  35         assert(bus);
  36         assert(reply);
  37         assert(s);
  38
  39         p = user_bus_path(s->user);
  40         if (!p)
  41                 return -ENOMEM;
  42
  43         return sd_bus_message_append(reply, "(uo)", (uint32_t) s->user->uid, p);
  44 }
  45
  46 static int property_get_name(
  47                 sd_bus *bus,
  48                 const char *path,
  49                 const char *interface,
  50                 const char *property,
  51                 sd_bus_message *reply,
  52                 void *userdata,
  53                 sd_bus_error *error) {
  54
  55         Session *s = userdata;
  56
  57         assert(bus);
  58         assert(reply);
  59         assert(s);
  60
  61         return sd_bus_message_append(reply, "s", s->user->name);
  62 }
  63
  64 static int property_get_seat(
  65                 sd_bus *bus,
  66                 const char *path,
  67                 const char *interface,
  68                 const char *property,
  69                 sd_bus_message *reply,
  70                 void *userdata,
  71                 sd_bus_error *error) {
  72
  73         _cleanup_free_ char *p = NULL;
  74         Session *s = userdata;
  75
  76         assert(bus);
  77         assert(reply);
  78         assert(s);
  79
  80         p = s->seat ? seat_bus_path(s->seat) : strdup("/");
  81         if (!p)
  82                 return -ENOMEM;
  83
  84         return sd_bus_message_append(reply, "(so)", s->seat ? s->seat->id : "", p);
  85 }
  86
  87 static BUS_DEFINE_PROPERTY_GET_ENUM(property_get_type, session_type, SessionType);
  88 static BUS_DEFINE_PROPERTY_GET_ENUM(property_get_class, session_class, SessionClass);
  89 static BUS_DEFINE_PROPERTY_GET(property_get_active, "b", Session, session_is_active);
  90 static BUS_DEFINE_PROPERTY_GET2(property_get_state, "s", Session, session_get_state, session_state_to_string);
  91
  92 static int property_get_idle_hint(
  93                 sd_bus *bus,
  94                 const char *path,
  95                 const char *interface,
  96                 const char *property,
  97                 sd_bus_message *reply,
  98                 void *userdata,
  99                 sd_bus_error *error) {
 100
 101         Session *s = userdata;
 102
 103         assert(bus);
 104         assert(reply);
 105         assert(s);
 106
 107         return sd_bus_message_append(reply, "b", session_get_idle_hint(s, NULL) > 0);
 108 }
 109
 110 static int property_get_idle_since_hint(
 111                 sd_bus *bus,
 112                 const char *path,
 113                 const char *interface,
 114                 const char *property,
 115                 sd_bus_message *reply,
 116                 void *userdata,
 117                 sd_bus_error *error) {
 118
 119         Session *s = userdata;
 120         dual_timestamp t = DUAL_TIMESTAMP_NULL;
 121         uint64_t u;
 122         int r;
 123
 124         assert(bus);
 125         assert(reply);
 126         assert(s);
 127
 128         r = session_get_idle_hint(s, &t);
 129         if (r < 0)
 130                 return r;
 131
 132         u = streq(property, "IdleSinceHint") ? t.realtime : t.monotonic;
 133
 134         return sd_bus_message_append(reply, "t", u);
 135 }
 136
 137 static int property_get_locked_hint(
 138                 sd_bus *bus,
 139                 const char *path,
 140                 const char *interface,
 141                 const char *property,
 142                 sd_bus_message *reply,
 143                 void *userdata,
 144                 sd_bus_error *error) {
 145
 146         Session *s = userdata;
 147
 148         assert(bus);
 149         assert(reply);
 150         assert(s);
 151
 152         return sd_bus_message_append(reply, "b", session_get_locked_hint(s) > 0);
 153 }
 154
 155 int bus_session_method_terminate(sd_bus_message *message, void *userdata, sd_bus_error *error) {
 156         Session *s = userdata;
 157         int r;
 158
 159         assert(message);
 160         assert(s);
 161
 162         r = bus_verify_polkit_async(
 163                         message,
 164                         CAP_KILL,
 165                         "org.freedesktop.login1.manage",
 166                         NULL,
 167                         false,
 168                         s->user->uid,
 169                         &s->manager->polkit_registry,
 170                         error);
 171         if (r < 0)
 172                 return r;
 173         if (r == 0)
 174                 return 1; /* Will call us back */
 175
 176         r = session_stop(s, true);
 177         if (r < 0)
 178                 return r;
 179
 180         return sd_bus_reply_method_return(message, NULL);
 181 }
 182
 183 int bus_session_method_activate(sd_bus_message *message, void *userdata, sd_bus_error *error) {
 184         Session *s = userdata;
 185         int r;
 186
 187         assert(message);
 188         assert(s);
 189
 190         r = session_activate(s);
 191         if (r < 0)
 192                 return r;
 193
 194         return sd_bus_reply_method_return(message, NULL);
 195 }
 196
 197 int bus_session_method_lock(sd_bus_message *message, void *userdata, sd_bus_error *error) {
 198         Session *s = userdata;
 199         int r;
 200
 201         assert(message);
 202         assert(s);
 203
 204         r = bus_verify_polkit_async(
 205                         message,
 206                         CAP_SYS_ADMIN,
 207                         "org.freedesktop.login1.lock-sessions",
 208                         NULL,
 209                         false,
 210                         s->user->uid,
 211                         &s->manager->polkit_registry,
 212                         error);
 213         if (r < 0)
 214                 return r;
 215         if (r == 0)
 216                 return 1; /* Will call us back */
 217
 218         r = session_send_lock(s, strstr(sd_bus_message_get_member(message), "Lock"));
 219         if (r < 0)
 220                 return r;
 221
 222         return sd_bus_reply_method_return(message, NULL);
 223 }
 224
 225 static int method_set_idle_hint(sd_bus_message *message, void *userdata, sd_bus_error *error) {
 226         _cleanup_(sd_bus_creds_unrefp) sd_bus_creds *creds = NULL;
 227         Session *s = userdata;
 228         uid_t uid;
 229         int r, b;
 230
 231         assert(message);
 232         assert(s);
 233
 234         r = sd_bus_message_read(message, "b", &b);
 235         if (r < 0)
 236                 return r;
 237
 238         r = sd_bus_query_sender_creds(message, SD_BUS_CREDS_EUID, &creds);
 239         if (r < 0)
 240                 return r;
 241
 242         r = sd_bus_creds_get_euid(creds, &uid);
 243         if (r < 0)
 244                 return r;
 245
 246         if (uid != 0 && uid != s->user->uid)
 247                 return sd_bus_error_setf(error, SD_BUS_ERROR_ACCESS_DENIED, "Only owner of session may set idle hint");
 248
 249         session_set_idle_hint(s, b);
 250
 251         return sd_bus_reply_method_return(message, NULL);
 252 }
 253
 254 static int method_set_locked_hint(sd_bus_message *message, void *userdata, sd_bus_error *error) {
 255         _cleanup_(sd_bus_creds_unrefp) sd_bus_creds *creds = NULL;
 256         Session *s = userdata;
 257         uid_t uid;
 258         int r, b;
 259
 260         assert(message);
 261         assert(s);
 262
 263         r = sd_bus_message_read(message, "b", &b);
 264         if (r < 0)
 265                 return r;
 266
 267         r = sd_bus_query_sender_creds(message, SD_BUS_CREDS_EUID, &creds);
 268         if (r < 0)
 269                 return r;
 270
 271         r = sd_bus_creds_get_euid(creds, &uid);
 272         if (r < 0)
 273                 return r;
 274
 275         if (uid != 0 && uid != s->user->uid)
 276                 return sd_bus_error_setf(error, SD_BUS_ERROR_ACCESS_DENIED, "Only owner of session may set locked hint");
 277
 278         session_set_locked_hint(s, b);
 279
 280         return sd_bus_reply_method_return(message, NULL);
 281 }
 282
 283 int bus_session_method_kill(sd_bus_message *message, void *userdata, sd_bus_error *error) {
 284         Session *s = userdata;
 285         const char *swho;
 286         int32_t signo;
 287         KillWho who;
 288         int r;
 289
 290         assert(message);
 291         assert(s);
 292
 293         r = sd_bus_message_read(message, "si", &swho, &signo);
 294         if (r < 0)
 295                 return r;
 296
 297         if (isempty(swho))
 298                 who = KILL_ALL;
 299         else {
 300                 who = kill_who_from_string(swho);
 301                 if (who < 0)
 302                         return sd_bus_error_setf(error, SD_BUS_ERROR_INVALID_ARGS, "Invalid kill parameter '%s'", swho);
 303         }
 304
 305         if (!SIGNAL_VALID(signo))
 306                 return sd_bus_error_setf(error, SD_BUS_ERROR_INVALID_ARGS, "Invalid signal %i", signo);
 307
 308         r = bus_verify_polkit_async(
 309                         message,
 310                         CAP_KILL,
 311                         "org.freedesktop.login1.manage",
 312                         NULL,
 313                         false,
 314                         s->user->uid,
 315                         &s->manager->polkit_registry,
 316                         error);
 317         if (r < 0)
 318                 return r;
 319         if (r == 0)
 320                 return 1; /* Will call us back */
 321
 322         r = session_kill(s, who, signo);
 323         if (r < 0)
 324                 return r;
 325
 326         return sd_bus_reply_method_return(message, NULL);
 327 }
 328
 329 static int method_take_control(sd_bus_message *message, void *userdata, sd_bus_error *error) {
 330         _cleanup_(sd_bus_creds_unrefp) sd_bus_creds *creds = NULL;
 331         Session *s = userdata;
 332         int r, force;
 333         uid_t uid;
 334
 335         assert(message);
 336         assert(s);
 337
 338         r = sd_bus_message_read(message, "b", &force);
 339         if (r < 0)
 340                 return r;
 341
 342         r = sd_bus_query_sender_creds(message, SD_BUS_CREDS_EUID, &creds);
 343         if (r < 0)
 344                 return r;
 345
 346         r = sd_bus_creds_get_euid(creds, &uid);
 347         if (r < 0)
 348                 return r;
 349
 350         if (uid != 0 && (force || uid != s->user->uid))
 351                 return sd_bus_error_setf(error, SD_BUS_ERROR_ACCESS_DENIED, "Only owner of session may take control");
 352
 353         r = session_set_controller(s, sd_bus_message_get_sender(message), force, true);
 354         if (r < 0)
 355                 return r;
 356
 357         return sd_bus_reply_method_return(message, NULL);
 358 }
 359
 360 static int method_release_control(sd_bus_message *message, void *userdata, sd_bus_error *error) {
 361         Session *s = userdata;
 362
 363         assert(message);
 364         assert(s);
 365
 366         if (!session_is_controller(s, sd_bus_message_get_sender(message)))
 367                 return sd_bus_error_setf(error, BUS_ERROR_NOT_IN_CONTROL, "You are not in control of this session");
 368
 369         session_drop_controller(s);
 370
 371         return sd_bus_reply_method_return(message, NULL);
 372 }
 373
 374 static int method_take_device(sd_bus_message *message, void *userdata, sd_bus_error *error) {
 375         Session *s = userdata;
 376         uint32_t major, minor;
 377         SessionDevice *sd;
 378         dev_t dev;
 379         int r;
 380
 381         assert(message);
 382         assert(s);
 383
 384         r = sd_bus_message_read(message, "uu", &major, &minor);
 385         if (r < 0)
 386                 return r;
 387
 388         if (!session_is_controller(s, sd_bus_message_get_sender(message)))
 389                 return sd_bus_error_setf(error, BUS_ERROR_NOT_IN_CONTROL, "You are not in control of this session");
 390
 391         dev = makedev(major, minor);
 392         sd = hashmap_get(s->devices, &dev);
 393         if (sd)
 394                 /* We don't allow retrieving a device multiple times.
 395                  * The related ReleaseDevice call is not ref-counted.
 396                  * The caller should use dup() if it requires more
 397                  * than one fd (it would be functionally
 398                  * equivalent). */
 399                 return sd_bus_error_setf(error, BUS_ERROR_DEVICE_IS_TAKEN, "Device already taken");
 400
 401         r = session_device_new(s, dev, true, &sd);
 402         if (r < 0)
 403                 return r;
 404
 405         r = session_device_save(sd);
 406         if (r < 0)
 407                 goto error;
 408
 409         r = sd_bus_reply_method_return(message, "hb", sd->fd, !sd->active);
 410         if (r < 0)
 411                 goto error;
 412
 413         session_save(s);
 414         return 1;
 415
 416 error:
 417         session_device_free(sd);
 418         return r;
 419 }
 420
 421 static int method_release_device(sd_bus_message *message, void *userdata, sd_bus_error *error) {
 422         Session *s = userdata;
 423         uint32_t major, minor;
 424         SessionDevice *sd;
 425         dev_t dev;
 426         int r;
 427
 428         assert(message);
 429         assert(s);
 430
 431         r = sd_bus_message_read(message, "uu", &major, &minor);
 432         if (r < 0)
 433                 return r;
 434
 435         if (!session_is_controller(s, sd_bus_message_get_sender(message)))
 436                 return sd_bus_error_setf(error, BUS_ERROR_NOT_IN_CONTROL, "You are not in control of this session");
 437
 438         dev = makedev(major, minor);
 439         sd = hashmap_get(s->devices, &dev);
 440         if (!sd)
 441                 return sd_bus_error_setf(error, BUS_ERROR_DEVICE_NOT_TAKEN, "Device not taken");
 442
 443         session_device_free(sd);
 444         session_save(s);
 445
 446         return sd_bus_reply_method_return(message, NULL);
 447 }
 448
 449 static int method_pause_device_complete(sd_bus_message *message, void *userdata, sd_bus_error *error) {
 450         Session *s = userdata;
 451         uint32_t major, minor;
 452         SessionDevice *sd;
 453         dev_t dev;
 454         int r;
 455
 456         assert(message);
 457         assert(s);
 458
 459         r = sd_bus_message_read(message, "uu", &major, &minor);
 460         if (r < 0)
 461                 return r;
 462
 463         if (!session_is_controller(s, sd_bus_message_get_sender(message)))
 464                 return sd_bus_error_setf(error, BUS_ERROR_NOT_IN_CONTROL, "You are not in control of this session");
 465
 466         dev = makedev(major, minor);
 467         sd = hashmap_get(s->devices, &dev);
 468         if (!sd)
 469                 return sd_bus_error_setf(error, BUS_ERROR_DEVICE_NOT_TAKEN, "Device not taken");
 470
 471         session_device_complete_pause(sd);
 472
 473         return sd_bus_reply_method_return(message, NULL);
 474 }
 475
 476 const sd_bus_vtable session_vtable[] = {
 477         SD_BUS_VTABLE_START(0),
 478
 479         SD_BUS_PROPERTY("Id", "s", NULL, offsetof(Session, id), SD_BUS_VTABLE_PROPERTY_CONST),
 480         SD_BUS_PROPERTY("User", "(uo)", property_get_user, 0, SD_BUS_VTABLE_PROPERTY_CONST),
 481         SD_BUS_PROPERTY("Name", "s", property_get_name, 0, SD_BUS_VTABLE_PROPERTY_CONST),
 482         BUS_PROPERTY_DUAL_TIMESTAMP("Timestamp", offsetof(Session, timestamp), SD_BUS_VTABLE_PROPERTY_CONST),
 483         SD_BUS_PROPERTY("VTNr", "u", NULL, offsetof(Session, vtnr), SD_BUS_VTABLE_PROPERTY_CONST),
 484         SD_BUS_PROPERTY("Seat", "(so)", property_get_seat, 0, SD_BUS_VTABLE_PROPERTY_CONST),
 485         SD_BUS_PROPERTY("TTY", "s", NULL, offsetof(Session, tty), SD_BUS_VTABLE_PROPERTY_CONST),
 486         SD_BUS_PROPERTY("Display", "s", NULL, offsetof(Session, display), SD_BUS_VTABLE_PROPERTY_CONST),
 487         SD_BUS_PROPERTY("Remote", "b", bus_property_get_bool, offsetof(Session, remote), SD_BUS_VTABLE_PROPERTY_CONST),
 488         SD_BUS_PROPERTY("RemoteHost", "s", NULL, offsetof(Session, remote_host), SD_BUS_VTABLE_PROPERTY_CONST),
 489         SD_BUS_PROPERTY("RemoteUser", "s", NULL, offsetof(Session, remote_user), SD_BUS_VTABLE_PROPERTY_CONST),
 490         SD_BUS_PROPERTY("Service", "s", NULL, offsetof(Session, service), SD_BUS_VTABLE_PROPERTY_CONST),
 491         SD_BUS_PROPERTY("Desktop", "s", NULL, offsetof(Session, desktop), SD_BUS_VTABLE_PROPERTY_CONST),
 492         SD_BUS_PROPERTY("Scope", "s", NULL, offsetof(Session, scope), SD_BUS_VTABLE_PROPERTY_CONST),
 493         SD_BUS_PROPERTY("Leader", "u", bus_property_get_pid, offsetof(Session, leader), SD_BUS_VTABLE_PROPERTY_CONST),
 494         SD_BUS_PROPERTY("Audit", "u", NULL, offsetof(Session, audit_id), SD_BUS_VTABLE_PROPERTY_CONST),
 495         SD_BUS_PROPERTY("Type", "s", property_get_type, offsetof(Session, type), SD_BUS_VTABLE_PROPERTY_CONST),
 496         SD_BUS_PROPERTY("Class", "s", property_get_class, offsetof(Session, class), SD_BUS_VTABLE_PROPERTY_CONST),
 497         SD_BUS_PROPERTY("Active", "b", property_get_active, 0, SD_BUS_VTABLE_PROPERTY_EMITS_CHANGE),
 498         SD_BUS_PROPERTY("State", "s", property_get_state, 0, 0),
 499         SD_BUS_PROPERTY("IdleHint", "b", property_get_idle_hint, 0, SD_BUS_VTABLE_PROPERTY_EMITS_CHANGE),
 500         SD_BUS_PROPERTY("IdleSinceHint", "t", property_get_idle_since_hint, 0, SD_BUS_VTABLE_PROPERTY_EMITS_CHANGE),
 501         SD_BUS_PROPERTY("IdleSinceHintMonotonic", "t", property_get_idle_since_hint, 0, SD_BUS_VTABLE_PROPERTY_EMITS_CHANGE),
 502         SD_BUS_PROPERTY("LockedHint", "b", property_get_locked_hint, 0, SD_BUS_VTABLE_PROPERTY_EMITS_CHANGE),
 503
 504         SD_BUS_METHOD("Terminate", NULL, NULL, bus_session_method_terminate, SD_BUS_VTABLE_UNPRIVILEGED),
 505         SD_BUS_METHOD("Activate", NULL, NULL, bus_session_method_activate, SD_BUS_VTABLE_UNPRIVILEGED),
 506         SD_BUS_METHOD("Lock", NULL, NULL, bus_session_method_lock, SD_BUS_VTABLE_UNPRIVILEGED),
 507         SD_BUS_METHOD("Unlock", NULL, NULL, bus_session_method_lock, SD_BUS_VTABLE_UNPRIVILEGED),
 508         SD_BUS_METHOD("SetIdleHint", "b", NULL, method_set_idle_hint, SD_BUS_VTABLE_UNPRIVILEGED),
 509         SD_BUS_METHOD("SetLockedHint", "b", NULL, method_set_locked_hint, SD_BUS_VTABLE_UNPRIVILEGED),
 510         SD_BUS_METHOD("Kill", "si", NULL, bus_session_method_kill, SD_BUS_VTABLE_UNPRIVILEGED),
 511         SD_BUS_METHOD("TakeControl", "b", NULL, method_take_control, SD_BUS_VTABLE_UNPRIVILEGED),
 512         SD_BUS_METHOD("ReleaseControl", NULL, NULL, method_release_control, SD_BUS_VTABLE_UNPRIVILEGED),
 513         SD_BUS_METHOD("TakeDevice", "uu", "hb", method_take_device, SD_BUS_VTABLE_UNPRIVILEGED),
 514         SD_BUS_METHOD("ReleaseDevice", "uu", NULL, method_release_device, SD_BUS_VTABLE_UNPRIVILEGED),
 515         SD_BUS_METHOD("PauseDeviceComplete", "uu", NULL, method_pause_device_complete, SD_BUS_VTABLE_UNPRIVILEGED),
 516
 517         SD_BUS_SIGNAL("PauseDevice", "uus", 0),
 518         SD_BUS_SIGNAL("ResumeDevice", "uuh", 0),
 519         SD_BUS_SIGNAL("Lock", NULL, 0),
 520         SD_BUS_SIGNAL("Unlock", NULL, 0),
 521
 522         SD_BUS_VTABLE_END
 523 };
 524
 525 int session_object_find(sd_bus *bus, const char *path, const char *interface, void *userdata, void **found, sd_bus_error *error) {
 526         Manager *m = userdata;
 527         Session *session;
 528         int r;
 529
 530         assert(bus);
 531         assert(path);
 532         assert(interface);
 533         assert(found);
 534         assert(m);
 535
 536         if (streq(path, "/org/freedesktop/login1/session/self")) {
 537                 sd_bus_message *message;
 538
 539                 message = sd_bus_get_current_message(bus);
 540                 if (!message)
 541                         return 0;
 542
 543                 r = manager_get_session_from_creds(m, message, NULL, error, &session);
 544                 if (r < 0)
 545                         return r;
 546         } else {
 547                 _cleanup_free_ char *e = NULL;
 548                 const char *p;
 549
 550                 p = startswith(path, "/org/freedesktop/login1/session/");
 551                 if (!p)
 552                         return 0;
 553
 554                 e = bus_label_unescape(p);
 555                 if (!e)
 556                         return -ENOMEM;
 557
 558                 session = hashmap_get(m->sessions, e);
 559                 if (!session)
 560                         return 0;
 561         }
 562
 563         *found = session;
 564         return 1;
 565 }
 566
 567 char *session_bus_path(Session *s) {
 568         _cleanup_free_ char *t = NULL;
 569
 570         assert(s);
 571
 572         t = bus_label_escape(s->id);
 573         if (!t)
 574                 return NULL;
 575
 576         return strappend("/org/freedesktop/login1/session/", t);
 577 }
 578
 579 int session_node_enumerator(sd_bus *bus, const char *path, void *userdata, char ***nodes, sd_bus_error *error) {
 580         _cleanup_strv_free_ char **l = NULL;
 581         sd_bus_message *message;
 582         Manager *m = userdata;
 583         Session *session;
 584         Iterator i;
 585         int r;
 586
 587         assert(bus);
 588         assert(path);
 589         assert(nodes);
 590
 591         HASHMAP_FOREACH(session, m->sessions, i) {
 592                 char *p;
 593
 594                 p = session_bus_path(session);
 595                 if (!p)
 596                         return -ENOMEM;
 597
 598                 r = strv_consume(&l, p);
 599                 if (r < 0)
 600                         return r;
 601         }
 602
 603         message = sd_bus_get_current_message(bus);
 604         if (message) {
 605                 _cleanup_(sd_bus_creds_unrefp) sd_bus_creds *creds = NULL;
 606                 const char *name;
 607
 608                 r = sd_bus_query_sender_creds(message, SD_BUS_CREDS_SESSION|SD_BUS_CREDS_AUGMENT, &creds);
 609                 if (r >= 0) {
 610                         r = sd_bus_creds_get_session(creds, &name);
 611                         if (r >= 0) {
 612                                 session = hashmap_get(m->sessions, name);
 613                                 if (session) {
 614                                         r = strv_extend(&l, "/org/freedesktop/login1/session/self");
 615                                         if (r < 0)
 616                                                 return r;
 617                                 }
 618                         }
 619                 }
 620         }
 621
 622         *nodes = TAKE_PTR(l);
 623
 624         return 1;
 625 }
 626
 627 int session_send_signal(Session *s, bool new_session) {
 628         _cleanup_free_ char *p = NULL;
 629
 630         assert(s);
 631
 632         p = session_bus_path(s);
 633         if (!p)
 634                 return -ENOMEM;
 635
 636         return sd_bus_emit_signal(
 637                         s->manager->bus,
 638                         "/org/freedesktop/login1",
 639                         "org.freedesktop.login1.Manager",
 640                         new_session ? "SessionNew" : "SessionRemoved",
 641                         "so", s->id, p);
 642 }
 643
 644 int session_send_changed(Session *s, const char *properties, ...) {
 645         _cleanup_free_ char *p = NULL;
 646         char **l;
 647
 648         assert(s);
 649
 650         if (!s->started)
 651                 return 0;
 652
 653         p = session_bus_path(s);
 654         if (!p)
 655                 return -ENOMEM;
 656
 657         l = strv_from_stdarg_alloca(properties);
 658
 659         return sd_bus_emit_properties_changed_strv(s->manager->bus, p, "org.freedesktop.login1.Session", l);
 660 }
 661
 662 int session_send_lock(Session *s, bool lock) {
 663         _cleanup_free_ char *p = NULL;
 664
 665         assert(s);
 666
 667         p = session_bus_path(s);
 668         if (!p)
 669                 return -ENOMEM;
 670
 671         return sd_bus_emit_signal(
 672                         s->manager->bus,
 673                         p,
 674                         "org.freedesktop.login1.Session",
 675                         lock ? "Lock" : "Unlock",
 676                         NULL);
 677 }
 678
 679 int session_send_lock_all(Manager *m, bool lock) {
 680         Session *session;
 681         Iterator i;
 682         int r = 0;
 683
 684         assert(m);
 685
 686         HASHMAP_FOREACH(session, m->sessions, i) {
 687                 int k;
 688
 689                 k = session_send_lock(session, lock);
 690                 if (k < 0)
 691                         r = k;
 692         }
 693
 694         return r;
 695 }
 696
 697 int session_send_create_reply(Session *s, sd_bus_error *error) {
 698         _cleanup_(sd_bus_message_unrefp) sd_bus_message *c = NULL;
 699         _cleanup_close_ int fifo_fd = -1;
 700         _cleanup_free_ char *p = NULL;
 701
 702         assert(s);
 703
 704         /* This is called after the session scope and the user service
 705          * were successfully created, and finishes where
 706          * bus_manager_create_session() left off. */
 707
 708         if (!s->create_message)
 709                 return 0;
 710
 711         if (!sd_bus_error_is_set(error) && (s->scope_job || s->user->service_job))
 712                 return 0;
 713
 714         c = s->create_message;
 715         s->create_message = NULL;
 716
 717         if (error)
 718                 return sd_bus_reply_method_error(c, error);
 719
 720         fifo_fd = session_create_fifo(s);
 721         if (fifo_fd < 0)
 722                 return fifo_fd;
 723
 724         /* Update the session state file before we notify the client
 725          * about the result. */
 726         session_save(s);
 727
 728         p = session_bus_path(s);
 729         if (!p)
 730                 return -ENOMEM;
 731
 732         log_debug("Sending reply about created session: "
 733                   "id=%s object_path=%s uid=%u runtime_path=%s "
 734                   "session_fd=%d seat=%s vtnr=%u",
 735                   s->id,
 736                   p,
 737                   (uint32_t) s->user->uid,
 738                   s->user->runtime_path,
 739                   fifo_fd,
 740                   s->seat ? s->seat->id : "",
 741                   (uint32_t) s->vtnr);
 742
 743         return sd_bus_reply_method_return(
 744                         c, "soshusub",
 745                         s->id,
 746                         p,
 747                         s->user->runtime_path,
 748                         fifo_fd,
 749                         (uint32_t) s->user->uid,
 750                         s->seat ? s->seat->id : "",
 751                         (uint32_t) s->vtnr,
 752                         false);
 753 }