Home
last modified time | relevance | path

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

123

/NextBSD/sys/kern/
HDuipc_socket.c390 SOCKBUF_LOCK_INIT(&so->so_rcv, "so_rcv"); in soalloc()
392 sx_init(&so->so_rcv.sb_sx, "so_rcv_sx"); in soalloc()
437 if (so->so_rcv.sb_hiwat) in sodealloc()
439 &so->so_rcv.sb_hiwat, 0, RLIM_INFINITY); in sodealloc()
454 sx_destroy(&so->so_rcv.sb_sx); in sodealloc()
456 SOCKBUF_LOCK_DESTROY(&so->so_rcv); in sodealloc()
513 knlist_init_mtx(&so->so_rcv.sb_sel.si_note, SOCKBUF_MTX(&so->so_rcv)); in socreate()
602 knlist_init_mtx(&so->so_rcv.sb_sel.si_note, SOCKBUF_MTX(&so->so_rcv));
605 if (soreserve(so, head->so_snd.sb_hiwat, head->so_rcv.sb_hiwat)) {
617 so->so_rcv.sb_lowat = head->so_rcv.sb_lowat;
[all …]
HDsys_socket.c157 SOCKBUF_LOCK(&so->so_rcv); in soo_ioctl()
158 so->so_rcv.sb_flags |= SB_ASYNC; in soo_ioctl()
159 SOCKBUF_UNLOCK(&so->so_rcv); in soo_ioctl()
167 SOCKBUF_LOCK(&so->so_rcv); in soo_ioctl()
168 so->so_rcv.sb_flags &= ~SB_ASYNC; in soo_ioctl()
169 SOCKBUF_UNLOCK(&so->so_rcv); in soo_ioctl()
178 *(int *)data = sbavail(&so->so_rcv); in soo_ioctl()
213 *(int *)data = (so->so_rcv.sb_state & SBS_RCVATMARK) != 0; in soo_ioctl()
274 sb = &so->so_rcv; in soo_stat()
345 so->so_rcv.sb_state; in soo_fill_kinfo()
HDuipc_usrreq.c401 if (so->so_snd.sb_hiwat == 0 || so->so_rcv.sb_hiwat == 0) { in uipc_attach()
813 SOCKBUF_LOCK(&so->so_rcv); in uipc_rcvd()
814 mbcnt = so->so_rcv.sb_mbcnt; in uipc_rcvd()
815 sbcc = sbavail(&so->so_rcv); in uipc_rcvd()
816 SOCKBUF_UNLOCK(&so->so_rcv); in uipc_rcvd()
904 SOCKBUF_LOCK(&so2->so_rcv); in uipc_send()
905 if (sbappendaddr_locked(&so2->so_rcv, from, m, in uipc_send()
911 SOCKBUF_UNLOCK(&so2->so_rcv); in uipc_send()
964 SOCKBUF_LOCK(&so2->so_rcv); in uipc_send()
980 if (sbappendcontrol_locked(&so2->so_rcv, m, in uipc_send()
[all …]
HDuipc_sockbuf.c238 SOCKBUF_LOCK_ASSERT(&so->so_rcv); in socantrcvmore_locked()
240 so->so_rcv.sb_state |= SBS_CANTRCVMORE; in socantrcvmore_locked()
242 mtx_assert(SOCKBUF_MTX(&so->so_rcv), MA_NOTOWNED); in socantrcvmore_locked()
249 SOCKBUF_LOCK(&so->so_rcv); in socantrcvmore()
251 mtx_assert(SOCKBUF_MTX(&so->so_rcv), MA_NOTOWNED); in socantrcvmore()
327 KASSERT(sb == &so->so_rcv, in sowakeup()
380 SOCKBUF_LOCK(&so->so_rcv); in soreserve()
383 if (sbreserve_locked(&so->so_rcv, rcvcc, so, td) == 0) in soreserve()
385 if (so->so_rcv.sb_lowat == 0) in soreserve()
386 so->so_rcv.sb_lowat = 1; in soreserve()
[all …]
/NextBSD/sys/netinet/
HDaccf_http.c165 if ((so->so_rcv.sb_state & SBS_CANTRCVMORE) == 0 && in sohashttpget()
166 !sbfull(&so->so_rcv)) { in sohashttpget()
171 m = so->so_rcv.sb_mb; in sohashttpget()
172 cc = sbavail(&so->so_rcv) - 1; in sohashttpget()
215 if ((so->so_rcv.sb_state & SBS_CANTRCVMORE) != 0 || sbfull(&so->so_rcv)) in soparsehttpvers()
218 m = so->so_rcv.sb_mb; in soparsehttpvers()
219 cc = sbavail(&so->so_rcv); in soparsehttpvers()
221 for (m = so->so_rcv.sb_mb; m; m = n) { in soparsehttpvers()
297 if ((so->so_rcv.sb_state & SBS_CANTRCVMORE) != 0 || sbfull(&so->so_rcv)) in soishttpconnected()
308 ccleft = sbavail(&so->so_rcv); in soishttpconnected()
[all …]
HDtcp_reass.c181 tp->t_segqlen >= (so->so_rcv.sb_hiwat / tp->t_maxseg) + 1) { in tcp_reass()
316 SOCKBUF_LOCK(&so->so_rcv); in tcp_reass()
322 if (so->so_rcv.sb_state & SBS_CANTRCVMORE) in tcp_reass()
325 sbappendstream_locked(&so->so_rcv, q->tqe_m, 0); in tcp_reass()
HDsctputil.c349 sctp_clog.x.lock.sock_lock = mtx_owned(&(inp->sctp_socket->so_rcv.sb_mtx)); in sctp_log_lock()
350 sctp_clog.x.lock.sockrcvbuf_lock = mtx_owned(&(inp->sctp_socket->so_rcv.sb_mtx)); in sctp_log_lock()
2739 &stcb->sctp_socket->so_rcv, 1, SCTP_READ_LOCK_NOT_HELD, in sctp_notify_assoc_change()
2889 &stcb->sctp_socket->so_rcv, 1, in sctp_notify_peer_addr_change()
2988 if (sctp_sbspace_failedmsgs(&stcb->sctp_socket->so_rcv) < SCTP_BUF_LEN(m_notify)) { in sctp_notify_send_failed()
3004 &stcb->sctp_socket->so_rcv, 1, in sctp_notify_send_failed()
3092 if (sctp_sbspace_failedmsgs(&stcb->sctp_socket->so_rcv) < SCTP_BUF_LEN(m_notify)) { in sctp_notify_send_failed2()
3108 &stcb->sctp_socket->so_rcv, 1, SCTP_READ_LOCK_NOT_HELD, so_locked); in sctp_notify_send_failed2()
3156 &stcb->sctp_socket->so_rcv, 1, SCTP_READ_LOCK_NOT_HELD, SCTP_SO_NOT_LOCKED); in sctp_notify_adaptation_layer()
3212 sb = &stcb->sctp_socket->so_rcv; in sctp_notify_partial_delivery_indication()
[all …]
HDtcp_input.c1791 tlen <= sbspace(&so->so_rcv)) { in tcp_do_segment()
1865 (so->so_rcv.sb_flags & SB_AUTOSIZE)) { in tcp_do_segment()
1869 (so->so_rcv.sb_hiwat / 8 * 7) && in tcp_do_segment()
1870 so->so_rcv.sb_hiwat < in tcp_do_segment()
1873 min(so->so_rcv.sb_hiwat + in tcp_do_segment()
1885 SOCKBUF_LOCK(&so->so_rcv); in tcp_do_segment()
1886 if (so->so_rcv.sb_state & SBS_CANTRCVMORE) { in tcp_do_segment()
1894 if (!sbreserve_locked(&so->so_rcv, in tcp_do_segment()
1896 so->so_rcv.sb_flags &= ~SB_AUTOSIZE; in tcp_do_segment()
1898 sbappendstream_locked(&so->so_rcv, m, 0); in tcp_do_segment()
[all …]
/NextBSD/sys/sys/
HDsocketvar.h109 struct sockbuf so_rcv, so_snd; member
150 #define SOCK_MTX(_so) SOCKBUF_MTX(&(_so)->so_rcv)
151 #define SOCK_LOCK(_so) SOCKBUF_LOCK(&(_so)->so_rcv)
152 #define SOCK_OWNED(_so) SOCKBUF_OWNED(&(_so)->so_rcv)
153 #define SOCK_UNLOCK(_so) SOCKBUF_UNLOCK(&(_so)->so_rcv)
154 #define SOCK_LOCK_ASSERT(_so) SOCKBUF_LOCK_ASSERT(&(_so)->so_rcv)
182 struct xsockbuf so_rcv, so_snd; member
211 (sbavail(&(so)->so_rcv) >= (so)->so_rcv.sb_lowat || \
214 (soreadabledata(so) || ((so)->so_rcv.sb_state & SBS_CANTRCVMORE))
256 SOCKBUF_LOCK_ASSERT(&(so)->so_rcv); \
[all …]
/NextBSD/sys/rpc/
HDsvc_dg.c138 SOCKBUF_LOCK(&so->so_rcv); in svc_dg_create()
140 SOCKBUF_UNLOCK(&so->so_rcv); in svc_dg_create()
199 SOCKBUF_LOCK(&xprt->xp_socket->so_rcv); in svc_dg_recv()
202 SOCKBUF_UNLOCK(&xprt->xp_socket->so_rcv); in svc_dg_recv()
208 SOCKBUF_LOCK(&xprt->xp_socket->so_rcv); in svc_dg_recv()
210 SOCKBUF_UNLOCK(&xprt->xp_socket->so_rcv); in svc_dg_recv()
275 SOCKBUF_LOCK(&xprt->xp_socket->so_rcv); in svc_dg_destroy()
277 SOCKBUF_UNLOCK(&xprt->xp_socket->so_rcv); in svc_dg_destroy()
HDsvc_vc.c186 SOCKBUF_LOCK(&so->so_rcv); in svc_vc_create()
189 SOCKBUF_UNLOCK(&so->so_rcv); in svc_vc_create()
267 SOCKBUF_LOCK(&so->so_rcv); in svc_vc_create_conn()
270 SOCKBUF_UNLOCK(&so->so_rcv); in svc_vc_create_conn()
364 KNOTE_UNLOCKED(&head->so_rcv.sb_sel.si_note, 0); in svc_vc_accept()
406 SOCKBUF_LOCK(&xprt->xp_socket->so_rcv); in svc_vc_rendezvous_recv()
411 SOCKBUF_UNLOCK(&xprt->xp_socket->so_rcv); in svc_vc_rendezvous_recv()
458 SOCKBUF_LOCK(&xprt->xp_socket->so_rcv); in svc_vc_destroy_common()
463 SOCKBUF_UNLOCK(&xprt->xp_socket->so_rcv); in svc_vc_destroy_common()
605 so->so_rcv.sb_lowat = sizeof(uint32_t) - n; in svc_vc_process_pending()
[all …]
HDclnt_dg.c272 sb = &so->so_rcv; in clnt_dg_create()
273 SOCKBUF_LOCK(&so->so_rcv); in clnt_dg_create()
277 SOCKBUF_UNLOCK(&so->so_rcv); in clnt_dg_create()
290 SOCKBUF_UNLOCK(&so->so_rcv); in clnt_dg_create()
292 SOCKBUF_LOCK(&so->so_rcv); in clnt_dg_create()
306 SOCKBUF_UNLOCK(&so->so_rcv); in clnt_dg_create()
355 cs = cu->cu_socket->so_rcv.sb_upcallarg; in clnt_dg_call()
820 cs = cu->cu_socket->so_rcv.sb_upcallarg; in clnt_dg_control()
953 cs = cu->cu_socket->so_rcv.sb_upcallarg; in clnt_dg_close()
1000 cs = cu->cu_socket->so_rcv.sb_upcallarg; in clnt_dg_destroy()
[all …]
HDclnt_vc.c263 SOCKBUF_LOCK(&ct->ct_socket->so_rcv); in clnt_vc_create()
265 SOCKBUF_UNLOCK(&ct->ct_socket->so_rcv); in clnt_vc_create()
752 SOCKBUF_LOCK(&ct->ct_socket->so_rcv); in clnt_vc_close()
755 SOCKBUF_UNLOCK(&ct->ct_socket->so_rcv); in clnt_vc_close()
863 if (sbavail(&so->so_rcv) >= sizeof(uint32_t) in clnt_vc_soupcall()
864 || (so->so_rcv.sb_state & SBS_CANTRCVMORE) in clnt_vc_soupcall()
871 SOCKBUF_UNLOCK(&so->so_rcv); in clnt_vc_soupcall()
876 SOCKBUF_LOCK(&so->so_rcv); in clnt_vc_soupcall()
916 if (sbavail(&so->so_rcv) >= ct->ct_record_resid in clnt_vc_soupcall()
917 || (so->so_rcv.sb_state & SBS_CANTRCVMORE) in clnt_vc_soupcall()
[all …]
/NextBSD/sys/cam/ctl/
HDctl_ha.c231 SOCKBUF_LOCK(&so->so_rcv); in ctl_ha_close()
235 msleep(&softc->ha_receiving, SOCKBUF_MTX(&so->so_rcv), in ctl_ha_close()
238 SOCKBUF_UNLOCK(&so->so_rcv); in ctl_ha_close()
259 SOCKBUF_LOCK(&softc->ha_lso->so_rcv); in ctl_ha_lclose()
261 SOCKBUF_UNLOCK(&softc->ha_lso->so_rcv); in ctl_ha_lclose()
283 SOCKBUF_LOCK(&so->so_rcv); in ctl_ha_rx_thread()
284 while (sbavail(&so->so_rcv) < next || softc->ha_disconnect) { in ctl_ha_rx_thread()
287 (so->so_rcv.sb_state & SBS_CANTRCVMORE)) { in ctl_ha_rx_thread()
290 so->so_rcv.sb_lowat = next; in ctl_ha_rx_thread()
291 msleep(&softc->ha_receiving, SOCKBUF_MTX(&so->so_rcv), in ctl_ha_rx_thread()
[all …]
/NextBSD/sys/dev/cxgb/ulp/tom/
HDcxgb_cpl_io.c593 struct sockbuf *so_rcv = &so->so_rcv; in t3_rcvd() local
599 SOCKBUF_LOCK(so_rcv); in t3_rcvd()
600 KASSERT(toep->tp_enqueued >= sbused(so_rcv), in t3_rcvd()
602 toep->tp_rx_credits += toep->tp_enqueued - sbused(so_rcv); in t3_rcvd()
603 toep->tp_enqueued = sbused(so_rcv); in t3_rcvd()
604 SOCKBUF_UNLOCK(so_rcv); in t3_rcvd()
739 SOCKBUF_LOCK_ASSERT(&so->so_rcv); in select_rcv_wnd()
741 wnd = sbspace(&so->so_rcv); in select_rcv_wnd()
781 SOCKBUF_LOCK(&so->so_rcv); in offload_socket()
783 SOCKBUF_UNLOCK(&so->so_rcv); in offload_socket()
[all …]
/NextBSD/sys/netinet/tcp_stacks/
HDfastpath.c442 (so->so_rcv.sb_flags & SB_AUTOSIZE)) { in tcp_do_fastnewdata()
446 (so->so_rcv.sb_hiwat / 8 * 7) && in tcp_do_fastnewdata()
447 so->so_rcv.sb_hiwat < in tcp_do_fastnewdata()
450 min(so->so_rcv.sb_hiwat + in tcp_do_fastnewdata()
462 SOCKBUF_LOCK(&so->so_rcv); in tcp_do_fastnewdata()
463 if (so->so_rcv.sb_state & SBS_CANTRCVMORE) { in tcp_do_fastnewdata()
471 if (!sbreserve_locked(&so->so_rcv, in tcp_do_fastnewdata()
473 so->so_rcv.sb_flags &= ~SB_AUTOSIZE; in tcp_do_fastnewdata()
475 sbappendstream_locked(&so->so_rcv, m, 0); in tcp_do_fastnewdata()
529 win = sbspace(&so->so_rcv); in tcp_do_slowpath()
[all …]
/NextBSD/sys/dev/iscsi/
HDicl_soft.c788 SOCKBUF_LOCK(&so->so_rcv); in icl_receive_thread()
789 available = sbavail(&so->so_rcv); in icl_receive_thread()
791 so->so_rcv.sb_lowat = ic->ic_receive_len; in icl_receive_thread()
792 cv_wait(&ic->ic_receive_cv, &so->so_rcv.sb_mtx); in icl_receive_thread()
794 so->so_rcv.sb_lowat = so->so_rcv.sb_hiwat + 1; in icl_receive_thread()
795 SOCKBUF_UNLOCK(&so->so_rcv); in icl_receive_thread()
1253 ic->ic_socket->so_rcv.sb_flags |= SB_AUTOSIZE; in icl_conn_start()
1278 SOCKBUF_LOCK(&ic->ic_socket->so_rcv); in icl_conn_start()
1280 SOCKBUF_UNLOCK(&ic->ic_socket->so_rcv); in icl_conn_start()
1394 SOCKBUF_LOCK(&so->so_rcv); in icl_soft_conn_close()
[all …]
/NextBSD/sys/netsmb/
HDsmb_trantcp.c155 SOCKBUF_LOCK(&so->so_rcv); in nb_connect_in()
157 SOCKBUF_UNLOCK(&so->so_rcv); in nb_connect_in()
158 so->so_rcv.sb_timeo = (5 * SBT_1S); in nb_connect_in()
165 SOCKBUF_LOCK(&so->so_rcv); in nb_connect_in()
166 so->so_rcv.sb_flags &= ~SB_NOINTR; in nb_connect_in()
167 SOCKBUF_UNLOCK(&so->so_rcv); in nb_connect_in()
354 (so->so_rcv.sb_state & SBS_CANTRCVMORE)) { in nbssn_recv()
/NextBSD/sys/netinet6/
HDsend.c289 SOCKBUF_LOCK(&V_send_so->so_rcv); in send_input()
290 if (sbappendaddr_locked(&V_send_so->so_rcv, in send_input()
292 SOCKBUF_UNLOCK(&V_send_so->so_rcv); in send_input()
/NextBSD/usr.bin/bluetooth/btsockstat/
HDbtsockstat.c258 so.so_rcv.sb_ccc, in hcirawpr()
306 so.so_rcv.sb_ccc, in l2caprawpr()
364 so.so_rcv.sb_ccc, in l2cappr()
470 so.so_rcv.sb_ccc, in rfcommpr()
/NextBSD/sys/netgraph/
HDng_ksocket.c611 SOCKBUF_LOCK(&priv->so->so_rcv); in ng_ksocket_connect()
613 SOCKBUF_UNLOCK(&priv->so->so_rcv); in ng_ksocket_connect()
945 SOCKBUF_LOCK(&priv->so->so_rcv); in ng_ksocket_shutdown()
947 SOCKBUF_UNLOCK(&priv->so->so_rcv); in ng_ksocket_shutdown()
1163 if (so->so_rcv.sb_state & SBS_CANTRCVMORE && in ng_ksocket_incoming2()
1190 if (head->so_rcv.sb_state & SBS_CANTRCVMORE) in ng_ksocket_check_accept()
1274 SOCKBUF_LOCK(&so->so_rcv); in ng_ksocket_finish_accept()
1276 SOCKBUF_UNLOCK(&so->so_rcv); in ng_ksocket_finish_accept()
HDng_socket.c911 SOCKBUF_LOCK(&so->so_rcv); in ngs_rcvmsg()
937 SOCKBUF_UNLOCK(&so->so_rcv); in ngs_rcvmsg()
951 SOCKBUF_UNLOCK(&so->so_rcv); in ngs_rcvmsg()
969 SOCKBUF_UNLOCK(&so->so_rcv); in ngs_rcvmsg()
975 if (sbappendaddr_locked(&so->so_rcv, (struct sockaddr *)&addr, m, in ngs_rcvmsg()
977 SOCKBUF_UNLOCK(&so->so_rcv); in ngs_rcvmsg()
1020 if (sbappendaddr(&so->so_rcv, (struct sockaddr *)addr, m, NULL) == 0) { in ngs_rcvdata()
/NextBSD/usr.bin/netstat/
HDinet.c180 sbtoxsockbuf(&so->so_rcv, &xso->so_rcv); in sotoxsocket()
511 so->so_rcv.sb_cc, so->so_snd.sb_cc); in protopr()
576 so->so_rcv.sb_mcnt, so->so_snd.sb_mcnt, in protopr()
577 so->so_rcv.sb_ccnt, so->so_snd.sb_ccnt, in protopr()
578 so->so_rcv.sb_hiwat, so->so_snd.sb_hiwat, in protopr()
579 so->so_rcv.sb_lowat, so->so_snd.sb_lowat, in protopr()
580 so->so_rcv.sb_mbcnt, so->so_snd.sb_mbcnt, in protopr()
581 so->so_rcv.sb_mbmax, so->so_snd.sb_mbmax); in protopr()
/NextBSD/sys/net/
HDraw_usrreq.c100 if (sbappendaddr(&last->so_rcv, src, in raw_input_ext()
111 if (sbappendaddr(&last->so_rcv, src, in raw_input_ext()
/NextBSD/sys/netnatm/
HDnatm.c129 if (so->so_snd.sb_hiwat == 0 || so->so_rcv.sb_hiwat == 0) { in natm_usr_attach()
450 if (sbspace(&so->so_rcv) > m->m_pkthdr.len) { in natmintr()
455 sbappendrecord(&so->so_rcv, m); in natmintr()

123