logind-dbus.c revision 486cd82c8f7642016895b72bcc09a1bfe885a783
1a14a53cfded6e78c6e8dfb73fdff0039971d642Lennart Poettering/*-*- Mode: C; c-basic-offset: 8; indent-tabs-mode: nil -*-*/
1a14a53cfded6e78c6e8dfb73fdff0039971d642Lennart Poettering
1a14a53cfded6e78c6e8dfb73fdff0039971d642Lennart Poettering/***
1a14a53cfded6e78c6e8dfb73fdff0039971d642Lennart Poettering This file is part of systemd.
1a14a53cfded6e78c6e8dfb73fdff0039971d642Lennart Poettering
1a14a53cfded6e78c6e8dfb73fdff0039971d642Lennart Poettering Copyright 2011 Lennart Poettering
1a14a53cfded6e78c6e8dfb73fdff0039971d642Lennart Poettering
1a14a53cfded6e78c6e8dfb73fdff0039971d642Lennart Poettering systemd is free software; you can redistribute it and/or modify it
1a14a53cfded6e78c6e8dfb73fdff0039971d642Lennart Poettering under the terms of the GNU Lesser General Public License as published by
1a14a53cfded6e78c6e8dfb73fdff0039971d642Lennart Poettering the Free Software Foundation; either version 2.1 of the License, or
1a14a53cfded6e78c6e8dfb73fdff0039971d642Lennart Poettering (at your option) any later version.
1a14a53cfded6e78c6e8dfb73fdff0039971d642Lennart Poettering
1a14a53cfded6e78c6e8dfb73fdff0039971d642Lennart Poettering systemd is distributed in the hope that it will be useful, but
1a14a53cfded6e78c6e8dfb73fdff0039971d642Lennart Poettering WITHOUT ANY WARRANTY; without even the implied warranty of
1a14a53cfded6e78c6e8dfb73fdff0039971d642Lennart Poettering MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
1a14a53cfded6e78c6e8dfb73fdff0039971d642Lennart Poettering Lesser General Public License for more details.
1a14a53cfded6e78c6e8dfb73fdff0039971d642Lennart Poettering
1a14a53cfded6e78c6e8dfb73fdff0039971d642Lennart Poettering You should have received a copy of the GNU Lesser General Public License
1a14a53cfded6e78c6e8dfb73fdff0039971d642Lennart Poettering along with systemd; If not, see <http://www.gnu.org/licenses/>.
1a14a53cfded6e78c6e8dfb73fdff0039971d642Lennart Poettering***/
1a14a53cfded6e78c6e8dfb73fdff0039971d642Lennart Poettering
1a14a53cfded6e78c6e8dfb73fdff0039971d642Lennart Poettering#include <errno.h>
1a14a53cfded6e78c6e8dfb73fdff0039971d642Lennart Poettering#include <string.h>
1a14a53cfded6e78c6e8dfb73fdff0039971d642Lennart Poettering#include <unistd.h>
96115cdfe0241ae9b4e7177cd3874c0a93d00b39Thomas Hindoe Paaboel Andersen#include <pwd.h>
1a14a53cfded6e78c6e8dfb73fdff0039971d642Lennart Poettering
1af7211984a8dba3c5ba40fae794c4c55f5e6bd3Lennart Poettering#include "sd-id128.h"
1af7211984a8dba3c5ba40fae794c4c55f5e6bd3Lennart Poettering#include "sd-messages.h"
1a14a53cfded6e78c6e8dfb73fdff0039971d642Lennart Poettering#include "strv.h"
1a14a53cfded6e78c6e8dfb73fdff0039971d642Lennart Poettering#include "mkdir.h"
1a14a53cfded6e78c6e8dfb73fdff0039971d642Lennart Poettering#include "path-util.h"
1a14a53cfded6e78c6e8dfb73fdff0039971d642Lennart Poettering#include "special.h"
1ca208fb4f93e5869704af1812cbff7130a2fc03Zbigniew Jędrzejewski-Szmek#include "sleep-config.h"
1a14a53cfded6e78c6e8dfb73fdff0039971d642Lennart Poettering#include "fileio-label.h"
1a14a53cfded6e78c6e8dfb73fdff0039971d642Lennart Poettering#include "label.h"
9a5cb1371b6d8b0a04bd08665bcf9b06cb40c64cZbigniew Jędrzejewski-Szmek#include "utf8.h"
e48fdd84432bbf9c2ecc339183258c7c33116032Lennart Poettering#include "unit-name.h"
e48fdd84432bbf9c2ecc339183258c7c33116032Lennart Poettering#include "virt.h"
1af7211984a8dba3c5ba40fae794c4c55f5e6bd3Lennart Poettering#include "audit.h"
73b80ec2d999c45ce13f3e034704249d80829f7eLennart Poettering#include "bus-util.h"
1b9e5b126359a2a2ec37de1f94f046093abc74b8Lennart Poettering#include "bus-error.h"
f9ac15442e4132f00eca5495d53c17062aae13e0Lennart Poettering#include "logind.h"
1a14a53cfded6e78c6e8dfb73fdff0039971d642Lennart Poettering#include "bus-errors.h"
1a14a53cfded6e78c6e8dfb73fdff0039971d642Lennart Poettering
73b80ec2d999c45ce13f3e034704249d80829f7eLennart Poetteringstatic int property_get_idle_hint(
73b80ec2d999c45ce13f3e034704249d80829f7eLennart Poettering sd_bus *bus,
73b80ec2d999c45ce13f3e034704249d80829f7eLennart Poettering const char *path,
1a14a53cfded6e78c6e8dfb73fdff0039971d642Lennart Poettering const char *interface,
cca1dfddd4ce4357113663532696488427cc54e4Lennart Poettering const char *property,
1af7211984a8dba3c5ba40fae794c4c55f5e6bd3Lennart Poettering sd_bus_message *reply,
1af7211984a8dba3c5ba40fae794c4c55f5e6bd3Lennart Poettering void *userdata,
1af7211984a8dba3c5ba40fae794c4c55f5e6bd3Lennart Poettering sd_bus_error *error) {
1af7211984a8dba3c5ba40fae794c4c55f5e6bd3Lennart Poettering
1af7211984a8dba3c5ba40fae794c4c55f5e6bd3Lennart Poettering Manager *m = userdata;
1af7211984a8dba3c5ba40fae794c4c55f5e6bd3Lennart Poettering
1af7211984a8dba3c5ba40fae794c4c55f5e6bd3Lennart Poettering assert(bus);
1af7211984a8dba3c5ba40fae794c4c55f5e6bd3Lennart Poettering assert(reply);
1af7211984a8dba3c5ba40fae794c4c55f5e6bd3Lennart Poettering assert(m);
7410616cd9dbbec97cf98d75324da5cda2b2f7a2Lennart Poettering
7410616cd9dbbec97cf98d75324da5cda2b2f7a2Lennart Poettering return sd_bus_message_append(reply, "b", manager_get_idle_hint(m, NULL) > 0);
7410616cd9dbbec97cf98d75324da5cda2b2f7a2Lennart Poettering}
1af7211984a8dba3c5ba40fae794c4c55f5e6bd3Lennart Poettering
1af7211984a8dba3c5ba40fae794c4c55f5e6bd3Lennart Poetteringstatic int property_get_idle_since_hint(
1af7211984a8dba3c5ba40fae794c4c55f5e6bd3Lennart Poettering sd_bus *bus,
1af7211984a8dba3c5ba40fae794c4c55f5e6bd3Lennart Poettering const char *path,
1af7211984a8dba3c5ba40fae794c4c55f5e6bd3Lennart Poettering const char *interface,
7410616cd9dbbec97cf98d75324da5cda2b2f7a2Lennart Poettering const char *property,
7410616cd9dbbec97cf98d75324da5cda2b2f7a2Lennart Poettering sd_bus_message *reply,
7410616cd9dbbec97cf98d75324da5cda2b2f7a2Lennart Poettering void *userdata,
1af7211984a8dba3c5ba40fae794c4c55f5e6bd3Lennart Poettering sd_bus_error *error) {
1af7211984a8dba3c5ba40fae794c4c55f5e6bd3Lennart Poettering
821b2e792159e237a1e5a1ea4bb6ae2e55d64be5Lukas Nykryn Manager *m = userdata;
1af7211984a8dba3c5ba40fae794c4c55f5e6bd3Lennart Poettering dual_timestamp t;
1af7211984a8dba3c5ba40fae794c4c55f5e6bd3Lennart Poettering
1af7211984a8dba3c5ba40fae794c4c55f5e6bd3Lennart Poettering assert(bus);
4a62c710b62a5a3c7a8a278b810b9d5b5a0c8f4fMichal Schmidt assert(reply);
4a62c710b62a5a3c7a8a278b810b9d5b5a0c8f4fMichal Schmidt assert(m);
1af7211984a8dba3c5ba40fae794c4c55f5e6bd3Lennart Poettering
1af7211984a8dba3c5ba40fae794c4c55f5e6bd3Lennart Poettering manager_get_idle_hint(m, &t);
1af7211984a8dba3c5ba40fae794c4c55f5e6bd3Lennart Poettering
1af7211984a8dba3c5ba40fae794c4c55f5e6bd3Lennart Poettering return sd_bus_message_append(reply, "t", streq(property, "IdleSinceHint") ? t.realtime : t.monotonic);
1af7211984a8dba3c5ba40fae794c4c55f5e6bd3Lennart Poettering}
c3834f9b881f2b1a68dc7d797c134f0b66b47b57Lennart Poettering
1af7211984a8dba3c5ba40fae794c4c55f5e6bd3Lennart Poetteringstatic int property_get_inhibited(
1af7211984a8dba3c5ba40fae794c4c55f5e6bd3Lennart Poettering sd_bus *bus,
1af7211984a8dba3c5ba40fae794c4c55f5e6bd3Lennart Poettering const char *path,
1af7211984a8dba3c5ba40fae794c4c55f5e6bd3Lennart Poettering const char *interface,
1af7211984a8dba3c5ba40fae794c4c55f5e6bd3Lennart Poettering const char *property,
1af7211984a8dba3c5ba40fae794c4c55f5e6bd3Lennart Poettering sd_bus_message *reply,
1af7211984a8dba3c5ba40fae794c4c55f5e6bd3Lennart Poettering void *userdata,
1af7211984a8dba3c5ba40fae794c4c55f5e6bd3Lennart Poettering sd_bus_error *error) {
1af7211984a8dba3c5ba40fae794c4c55f5e6bd3Lennart Poettering
1af7211984a8dba3c5ba40fae794c4c55f5e6bd3Lennart Poettering Manager *m = userdata;
cca1dfddd4ce4357113663532696488427cc54e4Lennart Poettering InhibitWhat w;
1af7211984a8dba3c5ba40fae794c4c55f5e6bd3Lennart Poettering
1af7211984a8dba3c5ba40fae794c4c55f5e6bd3Lennart Poettering assert(bus);
cca1dfddd4ce4357113663532696488427cc54e4Lennart Poettering assert(reply);
1af7211984a8dba3c5ba40fae794c4c55f5e6bd3Lennart Poettering assert(m);
1af7211984a8dba3c5ba40fae794c4c55f5e6bd3Lennart Poettering
dacd6cee76a08331b8c8616c5f30f70ee49aa2f9Lennart Poettering w = manager_inhibit_what(m, streq(property, "BlockInhibited") ? INHIBIT_BLOCK : INHIBIT_DELAY);
dacd6cee76a08331b8c8616c5f30f70ee49aa2f9Lennart Poettering
dacd6cee76a08331b8c8616c5f30f70ee49aa2f9Lennart Poettering return sd_bus_message_append(reply, "s", inhibit_what_to_string(w));
1af7211984a8dba3c5ba40fae794c4c55f5e6bd3Lennart Poettering}
63c372cb9df3bee01e3bf8cd7f96f336bddda846Lennart Poettering
1af7211984a8dba3c5ba40fae794c4c55f5e6bd3Lennart Poetteringstatic int property_get_preparing(
1af7211984a8dba3c5ba40fae794c4c55f5e6bd3Lennart Poettering sd_bus *bus,
1af7211984a8dba3c5ba40fae794c4c55f5e6bd3Lennart Poettering const char *path,
1af7211984a8dba3c5ba40fae794c4c55f5e6bd3Lennart Poettering const char *interface,
1af7211984a8dba3c5ba40fae794c4c55f5e6bd3Lennart Poettering const char *property,
1af7211984a8dba3c5ba40fae794c4c55f5e6bd3Lennart Poettering sd_bus_message *reply,
4a62c710b62a5a3c7a8a278b810b9d5b5a0c8f4fMichal Schmidt void *userdata,
4a62c710b62a5a3c7a8a278b810b9d5b5a0c8f4fMichal Schmidt sd_bus_error *error) {
1af7211984a8dba3c5ba40fae794c4c55f5e6bd3Lennart Poettering
1af7211984a8dba3c5ba40fae794c4c55f5e6bd3Lennart Poettering Manager *m = userdata;
1af7211984a8dba3c5ba40fae794c4c55f5e6bd3Lennart Poettering bool b;
1af7211984a8dba3c5ba40fae794c4c55f5e6bd3Lennart Poettering
1af7211984a8dba3c5ba40fae794c4c55f5e6bd3Lennart Poettering assert(bus);
1af7211984a8dba3c5ba40fae794c4c55f5e6bd3Lennart Poettering assert(reply);
1af7211984a8dba3c5ba40fae794c4c55f5e6bd3Lennart Poettering assert(m);
4a62c710b62a5a3c7a8a278b810b9d5b5a0c8f4fMichal Schmidt
4a62c710b62a5a3c7a8a278b810b9d5b5a0c8f4fMichal Schmidt if (streq(property, "PreparingForShutdown"))
1af7211984a8dba3c5ba40fae794c4c55f5e6bd3Lennart Poettering b = !!(m->action_what & INHIBIT_SHUTDOWN);
1af7211984a8dba3c5ba40fae794c4c55f5e6bd3Lennart Poettering else
1af7211984a8dba3c5ba40fae794c4c55f5e6bd3Lennart Poettering b = !!(m->action_what & INHIBIT_SLEEP);
1af7211984a8dba3c5ba40fae794c4c55f5e6bd3Lennart Poettering
1af7211984a8dba3c5ba40fae794c4c55f5e6bd3Lennart Poettering return sd_bus_message_append(reply, "b", b);
1af7211984a8dba3c5ba40fae794c4c55f5e6bd3Lennart Poettering}
1af7211984a8dba3c5ba40fae794c4c55f5e6bd3Lennart Poettering
4a62c710b62a5a3c7a8a278b810b9d5b5a0c8f4fMichal Schmidtstatic BUS_DEFINE_PROPERTY_GET_ENUM(property_get_handle_action, handle_action, HandleAction);
4a62c710b62a5a3c7a8a278b810b9d5b5a0c8f4fMichal Schmidt
1af7211984a8dba3c5ba40fae794c4c55f5e6bd3Lennart Poetteringstatic int method_get_session(sd_bus *bus, sd_bus_message *message, void *userdata, sd_bus_error *error) {
1af7211984a8dba3c5ba40fae794c4c55f5e6bd3Lennart Poettering _cleanup_free_ char *p = NULL;
1af7211984a8dba3c5ba40fae794c4c55f5e6bd3Lennart Poettering Manager *m = userdata;
1af7211984a8dba3c5ba40fae794c4c55f5e6bd3Lennart Poettering const char *name;
1af7211984a8dba3c5ba40fae794c4c55f5e6bd3Lennart Poettering Session *session;
1af7211984a8dba3c5ba40fae794c4c55f5e6bd3Lennart Poettering int r;
1af7211984a8dba3c5ba40fae794c4c55f5e6bd3Lennart Poettering
1af7211984a8dba3c5ba40fae794c4c55f5e6bd3Lennart Poettering assert(bus);
1af7211984a8dba3c5ba40fae794c4c55f5e6bd3Lennart Poettering assert(message);
1af7211984a8dba3c5ba40fae794c4c55f5e6bd3Lennart Poettering assert(m);
4c1fc3e404d648c70bd2f50ac50aeac6ece8872eDaniel Mack
4c1fc3e404d648c70bd2f50ac50aeac6ece8872eDaniel Mack r = sd_bus_message_read(message, "s", &name);
23bbb0de4e3f85d9704a5c12a5afa2dfa0159e41Michal Schmidt if (r < 0)
23bbb0de4e3f85d9704a5c12a5afa2dfa0159e41Michal Schmidt return r;
1af7211984a8dba3c5ba40fae794c4c55f5e6bd3Lennart Poettering
1af7211984a8dba3c5ba40fae794c4c55f5e6bd3Lennart Poettering session = hashmap_get(m->sessions, name);
1af7211984a8dba3c5ba40fae794c4c55f5e6bd3Lennart Poettering if (!session)
1af7211984a8dba3c5ba40fae794c4c55f5e6bd3Lennart Poettering return sd_bus_error_setf(error, BUS_ERROR_NO_SUCH_SESSION, "No session '%s' known", name);
1af7211984a8dba3c5ba40fae794c4c55f5e6bd3Lennart Poettering
1af7211984a8dba3c5ba40fae794c4c55f5e6bd3Lennart Poettering p = session_bus_path(session);
1af7211984a8dba3c5ba40fae794c4c55f5e6bd3Lennart Poettering if (!p)
1af7211984a8dba3c5ba40fae794c4c55f5e6bd3Lennart Poettering return -ENOMEM;
1af7211984a8dba3c5ba40fae794c4c55f5e6bd3Lennart Poettering
73b80ec2d999c45ce13f3e034704249d80829f7eLennart Poettering return sd_bus_reply_method_return(message, "o", p);
73b80ec2d999c45ce13f3e034704249d80829f7eLennart Poettering}
73b80ec2d999c45ce13f3e034704249d80829f7eLennart Poettering
73b80ec2d999c45ce13f3e034704249d80829f7eLennart Poetteringstatic int method_get_session_by_pid(sd_bus *bus, sd_bus_message *message, void *userdata, sd_bus_error *error) {
73b80ec2d999c45ce13f3e034704249d80829f7eLennart Poettering _cleanup_free_ char *p = NULL;
cca1dfddd4ce4357113663532696488427cc54e4Lennart Poettering Session *session = NULL;
59512f21d77d984cf1363fb0d1770218c5e17020Kay Sievers Manager *m = userdata;
73b80ec2d999c45ce13f3e034704249d80829f7eLennart Poettering pid_t pid;
73b80ec2d999c45ce13f3e034704249d80829f7eLennart Poettering int r;
73b80ec2d999c45ce13f3e034704249d80829f7eLennart Poettering
1af7211984a8dba3c5ba40fae794c4c55f5e6bd3Lennart Poettering assert(bus);
1a14a53cfded6e78c6e8dfb73fdff0039971d642Lennart Poettering assert(message);
e48fdd84432bbf9c2ecc339183258c7c33116032Lennart Poettering assert(m);
1a14a53cfded6e78c6e8dfb73fdff0039971d642Lennart Poettering
1af7211984a8dba3c5ba40fae794c4c55f5e6bd3Lennart Poettering assert_cc(sizeof(pid_t) == sizeof(uint32_t));
1af7211984a8dba3c5ba40fae794c4c55f5e6bd3Lennart Poettering
1af7211984a8dba3c5ba40fae794c4c55f5e6bd3Lennart Poettering r = sd_bus_message_read(message, "u", &pid);
1af7211984a8dba3c5ba40fae794c4c55f5e6bd3Lennart Poettering if (r < 0)
1af7211984a8dba3c5ba40fae794c4c55f5e6bd3Lennart Poettering return r;
73b80ec2d999c45ce13f3e034704249d80829f7eLennart Poettering
1a14a53cfded6e78c6e8dfb73fdff0039971d642Lennart Poettering if (pid == 0) {
73b80ec2d999c45ce13f3e034704249d80829f7eLennart Poettering r = sd_bus_get_owner_pid(bus, sd_bus_message_get_sender(message), &pid);
1af7211984a8dba3c5ba40fae794c4c55f5e6bd3Lennart Poettering if (r < 0)
cca1dfddd4ce4357113663532696488427cc54e4Lennart Poettering return r;
1af7211984a8dba3c5ba40fae794c4c55f5e6bd3Lennart Poettering }
1af7211984a8dba3c5ba40fae794c4c55f5e6bd3Lennart Poettering
1af7211984a8dba3c5ba40fae794c4c55f5e6bd3Lennart Poettering r = manager_get_session_by_pid(m, pid, &session);
1af7211984a8dba3c5ba40fae794c4c55f5e6bd3Lennart Poettering if (r < 0)
1af7211984a8dba3c5ba40fae794c4c55f5e6bd3Lennart Poettering return r;
1af7211984a8dba3c5ba40fae794c4c55f5e6bd3Lennart Poettering if (!session)
1af7211984a8dba3c5ba40fae794c4c55f5e6bd3Lennart Poettering return sd_bus_error_setf(error, BUS_ERROR_NO_SESSION_FOR_PID, "PID %lu does not belong to any known session", (unsigned long) pid);
7410616cd9dbbec97cf98d75324da5cda2b2f7a2Lennart Poettering
7410616cd9dbbec97cf98d75324da5cda2b2f7a2Lennart Poettering p = session_bus_path(session);
7410616cd9dbbec97cf98d75324da5cda2b2f7a2Lennart Poettering if (!p)
1a14a53cfded6e78c6e8dfb73fdff0039971d642Lennart Poettering return -ENOMEM;
e48fdd84432bbf9c2ecc339183258c7c33116032Lennart Poettering
e48fdd84432bbf9c2ecc339183258c7c33116032Lennart Poettering return sd_bus_reply_method_return(message, "o", p);
e48fdd84432bbf9c2ecc339183258c7c33116032Lennart Poettering}
e48fdd84432bbf9c2ecc339183258c7c33116032Lennart Poettering
e48fdd84432bbf9c2ecc339183258c7c33116032Lennart Poetteringstatic int method_get_user(sd_bus *bus, sd_bus_message *message, void *userdata, sd_bus_error *error) {
4a62c710b62a5a3c7a8a278b810b9d5b5a0c8f4fMichal Schmidt _cleanup_free_ char *p = NULL;
4a62c710b62a5a3c7a8a278b810b9d5b5a0c8f4fMichal Schmidt Manager *m = userdata;
1a14a53cfded6e78c6e8dfb73fdff0039971d642Lennart Poettering uint32_t uid;
1a14a53cfded6e78c6e8dfb73fdff0039971d642Lennart Poettering User *user;
1a14a53cfded6e78c6e8dfb73fdff0039971d642Lennart Poettering int r;
1a14a53cfded6e78c6e8dfb73fdff0039971d642Lennart Poettering
c3834f9b881f2b1a68dc7d797c134f0b66b47b57Lennart Poettering assert(bus);
c3834f9b881f2b1a68dc7d797c134f0b66b47b57Lennart Poettering assert(message);
e48fdd84432bbf9c2ecc339183258c7c33116032Lennart Poettering assert(m);
e48fdd84432bbf9c2ecc339183258c7c33116032Lennart Poettering
73b80ec2d999c45ce13f3e034704249d80829f7eLennart Poettering r = sd_bus_message_read(message, "u", &uid);
73b80ec2d999c45ce13f3e034704249d80829f7eLennart Poettering if (r < 0)
73b80ec2d999c45ce13f3e034704249d80829f7eLennart Poettering return r;
e48fdd84432bbf9c2ecc339183258c7c33116032Lennart Poettering
e48fdd84432bbf9c2ecc339183258c7c33116032Lennart Poettering user = hashmap_get(m->users, ULONG_TO_PTR((unsigned long) uid));
e48fdd84432bbf9c2ecc339183258c7c33116032Lennart Poettering if (!user)
e48fdd84432bbf9c2ecc339183258c7c33116032Lennart Poettering return sd_bus_error_setf(error, BUS_ERROR_NO_SUCH_USER, "No user '%lu' known or logged in", (unsigned long) uid);
e48fdd84432bbf9c2ecc339183258c7c33116032Lennart Poettering
e48fdd84432bbf9c2ecc339183258c7c33116032Lennart Poettering p = user_bus_path(user);
1a14a53cfded6e78c6e8dfb73fdff0039971d642Lennart Poettering if (!p)
1a14a53cfded6e78c6e8dfb73fdff0039971d642Lennart Poettering return -ENOMEM;
1af7211984a8dba3c5ba40fae794c4c55f5e6bd3Lennart Poettering
1af7211984a8dba3c5ba40fae794c4c55f5e6bd3Lennart Poettering return sd_bus_reply_method_return(message, "o", p);
1af7211984a8dba3c5ba40fae794c4c55f5e6bd3Lennart Poettering}
73b80ec2d999c45ce13f3e034704249d80829f7eLennart Poettering
73b80ec2d999c45ce13f3e034704249d80829f7eLennart Poetteringstatic int method_get_user_by_pid(sd_bus *bus, sd_bus_message *message, void *userdata, sd_bus_error *error) {
73b80ec2d999c45ce13f3e034704249d80829f7eLennart Poettering _cleanup_free_ char *p = NULL;
59512f21d77d984cf1363fb0d1770218c5e17020Kay Sievers Manager *m = userdata;
59512f21d77d984cf1363fb0d1770218c5e17020Kay Sievers User *user = NULL;
59512f21d77d984cf1363fb0d1770218c5e17020Kay Sievers pid_t pid;
59512f21d77d984cf1363fb0d1770218c5e17020Kay Sievers int r;
1a14a53cfded6e78c6e8dfb73fdff0039971d642Lennart Poettering
dacd6cee76a08331b8c8616c5f30f70ee49aa2f9Lennart Poettering assert(bus);
dacd6cee76a08331b8c8616c5f30f70ee49aa2f9Lennart Poettering assert(message);
dacd6cee76a08331b8c8616c5f30f70ee49aa2f9Lennart Poettering assert(m);
1a14a53cfded6e78c6e8dfb73fdff0039971d642Lennart Poettering
73b80ec2d999c45ce13f3e034704249d80829f7eLennart Poettering assert_cc(sizeof(pid_t) == sizeof(uint32_t));
73b80ec2d999c45ce13f3e034704249d80829f7eLennart Poettering
73b80ec2d999c45ce13f3e034704249d80829f7eLennart Poettering r = sd_bus_message_read(message, "u", &pid);
73b80ec2d999c45ce13f3e034704249d80829f7eLennart Poettering if (r < 0)
1a14a53cfded6e78c6e8dfb73fdff0039971d642Lennart Poettering return r;
73b80ec2d999c45ce13f3e034704249d80829f7eLennart Poettering
4a62c710b62a5a3c7a8a278b810b9d5b5a0c8f4fMichal Schmidt if (pid == 0) {
4a62c710b62a5a3c7a8a278b810b9d5b5a0c8f4fMichal Schmidt r = sd_bus_get_owner_pid(bus, sd_bus_message_get_sender(message), &pid);
1a14a53cfded6e78c6e8dfb73fdff0039971d642Lennart Poettering if (r < 0)
1a14a53cfded6e78c6e8dfb73fdff0039971d642Lennart Poettering return r;
1a14a53cfded6e78c6e8dfb73fdff0039971d642Lennart Poettering }
1a14a53cfded6e78c6e8dfb73fdff0039971d642Lennart Poettering
1a14a53cfded6e78c6e8dfb73fdff0039971d642Lennart Poettering r = manager_get_user_by_pid(m, pid, &user);
59512f21d77d984cf1363fb0d1770218c5e17020Kay Sievers if (r < 0)
59512f21d77d984cf1363fb0d1770218c5e17020Kay Sievers return r;
59512f21d77d984cf1363fb0d1770218c5e17020Kay Sievers if (!user)
59512f21d77d984cf1363fb0d1770218c5e17020Kay Sievers return sd_bus_error_setf(error, BUS_ERROR_NO_USER_FOR_PID, "PID %lu does not belong to any known or logged in user", (unsigned long) pid);
59512f21d77d984cf1363fb0d1770218c5e17020Kay Sievers
59512f21d77d984cf1363fb0d1770218c5e17020Kay Sievers p = user_bus_path(user);
59512f21d77d984cf1363fb0d1770218c5e17020Kay Sievers if (!p)
59512f21d77d984cf1363fb0d1770218c5e17020Kay Sievers return -ENOMEM;
59512f21d77d984cf1363fb0d1770218c5e17020Kay Sievers
59512f21d77d984cf1363fb0d1770218c5e17020Kay Sievers return sd_bus_reply_method_return(message, "o", p);
59512f21d77d984cf1363fb0d1770218c5e17020Kay Sievers}
59512f21d77d984cf1363fb0d1770218c5e17020Kay Sievers
59512f21d77d984cf1363fb0d1770218c5e17020Kay Sieversstatic int method_get_seat(sd_bus *bus, sd_bus_message *message, void *userdata, sd_bus_error *error) {
59512f21d77d984cf1363fb0d1770218c5e17020Kay Sievers _cleanup_free_ char *p = NULL;
59512f21d77d984cf1363fb0d1770218c5e17020Kay Sievers Manager *m = userdata;
59512f21d77d984cf1363fb0d1770218c5e17020Kay Sievers const char *name;
59512f21d77d984cf1363fb0d1770218c5e17020Kay Sievers Seat *seat;
59512f21d77d984cf1363fb0d1770218c5e17020Kay Sievers int r;
59512f21d77d984cf1363fb0d1770218c5e17020Kay Sievers
59512f21d77d984cf1363fb0d1770218c5e17020Kay Sievers assert(bus);
59512f21d77d984cf1363fb0d1770218c5e17020Kay Sievers assert(message);
59512f21d77d984cf1363fb0d1770218c5e17020Kay Sievers assert(m);
61331eab0a53cd9b8446eab6d1ebf1a046d8efc1Lennart Poettering
61331eab0a53cd9b8446eab6d1ebf1a046d8efc1Lennart Poettering r = sd_bus_message_read(message, "s", &name);
61331eab0a53cd9b8446eab6d1ebf1a046d8efc1Lennart Poettering if (r < 0)
61331eab0a53cd9b8446eab6d1ebf1a046d8efc1Lennart Poettering return r;
cca1dfddd4ce4357113663532696488427cc54e4Lennart Poettering
61331eab0a53cd9b8446eab6d1ebf1a046d8efc1Lennart Poettering seat = hashmap_get(m->seats, name);
61331eab0a53cd9b8446eab6d1ebf1a046d8efc1Lennart Poettering if (!seat)
61331eab0a53cd9b8446eab6d1ebf1a046d8efc1Lennart Poettering return sd_bus_error_setf(error, BUS_ERROR_NO_SUCH_SEAT, "No seat '%s' known", name);
61331eab0a53cd9b8446eab6d1ebf1a046d8efc1Lennart Poettering
a0b1209c4a59754f428894e0485413542da50014Zbigniew Jędrzejewski-Szmek p = seat_bus_path(seat);
61331eab0a53cd9b8446eab6d1ebf1a046d8efc1Lennart Poettering if (!p)
61331eab0a53cd9b8446eab6d1ebf1a046d8efc1Lennart Poettering return -ENOMEM;
61331eab0a53cd9b8446eab6d1ebf1a046d8efc1Lennart Poettering
61331eab0a53cd9b8446eab6d1ebf1a046d8efc1Lennart Poettering return sd_bus_reply_method_return(message, "o", p);
61331eab0a53cd9b8446eab6d1ebf1a046d8efc1Lennart Poettering}
61331eab0a53cd9b8446eab6d1ebf1a046d8efc1Lennart Poettering
61331eab0a53cd9b8446eab6d1ebf1a046d8efc1Lennart Poetteringstatic int method_list_sessions(sd_bus *bus, sd_bus_message *message, void *userdata, sd_bus_error *error) {
59512f21d77d984cf1363fb0d1770218c5e17020Kay Sievers _cleanup_bus_message_unref_ sd_bus_message *reply = NULL;
61331eab0a53cd9b8446eab6d1ebf1a046d8efc1Lennart Poettering Manager *m = userdata;
61331eab0a53cd9b8446eab6d1ebf1a046d8efc1Lennart Poettering Session *session;
61331eab0a53cd9b8446eab6d1ebf1a046d8efc1Lennart Poettering Iterator i;
61331eab0a53cd9b8446eab6d1ebf1a046d8efc1Lennart Poettering int r;
61331eab0a53cd9b8446eab6d1ebf1a046d8efc1Lennart Poettering
61331eab0a53cd9b8446eab6d1ebf1a046d8efc1Lennart Poettering assert(bus);
61331eab0a53cd9b8446eab6d1ebf1a046d8efc1Lennart Poettering assert(message);
61331eab0a53cd9b8446eab6d1ebf1a046d8efc1Lennart Poettering assert(m);
61331eab0a53cd9b8446eab6d1ebf1a046d8efc1Lennart Poettering
61331eab0a53cd9b8446eab6d1ebf1a046d8efc1Lennart Poettering r = sd_bus_message_new_method_return(message, &reply);
61331eab0a53cd9b8446eab6d1ebf1a046d8efc1Lennart Poettering if (r < 0)
61331eab0a53cd9b8446eab6d1ebf1a046d8efc1Lennart Poettering return r;
56f64d95763a799ba4475daf44d8e9f72a1bd474Michal Schmidt
61331eab0a53cd9b8446eab6d1ebf1a046d8efc1Lennart Poettering r = sd_bus_message_open_container(reply, 'a', "(susso)");
61331eab0a53cd9b8446eab6d1ebf1a046d8efc1Lennart Poettering if (r < 0)
61331eab0a53cd9b8446eab6d1ebf1a046d8efc1Lennart Poettering return r;
61331eab0a53cd9b8446eab6d1ebf1a046d8efc1Lennart Poettering
61331eab0a53cd9b8446eab6d1ebf1a046d8efc1Lennart Poettering HASHMAP_FOREACH(session, m->sessions, i) {
61331eab0a53cd9b8446eab6d1ebf1a046d8efc1Lennart Poettering _cleanup_free_ char *p = NULL;
61331eab0a53cd9b8446eab6d1ebf1a046d8efc1Lennart Poettering
61331eab0a53cd9b8446eab6d1ebf1a046d8efc1Lennart Poettering p = session_bus_path(session);
61331eab0a53cd9b8446eab6d1ebf1a046d8efc1Lennart Poettering if (!p)
61331eab0a53cd9b8446eab6d1ebf1a046d8efc1Lennart Poettering return -ENOMEM;
a0b1209c4a59754f428894e0485413542da50014Zbigniew Jędrzejewski-Szmek
a0b1209c4a59754f428894e0485413542da50014Zbigniew Jędrzejewski-Szmek r = sd_bus_message_append(reply, "(susso)",
61331eab0a53cd9b8446eab6d1ebf1a046d8efc1Lennart Poettering session->id,
a0b1209c4a59754f428894e0485413542da50014Zbigniew Jędrzejewski-Szmek (uint32_t) session->user->uid,
a0b1209c4a59754f428894e0485413542da50014Zbigniew Jędrzejewski-Szmek session->user->name,
61331eab0a53cd9b8446eab6d1ebf1a046d8efc1Lennart Poettering session->seat ? session->seat->id : "",
61331eab0a53cd9b8446eab6d1ebf1a046d8efc1Lennart Poettering p);
61331eab0a53cd9b8446eab6d1ebf1a046d8efc1Lennart Poettering if (r < 0)
61331eab0a53cd9b8446eab6d1ebf1a046d8efc1Lennart Poettering return r;
61331eab0a53cd9b8446eab6d1ebf1a046d8efc1Lennart Poettering }
61331eab0a53cd9b8446eab6d1ebf1a046d8efc1Lennart Poettering
cca1dfddd4ce4357113663532696488427cc54e4Lennart Poettering r = sd_bus_message_close_container(reply);
59512f21d77d984cf1363fb0d1770218c5e17020Kay Sievers if (r < 0)
61331eab0a53cd9b8446eab6d1ebf1a046d8efc1Lennart Poettering return r;
61331eab0a53cd9b8446eab6d1ebf1a046d8efc1Lennart Poettering
61331eab0a53cd9b8446eab6d1ebf1a046d8efc1Lennart Poettering return sd_bus_send(bus, reply, NULL);
61331eab0a53cd9b8446eab6d1ebf1a046d8efc1Lennart Poettering}
59512f21d77d984cf1363fb0d1770218c5e17020Kay Sievers
59512f21d77d984cf1363fb0d1770218c5e17020Kay Sieversstatic int method_list_users(sd_bus *bus, sd_bus_message *message, void *userdata, sd_bus_error *error) {
59512f21d77d984cf1363fb0d1770218c5e17020Kay Sievers _cleanup_bus_message_unref_ sd_bus_message *reply = NULL;
59512f21d77d984cf1363fb0d1770218c5e17020Kay Sievers Manager *m = userdata;
59512f21d77d984cf1363fb0d1770218c5e17020Kay Sievers User *user;
59512f21d77d984cf1363fb0d1770218c5e17020Kay Sievers Iterator i;
59512f21d77d984cf1363fb0d1770218c5e17020Kay Sievers int r;
59512f21d77d984cf1363fb0d1770218c5e17020Kay Sievers
59512f21d77d984cf1363fb0d1770218c5e17020Kay Sievers assert(bus);
59512f21d77d984cf1363fb0d1770218c5e17020Kay Sievers assert(message);
59512f21d77d984cf1363fb0d1770218c5e17020Kay Sievers assert(m);
59512f21d77d984cf1363fb0d1770218c5e17020Kay Sievers
59512f21d77d984cf1363fb0d1770218c5e17020Kay Sievers r = sd_bus_message_new_method_return(message, &reply);
59512f21d77d984cf1363fb0d1770218c5e17020Kay Sievers if (r < 0)
59512f21d77d984cf1363fb0d1770218c5e17020Kay Sievers return r;
59512f21d77d984cf1363fb0d1770218c5e17020Kay Sievers
59512f21d77d984cf1363fb0d1770218c5e17020Kay Sievers r = sd_bus_message_open_container(reply, 'a', "(uso)");
59512f21d77d984cf1363fb0d1770218c5e17020Kay Sievers if (r < 0)
59512f21d77d984cf1363fb0d1770218c5e17020Kay Sievers return r;
59512f21d77d984cf1363fb0d1770218c5e17020Kay Sievers
59512f21d77d984cf1363fb0d1770218c5e17020Kay Sievers HASHMAP_FOREACH(user, m->users, i) {
59512f21d77d984cf1363fb0d1770218c5e17020Kay Sievers _cleanup_free_ char *p = NULL;
59512f21d77d984cf1363fb0d1770218c5e17020Kay Sievers
59512f21d77d984cf1363fb0d1770218c5e17020Kay Sievers p = user_bus_path(user);
59512f21d77d984cf1363fb0d1770218c5e17020Kay Sievers if (!p)
59512f21d77d984cf1363fb0d1770218c5e17020Kay Sievers return -ENOMEM;
59512f21d77d984cf1363fb0d1770218c5e17020Kay Sievers
59512f21d77d984cf1363fb0d1770218c5e17020Kay Sievers r = sd_bus_message_append(reply, "(uso)",
59512f21d77d984cf1363fb0d1770218c5e17020Kay Sievers (uint32_t) user->uid,
59512f21d77d984cf1363fb0d1770218c5e17020Kay Sievers user->name,
dacd6cee76a08331b8c8616c5f30f70ee49aa2f9Lennart Poettering p);
dacd6cee76a08331b8c8616c5f30f70ee49aa2f9Lennart Poettering if (r < 0)
dacd6cee76a08331b8c8616c5f30f70ee49aa2f9Lennart Poettering return r;
59512f21d77d984cf1363fb0d1770218c5e17020Kay Sievers }
59512f21d77d984cf1363fb0d1770218c5e17020Kay Sievers
59512f21d77d984cf1363fb0d1770218c5e17020Kay Sievers r = sd_bus_message_close_container(reply);
59512f21d77d984cf1363fb0d1770218c5e17020Kay Sievers if (r < 0)
59512f21d77d984cf1363fb0d1770218c5e17020Kay Sievers return r;
59512f21d77d984cf1363fb0d1770218c5e17020Kay Sievers
59512f21d77d984cf1363fb0d1770218c5e17020Kay Sievers return sd_bus_send(bus, reply, NULL);
59512f21d77d984cf1363fb0d1770218c5e17020Kay Sievers}
59512f21d77d984cf1363fb0d1770218c5e17020Kay Sievers
59512f21d77d984cf1363fb0d1770218c5e17020Kay Sieversstatic int method_list_seats(sd_bus *bus, sd_bus_message *message, void *userdata, sd_bus_error *error) {
59512f21d77d984cf1363fb0d1770218c5e17020Kay Sievers _cleanup_bus_message_unref_ sd_bus_message *reply = NULL;
59512f21d77d984cf1363fb0d1770218c5e17020Kay Sievers Manager *m = userdata;
59512f21d77d984cf1363fb0d1770218c5e17020Kay Sievers Seat *seat;
7a1494aa4e4a131d73e866cf1e7eb7b6e47dbab8Tom Gundersen Iterator i;
7a1494aa4e4a131d73e866cf1e7eb7b6e47dbab8Tom Gundersen int r;
7a1494aa4e4a131d73e866cf1e7eb7b6e47dbab8Tom Gundersen
7a1494aa4e4a131d73e866cf1e7eb7b6e47dbab8Tom Gundersen assert(bus);
7a1494aa4e4a131d73e866cf1e7eb7b6e47dbab8Tom Gundersen assert(message);
7a1494aa4e4a131d73e866cf1e7eb7b6e47dbab8Tom Gundersen assert(m);
7a1494aa4e4a131d73e866cf1e7eb7b6e47dbab8Tom Gundersen
7a1494aa4e4a131d73e866cf1e7eb7b6e47dbab8Tom Gundersen r = sd_bus_message_new_method_return(message, &reply);
7a1494aa4e4a131d73e866cf1e7eb7b6e47dbab8Tom Gundersen if (r < 0)
7a1494aa4e4a131d73e866cf1e7eb7b6e47dbab8Tom Gundersen return r;
7a1494aa4e4a131d73e866cf1e7eb7b6e47dbab8Tom Gundersen
7a1494aa4e4a131d73e866cf1e7eb7b6e47dbab8Tom Gundersen r = sd_bus_message_open_container(reply, 'a', "(so)");
7a1494aa4e4a131d73e866cf1e7eb7b6e47dbab8Tom Gundersen if (r < 0)
7a1494aa4e4a131d73e866cf1e7eb7b6e47dbab8Tom Gundersen return r;
7a1494aa4e4a131d73e866cf1e7eb7b6e47dbab8Tom Gundersen
7a1494aa4e4a131d73e866cf1e7eb7b6e47dbab8Tom Gundersen HASHMAP_FOREACH(seat, m->seats, i) {
7a1494aa4e4a131d73e866cf1e7eb7b6e47dbab8Tom Gundersen _cleanup_free_ char *p = NULL;
7a1494aa4e4a131d73e866cf1e7eb7b6e47dbab8Tom Gundersen
7a1494aa4e4a131d73e866cf1e7eb7b6e47dbab8Tom Gundersen p = seat_bus_path(seat);
7a1494aa4e4a131d73e866cf1e7eb7b6e47dbab8Tom Gundersen if (!p)
7a1494aa4e4a131d73e866cf1e7eb7b6e47dbab8Tom Gundersen return -ENOMEM;
7a1494aa4e4a131d73e866cf1e7eb7b6e47dbab8Tom Gundersen
7a1494aa4e4a131d73e866cf1e7eb7b6e47dbab8Tom Gundersen r = sd_bus_message_append(reply, "(so)", seat->id, p);
7a1494aa4e4a131d73e866cf1e7eb7b6e47dbab8Tom Gundersen if (r < 0)
7a1494aa4e4a131d73e866cf1e7eb7b6e47dbab8Tom Gundersen return r;
7a1494aa4e4a131d73e866cf1e7eb7b6e47dbab8Tom Gundersen }
7a1494aa4e4a131d73e866cf1e7eb7b6e47dbab8Tom Gundersen
7a1494aa4e4a131d73e866cf1e7eb7b6e47dbab8Tom Gundersen r = sd_bus_message_close_container(reply);
7a1494aa4e4a131d73e866cf1e7eb7b6e47dbab8Tom Gundersen if (r < 0)
7a1494aa4e4a131d73e866cf1e7eb7b6e47dbab8Tom Gundersen return r;
7a1494aa4e4a131d73e866cf1e7eb7b6e47dbab8Tom Gundersen
7a1494aa4e4a131d73e866cf1e7eb7b6e47dbab8Tom Gundersen return sd_bus_send(bus, reply, NULL);
7a1494aa4e4a131d73e866cf1e7eb7b6e47dbab8Tom Gundersen}
7a1494aa4e4a131d73e866cf1e7eb7b6e47dbab8Tom Gundersen
7a1494aa4e4a131d73e866cf1e7eb7b6e47dbab8Tom Gundersenstatic int method_list_inhibitors(sd_bus *bus, sd_bus_message *message, void *userdata, sd_bus_error *error) {
7a1494aa4e4a131d73e866cf1e7eb7b6e47dbab8Tom Gundersen _cleanup_bus_message_unref_ sd_bus_message *reply = NULL;
7a1494aa4e4a131d73e866cf1e7eb7b6e47dbab8Tom Gundersen Manager *m = userdata;
7a1494aa4e4a131d73e866cf1e7eb7b6e47dbab8Tom Gundersen Inhibitor *inhibitor;
7a1494aa4e4a131d73e866cf1e7eb7b6e47dbab8Tom Gundersen Iterator i;
7a1494aa4e4a131d73e866cf1e7eb7b6e47dbab8Tom Gundersen int r;
7a1494aa4e4a131d73e866cf1e7eb7b6e47dbab8Tom Gundersen
7a1494aa4e4a131d73e866cf1e7eb7b6e47dbab8Tom Gundersen r = sd_bus_message_new_method_return(message, &reply);
7a1494aa4e4a131d73e866cf1e7eb7b6e47dbab8Tom Gundersen if (r < 0)
7a1494aa4e4a131d73e866cf1e7eb7b6e47dbab8Tom Gundersen return r;
7a1494aa4e4a131d73e866cf1e7eb7b6e47dbab8Tom Gundersen
7a1494aa4e4a131d73e866cf1e7eb7b6e47dbab8Tom Gundersen r = sd_bus_message_open_container(reply, 'a', "(ssssuu)");
7a1494aa4e4a131d73e866cf1e7eb7b6e47dbab8Tom Gundersen if (r < 0)
7a1494aa4e4a131d73e866cf1e7eb7b6e47dbab8Tom Gundersen return r;
7a1494aa4e4a131d73e866cf1e7eb7b6e47dbab8Tom Gundersen
7a1494aa4e4a131d73e866cf1e7eb7b6e47dbab8Tom Gundersen HASHMAP_FOREACH(inhibitor, m->inhibitors, i) {
7a1494aa4e4a131d73e866cf1e7eb7b6e47dbab8Tom Gundersen
7a1494aa4e4a131d73e866cf1e7eb7b6e47dbab8Tom Gundersen r = sd_bus_message_append(reply, "(ssssuu)",
7a1494aa4e4a131d73e866cf1e7eb7b6e47dbab8Tom Gundersen strempty(inhibit_what_to_string(inhibitor->what)),
7a1494aa4e4a131d73e866cf1e7eb7b6e47dbab8Tom Gundersen strempty(inhibitor->who),
7a1494aa4e4a131d73e866cf1e7eb7b6e47dbab8Tom Gundersen strempty(inhibitor->why),
7a1494aa4e4a131d73e866cf1e7eb7b6e47dbab8Tom Gundersen strempty(inhibit_mode_to_string(inhibitor->mode)),
7a1494aa4e4a131d73e866cf1e7eb7b6e47dbab8Tom Gundersen (uint32_t) inhibitor->uid,
7a1494aa4e4a131d73e866cf1e7eb7b6e47dbab8Tom Gundersen (uint32_t) inhibitor->pid);
7a1494aa4e4a131d73e866cf1e7eb7b6e47dbab8Tom Gundersen if (r < 0)
7a1494aa4e4a131d73e866cf1e7eb7b6e47dbab8Tom Gundersen return r;
7a1494aa4e4a131d73e866cf1e7eb7b6e47dbab8Tom Gundersen }
7a1494aa4e4a131d73e866cf1e7eb7b6e47dbab8Tom Gundersen
7a1494aa4e4a131d73e866cf1e7eb7b6e47dbab8Tom Gundersen r = sd_bus_message_close_container(reply);
7a1494aa4e4a131d73e866cf1e7eb7b6e47dbab8Tom Gundersen if (r < 0)
7a1494aa4e4a131d73e866cf1e7eb7b6e47dbab8Tom Gundersen return r;
7a1494aa4e4a131d73e866cf1e7eb7b6e47dbab8Tom Gundersen
7a1494aa4e4a131d73e866cf1e7eb7b6e47dbab8Tom Gundersen return sd_bus_send(bus, reply, NULL);
7a1494aa4e4a131d73e866cf1e7eb7b6e47dbab8Tom Gundersen}
7a1494aa4e4a131d73e866cf1e7eb7b6e47dbab8Tom Gundersen
7a1494aa4e4a131d73e866cf1e7eb7b6e47dbab8Tom Gundersenstatic int method_create_session(sd_bus *bus, sd_bus_message *message, void *userdata, sd_bus_error *error) {
7a1494aa4e4a131d73e866cf1e7eb7b6e47dbab8Tom Gundersen const char *service, *type, *class, *cseat, *tty, *display, *remote_user, *remote_host;
7a1494aa4e4a131d73e866cf1e7eb7b6e47dbab8Tom Gundersen uint32_t uid, leader, audit_id = 0;
7a1494aa4e4a131d73e866cf1e7eb7b6e47dbab8Tom Gundersen _cleanup_free_ char *id = NULL;
7a1494aa4e4a131d73e866cf1e7eb7b6e47dbab8Tom Gundersen Session *session = NULL;
7a1494aa4e4a131d73e866cf1e7eb7b6e47dbab8Tom Gundersen Manager *m = userdata;
7a1494aa4e4a131d73e866cf1e7eb7b6e47dbab8Tom Gundersen User *user = NULL;
7a1494aa4e4a131d73e866cf1e7eb7b6e47dbab8Tom Gundersen Seat *seat = NULL;
59512f21d77d984cf1363fb0d1770218c5e17020Kay Sievers int remote;
59512f21d77d984cf1363fb0d1770218c5e17020Kay Sievers uint32_t vtnr = 0;
59512f21d77d984cf1363fb0d1770218c5e17020Kay Sievers SessionType t;
59512f21d77d984cf1363fb0d1770218c5e17020Kay Sievers SessionClass c;
59512f21d77d984cf1363fb0d1770218c5e17020Kay Sievers int r;
59512f21d77d984cf1363fb0d1770218c5e17020Kay Sievers
59512f21d77d984cf1363fb0d1770218c5e17020Kay Sievers assert(bus);
59512f21d77d984cf1363fb0d1770218c5e17020Kay Sievers assert(message);
59512f21d77d984cf1363fb0d1770218c5e17020Kay Sievers assert(m);
59512f21d77d984cf1363fb0d1770218c5e17020Kay Sievers
59512f21d77d984cf1363fb0d1770218c5e17020Kay Sievers r = sd_bus_message_read(message, "uussssussbss", &uid, &leader, &service, &type, &class, &cseat, &vtnr, &tty, &display, &remote, &remote_user, &remote_host);
59512f21d77d984cf1363fb0d1770218c5e17020Kay Sievers if (r < 0)
59512f21d77d984cf1363fb0d1770218c5e17020Kay Sievers return r;
59512f21d77d984cf1363fb0d1770218c5e17020Kay Sievers
59512f21d77d984cf1363fb0d1770218c5e17020Kay Sievers if (leader == 1)
59512f21d77d984cf1363fb0d1770218c5e17020Kay Sievers return sd_bus_error_setf(error, SD_BUS_ERROR_INVALID_ARGS, "Invalid leader PID");
59512f21d77d984cf1363fb0d1770218c5e17020Kay Sievers
59512f21d77d984cf1363fb0d1770218c5e17020Kay Sievers if (isempty(type))
59512f21d77d984cf1363fb0d1770218c5e17020Kay Sievers t = _SESSION_TYPE_INVALID;
59512f21d77d984cf1363fb0d1770218c5e17020Kay Sievers else {
59512f21d77d984cf1363fb0d1770218c5e17020Kay Sievers t = session_type_from_string(type);
59512f21d77d984cf1363fb0d1770218c5e17020Kay Sievers if (t < 0)
59512f21d77d984cf1363fb0d1770218c5e17020Kay Sievers return sd_bus_error_setf(error, SD_BUS_ERROR_INVALID_ARGS, "Invalid session type %s", type);
59512f21d77d984cf1363fb0d1770218c5e17020Kay Sievers }
59512f21d77d984cf1363fb0d1770218c5e17020Kay Sievers
59512f21d77d984cf1363fb0d1770218c5e17020Kay Sievers if (isempty(class))
59512f21d77d984cf1363fb0d1770218c5e17020Kay Sievers c = _SESSION_CLASS_INVALID;
59512f21d77d984cf1363fb0d1770218c5e17020Kay Sievers else {
59512f21d77d984cf1363fb0d1770218c5e17020Kay Sievers c = session_class_from_string(class);
59512f21d77d984cf1363fb0d1770218c5e17020Kay Sievers if (c < 0)
59512f21d77d984cf1363fb0d1770218c5e17020Kay Sievers return sd_bus_error_setf(error, SD_BUS_ERROR_INVALID_ARGS, "Invalid session class %s", class);
59512f21d77d984cf1363fb0d1770218c5e17020Kay Sievers }
59512f21d77d984cf1363fb0d1770218c5e17020Kay Sievers
59512f21d77d984cf1363fb0d1770218c5e17020Kay Sievers if (isempty(cseat))
59512f21d77d984cf1363fb0d1770218c5e17020Kay Sievers seat = NULL;
59512f21d77d984cf1363fb0d1770218c5e17020Kay Sievers else {
59512f21d77d984cf1363fb0d1770218c5e17020Kay Sievers seat = hashmap_get(m->seats, cseat);
59512f21d77d984cf1363fb0d1770218c5e17020Kay Sievers if (!seat)
59512f21d77d984cf1363fb0d1770218c5e17020Kay Sievers return sd_bus_error_setf(error, BUS_ERROR_NO_SUCH_SEAT, "No seat '%s' known", seat);
59512f21d77d984cf1363fb0d1770218c5e17020Kay Sievers }
59512f21d77d984cf1363fb0d1770218c5e17020Kay Sievers
59512f21d77d984cf1363fb0d1770218c5e17020Kay Sievers if (tty_is_vc(tty)) {
59512f21d77d984cf1363fb0d1770218c5e17020Kay Sievers int v;
59512f21d77d984cf1363fb0d1770218c5e17020Kay Sievers
59512f21d77d984cf1363fb0d1770218c5e17020Kay Sievers if (!seat)
59512f21d77d984cf1363fb0d1770218c5e17020Kay Sievers seat = m->seat0;
59512f21d77d984cf1363fb0d1770218c5e17020Kay Sievers else if (seat != m->seat0)
59512f21d77d984cf1363fb0d1770218c5e17020Kay Sievers return sd_bus_error_setf(error, SD_BUS_ERROR_INVALID_ARGS, "TTY %s is virtual console but seat %s is not seat0", tty, seat);
59512f21d77d984cf1363fb0d1770218c5e17020Kay Sievers
59512f21d77d984cf1363fb0d1770218c5e17020Kay Sievers v = vtnr_from_tty(tty);
59512f21d77d984cf1363fb0d1770218c5e17020Kay Sievers if (v <= 0)
59512f21d77d984cf1363fb0d1770218c5e17020Kay Sievers return sd_bus_error_setf(error, SD_BUS_ERROR_INVALID_ARGS, "Cannot determine VT number from virtual console TTY %s", tty);
59512f21d77d984cf1363fb0d1770218c5e17020Kay Sievers
59512f21d77d984cf1363fb0d1770218c5e17020Kay Sievers if (!vtnr)
59512f21d77d984cf1363fb0d1770218c5e17020Kay Sievers vtnr = (uint32_t) v;
59512f21d77d984cf1363fb0d1770218c5e17020Kay Sievers else if (vtnr != (uint32_t) v)
59512f21d77d984cf1363fb0d1770218c5e17020Kay Sievers return sd_bus_error_setf(error, SD_BUS_ERROR_INVALID_ARGS, "Specified TTY and VT number do not match");
59512f21d77d984cf1363fb0d1770218c5e17020Kay Sievers
59512f21d77d984cf1363fb0d1770218c5e17020Kay Sievers } else if (tty_is_console(tty)) {
59512f21d77d984cf1363fb0d1770218c5e17020Kay Sievers
59512f21d77d984cf1363fb0d1770218c5e17020Kay Sievers if (!seat)
59512f21d77d984cf1363fb0d1770218c5e17020Kay Sievers seat = m->seat0;
59512f21d77d984cf1363fb0d1770218c5e17020Kay Sievers else if (seat != m->seat0)
59512f21d77d984cf1363fb0d1770218c5e17020Kay Sievers return sd_bus_error_setf(error, SD_BUS_ERROR_INVALID_ARGS, "Console TTY specified but seat is not seat0");
59512f21d77d984cf1363fb0d1770218c5e17020Kay Sievers
59512f21d77d984cf1363fb0d1770218c5e17020Kay Sievers if (vtnr != 0)
59512f21d77d984cf1363fb0d1770218c5e17020Kay Sievers return sd_bus_error_setf(error, SD_BUS_ERROR_INVALID_ARGS, "Console TTY specified but VT number is not 0");
59512f21d77d984cf1363fb0d1770218c5e17020Kay Sievers }
59512f21d77d984cf1363fb0d1770218c5e17020Kay Sievers
59512f21d77d984cf1363fb0d1770218c5e17020Kay Sievers if (seat) {
59512f21d77d984cf1363fb0d1770218c5e17020Kay Sievers if (seat_has_vts(seat)) {
59512f21d77d984cf1363fb0d1770218c5e17020Kay Sievers if (!vtnr || vtnr > 63)
59512f21d77d984cf1363fb0d1770218c5e17020Kay Sievers return sd_bus_error_setf(error, SD_BUS_ERROR_INVALID_ARGS, "VT number out of range");
59512f21d77d984cf1363fb0d1770218c5e17020Kay Sievers } else {
59512f21d77d984cf1363fb0d1770218c5e17020Kay Sievers if (vtnr != 0)
59512f21d77d984cf1363fb0d1770218c5e17020Kay Sievers return sd_bus_error_setf(error, SD_BUS_ERROR_INVALID_ARGS, "Seat has no VTs but VT number not 0");
59512f21d77d984cf1363fb0d1770218c5e17020Kay Sievers }
59512f21d77d984cf1363fb0d1770218c5e17020Kay Sievers }
59512f21d77d984cf1363fb0d1770218c5e17020Kay Sievers
59512f21d77d984cf1363fb0d1770218c5e17020Kay Sievers r = sd_bus_message_enter_container(message, 'a', "(sv)");
59512f21d77d984cf1363fb0d1770218c5e17020Kay Sievers if (r < 0)
59512f21d77d984cf1363fb0d1770218c5e17020Kay Sievers return r;
59512f21d77d984cf1363fb0d1770218c5e17020Kay Sievers
59512f21d77d984cf1363fb0d1770218c5e17020Kay Sievers if (t == _SESSION_TYPE_INVALID) {
59512f21d77d984cf1363fb0d1770218c5e17020Kay Sievers if (!isempty(display))
59512f21d77d984cf1363fb0d1770218c5e17020Kay Sievers t = SESSION_X11;
59512f21d77d984cf1363fb0d1770218c5e17020Kay Sievers else if (!isempty(tty))
59512f21d77d984cf1363fb0d1770218c5e17020Kay Sievers t = SESSION_TTY;
59512f21d77d984cf1363fb0d1770218c5e17020Kay Sievers else
7a1494aa4e4a131d73e866cf1e7eb7b6e47dbab8Tom Gundersen t = SESSION_UNSPECIFIED;
59512f21d77d984cf1363fb0d1770218c5e17020Kay Sievers }
7a1494aa4e4a131d73e866cf1e7eb7b6e47dbab8Tom Gundersen
59512f21d77d984cf1363fb0d1770218c5e17020Kay Sievers if (c == _SESSION_CLASS_INVALID) {
59512f21d77d984cf1363fb0d1770218c5e17020Kay Sievers if (!isempty(display) || !isempty(tty))
7a1494aa4e4a131d73e866cf1e7eb7b6e47dbab8Tom Gundersen c = SESSION_USER;
59512f21d77d984cf1363fb0d1770218c5e17020Kay Sievers else
61331eab0a53cd9b8446eab6d1ebf1a046d8efc1Lennart Poettering c = SESSION_BACKGROUND;
61331eab0a53cd9b8446eab6d1ebf1a046d8efc1Lennart Poettering }
1ca208fb4f93e5869704af1812cbff7130a2fc03Zbigniew Jędrzejewski-Szmek
1ca208fb4f93e5869704af1812cbff7130a2fc03Zbigniew Jędrzejewski-Szmek if (leader <= 0) {
61331eab0a53cd9b8446eab6d1ebf1a046d8efc1Lennart Poettering assert_cc(sizeof(uint32_t) == sizeof(pid_t));
61331eab0a53cd9b8446eab6d1ebf1a046d8efc1Lennart Poettering
59512f21d77d984cf1363fb0d1770218c5e17020Kay Sievers r = sd_bus_get_owner_pid(bus, sd_bus_message_get_sender(message), (pid_t*) &leader);
1a14a53cfded6e78c6e8dfb73fdff0039971d642Lennart Poettering if (r < 0)
e48fdd84432bbf9c2ecc339183258c7c33116032Lennart Poettering return r;
d2a623823f8d83c97c35fcd28f90e8cd59066f8aZbigniew Jędrzejewski-Szmek }
59512f21d77d984cf1363fb0d1770218c5e17020Kay Sievers
cca1dfddd4ce4357113663532696488427cc54e4Lennart Poettering manager_get_session_by_pid(m, leader, &session);
61331eab0a53cd9b8446eab6d1ebf1a046d8efc1Lennart Poettering if (session) {
73b80ec2d999c45ce13f3e034704249d80829f7eLennart Poettering _cleanup_free_ char *path = NULL;
61331eab0a53cd9b8446eab6d1ebf1a046d8efc1Lennart Poettering _cleanup_close_ int fifo_fd = -1;
1a14a53cfded6e78c6e8dfb73fdff0039971d642Lennart Poettering
61331eab0a53cd9b8446eab6d1ebf1a046d8efc1Lennart Poettering /* Session already exists, client is probably
61331eab0a53cd9b8446eab6d1ebf1a046d8efc1Lennart Poettering * something like "su" which changes uid but is still
b47d419c25ecc735615a1088060c1ec8bef1e41fZbigniew Jędrzejewski-Szmek * the same session */
1a14a53cfded6e78c6e8dfb73fdff0039971d642Lennart Poettering
61331eab0a53cd9b8446eab6d1ebf1a046d8efc1Lennart Poettering fifo_fd = session_create_fifo(session);
1ca208fb4f93e5869704af1812cbff7130a2fc03Zbigniew Jędrzejewski-Szmek if (fifo_fd < 0)
1ca208fb4f93e5869704af1812cbff7130a2fc03Zbigniew Jędrzejewski-Szmek return fifo_fd;
1a14a53cfded6e78c6e8dfb73fdff0039971d642Lennart Poettering
d2a623823f8d83c97c35fcd28f90e8cd59066f8aZbigniew Jędrzejewski-Szmek path = session_bus_path(session);
d2a623823f8d83c97c35fcd28f90e8cd59066f8aZbigniew Jędrzejewski-Szmek if (!path)
d2a623823f8d83c97c35fcd28f90e8cd59066f8aZbigniew Jędrzejewski-Szmek return -ENOMEM;
d2a623823f8d83c97c35fcd28f90e8cd59066f8aZbigniew Jędrzejewski-Szmek
d2a623823f8d83c97c35fcd28f90e8cd59066f8aZbigniew Jędrzejewski-Szmek return sd_bus_reply_method_return(
d2a623823f8d83c97c35fcd28f90e8cd59066f8aZbigniew Jędrzejewski-Szmek message, "soshusub",
d2a623823f8d83c97c35fcd28f90e8cd59066f8aZbigniew Jędrzejewski-Szmek session->id,
d2a623823f8d83c97c35fcd28f90e8cd59066f8aZbigniew Jędrzejewski-Szmek path,
d2a623823f8d83c97c35fcd28f90e8cd59066f8aZbigniew Jędrzejewski-Szmek session->user->runtime_path,
1a14a53cfded6e78c6e8dfb73fdff0039971d642Lennart Poettering fifo_fd,
fa041593fe04b12ffd7e81d8b3598a7a6f313fb3Lennart Poettering (uint32_t) session->user->uid,
d2a623823f8d83c97c35fcd28f90e8cd59066f8aZbigniew Jędrzejewski-Szmek session->seat ? session->seat->id : "",
9c4495ca561624c2f0085507dd1288ed5f1247c5Tomasz Torcz (uint32_t) session->vtnr,
fa041593fe04b12ffd7e81d8b3598a7a6f313fb3Lennart Poettering true);
1a14a53cfded6e78c6e8dfb73fdff0039971d642Lennart Poettering }
61331eab0a53cd9b8446eab6d1ebf1a046d8efc1Lennart Poettering
61331eab0a53cd9b8446eab6d1ebf1a046d8efc1Lennart Poettering audit_session_from_pid(leader, &audit_id);
fa041593fe04b12ffd7e81d8b3598a7a6f313fb3Lennart Poettering if (audit_id > 0) {
d2a623823f8d83c97c35fcd28f90e8cd59066f8aZbigniew Jędrzejewski-Szmek /* Keep our session IDs and the audit session IDs in sync */
61331eab0a53cd9b8446eab6d1ebf1a046d8efc1Lennart Poettering
fa041593fe04b12ffd7e81d8b3598a7a6f313fb3Lennart Poettering if (asprintf(&id, "%lu", (unsigned long) audit_id) < 0)
61331eab0a53cd9b8446eab6d1ebf1a046d8efc1Lennart Poettering return -ENOMEM;
61331eab0a53cd9b8446eab6d1ebf1a046d8efc1Lennart Poettering
fa041593fe04b12ffd7e81d8b3598a7a6f313fb3Lennart Poettering /* Wut? There's already a session by this name and we
d2a623823f8d83c97c35fcd28f90e8cd59066f8aZbigniew Jędrzejewski-Szmek * didn't find it above? Weird, then let's not trust
61331eab0a53cd9b8446eab6d1ebf1a046d8efc1Lennart Poettering * the audit data and let's better register a new
fa041593fe04b12ffd7e81d8b3598a7a6f313fb3Lennart Poettering * ID */
61331eab0a53cd9b8446eab6d1ebf1a046d8efc1Lennart Poettering if (hashmap_get(m->sessions, id)) {
61331eab0a53cd9b8446eab6d1ebf1a046d8efc1Lennart Poettering log_warning("Existing logind session ID %s used by new audit session, ignoring", id);
61331eab0a53cd9b8446eab6d1ebf1a046d8efc1Lennart Poettering audit_id = 0;
fa041593fe04b12ffd7e81d8b3598a7a6f313fb3Lennart Poettering
d2a623823f8d83c97c35fcd28f90e8cd59066f8aZbigniew Jędrzejewski-Szmek free(id);
61331eab0a53cd9b8446eab6d1ebf1a046d8efc1Lennart Poettering id = NULL;
fa041593fe04b12ffd7e81d8b3598a7a6f313fb3Lennart Poettering }
61331eab0a53cd9b8446eab6d1ebf1a046d8efc1Lennart Poettering }
d2a623823f8d83c97c35fcd28f90e8cd59066f8aZbigniew Jędrzejewski-Szmek
61331eab0a53cd9b8446eab6d1ebf1a046d8efc1Lennart Poettering if (!id) {
61331eab0a53cd9b8446eab6d1ebf1a046d8efc1Lennart Poettering do {
61331eab0a53cd9b8446eab6d1ebf1a046d8efc1Lennart Poettering free(id);
61331eab0a53cd9b8446eab6d1ebf1a046d8efc1Lennart Poettering id = NULL;
61331eab0a53cd9b8446eab6d1ebf1a046d8efc1Lennart Poettering
61331eab0a53cd9b8446eab6d1ebf1a046d8efc1Lennart Poettering if (asprintf(&id, "c%lu", ++m->session_counter) < 0)
61331eab0a53cd9b8446eab6d1ebf1a046d8efc1Lennart Poettering return -ENOMEM;
61331eab0a53cd9b8446eab6d1ebf1a046d8efc1Lennart Poettering
61331eab0a53cd9b8446eab6d1ebf1a046d8efc1Lennart Poettering } while (hashmap_get(m->sessions, id));
61331eab0a53cd9b8446eab6d1ebf1a046d8efc1Lennart Poettering }
61331eab0a53cd9b8446eab6d1ebf1a046d8efc1Lennart Poettering
d2a623823f8d83c97c35fcd28f90e8cd59066f8aZbigniew Jędrzejewski-Szmek r = manager_add_user_by_uid(m, uid, &user);
61331eab0a53cd9b8446eab6d1ebf1a046d8efc1Lennart Poettering if (r < 0)
61331eab0a53cd9b8446eab6d1ebf1a046d8efc1Lennart Poettering goto fail;
61331eab0a53cd9b8446eab6d1ebf1a046d8efc1Lennart Poettering
61331eab0a53cd9b8446eab6d1ebf1a046d8efc1Lennart Poettering r = manager_add_session(m, id, &session);
61331eab0a53cd9b8446eab6d1ebf1a046d8efc1Lennart Poettering if (r < 0)
61331eab0a53cd9b8446eab6d1ebf1a046d8efc1Lennart Poettering goto fail;
61331eab0a53cd9b8446eab6d1ebf1a046d8efc1Lennart Poettering
61331eab0a53cd9b8446eab6d1ebf1a046d8efc1Lennart Poettering session_set_user(session, user);
61331eab0a53cd9b8446eab6d1ebf1a046d8efc1Lennart Poettering
d2a623823f8d83c97c35fcd28f90e8cd59066f8aZbigniew Jędrzejewski-Szmek session->leader = leader;
d2a623823f8d83c97c35fcd28f90e8cd59066f8aZbigniew Jędrzejewski-Szmek session->audit_id = audit_id;
61331eab0a53cd9b8446eab6d1ebf1a046d8efc1Lennart Poettering session->type = t;
61331eab0a53cd9b8446eab6d1ebf1a046d8efc1Lennart Poettering session->class = c;
61331eab0a53cd9b8446eab6d1ebf1a046d8efc1Lennart Poettering session->remote = remote;
d2a623823f8d83c97c35fcd28f90e8cd59066f8aZbigniew Jędrzejewski-Szmek session->vtnr = vtnr;
d2a623823f8d83c97c35fcd28f90e8cd59066f8aZbigniew Jędrzejewski-Szmek
d2a623823f8d83c97c35fcd28f90e8cd59066f8aZbigniew Jędrzejewski-Szmek if (!isempty(tty)) {
61331eab0a53cd9b8446eab6d1ebf1a046d8efc1Lennart Poettering session->tty = strdup(tty);
61331eab0a53cd9b8446eab6d1ebf1a046d8efc1Lennart Poettering if (!session->tty) {
fa041593fe04b12ffd7e81d8b3598a7a6f313fb3Lennart Poettering r = -ENOMEM;
d2a623823f8d83c97c35fcd28f90e8cd59066f8aZbigniew Jędrzejewski-Szmek goto fail;
61331eab0a53cd9b8446eab6d1ebf1a046d8efc1Lennart Poettering }
fa041593fe04b12ffd7e81d8b3598a7a6f313fb3Lennart Poettering }
61331eab0a53cd9b8446eab6d1ebf1a046d8efc1Lennart Poettering
61331eab0a53cd9b8446eab6d1ebf1a046d8efc1Lennart Poettering if (!isempty(display)) {
61331eab0a53cd9b8446eab6d1ebf1a046d8efc1Lennart Poettering session->display = strdup(display);
61331eab0a53cd9b8446eab6d1ebf1a046d8efc1Lennart Poettering if (!session->display) {
61331eab0a53cd9b8446eab6d1ebf1a046d8efc1Lennart Poettering r = -ENOMEM;
61331eab0a53cd9b8446eab6d1ebf1a046d8efc1Lennart Poettering goto fail;
61331eab0a53cd9b8446eab6d1ebf1a046d8efc1Lennart Poettering }
d2a623823f8d83c97c35fcd28f90e8cd59066f8aZbigniew Jędrzejewski-Szmek }
61331eab0a53cd9b8446eab6d1ebf1a046d8efc1Lennart Poettering
61331eab0a53cd9b8446eab6d1ebf1a046d8efc1Lennart Poettering if (!isempty(remote_user)) {
61331eab0a53cd9b8446eab6d1ebf1a046d8efc1Lennart Poettering session->remote_user = strdup(remote_user);
61331eab0a53cd9b8446eab6d1ebf1a046d8efc1Lennart Poettering if (!session->remote_user) {
61331eab0a53cd9b8446eab6d1ebf1a046d8efc1Lennart Poettering r = -ENOMEM;
61331eab0a53cd9b8446eab6d1ebf1a046d8efc1Lennart Poettering goto fail;
1a14a53cfded6e78c6e8dfb73fdff0039971d642Lennart Poettering }
1ca208fb4f93e5869704af1812cbff7130a2fc03Zbigniew Jędrzejewski-Szmek }
1ca208fb4f93e5869704af1812cbff7130a2fc03Zbigniew Jędrzejewski-Szmek
1a14a53cfded6e78c6e8dfb73fdff0039971d642Lennart Poettering if (!isempty(remote_host)) {
1a14a53cfded6e78c6e8dfb73fdff0039971d642Lennart Poettering session->remote_host = strdup(remote_host);
1ca208fb4f93e5869704af1812cbff7130a2fc03Zbigniew Jędrzejewski-Szmek if (!session->remote_host) {
1ca208fb4f93e5869704af1812cbff7130a2fc03Zbigniew Jędrzejewski-Szmek r = -ENOMEM;
1a14a53cfded6e78c6e8dfb73fdff0039971d642Lennart Poettering goto fail;
1a14a53cfded6e78c6e8dfb73fdff0039971d642Lennart Poettering }
23bbb0de4e3f85d9704a5c12a5afa2dfa0159e41Michal Schmidt }
d2a623823f8d83c97c35fcd28f90e8cd59066f8aZbigniew Jędrzejewski-Szmek
1a14a53cfded6e78c6e8dfb73fdff0039971d642Lennart Poettering if (!isempty(service)) {
1a14a53cfded6e78c6e8dfb73fdff0039971d642Lennart Poettering session->service = strdup(service);
1a14a53cfded6e78c6e8dfb73fdff0039971d642Lennart Poettering if (!session->service) {
e48fdd84432bbf9c2ecc339183258c7c33116032Lennart Poettering r = -ENOMEM;
61331eab0a53cd9b8446eab6d1ebf1a046d8efc1Lennart Poettering goto fail;
1a14a53cfded6e78c6e8dfb73fdff0039971d642Lennart Poettering }
61331eab0a53cd9b8446eab6d1ebf1a046d8efc1Lennart Poettering }
61331eab0a53cd9b8446eab6d1ebf1a046d8efc1Lennart Poettering
61331eab0a53cd9b8446eab6d1ebf1a046d8efc1Lennart Poettering if (seat) {
1a14a53cfded6e78c6e8dfb73fdff0039971d642Lennart Poettering r = seat_attach_session(seat, session);
1a14a53cfded6e78c6e8dfb73fdff0039971d642Lennart Poettering if (r < 0)
1ca208fb4f93e5869704af1812cbff7130a2fc03Zbigniew Jędrzejewski-Szmek goto fail;
61331eab0a53cd9b8446eab6d1ebf1a046d8efc1Lennart Poettering }
1a14a53cfded6e78c6e8dfb73fdff0039971d642Lennart Poettering
61331eab0a53cd9b8446eab6d1ebf1a046d8efc1Lennart Poettering r = session_start(session);
61331eab0a53cd9b8446eab6d1ebf1a046d8efc1Lennart Poettering if (r < 0)
1ca208fb4f93e5869704af1812cbff7130a2fc03Zbigniew Jędrzejewski-Szmek goto fail;
1a14a53cfded6e78c6e8dfb73fdff0039971d642Lennart Poettering
61331eab0a53cd9b8446eab6d1ebf1a046d8efc1Lennart Poettering session->create_message = sd_bus_message_ref(message);
1ca208fb4f93e5869704af1812cbff7130a2fc03Zbigniew Jędrzejewski-Szmek
1a14a53cfded6e78c6e8dfb73fdff0039971d642Lennart Poettering /* Now, let's wait until the slice unit and stuff got
61331eab0a53cd9b8446eab6d1ebf1a046d8efc1Lennart Poettering * created. We send the reply back from
61331eab0a53cd9b8446eab6d1ebf1a046d8efc1Lennart Poettering * session_send_create_reply().*/
1a14a53cfded6e78c6e8dfb73fdff0039971d642Lennart Poettering
61331eab0a53cd9b8446eab6d1ebf1a046d8efc1Lennart Poettering return 1;
61331eab0a53cd9b8446eab6d1ebf1a046d8efc1Lennart Poettering
61331eab0a53cd9b8446eab6d1ebf1a046d8efc1Lennart Poetteringfail:
73b80ec2d999c45ce13f3e034704249d80829f7eLennart Poettering if (session)
61331eab0a53cd9b8446eab6d1ebf1a046d8efc1Lennart Poettering session_add_to_gc_queue(session);
61331eab0a53cd9b8446eab6d1ebf1a046d8efc1Lennart Poettering
73b80ec2d999c45ce13f3e034704249d80829f7eLennart Poettering if (user)
61331eab0a53cd9b8446eab6d1ebf1a046d8efc1Lennart Poettering user_add_to_gc_queue(user);
61331eab0a53cd9b8446eab6d1ebf1a046d8efc1Lennart Poettering
61331eab0a53cd9b8446eab6d1ebf1a046d8efc1Lennart Poettering return r;
61331eab0a53cd9b8446eab6d1ebf1a046d8efc1Lennart Poettering}
61331eab0a53cd9b8446eab6d1ebf1a046d8efc1Lennart Poettering
61331eab0a53cd9b8446eab6d1ebf1a046d8efc1Lennart Poetteringstatic int method_release_session(sd_bus *bus, sd_bus_message *message, void *userdata, sd_bus_error *error) {
61331eab0a53cd9b8446eab6d1ebf1a046d8efc1Lennart Poettering Manager *m = userdata;
61331eab0a53cd9b8446eab6d1ebf1a046d8efc1Lennart Poettering Session *session;
61331eab0a53cd9b8446eab6d1ebf1a046d8efc1Lennart Poettering const char *name;
61331eab0a53cd9b8446eab6d1ebf1a046d8efc1Lennart Poettering int r;
1ca208fb4f93e5869704af1812cbff7130a2fc03Zbigniew Jędrzejewski-Szmek
1a14a53cfded6e78c6e8dfb73fdff0039971d642Lennart Poettering assert(bus);
73b80ec2d999c45ce13f3e034704249d80829f7eLennart Poettering assert(message);
0238d4c660e732dd03ba0cdb54a29ec5870ee849Kay Sievers assert(m);
0238d4c660e732dd03ba0cdb54a29ec5870ee849Kay Sievers
0238d4c660e732dd03ba0cdb54a29ec5870ee849Kay Sievers r = sd_bus_message_read(message, "s", &name);
0238d4c660e732dd03ba0cdb54a29ec5870ee849Kay Sievers if (r < 0)
0238d4c660e732dd03ba0cdb54a29ec5870ee849Kay Sievers return r;
73b80ec2d999c45ce13f3e034704249d80829f7eLennart Poettering
cca1dfddd4ce4357113663532696488427cc54e4Lennart Poettering session = hashmap_get(m->sessions, name);
d2a623823f8d83c97c35fcd28f90e8cd59066f8aZbigniew Jędrzejewski-Szmek if (!session)
cca1dfddd4ce4357113663532696488427cc54e4Lennart Poettering return sd_bus_error_setf(error, BUS_ERROR_NO_SUCH_SESSION, "No session '%s' known", name);
cca1dfddd4ce4357113663532696488427cc54e4Lennart Poettering
cca1dfddd4ce4357113663532696488427cc54e4Lennart Poettering /* We use the FIFO to detect stray sessions where the process
61331eab0a53cd9b8446eab6d1ebf1a046d8efc1Lennart Poettering invoking PAM dies abnormally. We need to make sure that
73b80ec2d999c45ce13f3e034704249d80829f7eLennart Poettering that process is not killed if at the clean end of the
73b80ec2d999c45ce13f3e034704249d80829f7eLennart Poettering session it closes the FIFO. Hence, with this call
e48fdd84432bbf9c2ecc339183258c7c33116032Lennart Poettering explicitly turn off the FIFO logic, so that the PAM code
59512f21d77d984cf1363fb0d1770218c5e17020Kay Sievers can finish clean up on its own */
59512f21d77d984cf1363fb0d1770218c5e17020Kay Sievers session_remove_fifo(session);
59512f21d77d984cf1363fb0d1770218c5e17020Kay Sievers session_save(session);
59512f21d77d984cf1363fb0d1770218c5e17020Kay Sievers user_save(session->user);
59512f21d77d984cf1363fb0d1770218c5e17020Kay Sievers
59512f21d77d984cf1363fb0d1770218c5e17020Kay Sievers return sd_bus_reply_method_return(message, NULL);
59512f21d77d984cf1363fb0d1770218c5e17020Kay Sievers}
59512f21d77d984cf1363fb0d1770218c5e17020Kay Sievers
2fc09a9cdd1ad25bc7c53a23d5301eb952e1ce3dDaniel Mackstatic int method_activate_session(sd_bus *bus, sd_bus_message *message, void *userdata, sd_bus_error *error) {
2fc09a9cdd1ad25bc7c53a23d5301eb952e1ce3dDaniel Mack Manager *m = userdata;
59512f21d77d984cf1363fb0d1770218c5e17020Kay Sievers Session *session;
59512f21d77d984cf1363fb0d1770218c5e17020Kay Sievers const char *name;
73b80ec2d999c45ce13f3e034704249d80829f7eLennart Poettering int r;
0238d4c660e732dd03ba0cdb54a29ec5870ee849Kay Sievers
0238d4c660e732dd03ba0cdb54a29ec5870ee849Kay Sievers assert(bus);
0238d4c660e732dd03ba0cdb54a29ec5870ee849Kay Sievers assert(message);
0238d4c660e732dd03ba0cdb54a29ec5870ee849Kay Sievers assert(m);
0238d4c660e732dd03ba0cdb54a29ec5870ee849Kay Sievers
e48fdd84432bbf9c2ecc339183258c7c33116032Lennart Poettering r = sd_bus_message_read(message, "s", &name);
e48fdd84432bbf9c2ecc339183258c7c33116032Lennart Poettering if (r < 0)
e48fdd84432bbf9c2ecc339183258c7c33116032Lennart Poettering return r;
e48fdd84432bbf9c2ecc339183258c7c33116032Lennart Poettering
e48fdd84432bbf9c2ecc339183258c7c33116032Lennart Poettering session = hashmap_get(m->sessions, name);
e48fdd84432bbf9c2ecc339183258c7c33116032Lennart Poettering if (!session)
cca1dfddd4ce4357113663532696488427cc54e4Lennart Poettering return sd_bus_error_setf(error, BUS_ERROR_NO_SUCH_SESSION, "No session '%s' known", name);
e48fdd84432bbf9c2ecc339183258c7c33116032Lennart Poettering
2fc09a9cdd1ad25bc7c53a23d5301eb952e1ce3dDaniel Mack r = session_activate(session);
2fc09a9cdd1ad25bc7c53a23d5301eb952e1ce3dDaniel Mack if (r < 0)
e48fdd84432bbf9c2ecc339183258c7c33116032Lennart Poettering return r;
e48fdd84432bbf9c2ecc339183258c7c33116032Lennart Poettering
e48fdd84432bbf9c2ecc339183258c7c33116032Lennart Poettering return sd_bus_reply_method_return(message, NULL);
0238d4c660e732dd03ba0cdb54a29ec5870ee849Kay Sievers}
0238d4c660e732dd03ba0cdb54a29ec5870ee849Kay Sievers
0238d4c660e732dd03ba0cdb54a29ec5870ee849Kay Sieversstatic int method_activate_session_on_seat(sd_bus *bus, sd_bus_message *message, void *userdata, sd_bus_error *error) {
0238d4c660e732dd03ba0cdb54a29ec5870ee849Kay Sievers const char *session_name, *seat_name;
0238d4c660e732dd03ba0cdb54a29ec5870ee849Kay Sievers Manager *m = userdata;
e48fdd84432bbf9c2ecc339183258c7c33116032Lennart Poettering Session *session;
e48fdd84432bbf9c2ecc339183258c7c33116032Lennart Poettering Seat *seat;
e48fdd84432bbf9c2ecc339183258c7c33116032Lennart Poettering int r;
e48fdd84432bbf9c2ecc339183258c7c33116032Lennart Poettering
e48fdd84432bbf9c2ecc339183258c7c33116032Lennart Poettering assert(bus);
e48fdd84432bbf9c2ecc339183258c7c33116032Lennart Poettering assert(message);
cca1dfddd4ce4357113663532696488427cc54e4Lennart Poettering assert(m);
e48fdd84432bbf9c2ecc339183258c7c33116032Lennart Poettering
2fc09a9cdd1ad25bc7c53a23d5301eb952e1ce3dDaniel Mack /* Same as ActivateSession() but refuses to work if
2fc09a9cdd1ad25bc7c53a23d5301eb952e1ce3dDaniel Mack * the seat doesn't match */
e48fdd84432bbf9c2ecc339183258c7c33116032Lennart Poettering
1a14a53cfded6e78c6e8dfb73fdff0039971d642Lennart Poettering r = sd_bus_message_read(message, "ss", &session_name, &seat_name);
1a14a53cfded6e78c6e8dfb73fdff0039971d642Lennart Poettering if (r < 0)
1a14a53cfded6e78c6e8dfb73fdff0039971d642Lennart Poettering return r;
59512f21d77d984cf1363fb0d1770218c5e17020Kay Sievers
59512f21d77d984cf1363fb0d1770218c5e17020Kay Sievers session = hashmap_get(m->sessions, session_name);
59512f21d77d984cf1363fb0d1770218c5e17020Kay Sievers if (!session)
59512f21d77d984cf1363fb0d1770218c5e17020Kay Sievers return sd_bus_error_setf(error, BUS_ERROR_NO_SUCH_SESSION, "No session '%s' known", session_name);
59512f21d77d984cf1363fb0d1770218c5e17020Kay Sievers
59512f21d77d984cf1363fb0d1770218c5e17020Kay Sievers seat = hashmap_get(m->seats, seat_name);
61331eab0a53cd9b8446eab6d1ebf1a046d8efc1Lennart Poettering if (!seat)
cca1dfddd4ce4357113663532696488427cc54e4Lennart Poettering return sd_bus_error_setf(error, BUS_ERROR_NO_SUCH_SEAT, "No seat '%s' known", seat_name);
73b80ec2d999c45ce13f3e034704249d80829f7eLennart Poettering
73b80ec2d999c45ce13f3e034704249d80829f7eLennart Poettering if (session->seat != seat)
73b80ec2d999c45ce13f3e034704249d80829f7eLennart Poettering return sd_bus_error_setf(error, BUS_ERROR_SESSION_NOT_ON_SEAT, "Session %s not on seat %s", session_name, seat_name);
e48fdd84432bbf9c2ecc339183258c7c33116032Lennart Poettering
61331eab0a53cd9b8446eab6d1ebf1a046d8efc1Lennart Poettering r = session_activate(session);
cca1dfddd4ce4357113663532696488427cc54e4Lennart Poettering if (r < 0)
73b80ec2d999c45ce13f3e034704249d80829f7eLennart Poettering return r;
73b80ec2d999c45ce13f3e034704249d80829f7eLennart Poettering
73b80ec2d999c45ce13f3e034704249d80829f7eLennart Poettering return sd_bus_reply_method_return(message, NULL);
1a14a53cfded6e78c6e8dfb73fdff0039971d642Lennart Poettering}
1a14a53cfded6e78c6e8dfb73fdff0039971d642Lennart Poettering
1a14a53cfded6e78c6e8dfb73fdff0039971d642Lennart Poetteringstatic int method_lock_session(sd_bus *bus, sd_bus_message *message, void *userdata, sd_bus_error *error) {
1a14a53cfded6e78c6e8dfb73fdff0039971d642Lennart Poettering Manager *m = userdata;
1a14a53cfded6e78c6e8dfb73fdff0039971d642Lennart Poettering Session *session;
1a14a53cfded6e78c6e8dfb73fdff0039971d642Lennart Poettering const char *name;
1a14a53cfded6e78c6e8dfb73fdff0039971d642Lennart Poettering int r;
1a14a53cfded6e78c6e8dfb73fdff0039971d642Lennart Poettering
1a14a53cfded6e78c6e8dfb73fdff0039971d642Lennart Poettering assert(bus);
1a14a53cfded6e78c6e8dfb73fdff0039971d642Lennart Poettering assert(message);
1a14a53cfded6e78c6e8dfb73fdff0039971d642Lennart Poettering assert(m);
e48fdd84432bbf9c2ecc339183258c7c33116032Lennart Poettering
1a14a53cfded6e78c6e8dfb73fdff0039971d642Lennart Poettering r = sd_bus_message_read(message, "s", &name);
1a14a53cfded6e78c6e8dfb73fdff0039971d642Lennart Poettering if (r < 0)
1a14a53cfded6e78c6e8dfb73fdff0039971d642Lennart Poettering return r;
1a14a53cfded6e78c6e8dfb73fdff0039971d642Lennart Poettering
1a14a53cfded6e78c6e8dfb73fdff0039971d642Lennart Poettering session = hashmap_get(m->sessions, name);
1a14a53cfded6e78c6e8dfb73fdff0039971d642Lennart Poettering if (!session)
1a14a53cfded6e78c6e8dfb73fdff0039971d642Lennart Poettering return sd_bus_error_setf(error, BUS_ERROR_NO_SUCH_SESSION, "No session '%s' known", name);
e48fdd84432bbf9c2ecc339183258c7c33116032Lennart Poettering
1a14a53cfded6e78c6e8dfb73fdff0039971d642Lennart Poettering r = session_send_lock(session, streq(sd_bus_message_get_member(message), "LockSession"));
1a14a53cfded6e78c6e8dfb73fdff0039971d642Lennart Poettering if (r < 0)
c51cf05646a11c65daf65c1123c77efb068f4f7bZbigniew Jędrzejewski-Szmek return r;
f9ac15442e4132f00eca5495d53c17062aae13e0Lennart Poettering
1a14a53cfded6e78c6e8dfb73fdff0039971d642Lennart Poettering return sd_bus_reply_method_return(message, NULL);
1a14a53cfded6e78c6e8dfb73fdff0039971d642Lennart Poettering}
1a14a53cfded6e78c6e8dfb73fdff0039971d642Lennart Poettering
1a14a53cfded6e78c6e8dfb73fdff0039971d642Lennart Poetteringstatic int method_lock_sessions(sd_bus *bus, sd_bus_message *message, void *userdata, sd_bus_error *error) {
73b80ec2d999c45ce13f3e034704249d80829f7eLennart Poettering Manager *m = userdata;
73b80ec2d999c45ce13f3e034704249d80829f7eLennart Poettering int r;
1a14a53cfded6e78c6e8dfb73fdff0039971d642Lennart Poettering
73b80ec2d999c45ce13f3e034704249d80829f7eLennart Poettering assert(bus);
1a14a53cfded6e78c6e8dfb73fdff0039971d642Lennart Poettering assert(message);
73b80ec2d999c45ce13f3e034704249d80829f7eLennart Poettering assert(m);
1a14a53cfded6e78c6e8dfb73fdff0039971d642Lennart Poettering
73b80ec2d999c45ce13f3e034704249d80829f7eLennart Poettering r = session_send_lock_all(m, streq(sd_bus_message_get_member(message), "LockSessions"));
73b80ec2d999c45ce13f3e034704249d80829f7eLennart Poettering if (r < 0)
d2a623823f8d83c97c35fcd28f90e8cd59066f8aZbigniew Jędrzejewski-Szmek return r;
8086ffacdb1bfec5ec115d24626538bda6cc372eZbigniew Jędrzejewski-Szmek
8086ffacdb1bfec5ec115d24626538bda6cc372eZbigniew Jędrzejewski-Szmek return sd_bus_reply_method_return(message, NULL);
1a14a53cfded6e78c6e8dfb73fdff0039971d642Lennart Poettering}
73b80ec2d999c45ce13f3e034704249d80829f7eLennart Poettering
73b80ec2d999c45ce13f3e034704249d80829f7eLennart Poetteringstatic int method_kill_session(sd_bus *bus, sd_bus_message *message, void *userdata, sd_bus_error *error) {
73b80ec2d999c45ce13f3e034704249d80829f7eLennart Poettering const char *name, *swho;
73b80ec2d999c45ce13f3e034704249d80829f7eLennart Poettering Manager *m = userdata;
73b80ec2d999c45ce13f3e034704249d80829f7eLennart Poettering Session *session;
73b80ec2d999c45ce13f3e034704249d80829f7eLennart Poettering int32_t signo;
73b80ec2d999c45ce13f3e034704249d80829f7eLennart Poettering KillWho who;
73b80ec2d999c45ce13f3e034704249d80829f7eLennart Poettering int r;
73b80ec2d999c45ce13f3e034704249d80829f7eLennart Poettering
73b80ec2d999c45ce13f3e034704249d80829f7eLennart Poettering assert(bus);
73b80ec2d999c45ce13f3e034704249d80829f7eLennart Poettering assert(message);
73b80ec2d999c45ce13f3e034704249d80829f7eLennart Poettering assert(m);
73b80ec2d999c45ce13f3e034704249d80829f7eLennart Poettering
73b80ec2d999c45ce13f3e034704249d80829f7eLennart Poettering r = sd_bus_message_read(message, "ssi", &name, &swho, &signo);
73b80ec2d999c45ce13f3e034704249d80829f7eLennart Poettering if (r < 0)
73b80ec2d999c45ce13f3e034704249d80829f7eLennart Poettering return r;
73b80ec2d999c45ce13f3e034704249d80829f7eLennart Poettering
73b80ec2d999c45ce13f3e034704249d80829f7eLennart Poettering if (isempty(swho))
73b80ec2d999c45ce13f3e034704249d80829f7eLennart Poettering who = KILL_ALL;
73b80ec2d999c45ce13f3e034704249d80829f7eLennart Poettering else {
73b80ec2d999c45ce13f3e034704249d80829f7eLennart Poettering who = kill_who_from_string(swho);
73b80ec2d999c45ce13f3e034704249d80829f7eLennart Poettering if (who < 0)
73b80ec2d999c45ce13f3e034704249d80829f7eLennart Poettering return sd_bus_error_setf(error, SD_BUS_ERROR_INVALID_ARGS, "Invalid kill parameter '%s'", swho);
9a5cb1371b6d8b0a04bd08665bcf9b06cb40c64cZbigniew Jędrzejewski-Szmek }
9a5cb1371b6d8b0a04bd08665bcf9b06cb40c64cZbigniew Jędrzejewski-Szmek
73b80ec2d999c45ce13f3e034704249d80829f7eLennart Poettering if (signo <= 0 || signo >= _NSIG)
73b80ec2d999c45ce13f3e034704249d80829f7eLennart Poettering return sd_bus_error_setf(error, SD_BUS_ERROR_INVALID_ARGS, "Invalid signal %i", signo);
73b80ec2d999c45ce13f3e034704249d80829f7eLennart Poettering
73b80ec2d999c45ce13f3e034704249d80829f7eLennart Poettering session = hashmap_get(m->sessions, name);
23bbb0de4e3f85d9704a5c12a5afa2dfa0159e41Michal Schmidt if (!session)
23bbb0de4e3f85d9704a5c12a5afa2dfa0159e41Michal Schmidt return sd_bus_error_setf(error, BUS_ERROR_NO_SUCH_SESSION, "No session '%s' known", name);
1a14a53cfded6e78c6e8dfb73fdff0039971d642Lennart Poettering
73b80ec2d999c45ce13f3e034704249d80829f7eLennart Poettering r = session_kill(session, who, signo);
73b80ec2d999c45ce13f3e034704249d80829f7eLennart Poettering if (r < 0)
73b80ec2d999c45ce13f3e034704249d80829f7eLennart Poettering return r;
73b80ec2d999c45ce13f3e034704249d80829f7eLennart Poettering
73b80ec2d999c45ce13f3e034704249d80829f7eLennart Poettering return sd_bus_reply_method_return(message, NULL);
73b80ec2d999c45ce13f3e034704249d80829f7eLennart Poettering}
98b2f766b24c84fc49a4df954717b1f96bbce00dLennart Poettering
73b80ec2d999c45ce13f3e034704249d80829f7eLennart Poetteringstatic int method_kill_user(sd_bus *bus, sd_bus_message *message, void *userdata, sd_bus_error *error) {
73b80ec2d999c45ce13f3e034704249d80829f7eLennart Poettering Manager *m = userdata;
cca1dfddd4ce4357113663532696488427cc54e4Lennart Poettering uint32_t uid;
59512f21d77d984cf1363fb0d1770218c5e17020Kay Sievers int32_t signo;
73b80ec2d999c45ce13f3e034704249d80829f7eLennart Poettering User *user;
73b80ec2d999c45ce13f3e034704249d80829f7eLennart Poettering int r;
73b80ec2d999c45ce13f3e034704249d80829f7eLennart Poettering
73b80ec2d999c45ce13f3e034704249d80829f7eLennart Poettering assert(bus);
73b80ec2d999c45ce13f3e034704249d80829f7eLennart Poettering assert(message);
73b80ec2d999c45ce13f3e034704249d80829f7eLennart Poettering assert(m);
73b80ec2d999c45ce13f3e034704249d80829f7eLennart Poettering
73b80ec2d999c45ce13f3e034704249d80829f7eLennart Poettering r = sd_bus_message_read(message, "ui", &uid, &signo);
73b80ec2d999c45ce13f3e034704249d80829f7eLennart Poettering if (r < 0)
73b80ec2d999c45ce13f3e034704249d80829f7eLennart Poettering return r;
73b80ec2d999c45ce13f3e034704249d80829f7eLennart Poettering
3db604b907323b8df0fc810216f6112056d26a02Lennart Poettering if (signo <= 0 || signo >= _NSIG)
23bbb0de4e3f85d9704a5c12a5afa2dfa0159e41Michal Schmidt return sd_bus_error_setf(error, SD_BUS_ERROR_INVALID_ARGS, "Invalid signal %i", signo);
23bbb0de4e3f85d9704a5c12a5afa2dfa0159e41Michal Schmidt
23bbb0de4e3f85d9704a5c12a5afa2dfa0159e41Michal Schmidt user = hashmap_get(m->users, ULONG_TO_PTR((unsigned long) uid));
eafe88e34a0698d2f4ebb747ab4911e35d0dfe4cTobias Hunger if (!user)
eafe88e34a0698d2f4ebb747ab4911e35d0dfe4cTobias Hunger return sd_bus_error_setf(error, BUS_ERROR_NO_SUCH_USER, "No user '%lu' known or logged in", (unsigned long) uid);
eafe88e34a0698d2f4ebb747ab4911e35d0dfe4cTobias Hunger
eafe88e34a0698d2f4ebb747ab4911e35d0dfe4cTobias Hunger r = user_kill(user, signo);
eafe88e34a0698d2f4ebb747ab4911e35d0dfe4cTobias Hunger if (r < 0)
eafe88e34a0698d2f4ebb747ab4911e35d0dfe4cTobias Hunger return r;
eafe88e34a0698d2f4ebb747ab4911e35d0dfe4cTobias Hunger
3db604b907323b8df0fc810216f6112056d26a02Lennart Poettering return sd_bus_reply_method_return(message, NULL);
3db604b907323b8df0fc810216f6112056d26a02Lennart Poettering}
61331eab0a53cd9b8446eab6d1ebf1a046d8efc1Lennart Poettering
73b80ec2d999c45ce13f3e034704249d80829f7eLennart Poetteringstatic int method_terminate_session(sd_bus *bus, sd_bus_message *message, void *userdata, sd_bus_error *error) {
73b80ec2d999c45ce13f3e034704249d80829f7eLennart Poettering Manager *m = userdata;
73b80ec2d999c45ce13f3e034704249d80829f7eLennart Poettering const char *name;
73b80ec2d999c45ce13f3e034704249d80829f7eLennart Poettering Session *session;
73b80ec2d999c45ce13f3e034704249d80829f7eLennart Poettering int r;
73b80ec2d999c45ce13f3e034704249d80829f7eLennart Poettering
73b80ec2d999c45ce13f3e034704249d80829f7eLennart Poettering assert(bus);
73b80ec2d999c45ce13f3e034704249d80829f7eLennart Poettering assert(message);
73b80ec2d999c45ce13f3e034704249d80829f7eLennart Poettering assert(m);
73b80ec2d999c45ce13f3e034704249d80829f7eLennart Poettering
73b80ec2d999c45ce13f3e034704249d80829f7eLennart Poettering r = sd_bus_message_read(message, "s", &name);
73b80ec2d999c45ce13f3e034704249d80829f7eLennart Poettering if (r < 0)
73b80ec2d999c45ce13f3e034704249d80829f7eLennart Poettering return r;
73b80ec2d999c45ce13f3e034704249d80829f7eLennart Poettering
73b80ec2d999c45ce13f3e034704249d80829f7eLennart Poettering session = hashmap_get(m->sessions, name);
73b80ec2d999c45ce13f3e034704249d80829f7eLennart Poettering if (!session)
73b80ec2d999c45ce13f3e034704249d80829f7eLennart Poettering return sd_bus_error_setf(error, BUS_ERROR_NO_SUCH_SESSION, "No session '%s' known", name);
73b80ec2d999c45ce13f3e034704249d80829f7eLennart Poettering
73b80ec2d999c45ce13f3e034704249d80829f7eLennart Poettering r = session_stop(session);
73b80ec2d999c45ce13f3e034704249d80829f7eLennart Poettering if (r < 0)
73b80ec2d999c45ce13f3e034704249d80829f7eLennart Poettering return r;
e48fdd84432bbf9c2ecc339183258c7c33116032Lennart Poettering
1a14a53cfded6e78c6e8dfb73fdff0039971d642Lennart Poettering return sd_bus_reply_method_return(message, NULL);
3db604b907323b8df0fc810216f6112056d26a02Lennart Poettering}
b5884878a2874447b2a9f07f324a7cd909d96d48Lennart Poettering
b5884878a2874447b2a9f07f324a7cd909d96d48Lennart Poetteringstatic int method_terminate_user(sd_bus *bus, sd_bus_message *message, void *userdata, sd_bus_error *error) {
da927ba997d68401563b927f92e6e40e021a8e5cMichal Schmidt Manager *m = userdata;
1a14a53cfded6e78c6e8dfb73fdff0039971d642Lennart Poettering uint32_t uid;
73b80ec2d999c45ce13f3e034704249d80829f7eLennart Poettering User *user;
73b80ec2d999c45ce13f3e034704249d80829f7eLennart Poettering int r;
73b80ec2d999c45ce13f3e034704249d80829f7eLennart Poettering
73b80ec2d999c45ce13f3e034704249d80829f7eLennart Poettering assert(bus);
73b80ec2d999c45ce13f3e034704249d80829f7eLennart Poettering assert(message);
73b80ec2d999c45ce13f3e034704249d80829f7eLennart Poettering assert(m);
73b80ec2d999c45ce13f3e034704249d80829f7eLennart Poettering
73b80ec2d999c45ce13f3e034704249d80829f7eLennart Poettering r = sd_bus_message_read(message, "u", &uid);
73b80ec2d999c45ce13f3e034704249d80829f7eLennart Poettering if (r < 0)
73b80ec2d999c45ce13f3e034704249d80829f7eLennart Poettering return r;
73b80ec2d999c45ce13f3e034704249d80829f7eLennart Poettering
73b80ec2d999c45ce13f3e034704249d80829f7eLennart Poettering user = hashmap_get(m->users, ULONG_TO_PTR((unsigned long) uid));
73b80ec2d999c45ce13f3e034704249d80829f7eLennart Poettering if (!user)
73b80ec2d999c45ce13f3e034704249d80829f7eLennart Poettering return sd_bus_error_setf(error, BUS_ERROR_NO_SUCH_USER, "No user '%lu' known or logged in", (unsigned long) uid);
73b80ec2d999c45ce13f3e034704249d80829f7eLennart Poettering
73b80ec2d999c45ce13f3e034704249d80829f7eLennart Poettering r = user_stop(user);
73b80ec2d999c45ce13f3e034704249d80829f7eLennart Poettering if (r < 0)
1a14a53cfded6e78c6e8dfb73fdff0039971d642Lennart Poettering return r;
return sd_bus_reply_method_return(message, NULL);
}
static int method_terminate_seat(sd_bus *bus, sd_bus_message *message, void *userdata, sd_bus_error *error) {
Manager *m = userdata;
const char *name;
Seat *seat;
int r;
assert(bus);
assert(message);
assert(m);
r = sd_bus_message_read(message, "s", &name);
if (r < 0)
return r;
seat = hashmap_get(m->seats, name);
if (!seat)
return sd_bus_error_setf(error, BUS_ERROR_NO_SUCH_SEAT, "No seat '%s' known", name);
r = seat_stop_sessions(seat);
if (r < 0)
return r;
return sd_bus_reply_method_return(message, NULL);
}
static int method_set_user_linger(sd_bus *bus, sd_bus_message *message, void *userdata, sd_bus_error *error) {
_cleanup_free_ char *cc = NULL;
Manager *m = userdata;
int b, r;
struct passwd *pw;
const char *path;
uint32_t uid;
int interactive;
assert(bus);
assert(message);
assert(m);
r = sd_bus_message_read(message, "ubb", &uid, &b, &interactive);
if (r < 0)
return r;
errno = 0;
pw = getpwuid(uid);
if (!pw)
return errno ? -errno : -ENOENT;
r = bus_verify_polkit_async(bus,
&m->polkit_registry,
message,
"org.freedesktop.login1.set-user-linger",
interactive,
error,
method_set_user_linger, m);
if (r < 0)
return r;
if (r == 0)
return 1; /* No authorization for now, but the async polkit stuff will call us again when it has it */
mkdir_p_label("/var/lib/systemd", 0755);
r = mkdir_safe_label("/var/lib/systemd/linger", 0755, 0, 0);
if (r < 0)
return r;
cc = cescape(pw->pw_name);
if (!cc)
return -ENOMEM;
path = strappenda("/var/lib/systemd/linger/", cc);
if (b) {
User *u;
r = touch(path);
if (r < 0)
return r;
if (manager_add_user_by_uid(m, uid, &u) >= 0)
user_start(u);
} else {
User *u;
r = unlink(path);
if (r < 0 && errno != ENOENT)
return -errno;
u = hashmap_get(m->users, ULONG_TO_PTR((unsigned long) uid));
if (u)
user_add_to_gc_queue(u);
}
return sd_bus_reply_method_return(message, NULL);
}
static int trigger_device(Manager *m, struct udev_device *d) {
struct udev_enumerate *e;
struct udev_list_entry *first, *item;
int r;
assert(m);
e = udev_enumerate_new(m->udev);
if (!e) {
r = -ENOMEM;
goto finish;
}
if (d) {
if (udev_enumerate_add_match_parent(e, d) < 0) {
r = -EIO;
goto finish;
}
}
if (udev_enumerate_scan_devices(e) < 0) {
r = -EIO;
goto finish;
}
first = udev_enumerate_get_list_entry(e);
udev_list_entry_foreach(item, first) {
_cleanup_free_ char *t = NULL;
const char *p;
p = udev_list_entry_get_name(item);
t = strappend(p, "/uevent");
if (!t) {
r = -ENOMEM;
goto finish;
}
write_string_file(t, "change");
}
r = 0;
finish:
if (e)
udev_enumerate_unref(e);
return r;
}
static int attach_device(Manager *m, const char *seat, const char *sysfs) {
_cleanup_free_ char *rule = NULL, *file = NULL;
const char *id_for_seat;
struct udev_device *d;
int r;
assert(m);
assert(seat);
assert(sysfs);
d = udev_device_new_from_syspath(m->udev, sysfs);
if (!d)
return -ENODEV;
if (!udev_device_has_tag(d, "seat")) {
r = -ENODEV;
goto finish;
}
id_for_seat = udev_device_get_property_value(d, "ID_FOR_SEAT");
if (!id_for_seat) {
r = -ENODEV;
goto finish;
}
if (asprintf(&file, "/etc/udev/rules.d/72-seat-%s.rules", id_for_seat) < 0) {
r = -ENOMEM;
goto finish;
}
if (asprintf(&rule, "TAG==\"seat\", ENV{ID_FOR_SEAT}==\"%s\", ENV{ID_SEAT}=\"%s\"", id_for_seat, seat) < 0) {
r = -ENOMEM;
goto finish;
}
mkdir_p_label("/etc/udev/rules.d", 0755);
label_init("/etc");
r = write_string_file_atomic_label(file, rule);
if (r < 0)
goto finish;
r = trigger_device(m, d);
finish:
if (d)
udev_device_unref(d);
return r;
}
static int flush_devices(Manager *m) {
_cleanup_closedir_ DIR *d;
assert(m);
d = opendir("/etc/udev/rules.d");
if (!d) {
if (errno != ENOENT)
log_warning("Failed to open /etc/udev/rules.d: %m");
} else {
struct dirent *de;
while ((de = readdir(d))) {
if (!dirent_is_file(de))
continue;
if (!startswith(de->d_name, "72-seat-"))
continue;
if (!endswith(de->d_name, ".rules"))
continue;
if (unlinkat(dirfd(d), de->d_name, 0) < 0)
log_warning("Failed to unlink %s: %m", de->d_name);
}
}
return trigger_device(m, NULL);
}
static int method_attach_device(sd_bus *bus, sd_bus_message *message, void *userdata, sd_bus_error *error) {
const char *sysfs, *seat;
Manager *m = userdata;
int interactive, r;
assert(bus);
assert(message);
assert(m);
r = sd_bus_message_read(message, "ssb", &seat, &sysfs, &interactive);
if (r < 0)
return r;
if (!path_startswith(sysfs, "/sys"))
return sd_bus_error_setf(error, SD_BUS_ERROR_INVALID_ARGS, "Path %s is not in /sys", sysfs);
if (!seat_name_is_valid(seat))
return sd_bus_error_setf(error, SD_BUS_ERROR_INVALID_ARGS, "Seat %s is not valid", seat);
r = bus_verify_polkit_async(bus,
&m->polkit_registry,
message,
"org.freedesktop.login1.attach-device",
interactive,
error,
method_attach_device, m);
if (r < 0)
return r;
if (r == 0)
return 1; /* No authorization for now, but the async polkit stuff will call us again when it has it */
r = attach_device(m, seat, sysfs);
if (r < 0)
return r;
return sd_bus_reply_method_return(message, NULL);
}
static int method_flush_devices(sd_bus *bus, sd_bus_message *message, void *userdata, sd_bus_error *error) {
Manager *m = userdata;
int interactive, r;
assert(bus);
assert(message);
assert(m);
r = sd_bus_message_read(message, "b", &interactive);
if (r < 0)
return r;
r = bus_verify_polkit_async(bus,
&m->polkit_registry,
message,
"org.freedesktop.login1.flush-devices",
interactive,
error,
method_flush_devices, m);
if (r < 0)
return r;
if (r == 0)
return 1; /* No authorization for now, but the async polkit stuff will call us again when it has it */
r = flush_devices(m);
if (r < 0)
return r;
return sd_bus_reply_method_return(message, NULL);
}
static int have_multiple_sessions(
Manager *m,
uid_t uid) {
Session *session;
Iterator i;
assert(m);
/* Check for other users' sessions. Greeter sessions do not
* count, and non-login sessions do not count either. */
HASHMAP_FOREACH(session, m->sessions, i)
if (session->class == SESSION_USER &&
session->user->uid != uid)
return true;
return false;
}
static int bus_manager_log_shutdown(
Manager *m,
InhibitWhat w,
const char *unit_name) {
const char *p, *q;
assert(m);
assert(unit_name);
if (w != INHIBIT_SHUTDOWN)
return 0;
if (streq(unit_name, SPECIAL_POWEROFF_TARGET)) {
p = "MESSAGE=System is powering down.";
q = "SHUTDOWN=power-off";
} else if (streq(unit_name, SPECIAL_HALT_TARGET)) {
p = "MESSAGE=System is halting.";
q = "SHUTDOWN=halt";
} else if (streq(unit_name, SPECIAL_REBOOT_TARGET)) {
p = "MESSAGE=System is rebooting.";
q = "SHUTDOWN=reboot";
} else if (streq(unit_name, SPECIAL_KEXEC_TARGET)) {
p = "MESSAGE=System is rebooting with kexec.";
q = "SHUTDOWN=kexec";
} else {
p = "MESSAGE=System is shutting down.";
q = NULL;
}
return log_struct(LOG_NOTICE, MESSAGE_ID(SD_MESSAGE_SHUTDOWN),
p,
q, NULL);
}
static int execute_shutdown_or_sleep(
Manager *m,
InhibitWhat w,
const char *unit_name,
sd_bus_error *error) {
_cleanup_bus_message_unref_ sd_bus_message *reply = NULL;
const char *p;
char *c;
int r;
assert(m);
assert(w >= 0);
assert(w < _INHIBIT_WHAT_MAX);
assert(unit_name);
bus_manager_log_shutdown(m, w, unit_name);
r = sd_bus_call_method(
m->bus,
"org.freedesktop.systemd1",
"/org/freedesktop/systemd1",
"org.freedesktop.systemd1.Manager",
"StartUnit",
error,
&reply,
"ss", unit_name, "replace-irreversibly");
if (r < 0)
return r;
r = sd_bus_message_read(reply, "o", &p);
if (r < 0)
return r;
c = strdup(p);
if (!c)
return -ENOMEM;
m->action_unit = unit_name;
free(m->action_job);
m->action_job = c;
m->action_what = w;
return 0;
}
static int delay_shutdown_or_sleep(
Manager *m,
InhibitWhat w,
const char *unit_name) {
assert(m);
assert(w >= 0);
assert(w < _INHIBIT_WHAT_MAX);
assert(unit_name);
m->action_timestamp = now(CLOCK_MONOTONIC);
m->action_unit = unit_name;
m->action_what = w;
return 0;
}
static int send_prepare_for(Manager *m, InhibitWhat w, bool _active) {
static const char * const signal_name[_INHIBIT_WHAT_MAX] = {
[INHIBIT_SHUTDOWN] = "PrepareForShutdown",
[INHIBIT_SLEEP] = "PrepareForSleep"
};
int active = _active;
assert(m);
assert(w >= 0);
assert(w < _INHIBIT_WHAT_MAX);
assert(signal_name[w]);
return sd_bus_emit_signal(m->bus,
"/org/freedesktop/login1",
"org.freedesktop.login1.Manager",
signal_name[w],
"b",
active);
}
int bus_manager_shutdown_or_sleep_now_or_later(
Manager *m,
const char *unit_name,
InhibitWhat w,
sd_bus_error *error) {
bool delayed;
int r;
assert(m);
assert(unit_name);
assert(w >= 0);
assert(w <= _INHIBIT_WHAT_MAX);
assert(!m->action_job);
/* Tell everybody to prepare for shutdown/sleep */
send_prepare_for(m, w, true);
delayed =
m->inhibit_delay_max > 0 &&
manager_is_inhibited(m, w, INHIBIT_DELAY, NULL, false, false, 0, NULL);
if (delayed)
/* Shutdown is delayed, keep in mind what we
* want to do, and start a timeout */
r = delay_shutdown_or_sleep(m, w, unit_name);
else
/* Shutdown is not delayed, execute it
* immediately */
r = execute_shutdown_or_sleep(m, w, unit_name, error);
return r;
}
static int method_do_shutdown_or_sleep(
Manager *m,
sd_bus_message *message,
const char *unit_name,
InhibitWhat w,
const char *action,
const char *action_multiple_sessions,
const char *action_ignore_inhibit,
const char *sleep_verb,
sd_bus_message_handler_t method,
sd_bus_error *error) {
bool multiple_sessions, blocked;
int interactive, r;
uid_t uid;
assert(m);
assert(message);
assert(unit_name);
assert(w >= 0);
assert(w <= _INHIBIT_WHAT_MAX);
assert(action);
assert(action_multiple_sessions);
assert(action_ignore_inhibit);
assert(method);
r = sd_bus_message_read(message, "b", &interactive);
if (r < 0)
return r;
/* Don't allow multiple jobs being executed at the same time */
if (m->action_what)
return sd_bus_error_setf(error, BUS_ERROR_OPERATION_IN_PROGRESS, "There's already a shutdown or sleep operation in progress");
if (sleep_verb) {
r = can_sleep(sleep_verb);
if (r < 0)
return r;
if (r == 0)
return sd_bus_error_setf(error, BUS_ERROR_SLEEP_VERB_NOT_SUPPORTED, "Sleep verb not supported");
}
r = sd_bus_get_owner_uid(m->bus, sd_bus_message_get_sender(message), &uid);
if (r < 0)
return r;
r = have_multiple_sessions(m, uid);
if (r < 0)
return r;
multiple_sessions = r > 0;
blocked = manager_is_inhibited(m, w, INHIBIT_BLOCK, NULL, false, true, uid, NULL);
if (multiple_sessions) {
r = bus_verify_polkit_async(m->bus, &m->polkit_registry, message,
action_multiple_sessions, interactive, error, method, m);
if (r < 0)
return r;
}
if (blocked) {
r = bus_verify_polkit_async(m->bus, &m->polkit_registry, message,
action_ignore_inhibit, interactive, error, method, m);
if (r < 0)
return r;
}
if (!multiple_sessions && !blocked) {
r = bus_verify_polkit_async(m->bus, &m->polkit_registry, message,
action, interactive, error, method, m);
if (r < 0)
return r;
}
r = bus_manager_shutdown_or_sleep_now_or_later(m, unit_name, w, error);
if (r < 0)
return r;
return sd_bus_reply_method_return(message, NULL);
}
static int method_poweroff(sd_bus *bus, sd_bus_message *message, void *userdata, sd_bus_error *error) {
Manager *m = userdata;
return method_do_shutdown_or_sleep(
m, message,
SPECIAL_POWEROFF_TARGET,
INHIBIT_SHUTDOWN,
"org.freedesktop.login1.power-off",
"org.freedesktop.login1.power-off-multiple-sessions",
"org.freedesktop.login1.power-off-ignore-inhibit",
NULL,
method_poweroff,
error);
}
static int method_reboot(sd_bus *bus, sd_bus_message *message, void *userdata, sd_bus_error *error) {
Manager *m = userdata;
return method_do_shutdown_or_sleep(
m, message,
SPECIAL_REBOOT_TARGET,
INHIBIT_SHUTDOWN,
"org.freedesktop.login1.reboot",
"org.freedesktop.login1.reboot-multiple-sessions",
"org.freedesktop.login1.reboot-ignore-inhibit",
NULL,
method_reboot,
error);
}
static int method_suspend(sd_bus *bus, sd_bus_message *message, void *userdata, sd_bus_error *error) {
Manager *m = userdata;
return method_do_shutdown_or_sleep(
m, message,
SPECIAL_SUSPEND_TARGET,
INHIBIT_SLEEP,
"org.freedesktop.login1.suspend",
"org.freedesktop.login1.suspend-multiple-sessions",
"org.freedesktop.login1.suspend-ignore-inhibit",
"suspend",
method_suspend,
error);
}
static int method_hibernate(sd_bus *bus, sd_bus_message *message, void *userdata, sd_bus_error *error) {
Manager *m = userdata;
return method_do_shutdown_or_sleep(
m, message,
SPECIAL_HIBERNATE_TARGET,
INHIBIT_SLEEP,
"org.freedesktop.login1.hibernate",
"org.freedesktop.login1.hibernate-multiple-sessions",
"org.freedesktop.login1.hibernate-ignore-inhibit",
"hibernate",
method_hibernate,
error);
}
static int method_hybrid_sleep(sd_bus *bus, sd_bus_message *message, void *userdata, sd_bus_error *error) {
Manager *m = userdata;
return method_do_shutdown_or_sleep(
m, message,
SPECIAL_HYBRID_SLEEP_TARGET,
INHIBIT_SLEEP,
"org.freedesktop.login1.hibernate",
"org.freedesktop.login1.hibernate-multiple-sessions",
"org.freedesktop.login1.hibernate-ignore-inhibit",
"hybrid-sleep",
method_hybrid_sleep,
error);
}
static int method_can_shutdown_or_sleep(
Manager *m,
sd_bus_message *message,
InhibitWhat w,
const char *action,
const char *action_multiple_sessions,
const char *action_ignore_inhibit,
const char *sleep_verb,
sd_bus_error *error) {
bool multiple_sessions, challenge, blocked;
const char *result = NULL;
uid_t uid;
int r;
assert(m);
assert(message);
assert(w >= 0);
assert(w <= _INHIBIT_WHAT_MAX);
assert(action);
assert(action_multiple_sessions);
assert(action_ignore_inhibit);
if (sleep_verb) {
r = can_sleep(sleep_verb);
if (r < 0)
return r;
if (r == 0)
return sd_bus_reply_method_return(message, "s", "na");
}
r = sd_bus_get_owner_uid(m->bus, sd_bus_message_get_sender(message), &uid);
if (r < 0)
return r;
r = have_multiple_sessions(m, uid);
if (r < 0)
return r;
multiple_sessions = r > 0;
blocked = manager_is_inhibited(m, w, INHIBIT_BLOCK, NULL, false, true, uid, NULL);
if (multiple_sessions) {
r = bus_verify_polkit(m->bus, message, action_multiple_sessions, false, &challenge, error);
if (r < 0)
return r;
if (r > 0)
result = "yes";
else if (challenge)
result = "challenge";
else
result = "no";
}
if (blocked) {
r = bus_verify_polkit(m->bus, message, action_ignore_inhibit, false, &challenge, error);
if (r < 0)
return r;
if (r > 0 && !result)
result = "yes";
else if (challenge && (!result || streq(result, "yes")))
result = "challenge";
else
result = "no";
}
if (!multiple_sessions && !blocked) {
/* If neither inhibit nor multiple sessions
* apply then just check the normal policy */
r = bus_verify_polkit(m->bus, message, action, false, &challenge, error);
if (r < 0)
return r;
if (r > 0)
result = "yes";
else if (challenge)
result = "challenge";
else
result = "no";
}
return sd_bus_reply_method_return(message, "s", result);
}
static int method_can_poweroff(sd_bus *bus, sd_bus_message *message, void *userdata, sd_bus_error *error) {
Manager *m = userdata;
return method_can_shutdown_or_sleep(
m, message,
INHIBIT_SHUTDOWN,
"org.freedesktop.login1.power-off",
"org.freedesktop.login1.power-off-multiple-sessions",
"org.freedesktop.login1.power-off-ignore-inhibit",
NULL,
error);
}
static int method_can_reboot(sd_bus *bus, sd_bus_message *message, void *userdata, sd_bus_error *error) {
Manager *m = userdata;
return method_can_shutdown_or_sleep(
m, message,
INHIBIT_SHUTDOWN,
"org.freedesktop.login1.reboot",
"org.freedesktop.login1.reboot-multiple-sessions",
"org.freedesktop.login1.reboot-ignore-inhibit",
NULL,
error);
}
static int method_can_suspend(sd_bus *bus, sd_bus_message *message, void *userdata, sd_bus_error *error) {
Manager *m = userdata;
return method_can_shutdown_or_sleep(
m, message,
INHIBIT_SLEEP,
"org.freedesktop.login1.suspend",
"org.freedesktop.login1.suspend-multiple-sessions",
"org.freedesktop.login1.suspend-ignore-inhibit",
"suspend",
error);
}
static int method_can_hibernate(sd_bus *bus, sd_bus_message *message, void *userdata, sd_bus_error *error) {
Manager *m = userdata;
return method_can_shutdown_or_sleep(
m, message,
INHIBIT_SLEEP,
"org.freedesktop.login1.hibernate",
"org.freedesktop.login1.hibernate-multiple-sessions",
"org.freedesktop.login1.hibernate-ignore-inhibit",
"hibernate",
error);
}
static int method_can_hybrid_sleep(sd_bus *bus, sd_bus_message *message, void *userdata, sd_bus_error *error) {
Manager *m = userdata;
return method_can_shutdown_or_sleep(
m, message,
INHIBIT_SLEEP,
"org.freedesktop.login1.hibernate",
"org.freedesktop.login1.hibernate-multiple-sessions",
"org.freedesktop.login1.hibernate-ignore-inhibit",
"hybrid-sleep",
error);
}
static int method_inhibit(sd_bus *bus, sd_bus_message *message, void *userdata, sd_bus_error *error) {
const char *who, *why, *what, *mode;
_cleanup_free_ char *id = NULL;
_cleanup_close_ int fifo_fd = -1;
Manager *m = userdata;
Inhibitor *i = NULL;
InhibitMode mm;
InhibitWhat w;
pid_t pid;
uid_t uid;
int r;
assert(bus);
assert(message);
assert(m);
r = sd_bus_message_read(message, "ssss", &what, &who, &why, &mode);
if (r < 0)
return r;
w = inhibit_what_from_string(what);
if (w <= 0)
return sd_bus_error_setf(error, SD_BUS_ERROR_INVALID_ARGS, "Invalid what specification %s", what);
mm = inhibit_mode_from_string(mode);
if (mm < 0)
return sd_bus_error_setf(error, SD_BUS_ERROR_INVALID_ARGS, "Invalid mode specification %s", mode);
/* Delay is only supported for shutdown/sleep */
if (mm == INHIBIT_DELAY && (w & ~(INHIBIT_SHUTDOWN|INHIBIT_SLEEP)))
return sd_bus_error_setf(error, SD_BUS_ERROR_INVALID_ARGS, "Delay inhibitors only supported for shutdown and sleep");
/* Don't allow taking delay locks while we are already
* executing the operation. We shouldn't create the impression
* that the lock was successful if the machine is about to go
* down/suspend any moment. */
if (m->action_what & w)
return sd_bus_error_setf(error, BUS_ERROR_OPERATION_IN_PROGRESS, "The operation inhibition has been requested for is already running");
r = bus_verify_polkit_async(bus, &m->polkit_registry, message,
w == INHIBIT_SHUTDOWN ? (mm == INHIBIT_BLOCK ? "org.freedesktop.login1.inhibit-block-shutdown" : "org.freedesktop.login1.inhibit-delay-shutdown") :
w == INHIBIT_SLEEP ? (mm == INHIBIT_BLOCK ? "org.freedesktop.login1.inhibit-block-sleep" : "org.freedesktop.login1.inhibit-delay-sleep") :
w == INHIBIT_IDLE ? "org.freedesktop.login1.inhibit-block-idle" :
w == INHIBIT_HANDLE_POWER_KEY ? "org.freedesktop.login1.inhibit-handle-power-key" :
w == INHIBIT_HANDLE_SUSPEND_KEY ? "org.freedesktop.login1.inhibit-handle-suspend-key" :
w == INHIBIT_HANDLE_HIBERNATE_KEY ? "org.freedesktop.login1.inhibit-handle-hibernate-key" :
"org.freedesktop.login1.inhibit-handle-lid-switch",
false, error, method_inhibit, m);
if (r < 0)
return r;
if (r == 0)
return 1; /* No authorization for now, but the async polkit stuff will call us again when it has it */
r = sd_bus_get_owner_uid(m->bus, sd_bus_message_get_sender(message), &uid);
if (r < 0)
return r;
r = sd_bus_get_owner_pid(m->bus, sd_bus_message_get_sender(message), &pid);
if (r < 0)
return r;
do {
free(id);
id = NULL;
if (asprintf(&id, "%lu", ++m->inhibit_counter) < 0)
return -ENOMEM;
} while (hashmap_get(m->inhibitors, id));
r = manager_add_inhibitor(m, id, &i);
if (r < 0)
return r;
i->what = w;
i->mode = mm;
i->pid = pid;
i->uid = uid;
i->why = strdup(why);
i->who = strdup(who);
if (!i->why || !i->who) {
r = -ENOMEM;
goto fail;
}
fifo_fd = inhibitor_create_fifo(i);
if (fifo_fd < 0) {
r = fifo_fd;
goto fail;
}
inhibitor_start(i);
return sd_bus_reply_method_return(message, "h", fifo_fd);
fail:
if (i)
inhibitor_free(i);
return r;
}
const sd_bus_vtable manager_vtable[] = {
SD_BUS_VTABLE_START(0),
SD_BUS_PROPERTY("NAutoVTs", "u", NULL, offsetof(Manager, n_autovts), 0),
SD_BUS_PROPERTY("KillOnlyUsers", "as", NULL, offsetof(Manager, kill_only_users), 0),
SD_BUS_PROPERTY("KillExcludeUsers", "as", NULL, offsetof(Manager, kill_exclude_users), 0),
SD_BUS_PROPERTY("KillUserProcesses", "b", NULL, offsetof(Manager, kill_user_processes), 0),
SD_BUS_PROPERTY("IdleHint", "b", property_get_idle_hint, 0, SD_BUS_VTABLE_PROPERTY_EMITS_CHANGE),
SD_BUS_PROPERTY("IdleSinceHint", "t", property_get_idle_since_hint, 0, SD_BUS_VTABLE_PROPERTY_EMITS_CHANGE),
SD_BUS_PROPERTY("IdleSinceHintMonotonic", "t", property_get_idle_since_hint, 0, SD_BUS_VTABLE_PROPERTY_EMITS_CHANGE),
SD_BUS_PROPERTY("BlockInhibited", "s", property_get_inhibited, 0, SD_BUS_VTABLE_PROPERTY_EMITS_CHANGE),
SD_BUS_PROPERTY("DelayInhibited", "s", property_get_inhibited, 0, SD_BUS_VTABLE_PROPERTY_EMITS_CHANGE),
SD_BUS_PROPERTY("InhibitDelayMaxUSec", "t", NULL, offsetof(Manager, inhibit_delay_max), 0),
SD_BUS_PROPERTY("HandlePowerKey", "s", property_get_handle_action, offsetof(Manager, handle_power_key), 0),
SD_BUS_PROPERTY("HandleSuspendKey", "s", property_get_handle_action, offsetof(Manager, handle_suspend_key), 0),
SD_BUS_PROPERTY("HandleHibernateKey", "s", property_get_handle_action, offsetof(Manager, handle_hibernate_key), 0),
SD_BUS_PROPERTY("HandleLidSwitch", "s", property_get_handle_action, offsetof(Manager, handle_lid_switch), 0),
SD_BUS_PROPERTY("IdleAction", "s", property_get_handle_action, offsetof(Manager, idle_action), 0),
SD_BUS_PROPERTY("IdleActionUSec", "t", NULL, offsetof(Manager, idle_action_usec), 0),
SD_BUS_PROPERTY("PreparingForShutdown", "b", property_get_preparing, 0, 0),
SD_BUS_PROPERTY("PreparingForSleep", "b", property_get_preparing, 0, 0),
SD_BUS_METHOD("GetSession", "s", "o", method_get_session, 0),
SD_BUS_METHOD("GetSessionByPID", "u", "o", method_get_session_by_pid, 0),
SD_BUS_METHOD("GetUser", "u", "o", method_get_user, 0),
SD_BUS_METHOD("GetUserByPID", "u", "o", method_get_user_by_pid, 0),
SD_BUS_METHOD("GetSeat", "s", "o", method_get_seat, 0),
SD_BUS_METHOD("ListSessions", NULL, "a(susso)", method_list_sessions, 0),
SD_BUS_METHOD("ListUsers", NULL, "a(uso)", method_list_users, 0),
SD_BUS_METHOD("ListSeats", NULL, "a(so)", method_list_seats, 0),
SD_BUS_METHOD("ListInhibitors", NULL, "a(ssssuu)", method_list_inhibitors, 0),
SD_BUS_METHOD("CreateSession", "uussssussbssa(sv)", "soshusub", method_create_session, 0),
SD_BUS_METHOD("ReleaseSession", "s", NULL, method_release_session, 0),
SD_BUS_METHOD("ActivateSession", "s", NULL, method_activate_session, 0),
SD_BUS_METHOD("ActivateSessionOnSeat", "ss", NULL, method_activate_session_on_seat, 0),
SD_BUS_METHOD("LockSession", "s", NULL, method_lock_session, 0),
SD_BUS_METHOD("UnlockSession", "s", NULL, method_lock_session, 0),
SD_BUS_METHOD("LockSessions", NULL, NULL, method_lock_sessions, 0),
SD_BUS_METHOD("UnlockSessions", NULL, NULL, method_lock_sessions, 0),
SD_BUS_METHOD("KillSession", "ssi", NULL, method_kill_session, 0),
SD_BUS_METHOD("KillUser", "ui", NULL, method_kill_user, 0),
SD_BUS_METHOD("TerminateSession", "s", NULL, method_terminate_session, 0),
SD_BUS_METHOD("TerminateUser", "u", NULL, method_terminate_user, 0),
SD_BUS_METHOD("TerminateSeat", "s", NULL, method_terminate_seat, 0),
SD_BUS_METHOD("SetUserLinger", "ubb", NULL, method_set_user_linger, 0),
SD_BUS_METHOD("AttachDevice", "ssb", NULL, method_attach_device, 0),
SD_BUS_METHOD("FlushDevices", "b", NULL, method_flush_devices, 0),
SD_BUS_METHOD("PowerOff", "b", NULL, method_poweroff, 0),
SD_BUS_METHOD("Reboot", "b", NULL, method_reboot, 0),
SD_BUS_METHOD("Suspend", "b", NULL, method_suspend, 0),
SD_BUS_METHOD("Hibernate", "b", NULL, method_hibernate, 0),
SD_BUS_METHOD("HybridSleep", "b", NULL, method_hybrid_sleep, 0),
SD_BUS_METHOD("CanPowerOff", NULL, "s", method_can_poweroff, 0),
SD_BUS_METHOD("CanReboot", NULL, "s", method_can_reboot, 0),
SD_BUS_METHOD("CanSuspend", NULL, "s", method_can_suspend, 0),
SD_BUS_METHOD("CanHibernate", NULL, "s", method_can_hibernate, 0),
SD_BUS_METHOD("CanHybridSleep", NULL, "s", method_can_hybrid_sleep, 0),
SD_BUS_METHOD("Inhibit", "ssss", "h", method_inhibit, 0),
SD_BUS_SIGNAL("SessionNew", "so", 0),
SD_BUS_SIGNAL("SessionRemoved", "so", 0),
SD_BUS_SIGNAL("UserNew", "uo", 0),
SD_BUS_SIGNAL("UserRemoved", "uo", 0),
SD_BUS_SIGNAL("SeatNew", "so", 0),
SD_BUS_SIGNAL("SeatRemoved", "so", 0),
SD_BUS_SIGNAL("PrepareForShutdown", "b", 0),
SD_BUS_SIGNAL("PrepareForSleep", "b", 0),
SD_BUS_VTABLE_END
};
int match_job_removed(sd_bus *bus, sd_bus_message *message, void *userdata, sd_bus_error *error) {
const char *path, *result, *unit;
Manager *m = userdata;
Session *session;
uint32_t id;
User *user;
int r;
assert(bus);
assert(message);
assert(m);
r = sd_bus_message_read(message, "uoss", &id, &path, &unit, &result);
if (r < 0) {
bus_log_parse_error(r);
return r;
}
if (m->action_job && streq(m->action_job, path)) {
log_info("Operation finished.");
/* Tell people that they now may take a lock again */
send_prepare_for(m, m->action_what, false);
free(m->action_job);
m->action_job = NULL;
m->action_unit = NULL;
m->action_what = 0;
return 0;
}
session = hashmap_get(m->session_units, unit);
if (session) {
if (streq_ptr(path, session->scope_job)) {
free(session->scope_job);
session->scope_job = NULL;
}
if (session->started) {
if (streq(result, "done"))
session_send_create_reply(session, NULL);
else {
_cleanup_bus_error_free_ sd_bus_error e = SD_BUS_ERROR_NULL;
sd_bus_error_setf(&e, BUS_ERROR_JOB_FAILED, "Start job for unit %s failed with '%s'", unit, result);
session_send_create_reply(session, &e);
}
} else
session_save(session);
session_add_to_gc_queue(session);
}
user = hashmap_get(m->user_units, unit);
if (user) {
if (streq_ptr(path, user->service_job)) {
free(user->service_job);
user->service_job = NULL;
}
if (streq_ptr(path, user->slice_job)) {
free(user->slice_job);
user->slice_job = NULL;
}
user_save(user);
user_add_to_gc_queue(user);
}
return 0;
}
int match_unit_removed(sd_bus *bus, sd_bus_message *message, void *userdata, sd_bus_error *error) {
const char *path, *unit;
Manager *m = userdata;
Session *session;
User *user;
int r;
assert(bus);
assert(message);
assert(m);
r = sd_bus_message_read(message, "so", &unit, &path);
if (r < 0) {
bus_log_parse_error(r);
return r;
}
session = hashmap_get(m->session_units, unit);
if (session)
session_add_to_gc_queue(session);
user = hashmap_get(m->user_units, unit);
if (user)
user_add_to_gc_queue(user);
return 0;
}
int match_properties_changed(sd_bus *bus, sd_bus_message *message, void *userdata, sd_bus_error *error) {
_cleanup_free_ char *unit = NULL;
Manager *m = userdata;
const char *path;
Session *session;
User *user;
int r;
assert(bus);
assert(message);
assert(m);
path = sd_bus_message_get_path(message);
if (!path)
return 0;
r = unit_name_from_dbus_path(path, &unit);
if (r < 0)
return r;
session = hashmap_get(m->session_units, unit);
if (session)
session_add_to_gc_queue(session);
user = hashmap_get(m->user_units, unit);
if (user)
user_add_to_gc_queue(user);
return 0;
}
int match_reloading(sd_bus *bus, sd_bus_message *message, void *userdata, sd_bus_error *error) {
Manager *m = userdata;
Session *session;
Iterator i;
int b, r;
assert(bus);
r = sd_bus_message_read(message, "b", &b);
if (r < 0) {
bus_log_parse_error(r);
return r;
}
if (b)
return 0;
/* systemd finished reloading, let's recheck all our sessions */
log_debug("System manager has been reloaded, rechecking sessions...");
HASHMAP_FOREACH(session, m->sessions, i)
session_add_to_gc_queue(session);
return 0;
}
int match_name_owner_changed(sd_bus *bus, sd_bus_message *message, void *userdata, sd_bus_error *error) {
const char *name, *old, *new;
Manager *m = userdata;
Session *session;
Iterator i;
int r;
char *key;
r = sd_bus_message_read(message, "sss", &name, &old, &new);
if (r < 0) {
bus_log_parse_error(r);
return r;
}
if (isempty(old) || !isempty(new))
return 0;
key = set_remove(m->busnames, (char*) old);
if (!key)
return 0;
/* Drop all controllers owned by this name */
free(key);
HASHMAP_FOREACH(session, m->sessions, i)
if (session_is_controller(session, old))
session_drop_controller(session);
return 0;
}
int manager_send_changed(Manager *manager, const char *property, ...) {
char **l;
assert(manager);
l = strv_from_stdarg_alloca(property);
return sd_bus_emit_properties_changed_strv(
manager->bus,
"/org/freedesktop/login1",
"org.freedesktop.login1.Manager",
l);
}
int manager_dispatch_delayed(Manager *manager) {
_cleanup_bus_error_free_ sd_bus_error error = SD_BUS_ERROR_NULL;
Inhibitor *offending = NULL;
int r;
assert(manager);
if (manager->action_what == 0 || manager->action_job)
return 0;
/* Continue delay? */
if (manager_is_inhibited(manager, manager->action_what, INHIBIT_DELAY, NULL, false, false, 0, &offending)) {
_cleanup_free_ char *comm = NULL, *u = NULL;
get_process_comm(offending->pid, &comm);
u = uid_to_name(offending->uid);
if (manager->action_timestamp + manager->inhibit_delay_max > now(CLOCK_MONOTONIC))
return 0;
log_info("Delay lock is active (UID %lu/%s, PID %lu/%s) but inhibitor timeout is reached.",
(unsigned long) offending->uid, strna(u),
(unsigned long) offending->pid, strna(comm));
}
/* Actually do the operation */
r = execute_shutdown_or_sleep(manager, manager->action_what, manager->action_unit, &error);
if (r < 0) {
log_warning("Failed to send delayed message: %s", bus_error_message(&error, r));
manager->action_unit = NULL;
manager->action_what = 0;
return r;
}
return 1;
}
int manager_start_scope(
Manager *manager,
const char *scope,
pid_t pid,
const char *slice,
const char *description,
const char *after,
const char *kill_mode,
sd_bus_error *error,
char **job) {
_cleanup_bus_message_unref_ sd_bus_message *m = NULL, *reply = NULL;
int r;
assert(manager);
assert(scope);
assert(pid > 1);
r = sd_bus_message_new_method_call(
manager->bus,
"org.freedesktop.systemd1",
"/org/freedesktop/systemd1",
"org.freedesktop.systemd1.Manager",
"StartTransientUnit",
&m);
if (r < 0)
return r;
r = sd_bus_message_append(m, "ss", strempty(scope), "fail");
if (r < 0)
return r;
r = sd_bus_message_open_container(m, 'a', "(sv)");
if (r < 0)
return r;
if (!isempty(slice)) {
r = sd_bus_message_append(m, "(sv)", "Slice", "s", slice);
if (r < 0)
return r;
}
if (!isempty(description)) {
r = sd_bus_message_append(m, "(sv)", "Description", "s", description);
if (r < 0)
return r;
}
if (!isempty(description)) {
r = sd_bus_message_append(m, "(sv)", "After", "as", 1, after);
if (r < 0)
return r;
}
if (!isempty(kill_mode)) {
r = sd_bus_message_append(m, "(sv)", "KillMode", "s", kill_mode);
if (r < 0)
return r;
}
/* cgroup empty notification is not available in containers
* currently. To make this less problematic, let's shorten the
* stop timeout for sessions, so that we don't wait
* forever. */
r = sd_bus_message_append(m, "(sv)", "TimeoutStopUSec", "t", 500 * USEC_PER_MSEC);
if (r < 0)
return r;
/* Make sure that the session shells are terminated with
* SIGHUP since bash and friends tend to ignore SIGTERM */
r = sd_bus_message_append(m, "(sv)", "SendSIGHUP", "b", true);
if (r < 0)
return r;
r = sd_bus_message_append(m, "(sv)", "PIDs", "au", 1, pid);
if (r < 0)
return r;
r = sd_bus_message_close_container(m);
if (r < 0)
return r;
r = sd_bus_message_append(m, "a(sa(sv))", 0);
if (r < 0)
return r;
r = sd_bus_call(manager->bus, m, 0, error, &reply);
if (r < 0)
return r;
if (job) {
const char *j;
char *copy;
r = sd_bus_message_read(reply, "o", &j);
if (r < 0)
return r;
copy = strdup(j);
if (!copy)
return -ENOMEM;
*job = copy;
}
return 1;
}
int manager_start_unit(Manager *manager, const char *unit, sd_bus_error *error, char **job) {
_cleanup_bus_message_unref_ sd_bus_message *reply = NULL;
int r;
assert(manager);
assert(unit);
r = sd_bus_call_method(
manager->bus,
"org.freedesktop.systemd1",
"/org/freedesktop/systemd1",
"org.freedesktop.systemd1.Manager",
"StartUnit",
error,
&reply,
"ss", unit, "fail");
if (r < 0)
return r;
if (job) {
const char *j;
char *copy;
r = sd_bus_message_read(reply, "o", &j);
if (r < 0)
return r;
copy = strdup(j);
if (!copy)
return -ENOMEM;
*job = copy;
}
return 1;
}
int manager_stop_unit(Manager *manager, const char *unit, sd_bus_error *error, char **job) {
_cleanup_bus_message_unref_ sd_bus_message *reply = NULL;
int r;
assert(manager);
assert(unit);
r = sd_bus_call_method(
manager->bus,
"org.freedesktop.systemd1",
"/org/freedesktop/systemd1",
"org.freedesktop.systemd1.Manager",
"StopUnit",
error,
&reply,
"ss", unit, "fail");
if (r < 0) {
if (sd_bus_error_has_name(error, BUS_ERROR_NO_SUCH_UNIT) ||
sd_bus_error_has_name(error, BUS_ERROR_LOAD_FAILED)) {
if (job)
*job = NULL;
sd_bus_error_free(error);
return 0;
}
return r;
}
if (job) {
const char *j;
char *copy;
r = sd_bus_message_read(reply, "o", &j);
if (r < 0)
return r;
copy = strdup(j);
if (!copy)
return -ENOMEM;
*job = copy;
}
return 1;
}
int manager_kill_unit(Manager *manager, const char *unit, KillWho who, int signo, sd_bus_error *error) {
assert(manager);
assert(unit);
return sd_bus_call_method(
manager->bus,
"org.freedesktop.systemd1",
"/org/freedesktop/systemd1",
"org.freedesktop.systemd1.Manager",
"KillUnit",
error,
NULL,
"ssi", unit, who == KILL_LEADER ? "main" : "all", signo);
}
int manager_unit_is_active(Manager *manager, const char *unit) {
_cleanup_bus_error_free_ sd_bus_error error = SD_BUS_ERROR_NULL;
_cleanup_bus_message_unref_ sd_bus_message *reply = NULL;
_cleanup_free_ char *path = NULL;
const char *state;
int r;
assert(manager);
assert(unit);
path = unit_dbus_path_from_name(unit);
if (!path)
return -ENOMEM;
r = sd_bus_get_property(
manager->bus,
"org.freedesktop.systemd1",
path,
"org.freedesktop.systemd1.Unit",
"ActiveState",
&error,
&reply,
"s");
if (r < 0) {
/* systemd might have droppped off momentarily, let's
* not make this an error */
if (sd_bus_error_has_name(&error, SD_BUS_ERROR_NO_REPLY) ||
sd_bus_error_has_name(&error, SD_BUS_ERROR_DISCONNECTED))
return true;
/* If the unit is already unloaded then it's not
* active */
if (sd_bus_error_has_name(&error, BUS_ERROR_NO_SUCH_UNIT) ||
sd_bus_error_has_name(&error, BUS_ERROR_LOAD_FAILED))
return false;
return r;
}
r = sd_bus_message_read(reply, "s", &state);
if (r < 0)
return -EINVAL;
return !streq(state, "inactive") && !streq(state, "failed");
}
int manager_job_is_active(Manager *manager, const char *path) {
_cleanup_bus_error_free_ sd_bus_error error = SD_BUS_ERROR_NULL;
_cleanup_bus_message_unref_ sd_bus_message *reply = NULL;
int r;
assert(manager);
assert(path);
r = sd_bus_get_property(
manager->bus,
"org.freedesktop.systemd1",
path,
"org.freedesktop.systemd1.Job",
"State",
&error,
&reply,
"s");
if (r < 0) {
if (sd_bus_error_has_name(&error, SD_BUS_ERROR_NO_REPLY) ||
sd_bus_error_has_name(&error, SD_BUS_ERROR_DISCONNECTED))
return true;
if (sd_bus_error_has_name(&error, SD_BUS_ERROR_UNKNOWN_OBJECT))
return false;
return r;
}
/* We don't actually care about the state really. The fact
* that we could read the job state is enough for us */
return true;
}