| /xnu-11215/bsd/kern/ |
| H A D | uipc_socket.c | 753 so->so_rcv.sb_so = so->so_snd.sb_so = so; in socreate_internal() 2190 so->so_snd.sb_cc, so->so_snd.sb_lowat, so->so_snd.sb_hiwat); in sosend() 2727 so->so_snd.sb_cc, so->so_snd.sb_lowat, so->so_snd.sb_hiwat); in sosend_list() 4024 so, so->so_usecount); in soreceive() 4982 &so->so_snd : &so->so_rcv; in sosetoptlock() 7337 SOCK_DOM(so), so->so_type, in socket_unlock() 7522 so->so_gencnt, SOCK_DOM(so), in sosetdefunct() 7580 SOCK_DOM(so), SOCK_TYPE(so), in sodefunct() 7736 SOCK_DOM(so), SOCK_TYPE(so), in so_set_extended_bk_idle() 8111 so->e_upid = so->last_upid; in so_set_effective_uuid() [all …]
|
| H A D | sys_socket.c | 177 socket_lock(so, 1); in soioctl() 255 error = (*so->so_proto->pr_usrreqs->pru_control)(so, in soioctl() 271 error = (*so->so_proto->pr_usrreqs->pru_control)(so, in soioctl() 307 if (so == NULL || so == (struct socket *)-1) { in soo_select() 337 if (so->so_oobmark || (so->so_state & SS_RCVATMARK)) { in soo_select() 385 sb64->st_size = so->so_rcv.sb_cc - so->so_rcv.sb_ctl; in soo_stat() 397 sb->st_size = so->so_rcv.sb_cc - so->so_rcv.sb_ctl; in soo_stat() 402 ret = (*so->so_proto->pr_usrreqs->pru_sense)(so, ub, isstat64); in soo_stat() 430 if (so) { in soo_drain() 435 sorwakeup(so); in soo_drain() [all …]
|
| H A D | uipc_socket2.c | 404 so->so_rcv.sb_so = so->so_snd.sb_so = so; in sonewconn_internal() 562 SOCK_DOM(so), SOCK_TYPE(so), error); in sbwait() 602 SOCK_DOM(so), SOCK_TYPE(so), error); in sbwait() 629 so->so_gencnt, SOCK_DOM(so), in sowakeup() 779 so->so_snd.sb_lowat = so->so_snd.sb_hiwat; in soreserve() 2691 sowakeup(so, &so->so_rcv, NULL); in sorwakeup() 2699 sowakeup(so, &so->so_snd, NULL); in sowwakeup() 2711 so->so_event(so, so_eventarg, hint); in soevupcall() 2778 so->so_gencnt, SOCK_DOM(so), in soevent_ifdenied() 2790 so->last_pid, so->so_gencnt, in soevent_ifdenied() [all …]
|
| H A D | kpi_socketfilter.c | 445 if (SOCK_DOM(so) != PF_INET && SOCK_DOM(so) != PF_INET6) { in sflt_initsock() 625 if (so->so_filt == NULL || sflt_permission_check(sotoinpcb(so))) { in sflt_ioctl() 675 if (so->so_filt == NULL || sflt_permission_check(sotoinpcb(so))) { in sflt_bind() 725 if (so->so_filt == NULL || sflt_permission_check(sotoinpcb(so))) { in sflt_listen() 1440 if (so == NULL || (so->so_state & SS_DEFUNCT) || in sflt_register_common() 1458 if (so == NULL || (so->so_state & SS_DEFUNCT) || in sflt_register_common() 1479 so = solisthead->so; in sflt_register_common() 1616 sorwakeup(so); in sock_inject_data_in() 1623 sorwakeup(so); in sock_inject_data_in() 1634 sorwakeup(so); in sock_inject_data_in() [all …]
|
| H A D | vsock_domain.c | 44 #define sotovsockpcb(so) ((struct vsockpcb *)(so)->so_pcb) argument 221 struct socket *so = pcb->so; in vsock_unbind_pcb_locked() local 686 struct socket *so = pcb->so; in vsock_put_message() local 696 sowwakeup(so); in vsock_put_message() 809 if (pcb->so) { 890 pcb->so = so; in vsock_attach() 932 if (so) { in vsock_control() 1461 so->unlock_lr[so->next_unlock_lr] = lr_saved; in vsock_unlock() 1467 "lrh=%s", __func__, so->so_usecount, so, in vsock_unlock() 1468 SOCK_DOM(so), so->so_type, in vsock_unlock() [all …]
|
| H A D | uipc_usrreq.c | 264 sofree(so); in uipc_abort() 623 so->so_state, so->so_flags, so->so_flags1); in uipc_send() 989 if (so->so_snd.sb_hiwat == 0 || so->so_rcv.sb_hiwat == 0) { in unp_attach() 1643 waitso = so; in unp_disconnect() 1656 waitso = so; in unp_disconnect() 2742 if (so) { in unp_gc() 2853 so, lr_saved, so->so_usecount); in unp_lock() 2858 so, so->so_pcb, lr_saved, so->so_usecount); in unp_lock() 2865 so->lock_lr[so->next_lock_lr] = lr_saved; in unp_lock() 2866 so->next_lock_lr = (so->next_lock_lr + 1) % SO_LCKDBG_MAX; in unp_lock() [all …]
|
| H A D | socket_info.c | 77 si->soi_type = so->so_type; in fill_common_sockinfo() 80 si->soi_state = so->so_state; in fill_common_sockinfo() 82 if (so->so_proto) { in fill_common_sockinfo() 92 si->soi_qlen = so->so_qlen; in fill_common_sockinfo() 95 si->soi_timeo = so->so_timeo; in fill_common_sockinfo() 110 socket_lock(so, 0); in fill_socketinfo() 116 if (so->so_pcb == NULL || so->so_proto == 0 || in fill_socketinfo() 125 domain = SOCK_DOM(so); in fill_socketinfo() 126 type = SOCK_TYPE(so); in fill_socketinfo() 127 protocol = SOCK_PROTO(so); in fill_socketinfo() [all …]
|
| H A D | kern_control.c | 308 kcb->so = so; in ctl_attach() 1023 so->so_rcv.sb_hiwat, so->so_rcv.sb_cc); in ctl_enqueuembuf() 1136 so->so_rcv.sb_hiwat, so->so_rcv.sb_cc); in ctl_enqueuembuf_list() 1237 so->so_rcv.sb_hiwat, so->so_rcv.sb_cc); in ctl_enqueuedata() 2052 so, lr_saved, solockhistory_nr(so)); in ctl_lock() 2058 so, so->so_pcb, lr_saved, so->so_usecount, in ctl_lock() 2067 so->lock_lr[so->next_lock_lr] = lr_saved; in ctl_lock() 2097 so, so->so_usecount, solockhistory_nr(so)); in ctl_unlock() 2102 so, so->so_usecount, (void *)lr_saved, in ctl_unlock() 2129 so, so->so_usecount, solockhistory_nr(so)); [all …]
|
| H A D | socket_flows.c | 115 …so ? SOFLOW_SOCKET_PID(so) : 0, so ? (uint64_t)VM_KERNEL_ADDRPERM(so) : 0, ##__VA_ARGS__); … 118 …so ? SOFLOW_SOCKET_PID(so) : 0, so ? (uint64_t)VM_KERNEL_ADDRPERM(so) : 0, ##__VA_ARGS__); … 132 #define SOFLOW_IS_UDP(so) (so && SOCK_CHECK_TYPE(so, SOCK_DGRAM) && SOCK_CHECK_PROTO(so, IPPROTO_UD… argument 133 #define SOFLOW_GET_SO_PROTO(so) (so ? SOCK_PROTO(so) : IPPROTO_MAX) argument 135 #define SOFLOW_SOCKET_PID(so) ((so->so_flags & SOF_DELEGATED) ? so->e_pid : so->last_pid) argument 506 if (so == NULL || so->so_flow_db == NULL) { in soflow_detach() 948 struct inpcb *inp = so ? sotoinpcb(so) : NULL; in soflow_nstat_provider_request_vals() 1069 struct inpcb *inp = so ? sotoinpcb(so) : NULL; in soflow_nstat_provider_request_extensions() 1099 so->so_flags & SOF_DELEGATED ? so->e_pid : so->last_pid, in soflow_nstat_provider_request_extensions() 1286 if (so) { in soflow_socket_safe_lock() [all …]
|
| H A D | uipc_syscalls.c | 278 socket_ref_t so; in socket_common() local 350 socket_ref_t so; in bind() local 418 if (so != NULL) in listen() 599 soclose(so); in accept_nocancel() 631 soclose(so); in accept_nocancel() 1904 if (so->so_type == SOCK_DGRAM && sosendallatonce(so) && in sendmsg_x() 2042 if (so != NULL && (SOCK_DOM(so) == PF_INET6 || SOCK_DOM(so) == PF_INET)) { in copyout_control() 2605 error = so->so_proto->pr_usrreqs->pru_soreceive(so, psa, in recvmsg_x_array() 4028 if ((so->so_state & SS_CANTSENDMORE) || so->so_error) { in sendfile() 4043 if (sbspace(&so->so_snd) < (long)so->so_snd.sb_lowat) { in sendfile() [all …]
|
| /xnu-11215/bsd/net/ |
| H A D | raw_usrreq.c | 168 raw_uabort(struct socket *so) in raw_uabort() argument 174 mutex_held = (*so->so_proto->pr_getlock)(so, 0); in raw_uabort() 184 sofree(so); in raw_uabort() 185 soisdisconnected(so); in raw_uabort() 202 return raw_attach(so, proto); in raw_uattach() 227 mutex_held = (*so->so_proto->pr_getlock)(so, 0); in raw_udetach() 253 soisdisconnected(so); in raw_udisconnect() 286 mutex_held = (*so->so_proto->pr_getlock)(so, 0); in raw_usend() 323 error = (*so->so_proto->pr_output)(m, so); in raw_usend() 343 mutex_held = (*so->so_proto->pr_getlock)(so, 0); in raw_ushutdown() [all …]
|
| H A D | content_filter.c | 564 #define IS_ICMP(so) (so && (SOCK_CHECK_TYPE(so, SOCK_RAW) || SOCK_CHECK_TYPE(so, SOCK_DGRAM)) && \ argument 566 #define IS_RAW(so) (so && SOCK_CHECK_TYPE(so, SOCK_RAW) && SOCK_CHECK_PROTO(so, IPPROTO_RAW)) argument 568 #define OPTIONAL_IP_HEADER(so) (!IS_TCP(so) && !IS_UDP(so)) argument 569 #define GET_SO_PROTOCOL(so) (so ? SOCK_PROTO(so) : IPPROTO_IP) argument 570 #define GET_SO_INP_PROTOCOL(so) ((so && sotoinpcb(so)) ? sotoinpcb(so)->inp_ip_p : IPPROTO_IP) argument 571 #define GET_SO_PROTO(so) ((GET_SO_PROTOCOL(so) != IPPROTO_IP) ? GET_SO_PROTOCOL(so) : GET_SO_INP_PR… argument 579 #define IS_INITIAL_TFO_DATA(so) (so && (so->so_flags1 & SOF1_PRECONNECT_DATA) && (so->so_state & SS… argument 617 #define SOCKET_PID(so) ((so->so_flags & SOF_DELEGATED) ? so->e_pid : so->last_pid) argument 618 #define MATCH_PID(so) (so && (cfil_log_pid == SOCKET_PID(so))) argument 2942 if (so == NULL || !IS_TCP(so)) { in cfil_sock_tcp_add_time_wait() [all …]
|
| H A D | kext_net.h | 54 extern void sflt_initsock(struct socket *so); 55 extern void sflt_termsock(struct socket *so); 59 extern int sflt_bind(struct socket *so, const struct sockaddr *nam); 60 extern int sflt_listen(struct socket *so); 61 extern int sflt_accept(struct socket *head, struct socket *so, 64 extern int sflt_getsockname(struct socket *so, struct sockaddr **local); 65 extern int sflt_getpeername(struct socket *so, struct sockaddr **remote); 69 extern int sflt_setsockopt(struct socket *so, struct sockopt *sopt); 70 extern int sflt_getsockopt(struct socket *so, struct sockopt *sopt); 71 extern int sflt_data_out(struct socket *so, const struct sockaddr *to, [all …]
|
| H A D | raw_cb.c | 93 raw_attach(struct socket *so, int proto) in raw_attach() argument 95 struct rawcb *rp = sotorawcb(so); in raw_attach() 110 rp->rcb_socket = so; in raw_attach() 126 struct socket *so = rp->rcb_socket; in raw_detach_nofree() local 128 so->so_pcb = 0; in raw_detach_nofree() 129 so->so_flags |= SOF_PCBCLEARING; in raw_detach_nofree() 130 sofree(so); in raw_detach_nofree() 132 socket_unlock(so, 0); in raw_detach_nofree() 134 socket_lock(so, 0); in raw_detach_nofree() 147 struct socket *so = rp->rcb_socket; in raw_disconnect() local [all …]
|
| H A D | ndrv.c | 162 socket_unlock(so, 0); in ndrv_output() 170 socket_lock(so, 0); in ndrv_output() 183 struct socket *so; in ndrv_input() local 222 so = np->nd_socket; in ndrv_input() 226 sorwakeup(so); in ndrv_input() 262 np->nd_socket = so; in ndrv_attach() 333 soisconnected(so); in ndrv_connect() 456 socantsendmore(so); in ndrv_shutdown() 629 so->so_pcb = 0; in ndrv_do_detach() 631 sofree(so); in ndrv_do_detach() [all …]
|
| /xnu-11215/bsd/sys/ |
| H A D | kpi_socket.h | 137 extern errno_t sock_bind(socket_t so, const struct sockaddr *to) 296 extern errno_t sock_listen(socket_t so, int backlog) 402 extern errno_t sock_shutdown(socket_t so, int how) 440 extern void sock_close(socket_t so) 453 extern void sock_retain(socket_t so) 464 extern void sock_release(socket_t so) 475 extern errno_t sock_setpriv(socket_t so, int on) 484 extern int sock_isconnected(socket_t so) 498 extern int sock_isnonblocking(socket_t so) 525 extern errno_t sock_nointerrupt(socket_t so, int on); [all …]
|
| H A D | socketvar.h | 716 #define SOCK_DOM(so) ((so)->so_family) argument 717 #define SOCK_TYPE(so) ((so)->so_type) argument 718 #define SOCK_PROTO(so) ((so)->so_protocol) argument 720 #define SOCK_CHECK_DOM(so, dom) (SOCK_DOM(so) == (dom)) argument 721 #define SOCK_CHECK_TYPE(so, type) (SOCK_TYPE(so) == (type)) argument 1029 #define IS_INET(so) (so != NULL && (SOCK_CHECK_DOM(so, AF_INET) || SOCK_CHECK_DOM(so, AF_INET6))) argument 1030 #define IS_TCP(so) (so != NULL && SOCK_CHECK_TYPE(so, SOCK_STREAM) && SOCK_CHECK_PROTO(so, IPPROTO_… argument 1031 #define IS_UDP(so) (so != NULL && SOCK_CHECK_TYPE(so, SOCK_DGRAM) && SOCK_CHECK_PROTO(so, IPPROTO_U… argument 1036 #define NEED_DGRAM_FLOW_TRACKING(so) (IS_INET(so) && IS_UDP(so)) argument 1038 #define NEED_DGRAM_FLOW_TRACKING(so) (IS_INET(so) && !IS_TCP(so)) argument [all …]
|
| H A D | protosw.h | 182 (struct mbuf *m, struct socket *so); 206 (struct socket *so, int refcnt, void *debug); 208 (struct socket *so, int refcnt, void *debug); 210 (struct socket *so, int flags); 268 (struct mbuf *m, struct socket *so); 286 (struct socket *so, int refcnt, void *debug); 290 (struct socket *so, int flags); 301 (struct socket *so, struct socket *head); 464 int (*pru_abort)(struct socket *so); 474 int (*pru_detach)(struct socket *so); [all …]
|
| /xnu-11215/security/ |
| H A D | mac_socket.c | 100 (socket_t)so, NULL); in mac_socket_check_accept() 143 (socket_t)so, NULL, sockaddr); in mac_socket_check_bind() 161 (socket_t)so, NULL, in mac_socket_check_connect() 195 (socket_t)so, cmd, NULL); in mac_socket_check_ioctl() 212 (socket_t)so, NULL); in mac_socket_check_stat() 229 (socket_t)so, NULL); in mac_socket_check_listen() 246 (socket_t)so, NULL); in mac_socket_check_receive() 263 so, NULL, saddr); in mac_socket_check_received() 281 (socket_t)so, NULL, sockaddr); in mac_socket_check_send() 299 (socket_t)so, NULL, sopt); in mac_socket_check_setsockopt() [all …]
|
| /xnu-11215/bsd/netkey/ |
| H A D | keysock.c | 124 struct socket *so; local 136 socket_unlock(so, 0); 189 socket_lock(so, 0); 307 if (so && sotorawcb(so) == rp) { in key_sendup_mbuf() 356 if (so) { in key_sendup_mbuf() 357 socket_lock(so, 1); in key_sendup_mbuf() 359 socket_unlock(so, 1); in key_sendup_mbuf() 414 soisconnected(so); in key_attach() 461 socket_unlock(so, 0); in key_detach() 462 key_freereg(so); in key_detach() [all …]
|
| /xnu-11215/bsd/netinet/ |
| H A D | in_pcblist.c | 117 if (so == NULL) { in sotoxsocket_n() 127 if (so->so_proto) { in sotoxsocket_n() 193 if (so == NULL) { in sbtoxsockstat_n() 491 struct socket *so; in inpcb_get_if_ports_used() local 794 soevent(so, in inpcb_count_opportunistic() 799 soevent(so, in inpcb_count_opportunistic() 806 SOCK_DOM(so), SOCK_TYPE(so), in inpcb_count_opportunistic() 839 af = SOCK_DOM(so); in inpcb_find_anypcb_byaddr() 880 struct socket *so; in shutdown_sockets_on_interface_proc_callout() local 890 if (SOCK_DOM(so) != PF_INET && SOCK_DOM(so) != PF_INET6) { in shutdown_sockets_on_interface_proc_callout() [all …]
|
| H A D | tcp_usrreq.c | 171 if ((so->so_options & SO_LINGER) && so->so_linger == 0) { in tcp_usr_attach() 178 tp = sototcpcb(so); in tcp_usr_attach() 290 socket_lock(so, 0); in tcp_usr_bind() 646 so->so_error = 0; in tcp_usr_connect() 750 error = so->so_proto->pr_usrreqs->pru_sosend(so, NULL, in tcp_usr_connectx_common() 805 so->so_error = 0; in tcp6_usr_connect() 1116 so->last_pid, in mpkl_tcp_send() 1348 so->so_usecount--; in tcp_usr_abort() 1938 struct socket *so; in tcp_fill_info_for_info_tuple() local 3088 if (so->so_snd.sb_hiwat == 0 || so->so_rcv.sb_hiwat == 0) { in tcp_attach() [all …]
|
| H A D | in_pcb.c | 1413 if (so && (so->so_options & SO_NOAPNFALLBK)) { in apn_fallback_required() 2011 inp, so, SOCK_PROTO(so)); in in_pcbdetach() 2044 __func__, so, SOCK_PROTO(so)); in in_pcbdetach() 2115 if (so != NULL && so->so_usecount != 0) { in in_pcbdispose() 2117 __func__, so, SOCK_DOM(so), SOCK_TYPE(so), so->so_usecount, in in_pcbdispose() 2125 inp->inp_wantcnt, so, SOCK_DOM(so), SOCK_TYPE(so), in in_pcbdispose() 2126 so->so_usecount, so->so_retaincnt, so->so_state, in in_pcbdispose() 2127 so->so_flags, solockhistory_nr(so)); in in_pcbdispose() 3877 so->so_gencnt, SOCK_DOM(so), in inp_update_cellular_policy() 3919 so->so_gencnt, SOCK_DOM(so), in inp_update_necp_want_app_policy() [all …]
|
| H A D | flow_divert.c | 382 new_pcb->so = so; in flow_divert_pcb_create() 2230 so = fd_cb->so; in flow_divert_disable() 2231 if (so == NULL) { in flow_divert_disable() 2258 fd_cb->so = NULL; in flow_divert_disable() 2263 so->so_proto = pffindproto(SOCK_DOM(so), SOCK_PROTO(so), SOCK_TYPE(so)); in flow_divert_disable() 2302 error = (*so->so_proto->pr_usrreqs->pru_send)(so, in flow_divert_disable() 2386 error = (*so->so_proto->pr_usrreqs->pru_send)(so, in flow_divert_disable() 2422 so = fd_cb->so; in flow_divert_scope() 2423 if (so == NULL) { in flow_divert_scope() 2550 struct socket *so = fd_cb->so; in flow_divert_handle_connect_result() local [all …]
|
| /xnu-11215/bsd/netinet6/ |
| H A D | in6_pcb.c | 167 socket_lock(so, 0); in in6_pcblookup_local_and_cleanup() 220 socket_lock(so, 0); in in6_pcbbind() 229 socket_lock(so, 0); in in6_pcbbind() 238 socket_lock(so, 0); in in6_pcbbind() 250 socket_lock(so, 0); in in6_pcbbind() 534 socket_lock(so, 0); in in6_pcbbind() 754 soevent(so, in in6_pcbconnect() 773 socket_lock(so, 0); in in6_pcbconnect() 833 if (so) { in in6_pcbdisconnect() 871 inp, so, SOCK_PROTO(so)); in in6_pcbdetach() [all …]
|