projects/linux·blob master · refs

248 lines · 6.8 KiB

1// SPDX-License-Identifier: GPL-2.0-only
2/*
3 * OCB mode implementation
4 *
5 * Copyright: (c) 2014 Czech Technical University in Prague
6 * (c) 2014 Volkswagen Group Research
7 * Copyright (C) 2022 - 2024, 2026 Intel Corporation
8 * Author: Rostislav Lisovy <[email protected]>
9 * Funded by: Volkswagen Group Research
10 */
11
12#include <linux/delay.h>
13#include <linux/if_ether.h>
14#include <linux/skbuff.h>
15#include <linux/if_arp.h>
16#include <linux/etherdevice.h>
17#include <linux/rtnetlink.h>
18#include <net/mac80211.h>
19#include <linux/unaligned.h>
20
21#include "ieee80211_i.h"
22#include "driver-ops.h"
23#include "rate.h"
24
25#define IEEE80211_OCB_HOUSEKEEPING_INTERVAL (60 * HZ)
26#define IEEE80211_OCB_PEER_INACTIVITY_LIMIT (240 * HZ)
27#define IEEE80211_OCB_MAX_STA_ENTRIES 128
28
29/**
30 * enum ocb_deferred_task_flags - mac80211 OCB deferred tasks
31 * @OCB_WORK_HOUSEKEEPING: run the periodic OCB housekeeping tasks
32 *
33 * These flags are used in @wrkq_flags field of &struct ieee80211_if_ocb
34 */
35enum ocb_deferred_task_flags {
36 OCB_WORK_HOUSEKEEPING,
37};
38
39void ieee80211_ocb_rx_no_sta(struct ieee80211_sub_if_data *sdata,
40 const u8 *bssid, const u8 *addr,
41 u32 supp_rates)
42{
43 struct ieee80211_if_ocb *ifocb = &sdata->u.ocb;
44 struct ieee80211_local *local = sdata->local;
45 struct ieee80211_chanctx_conf *chanctx_conf;
46 struct ieee80211_supported_band *sband;
47 struct sta_info *sta;
48 int band;
49
50 if (!ifocb->joined)
51 return;
52
53 /* XXX: Consider removing the least recently used entry and
54 * allow new one to be added.
55 */
56 if (local->num_sta >= IEEE80211_OCB_MAX_STA_ENTRIES) {
57 net_info_ratelimited("%s: No room for a new OCB STA entry %pM\n",
58 sdata->name, addr);
59 return;
60 }
61
62 ocb_dbg(sdata, "Adding new OCB station %pM\n", addr);
63
64 rcu_read_lock();
65 chanctx_conf = rcu_dereference(sdata->vif.bss_conf.chanctx_conf);
66 if (WARN_ON_ONCE(!chanctx_conf)) {
67 rcu_read_unlock();
68 return;
69 }
70 band = chanctx_conf->def.chan->band;
71 rcu_read_unlock();
72
73 sta = sta_info_alloc(sdata, addr, GFP_ATOMIC);
74 if (!sta)
75 return;
76
77 /* Add only mandatory rates for now */
78 sband = local->hw.wiphy->bands[band];
79 sta->sta.deflink.supp_rates[band] = ieee80211_mandatory_rates(sband);
80
81 spin_lock(&ifocb->incomplete_lock);
82 list_add(&sta->list, &ifocb->incomplete_stations);
83 spin_unlock(&ifocb->incomplete_lock);
84 wiphy_work_queue(local->hw.wiphy, &sdata->work);
85}
86
87static struct sta_info *ieee80211_ocb_finish_sta(struct sta_info *sta)
88 __acquires(RCU)
89{
90 struct ieee80211_sub_if_data *sdata = sta->sdata;
91 u8 addr[ETH_ALEN];
92
93 memcpy(addr, sta->sta.addr, ETH_ALEN);
94
95 ieee80211_sta_init_nss_bw_capa(&sta->deflink,
96 &sdata->deflink.conf->chanreq.oper);
97
98 ocb_dbg(sdata, "Adding new IBSS station %pM (dev=%s)\n",
99 addr, sdata->name);
100
101 sta_info_move_state(sta, IEEE80211_STA_AUTH);
102 sta_info_move_state(sta, IEEE80211_STA_ASSOC);
103 sta_info_move_state(sta, IEEE80211_STA_AUTHORIZED);
104
105 rate_control_rate_init(&sta->deflink);
106
107 /* If it fails, maybe we raced another insertion? */
108 if (sta_info_insert_rcu(sta))
109 return sta_info_get(sdata, addr);
110 return sta;
111}
112
113static void ieee80211_ocb_housekeeping(struct ieee80211_sub_if_data *sdata)
114{
115 struct ieee80211_if_ocb *ifocb = &sdata->u.ocb;
116
117 ocb_dbg(sdata, "Running ocb housekeeping\n");
118
119 ieee80211_sta_expire(sdata, IEEE80211_OCB_PEER_INACTIVITY_LIMIT);
120
121 mod_timer(&ifocb->housekeeping_timer,
122 round_jiffies(jiffies + IEEE80211_OCB_HOUSEKEEPING_INTERVAL));
123}
124
125void ieee80211_ocb_work(struct ieee80211_sub_if_data *sdata)
126{
127 struct ieee80211_if_ocb *ifocb = &sdata->u.ocb;
128 struct sta_info *sta;
129
130 lockdep_assert_wiphy(sdata->local->hw.wiphy);
131
132 if (ifocb->joined != true)
133 return;
134
135 spin_lock_bh(&ifocb->incomplete_lock);
136 while (!list_empty(&ifocb->incomplete_stations)) {
137 sta = list_first_entry(&ifocb->incomplete_stations,
138 struct sta_info, list);
139 list_del(&sta->list);
140 spin_unlock_bh(&ifocb->incomplete_lock);
141
142 ieee80211_ocb_finish_sta(sta);
143 rcu_read_unlock();
144 spin_lock_bh(&ifocb->incomplete_lock);
145 }
146 spin_unlock_bh(&ifocb->incomplete_lock);
147
148 if (test_and_clear_bit(OCB_WORK_HOUSEKEEPING, &ifocb->wrkq_flags))
149 ieee80211_ocb_housekeeping(sdata);
150}
151
152static void ieee80211_ocb_housekeeping_timer(struct timer_list *t)
153{
154 struct ieee80211_sub_if_data *sdata =
155 timer_container_of(sdata, t, u.ocb.housekeeping_timer);
156 struct ieee80211_local *local = sdata->local;
157 struct ieee80211_if_ocb *ifocb = &sdata->u.ocb;
158
159 set_bit(OCB_WORK_HOUSEKEEPING, &ifocb->wrkq_flags);
160
161 wiphy_work_queue(local->hw.wiphy, &sdata->work);
162}
163
164void ieee80211_ocb_setup_sdata(struct ieee80211_sub_if_data *sdata)
165{
166 struct ieee80211_if_ocb *ifocb = &sdata->u.ocb;
167
168 timer_setup(&ifocb->housekeeping_timer,
169 ieee80211_ocb_housekeeping_timer, 0);
170 INIT_LIST_HEAD(&ifocb->incomplete_stations);
171 spin_lock_init(&ifocb->incomplete_lock);
172}
173
174int ieee80211_ocb_join(struct ieee80211_sub_if_data *sdata,
175 struct ocb_setup *setup)
176{
177 struct ieee80211_chan_req chanreq = { .oper = setup->chandef };
178 struct ieee80211_local *local = sdata->local;
179 struct ieee80211_if_ocb *ifocb = &sdata->u.ocb;
180 u64 changed = BSS_CHANGED_OCB | BSS_CHANGED_BSSID;
181 int err;
182
183 lockdep_assert_wiphy(sdata->local->hw.wiphy);
184
185 if (ifocb->joined == true)
186 return -EINVAL;
187
188 sdata->deflink.operating_11g_mode = true;
189 sdata->deflink.smps_mode = IEEE80211_SMPS_OFF;
190 sdata->deflink.needed_rx_chains = sdata->local->rx_chains;
191
192 err = ieee80211_link_use_channel(&sdata->deflink, &chanreq,
193 IEEE80211_CHANCTX_SHARED);
194 if (err)
195 return err;
196
197 ieee80211_bss_info_change_notify(sdata, changed);
198
199 ifocb->joined = true;
200
201 set_bit(OCB_WORK_HOUSEKEEPING, &ifocb->wrkq_flags);
202 wiphy_work_queue(local->hw.wiphy, &sdata->work);
203
204 netif_carrier_on(sdata->dev);
205 return 0;
206}
207
208int ieee80211_ocb_leave(struct ieee80211_sub_if_data *sdata)
209{
210 struct ieee80211_if_ocb *ifocb = &sdata->u.ocb;
211 struct ieee80211_local *local = sdata->local;
212 struct sta_info *sta;
213
214 lockdep_assert_wiphy(sdata->local->hw.wiphy);
215
216 ifocb->joined = false;
217 sta_info_flush(sdata, -1);
218
219 spin_lock_bh(&ifocb->incomplete_lock);
220 while (!list_empty(&ifocb->incomplete_stations)) {
221 sta = list_first_entry(&ifocb->incomplete_stations,
222 struct sta_info, list);
223 list_del(&sta->list);
224 spin_unlock_bh(&ifocb->incomplete_lock);
225
226 sta_info_free(local, sta);
227 spin_lock_bh(&ifocb->incomplete_lock);
228 }
229 spin_unlock_bh(&ifocb->incomplete_lock);
230
231 netif_carrier_off(sdata->dev);
232 clear_bit(SDATA_STATE_OFFCHANNEL, &sdata->state);
233 ieee80211_bss_info_change_notify(sdata, BSS_CHANGED_OCB);
234
235 ieee80211_link_release_channel(&sdata->deflink);
236
237 skb_queue_purge(&sdata->skb_queue);
238
239 timer_delete_sync(&sdata->u.ocb.housekeeping_timer);
240 /* If the timer fired while we waited for it, it will have
241 * requeued the work. Now the work will be running again
242 * but will not rearm the timer again because it checks
243 * whether we are connected to the network or not -- at this
244 * point we shouldn't be anymore.
245 */
246
247 return 0;
248}