Lines Matching refs:event
80 struct sctp_ulpevent *event; in sctp_ulpq_flush() local
83 event = sctp_skb2event(skb); in sctp_ulpq_flush()
84 sctp_ulpevent_free(event); in sctp_ulpq_flush()
88 event = sctp_skb2event(skb); in sctp_ulpq_flush()
89 sctp_ulpevent_free(event); in sctp_ulpq_flush()
108 struct sctp_ulpevent *event; in sctp_ulpq_tail_data() local
113 event = sctp_ulpevent_make_rcvmsg(chunk->asoc, chunk, gfp); in sctp_ulpq_tail_data()
114 if (!event) in sctp_ulpq_tail_data()
118 event = sctp_ulpq_reasm(ulpq, event); in sctp_ulpq_tail_data()
121 if ((event) && (event->msg_flags & MSG_EOR)){ in sctp_ulpq_tail_data()
124 __skb_queue_tail(&temp, sctp_event2skb(event)); in sctp_ulpq_tail_data()
126 event = sctp_ulpq_order(ulpq, event); in sctp_ulpq_tail_data()
132 if (event) in sctp_ulpq_tail_data()
133 sctp_ulpq_tail_event(ulpq, event); in sctp_ulpq_tail_data()
165 struct sctp_ulpevent *event; in sctp_clear_pd() local
168 event = sctp_skb2event(skb); in sctp_clear_pd()
169 if (event->asoc == asoc) { in sctp_clear_pd()
201 int sctp_ulpq_tail_event(struct sctp_ulpq *ulpq, struct sctp_ulpevent *event) in sctp_ulpq_tail_event() argument
205 struct sk_buff *skb = sctp_event2skb(event); in sctp_ulpq_tail_event()
217 if (!sctp_ulpevent_is_enabled(event, &sctp_sk(sk)->subscribe)) in sctp_ulpq_tail_event()
234 if ((event->msg_flags & MSG_NOTIFICATION) || in sctp_ulpq_tail_event()
236 (event->msg_flags & SCTP_DATA_FRAG_MASK))) in sctp_ulpq_tail_event()
239 clear_pd = event->msg_flags & MSG_EOR; in sctp_ulpq_tail_event()
278 sctp_ulpevent_free(event); in sctp_ulpq_tail_event()
287 struct sctp_ulpevent *event) in sctp_ulpq_store_reasm() argument
293 tsn = event->tsn; in sctp_ulpq_store_reasm()
298 __skb_queue_tail(&ulpq->reasm, sctp_event2skb(event)); in sctp_ulpq_store_reasm()
306 __skb_queue_tail(&ulpq->reasm, sctp_event2skb(event)); in sctp_ulpq_store_reasm()
320 __skb_queue_before(&ulpq->reasm, pos, sctp_event2skb(event)); in sctp_ulpq_store_reasm()
335 struct sctp_ulpevent *event; in sctp_make_reassembled_event() local
398 event = sctp_skb2event(f_frag); in sctp_make_reassembled_event()
401 return event; in sctp_make_reassembled_event()
580 struct sctp_ulpevent *event) in sctp_ulpq_reasm() argument
585 if (SCTP_DATA_NOT_FRAG == (event->msg_flags & SCTP_DATA_FRAG_MASK)) { in sctp_ulpq_reasm()
586 event->msg_flags |= MSG_EOR; in sctp_ulpq_reasm()
587 return event; in sctp_ulpq_reasm()
590 sctp_ulpq_store_reasm(ulpq, event); in sctp_ulpq_reasm()
599 ctsn = event->tsn; in sctp_ulpq_reasm()
681 struct sctp_ulpevent *event; in sctp_ulpq_reasm_flushtsn() local
688 event = sctp_skb2event(pos); in sctp_ulpq_reasm_flushtsn()
689 tsn = event->tsn; in sctp_ulpq_reasm_flushtsn()
698 sctp_ulpevent_free(event); in sctp_ulpq_reasm_flushtsn()
711 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()
719 if ((event) && (event->msg_flags & MSG_EOR)){ in sctp_ulpq_reasm_drain()
721 __skb_queue_tail(&temp, sctp_event2skb(event)); in sctp_ulpq_reasm_drain()
723 event = sctp_ulpq_order(ulpq, event); in sctp_ulpq_reasm_drain()
729 if (event) in sctp_ulpq_reasm_drain()
730 sctp_ulpq_tail_event(ulpq, event); in sctp_ulpq_reasm_drain()
739 struct sctp_ulpevent *event) in sctp_ulpq_retrieve_ordered() argument
748 sid = event->stream; in sctp_ulpq_retrieve_ordered()
749 ssn = event->ssn; in sctp_ulpq_retrieve_ordered()
752 event_list = (struct sk_buff_head *) sctp_event2skb(event)->prev; in sctp_ulpq_retrieve_ordered()
783 struct sctp_ulpevent *event) in sctp_ulpq_store_ordered() argument
792 __skb_queue_tail(&ulpq->lobby, sctp_event2skb(event)); in sctp_ulpq_store_ordered()
796 sid = event->stream; in sctp_ulpq_store_ordered()
797 ssn = event->ssn; in sctp_ulpq_store_ordered()
803 __skb_queue_tail(&ulpq->lobby, sctp_event2skb(event)); in sctp_ulpq_store_ordered()
808 __skb_queue_tail(&ulpq->lobby, sctp_event2skb(event)); in sctp_ulpq_store_ordered()
828 __skb_queue_before(&ulpq->lobby, pos, sctp_event2skb(event)); in sctp_ulpq_store_ordered()
832 struct sctp_ulpevent *event) in sctp_ulpq_order() argument
838 if (SCTP_DATA_UNORDERED & event->msg_flags) in sctp_ulpq_order()
839 return event; in sctp_ulpq_order()
842 sid = event->stream; in sctp_ulpq_order()
843 ssn = event->ssn; in sctp_ulpq_order()
851 sctp_ulpq_store_ordered(ulpq, event); in sctp_ulpq_order()
861 sctp_ulpq_retrieve_ordered(ulpq, event); in sctp_ulpq_order()
863 return event; in sctp_ulpq_order()
873 struct sctp_ulpevent *event; in sctp_ulpq_reap_ordered() local
883 event = NULL; in sctp_ulpq_reap_ordered()
902 if (!event) in sctp_ulpq_reap_ordered()
904 event = sctp_skb2event(pos); in sctp_ulpq_reap_ordered()
913 if (event == NULL && pos != (struct sk_buff *)lobby) { in sctp_ulpq_reap_ordered()
922 event = sctp_skb2event(pos); in sctp_ulpq_reap_ordered()
929 if (event) { in sctp_ulpq_reap_ordered()
931 sctp_ulpq_retrieve_ordered(ulpq, event); in sctp_ulpq_reap_ordered()
932 sctp_ulpq_tail_event(ulpq, event); in sctp_ulpq_reap_ordered()
966 struct sctp_ulpevent *event; in sctp_ulpq_renege_list() local
973 event = sctp_skb2event(skb); in sctp_ulpq_renege_list()
974 tsn = event->tsn; in sctp_ulpq_renege_list()
976 sctp_ulpevent_free(event); in sctp_ulpq_renege_list()
1002 struct sctp_ulpevent *event; in sctp_ulpq_partial_delivery() local
1022 event = sctp_ulpq_retrieve_first(ulpq); in sctp_ulpq_partial_delivery()
1024 if (event) { in sctp_ulpq_partial_delivery()
1025 sctp_ulpq_tail_event(ulpq, event); in sctp_ulpq_partial_delivery()