sys/netinet/sctputil.c

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,