/*-*- Mode: C; c-basic-offset: 8; indent-tabs-mode: nil -*-*/ /*** This file is part of systemd. Copyright 2013 Lennart Poettering systemd is free software; you can redistribute it and/or modify it under the terms of the GNU Lesser General Public License as published by the Free Software Foundation; either version 2.1 of the License, or (at your option) any later version. systemd is distributed in the hope that it will be useful, but WITHOUT ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU Lesser General Public License for more details. You should have received a copy of the GNU Lesser General Public License along with systemd; If not, see <http://www.gnu.org/licenses/>. ***/ #ifdef HAVE_VALGRIND_MEMCHECK_H #include <valgrind/memcheck.h> #endif #include <stddef.h> #include <errno.h> #include "strv.h" #include "sd-bus.h" #include "bus-internal.h" #include "bus-message.h" #include "bus-control.h" int sd_bus_get_unique_name(sd_bus *bus, const char **unique) { int r; if (!bus) return -EINVAL; if (!unique) return -EINVAL; r = bus_ensure_running(bus); if (r < 0) return r; *unique = bus->unique_name; return 0; } int sd_bus_request_name(sd_bus *bus, const char *name, int flags) { _cleanup_bus_message_unref_ sd_bus_message *reply = NULL; uint32_t ret; int r; if (!bus) return -EINVAL; if (!name) return -EINVAL; if (!bus->bus_client) return -EINVAL; if (bus->is_kernel) { struct kdbus_cmd_name *n; size_t l; l = strlen(name); n = alloca0(offsetof(struct kdbus_cmd_name, name) + l + 1); n->size = offsetof(struct kdbus_cmd_name, name) + l + 1; n->name_flags = flags; memcpy(n->name, name, l+1); #ifdef HAVE_VALGRIND_MEMCHECK_H VALGRIND_MAKE_MEM_DEFINED(n, n->size); #endif r = ioctl(bus->input_fd, KDBUS_CMD_NAME_ACQUIRE, n); if (r < 0) return -errno; return n->name_flags; } else { r = sd_bus_call_method( bus, "org.freedesktop.DBus", "/", "org.freedesktop.DBus", "RequestName", NULL, &reply, "su", name, flags); if (r < 0) return r; r = sd_bus_message_read(reply, "u", &ret); if (r < 0) return r; return ret; } } int sd_bus_release_name(sd_bus *bus, const char *name) { _cleanup_bus_message_unref_ sd_bus_message *reply = NULL; uint32_t ret; int r; if (!bus) return -EINVAL; if (!name) return -EINVAL; if (!bus->bus_client) return -EINVAL; if (bus->is_kernel) { struct kdbus_cmd_name *n; size_t l; l = strlen(name); n = alloca0(offsetof(struct kdbus_cmd_name, name) + l + 1); n->size = offsetof(struct kdbus_cmd_name, name) + l + 1; memcpy(n->name, name, l+1); #ifdef HAVE_VALGRIND_MEMCHECK_H VALGRIND_MAKE_MEM_DEFINED(n, n->size); #endif r = ioctl(bus->input_fd, KDBUS_CMD_NAME_RELEASE, n); if (r < 0) return -errno; return n->name_flags; } else { r = sd_bus_call_method( bus, "org.freedesktop.DBus", "/", "org.freedesktop.DBus", "ReleaseName", NULL, &reply, "s", name); if (r < 0) return r; r = sd_bus_message_read(reply, "u", &ret); if (r < 0) return r; } return ret; } int sd_bus_list_names(sd_bus *bus, char ***l) { _cleanup_bus_message_unref_ sd_bus_message *reply1 = NULL, *reply2 = NULL; char **x = NULL; int r; if (!bus) return -EINVAL; if (!l) return -EINVAL; r = sd_bus_call_method( bus, "org.freedesktop.DBus", "/", "org.freedesktop.DBus", "ListNames", NULL, &reply1, NULL); if (r < 0) return r; r = sd_bus_call_method( bus, "org.freedesktop.DBus", "/", "org.freedesktop.DBus", "ListActivatableNames", NULL, &reply2, NULL); if (r < 0) return r; r = bus_message_read_strv_extend(reply1, &x); if (r < 0) { strv_free(x); return r; } r = bus_message_read_strv_extend(reply2, &x); if (r < 0) { strv_free(x); return r; } *l = strv_uniq(x); return 0; } int sd_bus_get_owner(sd_bus *bus, const char *name, char **owner) { _cleanup_bus_message_unref_ sd_bus_message *reply = NULL; const char *found; int r; if (!bus) return -EINVAL; if (!name) return -EINVAL; r = sd_bus_call_method( bus, "org.freedesktop.DBus", "/", "org.freedesktop.DBus", "GetNameOwner", NULL, &reply, "s", name); if (r < 0) return r; r = sd_bus_message_read(reply, "s", &found); if (r < 0) return r; if (owner) { char *t; t = strdup(found); if (!t) return -ENOMEM; *owner = t; } return 0; } int sd_bus_get_owner_uid(sd_bus *bus, const char *name, uid_t *uid) { _cleanup_bus_message_unref_ sd_bus_message *reply = NULL; uint32_t u; int r; if (!bus) return -EINVAL; if (!name) return -EINVAL; if (!uid) return -EINVAL; r = sd_bus_call_method( bus, "org.freedesktop.DBus", "/", "org.freedesktop.DBus", "GetConnectionUnixUser", NULL, &reply, "s", name); if (r < 0) return r; r = sd_bus_message_read(reply, "u", &u); if (r < 0) return r; *uid = (uid_t) u; return 0; } int sd_bus_get_owner_pid(sd_bus *bus, const char *name, pid_t *pid) { _cleanup_bus_message_unref_ sd_bus_message *reply = NULL; uint32_t u; int r; if (!bus) return -EINVAL; if (!name) return -EINVAL; if (!pid) return -EINVAL; r = sd_bus_call_method( bus, "org.freedesktop.DBus", "/", "org.freedesktop.DBus", "GetConnectionUnixProcessID", NULL, &reply, "s", name); if (r < 0) return r; r = sd_bus_message_read(reply, "u", &u); if (r < 0) return r; if (u == 0) return -EIO; *pid = (uid_t) u; return 0; } int bus_add_match_internal(sd_bus *bus, const char *match) { assert(bus); assert(match); return sd_bus_call_method( bus, "org.freedesktop.DBus", "/", "org.freedesktop.DBus", "AddMatch", NULL, NULL, "s", match); } int bus_remove_match_internal(sd_bus *bus, const char *match) { assert(bus); assert(match); return sd_bus_call_method( bus, "org.freedesktop.DBus", "/", "org.freedesktop.DBus", "RemoveMatch", NULL, NULL, "s", match); } 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; const char *mid; int r; if (!bus) return -EINVAL; if (!name) return -EINVAL; if (streq_ptr(name, bus->unique_name)) return sd_id128_get_machine(machine); r = sd_bus_call_method(bus, name, "/", "org.freedesktop.DBus.Peer", "GetMachineId", NULL, &reply, NULL); 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); }