HomeSort by: relevance | last modified time | path
    Searched refs:so_snd (Results 1 - 25 of 38) sorted by relevancy

1 2

  /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;
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...]
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);
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);
sctputil.c 291 sctp_clog[sctp_cwnd_log_at].x.blk.maxmb = (u_int16_t)(so->so_snd.sb_mbmax/1024);
293 sctp_clog[sctp_cwnd_log_at].x.blk.maxsb = (u_int16_t)(so->so_snd.sb_hiwat/1024);
3361 if (stcb->sctp_socket->so_snd.sb_cc >= tp1->book_size) {
3362 stcb->sctp_socket->so_snd.sb_cc -= tp1->book_size;
3364 stcb->sctp_socket->so_snd.sb_cc = 0;
3367 if (stcb->sctp_socket->so_snd.sb_mbcnt >= tp1->mbcnt) {
3368 stcb->sctp_socket->so_snd.sb_mbcnt -= tp1->mbcnt;
3370 stcb->sctp_socket->so_snd.sb_mbcnt = 0;
  /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 &&
  /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/netstat/
atalk.c 271 sockb.so_snd.sb_cc);
unix.c 134 so->so_snd.sb_cc, (u_long)unp.unp_vnode,
  /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/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);
  /src/sys/netmpls/
mpls_proto.c 89 if (so->so_snd.sb_hiwat == 0 || so->so_rcv.sb_hiwat == 0) {

Completed in 49 milliseconds

1 2