Lines Matching +full:common +full:- +full:auth
3 * Copyright (c) 2019-2020, The Linux Foundation
4 * Copyright (c) 2021-2022, Qualcomm Innovation Center, Inc.
13 #include "utils/common.h"
16 #include "common/ieee802_11_common.h"
17 #include "common/wpa_ctrl.h"
29 struct dpp_authentication *auth; member
32 int (*process_conf_obj)(void *ctx, struct dpp_authentication *auth);
34 bool (*tcp_msg_sent)(void *ctx, struct dpp_authentication *auth);
86 int (*process_conf_obj)(void *ctx, struct dpp_authentication *auth);
87 bool (*tcp_msg_sent)(void *ctx, struct dpp_authentication *auth);
104 if (conn->sock >= 0) { in dpp_connection_free()
106 conn->sock); in dpp_connection_free()
107 eloop_unregister_sock(conn->sock, EVENT_TYPE_READ); in dpp_connection_free()
108 eloop_unregister_sock(conn->sock, EVENT_TYPE_WRITE); in dpp_connection_free()
109 close(conn->sock); in dpp_connection_free()
119 wpabuf_free(conn->msg); in dpp_connection_free()
120 wpabuf_free(conn->msg_out); in dpp_connection_free()
121 dpp_auth_deinit(conn->auth); in dpp_connection_free()
122 dpp_pkex_free(conn->pkex); in dpp_connection_free()
123 os_free(conn->name); in dpp_connection_free()
124 os_free(conn->mud_url); in dpp_connection_free()
125 os_free(conn->extra_conf_req_name); in dpp_connection_free()
126 os_free(conn->extra_conf_req_value); in dpp_connection_free()
133 dl_list_del(&conn->list); in dpp_connection_remove()
145 return -1; in dpp_relay_add_controller()
149 return -1; in dpp_relay_add_controller()
150 dl_list_init(&ctrl->conn); in dpp_relay_add_controller()
151 ctrl->global = dpp; in dpp_relay_add_controller()
152 os_memcpy(&ctrl->ipaddr, config->ipaddr, sizeof(*config->ipaddr)); in dpp_relay_add_controller()
153 os_memcpy(ctrl->pkhash, config->pkhash, SHA256_MAC_LEN); in dpp_relay_add_controller()
154 ctrl->msg_ctx = config->msg_ctx; in dpp_relay_add_controller()
155 ctrl->cb_ctx = config->cb_ctx; in dpp_relay_add_controller()
156 ctrl->tx = config->tx; in dpp_relay_add_controller()
157 ctrl->gas_resp_tx = config->gas_resp_tx; in dpp_relay_add_controller()
159 hostapd_ip_txt(&ctrl->ipaddr, txt, sizeof(txt))); in dpp_relay_add_controller()
160 dl_list_add(&dpp->controllers, &ctrl->list); in dpp_relay_add_controller()
173 dl_list_for_each(ctrl, &dpp->controllers, struct dpp_relay_controller, in dpp_relay_controller_get()
175 if (os_memcmp(pkhash, ctrl->pkhash, SHA256_MAC_LEN) == 0) in dpp_relay_controller_get()
191 dl_list_for_each(ctrl, &dpp->controllers, struct dpp_relay_controller, in dpp_relay_controller_get_ctx()
193 if (cb_ctx == ctrl->cb_ctx) in dpp_relay_controller_get_ctx()
210 dl_list_for_each(ctrl, &dpp->controllers, struct dpp_relay_controller, in dpp_relay_controller_get_addr()
212 if (ctrl->ipaddr.af == AF_INET && in dpp_relay_controller_get_addr()
213 addr->sin_addr.s_addr == ctrl->ipaddr.u.v4.s_addr) in dpp_relay_controller_get_addr()
217 if (dpp->tmp_controller && in dpp_relay_controller_get_addr()
218 dpp->tmp_controller->ipaddr.af == AF_INET && in dpp_relay_controller_get_addr()
219 addr->sin_addr.s_addr == dpp->tmp_controller->ipaddr.u.v4.s_addr) in dpp_relay_controller_get_addr()
220 return dpp->tmp_controller; in dpp_relay_controller_get_addr()
228 struct dpp_authentication *auth = conn->auth; in dpp_controller_gas_done() local
230 if (auth->waiting_csr) { in dpp_controller_gas_done()
232 conn->on_tcp_tx_complete_gas_done = 0; in dpp_controller_gas_done()
237 if (auth->waiting_new_key) { in dpp_controller_gas_done()
239 conn->on_tcp_tx_complete_gas_done = 0; in dpp_controller_gas_done()
244 if (auth->peer_version >= 2 && in dpp_controller_gas_done()
245 auth->conf_resp_status == DPP_STATUS_OK) { in dpp_controller_gas_done()
247 auth->waiting_conf_result = 1; in dpp_controller_gas_done()
251 wpa_msg(conn->msg_ctx, MSG_INFO, DPP_EVENT_CONF_SENT "conf_status=%d", in dpp_controller_gas_done()
252 auth->conf_resp_status); in dpp_controller_gas_done()
261 if (!conn->msg_out) { in dpp_tcp_send()
262 eloop_unregister_sock(conn->sock, EVENT_TYPE_WRITE); in dpp_tcp_send()
263 conn->write_eloop = 0; in dpp_tcp_send()
264 return -1; in dpp_tcp_send()
266 res = send(conn->sock, in dpp_tcp_send()
267 wpabuf_head_u8(conn->msg_out) + conn->msg_out_pos, in dpp_tcp_send()
268 wpabuf_len(conn->msg_out) - conn->msg_out_pos, 0); in dpp_tcp_send()
273 return -1; in dpp_tcp_send()
276 conn->msg_out_pos += res; in dpp_tcp_send()
277 if (wpabuf_len(conn->msg_out) > conn->msg_out_pos) { in dpp_tcp_send()
280 (unsigned int) conn->msg_out_pos, in dpp_tcp_send()
281 (unsigned int) wpabuf_len(conn->msg_out)); in dpp_tcp_send()
282 if (!conn->write_eloop && in dpp_tcp_send()
283 eloop_register_sock(conn->sock, EVENT_TYPE_WRITE, in dpp_tcp_send()
285 conn->write_eloop = 1; in dpp_tcp_send()
290 wpabuf_free(conn->msg_out); in dpp_tcp_send()
291 conn->msg_out = NULL; in dpp_tcp_send()
292 conn->msg_out_pos = 0; in dpp_tcp_send()
293 eloop_unregister_sock(conn->sock, EVENT_TYPE_WRITE); in dpp_tcp_send()
294 conn->write_eloop = 0; in dpp_tcp_send()
295 if (!conn->read_eloop && in dpp_tcp_send()
296 eloop_register_sock(conn->sock, EVENT_TYPE_READ, in dpp_tcp_send()
298 conn->read_eloop = 1; in dpp_tcp_send()
299 if (conn->on_tcp_tx_complete_remove) { in dpp_tcp_send()
300 if (conn->auth && conn->auth->connect_on_tx_status && in dpp_tcp_send()
301 conn->tcp_msg_sent && in dpp_tcp_send()
302 conn->tcp_msg_sent(conn->cb_ctx, conn->auth)) in dpp_tcp_send()
305 } else if (conn->auth && (conn->ctrl || conn->auth->configurator) && in dpp_tcp_send()
306 conn->on_tcp_tx_complete_gas_done) { in dpp_tcp_send()
308 } else if (conn->on_tcp_tx_complete_auth_ok) { in dpp_tcp_send()
309 conn->on_tcp_tx_complete_auth_ok = 0; in dpp_tcp_send()
320 wpabuf_free(conn->msg_out); in dpp_tcp_send_msg()
321 conn->msg_out_pos = 0; in dpp_tcp_send_msg()
322 conn->msg_out = wpabuf_alloc(4 + wpabuf_len(msg) - 1); in dpp_tcp_send_msg()
323 if (!conn->msg_out) in dpp_tcp_send_msg()
324 return -1; in dpp_tcp_send_msg()
325 wpabuf_put_be32(conn->msg_out, wpabuf_len(msg) - 1); in dpp_tcp_send_msg()
326 wpabuf_put_data(conn->msg_out, wpabuf_head_u8(msg) + 1, in dpp_tcp_send_msg()
327 wpabuf_len(msg) - 1); in dpp_tcp_send_msg()
330 if (!conn->write_eloop) { in dpp_tcp_send_msg()
331 if (eloop_register_sock(conn->sock, EVENT_TYPE_WRITE, in dpp_tcp_send_msg()
334 return -1; in dpp_tcp_send_msg()
335 conn->write_eloop = 1; in dpp_tcp_send_msg()
345 struct dpp_authentication *auth = conn->auth; in dpp_controller_start_gas_client() local
349 dpp_name = conn->name ? conn->name : "Test"; in dpp_controller_start_gas_client()
350 buf = dpp_build_conf_req_helper(auth, dpp_name, conn->netrole, in dpp_controller_start_gas_client()
351 conn->mud_url, NULL, in dpp_controller_start_gas_client()
352 conn->extra_conf_req_name, in dpp_controller_start_gas_client()
353 conn->extra_conf_req_value); in dpp_controller_start_gas_client()
368 struct dpp_authentication *auth = conn->auth; in dpp_controller_auth_success() local
370 if (!auth) in dpp_controller_auth_success()
374 dpp_notify_auth_success(auth, initiator); in dpp_controller_auth_success()
378 "DPP: TESTING - stop at Authentication Confirm"); in dpp_controller_auth_success()
379 if (auth->configurator) { in dpp_controller_auth_success()
381 auth->auth_success = 0; in dpp_controller_auth_success()
387 if (!auth->configurator) in dpp_controller_auth_success()
410 switch (ipaddr->af) { in dpp_ipaddr_to_sockaddr()
414 dst->sin_family = AF_INET; in dpp_ipaddr_to_sockaddr()
415 dst->sin_addr.s_addr = ipaddr->u.v4.s_addr; in dpp_ipaddr_to_sockaddr()
416 dst->sin_port = htons(port); in dpp_ipaddr_to_sockaddr()
423 dst6->sin6_family = AF_INET6; in dpp_ipaddr_to_sockaddr()
424 os_memcpy(&dst6->sin6_addr, &ipaddr->u.v6, in dpp_ipaddr_to_sockaddr()
426 dst6->sin6_port = htons(port); in dpp_ipaddr_to_sockaddr()
431 return -1; in dpp_ipaddr_to_sockaddr()
457 if (dl_list_len(&ctrl->conn) >= 15) { in dpp_relay_new_conn()
459 "DPP: Too many ongoing Relay connections to the Controller - cannot start a new one"); in dpp_relay_new_conn()
464 &ctrl->ipaddr, DPP_TCP_PORT) < 0) in dpp_relay_new_conn()
471 conn->global = ctrl->global; in dpp_relay_new_conn()
472 conn->relay = ctrl; in dpp_relay_new_conn()
473 conn->msg_ctx = ctrl->msg_ctx; in dpp_relay_new_conn()
474 conn->cb_ctx = ctrl->global->cb_ctx; in dpp_relay_new_conn()
475 os_memcpy(conn->mac_addr, src, ETH_ALEN); in dpp_relay_new_conn()
476 conn->freq = freq; in dpp_relay_new_conn()
478 conn->sock = socket(AF_INET, SOCK_STREAM, 0); in dpp_relay_new_conn()
479 if (conn->sock < 0) in dpp_relay_new_conn()
482 conn->sock, hostapd_ip_txt(&ctrl->ipaddr, txt, sizeof(txt))); in dpp_relay_new_conn()
484 if (fcntl(conn->sock, F_SETFL, O_NONBLOCK) != 0) { in dpp_relay_new_conn()
490 if (connect(conn->sock, (struct sockaddr *) &addr, addrlen) < 0) { in dpp_relay_new_conn()
503 if (eloop_register_sock(conn->sock, EVENT_TYPE_WRITE, in dpp_relay_new_conn()
506 conn->write_eloop = 1; in dpp_relay_new_conn()
511 dl_list_add(&ctrl->conn, &conn->list); in dpp_relay_new_conn()
538 u8 type = hdr[DPP_HDR_LEN - 1]; in dpp_relay_tx()
542 wpabuf_free(conn->msg_out); in dpp_relay_tx()
543 conn->msg_out_pos = 0; in dpp_relay_tx()
544 conn->msg_out = dpp_tcp_encaps(hdr, buf, len); in dpp_relay_tx()
545 if (!conn->msg_out) { in dpp_relay_tx()
547 return -1; in dpp_relay_tx()
553 conn->on_tcp_tx_complete_remove = 1; in dpp_relay_tx()
565 dl_list_for_each(conn, &ctrl->conn, struct dpp_connection, list) { in dpp_relay_match_ctrl()
566 if (ether_addr_equal(src, conn->mac_addr)) in dpp_relay_match_ctrl()
570 conn->freq == 0 && in dpp_relay_match_ctrl()
571 is_broadcast_ether_addr(conn->mac_addr)) { in dpp_relay_match_ctrl()
574 os_memcpy(conn->mac_addr, src, ETH_ALEN); in dpp_relay_match_ctrl()
575 conn->freq = freq; in dpp_relay_match_ctrl()
591 u8 type = hdr[DPP_HDR_LEN - 1]; in dpp_relay_rx_action()
600 dl_list_for_each(ctrl, &dpp->controllers, in dpp_relay_rx_action()
607 if (dpp->tmp_controller) { in dpp_relay_rx_action()
608 conn = dpp_relay_match_ctrl(dpp->tmp_controller, src, in dpp_relay_rx_action()
624 return -1; in dpp_relay_rx_action()
628 return -1; in dpp_relay_rx_action()
634 (!conn->auth || conn->auth->waiting_auth_resp)) { in dpp_relay_rx_action()
636 "DPP: Use existing TCP connection to Controller since no Auth Resp seen on it yet"); in dpp_relay_rx_action()
645 return -1; in dpp_relay_rx_action()
647 conn->msg_out = dpp_tcp_encaps(hdr, buf, len); in dpp_relay_rx_action()
648 if (!conn->msg_out) { in dpp_relay_rx_action()
650 return -1; in dpp_relay_rx_action()
663 dl_list_for_each(conn, &ctrl->conn, struct dpp_connection, list) { in dpp_relay_find_conn()
664 if (ether_addr_equal(src, conn->mac_addr)) in dpp_relay_find_conn()
682 dl_list_for_each(ctrl, &dpp->controllers, in dpp_relay_rx_gas_req()
689 if (!conn && dpp->tmp_controller) in dpp_relay_rx_gas_req()
690 conn = dpp_relay_find_conn(dpp->tmp_controller, src); in dpp_relay_rx_gas_req()
693 return -1; in dpp_relay_rx_gas_req()
697 return -1; in dpp_relay_rx_gas_req()
703 wpabuf_free(conn->msg_out); in dpp_relay_rx_gas_req()
704 conn->msg_out_pos = 0; in dpp_relay_rx_gas_req()
705 conn->msg_out = msg; in dpp_relay_rx_gas_req()
713 return dpp && dl_list_len(&dpp->controllers) > 0; in dpp_relay_controller_available()
724 dl_list_for_each_safe(conn, tmp, &ctrl->conn, struct dpp_connection, in dpp_controller_free()
728 if (ctrl->sock >= 0) { in dpp_controller_free()
729 close(ctrl->sock); in dpp_controller_free()
730 eloop_unregister_sock(ctrl->sock, EVENT_TYPE_READ); in dpp_controller_free()
732 os_free(ctrl->configurator_params); in dpp_controller_free()
733 os_free(ctrl->pkex_code); in dpp_controller_free()
734 os_free(ctrl->pkex_identifier); in dpp_controller_free()
746 if (!conn->ctrl) in dpp_controller_rx_auth_req()
756 return -1; in dpp_controller_rx_auth_req()
766 return -1; in dpp_controller_rx_auth_req()
773 dpp_bootstrap_find_pair(conn->ctrl->global, i_bootstrap, r_bootstrap, in dpp_controller_rx_auth_req()
777 "No matching own bootstrapping key found - ignore message"); in dpp_controller_rx_auth_req()
778 return -1; in dpp_controller_rx_auth_req()
781 if (conn->auth) { in dpp_controller_rx_auth_req()
783 "Already in DPP authentication exchange - ignore new one"); in dpp_controller_rx_auth_req()
787 conn->auth = dpp_auth_req_rx(conn->ctrl->global, conn->msg_ctx, in dpp_controller_rx_auth_req()
788 conn->ctrl->allowed_roles, in dpp_controller_rx_auth_req()
789 conn->ctrl->qr_mutual, in dpp_controller_rx_auth_req()
790 peer_bi, own_bi, -1, hdr, buf, len); in dpp_controller_rx_auth_req()
791 if (!conn->auth) { in dpp_controller_rx_auth_req()
793 return -1; in dpp_controller_rx_auth_req()
796 if (dpp_set_configurator(conn->auth, in dpp_controller_rx_auth_req()
797 conn->ctrl->configurator_params) < 0) in dpp_controller_rx_auth_req()
798 return -1; in dpp_controller_rx_auth_req()
800 return dpp_tcp_send_msg(conn, conn->auth->resp_msg); in dpp_controller_rx_auth_req()
807 struct dpp_authentication *auth = conn->auth; in dpp_controller_rx_auth_resp() local
811 if (!auth) in dpp_controller_rx_auth_resp()
812 return -1; in dpp_controller_rx_auth_resp()
816 msg = dpp_auth_resp_rx(auth, hdr, buf, len); in dpp_controller_rx_auth_resp()
818 if (auth->auth_resp_status == DPP_STATUS_RESPONSE_PENDING) { in dpp_controller_rx_auth_resp()
824 return -1; in dpp_controller_rx_auth_resp()
827 conn->on_tcp_tx_complete_auth_ok = 1; in dpp_controller_rx_auth_resp()
837 struct dpp_authentication *auth = conn->auth; in dpp_controller_rx_auth_conf() local
841 if (!auth) { in dpp_controller_rx_auth_conf()
843 "DPP: No DPP Authentication in progress - drop"); in dpp_controller_rx_auth_conf()
844 return -1; in dpp_controller_rx_auth_conf()
847 if (dpp_auth_conf_rx(auth, hdr, buf, len) < 0) { in dpp_controller_rx_auth_conf()
849 return -1; in dpp_controller_rx_auth_conf()
862 if (!conn->auth->waiting_conf_result) in dpp_controller_conn_status_result_wait_timeout()
867 wpa_msg(conn->msg_ctx, MSG_INFO, in dpp_controller_conn_status_result_wait_timeout()
877 struct dpp_authentication *auth = conn->auth; in dpp_controller_rx_conf_result() local
879 void *msg_ctx = conn->msg_ctx; in dpp_controller_rx_conf_result()
881 if (!conn->ctrl && (!auth || !auth->configurator)) in dpp_controller_rx_conf_result()
886 if (!auth || !auth->waiting_conf_result) { in dpp_controller_rx_conf_result()
888 "DPP: No DPP Configuration waiting for result - drop"); in dpp_controller_rx_conf_result()
889 return -1; in dpp_controller_rx_conf_result()
892 status = dpp_conf_result_rx(auth, hdr, buf, len); in dpp_controller_rx_conf_result()
893 if (status == DPP_STATUS_OK && auth->send_conn_status) { in dpp_controller_rx_conf_result()
896 auth->conf_resp_status); in dpp_controller_rx_conf_result()
898 auth->waiting_conn_status_result = 1; in dpp_controller_rx_conf_result()
909 "conf_resp_status=%d", auth->conf_resp_status); in dpp_controller_rx_conf_result()
912 return -1; /* to remove the completed connection */ in dpp_controller_rx_conf_result()
920 struct dpp_authentication *auth = conn->auth; in dpp_controller_rx_conn_status_result() local
926 if (!conn->ctrl) in dpp_controller_rx_conn_status_result()
931 if (!auth || !auth->waiting_conn_status_result) { in dpp_controller_rx_conn_status_result()
933 "DPP: No DPP Configuration waiting for connection status result - drop"); in dpp_controller_rx_conn_status_result()
934 return -1; in dpp_controller_rx_conn_status_result()
937 status = dpp_conn_status_result_rx(auth, hdr, buf, len, in dpp_controller_rx_conn_status_result()
939 wpa_msg(conn->msg_ctx, MSG_INFO, DPP_EVENT_CONN_STATUS_RESULT in dpp_controller_rx_conn_status_result()
944 return -1; /* to remove the completed connection */ in dpp_controller_rx_conn_status_result()
955 struct dpp_authentication *auth; in dpp_controller_rx_presence_announcement() local
956 struct dpp_global *dpp = conn->ctrl->global; in dpp_controller_rx_presence_announcement()
963 wpa_msg(conn->msg_ctx, MSG_INFO, DPP_EVENT_FAIL in dpp_controller_rx_presence_announcement()
965 return -1; in dpp_controller_rx_presence_announcement()
973 return -1; in dpp_controller_rx_presence_announcement()
976 if (conn->auth) { in dpp_controller_rx_presence_announcement()
982 auth = dpp_auth_init(dpp, conn->msg_ctx, peer_bi, NULL, in dpp_controller_rx_presence_announcement()
983 DPP_CAPAB_CONFIGURATOR, -1, NULL, 0); in dpp_controller_rx_presence_announcement()
984 if (!auth) in dpp_controller_rx_presence_announcement()
985 return -1; in dpp_controller_rx_presence_announcement()
986 if (dpp_set_configurator(auth, conn->ctrl->configurator_params) < 0) { in dpp_controller_rx_presence_announcement()
987 dpp_auth_deinit(auth); in dpp_controller_rx_presence_announcement()
988 return -1; in dpp_controller_rx_presence_announcement()
991 conn->auth = auth; in dpp_controller_rx_presence_announcement()
992 return dpp_tcp_send_msg(conn, conn->auth->req_msg); in dpp_controller_rx_presence_announcement()
1003 struct dpp_global *dpp = conn->ctrl->global; in dpp_controller_rx_reconfig_announcement()
1004 struct dpp_authentication *auth; in dpp_controller_rx_reconfig_announcement() local
1007 if (conn->auth) { in dpp_controller_rx_reconfig_announcement()
1010 return -1; in dpp_controller_rx_reconfig_announcement()
1018 wpa_msg(conn->msg_ctx, MSG_INFO, DPP_EVENT_FAIL in dpp_controller_rx_reconfig_announcement()
1019 "Missing or invalid required Configurator C-sign key Hash attribute"); in dpp_controller_rx_reconfig_announcement()
1020 return -1; in dpp_controller_rx_reconfig_announcement()
1022 wpa_hexdump(MSG_MSGDUMP, "DPP: Configurator C-sign key Hash (kid)", in dpp_controller_rx_reconfig_announcement()
1028 return -1; in dpp_controller_rx_reconfig_announcement()
1034 wpa_msg(conn->msg_ctx, MSG_INFO, DPP_EVENT_FAIL in dpp_controller_rx_reconfig_announcement()
1036 return -1; in dpp_controller_rx_reconfig_announcement()
1044 auth = dpp_reconfig_init(dpp, conn->msg_ctx, conf, 0, group, in dpp_controller_rx_reconfig_announcement()
1046 if (!auth) in dpp_controller_rx_reconfig_announcement()
1047 return -1; in dpp_controller_rx_reconfig_announcement()
1048 if (dpp_set_configurator(auth, conn->ctrl->configurator_params) < 0) { in dpp_controller_rx_reconfig_announcement()
1049 dpp_auth_deinit(auth); in dpp_controller_rx_reconfig_announcement()
1050 return -1; in dpp_controller_rx_reconfig_announcement()
1053 conn->auth = auth; in dpp_controller_rx_reconfig_announcement()
1054 return dpp_tcp_send_msg(conn, auth->reconfig_req_msg); in dpp_controller_rx_reconfig_announcement()
1062 struct dpp_authentication *auth = conn->auth; in dpp_controller_rx_reconfig_auth_resp() local
1068 if (!auth || !auth->reconfig || !auth->configurator) { in dpp_controller_rx_reconfig_auth_resp()
1070 "DPP: No DPP Reconfig Authentication in progress - drop"); in dpp_controller_rx_reconfig_auth_resp()
1071 return -1; in dpp_controller_rx_reconfig_auth_resp()
1074 conf = dpp_reconfig_auth_resp_rx(auth, hdr, buf, len); in dpp_controller_rx_reconfig_auth_resp()
1076 return -1; in dpp_controller_rx_reconfig_auth_resp()
1088 struct dpp_controller *ctrl = conn->ctrl; in dpp_controller_rx_pkex_exchange_req()
1098 if (!ctrl->pkex_code || !ctrl->pkex_bi) { in dpp_controller_rx_pkex_exchange_req()
1100 "DPP: No PKEX code configured - ignore request"); in dpp_controller_rx_pkex_exchange_req()
1104 if (conn->pkex || conn->auth) { in dpp_controller_rx_pkex_exchange_req()
1106 "DPP: Already in PKEX/Authentication session - ignore new PKEX request"); in dpp_controller_rx_pkex_exchange_req()
1110 conn->pkex = dpp_pkex_rx_exchange_req(conn->msg_ctx, ctrl->pkex_bi, in dpp_controller_rx_pkex_exchange_req()
1112 ctrl->pkex_identifier, in dpp_controller_rx_pkex_exchange_req()
1113 ctrl->pkex_code, in dpp_controller_rx_pkex_exchange_req()
1114 os_strlen(ctrl->pkex_code), in dpp_controller_rx_pkex_exchange_req()
1116 if (!conn->pkex) { in dpp_controller_rx_pkex_exchange_req()
1119 return -1; in dpp_controller_rx_pkex_exchange_req()
1122 return dpp_tcp_send_msg(conn, conn->pkex->exchange_resp); in dpp_controller_rx_pkex_exchange_req()
1130 struct dpp_pkex *pkex = conn->pkex; in dpp_controller_rx_pkex_exchange_resp()
1136 if (!pkex || !pkex->initiator || pkex->exchange_done) { in dpp_controller_rx_pkex_exchange_resp()
1144 return -1; in dpp_controller_rx_pkex_exchange_resp()
1147 wpa_printf(MSG_DEBUG, "DPP: Send PKEX Commit-Reveal Request"); in dpp_controller_rx_pkex_exchange_resp()
1158 struct dpp_pkex *pkex = conn->pkex; in dpp_controller_rx_pkex_commit_reveal_req()
1163 wpa_printf(MSG_DEBUG, "DPP: PKEX Commit-Reveal Request"); in dpp_controller_rx_pkex_commit_reveal_req()
1165 if (!pkex || pkex->initiator || !pkex->exchange_done) { in dpp_controller_rx_pkex_commit_reveal_req()
1173 return -1; in dpp_controller_rx_pkex_commit_reveal_req()
1176 wpa_printf(MSG_DEBUG, "DPP: Send PKEX Commit-Reveal Response"); in dpp_controller_rx_pkex_commit_reveal_req()
1181 bi = dpp_pkex_finish(conn->global, pkex, NULL, 0); in dpp_controller_rx_pkex_commit_reveal_req()
1183 return -1; in dpp_controller_rx_pkex_commit_reveal_req()
1184 conn->pkex = NULL; in dpp_controller_rx_pkex_commit_reveal_req()
1194 struct dpp_pkex *pkex = conn->pkex; in dpp_controller_rx_pkex_commit_reveal_resp()
1198 wpa_printf(MSG_DEBUG, "DPP: PKEX Commit-Reveal Response"); in dpp_controller_rx_pkex_commit_reveal_resp()
1200 if (!pkex || !pkex->initiator || !pkex->exchange_done) { in dpp_controller_rx_pkex_commit_reveal_resp()
1211 bi = dpp_pkex_finish(conn->global, pkex, NULL, 0); in dpp_controller_rx_pkex_commit_reveal_resp()
1213 return -1; in dpp_controller_rx_pkex_commit_reveal_resp()
1214 conn->pkex = NULL; in dpp_controller_rx_pkex_commit_reveal_resp()
1216 if (!conn->pkex_done) in dpp_controller_rx_pkex_commit_reveal_resp()
1217 return -1; in dpp_controller_rx_pkex_commit_reveal_resp()
1218 return conn->pkex_done(conn->cb_ctx, conn, bi); in dpp_controller_rx_pkex_commit_reveal_resp()
1232 if (end - pos < DPP_HDR_LEN || in dpp_controller_rx_action()
1236 return -1; in dpp_controller_rx_action()
1242 return -1; in dpp_controller_rx_action()
1249 pos, end - pos); in dpp_controller_rx_action()
1250 if (dpp_check_attrs(pos, end - pos) < 0) in dpp_controller_rx_action()
1251 return -1; in dpp_controller_rx_action()
1253 if (conn->relay) { in dpp_controller_rx_action()
1254 wpa_printf(MSG_DEBUG, "DPP: Relay - send over WLAN"); in dpp_controller_rx_action()
1255 conn->relay->tx(conn->relay->cb_ctx, conn->mac_addr, in dpp_controller_rx_action()
1256 conn->freq, msg, len); in dpp_controller_rx_action()
1262 return dpp_controller_rx_auth_req(conn, msg, pos, end - pos); in dpp_controller_rx_action()
1264 return dpp_controller_rx_auth_resp(conn, msg, pos, end - pos); in dpp_controller_rx_action()
1266 return dpp_controller_rx_auth_conf(conn, msg, pos, end - pos); in dpp_controller_rx_action()
1268 return dpp_controller_rx_conf_result(conn, msg, pos, end - pos); in dpp_controller_rx_action()
1271 end - pos); in dpp_controller_rx_action()
1274 end - pos); in dpp_controller_rx_action()
1277 end - pos); in dpp_controller_rx_action()
1280 end - pos); in dpp_controller_rx_action()
1283 "DPP: Ignore PKEXv1 Exchange Request - not supported over TCP"); in dpp_controller_rx_action()
1284 return -1; in dpp_controller_rx_action()
1287 end - pos); in dpp_controller_rx_action()
1290 end - pos); in dpp_controller_rx_action()
1293 end - pos); in dpp_controller_rx_action()
1296 end - pos); in dpp_controller_rx_action()
1301 return -1; in dpp_controller_rx_action()
1316 return -1; in dpp_tcp_send_comeback_delay()
1321 wpabuf_put_u8(buf, conn->gas_dialog_token); in dpp_tcp_send_comeback_delay()
1332 wpabuf_free(conn->msg_out); in dpp_tcp_send_comeback_delay()
1333 conn->msg_out_pos = 0; in dpp_tcp_send_comeback_delay()
1334 conn->msg_out = buf; in dpp_tcp_send_comeback_delay()
1347 return -1; in dpp_tcp_send_gas_resp()
1356 return -1; in dpp_tcp_send_gas_resp()
1362 wpabuf_put_u8(buf, conn->gas_dialog_token); in dpp_tcp_send_gas_resp()
1375 wpabuf_free(conn->msg_out); in dpp_tcp_send_gas_resp()
1376 conn->msg_out_pos = 0; in dpp_tcp_send_gas_resp()
1377 conn->msg_out = buf; in dpp_tcp_send_gas_resp()
1378 conn->on_tcp_tx_complete_gas_done = 1; in dpp_tcp_send_gas_resp()
1391 struct dpp_authentication *auth = conn->auth; in dpp_controller_rx_gas_req() local
1394 return -1; in dpp_controller_rx_gas_req()
1399 if (!auth || (!conn->ctrl && !auth->configurator) || in dpp_controller_rx_gas_req()
1400 (!auth->auth_success && !auth->reconfig_success)) { in dpp_controller_rx_gas_req()
1402 return -1; in dpp_controller_rx_gas_req()
1405 wpa_msg(conn->msg_ctx, MSG_INFO, DPP_EVENT_CONF_REQ_RX); in dpp_controller_rx_gas_req()
1410 conn->gas_dialog_token = *pos++; in dpp_controller_rx_gas_req()
1414 slen > end - pos || slen < 2) in dpp_controller_rx_gas_req()
1415 return -1; in dpp_controller_rx_gas_req()
1418 pos++; /* skip QueryRespLenLimit and PAME-BI */ in dpp_controller_rx_gas_req()
1423 return -1; in dpp_controller_rx_gas_req()
1427 if (end - pos < 2) in dpp_controller_rx_gas_req()
1428 return -1; in dpp_controller_rx_gas_req()
1431 if (slen > end - pos) in dpp_controller_rx_gas_req()
1432 return -1; in dpp_controller_rx_gas_req()
1434 resp = dpp_conf_req_rx(auth, pos, slen); in dpp_controller_rx_gas_req()
1435 if (!resp && auth->waiting_cert) { in dpp_controller_rx_gas_req()
1437 conn->gas_comeback_in_progress = 1; in dpp_controller_rx_gas_req()
1442 if (!resp && auth->waiting_config && auth->peer_bi) { in dpp_controller_rx_gas_req()
1445 int i, res, *opclass = auth->e_band_support; in dpp_controller_rx_gas_req()
1449 if (auth->e_name) { in dpp_controller_rx_gas_req()
1450 size_t e_len = os_strlen(auth->e_name); in dpp_controller_rx_gas_req()
1455 (const u8 *) auth->e_name, e_len); in dpp_controller_rx_gas_req()
1463 res = os_snprintf(b_pos, b_end - b_pos, "%s%d", in dpp_controller_rx_gas_req()
1465 if (os_snprintf_error(b_end - b_pos, res)) { in dpp_controller_rx_gas_req()
1471 if (auth->e_mud_url) { in dpp_controller_rx_gas_req()
1472 size_t e_len = os_strlen(auth->e_mud_url); in dpp_controller_rx_gas_req()
1474 if (!has_ctrl_char((const u8 *) auth->e_mud_url, e_len)) in dpp_controller_rx_gas_req()
1475 mud_url = auth->e_mud_url; in dpp_controller_rx_gas_req()
1477 wpa_msg(conn->msg_ctx, MSG_INFO, DPP_EVENT_CONF_NEEDED in dpp_controller_rx_gas_req()
1479 auth->peer_bi->id, dpp_netrole_str(auth->e_netrole), in dpp_controller_rx_gas_req()
1483 conn->gas_comeback_in_progress = 1; in dpp_controller_rx_gas_req()
1496 struct dpp_authentication *auth = conn->auth; in dpp_controller_rx_gas_comeback_req() local
1500 return -1; in dpp_controller_rx_gas_comeback_req()
1505 if (!auth || (!conn->ctrl && !auth->configurator) || in dpp_controller_rx_gas_comeback_req()
1506 (!auth->auth_success && !auth->reconfig_success) || in dpp_controller_rx_gas_comeback_req()
1507 !conn->gas_comeback_in_progress) { in dpp_controller_rx_gas_comeback_req()
1509 return -1; in dpp_controller_rx_gas_comeback_req()
1513 if (dialog_token != conn->gas_dialog_token) { in dpp_controller_rx_gas_comeback_req()
1515 dialog_token, conn->gas_dialog_token); in dpp_controller_rx_gas_comeback_req()
1516 return -1; in dpp_controller_rx_gas_comeback_req()
1519 if (!auth->conf_resp_tcp) { in dpp_controller_rx_gas_comeback_req()
1527 resp = auth->conf_resp_tcp; in dpp_controller_rx_gas_comeback_req()
1528 auth->conf_resp_tcp = NULL; in dpp_controller_rx_gas_comeback_req()
1536 struct dpp_authentication *auth = conn->auth; in dpp_tcp_build_csr() local
1538 if (!auth || !auth->csrattrs) in dpp_tcp_build_csr()
1542 wpabuf_free(auth->csr); in dpp_tcp_build_csr()
1544 auth->csr = dpp_build_csr(auth, conn->name ? conn->name : "Test"); in dpp_tcp_build_csr()
1545 if (!auth->csr) { in dpp_tcp_build_csr()
1558 struct dpp_authentication *auth = conn->auth; in dpp_tcp_build_new_key() local
1560 if (!auth || !auth->waiting_new_key) in dpp_tcp_build_new_key()
1571 struct dpp_authentication *auth = conn->auth; in dpp_tcp_rx_gas_resp() local
1579 if (auth) in dpp_tcp_rx_gas_resp()
1580 res = dpp_conf_resp_rx(auth, resp); in dpp_tcp_rx_gas_resp()
1582 res = -1; in dpp_tcp_rx_gas_resp()
1584 if (res == -2) { in dpp_tcp_rx_gas_resp()
1590 if (res == -3) { in dpp_tcp_rx_gas_resp()
1599 return -1; in dpp_tcp_rx_gas_resp()
1602 if (conn->process_conf_obj) in dpp_tcp_rx_gas_resp()
1603 res = conn->process_conf_obj(conn->cb_ctx, auth); in dpp_tcp_rx_gas_resp()
1607 if (auth->peer_version < 2 || auth->conf_resp_status != DPP_STATUS_OK) in dpp_tcp_rx_gas_resp()
1608 return -1; in dpp_tcp_rx_gas_resp()
1612 msg = dpp_build_conf_result(auth, status); in dpp_tcp_rx_gas_resp()
1614 return -1; in dpp_tcp_rx_gas_resp()
1616 conn->on_tcp_tx_complete_remove = 1; in dpp_tcp_rx_gas_resp()
1629 struct dpp_authentication *auth = conn->auth; in dpp_tcp_gas_query_comeback() local
1632 if (!auth) in dpp_tcp_gas_query_comeback()
1641 wpabuf_put_u8(msg, conn->gas_dialog_token); in dpp_tcp_gas_query_comeback()
1644 wpabuf_free(conn->msg_out); in dpp_tcp_gas_query_comeback()
1645 conn->msg_out_pos = 0; in dpp_tcp_gas_query_comeback()
1646 conn->msg_out = msg; in dpp_tcp_gas_query_comeback()
1660 return -1; in dpp_rx_gas_resp()
1672 return -1; in dpp_rx_gas_resp()
1683 slen > end - pos || slen < 2) in dpp_rx_gas_resp()
1684 return -1; in dpp_rx_gas_resp()
1687 pos++; /* skip QueryRespLenLimit and PAME-BI */ in dpp_rx_gas_resp()
1692 return -1; in dpp_rx_gas_resp()
1696 if (end - pos < 2) in dpp_rx_gas_resp()
1697 return -1; in dpp_rx_gas_resp()
1700 if (slen > end - pos) in dpp_rx_gas_resp()
1701 return -1; in dpp_rx_gas_resp()
1706 conn->gas_dialog_token = dialog_token; in dpp_rx_gas_resp()
1708 usecs = comeback_delay * 1024 - secs * 1000000; in dpp_rx_gas_resp()
1719 return -1; in dpp_rx_gas_resp()
1722 if (!conn->relay && in dpp_rx_gas_resp()
1723 (!conn->ctrl || (conn->ctrl->allowed_roles & DPP_CAPAB_ENROLLEE))) in dpp_rx_gas_resp()
1726 if (!conn->relay) { in dpp_rx_gas_resp()
1729 return -1; in dpp_rx_gas_resp()
1731 wpa_printf(MSG_DEBUG, "DPP: Relay - send over WLAN"); in dpp_rx_gas_resp()
1732 conn->relay->gas_resp_tx(conn->relay->cb_ctx, conn->mac_addr, in dpp_rx_gas_resp()
1748 if (conn->msg_len_octets < 4) { in dpp_controller_rx()
1751 res = recv(sd, &conn->msg_len[conn->msg_len_octets], in dpp_controller_rx()
1752 4 - conn->msg_len_octets, 0); in dpp_controller_rx()
1767 res, (int) (4 - conn->msg_len_octets)); in dpp_controller_rx()
1768 conn->msg_len_octets += res; in dpp_controller_rx()
1770 if (conn->msg_len_octets < 4) { in dpp_controller_rx()
1773 (int) (4 - conn->msg_len_octets)); in dpp_controller_rx()
1777 msglen = WPA_GET_BE32(conn->msg_len); in dpp_controller_rx()
1785 wpabuf_free(conn->msg); in dpp_controller_rx()
1786 conn->msg = wpabuf_alloc(msglen); in dpp_controller_rx()
1789 if (!conn->msg) { in dpp_controller_rx()
1797 (unsigned int) wpabuf_tailroom(conn->msg)); in dpp_controller_rx()
1799 res = recv(sd, wpabuf_put(conn->msg, 0), wpabuf_tailroom(conn->msg), 0); in dpp_controller_rx()
1811 wpabuf_put(conn->msg, res); in dpp_controller_rx()
1813 if (wpabuf_tailroom(conn->msg) > 0) { in dpp_controller_rx()
1816 (unsigned int) wpabuf_tailroom(conn->msg)); in dpp_controller_rx()
1820 conn->msg_len_octets = 0; in dpp_controller_rx()
1821 wpa_hexdump_buf(MSG_DEBUG, "DPP: Received TCP message", conn->msg); in dpp_controller_rx()
1822 if (wpabuf_len(conn->msg) < 1) { in dpp_controller_rx()
1827 pos = wpabuf_head(conn->msg); in dpp_controller_rx()
1831 wpabuf_len(conn->msg) - 1) < 0) in dpp_controller_rx()
1836 wpabuf_len(conn->msg) - 1) < 0) in dpp_controller_rx()
1842 wpabuf_len(conn->msg) - 1, in dpp_controller_rx()
1848 conn, pos + 1, wpabuf_len(conn->msg) - 1) < 0) in dpp_controller_rx()
1869 fd = accept(ctrl->sock, (struct sockaddr *) &addr, &addr_len); in dpp_controller_tcp_cb()
1883 conn->global = ctrl->global; in dpp_controller_tcp_cb()
1884 conn->ctrl = ctrl; in dpp_controller_tcp_cb()
1885 conn->msg_ctx = ctrl->msg_ctx; in dpp_controller_tcp_cb()
1886 conn->cb_ctx = ctrl->cb_ctx; in dpp_controller_tcp_cb()
1887 conn->process_conf_obj = ctrl->process_conf_obj; in dpp_controller_tcp_cb()
1888 conn->tcp_msg_sent = ctrl->tcp_msg_sent; in dpp_controller_tcp_cb()
1889 conn->sock = fd; in dpp_controller_tcp_cb()
1890 conn->netrole = ctrl->netrole; in dpp_controller_tcp_cb()
1892 if (fcntl(conn->sock, F_SETFL, O_NONBLOCK) != 0) { in dpp_controller_tcp_cb()
1898 if (eloop_register_sock(conn->sock, EVENT_TYPE_READ, in dpp_controller_tcp_cb()
1901 conn->read_eloop = 1; in dpp_controller_tcp_cb()
1905 dl_list_add(&ctrl->conn, &conn->list); in dpp_controller_tcp_cb()
1931 return -1; in dpp_tcp_pkex_init()
1937 return -1; in dpp_tcp_pkex_init()
1940 conn->msg_ctx = msg_ctx; in dpp_tcp_pkex_init()
1941 conn->cb_ctx = cb_ctx; in dpp_tcp_pkex_init()
1942 conn->pkex_done = pkex_done; in dpp_tcp_pkex_init()
1943 conn->global = dpp; in dpp_tcp_pkex_init()
1944 conn->pkex = pkex; in dpp_tcp_pkex_init()
1945 conn->sock = socket(AF_INET, SOCK_STREAM, 0); in dpp_tcp_pkex_init()
1946 if (conn->sock < 0) in dpp_tcp_pkex_init()
1949 if (fcntl(conn->sock, F_SETFL, O_NONBLOCK) != 0) { in dpp_tcp_pkex_init()
1955 if (connect(conn->sock, (struct sockaddr *) &saddr, addrlen) < 0) { in dpp_tcp_pkex_init()
1968 if (eloop_register_sock(conn->sock, EVENT_TYPE_WRITE, in dpp_tcp_pkex_init()
1971 conn->write_eloop = 1; in dpp_tcp_pkex_init()
1973 hdr = wpabuf_head(pkex->exchange_req); in dpp_tcp_pkex_init()
1974 end = hdr + wpabuf_len(pkex->exchange_req); in dpp_tcp_pkex_init()
1977 conn->msg_out = dpp_tcp_encaps(hdr, pos, end - pos); in dpp_tcp_pkex_init()
1978 if (!conn->msg_out) in dpp_tcp_pkex_init()
1984 dl_list_add(&dpp->tcp_init, &conn->list); in dpp_tcp_pkex_init()
1988 return -1; in dpp_tcp_pkex_init()
1993 struct dpp_authentication *auth) in dpp_tcp_auth_start() argument
1997 hdr = wpabuf_head(auth->req_msg); in dpp_tcp_auth_start()
1998 end = hdr + wpabuf_len(auth->req_msg); in dpp_tcp_auth_start()
2001 conn->msg_out = dpp_tcp_encaps(hdr, pos, end - pos); in dpp_tcp_auth_start()
2002 if (!conn->msg_out) in dpp_tcp_auth_start()
2003 return -1; in dpp_tcp_auth_start()
2009 int dpp_tcp_init(struct dpp_global *dpp, struct dpp_authentication *auth, in dpp_tcp_init() argument
2016 struct dpp_authentication *auth), in dpp_tcp_init() argument
2018 struct dpp_authentication *auth)) in dpp_tcp_init()
2029 dpp_auth_deinit(auth); in dpp_tcp_init()
2030 return -1; in dpp_tcp_init()
2035 dpp_auth_deinit(auth); in dpp_tcp_init()
2036 return -1; in dpp_tcp_init()
2039 conn->msg_ctx = msg_ctx; in dpp_tcp_init()
2040 conn->cb_ctx = cb_ctx; in dpp_tcp_init()
2041 conn->process_conf_obj = process_conf_obj; in dpp_tcp_init()
2042 conn->tcp_msg_sent = tcp_msg_sent; in dpp_tcp_init()
2043 conn->name = os_strdup(name ? name : "Test"); in dpp_tcp_init()
2045 conn->mud_url = os_strdup(mud_url); in dpp_tcp_init()
2047 conn->extra_conf_req_name = os_strdup(extra_conf_req_name); in dpp_tcp_init()
2049 conn->extra_conf_req_value = os_strdup(extra_conf_req_value); in dpp_tcp_init()
2050 conn->netrole = netrole; in dpp_tcp_init()
2051 conn->global = dpp; in dpp_tcp_init()
2052 conn->auth = auth; in dpp_tcp_init()
2053 conn->sock = socket(AF_INET, SOCK_STREAM, 0); in dpp_tcp_init()
2054 if (conn->sock < 0) in dpp_tcp_init()
2057 if (fcntl(conn->sock, F_SETFL, O_NONBLOCK) != 0) { in dpp_tcp_init()
2063 if (connect(conn->sock, (struct sockaddr *) &saddr, addrlen) < 0) { in dpp_tcp_init()
2076 if (eloop_register_sock(conn->sock, EVENT_TYPE_WRITE, in dpp_tcp_init()
2079 conn->write_eloop = 1; in dpp_tcp_init()
2081 if (dpp_tcp_auth_start(conn, auth) < 0) in dpp_tcp_init()
2086 dl_list_add(&dpp->tcp_init, &conn->list); in dpp_tcp_init()
2090 return -1; in dpp_tcp_init()
2095 struct dpp_authentication *auth, const char *name, in dpp_tcp_auth() argument
2100 struct dpp_authentication *auth), in dpp_tcp_auth() argument
2102 struct dpp_authentication *auth)) in dpp_tcp_auth()
2108 conn->process_conf_obj = process_conf_obj; in dpp_tcp_auth()
2109 conn->tcp_msg_sent = tcp_msg_sent; in dpp_tcp_auth()
2110 os_free(conn->name); in dpp_tcp_auth()
2111 conn->name = os_strdup(name ? name : "Test"); in dpp_tcp_auth()
2112 os_free(conn->mud_url); in dpp_tcp_auth()
2113 conn->mud_url = mud_url ? os_strdup(mud_url) : NULL; in dpp_tcp_auth()
2114 os_free(conn->extra_conf_req_name); in dpp_tcp_auth()
2115 conn->extra_conf_req_name = extra_conf_req_name ? in dpp_tcp_auth()
2117 conn->extra_conf_req_value = extra_conf_req_value ? in dpp_tcp_auth()
2119 conn->netrole = netrole; in dpp_tcp_auth()
2120 conn->auth = auth; in dpp_tcp_auth()
2122 if (dpp_tcp_auth_start(conn, auth) < 0) in dpp_tcp_auth()
2123 return -1; in dpp_tcp_auth()
2125 dpp_conn_tx_ready(conn->sock, conn, NULL); in dpp_tcp_auth()
2138 if (!dpp || dpp->controller) in dpp_controller_start()
2139 return -1; in dpp_controller_start()
2143 return -1; in dpp_controller_start()
2144 ctrl->global = dpp; in dpp_controller_start()
2145 if (config->configurator_params) in dpp_controller_start()
2146 ctrl->configurator_params = in dpp_controller_start()
2147 os_strdup(config->configurator_params); in dpp_controller_start()
2148 dl_list_init(&ctrl->conn); in dpp_controller_start()
2149 ctrl->allowed_roles = config->allowed_roles; in dpp_controller_start()
2150 ctrl->qr_mutual = config->qr_mutual; in dpp_controller_start()
2151 ctrl->netrole = config->netrole; in dpp_controller_start()
2152 ctrl->msg_ctx = config->msg_ctx; in dpp_controller_start()
2153 ctrl->cb_ctx = config->cb_ctx; in dpp_controller_start()
2154 ctrl->process_conf_obj = config->process_conf_obj; in dpp_controller_start()
2155 ctrl->tcp_msg_sent = config->tcp_msg_sent; in dpp_controller_start()
2157 ctrl->sock = socket(AF_INET, SOCK_STREAM, 0); in dpp_controller_start()
2158 if (ctrl->sock < 0) in dpp_controller_start()
2161 if (setsockopt(ctrl->sock, SOL_SOCKET, SO_REUSEADDR, in dpp_controller_start()
2169 if (fcntl(ctrl->sock, F_SETFL, O_NONBLOCK) < 0) { in dpp_controller_start()
2179 port = config->tcp_port ? config->tcp_port : DPP_TCP_PORT; in dpp_controller_start()
2181 if (bind(ctrl->sock, (struct sockaddr *) &sin, sizeof(sin)) < 0) { in dpp_controller_start()
2187 if (listen(ctrl->sock, 10 /* max backlog */) < 0 || in dpp_controller_start()
2188 fcntl(ctrl->sock, F_SETFL, O_NONBLOCK) < 0 || in dpp_controller_start()
2189 eloop_register_sock(ctrl->sock, EVENT_TYPE_READ, in dpp_controller_start()
2193 dpp->controller = ctrl; in dpp_controller_start()
2198 return -1; in dpp_controller_start()
2206 if (!dpp || !dpp->controller) in dpp_controller_set_params()
2207 return -1; in dpp_controller_set_params()
2213 return -1; in dpp_controller_set_params()
2214 os_free(dpp->controller->configurator_params); in dpp_controller_set_params()
2215 dpp->controller->configurator_params = val; in dpp_controller_set_params()
2217 os_free(dpp->controller->configurator_params); in dpp_controller_set_params()
2218 dpp->controller->configurator_params = NULL; in dpp_controller_set_params()
2228 dpp_controller_free(dpp->controller); in dpp_controller_stop()
2229 dpp->controller = NULL; in dpp_controller_stop()
2236 if (dpp && dpp->controller && dpp->controller->cb_ctx == cb_ctx) in dpp_controller_stop_for_ctx()
2241 static bool dpp_tcp_peer_id_match(struct dpp_authentication *auth, in dpp_tcp_peer_id_match() argument
2244 return auth && in dpp_tcp_peer_id_match()
2245 ((auth->peer_bi && auth->peer_bi->id == id) || in dpp_tcp_peer_id_match()
2246 (auth->tmp_peer_bi && auth->tmp_peer_bi->id == id)); in dpp_tcp_peer_id_match()
2255 dl_list_for_each(conn, &dpp->tcp_init, struct dpp_connection, list) { in dpp_tcp_get_auth()
2256 if (dpp_tcp_peer_id_match(conn->auth, id)) in dpp_tcp_get_auth()
2257 return conn->auth; in dpp_tcp_get_auth()
2267 struct dpp_controller *ctrl = dpp->controller; in dpp_controller_get_auth()
2273 dl_list_for_each(conn, &ctrl->conn, struct dpp_connection, list) { in dpp_controller_get_auth()
2274 if (dpp_tcp_peer_id_match(conn->auth, id)) in dpp_controller_get_auth()
2275 return conn->auth; in dpp_controller_get_auth()
2285 struct dpp_controller *ctrl = dpp->controller; in dpp_controller_new_qr_code()
2291 dl_list_for_each(conn, &ctrl->conn, struct dpp_connection, list) { in dpp_controller_new_qr_code()
2292 struct dpp_authentication *auth = conn->auth; in dpp_controller_new_qr_code() local
2294 if (!auth->response_pending || in dpp_controller_new_qr_code()
2295 dpp_notify_new_qr_code(auth, bi) != 1) in dpp_controller_new_qr_code()
2299 dpp_tcp_send_msg(conn, conn->auth->resp_msg); in dpp_controller_new_qr_code()
2308 struct dpp_controller *ctrl = dpp->controller; in dpp_controller_pkex_add()
2313 ctrl->pkex_bi = bi; in dpp_controller_pkex_add()
2314 os_free(ctrl->pkex_code); in dpp_controller_pkex_add()
2315 ctrl->pkex_code = code ? os_strdup(code) : NULL; in dpp_controller_pkex_add()
2316 os_free(ctrl->pkex_identifier); in dpp_controller_pkex_add()
2317 ctrl->pkex_identifier = identifier ? os_strdup(identifier) : NULL; in dpp_controller_pkex_add()
2328 dl_list_for_each(conn, &dpp->tcp_init, struct dpp_connection, list) { in dpp_controller_is_own_pkex_req()
2329 if (!conn->pkex || !conn->pkex->enc_key) in dpp_controller_is_own_pkex_req()
2340 if (attr_key_len == wpabuf_len(conn->pkex->enc_key) && in dpp_controller_is_own_pkex_req()
2341 os_memcmp(attr_key, wpabuf_head(conn->pkex->enc_key), in dpp_controller_is_own_pkex_req()
2354 dl_list_for_each_safe(conn, tmp, &dpp->tcp_init, struct dpp_connection, in dpp_tcp_init_flush()
2366 hostapd_ip_txt(&ctrl->ipaddr, txt, sizeof(txt))); in dpp_relay_controller_free()
2368 dl_list_for_each_safe(conn, tmp, &ctrl->conn, struct dpp_connection, in dpp_relay_controller_free()
2382 dl_list_for_each_safe(ctrl, tmp, &dpp->controllers, in dpp_relay_flush_controllers()
2384 dl_list_del(&ctrl->list); in dpp_relay_flush_controllers()
2388 if (dpp->tmp_controller) { in dpp_relay_flush_controllers()
2389 dpp_relay_controller_free(dpp->tmp_controller); in dpp_relay_flush_controllers()
2390 dpp->tmp_controller = NULL; in dpp_relay_flush_controllers()
2403 dl_list_for_each(ctrl, &dpp->controllers, struct dpp_relay_controller, in dpp_relay_remove_controller()
2405 if (hostapd_ip_equal(&ctrl->ipaddr, addr)) { in dpp_relay_remove_controller()
2406 dl_list_del(&ctrl->list); in dpp_relay_remove_controller()
2412 if (dpp->tmp_controller && in dpp_relay_remove_controller()
2413 hostapd_ip_equal(&dpp->tmp_controller->ipaddr, addr)) { in dpp_relay_remove_controller()
2414 dpp_relay_controller_free(dpp->tmp_controller); in dpp_relay_remove_controller()
2415 dpp->tmp_controller = NULL; in dpp_relay_remove_controller()
2431 fd = accept(dpp->relay_sock, (struct sockaddr *) &addr, &addr_len); in dpp_relay_tcp_cb()
2442 if (!ctrl && dpp->tmp_controller && in dpp_relay_tcp_cb()
2443 dl_list_len(&dpp->tmp_controller->conn)) { in dpp_relay_tcp_cb()
2448 hostapd_ip_txt(&dpp->tmp_controller->ipaddr, in dpp_relay_tcp_cb()
2450 dpp_relay_controller_free(dpp->tmp_controller); in dpp_relay_tcp_cb()
2451 dpp->tmp_controller = NULL; in dpp_relay_tcp_cb()
2453 if (!ctrl && !dpp->tmp_controller) { in dpp_relay_tcp_cb()
2458 dl_list_init(&ctrl->conn); in dpp_relay_tcp_cb()
2459 ctrl->global = dpp; in dpp_relay_tcp_cb()
2460 ctrl->ipaddr.af = AF_INET; in dpp_relay_tcp_cb()
2461 ctrl->ipaddr.u.v4.s_addr = addr.sin_addr.s_addr; in dpp_relay_tcp_cb()
2462 ctrl->msg_ctx = dpp->relay_msg_ctx; in dpp_relay_tcp_cb()
2463 ctrl->cb_ctx = dpp->relay_cb_ctx; in dpp_relay_tcp_cb()
2464 ctrl->tx = dpp->relay_tx; in dpp_relay_tcp_cb()
2465 ctrl->gas_resp_tx = dpp->relay_gas_resp_tx; in dpp_relay_tcp_cb()
2466 dpp->tmp_controller = ctrl; in dpp_relay_tcp_cb()
2474 if (dl_list_len(&ctrl->conn) >= 15) { in dpp_relay_tcp_cb()
2476 "DPP: Too many ongoing Relay connections to the Controller - cannot start a new one"); in dpp_relay_tcp_cb()
2484 conn->global = ctrl->global; in dpp_relay_tcp_cb()
2485 conn->relay = ctrl; in dpp_relay_tcp_cb()
2486 conn->msg_ctx = ctrl->msg_ctx; in dpp_relay_tcp_cb()
2487 conn->cb_ctx = ctrl->global->cb_ctx; in dpp_relay_tcp_cb()
2488 os_memset(conn->mac_addr, 0xff, ETH_ALEN); in dpp_relay_tcp_cb()
2489 conn->sock = fd; in dpp_relay_tcp_cb()
2491 if (fcntl(conn->sock, F_SETFL, O_NONBLOCK) != 0) { in dpp_relay_tcp_cb()
2497 if (eloop_register_sock(conn->sock, EVENT_TYPE_READ, in dpp_relay_tcp_cb()
2500 conn->read_eloop = 1; in dpp_relay_tcp_cb()
2504 dl_list_add(&ctrl->conn, &conn->list); in dpp_relay_tcp_cb()
2520 if (dpp->relay_sock >= 0) { in dpp_relay_listen()
2521 wpa_printf(MSG_INFO, "DPP: %s(%d) - relay port already opened", in dpp_relay_listen()
2523 return -1; in dpp_relay_listen()
2531 return -1; in dpp_relay_listen()
2545 return -1; in dpp_relay_listen()
2558 return -1; in dpp_relay_listen()
2565 return -1; in dpp_relay_listen()
2568 dpp->relay_sock = s; in dpp_relay_listen()
2569 dpp->relay_msg_ctx = config->msg_ctx; in dpp_relay_listen()
2570 dpp->relay_cb_ctx = config->cb_ctx; in dpp_relay_listen()
2571 dpp->relay_tx = config->tx; in dpp_relay_listen()
2572 dpp->relay_gas_resp_tx = config->gas_resp_tx; in dpp_relay_listen()
2580 if (!dpp || dpp->relay_sock < 0) in dpp_relay_stop_listen()
2582 eloop_unregister_sock(dpp->relay_sock, EVENT_TYPE_READ); in dpp_relay_stop_listen()
2583 close(dpp->relay_sock); in dpp_relay_stop_listen()
2584 dpp->relay_sock = -1; in dpp_relay_stop_listen()
2595 dl_list_for_each(conn, &dpp->tcp_init, struct dpp_connection, list) { in dpp_tcp_conn_status_requested()
2596 if (conn->auth && conn->auth->conn_status_requested) in dpp_tcp_conn_status_requested()
2610 struct dpp_authentication *auth = conn->auth; in dpp_tcp_send_conn_status_msg() local
2615 auth->conn_status_requested = 0; in dpp_tcp_send_conn_status_msg()
2617 msg = dpp_build_conn_status_result(auth, result, ssid, ssid_len, in dpp_tcp_send_conn_status_msg()
2634 dl_list_for_each(c, &dpp->tcp_init, struct dpp_connection, list) { in dpp_tcp_send_conn_status_msg()
2638 conn->on_tcp_tx_complete_remove = 1; in dpp_tcp_send_conn_status_msg()
2652 dl_list_for_each(conn, &dpp->tcp_init, struct dpp_connection, list) { in dpp_tcp_send_conn_status()
2653 if (conn->auth && conn->auth->conn_status_requested) { in dpp_tcp_send_conn_status()