Home
last modified time | relevance | path

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

12

/f-stack/freebsd/netinet/
H A Dtcp_output.c352 SOCKBUF_LOCK(&so->so_snd); in tcp_output()
377 if (off < sbused(&so->so_snd)) in tcp_output()
571 sbused(&so->so_snd))) in tcp_output()
761 SOCKBUF_UNLOCK(&so->so_snd); in tcp_output()
941 sbavail(&so->so_snd)) { in tcp_output()
978 SOCKBUF_UNLOCK(&so->so_snd); in tcp_output()
1053 SOCKBUF_UNLOCK(&so->so_snd); in tcp_output()
1077 msb = &so->so_snd; in tcp_output()
1108 SOCKBUF_UNLOCK(&so->so_snd); in tcp_output()
1110 SOCKBUF_UNLOCK(&so->so_snd); in tcp_output()
[all …]
H A Dsctputil.h262 if (stcb->sctp_socket->so_snd.sb_cc >= tp1->book_size) { \
263 atomic_subtract_int(&((stcb)->sctp_socket->so_snd.sb_cc), tp1->book_size); \
265 stcb->sctp_socket->so_snd.sb_cc = 0; \
283 if (stcb->sctp_socket->so_snd.sb_cc >= sp->length) { \
284 atomic_subtract_int(&stcb->sctp_socket->so_snd.sb_cc,sp->length); \
286 stcb->sctp_socket->so_snd.sb_cc = 0; \
298 atomic_add_int(&stcb->sctp_socket->so_snd.sb_cc,sz); \
H A Dtcp_input.c1824 sbdrop(&so->so_snd, acked); in tcp_do_segment()
1868 if (sbavail(&so->so_snd)) in tcp_do_segment()
2739 SOCKBUF_LOCK(&so->so_snd); in tcp_do_segment()
2740 avail = sbavail(&so->so_snd) - in tcp_do_segment()
2742 SOCKBUF_UNLOCK(&so->so_snd); in tcp_do_segment()
2908 SOCKBUF_LOCK(&so->so_snd); in tcp_do_segment()
2915 (int)sbavail(&so->so_snd)); in tcp_do_segment()
2925 SOCKBUF_UNLOCK(&so->so_snd); in tcp_do_segment()
3831 SOCKBUF_LOCK(&so->so_snd); in tcp_mss()
3835 bufsize = so->so_snd.sb_hiwat; in tcp_mss()
[all …]
H A Dtcp_usrreq.c182 so->so_snd.sb_flags |= SB_AUTOSIZE; in tcp_usr_attach()
1201 sbappendstream(&so->so_snd, m, flags); in tcp_usr_send()
1247 (so->so_snd.sb_ccc > 0)) { in tcp_usr_send()
1266 SOCKBUF_LOCK(&so->so_snd); in tcp_usr_send()
1267 if (sbspace(&so->so_snd) < -512) { in tcp_usr_send()
1268 SOCKBUF_UNLOCK(&so->so_snd); in tcp_usr_send()
1282 SOCKBUF_UNLOCK(&so->so_snd); in tcp_usr_send()
1328 &inp->inp_socket->so_snd, in tcp_usr_send()
1366 SOCKBUF_LOCK(&so->so_snd); in tcp_usr_ready()
1367 error = sbready(&so->so_snd, m, count); in tcp_usr_ready()
[all …]
H A Dtcp_ratelimit.c1225 if (tp->t_inpcb->inp_socket->so_snd.sb_flags & SB_TLS_IFNET) { in tcp_set_pacing_rate()
1226 tls = tp->t_inpcb->inp_socket->so_snd.sb_tls_info; in tcp_set_pacing_rate()
1284 if (tp->t_inpcb->inp_socket->so_snd.sb_flags & SB_TLS_IFNET) { in tcp_chg_pacing_rate()
1285 tls = tp->t_inpcb->inp_socket->so_snd.sb_tls_info; in tcp_chg_pacing_rate()
H A Dtcp_subr.c723 if ((!TCPS_HAVEESTABLISHED(tp->t_state) || sbavail(&so->so_snd) || in tcp_default_fb_init()
733 (int32_t)sbavail(&so->so_snd)) in tcp_default_fb_init()
1977 if (ssthresh != 0 && ssthresh < so->so_snd.sb_hiwat / 2) { in tcp_discardcb()
2918 SOCKBUF_LOCK(&so->so_snd); in tcp_mtudisc()
2920 if (so->so_snd.sb_hiwat < tp->t_maxseg) in tcp_mtudisc()
2921 tp->t_maxseg = so->so_snd.sb_hiwat; in tcp_mtudisc()
2922 SOCKBUF_UNLOCK(&so->so_snd); in tcp_mtudisc()
/f-stack/freebsd/kern/
H A Duipc_socket.c843 so->so_snd.sb_lowat = head->so_snd.sb_lowat;
845 so->so_snd.sb_timeo = head->so_snd.sb_timeo;
847 so->so_snd.sb_flags |= head->so_snd.sb_flags & SB_AUTOSIZE;
1791 sbunlock(&so->so_snd);
3606 sb = &so->so_snd;
3611 sb = &so->so_snd;
4078 sbdrop_locked(&so->so_snd, sbused(&so->so_snd));
4125 sb = &so->so_snd;
4148 sb = &so->so_snd;
4285 sbtoxsockbuf(&so->so_snd, &xso->so_snd);
[all …]
H A Dsys_socket.c189 SOCKBUF_LOCK(&so->so_snd); in soo_ioctl()
191 SOCKBUF_UNLOCK(&so->so_snd); in soo_ioctl()
204 SOCKBUF_LOCK(&so->so_snd); in soo_ioctl()
235 if ((so->so_snd.sb_hiwat < sbused(&so->so_snd)) || in soo_ioctl()
236 (so->so_snd.sb_mbmax < so->so_snd.sb_mbcnt)) { in soo_ioctl()
335 sb = &so->so_snd; in soo_stat()
396 sbused(&so->so_snd); in soo_fill_kinfo()
411 so->so_snd.sb_state; in soo_fill_kinfo()
413 sbused(&so->so_snd); in soo_fill_kinfo()
787 sb = &so->so_snd; in soo_aio_cancel()
[all …]
H A Dkern_sendfile.c783 SOCKBUF_LOCK(&so->so_snd); in vn_sendfile()
784 if (so->so_snd.sb_lowat < so->so_snd.sb_hiwat / 2) in vn_sendfile()
785 so->so_snd.sb_lowat = so->so_snd.sb_hiwat / 2; in vn_sendfile()
789 SOCKBUF_UNLOCK(&so->so_snd); in vn_sendfile()
794 SOCKBUF_UNLOCK(&so->so_snd); in vn_sendfile()
798 SOCKBUF_UNLOCK(&so->so_snd); in vn_sendfile()
803 space = sbspace(&so->so_snd); in vn_sendfile()
818 error = sbwait(&so->so_snd); in vn_sendfile()
830 SOCKBUF_UNLOCK(&so->so_snd); in vn_sendfile()
1210 sbunlock(&so->so_snd); in vn_sendfile()
[all …]
H A Duipc_ktls.c1143 SOCKBUF_LOCK(&so->so_snd); in ktls_enable_tx()
1148 SOCKBUF_UNLOCK(&so->so_snd); in ktls_enable_tx()
1150 sbunlock(&so->so_snd); in ktls_enable_tx()
1189 SOCKBUF_LOCK(&so->so_snd); in ktls_get_tx_mode()
1195 SOCKBUF_UNLOCK(&so->so_snd); in ktls_get_tx_mode()
1221 SOCKBUF_LOCK(&so->so_snd); in ktls_set_tx_mode()
1234 SOCKBUF_UNLOCK(&so->so_snd); in ktls_set_tx_mode()
1266 sbunlock(&so->so_snd); in ktls_set_tx_mode()
1273 SOCKBUF_LOCK(&so->so_snd); in ktls_set_tx_mode()
1277 SOCKBUF_UNLOCK(&so->so_snd); in ktls_set_tx_mode()
[all …]
H A Duipc_sockbuf.c399 SOCKBUF_LOCK_ASSERT(&so->so_snd); in socantsendmore_locked()
410 SOCKBUF_LOCK(&so->so_snd); in socantsendmore()
566 SOCKBUF_LOCK(&so->so_snd); in soreserve()
574 if (so->so_snd.sb_lowat == 0) in soreserve()
575 so->so_snd.sb_lowat = MCLBYTES; in soreserve()
576 if (so->so_snd.sb_lowat > so->so_snd.sb_hiwat) in soreserve()
577 so->so_snd.sb_lowat = so->so_snd.sb_hiwat; in soreserve()
579 SOCKBUF_UNLOCK(&so->so_snd); in soreserve()
582 sbrelease_locked(&so->so_snd, so); in soreserve()
585 SOCKBUF_UNLOCK(&so->so_snd); in soreserve()
[all …]
H A Duipc_usrreq.c525 if (so->so_snd.sb_hiwat == 0 || so->so_rcv.sb_hiwat == 0) { in uipc_attach()
989 SOCKBUF_LOCK(&so2->so_snd); in uipc_rcvd()
990 if (sbcc < so2->so_snd.sb_hiwat && mbcnt < so2->so_snd.sb_mbmax) in uipc_rcvd()
991 so2->so_snd.sb_flags &= ~SB_STOP; in uipc_rcvd()
1090 } else if (so->so_snd.sb_state & SBS_CANTSENDMORE) { in uipc_send()
1152 SOCKBUF_LOCK(&so->so_snd); in uipc_send()
1153 if (sbcc >= so->so_snd.sb_hiwat || mbcnt >= so->so_snd.sb_mbmax) in uipc_send()
1154 so->so_snd.sb_flags |= SB_STOP; in uipc_send()
1155 SOCKBUF_UNLOCK(&so->so_snd); in uipc_send()
1273 sb->st_blksize = so->so_snd.sb_hiwat; in uipc_sense()
H A Duipc_debug.c485 db_print_sockbuf(&so->so_snd, "so_snd", indent); in db_print_socket()
/f-stack/tools/compat/include/sys/
H A Dsocketvar.h127 struct sockbuf so_rcv, so_snd; member
278 ((sbspace(&(so)->so_snd) >= (so)->so_snd.sb_lowat && \
281 ((so)->so_snd.sb_state & SBS_CANTSENDMORE) || \
322 SOCKBUF_LOCK_ASSERT(&(so)->so_snd); \
323 if (sb_notify(&(so)->so_snd)) \
324 sowakeup((so), &(so)->so_snd); \
326 SOCKBUF_UNLOCK(&(so)->so_snd); \
330 SOCKBUF_LOCK(&(so)->so_snd); \
535 } so_rcv, so_snd; member
/f-stack/freebsd/sys/
H A Dsocketvar.h127 struct sockbuf so_rcv, so_snd; member
278 ((sbspace(&(so)->so_snd) >= (so)->so_snd.sb_lowat && \
281 ((so)->so_snd.sb_state & SBS_CANTSENDMORE) || \
322 SOCKBUF_LOCK_ASSERT(&(so)->so_snd); \
323 if (sb_notify(&(so)->so_snd)) \
324 sowakeup((so), &(so)->so_snd); \
326 SOCKBUF_UNLOCK(&(so)->so_snd); \
330 SOCKBUF_LOCK(&(so)->so_snd); \
535 } so_rcv, so_snd; member
/f-stack/tools/netstat/
H A Dinet.c186 sbtoxsockbuf(&so->so_snd, &xso->so_snd); in sotoxsocket()
434 so->so_rcv.sb_cc, so->so_snd.sb_cc); in protopr()
514 so->so_rcv.sb_mcnt, so->so_snd.sb_mcnt, in protopr()
515 so->so_rcv.sb_ccnt, so->so_snd.sb_ccnt, in protopr()
516 so->so_rcv.sb_hiwat, so->so_snd.sb_hiwat, in protopr()
517 so->so_rcv.sb_lowat, so->so_snd.sb_lowat, in protopr()
518 so->so_rcv.sb_mbcnt, so->so_snd.sb_mbcnt, in protopr()
519 so->so_rcv.sb_mbmax, so->so_snd.sb_mbmax); in protopr()
H A Dnetgraph.c125 name, sockb.so_rcv.sb_ccc, sockb.so_snd.sb_ccc); in netgraphprotopr()
H A Dunix.c328 so->so_snd.sb_cc, (long)xunp->unp_vnode, in unixdomainpr()
/f-stack/freebsd/netgraph/
H A Dng_ksocket.c612 SOCKBUF_LOCK(&priv->so->so_snd); in ng_ksocket_connect()
614 SOCKBUF_UNLOCK(&priv->so->so_snd); in ng_ksocket_connect()
942 SOCKBUF_LOCK(&priv->so->so_snd); in ng_ksocket_shutdown()
944 SOCKBUF_UNLOCK(&priv->so->so_snd); in ng_ksocket_shutdown()
1231 SOCKBUF_LOCK(&so->so_snd); in ng_ksocket_accept()
1233 SOCKBUF_UNLOCK(&so->so_snd); in ng_ksocket_accept()
/f-stack/freebsd/netgraph/bluetooth/socket/
H A Dng_btsocket_sco.c902 sbdroprecord(&pcb->so->so_snd); in ng_btsocket_sco_default_msg_input()
905 if (sbavail(&pcb->so->so_snd) > 0) in ng_btsocket_sco_default_msg_input()
1222 if ((so->so_snd.sb_hiwat == 0) || (so->so_rcv.sb_hiwat == 0)) { in ng_btsocket_sco_attach()
1713 sbappendrecord(&pcb->so->so_snd, m); in ng_btsocket_sco_send()
1721 sbdroprecord(&pcb->so->so_snd); /* XXX */ in ng_btsocket_sco_send()
1746 sbavail(&pcb->so->so_snd) > 0) { in ng_btsocket_sco_send2()
1748 m = m_dup(pcb->so->so_snd.sb_mb, M_NOWAIT); in ng_btsocket_sco_send2()
1963 sbdroprecord(&pcb->so->so_snd); in ng_btsocket_sco_process_timeout()
H A Dng_btsocket_rfcomm.c411 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 …]
H A Dng_btsocket_l2cap.c1196 sbdroprecord(&pcb->so->so_snd); in ng_btsocket_l2cap_process_l2ca_write_rsp()
1197 if (sbavail(&pcb->so->so_snd) > 0) { in ng_btsocket_l2cap_process_l2ca_write_rsp()
1201 sbdroprecord(&pcb->so->so_snd); /* XXX */ in ng_btsocket_l2cap_process_l2ca_write_rsp()
2014 if ((so->so_snd.sb_hiwat == 0) || (so->so_rcv.sb_hiwat == 0)) { in ng_btsocket_l2cap_attach()
2618 sbappendrecord(&pcb->so->so_snd, m); in ng_btsocket_l2cap_send()
2626 sbdroprecord(&pcb->so->so_snd); /* XXX */ in ng_btsocket_l2cap_send()
2650 if (sbavail(&pcb->so->so_snd) == 0) in ng_btsocket_l2cap_send2()
2653 m = m_dup(pcb->so->so_snd.sb_mb, M_NOWAIT); in ng_btsocket_l2cap_send2()
2857 sbdroprecord(&pcb->so->so_snd); in ng_btsocket_l2cap_process_timeout()
/f-stack/freebsd/netinet/tcp_stacks/
H A Dbbr.c7880 SOCKBUF_LOCK(&so->so_snd); in bbr_process_ack()
7884 SOCKBUF_UNLOCK(&so->so_snd); in bbr_process_ack()
8772 sbdrop(&so->so_snd, acked); in bbr_fastack()
8825 if (sbavail(&so->so_snd)) { in bbr_fastack()
9375 if (sbavail(&so->so_snd)) { in bbr_do_established()
9471 if (sbavail(&so->so_snd)) { in bbr_do_close_wait()
9623 if (sbavail(&so->so_snd)) { in bbr_do_fin_wait_1()
9736 if (sbavail(&so->so_snd)) { in bbr_do_closing()
9849 if (sbavail(&so->so_snd)) { in bbr_do_lastack()
9965 if (sbavail(&so->so_snd)) { in bbr_do_fin_wait_2()
[all …]
H A Drack.c8336 SOCKBUF_LOCK(&so->so_snd); in rack_process_ack()
8352 SOCKBUF_UNLOCK(&so->so_snd); in rack_process_ack()
9081 sbdrop(&so->so_snd, acked); in rack_fastack()
9151 if (sbavail(&so->so_snd)) { in rack_fastack()
9677 if (sbavail(&so->so_snd)) { in rack_do_established()
9772 if (sbavail(&so->so_snd)) { in rack_do_close_wait()
9923 if (sbavail(&so->so_snd)) { in rack_do_fin_wait_1()
10032 if (sbavail(&so->so_snd)) { in rack_do_closing()
10141 if (sbavail(&so->so_snd)) { in rack_do_lastack()
10247 if (sbavail(&so->so_snd)) { in rack_do_fin_wait_2()
[all …]
H A Drack_bbr_common.c142 tls = so->so_snd.sb_tls_info; in ctf_get_opt_tls_size()
889 &tp->t_inpcb->inp_socket->so_snd, in ctf_log_sack_filter()

12