X-Git-Url: http://git.archive.openwrt.org/?p=project%2Fnetifd.git;a=blobdiff_plain;f=bridge.c;h=5337e3a60a8913b9a706957b19351c26392d4b71;hp=1b9e6bd8d1083f7d4b7dc590883671f3078f8a79;hb=b7e1b35ff18a759a54e4033d04a3550499dd9fc1;hpb=43c2934a4d3f9a3e9d7fc2a4e9a32a2bef7174ba diff --git a/bridge.c b/bridge.c index 1b9e6bd..5337e3a 100644 --- a/bridge.c +++ b/bridge.c @@ -65,6 +65,7 @@ struct bridge_state { struct bridge_config config; struct blob_attr *ifnames; bool active; + bool force_active; struct list_head members; int n_present; @@ -119,6 +120,24 @@ error: } static void +bridge_remove_member(struct bridge_member *bm) +{ + struct bridge_state *bst = bm->bst; + + if (!bm->present) + return; + + bm->present = false; + bm->bst->n_present--; + if (bst->dev.active) + bridge_disable_member(bm); + + bst->force_active = false; + if (bst->n_present == 0) + device_set_present(&bst->dev, false); +} + +static void bridge_member_cb(struct device_user *dev, enum device_event ev) { struct bridge_member *bm = container_of(dev, struct bridge_member, dev); @@ -141,16 +160,11 @@ bridge_member_cb(struct device_user *dev, enum device_event ev) if (!bm->present) return; - if (bst->dev.active) - bridge_disable_member(bm); - - bm->present = false; - bm->bst->n_present--; - if (bst->n_present == 0) - device_set_present(&bst->dev, false); - if (dev->hotplug) bridge_free_member(bm); + else + bridge_remove_member(bm); + break; default: return; @@ -178,7 +192,7 @@ bridge_set_up(struct bridge_state *bst) struct bridge_member *bm; int ret; - if (!bst->n_present) + if (!bst->force_active && !bst->n_present) return -ENOENT; ret = system_bridge_addbr(&bst->dev, &bst->config); @@ -188,7 +202,7 @@ bridge_set_up(struct bridge_state *bst) list_for_each_entry(bm, &bst->members, list) bridge_enable_member(bm); - if (!bst->n_present) { + if (!bst->force_active && !bst->n_present) { /* initialization of all member interfaces failed */ system_bridge_delbr(&bst->dev); device_set_present(&bst->dev, false); @@ -224,26 +238,20 @@ bridge_create_member(struct bridge_state *bst, struct device *dev, bool hotplug) bm = calloc(1, sizeof(*bm)); bm->bst = bst; bm->dev.cb = bridge_member_cb; - device_add_user(&bm->dev, dev); bm->dev.hotplug = hotplug; - list_add_tail(&bm->list, &bst->members); + device_add_user(&bm->dev, dev); + return bm; } static void bridge_free_member(struct bridge_member *bm) { - if (bm->present) { - bridge_member_cb(&bm->dev, DEV_EVENT_REMOVE); - bm->bst->n_present--; - if (bm->bst->dev.active) - bridge_disable_member(bm); - } - - list_del(&bm->list); + bridge_remove_member(bm); device_remove_user(&bm->dev); + list_del(&bm->list); free(bm); } @@ -283,10 +291,23 @@ bridge_hotplug_del(struct device *dev, struct device *member) return 0; } - return -ENOENT; + return UBUS_STATUS_NOT_FOUND; +} + +static int +bridge_hotplug_prepare(struct device *dev) +{ + struct bridge_state *bst; + + bst = container_of(dev, struct bridge_state, dev); + bst->force_active = true; + device_set_present(&bst->dev, true); + + return 0; } static const struct device_hotplug_ops bridge_ops = { + .prepare = bridge_hotplug_prepare, .add = bridge_hotplug_add, .del = bridge_hotplug_del }; @@ -330,6 +351,10 @@ bridge_config_init(struct device *dev) int rem; bst = container_of(dev, struct bridge_state, dev); + + if (!bst->ifnames) + return; + blobmsg_for_each_attr(cur, bst->ifnames, rem) { bridge_add_member(bst, blobmsg_data(cur)); } @@ -384,9 +409,6 @@ bridge_create(const char *name, struct blob_attr *attr) blobmsg_parse(bridge_attrs, __BRIDGE_ATTR_MAX, tb_br, blob_data(attr), blob_len(attr)); - if (!tb_br[BRIDGE_ATTR_IFNAME]) - return NULL; - bst = calloc(1, sizeof(*bst)); if (!bst) return NULL;