Home
last modified time | relevance | path

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

123

/f-stack/freebsd/kern/
H A Duipc_socket.c842 so->so_rcv.sb_lowat = head->so_rcv.sb_lowat;
844 so->so_rcv.sb_timeo = head->so_rcv.sb_timeo;
846 so->so_rcv.sb_flags |= head->so_rcv.sb_flags & SB_AUTOSIZE;
945 bzero(&so->so_rcv,
1953 sbavail(&so->so_rcv) < so->so_rcv.sb_lowat &&
2416 sb = &so->so_rcv;
3601 sb = &so->so_rcv;
3833 kn->kn_data = sbavail(&so->so_rcv) - so->so_rcv.sb_ctl;
3844 } else if (sbavail(&so->so_rcv) >= so->so_rcv.sb_lowat)
4122 sb = &so->so_rcv;
[all …]
H A Dsys_socket.c186 SOCKBUF_LOCK(&so->so_rcv); in soo_ioctl()
188 SOCKBUF_UNLOCK(&so->so_rcv); in soo_ioctl()
201 SOCKBUF_LOCK(&so->so_rcv); in soo_ioctl()
203 SOCKBUF_UNLOCK(&so->so_rcv); in soo_ioctl()
328 sb = &so->so_rcv; in soo_stat()
398 sbused(&so->so_rcv); in soo_fill_kinfo()
409 so->so_rcv.sb_state; in soo_fill_kinfo()
415 sbused(&so->so_rcv); in soo_fill_kinfo()
633 if (sb == &so->so_rcv) { in soaio_process_job()
784 sb = &so->so_rcv; in soo_aio_cancel()
[all …]
H A Duipc_usrreq.c803 sbrelease(&so->so_rcv, so); in uipc_detach()
969 SOCKBUF_LOCK(&so->so_rcv); in uipc_rcvd()
970 mbcnt = so->so_rcv.sb_mbcnt; in uipc_rcvd()
971 sbcc = sbavail(&so->so_rcv); in uipc_rcvd()
972 SOCKBUF_UNLOCK(&so->so_rcv); in uipc_rcvd()
1055 SOCKBUF_LOCK(&so2->so_rcv); in uipc_send()
1101 SOCKBUF_LOCK(&so2->so_rcv); in uipc_send()
1197 sb = &so->so_rcv; in uipc_ready_scan()
1234 SOCKBUF_LOCK(&so2->so_rcv); in uipc_ready()
2621 SOCKBUF_LOCK(&soa->so_rcv); in unp_gc_scan()
[all …]
H A Duipc_sockbuf.c419 SOCKBUF_LOCK_ASSERT(&so->so_rcv); in socantrcvmore_locked()
423 if (so->so_rcv.sb_flags & SB_TLS_RX) in socantrcvmore_locked()
424 ktls_check_rx(&so->so_rcv); in socantrcvmore_locked()
434 SOCKBUF_LOCK(&so->so_rcv); in socantrcvmore()
512 KASSERT(sb == &so->so_rcv, in sowakeup()
567 SOCKBUF_LOCK(&so->so_rcv); in soreserve()
572 if (so->so_rcv.sb_lowat == 0) in soreserve()
573 so->so_rcv.sb_lowat = 1; in soreserve()
578 SOCKBUF_UNLOCK(&so->so_rcv); in soreserve()
584 SOCKBUF_UNLOCK(&so->so_rcv); in soreserve()
[all …]
H A Duipc_ktls.c1035 if (so->so_rcv.sb_tls_info != NULL) in ktls_enable_rx()
1062 SOCKBUF_LOCK(&so->so_rcv); in ktls_enable_rx()
1064 so->so_rcv.sb_tls_info = tls; in ktls_enable_rx()
1065 so->so_rcv.sb_flags |= SB_TLS_RX; in ktls_enable_rx()
1068 sb_mark_notready(&so->so_rcv); in ktls_enable_rx()
1069 ktls_check_rx(&so->so_rcv); in ktls_enable_rx()
1070 SOCKBUF_UNLOCK(&so->so_rcv); in ktls_enable_rx()
1168 SOCKBUF_LOCK(&so->so_rcv); in ktls_get_rx_mode()
1169 tls = so->so_rcv.sb_tls_info; in ktls_get_rx_mode()
1174 SOCKBUF_UNLOCK(&so->so_rcv); in ktls_get_rx_mode()
[all …]
/f-stack/freebsd/netinet/
H A Daccf_http.c155 if ((so->so_rcv.sb_state & SBS_CANTRCVMORE) == 0 && in sohashttpget()
156 !sbfull(&so->so_rcv)) { in sohashttpget()
161 m = so->so_rcv.sb_mb; in sohashttpget()
162 cc = sbavail(&so->so_rcv) - 1; in sohashttpget()
205 if ((so->so_rcv.sb_state & SBS_CANTRCVMORE) != 0 || sbfull(&so->so_rcv)) in soparsehttpvers()
208 m = so->so_rcv.sb_mb; in soparsehttpvers()
209 cc = sbavail(&so->so_rcv); in soparsehttpvers()
211 for (m = so->so_rcv.sb_mb; m; m = n) { in soparsehttpvers()
286 if ((so->so_rcv.sb_state & SBS_CANTRCVMORE) != 0 || sbfull(&so->so_rcv)) in soishttpconnected()
297 ccleft = sbavail(&so->so_rcv); in soishttpconnected()
[all …]
H A Dtcp_input.c1462 newsize = min((so->so_rcv.sb_hiwat + (so->so_rcv.sb_hiwat/2)), V_tcp_autorcvbuf_max); in tcp_autorcvbuf()
1917 SOCKBUF_LOCK(&so->so_rcv); in tcp_do_segment()
1932 SOCKBUF_UNLOCK(&so->so_rcv); in tcp_do_segment()
1950 win = sbspace(&so->so_rcv); in tcp_do_segment()
3039 SOCKBUF_LOCK(&so->so_rcv); in tcp_do_segment()
3069 SOCKBUF_UNLOCK(&so->so_rcv); in tcp_do_segment()
3142 SOCKBUF_LOCK(&so->so_rcv); in tcp_do_segment()
3147 SOCKBUF_UNLOCK(&so->so_rcv); in tcp_do_segment()
3201 len = so->so_rcv.sb_hiwat; in tcp_do_segment()
3856 SOCKBUF_LOCK(&so->so_rcv); in tcp_mss()
[all …]
H A Dtcp_reass.c235 &tp->t_inpcb->inp_socket->so_rcv, in tcp_log_reassm()
587 sb = &tp->t_inpcb->inp_socket->so_rcv; in tcp_reass()
956 SOCKBUF_LOCK(&so->so_rcv); in tcp_reass()
957 if (so->so_rcv.sb_state & SBS_CANTRCVMORE) { in tcp_reass()
960 sbappendstream_locked(&so->so_rcv, m, 0); in tcp_reass()
962 SOCKBUF_UNLOCK(&so->so_rcv); in tcp_reass()
990 if (tp->t_segqlen >= min((so->so_rcv.sb_hiwat / tp->t_maxseg) + 1, in tcp_reass()
1059 SOCKBUF_LOCK(&so->so_rcv); in tcp_reass()
1065 if (so->so_rcv.sb_state & SBS_CANTRCVMORE) { in tcp_reass()
1076 sbappendstream_locked(&so->so_rcv, q->tqe_m, 0); in tcp_reass()
[all …]
H A Dsctputil.c4788 sbunlock(&old_so->so_rcv); in sctp_pull_off_control_to_new_inp()
5550 SOCKBUF_LOCK(&so->so_rcv); in sctp_sorecvmsg()
5557 if ((so->so_rcv.sb_state & SBS_CANTRCVMORE) && (so->so_rcv.sb_cc == 0)) { in sctp_sorecvmsg()
5643 so->so_rcv.sb_cc = 0; in sctp_sorecvmsg()
6026 sctp_sblog(&so->so_rcv, in sctp_sorecvmsg()
6309 sctp_sblog(&so->so_rcv, in sctp_sorecvmsg()
6316 sctp_sblog(&so->so_rcv, in sctp_sorecvmsg()
6338 sbunlock(&so->so_rcv); in sctp_sorecvmsg()
6373 sbunlock(&so->so_rcv); in sctp_sorecvmsg()
6401 so->so_rcv.sb_cc); in sctp_sorecvmsg()
[all …]
H A Dtcp_output.c575 recwin = lmin(lmax(sbspace(&so->so_rcv), 0), in tcp_output()
689 (adv >= (int32_t)(so->so_rcv.sb_hiwat / 4) || in tcp_output()
690 recwin <= (so->so_rcv.sb_hiwat / 8) || in tcp_output()
691 so->so_rcv.sb_hiwat <= 8 * tp->t_maxseg || in tcp_output()
694 if (2 * adv >= (int32_t)so->so_rcv.sb_hiwat) in tcp_output()
856 (so->so_rcv.sb_flags & SB_AUTOSIZE)) in tcp_output()
1261 if (recwin < (so->so_rcv.sb_hiwat / 4) && in tcp_output()
1275 (min(sbspace(&so->so_rcv), TCP_MAXWIN))); in tcp_output()
1402 TCP_LOG_EVENT(tp, th, &so->so_rcv, &so->so_snd, TCP_LOG_OUT, ERRNO_UNK, in tcp_output()
1613 TCP_LOG_EVENT(tp, NULL, &so->so_rcv, &so->so_snd, TCP_LOG_OUT, in tcp_output()
H A Daccf_dns.c64 struct sockbuf *sb = &so->so_rcv; in sohasdns()
H A Dip_divert.c284 SOCKBUF_LOCK(&sa->so_rcv); in divert_packet()
285 if (sbappendaddr_locked(&sa->so_rcv, in divert_packet()
288 SOCKBUF_UNLOCK(&sa->so_rcv); in divert_packet()
H A Dsctp_indata.c565 &stcb->sctp_socket->so_rcv, 1, in sctp_queue_data_to_stream()
605 &stcb->sctp_socket->so_rcv, 1, in sctp_queue_data_to_stream()
665 sctp_sballoc(stcb, &stcb->sctp_socket->so_rcv, m); in sctp_setup_tail_pointer()
718 sctp_sballoc(stcb, &stcb->sctp_socket->so_rcv, m); in sctp_add_to_tail_pointer()
903 &stcb->sctp_socket->so_rcv, control->end_added, in sctp_handle_old_unordered_data()
1114 &stcb->sctp_socket->so_rcv, control->end_added, in sctp_deliver_reasm_check()
1944 if (stcb->sctp_socket->so_rcv.sb_cc) { in sctp_process_a_data_chunk()
2136 control, &stcb->sctp_socket->so_rcv, in sctp_process_a_data_chunk()
2245 &stcb->sctp_socket->so_rcv, 1, in sctp_process_a_data_chunk()
5283 &stcb->sctp_socket->so_rcv, in sctp_kick_prsctp_reorder_queue()
[all …]
/f-stack/tools/compat/include/sys/
H A Dsocketvar.h127 struct sockbuf so_rcv, so_snd; member
272 (sbavail(&(so)->so_rcv) >= (so)->so_rcv.sb_lowat || (so)->so_error)
274 (soreadabledata(so) || ((so)->so_rcv.sb_state & SBS_CANTRCVMORE))
309 SOCKBUF_LOCK_ASSERT(&(so)->so_rcv); \
310 if (sb_notify(&(so)->so_rcv)) \
311 sowakeup((so), &(so)->so_rcv); \
313 SOCKBUF_UNLOCK(&(so)->so_rcv); \
317 SOCKBUF_LOCK(&(so)->so_rcv); \
535 } so_rcv, so_snd; member
/f-stack/freebsd/sys/
H A Dsocketvar.h127 struct sockbuf so_rcv, so_snd; member
272 (sbavail(&(so)->so_rcv) >= (so)->so_rcv.sb_lowat || (so)->so_error)
274 (soreadabledata(so) || ((so)->so_rcv.sb_state & SBS_CANTRCVMORE))
309 SOCKBUF_LOCK_ASSERT(&(so)->so_rcv); \
310 if (sb_notify(&(so)->so_rcv)) \
311 sowakeup((so), &(so)->so_rcv); \
313 SOCKBUF_UNLOCK(&(so)->so_rcv); \
317 SOCKBUF_LOCK(&(so)->so_rcv); \
535 } so_rcv, so_snd; member
/f-stack/freebsd/netinet6/
H A Dsend.c291 SOCKBUF_LOCK(&V_send_so->so_rcv); in send_input()
292 if (sbappendaddr_locked(&V_send_so->so_rcv, in send_input()
294 SOCKBUF_UNLOCK(&V_send_so->so_rcv); in send_input()
H A Dudp6_usrreq.c197 SOCKBUF_LOCK(&so->so_rcv); in udp6_append()
198 if (sbappendaddr_locked(&so->so_rcv, (struct sockaddr *)&fromsa[0], n, in udp6_append()
200 SOCKBUF_UNLOCK(&so->so_rcv); in udp6_append()
1045 if (so->so_snd.sb_hiwat == 0 || so->so_rcv.sb_hiwat == 0) { in udp6_attach()
/f-stack/freebsd/netgraph/
H A Dng_socket.c924 SOCKBUF_LOCK(&so->so_rcv); in ngs_rcvmsg()
950 SOCKBUF_UNLOCK(&so->so_rcv); in ngs_rcvmsg()
964 SOCKBUF_UNLOCK(&so->so_rcv); in ngs_rcvmsg()
982 SOCKBUF_UNLOCK(&so->so_rcv); in ngs_rcvmsg()
988 if (sbappendaddr_locked(&so->so_rcv, (struct sockaddr *)&addr, m, in ngs_rcvmsg()
990 SOCKBUF_UNLOCK(&so->so_rcv); in ngs_rcvmsg()
1035 SOCKBUF_LOCK(&so->so_rcv); in ngs_rcvdata()
1036 if (sbappendaddr_locked(&so->so_rcv, (struct sockaddr *)addr, m, in ngs_rcvdata()
1038 SOCKBUF_UNLOCK(&so->so_rcv); in ngs_rcvdata()
H A Dng_ksocket.c609 SOCKBUF_LOCK(&priv->so->so_rcv); in ng_ksocket_connect()
611 SOCKBUF_UNLOCK(&priv->so->so_rcv); in ng_ksocket_connect()
939 SOCKBUF_LOCK(&priv->so->so_rcv); in ng_ksocket_shutdown()
941 SOCKBUF_UNLOCK(&priv->so->so_rcv); in ng_ksocket_shutdown()
1151 if (so->so_rcv.sb_state & SBS_CANTRCVMORE && in ng_ksocket_incoming2()
1228 SOCKBUF_LOCK(&so->so_rcv); in ng_ksocket_accept()
1230 SOCKBUF_UNLOCK(&so->so_rcv); in ng_ksocket_accept()
/f-stack/freebsd/net/
H A Draw_usrreq.c102 if (sbappendaddr(&last->so_rcv, src, in raw_input_ext()
113 if (sbappendaddr(&last->so_rcv, src, in raw_input_ext()
/f-stack/tools/netstat/
H A Dinet.c187 sbtoxsockbuf(&so->so_rcv, &xso->so_rcv); in sotoxsocket()
434 so->so_rcv.sb_cc, so->so_snd.sb_cc); in protopr()
514 so->so_rcv.sb_mcnt, so->so_snd.sb_mcnt, in protopr()
515 so->so_rcv.sb_ccnt, so->so_snd.sb_ccnt, in protopr()
516 so->so_rcv.sb_hiwat, so->so_snd.sb_hiwat, in protopr()
517 so->so_rcv.sb_lowat, so->so_snd.sb_lowat, in protopr()
518 so->so_rcv.sb_mbcnt, so->so_snd.sb_mbcnt, in protopr()
519 so->so_rcv.sb_mbmax, so->so_snd.sb_mbmax); in protopr()
H A Dnetgraph.c125 name, sockb.so_rcv.sb_ccc, sockb.so_snd.sb_ccc); in netgraphprotopr()
/f-stack/freebsd/netgraph/bluetooth/socket/
H A Dng_btsocket_rfcomm.c1062 SOCKBUF_LOCK(&s->l2so->so_rcv); in ng_btsocket_rfcomm_sessions_task()
1064 SOCKBUF_UNLOCK(&s->l2so->so_rcv); in ng_btsocket_rfcomm_sessions_task()
1093 if (s->l2so->so_rcv.sb_state & SBS_CANTRCVMORE) { in ng_btsocket_rfcomm_session_task()
1300 SOCKBUF_LOCK(&l2so->so_rcv); in ng_btsocket_rfcomm_session_create()
1302 SOCKBUF_UNLOCK(&l2so->so_rcv); in ng_btsocket_rfcomm_session_create()
1386 SOCKBUF_LOCK(&l2so->so_rcv); in ng_btsocket_rfcomm_session_create()
1388 SOCKBUF_UNLOCK(&l2so->so_rcv); in ng_btsocket_rfcomm_session_create()
2371 m0->m_pkthdr.len, sbspace(&pcb->so->so_rcv)); in ng_btsocket_rfcomm_receive_uih()
2376 sbappend(&pcb->so->so_rcv, m0, 0); in ng_btsocket_rfcomm_receive_uih()
3197 credits = sbspace(&pcb->so->so_rcv) / pcb->mtu; in ng_btsocket_rfcomm_send_credits()
[all …]
/f-stack/freebsd/netinet/tcp_stacks/
H A Dbbr.c1910 &bbr->rc_inp->inp_socket->so_rcv, in bbr_log_type_bw_reduce()
1928 &bbr->rc_inp->inp_socket->so_rcv, in bbr_log_type_rwnd_collapse()
1954 &bbr->rc_inp->inp_socket->so_rcv, in bbr_log_type_just_return()
1972 &bbr->rc_inp->inp_socket->so_rcv, in bbr_log_type_enter_rec()
8320 if (so->so_rcv.sb_shlim) { in bbr_process_data()
8353 SOCKBUF_LOCK(&so->so_rcv); in bbr_process_data()
8361 SOCKBUF_UNLOCK(&so->so_rcv); in bbr_process_data()
8551 if (so->so_rcv.sb_shlim) { in bbr_do_fastnewdata()
8594 SOCKBUF_LOCK(&so->so_rcv); in bbr_do_fastnewdata()
8603 if (!sbreserve_locked(&so->so_rcv, in bbr_do_fastnewdata()
[all …]
H A Drack.c1667 &rack->rc_inp->inp_socket->so_rcv, in rack_log_retran_reason()
1699 &rack->rc_inp->inp_socket->so_rcv, in rack_log_to_start()
1730 &rack->rc_inp->inp_socket->so_rcv, in rack_log_to_event()
1934 &tp->t_inpcb->inp_socket->so_rcv, in rack_log_type_hrdwtso()
8640 if (so->so_rcv.sb_shlim) { in rack_process_data()
8665 SOCKBUF_LOCK(&so->so_rcv); in rack_process_data()
8673 SOCKBUF_UNLOCK(&so->so_rcv); in rack_process_data()
8870 if (so->so_rcv.sb_shlim) { in rack_do_fastnewdata()
8913 SOCKBUF_LOCK(&so->so_rcv); in rack_do_fastnewdata()
8922 if (!sbreserve_locked(&so->so_rcv, in rack_do_fastnewdata()
[all …]

123