171 static int     unp_connect_pair(struct unpcb *unp, struct unpcb *unp2);
360 		struct unpcb *unp2 = unp->unp_conn;  in uipc_accept()  local
367 		if (unp2 && unp2->unp_addr) {  in uipc_accept()
368 			unp_reference(unp2);  in uipc_accept()
370 				(struct sockaddr *)unp2->unp_addr);  in uipc_accept()
371 			unp_free(unp2);  in uipc_accept()
516 		struct unpcb *unp2 = unp->unp_conn;  in uipc_peeraddr()  local
518 		unp_reference(unp2);  in uipc_peeraddr()
520 				(struct sockaddr *)unp2->unp_addr);  in uipc_peeraddr()
521 		unp_free(unp2);  in uipc_peeraddr()
542 	struct unpcb *unp, *unp2;  in uipc_rcvd()  local
567 		unp2 = unp->unp_conn;	/* protected by pool token */  in uipc_rcvd()
578 		so2 = unp2->unp_socket;  in uipc_rcvd()
579 		unp_reference(unp2);  in uipc_rcvd()
589 		unp_free(unp2);  in uipc_rcvd()
606 	struct unpcb *unp, *unp2;  in uipc_send()  local
651 			    msg->send.nm_td, so->so_type, &unp2);  in uipc_send()
663 			unp_reltoken(unp2);  in uipc_send()
670 			unp2 = unp->unp_conn;  in uipc_send()
671 			unp_reference(unp2);  in uipc_send()
674 		so2 = unp2->unp_socket;  in uipc_send()
717 		unp_free(unp2);  in uipc_send()
754 		unp2 = unp->unp_conn;  in uipc_send()
755 		KASSERT(unp2 != NULL, ("unp is not connected"));  in uipc_send()
756 		so2 = unp2->unp_socket;  in uipc_send()
758 		unp_reference(unp2);  in uipc_send()
792 		unp_free(unp2);  in uipc_send()
1180 	struct unpcb *unp, *unp2;  in unp_connect()  local
1199 	error = unp_find_lockref(nam, td, so->so_type, &unp2);  in unp_connect()
1211 		so2 = unp2->unp_socket;  in unp_connect()
1214 		    !(unp2->unp_flags & UNP_HAVEPCCACHED) ||  in unp_connect()
1246 		if (unp2->unp_addr != NULL) {  in unp_connect()
1248 			    dup_sockaddr((struct sockaddr *)unp2->unp_addr);  in unp_connect()
1267 		KASSERT(unp2->unp_flags & UNP_HAVEPCCACHED,  in unp_connect()
1269 		memcpy(&unp->unp_peercred, &unp2->unp_peercred,  in unp_connect()
1281 		error = unp_connect_pair(unp, unp2);  in unp_connect()
1284 	unp_free(unp2);  in unp_connect()
1285 	unp_reltoken(unp2);  in unp_connect()
1304 	struct unpcb *unp, *unp2;  in unp_connect2()  local
1313 	unp2 = unp_getsocktoken(so2);  in unp_connect2()
1316 	cru2x(cred, &unp2->unp_peercred);  in unp_connect2()
1318 	unp_setflags(unp2, UNP_HAVEPC);  in unp_connect2()
1324 	if (!UNP_ISATTACHED(unp2)) {  in unp_connect2()
1334 	    unp2->unp_conn != NULL) {  in unp_connect2()
1339 	error = unp_connect_pair(unp, unp2);  in unp_connect2()
1341 	unp_reltoken(unp2);  in unp_connect2()
1357 	struct unpcb *unp2;  in unp_disconnect()  local
1365 	while ((unp2 = unp->unp_conn) != NULL) {  in unp_disconnect()
1366 		lwkt_getpooltoken(unp2);  in unp_disconnect()
1367 		if (unp2 == unp->unp_conn)  in unp_disconnect()
1369 		lwkt_relpooltoken(unp2);  in unp_disconnect()
1371 	if (unp2 == NULL)  in unp_disconnect()
1375 	KASSERT((unp2->unp_flags & UNP_DROPPED) == 0, ("unp2 was dropped"));  in unp_disconnect()
1392 		unp_reference(unp2);  in unp_disconnect()
1393 		KASSERT(unp2->unp_conn == unp, ("unp_conn mismatch"));  in unp_disconnect()
1394 		unp2->unp_conn = NULL;  in unp_disconnect()
1397 		soisdisconnected(unp2->unp_socket);  in unp_disconnect()
1399 		unp_free(unp2);  in unp_disconnect()
1403 	lwkt_relpooltoken(unp2);  in unp_disconnect()
2477 unp_connect_pair(struct unpcb *unp, struct unpcb *unp2)  in unp_connect_pair()  argument
2480 	struct socket *so2 = unp2->unp_socket;  in unp_connect_pair()
2484 	UNP_ASSERT_TOKEN_HELD(unp2);  in unp_connect_pair()
2491 	if (!UNP_ISATTACHED(unp2))  in unp_connect_pair()
2495 	unp->unp_conn = unp2;  in unp_connect_pair()
2499 		LIST_INSERT_HEAD(&unp2->unp_refs, unp, unp_reflink);  in unp_connect_pair()
2505 		KASSERT(unp2->unp_conn == NULL, ("unp2 is already connected"));  in unp_connect_pair()
2506 		unp2->unp_conn = unp;  in unp_connect_pair()
2521 	struct unpcb *unp2;  in unp_drop()  local
2540 	while ((unp2 = LIST_FIRST(&unp->unp_refs)) != NULL) {  in unp_drop()
2541 		lwkt_getpooltoken(unp2);  in unp_drop()
2542 		unp_disconnect(unp2, ECONNRESET);  in unp_drop()
2543 		lwkt_relpooltoken(unp2);  in unp_drop()