src/network/netdev/bridge.c

   1 /* SPDX-License-Identifier: LGPL-2.1+ */
   2
   3 #include <net/if.h>
   4
   5 #include "missing.h"
   6 #include "netlink-util.h"
   7 #include "netdev/bridge.h"
   8 #include "network-internal.h"
   9 #include "networkd-manager.h"
  10 #include "string-table.h"
  11 #include "vlan-util.h"
  12
  13 static const char* const multicast_router_table[_MULTICAST_ROUTER_MAX] = {
  14         [MULTICAST_ROUTER_NONE] = "no",
  15         [MULTICAST_ROUTER_TEMPORARY_QUERY] = "query",
  16         [MULTICAST_ROUTER_PERMANENT] = "permanent",
  17         [MULTICAST_ROUTER_TEMPORARY] = "temporary",
  18 };
  19
  20 DEFINE_STRING_TABLE_LOOKUP_WITH_BOOLEAN(multicast_router, MulticastRouter, _MULTICAST_ROUTER_INVALID);
  21 DEFINE_CONFIG_PARSE_ENUM(config_parse_multicast_router, multicast_router, MulticastRouter,
  22                          "Failed to parse bridge multicast router setting");
  23
  24 /* callback for bridge netdev's parameter set */
  25 static int netdev_bridge_set_handler(sd_netlink *rtnl, sd_netlink_message *m, NetDev *netdev) {
  26         int r;
  27
  28         assert(netdev);
  29         assert(m);
  30
  31         r = sd_netlink_message_get_errno(m);
  32         if (r < 0) {
  33                 log_netdev_warning_errno(netdev, r, "Bridge parameters could not be set: %m");
  34                 return 1;
  35         }
  36
  37         log_netdev_debug(netdev, "Bridge parameters set success");
  38
  39         return 1;
  40 }
  41
  42 static int netdev_bridge_post_create(NetDev *netdev, Link *link, sd_netlink_message *m) {
  43         _cleanup_(sd_netlink_message_unrefp) sd_netlink_message *req = NULL;
  44         Bridge *b;
  45         int r;
  46
  47         assert(netdev);
  48
  49         b = BRIDGE(netdev);
  50
  51         assert(b);
  52
  53         r = sd_rtnl_message_new_link(netdev->manager->rtnl, &req, RTM_NEWLINK, netdev->ifindex);
  54         if (r < 0)
  55                 return log_netdev_error_errno(netdev, r, "Could not allocate RTM_SETLINK message: %m");
  56
  57         r = sd_netlink_message_set_flags(req, NLM_F_REQUEST | NLM_F_ACK);
  58         if (r < 0)
  59                 return log_link_error_errno(link, r, "Could not set netlink flags: %m");
  60
  61         r = sd_netlink_message_open_container(req, IFLA_LINKINFO);
  62         if (r < 0)
  63                 return log_netdev_error_errno(netdev, r, "Could not append IFLA_LINKINFO attribute: %m");
  64
  65         r = sd_netlink_message_open_container_union(req, IFLA_INFO_DATA, netdev_kind_to_string(netdev->kind));
  66         if (r < 0)
  67                 return log_netdev_error_errno(netdev, r, "Could not append IFLA_INFO_DATA attribute: %m");
  68
  69         /* convert to jiffes */
  70         if (b->forward_delay != USEC_INFINITY) {
  71                 r = sd_netlink_message_append_u32(req, IFLA_BR_FORWARD_DELAY, usec_to_jiffies(b->forward_delay));
  72                 if (r < 0)
  73                         return log_netdev_error_errno(netdev, r, "Could not append IFLA_BR_FORWARD_DELAY attribute: %m");
  74         }
  75
  76         if (b->hello_time > 0) {
  77                 r = sd_netlink_message_append_u32(req, IFLA_BR_HELLO_TIME, usec_to_jiffies(b->hello_time));
  78                 if (r < 0)
  79                         return log_netdev_error_errno(netdev, r, "Could not append IFLA_BR_HELLO_TIME attribute: %m");
  80         }
  81
  82         if (b->max_age > 0) {
  83                 r = sd_netlink_message_append_u32(req, IFLA_BR_MAX_AGE, usec_to_jiffies(b->max_age));
  84                 if (r < 0)
  85                         return log_netdev_error_errno(netdev, r, "Could not append IFLA_BR_MAX_AGE attribute: %m");
  86         }
  87
  88         if (b->ageing_time != USEC_INFINITY) {
  89                 r = sd_netlink_message_append_u32(req, IFLA_BR_AGEING_TIME, usec_to_jiffies(b->ageing_time));
  90                 if (r < 0)
  91                         return log_netdev_error_errno(netdev, r, "Could not append IFLA_BR_AGEING_TIME attribute: %m");
  92         }
  93
  94         if (b->priority > 0) {
  95                 r = sd_netlink_message_append_u16(req, IFLA_BR_PRIORITY, b->priority);
  96                 if (r < 0)
  97                         return log_netdev_error_errno(netdev, r, "Could not append IFLA_BR_PRIORITY attribute: %m");
  98         }
  99
 100         if (b->group_fwd_mask > 0) {
 101                 r = sd_netlink_message_append_u16(req, IFLA_BR_GROUP_FWD_MASK, b->group_fwd_mask);
 102                 if (r < 0)
 103                         return log_netdev_error_errno(netdev, r, "Could not append IFLA_BR_GROUP_FWD_MASK attribute: %m");
 104         }
 105
 106         if (b->default_pvid != VLANID_INVALID) {
 107                 r = sd_netlink_message_append_u16(req, IFLA_BR_VLAN_DEFAULT_PVID, b->default_pvid);
 108                 if (r < 0)
 109                         return log_netdev_error_errno(netdev, r, "Could not append IFLA_BR_VLAN_DEFAULT_PVID attribute: %m");
 110         }
 111
 112         if (b->mcast_querier >= 0) {
 113                 r = sd_netlink_message_append_u8(req, IFLA_BR_MCAST_QUERIER, b->mcast_querier);
 114                 if (r < 0)
 115                         return log_netdev_error_errno(netdev, r, "Could not append IFLA_BR_MCAST_QUERIER attribute: %m");
 116         }
 117
 118         if (b->mcast_snooping >= 0) {
 119                 r = sd_netlink_message_append_u8(req, IFLA_BR_MCAST_SNOOPING, b->mcast_snooping);
 120                 if (r < 0)
 121                         return log_netdev_error_errno(netdev, r, "Could not append IFLA_BR_MCAST_SNOOPING attribute: %m");
 122         }
 123
 124         if (b->vlan_filtering >= 0) {
 125                 r = sd_netlink_message_append_u8(req, IFLA_BR_VLAN_FILTERING, b->vlan_filtering);
 126                 if (r < 0)
 127                         return log_netdev_error_errno(netdev, r, "Could not append IFLA_BR_VLAN_FILTERING attribute: %m");
 128         }
 129
 130         if (b->stp >= 0) {
 131                 r = sd_netlink_message_append_u32(req, IFLA_BR_STP_STATE, b->stp);
 132                 if (r < 0)
 133                         return log_netdev_error_errno(netdev, r, "Could not append IFLA_BR_STP_STATE attribute: %m");
 134         }
 135
 136         r = sd_netlink_message_close_container(req);
 137         if (r < 0)
 138                 return log_netdev_error_errno(netdev, r, "Could not append IFLA_LINKINFO attribute: %m");
 139
 140         r = sd_netlink_message_close_container(req);
 141         if (r < 0)
 142                 return log_netdev_error_errno(netdev, r, "Could not append IFLA_INFO_DATA attribute: %m");
 143
 144         r = netlink_call_async(netdev->manager->rtnl, NULL, req, netdev_bridge_set_handler,
 145                                netdev_destroy_callback, netdev);
 146         if (r < 0)
 147                 return log_netdev_error_errno(netdev, r, "Could not send rtnetlink message: %m");
 148
 149         netdev_ref(netdev);
 150
 151         return r;
 152 }
 153
 154 static int link_set_bridge_handler(sd_netlink *rtnl, sd_netlink_message *m, Link *link) {
 155         int r;
 156
 157         assert(m);
 158         assert(link);
 159         assert(link->ifname);
 160
 161         if (IN_SET(link->state, LINK_STATE_FAILED, LINK_STATE_LINGER))
 162                 return 1;
 163
 164         r = sd_netlink_message_get_errno(m);
 165         if (r < 0) {
 166                 log_link_warning_errno(link, r, "Could not set bridge interface: %m");
 167                 return 1;
 168         }
 169
 170         return 1;
 171 }
 172
 173 int link_set_bridge(Link *link) {
 174         _cleanup_(sd_netlink_message_unrefp) sd_netlink_message *req = NULL;
 175         int r;
 176
 177         assert(link);
 178         assert(link->network);
 179
 180         r = sd_rtnl_message_new_link(link->manager->rtnl, &req, RTM_SETLINK, link->ifindex);
 181         if (r < 0)
 182                 return log_link_error_errno(link, r, "Could not allocate RTM_SETLINK message: %m");
 183
 184         r = sd_rtnl_message_link_set_family(req, PF_BRIDGE);
 185         if (r < 0)
 186                 return log_link_error_errno(link, r, "Could not set message family: %m");
 187
 188         r = sd_netlink_message_open_container(req, IFLA_PROTINFO);
 189         if (r < 0)
 190                 return log_link_error_errno(link, r, "Could not append IFLA_PROTINFO attribute: %m");
 191
 192         if (link->network->use_bpdu >= 0) {
 193                 r = sd_netlink_message_append_u8(req, IFLA_BRPORT_GUARD, link->network->use_bpdu);
 194                 if (r < 0)
 195                         return log_link_error_errno(link, r, "Could not append IFLA_BRPORT_GUARD attribute: %m");
 196         }
 197
 198         if (link->network->hairpin >= 0) {
 199                 r = sd_netlink_message_append_u8(req, IFLA_BRPORT_MODE, link->network->hairpin);
 200                 if (r < 0)
 201                         return log_link_error_errno(link, r, "Could not append IFLA_BRPORT_MODE attribute: %m");
 202         }
 203
 204         if (link->network->fast_leave >= 0) {
 205                 r = sd_netlink_message_append_u8(req, IFLA_BRPORT_FAST_LEAVE, link->network->fast_leave);
 206                 if (r < 0)
 207                         return log_link_error_errno(link, r, "Could not append IFLA_BRPORT_FAST_LEAVE attribute: %m");
 208         }
 209
 210         if (link->network->allow_port_to_be_root >=  0) {
 211                 r = sd_netlink_message_append_u8(req, IFLA_BRPORT_PROTECT, link->network->allow_port_to_be_root);
 212                 if (r < 0)
 213                         return log_link_error_errno(link, r, "Could not append IFLA_BRPORT_PROTECT attribute: %m");
 214         }
 215
 216         if (link->network->unicast_flood >= 0) {
 217                 r = sd_netlink_message_append_u8(req, IFLA_BRPORT_UNICAST_FLOOD, link->network->unicast_flood);
 218                 if (r < 0)
 219                         return log_link_error_errno(link, r, "Could not append IFLA_BRPORT_UNICAST_FLOOD attribute: %m");
 220         }
 221
 222         if (link->network->multicast_flood >= 0) {
 223                 r = sd_netlink_message_append_u8(req, IFLA_BRPORT_MCAST_FLOOD, link->network->multicast_flood);
 224                 if (r < 0)
 225                         return log_link_error_errno(link, r, "Could not append IFLA_BRPORT_MCAST_FLOOD attribute: %m");
 226         }
 227
 228         if (link->network->multicast_to_unicast >= 0) {
 229                 r = sd_netlink_message_append_u8(req, IFLA_BRPORT_MCAST_TO_UCAST, link->network->multicast_to_unicast);
 230                 if (r < 0)
 231                         return log_link_error_errno(link, r, "Could not append IFLA_BRPORT_MCAST_TO_UCAST attribute: %m");
 232         }
 233
 234         if (link->network->neighbor_suppression >= 0) {
 235                 r = sd_netlink_message_append_u8(req, IFLA_BRPORT_NEIGH_SUPPRESS, link->network->neighbor_suppression);
 236                 if (r < 0)
 237                         return log_link_error_errno(link, r, "Could not append IFLA_BRPORT_NEIGH_SUPPRESS attribute: %m");
 238         }
 239
 240         if (link->network->learning >= 0) {
 241                 r = sd_netlink_message_append_u8(req, IFLA_BRPORT_LEARNING, link->network->learning);
 242                 if (r < 0)
 243                         return log_link_error_errno(link, r, "Could not append IFLA_BRPORT_LEARNING attribute: %m");
 244         }
 245
 246         if (link->network->bridge_proxy_arp >= 0) {
 247                 r = sd_netlink_message_append_u8(req, IFLA_BRPORT_PROXYARP, link->network->bridge_proxy_arp);
 248                 if (r < 0)
 249                         return log_link_error_errno(link, r, "Could not append IFLA_BRPORT_PROXYARP attribute: %m");
 250         }
 251
 252         if (link->network->bridge_proxy_arp_wifi >= 0) {
 253                 r = sd_netlink_message_append_u8(req, IFLA_BRPORT_PROXYARP_WIFI, link->network->bridge_proxy_arp_wifi);
 254                 if (r < 0)
 255                         return log_link_error_errno(link, r, "Could not append IFLA_BRPORT_PROXYARP_WIFI attribute: %m");
 256         }
 257
 258         if (link->network->cost != 0) {
 259                 r = sd_netlink_message_append_u32(req, IFLA_BRPORT_COST, link->network->cost);
 260                 if (r < 0)
 261                         return log_link_error_errno(link, r, "Could not append IFLA_BRPORT_COST attribute: %m");
 262         }
 263
 264         if (link->network->priority != LINK_BRIDGE_PORT_PRIORITY_INVALID) {
 265                 r = sd_netlink_message_append_u16(req, IFLA_BRPORT_PRIORITY, link->network->priority);
 266                 if (r < 0)
 267                         return log_link_error_errno(link, r, "Could not append IFLA_BRPORT_PRIORITY attribute: %m");
 268         }
 269
 270         if (link->network->multicast_router != _MULTICAST_ROUTER_INVALID) {
 271                 r = sd_netlink_message_append_u8(req, IFLA_BRPORT_MULTICAST_ROUTER, link->network->multicast_router);
 272                 if (r < 0)
 273                         return log_link_error_errno(link, r, "Could not append IFLA_BRPORT_MULTICAST_ROUTER attribute: %m");
 274         }
 275
 276         r = sd_netlink_message_close_container(req);
 277         if (r < 0)
 278                 return log_link_error_errno(link, r, "Could not append IFLA_LINKINFO attribute: %m");
 279
 280         r = netlink_call_async(link->manager->rtnl, NULL, req, link_set_bridge_handler,
 281                                link_netlink_destroy_callback, link);
 282         if (r < 0)
 283                 return log_link_error_errno(link, r, "Could not send rtnetlink message: %m");
 284
 285         link_ref(link);
 286
 287         return r;
 288 }
 289
 290 static void bridge_init(NetDev *n) {
 291         Bridge *b;
 292
 293         b = BRIDGE(n);
 294
 295         assert(b);
 296
 297         b->mcast_querier = -1;
 298         b->mcast_snooping = -1;
 299         b->vlan_filtering = -1;
 300         b->stp = -1;
 301         b->default_pvid = VLANID_INVALID;
 302         b->forward_delay = USEC_INFINITY;
 303         b->ageing_time = USEC_INFINITY;
 304 }
 305
 306 const NetDevVTable bridge_vtable = {
 307         .object_size = sizeof(Bridge),
 308         .init = bridge_init,
 309         .sections = "Match\0NetDev\0Bridge\0",
 310         .post_create = netdev_bridge_post_create,
 311         .create_type = NETDEV_CREATE_MASTER,
 312 };