1 /*-
2 * Copyright (c) 2002-2008 Sam Leffler, Errno Consulting
3 * All rights reserved.
4 *
5 * Redistribution and use in source and binary forms, with or without
6 * modification, are permitted provided that the following conditions
7 * are met:
8 * 1. Redistributions of source code must retain the above copyright
9 * notice, this list of conditions and the following disclaimer.
10 * 2. Redistributions in binary form must reproduce the above copyright
11 * notice, this list of conditions and the following disclaimer in the
12 * documentation and/or other materials provided with the distribution.
13 *
14 * THIS SOFTWARE IS PROVIDED BY THE AUTHOR ``AS IS'' AND ANY EXPRESS OR
15 * IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES
16 * OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE DISCLAIMED.
17 * IN NO EVENT SHALL THE AUTHOR BE LIABLE FOR ANY DIRECT, INDIRECT,
18 * INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT
19 * NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE,
20 * DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY
21 * THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
22 * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF
23 * THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
24 */
25
26 #include <sys/cdefs.h>
27 /*
28 * IEEE 802.11 scanning support.
29 */
30 #include "opt_wlan.h"
31
32 #include <sys/param.h>
33 #include <sys/systm.h>
34 #include <sys/proc.h>
35 #include <sys/kernel.h>
36 #include <sys/malloc.h>
37 #include <sys/condvar.h>
38
39 #include <sys/socket.h>
40
41 #include <net/if.h>
42 #include <net/if_var.h>
43 #include <net/if_media.h>
44 #include <net/if_private.h>
45 #include <net/ethernet.h>
46
47 #include <net80211/ieee80211_var.h>
48
49 #include <net80211/ieee80211_scan_sw.h>
50
51 #include <net/bpf.h>
52
53 struct scan_state {
54 struct ieee80211_scan_state base; /* public state */
55
56 u_int ss_iflags; /* flags used internally */
57 #define ISCAN_MINDWELL 0x0001 /* min dwell time reached */
58 #define ISCAN_DISCARD 0x0002 /* discard rx'd frames */
59 #define ISCAN_INTERRUPT 0x0004 /* interrupt current scan */
60 #define ISCAN_CANCEL 0x0008 /* cancel current scan */
61 #define ISCAN_PAUSE (ISCAN_INTERRUPT | ISCAN_CANCEL)
62 #define ISCAN_ABORT 0x0010 /* end the scan immediately */
63 #define ISCAN_RUNNING 0x0020 /* scan was started */
64
65 unsigned long ss_chanmindwell; /* min dwell on curchan */
66 unsigned long ss_scanend; /* time scan must stop */
67 u_int ss_duration; /* duration for next scan */
68 struct task ss_scan_start; /* scan start */
69 struct timeout_task ss_scan_curchan; /* scan execution */
70 };
71 #define SCAN_PRIVATE(ss) ((struct scan_state *) ss)
72
73 /*
74 * Amount of time to go off-channel during a background
75 * scan. This value should be large enough to catch most
76 * ap's but short enough that we can return on-channel
77 * before our listen interval expires.
78 *
79 * XXX tunable
80 * XXX check against configured listen interval
81 */
82 #define IEEE80211_SCAN_OFFCHANNEL msecs_to_ticks(150)
83
84 static void scan_curchan(struct ieee80211_scan_state *, unsigned long);
85 static void scan_mindwell(struct ieee80211_scan_state *);
86 static void scan_signal(struct ieee80211_scan_state *, int);
87 static void scan_signal_locked(struct ieee80211_scan_state *, int);
88 static void scan_start(void *, int);
89 static void scan_curchan_task(void *, int);
90 static void scan_end(struct ieee80211_scan_state *, int);
91 static void scan_done(struct ieee80211_scan_state *, int);
92
93 MALLOC_DEFINE(M_80211_SCAN, "80211scan", "802.11 scan state");
94
95 static void
ieee80211_swscan_detach(struct ieee80211com * ic)96 ieee80211_swscan_detach(struct ieee80211com *ic)
97 {
98 struct ieee80211_scan_state *ss = ic->ic_scan;
99
100 if (ss != NULL) {
101 scan_signal(ss, ISCAN_ABORT);
102 ieee80211_draintask(ic, &SCAN_PRIVATE(ss)->ss_scan_start);
103 taskqueue_drain_timeout(ic->ic_tq,
104 &SCAN_PRIVATE(ss)->ss_scan_curchan);
105 KASSERT((ic->ic_flags & IEEE80211_F_SCAN) == 0,
106 ("scan still running"));
107
108 /*
109 * For now, do the ss_ops detach here rather
110 * than ieee80211_scan_detach().
111 *
112 * I'll figure out how to cleanly split things up
113 * at a later date.
114 */
115 if (ss->ss_ops != NULL) {
116 ss->ss_ops->scan_detach(ss);
117 ss->ss_ops = NULL;
118 }
119 ic->ic_scan = NULL;
120 IEEE80211_FREE(SCAN_PRIVATE(ss), M_80211_SCAN);
121 }
122 }
123
124 static void
ieee80211_swscan_vattach(struct ieee80211vap * vap)125 ieee80211_swscan_vattach(struct ieee80211vap *vap)
126 {
127 /* nothing to do for now */
128 /*
129 * TODO: all of the vap scan calls should be methods!
130 */
131
132 }
133
134 static void
ieee80211_swscan_vdetach(struct ieee80211vap * vap)135 ieee80211_swscan_vdetach(struct ieee80211vap *vap)
136 {
137 struct ieee80211com *ic = vap->iv_ic;
138 struct ieee80211_scan_state *ss = ic->ic_scan;
139
140 IEEE80211_LOCK_ASSERT(ic);
141
142 if (ss != NULL && ss->ss_vap == vap &&
143 (ic->ic_flags & IEEE80211_F_SCAN))
144 scan_signal_locked(ss, ISCAN_ABORT);
145 }
146
147 static void
ieee80211_swscan_set_scan_duration(struct ieee80211vap * vap,u_int duration)148 ieee80211_swscan_set_scan_duration(struct ieee80211vap *vap, u_int duration)
149 {
150 struct ieee80211com *ic = vap->iv_ic;
151 struct ieee80211_scan_state *ss = ic->ic_scan;
152
153 IEEE80211_LOCK_ASSERT(ic);
154
155 /* NB: flush frames rx'd before 1st channel change */
156 SCAN_PRIVATE(ss)->ss_iflags |= ISCAN_DISCARD;
157 SCAN_PRIVATE(ss)->ss_duration = duration;
158 }
159
160 /*
161 * Start a scan unless one is already going.
162 */
163 static int
ieee80211_swscan_start_scan_locked(const struct ieee80211_scanner * scan,struct ieee80211vap * vap,int flags,u_int duration,u_int mindwell,u_int maxdwell,u_int nssid,const struct ieee80211_scan_ssid ssids[])164 ieee80211_swscan_start_scan_locked(const struct ieee80211_scanner *scan,
165 struct ieee80211vap *vap, int flags, u_int duration,
166 u_int mindwell, u_int maxdwell,
167 u_int nssid, const struct ieee80211_scan_ssid ssids[])
168 {
169 struct ieee80211com *ic = vap->iv_ic;
170 struct ieee80211_scan_state *ss = ic->ic_scan;
171
172 IEEE80211_LOCK_ASSERT(ic);
173
174 if (ic->ic_flags & IEEE80211_F_CSAPENDING) {
175 IEEE80211_DPRINTF(vap, IEEE80211_MSG_SCAN,
176 "%s: scan inhibited by pending channel change\n", __func__);
177 } else if ((ic->ic_flags & IEEE80211_F_SCAN) == 0) {
178 IEEE80211_DPRINTF(vap, IEEE80211_MSG_SCAN,
179 "%s: %s scan, duration %u mindwell %u maxdwell %u, desired mode %s, %s%s%s%s%s%s\n"
180 , __func__
181 , flags & IEEE80211_SCAN_ACTIVE ? "active" : "passive"
182 , duration, mindwell, maxdwell
183 , ieee80211_phymode_name[vap->iv_des_mode]
184 , flags & IEEE80211_SCAN_FLUSH ? "flush" : "append"
185 , flags & IEEE80211_SCAN_NOPICK ? ", nopick" : ""
186 , flags & IEEE80211_SCAN_NOJOIN ? ", nojoin" : ""
187 , flags & IEEE80211_SCAN_NOBCAST ? ", nobcast" : ""
188 , flags & IEEE80211_SCAN_PICK1ST ? ", pick1st" : ""
189 , flags & IEEE80211_SCAN_ONCE ? ", once" : ""
190 );
191
192 ieee80211_scan_update_locked(vap, scan);
193 if (ss->ss_ops != NULL) {
194 if ((flags & IEEE80211_SCAN_NOSSID) == 0)
195 ieee80211_scan_copy_ssid(vap, ss, nssid, ssids);
196
197 ss->ss_flags = flags & IEEE80211_SCAN_PUBLIC_MASK;
198 if (ss->ss_flags & IEEE80211_SCAN_ACTIVE)
199 vap->iv_stats.is_scan_active++;
200 else
201 vap->iv_stats.is_scan_passive++;
202 if (flags & IEEE80211_SCAN_FLUSH)
203 ss->ss_ops->scan_flush(ss);
204 if (flags & IEEE80211_SCAN_BGSCAN)
205 ic->ic_flags_ext |= IEEE80211_FEXT_BGSCAN;
206
207 /* Set duration for this particular scan */
208 ieee80211_swscan_set_scan_duration(vap, duration);
209
210 ss->ss_next = 0;
211 ss->ss_mindwell = mindwell;
212 ss->ss_maxdwell = maxdwell;
213 /* NB: scan_start must be before the scan runtask */
214 ss->ss_ops->scan_start(ss, vap);
215 #ifdef IEEE80211_DEBUG
216 if (ieee80211_msg_scan(vap))
217 ieee80211_scan_dump(ss);
218 #endif /* IEEE80211_DEBUG */
219 ic->ic_flags |= IEEE80211_F_SCAN;
220
221 /* Start scan task */
222 ieee80211_runtask(ic, &SCAN_PRIVATE(ss)->ss_scan_start);
223 }
224 return 1;
225 } else {
226 IEEE80211_DPRINTF(vap, IEEE80211_MSG_SCAN,
227 "%s: %s scan already in progress\n", __func__,
228 ss->ss_flags & IEEE80211_SCAN_ACTIVE ? "active" : "passive");
229 }
230 return 0;
231 }
232
233 /*
234 * Start a scan unless one is already going.
235 *
236 * Called without the comlock held; grab the comlock as appropriate.
237 */
238 static int
ieee80211_swscan_start_scan(const struct ieee80211_scanner * scan,struct ieee80211vap * vap,int flags,u_int duration,u_int mindwell,u_int maxdwell,u_int nssid,const struct ieee80211_scan_ssid ssids[])239 ieee80211_swscan_start_scan(const struct ieee80211_scanner *scan,
240 struct ieee80211vap *vap, int flags,
241 u_int duration, u_int mindwell, u_int maxdwell,
242 u_int nssid, const struct ieee80211_scan_ssid ssids[])
243 {
244 struct ieee80211com *ic = vap->iv_ic;
245 int result;
246
247 IEEE80211_UNLOCK_ASSERT(ic);
248
249 IEEE80211_LOCK(ic);
250 result = ieee80211_swscan_start_scan_locked(scan, vap, flags, duration,
251 mindwell, maxdwell, nssid, ssids);
252 IEEE80211_UNLOCK(ic);
253
254 return result;
255 }
256
257 /*
258 * Check the scan cache for an ap/channel to use; if that
259 * fails then kick off a new scan.
260 *
261 * Called with the comlock held.
262 *
263 * XXX TODO: split out!
264 */
265 static int
ieee80211_swscan_check_scan(const struct ieee80211_scanner * scan,struct ieee80211vap * vap,int flags,u_int duration,u_int mindwell,u_int maxdwell,u_int nssid,const struct ieee80211_scan_ssid ssids[])266 ieee80211_swscan_check_scan(const struct ieee80211_scanner *scan,
267 struct ieee80211vap *vap, int flags,
268 u_int duration, u_int mindwell, u_int maxdwell,
269 u_int nssid, const struct ieee80211_scan_ssid ssids[])
270 {
271 struct ieee80211com *ic = vap->iv_ic;
272 struct ieee80211_scan_state *ss = ic->ic_scan;
273 int result;
274
275 IEEE80211_LOCK_ASSERT(ic);
276
277 if (ss->ss_ops != NULL) {
278 /* XXX verify ss_ops matches vap->iv_opmode */
279 if ((flags & IEEE80211_SCAN_NOSSID) == 0) {
280 /*
281 * Update the ssid list and mark flags so if
282 * we call start_scan it doesn't duplicate work.
283 */
284 ieee80211_scan_copy_ssid(vap, ss, nssid, ssids);
285 flags |= IEEE80211_SCAN_NOSSID;
286 }
287 if ((ic->ic_flags & IEEE80211_F_SCAN) == 0 &&
288 (flags & IEEE80211_SCAN_FLUSH) == 0 &&
289 ieee80211_time_before(ticks, ic->ic_lastscan + vap->iv_scanvalid)) {
290 /*
291 * We're not currently scanning and the cache is
292 * deemed hot enough to consult. Lock out others
293 * by marking IEEE80211_F_SCAN while we decide if
294 * something is already in the scan cache we can
295 * use. Also discard any frames that might come
296 * in while temporarily marked as scanning.
297 */
298 IEEE80211_DPRINTF(vap, IEEE80211_MSG_SCAN,
299 "cache hot; ic_lastscan=%d, scanvalid=%d, ticks=%d\n",
300 ic->ic_lastscan,
301 vap->iv_scanvalid,
302 ticks);
303 SCAN_PRIVATE(ss)->ss_iflags |= ISCAN_DISCARD;
304 ic->ic_flags |= IEEE80211_F_SCAN;
305
306 /* NB: need to use supplied flags in check */
307 ss->ss_flags = flags & IEEE80211_SCAN_PUBLIC_MASK;
308 result = ss->ss_ops->scan_end(ss, vap);
309
310 ic->ic_flags &= ~IEEE80211_F_SCAN;
311 SCAN_PRIVATE(ss)->ss_iflags &= ~ISCAN_DISCARD;
312 IEEE80211_DPRINTF(vap, IEEE80211_MSG_SCAN,
313 "%s: scan_end returned %d\n", __func__, result);
314 if (result) {
315 ieee80211_notify_scan_done(vap);
316 return 1;
317 }
318 }
319 }
320 result = ieee80211_swscan_start_scan_locked(scan, vap, flags, duration,
321 mindwell, maxdwell, nssid, ssids);
322
323 return result;
324 }
325
326 /*
327 * Restart a previous scan. If the previous scan completed
328 * then we start again using the existing channel list.
329 */
330 static int
ieee80211_swscan_bg_scan(const struct ieee80211_scanner * scan,struct ieee80211vap * vap,int flags)331 ieee80211_swscan_bg_scan(const struct ieee80211_scanner *scan,
332 struct ieee80211vap *vap, int flags)
333 {
334 struct ieee80211com *ic = vap->iv_ic;
335 struct ieee80211_scan_state *ss = ic->ic_scan;
336 bool scanning;
337
338 /* XXX assert unlocked? */
339 // IEEE80211_UNLOCK_ASSERT(ic);
340
341 IEEE80211_LOCK(ic);
342 scanning = ic->ic_flags & IEEE80211_F_SCAN;
343 if (!scanning) {
344 u_int duration;
345 /*
346 * Go off-channel for a fixed interval that is large
347 * enough to catch most ap's but short enough that
348 * we can return on-channel before our listen interval
349 * expires.
350 */
351 duration = IEEE80211_SCAN_OFFCHANNEL;
352
353 IEEE80211_DPRINTF(vap, IEEE80211_MSG_SCAN,
354 "%s: %s scan, ticks %u duration %u\n", __func__,
355 ss->ss_flags & IEEE80211_SCAN_ACTIVE ? "active" : "passive",
356 ticks, duration);
357
358 ieee80211_scan_update_locked(vap, scan);
359 if (ss->ss_ops != NULL) {
360 ss->ss_vap = vap;
361 /*
362 * A background scan does not select a new sta; it
363 * just refreshes the scan cache. Also, indicate
364 * the scan logic should follow the beacon schedule:
365 * we go off-channel and scan for a while, then
366 * return to the bss channel to receive a beacon,
367 * then go off-channel again. All during this time
368 * we notify the ap we're in power save mode. When
369 * the scan is complete we leave power save mode.
370 * If any beacon indicates there are frames pending
371 * for us then we drop out of power save mode
372 * (and background scan) automatically by way of the
373 * usual sta power save logic.
374 */
375 ss->ss_flags |= IEEE80211_SCAN_NOPICK
376 | IEEE80211_SCAN_BGSCAN
377 | flags
378 ;
379 /* if previous scan completed, restart */
380 if (ss->ss_next >= ss->ss_last) {
381 if (ss->ss_flags & IEEE80211_SCAN_ACTIVE)
382 vap->iv_stats.is_scan_active++;
383 else
384 vap->iv_stats.is_scan_passive++;
385 /*
386 * NB: beware of the scan cache being flushed;
387 * if the channel list is empty use the
388 * scan_start method to populate it.
389 */
390 ss->ss_next = 0;
391 if (ss->ss_last != 0) {
392 ieee80211_notify_scan_done(vap);
393 ss->ss_ops->scan_restart(ss, vap);
394 } else {
395 ss->ss_ops->scan_start(ss, vap);
396 #ifdef IEEE80211_DEBUG
397 if (ieee80211_msg_scan(vap))
398 ieee80211_scan_dump(ss);
399 #endif /* IEEE80211_DEBUG */
400 }
401 }
402 ieee80211_swscan_set_scan_duration(vap, duration);
403 ss->ss_maxdwell = duration;
404 ic->ic_flags |= IEEE80211_F_SCAN;
405 ic->ic_flags_ext |= IEEE80211_FEXT_BGSCAN;
406 ieee80211_runtask(ic,
407 &SCAN_PRIVATE(ss)->ss_scan_start);
408 scanning = true;
409 } else {
410 /* XXX msg+stat */
411 }
412 } else {
413 IEEE80211_DPRINTF(vap, IEEE80211_MSG_SCAN,
414 "%s: %s scan already in progress\n", __func__,
415 ss->ss_flags & IEEE80211_SCAN_ACTIVE ? "active" : "passive");
416 }
417 IEEE80211_UNLOCK(ic);
418
419 return (scanning);
420 }
421
422 /*
423 * Taskqueue work to cancel a scan.
424 *
425 * Note: for offload scan devices, we may want to call into the
426 * driver to try and cancel scanning, however it may not be cancelable.
427 */
428 static void
cancel_scan(struct ieee80211vap * vap,int any,const char * func)429 cancel_scan(struct ieee80211vap *vap, int any, const char *func)
430 {
431 struct ieee80211com *ic = vap->iv_ic;
432 struct ieee80211_scan_state *ss = ic->ic_scan;
433 struct scan_state *ss_priv = SCAN_PRIVATE(ss);
434 int signal;
435
436 IEEE80211_LOCK(ic);
437 signal = any ? ISCAN_PAUSE : ISCAN_CANCEL;
438 if ((ic->ic_flags & IEEE80211_F_SCAN) &&
439 (any || ss->ss_vap == vap) &&
440 (ss_priv->ss_iflags & signal) == 0) {
441 IEEE80211_DPRINTF(vap, IEEE80211_MSG_SCAN,
442 "%s: %s %s scan\n", func,
443 any ? "pause" : "cancel",
444 ss->ss_flags & IEEE80211_SCAN_ACTIVE ?
445 "active" : "passive");
446
447 /* clear bg scan NOPICK */
448 ss->ss_flags &= ~IEEE80211_SCAN_NOPICK;
449 /* mark request and wake up the scan task */
450 scan_signal_locked(ss, signal);
451 } else {
452 IEEE80211_DPRINTF(vap, IEEE80211_MSG_SCAN,
453 "%s: called; F_SCAN=%d, vap=%s, signal=%d\n",
454 func,
455 !! (ic->ic_flags & IEEE80211_F_SCAN),
456 (ss->ss_vap == vap ? "match" : "nomatch"),
457 !! (ss_priv->ss_iflags & signal));
458 }
459 IEEE80211_UNLOCK(ic);
460 }
461
462 /*
463 * Cancel any scan currently going on for the specified vap.
464 */
465 static void
ieee80211_swscan_cancel_scan(struct ieee80211vap * vap)466 ieee80211_swscan_cancel_scan(struct ieee80211vap *vap)
467 {
468 cancel_scan(vap, 0, __func__);
469 }
470
471 /*
472 * Cancel any scan currently going on.
473 */
474 static void
ieee80211_swscan_cancel_anyscan(struct ieee80211vap * vap)475 ieee80211_swscan_cancel_anyscan(struct ieee80211vap *vap)
476 {
477
478 /* XXX for now - just don't do this per packet. */
479 if (vap->iv_flags_ext & IEEE80211_FEXT_SCAN_OFFLOAD)
480 return;
481
482 cancel_scan(vap, 1, __func__);
483 }
484
485 /*
486 * Manually switch to the next channel in the channel list.
487 * Provided for drivers that manage scanning themselves
488 * (e.g. for firmware-based devices).
489 */
490 static void
ieee80211_swscan_scan_next(struct ieee80211vap * vap)491 ieee80211_swscan_scan_next(struct ieee80211vap *vap)
492 {
493 struct ieee80211_scan_state *ss = vap->iv_ic->ic_scan;
494
495 IEEE80211_DPRINTF(vap, IEEE80211_MSG_SCAN, "%s: called\n", __func__);
496
497 /* wake up the scan task */
498 scan_signal(ss, 0);
499 }
500
501 /*
502 * Manually stop a scan that is currently running.
503 * Provided for drivers that are not able to scan single channels
504 * (e.g. for firmware-based devices).
505 */
506 static void
ieee80211_swscan_scan_done(struct ieee80211vap * vap)507 ieee80211_swscan_scan_done(struct ieee80211vap *vap)
508 {
509 struct ieee80211com *ic = vap->iv_ic;
510 struct ieee80211_scan_state *ss = ic->ic_scan;
511
512 IEEE80211_LOCK_ASSERT(ic);
513
514 scan_signal_locked(ss, 0);
515 }
516
517 /*
518 * Probe the current channel, if allowed, while scanning.
519 * If the channel is not marked passive-only then send
520 * a probe request immediately. Otherwise mark state and
521 * listen for beacons on the channel; if we receive something
522 * then we'll transmit a probe request.
523 */
524 static void
ieee80211_swscan_probe_curchan(struct ieee80211vap * vap,bool force __unused)525 ieee80211_swscan_probe_curchan(struct ieee80211vap *vap, bool force __unused)
526 {
527 struct ieee80211com *ic = vap->iv_ic;
528 struct ieee80211_scan_state *ss = ic->ic_scan;
529 struct ifnet *ifp = vap->iv_ifp;
530 int i;
531
532 /*
533 * Full-offload scan devices don't require this.
534 */
535 if (vap->iv_flags_ext & IEEE80211_FEXT_SCAN_OFFLOAD)
536 return;
537
538 /*
539 * Send directed probe requests followed by any
540 * broadcast probe request.
541 * XXX remove dependence on ic/vap->iv_bss
542 */
543 for (i = 0; i < ss->ss_nssid; i++)
544 ieee80211_send_probereq(vap->iv_bss,
545 vap->iv_myaddr, ifp->if_broadcastaddr,
546 ifp->if_broadcastaddr,
547 ss->ss_ssid[i].ssid, ss->ss_ssid[i].len);
548 if ((ss->ss_flags & IEEE80211_SCAN_NOBCAST) == 0)
549 ieee80211_send_probereq(vap->iv_bss,
550 vap->iv_myaddr, ifp->if_broadcastaddr,
551 ifp->if_broadcastaddr,
552 "", 0);
553 }
554
555 /*
556 * Scan curchan. If this is an active scan and the channel
557 * is not marked passive then send probe request frame(s).
558 * Arrange for the channel change after maxdwell ticks.
559 */
560 static void
scan_curchan(struct ieee80211_scan_state * ss,unsigned long maxdwell)561 scan_curchan(struct ieee80211_scan_state *ss, unsigned long maxdwell)
562 {
563 struct ieee80211vap *vap = ss->ss_vap;
564 struct ieee80211com *ic = ss->ss_ic;
565
566 IEEE80211_DPRINTF(vap, IEEE80211_MSG_SCAN,
567 "%s: calling; maxdwell=%lu\n",
568 __func__,
569 maxdwell);
570 IEEE80211_LOCK(ic);
571 if (ss->ss_flags & IEEE80211_SCAN_ACTIVE)
572 ieee80211_probe_curchan(vap, false);
573 taskqueue_enqueue_timeout(ic->ic_tq,
574 &SCAN_PRIVATE(ss)->ss_scan_curchan, maxdwell);
575 IEEE80211_UNLOCK(ic);
576 }
577
578 static void
scan_signal(struct ieee80211_scan_state * ss,int iflags)579 scan_signal(struct ieee80211_scan_state *ss, int iflags)
580 {
581 struct ieee80211com *ic = ss->ss_ic;
582
583 IEEE80211_UNLOCK_ASSERT(ic);
584
585 IEEE80211_LOCK(ic);
586 scan_signal_locked(ss, iflags);
587 IEEE80211_UNLOCK(ic);
588 }
589
590 static void
scan_signal_locked(struct ieee80211_scan_state * ss,int iflags)591 scan_signal_locked(struct ieee80211_scan_state *ss, int iflags)
592 {
593 struct scan_state *ss_priv = SCAN_PRIVATE(ss);
594 struct timeout_task *scan_task = &ss_priv->ss_scan_curchan;
595 struct ieee80211com *ic = ss->ss_ic;
596
597 IEEE80211_LOCK_ASSERT(ic);
598
599 ss_priv->ss_iflags |= iflags;
600 if (ss_priv->ss_iflags & ISCAN_RUNNING) {
601 if (taskqueue_cancel_timeout(ic->ic_tq, scan_task, NULL) == 0)
602 taskqueue_enqueue_timeout(ic->ic_tq, scan_task, 0);
603 }
604 }
605
606 /*
607 * Handle mindwell requirements completed; initiate a channel
608 * change to the next channel asap.
609 */
610 static void
scan_mindwell(struct ieee80211_scan_state * ss)611 scan_mindwell(struct ieee80211_scan_state *ss)
612 {
613
614 IEEE80211_DPRINTF(ss->ss_vap, IEEE80211_MSG_SCAN, "%s: called\n",
615 __func__);
616
617 scan_signal(ss, 0);
618 }
619
620 static void
scan_start(void * arg,int pending)621 scan_start(void *arg, int pending)
622 {
623 #define ISCAN_REP (ISCAN_MINDWELL | ISCAN_DISCARD)
624 struct ieee80211_scan_state *ss = (struct ieee80211_scan_state *) arg;
625 struct scan_state *ss_priv = SCAN_PRIVATE(ss);
626 struct ieee80211vap *vap = ss->ss_vap;
627 struct ieee80211com *ic = ss->ss_ic;
628
629 IEEE80211_LOCK(ic);
630 if (vap == NULL || (ic->ic_flags & IEEE80211_F_SCAN) == 0 ||
631 (ss_priv->ss_iflags & ISCAN_ABORT)) {
632 /* Cancelled before we started */
633 scan_done(ss, 0);
634 return;
635 }
636
637 if (ss->ss_next == ss->ss_last) {
638 IEEE80211_DPRINTF(vap, IEEE80211_MSG_SCAN,
639 "%s: no channels to scan\n", __func__);
640 scan_done(ss, 1);
641 return;
642 }
643
644 /*
645 * Put the station into power save mode.
646 *
647 * This is only required if we're not a full-offload devices;
648 * those devices manage scan/traffic differently.
649 */
650 if (((vap->iv_flags_ext & IEEE80211_FEXT_SCAN_OFFLOAD) == 0) &&
651 vap->iv_opmode == IEEE80211_M_STA &&
652 vap->iv_state == IEEE80211_S_RUN) {
653 if ((vap->iv_bss->ni_flags & IEEE80211_NODE_PWR_MGT) == 0) {
654 /* Enable station power save mode */
655 vap->iv_sta_ps(vap, 1);
656 /* Wait until null data frame will be ACK'ed */
657 mtx_sleep(vap, IEEE80211_LOCK_OBJ(ic), PCATCH,
658 "sta_ps", msecs_to_ticks(10));
659 if (ss_priv->ss_iflags & ISCAN_ABORT) {
660 scan_done(ss, 0);
661 return;
662 }
663 }
664 }
665
666 ss_priv->ss_scanend = ticks + ss_priv->ss_duration;
667
668 /* XXX scan state can change! Re-validate scan state! */
669
670 IEEE80211_UNLOCK(ic);
671
672 ic->ic_scan_start(ic); /* notify driver */
673
674 scan_curchan_task(ss, 0);
675 }
676
677 static void
scan_curchan_task(void * arg,int pending __unused)678 scan_curchan_task(void *arg, int pending __unused)
679 {
680 struct ieee80211_scan_state *ss = arg;
681 struct scan_state *ss_priv = SCAN_PRIVATE(ss);
682 struct ieee80211com *ic = ss->ss_ic;
683 struct ieee80211_channel *chan;
684 unsigned long maxdwell;
685 int scandone, scanstop;
686
687 IEEE80211_LOCK(ic);
688 end:
689 /*
690 * Note: only /end/ the scan if we're CANCEL rather than
691 * CANCEL+INTERRUPT (ie, 'PAUSE').
692 *
693 * We can stop the scan if we hit cancel, but we shouldn't
694 * call scan_end(ss, 1) if we're just PAUSEing the scan.
695 */
696 scandone = (ss->ss_next >= ss->ss_last) ||
697 ((ss_priv->ss_iflags & ISCAN_PAUSE) == ISCAN_CANCEL);
698 scanstop = (ss->ss_next >= ss->ss_last) ||
699 ((ss_priv->ss_iflags & ISCAN_CANCEL) != 0);
700
701 IEEE80211_DPRINTF(ss->ss_vap, IEEE80211_MSG_SCAN,
702 "%s: loop start; scandone=%d, scanstop=%d, ss_iflags=0x%x, ss_next=%u, ss_last=%u\n",
703 __func__,
704 scandone,
705 scanstop,
706 (uint32_t) ss_priv->ss_iflags,
707 (uint32_t) ss->ss_next,
708 (uint32_t) ss->ss_last);
709
710 if (scanstop || (ss->ss_flags & IEEE80211_SCAN_GOTPICK) ||
711 (ss_priv->ss_iflags & ISCAN_ABORT) ||
712 ieee80211_time_after(ticks + ss->ss_mindwell, ss_priv->ss_scanend)) {
713 ss_priv->ss_iflags &= ~ISCAN_RUNNING;
714 scan_end(ss, scandone);
715 return;
716 } else
717 ss_priv->ss_iflags |= ISCAN_RUNNING;
718
719 chan = ss->ss_chans[ss->ss_next++];
720
721 /*
722 * Watch for truncation due to the scan end time.
723 */
724 if (ieee80211_time_after(ticks + ss->ss_maxdwell, ss_priv->ss_scanend))
725 maxdwell = ss_priv->ss_scanend - ticks;
726 else
727 maxdwell = ss->ss_maxdwell;
728
729 IEEE80211_DPRINTF(ss->ss_vap, IEEE80211_MSG_SCAN,
730 "%s: chan %3d%c -> %3d%c [%s, dwell min %lums max %lums]\n",
731 __func__,
732 ieee80211_chan2ieee(ic, ic->ic_curchan),
733 ieee80211_channel_type_char(ic->ic_curchan),
734 ieee80211_chan2ieee(ic, chan),
735 ieee80211_channel_type_char(chan),
736 (ss->ss_flags & IEEE80211_SCAN_ACTIVE) &&
737 (chan->ic_flags & IEEE80211_CHAN_PASSIVE) == 0 ?
738 "active" : "passive",
739 ticks_to_msecs(ss->ss_mindwell), ticks_to_msecs(maxdwell));
740
741 /*
742 * Potentially change channel and phy mode.
743 */
744 ic->ic_curchan = chan;
745 ic->ic_rt = ieee80211_get_ratetable(chan);
746 IEEE80211_UNLOCK(ic);
747 /*
748 * Perform the channel change and scan unlocked so the driver
749 * may sleep. Once set_channel returns the hardware has
750 * completed the channel change.
751 */
752 ic->ic_set_channel(ic);
753 ieee80211_radiotap_chan_change(ic);
754
755 /*
756 * Scan curchan. Drivers for "intelligent hardware"
757 * override ic_scan_curchan to tell the device to do
758 * the work. Otherwise we manage the work ourselves;
759 * sending a probe request (as needed), and arming the
760 * timeout to switch channels after maxdwell ticks.
761 *
762 * scan_curchan should only pause for the time required to
763 * prepare/initiate the hardware for the scan (if at all).
764 */
765 ic->ic_scan_curchan(ss, maxdwell);
766 IEEE80211_LOCK(ic);
767
768 /* XXX scan state can change! Re-validate scan state! */
769
770 ss_priv->ss_chanmindwell = ticks + ss->ss_mindwell;
771 /* clear mindwell lock and initial channel change flush */
772 ss_priv->ss_iflags &= ~ISCAN_REP;
773
774 if (ss_priv->ss_iflags & (ISCAN_CANCEL|ISCAN_ABORT)) {
775 taskqueue_cancel_timeout(ic->ic_tq, &ss_priv->ss_scan_curchan,
776 NULL);
777 goto end;
778 }
779
780 IEEE80211_DPRINTF(ss->ss_vap, IEEE80211_MSG_SCAN, "%s: waiting\n",
781 __func__);
782 IEEE80211_UNLOCK(ic);
783 }
784
785 static void
scan_end(struct ieee80211_scan_state * ss,int scandone)786 scan_end(struct ieee80211_scan_state *ss, int scandone)
787 {
788 struct scan_state *ss_priv = SCAN_PRIVATE(ss);
789 struct ieee80211vap *vap = ss->ss_vap;
790 struct ieee80211com *ic = ss->ss_ic;
791
792 IEEE80211_LOCK_ASSERT(ic);
793
794 IEEE80211_DPRINTF(vap, IEEE80211_MSG_SCAN, "%s: out\n", __func__);
795
796 if (ss_priv->ss_iflags & ISCAN_ABORT) {
797 scan_done(ss, scandone);
798 return;
799 }
800
801 IEEE80211_UNLOCK(ic);
802 ic->ic_scan_end(ic); /* notify driver */
803 IEEE80211_LOCK(ic);
804 /* XXX scan state can change! Re-validate scan state! */
805
806 /*
807 * Since a cancellation may have occurred during one of the
808 * driver calls (whilst unlocked), update scandone.
809 */
810 if ((scandone == 0) && ((ss_priv->ss_iflags & ISCAN_PAUSE) == ISCAN_CANCEL)) {
811 /* XXX printf? */
812 if_printf(vap->iv_ifp,
813 "%s: OOPS! scan cancelled during driver call (1) (ss_iflags=0x%x)!\n",
814 __func__,
815 ss_priv->ss_iflags);
816 scandone = 1;
817 }
818
819 /*
820 * Record scan complete time. Note that we also do
821 * this when canceled so any background scan will
822 * not be restarted for a while.
823 */
824 if (scandone)
825 ic->ic_lastscan = ticks;
826 /* return to the bss channel */
827 if (ic->ic_bsschan != IEEE80211_CHAN_ANYC &&
828 ic->ic_curchan != ic->ic_bsschan) {
829 ieee80211_setupcurchan(ic, ic->ic_bsschan);
830 IEEE80211_UNLOCK(ic);
831 ic->ic_set_channel(ic);
832 ieee80211_radiotap_chan_change(ic);
833 IEEE80211_LOCK(ic);
834 }
835 /* clear internal flags and any indication of a pick */
836 ss_priv->ss_iflags &= ~ISCAN_REP;
837 ss->ss_flags &= ~IEEE80211_SCAN_GOTPICK;
838
839 /*
840 * If not canceled and scan completed, do post-processing.
841 * If the callback function returns 0, then it wants to
842 * continue/restart scanning. Unfortunately we needed to
843 * notify the driver to end the scan above to avoid having
844 * rx frames alter the scan candidate list.
845 */
846 if ((ss_priv->ss_iflags & ISCAN_CANCEL) == 0 &&
847 !ss->ss_ops->scan_end(ss, vap) &&
848 (ss->ss_flags & IEEE80211_SCAN_ONCE) == 0 &&
849 ieee80211_time_before(ticks + ss->ss_mindwell, ss_priv->ss_scanend)) {
850 IEEE80211_DPRINTF(vap, IEEE80211_MSG_SCAN,
851 "%s: done, restart "
852 "[ticks %u, dwell min %lu scanend %lu]\n",
853 __func__,
854 ticks, ss->ss_mindwell, ss_priv->ss_scanend);
855 ss->ss_next = 0; /* reset to beginning */
856 if (ss->ss_flags & IEEE80211_SCAN_ACTIVE)
857 vap->iv_stats.is_scan_active++;
858 else
859 vap->iv_stats.is_scan_passive++;
860
861 ieee80211_notify_scan_done(vap);
862 ss->ss_ops->scan_restart(ss, vap); /* XXX? */
863 ieee80211_runtask(ic, &ss_priv->ss_scan_start);
864 IEEE80211_UNLOCK(ic);
865 return;
866 }
867
868 /* past here, scandone is ``true'' if not in bg mode */
869 if ((ss->ss_flags & IEEE80211_SCAN_BGSCAN) == 0)
870 scandone = 1;
871
872 IEEE80211_DPRINTF(vap, IEEE80211_MSG_SCAN,
873 "%s: %s, [ticks %u, dwell min %lu scanend %lu]\n",
874 __func__, scandone ? "done" : "stopped",
875 ticks, ss->ss_mindwell, ss_priv->ss_scanend);
876
877 /*
878 * Since a cancellation may have occurred during one of the
879 * driver calls (whilst unlocked), update scandone.
880 */
881 if (scandone == 0 && (ss_priv->ss_iflags & ISCAN_PAUSE) == ISCAN_CANCEL) {
882 /* XXX printf? */
883 if_printf(vap->iv_ifp,
884 "%s: OOPS! scan cancelled during driver call (2) (ss_iflags=0x%x)!\n",
885 __func__,
886 ss_priv->ss_iflags);
887 scandone = 1;
888 }
889
890 scan_done(ss, scandone);
891 }
892
893 static void
scan_done(struct ieee80211_scan_state * ss,int scandone)894 scan_done(struct ieee80211_scan_state *ss, int scandone)
895 {
896 struct scan_state *ss_priv = SCAN_PRIVATE(ss);
897 struct ieee80211com *ic = ss->ss_ic;
898 struct ieee80211vap *vap = ss->ss_vap;
899
900 IEEE80211_LOCK_ASSERT(ic);
901
902 /*
903 * Clear the SCAN bit first in case frames are
904 * pending on the station power save queue. If
905 * we defer this then the dispatch of the frames
906 * may generate a request to cancel scanning.
907 */
908 ic->ic_flags &= ~IEEE80211_F_SCAN;
909
910 /*
911 * Drop out of power save mode when a scan has
912 * completed. If this scan was prematurely terminated
913 * because it is a background scan then don't notify
914 * the ap; we'll either return to scanning after we
915 * receive the beacon frame or we'll drop out of power
916 * save mode because the beacon indicates we have frames
917 * waiting for us.
918 */
919 if (scandone) {
920 /*
921 * If we're not a scan offload device, come back out of
922 * station powersave. Offload devices handle this themselves.
923 */
924 if ((vap->iv_flags_ext & IEEE80211_FEXT_SCAN_OFFLOAD) == 0)
925 vap->iv_sta_ps(vap, 0);
926 if (ss->ss_next >= ss->ss_last) {
927 IEEE80211_DPRINTF(vap, IEEE80211_MSG_SCAN,
928 "%s: Dropping out of scan; ss_next=%u, ss_last=%u\n",
929 __func__,
930 (uint32_t) ss->ss_next,
931 (uint32_t) ss->ss_last);
932 ic->ic_flags_ext &= ~IEEE80211_FEXT_BGSCAN;
933 }
934
935 /* send 'scan done' event if not interrupted due to traffic. */
936 if (!(ss_priv->ss_iflags & ISCAN_INTERRUPT) ||
937 (ss->ss_next >= ss->ss_last))
938 ieee80211_notify_scan_done(vap);
939 }
940 ss_priv->ss_iflags &= ~(ISCAN_PAUSE | ISCAN_ABORT);
941 ss_priv->ss_scanend = 0;
942 ss->ss_flags &= ~(IEEE80211_SCAN_ONCE | IEEE80211_SCAN_PICK1ST);
943 IEEE80211_UNLOCK(ic);
944 #undef ISCAN_REP
945 }
946
947 /*
948 * Process a beacon or probe response frame.
949 */
950 static void
ieee80211_swscan_add_scan(struct ieee80211vap * vap,struct ieee80211_channel * curchan,const struct ieee80211_scanparams * sp,const struct ieee80211_frame * wh,int subtype,int rssi,int noise)951 ieee80211_swscan_add_scan(struct ieee80211vap *vap,
952 struct ieee80211_channel *curchan,
953 const struct ieee80211_scanparams *sp,
954 const struct ieee80211_frame *wh,
955 int subtype, int rssi, int noise)
956 {
957 struct ieee80211com *ic = vap->iv_ic;
958 struct ieee80211_scan_state *ss = ic->ic_scan;
959
960 /* XXX locking */
961 /*
962 * Frames received during startup are discarded to avoid
963 * using scan state setup on the initial entry to the timer
964 * callback. This can occur because the device may enable
965 * rx prior to our doing the initial channel change in the
966 * timer routine.
967 */
968 if (SCAN_PRIVATE(ss)->ss_iflags & ISCAN_DISCARD)
969 return;
970 #ifdef IEEE80211_DEBUG
971 if (ieee80211_msg_scan(vap) && (ic->ic_flags & IEEE80211_F_SCAN))
972 ieee80211_scan_dump_probe_beacon(subtype, 1, wh->i_addr2, sp, rssi);
973 #endif
974 if (ss->ss_ops != NULL &&
975 ss->ss_ops->scan_add(ss, curchan, sp, wh, subtype, rssi, noise)) {
976 /*
977 * If we've reached the min dwell time terminate
978 * the timer so we'll switch to the next channel.
979 */
980 if ((SCAN_PRIVATE(ss)->ss_iflags & ISCAN_MINDWELL) == 0 &&
981 ieee80211_time_after_eq(ticks, SCAN_PRIVATE(ss)->ss_chanmindwell)) {
982 IEEE80211_DPRINTF(vap, IEEE80211_MSG_SCAN,
983 "%s: chan %3d%c min dwell met (%u > %lu)\n",
984 __func__,
985 ieee80211_chan2ieee(ic, ic->ic_curchan),
986 ieee80211_channel_type_char(ic->ic_curchan),
987 ticks, SCAN_PRIVATE(ss)->ss_chanmindwell);
988 SCAN_PRIVATE(ss)->ss_iflags |= ISCAN_MINDWELL;
989 /*
990 * NB: trigger at next clock tick or wait for the
991 * hardware.
992 */
993 ic->ic_scan_mindwell(ss);
994 }
995 }
996 }
997
998 static struct ieee80211_scan_methods swscan_methods = {
999 .sc_attach = ieee80211_swscan_attach,
1000 .sc_detach = ieee80211_swscan_detach,
1001 .sc_vattach = ieee80211_swscan_vattach,
1002 .sc_vdetach = ieee80211_swscan_vdetach,
1003 .sc_set_scan_duration = ieee80211_swscan_set_scan_duration,
1004 .sc_start_scan = ieee80211_swscan_start_scan,
1005 .sc_check_scan = ieee80211_swscan_check_scan,
1006 .sc_bg_scan = ieee80211_swscan_bg_scan,
1007 .sc_cancel_scan = ieee80211_swscan_cancel_scan,
1008 .sc_cancel_anyscan = ieee80211_swscan_cancel_anyscan,
1009 .sc_scan_next = ieee80211_swscan_scan_next,
1010 .sc_scan_done = ieee80211_swscan_scan_done,
1011 .sc_scan_probe_curchan = ieee80211_swscan_probe_curchan,
1012 .sc_add_scan = ieee80211_swscan_add_scan
1013 };
1014
1015 /*
1016 * Default scan attach method.
1017 */
1018 void
ieee80211_swscan_attach(struct ieee80211com * ic)1019 ieee80211_swscan_attach(struct ieee80211com *ic)
1020 {
1021 struct scan_state *ss;
1022
1023 /*
1024 * Setup the default methods
1025 */
1026 ic->ic_scan_methods = &swscan_methods;
1027
1028 /* Allocate initial scan state */
1029 ss = (struct scan_state *) IEEE80211_MALLOC(sizeof(struct scan_state),
1030 M_80211_SCAN, IEEE80211_M_NOWAIT | IEEE80211_M_ZERO);
1031 if (ss == NULL) {
1032 ic->ic_scan = NULL;
1033 return;
1034 }
1035 TASK_INIT(&ss->ss_scan_start, 0, scan_start, ss);
1036 TIMEOUT_TASK_INIT(ic->ic_tq, &ss->ss_scan_curchan, 0,
1037 scan_curchan_task, ss);
1038
1039 ic->ic_scan = &ss->base;
1040 ss->base.ss_ic = ic;
1041
1042 ic->ic_scan_curchan = scan_curchan;
1043 ic->ic_scan_mindwell = scan_mindwell;
1044 }
1045