| /linux-6.3-rc2/net/sctp/ |
| A D | ulpqueue.c | 45 ulpq->asoc = asoc; in sctp_ulpq_init()
49 ulpq->pd_mode = 0; in sctp_ulpq_init()
78 sctp_ulpq_flush(ulpq); in sctp_ulpq_free()
168 ulpq->pd_mode = 1; in sctp_ulpq_set_pd()
174 ulpq->pd_mode = 0; in sctp_ulpq_clear_pd()
176 return sctp_clear_pd(ulpq->asoc->base.sk, ulpq->asoc); in sctp_ulpq_clear_pd()
469 asoc = ulpq->asoc; in sctp_ulpq_retrieve_reassembled()
1009 return sctp_ulpq_renege_list(ulpq, &ulpq->lobby, needed); in sctp_ulpq_renege_order()
1015 return sctp_ulpq_renege_list(ulpq, &ulpq->reasm, needed); in sctp_ulpq_renege_frags()
1028 asoc = ulpq->asoc; in sctp_ulpq_partial_delivery()
[all …]
|
| A D | stream_interleave.c | 181 struct sctp_ulpq *ulpq, in sctp_intl_retrieve_partial() argument
244 retval = sctp_make_reassembled_event(ulpq->asoc->base.net, &ulpq->reasm, in sctp_intl_retrieve_partial()
258 struct sctp_ulpq *ulpq, in sctp_intl_retrieve_reassembled() argument
329 &ulpq->reasm, in sctp_intl_retrieve_reassembled()
559 struct sctp_ulpq *ulpq, in sctp_intl_retrieve_partial_uo() argument
640 struct sctp_ulpq *ulpq, in sctp_intl_retrieve_reassembled_uo() argument
712 &ulpq->reasm_uo, in sctp_intl_retrieve_reassembled_uo()
965 freed = sctp_ulpq_renege_list(ulpq, &ulpq->lobby, needed); in sctp_renege_events()
967 freed += sctp_ulpq_renege_list(ulpq, &ulpq->reasm, in sctp_renege_events()
970 freed += sctp_ulpq_renege_list(ulpq, &ulpq->reasm_uo, in sctp_renege_events()
[all …]
|
| A D | sm_sideeffect.c | 659 asoc->stream.si->abort_pd(&asoc->ulpq, GFP_ATOMIC); in sctp_cmd_assoc_failed()
980 asoc->stream.si->enqueue_event(&asoc->ulpq, ev); in sctp_cmd_process_operr()
1054 asoc->stream.si->enqueue_event(&asoc->ulpq, ev); in sctp_cmd_assoc_change()
1064 asoc->stream.si->enqueue_event(&asoc->ulpq, ev); in sctp_cmd_peer_no_auth()
1076 asoc->stream.si->enqueue_event(&asoc->ulpq, ev); in sctp_cmd_adaptation_ind()
1348 asoc->stream.si->handle_ftsn(&asoc->ulpq, in sctp_cmd_interpreter()
1456 __func__, cmd->obj.chunk, &asoc->ulpq); in sctp_cmd_interpreter()
1458 asoc->stream.si->ulpevent_data(&asoc->ulpq, in sctp_cmd_interpreter()
1466 __func__, cmd->obj.ulpevent, &asoc->ulpq); in sctp_cmd_interpreter()
1468 asoc->stream.si->enqueue_event(&asoc->ulpq, in sctp_cmd_interpreter()
[all …]
|
| A D | chunk.c | 99 asoc->stream.si->enqueue_event(&asoc->ulpq, ev); in sctp_datamsg_destroy()
108 asoc->stream.si->enqueue_event(&asoc->ulpq, ev); in sctp_datamsg_destroy()
|
| A D | associola.c | 229 sctp_ulpq_init(&asoc->ulpq, asoc); in sctp_association_init()
342 sctp_ulpq_free(&asoc->ulpq); in sctp_association_free()
1150 sctp_ulpq_flush(&asoc->ulpq); in sctp_assoc_update()
|
| A D | stream.c | 731 asoc->stream.si->report_ftsn(&asoc->ulpq, max_tsn_seen); in sctp_process_strreset_tsnreq()
1008 asoc->stream.si->report_ftsn(&asoc->ulpq, mtsn); in sctp_process_strreset_resp()
|
| A D | socket.c | 198 sctp_skb_for_each(skb, &asoc->ulpq.lobby, tmp) in sctp_for_each_rx_skb()
201 sctp_skb_for_each(skb, &asoc->ulpq.reasm, tmp) in sctp_for_each_rx_skb()
204 sctp_skb_for_each(skb, &asoc->ulpq.reasm_uo, tmp) in sctp_for_each_rx_skb()
1519 !skb_queue_empty(&asoc->ulpq.reasm) || in sctp_close()
1520 !skb_queue_empty(&asoc->ulpq.reasm_uo) || in sctp_close()
2239 asoc->stream.si->enqueue_event(&asoc->ulpq, event); in sctp_setsockopt_events()
4269 asoc->stream.si->enqueue_event(&asoc->ulpq, event); in sctp_assoc_ulpevent_type_set()
9146 asoc->stream.si->enqueue_event(&asoc->ulpq, ev); in sctp_wfree()
9566 atomic_set(&sctp_sk(newsk)->pd_mode, assoc->ulpq.pd_mode); in sctp_sock_migrate()
9572 if (assoc->ulpq.pd_mode) { in sctp_sock_migrate()
[all …]
|
| A D | auth.c | 1014 asoc->stream.si->enqueue_event(&asoc->ulpq, ev); in sctp_auth_deact_key_id()
|
| A D | ulpevent.c | 355 asoc->stream.si->enqueue_event(&asoc->ulpq, event); in sctp_ulpevent_notify_peer_addr_change()
|
| A D | sm_make_chunk.c | 91 asoc->stream.si->enqueue_event(&asoc->ulpq, ev); in sctp_control_release_owner()
|
| A D | sm_statefuns.c | 6546 if ((datalen >= asoc->rwnd) && (!asoc->ulpq.pd_mode)) { in sctp_eat_data()
|
| /linux-6.3-rc2/include/net/sctp/ |
| A D | stream_interleave.h | 28 int (*ulpevent_data)(struct sctp_ulpq *ulpq,
30 int (*enqueue_event)(struct sctp_ulpq *ulpq,
32 void (*renege_events)(struct sctp_ulpq *ulpq,
34 void (*start_pd)(struct sctp_ulpq *ulpq, gfp_t gfp);
35 void (*abort_pd)(struct sctp_ulpq *ulpq, gfp_t gfp);
39 void (*report_ftsn)(struct sctp_ulpq *ulpq, __u32 ftsn);
40 void (*handle_ftsn)(struct sctp_ulpq *ulpq,
|
| A D | ulpqueue.h | 38 void sctp_ulpq_init(struct sctp_ulpq *ulpq, struct sctp_association *asoc);
39 void sctp_ulpq_flush(struct sctp_ulpq *ulpq);
61 void sctp_ulpq_skip(struct sctp_ulpq *ulpq, __u16 sid, __u16 ssn);
65 __u16 sctp_ulpq_renege_list(struct sctp_ulpq *ulpq,
|
| A D | structs.h | 1957 struct sctp_ulpq ulpq; member
|