net/sctp/stream_interleave.c

127 	struct sctp_ulpevent *cevent;
136 	cevent = sctp_skb2event(pos);
138 	if (event->stream == cevent->stream &&
139 	    event->mid == cevent->mid &&
140 	    (cevent->msg_flags & SCTP_DATA_FIRST_FRAG ||
142 	      event->fsn > cevent->fsn))) {
147 	if ((event->stream == cevent->stream &&
148 	     MID_lt(cevent->mid, event->mid)) ||
149 	    event->stream > cevent->stream) {
156 		cevent = sctp_skb2event(pos);
158 		if (event->stream < cevent->stream ||
159 		    (event->stream == cevent->stream &&
160 		     MID_lt(event->mid, cevent->mid))) {
164 		if (event->stream == cevent->stream &&
165 		    event->mid == cevent->mid &&
166 		    !(cevent->msg_flags & SCTP_DATA_FIRST_FRAG) &&
168 		     event->fsn < cevent->fsn)) {
195 		struct sctp_ulpevent *cevent = sctp_skb2event(pos);
197 		if (cevent->stream < event->stream)
200 		if (cevent->stream > event->stream ||
201 		    cevent->mid != sin->mid)
204 		switch (cevent->msg_flags & SCTP_DATA_FRAG_MASK) {
209 				if (cevent->fsn == sin->fsn) {
212 					next_fsn = cevent->fsn + 1;
214 			} else if (cevent->fsn == next_fsn) {
223 				if (cevent->fsn == sin->fsn) {
229 			} else if (cevent->fsn == next_fsn) {
275 		struct sctp_ulpevent *cevent = sctp_skb2event(pos);
277 		if (cevent->stream < event->stream)
279 		if (cevent->stream > event->stream)
282 		if (MID_lt(cevent->mid, event->mid))
284 		if (MID_lt(event->mid, cevent->mid))
287 		switch (cevent->msg_flags & SCTP_DATA_FRAG_MASK) {
289 			if (cevent->mid == sin->mid) {
297 			mid = cevent->mid;
301 			if (first_frag && cevent->mid == mid &&
302 			    cevent->fsn == next_fsn) {
314 			if (first_frag && cevent->mid == mid &&
315 			    cevent->fsn == next_fsn)
375 	struct sctp_ulpevent *cevent;
384 	cevent = (struct sctp_ulpevent *)pos->cb;
385 	if (event->stream == cevent->stream &&
386 	    MID_lt(cevent->mid, event->mid)) {
391 	if (event->stream > cevent->stream) {
398 		cevent = (struct sctp_ulpevent *)pos->cb;
400 		if (cevent->stream > event->stream) {
404 		if (cevent->stream == event->stream &&
405 		    MID_lt(event->mid, cevent->mid)) {
429 		struct sctp_ulpevent *cevent = (struct sctp_ulpevent *)pos->cb;
431 		if (cevent->stream > sid)
434 		if (cevent->stream < sid)
437 		if (cevent->mid != sctp_mid_peek(stream, in, sid))
512 	struct sctp_ulpevent *cevent;
521 	cevent = sctp_skb2event(pos);
523 	if (event->stream == cevent->stream &&
524 	    event->mid == cevent->mid &&
525 	    (cevent->msg_flags & SCTP_DATA_FIRST_FRAG ||
527 	      event->fsn > cevent->fsn))) {
532 	if ((event->stream == cevent->stream &&
533 	     MID_lt(cevent->mid, event->mid)) ||
534 	    event->stream > cevent->stream) {
540 		cevent = sctp_skb2event(pos);
542 		if (event->stream < cevent->stream ||
543 		    (event->stream == cevent->stream &&
544 		     MID_lt(event->mid, cevent->mid)))
547 		if (event->stream == cevent->stream &&
548 		    event->mid == cevent->mid &&
549 		    !(cevent->msg_flags & SCTP_DATA_FIRST_FRAG) &&
551 		     event->fsn < cevent->fsn))
573 		struct sctp_ulpevent *cevent = sctp_skb2event(pos);
575 		if (cevent->stream < event->stream)
577 		if (cevent->stream > event->stream)
580 		if (MID_lt(cevent->mid, sin->mid_uo))
582 		if (MID_lt(sin->mid_uo, cevent->mid))
585 		switch (cevent->msg_flags & SCTP_DATA_FRAG_MASK) {
590 				if (cevent->fsn == sin->fsn_uo) {
593 					next_fsn = cevent->fsn + 1;
595 			} else if (cevent->fsn == next_fsn) {
604 				if (cevent->fsn == sin->fsn_uo) {
610 			} else if (cevent->fsn == next_fsn) {
657 		struct sctp_ulpevent *cevent = sctp_skb2event(pos);
659 		if (cevent->stream < event->stream)
661 		if (cevent->stream > event->stream)
664 		if (MID_lt(cevent->mid, event->mid))
666 		if (MID_lt(event->mid, cevent->mid))
669 		switch (cevent->msg_flags & SCTP_DATA_FRAG_MASK) {
672 				sin->mid_uo = cevent->mid;
680 			mid = cevent->mid;
684 			if (first_frag && cevent->mid == mid &&
685 			    cevent->fsn == next_fsn) {
697 			if (first_frag && cevent->mid == mid &&
698 			    cevent->fsn == next_fsn)
766 		struct sctp_ulpevent *cevent = sctp_skb2event(pos);
768 		csin = sctp_stream_in(&ulpq->asoc->stream, cevent->stream);
772 		switch (cevent->msg_flags & SCTP_DATA_FRAG_MASK) {
780 			sid = cevent->stream;
781 			sin->mid_uo = cevent->mid;
786 			if (cevent->stream == sid &&
787 			    cevent->mid == sin->mid_uo &&
788 			    cevent->fsn == next_fsn) {
872 		struct sctp_ulpevent *cevent = sctp_skb2event(pos);
874 		csin = sctp_stream_in(&ulpq->asoc->stream, cevent->stream);
878 		switch (cevent->msg_flags & SCTP_DATA_FRAG_MASK) {
882 			if (cevent->mid == csin->mid) {
887 				sid = cevent->stream;
893 			if (cevent->stream == sid &&
894 			    cevent->mid == sin->mid &&
895 			    cevent->fsn == next_fsn) {
1005 	struct sctp_ulpevent *cevent, *event = NULL;
1014 		cevent = (struct sctp_ulpevent *)pos->cb;
1015 		csid = cevent->stream;
1016 		cmid = cevent->mid;
1035 		cevent = (struct sctp_ulpevent *)pos->cb;
1036 		csid = cevent->stream;
1037 		cmid = cevent->mid;