Home
last modified time | relevance | path

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

12

/dragonfly/sys/kern/
HDuipc_socket2.c305 sbdrop(&so->so_snd.sb, so->so_snd.ssb_cc); in soisdisconnected()
393 if (soreserve(so, head->so_snd.ssb_hiwat, in sonewconn_faddr()
414 so->so_snd.ssb_lowat = head->so_snd.ssb_lowat; in sonewconn_faddr()
416 so->so_snd.ssb_timeo = head->so_snd.ssb_timeo; in sonewconn_faddr()
423 if (head->so_snd.ssb_flags & SSB_AUTOLOWAT) in sonewconn_faddr()
424 so->so_snd.ssb_flags |= SSB_AUTOLOWAT; in sonewconn_faddr()
426 so->so_snd.ssb_flags &= ~SSB_AUTOLOWAT; in sonewconn_faddr()
433 if (head->so_snd.ssb_flags & SSB_AUTOSIZE) in sonewconn_faddr()
434 so->so_snd.ssb_flags |= SSB_AUTOSIZE; in sonewconn_faddr()
436 so->so_snd.ssb_flags &= ~SSB_AUTOSIZE; in sonewconn_faddr()
[all …]
HDuipc_socket.c186 TAILQ_INIT(&so->so_snd.ssb_mlist); in soalloc()
188 lwkt_token_init(&so->so_snd.ssb_token, "sndtok"); in soalloc()
315 if (so->so_snd.ssb_hiwat) in sodealloc()
317 &so->so_snd.ssb_hiwat, 0, RLIM_INFINITY); in sodealloc()
441 ssb_release(&so->so_snd, so); in sofree()
808 error = ssb_lock(&so->so_snd, SBLOCKWAIT(flags)); in sosend()
836 if ((atomic && resid > so->so_snd.ssb_hiwat) || in sosend()
837 clen > so->so_snd.ssb_hiwat) { in sosend()
840 space = ssb_space(&so->so_snd); in sosend()
844 (atomic || space < so->so_snd.ssb_lowat || space < clen)) { in sosend()
[all …]
HDuipc_syscalls.c1713 if ((so->so_snd.ssb_flags & (SSB_PREALLOC | SSB_STOPSUPP)) == 0) { in kern_sendfile()
1725 ssb_lock(&so->so_snd, M_WAITOK); in kern_sendfile()
1763 if (so->so_snd.ssb_flags & SSB_PREALLOC) in kern_sendfile()
1764 space = ssb_space_prealloc(&so->so_snd); in kern_sendfile()
1766 space = ssb_space(&so->so_snd); in kern_sendfile()
1895 if (so->so_snd.ssb_flags & SSB_PREALLOC) in kern_sendfile()
1896 space = ssb_space_prealloc(&so->so_snd); in kern_sendfile()
1898 space = ssb_space(&so->so_snd); in kern_sendfile()
1900 if (space < m->m_pkthdr.len && space < so->so_snd.ssb_lowat) { in kern_sendfile()
1907 error = ssb_wait(&so->so_snd); in kern_sendfile()
[all …]
HDsys_socket.c144 atomic_set_int(&so->so_snd.ssb_flags, SSB_ASYNC); in soo_ioctl()
148 atomic_clear_int(&so->so_snd.ssb_flags, SSB_ASYNC); in soo_ioctl()
HDuipc_usrreq.c581 if (so->so_rcv.ssb_cc < so2->so_snd.ssb_hiwat && in uipc_rcvd()
582 so->so_rcv.ssb_mbcnt < so2->so_snd.ssb_mbmax in uipc_rcvd()
584 atomic_clear_int(&so2->so_snd.ssb_flags, SSB_STOP); in uipc_rcvd()
784 if (so2->so_rcv.ssb_cc >= so->so_snd.ssb_hiwat || in uipc_send()
785 so2->so_rcv.ssb_mbcnt >= so->so_snd.ssb_mbmax in uipc_send()
787 atomic_set_int(&so->so_snd.ssb_flags, SSB_STOP); in uipc_send()
845 sb->st_blksize = so->so_snd.ssb_hiwat; in uipc_sense()
1034 if (so->so_snd.ssb_hiwat == 0 || so->so_rcv.ssb_hiwat == 0) { in unp_attach()
1062 atomic_set_int(&so->so_snd.ssb_flags, SSB_STOPSUPP); in unp_attach()
HDuipc_msg.c657 ssb = (msg->notify.nm_etype & NM_REVENT) ? &so->so_rcv : &so->so_snd; in netmsg_so_notify()
748 &nmsg->base.nm_so->so_snd; in netmsg_so_notify_abort()
/dragonfly/sys/netinet/
HDtcp_output.c326 if (off < so->so_snd.ssb_cc) in tcp_output()
351 len = (long)ulmin(so->so_snd.ssb_cc, sendwin) - off; in tcp_output()
446 if (tcp_do_autosndbuf && (so->so_snd.ssb_flags & SSB_AUTOSIZE)) { in tcp_output()
448 const int hiwat = so->so_snd.ssb_hiwat; in tcp_output()
449 const int lowat = so->so_snd.ssb_lowat; in tcp_output()
453 so->so_snd.ssb_cc >= (hiwat / 8 * 7) && in tcp_output()
457 sendwin >= (so->so_snd.ssb_cc - in tcp_output()
460 if (!ssb_reserve(&so->so_snd, newsize, so, NULL)) in tcp_output()
461 atomic_clear_int(&so->so_snd.ssb_flags, SSB_AUTOSIZE); in tcp_output()
464 atomic_clear_int(&so->so_snd.ssb_flags, SSB_AUTOSIZE); in tcp_output()
[all …]
HDtcp_usrreq.c182 if (so->so_snd.ssb_hiwat == 0 || so->so_rcv.ssb_hiwat == 0) { in tcp_usr_preattach()
189 atomic_set_int(&so->so_snd.ssb_flags, SSB_AUTOSIZE | SSB_PREALLOC); in tcp_usr_preattach()
846 if (ssb_space(&so->so_snd) < -512) { in tcp_usr_send()
858 ssb_appendstream(&so->so_snd, m); in tcp_usr_send()
870 tp->snd_up = tp->snd_una + so->so_snd.ssb_cc; in tcp_usr_send()
1103 ssb_appendstream(&so->so_snd, m); in tcp_connect_oncpu()
1106 tp->snd_up = tp->snd_una + so->so_snd.ssb_cc; in tcp_connect_oncpu()
1442 ssb_appendstream(&so->so_snd, m); in tcp6_connect_oncpu()
1445 tp->snd_up = tp->snd_una + so->so_snd.ssb_cc; in tcp6_connect_oncpu()
HDtcp_input.c1292 sbdrop(&so->so_snd.sb, acked); in tcp_input()
1330 if (so->so_snd.ssb_cc > 0 && in tcp_input()
2147 if (acked > so->so_snd.ssb_cc) { in tcp_input()
2148 tp->snd_wnd -= so->so_snd.ssb_cc; in tcp_input()
2149 sbdrop(&so->so_snd.sb, (int)so->so_snd.ssb_cc); in tcp_input()
2152 sbdrop(&so->so_snd.sb, acked); in tcp_input()
3059 bufsize = so->so_snd.ssb_hiwat; in tcp_rmx_mss()
3066 if (bufsize > so->so_snd.ssb_hiwat) in tcp_rmx_mss()
3067 ssb_reserve(&so->so_snd, bufsize, so, NULL); in tcp_rmx_mss()
/dragonfly/sys/sys/
HDsocketvar.h148 struct signalsockbuf so_snd; member
232 } so_rcv, so_snd; member
251 ((ssb_space(&(so)->so_snd) >= (so)->so_snd.ssb_lowat && \
346 #define sowwakeup(so) sowakeup((so), &(so)->so_snd)
/dragonfly/sys/vfs/fifofs/
HDfifo_vnops.c218 wso->so_snd.ssb_lowat = PIPE_BUF; in fifo_fip_create()
486 ssb = &so->so_snd; in fifo_kqfilter()
541 ssb_remove_knote(&so->so_snd, kn); in filt_fifowdetach()
552 kn->kn_data = ssb_space(&so->so_snd); in filt_fifowrite()
560 return (kn->kn_data >= so->so_snd.ssb_lowat); in filt_fifowrite()
/dragonfly/usr.bin/netstat/
HDunix.c126 so->so_snd.sb_cc, in unixdomainpr()
HDnetgraph.c163 name, sockb.so_rcv.ssb_cc, sockb.so_snd.ssb_cc); in netgraphprotopr()
/dragonfly/sys/netproto/smb/
HDsmb_trantcp.c158 so->so_snd.ssb_timeo = (5 * hz); in nb_connect_in()
166 atomic_clear_int(&so->so_snd.ssb_flags, SSB_NOINTR); in nb_connect_in()
174 atomic_set_int(&so->so_snd.ssb_flags, SSB_NOINTR); in nb_connect_in()
/dragonfly/sys/netgraph7/bluetooth/socket/
HDng_btsocket_l2cap.c1122 sbdroprecord(&pcb->so->so_snd.sb); in ng_btsocket_l2cap_process_l2ca_write_rsp()
1123 if (pcb->so->so_snd.sb.sb_cc > 0) { in ng_btsocket_l2cap_process_l2ca_write_rsp()
1127 sbdroprecord(&pcb->so->so_snd.sb); /* XXX */ in ng_btsocket_l2cap_process_l2ca_write_rsp()
1945 if ((so->so_snd.ssb_hiwat == 0) || (so->so_rcv.ssb_hiwat == 0)) { in ng_btsocket_l2cap_attach()
2560 sbappendrecord(&pcb->so->so_snd.sb, m); in ng_btsocket_l2cap_send()
2568 sbdroprecord(&pcb->so->so_snd.sb); /* XXX */ in ng_btsocket_l2cap_send()
2592 if (pcb->so->so_snd.sb.sb_cc == 0) in ng_btsocket_l2cap_send2()
2595 m = m_dup(pcb->so->so_snd.sb.sb_mb, M_NOWAIT); in ng_btsocket_l2cap_send2()
2805 sbdroprecord(&pcb->so->so_snd.sb); in ng_btsocket_l2cap_process_timeout()
HDng_btsocket_rfcomm.c406 if ((so->so_snd.ssb_hiwat == 0) || (so->so_rcv.ssb_hiwat == 0)) { in ng_btsocket_rfcomm_attach()
1050 sbappend(&pcb->so->so_snd.sb, m); in ng_btsocket_rfcomm_send()
1145 atomic_clear_int(&s->l2so->so_snd.ssb_flags, SSB_UPCALL); in ng_btsocket_rfcomm_sessions_task()
1380 atomic_set_int(&l2so->so_snd.ssb_flags, SSB_UPCALL); in ng_btsocket_rfcomm_session_create()
1459 atomic_clear_int(&l2so->so_snd.ssb_flags, SSB_UPCALL); in ng_btsocket_rfcomm_session_create()
3349 length = min(pcb->mtu, pcb->so->so_snd.sb.sb_cc); in ng_btsocket_rfcomm_pcb_send()
3354 m = ng_btsocket_rfcomm_prepare_packet(&pcb->so->so_snd.sb, in ng_btsocket_rfcomm_pcb_send()
3361 sbdrop(&pcb->so->so_snd.sb, length); in ng_btsocket_rfcomm_pcb_send()
/dragonfly/sys/netbt/
HDhci_socket.c437 sbdroprecord(&so->so_snd.sb); in hci_drop()
522 sbappendrecord(&pcb->hp_socket->so_snd.sb, m0); in hci_send()
570 if (so->so_snd.ssb_mb != NULL) in hci_sdetach()
HDsco_socket.c200 sbdroprecord(&so->so_snd.sb); in sco_complete()
411 sbappendrecord(&so->so_snd.sb, m); in sco_ssend()
HDl2cap_socket.c203 sbdroprecord(&so->so_snd.sb); in l2cap_complete()
450 sbappendrecord(&so->so_snd.sb, m); in l2cap_ssend()
HDrfcomm_socket.c204 sbdrop(&so->so_snd.sb, length); in rfcomm_complete()
445 sbappendstream(&so->so_snd.sb, m); in rfcomm_ssend()
/dragonfly/usr.bin/systat/
HDnetbw.c312 elm->xtcp.xt_socket.so_snd.sb_cc || in shownetbw()
363 (elm->xtcp.xt_socket.so_snd.sb_cc > 15000 ? in netbwline()
/dragonfly/sys/netgraph/ksocket/
HDng_ksocket.c608 atomic_set_int(&priv->so->so_snd.ssb_flags, SSB_UPCALL); in ng_ksocket_newhook()
933 atomic_clear_int(&priv->so->so_snd.ssb_flags, SSB_UPCALL); in ng_ksocket_rmnode()
1212 atomic_set_int(&so->so_snd.ssb_flags, SSB_UPCALL); in ng_ksocket_finish_accept()
/dragonfly/sys/netgraph7/ksocket/
HDng_ksocket.c616 atomic_set_int(&priv->so->so_snd.ssb_flags, SSB_UPCALL); in ng_ksocket_connect()
930 atomic_clear_int(&priv->so->so_snd.ssb_flags, SSB_UPCALL); in ng_ksocket_shutdown()
1247 atomic_set_int(&priv->so->so_snd.ssb_flags, SSB_UPCALL); in ng_ksocket_finish_accept()
/dragonfly/sys/vfs/nfs/
HDnfs_syscalls.c399 atomic_clear_int(&so->so_snd.ssb_flags, SSB_NOINTR); in nfssvc_addsock()
400 so->so_snd.ssb_timeo = 0; in nfssvc_addsock()
408 atomic_clear_int(&so->so_snd.ssb_flags, SSB_AUTOSIZE); in nfssvc_addsock()
HDnfs_socket.c288 so->so_snd.ssb_timeo = (5 * hz); in nfs_connect()
332 atomic_set_int(&so->so_snd.ssb_flags, SSB_NOINTR); in nfs_connect()
340 atomic_clear_int(&so->so_snd.ssb_flags, SSB_AUTOSIZE); in nfs_connect()
499 so->so_snd.ssb_hiwat); in nfs_send()
1902 if (ssb_space(&so->so_snd) >= req->r_mreq->m_pkthdr.len && in nfs_timer_req()

12