Home
last modified time | relevance | path

Searched refs:sb_cc (Results 1 – 25 of 27) sorted by relevance

12

/xnu-11417.140.69/bsd/kern/
H A Dsys_socket.c227 bcopy(&so->so_rcv.sb_cc, data, sizeof(u_int32_t)); in soioctl()
375 so->so_rcv.sb_cc != 0) { in soo_stat()
381 sb64->st_size = so->so_rcv.sb_cc - so->so_rcv.sb_ctl; in soo_stat()
387 so->so_rcv.sb_cc != 0) { in soo_stat()
393 sb->st_size = so->so_rcv.sb_cc - so->so_rcv.sb_ctl; in soo_stat()
H A Duipc_socket2.c581 error = msleep((caddr_t)&sb->sb_cc, mutex_held, in sbwait()
613 wakeup((caddr_t)&sb->sb_cc); in sbwakeup()
1073 if (len != sb->sb_cc || mbcnt != sb->sb_mbcnt) { in sbcheck()
1074 panic("cc %ld != %ld || mbcnt %ld != %ld", len, sb->sb_cc, in sbcheck()
1725 sb->sb_cc += m->m_len; in sbcompress()
1768 if (!(sb->sb_cc == 0 && sb->sb_mb == NULL && sb->sb_mbcnt == 0 && in sb_empty_assert()
1771 "lastrecord %p\n", where, sb, sb->sb_so, sb->sb_cc, in sb_empty_assert()
1815 if (!sb->sb_cc && (sb->sb_mb == NULL || sb->sb_mb->m_len)) { in sbflush()
1818 sbdrop(sb, (int)sb->sb_cc); in sbflush()
1887 sb->sb_cc = 0; in sbdrop()
[all …]
H A Duipc_socket.c2217 so->so_snd.sb_cc, so->so_snd.sb_lowat, so->so_snd.sb_hiwat); in sosend()
2659 so->so_snd.sb_cc, space, error); in sosend()
2757 so->so_snd.sb_cc, so->so_snd.sb_lowat, so->so_snd.sb_hiwat); in sosend_list()
2956 so->so_snd.sb_cc, 0, error); in sosend_list()
3065 if (m->m_next == NULL && so->so_rcv.sb_cc != 0) { in soreceive_addr()
3269 if ((flags & MSG_DONTWAIT) == 0 && so->so_rcv.sb_cc < uio_resid(uio) && in so_should_wait()
3275 if (so->so_rcv.sb_cc < so->so_rcv.sb_lowat) { in so_should_wait()
3356 uio_resid(uio), so->so_rcv.sb_cc, so->so_rcv.sb_lowat, in soreceive()
3888 so->so_rcv.sb_cc -= len; in soreceive()
4008 if ((so->so_options & SO_WANTMORE) && so->so_rcv.sb_cc > 0) { in soreceive()
[all …]
H A Dkern_control.c755 trim = sb->sb_hiwat - sb->sb_cc; in ctl_sbrcv_trim()
1023 so->so_rcv.sb_hiwat, so->so_rcv.sb_cc); in ctl_enqueuembuf()
1136 so->so_rcv.sb_hiwat, so->so_rcv.sb_cc); in ctl_enqueuembuf_list()
1237 so->so_rcv.sb_hiwat, so->so_rcv.sb_cc); in ctl_enqueuedata()
1315 if (so->so_rcv.sb_cc >= so->so_rcv.sb_lowat) { in ctl_getenqueuereadable()
1318 *difference = (so->so_rcv.sb_lowat - so->so_rcv.sb_cc); in ctl_getenqueuereadable()
H A Dsocket_info.c60 sbi->sbi_cc = sb->sb_cc; in fill_sockbuf_info()
H A Duipc_usrreq.c467 snd->sb_hiwat += unp->unp_cc - rcv->sb_cc; in uipc_rcvd()
468 unp->unp_cc = rcv->sb_cc; in uipc_rcvd()
669 (int32_t)(rcv->sb_cc - unp->unp_conn->unp_cc)) { in uipc_send()
670 snd->sb_hiwat -= rcv->sb_cc - unp->unp_conn->unp_cc; in uipc_send()
674 unp->unp_conn->unp_cc = rcv->sb_cc; in uipc_send()
739 blksize += so2->so_rcv.sb_cc; in uipc_sense()
/xnu-11417.140.69/bsd/netinet/
H A Dtcp_output.c372 if (so->so_snd.sb_cc > (tp->t_maxopd - MAX_TCPOPTLEN)) { in tcp_tfo_check()
1127 if (off < so->so_snd.sb_cc) { in tcp_output()
1156 len = min(so->so_snd.sb_cc, sendwin) - off; in tcp_output()
1167 len = min(so->so_snd.sb_cc, tp->snd_wnd) - off; in tcp_output()
1341 so->so_snd.sb_cc >= (so->so_snd.sb_hiwat / 8 * 7) && in tcp_output()
1342 sendwin >= (so->so_snd.sb_cc - (tp->snd_nxt - tp->snd_una))) { in tcp_output()
1461 if (SEQ_LT(seg->start_seq + len, tp->snd_una + so->so_snd.sb_cc)) { in tcp_output()
1465 if (SEQ_LT(p->rxmit + len, tp->snd_una + so->so_snd.sb_cc)) { in tcp_output()
1470 if (SEQ_LT(tp->snd_nxt + len, tp->snd_una + so->so_snd.sb_cc)) { in tcp_output()
1627 (len + off >= so->so_snd.sb_cc || in tcp_output()
[all …]
H A Dtcp_cc.c198 tp->t_inpcb->inp_socket->so_rcv.sb_cc > tp->t_inpcb->inp_socket->so_rcv.sb_lowat && in tcp_cc_delay_ack()
275 (so != NULL && so->so_snd.sb_cc > tp->snd_cwnd)) { in tcp_cc_is_cwnd_nonvalidated()
H A Dmptcp_subr.c660 if (mptetoso(mpte)->so_snd.sb_cc != 0 && tp->t_rxtshift >= mptcp_fail_thresh * 2) { in mptcp_handover_use_cellular()
673 if (mptetoso(mpte)->so_snd.sb_cc != 0) { in mptcp_handover_use_cellular()
779 mptetoso(mpte)->so_snd.sb_cc, in mptcp_check_subflows_and_add()
982 …nsigned long)VM_KERNEL_ADDRPERM(mpte), tp->t_rxtshift, mptetoso(mpte)->so_snd.sb_cc, wifi_quality); in mptcp_pure_handover_subflows_remove()
1035 …nsigned long)VM_KERNEL_ADDRPERM(mpte), tp->t_rxtshift, mptetoso(mpte)->so_snd.sb_cc, wifi_quality); in mptcp_handover_subflows_remove()
1966 so->so_rcv.sb_cc -= new->m_len; in mptcp_adj_rmap()
2267 if (SEQ_GT(sseq + tp->irs, tp->rcv_nxt - so->so_rcv.sb_cc)) { in mptcp_subflow_soreceive()
2269 int totrim = (int)sseq + tp->irs - (tp->rcv_nxt - so->so_rcv.sb_cc); in mptcp_subflow_soreceive()
2279 if ((int)so->so_rcv.sb_cc < dlen) { in mptcp_subflow_soreceive()
3033 int sb_cc = 0, error = 0, wakeup = 0; in mptcp_subflow_output() local
[all …]
H A Dmp_pcb.c276 if (mp_so->so_rcv.sb_cc > 0 || mp_so->so_snd.sb_cc > 0) { in mptcp_pcbdispose()
H A Dmptcp.c421 count = mp_so->so_rcv.sb_cc; in mptcp_input()
473 count = mp_so->so_rcv.sb_cc - count; in mptcp_input()
608 count = mp_so->so_rcv.sb_cc - count; in mptcp_input()
621 count = mp_so->so_rcv.sb_cc; in mptcp_input()
725 mp_so->so_snd.sb_cc >= (mp_so->so_snd.sb_hiwat / 8 * 7)) { in mptcp_output()
844 (mptetoso(mpte)->so_snd.sb_cc || mpte->mpte_reinjectq); in mptcp_subflow_is_slow()
H A Din_pcblist.c172 xsb->sb_cc = sb->sb_cc; in sbtoxsockbuf_n()
679 (activeonly && so->so_snd.sb_cc == 0)) { in inpcb_get_if_ports_used()
968 u_int32_t new_size = MAX(MIN(limit, so->so_snd.sb_lowat), so->so_snd.sb_cc); in inp_limit_companion_link()
H A Dtcp_ccdbg.c119 dbg_state.ccd_sndcc = inp->inp_socket->so_snd.sb_cc; in tcp_ccdbg_trace()
H A Dtcp_input.c1170 trim = sbrcv->sb_hiwat - (sbrcv->sb_cc + leave); in tcp_sbrcv_trim()
1193 if (sbsnd->sb_cc <= sbsnd->sb_idealsize) { in tcp_sbsnd_trim()
1196 trim = sbsnd->sb_hiwat - sbsnd->sb_cc; in tcp_sbsnd_trim()
1526 snd_len = min(so->so_snd.sb_cc, tp->snd_wnd) - snd_off; in tcp_early_rexmt_check()
3358 if ((so->so_snd.sb_cc) || (tp->t_flags & TF_ACKNOW)) { in tcp_input()
4831 if (so->so_snd.sb_cc) { in tcp_input()
5264 (so->so_snd.sb_cc - (tp->snd_max - tp->snd_una)) > 0) { in tcp_input()
5511 if (acked > so->so_snd.sb_cc) { in tcp_input()
5512 tp->snd_wnd -= so->so_snd.sb_cc; in tcp_input()
5513 sbdrop(&so->so_snd, (int)so->so_snd.sb_cc); in tcp_input()
[all …]
H A Dflow_divert.c1566 if (fd_cb->so->so_snd.sb_cc == 0) { in flow_divert_send_close_if_needed()
1744 to_send = fd_cb->so->so_snd.sb_cc; in flow_divert_send_buffered_data()
1858 if (fd_cb->so->so_snd.sb_cc > 0) { in flow_divert_send_app_data()
1912 fd_cb->so->so_snd.sb_cc, fd_cb->send_window); in flow_divert_send_app_data()
1924 fd_cb->so->so_snd.sb_cc, fd_cb->send_window); in flow_divert_send_app_data()
1960 fd_cb->so->so_snd.sb_cc, fd_cb->send_window, append_error); in flow_divert_send_app_data()
1966 fd_cb->so->so_snd.sb_cc, fd_cb->send_window); in flow_divert_send_app_data()
2295 size_t data_len = so->so_snd.sb_cc; in flow_divert_disable()
3248 state.send_buffer_bytes = so->so_snd.sb_cc; in flow_divert_handle_flow_states_request()
H A Dmptcp_opt.c1192 if (acked > mp_so->so_snd.sb_cc) { in mptcp_data_ack_rcvd()
1193 if (acked > mp_so->so_snd.sb_cc + 1 || in mptcp_data_ack_rcvd()
1197 (uint32_t)acked, mp_so->so_snd.sb_cc, in mptcp_data_ack_rcvd()
1202 sbdrop(&mp_so->so_snd, (int)mp_so->so_snd.sb_cc); in mptcp_data_ack_rcvd()
H A Dtcp_usrreq.c1200 mpkl_seq = tp->snd_una + so->so_snd.sb_cc; in tcp_usr_send()
1303 tp->snd_up = tp->snd_una + so->so_snd.sb_cc; in tcp_usr_send()
1800 ti->tcpi_snd_sbbytes = inp->inp_socket->so_snd.sb_cc; in tcp_fill_info()
2074 tci->tcpi_snd_sbbytes = inp->inp_socket->so_snd.sb_cc; in tcp_connection_fill_info()
3155 if (so->so_rcv.sb_cc != 0 || tp->t_reassqlen != 0 || in tcp_disconnect()
H A Dtcp_subr.c3396 (rcvbuf - sb->sb_cc) < rcvbufinc && in tcp_sbrcv_grow_rwin()
3426 space = ((int32_t) imin((rcvbuf - sb->sb_cc), in tcp_sbspace()
3767 notsent = so->so_snd.sb_cc - in tcp_notsent_lowat_check()
5086 if (so->so_snd.sb_cc == 0) { in tcp_notify_ack_id_valid()
5096 if (elm->notify_snd_una == tp->snd_una + so->so_snd.sb_cc) { in tcp_notify_ack_id_valid()
5114 nm->notify_snd_una = tp->snd_una + so->so_snd.sb_cc; in tcp_add_notify_ack_marker()
5227 so->so_snd.sb_cc > 0) { in inp_get_sndbytes_allunsent()
5233 unsent = so->so_snd.sb_cc - sent; in inp_get_sndbytes_allunsent()
H A Dmptcp_var.h214 int cwnd = (int)(MIN(tp->snd_wnd, tp->snd_cwnd) - (so->so_snd.sb_cc)); in mptcp_subflow_cwnd_space()
H A Din_pcb.c2145 if (so->so_rcv.sb_cc > 0 || so->so_snd.sb_cc > 0) { in in_pcbdispose()
4227 if (so->so_snd.sb_cc > 0) { in inp_count_sndbytes()
4228 inp_incr_sndbytes_total(so, so->so_snd.sb_cc); in inp_count_sndbytes()
/xnu-11417.140.69/tools/lldbmacros/
H A Dnet.py617 …out_string += " s=" + str(int(so.so_snd.sb_cc)) + " r=" + str(int(so.so_rcv.sb_cc)) + " usecnt=" +…
686 snd_cc += int(so.so_snd.sb_cc)
687 total_snd_cc[0] += int(so.so_snd.sb_cc)
688 rcv_cc += int(so.so_rcv.sb_cc)
689 total_rcv_cc[0] += int(so.so_rcv.sb_cc)
1557 …t_string += "so=" + str(so) + " s=" + str(int(so.so_snd.sb_cc)) + " r=" + str(int(so.so_rcv.sb_cc))
1605 snd_cc[0] += so.so_snd.sb_cc
1608 rcv_cc[0] += so.so_rcv.sb_cc
1853 …ter, pcb.evp_class_filter, pcb.evp_subclass_filter, pcb.evp_socket.so_rcv.sb_cc, pcb.evp_socket.so…
1886 snd_cc = so.so_snd.sb_cc
[all …]
/xnu-11417.140.69/bsd/sys/
H A Dsocketvar.h174 uint32_t sb_cc; /* actual chars in buffer */ member
437 u_int32_t sb_cc; member
547 u_int32_t sb_cc; member
690 (sb)->sb_cc == 0) || \
691 ((sb)->sb_mb == NULL && (sb)->sb_cc > 0)) \
693 (sb)->sb_mb, (sb)->sb_cc); \
/xnu-11417.140.69/bsd/dev/dtrace/scripts/
H A Dsocket.d38 cc = T->sb_cc;
/xnu-11417.140.69/bsd/miscfs/fifofs/
H A Dfifo_vnops.c344 error = (rso->so_rcv.sb_cc == 0) ? EWOULDBLOCK : 0; in fifo_read()
/xnu-11417.140.69/bsd/net/
H A Dntstat.c2114 desc->sndbufused = so->so_snd.sb_cc; in nstat_tcp_copy_descriptor()
2116 desc->rcvbufused = so->so_rcv.sb_cc; in nstat_tcp_copy_descriptor()
2501 desc->rcvbufused = so->so_rcv.sb_cc; in nstat_udp_copy_descriptor()
7277 xsbrcv->sb_cc = desc->rcvbufused; in nstat_userland_to_rcv_xsockbuf_n()
7281 xsbrcv->sb_cc = desc->rcvbufused; in nstat_userland_to_rcv_xsockbuf_n()
7294 xsbsnd->sb_cc = desc->sndbufused; in nstat_userland_to_snd_xsockbuf_n()

12