208 mptcp_reass_present(struct socket *mp_so)  in mptcp_reass_present()  argument
210 	struct mptses *mpte = mpsotompte(mp_so);  in mptcp_reass_present()
243 		if (mp_so->so_state & SS_CANTRCVMORE) {  in mptcp_reass_present()
247 			if (sbappendstream_rcvdemux(mp_so, q->tqe_m)) {  in mptcp_reass_present()
251 		tcp_reass_qent_free(mp_so->so_proto, q);  in mptcp_reass_present()
262 		sorwakeup(mp_so); /* done with socket lock held */  in mptcp_reass_present()
268 mptcp_reass(struct socket *mp_so, struct pkthdr *phdr, int *tlenp, struct mbuf *m)  in mptcp_reass()  argument
270 	struct mptcb *mp_tp = mpsotomppcb(mp_so)->mpp_pcbe->mpte_mptcb;  in mptcp_reass()
285 	qlimit = MIN(MAX(100, mp_so->so_rcv.sb_hiwat >> 10),  in mptcp_reass()
296 	te = tcp_reass_qent_alloc(mp_so->so_proto);  in mptcp_reass()
331 				tcp_reass_qent_free(mp_so->so_proto, te);  in mptcp_reass()
374 		tcp_reass_qent_free(mp_so->so_proto, q);  in mptcp_reass()
392 	return mptcp_reass_present(mp_so);  in mptcp_reass()
401 	struct socket *mp_so;  in mptcp_input()  local
413 	mp_so = mptetoso(mpte);  in mptcp_input()
416 	socket_lock_assert_owned(mp_so);  in mptcp_input()
428 	count = mp_so->so_rcv.sb_cc;  in mptcp_input()
471 		if (sbappendstream_rcvdemux(mp_so, m)) {  in mptcp_input()
472 			sorwakeup(mp_so);  in mptcp_input()
476 		    struct socket *, mp_so,  in mptcp_input()
477 		    struct sockbuf *, &mp_so->so_rcv,  in mptcp_input()
478 		    struct sockbuf *, &mp_so->so_snd,  in mptcp_input()
480 		count = mp_so->so_rcv.sb_cc - count;  in mptcp_input()
486 			socantrcvmore(mp_so);  in mptcp_input()
598 			mb_dfin = mptcp_reass(mp_so, &m->m_pkthdr, &mb_datalen, m);  in mptcp_input()
606 		if (sbappendstream_rcvdemux(mp_so, m)) {  in mptcp_input()
610 		DTRACE_MPTCP6(receive, struct mbuf *, m, struct socket *, mp_so,  in mptcp_input()
611 		    struct sockbuf *, &mp_so->so_rcv,  in mptcp_input()
612 		    struct sockbuf *, &mp_so->so_snd,  in mptcp_input()
615 		count = mp_so->so_rcv.sb_cc - count;  in mptcp_input()
624 			socantrcvmore(mp_so);  in mptcp_input()
628 		count = mp_so->so_rcv.sb_cc;  in mptcp_input()
636 		sorwakeup(mp_so);  in mptcp_input()
643 	struct socket *mp_so = mptetoso(mp_tp->mpt_mpte);  in mptcp_can_send_more()  local
661 …if (!(mp_so->so_flags1 & SOF1_PRECONNECT_DATA) && MPTCP_SEQ_GEQ(mp_tp->mpt_sndnxt, mp_tp->mpt_sndm…  in mptcp_can_send_more()
689 	struct socket *mp_so;  in mptcp_output()  local
694 	mp_so = mptetoso(mpte);  in mptcp_output()
697 	socket_lock_assert_owned(mp_so);  in mptcp_output()
699 	if (mp_so->so_flags & SOF_DEFUNCT) {  in mptcp_output()
730 		if ((mp_so->so_snd.sb_flags & (SB_AUTOSIZE | SB_TRIM)) == SB_AUTOSIZE) {  in mptcp_output()
731 			if ((mp_tp->mpt_sndwnd / 4 * 5) >= mp_so->so_snd.sb_hiwat &&  in mptcp_output()
732 			    mp_so->so_snd.sb_cc >= (mp_so->so_snd.sb_hiwat / 8 * 7)) {  in mptcp_output()
733 				if (sbreserve(&mp_so->so_snd,  in mptcp_output()
734 				    min(mp_so->so_snd.sb_hiwat + tcp_autosndbuf_inc,  in mptcp_output()
736 					mp_so->so_snd.sb_idealsize = mp_so->so_snd.sb_hiwat;  in mptcp_output()
742 		    struct socket *, mp_so);  in mptcp_output()
1038 	struct socket *mp_so = mptetoso(mp_tp->mpt_mpte);  in mptcp_close_fsm()  local
1040 	socket_lock_assert_owned(mp_so);  in mptcp_close_fsm()
1312 	struct socket *mp_so;  in mptcp_session_necp_cb()  local
1326 	mp_so = mptetoso(mpte);  in mptcp_session_necp_cb()
1329 		socket_lock(mp_so, 1);  in mptcp_session_necp_cb()
1338 	socket_lock_assert_owned(mp_so);  in mptcp_session_necp_cb()
1395 		    (mp_so->so_restrictions & SO_RESTRICT_DENY_EXPENSIVE)) {  in mptcp_session_necp_cb()
1400 		    (mp_so->so_restrictions & SO_RESTRICT_DENY_CONSTRAINED)) {  in mptcp_session_necp_cb()
1405 		    (mp_so->so_restrictions & SO_RESTRICT_DENY_CELLULAR)) {  in mptcp_session_necp_cb()
1489 		socket_unlock(mp_so, 1);  in mptcp_session_necp_cb()
1494 mptcp_set_restrictions(struct socket *mp_so)  in mptcp_set_restrictions()  argument
1496 	struct mptses *mpte = mpsotompte(mp_so);  in mptcp_set_restrictions()
1499 	socket_lock_assert_owned(mp_so);  in mptcp_set_restrictions()
1518 		    (mp_so->so_restrictions & SO_RESTRICT_DENY_EXPENSIVE)) {  in mptcp_set_restrictions()
1523 		    (mp_so->so_restrictions & SO_RESTRICT_DENY_CONSTRAINED)) {  in mptcp_set_restrictions()
1528 		    (mp_so->so_restrictions & SO_RESTRICT_DENY_CELLULAR)) {  in mptcp_set_restrictions()