Lines Matching defs:snd_una
610 bytes += (rack->rc_tp->snd_una - rack->r_ctl.lt_seq);
2295 if (SEQ_GT(ent->end_seq, rack->rc_tp->snd_una))
2296 lenleft = ent->end_seq - rack->rc_tp->snd_una;
2310 if (SEQ_GT(rack->rc_tp->snd_una, ent->start_seq))
2311 lengone = rack->rc_tp->snd_una - ent->start_seq;
3629 if ((tp->snd_max == tp->snd_una) ||
4226 if (rack->rc_tp->snd_max == rack->rc_tp->snd_una) {
4231 SEQ_GT(rack->rc_tp->snd_una, rack->rc_tp->gput_seq)) {
4240 rack->rc_tp->snd_una, __LINE__,
4269 SEQ_GT(rack->rc_tp->snd_una, rack->rc_tp->gput_seq)) {
4278 rack->rc_tp->snd_una, __LINE__,
4836 if (tp->snd_una == tp->snd_max) {
4840 if (SEQ_GT(tp->gput_seq, tp->snd_una)) {
5493 acked = tp->t_ccv.bytes_this_ack = (th_ack - tp->snd_una);
5711 tp->snd_recover = tp->snd_una;
5761 rack->r_ctl.rc_prr_recovery_fs = tp->snd_max - tp->snd_una;
6024 if (((tp->snd_max - tp->snd_una) - rack->r_ctl.rc_sacked + rack->r_ctl.rc_holes_rxt) <= segsiz) {
6143 rack_cong_signal(tp, CC_NDUPACK, tp->snd_una, __LINE__);
6215 if (SEQ_LT(tp->snd_una, tp->snd_max) ||
6263 ((tp->snd_max - tp->snd_una) == 1) &&
6391 rack_enter_persist(struct tcpcb *tp, struct tcp_rack *rack, uint32_t cts, tcp_seq snd_una)
6399 rack_do_goodput_measurement(tp, rack, tp->snd_una, __LINE__,
6415 rack->r_ctl.lt_bw_bytes += (snd_una - rack->r_ctl.lt_seq);
6416 rack->r_ctl.lt_seq = snd_una;
6720 * or sack) and that changes things (rw, or snd_una etc).
6860 if (SEQ_GT(tp->snd_max, tp->snd_una)) {
7022 (src_rsm->r_start - rack->rc_tp->snd_una),
7027 (rsm->r_start - rack->rc_tp->snd_una),
7211 out = tp->snd_max - tp->snd_una;
7306 if (SEQ_GT((rack->r_ctl.last_collapse_point - 1), rack->rc_tp->snd_una))
7394 rack->rc_tp->rcv_nxt, rack->rc_tp->snd_una - 1, 0);
7447 tp->snd_una == tp->snd_max)
7509 * number tp->snd_una-1 causes the transmitted zero-length
7544 rack->r_ctl.rc_last_timeout_snduna = tp->snd_una;
7724 (tp->snd_una == tp->snd_max)) {
7950 sack_filter_clear(&rack->r_ctl.rack_sf, tp->snd_una);
7954 rack_cong_signal(tp, CC_RTO, tp->snd_una, __LINE__);
7976 if (SEQ_GT(tp->gput_seq, tp->snd_una))
7977 bytes += tp->gput_seq - tp->snd_una;
8082 ((tp->snd_max - tp->snd_una) == 0))) {
8086 if ((tp->snd_max - tp->snd_una) == 0)
8300 register uint32_t snd_max, snd_una;
8339 snd_una = tp->snd_una;
8353 if (SEQ_LEQ((seq_out + len), snd_una)) {
8357 if (SEQ_LT(seq_out, snd_una)) {
8362 seq_out = snd_una;
8400 /* The data space is one beyond snd_una */
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);
9517 rack_need_set_test(tp, rack, nrsm, tp->snd_una, __LINE__, RACK_USE_END);
9712 rack_need_set_test(tp, rack, rsm, tp->snd_una, __LINE__, RACK_USE_END);
9876 rack_need_set_test(tp, rack, nrsm, tp->snd_una, __LINE__, RACK_USE_END);
10006 rack_need_set_test(tp, rack, rsm, tp->snd_una, __LINE__, RACK_USE_END);
10248 if (SEQ_GT(th_ack, tp->snd_una)) {
10253 if (SEQ_GT(th_ack, tp->snd_una))
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);
10473 * The peer has moved snd_una up to
10479 * given us snd_una up to (rsm->r_end).
10484 * where th_ack is behind snd_una.
10568 * At this point snd_una has not been updated with the sbcut() yet
10575 (rsm->r_start - tp->snd_una),
10591 rack_need_set_test(tp, rack, rsm, tp->snd_una, __LINE__, RACK_USE_BEG);
10627 tp->snd_recover = tp->snd_una;
10720 do_rack_compute_pipe(struct tcpcb *tp, struct tcp_rack *rack, uint32_t snd_una)
10722 return (((tp->snd_max - snd_una) -
10731 tp->snd_una));
10738 uint32_t pipe, snd_una;
10742 if (sbavail(&rack->rc_inp->inp_socket->so_snd) <= (tp->snd_max - tp->snd_una)) {
10746 * Note we use tp->snd_una here and not th_ack because
10753 if (SEQ_GT(tp->snd_una, th_ack)) {
10754 snd_una = tp->snd_una;
10756 snd_una = th_ack;
10758 pipe = do_rack_compute_pipe(tp, rack, snd_una);
10835 if (SEQ_GT(th_ack, tp->snd_una)) {
10859 if (SEQ_GT(th_ack, tp->snd_una))
10862 ack_point = tp->snd_una;
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)));
11594 * 2) snd_una adjusted to its new position.
11615 tcp_seq snd_una;
11620 snd_una = rack->rc_tp->snd_una;
11638 tm = sbsndmbuf(sb, (rsm->r_start - snd_una), &soff);
11668 rsm->m = sbsndmbuf(sb, (rsm->r_start - snd_una), &rsm->soff);
11792 if (SEQ_GEQ(tp->snd_una, tp->iss + (65535 << tp->snd_scale))) {
11802 seq_min = tp->snd_una - tp->max_sndwnd;
11805 if (SEQ_GT(tp->iss + 1, tp->snd_una - tp->max_sndwnd)) {
11814 seq_min = tp->snd_una - tp->max_sndwnd;
11838 if (SEQ_GEQ(th->th_ack, tp->snd_una) || to->to_nsacks) {
11849 if ((th->th_ack == tp->snd_una) &&
11860 if (__predict_false(SEQ_LEQ(th->th_ack, tp->snd_una))) {
11866 if (SEQ_LT(th->th_ack, tp->snd_una) && (sbspace(&so->so_rcv) > ctf_fixed_maxseg(tp))) {
11881 * to non-starred state, increment snd_una for ACK of SYN,
11885 tp->snd_una++;
12012 tp->snd_una = th->th_ack;
12020 if (SEQ_GT(tp->snd_una, tp->snd_recover))
12021 tp->snd_recover = tp->snd_una;
12034 if (tp->snd_una == tp->snd_max) {
12048 sack_filter_clear(&rack->r_ctl.rack_sf, tp->snd_una);
12301 ((tp->snd_max == tp->snd_una) || rack->rc_has_collapsed) &&
12310 rack_enter_persist(tp, rack, rack->r_ctl.rc_rcvtime, tp->snd_una);
12526 (sbavail(&so->so_snd) > (tp->snd_max - tp->snd_una))) {
12567 if (__predict_false((th->th_ack != tp->snd_una))) {
12650 if (tp->snd_una == tp->snd_max)
12651 sack_filter_clear(&rack->r_ctl.rack_sf, tp->snd_una);
12674 if (__predict_false(SEQ_LEQ(th->th_ack, tp->snd_una))) {
12728 ((tp->snd_max == tp->snd_una) || rack->rc_has_collapsed) &&
12785 tp->snd_una = th->th_ack;
12819 (SEQ_GT(tp->snd_una, rack->r_ctl.high_collapse_point)))
12844 if (tp->snd_una == tp->snd_max) {
12889 * tp->irs if seg contains ack then advance tp->snd_una if seg
12940 (tp->snd_una != tp->snd_max)) {
12960 if (SEQ_GT(th->th_ack, tp->snd_una)) {
12962 * We advance snd_una for the
12965 * snd_una we can't just call
12968 * will start at snd_una + 1 (one
12973 tp->snd_una++;
12974 if (tfo_partial && (SEQ_GT(tp->snd_max, tp->snd_una))) {
13110 (SEQ_LEQ(th->th_ack, tp->snd_una) ||
13241 if (SEQ_GT(th->th_ack, tp->snd_una) && !(tp->t_flags & TF_NEEDSYN))
13242 tp->snd_una++;
14275 (tp->snd_max == tp->snd_una)){
14435 if (tp->snd_una == tp->iss) {
14436 /* The data space is one beyond snd_una */
14439 rsm->r_end = rsm->r_start + (tp->snd_max - tp->snd_una);
14441 rsm->r_start = tp->snd_una;
14478 at = tp->snd_una;
14501 rsm->r_fas = rsm->r_start - tp->snd_una;
14514 (rsm->r_start - tp->snd_una), &rsm->soff);
14728 if (tp->snd_una != 0) {
14738 * snd_una/max are set yet so we have
14882 (tp->snd_una != tp->snd_max)) {
15030 if ((tp->t_flags & TF_SENTFIN) && ((tp->snd_max - tp->snd_una) > 1)) {
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) &&
15381 if (SEQ_GT(ae->ack, tp->snd_una)) {
15488 * snd_una to high_seq, but since compressed acks are
15489 * processed in two phases, at this point (logging) snd_una
15492 * snd_una was advanced and then un-advancing it so that the
15495 if (tp->snd_una != high_seq) {
15496 orig_snd_una = tp->snd_una;
15497 tp->snd_una = high_seq;
15506 tp->snd_una = orig_snd_una;
15749 if (SEQ_GT(tp->gput_seq, tp->snd_una))
15750 bytes += tp->gput_seq - tp->snd_una;
15770 high_seq = tp->snd_una;
15857 (tp->snd_max == tp->snd_una) &&
15890 if (SEQ_LT(ae->ack, tp->snd_una) && (sbspace(&so->so_rcv) > segsiz)) {
15996 acked_amount = acked = (high_seq - tp->snd_una);
16027 * to non-starred state, increment snd_una for ACK of SYN,
16031 tp->snd_una++;
16032 acked_amount = acked = (high_seq - tp->snd_una);
16070 * Lets make sure snd_una is updated
16074 tp->snd_una = high_seq;
16108 tp->snd_una = high_seq;
16127 if (SEQ_GT(tp->snd_una, tp->snd_recover))
16128 tp->snd_recover = tp->snd_una;
16147 if (tp->snd_una == tp->snd_max) {
16161 sack_filter_clear(&rack->r_ctl.rack_sf, tp->snd_una);
16569 if (SEQ_GT(tp->gput_seq, tp->snd_una))
16570 bytes += tp->gput_seq - tp->snd_una;
16590 if (SEQ_GT(th->th_ack, tp->snd_una)) {
16706 (tp->snd_max == tp->snd_una) &&
16866 if (SEQ_GT(th->th_ack, tp->snd_una) &&
16899 if ((tp->snd_una - tp->iss) > (ctf_fixed_maxseg(tp) * 10)) {
16967 if (SEQ_GEQ(tp->snd_una, rack->r_ctl.roundends) &&
16974 rack_new_round_setup(tp, rack, tp->snd_una);
16978 (SEQ_GT(tp->snd_max, tp->snd_una) ||
16983 if ((tp->snd_max == tp->snd_una) &&
19051 (tp->snd_max - tp->snd_una))) {
19209 sb_offset = tp->snd_max - tp->snd_una;
19218 tp->snd_up = tp->snd_una; /* drag it along, its deprecated */
19468 rack->r_ctl.lt_seq = tp->snd_una;
19479 rack->r_ctl.lt_bw_bytes += (tp->snd_una - rack->r_ctl.lt_seq);
19480 rack->r_ctl.lt_seq = tp->snd_una;
19489 if (tp->snd_una == 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)))
19633 if (rsm->r_end > (rack->rc_tp->snd_una + rack->rc_tp->snd_wnd)) {
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;
20117 KASSERT(SEQ_LEQ(tp->snd_una, rsm->r_start),
20120 rsm->r_start, tp->snd_una, tp, rack, rsm));
20121 sb_offset = rsm->r_start - tp->snd_una;
20140 sb_offset = rsm->r_start - tp->snd_una;
20149 rack_cong_signal(tp, CC_NDUPACK, tp->snd_una, __LINE__);
20152 if (SEQ_LT(rsm->r_start, tp->snd_una)) {
20153 panic("Huh, tp:%p rack:%p rsm:%p start:%u < snd_una:%u\n",
20154 tp, rack, rsm, rsm->r_start, tp->snd_una);
20158 KASSERT(SEQ_LEQ(tp->snd_una, rsm->r_start),
20161 rsm->r_start, tp->snd_una, tp, rack, rsm));
20162 sb_offset = rsm->r_start - tp->snd_una;
20190 KASSERT(SEQ_LEQ(tp->snd_una, rsm->r_start),
20193 rsm->r_start, tp->snd_una, tp, rack, rsm));
20194 sb_offset = rsm->r_start - tp->snd_una;
20200 (SEQ_GT(tp->snd_max, tp->snd_una)) &&
20255 sb_offset = rsm->r_start - tp->snd_una;
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) &&
20568 rack_enter_persist(tp, rack, cts, tp->snd_una);
20591 if (tp->snd_max == tp->snd_una) {
20596 rack_enter_persist(tp, rack, cts, tp->snd_una);
20708 outstanding = tp->snd_max - tp->snd_una;
20712 * snd_una
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)) {
21073 if ((tp->snd_max == tp->snd_una) &&
21079 rack_enter_persist(tp, rack, rack->r_ctl.rc_rcvtime, tp->snd_una);
21151 (sbused(sb) == (tp->snd_max - tp->snd_una)) &&
21152 ((tp->snd_max - tp->snd_una) <= segsiz)) {
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)) {
21795 tp->snd_up = tp->snd_una; /* drag it along, its deprecated */
22120 rack->r_ctl.lt_seq = tp->snd_una;
22129 rack->r_ctl.lt_bw_bytes += (tp->snd_una - rack->r_ctl.lt_seq);
22130 rack->r_ctl.lt_seq = tp->snd_una;
22203 (tp->snd_una == tp->snd_max))
22244 if ((tp->snd_una == tp->snd_max) && (len > 0)) {
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;
22668 sack_filter_clear(&rack->r_ctl.rack_sf, tp->snd_una);
22882 seq = rack->rc_tp->snd_una + rack->rc_tp->t_inpcb.inp_socket->so_snd.sb_ccc;
22888 /* The seq will be snd_una + everything in the buffer */