Lines Matching defs:th_ack
2139 uint32_t prev_acked, int32_t meth, uint32_t target, uint32_t th_ack, int32_t line)
2149 log.u_bbr.flex5 = th_ack;
3594 SEQ_GEQ(th->th_ack, tp->gput_ack)) {
3604 gput = (int64_t) (th->th_ack - tp->gput_seq) * 8;
3690 prev_acked, 1, target_cwnd, th->th_ack, line);
3733 bbr_log_type_cwndupd(bbr, saved_bytes, sack_changed, prev_acked, meth, target_cwnd, th->th_ack, line);
6761 struct bbr_sendmap *rsm, struct tcpopt *to, uint32_t cts, int32_t ack_type, uint32_t th_ack)
7189 bbr_peer_reneges(struct tcp_bbr *bbr, struct bbr_sendmap *rsm, tcp_seq th_ack)
7240 sack_filter_clear(&bbr->r_ctl.bbr_sf, th_ack);
7291 register uint32_t th_ack;
7308 th_ack = th->th_ack;
7309 if (SEQ_GT(th_ack, tp->snd_una)) {
7313 if (SEQ_LEQ(th_ack, tp->snd_una)) {
7317 if (rsm && SEQ_GT(th_ack, rsm->r_start)) {
7318 changed = th_ack - rsm->r_start;
7319 } else if ((rsm == NULL) && ((th_ack - 1) == tp->iss)) {
7351 * The ACK point is advancing to th_ack, we must drop off
7371 if (SEQ_LT(th_ack, rsm->r_start)) {
7374 printf("Rack map starts at r_start:%u for th_ack:%u huh? ts:%d rs:%d bbr:%p\n",
7376 th_ack, tp->t_state,
7381 } else if (th_ack == rsm->r_start) {
7392 if (SEQ_GEQ(th_ack, rsm->r_end)) {
7406 bbr_update_rtt(tp, bbr, rsm, to, cts, BBR_CUM_ACKED, th_ack);
7440 left = th_ack - rsm->r_end;
7455 bbr->r_ctl.rc_sacked -= (th_ack - rsm->r_start);
7460 * It was acked up to th_ack point for the first time
7465 lrsm.r_end = th_ack;
7466 bbr_update_rtt(tp, bbr, &lrsm, to, cts, BBR_CUM_ACKED, th_ack);
7475 bbr->r_ctl.rc_lost_bytes -= th_ack - rsm->r_start;
7481 rsm->r_start = th_ack;
7485 if (rsm && (rsm->r_flags & BBR_ACKED) && (th_ack == rsm->r_start)) {
7494 * Note we have to look to make sure th_ack is our
7495 * rsm->r_start in case we get an old ack where th_ack is
7498 bbr_peer_reneges(bbr, rsm, th->th_ack);
7511 if (SEQ_GT(th_ack, tp->snd_una))
7512 ack_point = th_ack;
7537 } else if (SEQ_LEQ(sack.start, th_ack) &&
7538 SEQ_LEQ(sack.end, th_ack)) {
7552 num_sack_blks, th->th_ack);
7652 * ack-received code to augment what was changed between th_ack <->
7721 if (SEQ_LT(th->th_ack, seq_min)) {
7732 if (SEQ_GT(th->th_ack, tp->snd_max)) {
7737 if (SEQ_GEQ(th->th_ack, tp->snd_una) || to->to_nsacks) {
7741 if ((th->th_ack == tp->snd_una) && (tiwin == tp->snd_wnd))
7746 if (__predict_false(SEQ_LEQ(th->th_ack, tp->snd_una))) {
7751 if (th->th_ack == tp->snd_una) {
7814 if (SEQ_GT(th->th_ack, tp->snd_una)) {
7817 tp->snd_una = th->th_ack;
7820 if (SEQ_LT(th->th_ack, tp->snd_recover) &&
7821 (SEQ_LT(th->th_ack, tp->snd_max))) {
8152 (tp->snd_wl1 == th->th_seq && (SEQ_LT(tp->snd_wl2, th->th_ack) ||
8153 (tp->snd_wl2 == th->th_ack && tiwin > tp->snd_wnd))))) {
8156 tp->snd_wl2 == th->th_ack && tiwin > tp->snd_wnd)
8160 tp->snd_wl2 = th->th_ack;
8165 if ((tp->snd_wl2 == th->th_ack) && (tiwin < tp->snd_wnd)) {
8168 tp->snd_wl2 = th->th_ack;
8456 if (__predict_false((th->th_ack != tp->snd_una))) {
8569 if (__predict_false(SEQ_LEQ(th->th_ack, tp->snd_una))) {
8573 if (__predict_false(SEQ_GT(th->th_ack, tp->snd_max))) {
8681 if (SEQ_GT(th->th_ack, tp->snd_una))
8683 tp->snd_una = th->th_ack;
8695 * Pull snd_wl2 up to prevent seq wrap relative to th_ack.
8697 tp->snd_wl2 = th->th_ack;
8763 (SEQ_LEQ(th->th_ack, tp->iss) ||
8764 SEQ_GT(th->th_ack, tp->snd_max))) {
8807 tp->snd_nxt = th->th_ack;
8822 if (SEQ_GT(th->th_ack, tp->iss)) {
8829 if (SEQ_GT(th->th_ack, tp->snd_una)) {
8832 * fast open case. If th_ack is
8965 (SEQ_LEQ(th->th_ack, tp->snd_una) ||
8966 SEQ_GT(th->th_ack, tp->snd_max))) {
9114 if (SEQ_GT(th->th_ack, tp->snd_una) && !(tp->t_flags & TF_NEEDSYN))
11458 sack_filter_clear(&bbr->r_ctl.bbr_sf, th->th_ack);
11477 if (SEQ_GT(th->th_ack, tp->snd_una) && (rsm = TAILQ_FIRST(&bbr->r_ctl.rc_map)) != NULL)
11511 (SEQ_LEQ(th->th_ack, tp->iss) || SEQ_GT(th->th_ack, tp->snd_max))) {
13348 th->th_ack = htonl(tp->rcv_nxt);