[thirdparty/systemd.git] / src / network / networkd-netdev-bond.c

/*-*- Mode: C; c-basic-offset: 8; indent-tabs-mode: nil -*-*/

/***
    This file is part of systemd.

    Copyright 2014  Tom Gundersen <teg@jklm.no>
    Copyright 2014  Susant Sahani

    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/>.
***/

#include <netinet/ether.h>
#include <linux/if_bonding.h>

#include "conf-parser.h"
#include "sd-rtnl.h"
#include "networkd-netdev-bond.h"
#include "missing.h"

static const char* const bond_mode_table[_NETDEV_BOND_MODE_MAX] = {
        [NETDEV_BOND_MODE_BALANCE_RR] = "balance-rr",
        [NETDEV_BOND_MODE_ACTIVE_BACKUP] = "active-backup",
        [NETDEV_BOND_MODE_BALANCE_XOR] = "balance-xor",
        [NETDEV_BOND_MODE_BROADCAST] = "broadcast",
        [NETDEV_BOND_MODE_802_3AD] = "802.3ad",
        [NETDEV_BOND_MODE_BALANCE_TLB] = "balance-tlb",
        [NETDEV_BOND_MODE_BALANCE_ALB] = "balance-alb",
};

DEFINE_STRING_TABLE_LOOKUP(bond_mode, BondMode);
DEFINE_CONFIG_PARSE_ENUM(config_parse_bond_mode, bond_mode, BondMode, "Failed to parse bond mode");


static const char* const bond_xmit_hash_policy_table[_NETDEV_BOND_XMIT_HASH_POLICY_MAX] = {
        [NETDEV_BOND_XMIT_HASH_POLICY_LAYER2] = "layer2",
        [NETDEV_BOND_XMIT_HASH_POLICY_LAYER34] = "layer3+4",
        [NETDEV_BOND_XMIT_HASH_POLICY_LAYER23] = "layer2+3",
        [NETDEV_BOND_XMIT_HASH_POLICY_ENCAP23] = "encap2+3",
        [NETDEV_BOND_XMIT_HASH_POLICY_ENCAP34] = "encap3+4",
};

DEFINE_STRING_TABLE_LOOKUP(bond_xmit_hash_policy, BondXmitHashPolicy);
DEFINE_CONFIG_PARSE_ENUM(config_parse_bond_xmit_hash_policy,
                         bond_xmit_hash_policy,
                         BondXmitHashPolicy,
                         "Failed to parse bond transmit hash policy")

static const char* const bond_lacp_rate_table[_NETDEV_BOND_LACP_RATE_MAX] = {
        [NETDEV_BOND_LACP_RATE_SLOW] = "slow",
        [NETDEV_BOND_LACP_RATE_FAST] = "fast",
};

DEFINE_STRING_TABLE_LOOKUP(bond_lacp_rate, BondLacpRate);
DEFINE_CONFIG_PARSE_ENUM(config_parse_bond_lacp_rate, bond_lacp_rate, BondLacpRate, "Failed to parse bond lacp rate")

static uint8_t bond_mode_to_kernel(BondMode mode) {
        switch (mode) {
        case NETDEV_BOND_MODE_BALANCE_RR:
                return BOND_MODE_ROUNDROBIN;
        case NETDEV_BOND_MODE_ACTIVE_BACKUP:
                return BOND_MODE_ACTIVEBACKUP;
        case NETDEV_BOND_MODE_BALANCE_XOR:
                return BOND_MODE_XOR;
        case NETDEV_BOND_MODE_BROADCAST:
                return BOND_MODE_BROADCAST;
        case NETDEV_BOND_MODE_802_3AD:
                return BOND_MODE_8023AD;
        case NETDEV_BOND_MODE_BALANCE_TLB:
                return BOND_MODE_TLB;
        case NETDEV_BOND_MODE_BALANCE_ALB:
                return BOND_MODE_ALB;
        default:
                return (uint8_t) -1;
        }
}

static uint8_t bond_xmit_hash_policy_to_kernel(BondXmitHashPolicy policy) {
        switch (policy) {
        case NETDEV_BOND_XMIT_HASH_POLICY_LAYER2:
                return BOND_XMIT_POLICY_LAYER2;
        case NETDEV_BOND_XMIT_HASH_POLICY_LAYER34:
                return BOND_XMIT_POLICY_LAYER34;
        case NETDEV_BOND_XMIT_HASH_POLICY_LAYER23:
                return BOND_XMIT_POLICY_LAYER23;
        case NETDEV_BOND_XMIT_HASH_POLICY_ENCAP23:
                return BOND_XMIT_POLICY_ENCAP23;
        case NETDEV_BOND_XMIT_HASH_POLICY_ENCAP34:
                return BOND_XMIT_POLICY_ENCAP34;
        default:
                return (uint8_t) -1;
        }
}

static int netdev_bond_fill_message_create(NetDev *netdev, Link *link, sd_rtnl_message *m) {
        Bond *b = BOND(netdev);
        int r;

        assert(netdev);
        assert(!link);
        assert(b);
        assert(m);

        if (b->mode != _NETDEV_BOND_MODE_INVALID) {
                r = sd_rtnl_message_append_u8(m, IFLA_BOND_MODE,
                                              bond_mode_to_kernel(b->mode));
                if (r < 0) {
                        log_netdev_error(netdev,
                                         "Could not append IFLA_BOND_MODE attribute: %s",
                                         strerror(-r));
                        return r;
                }
        }

        if (b->xmit_hash_policy != _NETDEV_BOND_XMIT_HASH_POLICY_INVALID) {
                r = sd_rtnl_message_append_u8(m, IFLA_BOND_XMIT_HASH_POLICY,
                                              bond_xmit_hash_policy_to_kernel(b->xmit_hash_policy));
                if (r < 0) {
                        log_netdev_error(netdev,
                                         "Could not append IFLA_BOND_XMIT_HASH_POLICY attribute: %s",
                                         strerror(-r));
                        return r;
                }
        }

        if (b->lacp_rate != _NETDEV_BOND_LACP_RATE_INVALID &&
            b->mode == NETDEV_BOND_MODE_802_3AD) {
                r = sd_rtnl_message_append_u8(m, IFLA_BOND_AD_LACP_RATE, b->lacp_rate );
                if (r < 0) {
                        log_netdev_error(netdev,
                                         "Could not append IFLA_BOND_AD_LACP_RATE attribute: %s",
                                         strerror(-r));
                        return r;
                }
        }

        if (b->miimon != 0) {
                r = sd_rtnl_message_append_u32(m, IFLA_BOND_MIIMON, b->miimon / USEC_PER_MSEC);
                if (r < 0) {
                        log_netdev_error(netdev,
                                         "Could not append IFLA_BOND_BOND_MIIMON attribute: %s",
                                         strerror(-r));
                        return r;
                }
        }

        if (b->downdelay != 0) {
                r = sd_rtnl_message_append_u32(m, IFLA_BOND_DOWNDELAY, b->downdelay / USEC_PER_MSEC);
                if (r < 0) {
                        log_netdev_error(netdev,
                                         "Could not append IFLA_BOND_DOWNDELAY attribute: %s",
                                         strerror(-r));
                        return r;
                }
        }

        if (b->updelay != 0) {
                r = sd_rtnl_message_append_u32(m, IFLA_BOND_UPDELAY, b->updelay / USEC_PER_MSEC);
                if (r < 0) {
                        log_netdev_error(netdev,
                                         "Could not append IFLA_BOND_UPDELAY attribute: %s",
                                         strerror(-r));
                        return r;
                }
        }

        return 0;
}

static void bond_init(NetDev *netdev) {
        Bond *b = BOND(netdev);

        assert(netdev);
        assert(b);

        b->mode = _NETDEV_BOND_MODE_INVALID;
        b->xmit_hash_policy = _NETDEV_BOND_XMIT_HASH_POLICY_INVALID;
        b->lacp_rate = _NETDEV_BOND_LACP_RATE_INVALID;
}

const NetDevVTable bond_vtable = {
        .object_size = sizeof(Bond),
        .init = bond_init,
        .sections = "Match\0NetDev\0Bond\0",
        .fill_message_create = netdev_bond_fill_message_create,
        .create_type = NETDEV_CREATE_MASTER,
};
Commit	Line	Data
fe8ac65b SS	1	/-- Mode: C; c-basic-offset: 8; indent-tabs-mode: nil --/
	2
	3	/***
	4	This file is part of systemd.
	5
	6	Copyright 2014 Tom Gundersen <teg@jklm.no>
	7	Copyright 2014 Susant Sahani
	8
	9	systemd is free software; you can redistribute it and/or modify it
	10	under the terms of the GNU Lesser General Public License as published by
	11	the Free Software Foundation; either version 2.1 of the License, or
	12	(at your option) any later version.
	13
	14	systemd is distributed in the hope that it will be useful, but
	15	WITHOUT ANY WARRANTY; without even the implied warranty of
	16	MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
	17	Lesser General Public License for more details.
	18
	19	You should have received a copy of the GNU Lesser General Public License
	20	along with systemd; If not, see <http://www.gnu.org/licenses/>.
	21	***/
	22
	23	#include <netinet/ether.h>
b621239e	24	#include <linux/if_bonding.h>
fe8ac65b SS	25
	26	#include "conf-parser.h"
	27	#include "sd-rtnl.h"
3be1d7e0	28	#include "networkd-netdev-bond.h"
fe8ac65b SS	29	#include "missing.h"
	30
	31	static const char* const bond_mode_table[_NETDEV_BOND_MODE_MAX] = {
	32	[NETDEV_BOND_MODE_BALANCE_RR] = "balance-rr",
	33	[NETDEV_BOND_MODE_ACTIVE_BACKUP] = "active-backup",
	34	[NETDEV_BOND_MODE_BALANCE_XOR] = "balance-xor",
	35	[NETDEV_BOND_MODE_BROADCAST] = "broadcast",
	36	[NETDEV_BOND_MODE_802_3AD] = "802.3ad",
	37	[NETDEV_BOND_MODE_BALANCE_TLB] = "balance-tlb",
	38	[NETDEV_BOND_MODE_BALANCE_ALB] = "balance-alb",
	39	};
	40
	41	DEFINE_STRING_TABLE_LOOKUP(bond_mode, BondMode);
	42	DEFINE_CONFIG_PARSE_ENUM(config_parse_bond_mode, bond_mode, BondMode, "Failed to parse bond mode");
	43
227cdf2c SS	44
	45	static const char* const bond_xmit_hash_policy_table[_NETDEV_BOND_XMIT_HASH_POLICY_MAX] = {
	46	[NETDEV_BOND_XMIT_HASH_POLICY_LAYER2] = "layer2",
	47	[NETDEV_BOND_XMIT_HASH_POLICY_LAYER34] = "layer3+4",
	48	[NETDEV_BOND_XMIT_HASH_POLICY_LAYER23] = "layer2+3",
	49	[NETDEV_BOND_XMIT_HASH_POLICY_ENCAP23] = "encap2+3",
	50	[NETDEV_BOND_XMIT_HASH_POLICY_ENCAP34] = "encap3+4",
	51	};
	52
	53	DEFINE_STRING_TABLE_LOOKUP(bond_xmit_hash_policy, BondXmitHashPolicy);
	54	DEFINE_CONFIG_PARSE_ENUM(config_parse_bond_xmit_hash_policy,
	55	bond_xmit_hash_policy,
	56	BondXmitHashPolicy,
	57	"Failed to parse bond transmit hash policy")
	58
fb1021a2 SS	59	static const char* const bond_lacp_rate_table[_NETDEV_BOND_LACP_RATE_MAX] = {
	60	[NETDEV_BOND_LACP_RATE_SLOW] = "slow",
	61	[NETDEV_BOND_LACP_RATE_FAST] = "fast",
	62	};
	63
	64	DEFINE_STRING_TABLE_LOOKUP(bond_lacp_rate, BondLacpRate);
	65	DEFINE_CONFIG_PARSE_ENUM(config_parse_bond_lacp_rate, bond_lacp_rate, BondLacpRate, "Failed to parse bond lacp rate")
	66
b621239e TG	67	static uint8_t bond_mode_to_kernel(BondMode mode) {
	68	switch (mode) {
	69	case NETDEV_BOND_MODE_BALANCE_RR:
	70	return BOND_MODE_ROUNDROBIN;
	71	case NETDEV_BOND_MODE_ACTIVE_BACKUP:
	72	return BOND_MODE_ACTIVEBACKUP;
	73	case NETDEV_BOND_MODE_BALANCE_XOR:
	74	return BOND_MODE_XOR;
	75	case NETDEV_BOND_MODE_BROADCAST:
	76	return BOND_MODE_BROADCAST;
	77	case NETDEV_BOND_MODE_802_3AD:
	78	return BOND_MODE_8023AD;
	79	case NETDEV_BOND_MODE_BALANCE_TLB:
	80	return BOND_MODE_TLB;
	81	case NETDEV_BOND_MODE_BALANCE_ALB:
	82	return BOND_MODE_ALB;
	83	default:
	84	return (uint8_t) -1;
	85	}
	86	}
	87
227cdf2c SS	88	static uint8_t bond_xmit_hash_policy_to_kernel(BondXmitHashPolicy policy) {
	89	switch (policy) {
	90	case NETDEV_BOND_XMIT_HASH_POLICY_LAYER2:
	91	return BOND_XMIT_POLICY_LAYER2;
	92	case NETDEV_BOND_XMIT_HASH_POLICY_LAYER34:
	93	return BOND_XMIT_POLICY_LAYER34;
	94	case NETDEV_BOND_XMIT_HASH_POLICY_LAYER23:
	95	return BOND_XMIT_POLICY_LAYER23;
	96	case NETDEV_BOND_XMIT_HASH_POLICY_ENCAP23:
	97	return BOND_XMIT_POLICY_ENCAP23;
	98	case NETDEV_BOND_XMIT_HASH_POLICY_ENCAP34:
	99	return BOND_XMIT_POLICY_ENCAP34;
	100	default:
	101	return (uint8_t) -1;
	102	}
	103	}
	104
aa9f1140 TG	105	static int netdev_bond_fill_message_create(NetDev netdev, Link link, sd_rtnl_message *m) {
aa9f1140 TG	106	Bond *b = BOND(netdev);
fe8ac65b SS	107	int r;
fe8ac65b SS	108
aa9f1140 TG	109	assert(netdev);
	110	assert(!link);
	111	assert(b);
fe8ac65b SS	112	assert(m);
fe8ac65b SS	113
aa9f1140	114	if (b->mode != _NETDEV_BOND_MODE_INVALID) {
b621239e	115	r = sd_rtnl_message_append_u8(m, IFLA_BOND_MODE,
aa9f1140	116	bond_mode_to_kernel(b->mode));
fe8ac65b	117	if (r < 0) {
79008bdd	118	log_netdev_error(netdev,
fe8ac65b SS	119	"Could not append IFLA_BOND_MODE attribute: %s",
	120	strerror(-r));
	121	return r;
	122	}
	123	}
	124
227cdf2c SS	125	if (b->xmit_hash_policy != _NETDEV_BOND_XMIT_HASH_POLICY_INVALID) {
	126	r = sd_rtnl_message_append_u8(m, IFLA_BOND_XMIT_HASH_POLICY,
	127	bond_xmit_hash_policy_to_kernel(b->xmit_hash_policy));
	128	if (r < 0) {
79008bdd	129	log_netdev_error(netdev,
227cdf2c SS	130	"Could not append IFLA_BOND_XMIT_HASH_POLICY attribute: %s",
	131	strerror(-r));
	132	return r;
	133	}
	134	}
	135
fb1021a2 SS	136	if (b->lacp_rate != _NETDEV_BOND_LACP_RATE_INVALID &&
	137	b->mode == NETDEV_BOND_MODE_802_3AD) {
	138	r = sd_rtnl_message_append_u8(m, IFLA_BOND_AD_LACP_RATE, b->lacp_rate );
	139	if (r < 0) {
79008bdd	140	log_netdev_error(netdev,
fb1021a2 SS	141	"Could not append IFLA_BOND_AD_LACP_RATE attribute: %s",
	142	strerror(-r));
	143	return r;
	144	}
	145	}
	146
d9c52fa0	147	if (b->miimon != 0) {
c9e738b9	148	r = sd_rtnl_message_append_u32(m, IFLA_BOND_MIIMON, b->miimon / USEC_PER_MSEC);
d9c52fa0	149	if (r < 0) {
79008bdd	150	log_netdev_error(netdev,
d9c52fa0 SS	151	"Could not append IFLA_BOND_BOND_MIIMON attribute: %s",
	152	strerror(-r));
	153	return r;
	154	}
	155	}
	156
	157	if (b->downdelay != 0) {
c9e738b9	158	r = sd_rtnl_message_append_u32(m, IFLA_BOND_DOWNDELAY, b->downdelay / USEC_PER_MSEC);
d9c52fa0	159	if (r < 0) {
79008bdd	160	log_netdev_error(netdev,
d9c52fa0 SS	161	"Could not append IFLA_BOND_DOWNDELAY attribute: %s",
	162	strerror(-r));
	163	return r;
	164	}
	165	}
	166
	167	if (b->updelay != 0) {
c9e738b9	168	r = sd_rtnl_message_append_u32(m, IFLA_BOND_UPDELAY, b->updelay / USEC_PER_MSEC);
d9c52fa0	169	if (r < 0) {
79008bdd	170	log_netdev_error(netdev,
d9c52fa0 SS	171	"Could not append IFLA_BOND_UPDELAY attribute: %s",
	172	strerror(-r));
	173	return r;
	174	}
	175	}
	176
aa9f1140 TG	177	return 0;
aa9f1140 TG	178	}
fe8ac65b	179
aa9f1140 TG	180	static void bond_init(NetDev *netdev) {
	181	Bond *b = BOND(netdev);
	182
	183	assert(netdev);
	184	assert(b);
fe8ac65b	185
aa9f1140	186	b->mode = _NETDEV_BOND_MODE_INVALID;
227cdf2c	187	b->xmit_hash_policy = _NETDEV_BOND_XMIT_HASH_POLICY_INVALID;
fb1021a2	188	b->lacp_rate = _NETDEV_BOND_LACP_RATE_INVALID;
fe8ac65b SS	189	}
fe8ac65b SS	190
3be1d7e0	191	const NetDevVTable bond_vtable = {
aa9f1140 TG	192	.object_size = sizeof(Bond),
	193	.init = bond_init,
	194	.sections = "Match\0NetDev\0Bond\0",
3be1d7e0	195	.fill_message_create = netdev_bond_fill_message_create,
aa9f1140	196	.create_type = NETDEV_CREATE_MASTER,
3be1d7e0	197	};