New upstream version 1.29.90 upstream/1.29.90

1 files changed, 504 insertions, 0 deletions

diff --git a/src/core/devices/nm-device-infiniband.c b/src/core/devices/nm-device-infiniband.c
new file mode 100644
index 00000000..f54ffcf0
--- /dev/null
+++ b/src/core/devices/nm-device-infiniband.c
@@ -0,0 +1,504 @@
+/* SPDX-License-Identifier: GPL-2.0-or-later */
+/*
+ * Copyright (C) 2011 - 2018 Red Hat, Inc.
+ */
+
+#include "src/core/nm-default-daemon.h"
+
+#include "nm-device-infiniband.h"
+
+#include <linux/if.h>
+#include <linux/if_infiniband.h>
+
+#include "NetworkManagerUtils.h"
+#include "nm-device-private.h"
+#include "nm-act-request.h"
+#include "nm-ip4-config.h"
+#include "platform/nm-platform.h"
+#include "nm-device-factory.h"
+#include "nm-core-internal.h"
+
+#define NM_DEVICE_INFINIBAND_IS_PARTITION "is-partition"
+
+/*****************************************************************************/
+
+NM_GOBJECT_PROPERTIES_DEFINE_BASE(PROP_IS_PARTITION, );
+
+typedef struct {
+    gboolean is_partition;
+    int      parent_ifindex;
+    int      p_key;
+} NMDeviceInfinibandPrivate;
+
+struct _NMDeviceInfiniband {
+    NMDevice                  parent;
+    NMDeviceInfinibandPrivate _priv;
+};
+
+struct _NMDeviceInfinibandClass {
+    NMDeviceClass parent;
+};
+
+G_DEFINE_TYPE(NMDeviceInfiniband, nm_device_infiniband, NM_TYPE_DEVICE)
+
+#define NM_DEVICE_INFINIBAND_GET_PRIVATE(self) \
+    _NM_GET_PRIVATE(self, NMDeviceInfiniband, NM_IS_DEVICE_INFINIBAND, NMDevice)
+
+/*****************************************************************************/
+
+static NMDeviceCapabilities
+get_generic_capabilities(NMDevice *device)
+{
+    guint32 caps = NM_DEVICE_CAP_CARRIER_DETECT;
+
+    if (NM_DEVICE_INFINIBAND_GET_PRIVATE(device)->is_partition)
+        caps |= NM_DEVICE_CAP_IS_SOFTWARE;
+
+    return caps;
+}
+
+static NMActStageReturn
+act_stage1_prepare(NMDevice *device, NMDeviceStateReason *out_failure_reason)
+{
+    nm_auto_close int    dirfd = -1;
+    NMSettingInfiniband *s_infiniband;
+    char                 ifname_verified[IFNAMSIZ];
+    const char *         transport_mode;
+    gboolean             ok;
+
+    s_infiniband = nm_device_get_applied_setting(device, NM_TYPE_SETTING_INFINIBAND);
+
+    g_return_val_if_fail(s_infiniband, NM_ACT_STAGE_RETURN_FAILURE);
+
+    transport_mode = nm_setting_infiniband_get_transport_mode(s_infiniband);
+
+    dirfd = nm_platform_sysctl_open_netdir(nm_device_get_platform(device),
+                                           nm_device_get_ifindex(device),
+                                           ifname_verified);
+    if (dirfd < 0) {
+        if (nm_streq(transport_mode, "datagram"))
+            return NM_ACT_STAGE_RETURN_SUCCESS;
+        else {
+            NM_SET_OUT(out_failure_reason, NM_DEVICE_STATE_REASON_INFINIBAND_MODE);
+            return NM_ACT_STAGE_RETURN_FAILURE;
+        }
+    }
+
+    /* With some drivers the interface must be down to set transport mode */
+    nm_device_take_down(device, TRUE);
+    ok = nm_platform_sysctl_set(nm_device_get_platform(device),
+                                NMP_SYSCTL_PATHID_NETDIR(dirfd, ifname_verified, "mode"),
+                                transport_mode);
+    nm_device_bring_up(device, TRUE, NULL);
+
+    if (!ok) {
+        NM_SET_OUT(out_failure_reason, NM_DEVICE_STATE_REASON_CONFIG_FAILED);
+        return NM_ACT_STAGE_RETURN_FAILURE;
+    }
+
+    return NM_ACT_STAGE_RETURN_SUCCESS;
+}
+
+static guint32
+get_configured_mtu(NMDevice *device, NMDeviceMtuSource *out_source, gboolean *out_force)
+{
+    return nm_device_get_configured_mtu_from_connection(device,
+                                                        NM_TYPE_SETTING_INFINIBAND,
+                                                        out_source);
+}
+
+static gboolean
+check_connection_compatible(NMDevice *device, NMConnection *connection, GError **error)
+{
+    NMSettingInfiniband *s_infiniband;
+
+    if (!NM_DEVICE_CLASS(nm_device_infiniband_parent_class)
+             ->check_connection_compatible(device, connection, error))
+        return FALSE;
+
+    if (nm_device_is_real(device)) {
+        const char *mac;
+        const char *hw_addr;
+
+        s_infiniband = nm_connection_get_setting_infiniband(connection);
+
+        mac = nm_setting_infiniband_get_mac_address(s_infiniband);
+        if (mac) {
+            hw_addr = nm_device_get_permanent_hw_address(device);
+            if (!hw_addr || !nm_utils_hwaddr_matches(mac, -1, hw_addr, -1)) {
+                nm_utils_error_set_literal(error,
+                                           NM_UTILS_ERROR_CONNECTION_AVAILABLE_TEMPORARY,
+                                           "MAC address mismatches");
+                return FALSE;
+            }
+        }
+    }
+
+    return TRUE;
+}
+
+static gboolean
+complete_connection(NMDevice *           device,
+                    NMConnection *       connection,
+                    const char *         specific_object,
+                    NMConnection *const *existing_connections,
+                    GError **            error)
+{
+    NMSettingInfiniband *s_infiniband;
+
+    s_infiniband = nm_connection_get_setting_infiniband(connection);
+    if (!s_infiniband) {
+        s_infiniband = (NMSettingInfiniband *) nm_setting_infiniband_new();
+        nm_connection_add_setting(connection, NM_SETTING(s_infiniband));
+    }
+
+    nm_utils_complete_generic(
+        nm_device_get_platform(device),
+        connection,
+        NM_SETTING_INFINIBAND_SETTING_NAME,
+        existing_connections,
+        NULL,
+        _("InfiniBand connection"),
+        NULL,
+        nm_setting_infiniband_get_mac_address(s_infiniband) ? NULL : nm_device_get_iface(device),
+        TRUE);
+
+    if (!nm_setting_infiniband_get_transport_mode(s_infiniband))
+        g_object_set(G_OBJECT(s_infiniband),
+                     NM_SETTING_INFINIBAND_TRANSPORT_MODE,
+                     "datagram",
+                     NULL);
+
+    return TRUE;
+}
+
+static void
+update_connection(NMDevice *device, NMConnection *connection)
+{
+    NMSettingInfiniband *s_infiniband   = nm_connection_get_setting_infiniband(connection);
+    const char *         mac            = nm_device_get_permanent_hw_address(device);
+    const char *         transport_mode = "datagram";
+    int                  ifindex;
+
+    if (!s_infiniband) {
+        s_infiniband = (NMSettingInfiniband *) nm_setting_infiniband_new();
+        nm_connection_add_setting(connection, (NMSetting *) s_infiniband);
+    }
+
+    if (mac && !nm_utils_hwaddr_matches(mac, -1, NULL, INFINIBAND_ALEN))
+        g_object_set(s_infiniband, NM_SETTING_INFINIBAND_MAC_ADDRESS, mac, NULL);
+
+    ifindex = nm_device_get_ifindex(device);
+    if (ifindex > 0) {
+        if (!nm_platform_link_infiniband_get_properties(nm_device_get_platform(device),
+                                                        ifindex,
+                                                        NULL,
+                                                        NULL,
+                                                        &transport_mode))
+            transport_mode = "datagram";
+    }
+    g_object_set(G_OBJECT(s_infiniband),
+                 NM_SETTING_INFINIBAND_TRANSPORT_MODE,
+                 transport_mode,
+                 NULL);
+}
+
+static gboolean
+can_reapply_change(NMDevice *  device,
+                   const char *setting_name,
+                   NMSetting * s_old,
+                   NMSetting * s_new,
+                   GHashTable *diffs,
+                   GError **   error)
+{
+    NMDeviceClass *device_class;
+
+    if (nm_streq(setting_name, NM_SETTING_INFINIBAND_SETTING_NAME)) {
+        return nm_device_hash_check_invalid_keys(
+            diffs,
+            NM_SETTING_INFINIBAND_SETTING_NAME,
+            error,
+            NM_SETTING_INFINIBAND_MTU); /* reapplied with IP config */
+    }
+
+    device_class = NM_DEVICE_CLASS(nm_device_infiniband_parent_class);
+    return device_class->can_reapply_change(device, setting_name, s_old, s_new, diffs, error);
+}
+
+static gboolean
+create_and_realize(NMDevice *             device,
+                   NMConnection *         connection,
+                   NMDevice *             parent,
+                   const NMPlatformLink **out_plink,
+                   GError **              error)
+{
+    NMDeviceInfinibandPrivate *priv = NM_DEVICE_INFINIBAND_GET_PRIVATE(device);
+    NMSettingInfiniband *      s_infiniband;
+    int                        r;
+
+    s_infiniband = nm_connection_get_setting_infiniband(connection);
+    g_assert(s_infiniband);
+
+    /* Can only create partitions at this time */
+    priv->p_key = nm_setting_infiniband_get_p_key(s_infiniband);
+    if (priv->p_key < 0) {
+        g_set_error_literal(error,
+                            NM_DEVICE_ERROR,
+                            NM_DEVICE_ERROR_FAILED,
+                            "only InfiniBand partitions can be created");
+        return FALSE;
+    }
+
+    if (!parent) {
+        g_set_error(error,
+                    NM_DEVICE_ERROR,
+                    NM_DEVICE_ERROR_MISSING_DEPENDENCIES,
+                    "InfiniBand partitions can not be created without a parent interface");
+        return FALSE;
+    }
+
+    if (!NM_IS_DEVICE_INFINIBAND(parent)) {
+        g_set_error(error,
+                    NM_DEVICE_ERROR,
+                    NM_DEVICE_ERROR_MISSING_DEPENDENCIES,
+                    "Parent interface %s must be an InfiniBand interface",
+                    nm_device_get_iface(parent));
+        return FALSE;
+    }
+
+    priv->parent_ifindex = nm_device_get_ifindex(parent);
+    if (priv->parent_ifindex <= 0) {
+        g_set_error(error,
+                    NM_DEVICE_ERROR,
+                    NM_DEVICE_ERROR_MISSING_DEPENDENCIES,
+                    "failed to get InfiniBand parent %s ifindex",
+                    nm_device_get_iface(parent));
+        return FALSE;
+    }
+
+    r = nm_platform_link_infiniband_add(nm_device_get_platform(device),
+                                        priv->parent_ifindex,
+                                        priv->p_key,
+                                        out_plink);
+    if (r < 0) {
+        g_set_error(error,
+                    NM_DEVICE_ERROR,
+                    NM_DEVICE_ERROR_CREATION_FAILED,
+                    "Failed to create InfiniBand P_Key interface '%s' for '%s': %s",
+                    nm_device_get_iface(device),
+                    nm_connection_get_id(connection),
+                    nm_strerror(r));
+        return FALSE;
+    }
+
+    priv->is_partition = TRUE;
+    return TRUE;
+}
+
+static gboolean
+unrealize(NMDevice *device, GError **error)
+{
+    NMDeviceInfinibandPrivate *priv;
+    int                        r;
+
+    g_return_val_if_fail(NM_IS_DEVICE_INFINIBAND(device), FALSE);
+
+    priv = NM_DEVICE_INFINIBAND_GET_PRIVATE(device);
+
+    if (priv->p_key < 0) {
+        g_set_error(error,
+                    NM_DEVICE_ERROR,
+                    NM_DEVICE_ERROR_FAILED,
+                    "Only InfiniBand partitions can be removed");
+        return FALSE;
+    }
+
+    r = nm_platform_link_infiniband_delete(nm_device_get_platform(device),
+                                           priv->parent_ifindex,
+                                           priv->p_key);
+    if (r < 0) {
+        g_set_error(error,
+                    NM_DEVICE_ERROR,
+                    NM_DEVICE_ERROR_CREATION_FAILED,
+                    "Failed to remove InfiniBand P_Key interface '%s': %s",
+                    nm_device_get_iface(device),
+                    nm_strerror(r));
+        return FALSE;
+    }
+
+    return TRUE;
+}
+
+/*****************************************************************************/
+
+static void
+get_property(GObject *object, guint prop_id, GValue *value, GParamSpec *pspec)
+{
+    switch (prop_id) {
+    case PROP_IS_PARTITION:
+        g_value_set_boolean(value, NM_DEVICE_INFINIBAND_GET_PRIVATE(object)->is_partition);
+        break;
+    default:
+        G_OBJECT_WARN_INVALID_PROPERTY_ID(object, prop_id, pspec);
+        break;
+    }
+}
+
+static void
+set_property(GObject *object, guint prop_id, const GValue *value, GParamSpec *pspec)
+{
+    switch (prop_id) {
+    case PROP_IS_PARTITION:
+        NM_DEVICE_INFINIBAND_GET_PRIVATE(object)->is_partition = g_value_get_boolean(value);
+        break;
+    default:
+        G_OBJECT_WARN_INVALID_PROPERTY_ID(object, prop_id, pspec);
+        break;
+    }
+}
+
+/*****************************************************************************/
+
+static void
+nm_device_infiniband_init(NMDeviceInfiniband *self)
+{}
+
+static const NMDBusInterfaceInfoExtended interface_info_device_infiniband = {
+    .parent = NM_DEFINE_GDBUS_INTERFACE_INFO_INIT(
+        NM_DBUS_INTERFACE_DEVICE_INFINIBAND,
+        .signals    = NM_DEFINE_GDBUS_SIGNAL_INFOS(&nm_signal_info_property_changed_legacy, ),
+        .properties = NM_DEFINE_GDBUS_PROPERTY_INFOS(
+            NM_DEFINE_DBUS_PROPERTY_INFO_EXTENDED_READABLE_L("HwAddress",
+                                                             "s",
+                                                             NM_DEVICE_HW_ADDRESS),
+            NM_DEFINE_DBUS_PROPERTY_INFO_EXTENDED_READABLE_L("Carrier",
+                                                             "b",
+                                                             NM_DEVICE_CARRIER), ), ),
+    .legacy_property_changed = TRUE,
+};
+
+static void
+nm_device_infiniband_class_init(NMDeviceInfinibandClass *klass)
+{
+    GObjectClass *     object_class      = G_OBJECT_CLASS(klass);
+    NMDBusObjectClass *dbus_object_class = NM_DBUS_OBJECT_CLASS(klass);
+    NMDeviceClass *    device_class      = NM_DEVICE_CLASS(klass);
+
+    object_class->get_property = get_property;
+    object_class->set_property = set_property;
+
+    dbus_object_class->interface_infos = NM_DBUS_INTERFACE_INFOS(&interface_info_device_infiniband);
+
+    device_class->connection_type_supported        = NM_SETTING_INFINIBAND_SETTING_NAME;
+    device_class->connection_type_check_compatible = NM_SETTING_INFINIBAND_SETTING_NAME;
+    device_class->link_types = NM_DEVICE_DEFINE_LINK_TYPES(NM_LINK_TYPE_INFINIBAND);
+
+    device_class->can_reapply_change          = can_reapply_change;
+    device_class->create_and_realize          = create_and_realize;
+    device_class->unrealize                   = unrealize;
+    device_class->get_generic_capabilities    = get_generic_capabilities;
+    device_class->check_connection_compatible = check_connection_compatible;
+    device_class->complete_connection         = complete_connection;
+    device_class->update_connection           = update_connection;
+
+    device_class->act_stage1_prepare = act_stage1_prepare;
+    device_class->get_configured_mtu = get_configured_mtu;
+
+    obj_properties[PROP_IS_PARTITION] =
+        g_param_spec_boolean(NM_DEVICE_INFINIBAND_IS_PARTITION,
+                             "",
+                             "",
+                             FALSE,
+                             G_PARAM_READWRITE | G_PARAM_CONSTRUCT_ONLY | G_PARAM_STATIC_STRINGS);
+
+    g_object_class_install_properties(object_class, _PROPERTY_ENUMS_LAST, obj_properties);
+}
+
+/*****************************************************************************/
+
+#define NM_TYPE_INFINIBAND_DEVICE_FACTORY (nm_infiniband_device_factory_get_type())
+#define NM_INFINIBAND_DEVICE_FACTORY(obj)                          \
+    (G_TYPE_CHECK_INSTANCE_CAST((obj),                             \
+                                NM_TYPE_INFINIBAND_DEVICE_FACTORY, \
+                                NMInfinibandDeviceFactory))
+
+static NMDevice *
+create_device(NMDeviceFactory *     factory,
+              const char *          iface,
+              const NMPlatformLink *plink,
+              NMConnection *        connection,
+              gboolean *            out_ignore)
+{
+    gboolean is_partition = FALSE;
+
+    if (plink)
+        is_partition = (plink->parent > 0 || plink->parent == NM_PLATFORM_LINK_OTHER_NETNS);
+    else if (connection) {
+        NMSettingInfiniband *s_infiniband;
+
+        s_infiniband = nm_connection_get_setting_infiniband(connection);
+        g_return_val_if_fail(s_infiniband, NULL);
+        is_partition = !!nm_setting_infiniband_get_parent(s_infiniband)
+                       || (nm_setting_infiniband_get_p_key(s_infiniband) >= 0
+                           && nm_setting_infiniband_get_mac_address(s_infiniband));
+    }
+
+    return g_object_new(NM_TYPE_DEVICE_INFINIBAND,
+                        NM_DEVICE_IFACE,
+                        iface,
+                        NM_DEVICE_TYPE_DESC,
+                        "InfiniBand",
+                        NM_DEVICE_DEVICE_TYPE,
+                        NM_DEVICE_TYPE_INFINIBAND,
+                        NM_DEVICE_LINK_TYPE,
+                        NM_LINK_TYPE_INFINIBAND,
+                        /* NOTE: Partition should probably be a different link type! */
+                        NM_DEVICE_INFINIBAND_IS_PARTITION,
+                        is_partition,
+                        NULL);
+}
+
+static const char *
+get_connection_parent(NMDeviceFactory *factory, NMConnection *connection)
+{
+    NMSettingInfiniband *s_infiniband;
+
+    g_return_val_if_fail(nm_connection_is_type(connection, NM_SETTING_INFINIBAND_SETTING_NAME),
+                         NULL);
+
+    s_infiniband = nm_connection_get_setting_infiniband(connection);
+    g_assert(s_infiniband);
+
+    return nm_setting_infiniband_get_parent(s_infiniband);
+}
+
+static char *
+get_connection_iface(NMDeviceFactory *factory, NMConnection *connection, const char *parent_iface)
+{
+    NMSettingInfiniband *s_infiniband;
+
+    g_return_val_if_fail(nm_connection_is_type(connection, NM_SETTING_INFINIBAND_SETTING_NAME),
+                         NULL);
+
+    s_infiniband = nm_connection_get_setting_infiniband(connection);
+    g_assert(s_infiniband);
+
+    if (!parent_iface)
+        return NULL;
+
+    g_return_val_if_fail(g_strcmp0(parent_iface, nm_setting_infiniband_get_parent(s_infiniband))
+                             == 0,
+                         NULL);
+
+    return g_strdup(nm_setting_infiniband_get_virtual_interface_name(s_infiniband));
+}
+
+NM_DEVICE_FACTORY_DEFINE_INTERNAL(
+    INFINIBAND,
+    Infiniband,
+    infiniband,
+    NM_DEVICE_FACTORY_DECLARE_LINK_TYPES(NM_LINK_TYPE_INFINIBAND)
+        NM_DEVICE_FACTORY_DECLARE_SETTING_TYPES(NM_SETTING_INFINIBAND_SETTING_NAME),
+    factory_class->create_device         = create_device;
+    factory_class->get_connection_parent = get_connection_parent;
+    factory_class->get_connection_iface  = get_connection_iface;);