update

git-svn-id: http://svn.freeswitch.org/svn/freeswitch/trunk@11483 d0543943-73ff-0310-b7d9-9358b9ac24b2

diff --git a/src/mod/formats/mod_shout/mod_shout.c b/src/mod/formats/mod_shout/mod_shout.c
index 102a70e20d5d60e0d315ee05d7db7e1e8df83849..3b020b236e9459f96044f34f5ba479b25cbd5175 100644 (file)
--- a/src/mod/formats/mod_shout/mod_shout.c
+++ b/src/mod/formats/mod_shout/mod_shout.c
@@ -544,6 +544,12 @@ static void *SWITCH_THREAD_FUNC write_stream_thread(switch_thread_t *thread, voi
 {
        shout_context_t *context = (shout_context_t *) obj;
 
+       if (context->thread_running) {
+               context->thread_running++;
+       } else {
+               return NULL;
+       }
+
        if (!context->lame_ready) {
                lame_init_params(context->gfp);
                lame_print_config(context->gfp);
@@ -620,6 +626,7 @@ static void launch_write_stream_thread(shout_context_t *context)
 {
        switch_thread_t *thread;
        switch_threadattr_t *thd_attr = NULL;
+       int sanity = 10;
 
        if (context->err) {
                return;
@@ -630,6 +637,11 @@ static void launch_write_stream_thread(shout_context_t *context)
        switch_threadattr_detach_set(thd_attr, 1);
        switch_threadattr_stacksize_set(thd_attr, SWITCH_THREAD_STACKSIZE);
        switch_thread_create(&thread, thd_attr, write_stream_thread, context, context->memory_pool);
+
+       while (context->thread_running && context->thread_running != 2) {
+               switch_yield(100000);
+               if (!--sanity) break;
+       }
 }
 
 #define TC_BUFFER_SIZE 1024 * 32