Lines Matching refs:event
60 struct sctp_ulpevent *event; in sctp_ulpq_flush() local
63 event = sctp_skb2event(skb); in sctp_ulpq_flush()
64 sctp_ulpevent_free(event); in sctp_ulpq_flush()
68 event = sctp_skb2event(skb); in sctp_ulpq_flush()
69 sctp_ulpevent_free(event); in sctp_ulpq_flush()
73 event = sctp_skb2event(skb); in sctp_ulpq_flush()
74 sctp_ulpevent_free(event); in sctp_ulpq_flush()
89 struct sctp_ulpevent *event; in sctp_ulpq_tail_data() local
93 event = sctp_ulpevent_make_rcvmsg(chunk->asoc, chunk, gfp); in sctp_ulpq_tail_data()
94 if (!event) in sctp_ulpq_tail_data()
97 event->ssn = ntohs(chunk->subh.data_hdr->ssn); in sctp_ulpq_tail_data()
98 event->ppid = chunk->subh.data_hdr->ppid; in sctp_ulpq_tail_data()
101 event = sctp_ulpq_reasm(ulpq, event); in sctp_ulpq_tail_data()
104 if (event) { in sctp_ulpq_tail_data()
107 __skb_queue_tail(&temp, sctp_event2skb(event)); in sctp_ulpq_tail_data()
109 if (event->msg_flags & MSG_EOR) in sctp_ulpq_tail_data()
110 event = sctp_ulpq_order(ulpq, event); in sctp_ulpq_tail_data()
116 if (event) { in sctp_ulpq_tail_data()
117 event_eor = (event->msg_flags & MSG_EOR) ? 1 : 0; in sctp_ulpq_tail_data()
149 struct sctp_ulpevent *event; in sctp_clear_pd() local
152 event = sctp_skb2event(skb); in sctp_clear_pd()
153 if (event->asoc == asoc) { in sctp_clear_pd()
186 struct sctp_ulpevent *event; in sctp_ulpq_tail_event() local
192 event = sctp_skb2event(skb); in sctp_ulpq_tail_event()
199 !sctp_ulpevent_is_notification(event))) in sctp_ulpq_tail_event()
202 if (!sctp_ulpevent_is_notification(event)) { in sctp_ulpq_tail_event()
207 if (!sctp_ulpevent_is_enabled(event, ulpq->asoc->subscribe)) in sctp_ulpq_tail_event()
224 if ((event->msg_flags & MSG_NOTIFICATION) || in sctp_ulpq_tail_event()
226 (event->msg_flags & SCTP_DATA_FRAG_MASK))) in sctp_ulpq_tail_event()
229 clear_pd = event->msg_flags & MSG_EOR; in sctp_ulpq_tail_event()
265 sctp_ulpevent_free(event); in sctp_ulpq_tail_event()
274 struct sctp_ulpevent *event) in sctp_ulpq_store_reasm() argument
280 tsn = event->tsn; in sctp_ulpq_store_reasm()
285 __skb_queue_tail(&ulpq->reasm, sctp_event2skb(event)); in sctp_ulpq_store_reasm()
293 __skb_queue_tail(&ulpq->reasm, sctp_event2skb(event)); in sctp_ulpq_store_reasm()
307 __skb_queue_before(&ulpq->reasm, pos, sctp_event2skb(event)); in sctp_ulpq_store_reasm()
325 struct sctp_ulpevent *event; in sctp_make_reassembled_event() local
389 event = sctp_skb2event(f_frag); in sctp_make_reassembled_event()
392 return event; in sctp_make_reassembled_event()
579 struct sctp_ulpevent *event) in sctp_ulpq_reasm() argument
584 if (SCTP_DATA_NOT_FRAG == (event->msg_flags & SCTP_DATA_FRAG_MASK)) { in sctp_ulpq_reasm()
585 event->msg_flags |= MSG_EOR; in sctp_ulpq_reasm()
586 return event; in sctp_ulpq_reasm()
589 sctp_ulpq_store_reasm(ulpq, event); in sctp_ulpq_reasm()
598 ctsn = event->tsn; in sctp_ulpq_reasm()
689 struct sctp_ulpevent *event; in sctp_ulpq_reasm_flushtsn() local
696 event = sctp_skb2event(pos); in sctp_ulpq_reasm_flushtsn()
697 tsn = event->tsn; in sctp_ulpq_reasm_flushtsn()
706 sctp_ulpevent_free(event); in sctp_ulpq_reasm_flushtsn()
719 struct sctp_ulpevent *event = NULL; in sctp_ulpq_reasm_drain() local
724 while ((event = sctp_ulpq_retrieve_reassembled(ulpq)) != NULL) { in sctp_ulpq_reasm_drain()
728 __skb_queue_tail(&temp, sctp_event2skb(event)); in sctp_ulpq_reasm_drain()
731 if (event->msg_flags & MSG_EOR) in sctp_ulpq_reasm_drain()
732 event = sctp_ulpq_order(ulpq, event); in sctp_ulpq_reasm_drain()
737 if (event) in sctp_ulpq_reasm_drain()
747 struct sctp_ulpevent *event) in sctp_ulpq_retrieve_ordered() argument
755 sid = event->stream; in sctp_ulpq_retrieve_ordered()
758 event_list = (struct sk_buff_head *) sctp_event2skb(event)->prev; in sctp_ulpq_retrieve_ordered()
789 struct sctp_ulpevent *event) in sctp_ulpq_store_ordered() argument
798 __skb_queue_tail(&ulpq->lobby, sctp_event2skb(event)); in sctp_ulpq_store_ordered()
802 sid = event->stream; in sctp_ulpq_store_ordered()
803 ssn = event->ssn; in sctp_ulpq_store_ordered()
809 __skb_queue_tail(&ulpq->lobby, sctp_event2skb(event)); in sctp_ulpq_store_ordered()
814 __skb_queue_tail(&ulpq->lobby, sctp_event2skb(event)); in sctp_ulpq_store_ordered()
834 __skb_queue_before(&ulpq->lobby, pos, sctp_event2skb(event)); in sctp_ulpq_store_ordered()
838 struct sctp_ulpevent *event) in sctp_ulpq_order() argument
844 if (event->msg_flags & SCTP_DATA_UNORDERED) in sctp_ulpq_order()
845 return event; in sctp_ulpq_order()
848 sid = event->stream; in sctp_ulpq_order()
849 ssn = event->ssn; in sctp_ulpq_order()
857 sctp_ulpq_store_ordered(ulpq, event); in sctp_ulpq_order()
867 sctp_ulpq_retrieve_ordered(ulpq, event); in sctp_ulpq_order()
869 return event; in sctp_ulpq_order()
879 struct sctp_ulpevent *event; in sctp_ulpq_reap_ordered() local
889 event = NULL; in sctp_ulpq_reap_ordered()
908 if (!event) in sctp_ulpq_reap_ordered()
910 event = sctp_skb2event(pos); in sctp_ulpq_reap_ordered()
919 if (event == NULL && pos != (struct sk_buff *)lobby) { in sctp_ulpq_reap_ordered()
928 event = sctp_skb2event(pos); in sctp_ulpq_reap_ordered()
935 if (event) { in sctp_ulpq_reap_ordered()
937 sctp_ulpq_retrieve_ordered(ulpq, event); in sctp_ulpq_reap_ordered()
971 struct sctp_ulpevent *event; in sctp_ulpq_renege_list() local
977 event = sctp_skb2event(skb); in sctp_ulpq_renege_list()
978 tsn = event->tsn; in sctp_ulpq_renege_list()
1001 sctp_ulpevent_free(event); in sctp_ulpq_renege_list()
1029 struct sctp_ulpevent *event; in sctp_ulpq_partial_delivery() local
1061 event = sctp_ulpq_retrieve_first(ulpq); in sctp_ulpq_partial_delivery()
1063 if (event) { in sctp_ulpq_partial_delivery()
1067 __skb_queue_tail(&temp, sctp_event2skb(event)); in sctp_ulpq_partial_delivery()