| /* |
| * Copyright (c) 2008, 2009 open80211s Ltd. |
| * Author: Luis Carlos Cobo <luisca@cozybit.com> |
| * |
| * This program is free software; you can redistribute it and/or modify |
| * it under the terms of the GNU General Public License version 2 as |
| * published by the Free Software Foundation. |
| */ |
| #include <linux/gfp.h> |
| #include <linux/kernel.h> |
| #include <linux/random.h> |
| #include "ieee80211_i.h" |
| #include "rate.h" |
| #include "mesh.h" |
| |
| #ifdef CONFIG_MAC80211_VERBOSE_MPL_DEBUG |
| #define mpl_dbg(fmt, args...) printk(KERN_DEBUG fmt, ##args) |
| #else |
| #define mpl_dbg(fmt, args...) do { (void)(0); } while (0) |
| #endif |
| |
| #define PLINK_GET_LLID(p) (p + 2) |
| #define PLINK_GET_PLID(p) (p + 4) |
| |
| #define mod_plink_timer(s, t) (mod_timer(&s->plink_timer, \ |
| jiffies + HZ * t / 1000)) |
| |
| #define dot11MeshMaxRetries(s) (s->u.mesh.mshcfg.dot11MeshMaxRetries) |
| #define dot11MeshRetryTimeout(s) (s->u.mesh.mshcfg.dot11MeshRetryTimeout) |
| #define dot11MeshConfirmTimeout(s) (s->u.mesh.mshcfg.dot11MeshConfirmTimeout) |
| #define dot11MeshHoldingTimeout(s) (s->u.mesh.mshcfg.dot11MeshHoldingTimeout) |
| #define dot11MeshMaxPeerLinks(s) (s->u.mesh.mshcfg.dot11MeshMaxPeerLinks) |
| |
| /* We only need a valid sta if user configured a minimum rssi_threshold. */ |
| #define rssi_threshold_check(sta, sdata) \ |
| (sdata->u.mesh.mshcfg.rssi_threshold == 0 ||\ |
| (sta && (s8) -ewma_read(&sta->avg_signal) > \ |
| sdata->u.mesh.mshcfg.rssi_threshold)) |
| |
| enum plink_event { |
| PLINK_UNDEFINED, |
| OPN_ACPT, |
| OPN_RJCT, |
| OPN_IGNR, |
| CNF_ACPT, |
| CNF_RJCT, |
| CNF_IGNR, |
| CLS_ACPT, |
| CLS_IGNR |
| }; |
| |
| static int mesh_plink_frame_tx(struct ieee80211_sub_if_data *sdata, |
| enum ieee80211_self_protected_actioncode action, |
| u8 *da, __le16 llid, __le16 plid, __le16 reason); |
| |
| static inline |
| void mesh_plink_inc_estab_count(struct ieee80211_sub_if_data *sdata) |
| { |
| atomic_inc(&sdata->u.mesh.mshstats.estab_plinks); |
| mesh_accept_plinks_update(sdata); |
| } |
| |
| static inline |
| void mesh_plink_dec_estab_count(struct ieee80211_sub_if_data *sdata) |
| { |
| atomic_dec(&sdata->u.mesh.mshstats.estab_plinks); |
| mesh_accept_plinks_update(sdata); |
| } |
| |
| /** |
| * mesh_plink_fsm_restart - restart a mesh peer link finite state machine |
| * |
| * @sta: mesh peer link to restart |
| * |
| * Locking: this function must be called holding sta->lock |
| */ |
| static inline void mesh_plink_fsm_restart(struct sta_info *sta) |
| { |
| sta->plink_state = NL80211_PLINK_LISTEN; |
| sta->llid = sta->plid = sta->reason = 0; |
| sta->plink_retries = 0; |
| } |
| |
| /* |
| * NOTE: This is just an alias for sta_info_alloc(), see notes |
| * on it in the lifecycle management section! |
| */ |
| static struct sta_info *mesh_plink_alloc(struct ieee80211_sub_if_data *sdata, |
| u8 *hw_addr, u32 rates, |
| struct ieee802_11_elems *elems) |
| { |
| struct ieee80211_local *local = sdata->local; |
| struct ieee80211_supported_band *sband; |
| struct sta_info *sta; |
| |
| sband = local->hw.wiphy->bands[local->oper_channel->band]; |
| |
| if (local->num_sta >= MESH_MAX_PLINKS) |
| return NULL; |
| |
| sta = sta_info_alloc(sdata, hw_addr, GFP_KERNEL); |
| if (!sta) |
| return NULL; |
| |
| sta_info_pre_move_state(sta, IEEE80211_STA_AUTH); |
| sta_info_pre_move_state(sta, IEEE80211_STA_ASSOC); |
| sta_info_pre_move_state(sta, IEEE80211_STA_AUTHORIZED); |
| |
| set_sta_flag(sta, WLAN_STA_WME); |
| |
| sta->sta.supp_rates[local->hw.conf.channel->band] = rates; |
| if (elems->ht_cap_elem) |
| ieee80211_ht_cap_ie_to_sta_ht_cap(sdata, sband, |
| elems->ht_cap_elem, |
| &sta->sta.ht_cap); |
| rate_control_rate_init(sta); |
| |
| return sta; |
| } |
| |
| /** |
| * __mesh_plink_deactivate - deactivate mesh peer link |
| * |
| * @sta: mesh peer link to deactivate |
| * |
| * All mesh paths with this peer as next hop will be flushed |
| * |
| * Locking: the caller must hold sta->lock |
| */ |
| static bool __mesh_plink_deactivate(struct sta_info *sta) |
| { |
| struct ieee80211_sub_if_data *sdata = sta->sdata; |
| bool deactivated = false; |
| |
| if (sta->plink_state == NL80211_PLINK_ESTAB) { |
| mesh_plink_dec_estab_count(sdata); |
| deactivated = true; |
| } |
| sta->plink_state = NL80211_PLINK_BLOCKED; |
| mesh_path_flush_by_nexthop(sta); |
| |
| return deactivated; |
| } |
| |
| /** |
| * mesh_plink_deactivate - deactivate mesh peer link |
| * |
| * @sta: mesh peer link to deactivate |
| * |
| * All mesh paths with this peer as next hop will be flushed |
| */ |
| void mesh_plink_deactivate(struct sta_info *sta) |
| { |
| struct ieee80211_sub_if_data *sdata = sta->sdata; |
| bool deactivated; |
| |
| spin_lock_bh(&sta->lock); |
| deactivated = __mesh_plink_deactivate(sta); |
| sta->reason = cpu_to_le16(WLAN_REASON_MESH_PEER_CANCELED); |
| mesh_plink_frame_tx(sdata, WLAN_SP_MESH_PEERING_CLOSE, |
| sta->sta.addr, sta->llid, sta->plid, |
| sta->reason); |
| spin_unlock_bh(&sta->lock); |
| |
| if (deactivated) |
| ieee80211_bss_info_change_notify(sdata, BSS_CHANGED_BEACON); |
| } |
| |
| static int mesh_plink_frame_tx(struct ieee80211_sub_if_data *sdata, |
| enum ieee80211_self_protected_actioncode action, |
| u8 *da, __le16 llid, __le16 plid, __le16 reason) { |
| struct ieee80211_local *local = sdata->local; |
| struct sk_buff *skb; |
| struct ieee80211_mgmt *mgmt; |
| bool include_plid = false; |
| u16 peering_proto = 0; |
| u8 *pos, ie_len = 4; |
| int hdr_len = offsetof(struct ieee80211_mgmt, u.action.u.self_prot) + |
| sizeof(mgmt->u.action.u.self_prot); |
| |
| skb = dev_alloc_skb(local->tx_headroom + |
| hdr_len + |
| 2 + /* capability info */ |
| 2 + /* AID */ |
| 2 + 8 + /* supported rates */ |
| 2 + (IEEE80211_MAX_SUPP_RATES - 8) + |
| 2 + sdata->u.mesh.mesh_id_len + |
| 2 + sizeof(struct ieee80211_meshconf_ie) + |
| 2 + sizeof(struct ieee80211_ht_cap) + |
| 2 + sizeof(struct ieee80211_ht_info) + |
| 2 + 8 + /* peering IE */ |
| sdata->u.mesh.ie_len); |
| if (!skb) |
| return -1; |
| skb_reserve(skb, local->tx_headroom); |
| mgmt = (struct ieee80211_mgmt *) skb_put(skb, hdr_len); |
| memset(mgmt, 0, hdr_len); |
| mgmt->frame_control = cpu_to_le16(IEEE80211_FTYPE_MGMT | |
| IEEE80211_STYPE_ACTION); |
| memcpy(mgmt->da, da, ETH_ALEN); |
| memcpy(mgmt->sa, sdata->vif.addr, ETH_ALEN); |
| memcpy(mgmt->bssid, sdata->vif.addr, ETH_ALEN); |
| mgmt->u.action.category = WLAN_CATEGORY_SELF_PROTECTED; |
| mgmt->u.action.u.self_prot.action_code = action; |
| |
| if (action != WLAN_SP_MESH_PEERING_CLOSE) { |
| /* capability info */ |
| pos = skb_put(skb, 2); |
| memset(pos, 0, 2); |
| if (action == WLAN_SP_MESH_PEERING_CONFIRM) { |
| /* AID */ |
| pos = skb_put(skb, 2); |
| memcpy(pos + 2, &plid, 2); |
| } |
| if (ieee80211_add_srates_ie(&sdata->vif, skb) || |
| ieee80211_add_ext_srates_ie(&sdata->vif, skb) || |
| mesh_add_rsn_ie(skb, sdata) || |
| mesh_add_meshid_ie(skb, sdata) || |
| mesh_add_meshconf_ie(skb, sdata)) |
| return -1; |
| } else { /* WLAN_SP_MESH_PEERING_CLOSE */ |
| if (mesh_add_meshid_ie(skb, sdata)) |
| return -1; |
| } |
| |
| /* Add Mesh Peering Management element */ |
| switch (action) { |
| case WLAN_SP_MESH_PEERING_OPEN: |
| break; |
| case WLAN_SP_MESH_PEERING_CONFIRM: |
| ie_len += 2; |
| include_plid = true; |
| break; |
| case WLAN_SP_MESH_PEERING_CLOSE: |
| if (plid) { |
| ie_len += 2; |
| include_plid = true; |
| } |
| ie_len += 2; /* reason code */ |
| break; |
| default: |
| return -EINVAL; |
| } |
| |
| if (WARN_ON(skb_tailroom(skb) < 2 + ie_len)) |
| return -ENOMEM; |
| |
| pos = skb_put(skb, 2 + ie_len); |
| *pos++ = WLAN_EID_PEER_MGMT; |
| *pos++ = ie_len; |
| memcpy(pos, &peering_proto, 2); |
| pos += 2; |
| memcpy(pos, &llid, 2); |
| pos += 2; |
| if (include_plid) { |
| memcpy(pos, &plid, 2); |
| pos += 2; |
| } |
| if (action == WLAN_SP_MESH_PEERING_CLOSE) { |
| memcpy(pos, &reason, 2); |
| pos += 2; |
| } |
| |
| if (action != WLAN_SP_MESH_PEERING_CLOSE) { |
| if (mesh_add_ht_cap_ie(skb, sdata) || |
| mesh_add_ht_info_ie(skb, sdata)) |
| return -1; |
| } |
| |
| if (mesh_add_vendor_ies(skb, sdata)) |
| return -1; |
| |
| ieee80211_tx_skb(sdata, skb); |
| return 0; |
| } |
| |
| void mesh_neighbour_update(u8 *hw_addr, u32 rates, |
| struct ieee80211_sub_if_data *sdata, |
| struct ieee802_11_elems *elems) |
| { |
| struct ieee80211_local *local = sdata->local; |
| struct sta_info *sta; |
| |
| rcu_read_lock(); |
| |
| sta = sta_info_get(sdata, hw_addr); |
| if (!sta) { |
| rcu_read_unlock(); |
| /* Userspace handles peer allocation when security is enabled |
| * */ |
| if (sdata->u.mesh.security & IEEE80211_MESH_SEC_AUTHED) |
| cfg80211_notify_new_peer_candidate(sdata->dev, hw_addr, |
| elems->ie_start, elems->total_len, |
| GFP_KERNEL); |
| else |
| sta = mesh_plink_alloc(sdata, hw_addr, rates, elems); |
| if (!sta) |
| return; |
| if (sta_info_insert_rcu(sta)) { |
| rcu_read_unlock(); |
| return; |
| } |
| } |
| |
| sta->last_rx = jiffies; |
| sta->sta.supp_rates[local->hw.conf.channel->band] = rates; |
| if (mesh_peer_accepts_plinks(elems) && |
| sta->plink_state == NL80211_PLINK_LISTEN && |
| sdata->u.mesh.accepting_plinks && |
| sdata->u.mesh.mshcfg.auto_open_plinks && |
| rssi_threshold_check(sta, sdata)) |
| mesh_plink_open(sta); |
| |
| rcu_read_unlock(); |
| } |
| |
| static void mesh_plink_timer(unsigned long data) |
| { |
| struct sta_info *sta; |
| __le16 llid, plid, reason; |
| struct ieee80211_sub_if_data *sdata; |
| |
| /* |
| * This STA is valid because sta_info_destroy() will |
| * del_timer_sync() this timer after having made sure |
| * it cannot be readded (by deleting the plink.) |
| */ |
| sta = (struct sta_info *) data; |
| |
| if (sta->sdata->local->quiescing) { |
| sta->plink_timer_was_running = true; |
| return; |
| } |
| |
| spin_lock_bh(&sta->lock); |
| if (sta->ignore_plink_timer) { |
| sta->ignore_plink_timer = false; |
| spin_unlock_bh(&sta->lock); |
| return; |
| } |
| mpl_dbg("Mesh plink timer for %pM fired on state %d\n", |
| sta->sta.addr, sta->plink_state); |
| reason = 0; |
| llid = sta->llid; |
| plid = sta->plid; |
| sdata = sta->sdata; |
| |
| switch (sta->plink_state) { |
| case NL80211_PLINK_OPN_RCVD: |
| case NL80211_PLINK_OPN_SNT: |
| /* retry timer */ |
| if (sta->plink_retries < dot11MeshMaxRetries(sdata)) { |
| u32 rand; |
| mpl_dbg("Mesh plink for %pM (retry, timeout): %d %d\n", |
| sta->sta.addr, sta->plink_retries, |
| sta->plink_timeout); |
| get_random_bytes(&rand, sizeof(u32)); |
| sta->plink_timeout = sta->plink_timeout + |
| rand % sta->plink_timeout; |
| ++sta->plink_retries; |
| mod_plink_timer(sta, sta->plink_timeout); |
| spin_unlock_bh(&sta->lock); |
| mesh_plink_frame_tx(sdata, WLAN_SP_MESH_PEERING_OPEN, |
| sta->sta.addr, llid, 0, 0); |
| break; |
| } |
| reason = cpu_to_le16(WLAN_REASON_MESH_MAX_RETRIES); |
| /* fall through on else */ |
| case NL80211_PLINK_CNF_RCVD: |
| /* confirm timer */ |
| if (!reason) |
| reason = cpu_to_le16(WLAN_REASON_MESH_CONFIRM_TIMEOUT); |
| sta->plink_state = NL80211_PLINK_HOLDING; |
| mod_plink_timer(sta, dot11MeshHoldingTimeout(sdata)); |
| spin_unlock_bh(&sta->lock); |
| mesh_plink_frame_tx(sdata, WLAN_SP_MESH_PEERING_CLOSE, |
| sta->sta.addr, llid, plid, reason); |
| break; |
| case NL80211_PLINK_HOLDING: |
| /* holding timer */ |
| del_timer(&sta->plink_timer); |
| mesh_plink_fsm_restart(sta); |
| spin_unlock_bh(&sta->lock); |
| break; |
| default: |
| spin_unlock_bh(&sta->lock); |
| break; |
| } |
| } |
| |
| #ifdef CONFIG_PM |
| void mesh_plink_quiesce(struct sta_info *sta) |
| { |
| if (del_timer_sync(&sta->plink_timer)) |
| sta->plink_timer_was_running = true; |
| } |
| |
| void mesh_plink_restart(struct sta_info *sta) |
| { |
| if (sta->plink_timer_was_running) { |
| add_timer(&sta->plink_timer); |
| sta->plink_timer_was_running = false; |
| } |
| } |
| #endif |
| |
| static inline void mesh_plink_timer_set(struct sta_info *sta, int timeout) |
| { |
| sta->plink_timer.expires = jiffies + (HZ * timeout / 1000); |
| sta->plink_timer.data = (unsigned long) sta; |
| sta->plink_timer.function = mesh_plink_timer; |
| sta->plink_timeout = timeout; |
| add_timer(&sta->plink_timer); |
| } |
| |
| int mesh_plink_open(struct sta_info *sta) |
| { |
| __le16 llid; |
| struct ieee80211_sub_if_data *sdata = sta->sdata; |
| |
| if (!test_sta_flag(sta, WLAN_STA_AUTH)) |
| return -EPERM; |
| |
| spin_lock_bh(&sta->lock); |
| get_random_bytes(&llid, 2); |
| sta->llid = llid; |
| if (sta->plink_state != NL80211_PLINK_LISTEN) { |
| spin_unlock_bh(&sta->lock); |
| return -EBUSY; |
| } |
| sta->plink_state = NL80211_PLINK_OPN_SNT; |
| mesh_plink_timer_set(sta, dot11MeshRetryTimeout(sdata)); |
| spin_unlock_bh(&sta->lock); |
| mpl_dbg("Mesh plink: starting establishment with %pM\n", |
| sta->sta.addr); |
| |
| return mesh_plink_frame_tx(sdata, WLAN_SP_MESH_PEERING_OPEN, |
| sta->sta.addr, llid, 0, 0); |
| } |
| |
| void mesh_plink_block(struct sta_info *sta) |
| { |
| struct ieee80211_sub_if_data *sdata = sta->sdata; |
| bool deactivated; |
| |
| spin_lock_bh(&sta->lock); |
| deactivated = __mesh_plink_deactivate(sta); |
| sta->plink_state = NL80211_PLINK_BLOCKED; |
| spin_unlock_bh(&sta->lock); |
| |
| if (deactivated) |
| ieee80211_bss_info_change_notify(sdata, BSS_CHANGED_BEACON); |
| } |
| |
| |
| void mesh_rx_plink_frame(struct ieee80211_sub_if_data *sdata, struct ieee80211_mgmt *mgmt, |
| size_t len, struct ieee80211_rx_status *rx_status) |
| { |
| struct ieee80211_local *local = sdata->local; |
| struct ieee802_11_elems elems; |
| struct sta_info *sta; |
| enum plink_event event; |
| enum ieee80211_self_protected_actioncode ftype; |
| size_t baselen; |
| bool deactivated, matches_local = true; |
| u8 ie_len; |
| u8 *baseaddr; |
| __le16 plid, llid, reason; |
| #ifdef CONFIG_MAC80211_VERBOSE_MPL_DEBUG |
| static const char *mplstates[] = { |
| [NL80211_PLINK_LISTEN] = "LISTEN", |
| [NL80211_PLINK_OPN_SNT] = "OPN-SNT", |
| [NL80211_PLINK_OPN_RCVD] = "OPN-RCVD", |
| [NL80211_PLINK_CNF_RCVD] = "CNF_RCVD", |
| [NL80211_PLINK_ESTAB] = "ESTAB", |
| [NL80211_PLINK_HOLDING] = "HOLDING", |
| [NL80211_PLINK_BLOCKED] = "BLOCKED" |
| }; |
| #endif |
| |
| /* need action_code, aux */ |
| if (len < IEEE80211_MIN_ACTION_SIZE + 3) |
| return; |
| |
| if (is_multicast_ether_addr(mgmt->da)) { |
| mpl_dbg("Mesh plink: ignore frame from multicast address"); |
| return; |
| } |
| |
| baseaddr = mgmt->u.action.u.self_prot.variable; |
| baselen = (u8 *) mgmt->u.action.u.self_prot.variable - (u8 *) mgmt; |
| if (mgmt->u.action.u.self_prot.action_code == |
| WLAN_SP_MESH_PEERING_CONFIRM) { |
| baseaddr += 4; |
| baselen += 4; |
| } |
| ieee802_11_parse_elems(baseaddr, len - baselen, &elems); |
| if (!elems.peering) { |
| mpl_dbg("Mesh plink: missing necessary peer link ie\n"); |
| return; |
| } |
| if (elems.rsn_len && |
| sdata->u.mesh.security == IEEE80211_MESH_SEC_NONE) { |
| mpl_dbg("Mesh plink: can't establish link with secure peer\n"); |
| return; |
| } |
| |
| ftype = mgmt->u.action.u.self_prot.action_code; |
| ie_len = elems.peering_len; |
| if ((ftype == WLAN_SP_MESH_PEERING_OPEN && ie_len != 4) || |
| (ftype == WLAN_SP_MESH_PEERING_CONFIRM && ie_len != 6) || |
| (ftype == WLAN_SP_MESH_PEERING_CLOSE && ie_len != 6 |
| && ie_len != 8)) { |
| mpl_dbg("Mesh plink: incorrect plink ie length %d %d\n", |
| ftype, ie_len); |
| return; |
| } |
| |
| if (ftype != WLAN_SP_MESH_PEERING_CLOSE && |
| (!elems.mesh_id || !elems.mesh_config)) { |
| mpl_dbg("Mesh plink: missing necessary ie\n"); |
| return; |
| } |
| /* Note the lines below are correct, the llid in the frame is the plid |
| * from the point of view of this host. |
| */ |
| memcpy(&plid, PLINK_GET_LLID(elems.peering), 2); |
| if (ftype == WLAN_SP_MESH_PEERING_CONFIRM || |
| (ftype == WLAN_SP_MESH_PEERING_CLOSE && ie_len == 8)) |
| memcpy(&llid, PLINK_GET_PLID(elems.peering), 2); |
| |
| rcu_read_lock(); |
| |
| sta = sta_info_get(sdata, mgmt->sa); |
| if (!sta && ftype != WLAN_SP_MESH_PEERING_OPEN) { |
| mpl_dbg("Mesh plink: cls or cnf from unknown peer\n"); |
| rcu_read_unlock(); |
| return; |
| } |
| |
| if (ftype == WLAN_SP_MESH_PEERING_OPEN && |
| !rssi_threshold_check(sta, sdata)) { |
| mpl_dbg("Mesh plink: %pM does not meet rssi threshold\n", |
| mgmt->sa); |
| rcu_read_unlock(); |
| return; |
| } |
| |
| if (sta && !test_sta_flag(sta, WLAN_STA_AUTH)) { |
| mpl_dbg("Mesh plink: Action frame from non-authed peer\n"); |
| rcu_read_unlock(); |
| return; |
| } |
| |
| if (sta && sta->plink_state == NL80211_PLINK_BLOCKED) { |
| rcu_read_unlock(); |
| return; |
| } |
| |
| /* Now we will figure out the appropriate event... */ |
| event = PLINK_UNDEFINED; |
| if (ftype != WLAN_SP_MESH_PEERING_CLOSE && |
| (!mesh_matches_local(&elems, sdata))) { |
| matches_local = false; |
| switch (ftype) { |
| case WLAN_SP_MESH_PEERING_OPEN: |
| event = OPN_RJCT; |
| break; |
| case WLAN_SP_MESH_PEERING_CONFIRM: |
| event = CNF_RJCT; |
| break; |
| default: |
| break; |
| } |
| } |
| |
| if (!sta && !matches_local) { |
| rcu_read_unlock(); |
| reason = cpu_to_le16(WLAN_REASON_MESH_CONFIG); |
| llid = 0; |
| mesh_plink_frame_tx(sdata, WLAN_SP_MESH_PEERING_CLOSE, |
| mgmt->sa, llid, plid, reason); |
| return; |
| } else if (!sta) { |
| /* ftype == WLAN_SP_MESH_PEERING_OPEN */ |
| u32 rates; |
| |
| rcu_read_unlock(); |
| |
| if (!mesh_plink_free_count(sdata)) { |
| mpl_dbg("Mesh plink error: no more free plinks\n"); |
| return; |
| } |
| |
| rates = ieee80211_sta_get_rates(local, &elems, rx_status->band); |
| sta = mesh_plink_alloc(sdata, mgmt->sa, rates, &elems); |
| if (!sta) { |
| mpl_dbg("Mesh plink error: plink table full\n"); |
| return; |
| } |
| if (sta_info_insert_rcu(sta)) { |
| rcu_read_unlock(); |
| return; |
| } |
| event = OPN_ACPT; |
| spin_lock_bh(&sta->lock); |
| } else if (matches_local) { |
| spin_lock_bh(&sta->lock); |
| switch (ftype) { |
| case WLAN_SP_MESH_PEERING_OPEN: |
| if (!mesh_plink_free_count(sdata) || |
| (sta->plid && sta->plid != plid)) |
| event = OPN_IGNR; |
| else |
| event = OPN_ACPT; |
| break; |
| case WLAN_SP_MESH_PEERING_CONFIRM: |
| if (!mesh_plink_free_count(sdata) || |
| (sta->llid != llid || sta->plid != plid)) |
| event = CNF_IGNR; |
| else |
| event = CNF_ACPT; |
| break; |
| case WLAN_SP_MESH_PEERING_CLOSE: |
| if (sta->plink_state == NL80211_PLINK_ESTAB) |
| /* Do not check for llid or plid. This does not |
| * follow the standard but since multiple plinks |
| * per sta are not supported, it is necessary in |
| * order to avoid a livelock when MP A sees an |
| * establish peer link to MP B but MP B does not |
| * see it. This can be caused by a timeout in |
| * B's peer link establishment or B beign |
| * restarted. |
| */ |
| event = CLS_ACPT; |
| else if (sta->plid != plid) |
| event = CLS_IGNR; |
| else if (ie_len == 7 && sta->llid != llid) |
| event = CLS_IGNR; |
| else |
| event = CLS_ACPT; |
| break; |
| default: |
| mpl_dbg("Mesh plink: unknown frame subtype\n"); |
| spin_unlock_bh(&sta->lock); |
| rcu_read_unlock(); |
| return; |
| } |
| } else { |
| spin_lock_bh(&sta->lock); |
| } |
| |
| mpl_dbg("Mesh plink (peer, state, llid, plid, event): %pM %s %d %d %d\n", |
| mgmt->sa, mplstates[sta->plink_state], |
| le16_to_cpu(sta->llid), le16_to_cpu(sta->plid), |
| event); |
| reason = 0; |
| switch (sta->plink_state) { |
| /* spin_unlock as soon as state is updated at each case */ |
| case NL80211_PLINK_LISTEN: |
| switch (event) { |
| case CLS_ACPT: |
| mesh_plink_fsm_restart(sta); |
| spin_unlock_bh(&sta->lock); |
| break; |
| case OPN_ACPT: |
| sta->plink_state = NL80211_PLINK_OPN_RCVD; |
| sta->plid = plid; |
| get_random_bytes(&llid, 2); |
| sta->llid = llid; |
| mesh_plink_timer_set(sta, dot11MeshRetryTimeout(sdata)); |
| spin_unlock_bh(&sta->lock); |
| mesh_plink_frame_tx(sdata, |
| WLAN_SP_MESH_PEERING_OPEN, |
| sta->sta.addr, llid, 0, 0); |
| mesh_plink_frame_tx(sdata, |
| WLAN_SP_MESH_PEERING_CONFIRM, |
| sta->sta.addr, llid, plid, 0); |
| break; |
| default: |
| spin_unlock_bh(&sta->lock); |
| break; |
| } |
| break; |
| |
| case NL80211_PLINK_OPN_SNT: |
| switch (event) { |
| case OPN_RJCT: |
| case CNF_RJCT: |
| reason = cpu_to_le16(WLAN_REASON_MESH_CONFIG); |
| case CLS_ACPT: |
| if (!reason) |
| reason = cpu_to_le16(WLAN_REASON_MESH_CLOSE); |
| sta->reason = reason; |
| sta->plink_state = NL80211_PLINK_HOLDING; |
| if (!mod_plink_timer(sta, |
| dot11MeshHoldingTimeout(sdata))) |
| sta->ignore_plink_timer = true; |
| |
| llid = sta->llid; |
| spin_unlock_bh(&sta->lock); |
| mesh_plink_frame_tx(sdata, |
| WLAN_SP_MESH_PEERING_CLOSE, |
| sta->sta.addr, llid, plid, reason); |
| break; |
| case OPN_ACPT: |
| /* retry timer is left untouched */ |
| sta->plink_state = NL80211_PLINK_OPN_RCVD; |
| sta->plid = plid; |
| llid = sta->llid; |
| spin_unlock_bh(&sta->lock); |
| mesh_plink_frame_tx(sdata, |
| WLAN_SP_MESH_PEERING_CONFIRM, |
| sta->sta.addr, llid, plid, 0); |
| break; |
| case CNF_ACPT: |
| sta->plink_state = NL80211_PLINK_CNF_RCVD; |
| if (!mod_plink_timer(sta, |
| dot11MeshConfirmTimeout(sdata))) |
| sta->ignore_plink_timer = true; |
| |
| spin_unlock_bh(&sta->lock); |
| break; |
| default: |
| spin_unlock_bh(&sta->lock); |
| break; |
| } |
| break; |
| |
| case NL80211_PLINK_OPN_RCVD: |
| switch (event) { |
| case OPN_RJCT: |
| case CNF_RJCT: |
| reason = cpu_to_le16(WLAN_REASON_MESH_CONFIG); |
| case CLS_ACPT: |
| if (!reason) |
| reason = cpu_to_le16(WLAN_REASON_MESH_CLOSE); |
| sta->reason = reason; |
| sta->plink_state = NL80211_PLINK_HOLDING; |
| if (!mod_plink_timer(sta, |
| dot11MeshHoldingTimeout(sdata))) |
| sta->ignore_plink_timer = true; |
| |
| llid = sta->llid; |
| spin_unlock_bh(&sta->lock); |
| mesh_plink_frame_tx(sdata, WLAN_SP_MESH_PEERING_CLOSE, |
| sta->sta.addr, llid, plid, reason); |
| break; |
| case OPN_ACPT: |
| llid = sta->llid; |
| spin_unlock_bh(&sta->lock); |
| mesh_plink_frame_tx(sdata, |
| WLAN_SP_MESH_PEERING_CONFIRM, |
| sta->sta.addr, llid, plid, 0); |
| break; |
| case CNF_ACPT: |
| del_timer(&sta->plink_timer); |
| sta->plink_state = NL80211_PLINK_ESTAB; |
| spin_unlock_bh(&sta->lock); |
| mesh_plink_inc_estab_count(sdata); |
| ieee80211_bss_info_change_notify(sdata, BSS_CHANGED_BEACON); |
| mpl_dbg("Mesh plink with %pM ESTABLISHED\n", |
| sta->sta.addr); |
| break; |
| default: |
| spin_unlock_bh(&sta->lock); |
| break; |
| } |
| break; |
| |
| case NL80211_PLINK_CNF_RCVD: |
| switch (event) { |
| case OPN_RJCT: |
| case CNF_RJCT: |
| reason = cpu_to_le16(WLAN_REASON_MESH_CONFIG); |
| case CLS_ACPT: |
| if (!reason) |
| reason = cpu_to_le16(WLAN_REASON_MESH_CLOSE); |
| sta->reason = reason; |
| sta->plink_state = NL80211_PLINK_HOLDING; |
| if (!mod_plink_timer(sta, |
| dot11MeshHoldingTimeout(sdata))) |
| sta->ignore_plink_timer = true; |
| |
| llid = sta->llid; |
| spin_unlock_bh(&sta->lock); |
| mesh_plink_frame_tx(sdata, |
| WLAN_SP_MESH_PEERING_CLOSE, |
| sta->sta.addr, llid, plid, reason); |
| break; |
| case OPN_ACPT: |
| del_timer(&sta->plink_timer); |
| sta->plink_state = NL80211_PLINK_ESTAB; |
| spin_unlock_bh(&sta->lock); |
| mesh_plink_inc_estab_count(sdata); |
| ieee80211_bss_info_change_notify(sdata, BSS_CHANGED_BEACON); |
| mpl_dbg("Mesh plink with %pM ESTABLISHED\n", |
| sta->sta.addr); |
| mesh_plink_frame_tx(sdata, |
| WLAN_SP_MESH_PEERING_CONFIRM, |
| sta->sta.addr, llid, plid, 0); |
| break; |
| default: |
| spin_unlock_bh(&sta->lock); |
| break; |
| } |
| break; |
| |
| case NL80211_PLINK_ESTAB: |
| switch (event) { |
| case CLS_ACPT: |
| reason = cpu_to_le16(WLAN_REASON_MESH_CLOSE); |
| sta->reason = reason; |
| deactivated = __mesh_plink_deactivate(sta); |
| sta->plink_state = NL80211_PLINK_HOLDING; |
| llid = sta->llid; |
| mod_plink_timer(sta, dot11MeshHoldingTimeout(sdata)); |
| spin_unlock_bh(&sta->lock); |
| if (deactivated) |
| ieee80211_bss_info_change_notify(sdata, BSS_CHANGED_BEACON); |
| mesh_plink_frame_tx(sdata, WLAN_SP_MESH_PEERING_CLOSE, |
| sta->sta.addr, llid, plid, reason); |
| break; |
| case OPN_ACPT: |
| llid = sta->llid; |
| spin_unlock_bh(&sta->lock); |
| mesh_plink_frame_tx(sdata, |
| WLAN_SP_MESH_PEERING_CONFIRM, |
| sta->sta.addr, llid, plid, 0); |
| break; |
| default: |
| spin_unlock_bh(&sta->lock); |
| break; |
| } |
| break; |
| case NL80211_PLINK_HOLDING: |
| switch (event) { |
| case CLS_ACPT: |
| if (del_timer(&sta->plink_timer)) |
| sta->ignore_plink_timer = 1; |
| mesh_plink_fsm_restart(sta); |
| spin_unlock_bh(&sta->lock); |
| break; |
| case OPN_ACPT: |
| case CNF_ACPT: |
| case OPN_RJCT: |
| case CNF_RJCT: |
| llid = sta->llid; |
| reason = sta->reason; |
| spin_unlock_bh(&sta->lock); |
| mesh_plink_frame_tx(sdata, WLAN_SP_MESH_PEERING_CLOSE, |
| sta->sta.addr, llid, plid, reason); |
| break; |
| default: |
| spin_unlock_bh(&sta->lock); |
| } |
| break; |
| default: |
| /* should not get here, PLINK_BLOCKED is dealt with at the |
| * beginning of the function |
| */ |
| spin_unlock_bh(&sta->lock); |
| break; |
| } |
| |
| rcu_read_unlock(); |
| } |