X-Git-Url: http://git.archive.openwrt.org/?p=project%2Fnetifd.git;a=blobdiff_plain;f=interface.c;h=7b18cef58a47d8aed15c0e568652a54b1d8d2ae7;hp=5166c0c75d6f2d2f04d190f8a2d57563d8f13101;hb=bd1ee3efb46ae013d81b1aec51668e7595274e69;hpb=c68587663ef18fa87841be0a5281264361fab411 diff --git a/interface.c b/interface.c index 5166c0c..7b18cef 100644 --- a/interface.c +++ b/interface.c @@ -74,6 +74,11 @@ const struct uci_blob_param_list interface_attr_list = { }; static void +set_config_state(struct interface *iface, enum interface_config_state s); +static void +interface_event(struct interface *iface, enum interface_event ev); + +static void interface_error_flush(struct interface *iface) { struct interface_error *error, *tmp; @@ -184,6 +189,9 @@ interface_add_data(struct interface *iface, const struct blob_attr *data) } n = calloc(1, sizeof(*n) + len); + if (!n) + return UBUS_STATUS_UNKNOWN_ERROR; + memcpy(n->data, data, len); n->node.key = blobmsg_name(n->data); avl_insert(&iface->data, &n->node); @@ -192,6 +200,25 @@ interface_add_data(struct interface *iface, const struct blob_attr *data) return 0; } +int interface_parse_data(struct interface *iface, const struct blob_attr *attr) +{ + struct blob_attr *cur; + int rem, ret; + + iface->updated = 0; + + blob_for_each_attr(cur, attr, rem) { + ret = interface_add_data(iface, cur); + if (ret) + return ret; + } + + if (iface->updated && iface->state == IFS_UP) + interface_event(iface, IFEV_UPDATE); + + return 0; +} + static void interface_event(struct interface *iface, enum interface_event ev) { @@ -237,6 +264,7 @@ mark_interface_down(struct interface *iface) if (state == IFS_UP) interface_event(iface, IFEV_DOWN); interface_ip_set_enabled(&iface->config_ip, false); + interface_ip_set_enabled(&iface->proto_ip, false); interface_ip_flush(&iface->proto_ip); interface_flush_state(iface); system_flush_routes(); @@ -256,9 +284,6 @@ __interface_set_down(struct interface *iface, bool force) interface_proto_event(iface->proto, PROTO_CMD_TEARDOWN, force); if (force) interface_flush_state(iface); - - if (iface->dynamic) - vlist_delete(&interfaces, &iface->node); break; case IFS_DOWN: @@ -644,10 +669,12 @@ interface_handle_config_change(struct interface *iface) } if (iface->autostart && iface->available) interface_set_up(iface); + else if (iface->dynamic) + set_config_state(iface, IFC_REMOVE); } static void -interface_proto_cb(struct interface_proto_state *state, enum interface_proto_event ev) +interface_proto_event_cb(struct interface_proto_state *state, enum interface_proto_event ev) { struct interface *iface = state->iface; @@ -662,6 +689,7 @@ interface_proto_cb(struct interface_proto_state *state, enum interface_proto_eve interface_set_l3_dev(iface, iface->main_dev.dev); interface_ip_set_enabled(&iface->config_ip, true); + interface_ip_set_enabled(&iface->proto_ip, true); system_flush_routes(); iface->state = IFS_UP; iface->start_time = system_get_rtime(); @@ -706,7 +734,7 @@ void interface_set_proto_state(struct interface *iface, struct interface_proto_s if (!state) return; - state->proto_event = interface_proto_cb; + state->proto_event = interface_proto_event_cb; state->iface = iface; } @@ -871,6 +899,7 @@ interface_set_l3_dev(struct interface *iface, struct device *dev) return; interface_ip_set_enabled(&iface->config_ip, false); + interface_ip_set_enabled(&iface->proto_ip, false); interface_ip_flush(&iface->proto_ip); device_add_user(&iface->l3_dev, dev); @@ -880,6 +909,7 @@ interface_set_l3_dev(struct interface *iface, struct device *dev) return; } interface_ip_set_enabled(&iface->config_ip, enabled); + interface_ip_set_enabled(&iface->proto_ip, enabled); } }