36 	int sock;  member
46 	int sock;  member
64 					   const char *ifname, int sock,
76 static void wpas_ctrl_sock_debug(const char *title, int sock, const char *buf,  in wpas_ctrl_sock_debug()  argument
89 	if (getsockopt(sock, SOL_SOCKET, SO_SNDBUF, &sndbuf, &optlen) < 0)  in wpas_ctrl_sock_debug()
92 	if (ioctl(sock, TIOCOUTQ, &outq) < 0)  in wpas_ctrl_sock_debug()
97 		   title, sock, sndbuf, outq, (int) len);  in wpas_ctrl_sock_debug()
129 static void wpa_supplicant_ctrl_iface_receive(int sock, void *eloop_ctx,  in wpa_supplicant_ctrl_iface_receive()  argument
145 	res = recvfrom(sock, buf, CTRL_IFACE_MAX_LEN + 1, 0,  in wpa_supplicant_ctrl_iface_receive()
205 		wpas_ctrl_sock_debug("ctrl_sock-sendto", sock, reply,  in wpa_supplicant_ctrl_iface_receive()
207 		if (sendto(sock, reply, reply_len, 0, (struct sockaddr *) &from,  in wpa_supplicant_ctrl_iface_receive()
222 				sock = wpas_ctrl_iface_reinit(wpa_s, priv);  in wpa_supplicant_ctrl_iface_receive()
223 				if (sock < 0) {  in wpa_supplicant_ctrl_iface_receive()
295 static int wpas_ctrl_iface_throttle(int sock)  in wpas_ctrl_iface_throttle()  argument
303 	if (getsockopt(sock, SOL_SOCKET, SO_SNDBUF, &sndbuf, &optlen) < 0 ||  in wpas_ctrl_iface_throttle()
304 	    ioctl(sock, TIOCOUTQ, &outq) < 0 ||  in wpas_ctrl_iface_throttle()
321 	       !wpas_ctrl_iface_throttle(gpriv->sock)) {  in wpas_ctrl_msg_send_pending_global()
331 			gpriv->sock, &gpriv->ctrl_dst, msg->level,  in wpas_ctrl_msg_send_pending_global()
345 	       !wpas_ctrl_iface_throttle(priv->sock)) {  in wpas_ctrl_msg_send_pending_iface()
351 		wpa_supplicant_ctrl_iface_send(wpa_s, NULL, priv->sock,  in wpas_ctrl_msg_send_pending_iface()
364 	int sock = -1, gsock = -1;  in wpas_ctrl_msg_queue_timeout()  local
371 		sock = priv->sock;  in wpas_ctrl_msg_queue_timeout()
375 		gsock = gpriv->sock;  in wpas_ctrl_msg_queue_timeout()
377 	if (sock > -1 || gsock > -1) {  in wpas_ctrl_msg_queue_timeout()
381 			   sock, gsock);  in wpas_ctrl_msg_queue_timeout()
444 		    wpas_ctrl_iface_throttle(gpriv->sock)) {  in wpa_supplicant_ctrl_iface_msg_cb()
448 					   gpriv->sock);  in wpa_supplicant_ctrl_iface_msg_cb()
459 					   gpriv->throttle_count, gpriv->sock);  in wpa_supplicant_ctrl_iface_msg_cb()
466 				gpriv->sock, &gpriv->ctrl_dst, level,  in wpa_supplicant_ctrl_iface_msg_cb()
475 		    wpas_ctrl_iface_throttle(priv->sock)) {  in wpa_supplicant_ctrl_iface_msg_cb()
479 					   priv->sock);  in wpa_supplicant_ctrl_iface_msg_cb()
490 					   priv->throttle_count, priv->sock);  in wpa_supplicant_ctrl_iface_msg_cb()
493 			wpa_supplicant_ctrl_iface_send(wpa_s, NULL, priv->sock,  in wpa_supplicant_ctrl_iface_msg_cb()
523 	priv->sock = android_get_control_socket(addr.sun_path);  in wpas_ctrl_iface_open_sock()
524 	if (priv->sock >= 0) {  in wpas_ctrl_iface_open_sock()
610 	priv->sock = socket(PF_UNIX, SOCK_DGRAM, 0);  in wpas_ctrl_iface_open_sock()
611 	if (priv->sock < 0) {  in wpas_ctrl_iface_open_sock()
625 	if (bind(priv->sock, (struct sockaddr *) &addr, sizeof(addr)) < 0) {  in wpas_ctrl_iface_open_sock()
628 		if (connect(priv->sock, (struct sockaddr *) &addr,  in wpas_ctrl_iface_open_sock()
639 			if (bind(priv->sock, (struct sockaddr *) &addr,  in wpas_ctrl_iface_open_sock()
679 	flags = fcntl(priv->sock, F_GETFL);  in wpas_ctrl_iface_open_sock()
682 		if (fcntl(priv->sock, F_SETFL, flags) < 0) {  in wpas_ctrl_iface_open_sock()
693 	if (getsockopt(priv->sock, SOL_SOCKET, SO_SNDBUF, &optval, &optlen) == -1) {  in wpas_ctrl_iface_open_sock()
695 			   priv->sock, strerror(errno));  in wpas_ctrl_iface_open_sock()
698 		if (setsockopt(priv->sock, SOL_SOCKET, SO_SNDBUF, &optval,  in wpas_ctrl_iface_open_sock()
701 				   "sock=%d: %s", priv->sock, strerror(errno));  in wpas_ctrl_iface_open_sock()
705 	eloop_register_read_sock(priv->sock, wpa_supplicant_ctrl_iface_receive,  in wpas_ctrl_iface_open_sock()
713 	if (priv->sock >= 0) {  in wpas_ctrl_iface_open_sock()
714 		close(priv->sock);  in wpas_ctrl_iface_open_sock()
715 		priv->sock = -1;  in wpas_ctrl_iface_open_sock()
737 	priv->sock = -1;  in wpa_supplicant_ctrl_iface_init()
803 	if (priv->sock <= 0)  in wpas_ctrl_iface_reinit()
814 		return priv->sock;  in wpas_ctrl_iface_reinit()
816 	eloop_unregister_read_sock(priv->sock);  in wpas_ctrl_iface_reinit()
817 	close(priv->sock);  in wpas_ctrl_iface_reinit()
818 	priv->sock = -1;  in wpas_ctrl_iface_reinit()
822 	return priv->sock;  in wpas_ctrl_iface_reinit()
872 	if (priv->sock > -1) {  in wpa_supplicant_ctrl_iface_deinit()
875 		eloop_unregister_read_sock(priv->sock);  in wpa_supplicant_ctrl_iface_deinit()
886 		close(priv->sock);  in wpa_supplicant_ctrl_iface_deinit()
887 		priv->sock = -1;  in wpa_supplicant_ctrl_iface_deinit()
961 					   const char *ifname, int sock,  in wpa_supplicant_ctrl_iface_send()  argument
974 	if (sock < 0 || dl_list_empty(ctrl_dst))  in wpa_supplicant_ctrl_iface_send()
1011 		wpas_ctrl_sock_debug("ctrl_sock-sendmsg", sock, buf, len);  in wpa_supplicant_ctrl_iface_send()
1012 		if (sendmsg(sock, &msg, MSG_DONTWAIT) >= 0) {  in wpa_supplicant_ctrl_iface_send()
1042 				sock = wpas_ctrl_iface_reinit(wpa_s, priv);  in wpa_supplicant_ctrl_iface_send()
1044 				sock = wpas_ctrl_iface_global_reinit(  in wpa_supplicant_ctrl_iface_send()
1048 			if (sock < 0) {  in wpa_supplicant_ctrl_iface_send()
1065 	if (priv->sock == -1)  in wpa_supplicant_ctrl_iface_wait()
1071 		eloop_wait_for_read_sock(priv->sock);  in wpa_supplicant_ctrl_iface_wait()
1073 		res = recvfrom(priv->sock, buf, sizeof(buf) - 1, 0,  in wpa_supplicant_ctrl_iface_wait()
1087 				if (sendto(priv->sock, "OK\n", 3, 0,  in wpa_supplicant_ctrl_iface_wait()
1096 				if (sendto(priv->sock, "FAIL\n", 5, 0,  in wpa_supplicant_ctrl_iface_wait()
1105 			if (sendto(priv->sock, "FAIL\n", 5, 0,  in wpa_supplicant_ctrl_iface_wait()
1118 static void wpa_supplicant_global_ctrl_iface_receive(int sock, void *eloop_ctx,  in wpa_supplicant_global_ctrl_iface_receive()  argument
1133 	res = recvfrom(sock, buf, CTRL_IFACE_MAX_LEN + 1, 0,  in wpa_supplicant_global_ctrl_iface_receive()
1183 				     sock, reply, reply_len);  in wpa_supplicant_global_ctrl_iface_receive()
1184 		if (sendto(sock, reply, reply_len, 0, (struct sockaddr *) &from,  in wpa_supplicant_global_ctrl_iface_receive()
1206 		priv->sock = android_get_control_socket(ctrl + 9);  in wpas_global_ctrl_iface_open_sock()
1207 		if (priv->sock < 0) {  in wpas_global_ctrl_iface_open_sock()
1224 		priv->sock = android_get_control_socket(ctrl);  in wpas_global_ctrl_iface_open_sock()
1225 		if (priv->sock >= 0) {  in wpas_global_ctrl_iface_open_sock()
1235 	priv->sock = socket(PF_UNIX, SOCK_DGRAM, 0);  in wpas_global_ctrl_iface_open_sock()
1236 	if (priv->sock < 0) {  in wpas_global_ctrl_iface_open_sock()
1251 		if (bind(priv->sock, (struct sockaddr *) &addr, sizeof(addr)) <  in wpas_global_ctrl_iface_open_sock()
1264 	if (bind(priv->sock, (struct sockaddr *) &addr, sizeof(addr)) < 0) {  in wpas_global_ctrl_iface_open_sock()
1267 		if (connect(priv->sock, (struct sockaddr *) &addr,  in wpas_global_ctrl_iface_open_sock()
1278 			if (bind(priv->sock, (struct sockaddr *) &addr,  in wpas_global_ctrl_iface_open_sock()
1351 	flags = fcntl(priv->sock, F_GETFL);  in wpas_global_ctrl_iface_open_sock()
1354 		if (fcntl(priv->sock, F_SETFL, flags) < 0) {  in wpas_global_ctrl_iface_open_sock()
1361 	eloop_register_read_sock(priv->sock,  in wpas_global_ctrl_iface_open_sock()
1368 	if (priv->sock >= 0) {  in wpas_global_ctrl_iface_open_sock()
1369 		close(priv->sock);  in wpas_global_ctrl_iface_open_sock()
1370 		priv->sock = -1;  in wpas_global_ctrl_iface_open_sock()
1387 	priv->sock = -1;  in wpa_supplicant_global_ctrl_iface_init()
1408 	if (priv->sock <= 0)  in wpas_ctrl_iface_global_reinit()
1419 		return priv->sock;  in wpas_ctrl_iface_global_reinit()
1421 	eloop_unregister_read_sock(priv->sock);  in wpas_ctrl_iface_global_reinit()
1422 	close(priv->sock);  in wpas_ctrl_iface_global_reinit()
1423 	priv->sock = -1;  in wpas_ctrl_iface_global_reinit()
1427 	return priv->sock;  in wpas_ctrl_iface_global_reinit()
1437 	if (priv->sock >= 0) {  in wpa_supplicant_global_ctrl_iface_deinit()
1438 		eloop_unregister_read_sock(priv->sock);  in wpa_supplicant_global_ctrl_iface_deinit()
1439 		close(priv->sock);  in wpa_supplicant_global_ctrl_iface_deinit()