| /f-stack/freebsd/kern/ |
| H A D | uipc_socket.c | 422 so->so_rcv.sb_sel = &so->so_rdsel; in soalloc() 423 so->so_snd.sb_sel = &so->so_wrsel; in soalloc() 937 sbdestroy(&so->so_snd, so); 938 sbdestroy(&so->so_rcv, so); 958 so->sol_qlen = so->sol_incqlen = 0; 1136 so->so_dtor(so); 1159 sbdestroy(&so->so_snd, so); 1160 sbdestroy(&so->so_rcv, so); 1214 (*so->so_proto->pr_usrreqs->pru_close)(so); 1224 so->sol_qlen = so->sol_incqlen = 0; [all …]
|
| H A D | sys_socket.c | 235 if ((so->so_snd.sb_hiwat < sbused(&so->so_snd)) || in soo_ioctl() 236 (so->so_snd.sb_mbmax < so->so_snd.sb_mbcnt)) { in soo_ioctl() 343 error = so->so_proto->pr_usrreqs->pru_sense(so, ub); in soo_stat() 364 if (so) in soo_close() 420 error = so->so_proto->pr_usrreqs->pru_sockaddr(so, &sa); in soo_fill_kinfo() 426 error = so->so_proto->pr_usrreqs->pru_peeraddr(so, &sa); in soo_fill_kinfo() 599 return (sb == &so->so_rcv ? soreadable(so) : sowriteable(so)); in soaio_ready() 738 sorele(so); in soaio_process_sb() 748 soaio_process_sb(so, &so->so_rcv); in soaio_rcv() 757 soaio_process_sb(so, &so->so_snd); in soaio_snd() [all …]
|
| H A D | uipc_accf.c | 174 SOCK_LOCK(so); in accept_filt_getopt() 187 SOCK_UNLOCK(so); in accept_filt_getopt() 210 SOCK_LOCK(so); in accept_filt_setopt() 212 SOCK_UNLOCK(so); in accept_filt_setopt() 216 SOCK_UNLOCK(so); in accept_filt_setopt() 220 so->sol_accept_filter->accf_destroy(so); in accept_filt_setopt() 240 so->sol_incqlen--; in accept_filt_setopt() 241 so->sol_qlen++; in accept_filt_setopt() 249 SOLISTEN_UNLOCK(so); in accept_filt_setopt() 280 SOCK_LOCK(so); in accept_filt_setopt() [all …]
|
| H A D | uipc_debug.c | 442 db_print_sotype(so->so_type); in db_print_socket() 447 db_print_sooptions(so->so_options); in db_print_socket() 453 db_print_sostate(so->so_state); in db_print_socket() 457 db_printf("so_pcb: %p ", so->so_pcb); in db_print_socket() 460 if (so->so_proto != NULL) in db_print_socket() 464 if (so->so_options & SO_ACCEPTCONN) { in db_print_socket() 466 TAILQ_FIRST(&so->sol_incomp)); in db_print_socket() 473 db_print_soqstate(so->so_qstate); in db_print_socket() 491 struct socket *so; in DB_SHOW_COMMAND() local 497 so = (struct socket *)addr; in DB_SHOW_COMMAND() [all …]
|
| H A D | uipc_ktls.c | 756 inp = so->so_pcb; in ktls_try_toe() 1141 inp = so->so_pcb; in ktls_enable_tx() 1166 inp = so->so_pcb; in ktls_get_rx_mode() 1645 soref(so); in ktls_check_rx() 1801 so->so_proto->pr_usrreqs->pru_abort(so); in ktls_decrypt() 1930 SOCK_LOCK(so); in ktls_decrypt() 1931 sorele(so); in ktls_decrypt() 2119 (void)(*so->so_proto->pr_usrreqs->pru_ready)(so, top, npages); in ktls_encrypt() 2121 so->so_proto->pr_usrreqs->pru_abort(so); in ktls_encrypt() 2126 SOCK_LOCK(so); in ktls_encrypt() [all …]
|
| H A D | uipc_usrreq.c | 525 if (so->so_snd.sb_hiwat == 0 || so->so_rcv.sb_hiwat == 0) { in uipc_attach() 795 SOCK_LOCK(so); in uipc_detach() 803 sbrelease(&so->so_rcv, so); in uipc_detach() 805 SOCK_UNLOCK(so); in uipc_detach() 903 SOCK_LOCK(so); in uipc_listen() 1191 SOCK_LOCK(so); in uipc_ready_scan() 1757 if (so) { in unp_disconnect() 1766 if (so) in unp_disconnect() 1975 if (so) in unp_drop() 2613 SOCK_LOCK(so); in unp_gc_scan() [all …]
|
| H A D | kern_sendfile.c | 366 so = sfio->so; in sendfile_iodone() 380 so->so_proto->pr_usrreqs->pru_abort(so); in sendfile_iodone() 399 (void)(so->so_proto->pr_usrreqs->pru_ready)(so, sfio->m, in sendfile_iodone() 403 sorele(so); in sendfile_iodone() 653 *so = NULL; in sendfile_getsock() 702 so = NULL; in vn_sendfile() 784 if (so->so_snd.sb_lowat < so->so_snd.sb_hiwat / 2) in vn_sendfile() 785 so->so_snd.sb_lowat = so->so_snd.sb_hiwat / 2; in vn_sendfile() 1185 sfio->so = so; in vn_sendfile() 1187 soref(so); in vn_sendfile() [all …]
|
| /f-stack/freebsd/security/mac/ |
| H A D | mac_socket.c | 239 MAC_POLICY_PERFORM_NOSLEEP(socket_create, cred, so, so->so_label); in mac_socket_create() 257 MAC_POLICY_PERFORM_NOSLEEP(socket_relabel, cred, so, so->so_label, in mac_socket_relabel() 296 MAC_POLICY_PERFORM_NOSLEEP(socket_create_mbuf, so, so->so_label, m, in mac_socket_create_mbuf() 503 SOCK_LOCK(so); in mac_socket_label_set() 506 SOCK_UNLOCK(so); in mac_socket_label_set() 511 SOCK_UNLOCK(so); in mac_socket_label_set() 520 (so->so_proto->pr_usrreqs->pru_sosetlabel)(so); in mac_socket_label_set() 581 SOCK_LOCK(so); in mac_getsockopt_label() 583 SOCK_UNLOCK(so); in mac_getsockopt_label() 620 SOCK_LOCK(so); in mac_getsockopt_peerlabel() [all …]
|
| /f-stack/tools/compat/include/sys/ |
| H A D | socketvar.h | 224 #define SOCK_MTX(so) &(so)->so_lock argument 225 #define SOCK_LOCK(so) mtx_lock(&(so)->so_lock) argument 226 #define SOCK_OWNED(so) mtx_owned(&(so)->so_lock) argument 227 #define SOCK_UNLOCK(so) mtx_unlock(&(so)->so_lock) argument 228 #define SOCK_LOCK_ASSERT(so) mtx_assert(&(so)->so_lock, MA_OWNED) argument 272 (sbavail(&(so)->so_rcv) >= (so)->so_rcv.sb_lowat || (so)->so_error) 274 (soreadabledata(so) || ((so)->so_rcv.sb_state & SBS_CANTRCVMORE)) 278 ((sbspace(&(so)->so_snd) >= (so)->so_snd.sb_lowat && \ 291 #define soref(so) refcount_acquire(&(so)->so_count) argument 311 sowakeup((so), &(so)->so_rcv); \ [all …]
|
| H A D | protosw.h | 187 void (*pru_abort)(struct socket *so); 197 void (*pru_detach)(struct socket *so); 198 int (*pru_disconnect)(struct socket *so); 202 int (*pru_rcvd)(struct socket *so, int flags); 213 int (*pru_shutdown)(struct socket *so); 222 int (*pru_sopoll)(struct socket *so, int events, 224 void (*pru_sosetlabel)(struct socket *so); 225 void (*pru_close)(struct socket *so); 228 int (*pru_connectat)(int fd, struct socket *so, 250 int pru_disconnect_notsupp(struct socket *so); [all …]
|
| H A D | sockstate.h | 75 void soisconnected(struct socket *so); 76 void soisconnecting(struct socket *so); 77 void soisdisconnected(struct socket *so); 78 void soisdisconnecting(struct socket *so); 79 void socantrcvmore(struct socket *so); 80 void socantrcvmore_locked(struct socket *so); 81 void socantsendmore(struct socket *so); 82 void socantsendmore_locked(struct socket *so);
|
| /f-stack/freebsd/sys/ |
| H A D | socketvar.h | 224 #define SOCK_MTX(so) &(so)->so_lock argument 225 #define SOCK_LOCK(so) mtx_lock(&(so)->so_lock) argument 226 #define SOCK_OWNED(so) mtx_owned(&(so)->so_lock) argument 227 #define SOCK_UNLOCK(so) mtx_unlock(&(so)->so_lock) argument 228 #define SOCK_LOCK_ASSERT(so) mtx_assert(&(so)->so_lock, MA_OWNED) argument 272 (sbavail(&(so)->so_rcv) >= (so)->so_rcv.sb_lowat || (so)->so_error) 274 (soreadabledata(so) || ((so)->so_rcv.sb_state & SBS_CANTRCVMORE)) 278 ((sbspace(&(so)->so_snd) >= (so)->so_snd.sb_lowat && \ 291 #define soref(so) refcount_acquire(&(so)->so_count) argument 311 sowakeup((so), &(so)->so_rcv); \ [all …]
|
| H A D | protosw.h | 189 void (*pru_abort)(struct socket *so); 199 void (*pru_detach)(struct socket *so); 200 int (*pru_disconnect)(struct socket *so); 204 int (*pru_rcvd)(struct socket *so, int flags); 216 int (*pru_shutdown)(struct socket *so); 225 int (*pru_sopoll)(struct socket *so, int events, 227 void (*pru_sosetlabel)(struct socket *so); 228 void (*pru_close)(struct socket *so); 231 int (*pru_connectat)(int fd, struct socket *so, 253 int pru_disconnect_notsupp(struct socket *so); [all …]
|
| /f-stack/freebsd/net/ |
| H A D | raw_usrreq.c | 134 raw_uabort(struct socket *so) in raw_uabort() argument 139 soisdisconnected(so); in raw_uabort() 143 raw_uclose(struct socket *so) in raw_uclose() argument 148 soisdisconnected(so); in raw_uclose() 169 return (raw_attach(so, proto)); in raw_uattach() 190 raw_udetach(struct socket *so) in raw_udetach() argument 192 struct rawcb *rp = sotorawcb(so); in raw_udetach() 200 raw_udisconnect(struct socket *so) in raw_udisconnect() argument 241 return ((*so->so_proto->pr_output)(m, so)); in raw_usend() 247 raw_ushutdown(struct socket *so) in raw_ushutdown() argument [all …]
|
| H A D | raw_cb.c | 80 raw_attach(struct socket *so, int proto) in raw_attach() argument 82 struct rawcb *rp = sotorawcb(so); in raw_attach() 93 error = soreserve(so, raw_sendspace, raw_recvspace); in raw_attach() 96 rp->rcb_socket = so; in raw_attach() 97 rp->rcb_proto.sp_family = so->so_proto->pr_domain->dom_family; in raw_attach() 111 struct socket *so = rp->rcb_socket; in raw_detach() local 113 KASSERT(so->so_pcb == rp, ("raw_detach: so_pcb != rp")); in raw_detach() 115 so->so_pcb = NULL; in raw_detach()
|
| /f-stack/freebsd/netipsec/ |
| H A D | keysock.c | 130 error = key_parse(m, so); in key_output() 234 if (so && sotorawcb(so) == rp) in key_sendup_mbuf() 270 key_abort(struct socket *so) in key_abort() argument 272 raw_usrreqs.pru_abort(so); in key_abort() 298 so->so_pcb = (caddr_t)kp; in key_attach() 303 so->so_pcb = (caddr_t) 0; in key_attach() 312 soisconnected(so); in key_attach() 333 key_close(struct socket *so) in key_close() argument 336 raw_usrreqs.pru_close(so); in key_close() 364 key_freereg(so); in key_detach() [all …]
|
| /f-stack/app/redis-5.0.5/src/modules/ |
| H A D | Makefile | 14 .SUFFIXES: .c .so .xo .o 16 all: helloworld.so hellotype.so helloblock.so testmodule.so hellocluster.so hellotimer.so hellodict… 23 helloworld.so: helloworld.xo 28 hellotype.so: hellotype.xo 33 helloblock.so: helloblock.xo 38 hellocluster.so: hellocluster.xo 43 hellotimer.so: hellotimer.xo 48 hellodict.so: hellodict.xo 52 testmodule.so: testmodule.xo 56 rm -rf *.xo *.so
|
| /f-stack/freebsd/netgraph/ |
| H A D | ng_ksocket.c | 85 struct socket *so; member 606 struct socket *const so = priv->so; in ng_ksocket_connect() local 664 struct socket *const so = priv->so; in ng_ksocket_rcvmsg() local 683 if (so == NULL) in ng_ksocket_rcvmsg() 887 struct socket *const so = priv->so; in ng_ksocket_rcvdata() local 1033 KASSERT(so == priv->so, ("%s: wrong socket", __func__)); in ng_ksocket_incoming2() 1087 if ((error = soreceive(so, (so->so_state & SS_ISCONNECTED) ? in ng_ksocket_incoming2() 1195 soclose(so); in ng_ksocket_accept() 1205 soclose(so); in ng_ksocket_accept() 1212 soclose(so); in ng_ksocket_accept() [all …]
|
| H A D | ng_socket.c | 163 #define sotongpcb(so) ((struct ngpcb *)(so)->so_pcb) argument 506 pcbp = sotongpcb(so); in ng_getsockaddr() 553 pcbp = sotongpcb(so); in ng_attach_cntl() 615 pcbp->ng_socket = so; in ng_attach_common() 895 struct socket *so; in ngs_rcvmsg() local 923 so = pcbp->ng_socket; in ngs_rcvmsg() 924 SOCKBUF_LOCK(&so->so_rcv); in ngs_rcvmsg() 997 sorwakeup_locked(so); in ngs_rcvmsg() 1010 struct socket *so; in ngs_rcvdata() local 1024 so = pcbp->ng_socket; in ngs_rcvdata() [all …]
|
| /f-stack/freebsd/netinet/ |
| H A D | accf_http.c | 156 !sbfull(&so->so_rcv)) { in sohashttpget() 161 m = so->so_rcv.sb_mb; in sohashttpget() 162 cc = sbavail(&so->so_rcv) - 1; in sohashttpget() 205 if ((so->so_rcv.sb_state & SBS_CANTRCVMORE) != 0 || sbfull(&so->so_rcv)) in soparsehttpvers() 208 m = so->so_rcv.sb_mb; in soparsehttpvers() 209 cc = sbavail(&so->so_rcv); in soparsehttpvers() 211 for (m = so->so_rcv.sb_mb; m; m = n) { in soparsehttpvers() 252 return (soishttpconnected(so, in soparsehttpvers() 286 if ((so->so_rcv.sb_state & SBS_CANTRCVMORE) != 0 || sbfull(&so->so_rcv)) in soishttpconnected() 297 ccleft = sbavail(&so->so_rcv); in soishttpconnected() [all …]
|
| H A D | raw_ip.c | 257 struct socket *so; in rip_append() local 462 va_start(ap, so); in rip_output() 886 inp = sotoinpcb(so); in rip_attach() 918 inp = sotoinpcb(so); in rip_detach() 948 SOCK_LOCK(so); in rip_dodisconnect() 950 SOCK_UNLOCK(so); in rip_dodisconnect() 960 inp = sotoinpcb(so); in rip_abort() 971 inp = sotoinpcb(so); in rip_close() 985 inp = sotoinpcb(so); in rip_disconnect() 1047 soisconnected(so); in rip_connect() [all …]
|
| /f-stack/freebsd/netinet6/ |
| H A D | raw_ip6.c | 411 va_start(ap, so); in rip6_output() 416 inp = sotoinpcb(so); in rip6_output() 661 inp = sotoinpcb(so); in rip6_attach() 697 inp = sotoinpcb(so); in rip6_detach() 717 inp = sotoinpcb(so); in rip6_abort() 728 inp = sotoinpcb(so); in rip6_close() 739 inp = sotoinpcb(so); in rip6_disconnect() 745 rip6_abort(so); in rip6_disconnect() 758 inp = sotoinpcb(so); in rip6_bind() 836 soisconnected(so); in rip6_connect() [all …]
|
| /f-stack/tools/netstat/ |
| H A D | unix.c | 112 struct socket so; in pcblist_kvm() local 177 KREAD(unp->unp_socket, &so, sizeof(so)); in pcblist_kvm() 178 if (sotoxsocket(&so, &xu.xu_socket) != 0) in pcblist_kvm() 207 struct xsocket *so; in unixpr() local 248 so = &xunp->xu_socket; in unixpr() 258 unixdomainpr(xunp, so); in unixpr() 316 if (Lflag && so->so_qlimit == 0) in unixdomainpr() 321 so->so_incqlen, so->so_qlimit); in unixdomainpr() 324 buf1, so->so_qlen, so->so_incqlen, so->so_qlimit); in unixdomainpr() 327 (long)so->so_pcb, socktype[so->so_type], so->so_rcv.sb_cc, in unixdomainpr() [all …]
|
| /f-stack/freebsd/netgraph/bluetooth/socket/ |
| H A D | ng_btsocket_sco.c | 799 sorwakeup(pcb->so); in ng_btsocket_sco_data_input() 910 sowwakeup(pcb->so); in ng_btsocket_sco_default_msg_input() 1222 if ((so->so_snd.sb_hiwat == 0) || (so->so_rcv.sb_hiwat == 0)) { in ng_btsocket_sco_attach() 1237 pcb->so = so; in ng_btsocket_sco_attach() 1328 pcb = so2sco_pcb(so); in ng_btsocket_sco_bind() 1548 soisdisconnected(so); in ng_btsocket_sco_detach() 1549 so->so_pcb = NULL; in ng_btsocket_sco_detach() 1609 SOCK_LOCK(so); in ng_btsocket_sco_listen() 1624 SOCK_UNLOCK(so); in ng_btsocket_sco_listen() 1832 if (p->so == NULL || !(p->so->so_options & SO_ACCEPTCONN)) { in ng_btsocket_sco_pcb_by_addr() [all …]
|
| /f-stack/dpdk/doc/guides/rel_notes/ |
| H A D | release_18_08.rst | 227 librte_acl.so.2 238 librte_acl.so.2 241 librte_bpf.so.1 253 + librte_eal.so.8 257 librte_gro.so.1 258 librte_gso.so.1 259 librte_hash.so.2 262 librte_kni.so.2 265 librte_lpm.so.2 270 librte_net.so.1 [all …]
|