FS-7500: reduce CNG frames on video and move debug from mod_fsv to the core with…

FS-7500: reduce CNG frames on video and move debug from mod_fsv to the core with a flag to enable it since the raw packet is not available anymore when you set DECODED READ flag

src/include/switch_types.h

@@ -1451,6 +1451,8 @@ typedef enum {
 	CF_HANGUP_HELD,
 	CF_CONFERENCE_RESET_MEDIA,
 	CF_VIDEO_DECODED_READ,
+	CF_VIDEO_DEBUG_READ,
+	CF_VIDEO_DEBUG_WRITE,
 	/* WARNING: DO NOT ADD ANY FLAGS BELOW THIS LINE */
 	/* IF YOU ADD NEW ONES CHECK IF THEY SHOULD PERSIST OR ZERO THEM IN switch_core_session.c switch_core_session_request_xml() */
 	CF_FLAG_MAX

src/mod/applications/mod_fsv/mod_fsv.c

@@ -723,6 +723,7 @@ static void decode_video_thread(switch_core_session_t *session, void *obj)
 	}
 
 	switch_channel_set_flag(channel, CF_VIDEO_DECODED_READ);
+	switch_channel_set_flag(channel, CF_VIDEO_DEBUG_READ);
 	
 	while (switch_channel_ready(channel)) {
 		switch_status_t status = switch_core_session_read_video_frame(session, &frame, SWITCH_IO_FLAG_NONE, 0);
@@ -742,15 +743,6 @@ static void decode_video_thread(switch_core_session_t *session, void *obj)
 			continue;
 		}
 
-		switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_INFO, "seq: %d ts: %ld len: %4d %02x %02x %02x %02x %02x %02x %02x %02x %02x %02x %02x mark: %d %s\n",
-			frame->seq, frame->timestamp, frame->datalen,
-			*((uint8_t *)frame->data), *((uint8_t *)frame->data + 1),
-			*((uint8_t *)frame->data + 2), *((uint8_t *)frame->data + 3),
-			*((uint8_t *)frame->data + 4), *((uint8_t *)frame->data + 5),
-			*((uint8_t *)frame->data + 6), *((uint8_t *)frame->data + 7),
-			*((uint8_t *)frame->data + 8), *((uint8_t *)frame->data + 9),
-			*((uint8_t *)frame->data + 10), frame->m, switch_test_flag(frame, SFF_CNG) ? " CNG" : "");
-
 		if (switch_test_flag(frame, SFF_CNG) || frame->datalen < 3) {
 			continue;
 		}

src/mod/codecs/mod_vpx/mod_vpx.c

@@ -315,16 +315,19 @@ static switch_status_t switch_vpx_init(switch_codec_t *codec, switch_codec_flag_
 
 static switch_status_t consume_partition(vpx_context_t *context, switch_frame_t *frame)
 {
-	if (!context->pkt) context->pkt = vpx_codec_get_cx_data(&context->encoder, &context->iter);
+	if (!context->pkt) {
+		context->pkt = vpx_codec_get_cx_data(&context->encoder, &context->iter);
+		context->pkt_pos = 0;
+	}
 
-	if (context->pkt) {
+	//	if (context->pkt) {
 		// if (context->pkt->kind == VPX_CODEC_CX_FRAME_PKT && (context->pkt->data.frame.flags & VPX_FRAME_IS_KEY) && context->pkt_pos == 0) {
 		// 	switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_ERROR, "============================Got a VP8 Key Frame size:[%d]===================================\n", (int)context->pkt->data.frame.sz);
 		// }
 
 		// switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_ERROR, "size:%d flag: %x part_id: %d pts: %lld duration:%ld\n",
 		// 	(int)context->pkt->data.frame.sz, context->pkt->data.frame.flags, context->pkt->data.frame.partition_id, context->pkt->data.frame.pts, context->pkt->data.frame.duration);
-	}
+		//}
 
 	if (!context->pkt || context->pkt_pos >= context->pkt->data.frame.sz - 1 || context->pkt->kind != VPX_CODEC_CX_FRAME_PKT) {
 		frame->datalen = 0;

src/switch_core_media.c

@@ -9687,6 +9687,18 @@ SWITCH_DECLARE(switch_status_t) switch_core_session_read_video_frame(switch_core
 		goto done;
 	}
 	
+	if (switch_channel_test_flag(session->channel, CF_VIDEO_DEBUG_READ)) {
+		switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_INFO, "seq: %d ts: %ld len: %4d %02x %02x %02x %02x %02x %02x %02x %02x %02x %02x %02x mark: %d %s\n",
+						  (*frame)->seq, (*frame)->timestamp, (*frame)->datalen,
+						  *((uint8_t *)(*frame)->data), *((uint8_t *)(*frame)->data + 1),
+						  *((uint8_t *)(*frame)->data + 2), *((uint8_t *)(*frame)->data + 3),
+						  *((uint8_t *)(*frame)->data + 4), *((uint8_t *)(*frame)->data + 5),
+						  *((uint8_t *)(*frame)->data + 6), *((uint8_t *)(*frame)->data + 7),
+						  *((uint8_t *)(*frame)->data + 8), *((uint8_t *)(*frame)->data + 9),
+						  *((uint8_t *)(*frame)->data + 10), (*frame)->m, switch_test_flag((*frame), SFF_CNG) ? " CNG" : "");
+	}
+
+
 	if (switch_test_flag(*frame, SFF_CNG)) {
 		status = SWITCH_STATUS_SUCCESS;
 		goto done;

src/switch_core_session.c

@@ -2680,6 +2680,7 @@ SWITCH_DECLARE(void) switch_core_session_video_reset(switch_core_session_t *sess
 	switch_channel_clear_flag(session->channel, CF_VIDEO_ECHO);
 	switch_channel_clear_flag(session->channel, CF_VIDEO_PASSIVE);
 	switch_channel_clear_flag(session->channel, CF_VIDEO_DECODED_READ);
+	switch_channel_clear_flag(session->channel, CF_VIDEO_DEBUG_READ);
 	switch_core_session_refresh_video(session);
 	session->image_write_callback = NULL;
 	session->image_write_callback_user_data = NULL;

src/switch_rtp.c

@@ -5578,17 +5578,16 @@ static int rtp_common_read(switch_rtp_t *rtp_session, switch_payload_t *payload_
 			}
 
 			if (rtp_session->flags[SWITCH_RTP_FLAG_VIDEO] && !rtp_session->flags[SWITCH_RTP_FLAG_PROXY_MEDIA]) {
-				pt = 100000;
+				pt = 200000;
 			}
 
-			if (using_ice(rtp_session)) {
-				pt = 20000;
-			}
+			//if (using_ice(rtp_session)) {
+			//	pt = 20000;
+			//}
 
 			poll_status = switch_poll(rtp_session->read_pollfd, 1, &fdr, pt);
 
-
-			if (rtp_session->dtmf_data.out_digit_dur > 0) {
+			if (!rtp_session->flags[SWITCH_RTP_FLAG_VIDEO] && rtp_session->dtmf_data.out_digit_dur > 0) {
 				return_cng_frame();
 			}