42 				 struct sctp_association *asoc)  in sctp_ulpq_init()  argument
46 	ulpq->asoc = asoc;  in sctp_ulpq_init()
93 	event = sctp_ulpevent_make_rcvmsg(chunk->asoc, chunk, gfp);  in sctp_ulpq_tail_data()
128 int sctp_clear_pd(struct sock *sk, struct sctp_association *asoc)  in sctp_clear_pd()  argument
147 		if (!skb_queue_empty(&sp->pd_lobby) && asoc) {  in sctp_clear_pd()
153 				if (event->asoc == asoc) {  in sctp_clear_pd()
168 	struct sctp_sock *sp = sctp_sk(ulpq->asoc->base.sk);  in sctp_ulpq_set_pd()
179 	return sctp_clear_pd(ulpq->asoc->base.sk, ulpq->asoc);  in sctp_ulpq_clear_pd()
184 	struct sock *sk = ulpq->asoc->base.sk;  in sctp_ulpq_tail_event()
207 	if (!sctp_ulpevent_is_enabled(event, ulpq->asoc->subscribe))  in sctp_ulpq_tail_event()
409 	struct sctp_association *asoc;  in sctp_ulpq_retrieve_reassembled()  local
475 	asoc = ulpq->asoc;  in sctp_ulpq_retrieve_reassembled()
482 		if (!sctp_sk(asoc->base.sk)->frag_interleave &&  in sctp_ulpq_retrieve_reassembled()
483 		    atomic_read(&sctp_sk(asoc->base.sk)->pd_mode))  in sctp_ulpq_retrieve_reassembled()
487 		pd_point = sctp_sk(asoc->base.sk)->pd_point;  in sctp_ulpq_retrieve_reassembled()
489 			retval = sctp_make_reassembled_event(asoc->base.net,  in sctp_ulpq_retrieve_reassembled()
499 	retval = sctp_make_reassembled_event(ulpq->asoc->base.net,  in sctp_ulpq_retrieve_reassembled()
565 	retval = sctp_make_reassembled_event(ulpq->asoc->base.net, &ulpq->reasm,  in sctp_ulpq_retrieve_partial()
598 		ctsnap = sctp_tsnmap_get_ctsn(&ulpq->asoc->peer.tsn_map);  in sctp_ulpq_reasm()
666 	retval = sctp_make_reassembled_event(ulpq->asoc->base.net, &ulpq->reasm,  in sctp_ulpq_retrieve_first()
755 	stream  = &ulpq->asoc->stream;  in sctp_ulpq_retrieve_ordered()
849 	stream  = &ulpq->asoc->stream;  in sctp_ulpq_order()
884 	stream = &ulpq->asoc->stream;  in sctp_ulpq_reap_ordered()
949 	stream  = &ulpq->asoc->stream;  in sctp_ulpq_skip()
973 	tsnmap = &ulpq->asoc->peer.tsn_map;  in sctp_ulpq_renege_list()
1029 	struct sctp_association *asoc;  in sctp_ulpq_partial_delivery()  local
1034 	asoc = ulpq->asoc;  in sctp_ulpq_partial_delivery()
1035 	sp = sctp_sk(asoc->base.sk);  in sctp_ulpq_partial_delivery()
1046 	skb = skb_peek(&asoc->ulpq.reasm);  in sctp_ulpq_partial_delivery()
1049 		if (!TSN_lte(ctsn, sctp_tsnmap_get_ctsn(&asoc->peer.tsn_map)))  in sctp_ulpq_partial_delivery()
1078 	struct sctp_association *asoc = ulpq->asoc;  in sctp_ulpq_renege()  local
1085 	if (skb_queue_empty(&asoc->base.sk->sk_receive_queue)) {  in sctp_ulpq_renege()
1091 	if (sk_rmem_schedule(asoc->base.sk, chunk->skb, needed) &&  in sctp_ulpq_renege()
1104 	sk_mem_reclaim(asoc->base.sk);  in sctp_ulpq_renege()
1121 	sk = ulpq->asoc->base.sk;  in sctp_ulpq_abort_pd()
1123 	if (sctp_ulpevent_type_enabled(ulpq->asoc->subscribe,  in sctp_ulpq_abort_pd()
1125 		ev = sctp_ulpevent_make_pdapi(ulpq->asoc,  in sctp_ulpq_abort_pd()