Home
last modified time | relevance | path

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

1234

/freebsd/sys/kern/
H A Duipc_socket.c550 sb_src = &so_src->so_rcv; in so_splice_xfer_data()
673 if (sbavail(&so_src->so_rcv) > 0 && in so_splice_xfer()
825 so->so_rcv.sb_sel = &so->so_rdsel; in soalloc()
830 TAILQ_INIT(&so->so_rcv.sb_aiojobq); in soalloc()
832 TASK_INIT(&so->so_rcv.sb_aiotask, 0, soaio_rcv, so); in soalloc()
890 if (so->so_rcv.sb_hiwat) in sodealloc()
892 &so->so_rcv.sb_hiwat, 0, RLIM_INFINITY); in sodealloc()
974 so->so_rcv.sb_mtx = &so->so_rcv_mtx; in socreate()
1215 so->so_rcv.sb_lowat = head->sol_sbrcv_lowat;
1217 so->so_rcv.sb_timeo = head->sol_sbrcv_timeo;
[all …]
H A Duipc_usrreq.c455 STAILQ_INIT(&so->so_rcv.uxdg_mb); in uipc_attach()
457 TAILQ_INIT(&so->so_rcv.uxdg_conns); in uipc_attach()
828 MPASS(so->so_rcv.uxdg_peeked == NULL); in uipc_detach()
829 MPASS(STAILQ_EMPTY(&so->so_rcv.uxdg_mb)); in uipc_detach()
830 MPASS(TAILQ_EMPTY(&so->so_rcv.uxdg_conns)); in uipc_detach()
933 SOCKBUF_LOCK(&so->so_rcv); in uipc_rcvd()
934 mbcnt = so->so_rcv.sb_mbcnt; in uipc_rcvd()
935 sbcc = sbavail(&so->so_rcv); in uipc_rcvd()
936 SOCKBUF_UNLOCK(&so->so_rcv); in uipc_rcvd()
1011 SOCKBUF_LOCK(&so2->so_rcv); in uipc_send()
[all …]
H A Dsys_socket.c175 so->so_rcv.sb_flags |= SB_ASYNC; in soo_ioctl()
190 so->so_rcv.sb_flags &= ~SB_ASYNC; in soo_ioctl()
205 *(int *)data = sbavail(&so->so_rcv) - so->so_rcv.sb_ctl; in soo_ioctl()
254 *(int *)data = (so->so_rcv.sb_state & SBS_RCVATMARK) != 0; in soo_ioctl()
315 sb = &so->so_rcv; in soo_stat()
393 so->so_rcv.sb_state; in soo_fill_kinfo()
399 sbused(&so->so_rcv); in soo_fill_kinfo()
408 so->so_rcv.sb_state; in soo_fill_kinfo()
414 sbused(&so->so_rcv); in soo_fill_kinfo()
595 return (sb == &so->so_rcv ? soreadable(so) : sowriteable(so)); in soaio_ready()
[all …]
H A Duipc_ktls.c1307 if (so->so_rcv.sb_tls_info != NULL) in ktls_enable_rx()
1335 if (__predict_false(so->so_rcv.sb_tls_info != NULL)) { in ktls_enable_rx()
1341 so->so_rcv.sb_tls_seqno = be64dec(en->rec_seq); in ktls_enable_rx()
1342 so->so_rcv.sb_tls_info = tls; in ktls_enable_rx()
1343 so->so_rcv.sb_flags |= SB_TLS_RX; in ktls_enable_rx()
1346 sb_mark_notready(&so->so_rcv); in ktls_enable_rx()
1347 ktls_check_rx(&so->so_rcv); in ktls_enable_rx()
1471 tls = so->so_rcv.sb_tls_info; in ktls_get_rx_mode()
1513 SOCKBUF_LOCK(&so->so_rcv); in ktls_get_rx_sequence()
1514 *tcpseq = tp->rcv_nxt - so->so_rcv.sb_tlscc; in ktls_get_rx_sequence()
[all …]
H A Duipc_sockbuf.c404 so->so_rcv.sb_state |= SBS_CANTRCVMORE; in socantrcvmore_locked()
406 if (so->so_rcv.sb_flags & SB_TLS_RX) in socantrcvmore_locked()
407 ktls_check_rx(&so->so_rcv); in socantrcvmore_locked()
494 KASSERT(sb == &so->so_rcv, in sowakeup()
550 if (so->so_rcv.sb_flags & SB_SPLICED) in sorwakeup_locked()
552 else if (sb_notify(&so->so_rcv)) in sorwakeup_locked()
612 if (so->so_rcv.sb_lowat == 0) in soreserve()
613 so->so_rcv.sb_lowat = 1; in soreserve()
734 sb = &so->so_rcv; in sbsetopt()
/freebsd/sys/netinet/
H A Daccf_http.c153 if ((so->so_rcv.sb_state & SBS_CANTRCVMORE) == 0 && in sohashttpget()
154 !sbfull(&so->so_rcv)) { in sohashttpget()
159 m = so->so_rcv.sb_mb; in sohashttpget()
160 cc = sbavail(&so->so_rcv) - 1; in sohashttpget()
203 if ((so->so_rcv.sb_state & SBS_CANTRCVMORE) != 0 || sbfull(&so->so_rcv)) in soparsehttpvers()
206 m = so->so_rcv.sb_mb; in soparsehttpvers()
207 cc = sbavail(&so->so_rcv); in soparsehttpvers()
209 for (m = so->so_rcv.sb_mb; m; m = n) { in soparsehttpvers()
284 if ((so->so_rcv.sb_state & SBS_CANTRCVMORE) != 0 || sbfull(&so->so_rcv)) in soishttpconnected()
295 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.c1478 if (V_tcp_do_autorcvbuf && (so->so_rcv.sb_flags & SB_AUTOSIZE) && in tcp_autorcvbuf()
1482 if (tp->rfbuf_cnt > ((so->so_rcv.sb_hiwat / 2)/ 4 * 3) && in tcp_autorcvbuf()
1483 so->so_rcv.sb_hiwat < V_tcp_autorcvbuf_max) { in tcp_autorcvbuf()
1484 newsize = min((so->so_rcv.sb_hiwat + (so->so_rcv.sb_hiwat/2)), V_tcp_autorcvbuf_max); in tcp_autorcvbuf()
1553 TCP_LOG_EVENT(tp, th, &so->so_rcv, &so->so_snd, TCP_LOG_IN, 0, in tcp_do_segment()
1898 tlen <= sbspace(&so->so_rcv)) { in tcp_do_segment()
1938 if (so->so_rcv.sb_state & SBS_CANTRCVMORE) { in tcp_do_segment()
1948 so->so_rcv.sb_flags &= ~SB_AUTOSIZE; in tcp_do_segment()
1950 sbappendstream_locked(&so->so_rcv, m, 0); in tcp_do_segment()
1970 win = sbspace(&so->so_rcv); in tcp_do_segment()
[all …]
H A Dtcp_reass.c226 TCP_LOG_EVENTP(tp, NULL, &so->so_rcv, &so->so_snd, in tcp_log_reassm()
526 struct sockbuf *sb = &so->so_rcv; in tcp_reass()
961 if (so->so_rcv.sb_state & SBS_CANTRCVMORE) { in tcp_reass()
964 sbappendstream_locked(&so->so_rcv, m, 0); in tcp_reass()
993 if (tp->t_segqlen >= min((so->so_rcv.sb_hiwat / tp->t_maxseg) + 1, in tcp_reass()
1067 if (so->so_rcv.sb_state & SBS_CANTRCVMORE) { in tcp_reass()
1078 sbappendstream_locked(&so->so_rcv, q->tqe_m, 0); in tcp_reass()
H A Dtcp_output.c575 recwin = lmin(lmax(sbspace(&so->so_rcv), 0), in tcp_default_output()
688 (adv >= (int32_t)(so->so_rcv.sb_hiwat / 4) || in tcp_default_output()
689 recwin <= (so->so_rcv.sb_hiwat / 8) || in tcp_default_output()
690 so->so_rcv.sb_hiwat <= 8 * tp->t_maxseg || in tcp_default_output()
693 if (2 * adv >= (int32_t)so->so_rcv.sb_hiwat) in tcp_default_output()
857 (so->so_rcv.sb_flags & SB_AUTOSIZE)) in tcp_default_output()
1280 if (recwin < (so->so_rcv.sb_hiwat / 4) && in tcp_default_output()
1294 (min(sbspace(&so->so_rcv), TCP_MAXWIN))); in tcp_default_output()
1426 lgb = tcp_log_event(tp, th, &so->so_rcv, &so->so_snd, in tcp_default_output()
H A Daccf_tls.c73 struct sockbuf *sb = &so->so_rcv; in so_hastls()
/freebsd/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 …]
/freebsd/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 …]
/freebsd/sys/sys/
H A Dsocketvar.h161 struct sockbuf so_rcv, so_snd; member
313 return (which == SO_RCV ? &so->so_rcv : &so->so_snd); in sobuf()
359 (sbavail(&(so)->so_rcv) >= (so)->so_rcv.sb_lowat || \
362 (soreadabledata(so) || ((so)->so_rcv.sb_state & SBS_CANTRCVMORE))
637 } so_rcv, so_snd; member
/freebsd/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()
/freebsd/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()
/freebsd/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()
/freebsd/usr.bin/netstat/
H A Dinet.c175 sbtoxsockbuf(&so->so_rcv, &xso->so_rcv); in sotoxsocket()
407 so->so_rcv.sb_cc, so->so_snd.sb_cc); in protopr()
486 so->so_rcv.sb_hiwat, so->so_snd.sb_hiwat, in protopr()
487 so->so_rcv.sb_lowat, so->so_snd.sb_lowat, in protopr()
488 so->so_rcv.sb_mbcnt, so->so_snd.sb_mbcnt, in protopr()
489 so->so_rcv.sb_mbmax, so->so_snd.sb_mbmax); in protopr()
/freebsd/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()
/freebsd/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()
/freebsd/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()
/freebsd/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()
H A Dsdp_rx.c180 max_bytes = max(ssk->socket->so_rcv.sb_hiwat, in sdp_post_recvs_needed()
187 bytes_in_process += sbused(&ssk->socket->so_rcv); in sdp_post_recvs_needed()
244 SOCKBUF_LOCK(&sk->so_rcv); in sdp_sock_queue_rcv_mb()
247 sbappend_locked(&sk->so_rcv, mb, 0); in sdp_sock_queue_rcv_mb()
/freebsd/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 …]
/freebsd/sys/netinet/tcp_stacks/
H A Dbbr.c1890 &bbr->rc_inp->inp_socket->so_rcv, in bbr_log_type_bw_reduce()
1908 &bbr->rc_inp->inp_socket->so_rcv, in bbr_log_type_rwnd_collapse()
1934 &bbr->rc_inp->inp_socket->so_rcv, in bbr_log_type_just_return()
1952 &bbr->rc_inp->inp_socket->so_rcv, in bbr_log_type_enter_rec()
1971 &bbr->rc_inp->inp_socket->so_rcv, in bbr_log_msgsize_fail()
1987 r = &bbr->rc_inp->inp_socket->so_rcv; in bbr_log_flowend()
2018 &bbr->rc_inp->inp_socket->so_rcv, in bbr_log_pkt_epoch()
2037 &bbr->rc_inp->inp_socket->so_rcv, in bbr_log_time_epoch()
2060 &bbr->rc_inp->inp_socket->so_rcv, in bbr_log_set_of_state_target()
2088 &bbr->rc_inp->inp_socket->so_rcv, in bbr_log_type_statechange()
[all …]

1234