| /xnu-12377.1.9/bsd/netinet/ |
| H A D | mptcp_timer.c | 143 struct socket *mp_so; in mptcp_timer() local
146 mp_so = mpp->mpp_socket; in mptcp_timer()
148 socket_lock(mp_so, 1); in mptcp_timer()
155 socket_unlock(mp_so, 1); in mptcp_timer()
233 struct socket *mp_so = mptetoso(mpte); in mptcp_urgency_timer() local
236 socket_lock(mp_so, 1); in mptcp_urgency_timer()
239 VERIFY(mp_so->so_usecount >= 0); in mptcp_urgency_timer()
242 …__func__, (unsigned long)VM_KERNEL_ADDRPERM(mpte), mpte->mpte_time_target, time_now, mp_so->so_use… in mptcp_urgency_timer()
246 mp_so->so_usecount--; in mptcp_urgency_timer()
248 socket_unlock(mp_so, 1); in mptcp_urgency_timer()
[all …]
|
| H A D | mptcp_usrreq.c | 122 mptcp_usr_attach(struct socket *mp_so, int proto, struct proc *p) in mptcp_usr_attach() argument
127 VERIFY(mpsotomppcb(mp_so) == NULL); in mptcp_usr_attach()
129 error = mptcp_attach(mp_so, p); in mptcp_usr_attach()
134 if ((mp_so->so_options & SO_LINGER) && mp_so->so_linger == 0) { in mptcp_usr_attach()
135 mp_so->so_linger = (short)(TCP_LINGERTIME * hz); in mptcp_usr_attach()
145 mptcp_usr_detach(struct socket *mp_so) in mptcp_usr_detach() argument
147 struct mptses *__single mpte = mpsotompte(mp_so); in mptcp_usr_detach()
148 struct mppcb *__single mpp = mpsotomppcb(mp_so); in mptcp_usr_detach()
163 mp_pcbdetach(mp_so); in mptcp_usr_detach()
175 mptcp_attach(struct socket *mp_so, struct proc *p) in mptcp_attach() argument
[all …]
|
| H A D | mptcp.c | 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()
[all …]
|
| H A D | mp_pcb.c | 231 mp_pcbdetach(struct socket *mp_so) in mp_pcbdetach() argument
233 struct mppcb *mpp = mpsotomppcb(mp_so); in mp_pcbdetach()
244 struct socket *mp_so = mpp->mpp_socket; in mptcp_pcbdispose() local
275 sofreelastref(mp_so, 0); in mptcp_pcbdispose()
276 if (mp_so->so_rcv.sb_cc > 0 || mp_so->so_snd.sb_cc > 0) { in mptcp_pcbdispose()
281 sbrelease(&mp_so->so_rcv); in mptcp_pcbdispose()
282 sbrelease(&mp_so->so_snd); in mptcp_pcbdispose()
295 mp_getaddr_v4(struct socket *mp_so, struct sockaddr **nam, boolean_t peer) in mp_getaddr_v4() argument
297 struct mptses *mpte = mpsotompte(mp_so); in mp_getaddr_v4()
321 mp_getaddr_v6(struct socket *mp_so, struct sockaddr **nam, boolean_t peer) in mp_getaddr_v6() argument
[all …]
|
| H A D | mptcp_subr.c | 591 struct socket *mp_so = mptetoso(mpte); in mptcp_trigger_cell_bringup() local
593 if (!uuid_is_null(mpsotomppcb(mp_so)->necp_client_uuid)) { in mptcp_trigger_cell_bringup()
597 socket_unlock(mp_so, 0); in mptcp_trigger_cell_bringup()
598 err = necp_client_assert_bb_radio_manager(mpsotomppcb(mp_so)->necp_client_uuid, in mptcp_trigger_cell_bringup()
600 socket_lock(mp_so, 0); in mptcp_trigger_cell_bringup()
606 uuid_unparse_upper(mpsotomppcb(mp_so)->necp_client_uuid, uuidstr); in mptcp_trigger_cell_bringup()
1195 struct socket *mp_so = mpp->mpp_socket; in mptcp_create_subflows() local
1198 socket_lock(mp_so, 1); in mptcp_create_subflows()
1201 socket_unlock(mp_so, 1); in mptcp_create_subflows()
1205 VERIFY(mp_so->so_usecount > 0); in mptcp_create_subflows()
[all …]
|
| H A D | mp_pcb.h | 69 mpsotomppcb(struct socket *mp_so) in mpsotomppcb() argument
71 VERIFY(SOCK_DOM(mp_so) == PF_MULTIPATH); in mpsotomppcb()
72 return (struct mppcb *)mp_so->so_pcb; in mpsotomppcb()
118 extern int mp_getsockaddr(struct socket *mp_so, struct sockaddr **nam);
119 extern int mp_getpeeraddr(struct socket *mp_so, struct sockaddr **nam);
|
| H A D | tcp_timer.c | 629 struct socket *so, *mp_so = NULL; in tcp_garbage_collect() local
636 mp_so = mptetoso(tptomptp(tp)->mpt_mpte); in tcp_garbage_collect()
637 if (!socket_try_lock(mp_so)) { in tcp_garbage_collect()
638 mp_so = NULL; in tcp_garbage_collect()
642 if (mpsotomppcb(mp_so)->mpp_inside > 0) { in tcp_garbage_collect()
644 (unsigned long)VM_KERNEL_ADDRPERM(mpsotompte(mp_so)), in tcp_garbage_collect()
645 mpsotomppcb(mp_so)->mpp_inside, in tcp_garbage_collect()
646 mp_so->so_usecount); in tcp_garbage_collect()
647 socket_unlock(mp_so, 0); in tcp_garbage_collect()
648 mp_so = NULL; in tcp_garbage_collect()
[all …]
|
| H A D | mptcp_opt.c | 1096 struct socket *mp_so = mptetoso(mp_tp->mpt_mpte); in mptcp_data_ack_rcvd() local
1098 if (acked > mp_so->so_snd.sb_cc) { in mptcp_data_ack_rcvd()
1099 if (acked > mp_so->so_snd.sb_cc + 1 || in mptcp_data_ack_rcvd()
1103 (uint32_t)acked, mp_so->so_snd.sb_cc, in mptcp_data_ack_rcvd()
1108 sbdrop(&mp_so->so_snd, (int)mp_so->so_snd.sb_cc); in mptcp_data_ack_rcvd()
1110 sbdrop(&mp_so->so_snd, (int)acked); in mptcp_data_ack_rcvd()
1127 sowwakeup(mp_so); in mptcp_data_ack_rcvd()
|
| H A D | tcp_subr.c | 3403 struct socket *mp_so = mptetoso(mp_tp->mpt_mpte); in tcp_lock() local
3405 socket_lock(mp_so, refcount); in tcp_lock()
3412 socket_unlock(mp_so, refcount); in tcp_lock()
3479 struct socket *mp_so = mptetoso(mp_tp->mpt_mpte); in tcp_unlock() local
3481 socket_lock_assert_owned(mp_so); in tcp_unlock()
3483 socket_unlock(mp_so, refcount); in tcp_unlock()
3506 struct socket *mp_so = mptetoso(mp_tp->mpt_mpte); in tcp_getlock() local
3508 return mp_so->so_proto->pr_getlock(mp_so, flags); in tcp_getlock()
|
| H A D | mptcp_var.h | 638 extern void mptcp_set_restrictions(struct socket *mp_so);
|
| H A D | tcp_output.c | 1726 struct socket *mp_so = mptetoso(mp_tp->mpt_mpte); in tcp_output() local
1728 if (recwin < (int32_t)(mp_so->so_rcv.sb_hiwat / 4) && in tcp_output()
|