Home
last modified time | relevance | path

Searched refs:acked (Results 1 – 10 of 10) sorted by relevance

/xnu-11215.81.4/bsd/netinet/
H A Dtcp_newreno.c142 uint32_t acked = 0; in tcp_newreno_congestion_avd() local
143 acked = BYTES_ACKED(th, tp); in tcp_newreno_congestion_avd()
149 tp->t_bytes_acked += acked; in tcp_newreno_congestion_avd()
176 uint32_t acked = 0; in tcp_newreno_ack_rcvd() local
178 acked = BYTES_ACKED(th, tp); in tcp_newreno_ack_rcvd()
180 tp->t_bytes_acked += acked; in tcp_newreno_ack_rcvd()
199 incr = ulmin(acked, abc_lim); in tcp_newreno_ack_rcvd()
H A Dtcp_prague.c43 static void tcp_prague_set_bytes_acked(struct tcpcb *tp, uint32_t acked);
46 static void prague_ca_after_ce(struct tcpcb *tp, uint32_t acked);
195 tcp_cubic_ack_ca(struct tcpcb *tp, struct tcphdr *th, uint32_t acked) in tcp_cubic_ack_ca() argument
205 tp->t_bytes_acked += acked; in tcp_cubic_ack_ca()
253 uint32_t acked = tp->t_ccstate->prague_bytes_acked; in tcp_prague_ack_rcvd() local
255 if (acked == 0) { in tcp_prague_ack_rcvd()
262 prague_ca_after_ce(tp, acked); in tcp_prague_ack_rcvd()
264 tcp_cubic_ack_ca(tp, th, acked); in tcp_prague_ack_rcvd()
272 uint32_t incr = min(acked, abc_lim); in tcp_prague_ack_rcvd()
409 prague_ca_after_ce(struct tcpcb *tp, uint32_t acked) in prague_ca_after_ce() argument
[all …]
H A Dtcp_ledbat.c196 int acked = 0; in tcp_ledbat_congestion_avd() local
199 acked = BYTES_ACKED(th, tp); in tcp_ledbat_congestion_avd()
202 ledbat_pp_ack_rcvd(tp, acked); in tcp_ledbat_congestion_avd()
204 tp->t_bytes_acked += acked; in tcp_ledbat_congestion_avd()
394 uint32_t acked = 0; in tcp_ledbat_ack_rcvd() local
396 acked = BYTES_ACKED(th, tp); in tcp_ledbat_ack_rcvd()
399 ledbat_pp_ack_rcvd(tp, acked); in tcp_ledbat_ack_rcvd()
403 tp->t_bytes_acked += acked; in tcp_ledbat_ack_rcvd()
423 incr = ulmin(acked, abc_lim); in tcp_ledbat_ack_rcvd()
H A Dtcp_cubic.c372 uint32_t acked, abc_lim, incr; in tcp_cubic_ack_rcvd() local
374 acked = BYTES_ACKED(th, tp); in tcp_cubic_ack_rcvd()
384 incr = min(acked, abc_lim); in tcp_cubic_ack_rcvd()
H A Dmptcp_opt.c1108 uint64_t acked = full_dack - mp_tp->mpt_snduna; in mptcp_data_ack_rcvd() local
1110 VERIFY(acked <= INT_MAX); in mptcp_data_ack_rcvd()
1112 if (acked) { in mptcp_data_ack_rcvd()
1115 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()
1127 sbdrop(&mp_so->so_snd, (int)acked); in mptcp_data_ack_rcvd()
1130 mp_tp->mpt_snduna += acked; in mptcp_data_ack_rcvd()
H A Dtcp_input.c1362 u_int32_t fsize, acked; in tcp_bad_rexmt_restore_state() local
1364 acked = BYTES_ACKED(th, tp); in tcp_bad_rexmt_restore_state()
1377 tp->snd_cwnd = fsize + min(acked, tp->snd_cwnd); in tcp_bad_rexmt_restore_state()
2027 int todrop, acked = 0, ourfinisacked, needoutput = 0; in tcp_input() local
3212 acked = BYTES_ACKED(th, tp); in tcp_input()
3214 tcpstat.tcps_rcvackbyte += acked; in tcp_input()
3221 uint32_t pkts_acked = tcp_packets_this_ack(tp, acked); in tcp_input()
3225 if (acked == 0 && (to.to_flags & TOF_TS) != 0 && to.to_tsecr != 0 && in tcp_input()
3229 if (acked > 0 || newly_acked_time) { in tcp_input()
3263 sbdrop(&so->so_snd, acked); in tcp_input()
[all …]
H A Dtcp_cc.h222 void (*set_bytes_acked) (struct tcpcb *tp, uint32_t acked);
H A Dtcp_subr.c490 tcp_packets_this_ack(struct tcpcb *tp, uint32_t acked) in tcp_packets_this_ack() argument
492 return acked / tp->t_maxseg + in tcp_packets_this_ack()
493 (((acked % tp->t_maxseg) != 0) ? 1 : 0); in tcp_packets_this_ack()
H A Dtcp_var.h1796 uint32_t tcp_packets_this_ack(struct tcpcb *tp, uint32_t acked);
/xnu-11215.81.4/doc/primitives/
H A Dsched_cond.md76 not awake and has not already been issued an un-acked wakeup. Conversely, the consumer acks the wak…