127 	struct sctp_ulpevent *cevent;  in sctp_intl_store_reasm()  local
136 	cevent = sctp_skb2event(pos);  in sctp_intl_store_reasm()
138 	if (event->stream == cevent->stream &&  in sctp_intl_store_reasm()
139 	    event->mid == cevent->mid &&  in sctp_intl_store_reasm()
140 	    (cevent->msg_flags & SCTP_DATA_FIRST_FRAG ||  in sctp_intl_store_reasm()
142 	      event->fsn > cevent->fsn))) {  in sctp_intl_store_reasm()
147 	if ((event->stream == cevent->stream &&  in sctp_intl_store_reasm()
148 	     MID_lt(cevent->mid, event->mid)) ||  in sctp_intl_store_reasm()
149 	    event->stream > cevent->stream) {  in sctp_intl_store_reasm()
156 		cevent = sctp_skb2event(pos);  in sctp_intl_store_reasm()
158 		if (event->stream < cevent->stream ||  in sctp_intl_store_reasm()
159 		    (event->stream == cevent->stream &&  in sctp_intl_store_reasm()
160 		     MID_lt(event->mid, cevent->mid))) {  in sctp_intl_store_reasm()
164 		if (event->stream == cevent->stream &&  in sctp_intl_store_reasm()
165 		    event->mid == cevent->mid &&  in sctp_intl_store_reasm()
166 		    !(cevent->msg_flags & SCTP_DATA_FIRST_FRAG) &&  in sctp_intl_store_reasm()
168 		     event->fsn < cevent->fsn)) {  in sctp_intl_store_reasm()
195 		struct sctp_ulpevent *cevent = sctp_skb2event(pos);  in sctp_intl_retrieve_partial()  local
197 		if (cevent->stream < event->stream)  in sctp_intl_retrieve_partial()
200 		if (cevent->stream > event->stream ||  in sctp_intl_retrieve_partial()
201 		    cevent->mid != sin->mid)  in sctp_intl_retrieve_partial()
204 		switch (cevent->msg_flags & SCTP_DATA_FRAG_MASK) {  in sctp_intl_retrieve_partial()
209 				if (cevent->fsn == sin->fsn) {  in sctp_intl_retrieve_partial()
212 					next_fsn = cevent->fsn + 1;  in sctp_intl_retrieve_partial()
214 			} else if (cevent->fsn == next_fsn) {  in sctp_intl_retrieve_partial()
223 				if (cevent->fsn == sin->fsn) {  in sctp_intl_retrieve_partial()
229 			} else if (cevent->fsn == next_fsn) {  in sctp_intl_retrieve_partial()
276 		struct sctp_ulpevent *cevent = sctp_skb2event(pos);  in sctp_intl_retrieve_reassembled()  local
278 		if (cevent->stream < event->stream)  in sctp_intl_retrieve_reassembled()
280 		if (cevent->stream > event->stream)  in sctp_intl_retrieve_reassembled()
283 		if (MID_lt(cevent->mid, event->mid))  in sctp_intl_retrieve_reassembled()
285 		if (MID_lt(event->mid, cevent->mid))  in sctp_intl_retrieve_reassembled()
288 		switch (cevent->msg_flags & SCTP_DATA_FRAG_MASK) {  in sctp_intl_retrieve_reassembled()
290 			if (cevent->mid == sin->mid) {  in sctp_intl_retrieve_reassembled()
298 			mid = cevent->mid;  in sctp_intl_retrieve_reassembled()
302 			if (first_frag && cevent->mid == mid &&  in sctp_intl_retrieve_reassembled()
303 			    cevent->fsn == next_fsn) {  in sctp_intl_retrieve_reassembled()
315 			if (first_frag && cevent->mid == mid &&  in sctp_intl_retrieve_reassembled()
316 			    cevent->fsn == next_fsn)  in sctp_intl_retrieve_reassembled()
377 	struct sctp_ulpevent *cevent;  in sctp_intl_store_ordered()  local
386 	cevent = (struct sctp_ulpevent *)pos->cb;  in sctp_intl_store_ordered()
387 	if (event->stream == cevent->stream &&  in sctp_intl_store_ordered()
388 	    MID_lt(cevent->mid, event->mid)) {  in sctp_intl_store_ordered()
393 	if (event->stream > cevent->stream) {  in sctp_intl_store_ordered()
400 		cevent = (struct sctp_ulpevent *)pos->cb;  in sctp_intl_store_ordered()
402 		if (cevent->stream > event->stream) {  in sctp_intl_store_ordered()
406 		if (cevent->stream == event->stream &&  in sctp_intl_store_ordered()
407 		    MID_lt(event->mid, cevent->mid)) {  in sctp_intl_store_ordered()
431 		struct sctp_ulpevent *cevent = (struct sctp_ulpevent *)pos->cb;  in sctp_intl_retrieve_ordered()  local
433 		if (cevent->stream > sid)  in sctp_intl_retrieve_ordered()
436 		if (cevent->stream < sid)  in sctp_intl_retrieve_ordered()
439 		if (cevent->mid != sctp_mid_peek(stream, in, sid))  in sctp_intl_retrieve_ordered()
520 	struct sctp_ulpevent *cevent;  in sctp_intl_store_reasm_uo()  local
529 	cevent = sctp_skb2event(pos);  in sctp_intl_store_reasm_uo()
531 	if (event->stream == cevent->stream &&  in sctp_intl_store_reasm_uo()
532 	    event->mid == cevent->mid &&  in sctp_intl_store_reasm_uo()
533 	    (cevent->msg_flags & SCTP_DATA_FIRST_FRAG ||  in sctp_intl_store_reasm_uo()
535 	      event->fsn > cevent->fsn))) {  in sctp_intl_store_reasm_uo()
540 	if ((event->stream == cevent->stream &&  in sctp_intl_store_reasm_uo()
541 	     MID_lt(cevent->mid, event->mid)) ||  in sctp_intl_store_reasm_uo()
542 	    event->stream > cevent->stream) {  in sctp_intl_store_reasm_uo()
548 		cevent = sctp_skb2event(pos);  in sctp_intl_store_reasm_uo()
550 		if (event->stream < cevent->stream ||  in sctp_intl_store_reasm_uo()
551 		    (event->stream == cevent->stream &&  in sctp_intl_store_reasm_uo()
552 		     MID_lt(event->mid, cevent->mid)))  in sctp_intl_store_reasm_uo()
555 		if (event->stream == cevent->stream &&  in sctp_intl_store_reasm_uo()
556 		    event->mid == cevent->mid &&  in sctp_intl_store_reasm_uo()
557 		    !(cevent->msg_flags & SCTP_DATA_FIRST_FRAG) &&  in sctp_intl_store_reasm_uo()
559 		     event->fsn < cevent->fsn))  in sctp_intl_store_reasm_uo()
581 		struct sctp_ulpevent *cevent = sctp_skb2event(pos);  in sctp_intl_retrieve_partial_uo()  local
583 		if (cevent->stream < event->stream)  in sctp_intl_retrieve_partial_uo()
585 		if (cevent->stream > event->stream)  in sctp_intl_retrieve_partial_uo()
588 		if (MID_lt(cevent->mid, sin->mid_uo))  in sctp_intl_retrieve_partial_uo()
590 		if (MID_lt(sin->mid_uo, cevent->mid))  in sctp_intl_retrieve_partial_uo()
593 		switch (cevent->msg_flags & SCTP_DATA_FRAG_MASK) {  in sctp_intl_retrieve_partial_uo()
598 				if (cevent->fsn == sin->fsn_uo) {  in sctp_intl_retrieve_partial_uo()
601 					next_fsn = cevent->fsn + 1;  in sctp_intl_retrieve_partial_uo()
603 			} else if (cevent->fsn == next_fsn) {  in sctp_intl_retrieve_partial_uo()
612 				if (cevent->fsn == sin->fsn_uo) {  in sctp_intl_retrieve_partial_uo()
618 			} else if (cevent->fsn == next_fsn) {  in sctp_intl_retrieve_partial_uo()
665 		struct sctp_ulpevent *cevent = sctp_skb2event(pos);  in sctp_intl_retrieve_reassembled_uo()  local
667 		if (cevent->stream < event->stream)  in sctp_intl_retrieve_reassembled_uo()
669 		if (cevent->stream > event->stream)  in sctp_intl_retrieve_reassembled_uo()
672 		if (MID_lt(cevent->mid, event->mid))  in sctp_intl_retrieve_reassembled_uo()
674 		if (MID_lt(event->mid, cevent->mid))  in sctp_intl_retrieve_reassembled_uo()
677 		switch (cevent->msg_flags & SCTP_DATA_FRAG_MASK) {  in sctp_intl_retrieve_reassembled_uo()
680 				sin->mid_uo = cevent->mid;  in sctp_intl_retrieve_reassembled_uo()
688 			mid = cevent->mid;  in sctp_intl_retrieve_reassembled_uo()
692 			if (first_frag && cevent->mid == mid &&  in sctp_intl_retrieve_reassembled_uo()
693 			    cevent->fsn == next_fsn) {  in sctp_intl_retrieve_reassembled_uo()
705 			if (first_frag && cevent->mid == mid &&  in sctp_intl_retrieve_reassembled_uo()
706 			    cevent->fsn == next_fsn)  in sctp_intl_retrieve_reassembled_uo()
775 		struct sctp_ulpevent *cevent = sctp_skb2event(pos);  in sctp_intl_retrieve_first_uo()  local
777 		csin = sctp_stream_in(&ulpq->asoc->stream, cevent->stream);  in sctp_intl_retrieve_first_uo()
781 		switch (cevent->msg_flags & SCTP_DATA_FRAG_MASK) {  in sctp_intl_retrieve_first_uo()
789 			sid = cevent->stream;  in sctp_intl_retrieve_first_uo()
790 			sin->mid_uo = cevent->mid;  in sctp_intl_retrieve_first_uo()
795 			if (cevent->stream == sid &&  in sctp_intl_retrieve_first_uo()
796 			    cevent->mid == sin->mid_uo &&  in sctp_intl_retrieve_first_uo()
797 			    cevent->fsn == next_fsn) {  in sctp_intl_retrieve_first_uo()
881 		struct sctp_ulpevent *cevent = sctp_skb2event(pos);  in sctp_intl_retrieve_first()  local
883 		csin = sctp_stream_in(&ulpq->asoc->stream, cevent->stream);  in sctp_intl_retrieve_first()
887 		switch (cevent->msg_flags & SCTP_DATA_FRAG_MASK) {  in sctp_intl_retrieve_first()
891 			if (cevent->mid == csin->mid) {  in sctp_intl_retrieve_first()
896 				sid = cevent->stream;  in sctp_intl_retrieve_first()
902 			if (cevent->stream == sid &&  in sctp_intl_retrieve_first()
903 			    cevent->mid == sin->mid &&  in sctp_intl_retrieve_first()
904 			    cevent->fsn == next_fsn) {  in sctp_intl_retrieve_first()
1016 	struct sctp_ulpevent *cevent, *event = NULL;  in sctp_intl_reap_ordered()  local
1025 		cevent = (struct sctp_ulpevent *)pos->cb;  in sctp_intl_reap_ordered()
1026 		csid = cevent->stream;  in sctp_intl_reap_ordered()
1027 		cmid = cevent->mid;  in sctp_intl_reap_ordered()
1046 		cevent = (struct sctp_ulpevent *)pos->cb;  in sctp_intl_reap_ordered()
1047 		csid = cevent->stream;  in sctp_intl_reap_ordered()
1048 		cmid = cevent->mid;  in sctp_intl_reap_ordered()