210 	struct sctp_chunk *chunk, *tmp;  in __sctp_outq_teardown()  local
216 			chunk = list_entry(lchunk, struct sctp_chunk,  in __sctp_outq_teardown()
219 			sctp_chunk_fail(chunk, q->error);  in __sctp_outq_teardown()
220 			sctp_chunk_free(chunk);  in __sctp_outq_teardown()
227 		chunk = list_entry(lchunk, struct sctp_chunk,  in __sctp_outq_teardown()
229 		sctp_chunk_fail(chunk, q->error);  in __sctp_outq_teardown()
230 		sctp_chunk_free(chunk);  in __sctp_outq_teardown()
236 		chunk = list_entry(lchunk, struct sctp_chunk,  in __sctp_outq_teardown()
238 		sctp_chunk_fail(chunk, q->error);  in __sctp_outq_teardown()
239 		sctp_chunk_free(chunk);  in __sctp_outq_teardown()
245 		chunk = list_entry(lchunk, struct sctp_chunk,  in __sctp_outq_teardown()
247 		sctp_chunk_fail(chunk, q->error);  in __sctp_outq_teardown()
248 		sctp_chunk_free(chunk);  in __sctp_outq_teardown()
252 	while ((chunk = sctp_outq_dequeue_data(q)) != NULL) {  in __sctp_outq_teardown()
253 		sctp_sched_dequeue_done(q, chunk);  in __sctp_outq_teardown()
256 		sctp_chunk_fail(chunk, q->error);  in __sctp_outq_teardown()
257 		sctp_chunk_free(chunk);  in __sctp_outq_teardown()
261 	list_for_each_entry_safe(chunk, tmp, &q->control_chunk_list, list) {  in __sctp_outq_teardown()
262 		list_del_init(&chunk->list);  in __sctp_outq_teardown()
263 		sctp_chunk_free(chunk);  in __sctp_outq_teardown()
281 void sctp_outq_tail(struct sctp_outq *q, struct sctp_chunk *chunk, gfp_t gfp)  in sctp_outq_tail()  argument
285 	pr_debug("%s: outq:%p, chunk:%p[%s]\n", __func__, q, chunk,  in sctp_outq_tail()
286 		 chunk && chunk->chunk_hdr ?  in sctp_outq_tail()
287 		 sctp_cname(SCTP_ST_CHUNK(chunk->chunk_hdr->type)) :  in sctp_outq_tail()
293 	if (sctp_chunk_is_data(chunk)) {  in sctp_outq_tail()
295 			 __func__, q, chunk, chunk && chunk->chunk_hdr ?  in sctp_outq_tail()
296 			 sctp_cname(SCTP_ST_CHUNK(chunk->chunk_hdr->type)) :  in sctp_outq_tail()
299 		sctp_outq_tail_data(q, chunk);  in sctp_outq_tail()
300 		if (chunk->asoc->peer.prsctp_capable &&  in sctp_outq_tail()
301 		    SCTP_PR_PRIO_ENABLED(chunk->sinfo.sinfo_flags))  in sctp_outq_tail()
302 			chunk->asoc->sent_cnt_removable++;  in sctp_outq_tail()
303 		if (chunk->chunk_hdr->flags & SCTP_DATA_UNORDERED)  in sctp_outq_tail()
308 		list_add_tail(&chunk->list, &q->control_chunk_list);  in sctp_outq_tail()
455 	struct sctp_chunk *chunk;  in sctp_retransmit_mark()  local
459 		chunk = list_entry(lchunk, struct sctp_chunk,  in sctp_retransmit_mark()
463 		if (sctp_chunk_abandoned(chunk)) {  in sctp_retransmit_mark()
472 			if (!chunk->tsn_gap_acked) {  in sctp_retransmit_mark()
473 				if (chunk->transport)  in sctp_retransmit_mark()
474 					chunk->transport->flight_size -=  in sctp_retransmit_mark()
475 							sctp_data_size(chunk);  in sctp_retransmit_mark()
476 				q->outstanding_bytes -= sctp_data_size(chunk);  in sctp_retransmit_mark()
477 				q->asoc->peer.rwnd += sctp_data_size(chunk);  in sctp_retransmit_mark()
487 			    (chunk->fast_retransmit == SCTP_NEED_FRTX)) ||  in sctp_retransmit_mark()
488 		    (reason != SCTP_RTXR_FAST_RTX  && !chunk->tsn_gap_acked)) {  in sctp_retransmit_mark()
497 			q->asoc->peer.rwnd += sctp_data_size(chunk);  in sctp_retransmit_mark()
498 			q->outstanding_bytes -= sctp_data_size(chunk);  in sctp_retransmit_mark()
499 			if (chunk->transport)  in sctp_retransmit_mark()
500 				transport->flight_size -= sctp_data_size(chunk);  in sctp_retransmit_mark()
507 			chunk->tsn_missing_report = 0;  in sctp_retransmit_mark()
515 			if (chunk->rtt_in_progress) {  in sctp_retransmit_mark()
516 				chunk->rtt_in_progress = 0;  in sctp_retransmit_mark()
599 	struct sctp_chunk *chunk, *chunk1;  in __sctp_outq_flush_rtx()  local
633 	list_for_each_entry_safe(chunk, chunk1, lqueue, transmitted_list) {  in __sctp_outq_flush_rtx()
635 		if (sctp_chunk_abandoned(chunk)) {  in __sctp_outq_flush_rtx()
636 			list_del_init(&chunk->transmitted_list);  in __sctp_outq_flush_rtx()
638 					 &chunk->transmitted_list);  in __sctp_outq_flush_rtx()
647 		if (chunk->tsn_gap_acked) {  in __sctp_outq_flush_rtx()
648 			list_move_tail(&chunk->transmitted_list,  in __sctp_outq_flush_rtx()
656 		if (fast_rtx && !chunk->fast_retransmit)  in __sctp_outq_flush_rtx()
661 		status = sctp_packet_append_chunk(pkt, chunk);  in __sctp_outq_flush_rtx()
713 			list_move_tail(&chunk->transmitted_list,  in __sctp_outq_flush_rtx()
719 			if (chunk->fast_retransmit == SCTP_NEED_FRTX)  in __sctp_outq_flush_rtx()
720 				chunk->fast_retransmit = SCTP_DONT_FRTX;  in __sctp_outq_flush_rtx()
765 				 struct sctp_chunk *chunk, gfp_t gfp)  in sctp_packet_singleton()  argument
775 	sctp_packet_append_chunk(&singleton, chunk);  in sctp_packet_singleton()
794 				       struct sctp_chunk *chunk)  in sctp_outq_select_transport()  argument
796 	struct sctp_transport *new_transport = chunk->transport;  in sctp_outq_select_transport()
799 		if (!sctp_chunk_is_data(chunk)) {  in sctp_outq_select_transport()
809 			if (ctx->transport && sctp_cmp_addr_exact(&chunk->dest,  in sctp_outq_select_transport()
814 								  &chunk->dest);  in sctp_outq_select_transport()
842 			type = chunk->chunk_hdr->type;  in sctp_outq_select_transport()
874 	struct sctp_chunk *chunk, *tmp;  in sctp_outq_flush_ctrl()  local
878 	list_for_each_entry_safe(chunk, tmp, &ctx->q->control_chunk_list, list) {  in sctp_outq_flush_ctrl()
888 		    chunk->chunk_hdr->type != SCTP_CID_ASCONF)  in sctp_outq_flush_ctrl()
891 		list_del_init(&chunk->list);  in sctp_outq_flush_ctrl()
896 		sctp_outq_select_transport(ctx, chunk);  in sctp_outq_flush_ctrl()
898 		switch (chunk->chunk_hdr->type) {  in sctp_outq_flush_ctrl()
907 			error = sctp_packet_singleton(ctx->transport, chunk,  in sctp_outq_flush_ctrl()
916 			if (sctp_test_T_bit(chunk))  in sctp_outq_flush_ctrl()
943 			status = sctp_packet_transmit_chunk(ctx->packet, chunk,  in sctp_outq_flush_ctrl()
947 				list_add(&chunk->list, &ctx->q->control_chunk_list);  in sctp_outq_flush_ctrl()
956 			if (chunk->chunk_hdr->type == SCTP_CID_FWD_TSN ||  in sctp_outq_flush_ctrl()
957 			    chunk->chunk_hdr->type == SCTP_CID_I_FWD_TSN) {  in sctp_outq_flush_ctrl()
962 			if (chunk == ctx->asoc->strreset_chunk)  in sctp_outq_flush_ctrl()
1024 	struct sctp_chunk *chunk;  in sctp_outq_flush_data()  local
1068 	while ((chunk = sctp_outq_dequeue_data(ctx->q)) != NULL) {  in sctp_outq_flush_data()
1069 		__u32 sid = ntohs(chunk->subh.data_hdr->stream);  in sctp_outq_flush_data()
1073 		if (sctp_chunk_abandoned(chunk)) {  in sctp_outq_flush_data()
1074 			sctp_sched_dequeue_done(ctx->q, chunk);  in sctp_outq_flush_data()
1075 			sctp_chunk_fail(chunk, 0);  in sctp_outq_flush_data()
1076 			sctp_chunk_free(chunk);  in sctp_outq_flush_data()
1081 			sctp_outq_head_data(ctx->q, chunk);  in sctp_outq_flush_data()
1085 		sctp_outq_select_transport(ctx, chunk);  in sctp_outq_flush_data()
1088 			 __func__, ctx->q, chunk, chunk && chunk->chunk_hdr ?  in sctp_outq_flush_data()
1089 			 sctp_cname(SCTP_ST_CHUNK(chunk->chunk_hdr->type)) :  in sctp_outq_flush_data()
1090 			 "illegal chunk", ntohl(chunk->subh.data_hdr->tsn),  in sctp_outq_flush_data()
1091 			 chunk->skb ? chunk->skb->head : NULL, chunk->skb ?  in sctp_outq_flush_data()
1092 			 refcount_read(&chunk->skb->users) : -1);  in sctp_outq_flush_data()
1095 		status = sctp_packet_transmit_chunk(ctx->packet, chunk, 0,  in sctp_outq_flush_data()
1102 				 __func__, ntohl(chunk->subh.data_hdr->tsn),  in sctp_outq_flush_data()
1105 			sctp_outq_head_data(ctx->q, chunk);  in sctp_outq_flush_data()
1114 			chunk->chunk_hdr->flags |= SCTP_DATA_SACK_IMM;  in sctp_outq_flush_data()
1115 		if (chunk->chunk_hdr->flags & SCTP_DATA_UNORDERED)  in sctp_outq_flush_data()
1123 		sctp_sched_dequeue_done(ctx->q, chunk);  in sctp_outq_flush_data()
1125 		list_add_tail(&chunk->transmitted_list,  in sctp_outq_flush_data()
1225 int sctp_outq_sack(struct sctp_outq *q, struct sctp_chunk *chunk)  in sctp_outq_sack()  argument
1228 	struct sctp_sackhdr *sack = chunk->subh.sack_hdr;  in sctp_outq_sack()
1313 				       transport, &chunk->source, sack,  in sctp_outq_sack()
1353 			    SCTP_PR_PRIO_ENABLED(chunk->sinfo.sinfo_flags))  in sctp_outq_sack()
1689 	struct sctp_chunk *chunk;  in sctp_mark_missing()  local
1695 	list_for_each_entry(chunk, transmitted_queue, transmitted_list) {  in sctp_mark_missing()
1697 		tsn = ntohl(chunk->subh.data_hdr->tsn);  in sctp_mark_missing()
1706 		if (chunk->fast_retransmit == SCTP_CAN_FRTX &&  in sctp_mark_missing()
1707 		    !chunk->tsn_gap_acked &&  in sctp_mark_missing()
1714 						chunk->transport,  in sctp_mark_missing()
1716 				chunk->tsn_missing_report++;  in sctp_mark_missing()
1719 					 __func__, tsn, chunk->tsn_missing_report);  in sctp_mark_missing()
1729 		if (chunk->tsn_missing_report >= 3) {  in sctp_mark_missing()
1730 			chunk->fast_retransmit = SCTP_NEED_FRTX;  in sctp_mark_missing()
1804 	struct sctp_chunk *chunk;  in sctp_generate_fwdtsn()  local
1841 		chunk = list_entry(lchunk, struct sctp_chunk,  in sctp_generate_fwdtsn()
1843 		tsn = ntohl(chunk->subh.data_hdr->tsn);  in sctp_generate_fwdtsn()
1850 			sctp_chunk_free(chunk);  in sctp_generate_fwdtsn()
1854 				if (chunk->chunk_hdr->flags &  in sctp_generate_fwdtsn()
1859 						chunk->subh.data_hdr->stream);  in sctp_generate_fwdtsn()
1861 					chunk->subh.data_hdr->stream;  in sctp_generate_fwdtsn()
1863 					 chunk->subh.data_hdr->ssn;  in sctp_generate_fwdtsn()