Adding upstream version 2.9.4.upstream/2.9.4

Signed-off-by: Daniel Baumann <daniel.baumann@progress-linux.org>

1 files changed, 188 insertions, 0 deletions

diff --git a/src/sbus/connection/sbus_dbus.c b/src/sbus/connection/sbus_dbus.c
new file mode 100644
index 0000000..69b18bc
--- /dev/null
+++ b/src/sbus/connection/sbus_dbus.c
@@ -0,0 +1,188 @@
+/*
+    Authors:
+        Pavel Březina <pbrezina@redhat.com>
+        Stephen Gallagher <sgallagh@redhat.com>
+        Simo Sorce <ssorce@redhat.com>
+
+    Copyright (C) 2017 Red Hat
+
+    This program is free software; you can redistribute it and/or modify
+    it under the terms of the GNU General Public License as published by
+    the Free Software Foundation; either version 3 of the License, or
+    (at your option) any later version.
+
+    This program 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 General Public License for more details.
+
+    You should have received a copy of the GNU General Public License
+    along with this program.  If not, see <http://www.gnu.org/licenses/>.
+*/
+
+#include <errno.h>
+#include <talloc.h>
+#include <dbus/dbus.h>
+
+#include "util/util.h"
+#include "sbus/connection/sbus_dbus_private.h"
+
+static errno_t
+sbus_dbus_request_name(DBusConnection *dbus_conn, const char *name)
+{
+    DBusError dbus_error;
+    errno_t ret;
+    int flags;
+    int dbret;
+
+    dbus_error_init(&dbus_error);
+
+    /* We are interested only in being the primary owner of this name. */
+    flags = DBUS_NAME_FLAG_DO_NOT_QUEUE;
+
+    dbret = dbus_bus_request_name(dbus_conn, name, flags, &dbus_error);
+    if (dbret == -1) {
+        DEBUG(SSSDBG_CRIT_FAILURE, "Unable to request name '%s' on the system"
+              " bus [%s]: %s\n", name, dbus_error.name, dbus_error.message);
+        if (dbus_error_has_name(&dbus_error, DBUS_ERROR_ACCESS_DENIED)) {
+            DEBUG(SSSDBG_FATAL_FAILURE,
+                  "Access denied - check dbus service configuration.\n");
+            sss_log(SSS_LOG_CRIT, "SSSD dbus service can't acquire bus name"
+                    " - check dbus service configuration.");
+        }
+        ret = EIO;
+        goto done;
+    } else if (dbret != DBUS_REQUEST_NAME_REPLY_PRIMARY_OWNER) {
+        DEBUG(SSSDBG_CRIT_FAILURE, "Unable to request name on the "
+              "system bus [%d]\n", dbret);
+        ret = EIO;
+        goto done;
+    }
+
+    ret = EOK;
+
+done:
+    dbus_error_free(&dbus_error);
+
+    return ret;
+}
+
+DBusConnection *
+sbus_dbus_connect_bus(DBusBusType bus, const char *name)
+{
+    DBusConnection *dbus_conn;
+    DBusError dbus_error;
+    const char *busname = "not-set";
+    errno_t ret;
+
+    switch (bus) {
+    case DBUS_BUS_SESSION:
+        busname = "session";
+        break;
+    case DBUS_BUS_SYSTEM:
+        busname = "system";
+        break;
+    case DBUS_BUS_STARTER:
+        busname = "starter";
+        break;
+    }
+
+    dbus_error_init(&dbus_error);
+
+    /* Connect to the system bus. */
+    dbus_conn = dbus_bus_get(bus, &dbus_error);
+    if (dbus_conn == NULL) {
+        DEBUG(SSSDBG_CRIT_FAILURE, "Unable to connect to %s bus [%s]: %s\n",
+              busname, dbus_error.name, dbus_error.message);
+        ret = EIO;
+        goto done;
+    }
+
+    if (name != NULL) {
+        /* Request a well-known name. */
+        ret = sbus_dbus_request_name(dbus_conn, name);
+        if (ret != EOK) {
+            dbus_connection_unref(dbus_conn);
+            goto done;
+        }
+    }
+
+    if (name == NULL) {
+        DEBUG(SSSDBG_TRACE_FUNC, "Connected to %s bus as anonymous\n", busname);
+    } else {
+        DEBUG(SSSDBG_TRACE_FUNC, "Connected to %s bus as %s\n", busname, name);
+    }
+
+    ret = EOK;
+
+done:
+    dbus_error_free(&dbus_error);
+
+    if (ret != EOK) {
+        return NULL;
+    }
+
+    return dbus_conn;
+}
+
+DBusConnection *
+sbus_dbus_connect_address(const char *address, const char *name, bool init)
+{
+    DBusConnection *dbus_conn;
+    DBusError dbus_error;
+    dbus_bool_t dbret;
+    errno_t ret;
+
+    if (address == NULL) {
+        DEBUG(SSSDBG_CRIT_FAILURE, "Can not connect to an empty address!\n");
+        return NULL;
+    }
+
+    dbus_error_init(&dbus_error);
+
+    dbus_conn = dbus_connection_open(address, &dbus_error);
+    if (dbus_conn == NULL) {
+        DEBUG(SSSDBG_CRIT_FAILURE, "Unable to connect to %s [%s]: %s\n",
+              address, dbus_error.name, dbus_error.message);
+        ret = EIO;
+        goto done;
+    }
+
+    if (!init) {
+        ret = EOK;
+        goto done;
+    }
+
+    dbret = dbus_bus_register(dbus_conn, &dbus_error);
+    if (!dbret) {
+        DEBUG(SSSDBG_CRIT_FAILURE, "Unable to register to %s [%s]: %s\n",
+              address, dbus_error.name, dbus_error.message);
+        ret = EIO;
+        goto done;
+    }
+
+    /* Request a well-known name. */
+    if (name != NULL) {
+        ret = sbus_dbus_request_name(dbus_conn, name);
+        if (ret != EOK) {
+            goto done;
+        }
+    }
+
+    if (name == NULL) {
+        DEBUG(SSSDBG_TRACE_FUNC, "Connected to %s bus as anonymous\n", address);
+    } else {
+        DEBUG(SSSDBG_TRACE_FUNC, "Connected to %s bus as %s\n", address, name);
+    }
+
+    ret = EOK;
+
+done:
+    dbus_error_free(&dbus_error);
+    if (ret != EOK && dbus_conn != NULL) {
+        dbus_connection_unref(dbus_conn);
+        dbus_conn = NULL;
+    }
+
+    return dbus_conn;
+}