1
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
34
35
36
37
38
39
40
41
42
43
47
48
49
50
51
52
53
54
55
56
57
58
59
60
66
67
68
69
70
71
72
73
74
80
81
82
83
84
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
150
151
152
157
158
159
160
161
162
167
168
169
170
171
172
173
174
175
176
181
182
183
184
185
186
187
191
192
193
197
198
199
200
201
202
203
204
205
211
212
213
214
215
216
217
218
219
220
221
225
226
227
231
232
233
234
235
237
238
239
240
241
242
244
245
246
247
248
249
250
251
257
258
259
260
261
262
263
264
265
266
267
268
269
270
271
272
273
274
275
276
277
278
279
280
281
282
283
284
285
286
287
288
289
290
291
292
293
294
295
296
297
298
299
300
301
302
306
307
308
309
310
311
312
313
314
315
316
317
318
319
320
321
322
323
324
325
331
332
333
334
335
336
337
338
339
340
341
342
343
344
345
346
347
348
349
350
351
352
353
354
355
356
357
358
359
360
361
362
363
364
365
366
367
368
369
370
371
372
377
378
379
380
381
382
383
384
385
386
387
388
389
390
391
392
393
394
395
396
397
398
399
400
401
402
403
404
405
406
407
408
409
410
411
412
413
414
415
416
417
418
419
420
421
422
423
424
425
431
432
433
434
435
439
440
441
442
443
444
445
446
447
448
449
450
451
452
453
454
455
456
457
458
459
460
461
462
463
464
465
466
467
468
469
470
471
472
473
474
475
476
477
478
479
480
481
482
483
484
485
486
487
488
489
490
491
492
493
494
495
496
497
498
499
500
501
502
503
504
505
506
509
510
511
512
513
514
515
516
517
518
519
520
521
522
523
524
525
526
530
531
532
534
535
536
537
538
539
540
541
542
549
550
551
552
553
554
555
556
557
558
559
560
561
562
563
564
565
566
567
568
569
570
571
572
573
574
575
576
577
578
579
580
581
582
583
584
585
586
587
588
589
590
591
592
593
594
595
596
597
598
599
600
601
602
603
604
605
606
607
608
614
615
616
617
618
619
620
621
626
627
628
629
630
631
632
633
634
635
636
637
638
639
640
641
646
647
648
649
650
651
652
653
654
655
656
657
658
659
660
661
662
663
664
665
666
667
668
669
670
671
672
673
674
675
676
677
678
679
680
681
686
687
692
693
694
695
696
712
713
719
720
721
722
727
728
729
730
731
737
738
744
745
750
751
752
756
757
758
759
760
763
773
777
778
779
780
781
782
783
788
789
790
791
792
793
794
795
796
797
798
799
800
801
802
803
804
805
806
807
808
809
810
811
812
813
814
815
816
817
818
819
820
822
823
824
825
826
832
833
834
835
842
843
844
845
846
847
851
852
853
858
859
860
861
866
867
871
872
873
874
875
876
877
878
879
880
881
885
886
887
888
889
890
891
892
893
894
895
896
897
898
899
900
901
902
907
908
909
915
916
917
918
919
931
932
933
934
935
936
940
941
942
943
944
945
946
947
948
949
950
951
952
953
954
955
959
960
961
968
969
973
974
978
979
980
981
982
983
984
985
986
987
988
989
990
991
992
993
994
995
996
997
998
999
1000
1001
1006
1007
1012
1013
1014
1015
1016
1017
1018
1019
1020
1021
1022
1023
1024
1025
1026
1027
1028
1029
1030
1031
1032
1033
1034
1035
1036
1037
1042
1043
1044
1045
1046
1047
1051
1052
1053
1056
1057
1058
1059
1060
1061
1062
1067
1068
1069
1070
1071
1072
1073
1074
1078
1079
1080
1081
1082
1083
1084
1085
1086
1087
1088
1089
1090
1091
1092
1093
1094
1095
1096
1097
1098
1099
1100
1101
1102
1103
1104
1105
1106
1107
1108
1109
1110
1111
1112
1113
1114
1115
1116
1117
1122
1123
1124
1125
1126
1127
1128
1129
1130
1131
1132
1133
1134
1135
1136
1137
1138
1139
1142
1143
1144
1145
1146
1147
1148
1149
1150
1151
1152
1153
1154
1155
1156
1157
1158
1159
1160
1161
1162
1163
1164
1165
1166
1167
1168
1169
/* ... */
#include "utils/includes.h"
#include "utils/common.h"
#include "utils/bitfield.h"
#include "utils/eloop.h"
#include "common/ieee802_11_defs.h"
#include "common/ieee802_11_common.h"
#include "wpa_supplicant_i.h"
#include "bss.h"
#include "rrm.h"
#include "scan.h"
#include <sys/errno.h>11 includes
#ifdef ESP_SUPPLICANT
#include "esp_common_i.h"
#endif
static void wpas_rrm_neighbor_rep_timeout_handler(void *data, void *user_ctx)
{
struct rrm_data *rrm = data;
if (!rrm->notify_neighbor_rep) {
wpa_printf(MSG_ERROR,
"RRM: Unexpected neighbor report timeout");
return;
}{...}
wpa_printf(MSG_DEBUG, "RRM: Notifying neighbor report - NONE");
rrm->notify_neighbor_rep(rrm->neighbor_rep_cb_ctx, NULL, 0);
rrm->notify_neighbor_rep = NULL;
rrm->neighbor_rep_cb_ctx = NULL;
}{ ... }
/* ... */
void wpas_rrm_reset(struct wpa_supplicant *wpa_s)
{
wpa_s->rrm.rrm_used = 0;
eloop_cancel_timeout(wpas_rrm_neighbor_rep_timeout_handler, &wpa_s->rrm,
NULL);
if (wpa_s->rrm.notify_neighbor_rep)
wpas_rrm_neighbor_rep_timeout_handler(&wpa_s->rrm, NULL);
wpa_s->rrm.next_neighbor_rep_token = 1;
wpas_clear_beacon_rep_data(wpa_s);
}{ ... }
/* ... */
void wpas_rrm_process_neighbor_rep(struct wpa_supplicant *wpa_s,
const u8 *report, size_t report_len)
{
wpa_hexdump(MSG_DEBUG, "RRM: New Neighbor Report", report, report_len);
if (report_len < 1)
return;
if (report[0] != wpa_s->rrm.next_neighbor_rep_token - 1) {
wpa_printf(MSG_DEBUG,
"RRM: Discarding neighbor report with token %d (expected %d)",
report[0], wpa_s->rrm.next_neighbor_rep_token - 1);
return;
}{...}
eloop_cancel_timeout(wpas_rrm_neighbor_rep_timeout_handler, &wpa_s->rrm,
NULL);
if (!wpa_s->rrm.notify_neighbor_rep) {
wpa_msg(wpa_s, MSG_INFO, "RRM: Unexpected neighbor report");
return;
}{...}
wpa_printf(MSG_DEBUG, "RRM: Notifying neighbor report (token = %d)",
report[0]);
wpa_s->rrm.notify_neighbor_rep(wpa_s->rrm.neighbor_rep_cb_ctx,
report, report_len);
wpa_s->rrm.notify_neighbor_rep = NULL;
wpa_s->rrm.neighbor_rep_cb_ctx = NULL;
}{ ... }
#if defined(__CYGWIN__) || defined(CONFIG_NATIVE_WINDOWS)
#ifndef ENOTCONN
#define ENOTCONN -1
#endif
#ifndef EOPNOTSUPP
#define EOPNOTSUPP -1
#endif
#ifndef ECANCELED
#define ECANCELED -1
#endif/* ... */
#endif
#define MEASURE_REQUEST_LCI_LEN (3 + 1 + 4)
#define MEASURE_REQUEST_CIVIC_LEN (3 + 5)
/* ... */
int wpas_rrm_send_neighbor_rep_request(struct wpa_supplicant *wpa_s,
const struct wpa_ssid_value *ssid,
int lci, int civic,
void (*cb)(void *ctx,
const u8 *neighbor_rep, size_t len),
void *cb_ctx)
{
struct wpabuf *buf;
if (!(wpa_s->rrm_ie[0] & WLAN_RRM_CAPS_NEIGHBOR_REPORT)) {
wpa_printf(MSG_ERROR,
"RRM: No network support for Neighbor Report.");
return -EOPNOTSUPP;
}{...}
if (wpa_s->rrm.notify_neighbor_rep) {
wpa_dbg(wpa_s, MSG_DEBUG,
"RRM: Currently handling previous Neighbor Report.");
return -EBUSY;
}{...}
buf = wpabuf_alloc(3 + (ssid ? 2 + ssid->ssid_len : 0) +
(lci ? 2 + MEASURE_REQUEST_LCI_LEN : 0) +
(civic ? 2 + MEASURE_REQUEST_CIVIC_LEN : 0));
if (buf == NULL) {
wpa_dbg(wpa_s, MSG_DEBUG,
"RRM: Failed to allocate Neighbor Report Request");
return -ENOMEM;
}{...}
wpa_dbg(wpa_s, MSG_DEBUG,
"RRM: Neighbor report request (for %s), token=%d",
(ssid ? wpa_ssid_txt(ssid->ssid, ssid->ssid_len) : ""),
wpa_s->rrm.next_neighbor_rep_token);
wpabuf_put_u8(buf, WLAN_ACTION_RADIO_MEASUREMENT);
wpabuf_put_u8(buf, WLAN_RRM_NEIGHBOR_REPORT_REQUEST);
wpabuf_put_u8(buf, wpa_s->rrm.next_neighbor_rep_token);
if (ssid) {
wpabuf_put_u8(buf, WLAN_EID_SSID);
wpabuf_put_u8(buf, ssid->ssid_len);
wpabuf_put_data(buf, ssid->ssid, ssid->ssid_len);
}{...}
if (lci) {
wpabuf_put_u8(buf, WLAN_EID_MEASURE_REQUEST);
wpabuf_put_u8(buf, MEASURE_REQUEST_LCI_LEN);
/* ... */
wpabuf_put_u8(buf, 1);
/* ... */
wpabuf_put_u8(buf, 0);
wpabuf_put_u8(buf, MEASURE_TYPE_LCI);
wpabuf_put_u8(buf, LOCATION_SUBJECT_REMOTE);
/* ... */
wpabuf_put_u8(buf, LCI_REQ_SUBELEM_MAX_AGE);
wpabuf_put_u8(buf, 2);
wpabuf_put_le16(buf, 0xffff);
}{...}
if (civic) {
wpabuf_put_u8(buf, WLAN_EID_MEASURE_REQUEST);
wpabuf_put_u8(buf, MEASURE_REQUEST_CIVIC_LEN);
/* ... */
wpabuf_put_u8(buf, 2);
/* ... */
wpabuf_put_u8(buf, 0);
wpabuf_put_u8(buf, MEASURE_TYPE_LOCATION_CIVIC);
/* ... */
wpabuf_put_u8(buf, LOCATION_SUBJECT_REMOTE);
wpabuf_put_u8(buf, 0);
wpabuf_put_u8(buf, 0);
/* ... */
wpabuf_put_le16(buf, 0);
}{...}
wpa_s->rrm.next_neighbor_rep_token++;
if (wpa_drv_send_action(wpa_s, 0, 0,
wpabuf_head(buf), wpabuf_len(buf), 0) < 0) {
wpa_dbg(wpa_s, MSG_DEBUG,
"RRM: Failed to send Neighbor Report Request");
wpabuf_free(buf);
return -ECANCELED;
}{...}
wpa_s->rrm.neighbor_rep_cb_ctx = cb_ctx;
wpa_s->rrm.notify_neighbor_rep = cb;
eloop_register_timeout(RRM_NEIGHBOR_REPORT_TIMEOUT, 0,
wpas_rrm_neighbor_rep_timeout_handler,
&wpa_s->rrm, NULL);
wpabuf_free(buf);
return 0;
}{ ... }
static int wpas_rrm_report_elem(struct wpabuf **buf, u8 token, u8 mode, u8 type,
const u8 *data, size_t data_len)
{
if (wpabuf_resize(buf, 5 + data_len))
return -1;
wpabuf_put_u8(*buf, WLAN_EID_MEASURE_REPORT);
wpabuf_put_u8(*buf, 3 + data_len);
wpabuf_put_u8(*buf, token);
wpabuf_put_u8(*buf, mode);
wpabuf_put_u8(*buf, type);
if (data_len)
wpabuf_put_data(*buf, data, data_len);
return 0;
}{ ... }
static void wpas_rrm_send_msr_report_mpdu(struct wpa_supplicant *wpa_s,
const u8 *data, size_t len)
{
struct wpabuf *report = wpabuf_alloc(len + 3);
if (!report)
return;
wpabuf_put_u8(report, WLAN_ACTION_RADIO_MEASUREMENT);
wpabuf_put_u8(report, WLAN_RRM_RADIO_MEASUREMENT_REPORT);
wpabuf_put_u8(report, wpa_s->rrm.token);
wpabuf_put_data(report, data, len);
if (wpa_drv_send_action(wpa_s, 0, 0,
wpabuf_head(report), wpabuf_len(report), 0)) {
wpa_printf(MSG_ERROR,
"RRM: Radio measurement report failed: Sending Action frame failed");
}{...}
wpabuf_free(report);
}{ ... }
static int wpas_rrm_beacon_rep_update_last_frame(u8 *pos, size_t len)
{
struct rrm_measurement_report_element *msr_rep;
u8 *end = pos + len;
u8 *msr_rep_end;
struct rrm_measurement_beacon_report *rep = NULL;
u8 *subelem;
while (end - pos >= (int) sizeof(*msr_rep)) {
msr_rep = (struct rrm_measurement_report_element *) pos;
msr_rep_end = pos + msr_rep->len + 2;
if (msr_rep->eid != WLAN_EID_MEASURE_REPORT ||
msr_rep_end > end) {
wpa_printf(MSG_ERROR,
"RRM: non-measurement report element in measurement report frame");
return -1;
}{...}
if (msr_rep->type == MEASURE_TYPE_BEACON)
rep = (struct rrm_measurement_beacon_report *)
msr_rep->variable;
pos += pos[1] + 2;
}{...}
if (!rep)
return 0;
subelem = rep->variable;
while (subelem + 2 < msr_rep_end &&
subelem[0] != WLAN_BEACON_REPORT_SUBELEM_LAST_INDICATION)
subelem += 2 + subelem[1];
if (subelem + 2 < msr_rep_end &&
subelem[0] == WLAN_BEACON_REPORT_SUBELEM_LAST_INDICATION &&
subelem[1] == 1 &&
subelem + BEACON_REPORT_LAST_INDICATION_SUBELEM_LEN <= end)
subelem[2] = 1;
return 0;
}{ ... }
static void wpas_rrm_send_msr_report(struct wpa_supplicant *wpa_s,
struct wpabuf *buf)
{
int len = wpabuf_len(buf);
u8 *pos = wpabuf_mhead_u8(buf), *next = pos;
#define MPDU_REPORT_LEN (int) (IEEE80211_MAX_MMPDU_SIZE - IEEE80211_HDRLEN - 3)
while (len) {
int send_len = (len > MPDU_REPORT_LEN) ? next - pos : len;
if (send_len == len)
wpas_rrm_beacon_rep_update_last_frame(pos, len);
if (send_len == len ||
(send_len + next[1] + 2) > MPDU_REPORT_LEN) {
wpas_rrm_send_msr_report_mpdu(wpa_s, pos, send_len);
len -= send_len;
pos = next;
}{...}
if (len)
next += next[1] + 2;
}{...}
#undef MPDU_REPORT_LEN
}{ ... }
static int wpas_get_op_chan_phy(int channel, const u8 *ies, size_t ies_len,
u8 *op_class, u8 *chan, u8 *phy_type)
{
const u8 *ie;
int sec_chan = 0;
struct ieee80211_ht_operation *ht_oper = NULL;
ie = get_ie(ies, ies_len, WLAN_EID_HT_OPERATION);
if (ie && ie[1] >= 2) {
ht_oper = (struct ieee80211_ht_operation *) (ie + 2);
if (ht_oper->ht_param & HT_INFO_HT_PARAM_SECONDARY_CHNL_ABOVE)
sec_chan = 1;
else if (ht_oper->ht_param &
HT_INFO_HT_PARAM_SECONDARY_CHNL_BELOW)
sec_chan = -1;
}{...}
*op_class = get_operating_class(channel, sec_chan);
*phy_type = (sec_chan != 0) ? PHY_TYPE_HT : PHY_TYPE_ERP;
return 0;
}{ ... }
static int wpas_beacon_rep_add_frame_body(struct bitfield *eids,
enum beacon_report_detail detail,
struct wpa_bss *bss, u8 *buf,
size_t buf_len, u8 **ies_buf,
size_t *ie_len, int add_fixed)
{
u8 *ies = *ies_buf;
size_t ies_len = *ie_len;
u8 *pos = buf;
int rem_len;
rem_len = 255 - sizeof(struct rrm_measurement_beacon_report) -
sizeof(struct rrm_measurement_report_element) - 2 -
REPORTED_FRAME_BODY_SUBELEM_LEN;
if (detail > BEACON_REPORT_DETAIL_ALL_FIELDS_AND_ELEMENTS) {
wpa_printf(MSG_DEBUG,
"Beacon Request: Invalid reporting detail: %d",
detail);
return -1;
}{...}
if (detail == BEACON_REPORT_DETAIL_NONE)
return 0;
/* ... */
if (add_fixed && buf_len < 14)
return -1;
*pos++ = WLAN_BEACON_REPORT_SUBELEM_FRAME_BODY;
pos++;
if (add_fixed) {
WPA_PUT_LE64(pos, bss->tsf);
pos += sizeof(bss->tsf);
WPA_PUT_LE16(pos, bss->beacon_int);
pos += 2;
WPA_PUT_LE16(pos, bss->caps);
pos += 2;
}{...}
rem_len -= pos - buf;
/* ... */
while (ies_len > 2 && 2U + ies[1] <= ies_len && rem_len > 0) {
if (detail == BEACON_REPORT_DETAIL_ALL_FIELDS_AND_ELEMENTS ||
(eids && bitfield_is_set(eids, ies[0]))) {
u8 elen = ies[1];
if (2 + elen > buf + buf_len - pos ||
2 + elen > rem_len)
break;
*pos++ = ies[0];
*pos++ = elen;
os_memcpy(pos, ies + 2, elen);
pos += elen;
rem_len -= 2 + elen;
}{...}
ies_len -= 2 + ies[1];
ies += 2 + ies[1];
}{...}
*ie_len = ies_len;
*ies_buf = ies;
buf[1] = pos - buf - 2;
return pos - buf;
}{ ... }
static int wpas_add_beacon_rep_elem(struct beacon_rep_data *data,
struct wpa_bss *bss,
struct wpabuf **wpa_buf,
struct rrm_measurement_beacon_report *rep,
u8 **ie, size_t *ie_len, u8 idx)
{
int ret;
u8 *buf, *pos;
u32 subelems_len = REPORTED_FRAME_BODY_SUBELEM_LEN +
(data->last_indication ?
BEACON_REPORT_LAST_INDICATION_SUBELEM_LEN : 0);
/* ... */
buf = os_malloc(sizeof(*rep) + 14 + *ie_len + subelems_len);
if (!buf)
return -1;
os_memcpy(buf, rep, sizeof(*rep));
ret = wpas_beacon_rep_add_frame_body(data->eids, data->report_detail,
bss, buf + sizeof(*rep),
14 + *ie_len, ie, ie_len,
idx == 0);
if (ret < 0)
goto out;
pos = buf + ret + sizeof(*rep);
pos[0] = WLAN_BEACON_REPORT_SUBELEM_FRAME_BODY_FRAGMENT_ID;
pos[1] = 2;
/* ... */
pos[2] = 1;
/* ... */
pos[3] = idx;
if (data->report_detail != BEACON_REPORT_DETAIL_NONE && *ie_len)
pos[3] |= REPORTED_FRAME_BODY_MORE_FRAGMENTS;
else
pos[3] &= ~REPORTED_FRAME_BODY_MORE_FRAGMENTS;
pos += REPORTED_FRAME_BODY_SUBELEM_LEN;
if (data->last_indication) {
pos[0] = WLAN_BEACON_REPORT_SUBELEM_LAST_INDICATION;
pos[1] = 1;
pos[2] = 0;
}{...}
ret = wpas_rrm_report_elem(wpa_buf, data->token,
MEASUREMENT_REPORT_MODE_ACCEPT,
MEASURE_TYPE_BEACON, buf,
ret + sizeof(*rep) + subelems_len);
out:
os_free(buf);
return ret;
}{ ... }
static int wpas_add_beacon_rep(struct wpa_supplicant *wpa_s,
struct wpabuf **wpa_buf, struct wpa_bss *bss,
u64 start, u64 parent_tsf)
{
struct beacon_rep_data *data = &wpa_s->beacon_rep_data;
u8 *ies = (u8 *) (bss + 1);
u8 *pos = ies;
size_t ies_len = bss->ie_len ? bss->ie_len : bss->beacon_ie_len;
struct rrm_measurement_beacon_report rep;
u8 idx = 0;
if (os_memcmp(data->bssid, broadcast_ether_addr, ETH_ALEN) != 0 &&
os_memcmp(data->bssid, bss->bssid, ETH_ALEN) != 0)
return 0;
if (data->ssid_len &&
(data->ssid_len != bss->ssid_len ||
os_memcmp(data->ssid, bss->ssid, bss->ssid_len) != 0))
return 0;
if (wpas_get_op_chan_phy(bss->channel, ies, ies_len, &rep.op_class,
&rep.channel, &rep.report_info) < 0)
return 0;
rep.channel = bss->channel;
rep.start_time = host_to_le64(start);
rep.duration = host_to_le16(data->scan_params.duration);
rep.rcpi = rssi_to_rcpi(bss->level);
rep.rsni = 255;
os_memcpy(rep.bssid, bss->bssid, ETH_ALEN);
rep.antenna_id = 0;
rep.parent_tsf = host_to_le32(parent_tsf);
do {
int ret;
ret = wpas_add_beacon_rep_elem(data, bss, wpa_buf, &rep,
&pos, &ies_len, idx++);
if (ret)
return ret;
}{...} while (data->report_detail != BEACON_REPORT_DETAIL_NONE &&
ies_len >= 2);
return 0;
}{ ... }
static int wpas_beacon_rep_no_results(struct wpa_supplicant *wpa_s,
struct wpabuf **buf)
{
return wpas_rrm_report_elem(buf, wpa_s->beacon_rep_data.token,
MEASUREMENT_REPORT_MODE_ACCEPT,
MEASURE_TYPE_BEACON, NULL, 0);
}{ ... }
static void wpas_beacon_rep_table(struct wpa_supplicant *wpa_s,
struct wpabuf **buf)
{
size_t i;
for (i = 0; i < wpa_s->last_scan_res_used; i++) {
if (wpas_add_beacon_rep(wpa_s, buf, wpa_s->last_scan_res[i],
0, 0) < 0)
break;
}{...}
if (!(*buf))
wpas_beacon_rep_no_results(wpa_s, buf);
wpa_hexdump_buf(MSG_DEBUG, "RRM: Radio Measurement report", *buf);
}{ ... }
static void wpas_rrm_refuse_request(struct wpa_supplicant *wpa_s)
{
if (!is_multicast_ether_addr(wpa_s->rrm.dst_addr)) {
struct wpabuf *buf = NULL;
if (wpas_rrm_report_elem(&buf, wpa_s->beacon_rep_data.token,
MEASUREMENT_REPORT_MODE_REJECT_REFUSED,
MEASURE_TYPE_BEACON, NULL, 0)) {
wpa_printf(MSG_ERROR, "RRM: Memory allocation failed");
wpabuf_free(buf);
return;
}{...}
wpas_rrm_send_msr_report(wpa_s, buf);
wpabuf_free(buf);
}{...}
wpas_clear_beacon_rep_data(wpa_s);
}{ ... }
static void wpas_rrm_scan_timeout(void *eloop_ctx, void *timeout_ctx)
{
struct wpa_supplicant *wpa_s = eloop_ctx;
struct wpa_driver_scan_params *params =
&wpa_s->beacon_rep_data.scan_params;
u16 prev_duration = params->duration;
if (!wpa_s->current_bss)
return;
os_get_reltime(&wpa_s->beacon_rep_scan);
wpa_s->scan_reason = REASON_RRM_BEACON_REPORT;
if (wpa_supplicant_trigger_scan(wpa_s, params) < 0)
wpas_rrm_refuse_request(wpa_s);
params->duration = prev_duration;
}{ ... }
static int wpas_rm_handle_beacon_req_subelem(struct wpa_supplicant *wpa_s,
struct beacon_rep_data *data,
u8 sid, u8 slen, const u8 *subelem)
{
u8 report_info, i;
switch (sid) {
case WLAN_BEACON_REQUEST_SUBELEM_SSID:
if (!slen) {
wpa_printf(MSG_DEBUG,
"SSID subelement with zero length - wildcard SSID");
break;
}{...}
if (slen > SSID_MAX_LEN) {
wpa_printf(MSG_DEBUG,
"Invalid SSID subelement length: %u", slen);
return -1;
}{...}
data->ssid_len = slen;
os_memcpy(data->ssid, subelem, data->ssid_len);
break;...
case WLAN_BEACON_REQUEST_SUBELEM_INFO:
if (slen != 2) {
wpa_printf(MSG_DEBUG,
"Invalid reporting information subelement length: %u",
slen);
return -1;
}{...}
report_info = subelem[0];
if (report_info != 0) {
wpa_printf(MSG_DEBUG,
"reporting information=%u is not supported",
report_info);
return 0;
}{...}
break;...
case WLAN_BEACON_REQUEST_SUBELEM_DETAIL:
if (slen != 1) {
wpa_printf(MSG_DEBUG,
"Invalid reporting detail subelement length: %u",
slen);
return -1;
}{...}
data->report_detail = subelem[0];
if (data->report_detail >
BEACON_REPORT_DETAIL_ALL_FIELDS_AND_ELEMENTS) {
wpa_printf(MSG_DEBUG, "Invalid reporting detail: %u",
subelem[0]);
return -1;
}{...}
break;...
case WLAN_BEACON_REQUEST_SUBELEM_REQUEST:
if (data->report_detail !=
BEACON_REPORT_DETAIL_REQUESTED_ONLY) {
wpa_printf(MSG_DEBUG,
"Beacon request: request subelement is present but report detail is %u",
data->report_detail);
return -1;
}{...}
if (!slen) {
wpa_printf(MSG_DEBUG,
"Invalid request subelement length: %u",
slen);
return -1;
}{...}
if (data->eids) {
wpa_printf(MSG_DEBUG,
"Beacon Request: Request subelement appears more than once");
return -1;
}{...}
data->eids = bitfield_alloc(255);
if (!data->eids) {
wpa_printf(MSG_DEBUG, "Failed to allocate EIDs bitmap");
return -1;
}{...}
for (i = 0; i < slen; i++)
bitfield_set(data->eids, subelem[i]);
break;...
case WLAN_BEACON_REQUEST_SUBELEM_AP_CHANNEL:
break;...
case WLAN_BEACON_REQUEST_SUBELEM_LAST_INDICATION:
if (slen != 1) {
wpa_printf(MSG_DEBUG,
"Beacon request: Invalid last indication request subelement length: %u",
slen);
return -1;
}{...}
data->last_indication = subelem[0];
break;...
default:
wpa_printf(MSG_DEBUG,
"Beacon request: Unknown subelement id %u", sid);
break;...
}{...}
return 1;
}{ ... }
/* ... */
static int
wpas_rm_handle_beacon_req(struct wpa_supplicant *wpa_s,
u8 elem_token, int duration_mandatory,
const struct rrm_measurement_beacon_request *req,
size_t len, struct wpabuf **buf)
{
struct beacon_rep_data *data = &wpa_s->beacon_rep_data;
struct wpa_driver_scan_params *params = &data->scan_params;
const u8 *subelems;
size_t elems_len;
u16 rand_interval;
u32 interval_usec;
u32 _rand;
int ret = 0, res;
u8 reject_mode;
if (len < sizeof(*req))
return -1;
if (req->mode != BEACON_REPORT_MODE_PASSIVE &&
req->mode != BEACON_REPORT_MODE_ACTIVE &&
req->mode != BEACON_REPORT_MODE_TABLE)
return 0;
subelems = req->variable;
elems_len = len - sizeof(*req);
rand_interval = le_to_host16(req->rand_interval);
os_memset(data, 0, sizeof(*data));
data->token = elem_token;
/* ... */
data->report_detail = BEACON_REPORT_DETAIL_ALL_FIELDS_AND_ELEMENTS;
os_memcpy(data->bssid, req->bssid, ETH_ALEN);
while (elems_len >= 2) {
if (subelems[1] > elems_len - 2) {
wpa_printf(MSG_DEBUG,
"Beacon Request: Truncated subelement");
ret = -1;
goto out;
}{...}
res = wpas_rm_handle_beacon_req_subelem(
wpa_s, data, subelems[0], subelems[1], &subelems[2]);
if (res < 0) {
ret = res;
goto out;
}{...} else if (!res) {
reject_mode = MEASUREMENT_REPORT_MODE_REJECT_INCAPABLE;
goto out_reject;
}{...}
elems_len -= 2 + subelems[1];
subelems += 2 + subelems[1];
}{...}
if (req->mode == BEACON_REPORT_MODE_TABLE) {
wpas_beacon_rep_table(wpa_s, buf);
goto out;
}{...}
params->channel = req->channel;
#ifdef ESP_SUPPLICANT
if (params->channel == 0xff) {
params->channel = 0;
}{...}
#endif/* ... */
params->duration = le_to_host16(req->duration);
params->duration_mandatory = duration_mandatory;
params->mode = req->mode;
if (!params->duration) {
wpa_printf(MSG_DEBUG, "Beacon request: Duration is 0");
ret = -1;
goto out;
}{...}
if (data->ssid_len) {
params->ssids[params->num_ssids].ssid = data->ssid;
params->ssids[params->num_ssids++].ssid_len = data->ssid_len;
}{...}
if (os_get_random((u8 *) &_rand, sizeof(_rand)) < 0)
_rand = os_random();
interval_usec = (_rand % (rand_interval + 1)) * 1024;
os_sleep(0, interval_usec);
wpas_rrm_scan_timeout(wpa_s, NULL);
return 1;
out_reject:
if (!is_multicast_ether_addr(wpa_s->rrm.dst_addr) &&
wpas_rrm_report_elem(buf, elem_token, reject_mode,
MEASURE_TYPE_BEACON, NULL, 0) < 0) {
wpa_printf(MSG_DEBUG, "RRM: Failed to add report element");
ret = -1;
}{...}
out:
wpas_clear_beacon_rep_data(wpa_s);
return ret;
}{ ... }
static int
wpas_rrm_handle_msr_req_element(
struct wpa_supplicant *wpa_s,
const struct rrm_measurement_request_element *req,
struct wpabuf **buf)
{
int duration_mandatory;
wpa_printf(MSG_DEBUG, "Measurement request type %d token %d",
req->type, req->token);
if (req->mode & MEASUREMENT_REQUEST_MODE_ENABLE) {
wpa_printf(MSG_DEBUG, "RRM: Enable bit not supported, ignore");
return 0;
}{...}
if ((req->mode & MEASUREMENT_REQUEST_MODE_PARALLEL) &&
req->type > MEASURE_TYPE_RPI_HIST) {
wpa_printf(MSG_DEBUG,
"RRM: Parallel measurements are not supported, reject");
goto reject;
}{...}
duration_mandatory =
!!(req->mode & MEASUREMENT_REQUEST_MODE_DURATION_MANDATORY);
switch (req->type) {
case MEASURE_TYPE_BEACON:
return wpas_rm_handle_beacon_req(wpa_s, req->token,
duration_mandatory,
(const void *) req->variable,
req->len - 3, buf);...
default:
wpa_printf(MSG_INFO,
"RRM: Unsupported radio measurement type %u",
req->type);
break;...
}{...}
reject:
if (!is_multicast_ether_addr(wpa_s->rrm.dst_addr) &&
wpas_rrm_report_elem(buf, req->token,
MEASUREMENT_REPORT_MODE_REJECT_INCAPABLE,
req->type, NULL, 0) < 0) {
wpa_printf(MSG_DEBUG, "RRM: Failed to add report element");
return -1;
}{...}
return 0;
}{ ... }
static struct wpabuf *
wpas_rrm_process_msr_req_elems(struct wpa_supplicant *wpa_s, const u8 *pos,
size_t len)
{
struct wpabuf *buf = NULL;
while (len) {
const struct rrm_measurement_request_element *req;
int res;
if (len < 2) {
wpa_printf(MSG_DEBUG, "RRM: Truncated element");
goto out;
}{...}
req = (const struct rrm_measurement_request_element *) pos;
if (req->eid != WLAN_EID_MEASURE_REQUEST) {
wpa_printf(MSG_DEBUG,
"RRM: Expected Measurement Request element, but EID is %u",
req->eid);
printf("len is %d", len);
goto out;
}{...}
if (req->len < 3) {
wpa_printf(MSG_DEBUG, "RRM: Element length too short");
goto out;
}{...}
if (req->len > len - 2) {
wpa_printf(MSG_DEBUG, "RRM: Element length too long");
goto out;
}{...}
res = wpas_rrm_handle_msr_req_element(wpa_s, req, &buf);
if (res < 0)
goto out;
pos += req->len + 2;
len -= req->len + 2;
}{...}
return buf;
out:
wpabuf_free(buf);
return NULL;
}{ ... }
void wpas_rrm_handle_radio_measurement_request(struct wpa_supplicant *wpa_s,
const u8 *src, const u8 *dst,
const u8 *frame, size_t len)
{
struct wpabuf *report;
if (!wpa_s->rrm.rrm_used) {
wpa_printf(MSG_INFO,
"RRM: Ignoring radio measurement request: Not RRM network");
return;
}{...}
if (len < 3) {
wpa_printf(MSG_INFO,
"RRM: Ignoring too short radio measurement request");
return;
}{...}
wpa_s->rrm.token = *frame;
os_memcpy(wpa_s->rrm.dst_addr, dst, ETH_ALEN);
report = wpas_rrm_process_msr_req_elems(wpa_s, frame + 3, len - 3);
if (!report)
return;
wpas_rrm_send_msr_report(wpa_s, report);
wpabuf_free(report);
}{ ... }
void wpas_rrm_handle_link_measurement_request(struct wpa_supplicant *wpa_s,
const u8 *src,
const u8 *frame, size_t len,
int rssi)
{
struct wpabuf *buf;
const struct rrm_link_measurement_request *req;
struct rrm_link_measurement_report report;
req = (const struct rrm_link_measurement_request *) frame;
if (len < sizeof(*req)) {
wpa_printf(MSG_INFO,
"RRM: Link measurement report failed. Request too short");
return;
}{...}
os_memset(&report, 0, sizeof(report));
report.dialog_token = req->dialog_token;
report.tpc.eid = WLAN_EID_TPC_REPORT;
report.tpc.len = 2;
/* ... */
#ifdef ESP_SUPPLICANT
esp_get_tx_power(&report.tpc.tx_power);
report.tpc.link_margin = rssi + 96;/* ... */
#endif
report.rsni = 255;
report.rcpi = rssi_to_rcpi(rssi);
buf = wpabuf_alloc(2 + sizeof(report));
if (buf == NULL) {
wpa_printf(MSG_ERROR,
"RRM: Link measurement report failed. Buffer allocation failed");
return;
}{...}
wpabuf_put_u8(buf, WLAN_ACTION_RADIO_MEASUREMENT);
wpabuf_put_u8(buf, WLAN_RRM_LINK_MEASUREMENT_REPORT);
wpabuf_put_data(buf, &report, sizeof(report));
wpa_hexdump_buf(MSG_DEBUG, "RRM: Link measurement report", buf);
if (wpa_drv_send_action(wpa_s, 0, 0,
wpabuf_head(buf), wpabuf_len(buf), 0)) {
wpa_printf(MSG_ERROR,
"RRM: Link measurement report failed. Send action failed");
}{...}
wpabuf_free(buf);
}{ ... }
int wpas_beacon_rep_scan_process(struct wpa_supplicant *wpa_s,
u64 scan_start_tsf)
{
size_t i = 0;
struct wpabuf *buf = NULL;
struct wpa_bss *bss = NULL;
if (!wpa_s->beacon_rep_data.token)
return 0;
if (!wpa_s->current_bss)
goto out;
wpa_printf(MSG_DEBUG, "RRM: TSF current BSS: " MACSTR,
MAC2STR(wpa_s->current_bss->bssid));
for (i = 0; i < wpa_s->num_bss; i++) {
bss = wpa_bss_get_next_bss(wpa_s, bss);
if (!bss)
continue;
if (wpa_s->beacon_rep_data.scan_params.channel &&
bss->channel != wpa_s->beacon_rep_data.scan_params.channel)
continue;
#ifndef ESP_SUPPLICANT
/* ... */
if (scan_start_tsf <
scan_res->res[i]->parent_tsf) {
struct os_reltime update_time, diff;
/* ... */
calculate_update_time(&scan_res->fetch_time,
scan_res->res[i]->age,
&update_time);
os_reltime_sub(&wpa_s->beacon_rep_scan,
&update_time, &diff);
if (os_reltime_before(&update_time,
&wpa_s->beacon_rep_scan) &&
(diff.sec || diff.usec >= 8000)) {
wpa_printf(MSG_ERROR,
"RRM: Ignore scan result for " MACSTR
" due to old update (age(ms) %u, calculated age %u.%06u seconds)",
MAC2STR(scan_res->res[i]->bssid),
scan_res->res[i]->age,
(unsigned int) diff.sec,
(unsigned int) diff.usec);
continue;
}{...}
}{...} else {
continue;
}{...}
#endif/* ... */
if (wpas_add_beacon_rep(wpa_s, &buf, bss, scan_start_tsf,
bss->parent_tsf) < 0)
break;
}{...}
if (!buf && wpas_beacon_rep_no_results(wpa_s, &buf))
goto out;
wpa_hexdump_buf(MSG_DEBUG, "RRM: Radio Measurement report", buf);
wpas_rrm_send_msr_report(wpa_s, buf);
wpabuf_free(buf);
out:
wpas_clear_beacon_rep_data(wpa_s);
return 1;
}{ ... }
void wpas_clear_beacon_rep_data(struct wpa_supplicant *wpa_s)
{
struct beacon_rep_data *data = &wpa_s->beacon_rep_data;
eloop_cancel_timeout(wpas_rrm_scan_timeout, wpa_s, NULL);
bitfield_free(data->eids);
os_memset(data, 0, sizeof(*data));
}{ ... }