Lines Matching defs:tp1
2949 struct sctp_tmit_chunk *tp1;
2953 /* Recover the tp1 we last saw */
2954 tp1 = *p_tp1;
2955 if (tp1 == NULL) {
2956 tp1 = TAILQ_FIRST(&stcb->asoc.sent_queue);
2960 while (tp1) {
2961 if (tp1->rec.data.doing_fast_retransmit)
2972 if ((tp1->sent < SCTP_DATAGRAM_RESEND) &&
2973 (tp1->whoTo->find_pseudo_cumack == 1) &&
2974 (tp1->snd_count == 1)) {
2975 tp1->whoTo->pseudo_cumack = tp1->rec.data.tsn;
2976 tp1->whoTo->find_pseudo_cumack = 0;
2978 if ((tp1->sent < SCTP_DATAGRAM_RESEND) &&
2979 (tp1->whoTo->find_rtx_pseudo_cumack == 1) &&
2980 (tp1->snd_count > 1)) {
2981 tp1->whoTo->rtx_pseudo_cumack = tp1->rec.data.tsn;
2982 tp1->whoTo->find_rtx_pseudo_cumack = 0;
2984 if (tp1->rec.data.tsn == theTSN) {
2985 if (tp1->sent != SCTP_DATAGRAM_UNSENT) {
2990 if (tp1->sent < SCTP_DATAGRAM_RESEND) {
2998 if (SCTP_TSN_GT(tp1->rec.data.tsn,
3000 *biggest_newly_acked_tsn = tp1->rec.data.tsn;
3009 if (tp1->rec.data.chunk_was_revoked == 0)
3010 tp1->whoTo->saw_newack = 1;
3012 if (SCTP_TSN_GT(tp1->rec.data.tsn,
3013 tp1->whoTo->this_sack_highest_newack)) {
3014 tp1->whoTo->this_sack_highest_newack =
3015 tp1->rec.data.tsn;
3025 tp1->rec.data.tsn,
3030 *this_sack_lowest_newack = tp1->rec.data.tsn;
3040 if (tp1->rec.data.tsn == tp1->whoTo->pseudo_cumack) {
3041 if (tp1->rec.data.chunk_was_revoked == 0) {
3042 tp1->whoTo->new_pseudo_cumack = 1;
3044 tp1->whoTo->find_pseudo_cumack = 1;
3047 sctp_log_cwnd(stcb, tp1->whoTo, tp1->rec.data.tsn, SCTP_CWND_LOG_FROM_SACK);
3049 if (tp1->rec.data.tsn == tp1->whoTo->rtx_pseudo_cumack) {
3050 if (tp1->rec.data.chunk_was_revoked == 0) {
3051 tp1->whoTo->new_pseudo_cumack = 1;
3053 tp1->whoTo->find_rtx_pseudo_cumack = 1;
3058 tp1->rec.data.tsn,
3065 tp1->whoTo->flight_size,
3066 tp1->book_size,
3067 (uint32_t)(uintptr_t)tp1->whoTo,
3068 tp1->rec.data.tsn);
3070 sctp_flight_size_decrease(tp1);
3072 (*stcb->asoc.cc_functions.sctp_cwnd_update_tsn_acknowledged) (tp1->whoTo,
3073 tp1);
3075 sctp_total_flight_decrease(stcb, tp1);
3077 tp1->whoTo->net_ack += tp1->send_size;
3078 if (tp1->snd_count < 2) {
3082 tp1->whoTo->net_ack2 += tp1->send_size;
3087 if (tp1->do_rtt) {
3091 tp1->whoTo,
3092 &tp1->sent_rcv_time,
3096 if (tp1->whoTo->rto_needed == 0) {
3097 tp1->whoTo->rto_needed = 1;
3099 tp1->do_rtt = 0;
3103 if (tp1->sent <= SCTP_DATAGRAM_RESEND) {
3104 if (SCTP_TSN_GT(tp1->rec.data.tsn,
3107 tp1->rec.data.tsn;
3109 if (tp1->sent == SCTP_DATAGRAM_RESEND) {
3121 if ((tp1->sent != SCTP_FORWARD_TSN_SKIP) &&
3122 (tp1->sent != SCTP_DATAGRAM_NR_ACKED)) {
3123 tp1->sent = SCTP_DATAGRAM_MARKED;
3125 if (tp1->rec.data.chunk_was_revoked) {
3127 tp1->whoTo->cwnd -= tp1->book_size;
3128 tp1->rec.data.chunk_was_revoked = 0;
3132 (tp1->sent != SCTP_DATAGRAM_NR_ACKED)) {
3133 if (stcb->asoc.strmout[tp1->rec.data.sid].chunks_on_queues > 0) {
3134 stcb->asoc.strmout[tp1->rec.data.sid].chunks_on_queues--;
3137 panic("No chunks on the queues for sid %u.", tp1->rec.data.sid);
3140 if ((stcb->asoc.strmout[tp1->rec.data.sid].chunks_on_queues == 0) &&
3141 (stcb->asoc.strmout[tp1->rec.data.sid].state == SCTP_STREAM_RESET_PENDING) &&
3142 TAILQ_EMPTY(&stcb->asoc.strmout[tp1->rec.data.sid].outqueue)) {
3145 tp1->sent = SCTP_DATAGRAM_NR_ACKED;
3146 if (tp1->data) {
3151 sctp_free_bufspace(stcb, &stcb->asoc, tp1, 1);
3152 sctp_m_freem(tp1->data);
3153 tp1->data = NULL;
3159 } /* if (tp1->tsn == theTSN) */
3160 if (SCTP_TSN_GT(tp1->rec.data.tsn, theTSN)) {
3163 tp1 = TAILQ_NEXT(tp1, sctp_next);
3164 if ((tp1 == NULL) && (circled == 0)) {
3166 tp1 = TAILQ_FIRST(&stcb->asoc.sent_queue);
3168 } /* end while (tp1) */
3169 if (tp1 == NULL) {
3171 tp1 = TAILQ_FIRST(&stcb->asoc.sent_queue);
3175 *p_tp1 = tp1;
3186 struct sctp_tmit_chunk *tp1;
3193 tp1 = TAILQ_FIRST(&asoc->sent_queue);
3200 tp1 = TAILQ_FIRST(&asoc->sent_queue);
3217 tp1 = TAILQ_FIRST(&asoc->sent_queue);
3227 if (sctp_process_segment_range(stcb, &tp1, last_tsn, frag_strt, frag_end,
3248 struct sctp_tmit_chunk *tp1;
3250 TAILQ_FOREACH(tp1, &asoc->sent_queue, sctp_next) {
3251 if (SCTP_TSN_GT(tp1->rec.data.tsn, cumack)) {
3258 if (SCTP_TSN_GT(tp1->rec.data.tsn, biggest_tsn_acked)) {
3261 if (tp1->sent == SCTP_DATAGRAM_ACKED) {
3263 tp1->sent = SCTP_DATAGRAM_SENT;
3264 tp1->rec.data.chunk_was_revoked = 1;
3271 tp1->whoTo->flight_size,
3272 tp1->book_size,
3273 (uint32_t)(uintptr_t)tp1->whoTo,
3274 tp1->rec.data.tsn);
3276 sctp_flight_size_increase(tp1);
3277 sctp_total_flight_increase(stcb, tp1);
3282 tp1->whoTo->cwnd += tp1->book_size;
3286 tp1->rec.data.tsn,
3291 } else if (tp1->sent == SCTP_DATAGRAM_MARKED) {
3293 tp1->sent = SCTP_DATAGRAM_ACKED;
3296 if (tp1->sent == SCTP_DATAGRAM_UNSENT)
3305 struct sctp_tmit_chunk *tp1;
3317 tp1 = TAILQ_FIRST(&stcb->asoc.send_queue);
3318 if (tp1 == NULL) {
3321 sending_seq = tp1->rec.data.tsn;
3335 TAILQ_FOREACH(tp1, &asoc->sent_queue, sctp_next) {
3337 if (tp1->no_fr_allowed) {
3342 if (tp1->sent < SCTP_DATAGRAM_RESEND)
3344 tp1->rec.data.tsn,
3345 tp1->sent,
3348 if (SCTP_TSN_GT(tp1->rec.data.tsn, biggest_tsn_acked) ||
3349 tp1->sent == SCTP_DATAGRAM_UNSENT) {
3354 if ((PR_SCTP_TTL_ENABLED(tp1->flags)) && tp1->sent < SCTP_DATAGRAM_ACKED) {
3356 if (timevalcmp(&now, &tp1->rec.data.timetodrop, >)) {
3358 if (tp1->data != NULL) {
3359 (void)sctp_release_pr_sctp_chunk(stcb, tp1, 1,
3366 if (SCTP_TSN_GT(tp1->rec.data.tsn, asoc->this_sack_highest_gap) &&
3371 if (tp1->sent >= SCTP_DATAGRAM_RESEND) {
3374 if (tp1->sent == SCTP_FORWARD_TSN_SKIP) {
3376 tp1->rec.data.fwd_tsn_cnt++;
3383 if (tp1->whoTo && tp1->whoTo->saw_newack == 0) {
3391 } else if (tp1->whoTo &&
3392 SCTP_TSN_GT(tp1->rec.data.tsn,
3393 tp1->whoTo->this_sack_highest_newack) &&
3398 * sent after tp1. Therefore, according to the SFR
3399 * algo for CMT, tp1 cannot be marked for FR using
3423 tp1->rec.data.tsn,
3424 tp1->sent,
3427 if (tp1->sent < SCTP_DATAGRAM_RESEND) {
3428 tp1->sent++;
3437 * rtx'd, If not a mixed sack and if tp1 is
3444 if ((tp1->sent < SCTP_DATAGRAM_RESEND) && (num_dests_sacked == 1) &&
3445 SCTP_TSN_GT(this_sack_lowest_newack, tp1->rec.data.tsn)) {
3448 tp1->rec.data.tsn,
3449 tp1->sent,
3452 tp1->sent++;
3455 } else if ((tp1->rec.data.doing_fast_retransmit) &&
3477 tp1->rec.data.fast_retran_tsn)) {
3485 tp1->rec.data.tsn,
3486 tp1->sent,
3489 if (tp1->sent < SCTP_DATAGRAM_RESEND) {
3490 tp1->sent++;
3504 * if tp1 is not between two
3514 if ((tp1->sent < SCTP_DATAGRAM_RESEND) &&
3517 tp1->rec.data.tsn)) {
3520 tp1->rec.data.tsn,
3521 tp1->sent,
3524 if (tp1->sent < SCTP_DATAGRAM_RESEND) {
3525 tp1->sent++;
3535 } else if (SCTP_TSN_GT(tp1->rec.data.tsn,
3547 tp1->rec.data.tsn,
3548 tp1->sent,
3551 if (tp1->sent < SCTP_DATAGRAM_RESEND) {
3552 tp1->sent++;
3561 * rtx'd, If not a mixed sack and if tp1 is
3568 if ((tp1->sent < SCTP_DATAGRAM_RESEND) && (num_dests_sacked == 1) &&
3569 SCTP_TSN_GT(this_sack_lowest_newack, tp1->rec.data.tsn)) {
3572 tp1->rec.data.tsn,
3573 tp1->sent,
3576 tp1->sent++;
3580 if (tp1->sent == SCTP_DATAGRAM_RESEND) {
3586 (tp1->whoTo ? (tp1->whoTo->flight_size) : 0),
3587 tp1->book_size,
3588 (uint32_t)(uintptr_t)tp1->whoTo,
3589 tp1->rec.data.tsn);
3591 if (tp1->whoTo) {
3592 tp1->whoTo->net_ack++;
3593 sctp_flight_size_decrease(tp1);
3595 (*stcb->asoc.cc_functions.sctp_cwnd_update_tsn_acknowledged) (tp1->whoTo,
3596 tp1);
3602 asoc->peers_rwnd, tp1->send_size, SCTP_BASE_SYSCTL(sctp_peer_chunk_oh));
3605 asoc->peers_rwnd += (tp1->send_size + SCTP_BASE_SYSCTL(sctp_peer_chunk_oh));
3608 sctp_total_flight_decrease(stcb, tp1);
3611 (PR_SCTP_RTX_ENABLED(tp1->flags))) {
3616 if (tp1->snd_count > tp1->rec.data.timetodrop.tv_sec) {
3618 if (tp1->data != NULL) {
3619 (void)sctp_release_pr_sctp_chunk(stcb, tp1, 1,
3623 if (tp1->whoTo != NULL) {
3624 tp1->whoTo->net_ack++;
3634 sctp_log_fr(tp1->rec.data.tsn, tp1->snd_count,
3648 tp1->no_fr_allowed = 1;
3649 alt = tp1->whoTo;
3668 alt = tp1->whoTo;
3677 if (tp1->whoTo) {
3678 tp1->whoTo->find_pseudo_cumack = 1;
3679 tp1->whoTo->find_rtx_pseudo_cumack = 1;
3684 alt = sctp_find_alternate_net(stcb, tp1->whoTo, 0);
3691 alt = tp1->whoTo;
3695 tp1->rec.data.doing_fast_retransmit = 1;
3709 tp1->rec.data.fast_retran_tsn = sending_seq;
3722 tp1->rec.data.fast_retran_tsn =
3726 if (tp1->do_rtt) {
3731 if ((tp1->whoTo != NULL) &&
3732 (tp1->whoTo->rto_needed == 0)) {
3733 tp1->whoTo->rto_needed = 1;
3735 tp1->do_rtt = 0;
3737 if (alt != tp1->whoTo) {
3739 sctp_free_remote_addr(tp1->whoTo);
3741 tp1->whoTo = alt;
3752 struct sctp_tmit_chunk *tp1, *tp2, *a_adv = NULL;
3759 TAILQ_FOREACH_SAFE(tp1, &asoc->sent_queue, sctp_next, tp2) {
3760 if (tp1->sent != SCTP_FORWARD_TSN_SKIP &&
3761 tp1->sent != SCTP_DATAGRAM_RESEND &&
3762 tp1->sent != SCTP_DATAGRAM_NR_ACKED) {
3767 if ((tp1->sent == SCTP_FORWARD_TSN_SKIP) ||
3768 (tp1->sent == SCTP_DATAGRAM_NR_ACKED)) {
3771 tp1->rec.data.tsn, 0, 0);
3774 if (!PR_SCTP_ENABLED(tp1->flags)) {
3791 if (tp1->sent == SCTP_DATAGRAM_RESEND &&
3792 (PR_SCTP_TTL_ENABLED(tp1->flags))) {
3797 if (timevalcmp(&now, &tp1->rec.data.timetodrop, >)) {
3799 if (tp1->data) {
3800 (void)sctp_release_pr_sctp_chunk(stcb, tp1,
3816 if ((tp1->sent == SCTP_FORWARD_TSN_SKIP) ||
3817 (tp1->sent == SCTP_DATAGRAM_NR_ACKED)) {
3819 if (SCTP_TSN_GT(tp1->rec.data.tsn, asoc->advanced_peer_ack_point)) {
3820 asoc->advanced_peer_ack_point = tp1->rec.data.tsn;
3821 a_adv = tp1;
3822 } else if (tp1->rec.data.tsn == asoc->advanced_peer_ack_point) {
3824 a_adv = tp1;
3891 struct sctp_tmit_chunk *tp1)
3893 tp1->window_probe = 0;
3894 if ((tp1->sent >= SCTP_DATAGRAM_ACKED) || (tp1->data == NULL)) {
3897 tp1->whoTo ? tp1->whoTo->flight_size : 0,
3898 tp1->book_size,
3899 (uint32_t)(uintptr_t)tp1->whoTo,
3900 tp1->rec.data.tsn);
3905 (*stcb->asoc.cc_functions.sctp_cwnd_update_tsn_acknowledged) (tp1->whoTo,
3906 tp1);
3908 sctp_flight_size_decrease(tp1);
3909 sctp_total_flight_decrease(stcb, tp1);
3911 tp1->sent = SCTP_DATAGRAM_RESEND;
3916 tp1->whoTo->flight_size,
3917 tp1->book_size,
3918 (uint32_t)(uintptr_t)tp1->whoTo,
3919 tp1->rec.data.tsn);
3929 struct sctp_tmit_chunk *tp1, *tp2;
3989 tp1 = TAILQ_LAST(&asoc->sent_queue,
3991 send_s = tp1->rec.data.tsn + 1;
4020 TAILQ_FOREACH_SAFE(tp1, &asoc->sent_queue, sctp_next, tp2) {
4021 if (SCTP_TSN_GE(cumack, tp1->rec.data.tsn)) {
4022 if (tp1->sent == SCTP_DATAGRAM_UNSENT) {
4025 if (tp1->sent < SCTP_DATAGRAM_ACKED) {
4031 if (tp1->sent < SCTP_DATAGRAM_RESEND) {
4034 tp1->whoTo->flight_size,
4035 tp1->book_size,
4036 (uint32_t)(uintptr_t)tp1->whoTo,
4037 tp1->rec.data.tsn);
4039 sctp_flight_size_decrease(tp1);
4041 (*stcb->asoc.cc_functions.sctp_cwnd_update_tsn_acknowledged) (tp1->whoTo,
4042 tp1);
4045 sctp_total_flight_decrease(stcb, tp1);
4047 tp1->whoTo->net_ack += tp1->send_size;
4048 if (tp1->snd_count < 2) {
4053 tp1->whoTo->net_ack2 +=
4054 tp1->send_size;
4057 if (tp1->do_rtt) {
4061 tp1->whoTo,
4062 &tp1->sent_rcv_time,
4066 if (tp1->whoTo->rto_needed == 0) {
4067 tp1->whoTo->rto_needed = 1;
4069 tp1->do_rtt = 0;
4084 tp1->whoTo->new_pseudo_cumack = 1;
4085 tp1->whoTo->find_pseudo_cumack = 1;
4086 tp1->whoTo->find_rtx_pseudo_cumack = 1;
4089 sctp_log_cwnd(stcb, tp1->whoTo, tp1->rec.data.tsn, SCTP_CWND_LOG_FROM_SACK);
4092 if (tp1->sent == SCTP_DATAGRAM_RESEND) {
4095 if (tp1->rec.data.chunk_was_revoked) {
4097 tp1->whoTo->cwnd -= tp1->book_size;
4098 tp1->rec.data.chunk_was_revoked = 0;
4100 if (tp1->sent != SCTP_DATAGRAM_NR_ACKED) {
4101 if (asoc->strmout[tp1->rec.data.sid].chunks_on_queues > 0) {
4102 asoc->strmout[tp1->rec.data.sid].chunks_on_queues--;
4105 panic("No chunks on the queues for sid %u.", tp1->rec.data.sid);
4109 if ((asoc->strmout[tp1->rec.data.sid].chunks_on_queues == 0) &&
4110 (asoc->strmout[tp1->rec.data.sid].state == SCTP_STREAM_RESET_PENDING) &&
4111 TAILQ_EMPTY(&asoc->strmout[tp1->rec.data.sid].outqueue)) {
4114 TAILQ_REMOVE(&asoc->sent_queue, tp1, sctp_next);
4115 if (tp1->data) {
4117 sctp_free_bufspace(stcb, asoc, tp1, 1);
4118 sctp_m_freem(tp1->data);
4119 tp1->data = NULL;
4124 tp1->rec.data.tsn,
4130 sctp_free_a_chunk(stcb, tp1, SCTP_SO_NOT_LOCKED);
4230 TAILQ_FOREACH(tp1, &asoc->sent_queue, sctp_next) {
4231 if (tp1->window_probe) {
4233 sctp_window_probe_recovery(stcb, asoc, tp1);
4277 TAILQ_FOREACH(tp1, &asoc->sent_queue, sctp_next) {
4278 if (tp1->sent < SCTP_DATAGRAM_RESEND) {
4279 sctp_flight_size_increase(tp1);
4280 sctp_total_flight_increase(stcb, tp1);
4281 } else if (tp1->sent == SCTP_DATAGRAM_RESEND) {
4408 struct sctp_tmit_chunk *tp1, *tp2;
4498 tp1 = TAILQ_LAST(&asoc->sent_queue,
4500 send_s = tp1->rec.data.tsn + 1;
4502 tp1 = NULL;
4515 if (tp1) {
4516 SCTP_PRINTF("Got send_s from tsn:%x + 1 of tp1: %p\n",
4517 tp1->rec.data.tsn, (void *)tp1);
4601 TAILQ_FOREACH(tp1, &asoc->sent_queue, sctp_next) {
4602 if (SCTP_TSN_GE(last_tsn, tp1->rec.data.tsn)) {
4603 if (tp1->sent != SCTP_DATAGRAM_UNSENT) {
4605 if (tp1->sent < SCTP_DATAGRAM_ACKED) {
4611 if ((tp1->whoTo->dest_state &
4613 (tp1->snd_count < 2)) {
4622 tp1->whoTo->dest_state &=
4625 if (tp1->sent < SCTP_DATAGRAM_RESEND) {
4628 tp1->whoTo->flight_size,
4629 tp1->book_size,
4630 (uint32_t)(uintptr_t)tp1->whoTo,
4631 tp1->rec.data.tsn);
4633 sctp_flight_size_decrease(tp1);
4634 sctp_total_flight_decrease(stcb, tp1);
4636 (*stcb->asoc.cc_functions.sctp_cwnd_update_tsn_acknowledged) (tp1->whoTo,
4637 tp1);
4640 tp1->whoTo->net_ack += tp1->send_size;
4643 this_sack_lowest_newack = tp1->rec.data.tsn;
4644 tp1->whoTo->saw_newack = 1;
4646 if (tp1->snd_count < 2) {
4651 tp1->whoTo->net_ack2 +=
4652 tp1->send_size;
4655 if (tp1->do_rtt) {
4659 tp1->whoTo,
4660 &tp1->sent_rcv_time,
4664 if (tp1->whoTo->rto_needed == 0) {
4665 tp1->whoTo->rto_needed = 1;
4667 tp1->do_rtt = 0;
4682 tp1->whoTo->new_pseudo_cumack = 1;
4683 tp1->whoTo->find_pseudo_cumack = 1;
4684 tp1->whoTo->find_rtx_pseudo_cumack = 1;
4688 tp1->rec.data.tsn,
4694 sctp_log_cwnd(stcb, tp1->whoTo, tp1->rec.data.tsn, SCTP_CWND_LOG_FROM_SACK);
4697 if (tp1->sent == SCTP_DATAGRAM_RESEND) {
4704 if (tp1->rec.data.chunk_was_revoked) {
4706 tp1->whoTo->cwnd -= tp1->book_size;
4707 tp1->rec.data.chunk_was_revoked = 0;
4709 if (tp1->sent != SCTP_DATAGRAM_NR_ACKED) {
4710 tp1->sent = SCTP_DATAGRAM_ACKED;
4770 TAILQ_FOREACH_SAFE(tp1, &asoc->sent_queue, sctp_next, tp2) {
4771 if (SCTP_TSN_GT(tp1->rec.data.tsn, cum_ack)) {
4774 if (tp1->sent != SCTP_DATAGRAM_NR_ACKED) {
4775 if (asoc->strmout[tp1->rec.data.sid].chunks_on_queues > 0) {
4776 asoc->strmout[tp1->rec.data.sid].chunks_on_queues--;
4779 panic("No chunks on the queues for sid %u.", tp1->rec.data.sid);
4783 if ((asoc->strmout[tp1->rec.data.sid].chunks_on_queues == 0) &&
4784 (asoc->strmout[tp1->rec.data.sid].state == SCTP_STREAM_RESET_PENDING) &&
4785 TAILQ_EMPTY(&asoc->strmout[tp1->rec.data.sid].outqueue)) {
4788 TAILQ_REMOVE(&asoc->sent_queue, tp1, sctp_next);
4789 if (PR_SCTP_ENABLED(tp1->flags)) {
4794 if (tp1->data) {
4796 sctp_free_bufspace(stcb, asoc, tp1, 1);
4797 sctp_m_freem(tp1->data);
4798 tp1->data = NULL;
4799 if (asoc->prsctp_supported && PR_SCTP_BUF_ENABLED(tp1->flags)) {
4806 tp1->rec.data.tsn,
4811 sctp_free_a_chunk(stcb, tp1, SCTP_SO_NOT_LOCKED);
4860 TAILQ_FOREACH(tp1, &asoc->sent_queue, sctp_next) {
4861 if (tp1->sent == SCTP_DATAGRAM_ACKED) {
4862 tp1->sent = SCTP_DATAGRAM_SENT;
4865 tp1->whoTo->flight_size,
4866 tp1->book_size,
4867 (uint32_t)(uintptr_t)tp1->whoTo,
4868 tp1->rec.data.tsn);
4870 sctp_flight_size_increase(tp1);
4871 sctp_total_flight_increase(stcb, tp1);
4872 tp1->rec.data.chunk_was_revoked = 1;
4879 tp1->whoTo->cwnd += tp1->book_size;
5106 TAILQ_FOREACH(tp1, &asoc->sent_queue, sctp_next) {
5107 if (tp1->window_probe) {
5108 sctp_window_probe_recovery(stcb, asoc, tp1);
5155 TAILQ_FOREACH(tp1, &asoc->sent_queue, sctp_next) {
5156 if (tp1->sent < SCTP_DATAGRAM_RESEND) {
5157 sctp_flight_size_increase(tp1);
5158 sctp_total_flight_increase(stcb, tp1);
5159 } else if (tp1->sent == SCTP_DATAGRAM_RESEND) {