Home
last modified time | relevance | path

Searched refs:sbavail (Results 1 – 23 of 23) sorted by relevance

/freebsd/sys/netinet/
H A Daccf_dns.c105 if (sbavail(sb) < 2) in skippacket()
112 q.len = sbavail(sb); in skippacket()
H A Daccf_http.c160 cc = sbavail(&so->so_rcv) - 1; in sohashttpget()
207 cc = sbavail(&so->so_rcv); in soparsehttpvers()
295 ccleft = sbavail(&so->so_rcv); in soishttpconnected()
H A Daccf_tls.c90 avail = sbavail(sb); in so_hastls()
H A Dtcp_output.c417 len = imin(sbavail(&so->so_snd), sendwin) - off; in tcp_default_output()
425 imin(sbavail(&so->so_snd), sendwin) - in tcp_default_output()
501 (off < (int) sbavail(&so->so_snd)) && in tcp_default_output()
616 (uint32_t)len + (uint32_t)off >= sbavail(&so->so_snd) && in tcp_default_output()
750 if (sbavail(&so->so_snd) && !tcp_timer_active(tp, TT_REXMT) && in tcp_default_output()
949 sbavail(&so->so_snd)) { in tcp_default_output()
1584 ulmin(sbavail(&so->so_snd) - off, sendwin); in tcp_default_output()
1607 } else if (len == 0 && sbavail(&so->so_snd) && in tcp_default_output()
H A Dtcp_input.c1875 if (sbavail(&so->so_snd) == 0) in tcp_do_segment()
1891 (sbavail(&so->so_snd) >= in tcp_do_segment()
2813 avail = sbavail(&so->so_snd); in tcp_do_segment()
2999 acked == sbavail(&so->so_snd)) || in tcp_do_segment()
3000 acked > sbavail(&so->so_snd)) in tcp_do_segment()
3033 if (acked > sbavail(&so->so_snd)) { in tcp_do_segment()
3034 if (tp->snd_wnd >= sbavail(&so->so_snd)) in tcp_do_segment()
3035 tp->snd_wnd -= sbavail(&so->so_snd); in tcp_do_segment()
3039 (int)sbavail(&so->so_snd)); in tcp_do_segment()
3159 if (th->th_urp + sbavail(&so->so_rcv) > sb_max) { in tcp_do_segment()
[all …]
H A Dsctp_os_bsd.h369 #define SCTP_SBAVAIL(sb) sbavail(sb)
H A Dtcp_subr.c1071 if ((!TCPS_HAVEESTABLISHED(tp->t_state) || sbavail(&so->so_snd) || in tcp_default_fb_init()
1081 (int32_t)sbavail(&so->so_snd)) in tcp_default_fb_init()
H A Dtcp_usrreq.c1195 tp->snd_up = tp->snd_una + sbavail(&so->so_snd); in tcp_usr_send()
/freebsd/sys/ofed/drivers/infiniband/ulp/sdp/
H A Dsdp_main.c1262 if (sbavail(sb)) in sdp_sorecv()
1270 if (sbavail(sb) == 0 && in sdp_sorecv()
1281 if (sbavail(sb)) in sdp_sorecv()
1293 if (sbavail(sb)) in sdp_sorecv()
1300 if (sbavail(sb) && !(flags & MSG_WAITALL) && in sdp_sorecv()
1303 sbavail(sb) >= sb->sb_lowat || in sdp_sorecv()
1304 sbavail(sb) >= uio->uio_resid || in sdp_sorecv()
1305 sbavail(sb) >= sb->sb_hiwat) ) { in sdp_sorecv()
1311 (sbavail(sb) >= uio->uio_resid || sbavail(sb) >= sb->sb_lowat)) in sdp_sorecv()
1325 KASSERT(sbavail(sb), ("%s: sockbuf empty", __func__)); in sdp_sorecv()
[all …]
/freebsd/sys/kern/
H A Duipc_socket.c556 len = MIN(max, MIN(space, sbavail(sb_src))); in so_splice_xfer_data()
668 if (sbavail(&so_src->so_rcv) > 0 && in so_splice_xfer()
2743 sbavail(&so->so_rcv) < uio->uio_resid) &&
2744 sbavail(&so->so_rcv) < so->so_rcv.sb_lowat &&
2746 KASSERT(m != NULL || !sbavail(&so->so_rcv),
2748 m, sbavail(&so->so_rcv)));
3250 if (sbavail(sb) > 0)
3262 if (sbavail(sb) > 0)
3269 if (sbavail(sb) == 0 &&
3276 if (sbavail(sb) > 0 && !(flags & MSG_WAITALL) &&
[all …]
H A Dsys_socket.c205 *(int *)data = sbavail(&so->so_rcv) - so->so_rcv.sb_ctl; in soo_ioctl()
215 *(int *)data = sbavail(&so->so_snd); in soo_ioctl()
317 if ((sb->sb_state & SBS_CANTRCVMORE) == 0 || sbavail(sb)) in soo_stat()
319 ub->st_size = sbavail(sb) - sb->sb_ctl; in soo_stat()
H A Duipc_usrreq.c935 sbcc = sbavail(&so->so_rcv); in uipc_rcvd()
1050 sbcc = sbavail(&so2->so_rcv); in uipc_send()
/freebsd/sys/netinet/tcp_stacks/
H A Dbbr.c581 sbavail(&tptosocket(tp)->so_snd)) { in bbr_timer_start()
4570 avail = sbavail(&so->so_snd); in bbr_timeout_tlp()
4761 if ((sbavail(&bbr->rc_inp->inp_socket->so_snd) == 0) && in bbr_timeout_persist()
7808 acked_amount = min(acked, (int)sbavail(&so->so_snd)); in bbr_process_ack()
7837 if (sbavail(&so->so_snd) == 0) in bbr_process_ack()
7855 (sbavail(&so->so_snd) == 0) && in bbr_process_ack()
8194 sbavail(&so->so_snd) && in bbr_process_data()
8195 (sbavail(&so->so_snd) > tp->snd_wnd)) { in bbr_process_data()
8411 (sbavail(&so->so_snd) > ctf_outstanding(tp))) { in bbr_process_data()
8634 sbavail(&so->so_snd) && in bbr_fastack()
[all …]
H A Drack.c5389 if (sbavail(&tptosocket(tp)->so_snd) < (tp->gput_ack - tp->gput_seq)) { in rack_do_goodput_measurement()
5671 if (ctf_outstanding(tp) <= sbavail(&tptosocket(tp)->so_snd)) { in rack_post_recovery()
6193 sbavail(&tptosocket(tp)->so_snd)) { in rack_timer_start()
7187 avail = sbavail(&so->so_snd); in rack_timeout_tlp()
7423 if ((sbavail(&rack->rc_inp->inp_socket->so_snd) == 0) && in rack_timeout_persist()
7955 if (bytes > sbavail(&tptosocket(tp)->so_snd)) { in rack_process_timers()
9278 if (ideal_amount > sbavail(&tptosocket(tp)->so_snd)) { in rack_need_set_test()
10719 if (sbavail(&rack->rc_inp->inp_socket->so_snd) <= (tp->snd_max - tp->snd_una)) { in rack_update_prr()
11197 (sbavail(&so->so_snd) > max((segsiz * (4 + rack_req_segs)), in rack_check_bottom_drag()
11548 gating_val = min((sbavail(&so->so_snd) - (tp->snd_max - tp->snd_una)), in rack_gain_for_fastoutput()
[all …]
/freebsd/sys/sys/
H A Dsockbuf.h257 sbavail(struct sockbuf *sb) in sbavail() function
H A Dsocketvar.h360 (sbavail(&(so)->so_rcv) >= (so)->so_rcv.sb_lowat || \
/freebsd/sys/dev/cxgbe/tom/
H A Dt4_ddp.c2360 KASSERT(toep->ddp.active_count == 0 || sbavail(sb) == 0, in aio_ddp_requeue()
2365 if (so->so_error && sbavail(sb) == 0) { in aio_ddp_requeue()
2396 if (sb->sb_state & SBS_CANTRCVMORE && sbavail(sb) == 0) { in aio_ddp_requeue()
2408 if (sbavail(sb) == 0 && (toep->ddp.flags & DDP_ON) == 0) { in aio_ddp_requeue()
2451 if (so->so_error && sbavail(sb) == 0) { in aio_ddp_requeue()
2470 if (sb->sb_state & SBS_CANTRCVMORE && sbavail(sb) == 0) { in aio_ddp_requeue()
2595 if (sbavail(sb) != 0) in aio_ddp_requeue()
H A Dt4_cpl_io.c1789 sbavail(sb) != 0) { in do_rx_data()
/freebsd/sys/netgraph/bluetooth/socket/
H A Dng_btsocket_sco.c904 if (sbavail(&pcb->so->so_snd) > 0) in ng_btsocket_sco_default_msg_input()
1728 sbavail(&pcb->so->so_snd) > 0) { in ng_btsocket_sco_send2()
H A Dng_btsocket_l2cap.c1196 if (sbavail(&pcb->so->so_snd) > 0) { in ng_btsocket_l2cap_process_l2ca_write_rsp()
2637 if (sbavail(&pcb->so->so_snd) == 0) in ng_btsocket_l2cap_send2()
H A Dng_btsocket_rfcomm.c3252 length = min(pcb->mtu, sbavail(&pcb->so->so_snd)); in ng_btsocket_rfcomm_pcb_send()
/freebsd/sys/dev/iscsi/
H A Dicl_soft.c754 available = sbavail(&so->so_rcv); in icl_receive_thread()
759 available = sbavail(&so->so_rcv); in icl_receive_thread()
/freebsd/sys/dev/nvmf/
H A Dnvmf_tcp.c1109 avail = sbavail(&so->so_rcv); in nvmf_tcp_receive()