Home
last modified time | relevance | path

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

123

/freebsd-10-stable/sys/kern/
Dsys_socket.c151 SOCKBUF_LOCK(&so->so_snd); in soo_ioctl()
152 so->so_snd.sb_flags |= SB_ASYNC; in soo_ioctl()
153 SOCKBUF_UNLOCK(&so->so_snd); in soo_ioctl()
161 SOCKBUF_LOCK(&so->so_snd); in soo_ioctl()
162 so->so_snd.sb_flags &= ~SB_ASYNC; in soo_ioctl()
163 SOCKBUF_UNLOCK(&so->so_snd); in soo_ioctl()
174 *(int *)data = so->so_snd.sb_cc; in soo_ioctl()
178 if ((so->so_snd.sb_hiwat < so->so_snd.sb_cc) || in soo_ioctl()
179 (so->so_snd.sb_mbmax < so->so_snd.sb_mbcnt)) in soo_ioctl()
182 *(int *)data = sbspace(&so->so_snd); in soo_ioctl()
[all …]
Duipc_socket.c336 SOCKBUF_LOCK_INIT(&so->so_snd, "so_snd"); in soalloc()
338 sx_init(&so->so_snd.sb_sx, "so_snd_sx"); in soalloc()
378 if (so->so_snd.sb_hiwat) in sodealloc()
380 &so->so_snd.sb_hiwat, 0, RLIM_INFINITY); in sodealloc()
390 sx_destroy(&so->so_snd.sb_sx); in sodealloc()
392 SOCKBUF_LOCK_DESTROY(&so->so_snd); in sodealloc()
451 knlist_init_mtx(&so->so_snd.sb_sel.si_note, SOCKBUF_MTX(&so->so_snd)); in socreate()
540 knlist_init_mtx(&so->so_snd.sb_sel.si_note, SOCKBUF_MTX(&so->so_snd));
542 if (soreserve(so, head->so_snd.sb_hiwat, head->so_rcv.sb_hiwat)) {
555 so->so_snd.sb_lowat = head->so_snd.sb_lowat;
[all …]
Duipc_sockbuf.c84 SOCKBUF_LOCK_ASSERT(&so->so_snd); in socantsendmore_locked()
86 so->so_snd.sb_state |= SBS_CANTSENDMORE; in socantsendmore_locked()
88 mtx_assert(SOCKBUF_MTX(&so->so_snd), MA_NOTOWNED); in socantsendmore_locked()
95 SOCKBUF_LOCK(&so->so_snd); in socantsendmore()
97 mtx_assert(SOCKBUF_MTX(&so->so_snd), MA_NOTOWNED); in socantsendmore()
245 SOCKBUF_LOCK(&so->so_snd); in soreserve()
247 if (sbreserve_locked(&so->so_snd, sndcc, so, td) == 0) in soreserve()
253 if (so->so_snd.sb_lowat == 0) in soreserve()
254 so->so_snd.sb_lowat = MCLBYTES; in soreserve()
255 if (so->so_snd.sb_lowat > so->so_snd.sb_hiwat) in soreserve()
[all …]
Duipc_syscalls.c2270 (void)sblock(&so->so_snd, SBL_WAIT | SBL_NOINTR); in vn_sendfile()
2314 SOCKBUF_LOCK(&so->so_snd); in vn_sendfile()
2315 if (so->so_snd.sb_lowat < so->so_snd.sb_hiwat / 2) in vn_sendfile()
2316 so->so_snd.sb_lowat = so->so_snd.sb_hiwat / 2; in vn_sendfile()
2318 if (so->so_snd.sb_state & SBS_CANTSENDMORE) { in vn_sendfile()
2320 SOCKBUF_UNLOCK(&so->so_snd); in vn_sendfile()
2325 SOCKBUF_UNLOCK(&so->so_snd); in vn_sendfile()
2328 space = sbspace(&so->so_snd); in vn_sendfile()
2331 space < so->so_snd.sb_lowat)) { in vn_sendfile()
2333 SOCKBUF_UNLOCK(&so->so_snd); in vn_sendfile()
[all …]
Duipc_usrreq.c400 if (so->so_snd.sb_hiwat == 0 || so->so_rcv.sb_hiwat == 0) { in uipc_attach()
842 SOCKBUF_LOCK(&so2->so_snd); in uipc_rcvd()
843 if (sbcc < so2->so_snd.sb_hiwat && mbcnt < so2->so_snd.sb_mbmax) in uipc_rcvd()
844 so2->so_snd.sb_flags &= ~SB_STOP; in uipc_rcvd()
945 if (so->so_snd.sb_state & SBS_CANTSENDMORE) { in uipc_send()
1021 SOCKBUF_LOCK(&so->so_snd); in uipc_send()
1022 if (sbcc >= so->so_snd.sb_hiwat || mbcnt >= so->so_snd.sb_mbmax) in uipc_send()
1023 so->so_snd.sb_flags |= SB_STOP; in uipc_send()
1024 SOCKBUF_UNLOCK(&so->so_snd); in uipc_send()
1067 sb->st_blksize = so->so_snd.sb_hiwat; in uipc_sense()
/freebsd-10-stable/sys/ofed/drivers/infiniband/ulp/sdp/
Dsdp_bcopy.c158 if (sk->so_snd.sb_sndptr) in sdp_nagle_timeout()
173 if (sk->so_snd.sb_sndptr) { in sdp_post_sends()
198 sdp_tx_ring_slots_left(ssk) && sk->so_snd.sb_sndptr && in sdp_post_sends()
199 sdp_nagle_off(ssk, sk->so_snd.sb_sndptr)) { in sdp_post_sends()
204 sdp_tx_ring_slots_left(ssk) && (mb = sk->so_snd.sb_sndptr) && in sdp_post_sends()
208 SOCKBUF_LOCK(&sk->so_snd); in sdp_post_sends()
209 sk->so_snd.sb_sndptr = mb->m_nextpkt; in sdp_post_sends()
210 sk->so_snd.sb_mb = mb->m_nextpkt; in sdp_post_sends()
212 SB_EMPTY_FIXUP(&sk->so_snd); in sdp_post_sends()
214 sbfree(&sk->so_snd, n); in sdp_post_sends()
[all …]
Dsdp_main.c453 if (so->so_snd.sb_hiwat == 0 || so->so_rcv.sb_hiwat == 0) { in sdp_attach()
459 so->so_snd.sb_flags |= SB_AUTOSIZE; in sdp_attach()
966 SOCKBUF_LOCK(&so->so_snd); in sdp_send()
967 sdp_append(ssk, &so->so_snd, m, cnt); in sdp_send()
968 SOCKBUF_UNLOCK(&so->so_snd); in sdp_send()
992 SOCKBUF_LOCK(&so->so_snd); in sdp_send()
993 if (sbspace(&so->so_snd) < -512) { in sdp_send()
994 SOCKBUF_UNLOCK(&so->so_snd); in sdp_send()
1008 sdp_append(ssk, &so->so_snd, m, cnt); in sdp_send()
1009 SOCKBUF_UNLOCK(&so->so_snd); in sdp_send()
[all …]
/freebsd-10-stable/sys/netinet/
Dtcp_output.c325 SOCKBUF_LOCK(&so->so_snd); in tcp_output()
350 if (off < so->so_snd.sb_cc) in tcp_output()
376 len = ((long)ulmin(so->so_snd.sb_cc, sendwin) - off); in tcp_output()
385 len = ((long)ulmin(so->so_snd.sb_cc, tp->snd_wnd) in tcp_output()
466 (off < (int) so->so_snd.sb_cc)) { in tcp_output()
513 if (V_tcp_do_autosndbuf && so->so_snd.sb_flags & SB_AUTOSIZE) { in tcp_output()
514 if ((tp->snd_wnd / 4 * 5) >= so->so_snd.sb_hiwat && in tcp_output()
515 so->so_snd.sb_cc >= (so->so_snd.sb_hiwat / 8 * 7) && in tcp_output()
516 so->so_snd.sb_cc < V_tcp_autosndbuf_max && in tcp_output()
517 sendwin >= (so->so_snd.sb_cc - (tp->snd_nxt - tp->snd_una))) { in tcp_output()
[all …]
Dsctputil.h292 if (stcb->sctp_socket->so_snd.sb_cc >= tp1->book_size) { \
293 atomic_subtract_int(&((stcb)->sctp_socket->so_snd.sb_cc), tp1->book_size); \
295 stcb->sctp_socket->so_snd.sb_cc = 0; \
313 if (stcb->sctp_socket->so_snd.sb_cc >= sp->length) { \
314 atomic_subtract_int(&stcb->sctp_socket->so_snd.sb_cc,sp->length); \
316 stcb->sctp_socket->so_snd.sb_cc = 0; \
328 atomic_add_int(&stcb->sctp_socket->so_snd.sb_cc,sz); \
Dtcp_input.c1793 sbdrop(&so->so_snd, acked); in tcp_do_segment()
1837 if (so->so_snd.sb_cc) in tcp_do_segment()
2690 SOCKBUF_LOCK(&so->so_snd); in tcp_do_segment()
2691 avail = so->so_snd.sb_cc - in tcp_do_segment()
2693 SOCKBUF_UNLOCK(&so->so_snd); in tcp_do_segment()
2838 SOCKBUF_LOCK(&so->so_snd); in tcp_do_segment()
2839 if (acked > so->so_snd.sb_cc) { in tcp_do_segment()
2840 if (tp->snd_wnd >= so->so_snd.sb_cc) in tcp_do_segment()
2841 tp->snd_wnd -= so->so_snd.sb_cc; in tcp_do_segment()
2844 mfree = sbcut_locked(&so->so_snd, in tcp_do_segment()
[all …]
Dtcp_usrreq.c920 sbappendstream(&so->so_snd, m); in tcp_usr_send()
963 SOCKBUF_LOCK(&so->so_snd); in tcp_usr_send()
964 if (sbspace(&so->so_snd) < -512) { in tcp_usr_send()
965 SOCKBUF_UNLOCK(&so->so_snd); in tcp_usr_send()
978 sbappendstream_locked(&so->so_snd, m); in tcp_usr_send()
979 SOCKBUF_UNLOCK(&so->so_snd); in tcp_usr_send()
1002 tp->snd_up = tp->snd_una + so->so_snd.sb_cc; in tcp_usr_send()
1744 if (so->so_snd.sb_hiwat == 0 || so->so_rcv.sb_hiwat == 0) { in tcp_attach()
1750 so->so_snd.sb_flags |= SB_AUTOSIZE; in tcp_attach()
/freebsd-10-stable/sys/sys/
Dsocketvar.h108 struct sockbuf so_rcv, so_snd; member
180 struct xsockbuf so_rcv, so_snd; member
216 ((sbspace(&(so)->so_snd) >= (so)->so_snd.sb_lowat && \
219 ((so)->so_snd.sb_state & SBS_CANTSENDMORE) || \
267 SOCKBUF_LOCK_ASSERT(&(so)->so_snd); \
268 if (sb_notify(&(so)->so_snd)) \
269 sowakeup((so), &(so)->so_snd); \
271 SOCKBUF_UNLOCK(&(so)->so_snd); \
275 SOCKBUF_LOCK(&(so)->so_snd); \
/freebsd-10-stable/sys/dev/iscsi/
Dicl.c860 SOCKBUF_LOCK(&so->so_snd); in icl_conn_send_pdus()
867 available = sbspace(&so->so_snd); in icl_conn_send_pdus()
873 so->so_snd.sb_lowat = so->so_snd.sb_hiwat + 1; in icl_conn_send_pdus()
874 SOCKBUF_UNLOCK(&so->so_snd); in icl_conn_send_pdus()
887 SOCKBUF_LOCK(&so->so_snd); in icl_conn_send_pdus()
888 available = sbspace(&so->so_snd); in icl_conn_send_pdus()
895 so->so_snd.sb_lowat = size; in icl_conn_send_pdus()
896 SOCKBUF_UNLOCK(&so->so_snd); in icl_conn_send_pdus()
899 SOCKBUF_UNLOCK(&so->so_snd); in icl_conn_send_pdus()
1201 ic->ic_socket->so_snd.sb_flags |= SB_AUTOSIZE; in icl_conn_start()
[all …]
/freebsd-10-stable/sys/cam/ctl/
Dctl_ha.c239 SOCKBUF_LOCK(&so->so_snd); in ctl_ha_close()
241 SOCKBUF_UNLOCK(&so->so_snd); in ctl_ha_close()
341 so->so_snd.sb_lowat = so->so_snd.sb_hiwat + 1; in ctl_ha_send()
345 SOCKBUF_LOCK(&so->so_snd); in ctl_ha_send()
346 if (sbspace(&so->so_snd) < softc->ha_sending->m_pkthdr.len) { in ctl_ha_send()
347 so->so_snd.sb_lowat = softc->ha_sending->m_pkthdr.len; in ctl_ha_send()
348 SOCKBUF_UNLOCK(&so->so_snd); in ctl_ha_send()
351 SOCKBUF_UNLOCK(&so->so_snd); in ctl_ha_send()
378 SOCKBUF_LOCK(&so->so_snd); in ctl_ha_sock_setup()
379 so->so_snd.sb_lowat = sizeof(struct ha_msg_wire); in ctl_ha_sock_setup()
[all …]
/freebsd-10-stable/usr.bin/bluetooth/btsockstat/
Dbtsockstat.c259 so.so_snd.sb_cc, in hcirawpr()
307 so.so_snd.sb_cc, in l2caprawpr()
365 so.so_snd.sb_cc, in l2cappr()
471 so.so_snd.sb_cc, in rfcommpr()
/freebsd-10-stable/usr.bin/netstat/
Dinet.c177 sbtoxsockbuf(&so->so_snd, &xso->so_snd); in sotoxsocket()
482 printf("%6u %6u ", so->so_rcv.sb_cc, so->so_snd.sb_cc); in protopr()
540 so->so_rcv.sb_mcnt, so->so_snd.sb_mcnt, in protopr()
541 so->so_rcv.sb_ccnt, so->so_snd.sb_ccnt, in protopr()
542 so->so_rcv.sb_hiwat, so->so_snd.sb_hiwat, in protopr()
543 so->so_rcv.sb_lowat, so->so_snd.sb_lowat, in protopr()
544 so->so_rcv.sb_mbcnt, so->so_snd.sb_mbcnt, in protopr()
545 so->so_rcv.sb_mbmax, so->so_snd.sb_mbmax); in protopr()
Dnetgraph.c122 name, sockb.so_rcv.sb_cc, sockb.so_snd.sb_cc); in netgraphprotopr()
/freebsd-10-stable/sys/netipx/
Dspx_reass.c252 SOCKBUF_LOCK(&so->so_snd); in spx_reass()
253 while ((m = so->so_snd.sb_mb) != NULL) { in spx_reass()
255 sbdroprecord_locked(&so->so_snd); in spx_reass()
Dspx_usrreq.c440 struct sockbuf *sb = &so->so_snd; in spx_output()
671 if (so->so_snd.sb_cc && cb->s_timer[SPXT_REXMT] == 0 && in spx_output()
1085 if (so->so_snd.sb_hiwat == 0 || so->so_rcv.sb_hiwat == 0) { in spx_attach()
1117 sb = &so->so_snd; in spx_attach()
1423 if (sbspace(&so->so_snd) < -512) { in spx_send()
1513 struct sockbuf *sb = &(ipxp->ipxp_socket->so_snd); in spx_template()
/freebsd-10-stable/sys/netgraph/
Dng_ksocket.c623 SOCKBUF_LOCK(&priv->so->so_snd); in ng_ksocket_connect()
625 SOCKBUF_UNLOCK(&priv->so->so_snd); in ng_ksocket_connect()
957 SOCKBUF_LOCK(&priv->so->so_snd); in ng_ksocket_shutdown()
959 SOCKBUF_UNLOCK(&priv->so->so_snd); in ng_ksocket_shutdown()
1286 SOCKBUF_LOCK(&so->so_snd); in ng_ksocket_finish_accept()
1288 SOCKBUF_UNLOCK(&so->so_snd); in ng_ksocket_finish_accept()
/freebsd-10-stable/sys/netsmb/
Dsmb_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-10-stable/sys/netgraph/bluetooth/socket/
Dng_btsocket_sco.c906 sbdroprecord(&pcb->so->so_snd); in ng_btsocket_sco_default_msg_input()
909 if (pcb->so->so_snd.sb_cc > 0) in ng_btsocket_sco_default_msg_input()
1226 if ((so->so_snd.sb_hiwat == 0) || (so->so_rcv.sb_hiwat == 0)) { in ng_btsocket_sco_attach()
1718 sbappendrecord(&pcb->so->so_snd, m); in ng_btsocket_sco_send()
1726 sbdroprecord(&pcb->so->so_snd); /* XXX */ in ng_btsocket_sco_send()
1751 pcb->so->so_snd.sb_cc > 0) { in ng_btsocket_sco_send2()
1753 m = m_dup(pcb->so->so_snd.sb_mb, M_NOWAIT); in ng_btsocket_sco_send2()
1968 sbdroprecord(&pcb->so->so_snd); in ng_btsocket_sco_process_timeout()
Dng_btsocket_l2cap.c1131 sbdroprecord(&pcb->so->so_snd); in ng_btsocket_l2cap_process_l2ca_write_rsp()
1132 if (pcb->so->so_snd.sb_cc > 0) { in ng_btsocket_l2cap_process_l2ca_write_rsp()
1136 sbdroprecord(&pcb->so->so_snd); /* XXX */ in ng_btsocket_l2cap_process_l2ca_write_rsp()
1935 if ((so->so_snd.sb_hiwat == 0) || (so->so_rcv.sb_hiwat == 0)) { in ng_btsocket_l2cap_attach()
2485 sbappendrecord(&pcb->so->so_snd, m); in ng_btsocket_l2cap_send()
2493 sbdroprecord(&pcb->so->so_snd); /* XXX */ in ng_btsocket_l2cap_send()
2517 if (pcb->so->so_snd.sb_cc == 0) in ng_btsocket_l2cap_send2()
2520 m = m_dup(pcb->so->so_snd.sb_mb, M_NOWAIT); in ng_btsocket_l2cap_send2()
2719 sbdroprecord(&pcb->so->so_snd); in ng_btsocket_l2cap_process_timeout()
Dng_btsocket_rfcomm.c408 if ((so->so_snd.sb_hiwat == 0) || (so->so_rcv.sb_hiwat == 0)) { in ng_btsocket_rfcomm_attach()
975 sbappend(&pcb->so->so_snd, m); in ng_btsocket_rfcomm_send()
1062 SOCKBUF_LOCK(&s->l2so->so_snd); in ng_btsocket_rfcomm_sessions_task()
1064 SOCKBUF_UNLOCK(&s->l2so->so_snd); in ng_btsocket_rfcomm_sessions_task()
1302 SOCKBUF_LOCK(&l2so->so_snd); in ng_btsocket_rfcomm_session_create()
1304 SOCKBUF_UNLOCK(&l2so->so_snd); in ng_btsocket_rfcomm_session_create()
1384 SOCKBUF_LOCK(&l2so->so_snd); in ng_btsocket_rfcomm_session_create()
1386 SOCKBUF_UNLOCK(&l2so->so_snd); in ng_btsocket_rfcomm_session_create()
3282 length = min(pcb->mtu, pcb->so->so_snd.sb_cc); in ng_btsocket_rfcomm_pcb_send()
3287 m = ng_btsocket_rfcomm_prepare_packet(&pcb->so->so_snd, length); in ng_btsocket_rfcomm_pcb_send()
[all …]
/freebsd-10-stable/sys/rpc/
Dclnt_bck.c308 SOCKBUF_LOCK(&xprt->xp_socket->so_snd); in clnt_bck_call()
309 sbwait(&xprt->xp_socket->so_snd); in clnt_bck_call()
310 SOCKBUF_UNLOCK(&xprt->xp_socket->so_snd); in clnt_bck_call()

123