Lines Matching defs:snd_max
2274 rack_log_hybrid_bw(rack, rack->rc_tp->snd_max,
2283 rack_log_hybrid_bw(rack, rack->rc_tp->snd_max,
2299 rack_log_hybrid_bw(rack, rack->rc_tp->snd_max,
2318 rack_log_hybrid_bw(rack, rack->rc_tp->snd_max,
2326 rack_log_hybrid_bw(rack, rack->rc_tp->snd_max,
2350 rack_log_hybrid_bw(rack, rack->rc_tp->snd_max,
2353 rack_log_hybrid_bw(rack, rack->rc_tp->snd_max,
2381 rack_log_hybrid_bw(rack, rack->rc_tp->snd_max,
3629 if ((tp->snd_max == tp->snd_una) ||
3630 (th_ack == tp->snd_max)){
4226 if (rack->rc_tp->snd_max == rack->rc_tp->snd_una) {
4290 * Measurements through the current snd_max are going
4422 rack->r_ctl.rc_probertt_sndmax_atexit = rack->rc_tp->snd_max;
4836 if (tp->snd_una == tp->snd_max) {
5506 if ((th_ack == tp->snd_max) && rack->lt_bw_up) {
5515 rack->r_ctl.lt_bw_bytes += (tp->snd_max - rack->r_ctl.lt_seq);
5516 rack->r_ctl.lt_seq = tp->snd_max;
5761 rack->r_ctl.rc_prr_recovery_fs = tp->snd_max - tp->snd_una;
5762 tp->snd_recover = tp->snd_max;
5777 tp->snd_recover = tp->snd_max + 1;
5814 tp->snd_nxt = tp->snd_max;
6024 if (((tp->snd_max - tp->snd_una) - rack->r_ctl.rc_sacked + rack->r_ctl.rc_holes_rxt) <= segsiz) {
6215 if (SEQ_LT(tp->snd_una, tp->snd_max) ||
6263 ((tp->snd_max - tp->snd_una) == 1) &&
6860 if (SEQ_GT(tp->snd_max, tp->snd_una)) {
7211 out = tp->snd_max - tp->snd_una;
7447 tp->snd_una == tp->snd_max)
7543 rack->r_ctl.rc_snd_max_at_rto = tp->snd_max;
7616 * we retransmit up to snd_max.
7724 (tp->snd_una == tp->snd_max)) {
7951 tp->snd_recover = tp->snd_max;
8082 ((tp->snd_max - tp->snd_una) == 0))) {
8086 if ((tp->snd_max - tp->snd_una) == 0)
8173 * in snduna <->snd_max.
8300 register uint32_t snd_max, snd_una;
8326 * We don't log errors -- we could but snd_max does not
8340 snd_max = tp->snd_max;
8344 * snd_max. This means we can record one extra byte on a SYN
8376 if (seq_out == snd_max) {
8416 * reflected in in snduna <->snd_max
8563 if (seq_out == tp->snd_max) {
8565 } else if (SEQ_LT(seq_out, tp->snd_max)) {
8567 printf("seq_out:%u len:%d snd_una:%u snd_max:%u -- but rsm not found?\n",
8568 seq_out, len, tp->snd_una, tp->snd_max);
8584 panic("seq_out:%u(%d) is beyond snd_max:%u tp:%p",
8585 seq_out, len, tp->snd_max, tp);
9248 if (SEQ_LT(tp->gput_seq, tp->snd_max))
10321 panic("No rack map tp:%p for state:%d ack:%u rack:%p snd_una:%u snd_max:%u\n",
10324 tp->snd_una, tp->snd_max);
10692 rack->r_ctl.dsack_round_end = rack->rc_tp->snd_max;
10722 return (((tp->snd_max - snd_una) -
10742 if (sbavail(&rack->rc_inp->inp_socket->so_snd) <= (tp->snd_max - tp->snd_una)) {
10870 SEQ_LT(sack.start, tp->snd_max) &&
10872 SEQ_LEQ(sack.end, tp->snd_max)) {
11153 if (tp->snd_max == tp->snd_una) {
11571 gating_val = min((sbavail(&so->so_snd) - (tp->snd_max - tp->snd_una)),
11572 (tp->snd_wnd - (tp->snd_max - tp->snd_una)));
11577 KASSERT((rack->r_ctl.fsb.left_to_send <= (sbavail(&rack->rc_inp->inp_socket->so_snd) - (tp->snd_max - tp->snd_una))),
11581 (tp->snd_max - tp->snd_una)));
11829 if (SEQ_GT(th->th_ack, tp->snd_max)) {
11961 (SEQ_LT(th->th_ack, tp->snd_max))) {
12023 if (SEQ_LT(tp->snd_nxt, tp->snd_max)) {
12024 tp->snd_nxt = tp->snd_max;
12034 if (tp->snd_una == tp->snd_max) {
12119 rack->r_ctl.high_collapse_point = rack->rc_tp->snd_max;
12293 tp->snd_nxt = tp->snd_max;
12301 ((tp->snd_max == tp->snd_una) || rack->rc_has_collapsed) &&
12526 (sbavail(&so->so_snd) > (tp->snd_max - tp->snd_una))) {
12650 if (tp->snd_una == tp->snd_max)
12678 if (__predict_false(SEQ_GT(th->th_ack, tp->snd_max))) {
12728 ((tp->snd_max == tp->snd_una) || rack->rc_has_collapsed) &&
12844 if (tp->snd_una == tp->snd_max) {
12897 SEQ_GT(th->th_ack, tp->snd_max))) {
12940 (tp->snd_una != tp->snd_max)) {
12942 if (SEQ_LT(th->th_ack, tp->snd_max))
12974 if (tfo_partial && (SEQ_GT(tp->snd_max, tp->snd_una))) {
13111 SEQ_GT(th->th_ack, tp->snd_max))) {
14181 log.u_bbr.flex4 = tp->snd_max;
14198 rack->r_ctl.roundends = tp->snd_max;
14274 if ((reqr->req_param == tp->snd_max) ||
14275 (tp->snd_max == tp->snd_una)){
14434 rsm->r_end = tp->snd_max;
14439 rsm->r_end = rsm->r_start + (tp->snd_max - tp->snd_una);
14479 while (at != tp->snd_max) {
14834 if (SEQ_GT(tp->snd_max, tp->iss))
14835 snt = tp->snd_max - tp->iss;
14882 (tp->snd_una != tp->snd_max)) {
15030 if ((tp->t_flags & TF_SENTFIN) && ((tp->snd_max - tp->snd_una) > 1)) {
15169 tp->snd_nxt = tp->snd_max;
15267 (tp->snd_max == tp->snd_una)) {
15272 if (SEQ_GT(tp->snd_max, tp->snd_una) &&
15351 ((tp->snd_max == tp->snd_una) || rack->rc_has_collapsed) &&
15575 rack->r_ctl.roundends = tp->snd_max;
15577 rack_log_hystart_event(rack, tp->snd_max, 4);
15857 (tp->snd_max == tp->snd_una) &&
15921 if (SEQ_GT(ae->ack, tp->snd_max)) {
15988 if (SEQ_GT(tp->snd_max, high_seq) && (tp->snd_wnd < (tp->snd_max - high_seq))) {
15990 rack_collapsed_window(rack, (tp->snd_max - high_seq), high_seq, __LINE__);
16041 (SEQ_LT(high_seq, tp->snd_max))) {
16129 if (SEQ_LT(tp->snd_nxt, tp->snd_max))
16130 tp->snd_nxt = tp->snd_max;
16147 if (tp->snd_una == tp->snd_max) {
16678 (SEQ_LEQ(th->th_ack, tp->iss) || SEQ_GT(th->th_ack, tp->snd_max))) {
16706 (tp->snd_max == tp->snd_una) &&
16978 (SEQ_GT(tp->snd_max, tp->snd_una) ||
16983 if ((tp->snd_max == tp->snd_una) &&
17434 rack_log_hybrid_bw(rack, rack->rc_tp->snd_max,
18921 /* Move snd_nxt to snd_max so we don't have false retransmissions */
18922 tp->snd_nxt = tp->snd_max;
19051 (tp->snd_max - tp->snd_una))) {
19123 startseq = tp->snd_max;
19209 sb_offset = tp->snd_max - tp->snd_una;
19210 th->th_seq = htonl(tp->snd_max);
19471 (((tp->snd_max + len) - rack->r_ctl.lt_seq) > 0x7fffffff)) {
19487 rack_log_output(tp, &to, len, tp->snd_max, flags, error, rack_to_usec_ts(tv),
19489 if (tp->snd_una == tp->snd_max) {
19500 rack_start_gp_measurement(tp, rack, tp->snd_max, sb_offset);
19501 tp->snd_max += len;
19502 tp->snd_nxt = tp->snd_max;
19504 rack_new_round_starts(tp, rack, tp->snd_max);
19576 rack->r_ctl.fsb.m = sbsndmbuf(sb, (tp->snd_max - tp->snd_una), &rack->r_ctl.fsb.off);
19593 KASSERT((rack->r_ctl.fsb.left_to_send <= (sbavail(sb) - (tp->snd_max - tp->snd_una))),
19596 (tp->snd_max - tp->snd_una)));
19600 if (rack->r_ctl.fsb.left_to_send == (sbavail(sb) - (tp->snd_max - tp->snd_una)))
19796 SEQ_GT(tp->snd_max, tp->snd_una) && /* initial SYN|ACK sent */
19945 SEQ_GT(tp->snd_max, tp->snd_una) && /* initial SYN or SYN|ACK sent */
19959 idle = (tp->t_flags & TF_LASTIDLE) || (tp->snd_max == tp->snd_una);
19971 if ((tp->snd_una == tp->snd_max) &&
20084 sb_offset = tp->snd_max - tp->snd_una;
20200 (SEQ_GT(tp->snd_max, tp->snd_una)) &&
20370 * are sending new data. This is always based on snd_max.
20371 * Now in theory snd_max may be equal to snd_una, if so
20377 if (SEQ_GT(tp->snd_max, tp->snd_una) && avail)
20378 sb_offset = tp->snd_max - tp->snd_una;
20431 outstanding = tp->snd_max - tp->snd_una;
20509 SEQ_GT(tp->snd_max, tp->snd_una) &&
20566 (tp->snd_una == tp->snd_max) &&
20591 if (tp->snd_max == tp->snd_una) {
20708 outstanding = tp->snd_max - tp->snd_una;
20711 * If we sent a fin, snd_max is 1 higher than
20751 if ((tp->snd_una == tp->snd_max) && len) { /* Nothing outstanding */
20866 (tp->snd_max == tp->snd_una)) {
20882 (sbused(sb) == (tp->snd_max - tp->snd_una)) &&
20883 ((tp->snd_max - tp->snd_una) <= segsiz)) {
20923 if (SEQ_GT(tp->snd_max, tp->snd_nxt))
20924 tp->snd_nxt = tp->snd_max;
21034 SEQ_GT(tp->gput_ack, tp->snd_max)) {
21035 tp->gput_ack = tp->snd_max;
21073 if ((tp->snd_max == tp->snd_una) &&
21151 (sbused(sb) == (tp->snd_max - tp->snd_una)) &&
21152 ((tp->snd_max - tp->snd_una) <= segsiz)) {
21211 * be snd_max-1 else its snd_max.
21218 rack_seq = tp->snd_max - 1;
21220 rack_seq = tp->snd_max;
21302 (tp->snd_una == tp->snd_max) &&
21490 if ((sbused(sb) == (tp->snd_max - tp->snd_una)) &&
21491 ((tp->snd_max - tp->snd_una) <= segsiz)) {
22104 * retransmit. In persist state, just set snd_max.
22203 (tp->snd_una == tp->snd_max))
22209 * It is used to advance snd_max if we have a new transmit.
22211 tcp_seq startseq = tp->snd_max;
22239 * If we are retransmitting we are done, snd_max
22244 if ((tp->snd_una == tp->snd_max) && (len > 0)) {
22258 tp->snd_max++;
22263 tp->snd_max++;
22267 tp->snd_max += len;
22269 rack_new_round_starts(tp, rack, tp->snd_max);
22302 rack->r_ctl.fsb.m = sbsndmbuf(sb, (tp->snd_max - tp->snd_una), &rack->r_ctl.fsb.off);
22323 sb_offset = tp->snd_max - tp->snd_una;
22342 sb_offset = tp->snd_max - tp->snd_una;
22519 } else if (SEQ_GEQ(tp->snd_max, rack->r_ctl.rc_snd_max_at_rto)) {
22530 SEQ_GT(tp->snd_max, rack->r_ctl.rc_snd_max_at_rto)) {
22532 * We hit an RTO and now have past snd_max at the RTO
22598 if (SEQ_GT(tp->snd_max, tp->snd_nxt))
22599 tp->snd_nxt = tp->snd_max;
22661 rack->r_ctl.rc_snd_max_at_rto = tp->snd_max;
22670 tp->snd_nxt = tp->snd_max;