Home
last modified time | relevance | path

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

1234

/src/sys/kern/
H A Duipc_socket.c592 sb_src = &so_src->so_rcv; in so_splice_xfer_data()
710 if (sbavail(&so_src->so_rcv) > 0 && in so_splice_xfer()
860 so->so_rcv.sb_sel = &so->so_rdsel; in soalloc()
865 TAILQ_INIT(&so->so_rcv.sb_aiojobq); in soalloc()
867 TASK_INIT(&so->so_rcv.sb_aiotask, 0, soaio_rcv, so); in soalloc()
925 if (so->so_rcv.sb_hiwat) in sodealloc()
927 &so->so_rcv.sb_hiwat, 0, RLIM_INFINITY); in sodealloc()
965 so->so_rcv.sb_mtx = &so->so_rcv_mtx; in soattach()
969 SOLISTENING(head) ? head->sol_sbrcv_hiwat : head->so_rcv.sb_hiwat)) in soattach()
1263 so->so_rcv.sb_lowat = head->sol_sbrcv_lowat;
[all …]
H A Duipc_usrreq.c488 STAILQ_INIT(&so->so_rcv.uxdg_mb); in uipc_attach()
490 TAILQ_INIT(&so->so_rcv.uxdg_conns); in uipc_attach()
512 STAILQ_INIT(&so->so_rcv.uxst_mbq); in uipc_attach()
874 MPASS(SOLISTENING(so) || (STAILQ_EMPTY(&so->so_rcv.uxst_mbq) && in uipc_detach()
875 so->so_rcv.uxst_peer == NULL)); in uipc_detach()
882 MPASS(so->so_rcv.uxdg_peeked == NULL); in uipc_detach()
883 MPASS(STAILQ_EMPTY(&so->so_rcv.uxdg_mb)); in uipc_detach()
884 MPASS(TAILQ_EMPTY(&so->so_rcv.uxdg_conns)); in uipc_detach()
951 &so->so_rcv.sb_hiwat, 0, RLIM_INFINITY); in uipc_listen()
1094 struct sockbuf *sb = &so->so_rcv; in uipc_stream_sbwait()
[all …]
H A Dsys_socket.c177 so->so_rcv.sb_flags |= SB_ASYNC; in soo_ioctl()
192 so->so_rcv.sb_flags &= ~SB_ASYNC; in soo_ioctl()
207 *(int *)data = sbavail(&so->so_rcv) - so->so_rcv.sb_ctl; in soo_ioctl()
256 *(int *)data = (so->so_rcv.sb_state & SBS_RCVATMARK) != 0; in soo_ioctl()
325 sb = &so->so_rcv; in soo_stat()
413 so->so_rcv.sb_state; in soo_fill_kinfo()
419 sbused(&so->so_rcv); in soo_fill_kinfo()
428 so->so_rcv.sb_state; in soo_fill_kinfo()
434 sbused(&so->so_rcv); in soo_fill_kinfo()
615 return (sb == &so->so_rcv ? soreadable(so) : sowriteable(so)); in soaio_ready()
[all …]
H A Duipc_ktls.c1309 if (so->so_rcv.sb_tls_info != NULL) in ktls_enable_rx()
1337 if (__predict_false(so->so_rcv.sb_tls_info != NULL)) in ktls_enable_rx()
1339 else if ((so->so_rcv.sb_flags & SB_SPLICED) != 0) in ktls_enable_rx()
1347 so->so_rcv.sb_tls_seqno = be64dec(en->rec_seq); in ktls_enable_rx()
1348 so->so_rcv.sb_tls_info = tls; in ktls_enable_rx()
1349 so->so_rcv.sb_flags |= SB_TLS_RX; in ktls_enable_rx()
1352 sb_mark_notready(&so->so_rcv); in ktls_enable_rx()
1353 ktls_check_rx(&so->so_rcv); in ktls_enable_rx()
1484 tls = so->so_rcv.sb_tls_info; in ktls_get_rx_mode()
1526 SOCKBUF_LOCK(&so->so_rcv); in ktls_get_rx_sequence()
[all …]
H A Duipc_sockbuf.c398 so->so_rcv.sb_state |= SBS_CANTRCVMORE; in socantrcvmore_locked()
400 if (so->so_rcv.sb_flags & SB_TLS_RX) in socantrcvmore_locked()
401 ktls_check_rx(&so->so_rcv); in socantrcvmore_locked()
488 KASSERT(sb == &so->so_rcv, in sowakeup()
544 if (so->so_rcv.sb_flags & SB_SPLICED) in sorwakeup_locked()
546 else if (sb_notify(&so->so_rcv)) in sorwakeup_locked()
606 if (so->so_rcv.sb_lowat == 0) in soreserve()
607 so->so_rcv.sb_lowat = 1; in soreserve()
740 sb = &so->so_rcv; in sbsetopt()
/src/sys/netinet/
H A Daccf_http.c152 if ((so->so_rcv.sb_state & SBS_CANTRCVMORE) == 0 && in sohashttpget()
153 !sbfull(&so->so_rcv)) { in sohashttpget()
158 m = so->so_rcv.sb_mb; in sohashttpget()
159 cc = sbavail(&so->so_rcv) - 1; in sohashttpget()
202 if ((so->so_rcv.sb_state & SBS_CANTRCVMORE) != 0 || sbfull(&so->so_rcv)) in soparsehttpvers()
205 m = so->so_rcv.sb_mb; in soparsehttpvers()
206 cc = sbavail(&so->so_rcv); in soparsehttpvers()
208 for (m = so->so_rcv.sb_mb; m; m = n) { in soparsehttpvers()
283 if ((so->so_rcv.sb_state & SBS_CANTRCVMORE) != 0 || sbfull(&so->so_rcv)) in soishttpconnected()
294 ccleft = sbavail(&so->so_rcv); in soishttpconnected()
[all …]
H A Dsctputil.c377 sctp_clog.x.lock.sockrcvbuf_lock = mtx_owned(SOCKBUF_MTX(&inp->sctp_socket->so_rcv)); in sctp_log_lock()
3236 &stcb->sctp_socket->so_rcv, 1, in sctp_notify_assoc_change()
3366 &stcb->sctp_socket->so_rcv, 1, in sctp_notify_peer_addr_change()
3480 if (sctp_sbspace_failedmsgs(&stcb->sctp_socket->so_rcv) < SCTP_BUF_LEN(m_notify)) { in sctp_notify_send_failed()
3498 &stcb->sctp_socket->so_rcv, 1, in sctp_notify_send_failed()
3580 if (sctp_sbspace_failedmsgs(&stcb->sctp_socket->so_rcv) < SCTP_BUF_LEN(m_notify)) { in sctp_notify_send_failed2()
3598 &stcb->sctp_socket->so_rcv, 1, in sctp_notify_send_failed2()
3648 &stcb->sctp_socket->so_rcv, 1, in sctp_notify_adaptation_layer()
3701 sb = &stcb->sctp_socket->so_rcv; in sctp_notify_partial_delivery_indication()
3771 &stcb->sctp_socket->so_rcv, 1, in sctp_notify_shutdown_event()
[all …]
H A Dtcp_input.c1441 if (V_tcp_do_autorcvbuf && (so->so_rcv.sb_flags & SB_AUTOSIZE) && in tcp_autorcvbuf()
1445 if (tp->rfbuf_cnt > ((so->so_rcv.sb_hiwat / 2)/ 4 * 3) && in tcp_autorcvbuf()
1446 so->so_rcv.sb_hiwat < V_tcp_autorcvbuf_max) { in tcp_autorcvbuf()
1447 newsize = min((so->so_rcv.sb_hiwat + (so->so_rcv.sb_hiwat/2)), V_tcp_autorcvbuf_max); in tcp_autorcvbuf()
1514 TCP_LOG_EVENT(tp, th, &so->so_rcv, &so->so_snd, TCP_LOG_IN, 0, in tcp_do_segment()
1858 tlen <= sbspace(&so->so_rcv)) { in tcp_do_segment()
1898 if (so->so_rcv.sb_state & SBS_CANTRCVMORE) { in tcp_do_segment()
1908 so->so_rcv.sb_flags &= ~SB_AUTOSIZE; in tcp_do_segment()
1910 sbappendstream_locked(&so->so_rcv, m, 0); in tcp_do_segment()
1930 win = sbspace(&so->so_rcv); in tcp_do_segment()
[all …]
H A Dtcp_reass.c225 TCP_LOG_EVENTP(tp, NULL, &so->so_rcv, &so->so_snd, in tcp_log_reassm()
525 struct sockbuf *sb = &so->so_rcv; in tcp_reass()
960 if (so->so_rcv.sb_state & SBS_CANTRCVMORE) { in tcp_reass()
963 sbappendstream_locked(&so->so_rcv, m, 0); in tcp_reass()
992 if (tp->t_segqlen >= min((so->so_rcv.sb_hiwat / tp->t_maxseg) + 1, in tcp_reass()
1066 if (so->so_rcv.sb_state & SBS_CANTRCVMORE) { in tcp_reass()
1077 sbappendstream_locked(&so->so_rcv, q->tqe_m, 0); in tcp_reass()
H A Dtcp_output.c571 recwin = lmin(lmax(sbspace(&so->so_rcv), 0), in tcp_default_output()
684 (adv >= (int32_t)(so->so_rcv.sb_hiwat / 4) || in tcp_default_output()
685 recwin <= (so->so_rcv.sb_hiwat / 8) || in tcp_default_output()
686 so->so_rcv.sb_hiwat <= 8 * tp->t_maxseg || in tcp_default_output()
689 if (2 * adv >= (int32_t)so->so_rcv.sb_hiwat) in tcp_default_output()
853 (so->so_rcv.sb_flags & SB_AUTOSIZE)) in tcp_default_output()
1276 if (recwin < (so->so_rcv.sb_hiwat / 4) && in tcp_default_output()
1290 (min(sbspace(&so->so_rcv), TCP_MAXWIN))); in tcp_default_output()
1422 lgb = tcp_log_event(tp, th, &so->so_rcv, &so->so_snd, in tcp_default_output()
H A Daccf_tls.c72 struct sockbuf *sb = &so->so_rcv; in so_hastls()
/src/sys/dev/iscsi/
H A Dicl_soft.c742 SOCKBUF_LOCK(&so->so_rcv); in icl_receive_thread()
744 SOCKBUF_UNLOCK(&so->so_rcv); in icl_receive_thread()
754 available = sbavail(&so->so_rcv); in icl_receive_thread()
756 so->so_rcv.sb_lowat = isc->receive_len - read; in icl_receive_thread()
757 cv_wait(&isc->receive_cv, SOCKBUF_MTX(&so->so_rcv)); in icl_receive_thread()
758 so->so_rcv.sb_lowat = so->so_rcv.sb_hiwat + 1; in icl_receive_thread()
759 available = sbavail(&so->so_rcv); in icl_receive_thread()
761 SOCKBUF_UNLOCK(&so->so_rcv); in icl_receive_thread()
1443 ic->ic_socket->so_rcv.sb_flags |= SB_AUTOSIZE; in icl_conn_start()
1468 SOCKBUF_LOCK(&ic->ic_socket->so_rcv); in icl_conn_start()
[all …]
/src/sys/dev/nvmf/
H A Dnvmf_tcp.c1092 SOCKBUF_LOCK(&so->so_rcv); in nvmf_tcp_receive()
1100 SOCKBUF_UNLOCK(&so->so_rcv); in nvmf_tcp_receive()
1104 SOCKBUF_LOCK(&so->so_rcv); in nvmf_tcp_receive()
1106 cv_wait(&qp->rx_cv, SOCKBUF_MTX(&so->so_rcv)); in nvmf_tcp_receive()
1109 avail = sbavail(&so->so_rcv); in nvmf_tcp_receive()
1110 if ((so->so_rcv.sb_state & SBS_CANTRCVMORE) != 0) { in nvmf_tcp_receive()
1115 SOCKBUF_UNLOCK(&so->so_rcv); in nvmf_tcp_receive()
1119 cv_wait(&qp->rx_cv, SOCKBUF_MTX(&so->so_rcv)); in nvmf_tcp_receive()
1122 SOCKBUF_UNLOCK(&so->so_rcv); in nvmf_tcp_receive()
1173 SOCKBUF_LOCK(&so->so_rcv); in nvmf_tcp_receive()
[all …]
/src/sys/dev/cxgbe/nvmf/
H A Dnvmf_che.c1894 SOCKBUF_LOCK(&so->so_rcv); in nvmf_che_attach_pdu_data()
1925 SOCKBUF_UNLOCK(&so->so_rcv); in nvmf_che_attach_pdu_data()
1944 SOCKBUF_LOCK(&so->so_rcv); in nvmf_che_receive()
1952 SOCKBUF_UNLOCK(&so->so_rcv); in nvmf_che_receive()
1955 SOCKBUF_LOCK(&so->so_rcv); in nvmf_che_receive()
1957 cv_wait(&qp->rx_cv, SOCKBUF_MTX(&so->so_rcv)); in nvmf_che_receive()
1963 if ((so->so_rcv.sb_state & SBS_CANTRCVMORE) != 0) { in nvmf_che_receive()
1965 SOCKBUF_UNLOCK(&so->so_rcv); in nvmf_che_receive()
1968 cv_wait(&qp->rx_cv, SOCKBUF_MTX(&so->so_rcv)); in nvmf_che_receive()
1971 SOCKBUF_UNLOCK(&so->so_rcv); in nvmf_che_receive()
[all …]
/src/sys/sys/
H A Dsocketvar.h162 struct sockbuf so_rcv, so_snd; member
314 return (which == SO_RCV ? &so->so_rcv : &so->so_snd); in sobuf()
360 (sbavail(&(so)->so_rcv) >= (so)->so_rcv.sb_lowat || \
363 (soreadabledata(so) || ((so)->so_rcv.sb_state & SBS_CANTRCVMORE))
640 } so_rcv, so_snd; member
/src/sys/netgraph/
H A Dng_socket.c929 SOCKBUF_LOCK(&so->so_rcv); in ngs_rcvmsg()
955 SOCKBUF_UNLOCK(&so->so_rcv); in ngs_rcvmsg()
969 SOCKBUF_UNLOCK(&so->so_rcv); in ngs_rcvmsg()
987 SOCKBUF_UNLOCK(&so->so_rcv); in ngs_rcvmsg()
993 if (sbappendaddr_locked(&so->so_rcv, (struct sockaddr *)&addr, m, in ngs_rcvmsg()
1040 SOCKBUF_LOCK(&so->so_rcv); in ngs_rcvdata()
1041 if (sbappendaddr_locked(&so->so_rcv, (struct sockaddr *)addr, m, in ngs_rcvdata()
1043 SOCKBUF_UNLOCK(&so->so_rcv); in ngs_rcvdata()
/src/usr.bin/bluetooth/btsockstat/
H A Dbtsockstat.c260 so.so_rcv.sb_ccc, in hcirawpr()
308 so.so_rcv.sb_ccc, in l2caprawpr()
366 so.so_rcv.sb_ccc, in l2cappr()
472 so.so_rcv.sb_ccc, in rfcommpr()
/src/sys/netlink/
H A Dnetlink_io.c108 sb = &so->so_rcv; in nl_process_received_one()
172 struct sockbuf *sb = &so->so_rcv; in nl_on_transmit()
204 struct sockbuf *sb = &so->so_rcv; in nl_send()
/src/sys/cam/ctl/
H A Dctl_ha.c222 while (sbavail(&so->so_rcv) < next || softc->ha_disconnect) { in ctl_ha_rx_thread()
225 (so->so_rcv.sb_state & SBS_CANTRCVMORE)) { in ctl_ha_rx_thread()
228 so->so_rcv.sb_lowat = next; in ctl_ha_rx_thread()
313 so->so_rcv.sb_lowat = sizeof(struct ha_msg_wire); in ctl_ha_sock_setup()
507 softc->ha_so->so_rcv.sb_state & SBS_CANTRCVMORE)) in ctl_ha_conn_thread()
540 softc->ha_so->so_rcv.sb_state & SBS_CANTRCVMORE)) in ctl_ha_conn_thread()
/src/usr.bin/netstat/
H A Dinet.c177 sbtoxsockbuf(&so->so_rcv, &xso->so_rcv); in sotoxsocket()
420 so->so_rcv.sb_cc, so->so_snd.sb_cc); in protopr()
499 so->so_rcv.sb_hiwat, so->so_snd.sb_hiwat, in protopr()
500 so->so_rcv.sb_lowat, so->so_snd.sb_lowat, in protopr()
501 so->so_rcv.sb_mbcnt, so->so_snd.sb_mbcnt, in protopr()
502 so->so_rcv.sb_mbmax, so->so_snd.sb_mbmax); in protopr()
/src/sys/rpc/
H A Dclnt_dg.c272 sb = &so->so_rcv; in clnt_dg_create()
352 cs = cu->cu_socket->so_rcv.sb_upcallarg; in clnt_dg_call()
813 cs = cu->cu_socket->so_rcv.sb_upcallarg; in clnt_dg_control()
946 cs = cu->cu_socket->so_rcv.sb_upcallarg; in clnt_dg_close()
993 cs = cu->cu_socket->so_rcv.sb_upcallarg; in clnt_dg_destroy()
1146 (void) msleep(&cs->cs_upcallrefs, SOCKBUF_MTX(&so->so_rcv), 0, in clnt_dg_upcallsdone()
/src/sys/netsmb/
H A Dsmb_trantcp.c154 SOCKBUF_LOCK(&so->so_rcv); in nb_connect_in()
156 SOCKBUF_UNLOCK(&so->so_rcv); in nb_connect_in()
157 so->so_rcv.sb_timeo = (5 * SBT_1S); in nb_connect_in()
347 (so->so_rcv.sb_state & SBS_CANTRCVMORE)) { in nbssn_recv()
/src/sys/netinet6/
H A Dsend.c305 SOCKBUF_LOCK(&V_send_so->so_rcv); in send_input()
306 if (sbappendaddr_locked(&V_send_so->so_rcv, in send_input()
/src/sys/ofed/drivers/infiniband/ulp/sdp/
H A Dsdp_main.c418 if (so->so_snd.sb_hiwat == 0 || so->so_rcv.sb_hiwat == 0) { in sdp_attach()
423 so->so_rcv.sb_flags |= SB_AUTOSIZE; in sdp_attach()
713 unread = sbused(&so->so_rcv); in sdp_start_disconnect()
714 sbflush(&so->so_rcv); in sdp_start_disconnect()
1243 sb = &so->so_rcv; in sdp_sorecv()
1277 SOCKBUF_LOCK_ASSERT(&so->so_rcv); in sdp_sorecv()
1324 SOCKBUF_LOCK_ASSERT(&so->so_rcv); in sdp_sorecv()
1480 (so->so_rcv.sb_state & SBS_RCVATMARK) == 0) || in sdp_rcvoob()
1510 so->so_oobmark = sbused(&so->so_rcv) + mb->m_pkthdr.len - 1; in sdp_urg()
/src/sys/netgraph/bluetooth/socket/
H A Dng_btsocket_rfcomm.c397 if ((so->so_snd.sb_hiwat == 0) || (so->so_rcv.sb_hiwat == 0)) { in ng_btsocket_rfcomm_attach()
1051 SOCKBUF_LOCK(&s->l2so->so_rcv); in ng_btsocket_rfcomm_sessions_task()
1053 SOCKBUF_UNLOCK(&s->l2so->so_rcv); in ng_btsocket_rfcomm_sessions_task()
1082 if (s->l2so->so_rcv.sb_state & SBS_CANTRCVMORE) { in ng_btsocket_rfcomm_session_task()
1289 SOCKBUF_LOCK(&l2so->so_rcv); in ng_btsocket_rfcomm_session_create()
1291 SOCKBUF_UNLOCK(&l2so->so_rcv); in ng_btsocket_rfcomm_session_create()
1375 SOCKBUF_LOCK(&l2so->so_rcv); in ng_btsocket_rfcomm_session_create()
1377 SOCKBUF_UNLOCK(&l2so->so_rcv); in ng_btsocket_rfcomm_session_create()
2349 } else if (m0->m_pkthdr.len > sbspace(&pcb->so->so_rcv)) { in ng_btsocket_rfcomm_receive_uih()
2360 m0->m_pkthdr.len, sbspace(&pcb->so->so_rcv)); in ng_btsocket_rfcomm_receive_uih()
[all …]

1234