]> sjero.net Git - linphone/blobdiff - coreapi/offeranswer.c
Aac-eld add missing header according to RFC3640 3.3.6
[linphone] / coreapi / offeranswer.c
index 4b41f4ca330fbbf5f66b6fe3751f3b824414936b..9823c24a69f12f6b448d4b687d85436249c9fdb7 100644 (file)
@@ -19,6 +19,7 @@ Foundation, Inc., 59 Temple Place - Suite 330, Boston, MA  02111-1307, USA.
 
 #include "sal.h"
 #include "offeranswer.h"
+#include "private.h"
 
 static bool_t only_telephone_event(const MSList *l){
        for(;l!=NULL;l=l->next){
@@ -205,25 +206,27 @@ static SalStreamDir compute_dir_incoming(SalStreamDir local, SalStreamDir offere
 static void initiate_outgoing(const SalStreamDescription *local_offer,
                                        const SalStreamDescription *remote_answer,
                                        SalStreamDescription *result){
-       if (remote_answer->port!=0)
+       if (remote_answer->rtp_port!=0)
                result->payloads=match_payloads(local_offer->payloads,remote_answer->payloads,TRUE,FALSE);
        result->proto=remote_answer->proto;
        result->type=local_offer->type;
        result->dir=compute_dir_outgoing(local_offer->dir,remote_answer->dir);
 
        if (result->payloads && !only_telephone_event(result->payloads)){
-               strcpy(result->addr,remote_answer->addr);
-               result->port=remote_answer->port;
+               strcpy(result->rtp_addr,remote_answer->rtp_addr);
+               strcpy(result->rtcp_addr,remote_answer->rtcp_addr);
+               result->rtp_port=remote_answer->rtp_port;
+               result->rtcp_port=remote_answer->rtcp_port;
                result->bandwidth=remote_answer->bandwidth;
                result->ptime=remote_answer->ptime;
        }else{
-               result->port=0;
+               result->rtp_port=0;
        }
        if (result->proto == SalProtoRtpSavp) {
                /* verify crypto algo */
                memset(result->crypto, 0, sizeof(result->crypto));
                if (!match_crypto_algo(local_offer->crypto, remote_answer->crypto, &result->crypto[0], &result->crypto_local_tag, FALSE))
-                       result->port = 0;
+                       result->rtp_port = 0;
        }
 }
 
@@ -235,22 +238,29 @@ static void initiate_incoming(const SalStreamDescription *local_cap,
        result->proto=remote_offer->proto;
        result->type=local_cap->type;
        result->dir=compute_dir_incoming(local_cap->dir,remote_offer->dir);
-       if (result->payloads && !only_telephone_event(result->payloads) && (remote_offer->port!=0 || remote_offer->port==SalStreamSendOnly)){
-               strcpy(result->addr,local_cap->addr);
-               memcpy(result->candidates,local_cap->candidates,sizeof(result->candidates));
-               result->port=local_cap->port;
+       if (result->payloads && !only_telephone_event(result->payloads) && (remote_offer->rtp_port!=0 || remote_offer->rtp_port==SalStreamSendOnly)){
+               strcpy(result->rtp_addr,local_cap->rtp_addr);
+               strcpy(result->rtcp_addr,local_cap->rtcp_addr);
+               result->rtp_port=local_cap->rtp_port;
+               result->rtcp_port=local_cap->rtcp_port;
                result->bandwidth=local_cap->bandwidth;
-               result->ptime=local_cap->ptime; 
+               result->ptime=local_cap->ptime;
        }else{
-               result->port=0;
+               result->rtp_port=0;
        }
        if (result->proto == SalProtoRtpSavp) {
                /* select crypto algo */
                memset(result->crypto, 0, sizeof(result->crypto));
                if (!match_crypto_algo(local_cap->crypto, remote_offer->crypto, &result->crypto[0], &result->crypto_local_tag, TRUE))
-                       result->port = 0; 
+                       result->rtp_port = 0;
                
        }
+       strcpy(result->ice_pwd, local_cap->ice_pwd);
+       strcpy(result->ice_ufrag, local_cap->ice_ufrag);
+       result->ice_mismatch = local_cap->ice_mismatch;
+       result->ice_completed = local_cap->ice_completed;
+       memcpy(result->ice_candidates, local_cap->ice_candidates, sizeof(result->ice_candidates));
+       memcpy(result->ice_remote_candidates, local_cap->ice_remote_candidates, sizeof(result->ice_remote_candidates));
 }
 
 /**
@@ -258,22 +268,23 @@ static void initiate_incoming(const SalStreamDescription *local_cap,
  * and the returned response (remote).
 **/
 int offer_answer_initiate_outgoing(const SalMediaDescription *local_offer,
-                                                                       const SalMediaDescription *remote_answer,
-                                                       SalMediaDescription *result){
-       int i,j;
-    
+                                       const SalMediaDescription *remote_answer,
+                                       SalMediaDescription *result){
+       int i,j;
+
        const SalStreamDescription *ls,*rs;
-       for(i=0,j=0;i<local_offer->nstreams;++i){
+       for(i=0,j=0;i<local_offer->n_total_streams;++i){
                ms_message("Processing for stream %i",i);
                ls=&local_offer->streams[i];
                rs=sal_media_description_find_stream((SalMediaDescription*)remote_answer,ls->proto,ls->type);
-       if (rs) {
+               if (rs) {
                        initiate_outgoing(ls,rs,&result->streams[j]);
                        ++j;
                }
                else ms_warning("No matching stream for %i",i);
        }
-       result->nstreams=j;
+       result->n_active_streams=j;
+       result->n_total_streams=local_offer->n_total_streams;
        result->bandwidth=remote_answer->bandwidth;
        strcpy(result->addr,remote_answer->addr);
        return 0;
@@ -285,12 +296,13 @@ int offer_answer_initiate_outgoing(const SalMediaDescription *local_offer,
  * The returned media description is an answer and should be sent to the offerer.
 **/
 int offer_answer_initiate_incoming(const SalMediaDescription *local_capabilities,
-                                               const SalMediaDescription *remote_offer,
-                                       SalMediaDescription *result, bool_t one_matching_codec){
+                                       const SalMediaDescription *remote_offer,
+                                       SalMediaDescription *result, bool_t one_matching_codec){
        int i;
        const SalStreamDescription *ls=NULL,*rs;
-                                                       
-       for(i=0;i<remote_offer->nstreams;++i){
+
+       result->n_active_streams=0;
+       for(i=0;i<remote_offer->n_total_streams;++i){
                rs=&remote_offer->streams[i];
                if (rs->proto!=SalProtoUnknown){
                        ls=sal_media_description_find_stream((SalMediaDescription*)local_capabilities,rs->proto,rs->type);
@@ -301,11 +313,11 @@ int offer_answer_initiate_incoming(const SalMediaDescription *local_capabilities
                }else ms_warning("Unknown protocol for mline %i, declining",i);
                if (ls){
                        initiate_incoming(ls,rs,&result->streams[i],one_matching_codec);
-               }
-               else {
-                       /* create an inactive stream for the answer, as there where no matching stream a local capability */
+                       if (result->streams[i].rtp_port!=0) result->n_active_streams++;
+               }else {
+                       /* create an inactive stream for the answer, as there where no matching stream in local capabilities */
                        result->streams[i].dir=SalStreamInactive;
-                       result->streams[i].port=0;
+                       result->streams[i].rtp_port=0;
                        result->streams[i].type=rs->type;
                        result->streams[i].proto=rs->proto;
                        if (rs->type==SalOther){
@@ -313,11 +325,15 @@ int offer_answer_initiate_incoming(const SalMediaDescription *local_capabilities
                        }
                }
        }
-       result->nstreams=i;
+       result->n_total_streams=i;
        strcpy(result->username, local_capabilities->username);
        strcpy(result->addr,local_capabilities->addr);
        result->bandwidth=local_capabilities->bandwidth;
        result->session_ver=local_capabilities->session_ver;
        result->session_id=local_capabilities->session_id;
+       strcpy(result->ice_pwd, local_capabilities->ice_pwd);
+       strcpy(result->ice_ufrag, local_capabilities->ice_ufrag);
+       result->ice_lite = local_capabilities->ice_lite;
+       result->ice_completed = local_capabilities->ice_completed;
        return 0;
 }