Searched refs:ulpq (Results 1 – 8 of 8) sorted by relevance
| /linux-4.4.14/net/sctp/ |
| D | ulpqueue.c | 47 static struct sctp_ulpevent *sctp_ulpq_reasm(struct sctp_ulpq *ulpq,
51 static void sctp_ulpq_reasm_drain(struct sctp_ulpq *ulpq);
56 struct sctp_ulpq *sctp_ulpq_init(struct sctp_ulpq *ulpq, in sctp_ulpq_init() argument
59 memset(ulpq, 0, sizeof(struct sctp_ulpq)); in sctp_ulpq_init()
61 ulpq->asoc = asoc; in sctp_ulpq_init()
62 skb_queue_head_init(&ulpq->reasm); in sctp_ulpq_init()
63 skb_queue_head_init(&ulpq->lobby); in sctp_ulpq_init()
64 ulpq->pd_mode = 0; in sctp_ulpq_init()
66 return ulpq; in sctp_ulpq_init()
71 void sctp_ulpq_flush(struct sctp_ulpq *ulpq) in sctp_ulpq_flush() argument
[all …]
|
| D | sm_sideeffect.c | 577 sctp_ulpq_abort_pd(&asoc->ulpq, GFP_ATOMIC); in sctp_cmd_assoc_failed()
903 sctp_ulpq_tail_event(&asoc->ulpq, ev); in sctp_cmd_process_operr()
938 static void sctp_cmd_process_fwdtsn(struct sctp_ulpq *ulpq, in sctp_cmd_process_fwdtsn() argument
944 sctp_ulpq_skip(ulpq, ntohs(skip->stream), ntohs(skip->ssn)); in sctp_cmd_process_fwdtsn()
987 sctp_ulpq_tail_event(&asoc->ulpq, ev); in sctp_cmd_assoc_change()
999 sctp_ulpq_tail_event(&asoc->ulpq, ev); in sctp_cmd_adaptation_ind()
1306 sctp_ulpq_reasm_flushtsn(&asoc->ulpq, cmd->obj.u32); in sctp_cmd_interpreter()
1309 sctp_ulpq_abort_pd(&asoc->ulpq, GFP_ATOMIC); in sctp_cmd_interpreter()
1313 sctp_cmd_process_fwdtsn(&asoc->ulpq, cmd->obj.chunk); in sctp_cmd_interpreter()
1415 __func__, cmd->obj.chunk, &asoc->ulpq); in sctp_cmd_interpreter()
[all …]
|
| D | associola.c | 246 if (!sctp_ulpq_init(&asoc->ulpq, asoc)) in sctp_association_init()
353 sctp_ulpq_free(&asoc->ulpq); in sctp_association_free()
841 sctp_ulpq_tail_event(&asoc->ulpq, event); in sctp_assoc_control_transport()
1136 sctp_ulpq_flush(&asoc->ulpq); in sctp_assoc_update()
|
| D | chunk.c | 127 sctp_ulpq_tail_event(&asoc->ulpq, ev); in sctp_datamsg_destroy()
|
| D | socket.c | 1513 if (data_was_unread || !skb_queue_empty(&asoc->ulpq.lobby) || in sctp_close()
1514 !skb_queue_empty(&asoc->ulpq.reasm) || in sctp_close()
2215 sctp_ulpq_tail_event(&asoc->ulpq, event); in sctp_setsockopt_events()
7294 atomic_set(&sctp_sk(newsk)->pd_mode, assoc->ulpq.pd_mode); in sctp_sock_migrate()
7300 if (assoc->ulpq.pd_mode) { in sctp_sock_migrate()
7320 if (assoc->ulpq.pd_mode) in sctp_sock_migrate()
7325 sctp_skb_for_each(skb, &assoc->ulpq.reasm, tmp) in sctp_sock_migrate()
7328 sctp_skb_for_each(skb, &assoc->ulpq.lobby, tmp) in sctp_sock_migrate()
|
| D | sm_statefuns.c | 6169 if ((datalen >= asoc->rwnd) && (!asoc->ulpq.pd_mode)) { in sctp_eat_data()
|
| /linux-4.4.14/include/net/sctp/ |
| D | ulpqueue.h | 54 void sctp_ulpq_flush(struct sctp_ulpq *ulpq);
76 void sctp_ulpq_skip(struct sctp_ulpq *ulpq, __u16 sid, __u16 ssn);
|
| D | structs.h | 1720 struct sctp_ulpq ulpq; member
|