2 * netifd - network interface daemon
3 * Copyright (C) 2012 Felix Fietkau <nbd@openwrt.org>
5 * This program is free software; you can redistribute it and/or modify
6 * it under the terms of the GNU General Public License version 2
7 * as published by the Free Software Foundation
9 * This program is distributed in the hope that it will be useful,
10 * but WITHOUT ANY WARRANTY; without even the implied warranty of
11 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
12 * GNU General Public License for more details.
22 #include "interface.h"
28 BRIDGE_ATTR_FORWARD_DELAY
,
29 BRIDGE_ATTR_IGMP_SNOOP
,
30 BRIDGE_ATTR_AGEING_TIME
,
31 BRIDGE_ATTR_HELLO_TIME
,
36 static const struct blobmsg_policy bridge_attrs
[__BRIDGE_ATTR_MAX
] = {
37 [BRIDGE_ATTR_IFNAME
] = { "ifname", BLOBMSG_TYPE_ARRAY
},
38 [BRIDGE_ATTR_STP
] = { "stp", BLOBMSG_TYPE_BOOL
},
39 [BRIDGE_ATTR_FORWARD_DELAY
] = { "forward_delay", BLOBMSG_TYPE_INT32
},
40 [BRIDGE_ATTR_AGEING_TIME
] = { "ageing_time", BLOBMSG_TYPE_INT32
},
41 [BRIDGE_ATTR_HELLO_TIME
] = { "hello_time", BLOBMSG_TYPE_INT32
},
42 [BRIDGE_ATTR_MAX_AGE
] = { "max_age", BLOBMSG_TYPE_INT32
},
43 [BRIDGE_ATTR_IGMP_SNOOP
] = { "igmp_snooping", BLOBMSG_TYPE_BOOL
},
46 static const union config_param_info bridge_attr_info
[__BRIDGE_ATTR_MAX
] = {
47 [BRIDGE_ATTR_IFNAME
] = { .type
= BLOBMSG_TYPE_STRING
},
50 static const struct config_param_list bridge_attr_list
= {
51 .n_params
= __BRIDGE_ATTR_MAX
,
52 .params
= bridge_attrs
,
53 .info
= bridge_attr_info
,
56 .next
= { &device_attr_list
},
59 static struct device
*bridge_create(const char *name
, struct blob_attr
*attr
);
60 static void bridge_config_init(struct device
*dev
);
61 static void bridge_free(struct device
*dev
);
62 static void bridge_dump_info(struct device
*dev
, struct blob_buf
*b
);
64 bridge_reload(struct device
*dev
, struct blob_attr
*attr
);
66 const struct device_type bridge_device_type
= {
68 .config_params
= &bridge_attr_list
,
70 .create
= bridge_create
,
71 .config_init
= bridge_config_init
,
72 .reload
= bridge_reload
,
74 .dump_info
= bridge_dump_info
,
79 device_state_cb set_state
;
81 struct blob_attr
*config_data
;
82 struct bridge_config config
;
83 struct blob_attr
*ifnames
;
87 struct bridge_member
*primary_port
;
88 struct vlist_tree members
;
92 struct bridge_member
{
93 struct vlist_node node
;
94 struct bridge_state
*bst
;
95 struct device_user dev
;
101 bridge_reset_primary(struct bridge_state
*bst
)
103 struct bridge_member
*bm
;
105 if (!bst
->primary_port
&&
106 (bst
->dev
.settings
.flags
& DEV_OPT_MACADDR
))
109 bst
->primary_port
= NULL
;
110 bst
->dev
.settings
.flags
&= ~DEV_OPT_MACADDR
;
111 vlist_for_each_element(&bst
->members
, bm
, node
) {
117 bst
->primary_port
= bm
;
118 if (bm
->dev
.dev
->settings
.flags
& DEV_OPT_MACADDR
)
119 macaddr
= bm
->dev
.dev
->settings
.macaddr
;
121 macaddr
= bm
->dev
.dev
->orig_settings
.macaddr
;
122 memcpy(bst
->dev
.settings
.macaddr
, macaddr
, 6);
123 bst
->dev
.settings
.flags
|= DEV_OPT_MACADDR
;
129 bridge_disable_member(struct bridge_member
*bm
)
131 struct bridge_state
*bst
= bm
->bst
;
136 system_bridge_delif(&bst
->dev
, bm
->dev
.dev
);
137 device_release(&bm
->dev
);
143 bridge_enable_member(struct bridge_member
*bm
)
145 struct bridge_state
*bst
= bm
->bst
;
151 ret
= device_claim(&bm
->dev
);
155 ret
= system_bridge_addif(&bst
->dev
, bm
->dev
.dev
);
157 D(DEVICE
, "Bridge device %s could not be added\n", bm
->dev
.dev
->ifname
);
170 bridge_remove_member(struct bridge_member
*bm
)
172 struct bridge_state
*bst
= bm
->bst
;
177 if (bm
== bst
->primary_port
);
178 bridge_reset_primary(bst
);
181 bridge_disable_member(bm
);
184 bm
->bst
->n_present
--;
186 bst
->force_active
= false;
187 if (bst
->n_present
== 0)
188 device_set_present(&bst
->dev
, false);
192 bridge_member_cb(struct device_user
*dev
, enum device_event ev
)
194 struct bridge_member
*bm
= container_of(dev
, struct bridge_member
, dev
);
195 struct bridge_state
*bst
= bm
->bst
;
199 assert(!bm
->present
);
205 bridge_enable_member(bm
);
206 else if (bst
->n_present
== 1)
207 device_set_present(&bst
->dev
, true);
210 case DEV_EVENT_REMOVE
:
212 vlist_delete(&bst
->members
, &bm
->node
);
217 bridge_remove_member(bm
);
226 bridge_set_down(struct bridge_state
*bst
)
228 struct bridge_member
*bm
;
230 bst
->set_state(&bst
->dev
, false);
232 vlist_for_each_element(&bst
->members
, bm
, node
)
233 bridge_disable_member(bm
);
235 system_bridge_delbr(&bst
->dev
);
241 bridge_set_up(struct bridge_state
*bst
)
243 struct bridge_member
*bm
;
246 if (!bst
->force_active
&& !bst
->n_present
)
249 ret
= system_bridge_addbr(&bst
->dev
, &bst
->config
);
253 vlist_for_each_element(&bst
->members
, bm
, node
)
254 bridge_enable_member(bm
);
256 if (!bst
->force_active
&& !bst
->n_present
) {
257 /* initialization of all member interfaces failed */
258 system_bridge_delbr(&bst
->dev
);
259 device_set_present(&bst
->dev
, false);
263 bridge_reset_primary(bst
);
264 ret
= bst
->set_state(&bst
->dev
, true);
266 bridge_set_down(bst
);
273 bridge_set_state(struct device
*dev
, bool up
)
275 struct bridge_state
*bst
;
277 bst
= container_of(dev
, struct bridge_state
, dev
);
280 return bridge_set_up(bst
);
282 return bridge_set_down(bst
);
285 static struct bridge_member
*
286 bridge_create_member(struct bridge_state
*bst
, struct device
*dev
, bool hotplug
)
288 struct bridge_member
*bm
;
290 bm
= calloc(1, sizeof(*bm
) + strlen(dev
->ifname
) + 1);
292 bm
->dev
.cb
= bridge_member_cb
;
293 bm
->dev
.hotplug
= hotplug
;
294 strcpy(bm
->name
, dev
->ifname
);
296 vlist_add(&bst
->members
, &bm
->node
, bm
->name
);
298 bm
->node
.version
= -1;
304 bridge_member_update(struct vlist_tree
*tree
, struct vlist_node
*node_new
,
305 struct vlist_node
*node_old
)
307 struct bridge_member
*bm
;
311 bm
= container_of(node_new
, struct bridge_member
, node
);
320 device_add_user(&bm
->dev
, dev
);
325 bm
= container_of(node_old
, struct bridge_member
, node
);
326 bridge_remove_member(bm
);
327 device_remove_user(&bm
->dev
);
334 bridge_add_member(struct bridge_state
*bst
, const char *name
)
338 dev
= device_get(name
, true);
342 bridge_create_member(bst
, dev
, false);
346 bridge_hotplug_add(struct device
*dev
, struct device
*member
)
348 struct bridge_state
*bst
= container_of(dev
, struct bridge_state
, dev
);
350 bridge_create_member(bst
, member
, true);
356 bridge_hotplug_del(struct device
*dev
, struct device
*member
)
358 struct bridge_state
*bst
= container_of(dev
, struct bridge_state
, dev
);
359 struct bridge_member
*bm
;
361 bm
= vlist_find(&bst
->members
, member
->ifname
, bm
, node
);
363 return UBUS_STATUS_NOT_FOUND
;
365 vlist_delete(&bst
->members
, &bm
->node
);
370 bridge_hotplug_prepare(struct device
*dev
)
372 struct bridge_state
*bst
;
374 bst
= container_of(dev
, struct bridge_state
, dev
);
375 bst
->force_active
= true;
376 device_set_present(&bst
->dev
, true);
381 static const struct device_hotplug_ops bridge_ops
= {
382 .prepare
= bridge_hotplug_prepare
,
383 .add
= bridge_hotplug_add
,
384 .del
= bridge_hotplug_del
388 bridge_free(struct device
*dev
)
390 struct bridge_state
*bst
;
392 bst
= container_of(dev
, struct bridge_state
, dev
);
393 vlist_flush_all(&bst
->members
);
398 bridge_dump_info(struct device
*dev
, struct blob_buf
*b
)
400 struct bridge_state
*bst
;
401 struct bridge_member
*bm
;
404 bst
= container_of(dev
, struct bridge_state
, dev
);
406 system_if_dump_info(dev
, b
);
407 list
= blobmsg_open_array(b
, "bridge-members");
409 vlist_for_each_element(&bst
->members
, bm
, node
)
410 blobmsg_add_string(b
, NULL
, bm
->dev
.dev
->ifname
);
412 blobmsg_close_array(b
, list
);
416 bridge_config_init(struct device
*dev
)
418 struct bridge_state
*bst
;
419 struct blob_attr
*cur
;
422 bst
= container_of(dev
, struct bridge_state
, dev
);
427 vlist_update(&bst
->members
);
428 blobmsg_for_each_attr(cur
, bst
->ifnames
, rem
) {
429 bridge_add_member(bst
, blobmsg_data(cur
));
431 vlist_flush(&bst
->members
);
435 bridge_apply_settings(struct bridge_state
*bst
, struct blob_attr
**tb
)
437 struct bridge_config
*cfg
= &bst
->config
;
438 struct blob_attr
*cur
;
442 cfg
->forward_delay
= 2;
443 cfg
->igmp_snoop
= true;
445 if ((cur
= tb
[BRIDGE_ATTR_STP
]))
446 cfg
->stp
= blobmsg_get_bool(cur
);
448 if ((cur
= tb
[BRIDGE_ATTR_FORWARD_DELAY
]))
449 cfg
->forward_delay
= blobmsg_get_u32(cur
);
451 if ((cur
= tb
[BRIDGE_ATTR_IGMP_SNOOP
]))
452 cfg
->igmp_snoop
= blobmsg_get_bool(cur
);
454 if ((cur
= tb
[BRIDGE_ATTR_AGEING_TIME
])) {
455 cfg
->ageing_time
= blobmsg_get_u32(cur
);
456 cfg
->flags
|= BRIDGE_OPT_AGEING_TIME
;
459 if ((cur
= tb
[BRIDGE_ATTR_HELLO_TIME
])) {
460 cfg
->hello_time
= blobmsg_get_u32(cur
);
461 cfg
->flags
|= BRIDGE_OPT_HELLO_TIME
;
464 if ((cur
= tb
[BRIDGE_ATTR_MAX_AGE
])) {
465 cfg
->max_age
= blobmsg_get_u32(cur
);
466 cfg
->flags
|= BRIDGE_OPT_MAX_AGE
;
471 bridge_reload(struct device
*dev
, struct blob_attr
*attr
)
473 struct blob_attr
*tb_dev
[__DEV_ATTR_MAX
];
474 struct blob_attr
*tb_br
[__BRIDGE_ATTR_MAX
];
475 enum dev_change_type ret
= DEV_CONFIG_APPLIED
;
477 struct bridge_state
*bst
;
479 BUILD_BUG_ON(sizeof(diff
) < __BRIDGE_ATTR_MAX
/ 8);
480 BUILD_BUG_ON(sizeof(diff
) < __DEV_ATTR_MAX
/ 8);
482 bst
= container_of(dev
, struct bridge_state
, dev
);
484 blobmsg_parse(device_attr_list
.params
, __DEV_ATTR_MAX
, tb_dev
,
485 blob_data(attr
), blob_len(attr
));
486 blobmsg_parse(bridge_attrs
, __BRIDGE_ATTR_MAX
, tb_br
,
487 blob_data(attr
), blob_len(attr
));
489 bst
->ifnames
= tb_br
[BRIDGE_ATTR_IFNAME
];
490 device_init_settings(dev
, tb_dev
);
491 bridge_apply_settings(bst
, tb_br
);
493 if (bst
->config_data
) {
494 struct blob_attr
*otb_dev
[__DEV_ATTR_MAX
];
495 struct blob_attr
*otb_br
[__BRIDGE_ATTR_MAX
];
497 blobmsg_parse(device_attr_list
.params
, __DEV_ATTR_MAX
, otb_dev
,
498 blob_data(bst
->config_data
), blob_len(bst
->config_data
));
501 config_diff(tb_dev
, otb_dev
, &device_attr_list
, &diff
);
502 if (diff
& ~(1 << DEV_ATTR_IFNAME
))
503 ret
= DEV_CONFIG_RESTART
;
505 blobmsg_parse(bridge_attrs
, __BRIDGE_ATTR_MAX
, otb_br
,
506 blob_data(bst
->config_data
), blob_len(bst
->config_data
));
509 config_diff(tb_br
, otb_br
, &bridge_attr_list
, &diff
);
510 if (diff
& ~(1 << BRIDGE_ATTR_IFNAME
))
511 ret
= DEV_CONFIG_RESTART
;
513 bridge_config_init(dev
);
516 bst
->config_data
= attr
;
520 static struct device
*
521 bridge_create(const char *name
, struct blob_attr
*attr
)
523 struct bridge_state
*bst
;
524 struct device
*dev
= NULL
;
526 bst
= calloc(1, sizeof(*bst
));
531 device_init(dev
, &bridge_device_type
, name
);
532 dev
->config_pending
= true;
534 bst
->set_state
= dev
->set_state
;
535 dev
->set_state
= bridge_set_state
;
537 dev
->hotplug_ops
= &bridge_ops
;
539 vlist_init(&bst
->members
, avl_strcmp
, bridge_member_update
);
540 bst
->members
.keep_old
= true;
541 bridge_reload(dev
, attr
);