~ [ source navigation ] ~ [ diff markup ] ~ [ identifier search ] ~

TOMOYO Linux Cross Reference
Linux/net/mac80211/ocb.c

Version: ~ [ linux-5.1-rc1 ] ~ [ linux-5.0.2 ] ~ [ linux-4.20.16 ] ~ [ linux-4.19.29 ] ~ [ linux-4.18.20 ] ~ [ linux-4.17.19 ] ~ [ linux-4.16.18 ] ~ [ linux-4.15.18 ] ~ [ linux-4.14.106 ] ~ [ linux-4.13.16 ] ~ [ linux-4.12.14 ] ~ [ linux-4.11.12 ] ~ [ linux-4.10.17 ] ~ [ linux-4.9.163 ] ~ [ linux-4.8.17 ] ~ [ linux-4.7.10 ] ~ [ linux-4.6.7 ] ~ [ linux-4.5.7 ] ~ [ linux-4.4.176 ] ~ [ linux-4.3.6 ] ~ [ linux-4.2.8 ] ~ [ linux-4.1.52 ] ~ [ linux-4.0.9 ] ~ [ linux-3.19.8 ] ~ [ linux-3.18.136 ] ~ [ linux-3.17.8 ] ~ [ linux-3.16.63 ] ~ [ linux-3.15.10 ] ~ [ linux-3.14.79 ] ~ [ linux-3.13.11 ] ~ [ linux-3.12.74 ] ~ [ linux-3.11.10 ] ~ [ linux-3.10.108 ] ~ [ linux-3.9.11 ] ~ [ linux-3.8.13 ] ~ [ linux-3.7.10 ] ~ [ linux-3.6.11 ] ~ [ linux-3.5.7 ] ~ [ linux-3.4.113 ] ~ [ linux-3.3.8 ] ~ [ linux-3.2.102 ] ~ [ linux-3.1.10 ] ~ [ linux-3.0.101 ] ~ [ linux-2.6.39.4 ] ~ [ linux-2.6.38.8 ] ~ [ linux-2.6.37.6 ] ~ [ linux-2.6.36.4 ] ~ [ linux-2.6.35.14 ] ~ [ linux-2.6.34.15 ] ~ [ linux-2.6.33.20 ] ~ [ linux-2.6.32.71 ] ~ [ linux-2.6.0 ] ~ [ linux-2.4.37.11 ] ~ [ unix-v6-master ] ~ [ ccs-tools-1.8.5 ] ~ [ policy-sample ] ~
Architecture: ~ [ i386 ] ~ [ alpha ] ~ [ m68k ] ~ [ mips ] ~ [ ppc ] ~ [ sparc ] ~ [ sparc64 ] ~

  1 /*
  2  * OCB mode implementation
  3  *
  4  * Copyright: (c) 2014 Czech Technical University in Prague
  5  *            (c) 2014 Volkswagen Group Research
  6  * Author:    Rostislav Lisovy <rostislav.lisovy@fel.cvut.cz>
  7  * Funded by: Volkswagen Group Research
  8  *
  9  * This program is free software; you can redistribute it and/or modify
 10  * it under the terms of the GNU General Public License version 2 as
 11  * published by the Free Software Foundation.
 12  */
 13 
 14 #include <linux/delay.h>
 15 #include <linux/if_ether.h>
 16 #include <linux/skbuff.h>
 17 #include <linux/if_arp.h>
 18 #include <linux/etherdevice.h>
 19 #include <linux/rtnetlink.h>
 20 #include <net/mac80211.h>
 21 #include <asm/unaligned.h>
 22 
 23 #include "ieee80211_i.h"
 24 #include "driver-ops.h"
 25 #include "rate.h"
 26 
 27 #define IEEE80211_OCB_HOUSEKEEPING_INTERVAL             (60 * HZ)
 28 #define IEEE80211_OCB_PEER_INACTIVITY_LIMIT             (240 * HZ)
 29 #define IEEE80211_OCB_MAX_STA_ENTRIES                   128
 30 
 31 /**
 32  * enum ocb_deferred_task_flags - mac80211 OCB deferred tasks
 33  * @OCB_WORK_HOUSEKEEPING: run the periodic OCB housekeeping tasks
 34  *
 35  * These flags are used in @wrkq_flags field of &struct ieee80211_if_ocb
 36  */
 37 enum ocb_deferred_task_flags {
 38         OCB_WORK_HOUSEKEEPING,
 39 };
 40 
 41 void ieee80211_ocb_rx_no_sta(struct ieee80211_sub_if_data *sdata,
 42                              const u8 *bssid, const u8 *addr,
 43                              u32 supp_rates)
 44 {
 45         struct ieee80211_if_ocb *ifocb = &sdata->u.ocb;
 46         struct ieee80211_local *local = sdata->local;
 47         struct ieee80211_chanctx_conf *chanctx_conf;
 48         struct ieee80211_supported_band *sband;
 49         enum nl80211_bss_scan_width scan_width;
 50         struct sta_info *sta;
 51         int band;
 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.chanctx_conf);
 66         if (WARN_ON_ONCE(!chanctx_conf)) {
 67                 rcu_read_unlock();
 68                 return;
 69         }
 70         band = chanctx_conf->def.chan->band;
 71         scan_width = cfg80211_chandef_to_scan_width(&chanctx_conf->def);
 72         rcu_read_unlock();
 73 
 74         sta = sta_info_alloc(sdata, addr, GFP_ATOMIC);
 75         if (!sta)
 76                 return;
 77 
 78         /* Add only mandatory rates for now */
 79         sband = local->hw.wiphy->bands[band];
 80         sta->sta.supp_rates[band] =
 81                 ieee80211_mandatory_rates(sband, scan_width);
 82 
 83         spin_lock(&ifocb->incomplete_lock);
 84         list_add(&sta->list, &ifocb->incomplete_stations);
 85         spin_unlock(&ifocb->incomplete_lock);
 86         ieee80211_queue_work(&local->hw, &sdata->work);
 87 }
 88 
 89 static struct sta_info *ieee80211_ocb_finish_sta(struct sta_info *sta)
 90         __acquires(RCU)
 91 {
 92         struct ieee80211_sub_if_data *sdata = sta->sdata;
 93         u8 addr[ETH_ALEN];
 94 
 95         memcpy(addr, sta->sta.addr, ETH_ALEN);
 96 
 97         ocb_dbg(sdata, "Adding new IBSS station %pM (dev=%s)\n",
 98                 addr, sdata->name);
 99 
100         sta_info_move_state(sta, IEEE80211_STA_AUTH);
101         sta_info_move_state(sta, IEEE80211_STA_ASSOC);
102         sta_info_move_state(sta, IEEE80211_STA_AUTHORIZED);
103 
104         rate_control_rate_init(sta);
105 
106         /* If it fails, maybe we raced another insertion? */
107         if (sta_info_insert_rcu(sta))
108                 return sta_info_get(sdata, addr);
109         return sta;
110 }
111 
112 static void ieee80211_ocb_housekeeping(struct ieee80211_sub_if_data *sdata)
113 {
114         struct ieee80211_if_ocb *ifocb = &sdata->u.ocb;
115 
116         ocb_dbg(sdata, "Running ocb housekeeping\n");
117 
118         ieee80211_sta_expire(sdata, IEEE80211_OCB_PEER_INACTIVITY_LIMIT);
119 
120         mod_timer(&ifocb->housekeeping_timer,
121                   round_jiffies(jiffies + IEEE80211_OCB_HOUSEKEEPING_INTERVAL));
122 }
123 
124 void ieee80211_ocb_work(struct ieee80211_sub_if_data *sdata)
125 {
126         struct ieee80211_if_ocb *ifocb = &sdata->u.ocb;
127         struct sta_info *sta;
128 
129         if (ifocb->joined != true)
130                 return;
131 
132         sdata_lock(sdata);
133 
134         spin_lock_bh(&ifocb->incomplete_lock);
135         while (!list_empty(&ifocb->incomplete_stations)) {
136                 sta = list_first_entry(&ifocb->incomplete_stations,
137                                        struct sta_info, list);
138                 list_del(&sta->list);
139                 spin_unlock_bh(&ifocb->incomplete_lock);
140 
141                 ieee80211_ocb_finish_sta(sta);
142                 rcu_read_unlock();
143                 spin_lock_bh(&ifocb->incomplete_lock);
144         }
145         spin_unlock_bh(&ifocb->incomplete_lock);
146 
147         if (test_and_clear_bit(OCB_WORK_HOUSEKEEPING, &ifocb->wrkq_flags))
148                 ieee80211_ocb_housekeeping(sdata);
149 
150         sdata_unlock(sdata);
151 }
152 
153 static void ieee80211_ocb_housekeeping_timer(struct timer_list *t)
154 {
155         struct ieee80211_sub_if_data *sdata =
156                 from_timer(sdata, t, u.ocb.housekeeping_timer);
157         struct ieee80211_local *local = sdata->local;
158         struct ieee80211_if_ocb *ifocb = &sdata->u.ocb;
159 
160         set_bit(OCB_WORK_HOUSEKEEPING, &ifocb->wrkq_flags);
161 
162         ieee80211_queue_work(&local->hw, &sdata->work);
163 }
164 
165 void ieee80211_ocb_setup_sdata(struct ieee80211_sub_if_data *sdata)
166 {
167         struct ieee80211_if_ocb *ifocb = &sdata->u.ocb;
168 
169         timer_setup(&ifocb->housekeeping_timer,
170                     ieee80211_ocb_housekeeping_timer, 0);
171         INIT_LIST_HEAD(&ifocb->incomplete_stations);
172         spin_lock_init(&ifocb->incomplete_lock);
173 }
174 
175 int ieee80211_ocb_join(struct ieee80211_sub_if_data *sdata,
176                        struct ocb_setup *setup)
177 {
178         struct ieee80211_local *local = sdata->local;
179         struct ieee80211_if_ocb *ifocb = &sdata->u.ocb;
180         u32 changed = BSS_CHANGED_OCB | BSS_CHANGED_BSSID;
181         int err;
182 
183         if (ifocb->joined == true)
184                 return -EINVAL;
185 
186         sdata->flags |= IEEE80211_SDATA_OPERATING_GMODE;
187         sdata->smps_mode = IEEE80211_SMPS_OFF;
188         sdata->needed_rx_chains = sdata->local->rx_chains;
189 
190         mutex_lock(&sdata->local->mtx);
191         err = ieee80211_vif_use_channel(sdata, &setup->chandef,
192                                         IEEE80211_CHANCTX_SHARED);
193         mutex_unlock(&sdata->local->mtx);
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         ieee80211_queue_work(&local->hw, &sdata->work);
203 
204         netif_carrier_on(sdata->dev);
205         return 0;
206 }
207 
208 int 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         ifocb->joined = false;
215         sta_info_flush(sdata);
216 
217         spin_lock_bh(&ifocb->incomplete_lock);
218         while (!list_empty(&ifocb->incomplete_stations)) {
219                 sta = list_first_entry(&ifocb->incomplete_stations,
220                                        struct sta_info, list);
221                 list_del(&sta->list);
222                 spin_unlock_bh(&ifocb->incomplete_lock);
223 
224                 sta_info_free(local, sta);
225                 spin_lock_bh(&ifocb->incomplete_lock);
226         }
227         spin_unlock_bh(&ifocb->incomplete_lock);
228 
229         netif_carrier_off(sdata->dev);
230         clear_bit(SDATA_STATE_OFFCHANNEL, &sdata->state);
231         ieee80211_bss_info_change_notify(sdata, BSS_CHANGED_OCB);
232 
233         mutex_lock(&sdata->local->mtx);
234         ieee80211_vif_release_channel(sdata);
235         mutex_unlock(&sdata->local->mtx);
236 
237         skb_queue_purge(&sdata->skb_queue);
238 
239         del_timer_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 }
249 

~ [ source navigation ] ~ [ diff markup ] ~ [ identifier search ] ~

kernel.org | git.kernel.org | LWN.net | Project Home | Wiki (Japanese) | Wiki (English) | SVN repository | Mail admin

Linux® is a registered trademark of Linus Torvalds in the United States and other countries.
TOMOYO® is a registered trademark of NTT DATA CORPORATION.

osdn.jp