Lines Matching refs:so_rcv
745 so->so_rcv.sb_flags |= SB_RECV; in socreate_internal()
746 so->so_rcv.sb_so = so->so_snd.sb_so = so; in socreate_internal()
1167 selthreadclear(&so->so_rcv.sb_sel); in sofreelastref()
1168 so->so_rcv.sb_flags &= ~(SB_SEL | SB_UPCALL); in sofreelastref()
1205 selthreadclear(&so->so_rcv.sb_sel); in sofreelastref()
1206 so->so_rcv.sb_flags &= ~(SB_SEL | SB_UPCALL); in sofreelastref()
1222 so->so_rcv.sb_flags &= ~SB_UPCALL; in sofreelastref()
1250 so->so_rcv.sb_flags &= ~SB_UPCALL; in soclose_wait_locked()
3021 sbfree(&so->so_rcv, m); in soreceive_addr()
3025 so->so_rcv.sb_mb = nextrecord; in soreceive_addr()
3026 SB_EMPTY_FIXUP(&so->so_rcv); in soreceive_addr()
3027 SBLASTRECORDCHK(&so->so_rcv, "soreceive 1a"); in soreceive_addr()
3028 SBLASTMBUFCHK(&so->so_rcv, "soreceive 1a"); in soreceive_addr()
3048 sbunlock(&so->so_rcv, TRUE); /* stay locked */ in soreceive_addr()
3067 sballoc(&so->so_rcv, m); in soreceive_addr()
3069 sballoc(&so->so_rcv, m); in soreceive_addr()
3070 if (so->so_rcv.sb_mb == NULL) { in soreceive_addr()
3071 so->so_rcv.sb_lastrecord = m0; in soreceive_addr()
3072 so->so_rcv.sb_mbtail = m; in soreceive_addr()
3075 nextrecord = m->m_nextpkt = so->so_rcv.sb_mb; in soreceive_addr()
3076 so->so_rcv.sb_mb = m; in soreceive_addr()
3077 SBLASTRECORDCHK(&so->so_rcv, "soreceive 1b"); in soreceive_addr()
3078 SBLASTMBUFCHK(&so->so_rcv, "soreceive 1b"); in soreceive_addr()
3091 sbfree(&so->so_rcv, m); in soreceive_addr()
3092 if (m->m_next == NULL && so->so_rcv.sb_cc != 0) { in soreceive_addr()
3097 MFREE(m, so->so_rcv.sb_mb); in soreceive_addr()
3098 m = so->so_rcv.sb_mb; in soreceive_addr()
3102 so->so_rcv.sb_mb = nextrecord; in soreceive_addr()
3103 SB_EMPTY_FIXUP(&so->so_rcv); in soreceive_addr()
3141 struct sockbuf *sb_rcv = &so->so_rcv; in soreceive_ctl()
3207 SBLASTRECORDCHK(&so->so_rcv, "soreceive ctl"); in soreceive_ctl()
3208 SBLASTMBUFCHK(&so->so_rcv, "soreceive ctl"); in soreceive_ctl()
3291 if ((flags & MSG_DONTWAIT) == 0 && so->so_rcv.sb_cc < uio_resid(uio) && in so_should_wait()
3297 if (so->so_rcv.sb_cc < so->so_rcv.sb_lowat) { in so_should_wait()
3306 if ((flags & MSG_WAITALL) && uio_resid(uio) <= so->so_rcv.sb_hiwat) { in so_should_wait()
3376 uio_resid(uio), so->so_rcv.sb_cc, so->so_rcv.sb_lowat, in soreceive()
3377 so->so_rcv.sb_hiwat); in soreceive()
3408 struct sockbuf *sb = &so->so_rcv; in soreceive()
3558 error = sblock(&so->so_rcv, SBLOCKWAIT(flags)); in soreceive()
3571 m = so->so_rcv.sb_mb; in soreceive()
3580 SB_MB_CHECK(&so->so_rcv); in soreceive()
3598 cfil_sock_data_pending(&so->so_rcv) != 0) { in soreceive()
3612 m = so->so_rcv.sb_mb; in soreceive()
3630 SBLASTRECORDCHK(&so->so_rcv, "soreceive sbwait 1"); in soreceive()
3631 SBLASTMBUFCHK(&so->so_rcv, "soreceive sbwait 1"); in soreceive()
3632 sbunlock(&so->so_rcv, TRUE); /* keep socket locked */ in soreceive()
3653 if (so_should_wait(so, uio, so->so_rcv.sb_mb, flags)) { in soreceive()
3654 error = sbwait(&so->so_rcv); in soreceive()
3682 SBLASTRECORDCHK(&so->so_rcv, "soreceive 1"); in soreceive()
3683 SBLASTMBUFCHK(&so->so_rcv, "soreceive 1"); in soreceive()
3721 if (m != so->so_rcv.sb_mb || in soreceive()
3729 so->so_rcv.sb_lastrecord = m; in soreceive()
3738 SB_EMPTY_FIXUP(&so->so_rcv); in soreceive()
3741 SBLASTRECORDCHK(&so->so_rcv, "soreceive 2"); in soreceive()
3742 SBLASTMBUFCHK(&so->so_rcv, "soreceive 2"); in soreceive()
3793 SBLASTRECORDCHK(&so->so_rcv, "soreceive uiomove"); in soreceive()
3794 SBLASTMBUFCHK(&so->so_rcv, "soreceive uiomove"); in soreceive()
3827 if (m != so->so_rcv.sb_mb) { in soreceive()
3852 sbfree(&so->so_rcv, m); in soreceive()
3858 so->so_rcv.sb_mb = m = m->m_next; in soreceive()
3867 so->so_rcv.sb_mb = m = m->m_next; in soreceive()
3873 so->so_rcv.sb_lastrecord = m; in soreceive()
3876 so->so_rcv.sb_mb = nextrecord; in soreceive()
3877 SB_EMPTY_FIXUP(&so->so_rcv); in soreceive()
3879 SBLASTRECORDCHK(&so->so_rcv, "soreceive 3"); in soreceive()
3880 SBLASTMBUFCHK(&so->so_rcv, "soreceive 3"); in soreceive()
3909 so->so_rcv.sb_cc -= len; in soreceive()
3942 && cfil_sock_data_pending(&so->so_rcv) == 0 in soreceive()
3961 SBLASTRECORDCHK(&so->so_rcv, "soreceive sbwait 2"); in soreceive()
3962 SBLASTMBUFCHK(&so->so_rcv, "soreceive sbwait 2"); in soreceive()
3964 if (so->so_rcv.sb_mb == NULL && sbwait(&so->so_rcv)) { in soreceive()
3987 (delayed_copy_len > (so->so_rcv.sb_hiwat / 2))) { in soreceive()
3995 m = so->so_rcv.sb_mb; in soreceive()
3999 SB_MB_CHECK(&so->so_rcv); in soreceive()
4016 (void) sbdroprecord(&so->so_rcv); in soreceive()
4029 if ((so->so_options & SO_WANTMORE) && so->so_rcv.sb_cc > 0) { in soreceive()
4035 so->so_rcv.sb_mb = nextrecord; in soreceive()
4041 if (so->so_rcv.sb_mb == NULL) { in soreceive()
4042 so->so_rcv.sb_mbtail = NULL; in soreceive()
4043 so->so_rcv.sb_lastrecord = NULL; in soreceive()
4045 so->so_rcv.sb_lastrecord = nextrecord; in soreceive()
4047 SB_MB_CHECK(&so->so_rcv); in soreceive()
4049 SBLASTRECORDCHK(&so->so_rcv, "soreceive 4"); in soreceive()
4050 SBLASTMBUFCHK(&so->so_rcv, "soreceive 4"); in soreceive()
4069 sbunlock(&so->so_rcv, TRUE); /* keep socket locked */ in soreceive()
4092 sbunlock(&so->so_rcv, FALSE); /* will unlock socket */ in soreceive()
4101 so->so_rcv.sb_cc, 0, error); in soreceive()
4187 so->so_rcv.sb_cc, so->so_rcv.sb_lowat, so->so_rcv.sb_hiwat); in soreceive_list()
4260 struct sockbuf *sb = &so->so_rcv; in soreceive_list()
4305 error = sblock(&so->so_rcv, SBLOCKWAIT(flags)); in soreceive_list()
4311 m = so->so_rcv.sb_mb; in soreceive_list()
4316 (so->so_rcv.sb_cc < so->so_rcv.sb_lowat || in soreceive_list()
4325 SB_MB_CHECK(&so->so_rcv); in soreceive_list()
4355 SBLASTRECORDCHK(&so->so_rcv, "soreceive sbwait 1"); in soreceive_list()
4356 SBLASTMBUFCHK(&so->so_rcv, "soreceive sbwait 1"); in soreceive_list()
4358 sbunlock(&so->so_rcv, TRUE); /* keep socket locked */ in soreceive_list()
4361 error = sbwait(&so->so_rcv); in soreceive_list()
4369 SBLASTRECORDCHK(&so->so_rcv, "soreceive 1"); in soreceive_list()
4370 SBLASTMBUFCHK(&so->so_rcv, "soreceive 1"); in soreceive_list()
4451 sbfree(&so->so_rcv, m); in soreceive_list()
4481 so->so_rcv.sb_mb = m = ml->m_next; in soreceive_list()
4487 so->so_rcv.sb_lastrecord = m; in soreceive_list()
4490 so->so_rcv.sb_mb = nextrecord; in soreceive_list()
4491 SB_EMPTY_FIXUP(&so->so_rcv); in soreceive_list()
4493 SBLASTRECORDCHK(&so->so_rcv, "soreceive 3"); in soreceive_list()
4494 SBLASTMBUFCHK(&so->so_rcv, "soreceive 3"); in soreceive_list()
4535 so->so_rcv.sb_cc -= len; in soreceive_list()
4538 (void) sbdroprecord(&so->so_rcv); in soreceive_list()
4539 nextrecord = so->so_rcv.sb_mb; in soreceive_list()
4546 so->so_rcv.sb_mb = nextrecord; in soreceive_list()
4552 if (so->so_rcv.sb_mb == NULL) { in soreceive_list()
4553 so->so_rcv.sb_mbtail = NULL; in soreceive_list()
4554 so->so_rcv.sb_lastrecord = NULL; in soreceive_list()
4556 so->so_rcv.sb_lastrecord = nextrecord; in soreceive_list()
4558 SB_MB_CHECK(&so->so_rcv); in soreceive_list()
4560 SBLASTRECORDCHK(&so->so_rcv, "soreceive 4"); in soreceive_list()
4561 SBLASTMBUFCHK(&so->so_rcv, "soreceive 4"); in soreceive_list()
4573 sbunlock(&so->so_rcv, TRUE); /* keep socket locked */ in soreceive_list()
4589 if ((so->so_options & SO_WANTMORE) && so->so_rcv.sb_cc > 0) { in soreceive_list()
4598 sbunlock(&so->so_rcv, FALSE); /* will unlock socket */ in soreceive_list()
4783 struct sockbuf *sb = &so->so_rcv; in sorflush()
5164 &so->so_snd : &so->so_rcv; in sosetoptlock()
5202 so->so_rcv.sb_lowat = in sosetoptlock()
5203 (optval > so->so_rcv.sb_hiwat) ? in sosetoptlock()
5204 so->so_rcv.sb_hiwat : optval; in sosetoptlock()
5205 data_len = so->so_rcv.sb_cc in sosetoptlock()
5206 - so->so_rcv.sb_ctl; in sosetoptlock()
5207 if (data_len >= so->so_rcv.sb_lowat) { in sosetoptlock()
5227 so->so_rcv.sb_timeo = tv; in sosetoptlock()
6073 m1 = so->so_rcv.sb_mb; in sogetoptlock()
6084 optval = so->so_rcv.sb_cc - so->so_rcv.sb_ctl; in sogetoptlock()
6093 m1 = so->so_rcv.sb_mb; in sogetoptlock()
6129 optval = so->so_rcv.sb_hiwat; in sogetoptlock()
6137 optval = so->so_rcv.sb_lowat; in sogetoptlock()
6143 so->so_snd.sb_timeo : so->so_rcv.sb_timeo); in sogetoptlock()
6539 selwakeup(&so->so_rcv.sb_sel); in sohasoutofband()
6540 if (so->so_rcv.sb_flags & SB_KNOTE) { in sohasoutofband()
6541 KNOTE(&so->so_rcv.sb_sel.si_note, in sohasoutofband()
6581 so->so_rcv.sb_flags |= SB_SEL; in sopoll()
6582 selrecord(p, &so->so_rcv.sb_sel, wql); in sopoll()
6663 data = so->so_rcv.sb_cc - so->so_rcv.sb_ctl; in filt_soread_common()
6676 && cfil_sock_data_pending(&so->so_rcv) == 0 in filt_soread_common()
6690 int64_t lowwat = so->so_rcv.sb_lowat; in filt_soread_common()
6697 if (kn->kn_sdata > so->so_rcv.sb_hiwat) { in filt_soread_common()
6698 lowwat = so->so_rcv.sb_hiwat; in filt_soread_common()
6709 retval = (so->so_rcv.sb_cc >= lowwat); in filt_soread_common()
6737 if (KNOTE_ATTACH(&so->so_rcv.sb_sel.si_note, kn)) { in filt_sorattach()
6738 so->so_rcv.sb_flags |= SB_KNOTE; in filt_sorattach()
6751 if (so->so_rcv.sb_flags & SB_KNOTE) { in filt_sordetach()
6752 if (KNOTE_DETACH(&so->so_rcv.sb_sel.si_note, kn)) { in filt_sordetach()
6753 so->so_rcv.sb_flags &= ~SB_KNOTE; in filt_sordetach()
7033 && cfil_sock_data_pending(&so->so_rcv) == 0 in filt_sockev_common()
7451 rcv = &so->so_rcv; in sosetdefunct()
7568 rcv = &so->so_rcv; in sodefunct()
7790 if (so->so_rcv.sb_cc || so->so_snd.sb_cc) { in so_drain_extended_bk_idle()