From 0e2f33e2b095239991f9fe48aa47894a96f0f0ce Mon Sep 17 00:00:00 2001 From: Anthony Minessale Date: Fri, 26 Oct 2012 16:12:44 -0500 Subject: [PATCH] add mutex for good measure --- src/switch_core_sqldb.c | 8 +++++++- 1 file changed, 7 insertions(+), 1 deletion(-) diff --git a/src/switch_core_sqldb.c b/src/switch_core_sqldb.c index 9807d9905d..45ea99ba29 100644 --- a/src/switch_core_sqldb.c +++ b/src/switch_core_sqldb.c @@ -1504,7 +1504,13 @@ static void *SWITCH_THREAD_FUNC switch_user_sql_thread(switch_thread_t *thread, if (!proceed) { for (i = 0; i < qm->numq; i++) { - if (switch_queue_trypop(qm->sql_queue[i], &pop) == SWITCH_STATUS_SUCCESS) { + switch_status_t status; + + switch_mutex_lock(qm->mutex); + status = switch_queue_trypop(qm->sql_queue[i], &pop); + switch_mutex_unlock(qm->mutex); + + if (status == SWITCH_STATUS_SUCCESS) { if (sql_manager.thread_running != 1) { if (pop) { switch_cache_db_execute_sql(qm->event_db, (char *) pop, NULL);