X-Git-Url: http://git.archive.openwrt.org/?p=project%2Fnetifd.git;a=blobdiff_plain;f=interface.c;h=5166c0c75d6f2d2f04d190f8a2d57563d8f13101;hp=8239eac60b77f9fc6cc8cc22669a4c1a79f1c906;hb=5990d1126fd33665e106508ebcbadfbb2d703d8e;hpb=92d2aea918f650f309f753349457028032d53280 diff --git a/interface.c b/interface.c index 8239eac..5166c0c 100644 --- a/interface.c +++ b/interface.c @@ -68,15 +68,9 @@ static const struct blobmsg_policy iface_attrs[IFACE_ATTR_MAX] = { [IFACE_ATTR_FORCE_LINK] = { .name = "force_link", .type = BLOBMSG_TYPE_BOOL }, }; -static const struct uci_blob_param_info iface_attr_info[IFACE_ATTR_MAX] = { - [IFACE_ATTR_DNS] = { .type = BLOBMSG_TYPE_STRING }, - [IFACE_ATTR_IP6CLASS] = { .type = BLOBMSG_TYPE_STRING }, -}; - const struct uci_blob_param_list interface_attr_list = { .n_params = IFACE_ATTR_MAX, .params = iface_attrs, - .info = iface_attr_info, }; static void @@ -145,7 +139,7 @@ void interface_add_error(struct interface *iface, const char *subsystem, memcpy(dest, data[i], datalen[i]); dest += datalen[i]; } - error->data[n_data++] = NULL; + error->data[n_data] = NULL; if (subsystem) error->subsystem = strcpy(d_subsys, subsystem); @@ -339,14 +333,14 @@ interface_set_link_state(struct interface *iface, bool new_state) } static void -interface_ext_cb(struct device_user *dep, enum device_event ev) +interface_ext_dev_cb(struct device_user *dep, enum device_event ev) { if (ev == DEV_EVENT_REMOVE) device_remove_user(dep); } static void -interface_cb(struct device_user *dep, enum device_event ev) +interface_main_dev_cb(struct device_user *dep, enum device_event ev) { struct interface *iface; bool new_state = false; @@ -378,6 +372,24 @@ interface_cb(struct device_user *dep, enum device_event ev) } } +static void +interface_l3_dev_cb(struct device_user *dep, enum device_event ev) +{ + struct interface *iface; + + iface = container_of(dep, struct interface, l3_dev); + if (iface->l3_dev.dev == iface->main_dev.dev) + return; + + switch (ev) { + case DEV_EVENT_LINK_DOWN: + interface_proto_event(iface->proto, PROTO_CMD_TEARDOWN, false); + break; + default: + break; + } +} + void interface_set_available(struct interface *iface, bool new_state) { @@ -520,6 +532,21 @@ interface_alias_cb(struct interface_user *dep, struct interface *iface, enum int } static void +interface_set_device_config(struct interface *iface, struct device *dev) +{ + if (!dev || !dev->default_config) + return; + + if (!iface->device_config && + (!dev->iface_config || dev->config_iface != iface)) + return; + + dev->config_iface = iface; + dev->iface_config = iface->device_config; + device_apply_config(dev, dev->type, iface->config); +} + +static void interface_claim_device(struct interface *iface) { struct interface *parent; @@ -535,8 +562,7 @@ interface_claim_device(struct interface *iface) } else if (iface->ifname && !(iface->proto_handler->flags & PROTO_FLAG_NODEV)) { dev = device_get(iface->ifname, true); - if (dev && dev->default_config && iface->device_config) - device_apply_config(dev, dev->type, iface->config); + interface_set_device_config(iface, dev); } else { dev = iface->ext_dev.dev; } @@ -704,8 +730,9 @@ interface_alloc(const char *name, struct blob_attr *config) avl_init(&iface->data, avl_strcmp, false, NULL); iface->config_ip.enabled = false; - iface->main_dev.cb = interface_cb; - iface->ext_dev.cb = interface_ext_cb; + iface->main_dev.cb = interface_main_dev_cb; + iface->l3_dev.cb = interface_l3_dev_cb; + iface->ext_dev.cb = interface_ext_dev_cb; blobmsg_parse(iface_attrs, IFACE_ATTR_MAX, tb, blob_data(config), blob_len(config)); @@ -814,7 +841,6 @@ static bool __interface_add(struct interface *iface, struct blob_attr *config, b iface->ifname = blobmsg_data(cur); } - iface->config = config; vlist_add(&interfaces, &iface->node, iface->name); return true; @@ -943,9 +969,7 @@ interface_handle_link(struct interface *iface, const char *name, bool add, bool } if (add) { - if (iface->device_config && dev->default_config) - device_apply_config(dev, dev->type, iface->config); - + interface_set_device_config(iface, dev); device_set_present(dev, true); ret = interface_add_link(iface, dev, link_ext); @@ -1041,6 +1065,35 @@ interface_replace_dns(struct interface_ip_settings *new, struct interface_ip_set vlist_simple_replace(&new->dns_search, &old->dns_search); } +static bool +interface_device_config_changed(struct interface *if_old, struct interface *if_new) +{ + 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; + + BUILD_BUG_ON(sizeof(diff) < __DEV_ATTR_MAX / 8); + + if (!dev) + return false; + + if (if_old->device_config != if_new->device_config) + return true; + + if (!if_new->device_config) + return false; + + blobmsg_parse(device_attr_list.params, __DEV_ATTR_MAX, otb, + blob_data(if_old->config), blob_len(if_old->config)); + + 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; +} + static void interface_change_config(struct interface *if_old, struct interface *if_new) { @@ -1058,6 +1111,9 @@ interface_change_config(struct interface *if_old, struct interface *if_new) reload = true; } + if (!reload && interface_device_config_changed(if_old, if_new)) + reload = true; + if (FIELD_CHANGED_STR(ifname) || if_old->proto_handler != if_new->proto_handler) reload = true;