1 // SPDX-License-Identifier: GPL-2.0-only
3 * OCB mode implementation
5 * Copyright: (c) 2014 Czech Technical University in Prague
6 * (c) 2014 Volkswagen Group Research
7 * Copyright (C) 2022 - 2023 Intel Corporation
8 * Author: Rostislav Lisovy <rostislav.lisovy@fel.cvut.cz>
9 * Funded by: Volkswagen Group Research
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>
21 #include "ieee80211_i.h"
22 #include "driver-ops.h"
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
30 * enum ocb_deferred_task_flags - mac80211 OCB deferred tasks
31 * @OCB_WORK_HOUSEKEEPING: run the periodic OCB housekeeping tasks
33 * These flags are used in @wrkq_flags field of &struct ieee80211_if_ocb
35 enum ocb_deferred_task_flags
{
36 OCB_WORK_HOUSEKEEPING
,
39 void ieee80211_ocb_rx_no_sta(struct ieee80211_sub_if_data
*sdata
,
40 const u8
*bssid
, const u8
*addr
,
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
;
50 /* XXX: Consider removing the least recently used entry and
51 * allow new one to be added.
53 if (local
->num_sta
>= IEEE80211_OCB_MAX_STA_ENTRIES
) {
54 net_info_ratelimited("%s: No room for a new OCB STA entry %pM\n",
59 ocb_dbg(sdata
, "Adding new OCB station %pM\n", addr
);
62 chanctx_conf
= rcu_dereference(sdata
->vif
.bss_conf
.chanctx_conf
);
63 if (WARN_ON_ONCE(!chanctx_conf
)) {
67 band
= chanctx_conf
->def
.chan
->band
;
70 sta
= sta_info_alloc(sdata
, addr
, GFP_ATOMIC
);
74 /* Add only mandatory rates for now */
75 sband
= local
->hw
.wiphy
->bands
[band
];
76 sta
->sta
.deflink
.supp_rates
[band
] = ieee80211_mandatory_rates(sband
);
78 spin_lock(&ifocb
->incomplete_lock
);
79 list_add(&sta
->list
, &ifocb
->incomplete_stations
);
80 spin_unlock(&ifocb
->incomplete_lock
);
81 wiphy_work_queue(local
->hw
.wiphy
, &sdata
->work
);
84 static struct sta_info
*ieee80211_ocb_finish_sta(struct sta_info
*sta
)
87 struct ieee80211_sub_if_data
*sdata
= sta
->sdata
;
90 memcpy(addr
, sta
->sta
.addr
, ETH_ALEN
);
92 ocb_dbg(sdata
, "Adding new IBSS station %pM (dev=%s)\n",
95 sta_info_move_state(sta
, IEEE80211_STA_AUTH
);
96 sta_info_move_state(sta
, IEEE80211_STA_ASSOC
);
97 sta_info_move_state(sta
, IEEE80211_STA_AUTHORIZED
);
99 rate_control_rate_init(sta
);
101 /* If it fails, maybe we raced another insertion? */
102 if (sta_info_insert_rcu(sta
))
103 return sta_info_get(sdata
, addr
);
107 static void ieee80211_ocb_housekeeping(struct ieee80211_sub_if_data
*sdata
)
109 struct ieee80211_if_ocb
*ifocb
= &sdata
->u
.ocb
;
111 ocb_dbg(sdata
, "Running ocb housekeeping\n");
113 ieee80211_sta_expire(sdata
, IEEE80211_OCB_PEER_INACTIVITY_LIMIT
);
115 mod_timer(&ifocb
->housekeeping_timer
,
116 round_jiffies(jiffies
+ IEEE80211_OCB_HOUSEKEEPING_INTERVAL
));
119 void ieee80211_ocb_work(struct ieee80211_sub_if_data
*sdata
)
121 struct ieee80211_if_ocb
*ifocb
= &sdata
->u
.ocb
;
122 struct sta_info
*sta
;
124 lockdep_assert_wiphy(sdata
->local
->hw
.wiphy
);
126 if (ifocb
->joined
!= true)
129 spin_lock_bh(&ifocb
->incomplete_lock
);
130 while (!list_empty(&ifocb
->incomplete_stations
)) {
131 sta
= list_first_entry(&ifocb
->incomplete_stations
,
132 struct sta_info
, list
);
133 list_del(&sta
->list
);
134 spin_unlock_bh(&ifocb
->incomplete_lock
);
136 ieee80211_ocb_finish_sta(sta
);
138 spin_lock_bh(&ifocb
->incomplete_lock
);
140 spin_unlock_bh(&ifocb
->incomplete_lock
);
142 if (test_and_clear_bit(OCB_WORK_HOUSEKEEPING
, &ifocb
->wrkq_flags
))
143 ieee80211_ocb_housekeeping(sdata
);
146 static void ieee80211_ocb_housekeeping_timer(struct timer_list
*t
)
148 struct ieee80211_sub_if_data
*sdata
=
149 from_timer(sdata
, t
, u
.ocb
.housekeeping_timer
);
150 struct ieee80211_local
*local
= sdata
->local
;
151 struct ieee80211_if_ocb
*ifocb
= &sdata
->u
.ocb
;
153 set_bit(OCB_WORK_HOUSEKEEPING
, &ifocb
->wrkq_flags
);
155 wiphy_work_queue(local
->hw
.wiphy
, &sdata
->work
);
158 void ieee80211_ocb_setup_sdata(struct ieee80211_sub_if_data
*sdata
)
160 struct ieee80211_if_ocb
*ifocb
= &sdata
->u
.ocb
;
162 timer_setup(&ifocb
->housekeeping_timer
,
163 ieee80211_ocb_housekeeping_timer
, 0);
164 INIT_LIST_HEAD(&ifocb
->incomplete_stations
);
165 spin_lock_init(&ifocb
->incomplete_lock
);
168 int ieee80211_ocb_join(struct ieee80211_sub_if_data
*sdata
,
169 struct ocb_setup
*setup
)
171 struct ieee80211_chan_req chanreq
= { .oper
= setup
->chandef
};
172 struct ieee80211_local
*local
= sdata
->local
;
173 struct ieee80211_if_ocb
*ifocb
= &sdata
->u
.ocb
;
174 u64 changed
= BSS_CHANGED_OCB
| BSS_CHANGED_BSSID
;
177 lockdep_assert_wiphy(sdata
->local
->hw
.wiphy
);
179 if (ifocb
->joined
== true)
182 sdata
->deflink
.operating_11g_mode
= true;
183 sdata
->deflink
.smps_mode
= IEEE80211_SMPS_OFF
;
184 sdata
->deflink
.needed_rx_chains
= sdata
->local
->rx_chains
;
186 err
= ieee80211_link_use_channel(&sdata
->deflink
, &chanreq
,
187 IEEE80211_CHANCTX_SHARED
);
191 ieee80211_bss_info_change_notify(sdata
, changed
);
193 ifocb
->joined
= true;
195 set_bit(OCB_WORK_HOUSEKEEPING
, &ifocb
->wrkq_flags
);
196 wiphy_work_queue(local
->hw
.wiphy
, &sdata
->work
);
198 netif_carrier_on(sdata
->dev
);
202 int ieee80211_ocb_leave(struct ieee80211_sub_if_data
*sdata
)
204 struct ieee80211_if_ocb
*ifocb
= &sdata
->u
.ocb
;
205 struct ieee80211_local
*local
= sdata
->local
;
206 struct sta_info
*sta
;
208 lockdep_assert_wiphy(sdata
->local
->hw
.wiphy
);
210 ifocb
->joined
= false;
211 sta_info_flush(sdata
, -1);
213 spin_lock_bh(&ifocb
->incomplete_lock
);
214 while (!list_empty(&ifocb
->incomplete_stations
)) {
215 sta
= list_first_entry(&ifocb
->incomplete_stations
,
216 struct sta_info
, list
);
217 list_del(&sta
->list
);
218 spin_unlock_bh(&ifocb
->incomplete_lock
);
220 sta_info_free(local
, sta
);
221 spin_lock_bh(&ifocb
->incomplete_lock
);
223 spin_unlock_bh(&ifocb
->incomplete_lock
);
225 netif_carrier_off(sdata
->dev
);
226 clear_bit(SDATA_STATE_OFFCHANNEL
, &sdata
->state
);
227 ieee80211_bss_info_change_notify(sdata
, BSS_CHANGED_OCB
);
229 ieee80211_link_release_channel(&sdata
->deflink
);
231 skb_queue_purge(&sdata
->skb_queue
);
233 del_timer_sync(&sdata
->u
.ocb
.housekeeping_timer
);
234 /* If the timer fired while we waited for it, it will have
235 * requeued the work. Now the work will be running again
236 * but will not rearm the timer again because it checks
237 * whether we are connected to the network or not -- at this
238 * point we shouldn't be anymore.