bsd/kern/uipc_usrreq.c

282 uipc_connect2(struct socket *so1, struct socket *so2)
289 	return (unp_connect2(so1, so2));
352 	struct socket *so2;
363 #define	snd (&so2->so_snd)
367 		so2 = unp->unp_conn->unp_socket;
368 		unp_get_locks_in_order(so, so2);
377 		sowwakeup(so2);
379 		socket_unlock(so2, 1);
418 	struct socket *so2;
458 		so2 = unp->unp_conn->unp_socket;
459 		if (so != so2)
460 			unp_get_locks_in_order(so, so2);
474 		if (sbappendaddr(&so2->so_rcv, from, m, control, &error)) {
476 			sorwakeup(so2);
482 		if (so != so2)
483 			socket_unlock(so2, 1);
493 #define	rcv (&so2->so_rcv)
518 		so2 = unp->unp_conn->unp_socket;
519 		unp_get_locks_in_order(so, so2);
527 			socket_unlock(so2, 1);
559 			sorwakeup(so2);
565 		socket_unlock(so2, 1);
603 	struct socket *so2;
611 		so2 = unp->unp_conn->unp_socket;
612 		blksize += so2->so_rcv.sb_cc;
1036 	struct socket *so2, *so3, *list_so=NULL;
1048 	so2 = so3 = NULL;
1096 	so2 = vp->v_socket;
1100 	if (so2->so_pcb == NULL) {
1102 		if (so != so2) {
1103 			socket_unlock(so2, 1);
1107 			so2->so_usecount--;
1112 	if (so < so2) {
1113 		socket_unlock(so2, 0);
1115 		socket_lock(so2, 0);
1116 	} else if (so > so2) {
1129 	if (so->so_type != so2->so_type) {
1138 		if ((so2->so_options & SO_ACCEPTCONN) == 0 ||
1139 		    (so3 = sonewconn(so2, 0, nam)) == 0) {
1141 			if (so != so2) {
1142 				socket_unlock(so2, 1);
1149 				so2->so_usecount--;
1153 		unp2 = sotounpcb(so2);
1178 		/* Here we need to have both so and so2 locks and so2
1181 		if (so < so2) {
1182 			socket_unlock(so2, 0);
1184 			socket_lock(so2, 0);
1192 			socket_unlock(so2, 1);
1209 		socket_unlock(so2, 0);
1210 		list_so = so2;
1214 		so2 = so3;
1229 	error = unp_connect2(so, so2);
1232 	if (so2 != NULL) {
1233 		if (so != so2) {
1234 			socket_unlock(so2, 1);
1240 			so2->so_usecount--;
1261 unp_connect2(struct socket *so, struct socket *so2)
1266 	if (so2->so_type != so->so_type)
1269 	unp2 = sotounpcb(so2);
1279 	so2->so_usecount++;
1286 		if (so != so2) {
1288  			/* Keep an extra reference on so2 that will be dropped
1291 			socket_unlock(so2, 0);
1293 			unp_get_locks_in_order(so, so2);
1294 			so2->so_usecount--;
1316 		soisconnected(so2);
1318 		/* Keep an extra reference on so2, that will be dropped soon after
1321 		socket_unlock(so2, 0);
1326 		unp_get_locks_in_order(so, so2);
1328 		so2->so_usecount--;
1343 	struct socket *so2 = NULL, *so;
1373 	so2 = unp2->unp_socket;
1376 	if (so == so2) {
1381 	} else if (so < so2) {
1385 		socket_lock(so2, 1);
1386 		waitso = so2;
1391 		socket_lock(so2, 1);
1405 		if (so != so2) {
1406 			socket_unlock(so2, 1);
1420 	so2->so_usecount--;
1430 		if (so != so2)
1431 			socket_unlock(so2, 1);
1464 		soisdisconnected(so2);
1465 		socket_unlock(so2, 1);
1793 	struct socket *so2;
1795 		so2 = unp->unp_conn->unp_socket;
1796 		unp_get_locks_in_order(so, so2);
1797 		socantrcvmore(so2);
1798 		socket_unlock(so2, 1);