1 files changed, 101 insertions, 0 deletions
diff --git a/src/core/nm-priv-helper-call.c b/src/core/nm-priv-helper-call.c
new file mode 100644
index 00000000..06249ece
--- /dev/null
+++ b/src/core/nm-priv-helper-call.c
@@ -0,0 +1,101 @@
+/* SPDX-License-Identifier: LGPL-2.1-or-later */
+
+#include "src/core/nm-default-daemon.h"
+
+#include "nm-priv-helper-call.h"
+
+#include <gio/gunixfdlist.h>
+
+#include "nm-dbus-manager.h"
+
+/*****************************************************************************/
+
+static void
+_nm_priv_helper_call_get_fd_cb(GObject *source, GAsyncResult *res, gpointer user_data)
+{
+    NMPrivHelperCallGetFDCallback callback;
+    gpointer                      callback_data;
+    gs_unref_variant GVariant *ret       = NULL;
+    gs_free_error GError *error          = NULL;
+    gs_unref_object GUnixFDList *fd_list = NULL;
+    gs_free int *                fd_arr  = NULL;
+
+    nm_utils_user_data_unpack(user_data, &callback, &callback_data);
+
+    ret = g_dbus_connection_call_with_unix_fd_list_finish(G_DBUS_CONNECTION(source),
+                                                          &fd_list,
+                                                          res,
+                                                          &error);
+
+    if (error) {
+        callback(-1, error, callback_data);
+        return;
+    }
+
+    if (!fd_list || g_unix_fd_list_get_length(fd_list) != 1) {
+        nm_utils_error_set(&error,
+                           NM_UTILS_ERROR_UNKNOWN,
+                           "Unexpectedly not one FD is returned by nm-priv-helper GetFD()");
+        callback(-1, error, callback_data);
+        return;
+    }
+
+    fd_arr = g_unix_fd_list_steal_fds(fd_list, NULL);
+
+    /* we transfer ownership of the file descriptor! */
+    callback(fd_arr[0], NULL, callback_data);
+}
+
+static gboolean
+_nm_priv_helper_call_get_fd_fail_on_idle(gpointer user_data)
+{
+    gs_unref_object GCancellable *cancellable = NULL;
+    NMPrivHelperCallGetFDCallback callback;
+    gpointer                      callback_data;
+    gs_free_error GError *error = NULL;
+
+    nm_utils_user_data_unpack(user_data, &cancellable, &callback, &callback_data);
+
+    if (!g_cancellable_set_error_if_cancelled(cancellable, &error))
+        nm_utils_error_set(&error,
+                           NM_UTILS_ERROR_UNKNOWN,
+                           "Cannot talk to nm-priv-helper without D-Bus");
+
+    callback(-1, error, callback_data);
+    return G_SOURCE_REMOVE;
+}
+
+void
+nm_priv_helper_call_get_fd(NMPrivHelperGetFDType         fd_type,
+                           GCancellable *                cancellable,
+                           NMPrivHelperCallGetFDCallback callback,
+                           gpointer                      user_data)
+{
+    GDBusConnection *dbus_connection;
+
+    nm_assert(NM_IN_SET(fd_type, NM_PRIV_HELPER_GET_FD_TYPE_OVSDB_SOCKET));
+    nm_assert(!cancellable || G_IS_CANCELLABLE(cancellable));
+    nm_assert(callback);
+
+    dbus_connection = NM_MAIN_DBUS_CONNECTION_GET;
+
+    if (!dbus_connection) {
+        nm_g_idle_add(_nm_priv_helper_call_get_fd_fail_on_idle,
+                      nm_utils_user_data_pack(g_object_ref(cancellable), callback, user_data));
+        return;
+    }
+
+    g_dbus_connection_call_with_unix_fd_list(dbus_connection,
+                                             NM_PRIV_HELPER_DBUS_BUS_NAME,
+                                             NM_PRIV_HELPER_DBUS_OBJECT_PATH,
+                                             NM_PRIV_HELPER_DBUS_IFACE_NAME,
+                                             "GetFD",
+                                             g_variant_new("(u)", fd_type),
+                                             G_VARIANT_TYPE("()"),
+                                             G_DBUS_CALL_FLAGS_NONE,
+                                             10000,
+                                             NULL,
+                                             cancellable,
+                                             _nm_priv_helper_call_get_fd_cb,
+                                             nm_utils_user_data_pack(callback, user_data));
+}