提交 86184a2f authored 作者: Anthony Minessale's avatar Anthony Minessale

FS-10757: [mod_conference] Race condition freeing avatar image #resolve

上级 ccb31ab4
...@@ -742,7 +742,9 @@ void *SWITCH_THREAD_FUNC conference_loop_input(switch_thread_t *thread, void *ob ...@@ -742,7 +742,9 @@ void *SWITCH_THREAD_FUNC conference_loop_input(switch_thread_t *thread, void *ob
if (switch_channel_test_flag(channel, CF_VIDEO) && !conference_utils_member_test_flag(member, MFLAG_ACK_VIDEO)) { if (switch_channel_test_flag(channel, CF_VIDEO) && !conference_utils_member_test_flag(member, MFLAG_ACK_VIDEO)) {
conference_utils_member_set_flag_locked(member, MFLAG_ACK_VIDEO); conference_utils_member_set_flag_locked(member, MFLAG_ACK_VIDEO);
switch_mutex_lock(member->flag_mutex);
switch_img_free(&member->avatar_png_img); switch_img_free(&member->avatar_png_img);
switch_mutex_unlock(member->flag_mutex);
conference_video_check_avatar(member, SWITCH_FALSE); conference_video_check_avatar(member, SWITCH_FALSE);
switch_core_session_video_reinit(member->session); switch_core_session_video_reinit(member->session);
conference_video_set_floor_holder(member->conference, member, SWITCH_FALSE); conference_video_set_floor_holder(member->conference, member, SWITCH_FALSE);
......
...@@ -1166,9 +1166,11 @@ switch_status_t conference_member_del(conference_obj_t *conference, conference_m ...@@ -1166,9 +1166,11 @@ switch_status_t conference_member_del(conference_obj_t *conference, conference_m
last = imember; last = imember;
} }
switch_mutex_lock(member->flag_mutex);
switch_img_free(&member->avatar_png_img); switch_img_free(&member->avatar_png_img);
switch_img_free(&member->video_mute_img); switch_img_free(&member->video_mute_img);
switch_img_free(&member->pcanvas_img); switch_img_free(&member->pcanvas_img);
switch_mutex_unlock(member->flag_mutex);
switch_thread_rwlock_unlock(member->rwlock); switch_thread_rwlock_unlock(member->rwlock);
......
...@@ -1861,8 +1861,10 @@ void conference_video_check_avatar(conference_member_t *member, switch_bool_t fo ...@@ -1861,8 +1861,10 @@ void conference_video_check_avatar(conference_member_t *member, switch_bool_t fo
avatar = var; avatar = var;
} }
switch_mutex_lock(member->flag_mutex);
switch_img_free(&member->avatar_png_img); switch_img_free(&member->avatar_png_img);
if (avatar) { if (avatar) {
member->avatar_png_img = switch_img_read_png(avatar, SWITCH_IMG_FMT_I420); member->avatar_png_img = switch_img_read_png(avatar, SWITCH_IMG_FMT_I420);
} }
...@@ -1875,6 +1877,8 @@ void conference_video_check_avatar(conference_member_t *member, switch_bool_t fo ...@@ -1875,6 +1877,8 @@ void conference_video_check_avatar(conference_member_t *member, switch_bool_t fo
member->auto_avatar = 1; member->auto_avatar = 1;
} }
switch_mutex_unlock(member->flag_mutex);
if (canvas) { if (canvas) {
switch_mutex_unlock(canvas->mutex); switch_mutex_unlock(canvas->mutex);
conference_video_release_canvas(&canvas); conference_video_release_canvas(&canvas);
...@@ -1894,7 +1898,9 @@ void conference_video_check_flush(conference_member_t *member, switch_bool_t for ...@@ -1894,7 +1898,9 @@ void conference_video_check_flush(conference_member_t *member, switch_bool_t for
if ((flushed || force) && member->auto_avatar) { if ((flushed || force) && member->auto_avatar) {
switch_channel_video_sync(member->channel); switch_channel_video_sync(member->channel);
switch_mutex_lock(member->flag_mutex);
switch_img_free(&member->avatar_png_img); switch_img_free(&member->avatar_png_img);
switch_mutex_unlock(member->flag_mutex);
member->avatar_patched = 0; member->avatar_patched = 0;
conference_video_reset_video_bitrate_counters(member); conference_video_reset_video_bitrate_counters(member);
member->blanks = 0; member->blanks = 0;
...@@ -2723,6 +2729,7 @@ void *SWITCH_THREAD_FUNC conference_video_muxing_thread_run(switch_thread_t *thr ...@@ -2723,6 +2729,7 @@ void *SWITCH_THREAD_FUNC conference_video_muxing_thread_run(switch_thread_t *thr
} }
} }
switch_mutex_lock(imember->flag_mutex);
if (imember->avatar_png_img) { if (imember->avatar_png_img) {
if (layer) { if (layer) {
if (!imember->avatar_patched || !layer->cur_img) { if (!imember->avatar_patched || !layer->cur_img) {
...@@ -2736,6 +2743,7 @@ void *SWITCH_THREAD_FUNC conference_video_muxing_thread_run(switch_thread_t *thr ...@@ -2736,6 +2743,7 @@ void *SWITCH_THREAD_FUNC conference_video_muxing_thread_run(switch_thread_t *thr
} }
switch_img_free(&img); switch_img_free(&img);
} }
switch_mutex_unlock(imember->flag_mutex);
if (!layer && (!conference_utils_test_flag(imember->conference, CFLAG_VIDEO_REQUIRED_FOR_CANVAS) || ((switch_channel_test_flag(imember->channel, CF_VIDEO_READY) && switch_core_session_media_flow(imember->session, SWITCH_MEDIA_TYPE_VIDEO) != SWITCH_MEDIA_FLOW_SENDONLY && switch_core_session_media_flow(imember->session, SWITCH_MEDIA_TYPE_VIDEO) != SWITCH_MEDIA_FLOW_INACTIVE)))) { if (!layer && (!conference_utils_test_flag(imember->conference, CFLAG_VIDEO_REQUIRED_FOR_CANVAS) || ((switch_channel_test_flag(imember->channel, CF_VIDEO_READY) && switch_core_session_media_flow(imember->session, SWITCH_MEDIA_TYPE_VIDEO) != SWITCH_MEDIA_FLOW_SENDONLY && switch_core_session_media_flow(imember->session, SWITCH_MEDIA_TYPE_VIDEO) != SWITCH_MEDIA_FLOW_INACTIVE)))) {
if (conference_video_find_layer(conference, canvas, imember, &layer) == SWITCH_STATUS_SUCCESS) { if (conference_video_find_layer(conference, canvas, imember, &layer) == SWITCH_STATUS_SUCCESS) {
......
Markdown 格式
0%
您添加了 0 到此讨论。请谨慎行事。
请先完成此评论的编辑!
注册 或者 后发表评论