| /src/sys/kern/ |
| sys_socket.c | 152 so->so_snd.sb_flags |= SB_ASYNC;
155 so->so_snd.sb_flags &= ~SB_ASYNC;
165 *(int *)data = so->so_snd.sb_cc;
176 if ((so->so_snd.sb_hiwat < so->so_snd.sb_cc)
177 || (so->so_snd.sb_mbmax < so->so_snd.sb_mbcnt))
180 *(int *)data = sbspace(&so->so_snd);
|
| uipc_socket2.c | 344 so->so_snd.sb_mowner = head->so_snd.sb_mowner;
346 if (soreserve(so, head->so_snd.sb_hiwat, head->so_rcv.sb_hiwat)) {
349 so->so_snd.sb_lowat = head->so_snd.sb_lowat;
352 so->so_snd.sb_timeo = head->so_snd.sb_timeo;
354 so->so_snd.sb_flags |= head->so_snd.sb_flags & (SB_AUTOSIZE | SB_ASYNC);
399 cv_init(&so->so_snd.sb_cv, "netio")
[all...] |
| uipc_socket.c | 533 so->so_snd.sb_mowner = &prp->pr_domain->dom_mowner;
708 if (so->so_snd.sb_hiwat)
709 (void)chgsbsize(so->so_uidinfo, &so->so_snd.sb_hiwat, 0,
711 sbrelease(&so->so_snd, so);
714 KASSERT(!cv_has_waiters(&so->so_snd.sb_cv));
944 if ((error = sblock(&so->so_snd, SBLOCKWAIT(flags))) != 0)
968 space = sbspace(&so->so_snd);
971 if ((atomic && resid > so->so_snd.sb_hiwat) ||
972 clen > so->so_snd.sb_hiwat) {
977 (atomic || space < so->so_snd.sb_lowat || space < clen))
[all...] |
| uipc_usrreq.c | 424 #define snd (&so2->so_snd)
527 #define snd (&so->so_snd)
751 if (so->so_snd.sb_hiwat == 0 || so->so_rcv.sb_hiwat == 0) {
894 ub->st_blksize = so->so_snd.sb_hiwat;
|
| /src/sys/netinet/ |
| tcp_output.c | 368 *txsegsizep = uimin(so->so_snd.sb_hiwat >> 1, *txsegsizep);
457 tp->t_lastm = so->so_snd.sb_mb;
727 if (off + len > so->so_snd.sb_cc) {
729 KASSERT(off + len == so->so_snd.sb_cc + 1);
731 len = so->so_snd.sb_cc - off;
763 if (off < so->so_snd.sb_cc)
781 if (tp->snd_wnd < so->so_snd.sb_cc) {
785 len = so->so_snd.sb_cc - off;
808 } else if (win < so->so_snd.sb_cc) {
812 len = so->so_snd.sb_cc - off
[all...] |
| tcp_usrreq.c | 465 so->so_snd.sb_mowner = &tcp_sock_tx_mowner;
467 if (so->so_snd.sb_hiwat == 0 || so->so_rcv.sb_hiwat == 0) {
474 so->so_snd.sb_flags |= SB_AUTOSIZE;
1028 sbappendstream(&so->so_snd, m);
1066 if (sbspace_oob(&so->so_snd) == 0) {
1080 sbappendstream(&so->so_snd, m);
1081 tp->snd_up = tp->snd_una + so->so_snd.sb_cc;
1699 pcb.ki_sndq = inp->inp_socket->so_snd.sb_cc;
1739 pcb.ki_sndq = inp->inp_socket->so_snd.sb_cc;
|
| tcp_input.c | 1862 sbdrop(&so->so_snd, acked);
1903 if (so->so_snd.sb_cc) {
2569 if (acked > so->so_snd.sb_cc) {
2570 tp->snd_wnd -= so->so_snd.sb_cc;
2571 sbdrop(&so->so_snd, (int)so->so_snd.sb_cc);
2576 sbdrop(&so->so_snd, acked);
|
| sctp_output.c | 4228 error = sblock(&so->so_snd, SBLOCKWAIT(flags));
4232 if (dataout > so->so_snd.sb_hiwat) {
4243 if ((so->so_snd.sb_hiwat <
4247 so->so_snd.sb_mbmax)
4253 while ((so->so_snd.sb_hiwat <
4257 so->so_snd.sb_mbmax)) {
4284 sbunlock(&so->so_snd);
4285 error = sbwait(&so->so_snd);
4303 error = sblock(&so->so_snd, M_WAITOK);
4566 so->so_snd.sb_cc += dataout
[all...] |
| dccp_usrreq.c | 1152 if (so->so_snd.sb_cc){
1321 m_copydata(so->so_snd.sb_mb, off, (int) len,
1325 m->m_next = m_copym(so->so_snd.sb_mb, off,
1523 sbdrop(&inp->inp_socket->so_snd, len);
1950 if (sbspace_oob(&so->so_snd) == 0) {
1969 sbappend(&so->so_snd, m);
|
| /src/sys/compat/common/ |
| kern_uipc_socket_50.c | 134 so->so_snd.sb_timeo : so->so_rcv.sb_timeo);
187 so->so_snd.sb_timeo = optval;
|
| /src/sys/miscfs/fifofs/ |
| fifo_vnops.c | 171 if (wso->so_snd.sb_lowat < PIPE_BUF) {
172 wso->so_snd.sb_hiwat = PIPE_BUF * 2;
174 wso->so_snd.sb_lowat = PIPE_BUF;
412 selrecord(curlwp, &wso->so_snd.sb_sel);
413 wso->so_snd.sb_flags |= SB_NOTIFY;
629 if (selremove_knote(&so->so_snd.sb_sel, kn))
630 so->so_snd.sb_flags &= ~SB_KNOTE;
643 kn->kn_data = sbspace(&so->so_snd);
649 rv = (kn->kn_data >= so->so_snd.sb_lowat);
690 sb = &so->so_snd;
[all...] |
| /src/sys/sys/ |
| socketvar.h | 168 struct sockbuf so_snd; /* send buffer */ member in struct:socket
401 * How much space is there in a socket buffer (so->so_snd or so->so_rcv)?
467 return (sbspace(&so->so_snd) >= so->so_snd.sb_lowat &&
516 if (sb_notify(&so->so_snd))
517 sowakeup(so, &so->so_snd, POLL_OUT);
|
| /src/sys/dev/ |
| kttcp.c | 227 if ((error = sblock(&so->so_snd, SBLOCKWAIT(flags))) != 0)
244 space = sbspace(&so->so_snd);
247 if ((atomic && resid > so->so_snd.sb_hiwat))
249 if (space < resid && (atomic || space < so->so_snd.sb_lowat)) {
256 sbunlock(&so->so_snd);
257 error = sbwait(&so->so_snd);
341 sbunlock(&so->so_snd);
|
| /src/sys/netbt/ |
| sco_socket.c | 318 sbappendrecord(&so->so_snd, m);
433 sbdroprecord(&so->so_snd);
|
| hci_socket.c | 323 sbdroprecord(&so->so_snd);
399 if (so->so_snd.sb_mb != NULL)
666 sbappendrecord(&pcb->hp_socket->so_snd, m0);
|
| l2cap_socket.c | 325 sbappendrecord(&so->so_snd, m);
446 sbdroprecord(&so->so_snd);
|
| rfcomm_socket.c | 332 sbappendstream(&so->so_snd, m);
455 sbdrop(&so->so_snd, length);
|
| /src/sys/nfs/ |
| nfs_socket.c | 201 so->so_snd.sb_mowner = &nfs_mowner;
278 so->so_snd.sb_timeo = (5 * hz);
285 so->so_snd.sb_timeo = 0;
321 so->so_snd.sb_flags |= SB_NOINTR;
821 if (sbspace(&so->so_snd) >= rep->r_mreq->m_pkthdr.len &&
|
| nfs_syscalls.c | 560 so->so_snd.sb_flags &= ~SB_NOINTR;
561 so->so_snd.sb_timeo = 0;
|
| /src/usr.bin/netstat/ |
| atalk.c | 271 sockb.so_snd.sb_cc);
|
| unix.c | 134 so->so_snd.sb_cc, (u_long)unp.unp_vnode,
|
| /src/sys/netcan/ |
| can.c | 440 so->so_snd.sb_mowner = &can_tx_mowner;
442 if (so->so_snd.sb_hiwat == 0 || so->so_rcv.sb_hiwat == 0) {
724 so->so_snd.sb_mowner = &can_tx_mowner;
726 if (so->so_snd.sb_hiwat == 0 || so->so_rcv.sb_hiwat == 0) {
|
| /src/usr.bin/systat/ |
| netstat.c | 345 p->ni_sndcc = so->so_snd.sb_cc;
394 p->ni_sndcc = so->so_snd.sb_cc;
|
| /src/sys/netmpls/ |
| mpls_proto.c | 89 if (so->so_snd.sb_hiwat == 0 || so->so_rcv.sb_hiwat == 0) {
|
| /src/sys/net/ |
| if_gre.c | 512 if ((error = sblock(&so->so_snd, M_NOWAIT)) != 0)
528 space = sbspace(&so->so_snd);
529 if (resid > so->so_snd.sb_hiwat)
542 sbunlock(&so->so_snd);
|
