]> sjero.net Git - linphone/blob - coreapi/misc.c
Merge branch 'master' of git.linphone.org:linphone into dev_edge_optim
[linphone] / coreapi / misc.c
1
2 /*
3 linphone
4 Copyright (C) 2000  Simon MORLAT (simon.morlat@linphone.org)
5
6 This program is free software; you can redistribute it and/or
7 modify it under the terms of the GNU General Public License
8 as published by the Free Software Foundation; either version 2
9 of the License, or (at your option) any later version.
10
11 This program is distributed in the hope that it will be useful,
12 but WITHOUT ANY WARRANTY; without even the implied warranty of
13 MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
14 GNU General Public License for more details.
15
16 You should have received a copy of the GNU General Public License
17 along with this program; if not, write to the Free Software
18 Foundation, Inc., 59 Temple Place - Suite 330, Boston, MA  02111-1307, USA.
19 */
20
21 #include "private.h"
22 #include "lpconfig.h"
23 #include "mediastreamer2/mediastream.h"
24 #include <stdlib.h>
25 #include <stdio.h>
26 #ifdef HAVE_SIGHANDLER_T
27 #include <signal.h>
28 #endif /*HAVE_SIGHANDLER_T*/
29
30 #include <string.h>
31 #if !defined(_WIN32_WCE)
32 #include <errno.h>
33 #include <sys/types.h>
34 #include <sys/stat.h>
35 #include <unistd.h>
36 #include <fcntl.h>
37 #endif /*_WIN32_WCE*/
38
39 #undef snprintf
40 #include <ortp/stun.h>
41
42 #ifdef HAVE_GETIFADDRS
43 #include <net/if.h>
44 #include <ifaddrs.h>
45 #endif
46
47
48 #if !defined(WIN32)
49
50 static char lock_name[80];
51 static char lock_set=0;
52 /* put a lock file in /tmp. this is called when linphone runs as a daemon*/
53 int set_lock_file()
54 {
55         FILE *lockfile;
56
57         snprintf(lock_name,80,"/tmp/linphone.%i",getuid());
58         lockfile=fopen(lock_name,"w");
59         if (lockfile==NULL)
60         {
61                 printf("Failed to create lock file.\n");
62                 return(-1);
63         }
64         fprintf(lockfile,"%i",getpid());
65         fclose(lockfile);
66         lock_set=1;
67         return(0);
68 }
69
70 /* looks if there is a lock file. If presents return its content (the pid of the already running linphone), if not found, returns -1*/
71 int get_lock_file()
72 {
73         int pid;
74         FILE *lockfile;
75
76         snprintf(lock_name,80,"/tmp/linphone.%i",getuid());
77         lockfile=fopen(lock_name,"r");
78         if (lockfile==NULL)
79                 return(-1);
80         if (fscanf(lockfile,"%i",&pid)!=1){
81                 ms_warning("Could not read pid in lock file.");
82                 fclose(lockfile);
83                 return -1;
84         }
85         fclose(lockfile);
86         return pid;
87 }
88
89 /* remove the lock file if it was set*/
90 int remove_lock_file()
91 {
92         int err=0;
93         if (lock_set)
94         {
95                 err=unlink(lock_name);
96                 lock_set=0;
97         }
98         return(err);
99 }
100
101 #endif
102
103 char *int2str(int number)
104 {
105         char *numstr=ms_malloc(10);
106         snprintf(numstr,10,"%i",number);
107         return numstr;
108 }
109
110 void check_sound_device(LinphoneCore *lc)
111 {
112 #ifdef _linux
113         int fd=0;
114         int len;
115         int a;
116         char *file=NULL;
117         char *i810_audio=NULL;
118         char *snd_pcm_oss=NULL;
119         char *snd_mixer_oss=NULL;
120         char *snd_pcm=NULL;
121         fd=open("/proc/modules",O_RDONLY);
122
123         if (fd>0){
124                 /* read the entire /proc/modules file and check if sound conf seems correct */
125                 /*a=fstat(fd,&statbuf);
126                 if (a<0) ms_warning("Can't stat /proc/modules:%s.",strerror(errno));
127                 len=statbuf.st_size;
128                 if (len==0) ms_warning("/proc/modules has zero size!");
129                 */
130                 /***** fstat does not work on /proc/modules for unknown reason *****/
131                 len=6000;
132                 file=ms_malloc(len+1);
133                 a=read(fd,file,len);
134                 if (a<len) file=ms_realloc(file,a+1);
135                 file[a]='\0';
136                 i810_audio=strstr(file,"i810_audio");
137                 if (i810_audio!=NULL){
138                         /* I'm sorry i put this warning in comments because
139                          * i don't use yet the right driver !! */
140 /*                      lc->vtable.display_warning(lc,_("You are currently using the i810_audio driver.\nThis driver is buggy and so does not work with Linphone.\nWe suggest that you replace it by its equivalent ALSA driver,\neither with packages from your distribution, or by downloading\nALSA drivers at http://www.alsa-project.org."));*/
141                         goto end;
142                 }
143                 snd_pcm=strstr(file,"snd-pcm");
144                 if (snd_pcm!=NULL){
145                         snd_pcm_oss=strstr(file,"snd-pcm-oss");
146                         snd_mixer_oss=strstr(file,"snd-mixer-oss");
147                         if (snd_pcm_oss==NULL){
148                                 lc->vtable.display_warning(lc,_("Your computer appears to be using ALSA sound drivers.\nThis is the best choice. However the pcm oss emulation module\nis missing and linphone needs it. Please execute\n'modprobe snd-pcm-oss' as root to load it."));
149                         }
150                         if (snd_mixer_oss==NULL){
151                                 lc->vtable.display_warning(lc,_("Your computer appears to be using ALSA sound drivers.\nThis is the best choice. However the mixer oss emulation module\nis missing and linphone needs it. Please execute\n 'modprobe snd-mixer-oss' as root to load it."));
152                         }
153                 }
154         }else {
155
156                 ms_warning("Could not open /proc/modules.");
157         }
158         /* now check general volume. Some user forget to rise it and then complain that linphone is
159         not working */
160         /* but some other users complain that linphone should not change levels...
161         if (lc->sound_conf.sndcard!=NULL){
162                 a=snd_card_get_level(lc->sound_conf.sndcard,SND_CARD_LEVEL_GENERAL);
163                 if (a<50){
164                         ms_warning("General level is quite low (%i). Linphone rises it up for you.",a);
165                         snd_card_set_level(lc->sound_conf.sndcard,SND_CARD_LEVEL_GENERAL,80);
166                 }
167         }
168         */
169         end:
170         if (file!=NULL) ms_free(file);
171         if (fd>0) close(fd);
172 #endif
173 }
174
175 #define UDP_HDR_SZ 8
176 #define RTP_HDR_SZ 12
177 #define IP4_HDR_SZ 20   /*20 is the minimum, but there may be some options*/
178
179 static void payload_type_set_enable(PayloadType *pt,int value)
180 {
181         if ((value)!=0) payload_type_set_flag(pt,PAYLOAD_TYPE_ENABLED); \
182         else payload_type_unset_flag(pt,PAYLOAD_TYPE_ENABLED);
183 }
184
185 static bool_t payload_type_enabled(const PayloadType *pt) {
186         return (((pt)->flags & PAYLOAD_TYPE_ENABLED)!=0);
187 }
188
189 bool_t linphone_core_payload_type_enabled(LinphoneCore *lc, const PayloadType *pt){
190         if (ms_list_find(lc->codecs_conf.audio_codecs, (PayloadType*) pt) || ms_list_find(lc->codecs_conf.video_codecs, (PayloadType*)pt)){
191                 return payload_type_enabled(pt);
192         }
193         ms_error("Getting enablement status of codec not in audio or video list of PayloadType !");
194         return FALSE;
195 }
196
197 int linphone_core_enable_payload_type(LinphoneCore *lc, PayloadType *pt, bool_t enabled){
198         if (ms_list_find(lc->codecs_conf.audio_codecs,pt) || ms_list_find(lc->codecs_conf.video_codecs,pt)){
199                 payload_type_set_enable(pt,enabled);
200                 _linphone_core_codec_config_write(lc);
201                 return 0;
202         }
203         ms_error("Enabling codec not in audio or video list of PayloadType !");
204         return -1;
205 }
206
207 int linphone_core_get_payload_type_number(LinphoneCore *lc, const PayloadType *pt){
208        return payload_type_get_number(pt);
209 }
210
211 const char *linphone_core_get_payload_type_description(LinphoneCore *lc, PayloadType *pt){
212         if (ms_filter_codec_supported(pt->mime_type)){
213                 MSFilterDesc *desc=ms_filter_get_encoder(pt->mime_type);
214 #ifdef ENABLE_NLS
215                 return dgettext("mediastreamer",desc->text);
216 #else
217                 return desc->text;
218 #endif
219         }
220         return NULL;
221 }
222
223
224 /*this function makes a special case for speex/8000.
225 This codec is variable bitrate. The 8kbit/s mode is interesting when having a low upload bandwidth, but its quality
226 is not very good. We 'd better use its 15kbt/s mode when we have enough bandwidth*/
227 static int get_codec_bitrate(LinphoneCore *lc, const PayloadType *pt){
228         int upload_bw=linphone_core_get_upload_bandwidth(lc);
229         if (bandwidth_is_greater(upload_bw,129) || (bandwidth_is_greater(upload_bw,33) && !linphone_core_video_enabled(lc)) ) {
230                 if (strcmp(pt->mime_type,"speex")==0 && pt->clock_rate==8000){
231                         return 15000;
232                 }
233         }
234         return pt->normal_bitrate;
235 }
236
237 static double get_audio_payload_bandwidth(LinphoneCore *lc, const PayloadType *pt){
238         double npacket=50;
239         double packet_size;
240         int bitrate;
241         bitrate=get_codec_bitrate(lc,pt);
242         packet_size= (((double)bitrate)/(50*8))+UDP_HDR_SZ+RTP_HDR_SZ+IP4_HDR_SZ;
243         return packet_size*8.0*npacket;
244 }
245
246 void linphone_core_update_allocated_audio_bandwidth_in_call(LinphoneCall *call, const PayloadType *pt){
247         call->audio_bw=(int)(get_audio_payload_bandwidth(call->core,pt)/1000.0);
248         ms_message("Audio bandwidth for this call is %i",call->audio_bw);
249 }
250
251 void linphone_core_update_allocated_audio_bandwidth(LinphoneCore *lc){
252         const MSList *elem;
253         PayloadType *max=NULL;
254         for(elem=linphone_core_get_audio_codecs(lc);elem!=NULL;elem=elem->next){
255                 PayloadType *pt=(PayloadType*)elem->data;
256                 if (payload_type_enabled(pt)){
257                         int pt_bitrate=get_codec_bitrate(lc,pt);
258                         if (max==NULL) max=pt;
259                         else if (max->normal_bitrate<pt_bitrate){
260                                 max=pt;
261                         }
262                 }
263         }
264         if (max) {
265                 lc->audio_bw=(int)(get_audio_payload_bandwidth(lc,max)/1000.0);
266         }
267 }
268
269 bool_t linphone_core_is_payload_type_usable_for_bandwidth(LinphoneCore *lc, PayloadType *pt,  int bandwidth_limit)
270 {
271         double codec_band;
272         bool_t ret=FALSE;
273         
274         switch (pt->type){
275                 case PAYLOAD_AUDIO_CONTINUOUS:
276                 case PAYLOAD_AUDIO_PACKETIZED:
277                         codec_band=get_audio_payload_bandwidth(lc,pt);
278                         ret=bandwidth_is_greater(bandwidth_limit*1000,codec_band);
279                         /*hack to avoid using uwb codecs when having low bitrate and video*/
280                         if (bandwidth_is_greater(199,bandwidth_limit)){
281                                 if (linphone_core_video_enabled(lc) && pt->clock_rate>16000){
282                                         ret=FALSE;
283                                 }
284                         }
285                         //ms_message("Payload %s: %g",pt->mime_type,codec_band);
286                         break;
287                 case PAYLOAD_VIDEO:
288                         if (bandwidth_limit!=0) {/* infinite (-1) or strictly positive*/
289                                 ret=TRUE;
290                         }
291                         else ret=FALSE;
292                         break;
293         }
294         return ret;
295 }
296
297 /* return TRUE if codec can be used with bandwidth, FALSE else*/
298 bool_t linphone_core_check_payload_type_usability(LinphoneCore *lc, PayloadType *pt)
299 {
300         double codec_band;
301         int allowed_bw,video_bw;
302         bool_t ret=FALSE;
303
304         linphone_core_update_allocated_audio_bandwidth(lc);
305         allowed_bw=get_min_bandwidth(linphone_core_get_download_bandwidth(lc),
306                                         linphone_core_get_upload_bandwidth(lc));
307         if (allowed_bw==0) {
308                 allowed_bw=-1;
309                 video_bw=1500; /*around 1.5 Mbit/s*/
310         }else
311                 video_bw=get_video_bandwidth(allowed_bw,lc->audio_bw);
312
313         switch (pt->type){
314                 case PAYLOAD_AUDIO_CONTINUOUS:
315                 case PAYLOAD_AUDIO_PACKETIZED:
316                         codec_band=get_audio_payload_bandwidth(lc,pt);
317                         ret=bandwidth_is_greater(allowed_bw*1000,codec_band);
318                         /*hack to avoid using uwb codecs when having low bitrate and video*/
319                         if (bandwidth_is_greater(199,allowed_bw)){
320                                 if (linphone_core_video_enabled(lc) && pt->clock_rate>16000){
321                                         ret=FALSE;
322                                 }
323                         }
324                         //ms_message("Payload %s: %g",pt->mime_type,codec_band);
325                         break;
326                 case PAYLOAD_VIDEO:
327                         if (video_bw>0){
328                                 pt->normal_bitrate=video_bw*1000;
329                                 ret=TRUE;
330                         }
331                         else ret=FALSE;
332                         break;
333         }
334         return ret;
335 }
336
337 bool_t lp_spawn_command_line_sync(const char *command, char **result,int *command_ret){
338 #if !defined(_WIN32_WCE)
339         FILE *f=popen(command,"r");
340         if (f!=NULL){
341                 int err;
342                 *result=ms_malloc(4096);
343                 err=fread(*result,1,4096-1,f);
344                 if (err<0){
345                         ms_warning("Error reading command output:%s",strerror(errno));
346                         ms_free(result);
347                         return FALSE;
348                 }
349                 (*result)[err]=0;
350                 err=pclose(f);
351                 if (command_ret!=NULL) *command_ret=err;
352                 return TRUE;
353         }
354 #endif /*_WIN32_WCE*/
355         return FALSE;
356 }
357
358 static ortp_socket_t create_socket(int local_port){
359         struct sockaddr_in laddr;
360         ortp_socket_t sock;
361         int optval;
362         sock=socket(PF_INET,SOCK_DGRAM,IPPROTO_UDP);
363         if (sock<0) {
364                 ms_error("Fail to create socket");
365                 return -1;
366         }
367         memset (&laddr,0,sizeof(laddr));
368         laddr.sin_family=AF_INET;
369         laddr.sin_addr.s_addr=INADDR_ANY;
370         laddr.sin_port=htons(local_port);
371         if (bind(sock,(struct sockaddr*)&laddr,sizeof(laddr))<0){
372                 ms_error("Bind socket to 0.0.0.0:%i failed: %s",local_port,getSocketError());
373                 close_socket(sock);
374                 return -1;
375         }
376         optval=1;
377         if (setsockopt (sock, SOL_SOCKET, SO_REUSEADDR,
378                                 (SOCKET_OPTION_VALUE)&optval, sizeof (optval))<0){
379                 ms_warning("Fail to set SO_REUSEADDR");
380         }
381         set_non_blocking_socket(sock);
382         return sock;
383 }
384
385 static int sendStunRequest(int sock, const struct sockaddr *server, socklen_t addrlen, int id, bool_t changeAddr){
386         char buf[STUN_MAX_MESSAGE_SIZE];
387         int len = STUN_MAX_MESSAGE_SIZE;
388         StunAtrString username;
389         StunAtrString password;
390         StunMessage req;
391         int err;
392         memset(&req, 0, sizeof(StunMessage));
393         memset(&username,0,sizeof(username));
394         memset(&password,0,sizeof(password));
395         stunBuildReqSimple( &req, &username, changeAddr , changeAddr , id);
396         len = stunEncodeMessage( &req, buf, len, &password);
397         if (len<=0){
398                 ms_error("Fail to encode stun message.");
399                 return -1;
400         }
401         err=sendto(sock,buf,len,0,server,addrlen);
402         if (err<0){
403                 ms_error("sendto failed: %s",strerror(errno));
404                 return -1;
405         }
406         return 0;
407 }
408
409 int parse_hostname_to_addr(const char *server, struct sockaddr_storage *ss, socklen_t *socklen){
410         struct addrinfo hints,*res=NULL;
411         int family = PF_INET;
412         int port_int = 3478;
413         int ret;
414         char port[6];
415         char host[NI_MAXHOST];
416         char *p1, *p2;
417         if ((sscanf(server, "[%64[^]]]:%d", host, &port_int) == 2) || (sscanf(server, "[%64[^]]]", host) == 1)) {
418                 family = PF_INET6;
419         } else {
420                 p1 = strchr(server, ':');
421                 p2 = strrchr(server, ':');
422                 if (p1 && p2 && (p1 != p2)) {
423                         family = PF_INET6;
424                         host[NI_MAXHOST-1]='\0';
425                         strncpy(host, server, sizeof(host) - 1);
426                 } else if (sscanf(server, "%[^:]:%d", host, &port_int) != 2) {
427                         host[NI_MAXHOST-1]='\0';
428                         strncpy(host, server, sizeof(host) - 1);
429                 }
430         }
431         snprintf(port, sizeof(port), "%d", port_int);
432         memset(&hints,0,sizeof(hints));
433         hints.ai_family=family;
434         hints.ai_socktype=SOCK_DGRAM;
435         hints.ai_protocol=IPPROTO_UDP;
436         ret=getaddrinfo(host,port,&hints,&res);
437         if (ret!=0){
438                 ms_error("getaddrinfo() failed for %s:%s : %s",host,port,gai_strerror(ret));
439                 return -1;
440         }
441         if (!res) return -1;
442         memcpy(ss,res->ai_addr,res->ai_addrlen);
443         *socklen=res->ai_addrlen;
444         freeaddrinfo(res);
445         return 0;
446 }
447
448 static int recvStunResponse(ortp_socket_t sock, char *ipaddr, int *port, int *id){
449         char buf[STUN_MAX_MESSAGE_SIZE];
450         int len = STUN_MAX_MESSAGE_SIZE;
451         StunMessage resp;
452         len=recv(sock,buf,len,0);
453         if (len>0){
454                 struct in_addr ia;
455                 stunParseMessage(buf,len, &resp );
456                 *id=resp.msgHdr.tr_id.octet[0];
457                 if (resp.hasXorMappedAddress){
458                         *port = resp.xorMappedAddress.ipv4.port;
459                         ia.s_addr=htonl(resp.xorMappedAddress.ipv4.addr);
460                 }else if (resp.hasMappedAddress){
461                         *port = resp.mappedAddress.ipv4.port;
462                         ia.s_addr=htonl(resp.mappedAddress.ipv4.addr);
463                 }else return -1;
464                 strncpy(ipaddr,inet_ntoa(ia),LINPHONE_IPADDR_SIZE);
465         }
466         return len;
467 }
468
469 /* this functions runs a simple stun test and return the number of milliseconds to complete the tests, or -1 if the test were failed.*/
470 int linphone_core_run_stun_tests(LinphoneCore *lc, LinphoneCall *call){
471         const char *server=linphone_core_get_stun_server(lc);
472         
473         if (lc->sip_conf.ipv6_enabled){
474                 ms_warning("stun support is not implemented for ipv6");
475                 return -1;
476         }
477         if (server!=NULL){
478                 struct sockaddr_storage ss;
479                 socklen_t ss_len;
480                 ortp_socket_t sock1=-1, sock2=-1;
481                 int loops=0;
482                 bool_t video_enabled=linphone_core_video_enabled(lc);
483                 bool_t got_audio,got_video;
484                 bool_t cone_audio=FALSE,cone_video=FALSE;
485                 struct timeval init,cur;
486                 SalEndpointCandidate *ac,*vc;
487                 double elapsed;
488                 int ret=0;
489                 
490                 ac=&call->localdesc->streams[0].candidates[0];
491                 vc=&call->localdesc->streams[1].candidates[0];
492                 
493                 if (parse_hostname_to_addr(server,&ss,&ss_len)<0){
494                         ms_error("Fail to parser stun server address: %s",server);
495                         return -1;
496                 }
497                 if (lc->vtable.display_status!=NULL)
498                         lc->vtable.display_status(lc,_("Stun lookup in progress..."));
499
500                 /*create the two audio and video RTP sockets, and send STUN message to our stun server */
501                 sock1=create_socket(call->audio_port);
502                 if (sock1==-1) return -1;
503                 if (video_enabled){
504                         sock2=create_socket(call->video_port);
505                         if (sock2==-1) return -1;
506                 }
507                 got_audio=FALSE;
508                 got_video=FALSE;
509                 gettimeofday(&init,NULL);
510                 do{
511                         
512                         int id;
513                         if (loops%20==0){
514                                 ms_message("Sending stun requests...");
515                                 sendStunRequest(sock1,(struct sockaddr*)&ss,ss_len,11,TRUE);
516                                 sendStunRequest(sock1,(struct sockaddr*)&ss,ss_len,1,FALSE);
517                                 if (sock2!=-1){
518                                         sendStunRequest(sock2,(struct sockaddr*)&ss,ss_len,22,TRUE);
519                                         sendStunRequest(sock2,(struct sockaddr*)&ss,ss_len,2,FALSE);
520                                 }
521                         }
522 #ifdef WIN32
523                         Sleep(10);
524 #else
525                         usleep(10000);
526 #endif
527
528                         if (recvStunResponse(sock1,ac->addr,
529                                                 &ac->port,&id)>0){
530                                 ms_message("STUN test result: local audio port maps to %s:%i",
531                                                 ac->addr,
532                                                 ac->port);
533                                 if (id==11)
534                                         cone_audio=TRUE;
535                                 got_audio=TRUE;
536                         }
537                         if (recvStunResponse(sock2,vc->addr,
538                                                         &vc->port,&id)>0){
539                                 ms_message("STUN test result: local video port maps to %s:%i",
540                                         vc->addr,
541                                         vc->port);
542                                 if (id==22)
543                                         cone_video=TRUE;
544                                 got_video=TRUE;
545                         }
546                         gettimeofday(&cur,NULL);
547                         elapsed=((cur.tv_sec-init.tv_sec)*1000.0) +  ((cur.tv_usec-init.tv_usec)/1000.0);
548                         if (elapsed>2000)  {
549                                 ms_message("Stun responses timeout, going ahead.");
550                                 ret=-1;
551                                 break;
552                         }
553                         loops++;
554                 }while(!(got_audio && (got_video||sock2==-1)  ) );
555                 if (ret==0) ret=(int)elapsed;
556                 if (!got_audio){
557                         ms_error("No stun server response for audio port.");
558                 }else{
559                         if (!cone_audio) {
560                                 ms_message("NAT is symmetric for audio port");
561                         }
562                 }
563                 if (sock2!=-1){
564                         if (!got_video){
565                                 ms_error("No stun server response for video port.");
566                         }else{
567                                 if (!cone_video) {
568                                         ms_message("NAT is symmetric for video port.");
569                                 }
570                         }
571                 }
572                 if ((ac->addr[0]!='\0' && vc->addr[0]!='\0' && strcmp(ac->addr,vc->addr)==0)
573                     || sock2==-1){
574                         strcpy(call->localdesc->addr,ac->addr);
575                 }
576                 close_socket(sock1);
577                 if (sock2!=-1) close_socket(sock2);
578                 return ret;
579         }
580         return -1;
581         
582 }
583
584 void linphone_core_adapt_to_network(LinphoneCore *lc, int ping_time_ms, LinphoneCallParams *params){
585         if (lp_config_get_int(lc->config,"net","activate_edge_workarounds",0)==1){
586                 int threshold=lp_config_get_int(lc->config,"net","edge_ping_time",500);
587                 
588                 if (ping_time_ms>threshold){
589                         int edge_ptime=lp_config_get_int(lc->config,"net","edge_ptime",100);
590                         int edge_bw=lp_config_get_int(lc->config,"net","edge_bw",30);
591                         /* we are in a 2G network*/
592                         params->up_bw=params->down_bw=edge_bw;
593                         params->up_ptime=params->down_ptime=edge_ptime;
594                         
595                 }/*else use default settings */
596         }
597 }
598
599
600
601 int linphone_core_gather_ice_candidates(LinphoneCore *lc, LinphoneCall *call)
602 {
603         char local_addr[64];
604         struct sockaddr_storage ss;
605         socklen_t ss_len;
606         IceCheckList *audio_check_list;
607         IceCheckList *video_check_list;
608         const char *server = linphone_core_get_stun_server(lc);
609
610         if ((server == NULL) || (call->ice_session == NULL)) return -1;
611         audio_check_list = ice_session_check_list(call->ice_session, 0);
612         video_check_list = ice_session_check_list(call->ice_session, 1);
613         if (audio_check_list == NULL) return -1;
614
615         if (lc->sip_conf.ipv6_enabled){
616                 ms_warning("stun support is not implemented for ipv6");
617                 return -1;
618         }
619
620         if (parse_hostname_to_addr(server, &ss, &ss_len) < 0) {
621                 ms_error("Fail to parser stun server address: %s", server);
622                 return -1;
623         }
624         if (lc->vtable.display_status != NULL)
625                 lc->vtable.display_status(lc, _("ICE local candidates gathering in progress..."));
626
627         /* Gather local host candidates. */
628         if (linphone_core_get_local_ip_for(AF_INET, NULL, local_addr) < 0) {
629                 ms_error("Fail to get local ip");
630                 return -1;
631         }
632         ice_add_local_candidate(audio_check_list, "host", local_addr, call->audio_port, 1, NULL);
633         ice_add_local_candidate(audio_check_list, "host", local_addr, call->audio_port + 1, 2, NULL);
634         if (call->params.has_video && (video_check_list != NULL)) {
635                 ice_add_local_candidate(video_check_list, "host", local_addr, call->video_port, 1, NULL);
636                 ice_add_local_candidate(video_check_list, "host", local_addr, call->video_port + 1, 2, NULL);
637         }
638
639         ms_message("ICE: gathering candidate from [%s]",server);
640         /* Gather local srflx candidates. */
641         ice_session_gather_candidates(call->ice_session, ss, ss_len);
642         return 0;
643 }
644
645 void linphone_core_update_local_media_description_from_ice(SalMediaDescription *desc, IceSession *session)
646 {
647         const char *rtp_addr, *rtcp_addr;
648         IceSessionState session_state = ice_session_state(session);
649         int nb_candidates;
650         int i, j;
651         bool_t result;
652
653         if (session_state == IS_Completed) {
654                 desc->ice_completed = TRUE;
655                 ice_check_list_selected_valid_local_candidate(ice_session_check_list(session, 0), &rtp_addr, NULL, NULL, NULL);
656                 strncpy(desc->addr, rtp_addr, sizeof(desc->addr));
657         }
658         else {
659                 desc->ice_completed = FALSE;
660         }
661         strncpy(desc->ice_pwd, ice_session_local_pwd(session), sizeof(desc->ice_pwd));
662         strncpy(desc->ice_ufrag, ice_session_local_ufrag(session), sizeof(desc->ice_ufrag));
663         for (i = 0; i < desc->nstreams; i++) {
664                 SalStreamDescription *stream = &desc->streams[i];
665                 IceCheckList *cl = ice_session_check_list(session, i);
666                 nb_candidates = 0;
667                 if (cl == NULL) continue;
668                 if (ice_check_list_state(cl) == ICL_Completed) {
669                         stream->ice_completed = TRUE;
670                         result = ice_check_list_selected_valid_local_candidate(ice_session_check_list(session, i), &rtp_addr, &stream->rtp_port, &rtcp_addr, &stream->rtcp_port);
671                 } else {
672                         stream->ice_completed = FALSE;
673                         result = ice_check_list_default_local_candidate(ice_session_check_list(session, i), &rtp_addr, &stream->rtp_port, &rtcp_addr, &stream->rtcp_port);
674                 }
675                 if (result == TRUE) {
676                         strncpy(stream->rtp_addr, rtp_addr, sizeof(stream->rtp_addr));
677                         strncpy(stream->rtcp_addr, rtcp_addr, sizeof(stream->rtcp_addr));
678                 } else {
679                         memset(stream->rtp_addr, 0, sizeof(stream->rtp_addr));
680                         memset(stream->rtcp_addr, 0, sizeof(stream->rtcp_addr));
681                 }
682                 if ((strlen(ice_check_list_local_pwd(cl)) != strlen(desc->ice_pwd)) || (strcmp(ice_check_list_local_pwd(cl), desc->ice_pwd)))
683                         strncpy(stream->ice_pwd, ice_check_list_local_pwd(cl), sizeof(stream->ice_pwd));
684                 else
685                         memset(stream->ice_pwd, 0, sizeof(stream->ice_pwd));
686                 if ((strlen(ice_check_list_local_ufrag(cl)) != strlen(desc->ice_ufrag)) || (strcmp(ice_check_list_local_ufrag(cl), desc->ice_ufrag)))
687                         strncpy(stream->ice_ufrag, ice_check_list_local_ufrag(cl), sizeof(stream->ice_ufrag));
688                 else
689                         memset(stream->ice_pwd, 0, sizeof(stream->ice_pwd));
690                 stream->ice_mismatch = ice_check_list_is_mismatch(cl);
691                 if ((ice_check_list_state(cl) == ICL_Running) || (ice_check_list_state(cl) == ICL_Completed)) {
692                         memset(stream->ice_candidates, 0, sizeof(stream->ice_candidates));
693                         for (j = 0; j < MIN(ms_list_size(cl->local_candidates), SAL_MEDIA_DESCRIPTION_MAX_ICE_CANDIDATES); j++) {
694                                 SalIceCandidate *sal_candidate = &stream->ice_candidates[nb_candidates];
695                                 IceCandidate *ice_candidate = ms_list_nth_data(cl->local_candidates, j);
696                                 const char *default_addr = NULL;
697                                 int default_port = 0;
698                                 if (ice_candidate->componentID == 1) {
699                                         default_addr = stream->rtp_addr;
700                                         default_port = stream->rtp_port;
701                                 } else if (ice_candidate->componentID == 2) {
702                                         default_addr = stream->rtcp_addr;
703                                         default_port = stream->rtcp_port;
704                                 } else continue;
705                                 if (default_addr[0] == '\0') default_addr = desc->addr;
706                                 /* Only include the candidates matching the default destination for each component of the stream if the state is Completed as specified in RFC5245 section 9.1.2.2. */
707                                 if ((ice_check_list_state(cl) == ICL_Completed)
708                                         && !((ice_candidate->taddr.port == default_port) && (strlen(ice_candidate->taddr.ip) == strlen(default_addr)) && (strcmp(ice_candidate->taddr.ip, default_addr) == 0)))
709                                         continue;
710                                 strncpy(sal_candidate->foundation, ice_candidate->foundation, sizeof(sal_candidate->foundation));
711                                 sal_candidate->componentID = ice_candidate->componentID;
712                                 sal_candidate->priority = ice_candidate->priority;
713                                 strncpy(sal_candidate->type, ice_candidate_type(ice_candidate), sizeof(sal_candidate->type));
714                                 strncpy(sal_candidate->addr, ice_candidate->taddr.ip, sizeof(sal_candidate->addr));
715                                 sal_candidate->port = ice_candidate->taddr.port;
716                                 if ((ice_candidate->base != NULL) && (ice_candidate->base != ice_candidate)) {
717                                         strncpy(sal_candidate->raddr, ice_candidate->base->taddr.ip, sizeof(sal_candidate->raddr));
718                                         sal_candidate->rport = ice_candidate->base->taddr.port;
719                                 }
720                                 nb_candidates++;
721                         }
722                 }
723                 if ((ice_check_list_state(cl) == ICL_Completed) && (ice_session_role(session) == IR_Controlling)) {
724                         int rtp_port, rtcp_port;
725                         memset(stream->ice_remote_candidates, 0, sizeof(stream->ice_remote_candidates));
726                         ice_check_list_selected_valid_remote_candidate(cl, &rtp_addr, &rtp_port, &rtcp_addr, &rtcp_port);
727                         strncpy(stream->ice_remote_candidates[0].addr, rtp_addr, sizeof(stream->ice_remote_candidates[0].addr));
728                         stream->ice_remote_candidates[0].port = rtp_port;
729                         strncpy(stream->ice_remote_candidates[1].addr, rtcp_addr, sizeof(stream->ice_remote_candidates[1].addr));
730                         stream->ice_remote_candidates[1].port = rtcp_port;
731                 }
732         }
733 }
734
735 static void get_default_addr_and_port(uint16_t componentID, const SalMediaDescription *md, const SalStreamDescription *stream, const char **addr, int *port)
736 {
737         if (componentID == 1) {
738                 *addr = stream->rtp_addr;
739                 *port = stream->rtp_port;
740         } else if (componentID == 2) {
741                 *addr = stream->rtcp_addr;
742                 *port = stream->rtcp_port;
743         } else return;
744         if ((*addr)[0] == '\0') *addr = md->addr;
745 }
746
747 void linphone_core_update_ice_from_remote_media_description(LinphoneCall *call, const SalMediaDescription *md)
748 {
749         bool_t ice_restarted = FALSE;
750
751         if ((md->ice_pwd[0] != '\0') && (md->ice_ufrag[0] != '\0')) {
752                 int i, j;
753
754                 /* Check for ICE restart and set remote credentials. */
755                 if ((strcmp(md->addr, "0.0.0.0") == 0) || (strcmp(md->addr, "::0") == 0)) {
756                         ice_session_restart(call->ice_session);
757                         ice_restarted = TRUE;
758                 } else {
759                         for (i = 0; i < md->nstreams; i++) {
760                                 const SalStreamDescription *stream = &md->streams[i];
761                                 IceCheckList *cl = ice_session_check_list(call->ice_session, i);
762                                 if (cl && (strcmp(stream->rtp_addr, "0.0.0.0") == 0)) {
763                                         ice_session_restart(call->ice_session);
764                                         ice_restarted = TRUE;
765                                         break;
766                                 }
767                         }
768                 }
769                 if ((ice_session_remote_ufrag(call->ice_session) == NULL) && (ice_session_remote_pwd(call->ice_session) == NULL)) {
770                         ice_session_set_remote_credentials(call->ice_session, md->ice_ufrag, md->ice_pwd);
771                 } else if (ice_session_remote_credentials_changed(call->ice_session, md->ice_ufrag, md->ice_pwd)) {
772                         if (ice_restarted == FALSE) {
773                                 ice_session_restart(call->ice_session);
774                                 ice_restarted = TRUE;
775                         }
776                         ice_session_set_remote_credentials(call->ice_session, md->ice_ufrag, md->ice_pwd);
777                 }
778                 for (i = 0; i < md->nstreams; i++) {
779                         const SalStreamDescription *stream = &md->streams[i];
780                         IceCheckList *cl = ice_session_check_list(call->ice_session, i);
781                         if (cl && (stream->ice_pwd[0] != '\0') && (stream->ice_ufrag[0] != '\0')) {
782                                 if (ice_check_list_remote_credentials_changed(cl, stream->ice_ufrag, stream->ice_pwd)) {
783                                         if (ice_restarted == FALSE) {
784                                                 ice_session_restart(call->ice_session);
785                                                 ice_restarted = TRUE;
786                                         }
787                                         ice_session_set_remote_credentials(call->ice_session, md->ice_ufrag, md->ice_pwd);
788                                         break;
789                                 }
790                         }
791                 }
792
793                 /* Create ICE check lists if needed and parse ICE attributes. */
794                 for (i = 0; i < md->nstreams; i++) {
795                         const SalStreamDescription *stream = &md->streams[i];
796                         IceCheckList *cl = ice_session_check_list(call->ice_session, i);
797                         if (cl == NULL) {
798                                 cl = ice_check_list_new();
799                                 ice_session_add_check_list(call->ice_session, cl);
800                                 switch (stream->type) {
801                                         case SalAudio:
802                                                 if (call->audiostream != NULL) call->audiostream->ice_check_list = cl;
803                                                 break;
804                                         case SalVideo:
805                                                 if (call->videostream != NULL) call->videostream->ice_check_list = cl;
806                                                 break;
807                                         default:
808                                                 break;
809                                 }
810                         }
811                         if ((stream->ice_mismatch == TRUE) || (stream->rtp_port == 0)) {
812                                 ice_check_list_set_state(cl, ICL_Failed);
813                         } else {
814                                 if ((stream->ice_pwd[0] != '\0') && (stream->ice_ufrag[0] != '\0'))
815                                         ice_check_list_set_remote_credentials(cl, stream->ice_ufrag, stream->ice_pwd);
816                                 for (j = 0; j < SAL_MEDIA_DESCRIPTION_MAX_ICE_CANDIDATES; j++) {
817                                         const SalIceCandidate *candidate = &stream->ice_candidates[j];
818                                         bool_t default_candidate = FALSE;
819                                         const char *addr = NULL;
820                                         int port = 0;
821                                         if (candidate->addr[0] == '\0') break;
822                                         if ((candidate->componentID == 0) || (candidate->componentID > 2)) continue;
823                                         get_default_addr_and_port(candidate->componentID, md, stream, &addr, &port);
824                                         if (addr && (candidate->port == port) && (strlen(candidate->addr) == strlen(addr)) && (strcmp(candidate->addr, addr) == 0))
825                                                 default_candidate = TRUE;
826                                         ice_add_remote_candidate(cl, candidate->type, candidate->addr, candidate->port, candidate->componentID,
827                                                 candidate->priority, candidate->foundation, default_candidate);
828                                 }
829                                 if (ice_restarted == FALSE) {
830                                         bool_t losing_pairs_added = FALSE;
831                                         for (j = 0; j < SAL_MEDIA_DESCRIPTION_MAX_ICE_REMOTE_CANDIDATES; j++) {
832                                                 const SalIceRemoteCandidate *candidate = &stream->ice_remote_candidates[j];
833                                                 const char *addr = NULL;
834                                                 int port = 0;
835                                                 int componentID = j + 1;
836                                                 if (candidate->addr[0] == '\0') break;
837                                                 get_default_addr_and_port(componentID, md, stream, &addr, &port);
838                                                 ice_add_losing_pair(cl, j + 1, candidate->addr, candidate->port, addr, port);
839                                                 losing_pairs_added = TRUE;
840                                         }
841                                         if (losing_pairs_added == TRUE) ice_check_list_check_completed(cl);
842                                 }
843                         }
844                 }
845                 for (i = ice_session_nb_check_lists(call->ice_session); i > md->nstreams; i--) {
846                         ice_session_remove_check_list(call->ice_session, ice_session_check_list(call->ice_session, i - 1));
847                 }
848                 ice_session_check_mismatch(call->ice_session);
849         }
850         if (ice_session_nb_check_lists(call->ice_session) == 0) {
851                 linphone_call_delete_ice_session(call);
852         }
853 }
854
855 void linphone_core_deactivate_ice_for_deactivated_media_streams(LinphoneCall *call, const SalMediaDescription *md)
856 {
857         int i;
858         for (i = 0; i < md->nstreams; i++) {
859                 IceCheckList *cl = ice_session_check_list(call->ice_session, i);
860                 if (cl && (md->streams[i].rtp_port == 0)) {
861                         if (ice_check_list_state(cl) != ICL_Completed) ice_check_list_set_state(cl, ICL_Failed);
862                 }
863         }
864 }
865
866 LinphoneCall * is_a_linphone_call(void *user_pointer){
867         LinphoneCall *call=(LinphoneCall*)user_pointer;
868         if (call==NULL) return NULL;
869         return call->magic==linphone_call_magic ? call : NULL;
870 }
871
872 LinphoneProxyConfig * is_a_linphone_proxy_config(void *user_pointer){
873         LinphoneProxyConfig *cfg=(LinphoneProxyConfig*)user_pointer;
874         if (cfg==NULL) return NULL;
875         return cfg->magic==linphone_proxy_config_magic ? cfg : NULL;
876 }
877
878 unsigned int linphone_core_get_audio_features(LinphoneCore *lc){
879         unsigned int ret=0;
880         const char *features=lp_config_get_string(lc->config,"sound","features",NULL);
881         if (features){
882                 char tmp[256]={0};
883                 char name[256];
884                 char *p,*n;
885                 strncpy(tmp,features,sizeof(tmp)-1);
886                 for(p=tmp;*p!='\0';p++){
887                         if (*p==' ') continue;
888                         n=strchr(p,'|');
889                         if (n) *n='\0';
890                         sscanf(p,"%s",name);
891                         ms_message("Found audio feature %s",name);
892                         if (strcasecmp(name,"PLC")==0) ret|=AUDIO_STREAM_FEATURE_PLC;
893                         else if (strcasecmp(name,"EC")==0) ret|=AUDIO_STREAM_FEATURE_EC;
894                         else if (strcasecmp(name,"EQUALIZER")==0) ret|=AUDIO_STREAM_FEATURE_EQUALIZER;
895                         else if (strcasecmp(name,"VOL_SND")==0) ret|=AUDIO_STREAM_FEATURE_VOL_SND;
896                         else if (strcasecmp(name,"VOL_RCV")==0) ret|=AUDIO_STREAM_FEATURE_VOL_RCV;
897                         else if (strcasecmp(name,"DTMF")==0) ret|=AUDIO_STREAM_FEATURE_DTMF;
898                         else if (strcasecmp(name,"DTMF_ECHO")==0) ret|=AUDIO_STREAM_FEATURE_DTMF_ECHO;
899                         else if (strcasecmp(name,"ALL")==0) ret|=AUDIO_STREAM_FEATURE_ALL;
900                         else if (strcasecmp(name,"NONE")==0) ret=0;
901                         else ms_error("Unsupported audio feature %s requested in config file.",name);
902                         if (!n) break;
903                         p=n;
904                 }
905         }else ret=AUDIO_STREAM_FEATURE_ALL;
906         return ret;
907 }
908
909
910 #ifdef HAVE_GETIFADDRS
911
912 #include <ifaddrs.h>
913 static int get_local_ip_with_getifaddrs(int type, char *address, int size)
914 {
915         struct ifaddrs *ifp;
916         struct ifaddrs *ifpstart;
917         int ret = 0;
918
919         if (getifaddrs(&ifpstart) < 0) {
920                 return -1;
921         }
922
923         for (ifp = ifpstart; ifp != NULL; ifp = ifp->ifa_next) {
924                 if (ifp->ifa_addr && ifp->ifa_addr->sa_family == type
925                         && (ifp->ifa_flags & IFF_RUNNING) && !(ifp->ifa_flags & IFF_LOOPBACK))
926                 {
927                         getnameinfo(ifp->ifa_addr,
928                                                 (type == AF_INET6) ?
929                                                 sizeof(struct sockaddr_in6) : sizeof(struct sockaddr_in),
930                                                 address, size, NULL, 0, NI_NUMERICHOST);
931                         if (strchr(address, '%') == NULL) {     /*avoid ipv6 link-local addresses */
932                                 /*ms_message("getifaddrs() found %s",address);*/
933                                 ret++;
934                                 break;
935                         }
936                 }
937         }
938         freeifaddrs(ifpstart);
939         return ret;
940 }
941 #endif
942
943
944 static int get_local_ip_for_with_connect(int type, const char *dest, char *result){
945         int err,tmp;
946         struct addrinfo hints;
947         struct addrinfo *res=NULL;
948         struct sockaddr_storage addr;
949         struct sockaddr *p_addr=(struct sockaddr*)&addr;
950         ortp_socket_t sock;
951         socklen_t s;
952
953         memset(&hints,0,sizeof(hints));
954         hints.ai_family=(type==AF_INET6) ? PF_INET6 : PF_INET;
955         hints.ai_socktype=SOCK_DGRAM;
956         /*hints.ai_flags=AI_NUMERICHOST|AI_CANONNAME;*/
957         err=getaddrinfo(dest,"5060",&hints,&res);
958         if (err!=0){
959                 ms_error("getaddrinfo() error: %s",gai_strerror(err));
960                 return -1;
961         }
962         if (res==NULL){
963                 ms_error("bug: getaddrinfo returned nothing.");
964                 return -1;
965         }
966         sock=socket(res->ai_family,SOCK_DGRAM,0);
967         tmp=1;
968         err=setsockopt(sock,SOL_SOCKET,SO_REUSEADDR,(SOCKET_OPTION_VALUE)&tmp,sizeof(int));
969         if (err<0){
970                 ms_warning("Error in setsockopt: %s",strerror(errno));
971         }
972         err=connect(sock,res->ai_addr,res->ai_addrlen);
973         if (err<0) {
974                 ms_error("Error in connect: %s",strerror(errno));
975                 freeaddrinfo(res);
976                 close_socket(sock);
977                 return -1;
978         }
979         freeaddrinfo(res);
980         res=NULL;
981         s=sizeof(addr);
982         err=getsockname(sock,(struct sockaddr*)&addr,&s);
983         if (err!=0) {
984                 ms_error("Error in getsockname: %s",strerror(errno));
985                 close_socket(sock);
986                 return -1;
987         }
988         if (p_addr->sa_family==AF_INET){
989                 struct sockaddr_in *p_sin=(struct sockaddr_in*)p_addr;
990                 if (p_sin->sin_addr.s_addr==0){
991                         close_socket(sock);
992                         return -1;
993                 }
994         }
995         err=getnameinfo((struct sockaddr *)&addr,s,result,LINPHONE_IPADDR_SIZE,NULL,0,NI_NUMERICHOST);
996         if (err!=0){
997                 ms_error("getnameinfo error: %s",strerror(errno));
998         }
999         close_socket(sock);
1000         ms_message("Local interface to reach %s is %s.",dest,result);
1001         return 0;
1002 }
1003
1004 int linphone_core_get_local_ip_for(int type, const char *dest, char *result){
1005         strcpy(result,type==AF_INET ? "127.0.0.1" : "::1");
1006 #ifdef HAVE_GETIFADDRS
1007         if (dest==NULL) {
1008                 /*we use getifaddrs for lookup of default interface */
1009                 int found_ifs;
1010         
1011                 found_ifs=get_local_ip_with_getifaddrs(type,result,LINPHONE_IPADDR_SIZE);
1012                 if (found_ifs==1){
1013                         return 0;
1014                 }else if (found_ifs<=0){
1015                         /*absolutely no network on this machine */
1016                         return -1;
1017                 }
1018         }
1019 #endif
1020         /*else use connect to find the best local ip address */
1021         if (type==AF_INET)
1022                 dest="87.98.157.38"; /*a public IP address*/
1023         else dest="2a00:1450:8002::68";
1024         return get_local_ip_for_with_connect(type,dest,result);
1025 }
1026
1027 #ifndef WIN32
1028 #include <resolv.h>
1029
1030
1031
1032 void _linphone_core_configure_resolver(){
1033 /*bionic declares _res but does not define nor export it !!*/
1034 #ifdef ANDROID
1035         /*timeout and attempts are the same as retrans and retry, but are android specific names.*/
1036         setenv("RES_OPTIONS","timeout:2 attempts:2 retrans:2 retry:2",1);
1037 #else
1038         res_init();
1039         _res.retrans=2; /*retransmit every two seconds*/
1040         _res.retry=2; /*only two times per DNS server*/
1041 #endif
1042 }
1043
1044 #else
1045
1046 void _linphone_core_configure_resolver(){
1047 }
1048
1049 #endif