Lines Matching refs:asoc

42 				 struct sctp_association *asoc)  in sctp_ulpq_init()  argument
46 ulpq->asoc = asoc; in sctp_ulpq_init()
93 event = sctp_ulpevent_make_rcvmsg(chunk->asoc, chunk, gfp); in sctp_ulpq_tail_data()
128 int sctp_clear_pd(struct sock *sk, struct sctp_association *asoc) in sctp_clear_pd() argument
147 if (!skb_queue_empty(&sp->pd_lobby) && asoc) { in sctp_clear_pd()
153 if (event->asoc == asoc) { in sctp_clear_pd()
168 struct sctp_sock *sp = sctp_sk(ulpq->asoc->base.sk); in sctp_ulpq_set_pd()
179 return sctp_clear_pd(ulpq->asoc->base.sk, ulpq->asoc); in sctp_ulpq_clear_pd()
184 struct sock *sk = ulpq->asoc->base.sk; in sctp_ulpq_tail_event()
207 if (!sctp_ulpevent_is_enabled(event, ulpq->asoc->subscribe)) in sctp_ulpq_tail_event()
409 struct sctp_association *asoc; in sctp_ulpq_retrieve_reassembled() local
475 asoc = ulpq->asoc; in sctp_ulpq_retrieve_reassembled()
482 if (!sctp_sk(asoc->base.sk)->frag_interleave && in sctp_ulpq_retrieve_reassembled()
483 atomic_read(&sctp_sk(asoc->base.sk)->pd_mode)) in sctp_ulpq_retrieve_reassembled()
487 pd_point = sctp_sk(asoc->base.sk)->pd_point; in sctp_ulpq_retrieve_reassembled()
489 retval = sctp_make_reassembled_event(sock_net(asoc->base.sk), in sctp_ulpq_retrieve_reassembled()
500 retval = sctp_make_reassembled_event(sock_net(ulpq->asoc->base.sk), in sctp_ulpq_retrieve_reassembled()
566 retval = sctp_make_reassembled_event(sock_net(ulpq->asoc->base.sk), in sctp_ulpq_retrieve_partial()
599 ctsnap = sctp_tsnmap_get_ctsn(&ulpq->asoc->peer.tsn_map); in sctp_ulpq_reasm()
667 retval = sctp_make_reassembled_event(sock_net(ulpq->asoc->base.sk), in sctp_ulpq_retrieve_first()
756 stream = &ulpq->asoc->stream; in sctp_ulpq_retrieve_ordered()
850 stream = &ulpq->asoc->stream; in sctp_ulpq_order()
885 stream = &ulpq->asoc->stream; in sctp_ulpq_reap_ordered()
950 stream = &ulpq->asoc->stream; in sctp_ulpq_skip()
974 tsnmap = &ulpq->asoc->peer.tsn_map; in sctp_ulpq_renege_list()
1030 struct sctp_association *asoc; in sctp_ulpq_partial_delivery() local
1035 asoc = ulpq->asoc; in sctp_ulpq_partial_delivery()
1036 sp = sctp_sk(asoc->base.sk); in sctp_ulpq_partial_delivery()
1047 skb = skb_peek(&asoc->ulpq.reasm); in sctp_ulpq_partial_delivery()
1050 if (!TSN_lte(ctsn, sctp_tsnmap_get_ctsn(&asoc->peer.tsn_map))) in sctp_ulpq_partial_delivery()
1079 struct sctp_association *asoc = ulpq->asoc; in sctp_ulpq_renege() local
1086 if (skb_queue_empty(&asoc->base.sk->sk_receive_queue)) { in sctp_ulpq_renege()
1092 if (sk_rmem_schedule(asoc->base.sk, chunk->skb, needed) && in sctp_ulpq_renege()
1105 sk_mem_reclaim(asoc->base.sk); in sctp_ulpq_renege()
1122 sk = ulpq->asoc->base.sk; in sctp_ulpq_abort_pd()
1124 if (sctp_ulpevent_type_enabled(ulpq->asoc->subscribe, in sctp_ulpq_abort_pd()
1126 ev = sctp_ulpevent_make_pdapi(ulpq->asoc, in sctp_ulpq_abort_pd()