FS-6440 --resolve

diff --git a/src/switch_core_session.c b/src/switch_core_session.c
index 61c8ac54e2aa9f16b6b678c086f216ac3dc3c98d..6df3632cb3a5fae50e541c2110c388fc3cc3b715 100644 (file)
--- a/src/switch_core_session.c
+++ b/src/switch_core_session.c
@@ -1827,10 +1827,17 @@ static void *SWITCH_THREAD_FUNC switch_core_session_thread_pool_manager(switch_t
 
        while(session_manager.ready) {
                int check = 1;
+               int ttl = 0;
 
-               switch_mutex_lock(session_manager.cond2_mutex);
-               switch_thread_cond_timedwait(session_manager.cond, session_manager.cond_mutex, sleep);
-               switch_mutex_unlock(session_manager.cond2_mutex);
+               switch_mutex_lock(session_manager.mutex);
+               ttl = switch_queue_size(session_manager.thread_queue);
+               switch_mutex_unlock(session_manager.mutex);
+
+               if (!ttl) {
+                       switch_mutex_lock(session_manager.cond2_mutex);
+                       switch_thread_cond_timedwait(session_manager.cond, session_manager.cond_mutex, sleep);
+                       switch_mutex_unlock(session_manager.cond2_mutex);
+               }
 
                if (switch_micro_time_now() >= next) {
                        if (session_manager.popping) {