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.c551 sb_dst = &so_dst->so_snd; in so_splice_xfer_data()
669 sbspace(&so_dst->so_snd) > 0) { in so_splice_xfer()
821 so->so_snd.sb_sel = &so->so_wrsel; in soalloc()
824 TAILQ_INIT(&so->so_snd.sb_aiojobq); in soalloc()
826 TASK_INIT(&so->so_snd.sb_aiotask, 0, soaio_snd, so); in soalloc()
888 if (so->so_snd.sb_hiwat) in sodealloc()
890 &so->so_snd.sb_hiwat, 0, RLIM_INFINITY); in sodealloc()
968 so->so_snd.sb_mtx = &so->so_snd_mtx; in socreate()
1211 so->so_snd.sb_lowat = head->sol_sbsnd_lowat;
1213 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.c456 STAILQ_INIT(&so->so_snd.uxdg_mb); in uipc_attach()
831 MPASS(STAILQ_EMPTY(&so->so_snd.uxdg_mb)); in uipc_detach()
953 SOCKBUF_LOCK(&so2->so_snd); in uipc_rcvd()
954 if (sbcc < so2->so_snd.sb_hiwat && mbcnt < so2->so_snd.sb_mbmax) in uipc_rcvd()
955 so2->so_snd.sb_flags &= ~SB_STOP; in uipc_rcvd()
1000 } else if (so->so_snd.sb_state & SBS_CANTSENDMORE) { in uipc_send()
1063 SOCKBUF_LOCK(&so->so_snd); in uipc_send()
1064 if (sbcc >= so->so_snd.sb_hiwat || mbcnt >= so->so_snd.sb_mbmax) in uipc_send()
1065 so->so_snd.sb_flags |= SB_STOP; in uipc_send()
1066 SOCKBUF_UNLOCK(&so->so_snd); in uipc_send()
[all …]
H A Duipc_sockbuf.c384 so->so_snd.sb_state |= SBS_CANTSENDMORE; in socantsendmore_locked()
562 if (so->so_snd.sb_flags & SB_SPLICED) in sowwakeup_locked()
564 else if (sb_notify(&so->so_snd)) in sowwakeup_locked()
614 if (so->so_snd.sb_lowat == 0) in soreserve()
615 so->so_snd.sb_lowat = MCLBYTES; in soreserve()
616 if (so->so_snd.sb_lowat > so->so_snd.sb_hiwat) in soreserve()
617 so->so_snd.sb_lowat = so->so_snd.sb_hiwat; in soreserve()
729 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.c391 if (off < sbused(&so->so_snd)) in tcp_default_output()
417 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()
571 tp->snd_una + sbused(&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()
1081 mb = sbsndptr_noadv(&so->so_snd, off, &moff); in tcp_default_output()
1086 sbsndptr_adv(&so->so_snd, mb, len); in tcp_default_output()
[all …]
H A Dtcp_input.c1553 TCP_LOG_EVENT(tp, th, &so->so_rcv, &so->so_snd, TCP_LOG_IN, 0, in tcp_do_segment()
1837 sbdrop(&so->so_snd, acked); in tcp_do_segment()
1875 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()
[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.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) || \
638 } 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.c174 sbtoxsockbuf(&so->so_snd, &xso->so_snd); 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()
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 …]
H A Dng_btsocket_l2cap.c1195 sbdroprecord(&pcb->so->so_snd); in ng_btsocket_l2cap_process_l2ca_write_rsp()
1196 if (sbavail(&pcb->so->so_snd) > 0) { in ng_btsocket_l2cap_process_l2ca_write_rsp()
1200 sbdroprecord(&pcb->so->so_snd); /* XXX */ in ng_btsocket_l2cap_process_l2ca_write_rsp()
1997 if ((so->so_snd.sb_hiwat == 0) || (so->so_rcv.sb_hiwat == 0)) { in ng_btsocket_l2cap_attach()
2605 sbappendrecord(&pcb->so->so_snd, m); in ng_btsocket_l2cap_send()
2613 sbdroprecord(&pcb->so->so_snd); /* XXX */ in ng_btsocket_l2cap_send()
2637 if (sbavail(&pcb->so->so_snd) == 0) in ng_btsocket_l2cap_send2()
2640 m = m_dup(pcb->so->so_snd.sb_mb, M_NOWAIT); in ng_btsocket_l2cap_send2()
2841 sbdroprecord(&pcb->so->so_snd); in ng_btsocket_l2cap_process_timeout()
/freebsd/sys/netinet/tcp_stacks/
H A Dbbr.c581 sbavail(&tptosocket(tp)->so_snd)) { in bbr_timer_start()
1891 &bbr->rc_inp->inp_socket->so_snd, in bbr_log_type_bw_reduce()
1909 &bbr->rc_inp->inp_socket->so_snd, in bbr_log_type_rwnd_collapse()
1935 &bbr->rc_inp->inp_socket->so_snd, in bbr_log_type_just_return()
1953 &bbr->rc_inp->inp_socket->so_snd, in bbr_log_type_enter_rec()
1972 &bbr->rc_inp->inp_socket->so_snd, in bbr_log_msgsize_fail()
1988 s = &bbr->rc_inp->inp_socket->so_snd; in bbr_log_flowend()
2019 &bbr->rc_inp->inp_socket->so_snd, in bbr_log_pkt_epoch()
2033 log.u_bbr.flex2 = bbr->rc_inp->inp_socket->so_snd.sb_lowat; in bbr_log_time_epoch()
2034 log.u_bbr.flex3 = bbr->rc_inp->inp_socket->so_snd.sb_hiwat; in bbr_log_time_epoch()
[all …]
H A Drack.c780 &rack->rc_inp->inp_socket->so_snd, in rack_log_gpset()
2109 &rack->rc_inp->inp_socket->so_snd, in rack_log_hybrid_bw()
2194 &rack->rc_inp->inp_socket->so_snd, in rack_log_hybrid_sends()
2542 &rack->rc_inp->inp_socket->so_snd, in rack_log_dsack_event()
2594 &rack->rc_inp->inp_socket->so_snd, in rack_log_hdwr_pacing()
2698 &rack->rc_inp->inp_socket->so_snd, in rack_log_retran_reason()
2741 &rack->rc_inp->inp_socket->so_snd, in rack_log_to_start()
2777 &rack->rc_inp->inp_socket->so_snd, in rack_log_to_event()
2829 &rack->rc_inp->inp_socket->so_snd, in rack_log_map_chg()
2897 &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.c340 TAILQ_INIT(&so->so_snd.nl_queue); in nl_attach()
511 while ((nb = TAILQ_FIRST(&so->so_snd.nl_queue)) != NULL) { in nl_close()
512 TAILQ_REMOVE(&so->so_snd.nl_queue, nb, tailq); in nl_close()
553 struct sockbuf *sb = &so->so_snd; in nl_sosend()

123