| /xnu-12377.1.9/bsd/netinet/ |
| H A D | mp_pcb.c | 201 struct mppcb *mpp = NULL; in mp_pcballoc() local
206 mpp = mppi->mppi_alloc(); in mp_pcballoc()
207 lck_mtx_init(&mpp->mpp_lock, mppi->mppi_lock_grp, &mppi->mppi_lock_attr); in mp_pcballoc()
208 mpp->mpp_pcbinfo = mppi; in mp_pcballoc()
209 mpp->mpp_state = MPPCB_STATE_INUSE; in mp_pcballoc()
210 mpp->mpp_socket = so; in mp_pcballoc()
211 so->so_pcb = mpp; in mp_pcballoc()
213 error = mptcp_session_create(mpp); in mp_pcballoc()
215 lck_mtx_destroy(&mpp->mpp_lock, mppi->mppi_lock_grp); in mp_pcballoc()
216 mppi->mppi_free(mpp); in mp_pcballoc()
[all …]
|
| H A D | mp_pcb.h | 88 mptcp_should_defer_upcall(struct mppcb *mpp) in mptcp_should_defer_upcall() argument
90 …return !!(mpp->mpp_flags & (MPP_INSIDE_OUTPUT | MPP_INSIDE_INPUT | MPP_INPUT_HANDLE | MPP_WUPCALL)… in mptcp_should_defer_upcall()
117 extern void mptcp_handle_deferred_upcalls(struct mppcb *mpp, uint32_t flag);
121 extern int necp_client_register_multipath_cb(pid_t pid, uuid_t client_id, struct mppcb *mpp);
122 extern void necp_mppcb_dispose(struct mppcb *mpp);
|
| H A D | mptcp_usrreq.c | 148 struct mppcb *__single mpp = mpsotomppcb(mp_so); in mptcp_usr_detach() local
150 if (mpp == NULL || mpp->mpp_state == MPPCB_STATE_DEAD) { in mptcp_usr_detach()
153 mpp ? mpp->mpp_state : -1); in mptcp_usr_detach()
180 struct mppcb *__single mpp = NULL; in mptcp_attach() local
212 mpp = mpsotomppcb(mp_so); in mptcp_attach()
213 mpte = (struct mptses *)mpp->mpp_pcbe; in mptcp_attach()
294 struct mppcb *mpp = mpsotomppcb(mp_so); in mptcp_usr_connectx() local
300 if (mpp == NULL || mpp->mpp_state == MPPCB_STATE_DEAD) { in mptcp_usr_connectx()
303 mpp ? mpp->mpp_state : -1); in mptcp_usr_connectx()
307 mpte = mptompte(mpp); in mptcp_usr_connectx()
[all …]
|
| H A D | mptcp_subr.c | 262 mptcp_session_create(struct mppcb *mpp) in mptcp_session_create() argument
269 VERIFY(mpp != NULL); in mptcp_session_create()
270 mppi = mpp->mpp_pcbinfo; in mptcp_session_create()
273 mtp = __container_of(mpp, struct mpp_mtp, mpp); in mptcp_session_create()
279 VERIFY(mpp->mpp_pcbe == NULL); in mptcp_session_create()
280 mpp->mpp_pcbe = mpte; in mptcp_session_create()
281 mpte->mpte_mppcb = mpp; in mptcp_session_create()
305 DTRACE_MPTCP1(session__create, struct mppcb *, mpp); in mptcp_session_create()
1180 struct mppcb *mpp; in mptcp_create_subflows() local
1194 TAILQ_FOREACH(mpp, &mtcbinfo.mppi_pcbs, mpp_entry) { in mptcp_create_subflows()
[all …]
|
| H A D | mptcp_timer.c | 133 struct mppcb *mpp, *tmpp; in mptcp_timer() local
142 TAILQ_FOREACH_SAFE(mpp, &mppi->mppi_pcbs, mpp_entry, tmpp) { in mptcp_timer()
146 mp_so = mpp->mpp_socket; in mptcp_timer()
147 mpte = mptompte(mpp); in mptcp_timer()
150 VERIFY(mpp->mpp_flags & MPP_ATTACHED); in mptcp_timer()
|
| H A D | mptcp.c | 1268 mptcp_handle_deferred_upcalls(struct mppcb *mpp, uint32_t flag) in mptcp_handle_deferred_upcalls() argument
1270 VERIFY(mpp->mpp_flags & flag); in mptcp_handle_deferred_upcalls()
1271 mpp->mpp_flags &= ~flag; in mptcp_handle_deferred_upcalls()
1273 if (mptcp_should_defer_upcall(mpp)) { in mptcp_handle_deferred_upcalls()
1277 if (mpp->mpp_flags & MPP_SHOULD_WORKLOOP) { in mptcp_handle_deferred_upcalls()
1278 mpp->mpp_flags &= ~MPP_SHOULD_WORKLOOP; in mptcp_handle_deferred_upcalls()
1280 mptcp_subflow_workloop(mpp->mpp_pcbe); in mptcp_handle_deferred_upcalls()
1283 if (mpp->mpp_flags & MPP_SHOULD_RWAKEUP) { in mptcp_handle_deferred_upcalls()
1284 mpp->mpp_flags &= ~MPP_SHOULD_RWAKEUP; in mptcp_handle_deferred_upcalls()
1286 sorwakeup(mpp->mpp_socket); in mptcp_handle_deferred_upcalls()
[all …]
|
| H A D | mptcp_var.h | 468 struct mppcb mpp; /* Multipath PCB */ member
|
| /xnu-12377.1.9/bsd/sys/ |
| H A D | mount_internal.h | 442 errno_t vfs_rootmountalloc(const char *, const char *, mount_t *mpp);
|
| /xnu-12377.1.9/bsd/net/ |
| H A D | necp_client.c | 3801 struct mppcb *mpp) in necp_client_add_multipath_interface_flows() argument
3803 flow_registration->interface_handle = mpp; in necp_client_add_multipath_interface_flows()
3804 flow_registration->interface_cb = mpp->necp_cb; in necp_client_add_multipath_interface_flows()
3819 necp_client_register_multipath_cb(pid_t pid, uuid_t client_id, struct mppcb *mpp) in necp_client_register_multipath_cb() argument
3835 necp_client_add_multipath_interface_flows(flow_registration, client, mpp); in necp_client_register_multipath_cb()
3844 necp_client_add_multipath_interface_flows(flow_registration, client, mpp); in necp_client_register_multipath_cb()
12495 necp_mppcb_dispose(struct mppcb *mpp) in necp_mppcb_dispose() argument
12499 if (!uuid_is_null(mpp->necp_client_uuid)) { in necp_mppcb_dispose()
12500 necp_client_unregister_multipath_cb(mpp->necp_client_uuid, mpp); in necp_mppcb_dispose()
12501 uuid_clear(mpp->necp_client_uuid); in necp_mppcb_dispose()
[all …]
|
| /xnu-12377.1.9/bsd/netinet6/ |
| H A D | ipsec.c | 4861 struct mbuf *n, **mpp, *mnew; in ipsec_copypkt() local
4863 for (n = m, mpp = &m; n; n = n->m_next) { in ipsec_copypkt()
4941 *mpp = mnew; in ipsec_copypkt()
4942 mpp = &n->m_next; in ipsec_copypkt()
4947 *mpp = n; in ipsec_copypkt()
4948 mpp = &n->m_next; in ipsec_copypkt()
|
| /xnu-12377.1.9/bsd/vfs/ |
| H A D | vfs_subr.c | 1169 vfs_rootmountalloc(const char *fstypename, const char *devname, mount_t *mpp) in vfs_rootmountalloc() argument
1183 *mpp = vfs_rootmountalloc_internal(vfsp, devname); in vfs_rootmountalloc()
1185 if (*mpp) { in vfs_rootmountalloc()
|