Lines Matching defs:tp1
2707 struct sctp_tmit_chunk *tp1;
2725 tp1 = NULL;
2741 if (tp1 == NULL) {
2742 tp1 = TAILQ_FIRST(&asoc->sent_queue);
2766 tp1 = TAILQ_FIRST(&asoc->sent_queue);
2771 while (tp1) {
2773 if (tp1->rec.data.doing_fast_retransmit)
2777 if (tp1->rec.data.TSN_seq == j) {
2778 if (tp1->sent != SCTP_DATAGRAM_UNSENT) {
2781 if (tp1->sent < SCTP_DATAGRAM_ACKED) {
2792 if (compare_with_wrap(tp1->rec.data.TSN_seq,
2796 tp1->rec.data.TSN_seq;
2798 sctp_flight_size_decrease(tp1);
2800 sctp_total_flight_decrease(stcb, tp1);
2802 if (tp1->snd_count < 2) {
2804 tp1->whoTo->net_ack2 +=
2805 tp1->send_size;
2808 if (tp1->do_rtt) {
2809 tp1->whoTo->RTO =
2812 tp1->whoTo,
2813 &tp1->sent_rcv_time);
2814 tp1->whoTo->rto_pending = 0;
2815 tp1->do_rtt = 0;
2819 if (tp1->sent <= SCTP_DATAGRAM_RESEND &&
2820 tp1->sent != SCTP_DATAGRAM_UNSENT &&
2821 compare_with_wrap(tp1->rec.data.TSN_seq,
2825 tp1->rec.data.TSN_seq;
2827 tp1->whoTo->cacc_saw_newack = 1;
2830 if (tp1->sent == SCTP_DATAGRAM_RESEND) {
2844 (*ecn_seg_sums) += tp1->rec.data.ect_nonce;
2846 tp1->sent = SCTP_DATAGRAM_MARKED;
2849 } /* if (tp1->TSN_seq == j) */
2850 if (compare_with_wrap(tp1->rec.data.TSN_seq, j,
2853 tp1 = TAILQ_NEXT(tp1, sctp_next);
2854 }/* end while (tp1) */
2869 struct sctp_tmit_chunk *tp1;
2872 tp1 = TAILQ_FIRST(&asoc->sent_queue);
2873 while (tp1) {
2874 if (compare_with_wrap(tp1->rec.data.TSN_seq, cum_ack,
2881 if (tp1->sent == SCTP_DATAGRAM_ACKED) {
2888 tp1->sent = SCTP_DATAGRAM_SENT;
2890 } else if (tp1->sent == SCTP_DATAGRAM_MARKED) {
2892 tp1->sent = SCTP_DATAGRAM_ACKED;
2895 if (compare_with_wrap(tp1->rec.data.TSN_seq, biggest_tsn_acked,
2900 if (tp1->sent == SCTP_DATAGRAM_UNSENT)
2902 tp1 = TAILQ_NEXT(tp1, sctp_next);
2913 tp1 = TAILQ_FIRST(&asoc->send_queue);
2914 if (tp1 == NULL) {
2917 asoc->nonce_resync_tsn = tp1->rec.data.TSN_seq;
2932 struct sctp_tmit_chunk *tp1;
2945 tp1 = TAILQ_FIRST(&stcb->asoc.send_queue);
2946 if (tp1 == NULL) {
2949 sending_seq = tp1->rec.data.TSN_seq;
2961 tp1 = TAILQ_FIRST(&asoc->sent_queue);
2962 while (tp1) {
2964 if (compare_with_wrap(tp1->rec.data.TSN_seq, biggest_tsn_acked,
2966 tp1->sent == SCTP_DATAGRAM_UNSENT) {
2970 if ((tp1->flags & (SCTP_PR_SCTP_ENABLED|SCTP_PR_SCTP_BUFFER)) ==
2972 tp1->sent < SCTP_DATAGRAM_ACKED) {
2975 if (timercmp(&now, &tp1->rec.data.timetodrop, >))
2977 if (timevalcmp(&now, &tp1->rec.data.timetodrop, >))
2981 if (tp1->data != NULL) {
2982 sctp_release_pr_sctp_chunk(stcb, tp1,
2986 tp1 = TAILQ_NEXT(tp1, sctp_next);
2991 if (compare_with_wrap(tp1->rec.data.TSN_seq,
2996 if (tp1->sent >= SCTP_DATAGRAM_RESEND) {
2999 tp1 = TAILQ_NEXT(tp1, sctp_next);
3003 if (tp1->whoTo != asoc->primary_destination) {
3008 tp1 = TAILQ_NEXT(tp1, sctp_next);
3012 if (tp1->whoTo->cacc_saw_newack == 0) {
3017 tp1 = TAILQ_NEXT(tp1, sctp_next);
3023 tp1->rec.data.TSN_seq, MAX_TSN))) {
3028 tp1 = TAILQ_NEXT(tp1, sctp_next);
3042 tp1->sent++;
3043 } else if (tp1->rec.data.doing_fast_retransmit) {
3064 tp1->rec.data.fast_retran_tsn, MAX_TSN)) ||
3066 tp1->rec.data.fast_retran_tsn)) {
3074 tp1->rec.data.TSN_seq,
3075 tp1->rec.data.fast_retran_tsn,
3078 tp1->sent++;
3082 } else if (compare_with_wrap(tp1->rec.data.TSN_seq,
3093 tp1->sent++;
3095 if (tp1->sent == SCTP_DATAGRAM_RESEND) {
3100 sctp_log_fr(tp1->rec.data.TSN_seq, tp1->snd_count,
3110 alt = sctp_find_alternate_net(stcb, tp1->whoTo);
3117 alt = tp1->whoTo;
3119 tp1->rec.data.doing_fast_retransmit = 1;
3129 tp1->rec.data.fast_retran_tsn = sending_seq - 1;
3141 tp1->rec.data.fast_retran_tsn =
3144 if (tp1->do_rtt) {
3149 tp1->whoTo->rto_pending = 0;
3150 tp1->do_rtt = 0;
3154 tp1->whoTo->net_ack++;
3155 sctp_flight_size_decrease(tp1);
3158 asoc->peers_rwnd , tp1->send_size, sctp_peer_chunk_oh);
3161 asoc->peers_rwnd += (tp1->send_size + sctp_peer_chunk_oh);
3164 sctp_total_flight_decrease(stcb, tp1);
3165 if (alt != tp1->whoTo) {
3167 sctp_free_remote_addr(tp1->whoTo);
3168 tp1->whoTo = alt;
3172 tp1 = TAILQ_NEXT(tp1, sctp_next);
3173 } /* while (tp1) */
3192 struct sctp_tmit_chunk *tp1, *tp2, *a_adv=NULL;
3199 tp1 = TAILQ_FIRST(&asoc->sent_queue);
3200 while (tp1) {
3201 if (tp1->sent != SCTP_FORWARD_TSN_SKIP &&
3202 tp1->sent != SCTP_DATAGRAM_RESEND) {
3206 if ((tp1->flags & SCTP_PR_SCTP_ENABLED) == 0) {
3217 tp2 = TAILQ_NEXT(tp1, sctp_next);
3225 if (tp1->sent == SCTP_DATAGRAM_RESEND &&
3226 (tp1->flags & SCTP_PR_SCTP_BUFFER) == 0) {
3232 if (timercmp(&now, &tp1->rec.data.timetodrop, >))
3234 if (timevalcmp(&now, &tp1->rec.data.timetodrop, >))
3238 if (tp1->data) {
3239 sctp_release_pr_sctp_chunk(stcb, tp1,
3256 if (tp1->sent == SCTP_FORWARD_TSN_SKIP) {
3258 asoc->advanced_peer_ack_point = tp1->rec.data.TSN_seq;
3259 a_adv = tp1;
3265 if (tp1->data) {
3266 sctp_free_bufspace(stcb, asoc, tp1);
3280 tp1);
3281 sctp_m_freem(tp1->data);
3282 tp1->data = NULL;
3291 * If we hit here we just dumped tp1, move to next
3294 tp1 = tp2;
3471 struct sctp_tmit_chunk *tp1, *tp2;
3549 tp1 = TAILQ_FIRST(&asoc->send_queue);
3550 send_s = tp1->rec.data.TSN_seq;
3653 tp1 = TAILQ_FIRST(&asoc->sent_queue);
3654 while (tp1) {
3655 if (compare_with_wrap(last_tsn, tp1->rec.data.TSN_seq,
3657 last_tsn == tp1->rec.data.TSN_seq) {
3658 if (tp1->sent != SCTP_DATAGRAM_UNSENT) {
3660 asoc->nonce_sum_expect_base += tp1->rec.data.ect_nonce;
3662 if (tp1->sent < SCTP_DATAGRAM_ACKED) {
3668 if ((tp1->whoTo->dest_state &
3670 (tp1->snd_count < 2) ) {
3678 tp1->whoTo->dest_state &=
3681 sctp_flight_size_decrease(tp1);
3682 sctp_total_flight_decrease(stcb, tp1);
3683 tp1->whoTo->net_ack += tp1->send_size;
3684 if (tp1->snd_count < 2) {
3686 tp1->whoTo->net_ack2 +=
3687 tp1->send_size;
3689 if (tp1->do_rtt) {
3690 tp1->whoTo->RTO =
3692 asoc, tp1->whoTo,
3693 &tp1->sent_rcv_time);
3694 tp1->whoTo->rto_pending = 0;
3695 tp1->do_rtt = 0;
3699 if (tp1->sent == SCTP_DATAGRAM_RESEND) {
3712 tp1->sent = SCTP_DATAGRAM_ACKED;
3717 tp1 = TAILQ_NEXT(tp1, sctp_next);
3806 tp1 = TAILQ_FIRST(&asoc->sent_queue);
3808 if (compare_with_wrap(tp1->rec.data.TSN_seq, cum_ack,
3812 if (tp1->sent == SCTP_DATAGRAM_UNSENT) {
3816 tp2 = TAILQ_NEXT(tp1, sctp_next);
3817 TAILQ_REMOVE(&asoc->sent_queue, tp1, sctp_next);
3818 if (tp1->data) {
3819 sctp_free_bufspace(stcb, asoc, tp1);
3828 sctp_m_freem(tp1->data);
3829 if (tp1->flags & SCTP_PR_SCTP_BUFFER) {
3834 tp1->data = NULL;
3836 sctp_free_remote_addr(tp1->whoTo);
3843 SCTP_ZONE_FREE(sctppcbinfo.ipi_zone_chunk, tp1);
3846 tp1 = tp2;
3847 } while (tp1 != NULL);