Lines Matching refs:conn
33 int (*pkex_done)(void *ctx, void *conn, struct dpp_bootstrap_info *bi);
69 struct dl_list conn; /* struct dpp_connection */ member
78 struct dl_list conn; /* struct dpp_connection */ member
92 static void dpp_controller_auth_success(struct dpp_connection *conn,
102 static void dpp_connection_free(struct dpp_connection *conn) in dpp_connection_free() argument
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()
112 conn, NULL); in dpp_connection_free()
113 eloop_cancel_timeout(dpp_tcp_build_csr, conn, NULL); in dpp_connection_free()
114 eloop_cancel_timeout(dpp_tcp_gas_query_comeback, conn, NULL); in dpp_connection_free()
115 eloop_cancel_timeout(dpp_relay_conn_timeout, conn, NULL); in dpp_connection_free()
117 eloop_cancel_timeout(dpp_tcp_build_new_key, conn, NULL); 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()
127 os_free(conn); in dpp_connection_free()
131 static void dpp_connection_remove(struct dpp_connection *conn) in dpp_connection_remove() argument
133 dl_list_del(&conn->list); in dpp_connection_remove()
134 dpp_connection_free(conn); in dpp_connection_remove()
150 dl_list_init(&ctrl->conn); in dpp_relay_add_controller()
226 static void dpp_controller_gas_done(struct dpp_connection *conn) in dpp_controller_gas_done() argument
228 struct dpp_authentication *auth = conn->auth; in dpp_controller_gas_done()
232 conn->on_tcp_tx_complete_gas_done = 0; in dpp_controller_gas_done()
239 conn->on_tcp_tx_complete_gas_done = 0; 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()
253 dpp_connection_remove(conn); in dpp_controller_gas_done()
257 static int dpp_tcp_send(struct dpp_connection *conn) in dpp_tcp_send() argument
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()
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()
272 dpp_connection_remove(conn); 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()
284 dpp_conn_tx_ready, conn, NULL) == 0) 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()
297 dpp_controller_rx, conn, NULL) == 0) 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()
304 dpp_connection_remove(conn); 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()
307 dpp_controller_gas_done(conn); 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()
310 dpp_controller_auth_success(conn, 1); in dpp_tcp_send()
317 static int dpp_tcp_send_msg(struct dpp_connection *conn, in dpp_tcp_send_msg() argument
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()
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()
329 if (dpp_tcp_send(conn) == 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()
333 conn, NULL) < 0) in dpp_tcp_send_msg()
335 conn->write_eloop = 1; in dpp_tcp_send_msg()
343 static void dpp_controller_start_gas_client(struct dpp_connection *conn) in dpp_controller_start_gas_client() argument
345 struct dpp_authentication *auth = conn->auth; in dpp_controller_start_gas_client()
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()
360 dpp_tcp_send_msg(conn, buf); in dpp_controller_start_gas_client()
365 static void dpp_controller_auth_success(struct dpp_connection *conn, in dpp_controller_auth_success() argument
368 struct dpp_authentication *auth = conn->auth; in dpp_controller_auth_success()
388 dpp_controller_start_gas_client(conn); in dpp_controller_auth_success()
394 struct dpp_connection *conn = eloop_ctx; in dpp_conn_tx_ready() local
397 dpp_tcp_send(conn); in dpp_conn_tx_ready()
440 struct dpp_connection *conn = eloop_ctx; in dpp_relay_conn_timeout() local
444 dpp_connection_remove(conn); in dpp_relay_conn_timeout()
452 struct dpp_connection *conn; in dpp_relay_new_conn() local
457 if (dl_list_len(&ctrl->conn) >= 15) { in dpp_relay_new_conn()
467 conn = os_zalloc(sizeof(*conn)); in dpp_relay_new_conn()
468 if (!conn) 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()
504 dpp_conn_tx_ready, conn, NULL) < 0) in dpp_relay_new_conn()
506 conn->write_eloop = 1; in dpp_relay_new_conn()
508 eloop_cancel_timeout(dpp_relay_conn_timeout, conn, NULL); in dpp_relay_new_conn()
509 eloop_register_timeout(20, 0, dpp_relay_conn_timeout, conn, NULL); in dpp_relay_new_conn()
511 dl_list_add(&ctrl->conn, &conn->list); in dpp_relay_new_conn()
512 return conn; in dpp_relay_new_conn()
514 dpp_connection_free(conn); in dpp_relay_new_conn()
535 static int dpp_relay_tx(struct dpp_connection *conn, const u8 *hdr, in dpp_relay_tx() argument
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()
546 dpp_connection_remove(conn); in dpp_relay_tx()
553 conn->on_tcp_tx_complete_remove = 1; in dpp_relay_tx()
554 dpp_tcp_send(conn); in dpp_relay_tx()
563 struct dpp_connection *conn; in dpp_relay_match_ctrl() local
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()
567 return conn; 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()
576 return conn; in dpp_relay_match_ctrl()
590 struct dpp_connection *conn; in dpp_relay_rx_action() local
602 conn = dpp_relay_match_ctrl(ctrl, src, freq, type); in dpp_relay_rx_action()
603 if (conn) in dpp_relay_rx_action()
604 return dpp_relay_tx(conn, hdr, buf, len); in dpp_relay_rx_action()
608 conn = dpp_relay_match_ctrl(dpp->tmp_controller, src, in dpp_relay_rx_action()
610 if (conn) in dpp_relay_rx_action()
611 return dpp_relay_tx(conn, hdr, buf, len); in dpp_relay_rx_action()
632 conn = dpp_relay_match_ctrl(ctrl, src, freq, type); in dpp_relay_rx_action()
633 if (conn && in dpp_relay_rx_action()
634 (!conn->auth || conn->auth->waiting_auth_resp)) { in dpp_relay_rx_action()
637 return dpp_relay_tx(conn, hdr, buf, len); in dpp_relay_rx_action()
643 conn = dpp_relay_new_conn(ctrl, src, freq); in dpp_relay_rx_action()
644 if (!conn) 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()
649 dpp_connection_remove(conn); in dpp_relay_rx_action()
661 struct dpp_connection *conn; in dpp_relay_find_conn() local
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()
665 return conn; in dpp_relay_find_conn()
676 struct dpp_connection *conn = NULL; in dpp_relay_rx_gas_req() local
684 conn = dpp_relay_find_conn(ctrl, src); in dpp_relay_rx_gas_req()
685 if (conn) 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()
692 if (!conn) 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()
706 dpp_tcp_send(conn); in dpp_relay_rx_gas_req()
719 struct dpp_connection *conn, *tmp; in dpp_controller_free() local
724 dl_list_for_each_safe(conn, tmp, &ctrl->conn, struct dpp_connection, in dpp_controller_free()
726 dpp_connection_remove(conn); in dpp_controller_free()
739 static int dpp_controller_rx_auth_req(struct dpp_connection *conn, in dpp_controller_rx_auth_req() argument
746 if (!conn->ctrl) in dpp_controller_rx_auth_req()
773 dpp_bootstrap_find_pair(conn->ctrl->global, i_bootstrap, r_bootstrap, in dpp_controller_rx_auth_req()
781 if (conn->auth) { 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()
791 if (!conn->auth) { 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()
800 return dpp_tcp_send_msg(conn, conn->auth->resp_msg); in dpp_controller_rx_auth_req()
804 static int dpp_controller_rx_auth_resp(struct dpp_connection *conn, in dpp_controller_rx_auth_resp() argument
807 struct dpp_authentication *auth = conn->auth; in dpp_controller_rx_auth_resp()
827 conn->on_tcp_tx_complete_auth_ok = 1; in dpp_controller_rx_auth_resp()
828 res = dpp_tcp_send_msg(conn, msg); in dpp_controller_rx_auth_resp()
834 static int dpp_controller_rx_auth_conf(struct dpp_connection *conn, in dpp_controller_rx_auth_conf() argument
837 struct dpp_authentication *auth = conn->auth; in dpp_controller_rx_auth_conf()
852 dpp_controller_auth_success(conn, 0); in dpp_controller_rx_auth_conf()
860 struct dpp_connection *conn = eloop_ctx; in dpp_controller_conn_status_result_wait_timeout() local
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()
869 dpp_connection_remove(conn); in dpp_controller_conn_status_result_wait_timeout()
873 static int dpp_controller_rx_conf_result(struct dpp_connection *conn, in dpp_controller_rx_conf_result() argument
877 struct dpp_authentication *auth = conn->auth; in dpp_controller_rx_conf_result()
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()
901 conn, NULL); in dpp_controller_rx_conf_result()
904 conn, NULL); in dpp_controller_rx_conf_result()
916 static int dpp_controller_rx_conn_status_result(struct dpp_connection *conn, in dpp_controller_rx_conn_status_result() argument
920 struct dpp_authentication *auth = conn->auth; in dpp_controller_rx_conn_status_result()
926 if (!conn->ctrl) 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()
948 static int dpp_controller_rx_presence_announcement(struct dpp_connection *conn, in dpp_controller_rx_presence_announcement() argument
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()
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()
986 if (dpp_set_configurator(auth, conn->ctrl->configurator_params) < 0) { 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()
996 static int dpp_controller_rx_reconfig_announcement(struct dpp_connection *conn, in dpp_controller_rx_reconfig_announcement() argument
1003 struct dpp_global *dpp = conn->ctrl->global; in dpp_controller_rx_reconfig_announcement()
1007 if (conn->auth) { in dpp_controller_rx_reconfig_announcement()
1018 wpa_msg(conn->msg_ctx, MSG_INFO, DPP_EVENT_FAIL in dpp_controller_rx_reconfig_announcement()
1034 wpa_msg(conn->msg_ctx, MSG_INFO, DPP_EVENT_FAIL in dpp_controller_rx_reconfig_announcement()
1044 auth = dpp_reconfig_init(dpp, conn->msg_ctx, conf, 0, group, in dpp_controller_rx_reconfig_announcement()
1048 if (dpp_set_configurator(auth, conn->ctrl->configurator_params) < 0) { 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()
1058 static int dpp_controller_rx_reconfig_auth_resp(struct dpp_connection *conn, in dpp_controller_rx_reconfig_auth_resp() argument
1062 struct dpp_authentication *auth = conn->auth; in dpp_controller_rx_reconfig_auth_resp()
1078 res = dpp_tcp_send_msg(conn, conf); in dpp_controller_rx_reconfig_auth_resp()
1084 static int dpp_controller_rx_pkex_exchange_req(struct dpp_connection *conn, in dpp_controller_rx_pkex_exchange_req() argument
1088 struct dpp_controller *ctrl = conn->ctrl; in dpp_controller_rx_pkex_exchange_req()
1104 if (conn->pkex || conn->auth) { 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()
1116 if (!conn->pkex) { 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()
1126 static int dpp_controller_rx_pkex_exchange_resp(struct dpp_connection *conn, in dpp_controller_rx_pkex_exchange_resp() argument
1130 struct dpp_pkex *pkex = conn->pkex; in dpp_controller_rx_pkex_exchange_resp()
1148 res = dpp_tcp_send_msg(conn, msg); in dpp_controller_rx_pkex_exchange_resp()
1154 static int dpp_controller_rx_pkex_commit_reveal_req(struct dpp_connection *conn, in dpp_controller_rx_pkex_commit_reveal_req() argument
1158 struct dpp_pkex *pkex = conn->pkex; in dpp_controller_rx_pkex_commit_reveal_req()
1177 res = dpp_tcp_send_msg(conn, msg); 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()
1184 conn->pkex = NULL; in dpp_controller_rx_pkex_commit_reveal_req()
1190 dpp_controller_rx_pkex_commit_reveal_resp(struct dpp_connection *conn, in dpp_controller_rx_pkex_commit_reveal_resp() argument
1194 struct dpp_pkex *pkex = conn->pkex; 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()
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()
1218 return conn->pkex_done(conn->cb_ctx, conn, bi); in dpp_controller_rx_pkex_commit_reveal_resp()
1222 static int dpp_controller_rx_action(struct dpp_connection *conn, const u8 *msg, in dpp_controller_rx_action() argument
1253 if (conn->relay) { 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()
1270 return dpp_controller_rx_conn_status_result(conn, msg, pos, in dpp_controller_rx_action()
1273 return dpp_controller_rx_presence_announcement(conn, msg, pos, in dpp_controller_rx_action()
1276 return dpp_controller_rx_reconfig_announcement(conn, msg, pos, in dpp_controller_rx_action()
1279 return dpp_controller_rx_reconfig_auth_resp(conn, msg, pos, in dpp_controller_rx_action()
1286 return dpp_controller_rx_pkex_exchange_req(conn, msg, pos, in dpp_controller_rx_action()
1289 return dpp_controller_rx_pkex_exchange_resp(conn, msg, pos, in dpp_controller_rx_action()
1292 return dpp_controller_rx_pkex_commit_reveal_req(conn, msg, pos, in dpp_controller_rx_action()
1295 return dpp_controller_rx_pkex_commit_reveal_resp(conn, msg, pos, in dpp_controller_rx_action()
1306 static int dpp_tcp_send_comeback_delay(struct dpp_connection *conn, u8 action) in dpp_tcp_send_comeback_delay() argument
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()
1335 dpp_tcp_send(conn); in dpp_tcp_send_comeback_delay()
1340 static int dpp_tcp_send_gas_resp(struct dpp_connection *conn, u8 action, in dpp_tcp_send_gas_resp() argument
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()
1379 dpp_tcp_send(conn); in dpp_tcp_send_gas_resp()
1384 static int dpp_controller_rx_gas_req(struct dpp_connection *conn, const u8 *msg, in dpp_controller_rx_gas_req() argument
1391 struct dpp_authentication *auth = conn->auth; in dpp_controller_rx_gas_req()
1399 if (!auth || (!conn->ctrl && !auth->configurator) || 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()
1437 conn->gas_comeback_in_progress = 1; in dpp_controller_rx_gas_req()
1438 return dpp_tcp_send_comeback_delay(conn, in dpp_controller_rx_gas_req()
1477 wpa_msg(conn->msg_ctx, MSG_INFO, DPP_EVENT_CONF_NEEDED in dpp_controller_rx_gas_req()
1483 conn->gas_comeback_in_progress = 1; in dpp_controller_rx_gas_req()
1484 return dpp_tcp_send_comeback_delay(conn, in dpp_controller_rx_gas_req()
1488 return dpp_tcp_send_gas_resp(conn, WLAN_PA_GAS_INITIAL_RESP, resp); in dpp_controller_rx_gas_req()
1492 static int dpp_controller_rx_gas_comeback_req(struct dpp_connection *conn, in dpp_controller_rx_gas_comeback_req() argument
1496 struct dpp_authentication *auth = conn->auth; in dpp_controller_rx_gas_comeback_req()
1505 if (!auth || (!conn->ctrl && !auth->configurator) || in dpp_controller_rx_gas_comeback_req()
1507 !conn->gas_comeback_in_progress) { 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()
1521 return dpp_tcp_send_comeback_delay(conn, in dpp_controller_rx_gas_comeback_req()
1529 return dpp_tcp_send_gas_resp(conn, WLAN_PA_GAS_COMEBACK_RESP, resp); in dpp_controller_rx_gas_comeback_req()
1535 struct dpp_connection *conn = eloop_ctx; in dpp_tcp_build_csr() local
1536 struct dpp_authentication *auth = conn->auth; in dpp_tcp_build_csr()
1544 auth->csr = dpp_build_csr(auth, conn->name ? conn->name : "Test"); in dpp_tcp_build_csr()
1546 dpp_connection_remove(conn); in dpp_tcp_build_csr()
1550 dpp_controller_start_gas_client(conn); in dpp_tcp_build_csr()
1557 struct dpp_connection *conn = eloop_ctx; in dpp_tcp_build_new_key() local
1558 struct dpp_authentication *auth = conn->auth; in dpp_tcp_build_new_key()
1564 dpp_controller_start_gas_client(conn); in dpp_tcp_build_new_key()
1569 static int dpp_tcp_rx_gas_resp(struct dpp_connection *conn, struct wpabuf *resp) in dpp_tcp_rx_gas_resp() argument
1571 struct dpp_authentication *auth = conn->auth; in dpp_tcp_rx_gas_resp()
1586 eloop_register_timeout(0, 0, dpp_tcp_build_csr, conn, NULL); in dpp_tcp_rx_gas_resp()
1592 eloop_register_timeout(0, 0, dpp_tcp_build_new_key, conn, 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()
1616 conn->on_tcp_tx_complete_remove = 1; in dpp_tcp_rx_gas_resp()
1617 res = dpp_tcp_send_msg(conn, msg); in dpp_tcp_rx_gas_resp()
1628 struct dpp_connection *conn = eloop_ctx; in dpp_tcp_gas_query_comeback() local
1629 struct dpp_authentication *auth = conn->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()
1647 dpp_tcp_send(conn); in dpp_tcp_gas_query_comeback()
1651 static int dpp_rx_gas_resp(struct dpp_connection *conn, const u8 *msg, in dpp_rx_gas_resp() argument
1706 conn->gas_dialog_token = dialog_token; in dpp_rx_gas_resp()
1711 eloop_cancel_timeout(dpp_tcp_gas_query_comeback, conn, NULL); in dpp_rx_gas_resp()
1713 conn, NULL); 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()
1724 return dpp_tcp_rx_gas_resp(conn, buf); in dpp_rx_gas_resp()
1726 if (!conn->relay) { in dpp_rx_gas_resp()
1732 conn->relay->gas_resp_tx(conn->relay->cb_ctx, conn->mac_addr, in dpp_rx_gas_resp()
1741 struct dpp_connection *conn = eloop_ctx; in dpp_controller_rx() local
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()
1756 dpp_connection_remove(conn); in dpp_controller_rx()
1762 dpp_connection_remove(conn); 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()
1781 dpp_connection_remove(conn); 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()
1792 dpp_connection_remove(conn); 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()
1802 dpp_connection_remove(conn); in dpp_controller_rx()
1807 dpp_connection_remove(conn); 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()
1823 dpp_connection_remove(conn); in dpp_controller_rx()
1827 pos = wpabuf_head(conn->msg); in dpp_controller_rx()
1830 if (dpp_controller_rx_action(conn, pos + 1, in dpp_controller_rx()
1831 wpabuf_len(conn->msg) - 1) < 0) in dpp_controller_rx()
1832 dpp_connection_remove(conn); in dpp_controller_rx()
1835 if (dpp_controller_rx_gas_req(conn, pos + 1, in dpp_controller_rx()
1836 wpabuf_len(conn->msg) - 1) < 0) in dpp_controller_rx()
1837 dpp_connection_remove(conn); in dpp_controller_rx()
1841 if (dpp_rx_gas_resp(conn, pos + 1, in dpp_controller_rx()
1842 wpabuf_len(conn->msg) - 1, in dpp_controller_rx()
1844 dpp_connection_remove(conn); in dpp_controller_rx()
1848 conn, pos + 1, wpabuf_len(conn->msg) - 1) < 0) in dpp_controller_rx()
1849 dpp_connection_remove(conn); in dpp_controller_rx()
1865 struct dpp_connection *conn; in dpp_controller_tcp_cb() local
1879 conn = os_zalloc(sizeof(*conn)); in dpp_controller_tcp_cb()
1880 if (!conn) 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()
1899 dpp_controller_rx, conn, NULL) < 0) 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()
1910 os_free(conn); in dpp_controller_tcp_cb()
1917 int (*pkex_done)(void *ctx, void *conn, in dpp_tcp_pkex_init() argument
1920 struct dpp_connection *conn; in dpp_tcp_pkex_init() local
1934 conn = os_zalloc(sizeof(*conn)); in dpp_tcp_pkex_init()
1935 if (!conn) { 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()
1969 dpp_conn_tx_ready, conn, NULL) < 0) in dpp_tcp_pkex_init()
1971 conn->write_eloop = 1; 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()
1987 dpp_connection_free(conn); in dpp_tcp_pkex_init()
1992 static int dpp_tcp_auth_start(struct dpp_connection *conn, in dpp_tcp_auth_start() argument
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()
2020 struct dpp_connection *conn; in dpp_tcp_init() local
2033 conn = os_zalloc(sizeof(*conn)); in dpp_tcp_init()
2034 if (!conn) { 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()
2077 dpp_conn_tx_ready, conn, NULL) < 0) 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()
2089 dpp_connection_free(conn); in dpp_tcp_init()
2104 struct dpp_connection *conn = _conn; in dpp_tcp_auth() local
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()
2125 dpp_conn_tx_ready(conn->sock, conn, NULL); in dpp_tcp_auth()
2148 dl_list_init(&ctrl->conn); in dpp_controller_start()
2253 struct dpp_connection *conn; in dpp_tcp_get_auth() local
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()
2268 struct dpp_connection *conn; in dpp_controller_get_auth() local
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()
2286 struct dpp_connection *conn; in dpp_controller_new_qr_code() local
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()
2299 dpp_tcp_send_msg(conn, conn->auth->resp_msg); in dpp_controller_new_qr_code()
2324 struct dpp_connection *conn; in dpp_controller_is_own_pkex_req() local
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()
2352 struct dpp_connection *conn, *tmp; in dpp_tcp_init_flush() local
2354 dl_list_for_each_safe(conn, tmp, &dpp->tcp_init, struct dpp_connection, in dpp_tcp_init_flush()
2356 dpp_connection_remove(conn); in dpp_tcp_init_flush()
2362 struct dpp_connection *conn, *tmp; in dpp_relay_controller_free() local
2368 dl_list_for_each_safe(conn, tmp, &ctrl->conn, struct dpp_connection, in dpp_relay_controller_free()
2370 dpp_connection_remove(conn); in dpp_relay_controller_free()
2427 struct dpp_connection *conn = NULL; in dpp_relay_tcp_cb() local
2443 dl_list_len(&dpp->tmp_controller->conn)) { in dpp_relay_tcp_cb()
2458 dl_list_init(&ctrl->conn); in dpp_relay_tcp_cb()
2474 if (dl_list_len(&ctrl->conn) >= 15) { in dpp_relay_tcp_cb()
2480 conn = os_zalloc(sizeof(*conn)); in dpp_relay_tcp_cb()
2481 if (!conn) 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()
2498 dpp_controller_rx, conn, NULL) < 0) 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()
2509 os_free(conn); in dpp_relay_tcp_cb()
2590 struct dpp_connection *conn; in dpp_tcp_conn_status_requested() local
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()
2605 struct dpp_connection *conn, in dpp_tcp_send_conn_status_msg() argument
2610 struct dpp_authentication *auth = conn->auth; in dpp_tcp_send_conn_status_msg()
2620 dpp_connection_remove(conn); in dpp_tcp_send_conn_status_msg()
2624 res = dpp_tcp_send_msg(conn, msg); in dpp_tcp_send_conn_status_msg()
2628 dpp_connection_remove(conn); in dpp_tcp_send_conn_status_msg()
2635 if (conn == c) { in dpp_tcp_send_conn_status_msg()
2638 conn->on_tcp_tx_complete_remove = 1; in dpp_tcp_send_conn_status_msg()
2650 struct dpp_connection *conn; in dpp_tcp_send_conn_status() local
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()
2654 dpp_tcp_send_conn_status_msg(dpp, conn, result, ssid, in dpp_tcp_send_conn_status()