Searched refs:so_rcv (Results 1 - 25 of 74) sorted by relevance

123

/freebsd-11-stable/sys/netinet/
H A Daccf_http.c165 if ((so->so_rcv.sb_state & SBS_CANTRCVMORE) == 0 &&
166 !sbfull(&so->so_rcv)) {
171 m = so->so_rcv.sb_mb;
172 cc = sbavail(&so->so_rcv) - 1;
215 if ((so->so_rcv.sb_state & SBS_CANTRCVMORE) != 0 || sbfull(&so->so_rcv))
218 m = so->so_rcv.sb_mb;
219 cc = sbavail(&so->so_rcv);
221 for (m = so->so_rcv.sb_mb; m; m = n) {
297 if ((so->so_rcv
[all...]
H A Dsctputil.c377 sctp_clog.x.lock.sock_lock = mtx_owned(&(inp->sctp_socket->so_rcv.sb_mtx));
378 sctp_clog.x.lock.sockrcvbuf_lock = mtx_owned(&(inp->sctp_socket->so_rcv.sb_mtx));
2851 &stcb->sctp_socket->so_rcv, 1, SCTP_READ_LOCK_NOT_HELD,
3001 &stcb->sctp_socket->so_rcv, 1,
3118 if (sctp_sbspace_failedmsgs(&stcb->sctp_socket->so_rcv) < SCTP_BUF_LEN(m_notify)) {
3137 &stcb->sctp_socket->so_rcv, 1,
3221 if (sctp_sbspace_failedmsgs(&stcb->sctp_socket->so_rcv) < SCTP_BUF_LEN(m_notify)) {
3240 &stcb->sctp_socket->so_rcv, 1, SCTP_READ_LOCK_NOT_HELD, so_locked);
3289 &stcb->sctp_socket->so_rcv, 1, SCTP_READ_LOCK_NOT_HELD, SCTP_SO_NOT_LOCKED);
3344 sb = &stcb->sctp_socket->so_rcv;
[all...]
H A Daccf_dns.c75 struct sockbuf *sb = &so->so_rcv;
H A Dtcp_reass.c232 &tp->t_inpcb->inp_socket->so_rcv,
586 sb = &tp->t_inpcb->inp_socket->so_rcv;
944 * XXXLAS: Using sbspace(so->so_rcv) instead of so->so_rcv.sb_hiwat
955 SOCKBUF_LOCK(&so->so_rcv);
956 if (so->so_rcv.sb_state & SBS_CANTRCVMORE) {
959 sbappendstream_locked(&so->so_rcv, m, 0);
988 if (tp->t_segqlen >= min((so->so_rcv.sb_hiwat / tp->t_maxseg) + 1,
1057 SOCKBUF_LOCK(&so->so_rcv);
1063 if (so->so_rcv
[all...]
H A Dtcp_input.c1531 if (V_tcp_do_autorcvbuf && (so->so_rcv.sb_flags & SB_AUTOSIZE) &&
1535 if (tp->rfbuf_cnt > (so->so_rcv.sb_hiwat / 8 * 7) &&
1536 so->so_rcv.sb_hiwat < V_tcp_autorcvbuf_max) {
1537 newsize = min(so->so_rcv.sb_hiwat +
1903 tlen <= sbspace(&so->so_rcv)) {
1942 SOCKBUF_LOCK(&so->so_rcv);
1943 if (so->so_rcv.sb_state & SBS_CANTRCVMORE) {
1951 if (!sbreserve_locked(&so->so_rcv,
1953 so->so_rcv.sb_flags &= ~SB_AUTOSIZE;
1955 sbappendstream_locked(&so->so_rcv,
[all...]
/freebsd-11-stable/sys/sys/
H A Dsocketvar.h66 * (c) locked by SOCKBUF_LOCK(&so->so_rcv).
107 struct sockbuf so_rcv, so_snd; member in struct:socket
153 #define SOCK_MTX(_so) SOCKBUF_MTX(&(_so)->so_rcv)
154 #define SOCK_LOCK(_so) SOCKBUF_LOCK(&(_so)->so_rcv)
155 #define SOCK_OWNED(_so) SOCKBUF_OWNED(&(_so)->so_rcv)
156 #define SOCK_UNLOCK(_so) SOCKBUF_UNLOCK(&(_so)->so_rcv)
157 #define SOCK_LOCK_ASSERT(_so) SOCKBUF_LOCK_ASSERT(&(_so)->so_rcv)
185 struct xsockbuf so_rcv, so_snd; member in struct:xsocket
214 (sbavail(&(so)->so_rcv) >= (so)->so_rcv
[all...]
/freebsd-11-stable/sys/kern/
H A Duipc_socket.c397 SOCKBUF_LOCK_INIT(&so->so_rcv, "so_rcv");
399 sx_init(&so->so_rcv.sb_sx, "so_rcv_sx");
401 TAILQ_INIT(&so->so_rcv.sb_aiojobq);
403 TASK_INIT(&so->so_rcv.sb_aiotask, 0, soaio_rcv, so);
447 if (so->so_rcv.sb_hiwat)
449 &so->so_rcv.sb_hiwat, 0, RLIM_INFINITY);
464 sx_destroy(&so->so_rcv.sb_sx);
466 SOCKBUF_LOCK_DESTROY(&so->so_rcv);
523 knlist_init_mtx(&so->so_rcv
[all...]
H A Dsys_socket.c175 * SOCKBUF_LOCK(&so->so_rcv) even though they are the same
183 SOCKBUF_LOCK(&so->so_rcv);
184 so->so_rcv.sb_flags |= SB_ASYNC;
185 SOCKBUF_UNLOCK(&so->so_rcv);
193 SOCKBUF_LOCK(&so->so_rcv);
194 so->so_rcv.sb_flags &= ~SB_ASYNC;
195 SOCKBUF_UNLOCK(&so->so_rcv);
204 *(int *)data = sbavail(&so->so_rcv);
239 *(int *)data = (so->so_rcv.sb_state & SBS_RCVATMARK) != 0;
300 sb = &so->so_rcv;
[all...]
H A Duipc_sockbuf.c239 SOCKBUF_LOCK_ASSERT(&so->so_rcv);
241 so->so_rcv.sb_state |= SBS_CANTRCVMORE;
243 mtx_assert(SOCKBUF_MTX(&so->so_rcv), MA_NOTOWNED);
250 SOCKBUF_LOCK(&so->so_rcv);
252 mtx_assert(SOCKBUF_MTX(&so->so_rcv), MA_NOTOWNED);
328 KASSERT(sb == &so->so_rcv,
381 SOCKBUF_LOCK(&so->so_rcv);
384 if (sbreserve_locked(&so->so_rcv, rcvcc, so, td) == 0)
386 if (so->so_rcv.sb_lowat == 0)
387 so->so_rcv
[all...]
H A Duipc_usrreq.c401 if (so->so_snd.sb_hiwat == 0 || so->so_rcv.sb_hiwat == 0) {
821 * so_rcv to avoid holding the so_rcv lock over the entire
824 SOCKBUF_LOCK(&so->so_rcv);
825 mbcnt = so->so_rcv.sb_mbcnt;
826 sbcc = sbavail(&so->so_rcv);
827 SOCKBUF_UNLOCK(&so->so_rcv);
915 SOCKBUF_LOCK(&so2->so_rcv);
916 if (sbappendaddr_locked(&so2->so_rcv, from, m,
922 SOCKBUF_UNLOCK(&so2->so_rcv);
[all...]
/freebsd-11-stable/sys/rpc/
H A Dsvc_dg.c138 SOCKBUF_LOCK(&so->so_rcv);
140 SOCKBUF_UNLOCK(&so->so_rcv);
198 SOCKBUF_LOCK(&xprt->xp_socket->so_rcv);
201 SOCKBUF_UNLOCK(&xprt->xp_socket->so_rcv);
207 SOCKBUF_LOCK(&xprt->xp_socket->so_rcv);
209 SOCKBUF_UNLOCK(&xprt->xp_socket->so_rcv);
274 SOCKBUF_LOCK(&xprt->xp_socket->so_rcv);
276 SOCKBUF_UNLOCK(&xprt->xp_socket->so_rcv);
H A Dsvc_vc.c186 SOCKBUF_LOCK(&so->so_rcv);
189 SOCKBUF_UNLOCK(&so->so_rcv);
267 SOCKBUF_LOCK(&so->so_rcv);
270 SOCKBUF_UNLOCK(&so->so_rcv);
362 KNOTE_UNLOCKED(&head->so_rcv.sb_sel.si_note, 0);
404 SOCKBUF_LOCK(&xprt->xp_socket->so_rcv);
409 SOCKBUF_UNLOCK(&xprt->xp_socket->so_rcv);
456 SOCKBUF_LOCK(&xprt->xp_socket->so_rcv);
461 SOCKBUF_UNLOCK(&xprt->xp_socket->so_rcv);
603 so->so_rcv
[all...]
H A Dclnt_dg.c277 sb = &so->so_rcv;
278 SOCKBUF_LOCK(&so->so_rcv);
282 SOCKBUF_UNLOCK(&so->so_rcv);
295 SOCKBUF_UNLOCK(&so->so_rcv);
297 SOCKBUF_LOCK(&so->so_rcv);
311 SOCKBUF_UNLOCK(&so->so_rcv);
358 cs = cu->cu_socket->so_rcv.sb_upcallarg;
822 cs = cu->cu_socket->so_rcv.sb_upcallarg;
955 cs = cu->cu_socket->so_rcv.sb_upcallarg;
1002 cs = cu->cu_socket->so_rcv
[all...]
H A Dclnt_vc.c266 SOCKBUF_LOCK(&ct->ct_socket->so_rcv);
268 SOCKBUF_UNLOCK(&ct->ct_socket->so_rcv);
768 SOCKBUF_LOCK(&ct->ct_socket->so_rcv);
771 SOCKBUF_UNLOCK(&ct->ct_socket->so_rcv);
875 if (sbavail(&so->so_rcv) >= sizeof(uint32_t)
876 || (so->so_rcv.sb_state & SBS_CANTRCVMORE)
883 SOCKBUF_UNLOCK(&so->so_rcv);
888 SOCKBUF_LOCK(&so->so_rcv);
928 if (sbavail(&so->so_rcv) >= ct->ct_record_resid
929 || (so->so_rcv
[all...]
/freebsd-11-stable/sys/cam/ctl/
H A Dctl_ha.c231 SOCKBUF_LOCK(&so->so_rcv);
235 msleep(&softc->ha_receiving, SOCKBUF_MTX(&so->so_rcv),
238 SOCKBUF_UNLOCK(&so->so_rcv);
259 SOCKBUF_LOCK(&softc->ha_lso->so_rcv);
260 if (softc->ha_lso->so_rcv.sb_upcall != NULL)
262 SOCKBUF_UNLOCK(&softc->ha_lso->so_rcv);
284 SOCKBUF_LOCK(&so->so_rcv);
285 while (sbavail(&so->so_rcv) < next || softc->ha_disconnect) {
288 (so->so_rcv.sb_state & SBS_CANTRCVMORE)) {
291 so->so_rcv
[all...]
/freebsd-11-stable/sys/dev/cxgb/ulp/tom/
H A Dcxgb_cpl_io.c592 struct sockbuf *so_rcv = &so->so_rcv; local
598 SOCKBUF_LOCK(so_rcv);
599 KASSERT(toep->tp_enqueued >= sbused(so_rcv),
600 ("%s: sbused(so_rcv) > enqueued", __func__));
601 toep->tp_rx_credits += toep->tp_enqueued - sbused(so_rcv);
602 toep->tp_enqueued = sbused(so_rcv);
603 SOCKBUF_UNLOCK(so_rcv);
738 SOCKBUF_LOCK_ASSERT(&so->so_rcv);
740 wnd = sbspace(&so->so_rcv);
1117 struct sockbuf *so_rcv; local
[all...]
/freebsd-11-stable/sys/dev/iscsi/
H A Dicl_soft.c782 SOCKBUF_LOCK(&so->so_rcv);
783 available = sbavail(&so->so_rcv);
785 so->so_rcv.sb_lowat = ic->ic_receive_len;
786 cv_wait(&ic->ic_receive_cv, &so->so_rcv.sb_mtx);
788 so->so_rcv.sb_lowat = so->so_rcv.sb_hiwat + 1;
789 SOCKBUF_UNLOCK(&so->so_rcv);
1239 ic->ic_socket->so_rcv.sb_flags |= SB_AUTOSIZE;
1264 SOCKBUF_LOCK(&ic->ic_socket->so_rcv);
1266 SOCKBUF_UNLOCK(&ic->ic_socket->so_rcv);
[all...]
/freebsd-11-stable/sys/net/
H A Draw_usrreq.c100 if (sbappendaddr(&last->so_rcv, src,
111 if (sbappendaddr(&last->so_rcv, src,
/freebsd-11-stable/sys/netinet6/
H A Dsend.c290 SOCKBUF_LOCK(&V_send_so->so_rcv);
291 if (sbappendaddr_locked(&V_send_so->so_rcv,
293 SOCKBUF_UNLOCK(&V_send_so->so_rcv);
/freebsd-11-stable/sys/netsmb/
H A Dsmb_trantcp.c155 SOCKBUF_LOCK(&so->so_rcv);
157 SOCKBUF_UNLOCK(&so->so_rcv);
158 so->so_rcv.sb_timeo = (5 * SBT_1S);
165 SOCKBUF_LOCK(&so->so_rcv);
166 so->so_rcv.sb_flags &= ~SB_NOINTR;
167 SOCKBUF_UNLOCK(&so->so_rcv);
354 (so->so_rcv.sb_state & SBS_CANTRCVMORE)) {
/freebsd-11-stable/sys/netinet/tcp_stacks/
H A Dfastpath.c399 SOCKBUF_LOCK(&so->so_rcv);
400 if (so->so_rcv.sb_state & SBS_CANTRCVMORE) {
408 if (!sbreserve_locked(&so->so_rcv,
410 so->so_rcv.sb_flags &= ~SB_AUTOSIZE;
412 sbappendstream_locked(&so->so_rcv, m, 0);
466 win = sbspace(&so->so_rcv);
1311 if (so->so_rcv.sb_state & SBS_CANTRCVMORE) {
1388 SOCKBUF_LOCK(&so->so_rcv);
1389 if (th->th_urp + sbavail(&so->so_rcv) > sb_max) {
1392 SOCKBUF_UNLOCK(&so->so_rcv); /* XX
[all...]
/freebsd-11-stable/sys/netnatm/
H A Dnatm.c129 if (so->so_snd.sb_hiwat == 0 || so->so_rcv.sb_hiwat == 0) {
450 if (sbspace(&so->so_rcv) > m->m_pkthdr.len) {
455 sbappendrecord(&so->so_rcv, m);
/freebsd-11-stable/usr.bin/netstat/
H A Dnetgraph.c124 name, sockb.so_rcv.sb_ccc, sockb.so_snd.sb_ccc);
/freebsd-11-stable/usr.bin/bluetooth/btsockstat/
H A Dbtsockstat.c260 so.so_rcv.sb_ccc,
308 so.so_rcv.sb_ccc,
366 so.so_rcv.sb_ccc,
472 so.so_rcv.sb_ccc,
/freebsd-11-stable/sys/netgraph/
H A Dng_ksocket.c611 SOCKBUF_LOCK(&priv->so->so_rcv);
613 SOCKBUF_UNLOCK(&priv->so->so_rcv);
945 SOCKBUF_LOCK(&priv->so->so_rcv);
947 SOCKBUF_UNLOCK(&priv->so->so_rcv);
1163 if (so->so_rcv.sb_state & SBS_CANTRCVMORE &&
1190 if (head->so_rcv.sb_state & SBS_CANTRCVMORE)
1230 /* XXX KNOTE_UNLOCKED(&head->so_rcv.sb_sel.si_note, 0); */
1274 SOCKBUF_LOCK(&so->so_rcv);
1276 SOCKBUF_UNLOCK(&so->so_rcv);

Completed in 202 milliseconds

123