misc.c 67.8 KB
Newer Older
aymeric's avatar
aymeric committed
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17

/*
linphone
Copyright (C) 2000  Simon MORLAT (simon.morlat@linphone.org)

This program is free software; you can redistribute it and/or
modify it under the terms of the GNU General Public License
as published by the Free Software Foundation; either version 2
of the License, or (at your option) any later version.

This program is distributed in the hope that it will be useful,
but WITHOUT ANY WARRANTY; without even the implied warranty of
MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
GNU General Public License for more details.

You should have received a copy of the GNU General Public License
along with this program; if not, write to the Free Software
18
Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA  02110-1301, USA.
aymeric's avatar
aymeric committed
19 20 21
*/

#include "private.h"
22
#include "linphone/lpconfig.h"
aymeric's avatar
aymeric committed
23 24 25
#include "mediastreamer2/mediastream.h"
#include <stdlib.h>
#include <stdio.h>
26
#ifdef HAVE_SIGHANDLER_T
aymeric's avatar
aymeric committed
27
#include <signal.h>
28
#endif /*HAVE_SIGHANDLER_T*/
Simon Morlat's avatar
Simon Morlat committed
29 30 31 32

#include <string.h>
#if !defined(_WIN32_WCE)
#include <errno.h>
aymeric's avatar
aymeric committed
33 34
#include <sys/types.h>
#include <sys/stat.h>
Sylvain Berfini's avatar
Sylvain Berfini committed
35 36 37
#if _MSC_VER
#include <io.h>
#else
aymeric's avatar
aymeric committed
38
#include <unistd.h>
Sylvain Berfini's avatar
Sylvain Berfini committed
39
#endif
aymeric's avatar
aymeric committed
40
#include <fcntl.h>
Jehan Monnier's avatar
Jehan Monnier committed
41
#endif /*_WIN32_WCE*/
aymeric's avatar
aymeric committed
42

43
#undef snprintf
jehan's avatar
jehan committed
44
#include <mediastreamer2/stun.h>
aymeric's avatar
aymeric committed
45

46 47 48 49
#ifdef HAVE_GETIFADDRS
#include <net/if.h>
#include <ifaddrs.h>
#endif
50
#include <math.h>
51 52 53 54
#if _MSC_VER
#define snprintf _snprintf
#define popen _popen
#define pclose _pclose
Sylvain Berfini's avatar
Sylvain Berfini committed
55
#endif
56

aymeric's avatar
aymeric committed
57 58 59 60 61

#define UDP_HDR_SZ 8
#define RTP_HDR_SZ 12
#define IP4_HDR_SZ 20   /*20 is the minimum, but there may be some options*/

Simon Morlat's avatar
Simon Morlat committed
62
static void clear_ice_check_list(LinphoneCall *call, IceCheckList *removed);
aymeric's avatar
aymeric committed
63

64
bool_t linphone_core_payload_type_enabled(LinphoneCore *lc, const LinphonePayloadType *pt){
65
	if (bctbx_list_find(lc->codecs_conf.audio_codecs, (PayloadType*) pt) || bctbx_list_find(lc->codecs_conf.video_codecs, (PayloadType*)pt) || bctbx_list_find(lc->codecs_conf.text_codecs, (PayloadType*)pt)){
66 67 68 69
		return payload_type_enabled(pt);
	}
	ms_error("Getting enablement status of codec not in audio or video list of PayloadType !");
	return FALSE;
aymeric's avatar
aymeric committed
70
}
71

72
bool_t linphone_core_payload_type_is_vbr(LinphoneCore *lc, const LinphonePayloadType *pt){
73 74 75 76
	if (pt->type==PAYLOAD_VIDEO) return TRUE;
	return !!(pt->flags & PAYLOAD_TYPE_IS_VBR);
}

77
int linphone_core_enable_payload_type(LinphoneCore *lc, LinphonePayloadType *pt, bool_t enabled){
78
	if (bctbx_list_find(lc->codecs_conf.audio_codecs,pt) || bctbx_list_find(lc->codecs_conf.video_codecs,pt) || bctbx_list_find(lc->codecs_conf.text_codecs,pt)){
79
		payload_type_set_enable(pt,enabled);
80
		_linphone_core_codec_config_write(lc);
81
		linphone_core_update_allocated_audio_bandwidth(lc);
82 83 84 85
		return 0;
	}
	ms_error("Enabling codec not in audio or video list of PayloadType !");
	return -1;
aymeric's avatar
aymeric committed
86 87
}

88
int linphone_core_get_payload_type_number(LinphoneCore *lc, const PayloadType *pt){
89
	return payload_type_get_number(pt);
90 91
}

92 93 94 95
void linphone_core_set_payload_type_number(LinphoneCore *lc, PayloadType *pt, int number){
	payload_type_set_number(pt,number);
}

96
const char *linphone_core_get_payload_type_description(LinphoneCore *lc, PayloadType *pt){
97 98 99
	//if (ms_filter_codec_supported(pt->mime_type)){
	if (ms_factory_codec_supported(lc->factory, pt->mime_type)){
		MSFilterDesc *desc=ms_factory_get_encoder(lc->factory, pt->mime_type);
100
#ifdef ENABLE_NLS
101 102 103 104
		return dgettext("mediastreamer",desc->text);
#else
		return desc->text;
#endif
105 106
	}
	return NULL;
aymeric's avatar
aymeric committed
107 108
}

109
void linphone_core_set_payload_type_bitrate(LinphoneCore *lc, LinphonePayloadType *pt, int bitrate){
110
	if (bctbx_list_find(lc->codecs_conf.audio_codecs, (PayloadType*) pt) || bctbx_list_find(lc->codecs_conf.video_codecs, (PayloadType*)pt) || bctbx_list_find(lc->codecs_conf.text_codecs, (PayloadType*)pt)){
111
		if (pt->type==PAYLOAD_VIDEO || pt->flags & PAYLOAD_TYPE_IS_VBR){
112 113
			pt->normal_bitrate=bitrate*1000;
			pt->flags|=PAYLOAD_TYPE_BITRATE_OVERRIDE;
114
			linphone_core_update_allocated_audio_bandwidth(lc);
115 116
		}else{
			ms_error("Cannot set an explicit bitrate for codec %s/%i, because it is not VBR.",pt->mime_type,pt->clock_rate);
117
			return;
118
		}
Guillaume BIENKOWSKI's avatar
Guillaume BIENKOWSKI committed
119 120
	} else {
		ms_error("linphone_core_set_payload_type_bitrate() payload type not in audio or video list !");
121 122 123
	}
}

124

125 126 127 128
/*
 *((codec-birate*ptime/8) + RTP header + UDP header + IP header)*8/ptime;
 *ptime=1/npacket
 */
129 130

static double get_audio_payload_bandwidth_from_codec_bitrate(const PayloadType *pt){
aymeric's avatar
aymeric committed
131 132 133
	double npacket=50;
	double packet_size;
	int bitrate;
134

135 136 137
	if (strcmp(payload_type_get_mime(&payload_type_aaceld_44k), payload_type_get_mime(pt))==0) {
		/*special case of aac 44K because ptime= 10ms*/
		npacket=100;
138 139
	}else if (strcmp(payload_type_get_mime(&payload_type_ilbc), payload_type_get_mime(pt))==0) {
		npacket=1000/30.0;
140
	}
141

142
	bitrate=pt->normal_bitrate;
143
	packet_size= (((double)bitrate)/(npacket*8))+UDP_HDR_SZ+RTP_HDR_SZ+IP4_HDR_SZ;
aymeric's avatar
aymeric committed
144 145 146
	return packet_size*8.0*npacket;
}

147 148 149 150 151 152 153 154 155 156 157 158 159 160 161 162 163 164 165 166 167 168 169 170 171 172 173 174 175 176
typedef struct vbr_codec_bitrate{
	int max_avail_bitrate;
	int min_rate;
	int recomended_bitrate;
}vbr_codec_bitrate_t;

static vbr_codec_bitrate_t defauls_vbr[]={
	//{ 100, 44100, 100 },
	{ 64, 44100, 50 },
	{ 64, 16000, 40 },
	{ 32, 16000, 32 },
	{ 32, 8000, 32 },
	{ 0 , 8000, 24 },
	{ 0 , 0, 0 }
};

static int lookup_vbr_typical_bitrate(int maxbw, int clock_rate){
	vbr_codec_bitrate_t *it;
	if (maxbw<=0) maxbw=defauls_vbr[0].max_avail_bitrate;
	for(it=defauls_vbr;it->min_rate!=0;it++){
		if (maxbw>=it->max_avail_bitrate && clock_rate>=it->min_rate)
			return it->recomended_bitrate;
	}
	ms_error("lookup_vbr_typical_bitrate(): should not happen.");
	return 32;
}

static int get_audio_payload_bandwidth(LinphoneCore *lc, const PayloadType *pt, int maxbw){
	if (linphone_core_payload_type_is_vbr(lc,pt)){
		if (pt->flags & PAYLOAD_TYPE_BITRATE_OVERRIDE){
177
			ms_debug("PayloadType %s/%i has bitrate override",pt->mime_type,pt->clock_rate);
178 179 180 181 182 183
			return pt->normal_bitrate/1000;
		}
		return lookup_vbr_typical_bitrate(maxbw,pt->clock_rate);
	}else return (int)ceil(get_audio_payload_bandwidth_from_codec_bitrate(pt)/1000.0);/*rounding codec bandwidth should be avoid, specially for AMR*/
}

184
int linphone_core_get_payload_type_bitrate(LinphoneCore *lc, const LinphonePayloadType *pt){
185 186 187 188 189 190 191 192 193 194 195 196 197 198 199 200 201 202
	int maxbw=get_min_bandwidth(linphone_core_get_download_bandwidth(lc),
					linphone_core_get_upload_bandwidth(lc));
	if (pt->type==PAYLOAD_AUDIO_CONTINUOUS || pt->type==PAYLOAD_AUDIO_PACKETIZED){
		return get_audio_payload_bandwidth(lc,pt,maxbw);
	}else if (pt->type==PAYLOAD_VIDEO){
		int video_bw;
		if (maxbw<=0) {
			video_bw=1500; /*default bitrate for video stream when no bandwidth limit is set, around 1.5 Mbit/s*/
		}else{
			video_bw=get_remaining_bandwidth_for_video(maxbw,lc->audio_bw);
		}
		return video_bw;
	}
	return 0;
}

void linphone_core_update_allocated_audio_bandwidth_in_call(LinphoneCall *call, const PayloadType *pt, int maxbw){
	call->audio_bw=get_audio_payload_bandwidth(call->core,pt,maxbw);
Simon Morlat's avatar
Simon Morlat committed
203
	ms_message("Audio bandwidth for this call is %i",call->audio_bw);
aymeric's avatar
aymeric committed
204 205
}

206
void linphone_core_update_allocated_audio_bandwidth(LinphoneCore *lc){
207
	const bctbx_list_t *elem;
208 209 210
	int maxbw=get_min_bandwidth(linphone_core_get_download_bandwidth(lc),
					linphone_core_get_upload_bandwidth(lc));
	int max_codec_bitrate=0;
211

aymeric's avatar
aymeric committed
212 213 214
	for(elem=linphone_core_get_audio_codecs(lc);elem!=NULL;elem=elem->next){
		PayloadType *pt=(PayloadType*)elem->data;
		if (payload_type_enabled(pt)){
215 216 217 218 219
			int pt_bitrate=get_audio_payload_bandwidth(lc,pt,maxbw);
			if (max_codec_bitrate==0) {
				max_codec_bitrate=pt_bitrate;
			}else if (max_codec_bitrate<pt_bitrate){
				max_codec_bitrate=pt_bitrate;
aymeric's avatar
aymeric committed
220 221 222
			}
		}
	}
223 224
	if (max_codec_bitrate) {
		lc->audio_bw=max_codec_bitrate;
aymeric's avatar
aymeric committed
225 226 227
	}
}

228
bool_t linphone_core_is_payload_type_usable_for_bandwidth(LinphoneCore *lc, const PayloadType *pt, int bandwidth_limit){
Simon Morlat's avatar
Simon Morlat committed
229
	double codec_band;
230
	const int video_enablement_limit = 99;
Simon Morlat's avatar
Simon Morlat committed
231
	bool_t ret=FALSE;
232

Simon Morlat's avatar
Simon Morlat committed
233 234 235
	switch (pt->type){
		case PAYLOAD_AUDIO_CONTINUOUS:
		case PAYLOAD_AUDIO_PACKETIZED:
236
			codec_band=get_audio_payload_bandwidth(lc,pt,bandwidth_limit);
237
			ret=bandwidth_is_greater(bandwidth_limit,(int)codec_band);
238
			/*ms_message("Payload %s: codec_bandwidth=%g, bandwidth_limit=%i",pt->mime_type,codec_band,bandwidth_limit);*/
Simon Morlat's avatar
Simon Morlat committed
239 240
			break;
		case PAYLOAD_VIDEO:
241
			if (bandwidth_limit<=0 || bandwidth_limit >= video_enablement_limit) {/* infinite or greater than video_enablement_limit*/
Simon Morlat's avatar
Simon Morlat committed
242 243 244 245
				ret=TRUE;
			}
			else ret=FALSE;
			break;
Sylvain Berfini's avatar
Sylvain Berfini committed
246 247 248
		case PAYLOAD_TEXT:
			ret=TRUE;
			break;
Simon Morlat's avatar
Simon Morlat committed
249 250 251 252
	}
	return ret;
}

aymeric's avatar
aymeric committed
253
/* return TRUE if codec can be used with bandwidth, FALSE else*/
254
bool_t linphone_core_check_payload_type_usability(LinphoneCore *lc, const PayloadType *pt){
255 256 257
	int maxbw=get_min_bandwidth(linphone_core_get_download_bandwidth(lc),
					linphone_core_get_upload_bandwidth(lc));
	bool_t ret=linphone_core_is_payload_type_usable_for_bandwidth(lc, pt, maxbw);
258
	if ((pt->type==PAYLOAD_AUDIO_CONTINUOUS || pt->type==PAYLOAD_AUDIO_PACKETIZED)
259
		&& lc->sound_conf.capt_sndcard
260 261 262 263
		&& !(ms_snd_card_get_capabilities(lc->sound_conf.capt_sndcard) & MS_SND_CARD_CAP_BUILTIN_ECHO_CANCELLER)
		&& linphone_core_echo_cancellation_enabled(lc)
		&& (pt->clock_rate!=16000 && pt->clock_rate!=8000)
		&& strcasecmp(pt->mime_type,"opus")!=0
264
		&& ms_factory_lookup_filter_by_name(lc->factory, "MSWebRTCAEC")!=NULL){
265 266 267 268 269
		ms_warning("Payload type %s/%i cannot be used because software echo cancellation is required but is unable to operate at this rate.",
			   pt->mime_type,pt->clock_rate);
		ret=FALSE;
	}
	return ret;
aymeric's avatar
aymeric committed
270 271 272
}

bool_t lp_spawn_command_line_sync(const char *command, char **result,int *command_ret){
273
#if !defined(_WIN32_WCE) && !defined(LINPHONE_WINDOWS_UNIVERSAL)
aymeric's avatar
aymeric committed
274 275 276 277 278 279 280 281 282 283 284 285 286 287 288
	FILE *f=popen(command,"r");
	if (f!=NULL){
		int err;
		*result=ms_malloc(4096);
		err=fread(*result,1,4096-1,f);
		if (err<0){
			ms_warning("Error reading command output:%s",strerror(errno));
			ms_free(result);
			return FALSE;
		}
		(*result)[err]=0;
		err=pclose(f);
		if (command_ret!=NULL) *command_ret=err;
		return TRUE;
	}
289
#endif /*_WIN32_WCE*/
aymeric's avatar
aymeric committed
290 291 292
	return FALSE;
}

smorlat's avatar
smorlat committed
293 294 295 296 297 298 299 300 301 302 303 304 305 306
static ortp_socket_t create_socket(int local_port){
	struct sockaddr_in laddr;
	ortp_socket_t sock;
	int optval;
	sock=socket(PF_INET,SOCK_DGRAM,IPPROTO_UDP);
	if (sock<0) {
		ms_error("Fail to create socket");
		return -1;
	}
	memset (&laddr,0,sizeof(laddr));
	laddr.sin_family=AF_INET;
	laddr.sin_addr.s_addr=INADDR_ANY;
	laddr.sin_port=htons(local_port);
	if (bind(sock,(struct sockaddr*)&laddr,sizeof(laddr))<0){
smorlat's avatar
smorlat committed
307
		ms_error("Bind socket to 0.0.0.0:%i failed: %s",local_port,getSocketError());
smorlat's avatar
smorlat committed
308 309 310 311 312 313 314 315 316 317 318 319
		close_socket(sock);
		return -1;
	}
	optval=1;
	if (setsockopt (sock, SOL_SOCKET, SO_REUSEADDR,
				(SOCKET_OPTION_VALUE)&optval, sizeof (optval))<0){
		ms_warning("Fail to set SO_REUSEADDR");
	}
	set_non_blocking_socket(sock);
	return sock;
}

Ghislain MARY's avatar
Ghislain MARY committed
320 321
static int send_stun_request(int sock, const struct sockaddr *server, socklen_t addrlen, int id, bool_t change_addr){
	char *buf = NULL;
Ghislain MARY's avatar
Ghislain MARY committed
322
	size_t len;
Ghislain MARY's avatar
Ghislain MARY committed
323 324 325 326 327 328 329 330 331
	int err = 0;
	MSStunMessage *req = ms_stun_binding_request_create();
	UInt96 tr_id = ms_stun_message_get_tr_id(req);
	tr_id.octet[0] = id;
	ms_stun_message_set_tr_id(req, tr_id);
	ms_stun_message_enable_change_ip(req, change_addr);
	ms_stun_message_enable_change_port(req, change_addr);
	len = ms_stun_message_encode(req, &buf);
	if (len <= 0) {
smorlat's avatar
smorlat committed
332
		ms_error("Fail to encode stun message.");
Ghislain MARY's avatar
Ghislain MARY committed
333 334
		err = -1;
	} else {
Ghislain MARY's avatar
Ghislain MARY committed
335
		err = bctbx_sendto(sock, buf, len, 0, server, addrlen);
Ghislain MARY's avatar
Ghislain MARY committed
336 337 338 339
		if (err < 0) {
			ms_error("sendto failed: %s",strerror(errno));
			err = -1;
		}
smorlat's avatar
smorlat committed
340
	}
Ghislain MARY's avatar
Ghislain MARY committed
341 342 343
	if (buf != NULL) ms_free(buf);
	ms_free(req);
	return err;
smorlat's avatar
smorlat committed
344 345
}

346 347
int linphone_parse_host_port(const char *input, char *host, size_t hostlen, int *port){
	char tmphost[NI_MAXHOST]={0};
348
	char *p1, *p2;
349

350
	if ((sscanf(input, "[%64[^]]]:%d", tmphost, port) == 2) || (sscanf(input, "[%64[^]]]", tmphost) == 1)) {
351

352
	} else {
353 354 355 356 357 358 359
		p1 = strchr(input, ':');
		p2 = strrchr(input, ':');
		if (p1 && p2 && (p1 != p2)) {/* an ipv6 address without port*/
			strncpy(tmphost, input, sizeof(tmphost) - 1);
		} else if (sscanf(input, "%[^:]:%d", tmphost, port) != 2) {
			/*no port*/
			strncpy(tmphost, input, sizeof(tmphost) - 1);
360 361
		}
	}
362 363 364 365 366 367 368 369 370 371
	strncpy(host,tmphost,hostlen);
	return 0;
}

int parse_hostname_to_addr(const char *server, struct sockaddr_storage *ss, socklen_t *socklen, int default_port){
	struct addrinfo hints,*res=NULL;
	char port[6];
	char host[NI_MAXHOST];
	int port_int=default_port;
	int ret;
372

373
	linphone_parse_host_port(server,host,sizeof(host),&port_int);
374

375
	snprintf(port, sizeof(port), "%d", port_int);
smorlat's avatar
smorlat committed
376
	memset(&hints,0,sizeof(hints));
377
	hints.ai_family=AF_UNSPEC;
smorlat's avatar
smorlat committed
378 379 380 381 382 383 384 385 386
	hints.ai_socktype=SOCK_DGRAM;
	hints.ai_protocol=IPPROTO_UDP;
	ret=getaddrinfo(host,port,&hints,&res);
	if (ret!=0){
		ms_error("getaddrinfo() failed for %s:%s : %s",host,port,gai_strerror(ret));
		return -1;
	}
	if (!res) return -1;
	memcpy(ss,res->ai_addr,res->ai_addrlen);
387
	*socklen=(socklen_t)res->ai_addrlen;
smorlat's avatar
smorlat committed
388 389 390 391
	freeaddrinfo(res);
	return 0;
}

Ghislain MARY's avatar
Ghislain MARY committed
392 393 394 395 396 397 398
static int recv_stun_response(ortp_socket_t sock, char *ipaddr, int *port, int *id) {
	char buf[MS_STUN_MAX_MESSAGE_SIZE];
	int len = MS_STUN_MAX_MESSAGE_SIZE;
	MSStunMessage *resp;

	len = recv(sock, buf, len, 0);
	if (len > 0) {
smorlat's avatar
smorlat committed
399
		struct in_addr ia;
Ghislain MARY's avatar
Ghislain MARY committed
400
		resp = ms_stun_message_create_from_buffer_parsing((uint8_t *)buf, (ssize_t)len);
Ghislain MARY's avatar
Ghislain MARY committed
401 402 403 404 405 406
		if (resp != NULL) {
			const MSStunAddress *stun_addr;
			UInt96 tr_id = ms_stun_message_get_tr_id(resp);
			*id = tr_id.octet[0];
			stun_addr = ms_stun_message_get_xor_mapped_address(resp);
			if (stun_addr != NULL) {
407 408
				*port = stun_addr->ip.v4.port;
				ia.s_addr = htonl(stun_addr->ip.v4.addr);
Ghislain MARY's avatar
Ghislain MARY committed
409 410 411
			} else {
				stun_addr = ms_stun_message_get_mapped_address(resp);
				if (stun_addr != NULL) {
412 413
					*port = stun_addr->ip.v4.port;
					ia.s_addr = htonl(stun_addr->ip.v4.addr);
Ghislain MARY's avatar
Ghislain MARY committed
414 415 416 417
				} else len = -1;
			}
			if (len > 0) strncpy(ipaddr, inet_ntoa(ia), LINPHONE_IPADDR_SIZE);
		}
smorlat's avatar
smorlat committed
418 419 420 421
	}
	return len;
}

Simon Morlat's avatar
Simon Morlat committed
422
/* this functions runs a simple stun test and return the number of milliseconds to complete the tests, or -1 if the test were failed.*/
423
int linphone_core_run_stun_tests(LinphoneCore *lc, LinphoneCall *call){
smorlat's avatar
smorlat committed
424
	const char *server=linphone_core_get_stun_server(lc);
425 426
	StunCandidate *ac=&call->ac;
	StunCandidate *vc=&call->vc;
427
	StunCandidate *tc=&call->tc;
428

smorlat's avatar
smorlat committed
429 430
	if (lc->sip_conf.ipv6_enabled){
		ms_warning("stun support is not implemented for ipv6");
Simon Morlat's avatar
Simon Morlat committed
431
		return -1;
smorlat's avatar
smorlat committed
432
	}
433
	if (call->media_ports[call->main_audio_stream_index].rtp_port==-1){
434 435 436
		ms_warning("Stun-only support not available for system random port");
		return -1;
	}
smorlat's avatar
smorlat committed
437
	if (server!=NULL){
438
		const struct addrinfo *ai=linphone_core_get_stun_server_addrinfo(lc);
439
		ortp_socket_t sock1=-1, sock2=-1, sock3=-1;
440
		int loops=0;
smorlat's avatar
smorlat committed
441
		bool_t video_enabled=linphone_core_video_enabled(lc);
442 443
		bool_t got_audio,got_video,got_text;
		bool_t cone_audio=FALSE,cone_video=FALSE,cone_text=FALSE;
smorlat's avatar
smorlat committed
444
		struct timeval init,cur;
Simon Morlat's avatar
Simon Morlat committed
445 446
		double elapsed;
		int ret=0;
447

448 449
		if (ai==NULL){
			ms_error("Could not obtain stun server addrinfo.");
Simon Morlat's avatar
Simon Morlat committed
450
			return -1;
smorlat's avatar
smorlat committed
451
		}
452
		linphone_core_notify_display_status(lc,_("Stun lookup in progress..."));
453

smorlat's avatar
smorlat committed
454
		/*create the two audio and video RTP sockets, and send STUN message to our stun server */
455
		sock1=create_socket(call->media_ports[call->main_audio_stream_index].rtp_port);
Simon Morlat's avatar
Simon Morlat committed
456
		if (sock1==-1) return -1;
smorlat's avatar
smorlat committed
457
		if (video_enabled){
458
			sock2=create_socket(call->media_ports[call->main_video_stream_index].rtp_port);
Simon Morlat's avatar
Simon Morlat committed
459
			if (sock2==-1) return -1;
smorlat's avatar
smorlat committed
460
		}
Sylvain Berfini's avatar
Sylvain Berfini committed
461 462 463
		sock3=create_socket(call->media_ports[call->main_text_stream_index].rtp_port);
		if (sock3==-1) return -1;
		
smorlat's avatar
smorlat committed
464 465
		got_audio=FALSE;
		got_video=FALSE;
466
		got_text=FALSE;
467
		ortp_gettimeofday(&init,NULL);
smorlat's avatar
smorlat committed
468
		do{
469

smorlat's avatar
smorlat committed
470
			int id;
471 472
			if (loops%20==0){
				ms_message("Sending stun requests...");
Ghislain MARY's avatar
Ghislain MARY committed
473 474
				send_stun_request((int)sock1,ai->ai_addr,(socklen_t)ai->ai_addrlen,11,TRUE);
				send_stun_request((int)sock1,ai->ai_addr,(socklen_t)ai->ai_addrlen,1,FALSE);
475
				if (sock2!=-1){
Ghislain MARY's avatar
Ghislain MARY committed
476 477
					send_stun_request((int)sock2,ai->ai_addr,(socklen_t)ai->ai_addrlen,22,TRUE);
					send_stun_request((int)sock2,ai->ai_addr,(socklen_t)ai->ai_addrlen,2,FALSE);
478
				}
479
				if (sock3!=-1){
Ghislain MARY's avatar
Ghislain MARY committed
480 481
					send_stun_request((int)sock3,ai->ai_addr,(socklen_t)ai->ai_addrlen,33,TRUE);
					send_stun_request((int)sock3,ai->ai_addr,(socklen_t)ai->ai_addrlen,3,FALSE);
482
				}
483
			}
484
			ms_usleep(10000);
smorlat's avatar
smorlat committed
485

Ghislain MARY's avatar
Ghislain MARY committed
486 487 488
			if (recv_stun_response(sock1, ac->addr, &ac->port, &id) > 0) {
				ms_message("STUN test result: local audio port maps to %s:%i", ac->addr, ac->port);
				if (id==11) cone_audio=TRUE;
smorlat's avatar
smorlat committed
489 490
				got_audio=TRUE;
			}
Ghislain MARY's avatar
Ghislain MARY committed
491 492 493
			if (recv_stun_response(sock2, vc->addr, &vc->port, &id) > 0) {
				ms_message("STUN test result: local video port maps to %s:%i", vc->addr, vc->port);
				if (id==22) cone_video=TRUE;
smorlat's avatar
smorlat committed
494
				got_video=TRUE;
smorlat's avatar
smorlat committed
495
			}
Ghislain MARY's avatar
Ghislain MARY committed
496 497 498
			if (recv_stun_response(sock3, tc->addr, &tc->port, &id)>0) {
				ms_message("STUN test result: local text port maps to %s:%i", tc->addr, tc->port);
				if (id==33) cone_text=TRUE;
499 500
				got_text=TRUE;
			}
501
			ortp_gettimeofday(&cur,NULL);
smorlat's avatar
smorlat committed
502
			elapsed=((cur.tv_sec-init.tv_sec)*1000.0) +  ((cur.tv_usec-init.tv_usec)/1000.0);
503 504
			if (elapsed>2000)  {
				ms_message("Stun responses timeout, going ahead.");
Simon Morlat's avatar
Simon Morlat committed
505
				ret=-1;
506 507 508
				break;
			}
			loops++;
509
		}while(!(got_audio && (got_video||sock2==-1) && (got_text||sock3==-1)  ) );
Simon Morlat's avatar
Simon Morlat committed
510
		if (ret==0) ret=(int)elapsed;
smorlat's avatar
smorlat committed
511 512
		if (!got_audio){
			ms_error("No stun server response for audio port.");
smorlat's avatar
smorlat committed
513 514
		}else{
			if (!cone_audio) {
515
				ms_message("NAT is symmetric for audio port");
smorlat's avatar
smorlat committed
516
			}
smorlat's avatar
smorlat committed
517
		}
518
		if (sock2!=-1){
smorlat's avatar
smorlat committed
519 520 521 522
			if (!got_video){
				ms_error("No stun server response for video port.");
			}else{
				if (!cone_video) {
523
					ms_message("NAT is symmetric for video port.");
smorlat's avatar
smorlat committed
524 525
				}
			}
smorlat's avatar
smorlat committed
526
		}
527 528 529 530 531 532 533 534 535
		if (sock3!=-1){
			if (!got_text){
				ms_error("No stun server response for text port.");
			}else{
				if (!cone_text) {
					ms_message("NAT is symmetric for text port.");
				}
			}
		}
smorlat's avatar
smorlat committed
536
		close_socket(sock1);
537
		if (sock2!=-1) close_socket(sock2);
538
		if (sock3!=-1) close_socket(sock3);
Simon Morlat's avatar
Simon Morlat committed
539
		return ret;
smorlat's avatar
smorlat committed
540
	}
Simon Morlat's avatar
Simon Morlat committed
541
	return -1;
smorlat's avatar
smorlat committed
542 543
}

544 545 546 547 548 549 550 551 552 553
int linphone_core_get_edge_bw(LinphoneCore *lc){
	int edge_bw=lp_config_get_int(lc->config,"net","edge_bw",20);
	return edge_bw;
}

int linphone_core_get_edge_ptime(LinphoneCore *lc){
	int edge_ptime=lp_config_get_int(lc->config,"net","edge_ptime",100);
	return edge_ptime;
}

Simon Morlat's avatar
Simon Morlat committed
554
void linphone_core_adapt_to_network(LinphoneCore *lc, int ping_time_ms, LinphoneCallParams *params){
Sylvain Berfini's avatar
Sylvain Berfini committed
555
	int threshold;
556
	if (ping_time_ms>0 && lp_config_get_int(lc->config,"net","activate_edge_workarounds",0)==1){
557
		ms_message("Stun server ping time is %i ms",ping_time_ms);
Sylvain Berfini's avatar
Sylvain Berfini committed
558
		threshold=lp_config_get_int(lc->config,"net","edge_ping_time",500);
559

Simon Morlat's avatar
Simon Morlat committed
560
		if (ping_time_ms>threshold){
561
			/* we might be in a 2G network*/
jehan's avatar
jehan committed
562
			params->low_bandwidth=TRUE;
Simon Morlat's avatar
Simon Morlat committed
563 564
		}/*else use default settings */
	}
565 566 567 568 569
	if (params->low_bandwidth){
		params->up_bw=params->down_bw=linphone_core_get_edge_bw(lc);
		params->up_ptime=params->down_ptime=linphone_core_get_edge_ptime(lc);
		params->has_video=FALSE;
	}
Simon Morlat's avatar
Simon Morlat committed
570 571 572
}


573
void linphone_core_resolve_stun_server(LinphoneCore *lc){
574 575 576
	if (lc->nat_policy != NULL) {
		linphone_nat_policy_resolve_stun_server(lc->nat_policy);
	} else {
577
		ms_error("linphone_core_resolve_stun_server(): called without nat_policy, this should not happen.");
578 579 580 581
	}
}

const struct addrinfo *linphone_core_get_stun_server_addrinfo(LinphoneCore *lc){
582 583 584
	if (lc->nat_policy != NULL) {
		return linphone_nat_policy_get_stun_server_addrinfo(lc->nat_policy);
	} else {
585
		ms_error("linphone_core_get_stun_server_addrinfo(): called without nat_policy, this should not happen.");
586
	}
587
	return NULL;
588
}
Simon Morlat's avatar
Simon Morlat committed
589

590 591 592 593
void linphone_core_enable_forced_ice_relay(LinphoneCore *lc, bool_t enable) {
	lc->forced_ice_relay = enable;
}

594 595 596 597
void linphone_core_enable_short_turn_refresh(LinphoneCore *lc, bool_t enable) {
	lc->short_turn_refresh = enable;
}

598 599
static void stun_auth_requested_cb(LinphoneCall *call, const char *realm, const char *nonce, const char **username, const char **password, const char **ha1) {
	LinphoneProxyConfig *proxy = NULL;
600
	const LinphoneNatPolicy *nat_policy = NULL;
601 602 603
	const LinphoneAddress *addr = NULL;
	const LinphoneAuthInfo *auth_info = NULL;
	LinphoneCore *lc = call->core;
Ghislain MARY's avatar
Ghislain MARY committed
604
	const char *user = NULL;
605

606
	// Get the username from the nat policy or the proxy config
607 608 609
	if (call->dest_proxy != NULL) proxy = call->dest_proxy;
	else proxy = linphone_core_get_default_proxy_config(call->core);
	if (proxy == NULL) return;
610 611 612 613 614 615 616 617 618 619 620 621 622 623 624
	nat_policy = linphone_proxy_config_get_nat_policy(proxy);
	if (nat_policy != NULL) {
		user = linphone_nat_policy_get_stun_server_username(nat_policy);
	} else {
		nat_policy = linphone_core_get_nat_policy(call->core);
		if (nat_policy != NULL) {
			user = linphone_nat_policy_get_stun_server_username(nat_policy);
		}
	}
	if (user == NULL) {
		/* If the username has not been found in the nat_policy, take the username from the currently used proxy config. */
		addr = linphone_proxy_config_get_identity_address(proxy);
		if (addr == NULL) return;
		user = linphone_address_get_username(addr);
	}
625 626 627 628 629 630 631 632 633 634 635 636 637 638 639 640
	if (user == NULL) return;

	auth_info = linphone_core_find_auth_info(lc, realm, user, NULL);
	if (auth_info != NULL) {
		const char *hash = linphone_auth_info_get_ha1(auth_info);
		if (hash != NULL) {
			*ha1 = hash;
		} else {
			*password = linphone_auth_info_get_passwd(auth_info);
		}
		*username = user;
	} else {
		ms_warning("No auth info found for STUN auth request");
	}
}

Ghislain MARY's avatar
Ghislain MARY committed
641 642 643 644 645 646 647 648 649 650 651 652 653 654 655 656 657 658 659 660 661 662 663 664 665 666 667 668 669 670 671 672 673 674 675 676 677 678 679 680 681 682 683
static void linphone_core_add_local_ice_candidates(LinphoneCall *call, int family, const char *addr, IceCheckList *audio_cl, IceCheckList *video_cl, IceCheckList *text_cl) {
	if ((ice_check_list_state(audio_cl) != ICL_Completed) && (ice_check_list_candidates_gathered(audio_cl) == FALSE)) {
		ice_add_local_candidate(audio_cl, "host", family, addr, call->media_ports[call->main_audio_stream_index].rtp_port, 1, NULL);
		ice_add_local_candidate(audio_cl, "host", family, addr, call->media_ports[call->main_audio_stream_index].rtcp_port, 2, NULL);
		call->stats[LINPHONE_CALL_STATS_AUDIO].ice_state = LinphoneIceStateInProgress;
	}
	if (linphone_core_video_enabled(call->core) && (video_cl != NULL)
		&& (ice_check_list_state(video_cl) != ICL_Completed) && (ice_check_list_candidates_gathered(video_cl) == FALSE)) {
		ice_add_local_candidate(video_cl, "host", family, addr, call->media_ports[call->main_video_stream_index].rtp_port, 1, NULL);
		ice_add_local_candidate(video_cl, "host", family, addr, call->media_ports[call->main_video_stream_index].rtcp_port, 2, NULL);
		call->stats[LINPHONE_CALL_STATS_VIDEO].ice_state = LinphoneIceStateInProgress;
	}
	if (call->params->realtimetext_enabled && (text_cl != NULL)
		&& (ice_check_list_state(text_cl) != ICL_Completed) && (ice_check_list_candidates_gathered(text_cl) == FALSE)) {
		ice_add_local_candidate(text_cl, "host", family, addr, call->media_ports[call->main_text_stream_index].rtp_port, 1, NULL);
		ice_add_local_candidate(text_cl, "host", family, addr, call->media_ports[call->main_text_stream_index].rtcp_port, 2, NULL);
		call->stats[LINPHONE_CALL_STATS_TEXT].ice_state = LinphoneIceStateInProgress;
	}
}

static const struct addrinfo * get_preferred_stun_server_addrinfo(const struct addrinfo *ai) {
	char ip[NI_MAXHOST];
	const struct addrinfo *preferred_ai = NULL;

	while (ai != NULL) {
		bctbx_addrinfo_to_printable_ip_address(ai, ip, sizeof(ip));
		if (ai->ai_family == AF_INET) {
			preferred_ai = ai;
			break;
		}
		else if (ai->ai_family == AF_INET6) {
			struct sockaddr_storage ss;
			socklen_t sslen = sizeof(ss);
			bctbx_sockaddr_ipv6_to_ipv4(ai->ai_addr, (struct sockaddr *)&ss, &sslen);
			if ((ss.ss_family == AF_INET) && (preferred_ai == NULL)) preferred_ai = ai;
		}
		ai = ai->ai_next;
	}

	bctbx_addrinfo_to_printable_ip_address(preferred_ai, ip, sizeof(ip));
	return preferred_ai;
}

684 685 686 687 688
/* Return values:
 * 1 :  STUN gathering is started
 * 0 :  no STUN gathering is started, but it's ok to proceed with ICE anyway (with local candidates only or because STUN gathering was already done before)
 * -1: no gathering started and something went wrong with local candidates. There is no way to start the ICE session.
 */
689
int linphone_core_gather_ice_candidates(LinphoneCore *lc, LinphoneCall *call){
690
	char local_addr[64];
691
	const struct addrinfo *ai = NULL;
Ghislain MARY's avatar
Ghislain MARY committed
692 693 694
	IceCheckList *audio_cl;
	IceCheckList *video_cl;
	IceCheckList *text_cl;
695 696 697 698 699 700
	LinphoneNatPolicy *nat_policy = NULL;
	const char *server = NULL;

	if (call->dest_proxy != NULL) nat_policy = linphone_proxy_config_get_nat_policy(call->dest_proxy);
	if (nat_policy == NULL) nat_policy = linphone_core_get_nat_policy(lc);
	if (nat_policy != NULL) server = linphone_nat_policy_get_stun_server(nat_policy);
701

702
	if (call->ice_session == NULL) return -1;
Ghislain MARY's avatar
Ghislain MARY committed
703 704 705 706
	audio_cl = ice_session_check_list(call->ice_session, call->main_audio_stream_index);
	video_cl = ice_session_check_list(call->ice_session, call->main_video_stream_index);
	text_cl = ice_session_check_list(call->ice_session, call->main_text_stream_index);
	if (audio_cl == NULL) return -1;
707

708 709
	if ((nat_policy != NULL) && (server != NULL) && (server[0] != '\0')) {
		ai=linphone_nat_policy_get_stun_server_addrinfo(nat_policy);
710 711
		if (ai==NULL){
			ms_warning("Fail to resolve STUN server for ICE gathering, continuing without stun.");
Ghislain MARY's avatar
Ghislain MARY committed
712 713
		} else {
			ai = get_preferred_stun_server_addrinfo(ai);
714 715 716
		}
	}else{
		ms_warning("Ice is used without stun server.");
717
	}
718
	linphone_core_notify_display_status(lc, _("ICE local candidates gathering in progress..."));
719

720
	ice_session_enable_forced_relay(call->ice_session, lc->forced_ice_relay);
721
	ice_session_enable_short_turn_refresh(call->ice_session, lc->short_turn_refresh);
722

723
	/* Gather local host candidates. */
Ghislain MARY's avatar
Ghislain MARY committed
724 725 726 727 728 729 730
	if (call->af == AF_INET6) {
		if (linphone_core_get_local_ip_for(AF_INET6, NULL, local_addr) < 0) {
			ms_error("Fail to get local IPv6");
			return -1;
		} else {
			linphone_core_add_local_ice_candidates(call, AF_INET6, local_addr, audio_cl, video_cl, text_cl);
		}
731
	}
Ghislain MARY's avatar
Ghislain MARY committed
732 733 734 735 736 737 738
	if (linphone_core_get_local_ip_for(AF_INET, NULL, local_addr) < 0) {
		if (call->af != AF_INET6) {
			ms_error("Fail to get local IPv4");
			return -1;
		}
	} else {
		linphone_core_add_local_ice_candidates(call, AF_INET, local_addr, audio_cl, video_cl, text_cl);
739
	}
740 741
	if ((ai != NULL) && (nat_policy != NULL)
		&& (linphone_nat_policy_stun_enabled(nat_policy) || linphone_nat_policy_turn_enabled(nat_policy))) {
742
		bool_t gathering_in_progress;
743
		ms_message("ICE: gathering candidate from [%s] using %s", server, linphone_nat_policy_turn_enabled(nat_policy) ? "TURN" : "STUN");
744
		/* Gather local srflx candidates. */
745
		ice_session_enable_turn(call->ice_session, linphone_nat_policy_turn_enabled(nat_policy));
746
		ice_session_set_stun_auth_requested_cb(call->ice_session, (MSStunAuthRequestedCb)stun_auth_requested_cb, call);
747 748
		gathering_in_progress = ice_session_gather_candidates(call->ice_session, ai->ai_addr, (socklen_t)ai->ai_addrlen);
		return (gathering_in_progress == FALSE) ? 0 : 1;
749 750 751 752 753
	} else {
		ms_message("ICE: bypass candidates gathering");
		ice_session_compute_candidates_foundations(call->ice_session);
		ice_session_eliminate_redundant_candidates(call->ice_session);
		ice_session_choose_default_candidates(call->ice_session);
754
	}
755
	return 0;
756 757
}

758 759 760 761 762 763 764 765 766 767 768 769 770 771 772 773 774 775
const char *linphone_ice_state_to_string(LinphoneIceState state){
	switch(state){
		case LinphoneIceStateFailed:
			return "IceStateFailed";
		case LinphoneIceStateHostConnection:
			return "IceStateHostConnection";
		case LinphoneIceStateInProgress:
			return "IceStateInProgress";
		case LinphoneIceStateNotActivated:
			return "IceStateNotActivated";
		case LinphoneIceStateReflexiveConnection:
			return "IceStateReflexiveConnection";
		case LinphoneIceStateRelayConnection:
			return "IceStateRelayConnection";
	}
	return "invalid";
}

776 777 778 779
void linphone_core_update_ice_state_in_call_stats(LinphoneCall *call)
{
	IceCheckList *audio_check_list;
	IceCheckList *video_check_list;
780
	IceCheckList *text_check_list;
Ghislain MARY's avatar
Ghislain MARY committed
781
	IceSessionState session_state;
782 783

	if (call->ice_session == NULL) return;
784 785
	audio_check_list = ice_session_check_list(call->ice_session, call->main_audio_stream_index);
	video_check_list = ice_session_check_list(call->ice_session, call->main_video_stream_index);
786
	text_check_list = ice_session_check_list(call->ice_session, call->main_text_stream_index);
787 788
	if (audio_check_list == NULL) return;

Ghislain MARY's avatar
Ghislain MARY committed
789 790
	session_state = ice_session_state(call->ice_session);
	if ((session_state == IS_Completed) || ((session_state == IS_Failed) && (ice_session_has_completed_check_list(call->ice_session) == TRUE))) {
791 792 793 794 795 796 797 798 799 800 801 802 803
		if (call->params->has_audio && (audio_check_list != NULL)) {
			if (ice_check_list_state(audio_check_list) == ICL_Completed) {
				switch (ice_check_list_selected_valid_candidate_type(audio_check_list)) {
					case ICT_HostCandidate:
						call->stats[LINPHONE_CALL_STATS_AUDIO].ice_state = LinphoneIceStateHostConnection;
						break;
					case ICT_ServerReflexiveCandidate:
					case ICT_PeerReflexiveCandidate:
						call->stats[LINPHONE_CALL_STATS_AUDIO].ice_state = LinphoneIceStateReflexiveConnection;
						break;
					case ICT_RelayedCandidate:
						call->stats[LINPHONE_CALL_STATS_AUDIO].ice_state = LinphoneIceStateRelayConnection;
						break;
804 805 806 807
					case ICT_CandidateInvalid:
					case ICT_CandidateTypeMax:
						/*shall not happen*/
						break;
808 809 810
				}
			} else {
				call->stats[LINPHONE_CALL_STATS_AUDIO].ice_state = LinphoneIceStateFailed;
Ghislain MARY's avatar
Ghislain MARY committed
811
			}
812 813
		}else call->stats[LINPHONE_CALL_STATS_AUDIO].ice_state = LinphoneIceStateNotActivated;
		
814
		if (call->params->has_video && (video_check_list != NULL)) {
815 816 817 818 819 820 821 822 823 824 825 826
			if (ice_check_list_state(video_check_list) == ICL_Completed) {
				switch (ice_check_list_selected_valid_candidate_type(video_check_list)) {
					case ICT_HostCandidate:
						call->stats[LINPHONE_CALL_STATS_VIDEO].ice_state = LinphoneIceStateHostConnection;
						break;
					case ICT_ServerReflexiveCandidate:
					case ICT_PeerReflexiveCandidate:
						call->stats[LINPHONE_CALL_STATS_VIDEO].ice_state = LinphoneIceStateReflexiveConnection;
						break;
					case ICT_RelayedCandidate:
						call->stats[LINPHONE_CALL_STATS_VIDEO].ice_state = LinphoneIceStateRelayConnection;
						break;
827 828 829 830
					case ICT_CandidateInvalid:
					case ICT_CandidateTypeMax:
						/*shall not happen*/
						break;
831 832 833 834
				}
			} else {
				call->stats[LINPHONE_CALL_STATS_VIDEO].ice_state = LinphoneIceStateFailed;
			}
Simon Morlat's avatar
Simon Morlat committed
835
		}else call->stats[LINPHONE_CALL_STATS_VIDEO].ice_state = LinphoneIceStateNotActivated;
836 837 838 839 840 841 842 843 844 845 846 847 848 849
		
		if (call->params->realtimetext_enabled && (text_check_list != NULL)) {
			if (ice_check_list_state(text_check_list) == ICL_Completed) {
				switch (ice_check_list_selected_valid_candidate_type(text_check_list)) {
					case ICT_HostCandidate:
						call->stats[LINPHONE_CALL_STATS_TEXT].ice_state = LinphoneIceStateHostConnection;
						break;
					case ICT_ServerReflexiveCandidate:
					case ICT_PeerReflexiveCandidate:
						call->stats[LINPHONE_CALL_STATS_TEXT].ice_state = LinphoneIceStateReflexiveConnection;
						break;
					case ICT_RelayedCandidate:
						call->stats[LINPHONE_CALL_STATS_TEXT].ice_state = LinphoneIceStateRelayConnection;
						break;
850 851 852 853
					case ICT_CandidateInvalid:
					case ICT_CandidateTypeMax:
						/*shall not happen*/
						break;
854 855 856 857 858
				}
			} else {
				call->stats[LINPHONE_CALL_STATS_TEXT].ice_state = LinphoneIceStateFailed;
			}
		}else call->stats[LINPHONE_CALL_STATS_TEXT].ice_state = LinphoneIceStateNotActivated;
859 860
	} else if (session_state == IS_Running) {
		call->stats[LINPHONE_CALL_STATS_AUDIO].ice_state = LinphoneIceStateInProgress;
861
		if (call->params->has_video && (video_check_list != NULL)) {
862 863
			call->stats[LINPHONE_CALL_STATS_VIDEO].ice_state = LinphoneIceStateInProgress;
		}
864 865 866
		if (call->params->realtimetext_enabled && (text_check_list != NULL)) {
			call->stats[LINPHONE_CALL_STATS_TEXT].ice_state = LinphoneIceStateInProgress;
		}
Ghislain MARY's avatar
Ghislain MARY committed
867 868
	} else {
		call->stats[LINPHONE_CALL_STATS_AUDIO].ice_state = LinphoneIceStateFailed;
869
		if (call->params->has_video && (video_check_list != NULL)) {
Ghislain MARY's avatar
Ghislain MARY committed
870 871
			call->stats[LINPHONE_CALL_STATS_VIDEO].ice_state = LinphoneIceStateFailed;
		}
872 873 874
		if (call->params->realtimetext_enabled && (text_check_list != NULL)) {
			call->stats[LINPHONE_CALL_STATS_TEXT].ice_state = LinphoneIceStateFailed;
		}
875
	}
876 877
	ms_message("Call [%p] New ICE state: audio: [%s]    video: [%s]    text: [%s]", call,
		   linphone_ice_state_to_string(call->stats[LINPHONE_CALL_STATS_AUDIO].ice_state), linphone_ice_state_to_string(call->stats[LINPHONE_CALL_STATS_VIDEO].ice_state), linphone_ice_state_to_string(call->stats[LINPHONE_CALL_STATS_TEXT].ice_state));
878 879
}

Simon Morlat's avatar
Simon Morlat committed
880
void linphone_call_stop_ice_for_inactive_streams(LinphoneCall *call, SalMediaDescription *desc) {
Ghislain MARY's avatar
Ghislain MARY committed
881
	int i;
Simon Morlat's avatar
Simon Morlat committed
882
	IceSession *session = call->ice_session;
883

Ghislain MARY's avatar
Ghislain MARY committed
884 885 886
	if (session == NULL) return;
	if (ice_session_state(session) == IS_Completed) return;

887
	for (i = 0; i < desc->nb_streams; i++) {
Ghislain MARY's avatar
Ghislain MARY committed
888 889 890
		IceCheckList *cl = ice_session_check_list(session, i);