Home
last modified time | relevance | path

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

123

/freebsd-14-stable/sys/ofed/drivers/infiniband/ulp/sdp/
HDsdp_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 …]
HDsdp_main.c436 if (so->so_snd.sb_hiwat == 0 || so->so_rcv.sb_hiwat == 0) { in sdp_attach()
442 so->so_snd.sb_flags |= SB_AUTOSIZE; in sdp_attach()
963 SOCKBUF_LOCK(&so->so_snd); in sdp_send()
964 sdp_append(ssk, &so->so_snd, m, cnt); in sdp_send()
965 SOCKBUF_UNLOCK(&so->so_snd); in sdp_send()
989 SOCKBUF_LOCK(&so->so_snd); in sdp_send()
990 if (sbspace(&so->so_snd) < -512) { in sdp_send()
991 SOCKBUF_UNLOCK(&so->so_snd); in sdp_send()
1005 sdp_append(ssk, &so->so_snd, m, cnt); in sdp_send()
1006 SOCKBUF_UNLOCK(&so->so_snd); in sdp_send()
[all …]
/freebsd-14-stable/sys/netinet/
HDtcp_output.c352 SOCKBUF_LOCK(&so->so_snd); in tcp_default_output()
377 if (off < sbused(&so->so_snd)) in tcp_default_output()
403 len = ((int32_t)min(sbavail(&so->so_snd), sendwin) - in tcp_default_output()
413 len = ((int32_t)min(sbavail(&so->so_snd), tp->snd_wnd) - in tcp_default_output()
505 (off < (int) sbavail(&so->so_snd)) && in tcp_default_output()
575 if (SEQ_LT(p->rxmit + len, tp->snd_una + sbused(&so->so_snd))) in tcp_default_output()
579 sbused(&so->so_snd))) in tcp_default_output()
624 (uint32_t)len + (uint32_t)off >= sbavail(&so->so_snd) && in tcp_default_output()
759 if (sbavail(&so->so_snd) && !tcp_timer_active(tp, TT_REXMT) && in tcp_default_output()
769 SOCKBUF_UNLOCK(&so->so_snd); in tcp_default_output()
[all …]
HDtcp_input.c1561 TCP_LOG_EVENT(tp, th, &so->so_rcv, &so->so_snd, TCP_LOG_IN, 0, in tcp_do_segment()
1830 sbdrop(&so->so_snd, acked); in tcp_do_segment()
1868 if (sbavail(&so->so_snd) == 0) in tcp_do_segment()
1883 if (SEQ_GT(tp->snd_una + sbavail(&so->so_snd), in tcp_do_segment()
2786 SOCKBUF_LOCK(&so->so_snd); in tcp_do_segment()
2787 avail = sbavail(&so->so_snd) - in tcp_do_segment()
2789 SOCKBUF_UNLOCK(&so->so_snd); in tcp_do_segment()
2960 SOCKBUF_LOCK(&so->so_snd); in tcp_do_segment()
2968 acked == sbavail(&so->so_snd)) || in tcp_do_segment()
2969 acked > sbavail(&so->so_snd)) in tcp_do_segment()
[all …]
HDtcp_usrreq.c172 so->so_snd.sb_flags |= SB_AUTOSIZE; in tcp_usr_attach()
1050 sbappendstream(&so->so_snd, m, flags); in tcp_usr_send()
1081 sbflush(&so->so_snd); in tcp_usr_send()
1102 (so->so_snd.sb_ccc > 0)) { in tcp_usr_send()
1121 SOCKBUF_LOCK(&so->so_snd); in tcp_usr_send()
1122 if (sbspace(&so->so_snd) < -512) { in tcp_usr_send()
1123 SOCKBUF_UNLOCK(&so->so_snd); in tcp_usr_send()
1137 sbappendstream_locked(&so->so_snd, m, flags); in tcp_usr_send()
1138 SOCKBUF_UNLOCK(&so->so_snd); in tcp_usr_send()
1172 sbflush(&so->so_snd); in tcp_usr_send()
[all …]
HDsctputil.h247 SCTP_SB_DECR(&stcb->sctp_socket->so_snd, sp->length); \
258 SCTP_SB_INCR(&stcb->sctp_socket->so_snd, sz); \
/freebsd-14-stable/sys/kern/
HDsys_socket.c181 so->so_snd.sb_flags |= SB_ASYNC; in soo_ioctl()
196 so->so_snd.sb_flags &= ~SB_ASYNC; in soo_ioctl()
218 *(int *)data = sbavail(&so->so_snd); in soo_ioctl()
227 if ((so->so_snd.sb_hiwat < sbused(&so->so_snd)) || in soo_ioctl()
228 (so->so_snd.sb_mbmax < so->so_snd.sb_mbcnt)) { in soo_ioctl()
231 *(int *)data = sbspace(&so->so_snd); in soo_ioctl()
325 sb = &so->so_snd; in soo_stat()
402 so->so_snd.sb_state; in soo_fill_kinfo()
404 sbused(&so->so_snd); in soo_fill_kinfo()
417 so->so_snd.sb_state; in soo_fill_kinfo()
[all …]
HDuipc_socket.c551 sb_dst = &so_dst->so_snd; in so_splice_xfer_data()
669 sbspace(&so_dst->so_snd) > 0) { in so_splice_xfer()
819 so->so_snd.sb_sel = &so->so_wrsel; in soalloc()
822 TAILQ_INIT(&so->so_snd.sb_aiojobq); in soalloc()
824 TASK_INIT(&so->so_snd.sb_aiotask, 0, soaio_snd, so); in soalloc()
882 if (so->so_snd.sb_hiwat) in sodealloc()
884 &so->so_snd.sb_hiwat, 0, RLIM_INFINITY); in sodealloc()
962 so->so_snd.sb_mtx = &so->so_snd_mtx; in socreate()
1192 so->so_snd.sb_lowat = head->sol_sbsnd_lowat;
1194 so->so_snd.sb_timeo = head->sol_sbsnd_timeo;
[all …]
HDkern_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 …]
HDuipc_usrreq.c475 if (so->so_snd.sb_hiwat == 0 || so->so_rcv.sb_hiwat == 0) { in uipc_attach()
484 STAILQ_INIT(&so->so_snd.uxdg_mb); in uipc_attach()
857 MPASS(STAILQ_EMPTY(&so->so_snd.uxdg_mb)); in uipc_detach()
981 SOCKBUF_LOCK(&so2->so_snd); in uipc_rcvd()
982 if (sbcc < so2->so_snd.sb_hiwat && mbcnt < so2->so_snd.sb_mbmax) in uipc_rcvd()
983 so2->so_snd.sb_flags &= ~SB_STOP; in uipc_rcvd()
1028 } else if (so->so_snd.sb_state & SBS_CANTSENDMORE) { in uipc_send()
1091 SOCKBUF_LOCK(&so->so_snd); in uipc_send()
1092 if (sbcc >= so->so_snd.sb_hiwat || mbcnt >= so->so_snd.sb_mbmax) in uipc_send()
1093 so->so_snd.sb_flags |= SB_STOP; in uipc_send()
[all …]
HDuipc_sockbuf.c386 so->so_snd.sb_state |= SBS_CANTSENDMORE; in socantsendmore_locked()
565 if (so->so_snd.sb_flags & SB_SPLICED) in sowwakeup_locked()
567 else if (sb_notify(&so->so_snd)) in sowwakeup_locked()
617 if (so->so_snd.sb_lowat == 0) in soreserve()
618 so->so_snd.sb_lowat = MCLBYTES; in soreserve()
619 if (so->so_snd.sb_lowat > so->so_snd.sb_hiwat) in soreserve()
620 so->so_snd.sb_lowat = so->so_snd.sb_hiwat; in soreserve()
732 sb = &so->so_snd; in sbsetopt()
HDuipc_ktls.c1316 if (so->so_snd.sb_tls_info != NULL) in ktls_enable_tx()
1362 if (__predict_false(so->so_snd.sb_tls_info != NULL)) in ktls_enable_tx()
1364 else if ((so->so_snd.sb_flags & SB_SPLICED) != 0) in ktls_enable_tx()
1373 so->so_snd.sb_tls_seqno = be64dec(en->rec_seq); in ktls_enable_tx()
1374 so->so_snd.sb_tls_info = tls; in ktls_enable_tx()
1465 tls = so->so_snd.sb_tls_info; in ktls_get_tx_mode()
1512 SOCKBUF_LOCK(&so->so_snd); in ktls_set_tx_mode()
1513 tls = so->so_snd.sb_tls_info; in ktls_set_tx_mode()
1515 SOCKBUF_UNLOCK(&so->so_snd); in ktls_set_tx_mode()
1520 SOCKBUF_UNLOCK(&so->so_snd); in ktls_set_tx_mode()
[all …]
/freebsd-14-stable/sys/dev/iscsi/
HDicl_soft.c893 SOCKBUF_LOCK(&so->so_snd); in icl_conn_send_pdus()
900 available = sbspace(&so->so_snd); in icl_conn_send_pdus()
907 so->so_snd.sb_lowat = so->so_snd.sb_hiwat + 1; in icl_conn_send_pdus()
908 SOCKBUF_UNLOCK(&so->so_snd); in icl_conn_send_pdus()
920 SOCKBUF_LOCK(&so->so_snd); in icl_conn_send_pdus()
921 available = sbspace(&so->so_snd); in icl_conn_send_pdus()
928 so->so_snd.sb_lowat = max(size, in icl_conn_send_pdus()
929 so->so_snd.sb_hiwat / 8); in icl_conn_send_pdus()
930 SOCKBUF_UNLOCK(&so->so_snd); in icl_conn_send_pdus()
933 SOCKBUF_UNLOCK(&so->so_snd); in icl_conn_send_pdus()
[all …]
/freebsd-14-stable/sys/cam/ctl/
HDctl_ha.c176 SOCKBUF_LOCK(&so->so_snd); in ctl_ha_close()
178 SOCKBUF_UNLOCK(&so->so_snd); in ctl_ha_close()
280 so->so_snd.sb_lowat = so->so_snd.sb_hiwat + 1; in ctl_ha_send()
284 SOCKBUF_LOCK(&so->so_snd); in ctl_ha_send()
285 if (sbspace(&so->so_snd) < softc->ha_sending->m_pkthdr.len) { in ctl_ha_send()
286 so->so_snd.sb_lowat = softc->ha_sending->m_pkthdr.len; in ctl_ha_send()
287 SOCKBUF_UNLOCK(&so->so_snd); in ctl_ha_send()
290 SOCKBUF_UNLOCK(&so->so_snd); in ctl_ha_send()
317 SOCKBUF_LOCK(&so->so_snd); in ctl_ha_sock_setup()
318 so->so_snd.sb_lowat = sizeof(struct ha_msg_wire); in ctl_ha_sock_setup()
[all …]
/freebsd-14-stable/sys/sys/
HDsocketvar.h164 struct sockbuf so_rcv, so_snd; member
316 return (which == SO_RCV ? &so->so_rcv : &so->so_snd); in sobuf()
379 ((sbspace(&(so)->so_snd) >= (so)->so_snd.sb_lowat && \
382 ((so)->so_snd.sb_state & SBS_CANTSENDMORE) || \
638 } so_rcv, so_snd; member
/freebsd-14-stable/usr.bin/bluetooth/btsockstat/
HDbtsockstat.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-14-stable/usr.bin/netstat/
HDinet.c181 sbtoxsockbuf(&so->so_snd, &xso->so_snd); in sotoxsocket()
414 so->so_rcv.sb_cc, so->so_snd.sb_cc); in protopr()
493 so->so_rcv.sb_hiwat, so->so_snd.sb_hiwat, in protopr()
494 so->so_rcv.sb_lowat, so->so_snd.sb_lowat, in protopr()
495 so->so_rcv.sb_mbcnt, so->so_snd.sb_mbcnt, in protopr()
496 so->so_rcv.sb_mbmax, so->so_snd.sb_mbmax); in protopr()
HDnetgraph.c123 name, sockb.so_rcv.sb_ccc, sockb.so_snd.sb_ccc); in netgraphprotopr()
/freebsd-14-stable/sys/netsmb/
HDsmb_trantcp.c159 so->so_snd.sb_timeo = (5 * SBT_1S); in nb_connect_in()
168 SOCKBUF_LOCK(&so->so_snd); in nb_connect_in()
169 so->so_snd.sb_flags &= ~SB_NOINTR; in nb_connect_in()
170 SOCKBUF_UNLOCK(&so->so_snd); in nb_connect_in()
/freebsd-14-stable/sys/netinet/tcp_stacks/
HDrack.c755 &rack->rc_inp->inp_socket->so_snd, in rack_log_gpset()
2100 &rack->rc_inp->inp_socket->so_snd, in rack_log_hybrid_bw()
2155 &rack->rc_inp->inp_socket->so_snd, in rack_log_hybrid_sends()
2494 &rack->rc_inp->inp_socket->so_snd, in rack_log_dsack_event()
2542 &rack->rc_inp->inp_socket->so_snd, in rack_log_hdwr_pacing()
2666 &rack->rc_inp->inp_socket->so_snd, in rack_log_retran_reason()
2705 &rack->rc_inp->inp_socket->so_snd, in rack_log_to_start()
2738 &rack->rc_inp->inp_socket->so_snd, in rack_log_to_event()
2787 &rack->rc_inp->inp_socket->so_snd, in rack_log_map_chg()
2855 &rack->rc_inp->inp_socket->so_snd, in rack_log_rtt_upd()
[all …]
HDbbr.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 …]
/freebsd-14-stable/sys/netgraph/bluetooth/socket/
HDng_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()
1219 if ((so->so_snd.sb_hiwat == 0) || (so->so_rcv.sb_hiwat == 0)) { in ng_btsocket_sco_attach()
1710 sbappendrecord(&pcb->so->so_snd, m); in ng_btsocket_sco_send()
1718 sbdroprecord(&pcb->so->so_snd); /* XXX */ in ng_btsocket_sco_send()
1743 sbavail(&pcb->so->so_snd) > 0) { in ng_btsocket_sco_send2()
1745 m = m_dup(pcb->so->so_snd.sb_mb, M_NOWAIT); in ng_btsocket_sco_send2()
1960 sbdroprecord(&pcb->so->so_snd); in ng_btsocket_sco_process_timeout()
HDng_btsocket_rfcomm.c408 if ((so->so_snd.sb_hiwat == 0) || (so->so_rcv.sb_hiwat == 0)) { in ng_btsocket_rfcomm_attach()
978 sbappend(&pcb->so->so_snd, m, flags); in ng_btsocket_rfcomm_send()
1065 SOCKBUF_LOCK(&s->l2so->so_snd); in ng_btsocket_rfcomm_sessions_task()
1067 SOCKBUF_UNLOCK(&s->l2so->so_snd); in ng_btsocket_rfcomm_sessions_task()
1303 SOCKBUF_LOCK(&l2so->so_snd); in ng_btsocket_rfcomm_session_create()
1305 SOCKBUF_UNLOCK(&l2so->so_snd); in ng_btsocket_rfcomm_session_create()
1389 SOCKBUF_LOCK(&l2so->so_snd); in ng_btsocket_rfcomm_session_create()
1391 SOCKBUF_UNLOCK(&l2so->so_snd); in ng_btsocket_rfcomm_session_create()
3263 length = min(pcb->mtu, sbavail(&pcb->so->so_snd)); in ng_btsocket_rfcomm_pcb_send()
3268 m = ng_btsocket_rfcomm_prepare_packet(&pcb->so->so_snd, length); in ng_btsocket_rfcomm_pcb_send()
[all …]
/freebsd-14-stable/sys/dev/cxgbe/tom/
HDt4_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-14-stable/sys/dev/hyperv/hvsock/
HDhv_sock.c767 if (so->so_snd.sb_state & SBS_CANTSENDMORE) { in hvs_trans_soreceive()
816 sb = &so->so_snd; in hvs_trans_sosend()
1012 sb = &so->so_snd; in hvs_trans_shutdown()
1125 SOCKBUF_LOCK(&(so)->so_snd); in hvsock_chan_cb()
1134 SOCKBUF_UNLOCK(&(so)->so_snd); in hvsock_chan_cb()
1410 sndbuf = MAX(so->so_snd.sb_hiwat, HVS_RINGBUF_SND_SIZE); in hvsock_open_channel()

123