200 void sctp_outq_init(struct sctp_association *asoc, struct sctp_outq *q)  in sctp_outq_init()  argument
204 	q->asoc = asoc;  in sctp_outq_init()
221 	list_for_each_entry(transport, &q->asoc->peer.transport_addr_list,  in __sctp_outq_teardown()
277 	sctp_outq_init(q->asoc, q);  in sctp_outq_teardown()
290 	struct net *net = sock_net(q->asoc->base.sk);  in sctp_outq_tail()
311 		switch (q->asoc->state) {  in sctp_outq_tail()
402 				q->asoc->peer.rwnd += sctp_data_size(chunk);  in sctp_retransmit_mark()
422 			q->asoc->peer.rwnd += sctp_data_size(chunk);  in sctp_retransmit_mark()
467 	struct net *net = sock_net(q->asoc->base.sk);  in sctp_retransmit()
477 		if (transport == transport->asoc->peer.retran_path)  in sctp_retransmit()
478 			sctp_assoc_update_retran_path(transport->asoc);  in sctp_retransmit()
479 		transport->asoc->rtx_data_chunks +=  in sctp_retransmit()
480 			transport->asoc->unack_data;  in sctp_retransmit()
492 		transport->asoc->init_retries++;  in sctp_retransmit()
505 		sctp_generate_fwdtsn(q, q->asoc->ctsn_ack_point);  in sctp_retransmit()
515 		q->asoc->base.sk->sk_err = -error;  in sctp_retransmit()
653 			q->asoc->stats.rtxchunks++;  in sctp_outq_flush_rtx()
709 	struct sctp_association *asoc = q->asoc;  in sctp_outq_flush()  local
710 	__u16 sport = asoc->base.bind_addr.port;  in sctp_outq_flush()
711 	__u16 dport = asoc->peer.port;  in sctp_outq_flush()
712 	__u32 vtag = asoc->peer.i.init_tag;  in sctp_outq_flush()
745 		if (asoc->src_out_of_asoc_ok &&  in sctp_outq_flush()
770 				new_transport = sctp_assoc_lookup_paddr(asoc,  in sctp_outq_flush()
777 				new_transport = asoc->peer.active_path;  in sctp_outq_flush()
797 				new_transport = asoc->peer.active_path;  in sctp_outq_flush()
811 					   asoc->peer.ecn_capable);  in sctp_outq_flush()
834 				packet->vtag = asoc->c.my_vtag;  in sctp_outq_flush()
863 				asoc->stats.octrlchunks++;  in sctp_outq_flush()
879 	if (q->asoc->src_out_of_asoc_ok)  in sctp_outq_flush()
883 	switch (asoc->state) {  in sctp_outq_flush()
905 			if (asoc->peer.retran_path->state == SCTP_UNCONFIRMED)  in sctp_outq_flush()
907 			if (transport == asoc->peer.retran_path)  in sctp_outq_flush()
912 			transport = asoc->peer.retran_path;  in sctp_outq_flush()
921 					   asoc->peer.ecn_capable);  in sctp_outq_flush()
956 			    asoc->c.sinit_num_ostreams) {  in sctp_outq_flush()
979 				new_transport = asoc->peer.active_path;  in sctp_outq_flush()
997 						   asoc->peer.ecn_capable);  in sctp_outq_flush()
1034 				if (asoc->state == SCTP_STATE_SHUTDOWN_PENDING)  in sctp_outq_flush()
1037 					asoc->stats.ouodchunks++;  in sctp_outq_flush()
1039 					asoc->stats.oodchunks++;  in sctp_outq_flush()
1125 	struct sctp_association *asoc = q->asoc;  in sctp_outq_sack()  local
1135 	struct sctp_transport *primary = asoc->peer.primary_path;  in sctp_outq_sack()
1141 	transport_list = &asoc->peer.transport_addr_list;  in sctp_outq_sack()
1145 	asoc->stats.gapcnt += gap_ack_blocks;  in sctp_outq_sack()
1188 	if (TSN_lt(asoc->highest_sacked, highest_tsn))  in sctp_outq_sack()
1189 		asoc->highest_sacked = highest_tsn;  in sctp_outq_sack()
1217 	if (TSN_lt(asoc->ctsn_ack_point, sack_ctsn)) {  in sctp_outq_sack()
1218 		asoc->ctsn_ack_point = sack_ctsn;  in sctp_outq_sack()
1224 		if (asoc->fast_recovery && accum_moved)  in sctp_outq_sack()
1233 	sctp_sack_update_unack_data(asoc, sack);  in sctp_outq_sack()
1235 	ctsn = asoc->ctsn_ack_point;  in sctp_outq_sack()
1261 	asoc->peer.rwnd = sack_a_rwnd;  in sctp_outq_sack()
1267 		 "advertised peer ack point:0x%x\n", __func__, asoc, ctsn,  in sctp_outq_sack()
1268 		 asoc->adv_peer_ack_point);  in sctp_outq_sack()
1414 					    q->asoc->peer.primary_path->cacc.  in sctp_check_transmitted()
1468 			struct sctp_association *asoc = transport->asoc;  in sctp_check_transmitted()  local
1486 			transport->asoc->overall_error_count = 0;  in sctp_check_transmitted()
1495 			if (asoc->state == SCTP_STATE_SHUTDOWN_PENDING &&  in sctp_check_transmitted()
1496 			    del_timer(&asoc->timers  in sctp_check_transmitted()
1498 					sctp_association_put(asoc);  in sctp_check_transmitted()
1507 					transport->asoc,  in sctp_check_transmitted()
1535 			if (!q->asoc->peer.rwnd &&  in sctp_check_transmitted()
1537 			    (sack_ctsn+2 == q->asoc->next_tsn) &&  in sctp_check_transmitted()
1538 			    q->asoc->state < SCTP_STATE_SHUTDOWN_PENDING) {  in sctp_check_transmitted()
1542 				q->asoc->overall_error_count = 0;  in sctp_check_transmitted()
1581 	struct sctp_association *asoc = q->asoc;  in sctp_mark_missing()  local
1582 	struct sctp_transport *primary = asoc->peer.primary_path;  in sctp_mark_missing()
1686 	struct sctp_association *asoc = q->asoc;  in sctp_generate_fwdtsn()  local
1695 	if (!asoc->peer.prsctp_capable)  in sctp_generate_fwdtsn()
1704 	if (TSN_lt(asoc->adv_peer_ack_point, ctsn))  in sctp_generate_fwdtsn()
1705 		asoc->adv_peer_ack_point = ctsn;  in sctp_generate_fwdtsn()
1740 			if (TSN_lte(tsn, asoc->adv_peer_ack_point+1)) {  in sctp_generate_fwdtsn()
1741 				asoc->adv_peer_ack_point = tsn;  in sctp_generate_fwdtsn()
1779 	if (asoc->adv_peer_ack_point > ctsn)  in sctp_generate_fwdtsn()
1780 		ftsn_chunk = sctp_make_fwdtsn(asoc, asoc->adv_peer_ack_point,  in sctp_generate_fwdtsn()
1785 		SCTP_INC_STATS(sock_net(asoc->base.sk), SCTP_MIB_OUTCTRLCHUNKS);  in sctp_generate_fwdtsn()