config: initialize bridge and bridge vlans before other devices
[project/netifd.git] / config.c
1 /*
2 * netifd - network interface daemon
3 * Copyright (C) 2012 Felix Fietkau <nbd@openwrt.org>
4 *
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
8 *
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.
13 */
14 #define _GNU_SOURCE
15 #include <string.h>
16 #include <stdlib.h>
17 #include <stdio.h>
18
19 #include <uci.h>
20
21 #include "netifd.h"
22 #include "interface.h"
23 #include "interface-ip.h"
24 #include "iprule.h"
25 #include "proto.h"
26 #include "wireless.h"
27 #include "config.h"
28
29 bool config_init = false;
30
31 static struct uci_context *uci_ctx;
32 static struct uci_package *uci_network;
33 static struct uci_package *uci_wireless;
34 static struct blob_buf b;
35
36 static int
37 config_section_idx(struct uci_section *s)
38 {
39 struct uci_element *e;
40 int idx = 0;
41
42 uci_foreach_element(&uci_wireless->sections, e) {
43 struct uci_section *cur = uci_to_section(e);
44
45 if (s == cur)
46 return idx;
47
48 if (!strcmp(cur->type, s->type))
49 idx++;
50 }
51
52 return -1;
53 }
54
55 static bool
56 config_bridge_has_vlans(const char *br_name)
57 {
58 struct uci_element *e;
59
60 uci_foreach_element(&uci_network->sections, e) {
61 struct uci_section *s = uci_to_section(e);
62 const char *name;
63
64 if (strcmp(s->type, "bridge-vlan") != 0)
65 continue;
66
67 name = uci_lookup_option_string(uci_ctx, s, "device");
68 if (!name)
69 continue;
70
71 if (!strcmp(name, br_name))
72 return true;
73 }
74
75 return false;
76 }
77
78 static void
79 config_fixup_bridge_var(struct uci_section *s, const char *name, const char *val)
80 {
81 struct uci_ptr ptr = {
82 .p = s->package,
83 .s = s,
84 .option = name,
85 .value = val,
86 };
87
88 uci_lookup_ptr(uci_ctx, &ptr, NULL, false);
89 if (ptr.o)
90 return;
91
92 uci_set(uci_ctx, &ptr);
93 }
94
95 static void
96 config_fixup_bridge_vlan_filtering(struct uci_section *s, const char *name)
97 {
98 bool has_vlans = config_bridge_has_vlans(name);
99
100 config_fixup_bridge_var(s, "__has_vlans", has_vlans ? "1" : "0");
101
102 if (!has_vlans)
103 return;
104
105 config_fixup_bridge_var(s, "vlan_filtering", "1");
106 }
107
108 static int
109 config_parse_bridge_interface(struct uci_section *s, struct device_type *devtype)
110 {
111 char *name;
112
113 name = alloca(strlen(s->e.name) + strlen(devtype->name_prefix) + 2);
114 sprintf(name, "%s-%s", devtype->name_prefix, s->e.name);
115 blobmsg_add_string(&b, "name", name);
116
117 config_fixup_bridge_vlan_filtering(s, name);
118 uci_to_blob(&b, s, devtype->config_params);
119 if (!device_create(name, devtype, b.head)) {
120 D(INTERFACE, "Failed to create '%s' device for interface '%s'\n",
121 devtype->name, s->e.name);
122 }
123
124 blob_buf_init(&b, 0);
125 blobmsg_add_string(&b, "ifname", name);
126 return 0;
127 }
128
129 static void
130 config_parse_interface(struct uci_section *s, bool alias)
131 {
132 struct interface *iface;
133 const char *type = NULL, *disabled;
134 struct blob_attr *config;
135 bool bridge = false;
136 struct device_type *devtype = NULL;
137
138 disabled = uci_lookup_option_string(uci_ctx, s, "disabled");
139 if (disabled && !strcmp(disabled, "1"))
140 return;
141
142 blob_buf_init(&b, 0);
143
144 if (!alias)
145 type = uci_lookup_option_string(uci_ctx, s, "type");
146
147 if (type)
148 devtype = device_type_get(type);
149
150 if (devtype && devtype->bridge_capability) {
151 if (config_parse_bridge_interface(s, devtype))
152 return;
153
154 bridge = true;
155 }
156
157 uci_to_blob(&b, s, &interface_attr_list);
158
159 iface = interface_alloc(s->e.name, b.head, false);
160 if (!iface)
161 return;
162
163 if (iface->proto_handler && iface->proto_handler->config_params)
164 uci_to_blob(&b, s, iface->proto_handler->config_params);
165
166 if (!bridge && uci_to_blob(&b, s, simple_device_type.config_params))
167 iface->device_config = true;
168
169 config = blob_memdup(b.head);
170 if (!config)
171 goto error;
172
173 if (alias) {
174 if (!interface_add_alias(iface, config))
175 goto error_free_config;
176 } else {
177 if (!interface_add(iface, config))
178 goto error_free_config;
179 }
180 return;
181
182 error_free_config:
183 free(config);
184 error:
185 free(iface);
186 }
187
188 static void
189 config_parse_route(struct uci_section *s, bool v6)
190 {
191 void *route;
192
193 blob_buf_init(&b, 0);
194 route = blobmsg_open_array(&b, "route");
195 uci_to_blob(&b, s, &route_attr_list);
196 blobmsg_close_array(&b, route);
197 interface_ip_add_route(NULL, blob_data(b.head), v6);
198 }
199
200 static void
201 config_parse_neighbor(struct uci_section *s, bool v6)
202 {
203 void *neighbor;
204 blob_buf_init(&b,0);
205 neighbor = blobmsg_open_array(&b, "neighbor");
206 uci_to_blob(&b,s, &neighbor_attr_list);
207 blobmsg_close_array(&b, neighbor);
208 interface_ip_add_neighbor(NULL, blob_data(b.head), v6);
209 }
210
211 static void
212 config_parse_rule(struct uci_section *s, bool v6)
213 {
214 void *rule;
215
216 blob_buf_init(&b, 0);
217 rule = blobmsg_open_array(&b, "rule");
218 uci_to_blob(&b, s, &rule_attr_list);
219 blobmsg_close_array(&b, rule);
220 iprule_add(blob_data(b.head), v6);
221 }
222
223 static void
224 config_init_devices(bool bridge)
225 {
226 struct uci_element *e;
227
228 uci_foreach_element(&uci_network->sections, e) {
229 const struct uci_blob_param_list *params = NULL;
230 struct uci_section *s = uci_to_section(e);
231 struct device_type *devtype = NULL;
232 struct device *dev;
233 const char *type, *name;
234
235 if (strcmp(s->type, "device") != 0)
236 continue;
237
238 name = uci_lookup_option_string(uci_ctx, s, "name");
239 if (!name)
240 continue;
241
242 type = uci_lookup_option_string(uci_ctx, s, "type");
243 if (type)
244 devtype = device_type_get(type);
245
246 if (bridge != (devtype && devtype->bridge_capability))
247 continue;
248
249 if (devtype)
250 params = devtype->config_params;
251 if (!params)
252 params = simple_device_type.config_params;
253
254 if (devtype && devtype->bridge_capability)
255 config_fixup_bridge_vlan_filtering(s, name);
256
257 blob_buf_init(&b, 0);
258 uci_to_blob(&b, s, params);
259 if (devtype) {
260 dev = device_create(name, devtype, b.head);
261 if (!dev)
262 continue;
263 } else {
264 dev = device_get(name, 1);
265 if (!dev)
266 continue;
267
268 dev->current_config = true;
269 device_apply_config(dev, dev->type, b.head);
270 }
271 dev->default_config = false;
272 }
273 }
274
275 static void
276 config_parse_vlan(struct device *dev, struct uci_section *s)
277 {
278 enum {
279 BRVLAN_ATTR_VID,
280 BRVLAN_ATTR_LOCAL,
281 BRVLAN_ATTR_PORTS,
282 __BRVLAN_ATTR_MAX,
283 };
284 static const struct blobmsg_policy vlan_attrs[__BRVLAN_ATTR_MAX] = {
285 [BRVLAN_ATTR_VID] = { "vlan", BLOBMSG_TYPE_INT32 },
286 [BRVLAN_ATTR_LOCAL] = { "local", BLOBMSG_TYPE_BOOL },
287 [BRVLAN_ATTR_PORTS] = { "ports", BLOBMSG_TYPE_ARRAY },
288 };
289 static const struct uci_blob_param_info vlan_attr_info[__BRVLAN_ATTR_MAX] = {
290 [BRVLAN_ATTR_PORTS] = { .type = BLOBMSG_TYPE_STRING },
291 };
292 static const struct uci_blob_param_list vlan_attr_list = {
293 .n_params = __BRVLAN_ATTR_MAX,
294 .params = vlan_attrs,
295 .info = vlan_attr_info,
296 };
297 struct blob_attr *tb[__BRVLAN_ATTR_MAX];
298 struct blob_attr *cur;
299 struct bridge_vlan_port *port;
300 struct bridge_vlan *vlan;
301 unsigned int vid;
302 const char *val;
303 char *name_buf;
304 int name_len = 0;
305 int n_ports = 0;
306 int rem;
307
308 val = uci_lookup_option_string(uci_ctx, s, "vlan");
309 if (!val)
310 return;
311
312 blob_buf_init(&b, 0);
313 uci_to_blob(&b, s, &vlan_attr_list);
314 blobmsg_parse(vlan_attrs, __BRVLAN_ATTR_MAX, tb, blob_data(b.head), blob_len(b.head));
315
316 if (!tb[BRVLAN_ATTR_VID])
317 return;
318
319 vid = blobmsg_get_u32(tb[BRVLAN_ATTR_VID]);
320 if (!vid || vid > 4095)
321 return;
322
323 blobmsg_for_each_attr(cur, tb[BRVLAN_ATTR_PORTS], rem) {
324 name_len += strlen(blobmsg_get_string(cur)) + 1;
325 n_ports++;
326 }
327
328 vlan = calloc(1, sizeof(*vlan) + n_ports * sizeof(*port) + name_len);
329 if (!vlan)
330 return;
331
332 vlan->vid = vid;
333 vlan->local = true;
334 if (tb[BRVLAN_ATTR_LOCAL])
335 vlan->local = blobmsg_get_bool(tb[BRVLAN_ATTR_LOCAL]);
336
337 vlan->n_ports = n_ports;
338 vlan->ports = port = (struct bridge_vlan_port *)&vlan[1];
339 INIT_LIST_HEAD(&vlan->hotplug_ports);
340 name_buf = (char *)&port[n_ports];
341
342 blobmsg_for_each_attr(cur, tb[BRVLAN_ATTR_PORTS], rem) {
343 char *sep;
344
345 port->ifname = name_buf;
346 port->flags = BRVLAN_F_UNTAGGED;
347 strcpy(name_buf, blobmsg_get_string(cur));
348
349 sep = strchr(name_buf, ':');
350 if (sep) {
351 for (*sep = 0, sep++; *sep; sep++)
352 switch (*sep) {
353 case '*':
354 port->flags |= BRVLAN_F_PVID;
355 break;
356 case 't':
357 port->flags &= ~BRVLAN_F_UNTAGGED;
358 break;
359 }
360 }
361
362 name_buf += strlen(name_buf) + 1;
363 port++;
364 }
365
366 vlist_add(&dev->vlans, &vlan->node, &vlan->vid);
367 }
368
369
370 static void
371 config_init_vlans(void)
372 {
373 struct uci_element *e;
374 struct device *dev;
375
376 device_vlan_update(false);
377 uci_foreach_element(&uci_network->sections, e) {
378 struct uci_section *s = uci_to_section(e);
379 const char *name;
380
381 if (strcmp(s->type, "bridge-vlan") != 0)
382 continue;
383
384 name = uci_lookup_option_string(uci_ctx, s, "device");
385 if (!name)
386 continue;
387
388 dev = device_get(name, 0);
389 if (!dev || !dev->vlans.update)
390 continue;
391
392 config_parse_vlan(dev, s);
393 }
394 device_vlan_update(true);
395 }
396
397 static struct uci_package *
398 config_init_package(const char *config)
399 {
400 struct uci_context *ctx = uci_ctx;
401 struct uci_package *p = NULL;
402
403 if (!ctx) {
404 ctx = uci_alloc_context();
405 uci_ctx = ctx;
406
407 ctx->flags &= ~UCI_FLAG_STRICT;
408 if (config_path)
409 uci_set_confdir(ctx, config_path);
410
411 #ifdef DUMMY_MODE
412 uci_set_savedir(ctx, "./tmp");
413 #endif
414 } else {
415 p = uci_lookup_package(ctx, config);
416 if (p)
417 uci_unload(ctx, p);
418 }
419
420 if (uci_load(ctx, config, &p))
421 return NULL;
422
423 return p;
424 }
425
426 static void
427 config_init_interfaces(void)
428 {
429 struct uci_element *e;
430
431 uci_foreach_element(&uci_network->sections, e) {
432 struct uci_section *s = uci_to_section(e);
433
434 if (!strcmp(s->type, "interface"))
435 config_parse_interface(s, false);
436 }
437
438 uci_foreach_element(&uci_network->sections, e) {
439 struct uci_section *s = uci_to_section(e);
440
441 if (!strcmp(s->type, "alias"))
442 config_parse_interface(s, true);
443 }
444 }
445
446 static void
447 config_init_ip(void)
448 {
449 struct interface *iface;
450 struct uci_element *e;
451
452 vlist_for_each_element(&interfaces, iface, node)
453 interface_ip_update_start(&iface->config_ip);
454
455 uci_foreach_element(&uci_network->sections, e) {
456 struct uci_section *s = uci_to_section(e);
457
458 if (!strcmp(s->type, "route"))
459 config_parse_route(s, false);
460 else if (!strcmp(s->type, "route6"))
461 config_parse_route(s, true);
462 if (!strcmp(s->type, "neighbor"))
463 config_parse_neighbor(s, false);
464 else if (!strcmp(s->type, "neighbor6"))
465 config_parse_neighbor(s, true);
466 }
467
468 vlist_for_each_element(&interfaces, iface, node)
469 interface_ip_update_complete(&iface->config_ip);
470 }
471
472 static void
473 config_init_rules(void)
474 {
475 struct uci_element *e;
476
477 iprule_update_start();
478
479 uci_foreach_element(&uci_network->sections, e) {
480 struct uci_section *s = uci_to_section(e);
481
482 if (!strcmp(s->type, "rule"))
483 config_parse_rule(s, false);
484 else if (!strcmp(s->type, "rule6"))
485 config_parse_rule(s, true);
486 }
487
488 iprule_update_complete();
489 }
490
491 static void
492 config_init_globals(void)
493 {
494 struct uci_section *globals = uci_lookup_section(
495 uci_ctx, uci_network, "globals");
496 if (!globals)
497 return;
498
499 const char *ula_prefix = uci_lookup_option_string(
500 uci_ctx, globals, "ula_prefix");
501 interface_ip_set_ula_prefix(ula_prefix);
502 }
503
504 static void
505 config_parse_wireless_device(struct uci_section *s)
506 {
507 struct wireless_driver *drv;
508 const char *driver_name;
509
510 driver_name = uci_lookup_option_string(uci_ctx, s, "type");
511 if (!driver_name)
512 return;
513
514 drv = avl_find_element(&wireless_drivers, driver_name, drv, node);
515 if (!drv)
516 return;
517
518 blob_buf_init(&b, 0);
519 uci_to_blob(&b, s, drv->device.config);
520 wireless_device_create(drv, s->e.name, b.head);
521 }
522
523 static struct wireless_interface*
524 config_parse_wireless_interface(struct wireless_device *wdev, struct uci_section *s)
525 {
526 char *name;
527
528 name = alloca(strlen(s->type) + 16);
529 sprintf(name, "@%s[%d]", s->type, config_section_idx(s));
530
531 blob_buf_init(&b, 0);
532 uci_to_blob(&b, s, wdev->drv->interface.config);
533 return wireless_interface_create(wdev, b.head, s->anonymous ? name : s->e.name);
534 }
535
536 static void
537 config_parse_wireless_vlan(struct wireless_device *wdev, char *vif, struct uci_section *s)
538 {
539 char *name;
540
541 name = alloca(strlen(s->type) + 16);
542 sprintf(name, "@%s[%d]", s->type, config_section_idx(s));
543
544 blob_buf_init(&b, 0);
545 uci_to_blob(&b, s, wdev->drv->vlan.config);
546 wireless_vlan_create(wdev, vif, b.head, s->anonymous ? name : s->e.name);
547 }
548
549 static void
550 config_parse_wireless_station(struct wireless_device *wdev, char *vif, struct uci_section *s)
551 {
552 char *name;
553
554 name = alloca(strlen(s->type) + 16);
555 sprintf(name, "@%s[%d]", s->type, config_section_idx(s));
556
557 blob_buf_init(&b, 0);
558 uci_to_blob(&b, s, wdev->drv->station.config);
559 wireless_station_create(wdev, vif, b.head, s->anonymous ? name : s->e.name);
560 }
561
562 static void
563 config_init_wireless(void)
564 {
565 struct wireless_device *wdev;
566 struct uci_element *e;
567 const char *dev_name;
568
569 if (!uci_wireless) {
570 DPRINTF("No wireless configuration found\n");
571 return;
572 }
573
574 vlist_update(&wireless_devices);
575
576 uci_foreach_element(&uci_wireless->sections, e) {
577 struct uci_section *s = uci_to_section(e);
578 if (strcmp(s->type, "wifi-device") != 0)
579 continue;
580
581 config_parse_wireless_device(s);
582 }
583
584 vlist_flush(&wireless_devices);
585
586 vlist_for_each_element(&wireless_devices, wdev, node) {
587 wdev->vif_idx = 0;
588 vlist_update(&wdev->interfaces);
589 wdev->vlan_idx = 0;
590 vlist_update(&wdev->vlans);
591 wdev->sta_idx = 0;
592 vlist_update(&wdev->stations);
593 }
594
595 uci_foreach_element(&uci_wireless->sections, e) {
596 struct uci_section *s = uci_to_section(e);
597 struct wireless_interface *vif;
598 struct uci_element *f;
599
600 if (strcmp(s->type, "wifi-iface") != 0)
601 continue;
602
603 dev_name = uci_lookup_option_string(uci_ctx, s, "device");
604 if (!dev_name)
605 continue;
606
607 wdev = vlist_find(&wireless_devices, dev_name, wdev, node);
608 if (!wdev) {
609 DPRINTF("device %s not found!\n", dev_name);
610 continue;
611 }
612
613 vif = config_parse_wireless_interface(wdev, s);
614
615 if (!vif || s->anonymous)
616 continue;
617 uci_foreach_element(&uci_wireless->sections, f) {
618 struct uci_section *s = uci_to_section(f);
619 const char *vif_name;
620
621 if (strcmp(s->type, "wifi-vlan") != 0)
622 continue;
623
624 vif_name = uci_lookup_option_string(uci_ctx, s, "iface");
625 if (vif_name && strcmp(e->name, vif_name))
626 continue;
627 config_parse_wireless_vlan(wdev, vif->name, s);
628 }
629
630 uci_foreach_element(&uci_wireless->sections, f) {
631 struct uci_section *s = uci_to_section(f);
632 const char *vif_name;
633
634 if (strcmp(s->type, "wifi-station") != 0)
635 continue;
636
637 vif_name = uci_lookup_option_string(uci_ctx, s, "iface");
638 if (vif_name && strcmp(e->name, vif_name))
639 continue;
640 config_parse_wireless_station(wdev, vif->name, s);
641 }
642 }
643
644 vlist_for_each_element(&wireless_devices, wdev, node) {
645 vlist_flush(&wdev->interfaces);
646 vlist_flush(&wdev->vlans);
647 vlist_flush(&wdev->stations);
648 }
649 }
650
651 int
652 config_init_all(void)
653 {
654 int ret = 0;
655 char *err;
656
657 uci_network = config_init_package("network");
658 if (!uci_network) {
659 uci_get_errorstr(uci_ctx, &err, NULL);
660 netifd_log_message(L_CRIT, "Failed to load network config (%s)\n", err);
661 free(err);
662 return -1;
663 }
664
665 uci_wireless = config_init_package("wireless");
666 if (!uci_wireless && uci_ctx->err != UCI_ERR_NOTFOUND) {
667 uci_get_errorstr(uci_ctx, &err, NULL);
668 netifd_log_message(L_CRIT, "Failed to load wireless config (%s)\n", err);
669 free(err);
670 ret = -1;
671 }
672
673 vlist_update(&interfaces);
674 config_init = true;
675 device_lock();
676
677 device_reset_config();
678 config_init_devices(true);
679 config_init_vlans();
680 config_init_devices(false);
681 config_init_interfaces();
682 config_init_ip();
683 config_init_rules();
684 config_init_globals();
685 config_init_wireless();
686
687 config_init = false;
688 device_unlock();
689
690 device_reset_old();
691 device_init_pending();
692 vlist_flush(&interfaces);
693 device_free_unused(NULL);
694 interface_refresh_assignments(false);
695 interface_start_pending();
696 wireless_start_pending();
697
698 return ret;
699 }