Home
last modified time | relevance | path

Searched refs:so_snd (Results 1 – 25 of 58) sorted by relevance

123

/freebsd/sys/ofed/drivers/infiniband/ulp/sdp/
H A Dsdp_bcopy.c160 if (sk->so_snd.sb_sndptr) in sdp_nagle_timeout()
175 if (sk->so_snd.sb_sndptr) { in sdp_post_sends()
200 sdp_tx_ring_slots_left(ssk) && sk->so_snd.sb_sndptr && in sdp_post_sends()
201 sdp_nagle_off(ssk, sk->so_snd.sb_sndptr)) { in sdp_post_sends()
206 sdp_tx_ring_slots_left(ssk) && (mb = sk->so_snd.sb_sndptr) && in sdp_post_sends()
210 SOCKBUF_LOCK(&sk->so_snd); in sdp_post_sends()
211 sk->so_snd.sb_sndptr = mb->m_nextpkt; in sdp_post_sends()
212 sk->so_snd.sb_mb = mb->m_nextpkt; in sdp_post_sends()
214 SB_EMPTY_FIXUP(&sk->so_snd); in sdp_post_sends()
216 sbfree(&sk->so_snd, n); in sdp_post_sends()
[all …]
H A Dsdp_main.c418 if (so->so_snd.sb_hiwat == 0 || so->so_rcv.sb_hiwat == 0) { in sdp_attach()
424 so->so_snd.sb_flags |= SB_AUTOSIZE; in sdp_attach()
968 SOCKBUF_LOCK(&so->so_snd); in sdp_send()
969 sdp_append(ssk, &so->so_snd, m, cnt); in sdp_send()
970 SOCKBUF_UNLOCK(&so->so_snd); in sdp_send()
994 SOCKBUF_LOCK(&so->so_snd); in sdp_send()
995 if (sbspace(&so->so_snd) < -512) { in sdp_send()
996 SOCKBUF_UNLOCK(&so->so_snd); in sdp_send()
1010 sdp_append(ssk, &so->so_snd, m, cnt); in sdp_send()
1011 SOCKBUF_UNLOCK(&so->so_snd); in sdp_send()
[all …]
/freebsd/sys/kern/
H A Dsys_socket.c180 so->so_snd.sb_flags |= SB_ASYNC; in soo_ioctl()
195 so->so_snd.sb_flags &= ~SB_ASYNC; in soo_ioctl()
217 *(int *)data = sbavail(&so->so_snd); in soo_ioctl()
226 if ((so->so_snd.sb_hiwat < sbused(&so->so_snd)) || in soo_ioctl()
227 (so->so_snd.sb_mbmax < so->so_snd.sb_mbcnt)) { in soo_ioctl()
230 *(int *)data = sbspace(&so->so_snd); in soo_ioctl()
332 sb = &so->so_snd; in soo_stat()
415 so->so_snd.sb_state; in soo_fill_kinfo()
417 sbused(&so->so_snd); in soo_fill_kinfo()
430 so->so_snd.sb_state; in soo_fill_kinfo()
[all …]
H A Duipc_socket.c593 sb_dst = &so_dst->so_snd; in so_splice_xfer_data()
711 sbspace(&so_dst->so_snd) > 0) { in so_splice_xfer()
861 so->so_snd.sb_sel = &so->so_wrsel; in soalloc()
864 TAILQ_INIT(&so->so_snd.sb_aiojobq); in soalloc()
866 TASK_INIT(&so->so_snd.sb_aiotask, 0, soaio_snd, so); in soalloc()
928 if (so->so_snd.sb_hiwat) in sodealloc()
930 &so->so_snd.sb_hiwat, 0, RLIM_INFINITY); in sodealloc()
964 so->so_snd.sb_mtx = &so->so_snd_mtx; in soattach()
968 SOLISTENING(head) ? head->sol_sbsnd_hiwat : head->so_snd.sb_hiwat, in soattach()
1264 so->so_snd.sb_lowat = head->sol_sbsnd_lowat;
[all …]
H A Dkern_sendfile.c660 if (so->so_snd.sb_flags & SB_AUTOLOWAT) { in sendfile_wait_generic()
661 if (so->so_snd.sb_lowat < so->so_snd.sb_hiwat / 2) in sendfile_wait_generic()
662 so->so_snd.sb_lowat = so->so_snd.sb_hiwat / 2; in sendfile_wait_generic()
663 if (so->so_snd.sb_lowat < PAGE_SIZE && in sendfile_wait_generic()
664 so->so_snd.sb_hiwat >= PAGE_SIZE) in sendfile_wait_generic()
665 so->so_snd.sb_lowat = PAGE_SIZE; in sendfile_wait_generic()
668 if (so->so_snd.sb_state & SBS_CANTSENDMORE) { in sendfile_wait_generic()
681 *space = sbspace(&so->so_snd); in sendfile_wait_generic()
682 if (*space < need && (*space <= 0 || *space < so->so_snd.sb_lowat)) { in sendfile_wait_generic()
774 tls = ktls_hold(so->so_snd.sb_tls_info); in vn_sendfile()
H A Duipc_usrreq.c490 STAILQ_INIT(&so->so_snd.uxdg_mb); in uipc_attach()
886 MPASS(STAILQ_EMPTY(&so->so_snd.uxdg_mb)); in uipc_detach()
950 &so->so_snd.sb_hiwat, 0, RLIM_INFINITY); in uipc_listen()
1152 if (__predict_false(so->so_snd.sb_flags & SB_AIO_RUNNING)) { in uipc_sosend_stream_or_seqpacket()
1165 error = mc_uiotomc(&mc, uio, so->so_snd.sb_hiwat, 0, M_WAITOK, in uipc_sosend_stream_or_seqpacket()
1230 so->so_snd.sb_ccc = in uipc_sosend_stream_or_seqpacket()
1231 so->so_snd.sb_hiwat - space; in uipc_sosend_stream_or_seqpacket()
1238 so->so_snd.sb_timeo)) != 0) { in uipc_sosend_stream_or_seqpacket()
1305 atomic_load_int(&so->so_snd.sb_hiwat), 0, M_WAITOK, in uipc_sosend_stream_or_seqpacket()
1541 so2->so_snd.sb_ccc -= datalen; in uipc_soreceive_stream_or_seqpacket()
[all …]
H A Duipc_sockbuf.c378 so->so_snd.sb_state |= SBS_CANTSENDMORE; in socantsendmore_locked()
556 if (so->so_snd.sb_flags & SB_SPLICED) in sowwakeup_locked()
558 else if (sb_notify(&so->so_snd)) in sowwakeup_locked()
608 if (so->so_snd.sb_lowat == 0) in soreserve()
609 so->so_snd.sb_lowat = MCLBYTES; in soreserve()
610 if (so->so_snd.sb_lowat > so->so_snd.sb_hiwat) in soreserve()
611 so->so_snd.sb_lowat = so->so_snd.sb_hiwat; in soreserve()
735 sb = &so->so_snd; in sbsetopt()
H A Duipc_ktls.c1380 if (so->so_snd.sb_tls_info != NULL) in ktls_enable_tx()
1429 if (__predict_false(so->so_snd.sb_tls_info != NULL)) in ktls_enable_tx()
1431 else if ((so->so_snd.sb_flags & SB_SPLICED) != 0) in ktls_enable_tx()
1440 so->so_snd.sb_tls_seqno = be64dec(en->rec_seq); in ktls_enable_tx()
1441 so->so_snd.sb_tls_info = tls; in ktls_enable_tx()
1524 tls = so->so_snd.sb_tls_info; in ktls_get_tx_mode()
1571 SOCKBUF_LOCK(&so->so_snd); in ktls_set_tx_mode()
1572 tls = so->so_snd.sb_tls_info; in ktls_set_tx_mode()
1574 SOCKBUF_UNLOCK(&so->so_snd); in ktls_set_tx_mode()
1579 SOCKBUF_UNLOCK(&so->so_snd); in ktls_set_tx_mode()
[all …]
/freebsd/sys/netinet/
H A Dtcp_output.c388 if (off < sbused(&so->so_snd)) in tcp_default_output()
414 len = imin(sbavail(&so->so_snd), sendwin) - off; in tcp_default_output()
422 imin(sbavail(&so->so_snd), sendwin) - in tcp_default_output()
498 (off < (int) sbavail(&so->so_snd)) && in tcp_default_output()
568 tp->snd_una + sbused(&so->so_snd))) { in tcp_default_output()
613 (uint32_t)len + (uint32_t)off >= sbavail(&so->so_snd) && in tcp_default_output()
747 if (sbavail(&so->so_snd) && !tcp_timer_active(tp, TT_REXMT) && in tcp_default_output()
946 sbavail(&so->so_snd)) { in tcp_default_output()
1078 mb = sbsndptr_noadv(&so->so_snd, off, &moff); in tcp_default_output()
1083 sbsndptr_adv(&so->so_snd, mb, len); in tcp_default_output()
[all …]
H A Dtcp_timewait.c146 if (tptosocket(tp)->so_snd.sb_tls_info != NULL) { in tcp_twstart()
147 ktls_release_snd_tag(tptosocket(tp)->so_snd.sb_tls_info); in tcp_twstart()
H A Dtcp_input.c1514 TCP_LOG_EVENT(tp, th, &so->so_rcv, &so->so_snd, TCP_LOG_IN, 0, in tcp_do_segment()
1797 sbdrop(&so->so_snd, acked); in tcp_do_segment()
1835 if (sbavail(&so->so_snd) == 0) in tcp_do_segment()
1851 (sbavail(&so->so_snd) >= in tcp_do_segment()
2742 avail = sbavail(&so->so_snd); in tcp_do_segment()
2924 acked == sbavail(&so->so_snd)) || in tcp_do_segment()
2925 acked > sbavail(&so->so_snd)) in tcp_do_segment()
2958 if (acked > sbavail(&so->so_snd)) { in tcp_do_segment()
2959 if (tp->snd_wnd >= sbavail(&so->so_snd)) in tcp_do_segment()
2960 tp->snd_wnd -= sbavail(&so->so_snd); in tcp_do_segment()
[all …]
H A Dsctputil.h247 SCTP_SB_DECR(&stcb->sctp_socket->so_snd, sp->length); \
258 SCTP_SB_INCR(&stcb->sctp_socket->so_snd, sz); \
H A Dtcp_usrreq.c168 so->so_snd.sb_flags |= (SB_AUTOLOWAT | SB_AUTOSIZE); in tcp_usr_attach()
1026 sbappendstream(&so->so_snd, m, flags); in tcp_usr_send()
1057 sbflush(&so->so_snd); in tcp_usr_send()
1078 (so->so_snd.sb_ccc > 0)) { in tcp_usr_send()
1097 if (sbspace(&so->so_snd) < -512) { in tcp_usr_send()
1112 sbappendstream_locked(&so->so_snd, m, flags); in tcp_usr_send()
1147 sbflush(&so->so_snd); in tcp_usr_send()
1153 tp->snd_up = tp->snd_una + sbavail(&so->so_snd); in tcp_usr_send()
1162 &inp->inp_socket->so_snd, in tcp_usr_send()
1207 error = sbready(&so->so_snd, m, count); in tcp_usr_ready()
/freebsd/sys/dev/iscsi/
H A Dicl_soft.c892 SOCKBUF_LOCK(&so->so_snd); in icl_conn_send_pdus()
899 available = sbspace(&so->so_snd); in icl_conn_send_pdus()
906 so->so_snd.sb_lowat = so->so_snd.sb_hiwat + 1; in icl_conn_send_pdus()
907 SOCKBUF_UNLOCK(&so->so_snd); in icl_conn_send_pdus()
919 SOCKBUF_LOCK(&so->so_snd); in icl_conn_send_pdus()
920 available = sbspace(&so->so_snd); in icl_conn_send_pdus()
927 so->so_snd.sb_lowat = max(size, in icl_conn_send_pdus()
928 so->so_snd.sb_hiwat / 8); in icl_conn_send_pdus()
929 SOCKBUF_UNLOCK(&so->so_snd); in icl_conn_send_pdus()
932 SOCKBUF_UNLOCK(&so->so_snd); in icl_conn_send_pdus()
[all …]
/freebsd/sys/dev/nvmf/
H A Dnvmf_tcp.c269 SOCKBUF_LOCK(&so->so_snd); in nvmf_tcp_write_pdu()
274 SOCKBUF_UNLOCK(&so->so_snd); in nvmf_tcp_write_pdu()
1308 SOCKBUF_LOCK(&so->so_snd); in nvmf_tcp_send()
1312 SOCKBUF_UNLOCK(&so->so_snd); in nvmf_tcp_send()
1316 SOCKBUF_LOCK(&so->so_snd); in nvmf_tcp_send()
1318 cv_wait(&qp->tx_cv, SOCKBUF_MTX(&so->so_snd)); in nvmf_tcp_send()
1328 cv_wait(&qp->tx_cv, SOCKBUF_MTX(&so->so_snd)); in nvmf_tcp_send()
1335 SOCKBUF_UNLOCK(&so->so_snd); in nvmf_tcp_send()
1340 SOCKBUF_LOCK(&so->so_snd); in nvmf_tcp_send()
1350 space = sbspace(&so->so_snd); in nvmf_tcp_send()
[all …]
/freebsd/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()
375 ((sbspace(&(so)->so_snd) >= (so)->so_snd.sb_lowat && \
378 ((so)->so_snd.sb_state & SBS_CANTSENDMORE) || \
640 } so_rcv, so_snd; member
/freebsd/usr.bin/bluetooth/btsockstat/
H A Dbtsockstat.c261 so.so_snd.sb_ccc, in hcirawpr()
309 so.so_snd.sb_ccc, in l2caprawpr()
367 so.so_snd.sb_ccc, in l2cappr()
473 so.so_snd.sb_ccc, in rfcommpr()
/freebsd/sys/dev/cxgbe/nvmf/
H A Dnvmf_che.c2276 SOCKBUF_LOCK(&so->so_snd); in nvmf_che_send()
2280 SOCKBUF_UNLOCK(&so->so_snd); in nvmf_che_send()
2283 SOCKBUF_LOCK(&so->so_snd); in nvmf_che_send()
2285 cv_wait(&qp->tx_cv, SOCKBUF_MTX(&so->so_snd)); in nvmf_che_send()
2290 cv_wait(&qp->tx_cv, SOCKBUF_MTX(&so->so_snd)); in nvmf_che_send()
2297 SOCKBUF_UNLOCK(&so->so_snd); in nvmf_che_send()
2304 SOCKBUF_LOCK(&so->so_snd); in nvmf_che_send()
2306 SOCKBUF_UNLOCK(&so->so_snd); in nvmf_che_send()
2317 SOCKBUF_LOCK(&so->so_snd); in nvmf_che_setsockopt()
2318 if (sspace < so->so_snd.sb_hiwat) in nvmf_che_setsockopt()
[all …]
/freebsd/usr.bin/netstat/
H A Dinet.c176 sbtoxsockbuf(&so->so_snd, &xso->so_snd); 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()
H A Dnetgraph.c121 name, sockb.so_rcv.sb_ccc, sockb.so_snd.sb_ccc); in netgraphprotopr()
/freebsd/sys/netgraph/bluetooth/socket/
H A Dng_btsocket_sco.c901 sbdroprecord(&pcb->so->so_snd); in ng_btsocket_sco_default_msg_input()
904 if (sbavail(&pcb->so->so_snd) > 0) in ng_btsocket_sco_default_msg_input()
1205 if ((so->so_snd.sb_hiwat == 0) || (so->so_rcv.sb_hiwat == 0)) { in ng_btsocket_sco_attach()
1695 sbappendrecord(&pcb->so->so_snd, m); in ng_btsocket_sco_send()
1703 sbdroprecord(&pcb->so->so_snd); /* XXX */ in ng_btsocket_sco_send()
1728 sbavail(&pcb->so->so_snd) > 0) { in ng_btsocket_sco_send2()
1730 m = m_dup(pcb->so->so_snd.sb_mb, M_NOWAIT); in ng_btsocket_sco_send2()
1944 sbdroprecord(&pcb->so->so_snd); in ng_btsocket_sco_process_timeout()
/freebsd/sys/netinet/tcp_stacks/
H A Dbbr.c579 sbavail(&tptosocket(tp)->so_snd)) { in bbr_timer_start()
1887 &bbr->rc_inp->inp_socket->so_snd, in bbr_log_type_bw_reduce()
1905 &bbr->rc_inp->inp_socket->so_snd, in bbr_log_type_rwnd_collapse()
1931 &bbr->rc_inp->inp_socket->so_snd, in bbr_log_type_just_return()
1949 &bbr->rc_inp->inp_socket->so_snd, in bbr_log_type_enter_rec()
1968 &bbr->rc_inp->inp_socket->so_snd, in bbr_log_msgsize_fail()
1984 s = &bbr->rc_inp->inp_socket->so_snd; in bbr_log_flowend()
2015 &bbr->rc_inp->inp_socket->so_snd, in bbr_log_pkt_epoch()
2029 log.u_bbr.flex2 = bbr->rc_inp->inp_socket->so_snd.sb_lowat; in bbr_log_time_epoch()
2030 log.u_bbr.flex3 = bbr->rc_inp->inp_socket->so_snd.sb_hiwat; in bbr_log_time_epoch()
[all …]
H A Drack.c762 &rack->rc_inp->inp_socket->so_snd, in rack_log_gpset()
1981 &rack->rc_inp->inp_socket->so_snd, in rack_log_hybrid_bw()
2066 &rack->rc_inp->inp_socket->so_snd, in rack_log_hybrid_sends()
2414 &rack->rc_inp->inp_socket->so_snd, in rack_log_dsack_event()
2466 &rack->rc_inp->inp_socket->so_snd, in rack_log_hdwr_pacing()
2570 &rack->rc_inp->inp_socket->so_snd, in rack_log_retran_reason()
2613 &rack->rc_inp->inp_socket->so_snd, in rack_log_to_start()
2649 &rack->rc_inp->inp_socket->so_snd, in rack_log_to_event()
2703 &rack->rc_inp->inp_socket->so_snd, in rack_log_map_chg()
2771 &rack->rc_inp->inp_socket->so_snd, in rack_log_rtt_upd()
[all …]
/freebsd/sys/dev/hyperv/hvsock/
H A Dhv_sock.c765 if (so->so_snd.sb_state & SBS_CANTSENDMORE) { in hvs_trans_soreceive()
814 sb = &so->so_snd; in hvs_trans_sosend()
1009 &so->so_snd); in hvs_trans_shutdown()
1123 SOCKBUF_LOCK(&(so)->so_snd); in hvsock_chan_cb()
1132 SOCKBUF_UNLOCK(&(so)->so_snd); in hvsock_chan_cb()
1408 sndbuf = MAX(so->so_snd.sb_hiwat, HVS_RINGBUF_SND_SIZE); in hvsock_open_channel()
/freebsd/sys/dev/cxgbe/tom/
H A Dt4_cpl_io.c291 sbflush(&so->so_snd); in send_reset()
697 struct sockbuf *sb = &so->so_snd; in t4_push_frames()
1453 struct sockbuf *sb = &so->so_snd; in t4_push_pdus()
2244 struct sockbuf *sb = &so->so_snd; in do_fw4_ack()
2537 sb = &so->so_snd; in t4_aiotx_process_job()
2554 if (so->so_snd.sb_state & SBS_CANTSENDMORE) { in t4_aiotx_process_job()
2713 SOCKBUF_LOCK(&so->so_snd); in t4_aiotx_task()
2723 SOCKBUF_UNLOCK(&so->so_snd); in t4_aiotx_task()
2735 SOCKBUF_LOCK_ASSERT(&toep->inp->inp_socket->so_snd); in t4_aiotx_queue_toep()
2760 sb = &so->so_snd; in t4_aiotx_cancel()
[all …]

123