Lines Matching refs:tp1
2984 struct sctp_tmit_chunk *tp1;
2988 /* Recover the tp1 we last saw */
2989 tp1 = *p_tp1;
2990 if (tp1 == NULL) {
2991 tp1 = TAILQ_FIRST(&stcb->asoc.sent_queue);
2995 while (tp1) {
2996 if (tp1->rec.data.doing_fast_retransmit)
3007 if ((tp1->sent < SCTP_DATAGRAM_RESEND) &&
3008 (tp1->whoTo->find_pseudo_cumack == 1) &&
3009 (tp1->snd_count == 1)) {
3010 tp1->whoTo->pseudo_cumack = tp1->rec.data.tsn;
3011 tp1->whoTo->find_pseudo_cumack = 0;
3013 if ((tp1->sent < SCTP_DATAGRAM_RESEND) &&
3014 (tp1->whoTo->find_rtx_pseudo_cumack == 1) &&
3015 (tp1->snd_count > 1)) {
3016 tp1->whoTo->rtx_pseudo_cumack = tp1->rec.data.tsn;
3017 tp1->whoTo->find_rtx_pseudo_cumack = 0;
3019 if (tp1->rec.data.tsn == theTSN) {
3020 if (tp1->sent != SCTP_DATAGRAM_UNSENT) {
3025 if (tp1->sent < SCTP_DATAGRAM_RESEND) {
3033 if (SCTP_TSN_GT(tp1->rec.data.tsn,
3035 *biggest_newly_acked_tsn = tp1->rec.data.tsn;
3044 if (tp1->rec.data.chunk_was_revoked == 0)
3045 tp1->whoTo->saw_newack = 1;
3047 if (SCTP_TSN_GT(tp1->rec.data.tsn,
3048 tp1->whoTo->this_sack_highest_newack)) {
3049 tp1->whoTo->this_sack_highest_newack =
3050 tp1->rec.data.tsn;
3060 tp1->rec.data.tsn,
3065 *this_sack_lowest_newack = tp1->rec.data.tsn;
3075 if (tp1->rec.data.tsn == tp1->whoTo->pseudo_cumack) {
3076 if (tp1->rec.data.chunk_was_revoked == 0) {
3077 tp1->whoTo->new_pseudo_cumack = 1;
3079 tp1->whoTo->find_pseudo_cumack = 1;
3082 sctp_log_cwnd(stcb, tp1->whoTo, tp1->rec.data.tsn, SCTP_CWND_LOG_FROM_SACK);
3084 if (tp1->rec.data.tsn == tp1->whoTo->rtx_pseudo_cumack) {
3085 if (tp1->rec.data.chunk_was_revoked == 0) {
3086 tp1->whoTo->new_pseudo_cumack = 1;
3088 tp1->whoTo->find_rtx_pseudo_cumack = 1;
3093 tp1->rec.data.tsn,
3100 tp1->whoTo->flight_size,
3101 tp1->book_size,
3102 (uint32_t)(uintptr_t)tp1->whoTo,
3103 tp1->rec.data.tsn);
3105 sctp_flight_size_decrease(tp1);
3107 (*stcb->asoc.cc_functions.sctp_cwnd_update_tsn_acknowledged) (tp1->whoTo,
3108 tp1);
3110 sctp_total_flight_decrease(stcb, tp1);
3112 tp1->whoTo->net_ack += tp1->send_size;
3113 if (tp1->snd_count < 2) {
3117 tp1->whoTo->net_ack2 += tp1->send_size;
3122 if (tp1->do_rtt) {
3126 tp1->whoTo,
3127 &tp1->sent_rcv_time,
3131 if (tp1->whoTo->rto_needed == 0) {
3132 tp1->whoTo->rto_needed = 1;
3134 tp1->do_rtt = 0;
3139 if (tp1->sent <= SCTP_DATAGRAM_RESEND) {
3140 if (SCTP_TSN_GT(tp1->rec.data.tsn,
3143 tp1->rec.data.tsn;
3145 if (tp1->sent == SCTP_DATAGRAM_RESEND) {
3157 if ((tp1->sent != SCTP_FORWARD_TSN_SKIP) &&
3158 (tp1->sent != SCTP_DATAGRAM_NR_ACKED)) {
3159 tp1->sent = SCTP_DATAGRAM_MARKED;
3161 if (tp1->rec.data.chunk_was_revoked) {
3163 tp1->whoTo->cwnd -= tp1->book_size;
3164 tp1->rec.data.chunk_was_revoked = 0;
3168 (tp1->sent != SCTP_DATAGRAM_NR_ACKED)) {
3169 if (stcb->asoc.strmout[tp1->rec.data.sid].chunks_on_queues > 0) {
3170 stcb->asoc.strmout[tp1->rec.data.sid].chunks_on_queues--;
3173 panic("No chunks on the queues for sid %u.", tp1->rec.data.sid);
3176 if ((stcb->asoc.strmout[tp1->rec.data.sid].chunks_on_queues == 0) &&
3177 (stcb->asoc.strmout[tp1->rec.data.sid].state == SCTP_STREAM_RESET_PENDING) &&
3178 TAILQ_EMPTY(&stcb->asoc.strmout[tp1->rec.data.sid].outqueue)) {
3181 tp1->sent = SCTP_DATAGRAM_NR_ACKED;
3182 if (tp1->data) {
3187 sctp_free_bufspace(stcb, &stcb->asoc, tp1, 1);
3188 sctp_m_freem(tp1->data);
3189 tp1->data = NULL;
3195 } /* if (tp1->tsn == theTSN) */
3196 if (SCTP_TSN_GT(tp1->rec.data.tsn, theTSN)) {
3199 tp1 = TAILQ_NEXT(tp1, sctp_next);
3200 if ((tp1 == NULL) && (circled == 0)) {
3202 tp1 = TAILQ_FIRST(&stcb->asoc.sent_queue);
3204 } /* end while (tp1) */
3205 if (tp1 == NULL) {
3207 tp1 = TAILQ_FIRST(&stcb->asoc.sent_queue);
3211 *p_tp1 = tp1;
3223 struct sctp_tmit_chunk *tp1;
3230 tp1 = TAILQ_FIRST(&asoc->sent_queue);
3237 tp1 = TAILQ_FIRST(&asoc->sent_queue);
3254 tp1 = TAILQ_FIRST(&asoc->sent_queue);
3264 if (sctp_process_segment_range(stcb, &tp1, last_tsn, frag_strt, frag_end,
3285 struct sctp_tmit_chunk *tp1;
3287 TAILQ_FOREACH(tp1, &asoc->sent_queue, sctp_next) {
3288 if (SCTP_TSN_GT(tp1->rec.data.tsn, cumack)) {
3295 if (SCTP_TSN_GT(tp1->rec.data.tsn, biggest_tsn_acked)) {
3298 if (tp1->sent == SCTP_DATAGRAM_ACKED) {
3300 tp1->sent = SCTP_DATAGRAM_SENT;
3301 tp1->rec.data.chunk_was_revoked = 1;
3308 tp1->whoTo->flight_size,
3309 tp1->book_size,
3310 (uint32_t)(uintptr_t)tp1->whoTo,
3311 tp1->rec.data.tsn);
3313 sctp_flight_size_increase(tp1);
3314 sctp_total_flight_increase(stcb, tp1);
3319 tp1->whoTo->cwnd += tp1->book_size;
3323 tp1->rec.data.tsn,
3328 } else if (tp1->sent == SCTP_DATAGRAM_MARKED) {
3330 tp1->sent = SCTP_DATAGRAM_ACKED;
3333 if (tp1->sent == SCTP_DATAGRAM_UNSENT)
3343 struct sctp_tmit_chunk *tp1;
3355 tp1 = TAILQ_FIRST(&stcb->asoc.send_queue);
3356 if (tp1 == NULL) {
3359 sending_seq = tp1->rec.data.tsn;
3373 TAILQ_FOREACH(tp1, &asoc->sent_queue, sctp_next) {
3375 if (tp1->no_fr_allowed) {
3380 if (tp1->sent < SCTP_DATAGRAM_RESEND)
3382 tp1->rec.data.tsn,
3383 tp1->sent,
3386 if (SCTP_TSN_GT(tp1->rec.data.tsn, biggest_tsn_acked) ||
3387 tp1->sent == SCTP_DATAGRAM_UNSENT) {
3392 if ((PR_SCTP_TTL_ENABLED(tp1->flags)) && tp1->sent < SCTP_DATAGRAM_ACKED) {
3394 if (timevalcmp(&now, &tp1->rec.data.timetodrop, >)) {
3396 if (tp1->data != NULL) {
3397 (void)sctp_release_pr_sctp_chunk(stcb, tp1, 1,
3405 if (SCTP_TSN_GT(tp1->rec.data.tsn, asoc->this_sack_highest_gap) &&
3410 if (tp1->sent >= SCTP_DATAGRAM_RESEND) {
3413 if (tp1->sent == SCTP_FORWARD_TSN_SKIP) {
3415 tp1->rec.data.fwd_tsn_cnt++;
3422 if (tp1->whoTo && tp1->whoTo->saw_newack == 0) {
3430 } else if (tp1->whoTo &&
3431 SCTP_TSN_GT(tp1->rec.data.tsn,
3432 tp1->whoTo->this_sack_highest_newack) &&
3437 * sent after tp1. Therefore, according to the SFR
3438 * algo for CMT, tp1 cannot be marked for FR using
3462 tp1->rec.data.tsn,
3463 tp1->sent,
3466 if (tp1->sent < SCTP_DATAGRAM_RESEND) {
3467 tp1->sent++;
3476 * rtx'd, If not a mixed sack and if tp1 is
3483 if ((tp1->sent < SCTP_DATAGRAM_RESEND) && (num_dests_sacked == 1) &&
3484 SCTP_TSN_GT(this_sack_lowest_newack, tp1->rec.data.tsn)) {
3487 tp1->rec.data.tsn,
3488 tp1->sent,
3491 tp1->sent++;
3494 } else if ((tp1->rec.data.doing_fast_retransmit) &&
3517 tp1->rec.data.fast_retran_tsn)) {
3525 tp1->rec.data.tsn,
3526 tp1->sent,
3529 if (tp1->sent < SCTP_DATAGRAM_RESEND) {
3530 tp1->sent++;
3544 * if tp1 is not between two
3554 if ((tp1->sent < SCTP_DATAGRAM_RESEND) &&
3557 tp1->rec.data.tsn)) {
3560 tp1->rec.data.tsn,
3561 tp1->sent,
3564 if (tp1->sent < SCTP_DATAGRAM_RESEND) {
3565 tp1->sent++;
3575 } else if (SCTP_TSN_GT(tp1->rec.data.tsn,
3587 tp1->rec.data.tsn,
3588 tp1->sent,
3591 if (tp1->sent < SCTP_DATAGRAM_RESEND) {
3592 tp1->sent++;
3601 * rtx'd, If not a mixed sack and if tp1 is
3608 if ((tp1->sent < SCTP_DATAGRAM_RESEND) && (num_dests_sacked == 1) &&
3609 SCTP_TSN_GT(this_sack_lowest_newack, tp1->rec.data.tsn)) {
3612 tp1->rec.data.tsn,
3613 tp1->sent,
3616 tp1->sent++;
3620 if (tp1->sent == SCTP_DATAGRAM_RESEND) {
3626 (tp1->whoTo ? (tp1->whoTo->flight_size) : 0),
3627 tp1->book_size,
3628 (uint32_t)(uintptr_t)tp1->whoTo,
3629 tp1->rec.data.tsn);
3631 if (tp1->whoTo) {
3632 tp1->whoTo->net_ack++;
3633 sctp_flight_size_decrease(tp1);
3635 (*stcb->asoc.cc_functions.sctp_cwnd_update_tsn_acknowledged) (tp1->whoTo,
3636 tp1);
3642 asoc->peers_rwnd, tp1->send_size, SCTP_BASE_SYSCTL(sctp_peer_chunk_oh));
3645 asoc->peers_rwnd += (tp1->send_size + SCTP_BASE_SYSCTL(sctp_peer_chunk_oh));
3648 sctp_total_flight_decrease(stcb, tp1);
3651 (PR_SCTP_RTX_ENABLED(tp1->flags))) {
3656 if (tp1->snd_count > tp1->rec.data.timetodrop.tv_sec) {
3658 if (tp1->data != NULL) {
3659 (void)sctp_release_pr_sctp_chunk(stcb, tp1, 1,
3663 if (tp1->whoTo != NULL) {
3664 tp1->whoTo->net_ack++;
3674 sctp_log_fr(tp1->rec.data.tsn, tp1->snd_count,
3688 tp1->no_fr_allowed = 1;
3689 alt = tp1->whoTo;
3708 alt = tp1->whoTo;
3717 if (tp1->whoTo) {
3718 tp1->whoTo->find_pseudo_cumack = 1;
3719 tp1->whoTo->find_rtx_pseudo_cumack = 1;
3726 alt = sctp_find_alternate_net(stcb, tp1->whoTo, 0);
3733 alt = tp1->whoTo;
3737 tp1->rec.data.doing_fast_retransmit = 1;
3751 tp1->rec.data.fast_retran_tsn = sending_seq;
3764 tp1->rec.data.fast_retran_tsn =
3768 if (tp1->do_rtt) {
3773 if ((tp1->whoTo != NULL) &&
3774 (tp1->whoTo->rto_needed == 0)) {
3775 tp1->whoTo->rto_needed = 1;
3777 tp1->do_rtt = 0;
3779 if (alt != tp1->whoTo) {
3781 sctp_free_remote_addr(tp1->whoTo);
3783 tp1->whoTo = alt;
3794 struct sctp_tmit_chunk *tp1, *tp2, *a_adv = NULL;
3801 TAILQ_FOREACH_SAFE(tp1, &asoc->sent_queue, sctp_next, tp2) {
3802 if (tp1->sent != SCTP_FORWARD_TSN_SKIP &&
3803 tp1->sent != SCTP_DATAGRAM_RESEND &&
3804 tp1->sent != SCTP_DATAGRAM_NR_ACKED) {
3809 if ((tp1->sent == SCTP_FORWARD_TSN_SKIP) ||
3810 (tp1->sent == SCTP_DATAGRAM_NR_ACKED)) {
3813 tp1->rec.data.tsn, 0, 0);
3816 if (!PR_SCTP_ENABLED(tp1->flags)) {
3833 if (tp1->sent == SCTP_DATAGRAM_RESEND &&
3834 (PR_SCTP_TTL_ENABLED(tp1->flags))) {
3839 if (timevalcmp(&now, &tp1->rec.data.timetodrop, >)) {
3841 if (tp1->data) {
3842 (void)sctp_release_pr_sctp_chunk(stcb, tp1,
3858 if ((tp1->sent == SCTP_FORWARD_TSN_SKIP) ||
3859 (tp1->sent == SCTP_DATAGRAM_NR_ACKED)) {
3861 if (SCTP_TSN_GT(tp1->rec.data.tsn, asoc->advanced_peer_ack_point)) {
3862 asoc->advanced_peer_ack_point = tp1->rec.data.tsn;
3863 a_adv = tp1;
3864 } else if (tp1->rec.data.tsn == asoc->advanced_peer_ack_point) {
3866 a_adv = tp1;
3934 struct sctp_tmit_chunk *tp1)
3936 tp1->window_probe = 0;
3937 if ((tp1->sent >= SCTP_DATAGRAM_ACKED) || (tp1->data == NULL)) {
3940 tp1->whoTo ? tp1->whoTo->flight_size : 0,
3941 tp1->book_size,
3942 (uint32_t)(uintptr_t)tp1->whoTo,
3943 tp1->rec.data.tsn);
3948 (*stcb->asoc.cc_functions.sctp_cwnd_update_tsn_acknowledged) (tp1->whoTo,
3949 tp1);
3951 sctp_flight_size_decrease(tp1);
3952 sctp_total_flight_decrease(stcb, tp1);
3954 tp1->sent = SCTP_DATAGRAM_RESEND;
3959 tp1->whoTo->flight_size,
3960 tp1->book_size,
3961 (uint32_t)(uintptr_t)tp1->whoTo,
3962 tp1->rec.data.tsn);
3972 struct sctp_tmit_chunk *tp1, *tp2;
4032 tp1 = TAILQ_LAST(&asoc->sent_queue,
4034 send_s = tp1->rec.data.tsn + 1;
4062 TAILQ_FOREACH_SAFE(tp1, &asoc->sent_queue, sctp_next, tp2) {
4063 if (SCTP_TSN_GE(cumack, tp1->rec.data.tsn)) {
4064 if (tp1->sent == SCTP_DATAGRAM_UNSENT) {
4067 if (tp1->sent < SCTP_DATAGRAM_ACKED) {
4073 if (tp1->sent < SCTP_DATAGRAM_RESEND) {
4076 tp1->whoTo->flight_size,
4077 tp1->book_size,
4078 (uint32_t)(uintptr_t)tp1->whoTo,
4079 tp1->rec.data.tsn);
4081 sctp_flight_size_decrease(tp1);
4083 (*stcb->asoc.cc_functions.sctp_cwnd_update_tsn_acknowledged) (tp1->whoTo,
4084 tp1);
4087 sctp_total_flight_decrease(stcb, tp1);
4089 tp1->whoTo->net_ack += tp1->send_size;
4090 if (tp1->snd_count < 2) {
4095 tp1->whoTo->net_ack2 +=
4096 tp1->send_size;
4099 if (tp1->do_rtt) {
4103 tp1->whoTo,
4104 &tp1->sent_rcv_time,
4108 if (tp1->whoTo->rto_needed == 0) {
4109 tp1->whoTo->rto_needed = 1;
4111 tp1->do_rtt = 0;
4126 tp1->whoTo->new_pseudo_cumack = 1;
4127 tp1->whoTo->find_pseudo_cumack = 1;
4128 tp1->whoTo->find_rtx_pseudo_cumack = 1;
4132 sctp_log_cwnd(stcb, tp1->whoTo, tp1->rec.data.tsn, SCTP_CWND_LOG_FROM_SACK);
4135 if (tp1->sent == SCTP_DATAGRAM_RESEND) {
4138 if (tp1->rec.data.chunk_was_revoked) {
4140 tp1->whoTo->cwnd -= tp1->book_size;
4141 tp1->rec.data.chunk_was_revoked = 0;
4143 if (tp1->sent != SCTP_DATAGRAM_NR_ACKED) {
4144 if (asoc->strmout[tp1->rec.data.sid].chunks_on_queues > 0) {
4145 asoc->strmout[tp1->rec.data.sid].chunks_on_queues--;
4148 panic("No chunks on the queues for sid %u.", tp1->rec.data.sid);
4152 if ((asoc->strmout[tp1->rec.data.sid].chunks_on_queues == 0) &&
4153 (asoc->strmout[tp1->rec.data.sid].state == SCTP_STREAM_RESET_PENDING) &&
4154 TAILQ_EMPTY(&asoc->strmout[tp1->rec.data.sid].outqueue)) {
4157 TAILQ_REMOVE(&asoc->sent_queue, tp1, sctp_next);
4158 if (tp1->data) {
4160 sctp_free_bufspace(stcb, asoc, tp1, 1);
4161 sctp_m_freem(tp1->data);
4162 tp1->data = NULL;
4167 tp1->rec.data.tsn,
4173 sctp_free_a_chunk(stcb, tp1, SCTP_SO_NOT_LOCKED);
4294 TAILQ_FOREACH(tp1, &asoc->sent_queue, sctp_next) {
4295 if (tp1->window_probe) {
4297 sctp_window_probe_recovery(stcb, asoc, tp1);
4341 TAILQ_FOREACH(tp1, &asoc->sent_queue, sctp_next) {
4342 if (tp1->sent < SCTP_DATAGRAM_RESEND) {
4343 sctp_flight_size_increase(tp1);
4344 sctp_total_flight_increase(stcb, tp1);
4345 } else if (tp1->sent == SCTP_DATAGRAM_RESEND) {
4474 struct sctp_tmit_chunk *tp1, *tp2;
4564 tp1 = TAILQ_LAST(&asoc->sent_queue,
4566 send_s = tp1->rec.data.tsn + 1;
4568 tp1 = NULL;
4581 if (tp1) {
4582 SCTP_PRINTF("Got send_s from tsn:%x + 1 of tp1: %p\n",
4583 tp1->rec.data.tsn, (void *)tp1);
4666 TAILQ_FOREACH(tp1, &asoc->sent_queue, sctp_next) {
4667 if (SCTP_TSN_GE(last_tsn, tp1->rec.data.tsn)) {
4668 if (tp1->sent != SCTP_DATAGRAM_UNSENT) {
4670 if (tp1->sent < SCTP_DATAGRAM_ACKED) {
4676 if ((tp1->whoTo->dest_state &
4678 (tp1->snd_count < 2)) {
4687 tp1->whoTo->dest_state &=
4690 if (tp1->sent < SCTP_DATAGRAM_RESEND) {
4693 tp1->whoTo->flight_size,
4694 tp1->book_size,
4695 (uint32_t)(uintptr_t)tp1->whoTo,
4696 tp1->rec.data.tsn);
4698 sctp_flight_size_decrease(tp1);
4699 sctp_total_flight_decrease(stcb, tp1);
4701 (*stcb->asoc.cc_functions.sctp_cwnd_update_tsn_acknowledged) (tp1->whoTo,
4702 tp1);
4705 tp1->whoTo->net_ack += tp1->send_size;
4708 this_sack_lowest_newack = tp1->rec.data.tsn;
4709 tp1->whoTo->saw_newack = 1;
4711 if (tp1->snd_count < 2) {
4716 tp1->whoTo->net_ack2 +=
4717 tp1->send_size;
4720 if (tp1->do_rtt) {
4724 tp1->whoTo,
4725 &tp1->sent_rcv_time,
4729 if (tp1->whoTo->rto_needed == 0) {
4730 tp1->whoTo->rto_needed = 1;
4732 tp1->do_rtt = 0;
4747 tp1->whoTo->new_pseudo_cumack = 1;
4748 tp1->whoTo->find_pseudo_cumack = 1;
4749 tp1->whoTo->find_rtx_pseudo_cumack = 1;
4755 tp1->rec.data.tsn,
4761 sctp_log_cwnd(stcb, tp1->whoTo, tp1->rec.data.tsn, SCTP_CWND_LOG_FROM_SACK);
4764 if (tp1->sent == SCTP_DATAGRAM_RESEND) {
4771 if (tp1->rec.data.chunk_was_revoked) {
4773 tp1->whoTo->cwnd -= tp1->book_size;
4774 tp1->rec.data.chunk_was_revoked = 0;
4776 if (tp1->sent != SCTP_DATAGRAM_NR_ACKED) {
4777 tp1->sent = SCTP_DATAGRAM_ACKED;
4839 TAILQ_FOREACH_SAFE(tp1, &asoc->sent_queue, sctp_next, tp2) {
4840 if (SCTP_TSN_GT(tp1->rec.data.tsn, cum_ack)) {
4843 if (tp1->sent != SCTP_DATAGRAM_NR_ACKED) {
4844 if (asoc->strmout[tp1->rec.data.sid].chunks_on_queues > 0) {
4845 asoc->strmout[tp1->rec.data.sid].chunks_on_queues--;
4848 panic("No chunks on the queues for sid %u.", tp1->rec.data.sid);
4852 if ((asoc->strmout[tp1->rec.data.sid].chunks_on_queues == 0) &&
4853 (asoc->strmout[tp1->rec.data.sid].state == SCTP_STREAM_RESET_PENDING) &&
4854 TAILQ_EMPTY(&asoc->strmout[tp1->rec.data.sid].outqueue)) {
4857 TAILQ_REMOVE(&asoc->sent_queue, tp1, sctp_next);
4858 if (PR_SCTP_ENABLED(tp1->flags)) {
4863 if (tp1->data) {
4865 sctp_free_bufspace(stcb, asoc, tp1, 1);
4866 sctp_m_freem(tp1->data);
4867 tp1->data = NULL;
4868 if (asoc->prsctp_supported && PR_SCTP_BUF_ENABLED(tp1->flags)) {
4875 tp1->rec.data.tsn,
4880 sctp_free_a_chunk(stcb, tp1, SCTP_SO_NOT_LOCKED);
4949 TAILQ_FOREACH(tp1, &asoc->sent_queue, sctp_next) {
4950 if (tp1->sent == SCTP_DATAGRAM_ACKED) {
4951 tp1->sent = SCTP_DATAGRAM_SENT;
4954 tp1->whoTo->flight_size,
4955 tp1->book_size,
4956 (uint32_t)(uintptr_t)tp1->whoTo,
4957 tp1->rec.data.tsn);
4959 sctp_flight_size_increase(tp1);
4960 sctp_total_flight_increase(stcb, tp1);
4961 tp1->rec.data.chunk_was_revoked = 1;
4968 tp1->whoTo->cwnd += tp1->book_size;
5197 TAILQ_FOREACH(tp1, &asoc->sent_queue, sctp_next) {
5198 if (tp1->window_probe) {
5199 sctp_window_probe_recovery(stcb, asoc, tp1);
5247 TAILQ_FOREACH(tp1, &asoc->sent_queue, sctp_next) {
5248 if (tp1->sent < SCTP_DATAGRAM_RESEND) {
5249 sctp_flight_size_increase(tp1);
5250 sctp_total_flight_increase(stcb, tp1);
5251 } else if (tp1->sent == SCTP_DATAGRAM_RESEND) {