kenmirrors/freeswitch
1
0
Fork 0
mirror of https://github.com/signalwire/freeswitch.git synced 2025-02-22 17:42:39 +00:00
Code Issues Projects Releases Wiki Activity

[core] reduce waits in sqldb

Browse Source
This commit is contained in:
Anthony Minessale 2018-12-14 20:54:03 +00:00 committed by Andrey Volk
parent 5260075cc2
commit 1b32bda60e
1 changed files with 7 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
src/switch_core_sqldb.c
View File

@ -1630,6 +1630,7 @@ struct switch_sql_queue_manager {
uint32_t max_trans; uint32_t max_trans;
uint32_t confirm; uint32_t confirm;
uint8_t paused; uint8_t paused;
int skip_wait;
}; };
static int qm_wake(switch_sql_queue_manager_t *qm) static int qm_wake(switch_sql_queue_manager_t *qm)
@ -1647,6 +1648,7 @@ static int qm_wake(switch_sql_queue_manager_t *qm)
return 1; return 1;
} else { } else {
if (switch_mutex_trylock(qm->cond2_mutex) == SWITCH_STATUS_SUCCESS) { if (switch_mutex_trylock(qm->cond2_mutex) == SWITCH_STATUS_SUCCESS) {
qm->skip_wait++;
switch_mutex_unlock(qm->cond2_mutex); switch_mutex_unlock(qm->cond2_mutex);
} else { } else {
if (++tries < 10) { if (++tries < 10) {
@ -2351,7 +2353,11 @@ static void *SWITCH_THREAD_FUNC switch_user_sql_thread(switch_thread_t *thread,
if ((lc = qm_ttl(qm)) == 0) { if ((lc = qm_ttl(qm)) == 0) {
switch_mutex_lock(qm->cond2_mutex); switch_mutex_lock(qm->cond2_mutex);
switch_thread_cond_wait(qm->cond, qm->cond_mutex); if (qm->skip_wait > 0) {
qm->skip_wait--;
} else {
switch_thread_cond_wait(qm->cond, qm->cond_mutex);
}
switch_mutex_unlock(qm->cond2_mutex); switch_mutex_unlock(qm->cond2_mutex);
} }