18 static void mesh_path_free_rcu(struct mesh_table *tbl, struct mesh_path *mpath);
35 static inline bool mpath_expired(struct mesh_path *mpath)  in mpath_expired()  argument
37 	return (mpath->flags & MESH_PATH_ACTIVE) &&  in mpath_expired()
38 	       time_after(jiffies, mpath->exp_time) &&  in mpath_expired()
39 	       !(mpath->flags & MESH_PATH_FIXED);  in mpath_expired()
44 	struct mesh_path *mpath = ptr;  in mesh_path_rht_free()  local
47 	mesh_path_free_rcu(tbl, mpath);  in mesh_path_rht_free()
86 void mesh_path_assign_nexthop(struct mesh_path *mpath, struct sta_info *sta)  in mesh_path_assign_nexthop()  argument
92 	rcu_assign_pointer(mpath->next_hop, sta);  in mesh_path_assign_nexthop()
94 	spin_lock_irqsave(&mpath->frame_queue.lock, flags);  in mesh_path_assign_nexthop()
95 	skb_queue_walk(&mpath->frame_queue, skb) {  in mesh_path_assign_nexthop()
98 		memcpy(hdr->addr2, mpath->sdata->vif.addr, ETH_ALEN);  in mesh_path_assign_nexthop()
102 	spin_unlock_irqrestore(&mpath->frame_queue.lock, flags);  in mesh_path_assign_nexthop()
217 	struct mesh_path *mpath;  in mpath_lookup()  local
219 	mpath = rhashtable_lookup(&tbl->rhead, dst, mesh_rht_params);  in mpath_lookup()
221 	if (mpath && mpath_expired(mpath)) {  in mpath_lookup()
222 		spin_lock_bh(&mpath->state_lock);  in mpath_lookup()
223 		mpath->flags &= ~MESH_PATH_ACTIVE;  in mpath_lookup()
224 		spin_unlock_bh(&mpath->state_lock);  in mpath_lookup()
226 	return mpath;  in mpath_lookup()
254 	struct mesh_path *mpath;  in __mesh_path_lookup_by_idx()  local
256 	hlist_for_each_entry_rcu(mpath, &tbl->walk_head, walk_list) {  in __mesh_path_lookup_by_idx()
261 	if (!mpath)  in __mesh_path_lookup_by_idx()
264 	if (mpath_expired(mpath)) {  in __mesh_path_lookup_by_idx()
265 		spin_lock_bh(&mpath->state_lock);  in __mesh_path_lookup_by_idx()
266 		mpath->flags &= ~MESH_PATH_ACTIVE;  in __mesh_path_lookup_by_idx()
267 		spin_unlock_bh(&mpath->state_lock);  in __mesh_path_lookup_by_idx()
269 	return mpath;  in __mesh_path_lookup_by_idx()
306 int mesh_path_add_gate(struct mesh_path *mpath)  in mesh_path_add_gate()  argument
312 	tbl = mpath->sdata->u.mesh.mesh_paths;  in mesh_path_add_gate()
314 	spin_lock_bh(&mpath->state_lock);  in mesh_path_add_gate()
315 	if (mpath->is_gate) {  in mesh_path_add_gate()
317 		spin_unlock_bh(&mpath->state_lock);  in mesh_path_add_gate()
320 	mpath->is_gate = true;  in mesh_path_add_gate()
321 	mpath->sdata->u.mesh.num_gates++;  in mesh_path_add_gate()
324 	hlist_add_head_rcu(&mpath->gate_list, &tbl->known_gates);  in mesh_path_add_gate()
327 	spin_unlock_bh(&mpath->state_lock);  in mesh_path_add_gate()
329 	mpath_dbg(mpath->sdata,  in mesh_path_add_gate()
331 		  mpath->dst, mpath->sdata->u.mesh.num_gates);  in mesh_path_add_gate()
343 static void mesh_gate_del(struct mesh_table *tbl, struct mesh_path *mpath)  in mesh_gate_del()  argument
345 	lockdep_assert_held(&mpath->state_lock);  in mesh_gate_del()
346 	if (!mpath->is_gate)  in mesh_gate_del()
349 	mpath->is_gate = false;  in mesh_gate_del()
351 	hlist_del_rcu(&mpath->gate_list);  in mesh_gate_del()
352 	mpath->sdata->u.mesh.num_gates--;  in mesh_gate_del()
355 	mpath_dbg(mpath->sdata,  in mesh_gate_del()
357 		  mpath->dst, mpath->sdata->u.mesh.num_gates);  in mesh_gate_del()
405 	struct mesh_path *mpath, *new_mpath;  in mesh_path_add()  local
423 	mpath = rhashtable_lookup_get_insert_fast(&tbl->rhead,  in mesh_path_add()
426 	if (!mpath)  in mesh_path_add()
430 	if (mpath) {  in mesh_path_add()
433 		if (IS_ERR(mpath))  in mesh_path_add()
434 			return mpath;  in mesh_path_add()
436 		new_mpath = mpath;  in mesh_path_add()
494 	struct mesh_path *mpath;  in mesh_plink_broken()  local
497 	hlist_for_each_entry_rcu(mpath, &tbl->walk_head, walk_list) {  in mesh_plink_broken()
498 		if (rcu_access_pointer(mpath->next_hop) == sta &&  in mesh_plink_broken()
499 		    mpath->flags & MESH_PATH_ACTIVE &&  in mesh_plink_broken()
500 		    !(mpath->flags & MESH_PATH_FIXED)) {  in mesh_plink_broken()
501 			spin_lock_bh(&mpath->state_lock);  in mesh_plink_broken()
502 			mpath->flags &= ~MESH_PATH_ACTIVE;  in mesh_plink_broken()
503 			++mpath->sn;  in mesh_plink_broken()
504 			spin_unlock_bh(&mpath->state_lock);  in mesh_plink_broken()
507 				mpath->dst, mpath->sn,  in mesh_plink_broken()
515 			       struct mesh_path *mpath)  in mesh_path_free_rcu()  argument
517 	struct ieee80211_sub_if_data *sdata = mpath->sdata;  in mesh_path_free_rcu()
519 	spin_lock_bh(&mpath->state_lock);  in mesh_path_free_rcu()
520 	mpath->flags |= MESH_PATH_RESOLVING | MESH_PATH_DELETED;  in mesh_path_free_rcu()
521 	mesh_gate_del(tbl, mpath);  in mesh_path_free_rcu()
522 	spin_unlock_bh(&mpath->state_lock);  in mesh_path_free_rcu()
523 	del_timer_sync(&mpath->timer);  in mesh_path_free_rcu()
526 	mesh_path_flush_pending(mpath);  in mesh_path_free_rcu()
527 	kfree_rcu(mpath, rcu);  in mesh_path_free_rcu()
530 static void __mesh_path_del(struct mesh_table *tbl, struct mesh_path *mpath)  in __mesh_path_del()  argument
532 	hlist_del_rcu(&mpath->walk_list);  in __mesh_path_del()
533 	rhashtable_remove_fast(&tbl->rhead, &mpath->rhash, mesh_rht_params);  in __mesh_path_del()
534 	mesh_path_free_rcu(tbl, mpath);  in __mesh_path_del()
552 	struct mesh_path *mpath;  in mesh_path_flush_by_nexthop()  local
556 	hlist_for_each_entry_safe(mpath, n, &tbl->walk_head, walk_list) {  in mesh_path_flush_by_nexthop()
557 		if (rcu_access_pointer(mpath->next_hop) == sta)  in mesh_path_flush_by_nexthop()
558 			__mesh_path_del(tbl, mpath);  in mesh_path_flush_by_nexthop()
567 	struct mesh_path *mpath;  in mpp_flush_by_proxy()  local
571 	hlist_for_each_entry_safe(mpath, n, &tbl->walk_head, walk_list) {  in mpp_flush_by_proxy()
572 		if (ether_addr_equal(mpath->mpp, proxy))  in mpp_flush_by_proxy()
573 			__mesh_path_del(tbl, mpath);  in mpp_flush_by_proxy()
580 	struct mesh_path *mpath;  in table_flush_by_iface()  local
584 	hlist_for_each_entry_safe(mpath, n, &tbl->walk_head, walk_list) {  in table_flush_by_iface()
585 		__mesh_path_del(tbl, mpath);  in table_flush_by_iface()
617 	struct mesh_path *mpath;  in table_path_del()  local
620 	mpath = rhashtable_lookup_fast(&tbl->rhead, addr, mesh_rht_params);  in table_path_del()
621 	if (!mpath) {  in table_path_del()
626 	__mesh_path_del(tbl, mpath);  in table_path_del()
660 void mesh_path_tx_pending(struct mesh_path *mpath)  in mesh_path_tx_pending()  argument
662 	if (mpath->flags & MESH_PATH_ACTIVE)  in mesh_path_tx_pending()
663 		ieee80211_add_pending_skbs(mpath->sdata->local,  in mesh_path_tx_pending()
664 				&mpath->frame_queue);  in mesh_path_tx_pending()
677 int mesh_path_send_to_gates(struct mesh_path *mpath)  in mesh_path_send_to_gates()  argument
679 	struct ieee80211_sub_if_data *sdata = mpath->sdata;  in mesh_path_send_to_gates()
681 	struct mesh_path *from_mpath = mpath;  in mesh_path_send_to_gates()
707 	return (from_mpath == mpath) ? -EHOSTUNREACH : 0;  in mesh_path_send_to_gates()
732 void mesh_path_flush_pending(struct mesh_path *mpath)  in mesh_path_flush_pending()  argument
736 	while ((skb = skb_dequeue(&mpath->frame_queue)) != NULL)  in mesh_path_flush_pending()
737 		mesh_path_discard_frame(mpath->sdata, skb);  in mesh_path_flush_pending()
748 void mesh_path_fix_nexthop(struct mesh_path *mpath, struct sta_info *next_hop)  in mesh_path_fix_nexthop()  argument
750 	spin_lock_bh(&mpath->state_lock);  in mesh_path_fix_nexthop()
751 	mesh_path_assign_nexthop(mpath, next_hop);  in mesh_path_fix_nexthop()
752 	mpath->sn = 0xffff;  in mesh_path_fix_nexthop()
753 	mpath->metric = 0;  in mesh_path_fix_nexthop()
754 	mpath->hop_count = 0;  in mesh_path_fix_nexthop()
755 	mpath->exp_time = 0;  in mesh_path_fix_nexthop()
756 	mpath->flags = MESH_PATH_FIXED | MESH_PATH_SN_VALID;  in mesh_path_fix_nexthop()
757 	mesh_path_activate(mpath);  in mesh_path_fix_nexthop()
758 	spin_unlock_bh(&mpath->state_lock);  in mesh_path_fix_nexthop()
762 	mesh_path_tx_pending(mpath);  in mesh_path_fix_nexthop()
794 	struct mesh_path *mpath;  in mesh_path_tbl_expire()  local
798 	hlist_for_each_entry_safe(mpath, n, &tbl->walk_head, walk_list) {  in mesh_path_tbl_expire()
799 		if ((!(mpath->flags & MESH_PATH_RESOLVING)) &&  in mesh_path_tbl_expire()
800 		    (!(mpath->flags & MESH_PATH_FIXED)) &&  in mesh_path_tbl_expire()
801 		     time_after(jiffies, mpath->exp_time + MESH_PATH_EXPIRE))  in mesh_path_tbl_expire()
802 			__mesh_path_del(tbl, mpath);  in mesh_path_tbl_expire()