kenmirrors
/
freeswitch
mirror of https://github.com/signalwire/freeswitch.git
1
0
Fork 0
Code Issues Projects Releases Wiki Activity

wrong turn in albakoykee

This commit is contained in:
Anthony Minessale 2012-11-22 15:19:38 -06:00
parent c157239294
commit 66e85c8d71
1 changed files with 3 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
src/switch_core_sqldb.c
View File

@ -1409,9 +1409,9 @@ SWITCH_DECLARE(switch_status_t) switch_sql_queue_manager_push_confirm(switch_sql
switch_mutex_lock(qm->mutex);
switch_queue_push(qm->sql_queue[pos], dup ? strdup(sql) : (char *)sql);
written = qm->written[pos];
written = qm->pre_written[pos];
size = switch_sql_queue_manager_size(qm, pos);
want = written + qm->pre_written[pos] + size;
want = written + size;
switch_mutex_unlock(qm->mutex);
qm_wake(qm);
@ -1494,12 +1494,6 @@ static uint32_t do_trans(switch_sql_queue_manager_t *qm)
if (io_mutex) switch_mutex_lock(io_mutex);
switch_mutex_lock(qm->mutex);
for (i = 0; i < qm->numq; i++) {
qm->pre_written[i] = 0;
}
switch_mutex_unlock(qm->mutex);
if (!zstr(qm->pre_trans_execute)) {
switch_cache_db_execute_sql_real(qm->event_db, qm->pre_trans_execute, &errmsg);
if (errmsg) {
@ -1623,7 +1617,7 @@ static uint32_t do_trans(switch_sql_queue_manager_t *qm)
switch_mutex_lock(qm->mutex);
for (i = 0; i < qm->numq; i++) {
qm->written[i] += qm->pre_written[i];
qm->written[i] = qm->pre_written[i];
}
switch_mutex_unlock(qm->mutex);