Home
last modified time | relevance | path

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

12

/xnu-12377.41.6/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.c583 error = msleep((caddr_t)&sb->sb_cc, mutex_held, in sbwait()
615 wakeup((caddr_t)&sb->sb_cc); in sbwakeup()
1685 sb->sb_cc += m->m_len; in sbcompress()
1707 sb->sb_cc += tocopy; in sbcompress()
1757 if (!(sb->sb_cc == 0 && sb->sb_mb == NULL && sb->sb_mbcnt == 0 && in sb_empty_assert()
1760 "lastrecord %p\n", where, sb, sb->sb_so, sb->sb_cc, in sb_empty_assert()
1804 if (!sb->sb_cc && (sb->sb_mb == NULL || sb->sb_mb->m_len)) { in sbflush()
1807 sbdrop(sb, (int)sb->sb_cc); in sbflush()
1869 sb->sb_cc = 0; in sbdrop()
1880 sb->sb_cc -= len; in sbdrop()
[all …]
H A Duipc_socket.c1978 (ret == MEMACCT_SOFTLIMIT && so->so_snd.sb_cc > 0)) { in sosendcheck()
2064 so->so_snd.sb_cc, so->so_snd.sb_lowat, so->so_snd.sb_hiwat); in sosend()
2507 so->so_snd.sb_cc, space, error); in sosend()
2608 so->so_snd.sb_cc, so->so_snd.sb_lowat, so->so_snd.sb_hiwat); in sosend_list()
2810 so->so_snd.sb_cc, 0, error); in sosend_list()
2919 if (m->m_next == NULL && so->so_rcv.sb_cc != 0) { in soreceive_addr()
3123 if ((flags & MSG_DONTWAIT) == 0 && so->so_rcv.sb_cc < uio_resid(uio) && in so_should_wait()
3129 if (so->so_rcv.sb_cc < so->so_rcv.sb_lowat) { in so_should_wait()
3210 uio_resid(uio), so->so_rcv.sb_cc, so->so_rcv.sb_lowat, in soreceive()
3742 so->so_rcv.sb_cc -= len; 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-12377.41.6/bsd/netinet/
H A Dtcp_output.c332 if (so->so_snd.sb_cc > (tp->t_maxopd - MAX_TCPOPTLEN)) { in tcp_tfo_check()
1363 if (off < so->so_snd.sb_cc) { in tcp_output()
1392 len = min(so->so_snd.sb_cc, sendwin) - off; in tcp_output()
1403 len = min(so->so_snd.sb_cc, tp->snd_wnd) - off; in tcp_output()
1577 so->so_snd.sb_cc >= (so->so_snd.sb_hiwat / 8 * 7) && in tcp_output()
1578 sendwin >= (so->so_snd.sb_cc - (tp->snd_nxt - tp->snd_una))) { in tcp_output()
1697 if (SEQ_LT(seg->start_seq + len, tp->snd_una + so->so_snd.sb_cc)) { in tcp_output()
1701 if (SEQ_LT(p->rxmit + len, tp->snd_una + so->so_snd.sb_cc)) { in tcp_output()
1706 if (SEQ_LT(tp->snd_nxt + len, tp->snd_una + so->so_snd.sb_cc)) { in tcp_output()
1863 (len + off >= so->so_snd.sb_cc || in tcp_output()
[all …]
H A Dtcp_cc.c189 tp->t_inpcb->inp_socket->so_rcv.sb_cc > tp->t_inpcb->inp_socket->so_rcv.sb_lowat && in tcp_cc_delay_ack()
251 (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()
3038 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.c428 count = mp_so->so_rcv.sb_cc; in mptcp_input()
480 count = mp_so->so_rcv.sb_cc - count; in mptcp_input()
615 count = mp_so->so_rcv.sb_cc - count; in mptcp_input()
628 count = mp_so->so_rcv.sb_cc; in mptcp_input()
732 mp_so->so_snd.sb_cc >= (mp_so->so_snd.sb_hiwat / 8 * 7)) { in mptcp_output()
851 (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.c1169 trim = sbrcv->sb_hiwat - (sbrcv->sb_cc + leave); in tcp_sbrcv_trim()
1192 if (sbsnd->sb_cc <= sbsnd->sb_idealsize) { in tcp_sbsnd_trim()
1195 trim = sbsnd->sb_hiwat - sbsnd->sb_cc; in tcp_sbsnd_trim()
1439 snd_len = min(so->so_snd.sb_cc, tp->snd_wnd) - snd_off; in tcp_early_rexmt_check()
3884 if ((so->so_snd.sb_cc) || (tp->t_flags & TF_ACKNOW)) { in tcp_input()
3904 (mem == MEMACCT_SOFTLIMIT && so->so_rcv.sb_cc > 0)) { in tcp_input()
5000 if (so->so_snd.sb_cc) { in tcp_input()
5446 (so->so_snd.sb_cc - (tp->snd_max - tp->snd_una)) > 0) { in tcp_input()
5695 if (acked > so->so_snd.sb_cc) { in tcp_input()
5696 tp->snd_wnd -= so->so_snd.sb_cc; in tcp_input()
[all …]
H A Dmptcp_opt.c1098 if (acked > mp_so->so_snd.sb_cc) { in mptcp_data_ack_rcvd()
1099 if (acked > mp_so->so_snd.sb_cc + 1 || in mptcp_data_ack_rcvd()
1103 (uint32_t)acked, mp_so->so_snd.sb_cc, in mptcp_data_ack_rcvd()
1108 sbdrop(&mp_so->so_snd, (int)mp_so->so_snd.sb_cc); in mptcp_data_ack_rcvd()
H A Dflow_divert.c1563 if (fd_cb->so->so_snd.sb_cc == 0) { in flow_divert_send_close_if_needed()
1741 to_send = fd_cb->so->so_snd.sb_cc; in flow_divert_send_buffered_data()
1855 if (fd_cb->so->so_snd.sb_cc > 0) { in flow_divert_send_app_data()
1909 fd_cb->so->so_snd.sb_cc, fd_cb->send_window); in flow_divert_send_app_data()
1921 fd_cb->so->so_snd.sb_cc, fd_cb->send_window); in flow_divert_send_app_data()
1957 fd_cb->so->so_snd.sb_cc, fd_cb->send_window, append_error); in flow_divert_send_app_data()
1963 fd_cb->so->so_snd.sb_cc, fd_cb->send_window); in flow_divert_send_app_data()
2327 size_t data_len = so->so_snd.sb_cc; in flow_divert_disable()
3333 state.send_buffer_bytes = so->so_snd.sb_cc; in flow_divert_handle_flow_states_request()
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()
1796 ti->tcpi_snd_sbbytes = inp->inp_socket->so_snd.sb_cc; in tcp_fill_info()
2078 tci->tcpi_snd_sbbytes = inp->inp_socket->so_snd.sb_cc; in tcp_connection_fill_info()
3152 if (so->so_rcv.sb_cc != 0 || tp->t_reassqlen != 0 || in tcp_disconnect()
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 Dtcp_subr.c3641 (rcvbuf - sb->sb_cc) < rcvbufinc && in tcp_sbrcv_grow_rwin()
3671 space = ((int32_t) imin((rcvbuf - sb->sb_cc), in tcp_sbspace()
3905 notsent = so->so_snd.sb_cc - in tcp_notsent_lowat_check()
5274 if (so->so_snd.sb_cc == 0) { in tcp_notify_ack_id_valid()
5284 if (elm->notify_snd_una == tp->snd_una + so->so_snd.sb_cc) { in tcp_notify_ack_id_valid()
5302 nm->notify_snd_una = tp->snd_una + so->so_snd.sb_cc; in tcp_add_notify_ack_marker()
5415 so->so_snd.sb_cc > 0) { in inp_get_sndbytes_allunsent()
5421 unsent = so->so_snd.sb_cc - sent; in inp_get_sndbytes_allunsent()
H A Din_pcb.c2104 if (so->so_rcv.sb_cc > 0 || so->so_snd.sb_cc > 0) { in in_pcbdispose()
4185 if (so->so_snd.sb_cc > 0) { in inp_count_sndbytes()
4186 inp_incr_sndbytes_total(so, so->so_snd.sb_cc); in inp_count_sndbytes()
H A Dtcp_timer.c1719 snd_len = min(so->so_snd.sb_cc, tp->snd_wnd) in tcp_timers()
1786 (tp->t_inpcb->inp_socket->so_snd.sb_cc != 0 || tp->t_state == TCPS_SYN_SENT || in tcp_timers()
/xnu-12377.41.6/bsd/sys/
H A Dsocketvar.h168 uint32_t sb_cc; /* actual chars in buffer */ member
428 u_int32_t sb_cc; member
538 u_int32_t sb_cc; member
680 if (((sb)->sb_mb != NULL && (sb)->sb_cc == 0 && m_length((sb)->sb_mb) != 0) || \
681 ((sb)->sb_mb == NULL && (sb)->sb_cc > 0)) \
685 (sb)->sb_mb != NULL ? (sb)->sb_mb->m_type : 0, (sb)->sb_cc, (sb)->sb_ctl); \
/xnu-12377.41.6/bsd/dev/dtrace/scripts/
H A Dsocket.d38 cc = T->sb_cc;
/xnu-12377.41.6/tools/lldbmacros/
H A Dnet.py570 …out_string += " s=" + str(int(so.so_snd.sb_cc)) + " r=" + str(int(so.so_rcv.sb_cc)) + " usecnt=" +…
639 snd_cc += int(so.so_snd.sb_cc)
640 total_snd_cc[0] += int(so.so_snd.sb_cc)
641 rcv_cc += int(so.so_rcv.sb_cc)
642 total_rcv_cc[0] += int(so.so_rcv.sb_cc)
1510 …t_string += "so=" + str(so) + " s=" + str(int(so.so_snd.sb_cc)) + " r=" + str(int(so.so_rcv.sb_cc))
1569 snd_cc[0] += so.so_snd.sb_cc
1572 rcv_cc[0] += so.so_rcv.sb_cc
1817 …ter, pcb.evp_class_filter, pcb.evp_subclass_filter, pcb.evp_socket.so_rcv.sb_cc, pcb.evp_socket.so…
1850 snd_cc = so.so_snd.sb_cc
[all …]
/xnu-12377.41.6/bsd/miscfs/fifofs/
H A Dfifo_vnops.c344 error = (rso->so_rcv.sb_cc == 0) ? EWOULDBLOCK : 0; in fifo_read()

12