HomeSort by: relevance | last modified time | path
    Searched refs:so_rcv (Results 1 - 25 of 55) sorted by relevancy

1 2 3

  /src/sys/dev/
kttcp.c 252 SBLASTRECORDCHK(&so->so_rcv,
254 SBLASTMBUFCHK(&so->so_rcv,
389 if ((error = sblock(&so->so_rcv, SBLOCKWAIT(flags))) != 0)
391 m = so->so_rcv.sb_mb;
404 so->so_rcv.sb_cc < resid) &&
405 (so->so_rcv.sb_cc < so->so_rcv.sb_lowat ||
406 ((flags & MSG_WAITALL) && resid <= so->so_rcv.sb_hiwat)) &&
409 if (m == NULL && so->so_rcv.sb_cc)
428 m = so->so_rcv.sb_mb
    [all...]
  /src/sys/netinet/
accf_http.c 218 if ((so->so_state & SS_CANTRCVMORE) == 0 && !sbfull(&so->so_rcv)) {
223 m = so->so_rcv.sb_mb;
224 cc = so->so_rcv.sb_cc - 1;
260 so->so_rcv.sb_flags &= ~SB_UPCALL;
271 if ((so->so_state & SS_CANTRCVMORE) != 0 || sbfull(&so->so_rcv))
274 m = so->so_rcv.sb_mb;
275 cc = so->so_rcv.sb_cc;
277 for (m = so->so_rcv.sb_mb; m; m = n) {
336 so->so_rcv.sb_flags |= SB_UPCALL;
342 so->so_rcv.sb_flags &= ~SB_UPCALL
    [all...]
accf_data.c 86 so->so_rcv.sb_flags &= ~SB_UPCALL;
sctp_indata.c 114 (u_long)stcb->sctp_socket->so_rcv.sb_cc,
115 (u_long)stcb->sctp_socket->so_rcv.sb_hiwat,
116 (u_long)stcb->sctp_socket->so_rcv.sb_lowat,
117 (u_long)stcb->sctp_socket->so_rcv.sb_mbcnt,
118 (u_long)stcb->sctp_socket->so_rcv.sb_mbmax);
120 sctp_sbspace(&stcb->sctp_socket->so_rcv),
126 if (stcb->sctp_socket->so_rcv.sb_cc == 0 &&
131 asoc->my_rwnd = uimax(stcb->sctp_socket->so_rcv.sb_hiwat,
136 calc = (u_int32_t)sctp_sbspace(&stcb->sctp_socket->so_rcv);
372 if (stcb->sctp_socket->so_rcv.sb_cc >= stcb->sctp_socket->so_rcv.sb_hiwat)
    [all...]
tcp_input.c 792 sbappendstream(&so->so_rcv, q->ipqe_m);
1913 tlen <= sbspace(&so->so_rcv)) {
1974 (so->so_rcv.sb_flags & SB_AUTOSIZE)) {
1978 (so->so_rcv.sb_hiwat / 8 * 7) &&
1979 so->so_rcv.sb_hiwat <
1982 uimin(so->so_rcv.sb_hiwat +
2005 if (!sbreserve(&so->so_rcv,
2007 so->so_rcv.sb_flags &= ~SB_AUTOSIZE;
2009 sbappendstream(&so->so_rcv, m);
2035 win = sbspace(&so->so_rcv);
    [all...]
sctputil.c 735 asoc->my_rwnd = uimax(m->sctp_socket->so_rcv.sb_hiwat, SCTP_MINIMAL_RWND);
736 asoc->peers_rwnd = m->sctp_socket->so_rcv.sb_hiwat;
1943 * if (sctp_sbspace(&stcb->sctp_socket->so_rcv) < m_notify->m_len) {
1951 if (!sbappendaddr_nocheck(&stcb->sctp_socket->so_rcv,
2028 if (sctp_sbspace(&stcb->sctp_socket->so_rcv) < m_notify->m_len) {
2036 if (!sbappendaddr_nocheck(&stcb->sctp_socket->so_rcv, to,
2122 if (sctp_sbspace(&stcb->sctp_socket->so_rcv) < m_notify->m_len) {
2131 if (!sbappendaddr_nocheck(&stcb->sctp_socket->so_rcv, to,
2193 if (sctp_sbspace(&stcb->sctp_socket->so_rcv) < m_notify->m_len) {
2201 if (!sbappendaddr_nocheck(&stcb->sctp_socket->so_rcv, to
    [all...]
  /src/sys/kern/
uipc_socket.c 532 so->so_rcv.sb_mowner = &prp->pr_domain->dom_mowner;
705 if (so->so_rcv.sb_hiwat)
706 (void)chgsbsize(so->so_uidinfo, &so->so_rcv.sb_hiwat, 0,
713 KASSERT(!cv_has_waiters(&so->so_rcv.sb_cv));
1218 if ((error = sblock(&so->so_rcv, SBLOCKWAIT(flags))) != 0) {
1223 m = so->so_rcv.sb_mb;
1238 so->so_rcv.sb_cc < uio->uio_resid &&
1239 (so->so_rcv.sb_cc < so->so_rcv.sb_lowat ||
1241 uio->uio_resid <= so->so_rcv.sb_hiwat)) &
    [all...]
uipc_socket2.c 206 so->so_rcv.sb_flags |= SB_UPCALL;
295 so2->so_rcv.sb_flags &= ~SB_UPCALL;
343 so->so_rcv.sb_mowner = head->so_rcv.sb_mowner;
346 if (soreserve(so, head->so_snd.sb_hiwat, head->so_rcv.sb_hiwat)) {
350 so->so_rcv.sb_lowat = head->so_rcv.sb_lowat;
351 so->so_rcv.sb_timeo = head->so_rcv.sb_timeo;
353 so->so_rcv.sb_flags |= head->so_rcv.sb_flags & (SB_AUTOSIZE | SB_ASYNC)
    [all...]
sys_socket.c 151 so->so_rcv.sb_flags |= SB_ASYNC;
154 so->so_rcv.sb_flags &= ~SB_ASYNC;
161 *(int *)data = so->so_rcv.sb_cc;
uipc_usrreq.c 368 if (sbappendaddr(&so2->so_rcv, (const struct sockaddr *)sun, m,
375 so2->so_rcv.sb_overflowed++;
423 #define rcv (&so->so_rcv)
526 #define rcv (&so2->so_rcv)
751 if (so->so_snd.sb_hiwat == 0 || so->so_rcv.sb_hiwat == 0) {
903 ub->st_blksize += so2->so_rcv.sb_cc;
1778 unp_scan(so->so_rcv.sb_mb, unp_mark, 0);
1781 unp_scan(so1->so_rcv.sb_mb, unp_mark, 0);
1784 unp_scan(so1->so_rcv.sb_mb, unp_mark, 0);
uipc_accf.c 255 so2->so_rcv.sb_flags &= ~SB_UPCALL;
  /src/sys/net/
if_gre.c 420 KASSERT((so->so_rcv.sb_flags & SB_UPCALL) == 0);
423 so->so_rcv.sb_flags |= SB_UPCALL;
429 so->so_rcv.sb_flags &= ~SB_UPCALL;
572 if ((error = sblock(&so->so_rcv, M_NOWAIT)) != 0) {
575 m = so->so_rcv.sb_mb;
581 if (so->so_rcv.sb_cc)
603 KASSERT(m == so->so_rcv.sb_mb);
604 SBLASTRECORDCHK(&so->so_rcv, "soreceive 1");
605 SBLASTMBUFCHK(&so->so_rcv, "soreceive 1");
612 sbfree(&so->so_rcv, m)
    [all...]
raw_usrreq.c 100 sbappendaddr(&last->so_rcv, src, n, NULL) == 0)
110 if (sbappendaddr(&last->so_rcv, src, m, NULL) == 0) {
  /src/sys/compat/common/
kern_uipc_socket_50.c 134 so->so_snd.sb_timeo : so->so_rcv.sb_timeo);
190 so->so_rcv.sb_timeo = optval;
  /src/sys/miscfs/fifofs/
fifo_vnops.c 170 rso->so_rcv.sb_lowat = 1;
400 selrecord(curlwp, &rso->so_rcv.sb_sel);
401 rso->so_rcv.sb_flags |= SB_NOTIFY;
465 if (sb_notify(&so->so_rcv)) {
466 sowakeup(so, &so->so_rcv, POLL_HUP);
595 if (selremove_knote(&so->so_rcv.sb_sel, kn))
596 so->so_rcv.sb_flags &= ~SB_KNOTE;
609 kn->kn_data = so->so_rcv.sb_cc;
615 rv = (kn->kn_data >= so->so_rcv.sb_lowat);
685 sb = &so->so_rcv;
    [all...]
  /src/sys/sys/
socketvar.h 169 struct sockbuf so_rcv; /* receive buffer */ member in struct:socket
401 * How much space is there in a socket buffer (so->so_snd or so->so_rcv)?
455 return so->so_rcv.sb_cc >= so->so_rcv.sb_lowat ||
506 if (sb_notify(&so->so_rcv))
507 sowakeup(so, &so->so_rcv, POLL_IN);
  /src/sys/netbt/
sco_socket.c 454 while (m->m_pkthdr.len > sbspace(&so->so_rcv))
455 sbdroprecord(&so->so_rcv);
459 sbappendrecord(&so->so_rcv, m);
rfcomm_socket.c 111 error = rfcomm_rcvd_pcb(so->so_pcb, sbspace(&so->so_rcv));
297 return rfcomm_rcvd_pcb(pcb, sbspace(&so->so_rcv));
497 if (m->m_pkthdr.len > sbspace(&so->so_rcv)) {
506 sbappendstream(&so->so_rcv, m);
l2cap_socket.c 479 if (m->m_pkthdr.len > sbspace(&so->so_rcv)) {
488 sbappendrecord(&so->so_rcv, m);
  /src/sys/netipsec/
keysock.c 197 ok = sbappendaddr(&rp->rcb_socket->so_rcv,
200 ok = sbappendaddrchain(&rp->rcb_socket->so_rcv,
211 rp->rcb_socket->so_rcv.sb_overflowed++;
239 * even if the socket is at or above its so->so_rcv.sb_max limits.
240 * The only constraint is that the so_rcv data fall below
313 if (kso->so_rcv.sb_cc <= key_registered_sb_max)
319 kso->so_rcv.sb_cc,
  /src/sys/netcan/
can.c 389 if (sbappendaddr(&canp->canp_socket->so_rcv,
439 so->so_rcv.sb_mowner = &can_rx_mowner;
442 if (so->so_snd.sb_hiwat == 0 || so->so_rcv.sb_hiwat == 0) {
723 so->so_rcv.sb_mowner = &can_rx_mowner;
726 if (so->so_snd.sb_hiwat == 0 || so->so_rcv.sb_hiwat == 0) {
  /src/sys/rump/net/lib/libsockin/
sockin.c 294 if (!sbappendaddr(&so->so_rcv, rmsg.msg_name, m, NULL)) {
298 sbappendstream(&so->so_rcv, m);
445 if (so->so_snd.sb_hiwat == 0 || so->so_rcv.sb_hiwat == 0) {
  /src/usr.bin/netstat/
atalk.c 270 printf("%-5.5s %6ld %6ld ", name, sockb.so_rcv.sb_cc,
unix.c 133 unixdomainpr0((u_long)so->so_pcb, so->so_type, so->so_rcv.sb_cc,
  /src/sys/nfs/
nfs_syscalls.c 558 so->so_rcv.sb_flags &= ~SB_NOINTR;
559 so->so_rcv.sb_timeo = 0;
581 so->so_rcv.sb_flags |= SB_UPCALL;
929 so->so_rcv.sb_flags &= ~SB_UPCALL;

Completed in 25 milliseconds

1 2 3