net/sctp/ulpqueue.c

41 void sctp_ulpq_init(struct sctp_ulpq *ulpq, struct sctp_association *asoc)
45 	ulpq->asoc = asoc;
90 	event = sctp_ulpevent_make_rcvmsg(chunk->asoc, chunk, gfp);
125 int sctp_clear_pd(struct sock *sk, struct sctp_association *asoc)
144 		if (!skb_queue_empty(&sp->pd_lobby) && asoc) {
150 				if (event->asoc == asoc) {
165 	struct sctp_sock *sp = sctp_sk(ulpq->asoc->base.sk);
176 	return sctp_clear_pd(ulpq->asoc->base.sk, ulpq->asoc);
181 	struct sock *sk = ulpq->asoc->base.sk;
204 	if (!sctp_ulpevent_is_enabled(event, ulpq->asoc->subscribe))
403 	struct sctp_association *asoc;
469 	asoc = ulpq->asoc;
476 		if (!sctp_sk(asoc->base.sk)->frag_interleave &&
477 		    atomic_read(&sctp_sk(asoc->base.sk)->pd_mode))
481 		pd_point = sctp_sk(asoc->base.sk)->pd_point;
483 			retval = sctp_make_reassembled_event(asoc->base.net,
493 	retval = sctp_make_reassembled_event(ulpq->asoc->base.net,
559 	retval = sctp_make_reassembled_event(ulpq->asoc->base.net, &ulpq->reasm,
592 		ctsnap = sctp_tsnmap_get_ctsn(&ulpq->asoc->peer.tsn_map);
660 	retval = sctp_make_reassembled_event(ulpq->asoc->base.net, &ulpq->reasm,
749 	stream  = &ulpq->asoc->stream;
843 	stream  = &ulpq->asoc->stream;
878 	stream = &ulpq->asoc->stream;
943 	stream  = &ulpq->asoc->stream;
967 	tsnmap = &ulpq->asoc->peer.tsn_map;
1023 	struct sctp_association *asoc;
1028 	asoc = ulpq->asoc;
1029 	sp = sctp_sk(asoc->base.sk);
1040 	skb = skb_peek(&asoc->ulpq.reasm);
1043 		if (!TSN_lte(ctsn, sctp_tsnmap_get_ctsn(&asoc->peer.tsn_map)))
1072 	struct sctp_association *asoc = ulpq->asoc;
1079 	if (skb_queue_empty(&asoc->base.sk->sk_receive_queue)) {
1085 	if (sk_rmem_schedule(asoc->base.sk, chunk->skb, needed) &&
1111 	sk = ulpq->asoc->base.sk;
1113 	if (sctp_ulpevent_type_enabled(ulpq->asoc->subscribe,
1115 		ev = sctp_ulpevent_make_pdapi(ulpq->asoc,