FS-7696

diff --git a/src/mod/formats/mod_local_stream/mod_local_stream.c b/src/mod/formats/mod_local_stream/mod_local_stream.c
index 2a5f89532a2a201b7ca406f42c7c2dd212b8bb97..f835972ab493d5a0f448aa4fb4388c790098747f 100644 (file)
--- a/src/mod/formats/mod_local_stream/mod_local_stream.c
+++ b/src/mod/formats/mod_local_stream/mod_local_stream.c
@@ -352,6 +352,7 @@ static void *SWITCH_THREAD_FUNC read_stream_thread(switch_thread_t *thread, void
                                                is_open = 0;
 
                                                switch_core_file_close(use_fh);
+                                               flush_video_queue(source->video_q);
                                                if (use_fh == &source->chime_fh) {
                                                        source->chime_counter = source->rate * source->chime_freq;
                                                        use_fh = &fh;
@@ -383,6 +384,7 @@ static void *SWITCH_THREAD_FUNC read_stream_thread(switch_thread_t *thread, void
 
                                        if (switch_core_file_read(use_fh, abuf, &olen) != SWITCH_STATUS_SUCCESS || !olen) {
                                                switch_core_file_close(use_fh);
+                                               flush_video_queue(source->video_q);
 
                                                if (use_fh == &source->chime_fh) {
                                                        source->chime_counter = source->rate * source->chime_freq;
@@ -394,6 +396,7 @@ static void *SWITCH_THREAD_FUNC read_stream_thread(switch_thread_t *thread, void
                                                        if (source->chime_max_counter >= source->chime_max) {
                                                                source->chime_max_counter = 0;
                                                                switch_core_file_close(use_fh);
+                                                               flush_video_queue(source->video_q);
                                                                source->chime_counter = source->rate * source->chime_freq;
                                                                use_fh = &fh;
                                                                goto retry;