Home
last modified time | relevance | path

Searched refs:so_snd (Results 1 – 25 of 55) 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.c178 so->so_snd.sb_flags |= SB_ASYNC; in soo_ioctl()
193 so->so_snd.sb_flags &= ~SB_ASYNC; in soo_ioctl()
215 *(int *)data = sbavail(&so->so_snd); in soo_ioctl()
224 if ((so->so_snd.sb_hiwat < sbused(&so->so_snd)) || in soo_ioctl()
225 (so->so_snd.sb_mbmax < so->so_snd.sb_mbcnt)) { in soo_ioctl()
228 *(int *)data = sbspace(&so->so_snd); in soo_ioctl()
322 sb = &so->so_snd; in soo_stat()
395 so->so_snd.sb_state; in soo_fill_kinfo()
397 sbused(&so->so_snd); in soo_fill_kinfo()
410 so->so_snd.sb_state; in soo_fill_kinfo()
[all …]
H A Duipc_socket.c536 sb_dst = &so_dst->so_snd; in so_splice_xfer_data()
659 sbspace(&so_dst->so_snd) > 0) { in so_splice_xfer()
811 so->so_snd.sb_sel = &so->so_wrsel; in soalloc()
814 TAILQ_INIT(&so->so_snd.sb_aiojobq); in soalloc()
816 TASK_INIT(&so->so_snd.sb_aiotask, 0, soaio_snd, so); in soalloc()
878 if (so->so_snd.sb_hiwat) in sodealloc()
880 &so->so_snd.sb_hiwat, 0, RLIM_INFINITY); in sodealloc()
958 so->so_snd.sb_mtx = &so->so_snd_mtx; in socreate()
1201 so->so_snd.sb_lowat = head->sol_sbsnd_lowat;
1203 so->so_snd.sb_timeo = head->sol_sbsnd_timeo;
[all …]
H A Dkern_sendfile.c742 tls = ktls_hold(so->so_snd.sb_tls_info); in vn_sendfile()
779 SOCKBUF_LOCK(&so->so_snd); in vn_sendfile()
780 if (so->so_snd.sb_lowat < so->so_snd.sb_hiwat / 2) in vn_sendfile()
781 so->so_snd.sb_lowat = so->so_snd.sb_hiwat / 2; in vn_sendfile()
783 if (so->so_snd.sb_state & SBS_CANTSENDMORE) { in vn_sendfile()
785 SOCKBUF_UNLOCK(&so->so_snd); in vn_sendfile()
790 SOCKBUF_UNLOCK(&so->so_snd); in vn_sendfile()
794 SOCKBUF_UNLOCK(&so->so_snd); in vn_sendfile()
799 space = sbspace(&so->so_snd); in vn_sendfile()
802 space < so->so_snd.sb_lowat)) { in vn_sendfile()
[all …]
H A Duipc_usrreq.c448 if (so->so_snd.sb_hiwat == 0 || so->so_rcv.sb_hiwat == 0) { in uipc_attach()
457 STAILQ_INIT(&so->so_snd.uxdg_mb); in uipc_attach()
833 MPASS(STAILQ_EMPTY(&so->so_snd.uxdg_mb)); in uipc_detach()
955 SOCKBUF_LOCK(&so2->so_snd); in uipc_rcvd()
956 if (sbcc < so2->so_snd.sb_hiwat && mbcnt < so2->so_snd.sb_mbmax) in uipc_rcvd()
957 so2->so_snd.sb_flags &= ~SB_STOP; in uipc_rcvd()
1002 } else if (so->so_snd.sb_state & SBS_CANTSENDMORE) { in uipc_send()
1065 SOCKBUF_LOCK(&so->so_snd); in uipc_send()
1066 if (sbcc >= so->so_snd.sb_hiwat || mbcnt >= so->so_snd.sb_mbmax) in uipc_send()
1067 so->so_snd.sb_flags |= SB_STOP; in uipc_send()
[all …]
H A Duipc_sockbuf.c384 so->so_snd.sb_state |= SBS_CANTSENDMORE; in socantsendmore_locked()
563 if (so->so_snd.sb_flags & SB_SPLICED) in sowwakeup_locked()
565 else if (sb_notify(&so->so_snd)) in sowwakeup_locked()
615 if (so->so_snd.sb_lowat == 0) in soreserve()
616 so->so_snd.sb_lowat = MCLBYTES; in soreserve()
617 if (so->so_snd.sb_lowat > so->so_snd.sb_hiwat) in soreserve()
618 so->so_snd.sb_lowat = so->so_snd.sb_hiwat; in soreserve()
730 sb = &so->so_snd; in sbsetopt()
H A Duipc_ktls.c1389 if (so->so_snd.sb_tls_info != NULL) in ktls_enable_tx()
1435 if (__predict_false(so->so_snd.sb_tls_info != NULL)) { in ktls_enable_tx()
1442 so->so_snd.sb_tls_seqno = be64dec(en->rec_seq); in ktls_enable_tx()
1443 so->so_snd.sb_tls_info = tls; in ktls_enable_tx()
1534 tls = so->so_snd.sb_tls_info; in ktls_get_tx_mode()
1581 SOCKBUF_LOCK(&so->so_snd); in ktls_set_tx_mode()
1582 tls = so->so_snd.sb_tls_info; in ktls_set_tx_mode()
1584 SOCKBUF_UNLOCK(&so->so_snd); in ktls_set_tx_mode()
1589 SOCKBUF_UNLOCK(&so->so_snd); in ktls_set_tx_mode()
1594 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()
421 len = imin(sbavail(&so->so_snd) - off, in tcp_default_output()
497 (off < (int) sbavail(&so->so_snd)) && in tcp_default_output()
567 tp->snd_una + sbused(&so->so_snd))) { in tcp_default_output()
612 (uint32_t)len + (uint32_t)off >= sbavail(&so->so_snd) && in tcp_default_output()
746 if (sbavail(&so->so_snd) && !tcp_timer_active(tp, TT_REXMT) && in tcp_default_output()
945 sbavail(&so->so_snd)) { in tcp_default_output()
1077 mb = sbsndptr_noadv(&so->so_snd, off, &moff); in tcp_default_output()
1082 sbsndptr_adv(&so->so_snd, mb, len); in tcp_default_output()
[all …]
H A Dtcp_input.c1555 TCP_LOG_EVENT(tp, th, &so->so_rcv, &so->so_snd, TCP_LOG_IN, 0, in tcp_do_segment()
1842 sbdrop(&so->so_snd, acked); in tcp_do_segment()
1880 if (sbavail(&so->so_snd) == 0) in tcp_do_segment()
1896 (sbavail(&so->so_snd) >= in tcp_do_segment()
2823 avail = sbavail(&so->so_snd); in tcp_do_segment()
3009 acked == sbavail(&so->so_snd)) || in tcp_do_segment()
3010 acked > sbavail(&so->so_snd)) in tcp_do_segment()
3043 if (acked > sbavail(&so->so_snd)) { in tcp_do_segment()
3044 if (tp->snd_wnd >= sbavail(&so->so_snd)) in tcp_do_segment()
3045 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); \
/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.c268 SOCKBUF_LOCK(&so->so_snd); in nvmf_tcp_write_pdu()
273 SOCKBUF_UNLOCK(&so->so_snd); in nvmf_tcp_write_pdu()
1307 SOCKBUF_LOCK(&so->so_snd); in nvmf_tcp_send()
1311 SOCKBUF_UNLOCK(&so->so_snd); in nvmf_tcp_send()
1315 SOCKBUF_LOCK(&so->so_snd); in nvmf_tcp_send()
1317 cv_wait(&qp->tx_cv, SOCKBUF_MTX(&so->so_snd)); in nvmf_tcp_send()
1327 cv_wait(&qp->tx_cv, SOCKBUF_MTX(&so->so_snd)); in nvmf_tcp_send()
1334 SOCKBUF_UNLOCK(&so->so_snd); in nvmf_tcp_send()
1339 SOCKBUF_LOCK(&so->so_snd); in nvmf_tcp_send()
1349 space = sbspace(&so->so_snd); in nvmf_tcp_send()
[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()
374 ((sbspace(&(so)->so_snd) >= (so)->so_snd.sb_lowat && \
377 ((so)->so_snd.sb_state & SBS_CANTSENDMORE) || \
636 } 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/usr.bin/netstat/
H A Dinet.c173 sbtoxsockbuf(&so->so_snd, &xso->so_snd); in sotoxsocket()
406 so->so_rcv.sb_cc, so->so_snd.sb_cc); in protopr()
485 so->so_rcv.sb_hiwat, so->so_snd.sb_hiwat, in protopr()
486 so->so_rcv.sb_lowat, so->so_snd.sb_lowat, in protopr()
487 so->so_rcv.sb_mbcnt, so->so_snd.sb_mbcnt, in protopr()
488 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()
H A Dng_btsocket_rfcomm.c397 if ((so->so_snd.sb_hiwat == 0) || (so->so_rcv.sb_hiwat == 0)) { in ng_btsocket_rfcomm_attach()
967 sbappend(&pcb->so->so_snd, m, flags); in ng_btsocket_rfcomm_send()
1054 SOCKBUF_LOCK(&s->l2so->so_snd); in ng_btsocket_rfcomm_sessions_task()
1056 SOCKBUF_UNLOCK(&s->l2so->so_snd); in ng_btsocket_rfcomm_sessions_task()
1292 SOCKBUF_LOCK(&l2so->so_snd); in ng_btsocket_rfcomm_session_create()
1294 SOCKBUF_UNLOCK(&l2so->so_snd); in ng_btsocket_rfcomm_session_create()
1378 SOCKBUF_LOCK(&l2so->so_snd); in ng_btsocket_rfcomm_session_create()
1380 SOCKBUF_UNLOCK(&l2so->so_snd); in ng_btsocket_rfcomm_session_create()
3252 length = min(pcb->mtu, sbavail(&pcb->so->so_snd)); in ng_btsocket_rfcomm_pcb_send()
3257 m = ng_btsocket_rfcomm_prepare_packet(&pcb->so->so_snd, length); in ng_btsocket_rfcomm_pcb_send()
[all …]
/freebsd/sys/netsmb/
H A Dsmb_trantcp.c158 so->so_snd.sb_timeo = (5 * SBT_1S); in nb_connect_in()
167 SOCKBUF_LOCK(&so->so_snd); in nb_connect_in()
168 so->so_snd.sb_flags &= ~SB_NOINTR; in nb_connect_in()
169 SOCKBUF_UNLOCK(&so->so_snd); in nb_connect_in()
/freebsd/sys/netinet/tcp_stacks/
H A Dbbr.c581 sbavail(&tptosocket(tp)->so_snd)) { in bbr_timer_start()
981 } else if (sbavail(&inp->inp_socket->so_snd) && in bbr_timer_audit()
1899 &bbr->rc_inp->inp_socket->so_snd, in bbr_log_type_bw_reduce()
1917 &bbr->rc_inp->inp_socket->so_snd, in bbr_log_type_rwnd_collapse()
1943 &bbr->rc_inp->inp_socket->so_snd, in bbr_log_type_just_return()
1961 &bbr->rc_inp->inp_socket->so_snd, in bbr_log_type_enter_rec()
1980 &bbr->rc_inp->inp_socket->so_snd, in bbr_log_msgsize_fail()
1996 s = &bbr->rc_inp->inp_socket->so_snd; in bbr_log_flowend()
2027 &bbr->rc_inp->inp_socket->so_snd, in bbr_log_pkt_epoch()
2041 log.u_bbr.flex2 = bbr->rc_inp->inp_socket->so_snd.sb_lowat; in bbr_log_time_epoch()
[all …]
H A Drack.c782 &rack->rc_inp->inp_socket->so_snd, in rack_log_gpset()
2131 &rack->rc_inp->inp_socket->so_snd, in rack_log_hybrid_bw()
2216 &rack->rc_inp->inp_socket->so_snd, in rack_log_hybrid_sends()
2564 &rack->rc_inp->inp_socket->so_snd, in rack_log_dsack_event()
2616 &rack->rc_inp->inp_socket->so_snd, in rack_log_hdwr_pacing()
2720 &rack->rc_inp->inp_socket->so_snd, in rack_log_retran_reason()
2763 &rack->rc_inp->inp_socket->so_snd, in rack_log_to_start()
2799 &rack->rc_inp->inp_socket->so_snd, in rack_log_to_event()
2851 &rack->rc_inp->inp_socket->so_snd, in rack_log_map_chg()
2919 &rack->rc_inp->inp_socket->so_snd, in rack_log_rtt_upd()
[all …]
/freebsd/sys/dev/cxgbe/tom/
H A Dt4_cpl_io.c285 sbflush(&so->so_snd); in send_reset()
646 struct sockbuf *sb = &so->so_snd; in t4_push_frames()
1150 struct sockbuf *sb = &so->so_snd; in t4_push_pdus()
1907 struct sockbuf *sb = &so->so_snd; in do_fw4_ack()
2179 sb = &so->so_snd; in t4_aiotx_process_job()
2196 if (so->so_snd.sb_state & SBS_CANTSENDMORE) { in t4_aiotx_process_job()
2355 SOCKBUF_LOCK(&so->so_snd); in t4_aiotx_task()
2365 SOCKBUF_UNLOCK(&so->so_snd); in t4_aiotx_task()
2377 SOCKBUF_LOCK_ASSERT(&toep->inp->inp_socket->so_snd); in t4_aiotx_queue_toep()
2402 sb = &so->so_snd; in t4_aiotx_cancel()
[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/netlink/
H A Dnetlink_domain.c347 TAILQ_INIT(&so->so_snd.nl_queue); in nl_pru_attach()
525 while ((nb = TAILQ_FIRST(&so->so_snd.nl_queue)) != NULL) { in nl_close()
526 TAILQ_REMOVE(&so->so_snd.nl_queue, nb, tailq); in nl_close()
567 struct sockbuf *sb = &so->so_snd; in nl_sosend()

123