Lines Matching full:peer
170 asoc->peer.rwnd = SCTP_DEFAULT_MAXWINDOW; 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()
240 /* Assume that peer would support both address types unless we are in sctp_association_init()
243 asoc->peer.ipv4_address = 1; in sctp_association_init()
245 asoc->peer.ipv6_address = 1; in sctp_association_init()
350 sctp_tsnmap_free(&asoc->peer.tsn_map); in sctp_association_free()
371 /* Free peer's cached cookie. */ in sctp_association_free()
372 kfree(asoc->peer.cookie); in sctp_association_free()
373 kfree(asoc->peer.peer_random); in sctp_association_free()
374 kfree(asoc->peer.peer_chunks); in sctp_association_free()
375 kfree(asoc->peer.peer_hmacs); in sctp_association_free()
378 list_for_each_safe(pos, temp, &asoc->peer.transport_addr_list) { in sctp_association_free()
385 asoc->peer.transport_count = 0; in sctp_association_free()
424 /* Change the primary destination address for the peer. */
433 if (asoc->peer.primary_path != NULL && in sctp_assoc_set_primary()
434 asoc->peer.primary_path != transport) in sctp_assoc_set_primary()
437 asoc->peer.primary_path = transport; in sctp_assoc_set_primary()
442 memcpy(&asoc->peer.primary_addr, &transport->ipaddr, in sctp_assoc_set_primary()
450 asoc->peer.active_path = transport; in sctp_assoc_set_primary()
485 struct sctp_transport *peer) in sctp_assoc_rm_peer() argument
492 __func__, asoc, &peer->ipaddr.sa); in sctp_assoc_rm_peer()
495 * to the next peer before removing this peer from the list. in sctp_assoc_rm_peer()
497 if (asoc->peer.retran_path == peer) in sctp_assoc_rm_peer()
500 /* Remove this peer from the list. */ in sctp_assoc_rm_peer()
501 list_del_rcu(&peer->transports); in sctp_assoc_rm_peer()
502 /* Remove this peer from the transport hashtable */ in sctp_assoc_rm_peer()
503 sctp_unhash_transport(peer); in sctp_assoc_rm_peer()
506 pos = asoc->peer.transport_addr_list.next; in sctp_assoc_rm_peer()
509 /* Update any entries that match the peer to be deleted. */ in sctp_assoc_rm_peer()
510 if (asoc->peer.primary_path == peer) in sctp_assoc_rm_peer()
512 if (asoc->peer.active_path == peer) in sctp_assoc_rm_peer()
513 asoc->peer.active_path = transport; in sctp_assoc_rm_peer()
514 if (asoc->peer.retran_path == peer) in sctp_assoc_rm_peer()
515 asoc->peer.retran_path = transport; in sctp_assoc_rm_peer()
516 if (asoc->peer.last_data_from == peer) in sctp_assoc_rm_peer()
517 asoc->peer.last_data_from = transport; in sctp_assoc_rm_peer()
520 asoc->strreset_chunk->transport == peer) { in sctp_assoc_rm_peer()
530 if (asoc->init_last_sent_to == peer) in sctp_assoc_rm_peer()
538 if (asoc->shutdown_last_sent_to == peer) in sctp_assoc_rm_peer()
545 asoc->addip_last_asconf->transport == peer) in sctp_assoc_rm_peer()
551 if (!list_empty(&peer->transmitted)) { in sctp_assoc_rm_peer()
552 struct sctp_transport *active = asoc->peer.active_path; in sctp_assoc_rm_peer()
555 list_for_each_entry(ch, &peer->transmitted, in sctp_assoc_rm_peer()
561 list_splice_tail_init(&peer->transmitted, in sctp_assoc_rm_peer()
575 if (ch->transport == peer) in sctp_assoc_rm_peer()
578 asoc->peer.transport_count--; in sctp_assoc_rm_peer()
580 sctp_ulpevent_notify_peer_addr_change(peer, SCTP_ADDR_REMOVED, 0); in sctp_assoc_rm_peer()
581 sctp_transport_free(peer); in sctp_assoc_rm_peer()
590 struct sctp_transport *peer; in sctp_assoc_add_peer() local
603 if (0 == asoc->peer.port) in sctp_assoc_add_peer()
604 asoc->peer.port = port; in sctp_assoc_add_peer()
607 peer = sctp_assoc_lookup_paddr(asoc, addr); in sctp_assoc_add_peer()
608 if (peer) { in sctp_assoc_add_peer()
613 if (peer->state == SCTP_UNKNOWN) { in sctp_assoc_add_peer()
614 peer->state = SCTP_ACTIVE; in sctp_assoc_add_peer()
616 return peer; in sctp_assoc_add_peer()
619 peer = sctp_transport_new(asoc->base.net, addr, gfp); in sctp_assoc_add_peer()
620 if (!peer) in sctp_assoc_add_peer()
623 sctp_transport_set_owner(peer, asoc); in sctp_assoc_add_peer()
625 /* Initialize the peer's heartbeat interval based on the in sctp_assoc_add_peer()
628 peer->hbinterval = asoc->hbinterval; in sctp_assoc_add_peer()
629 peer->probe_interval = asoc->probe_interval; in sctp_assoc_add_peer()
631 peer->encap_port = asoc->encap_port; in sctp_assoc_add_peer()
634 peer->pathmaxrxt = asoc->pathmaxrxt; in sctp_assoc_add_peer()
637 peer->pf_retrans = asoc->pf_retrans; in sctp_assoc_add_peer()
639 peer->ps_retrans = asoc->ps_retrans; in sctp_assoc_add_peer()
641 /* Initialize the peer's SACK delay timeout based on the in sctp_assoc_add_peer()
644 peer->sackdelay = asoc->sackdelay; in sctp_assoc_add_peer()
645 peer->sackfreq = asoc->sackfreq; in sctp_assoc_add_peer()
651 peer->flowlabel = ntohl(info & IPV6_FLOWLABEL_MASK); in sctp_assoc_add_peer()
652 peer->flowlabel |= SCTP_FLOWLABEL_SET_MASK; in sctp_assoc_add_peer()
654 peer->flowlabel = asoc->flowlabel; in sctp_assoc_add_peer()
657 peer->dscp = asoc->dscp; in sctp_assoc_add_peer()
662 peer->param_flags = asoc->param_flags; in sctp_assoc_add_peer()
665 sctp_transport_route(peer, NULL, sp); in sctp_assoc_add_peer()
668 * initialize the association PMTU to the peer's PMTU. in sctp_assoc_add_peer()
670 * peer's PMTU, reset the association PMTU to the new peer's PMTU. in sctp_assoc_add_peer()
673 min_t(int, peer->pathmtu, asoc->pathmtu) : in sctp_assoc_add_peer()
674 peer->pathmtu); in sctp_assoc_add_peer()
676 peer->pmtu_pending = 0; in sctp_assoc_add_peer()
678 /* The asoc->peer.port might not be meaningful yet, but in sctp_assoc_add_peer()
681 sctp_packet_init(&peer->packet, peer, asoc->base.bind_addr.port, in sctp_assoc_add_peer()
682 asoc->peer.port); in sctp_assoc_add_peer()
694 peer->cwnd = min(4*asoc->pathmtu, max_t(__u32, 2*asoc->pathmtu, 4380)); in sctp_assoc_add_peer()
700 peer->ssthresh = SCTP_DEFAULT_MAXWINDOW; in sctp_assoc_add_peer()
702 peer->partial_bytes_acked = 0; in sctp_assoc_add_peer()
703 peer->flight_size = 0; in sctp_assoc_add_peer()
704 peer->burst_limited = 0; in sctp_assoc_add_peer()
707 peer->rto = asoc->rto_initial; in sctp_assoc_add_peer()
708 sctp_max_rto(asoc, peer); in sctp_assoc_add_peer()
710 /* Set the peer's active state. */ in sctp_assoc_add_peer()
711 peer->state = peer_state; in sctp_assoc_add_peer()
713 /* Add this peer into the transport hashtable */ in sctp_assoc_add_peer()
714 if (sctp_hash_transport(peer)) { in sctp_assoc_add_peer()
715 sctp_transport_free(peer); in sctp_assoc_add_peer()
719 sctp_transport_pl_reset(peer); in sctp_assoc_add_peer()
722 list_add_tail_rcu(&peer->transports, &asoc->peer.transport_addr_list); in sctp_assoc_add_peer()
723 asoc->peer.transport_count++; in sctp_assoc_add_peer()
725 sctp_ulpevent_notify_peer_addr_change(peer, SCTP_ADDR_ADDED, 0); in sctp_assoc_add_peer()
728 if (!asoc->peer.primary_path) { in sctp_assoc_add_peer()
729 sctp_assoc_set_primary(asoc, peer); in sctp_assoc_add_peer()
730 asoc->peer.retran_path = peer; in sctp_assoc_add_peer()
733 if (asoc->peer.active_path == asoc->peer.retran_path && in sctp_assoc_add_peer()
734 peer->state != SCTP_UNCONFIRMED) { in sctp_assoc_add_peer()
735 asoc->peer.retran_path = peer; in sctp_assoc_add_peer()
738 return peer; in sctp_assoc_add_peer()
749 list_for_each_safe(pos, temp, &asoc->peer.transport_addr_list) { in sctp_assoc_del_peer()
752 /* Do book keeping for removing the peer and free it. */ in sctp_assoc_del_peer()
766 /* Cycle through all transports searching for a peer address. */ in sctp_assoc_lookup_paddr()
768 list_for_each_entry(t, &asoc->peer.transport_addr_list, in sctp_assoc_lookup_paddr()
784 list_for_each_entry_safe(t, temp, &asoc->peer.transport_addr_list, in sctp_assoc_del_nonprimary_peers()
951 active = asoc->peer.active_path; in sctp_assoc_lookup_tsn()
963 list_for_each_entry(transport, &asoc->peer.transport_addr_list, in sctp_assoc_lookup_tsn()
1031 * been sent to the peer during the association setup. It in sctp_assoc_bh_rcv()
1042 asoc->peer.last_data_from = chunk->transport; in sctp_assoc_bh_rcv()
1111 /* Copy in new parameters of peer. */ in sctp_assoc_update()
1113 asoc->peer.rwnd = new->peer.rwnd; in sctp_assoc_update()
1114 asoc->peer.sack_needed = new->peer.sack_needed; in sctp_assoc_update()
1115 asoc->peer.auth_capable = new->peer.auth_capable; in sctp_assoc_update()
1116 asoc->peer.i = new->peer.i; in sctp_assoc_update()
1118 if (!sctp_tsnmap_init(&asoc->peer.tsn_map, SCTP_TSN_MAP_INITIAL, in sctp_assoc_update()
1119 asoc->peer.i.initial_tsn, GFP_ATOMIC)) in sctp_assoc_update()
1122 /* Remove any peer addresses not present in the new association. */ in sctp_assoc_update()
1123 list_for_each_safe(pos, temp, &asoc->peer.transport_addr_list) { in sctp_assoc_update()
1136 * current next_tsn in case data sent to peer in sctp_assoc_update()
1145 * and peer's streams. in sctp_assoc_update()
1162 /* Add any peer addresses from the new association. */ in sctp_assoc_update()
1163 list_for_each_entry(trans, &new->peer.transport_addr_list, in sctp_assoc_update()
1181 /* SCTP-AUTH: Save the peer parameters from the new associations in sctp_assoc_update()
1184 kfree(asoc->peer.peer_random); in sctp_assoc_update()
1185 asoc->peer.peer_random = new->peer.peer_random; in sctp_assoc_update()
1186 new->peer.peer_random = NULL; in sctp_assoc_update()
1188 kfree(asoc->peer.peer_chunks); in sctp_assoc_update()
1189 asoc->peer.peer_chunks = new->peer.peer_chunks; in sctp_assoc_update()
1190 new->peer.peer_chunks = NULL; in sctp_assoc_update()
1192 kfree(asoc->peer.peer_hmacs); in sctp_assoc_update()
1193 asoc->peer.peer_hmacs = new->peer.peer_hmacs; in sctp_assoc_update()
1194 new->peer.peer_hmacs = NULL; in sctp_assoc_update()
1280 struct sctp_transport *trans = asoc->peer.retran_path; in sctp_assoc_update_retran_path()
1284 if (asoc->peer.transport_count == 1) in sctp_assoc_update_retran_path()
1289 if (asoc->peer.active_path == asoc->peer.retran_path && in sctp_assoc_update_retran_path()
1290 asoc->peer.active_path->state == SCTP_ACTIVE) in sctp_assoc_update_retran_path()
1297 if (&trans->transports == &asoc->peer.transport_addr_list) in sctp_assoc_update_retran_path()
1306 if (trans == asoc->peer.retran_path) in sctp_assoc_update_retran_path()
1310 asoc->peer.retran_path = trans_next; in sctp_assoc_update_retran_path()
1313 __func__, asoc, &asoc->peer.retran_path->ipaddr.sa); in sctp_assoc_update_retran_path()
1322 list_for_each_entry(trans, &asoc->peer.transport_addr_list, in sctp_select_active_and_retran_path()
1356 if ((asoc->peer.primary_path->state == SCTP_ACTIVE || in sctp_select_active_and_retran_path()
1357 asoc->peer.primary_path->state == SCTP_UNKNOWN) && in sctp_select_active_and_retran_path()
1358 asoc->peer.primary_path != trans_pri) { in sctp_select_active_and_retran_path()
1360 trans_pri = asoc->peer.primary_path; in sctp_select_active_and_retran_path()
1374 trans_pri = sctp_trans_elect_best(asoc->peer.active_path, trans_pf); in sctp_select_active_and_retran_path()
1379 asoc->peer.active_path = trans_pri; in sctp_select_active_and_retran_path()
1380 asoc->peer.retran_path = trans_sec; in sctp_select_active_and_retran_path()
1392 return asoc->peer.active_path; in sctp_assoc_choose_alter_transport()
1394 if (last_sent_to == asoc->peer.retran_path) in sctp_assoc_choose_alter_transport()
1397 return asoc->peer.retran_path; in sctp_assoc_choose_alter_transport()
1438 list_for_each_entry(t, &asoc->peer.transport_addr_list, transports) { in sctp_assoc_sync_pmtu()
1451 /* Should we send a SACK to update our peer? */
1521 asoc->peer.sack_needed = 0; in sctp_assoc_rwnd_increase()
1573 * local endpoint and the remote peer.
1587 if (asoc->peer.ipv4_address) in sctp_assoc_set_bind_addr_from_ep()
1589 if (asoc->peer.ipv6_address) in sctp_assoc_set_bind_addr_from_ep()
1685 * the "Peer-Sequence-Number". in sctp_assoc_clean_asconf_ack_cache()
1690 htonl(asoc->peer.addip_serial)) in sctp_assoc_clean_asconf_ack_cache()