misc.c 66.2 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 73 74 75 76 77
bool_t linphone_core_payload_type_is_vbr(LinphoneCore *lc, const LinphonePayloadType *pt) {
	return linphone_payload_type_is_vbr(pt);
}

bool_t linphone_payload_type_is_vbr(const LinphonePayloadType *pt) {
	if (pt->type == PAYLOAD_VIDEO) return TRUE;
78 79 80
	return !!(pt->flags & PAYLOAD_TYPE_IS_VBR);
}

81
int linphone_core_enable_payload_type(LinphoneCore *lc, LinphonePayloadType *pt, bool_t enabled){
82
	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)){
83
		payload_type_set_enable(pt,enabled);
84
		_linphone_core_codec_config_write(lc);
85
		linphone_core_update_allocated_audio_bandwidth(lc);
86 87 88 89
		return 0;
	}
	ms_error("Enabling codec not in audio or video list of PayloadType !");
	return -1;
aymeric's avatar
aymeric committed
90 91
}

92 93 94 95
int linphone_core_get_payload_type_number(LinphoneCore *lc, const PayloadType *pt) {
	return linphone_payload_type_get_number(pt);
}

96
int linphone_payload_type_get_number(const LinphonePayloadType *pt) {
97
	return payload_type_get_number(pt);
98 99
}

100 101 102 103
void linphone_core_set_payload_type_number(LinphoneCore *lc, PayloadType *pt, int number) {
	linphone_payload_type_set_number(pt, number);
}

104
void linphone_payload_type_set_number(LinphonePayloadType *pt, int number) {
105
	payload_type_set_number(pt, number);
106 107
}

108
const char *linphone_core_get_payload_type_description(LinphoneCore *lc, PayloadType *pt){
109 110 111
	//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);
112
#ifdef ENABLE_NLS
113 114 115 116
		return dgettext("mediastreamer",desc->text);
#else
		return desc->text;
#endif
117 118
	}
	return NULL;
aymeric's avatar
aymeric committed
119 120
}

121
void linphone_core_set_payload_type_bitrate(LinphoneCore *lc, LinphonePayloadType *pt, int bitrate){
122
	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)){
123
		if (pt->type==PAYLOAD_VIDEO || pt->flags & PAYLOAD_TYPE_IS_VBR){
124 125
			pt->normal_bitrate=bitrate*1000;
			pt->flags|=PAYLOAD_TYPE_BITRATE_OVERRIDE;
126
			linphone_core_update_allocated_audio_bandwidth(lc);
127 128
		}else{
			ms_error("Cannot set an explicit bitrate for codec %s/%i, because it is not VBR.",pt->mime_type,pt->clock_rate);
129
			return;
130
		}
Guillaume BIENKOWSKI's avatar
Guillaume BIENKOWSKI committed
131 132
	} else {
		ms_error("linphone_core_set_payload_type_bitrate() payload type not in audio or video list !");
133 134 135
	}
}

136

137 138 139 140
/*
 *((codec-birate*ptime/8) + RTP header + UDP header + IP header)*8/ptime;
 *ptime=1/npacket
 */
141 142

static double get_audio_payload_bandwidth_from_codec_bitrate(const PayloadType *pt){
aymeric's avatar
aymeric committed
143 144 145
	double npacket=50;
	double packet_size;
	int bitrate;
146

147 148 149
	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;
150 151
	}else if (strcmp(payload_type_get_mime(&payload_type_ilbc), payload_type_get_mime(pt))==0) {
		npacket=1000/30.0;
152
	}
153

154
	bitrate=pt->normal_bitrate;
155
	packet_size= (((double)bitrate)/(npacket*8))+UDP_HDR_SZ+RTP_HDR_SZ+IP4_HDR_SZ;
aymeric's avatar
aymeric committed
156 157 158
	return packet_size*8.0*npacket;
}

159 160 161 162 163 164 165 166 167 168 169 170 171 172 173 174 175 176 177 178 179 180 181 182 183 184 185 186 187 188
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){
189
			ms_debug("PayloadType %s/%i has bitrate override",pt->mime_type,pt->clock_rate);
190 191 192 193 194 195
			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*/
}

196
int linphone_core_get_payload_type_bitrate(LinphoneCore *lc, const LinphonePayloadType *pt){
197 198 199 200 201 202 203 204 205 206 207 208 209 210 211 212 213 214
	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
215
	ms_message("Audio bandwidth for this call is %i",call->audio_bw);
aymeric's avatar
aymeric committed
216 217
}

218
void linphone_core_update_allocated_audio_bandwidth(LinphoneCore *lc){
219
	const bctbx_list_t *elem;
220 221 222
	int maxbw=get_min_bandwidth(linphone_core_get_download_bandwidth(lc),
					linphone_core_get_upload_bandwidth(lc));
	int max_codec_bitrate=0;
223

aymeric's avatar
aymeric committed
224 225 226
	for(elem=linphone_core_get_audio_codecs(lc);elem!=NULL;elem=elem->next){
		PayloadType *pt=(PayloadType*)elem->data;
		if (payload_type_enabled(pt)){
227 228 229 230 231
			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
232 233 234
			}
		}
	}
235 236
	if (max_codec_bitrate) {
		lc->audio_bw=max_codec_bitrate;
aymeric's avatar
aymeric committed
237 238 239
	}
}

240
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
241
	double codec_band;
242
	const int video_enablement_limit = 99;
Simon Morlat's avatar
Simon Morlat committed
243
	bool_t ret=FALSE;
244

Simon Morlat's avatar
Simon Morlat committed
245 246 247
	switch (pt->type){
		case PAYLOAD_AUDIO_CONTINUOUS:
		case PAYLOAD_AUDIO_PACKETIZED:
248
			codec_band=get_audio_payload_bandwidth(lc,pt,bandwidth_limit);
249
			ret=bandwidth_is_greater(bandwidth_limit,(int)codec_band);
250
			/*ms_message("Payload %s: codec_bandwidth=%g, bandwidth_limit=%i",pt->mime_type,codec_band,bandwidth_limit);*/
Simon Morlat's avatar
Simon Morlat committed
251 252
			break;
		case PAYLOAD_VIDEO:
253
			if (bandwidth_limit<=0 || bandwidth_limit >= video_enablement_limit) {/* infinite or greater than video_enablement_limit*/
Simon Morlat's avatar
Simon Morlat committed
254 255 256 257
				ret=TRUE;
			}
			else ret=FALSE;
			break;
Sylvain Berfini's avatar
Sylvain Berfini committed
258 259 260
		case PAYLOAD_TEXT:
			ret=TRUE;
			break;
Simon Morlat's avatar
Simon Morlat committed
261 262 263 264
	}
	return ret;
}

265
bool_t linphone_core_check_payload_type_usability(LinphoneCore *lc, const PayloadType *pt){
266 267 268
	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);
269
	if ((pt->type==PAYLOAD_AUDIO_CONTINUOUS || pt->type==PAYLOAD_AUDIO_PACKETIZED)
270
		&& lc->sound_conf.capt_sndcard
271 272 273 274
		&& !(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
275
		&& ms_factory_lookup_filter_by_name(lc->factory, "MSWebRTCAEC")!=NULL){
276 277 278 279 280
		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
281 282 283
}

bool_t lp_spawn_command_line_sync(const char *command, char **result,int *command_ret){
284
#if !defined(_WIN32_WCE) && !defined(LINPHONE_WINDOWS_UNIVERSAL)
aymeric's avatar
aymeric committed
285 286 287 288
	FILE *f=popen(command,"r");
	if (f!=NULL){
		int err;
		*result=ms_malloc(4096);
Ghislain MARY's avatar
Ghislain MARY committed
289
		err=(int)fread(*result,1,4096-1,f);
aymeric's avatar
aymeric committed
290 291 292 293 294 295 296 297 298 299
		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;
	}
300
#endif /*_WIN32_WCE*/
aymeric's avatar
aymeric committed
301 302 303
	return FALSE;
}

smorlat's avatar
smorlat committed
304 305 306 307 308 309 310 311 312 313 314 315 316 317
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
318
		ms_error("Bind socket to 0.0.0.0:%i failed: %s",local_port,getSocketError());
smorlat's avatar
smorlat committed
319 320 321 322 323 324 325 326 327 328 329 330
		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
331 332
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
333
	size_t len;
Ghislain MARY's avatar
Ghislain MARY committed
334 335 336 337 338 339 340 341 342
	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
343
		ms_error("Fail to encode stun message.");
Ghislain MARY's avatar
Ghislain MARY committed
344 345
		err = -1;
	} else {
Ghislain MARY's avatar
Ghislain MARY committed
346
		err = bctbx_sendto(sock, buf, len, 0, server, addrlen);
Ghislain MARY's avatar
Ghislain MARY committed
347 348 349 350
		if (err < 0) {
			ms_error("sendto failed: %s",strerror(errno));
			err = -1;
		}
smorlat's avatar
smorlat committed
351
	}
Ghislain MARY's avatar
Ghislain MARY committed
352 353 354
	if (buf != NULL) ms_free(buf);
	ms_free(req);
	return err;
smorlat's avatar
smorlat committed
355 356
}

357 358
int linphone_parse_host_port(const char *input, char *host, size_t hostlen, int *port){
	char tmphost[NI_MAXHOST]={0};
359
	char *p1, *p2;
360

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

363
	} else {
364 365 366 367 368 369 370
		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);
371 372
		}
	}
373 374 375 376 377 378 379 380 381 382
	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;
383

384
	linphone_parse_host_port(server,host,sizeof(host),&port_int);
385

386
	snprintf(port, sizeof(port), "%d", port_int);
smorlat's avatar
smorlat committed
387
	memset(&hints,0,sizeof(hints));
388
	hints.ai_family=AF_UNSPEC;
smorlat's avatar
smorlat committed
389 390 391 392 393 394 395 396 397
	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);
398
	*socklen=(socklen_t)res->ai_addrlen;
smorlat's avatar
smorlat committed
399 400 401 402
	freeaddrinfo(res);
	return 0;
}

Ghislain MARY's avatar
Ghislain MARY committed
403 404 405 406 407 408 409
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
410
		struct in_addr ia;
Ghislain MARY's avatar
Ghislain MARY committed
411
		resp = ms_stun_message_create_from_buffer_parsing((uint8_t *)buf, (ssize_t)len);
Ghislain MARY's avatar
Ghislain MARY committed
412 413 414 415 416 417
		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) {
418 419
				*port = stun_addr->ip.v4.port;
				ia.s_addr = htonl(stun_addr->ip.v4.addr);
Ghislain MARY's avatar
Ghislain MARY committed
420 421 422
			} else {
				stun_addr = ms_stun_message_get_mapped_address(resp);
				if (stun_addr != NULL) {
423 424
					*port = stun_addr->ip.v4.port;
					ia.s_addr = htonl(stun_addr->ip.v4.addr);
Ghislain MARY's avatar
Ghislain MARY committed
425 426 427 428
				} else len = -1;
			}
			if (len > 0) strncpy(ipaddr, inet_ntoa(ia), LINPHONE_IPADDR_SIZE);
		}
smorlat's avatar
smorlat committed
429 430 431 432
	}
	return len;
}

Simon Morlat's avatar
Simon Morlat committed
433
/* this functions runs a simple stun test and return the number of milliseconds to complete the tests, or -1 if the test were failed.*/
434
int linphone_core_run_stun_tests(LinphoneCore *lc, LinphoneCall *call){
smorlat's avatar
smorlat committed
435
	const char *server=linphone_core_get_stun_server(lc);
436 437
	StunCandidate *ac=&call->ac;
	StunCandidate *vc=&call->vc;
438
	StunCandidate *tc=&call->tc;
439

smorlat's avatar
smorlat committed
440 441
	if (lc->sip_conf.ipv6_enabled){
		ms_warning("stun support is not implemented for ipv6");
Simon Morlat's avatar
Simon Morlat committed
442
		return -1;
smorlat's avatar
smorlat committed
443
	}
444
	if (call->media_ports[call->main_audio_stream_index].rtp_port==-1){
445 446 447
		ms_warning("Stun-only support not available for system random port");
		return -1;
	}
smorlat's avatar
smorlat committed
448
	if (server!=NULL){
449
		const struct addrinfo *ai=linphone_core_get_stun_server_addrinfo(lc);
450
		ortp_socket_t sock1=-1, sock2=-1, sock3=-1;
451
		int loops=0;
smorlat's avatar
smorlat committed
452
		bool_t video_enabled=linphone_core_video_enabled(lc);
453 454
		bool_t got_audio,got_video,got_text;
		bool_t cone_audio=FALSE,cone_video=FALSE,cone_text=FALSE;
smorlat's avatar
smorlat committed
455
		struct timeval init,cur;
Simon Morlat's avatar
Simon Morlat committed
456 457
		double elapsed;
		int ret=0;
458

459 460
		if (ai==NULL){
			ms_error("Could not obtain stun server addrinfo.");
Simon Morlat's avatar
Simon Morlat committed
461
			return -1;
smorlat's avatar
smorlat committed
462
		}
463
		linphone_core_notify_display_status(lc,_("Stun lookup in progress..."));
464

smorlat's avatar
smorlat committed
465
		/*create the two audio and video RTP sockets, and send STUN message to our stun server */
466
		sock1=create_socket(call->media_ports[call->main_audio_stream_index].rtp_port);
Simon Morlat's avatar
Simon Morlat committed
467
		if (sock1==-1) return -1;
smorlat's avatar
smorlat committed
468
		if (video_enabled){
469
			sock2=create_socket(call->media_ports[call->main_video_stream_index].rtp_port);
Simon Morlat's avatar
Simon Morlat committed
470
			if (sock2==-1) return -1;
smorlat's avatar
smorlat committed
471
		}
Sylvain Berfini's avatar
Sylvain Berfini committed
472 473 474
		sock3=create_socket(call->media_ports[call->main_text_stream_index].rtp_port);
		if (sock3==-1) return -1;
		
smorlat's avatar
smorlat committed
475 476
		got_audio=FALSE;
		got_video=FALSE;
477
		got_text=FALSE;
478
		ortp_gettimeofday(&init,NULL);
smorlat's avatar
smorlat committed
479
		do{
480

smorlat's avatar
smorlat committed
481
			int id;
482 483
			if (loops%20==0){
				ms_message("Sending stun requests...");
Ghislain MARY's avatar
Ghislain MARY committed
484 485
				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);
486
				if (sock2!=-1){
Ghislain MARY's avatar
Ghislain MARY committed
487 488
					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);
489
				}
490
				if (sock3!=-1){
Ghislain MARY's avatar
Ghislain MARY committed
491 492
					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);
493
				}
494
			}
495
			ms_usleep(10000);
smorlat's avatar
smorlat committed
496

Ghislain MARY's avatar
Ghislain MARY committed
497 498 499
			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
500 501
				got_audio=TRUE;
			}
Ghislain MARY's avatar
Ghislain MARY committed
502 503 504
			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
505
				got_video=TRUE;
smorlat's avatar
smorlat committed
506
			}
Ghislain MARY's avatar
Ghislain MARY committed
507 508 509
			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;
510 511
				got_text=TRUE;
			}
512
			ortp_gettimeofday(&cur,NULL);
smorlat's avatar
smorlat committed
513
			elapsed=((cur.tv_sec-init.tv_sec)*1000.0) +  ((cur.tv_usec-init.tv_usec)/1000.0);
514 515
			if (elapsed>2000)  {
				ms_message("Stun responses timeout, going ahead.");
Simon Morlat's avatar
Simon Morlat committed
516
				ret=-1;
517 518 519
				break;
			}
			loops++;
520
		}while(!(got_audio && (got_video||sock2==-1) && (got_text||sock3==-1)  ) );
Simon Morlat's avatar
Simon Morlat committed
521
		if (ret==0) ret=(int)elapsed;
smorlat's avatar
smorlat committed
522 523
		if (!got_audio){
			ms_error("No stun server response for audio port.");
smorlat's avatar
smorlat committed
524 525
		}else{
			if (!cone_audio) {
526
				ms_message("NAT is symmetric for audio port");
smorlat's avatar
smorlat committed
527
			}
smorlat's avatar
smorlat committed
528
		}
529
		if (sock2!=-1){
smorlat's avatar
smorlat committed
530 531 532 533
			if (!got_video){
				ms_error("No stun server response for video port.");
			}else{
				if (!cone_video) {
534
					ms_message("NAT is symmetric for video port.");
smorlat's avatar
smorlat committed
535 536
				}
			}
smorlat's avatar
smorlat committed
537
		}
538 539 540 541 542 543 544 545 546
		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
547
		close_socket(sock1);
548
		if (sock2!=-1) close_socket(sock2);
549
		if (sock3!=-1) close_socket(sock3);
Simon Morlat's avatar
Simon Morlat committed
550
		return ret;
smorlat's avatar
smorlat committed
551
	}
Simon Morlat's avatar
Simon Morlat committed
552
	return -1;
smorlat's avatar
smorlat committed
553 554
}

555 556 557 558 559 560 561 562 563 564
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
565
void linphone_core_adapt_to_network(LinphoneCore *lc, int ping_time_ms, LinphoneCallParams *params){
Sylvain Berfini's avatar
Sylvain Berfini committed
566
	int threshold;
567
	if (ping_time_ms>0 && lp_config_get_int(lc->config,"net","activate_edge_workarounds",0)==1){
568
		ms_message("Stun server ping time is %i ms",ping_time_ms);
Sylvain Berfini's avatar
Sylvain Berfini committed
569
		threshold=lp_config_get_int(lc->config,"net","edge_ping_time",500);
570

Simon Morlat's avatar
Simon Morlat committed
571
		if (ping_time_ms>threshold){
572
			/* we might be in a 2G network*/
jehan's avatar
jehan committed
573
			params->low_bandwidth=TRUE;
Simon Morlat's avatar
Simon Morlat committed
574 575
		}/*else use default settings */
	}
576 577 578 579 580
	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
581 582 583
}


584
void linphone_core_resolve_stun_server(LinphoneCore *lc){
585 586 587
	if (lc->nat_policy != NULL) {
		linphone_nat_policy_resolve_stun_server(lc->nat_policy);
	} else {
588
		ms_error("linphone_core_resolve_stun_server(): called without nat_policy, this should not happen.");
589 590 591 592
	}
}

const struct addrinfo *linphone_core_get_stun_server_addrinfo(LinphoneCore *lc){
593 594 595
	if (lc->nat_policy != NULL) {
		return linphone_nat_policy_get_stun_server_addrinfo(lc->nat_policy);
	} else {
596
		ms_error("linphone_core_get_stun_server_addrinfo(): called without nat_policy, this should not happen.");
597
	}
598
	return NULL;
599
}
Simon Morlat's avatar
Simon Morlat committed
600

601 602 603 604
void linphone_core_enable_forced_ice_relay(LinphoneCore *lc, bool_t enable) {
	lc->forced_ice_relay = enable;
}

605 606 607 608
void linphone_core_enable_short_turn_refresh(LinphoneCore *lc, bool_t enable) {
	lc->short_turn_refresh = enable;
}

609 610
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;
611
	const LinphoneNatPolicy *nat_policy = NULL;
612 613 614
	const LinphoneAddress *addr = NULL;
	const LinphoneAuthInfo *auth_info = NULL;
	LinphoneCore *lc = call->core;
Ghislain MARY's avatar
Ghislain MARY committed
615
	const char *user = NULL;
616

617
	// Get the username from the nat policy or the proxy config
618 619 620
	if (call->dest_proxy != NULL) proxy = call->dest_proxy;
	else proxy = linphone_core_get_default_proxy_config(call->core);
	if (proxy == NULL) return;
621 622 623 624 625 626 627 628 629 630 631 632 633 634 635
	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);
	}
636 637 638 639 640 641 642 643 644 645 646 647 648 649 650 651
	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
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 684 685 686 687 688 689 690 691 692 693 694
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;
}

695 696 697 698 699
/* 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.
 */
700
int linphone_core_gather_ice_candidates(LinphoneCore *lc, LinphoneCall *call){
701
	char local_addr[64];
702
	const struct addrinfo *ai = NULL;
Ghislain MARY's avatar
Ghislain MARY committed
703 704 705
	IceCheckList *audio_cl;
	IceCheckList *video_cl;
	IceCheckList *text_cl;
706 707 708 709 710 711
	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);
712

713
	if (call->ice_session == NULL) return -1;
Ghislain MARY's avatar
Ghislain MARY committed
714 715 716
	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);
717
	if ((audio_cl == NULL) && (video_cl == NULL) && (text_cl == NULL)) return -1;
718

719 720
	if ((nat_policy != NULL) && (server != NULL) && (server[0] != '\0')) {
		ai=linphone_nat_policy_get_stun_server_addrinfo(nat_policy);
721 722
		if (ai==NULL){
			ms_warning("Fail to resolve STUN server for ICE gathering, continuing without stun.");
Ghislain MARY's avatar
Ghislain MARY committed
723 724
		} else {
			ai = get_preferred_stun_server_addrinfo(ai);
725 726 727
		}
	}else{
		ms_warning("Ice is used without stun server.");
728
	}
729
	linphone_core_notify_display_status(lc, _("ICE local candidates gathering in progress..."));
730

731
	ice_session_enable_forced_relay(call->ice_session, lc->forced_ice_relay);
732
	ice_session_enable_short_turn_refresh(call->ice_session, lc->short_turn_refresh);
733

734
	/* Gather local host candidates. */
Ghislain MARY's avatar
Ghislain MARY committed
735 736 737 738 739 740 741
	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);
		}
742
	}
Ghislain MARY's avatar
Ghislain MARY committed
743 744 745 746 747 748 749
	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);
750
	}
751 752
	if ((ai != NULL) && (nat_policy != NULL)
		&& (linphone_nat_policy_stun_enabled(nat_policy) || linphone_nat_policy_turn_enabled(nat_policy))) {
753
		bool_t gathering_in_progress;
754
		ms_message("ICE: gathering candidate from [%s] using %s", server, linphone_nat_policy_turn_enabled(nat_policy) ? "TURN" : "STUN");
755
		/* Gather local srflx candidates. */
756
		ice_session_enable_turn(call->ice_session, linphone_nat_policy_turn_enabled(nat_policy));
757
		ice_session_set_stun_auth_requested_cb(call->ice_session, (MSStunAuthRequestedCb)stun_auth_requested_cb, call);
758 759
		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;
760 761 762 763 764
	} 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);
765
	}
766
	return 0;
767 768
}

769 770 771 772 773 774 775 776 777 778 779 780 781 782 783 784 785 786
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";
}

787
void linphone_call_update_ice_state_in_call_stats(LinphoneCall *call) {
788 789
	IceCheckList *audio_check_list;
	IceCheckList *video_check_list;
790
	IceCheckList *text_check_list;
Ghislain MARY's avatar
Ghislain MARY committed
791
	IceSessionState session_state;
792 793

	if (call->ice_session == NULL) return;
794 795
	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);
796
	text_check_list = ice_session_check_list(call->ice_session, call->main_text_stream_index);
797
	if ((audio_check_list == NULL) && (video_check_list == NULL) && (text_check_list == NULL)) return;
798

Ghislain MARY's avatar
Ghislain MARY committed
799 800
	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))) {
801 802 803 804 805 806 807 808 809 810 811 812 813
		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;
814 815 816 817
					case ICT_CandidateInvalid:
					case ICT_CandidateTypeMax:
						/*shall not happen*/
						break;
818 819 820
				}
			} else {
				call->stats[LINPHONE_CALL_STATS_AUDIO].ice_state = LinphoneIceStateFailed;
Ghislain MARY's avatar
Ghislain MARY committed
821
			}
822 823
		}else call->stats[LINPHONE_CALL_STATS_AUDIO].ice_state = LinphoneIceStateNotActivated;
		
824
		if (call->params->has_video && (video_check_list != NULL)) {
825 826 827 828 829 830 831 832 833 834 835 836
			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;
837 838 839 840
					case ICT_CandidateInvalid:
					case ICT_CandidateTypeMax:
						/*shall not happen*/
						break;
841 842 843 844
				}
			} else {
				call->stats[LINPHONE_CALL_STATS_VIDEO].ice_state = LinphoneIceStateFailed;
			}
Simon Morlat's avatar
Simon Morlat committed
845
		}else call->stats[LINPHONE_CALL_STATS_VIDEO].ice_state = LinphoneIceStateNotActivated;
846 847 848 849 850 851 852 853 854 855 856 857 858 859
		
		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;
860 861 862 863
					case ICT_CandidateInvalid:
					case ICT_CandidateTypeMax:
						/*shall not happen*/
						break;
864 865 866 867 868
				}
			} else {
				call->stats[LINPHONE_CALL_STATS_TEXT].ice_state = LinphoneIceStateFailed;
			}
		}else call->stats[LINPHONE_CALL_STATS_TEXT].ice_state = LinphoneIceStateNotActivated;
869 870
	} else if (session_state == IS_Running) {
		call->stats[LINPHONE_CALL_STATS_AUDIO].ice_state = LinphoneIceStateInProgress;
871
		if (call->params->has_video && (video_check_list != NULL)) {
872 873
			call->stats[LINPHONE_CALL_STATS_VIDEO].ice_state = LinphoneIceStateInProgress;
		}
874 875 876
		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
877 878
	} else {
		call->stats[LINPHONE_CALL_STATS_AUDIO].ice_state = LinphoneIceStateFailed;
879
		if (call->params->has_video && (video_check_list != NULL)) {
Ghislain MARY's avatar
Ghislain MARY committed
880 881
			call->stats[LINPHONE_CALL_STATS_VIDEO].ice_state = LinphoneIceStateFailed;
		}
882 883 884
		if (call->params->realtimetext_enabled && (text_check_list != NULL)) {
			call->stats[LINPHONE_CALL_STATS_TEXT].ice_state = LinphoneIceStateFailed;
		}
885
	}
886 887
	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));
888 889
}

Simon Morlat's avatar
Simon Morlat committed
890
void linphone_call_stop_ice_for_inactive_streams(LinphoneCall *call, SalMediaDescription *desc) {
Ghislain MARY's avatar
Ghislain MARY committed
891
	int i;
Simon Morlat's avatar
Simon Morlat committed
892
	IceSession *session = call->ice_session;
893

Ghislain MARY's avatar
Ghislain MARY committed
894 895 896
	if (session == NULL) return;
	if (ice_session_state(session) == IS_Completed) return;