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()
83 void mesh_path_assign_nexthop(struct mesh_path *mpath, struct sta_info *sta)  in mesh_path_assign_nexthop()  argument
89 	rcu_assign_pointer(mpath->next_hop, sta);  in mesh_path_assign_nexthop()
91 	spin_lock_irqsave(&mpath->frame_queue.lock, flags);  in mesh_path_assign_nexthop()
92 	skb_queue_walk(&mpath->frame_queue, skb) {  in mesh_path_assign_nexthop()
95 		memcpy(hdr->addr2, mpath->sdata->vif.addr, ETH_ALEN);  in mesh_path_assign_nexthop()
99 	spin_unlock_irqrestore(&mpath->frame_queue.lock, flags);  in mesh_path_assign_nexthop()
215 	struct mesh_path *mpath;  in mpath_lookup()  local
217 	mpath = rhashtable_lookup(&tbl->rhead, dst, mesh_rht_params);  in mpath_lookup()
219 	if (mpath && mpath_expired(mpath)) {  in mpath_lookup()
220 		spin_lock_bh(&mpath->state_lock);  in mpath_lookup()
221 		mpath->flags &= ~MESH_PATH_ACTIVE;  in mpath_lookup()
222 		spin_unlock_bh(&mpath->state_lock);  in mpath_lookup()
224 	return mpath;  in mpath_lookup()
252 	struct mesh_path *mpath;  in __mesh_path_lookup_by_idx()  local
254 	hlist_for_each_entry_rcu(mpath, &tbl->walk_head, walk_list) {  in __mesh_path_lookup_by_idx()
259 	if (!mpath)  in __mesh_path_lookup_by_idx()
262 	if (mpath_expired(mpath)) {  in __mesh_path_lookup_by_idx()
263 		spin_lock_bh(&mpath->state_lock);  in __mesh_path_lookup_by_idx()
264 		mpath->flags &= ~MESH_PATH_ACTIVE;  in __mesh_path_lookup_by_idx()
265 		spin_unlock_bh(&mpath->state_lock);  in __mesh_path_lookup_by_idx()
267 	return mpath;  in __mesh_path_lookup_by_idx()
304 int mesh_path_add_gate(struct mesh_path *mpath)  in mesh_path_add_gate()  argument
310 	tbl = mpath->sdata->u.mesh.mesh_paths;  in mesh_path_add_gate()
312 	spin_lock_bh(&mpath->state_lock);  in mesh_path_add_gate()
313 	if (mpath->is_gate) {  in mesh_path_add_gate()
315 		spin_unlock_bh(&mpath->state_lock);  in mesh_path_add_gate()
318 	mpath->is_gate = true;  in mesh_path_add_gate()
319 	mpath->sdata->u.mesh.num_gates++;  in mesh_path_add_gate()
322 	hlist_add_head_rcu(&mpath->gate_list, &tbl->known_gates);  in mesh_path_add_gate()
325 	spin_unlock_bh(&mpath->state_lock);  in mesh_path_add_gate()
327 	mpath_dbg(mpath->sdata,  in mesh_path_add_gate()
329 		  mpath->dst, mpath->sdata->u.mesh.num_gates);  in mesh_path_add_gate()
341 static void mesh_gate_del(struct mesh_table *tbl, struct mesh_path *mpath)  in mesh_gate_del()  argument
343 	lockdep_assert_held(&mpath->state_lock);  in mesh_gate_del()
344 	if (!mpath->is_gate)  in mesh_gate_del()
347 	mpath->is_gate = false;  in mesh_gate_del()
349 	hlist_del_rcu(&mpath->gate_list);  in mesh_gate_del()
350 	mpath->sdata->u.mesh.num_gates--;  in mesh_gate_del()
353 	mpath_dbg(mpath->sdata,  in mesh_gate_del()
355 		  mpath->dst, mpath->sdata->u.mesh.num_gates);  in mesh_gate_del()
403 	struct mesh_path *mpath, *new_mpath;  in mesh_path_add()  local
421 	mpath = rhashtable_lookup_get_insert_fast(&tbl->rhead,  in mesh_path_add()
424 	if (!mpath)  in mesh_path_add()
428 	if (mpath) {  in mesh_path_add()
431 		if (IS_ERR(mpath))  in mesh_path_add()
432 			return mpath;  in mesh_path_add()
434 		new_mpath = mpath;  in mesh_path_add()
492 	struct mesh_path *mpath;  in mesh_plink_broken()  local
495 	hlist_for_each_entry_rcu(mpath, &tbl->walk_head, walk_list) {  in mesh_plink_broken()
496 		if (rcu_access_pointer(mpath->next_hop) == sta &&  in mesh_plink_broken()
497 		    mpath->flags & MESH_PATH_ACTIVE &&  in mesh_plink_broken()
498 		    !(mpath->flags & MESH_PATH_FIXED)) {  in mesh_plink_broken()
499 			spin_lock_bh(&mpath->state_lock);  in mesh_plink_broken()
500 			mpath->flags &= ~MESH_PATH_ACTIVE;  in mesh_plink_broken()
501 			++mpath->sn;  in mesh_plink_broken()
502 			spin_unlock_bh(&mpath->state_lock);  in mesh_plink_broken()
505 				mpath->dst, mpath->sn,  in mesh_plink_broken()
513 			       struct mesh_path *mpath)  in mesh_path_free_rcu()  argument
515 	struct ieee80211_sub_if_data *sdata = mpath->sdata;  in mesh_path_free_rcu()
517 	spin_lock_bh(&mpath->state_lock);  in mesh_path_free_rcu()
518 	mpath->flags |= MESH_PATH_RESOLVING | MESH_PATH_DELETED;  in mesh_path_free_rcu()
519 	mesh_gate_del(tbl, mpath);  in mesh_path_free_rcu()
520 	spin_unlock_bh(&mpath->state_lock);  in mesh_path_free_rcu()
521 	del_timer_sync(&mpath->timer);  in mesh_path_free_rcu()
524 	kfree_rcu(mpath, rcu);  in mesh_path_free_rcu()
527 static void __mesh_path_del(struct mesh_table *tbl, struct mesh_path *mpath)  in __mesh_path_del()  argument
529 	hlist_del_rcu(&mpath->walk_list);  in __mesh_path_del()
530 	rhashtable_remove_fast(&tbl->rhead, &mpath->rhash, mesh_rht_params);  in __mesh_path_del()
531 	mesh_path_free_rcu(tbl, mpath);  in __mesh_path_del()
549 	struct mesh_path *mpath;  in mesh_path_flush_by_nexthop()  local
553 	hlist_for_each_entry_safe(mpath, n, &tbl->walk_head, walk_list) {  in mesh_path_flush_by_nexthop()
554 		if (rcu_access_pointer(mpath->next_hop) == sta)  in mesh_path_flush_by_nexthop()
555 			__mesh_path_del(tbl, mpath);  in mesh_path_flush_by_nexthop()
564 	struct mesh_path *mpath;  in mpp_flush_by_proxy()  local
568 	hlist_for_each_entry_safe(mpath, n, &tbl->walk_head, walk_list) {  in mpp_flush_by_proxy()
569 		if (ether_addr_equal(mpath->mpp, proxy))  in mpp_flush_by_proxy()
570 			__mesh_path_del(tbl, mpath);  in mpp_flush_by_proxy()
577 	struct mesh_path *mpath;  in table_flush_by_iface()  local
581 	hlist_for_each_entry_safe(mpath, n, &tbl->walk_head, walk_list) {  in table_flush_by_iface()
582 		__mesh_path_del(tbl, mpath);  in table_flush_by_iface()
614 	struct mesh_path *mpath;  in table_path_del()  local
617 	mpath = rhashtable_lookup_fast(&tbl->rhead, addr, mesh_rht_params);  in table_path_del()
618 	if (!mpath) {  in table_path_del()
623 	__mesh_path_del(tbl, mpath);  in table_path_del()
657 void mesh_path_tx_pending(struct mesh_path *mpath)  in mesh_path_tx_pending()  argument
659 	if (mpath->flags & MESH_PATH_ACTIVE)  in mesh_path_tx_pending()
660 		ieee80211_add_pending_skbs(mpath->sdata->local,  in mesh_path_tx_pending()
661 				&mpath->frame_queue);  in mesh_path_tx_pending()
674 int mesh_path_send_to_gates(struct mesh_path *mpath)  in mesh_path_send_to_gates()  argument
676 	struct ieee80211_sub_if_data *sdata = mpath->sdata;  in mesh_path_send_to_gates()
678 	struct mesh_path *from_mpath = mpath;  in mesh_path_send_to_gates()
704 	return (from_mpath == mpath) ? -EHOSTUNREACH : 0;  in mesh_path_send_to_gates()
729 void mesh_path_flush_pending(struct mesh_path *mpath)  in mesh_path_flush_pending()  argument
733 	while ((skb = skb_dequeue(&mpath->frame_queue)) != NULL)  in mesh_path_flush_pending()
734 		mesh_path_discard_frame(mpath->sdata, skb);  in mesh_path_flush_pending()
745 void mesh_path_fix_nexthop(struct mesh_path *mpath, struct sta_info *next_hop)  in mesh_path_fix_nexthop()  argument
747 	spin_lock_bh(&mpath->state_lock);  in mesh_path_fix_nexthop()
748 	mesh_path_assign_nexthop(mpath, next_hop);  in mesh_path_fix_nexthop()
749 	mpath->sn = 0xffff;  in mesh_path_fix_nexthop()
750 	mpath->metric = 0;  in mesh_path_fix_nexthop()
751 	mpath->hop_count = 0;  in mesh_path_fix_nexthop()
752 	mpath->exp_time = 0;  in mesh_path_fix_nexthop()
753 	mpath->flags = MESH_PATH_FIXED | MESH_PATH_SN_VALID;  in mesh_path_fix_nexthop()
754 	mesh_path_activate(mpath);  in mesh_path_fix_nexthop()
755 	spin_unlock_bh(&mpath->state_lock);  in mesh_path_fix_nexthop()
759 	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()