Lines Matching full: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()
101 asoc->probe_interval = msecs_to_jiffies(sp->probe_interval); in sctp_association_init()
103 asoc->encap_port = sp->encap_port; in sctp_association_init()
106 asoc->pathmaxrxt = sp->pathmaxrxt; in sctp_association_init()
108 asoc->flowlabel = sp->flowlabel; in sctp_association_init()
109 asoc->dscp = sp->dscp; in sctp_association_init()
112 asoc->sackdelay = msecs_to_jiffies(sp->sackdelay); in sctp_association_init()
113 asoc->sackfreq = sp->sackfreq; in sctp_association_init()
118 asoc->param_flags = sp->param_flags; in sctp_association_init()
123 asoc->max_burst = sp->max_burst; in sctp_association_init()
125 asoc->subscribe = sp->subscribe; in sctp_association_init()
128 asoc->timeouts[SCTP_EVENT_TIMEOUT_T1_COOKIE] = asoc->rto_initial; in sctp_association_init()
129 asoc->timeouts[SCTP_EVENT_TIMEOUT_T1_INIT] = asoc->rto_initial; in sctp_association_init()
130 asoc->timeouts[SCTP_EVENT_TIMEOUT_T2_SHUTDOWN] = asoc->rto_initial; in sctp_association_init()
136 asoc->timeouts[SCTP_EVENT_TIMEOUT_T5_SHUTDOWN_GUARD] in sctp_association_init()
137 = 5 * asoc->rto_max; in sctp_association_init()
139 asoc->timeouts[SCTP_EVENT_TIMEOUT_SACK] = asoc->sackdelay; in sctp_association_init()
140 asoc->timeouts[SCTP_EVENT_TIMEOUT_AUTOCLOSE] = sp->autoclose * HZ; in sctp_association_init()
144 timer_setup(&asoc->timers[i], sctp_timer_events[i], 0); in sctp_association_init()
150 asoc->c.sinit_max_instreams = sp->initmsg.sinit_max_instreams; in sctp_association_init()
151 asoc->c.sinit_num_ostreams = sp->initmsg.sinit_num_ostreams; in sctp_association_init()
152 asoc->max_init_attempts = sp->initmsg.sinit_max_attempts; in sctp_association_init()
154 asoc->max_init_timeo = in sctp_association_init()
163 asoc->rwnd = SCTP_DEFAULT_MINWINDOW; in sctp_association_init()
165 asoc->rwnd = sk->sk_rcvbuf/2; in sctp_association_init()
167 asoc->a_rwnd = asoc->rwnd; in sctp_association_init()
170 asoc->peer.rwnd = SCTP_DEFAULT_MAXWINDOW; in sctp_association_init()
173 atomic_set(&asoc->rmem_alloc, 0); in sctp_association_init()
175 init_waitqueue_head(&asoc->wait); in sctp_association_init()
177 asoc->c.my_vtag = sctp_generate_tag(ep); in sctp_association_init()
178 asoc->c.my_port = ep->base.bind_addr.port; in sctp_association_init()
180 asoc->c.initial_tsn = sctp_generate_tsn(ep); in sctp_association_init()
182 asoc->next_tsn = asoc->c.initial_tsn; in sctp_association_init()
184 asoc->ctsn_ack_point = asoc->next_tsn - 1; in sctp_association_init()
185 asoc->adv_peer_ack_point = asoc->ctsn_ack_point; in sctp_association_init()
186 asoc->highest_sacked = asoc->ctsn_ack_point; in sctp_association_init()
187 asoc->last_cwr_tsn = asoc->ctsn_ack_point; in sctp_association_init()
199 asoc->addip_serial = asoc->c.initial_tsn; in sctp_association_init()
200 asoc->strreset_outseq = asoc->c.initial_tsn; in sctp_association_init()
202 INIT_LIST_HEAD(&asoc->addip_chunk_list); in sctp_association_init()
203 INIT_LIST_HEAD(&asoc->asconf_ack_list); in sctp_association_init()
206 INIT_LIST_HEAD(&asoc->peer.transport_addr_list); in sctp_association_init()
219 asoc->peer.sack_needed = 1; in sctp_association_init()
220 asoc->peer.sack_generation = 1; in sctp_association_init()
223 sctp_inq_init(&asoc->base.inqueue); in sctp_association_init()
224 sctp_inq_set_th_handler(&asoc->base.inqueue, sctp_assoc_bh_rcv); 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()
231 if (sctp_stream_init(&asoc->stream, asoc->c.sinit_num_ostreams, 0, gfp)) in sctp_association_init()
235 asoc->pathmtu = sp->pathmtu; in sctp_association_init()
236 sctp_assoc_update_frag_point(asoc); in sctp_association_init()
241 asoc->peer.ipv4_address = 1; in sctp_association_init()
242 if (asoc->base.sk->sk_family == PF_INET6) in sctp_association_init()
243 asoc->peer.ipv6_address = 1; in sctp_association_init()
244 INIT_LIST_HEAD(&asoc->asocs); in sctp_association_init()
246 asoc->default_stream = sp->default_stream; in sctp_association_init()
247 asoc->default_ppid = sp->default_ppid; in sctp_association_init()
248 asoc->default_flags = sp->default_flags; in sctp_association_init()
249 asoc->default_context = sp->default_context; in sctp_association_init()
250 asoc->default_timetolive = sp->default_timetolive; in sctp_association_init()
251 asoc->default_rcv_context = sp->default_rcv_context; in sctp_association_init()
254 INIT_LIST_HEAD(&asoc->endpoint_shared_keys); in sctp_association_init()
255 if (sctp_auth_asoc_copy_shkeys(ep, asoc, gfp)) in sctp_association_init()
258 asoc->active_key_id = ep->active_key_id; in sctp_association_init()
259 asoc->strreset_enable = ep->strreset_enable; in sctp_association_init()
263 memcpy(asoc->c.auth_hmacs, ep->auth_hmacs_list, in sctp_association_init()
266 memcpy(asoc->c.auth_chunks, ep->auth_chunk_list, in sctp_association_init()
270 p = (struct sctp_paramhdr *)asoc->c.auth_random; in sctp_association_init()
275 return asoc; in sctp_association_init()
278 sctp_stream_free(&asoc->stream); in sctp_association_init()
279 sock_put(asoc->base.sk); in sctp_association_init()
280 sctp_endpoint_put(asoc->ep); in sctp_association_init()
289 struct sctp_association *asoc; in sctp_association_new() local
291 asoc = kzalloc(sizeof(*asoc), gfp); in sctp_association_new()
292 if (!asoc) in sctp_association_new()
295 if (!sctp_association_init(asoc, ep, sk, scope, gfp)) in sctp_association_new()
300 pr_debug("Created asoc %p\n", asoc); in sctp_association_new()
302 return asoc; in sctp_association_new()
305 kfree(asoc); in sctp_association_new()
313 void sctp_association_free(struct sctp_association *asoc) in sctp_association_free() argument
315 struct sock *sk = asoc->base.sk; in sctp_association_free()
323 if (!list_empty(&asoc->asocs)) { in sctp_association_free()
324 list_del(&asoc->asocs); in sctp_association_free()
336 asoc->base.dead = true; in sctp_association_free()
339 sctp_outq_free(&asoc->outqueue); in sctp_association_free()
342 sctp_ulpq_free(&asoc->ulpq); in sctp_association_free()
345 sctp_inq_free(&asoc->base.inqueue); in sctp_association_free()
347 sctp_tsnmap_free(&asoc->peer.tsn_map); in sctp_association_free()
350 sctp_stream_free(&asoc->stream); in sctp_association_free()
352 if (asoc->strreset_chunk) in sctp_association_free()
353 sctp_chunk_free(asoc->strreset_chunk); in sctp_association_free()
356 sctp_bind_addr_free(&asoc->base.bind_addr); in sctp_association_free()
364 if (del_timer(&asoc->timers[i])) in sctp_association_free()
365 sctp_association_put(asoc); in sctp_association_free()
369 kfree(asoc->peer.cookie); in sctp_association_free()
370 kfree(asoc->peer.peer_random); in sctp_association_free()
371 kfree(asoc->peer.peer_chunks); in sctp_association_free()
372 kfree(asoc->peer.peer_hmacs); in sctp_association_free()
375 list_for_each_safe(pos, temp, &asoc->peer.transport_addr_list) { in sctp_association_free()
382 asoc->peer.transport_count = 0; in sctp_association_free()
384 sctp_asconf_queue_teardown(asoc); in sctp_association_free()
387 kfree(asoc->asconf_addr_del_pending); in sctp_association_free()
390 sctp_auth_destroy_keys(&asoc->endpoint_shared_keys); in sctp_association_free()
393 sctp_auth_key_put(asoc->asoc_shared_key); in sctp_association_free()
395 sctp_association_put(asoc); in sctp_association_free()
399 static void sctp_association_destroy(struct sctp_association *asoc) in sctp_association_destroy() argument
401 if (unlikely(!asoc->base.dead)) { in sctp_association_destroy()
402 WARN(1, "Attempt to destroy undead association %p!\n", asoc); in sctp_association_destroy()
406 sctp_endpoint_put(asoc->ep); in sctp_association_destroy()
407 sock_put(asoc->base.sk); in sctp_association_destroy()
409 if (asoc->assoc_id != 0) { in sctp_association_destroy()
411 idr_remove(&sctp_assocs_id, asoc->assoc_id); in sctp_association_destroy()
415 WARN_ON(atomic_read(&asoc->rmem_alloc)); in sctp_association_destroy()
417 kfree_rcu(asoc, rcu); in sctp_association_destroy()
422 void sctp_assoc_set_primary(struct sctp_association *asoc, in sctp_assoc_set_primary() argument
430 if (asoc->peer.primary_path != NULL && in sctp_assoc_set_primary()
431 asoc->peer.primary_path != transport) in sctp_assoc_set_primary()
434 asoc->peer.primary_path = transport; in sctp_assoc_set_primary()
439 memcpy(&asoc->peer.primary_addr, &transport->ipaddr, in sctp_assoc_set_primary()
447 asoc->peer.active_path = transport; in sctp_assoc_set_primary()
463 if (!asoc->outqueue.outstanding_bytes && !asoc->outqueue.out_qlen) in sctp_assoc_set_primary()
477 transport->cacc.next_tsn_at_change = asoc->next_tsn; in sctp_assoc_set_primary()
481 void sctp_assoc_rm_peer(struct sctp_association *asoc, in sctp_assoc_rm_peer() argument
489 __func__, asoc, &peer->ipaddr.sa); in sctp_assoc_rm_peer()
494 if (asoc->peer.retran_path == peer) in sctp_assoc_rm_peer()
495 sctp_assoc_update_retran_path(asoc); in sctp_assoc_rm_peer()
502 /* Get the first transport of asoc. */ in sctp_assoc_rm_peer()
503 pos = asoc->peer.transport_addr_list.next; in sctp_assoc_rm_peer()
507 if (asoc->peer.primary_path == peer) in sctp_assoc_rm_peer()
508 sctp_assoc_set_primary(asoc, transport); in sctp_assoc_rm_peer()
509 if (asoc->peer.active_path == peer) in sctp_assoc_rm_peer()
510 asoc->peer.active_path = transport; in sctp_assoc_rm_peer()
511 if (asoc->peer.retran_path == peer) in sctp_assoc_rm_peer()
512 asoc->peer.retran_path = transport; in sctp_assoc_rm_peer()
513 if (asoc->peer.last_data_from == peer) in sctp_assoc_rm_peer()
514 asoc->peer.last_data_from = transport; in sctp_assoc_rm_peer()
516 if (asoc->strreset_chunk && in sctp_assoc_rm_peer()
517 asoc->strreset_chunk->transport == peer) { in sctp_assoc_rm_peer()
518 asoc->strreset_chunk->transport = transport; in sctp_assoc_rm_peer()
527 if (asoc->init_last_sent_to == peer) in sctp_assoc_rm_peer()
528 asoc->init_last_sent_to = NULL; in sctp_assoc_rm_peer()
535 if (asoc->shutdown_last_sent_to == peer) in sctp_assoc_rm_peer()
536 asoc->shutdown_last_sent_to = NULL; in sctp_assoc_rm_peer()
541 if (asoc->addip_last_asconf && in sctp_assoc_rm_peer()
542 asoc->addip_last_asconf->transport == peer) in sctp_assoc_rm_peer()
543 asoc->addip_last_asconf->transport = NULL; in sctp_assoc_rm_peer()
549 struct sctp_transport *active = asoc->peer.active_path; in sctp_assoc_rm_peer()
571 list_for_each_entry(ch, &asoc->outqueue.out_chunk_list, list) in sctp_assoc_rm_peer()
575 asoc->peer.transport_count--; in sctp_assoc_rm_peer()
582 struct sctp_transport *sctp_assoc_add_peer(struct sctp_association *asoc, in sctp_assoc_add_peer() argument
591 sp = sctp_sk(asoc->base.sk); in sctp_assoc_add_peer()
597 asoc, &addr->sa, peer_state); in sctp_assoc_add_peer()
600 if (0 == asoc->peer.port) in sctp_assoc_add_peer()
601 asoc->peer.port = port; in sctp_assoc_add_peer()
604 peer = sctp_assoc_lookup_paddr(asoc, addr); in sctp_assoc_add_peer()
616 peer = sctp_transport_new(asoc->base.net, addr, gfp); in sctp_assoc_add_peer()
620 sctp_transport_set_owner(peer, asoc); in sctp_assoc_add_peer()
625 peer->hbinterval = asoc->hbinterval; in sctp_assoc_add_peer()
626 peer->probe_interval = asoc->probe_interval; in sctp_assoc_add_peer()
628 peer->encap_port = asoc->encap_port; in sctp_assoc_add_peer()
631 peer->pathmaxrxt = asoc->pathmaxrxt; in sctp_assoc_add_peer()
634 peer->pf_retrans = asoc->pf_retrans; in sctp_assoc_add_peer()
636 peer->ps_retrans = asoc->ps_retrans; in sctp_assoc_add_peer()
641 peer->sackdelay = asoc->sackdelay; in sctp_assoc_add_peer()
642 peer->sackfreq = asoc->sackfreq; in sctp_assoc_add_peer()
651 peer->flowlabel = asoc->flowlabel; in sctp_assoc_add_peer()
654 peer->dscp = asoc->dscp; in sctp_assoc_add_peer()
659 peer->param_flags = asoc->param_flags; in sctp_assoc_add_peer()
669 sctp_assoc_set_pmtu(asoc, asoc->pathmtu ? in sctp_assoc_add_peer()
670 min_t(int, peer->pathmtu, asoc->pathmtu) : in sctp_assoc_add_peer()
675 /* The asoc->peer.port might not be meaningful yet, but in sctp_assoc_add_peer()
678 sctp_packet_init(&peer->packet, peer, asoc->base.bind_addr.port, in sctp_assoc_add_peer()
679 asoc->peer.port); in sctp_assoc_add_peer()
691 peer->cwnd = min(4*asoc->pathmtu, max_t(__u32, 2*asoc->pathmtu, 4380)); in sctp_assoc_add_peer()
704 peer->rto = asoc->rto_initial; in sctp_assoc_add_peer()
705 sctp_max_rto(asoc, peer); in sctp_assoc_add_peer()
718 /* Attach the remote transport to our asoc. */ in sctp_assoc_add_peer()
719 list_add_tail_rcu(&peer->transports, &asoc->peer.transport_addr_list); in sctp_assoc_add_peer()
720 asoc->peer.transport_count++; in sctp_assoc_add_peer()
725 if (!asoc->peer.primary_path) { in sctp_assoc_add_peer()
726 sctp_assoc_set_primary(asoc, peer); in sctp_assoc_add_peer()
727 asoc->peer.retran_path = peer; in sctp_assoc_add_peer()
730 if (asoc->peer.active_path == asoc->peer.retran_path && in sctp_assoc_add_peer()
732 asoc->peer.retran_path = peer; in sctp_assoc_add_peer()
739 void sctp_assoc_del_peer(struct sctp_association *asoc, in sctp_assoc_del_peer() argument
746 list_for_each_safe(pos, temp, &asoc->peer.transport_addr_list) { in sctp_assoc_del_peer()
750 sctp_assoc_rm_peer(asoc, transport); in sctp_assoc_del_peer()
758 const struct sctp_association *asoc, in sctp_assoc_lookup_paddr() argument
765 list_for_each_entry(t, &asoc->peer.transport_addr_list, in sctp_assoc_lookup_paddr()
775 void sctp_assoc_del_nonprimary_peers(struct sctp_association *asoc, in sctp_assoc_del_nonprimary_peers() argument
781 list_for_each_entry_safe(t, temp, &asoc->peer.transport_addr_list, in sctp_assoc_del_nonprimary_peers()
785 sctp_assoc_rm_peer(asoc, t); in sctp_assoc_del_nonprimary_peers()
793 void sctp_assoc_control_transport(struct sctp_association *asoc, in sctp_assoc_control_transport() argument
809 asoc->pf_expose != SCTP_PF_EXPOSE_ENABLE) in sctp_assoc_control_transport()
836 if (asoc->pf_expose != SCTP_PF_EXPOSE_ENABLE) in sctp_assoc_control_transport()
854 sctp_select_active_and_retran_path(asoc); in sctp_assoc_control_transport()
858 void sctp_association_hold(struct sctp_association *asoc) in sctp_association_hold() argument
860 refcount_inc(&asoc->base.refcnt); in sctp_association_hold()
866 void sctp_association_put(struct sctp_association *asoc) in sctp_association_put() argument
868 if (refcount_dec_and_test(&asoc->base.refcnt)) in sctp_association_put()
869 sctp_association_destroy(asoc); in sctp_association_put()
875 __u32 sctp_association_get_next_tsn(struct sctp_association *asoc) in sctp_association_get_next_tsn() argument
882 __u32 retval = asoc->next_tsn; in sctp_association_get_next_tsn()
883 asoc->next_tsn++; in sctp_association_get_next_tsn()
884 asoc->unack_data++; in sctp_association_get_next_tsn()
908 struct sctp_chunk *sctp_get_ecne_prepend(struct sctp_association *asoc) in sctp_get_ecne_prepend() argument
910 if (!asoc->need_ecne) in sctp_get_ecne_prepend()
916 return sctp_make_ecne(asoc, asoc->last_ecne_tsn); in sctp_get_ecne_prepend()
922 struct sctp_transport *sctp_assoc_lookup_tsn(struct sctp_association *asoc, in sctp_assoc_lookup_tsn() argument
948 active = asoc->peer.active_path; in sctp_assoc_lookup_tsn()
960 list_for_each_entry(transport, &asoc->peer.transport_addr_list, in sctp_assoc_lookup_tsn()
980 struct sctp_association *asoc = in sctp_assoc_bh_rcv() local
983 struct net *net = asoc->base.net; in sctp_assoc_bh_rcv()
993 ep = asoc->ep; in sctp_assoc_bh_rcv()
995 inqueue = &asoc->base.inqueue; in sctp_assoc_bh_rcv()
996 sctp_association_hold(asoc); in sctp_assoc_bh_rcv()
998 state = asoc->state; in sctp_assoc_bh_rcv()
1032 if (sctp_auth_recv_cid(subtype.chunk, asoc) && !chunk->auth) in sctp_assoc_bh_rcv()
1039 asoc->peer.last_data_from = chunk->transport; in sctp_assoc_bh_rcv()
1042 asoc->stats.ictrlchunks++; in sctp_assoc_bh_rcv()
1044 asoc->stats.isacks++; in sctp_assoc_bh_rcv()
1052 state, ep, asoc, chunk, GFP_ATOMIC); in sctp_assoc_bh_rcv()
1057 if (asoc->base.dead) in sctp_assoc_bh_rcv()
1067 sctp_association_put(asoc); in sctp_assoc_bh_rcv()
1102 int sctp_assoc_update(struct sctp_association *asoc, in sctp_assoc_update() argument
1109 asoc->c = new->c; in sctp_assoc_update()
1110 asoc->peer.rwnd = new->peer.rwnd; in sctp_assoc_update()
1111 asoc->peer.sack_needed = new->peer.sack_needed; in sctp_assoc_update()
1112 asoc->peer.auth_capable = new->peer.auth_capable; in sctp_assoc_update()
1113 asoc->peer.i = new->peer.i; in sctp_assoc_update()
1115 if (!sctp_tsnmap_init(&asoc->peer.tsn_map, SCTP_TSN_MAP_INITIAL, in sctp_assoc_update()
1116 asoc->peer.i.initial_tsn, GFP_ATOMIC)) in sctp_assoc_update()
1120 list_for_each_safe(pos, temp, &asoc->peer.transport_addr_list) { in sctp_assoc_update()
1123 sctp_assoc_rm_peer(asoc, trans); in sctp_assoc_update()
1127 if (asoc->state >= SCTP_STATE_ESTABLISHED) in sctp_assoc_update()
1136 if (asoc->state >= SCTP_STATE_ESTABLISHED) { in sctp_assoc_update()
1137 asoc->next_tsn = new->next_tsn; in sctp_assoc_update()
1138 asoc->ctsn_ack_point = new->ctsn_ack_point; in sctp_assoc_update()
1139 asoc->adv_peer_ack_point = new->adv_peer_ack_point; in sctp_assoc_update()
1144 sctp_stream_clear(&asoc->stream); in sctp_assoc_update()
1150 sctp_ulpq_flush(&asoc->ulpq); in sctp_assoc_update()
1156 asoc->overall_error_count = 0; in sctp_assoc_update()
1162 if (!sctp_assoc_add_peer(asoc, &trans->ipaddr, in sctp_assoc_update()
1166 asoc->ctsn_ack_point = asoc->next_tsn - 1; in sctp_assoc_update()
1167 asoc->adv_peer_ack_point = asoc->ctsn_ack_point; in sctp_assoc_update()
1169 if (sctp_state(asoc, COOKIE_WAIT)) in sctp_assoc_update()
1170 sctp_stream_update(&asoc->stream, &new->stream); in sctp_assoc_update()
1173 if (sctp_assoc_set_id(asoc, GFP_ATOMIC)) in sctp_assoc_update()
1180 kfree(asoc->peer.peer_random); in sctp_assoc_update()
1181 asoc->peer.peer_random = new->peer.peer_random; in sctp_assoc_update()
1184 kfree(asoc->peer.peer_chunks); in sctp_assoc_update()
1185 asoc->peer.peer_chunks = new->peer.peer_chunks; in sctp_assoc_update()
1188 kfree(asoc->peer.peer_hmacs); in sctp_assoc_update()
1189 asoc->peer.peer_hmacs = new->peer.peer_hmacs; in sctp_assoc_update()
1192 return sctp_auth_asoc_init_active_key(asoc, GFP_ATOMIC); in sctp_assoc_update()
1274 void sctp_assoc_update_retran_path(struct sctp_association *asoc) in sctp_assoc_update_retran_path() argument
1276 struct sctp_transport *trans = asoc->peer.retran_path; in sctp_assoc_update_retran_path()
1280 if (asoc->peer.transport_count == 1) in sctp_assoc_update_retran_path()
1285 if (asoc->peer.active_path == asoc->peer.retran_path && in sctp_assoc_update_retran_path()
1286 asoc->peer.active_path->state == SCTP_ACTIVE) in sctp_assoc_update_retran_path()
1293 if (&trans->transports == &asoc->peer.transport_addr_list) in sctp_assoc_update_retran_path()
1302 if (trans == asoc->peer.retran_path) in sctp_assoc_update_retran_path()
1306 asoc->peer.retran_path = trans_next; in sctp_assoc_update_retran_path()
1309 __func__, asoc, &asoc->peer.retran_path->ipaddr.sa); in sctp_assoc_update_retran_path()
1312 static void sctp_select_active_and_retran_path(struct sctp_association *asoc) in sctp_select_active_and_retran_path() argument
1318 list_for_each_entry(trans, &asoc->peer.transport_addr_list, in sctp_select_active_and_retran_path()
1352 if ((asoc->peer.primary_path->state == SCTP_ACTIVE || in sctp_select_active_and_retran_path()
1353 asoc->peer.primary_path->state == SCTP_UNKNOWN) && in sctp_select_active_and_retran_path()
1354 asoc->peer.primary_path != trans_pri) { in sctp_select_active_and_retran_path()
1356 trans_pri = asoc->peer.primary_path; in sctp_select_active_and_retran_path()
1370 trans_pri = sctp_trans_elect_best(asoc->peer.active_path, trans_pf); in sctp_select_active_and_retran_path()
1375 asoc->peer.active_path = trans_pri; in sctp_select_active_and_retran_path()
1376 asoc->peer.retran_path = trans_sec; in sctp_select_active_and_retran_path()
1380 sctp_assoc_choose_alter_transport(struct sctp_association *asoc, in sctp_assoc_choose_alter_transport() argument
1388 return asoc->peer.active_path; in sctp_assoc_choose_alter_transport()
1390 if (last_sent_to == asoc->peer.retran_path) in sctp_assoc_choose_alter_transport()
1391 sctp_assoc_update_retran_path(asoc); in sctp_assoc_choose_alter_transport()
1393 return asoc->peer.retran_path; in sctp_assoc_choose_alter_transport()
1397 void sctp_assoc_update_frag_point(struct sctp_association *asoc) in sctp_assoc_update_frag_point() argument
1399 int frag = sctp_mtu_payload(sctp_sk(asoc->base.sk), asoc->pathmtu, in sctp_assoc_update_frag_point()
1400 sctp_datachk_len(&asoc->stream)); in sctp_assoc_update_frag_point()
1402 if (asoc->user_frag) in sctp_assoc_update_frag_point()
1403 frag = min_t(int, frag, asoc->user_frag); in sctp_assoc_update_frag_point()
1406 sctp_datachk_len(&asoc->stream)); in sctp_assoc_update_frag_point()
1408 asoc->frag_point = SCTP_TRUNC4(frag); in sctp_assoc_update_frag_point()
1411 void sctp_assoc_set_pmtu(struct sctp_association *asoc, __u32 pmtu) in sctp_assoc_set_pmtu() argument
1413 if (asoc->pathmtu != pmtu) { in sctp_assoc_set_pmtu()
1414 asoc->pathmtu = pmtu; in sctp_assoc_set_pmtu()
1415 sctp_assoc_update_frag_point(asoc); in sctp_assoc_set_pmtu()
1418 pr_debug("%s: asoc:%p, pmtu:%d, frag_point:%d\n", __func__, asoc, in sctp_assoc_set_pmtu()
1419 asoc->pathmtu, asoc->frag_point); in sctp_assoc_set_pmtu()
1425 void sctp_assoc_sync_pmtu(struct sctp_association *asoc) in sctp_assoc_sync_pmtu() argument
1430 if (!asoc) in sctp_assoc_sync_pmtu()
1434 list_for_each_entry(t, &asoc->peer.transport_addr_list, transports) { in sctp_assoc_sync_pmtu()
1444 sctp_assoc_set_pmtu(asoc, pmtu); in sctp_assoc_sync_pmtu()
1448 static inline bool sctp_peer_needs_update(struct sctp_association *asoc) in sctp_peer_needs_update() argument
1450 struct net *net = asoc->base.net; in sctp_peer_needs_update()
1452 switch (asoc->state) { in sctp_peer_needs_update()
1457 if ((asoc->rwnd > asoc->a_rwnd) && in sctp_peer_needs_update()
1458 ((asoc->rwnd - asoc->a_rwnd) >= max_t(__u32, in sctp_peer_needs_update()
1459 (asoc->base.sk->sk_rcvbuf >> net->sctp.rwnd_upd_shift), in sctp_peer_needs_update()
1460 asoc->pathmtu))) in sctp_peer_needs_update()
1469 /* Increase asoc's rwnd by len and send any window update SACK if needed. */
1470 void sctp_assoc_rwnd_increase(struct sctp_association *asoc, unsigned int len) in sctp_assoc_rwnd_increase() argument
1475 if (asoc->rwnd_over) { in sctp_assoc_rwnd_increase()
1476 if (asoc->rwnd_over >= len) { in sctp_assoc_rwnd_increase()
1477 asoc->rwnd_over -= len; in sctp_assoc_rwnd_increase()
1479 asoc->rwnd += (len - asoc->rwnd_over); in sctp_assoc_rwnd_increase()
1480 asoc->rwnd_over = 0; in sctp_assoc_rwnd_increase()
1483 asoc->rwnd += len; in sctp_assoc_rwnd_increase()
1491 if (asoc->rwnd_press) { in sctp_assoc_rwnd_increase()
1492 int change = min(asoc->pathmtu, asoc->rwnd_press); in sctp_assoc_rwnd_increase()
1493 asoc->rwnd += change; in sctp_assoc_rwnd_increase()
1494 asoc->rwnd_press -= change; in sctp_assoc_rwnd_increase()
1497 pr_debug("%s: asoc:%p rwnd increased by %d to (%u, %u) - %u\n", in sctp_assoc_rwnd_increase()
1498 __func__, asoc, len, asoc->rwnd, asoc->rwnd_over, in sctp_assoc_rwnd_increase()
1499 asoc->a_rwnd); in sctp_assoc_rwnd_increase()
1506 if (sctp_peer_needs_update(asoc)) { in sctp_assoc_rwnd_increase()
1507 asoc->a_rwnd = asoc->rwnd; in sctp_assoc_rwnd_increase()
1509 pr_debug("%s: sending window update SACK- asoc:%p rwnd:%u " in sctp_assoc_rwnd_increase()
1510 "a_rwnd:%u\n", __func__, asoc, asoc->rwnd, in sctp_assoc_rwnd_increase()
1511 asoc->a_rwnd); in sctp_assoc_rwnd_increase()
1513 sack = sctp_make_sack(asoc); in sctp_assoc_rwnd_increase()
1517 asoc->peer.sack_needed = 0; in sctp_assoc_rwnd_increase()
1519 sctp_outq_tail(&asoc->outqueue, sack, GFP_ATOMIC); in sctp_assoc_rwnd_increase()
1522 timer = &asoc->timers[SCTP_EVENT_TIMEOUT_SACK]; in sctp_assoc_rwnd_increase()
1524 sctp_association_put(asoc); in sctp_assoc_rwnd_increase()
1528 /* Decrease asoc's rwnd by len. */
1529 void sctp_assoc_rwnd_decrease(struct sctp_association *asoc, unsigned int len) in sctp_assoc_rwnd_decrease() argument
1534 if (unlikely(!asoc->rwnd || asoc->rwnd_over)) in sctp_assoc_rwnd_decrease()
1535 pr_debug("%s: association:%p has asoc->rwnd:%u, " in sctp_assoc_rwnd_decrease()
1536 "asoc->rwnd_over:%u!\n", __func__, asoc, in sctp_assoc_rwnd_decrease()
1537 asoc->rwnd, asoc->rwnd_over); in sctp_assoc_rwnd_decrease()
1539 if (asoc->ep->rcvbuf_policy) in sctp_assoc_rwnd_decrease()
1540 rx_count = atomic_read(&asoc->rmem_alloc); in sctp_assoc_rwnd_decrease()
1542 rx_count = atomic_read(&asoc->base.sk->sk_rmem_alloc); in sctp_assoc_rwnd_decrease()
1549 if (rx_count >= asoc->base.sk->sk_rcvbuf) in sctp_assoc_rwnd_decrease()
1552 if (asoc->rwnd >= len) { in sctp_assoc_rwnd_decrease()
1553 asoc->rwnd -= len; in sctp_assoc_rwnd_decrease()
1555 asoc->rwnd_press += asoc->rwnd; in sctp_assoc_rwnd_decrease()
1556 asoc->rwnd = 0; in sctp_assoc_rwnd_decrease()
1559 asoc->rwnd_over += len - asoc->rwnd; in sctp_assoc_rwnd_decrease()
1560 asoc->rwnd = 0; in sctp_assoc_rwnd_decrease()
1563 pr_debug("%s: asoc:%p rwnd decreased by %d to (%u, %u, %u)\n", in sctp_assoc_rwnd_decrease()
1564 __func__, asoc, len, asoc->rwnd, asoc->rwnd_over, in sctp_assoc_rwnd_decrease()
1565 asoc->rwnd_press); in sctp_assoc_rwnd_decrease()
1571 int sctp_assoc_set_bind_addr_from_ep(struct sctp_association *asoc, in sctp_assoc_set_bind_addr_from_ep() argument
1574 struct sock *sk = asoc->base.sk; in sctp_assoc_set_bind_addr_from_ep()
1583 if (asoc->peer.ipv4_address) in sctp_assoc_set_bind_addr_from_ep()
1585 if (asoc->peer.ipv6_address) in sctp_assoc_set_bind_addr_from_ep()
1588 return sctp_bind_addr_copy(asoc->base.net, in sctp_assoc_set_bind_addr_from_ep()
1589 &asoc->base.bind_addr, in sctp_assoc_set_bind_addr_from_ep()
1590 &asoc->ep->base.bind_addr, in sctp_assoc_set_bind_addr_from_ep()
1595 int sctp_assoc_set_bind_addr_from_cookie(struct sctp_association *asoc, in sctp_assoc_set_bind_addr_from_cookie() argument
1604 return sctp_raw_to_bind_addrs(&asoc->base.bind_addr, raw, var_size3, in sctp_assoc_set_bind_addr_from_cookie()
1605 asoc->ep->base.bind_addr.port, gfp); in sctp_assoc_set_bind_addr_from_cookie()
1609 int sctp_assoc_lookup_laddr(struct sctp_association *asoc, in sctp_assoc_lookup_laddr() argument
1614 if ((asoc->base.bind_addr.port == ntohs(laddr->v4.sin_port)) && in sctp_assoc_lookup_laddr()
1615 sctp_bind_addr_match(&asoc->base.bind_addr, laddr, in sctp_assoc_lookup_laddr()
1616 sctp_sk(asoc->base.sk))) in sctp_assoc_lookup_laddr()
1623 int sctp_assoc_set_id(struct sctp_association *asoc, gfp_t gfp) in sctp_assoc_set_id() argument
1629 if (asoc->assoc_id) in sctp_assoc_set_id()
1638 ret = idr_alloc_cyclic(&sctp_assocs_id, asoc, SCTP_ALL_ASSOC + 1, 0, in sctp_assoc_set_id()
1646 asoc->assoc_id = (sctp_assoc_t)ret; in sctp_assoc_set_id()
1651 static void sctp_assoc_free_asconf_queue(struct sctp_association *asoc) in sctp_assoc_free_asconf_queue() argument
1656 list_for_each_entry_safe(asconf, tmp, &asoc->addip_chunk_list, list) { in sctp_assoc_free_asconf_queue()
1663 static void sctp_assoc_free_asconf_acks(struct sctp_association *asoc) in sctp_assoc_free_asconf_acks() argument
1668 list_for_each_entry_safe(ack, tmp, &asoc->asconf_ack_list, in sctp_assoc_free_asconf_acks()
1676 void sctp_assoc_clean_asconf_ack_cache(const struct sctp_association *asoc) in sctp_assoc_clean_asconf_ack_cache() argument
1684 list_for_each_entry_safe(ack, tmp, &asoc->asconf_ack_list, in sctp_assoc_clean_asconf_ack_cache()
1687 htonl(asoc->peer.addip_serial)) in sctp_assoc_clean_asconf_ack_cache()
1697 const struct sctp_association *asoc, in sctp_assoc_lookup_asconf_ack() argument
1705 list_for_each_entry(ack, &asoc->asconf_ack_list, transmitted_list) { in sctp_assoc_lookup_asconf_ack()
1717 void sctp_asconf_queue_teardown(struct sctp_association *asoc) in sctp_asconf_queue_teardown() argument
1720 sctp_assoc_free_asconf_acks(asoc); in sctp_asconf_queue_teardown()
1723 sctp_assoc_free_asconf_queue(asoc); in sctp_asconf_queue_teardown()
1726 if (asoc->addip_last_asconf) in sctp_asconf_queue_teardown()
1727 sctp_chunk_free(asoc->addip_last_asconf); in sctp_asconf_queue_teardown()