57 	struct sctp_ulpevent *event;  in sctp_ulpq_flush()  local
60 		event = sctp_skb2event(skb);  in sctp_ulpq_flush()
61 		sctp_ulpevent_free(event);  in sctp_ulpq_flush()
65 		event = sctp_skb2event(skb);  in sctp_ulpq_flush()
66 		sctp_ulpevent_free(event);  in sctp_ulpq_flush()
70 		event = sctp_skb2event(skb);  in sctp_ulpq_flush()
71 		sctp_ulpevent_free(event);  in sctp_ulpq_flush()
86 	struct sctp_ulpevent *event;  in sctp_ulpq_tail_data()  local
90 	event = sctp_ulpevent_make_rcvmsg(chunk->asoc, chunk, gfp);  in sctp_ulpq_tail_data()
91 	if (!event)  in sctp_ulpq_tail_data()
94 	event->ssn = ntohs(chunk->subh.data_hdr->ssn);  in sctp_ulpq_tail_data()
95 	event->ppid = chunk->subh.data_hdr->ppid;  in sctp_ulpq_tail_data()
98 	event = sctp_ulpq_reasm(ulpq, event);  in sctp_ulpq_tail_data()
101 	if (event) {  in sctp_ulpq_tail_data()
104 		__skb_queue_tail(&temp, sctp_event2skb(event));  in sctp_ulpq_tail_data()
106 		if (event->msg_flags & MSG_EOR)  in sctp_ulpq_tail_data()
107 			event = sctp_ulpq_order(ulpq, event);  in sctp_ulpq_tail_data()
113 	if (event) {  in sctp_ulpq_tail_data()
114 		event_eor = (event->msg_flags & MSG_EOR) ? 1 : 0;  in sctp_ulpq_tail_data()
146 			struct sctp_ulpevent *event;  in sctp_clear_pd()  local
149 				event = sctp_skb2event(skb);  in sctp_clear_pd()
150 				if (event->asoc == asoc) {  in sctp_clear_pd()
183 	struct sctp_ulpevent *event;  in sctp_ulpq_tail_event()  local
189 	event = sctp_skb2event(skb);  in sctp_ulpq_tail_event()
196 	     !sctp_ulpevent_is_notification(event)))  in sctp_ulpq_tail_event()
199 	if (!sctp_ulpevent_is_notification(event)) {  in sctp_ulpq_tail_event()
204 	if (!sctp_ulpevent_is_enabled(event, ulpq->asoc->subscribe))  in sctp_ulpq_tail_event()
221 			if ((event->msg_flags & MSG_NOTIFICATION) ||  in sctp_ulpq_tail_event()
223 				    (event->msg_flags & SCTP_DATA_FRAG_MASK)))  in sctp_ulpq_tail_event()
226 				clear_pd = event->msg_flags & MSG_EOR;  in sctp_ulpq_tail_event()
268 					 struct sctp_ulpevent *event)  in sctp_ulpq_store_reasm()  argument
274 	tsn = event->tsn;  in sctp_ulpq_store_reasm()
279 		__skb_queue_tail(&ulpq->reasm, sctp_event2skb(event));  in sctp_ulpq_store_reasm()
287 		__skb_queue_tail(&ulpq->reasm, sctp_event2skb(event));  in sctp_ulpq_store_reasm()
301 	__skb_queue_before(&ulpq->reasm, pos, sctp_event2skb(event));  in sctp_ulpq_store_reasm()
319 	struct sctp_ulpevent *event;  in sctp_make_reassembled_event()  local
383 	event = sctp_skb2event(f_frag);  in sctp_make_reassembled_event()
386 	return event;  in sctp_make_reassembled_event()
572 						struct sctp_ulpevent *event)  in sctp_ulpq_reasm()  argument
577 	if (SCTP_DATA_NOT_FRAG == (event->msg_flags & SCTP_DATA_FRAG_MASK)) {  in sctp_ulpq_reasm()
578 		event->msg_flags |= MSG_EOR;  in sctp_ulpq_reasm()
579 		return event;  in sctp_ulpq_reasm()
582 	sctp_ulpq_store_reasm(ulpq, event);  in sctp_ulpq_reasm()
591 		ctsn = event->tsn;  in sctp_ulpq_reasm()
682 	struct sctp_ulpevent *event;  in sctp_ulpq_reasm_flushtsn()  local
689 		event = sctp_skb2event(pos);  in sctp_ulpq_reasm_flushtsn()
690 		tsn = event->tsn;  in sctp_ulpq_reasm_flushtsn()
699 			sctp_ulpevent_free(event);  in sctp_ulpq_reasm_flushtsn()
712 	struct sctp_ulpevent *event = NULL;  in sctp_ulpq_reasm_drain()  local
717 	while ((event = sctp_ulpq_retrieve_reassembled(ulpq)) != NULL) {  in sctp_ulpq_reasm_drain()
721 		__skb_queue_tail(&temp, sctp_event2skb(event));  in sctp_ulpq_reasm_drain()
724 		if (event->msg_flags & MSG_EOR)  in sctp_ulpq_reasm_drain()
725 			event = sctp_ulpq_order(ulpq, event);  in sctp_ulpq_reasm_drain()
730 		if (event)  in sctp_ulpq_reasm_drain()
740 					      struct sctp_ulpevent *event)  in sctp_ulpq_retrieve_ordered()  argument
748 	sid = event->stream;  in sctp_ulpq_retrieve_ordered()
751 	event_list = (struct sk_buff_head *) sctp_event2skb(event)->prev;  in sctp_ulpq_retrieve_ordered()
782 					   struct sctp_ulpevent *event)  in sctp_ulpq_store_ordered()  argument
791 		__skb_queue_tail(&ulpq->lobby, sctp_event2skb(event));  in sctp_ulpq_store_ordered()
795 	sid = event->stream;  in sctp_ulpq_store_ordered()
796 	ssn = event->ssn;  in sctp_ulpq_store_ordered()
802 		__skb_queue_tail(&ulpq->lobby, sctp_event2skb(event));  in sctp_ulpq_store_ordered()
807 		__skb_queue_tail(&ulpq->lobby, sctp_event2skb(event));  in sctp_ulpq_store_ordered()
827 	__skb_queue_before(&ulpq->lobby, pos, sctp_event2skb(event));  in sctp_ulpq_store_ordered()
831 					     struct sctp_ulpevent *event)  in sctp_ulpq_order()  argument
837 	if (event->msg_flags & SCTP_DATA_UNORDERED)  in sctp_ulpq_order()
838 		return event;  in sctp_ulpq_order()
841 	sid = event->stream;  in sctp_ulpq_order()
842 	ssn = event->ssn;  in sctp_ulpq_order()
850 		sctp_ulpq_store_ordered(ulpq, event);  in sctp_ulpq_order()
860 	sctp_ulpq_retrieve_ordered(ulpq, event);  in sctp_ulpq_order()
862 	return event;  in sctp_ulpq_order()
872 	struct sctp_ulpevent *event;  in sctp_ulpq_reap_ordered()  local
882 	event = NULL;  in sctp_ulpq_reap_ordered()
901 		if (!event)  in sctp_ulpq_reap_ordered()
903 			event = sctp_skb2event(pos);  in sctp_ulpq_reap_ordered()
912 	if (event == NULL && pos != (struct sk_buff *)lobby) {  in sctp_ulpq_reap_ordered()
921 			event = sctp_skb2event(pos);  in sctp_ulpq_reap_ordered()
928 	if (event) {  in sctp_ulpq_reap_ordered()
930 		sctp_ulpq_retrieve_ordered(ulpq, event);  in sctp_ulpq_reap_ordered()
964 	struct sctp_ulpevent *event;  in sctp_ulpq_renege_list()  local
970 		event = sctp_skb2event(skb);  in sctp_ulpq_renege_list()
971 		tsn = event->tsn;  in sctp_ulpq_renege_list()
994 		sctp_ulpevent_free(event);  in sctp_ulpq_renege_list()
1022 	struct sctp_ulpevent *event;  in sctp_ulpq_partial_delivery()  local
1054 		event = sctp_ulpq_retrieve_first(ulpq);  in sctp_ulpq_partial_delivery()
1056 		if (event) {  in sctp_ulpq_partial_delivery()
1060 			__skb_queue_tail(&temp, sctp_event2skb(event));  in sctp_ulpq_partial_delivery()