xref: /dragonfly/contrib/wpa_supplicant/src/eapol_auth/eapol_auth_sm.c (revision 3a84a4273475ed07d0ab1c2dfeffdfedef35d9cd)
1 /*
2  * IEEE 802.1X-2004 Authenticator - EAPOL state machine
3  * Copyright (c) 2002-2015, Jouni Malinen <j@w1.fi>
4  *
5  * This software may be distributed under the terms of the BSD license.
6  * See README for more details.
7  */
8 
9 #include "includes.h"
10 
11 #include "common.h"
12 #include "eloop.h"
13 #include "state_machine.h"
14 #include "common/eapol_common.h"
15 #include "eap_common/eap_defs.h"
16 #include "eap_common/eap_common.h"
17 #include "eap_server/eap.h"
18 #include "eapol_auth_sm.h"
19 #include "eapol_auth_sm_i.h"
20 
21 #define STATE_MACHINE_DATA struct eapol_state_machine
22 #define STATE_MACHINE_DEBUG_PREFIX "IEEE 802.1X"
23 #define STATE_MACHINE_ADDR sm->addr
24 
25 static const struct eapol_callbacks eapol_cb;
26 
27 /* EAPOL state machines are described in IEEE Std 802.1X-2004, Chap. 8.2 */
28 
29 #define setPortAuthorized() \
30 sm->eapol->cb.set_port_authorized(sm->eapol->conf.ctx, sm->sta, 1)
31 #define setPortUnauthorized() \
32 sm->eapol->cb.set_port_authorized(sm->eapol->conf.ctx, sm->sta, 0)
33 
34 /* procedures */
35 #define txCannedFail() eapol_auth_tx_canned_eap(sm, 0)
36 #define txCannedSuccess() eapol_auth_tx_canned_eap(sm, 1)
37 #define txReq() eapol_auth_tx_req(sm)
38 #define abortAuth() sm->eapol->cb.abort_auth(sm->eapol->conf.ctx, sm->sta)
39 #define txKey() sm->eapol->cb.tx_key(sm->eapol->conf.ctx, sm->sta)
40 #define processKey() do { } while (0)
41 
42 
43 static void eapol_sm_step_run(struct eapol_state_machine *sm);
44 static void eapol_sm_step_cb(void *eloop_ctx, void *timeout_ctx);
45 static void eapol_auth_initialize(struct eapol_state_machine *sm);
46 static void eapol_auth_conf_free(struct eapol_auth_config *conf);
47 
48 
eapol_auth_logger(struct eapol_authenticator * eapol,const u8 * addr,eapol_logger_level level,const char * txt)49 static void eapol_auth_logger(struct eapol_authenticator *eapol,
50                                     const u8 *addr, eapol_logger_level level,
51                                     const char *txt)
52 {
53           if (eapol->cb.logger == NULL)
54                     return;
55           eapol->cb.logger(eapol->conf.ctx, addr, level, txt);
56 }
57 
58 
eapol_auth_vlogger(struct eapol_authenticator * eapol,const u8 * addr,eapol_logger_level level,const char * fmt,...)59 static void eapol_auth_vlogger(struct eapol_authenticator *eapol,
60                                      const u8 *addr, eapol_logger_level level,
61                                      const char *fmt, ...)
62 {
63           char *format;
64           int maxlen;
65           va_list ap;
66 
67           if (eapol->cb.logger == NULL)
68                     return;
69 
70           maxlen = os_strlen(fmt) + 100;
71           format = os_malloc(maxlen);
72           if (!format)
73                     return;
74 
75           va_start(ap, fmt);
76           vsnprintf(format, maxlen, fmt, ap);
77           va_end(ap);
78 
79           eapol_auth_logger(eapol, addr, level, format);
80 
81           os_free(format);
82 }
83 
84 
eapol_auth_tx_canned_eap(struct eapol_state_machine * sm,int success)85 static void eapol_auth_tx_canned_eap(struct eapol_state_machine *sm,
86                                              int success)
87 {
88           struct eap_hdr eap;
89 
90           os_memset(&eap, 0, sizeof(eap));
91 
92           eap.code = success ? EAP_CODE_SUCCESS : EAP_CODE_FAILURE;
93           eap.identifier = ++sm->last_eap_id;
94           eap.length = host_to_be16(sizeof(eap));
95 
96           eapol_auth_vlogger(sm->eapol, sm->addr, EAPOL_LOGGER_DEBUG,
97                                  "Sending canned EAP packet %s (identifier %d)",
98                                  success ? "SUCCESS" : "FAILURE", eap.identifier);
99           sm->eapol->cb.eapol_send(sm->eapol->conf.ctx, sm->sta,
100                                          IEEE802_1X_TYPE_EAP_PACKET,
101                                          (u8 *) &eap, sizeof(eap));
102           sm->dot1xAuthEapolFramesTx++;
103 }
104 
105 
eapol_auth_tx_req(struct eapol_state_machine * sm)106 static void eapol_auth_tx_req(struct eapol_state_machine *sm)
107 {
108           if (sm->eap_if->eapReqData == NULL ||
109               wpabuf_len(sm->eap_if->eapReqData) < sizeof(struct eap_hdr)) {
110                     eapol_auth_logger(sm->eapol, sm->addr,
111                                           EAPOL_LOGGER_DEBUG,
112                                           "TxReq called, but there is no EAP request "
113                                           "from authentication server");
114                     return;
115           }
116 
117           if (sm->flags & EAPOL_SM_WAIT_START) {
118                     wpa_printf(MSG_DEBUG, "EAPOL: Drop EAPOL TX to " MACSTR
119                                  " while waiting for EAPOL-Start",
120                                  MAC2STR(sm->addr));
121                     return;
122           }
123 
124           sm->last_eap_id = eap_get_id(sm->eap_if->eapReqData);
125           eapol_auth_vlogger(sm->eapol, sm->addr, EAPOL_LOGGER_DEBUG,
126                                  "Sending EAP Packet (identifier %d)",
127                                  sm->last_eap_id);
128           sm->eapol->cb.eapol_send(sm->eapol->conf.ctx, sm->sta,
129                                          IEEE802_1X_TYPE_EAP_PACKET,
130                                          wpabuf_head(sm->eap_if->eapReqData),
131                                          wpabuf_len(sm->eap_if->eapReqData));
132           sm->dot1xAuthEapolFramesTx++;
133           if (eap_get_type(sm->eap_if->eapReqData) == EAP_TYPE_IDENTITY)
134                     sm->dot1xAuthEapolReqIdFramesTx++;
135           else
136                     sm->dot1xAuthEapolReqFramesTx++;
137 }
138 
139 
140 /**
141  * eapol_port_timers_tick - Port Timers state machine
142  * @eloop_ctx: struct eapol_state_machine *
143  * @timeout_ctx: Not used
144  *
145  * This statemachine is implemented as a function that will be called
146  * once a second as a registered event loop timeout.
147  */
eapol_port_timers_tick(void * eloop_ctx,void * timeout_ctx)148 static void eapol_port_timers_tick(void *eloop_ctx, void *timeout_ctx)
149 {
150           struct eapol_state_machine *state = timeout_ctx;
151 
152           if (state->aWhile > 0) {
153                     state->aWhile--;
154                     if (state->aWhile == 0) {
155                               wpa_printf(MSG_DEBUG, "IEEE 802.1X: " MACSTR
156                                            " - aWhile --> 0",
157                                            MAC2STR(state->addr));
158                     }
159           }
160 
161           if (state->quietWhile > 0) {
162                     state->quietWhile--;
163                     if (state->quietWhile == 0) {
164                               wpa_printf(MSG_DEBUG, "IEEE 802.1X: " MACSTR
165                                            " - quietWhile --> 0",
166                                            MAC2STR(state->addr));
167                     }
168           }
169 
170           if (state->reAuthWhen > 0) {
171                     state->reAuthWhen--;
172                     if (state->reAuthWhen == 0) {
173                               wpa_printf(MSG_DEBUG, "IEEE 802.1X: " MACSTR
174                                            " - reAuthWhen --> 0",
175                                            MAC2STR(state->addr));
176                     }
177           }
178 
179           if (state->eap_if->retransWhile > 0) {
180                     state->eap_if->retransWhile--;
181                     if (state->eap_if->retransWhile == 0) {
182                               wpa_printf(MSG_DEBUG, "IEEE 802.1X: " MACSTR
183                                            " - (EAP) retransWhile --> 0",
184                                            MAC2STR(state->addr));
185                     }
186           }
187 
188           eapol_sm_step_run(state);
189 
190           eloop_register_timeout(1, 0, eapol_port_timers_tick, eloop_ctx, state);
191 }
192 
193 
194 
195 /* Authenticator PAE state machine */
196 
SM_STATE(AUTH_PAE,INITIALIZE)197 SM_STATE(AUTH_PAE, INITIALIZE)
198 {
199           SM_ENTRY_MA(AUTH_PAE, INITIALIZE, auth_pae);
200           sm->portMode = Auto;
201 
202           /*
203            * Clearing keyRun here is not specified in IEEE Std 802.1X-2004, but
204            * it looks like this would be logical thing to do here since the
205            * EAPOL-Key exchange is not possible in this state. It is possible to
206            * get here on disconnection event without advancing to the
207            * AUTHENTICATING state to clear keyRun before the IEEE 802.11 RSN
208            * authenticator state machine runs and that may advance from
209            * AUTHENTICATION2 to INITPMK if keyRun = TRUE has been left from the
210            * last association. This can be avoided by clearing keyRun here.
211            */
212           sm->keyRun = FALSE;
213 }
214 
215 
SM_STATE(AUTH_PAE,DISCONNECTED)216 SM_STATE(AUTH_PAE, DISCONNECTED)
217 {
218           int from_initialize = sm->auth_pae_state == AUTH_PAE_INITIALIZE;
219 
220           if (sm->eapolLogoff) {
221                     if (sm->auth_pae_state == AUTH_PAE_CONNECTING)
222                               sm->authEapLogoffsWhileConnecting++;
223                     else if (sm->auth_pae_state == AUTH_PAE_AUTHENTICATED)
224                               sm->authAuthEapLogoffWhileAuthenticated++;
225           }
226 
227           SM_ENTRY_MA(AUTH_PAE, DISCONNECTED, auth_pae);
228 
229           sm->authPortStatus = Unauthorized;
230           setPortUnauthorized();
231           sm->reAuthCount = 0;
232           sm->eapolLogoff = FALSE;
233           if (!from_initialize) {
234                     sm->eapol->cb.finished(sm->eapol->conf.ctx, sm->sta, 0,
235                                                sm->flags & EAPOL_SM_PREAUTH,
236                                                sm->remediation);
237           }
238 }
239 
240 
SM_STATE(AUTH_PAE,RESTART)241 SM_STATE(AUTH_PAE, RESTART)
242 {
243           if (sm->auth_pae_state == AUTH_PAE_AUTHENTICATED) {
244                     if (sm->reAuthenticate)
245                               sm->authAuthReauthsWhileAuthenticated++;
246                     if (sm->eapolStart)
247                               sm->authAuthEapStartsWhileAuthenticated++;
248                     if (sm->eapolLogoff)
249                               sm->authAuthEapLogoffWhileAuthenticated++;
250           }
251 
252           SM_ENTRY_MA(AUTH_PAE, RESTART, auth_pae);
253 
254           sm->eap_if->eapRestart = TRUE;
255 }
256 
257 
SM_STATE(AUTH_PAE,CONNECTING)258 SM_STATE(AUTH_PAE, CONNECTING)
259 {
260           if (sm->auth_pae_state != AUTH_PAE_CONNECTING)
261                     sm->authEntersConnecting++;
262 
263           SM_ENTRY_MA(AUTH_PAE, CONNECTING, auth_pae);
264 
265           sm->reAuthenticate = FALSE;
266           sm->reAuthCount++;
267 }
268 
269 
SM_STATE(AUTH_PAE,HELD)270 SM_STATE(AUTH_PAE, HELD)
271 {
272           if (sm->auth_pae_state == AUTH_PAE_AUTHENTICATING && sm->authFail)
273                     sm->authAuthFailWhileAuthenticating++;
274 
275           SM_ENTRY_MA(AUTH_PAE, HELD, auth_pae);
276 
277           sm->authPortStatus = Unauthorized;
278           setPortUnauthorized();
279           sm->quietWhile = sm->quietPeriod;
280           sm->eapolLogoff = FALSE;
281 
282           eapol_auth_vlogger(sm->eapol, sm->addr, EAPOL_LOGGER_WARNING,
283                                  "authentication failed - EAP type: %d (%s)",
284                                  sm->eap_type_authsrv,
285                                  eap_server_get_name(0, sm->eap_type_authsrv));
286           if (sm->eap_type_authsrv != sm->eap_type_supp) {
287                     eapol_auth_vlogger(sm->eapol, sm->addr, EAPOL_LOGGER_INFO,
288                                            "Supplicant used different EAP type: "
289                                            "%d (%s)", sm->eap_type_supp,
290                                            eap_server_get_name(0, sm->eap_type_supp));
291           }
292           sm->eapol->cb.finished(sm->eapol->conf.ctx, sm->sta, 0,
293                                      sm->flags & EAPOL_SM_PREAUTH, sm->remediation);
294 }
295 
296 
SM_STATE(AUTH_PAE,AUTHENTICATED)297 SM_STATE(AUTH_PAE, AUTHENTICATED)
298 {
299           char *extra = "";
300 
301           if (sm->auth_pae_state == AUTH_PAE_AUTHENTICATING && sm->authSuccess)
302                     sm->authAuthSuccessesWhileAuthenticating++;
303 
304           SM_ENTRY_MA(AUTH_PAE, AUTHENTICATED, auth_pae);
305 
306           sm->authPortStatus = Authorized;
307           setPortAuthorized();
308           sm->reAuthCount = 0;
309           if (sm->flags & EAPOL_SM_PREAUTH)
310                     extra = " (pre-authentication)";
311           else if (sm->flags & EAPOL_SM_FROM_PMKSA_CACHE)
312                     extra = " (PMKSA cache)";
313           eapol_auth_vlogger(sm->eapol, sm->addr, EAPOL_LOGGER_INFO,
314                                  "authenticated - EAP type: %d (%s)%s",
315                                  sm->eap_type_authsrv,
316                                  eap_server_get_name(0, sm->eap_type_authsrv),
317                                  extra);
318           sm->eapol->cb.finished(sm->eapol->conf.ctx, sm->sta, 1,
319                                      sm->flags & EAPOL_SM_PREAUTH, sm->remediation);
320 }
321 
322 
SM_STATE(AUTH_PAE,AUTHENTICATING)323 SM_STATE(AUTH_PAE, AUTHENTICATING)
324 {
325           SM_ENTRY_MA(AUTH_PAE, AUTHENTICATING, auth_pae);
326 
327           sm->eapolStart = FALSE;
328           sm->authSuccess = FALSE;
329           sm->authFail = FALSE;
330           sm->authTimeout = FALSE;
331           sm->authStart = TRUE;
332           sm->keyRun = FALSE;
333           sm->keyDone = FALSE;
334 }
335 
336 
SM_STATE(AUTH_PAE,ABORTING)337 SM_STATE(AUTH_PAE, ABORTING)
338 {
339           if (sm->auth_pae_state == AUTH_PAE_AUTHENTICATING) {
340                     if (sm->authTimeout)
341                               sm->authAuthTimeoutsWhileAuthenticating++;
342                     if (sm->eapolStart)
343                               sm->authAuthEapStartsWhileAuthenticating++;
344                     if (sm->eapolLogoff)
345                               sm->authAuthEapLogoffWhileAuthenticating++;
346           }
347 
348           SM_ENTRY_MA(AUTH_PAE, ABORTING, auth_pae);
349 
350           sm->authAbort = TRUE;
351           sm->keyRun = FALSE;
352           sm->keyDone = FALSE;
353 }
354 
355 
SM_STATE(AUTH_PAE,FORCE_AUTH)356 SM_STATE(AUTH_PAE, FORCE_AUTH)
357 {
358           SM_ENTRY_MA(AUTH_PAE, FORCE_AUTH, auth_pae);
359 
360           sm->authPortStatus = Authorized;
361           setPortAuthorized();
362           sm->portMode = ForceAuthorized;
363           sm->eapolStart = FALSE;
364           txCannedSuccess();
365 }
366 
367 
SM_STATE(AUTH_PAE,FORCE_UNAUTH)368 SM_STATE(AUTH_PAE, FORCE_UNAUTH)
369 {
370           SM_ENTRY_MA(AUTH_PAE, FORCE_UNAUTH, auth_pae);
371 
372           sm->authPortStatus = Unauthorized;
373           setPortUnauthorized();
374           sm->portMode = ForceUnauthorized;
375           sm->eapolStart = FALSE;
376           txCannedFail();
377 }
378 
379 
SM_STEP(AUTH_PAE)380 SM_STEP(AUTH_PAE)
381 {
382           if ((sm->portControl == Auto && sm->portMode != sm->portControl) ||
383               sm->initialize || !sm->eap_if->portEnabled)
384                     SM_ENTER_GLOBAL(AUTH_PAE, INITIALIZE);
385           else if (sm->portControl == ForceAuthorized &&
386                      sm->portMode != sm->portControl &&
387                      !(sm->initialize || !sm->eap_if->portEnabled))
388                     SM_ENTER_GLOBAL(AUTH_PAE, FORCE_AUTH);
389           else if (sm->portControl == ForceUnauthorized &&
390                      sm->portMode != sm->portControl &&
391                      !(sm->initialize || !sm->eap_if->portEnabled))
392                     SM_ENTER_GLOBAL(AUTH_PAE, FORCE_UNAUTH);
393           else {
394                     switch (sm->auth_pae_state) {
395                     case AUTH_PAE_INITIALIZE:
396                               SM_ENTER(AUTH_PAE, DISCONNECTED);
397                               break;
398                     case AUTH_PAE_DISCONNECTED:
399                               SM_ENTER(AUTH_PAE, RESTART);
400                               break;
401                     case AUTH_PAE_RESTART:
402                               if (!sm->eap_if->eapRestart)
403                                         SM_ENTER(AUTH_PAE, CONNECTING);
404                               break;
405                     case AUTH_PAE_HELD:
406                               if (sm->quietWhile == 0)
407                                         SM_ENTER(AUTH_PAE, RESTART);
408                               break;
409                     case AUTH_PAE_CONNECTING:
410                               if (sm->eapolLogoff || sm->reAuthCount > sm->reAuthMax)
411                                         SM_ENTER(AUTH_PAE, DISCONNECTED);
412                               else if ((sm->eap_if->eapReq &&
413                                           sm->reAuthCount <= sm->reAuthMax) ||
414                                          sm->eap_if->eapSuccess || sm->eap_if->eapFail)
415                                         SM_ENTER(AUTH_PAE, AUTHENTICATING);
416                               break;
417                     case AUTH_PAE_AUTHENTICATED:
418                               if (sm->eapolStart || sm->reAuthenticate)
419                                         SM_ENTER(AUTH_PAE, RESTART);
420                               else if (sm->eapolLogoff || !sm->portValid)
421                                         SM_ENTER(AUTH_PAE, DISCONNECTED);
422                               break;
423                     case AUTH_PAE_AUTHENTICATING:
424                               if (sm->authSuccess && sm->portValid)
425                                         SM_ENTER(AUTH_PAE, AUTHENTICATED);
426                               else if (sm->authFail ||
427                                          (sm->keyDone && !sm->portValid))
428                                         SM_ENTER(AUTH_PAE, HELD);
429                               else if (sm->eapolStart || sm->eapolLogoff ||
430                                          sm->authTimeout)
431                                         SM_ENTER(AUTH_PAE, ABORTING);
432                               break;
433                     case AUTH_PAE_ABORTING:
434                               if (sm->eapolLogoff && !sm->authAbort)
435                                         SM_ENTER(AUTH_PAE, DISCONNECTED);
436                               else if (!sm->eapolLogoff && !sm->authAbort)
437                                         SM_ENTER(AUTH_PAE, RESTART);
438                               break;
439                     case AUTH_PAE_FORCE_AUTH:
440                               if (sm->eapolStart)
441                                         SM_ENTER(AUTH_PAE, FORCE_AUTH);
442                               break;
443                     case AUTH_PAE_FORCE_UNAUTH:
444                               if (sm->eapolStart)
445                                         SM_ENTER(AUTH_PAE, FORCE_UNAUTH);
446                               break;
447                     }
448           }
449 }
450 
451 
452 
453 /* Backend Authentication state machine */
454 
SM_STATE(BE_AUTH,INITIALIZE)455 SM_STATE(BE_AUTH, INITIALIZE)
456 {
457           SM_ENTRY_MA(BE_AUTH, INITIALIZE, be_auth);
458 
459           abortAuth();
460           sm->eap_if->eapNoReq = FALSE;
461           sm->authAbort = FALSE;
462 }
463 
464 
SM_STATE(BE_AUTH,REQUEST)465 SM_STATE(BE_AUTH, REQUEST)
466 {
467           SM_ENTRY_MA(BE_AUTH, REQUEST, be_auth);
468 
469           txReq();
470           sm->eap_if->eapReq = FALSE;
471           sm->backendOtherRequestsToSupplicant++;
472 
473           /*
474            * Clearing eapolEap here is not specified in IEEE Std 802.1X-2004, but
475            * it looks like this would be logical thing to do there since the old
476            * EAP response would not be valid anymore after the new EAP request
477            * was sent out.
478            *
479            * A race condition has been reported, in which hostapd ended up
480            * sending out EAP-Response/Identity as a response to the first
481            * EAP-Request from the main EAP method. This can be avoided by
482            * clearing eapolEap here.
483            */
484           sm->eapolEap = FALSE;
485 }
486 
487 
SM_STATE(BE_AUTH,RESPONSE)488 SM_STATE(BE_AUTH, RESPONSE)
489 {
490           SM_ENTRY_MA(BE_AUTH, RESPONSE, be_auth);
491 
492           sm->authTimeout = FALSE;
493           sm->eapolEap = FALSE;
494           sm->eap_if->eapNoReq = FALSE;
495           sm->aWhile = sm->serverTimeout;
496           sm->eap_if->eapResp = TRUE;
497           /* sendRespToServer(); */
498           sm->backendResponses++;
499 }
500 
501 
SM_STATE(BE_AUTH,SUCCESS)502 SM_STATE(BE_AUTH, SUCCESS)
503 {
504           SM_ENTRY_MA(BE_AUTH, SUCCESS, be_auth);
505 
506           txReq();
507           sm->authSuccess = TRUE;
508           sm->keyRun = TRUE;
509 }
510 
511 
SM_STATE(BE_AUTH,FAIL)512 SM_STATE(BE_AUTH, FAIL)
513 {
514           SM_ENTRY_MA(BE_AUTH, FAIL, be_auth);
515 
516           txReq();
517           sm->authFail = TRUE;
518 }
519 
520 
SM_STATE(BE_AUTH,TIMEOUT)521 SM_STATE(BE_AUTH, TIMEOUT)
522 {
523           SM_ENTRY_MA(BE_AUTH, TIMEOUT, be_auth);
524 
525           sm->authTimeout = TRUE;
526 }
527 
528 
SM_STATE(BE_AUTH,IDLE)529 SM_STATE(BE_AUTH, IDLE)
530 {
531           SM_ENTRY_MA(BE_AUTH, IDLE, be_auth);
532 
533           sm->authStart = FALSE;
534 }
535 
536 
SM_STATE(BE_AUTH,IGNORE)537 SM_STATE(BE_AUTH, IGNORE)
538 {
539           SM_ENTRY_MA(BE_AUTH, IGNORE, be_auth);
540 
541           sm->eap_if->eapNoReq = FALSE;
542 }
543 
544 
SM_STEP(BE_AUTH)545 SM_STEP(BE_AUTH)
546 {
547           if (sm->portControl != Auto || sm->initialize || sm->authAbort) {
548                     SM_ENTER_GLOBAL(BE_AUTH, INITIALIZE);
549                     return;
550           }
551 
552           switch (sm->be_auth_state) {
553           case BE_AUTH_INITIALIZE:
554                     SM_ENTER(BE_AUTH, IDLE);
555                     break;
556           case BE_AUTH_REQUEST:
557                     if (sm->eapolEap)
558                               SM_ENTER(BE_AUTH, RESPONSE);
559                     else if (sm->eap_if->eapReq)
560                               SM_ENTER(BE_AUTH, REQUEST);
561                     else if (sm->eap_if->eapTimeout)
562                               SM_ENTER(BE_AUTH, TIMEOUT);
563                     break;
564           case BE_AUTH_RESPONSE:
565                     if (sm->eap_if->eapNoReq)
566                               SM_ENTER(BE_AUTH, IGNORE);
567                     if (sm->eap_if->eapReq) {
568                               sm->backendAccessChallenges++;
569                               SM_ENTER(BE_AUTH, REQUEST);
570                     } else if (sm->aWhile == 0)
571                               SM_ENTER(BE_AUTH, TIMEOUT);
572                     else if (sm->eap_if->eapFail) {
573                               sm->backendAuthFails++;
574                               SM_ENTER(BE_AUTH, FAIL);
575                     } else if (sm->eap_if->eapSuccess) {
576                               sm->backendAuthSuccesses++;
577                               SM_ENTER(BE_AUTH, SUCCESS);
578                     }
579                     break;
580           case BE_AUTH_SUCCESS:
581                     SM_ENTER(BE_AUTH, IDLE);
582                     break;
583           case BE_AUTH_FAIL:
584                     SM_ENTER(BE_AUTH, IDLE);
585                     break;
586           case BE_AUTH_TIMEOUT:
587                     SM_ENTER(BE_AUTH, IDLE);
588                     break;
589           case BE_AUTH_IDLE:
590                     if (sm->eap_if->eapFail && sm->authStart)
591                               SM_ENTER(BE_AUTH, FAIL);
592                     else if (sm->eap_if->eapReq && sm->authStart)
593                               SM_ENTER(BE_AUTH, REQUEST);
594                     else if (sm->eap_if->eapSuccess && sm->authStart)
595                               SM_ENTER(BE_AUTH, SUCCESS);
596                     break;
597           case BE_AUTH_IGNORE:
598                     if (sm->eapolEap)
599                               SM_ENTER(BE_AUTH, RESPONSE);
600                     else if (sm->eap_if->eapReq)
601                               SM_ENTER(BE_AUTH, REQUEST);
602                     else if (sm->eap_if->eapTimeout)
603                               SM_ENTER(BE_AUTH, TIMEOUT);
604                     break;
605           }
606 }
607 
608 
609 
610 /* Reauthentication Timer state machine */
611 
SM_STATE(REAUTH_TIMER,INITIALIZE)612 SM_STATE(REAUTH_TIMER, INITIALIZE)
613 {
614           SM_ENTRY_MA(REAUTH_TIMER, INITIALIZE, reauth_timer);
615 
616           sm->reAuthWhen = sm->reAuthPeriod;
617 }
618 
619 
SM_STATE(REAUTH_TIMER,REAUTHENTICATE)620 SM_STATE(REAUTH_TIMER, REAUTHENTICATE)
621 {
622           SM_ENTRY_MA(REAUTH_TIMER, REAUTHENTICATE, reauth_timer);
623 
624           sm->reAuthenticate = TRUE;
625           sm->eapol->cb.eapol_event(sm->eapol->conf.ctx, sm->sta,
626                                           EAPOL_AUTH_REAUTHENTICATE);
627 }
628 
629 
SM_STEP(REAUTH_TIMER)630 SM_STEP(REAUTH_TIMER)
631 {
632           if (sm->portControl != Auto || sm->initialize ||
633               sm->authPortStatus == Unauthorized || !sm->reAuthEnabled) {
634                     SM_ENTER_GLOBAL(REAUTH_TIMER, INITIALIZE);
635                     return;
636           }
637 
638           switch (sm->reauth_timer_state) {
639           case REAUTH_TIMER_INITIALIZE:
640                     if (sm->reAuthWhen == 0)
641                               SM_ENTER(REAUTH_TIMER, REAUTHENTICATE);
642                     break;
643           case REAUTH_TIMER_REAUTHENTICATE:
644                     SM_ENTER(REAUTH_TIMER, INITIALIZE);
645                     break;
646           }
647 }
648 
649 
650 
651 /* Authenticator Key Transmit state machine */
652 
SM_STATE(AUTH_KEY_TX,NO_KEY_TRANSMIT)653 SM_STATE(AUTH_KEY_TX, NO_KEY_TRANSMIT)
654 {
655           SM_ENTRY_MA(AUTH_KEY_TX, NO_KEY_TRANSMIT, auth_key_tx);
656 }
657 
658 
SM_STATE(AUTH_KEY_TX,KEY_TRANSMIT)659 SM_STATE(AUTH_KEY_TX, KEY_TRANSMIT)
660 {
661           SM_ENTRY_MA(AUTH_KEY_TX, KEY_TRANSMIT, auth_key_tx);
662 
663           txKey();
664           sm->eap_if->eapKeyAvailable = FALSE;
665           sm->keyDone = TRUE;
666 }
667 
668 
SM_STEP(AUTH_KEY_TX)669 SM_STEP(AUTH_KEY_TX)
670 {
671           if (sm->initialize || sm->portControl != Auto) {
672                     SM_ENTER_GLOBAL(AUTH_KEY_TX, NO_KEY_TRANSMIT);
673                     return;
674           }
675 
676           switch (sm->auth_key_tx_state) {
677           case AUTH_KEY_TX_NO_KEY_TRANSMIT:
678                     if (sm->keyTxEnabled && sm->eap_if->eapKeyAvailable &&
679                         sm->keyRun && !(sm->flags & EAPOL_SM_USES_WPA))
680                               SM_ENTER(AUTH_KEY_TX, KEY_TRANSMIT);
681                     break;
682           case AUTH_KEY_TX_KEY_TRANSMIT:
683                     if (!sm->keyTxEnabled || !sm->keyRun)
684                               SM_ENTER(AUTH_KEY_TX, NO_KEY_TRANSMIT);
685                     else if (sm->eap_if->eapKeyAvailable)
686                               SM_ENTER(AUTH_KEY_TX, KEY_TRANSMIT);
687                     break;
688           }
689 }
690 
691 
692 
693 /* Key Receive state machine */
694 
SM_STATE(KEY_RX,NO_KEY_RECEIVE)695 SM_STATE(KEY_RX, NO_KEY_RECEIVE)
696 {
697           SM_ENTRY_MA(KEY_RX, NO_KEY_RECEIVE, key_rx);
698 }
699 
700 
SM_STATE(KEY_RX,KEY_RECEIVE)701 SM_STATE(KEY_RX, KEY_RECEIVE)
702 {
703           SM_ENTRY_MA(KEY_RX, KEY_RECEIVE, key_rx);
704 
705           processKey();
706           sm->rxKey = FALSE;
707 }
708 
709 
SM_STEP(KEY_RX)710 SM_STEP(KEY_RX)
711 {
712           if (sm->initialize || !sm->eap_if->portEnabled) {
713                     SM_ENTER_GLOBAL(KEY_RX, NO_KEY_RECEIVE);
714                     return;
715           }
716 
717           switch (sm->key_rx_state) {
718           case KEY_RX_NO_KEY_RECEIVE:
719                     if (sm->rxKey)
720                               SM_ENTER(KEY_RX, KEY_RECEIVE);
721                     break;
722           case KEY_RX_KEY_RECEIVE:
723                     if (sm->rxKey)
724                               SM_ENTER(KEY_RX, KEY_RECEIVE);
725                     break;
726           }
727 }
728 
729 
730 
731 /* Controlled Directions state machine */
732 
SM_STATE(CTRL_DIR,FORCE_BOTH)733 SM_STATE(CTRL_DIR, FORCE_BOTH)
734 {
735           SM_ENTRY_MA(CTRL_DIR, FORCE_BOTH, ctrl_dir);
736           sm->operControlledDirections = Both;
737 }
738 
739 
SM_STATE(CTRL_DIR,IN_OR_BOTH)740 SM_STATE(CTRL_DIR, IN_OR_BOTH)
741 {
742           SM_ENTRY_MA(CTRL_DIR, IN_OR_BOTH, ctrl_dir);
743           sm->operControlledDirections = sm->adminControlledDirections;
744 }
745 
746 
SM_STEP(CTRL_DIR)747 SM_STEP(CTRL_DIR)
748 {
749           if (sm->initialize) {
750                     SM_ENTER_GLOBAL(CTRL_DIR, IN_OR_BOTH);
751                     return;
752           }
753 
754           switch (sm->ctrl_dir_state) {
755           case CTRL_DIR_FORCE_BOTH:
756                     if (sm->eap_if->portEnabled && sm->operEdge)
757                               SM_ENTER(CTRL_DIR, IN_OR_BOTH);
758                     break;
759           case CTRL_DIR_IN_OR_BOTH:
760                     if (sm->operControlledDirections !=
761                         sm->adminControlledDirections)
762                               SM_ENTER(CTRL_DIR, IN_OR_BOTH);
763                     if (!sm->eap_if->portEnabled || !sm->operEdge)
764                               SM_ENTER(CTRL_DIR, FORCE_BOTH);
765                     break;
766           }
767 }
768 
769 
770 
771 struct eapol_state_machine *
eapol_auth_alloc(struct eapol_authenticator * eapol,const u8 * addr,int flags,const struct wpabuf * assoc_wps_ie,const struct wpabuf * assoc_p2p_ie,void * sta_ctx,const char * identity,const char * radius_cui)772 eapol_auth_alloc(struct eapol_authenticator *eapol, const u8 *addr,
773                      int flags, const struct wpabuf *assoc_wps_ie,
774                      const struct wpabuf *assoc_p2p_ie, void *sta_ctx,
775                      const char *identity, const char *radius_cui)
776 {
777           struct eapol_state_machine *sm;
778           struct eap_config eap_conf;
779 
780           if (eapol == NULL)
781                     return NULL;
782 
783           sm = os_zalloc(sizeof(*sm));
784           if (sm == NULL) {
785                     wpa_printf(MSG_DEBUG, "IEEE 802.1X state machine allocation "
786                                  "failed");
787                     return NULL;
788           }
789           sm->radius_identifier = -1;
790           os_memcpy(sm->addr, addr, ETH_ALEN);
791           sm->flags = flags;
792 
793           sm->eapol = eapol;
794           sm->sta = sta_ctx;
795 
796           /* Set default values for state machine constants */
797           sm->auth_pae_state = AUTH_PAE_INITIALIZE;
798           sm->quietPeriod = AUTH_PAE_DEFAULT_quietPeriod;
799           sm->reAuthMax = AUTH_PAE_DEFAULT_reAuthMax;
800 
801           sm->be_auth_state = BE_AUTH_INITIALIZE;
802           sm->serverTimeout = BE_AUTH_DEFAULT_serverTimeout;
803 
804           sm->reauth_timer_state = REAUTH_TIMER_INITIALIZE;
805           sm->reAuthPeriod = eapol->conf.eap_reauth_period;
806           sm->reAuthEnabled = eapol->conf.eap_reauth_period > 0 ? TRUE : FALSE;
807 
808           sm->auth_key_tx_state = AUTH_KEY_TX_NO_KEY_TRANSMIT;
809 
810           sm->key_rx_state = KEY_RX_NO_KEY_RECEIVE;
811 
812           sm->ctrl_dir_state = CTRL_DIR_IN_OR_BOTH;
813 
814           sm->portControl = Auto;
815 
816           if (!eapol->conf.wpa &&
817               (eapol->default_wep_key || eapol->conf.individual_wep_key_len > 0))
818                     sm->keyTxEnabled = TRUE;
819           else
820                     sm->keyTxEnabled = FALSE;
821           if (eapol->conf.wpa)
822                     sm->portValid = FALSE;
823           else
824                     sm->portValid = TRUE;
825 
826           os_memset(&eap_conf, 0, sizeof(eap_conf));
827           eap_conf.eap_server = eapol->conf.eap_server;
828           eap_conf.ssl_ctx = eapol->conf.ssl_ctx;
829           eap_conf.msg_ctx = eapol->conf.msg_ctx;
830           eap_conf.eap_sim_db_priv = eapol->conf.eap_sim_db_priv;
831           eap_conf.pac_opaque_encr_key = eapol->conf.pac_opaque_encr_key;
832           eap_conf.eap_fast_a_id = eapol->conf.eap_fast_a_id;
833           eap_conf.eap_fast_a_id_len = eapol->conf.eap_fast_a_id_len;
834           eap_conf.eap_fast_a_id_info = eapol->conf.eap_fast_a_id_info;
835           eap_conf.eap_fast_prov = eapol->conf.eap_fast_prov;
836           eap_conf.pac_key_lifetime = eapol->conf.pac_key_lifetime;
837           eap_conf.pac_key_refresh_time = eapol->conf.pac_key_refresh_time;
838           eap_conf.eap_teap_auth = eapol->conf.eap_teap_auth;
839           eap_conf.eap_teap_pac_no_inner = eapol->conf.eap_teap_pac_no_inner;
840           eap_conf.eap_sim_aka_result_ind = eapol->conf.eap_sim_aka_result_ind;
841           eap_conf.eap_sim_id = eapol->conf.eap_sim_id;
842           eap_conf.tnc = eapol->conf.tnc;
843           eap_conf.wps = eapol->conf.wps;
844           eap_conf.assoc_wps_ie = assoc_wps_ie;
845           eap_conf.assoc_p2p_ie = assoc_p2p_ie;
846           eap_conf.peer_addr = addr;
847           eap_conf.fragment_size = eapol->conf.fragment_size;
848           eap_conf.pwd_group = eapol->conf.pwd_group;
849           eap_conf.pbc_in_m1 = eapol->conf.pbc_in_m1;
850           eap_conf.server_id = eapol->conf.server_id;
851           eap_conf.server_id_len = eapol->conf.server_id_len;
852           eap_conf.erp = eapol->conf.erp;
853           eap_conf.tls_session_lifetime = eapol->conf.tls_session_lifetime;
854           eap_conf.tls_flags = eapol->conf.tls_flags;
855           sm->eap = eap_server_sm_init(sm, &eapol_cb, &eap_conf);
856           if (sm->eap == NULL) {
857                     eapol_auth_free(sm);
858                     return NULL;
859           }
860           sm->eap_if = eap_get_interface(sm->eap);
861 
862           eapol_auth_initialize(sm);
863 
864           if (identity) {
865                     sm->identity = (u8 *) os_strdup(identity);
866                     if (sm->identity)
867                               sm->identity_len = os_strlen(identity);
868           }
869           if (radius_cui)
870                     sm->radius_cui = wpabuf_alloc_copy(radius_cui,
871                                                                os_strlen(radius_cui));
872 
873 #ifndef CONFIG_NO_RADIUS
874           if (radius_gen_session_id((u8 *) &sm->acct_multi_session_id,
875                                           sizeof(sm->acct_multi_session_id)) < 0) {
876                     eapol_auth_free(sm);
877                     return NULL;
878           }
879 #endif /* CONFIG_NO_RADIUS */
880 
881           return sm;
882 }
883 
884 
eapol_auth_free(struct eapol_state_machine * sm)885 void eapol_auth_free(struct eapol_state_machine *sm)
886 {
887           if (sm == NULL)
888                     return;
889 
890           eloop_cancel_timeout(eapol_port_timers_tick, NULL, sm);
891           eloop_cancel_timeout(eapol_sm_step_cb, sm, NULL);
892           if (sm->eap)
893                     eap_server_sm_deinit(sm->eap);
894 
895           wpabuf_free(sm->radius_cui);
896           os_free(sm->identity);
897           os_free(sm);
898 }
899 
900 
eapol_sm_sta_entry_alive(struct eapol_authenticator * eapol,const u8 * addr)901 static int eapol_sm_sta_entry_alive(struct eapol_authenticator *eapol,
902                                             const u8 *addr)
903 {
904           return eapol->cb.sta_entry_alive(eapol->conf.ctx, addr);
905 }
906 
907 
eapol_sm_step_run(struct eapol_state_machine * sm)908 static void eapol_sm_step_run(struct eapol_state_machine *sm)
909 {
910           struct eapol_authenticator *eapol = sm->eapol;
911           u8 addr[ETH_ALEN];
912           unsigned int prev_auth_pae, prev_be_auth, prev_reauth_timer,
913                     prev_auth_key_tx, prev_key_rx, prev_ctrl_dir;
914           int max_steps = 100;
915 
916           os_memcpy(addr, sm->addr, ETH_ALEN);
917 
918           /*
919            * Allow EAPOL state machines to run as long as there are state
920            * changes, but exit and return here through event loop if more than
921            * 100 steps is needed as a precaution against infinite loops inside
922            * eloop callback.
923            */
924 restart:
925           prev_auth_pae = sm->auth_pae_state;
926           prev_be_auth = sm->be_auth_state;
927           prev_reauth_timer = sm->reauth_timer_state;
928           prev_auth_key_tx = sm->auth_key_tx_state;
929           prev_key_rx = sm->key_rx_state;
930           prev_ctrl_dir = sm->ctrl_dir_state;
931 
932           SM_STEP_RUN(AUTH_PAE);
933           if (sm->initializing || eapol_sm_sta_entry_alive(eapol, addr))
934                     SM_STEP_RUN(BE_AUTH);
935           if (sm->initializing || eapol_sm_sta_entry_alive(eapol, addr))
936                     SM_STEP_RUN(REAUTH_TIMER);
937           if (sm->initializing || eapol_sm_sta_entry_alive(eapol, addr))
938                     SM_STEP_RUN(AUTH_KEY_TX);
939           if (sm->initializing || eapol_sm_sta_entry_alive(eapol, addr))
940                     SM_STEP_RUN(KEY_RX);
941           if (sm->initializing || eapol_sm_sta_entry_alive(eapol, addr))
942                     SM_STEP_RUN(CTRL_DIR);
943 
944           if (prev_auth_pae != sm->auth_pae_state ||
945               prev_be_auth != sm->be_auth_state ||
946               prev_reauth_timer != sm->reauth_timer_state ||
947               prev_auth_key_tx != sm->auth_key_tx_state ||
948               prev_key_rx != sm->key_rx_state ||
949               prev_ctrl_dir != sm->ctrl_dir_state) {
950                     if (--max_steps > 0)
951                               goto restart;
952                     /* Re-run from eloop timeout */
953                     eapol_auth_step(sm);
954                     return;
955           }
956 
957           if (eapol_sm_sta_entry_alive(eapol, addr) && sm->eap) {
958                     if (eap_server_sm_step(sm->eap)) {
959                               if (--max_steps > 0)
960                                         goto restart;
961                               /* Re-run from eloop timeout */
962                               eapol_auth_step(sm);
963                               return;
964                     }
965 
966                     /* TODO: find a better location for this */
967                     if (sm->eap_if->aaaEapResp) {
968                               sm->eap_if->aaaEapResp = FALSE;
969                               if (sm->eap_if->aaaEapRespData == NULL) {
970                                         wpa_printf(MSG_DEBUG, "EAPOL: aaaEapResp set, "
971                                                      "but no aaaEapRespData available");
972                                         return;
973                               }
974                               sm->eapol->cb.aaa_send(
975                                         sm->eapol->conf.ctx, sm->sta,
976                                         wpabuf_head(sm->eap_if->aaaEapRespData),
977                                         wpabuf_len(sm->eap_if->aaaEapRespData));
978                     }
979           }
980 
981           if (eapol_sm_sta_entry_alive(eapol, addr))
982                     sm->eapol->cb.eapol_event(sm->eapol->conf.ctx, sm->sta,
983                                                     EAPOL_AUTH_SM_CHANGE);
984 }
985 
986 
eapol_sm_step_cb(void * eloop_ctx,void * timeout_ctx)987 static void eapol_sm_step_cb(void *eloop_ctx, void *timeout_ctx)
988 {
989           struct eapol_state_machine *sm = eloop_ctx;
990           eapol_sm_step_run(sm);
991 }
992 
993 
994 /**
995  * eapol_auth_step - Advance EAPOL state machines
996  * @sm: EAPOL state machine
997  *
998  * This function is called to advance EAPOL state machines after any change
999  * that could affect their state.
1000  */
eapol_auth_step(struct eapol_state_machine * sm)1001 void eapol_auth_step(struct eapol_state_machine *sm)
1002 {
1003           /*
1004            * Run eapol_sm_step_run from a registered timeout to make sure that
1005            * other possible timeouts/events are processed and to avoid long
1006            * function call chains.
1007            */
1008 
1009           eloop_register_timeout(0, 0, eapol_sm_step_cb, sm, NULL);
1010 }
1011 
1012 
eapol_auth_initialize(struct eapol_state_machine * sm)1013 static void eapol_auth_initialize(struct eapol_state_machine *sm)
1014 {
1015           sm->initializing = TRUE;
1016           /* Initialize the state machines by asserting initialize and then
1017            * deasserting it after one step */
1018           sm->initialize = TRUE;
1019           eapol_sm_step_run(sm);
1020           sm->initialize = FALSE;
1021           eapol_sm_step_run(sm);
1022           sm->initializing = FALSE;
1023 
1024           /* Start one second tick for port timers state machine */
1025           eloop_cancel_timeout(eapol_port_timers_tick, NULL, sm);
1026           eloop_register_timeout(1, 0, eapol_port_timers_tick, NULL, sm);
1027 }
1028 
1029 
eapol_sm_get_eap_user(void * ctx,const u8 * identity,size_t identity_len,int phase2,struct eap_user * user)1030 static int eapol_sm_get_eap_user(void *ctx, const u8 *identity,
1031                                          size_t identity_len, int phase2,
1032                                          struct eap_user *user)
1033 {
1034           struct eapol_state_machine *sm = ctx;
1035           int ret;
1036 
1037           ret = sm->eapol->cb.get_eap_user(sm->eapol->conf.ctx, identity,
1038                                                    identity_len, phase2, user);
1039           if (user->remediation)
1040                     sm->remediation = 1;
1041           return ret;
1042 }
1043 
1044 
eapol_sm_get_eap_req_id_text(void * ctx,size_t * len)1045 static const char * eapol_sm_get_eap_req_id_text(void *ctx, size_t *len)
1046 {
1047           struct eapol_state_machine *sm = ctx;
1048           *len = sm->eapol->conf.eap_req_id_text_len;
1049           return sm->eapol->conf.eap_req_id_text;
1050 }
1051 
1052 
eapol_sm_get_erp_send_reauth_start(void * ctx)1053 static int eapol_sm_get_erp_send_reauth_start(void *ctx)
1054 {
1055           struct eapol_state_machine *sm = ctx;
1056           return sm->eapol->conf.erp_send_reauth_start;
1057 }
1058 
1059 
eapol_sm_get_erp_domain(void * ctx)1060 static const char * eapol_sm_get_erp_domain(void *ctx)
1061 {
1062           struct eapol_state_machine *sm = ctx;
1063           return sm->eapol->conf.erp_domain;
1064 }
1065 
1066 
eapol_sm_erp_get_key(void * ctx,const char * keyname)1067 static struct eap_server_erp_key * eapol_sm_erp_get_key(void *ctx,
1068                                                                       const char *keyname)
1069 {
1070           struct eapol_state_machine *sm = ctx;
1071           return sm->eapol->cb.erp_get_key(sm->eapol->conf.ctx, keyname);
1072 }
1073 
1074 
eapol_sm_erp_add_key(void * ctx,struct eap_server_erp_key * erp)1075 static int eapol_sm_erp_add_key(void *ctx, struct eap_server_erp_key *erp)
1076 {
1077           struct eapol_state_machine *sm = ctx;
1078           return sm->eapol->cb.erp_add_key(sm->eapol->conf.ctx, erp);
1079 }
1080 
1081 
1082 static const struct eapol_callbacks eapol_cb =
1083 {
1084           eapol_sm_get_eap_user,
1085           eapol_sm_get_eap_req_id_text,
1086           NULL,
1087           eapol_sm_get_erp_send_reauth_start,
1088           eapol_sm_get_erp_domain,
1089           eapol_sm_erp_get_key,
1090           eapol_sm_erp_add_key,
1091 };
1092 
1093 
eapol_auth_eap_pending_cb(struct eapol_state_machine * sm,void * ctx)1094 int eapol_auth_eap_pending_cb(struct eapol_state_machine *sm, void *ctx)
1095 {
1096           if (sm == NULL || ctx == NULL || ctx != sm->eap)
1097                     return -1;
1098 
1099           eap_sm_pending_cb(sm->eap);
1100           eapol_auth_step(sm);
1101 
1102           return 0;
1103 }
1104 
1105 
eapol_auth_reauthenticate(struct eapol_state_machine * sm)1106 void eapol_auth_reauthenticate(struct eapol_state_machine *sm)
1107 {
1108           wpa_printf(MSG_DEBUG, "EAPOL: External reauthentication trigger for "
1109                        MACSTR, MAC2STR(sm->addr));
1110           sm->reAuthenticate = TRUE;
1111           eapol_auth_step(sm);
1112 }
1113 
1114 
eapol_auth_set_conf(struct eapol_state_machine * sm,const char * param,const char * value)1115 int eapol_auth_set_conf(struct eapol_state_machine *sm, const char *param,
1116                               const char *value)
1117 {
1118           wpa_printf(MSG_DEBUG, "EAPOL: External configuration operation for "
1119                        MACSTR " - param=%s value=%s",
1120                        MAC2STR(sm->addr), param, value);
1121 
1122           if (os_strcasecmp(param, "AdminControlledDirections") == 0) {
1123                     if (os_strcmp(value, "Both") == 0)
1124                               sm->adminControlledDirections = Both;
1125                     else if (os_strcmp(value, "In") == 0)
1126                               sm->adminControlledDirections = In;
1127                     else
1128                               return -1;
1129                     eapol_auth_step(sm);
1130                     return 0;
1131           }
1132 
1133           if (os_strcasecmp(param, "AdminControlledPortControl") == 0) {
1134                     if (os_strcmp(value, "ForceAuthorized") == 0)
1135                               sm->portControl = ForceAuthorized;
1136                     else if (os_strcmp(value, "ForceUnauthorized") == 0)
1137                               sm->portControl = ForceUnauthorized;
1138                     else if (os_strcmp(value, "Auto") == 0)
1139                               sm->portControl = Auto;
1140                     else
1141                               return -1;
1142                     eapol_auth_step(sm);
1143                     return 0;
1144           }
1145 
1146           if (os_strcasecmp(param, "quietPeriod") == 0) {
1147                     sm->quietPeriod = atoi(value);
1148                     return 0;
1149           }
1150 
1151           if (os_strcasecmp(param, "serverTimeout") == 0) {
1152                     sm->serverTimeout = atoi(value);
1153                     return 0;
1154           }
1155 
1156           if (os_strcasecmp(param, "reAuthPeriod") == 0) {
1157                     sm->reAuthPeriod = atoi(value);
1158                     return 0;
1159           }
1160 
1161           if (os_strcasecmp(param, "reAuthEnabled") == 0) {
1162                     if (os_strcmp(value, "TRUE") == 0)
1163                               sm->reAuthEnabled = TRUE;
1164                     else if (os_strcmp(value, "FALSE") == 0)
1165                               sm->reAuthEnabled = FALSE;
1166                     else
1167                               return -1;
1168                     eapol_auth_step(sm);
1169                     return 0;
1170           }
1171 
1172           if (os_strcasecmp(param, "KeyTransmissionEnabled") == 0) {
1173                     if (os_strcmp(value, "TRUE") == 0)
1174                               sm->keyTxEnabled = TRUE;
1175                     else if (os_strcmp(value, "FALSE") == 0)
1176                               sm->keyTxEnabled = FALSE;
1177                     else
1178                               return -1;
1179                     eapol_auth_step(sm);
1180                     return 0;
1181           }
1182 
1183           return -1;
1184 }
1185 
1186 
eapol_auth_conf_clone(struct eapol_auth_config * dst,struct eapol_auth_config * src)1187 static int eapol_auth_conf_clone(struct eapol_auth_config *dst,
1188                                          struct eapol_auth_config *src)
1189 {
1190           dst->ctx = src->ctx;
1191           dst->eap_reauth_period = src->eap_reauth_period;
1192           dst->wpa = src->wpa;
1193           dst->individual_wep_key_len = src->individual_wep_key_len;
1194           dst->eap_server = src->eap_server;
1195           dst->ssl_ctx = src->ssl_ctx;
1196           dst->msg_ctx = src->msg_ctx;
1197           dst->eap_sim_db_priv = src->eap_sim_db_priv;
1198           os_free(dst->eap_req_id_text);
1199           dst->pwd_group = src->pwd_group;
1200           dst->pbc_in_m1 = src->pbc_in_m1;
1201           dst->server_id = src->server_id;
1202           dst->server_id_len = src->server_id_len;
1203           if (src->eap_req_id_text) {
1204                     dst->eap_req_id_text = os_memdup(src->eap_req_id_text,
1205                                                              src->eap_req_id_text_len);
1206                     if (dst->eap_req_id_text == NULL)
1207                               return -1;
1208                     dst->eap_req_id_text_len = src->eap_req_id_text_len;
1209           } else {
1210                     dst->eap_req_id_text = NULL;
1211                     dst->eap_req_id_text_len = 0;
1212           }
1213           if (src->pac_opaque_encr_key) {
1214                     dst->pac_opaque_encr_key = os_memdup(src->pac_opaque_encr_key,
1215                                                                  16);
1216                     if (dst->pac_opaque_encr_key == NULL)
1217                               goto fail;
1218           } else
1219                     dst->pac_opaque_encr_key = NULL;
1220           if (src->eap_fast_a_id) {
1221                     dst->eap_fast_a_id = os_memdup(src->eap_fast_a_id,
1222                                                          src->eap_fast_a_id_len);
1223                     if (dst->eap_fast_a_id == NULL)
1224                               goto fail;
1225                     dst->eap_fast_a_id_len = src->eap_fast_a_id_len;
1226           } else
1227                     dst->eap_fast_a_id = NULL;
1228           if (src->eap_fast_a_id_info) {
1229                     dst->eap_fast_a_id_info = os_strdup(src->eap_fast_a_id_info);
1230                     if (dst->eap_fast_a_id_info == NULL)
1231                               goto fail;
1232           } else
1233                     dst->eap_fast_a_id_info = NULL;
1234           dst->eap_fast_prov = src->eap_fast_prov;
1235           dst->pac_key_lifetime = src->pac_key_lifetime;
1236           dst->pac_key_refresh_time = src->pac_key_refresh_time;
1237           dst->eap_teap_auth = src->eap_teap_auth;
1238           dst->eap_teap_pac_no_inner = src->eap_teap_pac_no_inner;
1239           dst->eap_sim_aka_result_ind = src->eap_sim_aka_result_ind;
1240           dst->eap_sim_id = src->eap_sim_id;
1241           dst->tnc = src->tnc;
1242           dst->wps = src->wps;
1243           dst->fragment_size = src->fragment_size;
1244 
1245           os_free(dst->erp_domain);
1246           if (src->erp_domain) {
1247                     dst->erp_domain = os_strdup(src->erp_domain);
1248                     if (dst->erp_domain == NULL)
1249                               goto fail;
1250           } else {
1251                     dst->erp_domain = NULL;
1252           }
1253           dst->erp_send_reauth_start = src->erp_send_reauth_start;
1254           dst->erp = src->erp;
1255           dst->tls_session_lifetime = src->tls_session_lifetime;
1256           dst->tls_flags = src->tls_flags;
1257 
1258           return 0;
1259 
1260 fail:
1261           eapol_auth_conf_free(dst);
1262           return -1;
1263 }
1264 
1265 
eapol_auth_conf_free(struct eapol_auth_config * conf)1266 static void eapol_auth_conf_free(struct eapol_auth_config *conf)
1267 {
1268           os_free(conf->eap_req_id_text);
1269           conf->eap_req_id_text = NULL;
1270           os_free(conf->pac_opaque_encr_key);
1271           conf->pac_opaque_encr_key = NULL;
1272           os_free(conf->eap_fast_a_id);
1273           conf->eap_fast_a_id = NULL;
1274           os_free(conf->eap_fast_a_id_info);
1275           conf->eap_fast_a_id_info = NULL;
1276           os_free(conf->erp_domain);
1277           conf->erp_domain = NULL;
1278 }
1279 
1280 
eapol_auth_init(struct eapol_auth_config * conf,struct eapol_auth_cb * cb)1281 struct eapol_authenticator * eapol_auth_init(struct eapol_auth_config *conf,
1282                                                        struct eapol_auth_cb *cb)
1283 {
1284           struct eapol_authenticator *eapol;
1285 
1286           eapol = os_zalloc(sizeof(*eapol));
1287           if (eapol == NULL)
1288                     return NULL;
1289 
1290           if (eapol_auth_conf_clone(&eapol->conf, conf) < 0) {
1291                     os_free(eapol);
1292                     return NULL;
1293           }
1294 
1295           if (conf->individual_wep_key_len > 0) {
1296                     /* use key0 in individual key and key1 in broadcast key */
1297                     eapol->default_wep_key_idx = 1;
1298           }
1299 
1300           eapol->cb.eapol_send = cb->eapol_send;
1301           eapol->cb.aaa_send = cb->aaa_send;
1302           eapol->cb.finished = cb->finished;
1303           eapol->cb.get_eap_user = cb->get_eap_user;
1304           eapol->cb.sta_entry_alive = cb->sta_entry_alive;
1305           eapol->cb.logger = cb->logger;
1306           eapol->cb.set_port_authorized = cb->set_port_authorized;
1307           eapol->cb.abort_auth = cb->abort_auth;
1308           eapol->cb.tx_key = cb->tx_key;
1309           eapol->cb.eapol_event = cb->eapol_event;
1310           eapol->cb.erp_get_key = cb->erp_get_key;
1311           eapol->cb.erp_add_key = cb->erp_add_key;
1312 
1313           return eapol;
1314 }
1315 
1316 
eapol_auth_deinit(struct eapol_authenticator * eapol)1317 void eapol_auth_deinit(struct eapol_authenticator *eapol)
1318 {
1319           if (eapol == NULL)
1320                     return;
1321 
1322           eapol_auth_conf_free(&eapol->conf);
1323           os_free(eapol->default_wep_key);
1324           os_free(eapol);
1325 }
1326