| /openbmc/linux/net/sctp/ |
| H A D | associola.c | 167 asoc->a_rwnd = asoc->rwnd; in sctp_association_init()
182 asoc->next_tsn = asoc->c.initial_tsn; in sctp_association_init()
227 sctp_outq_init(asoc, &asoc->outqueue); in sctp_association_init()
229 sctp_ulpq_init(&asoc->ulpq, asoc); in sctp_association_init()
291 asoc = kzalloc(sizeof(*asoc), gfp); in sctp_association_new()
1419 asoc->pathmtu, asoc->frag_point); in sctp_assoc_set_pmtu()
1498 __func__, asoc, len, asoc->rwnd, asoc->rwnd_over, in sctp_assoc_rwnd_increase()
1507 asoc->a_rwnd = asoc->rwnd; in sctp_assoc_rwnd_increase()
1537 asoc->rwnd, asoc->rwnd_over); in sctp_assoc_rwnd_decrease()
1555 asoc->rwnd_press += asoc->rwnd; in sctp_assoc_rwnd_decrease()
[all …]
|
| H A D | sm_sideeffect.c | 205 asoc->a_rwnd = asoc->rwnd; in sctp_gen_sack()
256 asoc->ep, asoc, in sctp_generate_t3_rtx_event()
297 asoc->state, asoc->ep, asoc, in sctp_generate_timeout_event()
393 asoc->state, asoc->ep, asoc, in sctp_generate_heartbeat_event()
434 asoc->state, asoc->ep, asoc, transport, GFP_ATOMIC); in sctp_generate_proto_unreach_event()
467 asoc->state, asoc->ep, asoc, in sctp_generate_reconf_event()
499 asoc->state, asoc->ep, asoc, in sctp_generate_probe_event()
838 asoc->state, asoc->ep, asoc, NULL, in sctp_cmd_process_sack()
1315 asoc = cmd->obj.asoc; in sctp_cmd_interpreter()
1350 asoc->stream.si->handle_ftsn(&asoc->ulpq, in sctp_cmd_interpreter()
[all …]
|
| H A D | stream.c | 32 outq = &asoc->outqueue; in sctp_stream_shrink_out()
234 retval = sctp_primitive_RECONF(asoc->base.net, asoc, chunk); in sctp_send_reconf()
512 asoc->strreset_result[1] = asoc->strreset_result[0]; in sctp_update_strreset_result()
545 asoc->strreset_inseq++; in sctp_process_strreset_outreq()
630 asoc->strreset_inseq++; in sctp_process_strreset_inreq()
715 asoc->strreset_inseq++; in sctp_process_strreset_tsnreq()
731 asoc->stream.si->report_ftsn(&asoc->ulpq, max_tsn_seen); in sctp_process_strreset_tsnreq()
755 asoc->adv_peer_ack_point = asoc->ctsn_ack_point; in sctp_process_strreset_tsnreq()
1008 asoc->stream.si->report_ftsn(&asoc->ulpq, mtsn); in sctp_process_strreset_resp()
1023 asoc->ctsn_ack_point = asoc->next_tsn - 1; in sctp_process_strreset_resp()
[all …]
|
| H A D | sm_statefuns.c | 656 auth.asoc = chunk->asoc; in sctp_auth_chunk_verify()
714 if (asoc && !sctp_vtag_verify(chunk, asoc)) in sctp_sf_do_5_1D_ce()
1047 if (asoc->overall_error_count >= asoc->max_retrans) { in sctp_sf_sendbeat_8_3()
1095 if (asoc->overall_error_count >= asoc->max_retrans) { in sctp_sf_send_reconf()
3705 if (asoc && !sctp_vtag_verify(chunk, asoc)) in sctp_sf_ootb()
4616 if (asoc && !sctp_vtag_verify(chunk, asoc)) in sctp_sf_discard_chunk()
4732 if (asoc) { in sctp_sf_abort_violation()
5799 if (asoc->overall_error_count >= asoc->max_retrans) { in sctp_sf_do_6_3_3_rtx()
6039 if (asoc->overall_error_count >= asoc->max_retrans) { in sctp_sf_t2_timer_expire()
6123 if (asoc->overall_error_count >= asoc->max_retrans) { in sctp_sf_t4_timer_expire()
[all …]
|
| H A D | sm_make_chunk.c | 77 struct sctp_association *asoc = chunk->asoc; in sctp_control_release_owner() local
91 asoc->stream.si->enqueue_event(&asoc->ulpq, ev); in sctp_control_release_owner()
99 struct sctp_association *asoc = chunk->asoc; in sctp_control_set_owner_w() local
113 skb->sk = asoc ? asoc->base.sk : NULL; in sctp_control_set_owner_w()
524 retval->asoc = (struct sctp_association *) asoc; in sctp_make_init_ack()
1390 retval->asoc = (struct sctp_association *)asoc; in sctp_chunkify()
1453 sk = asoc ? asoc->base.sk : NULL; in _sctp_make_chunk()
2448 asoc->strreset_inseq = asoc->peer.i.initial_tsn; in sctp_process_init()
2466 asoc->c.peer_vtag = asoc->peer.i.init_tag; in sctp_process_init()
2469 asoc->peer.rwnd = asoc->peer.i.a_rwnd; in sctp_process_init()
[all …]
|
| H A D | socket.c | 126 struct sctp_association *asoc = chunk->asoc; in sctp_set_owner_w() local
258 if (asoc && (asoc->base.sk != sk || asoc->base.dead)) in sctp_id2assoc()
262 return asoc; in sctp_id2assoc()
1091 if (!asoc) in sctp_connect_new_asoc()
1192 if (asoc) in __sctp_connect()
1199 asoc = transport->asoc; in __sctp_connect()
1695 asoc = (*tp)->asoc; in sctp_sendmsg_new_asoc()
2008 asoc = transport->asoc; in sctp_sendmsg()
7269 asoc->stats.max_obs_rto = asoc->rto_min; in sctp_getsockopt_assoc_stats()
7924 params.assoc_value = asoc ? asoc->pf_expose in sctp_getsockopt_pf_expose()
[all …]
|
| H A D | stream_sched.c | 167 asoc->outqueue.sched = n; in sctp_sched_set_sched()
168 n->init(&asoc->stream); in sctp_sched_set_sched()
183 n->enqueue(&asoc->outqueue, msg); in sctp_sched_set_sched()
209 if (sid >= asoc->stream.outcnt) in sctp_sched_set_value()
220 return asoc->outqueue.sched->set(&asoc->stream, sid, value, gfp); in sctp_sched_set_value()
226 if (sid >= asoc->stream.outcnt) in sctp_sched_get_value()
232 return asoc->outqueue.sched->get(&asoc->stream, sid, value); in sctp_sched_get_value()
248 q->asoc->stream.out_curr = sout; in sctp_sched_dequeue_done()
252 q->asoc->stream.out_curr = NULL; in sctp_sched_dequeue_done()
275 struct sctp_association *asoc; in sctp_sched_ops_from_stream() local
[all …]
|
| H A D | auth.c | 400 ep_key = sctp_auth_get_shkey(asoc, asoc->active_key_id); in sctp_auth_asoc_init_active_key()
590 if (!asoc) in sctp_auth_asoc_verify_hmac_id()
620 ep = asoc->ep; in sctp_auth_asoc_set_default_hmac()
676 if (!asoc) in sctp_auth_send_cid()
688 if (!asoc) in sctp_auth_recv_cid()
829 if (asoc) { in sctp_auth_set_key()
889 if (asoc) { in sctp_auth_set_active_key()
909 if (asoc) { in sctp_auth_set_active_key()
934 if (asoc) { in sctp_auth_del_key_id()
977 if (asoc) { in sctp_auth_deact_key_id()
[all …]
|
| H A D | chunk.c | 74 struct sctp_association *asoc = NULL; in sctp_datamsg_destroy() local
90 asoc = chunk->asoc; in sctp_datamsg_destroy()
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()
174 max_data = asoc->frag_point; in sctp_datamsg_from_user()
179 __func__, asoc, max_data); in sctp_datamsg_from_user()
201 shkey = asoc->shkey; in sctp_datamsg_from_user()
228 SCTP_INC_STATS(asoc->base.net, in sctp_datamsg_from_user()
262 chunk = asoc->stream.si->make_datafrag(asoc, sinfo, len, frag, in sctp_datamsg_from_user()
315 SCTP_SO(&chunk->asoc->stream, in sctp_chunk_abandoned()
[all …]
|
| H A D | outqueue.c | 195 q->asoc = asoc; in sctp_outq_init()
201 sctp_sched_set_sched(asoc, sctp_sk(asoc->base.sk)->default_ss); in sctp_outq_init()
428 if (!asoc->peer.prsctp_capable || !asoc->sent_cnt_removable) in sctp_prsctp_prune()
580 q->asoc->stream.si->generate_ftsn(q, q->asoc->ctsn_ack_point); in sctp_retransmit()
770 const struct sctp_association *asoc = transport->asoc; in sctp_packet_singleton() local
1198 .asoc = q->asoc, in sctp_outq_flush()
1250 struct sctp_association *asoc = q->asoc; in sctp_outq_sack() local
1605 struct sctp_association *asoc = transport->asoc; in sctp_check_transmitted() local
1718 struct sctp_association *asoc = q->asoc; in sctp_mark_missing() local
1824 struct sctp_association *asoc = q->asoc; in sctp_generate_fwdtsn() local
[all …]
|
| H A D | ulpevent.c | 87 event->asoc = (struct sctp_association *)asoc; in sctp_ulpevent_set_owner()
91 chunk->head_skb->sk = asoc->base.sk; in sctp_ulpevent_set_owner()
97 struct sctp_association *asoc = event->asoc; in sctp_ulpevent_release_owner() local
100 sctp_association_put(asoc); in sctp_ulpevent_release_owner()
115 const struct sctp_association *asoc, in sctp_ulpevent_make_assoc_change() argument
242 const struct sctp_association *asoc, in sctp_ulpevent_make_peer_addr_change() argument
330 sctp_sk(asoc->base.sk), in sctp_ulpevent_make_peer_addr_change()
342 struct sctp_association *asoc = transport->asoc; in sctp_ulpevent_notify_peer_addr_change() local
355 asoc->stream.si->enqueue_event(&asoc->ulpq, event); in sctp_ulpevent_notify_peer_addr_change()
681 struct sock *sk = asoc->base.sk; in sctp_ulpevent_make_rcvmsg()
[all …]
|
| H A D | output.c | 77 struct sctp_association *asoc = tp->asoc; in sctp_packet_config() local
91 if (asoc) { in sctp_packet_config()
98 if (!asoc) in sctp_packet_config()
244 struct sctp_association *asoc = pkt->transport->asoc; in sctp_packet_bundle_auth() local
249 if (!asoc) in sctp_packet_bundle_auth()
292 asoc = pkt->transport->asoc; in sctp_packet_bundle_sack()
303 asoc->a_rwnd = asoc->rwnd; in sctp_packet_bundle_sack()
572 struct sctp_association *asoc = tp->asoc; in sctp_packet_transmit() local
642 if (asoc) { in sctp_packet_transmit()
677 struct sctp_association *asoc = transport->asoc; in sctp_packet_can_append_data() local
[all …]
|
| H A D | transport.c | 168 if (transport->asoc) in sctp_transport_destroy()
233 transport->asoc = asoc; in sctp_transport_set_owner()
248 struct sctp_association *asoc = transport->asoc; in sctp_transport_pmtu() local
250 if (!transport->pathmtu && asoc && asoc->pathmtu) in sctp_transport_pmtu()
451 struct sctp_association *asoc = transport->asoc; in sctp_transport_route() local
558 struct sctp_association *asoc = transport->asoc; in sctp_transport_raise_cwnd() local
656 struct sctp_association *asoc = transport->asoc; in sctp_transport_lower_cwnd() local
693 asoc->fast_recovery_exit = asoc->next_tsn - 1; in sctp_transport_lower_cwnd()
757 struct sctp_association *asoc = t->asoc; in sctp_transport_burst_limited() local
798 struct sctp_association *asoc = t->asoc; in sctp_transport_reset() local
[all …]
|
| H A D | input.c | 167 if (!asoc) in sctp_rcv()
171 rcvr = asoc ? &asoc->base : &ep->base; in sctp_rcv()
182 if (!asoc) { in sctp_rcv()
454 asoc->state, asoc->ep, asoc, t, in sctp_icmp_proto_unreachable()
491 if (!asoc) in sctp_err_lookup()
551 struct sctp_association *asoc = t->asoc; in sctp_v4_err_handle() local
961 if (transport->asoc->ep == t->asoc->ep) { in sctp_hash_transport()
1066 asoc = t->asoc; in __sctp_lookup_association()
1167 if (asoc) in __sctp_rcv_init_lookup()
1340 if (asoc) in __sctp_rcv_lookup()
[all …]
|
| H A D | diag.c | 28 struct sctp_association *asoc) in inet_diag_msg_sctpasoc_fill() argument
59 r->idiag_state = asoc->state; in inet_diag_msg_sctpasoc_fill()
146 if (asoc) { in inet_sctp_diag_fill()
160 if (asoc && asoc->ep->sndbuf_policy) in inet_sctp_diag_fill()
161 amt = asoc->sndbuf_used; in inet_sctp_diag_fill()
165 if (asoc && asoc->ep->rcvbuf_policy) in inet_sctp_diag_fill()
194 infox.asoc = asoc; in inet_sctp_diag_fill()
197 addr_list = asoc ? &asoc->base.bind_addr.address_list in inet_sctp_diag_fill()
206 if (asoc && inet_diag_msg_sctpaddrs_fill(skb, asoc)) in inet_sctp_diag_fill()
297 if (ep != tsp->asoc->ep) in sctp_sock_dump()
[all …]
|
| H A D | endpointola.c | 152 struct sctp_association *asoc) in sctp_endpoint_add_asoc() argument
160 if (asoc->temp) in sctp_endpoint_add_asoc()
292 asoc = t->asoc; in sctp_endpoint_lookup_assoc()
295 return asoc; in sctp_endpoint_lookup_assoc()
330 struct sctp_association *asoc; in sctp_endpoint_bh_rcv() local
344 asoc = NULL; in sctp_endpoint_bh_rcv()
381 if (NULL == chunk->asoc) { in sctp_endpoint_bh_rcv()
385 chunk->asoc = asoc; in sctp_endpoint_bh_rcv()
389 state = asoc ? asoc->state : SCTP_STATE_CLOSED; in sctp_endpoint_bh_rcv()
400 if (asoc) in sctp_endpoint_bh_rcv()
[all …]
|
| H A D | ulpqueue.c | 45 ulpq->asoc = asoc; in sctp_ulpq_init()
150 if (event->asoc == asoc) { in sctp_clear_pd()
176 return sctp_clear_pd(ulpq->asoc->base.sk, ulpq->asoc); in sctp_ulpq_clear_pd()
403 struct sctp_association *asoc; in sctp_ulpq_retrieve_reassembled() local
469 asoc = ulpq->asoc; in sctp_ulpq_retrieve_reassembled()
749 stream = &ulpq->asoc->stream; in sctp_ulpq_retrieve_ordered()
878 stream = &ulpq->asoc->stream; in sctp_ulpq_reap_ordered()
1028 asoc = ulpq->asoc; in sctp_ulpq_partial_delivery()
1029 sp = sctp_sk(asoc->base.sk); in sctp_ulpq_partial_delivery()
1072 struct sctp_association *asoc = ulpq->asoc; in sctp_ulpq_renege() local
[all …]
|
| H A D | stream_interleave.c | 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()
261 struct sctp_association *asoc = ulpq->asoc; in sctp_intl_retrieve_reassembled() local
425 stream = &ulpq->asoc->stream; in sctp_intl_retrieve_ordered()
454 stream = &ulpq->asoc->stream; in sctp_intl_order()
643 struct sctp_association *asoc = ulpq->asoc; in sctp_intl_retrieve_reassembled_uo() local
957 struct sctp_association *asoc = ulpq->asoc; in sctp_renege_events() local
1101 struct sctp_association *asoc = q->asoc; in sctp_generate_iftsn() local
1146 ftsn_chunk = sctp_make_ifwdtsn(asoc, asoc->adv_peer_ack_point, in sctp_generate_iftsn()
[all …]
|
| H A D | primitive.c | 38 int sctp_primitive_ ## name(struct net *net, struct sctp_association *asoc, \
47 state = asoc ? asoc->state : SCTP_STATE_CLOSED; \
48 ep = asoc ? asoc->ep : NULL; \
50 error = sctp_do_sm(net, event_type, subtype, state, ep, asoc, \
|
| H A D | stream_sched_rr.c | 106 stream = &q->asoc->stream; in sctp_sched_rr_enqueue()
112 struct sctp_stream *stream = &q->asoc->stream; in sctp_sched_rr_dequeue()
141 soute = SCTP_SO(&q->asoc->stream, sid)->ext; in sctp_sched_rr_dequeue_done()
143 sctp_sched_rr_next_stream(&q->asoc->stream); in sctp_sched_rr_dequeue_done()
146 sctp_sched_rr_unsched(&q->asoc->stream, soute); in sctp_sched_rr_dequeue_done()
151 struct sctp_association *asoc; in sctp_sched_rr_sched_all() local
155 asoc = container_of(stream, struct sctp_association, stream); in sctp_sched_rr_sched_all()
156 list_for_each_entry(ch, &asoc->outqueue.out_chunk_list, list) { in sctp_sched_rr_sched_all()
|
| /openbmc/linux/include/net/sctp/ |
| H A D | sm.h | 56 const struct sctp_association *asoc,
199 const struct sctp_association *asoc,
211 const struct sctp_association *asoc,
278 struct sctp_association *asoc,
282 struct sctp_association *asoc,
286 struct sctp_association *asoc,
290 struct sctp_association *asoc,
294 struct sctp_association *asoc,
298 struct sctp_association *asoc,
376 const struct sctp_association *asoc) in sctp_vtag_verify() argument
[all …]
|
| H A D | auth.h | 73 int sctp_auth_asoc_init_active_key(struct sctp_association *asoc, gfp_t gfp);
75 const struct sctp_association *asoc,
78 struct sctp_association *asoc,
84 void sctp_auth_asoc_set_default_hmac(struct sctp_association *asoc,
86 int sctp_auth_asoc_verify_hmac_id(const struct sctp_association *asoc,
89 const struct sctp_association *asoc);
91 const struct sctp_association *asoc);
92 void sctp_auth_calculate_hmac(const struct sctp_association *asoc,
105 struct sctp_association *asoc, __u16 key_id);
107 struct sctp_association *asoc, __u16 key_id);
[all …]
|
| H A D | ulpevent.h | 39 struct sctp_association *asoc; member
74 const struct sctp_association *asoc,
87 const struct sctp_association *asoc,
92 const struct sctp_association *asoc,
99 const struct sctp_association *asoc,
106 const struct sctp_association *asoc,
111 const struct sctp_association *asoc,
116 const struct sctp_association *asoc, gfp_t gfp);
127 const struct sctp_association *asoc, gfp_t gfp);
130 const struct sctp_association *asoc, __u16 flags,
[all …]
|
| H A D | sctp.h | 98 struct sctp_association *asoc);
149 struct sctp_association *asoc,
186 int sctp_send_add_streams(struct sctp_association *asoc,
259 if (asoc->stats.max_obs_rto < (__u64)trans->rto) { in sctp_max_rto()
260 asoc->stats.max_obs_rto = trans->rto; in sctp_max_rto()
261 memset(&asoc->stats.obs_rto_ipaddr, 0, in sctp_max_rto()
263 memcpy(&asoc->stats.obs_rto_ipaddr, &trans->ipaddr, in sctp_max_rto()
348 return asoc ? asoc->assoc_id : 0; in sctp_assoc2id()
361 return asoc->state + 1; in sctp_assoc_to_state()
519 #define sctp_state(asoc, state) __sctp_state((asoc), (SCTP_STATE_##state)) argument
[all …]
|
| /openbmc/linux/include/trace/events/ |
| H A D | sctp.h | 14 const struct sctp_association *asoc),
16 TP_ARGS(sp, asoc),
19 __field(__u64, asoc)
31 __entry->asoc = (unsigned long)asoc;
53 const struct sctp_association *asoc,
56 TP_ARGS(ep, asoc, chunk),
59 __field(__u64, asoc)
71 __entry->asoc = (unsigned long)asoc;
74 __entry->peer_port = asoc->peer.port;
75 __entry->pathmtu = asoc->pathmtu;
[all …]
|