freeDiameter: libfdcore/p

annotate libfdcore/p_cnx.c @ 662:2e94ef0515d7 1.1.0-rc1

Updated copyright information

author	Sebastien Decugis <sdecugis@nict.go.jp>
date	Fri, 14 Jan 2011 16:27:21 +0900
parents	f198d16fa7f4
children	78b665400097

rev	line source
37 cc3c59fe98fe Lot of cleanups in peer structure management Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	1 /*********************************************************************************************************
cc3c59fe98fe Lot of cleanups in peer structure management Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	2 * Software License Agreement (BSD License) *
cc3c59fe98fe Lot of cleanups in peer structure management Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	3 * Author: Sebastien Decugis <sdecugis@nict.go.jp> *
cc3c59fe98fe Lot of cleanups in peer structure management Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	4 * *
662 2e94ef0515d7 Updated copyright information Sebastien Decugis <sdecugis@nict.go.jp> parents: 658 diff changeset	5 * Copyright (c) 2011, WIDE Project and NICT *
37 cc3c59fe98fe Lot of cleanups in peer structure management Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	6 * All rights reserved. *
cc3c59fe98fe Lot of cleanups in peer structure management Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	7 * *
cc3c59fe98fe Lot of cleanups in peer structure management Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	8 * Redistribution and use of this software in source and binary forms, with or without modification, are *
cc3c59fe98fe Lot of cleanups in peer structure management Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	9 * permitted provided that the following conditions are met: *
cc3c59fe98fe Lot of cleanups in peer structure management Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	10 * *
cc3c59fe98fe Lot of cleanups in peer structure management Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	11 * * Redistributions of source code must retain the above *
cc3c59fe98fe Lot of cleanups in peer structure management Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	12 * copyright notice, this list of conditions and the *
cc3c59fe98fe Lot of cleanups in peer structure management Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	13 * following disclaimer. *
cc3c59fe98fe Lot of cleanups in peer structure management Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	14 * *
cc3c59fe98fe Lot of cleanups in peer structure management Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	15 * * Redistributions in binary form must reproduce the above *
cc3c59fe98fe Lot of cleanups in peer structure management Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	16 * copyright notice, this list of conditions and the *
cc3c59fe98fe Lot of cleanups in peer structure management Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	17 * following disclaimer in the documentation and/or other *
cc3c59fe98fe Lot of cleanups in peer structure management Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	18 * materials provided with the distribution. *
cc3c59fe98fe Lot of cleanups in peer structure management Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	19 * *
cc3c59fe98fe Lot of cleanups in peer structure management Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	20 * * Neither the name of the WIDE Project or NICT nor the *
cc3c59fe98fe Lot of cleanups in peer structure management Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	21 * names of its contributors may be used to endorse or *
cc3c59fe98fe Lot of cleanups in peer structure management Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	22 * promote products derived from this software without *
cc3c59fe98fe Lot of cleanups in peer structure management Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	23 * specific prior written permission of WIDE Project and *
cc3c59fe98fe Lot of cleanups in peer structure management Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	24 * NICT. *
cc3c59fe98fe Lot of cleanups in peer structure management Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	25 * *
cc3c59fe98fe Lot of cleanups in peer structure management Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	26 * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS "AS IS" AND ANY EXPRESS OR IMPLIED *
cc3c59fe98fe Lot of cleanups in peer structure management Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	27 * WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A *
cc3c59fe98fe Lot of cleanups in peer structure management Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	28 * PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT OWNER OR CONTRIBUTORS BE LIABLE FOR *
cc3c59fe98fe Lot of cleanups in peer structure management Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	29 * ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT *
cc3c59fe98fe Lot of cleanups in peer structure management Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	30 * LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS *
cc3c59fe98fe Lot of cleanups in peer structure management Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	31 * INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR *
cc3c59fe98fe Lot of cleanups in peer structure management Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	32 * TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF *
cc3c59fe98fe Lot of cleanups in peer structure management Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	33 * ADVISED OF THE POSSIBILITY OF SUCH DAMAGE. *
cc3c59fe98fe Lot of cleanups in peer structure management Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	34 *********************************************************************************************************/
cc3c59fe98fe Lot of cleanups in peer structure management Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	35
658 f198d16fa7f4 Initial commit for 1.1.0: Sebastien Decugis <sdecugis@nict.go.jp> parents: 379 diff changeset	36 #include "fdcore-internal.h"
37 cc3c59fe98fe Lot of cleanups in peer structure management Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	37
cc3c59fe98fe Lot of cleanups in peer structure management Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	38 /* This file contains code used by a peer state machine to initiate a connection to remote peer */
cc3c59fe98fe Lot of cleanups in peer structure management Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	39
38 68c1890f7049 Fixed a small bug in SCTP close Sebastien Decugis <sdecugis@nict.go.jp> parents: 37 diff changeset	40 struct next_conn {
68c1890f7049 Fixed a small bug in SCTP close Sebastien Decugis <sdecugis@nict.go.jp> parents: 37 diff changeset	41 struct fd_list chain;
68c1890f7049 Fixed a small bug in SCTP close Sebastien Decugis <sdecugis@nict.go.jp> parents: 37 diff changeset	42 int proto; /* Protocol of the next attempt */
39 d7535cf7bab5 Added initiator connection logic Sebastien Decugis <sdecugis@nict.go.jp> parents: 38 diff changeset	43 union {
d7535cf7bab5 Added initiator connection logic Sebastien Decugis <sdecugis@nict.go.jp> parents: 38 diff changeset	44 sSS ss; /* The address, only for TCP */
d7535cf7bab5 Added initiator connection logic Sebastien Decugis <sdecugis@nict.go.jp> parents: 38 diff changeset	45 sSA4 sin;
d7535cf7bab5 Added initiator connection logic Sebastien Decugis <sdecugis@nict.go.jp> parents: 38 diff changeset	46 sSA6 sin6;
d7535cf7bab5 Added initiator connection logic Sebastien Decugis <sdecugis@nict.go.jp> parents: 38 diff changeset	47 };
38 68c1890f7049 Fixed a small bug in SCTP close Sebastien Decugis <sdecugis@nict.go.jp> parents: 37 diff changeset	48 uint16_t port; /* The port, for SCTP (included in ss for TCP) */
68c1890f7049 Fixed a small bug in SCTP close Sebastien Decugis <sdecugis@nict.go.jp> parents: 37 diff changeset	49 int dotls; /* Handshake TLS after connection ? */
68c1890f7049 Fixed a small bug in SCTP close Sebastien Decugis <sdecugis@nict.go.jp> parents: 37 diff changeset	50 };
68c1890f7049 Fixed a small bug in SCTP close Sebastien Decugis <sdecugis@nict.go.jp> parents: 37 diff changeset	51
39 d7535cf7bab5 Added initiator connection logic Sebastien Decugis <sdecugis@nict.go.jp> parents: 38 diff changeset	52 static __inline__ void failed_connection_attempt(struct fd_peer * peer)
d7535cf7bab5 Added initiator connection logic Sebastien Decugis <sdecugis@nict.go.jp> parents: 38 diff changeset	53 {
50 dbba83bafd66 Fix small bug thedoc@morbier.koganei.wide.ad.jp parents: 49 diff changeset	54 /* Simply remove the first item in the list if not empty */
dbba83bafd66 Fix small bug thedoc@morbier.koganei.wide.ad.jp parents: 49 diff changeset	55 if (! FD_IS_LIST_EMPTY(&peer->p_connparams) ) {
dbba83bafd66 Fix small bug thedoc@morbier.koganei.wide.ad.jp parents: 49 diff changeset	56 struct fd_list * li = peer->p_connparams.next;
dbba83bafd66 Fix small bug thedoc@morbier.koganei.wide.ad.jp parents: 49 diff changeset	57 fd_list_unlink(li);
dbba83bafd66 Fix small bug thedoc@morbier.koganei.wide.ad.jp parents: 49 diff changeset	58 free(li);
dbba83bafd66 Fix small bug thedoc@morbier.koganei.wide.ad.jp parents: 49 diff changeset	59 }
39 d7535cf7bab5 Added initiator connection logic Sebastien Decugis <sdecugis@nict.go.jp> parents: 38 diff changeset	60 }
d7535cf7bab5 Added initiator connection logic Sebastien Decugis <sdecugis@nict.go.jp> parents: 38 diff changeset	61
d7535cf7bab5 Added initiator connection logic Sebastien Decugis <sdecugis@nict.go.jp> parents: 38 diff changeset	62 static void empty_connection_list(struct fd_peer * peer)
d7535cf7bab5 Added initiator connection logic Sebastien Decugis <sdecugis@nict.go.jp> parents: 38 diff changeset	63 {
d7535cf7bab5 Added initiator connection logic Sebastien Decugis <sdecugis@nict.go.jp> parents: 38 diff changeset	64 /* Remove all items */
d7535cf7bab5 Added initiator connection logic Sebastien Decugis <sdecugis@nict.go.jp> parents: 38 diff changeset	65 while (!FD_IS_LIST_EMPTY(&peer->p_connparams)) {
d7535cf7bab5 Added initiator connection logic Sebastien Decugis <sdecugis@nict.go.jp> parents: 38 diff changeset	66 failed_connection_attempt(peer);
d7535cf7bab5 Added initiator connection logic Sebastien Decugis <sdecugis@nict.go.jp> parents: 38 diff changeset	67 }
d7535cf7bab5 Added initiator connection logic Sebastien Decugis <sdecugis@nict.go.jp> parents: 38 diff changeset	68 }
d7535cf7bab5 Added initiator connection logic Sebastien Decugis <sdecugis@nict.go.jp> parents: 38 diff changeset	69
38 68c1890f7049 Fixed a small bug in SCTP close Sebastien Decugis <sdecugis@nict.go.jp> parents: 37 diff changeset	70 static int prepare_connection_list(struct fd_peer * peer)
68c1890f7049 Fixed a small bug in SCTP close Sebastien Decugis <sdecugis@nict.go.jp> parents: 37 diff changeset	71 {
39 d7535cf7bab5 Added initiator connection logic Sebastien Decugis <sdecugis@nict.go.jp> parents: 38 diff changeset	72 struct fd_list * li, *last_prio;
d7535cf7bab5 Added initiator connection logic Sebastien Decugis <sdecugis@nict.go.jp> parents: 38 diff changeset	73 struct next_conn * new;
d7535cf7bab5 Added initiator connection logic Sebastien Decugis <sdecugis@nict.go.jp> parents: 38 diff changeset	74
d7535cf7bab5 Added initiator connection logic Sebastien Decugis <sdecugis@nict.go.jp> parents: 38 diff changeset	75 uint16_t port_no; /* network order */
d7535cf7bab5 Added initiator connection logic Sebastien Decugis <sdecugis@nict.go.jp> parents: 38 diff changeset	76 int dotls_immediate;
d7535cf7bab5 Added initiator connection logic Sebastien Decugis <sdecugis@nict.go.jp> parents: 38 diff changeset	77
d7535cf7bab5 Added initiator connection logic Sebastien Decugis <sdecugis@nict.go.jp> parents: 38 diff changeset	78 TRACE_ENTRY("%p", peer);
d7535cf7bab5 Added initiator connection logic Sebastien Decugis <sdecugis@nict.go.jp> parents: 38 diff changeset	79
38 68c1890f7049 Fixed a small bug in SCTP close Sebastien Decugis <sdecugis@nict.go.jp> parents: 37 diff changeset	80 /* Resolve peer address(es) if needed */
68c1890f7049 Fixed a small bug in SCTP close Sebastien Decugis <sdecugis@nict.go.jp> parents: 37 diff changeset	81 if (FD_IS_LIST_EMPTY(&peer->p_hdr.info.pi_endpoints)) {
68c1890f7049 Fixed a small bug in SCTP close Sebastien Decugis <sdecugis@nict.go.jp> parents: 37 diff changeset	82 struct addrinfo hints, ai, aip;
68c1890f7049 Fixed a small bug in SCTP close Sebastien Decugis <sdecugis@nict.go.jp> parents: 37 diff changeset	83 int ret;
68c1890f7049 Fixed a small bug in SCTP close Sebastien Decugis <sdecugis@nict.go.jp> parents: 37 diff changeset	84
68c1890f7049 Fixed a small bug in SCTP close Sebastien Decugis <sdecugis@nict.go.jp> parents: 37 diff changeset	85 memset(&hints, 0, sizeof(hints));
68c1890f7049 Fixed a small bug in SCTP close Sebastien Decugis <sdecugis@nict.go.jp> parents: 37 diff changeset	86 hints.ai_flags = AI_ADDRCONFIG;
68c1890f7049 Fixed a small bug in SCTP close Sebastien Decugis <sdecugis@nict.go.jp> parents: 37 diff changeset	87 ret = getaddrinfo(peer->p_hdr.info.pi_diamid, NULL, &hints, &ai);
68c1890f7049 Fixed a small bug in SCTP close Sebastien Decugis <sdecugis@nict.go.jp> parents: 37 diff changeset	88 if (ret) {
39 d7535cf7bab5 Added initiator connection logic Sebastien Decugis <sdecugis@nict.go.jp> parents: 38 diff changeset	89 fd_log_debug("Unable to resolve address for peer '%s' (%s), aborting\n", peer->p_hdr.info.pi_diamid, gai_strerror(ret));
370 06692259d788 Enforce address family from config when connecting to a peer Sebastien Decugis <sdecugis@nict.go.jp> parents: 258 diff changeset	90 if (ret != EAI_AGAIN)
06692259d788 Enforce address family from config when connecting to a peer Sebastien Decugis <sdecugis@nict.go.jp> parents: 258 diff changeset	91 fd_psm_terminate( peer, NULL );
38 68c1890f7049 Fixed a small bug in SCTP close Sebastien Decugis <sdecugis@nict.go.jp> parents: 37 diff changeset	92 return 0;
68c1890f7049 Fixed a small bug in SCTP close Sebastien Decugis <sdecugis@nict.go.jp> parents: 37 diff changeset	93 }
68c1890f7049 Fixed a small bug in SCTP close Sebastien Decugis <sdecugis@nict.go.jp> parents: 37 diff changeset	94
68c1890f7049 Fixed a small bug in SCTP close Sebastien Decugis <sdecugis@nict.go.jp> parents: 37 diff changeset	95 for (aip = ai; aip != NULL; aip = aip->ai_next) {
68c1890f7049 Fixed a small bug in SCTP close Sebastien Decugis <sdecugis@nict.go.jp> parents: 37 diff changeset	96 CHECK_FCT( fd_ep_add_merge( &peer->p_hdr.info.pi_endpoints, aip->ai_addr, aip->ai_addrlen, EP_FL_DISC ) );
68c1890f7049 Fixed a small bug in SCTP close Sebastien Decugis <sdecugis@nict.go.jp> parents: 37 diff changeset	97 }
68c1890f7049 Fixed a small bug in SCTP close Sebastien Decugis <sdecugis@nict.go.jp> parents: 37 diff changeset	98 freeaddrinfo(ai);
68c1890f7049 Fixed a small bug in SCTP close Sebastien Decugis <sdecugis@nict.go.jp> parents: 37 diff changeset	99 }
68c1890f7049 Fixed a small bug in SCTP close Sebastien Decugis <sdecugis@nict.go.jp> parents: 37 diff changeset	100
68c1890f7049 Fixed a small bug in SCTP close Sebastien Decugis <sdecugis@nict.go.jp> parents: 37 diff changeset	101 /* Remove addresses from unwanted family */
68c1890f7049 Fixed a small bug in SCTP close Sebastien Decugis <sdecugis@nict.go.jp> parents: 37 diff changeset	102 if (peer->p_hdr.info.config.pic_flags.pro3) {
68c1890f7049 Fixed a small bug in SCTP close Sebastien Decugis <sdecugis@nict.go.jp> parents: 37 diff changeset	103 CHECK_FCT( fd_ep_filter_family(
68c1890f7049 Fixed a small bug in SCTP close Sebastien Decugis <sdecugis@nict.go.jp> parents: 37 diff changeset	104 &peer->p_hdr.info.pi_endpoints,
68c1890f7049 Fixed a small bug in SCTP close Sebastien Decugis <sdecugis@nict.go.jp> parents: 37 diff changeset	105 (peer->p_hdr.info.config.pic_flags.pro3 == PI_P3_IP) ?
68c1890f7049 Fixed a small bug in SCTP close Sebastien Decugis <sdecugis@nict.go.jp> parents: 37 diff changeset	106 AF_INET
68c1890f7049 Fixed a small bug in SCTP close Sebastien Decugis <sdecugis@nict.go.jp> parents: 37 diff changeset	107 : AF_INET6));
68c1890f7049 Fixed a small bug in SCTP close Sebastien Decugis <sdecugis@nict.go.jp> parents: 37 diff changeset	108 }
370 06692259d788 Enforce address family from config when connecting to a peer Sebastien Decugis <sdecugis@nict.go.jp> parents: 258 diff changeset	109 if (fd_g_config->cnf_flags.no_ip4) {
06692259d788 Enforce address family from config when connecting to a peer Sebastien Decugis <sdecugis@nict.go.jp> parents: 258 diff changeset	110 CHECK_FCT( fd_ep_filter_family(
06692259d788 Enforce address family from config when connecting to a peer Sebastien Decugis <sdecugis@nict.go.jp> parents: 258 diff changeset	111 &peer->p_hdr.info.pi_endpoints,
06692259d788 Enforce address family from config when connecting to a peer Sebastien Decugis <sdecugis@nict.go.jp> parents: 258 diff changeset	112 AF_INET6));
06692259d788 Enforce address family from config when connecting to a peer Sebastien Decugis <sdecugis@nict.go.jp> parents: 258 diff changeset	113 }
06692259d788 Enforce address family from config when connecting to a peer Sebastien Decugis <sdecugis@nict.go.jp> parents: 258 diff changeset	114 if (fd_g_config->cnf_flags.no_ip6) {
06692259d788 Enforce address family from config when connecting to a peer Sebastien Decugis <sdecugis@nict.go.jp> parents: 258 diff changeset	115 CHECK_FCT( fd_ep_filter_family(
06692259d788 Enforce address family from config when connecting to a peer Sebastien Decugis <sdecugis@nict.go.jp> parents: 258 diff changeset	116 &peer->p_hdr.info.pi_endpoints,
06692259d788 Enforce address family from config when connecting to a peer Sebastien Decugis <sdecugis@nict.go.jp> parents: 258 diff changeset	117 AF_INET));
06692259d788 Enforce address family from config when connecting to a peer Sebastien Decugis <sdecugis@nict.go.jp> parents: 258 diff changeset	118 }
38 68c1890f7049 Fixed a small bug in SCTP close Sebastien Decugis <sdecugis@nict.go.jp> parents: 37 diff changeset	119
379 7337305ee51e Workaround to prevent peer connecting to itself (ipv6 local addresses) Sebastien Decugis <sdecugis@nict.go.jp> parents: 375 diff changeset	120 /* Remove any local address that would be here, it should not happen but it does sometimes... */
7337305ee51e Workaround to prevent peer connecting to itself (ipv6 local addresses) Sebastien Decugis <sdecugis@nict.go.jp> parents: 375 diff changeset	121 CHECK_FCT( fd_ep_filter_list(&peer->p_hdr.info.pi_endpoints, &fd_g_config->cnf_endpoints) );
7337305ee51e Workaround to prevent peer connecting to itself (ipv6 local addresses) Sebastien Decugis <sdecugis@nict.go.jp> parents: 375 diff changeset	122
39 d7535cf7bab5 Added initiator connection logic Sebastien Decugis <sdecugis@nict.go.jp> parents: 38 diff changeset	123 /* Now check we have at least one address to attempt */
d7535cf7bab5 Added initiator connection logic Sebastien Decugis <sdecugis@nict.go.jp> parents: 38 diff changeset	124 if (FD_IS_LIST_EMPTY(&peer->p_hdr.info.pi_endpoints)) {
d7535cf7bab5 Added initiator connection logic Sebastien Decugis <sdecugis@nict.go.jp> parents: 38 diff changeset	125 fd_log_debug("No address %savailable to connect to peer '%s', aborting\n", peer->p_hdr.info.config.pic_flags.pro3 ? "in the configured family " : "", peer->p_hdr.info.pi_diamid);
78 a58f0757c06a Added code for DPR/DPA Sebastien Decugis <sdecugis@nict.go.jp> parents: 70 diff changeset	126 fd_psm_terminate( peer, NULL );
39 d7535cf7bab5 Added initiator connection logic Sebastien Decugis <sdecugis@nict.go.jp> parents: 38 diff changeset	127 return 0;
d7535cf7bab5 Added initiator connection logic Sebastien Decugis <sdecugis@nict.go.jp> parents: 38 diff changeset	128 }
d7535cf7bab5 Added initiator connection logic Sebastien Decugis <sdecugis@nict.go.jp> parents: 38 diff changeset	129
d7535cf7bab5 Added initiator connection logic Sebastien Decugis <sdecugis@nict.go.jp> parents: 38 diff changeset	130 /* Cleanup any previous list */
d7535cf7bab5 Added initiator connection logic Sebastien Decugis <sdecugis@nict.go.jp> parents: 38 diff changeset	131 empty_connection_list(peer);
d7535cf7bab5 Added initiator connection logic Sebastien Decugis <sdecugis@nict.go.jp> parents: 38 diff changeset	132
d7535cf7bab5 Added initiator connection logic Sebastien Decugis <sdecugis@nict.go.jp> parents: 38 diff changeset	133 /* Prepare the parameters */
372 2687aa506ef6 Enforce TLS_OLD mechanism from configuration Sebastien Decugis <sdecugis@nict.go.jp> parents: 370 diff changeset	134 if ((peer->p_hdr.info.config.pic_flags.sec != PI_SEC_DEFAULT) \|\| (fd_g_config->cnf_flags.tls_alg)) {
39 d7535cf7bab5 Added initiator connection logic Sebastien Decugis <sdecugis@nict.go.jp> parents: 38 diff changeset	135 dotls_immediate = 0;
d7535cf7bab5 Added initiator connection logic Sebastien Decugis <sdecugis@nict.go.jp> parents: 38 diff changeset	136 port_no = htons(peer->p_hdr.info.config.pic_port ?: fd_g_config->cnf_port);
d7535cf7bab5 Added initiator connection logic Sebastien Decugis <sdecugis@nict.go.jp> parents: 38 diff changeset	137 } else {
d7535cf7bab5 Added initiator connection logic Sebastien Decugis <sdecugis@nict.go.jp> parents: 38 diff changeset	138 dotls_immediate = 1;
d7535cf7bab5 Added initiator connection logic Sebastien Decugis <sdecugis@nict.go.jp> parents: 38 diff changeset	139 port_no = htons(peer->p_hdr.info.config.pic_port ?: fd_g_config->cnf_port_tls);
d7535cf7bab5 Added initiator connection logic Sebastien Decugis <sdecugis@nict.go.jp> parents: 38 diff changeset	140 }
d7535cf7bab5 Added initiator connection logic Sebastien Decugis <sdecugis@nict.go.jp> parents: 38 diff changeset	141
d7535cf7bab5 Added initiator connection logic Sebastien Decugis <sdecugis@nict.go.jp> parents: 38 diff changeset	142 last_prio = &peer->p_connparams;
38 68c1890f7049 Fixed a small bug in SCTP close Sebastien Decugis <sdecugis@nict.go.jp> parents: 37 diff changeset	143
39 d7535cf7bab5 Added initiator connection logic Sebastien Decugis <sdecugis@nict.go.jp> parents: 38 diff changeset	144 /* Create TCP parameters unless specified otherwise */
64 bb45a8ffec77 Enforce configuration flags for new outgoing connections Sebastien Decugis <sdecugis@nict.go.jp> parents: 50 diff changeset	145 if ((!fd_g_config->cnf_flags.no_tcp) && (peer->p_hdr.info.config.pic_flags.pro4 != PI_P4_SCTP)) {
39 d7535cf7bab5 Added initiator connection logic Sebastien Decugis <sdecugis@nict.go.jp> parents: 38 diff changeset	146 for (li = peer->p_hdr.info.pi_endpoints.next; li != &peer->p_hdr.info.pi_endpoints; li = li->next) {
d7535cf7bab5 Added initiator connection logic Sebastien Decugis <sdecugis@nict.go.jp> parents: 38 diff changeset	147 struct fd_endpoint * ep = (struct fd_endpoint *)li;
d7535cf7bab5 Added initiator connection logic Sebastien Decugis <sdecugis@nict.go.jp> parents: 38 diff changeset	148
d7535cf7bab5 Added initiator connection logic Sebastien Decugis <sdecugis@nict.go.jp> parents: 38 diff changeset	149 CHECK_MALLOC( new = malloc(sizeof(struct next_conn)) );
d7535cf7bab5 Added initiator connection logic Sebastien Decugis <sdecugis@nict.go.jp> parents: 38 diff changeset	150 memset(new, 0, sizeof(struct next_conn));
d7535cf7bab5 Added initiator connection logic Sebastien Decugis <sdecugis@nict.go.jp> parents: 38 diff changeset	151 fd_list_init(&new->chain, new);
d7535cf7bab5 Added initiator connection logic Sebastien Decugis <sdecugis@nict.go.jp> parents: 38 diff changeset	152
d7535cf7bab5 Added initiator connection logic Sebastien Decugis <sdecugis@nict.go.jp> parents: 38 diff changeset	153 new->proto = IPPROTO_TCP;
d7535cf7bab5 Added initiator connection logic Sebastien Decugis <sdecugis@nict.go.jp> parents: 38 diff changeset	154
d7535cf7bab5 Added initiator connection logic Sebastien Decugis <sdecugis@nict.go.jp> parents: 38 diff changeset	155 memcpy( &new->ss, &ep->ss, sizeof(sSS) );
d7535cf7bab5 Added initiator connection logic Sebastien Decugis <sdecugis@nict.go.jp> parents: 38 diff changeset	156 switch (new->ss.ss_family) {
d7535cf7bab5 Added initiator connection logic Sebastien Decugis <sdecugis@nict.go.jp> parents: 38 diff changeset	157 case AF_INET:
d7535cf7bab5 Added initiator connection logic Sebastien Decugis <sdecugis@nict.go.jp> parents: 38 diff changeset	158 new->sin.sin_port = port_no;
d7535cf7bab5 Added initiator connection logic Sebastien Decugis <sdecugis@nict.go.jp> parents: 38 diff changeset	159 break;
d7535cf7bab5 Added initiator connection logic Sebastien Decugis <sdecugis@nict.go.jp> parents: 38 diff changeset	160 case AF_INET6:
d7535cf7bab5 Added initiator connection logic Sebastien Decugis <sdecugis@nict.go.jp> parents: 38 diff changeset	161 new->sin6.sin6_port = port_no;
d7535cf7bab5 Added initiator connection logic Sebastien Decugis <sdecugis@nict.go.jp> parents: 38 diff changeset	162 break;
d7535cf7bab5 Added initiator connection logic Sebastien Decugis <sdecugis@nict.go.jp> parents: 38 diff changeset	163 default:
d7535cf7bab5 Added initiator connection logic Sebastien Decugis <sdecugis@nict.go.jp> parents: 38 diff changeset	164 free(new);
d7535cf7bab5 Added initiator connection logic Sebastien Decugis <sdecugis@nict.go.jp> parents: 38 diff changeset	165 continue; /* Move to the next endpoint */
d7535cf7bab5 Added initiator connection logic Sebastien Decugis <sdecugis@nict.go.jp> parents: 38 diff changeset	166 }
d7535cf7bab5 Added initiator connection logic Sebastien Decugis <sdecugis@nict.go.jp> parents: 38 diff changeset	167
d7535cf7bab5 Added initiator connection logic Sebastien Decugis <sdecugis@nict.go.jp> parents: 38 diff changeset	168 new->dotls = dotls_immediate;
d7535cf7bab5 Added initiator connection logic Sebastien Decugis <sdecugis@nict.go.jp> parents: 38 diff changeset	169
d7535cf7bab5 Added initiator connection logic Sebastien Decugis <sdecugis@nict.go.jp> parents: 38 diff changeset	170 /* Add the new entry to the appropriate position (conf and disc go first) */
d7535cf7bab5 Added initiator connection logic Sebastien Decugis <sdecugis@nict.go.jp> parents: 38 diff changeset	171 if (ep->flags & (EP_FL_CONF \| EP_FL_DISC)) {
d7535cf7bab5 Added initiator connection logic Sebastien Decugis <sdecugis@nict.go.jp> parents: 38 diff changeset	172 fd_list_insert_after(last_prio, &new->chain);
d7535cf7bab5 Added initiator connection logic Sebastien Decugis <sdecugis@nict.go.jp> parents: 38 diff changeset	173 last_prio = &new->chain;
d7535cf7bab5 Added initiator connection logic Sebastien Decugis <sdecugis@nict.go.jp> parents: 38 diff changeset	174 } else {
d7535cf7bab5 Added initiator connection logic Sebastien Decugis <sdecugis@nict.go.jp> parents: 38 diff changeset	175 fd_list_insert_before(&peer->p_connparams, &new->chain);
d7535cf7bab5 Added initiator connection logic Sebastien Decugis <sdecugis@nict.go.jp> parents: 38 diff changeset	176 }
d7535cf7bab5 Added initiator connection logic Sebastien Decugis <sdecugis@nict.go.jp> parents: 38 diff changeset	177 }
d7535cf7bab5 Added initiator connection logic Sebastien Decugis <sdecugis@nict.go.jp> parents: 38 diff changeset	178 }
38 68c1890f7049 Fixed a small bug in SCTP close Sebastien Decugis <sdecugis@nict.go.jp> parents: 37 diff changeset	179
39 d7535cf7bab5 Added initiator connection logic Sebastien Decugis <sdecugis@nict.go.jp> parents: 38 diff changeset	180 /* Now, add the SCTP entry, if not disabled */
d7535cf7bab5 Added initiator connection logic Sebastien Decugis <sdecugis@nict.go.jp> parents: 38 diff changeset	181 #ifndef DISABLE_SCTP
64 bb45a8ffec77 Enforce configuration flags for new outgoing connections Sebastien Decugis <sdecugis@nict.go.jp> parents: 50 diff changeset	182 if ((!fd_g_config->cnf_flags.no_sctp) && (peer->p_hdr.info.config.pic_flags.pro4 != PI_P4_TCP)) {
39 d7535cf7bab5 Added initiator connection logic Sebastien Decugis <sdecugis@nict.go.jp> parents: 38 diff changeset	183 struct next_conn * new;
d7535cf7bab5 Added initiator connection logic Sebastien Decugis <sdecugis@nict.go.jp> parents: 38 diff changeset	184
d7535cf7bab5 Added initiator connection logic Sebastien Decugis <sdecugis@nict.go.jp> parents: 38 diff changeset	185 CHECK_MALLOC( new = malloc(sizeof(struct next_conn)) );
d7535cf7bab5 Added initiator connection logic Sebastien Decugis <sdecugis@nict.go.jp> parents: 38 diff changeset	186 memset(new, 0, sizeof(struct next_conn));
d7535cf7bab5 Added initiator connection logic Sebastien Decugis <sdecugis@nict.go.jp> parents: 38 diff changeset	187 fd_list_init(&new->chain, new);
38 68c1890f7049 Fixed a small bug in SCTP close Sebastien Decugis <sdecugis@nict.go.jp> parents: 37 diff changeset	188
39 d7535cf7bab5 Added initiator connection logic Sebastien Decugis <sdecugis@nict.go.jp> parents: 38 diff changeset	189 new->proto = IPPROTO_SCTP;
d7535cf7bab5 Added initiator connection logic Sebastien Decugis <sdecugis@nict.go.jp> parents: 38 diff changeset	190 new->port = ntohs(port_no); /* back to host byte order... */
d7535cf7bab5 Added initiator connection logic Sebastien Decugis <sdecugis@nict.go.jp> parents: 38 diff changeset	191 new->dotls = dotls_immediate;
38 68c1890f7049 Fixed a small bug in SCTP close Sebastien Decugis <sdecugis@nict.go.jp> parents: 37 diff changeset	192
39 d7535cf7bab5 Added initiator connection logic Sebastien Decugis <sdecugis@nict.go.jp> parents: 38 diff changeset	193 /* Add the new entry to the appropriate position (depending on preferences) */
374 8f4ae09bc7c3 Enforce the TCP preference from config also Sebastien Decugis <sdecugis@nict.go.jp> parents: 372 diff changeset	194 if ((fd_g_config->cnf_flags.pr_tcp) \|\| (peer->p_hdr.info.config.pic_flags.alg == PI_ALGPREF_TCP)) {
39 d7535cf7bab5 Added initiator connection logic Sebastien Decugis <sdecugis@nict.go.jp> parents: 38 diff changeset	195 fd_list_insert_after(last_prio, &new->chain);
d7535cf7bab5 Added initiator connection logic Sebastien Decugis <sdecugis@nict.go.jp> parents: 38 diff changeset	196 } else {
d7535cf7bab5 Added initiator connection logic Sebastien Decugis <sdecugis@nict.go.jp> parents: 38 diff changeset	197 fd_list_insert_after(&peer->p_connparams, &new->chain); /* very first position */
d7535cf7bab5 Added initiator connection logic Sebastien Decugis <sdecugis@nict.go.jp> parents: 38 diff changeset	198 }
38 68c1890f7049 Fixed a small bug in SCTP close Sebastien Decugis <sdecugis@nict.go.jp> parents: 37 diff changeset	199 }
39 d7535cf7bab5 Added initiator connection logic Sebastien Decugis <sdecugis@nict.go.jp> parents: 38 diff changeset	200 #endif /* DISABLE_SCTP */
d7535cf7bab5 Added initiator connection logic Sebastien Decugis <sdecugis@nict.go.jp> parents: 38 diff changeset	201
375 40507b3750da No need to return an error there Sebastien Decugis <sdecugis@nict.go.jp> parents: 374 diff changeset	202 return 0;
38 68c1890f7049 Fixed a small bug in SCTP close Sebastien Decugis <sdecugis@nict.go.jp> parents: 37 diff changeset	203 }
68c1890f7049 Fixed a small bug in SCTP close Sebastien Decugis <sdecugis@nict.go.jp> parents: 37 diff changeset	204
37 cc3c59fe98fe Lot of cleanups in peer structure management Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	205
cc3c59fe98fe Lot of cleanups in peer structure management Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	206 /* The thread that attempts the connection */
cc3c59fe98fe Lot of cleanups in peer structure management Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	207 static void * connect_thr(void * arg)
cc3c59fe98fe Lot of cleanups in peer structure management Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	208 {
cc3c59fe98fe Lot of cleanups in peer structure management Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	209 struct fd_peer * peer = arg;
cc3c59fe98fe Lot of cleanups in peer structure management Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	210 struct cnxctx * cnx = NULL;
38 68c1890f7049 Fixed a small bug in SCTP close Sebastien Decugis <sdecugis@nict.go.jp> parents: 37 diff changeset	211 struct next_conn * nc = NULL;
49 204718b0fa54 Couple of fixes Sebastien Decugis <sdecugis@nict.go.jp> parents: 43 diff changeset	212 int rebuilt = 0;
37 cc3c59fe98fe Lot of cleanups in peer structure management Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	213
38 68c1890f7049 Fixed a small bug in SCTP close Sebastien Decugis <sdecugis@nict.go.jp> parents: 37 diff changeset	214 TRACE_ENTRY("%p", arg);
68c1890f7049 Fixed a small bug in SCTP close Sebastien Decugis <sdecugis@nict.go.jp> parents: 37 diff changeset	215 CHECK_PARAMS_DO( CHECK_PEER(peer), return NULL );
68c1890f7049 Fixed a small bug in SCTP close Sebastien Decugis <sdecugis@nict.go.jp> parents: 37 diff changeset	216
49 204718b0fa54 Couple of fixes Sebastien Decugis <sdecugis@nict.go.jp> parents: 43 diff changeset	217 /* Set the thread name */
204718b0fa54 Couple of fixes Sebastien Decugis <sdecugis@nict.go.jp> parents: 43 diff changeset	218 {
204718b0fa54 Couple of fixes Sebastien Decugis <sdecugis@nict.go.jp> parents: 43 diff changeset	219 char buf[48];
136 abd3c441780b Fix 64 bits warnings Sebastien Decugis <sdecugis@nict.go.jp> parents: 78 diff changeset	220 sprintf(buf, "ConnTo:%.*s", (int)(sizeof(buf)) - 8, peer->p_hdr.info.pi_diamid);
49 204718b0fa54 Couple of fixes Sebastien Decugis <sdecugis@nict.go.jp> parents: 43 diff changeset	221 fd_log_threadname ( buf );
204718b0fa54 Couple of fixes Sebastien Decugis <sdecugis@nict.go.jp> parents: 43 diff changeset	222 }
204718b0fa54 Couple of fixes Sebastien Decugis <sdecugis@nict.go.jp> parents: 43 diff changeset	223
38 68c1890f7049 Fixed a small bug in SCTP close Sebastien Decugis <sdecugis@nict.go.jp> parents: 37 diff changeset	224 do {
49 204718b0fa54 Couple of fixes Sebastien Decugis <sdecugis@nict.go.jp> parents: 43 diff changeset	225 /* Rebuild the list if needed, if it is empty -- but at most once */
38 68c1890f7049 Fixed a small bug in SCTP close Sebastien Decugis <sdecugis@nict.go.jp> parents: 37 diff changeset	226 if (FD_IS_LIST_EMPTY(&peer->p_connparams)) {
49 204718b0fa54 Couple of fixes Sebastien Decugis <sdecugis@nict.go.jp> parents: 43 diff changeset	227 if (! rebuilt) {
204718b0fa54 Couple of fixes Sebastien Decugis <sdecugis@nict.go.jp> parents: 43 diff changeset	228 CHECK_FCT_DO( prepare_connection_list(peer), goto fatal_error );
204718b0fa54 Couple of fixes Sebastien Decugis <sdecugis@nict.go.jp> parents: 43 diff changeset	229 rebuilt ++;
204718b0fa54 Couple of fixes Sebastien Decugis <sdecugis@nict.go.jp> parents: 43 diff changeset	230 }
204718b0fa54 Couple of fixes Sebastien Decugis <sdecugis@nict.go.jp> parents: 43 diff changeset	231 if (FD_IS_LIST_EMPTY(&peer->p_connparams)) {
204718b0fa54 Couple of fixes Sebastien Decugis <sdecugis@nict.go.jp> parents: 43 diff changeset	232 /* We encountered an error or we have looped over all the addresses of the peer. */
204718b0fa54 Couple of fixes Sebastien Decugis <sdecugis@nict.go.jp> parents: 43 diff changeset	233 TRACE_DEBUG(INFO, "Unable to connect to the peer %s, aborting attempts for now.", peer->p_hdr.info.pi_diamid);
70 65b32c93f21e Do not wait for timeout when all connections attempts have failed Sebastien Decugis <sdecugis@nict.go.jp> parents: 64 diff changeset	234 CHECK_FCT_DO( fd_event_send(peer->p_events, FDEVP_CNX_FAILED, 0, NULL), goto fatal_error );
38 68c1890f7049 Fixed a small bug in SCTP close Sebastien Decugis <sdecugis@nict.go.jp> parents: 37 diff changeset	235 return NULL;
49 204718b0fa54 Couple of fixes Sebastien Decugis <sdecugis@nict.go.jp> parents: 43 diff changeset	236 }
38 68c1890f7049 Fixed a small bug in SCTP close Sebastien Decugis <sdecugis@nict.go.jp> parents: 37 diff changeset	237 }
68c1890f7049 Fixed a small bug in SCTP close Sebastien Decugis <sdecugis@nict.go.jp> parents: 37 diff changeset	238
68c1890f7049 Fixed a small bug in SCTP close Sebastien Decugis <sdecugis@nict.go.jp> parents: 37 diff changeset	239 /* Attempt connection to the first entry */
68c1890f7049 Fixed a small bug in SCTP close Sebastien Decugis <sdecugis@nict.go.jp> parents: 37 diff changeset	240 nc = (struct next_conn *)(peer->p_connparams.next);
68c1890f7049 Fixed a small bug in SCTP close Sebastien Decugis <sdecugis@nict.go.jp> parents: 37 diff changeset	241
68c1890f7049 Fixed a small bug in SCTP close Sebastien Decugis <sdecugis@nict.go.jp> parents: 37 diff changeset	242 switch (nc->proto) {
68c1890f7049 Fixed a small bug in SCTP close Sebastien Decugis <sdecugis@nict.go.jp> parents: 37 diff changeset	243 case IPPROTO_TCP:
246 6418a188c1b5 getnameinfo is also more sensitive on freeBSD Sebastien Decugis <sdecugis@nict.go.jp> parents: 219 diff changeset	244 cnx = fd_cnx_cli_connect_tcp((sSA *)&nc->ss, sSAlen(&nc->ss));
38 68c1890f7049 Fixed a small bug in SCTP close Sebastien Decugis <sdecugis@nict.go.jp> parents: 37 diff changeset	245 break;
68c1890f7049 Fixed a small bug in SCTP close Sebastien Decugis <sdecugis@nict.go.jp> parents: 37 diff changeset	246 #ifndef DISABLE_SCTP
68c1890f7049 Fixed a small bug in SCTP close Sebastien Decugis <sdecugis@nict.go.jp> parents: 37 diff changeset	247 case IPPROTO_SCTP:
68c1890f7049 Fixed a small bug in SCTP close Sebastien Decugis <sdecugis@nict.go.jp> parents: 37 diff changeset	248 cnx = fd_cnx_cli_connect_sctp((peer->p_hdr.info.config.pic_flags.pro3 == PI_P3_IP) ?: fd_g_config->cnf_flags.no_ip6, nc->port, &peer->p_hdr.info.pi_endpoints);
68c1890f7049 Fixed a small bug in SCTP close Sebastien Decugis <sdecugis@nict.go.jp> parents: 37 diff changeset	249 break;
68c1890f7049 Fixed a small bug in SCTP close Sebastien Decugis <sdecugis@nict.go.jp> parents: 37 diff changeset	250 #endif /* DISABLE_SCTP */
68c1890f7049 Fixed a small bug in SCTP close Sebastien Decugis <sdecugis@nict.go.jp> parents: 37 diff changeset	251 }
68c1890f7049 Fixed a small bug in SCTP close Sebastien Decugis <sdecugis@nict.go.jp> parents: 37 diff changeset	252
68c1890f7049 Fixed a small bug in SCTP close Sebastien Decugis <sdecugis@nict.go.jp> parents: 37 diff changeset	253 if (cnx)
68c1890f7049 Fixed a small bug in SCTP close Sebastien Decugis <sdecugis@nict.go.jp> parents: 37 diff changeset	254 break;
68c1890f7049 Fixed a small bug in SCTP close Sebastien Decugis <sdecugis@nict.go.jp> parents: 37 diff changeset	255
68c1890f7049 Fixed a small bug in SCTP close Sebastien Decugis <sdecugis@nict.go.jp> parents: 37 diff changeset	256 /* Pop these parameters and continue */
68c1890f7049 Fixed a small bug in SCTP close Sebastien Decugis <sdecugis@nict.go.jp> parents: 37 diff changeset	257 failed_connection_attempt(peer);
68c1890f7049 Fixed a small bug in SCTP close Sebastien Decugis <sdecugis@nict.go.jp> parents: 37 diff changeset	258
68c1890f7049 Fixed a small bug in SCTP close Sebastien Decugis <sdecugis@nict.go.jp> parents: 37 diff changeset	259 pthread_testcancel();
68c1890f7049 Fixed a small bug in SCTP close Sebastien Decugis <sdecugis@nict.go.jp> parents: 37 diff changeset	260
68c1890f7049 Fixed a small bug in SCTP close Sebastien Decugis <sdecugis@nict.go.jp> parents: 37 diff changeset	261 } while (!cnx); /* and until cancellation */
37 cc3c59fe98fe Lot of cleanups in peer structure management Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	262
cc3c59fe98fe Lot of cleanups in peer structure management Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	263 /* Now, we have an established connection in cnx */
cc3c59fe98fe Lot of cleanups in peer structure management Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	264
cc3c59fe98fe Lot of cleanups in peer structure management Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	265 pthread_cleanup_push((void *)fd_cnx_destroy, cnx);
cc3c59fe98fe Lot of cleanups in peer structure management Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	266
219 e5bcc8c9322e Add hostname verification Sebastien Decugis <sdecugis@nict.go.jp> parents: 136 diff changeset	267 /* Set the hostname in the connection, so that handshake verifies the remote identity */
e5bcc8c9322e Add hostname verification Sebastien Decugis <sdecugis@nict.go.jp> parents: 136 diff changeset	268 fd_cnx_sethostname(cnx,peer->p_hdr.info.pi_diamid);
e5bcc8c9322e Add hostname verification Sebastien Decugis <sdecugis@nict.go.jp> parents: 136 diff changeset	269
37 cc3c59fe98fe Lot of cleanups in peer structure management Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	270 /* Handshake if needed (secure port) */
38 68c1890f7049 Fixed a small bug in SCTP close Sebastien Decugis <sdecugis@nict.go.jp> parents: 37 diff changeset	271 if (nc->dotls) {
68c1890f7049 Fixed a small bug in SCTP close Sebastien Decugis <sdecugis@nict.go.jp> parents: 37 diff changeset	272 CHECK_FCT_DO( fd_cnx_handshake(cnx, GNUTLS_CLIENT, peer->p_hdr.info.config.pic_priority, NULL),
68c1890f7049 Fixed a small bug in SCTP close Sebastien Decugis <sdecugis@nict.go.jp> parents: 37 diff changeset	273 {
68c1890f7049 Fixed a small bug in SCTP close Sebastien Decugis <sdecugis@nict.go.jp> parents: 37 diff changeset	274 /* Handshake failed ... */
68c1890f7049 Fixed a small bug in SCTP close Sebastien Decugis <sdecugis@nict.go.jp> parents: 37 diff changeset	275 fd_log_debug("TLS Handshake failed with peer '%s', resetting the connection\n", peer->p_hdr.info.pi_diamid);
68c1890f7049 Fixed a small bug in SCTP close Sebastien Decugis <sdecugis@nict.go.jp> parents: 37 diff changeset	276 fd_cnx_destroy(cnx);
68c1890f7049 Fixed a small bug in SCTP close Sebastien Decugis <sdecugis@nict.go.jp> parents: 37 diff changeset	277 empty_connection_list(peer);
68c1890f7049 Fixed a small bug in SCTP close Sebastien Decugis <sdecugis@nict.go.jp> parents: 37 diff changeset	278 fd_ep_filter(&peer->p_hdr.info.pi_endpoints, EP_FL_CONF);
68c1890f7049 Fixed a small bug in SCTP close Sebastien Decugis <sdecugis@nict.go.jp> parents: 37 diff changeset	279 return NULL;
68c1890f7049 Fixed a small bug in SCTP close Sebastien Decugis <sdecugis@nict.go.jp> parents: 37 diff changeset	280 } );
43 2db15632a63d Added a large part of connection establishment logic, to test Sebastien Decugis <sdecugis@nict.go.jp> parents: 39 diff changeset	281 } else {
2db15632a63d Added a large part of connection establishment logic, to test Sebastien Decugis <sdecugis@nict.go.jp> parents: 39 diff changeset	282 /* Prepare to receive the next message */
2db15632a63d Added a large part of connection establishment logic, to test Sebastien Decugis <sdecugis@nict.go.jp> parents: 39 diff changeset	283 CHECK_FCT_DO( fd_cnx_start_clear(cnx, 0), goto fatal_error );
38 68c1890f7049 Fixed a small bug in SCTP close Sebastien Decugis <sdecugis@nict.go.jp> parents: 37 diff changeset	284 }
37 cc3c59fe98fe Lot of cleanups in peer structure management Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	285
cc3c59fe98fe Lot of cleanups in peer structure management Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	286 /* Upon success, generate FDEVP_CNX_ESTABLISHED */
cc3c59fe98fe Lot of cleanups in peer structure management Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	287 CHECK_FCT_DO( fd_event_send(peer->p_events, FDEVP_CNX_ESTABLISHED, 0, cnx), goto fatal_error );
38 68c1890f7049 Fixed a small bug in SCTP close Sebastien Decugis <sdecugis@nict.go.jp> parents: 37 diff changeset	288
37 cc3c59fe98fe Lot of cleanups in peer structure management Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	289 pthread_cleanup_pop(0);
cc3c59fe98fe Lot of cleanups in peer structure management Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	290
cc3c59fe98fe Lot of cleanups in peer structure management Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	291 return NULL;
38 68c1890f7049 Fixed a small bug in SCTP close Sebastien Decugis <sdecugis@nict.go.jp> parents: 37 diff changeset	292
37 cc3c59fe98fe Lot of cleanups in peer structure management Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	293 fatal_error:
cc3c59fe98fe Lot of cleanups in peer structure management Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	294 /* Cleanup the connection */
38 68c1890f7049 Fixed a small bug in SCTP close Sebastien Decugis <sdecugis@nict.go.jp> parents: 37 diff changeset	295 if (cnx)
68c1890f7049 Fixed a small bug in SCTP close Sebastien Decugis <sdecugis@nict.go.jp> parents: 37 diff changeset	296 fd_cnx_destroy(cnx);
37 cc3c59fe98fe Lot of cleanups in peer structure management Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	297
cc3c59fe98fe Lot of cleanups in peer structure management Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	298 /* Generate a termination event */
cc3c59fe98fe Lot of cleanups in peer structure management Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	299 CHECK_FCT_DO(fd_event_send(fd_g_config->cnf_main_ev, FDEV_TERMINATE, 0, NULL), );
cc3c59fe98fe Lot of cleanups in peer structure management Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	300
cc3c59fe98fe Lot of cleanups in peer structure management Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	301 return NULL;
cc3c59fe98fe Lot of cleanups in peer structure management Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	302 }
cc3c59fe98fe Lot of cleanups in peer structure management Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	303
cc3c59fe98fe Lot of cleanups in peer structure management Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	304
cc3c59fe98fe Lot of cleanups in peer structure management Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	305 /* Initiate a connection attempt to a remote peer */
cc3c59fe98fe Lot of cleanups in peer structure management Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	306 int fd_p_cnx_init(struct fd_peer * peer)
cc3c59fe98fe Lot of cleanups in peer structure management Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	307 {
38 68c1890f7049 Fixed a small bug in SCTP close Sebastien Decugis <sdecugis@nict.go.jp> parents: 37 diff changeset	308 TRACE_ENTRY("%p", peer);
68c1890f7049 Fixed a small bug in SCTP close Sebastien Decugis <sdecugis@nict.go.jp> parents: 37 diff changeset	309
37 cc3c59fe98fe Lot of cleanups in peer structure management Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	310 /* Start the connect thread */
cc3c59fe98fe Lot of cleanups in peer structure management Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	311 CHECK_FCT( pthread_create(&peer->p_ini_thr, NULL, connect_thr, peer) );
cc3c59fe98fe Lot of cleanups in peer structure management Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	312 return 0;
cc3c59fe98fe Lot of cleanups in peer structure management Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	313 }
38 68c1890f7049 Fixed a small bug in SCTP close Sebastien Decugis <sdecugis@nict.go.jp> parents: 37 diff changeset	314
68c1890f7049 Fixed a small bug in SCTP close Sebastien Decugis <sdecugis@nict.go.jp> parents: 37 diff changeset	315 /* Cancel a connection attempt */
68c1890f7049 Fixed a small bug in SCTP close Sebastien Decugis <sdecugis@nict.go.jp> parents: 37 diff changeset	316 void fd_p_cnx_abort(struct fd_peer * peer, int cleanup_all)
68c1890f7049 Fixed a small bug in SCTP close Sebastien Decugis <sdecugis@nict.go.jp> parents: 37 diff changeset	317 {
68c1890f7049 Fixed a small bug in SCTP close Sebastien Decugis <sdecugis@nict.go.jp> parents: 37 diff changeset	318 TRACE_ENTRY("%p %d", peer, cleanup_all);
68c1890f7049 Fixed a small bug in SCTP close Sebastien Decugis <sdecugis@nict.go.jp> parents: 37 diff changeset	319 CHECK_PARAMS_DO( CHECK_PEER(peer), return );
68c1890f7049 Fixed a small bug in SCTP close Sebastien Decugis <sdecugis@nict.go.jp> parents: 37 diff changeset	320
68c1890f7049 Fixed a small bug in SCTP close Sebastien Decugis <sdecugis@nict.go.jp> parents: 37 diff changeset	321 if (peer->p_ini_thr != (pthread_t)NULL) {
68c1890f7049 Fixed a small bug in SCTP close Sebastien Decugis <sdecugis@nict.go.jp> parents: 37 diff changeset	322 CHECK_FCT_DO( fd_thr_term(&peer->p_ini_thr), /* continue */);
68c1890f7049 Fixed a small bug in SCTP close Sebastien Decugis <sdecugis@nict.go.jp> parents: 37 diff changeset	323 failed_connection_attempt(peer);
68c1890f7049 Fixed a small bug in SCTP close Sebastien Decugis <sdecugis@nict.go.jp> parents: 37 diff changeset	324 }
68c1890f7049 Fixed a small bug in SCTP close Sebastien Decugis <sdecugis@nict.go.jp> parents: 37 diff changeset	325
68c1890f7049 Fixed a small bug in SCTP close Sebastien Decugis <sdecugis@nict.go.jp> parents: 37 diff changeset	326 if (cleanup_all) {
68c1890f7049 Fixed a small bug in SCTP close Sebastien Decugis <sdecugis@nict.go.jp> parents: 37 diff changeset	327 empty_connection_list(peer);
68c1890f7049 Fixed a small bug in SCTP close Sebastien Decugis <sdecugis@nict.go.jp> parents: 37 diff changeset	328 }
68c1890f7049 Fixed a small bug in SCTP close Sebastien Decugis <sdecugis@nict.go.jp> parents: 37 diff changeset	329 }

Mercurial > hg > freeDiameter

annotate libfdcore/p_cnx.c @ 662:2e94ef0515d7 1.1.0-rc1