sys/kern/uipc_usrreq.c

279 static int	unp_connect2(struct socket *so, struct socket *so2, int);
622 uipc_connect2(struct socket *so1, struct socket *so2)
631 	unp2 = so2->so_pcb;
634 	error = unp_connect2(so1, so2, PRU_CONNECT2);
790 	struct socket *so2;
820 	so2 = unp2->unp_socket;
821 	SOCKBUF_LOCK(&so2->so_snd);
822 	so2->so_snd.sb_mbmax += unp->unp_mbcnt - mbcnt;
823 	newhiwat = so2->so_snd.sb_hiwat + unp->unp_cc - sbcc;
824 	(void)chgsbsize(so2->so_cred->cr_uidinfo, &so2->so_snd.sb_hiwat,
826 	sowwakeup_locked(so2);
838 	struct socket *so2;
893 		so2 = unp2->unp_socket;
894 		SOCKBUF_LOCK(&so2->so_rcv);
895 		if (sbappendaddr_locked(&so2->so_rcv, from, m, control)) {
896 			sorwakeup_locked(so2);
900 			SOCKBUF_UNLOCK(&so2->so_rcv);
951 		so2 = unp2->unp_socket;
953 		SOCKBUF_LOCK(&so2->so_rcv);
969 				if (sbappendcontrol_locked(&so2->so_rcv, m,
973 				sbappend_locked(&so2->so_rcv, m);
980 			if (sbappendaddr_locked(&so2->so_rcv, from, m,
993 		mbcnt_delta = so2->so_rcv.sb_mbcnt - unp2->unp_mbcnt;
994 		unp2->unp_mbcnt = so2->so_rcv.sb_mbcnt;
995 		sbcc = so2->so_rcv.sb_cc;
996 		sorwakeup_locked(so2);
1046 	struct socket *so2;
1057 		so2 = unp2->unp_socket;
1058 		sb->st_blksize += so2->so_rcv.sb_cc;
1279 	struct socket *so2, *so3;
1343 	VOP_UNP_CONNECT(vp, &so2);
1344 	if (so2 == NULL) {
1348 	if (so->so_type != so2->so_type) {
1353 		if (so2->so_options & SO_ACCEPTCONN) {
1354 			CURVNET_SET(so2->so_vnet);
1355 			so3 = sonewconn(so2, 0);
1364 		unp2 = sotounpcb(so2);
1403 		so2 = so3;
1407 	unp2 = sotounpcb(so2);
1411 	error = unp_connect2(so, so2, PRU_CONNECT);
1428 unp_connect2(struct socket *so, struct socket *so2, int req)
1435 	unp2 = sotounpcb(so2);
1442 	if (so2->so_type != so->so_type)
1460 		soisconnected(so2);