so 111 compat/svr4/svr4_net.c struct socket *so;
so 173 compat/svr4/svr4_net.c if ((error = socreate(family, &so, type, protocol)) != 0) {
so 184 compat/svr4/svr4_net.c fp->f_data = (caddr_t)so;
so 199 compat/svr4/svr4_net.c struct socket *so = (struct socket *) fp->f_data;
so 201 compat/svr4/svr4_net.c free(so->so_internal, M_NETADDR);
so 209 compat/svr4/svr4_net.c struct socket *so;
so 215 compat/svr4/svr4_net.c so = (struct socket *) fp->f_data;
so 217 compat/svr4/svr4_net.c if (so->so_internal)
so 218 compat/svr4/svr4_net.c return so->so_internal;
so 223 compat/svr4/svr4_net.c st->s_family = so->so_proto->pr_domain->dom_family;
so 226 compat/svr4/svr4_net.c so->so_internal = st;
so 387 compat/svr4/svr4_stream.c struct socket *so = (struct socket *) fp->f_data;
so 394 compat/svr4/svr4_stream.c switch (so->so_type) {
so 227 dev/rasops/rasops15.c int height, so, fs;
so 271 dev/rasops/rasops15.c so = STAMP_SHIFT(fr[0], 1) & STAMP_MASK;
so 272 dev/rasops/rasops15.c rp[0] = STAMP_READ(so);
so 273 dev/rasops/rasops15.c rp[1] = STAMP_READ(so + 4);
so 275 dev/rasops/rasops15.c so = STAMP_SHIFT(fr[0], 0) & STAMP_MASK;
so 276 dev/rasops/rasops15.c rp[2] = STAMP_READ(so);
so 277 dev/rasops/rasops15.c rp[3] = STAMP_READ(so + 4);
so 306 dev/rasops/rasops15.c int height, so, fs;
so 350 dev/rasops/rasops15.c so = STAMP_SHIFT(fr[0], 1) & STAMP_MASK;
so 351 dev/rasops/rasops15.c rp[0] = STAMP_READ(so);
so 352 dev/rasops/rasops15.c rp[1] = STAMP_READ(so + 4);
so 354 dev/rasops/rasops15.c so = STAMP_SHIFT(fr[0], 0) & STAMP_MASK;
so 355 dev/rasops/rasops15.c rp[2] = STAMP_READ(so);
so 356 dev/rasops/rasops15.c rp[3] = STAMP_READ(so + 4);
so 358 dev/rasops/rasops15.c so = STAMP_SHIFT(fr[1], 1) & STAMP_MASK;
so 359 dev/rasops/rasops15.c rp[4] = STAMP_READ(so);
so 360 dev/rasops/rasops15.c rp[5] = STAMP_READ(so + 4);
so 389 dev/rasops/rasops15.c int height, so, fs;
so 434 dev/rasops/rasops15.c so = STAMP_SHIFT(fr[0], 1) & STAMP_MASK;
so 435 dev/rasops/rasops15.c rp[0] = STAMP_READ(so);
so 436 dev/rasops/rasops15.c rp[1] = STAMP_READ(so + 4);
so 438 dev/rasops/rasops15.c so = STAMP_SHIFT(fr[0], 0) & STAMP_MASK;
so 439 dev/rasops/rasops15.c rp[2] = STAMP_READ(so);
so 440 dev/rasops/rasops15.c rp[3] = STAMP_READ(so + 4);
so 442 dev/rasops/rasops15.c so = STAMP_SHIFT(fr[1], 1) & STAMP_MASK;
so 443 dev/rasops/rasops15.c rp[4] = STAMP_READ(so);
so 444 dev/rasops/rasops15.c rp[5] = STAMP_READ(so + 4);
so 446 dev/rasops/rasops15.c so = STAMP_SHIFT(fr[1], 0) & STAMP_MASK;
so 447 dev/rasops/rasops15.c rp[6] = STAMP_READ(so);
so 448 dev/rasops/rasops15.c rp[7] = STAMP_READ(so + 4);
so 257 dev/rasops/rasops24.c int height, so, fs;
so 301 dev/rasops/rasops24.c so = STAMP_SHIFT(fr[0], 1) & STAMP_MASK;
so 302 dev/rasops/rasops24.c rp[0] = STAMP_READ(so);
so 303 dev/rasops/rasops24.c rp[1] = STAMP_READ(so + 4);
so 304 dev/rasops/rasops24.c rp[2] = STAMP_READ(so + 8);
so 306 dev/rasops/rasops24.c so = STAMP_SHIFT(fr[0], 0) & STAMP_MASK;
so 307 dev/rasops/rasops24.c rp[3] = STAMP_READ(so);
so 308 dev/rasops/rasops24.c rp[4] = STAMP_READ(so + 4);
so 309 dev/rasops/rasops24.c rp[5] = STAMP_READ(so + 8);
so 338 dev/rasops/rasops24.c int height, so, fs;
so 383 dev/rasops/rasops24.c so = STAMP_SHIFT(fr[0], 1) & STAMP_MASK;
so 384 dev/rasops/rasops24.c rp[0] = STAMP_READ(so);
so 385 dev/rasops/rasops24.c rp[1] = STAMP_READ(so + 4);
so 386 dev/rasops/rasops24.c rp[2] = STAMP_READ(so + 8);
so 388 dev/rasops/rasops24.c so = STAMP_SHIFT(fr[0], 0) & STAMP_MASK;
so 389 dev/rasops/rasops24.c rp[3] = STAMP_READ(so);
so 390 dev/rasops/rasops24.c rp[4] = STAMP_READ(so + 4);
so 391 dev/rasops/rasops24.c rp[5] = STAMP_READ(so + 8);
so 393 dev/rasops/rasops24.c so = STAMP_SHIFT(fr[1], 1) & STAMP_MASK;
so 394 dev/rasops/rasops24.c rp[6] = STAMP_READ(so);
so 395 dev/rasops/rasops24.c rp[7] = STAMP_READ(so + 4);
so 396 dev/rasops/rasops24.c rp[8] = STAMP_READ(so + 8);
so 426 dev/rasops/rasops24.c int height, so, fs;
so 472 dev/rasops/rasops24.c so = STAMP_SHIFT(fr[0], 1) & STAMP_MASK;
so 473 dev/rasops/rasops24.c rp[0] = STAMP_READ(so);
so 474 dev/rasops/rasops24.c rp[1] = STAMP_READ(so + 4);
so 475 dev/rasops/rasops24.c rp[2] = STAMP_READ(so + 8);
so 477 dev/rasops/rasops24.c so = STAMP_SHIFT(fr[0], 0) & STAMP_MASK;
so 478 dev/rasops/rasops24.c rp[3] = STAMP_READ(so);
so 479 dev/rasops/rasops24.c rp[4] = STAMP_READ(so + 4);
so 480 dev/rasops/rasops24.c rp[5] = STAMP_READ(so + 8);
so 482 dev/rasops/rasops24.c so = STAMP_SHIFT(fr[1], 1) & STAMP_MASK;
so 483 dev/rasops/rasops24.c rp[6] = STAMP_READ(so);
so 484 dev/rasops/rasops24.c rp[7] = STAMP_READ(so + 4);
so 485 dev/rasops/rasops24.c rp[8] = STAMP_READ(so + 8);
so 487 dev/rasops/rasops24.c so = STAMP_SHIFT(fr[1], 0) & STAMP_MASK;
so 488 dev/rasops/rasops24.c rp[9] = STAMP_READ(so);
so 489 dev/rasops/rasops24.c rp[10] = STAMP_READ(so + 4);
so 490 dev/rasops/rasops24.c rp[11] = STAMP_READ(so + 8);
so 382 kern/kern_descrip.c struct socket *so = (struct socket *)fp->f_data;
so 384 kern/kern_descrip.c so->so_pgid = (long)SCARG(uap, arg);
so 385 kern/kern_descrip.c so->so_siguid = p->p_cred->p_ruid;
so 386 kern/kern_descrip.c so->so_sigeuid = p->p_ucred->cr_uid;
so 563 kern/sys_generic.c struct socket *so = (struct socket *)fp->f_data;
so 565 kern/sys_generic.c so->so_pgid = tmp;
so 566 kern/sys_generic.c so->so_siguid = p->p_cred->p_ruid;
so 567 kern/sys_generic.c so->so_sigeuid = p->p_ucred->cr_uid;
so 76 kern/sys_socket.c struct socket *so = (struct socket *)fp->f_data;
so 82 kern/sys_socket.c so->so_state |= SS_NBIO;
so 84 kern/sys_socket.c so->so_state &= ~SS_NBIO;
so 89 kern/sys_socket.c so->so_state |= SS_ASYNC;
so 90 kern/sys_socket.c so->so_rcv.sb_flags |= SB_ASYNC;
so 91 kern/sys_socket.c so->so_snd.sb_flags |= SB_ASYNC;
so 93 kern/sys_socket.c so->so_state &= ~SS_ASYNC;
so 94 kern/sys_socket.c so->so_rcv.sb_flags &= ~SB_ASYNC;
so 95 kern/sys_socket.c so->so_snd.sb_flags &= ~SB_ASYNC;
so 100 kern/sys_socket.c *(int *)data = so->so_rcv.sb_datacc;
so 104 kern/sys_socket.c so->so_pgid = *(int *)data;
so 105 kern/sys_socket.c so->so_siguid = p->p_cred->p_ruid;
so 106 kern/sys_socket.c so->so_sigeuid = p->p_ucred->cr_uid;
so 110 kern/sys_socket.c *(int *)data = so->so_pgid;
so 114 kern/sys_socket.c *(int *)data = (so->so_state&SS_RCVATMARK) != 0;
so 123 kern/sys_socket.c return (ifioctl(so, cmd, data, p));
so 126 kern/sys_socket.c return ((*so->so_proto->pr_usrreq)(so, PRU_CONTROL,
so 133 kern/sys_socket.c struct socket *so = (struct socket *)fp->f_data;
so 138 kern/sys_socket.c if (soreadable(so))
so 142 kern/sys_socket.c if (sowriteable(so))
so 146 kern/sys_socket.c if (so->so_oobmark || (so->so_state & SS_RCVATMARK))
so 151 kern/sys_socket.c selrecord(p, &so->so_rcv.sb_sel);
so 152 kern/sys_socket.c so->so_rcv.sb_flags |= SB_SEL;
so 155 kern/sys_socket.c selrecord(p, &so->so_snd.sb_sel);
so 156 kern/sys_socket.c so->so_snd.sb_flags |= SB_SEL;
so 166 kern/sys_socket.c struct socket *so = (struct socket *)fp->f_data;
so 170 kern/sys_socket.c return ((*so->so_proto->pr_usrreq)(so, PRU_SENSE,
so 94 kern/uipc_socket.c struct socket *so;
so 106 kern/uipc_socket.c so = pool_get(&socket_pool, PR_WAITOK);
so 107 kern/uipc_socket.c bzero(so, sizeof(*so));
so 108 kern/uipc_socket.c TAILQ_INIT(&so->so_q0);
so 109 kern/uipc_socket.c TAILQ_INIT(&so->so_q);
so 110 kern/uipc_socket.c so->so_type = type;
so 112 kern/uipc_socket.c so->so_state = SS_PRIV;
so 113 kern/uipc_socket.c so->so_ruid = p->p_cred->p_ruid;
so 114 kern/uipc_socket.c so->so_euid = p->p_ucred->cr_uid;
so 115 kern/uipc_socket.c so->so_rgid = p->p_cred->p_rgid;
so 116 kern/uipc_socket.c so->so_egid = p->p_ucred->cr_gid;
so 117 kern/uipc_socket.c so->so_cpid = p->p_pid;
so 118 kern/uipc_socket.c so->so_proto = prp;
so 119 kern/uipc_socket.c error = (*prp->pr_usrreq)(so, PRU_ATTACH, NULL,
so 122 kern/uipc_socket.c so->so_state |= SS_NOFDREF;
so 123 kern/uipc_socket.c sofree(so);
so 131 kern/uipc_socket.c so->so_options |= SO_BROADCAST;
so 135 kern/uipc_socket.c *aso = so;
so 140 kern/uipc_socket.c sobind(struct socket *so, struct mbuf *nam)
so 145 kern/uipc_socket.c error = (*so->so_proto->pr_usrreq)(so, PRU_BIND, NULL, nam, NULL);
so 151 kern/uipc_socket.c solisten(struct socket *so, int backlog)
so 155 kern/uipc_socket.c error = (*so->so_proto->pr_usrreq)(so, PRU_LISTEN, NULL, NULL, NULL);
so 160 kern/uipc_socket.c if (TAILQ_FIRST(&so->so_q) == NULL)
so 161 kern/uipc_socket.c so->so_options |= SO_ACCEPTCONN;
so 166 kern/uipc_socket.c so->so_qlimit = backlog;
so 176 kern/uipc_socket.c sofree(struct socket *so)
so 180 kern/uipc_socket.c if (so->so_pcb || (so->so_state & SS_NOFDREF) == 0)
so 182 kern/uipc_socket.c if (so->so_head) {
so 188 kern/uipc_socket.c if (!soqremque(so, 0))
so 191 kern/uipc_socket.c sbrelease(&so->so_snd);
so 192 kern/uipc_socket.c sorflush(so);
so 193 kern/uipc_socket.c pool_put(&socket_pool, so);
so 202 kern/uipc_socket.c soclose(struct socket *so)
so 208 kern/uipc_socket.c if (so->so_options & SO_ACCEPTCONN) {
so 209 kern/uipc_socket.c while ((so2 = TAILQ_FIRST(&so->so_q0)) != NULL) {
so 213 kern/uipc_socket.c while ((so2 = TAILQ_FIRST(&so->so_q)) != NULL) {
so 218 kern/uipc_socket.c if (so->so_pcb == 0)
so 220 kern/uipc_socket.c if (so->so_state & SS_ISCONNECTED) {
so 221 kern/uipc_socket.c if ((so->so_state & SS_ISDISCONNECTING) == 0) {
so 222 kern/uipc_socket.c error = sodisconnect(so);
so 226 kern/uipc_socket.c if (so->so_options & SO_LINGER) {
so 227 kern/uipc_socket.c if ((so->so_state & SS_ISDISCONNECTING) &&
so 228 kern/uipc_socket.c (so->so_state & SS_NBIO))
so 230 kern/uipc_socket.c while (so->so_state & SS_ISCONNECTED) {
so 231 kern/uipc_socket.c error = tsleep(&so->so_timeo,
so 233 kern/uipc_socket.c so->so_linger * hz);
so 240 kern/uipc_socket.c if (so->so_pcb) {
so 241 kern/uipc_socket.c int error2 = (*so->so_proto->pr_usrreq)(so, PRU_DETACH, NULL,
so 247 kern/uipc_socket.c if (so->so_state & SS_NOFDREF)
so 249 kern/uipc_socket.c so->so_state |= SS_NOFDREF;
so 250 kern/uipc_socket.c sofree(so);
so 259 kern/uipc_socket.c soabort(struct socket *so)
so 263 kern/uipc_socket.c return (*so->so_proto->pr_usrreq)(so, PRU_ABORT, NULL, NULL, NULL);
so 267 kern/uipc_socket.c soaccept(struct socket *so, struct mbuf *nam)
so 272 kern/uipc_socket.c if ((so->so_state & SS_NOFDREF) == 0)
so 274 kern/uipc_socket.c so->so_state &= ~SS_NOFDREF;
so 275 kern/uipc_socket.c if ((so->so_state & SS_ISDISCONNECTED) == 0 ||
so 276 kern/uipc_socket.c (so->so_proto->pr_flags & PR_ABRTACPTDIS) == 0)
so 277 kern/uipc_socket.c error = (*so->so_proto->pr_usrreq)(so, PRU_ACCEPT, NULL,
so 286 kern/uipc_socket.c soconnect(struct socket *so, struct mbuf *nam)
so 291 kern/uipc_socket.c if (so->so_options & SO_ACCEPTCONN)
so 300 kern/uipc_socket.c if (so->so_state & (SS_ISCONNECTED|SS_ISCONNECTING) &&
so 301 kern/uipc_socket.c ((so->so_proto->pr_flags & PR_CONNREQUIRED) ||
so 302 kern/uipc_socket.c (error = sodisconnect(so))))
so 305 kern/uipc_socket.c error = (*so->so_proto->pr_usrreq)(so, PRU_CONNECT,
so 324 kern/uipc_socket.c sodisconnect(struct socket *so)
so 329 kern/uipc_socket.c if ((so->so_state & SS_ISCONNECTED) == 0) {
so 333 kern/uipc_socket.c if (so->so_state & SS_ISDISCONNECTING) {
so 337 kern/uipc_socket.c error = (*so->so_proto->pr_usrreq)(so, PRU_DISCONNECT, NULL, NULL,
so 363 kern/uipc_socket.c sosend(struct socket *so, struct mbuf *addr, struct uio *uio, struct mbuf *top,
so 371 kern/uipc_socket.c int atomic = sosendallatonce(so) || top;
so 386 kern/uipc_socket.c (so->so_type == SOCK_STREAM && (flags & MSG_EOR))) {
so 391 kern/uipc_socket.c (flags & MSG_DONTROUTE) && (so->so_options & SO_DONTROUTE) == 0 &&
so 392 kern/uipc_socket.c (so->so_proto->pr_flags & PR_ATOMIC);
so 400 kern/uipc_socket.c if ((error = sblock(&so->so_snd, SBLOCKWAIT(flags))) != 0)
so 402 kern/uipc_socket.c so->so_state |= SS_ISSENDING;
so 405 kern/uipc_socket.c if (so->so_state & SS_CANTSENDMORE)
so 407 kern/uipc_socket.c if (so->so_error) {
so 408 kern/uipc_socket.c error = so->so_error;
so 409 kern/uipc_socket.c so->so_error = 0;
so 413 kern/uipc_socket.c if ((so->so_state & SS_ISCONNECTED) == 0) {
so 414 kern/uipc_socket.c if (so->so_proto->pr_flags & PR_CONNREQUIRED) {
so 415 kern/uipc_socket.c if ((so->so_state & SS_ISCONFIRMING) == 0 &&
so 421 kern/uipc_socket.c space = sbspace(&so->so_snd);
so 424 kern/uipc_socket.c if ((atomic && resid > so->so_snd.sb_hiwat) ||
so 425 kern/uipc_socket.c clen > so->so_snd.sb_hiwat)
so 428 kern/uipc_socket.c (atomic || space < so->so_snd.sb_lowat || space < clen)) {
so 429 kern/uipc_socket.c if (so->so_state & SS_NBIO)
so 431 kern/uipc_socket.c sbunlock(&so->so_snd);
so 432 kern/uipc_socket.c error = sbwait(&so->so_snd);
so 433 kern/uipc_socket.c so->so_state &= ~SS_ISSENDING;
so 498 kern/uipc_socket.c so->so_options |= SO_DONTROUTE;
so 501 kern/uipc_socket.c so->so_state &= ~SS_ISSENDING;
so 502 kern/uipc_socket.c error = (*so->so_proto->pr_usrreq)(so,
so 507 kern/uipc_socket.c so->so_options &= ~SO_DONTROUTE;
so 518 kern/uipc_socket.c so->so_state &= ~SS_ISSENDING;
so 519 kern/uipc_socket.c sbunlock(&so->so_snd);
so 545 kern/uipc_socket.c soreceive(struct socket *so, struct mbuf **paddr, struct uio *uio,
so 550 kern/uipc_socket.c struct protosw *pr = so->so_proto;
so 566 kern/uipc_socket.c if (so->so_state & SS_NBIO)
so 570 kern/uipc_socket.c error = (*pr->pr_usrreq)(so, PRU_RCVOOB, m,
so 586 kern/uipc_socket.c if (so->so_state & SS_ISCONFIRMING && uio->uio_resid)
so 587 kern/uipc_socket.c (*pr->pr_usrreq)(so, PRU_RCVD, NULL, NULL, NULL);
so 590 kern/uipc_socket.c if ((error = sblock(&so->so_rcv, SBLOCKWAIT(flags))) != 0)
so 594 kern/uipc_socket.c m = so->so_rcv.sb_mb;
so 607 kern/uipc_socket.c so->so_rcv.sb_cc < uio->uio_resid) &&
so 608 kern/uipc_socket.c (so->so_rcv.sb_cc < so->so_rcv.sb_lowat ||
so 609 kern/uipc_socket.c ((flags & MSG_WAITALL) && uio->uio_resid <= so->so_rcv.sb_hiwat)) &&
so 612 kern/uipc_socket.c if (m == NULL && so->so_rcv.sb_cc)
so 615 kern/uipc_socket.c if (so->so_error) {
so 618 kern/uipc_socket.c error = so->so_error;
so 620 kern/uipc_socket.c so->so_error = 0;
so 623 kern/uipc_socket.c if (so->so_state & SS_CANTRCVMORE) {
so 631 kern/uipc_socket.c m = so->so_rcv.sb_mb;
so 634 kern/uipc_socket.c if ((so->so_state & (SS_ISCONNECTED|SS_ISCONNECTING)) == 0 &&
so 635 kern/uipc_socket.c (so->so_proto->pr_flags & PR_CONNREQUIRED)) {
so 641 kern/uipc_socket.c if ((so->so_state & SS_NBIO) || (flags & MSG_DONTWAIT)) {
so 645 kern/uipc_socket.c SBLASTRECORDCHK(&so->so_rcv, "soreceive sbwait 1");
so 646 kern/uipc_socket.c SBLASTMBUFCHK(&so->so_rcv, "soreceive sbwait 1");
so 647 kern/uipc_socket.c sbunlock(&so->so_rcv);
so 648 kern/uipc_socket.c error = sbwait(&so->so_rcv);
so 662 kern/uipc_socket.c KASSERT(m == so->so_rcv.sb_mb);
so 663 kern/uipc_socket.c SBLASTRECORDCHK(&so->so_rcv, "soreceive 1");
so 664 kern/uipc_socket.c SBLASTMBUFCHK(&so->so_rcv, "soreceive 1");
so 677 kern/uipc_socket.c sbfree(&so->so_rcv, m);
so 680 kern/uipc_socket.c so->so_rcv.sb_mb = m->m_next;
so 682 kern/uipc_socket.c m = so->so_rcv.sb_mb;
so 684 kern/uipc_socket.c MFREE(m, so->so_rcv.sb_mb);
so 685 kern/uipc_socket.c m = so->so_rcv.sb_mb;
so 695 kern/uipc_socket.c sbfree(&so->so_rcv, m);
so 702 kern/uipc_socket.c so->so_rcv.sb_mb = m->m_next;
so 704 kern/uipc_socket.c m = so->so_rcv.sb_mb;
so 713 kern/uipc_socket.c MFREE(m, so->so_rcv.sb_mb);
so 714 kern/uipc_socket.c m = so->so_rcv.sb_mb;
so 738 kern/uipc_socket.c KASSERT(so->so_rcv.sb_mb == m);
so 739 kern/uipc_socket.c so->so_rcv.sb_lastrecord = m;
so 751 kern/uipc_socket.c KASSERT(so->so_rcv.sb_mb == m);
so 752 kern/uipc_socket.c so->so_rcv.sb_mb = nextrecord;
so 753 kern/uipc_socket.c SB_EMPTY_FIXUP(&so->so_rcv);
so 756 kern/uipc_socket.c SBLASTRECORDCHK(&so->so_rcv, "soreceive 2");
so 757 kern/uipc_socket.c SBLASTMBUFCHK(&so->so_rcv, "soreceive 2");
so 771 kern/uipc_socket.c so->so_state &= ~SS_RCVATMARK;
so 773 kern/uipc_socket.c if (so->so_oobmark && len > so->so_oobmark - offset)
so 774 kern/uipc_socket.c len = so->so_oobmark - offset;
so 786 kern/uipc_socket.c SBLASTRECORDCHK(&so->so_rcv, "soreceive uiomove");
so 787 kern/uipc_socket.c SBLASTMBUFCHK(&so->so_rcv, "soreceive uiomove");
so 806 kern/uipc_socket.c sbfree(&so->so_rcv, m);
so 810 kern/uipc_socket.c so->so_rcv.sb_mb = m = m->m_next;
so 813 kern/uipc_socket.c MFREE(m, so->so_rcv.sb_mb);
so 814 kern/uipc_socket.c m = so->so_rcv.sb_mb;
so 820 kern/uipc_socket.c KASSERT(so->so_rcv.sb_mb == m);
so 824 kern/uipc_socket.c so->so_rcv.sb_lastrecord = m;
so 826 kern/uipc_socket.c so->so_rcv.sb_mb = nextrecord;
so 827 kern/uipc_socket.c SB_EMPTY_FIXUP(&so->so_rcv);
so 829 kern/uipc_socket.c SBLASTRECORDCHK(&so->so_rcv, "soreceive 3");
so 830 kern/uipc_socket.c SBLASTMBUFCHK(&so->so_rcv, "soreceive 3");
so 840 kern/uipc_socket.c so->so_rcv.sb_cc -= len;
so 841 kern/uipc_socket.c so->so_rcv.sb_datacc -= len;
so 844 kern/uipc_socket.c if (so->so_oobmark) {
so 846 kern/uipc_socket.c so->so_oobmark -= len;
so 847 kern/uipc_socket.c if (so->so_oobmark == 0) {
so 848 kern/uipc_socket.c so->so_state |= SS_RCVATMARK;
so 853 kern/uipc_socket.c if (offset == so->so_oobmark)
so 867 kern/uipc_socket.c !sosendallatonce(so) && !nextrecord) {
so 868 kern/uipc_socket.c if (so->so_error || so->so_state & SS_CANTRCVMORE)
so 870 kern/uipc_socket.c SBLASTRECORDCHK(&so->so_rcv, "soreceive sbwait 2");
so 871 kern/uipc_socket.c SBLASTMBUFCHK(&so->so_rcv, "soreceive sbwait 2");
so 872 kern/uipc_socket.c error = sbwait(&so->so_rcv);
so 874 kern/uipc_socket.c sbunlock(&so->so_rcv);
so 878 kern/uipc_socket.c if ((m = so->so_rcv.sb_mb) != NULL)
so 886 kern/uipc_socket.c (void) sbdroprecord(&so->so_rcv);
so 895 kern/uipc_socket.c so->so_rcv.sb_mb = nextrecord;
so 896 kern/uipc_socket.c if (so->so_rcv.sb_mb == NULL) {
so 897 kern/uipc_socket.c so->so_rcv.sb_mbtail = NULL;
so 898 kern/uipc_socket.c so->so_rcv.sb_lastrecord = NULL;
so 900 kern/uipc_socket.c so->so_rcv.sb_lastrecord = nextrecord;
so 902 kern/uipc_socket.c SBLASTRECORDCHK(&so->so_rcv, "soreceive 4");
so 903 kern/uipc_socket.c SBLASTMBUFCHK(&so->so_rcv, "soreceive 4");
so 904 kern/uipc_socket.c if (pr->pr_flags & PR_WANTRCVD && so->so_pcb)
so 905 kern/uipc_socket.c (*pr->pr_usrreq)(so, PRU_RCVD, NULL,
so 909 kern/uipc_socket.c (flags & MSG_EOR) == 0 && (so->so_state & SS_CANTRCVMORE) == 0) {
so 910 kern/uipc_socket.c sbunlock(&so->so_rcv);
so 921 kern/uipc_socket.c sbunlock(&so->so_rcv);
so 927 kern/uipc_socket.c soshutdown(struct socket *so, int how)
so 929 kern/uipc_socket.c struct protosw *pr = so->so_proto;
so 934 kern/uipc_socket.c sorflush(so);
so 939 kern/uipc_socket.c return (*pr->pr_usrreq)(so, PRU_SHUTDOWN, NULL, NULL, NULL);
so 946 kern/uipc_socket.c sorflush(struct socket *so)
so 948 kern/uipc_socket.c struct sockbuf *sb = &so->so_rcv;
so 949 kern/uipc_socket.c struct protosw *pr = so->so_proto;
so 956 kern/uipc_socket.c socantrcvmore(so);
so 972 kern/uipc_socket.c sosetopt(struct socket *so, int level, int optname, struct mbuf *m0)
so 978 kern/uipc_socket.c if (so->so_proto && so->so_proto->pr_ctloutput)
so 979 kern/uipc_socket.c return ((*so->so_proto->pr_ctloutput)
so 980 kern/uipc_socket.c (PRCO_SETOPT, so, level, optname, &m0));
so 992 kern/uipc_socket.c so->so_linger = mtod(m, struct linger *)->l_linger;
so 1009 kern/uipc_socket.c so->so_options |= optname;
so 1011 kern/uipc_socket.c so->so_options &= ~optname;
so 1031 kern/uipc_socket.c if (sbcheckreserve(cnt, so->so_snd.sb_hiwat) ||
so 1032 kern/uipc_socket.c sbreserve(&so->so_snd, cnt) == 0) {
so 1039 kern/uipc_socket.c if (sbcheckreserve(cnt, so->so_rcv.sb_hiwat) ||
so 1040 kern/uipc_socket.c sbreserve(&so->so_rcv, cnt) == 0) {
so 1047 kern/uipc_socket.c so->so_snd.sb_lowat = (cnt > so->so_snd.sb_hiwat) ?
so 1048 kern/uipc_socket.c so->so_snd.sb_hiwat : cnt;
so 1051 kern/uipc_socket.c so->so_rcv.sb_lowat = (cnt > so->so_rcv.sb_hiwat) ?
so 1052 kern/uipc_socket.c so->so_rcv.sb_hiwat : cnt;
so 1080 kern/uipc_socket.c so->so_snd.sb_timeo = val;
so 1083 kern/uipc_socket.c so->so_rcv.sb_timeo = val;
so 1093 kern/uipc_socket.c if (error == 0 && so->so_proto && so->so_proto->pr_ctloutput) {
so 1094 kern/uipc_socket.c (void) ((*so->so_proto->pr_ctloutput)
so 1095 kern/uipc_socket.c (PRCO_SETOPT, so, level, optname, &m0));
so 1106 kern/uipc_socket.c sogetopt(struct socket *so, int level, int optname, struct mbuf **mp)
so 1111 kern/uipc_socket.c if (so->so_proto && so->so_proto->pr_ctloutput) {
so 1112 kern/uipc_socket.c return ((*so->so_proto->pr_ctloutput)
so 1113 kern/uipc_socket.c (PRCO_GETOPT, so, level, optname, mp));
so 1125 kern/uipc_socket.c so->so_options & SO_LINGER;
so 1126 kern/uipc_socket.c mtod(m, struct linger *)->l_linger = so->so_linger;
so 1138 kern/uipc_socket.c *mtod(m, int *) = so->so_options & optname;
so 1142 kern/uipc_socket.c *mtod(m, int *) = so->so_type;
so 1146 kern/uipc_socket.c *mtod(m, int *) = so->so_error;
so 1147 kern/uipc_socket.c so->so_error = 0;
so 1151 kern/uipc_socket.c *mtod(m, int *) = so->so_snd.sb_hiwat;
so 1155 kern/uipc_socket.c *mtod(m, int *) = so->so_rcv.sb_hiwat;
so 1159 kern/uipc_socket.c *mtod(m, int *) = so->so_snd.sb_lowat;
so 1163 kern/uipc_socket.c *mtod(m, int *) = so->so_rcv.sb_lowat;
so 1170 kern/uipc_socket.c so->so_snd.sb_timeo : so->so_rcv.sb_timeo);
so 1189 kern/uipc_socket.c sohasoutofband(struct socket *so)
so 1191 kern/uipc_socket.c csignal(so->so_pgid, SIGURG, so->so_siguid, so->so_sigeuid);
so 1192 kern/uipc_socket.c selwakeup(&so->so_rcv.sb_sel);
so 1198 kern/uipc_socket.c struct socket *so = (struct socket *)kn->kn_fp->f_data;
so 1204 kern/uipc_socket.c if (so->so_options & SO_ACCEPTCONN)
so 1208 kern/uipc_socket.c sb = &so->so_rcv;
so 1212 kern/uipc_socket.c sb = &so->so_snd;
so 1228 kern/uipc_socket.c struct socket *so = (struct socket *)kn->kn_fp->f_data;
so 1231 kern/uipc_socket.c SLIST_REMOVE(&so->so_rcv.sb_sel.si_note, kn, knote, kn_selnext);
so 1232 kern/uipc_socket.c if (SLIST_EMPTY(&so->so_rcv.sb_sel.si_note))
so 1233 kern/uipc_socket.c so->so_rcv.sb_flags &= ~SB_KNOTE;
so 1241 kern/uipc_socket.c struct socket *so = (struct socket *)kn->kn_fp->f_data;
so 1243 kern/uipc_socket.c kn->kn_data = so->so_rcv.sb_cc;
so 1244 kern/uipc_socket.c if (so->so_state & SS_CANTRCVMORE) {
so 1246 kern/uipc_socket.c kn->kn_fflags = so->so_error;
so 1249 kern/uipc_socket.c if (so->so_error) /* temporary udp error */
so 1253 kern/uipc_socket.c return (kn->kn_data >= so->so_rcv.sb_lowat);
so 1259 kern/uipc_socket.c struct socket *so = (struct socket *)kn->kn_fp->f_data;
so 1262 kern/uipc_socket.c SLIST_REMOVE(&so->so_snd.sb_sel.si_note, kn, knote, kn_selnext);
so 1263 kern/uipc_socket.c if (SLIST_EMPTY(&so->so_snd.sb_sel.si_note))
so 1264 kern/uipc_socket.c so->so_snd.sb_flags &= ~SB_KNOTE;
so 1272 kern/uipc_socket.c struct socket *so = (struct socket *)kn->kn_fp->f_data;
so 1274 kern/uipc_socket.c kn->kn_data = sbspace(&so->so_snd);
so 1275 kern/uipc_socket.c if (so->so_state & SS_CANTSENDMORE) {
so 1277 kern/uipc_socket.c kn->kn_fflags = so->so_error;
so 1280 kern/uipc_socket.c if (so->so_error) /* temporary udp error */
so 1282 kern/uipc_socket.c if (((so->so_state & SS_ISCONNECTED) == 0) &&
so 1283 kern/uipc_socket.c (so->so_proto->pr_flags & PR_CONNREQUIRED))
so 1287 kern/uipc_socket.c return (kn->kn_data >= so->so_snd.sb_lowat);
so 1294 kern/uipc_socket.c struct socket *so = (struct socket *)kn->kn_fp->f_data;
so 1296 kern/uipc_socket.c kn->kn_data = so->so_qlen;
so 1297 kern/uipc_socket.c return (so->so_qlen != 0);
so 91 kern/uipc_socket2.c soisconnecting(struct socket *so)
so 94 kern/uipc_socket2.c so->so_state &= ~(SS_ISCONNECTED|SS_ISDISCONNECTING);
so 95 kern/uipc_socket2.c so->so_state |= SS_ISCONNECTING;
so 99 kern/uipc_socket2.c soisconnected(struct socket *so)
so 101 kern/uipc_socket2.c struct socket *head = so->so_head;
so 103 kern/uipc_socket2.c so->so_state &= ~(SS_ISCONNECTING|SS_ISDISCONNECTING|SS_ISCONFIRMING);
so 104 kern/uipc_socket2.c so->so_state |= SS_ISCONNECTED;
so 105 kern/uipc_socket2.c if (head && soqremque(so, 0)) {
so 106 kern/uipc_socket2.c soqinsque(head, so, 1);
so 110 kern/uipc_socket2.c wakeup(&so->so_timeo);
so 111 kern/uipc_socket2.c sorwakeup(so);
so 112 kern/uipc_socket2.c sowwakeup(so);
so 117 kern/uipc_socket2.c soisdisconnecting(struct socket *so)
so 120 kern/uipc_socket2.c so->so_state &= ~SS_ISCONNECTING;
so 121 kern/uipc_socket2.c so->so_state |= (SS_ISDISCONNECTING|SS_CANTRCVMORE|SS_CANTSENDMORE);
so 122 kern/uipc_socket2.c wakeup(&so->so_timeo);
so 123 kern/uipc_socket2.c sowwakeup(so);
so 124 kern/uipc_socket2.c sorwakeup(so);
so 128 kern/uipc_socket2.c soisdisconnected(struct socket *so)
so 131 kern/uipc_socket2.c so->so_state &= ~(SS_ISCONNECTING|SS_ISCONNECTED|SS_ISDISCONNECTING);
so 132 kern/uipc_socket2.c so->so_state |= (SS_CANTRCVMORE|SS_CANTSENDMORE|SS_ISDISCONNECTED);
so 133 kern/uipc_socket2.c wakeup(&so->so_timeo);
so 134 kern/uipc_socket2.c sowwakeup(so);
so 135 kern/uipc_socket2.c sorwakeup(so);
so 151 kern/uipc_socket2.c struct socket *so;
so 162 kern/uipc_socket2.c so = pool_get(&socket_pool, PR_NOWAIT);
so 163 kern/uipc_socket2.c if (so == NULL)
so 165 kern/uipc_socket2.c bzero(so, sizeof(*so));
so 166 kern/uipc_socket2.c so->so_type = head->so_type;
so 167 kern/uipc_socket2.c so->so_options = head->so_options &~ SO_ACCEPTCONN;
so 168 kern/uipc_socket2.c so->so_linger = head->so_linger;
so 169 kern/uipc_socket2.c so->so_state = head->so_state | SS_NOFDREF;
so 170 kern/uipc_socket2.c so->so_proto = head->so_proto;
so 171 kern/uipc_socket2.c so->so_timeo = head->so_timeo;
so 172 kern/uipc_socket2.c so->so_pgid = head->so_pgid;
so 173 kern/uipc_socket2.c so->so_euid = head->so_euid;
so 174 kern/uipc_socket2.c so->so_ruid = head->so_ruid;
so 175 kern/uipc_socket2.c so->so_egid = head->so_egid;
so 176 kern/uipc_socket2.c so->so_rgid = head->so_rgid;
so 177 kern/uipc_socket2.c so->so_cpid = head->so_cpid;
so 178 kern/uipc_socket2.c so->so_siguid = head->so_siguid;
so 179 kern/uipc_socket2.c so->so_sigeuid = head->so_sigeuid;
so 192 kern/uipc_socket2.c (void) soreserve(so, snd_sb_hiwat, rcv_sb_hiwat);
so 193 kern/uipc_socket2.c soqinsque(head, so, soqueue);
so 194 kern/uipc_socket2.c if ((*so->so_proto->pr_usrreq)(so, PRU_ATTACH,
so 196 kern/uipc_socket2.c (void) soqremque(so, soqueue);
so 197 kern/uipc_socket2.c pool_put(&socket_pool, so);
so 203 kern/uipc_socket2.c so->so_state |= connstatus;
so 205 kern/uipc_socket2.c return (so);
so 209 kern/uipc_socket2.c soqinsque(struct socket *head, struct socket *so, int q)
so 213 kern/uipc_socket2.c if (so->so_onq != NULL)
so 217 kern/uipc_socket2.c so->so_head = head;
so 220 kern/uipc_socket2.c so->so_onq = &head->so_q0;
so 223 kern/uipc_socket2.c so->so_onq = &head->so_q;
so 225 kern/uipc_socket2.c TAILQ_INSERT_TAIL(so->so_onq, so, so_qe);
so 229 kern/uipc_socket2.c soqremque(struct socket *so, int q)
so 233 kern/uipc_socket2.c head = so->so_head;
so 235 kern/uipc_socket2.c if (so->so_onq != &head->so_q0)
so 239 kern/uipc_socket2.c if (so->so_onq != &head->so_q)
so 243 kern/uipc_socket2.c TAILQ_REMOVE(so->so_onq, so, so_qe);
so 244 kern/uipc_socket2.c so->so_onq = NULL;
so 245 kern/uipc_socket2.c so->so_head = NULL;
so 260 kern/uipc_socket2.c socantsendmore(struct socket *so)
so 263 kern/uipc_socket2.c so->so_state |= SS_CANTSENDMORE;
so 264 kern/uipc_socket2.c sowwakeup(so);
so 268 kern/uipc_socket2.c socantrcvmore(struct socket *so)
so 271 kern/uipc_socket2.c so->so_state |= SS_CANTRCVMORE;
so 272 kern/uipc_socket2.c sorwakeup(so);
so 315 kern/uipc_socket2.c sowakeup(struct socket *so, struct sockbuf *sb)
so 323 kern/uipc_socket2.c if (so->so_state & SS_ASYNC)
so 324 kern/uipc_socket2.c csignal(so->so_pgid, SIGIO, so->so_siguid, so->so_sigeuid);
so 361 kern/uipc_socket2.c soreserve(struct socket *so, u_long sndcc, u_long rcvcc)
so 364 kern/uipc_socket2.c if (sbreserve(&so->so_snd, sndcc) == 0)
so 366 kern/uipc_socket2.c if (sbreserve(&so->so_rcv, rcvcc) == 0)
so 368 kern/uipc_socket2.c if (so->so_rcv.sb_lowat == 0)
so 369 kern/uipc_socket2.c so->so_rcv.sb_lowat = 1;
so 370 kern/uipc_socket2.c if (so->so_snd.sb_lowat == 0)
so 371 kern/uipc_socket2.c so->so_snd.sb_lowat = MCLBYTES;
so 372 kern/uipc_socket2.c if (so->so_snd.sb_lowat > so->so_snd.sb_hiwat)
so 373 kern/uipc_socket2.c so->so_snd.sb_lowat = so->so_snd.sb_hiwat;
so 376 kern/uipc_socket2.c sbrelease(&so->so_snd);
so 71 kern/uipc_syscalls.c struct socket *so;
so 82 kern/uipc_syscalls.c error = socreate(SCARG(uap, domain), &so, SCARG(uap, type),
so 88 kern/uipc_syscalls.c fp->f_data = so;
so 152 kern/uipc_syscalls.c struct socket *head, *so;
so 197 kern/uipc_syscalls.c so = TAILQ_FIRST(&head->so_q);
so 198 kern/uipc_syscalls.c if (soqremque(so, 1) == 0)
so 212 kern/uipc_syscalls.c so->so_head = head;
so 214 kern/uipc_syscalls.c so->so_onq = &head->so_q;
so 215 kern/uipc_syscalls.c TAILQ_INSERT_HEAD(so->so_onq, so, so_qe);
so 227 kern/uipc_syscalls.c fp->f_data = so;
so 229 kern/uipc_syscalls.c error = soaccept(so, nam);
so 264 kern/uipc_syscalls.c struct socket *so;
so 270 kern/uipc_syscalls.c so = fp->f_data;
so 271 kern/uipc_syscalls.c if ((so->so_state & SS_NBIO) && (so->so_state & SS_ISCONNECTING)) {
so 279 kern/uipc_syscalls.c error = soconnect(so, nam);
so 282 kern/uipc_syscalls.c if ((so->so_state & SS_NBIO) && (so->so_state & SS_ISCONNECTING)) {
so 288 kern/uipc_syscalls.c while ((so->so_state & SS_ISCONNECTING) && so->so_error == 0) {
so 289 kern/uipc_syscalls.c error = tsleep(&so->so_timeo, PSOCK | PCATCH,
so 295 kern/uipc_syscalls.c error = so->so_error;
so 296 kern/uipc_syscalls.c so->so_error = 0;
so 300 kern/uipc_syscalls.c so->so_state &= ~SS_ISCONNECTING;
so 924 kern/uipc_syscalls.c struct socket *so;
so 934 kern/uipc_syscalls.c so = fp->f_data;
so 936 kern/uipc_syscalls.c error = (*so->so_proto->pr_usrreq)(so, PRU_SOCKADDR, 0, m, 0);
so 964 kern/uipc_syscalls.c struct socket *so;
so 971 kern/uipc_syscalls.c so = fp->f_data;
so 972 kern/uipc_syscalls.c if ((so->so_state & (SS_ISCONNECTED|SS_ISCONFIRMING)) == 0) {
so 980 kern/uipc_syscalls.c error = (*so->so_proto->pr_usrreq)(so, PRU_PEERADDR, 0, m, 0);
so 1007 kern/uipc_syscalls.c struct socket *so;
so 1014 kern/uipc_syscalls.c so = fp->f_data;
so 1015 kern/uipc_syscalls.c if (so->so_proto != pffindtype(AF_LOCAL, SOCK_STREAM)) {
so 1024 kern/uipc_syscalls.c error = (*so->so_proto->pr_usrreq)(so, PRU_PEEREID, 0, m, 0);
so 64 kern/uipc_usrreq.c uipc_usrreq(struct socket *so, int req, struct mbuf *m, struct mbuf *nam,
so 67 kern/uipc_usrreq.c struct unpcb *unp = sotounpcb(so);
so 89 kern/uipc_usrreq.c error = unp_attach(so);
so 106 kern/uipc_usrreq.c error = unp_connect(so, nam, p);
so 110 kern/uipc_usrreq.c error = unp_connect2(so, (struct socket *)nam);
so 134 kern/uipc_usrreq.c socantsendmore(so);
so 139 kern/uipc_usrreq.c switch (so->so_type) {
so 146 kern/uipc_usrreq.c #define rcv (&so->so_rcv)
so 172 kern/uipc_usrreq.c switch (so->so_type) {
so 182 kern/uipc_usrreq.c error = unp_connect(so, nam, p);
so 209 kern/uipc_usrreq.c #define snd (&so->so_snd)
so 210 kern/uipc_usrreq.c if (so->so_state & SS_CANTSENDMORE) {
so 253 kern/uipc_usrreq.c ((struct stat *) m)->st_blksize = so->so_snd.sb_hiwat;
so 254 kern/uipc_usrreq.c if (so->so_type == SOCK_STREAM && unp->unp_conn != NULL) {
so 332 kern/uipc_usrreq.c unp_attach(struct socket *so)
so 337 kern/uipc_usrreq.c if (so->so_snd.sb_hiwat == 0 || so->so_rcv.sb_hiwat == 0) {
so 338 kern/uipc_usrreq.c switch (so->so_type) {
so 341 kern/uipc_usrreq.c error = soreserve(so, unpst_sendspace, unpst_recvspace);
so 345 kern/uipc_usrreq.c error = soreserve(so, unpdg_sendspace, unpdg_recvspace);
so 358 kern/uipc_usrreq.c unp->unp_socket = so;
so 359 kern/uipc_usrreq.c so->so_pcb = unp;
so 444 kern/uipc_usrreq.c unp_connect(struct socket *so, struct mbuf *nam, struct proc *p)
so 473 kern/uipc_usrreq.c if (so->so_type != so2->so_type) {
so 477 kern/uipc_usrreq.c if (so->so_proto->pr_flags & PR_CONNREQUIRED) {
so 483 kern/uipc_usrreq.c unp = sotounpcb(so);
so 499 kern/uipc_usrreq.c error = unp_connect2(so, so2);
so 506 kern/uipc_usrreq.c unp_connect2(struct socket *so, struct socket *so2)
so 508 kern/uipc_usrreq.c struct unpcb *unp = sotounpcb(so);
so 511 kern/uipc_usrreq.c if (so2->so_type != so->so_type)
so 515 kern/uipc_usrreq.c switch (so->so_type) {
so 520 kern/uipc_usrreq.c soisconnected(so);
so 525 kern/uipc_usrreq.c soisconnected(so);
so 581 kern/uipc_usrreq.c struct socket *so;
so 584 kern/uipc_usrreq.c (so = unp->unp_conn->unp_socket))
so 585 kern/uipc_usrreq.c socantrcvmore(so);
so 591 kern/uipc_usrreq.c struct socket *so = unp->unp_socket;
so 593 kern/uipc_usrreq.c so->so_error = errno;
so 595 kern/uipc_usrreq.c if (so->so_head) {
so 596 kern/uipc_usrreq.c so->so_pcb = NULL;
so 597 kern/uipc_usrreq.c sofree(so);
so 807 kern/uipc_usrreq.c struct socket *so;
so 833 kern/uipc_usrreq.c (so = (struct socket *)fp->f_data) == NULL)
so 835 kern/uipc_usrreq.c if (so->so_proto->pr_domain != &unixdomain ||
so 836 kern/uipc_usrreq.c (so->so_proto->pr_flags&PR_RIGHTS) == 0)
so 839 kern/uipc_usrreq.c if (so->so_rcv.sb_flags & SB_LOCK) {
so 850 kern/uipc_usrreq.c (void) sbwait(&so->so_rcv);
so 854 kern/uipc_usrreq.c unp_scan(so->so_rcv.sb_mb, unp_mark, 0);
so 508 miscfs/fifofs/fifo_vnops.c struct socket *so = (struct socket *)ap->a_vp->v_fifoinfo->fi_readsock;
so 514 miscfs/fifofs/fifo_vnops.c sb = &so->so_rcv;
so 518 miscfs/fifofs/fifo_vnops.c sb = &so->so_snd;
so 524 miscfs/fifofs/fifo_vnops.c ap->a_kn->kn_hook = so;
so 535 miscfs/fifofs/fifo_vnops.c struct socket *so = (struct socket *)kn->kn_hook;
so 537 miscfs/fifofs/fifo_vnops.c SLIST_REMOVE(&so->so_rcv.sb_sel.si_note, kn, knote, kn_selnext);
so 538 miscfs/fifofs/fifo_vnops.c if (SLIST_EMPTY(&so->so_rcv.sb_sel.si_note))
so 539 miscfs/fifofs/fifo_vnops.c so->so_rcv.sb_flags &= ~SB_KNOTE;
so 545 miscfs/fifofs/fifo_vnops.c struct socket *so = (struct socket *)kn->kn_hook;
so 547 miscfs/fifofs/fifo_vnops.c kn->kn_data = so->so_rcv.sb_cc;
so 548 miscfs/fifofs/fifo_vnops.c if (so->so_state & SS_CANTRCVMORE) {
so 559 miscfs/fifofs/fifo_vnops.c struct socket *so = (struct socket *)kn->kn_hook;
so 561 miscfs/fifofs/fifo_vnops.c SLIST_REMOVE(&so->so_snd.sb_sel.si_note, kn, knote, kn_selnext);
so 562 miscfs/fifofs/fifo_vnops.c if (SLIST_EMPTY(&so->so_snd.sb_sel.si_note))
so 563 miscfs/fifofs/fifo_vnops.c so->so_snd.sb_flags &= ~SB_KNOTE;
so 569 miscfs/fifofs/fifo_vnops.c struct socket *so = (struct socket *)kn->kn_hook;
so 571 miscfs/fifofs/fifo_vnops.c kn->kn_data = sbspace(&so->so_snd);
so 572 miscfs/fifofs/fifo_vnops.c if (so->so_state & SS_CANTSENDMORE) {
so 577 miscfs/fifofs/fifo_vnops.c return (kn->kn_data >= so->so_snd.sb_lowat);
so 82 miscfs/portal/portal_vfsops.c struct socket *so;
so 99 miscfs/portal/portal_vfsops.c so = (struct socket *) fp->f_data;
so 100 miscfs/portal/portal_vfsops.c if (so->so_proto->pr_domain->dom_family != AF_UNIX) {
so 239 miscfs/portal/portal_vnops.c portal_connect(struct socket *so, struct socket *so2)
so 249 miscfs/portal/portal_vnops.c if (so->so_type != so2->so_type)
so 266 miscfs/portal/portal_vnops.c return (unp_connect2(so, so2));
so 273 miscfs/portal/portal_vnops.c struct socket *so = 0;
so 312 miscfs/portal/portal_vnops.c error = socreate(AF_UNIX, &so, SOCK_STREAM, 0);
so 320 miscfs/portal/portal_vnops.c error = soreserve(so, res, res);
so 328 miscfs/portal/portal_vnops.c error = portal_connect(so, (struct socket *)fmp->pm_server->f_data);
so 347 miscfs/portal/portal_vnops.c while ((so->so_state & SS_ISCONNECTING) && so->so_error == 0) {
so 353 miscfs/portal/portal_vnops.c (void) tsleep(&so->so_timeo, PSOCK, "portalcon", 5 * hz);
so 357 miscfs/portal/portal_vnops.c if (so->so_error) {
so 358 miscfs/portal/portal_vnops.c error = so->so_error;
so 365 miscfs/portal/portal_vnops.c so->so_rcv.sb_timeo = 0;
so 366 miscfs/portal/portal_vnops.c so->so_snd.sb_timeo = 0;
so 367 miscfs/portal/portal_vnops.c so->so_rcv.sb_flags |= SB_NOINTR;
so 368 miscfs/portal/portal_vnops.c so->so_snd.sb_flags |= SB_NOINTR;
so 388 miscfs/portal/portal_vnops.c error = sosend(so, (struct mbuf *) 0, &auio,
so 398 miscfs/portal/portal_vnops.c error = soreceive(so, (struct mbuf **) 0, &auio,
so 498 miscfs/portal/portal_vnops.c if (so) {
so 499 miscfs/portal/portal_vnops.c soshutdown(so, 2);
so 500 miscfs/portal/portal_vnops.c soclose(so);
so 1145 net/if.c ifioctl(struct socket *so, u_long cmd, caddr_t data, struct proc *p)
so 1384 net/if.c if (so->so_proto == 0)
so 1387 net/if.c error = ((*so->so_proto->pr_usrreq)(so, PRU_CONTROL,
so 1427 net/if.c error = ((*so->so_proto->pr_usrreq)(so, PRU_CONTROL,
so 843 net/pfkeyv2.c struct pfkeyv2_socket *pfkeyv2_socket, *so = NULL;
so 898 net/pfkeyv2.c for (so = pfkeyv2_sockets; so; so = so->next)
so 899 net/pfkeyv2.c if (so->flags & PFKEYV2_SOCKETFLAGS_PROMISC)
so 900 net/pfkeyv2.c pfkey_sendup(so->socket, packet, 1);
so 1776 net/pfkeyv2.c for (so = pfkeyv2_sockets; so; so = so->next)
so 1777 net/pfkeyv2.c if ((so != pfkeyv2_socket) &&
so 1780 net/pfkeyv2.c pfkey_sendup(so->socket, packet, 1);
so 67 net/raw_cb.c raw_attach(so, proto)
so 68 net/raw_cb.c struct socket *so;
so 71 net/raw_cb.c struct rawcb *rp = sotorawcb(so);
so 81 net/raw_cb.c if ((error = soreserve(so, raw_sendspace, raw_recvspace)) != 0)
so 83 net/raw_cb.c rp->rcb_socket = so;
so 84 net/raw_cb.c rp->rcb_proto.sp_family = so->so_proto->pr_domain->dom_family;
so 98 net/raw_cb.c struct socket *so = rp->rcb_socket;
so 100 net/raw_cb.c so->so_pcb = 0;
so 101 net/raw_cb.c sofree(so);
so 130 net/raw_cb.c raw_bind(so, nam)
so 131 net/raw_cb.c struct socket *so;
so 139 net/raw_cb.c rp = sotorawcb(so);
so 50 net/raw_cb.h #define sotorawcb(so) ((struct rawcb *)(so)->so_pcb)
so 150 net/raw_usrreq.c raw_usrreq(so, req, m, nam, control)
so 151 net/raw_usrreq.c struct socket *so;
so 155 net/raw_usrreq.c struct rawcb *rp = sotorawcb(so);
so 177 net/raw_usrreq.c if ((so->so_state & SS_PRIV) == 0) {
so 181 net/raw_usrreq.c error = raw_attach(so, (int)(long)nam);
so 210 net/raw_usrreq.c soisconnected(so);
so 218 net/raw_usrreq.c error = raw_bind(so, nam);
so 234 net/raw_usrreq.c soisdisconnected(so);
so 241 net/raw_usrreq.c socantsendmore(so);
so 259 net/raw_usrreq.c error = (*so->so_proto->pr_output)(m, so);
so 267 net/raw_usrreq.c sofree(so);
so 268 net/raw_usrreq.c soisdisconnected(so);
so 106 net/rtsock.c route_usrreq(struct socket *so, int req, struct mbuf *m, struct mbuf *nam,
so 110 net/rtsock.c struct rawcb *rp = sotorawcb(so);
so 115 net/rtsock.c so->so_pcb = rp;
so 116 net/rtsock.c bzero(so->so_pcb, sizeof(*rp));
so 136 net/rtsock.c error = raw_attach(so, (int)(long)nam);
so 138 net/rtsock.c error = raw_usrreq(so, req, m, nam, control);
so 140 net/rtsock.c rp = sotorawcb(so);
so 154 net/rtsock.c soisconnected(so);
so 155 net/rtsock.c so->so_options |= SO_USELOOPBACK;
so 173 net/rtsock.c struct socket *so;
so 181 net/rtsock.c so = va_arg(ap, struct socket *);
so 456 net/rtsock.c if (!(so->so_options & SO_USELOOPBACK)) {
so 464 net/rtsock.c rp = sotorawcb(so);
so 102 netatalk/ddp_usrreq.c ddp_usrreq( so, req, m, addr, rights )
so 103 netatalk/ddp_usrreq.c struct socket *so;
so 112 netatalk/ddp_usrreq.c ddp = sotoddpcb( so );
so 135 netatalk/ddp_usrreq.c if (( error = at_pcballoc( so )) != 0 ) {
so 138 netatalk/ddp_usrreq.c error = soreserve( so, ddp_sendspace, ddp_recvspace );
so 142 netatalk/ddp_usrreq.c at_pcbdetach( so, ddp );
so 161 netatalk/ddp_usrreq.c soisconnected( so );
so 170 netatalk/ddp_usrreq.c soisdisconnected( so );
so 174 netatalk/ddp_usrreq.c socantsendmore( so );
so 209 netatalk/ddp_usrreq.c soisdisconnected( so );
so 210 netatalk/ddp_usrreq.c at_pcbdetach( so, ddp );
so 467 netatalk/ddp_usrreq.c at_pcballoc( so )
so 468 netatalk/ddp_usrreq.c struct socket *so;
so 489 netatalk/ddp_usrreq.c ddp->ddp_socket = so;
so 490 netatalk/ddp_usrreq.c so->so_pcb = (caddr_t)ddp;
so 495 netatalk/ddp_usrreq.c at_pcbdetach( so, ddp )
so 496 netatalk/ddp_usrreq.c struct socket *so;
so 499 netatalk/ddp_usrreq.c soisdisconnected( so );
so 500 netatalk/ddp_usrreq.c so->so_pcb = 0;
so 501 netatalk/ddp_usrreq.c sofree( so );
so 64 netatalk/ddp_var.h #define sotoddpcb(so) ((struct ddpcb *)(so)->so_pcb)
so 206 netbt/hci_socket.c struct socket *so = arg;
so 208 netbt/hci_socket.c sbdroprecord(&so->so_snd);
so 209 netbt/hci_socket.c sowwakeup(so);
so 218 netbt/hci_socket.c hci_cmdwait_flush(struct socket *so)
so 224 netbt/hci_socket.c DPRINTF("flushing %p\n", so);
so 230 netbt/hci_socket.c if (ctx == so)
so 527 netbt/hci_socket.c hci_ctloutput(int req, struct socket *so, int level,
so 530 netbt/hci_socket.c struct hci_pcb *pcb = (struct hci_pcb *)so->so_pcb;
so 267 netbt/l2cap_socket.c l2cap_ctloutput(int req, struct socket *so, int level,
so 270 netbt/l2cap_socket.c struct l2cap_channel *pcb = so->so_pcb;
so 320 netbt/l2cap_socket.c struct socket *so = arg;
so 323 netbt/l2cap_socket.c soisconnecting(so);
so 329 netbt/l2cap_socket.c struct socket *so = arg;
so 332 netbt/l2cap_socket.c soisconnected(so);
so 338 netbt/l2cap_socket.c struct socket *so = arg;
so 342 netbt/l2cap_socket.c so->so_error = err;
so 343 netbt/l2cap_socket.c soisdisconnected(so);
so 350 netbt/l2cap_socket.c struct socket *so = arg;
so 353 netbt/l2cap_socket.c so = sonewconn(so, 0);
so 354 netbt/l2cap_socket.c if (so == NULL)
so 357 netbt/l2cap_socket.c soisconnecting(so);
so 359 netbt/l2cap_socket.c return so->so_pcb;
so 365 netbt/l2cap_socket.c struct socket *so = arg;
so 368 netbt/l2cap_socket.c sbdroprecord(&so->so_snd);
so 370 netbt/l2cap_socket.c sowwakeup(so);
so 376 netbt/l2cap_socket.c struct socket *so = arg;
so 384 netbt/l2cap_socket.c (void)l2cap_getopt(so->so_pcb, SO_L2CAP_LM, &mode);
so 388 netbt/l2cap_socket.c l2cap_disconnect(so->so_pcb, 0);
so 394 netbt/l2cap_socket.c struct socket *so = arg;
so 396 netbt/l2cap_socket.c if (m->m_pkthdr.len > sbspace(&so->so_rcv)) {
so 405 netbt/l2cap_socket.c sbappendrecord(&so->so_rcv, m);
so 406 netbt/l2cap_socket.c sorwakeup(so);
so 266 netbt/rfcomm_socket.c rfcomm_ctloutput(int req, struct socket *so, int level,
so 269 netbt/rfcomm_socket.c struct rfcomm_dlc *pcb = so->so_pcb;
so 327 netbt/rfcomm_socket.c struct socket *so = arg;
so 329 netbt/rfcomm_socket.c KASSERT(so != NULL);
so 331 netbt/rfcomm_socket.c soisconnected(so);
so 337 netbt/rfcomm_socket.c struct socket *so = arg;
so 339 netbt/rfcomm_socket.c KASSERT(so != NULL);
so 342 netbt/rfcomm_socket.c so->so_error = err;
so 343 netbt/rfcomm_socket.c soisdisconnected(so);
so 350 netbt/rfcomm_socket.c struct socket *so = arg;
so 353 netbt/rfcomm_socket.c so = sonewconn(so, 0);
so 354 netbt/rfcomm_socket.c if (so == NULL)
so 357 netbt/rfcomm_socket.c soisconnecting(so);
so 359 netbt/rfcomm_socket.c return so->so_pcb;
so 370 netbt/rfcomm_socket.c struct socket *so = arg;
so 372 netbt/rfcomm_socket.c sbdrop(&so->so_snd, length);
so 373 netbt/rfcomm_socket.c sowwakeup(so);
so 384 netbt/rfcomm_socket.c struct socket *so = arg;
so 392 netbt/rfcomm_socket.c (void)rfcomm_getopt(so->so_pcb, SO_RFCOMM_LM, &mode);
so 396 netbt/rfcomm_socket.c rfcomm_disconnect(so->so_pcb, 0);
so 405 netbt/rfcomm_socket.c struct socket *so = arg;
so 407 netbt/rfcomm_socket.c KASSERT(so != NULL);
so 409 netbt/rfcomm_socket.c if (m->m_pkthdr.len > sbspace(&so->so_rcv)) {
so 418 netbt/rfcomm_socket.c sbappendstream(&so->so_rcv, m);
so 419 netbt/rfcomm_socket.c sorwakeup(so);
so 253 netbt/sco_socket.c sco_ctloutput(int req, struct socket *so, int level,
so 256 netbt/sco_socket.c struct sco_pcb *pcb = (struct sco_pcb *)so->so_pcb;
so 305 netbt/sco_socket.c struct socket *so = arg;
so 308 netbt/sco_socket.c soisconnecting(so);
so 314 netbt/sco_socket.c struct socket *so = arg;
so 317 netbt/sco_socket.c soisconnected(so);
so 323 netbt/sco_socket.c struct socket *so = arg;
so 327 netbt/sco_socket.c so->so_error = err;
so 328 netbt/sco_socket.c soisdisconnected(so);
so 335 netbt/sco_socket.c struct socket *so = arg;
so 338 netbt/sco_socket.c so = sonewconn(so, 0);
so 339 netbt/sco_socket.c if (so == NULL)
so 342 netbt/sco_socket.c soisconnecting(so);
so 343 netbt/sco_socket.c return so->so_pcb;
so 349 netbt/sco_socket.c struct socket *so = arg;
so 352 netbt/sco_socket.c sbdroprecord(&so->so_snd);
so 354 netbt/sco_socket.c sowwakeup(so);
so 365 netbt/sco_socket.c struct socket *so = arg;
so 373 netbt/sco_socket.c while (m->m_pkthdr.len > sbspace(&so->so_rcv))
so 374 netbt/sco_socket.c sbdroprecord(&so->so_rcv);
so 378 netbt/sco_socket.c sbappendrecord(&so->so_rcv, m);
so 379 netbt/sco_socket.c sorwakeup(so);
so 218 netinet/in.c in_control(so, cmd, data, ifp)
so 219 netinet/in.c struct socket *so;
so 235 netinet/in.c if ((so->so_state & SS_PRIV) == 0)
so 241 netinet/in.c return in_lifaddr_ioctl(so, cmd, data, ifp);
so 270 netinet/in.c if ((so->so_state & SS_PRIV) == 0)
so 305 netinet/in.c if ((so->so_state & SS_PRIV) == 0)
so 464 netinet/in.c return (mrt_ioctl(so, cmd, data));
so 492 netinet/in.c in_lifaddr_ioctl(so, cmd, data, ifp)
so 493 netinet/in.c struct socket *so;
so 566 netinet/in.c return in_control(so, SIOCAIFADDR, (caddr_t)&ifra, ifp);
so 651 netinet/in.c return in_control(so, SIOCDIFADDR, (caddr_t)&ifra, ifp);
so 185 netinet/in_pcb.c in_pcballoc(so, v)
so 186 netinet/in_pcb.c struct socket *so;
so 203 netinet/in_pcb.c inp->inp_socket = so;
so 214 netinet/in_pcb.c so->so_pcb = inp;
so 223 netinet/in_pcb.c if (sotopf(so) == PF_INET6)
so 236 netinet/in_pcb.c struct socket *so = inp->inp_socket;
so 242 netinet/in_pcb.c int wild = 0, reuseport = (so->so_options & SO_REUSEPORT);
so 246 netinet/in_pcb.c if (sotopf(so) == PF_INET6)
so 254 netinet/in_pcb.c if ((so->so_options & (SO_REUSEADDR|SO_REUSEPORT)) == 0 &&
so 255 netinet/in_pcb.c ((so->so_proto->pr_flags & PR_CONNREQUIRED) == 0 ||
so 256 netinet/in_pcb.c (so->so_options & SO_ACCEPTCONN) == 0))
so 279 netinet/in_pcb.c if (so->so_options & SO_REUSEADDR)
so 293 netinet/in_pcb.c if (so->so_euid) {
so 296 netinet/in_pcb.c if (t && (so->so_euid != t->inp_socket->so_euid))
so 346 netinet/in_pcb.c } while (in_baddynamic(*lastport, so->so_proto->pr_protocol) ||
so 364 netinet/in_pcb.c } while (in_baddynamic(*lastport, so->so_proto->pr_protocol) ||
so 479 netinet/in_pcb.c struct socket *so = inp->inp_socket;
so 482 netinet/in_pcb.c so->so_pcb = 0;
so 483 netinet/in_pcb.c sofree(so);
so 218 netinet/in_pcb.h #define sotoinpcb(so) ((struct inpcb *)(so)->so_pcb)
so 238 netinet/in_pcb.h #define sotopf(so) (so->so_proto->pr_domain->dom_family)
so 394 netinet/ip_mroute.c ip_mrouter_set(struct socket *so, int optname, struct mbuf **m)
so 398 netinet/ip_mroute.c if (optname != MRT_INIT && so != ip_mrouter)
so 403 netinet/ip_mroute.c error = ip_mrouter_init(so, *m);
so 446 netinet/ip_mroute.c ip_mrouter_get(struct socket *so, int optname, struct mbuf **m)
so 450 netinet/ip_mroute.c if (so != ip_mrouter)
so 484 netinet/ip_mroute.c mrt_ioctl(struct socket *so, u_long cmd, caddr_t data)
so 488 netinet/ip_mroute.c if (so != ip_mrouter)
so 553 netinet/ip_mroute.c ip_mrouter_init(struct socket *so, struct mbuf *m)
so 560 netinet/ip_mroute.c so->so_type, so->so_proto->pr_protocol);
so 562 netinet/ip_mroute.c if (so->so_type != SOCK_RAW ||
so 563 netinet/ip_mroute.c so->so_proto->pr_protocol != IPPROTO_IGMP)
so 576 netinet/ip_mroute.c ip_mrouter = so;
so 2162 netinet/ip_mroute.c ip_rsvp_vif_init(struct socket *so, struct mbuf *m)
so 2168 netinet/ip_mroute.c so->so_type, so->so_proto->pr_protocol);
so 2170 netinet/ip_mroute.c if (so->so_type != SOCK_RAW ||
so 2171 netinet/ip_mroute.c so->so_proto->pr_protocol != IPPROTO_RSVP)
so 2198 netinet/ip_mroute.c viftable[vifi].v_rsvpd = so;
so 2212 netinet/ip_mroute.c ip_rsvp_vif_done(struct socket *so, struct mbuf *m)
so 2218 netinet/ip_mroute.c so->so_type, so->so_proto->pr_protocol);
so 2220 netinet/ip_mroute.c if (so->so_type != SOCK_RAW ||
so 2221 netinet/ip_mroute.c so->so_proto->pr_protocol != IPPROTO_RSVP)
so 2240 netinet/ip_mroute.c viftable[vifi].v_rsvpd, so);
so 2257 netinet/ip_mroute.c ip_rsvp_force_done(struct socket *so)
so 2262 netinet/ip_mroute.c if (so->so_type != SOCK_RAW ||
so 2263 netinet/ip_mroute.c so->so_proto->pr_protocol != IPPROTO_RSVP)
so 2273 netinet/ip_mroute.c if (viftable[vifi].v_rsvpd == so) {
so 1027 netinet/ip_output.c ip_ctloutput(op, so, level, optname, mp)
so 1029 netinet/ip_output.c struct socket *so;
so 1033 netinet/ip_output.c struct inpcb *inp = sotoinpcb(so);
so 186 netinet/raw_ip.c struct socket *so;
so 194 netinet/raw_ip.c so = va_arg(ap, struct socket *);
so 198 netinet/raw_ip.c inp = sotoinpcb(so);
so 199 netinet/raw_ip.c flags = (so->so_options & (SO_DONTROUTE|SO_JUMBO)) | IP_ALLOWBROADCAST;
so 263 netinet/raw_ip.c rip_ctloutput(int op, struct socket *so, int level, int optname,
so 266 netinet/raw_ip.c struct inpcb *inp = sotoinpcb(so);
so 310 netinet/raw_ip.c error = ip_mrouter_set(so, optname, m);
so 313 netinet/raw_ip.c error = ip_mrouter_get(so, optname, m);
so 326 netinet/raw_ip.c return (ip_ctloutput(op, so, level, optname, m));
so 334 netinet/raw_ip.c rip_usrreq(struct socket *so, int req, struct mbuf *m, struct mbuf *nam,
so 338 netinet/raw_ip.c struct inpcb *inp = sotoinpcb(so);
so 343 netinet/raw_ip.c return (in_control(so, (u_long)m, (caddr_t)nam,
so 356 netinet/raw_ip.c if ((so->so_state & SS_PRIV) == 0) {
so 360 netinet/raw_ip.c if ((error = soreserve(so, rip_sendspace, rip_recvspace)) ||
so 361 netinet/raw_ip.c (error = in_pcballoc(so, &rawcbtable)))
so 363 netinet/raw_ip.c inp = (struct inpcb *)so->so_pcb;
so 368 netinet/raw_ip.c if ((so->so_state & SS_ISCONNECTED) == 0) {
so 374 netinet/raw_ip.c soisdisconnected(so);
so 380 netinet/raw_ip.c if (so == ip_mrouter)
so 423 netinet/raw_ip.c soisconnected(so);
so 435 netinet/raw_ip.c socantsendmore(so);
so 446 netinet/raw_ip.c if (so->so_state & SS_ISCONNECTED) {
so 462 netinet/raw_ip.c error = rip_output(m, so, dst);
so 197 netinet/tcp_input.c struct socket *so = tp->t_inpcb->inp_socket;
so 314 netinet/tcp_input.c if (so->so_state & SS_CANTRCVMORE)
so 317 netinet/tcp_input.c sbappendstream(&so->so_rcv, q->tcpqe_m);
so 321 netinet/tcp_input.c sorwakeup(so);
so 377 netinet/tcp_input.c struct socket *so = NULL;
so 653 netinet/tcp_input.c so = inp->inp_socket;
so 654 netinet/tcp_input.c if (so->so_options & (SO_DEBUG|SO_ACCEPTCONN)) {
so 691 netinet/tcp_input.c if (so->so_options & SO_DEBUG) {
so 706 netinet/tcp_input.c if (so->so_options & SO_ACCEPTCONN) {
so 719 netinet/tcp_input.c so = syn_cache_get(&src.sa, &dst.sa,
so 720 netinet/tcp_input.c th, iphlen, tlen, so, m);
so 721 netinet/tcp_input.c if (so == NULL) {
so 727 netinet/tcp_input.c } else if (so ==
so 746 netinet/tcp_input.c inp = (struct inpcb *)so->so_pcb;
so 755 netinet/tcp_input.c tcp_rscale(tp, so->so_rcv.sb_hiwat);
so 847 netinet/tcp_input.c if (so->so_qlen <= so->so_qlimit &&
so 849 netinet/tcp_input.c so, m, optp, optlen, &opti, reuse))
so 1017 netinet/tcp_input.c sbdrop(&so->so_snd, acked);
so 1068 netinet/tcp_input.c if (sb_notify(&so->so_snd))
so 1069 netinet/tcp_input.c sowwakeup(so);
so 1070 netinet/tcp_input.c if (so->so_snd.sb_cc)
so 1076 netinet/tcp_input.c tlen <= sbspace(&so->so_rcv)) {
so 1096 netinet/tcp_input.c if (so->so_state & SS_CANTRCVMORE)
so 1100 netinet/tcp_input.c sbappendstream(&so->so_rcv, m);
so 1102 netinet/tcp_input.c sorwakeup(so);
so 1123 netinet/tcp_input.c win = sbspace(&so->so_rcv);
so 1220 netinet/tcp_input.c soisconnected(so);
so 1375 netinet/tcp_input.c if ((so->so_state & SS_NOFDREF) &&
so 1448 netinet/tcp_input.c so->so_error = ECONNREFUSED;
so 1455 netinet/tcp_input.c so->so_error = ECONNRESET;
so 1498 netinet/tcp_input.c soisconnected(so);
so 1837 netinet/tcp_input.c if (acked > so->so_snd.sb_cc) {
so 1838 netinet/tcp_input.c tp->snd_wnd -= so->so_snd.sb_cc;
so 1839 netinet/tcp_input.c sbdrop(&so->so_snd, (int)so->so_snd.sb_cc);
so 1842 netinet/tcp_input.c sbdrop(&so->so_snd, acked);
so 1846 netinet/tcp_input.c if (sb_notify(&so->so_snd))
so 1847 netinet/tcp_input.c sowwakeup(so);
so 1900 netinet/tcp_input.c if (so->so_state & SS_CANTRCVMORE) {
so 1901 netinet/tcp_input.c soisdisconnected(so);
so 1919 netinet/tcp_input.c soisdisconnected(so);
so 1979 netinet/tcp_input.c if (th->th_urp + so->so_rcv.sb_cc > sb_max) {
so 2000 netinet/tcp_input.c so->so_oobmark = so->so_rcv.sb_cc +
so 2002 netinet/tcp_input.c if (so->so_oobmark == 0)
so 2003 netinet/tcp_input.c so->so_state |= SS_RCVATMARK;
so 2004 netinet/tcp_input.c sohasoutofband(so);
so 2015 netinet/tcp_input.c && (so->so_options & SO_OOBINLINE) == 0
so 2018 netinet/tcp_input.c tcp_pulloutofband(so, th->th_urp, m, hdroptlen);
so 2053 netinet/tcp_input.c if (so->so_state & SS_CANTRCVMORE)
so 2057 netinet/tcp_input.c sbappendstream(&so->so_rcv, m);
so 2059 netinet/tcp_input.c sorwakeup(so);
so 2081 netinet/tcp_input.c len = so->so_rcv.sb_hiwat - (tp->rcv_adv - tp->rcv_nxt);
so 2095 netinet/tcp_input.c socantrcvmore(so);
so 2125 netinet/tcp_input.c soisdisconnected(so);
so 2136 netinet/tcp_input.c if (so->so_options & SO_DEBUG) {
so 2842 netinet/tcp_input.c tcp_pulloutofband(so, urgent, m, off)
so 2843 netinet/tcp_input.c struct socket *so;
so 2853 netinet/tcp_input.c struct tcpcb *tp = sototcpcb(so);
so 3183 netinet/tcp_input.c struct socket *so;
so 3185 netinet/tcp_input.c so = tp->t_inpcb->inp_socket;
so 3193 netinet/tcp_input.c bufsize = so->so_snd.sb_hiwat;
so 3202 netinet/tcp_input.c (void)sbreserve(&so->so_snd, bufsize);
so 3205 netinet/tcp_input.c bufsize = so->so_rcv.sb_hiwat;
so 3210 netinet/tcp_input.c (void)sbreserve(&so->so_rcv, bufsize);
so 3631 netinet/tcp_input.c syn_cache_get(src, dst, th, hlen, tlen, so, m)
so 3636 netinet/tcp_input.c struct socket *so;
so 3675 netinet/tcp_input.c oso = so;
so 3676 netinet/tcp_input.c so = sonewconn(so, SS_ISCONNECTED);
so 3677 netinet/tcp_input.c if (so == NULL)
so 3688 netinet/tcp_input.c struct inpcb *newinp = (struct inpcb *)so->so_pcb;
so 3716 netinet/tcp_input.c inp = (struct inpcb *)so->so_pcb;
so 3724 netinet/tcp_input.c inp = (struct inpcb *)so->so_pcb;
so 3801 netinet/tcp_input.c so = NULL;
so 3863 netinet/tcp_input.c return (so);
so 3868 netinet/tcp_input.c if (so != NULL)
so 3869 netinet/tcp_input.c (void) soabort(so);
so 3962 netinet/tcp_input.c syn_cache_add(src, dst, th, iphlen, so, m, optp, optlen, oi, issp)
so 3967 netinet/tcp_input.c struct socket *so;
so 3980 netinet/tcp_input.c tp = sototcpcb(so);
so 3991 netinet/tcp_input.c win = sbspace(&so->so_rcv);
so 4093 netinet/tcp_input.c so->so_rcv.sb_hiwat)
so 211 netinet/tcp_output.c struct socket *so = tp->t_inpcb->inp_socket;
so 254 netinet/tcp_output.c if (idle && soissending(so)) {
so 335 netinet/tcp_output.c if (off < so->so_snd.sb_cc)
so 347 netinet/tcp_output.c len = ulmin(so->so_snd.sb_cc, win) - off;
so 390 netinet/tcp_output.c txmaxseg = ulmin(so->so_snd.sb_hiwat / 2, tp->t_maxseg);
so 396 netinet/tcp_output.c if (off + len < so->so_snd.sb_cc)
so 399 netinet/tcp_output.c win = sbspace(&so->so_rcv);
so 415 netinet/tcp_output.c len + off >= so->so_snd.sb_cc && !soissending(so))
so 447 netinet/tcp_output.c if (2 * adv >= (long) so->so_rcv.sb_hiwat)
so 504 netinet/tcp_output.c if (so->so_snd.sb_cc && TCP_TIMER_ISARMED(tp, TCPT_REXMT) == 0 &&
so 696 netinet/tcp_output.c if ((m = m_copypack(so->so_snd.sb_mb, off,
so 722 netinet/tcp_output.c m_copydata(so->so_snd.sb_mb, off, (int) len,
so 726 netinet/tcp_output.c m->m_next = m_copy(so->so_snd.sb_mb, off, (int) len);
so 740 netinet/tcp_output.c if (off + len == so->so_snd.sb_cc && !soissending(so))
so 870 netinet/tcp_output.c if (win < (long)(so->so_rcv.sb_hiwat / 4) && win < (long)tp->t_maxseg)
so 1039 netinet/tcp_output.c if (so->so_options & SO_DEBUG)
so 1087 netinet/tcp_output.c (so->so_options & SO_DONTROUTE),
so 1109 netinet/tcp_output.c (so->so_options & SO_DONTROUTE), NULL, NULL,
so 539 netinet/tcp_subr.c struct socket *so = tp->t_inpcb->inp_socket;
so 549 netinet/tcp_subr.c so->so_error = errno;
so 563 netinet/tcp_subr.c struct socket *so = inp->inp_socket;
so 593 netinet/tcp_subr.c soisdisconnected(so);
so 668 netinet/tcp_subr.c struct socket *so = inp->inp_socket;
so 683 netinet/tcp_subr.c so->so_error = error;
so 686 netinet/tcp_subr.c wakeup((caddr_t) &so->so_timeo);
so 687 netinet/tcp_subr.c sorwakeup(so);
so 688 netinet/tcp_subr.c sowwakeup(so);
so 129 netinet/tcp_usrreq.c tcp6_usrreq(so, req, m, nam, control, p)
so 130 netinet/tcp_usrreq.c struct socket *so;
so 136 netinet/tcp_usrreq.c return tcp_usrreq(so, req, m, nam, control);
so 147 netinet/tcp_usrreq.c tcp_usrreq(so, req, m, nam, control)
so 148 netinet/tcp_usrreq.c struct socket *so;
so 161 netinet/tcp_usrreq.c if (sotopf(so) == PF_INET6)
so 162 netinet/tcp_usrreq.c return in6_control(so, (u_long)m, (caddr_t)nam,
so 166 netinet/tcp_usrreq.c return (in_control(so, (u_long)m, (caddr_t)nam,
so 177 netinet/tcp_usrreq.c inp = sotoinpcb(so);
so 213 netinet/tcp_usrreq.c error = tcp_attach(so);
so 216 netinet/tcp_usrreq.c if ((so->so_options & SO_LINGER) && so->so_linger == 0)
so 217 netinet/tcp_usrreq.c so->so_linger = TCP_LINGERTIME;
so 218 netinet/tcp_usrreq.c tp = sototcpcb(so);
so 323 netinet/tcp_usrreq.c so->so_state |= SS_CONNECTOUT;
so 326 netinet/tcp_usrreq.c tcp_rscale(tp, so->so_rcv.sb_hiwat);
so 328 netinet/tcp_usrreq.c soisconnecting(so);
so 390 netinet/tcp_usrreq.c if (so->so_state & SS_CANTSENDMORE)
so 392 netinet/tcp_usrreq.c socantsendmore(so);
so 409 netinet/tcp_usrreq.c if ((so->so_state & (SS_ISCONNECTED|SS_ISCONNECTING)) != 0)
so 418 netinet/tcp_usrreq.c sbappendstream(&so->so_snd, m);
so 430 netinet/tcp_usrreq.c ((struct stat *) m)->st_blksize = so->so_snd.sb_hiwat;
so 435 netinet/tcp_usrreq.c if ((so->so_oobmark == 0 &&
so 436 netinet/tcp_usrreq.c (so->so_state & SS_RCVATMARK) == 0) ||
so 437 netinet/tcp_usrreq.c so->so_options & SO_OOBINLINE ||
so 453 netinet/tcp_usrreq.c if (sbspace(&so->so_snd) < -512) {
so 466 netinet/tcp_usrreq.c sbappendstream(&so->so_snd, m);
so 467 netinet/tcp_usrreq.c tp->snd_up = tp->snd_una + so->so_snd.sb_cc;
so 494 netinet/tcp_usrreq.c if (tp && (so->so_options & SO_DEBUG))
so 501 netinet/tcp_usrreq.c tcp_ctloutput(op, so, level, optname, mp)
so 503 netinet/tcp_usrreq.c struct socket *so;
so 514 netinet/tcp_usrreq.c inp = sotoinpcb(so);
so 525 netinet/tcp_usrreq.c switch (so->so_proto->pr_domain->dom_family) {
so 528 netinet/tcp_usrreq.c error = ip6_ctloutput(op, so, level, optname, mp);
so 532 netinet/tcp_usrreq.c error = ip_ctloutput(op, so, level, optname, mp);
so 662 netinet/tcp_usrreq.c tcp_attach(so)
so 663 netinet/tcp_usrreq.c struct socket *so;
so 669 netinet/tcp_usrreq.c if (so->so_snd.sb_hiwat == 0 || so->so_rcv.sb_hiwat == 0) {
so 670 netinet/tcp_usrreq.c error = soreserve(so, tcp_sendspace, tcp_recvspace);
so 674 netinet/tcp_usrreq.c error = in_pcballoc(so, &tcbtable);
so 677 netinet/tcp_usrreq.c inp = sotoinpcb(so);
so 680 netinet/tcp_usrreq.c int nofd = so->so_state & SS_NOFDREF; /* XXX */
so 682 netinet/tcp_usrreq.c so->so_state &= ~SS_NOFDREF; /* don't free the socket yet */
so 684 netinet/tcp_usrreq.c so->so_state |= nofd;
so 712 netinet/tcp_usrreq.c struct socket *so = tp->t_inpcb->inp_socket;
so 716 netinet/tcp_usrreq.c else if ((so->so_options & SO_LINGER) && so->so_linger == 0)
so 719 netinet/tcp_usrreq.c soisdisconnecting(so);
so 720 netinet/tcp_usrreq.c sbflush(&so->so_rcv);
so 204 netinet/tcp_var.h #define sototcpcb(so) (intotcpcb(sotoinpcb(so)))
so 669 netinet/tcp_var.h struct socket *so, struct mbuf *);
so 991 netinet/udp_usrreq.c udp6_usrreq(so, req, m, addr, control, p)
so 992 netinet/udp_usrreq.c struct socket *so;
so 998 netinet/udp_usrreq.c return udp_usrreq(so, req, m, addr, control);
so 1004 netinet/udp_usrreq.c udp_usrreq(so, req, m, addr, control)
so 1005 netinet/udp_usrreq.c struct socket *so;
so 1009 netinet/udp_usrreq.c struct inpcb *inp = sotoinpcb(so);
so 1016 netinet/udp_usrreq.c return (in6_control(so, (u_long)m, (caddr_t)addr,
so 1020 netinet/udp_usrreq.c return (in_control(so, (u_long)m, (caddr_t)addr,
so 1039 netinet/udp_usrreq.c error = in_pcballoc(so, &udbtable);
so 1043 netinet/udp_usrreq.c error = soreserve(so, udp_sendspace, udp_recvspace);
so 1047 netinet/udp_usrreq.c if (((struct inpcb *)so->so_pcb)->inp_flags & INP_IPV6)
so 1048 netinet/udp_usrreq.c ((struct inpcb *) so->so_pcb)->inp_ipv6.ip6_hlim =
so 1052 netinet/udp_usrreq.c ((struct inpcb *) so->so_pcb)->inp_ip.ip_ttl = ip_defttl;
so 1097 netinet/udp_usrreq.c soisconnected(so);
so 1134 netinet/udp_usrreq.c so->so_state &= ~SS_ISCONNECTED; /* XXX */
so 1138 netinet/udp_usrreq.c socantsendmore(so);
so 1152 netinet/udp_usrreq.c soisdisconnected(so);
so 2663 netinet6/icmp6.c icmp6_ctloutput(op, so, level, optname, mp)
so 2665 netinet6/icmp6.c struct socket *so;
so 2671 netinet6/icmp6.c struct in6pcb *in6p = sotoin6pcb(so);
so 324 netinet6/in6.c in6_control(so, cmd, data, ifp, p)
so 325 netinet6/in6.c struct socket *so;
so 338 netinet6/in6.c if ((so->so_state & SS_PRIV) != 0)
so 390 netinet6/in6.c return in6_lifaddr_ioctl(so, cmd, data, ifp, p);
so 1364 netinet6/in6.c in6_lifaddr_ioctl(so, cmd, data, ifp, p)
so 1365 netinet6/in6.c struct socket *so;
so 1476 netinet6/in6.c return in6_control(so, SIOCAIFADDR_IN6, (caddr_t)&ifra, ifp, p);
so 1571 netinet6/in6.c return in6_control(so, SIOCDIFADDR_IN6, (caddr_t)&ifra,
so 169 netinet6/in6_pcb.c struct socket *so = inp->inp_socket;
so 175 netinet6/in6_pcb.c int wild = INPLOOKUP_IPV6, reuseport = (so->so_options & SO_REUSEPORT);
so 188 netinet6/in6_pcb.c if ((so->so_options & (SO_REUSEADDR | SO_REUSEPORT)) == 0 &&
so 189 netinet6/in6_pcb.c ((so->so_proto->pr_flags & PR_CONNREQUIRED) == 0 ||
so 190 netinet6/in6_pcb.c (so->so_options & SO_ACCEPTCONN) == 0))
so 228 netinet6/in6_pcb.c if (so->so_options & SO_REUSEADDR)
so 307 netinet6/in6_pcb.c struct socket *so = inp->inp_socket;
so 318 netinet6/in6_pcb.c if ((so->so_options & (SO_REUSEADDR|SO_REUSEPORT)) == 0 &&
so 319 netinet6/in6_pcb.c ((so->so_proto->pr_flags & PR_CONNREQUIRED) == 0 ||
so 320 netinet6/in6_pcb.c (so->so_options & SO_ACCEPTCONN) == 0))
so 359 netinet6/in6_pcb.c } while (in_baddynamic(*lastport, so->so_proto->pr_protocol) ||
so 377 netinet6/in6_pcb.c } while (in_baddynamic(*lastport, so->so_proto->pr_protocol) ||
so 260 netinet6/ip6_mroute.c ip6_mrouter_set(cmd, so, m)
so 262 netinet6/ip6_mroute.c struct socket *so;
so 265 netinet6/ip6_mroute.c if (cmd != MRT6_INIT && so != ip6_mrouter)
so 275 netinet6/ip6_mroute.c return (ip6_mrouter_init(so, *mtod(m, int *), cmd));
so 307 netinet6/ip6_mroute.c ip6_mrouter_get(cmd, so, m)
so 309 netinet6/ip6_mroute.c struct socket *so;
so 314 netinet6/ip6_mroute.c if (so != ip6_mrouter) return EACCES;
so 425 netinet6/ip6_mroute.c ip6_mrouter_init(so, v, cmd)
so 426 netinet6/ip6_mroute.c struct socket *so;
so 434 netinet6/ip6_mroute.c so->so_type, so->so_proto->pr_protocol);
so 437 netinet6/ip6_mroute.c if (so->so_type != SOCK_RAW ||
so 438 netinet6/ip6_mroute.c so->so_proto->pr_protocol != IPPROTO_ICMPV6)
so 447 netinet6/ip6_mroute.c ip6_mrouter = so;
so 1254 netinet6/ip6_output.c ip6_ctloutput(op, so, level, optname, mp)
so 1256 netinet6/ip6_output.c struct socket *so;
so 1262 netinet6/ip6_output.c struct inpcb *inp = sotoinpcb(so);
so 1277 netinet6/ip6_output.c uproto = (int)so->so_proto->pr_protocol;
so 1286 netinet6/ip6_output.c m, so);
so 1796 netinet6/ip6_output.c if (!(so->so_state & SS_ISCONNECTED))
so 1939 netinet6/ip6_output.c ip6_raw_ctloutput(op, so, level, optname, mp)
so 1941 netinet6/ip6_output.c struct socket *so;
so 1947 netinet6/ip6_output.c struct inpcb *inp = sotoinpcb(so);
so 1978 netinet6/ip6_output.c } else if (so->so_proto->pr_protocol == IPPROTO_ICMPV6) {
so 1986 netinet6/ip6_output.c if (so->so_proto->pr_protocol == IPPROTO_ICMPV6)
so 2019 netinet6/ip6_output.c ip6_pcbopts(pktopt, m, so)
so 2022 netinet6/ip6_output.c struct socket *so;
so 2049 netinet6/ip6_output.c so->so_proto->pr_protocol)) != 0) {
so 363 netinet6/raw_ip6.c struct socket *so;
so 379 netinet6/raw_ip6.c so = va_arg(ap, struct socket *);
so 384 netinet6/raw_ip6.c in6p = sotoin6pcb(so);
so 387 netinet6/raw_ip6.c if ((so->so_state & SS_PRIV) != 0)
so 393 netinet6/raw_ip6.c priv, so->so_proto->pr_protocol)) != 0)
so 403 netinet6/raw_ip6.c if (so->so_proto->pr_protocol == IPPROTO_ICMPV6) {
so 464 netinet6/raw_ip6.c if (so->so_proto->pr_protocol == IPPROTO_ICMPV6 ||
so 472 netinet6/raw_ip6.c if (so->so_proto->pr_protocol == IPPROTO_ICMPV6)
so 499 netinet6/raw_ip6.c if (so->so_proto->pr_protocol == IPPROTO_ICMPV6) {
so 524 netinet6/raw_ip6.c rip6_ctloutput(op, so, level, optname, mp)
so 526 netinet6/raw_ip6.c struct socket *so;
so 546 netinet6/raw_ip6.c error = ip6_mrouter_set(optname, so, *mp);
so 550 netinet6/raw_ip6.c error = ip6_mrouter_get(optname, so, mp);
so 556 netinet6/raw_ip6.c return (ip6_raw_ctloutput(op, so, level, optname, mp));
so 558 netinet6/raw_ip6.c return (ip6_ctloutput(op, so, level, optname, mp));
so 566 netinet6/raw_ip6.c return (icmp6_ctloutput(op, so, level, optname, mp));
so 579 netinet6/raw_ip6.c rip6_usrreq(so, req, m, nam, control, p)
so 580 netinet6/raw_ip6.c struct socket *so;
so 585 netinet6/raw_ip6.c struct in6pcb *in6p = sotoin6pcb(so);
so 591 netinet6/raw_ip6.c if ((so->so_state & SS_PRIV) != 0)
so 595 netinet6/raw_ip6.c return (in6_control(so, (u_long)m, (caddr_t)nam,
so 607 netinet6/raw_ip6.c if ((error = soreserve(so, rip6_sendspace, rip6_recvspace)) != 0) {
so 611 netinet6/raw_ip6.c if ((error = in_pcballoc(so, &rawin6pcbtable)) != 0)
so 617 netinet6/raw_ip6.c in6p = sotoin6pcb(so);
so 632 netinet6/raw_ip6.c if ((so->so_state & SS_ISCONNECTED) == 0) {
so 637 netinet6/raw_ip6.c so->so_state &= ~SS_ISCONNECTED; /* XXX */
so 641 netinet6/raw_ip6.c soisdisconnected(so);
so 647 netinet6/raw_ip6.c if (so == ip6_mrouter)
so 748 netinet6/raw_ip6.c soisconnected(so);
so 760 netinet6/raw_ip6.c socantsendmore(so);
so 772 netinet6/raw_ip6.c if (so->so_state & SS_ISCONNECTED) {
so 808 netinet6/raw_ip6.c error = rip6_output(m, so, dst, control);
so 71 netnatm/natm.c int natm_usrreq(so, req, m, nam, control)
so 73 netnatm/natm.c int natm_usrreq(so, req, m, nam, control)
so 75 netnatm/natm.c struct socket *so;
so 89 netnatm/natm.c int proto = so->so_proto->pr_protocol;
so 93 netnatm/natm.c npcb = (struct natmpcb *) so->so_pcb;
so 109 netnatm/natm.c if (so->so_snd.sb_hiwat == 0 || so->so_rcv.sb_hiwat == 0) {
so 111 netnatm/natm.c error = soreserve(so, natm5_sendspace, natm5_recvspace);
so 113 netnatm/natm.c error = soreserve(so, natm0_sendspace, natm0_recvspace);
so 118 netnatm/natm.c so->so_pcb = (caddr_t) (npcb = npcb_alloc(M_WAITOK));
so 119 netnatm/natm.c npcb->npcb_socket = so;
so 130 netnatm/natm.c so->so_pcb = NULL;
so 131 netnatm/natm.c sofree(so);
so 201 netnatm/natm.c soisconnected(so);
so 228 netnatm/natm.c soisdisconnected(so);
so 233 netnatm/natm.c socantsendmore(so);
so 346 netnatm/natm.c struct socket *so;
so 362 netnatm/natm.c so = npcb->npcb_socket;
so 388 netnatm/natm.c if (sbspace(&so->so_rcv) > m->m_pkthdr.len ||
so 389 netnatm/natm.c ((npcb->npcb_flags & NPCB_RAW) != 0 && so->so_rcv.sb_cc < NPCB_RAWCC) ) {
so 394 netnatm/natm.c sbappendrecord(&so->so_rcv, m);
so 395 netnatm/natm.c sorwakeup(so);
so 196 nfs/krpc_subr.c struct socket *so;
so 222 nfs/krpc_subr.c if ((error = socreate(AF_INET, &so, SOCK_DGRAM, 0)))
so 230 nfs/krpc_subr.c if ((error = sosetopt(so, SOL_SOCKET, SO_RCVTIMEO, m)))
so 242 nfs/krpc_subr.c if ((error = sosetopt(so, SOL_SOCKET, SO_BROADCAST, m)))
so 261 nfs/krpc_subr.c error = sosetopt(so, IPPROTO_IP, IP_PORTRANGE, mopt);
so 271 nfs/krpc_subr.c error = sobind(so, m);
so 282 nfs/krpc_subr.c error = sosetopt(so, IPPROTO_IP, IP_PORTRANGE, mopt);
so 341 nfs/krpc_subr.c error = sosend(so, nam, NULL, m, NULL, 0);
so 373 nfs/krpc_subr.c error = soreceive(so, &from, &auio, &m, NULL, &rcvflg);
so 450 nfs/krpc_subr.c soclose(so);
so 127 nfs/nfs_boot.c struct socket *so;
so 164 nfs/nfs_boot.c if ((error = socreate(AF_INET, &so, SOCK_DGRAM, 0)) != 0)
so 166 nfs/nfs_boot.c error = ifioctl(so, SIOCGIFFLAGS, (caddr_t)&ireq, procp);
so 170 nfs/nfs_boot.c error = ifioctl(so, SIOCSIFFLAGS, (caddr_t)&ireq, procp);
so 190 nfs/nfs_boot.c error = ifioctl(so, SIOCSIFADDR, (caddr_t)&ireq, procp);
so 194 nfs/nfs_boot.c soclose(so);
so 151 nfs/nfs_socket.c struct socket *so;
so 163 nfs/nfs_socket.c so = nmp->nm_so;
so 164 nfs/nfs_socket.c nmp->nm_soflags = so->so_proto->pr_flags;
so 179 nfs/nfs_socket.c error = sosetopt(so, IPPROTO_IP, IP_PORTRANGE, mopt);
so 189 nfs/nfs_socket.c error = sobind(so, m);
so 198 nfs/nfs_socket.c error = sosetopt(so, IPPROTO_IP, IP_PORTRANGE, mopt);
so 213 nfs/nfs_socket.c error = soconnect(so, nmp->nm_nam);
so 223 nfs/nfs_socket.c while ((so->so_state & SS_ISCONNECTING) && so->so_error == 0) {
so 224 nfs/nfs_socket.c (void) tsleep((caddr_t)&so->so_timeo, PSOCK,
so 226 nfs/nfs_socket.c if ((so->so_state & SS_ISCONNECTING) &&
so 227 nfs/nfs_socket.c so->so_error == 0 && rep &&
so 229 nfs/nfs_socket.c so->so_state &= ~SS_ISCONNECTING;
so 234 nfs/nfs_socket.c if (so->so_error) {
so 235 nfs/nfs_socket.c error = so->so_error;
so 236 nfs/nfs_socket.c so->so_error = 0;
so 246 nfs/nfs_socket.c so->so_rcv.sb_timeo = (5 * hz);
so 248 nfs/nfs_socket.c so->so_snd.sb_timeo = (5 * hz);
so 250 nfs/nfs_socket.c so->so_snd.sb_timeo = 0;
so 262 nfs/nfs_socket.c if (so->so_proto->pr_flags & PR_CONNREQUIRED) {
so 266 nfs/nfs_socket.c sosetopt(so, SOL_SOCKET, SO_KEEPALIVE, m);
so 268 nfs/nfs_socket.c if (so->so_proto->pr_protocol == IPPROTO_TCP) {
so 272 nfs/nfs_socket.c sosetopt(so, IPPROTO_TCP, TCP_NODELAY, m);
so 279 nfs/nfs_socket.c error = soreserve(so, sndreserve, rcvreserve);
so 282 nfs/nfs_socket.c so->so_rcv.sb_flags |= SB_NOINTR;
so 283 nfs/nfs_socket.c so->so_snd.sb_flags |= SB_NOINTR;
so 344 nfs/nfs_socket.c struct socket *so;
so 347 nfs/nfs_socket.c so = nmp->nm_so;
so 349 nfs/nfs_socket.c soshutdown(so, SHUT_RDWR);
so 350 nfs/nfs_socket.c soclose(so);
so 368 nfs/nfs_socket.c nfs_send(so, nam, top, rep)
so 369 nfs/nfs_socket.c struct socket *so;
so 382 nfs/nfs_socket.c if ((so = rep->r_nmp->nm_so) == NULL) {
so 390 nfs/nfs_socket.c soflags = so->so_proto->pr_flags;
so 391 nfs/nfs_socket.c if ((soflags & PR_CONNREQUIRED) || (so->so_state & SS_ISCONNECTED))
so 395 nfs/nfs_socket.c if (so->so_type == SOCK_SEQPACKET)
so 400 nfs/nfs_socket.c error = sosend(so, sendnam, (struct uio *)0, top,
so 439 nfs/nfs_socket.c struct socket *so;
so 482 nfs/nfs_socket.c so = rep->r_nmp->nm_so;
so 483 nfs/nfs_socket.c if (!so) {
so 496 nfs/nfs_socket.c error = nfs_send(so, rep->r_nmp->nm_nam, m, rep);
so 519 nfs/nfs_socket.c error = soreceive(so, (struct mbuf **)0, &auio,
so 563 nfs/nfs_socket.c error = soreceive(so, (struct mbuf **)0,
so 587 nfs/nfs_socket.c error = soreceive(so, (struct mbuf **)0,
so 621 nfs/nfs_socket.c if ((so = rep->r_nmp->nm_so) == NULL)
so 623 nfs/nfs_socket.c if (so->so_state & SS_ISCONNECTED)
so 631 nfs/nfs_socket.c error = soreceive(so, getnam, &auio, mp,
so 1224 nfs/nfs_socket.c struct socket *so;
so 1277 nfs/nfs_socket.c if ((so = nmp->nm_so) == NULL)
so 1286 nfs/nfs_socket.c if (sbspace(&so->so_snd) >= rep->r_mreq->m_pkthdr.len &&
so 1292 nfs/nfs_socket.c error = (*so->so_proto->pr_usrreq)(so, PRU_SEND, m,
so 1295 nfs/nfs_socket.c error = (*so->so_proto->pr_usrreq)(so, PRU_SEND, m,
so 1299 nfs/nfs_socket.c so->so_error = 0;
so 1816 nfs/nfs_socket.c nfsrv_rcv(so, arg, waitflag)
so 1817 nfs/nfs_socket.c struct socket *so;
so 1838 nfs/nfs_socket.c if (so->so_type == SOCK_STREAM) {
so 1854 nfs/nfs_socket.c error = soreceive(so, &nam, &auio, &mp, (struct mbuf **)0, &flags);
so 1888 nfs/nfs_socket.c error = soreceive(so, &nam, &auio, &mp,
so 1904 nfs/nfs_socket.c if ((so->so_proto->pr_flags & PR_CONNREQUIRED)
so 205 nfs/nfs_syscalls.c struct socket *so;
so 209 nfs/nfs_syscalls.c so = (struct socket *)fp->f_data;
so 214 nfs/nfs_syscalls.c if (so->so_proto->pr_protocol == IPPROTO_UDP) {
so 221 nfs/nfs_syscalls.c if (so->so_type == SOCK_STREAM)
so 225 nfs/nfs_syscalls.c error = soreserve(so, siz, siz);
so 236 nfs/nfs_syscalls.c if (so->so_type == SOCK_STREAM) {
so 240 nfs/nfs_syscalls.c sosetopt(so, SOL_SOCKET, SO_KEEPALIVE, m);
so 242 nfs/nfs_syscalls.c if (so->so_proto->pr_domain->dom_family == AF_INET &&
so 243 nfs/nfs_syscalls.c so->so_proto->pr_protocol == IPPROTO_TCP) {
so 247 nfs/nfs_syscalls.c sosetopt(so, IPPROTO_TCP, TCP_NODELAY, m);
so 249 nfs/nfs_syscalls.c so->so_rcv.sb_flags &= ~SB_NOINTR;
so 250 nfs/nfs_syscalls.c so->so_rcv.sb_timeo = 0;
so 251 nfs/nfs_syscalls.c so->so_snd.sb_flags &= ~SB_NOINTR;
so 252 nfs/nfs_syscalls.c so->so_snd.sb_timeo = 0;
so 262 nfs/nfs_syscalls.c slp->ns_so = so;
so 267 nfs/nfs_syscalls.c so->so_upcallarg = (caddr_t)slp;
so 268 nfs/nfs_syscalls.c so->so_upcall = nfsrv_rcv;
so 288 nfs/nfs_syscalls.c struct socket *so;
so 384 nfs/nfs_syscalls.c so = slp->ns_so;
so 385 nfs/nfs_syscalls.c sotype = so->so_type;
so 386 nfs/nfs_syscalls.c if (so->so_proto->pr_flags & PR_CONNREQUIRED)
so 477 nfs/nfs_syscalls.c error = nfs_send(so, nd->nd_nam2, m, NULL);
so 557 nfs/nfs_syscalls.c struct socket *so;
so 567 nfs/nfs_syscalls.c so = slp->ns_so;
so 568 nfs/nfs_syscalls.c so->so_upcall = NULL;
so 569 nfs/nfs_syscalls.c soshutdown(so, SHUT_RDWR);
so 106 sys/socketvar.h void (*so_upcall)(struct socket *so, caddr_t arg, int waitf);
so 160 sys/socketvar.h #define sosendallatonce(so) \
so 161 sys/socketvar.h ((so)->so_proto->pr_flags & PR_ATOMIC)
so 164 sys/socketvar.h #define soissending(so) \
so 165 sys/socketvar.h ((so)->so_state & SS_ISSENDING)
so 168 sys/socketvar.h #define soreadable(so) \
so 169 sys/socketvar.h ((so)->so_rcv.sb_cc >= (so)->so_rcv.sb_lowat || \
so 170 sys/socketvar.h ((so)->so_state & SS_CANTRCVMORE) || \
so 171 sys/socketvar.h (so)->so_qlen || (so)->so_error)
so 174 sys/socketvar.h #define sowriteable(so) \
so 175 sys/socketvar.h ((sbspace(&(so)->so_snd) >= (so)->so_snd.sb_lowat && \
so 176 sys/socketvar.h (((so)->so_state&SS_ISCONNECTED) || \
so 177 sys/socketvar.h ((so)->so_proto->pr_flags&PR_CONNREQUIRED)==0)) || \
so 178 sys/socketvar.h ((so)->so_state & SS_CANTSENDMORE) || (so)->so_error)
so 218 sys/socketvar.h #define sorwakeup(so) { sowakeup((so), &(so)->so_rcv); \
so 219 sys/socketvar.h if ((so)->so_upcall) \
so 220 sys/socketvar.h (*((so)->so_upcall))((so), (so)->so_upcallarg, M_DONTWAIT); \
so 223 sys/socketvar.h #define sowwakeup(so) sowakeup((so), &(so)->so_snd)
so 277 sys/socketvar.h int soabort(struct socket *so);
so 278 sys/socketvar.h int soaccept(struct socket *so, struct mbuf *nam);
so 279 sys/socketvar.h int sobind(struct socket *so, struct mbuf *nam);
so 280 sys/socketvar.h void socantrcvmore(struct socket *so);
so 281 sys/socketvar.h void socantsendmore(struct socket *so);
so 282 sys/socketvar.h int soclose(struct socket *so);
so 283 sys/socketvar.h int soconnect(struct socket *so, struct mbuf *nam);
so 286 sys/socketvar.h int sodisconnect(struct socket *so);
so 287 sys/socketvar.h void sofree(struct socket *so);
so 288 sys/socketvar.h int sogetopt(struct socket *so, int level, int optname,
so 290 sys/socketvar.h void sohasoutofband(struct socket *so);
so 291 sys/socketvar.h void soisconnected(struct socket *so);
so 292 sys/socketvar.h void soisconnecting(struct socket *so);
so 293 sys/socketvar.h void soisdisconnected(struct socket *so);
so 294 sys/socketvar.h void soisdisconnecting(struct socket *so);
so 295 sys/socketvar.h int solisten(struct socket *so, int backlog);
so 297 sys/socketvar.h void soqinsque(struct socket *head, struct socket *so, int q);
so 298 sys/socketvar.h int soqremque(struct socket *so, int q);
so 299 sys/socketvar.h int soreceive(struct socket *so, struct mbuf **paddr, struct uio *uio,
so 301 sys/socketvar.h int soreserve(struct socket *so, u_long sndcc, u_long rcvcc);
so 302 sys/socketvar.h void sorflush(struct socket *so);
so 303 sys/socketvar.h int sosend(struct socket *so, struct mbuf *addr, struct uio *uio,
so 305 sys/socketvar.h int sosetopt(struct socket *so, int level, int optname,
so 307 sys/socketvar.h int soshutdown(struct socket *so, int how);
so 308 sys/socketvar.h void sowakeup(struct socket *so, struct sockbuf *sb);
so 51 sys/un.h int unp_attach(struct socket *so);
so 53 sys/un.h int unp_connect(struct socket *so, struct mbuf *nam, struct proc *p);
so 54 sys/un.h int unp_connect2(struct socket *so, struct socket *so2);
so 86 sys/unpcb.h #define sotounpcb(so) ((struct unpcb *)((so)->so_pcb))