提交 fdc7cd03 authored 作者: Anthony Minessale's avatar Anthony Minessale

add define for thread pool debug

上级 8f62bc62
...@@ -1579,9 +1579,9 @@ static void *SWITCH_THREAD_FUNC switch_core_session_thread_pool_worker(switch_th ...@@ -1579,9 +1579,9 @@ static void *SWITCH_THREAD_FUNC switch_core_session_thread_pool_worker(switch_th
switch_mutex_lock(session_manager.mutex); switch_mutex_lock(session_manager.mutex);
session_manager.running++; session_manager.running++;
switch_mutex_unlock(session_manager.mutex); switch_mutex_unlock(session_manager.mutex);
#ifdef DEBUG_THREAD_POOL
switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_DEBUG10, "Worker Thread %ld Started\n", (long) thread); switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_DEBUG10, "Worker Thread %ld Started\n", (long) thread);
#endif
while(session_manager.ready) { while(session_manager.ready) {
switch_status_t check_status; switch_status_t check_status;
...@@ -1609,9 +1609,9 @@ static void *SWITCH_THREAD_FUNC switch_core_session_thread_pool_worker(switch_th ...@@ -1609,9 +1609,9 @@ static void *SWITCH_THREAD_FUNC switch_core_session_thread_pool_worker(switch_th
switch_mutex_lock(session_manager.mutex); switch_mutex_lock(session_manager.mutex);
session_manager.busy++; session_manager.busy++;
switch_mutex_unlock(session_manager.mutex); switch_mutex_unlock(session_manager.mutex);
#ifdef DEBUG_THREAD_POOL
switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_DEBUG10, "Worker Thread %ld Processing\n", (long) thread); switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_DEBUG10, "Worker Thread %ld Processing\n", (long) thread);
#endif
td->func(thread, td->obj); td->func(thread, td->obj);
...@@ -1622,9 +1622,9 @@ static void *SWITCH_THREAD_FUNC switch_core_session_thread_pool_worker(switch_th ...@@ -1622,9 +1622,9 @@ static void *SWITCH_THREAD_FUNC switch_core_session_thread_pool_worker(switch_th
} else if (td->alloc) { } else if (td->alloc) {
free(td); free(td);
} }
#ifdef DEBUG_THREAD_POOL
switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_DEBUG10, "Worker Thread %ld Done Processing\n", (long) thread); switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_DEBUG10, "Worker Thread %ld Done Processing\n", (long) thread);
#endif
switch_mutex_lock(session_manager.mutex); switch_mutex_lock(session_manager.mutex);
session_manager.busy--; session_manager.busy--;
switch_mutex_unlock(session_manager.mutex); switch_mutex_unlock(session_manager.mutex);
...@@ -1636,9 +1636,9 @@ static void *SWITCH_THREAD_FUNC switch_core_session_thread_pool_worker(switch_th ...@@ -1636,9 +1636,9 @@ static void *SWITCH_THREAD_FUNC switch_core_session_thread_pool_worker(switch_th
check++; check++;
} }
} }
#ifdef DEBUG_THREAD_POOL
switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_DEBUG10, "Worker Thread %ld Ended\n", (long) thread); switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_DEBUG10, "Worker Thread %ld Ended\n", (long) thread);
#endif
switch_mutex_lock(session_manager.mutex); switch_mutex_lock(session_manager.mutex);
session_manager.running--; session_manager.running--;
switch_mutex_unlock(session_manager.mutex); switch_mutex_unlock(session_manager.mutex);
...@@ -1722,9 +1722,10 @@ static void *SWITCH_THREAD_FUNC switch_core_session_thread_pool_manager(switch_t ...@@ -1722,9 +1722,10 @@ static void *SWITCH_THREAD_FUNC switch_core_session_thread_pool_manager(switch_t
if (++x == 300) { if (++x == 300) {
if (session_manager.popping) { if (session_manager.popping) {
#ifdef DEBUG_THREAD_POOL
switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_DEBUG10, switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_DEBUG10,
"Thread pool: running:%d busy:%d popping:%d\n", session_manager.running, session_manager.busy, session_manager.popping); "Thread pool: running:%d busy:%d popping:%d\n", session_manager.running, session_manager.busy, session_manager.popping);
#endif
switch_queue_interrupt_all(session_manager.thread_queue); switch_queue_interrupt_all(session_manager.thread_queue);
x--; x--;
......
Markdown 格式
0%
您添加了 0 到此讨论。请谨慎行事。
请先完成此评论的编辑!
注册 或者 后发表评论