net/sctp/outqueue.c

42 static int sctp_acked(struct sctp_sackhdr *sack, __u32 tsn);
153 static inline int sctp_cacc_skip_3_2(struct sctp_transport *primary, __u32 tsn)
156 	    TSN_lt(tsn, primary->cacc.next_tsn_at_change))
178 				 __u32 tsn)
182 	     sctp_cacc_skip_3_2(primary, tsn)))
327 	ntsn = ntohl(nchunk->subh.data_hdr->tsn);
331 		ltsn = ntohl(lchunk->subh.data_hdr->tsn);
1103 		pr_debug("%s: outq:%p, chunk:%p[%s], tx-tsn:0x%x skb->head:%p skb->users:%d\n",
1106 			 "illegal chunk", ntohl(chunk->subh.data_hdr->tsn),
1117 			pr_debug("%s: could not transmit tsn:0x%x, status:%d\n",
1118 				 __func__, ntohl(chunk->subh.data_hdr->tsn),
1255 	__u32 sack_ctsn, ctsn, tsn;
1375 		tsn = ntohl(tchunk->subh.data_hdr->tsn);
1376 		if (TSN_lte(tsn, ctsn)) {
1403 	pr_debug("%s: sack cumulative tsn ack:0x%x\n", __func__, sack_ctsn);
1404 	pr_debug("%s: cumulative tsn ack of assoc:%p is 0x%x, "
1445 	__u32 tsn;
1479 		tsn = ntohl(tchunk->subh.data_hdr->tsn);
1480 		if (sctp_acked(sack, tsn)) {
1506 				if (TSN_lte(tsn, sack_ctsn)) {
1536 				if (TSN_lt(*highest_new_tsn_in_sack, tsn))
1537 					*highest_new_tsn_in_sack = tsn;
1544 			if (TSN_lte(tsn, sack_ctsn)) {
1580 					 __func__, tsn);
1716 	__u32 tsn;
1723 		tsn = ntohl(chunk->subh.data_hdr->tsn);
1734 		    TSN_lt(tsn, highest_new_tsn_in_sack)) {
1741 						count_of_newacks, tsn)) {
1744 				pr_debug("%s: tsn:0x%x missing counter:%d\n",
1745 					 __func__, tsn, chunk->tsn_missing_report);
1773 static int sctp_acked(struct sctp_sackhdr *sack, __u32 tsn)
1780 	if (TSN_lte(tsn, ctsn))
1797 	tsn_offset = tsn - ctsn;
1829 	__u32 tsn;
1869 		tsn = ntohl(chunk->subh.data_hdr->tsn);
1874 		if (TSN_lte(tsn, ctsn)) {
1878 			if (TSN_lte(tsn, asoc->adv_peer_ack_point+1)) {
1879 				asoc->adv_peer_ack_point = tsn;