net/sctp/stream_interleave.c

25 					const struct sctp_association *asoc,
38 	retval = sctp_make_idata(asoc, flags, sizeof(dp) + len, gfp);
59 	stream = &chunk->asoc->stream;
98 	stream = &chunk->asoc->stream;
117 	stream = &chunk->asoc->stream;
192 	sin = sctp_stream_in(&ulpq->asoc->stream, event->stream);
244 	retval = sctp_make_reassembled_event(ulpq->asoc->base.net, &ulpq->reasm,
261 	struct sctp_association *asoc = ulpq->asoc;
272 	sin = sctp_stream_in(&ulpq->asoc->stream, event->stream);
326 	pd_point = sctp_sk(asoc->base.sk)->pd_point;
328 		retval = sctp_make_reassembled_event(asoc->base.net,
339 	retval = sctp_make_reassembled_event(asoc->base.net, &ulpq->reasm,
361 	sin = sctp_stream_in(&ulpq->asoc->stream, event->stream);
425 	stream  = &ulpq->asoc->stream;
454 	stream  = &ulpq->asoc->stream;
472 	struct sock *sk = ulpq->asoc->base.sk;
490 	if (!sctp_ulpevent_is_enabled(event, ulpq->asoc->subscribe))
570 	sin = sctp_stream_in(&ulpq->asoc->stream, event->stream);
625 	retval = sctp_make_reassembled_event(ulpq->asoc->base.net,
643 	struct sctp_association *asoc = ulpq->asoc;
654 	sin = sctp_stream_in(&ulpq->asoc->stream, event->stream);
709 	pd_point = sctp_sk(asoc->base.sk)->pd_point;
711 		retval = sctp_make_reassembled_event(asoc->base.net,
722 	retval = sctp_make_reassembled_event(asoc->base.net, &ulpq->reasm_uo,
744 	sin = sctp_stream_in(&ulpq->asoc->stream, event->stream);
768 		csin = sctp_stream_in(&ulpq->asoc->stream, cevent->stream);
808 	retval = sctp_make_reassembled_event(ulpq->asoc->base.net,
826 	event = sctp_ulpevent_make_rcvmsg(chunk->asoc, chunk, gfp);
874 		csin = sctp_stream_in(&ulpq->asoc->stream, cevent->stream);
915 	retval = sctp_make_reassembled_event(ulpq->asoc->base.net,
957 	struct sctp_association *asoc = ulpq->asoc;
964 	if (skb_queue_empty(&asoc->base.sk->sk_receive_queue)) {
981 	struct sock *sk = ulpq->asoc->base.sk;
984 	if (!sctp_ulpevent_type_enabled(ulpq->asoc->subscribe,
988 	ev = sctp_ulpevent_make_pdapi(ulpq->asoc, SCTP_PARTIAL_DELIVERY_ABORTED,
1004 	struct sctp_stream *stream = &ulpq->asoc->stream;
1055 	struct sctp_stream *stream = &ulpq->asoc->stream;
1101 	struct sctp_association *asoc = q->asoc;
1108 	if (!asoc->peer.prsctp_capable)
1111 	if (TSN_lt(asoc->adv_peer_ack_point, ctsn))
1112 		asoc->adv_peer_ack_point = ctsn;
1121 		} else if (TSN_lte(tsn, asoc->adv_peer_ack_point + 1)) {
1129 			asoc->adv_peer_ack_point = tsn;
1145 	if (asoc->adv_peer_ack_point > ctsn)
1146 		ftsn_chunk = sctp_make_ifwdtsn(asoc, asoc->adv_peer_ack_point,
1151 		SCTP_INC_STATS(asoc->base.net, SCTP_MIB_OUTCTRLCHUNKS);
1172 	incnt = chunk->asoc->stream.incnt;
1188 	incnt = chunk->asoc->stream.incnt;
1199 	sctp_tsnmap_skip(&ulpq->asoc->peer.tsn_map, ftsn);
1234 	sctp_tsnmap_skip(&ulpq->asoc->peer.tsn_map, ftsn);
1238 	if (ftsn == sctp_tsnmap_get_max_tsn_seen(&ulpq->asoc->peer.tsn_map))
1254 	struct sctp_stream_in *sin = sctp_stream_in(&ulpq->asoc->stream, sid);
1255 	struct sctp_stream *stream  = &ulpq->asoc->stream;
1348 	struct sctp_association *asoc;
1350 	asoc = container_of(stream, struct sctp_association, stream);
1351 	stream->si = asoc->peer.intl_capable ? &sctp_stream_interleave_1