path: root/src/devices/contrail/nm-device-contrail-vrouter.c

// SPDX-License-Identifier: LGPL-2.1+
/*
 * Copyright (C) 2007 - 2013 Red Hat, Inc.
 * Copyright (C) 2007 - 2008 Novell, Inc.
 */

#include <string.h>
#include <sys/socket.h>
#include <sys/ioctl.h>
#include <net/if.h>
#include <unistd.h>

#include "nm-default.h"

#include "nm-device-contrail-vrouter.h"

#include "devices/nm-device-private.h"
#include "nm-active-connection.h"
#include "nm-setting-connection.h"
#include "nm-setting-contrail-vrouter.h"

#include "devices/nm-device-logging.h"
_LOG_DECLARE_SELF(NMDeviceContrailVrouter);

/*****************************************************************************/

typedef struct {
	bool waiting_for_interface:1;
} NMDeviceContrailVrouterPrivate;

struct _NMDeviceContrailVrouter {
	NMDevice parent;
	NMDeviceContrailVrouterPrivate _priv;
};

struct _NMDeviceContrailVrouterClass {
	NMDeviceClass parent;
};

G_DEFINE_TYPE (NMDeviceContrailVrouter, nm_device_contrail_vrouter, NM_TYPE_DEVICE)

#define NM_DEVICE_CONTRAIL_VROUTER_GET_PRIVATE(self) _NM_GET_PRIVATE (self, NMDeviceContrailVrouter, NM_IS_DEVICE_CONTRAIL_VROUTER, NMDevice)

/*****************************************************************************/

void _get_command(const char *iface,
                  const char *physdev,
                  char *command,
                  const int command_size);

void
_get_mac (const char *physdev, char *mac_str);

void
_get_mac (const char *physdev, char *mac_str)
{
	struct ifreq ifr;
	int fd;
	unsigned char *mac;
	int i;
	char *pos;

	nm_log_dbg (LOGD_DEVICE, "CONTRAIL: %s %s", __FILE__ , __func__);

	memset(&ifr, 0, sizeof(ifr));
	fd = socket(AF_INET, SOCK_DGRAM, 0);
	ifr.ifr_addr.sa_family = AF_INET;
	strncpy(ifr.ifr_name , physdev , IFNAMSIZ-1);
	if (0 == ioctl(fd, SIOCGIFHWADDR, &ifr)) {
		mac = (unsigned char *)ifr.ifr_hwaddr.sa_data;
		i = 0;
		pos = mac_str;
		for ( ; i < 6; i++) {
			if (i) {
				pos += sprintf(pos, ":");
			}
			pos += sprintf(pos, "%02X", (unsigned char)mac[i]);
		}
	}
	close(fd);
}

void
_get_command (const char *iface,
              const char *physdev,
              char *command,
              const int command_size)
{
	char mac_str[19];

	nm_log_dbg (LOGD_DEVICE, "CONTRAIL: %s %s", __FILE__ , __func__);

	_get_mac(physdev, mac_str);
	nm_log_dbg (LOGD_DEVICE, "CONTRAIL: mac address: %s", mac_str);

	snprintf(command, command_size,
			"modprobe vrouter && "
			"vif --create %s --mac %s 2>&1 && "
			"vif --add %s --mac %s --vrf 0 --vhost-phys --type physical 2>&1 && "
			"vif --add %s --mac %s --vrf 0 --type vhost --xconnect %s 2>&1 && "
			"ip link set dev %s address %s 2>&1 && "
			"ip link set dev %s up 2>&1",
			iface, mac_str,
			physdev, mac_str,
			iface, mac_str, physdev,
			iface, mac_str,
			iface);
}

/*********************************************************************************/

static const char *
get_type_description (NMDevice *device)
{
	nm_log_dbg (LOGD_DEVICE, "CONTRAIL: %s %s", __FILE__ , __func__);

	return "contrail-vrouter";
}

static gboolean
create_and_realize (NMDevice *device,
                    NMConnection *connection,
                    NMDevice *parent,
                    const NMPlatformLink **out_plink,
                    GError **error)
{
	nm_log_dbg (LOGD_DEVICE, "CONTRAIL: %s %s", __FILE__ , __func__);

	return TRUE;
}

static NMDeviceCapabilities
get_generic_capabilities (NMDevice *device)
{
	nm_log_dbg (LOGD_DEVICE, "CONTRAIL: %s %s", __FILE__ , __func__);

	return NM_DEVICE_CAP_IS_SOFTWARE;
}

static gboolean
is_available (NMDevice *device, NMDeviceCheckDevAvailableFlags flags)
{
	nm_log_dbg (LOGD_DEVICE, "CONTRAIL: %s %s", __FILE__ , __func__);

	return TRUE;
}

static gboolean
check_connection_compatible (NMDevice *device, NMConnection *connection, GError **error)
{
	nm_log_dbg (LOGD_DEVICE, "CONTRAIL: %s %s", __FILE__ , __func__);

	return TRUE;
}

static void
link_changed (NMDevice *device,
              const NMPlatformLink *pllink)
{
    NMDeviceContrailVrouterPrivate *priv;

    nm_log_dbg (LOGD_DEVICE, "CONTRAIL: %s %s", __FILE__ , __func__);
	priv = NM_DEVICE_CONTRAIL_VROUTER_GET_PRIVATE (device);

	if (pllink && priv->waiting_for_interface) {
		priv->waiting_for_interface = FALSE;
		nm_device_bring_up (device, TRUE, NULL);
		nm_device_activate_schedule_stage3_ip_config_start (device);
	}
}

static NMActStageReturn
act_stage1_prepare (NMDevice *device, NMDeviceStateReason *out_failure_reason)
{
	FILE *fp;
	int COMMAND_OUTPUT_SIZE = 512;
	char output[COMMAND_OUTPUT_SIZE];
	const char *iface;
	int COMMAND_SIZE = 512;
	char command[COMMAND_SIZE];
	const char *physdev;
    NMConnection *connection;

	nm_log_dbg (LOGD_DEVICE, "CONTRAIL: %s %s", __FILE__ , __func__);

	if (!device) {
		nm_log_err (LOGD_DEVICE, "CONTRAIL: device is null");
		return NM_ACT_STAGE_RETURN_FAILURE;
	}
	connection = nm_device_get_applied_connection (device);
	if (!connection) {
		nm_log_err (LOGD_DEVICE, "CONTRAIL: connection is null");
		return NM_ACT_STAGE_RETURN_FAILURE;
	}
	nm_connection_dump (connection);
	iface = nm_connection_get_interface_name (connection);
	nm_log_dbg (LOGD_DEVICE, "CONTRAIL: interface name: %s", iface);
	physdev = nm_setting_contrail_vrouter_get_physdev (nm_connection_get_setting_contrail_vrouter (connection));
	if (physdev) {
		nm_log_dbg (LOGD_DEVICE, "CONTRAIL: physical device name: %s", physdev);
		_get_command(iface, physdev, command, COMMAND_SIZE);
		nm_log_dbg (LOGD_DEVICE, "CONTRAIL: vrouter command: %s", command);
		fp = popen(command, "r");
		while (fgets(output, COMMAND_OUTPUT_SIZE, fp) != NULL){
			nm_log_err (LOGD_DEVICE, "CONTRAIL: %s", output);
		}
		pclose(fp);
	}
	else {
		nm_log_err (LOGD_DEVICE, "CONTRAIL: physical device name was not provided.");
		return NM_ACT_STAGE_RETURN_FAILURE;
	}
	return NM_ACT_STAGE_RETURN_SUCCESS;
}

static NMActStageReturn
act_stage3_ip_config_start (NMDevice *device,
                            int addr_family,
                            gpointer *out_config,
                            NMDeviceStateReason *out_failure_reason)
{
    NMDeviceContrailVrouterPrivate *priv;

	nm_log_dbg (LOGD_DEVICE, "CONTRAIL: %s %s", __FILE__ , __func__);
	priv = NM_DEVICE_CONTRAIL_VROUTER_GET_PRIVATE (device);

	if (!nm_device_get_ip_ifindex (device)) {
		priv->waiting_for_interface = TRUE;
		return NM_ACT_STAGE_RETURN_POSTPONE;
	}

	return NM_DEVICE_CLASS (nm_device_contrail_vrouter_parent_class)->act_stage3_ip_config_start (device, addr_family, out_config, out_failure_reason);
}

static gboolean
can_unmanaged_external_down (NMDevice *self)
{
	nm_log_dbg (LOGD_DEVICE, "CONTRAIL: %s %s", __FILE__ , __func__);

	return FALSE;
}

/*****************************************************************************/

static void
nm_device_contrail_vrouter_init (NMDeviceContrailVrouter *self)
{
	nm_log_dbg (LOGD_DEVICE, "CONTRAIL: %s %s", __FILE__ , __func__);
}

static const NMDBusInterfaceInfoExtended interface_info_device_contrail_vrouter = {
	.parent = NM_DEFINE_GDBUS_INTERFACE_INFO_INIT (
		NM_DBUS_INTERFACE_DEVICE_CONTRAIL_VROUTER,
		.signals = NM_DEFINE_GDBUS_SIGNAL_INFOS (
			&nm_signal_info_property_changed_legacy,
		),
	),
	.legacy_property_changed = TRUE,
};

static void
nm_device_contrail_vrouter_class_init (NMDeviceContrailVrouterClass *klass)
{
	NMDBusObjectClass *dbus_object_class = NM_DBUS_OBJECT_CLASS (klass);
	NMDeviceClass *device_class = NM_DEVICE_CLASS (klass);

	dbus_object_class->interface_infos = NM_DBUS_INTERFACE_INFOS (&interface_info_device_contrail_vrouter);

	device_class->connection_type_supported = NM_SETTING_CONTRAIL_VROUTER_SETTING_NAME;
	device_class->connection_type_check_compatible = NM_SETTING_CONTRAIL_VROUTER_SETTING_NAME;
	device_class->link_types = NM_DEVICE_DEFINE_LINK_TYPES (NM_LINK_TYPE_CONTRAILVROUTER);

	device_class->get_type_description = get_type_description;
	device_class->create_and_realize = create_and_realize;
	device_class->get_generic_capabilities = get_generic_capabilities;
	device_class->is_available = is_available;
	device_class->check_connection_compatible = check_connection_compatible;
	device_class->link_changed = link_changed;
	device_class->act_stage1_prepare = act_stage1_prepare;
    device_class->act_stage3_ip_config_start = act_stage3_ip_config_start;
	device_class->can_unmanaged_external_down = can_unmanaged_external_down;
}