wireless: add support for defining wifi interfaces via procd service data
[project/netifd.git] / interface.c
index 1d1a5f8cb8db260f3e350e5d5e870f26694230a0..641bcddcf031f4ae472fb45eb5c9261d58fc9eb4 100644 (file)
@@ -25,6 +25,7 @@
 #include "ubus.h"
 #include "config.h"
 #include "system.h"
+#include "wireless.h"
 
 struct vlist_tree interfaces;
 static LIST_HEAD(iface_all_users);
@@ -34,8 +35,11 @@ enum {
        IFACE_ATTR_IFNAME, /* Backward compatibility */
        IFACE_ATTR_PROTO,
        IFACE_ATTR_AUTO,
+       IFACE_ATTR_ZONE,
        IFACE_ATTR_JAIL,
+       IFACE_ATTR_JAIL_DEVICE,
        IFACE_ATTR_JAIL_IFNAME,
+       IFACE_ATTR_HOST_DEVICE,
        IFACE_ATTR_DEFAULTROUTE,
        IFACE_ATTR_PEERDNS,
        IFACE_ATTR_DNS,
@@ -60,8 +64,11 @@ static const struct blobmsg_policy iface_attrs[IFACE_ATTR_MAX] = {
        [IFACE_ATTR_PROTO] = { .name = "proto", .type = BLOBMSG_TYPE_STRING },
        [IFACE_ATTR_IFNAME] = { .name = "ifname", .type = BLOBMSG_TYPE_STRING },
        [IFACE_ATTR_AUTO] = { .name = "auto", .type = BLOBMSG_TYPE_BOOL },
+       [IFACE_ATTR_ZONE] = { .name = "zone", .type = BLOBMSG_TYPE_STRING },
        [IFACE_ATTR_JAIL] = { .name = "jail", .type = BLOBMSG_TYPE_STRING },
+       [IFACE_ATTR_JAIL_DEVICE] = { .name = "jail_device", .type = BLOBMSG_TYPE_STRING },
        [IFACE_ATTR_JAIL_IFNAME] = { .name = "jail_ifname", .type = BLOBMSG_TYPE_STRING },
+       [IFACE_ATTR_HOST_DEVICE] = { .name = "host_device", .type = BLOBMSG_TYPE_STRING },
        [IFACE_ATTR_DEFAULTROUTE] = { .name = "defaultroute", .type = BLOBMSG_TYPE_BOOL },
        [IFACE_ATTR_PEERDNS] = { .name = "peerdns", .type = BLOBMSG_TYPE_BOOL },
        [IFACE_ATTR_METRIC] = { .name = "metric", .type = BLOBMSG_TYPE_INT32 },
@@ -226,7 +233,8 @@ interface_add_data(struct interface *iface, const struct blob_attr *data)
 int interface_parse_data(struct interface *iface, const struct blob_attr *attr)
 {
        struct blob_attr *cur;
-       int rem, ret;
+       size_t rem;
+       int ret;
 
        iface->updated = 0;
 
@@ -429,7 +437,7 @@ interface_main_dev_cb(struct device_user *dep, enum device_event ev)
                break;
        case DEV_EVENT_REMOVE:
                interface_set_available(iface, false);
-               if (dep->dev && dep->dev->external)
+               if (dep->dev && dep->dev->external && !dep->dev->sys_present)
                        interface_set_main_dev(iface, NULL);
                break;
        case DEV_EVENT_UP:
@@ -476,7 +484,7 @@ interface_set_available(struct interface *iface, bool new_state)
        if (iface->available == new_state)
                return;
 
-       D(INTERFACE, "Interface '%s', available=%d\n", iface->name, new_state);
+       D(INTERFACE, "Interface '%s', available=%d", iface->name, new_state);
        iface->available = new_state;
 
        if (new_state) {
@@ -511,7 +519,7 @@ static void
 interface_add_assignment_classes(struct interface *iface, struct blob_attr *list)
 {
        struct blob_attr *cur;
-       int rem;
+       size_t rem;
 
        blobmsg_for_each_attr(cur, list, rem) {
                if (blobmsg_type(cur) != BLOBMSG_TYPE_STRING)
@@ -637,8 +645,6 @@ interface_claim_device(struct interface *iface)
        if (iface->parent_iface.iface)
                interface_remove_user(&iface->parent_iface);
 
-       device_lock();
-
        if (iface->parent_ifname) {
                parent = vlist_find(&interfaces, iface->parent_ifname, parent, node);
                iface->parent_iface.cb = interface_alias_cb;
@@ -646,7 +652,8 @@ interface_claim_device(struct interface *iface)
        } else if (iface->device &&
                !(iface->proto_handler->flags & PROTO_FLAG_NODEV)) {
                dev = device_get(iface->device, true);
-               interface_set_device_config(iface, dev);
+               if (!(iface->proto_handler->flags & PROTO_FLAG_NODEV_CONFIG))
+                       interface_set_device_config(iface, dev);
        } else {
                dev = iface->ext_dev.dev;
        }
@@ -654,8 +661,6 @@ interface_claim_device(struct interface *iface)
        if (dev)
                interface_set_main_dev(iface, dev);
 
-       device_unlock();
-
        if (iface->proto_handler->flags & PROTO_FLAG_INIT_AVAILABLE)
                interface_set_available(iface, true);
 }
@@ -702,8 +707,10 @@ interface_do_free(struct interface *iface)
        avl_delete(&interfaces.avl, &iface->node.avl);
        if (iface->jail)
                free(iface->jail);
-       if (iface->jail_ifname)
-               free(iface->jail_ifname);
+       if (iface->jail_device)
+               free(iface->jail_device);
+       if (iface->host_device)
+               free(iface->host_device);
 
        free(iface);
 }
@@ -767,12 +774,13 @@ interface_proto_event_cb(struct interface_proto_state *state, enum interface_pro
 
                netifd_log_message(L_NOTICE, "Interface '%s' is now down\n", iface->name);
                mark_interface_down(iface);
-               if (iface->main_dev.dev)
+               interface_write_resolv_conf(iface->jail);
+               if (iface->main_dev.dev && !(iface->config_state == IFC_NORMAL && iface->autostart && iface->available))
                        device_release(&iface->main_dev);
                if (iface->l3_dev.dev)
                        device_remove_user(&iface->l3_dev);
                interface_handle_config_change(iface);
-               break;
+               return;
        case IFPEV_LINK_LOST:
                if (iface->state != IFS_UP)
                        return;
@@ -830,6 +838,10 @@ interface_alloc(const char *name, struct blob_attr *config, bool dynamic)
        blobmsg_parse(iface_attrs, IFACE_ATTR_MAX, tb,
                      blob_data(config), blob_len(config));
 
+       iface->zone = NULL;
+       if ((cur = tb[IFACE_ATTR_ZONE]))
+               iface->zone = strdup(blobmsg_get_string(cur));
+
        if ((cur = tb[IFACE_ATTR_PROTO]))
                proto_name = blobmsg_data(cur);
 
@@ -900,12 +912,12 @@ interface_alloc(const char *name, struct blob_attr *config, bool dynamic)
 
        if ((cur = tb[IFACE_ATTR_IP4TABLE])) {
                if (!system_resolve_rt_table(blobmsg_data(cur), &iface->ip4table))
-                       DPRINTF("Failed to resolve routing table: %s\n", (char *) blobmsg_data(cur));
+                       D(INTERFACE, "Failed to resolve routing table: %s", (char *) blobmsg_data(cur));
        }
 
        if ((cur = tb[IFACE_ATTR_IP6TABLE])) {
                if (!system_resolve_rt_table(blobmsg_data(cur), &iface->ip6table))
-                       DPRINTF("Failed to resolve routing table: %s\n", (char *) blobmsg_data(cur));
+                       D(INTERFACE, "Failed to resolve routing table: %s", (char *) blobmsg_data(cur));
        }
 
        iface->proto_ip.no_delegation = !blobmsg_get_bool_default(tb[IFACE_ATTR_DELEGATE], true);
@@ -918,9 +930,15 @@ interface_alloc(const char *name, struct blob_attr *config, bool dynamic)
                iface->autostart = false;
        }
 
-       iface->jail_ifname = NULL;
-       if ((cur = tb[IFACE_ATTR_JAIL_IFNAME]))
-               iface->jail_ifname = strdup(blobmsg_get_string(cur));
+       iface->jail_device = NULL;
+       if ((cur = tb[IFACE_ATTR_JAIL_DEVICE]))
+               iface->jail_device = strdup(blobmsg_get_string(cur));
+       else if ((cur = tb[IFACE_ATTR_JAIL_IFNAME]))
+               iface->jail_device = strdup(blobmsg_get_string(cur));
+
+       iface->host_device = NULL;
+       if ((cur = tb[IFACE_ATTR_HOST_DEVICE]))
+               iface->host_device = strdup(blobmsg_get_string(cur));
 
        return iface;
 }
@@ -1034,12 +1052,13 @@ interface_set_main_dev(struct interface *iface, struct device *dev)
 }
 
 static int
-interface_remove_link(struct interface *iface, struct device *dev)
+interface_remove_link(struct interface *iface, struct device *dev,
+                     struct blob_attr *vlan)
 {
        struct device *mdev = iface->main_dev.dev;
 
        if (mdev && mdev->hotplug_ops)
-               return mdev->hotplug_ops->del(mdev, dev);
+               return mdev->hotplug_ops->del(mdev, dev, vlan);
 
        if (dev == iface->ext_dev.dev)
                device_remove_user(&iface->ext_dev);
@@ -1086,30 +1105,19 @@ interface_handle_link(struct interface *iface, const char *name,
                      struct blob_attr *vlan, bool add, bool link_ext)
 {
        struct device *dev;
-       int ret;
-
-       device_lock();
 
        dev = device_get(name, add ? (link_ext ? 2 : 1) : 0);
-       if (!dev) {
-               ret = UBUS_STATUS_NOT_FOUND;
-               goto out;
-       }
+       if (!dev)
+               return UBUS_STATUS_NOT_FOUND;
 
-       if (add) {
-               interface_set_device_config(iface, dev);
-               if (!link_ext)
-                       device_set_present(dev, true);
+       if (!add)
+               return interface_remove_link(iface, dev, vlan);
 
-               ret = interface_add_link(iface, dev, vlan, link_ext);
-       } else {
-               ret = interface_remove_link(iface, dev);
-       }
+       interface_set_device_config(iface, dev);
+       if (!link_ext)
+               device_set_present(dev, true);
 
-out:
-       device_unlock();
-
-       return ret;
+       return interface_add_link(iface, dev, vlan, link_ext);
 }
 
 void
@@ -1119,6 +1127,7 @@ interface_set_up(struct interface *iface)
        const char *error = NULL;
 
        iface->autostart = true;
+       wireless_check_network_enabled();
 
        if (iface->state != IFS_DOWN)
                return;
@@ -1151,6 +1160,7 @@ interface_set_down(struct interface *iface)
                        __interface_set_down(iface, false);
        } else {
                iface->autostart = false;
+               wireless_check_network_enabled();
                __interface_set_down(iface, false);
        }
 }
@@ -1176,104 +1186,29 @@ interface_start_pending(void)
 }
 
 void
-interface_start_jail(const char *jail, const pid_t netns_pid)
+interface_start_jail(int netns_fd, const char *jail)
 {
        struct interface *iface;
-       int netns_fd;
-       int wstatus;
-       pid_t pr = 0;
-
-       netns_fd = system_netns_open(netns_pid);
-       if (netns_fd < 0)
-               return;
-
-       vlist_for_each_element(&interfaces, iface, node) {
-               if (!iface->jail || strcmp(iface->jail, jail))
-                       continue;
-
-               system_link_netns_move(iface->main_dev.dev, netns_fd, iface->jail_ifname);
-       }
-
-       close(netns_fd);
-
-       pr = fork();
-       if (pr) {
-               waitpid(pr, &wstatus, WUNTRACED | WCONTINUED);
-               return;
-       }
-
-       /* child process */
-       netns_fd = system_netns_open(netns_pid);
-       if (netns_fd < 0)
-               return;
 
-       system_netns_set(netns_fd);
-       system_init();
        vlist_for_each_element(&interfaces, iface, node) {
                if (!iface->jail || strcmp(iface->jail, jail))
                        continue;
 
-               /*
-                * The interface has already been renamed and is inside target
-                * namespace, hence overwrite ifname with jail_ifname for
-                * interface_set_up().
-                * We are inside a fork which got it's own copy of the interfaces
-                * list, so we can mess with it :)
-                */
-               if (iface->jail_ifname)
-                       iface->device = iface->jail_ifname;
-
-               interface_do_reload(iface);
-               interface_set_up(iface);
+               system_link_netns_move(iface->main_dev.dev, netns_fd, iface->jail_device);
        }
-
-       close(netns_fd);
-       _exit(0);
 }
 
 void
-interface_stop_jail(const char *jail, const pid_t netns_pid)
+interface_stop_jail(int netns_fd)
 {
        struct interface *iface;
-       int netns_fd, root_netns;
-       int wstatus;
-       pid_t parent_pid = getpid();
-       pid_t pr = 0;
-       const char *orig_ifname;
-
-       pr = fork();
-       if (pr) {
-               waitpid(pr, &wstatus, WUNTRACED | WCONTINUED);
-               return;
-       }
+       char *orig_ifname;
 
-       /* child process */
-       root_netns = system_netns_open(parent_pid);
-       if (root_netns < 0)
-               return;
-
-       netns_fd = system_netns_open(netns_pid);
-       if (netns_fd < 0)
-               return;
-
-       system_netns_set(netns_fd);
-       system_init();
        vlist_for_each_element(&interfaces, iface, node) {
-               if (!iface->jail || strcmp(iface->jail, jail))
-                       continue;
-
-               orig_ifname = iface->device;
-               if (iface->jail_ifname)
-                       iface->device = iface->jail_ifname;
-
-               interface_do_reload(iface);
+               orig_ifname = iface->host_device;
                interface_set_down(iface);
-               system_link_netns_move(iface->main_dev.dev, root_netns, orig_ifname);
+               system_link_netns_move(iface->main_dev.dev, netns_fd, orig_ifname);
        }
-
-       close(root_netns);
-       close(netns_fd);
-       _exit(0);
 }
 
 static void
@@ -1314,7 +1249,7 @@ interface_device_config_changed(struct interface *if_old, struct interface *if_n
        struct blob_attr *ntb[__DEV_ATTR_MAX];
        struct blob_attr *otb[__DEV_ATTR_MAX];
        struct device *dev = if_old->main_dev.dev;
-       unsigned long diff = 0;
+       unsigned long diff[2] = {};
 
        BUILD_BUG_ON(sizeof(diff) < __DEV_ATTR_MAX / 8);
 
@@ -1333,8 +1268,9 @@ interface_device_config_changed(struct interface *if_old, struct interface *if_n
        blobmsg_parse(device_attr_list.params, __DEV_ATTR_MAX, ntb,
                blob_data(if_new->config), blob_len(if_new->config));
 
-       uci_blob_diff(ntb, otb, &device_attr_list, &diff);
-       return diff;
+       uci_blob_diff(ntb, otb, &device_attr_list, diff);
+
+       return diff[0] | diff[1];
 }
 
 static void
@@ -1362,7 +1298,7 @@ interface_change_config(struct interface *if_old, struct interface *if_new)
                reload = true;
 
        if (!if_old->proto_handler->config_params)
-               D(INTERFACE, "No config parameters for interface '%s'\n",
+               D(INTERFACE, "No config parameters for interface '%s'",
                  if_old->name);
        else if (!uci_blob_check_equal(if_old->config, if_new->config,
                                       if_old->proto_handler->config_params))
@@ -1391,10 +1327,15 @@ interface_change_config(struct interface *if_old, struct interface *if_new)
        if (if_old->jail)
                if_old->autostart = false;
 
-       if (if_old->jail_ifname)
-               free(if_old->jail_ifname);
+       if (if_old->jail_device)
+               free(if_old->jail_device);
+
+       if_old->jail_device = if_new->jail_device;
+
+       if (if_old->host_device)
+               free(if_old->host_device);
 
-       if_old->jail_ifname = if_new->jail_ifname;
+       if_old->host_device = if_new->host_device;
 
        if_old->device = if_new->device;
        if_old->parent_ifname = if_new->parent_ifname;
@@ -1420,7 +1361,7 @@ interface_change_config(struct interface *if_old, struct interface *if_new)
 #undef UPDATE
 
        if (reload) {
-               D(INTERFACE, "Reload interface '%s' because of config changes\n",
+               D(INTERFACE, "Reload interface '%s' because of config changes",
                  if_old->name);
                interface_clear_errors(if_old);
                set_config_state(if_old, IFC_RELOAD);
@@ -1459,13 +1400,13 @@ interface_update(struct vlist_tree *tree, struct vlist_node *node_new,
        struct interface *if_new = container_of(node_new, struct interface, node);
 
        if (node_old && node_new) {
-               D(INTERFACE, "Update interface '%s'\n", if_new->name);
+               D(INTERFACE, "Update interface '%s'", if_new->name);
                interface_change_config(if_old, if_new);
        } else if (node_old) {
-               D(INTERFACE, "Remove interface '%s'\n", if_old->name);
+               D(INTERFACE, "Remove interface '%s'", if_old->name);
                set_config_state(if_old, IFC_REMOVE);
        } else if (node_new) {
-               D(INTERFACE, "Create interface '%s'\n", if_new->name);
+               D(INTERFACE, "Create interface '%s'", if_new->name);
                interface_event(if_new, IFEV_CREATE);
                proto_init_interface(if_new, if_new->config);
                interface_claim_device(if_new);