Lines Matching refs:asoc
43 static void sctp_select_active_and_retran_path(struct sctp_association *asoc);
45 static void sctp_assoc_free_asconf_acks(struct sctp_association *asoc);
46 static void sctp_assoc_free_asconf_queue(struct sctp_association *asoc);
52 struct sctp_association *asoc, in sctp_association_init() argument
65 asoc->ep = (struct sctp_endpoint *)ep; in sctp_association_init()
66 asoc->base.sk = (struct sock *)sk; in sctp_association_init()
67 asoc->base.net = sock_net(sk); in sctp_association_init()
69 sctp_endpoint_hold(asoc->ep); in sctp_association_init()
70 sock_hold(asoc->base.sk); in sctp_association_init()
73 asoc->base.type = SCTP_EP_TYPE_ASSOCIATION; in sctp_association_init()
76 refcount_set(&asoc->base.refcnt, 1); in sctp_association_init()
79 sctp_bind_addr_init(&asoc->base.bind_addr, ep->base.bind_addr.port); in sctp_association_init()
81 asoc->state = SCTP_STATE_CLOSED; in sctp_association_init()
82 asoc->cookie_life = ms_to_ktime(sp->assocparams.sasoc_cookie_life); in sctp_association_init()
83 asoc->user_frag = sp->user_frag; in sctp_association_init()
88 asoc->max_retrans = sp->assocparams.sasoc_asocmaxrxt; in sctp_association_init()
89 asoc->pf_retrans = sp->pf_retrans; in sctp_association_init()
90 asoc->ps_retrans = sp->ps_retrans; in sctp_association_init()
91 asoc->pf_expose = sp->pf_expose; in sctp_association_init()
93 asoc->rto_initial = msecs_to_jiffies(sp->rtoinfo.srto_initial); in sctp_association_init()
94 asoc->rto_max = msecs_to_jiffies(sp->rtoinfo.srto_max); in sctp_association_init()
95 asoc->rto_min = msecs_to_jiffies(sp->rtoinfo.srto_min); in sctp_association_init()
100 asoc->hbinterval = msecs_to_jiffies(sp->hbinterval); in sctp_association_init()
103 asoc->pathmaxrxt = sp->pathmaxrxt; in sctp_association_init()
105 asoc->flowlabel = sp->flowlabel; in sctp_association_init()
106 asoc->dscp = sp->dscp; in sctp_association_init()
109 asoc->sackdelay = msecs_to_jiffies(sp->sackdelay); in sctp_association_init()
110 asoc->sackfreq = sp->sackfreq; in sctp_association_init()
115 asoc->param_flags = sp->param_flags; in sctp_association_init()
120 asoc->max_burst = sp->max_burst; in sctp_association_init()
122 asoc->subscribe = sp->subscribe; in sctp_association_init()
125 asoc->timeouts[SCTP_EVENT_TIMEOUT_T1_COOKIE] = asoc->rto_initial; in sctp_association_init()
126 asoc->timeouts[SCTP_EVENT_TIMEOUT_T1_INIT] = asoc->rto_initial; in sctp_association_init()
127 asoc->timeouts[SCTP_EVENT_TIMEOUT_T2_SHUTDOWN] = asoc->rto_initial; in sctp_association_init()
133 asoc->timeouts[SCTP_EVENT_TIMEOUT_T5_SHUTDOWN_GUARD] in sctp_association_init()
134 = 5 * asoc->rto_max; in sctp_association_init()
136 asoc->timeouts[SCTP_EVENT_TIMEOUT_SACK] = asoc->sackdelay; in sctp_association_init()
137 asoc->timeouts[SCTP_EVENT_TIMEOUT_AUTOCLOSE] = sp->autoclose * HZ; in sctp_association_init()
141 timer_setup(&asoc->timers[i], sctp_timer_events[i], 0); in sctp_association_init()
147 asoc->c.sinit_max_instreams = sp->initmsg.sinit_max_instreams; in sctp_association_init()
148 asoc->c.sinit_num_ostreams = sp->initmsg.sinit_num_ostreams; in sctp_association_init()
149 asoc->max_init_attempts = sp->initmsg.sinit_max_attempts; in sctp_association_init()
151 asoc->max_init_timeo = in sctp_association_init()
160 asoc->rwnd = SCTP_DEFAULT_MINWINDOW; in sctp_association_init()
162 asoc->rwnd = sk->sk_rcvbuf/2; in sctp_association_init()
164 asoc->a_rwnd = asoc->rwnd; in sctp_association_init()
167 asoc->peer.rwnd = SCTP_DEFAULT_MAXWINDOW; in sctp_association_init()
170 atomic_set(&asoc->rmem_alloc, 0); in sctp_association_init()
172 init_waitqueue_head(&asoc->wait); in sctp_association_init()
174 asoc->c.my_vtag = sctp_generate_tag(ep); in sctp_association_init()
175 asoc->c.my_port = ep->base.bind_addr.port; in sctp_association_init()
177 asoc->c.initial_tsn = sctp_generate_tsn(ep); in sctp_association_init()
179 asoc->next_tsn = asoc->c.initial_tsn; in sctp_association_init()
181 asoc->ctsn_ack_point = asoc->next_tsn - 1; in sctp_association_init()
182 asoc->adv_peer_ack_point = asoc->ctsn_ack_point; in sctp_association_init()
183 asoc->highest_sacked = asoc->ctsn_ack_point; in sctp_association_init()
184 asoc->last_cwr_tsn = asoc->ctsn_ack_point; in sctp_association_init()
196 asoc->addip_serial = asoc->c.initial_tsn; in sctp_association_init()
197 asoc->strreset_outseq = asoc->c.initial_tsn; in sctp_association_init()
199 INIT_LIST_HEAD(&asoc->addip_chunk_list); in sctp_association_init()
200 INIT_LIST_HEAD(&asoc->asconf_ack_list); in sctp_association_init()
203 INIT_LIST_HEAD(&asoc->peer.transport_addr_list); in sctp_association_init()
216 asoc->peer.sack_needed = 1; in sctp_association_init()
217 asoc->peer.sack_generation = 1; in sctp_association_init()
220 sctp_inq_init(&asoc->base.inqueue); in sctp_association_init()
221 sctp_inq_set_th_handler(&asoc->base.inqueue, sctp_assoc_bh_rcv); in sctp_association_init()
224 sctp_outq_init(asoc, &asoc->outqueue); in sctp_association_init()
226 if (!sctp_ulpq_init(&asoc->ulpq, asoc)) in sctp_association_init()
229 if (sctp_stream_init(&asoc->stream, asoc->c.sinit_num_ostreams, 0, gfp)) in sctp_association_init()
233 asoc->pathmtu = sp->pathmtu; in sctp_association_init()
234 sctp_assoc_update_frag_point(asoc); in sctp_association_init()
239 asoc->peer.ipv4_address = 1; in sctp_association_init()
240 if (asoc->base.sk->sk_family == PF_INET6) in sctp_association_init()
241 asoc->peer.ipv6_address = 1; in sctp_association_init()
242 INIT_LIST_HEAD(&asoc->asocs); in sctp_association_init()
244 asoc->default_stream = sp->default_stream; in sctp_association_init()
245 asoc->default_ppid = sp->default_ppid; in sctp_association_init()
246 asoc->default_flags = sp->default_flags; in sctp_association_init()
247 asoc->default_context = sp->default_context; in sctp_association_init()
248 asoc->default_timetolive = sp->default_timetolive; in sctp_association_init()
249 asoc->default_rcv_context = sp->default_rcv_context; in sctp_association_init()
252 INIT_LIST_HEAD(&asoc->endpoint_shared_keys); in sctp_association_init()
253 if (sctp_auth_asoc_copy_shkeys(ep, asoc, gfp)) in sctp_association_init()
256 asoc->active_key_id = ep->active_key_id; in sctp_association_init()
257 asoc->strreset_enable = ep->strreset_enable; in sctp_association_init()
261 memcpy(asoc->c.auth_hmacs, ep->auth_hmacs_list, in sctp_association_init()
264 memcpy(asoc->c.auth_chunks, ep->auth_chunk_list, in sctp_association_init()
268 p = (struct sctp_paramhdr *)asoc->c.auth_random; in sctp_association_init()
273 return asoc; in sctp_association_init()
276 sctp_stream_free(&asoc->stream); in sctp_association_init()
278 sock_put(asoc->base.sk); in sctp_association_init()
279 sctp_endpoint_put(asoc->ep); in sctp_association_init()
288 struct sctp_association *asoc; in sctp_association_new() local
290 asoc = kzalloc(sizeof(*asoc), gfp); in sctp_association_new()
291 if (!asoc) in sctp_association_new()
294 if (!sctp_association_init(asoc, ep, sk, scope, gfp)) in sctp_association_new()
299 pr_debug("Created asoc %p\n", asoc); in sctp_association_new()
301 return asoc; in sctp_association_new()
304 kfree(asoc); in sctp_association_new()
312 void sctp_association_free(struct sctp_association *asoc) in sctp_association_free() argument
314 struct sock *sk = asoc->base.sk; in sctp_association_free()
322 if (!list_empty(&asoc->asocs)) { in sctp_association_free()
323 list_del(&asoc->asocs); in sctp_association_free()
335 asoc->base.dead = true; in sctp_association_free()
338 sctp_outq_free(&asoc->outqueue); in sctp_association_free()
341 sctp_ulpq_free(&asoc->ulpq); in sctp_association_free()
344 sctp_inq_free(&asoc->base.inqueue); in sctp_association_free()
346 sctp_tsnmap_free(&asoc->peer.tsn_map); in sctp_association_free()
349 sctp_stream_free(&asoc->stream); in sctp_association_free()
351 if (asoc->strreset_chunk) in sctp_association_free()
352 sctp_chunk_free(asoc->strreset_chunk); in sctp_association_free()
355 sctp_bind_addr_free(&asoc->base.bind_addr); in sctp_association_free()
363 if (del_timer(&asoc->timers[i])) in sctp_association_free()
364 sctp_association_put(asoc); in sctp_association_free()
368 kfree(asoc->peer.cookie); in sctp_association_free()
369 kfree(asoc->peer.peer_random); in sctp_association_free()
370 kfree(asoc->peer.peer_chunks); in sctp_association_free()
371 kfree(asoc->peer.peer_hmacs); in sctp_association_free()
374 list_for_each_safe(pos, temp, &asoc->peer.transport_addr_list) { in sctp_association_free()
381 asoc->peer.transport_count = 0; in sctp_association_free()
383 sctp_asconf_queue_teardown(asoc); in sctp_association_free()
386 kfree(asoc->asconf_addr_del_pending); in sctp_association_free()
389 sctp_auth_destroy_keys(&asoc->endpoint_shared_keys); in sctp_association_free()
392 sctp_auth_key_put(asoc->asoc_shared_key); in sctp_association_free()
394 sctp_association_put(asoc); in sctp_association_free()
398 static void sctp_association_destroy(struct sctp_association *asoc) in sctp_association_destroy() argument
400 if (unlikely(!asoc->base.dead)) { in sctp_association_destroy()
401 WARN(1, "Attempt to destroy undead association %p!\n", asoc); in sctp_association_destroy()
405 sctp_endpoint_put(asoc->ep); in sctp_association_destroy()
406 sock_put(asoc->base.sk); in sctp_association_destroy()
408 if (asoc->assoc_id != 0) { in sctp_association_destroy()
410 idr_remove(&sctp_assocs_id, asoc->assoc_id); in sctp_association_destroy()
414 WARN_ON(atomic_read(&asoc->rmem_alloc)); in sctp_association_destroy()
416 kfree_rcu(asoc, rcu); in sctp_association_destroy()
421 void sctp_assoc_set_primary(struct sctp_association *asoc, in sctp_assoc_set_primary() argument
429 if (asoc->peer.primary_path != NULL && in sctp_assoc_set_primary()
430 asoc->peer.primary_path != transport) in sctp_assoc_set_primary()
433 asoc->peer.primary_path = transport; in sctp_assoc_set_primary()
438 memcpy(&asoc->peer.primary_addr, &transport->ipaddr, in sctp_assoc_set_primary()
446 asoc->peer.active_path = transport; in sctp_assoc_set_primary()
462 if (!asoc->outqueue.outstanding_bytes && !asoc->outqueue.out_qlen) in sctp_assoc_set_primary()
476 transport->cacc.next_tsn_at_change = asoc->next_tsn; in sctp_assoc_set_primary()
480 void sctp_assoc_rm_peer(struct sctp_association *asoc, in sctp_assoc_rm_peer() argument
488 __func__, asoc, &peer->ipaddr.sa); in sctp_assoc_rm_peer()
493 if (asoc->peer.retran_path == peer) in sctp_assoc_rm_peer()
494 sctp_assoc_update_retran_path(asoc); in sctp_assoc_rm_peer()
502 pos = asoc->peer.transport_addr_list.next; in sctp_assoc_rm_peer()
506 if (asoc->peer.primary_path == peer) in sctp_assoc_rm_peer()
507 sctp_assoc_set_primary(asoc, transport); in sctp_assoc_rm_peer()
508 if (asoc->peer.active_path == peer) in sctp_assoc_rm_peer()
509 asoc->peer.active_path = transport; in sctp_assoc_rm_peer()
510 if (asoc->peer.retran_path == peer) in sctp_assoc_rm_peer()
511 asoc->peer.retran_path = transport; in sctp_assoc_rm_peer()
512 if (asoc->peer.last_data_from == peer) in sctp_assoc_rm_peer()
513 asoc->peer.last_data_from = transport; in sctp_assoc_rm_peer()
515 if (asoc->strreset_chunk && in sctp_assoc_rm_peer()
516 asoc->strreset_chunk->transport == peer) { in sctp_assoc_rm_peer()
517 asoc->strreset_chunk->transport = transport; in sctp_assoc_rm_peer()
526 if (asoc->init_last_sent_to == peer) in sctp_assoc_rm_peer()
527 asoc->init_last_sent_to = NULL; in sctp_assoc_rm_peer()
534 if (asoc->shutdown_last_sent_to == peer) in sctp_assoc_rm_peer()
535 asoc->shutdown_last_sent_to = NULL; in sctp_assoc_rm_peer()
540 if (asoc->addip_last_asconf && in sctp_assoc_rm_peer()
541 asoc->addip_last_asconf->transport == peer) in sctp_assoc_rm_peer()
542 asoc->addip_last_asconf->transport = NULL; in sctp_assoc_rm_peer()
548 struct sctp_transport *active = asoc->peer.active_path; in sctp_assoc_rm_peer()
570 list_for_each_entry(ch, &asoc->outqueue.out_chunk_list, list) in sctp_assoc_rm_peer()
574 asoc->peer.transport_count--; in sctp_assoc_rm_peer()
581 struct sctp_transport *sctp_assoc_add_peer(struct sctp_association *asoc, in sctp_assoc_add_peer() argument
590 sp = sctp_sk(asoc->base.sk); in sctp_assoc_add_peer()
596 asoc, &addr->sa, peer_state); in sctp_assoc_add_peer()
599 if (0 == asoc->peer.port) in sctp_assoc_add_peer()
600 asoc->peer.port = port; in sctp_assoc_add_peer()
603 peer = sctp_assoc_lookup_paddr(asoc, addr); in sctp_assoc_add_peer()
615 peer = sctp_transport_new(asoc->base.net, addr, gfp); in sctp_assoc_add_peer()
619 sctp_transport_set_owner(peer, asoc); in sctp_assoc_add_peer()
624 peer->hbinterval = asoc->hbinterval; in sctp_assoc_add_peer()
627 peer->pathmaxrxt = asoc->pathmaxrxt; in sctp_assoc_add_peer()
630 peer->pf_retrans = asoc->pf_retrans; in sctp_assoc_add_peer()
632 peer->ps_retrans = asoc->ps_retrans; in sctp_assoc_add_peer()
637 peer->sackdelay = asoc->sackdelay; in sctp_assoc_add_peer()
638 peer->sackfreq = asoc->sackfreq; in sctp_assoc_add_peer()
647 peer->flowlabel = asoc->flowlabel; in sctp_assoc_add_peer()
650 peer->dscp = asoc->dscp; in sctp_assoc_add_peer()
655 peer->param_flags = asoc->param_flags; in sctp_assoc_add_peer()
665 sctp_assoc_set_pmtu(asoc, asoc->pathmtu ? in sctp_assoc_add_peer()
666 min_t(int, peer->pathmtu, asoc->pathmtu) : in sctp_assoc_add_peer()
674 sctp_packet_init(&peer->packet, peer, asoc->base.bind_addr.port, in sctp_assoc_add_peer()
675 asoc->peer.port); in sctp_assoc_add_peer()
687 peer->cwnd = min(4*asoc->pathmtu, max_t(__u32, 2*asoc->pathmtu, 4380)); in sctp_assoc_add_peer()
700 peer->rto = asoc->rto_initial; in sctp_assoc_add_peer()
701 sctp_max_rto(asoc, peer); in sctp_assoc_add_peer()
713 list_add_tail_rcu(&peer->transports, &asoc->peer.transport_addr_list); in sctp_assoc_add_peer()
714 asoc->peer.transport_count++; in sctp_assoc_add_peer()
719 if (!asoc->peer.primary_path) { in sctp_assoc_add_peer()
720 sctp_assoc_set_primary(asoc, peer); in sctp_assoc_add_peer()
721 asoc->peer.retran_path = peer; in sctp_assoc_add_peer()
724 if (asoc->peer.active_path == asoc->peer.retran_path && in sctp_assoc_add_peer()
726 asoc->peer.retran_path = peer; in sctp_assoc_add_peer()
733 void sctp_assoc_del_peer(struct sctp_association *asoc, in sctp_assoc_del_peer() argument
740 list_for_each_safe(pos, temp, &asoc->peer.transport_addr_list) { in sctp_assoc_del_peer()
744 sctp_assoc_rm_peer(asoc, transport); in sctp_assoc_del_peer()
752 const struct sctp_association *asoc, in sctp_assoc_lookup_paddr() argument
759 list_for_each_entry(t, &asoc->peer.transport_addr_list, in sctp_assoc_lookup_paddr()
769 void sctp_assoc_del_nonprimary_peers(struct sctp_association *asoc, in sctp_assoc_del_nonprimary_peers() argument
775 list_for_each_entry_safe(t, temp, &asoc->peer.transport_addr_list, in sctp_assoc_del_nonprimary_peers()
779 sctp_assoc_rm_peer(asoc, t); in sctp_assoc_del_nonprimary_peers()
787 void sctp_assoc_control_transport(struct sctp_association *asoc, in sctp_assoc_control_transport() argument
803 asoc->pf_expose != SCTP_PF_EXPOSE_ENABLE) in sctp_assoc_control_transport()
828 if (asoc->pf_expose != SCTP_PF_EXPOSE_ENABLE) in sctp_assoc_control_transport()
846 sctp_select_active_and_retran_path(asoc); in sctp_assoc_control_transport()
850 void sctp_association_hold(struct sctp_association *asoc) in sctp_association_hold() argument
852 refcount_inc(&asoc->base.refcnt); in sctp_association_hold()
858 void sctp_association_put(struct sctp_association *asoc) in sctp_association_put() argument
860 if (refcount_dec_and_test(&asoc->base.refcnt)) in sctp_association_put()
861 sctp_association_destroy(asoc); in sctp_association_put()
867 __u32 sctp_association_get_next_tsn(struct sctp_association *asoc) in sctp_association_get_next_tsn() argument
874 __u32 retval = asoc->next_tsn; in sctp_association_get_next_tsn()
875 asoc->next_tsn++; in sctp_association_get_next_tsn()
876 asoc->unack_data++; in sctp_association_get_next_tsn()
900 struct sctp_chunk *sctp_get_ecne_prepend(struct sctp_association *asoc) in sctp_get_ecne_prepend() argument
902 if (!asoc->need_ecne) in sctp_get_ecne_prepend()
908 return sctp_make_ecne(asoc, asoc->last_ecne_tsn); in sctp_get_ecne_prepend()
914 struct sctp_transport *sctp_assoc_lookup_tsn(struct sctp_association *asoc, in sctp_assoc_lookup_tsn() argument
940 active = asoc->peer.active_path; in sctp_assoc_lookup_tsn()
952 list_for_each_entry(transport, &asoc->peer.transport_addr_list, in sctp_assoc_lookup_tsn()
972 struct sctp_association *asoc = in sctp_assoc_bh_rcv() local
975 struct net *net = asoc->base.net; in sctp_assoc_bh_rcv()
985 ep = asoc->ep; in sctp_assoc_bh_rcv()
987 inqueue = &asoc->base.inqueue; in sctp_assoc_bh_rcv()
988 sctp_association_hold(asoc); in sctp_assoc_bh_rcv()
990 state = asoc->state; in sctp_assoc_bh_rcv()
1024 if (sctp_auth_recv_cid(subtype.chunk, asoc) && !chunk->auth) in sctp_assoc_bh_rcv()
1031 asoc->peer.last_data_from = chunk->transport; in sctp_assoc_bh_rcv()
1034 asoc->stats.ictrlchunks++; in sctp_assoc_bh_rcv()
1036 asoc->stats.isacks++; in sctp_assoc_bh_rcv()
1044 state, ep, asoc, chunk, GFP_ATOMIC); in sctp_assoc_bh_rcv()
1049 if (asoc->base.dead) in sctp_assoc_bh_rcv()
1059 sctp_association_put(asoc); in sctp_assoc_bh_rcv()
1094 int sctp_assoc_update(struct sctp_association *asoc, in sctp_assoc_update() argument
1101 asoc->c = new->c; in sctp_assoc_update()
1102 asoc->peer.rwnd = new->peer.rwnd; in sctp_assoc_update()
1103 asoc->peer.sack_needed = new->peer.sack_needed; in sctp_assoc_update()
1104 asoc->peer.auth_capable = new->peer.auth_capable; in sctp_assoc_update()
1105 asoc->peer.i = new->peer.i; in sctp_assoc_update()
1107 if (!sctp_tsnmap_init(&asoc->peer.tsn_map, SCTP_TSN_MAP_INITIAL, in sctp_assoc_update()
1108 asoc->peer.i.initial_tsn, GFP_ATOMIC)) in sctp_assoc_update()
1112 list_for_each_safe(pos, temp, &asoc->peer.transport_addr_list) { in sctp_assoc_update()
1115 sctp_assoc_rm_peer(asoc, trans); in sctp_assoc_update()
1119 if (asoc->state >= SCTP_STATE_ESTABLISHED) in sctp_assoc_update()
1128 if (asoc->state >= SCTP_STATE_ESTABLISHED) { in sctp_assoc_update()
1129 asoc->next_tsn = new->next_tsn; in sctp_assoc_update()
1130 asoc->ctsn_ack_point = new->ctsn_ack_point; in sctp_assoc_update()
1131 asoc->adv_peer_ack_point = new->adv_peer_ack_point; in sctp_assoc_update()
1136 sctp_stream_clear(&asoc->stream); in sctp_assoc_update()
1142 sctp_ulpq_flush(&asoc->ulpq); in sctp_assoc_update()
1148 asoc->overall_error_count = 0; in sctp_assoc_update()
1154 if (!sctp_assoc_lookup_paddr(asoc, &trans->ipaddr) && in sctp_assoc_update()
1155 !sctp_assoc_add_peer(asoc, &trans->ipaddr, in sctp_assoc_update()
1159 asoc->ctsn_ack_point = asoc->next_tsn - 1; in sctp_assoc_update()
1160 asoc->adv_peer_ack_point = asoc->ctsn_ack_point; in sctp_assoc_update()
1162 if (sctp_state(asoc, COOKIE_WAIT)) in sctp_assoc_update()
1163 sctp_stream_update(&asoc->stream, &new->stream); in sctp_assoc_update()
1166 if (sctp_assoc_set_id(asoc, GFP_ATOMIC)) in sctp_assoc_update()
1173 kfree(asoc->peer.peer_random); in sctp_assoc_update()
1174 asoc->peer.peer_random = new->peer.peer_random; in sctp_assoc_update()
1177 kfree(asoc->peer.peer_chunks); in sctp_assoc_update()
1178 asoc->peer.peer_chunks = new->peer.peer_chunks; in sctp_assoc_update()
1181 kfree(asoc->peer.peer_hmacs); in sctp_assoc_update()
1182 asoc->peer.peer_hmacs = new->peer.peer_hmacs; in sctp_assoc_update()
1185 return sctp_auth_asoc_init_active_key(asoc, GFP_ATOMIC); in sctp_assoc_update()
1267 void sctp_assoc_update_retran_path(struct sctp_association *asoc) in sctp_assoc_update_retran_path() argument
1269 struct sctp_transport *trans = asoc->peer.retran_path; in sctp_assoc_update_retran_path()
1273 if (asoc->peer.transport_count == 1) in sctp_assoc_update_retran_path()
1278 if (asoc->peer.active_path == asoc->peer.retran_path && in sctp_assoc_update_retran_path()
1279 asoc->peer.active_path->state == SCTP_ACTIVE) in sctp_assoc_update_retran_path()
1286 if (&trans->transports == &asoc->peer.transport_addr_list) in sctp_assoc_update_retran_path()
1295 if (trans == asoc->peer.retran_path) in sctp_assoc_update_retran_path()
1299 asoc->peer.retran_path = trans_next; in sctp_assoc_update_retran_path()
1302 __func__, asoc, &asoc->peer.retran_path->ipaddr.sa); in sctp_assoc_update_retran_path()
1305 static void sctp_select_active_and_retran_path(struct sctp_association *asoc) in sctp_select_active_and_retran_path() argument
1311 list_for_each_entry(trans, &asoc->peer.transport_addr_list, in sctp_select_active_and_retran_path()
1345 if ((asoc->peer.primary_path->state == SCTP_ACTIVE || in sctp_select_active_and_retran_path()
1346 asoc->peer.primary_path->state == SCTP_UNKNOWN) && in sctp_select_active_and_retran_path()
1347 asoc->peer.primary_path != trans_pri) { in sctp_select_active_and_retran_path()
1349 trans_pri = asoc->peer.primary_path; in sctp_select_active_and_retran_path()
1363 trans_pri = sctp_trans_elect_best(asoc->peer.active_path, trans_pf); in sctp_select_active_and_retran_path()
1368 asoc->peer.active_path = trans_pri; in sctp_select_active_and_retran_path()
1369 asoc->peer.retran_path = trans_sec; in sctp_select_active_and_retran_path()
1373 sctp_assoc_choose_alter_transport(struct sctp_association *asoc, in sctp_assoc_choose_alter_transport() argument
1381 return asoc->peer.active_path; in sctp_assoc_choose_alter_transport()
1383 if (last_sent_to == asoc->peer.retran_path) in sctp_assoc_choose_alter_transport()
1384 sctp_assoc_update_retran_path(asoc); in sctp_assoc_choose_alter_transport()
1386 return asoc->peer.retran_path; in sctp_assoc_choose_alter_transport()
1390 void sctp_assoc_update_frag_point(struct sctp_association *asoc) in sctp_assoc_update_frag_point() argument
1392 int frag = sctp_mtu_payload(sctp_sk(asoc->base.sk), asoc->pathmtu, in sctp_assoc_update_frag_point()
1393 sctp_datachk_len(&asoc->stream)); in sctp_assoc_update_frag_point()
1395 if (asoc->user_frag) in sctp_assoc_update_frag_point()
1396 frag = min_t(int, frag, asoc->user_frag); in sctp_assoc_update_frag_point()
1399 sctp_datachk_len(&asoc->stream)); in sctp_assoc_update_frag_point()
1401 asoc->frag_point = SCTP_TRUNC4(frag); in sctp_assoc_update_frag_point()
1404 void sctp_assoc_set_pmtu(struct sctp_association *asoc, __u32 pmtu) in sctp_assoc_set_pmtu() argument
1406 if (asoc->pathmtu != pmtu) { in sctp_assoc_set_pmtu()
1407 asoc->pathmtu = pmtu; in sctp_assoc_set_pmtu()
1408 sctp_assoc_update_frag_point(asoc); in sctp_assoc_set_pmtu()
1411 pr_debug("%s: asoc:%p, pmtu:%d, frag_point:%d\n", __func__, asoc, in sctp_assoc_set_pmtu()
1412 asoc->pathmtu, asoc->frag_point); in sctp_assoc_set_pmtu()
1418 void sctp_assoc_sync_pmtu(struct sctp_association *asoc) in sctp_assoc_sync_pmtu() argument
1423 if (!asoc) in sctp_assoc_sync_pmtu()
1427 list_for_each_entry(t, &asoc->peer.transport_addr_list, transports) { in sctp_assoc_sync_pmtu()
1437 sctp_assoc_set_pmtu(asoc, pmtu); in sctp_assoc_sync_pmtu()
1441 static inline bool sctp_peer_needs_update(struct sctp_association *asoc) in sctp_peer_needs_update() argument
1443 struct net *net = asoc->base.net; in sctp_peer_needs_update()
1445 switch (asoc->state) { in sctp_peer_needs_update()
1450 if ((asoc->rwnd > asoc->a_rwnd) && in sctp_peer_needs_update()
1451 ((asoc->rwnd - asoc->a_rwnd) >= max_t(__u32, in sctp_peer_needs_update()
1452 (asoc->base.sk->sk_rcvbuf >> net->sctp.rwnd_upd_shift), in sctp_peer_needs_update()
1453 asoc->pathmtu))) in sctp_peer_needs_update()
1463 void sctp_assoc_rwnd_increase(struct sctp_association *asoc, unsigned int len) in sctp_assoc_rwnd_increase() argument
1468 if (asoc->rwnd_over) { in sctp_assoc_rwnd_increase()
1469 if (asoc->rwnd_over >= len) { in sctp_assoc_rwnd_increase()
1470 asoc->rwnd_over -= len; in sctp_assoc_rwnd_increase()
1472 asoc->rwnd += (len - asoc->rwnd_over); in sctp_assoc_rwnd_increase()
1473 asoc->rwnd_over = 0; in sctp_assoc_rwnd_increase()
1476 asoc->rwnd += len; in sctp_assoc_rwnd_increase()
1484 if (asoc->rwnd_press) { in sctp_assoc_rwnd_increase()
1485 int change = min(asoc->pathmtu, asoc->rwnd_press); in sctp_assoc_rwnd_increase()
1486 asoc->rwnd += change; in sctp_assoc_rwnd_increase()
1487 asoc->rwnd_press -= change; in sctp_assoc_rwnd_increase()
1491 __func__, asoc, len, asoc->rwnd, asoc->rwnd_over, in sctp_assoc_rwnd_increase()
1492 asoc->a_rwnd); in sctp_assoc_rwnd_increase()
1499 if (sctp_peer_needs_update(asoc)) { in sctp_assoc_rwnd_increase()
1500 asoc->a_rwnd = asoc->rwnd; in sctp_assoc_rwnd_increase()
1503 "a_rwnd:%u\n", __func__, asoc, asoc->rwnd, in sctp_assoc_rwnd_increase()
1504 asoc->a_rwnd); in sctp_assoc_rwnd_increase()
1506 sack = sctp_make_sack(asoc); in sctp_assoc_rwnd_increase()
1510 asoc->peer.sack_needed = 0; in sctp_assoc_rwnd_increase()
1512 sctp_outq_tail(&asoc->outqueue, sack, GFP_ATOMIC); in sctp_assoc_rwnd_increase()
1515 timer = &asoc->timers[SCTP_EVENT_TIMEOUT_SACK]; in sctp_assoc_rwnd_increase()
1517 sctp_association_put(asoc); in sctp_assoc_rwnd_increase()
1522 void sctp_assoc_rwnd_decrease(struct sctp_association *asoc, unsigned int len) in sctp_assoc_rwnd_decrease() argument
1527 if (unlikely(!asoc->rwnd || asoc->rwnd_over)) in sctp_assoc_rwnd_decrease()
1529 "asoc->rwnd_over:%u!\n", __func__, asoc, in sctp_assoc_rwnd_decrease()
1530 asoc->rwnd, asoc->rwnd_over); in sctp_assoc_rwnd_decrease()
1532 if (asoc->ep->rcvbuf_policy) in sctp_assoc_rwnd_decrease()
1533 rx_count = atomic_read(&asoc->rmem_alloc); in sctp_assoc_rwnd_decrease()
1535 rx_count = atomic_read(&asoc->base.sk->sk_rmem_alloc); in sctp_assoc_rwnd_decrease()
1542 if (rx_count >= asoc->base.sk->sk_rcvbuf) in sctp_assoc_rwnd_decrease()
1545 if (asoc->rwnd >= len) { in sctp_assoc_rwnd_decrease()
1546 asoc->rwnd -= len; in sctp_assoc_rwnd_decrease()
1548 asoc->rwnd_press += asoc->rwnd; in sctp_assoc_rwnd_decrease()
1549 asoc->rwnd = 0; in sctp_assoc_rwnd_decrease()
1552 asoc->rwnd_over += len - asoc->rwnd; in sctp_assoc_rwnd_decrease()
1553 asoc->rwnd = 0; in sctp_assoc_rwnd_decrease()
1557 __func__, asoc, len, asoc->rwnd, asoc->rwnd_over, in sctp_assoc_rwnd_decrease()
1558 asoc->rwnd_press); in sctp_assoc_rwnd_decrease()
1564 int sctp_assoc_set_bind_addr_from_ep(struct sctp_association *asoc, in sctp_assoc_set_bind_addr_from_ep() argument
1567 struct sock *sk = asoc->base.sk; in sctp_assoc_set_bind_addr_from_ep()
1576 if (asoc->peer.ipv4_address) in sctp_assoc_set_bind_addr_from_ep()
1578 if (asoc->peer.ipv6_address) in sctp_assoc_set_bind_addr_from_ep()
1581 return sctp_bind_addr_copy(asoc->base.net, in sctp_assoc_set_bind_addr_from_ep()
1582 &asoc->base.bind_addr, in sctp_assoc_set_bind_addr_from_ep()
1583 &asoc->ep->base.bind_addr, in sctp_assoc_set_bind_addr_from_ep()
1588 int sctp_assoc_set_bind_addr_from_cookie(struct sctp_association *asoc, in sctp_assoc_set_bind_addr_from_cookie() argument
1596 return sctp_raw_to_bind_addrs(&asoc->base.bind_addr, raw, var_size3, in sctp_assoc_set_bind_addr_from_cookie()
1597 asoc->ep->base.bind_addr.port, gfp); in sctp_assoc_set_bind_addr_from_cookie()
1601 int sctp_assoc_lookup_laddr(struct sctp_association *asoc, in sctp_assoc_lookup_laddr() argument
1606 if ((asoc->base.bind_addr.port == ntohs(laddr->v4.sin_port)) && in sctp_assoc_lookup_laddr()
1607 sctp_bind_addr_match(&asoc->base.bind_addr, laddr, in sctp_assoc_lookup_laddr()
1608 sctp_sk(asoc->base.sk))) in sctp_assoc_lookup_laddr()
1615 int sctp_assoc_set_id(struct sctp_association *asoc, gfp_t gfp) in sctp_assoc_set_id() argument
1621 if (asoc->assoc_id) in sctp_assoc_set_id()
1630 ret = idr_alloc_cyclic(&sctp_assocs_id, asoc, SCTP_ALL_ASSOC + 1, 0, in sctp_assoc_set_id()
1638 asoc->assoc_id = (sctp_assoc_t)ret; in sctp_assoc_set_id()
1643 static void sctp_assoc_free_asconf_queue(struct sctp_association *asoc) in sctp_assoc_free_asconf_queue() argument
1648 list_for_each_entry_safe(asconf, tmp, &asoc->addip_chunk_list, list) { in sctp_assoc_free_asconf_queue()
1655 static void sctp_assoc_free_asconf_acks(struct sctp_association *asoc) in sctp_assoc_free_asconf_acks() argument
1660 list_for_each_entry_safe(ack, tmp, &asoc->asconf_ack_list, in sctp_assoc_free_asconf_acks()
1668 void sctp_assoc_clean_asconf_ack_cache(const struct sctp_association *asoc) in sctp_assoc_clean_asconf_ack_cache() argument
1676 list_for_each_entry_safe(ack, tmp, &asoc->asconf_ack_list, in sctp_assoc_clean_asconf_ack_cache()
1679 htonl(asoc->peer.addip_serial)) in sctp_assoc_clean_asconf_ack_cache()
1689 const struct sctp_association *asoc, in sctp_assoc_lookup_asconf_ack() argument
1697 list_for_each_entry(ack, &asoc->asconf_ack_list, transmitted_list) { in sctp_assoc_lookup_asconf_ack()
1709 void sctp_asconf_queue_teardown(struct sctp_association *asoc) in sctp_asconf_queue_teardown() argument
1712 sctp_assoc_free_asconf_acks(asoc); in sctp_asconf_queue_teardown()
1715 sctp_assoc_free_asconf_queue(asoc); in sctp_asconf_queue_teardown()
1718 if (asoc->addip_last_asconf) in sctp_asconf_queue_teardown()
1719 sctp_chunk_free(asoc->addip_last_asconf); in sctp_asconf_queue_teardown()