Home
last modified time | relevance | path

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

12

/xnu-10063.141.1/bsd/kern/
H A Dsys_socket.c227 bcopy(&so->so_rcv.sb_cc, data, sizeof(u_int32_t)); in soioctl()
379 so->so_rcv.sb_cc != 0) { in soo_stat()
385 sb64->st_size = so->so_rcv.sb_cc - so->so_rcv.sb_ctl; in soo_stat()
391 so->so_rcv.sb_cc != 0) { in soo_stat()
397 sb->st_size = so->so_rcv.sb_cc - so->so_rcv.sb_ctl; in soo_stat()
H A Duipc_socket2.c580 error = msleep((caddr_t)&sb->sb_cc, mutex_held, in sbwait()
612 wakeup((caddr_t)&sb->sb_cc); in sbwakeup()
1037 if (len != sb->sb_cc || mbcnt != sb->sb_mbcnt) { in sbcheck()
1038 panic("cc %ld != %ld || mbcnt %ld != %ld", len, sb->sb_cc, in sbcheck()
1672 sb->sb_cc += m->m_len; in sbcompress()
1714 if (!(sb->sb_cc == 0 && sb->sb_mb == NULL && sb->sb_mbcnt == 0 && in sb_empty_assert()
1717 "lastrecord %p\n", where, sb, sb->sb_so, sb->sb_cc, in sb_empty_assert()
1761 if (!sb->sb_cc && (sb->sb_mb == NULL || sb->sb_mb->m_len)) { in sbflush()
1764 sbdrop(sb, (int)sb->sb_cc); in sbflush()
1833 sb->sb_cc = 0; in sbdrop()
[all …]
H A Duipc_socket.c2197 so->so_snd.sb_cc, so->so_snd.sb_lowat, so->so_snd.sb_hiwat); in sosend()
2639 so->so_snd.sb_cc, space, error); in sosend()
2734 so->so_snd.sb_cc, so->so_snd.sb_lowat, so->so_snd.sb_hiwat); in sosend_list()
2924 so->so_snd.sb_cc, 0, error); in sosend_list()
3033 if (m->m_next == NULL && so->so_rcv.sb_cc != 0) { in soreceive_addr()
3237 if ((flags & MSG_DONTWAIT) == 0 && so->so_rcv.sb_cc < uio_resid(uio) && in so_should_wait()
3243 if (so->so_rcv.sb_cc < so->so_rcv.sb_lowat) { in so_should_wait()
3322 uio_resid(uio), so->so_rcv.sb_cc, so->so_rcv.sb_lowat, in soreceive()
3854 so->so_rcv.sb_cc -= len; in soreceive()
3974 if ((so->so_options & SO_WANTMORE) && so->so_rcv.sb_cc > 0) { in soreceive()
[all …]
H A Dkern_control.c742 trim = sb->sb_hiwat - sb->sb_cc; in ctl_sbrcv_trim()
1005 so->so_rcv.sb_hiwat, so->so_rcv.sb_cc); in ctl_enqueuembuf()
1118 so->so_rcv.sb_hiwat, so->so_rcv.sb_cc); in ctl_enqueuembuf_list()
1220 so->so_rcv.sb_hiwat, so->so_rcv.sb_cc); in ctl_enqueuedata()
1298 if (so->so_rcv.sb_cc >= so->so_rcv.sb_lowat) { in ctl_getenqueuereadable()
1301 *difference = (so->so_rcv.sb_lowat - so->so_rcv.sb_cc); in ctl_getenqueuereadable()
H A Duipc_usrreq.c449 snd->sb_hiwat += unp->unp_cc - rcv->sb_cc; in uipc_rcvd()
450 unp->unp_cc = rcv->sb_cc; in uipc_rcvd()
650 (int32_t)(rcv->sb_cc - unp->unp_conn->unp_cc)) { in uipc_send()
651 snd->sb_hiwat -= rcv->sb_cc - unp->unp_conn->unp_cc; in uipc_send()
655 unp->unp_conn->unp_cc = rcv->sb_cc; in uipc_send()
721 blksize += so2->so_rcv.sb_cc; in uipc_sense()
H A Dsocket_info.c58 sbi->sbi_cc = sb->sb_cc; in fill_sockbuf_info()
/xnu-10063.141.1/bsd/netinet/
H A Dtcp_output.c355 if (so->so_snd.sb_cc > (tp->t_maxopd - MAX_TCPOPTLEN)) { in tcp_tfo_check()
1055 if (off < so->so_snd.sb_cc) { in tcp_output()
1083 len = min(so->so_snd.sb_cc, sendwin) - off; in tcp_output()
1102 len = min(so->so_snd.sb_cc, tp->snd_wnd) - off; in tcp_output()
1268 so->so_snd.sb_cc >= (so->so_snd.sb_hiwat / 8 * 7) && in tcp_output()
1269 sendwin >= (so->so_snd.sb_cc - (tp->snd_nxt - tp->snd_una))) { in tcp_output()
1387 if (SEQ_LT(p->rxmit + len, tp->snd_una + so->so_snd.sb_cc)) { in tcp_output()
1391 if (SEQ_LT(tp->snd_nxt + len, tp->snd_una + so->so_snd.sb_cc)) { in tcp_output()
1532 (len + off >= so->so_snd.sb_cc || in tcp_output()
1593 if (so->so_rcv.sb_cc < so->so_rcv.sb_lowat && in tcp_output()
[all …]
H A Dtcp_cc.c200 tp->t_inpcb->inp_socket->so_rcv.sb_cc > tp->t_inpcb->inp_socket->so_rcv.sb_lowat && in tcp_cc_delay_ack()
276 (so != NULL && so->so_snd.sb_cc > tp->snd_cwnd)) { in tcp_cc_is_cwnd_nonvalidated()
H A Dmptcp_subr.c654 if (mptetoso(mpte)->so_snd.sb_cc != 0 && tp->t_rxtshift >= mptcp_fail_thresh * 2) { in mptcp_handover_use_cellular()
667 if (mptetoso(mpte)->so_snd.sb_cc != 0) { in mptcp_handover_use_cellular()
773 mptetoso(mpte)->so_snd.sb_cc, in mptcp_check_subflows_and_add()
976 …nsigned long)VM_KERNEL_ADDRPERM(mpte), tp->t_rxtshift, mptetoso(mpte)->so_snd.sb_cc, wifi_quality); in mptcp_pure_handover_subflows_remove()
1029 …nsigned long)VM_KERNEL_ADDRPERM(mpte), tp->t_rxtshift, mptetoso(mpte)->so_snd.sb_cc, wifi_quality); in mptcp_handover_subflows_remove()
1952 so->so_rcv.sb_cc -= new->m_len; in mptcp_adj_rmap()
2253 if (SEQ_GT(sseq + tp->irs, tp->rcv_nxt - so->so_rcv.sb_cc)) { in mptcp_subflow_soreceive()
2255 int totrim = (int)sseq + tp->irs - (tp->rcv_nxt - so->so_rcv.sb_cc); in mptcp_subflow_soreceive()
2265 if ((int)so->so_rcv.sb_cc < dlen) { in mptcp_subflow_soreceive()
3008 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.c418 count = mp_so->so_rcv.sb_cc; in mptcp_input()
470 count = mp_so->so_rcv.sb_cc - count; in mptcp_input()
605 count = mp_so->so_rcv.sb_cc - count; in mptcp_input()
618 count = mp_so->so_rcv.sb_cc; in mptcp_input()
722 mp_so->so_snd.sb_cc >= (mp_so->so_snd.sb_hiwat / 8 * 7)) { in mptcp_output()
841 (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()
676 (activeonly && so->so_snd.sb_cc == 0)) { in inpcb_get_if_ports_used()
964 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.c1172 trim = sbrcv->sb_hiwat - (sbrcv->sb_cc + leave); in tcp_sbrcv_trim()
1195 if (sbsnd->sb_cc <= sbsnd->sb_idealsize) { in tcp_sbsnd_trim()
1198 trim = sbsnd->sb_hiwat - sbsnd->sb_cc; in tcp_sbsnd_trim()
1521 snd_len = min(so->so_snd.sb_cc, tp->snd_wnd) - snd_off; in tcp_early_rexmt_check()
3174 if ((so->so_snd.sb_cc) || (tp->t_flags & TF_ACKNOW)) { in tcp_input()
4587 if (so->so_snd.sb_cc) { in tcp_input()
5008 (so->so_snd.sb_cc - (tp->snd_max - tp->snd_una)) > 0) { in tcp_input()
5203 if (acked > so->so_snd.sb_cc) { in tcp_input()
5204 tp->snd_wnd -= so->so_snd.sb_cc; in tcp_input()
5205 sbdrop(&so->so_snd, (int)so->so_snd.sb_cc); in tcp_input()
[all …]
H A Dmptcp_opt.c1115 if (acked > mp_so->so_snd.sb_cc) { in mptcp_data_ack_rcvd()
1116 if (acked > mp_so->so_snd.sb_cc + 1 || in mptcp_data_ack_rcvd()
1120 (uint32_t)acked, mp_so->so_snd.sb_cc, in mptcp_data_ack_rcvd()
1125 sbdrop(&mp_so->so_snd, (int)mp_so->so_snd.sb_cc); in mptcp_data_ack_rcvd()
H A Dflow_divert.c1555 if (fd_cb->so->so_snd.sb_cc == 0) { in flow_divert_send_close_if_needed()
1737 to_send = fd_cb->so->so_snd.sb_cc; in flow_divert_send_buffered_data()
1851 if (fd_cb->so->so_snd.sb_cc > 0) { in flow_divert_send_app_data()
1906 fd_cb->so->so_snd.sb_cc, fd_cb->send_window); in flow_divert_send_app_data()
1918 fd_cb->so->so_snd.sb_cc, fd_cb->send_window); in flow_divert_send_app_data()
1954 fd_cb->so->so_snd.sb_cc, fd_cb->send_window, append_error); in flow_divert_send_app_data()
1960 fd_cb->so->so_snd.sb_cc, fd_cb->send_window); in flow_divert_send_app_data()
2289 size_t data_len = so->so_snd.sb_cc; in flow_divert_disable()
3279 state.send_buffer_bytes = fd_cb->so->so_snd.sb_cc; in flow_divert_handle_flow_states_request()
H A Dtcp_usrreq.c1201 mpkl_seq = tp->snd_una + so->so_snd.sb_cc; in tcp_usr_send()
1304 tp->snd_up = tp->snd_una + so->so_snd.sb_cc; in tcp_usr_send()
1803 ti->tcpi_snd_sbbytes = inp->inp_socket->so_snd.sb_cc; in tcp_fill_info()
2063 tci->tcpi_snd_sbbytes = inp->inp_socket->so_snd.sb_cc; in tcp_connection_fill_info()
3136 if (so->so_rcv.sb_cc != 0 || tp->t_reassqlen != 0 || in tcp_disconnect()
H A Dtcp_subr.c3361 (rcvbuf - sb->sb_cc) < rcvbufinc && in tcp_sbrcv_grow_rwin()
3391 space = ((int32_t) imin((rcvbuf - sb->sb_cc), in tcp_sbspace()
3647 notsent = so->so_snd.sb_cc - in tcp_notsent_lowat_check()
4298 if (so->so_snd.sb_cc == 0) { in tcp_notify_ack_id_valid()
4308 if (elm->notify_snd_una == tp->snd_una + so->so_snd.sb_cc) { in tcp_notify_ack_id_valid()
4326 nm->notify_snd_una = tp->snd_una + so->so_snd.sb_cc; in tcp_add_notify_ack_marker()
4439 so->so_snd.sb_cc > 0) { in inp_get_sndbytes_allunsent()
4445 unsent = so->so_snd.sb_cc - sent; in inp_get_sndbytes_allunsent()
H A Dmptcp_var.h212 int cwnd = (int)(MIN(tp->snd_wnd, tp->snd_cwnd) - (so->so_snd.sb_cc)); in mptcp_subflow_cwnd_space()
H A Din_pcb.c2113 if (so->so_rcv.sb_cc > 0 || so->so_snd.sb_cc > 0) { in in_pcbdispose()
4130 if (so->so_snd.sb_cc > 0) { in inp_count_sndbytes()
4131 inp_incr_sndbytes_total(so, so->so_snd.sb_cc); in inp_count_sndbytes()
/xnu-10063.141.1/tools/lldbmacros/
H A Dnet.py579 …out_string += " s=" + str(int(so.so_snd.sb_cc)) + " r=" + str(int(so.so_rcv.sb_cc)) + " usecnt=" +…
648 snd_cc += int(so.so_snd.sb_cc)
649 total_snd_cc[0] += int(so.so_snd.sb_cc)
650 rcv_cc += int(so.so_rcv.sb_cc)
651 total_rcv_cc[0] += int(so.so_rcv.sb_cc)
1566 …t_string += "so=" + str(so) + " s=" + str(int(so.so_snd.sb_cc)) + " r=" + str(int(so.so_rcv.sb_cc))
1614 snd_cc[0] += so.so_snd.sb_cc
1617 rcv_cc[0] += so.so_rcv.sb_cc
1860 …ter, pcb.evp_class_filter, pcb.evp_subclass_filter, pcb.evp_socket.so_rcv.sb_cc, pcb.evp_socket.so…
1893 snd_cc = so.so_snd.sb_cc
[all …]
/xnu-10063.141.1/bsd/sys/
H A Dsocketvar.h168 uint32_t sb_cc; /* actual chars in buffer */ member
430 u_int32_t sb_cc; member
540 u_int32_t sb_cc; member
683 (sb)->sb_cc == 0) || \
684 ((sb)->sb_mb == NULL && (sb)->sb_cc > 0)) \
686 (sb)->sb_mb, (sb)->sb_cc); \
/xnu-10063.141.1/bsd/dev/dtrace/scripts/
H A Dsocket.d38 cc = T->sb_cc;
/xnu-10063.141.1/bsd/miscfs/fifofs/
H A Dfifo_vnops.c344 error = (rso->so_rcv.sb_cc == 0) ? EWOULDBLOCK : 0; in fifo_read()
/xnu-10063.141.1/bsd/net/
H A Dntstat.c1796 desc->sndbufused = so->so_snd.sb_cc; in nstat_tcp_copy_descriptor()
1798 desc->rcvbufused = so->so_rcv.sb_cc; in nstat_tcp_copy_descriptor()
2179 desc->rcvbufused = so->so_rcv.sb_cc; in nstat_udp_copy_descriptor()
7207 xsbrcv->sb_cc = desc->rcvbufused; in nstat_userland_to_rcv_xsockbuf_n()
7211 xsbrcv->sb_cc = desc->rcvbufused; in nstat_userland_to_rcv_xsockbuf_n()
7224 xsbsnd->sb_cc = desc->sndbufused; in nstat_userland_to_snd_xsockbuf_n()

12