/linux/net/sctp/ |
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 if (!sctp_ulpq_init(&asoc->ulpq, asoc)) in sctp_association_init() 294 asoc = kzalloc(sizeof(*asoc), gfp); in sctp_association_new() 1423 asoc->pathmtu, asoc->frag_point); in sctp_assoc_set_pmtu() 1502 __func__, asoc, len, asoc->rwnd, asoc->rwnd_over, in sctp_assoc_rwnd_increase() 1511 asoc->a_rwnd = asoc->rwnd; in sctp_assoc_rwnd_increase() 1541 asoc->rwnd, asoc->rwnd_over); in sctp_assoc_rwnd_decrease() 1559 asoc->rwnd_press += asoc->rwnd; in sctp_assoc_rwnd_decrease() [all …]
|
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() 463 asoc->state, asoc->ep, asoc, in sctp_generate_reconf_event() 495 asoc->state, asoc->ep, asoc, in sctp_generate_probe_event() 834 asoc->state, asoc->ep, asoc, NULL, in sctp_cmd_process_sack() 1309 asoc = cmd->obj.asoc; in sctp_cmd_interpreter() 1344 asoc->stream.si->handle_ftsn(&asoc->ulpq, in sctp_cmd_interpreter() [all …]
|
A D | stream.c | 32 outq = &asoc->outqueue; in sctp_stream_shrink_out() 236 retval = sctp_primitive_RECONF(asoc->base.net, asoc, chunk); in sctp_send_reconf() 514 asoc->strreset_result[1] = asoc->strreset_result[0]; in sctp_update_strreset_result() 547 asoc->strreset_inseq++; in sctp_process_strreset_outreq() 632 asoc->strreset_inseq++; in sctp_process_strreset_inreq() 717 asoc->strreset_inseq++; in sctp_process_strreset_tsnreq() 733 asoc->stream.si->report_ftsn(&asoc->ulpq, max_tsn_seen); in sctp_process_strreset_tsnreq() 757 asoc->adv_peer_ack_point = asoc->ctsn_ack_point; in sctp_process_strreset_tsnreq() 1010 asoc->stream.si->report_ftsn(&asoc->ulpq, mtsn); in sctp_process_strreset_resp() 1025 asoc->ctsn_ack_point = asoc->next_tsn - 1; in sctp_process_strreset_resp() [all …]
|
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() 1046 if (asoc->overall_error_count >= asoc->max_retrans) { in sctp_sf_sendbeat_8_3() 1094 if (asoc->overall_error_count >= asoc->max_retrans) { in sctp_sf_send_reconf() 3696 if (asoc && !sctp_vtag_verify(chunk, asoc)) in sctp_sf_ootb() 4607 if (asoc && !sctp_vtag_verify(chunk, asoc)) in sctp_sf_discard_chunk() 4723 if (asoc) { in sctp_sf_abort_violation() 5790 if (asoc->overall_error_count >= asoc->max_retrans) { in sctp_sf_do_6_3_3_rtx() 6030 if (asoc->overall_error_count >= asoc->max_retrans) { in sctp_sf_t2_timer_expire() 6114 if (asoc->overall_error_count >= asoc->max_retrans) { in sctp_sf_t4_timer_expire() [all …]
|
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 …]
|
A D | socket.c | 124 struct sctp_association *asoc = chunk->asoc; in sctp_set_owner_w() local 256 if (asoc && (asoc->base.sk != sk || asoc->base.dead)) in sctp_id2assoc() 260 return asoc; in sctp_id2assoc() 1089 if (!asoc) in sctp_connect_new_asoc() 1190 if (asoc) in __sctp_connect() 1197 asoc = transport->asoc; in __sctp_connect() 1693 asoc = (*tp)->asoc; in sctp_sendmsg_new_asoc() 2005 asoc = transport->asoc; in sctp_sendmsg() 7258 asoc->stats.max_obs_rto = asoc->rto_min; in sctp_getsockopt_assoc_stats() 7913 params.assoc_value = asoc ? asoc->pf_expose in sctp_getsockopt_pf_expose() [all …]
|
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() 884 if (asoc) { in sctp_auth_set_active_key() 904 if (asoc) { in sctp_auth_set_active_key() 924 if (asoc) { in sctp_auth_del_key_id() 967 if (asoc) { in sctp_auth_deact_key_id() [all …]
|
A D | stream_sched.c | 145 old->free(&asoc->stream); in sctp_sched_set_sched() 160 asoc->outqueue.sched = n; in sctp_sched_set_sched() 161 n->init(&asoc->stream); in sctp_sched_set_sched() 182 n->free(&asoc->stream); in sctp_sched_set_sched() 202 if (sid >= asoc->stream.outcnt) in sctp_sched_set_value() 213 return asoc->outqueue.sched->set(&asoc->stream, sid, value, gfp); in sctp_sched_set_value() 219 if (sid >= asoc->stream.outcnt) in sctp_sched_get_value() 225 return asoc->outqueue.sched->get(&asoc->stream, sid, value); in sctp_sched_get_value() 245 q->asoc->stream.out_curr = NULL; in sctp_sched_dequeue_done() 268 struct sctp_association *asoc; in sctp_sched_ops_from_stream() local [all …]
|
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() 425 if (!asoc->peer.prsctp_capable || !asoc->sent_cnt_removable) in sctp_prsctp_prune() 574 q->asoc->stream.si->generate_ftsn(q, q->asoc->ctsn_ack_point); in sctp_retransmit() 764 const struct sctp_association *asoc = transport->asoc; in sctp_packet_singleton() local 1188 .asoc = q->asoc, in sctp_outq_flush() 1240 struct sctp_association *asoc = q->asoc; in sctp_outq_sack() local 1592 struct sctp_association *asoc = transport->asoc; in sctp_check_transmitted() local 1705 struct sctp_association *asoc = q->asoc; in sctp_mark_missing() local 1811 struct sctp_association *asoc = q->asoc; in sctp_generate_fwdtsn() local [all …]
|
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 …]
|
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 …]
|
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() 243 struct sctp_association *asoc = pkt->transport->asoc; in sctp_packet_bundle_auth() local 248 if (!asoc) in sctp_packet_bundle_auth() 291 asoc = pkt->transport->asoc; in sctp_packet_bundle_sack() 302 asoc->a_rwnd = asoc->rwnd; in sctp_packet_bundle_sack() 571 struct sctp_association *asoc = tp->asoc; in sctp_packet_transmit() local 641 if (asoc) { in sctp_packet_transmit() 676 struct sctp_association *asoc = transport->asoc; in sctp_packet_can_append_data() local [all …]
|
A D | transport.c | 168 if (transport->asoc) in sctp_transport_destroy() 230 transport->asoc = asoc; in sctp_transport_set_owner() 245 struct sctp_association *asoc = transport->asoc; in sctp_transport_pmtu() local 247 if (!transport->pathmtu && asoc && asoc->pathmtu) in sctp_transport_pmtu() 454 struct sctp_association *asoc = transport->asoc; in sctp_transport_route() local 561 struct sctp_association *asoc = transport->asoc; in sctp_transport_raise_cwnd() local 659 struct sctp_association *asoc = transport->asoc; in sctp_transport_lower_cwnd() local 696 asoc->fast_recovery_exit = asoc->next_tsn - 1; in sctp_transport_lower_cwnd() 760 struct sctp_association *asoc = t->asoc; in sctp_transport_burst_limited() local 801 struct sctp_association *asoc = t->asoc; in sctp_transport_reset() local [all …]
|
A D | input.c | 161 if (!asoc) in sctp_rcv() 165 rcvr = asoc ? &asoc->base : &ep->base; in sctp_rcv() 195 if (!asoc) { in sctp_rcv() 467 asoc->state, asoc->ep, asoc, t, in sctp_icmp_proto_unreachable() 502 if (!asoc) in sctp_err_lookup() 562 struct sctp_association *asoc = t->asoc; in sctp_v4_err_handle() local 975 if (transport->asoc->ep == t->asoc->ep) { in sctp_hash_transport() 1065 asoc = t->asoc; in __sctp_lookup_association() 1163 if (asoc) in __sctp_rcv_init_lookup() 1332 if (asoc) in __sctp_rcv_lookup() [all …]
|
A D | diag.c | 59 r->idiag_state = asoc->state; in inet_diag_msg_sctpasoc_fill() 147 if (asoc) { in inet_sctp_diag_fill() 163 if (asoc && asoc->ep->sndbuf_policy) in inet_sctp_diag_fill() 164 amt = asoc->sndbuf_used; in inet_sctp_diag_fill() 168 if (asoc && asoc->ep->rcvbuf_policy) in inet_sctp_diag_fill() 197 infox.asoc = asoc; in inet_sctp_diag_fill() 200 addr_list = asoc ? &asoc->base.bind_addr.address_list in inet_sctp_diag_fill() 209 if (asoc && inet_diag_msg_sctpaddrs_fill(skb, asoc)) in inet_sctp_diag_fill() 300 if (ep != tsp->asoc->ep) in sctp_sock_dump() 353 if (tsp->asoc != assoc) in sctp_sock_filter() [all …]
|
A D | endpointola.c | 152 struct sctp_association *asoc) in sctp_endpoint_add_asoc() argument 160 if (asoc->temp) in sctp_endpoint_add_asoc() 289 asoc = t->asoc; in sctp_endpoint_lookup_assoc() 292 return asoc; in sctp_endpoint_lookup_assoc() 325 struct sctp_association *asoc; in sctp_endpoint_bh_rcv() local 339 asoc = NULL; in sctp_endpoint_bh_rcv() 376 if (NULL == chunk->asoc) { in sctp_endpoint_bh_rcv() 380 chunk->asoc = asoc; in sctp_endpoint_bh_rcv() 384 state = asoc ? asoc->state : SCTP_STATE_CLOSED; in sctp_endpoint_bh_rcv() 395 if (asoc) in sctp_endpoint_bh_rcv() [all …]
|
A D | ulpqueue.c | 42 struct sctp_association *asoc) in sctp_ulpq_init() argument 46 ulpq->asoc = asoc; in sctp_ulpq_init() 153 if (event->asoc == asoc) { in sctp_clear_pd() 179 return sctp_clear_pd(ulpq->asoc->base.sk, ulpq->asoc); in sctp_ulpq_clear_pd() 409 struct sctp_association *asoc; in sctp_ulpq_retrieve_reassembled() local 475 asoc = ulpq->asoc; in sctp_ulpq_retrieve_reassembled() 884 stream = &ulpq->asoc->stream; in sctp_ulpq_reap_ordered() 1034 asoc = ulpq->asoc; in sctp_ulpq_partial_delivery() 1035 sp = sctp_sk(asoc->base.sk); in sctp_ulpq_partial_delivery() 1078 struct sctp_association *asoc = ulpq->asoc; in sctp_ulpq_renege() local [all …]
|
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() 649 struct sctp_association *asoc = ulpq->asoc; in sctp_intl_retrieve_reassembled_uo() local 963 struct sctp_association *asoc = ulpq->asoc; in sctp_renege_events() local 983 sk_mem_reclaim(asoc->base.sk); in sctp_renege_events() 1109 struct sctp_association *asoc = q->asoc; in sctp_generate_iftsn() local [all …]
|
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, \
|
A D | stream_sched_rr.c | 107 stream = &q->asoc->stream; in sctp_sched_rr_enqueue() 113 struct sctp_stream *stream = &q->asoc->stream; in sctp_sched_rr_dequeue() 142 soute = SCTP_SO(&q->asoc->stream, sid)->ext; in sctp_sched_rr_dequeue_done() 144 sctp_sched_rr_next_stream(&q->asoc->stream); in sctp_sched_rr_dequeue_done() 147 sctp_sched_rr_unsched(&q->asoc->stream, soute); in sctp_sched_rr_dequeue_done() 152 struct sctp_association *asoc; in sctp_sched_rr_sched_all() local 156 asoc = container_of(stream, struct sctp_association, stream); in sctp_sched_rr_sched_all() 157 list_for_each_entry(ch, &asoc->outqueue.out_chunk_list, list) { in sctp_sched_rr_sched_all()
|
/linux/include/net/sctp/ |
A D | sm.h | 56 const struct sctp_association *asoc, 202 const struct sctp_association *asoc, 214 const struct sctp_association *asoc, 281 struct sctp_association *asoc, 285 struct sctp_association *asoc, 289 struct sctp_association *asoc, 293 struct sctp_association *asoc, 297 struct sctp_association *asoc, 301 struct sctp_association *asoc, 379 const struct sctp_association *asoc) in sctp_vtag_verify() argument [all …]
|
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 …]
|
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 …]
|
A D | sctp.h | 103 struct sctp_association *asoc); 154 struct sctp_association *asoc, 191 int sctp_send_add_streams(struct sctp_association *asoc, 264 if (asoc->stats.max_obs_rto < (__u64)trans->rto) { in sctp_max_rto() 265 asoc->stats.max_obs_rto = trans->rto; in sctp_max_rto() 266 memset(&asoc->stats.obs_rto_ipaddr, 0, in sctp_max_rto() 268 memcpy(&asoc->stats.obs_rto_ipaddr, &trans->ipaddr, in sctp_max_rto() 353 return asoc ? asoc->assoc_id : 0; in sctp_assoc2id() 366 return asoc->state + 1; in sctp_assoc_to_state() 524 #define sctp_state(asoc, state) __sctp_state((asoc), (SCTP_STATE_##state)) argument [all …]
|
/linux/include/trace/events/ |
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 …]
|