Lines Matching full:asoc
25 const struct sctp_association *asoc, in sctp_make_idatafrag_empty() argument
38 retval = sctp_make_idata(asoc, flags, sizeof(dp) + len, gfp); in sctp_make_idatafrag_empty()
59 stream = &chunk->asoc->stream; in sctp_chunk_assign_mid()
98 stream = &chunk->asoc->stream; in sctp_validate_data()
117 stream = &chunk->asoc->stream; in sctp_validate_idata()
192 sin = sctp_stream_in(&ulpq->asoc->stream, event->stream); in sctp_intl_retrieve_partial()
244 retval = sctp_make_reassembled_event(ulpq->asoc->base.net, &ulpq->reasm, in sctp_intl_retrieve_partial()
261 struct sctp_association *asoc = ulpq->asoc; in sctp_intl_retrieve_reassembled() local
272 sin = sctp_stream_in(&ulpq->asoc->stream, event->stream); in sctp_intl_retrieve_reassembled()
326 pd_point = sctp_sk(asoc->base.sk)->pd_point; in sctp_intl_retrieve_reassembled()
328 retval = sctp_make_reassembled_event(asoc->base.net, in sctp_intl_retrieve_reassembled()
339 retval = sctp_make_reassembled_event(asoc->base.net, &ulpq->reasm, in sctp_intl_retrieve_reassembled()
361 sin = sctp_stream_in(&ulpq->asoc->stream, event->stream); in sctp_intl_reasm()
425 stream = &ulpq->asoc->stream; in sctp_intl_retrieve_ordered()
454 stream = &ulpq->asoc->stream; in sctp_intl_order()
472 struct sock *sk = ulpq->asoc->base.sk; in sctp_enqueue_event()
490 if (!sctp_ulpevent_is_enabled(event, ulpq->asoc->subscribe)) in sctp_enqueue_event()
570 sin = sctp_stream_in(&ulpq->asoc->stream, event->stream); in sctp_intl_retrieve_partial_uo()
625 retval = sctp_make_reassembled_event(ulpq->asoc->base.net, in sctp_intl_retrieve_partial_uo()
643 struct sctp_association *asoc = ulpq->asoc; in sctp_intl_retrieve_reassembled_uo() local
654 sin = sctp_stream_in(&ulpq->asoc->stream, event->stream); in sctp_intl_retrieve_reassembled_uo()
709 pd_point = sctp_sk(asoc->base.sk)->pd_point; in sctp_intl_retrieve_reassembled_uo()
711 retval = sctp_make_reassembled_event(asoc->base.net, in sctp_intl_retrieve_reassembled_uo()
722 retval = sctp_make_reassembled_event(asoc->base.net, &ulpq->reasm_uo, in sctp_intl_retrieve_reassembled_uo()
744 sin = sctp_stream_in(&ulpq->asoc->stream, event->stream); in sctp_intl_reasm_uo()
768 csin = sctp_stream_in(&ulpq->asoc->stream, cevent->stream); in sctp_intl_retrieve_first_uo()
808 retval = sctp_make_reassembled_event(ulpq->asoc->base.net, in sctp_intl_retrieve_first_uo()
826 event = sctp_ulpevent_make_rcvmsg(chunk->asoc, chunk, gfp); in sctp_ulpevent_idata()
874 csin = sctp_stream_in(&ulpq->asoc->stream, cevent->stream); in sctp_intl_retrieve_first()
915 retval = sctp_make_reassembled_event(ulpq->asoc->base.net, in sctp_intl_retrieve_first()
957 struct sctp_association *asoc = ulpq->asoc; in sctp_renege_events() local
964 if (skb_queue_empty(&asoc->base.sk->sk_receive_queue)) { in sctp_renege_events()
981 struct sock *sk = ulpq->asoc->base.sk; in sctp_intl_stream_abort_pd()
984 if (!sctp_ulpevent_type_enabled(ulpq->asoc->subscribe, in sctp_intl_stream_abort_pd()
988 ev = sctp_ulpevent_make_pdapi(ulpq->asoc, SCTP_PARTIAL_DELIVERY_ABORTED, in sctp_intl_stream_abort_pd()
1004 struct sctp_stream *stream = &ulpq->asoc->stream; in sctp_intl_reap_ordered()
1055 struct sctp_stream *stream = &ulpq->asoc->stream; in sctp_intl_abort_pd()
1101 struct sctp_association *asoc = q->asoc; in sctp_generate_iftsn() local
1108 if (!asoc->peer.prsctp_capable) in sctp_generate_iftsn()
1111 if (TSN_lt(asoc->adv_peer_ack_point, ctsn)) in sctp_generate_iftsn()
1112 asoc->adv_peer_ack_point = ctsn; in sctp_generate_iftsn()
1121 } else if (TSN_lte(tsn, asoc->adv_peer_ack_point + 1)) { in sctp_generate_iftsn()
1129 asoc->adv_peer_ack_point = tsn; in sctp_generate_iftsn()
1145 if (asoc->adv_peer_ack_point > ctsn) in sctp_generate_iftsn()
1146 ftsn_chunk = sctp_make_ifwdtsn(asoc, asoc->adv_peer_ack_point, in sctp_generate_iftsn()
1151 SCTP_INC_STATS(asoc->base.net, SCTP_MIB_OUTCTRLCHUNKS); in sctp_generate_iftsn()
1172 incnt = chunk->asoc->stream.incnt; in sctp_validate_fwdtsn()
1188 incnt = chunk->asoc->stream.incnt; in sctp_validate_iftsn()
1199 sctp_tsnmap_skip(&ulpq->asoc->peer.tsn_map, ftsn); in sctp_report_fwdtsn()
1234 sctp_tsnmap_skip(&ulpq->asoc->peer.tsn_map, ftsn); in sctp_report_iftsn()
1238 if (ftsn == sctp_tsnmap_get_max_tsn_seen(&ulpq->asoc->peer.tsn_map)) in sctp_report_iftsn()
1254 struct sctp_stream_in *sin = sctp_stream_in(&ulpq->asoc->stream, sid); in sctp_intl_skip()
1255 struct sctp_stream *stream = &ulpq->asoc->stream; in sctp_intl_skip()
1348 struct sctp_association *asoc; in sctp_stream_interleave_init() local
1350 asoc = container_of(stream, struct sctp_association, stream); in sctp_stream_interleave_init()
1351 stream->si = asoc->peer.intl_capable ? &sctp_stream_interleave_1 in sctp_stream_interleave_init()