Lines Matching defs:conn
33 int (*pkex_done)(void *ctx, void *conn, struct dpp_bootstrap_info *bi);
69 struct dl_list conn; /* struct dpp_connection */
78 struct dl_list conn; /* struct dpp_connection */
92 static void dpp_controller_auth_success(struct dpp_connection *conn,
102 static void dpp_connection_free(struct dpp_connection *conn)
104 if (conn->sock >= 0) {
106 conn->sock);
107 eloop_unregister_sock(conn->sock, EVENT_TYPE_READ);
108 eloop_unregister_sock(conn->sock, EVENT_TYPE_WRITE);
109 close(conn->sock);
112 conn, NULL);
113 eloop_cancel_timeout(dpp_tcp_build_csr, conn, NULL);
114 eloop_cancel_timeout(dpp_tcp_gas_query_comeback, conn, NULL);
115 eloop_cancel_timeout(dpp_relay_conn_timeout, conn, NULL);
117 eloop_cancel_timeout(dpp_tcp_build_new_key, conn, NULL);
119 wpabuf_free(conn->msg);
120 wpabuf_free(conn->msg_out);
121 dpp_auth_deinit(conn->auth);
122 dpp_pkex_free(conn->pkex);
123 os_free(conn->name);
124 os_free(conn->mud_url);
125 os_free(conn->extra_conf_req_name);
126 os_free(conn->extra_conf_req_value);
127 os_free(conn);
131 static void dpp_connection_remove(struct dpp_connection *conn)
133 dl_list_del(&conn->list);
134 dpp_connection_free(conn);
150 dl_list_init(&ctrl->conn);
226 static void dpp_controller_gas_done(struct dpp_connection *conn)
228 struct dpp_authentication *auth = conn->auth;
232 conn->on_tcp_tx_complete_gas_done = 0;
239 conn->on_tcp_tx_complete_gas_done = 0;
251 wpa_msg(conn->msg_ctx, MSG_INFO, DPP_EVENT_CONF_SENT "conf_status=%d",
253 dpp_connection_remove(conn);
257 static int dpp_tcp_send(struct dpp_connection *conn)
261 if (!conn->msg_out) {
262 eloop_unregister_sock(conn->sock, EVENT_TYPE_WRITE);
263 conn->write_eloop = 0;
266 res = send(conn->sock,
267 wpabuf_head_u8(conn->msg_out) + conn->msg_out_pos,
268 wpabuf_len(conn->msg_out) - conn->msg_out_pos, 0);
272 dpp_connection_remove(conn);
276 conn->msg_out_pos += res;
277 if (wpabuf_len(conn->msg_out) > conn->msg_out_pos) {
280 (unsigned int) conn->msg_out_pos,
281 (unsigned int) wpabuf_len(conn->msg_out));
282 if (!conn->write_eloop &&
283 eloop_register_sock(conn->sock, EVENT_TYPE_WRITE,
284 dpp_conn_tx_ready, conn, NULL) == 0)
285 conn->write_eloop = 1;
290 wpabuf_free(conn->msg_out);
291 conn->msg_out = NULL;
292 conn->msg_out_pos = 0;
293 eloop_unregister_sock(conn->sock, EVENT_TYPE_WRITE);
294 conn->write_eloop = 0;
295 if (!conn->read_eloop &&
296 eloop_register_sock(conn->sock, EVENT_TYPE_READ,
297 dpp_controller_rx, conn, NULL) == 0)
298 conn->read_eloop = 1;
299 if (conn->on_tcp_tx_complete_remove) {
300 if (conn->auth && conn->auth->connect_on_tx_status &&
301 conn->tcp_msg_sent &&
302 conn->tcp_msg_sent(conn->cb_ctx, conn->auth))
304 dpp_connection_remove(conn);
305 } else if (conn->auth && (conn->ctrl || conn->auth->configurator) &&
306 conn->on_tcp_tx_complete_gas_done) {
307 dpp_controller_gas_done(conn);
308 } else if (conn->on_tcp_tx_complete_auth_ok) {
309 conn->on_tcp_tx_complete_auth_ok = 0;
310 dpp_controller_auth_success(conn, 1);
317 static int dpp_tcp_send_msg(struct dpp_connection *conn,
320 wpabuf_free(conn->msg_out);
321 conn->msg_out_pos = 0;
322 conn->msg_out = wpabuf_alloc(4 + wpabuf_len(msg) - 1);
323 if (!conn->msg_out)
325 wpabuf_put_be32(conn->msg_out, wpabuf_len(msg) - 1);
326 wpabuf_put_data(conn->msg_out, wpabuf_head_u8(msg) + 1,
329 if (dpp_tcp_send(conn) == 1) {
330 if (!conn->write_eloop) {
331 if (eloop_register_sock(conn->sock, EVENT_TYPE_WRITE,
333 conn, NULL) < 0)
335 conn->write_eloop = 1;
343 static void dpp_controller_start_gas_client(struct dpp_connection *conn)
345 struct dpp_authentication *auth = conn->auth;
349 dpp_name = conn->name ? conn->name : "Test";
350 buf = dpp_build_conf_req_helper(auth, dpp_name, conn->netrole,
351 conn->mud_url, NULL,
352 conn->extra_conf_req_name,
353 conn->extra_conf_req_value);
360 dpp_tcp_send_msg(conn, buf);
365 static void dpp_controller_auth_success(struct dpp_connection *conn,
368 struct dpp_authentication *auth = conn->auth;
388 dpp_controller_start_gas_client(conn);
394 struct dpp_connection *conn = eloop_ctx;
397 dpp_tcp_send(conn);
440 struct dpp_connection *conn = eloop_ctx;
444 dpp_connection_remove(conn);
452 struct dpp_connection *conn;
457 if (dl_list_len(&ctrl->conn) >= 15) {
467 conn = os_zalloc(sizeof(*conn));
468 if (!conn)
471 conn->global = ctrl->global;
472 conn->relay = ctrl;
473 conn->msg_ctx = ctrl->msg_ctx;
474 conn->cb_ctx = ctrl->global->cb_ctx;
475 os_memcpy(conn->mac_addr, src, ETH_ALEN);
476 conn->freq = freq;
478 conn->sock = socket(AF_INET, SOCK_STREAM, 0);
479 if (conn->sock < 0)
482 conn->sock, hostapd_ip_txt(&ctrl->ipaddr, txt, sizeof(txt)));
484 if (fcntl(conn->sock, F_SETFL, O_NONBLOCK) != 0) {
490 if (connect(conn->sock, (struct sockaddr *) &addr, addrlen) < 0) {
503 if (eloop_register_sock(conn->sock, EVENT_TYPE_WRITE,
504 dpp_conn_tx_ready, conn, NULL) < 0)
506 conn->write_eloop = 1;
508 eloop_cancel_timeout(dpp_relay_conn_timeout, conn, NULL);
509 eloop_register_timeout(20, 0, dpp_relay_conn_timeout, conn, NULL);
511 dl_list_add(&ctrl->conn, &conn->list);
512 return conn;
514 dpp_connection_free(conn);
535 static int dpp_relay_tx(struct dpp_connection *conn, const u8 *hdr,
542 wpabuf_free(conn->msg_out);
543 conn->msg_out_pos = 0;
544 conn->msg_out = dpp_tcp_encaps(hdr, buf, len);
545 if (!conn->msg_out) {
546 dpp_connection_remove(conn);
553 conn->on_tcp_tx_complete_remove = 1;
554 dpp_tcp_send(conn);
563 struct dpp_connection *conn;
565 dl_list_for_each(conn, &ctrl->conn, struct dpp_connection, list) {
566 if (ether_addr_equal(src, conn->mac_addr))
567 return conn;
570 conn->freq == 0 &&
571 is_broadcast_ether_addr(conn->mac_addr)) {
574 os_memcpy(conn->mac_addr, src, ETH_ALEN);
575 conn->freq = freq;
576 return conn;
590 struct dpp_connection *conn;
602 conn = dpp_relay_match_ctrl(ctrl, src, freq, type);
603 if (conn)
604 return dpp_relay_tx(conn, hdr, buf, len);
608 conn = dpp_relay_match_ctrl(dpp->tmp_controller, src,
610 if (conn)
611 return dpp_relay_tx(conn, hdr, buf, len);
632 conn = dpp_relay_match_ctrl(ctrl, src, freq, type);
633 if (conn &&
634 (!conn->auth || conn->auth->waiting_auth_resp)) {
637 return dpp_relay_tx(conn, hdr, buf, len);
643 conn = dpp_relay_new_conn(ctrl, src, freq);
644 if (!conn)
647 conn->msg_out = dpp_tcp_encaps(hdr, buf, len);
648 if (!conn->msg_out) {
649 dpp_connection_remove(conn);
661 struct dpp_connection *conn;
663 dl_list_for_each(conn, &ctrl->conn, struct dpp_connection, list) {
664 if (ether_addr_equal(src, conn->mac_addr))
665 return conn;
676 struct dpp_connection *conn = NULL;
684 conn = dpp_relay_find_conn(ctrl, src);
685 if (conn)
689 if (!conn && dpp->tmp_controller)
690 conn = dpp_relay_find_conn(dpp->tmp_controller, src);
692 if (!conn)
703 wpabuf_free(conn->msg_out);
704 conn->msg_out_pos = 0;
705 conn->msg_out = msg;
706 dpp_tcp_send(conn);
719 struct dpp_connection *conn, *tmp;
724 dl_list_for_each_safe(conn, tmp, &ctrl->conn, struct dpp_connection,
726 dpp_connection_remove(conn);
739 static int dpp_controller_rx_auth_req(struct dpp_connection *conn,
746 if (!conn->ctrl)
773 dpp_bootstrap_find_pair(conn->ctrl->global, i_bootstrap, r_bootstrap,
781 if (conn->auth) {
787 conn->auth = dpp_auth_req_rx(conn->ctrl->global, conn->msg_ctx,
788 conn->ctrl->allowed_roles,
789 conn->ctrl->qr_mutual,
791 if (!conn->auth) {
796 if (dpp_set_configurator(conn->auth,
797 conn->ctrl->configurator_params) < 0)
800 return dpp_tcp_send_msg(conn, conn->auth->resp_msg);
804 static int dpp_controller_rx_auth_resp(struct dpp_connection *conn,
807 struct dpp_authentication *auth = conn->auth;
827 conn->on_tcp_tx_complete_auth_ok = 1;
828 res = dpp_tcp_send_msg(conn, msg);
834 static int dpp_controller_rx_auth_conf(struct dpp_connection *conn,
837 struct dpp_authentication *auth = conn->auth;
852 dpp_controller_auth_success(conn, 0);
860 struct dpp_connection *conn = eloop_ctx;
862 if (!conn->auth->waiting_conf_result)
867 wpa_msg(conn->msg_ctx, MSG_INFO,
869 dpp_connection_remove(conn);
873 static int dpp_controller_rx_conf_result(struct dpp_connection *conn,
877 struct dpp_authentication *auth = conn->auth;
879 void *msg_ctx = conn->msg_ctx;
881 if (!conn->ctrl && (!auth || !auth->configurator))
901 conn, NULL);
904 conn, NULL);
916 static int dpp_controller_rx_conn_status_result(struct dpp_connection *conn,
920 struct dpp_authentication *auth = conn->auth;
926 if (!conn->ctrl)
939 wpa_msg(conn->msg_ctx, MSG_INFO, DPP_EVENT_CONN_STATUS_RESULT
948 static int dpp_controller_rx_presence_announcement(struct dpp_connection *conn,
956 struct dpp_global *dpp = conn->ctrl->global;
963 wpa_msg(conn->msg_ctx, MSG_INFO, DPP_EVENT_FAIL
976 if (conn->auth) {
982 auth = dpp_auth_init(dpp, conn->msg_ctx, peer_bi, NULL,
986 if (dpp_set_configurator(auth, conn->ctrl->configurator_params) < 0) {
991 conn->auth = auth;
992 return dpp_tcp_send_msg(conn, conn->auth->req_msg);
996 static int dpp_controller_rx_reconfig_announcement(struct dpp_connection *conn,
1003 struct dpp_global *dpp = conn->ctrl->global;
1007 if (conn->auth) {
1018 wpa_msg(conn->msg_ctx, MSG_INFO, DPP_EVENT_FAIL
1034 wpa_msg(conn->msg_ctx, MSG_INFO, DPP_EVENT_FAIL
1044 auth = dpp_reconfig_init(dpp, conn->msg_ctx, conf, 0, group,
1048 if (dpp_set_configurator(auth, conn->ctrl->configurator_params) < 0) {
1053 conn->auth = auth;
1054 return dpp_tcp_send_msg(conn, auth->reconfig_req_msg);
1058 static int dpp_controller_rx_reconfig_auth_resp(struct dpp_connection *conn,
1062 struct dpp_authentication *auth = conn->auth;
1078 res = dpp_tcp_send_msg(conn, conf);
1084 static int dpp_controller_rx_pkex_exchange_req(struct dpp_connection *conn,
1088 struct dpp_controller *ctrl = conn->ctrl;
1104 if (conn->pkex || conn->auth) {
1110 conn->pkex = dpp_pkex_rx_exchange_req(conn->msg_ctx, ctrl->pkex_bi,
1116 if (!conn->pkex) {
1122 return dpp_tcp_send_msg(conn, conn->pkex->exchange_resp);
1126 static int dpp_controller_rx_pkex_exchange_resp(struct dpp_connection *conn,
1130 struct dpp_pkex *pkex = conn->pkex;
1148 res = dpp_tcp_send_msg(conn, msg);
1154 static int dpp_controller_rx_pkex_commit_reveal_req(struct dpp_connection *conn,
1158 struct dpp_pkex *pkex = conn->pkex;
1177 res = dpp_tcp_send_msg(conn, msg);
1181 bi = dpp_pkex_finish(conn->global, pkex, NULL, 0);
1184 conn->pkex = NULL;
1190 dpp_controller_rx_pkex_commit_reveal_resp(struct dpp_connection *conn,
1194 struct dpp_pkex *pkex = conn->pkex;
1211 bi = dpp_pkex_finish(conn->global, pkex, NULL, 0);
1214 conn->pkex = NULL;
1216 if (!conn->pkex_done)
1218 return conn->pkex_done(conn->cb_ctx, conn, bi);
1222 static int dpp_controller_rx_action(struct dpp_connection *conn, const u8 *msg,
1253 if (conn->relay) {
1255 conn->relay->tx(conn->relay->cb_ctx, conn->mac_addr,
1256 conn->freq, msg, len);
1262 return dpp_controller_rx_auth_req(conn, msg, pos, end - pos);
1264 return dpp_controller_rx_auth_resp(conn, msg, pos, end - pos);
1266 return dpp_controller_rx_auth_conf(conn, msg, pos, end - pos);
1268 return dpp_controller_rx_conf_result(conn, msg, pos, end - pos);
1270 return dpp_controller_rx_conn_status_result(conn, msg, pos,
1273 return dpp_controller_rx_presence_announcement(conn, msg, pos,
1276 return dpp_controller_rx_reconfig_announcement(conn, msg, pos,
1279 return dpp_controller_rx_reconfig_auth_resp(conn, msg, pos,
1286 return dpp_controller_rx_pkex_exchange_req(conn, msg, pos,
1289 return dpp_controller_rx_pkex_exchange_resp(conn, msg, pos,
1292 return dpp_controller_rx_pkex_commit_reveal_req(conn, msg, pos,
1295 return dpp_controller_rx_pkex_commit_reveal_resp(conn, msg, pos,
1306 static int dpp_tcp_send_comeback_delay(struct dpp_connection *conn, u8 action)
1321 wpabuf_put_u8(buf, conn->gas_dialog_token);
1332 wpabuf_free(conn->msg_out);
1333 conn->msg_out_pos = 0;
1334 conn->msg_out = buf;
1335 dpp_tcp_send(conn);
1340 static int dpp_tcp_send_gas_resp(struct dpp_connection *conn, u8 action,
1362 wpabuf_put_u8(buf, conn->gas_dialog_token);
1375 wpabuf_free(conn->msg_out);
1376 conn->msg_out_pos = 0;
1377 conn->msg_out = buf;
1378 conn->on_tcp_tx_complete_gas_done = 1;
1379 dpp_tcp_send(conn);
1384 static int dpp_controller_rx_gas_req(struct dpp_connection *conn, const u8 *msg,
1391 struct dpp_authentication *auth = conn->auth;
1399 if (!auth || (!conn->ctrl && !auth->configurator) ||
1405 wpa_msg(conn->msg_ctx, MSG_INFO, DPP_EVENT_CONF_REQ_RX);
1410 conn->gas_dialog_token = *pos++;
1437 conn->gas_comeback_in_progress = 1;
1438 return dpp_tcp_send_comeback_delay(conn,
1477 wpa_msg(conn->msg_ctx, MSG_INFO, DPP_EVENT_CONF_NEEDED
1483 conn->gas_comeback_in_progress = 1;
1484 return dpp_tcp_send_comeback_delay(conn,
1488 return dpp_tcp_send_gas_resp(conn, WLAN_PA_GAS_INITIAL_RESP, resp);
1492 static int dpp_controller_rx_gas_comeback_req(struct dpp_connection *conn,
1496 struct dpp_authentication *auth = conn->auth;
1505 if (!auth || (!conn->ctrl && !auth->configurator) ||
1507 !conn->gas_comeback_in_progress) {
1513 if (dialog_token != conn->gas_dialog_token) {
1515 dialog_token, conn->gas_dialog_token);
1521 return dpp_tcp_send_comeback_delay(conn,
1529 return dpp_tcp_send_gas_resp(conn, WLAN_PA_GAS_COMEBACK_RESP, resp);
1535 struct dpp_connection *conn = eloop_ctx;
1536 struct dpp_authentication *auth = conn->auth;
1544 auth->csr = dpp_build_csr(auth, conn->name ? conn->name : "Test");
1546 dpp_connection_remove(conn);
1550 dpp_controller_start_gas_client(conn);
1557 struct dpp_connection *conn = eloop_ctx;
1558 struct dpp_authentication *auth = conn->auth;
1564 dpp_controller_start_gas_client(conn);
1569 static int dpp_tcp_rx_gas_resp(struct dpp_connection *conn, struct wpabuf *resp)
1571 struct dpp_authentication *auth = conn->auth;
1586 eloop_register_timeout(0, 0, dpp_tcp_build_csr, conn, NULL);
1592 eloop_register_timeout(0, 0, dpp_tcp_build_new_key, conn,
1602 if (conn->process_conf_obj)
1603 res = conn->process_conf_obj(conn->cb_ctx, auth);
1616 conn->on_tcp_tx_complete_remove = 1;
1617 res = dpp_tcp_send_msg(conn, msg);
1628 struct dpp_connection *conn = eloop_ctx;
1629 struct dpp_authentication *auth = conn->auth;
1641 wpabuf_put_u8(msg, conn->gas_dialog_token);
1644 wpabuf_free(conn->msg_out);
1645 conn->msg_out_pos = 0;
1646 conn->msg_out = msg;
1647 dpp_tcp_send(conn);
1651 static int dpp_rx_gas_resp(struct dpp_connection *conn, const u8 *msg,
1706 conn->gas_dialog_token = dialog_token;
1711 eloop_cancel_timeout(dpp_tcp_gas_query_comeback, conn, NULL);
1713 conn, NULL);
1722 if (!conn->relay &&
1723 (!conn->ctrl || (conn->ctrl->allowed_roles & DPP_CAPAB_ENROLLEE)))
1724 return dpp_tcp_rx_gas_resp(conn, buf);
1726 if (!conn->relay) {
1732 conn->relay->gas_resp_tx(conn->relay->cb_ctx, conn->mac_addr,
1741 struct dpp_connection *conn = eloop_ctx;
1748 if (conn->msg_len_octets < 4) {
1751 res = recv(sd, &conn->msg_len[conn->msg_len_octets],
1752 4 - conn->msg_len_octets, 0);
1756 dpp_connection_remove(conn);
1762 dpp_connection_remove(conn);
1767 res, (int) (4 - conn->msg_len_octets));
1768 conn->msg_len_octets += res;
1770 if (conn->msg_len_octets < 4) {
1773 (int) (4 - conn->msg_len_octets));
1777 msglen = WPA_GET_BE32(conn->msg_len);
1781 dpp_connection_remove(conn);
1785 wpabuf_free(conn->msg);
1786 conn->msg = wpabuf_alloc(msglen);
1789 if (!conn->msg) {
1792 dpp_connection_remove(conn);
1797 (unsigned int) wpabuf_tailroom(conn->msg));
1799 res = recv(sd, wpabuf_put(conn->msg, 0), wpabuf_tailroom(conn->msg), 0);
1802 dpp_connection_remove(conn);
1807 dpp_connection_remove(conn);
1811 wpabuf_put(conn->msg, res);
1813 if (wpabuf_tailroom(conn->msg) > 0) {
1816 (unsigned int) wpabuf_tailroom(conn->msg));
1820 conn->msg_len_octets = 0;
1821 wpa_hexdump_buf(MSG_DEBUG, "DPP: Received TCP message", conn->msg);
1822 if (wpabuf_len(conn->msg) < 1) {
1823 dpp_connection_remove(conn);
1827 pos = wpabuf_head(conn->msg);
1830 if (dpp_controller_rx_action(conn, pos + 1,
1831 wpabuf_len(conn->msg) - 1) < 0)
1832 dpp_connection_remove(conn);
1835 if (dpp_controller_rx_gas_req(conn, pos + 1,
1836 wpabuf_len(conn->msg) - 1) < 0)
1837 dpp_connection_remove(conn);
1841 if (dpp_rx_gas_resp(conn, pos + 1,
1842 wpabuf_len(conn->msg) - 1,
1844 dpp_connection_remove(conn);
1848 conn, pos + 1, wpabuf_len(conn->msg) - 1) < 0)
1849 dpp_connection_remove(conn);
1865 struct dpp_connection *conn;
1879 conn = os_zalloc(sizeof(*conn));
1880 if (!conn)
1883 conn->global = ctrl->global;
1884 conn->ctrl = ctrl;
1885 conn->msg_ctx = ctrl->msg_ctx;
1886 conn->cb_ctx = ctrl->cb_ctx;
1887 conn->process_conf_obj = ctrl->process_conf_obj;
1888 conn->tcp_msg_sent = ctrl->tcp_msg_sent;
1889 conn->sock = fd;
1890 conn->netrole = ctrl->netrole;
1892 if (fcntl(conn->sock, F_SETFL, O_NONBLOCK) != 0) {
1898 if (eloop_register_sock(conn->sock, EVENT_TYPE_READ,
1899 dpp_controller_rx, conn, NULL) < 0)
1901 conn->read_eloop = 1;
1905 dl_list_add(&ctrl->conn, &conn->list);
1910 os_free(conn);
1917 int (*pkex_done)(void *ctx, void *conn,
1920 struct dpp_connection *conn;
1934 conn = os_zalloc(sizeof(*conn));
1935 if (!conn) {
1940 conn->msg_ctx = msg_ctx;
1941 conn->cb_ctx = cb_ctx;
1942 conn->pkex_done = pkex_done;
1943 conn->global = dpp;
1944 conn->pkex = pkex;
1945 conn->sock = socket(AF_INET, SOCK_STREAM, 0);
1946 if (conn->sock < 0)
1949 if (fcntl(conn->sock, F_SETFL, O_NONBLOCK) != 0) {
1955 if (connect(conn->sock, (struct sockaddr *) &saddr, addrlen) < 0) {
1968 if (eloop_register_sock(conn->sock, EVENT_TYPE_WRITE,
1969 dpp_conn_tx_ready, conn, NULL) < 0)
1971 conn->write_eloop = 1;
1977 conn->msg_out = dpp_tcp_encaps(hdr, pos, end - pos);
1978 if (!conn->msg_out)
1984 dl_list_add(&dpp->tcp_init, &conn->list);
1987 dpp_connection_free(conn);
1992 static int dpp_tcp_auth_start(struct dpp_connection *conn,
2001 conn->msg_out = dpp_tcp_encaps(hdr, pos, end - pos);
2002 if (!conn->msg_out)
2020 struct dpp_connection *conn;
2033 conn = os_zalloc(sizeof(*conn));
2034 if (!conn) {
2039 conn->msg_ctx = msg_ctx;
2040 conn->cb_ctx = cb_ctx;
2041 conn->process_conf_obj = process_conf_obj;
2042 conn->tcp_msg_sent = tcp_msg_sent;
2043 conn->name = os_strdup(name ? name : "Test");
2045 conn->mud_url = os_strdup(mud_url);
2047 conn->extra_conf_req_name = os_strdup(extra_conf_req_name);
2049 conn->extra_conf_req_value = os_strdup(extra_conf_req_value);
2050 conn->netrole = netrole;
2051 conn->global = dpp;
2052 conn->auth = auth;
2053 conn->sock = socket(AF_INET, SOCK_STREAM, 0);
2054 if (conn->sock < 0)
2057 if (fcntl(conn->sock, F_SETFL, O_NONBLOCK) != 0) {
2063 if (connect(conn->sock, (struct sockaddr *) &saddr, addrlen) < 0) {
2076 if (eloop_register_sock(conn->sock, EVENT_TYPE_WRITE,
2077 dpp_conn_tx_ready, conn, NULL) < 0)
2079 conn->write_eloop = 1;
2081 if (dpp_tcp_auth_start(conn, auth) < 0)
2086 dl_list_add(&dpp->tcp_init, &conn->list);
2089 dpp_connection_free(conn);
2104 struct dpp_connection *conn = _conn;
2108 conn->process_conf_obj = process_conf_obj;
2109 conn->tcp_msg_sent = tcp_msg_sent;
2110 os_free(conn->name);
2111 conn->name = os_strdup(name ? name : "Test");
2112 os_free(conn->mud_url);
2113 conn->mud_url = mud_url ? os_strdup(mud_url) : NULL;
2114 os_free(conn->extra_conf_req_name);
2115 conn->extra_conf_req_name = extra_conf_req_name ?
2117 conn->extra_conf_req_value = extra_conf_req_value ?
2119 conn->netrole = netrole;
2120 conn->auth = auth;
2122 if (dpp_tcp_auth_start(conn, auth) < 0)
2125 dpp_conn_tx_ready(conn->sock, conn, NULL);
2148 dl_list_init(&ctrl->conn);
2253 struct dpp_connection *conn;
2255 dl_list_for_each(conn, &dpp->tcp_init, struct dpp_connection, list) {
2256 if (dpp_tcp_peer_id_match(conn->auth, id))
2257 return conn->auth;
2268 struct dpp_connection *conn;
2273 dl_list_for_each(conn, &ctrl->conn, struct dpp_connection, list) {
2274 if (dpp_tcp_peer_id_match(conn->auth, id))
2275 return conn->auth;
2286 struct dpp_connection *conn;
2291 dl_list_for_each(conn, &ctrl->conn, struct dpp_connection, list) {
2292 struct dpp_authentication *auth = conn->auth;
2299 dpp_tcp_send_msg(conn, conn->auth->resp_msg);
2324 struct dpp_connection *conn;
2328 dl_list_for_each(conn, &dpp->tcp_init, struct dpp_connection, list) {
2329 if (!conn->pkex || !conn->pkex->enc_key)
2340 if (attr_key_len == wpabuf_len(conn->pkex->enc_key) &&
2341 os_memcmp(attr_key, wpabuf_head(conn->pkex->enc_key),
2352 struct dpp_connection *conn, *tmp;
2354 dl_list_for_each_safe(conn, tmp, &dpp->tcp_init, struct dpp_connection,
2356 dpp_connection_remove(conn);
2362 struct dpp_connection *conn, *tmp;
2368 dl_list_for_each_safe(conn, tmp, &ctrl->conn, struct dpp_connection,
2370 dpp_connection_remove(conn);
2427 struct dpp_connection *conn = NULL;
2443 dl_list_len(&dpp->tmp_controller->conn)) {
2458 dl_list_init(&ctrl->conn);
2474 if (dl_list_len(&ctrl->conn) >= 15) {
2480 conn = os_zalloc(sizeof(*conn));
2481 if (!conn)
2484 conn->global = ctrl->global;
2485 conn->relay = ctrl;
2486 conn->msg_ctx = ctrl->msg_ctx;
2487 conn->cb_ctx = ctrl->global->cb_ctx;
2488 os_memset(conn->mac_addr, 0xff, ETH_ALEN);
2489 conn->sock = fd;
2491 if (fcntl(conn->sock, F_SETFL, O_NONBLOCK) != 0) {
2497 if (eloop_register_sock(conn->sock, EVENT_TYPE_READ,
2498 dpp_controller_rx, conn, NULL) < 0)
2500 conn->read_eloop = 1;
2504 dl_list_add(&ctrl->conn, &conn->list);
2509 os_free(conn);
2590 struct dpp_connection *conn;
2595 dl_list_for_each(conn, &dpp->tcp_init, struct dpp_connection, list) {
2596 if (conn->auth && conn->auth->conn_status_requested)
2605 struct dpp_connection *conn,
2610 struct dpp_authentication *auth = conn->auth;
2620 dpp_connection_remove(conn);
2624 res = dpp_tcp_send_msg(conn, msg);
2628 dpp_connection_remove(conn);
2632 /* conn might have been removed during the dpp_tcp_send_msg() call, so
2635 if (conn == c) {
2638 conn->on_tcp_tx_complete_remove = 1;
2650 struct dpp_connection *conn;
2652 dl_list_for_each(conn, &dpp->tcp_init, struct dpp_connection, list) {
2653 if (conn->auth && conn->auth->conn_status_requested) {
2654 dpp_tcp_send_conn_status_msg(dpp, conn, result, ssid,