xref: /netbsd-src/external/bsd/wpa/dist/wpa_supplicant/ctrl_iface_unix.c (revision 6a493d6bc668897c91594964a732d38505b70cbb)
1 /*
2  * WPA Supplicant / UNIX domain socket -based control interface
3  * Copyright (c) 2004-2009, Jouni Malinen <j@w1.fi>
4  *
5  * This program is free software; you can redistribute it and/or modify
6  * it under the terms of the GNU General Public License version 2 as
7  * published by the Free Software Foundation.
8  *
9  * Alternatively, this software may be distributed under the terms of BSD
10  * license.
11  *
12  * See README and COPYING for more details.
13  */
14 
15 #include "includes.h"
16 #include <sys/un.h>
17 #include <sys/stat.h>
18 #include <grp.h>
19 #include <stddef.h>
20 #ifdef ANDROID
21 #include <cutils/sockets.h>
22 #endif /* ANDROID */
23 
24 #include "utils/common.h"
25 #include "utils/eloop.h"
26 #include "utils/list.h"
27 #include "eapol_supp/eapol_supp_sm.h"
28 #include "config.h"
29 #include "wpa_supplicant_i.h"
30 #include "ctrl_iface.h"
31 
32 /* Per-interface ctrl_iface */
33 
34 /**
35  * struct wpa_ctrl_dst - Internal data structure of control interface monitors
36  *
37  * This structure is used to store information about registered control
38  * interface monitors into struct wpa_supplicant. This data is private to
39  * ctrl_iface_unix.c and should not be touched directly from other files.
40  */
41 struct wpa_ctrl_dst {
42 	struct dl_list list;
43 	struct sockaddr_un addr;
44 	socklen_t addrlen;
45 	int debug_level;
46 	int errors;
47 };
48 
49 
50 struct ctrl_iface_priv {
51 	struct wpa_supplicant *wpa_s;
52 	int sock;
53 	struct dl_list ctrl_dst;
54 };
55 
56 
57 static void wpa_supplicant_ctrl_iface_send(struct ctrl_iface_priv *priv,
58 					   int level, const char *buf,
59 					   size_t len);
60 
61 
62 static int wpa_supplicant_ctrl_iface_attach(struct ctrl_iface_priv *priv,
63 					    struct sockaddr_un *from,
64 					    socklen_t fromlen)
65 {
66 	struct wpa_ctrl_dst *dst;
67 
68 	dst = os_zalloc(sizeof(*dst));
69 	if (dst == NULL)
70 		return -1;
71 	os_memcpy(&dst->addr, from, sizeof(struct sockaddr_un));
72 	dst->addrlen = fromlen;
73 	dst->debug_level = MSG_INFO;
74 	dl_list_add(&priv->ctrl_dst, &dst->list);
75 	wpa_hexdump(MSG_DEBUG, "CTRL_IFACE monitor attached",
76 		    (u8 *) from->sun_path,
77 		    fromlen - offsetof(struct sockaddr_un, sun_path));
78 	return 0;
79 }
80 
81 
82 static int wpa_supplicant_ctrl_iface_detach(struct ctrl_iface_priv *priv,
83 					    struct sockaddr_un *from,
84 					    socklen_t fromlen)
85 {
86 	struct wpa_ctrl_dst *dst;
87 
88 	dl_list_for_each(dst, &priv->ctrl_dst, struct wpa_ctrl_dst, list) {
89 		if (fromlen == dst->addrlen &&
90 		    os_memcmp(from->sun_path, dst->addr.sun_path,
91 			      fromlen - offsetof(struct sockaddr_un, sun_path))
92 		    == 0) {
93 			dl_list_del(&dst->list);
94 			os_free(dst);
95 			wpa_hexdump(MSG_DEBUG, "CTRL_IFACE monitor detached",
96 				    (u8 *) from->sun_path,
97 				    fromlen -
98 				    offsetof(struct sockaddr_un, sun_path));
99 			return 0;
100 		}
101 	}
102 	return -1;
103 }
104 
105 
106 static int wpa_supplicant_ctrl_iface_level(struct ctrl_iface_priv *priv,
107 					   struct sockaddr_un *from,
108 					   socklen_t fromlen,
109 					   char *level)
110 {
111 	struct wpa_ctrl_dst *dst;
112 
113 	wpa_printf(MSG_DEBUG, "CTRL_IFACE LEVEL %s", level);
114 
115 	dl_list_for_each(dst, &priv->ctrl_dst, struct wpa_ctrl_dst, list) {
116 		if (fromlen == dst->addrlen &&
117 		    os_memcmp(from->sun_path, dst->addr.sun_path,
118 			      fromlen - offsetof(struct sockaddr_un, sun_path))
119 		    == 0) {
120 			wpa_hexdump(MSG_DEBUG, "CTRL_IFACE changed monitor "
121 				    "level", (u8 *) from->sun_path,
122 				    fromlen -
123 				    offsetof(struct sockaddr_un, sun_path));
124 			dst->debug_level = atoi(level);
125 			return 0;
126 		}
127 	}
128 
129 	return -1;
130 }
131 
132 
133 static void wpa_supplicant_ctrl_iface_receive(int sock, void *eloop_ctx,
134 					      void *sock_ctx)
135 {
136 	struct wpa_supplicant *wpa_s = eloop_ctx;
137 	struct ctrl_iface_priv *priv = sock_ctx;
138 	char buf[4096];
139 	int res;
140 	struct sockaddr_un from;
141 	socklen_t fromlen = sizeof(from);
142 	char *reply = NULL;
143 	size_t reply_len = 0;
144 	int new_attached = 0;
145 
146 	res = recvfrom(sock, buf, sizeof(buf) - 1, 0,
147 		       (struct sockaddr *) &from, &fromlen);
148 	if (res < 0) {
149 		perror("recvfrom(ctrl_iface)");
150 		return;
151 	}
152 	buf[res] = '\0';
153 
154 	if (os_strcmp(buf, "ATTACH") == 0) {
155 		if (wpa_supplicant_ctrl_iface_attach(priv, &from, fromlen))
156 			reply_len = 1;
157 		else {
158 			new_attached = 1;
159 			reply_len = 2;
160 		}
161 	} else if (os_strcmp(buf, "DETACH") == 0) {
162 		if (wpa_supplicant_ctrl_iface_detach(priv, &from, fromlen))
163 			reply_len = 1;
164 		else
165 			reply_len = 2;
166 	} else if (os_strncmp(buf, "LEVEL ", 6) == 0) {
167 		if (wpa_supplicant_ctrl_iface_level(priv, &from, fromlen,
168 						    buf + 6))
169 			reply_len = 1;
170 		else
171 			reply_len = 2;
172 	} else {
173 		reply = wpa_supplicant_ctrl_iface_process(wpa_s, buf,
174 							  &reply_len);
175 	}
176 
177 	if (reply) {
178 		sendto(sock, reply, reply_len, 0, (struct sockaddr *) &from,
179 		       fromlen);
180 		os_free(reply);
181 	} else if (reply_len == 1) {
182 		sendto(sock, "FAIL\n", 5, 0, (struct sockaddr *) &from,
183 		       fromlen);
184 	} else if (reply_len == 2) {
185 		sendto(sock, "OK\n", 3, 0, (struct sockaddr *) &from,
186 		       fromlen);
187 	}
188 
189 	if (new_attached)
190 		eapol_sm_notify_ctrl_attached(wpa_s->eapol);
191 }
192 
193 
194 static char * wpa_supplicant_ctrl_iface_path(struct wpa_supplicant *wpa_s)
195 {
196 	char *buf;
197 	size_t len;
198 	char *pbuf, *dir = NULL, *gid_str = NULL;
199 	int res;
200 
201 	if (wpa_s->conf->ctrl_interface == NULL)
202 		return NULL;
203 
204 	pbuf = os_strdup(wpa_s->conf->ctrl_interface);
205 	if (pbuf == NULL)
206 		return NULL;
207 	if (os_strncmp(pbuf, "DIR=", 4) == 0) {
208 		dir = pbuf + 4;
209 		gid_str = os_strstr(dir, " GROUP=");
210 		if (gid_str) {
211 			*gid_str = '\0';
212 			gid_str += 7;
213 		}
214 	} else
215 		dir = pbuf;
216 
217 	len = os_strlen(dir) + os_strlen(wpa_s->ifname) + 2;
218 	buf = os_malloc(len);
219 	if (buf == NULL) {
220 		os_free(pbuf);
221 		return NULL;
222 	}
223 
224 	res = os_snprintf(buf, len, "%s/%s", dir, wpa_s->ifname);
225 	if (res < 0 || (size_t) res >= len) {
226 		os_free(pbuf);
227 		os_free(buf);
228 		return NULL;
229 	}
230 #ifdef __CYGWIN__
231 	{
232 		/* Windows/WinPcap uses interface names that are not suitable
233 		 * as a file name - convert invalid chars to underscores */
234 		char *pos = buf;
235 		while (*pos) {
236 			if (*pos == '\\')
237 				*pos = '_';
238 			pos++;
239 		}
240 	}
241 #endif /* __CYGWIN__ */
242 	os_free(pbuf);
243 	return buf;
244 }
245 
246 
247 static void wpa_supplicant_ctrl_iface_msg_cb(void *ctx, int level,
248 					     const char *txt, size_t len)
249 {
250 	struct wpa_supplicant *wpa_s = ctx;
251 	if (wpa_s == NULL || wpa_s->ctrl_iface == NULL)
252 		return;
253 	wpa_supplicant_ctrl_iface_send(wpa_s->ctrl_iface, level, txt, len);
254 }
255 
256 
257 struct ctrl_iface_priv *
258 wpa_supplicant_ctrl_iface_init(struct wpa_supplicant *wpa_s)
259 {
260 	struct ctrl_iface_priv *priv;
261 	struct sockaddr_un addr;
262 	char *fname = NULL;
263 	gid_t gid = 0;
264 	int gid_set = 0;
265 	char *buf, *dir = NULL, *gid_str = NULL;
266 	struct group *grp;
267 	char *endp;
268 
269 	priv = os_zalloc(sizeof(*priv));
270 	if (priv == NULL)
271 		return NULL;
272 	dl_list_init(&priv->ctrl_dst);
273 	priv->wpa_s = wpa_s;
274 	priv->sock = -1;
275 
276 	if (wpa_s->conf->ctrl_interface == NULL)
277 		return priv;
278 
279 	buf = os_strdup(wpa_s->conf->ctrl_interface);
280 	if (buf == NULL)
281 		goto fail;
282 #ifdef ANDROID
283 	os_snprintf(addr.sun_path, sizeof(addr.sun_path), "wpa_%s",
284 		    wpa_s->conf->ctrl_interface);
285 	priv->sock = android_get_control_socket(addr.sun_path);
286 	if (priv->sock >= 0)
287 		goto havesock;
288 #endif /* ANDROID */
289 	if (os_strncmp(buf, "DIR=", 4) == 0) {
290 		dir = buf + 4;
291 		gid_str = os_strstr(dir, " GROUP=");
292 		if (gid_str) {
293 			*gid_str = '\0';
294 			gid_str += 7;
295 		}
296 	} else {
297 		dir = buf;
298 		gid_str = wpa_s->conf->ctrl_interface_group;
299 	}
300 
301 	if (mkdir(dir, S_IRWXU | S_IRWXG) < 0) {
302 		if (errno == EEXIST) {
303 			wpa_printf(MSG_DEBUG, "Using existing control "
304 				   "interface directory.");
305 		} else {
306 			perror("mkdir[ctrl_interface]");
307 			goto fail;
308 		}
309 	}
310 
311 	if (gid_str) {
312 		grp = getgrnam(gid_str);
313 		if (grp) {
314 			gid = grp->gr_gid;
315 			gid_set = 1;
316 			wpa_printf(MSG_DEBUG, "ctrl_interface_group=%d"
317 				   " (from group name '%s')",
318 				   (int) gid, gid_str);
319 		} else {
320 			/* Group name not found - try to parse this as gid */
321 			gid = strtol(gid_str, &endp, 10);
322 			if (*gid_str == '\0' || *endp != '\0') {
323 				wpa_printf(MSG_ERROR, "CTRL: Invalid group "
324 					   "'%s'", gid_str);
325 				goto fail;
326 			}
327 			gid_set = 1;
328 			wpa_printf(MSG_DEBUG, "ctrl_interface_group=%d",
329 				   (int) gid);
330 		}
331 	}
332 
333 	if (gid_set && chown(dir, -1, gid) < 0) {
334 		perror("chown[ctrl_interface]");
335 		goto fail;
336 	}
337 
338 	/* Make sure the group can enter and read the directory */
339 	if (gid_set &&
340 	    chmod(dir, S_IRUSR | S_IWUSR | S_IXUSR | S_IRGRP | S_IXGRP) < 0) {
341 		wpa_printf(MSG_ERROR, "CTRL: chmod[ctrl_interface]: %s",
342 			   strerror(errno));
343 		goto fail;
344 	}
345 
346 	if (os_strlen(dir) + 1 + os_strlen(wpa_s->ifname) >=
347 	    sizeof(addr.sun_path)) {
348 		wpa_printf(MSG_ERROR, "ctrl_iface path limit exceeded");
349 		goto fail;
350 	}
351 
352 	priv->sock = socket(PF_UNIX, SOCK_DGRAM, 0);
353 	if (priv->sock < 0) {
354 		perror("socket(PF_UNIX)");
355 		goto fail;
356 	}
357 
358 	os_memset(&addr, 0, sizeof(addr));
359 #if defined(__FreeBSD__) || defined(__FreeBSD_kernel__)
360 	addr.sun_len = sizeof(addr);
361 #endif /* __FreeBSD__ */
362 	addr.sun_family = AF_UNIX;
363 	fname = wpa_supplicant_ctrl_iface_path(wpa_s);
364 	if (fname == NULL)
365 		goto fail;
366 	os_strlcpy(addr.sun_path, fname, sizeof(addr.sun_path));
367 	if (bind(priv->sock, (struct sockaddr *) &addr, sizeof(addr)) < 0) {
368 		wpa_printf(MSG_DEBUG, "ctrl_iface bind(PF_UNIX) failed: %s",
369 			   strerror(errno));
370 		if (connect(priv->sock, (struct sockaddr *) &addr,
371 			    sizeof(addr)) < 0) {
372 			wpa_printf(MSG_DEBUG, "ctrl_iface exists, but does not"
373 				   " allow connections - assuming it was left"
374 				   "over from forced program termination");
375 			if (unlink(fname) < 0) {
376 				perror("unlink[ctrl_iface]");
377 				wpa_printf(MSG_ERROR, "Could not unlink "
378 					   "existing ctrl_iface socket '%s'",
379 					   fname);
380 				goto fail;
381 			}
382 			if (bind(priv->sock, (struct sockaddr *) &addr,
383 				 sizeof(addr)) < 0) {
384 				perror("bind(PF_UNIX)");
385 				goto fail;
386 			}
387 			wpa_printf(MSG_DEBUG, "Successfully replaced leftover "
388 				   "ctrl_iface socket '%s'", fname);
389 		} else {
390 			wpa_printf(MSG_INFO, "ctrl_iface exists and seems to "
391 				   "be in use - cannot override it");
392 			wpa_printf(MSG_INFO, "Delete '%s' manually if it is "
393 				   "not used anymore", fname);
394 			os_free(fname);
395 			fname = NULL;
396 			goto fail;
397 		}
398 	}
399 
400 	if (gid_set && chown(fname, -1, gid) < 0) {
401 		perror("chown[ctrl_interface/ifname]");
402 		goto fail;
403 	}
404 
405 	if (chmod(fname, S_IRWXU | S_IRWXG) < 0) {
406 		perror("chmod[ctrl_interface/ifname]");
407 		goto fail;
408 	}
409 	os_free(fname);
410 
411 #ifdef ANDROID
412 havesock:
413 #endif /* ANDROID */
414 	eloop_register_read_sock(priv->sock, wpa_supplicant_ctrl_iface_receive,
415 				 wpa_s, priv);
416 	wpa_msg_register_cb(wpa_supplicant_ctrl_iface_msg_cb);
417 
418 	os_free(buf);
419 	return priv;
420 
421 fail:
422 	if (priv->sock >= 0)
423 		close(priv->sock);
424 	os_free(priv);
425 	if (fname) {
426 		unlink(fname);
427 		os_free(fname);
428 	}
429 	os_free(buf);
430 	return NULL;
431 }
432 
433 
434 void wpa_supplicant_ctrl_iface_deinit(struct ctrl_iface_priv *priv)
435 {
436 	struct wpa_ctrl_dst *dst, *prev;
437 
438 	if (priv->sock > -1) {
439 		char *fname;
440 		char *buf, *dir = NULL, *gid_str = NULL;
441 		eloop_unregister_read_sock(priv->sock);
442 		if (!dl_list_empty(&priv->ctrl_dst)) {
443 			/*
444 			 * Wait a second before closing the control socket if
445 			 * there are any attached monitors in order to allow
446 			 * them to receive any pending messages.
447 			 */
448 			wpa_printf(MSG_DEBUG, "CTRL_IFACE wait for attached "
449 				   "monitors to receive messages");
450 			os_sleep(1, 0);
451 		}
452 		close(priv->sock);
453 		priv->sock = -1;
454 		fname = wpa_supplicant_ctrl_iface_path(priv->wpa_s);
455 		if (fname) {
456 			unlink(fname);
457 			os_free(fname);
458 		}
459 
460 		buf = os_strdup(priv->wpa_s->conf->ctrl_interface);
461 		if (buf == NULL)
462 			goto free_dst;
463 		if (os_strncmp(buf, "DIR=", 4) == 0) {
464 			dir = buf + 4;
465 			gid_str = os_strstr(dir, " GROUP=");
466 			if (gid_str) {
467 				*gid_str = '\0';
468 				gid_str += 7;
469 			}
470 		} else
471 			dir = buf;
472 
473 		if (rmdir(dir) < 0) {
474 			if (errno == ENOTEMPTY) {
475 				wpa_printf(MSG_DEBUG, "Control interface "
476 					   "directory not empty - leaving it "
477 					   "behind");
478 			} else {
479 				perror("rmdir[ctrl_interface]");
480 			}
481 		}
482 		os_free(buf);
483 	}
484 
485 free_dst:
486 	dl_list_for_each_safe(dst, prev, &priv->ctrl_dst, struct wpa_ctrl_dst,
487 			      list)
488 		os_free(dst);
489 	os_free(priv);
490 }
491 
492 
493 /**
494  * wpa_supplicant_ctrl_iface_send - Send a control interface packet to monitors
495  * @priv: Pointer to private data from wpa_supplicant_ctrl_iface_init()
496  * @level: Priority level of the message
497  * @buf: Message data
498  * @len: Message length
499  *
500  * Send a packet to all monitor programs attached to the control interface.
501  */
502 static void wpa_supplicant_ctrl_iface_send(struct ctrl_iface_priv *priv,
503 					   int level, const char *buf,
504 					   size_t len)
505 {
506 	struct wpa_ctrl_dst *dst, *next;
507 	char levelstr[10];
508 	int idx, res;
509 	struct msghdr msg;
510 	struct iovec io[2];
511 
512 	if (priv->sock < 0 || dl_list_empty(&priv->ctrl_dst))
513 		return;
514 
515 	res = os_snprintf(levelstr, sizeof(levelstr), "<%d>", level);
516 	if (res < 0 || (size_t) res >= sizeof(levelstr))
517 		return;
518 	io[0].iov_base = levelstr;
519 	io[0].iov_len = os_strlen(levelstr);
520 	io[1].iov_base = (char *) buf;
521 	io[1].iov_len = len;
522 	os_memset(&msg, 0, sizeof(msg));
523 	msg.msg_iov = io;
524 	msg.msg_iovlen = 2;
525 
526 	idx = 0;
527 	dl_list_for_each_safe(dst, next, &priv->ctrl_dst, struct wpa_ctrl_dst,
528 			      list) {
529 		if (level >= dst->debug_level) {
530 			wpa_hexdump(MSG_DEBUG, "CTRL_IFACE monitor send",
531 				    (u8 *) dst->addr.sun_path, dst->addrlen -
532 				    offsetof(struct sockaddr_un, sun_path));
533 			msg.msg_name = (void *) &dst->addr;
534 			msg.msg_namelen = dst->addrlen;
535 			if (sendmsg(priv->sock, &msg, 0) < 0) {
536 				int _errno = errno;
537 				wpa_printf(MSG_INFO, "CTRL_IFACE monitor[%d]: "
538 					   "%d - %s",
539 					   idx, errno, strerror(errno));
540 				dst->errors++;
541 				if (dst->errors > 1000 ||
542 				    (_errno != ENOBUFS && dst->errors > 10) ||
543 				    _errno == ENOENT) {
544 					wpa_supplicant_ctrl_iface_detach(
545 						priv, &dst->addr,
546 						dst->addrlen);
547 				}
548 			} else
549 				dst->errors = 0;
550 		}
551 		idx++;
552 	}
553 }
554 
555 
556 void wpa_supplicant_ctrl_iface_wait(struct ctrl_iface_priv *priv)
557 {
558 	char buf[256];
559 	int res;
560 	struct sockaddr_un from;
561 	socklen_t fromlen = sizeof(from);
562 
563 	for (;;) {
564 		wpa_printf(MSG_DEBUG, "CTRL_IFACE - %s - wait for monitor to "
565 			   "attach", priv->wpa_s->ifname);
566 		eloop_wait_for_read_sock(priv->sock);
567 
568 		res = recvfrom(priv->sock, buf, sizeof(buf) - 1, 0,
569 			       (struct sockaddr *) &from, &fromlen);
570 		if (res < 0) {
571 			perror("recvfrom(ctrl_iface)");
572 			continue;
573 		}
574 		buf[res] = '\0';
575 
576 		if (os_strcmp(buf, "ATTACH") == 0) {
577 			/* handle ATTACH signal of first monitor interface */
578 			if (!wpa_supplicant_ctrl_iface_attach(priv, &from,
579 							      fromlen)) {
580 				sendto(priv->sock, "OK\n", 3, 0,
581 				       (struct sockaddr *) &from, fromlen);
582 				/* OK to continue */
583 				return;
584 			} else {
585 				sendto(priv->sock, "FAIL\n", 5, 0,
586 				       (struct sockaddr *) &from, fromlen);
587 			}
588 		} else {
589 			/* return FAIL for all other signals */
590 			sendto(priv->sock, "FAIL\n", 5, 0,
591 			       (struct sockaddr *) &from, fromlen);
592 		}
593 	}
594 }
595 
596 
597 /* Global ctrl_iface */
598 
599 struct ctrl_iface_global_priv {
600 	struct wpa_global *global;
601 	int sock;
602 };
603 
604 
605 static void wpa_supplicant_global_ctrl_iface_receive(int sock, void *eloop_ctx,
606 						     void *sock_ctx)
607 {
608 	struct wpa_global *global = eloop_ctx;
609 	char buf[256];
610 	int res;
611 	struct sockaddr_un from;
612 	socklen_t fromlen = sizeof(from);
613 	char *reply;
614 	size_t reply_len;
615 
616 	res = recvfrom(sock, buf, sizeof(buf) - 1, 0,
617 		       (struct sockaddr *) &from, &fromlen);
618 	if (res < 0) {
619 		perror("recvfrom(ctrl_iface)");
620 		return;
621 	}
622 	buf[res] = '\0';
623 
624 	reply = wpa_supplicant_global_ctrl_iface_process(global, buf,
625 							 &reply_len);
626 
627 	if (reply) {
628 		sendto(sock, reply, reply_len, 0, (struct sockaddr *) &from,
629 		       fromlen);
630 		os_free(reply);
631 	} else if (reply_len) {
632 		sendto(sock, "FAIL\n", 5, 0, (struct sockaddr *) &from,
633 		       fromlen);
634 	}
635 }
636 
637 
638 struct ctrl_iface_global_priv *
639 wpa_supplicant_global_ctrl_iface_init(struct wpa_global *global)
640 {
641 	struct ctrl_iface_global_priv *priv;
642 	struct sockaddr_un addr;
643 
644 	priv = os_zalloc(sizeof(*priv));
645 	if (priv == NULL)
646 		return NULL;
647 	priv->global = global;
648 	priv->sock = -1;
649 
650 	if (global->params.ctrl_interface == NULL)
651 		return priv;
652 
653 #ifdef ANDROID
654 	priv->sock = android_get_control_socket(global->params.ctrl_interface);
655 	if (priv->sock >= 0)
656 		goto havesock;
657 #endif /* ANDROID */
658 
659 	wpa_printf(MSG_DEBUG, "Global control interface '%s'",
660 		   global->params.ctrl_interface);
661 
662 	priv->sock = socket(PF_UNIX, SOCK_DGRAM, 0);
663 	if (priv->sock < 0) {
664 		perror("socket(PF_UNIX)");
665 		goto fail;
666 	}
667 
668 	os_memset(&addr, 0, sizeof(addr));
669 #if defined(__FreeBSD__) || defined(__FreeBSD_kernel__)
670 	addr.sun_len = sizeof(addr);
671 #endif /* __FreeBSD__ */
672 	addr.sun_family = AF_UNIX;
673 	os_strlcpy(addr.sun_path, global->params.ctrl_interface,
674 		   sizeof(addr.sun_path));
675 	if (bind(priv->sock, (struct sockaddr *) &addr, sizeof(addr)) < 0) {
676 		perror("bind(PF_UNIX)");
677 		if (connect(priv->sock, (struct sockaddr *) &addr,
678 			    sizeof(addr)) < 0) {
679 			wpa_printf(MSG_DEBUG, "ctrl_iface exists, but does not"
680 				   " allow connections - assuming it was left"
681 				   "over from forced program termination");
682 			if (unlink(global->params.ctrl_interface) < 0) {
683 				perror("unlink[ctrl_iface]");
684 				wpa_printf(MSG_ERROR, "Could not unlink "
685 					   "existing ctrl_iface socket '%s'",
686 					   global->params.ctrl_interface);
687 				goto fail;
688 			}
689 			if (bind(priv->sock, (struct sockaddr *) &addr,
690 				 sizeof(addr)) < 0) {
691 				perror("bind(PF_UNIX)");
692 				goto fail;
693 			}
694 			wpa_printf(MSG_DEBUG, "Successfully replaced leftover "
695 				   "ctrl_iface socket '%s'",
696 				   global->params.ctrl_interface);
697 		} else {
698 			wpa_printf(MSG_INFO, "ctrl_iface exists and seems to "
699 				   "be in use - cannot override it");
700 			wpa_printf(MSG_INFO, "Delete '%s' manually if it is "
701 				   "not used anymore",
702 				   global->params.ctrl_interface);
703 			goto fail;
704 		}
705 	}
706 
707 #ifdef ANDROID
708 havesock:
709 #endif /* ANDROID */
710 	eloop_register_read_sock(priv->sock,
711 				 wpa_supplicant_global_ctrl_iface_receive,
712 				 global, NULL);
713 
714 	return priv;
715 
716 fail:
717 	if (priv->sock >= 0)
718 		close(priv->sock);
719 	os_free(priv);
720 	return NULL;
721 }
722 
723 
724 void
725 wpa_supplicant_global_ctrl_iface_deinit(struct ctrl_iface_global_priv *priv)
726 {
727 	if (priv->sock >= 0) {
728 		eloop_unregister_read_sock(priv->sock);
729 		close(priv->sock);
730 	}
731 	if (priv->global->params.ctrl_interface)
732 		unlink(priv->global->params.ctrl_interface);
733 	os_free(priv);
734 }
735