X-Git-Url: http://git.archive.openwrt.org/?p=project%2Fnetifd.git;a=blobdiff_plain;f=interface.c;h=4ad89f538a41328f006d49c49c3576f1348463da;hp=0f54d51c13a143d8d771c4ea4ecd4743f3a860e1;hb=75baeca6f817b161f522a9961bfe5c3718397189;hpb=ea6dec1329b08109387f091b60a13d1b40839317 diff --git a/interface.c b/interface.c index 0f54d51..4ad89f5 100644 --- a/interface.c +++ b/interface.c @@ -17,6 +17,7 @@ enum { IFACE_ATTR_IFNAME, IFACE_ATTR_PROTO, IFACE_ATTR_AUTO, + IFACE_ATTR_DEFAULTROUTE, IFACE_ATTR_MAX }; @@ -24,6 +25,7 @@ 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_DEFAULTROUTE] = { .name = "defaultroute", .type = BLOBMSG_TYPE_BOOL }, }; const struct config_param_list interface_attr_list = { @@ -93,39 +95,19 @@ interface_flush_state(struct interface *iface) interface_ip_flush(&iface->proto_ip); if (iface->main_dev.dev) device_release(&iface->main_dev); + if (iface->l3_dev != &iface->main_dev && iface->l3_dev->dev) + device_release(iface->l3_dev); } static void mark_interface_down(struct interface *iface) { + if (iface->state == IFS_UP) + interface_event(iface, IFEV_DOWN); interface_flush_state(iface); iface->state = IFS_DOWN; } -static int -__interface_set_up(struct interface *iface) -{ - int ret; - - if (iface->state != IFS_DOWN) - return 0; - - if (iface->main_dev.dev) { - ret = device_claim(&iface->main_dev); - if (ret) - return ret; - } - - iface->state = IFS_SETUP; - ret = interface_proto_event(iface->proto, PROTO_CMD_SETUP, false); - if (ret) { - mark_interface_down(iface); - return ret; - } - - return 0; -} - void __interface_set_down(struct interface *iface, bool force) { @@ -135,8 +117,11 @@ __interface_set_down(struct interface *iface, bool force) iface->state == IFS_TEARDOWN) return; + if (iface->state == IFS_UP) + interface_event(iface, IFEV_DOWN); iface->state = IFS_TEARDOWN; - interface_event(iface, IFEV_DOWN); + interface_ip_flush(&iface->config_ip); + interface_ip_flush(&iface->proto_ip); interface_proto_event(iface->proto, PROTO_CMD_TEARDOWN, force); if (force) interface_flush_state(iface); @@ -200,17 +185,19 @@ interface_claim_device(struct interface *iface) { struct device *dev; - if (iface->ifname && iface->proto_handler && + if (iface->ifname && !(iface->proto_handler->flags & PROTO_FLAG_NODEV)) { dev = device_get(iface->ifname, true); if (dev) device_add_user(&iface->main_dev, dev); } + if (iface->proto_handler->flags & PROTO_FLAG_INIT_AVAILABLE) + interface_set_available(iface, true); } static void -interface_cleanup(struct interface *iface) +interface_cleanup(struct interface *iface, bool reload) { struct interface_user *dep, *tmp; @@ -220,7 +207,8 @@ interface_cleanup(struct interface *iface) interface_ip_flush(&iface->config_ip); interface_flush_state(iface); interface_clear_errors(iface); - if (iface->main_dev.dev) + if (iface->main_dev.dev && + (!reload || !iface->main_dev.hotplug)) device_remove_user(&iface->main_dev); iface->l3_dev = &iface->main_dev; interface_set_proto_state(iface, NULL); @@ -229,7 +217,7 @@ interface_cleanup(struct interface *iface) static void interface_do_free(struct interface *iface) { - interface_cleanup(iface); + interface_cleanup(iface, false); free(iface->config); netifd_ubus_remove_interface(iface); avl_delete(&interfaces.avl, &iface->node.avl); @@ -239,13 +227,9 @@ interface_do_free(struct interface *iface) static void interface_do_reload(struct interface *iface) { - interface_cleanup(iface); - - interface_claim_device(iface); + interface_cleanup(iface, true); proto_init_interface(iface, iface->config); - - if (iface->autostart && !config_init) - interface_set_up(iface); + interface_claim_device(iface); } static void @@ -259,8 +243,10 @@ interface_handle_config_change(struct interface *iface) break; case IFC_REMOVE: interface_do_free(iface); - break; + return; } + if (iface->autostart && iface->available) + interface_set_up(iface); } static void @@ -290,18 +276,15 @@ interface_proto_cb(struct interface_proto_state *state, enum interface_proto_eve system_flush_routes(); mark_interface_down(iface); interface_handle_config_change(iface); - if (iface->l3_dev->dev) - device_release(iface->l3_dev); - if (iface->autostart && iface->available) - __interface_set_up(iface); break; case IFPEV_LINK_LOST: if (iface->state != IFS_UP) return; netifd_log_message(L_NOTICE, "Interface '%s' has lost the connection\n", iface->name); + if (iface->state == IFS_UP) + interface_event(iface, IFEV_DOWN); iface->state = IFS_SETUP; - interface_event(iface, IFEV_DOWN); break; } } @@ -348,10 +331,10 @@ interface_init(struct interface *iface, const char *name, proto_attach_interface(iface, proto_name); - if ((cur = tb[IFACE_ATTR_AUTO])) - iface->autostart = blobmsg_get_bool(cur); - else - iface->autostart = true; + iface->autostart = blobmsg_get_bool_default(tb[IFACE_ATTR_AUTO], true); + iface->proto_ip.no_defaultroute = + !blobmsg_get_bool_default(tb[IFACE_ATTR_DEFAULTROUTE], true); + iface->config_autostart = iface->autostart; } @@ -368,20 +351,25 @@ interface_add(struct interface *iface, struct blob_attr *config) iface->ifname = blobmsg_data(cur); iface->config = config; - vlist_add(&interfaces, &iface->node); + vlist_add(&interfaces, &iface->node, iface->name); } -void +int interface_remove_link(struct interface *iface, struct device *dev) { struct device *mdev = iface->main_dev.dev; - if (mdev && mdev->hotplug_ops) { - mdev->hotplug_ops->del(mdev, dev); - return; - } + if (mdev && mdev->hotplug_ops) + return mdev->hotplug_ops->del(mdev, dev); + + if (!iface->main_dev.hotplug) + return UBUS_STATUS_INVALID_ARGUMENT; + + if (dev != iface->main_dev.dev) + return UBUS_STATUS_INVALID_ARGUMENT; device_remove_user(&iface->main_dev); + return 0; } int @@ -389,20 +377,29 @@ interface_add_link(struct interface *iface, struct device *dev) { struct device *mdev = iface->main_dev.dev; - if (mdev && mdev->hotplug_ops) - return mdev->hotplug_ops->add(mdev, dev); + if (mdev == dev) + return 0; - if (iface->main_dev.dev) - interface_remove_link(iface, NULL); + if (iface->main_dev.hotplug) + device_remove_user(&iface->main_dev); - device_add_user(&iface->main_dev, dev); + if (mdev) { + if (mdev->hotplug_ops) + return mdev->hotplug_ops->add(mdev, dev); + else + return UBUS_STATUS_NOT_SUPPORTED; + } + device_add_user(&iface->main_dev, dev); + iface->main_dev.hotplug = true; return 0; } int interface_set_up(struct interface *iface) { + int ret; + iface->autostart = true; if (iface->state != IFS_DOWN) @@ -414,7 +411,20 @@ interface_set_up(struct interface *iface) return -1; } - return __interface_set_up(iface); + if (iface->main_dev.dev) { + ret = device_claim(&iface->main_dev); + if (ret) + return ret; + } + + iface->state = IFS_SETUP; + ret = interface_proto_event(iface->proto, PROTO_CMD_SETUP, false); + if (ret) { + mark_interface_down(iface); + return ret; + } + + return 0; } int @@ -488,8 +498,9 @@ interface_change_config(struct interface *if_old, struct interface *if_new) if_old->ifname = if_new->ifname; if_old->proto_handler = if_new->proto_handler; - if (strcmp(old_ifname, if_new->ifname) != 0 || - proto != if_new->proto_handler) { + if ((!!old_ifname != !!if_new->ifname) || + (old_ifname && strcmp(old_ifname, if_new->ifname) != 0) || + proto != if_new->proto_handler) { D(INTERFACE, "Reload interface '%s' because of ifname/proto change\n", if_old->name); goto reload; @@ -505,6 +516,11 @@ interface_change_config(struct interface *if_old, struct interface *if_new) goto reload; } + if (if_old->proto_ip.no_defaultroute != if_new->proto_ip.no_defaultroute) { + if_old->proto_ip.no_defaultroute = if_new->proto_ip.no_defaultroute; + interface_ip_set_enabled(&if_old->proto_ip, if_old->proto_ip.enabled); + } + goto out; reload: @@ -529,8 +545,8 @@ interface_update(struct vlist_tree *tree, struct vlist_node *node_new, set_config_state(if_old, IFC_REMOVE); } else if (node_new) { D(INTERFACE, "Create interface '%s'\n", if_new->name); - interface_claim_device(if_new); proto_init_interface(if_new, if_new->config); + interface_claim_device(if_new); netifd_ubus_add_interface(if_new); } } @@ -539,8 +555,7 @@ interface_update(struct vlist_tree *tree, struct vlist_node *node_new, static void __init interface_init_list(void) { - vlist_init(&interfaces, avl_strcmp, interface_update, - struct interface, node, name); + vlist_init(&interfaces, avl_strcmp, interface_update); interfaces.keep_old = true; interfaces.no_delete = true; }