Changeset 5339 for pjproject/trunk/pjnath/src/pjnath/ice_strans.c

Timestamp:

Jun 8, 2016 3:17:45 AM (8 years ago)

Author:

nanang

Message:

Re #422: Added IPv6 support to PJNATH, changes:

• Deprecated 'pj_ice_strans_cfg.af', if set, the value will be ignored, address family setting is now specified via transport setting, i.e: 'pj_ice_strans_cfg.stun_tp/turn_tp'.
• Deprecated 'pj_ice_strans_cfg.stun/turn', for backward compatibility, this field value will be checked if 'pj_ice_strans_cfg.stun_tp_cnt/turn_tp_cnt' is set to zero.
• Added 'pj_ice_strans_stun_cfg' & 'pj_ice_strans_stun_cfg' and the corresponding 'pj_ice_strans_stun/turn_cfg_default()'
• Added 'pj_ice_strans_cfg.stun_tp/turn_tp' as replacement of 'pj_ice_strans_cfg.stun/turn', it is now an array so app can have multiple STUN/TURN transports.
• Added macro PJ_ICE_MAX_STUN/TURN to specify maximum number of STUN/TURN transports in each ICE component in compile-time.
• Miscellaneous: fixed socket number limit in concurrency test in pjnath-test, updated pjsua_media.c to use new 'pj_ice_strans_cfg' setting.

File:

• pjproject/trunk/pjnath/src/pjnath/ice_strans.c (modified) (48 diffs)

pjproject/trunk/pjnath/src/pjnath/ice_strans.c

@@ -49 +49 @@
 };
 
+
+#define CREATE_TP_ID(type, idx)     (pj_uint8_t)((type << 6) | idx)
+#define GET_TP_TYPE(transport_id)   ((transport_id & 0xC0) >> 6)
+#define GET_TP_IDX(transport_id)    (transport_id & 0x3F)
+
+
 /* Candidate's local preference values. This is mostly used to
  * specify preference among candidates with the same type. Since
@@ -149 +155 @@
     unsigned             comp_id;       /**< Component ID.              */
 
-    pj_stun_sock        *stun_sock;     /**< STUN transport.            */
-    pj_turn_sock        *turn_sock;     /**< TURN relay transport.      */
-    pj_bool_t            turn_log_off;  /**< TURN loggin off?           */
-    unsigned             turn_err_cnt;  /**< TURN disconnected count.   */
+    struct {
+        pj_stun_sock    *sock;          /**< STUN transport.            */
+    } stun[PJ_ICE_MAX_STUN];
+
+    struct {
+        pj_turn_sock    *sock;          /**< TURN relay transport.      */
+        pj_bool_t        log_off;       /**< TURN loggin off?           */
+        unsigned         err_cnt;       /**< TURN disconnected count.   */
+    } turn[PJ_ICE_MAX_TURN];
 
     unsigned             cand_cnt;      /**< # of candidates/aliaes.    */
@@ -188 +199 @@
 
 
+/**
+ * This structure describe user data for STUN/TURN sockets of the
+ * ICE stream transport.
+ */
+typedef struct sock_user_data
+{
+    pj_ice_strans_comp      *comp;
+    pj_uint8_t               transport_id;
+
+} sock_user_data;
+
+
 /* Validate configuration */
 static pj_status_t pj_ice_strans_cfg_check_valid(const pj_ice_strans_cfg *cfg)
@@ -209 +232 @@
 
     pj_stun_config_init(&cfg->stun_cfg, NULL, 0, NULL, NULL);
-    pj_stun_sock_cfg_default(&cfg->stun.cfg);
-    pj_turn_alloc_param_default(&cfg->turn.alloc_param);
-    pj_turn_sock_cfg_default(&cfg->turn.cfg);
-
+    pj_ice_strans_stun_cfg_default(&cfg->stun);
+    pj_ice_strans_turn_cfg_default(&cfg->turn);
     pj_ice_sess_options_default(&cfg->opt);
+}
+
+
+/*
+ * Initialize ICE STUN transport configuration with default values.
+ */
+PJ_DEF(void) pj_ice_strans_stun_cfg_default(pj_ice_strans_stun_cfg *cfg)
+{
+    pj_bzero(cfg, sizeof(*cfg));
 
     cfg->af = pj_AF_INET();
-    cfg->stun.port = PJ_STUN_PORT;
-    cfg->turn.conn_type = PJ_TURN_TP_UDP;
-
-    cfg->stun.max_host_cands = 64;
-    cfg->stun.ignore_stun_error = PJ_FALSE;
+    cfg->port = PJ_STUN_PORT;
+    cfg->max_host_cands = 64;
+    cfg->ignore_stun_error = PJ_FALSE;
+    pj_stun_sock_cfg_default(&cfg->cfg);
+}
+
+
+/*
+ * Initialize ICE TURN transport configuration with default values.
+ */
+PJ_DEF(void) pj_ice_strans_turn_cfg_default(pj_ice_strans_turn_cfg *cfg)
+{
+    pj_bzero(cfg, sizeof(*cfg));
+
+    cfg->af = pj_AF_INET();
+    cfg->conn_type = PJ_TURN_TP_UDP;
+    pj_turn_alloc_param_default(&cfg->alloc_param);
+    pj_turn_sock_cfg_default(&cfg->cfg);
 }
 
@@ -231 +274 @@
                                      const pj_ice_strans_cfg *src)
 {
+    unsigned i;
+
     pj_memcpy(dst, src, sizeof(*src));
 
     if (src->stun.server.slen)
         pj_strdup(pool, &dst->stun.server, &src->stun.server);
+
+    for (i = 0; i < src->stun_tp_cnt; ++i) {
+        if (src->stun_tp[i].server.slen)
+            pj_strdup(pool, &dst->stun_tp[i].server,
+                      &src->stun_tp[i].server);
+    }
+
     if (src->turn.server.slen)
         pj_strdup(pool, &dst->turn.server, &src->turn.server);
-    pj_stun_auth_cred_dup(pool, &dst->turn.auth_cred,
-                          &src->turn.auth_cred);
+    pj_stun_auth_cred_dup(pool, &dst->turn.auth_cred, &src->turn.auth_cred);
+
+    for (i = 0; i < src->turn_tp_cnt; ++i) {
+        if (src->turn_tp[i].server.slen)
+            pj_strdup(pool, &dst->turn_tp[i].server,
+                      &src->turn_tp[i].server);
+        pj_stun_auth_cred_dup(pool, &dst->turn_tp[i].auth_cred,
+                              &src->turn_tp[i].auth_cred);
+    }
 }
 
@@ -246 +305 @@
  */
 static pj_status_t add_update_turn(pj_ice_strans *ice_st,
-                                   pj_ice_strans_comp *comp)
-{
+                                   pj_ice_strans_comp *comp,
+                                   unsigned idx)
+{
+    pj_ice_sess_cand *cand = NULL;
+    pj_ice_strans_turn_cfg *turn_cfg = &ice_st->cfg.turn_tp[idx];
+    pj_turn_sock_cfg *sock_cfg  = &turn_cfg->cfg;
+    unsigned comp_idx = comp->comp_id - 1;
     pj_turn_sock_cb turn_sock_cb;
-    pj_ice_sess_cand *cand = NULL;
+    sock_user_data *data;
     unsigned i;
+    pj_uint8_t tp_id;
     pj_status_t status;
 
+    /* Check if TURN transport is configured */
+    if (turn_cfg->server.slen == 0)
+        return PJ_SUCCESS;
+
     /* Find relayed candidate in the component */
+    tp_id = CREATE_TP_ID(TP_TURN, idx);
     for (i=0; i<comp->cand_cnt; ++i) {
-        if (comp->cand_list[i].type == PJ_ICE_CAND_TYPE_RELAYED) {
+        if (comp->cand_list[i].transport_id == tp_id) {
             cand = &comp->cand_list[i];
             break;
@@ -287 +357 @@
 
     /* Override with component specific QoS settings, if any */
-    if (ice_st->cfg.comp[comp->comp_id-1].qos_type) {
-        ice_st->cfg.turn.cfg.qos_type =
-            ice_st->cfg.comp[comp->comp_id-1].qos_type;
-    }
-    if (ice_st->cfg.comp[comp->comp_id-1].qos_params.flags) {
-        pj_memcpy(&ice_st->cfg.turn.cfg.qos_params,
-                  &ice_st->cfg.comp[comp->comp_id-1].qos_params,
-                  sizeof(ice_st->cfg.turn.cfg.qos_params));
-    }
+    if (ice_st->cfg.comp[comp_idx].qos_type)
+        sock_cfg->qos_type = ice_st->cfg.comp[comp_idx].qos_type;
+    if (ice_st->cfg.comp[comp_idx].qos_params.flags)
+        pj_memcpy(&sock_cfg->qos_params,
+                  &ice_st->cfg.comp[comp_idx].qos_params,
+                  sizeof(sock_cfg->qos_params));
 
     /* Override with component specific socket buffer size settings, if any */
-    if (ice_st->cfg.comp[comp->comp_id-1].so_rcvbuf_size > 0) {
-        ice_st->cfg.turn.cfg.so_rcvbuf_size =
-            ice_st->cfg.comp[comp->comp_id-1].so_rcvbuf_size;
-    }
-    if (ice_st->cfg.comp[comp->comp_id-1].so_sndbuf_size > 0) {
-        ice_st->cfg.turn.cfg.so_sndbuf_size =
-            ice_st->cfg.comp[comp->comp_id-1].so_sndbuf_size;
-    }
+    if (ice_st->cfg.comp[comp_idx].so_rcvbuf_size > 0)
+        sock_cfg->so_rcvbuf_size = ice_st->cfg.comp[comp_idx].so_rcvbuf_size;
+    if (ice_st->cfg.comp[comp_idx].so_sndbuf_size > 0)
+        sock_cfg->so_sndbuf_size = ice_st->cfg.comp[comp_idx].so_sndbuf_size;
+
+    /* Add relayed candidate with pending status if there's no existing one */
+    if (cand == NULL) {
+        cand = &comp->cand_list[comp->cand_cnt];
+        cand->type = PJ_ICE_CAND_TYPE_RELAYED;
+        cand->status = PJ_EPENDING;
+        cand->local_pref = RELAY_PREF;
+        cand->transport_id = CREATE_TP_ID(TP_TURN, idx);
+        cand->comp_id = (pj_uint8_t) comp->comp_id;
+    }
+
+    /* Allocate and initialize TURN socket data */
+    data = PJ_POOL_ZALLOC_T(ice_st->pool, sock_user_data);
+    data->comp = comp;
+    data->transport_id = cand->transport_id;
 
     /* Create the TURN transport */
-    status = pj_turn_sock_create(&ice_st->cfg.stun_cfg, ice_st->cfg.af,
-                                 ice_st->cfg.turn.conn_type,
-                                 &turn_sock_cb, &ice_st->cfg.turn.cfg,
-                                 comp, &comp->turn_sock);
+    status = pj_turn_sock_create(&ice_st->cfg.stun_cfg, turn_cfg->af,
+                                 turn_cfg->conn_type,
+                                 &turn_sock_cb, sock_cfg,
+                                 data, &comp->turn[idx].sock);
     if (status != PJ_SUCCESS) {
         return status;
@@ -320 +398 @@
 
     /* Start allocation */
-    status=pj_turn_sock_alloc(comp->turn_sock,
-                              &ice_st->cfg.turn.server,
-                              ice_st->cfg.turn.port,
+    status=pj_turn_sock_alloc(comp->turn[idx].sock,
+                              &turn_cfg->server,
+                              turn_cfg->port,
                               ice_st->cfg.resolver,
-                              &ice_st->cfg.turn.auth_cred,
-                              &ice_st->cfg.turn.alloc_param);
+                              &turn_cfg->auth_cred,
+                              &turn_cfg->alloc_param);
     if (status != PJ_SUCCESS) {
         ///sess_dec_ref(ice_st);
@@ -331 +409 @@
     }
 
-    /* Add relayed candidate with pending status if there's no existing one */
-    if (cand == NULL) {
-        cand = &comp->cand_list[comp->cand_cnt++];
-        cand->type = PJ_ICE_CAND_TYPE_RELAYED;
-        cand->status = PJ_EPENDING;
-        cand->local_pref = RELAY_PREF;
-        cand->transport_id = TP_TURN;
-        cand->comp_id = (pj_uint8_t) comp->comp_id;
-    }
+    /* Commit the relayed candidate. */
+    comp->cand_cnt++;
 
     PJ_LOG(4,(ice_st->obj_name,
@@ -373 +444 @@
 }
 
+
+static pj_status_t add_stun_and_host(pj_ice_strans *ice_st,
+                                     pj_ice_strans_comp *comp,
+                                     unsigned idx)
+{
+    pj_ice_sess_cand *cand;
+    pj_ice_strans_stun_cfg *stun_cfg = &ice_st->cfg.stun_tp[idx];
+    pj_stun_sock_cfg *sock_cfg  = &stun_cfg->cfg;
+    unsigned comp_idx = comp->comp_id - 1;
+    pj_stun_sock_cb stun_sock_cb;
+    sock_user_data *data;
+    pj_status_t status;
+
+    /* Check if STUN transport or host candidate is configured */
+    if (stun_cfg->server.slen == 0 && stun_cfg->max_host_cands == 0)
+        return PJ_SUCCESS;
+
+    /* Initialize STUN socket callback */
+    pj_bzero(&stun_sock_cb, sizeof(stun_sock_cb));
+    stun_sock_cb.on_rx_data = &stun_on_rx_data;
+    stun_sock_cb.on_status = &stun_on_status;
+    stun_sock_cb.on_data_sent = &stun_on_data_sent;
+
+    /* Override component specific QoS settings, if any */
+    if (ice_st->cfg.comp[comp_idx].qos_type) {
+        sock_cfg->qos_type = ice_st->cfg.comp[comp_idx].qos_type;
+    }
+    if (ice_st->cfg.comp[comp_idx].qos_params.flags) {
+        pj_memcpy(&sock_cfg->qos_params,
+                  &ice_st->cfg.comp[comp_idx].qos_params,
+                  sizeof(sock_cfg->qos_params));
+    }
+
+    /* Override component specific socket buffer size settings, if any */
+    if (ice_st->cfg.comp[comp_idx].so_rcvbuf_size > 0) {
+        sock_cfg->so_rcvbuf_size = ice_st->cfg.comp[comp_idx].so_rcvbuf_size;
+    }
+    if (ice_st->cfg.comp[comp_idx].so_sndbuf_size > 0) {
+        sock_cfg->so_sndbuf_size = ice_st->cfg.comp[comp_idx].so_sndbuf_size;
+    }
+
+    /* Prepare srflx candidate with pending status. */
+    cand = &comp->cand_list[comp->cand_cnt];
+    cand->type = PJ_ICE_CAND_TYPE_SRFLX;
+    cand->status = PJ_EPENDING;
+    cand->local_pref = SRFLX_PREF;
+    cand->transport_id = CREATE_TP_ID(TP_STUN, idx);
+    cand->comp_id = (pj_uint8_t) comp->comp_id;
+
+    /* Allocate and initialize STUN socket data */
+    data = PJ_POOL_ZALLOC_T(ice_st->pool, sock_user_data);
+    data->comp = comp;
+    data->transport_id = cand->transport_id;
+
+    /* Create the STUN transport */
+    status = pj_stun_sock_create(&ice_st->cfg.stun_cfg, NULL,
+                                 stun_cfg->af, &stun_sock_cb,
+                                 sock_cfg, data, &comp->stun[idx].sock);
+    if (status != PJ_SUCCESS)
+        return status;
+
+    /* Start STUN Binding resolution and add srflx candidate
+     * only if server is set
+     */
+    if (stun_cfg->server.slen) {
+        pj_stun_sock_info stun_sock_info;
+
+        /* Add pending job */
+        ///sess_add_ref(ice_st);
+
+        PJ_LOG(4,(ice_st->obj_name,
+                  "Comp %d: srflx candidate starts Binding discovery",
+                  comp->comp_id));
+
+        pj_log_push_indent();
+
+        /* Start Binding resolution */
+        status = pj_stun_sock_start(comp->stun[idx].sock, &stun_cfg->server,
+                                    stun_cfg->port, ice_st->cfg.resolver);
+        if (status != PJ_SUCCESS) {
+            ///sess_dec_ref(ice_st);
+            pj_log_pop_indent();
+            return status;
+        }
+
+        /* Enumerate addresses */
+        status = pj_stun_sock_get_info(comp->stun[idx].sock, &stun_sock_info);
+        if (status != PJ_SUCCESS) {
+            ///sess_dec_ref(ice_st);
+            pj_log_pop_indent();
+            return status;
+        }
+
+        /* Update and commit the srflx candidate. */
+        pj_sockaddr_cp(&cand->base_addr, &stun_sock_info.aliases[0]);
+        pj_sockaddr_cp(&cand->rel_addr, &cand->base_addr);
+        pj_ice_calc_foundation(ice_st->pool, &cand->foundation,
+                               cand->type, &cand->base_addr);
+        comp->cand_cnt++;
+
+        /* Set default candidate to srflx */
+        comp->default_cand = (unsigned)(cand - comp->cand_list);
+
+        pj_log_pop_indent();
+    }
+
+    /* Add local addresses to host candidates, unless max_host_cands
+     * is set to zero.
+     */
+    if (stun_cfg->max_host_cands) {
+        pj_stun_sock_info stun_sock_info;
+        unsigned i;
+
+        /* Enumerate addresses */
+        status = pj_stun_sock_get_info(comp->stun[idx].sock, &stun_sock_info);
+        if (status != PJ_SUCCESS)
+            return status;
+
+        for (i=0; i<stun_sock_info.alias_cnt &&
+                  i<stun_cfg->max_host_cands; ++i)
+        {
+            unsigned j;
+            pj_bool_t cand_duplicate = PJ_FALSE;
+            char addrinfo[PJ_INET6_ADDRSTRLEN+10];
+            const pj_sockaddr *addr = &stun_sock_info.aliases[i];
+
+            /* Leave one candidate for relay */
+            if (comp->cand_cnt >= PJ_ICE_ST_MAX_CAND-1) {
+                PJ_LOG(4,(ice_st->obj_name, "Too many host candidates"));
+                break;
+            }
+
+            /* Ignore loopback addresses if cfg->stun.loop_addr is unset */
+            if (stun_cfg->loop_addr==PJ_FALSE) {
+                if (stun_cfg->af == pj_AF_INET() && 
+                    (pj_ntohl(addr->ipv4.sin_addr.s_addr)>>24)==127)
+                {
+                    continue;
+                }
+                else if (stun_cfg->af == pj_AF_INET6()) {
+                    pj_in6_addr in6addr = {0};
+                    in6addr.s6_addr[15] = 1;
+                    if (pj_memcmp(&in6addr, &addr->ipv6.sin6_addr,
+                                  sizeof(in6addr))==0)
+                    {
+                        continue;
+                    }
+                }
+            }
+
+            cand = &comp->cand_list[comp->cand_cnt];
+
+            cand->type = PJ_ICE_CAND_TYPE_HOST;
+            cand->status = PJ_SUCCESS;
+            cand->local_pref = HOST_PREF;
+            cand->transport_id = CREATE_TP_ID(TP_STUN, idx);
+            cand->comp_id = (pj_uint8_t) comp->comp_id;
+            pj_sockaddr_cp(&cand->addr, addr);
+            pj_sockaddr_cp(&cand->base_addr, addr);
+            pj_bzero(&cand->rel_addr, sizeof(cand->rel_addr));
+            
+            /* Check if not already in list */
+            for (j=0; j<comp->cand_cnt; j++) {
+                if (ice_cand_equals(cand, &comp->cand_list[j])) {
+                    cand_duplicate = PJ_TRUE;
+                    break;
+                }
+            }
+
+            if (cand_duplicate) {
+                PJ_LOG(4, (ice_st->obj_name,
+                       "Comp %d: host candidate %s is a duplicate",
+                       comp->comp_id, pj_sockaddr_print(&cand->addr, addrinfo,
+                       sizeof(addrinfo), 3)));
+
+                pj_bzero(&cand->addr, sizeof(cand->addr));
+                pj_bzero(&cand->base_addr, sizeof(cand->base_addr));
+                continue;
+            } else {
+                comp->cand_cnt+=1;
+            }
+            
+            pj_ice_calc_foundation(ice_st->pool, &cand->foundation,
+                                   cand->type, &cand->base_addr);
+
+            PJ_LOG(4,(ice_st->obj_name,
+                      "Comp %d: host candidate %s added",
+                      comp->comp_id, pj_sockaddr_print(&cand->addr, addrinfo,
+                                                      sizeof(addrinfo), 3)));
+        }
+    }
+
+    return PJ_SUCCESS;
+}
+
+
 /*
  * Create the component.
@@ -379 +646 @@
 {
     pj_ice_strans_comp *comp = NULL;
+    unsigned i;
     pj_status_t status;
 
@@ -398 +666 @@
 
     /* Create STUN transport if configured */
-    if (ice_st->cfg.stun.server.slen || ice_st->cfg.stun.max_host_cands) {
-        pj_stun_sock_cb stun_sock_cb;
-        pj_ice_sess_cand *cand;
-
-        pj_bzero(&stun_sock_cb, sizeof(stun_sock_cb));
-        stun_sock_cb.on_rx_data = &stun_on_rx_data;
-        stun_sock_cb.on_status = &stun_on_status;
-        stun_sock_cb.on_data_sent = &stun_on_data_sent;
-
-        /* Override component specific QoS settings, if any */
-        if (ice_st->cfg.comp[comp_id-1].qos_type) {
-            ice_st->cfg.stun.cfg.qos_type =
-                ice_st->cfg.comp[comp_id-1].qos_type;
-        }
-        if (ice_st->cfg.comp[comp_id-1].qos_params.flags) {
-            pj_memcpy(&ice_st->cfg.stun.cfg.qos_params,
-                      &ice_st->cfg.comp[comp_id-1].qos_params,
-                      sizeof(ice_st->cfg.stun.cfg.qos_params));
-        }
-
-        /* Override component specific socket buffer size settings, if any */
-        if (ice_st->cfg.comp[comp_id-1].so_rcvbuf_size > 0) {
-            ice_st->cfg.stun.cfg.so_rcvbuf_size =
-                ice_st->cfg.comp[comp_id-1].so_rcvbuf_size;
-        }
-        if (ice_st->cfg.comp[comp_id-1].so_sndbuf_size > 0) {
-            ice_st->cfg.stun.cfg.so_sndbuf_size =
-                ice_st->cfg.comp[comp_id-1].so_sndbuf_size;
-        }
-
-        /* Create the STUN transport */
-        status = pj_stun_sock_create(&ice_st->cfg.stun_cfg, NULL,
-                                     ice_st->cfg.af, &stun_sock_cb,
-                                     &ice_st->cfg.stun.cfg,
-                                     comp, &comp->stun_sock);
+    for (i=0; i<ice_st->cfg.stun_tp_cnt; ++i) {
+        status = add_stun_and_host(ice_st, comp, i);
         if (status != PJ_SUCCESS)
             return status;
-
-        /* Start STUN Binding resolution and add srflx candidate
-         * only if server is set
-         */
-        if (ice_st->cfg.stun.server.slen) {
-            pj_stun_sock_info stun_sock_info;
-
-            /* Add pending job */
-            ///sess_add_ref(ice_st);
-
-            PJ_LOG(4,(ice_st->obj_name,
-                      "Comp %d: srflx candidate starts Binding discovery",
-                      comp_id));
-
-            pj_log_push_indent();
-
-            /* Start Binding resolution */
-            status = pj_stun_sock_start(comp->stun_sock,
-                                        &ice_st->cfg.stun.server,
-                                        ice_st->cfg.stun.port,
-                                        ice_st->cfg.resolver);
-            if (status != PJ_SUCCESS) {
-                ///sess_dec_ref(ice_st);
-                pj_log_pop_indent();
-                return status;
-            }
-
-            /* Enumerate addresses */
-            status = pj_stun_sock_get_info(comp->stun_sock, &stun_sock_info);
-            if (status != PJ_SUCCESS) {
-                ///sess_dec_ref(ice_st);
-                pj_log_pop_indent();
-                return status;
-            }
-
-            /* Add srflx candidate with pending status. */
-            cand = &comp->cand_list[comp->cand_cnt++];
-            cand->type = PJ_ICE_CAND_TYPE_SRFLX;
-            cand->status = PJ_EPENDING;
-            cand->local_pref = SRFLX_PREF;
-            cand->transport_id = TP_STUN;
-            cand->comp_id = (pj_uint8_t) comp_id;
-            pj_sockaddr_cp(&cand->base_addr, &stun_sock_info.aliases[0]);
-            pj_sockaddr_cp(&cand->rel_addr, &cand->base_addr);
-            pj_ice_calc_foundation(ice_st->pool, &cand->foundation,
-                                   cand->type, &cand->base_addr);
-
-            /* Set default candidate to srflx */
-            comp->default_cand = (unsigned)(cand - comp->cand_list);
-
-            pj_log_pop_indent();
-        }
-
-        /* Add local addresses to host candidates, unless max_host_cands
-         * is set to zero.
-         */
-        if (ice_st->cfg.stun.max_host_cands) {
-            pj_stun_sock_info stun_sock_info;
-            unsigned i;
-
-            /* Enumerate addresses */
-            status = pj_stun_sock_get_info(comp->stun_sock, &stun_sock_info);
-            if (status != PJ_SUCCESS)
-                return status;
-
-            for (i=0; i<stun_sock_info.alias_cnt &&
-                      i<ice_st->cfg.stun.max_host_cands; ++i)
-            {
-                unsigned j;
-                pj_bool_t cand_duplicate = PJ_FALSE;
-                char addrinfo[PJ_INET6_ADDRSTRLEN+10];
-                const pj_sockaddr *addr = &stun_sock_info.aliases[i];
-
-                /* Leave one candidate for relay */
-                if (comp->cand_cnt >= PJ_ICE_ST_MAX_CAND-1) {
-                    PJ_LOG(4,(ice_st->obj_name, "Too many host candidates"));
-                    break;
-                }
-
-                /* Ignore loopback addresses unless cfg->stun.loop_addr
-                 * is set
-                 */
-                if ((pj_ntohl(addr->ipv4.sin_addr.s_addr)>>24)==127) {
-                    if (ice_st->cfg.stun.loop_addr==PJ_FALSE)
-                        continue;
-                }
-
-                cand = &comp->cand_list[comp->cand_cnt];
-
-                cand->type = PJ_ICE_CAND_TYPE_HOST;
-                cand->status = PJ_SUCCESS;
-                cand->local_pref = HOST_PREF;
-                cand->transport_id = TP_STUN;
-                cand->comp_id = (pj_uint8_t) comp_id;
-                pj_sockaddr_cp(&cand->addr, addr);
-                pj_sockaddr_cp(&cand->base_addr, addr);
-                pj_bzero(&cand->rel_addr, sizeof(cand->rel_addr));
-            
-                /* Check if not already in list */
-                for (j=0; j<comp->cand_cnt; j++) {
-                    if (ice_cand_equals(cand, &comp->cand_list[j])) {
-                        cand_duplicate = PJ_TRUE;
-                        break;
-                    }
-                }
-
-                if (cand_duplicate) {
-                    PJ_LOG(4, (ice_st->obj_name,
-                           "Comp %d: host candidate %s is a duplicate",
-                           comp_id, pj_sockaddr_print(&cand->addr, addrinfo,
-                           sizeof(addrinfo), 3)));
-
-                    pj_bzero(&cand->addr, sizeof(cand->addr));
-                    pj_bzero(&cand->base_addr, sizeof(cand->base_addr));
-                    continue;
-                } else {
-                    comp->cand_cnt+=1;
-                }
-            
-                pj_ice_calc_foundation(ice_st->pool, &cand->foundation,
-                                       cand->type, &cand->base_addr);
-
-                PJ_LOG(4,(ice_st->obj_name,
-                          "Comp %d: host candidate %s added",
-                          comp_id, pj_sockaddr_print(&cand->addr, addrinfo,
-                                                     sizeof(addrinfo), 3)));
-            }
-        }
     }
 
     /* Create TURN relay if configured. */
-    if (ice_st->cfg.turn.server.slen) {
-        add_update_turn(ice_st, comp);
+    for (i=0; i<ice_st->cfg.turn_tp_cnt; ++i) {
+        status = add_update_turn(ice_st, comp, i);
+        if (status != PJ_SUCCESS)
+            return status;
     }
 
@@ -630 +739 @@
 
     pj_ice_strans_cfg_copy(pool, &ice_st->cfg, cfg);
-    ice_st->cfg.stun.cfg.grp_lock = ice_st->grp_lock;
-    ice_st->cfg.turn.cfg.grp_lock = ice_st->grp_lock;
+
+    /* To maintain backward compatibility, check if old/deprecated setting is set
+     * and the new setting is not, copy the value to the new setting.
+     */
+    if (cfg->stun_tp_cnt == 0 && 
+        (cfg->stun.server.slen || cfg->stun.max_host_cands))
+    {
+        ice_st->cfg.stun_tp_cnt = 1;
+        ice_st->cfg.stun_tp[0] = ice_st->cfg.stun;
+    }
+    if (cfg->turn_tp_cnt == 0 && cfg->turn.server.slen) {
+        ice_st->cfg.turn_tp_cnt = 1;
+        ice_st->cfg.turn_tp[0] = ice_st->cfg.turn;
+    }
+
+    for (i=0; i<ice_st->cfg.stun_tp_cnt; ++i)
+        ice_st->cfg.stun_tp[i].cfg.grp_lock = ice_st->grp_lock;
+    for (i=0; i<ice_st->cfg.turn_tp_cnt; ++i)
+        ice_st->cfg.turn_tp[i].cfg.grp_lock = ice_st->grp_lock;
     pj_memcpy(&ice_st->cb, cb, sizeof(*cb));
 
@@ -709 +835 @@
     for (i=0; i<ice_st->comp_cnt; ++i) {
         if (ice_st->comp[i]) {
-            if (ice_st->comp[i]->stun_sock) {
-                pj_stun_sock_destroy(ice_st->comp[i]->stun_sock);
-                ice_st->comp[i]->stun_sock = NULL;
+            pj_ice_strans_comp *comp = ice_st->comp[i];
+            unsigned j;
+            for (j = 0; j < ice_st->cfg.stun_tp_cnt; ++j) {
+                if (comp->stun[j].sock) {
+                    pj_stun_sock_destroy(comp->stun[j].sock);
+                    comp->stun[j].sock = NULL;
+                }
             }
-            if (ice_st->comp[i]->turn_sock) {
-                pj_turn_sock_destroy(ice_st->comp[i]->turn_sock);
-                ice_st->comp[i]->turn_sock = NULL;
+            for (j = 0; j < ice_st->cfg.turn_tp_cnt; ++j) {
+                if (comp->turn[j].sock) {
+                    pj_turn_sock_destroy(comp->turn[j].sock);
+                    comp->turn[j].sock = NULL;
+                }
             }
         }
@@ -912 +1044 @@
 
         /* Re-enable logging for Send/Data indications */
-        if (comp->turn_sock) {
+        if (ice_st->cfg.turn_tp_cnt) {
             PJ_LOG(5,(ice_st->obj_name,
-                      "Disabling STUN Indication logging for "
+                      "Enabling STUN Indication logging for "
                       "component %d", i+1));
-            pj_turn_sock_set_log(comp->turn_sock, 0xFFFF);
-            comp->turn_log_off = PJ_FALSE;
+        }
+        for (j = 0; j < ice_st->cfg.turn_tp_cnt; ++j) {
+            if (comp->turn[j].sock) {
+                pj_turn_sock_set_log(comp->turn[j].sock, 0xFFFF);
+                comp->turn[j].log_off = PJ_FALSE;
+            }
         }
 
@@ -1123 +1259 @@
                                              const pj_ice_sess_cand rem_cand[])
 {
+    unsigned n;
     pj_status_t status;
 
@@ -1138 +1275 @@
 
     /* If we have TURN candidate, now is the time to create the permissions */
-    if (ice_st->comp[0]->turn_sock) {
+    for (n = 0; n < ice_st->cfg.turn_tp_cnt; ++n) {
         unsigned i;
 
@@ -1148 +1285 @@
             /* Gather remote addresses for this component */
             for (j=0; j<rem_cand_cnt && count<PJ_ARRAY_SIZE(addrs); ++j) {
-                if (rem_cand[j].comp_id==i+1) {
-                    pj_memcpy(&addrs[count++], &rem_cand[j].addr,
-                              pj_sockaddr_get_len(&rem_cand[j].addr));
+                if (rem_cand[j].comp_id==i+1 &&
+                    rem_cand[j].addr.addr.sa_family==
+                    ice_st->cfg.turn_tp[n].af)
+                {
+                    pj_sockaddr_cp(&addrs[count++], &rem_cand[j].addr);
                 }
             }
 
             if (count) {
-                status = pj_turn_sock_set_perm(comp->turn_sock, count,
+                status = pj_turn_sock_set_perm(comp->turn[n].sock, count,
                                                addrs, 0);
                 if (status != PJ_SUCCESS) {
@@ -1228 +1367 @@
 {
     pj_ice_strans_comp *comp;
-    unsigned def_cand;
+    pj_ice_sess_cand *def_cand;
     pj_status_t status;
 
@@ -1237 +1376 @@
 
     /* Check that default candidate for the component exists */
-    def_cand = comp->default_cand;
-    if (def_cand >= comp->cand_cnt)
+    if (comp->default_cand >= comp->cand_cnt)
         return PJ_EINVALIDOP;
 
@@ -1262 +1400 @@
     
     pj_grp_lock_release(ice_st->grp_lock);
+
+    def_cand = &comp->cand_list[comp->default_cand];
     
-    if (comp->cand_list[def_cand].status == PJ_SUCCESS) {
-
-        if (comp->cand_list[def_cand].type == PJ_ICE_CAND_TYPE_RELAYED) {
+    if (def_cand->status == PJ_SUCCESS) {
+        unsigned tp_idx = GET_TP_IDX(def_cand->transport_id);
+
+        if (def_cand->type == PJ_ICE_CAND_TYPE_RELAYED) {
 
             enum {
@@ -1274 +1415 @@
 
             /* https://trac.pjsip.org/repos/ticket/1316 */
-            if (comp->turn_sock == NULL) {
+            if (comp->turn[tp_idx].sock == NULL) {
                 /* TURN socket error */
                 return PJ_EINVALIDOP;
             }
 
-            if (!comp->turn_log_off) {
+            if (!comp->turn[tp_idx].log_off) {
                 /* Disable logging for Send/Data indications */
                 PJ_LOG(5,(ice_st->obj_name,
                           "Disabling STUN Indication logging for "
                           "component %d", comp->comp_id));
-                pj_turn_sock_set_log(comp->turn_sock, msg_disable_ind);
-                comp->turn_log_off = PJ_TRUE;
+                pj_turn_sock_set_log(comp->turn[tp_idx].sock,
+                                     msg_disable_ind);
+                comp->turn[tp_idx].log_off = PJ_TRUE;
             }
 
-            status = pj_turn_sock_sendto(comp->turn_sock,
+            status = pj_turn_sock_sendto(comp->turn[tp_idx].sock,
                                          (const pj_uint8_t*)data,
                                          (unsigned)data_len,
@@ -1295 +1437 @@
                     PJ_SUCCESS : status;
         } else {
-            status = pj_stun_sock_sendto(comp->stun_sock, NULL, data,
+            status = pj_stun_sock_sendto(comp->stun[tp_idx].sock, NULL, data,
                                          (unsigned)data_len, 0, dst_addr,
                                          dst_addr_len);
@@ -1343 +1485 @@
             for (i=0; i<ice_st->comp_cnt; ++i) {
                 const pj_ice_sess_check *check;
+                pj_ice_strans_comp *comp = ice_st->comp[i];
 
                 check = pj_ice_strans_get_valid_pair(ice_st, i+1);
@@ -1348 +1491 @@
                     char lip[PJ_INET6_ADDRSTRLEN+10];
                     char rip[PJ_INET6_ADDRSTRLEN+10];
+                    unsigned tp_idx = GET_TP_IDX(check->lcand->transport_id);
+                    unsigned tp_typ = GET_TP_TYPE(check->lcand->transport_id);
 
                     pj_sockaddr_print(&check->lcand->addr, lip,
@@ -1354 +1499 @@
                                       sizeof(rip), 3);
 
-                    if (check->lcand->transport_id == TP_TURN) {
+                    if (tp_typ == TP_TURN) {
                         /* Activate channel binding for the remote address
                          * for more efficient data transfer using TURN.
                          */
                         status = pj_turn_sock_bind_channel(
-                                        ice_st->comp[i]->turn_sock,
+                                        comp->turn[tp_idx].sock,
                                         &check->rcand->addr,
                                         sizeof(check->rcand->addr));
@@ -1367 +1512 @@
                                   "Disabling STUN Indication logging for "
                                   "component %d", i+1));
-                        pj_turn_sock_set_log(ice_st->comp[i]->turn_sock,
+                        pj_turn_sock_set_log(comp->turn[tp_idx].sock,
                                              msg_disable_ind);
-                        ice_st->comp[i]->turn_log_off = PJ_TRUE;
+                        comp->turn[tp_idx].log_off = PJ_TRUE;
                     }
 
@@ -1417 +1562 @@
     char daddr[PJ_INET6_ADDRSTRLEN];
 #endif
+    unsigned tp_idx = GET_TP_IDX(transport_id);
+    unsigned tp_typ = GET_TP_TYPE(transport_id);
 
     PJ_ASSERT_RETURN(comp_id && comp_id <= ice_st->comp_cnt, PJ_EINVAL);
@@ -1427 +1574 @@
                pj_sockaddr_print(dst_addr, daddr, sizeof(addr), 0),
                pj_sockaddr_get_port(dst_addr),
-               transport_id));
-
-    if (transport_id == TP_TURN) {
-        if (comp->turn_sock) {
-            status = pj_turn_sock_sendto(comp->turn_sock,
+               tp_typ));
+
+    if (tp_typ == TP_TURN) {
+        if (comp->turn[tp_idx].sock) {
+            status = pj_turn_sock_sendto(comp->turn[tp_idx].sock,
                                          (const pj_uint8_t*)pkt,
                                          (unsigned)size,
@@ -1438 +1585 @@
             status = PJ_EINVALIDOP;
         }
-    } else if (transport_id == TP_STUN) {
-        status = pj_stun_sock_sendto(comp->stun_sock, NULL,
+    } else if (tp_typ == TP_STUN) {
+        status = pj_stun_sock_sendto(comp->stun[tp_idx].sock, NULL,
                                      pkt, (unsigned)size, 0,
                                      dst_addr, dst_addr_len);
@@ -1479 +1626 @@
                                  unsigned addr_len)
 {
+    sock_user_data *data;
     pj_ice_strans_comp *comp;
     pj_ice_strans *ice_st;
     pj_status_t status;
 
-    comp = (pj_ice_strans_comp*) pj_stun_sock_get_user_data(stun_sock);
-    if (comp == NULL) {
+    data = (sock_user_data*) pj_stun_sock_get_user_data(stun_sock);
+    if (data == NULL) {
         /* We have disassociated ourselves from the STUN socket */
         return PJ_FALSE;
     }
 
+    comp = data->comp;
     ice_st = comp->ice_st;
 
@@ -1507 +1656 @@
         /* Hand over the packet to ICE session */
         status = pj_ice_sess_on_rx_pkt(comp->ice_st->ice, comp->comp_id,
-                                       TP_STUN, pkt, pkt_len,
+                                       data->transport_id,
+                                       pkt, pkt_len,
                                        src_addr, addr_len);
 
@@ -1537 +1687 @@
                                 pj_status_t status)
 {
+    sock_user_data *data;
     pj_ice_strans_comp *comp;
     pj_ice_strans *ice_st;
     pj_ice_sess_cand *cand = NULL;
     unsigned i;
+    int tp_idx;
 
     pj_assert(status != PJ_EPENDING);
 
-    comp = (pj_ice_strans_comp*) pj_stun_sock_get_user_data(stun_sock);
+    data = (sock_user_data*) pj_stun_sock_get_user_data(stun_sock);
+    comp = data->comp;
     ice_st = comp->ice_st;
 
@@ -1554 +1707 @@
     /* Find the srflx cancidate */
     for (i=0; i<comp->cand_cnt; ++i) {
-        if (comp->cand_list[i].type == PJ_ICE_CAND_TYPE_SRFLX) {
+        if (comp->cand_list[i].type == PJ_ICE_CAND_TYPE_SRFLX &&
+            comp->cand_list[i].transport_id == data->transport_id)
+        {
             cand = &comp->cand_list[i];
             break;
@@ -1570 +1725 @@
     }
 
+    tp_idx = GET_TP_IDX(data->transport_id);
+
     switch (op) {
     case PJ_STUN_SOCK_DNS_OP:
@@ -1576 +1733 @@
             if (cand)
                 cand->status = status;
-            if (!ice_st->cfg.stun.ignore_stun_error) {
+            if (!ice_st->cfg.stun_tp[tp_idx].ignore_stun_error) {
                 sess_fail(ice_st, PJ_ICE_STRANS_OP_INIT,
                           "DNS resolution failed", status);
@@ -1656 +1813 @@
             if (cand)
                 cand->status = status;
-            if (!ice_st->cfg.stun.ignore_stun_error || comp->cand_cnt==1) {
+            if (!ice_st->cfg.stun_tp[tp_idx].ignore_stun_error ||
+                comp->cand_cnt==1)
+            {
                 sess_fail(ice_st, PJ_ICE_STRANS_OP_INIT,
                           "STUN binding request failed", status);
@@ -1681 +1840 @@
             pj_assert(cand != NULL);
             cand->status = status;
-            if (!ice_st->cfg.stun.ignore_stun_error) {
+            if (!ice_st->cfg.stun_tp[tp_idx].ignore_stun_error) {
                 sess_fail(ice_st, PJ_ICE_STRANS_OP_INIT,
                           "STUN keep-alive failed", status);
@@ -1702 +1861 @@
 {
     pj_ice_strans_comp *comp;
+    sock_user_data *data;
     pj_status_t status;
 
-    comp = (pj_ice_strans_comp*) pj_turn_sock_get_user_data(turn_sock);
-    if (comp == NULL) {
+    data = (sock_user_data*) pj_turn_sock_get_user_data(turn_sock);
+    if (data == NULL) {
         /* We have disassociated ourselves from the TURN socket */
         return;
     }
+
+    comp = data->comp;
 
     pj_grp_lock_add_ref(comp->ice_st->grp_lock);
@@ -1727 +1889 @@
         /* Hand over the packet to ICE */
         status = pj_ice_sess_on_rx_pkt(comp->ice_st->ice, comp->comp_id,
-                                       TP_TURN, pkt, pkt_len,
+                                       data->transport_id, pkt, pkt_len,
                                        peer_addr, addr_len);
 
@@ -1746 +1908 @@
 {
     pj_ice_strans_comp *comp;
-
-    comp = (pj_ice_strans_comp*) pj_turn_sock_get_user_data(turn_sock);
-    if (comp == NULL) {
+    sock_user_data *data;
+    int tp_idx;
+
+    data = (sock_user_data*) pj_turn_sock_get_user_data(turn_sock);
+    if (data == NULL) {
         /* Not interested in further state notification once the relay is
          * disconnecting.
@@ -1754 +1918 @@
         return;
     }
+
+    comp = data->comp;
+    tp_idx = GET_TP_IDX(data->transport_id);
 
     PJ_LOG(5,(comp->ice_st->obj_name, "TURN client state changed %s --> %s",
@@ -1767 +1934 @@
         unsigned i;
 
-        comp->turn_err_cnt = 0;
+        comp->turn[tp_idx].err_cnt = 0;
 
         /* Get allocation info */
@@ -1777 +1944 @@
         /* Find relayed candidate in the component */
         for (i=0; i<comp->cand_cnt; ++i) {
-            if (comp->cand_list[i].type == PJ_ICE_CAND_TYPE_RELAYED) {
+            if (comp->cand_list[i].type == PJ_ICE_CAND_TYPE_RELAYED &&
+                comp->cand_list[i].transport_id == data->transport_id)
+            {
                 cand = &comp->cand_list[i];
                 break;
@@ -1809 +1978 @@
         pj_turn_session_info info;
 
-        ++comp->turn_err_cnt;
+        ++comp->turn[tp_idx].err_cnt;
 
         pj_turn_sock_get_info(turn_sock, &info);
@@ -1815 +1984 @@
         /* Unregister ourself from the TURN relay */
         pj_turn_sock_set_user_data(turn_sock, NULL);
-        comp->turn_sock = NULL;
+        comp->turn[tp_idx].sock = NULL;
 
         /* Set session to fail on error. last_status PJ_SUCCESS means normal
@@ -1825 +1994 @@
                 sess_fail(comp->ice_st, PJ_ICE_STRANS_OP_INIT,
                           "TURN allocation failed", info.last_status);
-            } else if (comp->turn_err_cnt > 1) {
+            } else if (comp->turn[tp_idx].err_cnt > 1) {
                 sess_fail(comp->ice_st, PJ_ICE_STRANS_OP_KEEP_ALIVE,
                           "TURN refresh failed", info.last_status);
@@ -1832 +2001 @@
                           "Comp %d: TURN allocation failed, retrying",
                           comp->comp_id));
-                add_update_turn(comp->ice_st, comp);
+                add_update_turn(comp->ice_st, comp, tp_idx);
             }
         }