]> git.ipfire.org Git - thirdparty/hostap.git/blame - wpa_supplicant/mesh_mpm.c
mesh: Report mesh peer AID to kernel
[thirdparty/hostap.git] / wpa_supplicant / mesh_mpm.c
CommitLineData
5f92659d
BC
1/*
2 * WPA Supplicant - Basic mesh peer management
3 * Copyright (c) 2013-2014, cozybit, Inc. All rights reserved.
4 *
5 * This software may be distributed under the terms of the BSD license.
6 * See README for more details.
7 */
8
9#include "utils/includes.h"
10
11#include "utils/common.h"
12#include "utils/eloop.h"
13#include "common/ieee802_11_defs.h"
14#include "ap/hostapd.h"
15#include "ap/sta_info.h"
16#include "ap/ieee802_11.h"
9f2cf23e 17#include "ap/wpa_auth.h"
5f92659d
BC
18#include "wpa_supplicant_i.h"
19#include "driver_i.h"
20#include "mesh_mpm.h"
0f950df0 21#include "mesh_rsn.h"
5f92659d 22
5f92659d 23struct mesh_peer_mgmt_ie {
c2ed7797
JM
24 const u8 *proto_id; /* Mesh Peering Protocol Identifier (2 octets) */
25 const u8 *llid; /* Local Link ID (2 octets) */
26 const u8 *plid; /* Peer Link ID (conditional, 2 octets) */
27 const u8 *reason; /* Reason Code (conditional, 2 octets) */
28 const u8 *chosen_pmk; /* Chosen PMK (optional, 16 octets) */
5f92659d
BC
29};
30
31static void plink_timer(void *eloop_ctx, void *user_data);
32
33
34enum plink_event {
35 PLINK_UNDEFINED,
36 OPN_ACPT,
37 OPN_RJCT,
5f92659d
BC
38 CNF_ACPT,
39 CNF_RJCT,
5f92659d 40 CLS_ACPT,
02022564 41 REQ_RJCT
5f92659d
BC
42};
43
44static const char * const mplstate[] = {
b5f5c324 45 [0] = "UNINITIALIZED",
d02e5498
JM
46 [PLINK_IDLE] = "IDLE",
47 [PLINK_OPN_SNT] = "OPN_SNT",
48 [PLINK_OPN_RCVD] = "OPN_RCVD",
5f92659d
BC
49 [PLINK_CNF_RCVD] = "CNF_RCVD",
50 [PLINK_ESTAB] = "ESTAB",
51 [PLINK_HOLDING] = "HOLDING",
52 [PLINK_BLOCKED] = "BLOCKED"
53};
54
55static const char * const mplevent[] = {
56 [PLINK_UNDEFINED] = "UNDEFINED",
57 [OPN_ACPT] = "OPN_ACPT",
58 [OPN_RJCT] = "OPN_RJCT",
5f92659d
BC
59 [CNF_ACPT] = "CNF_ACPT",
60 [CNF_RJCT] = "CNF_RJCT",
5f92659d 61 [CLS_ACPT] = "CLS_ACPT",
02022564 62 [REQ_RJCT] = "REQ_RJCT",
5f92659d
BC
63};
64
65
66static int mesh_mpm_parse_peer_mgmt(struct wpa_supplicant *wpa_s,
67 u8 action_field,
68 const u8 *ie, size_t len,
69 struct mesh_peer_mgmt_ie *mpm_ie)
70{
71 os_memset(mpm_ie, 0, sizeof(*mpm_ie));
72
c2ed7797
JM
73 /* Remove optional Chosen PMK field at end */
74 if (len >= SAE_PMKID_LEN) {
75 mpm_ie->chosen_pmk = ie + len - SAE_PMKID_LEN;
76 len -= SAE_PMKID_LEN;
5f92659d
BC
77 }
78
79 if ((action_field == PLINK_OPEN && len != 4) ||
80 (action_field == PLINK_CONFIRM && len != 6) ||
81 (action_field == PLINK_CLOSE && len != 6 && len != 8)) {
82 wpa_msg(wpa_s, MSG_DEBUG, "MPM: Invalid peer mgmt ie");
83 return -1;
84 }
85
86 /* required fields */
87 if (len < 4)
88 return -1;
89 mpm_ie->proto_id = ie;
90 mpm_ie->llid = ie + 2;
91 ie += 4;
92 len -= 4;
93
94 /* close reason is always present at end for close */
95 if (action_field == PLINK_CLOSE) {
96 if (len < 2)
97 return -1;
98 mpm_ie->reason = ie + len - 2;
99 len -= 2;
100 }
101
c2ed7797
JM
102 /* Peer Link ID, present for confirm, and possibly close */
103 if (len >= 2)
5f92659d
BC
104 mpm_ie->plid = ie;
105
106 return 0;
107}
108
109
110static int plink_free_count(struct hostapd_data *hapd)
111{
112 if (hapd->max_plinks > hapd->num_plinks)
113 return hapd->max_plinks - hapd->num_plinks;
114 return 0;
115}
116
117
118static u16 copy_supp_rates(struct wpa_supplicant *wpa_s,
119 struct sta_info *sta,
120 struct ieee802_11_elems *elems)
121{
122 if (!elems->supp_rates) {
123 wpa_msg(wpa_s, MSG_ERROR, "no supported rates from " MACSTR,
124 MAC2STR(sta->addr));
125 return WLAN_STATUS_UNSPECIFIED_FAILURE;
126 }
127
128 if (elems->supp_rates_len + elems->ext_supp_rates_len >
129 sizeof(sta->supported_rates)) {
130 wpa_msg(wpa_s, MSG_ERROR,
131 "Invalid supported rates element length " MACSTR
132 " %d+%d", MAC2STR(sta->addr), elems->supp_rates_len,
133 elems->ext_supp_rates_len);
134 return WLAN_STATUS_UNSPECIFIED_FAILURE;
135 }
136
137 sta->supported_rates_len = merge_byte_arrays(
138 sta->supported_rates, sizeof(sta->supported_rates),
139 elems->supp_rates, elems->supp_rates_len,
140 elems->ext_supp_rates, elems->ext_supp_rates_len);
141
142 return WLAN_STATUS_SUCCESS;
143}
144
145
146/* return true if elems from a neighbor match this MBSS */
147static Boolean matches_local(struct wpa_supplicant *wpa_s,
148 struct ieee802_11_elems *elems)
149{
150 struct mesh_conf *mconf = wpa_s->ifmsh->mconf;
151
152 if (elems->mesh_config_len < 5)
153 return FALSE;
154
155 return (mconf->meshid_len == elems->mesh_id_len &&
156 os_memcmp(mconf->meshid, elems->mesh_id,
157 elems->mesh_id_len) == 0 &&
158 mconf->mesh_pp_id == elems->mesh_config[0] &&
159 mconf->mesh_pm_id == elems->mesh_config[1] &&
160 mconf->mesh_cc_id == elems->mesh_config[2] &&
161 mconf->mesh_sp_id == elems->mesh_config[3] &&
162 mconf->mesh_auth_id == elems->mesh_config[4]);
163}
164
165
166/* check if local link id is already used with another peer */
167static Boolean llid_in_use(struct wpa_supplicant *wpa_s, u16 llid)
168{
169 struct sta_info *sta;
170 struct hostapd_data *hapd = wpa_s->ifmsh->bss[0];
171
172 for (sta = hapd->sta_list; sta; sta = sta->next) {
173 if (sta->my_lid == llid)
174 return TRUE;
175 }
176
177 return FALSE;
178}
179
180
181/* generate an llid for a link and set to initial state */
182static void mesh_mpm_init_link(struct wpa_supplicant *wpa_s,
183 struct sta_info *sta)
184{
185 u16 llid;
186
187 do {
188 if (os_get_random((u8 *) &llid, sizeof(llid)) < 0)
189 continue;
190 } while (!llid || llid_in_use(wpa_s, llid));
191
192 sta->my_lid = llid;
193 sta->peer_lid = 0;
e347cafe 194 sta->peer_aid = 0;
871ff0b7
MH
195
196 /*
197 * We do not use wpa_mesh_set_plink_state() here because there is no
198 * entry in kernel yet.
199 */
d02e5498 200 sta->plink_state = PLINK_IDLE;
5f92659d
BC
201}
202
203
204static void mesh_mpm_send_plink_action(struct wpa_supplicant *wpa_s,
205 struct sta_info *sta,
206 enum plink_action_field type,
207 u16 close_reason)
208{
209 struct wpabuf *buf;
210 struct hostapd_iface *ifmsh = wpa_s->ifmsh;
211 struct hostapd_data *bss = ifmsh->bss[0];
212 struct mesh_conf *conf = ifmsh->mconf;
213 u8 supp_rates[2 + 2 + 32];
0f950df0 214 u8 *pos, *cat;
5f92659d
BC
215 u8 ie_len, add_plid = 0;
216 int ret;
217 int ampe = conf->security & MESH_CONF_SEC_AMPE;
798b3182 218 size_t buf_len;
5f92659d
BC
219
220 if (!sta)
221 return;
222
798b3182
MH
223 buf_len = 2 + /* capability info */
224 2 + /* AID */
225 2 + 8 + /* supported rates */
226 2 + (32 - 8) +
227 2 + 32 + /* mesh ID */
228 2 + 7 + /* mesh config */
229 2 + 23 + /* peering management */
230 2 + 96 + /* AMPE */
231 2 + 16; /* MIC */
232#ifdef CONFIG_IEEE80211N
6334330e 233 if (type != PLINK_CLOSE && wpa_s->mesh_ht_enabled) {
798b3182
MH
234 buf_len += 2 + 26 + /* HT capabilities */
235 2 + 22; /* HT operation */
236 }
237#endif /* CONFIG_IEEE80211N */
a65efbfb
PO
238#ifdef CONFIG_IEEE80211AC
239 if (type != PLINK_CLOSE && wpa_s->mesh_vht_enabled) {
240 buf_len += 2 + 12 + /* VHT Capabilities */
241 2 + 5; /* VHT Operation */
242 }
243#endif /* CONFIG_IEEE80211AC */
f029c44c
MH
244 if (type != PLINK_CLOSE)
245 buf_len += conf->rsn_ie_len; /* RSN IE */
246
798b3182 247 buf = wpabuf_alloc(buf_len);
5f92659d
BC
248 if (!buf)
249 return;
250
0f950df0 251 cat = wpabuf_mhead_u8(buf);
5f92659d
BC
252 wpabuf_put_u8(buf, WLAN_ACTION_SELF_PROTECTED);
253 wpabuf_put_u8(buf, type);
254
255 if (type != PLINK_CLOSE) {
d5b95325
MH
256 u8 info;
257
5f92659d
BC
258 /* capability info */
259 wpabuf_put_le16(buf, ampe ? IEEE80211_CAP_PRIVACY : 0);
260
5cfb672d 261 /* aid */
5f92659d 262 if (type == PLINK_CONFIRM)
681753f2 263 wpabuf_put_le16(buf, sta->aid);
5f92659d
BC
264
265 /* IE: supp + ext. supp rates */
266 pos = hostapd_eid_supp_rates(bss, supp_rates);
267 pos = hostapd_eid_ext_supp_rates(bss, pos);
268 wpabuf_put_data(buf, supp_rates, pos - supp_rates);
269
f029c44c
MH
270 /* IE: RSN IE */
271 wpabuf_put_data(buf, conf->rsn_ie, conf->rsn_ie_len);
272
5f92659d
BC
273 /* IE: Mesh ID */
274 wpabuf_put_u8(buf, WLAN_EID_MESH_ID);
275 wpabuf_put_u8(buf, conf->meshid_len);
276 wpabuf_put_data(buf, conf->meshid, conf->meshid_len);
277
278 /* IE: mesh conf */
279 wpabuf_put_u8(buf, WLAN_EID_MESH_CONFIG);
280 wpabuf_put_u8(buf, 7);
281 wpabuf_put_u8(buf, conf->mesh_pp_id);
282 wpabuf_put_u8(buf, conf->mesh_pm_id);
283 wpabuf_put_u8(buf, conf->mesh_cc_id);
284 wpabuf_put_u8(buf, conf->mesh_sp_id);
285 wpabuf_put_u8(buf, conf->mesh_auth_id);
d5b95325
MH
286 info = (bss->num_plinks > 63 ? 63 : bss->num_plinks) << 1;
287 /* TODO: Add Connected to Mesh Gate/AS subfields */
288 wpabuf_put_u8(buf, info);
5f92659d 289 /* always forwarding & accepting plinks for now */
5a8e48fd
MH
290 wpabuf_put_u8(buf, MESH_CAP_ACCEPT_ADDITIONAL_PEER |
291 MESH_CAP_FORWARDING);
5f92659d
BC
292 } else { /* Peer closing frame */
293 /* IE: Mesh ID */
294 wpabuf_put_u8(buf, WLAN_EID_MESH_ID);
295 wpabuf_put_u8(buf, conf->meshid_len);
296 wpabuf_put_data(buf, conf->meshid, conf->meshid_len);
297 }
298
299 /* IE: Mesh Peering Management element */
300 ie_len = 4;
301 if (ampe)
302 ie_len += PMKID_LEN;
303 switch (type) {
304 case PLINK_OPEN:
305 break;
306 case PLINK_CONFIRM:
307 ie_len += 2;
308 add_plid = 1;
309 break;
310 case PLINK_CLOSE:
311 ie_len += 2;
312 add_plid = 1;
313 ie_len += 2; /* reason code */
314 break;
315 }
316
317 wpabuf_put_u8(buf, WLAN_EID_PEER_MGMT);
318 wpabuf_put_u8(buf, ie_len);
319 /* peering protocol */
320 if (ampe)
321 wpabuf_put_le16(buf, 1);
322 else
323 wpabuf_put_le16(buf, 0);
324 wpabuf_put_le16(buf, sta->my_lid);
325 if (add_plid)
326 wpabuf_put_le16(buf, sta->peer_lid);
327 if (type == PLINK_CLOSE)
328 wpabuf_put_le16(buf, close_reason);
608b0ff5
JM
329 if (ampe) {
330 if (sta->sae == NULL) {
331 wpa_msg(wpa_s, MSG_INFO, "Mesh MPM: no SAE session");
332 goto fail;
333 }
0f950df0
TP
334 mesh_rsn_get_pmkid(wpa_s->mesh_rsn, sta,
335 wpabuf_put(buf, PMKID_LEN));
608b0ff5 336 }
5f92659d 337
5cfb672d 338#ifdef CONFIG_IEEE80211N
6334330e 339 if (type != PLINK_CLOSE && wpa_s->mesh_ht_enabled) {
a65efbfb
PO
340 u8 ht_capa_oper[2 + 26 + 2 + 22];
341
5cfb672d
JM
342 pos = hostapd_eid_ht_capabilities(bss, ht_capa_oper);
343 pos = hostapd_eid_ht_operation(bss, pos);
344 wpabuf_put_data(buf, ht_capa_oper, pos - ht_capa_oper);
345 }
346#endif /* CONFIG_IEEE80211N */
a65efbfb
PO
347#ifdef CONFIG_IEEE80211AC
348 if (type != PLINK_CLOSE && wpa_s->mesh_vht_enabled) {
349 u8 vht_capa_oper[2 + 12 + 2 + 5];
350
351 pos = hostapd_eid_vht_capabilities(bss, vht_capa_oper);
352 pos = hostapd_eid_vht_operation(bss, pos);
353 wpabuf_put_data(buf, vht_capa_oper, pos - vht_capa_oper);
354 }
355#endif /* CONFIG_IEEE80211AC */
5f92659d 356
0f950df0
TP
357 if (ampe && mesh_rsn_protect_frame(wpa_s->mesh_rsn, sta, cat, buf)) {
358 wpa_msg(wpa_s, MSG_INFO,
359 "Mesh MPM: failed to add AMPE and MIC IE");
360 goto fail;
361 }
362
b5f5c324
JM
363 wpa_msg(wpa_s, MSG_DEBUG, "Mesh MPM: Sending peering frame type %d to "
364 MACSTR " (my_lid=0x%x peer_lid=0x%x)",
365 type, MAC2STR(sta->addr), sta->my_lid, sta->peer_lid);
5f92659d
BC
366 ret = wpa_drv_send_action(wpa_s, wpa_s->assoc_freq, 0,
367 sta->addr, wpa_s->own_addr, wpa_s->own_addr,
368 wpabuf_head(buf), wpabuf_len(buf), 0);
369 if (ret < 0)
370 wpa_msg(wpa_s, MSG_INFO,
371 "Mesh MPM: failed to send peering frame");
372
0f950df0 373fail:
5f92659d
BC
374 wpabuf_free(buf);
375}
376
377
378/* configure peering state in ours and driver's station entry */
871ff0b7
MH
379void wpa_mesh_set_plink_state(struct wpa_supplicant *wpa_s,
380 struct sta_info *sta,
381 enum mesh_plink_state state)
5f92659d
BC
382{
383 struct hostapd_sta_add_params params;
384 int ret;
385
b5f5c324
JM
386 wpa_msg(wpa_s, MSG_DEBUG, "MPM set " MACSTR " from %s into %s",
387 MAC2STR(sta->addr), mplstate[sta->plink_state],
388 mplstate[state]);
5f92659d
BC
389 sta->plink_state = state;
390
391 os_memset(&params, 0, sizeof(params));
392 params.addr = sta->addr;
393 params.plink_state = state;
e347cafe 394 params.peer_aid = sta->peer_aid;
5f92659d
BC
395 params.set = 1;
396
5f92659d
BC
397 ret = wpa_drv_sta_add(wpa_s, &params);
398 if (ret) {
399 wpa_msg(wpa_s, MSG_ERROR, "Driver failed to set " MACSTR
400 ": %d", MAC2STR(sta->addr), ret);
401 }
402}
403
404
405static void mesh_mpm_fsm_restart(struct wpa_supplicant *wpa_s,
406 struct sta_info *sta)
407{
408 struct hostapd_data *hapd = wpa_s->ifmsh->bss[0];
409
410 eloop_cancel_timeout(plink_timer, wpa_s, sta);
411
41bff862 412 ap_free_sta(hapd, sta);
5f92659d
BC
413}
414
415
416static void plink_timer(void *eloop_ctx, void *user_data)
417{
418 struct wpa_supplicant *wpa_s = eloop_ctx;
419 struct sta_info *sta = user_data;
420 u16 reason = 0;
e6096799 421 struct mesh_conf *conf = wpa_s->ifmsh->mconf;
9f2cf23e 422 struct hostapd_data *hapd = wpa_s->ifmsh->bss[0];
5f92659d
BC
423
424 switch (sta->plink_state) {
d02e5498
JM
425 case PLINK_OPN_RCVD:
426 case PLINK_OPN_SNT:
5f92659d 427 /* retry timer */
e6096799
MH
428 if (sta->mpm_retries < conf->dot11MeshMaxRetries) {
429 eloop_register_timeout(
430 conf->dot11MeshRetryTimeout / 1000,
431 (conf->dot11MeshRetryTimeout % 1000) * 1000,
432 plink_timer, wpa_s, sta);
5f92659d
BC
433 mesh_mpm_send_plink_action(wpa_s, sta, PLINK_OPEN, 0);
434 sta->mpm_retries++;
435 break;
436 }
437 reason = WLAN_REASON_MESH_MAX_RETRIES;
438 /* fall through on else */
439
440 case PLINK_CNF_RCVD:
441 /* confirm timer */
442 if (!reason)
443 reason = WLAN_REASON_MESH_CONFIRM_TIMEOUT;
871ff0b7 444 wpa_mesh_set_plink_state(wpa_s, sta, PLINK_HOLDING);
e6096799
MH
445 eloop_register_timeout(conf->dot11MeshHoldingTimeout / 1000,
446 (conf->dot11MeshHoldingTimeout % 1000) * 1000,
447 plink_timer, wpa_s, sta);
5f92659d
BC
448 mesh_mpm_send_plink_action(wpa_s, sta, PLINK_CLOSE, reason);
449 break;
450 case PLINK_HOLDING:
451 /* holding timer */
9f2cf23e
MH
452
453 if (sta->mesh_sae_pmksa_caching) {
454 wpa_printf(MSG_DEBUG, "MPM: Peer " MACSTR
455 " looks like it does not support mesh SAE PMKSA caching, so remove the cached entry for it",
456 MAC2STR(sta->addr));
457 wpa_auth_pmksa_remove(hapd->wpa_auth, sta->addr);
458 }
5f92659d
BC
459 mesh_mpm_fsm_restart(wpa_s, sta);
460 break;
461 default:
462 break;
463 }
464}
465
466
467/* initiate peering with station */
468static void
469mesh_mpm_plink_open(struct wpa_supplicant *wpa_s, struct sta_info *sta,
470 enum mesh_plink_state next_state)
471{
e6096799
MH
472 struct mesh_conf *conf = wpa_s->ifmsh->mconf;
473
5f92659d 474 eloop_cancel_timeout(plink_timer, wpa_s, sta);
e6096799
MH
475 eloop_register_timeout(conf->dot11MeshRetryTimeout / 1000,
476 (conf->dot11MeshRetryTimeout % 1000) * 1000,
477 plink_timer, wpa_s, sta);
5f92659d
BC
478 mesh_mpm_send_plink_action(wpa_s, sta, PLINK_OPEN, 0);
479 wpa_mesh_set_plink_state(wpa_s, sta, next_state);
480}
481
482
e174ef34
MH
483static int mesh_mpm_plink_close(struct hostapd_data *hapd, struct sta_info *sta,
484 void *ctx)
5f92659d
BC
485{
486 struct wpa_supplicant *wpa_s = ctx;
487 int reason = WLAN_REASON_MESH_PEERING_CANCELLED;
488
489 if (sta) {
490 wpa_mesh_set_plink_state(wpa_s, sta, PLINK_HOLDING);
491 mesh_mpm_send_plink_action(wpa_s, sta, PLINK_CLOSE, reason);
492 wpa_printf(MSG_DEBUG, "MPM closing plink sta=" MACSTR,
493 MAC2STR(sta->addr));
494 eloop_cancel_timeout(plink_timer, wpa_s, sta);
495 return 0;
496 }
497
498 return 1;
499}
500
501
e174ef34
MH
502int mesh_mpm_close_peer(struct wpa_supplicant *wpa_s, const u8 *addr)
503{
504 struct hostapd_data *hapd;
505 struct sta_info *sta;
506
507 if (!wpa_s->ifmsh) {
508 wpa_msg(wpa_s, MSG_INFO, "Mesh is not prepared yet");
509 return -1;
510 }
511
512 hapd = wpa_s->ifmsh->bss[0];
513 sta = ap_get_sta(hapd, addr);
514 if (!sta) {
515 wpa_msg(wpa_s, MSG_INFO, "No such mesh peer");
516 return -1;
517 }
518
519 return mesh_mpm_plink_close(hapd, sta, wpa_s) == 0 ? 0 : -1;
520}
521
522
9f2cf23e
MH
523static void peer_add_timer(void *eloop_ctx, void *user_data)
524{
525 struct wpa_supplicant *wpa_s = eloop_ctx;
526 struct hostapd_data *hapd = wpa_s->ifmsh->bss[0];
527
528 os_memset(hapd->mesh_required_peer, 0, ETH_ALEN);
529}
530
531
532int mesh_mpm_connect_peer(struct wpa_supplicant *wpa_s, const u8 *addr,
533 int duration)
2604edbf
MH
534{
535 struct wpa_ssid *ssid = wpa_s->current_ssid;
536 struct hostapd_data *hapd;
537 struct sta_info *sta;
538 struct mesh_conf *conf;
539
540 if (!wpa_s->ifmsh) {
541 wpa_msg(wpa_s, MSG_INFO, "Mesh is not prepared yet");
542 return -1;
543 }
544
545 if (!ssid || !ssid->no_auto_peer) {
546 wpa_msg(wpa_s, MSG_INFO,
547 "This command is available only with no_auto_peer mesh network");
548 return -1;
549 }
550
551 hapd = wpa_s->ifmsh->bss[0];
552 conf = wpa_s->ifmsh->mconf;
553
554 sta = ap_get_sta(hapd, addr);
555 if (!sta) {
556 wpa_msg(wpa_s, MSG_INFO, "No such mesh peer");
557 return -1;
558 }
559
d02e5498 560 if ((PLINK_OPN_SNT <= sta->plink_state &&
2604edbf
MH
561 sta->plink_state <= PLINK_ESTAB) ||
562 (sta->sae && sta->sae->state > SAE_NOTHING)) {
563 wpa_msg(wpa_s, MSG_INFO,
564 "Specified peer is connecting/connected");
565 return -1;
566 }
567
9f2cf23e 568 if (conf->security == MESH_CONF_SEC_NONE) {
d02e5498 569 mesh_mpm_plink_open(wpa_s, sta, PLINK_OPN_SNT);
9f2cf23e 570 } else {
2604edbf 571 mesh_rsn_auth_sae_sta(wpa_s, sta);
9f2cf23e
MH
572 os_memcpy(hapd->mesh_required_peer, addr, ETH_ALEN);
573 eloop_register_timeout(duration == -1 ? 10 : duration, 0,
574 peer_add_timer, wpa_s, NULL);
575 }
2604edbf
MH
576
577 return 0;
578}
579
580
5f92659d
BC
581void mesh_mpm_deinit(struct wpa_supplicant *wpa_s, struct hostapd_iface *ifmsh)
582{
583 struct hostapd_data *hapd = ifmsh->bss[0];
584
585 /* notify peers we're leaving */
586 ap_for_each_sta(hapd, mesh_mpm_plink_close, wpa_s);
587
588 hapd->num_plinks = 0;
589 hostapd_free_stas(hapd);
9f2cf23e 590 eloop_cancel_timeout(peer_add_timer, wpa_s, NULL);
5f92659d
BC
591}
592
593
594/* for mesh_rsn to indicate this peer has completed authentication, and we're
595 * ready to start AMPE */
596void mesh_mpm_auth_peer(struct wpa_supplicant *wpa_s, const u8 *addr)
597{
598 struct hostapd_data *data = wpa_s->ifmsh->bss[0];
599 struct hostapd_sta_add_params params;
600 struct sta_info *sta;
601 int ret;
602
603 sta = ap_get_sta(data, addr);
604 if (!sta) {
605 wpa_msg(wpa_s, MSG_DEBUG, "no such mesh peer");
606 return;
607 }
608
609 /* TODO: Should do nothing if this STA is already authenticated, but
610 * the AP code already sets this flag. */
611 sta->flags |= WLAN_STA_AUTH;
612
0f950df0
TP
613 mesh_rsn_init_ampe_sta(wpa_s, sta);
614
5f92659d
BC
615 os_memset(&params, 0, sizeof(params));
616 params.addr = sta->addr;
617 params.flags = WPA_STA_AUTHENTICATED | WPA_STA_AUTHORIZED;
618 params.set = 1;
619
620 wpa_msg(wpa_s, MSG_DEBUG, "MPM authenticating " MACSTR,
621 MAC2STR(sta->addr));
622 ret = wpa_drv_sta_add(wpa_s, &params);
623 if (ret) {
624 wpa_msg(wpa_s, MSG_ERROR,
625 "Driver failed to set " MACSTR ": %d",
626 MAC2STR(sta->addr), ret);
627 }
628
629 if (!sta->my_lid)
630 mesh_mpm_init_link(wpa_s, sta);
631
d02e5498 632 mesh_mpm_plink_open(wpa_s, sta, PLINK_OPN_SNT);
5f92659d
BC
633}
634
745d9369
BC
635/*
636 * Initialize a sta_info structure for a peer and upload it into the driver
637 * in preparation for beginning authentication or peering. This is done when a
638 * Beacon (secure or open mesh) or a peering open frame (for open mesh) is
639 * received from the peer for the first time.
640 */
641static struct sta_info * mesh_mpm_add_peer(struct wpa_supplicant *wpa_s,
642 const u8 *addr,
643 struct ieee802_11_elems *elems)
5f92659d
BC
644{
645 struct hostapd_sta_add_params params;
646 struct mesh_conf *conf = wpa_s->ifmsh->mconf;
647 struct hostapd_data *data = wpa_s->ifmsh->bss[0];
648 struct sta_info *sta;
745d9369 649 int ret;
5f92659d 650
d70a8ab1
MH
651 if (elems->mesh_config_len >= 7 &&
652 !(elems->mesh_config[6] & MESH_CAP_ACCEPT_ADDITIONAL_PEER)) {
653 wpa_msg(wpa_s, MSG_DEBUG,
654 "mesh: Ignore a crowded peer " MACSTR,
655 MAC2STR(addr));
656 return NULL;
657 }
658
5f92659d
BC
659 sta = ap_get_sta(data, addr);
660 if (!sta) {
661 sta = ap_sta_add(data, addr);
662 if (!sta)
745d9369 663 return NULL;
5f92659d
BC
664 }
665
a73c9842
PO
666 /* Set WMM by default since Mesh STAs are QoS STAs */
667 sta->flags |= WLAN_STA_WMM;
668
5f92659d 669 /* initialize sta */
745d9369
BC
670 if (copy_supp_rates(wpa_s, sta, elems)) {
671 ap_free_sta(data, sta);
672 return NULL;
673 }
5f92659d 674
cc64fe7b
JM
675 if (!sta->my_lid)
676 mesh_mpm_init_link(wpa_s, sta);
5f92659d 677
5cfb672d 678#ifdef CONFIG_IEEE80211N
baae4cb9 679 copy_sta_ht_capab(data, sta, elems->ht_capabilities);
5cfb672d
JM
680 update_ht_state(data, sta);
681#endif /* CONFIG_IEEE80211N */
682
a65efbfb
PO
683#ifdef CONFIG_IEEE80211AC
684 copy_sta_vht_capab(data, sta, elems->vht_capabilities);
685 set_sta_vht_opmode(data, sta, elems->vht_opmode_notif);
686#endif /* CONFIG_IEEE80211AC */
687
681753f2
BC
688 if (hostapd_get_aid(data, sta) < 0) {
689 wpa_msg(wpa_s, MSG_ERROR, "No AIDs available");
690 ap_free_sta(data, sta);
691 return NULL;
692 }
693
5f92659d
BC
694 /* insert into driver */
695 os_memset(&params, 0, sizeof(params));
696 params.supp_rates = sta->supported_rates;
697 params.supp_rates_len = sta->supported_rates_len;
698 params.addr = addr;
699 params.plink_state = sta->plink_state;
681753f2 700 params.aid = sta->aid;
e347cafe 701 params.peer_aid = sta->peer_aid;
5f92659d 702 params.listen_interval = 100;
5cfb672d 703 params.ht_capabilities = sta->ht_capabilities;
a65efbfb 704 params.vht_capabilities = sta->vht_capabilities;
5f92659d
BC
705 params.flags |= WPA_STA_WMM;
706 params.flags_mask |= WPA_STA_AUTHENTICATED;
707 if (conf->security == MESH_CONF_SEC_NONE) {
708 params.flags |= WPA_STA_AUTHORIZED;
709 params.flags |= WPA_STA_AUTHENTICATED;
710 } else {
711 sta->flags |= WLAN_STA_MFP;
712 params.flags |= WPA_STA_MFP;
713 }
714
715 ret = wpa_drv_sta_add(wpa_s, &params);
716 if (ret) {
717 wpa_msg(wpa_s, MSG_ERROR,
718 "Driver failed to insert " MACSTR ": %d",
719 MAC2STR(addr), ret);
745d9369
BC
720 ap_free_sta(data, sta);
721 return NULL;
5f92659d
BC
722 }
723
745d9369
BC
724 return sta;
725}
726
727
728void wpa_mesh_new_mesh_peer(struct wpa_supplicant *wpa_s, const u8 *addr,
729 struct ieee802_11_elems *elems)
730{
731 struct mesh_conf *conf = wpa_s->ifmsh->mconf;
732 struct hostapd_data *data = wpa_s->ifmsh->bss[0];
733 struct sta_info *sta;
734 struct wpa_ssid *ssid = wpa_s->current_ssid;
735
736 sta = mesh_mpm_add_peer(wpa_s, addr, elems);
737 if (!sta)
738 return;
739
9f2cf23e
MH
740 if (ssid && ssid->no_auto_peer &&
741 (is_zero_ether_addr(data->mesh_required_peer) ||
742 os_memcmp(data->mesh_required_peer, addr, ETH_ALEN) != 0)) {
07cb45cc
TP
743 wpa_msg(wpa_s, MSG_INFO, "will not initiate new peer link with "
744 MACSTR " because of no_auto_peer", MAC2STR(addr));
3a322496
JM
745 if (data->mesh_pending_auth) {
746 struct os_reltime age;
747 const struct ieee80211_mgmt *mgmt;
748 struct hostapd_frame_info fi;
749
750 mgmt = wpabuf_head(data->mesh_pending_auth);
751 os_reltime_age(&data->mesh_pending_auth_time, &age);
752 if (age.sec < 2 &&
753 os_memcmp(mgmt->sa, addr, ETH_ALEN) == 0) {
754 wpa_printf(MSG_DEBUG,
755 "mesh: Process pending Authentication frame from %u.%06u seconds ago",
756 (unsigned int) age.sec,
757 (unsigned int) age.usec);
758 os_memset(&fi, 0, sizeof(fi));
759 ieee802_11_mgmt(
760 data,
761 wpabuf_head(data->mesh_pending_auth),
762 wpabuf_len(data->mesh_pending_auth),
763 &fi);
764 }
765 wpabuf_free(data->mesh_pending_auth);
766 data->mesh_pending_auth = NULL;
767 }
07cb45cc
TP
768 return;
769 }
770
27446e47 771 if (conf->security == MESH_CONF_SEC_NONE) {
d02e5498 772 if (sta->plink_state < PLINK_OPN_SNT ||
27446e47 773 sta->plink_state > PLINK_ESTAB)
d02e5498 774 mesh_mpm_plink_open(wpa_s, sta, PLINK_OPN_SNT);
27446e47 775 } else {
0f950df0 776 mesh_rsn_auth_sae_sta(wpa_s, sta);
27446e47 777 }
5f92659d
BC
778}
779
780
781void mesh_mpm_mgmt_rx(struct wpa_supplicant *wpa_s, struct rx_mgmt *rx_mgmt)
782{
783 struct hostapd_frame_info fi;
784
785 os_memset(&fi, 0, sizeof(fi));
786 fi.datarate = rx_mgmt->datarate;
787 fi.ssi_signal = rx_mgmt->ssi_signal;
788 ieee802_11_mgmt(wpa_s->ifmsh->bss[0], rx_mgmt->frame,
789 rx_mgmt->frame_len, &fi);
790}
791
792
793static void mesh_mpm_plink_estab(struct wpa_supplicant *wpa_s,
794 struct sta_info *sta)
795{
796 struct hostapd_data *hapd = wpa_s->ifmsh->bss[0];
0f950df0
TP
797 struct mesh_conf *conf = wpa_s->ifmsh->mconf;
798 u8 seq[6] = {};
5f92659d
BC
799
800 wpa_msg(wpa_s, MSG_INFO, "mesh plink with " MACSTR " established",
801 MAC2STR(sta->addr));
802
0f950df0 803 if (conf->security & MESH_CONF_SEC_AMPE) {
b02f4d05 804 wpa_hexdump_key(MSG_DEBUG, "mesh: MTK", sta->mtk, sta->mtk_len);
3b6deac0
JM
805 wpa_drv_set_key(wpa_s, wpa_cipher_to_alg(conf->pairwise_cipher),
806 sta->addr, 0, 0, seq, sizeof(seq),
807 sta->mtk, sta->mtk_len);
a4eec3c2 808
f868d560
JM
809 wpa_hexdump_key(MSG_DEBUG, "mesh: RX MGTK Key RSC",
810 sta->mgtk_rsc, sizeof(sta->mgtk_rsc));
a4eec3c2
JM
811 wpa_hexdump_key(MSG_DEBUG, "mesh: RX MGTK",
812 sta->mgtk, sta->mgtk_len);
3b6deac0
JM
813 wpa_drv_set_key(wpa_s, wpa_cipher_to_alg(conf->group_cipher),
814 sta->addr, sta->mgtk_key_id, 0,
f868d560 815 sta->mgtk_rsc, sizeof(sta->mgtk_rsc),
a4eec3c2 816 sta->mgtk, sta->mgtk_len);
4367eec4
JM
817
818 if (sta->igtk_len) {
f868d560
JM
819 wpa_hexdump_key(MSG_DEBUG, "mesh: RX IGTK Key RSC",
820 sta->igtk_rsc, sizeof(sta->igtk_rsc));
3b6deac0 821 wpa_hexdump_key(MSG_DEBUG, "mesh: RX IGTK",
4367eec4 822 sta->igtk, sta->igtk_len);
3b6deac0
JM
823 wpa_drv_set_key(
824 wpa_s,
825 wpa_cipher_to_alg(conf->mgmt_group_cipher),
826 sta->addr, sta->igtk_key_id, 0,
827 sta->igtk_rsc, sizeof(sta->igtk_rsc),
828 sta->igtk, sta->igtk_len);
4367eec4 829 }
0f950df0
TP
830 }
831
5f92659d
BC
832 wpa_mesh_set_plink_state(wpa_s, sta, PLINK_ESTAB);
833 hapd->num_plinks++;
834
835 sta->flags |= WLAN_STA_ASSOC;
9f2cf23e 836 sta->mesh_sae_pmksa_caching = 0;
5f92659d 837
9f2cf23e
MH
838 eloop_cancel_timeout(peer_add_timer, wpa_s, NULL);
839 peer_add_timer(wpa_s, NULL);
5f92659d
BC
840 eloop_cancel_timeout(plink_timer, wpa_s, sta);
841
842 /* Send ctrl event */
6174de66
JM
843 wpa_msg(wpa_s, MSG_INFO, MESH_PEER_CONNECTED MACSTR,
844 MAC2STR(sta->addr));
5f92659d
BC
845}
846
847
848static void mesh_mpm_fsm(struct wpa_supplicant *wpa_s, struct sta_info *sta,
02022564 849 enum plink_event event, u16 reason)
5f92659d
BC
850{
851 struct hostapd_data *hapd = wpa_s->ifmsh->bss[0];
0f950df0 852 struct mesh_conf *conf = wpa_s->ifmsh->mconf;
5f92659d
BC
853
854 wpa_msg(wpa_s, MSG_DEBUG, "MPM " MACSTR " state %s event %s",
855 MAC2STR(sta->addr), mplstate[sta->plink_state],
856 mplevent[event]);
857
858 switch (sta->plink_state) {
d02e5498 859 case PLINK_IDLE:
5f92659d
BC
860 switch (event) {
861 case CLS_ACPT:
862 mesh_mpm_fsm_restart(wpa_s, sta);
863 break;
864 case OPN_ACPT:
d02e5498 865 mesh_mpm_plink_open(wpa_s, sta, PLINK_OPN_RCVD);
5f92659d
BC
866 mesh_mpm_send_plink_action(wpa_s, sta, PLINK_CONFIRM,
867 0);
868 break;
02022564
JM
869 case REQ_RJCT:
870 mesh_mpm_send_plink_action(wpa_s, sta,
871 PLINK_CLOSE, reason);
872 break;
5f92659d
BC
873 default:
874 break;
875 }
876 break;
d02e5498 877 case PLINK_OPN_SNT:
5f92659d
BC
878 switch (event) {
879 case OPN_RJCT:
880 case CNF_RJCT:
02022564
JM
881 if (!reason)
882 reason = WLAN_REASON_MESH_CONFIG_POLICY_VIOLATION;
5f92659d
BC
883 /* fall-through */
884 case CLS_ACPT:
885 wpa_mesh_set_plink_state(wpa_s, sta, PLINK_HOLDING);
886 if (!reason)
887 reason = WLAN_REASON_MESH_CLOSE_RCVD;
e6096799
MH
888 eloop_register_timeout(
889 conf->dot11MeshHoldingTimeout / 1000,
890 (conf->dot11MeshHoldingTimeout % 1000) * 1000,
891 plink_timer, wpa_s, sta);
5f92659d
BC
892 mesh_mpm_send_plink_action(wpa_s, sta,
893 PLINK_CLOSE, reason);
894 break;
895 case OPN_ACPT:
896 /* retry timer is left untouched */
d02e5498 897 wpa_mesh_set_plink_state(wpa_s, sta, PLINK_OPN_RCVD);
5f92659d
BC
898 mesh_mpm_send_plink_action(wpa_s, sta,
899 PLINK_CONFIRM, 0);
900 break;
901 case CNF_ACPT:
902 wpa_mesh_set_plink_state(wpa_s, sta, PLINK_CNF_RCVD);
baa12136 903 eloop_cancel_timeout(plink_timer, wpa_s, sta);
e6096799
MH
904 eloop_register_timeout(
905 conf->dot11MeshConfirmTimeout / 1000,
906 (conf->dot11MeshConfirmTimeout % 1000) * 1000,
907 plink_timer, wpa_s, sta);
5f92659d
BC
908 break;
909 default:
910 break;
911 }
912 break;
d02e5498 913 case PLINK_OPN_RCVD:
5f92659d
BC
914 switch (event) {
915 case OPN_RJCT:
916 case CNF_RJCT:
02022564
JM
917 if (!reason)
918 reason = WLAN_REASON_MESH_CONFIG_POLICY_VIOLATION;
5f92659d
BC
919 /* fall-through */
920 case CLS_ACPT:
921 wpa_mesh_set_plink_state(wpa_s, sta, PLINK_HOLDING);
922 if (!reason)
923 reason = WLAN_REASON_MESH_CLOSE_RCVD;
e6096799
MH
924 eloop_register_timeout(
925 conf->dot11MeshHoldingTimeout / 1000,
926 (conf->dot11MeshHoldingTimeout % 1000) * 1000,
927 plink_timer, wpa_s, sta);
5f92659d
BC
928 sta->mpm_close_reason = reason;
929 mesh_mpm_send_plink_action(wpa_s, sta,
930 PLINK_CLOSE, reason);
931 break;
932 case OPN_ACPT:
933 mesh_mpm_send_plink_action(wpa_s, sta,
934 PLINK_CONFIRM, 0);
935 break;
936 case CNF_ACPT:
0f950df0
TP
937 if (conf->security & MESH_CONF_SEC_AMPE)
938 mesh_rsn_derive_mtk(wpa_s, sta);
5f92659d
BC
939 mesh_mpm_plink_estab(wpa_s, sta);
940 break;
941 default:
942 break;
943 }
944 break;
945 case PLINK_CNF_RCVD:
946 switch (event) {
947 case OPN_RJCT:
948 case CNF_RJCT:
02022564
JM
949 if (!reason)
950 reason = WLAN_REASON_MESH_CONFIG_POLICY_VIOLATION;
5f92659d
BC
951 /* fall-through */
952 case CLS_ACPT:
953 wpa_mesh_set_plink_state(wpa_s, sta, PLINK_HOLDING);
954 if (!reason)
955 reason = WLAN_REASON_MESH_CLOSE_RCVD;
e6096799
MH
956 eloop_register_timeout(
957 conf->dot11MeshHoldingTimeout / 1000,
958 (conf->dot11MeshHoldingTimeout % 1000) * 1000,
959 plink_timer, wpa_s, sta);
5f92659d
BC
960 sta->mpm_close_reason = reason;
961 mesh_mpm_send_plink_action(wpa_s, sta,
962 PLINK_CLOSE, reason);
963 break;
964 case OPN_ACPT:
f42c3ceb
PO
965 if (conf->security & MESH_CONF_SEC_AMPE)
966 mesh_rsn_derive_mtk(wpa_s, sta);
5f92659d
BC
967 mesh_mpm_plink_estab(wpa_s, sta);
968 mesh_mpm_send_plink_action(wpa_s, sta,
969 PLINK_CONFIRM, 0);
970 break;
971 default:
972 break;
973 }
974 break;
975 case PLINK_ESTAB:
976 switch (event) {
78ac3685
JM
977 case OPN_RJCT:
978 case CNF_RJCT:
5f92659d
BC
979 case CLS_ACPT:
980 wpa_mesh_set_plink_state(wpa_s, sta, PLINK_HOLDING);
02022564
JM
981 if (!reason)
982 reason = WLAN_REASON_MESH_CLOSE_RCVD;
5f92659d 983
e6096799
MH
984 eloop_register_timeout(
985 conf->dot11MeshHoldingTimeout / 1000,
986 (conf->dot11MeshHoldingTimeout % 1000) * 1000,
987 plink_timer, wpa_s, sta);
5f92659d
BC
988 sta->mpm_close_reason = reason;
989
990 wpa_msg(wpa_s, MSG_INFO, "mesh plink with " MACSTR
991 " closed with reason %d",
992 MAC2STR(sta->addr), reason);
993
6174de66
JM
994 wpa_msg(wpa_s, MSG_INFO, MESH_PEER_DISCONNECTED MACSTR,
995 MAC2STR(sta->addr));
5f92659d
BC
996
997 hapd->num_plinks--;
998
999 mesh_mpm_send_plink_action(wpa_s, sta,
1000 PLINK_CLOSE, reason);
1001 break;
1002 case OPN_ACPT:
1003 mesh_mpm_send_plink_action(wpa_s, sta,
1004 PLINK_CONFIRM, 0);
1005 break;
1006 default:
1007 break;
1008 }
1009 break;
1010 case PLINK_HOLDING:
1011 switch (event) {
1012 case CLS_ACPT:
1013 mesh_mpm_fsm_restart(wpa_s, sta);
1014 break;
1015 case OPN_ACPT:
1016 case CNF_ACPT:
1017 case OPN_RJCT:
1018 case CNF_RJCT:
1019 reason = sta->mpm_close_reason;
1020 mesh_mpm_send_plink_action(wpa_s, sta,
1021 PLINK_CLOSE, reason);
1022 break;
1023 default:
1024 break;
1025 }
1026 break;
1027 default:
1028 wpa_msg(wpa_s, MSG_DEBUG,
1029 "Unsupported MPM event %s for state %s",
1030 mplevent[event], mplstate[sta->plink_state]);
1031 break;
1032 }
1033}
1034
1035
1036void mesh_mpm_action_rx(struct wpa_supplicant *wpa_s,
1037 const struct ieee80211_mgmt *mgmt, size_t len)
1038{
1039 u8 action_field;
1040 struct hostapd_data *hapd = wpa_s->ifmsh->bss[0];
0f950df0 1041 struct mesh_conf *mconf = wpa_s->ifmsh->mconf;
5f92659d 1042 struct sta_info *sta;
e347cafe 1043 u16 plid = 0, llid = 0, aid = 0;
5f92659d
BC
1044 enum plink_event event;
1045 struct ieee802_11_elems elems;
1046 struct mesh_peer_mgmt_ie peer_mgmt_ie;
1047 const u8 *ies;
1048 size_t ie_len;
1049 int ret;
02022564 1050 u16 reason = 0;
5f92659d
BC
1051
1052 if (mgmt->u.action.category != WLAN_ACTION_SELF_PROTECTED)
1053 return;
1054
1055 action_field = mgmt->u.action.u.slf_prot_action.action;
c932b43e
JM
1056 if (action_field != PLINK_OPEN &&
1057 action_field != PLINK_CONFIRM &&
1058 action_field != PLINK_CLOSE)
1059 return;
5f92659d
BC
1060
1061 ies = mgmt->u.action.u.slf_prot_action.variable;
1062 ie_len = (const u8 *) mgmt + len -
1063 mgmt->u.action.u.slf_prot_action.variable;
1064
1065 /* at least expect mesh id and peering mgmt */
c932b43e
JM
1066 if (ie_len < 2 + 2) {
1067 wpa_printf(MSG_DEBUG,
1068 "MPM: Ignore too short action frame %u ie_len %u",
1069 action_field, (unsigned int) ie_len);
5f92659d 1070 return;
c932b43e
JM
1071 }
1072 wpa_printf(MSG_DEBUG, "MPM: Received PLINK action %u", action_field);
5f92659d
BC
1073
1074 if (action_field == PLINK_OPEN || action_field == PLINK_CONFIRM) {
c932b43e
JM
1075 wpa_printf(MSG_DEBUG, "MPM: Capability 0x%x",
1076 WPA_GET_LE16(ies));
5f92659d
BC
1077 ies += 2; /* capability */
1078 ie_len -= 2;
1079 }
1080 if (action_field == PLINK_CONFIRM) {
e347cafe
MH
1081 aid = WPA_GET_LE16(ies);
1082 wpa_printf(MSG_DEBUG, "MPM: AID 0x%x", aid);
5f92659d
BC
1083 ies += 2; /* aid */
1084 ie_len -= 2;
1085 }
1086
1087 /* check for mesh peering, mesh id and mesh config IEs */
c932b43e
JM
1088 if (ieee802_11_parse_elems(ies, ie_len, &elems, 0) == ParseFailed) {
1089 wpa_printf(MSG_DEBUG, "MPM: Failed to parse PLINK IEs");
5f92659d 1090 return;
c932b43e
JM
1091 }
1092 if (!elems.peer_mgmt) {
1093 wpa_printf(MSG_DEBUG,
1094 "MPM: No Mesh Peering Management element");
5f92659d 1095 return;
c932b43e
JM
1096 }
1097 if (action_field != PLINK_CLOSE) {
1098 if (!elems.mesh_id || !elems.mesh_config) {
1099 wpa_printf(MSG_DEBUG,
1100 "MPM: No Mesh ID or Mesh Configuration element");
1101 return;
1102 }
5f92659d 1103
c932b43e
JM
1104 if (!matches_local(wpa_s, &elems)) {
1105 wpa_printf(MSG_DEBUG,
1106 "MPM: Mesh ID or Mesh Configuration element do not match local MBSS");
1107 return;
1108 }
1109 }
5f92659d
BC
1110
1111 ret = mesh_mpm_parse_peer_mgmt(wpa_s, action_field,
1112 elems.peer_mgmt,
1113 elems.peer_mgmt_len,
1114 &peer_mgmt_ie);
c932b43e
JM
1115 if (ret) {
1116 wpa_printf(MSG_DEBUG, "MPM: Mesh parsing rejected frame");
5f92659d 1117 return;
c932b43e 1118 }
5f92659d
BC
1119
1120 /* the sender's llid is our plid and vice-versa */
1121 plid = WPA_GET_LE16(peer_mgmt_ie.llid);
1122 if (peer_mgmt_ie.plid)
1123 llid = WPA_GET_LE16(peer_mgmt_ie.plid);
c932b43e 1124 wpa_printf(MSG_DEBUG, "MPM: plid=0x%x llid=0x%x", plid, llid);
5f92659d 1125
e8afaad7
JM
1126 if (action_field == PLINK_CLOSE)
1127 wpa_printf(MSG_DEBUG, "MPM: close reason=%u",
1128 WPA_GET_LE16(peer_mgmt_ie.reason));
1129
5f92659d 1130 sta = ap_get_sta(hapd, mgmt->sa);
745d9369
BC
1131
1132 /*
1133 * If this is an open frame from an unknown STA, and this is an
1134 * open mesh, then go ahead and add the peer before proceeding.
1135 */
1136 if (!sta && action_field == PLINK_OPEN &&
9f2cf23e
MH
1137 (!(mconf->security & MESH_CONF_SEC_AMPE) ||
1138 wpa_auth_pmksa_get(hapd->wpa_auth, mgmt->sa)))
745d9369
BC
1139 sta = mesh_mpm_add_peer(wpa_s, mgmt->sa, &elems);
1140
c932b43e
JM
1141 if (!sta) {
1142 wpa_printf(MSG_DEBUG, "MPM: No STA entry for peer");
5f92659d 1143 return;
c932b43e 1144 }
5f92659d 1145
0f950df0
TP
1146#ifdef CONFIG_SAE
1147 /* peer is in sae_accepted? */
c932b43e
JM
1148 if (sta->sae && sta->sae->state != SAE_ACCEPTED) {
1149 wpa_printf(MSG_DEBUG, "MPM: SAE not yet accepted for peer");
0f950df0 1150 return;
c932b43e 1151 }
0f950df0
TP
1152#endif /* CONFIG_SAE */
1153
5f92659d
BC
1154 if (!sta->my_lid)
1155 mesh_mpm_init_link(wpa_s, sta);
1156
1f2f3f1c
JM
1157 if (mconf->security & MESH_CONF_SEC_AMPE) {
1158 int res;
1159
1160 res = mesh_rsn_process_ampe(wpa_s, sta, &elems,
1161 &mgmt->u.action.category,
1162 peer_mgmt_ie.chosen_pmk,
1163 ies, ie_len);
1164 if (res) {
1165 wpa_printf(MSG_DEBUG,
1166 "MPM: RSN process rejected frame (res=%d)",
1167 res);
1168 if (action_field == PLINK_OPEN && res == -2) {
1169 /* AES-SIV decryption failed */
02022564
JM
1170 mesh_mpm_fsm(wpa_s, sta, OPN_RJCT,
1171 WLAN_REASON_MESH_INVALID_GTK);
1f2f3f1c
JM
1172 }
1173 return;
1174 }
c932b43e 1175 }
0f950df0 1176
c932b43e
JM
1177 if (sta->plink_state == PLINK_BLOCKED) {
1178 wpa_printf(MSG_DEBUG, "MPM: PLINK_BLOCKED");
5f92659d 1179 return;
c932b43e 1180 }
5f92659d
BC
1181
1182 /* Now we will figure out the appropriate event... */
1183 switch (action_field) {
1184 case PLINK_OPEN:
46e8d90f 1185 if (plink_free_count(hapd) == 0) {
02022564
JM
1186 event = REQ_RJCT;
1187 reason = WLAN_REASON_MESH_MAX_PEERS;
46e8d90f
MH
1188 wpa_printf(MSG_INFO,
1189 "MPM: Peer link num over quota(%d)",
1190 hapd->max_plinks);
1191 } else if (sta->peer_lid && sta->peer_lid != plid) {
8bd90996
JM
1192 wpa_printf(MSG_DEBUG,
1193 "MPM: peer_lid mismatch: 0x%x != 0x%x",
1194 sta->peer_lid, plid);
02022564 1195 return; /* no FSM event */
5f92659d
BC
1196 } else {
1197 sta->peer_lid = plid;
1198 event = OPN_ACPT;
1199 }
1200 break;
1201 case PLINK_CONFIRM:
46e8d90f 1202 if (plink_free_count(hapd) == 0) {
02022564
JM
1203 event = REQ_RJCT;
1204 reason = WLAN_REASON_MESH_MAX_PEERS;
46e8d90f
MH
1205 wpa_printf(MSG_INFO,
1206 "MPM: Peer link num over quota(%d)",
1207 hapd->max_plinks);
1208 } else if (sta->my_lid != llid ||
1209 (sta->peer_lid && sta->peer_lid != plid)) {
8bd90996
JM
1210 wpa_printf(MSG_DEBUG,
1211 "MPM: lid mismatch: my_lid: 0x%x != 0x%x or peer_lid: 0x%x != 0x%x",
1212 sta->my_lid, llid, sta->peer_lid, plid);
02022564 1213 return; /* no FSM event */
5f92659d
BC
1214 } else {
1215 if (!sta->peer_lid)
1216 sta->peer_lid = plid;
e347cafe 1217 sta->peer_aid = aid;
5f92659d
BC
1218 event = CNF_ACPT;
1219 }
1220 break;
1221 case PLINK_CLOSE:
1222 if (sta->plink_state == PLINK_ESTAB)
1223 /* Do not check for llid or plid. This does not
1224 * follow the standard but since multiple plinks
1225 * per cand are not supported, it is necessary in
1226 * order to avoid a livelock when MP A sees an
1227 * establish peer link to MP B but MP B does not
1228 * see it. This can be caused by a timeout in
1229 * B's peer link establishment or B being
1230 * restarted.
1231 */
1232 event = CLS_ACPT;
8bd90996
JM
1233 else if (sta->peer_lid != plid) {
1234 wpa_printf(MSG_DEBUG,
1235 "MPM: peer_lid mismatch: 0x%x != 0x%x",
1236 sta->peer_lid, plid);
02022564 1237 return; /* no FSM event */
8bd90996
JM
1238 } else if (peer_mgmt_ie.plid && sta->my_lid != llid) {
1239 wpa_printf(MSG_DEBUG,
1240 "MPM: my_lid mismatch: 0x%x != 0x%x",
1241 sta->my_lid, llid);
02022564 1242 return; /* no FSM event */
8bd90996 1243 } else {
5f92659d 1244 event = CLS_ACPT;
8bd90996 1245 }
5f92659d 1246 break;
763041b2
JM
1247 default:
1248 /*
1249 * This cannot be hit due to the action_field check above, but
1250 * compilers may not be able to figure that out and can warn
1251 * about uninitialized event below.
1252 */
1253 return;
5f92659d 1254 }
02022564 1255 mesh_mpm_fsm(wpa_s, sta, event, reason);
5f92659d 1256}
c596f3f0
CYY
1257
1258
1259/* called by ap_free_sta */
9684c756 1260void mesh_mpm_free_sta(struct hostapd_data *hapd, struct sta_info *sta)
c596f3f0 1261{
9684c756
SD
1262 if (sta->plink_state == PLINK_ESTAB)
1263 hapd->num_plinks--;
c596f3f0
CYY
1264 eloop_cancel_timeout(plink_timer, ELOOP_ALL_CTX, sta);
1265 eloop_cancel_timeout(mesh_auth_timer, ELOOP_ALL_CTX, sta);
1266}