libsystemd/sd-bus/bus-control.c

	bus-control.c revision cccb0b2cdbd25e90ae92d2d5b107125cb1ca3433
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering/*-*- Mode: C; c-basic-offset: 8; indent-tabs-mode: nil -*-*/
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering/***
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering  This file is part of systemd.
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering  Copyright 2013 Lennart Poettering
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering  systemd is free software; you can redistribute it and/or modify it
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering  under the terms of the GNU Lesser General Public License as published by
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering  the Free Software Foundation; either version 2.1 of the License, or
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering  (at your option) any later version.
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering  systemd is distributed in the hope that it will be useful, but
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering  WITHOUT ANY WARRANTY; without even the implied warranty of
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering  MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering  Lesser General Public License for more details.
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering  You should have received a copy of the GNU Lesser General Public License
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering  along with systemd; If not, see <http://www.gnu.org/licenses/>.
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering***/
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering#ifdef HAVE_VALGRIND_MEMCHECK_H
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering#include <valgrind/memcheck.h>
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering#endif
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering#include <stddef.h>
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering#include <errno.h>
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering#include "strv.h"
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering#include "sd-bus.h"
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering#include "bus-internal.h"
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering#include "bus-message.h"
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering#include "bus-control.h"
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering#include "bus-bloom.h"
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering#include "bus-util.h"
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering#include "cgroup-util.h"
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering_public_ int sd_bus_get_unique_name(sd_bus *bus, const char **unique) {
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering        int r;
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering        assert_return(bus, -EINVAL);
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering        assert_return(unique, -EINVAL);
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering        assert_return(!bus_pid_changed(bus), -ECHILD);
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering        r = bus_ensure_running(bus);
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering        if (r < 0)
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering                return r;
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering        *unique = bus->unique_name;
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering        return 0;
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering}
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poetteringstatic int bus_request_name_kernel(sd_bus *bus, const char *name, uint64_t flags) {
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering        struct kdbus_cmd_name *n;
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering        size_t size, l;
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering        int r;
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering        assert(bus);
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering        assert(name);
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering        l = strlen(name);
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering        size = offsetof(struct kdbus_cmd_name, name) + l + 1;
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering        n = alloca0(size);
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering        n->size = size;
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering        kdbus_translate_request_name_flags(flags, (uint64_t *) &n->flags);
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering        memcpy(n->name, name, l+1);
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering#ifdef HAVE_VALGRIND_MEMCHECK_H
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering        VALGRIND_MAKE_MEM_DEFINED(n, n->size);
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering#endif
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering        r = ioctl(bus->input_fd, KDBUS_CMD_NAME_ACQUIRE, n);
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering        if (r < 0)
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering                return -errno;
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering        if (n->flags & KDBUS_NAME_IN_QUEUE)
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering                return 0;
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering        return 1;
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering}
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poetteringstatic int bus_request_name_dbus1(sd_bus *bus, const char *name, uint64_t flags) {
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering        _cleanup_bus_message_unref_ sd_bus_message *reply = NULL;
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering        uint32_t ret, param = 0;
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering        int r;
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering        assert(bus);
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering        assert(name);
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering        if (flags & SD_BUS_NAME_ALLOW_REPLACEMENT)
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering                param |= BUS_NAME_ALLOW_REPLACEMENT;
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering        if (flags & SD_BUS_NAME_REPLACE_EXISTING)
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering                param |= BUS_NAME_REPLACE_EXISTING;
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering        if (!(flags & SD_BUS_NAME_QUEUE))
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering                param |= BUS_NAME_DO_NOT_QUEUE;
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering        r = sd_bus_call_method(
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering                        bus,
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering                        "org.freedesktop.DBus",
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering                        "/org/freedesktop/DBus",
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering                        "org.freedesktop.DBus",
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering                        "RequestName",
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering                        NULL,
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering                        &reply,
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering                        "su",
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering                        name,
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering                        param);
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering        if (r < 0)
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering                return r;
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering        r = sd_bus_message_read(reply, "u", &ret);
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering        if (r < 0)
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering                return r;
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering        if (ret == BUS_NAME_ALREADY_OWNER)
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering                return -EALREADY;
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering        else if (ret == BUS_NAME_EXISTS)
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering                return -EEXIST;
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering        else if (ret == BUS_NAME_IN_QUEUE)
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering                return 0;
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering        else if (ret == BUS_NAME_PRIMARY_OWNER)
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering                return 1;
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering        return -EIO;
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering}
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering_public_ int sd_bus_request_name(sd_bus *bus, const char *name, uint64_t flags) {
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering        assert_return(bus, -EINVAL);
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering        assert_return(name, -EINVAL);
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering        assert_return(bus->bus_client, -EINVAL);
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering        assert_return(BUS_IS_OPEN(bus->state), -ENOTCONN);
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering        assert_return(!bus_pid_changed(bus), -ECHILD);
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering        assert_return(!(flags & ~(SD_BUS_NAME_ALLOW_REPLACEMENT|SD_BUS_NAME_REPLACE_EXISTING|SD_BUS_NAME_QUEUE)), -EINVAL);
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering        assert_return(service_name_is_valid(name), -EINVAL);
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering        assert_return(name[0] != ':', -EINVAL);
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering        if (bus->is_kernel)
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering                return bus_request_name_kernel(bus, name, flags);
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering        else
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering                return bus_request_name_dbus1(bus, name, flags);
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering}
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poetteringstatic int bus_release_name_kernel(sd_bus *bus, const char *name) {
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering        struct kdbus_cmd_name *n;
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering        size_t l;
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering        int r;
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering        assert(bus);
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering        assert(name);
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering        l = strlen(name);
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering        n = alloca0(offsetof(struct kdbus_cmd_name, name) + l + 1);
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering        n->size = offsetof(struct kdbus_cmd_name, name) + l + 1;
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering        memcpy(n->name, name, l+1);
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering#ifdef HAVE_VALGRIND_MEMCHECK_H
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering        VALGRIND_MAKE_MEM_DEFINED(n, n->size);
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering#endif
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering        r = ioctl(bus->input_fd, KDBUS_CMD_NAME_RELEASE, n);
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering        if (r < 0)
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering                return -errno;
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering        return n->flags;
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering}
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poetteringstatic int bus_release_name_dbus1(sd_bus *bus, const char *name) {
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering        _cleanup_bus_message_unref_ sd_bus_message *reply = NULL;
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering        uint32_t ret;
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering        int r;
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering        assert(bus);
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering        assert(name);
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering        r = sd_bus_call_method(
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering                        bus,
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering                        "org.freedesktop.DBus",
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering                        "/org/freedesktop/DBus",
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering                        "org.freedesktop.DBus",
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering                        "ReleaseName",
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering                        NULL,
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering                        &reply,
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering                        "s",
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering                        name);
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering        if (r < 0)
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering                return r;
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering        r = sd_bus_message_read(reply, "u", &ret);
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering        if (r < 0)
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering                return r;
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering        if (ret == BUS_NAME_NON_EXISTENT)
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering                return -ESRCH;
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering        if (ret == BUS_NAME_NOT_OWNER)
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering                return -EADDRINUSE;
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering        if (ret == BUS_NAME_RELEASED)
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering                return 0;
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering        return -EINVAL;
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering}
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering_public_ int sd_bus_release_name(sd_bus *bus, const char *name) {
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering        assert_return(bus, -EINVAL);
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering        assert_return(name, -EINVAL);
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering        assert_return(bus->bus_client, -EINVAL);
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering        assert_return(BUS_IS_OPEN(bus->state), -ENOTCONN);
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering        assert_return(!bus_pid_changed(bus), -ECHILD);
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering        assert_return(service_name_is_valid(name), -EINVAL);
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering        assert_return(name[0] != ':', -EINVAL);
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering        if (bus->is_kernel)
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering                return bus_release_name_kernel(bus, name);
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering        else
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering                return bus_release_name_dbus1(bus, name);
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering}
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poetteringstatic int kernel_get_list(sd_bus *bus, uint64_t flags, char ***x) {
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering        struct kdbus_cmd_name_list cmd = {};
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering        struct kdbus_name_list *name_list;
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering        struct kdbus_cmd_name *name;
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering        uint64_t previous_id = 0;
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering        int r;
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering        /* Caller will free half-constructed list on failure... */
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering        cmd.flags = flags;
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering        r = ioctl(bus->input_fd, KDBUS_CMD_NAME_LIST, &cmd);
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering        if (r < 0)
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering                return -errno;
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering        name_list = (struct kdbus_name_list *) ((uint8_t *) bus->kdbus_buffer + cmd.offset);
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering        KDBUS_ITEM_FOREACH(name, name_list, names) {
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering                if ((flags & KDBUS_NAME_LIST_UNIQUE) && name->owner_id != previous_id) {
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering                        char *n;
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering                        if (asprintf(&n, ":1.%llu", (unsigned long long) name->owner_id) < 0)
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering                                return -ENOMEM;
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering                        r = strv_push(x, n);
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering                        if (r < 0) {
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering                                free(n);
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering                                return -ENOMEM;
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering                        }
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering                        previous_id = name->owner_id;
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering                }
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering                if (name->size > sizeof(*name) && service_name_is_valid(name->name)) {
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering                        r = strv_extend(x, name->name);
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering                        if (r < 0)
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering                                return -ENOMEM;
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering                }
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering        }
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering        r = ioctl(bus->input_fd, KDBUS_CMD_FREE, &cmd.offset);
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering        if (r < 0)
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering                return -errno;
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering        return 0;
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering}
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poetteringstatic int bus_list_names_kernel(sd_bus *bus, char ***acquired, char ***activatable) {
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering        _cleanup_strv_free_ char **x = NULL, **y = NULL;
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering        int r;
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering        if (acquired) {
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering                r = kernel_get_list(bus, KDBUS_NAME_LIST_UNIQUE | KDBUS_NAME_LIST_NAMES, &x);
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering                if (r < 0)
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering                        return r;
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering        }
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering        if (activatable) {
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering                r = kernel_get_list(bus, KDBUS_NAME_LIST_ACTIVATORS, &y);
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering                if (r < 0)
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering                        return r;
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering                *activatable = y;
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering                y = NULL;
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering        }
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering        if (acquired) {
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering                *acquired = x;
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering                x = NULL;
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering        }
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering        return 0;
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering}
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poetteringstatic int bus_list_names_dbus1(sd_bus *bus, char ***acquired, char ***activatable) {
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering        _cleanup_bus_message_unref_ sd_bus_message *reply = NULL;
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering        _cleanup_strv_free_ char **x = NULL, **y = NULL;
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering        int r;
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering        if (acquired) {
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering                r = sd_bus_call_method(
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering                                bus,
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering                                "org.freedesktop.DBus",
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering                                "/org/freedesktop/DBus",
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering                                "org.freedesktop.DBus",
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering                                "ListNames",
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering                                NULL,
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering                                &reply,
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering                                NULL);
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering                if (r < 0)
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering                        return r;
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering                r = sd_bus_message_read_strv(reply, &x);
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering                if (r < 0)
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering                        return r;
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering                reply = sd_bus_message_unref(reply);
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering        }
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering        if (activatable) {
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering                r = sd_bus_call_method(
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering                                bus,
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering                                "org.freedesktop.DBus",
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering                                "/org/freedesktop/DBus",
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering                                "org.freedesktop.DBus",
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering                                "ListActivatableNames",
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering                                NULL,
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering                                &reply,
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering                                NULL);
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering                if (r < 0)
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering                        return r;
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering                r = sd_bus_message_read_strv(reply, &y);
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering                if (r < 0)
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering                        return r;
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering                *activatable = y;
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering                y = NULL;
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering        }
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering        if (acquired) {
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering                *acquired = x;
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering                x = NULL;
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering        }
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering        return 0;
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering}
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering_public_ int sd_bus_list_names(sd_bus *bus, char ***acquired, char ***activatable) {
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering        assert_return(bus, -EINVAL);
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering        assert_return(acquired || activatable, -EINVAL);
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering        assert_return(BUS_IS_OPEN(bus->state), -ENOTCONN);
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering        assert_return(!bus_pid_changed(bus), -ECHILD);
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering        if (bus->is_kernel)
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering                return bus_list_names_kernel(bus, acquired, activatable);
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering        else
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering                return bus_list_names_dbus1(bus, acquired, activatable);
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering}
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poetteringstatic int bus_get_owner_kdbus(
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering                sd_bus *bus,
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering                const char *name,
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering                uint64_t mask,
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering                sd_bus_creds **creds) {
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering        _cleanup_bus_creds_unref_ sd_bus_creds *c = NULL;
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering        struct kdbus_cmd_conn_info *cmd;
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering        struct kdbus_conn_info *conn_info;
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering        struct kdbus_item *item;
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering        size_t size;
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering        uint64_t m, id;
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering        int r;
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering        r = bus_kernel_parse_unique_name(name, &id);
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering        if (r < 0)
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering                return r;
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering        if (r > 0) {
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering                size = offsetof(struct kdbus_cmd_conn_info, name);
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering                cmd = alloca0(size);
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering                cmd->id = id;
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering        } else {
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering                size = offsetof(struct kdbus_cmd_conn_info, name) + strlen(name) + 1;
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering                cmd = alloca0(size);
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering                strcpy(cmd->name, name);
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering        }
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering        cmd->size = size;
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering        kdbus_translate_attach_flags(mask, (uint64_t*) &cmd->flags);
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering        r = ioctl(bus->input_fd, KDBUS_CMD_CONN_INFO, cmd);
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering        if (r < 0)
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering                return -errno;
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering        conn_info = (struct kdbus_conn_info *) ((uint8_t *) bus->kdbus_buffer + cmd->offset);
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering        /* Non-activated names are considered not available */
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering        if (conn_info->flags & KDBUS_HELLO_ACTIVATOR)
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering                return name[0] == ':' ? -ENXIO : -ENOENT;
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering        c = bus_creds_new();
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering        if (!c)
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering                return -ENOMEM;
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering        if (mask & SD_BUS_CREDS_UNIQUE_NAME) {
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering                if (asprintf(&c->unique_name, ":1.%llu", (unsigned long long) conn_info->id) < 0)
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering                        return -ENOMEM;
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering                c->mask |= SD_BUS_CREDS_UNIQUE_NAME;
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering        }
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering        KDBUS_ITEM_FOREACH(item, conn_info, items) {
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering                switch (item->type) {
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering                case KDBUS_ITEM_CREDS:
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering                        m = (SD_BUS_CREDS_UID | SD_BUS_CREDS_GID | SD_BUS_CREDS_PID) & mask;
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering                        if (m) {
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering                                c->uid = (uid_t) item->creds.uid;
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering                                c->pid = (pid_t) item->creds.pid;
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering                                c->gid = (gid_t) item->creds.gid;
839a4a20d8b4f6ebf3a342fd05c821358be5a313Lennart Poettering                                c->mask |= m;
                        }

                        if (mask & SD_BUS_CREDS_TID && item->creds.tid > 0) {
                                c->tid = (pid_t) item->creds.tid;
                                c->mask |= SD_BUS_CREDS_TID;
                        }

                        if (mask & SD_BUS_CREDS_PID_STARTTIME && item->creds.starttime > 0) {
                                c->pid_starttime = item->creds.starttime;
                                c->mask |= SD_BUS_CREDS_PID_STARTTIME;
                        }

                        break;

                case KDBUS_ITEM_PID_COMM:
                        if (mask & SD_BUS_CREDS_COMM) {
                                c->comm = strdup(item->str);
                                if (!c->comm) {
                                        r = -ENOMEM;
                                        goto fail;
                                }

                                c->mask |= SD_BUS_CREDS_COMM;
                        }
                        break;

                case KDBUS_ITEM_TID_COMM:
                        if (mask & SD_BUS_CREDS_TID_COMM) {
                                c->tid_comm = strdup(item->str);
                                if (!c->tid_comm) {
                                        r = -ENOMEM;
                                        goto fail;
                                }

                                c->mask |= SD_BUS_CREDS_TID_COMM;
                        }
                        break;

                case KDBUS_ITEM_EXE:
                        if (mask & SD_BUS_CREDS_EXE) {
                                c->exe = strdup(item->str);
                                if (!c->exe) {
                                        r = -ENOMEM;
                                        goto fail;
                                }

                                c->mask |= SD_BUS_CREDS_EXE;
                        }
                        break;

                case KDBUS_ITEM_CMDLINE:
                        if (mask & SD_BUS_CREDS_CMDLINE) {
                                c->cmdline_size = item->size - KDBUS_ITEM_HEADER_SIZE;
                                c->cmdline = memdup(item->data, c->cmdline_size);
                                if (!c->cmdline) {
                                        r = -ENOMEM;
                                        goto fail;
                                }

                                c->mask |= SD_BUS_CREDS_CMDLINE;
                        }
                        break;

                case KDBUS_ITEM_CGROUP:
                        m = (SD_BUS_CREDS_CGROUP | SD_BUS_CREDS_UNIT |
                             SD_BUS_CREDS_USER_UNIT | SD_BUS_CREDS_SLICE |
                             SD_BUS_CREDS_SESSION | SD_BUS_CREDS_OWNER_UID) & mask;

                        if (m) {
                                c->cgroup = strdup(item->str);
                                if (!c->cgroup) {
                                        r = -ENOMEM;
                                        goto fail;
                                }

                                if (!bus->cgroup_root) {
                                        r = cg_get_root_path(&bus->cgroup_root);
                                        if (r < 0)
                                                goto fail;
                                }

                                c->cgroup_root = strdup(bus->cgroup_root);
                                if (!c->cgroup_root) {
                                        r = -ENOMEM;
                                        goto fail;
                                }

                                c->mask |= m;
                        }
                        break;

                case KDBUS_ITEM_CAPS:
                        m = (SD_BUS_CREDS_EFFECTIVE_CAPS | SD_BUS_CREDS_PERMITTED_CAPS |
                             SD_BUS_CREDS_INHERITABLE_CAPS | SD_BUS_CREDS_BOUNDING_CAPS) & mask;

                        if (m) {
                                c->capability_size = item->size - KDBUS_ITEM_HEADER_SIZE;
                                c->capability = memdup(item->data, c->capability_size);
                                if (!c->capability) {
                                        r = -ENOMEM;
                                        goto fail;
                                }

                                c->mask |= m;
                        }
                        break;

                case KDBUS_ITEM_SECLABEL:
                        if (mask & SD_BUS_CREDS_SELINUX_CONTEXT) {
                                c->label = strdup(item->str);
                                if (!c->label) {
                                        r = -ENOMEM;
                                        goto fail;
                                }

                                c->mask |= SD_BUS_CREDS_SELINUX_CONTEXT;
                        }
                        break;

                case KDBUS_ITEM_AUDIT:
                        m = (SD_BUS_CREDS_AUDIT_SESSION_ID | SD_BUS_CREDS_AUDIT_LOGIN_UID) & mask;

                        if (m) {
                                c->audit_session_id = item->audit.sessionid;
                                c->audit_login_uid = item->audit.loginuid;
                                c->mask |= m;
                        }
                        break;

                case KDBUS_ITEM_NAME:
                        if ((mask & SD_BUS_CREDS_WELL_KNOWN_NAMES) && service_name_is_valid(item->name.name)) {
                                r = strv_extend(&c->well_known_names, item->name.name);
                                if (r < 0)
                                        goto fail;

                                c->mask |= SD_BUS_CREDS_WELL_KNOWN_NAMES;
                        }
                        break;

                case KDBUS_ITEM_CONN_NAME:
                        if ((mask & SD_BUS_CREDS_CONNECTION_NAME)) {
                                c->conn_name = strdup(item->str);
                                if (!c->conn_name) {
                                        r = -ENOMEM;
                                        goto fail;
                                }

                                c->mask |= SD_BUS_CREDS_CONNECTION_NAME;
                        }
                        break;
                }
        }

        if (creds) {
                *creds = c;
                c = NULL;
        }

        r = 0;

fail:
        ioctl(bus->input_fd, KDBUS_CMD_FREE, &cmd->offset);
        return r;
}

static int bus_get_owner_dbus1(
                sd_bus *bus,
                const char *name,
                uint64_t mask,
                sd_bus_creds **creds) {

        _cleanup_bus_message_unref_ sd_bus_message *reply_unique = NULL, *reply = NULL;
        _cleanup_bus_creds_unref_ sd_bus_creds *c = NULL;
        const char *unique = NULL;
        pid_t pid = 0;
        int r;

        /* Only query the owner if the caller wants to know it or if
         * the caller just wants to check whether a name exists */
        if ((mask & SD_BUS_CREDS_UNIQUE_NAME) || mask == 0) {
                r = sd_bus_call_method(
                                bus,
                                "org.freedesktop.DBus",
                                "/org/freedesktop/DBus",
                                "org.freedesktop.DBus",
                                "GetNameOwner",
                                NULL,
                                &reply_unique,
                                "s",
                                name);
                if (r < 0)
                        return r;

                r = sd_bus_message_read(reply_unique, "s", &unique);
                if (r < 0)
                        return r;
        }

        if (mask != 0) {
                c = bus_creds_new();
                if (!c)
                        return -ENOMEM;

                if ((mask & SD_BUS_CREDS_UNIQUE_NAME) && unique) {
                        c->unique_name = strdup(unique);
                        if (!c->unique_name)
                                return -ENOMEM;

                        c->mask |= SD_BUS_CREDS_UNIQUE_NAME;
                }

                if (mask & (SD_BUS_CREDS_PID|SD_BUS_CREDS_PID_STARTTIME|SD_BUS_CREDS_GID|
                            SD_BUS_CREDS_COMM|SD_BUS_CREDS_EXE|SD_BUS_CREDS_CMDLINE|
                            SD_BUS_CREDS_CGROUP|SD_BUS_CREDS_UNIT|SD_BUS_CREDS_USER_UNIT|SD_BUS_CREDS_SLICE|SD_BUS_CREDS_SESSION|SD_BUS_CREDS_OWNER_UID|
                            SD_BUS_CREDS_EFFECTIVE_CAPS|SD_BUS_CREDS_PERMITTED_CAPS|SD_BUS_CREDS_INHERITABLE_CAPS|SD_BUS_CREDS_BOUNDING_CAPS|
                            SD_BUS_CREDS_AUDIT_SESSION_ID|SD_BUS_CREDS_AUDIT_LOGIN_UID)) {
                        uint32_t u;

                        r = sd_bus_call_method(
                                        bus,
                                        "org.freedesktop.DBus",
                                        "/org/freedesktop/DBus",
                                        "org.freedesktop.DBus",
                                        "GetConnectionUnixProcessID",
                                        NULL,
                                        &reply,
                                        "s",
                                        unique ? unique : name);
                        if (r < 0)
                                return r;

                        r = sd_bus_message_read(reply, "u", &u);
                        if (r < 0)
                                return r;

                        pid = u;
                        if (mask & SD_BUS_CREDS_PID) {
                                c->pid = u;
                                c->mask |= SD_BUS_CREDS_PID;
                        }

                        reply = sd_bus_message_unref(reply);
                }

                if (mask & SD_BUS_CREDS_UID) {
                        uint32_t u;

                        r = sd_bus_call_method(
                                        bus,
                                        "org.freedesktop.DBus",
                                        "/org/freedesktop/DBus",
                                        "org.freedesktop.DBus",
                                        "GetConnectionUnixUser",
                                        NULL,
                                        &reply,
                                        "s",
                                        unique ? unique : name);
                        if (r < 0)
                                return r;

                        r = sd_bus_message_read(reply, "u", &u);
                        if (r < 0)
                                return r;

                        c->uid = u;
                        c->mask |= SD_BUS_CREDS_UID;

                        reply = sd_bus_message_unref(reply);
                }

                if (mask & SD_BUS_CREDS_SELINUX_CONTEXT) {
                        const void *p;
                        size_t sz;

                        r = sd_bus_call_method(
                                        bus,
                                        "org.freedesktop.DBus",
                                        "/org/freedesktop/DBus",
                                        "org.freedesktop.DBus",
                                        "GetConnectionSELinuxSecurityContext",
                                        NULL,
                                        &reply,
                                        "s",
                                        unique ? unique : name);
                        if (r < 0)
                                return r;

                        r = sd_bus_message_read_array(reply, 'y', &p, &sz);
                        if (r < 0)
                                return r;

                        c->label = strndup(p, sz);
                        if (!c->label)
                                return -ENOMEM;

                        c->mask |= SD_BUS_CREDS_SELINUX_CONTEXT;
                }

                r = bus_creds_add_more(c, mask, pid, 0);
                if (r < 0)
                        return r;
        }

        if (creds) {
                *creds = c;
                c = NULL;
        }

        return 0;
}

_public_ int sd_bus_get_owner(
                sd_bus *bus,
                const char *name,
                uint64_t mask,
                sd_bus_creds **creds) {

        assert_return(bus, -EINVAL);
        assert_return(name, -EINVAL);
        assert_return(mask <= _SD_BUS_CREDS_ALL, -ENOTSUP);
        assert_return(mask == 0 || creds, -EINVAL);
        assert_return(BUS_IS_OPEN(bus->state), -ENOTCONN);
        assert_return(!bus_pid_changed(bus), -ECHILD);
        assert_return(service_name_is_valid(name), -EINVAL);
        assert_return(bus->bus_client, -ENODATA);

        if (bus->is_kernel)
                return bus_get_owner_kdbus(bus, name, mask, creds);
        else
                return bus_get_owner_dbus1(bus, name, mask, creds);
}

static int add_name_change_match(sd_bus *bus,
                                 uint64_t cookie,
                                 const char *name,
                                 const char *old_owner,
                                 const char *new_owner) {

        uint64_t name_id = KDBUS_MATCH_ID_ANY, old_owner_id = 0, new_owner_id = 0;
        int is_name_id = -1, r;
        struct kdbus_item *item;

        assert(bus);

        /* If we encounter a match that could match against
         * NameOwnerChanged messages, then we need to create
         * KDBUS_ITEM_NAME_{ADD,REMOVE,CHANGE} and
         * KDBUS_ITEM_ID_{ADD,REMOVE} matches for it, possibly
         * multiple if the match is underspecified.
         *
         * The NameOwnerChanged signals take three parameters with
         * unique or well-known names, but only some forms actually
         * exist:
         *
         * WELLKNOWN, "", UNIQUE       → KDBUS_ITEM_NAME_ADD
         * WELLKNOWN, UNIQUE, ""       → KDBUS_ITEM_NAME_REMOVE
         * WELLKNOWN, UNIQUE, UNIQUE   → KDBUS_ITEM_NAME_CHANGE
         * UNIQUE, "", UNIQUE          → KDBUS_ITEM_ID_ADD
         * UNIQUE, UNIQUE, ""          → KDBUS_ITEM_ID_REMOVE
         *
         * For the latter two the two unique names must be identical.
         *
         * */

        if (name) {
                is_name_id = bus_kernel_parse_unique_name(name, &name_id);
                if (is_name_id < 0)
                        return 0;
        }

        if (!isempty(old_owner)) {
                r = bus_kernel_parse_unique_name(old_owner, &old_owner_id);
                if (r < 0)
                        return 0;
                if (r == 0)
                        return 0;
                if (is_name_id > 0 && old_owner_id != name_id)
                        return 0;
        } else
                old_owner_id = KDBUS_MATCH_ID_ANY;

        if (!isempty(new_owner)) {
                r = bus_kernel_parse_unique_name(new_owner, &new_owner_id);
                if (r < 0)
                        return r;
                if (r == 0)
                        return 0;
                if (is_name_id > 0 && new_owner_id != name_id)
                        return 0;
        } else
                new_owner_id = KDBUS_MATCH_ID_ANY;

        if (is_name_id <= 0) {
                struct kdbus_cmd_match *m;
                size_t sz, l;

                /* If the name argument is missing or is a well-known
                 * name, then add KDBUS_ITEM_NAME_{ADD,REMOVE,CHANGE}
                 * matches for it */

                l = name ? strlen(name) + 1 : 0;

                sz = ALIGN8(offsetof(struct kdbus_cmd_match, items) +
                            offsetof(struct kdbus_item, name_change) +
                            offsetof(struct kdbus_notify_name_change, name) +
                            l);

                m = alloca0(sz);
                m->size = sz;
                m->cookie = cookie;

                item = m->items;
                item->size =
                        offsetof(struct kdbus_item, name_change) +
                        offsetof(struct kdbus_notify_name_change, name) +
                        l;

                item->name_change.old.id = old_owner_id;
                item->name_change.new.id = new_owner_id;

                if (name)
                        memcpy(item->name_change.name, name, l);

                /* If the old name is unset or empty, then
                 * this can match against added names */
                if (!old_owner || old_owner[0] == 0) {
                        item->type = KDBUS_ITEM_NAME_ADD;

                        r = ioctl(bus->input_fd, KDBUS_CMD_MATCH_ADD, m);
                        if (r < 0)
                                return -errno;
                }

                /* If the new name is unset or empty, then
                 * this can match against removed names */
                if (!new_owner || new_owner[0] == 0) {
                        item->type = KDBUS_ITEM_NAME_REMOVE;

                        r = ioctl(bus->input_fd, KDBUS_CMD_MATCH_ADD, m);
                        if (r < 0)
                                return -errno;
                }

                /* The CHANGE match we need in either case, because
                 * what is reported as a name change by the kernel
                 * might just be an owner change between starter and
                 * normal clients. For userspace such a change should
                 * be considered a removal/addition, hence let's
                 * subscribe to this unconditionally. */
                item->type = KDBUS_ITEM_NAME_CHANGE;
                r = ioctl(bus->input_fd, KDBUS_CMD_MATCH_ADD, m);
                if (r < 0)
                        return -errno;
        }

        if (is_name_id != 0) {
                struct kdbus_cmd_match *m;
                uint64_t sz;

                /* If the name argument is missing or is a unique
                 * name, then add KDBUS_ITEM_ID_{ADD,REMOVE} matches
                 * for it */

                sz = ALIGN8(offsetof(struct kdbus_cmd_match, items) +
                            offsetof(struct kdbus_item, id_change) +
                            sizeof(struct kdbus_notify_id_change));

                m = alloca0(sz);
                m->size = sz;
                m->cookie = cookie;

                item = m->items;
                item->size =
                        offsetof(struct kdbus_item, id_change) +
                        sizeof(struct kdbus_notify_id_change);
                item->id_change.id = name_id;

                /* If the old name is unset or empty, then this can
                 * match against added ids */
                if (!old_owner || old_owner[0] == 0) {
                        item->type = KDBUS_ITEM_ID_ADD;

                        r = ioctl(bus->input_fd, KDBUS_CMD_MATCH_ADD, m);
                        if (r < 0)
                                return -errno;
                }

                /* If thew new name is unset or empty, then this can
                 * match against removed ids */
                if (!new_owner || new_owner[0] == 0) {
                        item->type = KDBUS_ITEM_ID_REMOVE;

                        r = ioctl(bus->input_fd, KDBUS_CMD_MATCH_ADD, m);
                        if (r < 0)
                                return -errno;
                }
        }

        return 0;
}

int bus_add_match_internal_kernel(
                sd_bus *bus,
                uint64_t id,
                struct bus_match_component *components,
                unsigned n_components,
                uint64_t cookie) {

        struct kdbus_cmd_match *m;
        struct kdbus_item *item;
        uint64_t bloom[BLOOM_SIZE/8];
        size_t sz;
        const char *sender = NULL;
        size_t sender_length = 0;
        uint64_t src_id = KDBUS_MATCH_ID_ANY;
        bool using_bloom = false;
        unsigned i;
        bool matches_name_change = true;
        const char *name_change_arg[3] = {};
        int r;

        assert(bus);

        zero(bloom);

        sz = ALIGN8(offsetof(struct kdbus_cmd_match, items));

        for (i = 0; i < n_components; i++) {
                struct bus_match_component *c = &components[i];

                switch (c->type) {

                case BUS_MATCH_SENDER:
                        if (!streq(c->value_str, "org.freedesktop.DBus"))
                                matches_name_change = false;

                        r = bus_kernel_parse_unique_name(c->value_str, &src_id);
                        if (r < 0)
                                return r;
                        else if (r > 0)
                                sz += ALIGN8(offsetof(struct kdbus_item, id) + sizeof(uint64_t));
                        else  {
                                sender = c->value_str;
                                sender_length = strlen(sender);
                                sz += ALIGN8(offsetof(struct kdbus_item, str) + sender_length + 1);
                        }

                        break;

                case BUS_MATCH_MESSAGE_TYPE:
                        if (c->value_u8 != SD_BUS_MESSAGE_SIGNAL)
                                matches_name_change = false;

                        bloom_add_pair(bloom, "message-type", bus_message_type_to_string(c->value_u8));
                        using_bloom = true;
                        break;

                case BUS_MATCH_INTERFACE:
                        if (!streq(c->value_str, "org.freedesktop.DBus"))
                                matches_name_change = false;

                        bloom_add_pair(bloom, "interface", c->value_str);
                        using_bloom = true;
                        break;

                case BUS_MATCH_MEMBER:
                        if (!streq(c->value_str, "NameOwnerChanged"))
                                matches_name_change = false;

                        bloom_add_pair(bloom, "member", c->value_str);
                        using_bloom = true;
                        break;

                case BUS_MATCH_PATH:
                        if (!streq(c->value_str, "/org/freedesktop/DBus"))
                                matches_name_change = false;

                        bloom_add_pair(bloom, "path", c->value_str);
                        using_bloom = true;
                        break;

                case BUS_MATCH_PATH_NAMESPACE:
                        if (!streq(c->value_str, "/")) {
                                bloom_add_pair(bloom, "path-slash-prefix", c->value_str);
                                using_bloom = true;
                        }
                        break;

                case BUS_MATCH_ARG...BUS_MATCH_ARG_LAST: {
                        char buf[sizeof("arg")-1 + 2 + 1];

                        if (c->type - BUS_MATCH_ARG < 3)
                                name_change_arg[c->type - BUS_MATCH_ARG] = c->value_str;

                        snprintf(buf, sizeof(buf), "arg%u", c->type - BUS_MATCH_ARG);
                        bloom_add_pair(bloom, buf, c->value_str);
                        using_bloom = true;
                        break;
                }

                case BUS_MATCH_ARG_PATH...BUS_MATCH_ARG_PATH_LAST: {
                        char buf[sizeof("arg")-1 + 2 + sizeof("-slash-prefix")];

                        snprintf(buf, sizeof(buf), "arg%u-slash-prefix", c->type - BUS_MATCH_ARG_PATH);
                        bloom_add_pair(bloom, buf, c->value_str);
                        using_bloom = true;
                        break;
                }

                case BUS_MATCH_ARG_NAMESPACE...BUS_MATCH_ARG_NAMESPACE_LAST: {
                        char buf[sizeof("arg")-1 + 2 + sizeof("-dot-prefix")];

                        snprintf(buf, sizeof(buf), "arg%u-dot-prefix", c->type - BUS_MATCH_ARG_NAMESPACE);
                        bloom_add_pair(bloom, buf, c->value_str);
                        using_bloom = true;
                        break;
                }

                case BUS_MATCH_DESTINATION:
                        /* The bloom filter does not include
                           the destination, since it is only
                           available for broadcast messages
                           which do not carry a destination
                           since they are undirected. */
                        break;

                case BUS_MATCH_ROOT:
                case BUS_MATCH_VALUE:
                case BUS_MATCH_LEAF:
                case _BUS_MATCH_NODE_TYPE_MAX:
                case _BUS_MATCH_NODE_TYPE_INVALID:
                        assert_not_reached("Invalid match type?");
                }
        }

        if (using_bloom)
                sz += ALIGN8(offsetof(struct kdbus_item, data64) + BLOOM_SIZE);

        m = alloca0(sz);
        m->size = sz;
        m->cookie = cookie;
        m->owner_id = id;

        item = m->items;

        if (src_id != KDBUS_MATCH_ID_ANY) {
                item->size = offsetof(struct kdbus_item, id) + sizeof(uint64_t);
                item->type = KDBUS_ITEM_ID;
                item->id = src_id;
                item = KDBUS_ITEM_NEXT(item);
        }

        if (using_bloom) {
                item->size = offsetof(struct kdbus_item, data64) + BLOOM_SIZE;
                item->type = KDBUS_ITEM_BLOOM;
                memcpy(item->data64, bloom, BLOOM_SIZE);
                item = KDBUS_ITEM_NEXT(item);
        }

        if (sender) {
                item->size = offsetof(struct kdbus_item, str) + sender_length + 1;
                item->type = KDBUS_ITEM_NAME;
                memcpy(item->str, sender, sender_length + 1);
        }

        r = ioctl(bus->input_fd, KDBUS_CMD_MATCH_ADD, m);
        if (r < 0)
                return -errno;

        if (matches_name_change) {

                /* If this match could theoretically match
                 * NameOwnerChanged messages, we need to
                 * install a second non-bloom filter explitly
                 * for it */

                r = add_name_change_match(bus, cookie, name_change_arg[0], name_change_arg[1], name_change_arg[2]);
                if (r < 0)
                        return r;
        }

        return 0;
}

static int bus_add_match_internal_dbus1(
                sd_bus *bus,
                const char *match) {

        assert(bus);
        assert(match);

        return sd_bus_call_method(
                        bus,
                        "org.freedesktop.DBus",
                        "/org/freedesktop/DBus",
                        "org.freedesktop.DBus",
                        "AddMatch",
                        NULL,
                        NULL,
                        "s",
                        match);
}

int bus_add_match_internal(
                sd_bus *bus,
                const char *match,
                struct bus_match_component *components,
                unsigned n_components,
                uint64_t cookie) {

        assert(bus);
        assert(match);

        if (bus->is_kernel)
                return bus_add_match_internal_kernel(bus, 0, components, n_components, cookie);
        else
                return bus_add_match_internal_dbus1(bus, match);
}

int bus_remove_match_internal_kernel(
                sd_bus *bus,
                uint64_t id,
                uint64_t cookie) {

        struct kdbus_cmd_match m;
        int r;

        assert(bus);

        zero(m);
        m.size = offsetof(struct kdbus_cmd_match, items);
        m.cookie = cookie;
        m.owner_id = id;

        r = ioctl(bus->input_fd, KDBUS_CMD_MATCH_REMOVE, &m);
        if (r < 0)
                return -errno;

        return 0;
}

static int bus_remove_match_internal_dbus1(
                sd_bus *bus,
                const char *match) {

        assert(bus);
        assert(match);

        return sd_bus_call_method(
                        bus,
                        "org.freedesktop.DBus",
                        "/org/freedesktop/DBus",
                        "org.freedesktop.DBus",
                        "RemoveMatch",
                        NULL,
                        NULL,
                        "s",
                        match);
}

int bus_remove_match_internal(
                sd_bus *bus,
                const char *match,
                uint64_t cookie) {

        assert(bus);
        assert(match);

        if (bus->is_kernel)
                return bus_remove_match_internal_kernel(bus, 0, cookie);
        else
                return bus_remove_match_internal_dbus1(bus, match);
}

_public_ int sd_bus_get_owner_machine_id(sd_bus *bus, const char *name, sd_id128_t *machine) {
        _cleanup_bus_message_unref_ sd_bus_message *reply = NULL, *m = NULL;
        const char *mid;
        int r;

        assert_return(bus, -EINVAL);
        assert_return(name, -EINVAL);
        assert_return(machine, -EINVAL);
        assert_return(BUS_IS_OPEN(bus->state), -ENOTCONN);
        assert_return(!bus_pid_changed(bus), -ECHILD);
        assert_return(service_name_is_valid(name), -EINVAL);

        if (streq_ptr(name, bus->unique_name))
                return sd_id128_get_machine(machine);

        r = sd_bus_message_new_method_call(
                        bus,
                        name,
                        "/",
                        "org.freedesktop.DBus.Peer",
                        "GetMachineId", &m);
        if (r < 0)
                return r;

        r = sd_bus_message_set_no_auto_start(m, true);
        if (r < 0)
                return r;

        r = sd_bus_call(bus, m, 0, NULL, &reply);
        if (r < 0)
                return r;

        r = sd_bus_message_read(reply, "s", &mid);
        if (r < 0)
                return r;

        return sd_id128_from_string(mid, machine);
}