[thirdparty/systemd.git] / src / network / netdev / bridge.c

/***
    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 <net/if.h>

#include "missing.h"
#include "netlink-util.h"
#include "netdev/bridge.h"
#include "networkd-manager.h"

/* callback for brige netdev's parameter set */
static int netdev_bridge_set_handler(sd_netlink *rtnl, sd_netlink_message *m, void *userdata) {
        _cleanup_netdev_unref_ NetDev *netdev = userdata;
        int r;

        assert(netdev);
        assert(m);

        r = sd_netlink_message_get_errno(m);
        if (r < 0) {
                log_netdev_warning_errno(netdev, r, "Bridge parameters could not be set: %m");
                return 1;
        }

        log_netdev_debug(netdev, "Bridge parameters set success");

        return 1;
}

static int netdev_bridge_post_create(NetDev *netdev, Link *link, sd_netlink_message *m) {
        _cleanup_(sd_netlink_message_unrefp) sd_netlink_message *req = NULL;
        Bridge *b;
        int r;

        assert(netdev);

        b = BRIDGE(netdev);

        assert(b);

        r = sd_rtnl_message_new_link(netdev->manager->rtnl, &req, RTM_NEWLINK, netdev->ifindex);
        if (r < 0)
                return log_netdev_error_errno(netdev, r, "Could not allocate RTM_SETLINK message: %m");

        r = sd_netlink_message_set_flags(req, NLM_F_REQUEST | NLM_F_ACK);
        if (r < 0)
                return log_link_error_errno(link, r, "Could not set netlink flags: %m");

        r = sd_netlink_message_open_container(req, IFLA_LINKINFO);
        if (r < 0)
                return log_netdev_error_errno(netdev, r, "Could not append IFLA_PROTINFO attribute: %m");

        r = sd_netlink_message_open_container_union(req, IFLA_INFO_DATA, netdev_kind_to_string(netdev->kind));
        if (r < 0)
                return log_netdev_error_errno(netdev, r, "Could not append IFLA_INFO_DATA attribute: %m");

        /* convert to jiffes */
        if (b->forward_delay > 0) {
                r = sd_netlink_message_append_u32(req, IFLA_BR_FORWARD_DELAY, usec_to_jiffies(b->forward_delay));
                if (r < 0)
                        return log_netdev_error_errno(netdev, r, "Could not append IFLA_BR_FORWARD_DELAY attribute: %m");
        }

        if (b->hello_time > 0) {
                r = sd_netlink_message_append_u32(req, IFLA_BR_HELLO_TIME, usec_to_jiffies(b->hello_time));
                if (r < 0)
                        return log_netdev_error_errno(netdev, r, "Could not append IFLA_BR_HELLO_TIME attribute: %m");
        }

        if (b->max_age > 0) {
                r = sd_netlink_message_append_u32(req, IFLA_BR_MAX_AGE, usec_to_jiffies(b->max_age));
                if (r < 0)
                        return log_netdev_error_errno(netdev, r, "Could not append IFLA_BR_MAX_AGE attribute: %m");
        }

        if (b->ageing_time > 0) {
                r = sd_netlink_message_append_u32(req, IFLA_BR_AGEING_TIME, usec_to_jiffies(b->ageing_time));
                if (r < 0)
                        return log_netdev_error_errno(netdev, r, "Could not append IFLA_BR_AGEING_TIME attribute: %m");
        }

        if (b->priority > 0) {
                r = sd_netlink_message_append_u16(req, IFLA_BR_PRIORITY, b->priority);
                if (r < 0)
                        return log_netdev_error_errno(netdev, r, "Could not append IFLA_BR_PRIORITY attribute: %m");
        }

        if (b->default_pvid > 0) {
                r = sd_netlink_message_append_u16(req, IFLA_BR_VLAN_DEFAULT_PVID, b->default_pvid);
                if (r < 0)
                        return log_netdev_error_errno(netdev, r, "Could not append IFLA_BR_VLAN_DEFAULT_PVID attribute: %m");
        }

        if (b->mcast_querier >= 0) {
                r = sd_netlink_message_append_u8(req, IFLA_BR_MCAST_QUERIER, b->mcast_querier);
                if (r < 0)
                        return log_netdev_error_errno(netdev, r, "Could not append IFLA_BR_MCAST_QUERIER attribute: %m");
        }

        if (b->mcast_snooping >= 0) {
                r = sd_netlink_message_append_u8(req, IFLA_BR_MCAST_SNOOPING, b->mcast_snooping);
                if (r < 0)
                        return log_netdev_error_errno(netdev, r, "Could not append IFLA_BR_MCAST_SNOOPING attribute: %m");
        }

        if (b->vlan_filtering >= 0) {
                r = sd_netlink_message_append_u8(req, IFLA_BR_VLAN_FILTERING, b->vlan_filtering);
                if (r < 0)
                        return log_netdev_error_errno(netdev, r, "Could not append IFLA_BR_VLAN_FILTERING attribute: %m");
        }

        if (b->stp >= 0) {
                r = sd_netlink_message_append_u32(req, IFLA_BR_STP_STATE, b->stp);
                if (r < 0)
                        return log_netdev_error_errno(netdev, r, "Could not append IFLA_BR_STP_STATE attribute: %m");
        }

        r = sd_netlink_message_close_container(req);
        if (r < 0)
                return log_netdev_error_errno(netdev, r, "Could not append IFLA_LINKINFO attribute: %m");

        r = sd_netlink_message_close_container(req);
        if (r < 0)
                return log_netdev_error_errno(netdev, r, "Could not append IFLA_INFO_DATA attribute: %m");

        r = sd_netlink_call_async(netdev->manager->rtnl, req, netdev_bridge_set_handler, netdev, 0, NULL);
        if (r < 0)
                return log_netdev_error_errno(netdev, r, "Could not send rtnetlink message: %m");

        netdev_ref(netdev);

        return r;
}

static void bridge_init(NetDev *n) {
        Bridge *b;

        b = BRIDGE(n);

        assert(b);

        b->mcast_querier = -1;
        b->mcast_snooping = -1;
        b->vlan_filtering = -1;
        b->stp = -1;
}

const NetDevVTable bridge_vtable = {
        .object_size = sizeof(Bridge),
        .init = bridge_init,
        .sections = "Match\0NetDev\0Bridge\0",
        .post_create = netdev_bridge_post_create,
        .create_type = NETDEV_CREATE_MASTER,
};
Commit	Line	Data
6235b3de TG	1	/***
	2	This file is part of systemd.
	3
	4	Copyright 2014 Tom Gundersen <teg@jklm.no>
	5	Copyright 2014 Susant Sahani
	6
	7	systemd is free software; you can redistribute it and/or modify it
	8	under the terms of the GNU Lesser General Public License as published by
	9	the Free Software Foundation; either version 2.1 of the License, or
	10	(at your option) any later version.
	11
	12	systemd is distributed in the hope that it will be useful, but
	13	WITHOUT ANY WARRANTY; without even the implied warranty of
	14	MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
	15	Lesser General Public License for more details.
	16
	17	You should have received a copy of the GNU Lesser General Public License
	18	along with systemd; If not, see <http://www.gnu.org/licenses/>.
	19	***/
	20
540eb5f0	21	#include <net/if.h>
6235b3de	22
6235b3de	23	#include "missing.h"
540eb5f0	24	#include "netlink-util.h"
441e9ae4	25	#include "netdev/bridge.h"
23f53b99	26	#include "networkd-manager.h"
540eb5f0 SS	27
	28	/* callback for brige netdev's parameter set */
	29	static int netdev_bridge_set_handler(sd_netlink rtnl, sd_netlink_message m, void *userdata) {
	30	_cleanup_netdev_unref_ NetDev *netdev = userdata;
	31	int r;
	32
	33	assert(netdev);
	34	assert(m);
	35
	36	r = sd_netlink_message_get_errno(m);
	37	if (r < 0) {
	38	log_netdev_warning_errno(netdev, r, "Bridge parameters could not be set: %m");
	39	return 1;
	40	}
	41
82936769	42	log_netdev_debug(netdev, "Bridge parameters set success");
540eb5f0 SS	43
	44	return 1;
	45	}
	46
	47	static int netdev_bridge_post_create(NetDev netdev, Link link, sd_netlink_message *m) {
4afd3348	48	_cleanup_(sd_netlink_message_unrefp) sd_netlink_message *req = NULL;
540eb5f0 SS	49	Bridge *b;
	50	int r;
	51
	52	assert(netdev);
	53
	54	b = BRIDGE(netdev);
	55
	56	assert(b);
	57
	58	r = sd_rtnl_message_new_link(netdev->manager->rtnl, &req, RTM_NEWLINK, netdev->ifindex);
	59	if (r < 0)
	60	return log_netdev_error_errno(netdev, r, "Could not allocate RTM_SETLINK message: %m");
	61
	62	r = sd_netlink_message_set_flags(req, NLM_F_REQUEST \| NLM_F_ACK);
	63	if (r < 0)
	64	return log_link_error_errno(link, r, "Could not set netlink flags: %m");
	65
	66	r = sd_netlink_message_open_container(req, IFLA_LINKINFO);
	67	if (r < 0)
	68	return log_netdev_error_errno(netdev, r, "Could not append IFLA_PROTINFO attribute: %m");
	69
	70	r = sd_netlink_message_open_container_union(req, IFLA_INFO_DATA, netdev_kind_to_string(netdev->kind));
	71	if (r < 0)
	72	return log_netdev_error_errno(netdev, r, "Could not append IFLA_INFO_DATA attribute: %m");
	73
1a14863e	74	/* convert to jiffes */
540eb5f0	75	if (b->forward_delay > 0) {
1a14863e	76	r = sd_netlink_message_append_u32(req, IFLA_BR_FORWARD_DELAY, usec_to_jiffies(b->forward_delay));
540eb5f0 SS	77	if (r < 0)
	78	return log_netdev_error_errno(netdev, r, "Could not append IFLA_BR_FORWARD_DELAY attribute: %m");
	79	}
	80
	81	if (b->hello_time > 0) {
1a14863e	82	r = sd_netlink_message_append_u32(req, IFLA_BR_HELLO_TIME, usec_to_jiffies(b->hello_time));
540eb5f0 SS	83	if (r < 0)
	84	return log_netdev_error_errno(netdev, r, "Could not append IFLA_BR_HELLO_TIME attribute: %m");
	85	}
	86
	87	if (b->max_age > 0) {
1a14863e	88	r = sd_netlink_message_append_u32(req, IFLA_BR_MAX_AGE, usec_to_jiffies(b->max_age));
540eb5f0 SS	89	if (r < 0)
	90	return log_netdev_error_errno(netdev, r, "Could not append IFLA_BR_MAX_AGE attribute: %m");
	91	}
	92
c7440e74 TJ	93	if (b->ageing_time > 0) {
	94	r = sd_netlink_message_append_u32(req, IFLA_BR_AGEING_TIME, usec_to_jiffies(b->ageing_time));
	95	if (r < 0)
	96	return log_netdev_error_errno(netdev, r, "Could not append IFLA_BR_AGEING_TIME attribute: %m");
	97	}
	98
	99	if (b->priority > 0) {
	100	r = sd_netlink_message_append_u16(req, IFLA_BR_PRIORITY, b->priority);
	101	if (r < 0)
	102	return log_netdev_error_errno(netdev, r, "Could not append IFLA_BR_PRIORITY attribute: %m");
	103	}
	104
	105	if (b->default_pvid > 0) {
	106	r = sd_netlink_message_append_u16(req, IFLA_BR_VLAN_DEFAULT_PVID, b->default_pvid);
	107	if (r < 0)
	108	return log_netdev_error_errno(netdev, r, "Could not append IFLA_BR_VLAN_DEFAULT_PVID attribute: %m");
	109	}
	110
3fef7a3f SS	111	if (b->mcast_querier >= 0) {
	112	r = sd_netlink_message_append_u8(req, IFLA_BR_MCAST_QUERIER, b->mcast_querier);
	113	if (r < 0)
	114	return log_netdev_error_errno(netdev, r, "Could not append IFLA_BR_MCAST_QUERIER attribute: %m");
	115	}
	116
6df6d898 SS	117	if (b->mcast_snooping >= 0) {
	118	r = sd_netlink_message_append_u8(req, IFLA_BR_MCAST_SNOOPING, b->mcast_snooping);
	119	if (r < 0)
	120	return log_netdev_error_errno(netdev, r, "Could not append IFLA_BR_MCAST_SNOOPING attribute: %m");
	121	}
	122
c6f8d17d TJ	123	if (b->vlan_filtering >= 0) {
	124	r = sd_netlink_message_append_u8(req, IFLA_BR_VLAN_FILTERING, b->vlan_filtering);
	125	if (r < 0)
	126	return log_netdev_error_errno(netdev, r, "Could not append IFLA_BR_VLAN_FILTERING attribute: %m");
	127	}
	128
b760a9af SS	129	if (b->stp >= 0) {
	130	r = sd_netlink_message_append_u32(req, IFLA_BR_STP_STATE, b->stp);
	131	if (r < 0)
	132	return log_netdev_error_errno(netdev, r, "Could not append IFLA_BR_STP_STATE attribute: %m");
	133	}
	134
540eb5f0 SS	135	r = sd_netlink_message_close_container(req);
	136	if (r < 0)
	137	return log_netdev_error_errno(netdev, r, "Could not append IFLA_LINKINFO attribute: %m");
	138
	139	r = sd_netlink_message_close_container(req);
	140	if (r < 0)
	141	return log_netdev_error_errno(netdev, r, "Could not append IFLA_INFO_DATA attribute: %m");
	142
	143	r = sd_netlink_call_async(netdev->manager->rtnl, req, netdev_bridge_set_handler, netdev, 0, NULL);
	144	if (r < 0)
	145	return log_netdev_error_errno(netdev, r, "Could not send rtnetlink message: %m");
	146
	147	netdev_ref(netdev);
	148
	149	return r;
	150	}
6235b3de	151
3fef7a3f SS	152	static void bridge_init(NetDev *n) {
	153	Bridge *b;
	154
	155	b = BRIDGE(n);
	156
	157	assert(b);
	158
	159	b->mcast_querier = -1;
6df6d898	160	b->mcast_snooping = -1;
c6f8d17d	161	b->vlan_filtering = -1;
b760a9af	162	b->stp = -1;
3fef7a3f SS	163	}
3fef7a3f SS	164
3be1d7e0	165	const NetDevVTable bridge_vtable = {
aa9f1140	166	.object_size = sizeof(Bridge),
3fef7a3f	167	.init = bridge_init,
540eb5f0 SS	168	.sections = "Match\0NetDev\0Bridge\0",
540eb5f0 SS	169	.post_create = netdev_bridge_post_create,
aa9f1140	170	.create_type = NETDEV_CREATE_MASTER,
3be1d7e0	171	};