Merge pull request #592 in FS/freeswitch from bugfix/FS-8384 to master

* commit '6c7ed71a':
  update
  update
  fix close file snafu
  update
  commit

src/mod/applications/mod_conference/conference_api.c

@@ -1213,15 +1213,18 @@ switch_status_t conference_api_sub_vid_layout(conference_obj_t *conference, swit
 
 	if (idx < 0 || idx > (int)(conference->canvas_count - 1)) idx = 0;
 
-	switch_mutex_lock(conference->canvas_mutex);
+
 	if (conference_utils_test_flag(conference, CFLAG_PERSONAL_CANVAS)) {
 		stream->write_function(stream, "Change personal canvas set to layout [%s]\n", vlayout->name);
+		switch_mutex_lock(conference->member_mutex);
 		conference->new_personal_vlayout = vlayout;
+		switch_mutex_unlock(conference->member_mutex);
 	} else {
 		stream->write_function(stream, "Change canvas %d to layout [%s]\n", idx + 1, vlayout->name);
+		switch_mutex_lock(conference->canvases[idx]->mutex);
 		conference->canvases[idx]->new_vlayout = vlayout;
+		switch_mutex_unlock(conference->canvases[idx]->mutex);
 	}
-	switch_mutex_unlock(conference->canvas_mutex);
 
 	return SWITCH_STATUS_SUCCESS;
 }
@@ -1579,8 +1582,6 @@ switch_status_t conference_api_sub_vid_res_id(conference_member_t *member, switc
 		return SWITCH_STATUS_SUCCESS;
 	}
 
-	switch_mutex_lock(member->conference->canvas_mutex);
-
 	if (!strcasecmp(text, "clear") || (member->video_reservation_id && !strcasecmp(text, member->video_reservation_id))) {
 		member->video_reservation_id = NULL;
 		stream->write_function(stream, "+OK reservation_id cleared\n");
@@ -1591,8 +1592,6 @@ switch_status_t conference_api_sub_vid_res_id(conference_member_t *member, switc
 
 	conference_video_detach_video_layer(member);
 
-	switch_mutex_unlock(member->conference->canvas_mutex);
-
 	return SWITCH_STATUS_SUCCESS;
 
 }

src/mod/applications/mod_conference/conference_file.c

@@ -410,6 +410,45 @@ switch_status_t conference_file_local_play(conference_obj_t *conference, switch_
 	return status;
 }
 
+switch_status_t conference_close_open_files(conference_obj_t *conference)
+{
+	int x = 0;
+
+	switch_mutex_lock(conference->mutex);
+	/* Close Unused Handles */
+	if (conference->fnode) {
+		conference_file_node_t *fnode, *cur;
+		switch_memory_pool_t *pool;
+
+		fnode = conference->fnode;
+		while (fnode) {
+			cur = fnode;
+			fnode = fnode->next;
+
+			if (cur->type != NODE_TYPE_SPEECH) {
+				conference_file_close(conference, cur);
+			}
+
+			pool = cur->pool;
+			switch_core_destroy_memory_pool(&pool);
+			x++;
+		}
+		conference->fnode = NULL;
+	}
+
+	if (conference->async_fnode) {
+		switch_memory_pool_t *pool;
+		conference_file_close(conference, conference->async_fnode);
+		pool = conference->async_fnode->pool;
+		conference->async_fnode = NULL;
+		switch_core_destroy_memory_pool(&pool);
+		x++;
+	}
+	switch_mutex_unlock(conference->mutex);
+
+	return x ? SWITCH_STATUS_SUCCESS : SWITCH_STATUS_FALSE;
+}
+
 /* For Emacs:
  * Local Variables:
  * mode:c

src/mod/applications/mod_conference/conference_member.c

@@ -694,12 +694,10 @@ switch_status_t conference_member_add(conference_obj_t *conference, conference_m
 	if (conference_utils_test_flag(conference, CFLAG_PERSONAL_CANVAS)) {
 		video_layout_t *vlayout = NULL;
 
-		switch_mutex_lock(conference->canvas_mutex);
 		if ((vlayout = conference_video_get_layout(conference, conference->video_layout_name, conference->video_layout_group))) {
 			conference_video_init_canvas(conference, vlayout, &member->canvas);
 			conference_video_init_canvas_layers(conference, member->canvas, vlayout);
 		}
-		switch_mutex_unlock(conference->canvas_mutex);
 	}
 
 	conference->members = member;

src/mod/applications/mod_conference/conference_video.c

@@ -553,22 +553,16 @@ mcu_layer_t *conference_video_get_layer_locked(conference_member_t *member)
 	mcu_canvas_t *canvas = NULL;
 
 	if (!member || member->canvas_id < 0 || member->video_layer_id < 0) return NULL;
-	
-	canvas = member->conference->canvases[member->canvas_id];
 
-	if (!canvas) {
-		goto end;
-	}
-
-	switch_mutex_lock(canvas->mutex);
-	layer = &canvas->layers[member->video_layer_id];
+	if ((canvas = conference_video_get_canvas_locked(member))) {
+		switch_mutex_lock(canvas->mutex);
+		layer = &canvas->layers[member->video_layer_id];
 
-	if (!layer) {
-		switch_mutex_unlock(canvas->mutex);
+		if (!layer) {
+			switch_mutex_unlock(canvas->mutex);
+		}
 	}
 	
- end:
-
 	return layer;
 }
 
@@ -583,26 +577,52 @@ void conference_video_release_layer(mcu_layer_t **layer)
 	if (!canvas) return;
 
 	switch_mutex_unlock(canvas->mutex);
+	conference_video_release_canvas(&canvas);
+	
+	*layer = NULL;
+}
 
-	switch_assert(canvas->conference);
+mcu_canvas_t *conference_video_get_canvas_locked(conference_member_t *member)
+{
+	mcu_canvas_t *canvas = NULL;
 
-	*layer = NULL;
+	if (!member || member->canvas_id < 0 || member->video_layer_id < 0) return NULL;
+
+	switch_mutex_lock(member->conference->canvas_mutex);
+	canvas = member->conference->canvases[member->canvas_id];
+
+	if (!canvas) {
+	   	switch_mutex_unlock(member->conference->canvas_mutex);
+	}
+
+	return canvas;
 }
 
+void conference_video_release_canvas(mcu_canvas_t **canvasP)
+{
+	mcu_canvas_t *canvas = NULL;
+
+	switch_assert(canvasP);
+	
+	canvas = *canvasP;
+
+	if (!canvas) return;
+
+	switch_mutex_unlock(canvas->conference->canvas_mutex);
+	*canvasP = NULL;
+}
 
 void conference_video_detach_video_layer(conference_member_t *member)
 {
 	mcu_layer_t *layer = NULL;
 	mcu_canvas_t *canvas = NULL;
 
-	switch_mutex_lock(member->conference->canvas_mutex);
-
-	if (member->canvas_id < 0) goto end;
+	if (member->canvas_id < 0) return;
 
-	canvas = member->conference->canvases[member->canvas_id];
+	canvas = conference_video_get_canvas_locked(member);
 
 	if (!canvas || member->video_layer_id < 0) {
-		goto end;
+		return;
 	}
 
 	switch_mutex_lock(canvas->mutex);
@@ -638,11 +658,8 @@ void conference_video_detach_video_layer(conference_member_t *member)
 	}
 
 	switch_mutex_unlock(canvas->mutex);
-
- end:
-
-	switch_mutex_unlock(member->conference->canvas_mutex);
-
+	conference_video_release_canvas(&canvas);
+	
 }
 
 
@@ -884,8 +901,6 @@ switch_status_t conference_video_attach_video_layer(conference_member_t *member,
 		return SWITCH_STATUS_FALSE;
 	}
 
-	switch_mutex_lock(member->conference->canvas_mutex);
-
 	switch_mutex_lock(canvas->mutex);
 
 	layer = &canvas->layers[idx];
@@ -965,8 +980,6 @@ switch_status_t conference_video_attach_video_layer(conference_member_t *member,
 
 	switch_mutex_unlock(canvas->mutex);
 
-	switch_mutex_unlock(member->conference->canvas_mutex);
-
 	return status;
 }
 
@@ -977,7 +990,6 @@ void conference_video_init_canvas_layers(conference_obj_t *conference, mcu_canva
 	if (!canvas) return;
 
 	switch_thread_rwlock_wrlock(canvas->video_rwlock);
-	switch_mutex_lock(conference->canvas_mutex);
 	switch_mutex_lock(canvas->mutex);
 	canvas->layout_floor_id = -1;
 
@@ -988,7 +1000,6 @@ void conference_video_init_canvas_layers(conference_obj_t *conference, mcu_canva
 
 	if (!vlayout) {
 		switch_mutex_unlock(canvas->mutex);
-		switch_mutex_lock(conference->canvas_mutex);
 		switch_thread_rwlock_unlock(canvas->video_rwlock);
 		return;
 	}
@@ -1064,7 +1075,6 @@ void conference_video_init_canvas_layers(conference_obj_t *conference, mcu_canva
 	}
 	
 	switch_mutex_unlock(canvas->mutex);
-	switch_mutex_unlock(conference->canvas_mutex);
 	switch_thread_rwlock_unlock(canvas->video_rwlock);
 
 	switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_DEBUG, "Canvas position %d applied layout %s\n", canvas->canvas_id + 1, vlayout->name);
@@ -1314,7 +1324,7 @@ video_layout_t *conference_video_get_layout(conference_obj_t *conference, const
 	} else {
 		vlayout = switch_core_hash_find(conference->layout_hash, video_layout_name);
 	}
-
+		
 	return vlayout;
 }
 
@@ -1326,8 +1336,8 @@ void conference_video_vmute_snap(conference_member_t *member, switch_bool_t clea
 		mcu_layer_t *layer = NULL;
 		mcu_canvas_t *canvas = NULL;
 
-		canvas = member->conference->canvases[member->canvas_id];
-
+		canvas = conference_video_get_canvas_locked(member);
+		
 		switch_mutex_lock(canvas->mutex);
 		layer = &canvas->layers[member->video_layer_id];
 		switch_img_free(&layer->mute_img);
@@ -1339,6 +1349,7 @@ void conference_video_vmute_snap(conference_member_t *member, switch_bool_t clea
 		}
 
 		switch_mutex_unlock(canvas->mutex);
+		conference_video_release_canvas(&canvas);
 	}
 }
 
@@ -1497,26 +1508,25 @@ void *SWITCH_THREAD_FUNC conference_video_muxing_write_thread_run(switch_thread_
 				switch_frame_buffer_free(member->fb, &frame);
 			}
 
+			canvas = NULL;                                                                                                                              
+			layer = NULL;
+			
 			switch_mutex_lock(member->conference->canvas_mutex);
 			if (member->video_layer_id > -1 && member->canvas_id > -1) {
 				canvas = member->conference->canvases[member->canvas_id];
 				layer = &canvas->layers[member->video_layer_id];
 
-				if (layer->need_patch) {
-					switch_mutex_lock(canvas->mutex);
-				} else {
+				if (!layer->need_patch || switch_thread_rwlock_tryrdlock(canvas->video_rwlock) != SWITCH_STATUS_SUCCESS) {
 					canvas = NULL;
 					layer = NULL;
 				}
 			}
 			switch_mutex_unlock(member->conference->canvas_mutex);
 
-			if (canvas) {
-				switch_thread_rwlock_rdlock(canvas->video_rwlock);
+			if (canvas && layer && layer->need_patch) {
 				conference_video_scale_and_patch(layer, NULL, SWITCH_FALSE);
 				layer->need_patch = 0;
 				switch_thread_rwlock_unlock(canvas->video_rwlock);
-				switch_mutex_unlock(canvas->mutex);
 			}
 		}
 	}
@@ -1572,10 +1582,13 @@ void conference_video_check_avatar(conference_member_t *member, switch_bool_t fo
 		return;
 	}
 
-	canvas = member->conference->canvases[member->canvas_id];
+	canvas = conference_video_get_canvas_locked(member);
 
 	if (conference_utils_test_flag(member->conference, CFLAG_VIDEO_REQUIRED_FOR_CANVAS) &&
 		(!switch_channel_test_flag(member->channel, CF_VIDEO) || switch_core_session_media_flow(member->session, SWITCH_MEDIA_TYPE_VIDEO) == SWITCH_MEDIA_FLOW_SENDONLY)) {
+		if (canvas) {
+			conference_video_release_canvas(&canvas);
+		}
 		return;
 	}
 
@@ -1613,6 +1626,7 @@ void conference_video_check_avatar(conference_member_t *member, switch_bool_t fo
 
 	if (canvas) {
 		switch_mutex_unlock(canvas->mutex);
+		conference_video_release_canvas(&canvas);
 	}
 }
 
@@ -1705,7 +1719,7 @@ switch_status_t conference_video_find_layer(conference_obj_t *conference, mcu_ca
 	mcu_layer_t *layer = NULL;
 	int i;
 
-	switch_mutex_lock(conference->canvas_mutex);
+	switch_mutex_lock(canvas->mutex);
 
 	for (i = 0; i < canvas->total_layers; i++) {
 		mcu_layer_t *xlayer = &canvas->layers[i];
@@ -1751,7 +1765,7 @@ switch_status_t conference_video_find_layer(conference_obj_t *conference, mcu_ca
 		}
 	}
 
-	switch_mutex_unlock(conference->canvas_mutex);
+	switch_mutex_unlock(canvas->mutex);
 
 	if (layer) {
 		*layerP = layer;
@@ -2190,7 +2204,6 @@ void *SWITCH_THREAD_FUNC conference_video_muxing_thread_run(switch_thread_t *thr
 			//printf("MEMBER %d layer_id %d canvas: %d/%d\n", imember->id, imember->video_layer_id,
 			//	   canvas->layers_used, canvas->total_layers);
 
-			switch_mutex_lock(conference->canvas_mutex);
 			if (imember->video_layer_id > -1) {
 				layer = &canvas->layers[imember->video_layer_id];
 				if (layer->member_id != (int)imember->id) {
@@ -2199,8 +2212,6 @@ void *SWITCH_THREAD_FUNC conference_video_muxing_thread_run(switch_thread_t *thr
 					imember->layer_timeout = DEFAULT_LAYER_TIMEOUT;
 				}
 			}
-			switch_mutex_unlock(conference->canvas_mutex);
-			
 
 			if (imember->avatar_png_img) {
 				if (layer) {
@@ -2740,6 +2751,8 @@ void *SWITCH_THREAD_FUNC conference_video_muxing_thread_run(switch_thread_t *thr
 		}
 	}
 
+	conference_close_open_files(conference);
+
 	switch_core_timer_destroy(&canvas->timer);
 	conference_video_destroy_canvas(&canvas);
 
@@ -3407,10 +3420,14 @@ switch_status_t conference_video_thread_callback(switch_core_session_t *session,
 	if (conference_utils_test_flag(member->conference, CFLAG_VIDEO_MUXING)) {
 		switch_image_t *img_copy = NULL;
 
-		if (frame->img && (member->video_layer_id > -1 || member->canvas) && conference_utils_member_test_flag(member, MFLAG_CAN_BE_SEEN) &&
+		if (frame->img && (member->video_layer_id > -1 || member->canvas) && 
+			conference_utils_member_test_flag(member, MFLAG_CAN_BE_SEEN) &&
+			switch_queue_size(member->video_queue) < member->conference->video_fps.fps * 2 &&
 			!member->conference->playing_video_file) {
 			switch_img_copy(frame->img, &img_copy);
-			switch_queue_push(member->video_queue, img_copy);
+			if (switch_queue_trypush(member->video_queue, img_copy) != SWITCH_STATUS_SUCCESS) {
+				switch_img_free(&img_copy);
+			}
 		}
 
 		switch_thread_rwlock_unlock(member->conference->rwlock);

src/mod/applications/mod_conference/mod_conference.h

@@ -865,7 +865,7 @@ void conference_member_add_file_data(conference_member_t *member, int16_t *data,
 void conference_send_notify(conference_obj_t *conference, const char *status, const char *call_id, switch_bool_t final);
 switch_status_t conference_file_close(conference_obj_t *conference, conference_file_node_t *node);
 void *SWITCH_THREAD_FUNC conference_record_thread_run(switch_thread_t *thread, void *obj);
-
+switch_status_t conference_close_open_files(conference_obj_t *conference);
 void conference_al_gen_arc(conference_obj_t *conference, switch_stream_handle_t *stream);
 void conference_al_process(al_handle_t *al, void *data, switch_size_t datalen, int rate);
 
@@ -887,7 +887,8 @@ switch_status_t conference_loop_dmachine_dispatcher(switch_ivr_dmachine_match_t
 
 mcu_layer_t *conference_video_get_layer_locked(conference_member_t *member);
 void conference_video_release_layer(mcu_layer_t **layer);
-	
+mcu_canvas_t *conference_video_get_canvas_locked(conference_member_t *member);
+void conference_video_release_canvas(mcu_canvas_t **canvasP);
 int conference_member_setup_media(conference_member_t *member, conference_obj_t *conference);
 
 al_handle_t *conference_al_create(switch_memory_pool_t *pool);

src/switch_jitterbuffer.c

@@ -1234,9 +1234,9 @@ SWITCH_DECLARE(switch_status_t) switch_jb_get_packet(switch_jb_t *jb, switch_rtp
 
 	jb->period_miss_pct = ((double)jb->period_miss_count / jb->period_count) * 100;
 
-	if (jb->period_miss_pct > 40.0f) {
+	if (jb->period_miss_pct > 60.0f) {
 		jb_debug(jb, 2, "Miss percent %02f too high, resetting buffer.\n", jb->period_miss_pct);
-		//switch_jb_reset(jb);
+		switch_jb_reset(jb);
 	}
 
 	if ((status = jb_next_packet(jb, &node)) == SWITCH_STATUS_SUCCESS) {
@@ -1324,15 +1324,12 @@ SWITCH_DECLARE(switch_status_t) switch_jb_get_packet(switch_jb_t *jb, switch_rtp
 	}
 
 	switch_mutex_unlock(jb->mutex);
-
-	if (status == SWITCH_STATUS_SUCCESS) {
-		if (jb->complete_frames > jb->max_frame_len) {
-			thin_frames(jb, 8, 25);
-		}
+	
+	if (jb->complete_frames > jb->max_frame_len) {
+		thin_frames(jb, 8, 25);
 	}
 
 	return status;
-
 }