Commit cfa22c71 authored by Luis Carlos Cobo's avatar Luis Carlos Cobo Committed by John W. Linville

mac80211: always force mesh_path deletions

Postponing the deletion is not really useful anymore.
Signed-off-by: default avatarLuis Carlos Cobo <luisca@cozybit.com>
Acked-by: default avatarJohannes Berg <johannes@sipsolutions.net>
Signed-off-by: default avatarJohn W. Linville <linville@tuxdriver.com>
parent 89a1ad69
...@@ -785,7 +785,7 @@ static int ieee80211_del_mpath(struct wiphy *wiphy, struct net_device *dev, ...@@ -785,7 +785,7 @@ static int ieee80211_del_mpath(struct wiphy *wiphy, struct net_device *dev,
u8 *dst) u8 *dst)
{ {
if (dst) if (dst)
return mesh_path_del(dst, dev, false); return mesh_path_del(dst, dev);
mesh_path_flush(dev); mesh_path_flush(dev);
return 0; return 0;
......
...@@ -30,7 +30,6 @@ ...@@ -30,7 +30,6 @@
* @MESH_PATH_FIXED: the mesh path has been manually set and should not be * @MESH_PATH_FIXED: the mesh path has been manually set and should not be
* modified * modified
* @MESH_PATH_RESOLVED: the mesh path can has been resolved * @MESH_PATH_RESOLVED: the mesh path can has been resolved
* @MESH_PATH_DELETE: the mesh path is scheduled to be deleted
* *
* MESH_PATH_RESOLVED and MESH_PATH_DELETE are used by the mesh path timer to * MESH_PATH_RESOLVED and MESH_PATH_DELETE are used by the mesh path timer to
* decide when to stop or cancel the mesh path discovery. * decide when to stop or cancel the mesh path discovery.
...@@ -41,7 +40,6 @@ enum mesh_path_flags { ...@@ -41,7 +40,6 @@ enum mesh_path_flags {
MESH_PATH_DSN_VALID = BIT(2), MESH_PATH_DSN_VALID = BIT(2),
MESH_PATH_FIXED = BIT(3), MESH_PATH_FIXED = BIT(3),
MESH_PATH_RESOLVED = BIT(4), MESH_PATH_RESOLVED = BIT(4),
MESH_PATH_DELETE = BIT(5),
}; };
/** /**
...@@ -254,7 +252,7 @@ void mesh_path_flush_pending(struct mesh_path *mpath); ...@@ -254,7 +252,7 @@ void mesh_path_flush_pending(struct mesh_path *mpath);
void mesh_path_tx_pending(struct mesh_path *mpath); void mesh_path_tx_pending(struct mesh_path *mpath);
int mesh_pathtbl_init(void); int mesh_pathtbl_init(void);
void mesh_pathtbl_unregister(void); void mesh_pathtbl_unregister(void);
int mesh_path_del(u8 *addr, struct net_device *dev, bool force); int mesh_path_del(u8 *addr, struct net_device *dev);
void mesh_path_timer(unsigned long data); void mesh_path_timer(unsigned long data);
void mesh_path_flush_by_nexthop(struct sta_info *sta); void mesh_path_flush_by_nexthop(struct sta_info *sta);
void mesh_path_discard_frame(struct sk_buff *skb, struct net_device *dev); void mesh_path_discard_frame(struct sk_buff *skb, struct net_device *dev);
......
...@@ -828,7 +828,6 @@ void mesh_path_timer(unsigned long data) ...@@ -828,7 +828,6 @@ void mesh_path_timer(unsigned long data)
{ {
struct ieee80211_sub_if_data *sdata; struct ieee80211_sub_if_data *sdata;
struct mesh_path *mpath; struct mesh_path *mpath;
bool delete = false;
rcu_read_lock(); rcu_read_lock();
mpath = (struct mesh_path *) data; mpath = (struct mesh_path *) data;
...@@ -837,10 +836,7 @@ void mesh_path_timer(unsigned long data) ...@@ -837,10 +836,7 @@ void mesh_path_timer(unsigned long data)
goto endmpathtimer; goto endmpathtimer;
spin_lock_bh(&mpath->state_lock); spin_lock_bh(&mpath->state_lock);
sdata = IEEE80211_DEV_TO_SUB_IF(mpath->dev); sdata = IEEE80211_DEV_TO_SUB_IF(mpath->dev);
if (mpath->flags & MESH_PATH_DELETE) { if (mpath->flags & MESH_PATH_RESOLVED ||
mpath->flags = 0;
delete = true;
} else if (mpath->flags & MESH_PATH_RESOLVED ||
(!(mpath->flags & MESH_PATH_RESOLVING))) (!(mpath->flags & MESH_PATH_RESOLVING)))
mpath->flags &= ~(MESH_PATH_RESOLVING | MESH_PATH_RESOLVED); mpath->flags &= ~(MESH_PATH_RESOLVING | MESH_PATH_RESOLVED);
else if (mpath->discovery_retries < max_preq_retries(sdata)) { else if (mpath->discovery_retries < max_preq_retries(sdata)) {
...@@ -856,6 +852,4 @@ void mesh_path_timer(unsigned long data) ...@@ -856,6 +852,4 @@ void mesh_path_timer(unsigned long data)
spin_unlock_bh(&mpath->state_lock); spin_unlock_bh(&mpath->state_lock);
endmpathtimer: endmpathtimer:
rcu_read_unlock(); rcu_read_unlock();
if (delete)
mesh_path_del(mpath->dst, mpath->dev, false);
} }
...@@ -277,7 +277,7 @@ void mesh_path_flush_by_nexthop(struct sta_info *sta) ...@@ -277,7 +277,7 @@ void mesh_path_flush_by_nexthop(struct sta_info *sta)
for_each_mesh_entry(mesh_paths, p, node, i) { for_each_mesh_entry(mesh_paths, p, node, i) {
mpath = node->mpath; mpath = node->mpath;
if (mpath->next_hop == sta) if (mpath->next_hop == sta)
mesh_path_del(mpath->dst, mpath->dev, true); mesh_path_del(mpath->dst, mpath->dev);
} }
} }
...@@ -291,7 +291,7 @@ void mesh_path_flush(struct net_device *dev) ...@@ -291,7 +291,7 @@ void mesh_path_flush(struct net_device *dev)
for_each_mesh_entry(mesh_paths, p, node, i) { for_each_mesh_entry(mesh_paths, p, node, i) {
mpath = node->mpath; mpath = node->mpath;
if (mpath->dev == dev) if (mpath->dev == dev)
mesh_path_del(mpath->dst, mpath->dev, false); mesh_path_del(mpath->dst, mpath->dev);
} }
} }
...@@ -314,12 +314,8 @@ static void mesh_path_node_reclaim(struct rcu_head *rp) ...@@ -314,12 +314,8 @@ static void mesh_path_node_reclaim(struct rcu_head *rp)
* @dev: local interface * @dev: local interface
* *
* Returns: 0 if succesful * Returns: 0 if succesful
*
* State: if the path is being resolved, the deletion will be postponed until
* the path resolution completes or times out, unless the force parameter
* is given.
*/ */
int mesh_path_del(u8 *addr, struct net_device *dev, bool force) int mesh_path_del(u8 *addr, struct net_device *dev)
{ {
struct mesh_path *mpath; struct mesh_path *mpath;
struct mpath_node *node; struct mpath_node *node;
...@@ -338,14 +334,10 @@ int mesh_path_del(u8 *addr, struct net_device *dev, bool force) ...@@ -338,14 +334,10 @@ int mesh_path_del(u8 *addr, struct net_device *dev, bool force)
if (mpath->dev == dev && if (mpath->dev == dev &&
memcmp(addr, mpath->dst, ETH_ALEN) == 0) { memcmp(addr, mpath->dst, ETH_ALEN) == 0) {
spin_lock_bh(&mpath->state_lock); spin_lock_bh(&mpath->state_lock);
if (!force && mpath->flags & MESH_PATH_RESOLVING) { mpath->flags |= MESH_PATH_RESOLVING;
mpath->flags |= MESH_PATH_DELETE; hlist_del_rcu(&node->list);
} else { call_rcu(&node->rcu, mesh_path_node_reclaim);
mpath->flags |= MESH_PATH_RESOLVING; atomic_dec(&mesh_paths->entries);
hlist_del_rcu(&node->list);
call_rcu(&node->rcu, mesh_path_node_reclaim);
atomic_dec(&mesh_paths->entries);
}
spin_unlock_bh(&mpath->state_lock); spin_unlock_bh(&mpath->state_lock);
goto enddel; goto enddel;
} }
...@@ -508,7 +500,7 @@ void mesh_path_expire(struct net_device *dev) ...@@ -508,7 +500,7 @@ void mesh_path_expire(struct net_device *dev)
time_after(jiffies, time_after(jiffies,
mpath->exp_time + MESH_PATH_EXPIRE)) { mpath->exp_time + MESH_PATH_EXPIRE)) {
spin_unlock_bh(&mpath->state_lock); spin_unlock_bh(&mpath->state_lock);
mesh_path_del(mpath->dst, mpath->dev, false); mesh_path_del(mpath->dst, mpath->dev);
} else } else
spin_unlock_bh(&mpath->state_lock); spin_unlock_bh(&mpath->state_lock);
} }
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment