Bfcp

CMakeLists.txt

@@ -147,6 +147,7 @@ set(SRCS
   src/auplay.c
   src/ausrc.c
   src/baresip.c
+  src/bfcp.c
   src/bundle.c
   src/call.c
   src/cmd.c

cmake/modules.cmake

@@ -173,6 +173,7 @@ if(WEBRTC_AECM_FOUND)
 endif()
 if(X11_XShm_FOUND)
   list(APPEND MODULES x11)
+  list(APPEND MODULES x11grab)
 endif()
 if(${CMAKE_SYSTEM_NAME} MATCHES "Linux")
   list(APPEND MODULES evdev)

include/baresip.h

@@ -205,6 +205,8 @@ int  call_modify(struct call *call);
 int  call_hold(struct call *call, bool hold);
 int  call_set_video_dir(struct call *call, enum sdp_dir dir);
 int  call_send_digit(struct call *call, char key);
+int  call_send_pfu(struct call *call, const char* content,
+		   const char* label);
 bool call_has_audio(const struct call *call);
 bool call_has_video(const struct call *call);
 bool call_early_video_available(const struct call *call);
@@ -230,6 +232,7 @@ const char   *call_alerturi(const struct call *call);
 const char   *call_diverteruri(const struct call *call);
 struct audio *call_audio(const struct call *call);
 struct video *call_video(const struct call *call);
+struct video *call_slides(const struct call *call);
 struct list  *call_streaml(const struct call *call);
 struct ua    *call_get_ua(const struct call *call);
 bool          call_is_onhold(const struct call *call);
@@ -323,6 +326,7 @@ struct config_sip {
 	enum sip_transp transp; /**< Default outgoing SIP transport protocol */
 	bool verify_server;     /**< Enable SIP TLS verify server   */
 	uint8_t tos;            /**< Type-of-Service for SIP        */
+	bool media_control;     /**< Media Control over SIP         */
 };
 
 /** Call config */
@@ -397,6 +401,11 @@ struct config_net {
 	bool use_getaddrinfo;   /**< Use getaddrinfo for A/AAAA records */
 };
 
+/** BFCP **/
+struct config_bfcp {
+	char proto[16];         /**< BFCP Transport              */
+	char floorctrl[16];     /**< BFCP floor control role     */
+};
 
 /** Core configuration */
 struct config {
@@ -408,9 +417,12 @@ struct config {
 	struct config_audio audio;
 
 	struct config_video video;
+	struct config_video slides;
+
 	struct config_avt avt;
 
 	struct config_net net;
+	struct config_bfcp bfcp;
 };
 
 int config_parse_conf(struct config *cfg, const struct conf *conf);
@@ -803,6 +815,7 @@ enum ua_event {
 	UA_EVENT_CALL_DTMF_END,
 	UA_EVENT_CALL_RTPESTAB,
 	UA_EVENT_CALL_RTCP,
+	UA_EVENT_CALL_VIDEO_DISP,
 	UA_EVENT_CALL_MENC,
 	UA_EVENT_VU_TX,
 	UA_EVENT_VU_RX,
@@ -1075,6 +1088,7 @@ struct vidisp_st;
 /** Video Display parameters */
 struct vidisp_prm {
 	bool fullscreen;  /**< Enable fullscreen display                    */
+	char content[64];
 };
 
 typedef void (vidisp_resize_h)(const struct vidsz *size, void *arg);
@@ -1368,6 +1382,7 @@ void  video_set_devicename(struct video *v, const char *src, const char *disp);
 int   video_debug(struct re_printf *pf, const struct video *v);
 struct stream *video_strm(const struct video *v);
 const struct vidcodec *video_codec(const struct video *vid, bool tx);
+void video_encode_refresh(struct video *v);
 void video_sdp_attr_decode(struct video *v);
 
 double video_calc_seconds(uint64_t rtp_ts);
@@ -1429,6 +1444,7 @@ const char *stream_peer(const struct stream *strm);
 int  stream_bundle_init(struct stream *strm, bool offerer);
 int  stream_debug(struct re_printf *pf, const struct stream *s);
 void stream_enable_rtp_timeout(struct stream *strm, uint32_t timeout_ms);
+void print_rtp_stats(const struct stream *s);
 
 
 /*

mk/modules.mk

@@ -339,7 +339,7 @@ ifneq ($(USE_WINWAVE),)
 MODULES   += winwave
 endif
 ifneq ($(USE_X11),)
-MODULES   += x11
+MODULES   += x11 x11grab
 endif
 ifneq ($(USE_GZRTP),)
 MODULES   += gzrtp

modules/avcodec/sdp.c

@@ -39,13 +39,16 @@ int avcodec_h264_fmtp_enc(struct mbuf *mb, const struct sdp_format *fmt,
 	uint8_t profile_idc = 0x42; /* baseline profile */
 	uint8_t profile_iop = 0xe0;
 	uint8_t h264_level_idc = 0x1f;
+	char append[64] = "";
 	(void)offer;
 
 	if (!mb || !fmt || !vc)
 		return 0;
 
 	conf_get_str(conf_cur(), "avcodec_profile_level_id",
 		     profile_level_id, sizeof(profile_level_id));
+	conf_get_str(conf_cur(), "video_fmtp_append",
+		     append, sizeof(append));
 
 	if (str_isset(profile_level_id)) {
 		struct pl prof;
@@ -67,10 +70,11 @@ int avcodec_h264_fmtp_enc(struct mbuf *mb, const struct sdp_format *fmt,
  out:
 	return mbuf_printf(mb, "a=fmtp:%s"
 			   " %s"
-			   ";profile-level-id=%02x%02x%02x"
+			   ";profile-level-id=%02x%02x%02x%s"
 			   "\r\n",
 			   fmt->id, vc->variant,
-			   profile_idc, profile_iop, h264_level_idc);
+			   profile_idc, profile_iop, h264_level_idc,
+			   append);
 }
 
 

modules/ice/ice.c

@@ -236,7 +236,7 @@ static int cand_gather_relayed(struct mnat_media *m, struct comp *comp,
 	err = turnc_alloc(&turnc, stun_conf(icem_stun(m->icem)),
 			  IPPROTO_UDP, comp->sock, layer, &m->sess->srv,
 			  username, password,
-			  60, turnc_handler, comp);
+			  60, NULL, turnc_handler, comp);
 	if (err)
 		return err;
 

modules/menu/static_menu.c

@@ -1299,7 +1299,7 @@ static int switch_video_source(struct re_printf *pf, void *arg)
 {
 	const struct cmd_arg *carg = arg;
 	struct pl pl_driver, pl_device;
-	struct config_video *vidcfg;
+	struct config_video *vidcfg, *slidescfg;
 	struct config *cfg;
 	struct video *v;
 	const struct vidsrc *vs;
@@ -1344,10 +1344,8 @@ static int switch_video_source(struct re_printf *pf, void *arg)
 		return EINVAL;
 	}
 
-	vidcfg = &cfg->video;
-
-	str_ncpy(vidcfg->src_mod, driver, sizeof(vidcfg->src_mod));
-	str_ncpy(vidcfg->src_dev, device, sizeof(vidcfg->src_dev));
+	vidcfg= &cfg->video;
+	slidescfg = &cfg->slides;
 
 	for (leu = list_head(uag_list()); leu; leu = leu->next) {
 		struct ua *ua = leu->data;
@@ -1356,8 +1354,11 @@ static int switch_video_source(struct re_printf *pf, void *arg)
 			struct call *call = le->data;
 
 			v = call_video(call);
-
-			err = video_set_source(v, driver, device);
+			err = video_set_source(v, vidcfg->src_mod,
+					       vidcfg->src_dev);
+			v = call_slides(call);
+			err |= video_set_source(v, slidescfg->src_mod,
+						slidescfg->src_dev);
 			if (err) {
 				(void)re_hprintf(pf,
 						 "failed to set video-source"

modules/srtp/srtp.c

@@ -56,7 +56,7 @@ static const char aes_cm_128_hmac_sha1_80[] = "AES_CM_128_HMAC_SHA1_80";
 static const char aes_128_gcm[]             = "AEAD_AES_128_GCM";
 static const char aes_256_gcm[]             = "AEAD_AES_256_GCM";
 
-static const char *preferred_suite = aes_cm_128_hmac_sha1_80;
+static const char *default_suite = aes_cm_128_hmac_sha1_80;
 
 
 static void destructor(void *arg)
@@ -377,6 +377,7 @@ static int media_alloc(struct menc_media **stp, struct menc_sess *sess,
 	int layer = 10; /* above zero */
 	int err = 0;
 	bool mux = (rtpsock == rtcpsock);
+	char preferred_suite[64] = "";
 	(void)sess;
 	(void)rtp;
 	(void)raddr_rtp;
@@ -422,6 +423,9 @@ static int media_alloc(struct menc_media **stp, struct menc_sess *sess,
 			goto out;
 
 		/* set our preferred crypto-suite */
+		str_ncpy(preferred_suite, default_suite, sizeof(default_suite));
+		conf_get_str(conf_cur(), "preferred_crypto_suite",
+			     preferred_suite, sizeof(preferred_suite));
 		err |= str_dup(&st->crypto_suite, preferred_suite);
 		if (err)
 			goto out;

modules/turn/turn.c

@@ -49,6 +49,7 @@ struct mnat_media {
 		struct tls_conn *tlsc;
 		struct mbuf *mb;
 		unsigned ix;
+		uint64_t token;
 	} compv[COMPC];
 };
 
@@ -196,16 +197,27 @@ static void turn_handler(int err, uint16_t scode, const char *reason,
 			 void *arg)
 {
 	struct comp *comp = arg;
+	uint64_t token;
 	struct mnat_media *m = comp->m;
 	(void)mapped_addr;
 	(void)msg;
 
 	if (!err && !scode) {
 
-		const struct comp *other = &m->compv[comp->ix ^ 1];
+		struct comp *other = &m->compv[comp->ix ^ 1];
 
-		if (comp->ix == 0)
-			sdp_media_set_laddr(m->sdpm, relay_addr);
+		struct stun_attr *token_attr = stun_msg_attr(msg, STUN_ATTR_RSV_TOKEN);
+		if (token_attr)
+		    token = token_attr->v.uint64;
+
+		if (comp->ix == 0) {
+		    sdp_media_set_laddr(m->sdpm, relay_addr);
+		    err = turnc_alloc(&other->turnc, NULL,
+		          IPPROTO_UDP, other->sock, LAYER,
+		          &m->sess->srv, m->sess->user, m->sess->pass,
+		          TURN_DEFAULT_LIFETIME, &token,
+		          turn_handler, other);
+		}
 		else
 			sdp_media_set_laddr_rtcp(m->sdpm, relay_addr);
 
@@ -238,7 +250,7 @@ static void tcp_estab_handler(void *arg)
 	err = turnc_alloc(&comp->turnc, NULL, IPPROTO_TCP, comp->tc, 0,
 			  &m->sess->srv,
 			  m->sess->user, m->sess->pass,
-			  TURN_DEFAULT_LIFETIME, turn_handler, comp);
+			  TURN_DEFAULT_LIFETIME, NULL, turn_handler, comp);
 	if (err) {
 		m->sess->estabh(err, 0, NULL, m->sess->arg);
 	}
@@ -259,7 +271,7 @@ static int media_start(struct mnat_sess *sess, struct mnat_media *m)
 	unsigned i;
 	int err = 0;
 
-	for (i=0; i<COMPC; i++) {
+	for (i=0; i<1; i++) {
 
 		struct comp *comp = &m->compv[i];
 
@@ -272,7 +284,7 @@ static int media_start(struct mnat_sess *sess, struct mnat_media *m)
 			err |= turnc_alloc(&comp->turnc, NULL,
 					   IPPROTO_UDP, comp->sock, LAYER,
 					   &sess->srv, sess->user, sess->pass,
-					   TURN_DEFAULT_LIFETIME,
+					   TURN_DEFAULT_LIFETIME, NULL,
 					   turn_handler, comp);
 			break;