Lines Matching refs:snd_una

606 		bytes += (rack->rc_tp->snd_una - rack->r_ctl.lt_seq);  in rack_get_lt_bw()
2272 if (SEQ_GT(ent->end_seq, rack->rc_tp->snd_una)) in rack_rate_cap_bw()
2273 lenleft = ent->end_seq - rack->rc_tp->snd_una; in rack_rate_cap_bw()
2287 if (SEQ_GT(rack->rc_tp->snd_una, ent->start_seq)) in rack_rate_cap_bw()
2288 lengone = rack->rc_tp->snd_una - ent->start_seq; in rack_rate_cap_bw()
3605 if ((tp->snd_max == tp->snd_una) || in rack_enough_for_measurement()
4202 if (rack->rc_tp->snd_max == rack->rc_tp->snd_una) { in rack_enter_probertt()
4207 SEQ_GT(rack->rc_tp->snd_una, rack->rc_tp->gput_seq)) { in rack_enter_probertt()
4216 rack->rc_tp->snd_una, __LINE__, in rack_enter_probertt()
4245 SEQ_GT(rack->rc_tp->snd_una, rack->rc_tp->gput_seq)) { in rack_exit_probertt()
4254 rack->rc_tp->snd_una, __LINE__, in rack_exit_probertt()
4812 if (tp->snd_una == tp->snd_max) { in rack_tend_gp_marks()
4816 if (SEQ_GT(tp->gput_seq, tp->snd_una)) { in rack_tend_gp_marks()
5469 acked = tp->t_ccv.bytes_this_ack = (th_ack - tp->snd_una); in rack_ack_received()
5687 tp->snd_recover = tp->snd_una; in rack_post_recovery()
5737 rack->r_ctl.rc_prr_recovery_fs = tp->snd_max - tp->snd_una; in rack_cong_signal()
6000 if (((tp->snd_max - tp->snd_una) - rack->r_ctl.rc_sacked + rack->r_ctl.rc_holes_rxt) <= segsiz) { in rack_calc_thresh_tlp()
6119 rack_cong_signal(tp, CC_NDUPACK, tp->snd_una, __LINE__); in rack_check_recovery_mode()
6191 if (SEQ_LT(tp->snd_una, tp->snd_max) || in rack_timer_start()
6239 ((tp->snd_max - tp->snd_una) == 1) && in rack_timer_start()
6367 rack_enter_persist(struct tcpcb *tp, struct tcp_rack *rack, uint32_t cts, tcp_seq snd_una) in rack_enter_persist() argument
6375 rack_do_goodput_measurement(tp, rack, tp->snd_una, __LINE__, in rack_enter_persist()
6391 rack->r_ctl.lt_bw_bytes += (snd_una - rack->r_ctl.lt_seq); in rack_enter_persist()
6392 rack->r_ctl.lt_seq = snd_una; in rack_enter_persist()
6836 if (SEQ_GT(tp->snd_max, tp->snd_una)) { in rack_start_hpts_timer()
6998 (src_rsm->r_start - rack->rc_tp->snd_una), in rack_setup_offset_for_rsm()
7003 (rsm->r_start - rack->rc_tp->snd_una), in rack_setup_offset_for_rsm()
7190 out = tp->snd_max - tp->snd_una; in rack_timeout_tlp()
7285 if (SEQ_GT((rack->r_ctl.last_collapse_point - 1), rack->rc_tp->snd_una)) in rack_timeout_tlp()
7373 rack->rc_tp->rcv_nxt, rack->rc_tp->snd_una - 1, 0); in rack_send_ack_challange()
7426 tp->snd_una == tp->snd_max) in rack_timeout_persist()
7523 rack->r_ctl.rc_last_timeout_snduna = tp->snd_una; in rack_remxt_tmr()
7703 (tp->snd_una == tp->snd_max)) { in rack_timeout_rxt()
7929 sack_filter_clear(&rack->r_ctl.rack_sf, tp->snd_una); in rack_timeout_rxt()
7933 rack_cong_signal(tp, CC_RTO, tp->snd_una, __LINE__); in rack_timeout_rxt()
7955 if (SEQ_GT(tp->gput_seq, tp->snd_una)) in rack_process_timers()
7956 bytes += tp->gput_seq - tp->snd_una; in rack_process_timers()
8062 ((tp->snd_max - tp->snd_una) == 0))) { in rack_timer_cancel()
8066 if ((tp->snd_max - tp->snd_una) == 0) in rack_timer_cancel()
8280 register uint32_t snd_max, snd_una; in rack_log_output() local
8319 snd_una = tp->snd_una; in rack_log_output()
8333 if (SEQ_LEQ((seq_out + len), snd_una)) { in rack_log_output()
8337 if (SEQ_LT(seq_out, snd_una)) { in rack_log_output()
8342 seq_out = snd_una; in rack_log_output()
8548 seq_out, len, tp->snd_una, tp->snd_max); in rack_log_output()
9497 rack_need_set_test(tp, rack, nrsm, tp->snd_una, __LINE__, RACK_USE_END); in rack_proc_sack_blk()
9692 rack_need_set_test(tp, rack, rsm, tp->snd_una, __LINE__, RACK_USE_END); in rack_proc_sack_blk()
9856 rack_need_set_test(tp, rack, nrsm, tp->snd_una, __LINE__, RACK_USE_END); in rack_proc_sack_blk()
9986 rack_need_set_test(tp, rack, rsm, tp->snd_una, __LINE__, RACK_USE_END); in rack_proc_sack_blk()
10228 if (SEQ_GT(th_ack, tp->snd_una)) { in rack_process_to_cumack()
10233 if (SEQ_GT(th_ack, tp->snd_una)) in rack_process_to_cumack()
10304 tp->snd_una, tp->snd_max); in rack_process_to_cumack()
10555 (rsm->r_start - tp->snd_una), in rack_process_to_cumack()
10571 rack_need_set_test(tp, rack, rsm, tp->snd_una, __LINE__, RACK_USE_BEG); in rack_process_to_cumack()
10607 tp->snd_recover = tp->snd_una; in rack_handle_might_revert()
10700 do_rack_compute_pipe(struct tcpcb *tp, struct tcp_rack *rack, uint32_t snd_una) in do_rack_compute_pipe() argument
10702 return (((tp->snd_max - snd_una) - in do_rack_compute_pipe()
10711 tp->snd_una)); in rack_compute_pipe()
10718 uint32_t pipe, snd_una; in rack_update_prr() local
10722 if (sbavail(&rack->rc_inp->inp_socket->so_snd) <= (tp->snd_max - tp->snd_una)) { in rack_update_prr()
10733 if (SEQ_GT(tp->snd_una, th_ack)) { in rack_update_prr()
10734 snd_una = tp->snd_una; in rack_update_prr()
10736 snd_una = th_ack; in rack_update_prr()
10738 pipe = do_rack_compute_pipe(tp, rack, snd_una); in rack_update_prr()
10815 if (SEQ_GT(th_ack, tp->snd_una)) { in rack_log_ack()
10839 if (SEQ_GT(th_ack, tp->snd_una)) in rack_log_ack()
10842 ack_point = tp->snd_una; in rack_log_ack()
11133 if (tp->snd_max == tp->snd_una) { in rack_check_bottom_drag()
11551 gating_val = min((sbavail(&so->so_snd) - (tp->snd_max - tp->snd_una)), in rack_gain_for_fastoutput()
11552 (tp->snd_wnd - (tp->snd_max - tp->snd_una))); in rack_gain_for_fastoutput()
11557 …tl.fsb.left_to_send <= (sbavail(&rack->rc_inp->inp_socket->so_snd) - (tp->snd_max - tp->snd_una))), in rack_gain_for_fastoutput()
11561 (tp->snd_max - tp->snd_una))); in rack_gain_for_fastoutput()
11595 tcp_seq snd_una; in rack_adjust_sendmap_head() local
11600 snd_una = rack->rc_tp->snd_una; in rack_adjust_sendmap_head()
11618 tm = sbsndmbuf(sb, (rsm->r_start - snd_una), &soff); in rack_adjust_sendmap_head()
11648 rsm->m = sbsndmbuf(sb, (rsm->r_start - snd_una), &rsm->soff); in rack_adjust_sendmap_head()
11772 if (SEQ_GEQ(tp->snd_una, tp->iss + (65535 << tp->snd_scale))) { in rack_process_ack()
11782 seq_min = tp->snd_una - tp->max_sndwnd; in rack_process_ack()
11785 if (SEQ_GT(tp->iss + 1, tp->snd_una - tp->max_sndwnd)) { in rack_process_ack()
11794 seq_min = tp->snd_una - tp->max_sndwnd; in rack_process_ack()
11818 if (SEQ_GEQ(th->th_ack, tp->snd_una) || to->to_nsacks) { in rack_process_ack()
11829 if ((th->th_ack == tp->snd_una) && in rack_process_ack()
11840 if (__predict_false(SEQ_LEQ(th->th_ack, tp->snd_una))) { in rack_process_ack()
11846 if (SEQ_LT(th->th_ack, tp->snd_una) && (sbspace(&so->so_rcv) > ctf_fixed_maxseg(tp))) { in rack_process_ack()
11865 tp->snd_una++; in rack_process_ack()
11992 tp->snd_una = th->th_ack; in rack_process_ack()
12000 if (SEQ_GT(tp->snd_una, tp->snd_recover)) in rack_process_ack()
12001 tp->snd_recover = tp->snd_una; in rack_process_ack()
12014 if (tp->snd_una == tp->snd_max) { in rack_process_ack()
12028 sack_filter_clear(&rack->r_ctl.rack_sf, tp->snd_una); in rack_process_ack()
12281 ((tp->snd_max == tp->snd_una) || rack->rc_has_collapsed) && in rack_process_data()
12290 rack_enter_persist(tp, rack, rack->r_ctl.rc_rcvtime, tp->snd_una); in rack_process_data()
12506 (sbavail(&so->so_snd) > (tp->snd_max - tp->snd_una))) { in rack_process_data()
12547 if (__predict_false((th->th_ack != tp->snd_una))) { in rack_do_fastnewdata()
12630 if (tp->snd_una == tp->snd_max) in rack_do_fastnewdata()
12631 sack_filter_clear(&rack->r_ctl.rack_sf, tp->snd_una); in rack_do_fastnewdata()
12654 if (__predict_false(SEQ_LEQ(th->th_ack, tp->snd_una))) { in rack_fastack()
12708 ((tp->snd_max == tp->snd_una) || rack->rc_has_collapsed) && in rack_fastack()
12765 tp->snd_una = th->th_ack; in rack_fastack()
12799 (SEQ_GT(tp->snd_una, rack->r_ctl.high_collapse_point))) in rack_fastack()
12824 if (tp->snd_una == tp->snd_max) { in rack_fastack()
12920 (tp->snd_una != tp->snd_max)) { in rack_do_syn_sent()
12940 if (SEQ_GT(th->th_ack, tp->snd_una)) { in rack_do_syn_sent()
12953 tp->snd_una++; in rack_do_syn_sent()
12954 if (tfo_partial && (SEQ_GT(tp->snd_max, tp->snd_una))) { in rack_do_syn_sent()
13090 (SEQ_LEQ(th->th_ack, tp->snd_una) || in rack_do_syn_recv()
13221 if (SEQ_GT(th->th_ack, tp->snd_una) && !(tp->t_flags & TF_NEEDSYN)) in rack_do_syn_recv()
13222 tp->snd_una++; in rack_do_syn_recv()
14255 (tp->snd_max == tp->snd_una)){ in rack_chg_query()
14415 if (tp->snd_una == tp->iss) { in rack_init_outstanding()
14419 rsm->r_end = rsm->r_start + (tp->snd_max - tp->snd_una); in rack_init_outstanding()
14421 rsm->r_start = tp->snd_una; in rack_init_outstanding()
14458 at = tp->snd_una; in rack_init_outstanding()
14481 rsm->r_fas = rsm->r_start - tp->snd_una; in rack_init_outstanding()
14494 (rsm->r_start - tp->snd_una), &rsm->soff); in rack_init_outstanding()
14704 if (tp->snd_una != 0) { in rack_init()
14858 (tp->snd_una != tp->snd_max)) { in rack_init()
15006 if ((tp->t_flags & TF_SENTFIN) && ((tp->snd_max - tp->snd_una) > 1)) { in rack_handoff_ok()
15243 (tp->snd_max == tp->snd_una)) { in rack_timer_audit()
15248 if (SEQ_GT(tp->snd_max, tp->snd_una) && in rack_timer_audit()
15327 ((tp->snd_max == tp->snd_una) || rack->rc_has_collapsed) && in rack_do_win_updates()
15357 if (SEQ_GT(ae->ack, tp->snd_una)) { in rack_log_input_packet()
15471 if (tp->snd_una != high_seq) { in rack_log_input_packet()
15472 orig_snd_una = tp->snd_una; in rack_log_input_packet()
15473 tp->snd_una = high_seq; in rack_log_input_packet()
15482 tp->snd_una = orig_snd_una; in rack_log_input_packet()
15725 if (SEQ_GT(tp->gput_seq, tp->snd_una)) in rack_do_compressed_ack_processing()
15726 bytes += tp->gput_seq - tp->snd_una; in rack_do_compressed_ack_processing()
15746 high_seq = tp->snd_una; in rack_do_compressed_ack_processing()
15833 (tp->snd_max == tp->snd_una) && in rack_do_compressed_ack_processing()
15866 if (SEQ_LT(ae->ack, tp->snd_una) && (sbspace(&so->so_rcv) > segsiz)) { in rack_do_compressed_ack_processing()
15972 acked_amount = acked = (high_seq - tp->snd_una); in rack_do_compressed_ack_processing()
16007 tp->snd_una++; in rack_do_compressed_ack_processing()
16008 acked_amount = acked = (high_seq - tp->snd_una); in rack_do_compressed_ack_processing()
16050 tp->snd_una = high_seq; in rack_do_compressed_ack_processing()
16084 tp->snd_una = high_seq; in rack_do_compressed_ack_processing()
16103 if (SEQ_GT(tp->snd_una, tp->snd_recover)) in rack_do_compressed_ack_processing()
16104 tp->snd_recover = tp->snd_una; in rack_do_compressed_ack_processing()
16123 if (tp->snd_una == tp->snd_max) { in rack_do_compressed_ack_processing()
16137 sack_filter_clear(&rack->r_ctl.rack_sf, tp->snd_una); in rack_do_compressed_ack_processing()
16545 if (SEQ_GT(tp->gput_seq, tp->snd_una)) in rack_do_segment_nounlock()
16546 bytes += tp->gput_seq - tp->snd_una; in rack_do_segment_nounlock()
16566 if (SEQ_GT(th->th_ack, tp->snd_una)) { in rack_do_segment_nounlock()
16682 (tp->snd_max == tp->snd_una) && in rack_do_segment_nounlock()
16842 if (SEQ_GT(th->th_ack, tp->snd_una) && in rack_do_segment_nounlock()
16875 if ((tp->snd_una - tp->iss) > (ctf_fixed_maxseg(tp) * 10)) { in rack_do_segment_nounlock()
16943 if (SEQ_GEQ(tp->snd_una, rack->r_ctl.roundends) && in rack_do_segment_nounlock()
16950 rack_new_round_setup(tp, rack, tp->snd_una); in rack_do_segment_nounlock()
16954 (SEQ_GT(tp->snd_max, tp->snd_una) || in rack_do_segment_nounlock()
16959 if ((tp->snd_max == tp->snd_una) && in rack_do_segment_nounlock()
19029 (tp->snd_max - tp->snd_una))) { in rack_sndbuf_autoscale()
19187 sb_offset = tp->snd_max - tp->snd_una; in rack_fast_output()
19196 tp->snd_up = tp->snd_una; /* drag it along, its deprecated */ in rack_fast_output()
19446 rack->r_ctl.lt_seq = tp->snd_una; in rack_fast_output()
19457 rack->r_ctl.lt_bw_bytes += (tp->snd_una - rack->r_ctl.lt_seq); in rack_fast_output()
19458 rack->r_ctl.lt_seq = tp->snd_una; in rack_fast_output()
19467 if (tp->snd_una == tp->snd_max) { in rack_fast_output()
19551 rack->r_ctl.fsb.m = sbsndmbuf(sb, (tp->snd_max - tp->snd_una), &rack->r_ctl.fsb.off); in rack_setup_fast_output()
19568 KASSERT((rack->r_ctl.fsb.left_to_send <= (sbavail(sb) - (tp->snd_max - tp->snd_una))), in rack_setup_fast_output()
19571 (tp->snd_max - tp->snd_una))); in rack_setup_fast_output()
19575 if (rack->r_ctl.fsb.left_to_send == (sbavail(sb) - (tp->snd_max - tp->snd_una))) in rack_setup_fast_output()
19608 if (rsm->r_end > (rack->rc_tp->snd_una + rack->rc_tp->snd_wnd)) { in rack_check_collapsed()
19771 SEQ_GT(tp->snd_max, tp->snd_una) && /* initial SYN|ACK sent */ in rack_output()
19934 SEQ_GT(tp->snd_max, tp->snd_una) && /* initial SYN or SYN|ACK sent */ in rack_output()
19948 idle = (tp->t_flags & TF_LASTIDLE) || (tp->snd_max == tp->snd_una); in rack_output()
19960 if ((tp->snd_una == tp->snd_max) && in rack_output()
20067 sb_offset = tp->snd_max - tp->snd_una; in rack_output()
20100 KASSERT(SEQ_LEQ(tp->snd_una, rsm->r_start), in rack_output()
20103 rsm->r_start, tp->snd_una, tp, rack, rsm)); in rack_output()
20104 sb_offset = rsm->r_start - tp->snd_una; in rack_output()
20123 sb_offset = rsm->r_start - tp->snd_una; in rack_output()
20132 rack_cong_signal(tp, CC_NDUPACK, tp->snd_una, __LINE__); in rack_output()
20135 if (SEQ_LT(rsm->r_start, tp->snd_una)) { in rack_output()
20137 tp, rack, rsm, rsm->r_start, tp->snd_una); in rack_output()
20141 KASSERT(SEQ_LEQ(tp->snd_una, rsm->r_start), in rack_output()
20144 rsm->r_start, tp->snd_una, tp, rack, rsm)); in rack_output()
20145 sb_offset = rsm->r_start - tp->snd_una; in rack_output()
20173 KASSERT(SEQ_LEQ(tp->snd_una, rsm->r_start), in rack_output()
20176 rsm->r_start, tp->snd_una, tp, rack, rsm)); in rack_output()
20177 sb_offset = rsm->r_start - tp->snd_una; in rack_output()
20183 (SEQ_GT(tp->snd_max, tp->snd_una)) && in rack_output()
20238 sb_offset = rsm->r_start - tp->snd_una; in rack_output()
20360 if (SEQ_GT(tp->snd_max, tp->snd_una) && avail) in rack_output()
20361 sb_offset = tp->snd_max - tp->snd_una; in rack_output()
20414 outstanding = tp->snd_max - tp->snd_una; in rack_output()
20492 SEQ_GT(tp->snd_max, tp->snd_una) && in rack_output()
20549 (tp->snd_una == tp->snd_max) && in rack_output()
20551 rack_enter_persist(tp, rack, cts, tp->snd_una); in rack_output()
20574 if (tp->snd_max == tp->snd_una) { in rack_output()
20579 rack_enter_persist(tp, rack, cts, tp->snd_una); in rack_output()
20691 outstanding = tp->snd_max - tp->snd_una; in rack_output()
20734 if ((tp->snd_una == tp->snd_max) && len) { /* Nothing outstanding */ in rack_output()
20849 (tp->snd_max == tp->snd_una)) { in rack_output()
20865 (sbused(sb) == (tp->snd_max - tp->snd_una)) && in rack_output()
20866 ((tp->snd_max - tp->snd_una) <= segsiz)) { in rack_output()
21057 if ((tp->snd_max == tp->snd_una) && in rack_output()
21063 rack_enter_persist(tp, rack, rack->r_ctl.rc_rcvtime, tp->snd_una); in rack_output()
21129 (sbused(sb) == (tp->snd_max - tp->snd_una)) && in rack_output()
21130 ((tp->snd_max - tp->snd_una) <= segsiz)) { in rack_output()
21280 (tp->snd_una == tp->snd_max) && in rack_output()
21467 if ((sbused(sb) == (tp->snd_max - tp->snd_una)) && in rack_output()
21468 ((tp->snd_max - tp->snd_una) <= segsiz)) { in rack_output()
21767 tp->snd_up = tp->snd_una; /* drag it along, its deprecated */ in rack_output()
22094 rack->r_ctl.lt_seq = tp->snd_una; in rack_output()
22103 rack->r_ctl.lt_bw_bytes += (tp->snd_una - rack->r_ctl.lt_seq); in rack_output()
22104 rack->r_ctl.lt_seq = tp->snd_una; in rack_output()
22176 (tp->snd_una == tp->snd_max)) in rack_output()
22217 if ((tp->snd_una == tp->snd_max) && (len > 0)) { in rack_output()
22275 rack->r_ctl.fsb.m = sbsndmbuf(sb, (tp->snd_max - tp->snd_una), &rack->r_ctl.fsb.off); in rack_output()
22296 sb_offset = tp->snd_max - tp->snd_una; in rack_output()
22315 sb_offset = tp->snd_max - tp->snd_una; in rack_output()
22631 sack_filter_clear(&rack->r_ctl.rack_sf, tp->snd_una); in rack_mtu_change()
22845 seq = rack->rc_tp->snd_una + rack->rc_tp->t_inpcb.inp_socket->so_snd.sb_ccc; in process_hybrid_pacing()