2 * Copyright (c) 2008, 2009 open80211s Ltd.
3 * Author: Luis Carlos Cobo <luisca@cozybit.com>
5 * This program is free software; you can redistribute it and/or modify
6 * it under the terms of the GNU General Public License version 2 as
7 * published by the Free Software Foundation.
10 #include <linux/kernel.h>
11 #include <linux/random.h>
12 #include "ieee80211_i.h"
16 #define PLINK_CNF_AID(mgmt) ((mgmt)->u.action.u.self_prot.variable + 2)
17 #define PLINK_GET_LLID(p) (p + 2)
18 #define PLINK_GET_PLID(p) (p + 4)
20 #define mod_plink_timer(s, t) (mod_timer(&s->mesh->plink_timer, \
21 jiffies + msecs_to_jiffies(t)))
35 static const char * const mplstates
[] = {
36 [NL80211_PLINK_LISTEN
] = "LISTEN",
37 [NL80211_PLINK_OPN_SNT
] = "OPN-SNT",
38 [NL80211_PLINK_OPN_RCVD
] = "OPN-RCVD",
39 [NL80211_PLINK_CNF_RCVD
] = "CNF_RCVD",
40 [NL80211_PLINK_ESTAB
] = "ESTAB",
41 [NL80211_PLINK_HOLDING
] = "HOLDING",
42 [NL80211_PLINK_BLOCKED
] = "BLOCKED"
45 static const char * const mplevents
[] = {
46 [PLINK_UNDEFINED
] = "NONE",
47 [OPN_ACPT
] = "OPN_ACPT",
48 [OPN_RJCT
] = "OPN_RJCT",
49 [OPN_IGNR
] = "OPN_IGNR",
50 [CNF_ACPT
] = "CNF_ACPT",
51 [CNF_RJCT
] = "CNF_RJCT",
52 [CNF_IGNR
] = "CNF_IGNR",
53 [CLS_ACPT
] = "CLS_ACPT",
54 [CLS_IGNR
] = "CLS_IGNR"
57 /* We only need a valid sta if user configured a minimum rssi_threshold. */
58 static bool rssi_threshold_check(struct ieee80211_sub_if_data
*sdata
,
61 s32 rssi_threshold
= sdata
->u
.mesh
.mshcfg
.rssi_threshold
;
62 return rssi_threshold
== 0 ||
64 (s8
)-ewma_signal_read(&sta
->rx_stats_avg
.signal
) >
69 * mesh_plink_fsm_restart - restart a mesh peer link finite state machine
71 * @sta: mesh peer link to restart
73 * Locking: this function must be called holding sta->mesh->plink_lock
75 static inline void mesh_plink_fsm_restart(struct sta_info
*sta
)
77 lockdep_assert_held(&sta
->mesh
->plink_lock
);
78 sta
->mesh
->plink_state
= NL80211_PLINK_LISTEN
;
79 sta
->mesh
->llid
= sta
->mesh
->plid
= sta
->mesh
->reason
= 0;
80 sta
->mesh
->plink_retries
= 0;
84 * mesh_set_short_slot_time - enable / disable ERP short slot time.
86 * The standard indirectly mandates mesh STAs to turn off short slot time by
87 * disallowing advertising this (802.11-2012 8.4.1.4), but that doesn't mean we
88 * can't be sneaky about it. Enable short slot time if all mesh STAs in the
89 * MBSS support ERP rates.
91 * Returns BSS_CHANGED_ERP_SLOT or 0 for no change.
93 static u32
mesh_set_short_slot_time(struct ieee80211_sub_if_data
*sdata
)
95 struct ieee80211_local
*local
= sdata
->local
;
96 enum nl80211_band band
= ieee80211_get_sdata_band(sdata
);
97 struct ieee80211_supported_band
*sband
= local
->hw
.wiphy
->bands
[band
];
99 u32 erp_rates
= 0, changed
= 0;
101 bool short_slot
= false;
103 if (band
== NL80211_BAND_5GHZ
) {
104 /* (IEEE 802.11-2012 19.4.5) */
107 } else if (band
!= NL80211_BAND_2GHZ
)
110 for (i
= 0; i
< sband
->n_bitrates
; i
++)
111 if (sband
->bitrates
[i
].flags
& IEEE80211_RATE_ERP_G
)
118 list_for_each_entry_rcu(sta
, &local
->sta_list
, list
) {
119 if (sdata
!= sta
->sdata
||
120 sta
->mesh
->plink_state
!= NL80211_PLINK_ESTAB
)
124 if (erp_rates
& sta
->sta
.supp_rates
[band
])
132 if (sdata
->vif
.bss_conf
.use_short_slot
!= short_slot
) {
133 sdata
->vif
.bss_conf
.use_short_slot
= short_slot
;
134 changed
= BSS_CHANGED_ERP_SLOT
;
135 mpl_dbg(sdata
, "mesh_plink %pM: ERP short slot time %d\n",
136 sdata
->vif
.addr
, short_slot
);
142 * mesh_set_ht_prot_mode - set correct HT protection mode
144 * Section 9.23.3.5 of IEEE 80211-2012 describes the protection rules for HT
145 * mesh STA in a MBSS. Three HT protection modes are supported for now, non-HT
146 * mixed mode, 20MHz-protection and no-protection mode. non-HT mixed mode is
147 * selected if any non-HT peers are present in our MBSS. 20MHz-protection mode
148 * is selected if all peers in our 20/40MHz MBSS support HT and atleast one
149 * HT20 peer is present. Otherwise no-protection mode is selected.
151 static u32
mesh_set_ht_prot_mode(struct ieee80211_sub_if_data
*sdata
)
153 struct ieee80211_local
*local
= sdata
->local
;
154 struct sta_info
*sta
;
156 bool non_ht_sta
= false, ht20_sta
= false;
158 switch (sdata
->vif
.bss_conf
.chandef
.width
) {
159 case NL80211_CHAN_WIDTH_20_NOHT
:
160 case NL80211_CHAN_WIDTH_5
:
161 case NL80211_CHAN_WIDTH_10
:
168 list_for_each_entry_rcu(sta
, &local
->sta_list
, list
) {
169 if (sdata
!= sta
->sdata
||
170 sta
->mesh
->plink_state
!= NL80211_PLINK_ESTAB
)
173 if (sta
->sta
.bandwidth
> IEEE80211_STA_RX_BW_20
)
176 if (!sta
->sta
.ht_cap
.ht_supported
) {
177 mpl_dbg(sdata
, "nonHT sta (%pM) is present\n",
183 mpl_dbg(sdata
, "HT20 sta (%pM) is present\n", sta
->sta
.addr
);
189 ht_opmode
= IEEE80211_HT_OP_MODE_PROTECTION_NONHT_MIXED
;
191 sdata
->vif
.bss_conf
.chandef
.width
> NL80211_CHAN_WIDTH_20
)
192 ht_opmode
= IEEE80211_HT_OP_MODE_PROTECTION_20MHZ
;
194 ht_opmode
= IEEE80211_HT_OP_MODE_PROTECTION_NONE
;
196 if (sdata
->vif
.bss_conf
.ht_operation_mode
== ht_opmode
)
199 sdata
->vif
.bss_conf
.ht_operation_mode
= ht_opmode
;
200 sdata
->u
.mesh
.mshcfg
.ht_opmode
= ht_opmode
;
201 mpl_dbg(sdata
, "selected new HT protection mode %d\n", ht_opmode
);
202 return BSS_CHANGED_HT
;
205 static int mesh_plink_frame_tx(struct ieee80211_sub_if_data
*sdata
,
206 struct sta_info
*sta
,
207 enum ieee80211_self_protected_actioncode action
,
208 u8
*da
, u16 llid
, u16 plid
, u16 reason
)
210 struct ieee80211_local
*local
= sdata
->local
;
212 struct ieee80211_tx_info
*info
;
213 struct ieee80211_mgmt
*mgmt
;
214 bool include_plid
= false;
215 u16 peering_proto
= 0;
217 int hdr_len
= offsetof(struct ieee80211_mgmt
, u
.action
.u
.self_prot
) +
218 sizeof(mgmt
->u
.action
.u
.self_prot
);
221 skb
= dev_alloc_skb(local
->tx_headroom
+
223 2 + /* capability info */
225 2 + 8 + /* supported rates */
226 2 + (IEEE80211_MAX_SUPP_RATES
- 8) +
227 2 + sdata
->u
.mesh
.mesh_id_len
+
228 2 + sizeof(struct ieee80211_meshconf_ie
) +
229 2 + sizeof(struct ieee80211_ht_cap
) +
230 2 + sizeof(struct ieee80211_ht_operation
) +
231 2 + sizeof(struct ieee80211_vht_cap
) +
232 2 + sizeof(struct ieee80211_vht_operation
) +
233 2 + 8 + /* peering IE */
234 sdata
->u
.mesh
.ie_len
);
237 info
= IEEE80211_SKB_CB(skb
);
238 skb_reserve(skb
, local
->tx_headroom
);
239 mgmt
= (struct ieee80211_mgmt
*) skb_put(skb
, hdr_len
);
240 memset(mgmt
, 0, hdr_len
);
241 mgmt
->frame_control
= cpu_to_le16(IEEE80211_FTYPE_MGMT
|
242 IEEE80211_STYPE_ACTION
);
243 memcpy(mgmt
->da
, da
, ETH_ALEN
);
244 memcpy(mgmt
->sa
, sdata
->vif
.addr
, ETH_ALEN
);
245 memcpy(mgmt
->bssid
, sdata
->vif
.addr
, ETH_ALEN
);
246 mgmt
->u
.action
.category
= WLAN_CATEGORY_SELF_PROTECTED
;
247 mgmt
->u
.action
.u
.self_prot
.action_code
= action
;
249 if (action
!= WLAN_SP_MESH_PEERING_CLOSE
) {
250 enum nl80211_band band
= ieee80211_get_sdata_band(sdata
);
252 /* capability info */
253 pos
= skb_put(skb
, 2);
255 if (action
== WLAN_SP_MESH_PEERING_CONFIRM
) {
257 pos
= skb_put(skb
, 2);
258 put_unaligned_le16(sta
->sta
.aid
, pos
);
260 if (ieee80211_add_srates_ie(sdata
, skb
, true, band
) ||
261 ieee80211_add_ext_srates_ie(sdata
, skb
, true, band
) ||
262 mesh_add_rsn_ie(sdata
, skb
) ||
263 mesh_add_meshid_ie(sdata
, skb
) ||
264 mesh_add_meshconf_ie(sdata
, skb
))
266 } else { /* WLAN_SP_MESH_PEERING_CLOSE */
267 info
->flags
|= IEEE80211_TX_CTL_NO_ACK
;
268 if (mesh_add_meshid_ie(sdata
, skb
))
272 /* Add Mesh Peering Management element */
274 case WLAN_SP_MESH_PEERING_OPEN
:
276 case WLAN_SP_MESH_PEERING_CONFIRM
:
280 case WLAN_SP_MESH_PEERING_CLOSE
:
285 ie_len
+= 2; /* reason code */
292 if (WARN_ON(skb_tailroom(skb
) < 2 + ie_len
))
295 pos
= skb_put(skb
, 2 + ie_len
);
296 *pos
++ = WLAN_EID_PEER_MGMT
;
298 memcpy(pos
, &peering_proto
, 2);
300 put_unaligned_le16(llid
, pos
);
303 put_unaligned_le16(plid
, pos
);
306 if (action
== WLAN_SP_MESH_PEERING_CLOSE
) {
307 put_unaligned_le16(reason
, pos
);
311 if (action
!= WLAN_SP_MESH_PEERING_CLOSE
) {
312 if (mesh_add_ht_cap_ie(sdata
, skb
) ||
313 mesh_add_ht_oper_ie(sdata
, skb
) ||
314 mesh_add_vht_cap_ie(sdata
, skb
) ||
315 mesh_add_vht_oper_ie(sdata
, skb
))
319 if (mesh_add_vendor_ies(sdata
, skb
))
322 ieee80211_tx_skb(sdata
, skb
);
330 * __mesh_plink_deactivate - deactivate mesh peer link
332 * @sta: mesh peer link to deactivate
334 * Mesh paths with this peer as next hop should be flushed
335 * by the caller outside of plink_lock.
337 * Returns beacon changed flag if the beacon content changed.
339 * Locking: the caller must hold sta->mesh->plink_lock
341 static u32
__mesh_plink_deactivate(struct sta_info
*sta
)
343 struct ieee80211_sub_if_data
*sdata
= sta
->sdata
;
346 lockdep_assert_held(&sta
->mesh
->plink_lock
);
348 if (sta
->mesh
->plink_state
== NL80211_PLINK_ESTAB
)
349 changed
= mesh_plink_dec_estab_count(sdata
);
350 sta
->mesh
->plink_state
= NL80211_PLINK_BLOCKED
;
352 ieee80211_mps_sta_status_update(sta
);
353 changed
|= ieee80211_mps_set_sta_local_pm(sta
,
354 NL80211_MESH_POWER_UNKNOWN
);
360 * mesh_plink_deactivate - deactivate mesh peer link
362 * @sta: mesh peer link to deactivate
364 * All mesh paths with this peer as next hop will be flushed
366 u32
mesh_plink_deactivate(struct sta_info
*sta
)
368 struct ieee80211_sub_if_data
*sdata
= sta
->sdata
;
371 spin_lock_bh(&sta
->mesh
->plink_lock
);
372 changed
= __mesh_plink_deactivate(sta
);
374 if (!sdata
->u
.mesh
.user_mpm
) {
375 sta
->mesh
->reason
= WLAN_REASON_MESH_PEER_CANCELED
;
376 mesh_plink_frame_tx(sdata
, sta
, WLAN_SP_MESH_PEERING_CLOSE
,
377 sta
->sta
.addr
, sta
->mesh
->llid
,
378 sta
->mesh
->plid
, sta
->mesh
->reason
);
380 spin_unlock_bh(&sta
->mesh
->plink_lock
);
381 if (!sdata
->u
.mesh
.user_mpm
)
382 del_timer_sync(&sta
->mesh
->plink_timer
);
383 mesh_path_flush_by_nexthop(sta
);
385 /* make sure no readers can access nexthop sta from here on */
391 static void mesh_sta_info_init(struct ieee80211_sub_if_data
*sdata
,
392 struct sta_info
*sta
,
393 struct ieee802_11_elems
*elems
, bool insert
)
395 struct ieee80211_local
*local
= sdata
->local
;
396 enum nl80211_band band
= ieee80211_get_sdata_band(sdata
);
397 struct ieee80211_supported_band
*sband
;
398 u32 rates
, basic_rates
= 0, changed
= 0;
399 enum ieee80211_sta_rx_bandwidth bw
= sta
->sta
.bandwidth
;
401 sband
= local
->hw
.wiphy
->bands
[band
];
402 rates
= ieee80211_sta_get_rates(sdata
, elems
, band
, &basic_rates
);
404 spin_lock_bh(&sta
->mesh
->plink_lock
);
405 sta
->rx_stats
.last_rx
= jiffies
;
407 /* rates and capabilities don't change during peering */
408 if (sta
->mesh
->plink_state
== NL80211_PLINK_ESTAB
&&
409 sta
->mesh
->processed_beacon
)
411 sta
->mesh
->processed_beacon
= true;
413 if (sta
->sta
.supp_rates
[band
] != rates
)
414 changed
|= IEEE80211_RC_SUPP_RATES_CHANGED
;
415 sta
->sta
.supp_rates
[band
] = rates
;
417 if (ieee80211_ht_cap_ie_to_sta_ht_cap(sdata
, sband
,
418 elems
->ht_cap_elem
, sta
))
419 changed
|= IEEE80211_RC_BW_CHANGED
;
421 ieee80211_vht_cap_ie_to_sta_vht_cap(sdata
, sband
,
422 elems
->vht_cap_elem
, sta
);
424 if (bw
!= sta
->sta
.bandwidth
)
425 changed
|= IEEE80211_RC_BW_CHANGED
;
427 /* HT peer is operating 20MHz-only */
428 if (elems
->ht_operation
&&
429 !(elems
->ht_operation
->ht_param
&
430 IEEE80211_HT_PARAM_CHAN_WIDTH_ANY
)) {
431 if (sta
->sta
.bandwidth
!= IEEE80211_STA_RX_BW_20
)
432 changed
|= IEEE80211_RC_BW_CHANGED
;
433 sta
->sta
.bandwidth
= IEEE80211_STA_RX_BW_20
;
437 rate_control_rate_init(sta
);
439 rate_control_rate_update(local
, sband
, sta
, changed
);
441 spin_unlock_bh(&sta
->mesh
->plink_lock
);
444 static int mesh_allocate_aid(struct ieee80211_sub_if_data
*sdata
)
446 struct sta_info
*sta
;
447 unsigned long *aid_map
;
450 aid_map
= kcalloc(BITS_TO_LONGS(IEEE80211_MAX_AID
+ 1),
451 sizeof(*aid_map
), GFP_KERNEL
);
455 /* reserve aid 0 for mcast indication */
456 __set_bit(0, aid_map
);
459 list_for_each_entry_rcu(sta
, &sdata
->local
->sta_list
, list
)
460 __set_bit(sta
->sta
.aid
, aid_map
);
463 aid
= find_first_zero_bit(aid_map
, IEEE80211_MAX_AID
+ 1);
466 if (aid
> IEEE80211_MAX_AID
)
472 static struct sta_info
*
473 __mesh_sta_info_alloc(struct ieee80211_sub_if_data
*sdata
, u8
*hw_addr
)
475 struct sta_info
*sta
;
478 if (sdata
->local
->num_sta
>= MESH_MAX_PLINKS
)
481 aid
= mesh_allocate_aid(sdata
);
485 sta
= sta_info_alloc(sdata
, hw_addr
, GFP_KERNEL
);
489 sta
->mesh
->plink_state
= NL80211_PLINK_LISTEN
;
493 sta_info_pre_move_state(sta
, IEEE80211_STA_AUTH
);
494 sta_info_pre_move_state(sta
, IEEE80211_STA_ASSOC
);
495 sta_info_pre_move_state(sta
, IEEE80211_STA_AUTHORIZED
);
500 static struct sta_info
*
501 mesh_sta_info_alloc(struct ieee80211_sub_if_data
*sdata
, u8
*addr
,
502 struct ieee802_11_elems
*elems
)
504 struct sta_info
*sta
= NULL
;
506 /* Userspace handles station allocation */
507 if (sdata
->u
.mesh
.user_mpm
||
508 sdata
->u
.mesh
.security
& IEEE80211_MESH_SEC_AUTHED
)
509 cfg80211_notify_new_peer_candidate(sdata
->dev
, addr
,
514 sta
= __mesh_sta_info_alloc(sdata
, addr
);
520 * mesh_sta_info_get - return mesh sta info entry for @addr.
522 * @sdata: local meshif
523 * @addr: peer's address
524 * @elems: IEs from beacon or mesh peering frame.
526 * Return existing or newly allocated sta_info under RCU read lock.
527 * (re)initialize with given IEs.
529 static struct sta_info
*
530 mesh_sta_info_get(struct ieee80211_sub_if_data
*sdata
,
531 u8
*addr
, struct ieee802_11_elems
*elems
) __acquires(RCU
)
533 struct sta_info
*sta
= NULL
;
536 sta
= sta_info_get(sdata
, addr
);
538 mesh_sta_info_init(sdata
, sta
, elems
, false);
541 /* can't run atomic */
542 sta
= mesh_sta_info_alloc(sdata
, addr
, elems
);
548 mesh_sta_info_init(sdata
, sta
, elems
, true);
550 if (sta_info_insert_rcu(sta
))
558 * mesh_neighbour_update - update or initialize new mesh neighbor.
560 * @sdata: local meshif
561 * @addr: peer's address
562 * @elems: IEs from beacon or mesh peering frame
564 * Initiates peering if appropriate.
566 void mesh_neighbour_update(struct ieee80211_sub_if_data
*sdata
,
568 struct ieee802_11_elems
*elems
)
570 struct sta_info
*sta
;
573 sta
= mesh_sta_info_get(sdata
, hw_addr
, elems
);
577 if (mesh_peer_accepts_plinks(elems
) &&
578 sta
->mesh
->plink_state
== NL80211_PLINK_LISTEN
&&
579 sdata
->u
.mesh
.accepting_plinks
&&
580 sdata
->u
.mesh
.mshcfg
.auto_open_plinks
&&
581 rssi_threshold_check(sdata
, sta
))
582 changed
= mesh_plink_open(sta
);
584 ieee80211_mps_frame_release(sta
, elems
);
587 ieee80211_mbss_info_change_notify(sdata
, changed
);
590 static void mesh_plink_timer(unsigned long data
)
592 struct sta_info
*sta
;
594 struct ieee80211_sub_if_data
*sdata
;
595 struct mesh_config
*mshcfg
;
596 enum ieee80211_self_protected_actioncode action
= 0;
599 * This STA is valid because sta_info_destroy() will
600 * del_timer_sync() this timer after having made sure
601 * it cannot be readded (by deleting the plink.)
603 sta
= (struct sta_info
*) data
;
605 if (sta
->sdata
->local
->quiescing
)
608 spin_lock_bh(&sta
->mesh
->plink_lock
);
610 /* If a timer fires just before a state transition on another CPU,
611 * we may have already extended the timeout and changed state by the
612 * time we've acquired the lock and arrived here. In that case,
613 * skip this timer and wait for the new one.
615 if (time_before(jiffies
, sta
->mesh
->plink_timer
.expires
)) {
617 "Ignoring timer for %pM in state %s (timer adjusted)",
618 sta
->sta
.addr
, mplstates
[sta
->mesh
->plink_state
]);
619 spin_unlock_bh(&sta
->mesh
->plink_lock
);
623 /* del_timer() and handler may race when entering these states */
624 if (sta
->mesh
->plink_state
== NL80211_PLINK_LISTEN
||
625 sta
->mesh
->plink_state
== NL80211_PLINK_ESTAB
) {
627 "Ignoring timer for %pM in state %s (timer deleted)",
628 sta
->sta
.addr
, mplstates
[sta
->mesh
->plink_state
]);
629 spin_unlock_bh(&sta
->mesh
->plink_lock
);
634 "Mesh plink timer for %pM fired on state %s\n",
635 sta
->sta
.addr
, mplstates
[sta
->mesh
->plink_state
]);
637 mshcfg
= &sdata
->u
.mesh
.mshcfg
;
639 switch (sta
->mesh
->plink_state
) {
640 case NL80211_PLINK_OPN_RCVD
:
641 case NL80211_PLINK_OPN_SNT
:
643 if (sta
->mesh
->plink_retries
< mshcfg
->dot11MeshMaxRetries
) {
646 "Mesh plink for %pM (retry, timeout): %d %d\n",
647 sta
->sta
.addr
, sta
->mesh
->plink_retries
,
648 sta
->mesh
->plink_timeout
);
649 get_random_bytes(&rand
, sizeof(u32
));
650 sta
->mesh
->plink_timeout
= sta
->mesh
->plink_timeout
+
651 rand
% sta
->mesh
->plink_timeout
;
652 ++sta
->mesh
->plink_retries
;
653 mod_plink_timer(sta
, sta
->mesh
->plink_timeout
);
654 action
= WLAN_SP_MESH_PEERING_OPEN
;
657 reason
= WLAN_REASON_MESH_MAX_RETRIES
;
658 /* fall through on else */
659 case NL80211_PLINK_CNF_RCVD
:
662 reason
= WLAN_REASON_MESH_CONFIRM_TIMEOUT
;
663 sta
->mesh
->plink_state
= NL80211_PLINK_HOLDING
;
664 mod_plink_timer(sta
, mshcfg
->dot11MeshHoldingTimeout
);
665 action
= WLAN_SP_MESH_PEERING_CLOSE
;
667 case NL80211_PLINK_HOLDING
:
669 del_timer(&sta
->mesh
->plink_timer
);
670 mesh_plink_fsm_restart(sta
);
675 spin_unlock_bh(&sta
->mesh
->plink_lock
);
677 mesh_plink_frame_tx(sdata
, sta
, action
, sta
->sta
.addr
,
678 sta
->mesh
->llid
, sta
->mesh
->plid
, reason
);
681 static inline void mesh_plink_timer_set(struct sta_info
*sta
, u32 timeout
)
683 sta
->mesh
->plink_timer
.expires
= jiffies
+ msecs_to_jiffies(timeout
);
684 sta
->mesh
->plink_timer
.data
= (unsigned long) sta
;
685 sta
->mesh
->plink_timer
.function
= mesh_plink_timer
;
686 sta
->mesh
->plink_timeout
= timeout
;
687 add_timer(&sta
->mesh
->plink_timer
);
690 static bool llid_in_use(struct ieee80211_sub_if_data
*sdata
,
693 struct ieee80211_local
*local
= sdata
->local
;
695 struct sta_info
*sta
;
698 list_for_each_entry_rcu(sta
, &local
->sta_list
, list
) {
699 if (sdata
!= sta
->sdata
)
702 if (!memcmp(&sta
->mesh
->llid
, &llid
, sizeof(llid
))) {
712 static u16
mesh_get_new_llid(struct ieee80211_sub_if_data
*sdata
)
717 get_random_bytes(&llid
, sizeof(llid
));
718 } while (llid_in_use(sdata
, llid
));
723 u32
mesh_plink_open(struct sta_info
*sta
)
725 struct ieee80211_sub_if_data
*sdata
= sta
->sdata
;
728 if (!test_sta_flag(sta
, WLAN_STA_AUTH
))
731 spin_lock_bh(&sta
->mesh
->plink_lock
);
732 sta
->mesh
->llid
= mesh_get_new_llid(sdata
);
733 if (sta
->mesh
->plink_state
!= NL80211_PLINK_LISTEN
&&
734 sta
->mesh
->plink_state
!= NL80211_PLINK_BLOCKED
) {
735 spin_unlock_bh(&sta
->mesh
->plink_lock
);
738 sta
->mesh
->plink_state
= NL80211_PLINK_OPN_SNT
;
739 mesh_plink_timer_set(sta
, sdata
->u
.mesh
.mshcfg
.dot11MeshRetryTimeout
);
740 spin_unlock_bh(&sta
->mesh
->plink_lock
);
742 "Mesh plink: starting establishment with %pM\n",
745 /* set the non-peer mode to active during peering */
746 changed
= ieee80211_mps_local_status_update(sdata
);
748 mesh_plink_frame_tx(sdata
, sta
, WLAN_SP_MESH_PEERING_OPEN
,
749 sta
->sta
.addr
, sta
->mesh
->llid
, 0, 0);
753 u32
mesh_plink_block(struct sta_info
*sta
)
757 spin_lock_bh(&sta
->mesh
->plink_lock
);
758 changed
= __mesh_plink_deactivate(sta
);
759 sta
->mesh
->plink_state
= NL80211_PLINK_BLOCKED
;
760 spin_unlock_bh(&sta
->mesh
->plink_lock
);
761 mesh_path_flush_by_nexthop(sta
);
766 static void mesh_plink_close(struct ieee80211_sub_if_data
*sdata
,
767 struct sta_info
*sta
,
768 enum plink_event event
)
770 struct mesh_config
*mshcfg
= &sdata
->u
.mesh
.mshcfg
;
771 u16 reason
= (event
== CLS_ACPT
) ?
772 WLAN_REASON_MESH_CLOSE
: WLAN_REASON_MESH_CONFIG
;
774 sta
->mesh
->reason
= reason
;
775 sta
->mesh
->plink_state
= NL80211_PLINK_HOLDING
;
776 mod_plink_timer(sta
, mshcfg
->dot11MeshHoldingTimeout
);
779 static u32
mesh_plink_establish(struct ieee80211_sub_if_data
*sdata
,
780 struct sta_info
*sta
)
782 struct mesh_config
*mshcfg
= &sdata
->u
.mesh
.mshcfg
;
785 del_timer(&sta
->mesh
->plink_timer
);
786 sta
->mesh
->plink_state
= NL80211_PLINK_ESTAB
;
787 changed
|= mesh_plink_inc_estab_count(sdata
);
788 changed
|= mesh_set_ht_prot_mode(sdata
);
789 changed
|= mesh_set_short_slot_time(sdata
);
790 mpl_dbg(sdata
, "Mesh plink with %pM ESTABLISHED\n", sta
->sta
.addr
);
791 ieee80211_mps_sta_status_update(sta
);
792 changed
|= ieee80211_mps_set_sta_local_pm(sta
, mshcfg
->power_mode
);
797 * mesh_plink_fsm - step @sta MPM based on @event
800 * @sta: mesh neighbor
801 * @event: peering event
803 * Return: changed MBSS flags
805 static u32
mesh_plink_fsm(struct ieee80211_sub_if_data
*sdata
,
806 struct sta_info
*sta
, enum plink_event event
)
808 struct mesh_config
*mshcfg
= &sdata
->u
.mesh
.mshcfg
;
809 enum ieee80211_self_protected_actioncode action
= 0;
813 mpl_dbg(sdata
, "peer %pM in state %s got event %s\n", sta
->sta
.addr
,
814 mplstates
[sta
->mesh
->plink_state
], mplevents
[event
]);
816 spin_lock_bh(&sta
->mesh
->plink_lock
);
817 switch (sta
->mesh
->plink_state
) {
818 case NL80211_PLINK_LISTEN
:
821 mesh_plink_fsm_restart(sta
);
824 sta
->mesh
->plink_state
= NL80211_PLINK_OPN_RCVD
;
825 sta
->mesh
->llid
= mesh_get_new_llid(sdata
);
826 mesh_plink_timer_set(sta
,
827 mshcfg
->dot11MeshRetryTimeout
);
829 /* set the non-peer mode to active during peering */
830 changed
|= ieee80211_mps_local_status_update(sdata
);
831 action
= WLAN_SP_MESH_PEERING_OPEN
;
837 case NL80211_PLINK_OPN_SNT
:
842 mesh_plink_close(sdata
, sta
, event
);
843 action
= WLAN_SP_MESH_PEERING_CLOSE
;
846 /* retry timer is left untouched */
847 sta
->mesh
->plink_state
= NL80211_PLINK_OPN_RCVD
;
848 action
= WLAN_SP_MESH_PEERING_CONFIRM
;
851 sta
->mesh
->plink_state
= NL80211_PLINK_CNF_RCVD
;
852 mod_plink_timer(sta
, mshcfg
->dot11MeshConfirmTimeout
);
858 case NL80211_PLINK_OPN_RCVD
:
863 mesh_plink_close(sdata
, sta
, event
);
864 action
= WLAN_SP_MESH_PEERING_CLOSE
;
867 action
= WLAN_SP_MESH_PEERING_CONFIRM
;
870 changed
|= mesh_plink_establish(sdata
, sta
);
876 case NL80211_PLINK_CNF_RCVD
:
881 mesh_plink_close(sdata
, sta
, event
);
882 action
= WLAN_SP_MESH_PEERING_CLOSE
;
885 changed
|= mesh_plink_establish(sdata
, sta
);
886 action
= WLAN_SP_MESH_PEERING_CONFIRM
;
892 case NL80211_PLINK_ESTAB
:
895 changed
|= __mesh_plink_deactivate(sta
);
896 changed
|= mesh_set_ht_prot_mode(sdata
);
897 changed
|= mesh_set_short_slot_time(sdata
);
898 mesh_plink_close(sdata
, sta
, event
);
899 action
= WLAN_SP_MESH_PEERING_CLOSE
;
903 action
= WLAN_SP_MESH_PEERING_CONFIRM
;
909 case NL80211_PLINK_HOLDING
:
912 del_timer(&sta
->mesh
->plink_timer
);
913 mesh_plink_fsm_restart(sta
);
919 action
= WLAN_SP_MESH_PEERING_CLOSE
;
926 /* should not get here, PLINK_BLOCKED is dealt with at the
927 * beginning of the function
931 spin_unlock_bh(&sta
->mesh
->plink_lock
);
933 mesh_path_flush_by_nexthop(sta
);
935 mesh_plink_frame_tx(sdata
, sta
, action
, sta
->sta
.addr
,
936 sta
->mesh
->llid
, sta
->mesh
->plid
,
939 /* also send confirm in open case */
940 if (action
== WLAN_SP_MESH_PEERING_OPEN
) {
941 mesh_plink_frame_tx(sdata
, sta
,
942 WLAN_SP_MESH_PEERING_CONFIRM
,
943 sta
->sta
.addr
, sta
->mesh
->llid
,
952 * mesh_plink_get_event - get correct MPM event
955 * @sta: peer, leave NULL if processing a frame from a new suitable peer
956 * @elems: peering management IEs
958 * @llid: peer's peer link ID
959 * @plid: peer's local link ID
961 * Return: new peering event for @sta, but PLINK_UNDEFINED should be treated as
964 static enum plink_event
965 mesh_plink_get_event(struct ieee80211_sub_if_data
*sdata
,
966 struct sta_info
*sta
,
967 struct ieee802_11_elems
*elems
,
968 enum ieee80211_self_protected_actioncode ftype
,
971 enum plink_event event
= PLINK_UNDEFINED
;
972 u8 ie_len
= elems
->peering_len
;
975 matches_local
= (ftype
== WLAN_SP_MESH_PEERING_CLOSE
||
976 mesh_matches_local(sdata
, elems
));
978 /* deny open request from non-matching peer */
979 if (!matches_local
&& !sta
) {
985 if (ftype
!= WLAN_SP_MESH_PEERING_OPEN
) {
986 mpl_dbg(sdata
, "Mesh plink: cls or cnf from unknown peer\n");
989 /* ftype == WLAN_SP_MESH_PEERING_OPEN */
990 if (!mesh_plink_free_count(sdata
)) {
991 mpl_dbg(sdata
, "Mesh plink error: no more free plinks\n");
995 /* new matching peer */
999 if (!test_sta_flag(sta
, WLAN_STA_AUTH
)) {
1000 mpl_dbg(sdata
, "Mesh plink: Action frame from non-authed peer\n");
1003 if (sta
->mesh
->plink_state
== NL80211_PLINK_BLOCKED
)
1008 case WLAN_SP_MESH_PEERING_OPEN
:
1011 if (!mesh_plink_free_count(sdata
) ||
1012 (sta
->mesh
->plid
&& sta
->mesh
->plid
!= plid
))
1017 case WLAN_SP_MESH_PEERING_CONFIRM
:
1020 if (!mesh_plink_free_count(sdata
) ||
1021 sta
->mesh
->llid
!= llid
||
1022 (sta
->mesh
->plid
&& sta
->mesh
->plid
!= plid
))
1027 case WLAN_SP_MESH_PEERING_CLOSE
:
1028 if (sta
->mesh
->plink_state
== NL80211_PLINK_ESTAB
)
1029 /* Do not check for llid or plid. This does not
1030 * follow the standard but since multiple plinks
1031 * per sta are not supported, it is necessary in
1032 * order to avoid a livelock when MP A sees an
1033 * establish peer link to MP B but MP B does not
1034 * see it. This can be caused by a timeout in
1035 * B's peer link establishment or B beign
1039 else if (sta
->mesh
->plid
!= plid
)
1041 else if (ie_len
== 8 && sta
->mesh
->llid
!= llid
)
1047 mpl_dbg(sdata
, "Mesh plink: unknown frame subtype\n");
1056 mesh_process_plink_frame(struct ieee80211_sub_if_data
*sdata
,
1057 struct ieee80211_mgmt
*mgmt
,
1058 struct ieee802_11_elems
*elems
)
1061 struct sta_info
*sta
;
1062 enum plink_event event
;
1063 enum ieee80211_self_protected_actioncode ftype
;
1065 u8 ie_len
= elems
->peering_len
;
1068 if (!elems
->peering
) {
1070 "Mesh plink: missing necessary peer link ie\n");
1074 if (elems
->rsn_len
&&
1075 sdata
->u
.mesh
.security
== IEEE80211_MESH_SEC_NONE
) {
1077 "Mesh plink: can't establish link with secure peer\n");
1081 ftype
= mgmt
->u
.action
.u
.self_prot
.action_code
;
1082 if ((ftype
== WLAN_SP_MESH_PEERING_OPEN
&& ie_len
!= 4) ||
1083 (ftype
== WLAN_SP_MESH_PEERING_CONFIRM
&& ie_len
!= 6) ||
1084 (ftype
== WLAN_SP_MESH_PEERING_CLOSE
&& ie_len
!= 6
1087 "Mesh plink: incorrect plink ie length %d %d\n",
1092 if (ftype
!= WLAN_SP_MESH_PEERING_CLOSE
&&
1093 (!elems
->mesh_id
|| !elems
->mesh_config
)) {
1094 mpl_dbg(sdata
, "Mesh plink: missing necessary ie\n");
1097 /* Note the lines below are correct, the llid in the frame is the plid
1098 * from the point of view of this host.
1100 plid
= get_unaligned_le16(PLINK_GET_LLID(elems
->peering
));
1101 if (ftype
== WLAN_SP_MESH_PEERING_CONFIRM
||
1102 (ftype
== WLAN_SP_MESH_PEERING_CLOSE
&& ie_len
== 8))
1103 llid
= get_unaligned_le16(PLINK_GET_PLID(elems
->peering
));
1105 /* WARNING: Only for sta pointer, is dropped & re-acquired */
1108 sta
= sta_info_get(sdata
, mgmt
->sa
);
1110 if (ftype
== WLAN_SP_MESH_PEERING_OPEN
&&
1111 !rssi_threshold_check(sdata
, sta
)) {
1112 mpl_dbg(sdata
, "Mesh plink: %pM does not meet rssi threshold\n",
1117 /* Now we will figure out the appropriate event... */
1118 event
= mesh_plink_get_event(sdata
, sta
, elems
, ftype
, llid
, plid
);
1120 if (event
== OPN_ACPT
) {
1122 /* allocate sta entry if necessary and update info */
1123 sta
= mesh_sta_info_get(sdata
, mgmt
->sa
, elems
);
1125 mpl_dbg(sdata
, "Mesh plink: failed to init peer!\n");
1128 sta
->mesh
->plid
= plid
;
1129 } else if (!sta
&& event
== OPN_RJCT
) {
1130 mesh_plink_frame_tx(sdata
, NULL
, WLAN_SP_MESH_PEERING_CLOSE
,
1132 WLAN_REASON_MESH_CONFIG
);
1134 } else if (!sta
|| event
== PLINK_UNDEFINED
) {
1135 /* something went wrong */
1139 if (event
== CNF_ACPT
) {
1140 /* 802.11-2012 13.3.7.2 - update plid on CNF if not set */
1141 if (!sta
->mesh
->plid
)
1142 sta
->mesh
->plid
= plid
;
1144 sta
->mesh
->aid
= get_unaligned_le16(PLINK_CNF_AID(mgmt
));
1147 changed
|= mesh_plink_fsm(sdata
, sta
, event
);
1153 ieee80211_mbss_info_change_notify(sdata
, changed
);
1156 void mesh_rx_plink_frame(struct ieee80211_sub_if_data
*sdata
,
1157 struct ieee80211_mgmt
*mgmt
, size_t len
,
1158 struct ieee80211_rx_status
*rx_status
)
1160 struct ieee802_11_elems elems
;
1164 /* need action_code, aux */
1165 if (len
< IEEE80211_MIN_ACTION_SIZE
+ 3)
1168 if (sdata
->u
.mesh
.user_mpm
)
1169 /* userspace must register for these */
1172 if (is_multicast_ether_addr(mgmt
->da
)) {
1174 "Mesh plink: ignore frame from multicast address\n");
1178 baseaddr
= mgmt
->u
.action
.u
.self_prot
.variable
;
1179 baselen
= (u8
*) mgmt
->u
.action
.u
.self_prot
.variable
- (u8
*) mgmt
;
1180 if (mgmt
->u
.action
.u
.self_prot
.action_code
==
1181 WLAN_SP_MESH_PEERING_CONFIRM
) {
1188 ieee802_11_parse_elems(baseaddr
, len
- baselen
, true, &elems
);
1189 mesh_process_plink_frame(sdata
, mgmt
, &elems
);