Lines Matching defs:tp1
4978 struct sctp_tmit_chunk *tp1, int chk_cnt)
4980 if (tp1->data == NULL) {
4987 tp1->book_size,
4989 tp1->mbcnt);
4991 if (asoc->total_output_queue_size >= tp1->book_size) {
4992 atomic_add_int(&asoc->total_output_queue_size, -tp1->book_size);
4999 if (stcb->sctp_socket->so_snd.sb_cc >= tp1->book_size) {
5000 stcb->sctp_socket->so_snd.sb_cc -= tp1->book_size;
5010 sctp_release_pr_sctp_chunk(struct sctp_tcb *stcb, struct sctp_tmit_chunk *tp1,
5023 sid = tp1->rec.data.sid;
5024 mid = tp1->rec.data.mid;
5025 if (sent || !(tp1->rec.data.rcv_flags & SCTP_DATA_FIRST_FRAG)) {
5027 stcb->asoc.abandoned_sent[PR_SCTP_POLICY(tp1->flags)]++;
5030 stcb->asoc.strmout[sid].abandoned_sent[PR_SCTP_POLICY(tp1->flags)]++;
5034 stcb->asoc.abandoned_unsent[PR_SCTP_POLICY(tp1->flags)]++;
5037 stcb->asoc.strmout[sid].abandoned_unsent[PR_SCTP_POLICY(tp1->flags)]++;
5041 ret_sz += tp1->book_size;
5042 if (tp1->data != NULL) {
5043 if (tp1->sent < SCTP_DATAGRAM_RESEND) {
5044 sctp_flight_size_decrease(tp1);
5045 sctp_total_flight_decrease(stcb, tp1);
5047 sctp_free_bufspace(stcb, &stcb->asoc, tp1, 1);
5048 stcb->asoc.peers_rwnd += tp1->send_size;
5051 sctp_ulp_notify(SCTP_NOTIFY_SENT_DG_FAIL, stcb, 0, tp1, so_locked);
5053 sctp_ulp_notify(SCTP_NOTIFY_UNSENT_DG_FAIL, stcb, 0, tp1, so_locked);
5055 if (tp1->data) {
5056 sctp_m_freem(tp1->data);
5057 tp1->data = NULL;
5060 if (PR_SCTP_BUF_ENABLED(tp1->flags)) {
5064 tp1->sent = SCTP_FORWARD_TSN_SKIP;
5065 if ((tp1->rec.data.rcv_flags & SCTP_DATA_NOT_FRAG) ==
5070 } else if (tp1->rec.data.rcv_flags & SCTP_DATA_LAST_FRAG) {
5080 tp1 = TAILQ_NEXT(tp1, sctp_next);
5082 } while (tp1 && notdone);
5088 TAILQ_FOREACH_SAFE(tp1, &stcb->asoc.send_queue, sctp_next, tp2) {
5089 if ((tp1->rec.data.sid != sid) ||
5090 (!SCTP_MID_EQ(stcb->asoc.idata_supported, tp1->rec.data.mid, mid))) {
5098 chk = tp1;
5099 ret_sz += tp1->book_size;
5100 sctp_free_bufspace(stcb, &stcb->asoc, tp1, 1);
5102 sctp_ulp_notify(SCTP_NOTIFY_SENT_DG_FAIL, stcb, 0, tp1, so_locked);
5104 sctp_ulp_notify(SCTP_NOTIFY_UNSENT_DG_FAIL, stcb, 0, tp1, so_locked);
5106 if (tp1->data) {
5107 sctp_m_freem(tp1->data);
5108 tp1->data = NULL;
5111 tp1->book_size = 0;
5112 if (tp1->rec.data.rcv_flags & SCTP_DATA_LAST_FRAG) {
5116 tp1->sent = SCTP_FORWARD_TSN_SKIP;
5117 TAILQ_REMOVE(&stcb->asoc.send_queue, tp1, sctp_next);
5122 TAILQ_INSERT_TAIL(&stcb->asoc.sent_queue, tp1,