Lines Matching defs:tp1
2937 struct sctp_tmit_chunk *tp1;
2941 /* Recover the tp1 we last saw */
2942 tp1 = *p_tp1;
2943 if (tp1 == NULL) {
2944 tp1 = TAILQ_FIRST(&stcb->asoc.sent_queue);
2948 while (tp1) {
2949 if (tp1->rec.data.doing_fast_retransmit)
2960 if ((tp1->sent < SCTP_DATAGRAM_RESEND) &&
2961 (tp1->whoTo->find_pseudo_cumack == 1) &&
2962 (tp1->snd_count == 1)) {
2963 tp1->whoTo->pseudo_cumack = tp1->rec.data.tsn;
2964 tp1->whoTo->find_pseudo_cumack = 0;
2966 if ((tp1->sent < SCTP_DATAGRAM_RESEND) &&
2967 (tp1->whoTo->find_rtx_pseudo_cumack == 1) &&
2968 (tp1->snd_count > 1)) {
2969 tp1->whoTo->rtx_pseudo_cumack = tp1->rec.data.tsn;
2970 tp1->whoTo->find_rtx_pseudo_cumack = 0;
2972 if (tp1->rec.data.tsn == theTSN) {
2973 if (tp1->sent != SCTP_DATAGRAM_UNSENT) {
2978 if (tp1->sent < SCTP_DATAGRAM_RESEND) {
2986 if (SCTP_TSN_GT(tp1->rec.data.tsn,
2988 *biggest_newly_acked_tsn = tp1->rec.data.tsn;
2997 if (tp1->rec.data.chunk_was_revoked == 0)
2998 tp1->whoTo->saw_newack = 1;
3000 if (SCTP_TSN_GT(tp1->rec.data.tsn,
3001 tp1->whoTo->this_sack_highest_newack)) {
3002 tp1->whoTo->this_sack_highest_newack =
3003 tp1->rec.data.tsn;
3013 tp1->rec.data.tsn,
3018 *this_sack_lowest_newack = tp1->rec.data.tsn;
3028 if (tp1->rec.data.tsn == tp1->whoTo->pseudo_cumack) {
3029 if (tp1->rec.data.chunk_was_revoked == 0) {
3030 tp1->whoTo->new_pseudo_cumack = 1;
3032 tp1->whoTo->find_pseudo_cumack = 1;
3035 sctp_log_cwnd(stcb, tp1->whoTo, tp1->rec.data.tsn, SCTP_CWND_LOG_FROM_SACK);
3037 if (tp1->rec.data.tsn == tp1->whoTo->rtx_pseudo_cumack) {
3038 if (tp1->rec.data.chunk_was_revoked == 0) {
3039 tp1->whoTo->new_pseudo_cumack = 1;
3041 tp1->whoTo->find_rtx_pseudo_cumack = 1;
3046 tp1->rec.data.tsn,
3053 tp1->whoTo->flight_size,
3054 tp1->book_size,
3055 (uint32_t)(uintptr_t)tp1->whoTo,
3056 tp1->rec.data.tsn);
3058 sctp_flight_size_decrease(tp1);
3060 (*stcb->asoc.cc_functions.sctp_cwnd_update_tsn_acknowledged) (tp1->whoTo,
3061 tp1);
3063 sctp_total_flight_decrease(stcb, tp1);
3065 tp1->whoTo->net_ack += tp1->send_size;
3066 if (tp1->snd_count < 2) {
3070 tp1->whoTo->net_ack2 += tp1->send_size;
3075 if (tp1->do_rtt) {
3079 tp1->whoTo,
3080 &tp1->sent_rcv_time,
3084 if (tp1->whoTo->rto_needed == 0) {
3085 tp1->whoTo->rto_needed = 1;
3087 tp1->do_rtt = 0;
3091 if (tp1->sent <= SCTP_DATAGRAM_RESEND) {
3092 if (SCTP_TSN_GT(tp1->rec.data.tsn,
3095 tp1->rec.data.tsn;
3097 if (tp1->sent == SCTP_DATAGRAM_RESEND) {
3109 if ((tp1->sent != SCTP_FORWARD_TSN_SKIP) &&
3110 (tp1->sent != SCTP_DATAGRAM_NR_ACKED)) {
3111 tp1->sent = SCTP_DATAGRAM_MARKED;
3113 if (tp1->rec.data.chunk_was_revoked) {
3115 tp1->whoTo->cwnd -= tp1->book_size;
3116 tp1->rec.data.chunk_was_revoked = 0;
3120 (tp1->sent != SCTP_DATAGRAM_NR_ACKED)) {
3121 if (stcb->asoc.strmout[tp1->rec.data.sid].chunks_on_queues > 0) {
3122 stcb->asoc.strmout[tp1->rec.data.sid].chunks_on_queues--;
3125 panic("No chunks on the queues for sid %u.", tp1->rec.data.sid);
3128 if ((stcb->asoc.strmout[tp1->rec.data.sid].chunks_on_queues == 0) &&
3129 (stcb->asoc.strmout[tp1->rec.data.sid].state == SCTP_STREAM_RESET_PENDING) &&
3130 TAILQ_EMPTY(&stcb->asoc.strmout[tp1->rec.data.sid].outqueue)) {
3133 tp1->sent = SCTP_DATAGRAM_NR_ACKED;
3134 if (tp1->data) {
3139 sctp_free_bufspace(stcb, &stcb->asoc, tp1, 1);
3140 sctp_m_freem(tp1->data);
3141 tp1->data = NULL;
3147 } /* if (tp1->tsn == theTSN) */
3148 if (SCTP_TSN_GT(tp1->rec.data.tsn, theTSN)) {
3151 tp1 = TAILQ_NEXT(tp1, sctp_next);
3152 if ((tp1 == NULL) && (circled == 0)) {
3154 tp1 = TAILQ_FIRST(&stcb->asoc.sent_queue);
3156 } /* end while (tp1) */
3157 if (tp1 == NULL) {
3159 tp1 = TAILQ_FIRST(&stcb->asoc.sent_queue);
3163 *p_tp1 = tp1;
3174 struct sctp_tmit_chunk *tp1;
3181 tp1 = TAILQ_FIRST(&asoc->sent_queue);
3188 tp1 = TAILQ_FIRST(&asoc->sent_queue);
3205 tp1 = TAILQ_FIRST(&asoc->sent_queue);
3215 if (sctp_process_segment_range(stcb, &tp1, last_tsn, frag_strt, frag_end,
3236 struct sctp_tmit_chunk *tp1;
3238 TAILQ_FOREACH(tp1, &asoc->sent_queue, sctp_next) {
3239 if (SCTP_TSN_GT(tp1->rec.data.tsn, cumack)) {
3246 if (SCTP_TSN_GT(tp1->rec.data.tsn, biggest_tsn_acked)) {
3249 if (tp1->sent == SCTP_DATAGRAM_ACKED) {
3251 tp1->sent = SCTP_DATAGRAM_SENT;
3252 tp1->rec.data.chunk_was_revoked = 1;
3259 tp1->whoTo->flight_size,
3260 tp1->book_size,
3261 (uint32_t)(uintptr_t)tp1->whoTo,
3262 tp1->rec.data.tsn);
3264 sctp_flight_size_increase(tp1);
3265 sctp_total_flight_increase(stcb, tp1);
3270 tp1->whoTo->cwnd += tp1->book_size;
3274 tp1->rec.data.tsn,
3279 } else if (tp1->sent == SCTP_DATAGRAM_MARKED) {
3281 tp1->sent = SCTP_DATAGRAM_ACKED;
3284 if (tp1->sent == SCTP_DATAGRAM_UNSENT)
3293 struct sctp_tmit_chunk *tp1;
3304 tp1 = TAILQ_FIRST(&stcb->asoc.send_queue);
3305 if (tp1 == NULL) {
3308 sending_seq = tp1->rec.data.tsn;
3322 TAILQ_FOREACH(tp1, &asoc->sent_queue, sctp_next) {
3324 if (tp1->no_fr_allowed) {
3329 if (tp1->sent < SCTP_DATAGRAM_RESEND)
3331 tp1->rec.data.tsn,
3332 tp1->sent,
3335 if (SCTP_TSN_GT(tp1->rec.data.tsn, biggest_tsn_acked) ||
3336 tp1->sent == SCTP_DATAGRAM_UNSENT) {
3341 if ((PR_SCTP_TTL_ENABLED(tp1->flags)) && tp1->sent < SCTP_DATAGRAM_ACKED) {
3343 if (timevalcmp(&now, &tp1->rec.data.timetodrop, >)) {
3345 if (tp1->data != NULL) {
3346 (void)sctp_release_pr_sctp_chunk(stcb, tp1, 1,
3353 if (SCTP_TSN_GT(tp1->rec.data.tsn, asoc->this_sack_highest_gap) &&
3358 if (tp1->sent >= SCTP_DATAGRAM_RESEND) {
3361 if (tp1->sent == SCTP_FORWARD_TSN_SKIP) {
3363 tp1->rec.data.fwd_tsn_cnt++;
3370 if (tp1->whoTo && tp1->whoTo->saw_newack == 0) {
3378 } else if (tp1->whoTo &&
3379 SCTP_TSN_GT(tp1->rec.data.tsn,
3380 tp1->whoTo->this_sack_highest_newack) &&
3385 * after tp1. Therefore, according to the SFR algo
3386 * for CMT, tp1 cannot be marked for FR using this
3410 tp1->rec.data.tsn,
3411 tp1->sent,
3414 if (tp1->sent < SCTP_DATAGRAM_RESEND) {
3415 tp1->sent++;
3424 * rtx'd, If not a mixed sack and if tp1 is
3431 if ((tp1->sent < SCTP_DATAGRAM_RESEND) && (num_dests_sacked == 1) &&
3432 SCTP_TSN_GT(this_sack_lowest_newack, tp1->rec.data.tsn)) {
3435 tp1->rec.data.tsn,
3436 tp1->sent,
3439 tp1->sent++;
3442 } else if ((tp1->rec.data.doing_fast_retransmit) &&
3464 tp1->rec.data.fast_retran_tsn)) {
3472 tp1->rec.data.tsn,
3473 tp1->sent,
3476 if (tp1->sent < SCTP_DATAGRAM_RESEND) {
3477 tp1->sent++;
3491 * if tp1 is not between two
3501 if ((tp1->sent < SCTP_DATAGRAM_RESEND) &&
3504 tp1->rec.data.tsn)) {
3507 tp1->rec.data.tsn,
3508 tp1->sent,
3511 if (tp1->sent < SCTP_DATAGRAM_RESEND) {
3512 tp1->sent++;
3522 } else if (SCTP_TSN_GT(tp1->rec.data.tsn,
3534 tp1->rec.data.tsn,
3535 tp1->sent,
3538 if (tp1->sent < SCTP_DATAGRAM_RESEND) {
3539 tp1->sent++;
3548 * rtx'd, If not a mixed sack and if tp1 is
3555 if ((tp1->sent < SCTP_DATAGRAM_RESEND) && (num_dests_sacked == 1) &&
3556 SCTP_TSN_GT(this_sack_lowest_newack, tp1->rec.data.tsn)) {
3559 tp1->rec.data.tsn,
3560 tp1->sent,
3563 tp1->sent++;
3567 if (tp1->sent == SCTP_DATAGRAM_RESEND) {
3573 (tp1->whoTo ? (tp1->whoTo->flight_size) : 0),
3574 tp1->book_size,
3575 (uint32_t)(uintptr_t)tp1->whoTo,
3576 tp1->rec.data.tsn);
3578 if (tp1->whoTo) {
3579 tp1->whoTo->net_ack++;
3580 sctp_flight_size_decrease(tp1);
3582 (*stcb->asoc.cc_functions.sctp_cwnd_update_tsn_acknowledged) (tp1->whoTo,
3583 tp1);
3589 asoc->peers_rwnd, tp1->send_size, SCTP_BASE_SYSCTL(sctp_peer_chunk_oh));
3592 asoc->peers_rwnd += (tp1->send_size + SCTP_BASE_SYSCTL(sctp_peer_chunk_oh));
3595 sctp_total_flight_decrease(stcb, tp1);
3598 (PR_SCTP_RTX_ENABLED(tp1->flags))) {
3603 if (tp1->snd_count > tp1->rec.data.timetodrop.tv_sec) {
3605 if (tp1->data != NULL) {
3606 (void)sctp_release_pr_sctp_chunk(stcb, tp1, 1,
3610 if (tp1->whoTo != NULL) {
3611 tp1->whoTo->net_ack++;
3621 sctp_log_fr(tp1->rec.data.tsn, tp1->snd_count,
3635 tp1->no_fr_allowed = 1;
3636 alt = tp1->whoTo;
3655 alt = tp1->whoTo;
3664 if (tp1->whoTo) {
3665 tp1->whoTo->find_pseudo_cumack = 1;
3666 tp1->whoTo->find_rtx_pseudo_cumack = 1;
3671 alt = sctp_find_alternate_net(stcb, tp1->whoTo, 0);
3678 alt = tp1->whoTo;
3682 tp1->rec.data.doing_fast_retransmit = 1;
3695 tp1->rec.data.fast_retran_tsn = sending_seq;
3708 tp1->rec.data.fast_retran_tsn =
3712 if (tp1->do_rtt) {
3717 if ((tp1->whoTo != NULL) &&
3718 (tp1->whoTo->rto_needed == 0)) {
3719 tp1->whoTo->rto_needed = 1;
3721 tp1->do_rtt = 0;
3723 if (alt != tp1->whoTo) {
3725 sctp_free_remote_addr(tp1->whoTo);
3727 tp1->whoTo = alt;
3738 struct sctp_tmit_chunk *tp1, *tp2, *a_adv = NULL;
3745 TAILQ_FOREACH_SAFE(tp1, &asoc->sent_queue, sctp_next, tp2) {
3746 if (tp1->sent != SCTP_FORWARD_TSN_SKIP &&
3747 tp1->sent != SCTP_DATAGRAM_RESEND &&
3748 tp1->sent != SCTP_DATAGRAM_NR_ACKED) {
3753 if ((tp1->sent == SCTP_FORWARD_TSN_SKIP) ||
3754 (tp1->sent == SCTP_DATAGRAM_NR_ACKED)) {
3757 tp1->rec.data.tsn, 0, 0);
3760 if (!PR_SCTP_ENABLED(tp1->flags)) {
3777 if (tp1->sent == SCTP_DATAGRAM_RESEND &&
3778 (PR_SCTP_TTL_ENABLED(tp1->flags))) {
3783 if (timevalcmp(&now, &tp1->rec.data.timetodrop, >)) {
3785 if (tp1->data) {
3786 (void)sctp_release_pr_sctp_chunk(stcb, tp1,
3802 if ((tp1->sent == SCTP_FORWARD_TSN_SKIP) ||
3803 (tp1->sent == SCTP_DATAGRAM_NR_ACKED)) {
3805 if (SCTP_TSN_GT(tp1->rec.data.tsn, asoc->advanced_peer_ack_point)) {
3806 asoc->advanced_peer_ack_point = tp1->rec.data.tsn;
3807 a_adv = tp1;
3808 } else if (tp1->rec.data.tsn == asoc->advanced_peer_ack_point) {
3810 a_adv = tp1;
3877 struct sctp_tmit_chunk *tp1)
3879 tp1->window_probe = 0;
3880 if ((tp1->sent >= SCTP_DATAGRAM_ACKED) || (tp1->data == NULL)) {
3883 tp1->whoTo ? tp1->whoTo->flight_size : 0,
3884 tp1->book_size,
3885 (uint32_t)(uintptr_t)tp1->whoTo,
3886 tp1->rec.data.tsn);
3891 (*stcb->asoc.cc_functions.sctp_cwnd_update_tsn_acknowledged) (tp1->whoTo,
3892 tp1);
3894 sctp_flight_size_decrease(tp1);
3895 sctp_total_flight_decrease(stcb, tp1);
3897 tp1->sent = SCTP_DATAGRAM_RESEND;
3902 tp1->whoTo->flight_size,
3903 tp1->book_size,
3904 (uint32_t)(uintptr_t)tp1->whoTo,
3905 tp1->rec.data.tsn);
3915 struct sctp_tmit_chunk *tp1, *tp2;
3975 tp1 = TAILQ_LAST(&asoc->sent_queue,
3977 send_s = tp1->rec.data.tsn + 1;
4006 TAILQ_FOREACH_SAFE(tp1, &asoc->sent_queue, sctp_next, tp2) {
4007 if (SCTP_TSN_GE(cumack, tp1->rec.data.tsn)) {
4008 if (tp1->sent == SCTP_DATAGRAM_UNSENT) {
4011 if (tp1->sent < SCTP_DATAGRAM_ACKED) {
4017 if (tp1->sent < SCTP_DATAGRAM_RESEND) {
4020 tp1->whoTo->flight_size,
4021 tp1->book_size,
4022 (uint32_t)(uintptr_t)tp1->whoTo,
4023 tp1->rec.data.tsn);
4025 sctp_flight_size_decrease(tp1);
4027 (*stcb->asoc.cc_functions.sctp_cwnd_update_tsn_acknowledged) (tp1->whoTo,
4028 tp1);
4031 sctp_total_flight_decrease(stcb, tp1);
4033 tp1->whoTo->net_ack += tp1->send_size;
4034 if (tp1->snd_count < 2) {
4039 tp1->whoTo->net_ack2 +=
4040 tp1->send_size;
4043 if (tp1->do_rtt) {
4047 tp1->whoTo,
4048 &tp1->sent_rcv_time,
4052 if (tp1->whoTo->rto_needed == 0) {
4053 tp1->whoTo->rto_needed = 1;
4055 tp1->do_rtt = 0;
4070 tp1->whoTo->new_pseudo_cumack = 1;
4071 tp1->whoTo->find_pseudo_cumack = 1;
4072 tp1->whoTo->find_rtx_pseudo_cumack = 1;
4075 sctp_log_cwnd(stcb, tp1->whoTo, tp1->rec.data.tsn, SCTP_CWND_LOG_FROM_SACK);
4078 if (tp1->sent == SCTP_DATAGRAM_RESEND) {
4081 if (tp1->rec.data.chunk_was_revoked) {
4083 tp1->whoTo->cwnd -= tp1->book_size;
4084 tp1->rec.data.chunk_was_revoked = 0;
4086 if (tp1->sent != SCTP_DATAGRAM_NR_ACKED) {
4087 if (asoc->strmout[tp1->rec.data.sid].chunks_on_queues > 0) {
4088 asoc->strmout[tp1->rec.data.sid].chunks_on_queues--;
4091 panic("No chunks on the queues for sid %u.", tp1->rec.data.sid);
4095 if ((asoc->strmout[tp1->rec.data.sid].chunks_on_queues == 0) &&
4096 (asoc->strmout[tp1->rec.data.sid].state == SCTP_STREAM_RESET_PENDING) &&
4097 TAILQ_EMPTY(&asoc->strmout[tp1->rec.data.sid].outqueue)) {
4100 TAILQ_REMOVE(&asoc->sent_queue, tp1, sctp_next);
4101 if (tp1->data) {
4103 sctp_free_bufspace(stcb, asoc, tp1, 1);
4104 sctp_m_freem(tp1->data);
4105 tp1->data = NULL;
4110 tp1->rec.data.tsn,
4116 sctp_free_a_chunk(stcb, tp1, SCTP_SO_NOT_LOCKED);
4216 TAILQ_FOREACH(tp1, &asoc->sent_queue, sctp_next) {
4217 if (tp1->window_probe) {
4219 sctp_window_probe_recovery(stcb, asoc, tp1);
4263 TAILQ_FOREACH(tp1, &asoc->sent_queue, sctp_next) {
4264 if (tp1->sent < SCTP_DATAGRAM_RESEND) {
4265 sctp_flight_size_increase(tp1);
4266 sctp_total_flight_increase(stcb, tp1);
4267 } else if (tp1->sent == SCTP_DATAGRAM_RESEND) {
4394 struct sctp_tmit_chunk *tp1, *tp2;
4484 tp1 = TAILQ_LAST(&asoc->sent_queue,
4486 send_s = tp1->rec.data.tsn + 1;
4488 tp1 = NULL;
4501 if (tp1) {
4502 SCTP_PRINTF("Got send_s from tsn:%x + 1 of tp1: %p\n",
4503 tp1->rec.data.tsn, (void *)tp1);
4587 TAILQ_FOREACH(tp1, &asoc->sent_queue, sctp_next) {
4588 if (SCTP_TSN_GE(last_tsn, tp1->rec.data.tsn)) {
4589 if (tp1->sent != SCTP_DATAGRAM_UNSENT) {
4591 if (tp1->sent < SCTP_DATAGRAM_ACKED) {
4597 if ((tp1->whoTo->dest_state &
4599 (tp1->snd_count < 2)) {
4608 tp1->whoTo->dest_state &=
4611 if (tp1->sent < SCTP_DATAGRAM_RESEND) {
4614 tp1->whoTo->flight_size,
4615 tp1->book_size,
4616 (uint32_t)(uintptr_t)tp1->whoTo,
4617 tp1->rec.data.tsn);
4619 sctp_flight_size_decrease(tp1);
4620 sctp_total_flight_decrease(stcb, tp1);
4622 (*stcb->asoc.cc_functions.sctp_cwnd_update_tsn_acknowledged) (tp1->whoTo,
4623 tp1);
4626 tp1->whoTo->net_ack += tp1->send_size;
4629 this_sack_lowest_newack = tp1->rec.data.tsn;
4630 tp1->whoTo->saw_newack = 1;
4632 if (tp1->snd_count < 2) {
4637 tp1->whoTo->net_ack2 +=
4638 tp1->send_size;
4641 if (tp1->do_rtt) {
4645 tp1->whoTo,
4646 &tp1->sent_rcv_time,
4650 if (tp1->whoTo->rto_needed == 0) {
4651 tp1->whoTo->rto_needed = 1;
4653 tp1->do_rtt = 0;
4668 tp1->whoTo->new_pseudo_cumack = 1;
4669 tp1->whoTo->find_pseudo_cumack = 1;
4670 tp1->whoTo->find_rtx_pseudo_cumack = 1;
4674 tp1->rec.data.tsn,
4680 sctp_log_cwnd(stcb, tp1->whoTo, tp1->rec.data.tsn, SCTP_CWND_LOG_FROM_SACK);
4683 if (tp1->sent == SCTP_DATAGRAM_RESEND) {
4690 if (tp1->rec.data.chunk_was_revoked) {
4692 tp1->whoTo->cwnd -= tp1->book_size;
4693 tp1->rec.data.chunk_was_revoked = 0;
4695 if (tp1->sent != SCTP_DATAGRAM_NR_ACKED) {
4696 tp1->sent = SCTP_DATAGRAM_ACKED;
4756 TAILQ_FOREACH_SAFE(tp1, &asoc->sent_queue, sctp_next, tp2) {
4757 if (SCTP_TSN_GT(tp1->rec.data.tsn, cum_ack)) {
4760 if (tp1->sent != SCTP_DATAGRAM_NR_ACKED) {
4761 if (asoc->strmout[tp1->rec.data.sid].chunks_on_queues > 0) {
4762 asoc->strmout[tp1->rec.data.sid].chunks_on_queues--;
4765 panic("No chunks on the queues for sid %u.", tp1->rec.data.sid);
4769 if ((asoc->strmout[tp1->rec.data.sid].chunks_on_queues == 0) &&
4770 (asoc->strmout[tp1->rec.data.sid].state == SCTP_STREAM_RESET_PENDING) &&
4771 TAILQ_EMPTY(&asoc->strmout[tp1->rec.data.sid].outqueue)) {
4774 TAILQ_REMOVE(&asoc->sent_queue, tp1, sctp_next);
4775 if (PR_SCTP_ENABLED(tp1->flags)) {
4780 if (tp1->data) {
4782 sctp_free_bufspace(stcb, asoc, tp1, 1);
4783 sctp_m_freem(tp1->data);
4784 tp1->data = NULL;
4785 if (asoc->prsctp_supported && PR_SCTP_BUF_ENABLED(tp1->flags)) {
4792 tp1->rec.data.tsn,
4797 sctp_free_a_chunk(stcb, tp1, SCTP_SO_NOT_LOCKED);
4846 TAILQ_FOREACH(tp1, &asoc->sent_queue, sctp_next) {
4847 if (tp1->sent == SCTP_DATAGRAM_ACKED) {
4848 tp1->sent = SCTP_DATAGRAM_SENT;
4851 tp1->whoTo->flight_size,
4852 tp1->book_size,
4853 (uint32_t)(uintptr_t)tp1->whoTo,
4854 tp1->rec.data.tsn);
4856 sctp_flight_size_increase(tp1);
4857 sctp_total_flight_increase(stcb, tp1);
4858 tp1->rec.data.chunk_was_revoked = 1;
4865 tp1->whoTo->cwnd += tp1->book_size;
5092 TAILQ_FOREACH(tp1, &asoc->sent_queue, sctp_next) {
5093 if (tp1->window_probe) {
5094 sctp_window_probe_recovery(stcb, asoc, tp1);
5141 TAILQ_FOREACH(tp1, &asoc->sent_queue, sctp_next) {
5142 if (tp1->sent < SCTP_DATAGRAM_RESEND) {
5143 sctp_flight_size_increase(tp1);
5144 sctp_total_flight_increase(stcb, tp1);
5145 } else if (tp1->sent == SCTP_DATAGRAM_RESEND) {